rev:任务状态反馈修改
This commit is contained in:
@@ -209,11 +209,7 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
|
||||
}
|
||||
}catch (Exception ex){
|
||||
WQLObject.getWQLObject("SCH_BASE_Task").update(MapOf.of("remark",DateUtil.now()+"更新"+row.getString("task_status")+"失败:"+ex.getMessage()),"task_id = '" + task_id + "'");
|
||||
StringBuffer exinfo = new StringBuffer();
|
||||
for (int i1 = 0; i1 < ex.getStackTrace().length; i1++) {
|
||||
exinfo.append(ex.getStackTrace()[i1].toString());
|
||||
}
|
||||
log.error(task_id+"手动更新任务失败:{}", exinfo);
|
||||
log.error(task_id+"acs更新任务失败:{}", ex);
|
||||
throw new BadRequestException(ex.getMessage());
|
||||
}finally {
|
||||
if (lock.isLocked() && lock.isHeldByCurrentThread()) {
|
||||
|
||||
@@ -152,12 +152,8 @@ public class TaskServiceImpl implements TaskService {
|
||||
throw new BadRequestException("任务标识为:" + task_id + "的任务正在操作中!");
|
||||
}
|
||||
}catch (Exception ex){
|
||||
StringBuffer exinfo = new StringBuffer();
|
||||
WQLObject.getWQLObject("SCH_BASE_Task").update(MapOf.of("remark",DateUtil.now()+"更新"+MapUtil.getStr(map, "method_name")+"失败:"+ex.getMessage()),"task_id = '" + task_id + "'");
|
||||
for (int i1 = 0; i1 < ex.getStackTrace().length; i1++) {
|
||||
exinfo.append(ex.getStackTrace()[i1].toString());
|
||||
}
|
||||
log.error(task_id+"手动更新任务失败:{}", exinfo);
|
||||
log.error(task_id+"手动更新任务失败:{}", ex);
|
||||
throw new BadRequestException(ex.getMessage());
|
||||
}
|
||||
finally {
|
||||
|
||||
Reference in New Issue
Block a user