|
@@ -57,7 +57,7 @@ import java.util.function.Function;
|
|
import java.util.stream.Collectors;
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 监察管理
|
|
|
|
|
|
+ * 监督管理
|
|
*
|
|
*
|
|
* @author jimmy
|
|
* @author jimmy
|
|
* @date 11/07/2024 18:28
|
|
* @date 11/07/2024 18:28
|
|
@@ -90,7 +90,7 @@ public class WmSupervisionManager {
|
|
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 获取监察分页
|
|
|
|
|
|
+ * 获取监督分页
|
|
*
|
|
*
|
|
* @param query 查询条件
|
|
* @param query 查询条件
|
|
* @param operator 操作人
|
|
* @param operator 操作人
|
|
@@ -150,7 +150,7 @@ public class WmSupervisionManager {
|
|
Set<Integer> deptId = records.stream().mapToInt(map -> Integer.parseInt((String) map.get("deptId"))).boxed().collect(Collectors.toSet());
|
|
Set<Integer> deptId = records.stream().mapToInt(map -> Integer.parseInt((String) map.get("deptId"))).boxed().collect(Collectors.toSet());
|
|
Map<Integer, String> deptIdToDeptNameMap = deptService.listByIds(deptId).stream().collect(Collectors.toMap(SysDept::getDeptId, SysDept::getName));
|
|
Map<Integer, String> deptIdToDeptNameMap = deptService.listByIds(deptId).stream().collect(Collectors.toMap(SysDept::getDeptId, SysDept::getName));
|
|
|
|
|
|
- // 获取监察信息 && 任务监察
|
|
|
|
|
|
+ // 获取监督信息 && 任务监督
|
|
Set<Integer> pkgIds = records.stream().filter(map ->
|
|
Set<Integer> pkgIds = records.stream().filter(map ->
|
|
Objects.nonNull(map.get("supFlag"))).mapToInt(map -> (Integer) map.get("id")).boxed().collect(Collectors.toSet());
|
|
Objects.nonNull(map.get("supFlag"))).mapToInt(map -> (Integer) map.get("id")).boxed().collect(Collectors.toSet());
|
|
|
|
|
|
@@ -218,28 +218,28 @@ public class WmSupervisionManager {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 执行包监察
|
|
|
|
|
|
+ * 执行包监督
|
|
*
|
|
*
|
|
- * @param resource 监察信息
|
|
|
|
|
|
+ * @param resource 监督信息
|
|
* @param user 操作人
|
|
* @param user 操作人
|
|
- * @return 监察结果
|
|
|
|
|
|
+ * @return 监督结果
|
|
*/
|
|
*/
|
|
public Boolean createPkgSupervision(WmSupervisionDto.OnPkgSupervision resource, HnqzUser user) {
|
|
public Boolean createPkgSupervision(WmSupervisionDto.OnPkgSupervision resource, HnqzUser user) {
|
|
|
|
|
|
// 校验周期
|
|
// 校验周期
|
|
if (!this.checkDate(100)) {
|
|
if (!this.checkDate(100)) {
|
|
- throw new BizException("不在监察周期");
|
|
|
|
|
|
+ throw new BizException("不在监督周期");
|
|
}
|
|
}
|
|
|
|
|
|
- // 校验是否已经完成了监察
|
|
|
|
|
|
+ // 校验是否已经完成了监督
|
|
boolean checked = packageSupervisionService.hasChecked(resource.getPkgId());
|
|
boolean checked = packageSupervisionService.hasChecked(resource.getPkgId());
|
|
if (checked) {
|
|
if (checked) {
|
|
- throw new BizException("执行包存在监察记录,请勿重复操作");
|
|
|
|
|
|
+ throw new BizException("执行包存在监督记录,请勿重复操作");
|
|
}
|
|
}
|
|
|
|
|
|
packageSupervisionService.createPkgSupervision(resource, user);
|
|
packageSupervisionService.createPkgSupervision(resource, user);
|
|
|
|
|
|
- // 更新监察结果
|
|
|
|
|
|
+ // 更新监督结果
|
|
packageStatusService.updateSupervisionFlag(resource.getPkgId());
|
|
packageStatusService.updateSupervisionFlag(resource.getPkgId());
|
|
|
|
|
|
return Boolean.TRUE;
|
|
return Boolean.TRUE;
|
|
@@ -263,10 +263,10 @@ public class WmSupervisionManager {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 获取积分包监察结果
|
|
|
|
|
|
+ * 获取积分包监督结果
|
|
*
|
|
*
|
|
- * @param supId 监察记录
|
|
|
|
- * @return 监察结果
|
|
|
|
|
|
+ * @param supId 监督记录
|
|
|
|
+ * @return 监督结果
|
|
*/
|
|
*/
|
|
public WmPackageSupervision getPkgSupervision(Integer supId) {
|
|
public WmPackageSupervision getPkgSupervision(Integer supId) {
|
|
return packageSupervisionService.getById(supId);
|
|
return packageSupervisionService.getById(supId);
|
|
@@ -335,9 +335,9 @@ public class WmSupervisionManager {
|
|
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 服务任务监察
|
|
|
|
|
|
+ * 服务任务监督
|
|
*
|
|
*
|
|
- * @param resource 监察信息
|
|
|
|
|
|
+ * @param resource 监督信息
|
|
* @param user 操作人
|
|
* @param user 操作人
|
|
* @return 操作结果
|
|
* @return 操作结果
|
|
*/
|
|
*/
|
|
@@ -346,14 +346,14 @@ public class WmSupervisionManager {
|
|
}
|
|
}
|
|
|
|
|
|
// /**
|
|
// /**
|
|
- // * 获取可以监察的任务
|
|
|
|
|
|
+ // * 获取可以监督的任务
|
|
// *
|
|
// *
|
|
// * @param pkgId 执行包ID
|
|
// * @param pkgId 执行包ID
|
|
// * @return 任务列表
|
|
// * @return 任务列表
|
|
// */
|
|
// */
|
|
// public List<Map<String, Object>> listAvailableTask(Integer pkgId) {
|
|
// public List<Map<String, Object>> listAvailableTask(Integer pkgId) {
|
|
//
|
|
//
|
|
- // // 获取当前积分包已经监察过的任务ID
|
|
|
|
|
|
+ // // 获取当前积分包已经监督过的任务ID
|
|
// Set<Integer> supTaskIds = taskSupervisionService.list(Wrappers.<WmTaskSupervision>lambdaQuery().eq(WmTaskSupervision::getPackageId, pkgId)).stream().mapToInt(WmTaskSupervision::getTaskId).boxed().collect(Collectors.toSet());
|
|
// Set<Integer> supTaskIds = taskSupervisionService.list(Wrappers.<WmTaskSupervision>lambdaQuery().eq(WmTaskSupervision::getPackageId, pkgId)).stream().mapToInt(WmTaskSupervision::getTaskId).boxed().collect(Collectors.toSet());
|
|
// List<WmTask> wmTasks = taskService.listAvailableTaskForSupervision(pkgId, supTaskIds);
|
|
// List<WmTask> wmTasks = taskService.listAvailableTaskForSupervision(pkgId, supTaskIds);
|
|
// List<Map<String, Object>> maps = taskService.listTaskInfo(wmTasks, pkgId.toString());
|
|
// List<Map<String, Object>> maps = taskService.listTaskInfo(wmTasks, pkgId.toString());
|
|
@@ -361,7 +361,7 @@ public class WmSupervisionManager {
|
|
// }
|
|
// }
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 获取可以监察的任务
|
|
|
|
|
|
+ * 获取可以监督的任务
|
|
*
|
|
*
|
|
* @param pkgId 执行包ID
|
|
* @param pkgId 执行包ID
|
|
* @return 任务列表
|
|
* @return 任务列表
|
|
@@ -372,10 +372,10 @@ public class WmSupervisionManager {
|
|
List<Integer> roles = SecurityUtils.getRoles();
|
|
List<Integer> roles = SecurityUtils.getRoles();
|
|
|
|
|
|
|
|
|
|
- // 监察员
|
|
|
|
|
|
+ // 监督员
|
|
if (CollUtil.containsAny(roles, List.of(49, 52, 53, 56))) {
|
|
if (CollUtil.containsAny(roles, List.of(49, 52, 53, 56))) {
|
|
|
|
|
|
- // 获取当前积分包已经监察过的任务ID
|
|
|
|
|
|
+ // 获取当前积分包已经监督过的任务ID
|
|
Set<Integer> supTaskIds = taskSupervisionService.list(Wrappers.<WmTaskSupervision>lambdaQuery().eq(WmTaskSupervision::getPackageId, pkgId)).stream().mapToInt(WmTaskSupervision::getTaskId).boxed().collect(Collectors.toSet());
|
|
Set<Integer> supTaskIds = taskSupervisionService.list(Wrappers.<WmTaskSupervision>lambdaQuery().eq(WmTaskSupervision::getPackageId, pkgId)).stream().mapToInt(WmTaskSupervision::getTaskId).boxed().collect(Collectors.toSet());
|
|
|
|
|
|
List<WmTask> wmTasks = taskService.listAvailableTaskForSupervision(pkgId, supTaskIds);
|
|
List<WmTask> wmTasks = taskService.listAvailableTaskForSupervision(pkgId, supTaskIds);
|
|
@@ -384,7 +384,7 @@ public class WmSupervisionManager {
|
|
|
|
|
|
return maps;
|
|
return maps;
|
|
} else if (CollUtil.containsAny(roles, List.of(37))) {
|
|
} else if (CollUtil.containsAny(roles, List.of(37))) {
|
|
- // 获取当前积分包已经监察过的任务ID
|
|
|
|
|
|
+ // 获取当前积分包已经监督过的任务ID
|
|
List<WmTaskSupervision> list = taskSupervisionService.list(Wrappers.<WmTaskSupervision>lambdaQuery()
|
|
List<WmTaskSupervision> list = taskSupervisionService.list(Wrappers.<WmTaskSupervision>lambdaQuery()
|
|
.eq(WmTaskSupervision::getSupervisionState, UpmsState.TaskSupervisionState.PASSED)
|
|
.eq(WmTaskSupervision::getSupervisionState, UpmsState.TaskSupervisionState.PASSED)
|
|
.eq(WmTaskSupervision::getPackageId, pkgId).orderByDesc(WmTaskSupervision::getCreateTime));
|
|
.eq(WmTaskSupervision::getPackageId, pkgId).orderByDesc(WmTaskSupervision::getCreateTime));
|
|
@@ -411,7 +411,7 @@ public class WmSupervisionManager {
|
|
} else {
|
|
} else {
|
|
|
|
|
|
|
|
|
|
- // 获取当前积分包已经监察过的任务ID
|
|
|
|
|
|
+ // 获取当前积分包已经监督过的任务ID
|
|
List<WmTaskSupervision> list = taskSupervisionService.
|
|
List<WmTaskSupervision> list = taskSupervisionService.
|
|
list(Wrappers.<WmTaskSupervision>lambdaQuery()
|
|
list(Wrappers.<WmTaskSupervision>lambdaQuery()
|
|
.eq(WmTaskSupervision::getPackageId, pkgId)
|
|
.eq(WmTaskSupervision::getPackageId, pkgId)
|
|
@@ -446,7 +446,7 @@ public class WmSupervisionManager {
|
|
Set<Integer> temp = CollUtil.unionDistinct(passed, rejected);
|
|
Set<Integer> temp = CollUtil.unionDistinct(passed, rejected);
|
|
supTaskIds = CollUtil.subtractToList(ckt2, temp);
|
|
supTaskIds = CollUtil.subtractToList(ckt2, temp);
|
|
} else {
|
|
} else {
|
|
- throw new BizException("无监察权限");
|
|
|
|
|
|
+ throw new BizException("无监督权限");
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
@@ -613,7 +613,7 @@ public class WmSupervisionManager {
|
|
.eq(WmTask::getScorePackageId, pkg.toString()));
|
|
.eq(WmTask::getScorePackageId, pkg.toString()));
|
|
|
|
|
|
|
|
|
|
- String msg = "积分包【" + scorePackage.getScorePackageName() + "】中共有审核通过的服务" + taskCount + "条,监察员共监察" + list.size() + "条,监察占比为"
|
|
|
|
|
|
+ String msg = "积分包【" + scorePackage.getScorePackageName() + "】中共有审核通过的服务" + taskCount + "条,监督员共监督" + list.size() + "条,监督占比为"
|
|
+ String.format("%.2f", (list.size() * 100.0f / taskCount)) + "%";
|
|
+ String.format("%.2f", (list.size() * 100.0f / taskCount)) + "%";
|
|
|
|
|
|
|
|
|
|
@@ -641,7 +641,7 @@ public class WmSupervisionManager {
|
|
state = UpmsState.PackageSupervisionState.PASSED;
|
|
state = UpmsState.PackageSupervisionState.PASSED;
|
|
break;
|
|
break;
|
|
default:
|
|
default:
|
|
- throw new BizException("监察状态不正确,不能操作");
|
|
|
|
|
|
+ throw new BizException("监督状态不正确,不能操作");
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
@@ -662,7 +662,7 @@ public class WmSupervisionManager {
|
|
supervision.setSupervisionState(UpmsState.PackageSupervisionState.REJECTED);
|
|
supervision.setSupervisionState(UpmsState.PackageSupervisionState.REJECTED);
|
|
packageSupervisionService.updateById(supervision);
|
|
packageSupervisionService.updateById(supervision);
|
|
|
|
|
|
- // 如果审核拒绝 任务监察信息全部放弃 重新审核
|
|
|
|
|
|
+ // 如果审核拒绝 任务监督信息全部放弃 重新审核
|
|
taskSupervisionService.remove(Wrappers.<WmTaskSupervision>lambdaQuery().eq(WmTaskSupervision::getPackageId, supervision.getPackageId()).eq(WmTaskSupervision::getCreateBy, supervision.getCreateBy()));
|
|
taskSupervisionService.remove(Wrappers.<WmTaskSupervision>lambdaQuery().eq(WmTaskSupervision::getPackageId, supervision.getPackageId()).eq(WmTaskSupervision::getCreateBy, supervision.getCreateBy()));
|
|
|
|
|
|
}
|
|
}
|
|
@@ -691,7 +691,7 @@ public class WmSupervisionManager {
|
|
// state = UpmsState.TaskSupervisionState.PASSED;
|
|
// state = UpmsState.TaskSupervisionState.PASSED;
|
|
// break;
|
|
// break;
|
|
// default:
|
|
// default:
|
|
-// throw new BizException("监察状态不正确,不能操作");
|
|
|
|
|
|
+// throw new BizException("监督状态不正确,不能操作");
|
|
//
|
|
//
|
|
// }
|
|
// }
|
|
//
|
|
//
|