refact(注册开通)：流程调整

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-biz/src/main/java/com/yeejoin/amos/boot/module/jyjc/biz/service/impl/JyjcOpeningApplicationServiceImpl.java

@@ -38,6 +38,7 @@ import com.yeejoin.amos.boot.module.jyjc.api.model.*;
 import com.yeejoin.amos.boot.module.jyjc.api.service.IJyjcOpeningApplicationService;
 import com.yeejoin.amos.boot.module.jyjc.api.vo.JyjcOpeningApplicationVo;
 import com.yeejoin.amos.boot.module.jyjc.biz.config.BaseException;
+import com.yeejoin.amos.boot.module.jyjc.biz.feign.MessageFeignClient;
 import com.yeejoin.amos.boot.module.jyjc.biz.feign.TzsServiceFeignClient;
 import com.yeejoin.amos.boot.module.jyjc.biz.service.TaskModelServiceImpl;
 import com.yeejoin.amos.boot.module.ymt.api.dto.TzBaseEnterpriseInfoDto;
@@ -153,6 +154,9 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
     @Value("${open.app.msg.detail.path:/mixuap?appId=1742358052905971713&id=1947557820039720961&lfrom=studio}")
     private String msgDetailPath;
 
+    @Autowired
+    private MessageFeignClient messageFeignClient;
+
     /**
      * 编辑、工作台暂存逻辑
      *
@@ -789,7 +793,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
         messageModel.setTerminal("WEB");
         messageModel.setRoutePath(msgDetailPath);
         messageModel.setCompanyType(companyType);
-        Systemctl.messageClient.create(messageModel);
+        messageFeignClient.create(messageModel);
     }
 
     private void saveLicenseData2Company(JyjcOpeningApplication jyjcOpeningApplication) {
@@ -947,9 +951,14 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
     }
 
     private void deleteMsg(String taskCode, Long sequenceNbr) {
+        // 流程到发起单位时删除之前的消息
         if(WorkFlowStatusEnum.OPENING_APPLICATION_SUBMIT.getCode().equals(taskCode)){
             // 按照relationId查询
+            List<MessageModel> messageModels = messageFeignClient.listByRelationId(sequenceNbr + "").getResult();
             // 查询结果删除接口
+            if(!messageModels.isEmpty()){
+                messageFeignClient.delete(messageModels.stream().map(e-> String.valueOf(e.getSequenceNbr())).collect(Collectors.joining(",")));
+            }
         }
     }