From 665151273677c54111bcad27f0bededa7e38fc9b Mon Sep 17 00:00:00 2001
From: yechenhao <yechenhao>
Date: Mon, 18 May 2020 01:59:49 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=A7=E5=B1=8F=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ic/job/count/CountDTOMessageHandler.java  | 110 ------------------
 .../job/detail/DetailDTOMessageHandler.java   | 110 ------------------
 2 files changed, 220 deletions(-)
 delete mode 100644 src/main/java/com/kiisoo/ic/job/count/CountDTOMessageHandler.java
 delete mode 100644 src/main/java/com/kiisoo/ic/job/detail/DetailDTOMessageHandler.java

diff --git a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageHandler.java b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageHandler.java
deleted file mode 100644
index 2119b66..0000000
--- a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageHandler.java
+++ /dev/null
@@ -1,110 +0,0 @@
-package com.kiisoo.ic.job.count;
-
-import com.kiisoo.ic.customer.CustomerService;
-import com.kiisoo.ic.store.entity.PoiStoreStaff;
-import com.kiisoo.ic.store.mapper.PoiStoreStaffDOMapper;
-import com.kiisoo.ic.synchronous.entity.TurnBackDTO;
-import com.kiisoo.ic.synchronous.entity.WxDataDTO;
-import com.kiisoo.ic.wx.service.QWMailListManageService;
-import com.lmax.disruptor.EventHandler;
-import lombok.extern.slf4j.Slf4j;
-import me.chanjar.weixin.cp.bean.WxCpUserExternalContactInfo;
-import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.lang3.StringUtils;
-
-import java.text.SimpleDateFormat;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
-
-@Slf4j
-public class CountDTOMessageHandler implements EventHandler<CountDTOMessage> {
-
-
-    /**
-     * 处理事件， 如入库操作
-     * @param countDtoMessage
-     * @throws Exception
-     */
-    @Override
-    public void onEvent(CountDTOMessage countDtoMessage, long l, boolean b) throws Exception {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        countDtoMessage.setId(UUID.randomUUID().toString());
-        String cpUserId = countDtoMessage.getCpUserId();
-        CustomerService customerService = countDtoMessage.getCustomerService();
-        PoiStoreStaffDOMapper poiStoreStaffDOMapper = countDtoMessage.getPoiStoreStaffDOMapper();
-        QWMailListManageService qwMailListManageService = countDtoMessage.getQwMailListManageService();
-        Long storeId = countDtoMessage.getStoreId();
-        List<Map<String,Object>> tagList = poiStoreStaffDOMapper.selectStaffTagByStoreId(storeId);
-        Map<String,Long> tagMap = new HashMap<>();
-        for (Map<String,Object> map:tagList){
-            tagMap.put((String)map.get("tag"),(Long)map.get("staffId"));
-        }
-
-        List<WxCpUserExternalContactInfo> customers = null;
-        try {
-            customers = qwMailListManageService.getCustomer(cpUserId);
-        }catch (Exception e) {
-            log.error("查询联系人失败："+cpUserId,e);
-        }
-        if (CollectionUtils.isEmpty(customers)){
-            return;
-        }
-        for (WxCpUserExternalContactInfo customer:customers){
-            TurnBackDTO turnBackDTO = new TurnBackDTO();
-
-            WxCpUserExternalContactInfo.ExternalContact externalContact = customer.getExternalContact();
-            List<WxCpUserExternalContactInfo.FollowedUser> followedUsers = customer.getFollowedUsers();
-
-            turnBackDTO.setEaCode("");
-            if (CollectionUtils.isNotEmpty(followedUsers)){
-                for (WxCpUserExternalContactInfo.FollowedUser followedUser:followedUsers){
-                    if (cpUserId.equals(followedUser.getUserId())){
-                        String state = followedUser.getState();
-                        WxCpUserExternalContactInfo.Tag[] tags = followedUser.getTags();
-                        if (StringUtils.isNotBlank(state)){
-                            //判断是否有导购码
-                            turnBackDTO.setEaCode(state);
-                        }else if(tags != null && tags.length > 0 && tagList != null && tagList.size() > 0){
-                            //判断是否有打tag
-                            //todo 根据tag获取导购码
-                            for (int j = 0;j<tags.length;j++){
-                                String groupName = tags[j].getGroupName();
-                                if ("导购".equals(groupName)){
-                                    String tagName = tags[j].getTagName();
-                                    Long staffId = tagMap.get(tagName);
-                                    if (staffId != null){
-                                        PoiStoreStaff poiStoreStaff = poiStoreStaffDOMapper.selectById(staffId);
-                                        if (poiStoreStaff!=null){
-                                            turnBackDTO.setEaCode(poiStoreStaff.getStaffCode());
-                                        }
-                                    }else{
-                                        //todo 绑定在标签导购上，后续删除
-                                        turnBackDTO.setEaCode(tagName);
-                                    }
-                                }
-                            }
-                        }
-                        Long joinTimeL = followedUser.getCreateTime();
-                        Long time=new Long(joinTimeL);
-                        String joinTime = sdf.format(time*1000);
-                        turnBackDTO.setJoinTime(joinTime);
-                    }
-                }
-            }
-            //type 1 微信，type 2 企业微信
-            turnBackDTO.setType(externalContact.getType());
-            turnBackDTO.setUserId(cpUserId);
-            turnBackDTO.setName(externalContact.getName());
-            WxDataDTO wxDataDTO = new WxDataDTO();
-            wxDataDTO.setAvatarUrl(externalContact.getAvatar());
-            wxDataDTO.setUserId(externalContact.getExternalUserId());
-            wxDataDTO.setUnionId(externalContact.getUnionId());
-            turnBackDTO.setWxData(wxDataDTO);
-
-            customerService.turnBack(turnBackDTO);
-        }
-    }
-
-}
diff --git a/src/main/java/com/kiisoo/ic/job/detail/DetailDTOMessageHandler.java b/src/main/java/com/kiisoo/ic/job/detail/DetailDTOMessageHandler.java
deleted file mode 100644
index aa3f34e..0000000
--- a/src/main/java/com/kiisoo/ic/job/detail/DetailDTOMessageHandler.java
+++ /dev/null
@@ -1,110 +0,0 @@
-package com.kiisoo.ic.job.detail;
-
-import com.kiisoo.ic.customer.CustomerService;
-import com.kiisoo.ic.store.entity.PoiStoreStaff;
-import com.kiisoo.ic.store.mapper.PoiStoreStaffDOMapper;
-import com.kiisoo.ic.synchronous.entity.TurnBackDTO;
-import com.kiisoo.ic.synchronous.entity.WxDataDTO;
-import com.kiisoo.ic.wx.service.QWMailListManageService;
-import com.lmax.disruptor.EventHandler;
-import lombok.extern.slf4j.Slf4j;
-import me.chanjar.weixin.cp.bean.WxCpUserExternalContactInfo;
-import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.lang3.StringUtils;
-
-import java.text.SimpleDateFormat;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
-
-@Slf4j
-public class DetailDTOMessageHandler implements EventHandler<DetailDTOMessage> {
-
-
-    /**
-     * 处理事件， 如入库操作
-     * @param detailDtoMessage
-     * @throws Exception
-     */
-    @Override
-    public void onEvent(DetailDTOMessage detailDtoMessage, long l, boolean b) throws Exception {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        detailDtoMessage.setId(UUID.randomUUID().toString());
-        String cpUserId = detailDtoMessage.getCpUserId();
-        CustomerService customerService = detailDtoMessage.getCustomerService();
-        PoiStoreStaffDOMapper poiStoreStaffDOMapper = detailDtoMessage.getPoiStoreStaffDOMapper();
-        QWMailListManageService qwMailListManageService = detailDtoMessage.getQwMailListManageService();
-        Long storeId = detailDtoMessage.getStoreId();
-        List<Map<String,Object>> tagList = poiStoreStaffDOMapper.selectStaffTagByStoreId(storeId);
-        Map<String,Long> tagMap = new HashMap<>();
-        for (Map<String,Object> map:tagList){
-            tagMap.put((String)map.get("tag"),(Long)map.get("staffId"));
-        }
-
-        List<WxCpUserExternalContactInfo> customers = null;
-        try {
-            customers = qwMailListManageService.getCustomer(cpUserId);
-        }catch (Exception e) {
-            log.error("查询联系人失败："+cpUserId,e);
-        }
-        if (CollectionUtils.isEmpty(customers)){
-            return;
-        }
-        for (WxCpUserExternalContactInfo customer:customers){
-            TurnBackDTO turnBackDTO = new TurnBackDTO();
-
-            WxCpUserExternalContactInfo.ExternalContact externalContact = customer.getExternalContact();
-            List<WxCpUserExternalContactInfo.FollowedUser> followedUsers = customer.getFollowedUsers();
-
-            turnBackDTO.setEaCode("");
-            if (CollectionUtils.isNotEmpty(followedUsers)){
-                for (WxCpUserExternalContactInfo.FollowedUser followedUser:followedUsers){
-                    if (cpUserId.equals(followedUser.getUserId())){
-                        String state = followedUser.getState();
-                        WxCpUserExternalContactInfo.Tag[] tags = followedUser.getTags();
-                        if (StringUtils.isNotBlank(state)){
-                            //判断是否有导购码
-                            turnBackDTO.setEaCode(state);
-                        }else if(tags != null && tags.length > 0 && tagList != null && tagList.size() > 0){
-                            //判断是否有打tag
-                            //todo 根据tag获取导购码
-                            for (int j = 0;j<tags.length;j++){
-                                String groupName = tags[j].getGroupName();
-                                if ("导购".equals(groupName)){
-                                    String tagName = tags[j].getTagName();
-                                    Long staffId = tagMap.get(tagName);
-                                    if (staffId != null){
-                                        PoiStoreStaff poiStoreStaff = poiStoreStaffDOMapper.selectById(staffId);
-                                        if (poiStoreStaff!=null){
-                                            turnBackDTO.setEaCode(poiStoreStaff.getStaffCode());
-                                        }
-                                    }else{
-                                        //todo 绑定在标签导购上，后续删除
-                                        turnBackDTO.setEaCode(tagName);
-                                    }
-                                }
-                            }
-                        }
-                        Long joinTimeL = followedUser.getCreateTime();
-                        Long time=new Long(joinTimeL);
-                        String joinTime = sdf.format(time*1000);
-                        turnBackDTO.setJoinTime(joinTime);
-                    }
-                }
-            }
-            //type 1 微信，type 2 企业微信
-            turnBackDTO.setType(externalContact.getType());
-            turnBackDTO.setUserId(cpUserId);
-            turnBackDTO.setName(externalContact.getName());
-            WxDataDTO wxDataDTO = new WxDataDTO();
-            wxDataDTO.setAvatarUrl(externalContact.getAvatar());
-            wxDataDTO.setUserId(externalContact.getExternalUserId());
-            wxDataDTO.setUnionId(externalContact.getUnionId());
-            turnBackDTO.setWxData(wxDataDTO);
-
-            customerService.turnBack(turnBackDTO);
-        }
-    }
-
-}