重庆贰嘉叁

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

@@ -32,6 +32,8 @@ public enum CommercialCallBackReadyEnum implements StringCodeable {
     Commercial_SRLF("4776","0c238b6df918250718103123business","https://api.zhudaicms.com/api/stars_back.html?brand=1849&orgid=4776&d=1753863536&v=2"),//速融（廊坊）信息咨询服务有限公司
 
     Commercial_JXJJG("4514","2f81bca076f6250509032146business","http://8.153.166.121:8800/api/customer/customerStarBack"),//4514江西聚金阁&讯速邦掩码撞库
+    Commercial_CQEJS("4507","e2f1d67ea13b250508021340business","http://47.109.79.129:8888/api/customer/customerStarBack"),//4507重庆贰嘉叁-讯速邦掩码撞库
+
     Commercial_DAQN("4381", "445982746008128business", "http://xsd.qnkj88.net/api/xiaoan/queryByUniqueId"),//大连青柠
     Commercial_GZWA("4355", "198546fcf18b250331014900business", "https://gw.rongxk.cn/crm/api/channel/queryCustomerGrade"),//广州维安信息咨询有限公司
     Commercial_LSDJC("4800", "90587353752b250808044431business", "https://gw.rongxk.cn/crm/api/channel/queryCustomerGrade"),//乐山都聚财信息技术咨询有限公司

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

@@ -227,6 +227,15 @@ public class CasllBackDataProcessor implements CallBackService {
                         sendGetRequestJXJJG(commercialCallBackReadyEnum.getCode(),
                                 commercialCallBackReadyEnum.getBusid(),commercialCallBackReadyEnum.getUrl(),md5ListJXJJG,resultMap);
                         break;
+                    case Commercial_CQEJS://4507重庆贰嘉叁
+                        List<String> md5ListCQEJS = callBackMap.get(productBizId);
+                        log.info("开始处理机构id:{},重庆贰嘉叁 当日订单数:{},条数:{}", productBizId,md5ListCQEJS,md5ListCQEJS.size());
+                        if (CollectionUtils.isEmpty(md5ListCQEJS)) {
+                            return;
+                        }
+                        sendGetRequestCQEJS(commercialCallBackReadyEnum.getCode(),
+                                commercialCallBackReadyEnum.getBusid(),commercialCallBackReadyEnum.getUrl(),md5ListCQEJS,resultMap);
+                        break;
                     case Commercial_SZYC://苏州央创
                         List<String> md5ListSZYC = callBackMap.get(productBizId);
                         log.info("开始处理机构id:{},苏州央创 当日订单数:{},条数:{}", productBizId,md5ListSZYC,md5ListSZYC.size());
@@ -669,7 +678,116 @@ public class CasllBackDataProcessor implements CallBackService {
         handleMappedData(busiId,followupList);
 
     }
+    private  void sendGetRequestCQEJS(String productBizId,String busiId,String url,List<String> md5ListJXJJG,Map<String, String> resultMap){
+
+        StringBuilder stringBuilder = new StringBuilder();
+        Map<String, String> map = new HashMap<>();
+
+        for (int i = 0; i < md5ListJXJJG.size(); i++) {
+            stringBuilder.append(md5ListJXJJG.get(i));
+            if (i < md5ListJXJJG.size() - 1) {
+                stringBuilder.append(",");
+            }
+        }
+        map.put("channel_code", "23");
+        map.put("md5_phone_list", stringBuilder.toString());
+        String jsonString = JSON.toJSONString(map);
+        log.info("busiId:{},:重庆贰嘉叁 jsonString:{}" ,busiId, jsonString);
+
+        String responseStr = HttpClientThreeUtil.post(url, jsonString);
+        JSONObject response = JSON.parseObject(responseStr);
+        String code = response.getString("code");
+        if (!"1".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;
+        }
+        String s = resultMap.get(busiId);
+        JSONObject jsonObject = JSON.parseObject(s);
+        for (int i = 0; i < dataArray.size(); i++) {
+            JSONObject obj = dataArray.getJSONObject(i);
+            CustomerFollowup followup = new CustomerFollowup();
+            followup.setPhoneMd5(obj.getString("phoneMd5"));
+            followup.setBusiId(busiId);
+            followup.setProductBizId(Integer.parseInt(productBizId));
+            followup.setFollowTime(new Date());
+            followup.setSourceType(3);
+            String star = obj.getString("star");
+            if (StringUtils.isEmpty(star)) {
+                log.info("busiId:{} 重庆贰嘉叁 mobile_md5{} 没有填星级:", busiId, followup.getPhoneMd5());
+                continue;
+            } else {
+                if (StringUtils.isEmpty(s)){
+                    if ("0".equals(star)) {
+                        followup.setStarLevel(new BigDecimal(0));
+                    } else if ("1".equals(star)) {
+                        followup.setStarLevel(new BigDecimal(1));
+                    }else if ("2".equals(star) || "3".equals(star)) {
+                        followup.setStarLevel(new BigDecimal(2));
+                    }else if ("4".equals(star)) {
+                        followup.setStarLevel(new BigDecimal(3));
+                    }else if ("5".equals(star)) {
+                        followup.setStarLevel(new BigDecimal(4));
+                    }else if ("6".equals(star)) {
+                        followup.setStarLevel(new BigDecimal(5));
+                    }
+                }else {
+                    try {
+                        Map<String, String> starMap = JSON.parseObject(jsonObject.toString(), Map.class);
+                        String level = starMap.get(star);
+                        if (StringUtils.isEmpty(level)) {
+                            if ("0".equals(star)) {
+                                followup.setStarLevel(new BigDecimal(0));
+                            } else if ("1".equals(star)) {
+                                followup.setStarLevel(new BigDecimal(1));
+                            }else if ("2".equals(star) || "3".equals(star)) {
+                                followup.setStarLevel(new BigDecimal(2));
+                            }else if ("4".equals(star)) {
+                                followup.setStarLevel(new BigDecimal(3));
+                            }else if ("5".equals(star)) {
+                                followup.setStarLevel(new BigDecimal(4));
+                            }else if ("6".equals(star)) {
+                                followup.setStarLevel(new BigDecimal(5));
+                            }
+                        }else {
+                            followup.setStarLevel(new BigDecimal(level));
+                        }
+                    }catch (Exception e){
+                        if ("0".equals(star)) {
+                            followup.setStarLevel(new BigDecimal(0));
+                        } else if ("1".equals(star)) {
+                            followup.setStarLevel(new BigDecimal(1));
+                        }else if ("2".equals(star) || "3".equals(star)) {
+                            followup.setStarLevel(new BigDecimal(2));
+                        }else if ("4".equals(star)) {
+                            followup.setStarLevel(new BigDecimal(3));
+                        }else if ("5".equals(star)) {
+                            followup.setStarLevel(new BigDecimal(4));
+                        }else if ("6".equals(star)) {
+                            followup.setStarLevel(new BigDecimal(5));
+                        }
+                    }
 
+
+                }
+
+            }
+            followupList.add(followup);
+        }
+
+        if (CollectionUtils.isEmpty(followupList)) {
+            log.info("busiId:{} 重庆贰嘉叁 无星级数据", busiId);
+            return;
+        }
+        log.info("busiId:{} 重庆贰嘉叁 处理数据条:{}", busiId, followupList.size());
+        handleMappedData(busiId,followupList);
+
+    }
     private  void sendGetRequestJXJJG(String productBizId,String busiId,String url,List<String> md5ListJXJJG,Map<String, String> resultMap){
 
         StringBuilder stringBuilder = new StringBuilder();