朋友圈重试

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/moment/QwMomentPlanService.java

@@ -52,4 +52,6 @@ public interface QwMomentPlanService {
     void getQwPublishData(Long planId , String cursor) ;
 
     void qwDataTimer(String params);
+
+    void sendRetry(Long qwPlanId);
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/moment/impl/QwMomentPlanServiceImpl.java

@@ -443,6 +443,16 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
         List<String> clerkIdList = clerkList.stream().map(o->o.getClerkId()).collect(Collectors.toList());
         ServiceResponse<String> resp = this.qywxSendService.share(plan.getWxEnterpriseId(),clerkIdList,msg,imageList) ;
         logger.info("发企微朋友={}",JSONObject.toJSONString(resp));
+        // api concurrent out of limit
+        if("45033".equals(resp.getCode())) {
+            CommonMQDTO mq = new CommonMQDTO() ;
+            mq.setType(8) ;
+            Map<String,String> map = new HashMap<>() ;
+            map.put("planId",plan.getPlanId()+"") ;
+            mq.setParams(map);
+            this.haobanCommonMQApiService.putCommonDelayMessage(mq, 300);
+            return;
+        }
         String jobId = resp.getResult() ;
         if(StringUtils.isBlank(jobId)) {
             logger.info("朋友圈调用企微失败={}",plan.getPlanId());
@@ -683,4 +693,11 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
             }
         }
     }
+
+    @Override
+    public void sendRetry(Long qwPlanId) {
+        logger.info("朋友圈重试={}",qwPlanId);
+        TabQwMomentPlan plan = this.qwMomentPlanMapper.getById(qwPlanId) ;
+        this.sendToQiwei(plan);
+    }
 }

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

@@ -166,6 +166,10 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
             int times = Integer.valueOf(map.get("times")) ;
             this.qwMomentPlanAttendService.updateMomentId(attendId,times);
             break;
+        case 8 :
+            Long qwPlanId = Long.valueOf(map.get("planId")) ;
+            this.qwMomentPlanService.sendRetry(qwPlanId);
+            break;
         default:
             break;
         }

haoban-manage3-service/src/test/java/MomentTest.java

@@ -57,27 +57,10 @@ public class MomentTest {
 
 
     @Test
-    public void ddd() {
-           /* QwMomentPlanDTO dto = new QwMomentPlanDTO() ;
-            dto.setPublishType(1);
-            dto.setPublishTime(new Date());
-            dto.setWxEnterpriseId("ca66a01b79474c40b3e7c7f93daf1a3b");
-            dto.setCreatorId("fefd1c81641711e69d0818c58a146fd2");
-            dto.setCreatorName("达摩管理");
-            dto.setEnterpriseId("ff8080815dacd3a2015dacd3ef5c0000");
-            dto.setExecType(1);
-            dto.setExpireDays(10);
-            dto.setPlanClerkType(1);
-            // ,"b2ef17cce11f476b996d0b27ebadf7fb"
-            List<String> clerkIds = Arrays.asList("b2ef17cce11f476b996d0b27ebadf7fb","753a367d709d40a38b17ed25847d3b4b") ;
-            dto.setSelectClerkIdList(clerkIds);
-            this.qwMomentApiService.save(dto) ;*/
-
-/*        Long planId = 772924621895778364L ;
-        TabQwMomentPlan plan = this.qwMomentPlanMapper.getById(planId) ;
-        this.qwMomentPlanService.sendToQiwei(plan);*/
-
-        this.qwMomentPlanService.qwDataTimer("2");
+    public void sendToQw() {
+        Long id = 792759787778540646L ;
+        TabQwMomentPlan plan = this.qwMomentPlanMapper.getById(id) ;
+        this.qwMomentPlanService.sendToQiwei(plan);
     }