diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java index d58108693..9d82d0e83 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java @@ -5,7 +5,6 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.logpm.factory.comfac.dto.OrderStatusDTO; @@ -132,7 +131,7 @@ public class FactoryXxlJob { // 查询所有的数据库内容 只包含客户单号 List allDataList = stationOrderService.list(); - XxlJobLogger.log("allDataList{}", allDataList.size()); + XxlJobLogger.log("allDataList {}", allDataList.size()); // 解析数据 ls.forEach(orderLogEntity -> { @@ -220,7 +219,7 @@ public class FactoryXxlJob { } @Transactional(rollbackFor = Exception.class) - public Boolean resoveFactoryData() { + public void resoveFactoryData() { Map> map = new HashMap<>(); //TODO 调用Service 获取需要处理的数据 //查询要处理的订单信息 @@ -416,7 +415,6 @@ public class FactoryXxlJob { }); } - return true; } @Transactional(rollbackFor = Exception.class) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java index fef7abcdc..d3d356bbb 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java @@ -121,6 +121,7 @@ public class OrderServiceImpl implements IOrderService { @Override public Map dataRelative(OrderLogEntity orderLogEntity) { + logger.info(">>>>>>>>>>>>>> 待解析数据{}", orderLogEntity.getResBody()); Map map = new HashMap<>(); String resBody = orderLogEntity.getResBody(); @@ -136,6 +137,8 @@ public class OrderServiceImpl implements IOrderService { List rs = new ArrayList<>(); List PACKAGE_LIST = new ArrayList<>(); + logger.info(">>>>>>>>>>>>>> responseStationOrderVo.getData() {}", responseStationOrderVo.getData()); + responseStationOrderVo.getData().forEach(responseStationOrderInfoVo -> { StationOrderEntity stationOrderEntity = new StationOrderEntity(); PACKAGE_LIST.addAll(responseStationOrderInfoVo.getPACKAGE_LIST());