Commit 731b359b by songyinghui

feature: 客户触达日志

parent 349058b6
...@@ -29,13 +29,11 @@ public class HoloDataSource implements InitializingBean, DisposableBean { ...@@ -29,13 +29,11 @@ public class HoloDataSource implements InitializingBean, DisposableBean {
String holoUserName = appConfig.getProperty("holo.username", ""); String holoUserName = appConfig.getProperty("holo.username", "");
String holoPassword = appConfig.getProperty("holo.password", ""); String holoPassword = appConfig.getProperty("holo.password", "");
HoloConfig holoConfig = new HoloConfig(); HoloConfig holoConfig = new HoloConfig();
//holoConfig.setJdbcUrl("jdbc:postgresql://hgprecn-cn-lbj34oq08002-cn-shanghai.hologres.aliyuncs.com:80/gicdatadev.public");
//holoConfig.setUsername("LTAI5tGn2YicKmgcyTiJDV59");
//holoConfig.setPassword("iOp7cICESPZIvIjJRtTmLnCd4gT1Qy");
holoConfig.setJdbcUrl(holoUrl); holoConfig.setJdbcUrl(holoUrl);
holoConfig.setUsername(holoUserName); holoConfig.setUsername(holoUserName);
holoConfig.setPassword(holoPassword); holoConfig.setPassword(holoPassword);
client = new HoloClient(holoConfig); this.client = new HoloClient(holoConfig);
this.client.setAsyncCommit(false);
}catch (Exception ex) { }catch (Exception ex) {
log.info("初始化client 异常 >>>", ex); log.info("初始化client 异常 >>>", ex);
} }
......
...@@ -96,7 +96,6 @@ public class TriggerCustomerDetailServiceImpl implements TriggerCustomerDetailSe ...@@ -96,7 +96,6 @@ public class TriggerCustomerDetailServiceImpl implements TriggerCustomerDetailSe
}) })
.collect(Collectors.toList()); .collect(Collectors.toList());
client.put(puts); client.put(puts);
client.flush();
log.info("客户触达写数据组完成 >>>>>"); log.info("客户触达写数据组完成 >>>>>");
}catch (Exception ex) { }catch (Exception ex) {
log.info("数据组写入异常", ex); log.info("数据组写入异常", ex);
......
...@@ -74,7 +74,7 @@ public class PotentialCustomerServiceTest { ...@@ -74,7 +74,7 @@ public class PotentialCustomerServiceTest {
triggerCustomerDetailBO.setCustomerId("dadadada"); triggerCustomerDetailBO.setCustomerId("dadadada");
triggerCustomerDetailBO.setEnterpriseId(eid); triggerCustomerDetailBO.setEnterpriseId(eid);
triggerCustomerDetailBO.setWxEnterpriseId(wxEid); triggerCustomerDetailBO.setWxEnterpriseId(wxEid);
triggerCustomerDetailBO.setBizId("musiceshitrigger"); triggerCustomerDetailBO.setBizId("musidanxieru091203flush");
triggerCustomerDetailBO.setBizType(1); triggerCustomerDetailBO.setBizType(1);
triggerCustomerDetailBO.setClerkId(clerkId); triggerCustomerDetailBO.setClerkId(clerkId);
triggerCustomerDetailBO.setStaffId(staffId); triggerCustomerDetailBO.setStaffId(staffId);
...@@ -87,7 +87,7 @@ public class PotentialCustomerServiceTest { ...@@ -87,7 +87,7 @@ public class PotentialCustomerServiceTest {
triggerCustomerDetailBO.setId(UniqueIdUtils.uniqueLong()); triggerCustomerDetailBO.setId(UniqueIdUtils.uniqueLong());
triggerCustomerDetailService.batchSave(Collections.singletonList(triggerCustomerDetailBO)); triggerCustomerDetailService.batchSave(Collections.singletonList(triggerCustomerDetailBO));
triggerCustomerDetailBO.setId(UniqueIdUtils.uniqueLong()); triggerCustomerDetailBO.setId(UniqueIdUtils.uniqueLong());
triggerCustomerDetailBO.setBizId("musitets22222"); triggerCustomerDetailBO.setBizId("musidanxieru091204");
triggerCustomerDetailService.batchSave(Collections.singletonList(triggerCustomerDetailBO)); triggerCustomerDetailService.batchSave(Collections.singletonList(triggerCustomerDetailBO));
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment