Commit a2bc2d8f by 徐高华

朋友圈重试

parent 5b7dcf52
...@@ -443,6 +443,9 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService { ...@@ -443,6 +443,9 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
List<String> clerkIdList = clerkList.stream().map(o->o.getClerkId()).collect(Collectors.toList()); List<String> clerkIdList = clerkList.stream().map(o->o.getClerkId()).collect(Collectors.toList());
ServiceResponse<String> resp = this.qywxSendService.share(plan.getWxEnterpriseId(),clerkIdList,msg,imageList) ; ServiceResponse<String> resp = this.qywxSendService.share(plan.getWxEnterpriseId(),clerkIdList,msg,imageList) ;
logger.info("发企微朋友={}",JSONObject.toJSONString(resp)); logger.info("发企微朋友={}",JSONObject.toJSONString(resp));
String jobId = resp.getResult() ;
if(StringUtils.isBlank(jobId)) {
logger.info("朋友圈调用企微失败={}",plan.getPlanId());
// api concurrent out of limit // api concurrent out of limit
if("45033".equals(resp.getCode())) { if("45033".equals(resp.getCode())) {
CommonMQDTO mq = new CommonMQDTO() ; CommonMQDTO mq = new CommonMQDTO() ;
...@@ -453,9 +456,6 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService { ...@@ -453,9 +456,6 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
this.haobanCommonMQApiService.putCommonDelayMessage(mq, 300); this.haobanCommonMQApiService.putCommonDelayMessage(mq, 300);
return; return;
} }
String jobId = resp.getResult() ;
if(StringUtils.isBlank(jobId)) {
logger.info("朋友圈调用企微失败={}",plan.getPlanId());
return; return;
} }
for (QwMomentPlanAttendDTO dto : clerkList) { for (QwMomentPlanAttendDTO dto : clerkList) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment