feat: 销售线索通知

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/pojo/bo/content/context/PotentialCustomerNotifyContext.java

@@ -55,28 +55,15 @@ public class PotentialCustomerNotifyContext {
      */
     private List<StaffClerkRelationDTO> staffClerkRelations;
 
-
+    /**
+     * 导购新销售线索统计
+     */
     List<PotentialCustomerStaticsBO> customerStaticsBos;
 
-
-    public static NoticeMessageBO buildMessage(String clerkId, int count) {
-
-
-        NoticeMessageBO noticeMessageBO = new NoticeMessageBO();
-//        noticeMessageBO.setCategoryType(POTENTIAL_CUSTOMER_NOTIFY.getCategory());
-//        noticeMessageBO.setMessageType(POTENTIAL_CUSTOMER_NOTIFY.getType());
-//        noticeMessageBO.setClerkId(clerkId);
-//        noticeMessageBO.setStoreId("");
-//        noticeMessageBO.setTitle("销售线索通知");
-//        noticeMessageBO.setTemplateCode(POTENTIAL_CUSTOMER_NOTIFY.getTemplateCode());
-//        noticeMessageBO.setDescription(String.format("新增%s个客户的销售线索，请及时跟进", count));
-//        noticeMessageBO.setEnterpriseId(this.enterpriseId);
-//        noticeMessageBO.setRelationId(this.clerkId);
-//        noticeMessageBO.setMessageContent();
-        return noticeMessageBO;
-    }
-
-
+    /**
+     * 构建小程序消息通知
+     * @return
+     */
     public List<NoticeMessageBO> buildNoticeMessage() {
         if (CollectionUtils.isEmpty(this.customerStaticsBos)) {
             return Collections.emptyList();

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/content/adaptor/PotentialCustomerNotifyBuilder.java

@@ -113,6 +113,7 @@ public class PotentialCustomerNotifyBuilder {
     public void sendHaoBanNotifyMessage(PotentialCustomerNotifyContext context) {
         List<NoticeMessageBO> noticeMessageBos = context.buildNoticeMessage();
         if (CollectionUtils.isEmpty(noticeMessageBos)) {
+            log.info("好办消息为空");
             return;
         }
         noticeMessageService.addNoticeMessageBatch(noticeMessageBos);
@@ -125,6 +126,7 @@ public class PotentialCustomerNotifyBuilder {
      */
     public void sendApplicationMessage(PotentialCustomerNotifyContext context) {
         if (CollectionUtils.isEmpty(context.getCustomerStaticsBos()) || CollectionUtils.isEmpty(context.getStaffClerkRelations())) {
+            log.info("发送应用消息 参数缺失 {}");
             return;
         }
         Map<String, PotentialCustomerStaticsBO> customerStaticsBOMap = context.getCustomerStaticsBos()
@@ -134,21 +136,32 @@ public class PotentialCustomerNotifyBuilder {
         Map<String, WxEnterpriseQwDTO> clerkEnterpriseMap = new HashMap<>();
 
         for (StaffClerkRelationDTO staffClerkRelation : context.getStaffClerkRelations()) {
+            PotentialCustomerStaticsBO customerStaticsBO = customerStaticsBOMap.get(staffClerkRelation.getClerkId());
+            if (customerStaticsBO == null || customerStaticsBO.getNum() == null || customerStaticsBO.getNum() == 0) {
+                log.info("导购不存在新访问");
+                continue;
+            }
             String staffId = staffClerkRelation.getStaffId();
             TabHaobanClerkMainStoreRelated temp = clerkMainStoreMap.get(staffId);
+            if (temp == null) {
+                TabHaobanClerkMainStoreRelated tabHaobanClerkMainStoreRelated = clerkMainStoreRelatedService.selectByWxEnterpriseIdAndStoreId(staffId, staffClerkRelation.getWxEnterpriseId());
+                if (tabHaobanClerkMainStoreRelated == null) {
+                    tabHaobanClerkMainStoreRelated = new TabHaobanClerkMainStoreRelated();
+                }
+                clerkMainStoreMap.put(staffId, tabHaobanClerkMainStoreRelated);
+                temp = clerkMainStoreMap.get(staffId);
+            }
+
             if (temp != null) {
                 if (StringUtils.isBlank(temp.getStoreId())) {
                     // 该成员无主门店
+                    log.info("成员无主门店 {}", staffId);
                     continue;
                 }
                 if (StringUtils.isBlank(temp.getStoreId())) {
                     log.info("成员不存在主门店 {}", staffId);
                     continue;
                 }
-                PotentialCustomerStaticsBO customerStaticsBO = customerStaticsBOMap.get(staffClerkRelation.getClerkId());
-                if (customerStaticsBO == null || customerStaticsBO.getNum() == null || customerStaticsBO.getNum() == 0) {
-                    return;
-                }
                 // 需要发送应用消息
                 WxEnterpriseQwDTO wxEnterpriseQwDTO = clerkEnterpriseMap.get(staffClerkRelation.getWxEnterpriseId());
                 if (wxEnterpriseQwDTO == null) {
@@ -157,17 +170,13 @@ public class PotentialCustomerNotifyBuilder {
                 }
                 wxEnterpriseQwDTO = clerkEnterpriseMap.get(staffClerkRelation.getWxEnterpriseId());
                 if (wxEnterpriseQwDTO == null) {
+                    log.info("企业信息不存在 {}", staffClerkRelation.getWxEnterpriseId());
                     return;
                 }
                 QywxXcxSendMessageDTO messageDTO = this.buildApplicationMessage(staffClerkRelation, wxEnterpriseQwDTO, customerStaticsBO.getNum());
-                qywxSuiteApiService.sendMessage(wxEnterpriseQwDTO.getThirdCorpid(), config.getWxSuiteid(), messageDTO);
-                continue;
+                boolean sendMessage = qywxSuiteApiService.sendMessage(wxEnterpriseQwDTO.getThirdCorpid(), config.getWxSuiteid(), messageDTO);
+                log.info("发送应用消息结果 {}", sendMessage);
             }
-            TabHaobanClerkMainStoreRelated tabHaobanClerkMainStoreRelated = clerkMainStoreRelatedService.selectByWxEnterpriseIdAndStoreId(staffId, staffClerkRelation.getWxEnterpriseId());
-            if (tabHaobanClerkMainStoreRelated == null) {
-                tabHaobanClerkMainStoreRelated = new TabHaobanClerkMainStoreRelated();
-            }
-            clerkMainStoreMap.put(staffId, tabHaobanClerkMainStoreRelated);
         }
     }
 

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/content/impl/PotentialCustomerServiceImpl.java

 package com.gic.haoban.manage.service.service.content.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.gic.api.base.commons.Page;
 import com.gic.commons.util.UniqueIdUtils;
 import com.gic.haoban.common.utils.PageUtil;
@@ -155,6 +156,8 @@ public class PotentialCustomerServiceImpl implements PotentialCustomerService {
     @Override
     public void sendPotentialCustomerNotice(PotentialCustomerNotifyContext context) {
 
+        log.info("处理企业{}下的销售线索通知", context.getEnterpriseId());
+
         // 根据企业id + 时间  循环查询时间段内的有新互动记录的导购id 去重
         InteractRecordQO searchQo = new InteractRecordQO();
         searchQo.setEnterpriseId(context.getEnterpriseId());
@@ -162,6 +165,7 @@ public class PotentialCustomerServiceImpl implements PotentialCustomerService {
         searchQo.setEndTime(context.getEndTime());
         List<PotentialCustomerStaticsBO> customerStaticsBos = interactRecordService.staticsClerkNewInteractRecord(searchQo);
         if (CollectionUtils.isEmpty(customerStaticsBos)) {
+            log.info("企业下不存在新增线索的导购 {}", JSON.toJSONString(context));
             return;
         }
         context.setCustomerStaticsBos(customerStaticsBos);

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/content/task/QywxGroupMsgTaskApiServiceImpl.java

@@ -205,8 +205,8 @@ public class QywxGroupMsgTaskApiServiceImpl implements QywxGroupMsgTaskApiServic
      */
     @Override
     public ServiceResponse<Void> potentialCustomerJob(String params) {
-
         Date now = new Date();
+        log.info("potentialCustomerJob 执行销售线索通知 {}", cn.hutool.core.date.DateUtil.format(now, "yyyy-MM-dd HH:mm:ss"));
         int currentHour = cn.hutool.core.date.DateUtil.hour(now, true);
         if (currentHour >= 23 || currentHour < 8) {
             log.info("当前时间处于消息禁发时间, 忽略{}", cn.hutool.core.date.DateUtil.format(now, "yyyy-MM-dd HH:mm:ss"));
@@ -214,6 +214,7 @@ public class QywxGroupMsgTaskApiServiceImpl implements QywxGroupMsgTaskApiServic
         }
         List<String> enterpriseIds = groupMessageService.hasMaterialRightEnterprise();
         if (CollectionUtils.isEmpty(enterpriseIds)) {
+            log.info("开通内容权限的企业为空");
             return ServiceResponse.success();
         }
         Date startTime = cn.hutool.core.date.DateUtil.offsetMinute(now, -30).toJdkDate();

haoban-manage3-service/src/test/java/GroupMessageServiceTest.java

 import com.alibaba.fastjson.JSON;
+import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.util.DateUtil;
 import com.gic.haoban.manage.api.dto.content.log.TriggerCustomerDetailLogDTO;
 import com.gic.haoban.manage.api.enums.content.ClerkShareMaterialType;
@@ -7,8 +8,10 @@ import com.gic.haoban.manage.api.enums.content.TriggerCustomerChannelType;
 import com.gic.haoban.manage.api.service.content.task.QywxGroupMsgTaskApiService;
 import com.gic.haoban.manage.service.pojo.bo.content.ClerkShareLogBO;
 import com.gic.haoban.manage.service.pojo.bo.content.GroupMessageInfoBo;
+import com.gic.haoban.manage.service.pojo.bo.content.context.PotentialCustomerNotifyContext;
 import com.gic.haoban.manage.service.service.content.ClerkShareLogService;
 import com.gic.haoban.manage.service.service.content.GroupMessageService;
+import com.gic.haoban.manage.service.service.content.PotentialCustomerService;
 import com.squareup.moshi.Json;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -33,6 +36,9 @@ public class GroupMessageServiceTest {
     private ClerkShareLogService clerkShareLogService;
     @Autowired
     private QywxGroupMsgTaskApiService qywxGroupMsgTaskApiService;
+    @Autowired
+    PotentialCustomerService potentialCustomerService;
+
     String eid = "ff8080815dacd3a2015dacd3ef5c0000";
 
     String wxEid = "ca66a01b79474c40b3e7c7f93daf1a3b";
@@ -70,4 +76,14 @@ public class GroupMessageServiceTest {
         groupMessageInfoBo.setEndTime(currentTime);
         groupMessageService.handlerGroupMessage(groupMessageInfoBo);
     }
+
+    @Test
+    public void potentialCustomerMessageTest(){
+        PotentialCustomerNotifyContext context = PotentialCustomerNotifyContext.builder()
+                .enterpriseId(eid)
+                .startTime(cn.hutool.core.date.DateUtil.beginOfDay(new Date()))
+                .endTime(cn.hutool.core.date.DateUtil.endOfDay(new Date()))
+                .build();
+        potentialCustomerService.sendPotentialCustomerNotice(context);
+    }
 }