更新潜客分

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/controller/potential/ContactController.java

@@ -2,7 +2,9 @@ package com.gic.haoban.manage.web.controller.potential;
 
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.gic.api.base.commons.BasePageInfo;
+import com.gic.api.base.commons.Constant;
 import com.gic.api.base.commons.Page;
 import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.util.EntityUtil;
@@ -17,7 +19,11 @@ import com.gic.haoban.manage.api.service.contact.ContactConfigApiService;
 import com.gic.haoban.manage.api.service.contact.ContactFollowApiService;
 import com.gic.haoban.manage.api.service.contact.ContactLogApiService;
 import com.gic.haoban.manage.web.qo.contact.*;
+import com.gic.haoban.manage.web.utils.EsMemberInfoUtils;
 import com.gic.haoban.manage.web.vo.contact.ContactLogCheckVO;
+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.google.common.collect.Lists;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -28,6 +34,7 @@ import org.springframework.web.bind.annotation.RestController;
 
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
 /**
@@ -43,6 +50,31 @@ public class ContactController {
     private ContactLogApiService contactLogApiService;
     @Autowired
     private ContactConfigApiService contactConfigApiService;
+    @Autowired
+    private ESDataDynamicOperationApiService esDataDynamicOperationApiService;
+
+    /**
+     * 更新潜客分
+     * @param memberId
+     * @return
+     */
+    @RequestMapping(path = "/potential-score")
+    public RestResponse<Void> potentialScore(String enterpriseId,String memberId,Integer potentialScore) {
+        DynamicDocDTO dynamicDocDTO = new DynamicDocDTO();
+        dynamicDocDTO.setEnterpriseId(enterpriseId);
+        dynamicDocDTO.setColumnCategoryCode("member");
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("id", memberId);
+        jsonObject.put("memberId", memberId);
+        jsonObject.put("potentialScore", potentialScore);
+        dynamicDocDTO.setDocJson(jsonObject);
+        dynamicDocDTO.setRefresh(Constant.FLAG_TRUE);
+        ESResponse res = esDataDynamicOperationApiService.updateDataSingle(dynamicDocDTO, false);
+        if (res != null && Objects.equals(res.getErrCode(),"0")) {
+            return RestResponse.successResult();
+        }
+        return RestResponse.failure(res.getErrCode(), res.getErrMsg());
+    }
 
     /**
      * 添加跟进记录