|
@@ -164,15 +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_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());
|
|
@@ -354,68 +354,68 @@ public class CasllBackDataProcessor implements CallBackService {
|
|
|
|
|
|
}
|
|
|
|
|
|
- public void sendGetRequestHeiLongJiang(String productBizId, String busiId, String url, List<String> md5ListHLJJC){
|
|
|
- List<Map<String, String>> jsonList = new ArrayList<>();
|
|
|
- for (String md5 : md5ListHLJJC) {
|
|
|
- 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);
|
|
|
-
|
|
|
- }
|
|
|
+// public void sendGetRequestHeiLongJiang(String productBizId, String busiId, String url, List<String> md5ListHLJJC){
|
|
|
+// List<Map<String, String>> jsonList = new ArrayList<>();
|
|
|
+// for (String md5 : md5ListHLJJC) {
|
|
|
+// 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){
|