朋友圈

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

@@ -178,8 +178,7 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
                 try {
                     // initTaskClerk
                     logger.info("立即开始执行");
-                    this.initTaskClerk(jsonObject.toJSONString());
-                   // clientInstance.sendMessage("qwMomentInitClerkMQ", jsonObject.toJSONString(),10);
+                    clientInstance.sendMessage("qwMomentInitClerkMQ", jsonObject.toJSONString(),10);
                 } catch (Exception e) {
                     throw new RuntimeException(e);
                 }
@@ -379,6 +378,9 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
         ServiceResponse<String> resp = this.qywxSendService.share(plan.getWxEnterpriseId(),Arrays.asList("b2ef17cce11f476b996d0b27ebadf7fb"),msg,imageList) ;
         logger.info("发企微朋友={}",JSONObject.toJSONString(resp));
         String jobId = resp.getResult() ;
+        if(StringUtils.isBlank(jobId)) {
+
+        }
         this.qwMomentPlanMapper.updateJobid(plan.getPlanId(),jobId) ;
         WxEnterpriseQwDTO qwDTO = this.wxEnterpriseService.getQwInfo(plan.getWxEnterpriseId());
         ServiceResponse<Object> resp2 = this.qywxExternalUserService.getMomentTaskResult(qwDTO.getThirdCorpid(),
@@ -387,8 +389,9 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
         if(null != resp2.getResult()) {
             String moment_id = resp2.getResult().toString() ;
             this.qwMomentPlanMapper.updateMomentId(plan.getPlanId(),moment_id);
-        }
+        }else {
 
+        }
     }
 
     @Override