重试次数

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/dto/send/DealQwSendDTO.java

@@ -14,6 +14,11 @@ public class DealQwSendDTO implements Serializable {
     private Integer refreshType;
 
     /**
+     * 重试次数
+     */
+    private Integer tryCount;
+
+    /**
      * 获取msgId数据
      */
     private FinishQwSendBO finishQwSend;
@@ -220,6 +225,14 @@ public class DealQwSendDTO implements Serializable {
         this.refreshType = refreshType;
     }
 
+    public Integer getTryCount() {
+        return tryCount;
+    }
+
+    public void setTryCount(Integer tryCount) {
+        this.tryCount = tryCount;
+    }
+
     public FinishQwSendBO getFinishQwSend() {
         return finishQwSend;
     }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/send/QwSendApiServiceImpl.java

@@ -31,7 +31,7 @@ public class QwSendApiServiceImpl implements QwSendApiService {
         DealQwSendDTO dealQwSendDTO = JSONObject.parseObject(message, DealQwSendDTO.class);
         Integer refreshType = dealQwSendDTO.getRefreshType();
         if (Objects.equals(refreshType,1)) {
-            qwSendMsgService.finishQwSend(dealQwSendDTO.getFinishQwSend());
+            qwSendMsgService.finishQwSend(dealQwSendDTO.getFinishQwSend(),dealQwSendDTO.getTryCount());
         } else if (Objects.equals(refreshType, 2)) {
             qwSendMsgService.refreshQwSendLog(dealQwSendDTO.getQwSendMsg());
         }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/send/QwSendMsgService.java

@@ -16,7 +16,7 @@ public interface QwSendMsgService {
      * 完成企微群发获取msgId
      * @param finishQwSendBO
      */
-    void finishQwSend(DealQwSendDTO.FinishQwSendBO finishQwSendBO);
+    void finishQwSend(DealQwSendDTO.FinishQwSendBO finishQwSendBO,Integer tryCount);
 
     /**
      * 刷新企微群结果

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/send/impl/QwSendMsgServiceImpl.java

@@ -56,7 +56,7 @@ public class QwSendMsgServiceImpl implements QwSendMsgService {
     private MessageApiService messageApiService;
 
     @Override
-    public void finishQwSend(DealQwSendDTO.FinishQwSendBO finishQwSendBO) {
+    public void finishQwSend(DealQwSendDTO.FinishQwSendBO finishQwSendBO,Integer tryCount) {
         String clerkId = finishQwSendBO.getClerkId();
         String staffId = finishQwSendBO.getStaffId();
         Date sendTime = finishQwSendBO.getSendTime();
@@ -83,10 +83,17 @@ public class QwSendMsgServiceImpl implements QwSendMsgService {
             dealQwSendDTO.setQwSendMsg(qwSendMsgBO);
             MqUtils.sendMessageToMQ("qwSendRefreshByMQ", JSON.toJSONString(dealQwSendDTO), 60);
         }else {
+            if (tryCount != null && tryCount >= 5) {
+                return;
+            }
+            if (tryCount == null) {
+                tryCount = 0;
+            }
             // 重新刷新
             DealQwSendDTO dealQwSendDTO = new DealQwSendDTO();
             dealQwSendDTO.setRefreshType(1);
             dealQwSendDTO.setFinishQwSend(finishQwSendBO);
+            dealQwSendDTO.setTryCount(++tryCount);
             MqUtils.sendMessageToMQ("qwSendRefreshByMQ", JSON.toJSONString(dealQwSendDTO), 60);
         }
     }