1.查客户资料增加字段 2.增加查变更记录接口

controllers/ermcp/qryOPLog.go

@@ -0,0 +1,47 @@
+/**
+* @Author: zou.yingbin
+* @Create  : 2021/1/14 11:43
+* @Modify  : 2021/1/14 11:43
+ */
+
+package ermcp
+
+import (
+	"github.com/gin-gonic/gin"
+	"mtp2_if/global/app"
+	"mtp2_if/global/e"
+	"mtp2_if/models"
+	"net/http"
+)
+
+// 查询变更记录请求
+type QryOPLogReq struct {
+	RelatedId string `form:"RelatedId" binding:"required"` // 现货合同ID\套保计划
+}
+
+// 查询变更记录响应
+type QryOPLogRsp models.ErmcpOPLogModel
+
+// QueryChangeLog 查询变更记录
+// @Summary 查询变更记录
+// @Produce json
+// @Security ApiKeyAuth
+// @Param RelatedId query string true "用户ID"
+// @Success 200 {array} QryOPLogRsp
+// @Failure 500 {object} app.Response
+// @Router /Ermcp/QueryChangeLog [get]
+// @Tags 企业风险管理(app)
+func QueryChangeLog(c *gin.Context) {
+	appG := app.Gin{C: c}
+	var req QryOPLogReq
+	if err := c.ShouldBind(&req); err != nil{
+		appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
+		return
+	}
+	m := models.ErmcpOPLogModel{RELATEDID: req.RelatedId}
+	if d, err := m.GetData(); err == nil {
+		appG.Response(http.StatusOK, e.SUCCESS, d)
+	}else{
+		appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
+	}
+}

models/ermcpOPLog.go

@@ -0,0 +1,73 @@
+/**
+* @Author: zou.yingbin
+* @Create  : 2021/1/14 11:44
+* @Modify  : 2021/1/14 11:44
+ */
+
+package models
+
+import (
+	"fmt"
+	"mtp2_if/db"
+	"mtp2_if/mtpcache"
+	"strconv"
+)
+
+//变更变记录
+type ErmcpOPLogModel struct {
+	BIZTYPE            int32   `json:"biztype"  xorm:"'BIZTYPE'"`               // 业务类型 - 1:套保计划 2:现货合同
+	OPERATELOGTYPE     int32   `json:"operatelogtype"  xorm:"'OPERATELOGTYPE'"` // 操作流水类型
+	RELATEDID          string  `json:"relatedid"  xorm:"'RELATEDID'"`           // 现货合同ID\套保计划
+	LOGVALUE           float64 `json:"logvalue"  xorm:"'LOGVALUE'"`             // 数值
+	BEFOREVALUE        float64 `json:"beforevalue"  xorm:"'BEFOREVALUE'"`       // 变更前
+	AFTERVALUE         float64 `json:"aftervalue"  xorm:"'AFTERVALUE'"`         // 变更后
+	UPDATETIME         string  `json:"updatetime"  xorm:"'UPDATETIME'"`         // 更新时间
+	APPLYID            string  `json:"applyid"  xorm:"'APPLYID'"`               // 操作人ID
+	CONTRACTTYPE       int32   `json:"contracttype"  xorm:"'CONTRACTTYPE'"`     // 现货合同类型 - 1:采购 -1:销售
+	OPERATELOGTYPEDESC string  `json:"operatelogtypedesc"`                      // 操作流水类型名称
+	APPLYNAME          string  `json:"applyname"`                               // 操作人名称
+}
+
+func (r *ErmcpOPLogModel) decodeOperateLogType() {
+	//1:点价价格 2:点价数量 3:结算量 4:其它费用 5:追加保证金 6溢短金额 7:调整金额 8:付款金额 9:收款金额 10:退款金额
+	//11:收票金额 12:开票金额 13:提交审核(合同) 14:审核通过(合同) 15:审核拒绝(合同) 16:合同撤回 17:提交审核(计划)
+	//18:审核通过(计划) 19:审核拒绝(计划) 20:计划撤回 21:正常完结(合同) 22:异常终止(合同) 23:退还保证金
+	sDes := []string{"点价价格", "点价数量", "结算量", "其它费用", "追加保证金", "溢短金额", "调整金额", "付款金额", "收款金额", "退款金额",
+		"收票金额", "开票金额", "提交审核(合同)", "审核通过(合同)", "审核拒绝(合同)", "合同撤回", "提交审核(计划)",
+		"审核通过(计划)", "审核拒绝(计划)", "计划撤回", "正常完结(合同)", "异常终止(合同)", "退还保证金"}
+	if r.OPERATELOGTYPE >= 1 && r.OPERATELOGTYPE <= 23 {
+		r.OPERATELOGTYPEDESC = sDes[r.OPERATELOGTYPE-1]
+	}
+}
+
+func (r *ErmcpOPLogModel) buildSql() string {
+	str := "select BIZTYPE," +
+		"       OPERATELOGTYPE," +
+		"       RELATEDID," +
+		"       LOGVALUE," +
+		"       BEFOREVALUE," +
+		"       AFTERVALUE," +
+		"       to_char(UPDATETIME,'yyyy-mm-dd hh:mi:ss') UPDATETIME," +
+		"       APPLYID," +
+		"       CONTRACTTYPE" +
+		"  from ermcp_contractoperatelog t" +
+		"  where t.relatedid=%v"
+	return fmt.Sprintf(str, r.RELATEDID)
+}
+
+//从数据库中获取操作变更数据
+func (r *ErmcpOPLogModel) GetData() ([]ErmcpOPLogModel, error) {
+	e := db.GetEngine()
+	sData := make([]ErmcpOPLogModel, 0)
+	if err := e.SQL(r.buildSql()).Find(&sData); err != nil {
+		return nil, err
+	}
+	// 类型解析成中文,操作人id转换为名称
+	for i := range sData {
+		sData[i].decodeOperateLogType()
+		if id, err := strconv.ParseInt(sData[i].APPLYID, 10, 64); err == nil {
+			sData[i].APPLYNAME = mtpcache.GetUserNameByLoginId(id)
+		}
+	}
+	return sData, nil
+}

models/ermcpUser.go

@@ -16,17 +16,20 @@ import (
 
 // 客户资料结构
 type ErmcpUserModel struct {
-	USERID       int    `json:"userid"  xorm:"'USERID'"`             // 用户ID
-	MEMBERUSERID int    `json:"memberuserid"  xorm:"'MEMBERUSERID'"` //所属机构ID
-	USERINFOTYPE string `json:"userinfotype"  xorm:"'USERINFOTYPE'"` // 客户类型
-	CUSTOMERNAME string `json:"customername"  xorm:"'CUSTOMERNAME'"` // 企业名称
-	CARDTYPE     string `json:"cardtype"  xorm:"'CARDTYPE'"`         // 证件类型
-	CARDNUM      string `json:"cardnum"  xorm:"'CARDNUM'"`           // 证件号码
-	MOBILE       string `json:"mobile"  xorm:"'MOBILE'"`             // 手机号码
-	TELPHONE     string `json:"telphone"  xorm:"'TELPHONE'"`         // 联系电话
-	ADDRESS      string `json:"address"  xorm:"'ADDRESS'"`           // 通讯地址
-	REMARK       string `json:"remark"  xorm:"'REMARK'"`             // 备注
-	Status       string `json:"status"  xorm:"'STATUS'"`             // 账户状态
+	USERID            int    `json:"userid"  xorm:"'USERID'"`                       // 用户ID
+	MEMBERUSERID      int    `json:"memberuserid"  xorm:"'MEMBERUSERID'"`           // 所属机构ID
+	USERINFOTYPE      string `json:"userinfotype"  xorm:"'USERINFOTYPE'"`           // 客户类型
+	CUSTOMERNAME      string `json:"customername"  xorm:"'CUSTOMERNAME'"`           // 企业名称
+	CARDTYPE          string `json:"cardtype"  xorm:"'CARDTYPE'"`                   // 证件类型
+	CARDNUM           string `json:"cardnum"  xorm:"'CARDNUM'"`                     // 证件号码
+	MOBILE            string `json:"mobile"  xorm:"'MOBILE'"`                       // 手机号码
+	TELPHONE          string `json:"telphone"  xorm:"'TELPHONE'"`                   // 联系电话
+	ADDRESS           string `json:"address"  xorm:"'ADDRESS'"`                     // 通讯地址
+	REMARK            string `json:"remark"  xorm:"'REMARK'"`                       // 备注
+	STATUS            int32  `json:"status"  xorm:"'STATUS'"`                       // 账户状态 -  1:待激活 2:待审核 3:待复审 4:正常 5:审核拒绝 6:注销
+	STATUSDESC        string `json:"statusdesc"  xorm:"'STATUSDESC'"`               // 账户状态中文描述
+	ATTACHMENT1       string `json:"attachment1"  xorm:"'ATTACHMENT1'"`              // 附件1
+	CARDFRONTPHOTOURL string `json:"cardfrontphotourl"  xorm:"'CARDFRONTPHOTOURL'"` // 证件正面图片地址
 }
 
 func (r *ErmcpUserModel) buildSql(accStatus string) string {
@@ -41,8 +44,10 @@ func (r *ErmcpUserModel) buildSql(accStatus string) string {
 		"       u.TELPHONE," +
 		"       u.ADDRESS," +
 		"       u.REMARK," +
-		"       t.accountstatus," +
-		"       decode(t.accountstatus,1,'待激活',2,'待审核',3,'待复审',4,'正常',5,'审核拒绝',6,'注销','缺省') Status" +
+		"       u.ATTACHMENT1," +
+		"       u.CARDFRONTPHOTOURL," +
+		"       t.accountstatus status," +
+		"       decode(t.accountstatus,1,'待激活',2,'待审核',3,'待复审',4,'正常',5,'审核拒绝',6,'注销','缺省') StatusDesc" +
 		"  from useraccount t" +
 		"  left join userinfo u" +
 		"    on t.userid = u.userid" +

routers/router.go

@@ -307,6 +307,7 @@ func InitRouter() *gin.Engine {
 		ermcpR.GET("/QueryBusinessJs", ermcp.QueryBusinessJs)
 		ermcpR.GET("/QueryBusinessKx", ermcp.QueryBusinessKx)
 		ermcpR.GET("/QueryBusinessFp", ermcp.QueryBusinessFp)
+		ermcpR.GET("/QueryChangeLog", ermcp.QueryChangeLog)
 	}
 
 	return r