提交 d0e23d79 authored 作者: 000516's avatar 000516 提交者: Coding

勤策接口返回异常值打印日志且跳过当前数据,for循环继续执行

Merge Request: 勤策接口返回异常值打印日志且跳过当前数据,for循环继续执行 Created By: @李秋林 Accepted By: @李秋林 URL: https://g-pkkp8204.coding.net/p/wangxiaolu-sfa/d/wangxiaolu-sfa-module-job/git/merge/126?initial=true
...@@ -39,22 +39,30 @@ public class QinceDealerQueryServiceImpl implements IQinceDealerQueryService { ...@@ -39,22 +39,30 @@ public class QinceDealerQueryServiceImpl implements IQinceDealerQueryService {
* 反写勤策中的自定义字段:大区、战区 * 反写勤策中的自定义字段:大区、战区
*/ */
for (QinceDealerDto dealerDTO : pushQinceDealers) { for (QinceDealerDto dealerDTO : pushQinceDealers) {
try {
Map<String, Object> ext1 = new HashMap<>(); Map<String, Object> ext1 = new HashMap<>();
ext1.put("dealer_ext_key","大区"); ext1.put("dealer_ext_key", "大区");
ext1.put("dealer_ext_value",dealerDTO.getDqOrgName()); ext1.put("dealer_ext_value", dealerDTO.getDqOrgName());
Map<String, Object> ext2 = new HashMap<>(); Map<String, Object> ext2 = new HashMap<>();
ext2.put("dealer_ext_key","战区"); ext2.put("dealer_ext_key", "战区");
ext2.put("dealer_ext_value",dealerDTO.getZqOrgName()); ext2.put("dealer_ext_value", dealerDTO.getZqOrgName());
Map<String, Object> params = new HashMap<>(); Map<String, Object> params = new HashMap<>();
params.put("dealer_id",dealerDTO.getDealerId()); params.put("dealer_id", dealerDTO.getDealerId());
params.put("exts", Arrays.asList(ext1, ext2)); params.put("exts", Arrays.asList(ext1, ext2));
String url = qinCeUtils.builderUrl(QinCeUtils.MODIFY_DEALER, params); String url = qinCeUtils.builderUrl(QinCeUtils.MODIFY_DEALER, params);
qinCeUtils.postQC(url, params); qinCeUtils.postQC(url, params);
log.info("更新经销商成功:{}", JSONObject.toJSONString(dealerDTO));
} catch (RuntimeException e) {
log.error("更新经销商失败:{}", JSONObject.toJSONString(dealerDTO));
log.error("失败原因:{}", e.getMessage());
} catch (Exception e) {
log.error("更新经销商失败:{}", e.getMessage());
}
} }
log.info("更新勤策经销商战区、大区信息完成,更新量:{}",pushQinceDealers.size()); log.info("更新勤策经销商战区、大区信息完成,更新量:{}",pushQinceDealers.size());
......
...@@ -51,7 +51,7 @@ public class QinCeUtils { ...@@ -51,7 +51,7 @@ public class QinCeUtils {
public JSONObject postQC(String url, Object params) { public JSONObject postQC(String url, Object params) throws Exception {
String requestBody = HttpUtil.createPost(url).contentType("application/json;charset=utf-8").header("","").body(JSONObject.toJSONString(params)).execute().body(); String requestBody = HttpUtil.createPost(url).contentType("application/json;charset=utf-8").header("","").body(JSONObject.toJSONString(params)).execute().body();
JSONObject resultJson = JSONObject.parseObject(requestBody); JSONObject resultJson = JSONObject.parseObject(requestBody);
String returnCode = resultJson.getString("return_code"); String returnCode = resultJson.getString("return_code");
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论