fix:任务状态反馈
This commit is contained in:
@@ -201,8 +201,17 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
|
|||||||
throw new BadRequestException("任务标识为:" + task_id + "的任务正在操作中!");
|
throw new BadRequestException("任务标识为:" + task_id + "的任务正在操作中!");
|
||||||
}
|
}
|
||||||
}catch (Exception ex){
|
}catch (Exception ex){
|
||||||
WQLObject.getWQLObject("SCH_BASE_Task").update(MapOf.of("remark",DateUtil.now()+"更新"+row.getString("task_status")+"失败:"+ex.getMessage()),"task_id = '" + task_id + "'");
|
|
||||||
log.error(task_id+"acs更新任务失败:{}", ex);
|
log.error(task_id+"acs更新任务失败:{}", ex);
|
||||||
|
String msg = "";
|
||||||
|
if (!StringUtils.isEmpty(ex.getMessage())){
|
||||||
|
int length = ex.getMessage().length();
|
||||||
|
if (length>100){
|
||||||
|
msg = ex.getMessage().substring(0, 99);
|
||||||
|
}else {
|
||||||
|
msg = ex.getMessage();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
WQLObject.getWQLObject("SCH_BASE_Task").update(MapOf.of("remark","更新"+row.getString("task_status")+"失败:"+msg),"task_id = '" + task_id + "'");
|
||||||
throw ex;
|
throw ex;
|
||||||
}finally {
|
}finally {
|
||||||
if (lock.isLocked() && lock.isHeldByCurrentThread()) {
|
if (lock.isLocked() && lock.isHeldByCurrentThread()) {
|
||||||
|
|||||||
Reference in New Issue
Block a user