合同签署成功回调添加队列监听

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/MqProducer.java

 package com.mmc.iuav.user.mq;
 
+import com.mmc.iuav.user.model.fdd.dto.ContractInfoDTO;
 import com.mmc.iuav.user.model.vo.UserAccountVO;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
 
 /**
  * @author: zj
@@ -13,7 +10,15 @@ import org.springframework.stereotype.Component;
 public interface MqProducer {
     /**
      * 用户信息变更
+     *
      * @param userAccountVO
      */
     public void sentUserInfoChangedMsg(UserAccountVO userAccountVO);
+
+    /**
+     * 合同签署完成
+     *
+     * @param contractInfoDTO
+     */
+    public void sentFinishOrderSign(ContractInfoDTO contractInfoDTO);
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/constant/RabbitmqConstant.java

@@ -24,4 +24,11 @@ public class RabbitmqConstant {
      */
     public final static String USER_TOP_UP_SUCCESS_QUEUE = "USER_TOP_UP_SUCCESS_QUEUE";
     public final static String USER_TOP_UP_SUCCESS_ROUTING_KEY = "USER_TOP_UP_SUCCESS_ROUTING_KEY";
+
+    /**
+     * 合同签署成功队列、routing_key
+     */
+    public final static String ORDER_SIGN_EXCHANGE = "ORDER_SIGN_EXCHANGE";
+    public final static String ORDER_SIGN_FINISH_QUEUE = "ORDER_SIGN_FINISH_QUEUE";
+    public final static String ORDER_SIGN_SUCCESS_ROUTING_KEY = "ORDER_SIGN_SUCCESS_ROUTING_KEY";
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/impl/MqProducerImpl.java

 package com.mmc.iuav.user.mq.impl;
 
 import com.alibaba.fastjson2.JSONObject;
+import com.mmc.iuav.user.model.fdd.dto.ContractInfoDTO;
 import com.mmc.iuav.user.model.vo.UserAccountVO;
 import com.mmc.iuav.user.mq.MqProducer;
 import com.mmc.iuav.user.mq.constant.RabbitmqConstant;
@@ -24,4 +25,10 @@ public class MqProducerImpl implements MqProducer {
         log.info("sentUserInfoChangedMsg:{}", JSONObject.toJSONString(userAccountVO));
         rabbitTemplate.convertAndSend(RabbitmqConstant.USER_INFO_UPDATE_FANOUT_EXCHANGE, "", JSONObject.toJSONString(userAccountVO));
     }
+
+    @Override
+    public void sentFinishOrderSign(ContractInfoDTO contractInfoDTO) {
+        log.info("sentUserInfoChangedMsg:{}", JSONObject.toJSONString(contractInfoDTO));
+        rabbitTemplate.convertAndSend(RabbitmqConstant.ORDER_SIGN_EXCHANGE, RabbitmqConstant.ORDER_SIGN_SUCCESS_ROUTING_KEY, JSONObject.toJSONString(contractInfoDTO));
+    }
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/fdd/impl/ContractServiceImpl.java

@@ -15,6 +15,7 @@ import com.mmc.iuav.user.entity.fdd.UserFddDO;
 import com.mmc.iuav.user.model.dto.LoginSuccessDTO;
 import com.mmc.iuav.user.model.fdd.dto.ContractInfoDTO;
 import com.mmc.iuav.user.model.fdd.vo.ContractVO;
+import com.mmc.iuav.user.mq.MqProducer;
 import com.mmc.iuav.user.service.fdd.ContractService;
 import com.mmc.iuav.user.service.fdd.SealManageService;
 import com.mmc.iuav.user.util.TDateUtil;
@@ -40,6 +41,8 @@ public class ContractServiceImpl implements ContractService {
     ContractDao contractDao;
     @Resource
     SealManageService sealManageService;
+    @Resource
+    private MqProducer mqProducer;
 
     /**
      * 上传合同
@@ -189,6 +192,10 @@ public class ContractServiceImpl implements ContractService {
             updateSignStatus.setSignStatus(4);
             updateSignStatus.setBRemark(resultDesc);
             updateSignStatus.setSingerTime(new Date());
+            // 同步订单状态
+            ContractInfoDTO contractInfoDTO = contractInfoDO.buildContractInfoDTO();
+            contractInfoDTO.setSignStatus(4);
+            mqProducer.sentFinishOrderSign(contractInfoDTO);
         } else if (contractInfoDO.getSignStatus() == 2 && FddConstant.SIGN_FAIL.equals(resultCode) && contractInfoDO.getBTransactionId().equals(transactionId)) {
             // 乙方公司签章失败
             updateSignStatus.setSignStatus(3);