From 31cfa5f152473eaa950567fc994b1bf62aa11c33 Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Sat, 8 Feb 2025 17:59:14 +0800
Subject: [PATCH] =?UTF-8?q?feat(REQ-3300)=20-=20=E6=B7=BB=E5=8A=A0=20IM=20?=
 =?UTF-8?q?=E7=BE=A4=E4=B8=AD=E9=87=8D=E6=96=B0=E5=8F=91=E8=B5=B7=E5=90=8E?=
 =?UTF-8?q?=EF=BC=8C=E9=9C=80=E8=A6=81=E9=87=8D=E6=96=B0=E5=8F=91=E9=80=81?=
 =?UTF-8?q?=E5=8D=A1=E7=89=87=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/ChangeRecordServiceImpl.java | 37 +++++++++++++++++++
 1 file changed, 37 insertions(+)

diff --git a/visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/service/impl/ChangeRecordServiceImpl.java b/visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/service/impl/ChangeRecordServiceImpl.java
index df170b5c..d90d8fd7 100644
--- a/visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/service/impl/ChangeRecordServiceImpl.java
+++ b/visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/service/impl/ChangeRecordServiceImpl.java
@@ -22,7 +22,10 @@ import cn.axzo.maokai.api.vo.request.CooperateShipQueryReq;
 import cn.axzo.maokai.api.vo.request.OrgNodeUserBriefInfoListReq;
 import cn.axzo.maokai.api.vo.response.CooperateShipResp;
 import cn.axzo.maokai.api.vo.response.OrgNodeUserBriefInfoResp;
+import cn.axzo.maokai.api.vo.response.OrganizationalUnitVO;
 import cn.axzo.maokai.common.enums.SaasCooperateShipCooperateTypeEnum;
+import cn.axzo.msg.center.service.dto.PeerPerson;
+import cn.axzo.msg.center.service.pending.request.CardSendRequest;
 import cn.axzo.nanopart.visa.api.enums.VisaBillTypeEnum;
 import cn.axzo.nanopart.visa.api.enums.VisaChangeFieldEnum;
 import cn.axzo.nanopart.visa.api.enums.VisaConfirmBizTypeEnum;
@@ -98,6 +101,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.collections.MapUtils;
 import org.apache.groovy.util.Maps;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
@@ -131,6 +135,7 @@ import static cn.axzo.nanopart.visa.api.constant.VisaConstant.FORM_FIELD_TOPIC;
 import static cn.axzo.nanopart.visa.api.constant.VisaConstant.IM_GROUP_BIZ_INFO_INITIATOR_WORKSPACE_ID;
 import static cn.axzo.nanopart.visa.api.constant.VisaConstant.IM_GROUP_BIZ_INFO_VISA_ID;
 import static cn.axzo.nanopart.visa.api.constant.VisaConstant.IM_GROUP_BIZ_INFO_VISA_TYPE;
+import static cn.axzo.nanopart.visa.api.constant.VisaConstant.MSG_CENTER_APP_CODE;
 import static cn.axzo.nanopart.visa.api.constant.VisaConstant.WORKFLOW_PENDING_TOPIC;
 import static cn.axzo.nanopart.visa.api.constant.VisaConstant.WORKFLOW_VAR_VISA_TYPE_KEY;
 
@@ -202,6 +207,8 @@ public class ChangeRecordServiceImpl extends ServiceImpl<ChangeRecordDao, Change
 
     @Resource
     private VisaCooperateShipGateway visaCooperateShipGateway;
+    @Autowired
+    private ChangeRecordService changeRecordService;
 
     /**
      * 状态变更
@@ -1266,6 +1273,8 @@ public class ChangeRecordServiceImpl extends ServiceImpl<ChangeRecordDao, Change
 
     @Override
     public void reDecision(ChangeRecordButtonOperationReq req) {
+        ChangeRecord visa = changeRecordService.getById(req.getVisaId());
+        AssertUtil.notNull(visa, "未找到变洽签单据");
         validOperationPermission(req.getVisaId(), req.getOperatorPersonId(), req.getOperatorOuId(), req.getOperatorWorkspaceId());
 
         ImGroupOperationClearReq build = new ImGroupOperationClearReq();
@@ -1273,6 +1282,34 @@ public class ChangeRecordServiceImpl extends ServiceImpl<ChangeRecordDao, Change
         build.setImGroupId(req.getImGroupId());
         build.setClearAll(true);
         changeRecordRelationService.clearImOperationParticipate(build);
+
+        // 重新发送卡片
+        CardSendRequest cardRequest = new CardSendRequest();
+        cardRequest.setAppCode(MSG_CENTER_APP_CODE);
+        cardRequest.setTemplateCode(refreshableConfiguration.getImGroupCardTemplateCode());
+        cardRequest.setBizCode(IM_GROUP_BIZ_INFO_VISA_ID + ":" + visa.getId());
+        cardRequest.setSender(PeerPerson.create(req.getOperatorPersonId(), req.getOperatorOuId(), req.getOperatorWorkspaceId()));
+        cardRequest.setImSenderAccountAppType(AppTypeEnum.CMP);
+        cardRequest.setImReceiveAccounts(Sets.newHashSet(String.valueOf(visa.getImGroupId())));
+
+        OrganizationalUnitVO unitInfo = organizationalUnitGateway.getUnitInfo(req.getOperatorOuId());
+        PersonProfileDto profile = visaProfileGateway.getProfile(req.getOperatorPersonId());
+        String amountDesc = "不变";
+        if (visa.getAmountChange().compareTo(BigDecimal.ZERO) > 0) {
+            amountDesc = "增加" + visa.getAmountChange().toPlainString() + "元";
+        } else if (visa.getAmountChange().compareTo(BigDecimal.ZERO) < 0) {
+            amountDesc = "减少" + visa.getAmountChange().toPlainString() + "元";
+        }
+
+        cardRequest.setBizParam(new JSONObject(Maps.of(
+                "topic", visa.getTopic(),
+                "reason", visa.getReason(),
+                "initiatorName", profile.getRealName(),
+                "initiatorUnitName", unitInfo.getName(),
+                "visaType", visa.getType().getDesc(),
+                "amountChange", amountDesc
+        )));
+        msgCenterGateway.sendCardToCroup(cardRequest);
     }
 
     @Override