画布

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

@@ -8,7 +8,7 @@ public class CommonMQDTO implements Serializable {
     * @Fields serialVersionUID : TODO(用一句话描述这个变量表示什么)
     */
     private static final long serialVersionUID = -5681421708810402425L;
-    // 1删除日报定时 2无部门成员修复 3 通知会员好友关系 4社群终止
+    // 1删除日报定时 2无部门成员修复 3 通知会员好友关系 4社群终止 5 刷新社群群发结果
     private int type;
     private Object params;
 

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

@@ -855,6 +855,12 @@ public class GroupChatPlanServiceImpl implements GroupChatPlanService {
             if(null != msgid) {
                 logger.info("获取msgid={},{}",ownerLogId,msgid);
                 this.groupChatPlanOwnerLogMapper.updateMsgid(ownerLogId,msgid);
+                CommonMQDTO mq = new CommonMQDTO() ;
+                mq.setType(5) ;
+                JSONObject json = new JSONObject() ;
+                json.put("ownerLogId",ownerLogId) ;
+                mq.setParams(json.toJSONString());
+                this.haobanCommonMQApiService.putCommonDelayMessage(mq, 60);
             }
         }catch (Exception e) {
             logger.info("异常",e);

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

@@ -142,6 +142,10 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
             Long planId = Long.valueOf(map.get("planId")) ;
             this.groupChatPlanService.stopByMsgid(planId);
             break ;
+        case 5 :
+            Long ownerLogId = Long.valueOf(map.get("ownerLogId")) ;
+            this.groupChatPlanService.doPlanSendInfo(ownerLogId);
+            break;
         default:
             break;
         }