Commit e7e5372f by 周晓航

上报数据日志添加

parent e11fc5a2
...@@ -54,10 +54,12 @@ public class OrderCountJobHandler extends IJobHandler { ...@@ -54,10 +54,12 @@ public class OrderCountJobHandler extends IJobHandler {
*/ */
@Override @Override
public ReturnT<String> execute(String param) throws Exception { public ReturnT<String> execute(String param) throws Exception {
String trackingNo = LogThreadLocal.getTrackingNo();
log.info("begin xxl-job by send report msg -------- trackingNo:{}", trackingNo);
// 获取需要 上报的商户号 // 获取需要 上报的商户号
BaseResponse<GetFilterPartnerResponse> filterPartner = microOpenplatformClient.getFilterPartner(OrderGetPartnerRequest.builder().type(2).build()); BaseResponse<GetFilterPartnerResponse> filterPartner = microOpenplatformClient.getFilterPartner(OrderGetPartnerRequest.builder().type(2).build());
String trackingNo = LogThreadLocal.getTrackingNo(); log.info("orderCountJobHandler getFilterPartner filterPartner: {} , trackingNo:{}", filterPartner.toString(), trackingNo);
log.info("orderCountJobHandler getFilterPartner filterPartner: {} , trackingNo:{}", filterPartner, trackingNo);
if (filterPartner == null || filterPartner.getResult() == null) { if (filterPartner == null || filterPartner.getResult() == null) {
return ReturnT.SUCCESS; return ReturnT.SUCCESS;
} }
...@@ -67,7 +69,7 @@ public class OrderCountJobHandler extends IJobHandler { ...@@ -67,7 +69,7 @@ public class OrderCountJobHandler extends IJobHandler {
// 时间设置 前一天 // 时间设置 前一天
setBeginAndEndTime(orderCountRequestVo); setBeginAndEndTime(orderCountRequestVo);
BaseResponse<List<OrderCountResp>> result = orderservice.selectCountOrdersByPartnerIds(orderCountRequestVo, trackingNo); BaseResponse<List<OrderCountResp>> result = orderservice.selectCountOrdersByPartnerIds(orderCountRequestVo, trackingNo);
log.info("orderCountJobHandler send report order count msg request:{} response:{} , trackingNo:{} ", orderCountRequestVo, result, trackingNo); log.info("orderCountJobHandler send report order count msg request:{} response:{} , trackingNo:{} ", orderCountRequestVo.toString(), result.toString(), trackingNo);
if (!ResponseResultEnum.SUCCESS.getCode().equalsIgnoreCase(result.getCode()) || Objects.isNull(result.getResult())) { if (!ResponseResultEnum.SUCCESS.getCode().equalsIgnoreCase(result.getCode()) || Objects.isNull(result.getResult())) {
return ReturnT.SUCCESS; return ReturnT.SUCCESS;
} }
...@@ -75,8 +77,9 @@ public class OrderCountJobHandler extends IJobHandler { ...@@ -75,8 +77,9 @@ public class OrderCountJobHandler extends IJobHandler {
// 每次推送 只能 50条 让生态端处理 // 每次推送 只能 50条 让生态端处理
List<OrderCountResp> orderCounts = result.getResult(); List<OrderCountResp> orderCounts = result.getResult();
BaseResponse baseResponse = microOpenplatformClient.addOrderSum(orderCounts); BaseResponse baseResponse = microOpenplatformClient.addOrderSum(orderCounts);
log.info("orderCountJobHandler send report order end result :{} , trackingNo:{}", baseResponse, trackingNo); log.info("orderCountJobHandler send report order end result :{} , trackingNo:{}", baseResponse.toString(), trackingNo);
log.info("end xxl-job by send report msg -------- trackingNo:{}", trackingNo);
return ReturnT.SUCCESS; return ReturnT.SUCCESS;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment