群发

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatPlanServiceImpl.java

@@ -34,7 +34,6 @@ import com.gic.haoban.common.utils.DingUtils;
 import com.gic.haoban.manage.api.dto.WxEnterpriseQwDTO;
 import com.gic.haoban.manage.api.dto.chat.GroupChatPlanDTO;
 import com.gic.haoban.manage.api.dto.chat.GroupChatPlanLogDTO;
-import com.gic.haoban.manage.api.dto.chat.GroupChatPlanOwnerLogDTO;
 import com.gic.haoban.manage.api.dto.qdto.chat.GroupChatPlanSearchQDTO;
 import com.gic.haoban.manage.api.enums.PendingTaskTypeEnum;
 import com.gic.haoban.manage.api.enums.chat.PlanSendStatusEnum;
@@ -201,37 +200,42 @@ public class GroupChatPlanServiceImpl implements GroupChatPlanService {
             madidList.add(json.getString("relation_id"));
         }
         int pageNum = 0;
-        int pageSize = 1 ;
-        List<TabGroupChatPlanOwnerLog> ownerList = null ;
+        int pageSize = 1;
+        List<TabGroupChatPlanOwnerLog> ownerList = null;
         while (true) {
-            ownerList = this.groupChatPlanOwnerLogMapper.listForDoPlan(planId, pageNum*pageSize, pageSize) ;
+            ownerList = this.groupChatPlanOwnerLogMapper.listForDoPlan(planId, pageNum * pageSize, pageSize);
             if (CollectionUtils.isEmpty(ownerList)) {
                 break;
             }
             pageNum++;
             for (TabGroupChatPlanOwnerLog ownerLog : ownerList) {
+                try {
                     String staffId = ownerLog.getStaffId();
-                ServiceResponse<String> sendResp = qywxSendService.sendChatMessage(wxEnterpriseId, staffId, madidList);
+                    ServiceResponse<String> sendResp = qywxSendService.sendChatMessage(wxEnterpriseId, staffId,
+                            madidList);
                     if (sendResp.isSuccess()) {
                         String msgid = sendResp.getResult();
                         ownerLog.setMsgid(msgid);
                         ownerLog.setSendStatus(PlanSendStatusEnum.TO_BE_SEND.getCode());
                     } else {
-                    ownerLog.setRemark(sendResp.getMessage());
+                        ownerLog.setRemark(sendResp.getMessage().substring(0, 500));
                         ownerLog.setSendStatus(PlanSendStatusEnum.FAIL.getCode());
                     }
                     ownerLog.setWxEnterpriseId(wxEnterpriseId);
                     this.groupChatPlanOwnerLogService.update(ownerLog);
                     // 代办
-                if (StringUtils.isNotBlank(ownerLog.getClerkId())) {
+                    if (StringUtils.isNotBlank(ownerLog.getClerkId()) && StringUtils.isNotBlank(ownerLog.getMsgid())) {
                         this.savePendTask(ownerLog, plan);
                     }
+                } catch (Exception e) {
+                    logger.info("群群发任务异常,ownerLog={}", ownerLog.getOwnerLogId());
+                }
             }
         }
     }
 
     private void savePendTask(TabGroupChatPlanOwnerLog ownerLog, TabGroupChatPlan plan) {
-        logger.info("创建待办数据：{}", JSON.toJSONString(ownerLog));
+        logger.info("创建导购待办={}", JSON.toJSONString(ownerLog));
         PendingTaskBO task = new PendingTaskBO();
         task.setRelationId(ownerLog.getOwnerLogId() + "");
         task.setBusinessId(ownerLog.getPlanId() + "");

haoban-manage3-service/src/main/resources/mapper/chat/GroupChatPlanMapper.xml

@@ -102,7 +102,7 @@
 	</insert>
 
 	<!-- =====================删除==================== -->
-	<update id="deleteById" parameterType="long">
+	<update id="deleteById">
 		UPDATE
 		tab_haoban_group_chat_plan SET delete_flag = 1 , modifier_id =
 		#{clerkId} , modifier_name = #{clerkName} , update_time=now()  WHERE plan_id = #{planId}