Commit e0158808 by “zcwang”

modify:工单到期执行时间修改

parent e7026e77
...@@ -57,8 +57,8 @@ public interface ChangeFlowService { ...@@ -57,8 +57,8 @@ public interface ChangeFlowService {
* @param entityId * @param entityId
* @param nodeId1 * @param nodeId1
* @param nodeId2 * @param nodeId2
* @param currentTime * @param tomorrowSpecificTime
* @return * @return
*/ */
List<ChangeRecord> getByStatusAndTime(Long entityId, String nodeId1, String nodeId2, long currentTime); List<ChangeRecord> getByStatusAndTime(Long entityId, String nodeId1, String nodeId2, long tomorrowSpecificTime);
} }
\ No newline at end of file
...@@ -56,7 +56,7 @@ public class ChangeFlowServiceImpl implements ChangeFlowService { ...@@ -56,7 +56,7 @@ public class ChangeFlowServiceImpl implements ChangeFlowService {
} }
@Override @Override
public List<ChangeRecord> getByStatusAndTime(Long entityId, String nodeId1, String nodeId2, long currentTime) { public List<ChangeRecord> getByStatusAndTime(Long entityId, String nodeId1, String nodeId2, long tomorrowSpecificTime) {
return changeRecordMapper.getByStatusAndTime(entityId, nodeId1, nodeId2, currentTime); return changeRecordMapper.getByStatusAndTime(entityId, nodeId1, nodeId2, tomorrowSpecificTime);
} }
} }
\ No newline at end of file
...@@ -66,13 +66,15 @@ public class AutoSubmit extends IJobHandler { ...@@ -66,13 +66,15 @@ public class AutoSubmit extends IJobHandler {
public ReturnT<String> execute(String... strings) throws Exception { public ReturnT<String> execute(String... strings) throws Exception {
log.info("AutoSubmit start"); log.info("AutoSubmit start");
long startTime = DateUtils.getCurrentTime(); long startTime = DateUtils.getCurrentTime();
// 处理变更确认时间是今天24点之前的
Long tomorrowSpecificTime = DateUtils.getTomorrowSpecificTime("00:00:00");
List<Long> count = new ArrayList<>(); List<Long> count = new ArrayList<>();
Long entityId = 0L; Long entityId = 0L;
// 查询今天时间之前的数据 // 查询今天时间之前的数据
try { try {
while (true) { while (true) {
List<ChangeRecord> records = changeFlowService.getByStatusAndTime(entityId, ChangeFlowEnum.CHANGE_FLOW_EXE.getNodeId(), List<ChangeRecord> records = changeFlowService.getByStatusAndTime(entityId, ChangeFlowEnum.CHANGE_FLOW_EXE.getNodeId(),
ChangeFlowEnum.CHANGE_FLOW_CONFIRM.getNodeId(), startTime); ChangeFlowEnum.CHANGE_FLOW_CONFIRM.getNodeId(), tomorrowSpecificTime);
if (CollectionUtils.isEmpty(records)) { if (CollectionUtils.isEmpty(records)) {
break; break;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment