|
@@ -269,7 +269,7 @@ public class LogisticsInfosServiceImpl extends ServiceImpl<LogisticsInfosMapper,
|
|
|
}
|
|
|
DynamicDataSourceContextHolder.push(SourceConstant.VICTORIATOURIST);
|
|
|
IWrapper<LogisticsInfos> wrapper = IWrapper.getWrapper();
|
|
|
- wrapper.eq(LogisticsInfos::getStatus, -1);
|
|
|
+ wrapper.eq(LogisticsInfos::getLogisticsStatus, -1);
|
|
|
wrapper.eq(LogisticsInfos::getIsKd100, 1);
|
|
|
wrapper.eq("tenant_id", tenantId);
|
|
|
wrapper.apply("DATE_SUB( CURDATE(), INTERVAL 3 DAY )<= create_time");
|
|
@@ -283,9 +283,9 @@ public class LogisticsInfosServiceImpl extends ServiceImpl<LogisticsInfosMapper,
|
|
|
try {
|
|
|
KD100Result kd100Result = KD100Util.queryTrack(com, num, configInfo);
|
|
|
if (kd100Result.getState() == null || kd100Result.getState() == -1) {
|
|
|
- return;
|
|
|
+ continue;
|
|
|
}
|
|
|
- logisticsInfos.setStatus(kd100Result.getState());
|
|
|
+ logisticsInfos.setLogisticsStatus(kd100Result.getState());
|
|
|
//重新订阅
|
|
|
KD100Util.subscribe(com, num, configInfo);
|
|
|
Thread.sleep(2000);
|