停用商户-删除好办定时

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

@@ -3,24 +3,28 @@ package com.gic.haoban.manage.api.dto;
 import java.io.Serializable;
 
 public class CommonMQDTO implements Serializable {
-    
+
     /**
     * @Fields serialVersionUID : TODO(用一句话描述这个变量表示什么)
     */
     private static final long serialVersionUID = -5681421708810402425L;
-    
-    private int type ;
-    private String params ;
+
+    private int type;
+    private Object params;
+
     public int getType() {
         return type;
     }
-    public String getParams() {
-        return params;
-    }
+
     public void setType(int type) {
         this.type = type;
     }
-    public void setParams(String params) {
+
+    public Object getParams() {
+        return params;
+    }
+
+    public void setParams(Object params) {
         this.params = params;
     }
 }

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/service/HaobanCommonMQApiService.java

@@ -11,7 +11,9 @@ import com.gic.haoban.manage.api.dto.CommonMQDTO;
 *
  */
 public interface HaobanCommonMQApiService {
-    
-    public void commonHandler(CommonMQDTO dto) ;
-    
+
+    public void putCommonMessage(CommonMQDTO dto);
+
+    public void commonHandler(String message);
+
 }

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

 package com.gic.haoban.manage.service.service.out.impl;
 
+import java.util.Map;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.gic.commons.util.GICMQClientUtil;
 import com.gic.haoban.manage.api.dto.CommonMQDTO;
 import com.gic.haoban.manage.api.service.HaobanCommonMQApiService;
+import com.gic.mq.sdk.GicMQClient;
+import com.gic.quartz.api.dto.QuartzTaskDTO;
+import com.gic.quartz.api.service.QuartzService;
 
 @Service("haobanCommonMQApiService")
 public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
+
+    private final Logger log = LogManager.getLogger(HaobanCommonMQApiService.class);
+
+    private static GicMQClient mqClient = GICMQClientUtil.getClientInstance();
     
+    @Autowired
+    private QuartzService quartzService ;
+
     @Override
-    public void commonHandler(CommonMQDTO dto) {
-        
+    public void putCommonMessage(CommonMQDTO dto) {
+        String message = JSONObject.toJSONString(dto);
+        log.info("接收信息={}",message);
+        try {
+            mqClient.sendCommonMessage("marketingCommonRouter", message,
+                    "com.gic.haoban.manage.api.service.HaobanCommonMQApiService", "commonHandler");
+        } catch (Exception e) {
+            log.error("发送MQ异常");
+            e.printStackTrace();
+        }
+    }
+
+    @Override
+    public void commonHandler(String message) {
+        CommonMQDTO dto = JSON.parseObject(message, CommonMQDTO.class);
+        // 好办停用,删除定时
+        if(dto.getType()==1) {
+            Map<String,String> map = (Map<String, String>) dto.getParams() ;
+            String enterpriseId = map.get("enterpriseId") ;
+            this.deleteQuartz(enterpriseId);
+        }
     }
     
-} 
+    private void deleteQuartz(String enterpriseId) {
+        log.info("删除好办定时eid={}",enterpriseId);
+        QuartzTaskDTO task = new QuartzTaskDTO();
+        task.setTaskService("com.gic.haoban.app.daily.api.service.DailyReportJobApiService");
+        task.setTaskMethod("callBack");
+        task.setReferId(enterpriseId);
+        this.quartzService.delQuartzTask(task);
+    }
+}

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

@@ -3,8 +3,10 @@ package com.gic.haoban.manage.service.service.out.impl;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
+import java.util.Map;
 import java.util.Objects;
 import java.util.Set;
 
@@ -25,6 +27,7 @@ import com.gic.enterprise.api.dto.EnterpriseUsingPermissionDto;
 import com.gic.enterprise.api.service.EnterpriseUseForbidService;
 import com.gic.haoban.base.api.common.BasePageInfo;
 import com.gic.haoban.common.utils.PageUtil;
+import com.gic.haoban.manage.api.dto.CommonMQDTO;
 import com.gic.haoban.manage.api.dto.MiniprogramSettingDTO;
 import com.gic.haoban.manage.api.dto.QywxCorpInfoSimpleDTO;
 import com.gic.haoban.manage.api.dto.SecretSettingDTO;
@@ -34,6 +37,7 @@ import com.gic.haoban.manage.api.dto.WxEnterpriseDTO;
 import com.gic.haoban.manage.api.dto.WxEnterpriseQwDTO;
 import com.gic.haoban.manage.api.dto.YwWxEnterpriseDTO;
 import com.gic.haoban.manage.api.enums.SecretTypeEnum;
+import com.gic.haoban.manage.api.service.HaobanCommonMQApiService;
 import com.gic.haoban.manage.api.service.WxEnterpriseApiService;
 import com.gic.haoban.manage.service.config.Config;
 import com.gic.haoban.manage.service.dao.mapper.TabHaobanWelcomeMapper;
@@ -79,6 +83,8 @@ public class WxEnterpriseApiServiceImpl implements WxEnterpriseApiService {
     private QywxUserApiService qywxUserApiService;
     @Autowired
     private EnterpriseUseForbidService enterpriseUseForbidService;
+    @Autowired
+    private HaobanCommonMQApiService haobanCommonMQApiService ;
 
     @Override
     public void callbackReviceEnterprise(QywxCorpInfoSimpleDTO dto) {
@@ -479,6 +485,12 @@ public class WxEnterpriseApiServiceImpl implements WxEnterpriseApiService {
 
     @Override
     public void stopHaoban(String enterpriseId) {
+        log.info("停用好办eid={}",enterpriseId);
         this.wxEnterpriseService.stopHaoban(enterpriseId);
+        CommonMQDTO dto = new CommonMQDTO();
+        dto.setType(1);
+        Map<String,String> map = new HashMap<>() ;
+        map.put("enterpriseId", enterpriseId) ;
+        this.haobanCommonMQApiService.putCommonMessage(dto);
     }
 }