mes/nalinv-int
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

批量处理W的数据时,如果第一行处理失败后就跳过

Browse Source
This commit is contained in:
彭枝刚 2025-01-14 17:11:24 +08:00
parent d5dcf214dc
commit d5986e0ecb
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
int-core/src/main/java/com/foreverwin/iep/integration/service/impl/IntInDataServiceImpl.java
View File

@ -138,6 +138,8 @@ public class IntInDataServiceImpl extends ServiceImpl<IntInDataMapper, IntInData
throw BusinessException.build(messageId+" 接口未检索到帐期关闭的数据");
}else{
Integer countSize = dataLogDTOS.size();
Integer errorCount = 0;
Integer successCount = 0;
InvokeResponse invokeResponse = new InvokeResponse();
for (int i = 0; i < countSize; i++) {
IntInDataLogDTO dataLogDTO = dataLogDTOS.get(i);
@ -158,18 +160,20 @@ public class IntInDataServiceImpl extends ServiceImpl<IntInDataMapper, IntInData
log.setState("S");
log.setResponse(jsonObject.toJSONString());
intInDataLogService.updateById(log);
successCount = successCount +1;
}else{
IntInDataLog log = intInDataLogService.getById(logId);
log.setState(result);
log.setResponse(jsonObject.toJSONString());
intInDataLogService.updateById(log);
throw BusinessException.build("共【"+countSize+"】数据,第【"+(i+1)+"】笔处理失败,结果为【"+result+"】,请求编号【"+logId+"】报: "+message);
errorCount = errorCount+1;
// throw BusinessException.build("共【"+countSize+"】数据,第【"+(i+1)+"】笔处理失败,结果为【"+result+"】,请求编号【"+logId+"】报: "+message);
}
}else{
throw BusinessException.build(messageId+" SAP处理失败");
}
}
return "成功处理【"+countSize+"】笔数据";
return "共处理【"+countSize+"】笔数据,【"+successCount+"】笔成功,【"+errorCount+"】笔失败";
}
}
}