### commit message

#### 1. 和郭哥讨论之后给出的解决方案:先把这几行注释掉,处理定时器调用查询失败的我哪天
This commit is contained in:
liuy 2024-09-24 13:09:58 +08:00
parent e142ad212b
commit b7139d7c1d
2 changed files with 3 additions and 2 deletions

View File

@ -228,6 +228,7 @@ public class ConsignmachiningIn extends PluginBaseEntity {
@Override @Override
public void run() { public void run() {
try { try {
Assert.notNull(code, "code不能为空");
List<StockinOrderSearchResponse.StockinOrder> returnGoodHeaderDetailsDataDtoArrayList = new ArrayList<>(); List<StockinOrderSearchResponse.StockinOrder> returnGoodHeaderDetailsDataDtoArrayList = new ArrayList<>();
QueryOfsSoSaleOutVo queryOfsSoSaleOutVo = new QueryOfsSoSaleOutVo(); QueryOfsSoSaleOutVo queryOfsSoSaleOutVo = new QueryOfsSoSaleOutVo();
queryOfsSoSaleOutVo.setClientCode("LETS"); queryOfsSoSaleOutVo.setClientCode("LETS");

View File

@ -169,13 +169,13 @@ public class QuartzJobFactory implements Job {
integrationTaskLivingEntity.setDiffTime(interval.toString()); integrationTaskLivingEntity.setDiffTime(interval.toString());
integrationTaskLivingEntity.setRunNum(integrationTaskLivingEntity.getRunNum()+1); integrationTaskLivingEntity.setRunNum(integrationTaskLivingEntity.getRunNum()+1);
integrationTaskLivingEntity.setModify_time(new Date()); integrationTaskLivingEntity.setModify_time(new Date());
iIntegrationTaskCacheableService.updateIntegrationTaskLivingEntity(integrationTaskLivingEntity); // iIntegrationTaskCacheableService.updateIntegrationTaskLivingEntity(integrationTaskLivingEntity);
if(integrationTaskLogEntity != null ){ if(integrationTaskLogEntity != null ){
integrationTaskLogEntity.setEndTime(endTime); integrationTaskLogEntity.setEndTime(endTime);
integrationTaskLogEntity.setDiffTime(interval.toString()); integrationTaskLogEntity.setDiffTime(interval.toString());
integrationTaskLogEntity.setTaskStatus(detailtype);//执行成功 integrationTaskLogEntity.setTaskStatus(detailtype);//执行成功
integrationTaskLogEntity.setRemark(msg); integrationTaskLogEntity.setRemark(msg);
integrationTaskLogDao.update(integrationTaskLogEntity); // integrationTaskLogDao.update(integrationTaskLogEntity);
} }
} }
} }