Merge branch 'feature-202309-数据组队列迁移' into developer

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/content/holo/HoloDataSource.java

@@ -34,6 +34,7 @@ public class HoloDataSource implements InitializingBean, DisposableBean {
             holoConfig.setPassword(holoPassword);
             this.client = new HoloClient(holoConfig);
             this.client.setAsyncCommit(false);
+            log.info("holo链接初始化完成");
         }catch (Exception ex) {
             log.info("初始化client 异常 >>>", ex);
         }

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

@@ -59,11 +59,12 @@ public class TriggerCustomerDetailServiceImpl implements TriggerCustomerDetailSe
     @Override
     public void batchSave(List<TriggerCustomerDetailBO> triggerCustomerDetailBos) {
         if (CollectionUtils.isEmpty(triggerCustomerDetailBos)) {
+            log.info("无客户触达日志 >>>> ");
             return;
         }
         Config appConfig = ConfigService.getAppConfig();
         // 当前阶段 0双写 1 只写数据表
-        String triggerProcess = appConfig.getProperty("trigger.write", "0");
+        String triggerProcess = appConfig.getProperty("trigger.write", "1");
         if (StringUtils.equals(triggerProcess, "0")) {
             List<TabHaobanTriggerCustomerDetail> customerDetails = triggerCustomerDetailBos
                     .stream()
@@ -78,7 +79,7 @@ public class TriggerCustomerDetailServiceImpl implements TriggerCustomerDetailSe
         try {
             HoloClient client = holoDataSource.getClient();
             if (client == null) {
-                log.error("数仓数据源链接异常, 请检查！！！！");
+                log.error("数仓数据源链接异常, 请检查！！！！{}", JSON.toJSONString(triggerCustomerDetailBos));
                 return;
             }
             TableSchema tableSchema = client.getTableSchema("tab_haoban_trigger_customer_detail");