feature: 客户触达逻辑

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

@@ -96,6 +96,8 @@ public class TriggerCustomerDetailServiceImpl implements TriggerCustomerDetailSe
                     })
                     .collect(Collectors.toList());
             client.put(puts);
+            client.flush();
+            log.info("客户触达写数据组完成 >>>>>");
         }catch (Exception ex) {
             log.info("数据组写入异常", ex);
         }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/content/message/InteractRecordMessageListener.java

@@ -57,7 +57,7 @@ public class InteractRecordMessageListener implements MessageListener<String, St
         Config config = ConfigService.getAppConfig();
         String envKey = config.getProperty("bury.point.env.app.key", "");
         if (!StringUtils.equalsIgnoreCase(envKey, recordMessageBO.getAppKey())) {
-            log.info("埋点数据环境正确 config.env: {}, appKey: {}", envKey, recordMessageBO.getAppKey());
+            log.info("埋点数据环境不正确 config.env: {}, appKey: {}", envKey, recordMessageBO.getAppKey());
             return;
         }
         if (recordMessageBO.getEventType() == null || !dealEventType.contains(recordMessageBO.getEventType())) {

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

@@ -70,10 +70,11 @@ public class PotentialCustomerServiceTest {
     @Test
     public void triggerTest(){
         TriggerCustomerDetailBO triggerCustomerDetailBO = new TriggerCustomerDetailBO();
+        triggerCustomerDetailBO.setId(UniqueIdUtils.uniqueLong());
         triggerCustomerDetailBO.setCustomerId("dadadada");
         triggerCustomerDetailBO.setEnterpriseId(eid);
         triggerCustomerDetailBO.setWxEnterpriseId(wxEid);
-        triggerCustomerDetailBO.setBizId("12313213");
+        triggerCustomerDetailBO.setBizId("musiceshitrigger");
         triggerCustomerDetailBO.setBizType(1);
         triggerCustomerDetailBO.setClerkId(clerkId);
         triggerCustomerDetailBO.setStaffId(staffId);
@@ -85,10 +86,9 @@ public class PotentialCustomerServiceTest {
         triggerCustomerDetailBO.setDeleteFlag(1);
         triggerCustomerDetailBO.setId(UniqueIdUtils.uniqueLong());
         triggerCustomerDetailService.batchSave(Collections.singletonList(triggerCustomerDetailBO));
+        triggerCustomerDetailBO.setId(UniqueIdUtils.uniqueLong());
+        triggerCustomerDetailBO.setBizId("musitets22222");
+        triggerCustomerDetailService.batchSave(Collections.singletonList(triggerCustomerDetailBO));
 
-        SerializeConfig serializeConfig = new SerializeConfig();
-        serializeConfig.setPropertyNamingStrategy(PropertyNamingStrategy.SnakeCase);
-        JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(triggerCustomerDetailBO, serializeConfig));
-        System.out.println(jsonObject.toJSONString());
     }
 }