提交 68a5a8c0 authored 作者: Matrix's avatar Matrix

[核查模块] 修复了CD状态异常的问题

上级 97e4bd9f
...@@ -468,9 +468,11 @@ public class DeviceCheckController { ...@@ -468,9 +468,11 @@ public class DeviceCheckController {
// 如果是4流程的,则需要指定核查组成员A接任务 // 如果是4流程的,则需要指定核查组成员A接任务
detailRepo.updateCheckStatus(id, checkStatus); detailRepo.updateCheckStatus(id, checkStatus);
if (userAId > 0 && userBId > 0) { if (userAId > 0 && userBId > 0) {
log.info("[核查模块] 该详情任务是一个4流程任务,推送到C状态...");
taskService.moveToNext(currentTask, userAId); taskService.moveToNext(currentTask, userAId);
} else { } else {
// 如果是2流程的,则直接结束该任务 // 如果是2流程的,则直接结束该任务
log.info("[核查模块] 该详情任务是一个2流程任务,结束任务并统计数据...");
taskService.moveToEnd(currentTask); taskService.moveToEnd(currentTask);
summaryDetail(currentTask, currentDetail); summaryDetail(currentTask, currentDetail);
} }
...@@ -494,6 +496,7 @@ public class DeviceCheckController { ...@@ -494,6 +496,7 @@ public class DeviceCheckController {
if (pass) { if (pass) {
// 如果当前是第3步(利用余数来判断),则需要指定核查组B的人来接受任务 // 如果当前是第3步(利用余数来判断),则需要指定核查组B的人来接受任务
boolean stepC = currentTask.getBillStatus() % 10 == 2; boolean stepC = currentTask.getBillStatus() % 10 == 2;
boolean stepD = currentTask.getBillStatus() % 10 == 3;
if (stepC) { if (stepC) {
log.info("[核查模块] C 检查组成员A正在进行核查操作,核查详情账单id为 : {}", id); log.info("[核查模块] C 检查组成员A正在进行核查操作,核查详情账单id为 : {}", id);
if (!currentTask.getBillStatus().equals(CHECK_DETAIL_2.id)) { if (!currentTask.getBillStatus().equals(CHECK_DETAIL_2.id)) {
...@@ -503,7 +506,6 @@ public class DeviceCheckController { ...@@ -503,7 +506,6 @@ public class DeviceCheckController {
log.info("[核查模块] C 操作完毕"); log.info("[核查模块] C 操作完毕");
} }
boolean stepD = currentTask.getBillStatus() % 10 == 3;
if (stepD) { if (stepD) {
if (!currentTask.getBillStatus().equals(CHECK_DETAIL_3.id)) { if (!currentTask.getBillStatus().equals(CHECK_DETAIL_3.id)) {
return ResponseEntity.status(400).body(new ResultObj<>(String.format("当前任务的状态异常!当前任务状态为 %s , 任务状态应该为 %s", GlobalMap.getStatusEnumMap().get(currentTask.getBillStatus()), CHECK_DETAIL_3.name))); return ResponseEntity.status(400).body(new ResultObj<>(String.format("当前任务的状态异常!当前任务状态为 %s , 任务状态应该为 %s", GlobalMap.getStatusEnumMap().get(currentTask.getBillStatus()), CHECK_DETAIL_3.name)));
...@@ -585,8 +587,8 @@ public class DeviceCheckController { ...@@ -585,8 +587,8 @@ public class DeviceCheckController {
// 如果汇总完毕则将父级的统计任务推进 // 如果汇总完毕则将父级的统计任务推进
if (over) { if (over) {
TaskBto fatherTask = taskService.get(fatherTaskId); TaskBto fatherTask = taskService.get(fatherTaskId);
//如果上一个id是-1 则证明是所有人的跟踪统计,即自动核查,那么下一步推进到所有人的待办 //如果上一个id是-1 则证明是所有人的跟踪统计,即自动核查,那么下一步推进到所有人的跟踪,否则设置为-2,即维持跟踪者id
Integer lastUserId = fatherTask.getLastUserId() == -1 ? 0 : fatherTask.getLastUserId(); Integer lastUserId = fatherTask.getLastUserId() == -1 ? -1 : -2;
taskService.moveToNext(fatherTask, lastUserId); taskService.moveToNext(fatherTask, lastUserId);
} }
log.info("[核查模块] 数据汇总完毕"); log.info("[核查模块] 数据汇总完毕");
......
...@@ -137,7 +137,7 @@ class DeviceCheckControllerTest extends BaseTest { ...@@ -137,7 +137,7 @@ class DeviceCheckControllerTest extends BaseTest {
// .build()) // .build())
// .get(0); // .get(0);
initTask = taskRepo.findById(724).get(); initTask = taskRepo.findById(741).get();
detailBillId = initTask.getBillId(); detailBillId = initTask.getBillId();
...@@ -180,7 +180,7 @@ class DeviceCheckControllerTest extends BaseTest { ...@@ -180,7 +180,7 @@ class DeviceCheckControllerTest extends BaseTest {
@Test @Test
void checkUserA2D() throws Exception { void checkUserA2D() throws Exception {
initTask = taskRepo.findById(723).get(); initTask = taskRepo.findById(748).get();
detailBillId = initTask.getBillId(); detailBillId = initTask.getBillId();
...@@ -220,7 +220,7 @@ class DeviceCheckControllerTest extends BaseTest { ...@@ -220,7 +220,7 @@ class DeviceCheckControllerTest extends BaseTest {
// checkUserB 接口 测试审核通过 // checkUserB 接口 测试审核通过
String url_b = baseUrl + "B/" + detailBillId + "?" + "checkStatus=1"; String url_b = baseUrl + "B/" + detailBillId + "?" + "checkStatus=1&checkUserAId=3&checkUserBId=4";
request = put(url_b) request = put(url_b)
.header("Origin", "*"); .header("Origin", "*");
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论