单向好友

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

+package com.gic.haoban.manage.api.dto;
+
+import java.io.Serializable;
+
+public class CommonDataMQDTO implements Serializable {
+
+    /**
+    * @Fields serialVersionUID : TODO(用一句话描述这个变量表示什么)
+    */
+    private static final long serialVersionUID = -5681421708810402425L;
+    // 1删除日报定时 2无部门成员修复
+    private int type;
+    private Object params;
+
+    public int getType() {
+        return type;
+    }
+
+    public void setType(int type) {
+        this.type = type;
+    }
+
+    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

 package com.gic.haoban.manage.api.service;
 
+import com.gic.haoban.manage.api.dto.CommonDataMQDTO;
 import com.gic.haoban.manage.api.dto.CommonMQDTO;
 
 import java.util.List;
@@ -16,10 +17,14 @@ public interface HaobanCommonMQApiService {
 
     public void putCommonMessage(CommonMQDTO dto);
 
+    public void putDataMessage(CommonDataMQDTO dto);
+    
     public void putCommonDelayMessage(CommonMQDTO dto , int delay);
 
     public void commonHandler(String message);
 
+    public void commonDataHandler(String message) ;
+    
     public void welcomeMQ(String params) ;
 
     public void putToNoticeMemberMQ(String enterpriseId, List<String> memberIdList) ;

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.Date;
 import java.util.List;
 import java.util.Map;
 
 import com.alibaba.fastjson.JSONArray;
+import com.gic.haoban.manage.api.dto.CommonDataMQDTO;
+import com.gic.haoban.manage.service.dao.mapper.TabHaobanExternalClerkRelatedMapper;
 import com.gic.haoban.manage.service.service.StaffClerkRelationService;
 import com.gic.commons.util.StringUtil;
 import com.gic.haoban.manage.api.dto.MemberUnionidWechatAccountQDTO;
@@ -51,6 +54,8 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
     private StaffClerkRelationService staffClerkRelationService ;
     @Autowired
     private HaobanMenuService haobanMenuService ;
+    @Autowired
+    private TabHaobanExternalClerkRelatedMapper externalClerkRelatedMapper ;
 
     @Override
     public void putCommonMessage(CommonMQDTO dto) {
@@ -65,6 +70,37 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
     }
 
     @Override
+    public void putDataMessage(CommonDataMQDTO dto) {
+        String message = JSONObject.toJSONString(dto);
+        log.info("加入好办通用队列params={}", message);
+        try {
+            mqClient.sendCommonMessage("haobanDataCommonRouter", message,
+                    "com.gic.haoban.manage.api.service.HaobanCommonMQApiService", "commonDataHandler");
+        } catch (Exception e) {
+            log.error("发送MQ异常",e);
+        }
+    }
+
+    @Override
+    public void commonDataHandler(String message) {
+        CommonDataMQDTO dto = JSON.parseObject(message, CommonDataMQDTO.class);
+        switch (dto.getType()) {
+            case 1:
+                String listStr = dto.getParams().toString() ;
+                JSONArray list = JSONArray.parseArray(listStr) ;
+                for(int i=0;i<list.size();i++) {
+                    JSONObject json  = list.getJSONObject(i) ;
+                    String id = json.getString("id") ;
+                    Date delTime = json.getDate("delTime") ;
+                    this.externalClerkRelatedMapper.updateHalfTime(id,delTime);
+                }
+                break;
+            default:
+                break;
+        }
+    }
+
+    @Override
     public void putCommonDelayMessage(CommonMQDTO dto, int delay) {
         String message = JSONObject.toJSONString(dto);
         log.info("加入好办延时通用队列params={}", message);
@@ -75,6 +111,7 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
         }
     }
 
+
     @Override
     public void commonHandler(String message) {
         log.info("接收好办通用队列params={}", message);

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

 package com.gic.haoban.manage.service.service.out.impl;
 
 import com.alibaba.fastjson.JSONObject;
-import com.alibaba.hologres.com.google.common.collect.RangeMap;
-import com.gic.haoban.manage.api.dto.ExternalClerkRelatedDTO;
+import com.gic.haoban.manage.api.dto.CommonDataMQDTO;
+import com.gic.haoban.manage.api.service.HaobanCommonMQApiService;
 import com.gic.haoban.manage.service.dao.mapper.TabHaobanExternalClerkRelatedMapper;
 import com.gic.haoban.manage.service.dao.mapper.hm.WxUserAddLogMapper;
 import com.gic.haoban.manage.service.entity.TabHaobanExternalClerkRelated;
 import com.gic.haoban.manage.service.entity.hm.TabWxUserAddLog;
 import com.gic.haoban.manage.service.service.QywxErrorLogService;
 import com.gic.haoban.manage.service.service.chat.GroupChatDataService;
+import com.gic.haoban.manage.service.util.DingUtils;
 import com.gic.haoban.manage.service.util.HBQwMonitorUtils;
 import com.gic.redis.data.util.RedisUtil;
 import org.apache.commons.collections.CollectionUtils;
@@ -53,6 +54,8 @@ public class HaobanTimerApiServiceImpl implements HaobanTimerApiService {
     private TabHaobanExternalClerkRelatedMapper  externalClerkRelatedMapper ;
     @Autowired
     private WxUserAddLogMapper wxUserAddLogMapper ;
+    @Autowired
+    private HaobanCommonMQApiService haobanCommonMQApiService ;
     
 
     @Override
@@ -146,19 +149,30 @@ public class HaobanTimerApiServiceImpl implements HaobanTimerApiService {
                    if(CollectionUtils.isNotEmpty(logList)) {
                        map = logList.stream().collect(Collectors.toMap(TabWxUserAddLog::getExternalUserid, o -> o.getCreateTime(), (k1, k2) -> k1));
                    }
+                   List<JSONObject> jsonList = new ArrayList<>() ;
                    for(TabHaobanExternalClerkRelated dto : list) {
+                        JSONObject json = new JSONObject() ;
+                       json.put("id",dto.getExternalClerkRelatedId()) ;
                        if(null != map.get(dto.getExternalUserId())) {
-                            this.externalClerkRelatedMapper.updateHalfTime(dto.getExternalClerkRelatedId(),map.get(dto.getExternalUserId()));
+                            //this.externalClerkRelatedMapper.updateHalfTime(dto.getExternalClerkRelatedId(),map.get(dto.getExternalUserId()));
+                            json.put("delTime",map.get(dto.getExternalUserId())) ;
                         }else {
-                            this.externalClerkRelatedMapper.updateHalfTime(dto.getExternalClerkRelatedId(),dto.getUpdateTime());
+                           // this.externalClerkRelatedMapper.updateHalfTime(dto.getExternalClerkRelatedId(),dto.getUpdateTime());
+                           json.put("delTime",dto.getUpdateTime()) ;
                         }
+                        jsonList.add(json) ;
                    }
+                   CommonDataMQDTO data = new CommonDataMQDTO() ;
+                   data.setType(1);
+                   data.setParams(jsonList);
+                   this.haobanCommonMQApiService.putDataMessage(data);
                 }
             }else {
                 break;
             }
         }
         mapCache.put("wxEnterpriseId","1") ;
+        DingUtils.send("halfTimer告警,wxEnterpriseId="+wxEnterpriseId, null, false);
         log.info("结束单向数据={}",wxEnterpriseId);
     }
 }