md5星级回传

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

@@ -5,13 +5,16 @@ import com.tiangua.kirin.utils.EnumUtils;
 
 public enum CommercialCallBackReadyEnum implements StringCodeable {
 
-    Commercial_ONE("11", "www.baidu.com");//六安
+    Commercial_ONE("4330", "445759631851840business", "http://rcw.notify.succtime.com/customerNotify/getCustomerInfo"),
+    Commercial_Test("2336", "1778fd4985a9240809111258business", "http://rcw.notify.succtime.com/customerNotify/getCustomerInfo");
 
     private String code;
+    private String busid;
     private String url;
 
-    CommercialCallBackReadyEnum(String code, String url) {
+    CommercialCallBackReadyEnum(String code, String busid, String url) {
         this.code = code;
+        this.busid = busid;
         this.url = url;
     }
 
@@ -24,7 +27,12 @@ public enum CommercialCallBackReadyEnum implements StringCodeable {
         return this.code;
     }
 
+    public String getBusid() {
+        return this.busid;
+    }
+
     public String getUrl() {
-        return url;
+        return this.url;
     }
 }
+

src/main/java/com/tiangua/star/model/XdOrderDto.java

@@ -7,10 +7,11 @@ import java.io.Serializable;
 @Data
 public class XdOrderDto implements Serializable {
     private String busiId;
+    private String productBizId;
     private String mobileMd5;
 
-    public XdOrderDto(String busiId, String mobileMd5) {
-        this.busiId = busiId;
+    public XdOrderDto(String productBizId, String mobileMd5) {
+        this.productBizId = productBizId;
         this.mobileMd5 = mobileMd5;
     }
 }

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

@@ -53,13 +53,17 @@ public class CasllBackDataProcessor implements CallBackService {
     public void processInstitutionData(List<XdOrderDto> xdOrderDtos) {
         Map<String, List<String>> groupedByBusiId = xdOrderDtos.stream()
                 .collect(Collectors.groupingBy(
-                        XdOrderDto::getBusiId,
+                        XdOrderDto::getProductBizId,
                         Collectors.mapping(XdOrderDto::getMobileMd5, Collectors.toList())
                 ));
         Map<String, List<String>> callBackMap = groupedByBusiId.entrySet().stream()
                 .filter(entry -> CommercialCallBackReadyEnum.of(entry.getKey()) != null)
                 .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
         log.info("已经对接md5星级回传的机构id:{}", callBackMap.keySet());
+        if (CollectionUtils.isEmpty(callBackMap.keySet())) {
+            log.info("MD5 无需要处理的星级回传:{}", callBackMap.keySet());
+            return;
+        }
 
         for (String busiId : callBackMap.keySet()) {
             CommercialCallBackReadyEnum commercialCallBackReadyEnum = CommercialCallBackReadyEnum.of(busiId);
@@ -72,9 +76,17 @@ public class CasllBackDataProcessor implements CallBackService {
                             return;
                         }
                         sendGetRequest(CommercialCallBackReadyEnum.Commercial_ONE.getCode(),
-                                busiId,commercialCallBackReadyEnum.getUrl(),md5List);
+                                CommercialCallBackReadyEnum.Commercial_ONE.getBusid(),commercialCallBackReadyEnum.getUrl(),md5List);
                         break;
-
+//                    case Commercial_Test:
+//                        log.info("开始处理机构id:{}", busiId);
+//                        List<String> md5List2 = callBackMap.get(busiId);
+//                        if (CollectionUtils.isEmpty(md5List2)) {
+//                            return;
+//                        }
+//                        sendGetRequest(CommercialCallBackReadyEnum.Commercial_Test.getCode(),
+//                                CommercialCallBackReadyEnum.Commercial_Test.getBusid(),commercialCallBackReadyEnum.getUrl(),md5List2);
+//                        break;
                 }
             }
         }
@@ -90,7 +102,7 @@ public class CasllBackDataProcessor implements CallBackService {
         JSONObject response = null;
         for (String md5 : md5s) {
             map.put("customer_phone", md5);
-            map.put("customer_source", "");
+            map.put("customer_source", "LCD-HX");
             String responseStr = HttpClientThreeUtil.post(url, map.toJSONString());
             response = JSON.parseObject(responseStr);
             if (response.getInteger("code") == 1) {
@@ -113,10 +125,12 @@ public class CasllBackDataProcessor implements CallBackService {
                 }
                 param.setPhoneMd5(md5);
                 param.setStarLevel(data.getBigDecimal("customer_starlevel"));
-                param.setProductBizId(Integer.getInteger(productBizId));
+                param.setProductBizId(Integer.parseInt(productBizId));
                 param.setBusiId(busiId);
                 param.setSourceType(3);
                 list.add(param);
+            } else {
+                log.warn("url:{} ,productBizId:{},md5:{} 获取结果失败",url,productBizId,md5);
             }
         }
         log.info("busiId:{} 处理数据条:{}", busiId, list.size());
@@ -127,7 +141,7 @@ public class CasllBackDataProcessor implements CallBackService {
 
     private void handleMappedData(List<CustomerFollowup> data) {
         log.info("【CasllBackDataProcessor】成功处理 {} 条映射数据 明细：{}", data.size(), data);
-        String post = HttpClientThreeUtil.post(url, JSON.toJSONString(data));
+            String post = HttpClientThreeUtil.post(url, JSON.toJSONString(data));
         log.info("【CasllBackDataProcessor】post结果：{}", post);
     }
 

src/main/resources/application-dev.yml

@@ -0,0 +1,7 @@
+xinlu:
+  callback:
+    url: http://192.168.0.61:810/xinlu/callback
+
+md5:
+  callback:
+    url: http://192.168.0.61:810/md5/star/callback

src/main/resources/application.yml

@@ -1,9 +1,9 @@
 spring:
   profiles:
-    active: pre
+    active: dev
   application:
     name: loan-call-back-star
-logging.config: classpath:logback-${spring.profiles.active}.xml
+#logging.config: classpath:logback-${spring.profiles.active}.xml
 
 server:
   port: 8801