feature: holo写入

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

 package com.gic.haoban.manage.service.service.content.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.alibaba.hologres.client.HoloClient;
 import com.alibaba.hologres.client.Put;
 import com.alibaba.hologres.client.model.TableSchema;
@@ -20,6 +22,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
@@ -79,7 +82,10 @@ public class TriggerCustomerDetailServiceImpl implements TriggerCustomerDetailSe
                     .stream()
                     .map(item -> {
                         Put temp = new Put(tableSchema);
-                        temp.setObject("", "");
+                        JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(item));
+                        for (Map.Entry<String, Object> entry : jsonObject.entrySet()) {
+                            temp.setObject(entry.getKey(), entry.getValue());
+                        }
                         return temp;
                     })
                     .collect(Collectors.toList());

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

 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.gic.api.base.commons.Page;
+import com.gic.commons.util.UniqueIdUtils;
 import com.gic.haoban.manage.service.pojo.bo.content.PotentialCustomerBO;
+import com.gic.haoban.manage.service.pojo.bo.content.TriggerCustomerDetailBO;
 import com.gic.haoban.manage.service.pojo.qo.content.PotentialCustomerQO;
 import com.gic.haoban.manage.service.service.MemberQueryService;
 import com.gic.haoban.manage.service.service.content.PotentialCustomerService;
+import com.gic.haoban.manage.service.service.content.TriggerCustomerDetailService;
 import com.gic.member.api.dto.MemberDTO;
 import com.gic.member.api.service.MemberService;
 import org.junit.Test;
@@ -13,6 +16,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
+import java.util.Collections;
+import java.util.Date;
+
 /**
  * @Author MUSI
  * @Date 2023/3/30 10:15 PM
@@ -29,6 +35,8 @@ public class PotentialCustomerServiceTest {
     private MemberService memberService;
     @Autowired
     MemberQueryService memberQueryService;
+    @Autowired
+    private TriggerCustomerDetailService triggerCustomerDetailService;
 
     String eid = "ff8080815dacd3a2015dacd3ef5c0000";
     String wxEid = "ca66a01b79474c40b3e7c7f93daf1a3b";
@@ -56,4 +64,24 @@ public class PotentialCustomerServiceTest {
         JSONObject jsonObject = memberQueryService.queryDataSingle(eid, "ff8080818215878101821949a845003c", null);
         System.out.println(jsonObject.toJSONString());
     }
+
+    @Test
+    public void triggerTest(){
+        TriggerCustomerDetailBO triggerCustomerDetailBO = new TriggerCustomerDetailBO();
+        triggerCustomerDetailBO.setCustomerId("dadadada");
+        triggerCustomerDetailBO.setEnterpriseId(eid);
+        triggerCustomerDetailBO.setWxEnterpriseId(wxEid);
+        triggerCustomerDetailBO.setBizId("12313213");
+        triggerCustomerDetailBO.setBizType(1);
+        triggerCustomerDetailBO.setClerkId(clerkId);
+        triggerCustomerDetailBO.setStaffId(staffId);
+        triggerCustomerDetailBO.setStoreId(staffId);
+        triggerCustomerDetailBO.setChannelType(1);
+        triggerCustomerDetailBO.setCustomerId(staffId);
+        triggerCustomerDetailBO.setCreateTime(new Date());
+        triggerCustomerDetailBO.setUpdateTime(new Date());
+        triggerCustomerDetailBO.setDeleteFlag(1);
+        triggerCustomerDetailBO.setId(UniqueIdUtils.uniqueLong());
+        triggerCustomerDetailService.batchSave(Collections.singletonList(triggerCustomerDetailBO));
+    }
 }