画布

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/controller/haoban/GroupChatPlanController.java

@@ -7,9 +7,11 @@ import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
+import com.gic.haoban.manage.api.dto.CommonMQDTO;
 import com.gic.haoban.manage.api.dto.chat.*;
 import com.gic.haoban.manage.api.dto.qdto.chat.GroupChatSearchQDTO;
 import com.gic.haoban.manage.api.qdto.StaffSendResultQDTO;
+import com.gic.haoban.manage.api.service.HaobanCommonMQApiService;
 import com.gic.haoban.manage.api.service.chat.GroupChatApiService;
 import com.gic.haoban.manage.web.qo.GroupChatQO;
 import org.apache.commons.lang3.StringUtils;
@@ -43,6 +45,9 @@ public class GroupChatPlanController {
     private GroupChatApiService groupChatApiService ;
     @Autowired
     private MaterialApiService materialApiService;
+    @Autowired
+    private HaobanCommonMQApiService haobanCommonMQApiService ;
+
 
     /**
      * 群计划列表 - 分页
@@ -198,6 +203,14 @@ public class GroupChatPlanController {
             ownerInfo.put("clerkName", owner.getClerkName());
             ownerInfo.put("ownerLogId", owner.getOwnerLogId());
             ownerInfo.put("sendStatus", owner.getSendStatus());
+            if(owner.getSendStatus() > 0)  {
+                CommonMQDTO mq = new CommonMQDTO() ;
+                mq.setType(5) ;
+                Map<String,String> map = new HashMap<>() ;
+                map.put("ownerLogId",ownerLogId+"") ;
+                mq.setParams(map);
+                this.haobanCommonMQApiService.putCommonDelayMessage(mq, 0);
+            }
             ownerInfo.put("dataGetTime",owner.getDataGetTime());
             retMap.put("ownerInfo", ownerInfo);
         }

haoban-manage3-wx/src/main/webapp/WEB-INF/dubbo-haoban-manage-wx.xml

@@ -175,6 +175,7 @@
     <dubbo:reference id="storeRankApiService" interface="com.gic.enterprise.api.service.rank.StoreRankApiService" timeout="100000" retries="0" check="false" />
     <dubbo:reference id="enterpriseWxaLinkService" interface="com.gic.enterprise.api.service.EnterpriseWxaLinkService" timeout="100000" retries="0" check="false" />
     <dubbo:reference id="clerkTaskApiService" interface="com.gic.marketing.pro.api.service.clerktask.ClerkTaskApiService" timeout="100000" retries="0" check="false" />
+    <dubbo:service interface="com.gic.haoban.manage.api.service.HaobanCommonMQApiService" ref="haobanCommonMQApiService" timeout="10000"/>