4514江西聚金阁&讯速邦掩码撞库

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

@@ -25,6 +25,7 @@ public enum CommercialCallBackReadyEnum implements StringCodeable {
     Commercial_SXJLHJ("4592","92ead8dc6ee0250527011912business","https://api.zhudaicms.com/api/stars_back.html?brand=1725&orgid=1235&d=1741484676"),//陕西聚隆汇金
     Commercial_SXJLHJ2("4592","92ead8dc6ee0250527011912business","https://api.zhudaicms.com/api/stars_back.html?brand=1673&orgid=1568&d=1738894871"),//陕西聚隆汇金（二店)
     //Commercial_HLJJC("4542","88c430c8a939250513054555business","http://43.139.215.175/api/customer.callback/index"),//黑龙江省景琛信息咨询有限公司
+    Commercial_JXJJG("4514","2f81bca076f6250509032146business","http://8.153.166.121:8800/api/customer/customerStarBack"),//4514江西聚金阁&讯速邦掩码撞库
     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

@@ -74,6 +74,15 @@ public class CasllBackDataProcessor implements CallBackService {
                         sendGetRequest(CommercialCallBackReadyEnum.Commercial_ONE.getCode(),
                                 CommercialCallBackReadyEnum.Commercial_ONE.getBusid(),commercialCallBackReadyEnum.getUrl(),md5List);
                         break;
+                    case Commercial_JXJJG://4514江西聚金阁
+                        List<String> md5ListJXJJG = callBackMap.get(productBizId);
+                        log.info("开始处理机构id:{},江西聚金阁 当日订单数:{},条数:{}", productBizId,md5ListJXJJG,md5ListJXJJG.size());
+                        if (CollectionUtils.isEmpty(md5ListJXJJG)) {
+                            return;
+                        }
+                        sendGetRequestJXJJG(commercialCallBackReadyEnum.getCode(),
+                                commercialCallBackReadyEnum.getBusid(),commercialCallBackReadyEnum.getUrl(),md5ListJXJJG);
+                        break;
                     case Commercial_SZYC://苏州央创
                         List<String> md5ListSZYC = callBackMap.get(productBizId);
                         log.info("开始处理机构id:{},苏州央创 当日订单数:{},条数:{}", productBizId,md5ListSZYC,md5ListSZYC.size());
@@ -405,6 +414,75 @@ public class CasllBackDataProcessor implements CallBackService {
         log.info("busiId:{} 重庆优兴嘉 处理数据条:{}", busiId, followupList.size());
         handleMappedData(busiId,followupList);
 
+    }
+
+    private  void sendGetRequestJXJJG(String productBizId,String busiId,String url,List<String> md5ListJXJJG){
+
+        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", "12");
+        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;
+        }
+
+        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 ("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 sendGetRequestFoShan(String productBizId,String busiId,String url,List<String> md5ListFS){
         List<Map<String, String>> jsonList = new ArrayList<>();