刷新es建联时间

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/contact/impl/ContactLogServiceImpl.java

 package com.gic.haoban.manage.service.service.contact.impl;
 
-import cn.hutool.core.date.DateField;
-import cn.hutool.core.date.DateTime;
-import cn.hutool.core.date.DateUnit;
-import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.date.*;
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.gic.api.base.commons.BusinessException;
 import com.gic.api.base.commons.Constant;
 import com.gic.clerk.api.dto.ClerkDTO;
@@ -20,7 +18,11 @@ import com.gic.haoban.manage.service.service.contact.ContactFollowService;
 import com.gic.haoban.manage.service.service.contact.ContactLogService;
 import com.gic.member.api.dto.MemberStoreClerkDTO;
 import com.gic.member.api.dto.MemberStoreDTO;
+import com.gic.member.api.dto.es.MemberDataDTO;
 import com.gic.member.api.service.MemberService;
+import com.gic.search.engine.api.dto.ESResponse;
+import com.gic.search.engine.api.dto.dynamic.DynamicDocDTO;
+import com.gic.search.engine.api.service.dynamic.ESDataDynamicOperationApiService;
 import com.gic.store.goods.service.StoreGoodsService;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
@@ -46,6 +48,8 @@ public class ContactLogServiceImpl implements ContactLogService {
     private StoreService storeService;
     @Autowired
     private MemberService memberService;
+    @Autowired
+    private ESDataDynamicOperationApiService esDataDynamicOperationApiService;
 
 
     @Override
@@ -106,7 +110,9 @@ public class ContactLogServiceImpl implements ContactLogService {
         contactLog.setPotentialTime(null);
         contactLog.setEnterpriseId(enterpriseId);
         contactLogMapper.insert(contactLog);
-        // todo 刷新es建联时间
+        // 刷新es建联时间
+        Long clerkContactTime = Long.parseLong(DateUtil.format(date, DatePattern.PURE_DATETIME_PATTERN));
+        refreshContactTime(enterpriseId, memberId, clerkContactTime);
     }
 
     @Override
@@ -123,7 +129,23 @@ public class ContactLogServiceImpl implements ContactLogService {
             update.setContactStatus(Constant.FLAG_FALSE);
             contactLogMapper.update(update);
         }
-        // todo 清除es建联时间 -1
+        // 清除es建联时间 -1
+        refreshContactTime(lastContactLog.getEnterpriseId(), memberId, -1L);
+    }
+
+    private void refreshContactTime(String enterpriseId,String memberId, Long contactTime) {
+        DynamicDocDTO dynamicDocDTO = new DynamicDocDTO();
+        dynamicDocDTO.setEnterpriseId(enterpriseId);
+        dynamicDocDTO.setColumnCategoryCode("member");
+        MemberDataDTO memberDataDTO = new MemberDataDTO();
+        memberDataDTO.setMemberId(memberId);
+        memberDataDTO.setId(memberId);
+        memberDataDTO.setClerkContactTime(contactTime);
+        JSONObject jsonObject = JSONObject.parseObject(JSON.toJSONString(dynamicDocDTO));
+        dynamicDocDTO.setDocJson(jsonObject);
+        dynamicDocDTO.setRefresh(Constant.FLAG_TRUE);
+        ESResponse res = esDataDynamicOperationApiService.updateDataSingle(dynamicDocDTO, false);
+        logger.info("刷新建联时间返回:{}", res.getErrCode());
     }
 
     @Override