黑龙江省景琛信息咨询有限公司

src/main/java/com/tiangua/star/controller/Md5CallBackController.java

@@ -13,9 +13,11 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
+
 /**
  * @author
  * @description 本应用 +诚易融 需求开发上线一共两天
@@ -44,4 +46,14 @@ public class Md5CallBackController {
         log.info("md5GainStarData get end");
         return MessageResult.ok();
     }
+
+
+
+//    @PostMapping("/sendGetRequestHeiLongJiang")
+//    public void processInstitutionData() {
+//        ArrayList<String> strings = new ArrayList<>();
+//        strings.add("d1531a8519025988df40e8c36c0454ad");
+//        strings.add("7bb81f1d2fb6cd213e2b8e3aac84db54");
+//        sendGetRequestHeiLongJiang("4542","88c430c8a939250513054555business","http://43.139.215.175/api/customer.callback/index",strings);
+//    }
 }

src/main/java/com/tiangua/star/enmus/CommercialCallBackReadyEnum.java

@@ -19,6 +19,7 @@ public enum CommercialCallBackReadyEnum implements StringCodeable {
     Commercial_CDHJT("4286","93047f718343250310100329business","https://api.zhudaicms.com/api/stars_back.html?brand=1625&orgid=12356&d=1729072676"),//成都汇锦通创商务信息咨询服务有限公司
     Commercial_NXCX("4361","20e3f861d99b250401045335business","https://api.zhudaicms.com/api/stars_back.html?brand=1547&orgid=12300bs&d=1721112535"),//宁夏簇鑫科技有限公司
     Commercial_JDPHAJ("2471","3de499d53dbf230708124743business","https://api.zhudaicms.com/api/stars_back.html?brand=35&orgid=hry1&d=1638773656"),//广州金贷普惠按揭服务有限公司
+    Commercial_HLJJC("4542","88c430c8a939250513054555business","http://43.139.215.175/api/customer.callback/index"),//黑龙江省景琛信息咨询有限公司
     Commercial_DAQN("4381", "445982746008128business", "http://47.113.122.223:8001/api/xiaoan/queryByUniqueId");//大连青柠
 
     private String code;

src/main/java/com/tiangua/star/service/impl/CasllBackDataProcessor.java

@@ -164,6 +164,15 @@ public class CasllBackDataProcessor implements CallBackService {
                         sendGetRequestFoShan(commercialCallBackReadyEnum.getCode(),
                                 commercialCallBackReadyEnum.getBusid(),commercialCallBackReadyEnum.getUrl(), md5ListFS);
                         break;
+                    case Commercial_HLJJC:
+                        List<String> md5ListHLJJC = callBackMap.get(productBizId);
+                        log.info("开始处理机构id:{},黑龙江省景琛信息咨询有限公司 当日订单数:{},条数:{}", productBizId,md5ListHLJJC,md5ListHLJJC.size());
+                        if (CollectionUtils.isEmpty(md5ListHLJJC)) {
+                            return;
+                        }
+                        sendGetRequestHeiLongJiang(commercialCallBackReadyEnum.getCode(),
+                                commercialCallBackReadyEnum.getBusid(),commercialCallBackReadyEnum.getUrl(), md5ListHLJJC);
+                        break;
                     case Commercial_SXRKX:
                         List<String> md5ListSXRKX = callBackMap.get(productBizId);
                         log.info("开始处理机构id:{},山西瑞凯鑫 当日订单数:{},条数:{}", productBizId,md5ListSXRKX,md5ListSXRKX.size());
@@ -345,6 +354,69 @@ public class CasllBackDataProcessor implements CallBackService {
 
     }
 
+    public  void sendGetRequestHeiLongJiang(String productBizId, String busiId, String url, List<String> md5ListFS){
+        List<Map<String, String>> jsonList = new ArrayList<>();
+        for (String md5 : md5ListFS) {
+            Map<String, String> map = new HashMap<>();
+            map.put("source", "迅速邦");
+            map.put("mobile_md5", md5);
+            jsonList.add(map);
+        }
+        String jsonString = JSON.toJSONString(jsonList);
+        log.info("busiId:{},:黑龙江省景琛信息咨询有限公司 jsonString:{}" ,busiId, jsonString);
+
+        String responseStr = HttpClientThreeUtil.post(url, jsonString);
+        JSONObject response = JSON.parseObject(responseStr);
+        String code = response.getString("code");
+        if (!"200".equals(code)) {
+            log.info("黑龙江省景琛信息咨询有限公司 返回数据错误: " + response.getString("msg"));
+            return ;
+        }
+        JSONArray dataArray = response.getJSONArray("data");
+        List<CustomerFollowup> followupList = new ArrayList<>();
+        if (CollectionUtils.isEmpty(dataArray)) {
+            log.info("busiId:{},:黑龙江省景琛信息咨询有限公司 今天没有星级数据",busiId);
+            return;
+        }
+
+        for (int i = 0; i < dataArray.size(); i++) {
+            JSONObject obj = dataArray.getJSONObject(i);
+            CustomerFollowup followup = new CustomerFollowup();
+            followup.setPhoneMd5(obj.getString("mobile_md5"));
+            followup.setBusiId(busiId);
+            followup.setProductBizId(Integer.parseInt(productBizId));
+            followup.setFollowTime(new Date());
+            followup.setSourceType(3);
+            String star = obj.getString("industry");
+            if (StringUtils.isEmpty(star)) {
+                log.info("busiId:{} 黑龙江省景琛信息咨询有限公司 mobile_md5{} 没有填星级:", busiId, followup.getPhoneMd5());
+                continue;
+            } else {
+                if ("1星".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(1));
+                }else if ("2星".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(2));
+                }else if ("3星".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(3));
+                }else if ("4星".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(4));
+                }else if ("5星".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(5));
+                }
+            }
+            followupList.add(followup);
+        }
+
+        if (CollectionUtils.isEmpty(followupList)) {
+            log.info("busiId:{} 黑龙江省景琛信息咨询有限公司 无星级数据", busiId);
+            return;
+        }
+        log.info("黑龙江省景琛信息咨询有限公司:{}", followupList);
+        log.info("busiId:{} 黑龙江省景琛信息咨询有限公司 处理数据条:{}", busiId, followupList.size());
+        handleMappedData(busiId,followupList);
+
+    }
+
     //https://api.zhudaicms.com/ 通用
     private void sendGetRequestHz(String productBizId,String busiId,String url,String companyName){
         String responseStr = HttpClientThreeUtil.get(url,null);