添加线程发送钉钉申诉

attendance-performance-manager/src/main/java/com/mortals/xhx/common/utils/SendAppealDingDingMsgThread.java

+package com.mortals.xhx.common.utils;
+
+import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson.JSONObject;
+import com.mortals.framework.common.Rest;
+import com.mortals.xhx.base.system.message.MessageService;
+import com.mortals.xhx.common.code.PerformTypeEnum;
+import com.mortals.xhx.common.code.YesNoEnum;
+import com.mortals.xhx.module.dingding.CheckDingMsg;
+import com.mortals.xhx.module.dingding.personal.service.IDingPersonService;
+import com.mortals.xhx.module.perform.model.PerformAttendAppealEntity;
+import com.mortals.xhx.module.staff.model.StaffEntity;
+import com.mortals.xhx.module.staff.service.StaffService;
+import com.mortals.xhx.utils.SpringUtils;
+import lombok.NonNull;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Date;
+
+
+@RequiredArgsConstructor
+@Slf4j
+public class SendAppealDingDingMsgThread implements Runnable {
+
+    private IDingPersonService dingPersonService;
+
+    private StaffService staffService;
+
+    private MessageService messageService;
+
+    @NonNull
+    private PerformAttendAppealEntity entity;
+
+
+    @Override
+    public void run() {
+        String ruleStr = String.format("%s/%s/%s", PerformTypeEnum.考勤绩效.getDesc(), entity.getCategoryName(), entity.getRuleName());
+
+        dingPersonService = SpringUtils.getBean(IDingPersonService.class);
+        staffService = SpringUtils.getBean(StaffService.class);
+        messageService = SpringUtils.getBean(MessageService.class);
+
+        StaffEntity staffCache = staffService.getCache(entity.getStaffId().toString());
+        Rest<String> personRest = dingPersonService.getPersonByMobile(staffCache.getPhoneNumber());
+        if (YesNoEnum.YES.getValue() == personRest.getCode()) {
+            CheckDingMsg checkDingMsg = new CheckDingMsg();
+            checkDingMsg.setUserIds(personRest.getData());
+            checkDingMsg.setDateTime(DateUtil.formatDateTime(entity.getAppealTime() == null ? new Date() : entity.getAppealTime()));
+            checkDingMsg.setRuleStr(ruleStr);
+            checkDingMsg.setScore(entity.getScore().toString());
+            checkDingMsg.setAppealResult(entity.getAppealResult());
+            checkDingMsg.setAppealDesc(entity.getAppealDesc());
+
+
+            Rest<String> msgRest = messageService.sendDingTalkAppealMsg(checkDingMsg);
+
+            log.info("钉钉消息发送结果：{}", JSONObject.toJSONString(msgRest));
+        } else {
+            log.error("根据手机号码获取人员错误，msg:{}", personRest.getMsg());
+        }
+
+
+    }
+
+}

attendance-performance-manager/src/main/java/com/mortals/xhx/module/perform/service/impl/PerformAttendAppealServiceImpl.java

@@ -8,8 +8,10 @@ import com.mortals.framework.model.OrderCol;
 import com.mortals.framework.model.PageInfo;
 import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
 import com.mortals.framework.util.DateUtils;
+import com.mortals.framework.util.ThreadPool;
 import com.mortals.xhx.base.system.message.MessageService;
 import com.mortals.xhx.common.code.*;
+import com.mortals.xhx.common.utils.SendAppealDingDingMsgThread;
 import com.mortals.xhx.module.check.model.*;
 import com.mortals.xhx.module.check.service.*;
 import com.mortals.xhx.module.dingding.CheckDingMsg;
@@ -87,6 +89,10 @@ public class PerformAttendAppealServiceImpl extends AbstractCRUDServiceImpl<Perf
                 checkDingMsg.setAppealResult(entity.getAppealResult());
                 checkDingMsg.setAppealDesc(entity.getAppealDesc());
 
+
+
+
+
                 Rest<String> msgRest = messageService.sendDingTalkAppealMsg(checkDingMsg);
             } else {
                 log.error("根据手机号码获取人员错误，msg:{}", personRest.getMsg());
@@ -119,7 +125,10 @@ public class PerformAttendAppealServiceImpl extends AbstractCRUDServiceImpl<Perf
             }
         }
         String appealMsg = "申诉成功，返回所扣分数，申诉ID:" + appeal.getId().toString();
-       // sendCheckDingTalk(appealEntity);
+        //线程发送
+        SendAppealDingDingMsgThread sendAppealDingDingMsgThread = new SendAppealDingDingMsgThread(appealEntity);
+        ThreadPool.getInstance().execute(sendAppealDingDingMsgThread);
+        //sendCheckDingTalk(appealEntity);
         log.info(appealMsg);
 
         if (appealEntity.getAppealResult() == AppealResultEnum.通过.getValue()) {