|
|
@@ -55,13 +55,8 @@ func (r *QhjAgreementConfig) buildSql() string {
|
|
|
sqlId.AndEx("t.agreementtype", r.AGREEMENTTYPE, r.AGREEMENTTYPE > 0)
|
|
|
sqlId.AndEx("t.agreementfrequency", r.AGREEMENTFREQUENCY, r.AGREEMENTFREQUENCY > 0)
|
|
|
sqlId.AndEx("t.isvalid", r.ISVALID, r.ISVALID > 0)
|
|
|
- if r.AGREEMENTNO != "" {
|
|
|
- sqlId.JoinFormat(" and t.agreementno like '%%%v%%'", r.AGREEMENTNO)
|
|
|
- }
|
|
|
- if r.AGREEMENTNAME != "" {
|
|
|
- sqlId.JoinFormat(" and t.agreementname like '%%%v%%'", r.AGREEMENTNAME)
|
|
|
- }
|
|
|
-
|
|
|
+ sqlId.AndLike("t.agreementno", r.AGREEMENTNO)
|
|
|
+ sqlId.AndLike("t.agreementname", r.AGREEMENTNAME)
|
|
|
return sqlId.String()
|
|
|
}
|
|
|
|
|
|
@@ -112,13 +107,8 @@ func (r *QhjAgreementChangeLog) buildSql() string {
|
|
|
sqlId.AndEx("t.agreementid", r.AGREEMENTID, r.AGREEMENTID > 0)
|
|
|
sqlId.AndEx("t.agreementversion", r.AGREEMENTVERSION, r.AGREEMENTVERSION > 0)
|
|
|
sqlId.AndEx("t.agreementtype", r.AGREEMENTTYPE, r.AGREEMENTTYPE > 0)
|
|
|
-
|
|
|
- if r.AGREEMENTNO != "" {
|
|
|
- sqlId.JoinFormat(" and t.agreementno like '%%%v%%'", r.AGREEMENTNO)
|
|
|
- }
|
|
|
- if r.AGREEMENTNAME != "" {
|
|
|
- sqlId.JoinFormat(" and t.agreementname like '%%%v%%'", r.AGREEMENTNAME)
|
|
|
- }
|
|
|
+ sqlId.AndLike("t.agreementno", r.AGREEMENTNO)
|
|
|
+ sqlId.AndLike("t.agreementname", r.AGREEMENTNAME)
|
|
|
|
|
|
return sqlId.String()
|
|
|
}
|
|
|
@@ -144,6 +134,7 @@ type QhjNodeAgreementConfig struct {
|
|
|
GOODSID int32 `json:"goodsid" xorm:"GOODSID" form:"goodsid"` // 商品ID [默认为0, NodeType>=3 的为商品值]
|
|
|
AGREEMENTNO string `json:"agreementno" xorm:"AGREEMENTNO" form:"agreementno"` // 协议编号
|
|
|
AGREEMENTNAME string `json:"agreementname" xorm:"AGREEMENTNAME" form:"agreementname"` // 协议名称
|
|
|
+ AGREEMENTCONTENT string `json:"agreementcontent" xorm:"AGREEMENTCONTENT" form:"agreementcontent"` // 协议内容
|
|
|
}
|
|
|
|
|
|
func (r *QhjNodeAgreementConfig) calc() {
|
|
|
@@ -170,12 +161,8 @@ func (r *QhjNodeAgreementConfig) buildSql() string {
|
|
|
sqlId.AndEx("t.agreementid", r.AGREEMENTID, r.AGREEMENTID > 0)
|
|
|
sqlId.AndEx("t.agreementtype", r.AGREEMENTTYPE, r.AGREEMENTTYPE > 0)
|
|
|
sqlId.AndEx("t.agreementversion", r.AGREEMENTVERSION, r.AGREEMENTVERSION > 0)
|
|
|
- if r.AGREEMENTNO != "" {
|
|
|
- sqlId.JoinFormat(" and c.agreementno like '%%%v%%'", r.AGREEMENTNO)
|
|
|
- }
|
|
|
- if r.AGREEMENTNAME != "" {
|
|
|
- sqlId.JoinFormat(" and c.agreementname like '%%%v%%'", r.AGREEMENTNAME)
|
|
|
- }
|
|
|
+ sqlId.AndLike("c.agreementno", r.AGREEMENTNO)
|
|
|
+ sqlId.AndLike("c.agreementname", r.AGREEMENTNAME)
|
|
|
return sqlId.String()
|
|
|
}
|
|
|
|
|
|
@@ -227,9 +214,7 @@ func (r *QhjCustomerSignStatus) buildSql() string {
|
|
|
sqlId.AndEx("t.nodetype", r.NODETYPE, r.NODETYPE > 0)
|
|
|
sqlId.AndEx("t.goodsid", r.GOODSID, r.GOODSID > 0)
|
|
|
sqlId.AndEx("t.tradedate", r.TRADEDATE, r.TRADEDATE != "")
|
|
|
- if r.USERNAME != "" {
|
|
|
- sqlId.JoinFormat(" and u.accountname like '%%%v%%'", r.USERNAME)
|
|
|
- }
|
|
|
+ sqlId.AndLike("u.accountname", r.USERNAME)
|
|
|
return sqlId.String()
|
|
|
}
|
|
|
|
|
|
@@ -295,15 +280,9 @@ func (r *QhjCustomerSignLog) buildSql() string {
|
|
|
sqlId.AndEx("t.nodetype", r.NODETYPE, r.NODETYPE > 0)
|
|
|
sqlId.AndEx("t.goodsid", r.GOODSID, r.GOODSID > 0)
|
|
|
sqlId.AndEx("t.agreementid", r.AGREEMENTID, r.AGREEMENTID > 0)
|
|
|
- if r.USERNAME != "" {
|
|
|
- sqlId.JoinFormat(" and u.accountname like '%%%v%%'", r.USERNAME)
|
|
|
- }
|
|
|
- if r.AGREEMENTNO != "" {
|
|
|
- sqlId.JoinFormat(" and c.agreementno like '%%%v%%'", r.AGREEMENTNO)
|
|
|
- }
|
|
|
- if r.AGREEMENTNAME != "" {
|
|
|
- sqlId.JoinFormat(" and c.agreementname like '%%%v%%'", r.AGREEMENTNAME)
|
|
|
- }
|
|
|
+ sqlId.AndLike("u.accountname", r.USERNAME)
|
|
|
+ sqlId.AndLike("c.agreementno", r.AGREEMENTNO)
|
|
|
+ sqlId.AndLike("c.agreementname", r.AGREEMENTNAME)
|
|
|
return sqlId.String()
|
|
|
}
|
|
|
|
|
|
@@ -316,3 +295,71 @@ func (r *QhjCustomerSignLog) GetDataEx() (interface{}, error) {
|
|
|
}
|
|
|
return sData, err
|
|
|
}
|
|
|
+
|
|
|
+// QhjUserNodeCfgAndStatus 客户签约节点和状态
|
|
|
+type QhjUserNodeCfgAndStatus struct {
|
|
|
+ AGREEMENTTYPE int32 `json:"agreementtype" xorm:"AGREEMENTTYPE" form:"agreementtype"` // 协议类型 - 1:注册 2:登录 3:交易
|
|
|
+ AGREEMENTVERSION int32 `json:"agreementversion" xorm:"AGREEMENTVERSION" form:"agreementversion"` // 协议版本号
|
|
|
+ NODETYPE int32 `json:"nodetype" xorm:"NODETYPE" form:"nodetype"` // 环节类型 - 1:注册 2:登录 3:购买 4:融资购买 5:定投 6:卖出
|
|
|
+ CONFIGID int64 `json:"configid" xorm:"CONFIGID" form:"configid"` // 配置(SEQ_QHJ_NODEAGREEMENTCONFIG)
|
|
|
+ AGREEMENTID int64 `json:"agreementid" xorm:"AGREEMENTID" form:"agreementid"` // 协议ID
|
|
|
+ CREATETIME string `json:"createtime" xorm:"CREATETIME" form:"createtime"` // 创建时间
|
|
|
+ GOODSID int32 `json:"goodsid" xorm:"GOODSID" form:"goodsid"` // 商品ID [默认为0, NodeType>=3 的为商品值]
|
|
|
+ AGREEMENTNO string `json:"agreementno" xorm:"AGREEMENTNO" form:"agreementno"` // 协议编号
|
|
|
+ AGREEMENTNAME string `json:"agreementname" xorm:"AGREEMENTNAME" form:"agreementname"` // 协议名称
|
|
|
+ AGREEMENTCONTENT string `json:"agreementcontent" xorm:"AGREEMENTCONTENT" form:"agreementcontent"` // 协议内容
|
|
|
+ USERID int64 `json:"userid" xorm:"USERID" form:"userid"` // 客户ID
|
|
|
+ SIGNTIMESTAMP string `json:"signtimestamp" xorm:"SIGNTIMESTAMP" form:"signtimestamp"` // 签约状态时间戳(最近一次)
|
|
|
+ TRADEDATE string `json:"tradedate" xorm:"TRADEDATE" form:"tradedate"` // 签约交易日(yyyyMMdd)
|
|
|
+}
|
|
|
+
|
|
|
+func (r *QhjUserNodeCfgAndStatus) calc() {
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+func (r *QhjUserNodeCfgAndStatus) buildSql() string {
|
|
|
+ var sqlId utils.SQLVal = "with k as" +
|
|
|
+ " (select *" +
|
|
|
+ " from (select row_number() over(partition by userid, nodetype order by tradedate desc) cnt," +
|
|
|
+ " r.*" +
|
|
|
+ " from QHJ_CustomerSignStatus r)" +
|
|
|
+ " where cnt = 1)" +
|
|
|
+ "SELECT t.CONFIGID," +
|
|
|
+ " t.NODETYPE," +
|
|
|
+ " t.GOODSID," +
|
|
|
+ " t.AGREEMENTID," +
|
|
|
+ " t.AGREEMENTTYPE," +
|
|
|
+ " t.AGREEMENTVERSION," +
|
|
|
+ " to_char(t.CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME," +
|
|
|
+ " c.agreementno," +
|
|
|
+ " c.agreementname," +
|
|
|
+ " to_char(c.agreementcontent) agreementcontent," +
|
|
|
+ " k.userid," +
|
|
|
+ " k.tradedate," +
|
|
|
+ " k.signtimestamp" +
|
|
|
+ " FROM QHJ_NODEAGREEMENTCONFIG t" +
|
|
|
+ " LEFT JOIN QHJ_AGREEMENTCONFIG c" +
|
|
|
+ " on t.agreementid = c.agreementid" +
|
|
|
+ " LEFT JOIN k on k.nodetype=t.nodetype and k.userid=%v" +
|
|
|
+ " WHERE 1 = 1"
|
|
|
+ sqlId.FormatParam(r.USERID)
|
|
|
+ sqlId.AndEx("t.configid", r.CONFIGID, r.CONFIGID > 0)
|
|
|
+ sqlId.AndEx("t.nodetype", r.NODETYPE, r.NODETYPE > 0)
|
|
|
+ sqlId.AndEx("t.goodsid", r.GOODSID, r.GOODSID > 0)
|
|
|
+ sqlId.AndEx("t.agreementid", r.AGREEMENTID, r.AGREEMENTID > 0)
|
|
|
+ sqlId.AndEx("t.agreementtype", r.AGREEMENTTYPE, r.AGREEMENTTYPE > 0)
|
|
|
+ sqlId.AndEx("t.agreementversion", r.AGREEMENTVERSION, r.AGREEMENTVERSION > 0)
|
|
|
+ sqlId.AndLike("c.agreementno", r.AGREEMENTNO)
|
|
|
+ sqlId.AndLike("c.agreementname", r.AGREEMENTNAME)
|
|
|
+ return sqlId.String()
|
|
|
+}
|
|
|
+
|
|
|
+// GetDataEx 获取客户签约节点和状态
|
|
|
+func (r *QhjUserNodeCfgAndStatus) GetDataEx() (interface{}, error) {
|
|
|
+ sData := make([]QhjUserNodeCfgAndStatus, 0)
|
|
|
+ err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
|
|
|
+ for i := range sData {
|
|
|
+ sData[i].calc()
|
|
|
+ }
|
|
|
+ return sData, err
|
|
|
+}
|