Browse Source

修复snm 数据重复问题

dist.1.3.0
pref_mail@163.com 6 months ago
parent
commit
798522a536
  1. 6
      blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java
  2. 3
      blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java

6
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.core.util.StrUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject; 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.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.logpm.factory.comfac.dto.OrderStatusDTO; import com.logpm.factory.comfac.dto.OrderStatusDTO;
@ -132,7 +131,7 @@ public class FactoryXxlJob {
// 查询所有的数据库内容 只包含客户单号 // 查询所有的数据库内容 只包含客户单号
List<StationOrderEntity> allDataList = stationOrderService.list(); List<StationOrderEntity> allDataList = stationOrderService.list();
XxlJobLogger.log("allDataList{}", allDataList.size()); XxlJobLogger.log("allDataList {}", allDataList.size());
// 解析数据 // 解析数据
ls.forEach(orderLogEntity -> { ls.forEach(orderLogEntity -> {
@ -220,7 +219,7 @@ public class FactoryXxlJob {
} }
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public Boolean resoveFactoryData() { public void resoveFactoryData() {
Map<Long, List<StaorderPackagesEntity>> map = new HashMap<>(); Map<Long, List<StaorderPackagesEntity>> map = new HashMap<>();
//TODO 调用Service 获取需要处理的数据 //TODO 调用Service 获取需要处理的数据
//查询要处理的订单信息 //查询要处理的订单信息
@ -416,7 +415,6 @@ public class FactoryXxlJob {
}); });
} }
return true;
} }
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)

3
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 @Override
public Map<String,List> dataRelative(OrderLogEntity orderLogEntity) { public Map<String,List> dataRelative(OrderLogEntity orderLogEntity) {
logger.info(">>>>>>>>>>>>>> 待解析数据{}", orderLogEntity.getResBody());
Map<String,List> map = new HashMap<>(); Map<String,List> map = new HashMap<>();
String resBody = orderLogEntity.getResBody(); String resBody = orderLogEntity.getResBody();
@ -136,6 +137,8 @@ public class OrderServiceImpl implements IOrderService {
List<StationOrderEntity> rs = new ArrayList<>(); List<StationOrderEntity> rs = new ArrayList<>();
List<ResponseStaorderPackagesInfoVo> PACKAGE_LIST = new ArrayList<>(); List<ResponseStaorderPackagesInfoVo> PACKAGE_LIST = new ArrayList<>();
logger.info(">>>>>>>>>>>>>> responseStationOrderVo.getData() {}", responseStationOrderVo.getData());
responseStationOrderVo.getData().forEach(responseStationOrderInfoVo -> { responseStationOrderVo.getData().forEach(responseStationOrderInfoVo -> {
StationOrderEntity stationOrderEntity = new StationOrderEntity(); StationOrderEntity stationOrderEntity = new StationOrderEntity();
PACKAGE_LIST.addAll(responseStationOrderInfoVo.getPACKAGE_LIST()); PACKAGE_LIST.addAll(responseStationOrderInfoVo.getPACKAGE_LIST());

Loading…
Cancel
Save