重庆优兴嘉

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_CQYXJ("4516","bff040093fee250512093334business","https://gw.rongxk.com/crm/api/channel/queryCustomerGrade"),//重庆优兴嘉
     //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");//大连青柠
 

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

@@ -173,6 +173,15 @@ public class CasllBackDataProcessor implements CallBackService {
 //                        sendGetRequestHeiLongJiang(commercialCallBackReadyEnum.getCode(),
 //                                commercialCallBackReadyEnum.getBusid(),commercialCallBackReadyEnum.getUrl(), md5ListHLJJC);
 //                        break;
+                    case Commercial_CQYXJ:
+                        List<String> md5ListCQYXJ = callBackMap.get(productBizId);
+                        log.info("开始处理机构id:{},重庆优兴嘉 当日订单数:{},条数:{}", productBizId,md5ListCQYXJ,md5ListCQYXJ.size());
+                        if (CollectionUtils.isEmpty(md5ListCQYXJ)) {
+                            return;
+                        }
+                        sendGetRequestCQYXJ(commercialCallBackReadyEnum.getCode(),
+                                commercialCallBackReadyEnum.getBusid(),commercialCallBackReadyEnum.getUrl(),md5ListCQYXJ,"1D4C6329-399F-42CA-AC0C-236E0B048AD0",21540);
+                        break;
                     case Commercial_SXRKX:
                         List<String> md5ListSXRKX = callBackMap.get(productBizId);
                         log.info("开始处理机构id:{},山西瑞凯鑫 当日订单数:{},条数:{}", productBizId,md5ListSXRKX,md5ListSXRKX.size());
@@ -301,7 +310,66 @@ public class CasllBackDataProcessor implements CallBackService {
         log.info("busiId:{} 山西瑞凯鑫 处理数据条:{}", busiId, followupList.size());
         handleMappedData(busiId,followupList);
     }
+    private  void sendGetRequestCQYXJ(String productBizId,String busiId,String url,List<String> md5ListCQYXJ,String accessKey,Integer channelType){
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("accessKey", accessKey);
+        jsonObject.put("channelType", channelType);
+        jsonObject.put("phoneMd5List", md5ListCQYXJ);
+        String jsonString = JSON.toJSONString(jsonObject);
+        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("phoneMd5"));
+            followup.setBusiId(busiId);
+            followup.setProductBizId(Integer.parseInt(productBizId));
+            followup.setFollowTime(new Date());
+            followup.setSourceType(3);
+            String star = obj.getString("grade");
+            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 ("10".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(1));
+                }else if ("20".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(2));
+                }else if ("30".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(3));
+                }else if ("40".equals(star)) {
+                    followup.setStarLevel(new BigDecimal(4));
+                }else if ("50".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<>();
         for (String md5 : md5ListFS) {