update

initialize/rabbitmq.go

@@ -46,11 +46,11 @@ type MQProc struct{}
 
 // process 消息处理接口
 func (t *MQProc) Process(topic, queuename string, msg *[]byte) {
-	// info := fmt.Sprintf("rabbitmq receive message from: topic[%s] queue[%s] contentLen[%d]",
-	// 	topic,
-	// 	queuename,
-	// 	len(string(*msg)))
-	// global.M2A_LOG.Info(info)
+	info := fmt.Sprintf("rabbitmq receive message from: topic[%s] queue[%s] contentLen[%d]",
+		topic,
+		queuename,
+		len(string(*msg)))
+	global.M2A_LOG.Info(info)
 
 	if funcode, sessionId, bytes, serialNumber, err := t.getRspProtobuf(msg); err == nil && bytes != nil {
 		if sessionId == 0 || funcode == uint32(global.LogoutRsp) || funcode == uint32(global.LoginRsp) {

service/account/login.go

@@ -338,7 +338,7 @@ func Logout(c *gin.Context) (err error) {
 	t, exists := client.Clients[claims.SessionID]
 	if !exists {
 		err = errors.New("获取登录账户信息异常")
-		global.M2A_LOG.Error(err.Error(), zap.Error(err))
+		global.M2A_LOG.Error(err.Error(), zap.Any("SessionID", claims.SessionID), zap.Error(err))
 		return
 	}
 

service/mq/mq.go

@@ -31,7 +31,7 @@ func SendMQ(c *gin.Context, req *request.MQBodyReq) (err error) {
 	t, exists := client.Clients[claims.SessionID]
 	if !exists {
 		err = errors.New("获取登录账户信息异常")
-		global.M2A_LOG.Error(err.Error(), zap.Error(err))
+		global.M2A_LOG.Error(err.Error(), zap.Any("SessionID", claims.SessionID), zap.Error(err))
 		return
 	}
 

service/sign/sign.go

@@ -61,7 +61,7 @@ func AddUser(req request.AddUserReq, userId int) (err error) {
 		SET RECORDSTATUS = 3,
 			UPDATETIME = SYSDATE,
 			AUTHINFO = '%v'
-		WHERE USERID = %v
+		WHERE USERID = %v AND TEMPLATETYPE = 1 
 	`, string(authinfo), userId)
 	if _, err = global.M2A_DB.Exec(sql); err != nil {
 		global.M2A_LOG.Error("【AddUser】 更新用户电子签记录失败", zap.Error(err))
@@ -154,3 +154,50 @@ func CreateContractAndAddSigner(req request.CreateContractAndAddSignerReq, userI
 
 	return
 }
+
+/*
+handleASignCompleted 处理爱签合同签署完成后回调通知
+
+req 异步推送参数
+*/
+func HandleASignCompleted(req map[string]string) (err error) {
+	// 合同签署完成后回调通知示例
+	// String publickey = "MFwwDQcccccxxxxmEz/nw27Ln6AP90ZCMPi+iNF1m9mhNECAwEAAQ==";
+	// String remark = ""; // 若被拒签则会返回拒签原因，拒签原因不参与签名
+	// Map <String, String> map = new HashMap<>();
+	// map.put("action", "signCompleted");
+	// map.put("contractNo", "20221114142140345");
+	// map.put("status", "2");
+	// map.put("signTime", "2022-11-14 14:22:00");
+	// map.put("timestamp", "1668406920005");
+	// map.put("validityTime", "2022-11-24 23:59:59");
+	// String json = JSONObject.toJSONString(map, SerializerFeature.MapSortField);
+	// System.out.println("数据:" + json);
+	// // 计算签名
+	// try {
+	// String sign = "feFfcprGjdmDDqRmxK5qlWlMncX0mc6LJ5agebOGIx2QiAern+6ZRg/SBHOgvHp/+1ywVRdyKNUKxPneETwKPw==";
+	// System.out.println(RSAUtils.rsaSignCheck(sign, json, publickey));
+	// } catch (Exception e) {
+	// 	e.printStackTrace();
+	// }
+
+	// 获取合同编号
+	// contractNo, ok := req["contractNo"]
+	// if !ok {
+	// 	global.M2A_LOG.Error("【HandleASignCompleted】 获取合同编号失败", zap.Any("req", req))
+	// 	return
+	// }
+	// // 获取合同状态
+	// status, ok := req["status"]
+	// if !ok {
+	// 	global.M2A_LOG.Error("【HandleASignCompleted】 获取获取合同状态失败", zap.Any("req", req))
+	// 	return
+	// }
+	// if status == "2" {
+	// 	// 已签约
+	// 	// 下载合同
+
+	// }
+
+	return
+}

service/trade/trade.go

@@ -69,7 +69,7 @@ func TradeConn(c *gin.Context) (err error) {
 	client, exists := client.Clients[claims.SessionID]
 	if !exists {
 		err = errors.New("获取登录账户信息异常")
-		global.M2A_LOG.Error(err.Error())
+		global.M2A_LOG.Error(err.Error(), zap.Any("SessionID", claims.SessionID))
 		return
 	}