|
|
|
@ -63,11 +63,13 @@ public class RetryProcessor extends AbstractProcessor {
|
|
|
|
|
taskConfigRetryLog.setLastErrorMsg(context.getExMessageResult());
|
|
|
|
|
taskConfigRetryLog.setState(StateEnum.FAIL);
|
|
|
|
|
taskConfigDO.setState(StateEnum.FAIL);
|
|
|
|
|
taskConfigDO.setCreateTime(new Date());
|
|
|
|
|
taskConfigDO.setUpdateTime(new Date());
|
|
|
|
|
} else {
|
|
|
|
|
taskConfigRetryLog.setLastErrorMsg(EMPTY_STRING);
|
|
|
|
|
taskConfigRetryLog.setState(StateEnum.OK);
|
|
|
|
|
taskConfigDO.setState(StateEnum.OK);
|
|
|
|
|
taskConfigDO.setCreateTime(new Date());
|
|
|
|
|
taskConfigDO.setUpdateTime(new Date());
|
|
|
|
|
}
|
|
|
|
|
taskConfigRetryLogDao.save(taskConfigRetryLog);
|
|
|
|
@ -83,11 +85,13 @@ public class RetryProcessor extends AbstractProcessor {
|
|
|
|
|
taskMessageRetryLog.setErrorMsg(context.getExMessageResult());
|
|
|
|
|
taskMessageRetryLog.setState(StateEnum.FAIL);
|
|
|
|
|
taskMessageDO.setState(StateEnum.FAIL);
|
|
|
|
|
taskMessageDO.setCreateTime(new Date());
|
|
|
|
|
taskMessageDO.setUpdateTime(new Date());
|
|
|
|
|
} else {
|
|
|
|
|
taskMessageRetryLog.setErrorMsg(EMPTY_STRING);
|
|
|
|
|
taskMessageRetryLog.setState(StateEnum.OK);
|
|
|
|
|
taskMessageDO.setState(StateEnum.OK);
|
|
|
|
|
taskMessageDO.setCreateTime(new Date());
|
|
|
|
|
taskMessageDO.setUpdateTime(new Date());
|
|
|
|
|
}
|
|
|
|
|
taskMessageRetryLogDao.save(taskMessageRetryLog);
|
|
|
|
|