|
@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
|
|
import com.gree.mall.manager.bean.admin.AdminUserCom;
|
|
|
import com.gree.mall.manager.bean.policy.WorkerManagerBean;
|
|
|
import com.gree.mall.manager.bean.policy.WorkerManagerDetail;
|
|
|
+import com.gree.mall.manager.bean.policy.WorkerUserCount;
|
|
|
import com.gree.mall.manager.enums.*;
|
|
|
import com.gree.mall.manager.enums.workorder.OrderBaseStatusEnum;
|
|
|
import com.gree.mall.manager.exception.RemoteServiceException;
|
|
@@ -600,4 +601,27 @@ public class WorkerManagerLogic {
|
|
|
workerPolicyService.saveOrUpdateBatch(workerManagerBean.getWorkerPolicies());
|
|
|
|
|
|
}
|
|
|
+
|
|
|
+ public WorkerUserCount countWorker(String id) {
|
|
|
+
|
|
|
+
|
|
|
+ AdminUserCom adminUser = commonLogic.getAdminUser();
|
|
|
+ List<WebsitUser> websitUsers = websitUserService.lambdaQuery().in(!CollectionUtils.isEmpty(adminUser.getAdminWebsitIds())
|
|
|
+ , WebsitUser::getWebsitId, adminUser.getAdminWebsitIds())
|
|
|
+ .list();
|
|
|
+
|
|
|
+ WorkerUserCount workerUserCount = new WorkerUserCount();
|
|
|
+ workerUserCount.setRzsp(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.WAIT.getKey())).count());
|
|
|
+ workerUserCount.setDsfgm(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.WAIT_WORKER.getKey())).count());
|
|
|
+ workerUserCount.setBxsp(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.POLICY_WAIT.getKey())).count());
|
|
|
+ workerUserCount.setZtzc(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.OK.getKey())).count());
|
|
|
+ workerUserCount.setYbh(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.FAIL.getKey())).count());
|
|
|
+ workerUserCount.setZjkgq(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.EXPIRED.getKey())).count());
|
|
|
+ workerUserCount.setZjygq(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.OVERDUE.getKey())).count());
|
|
|
+ workerUserCount.setYzt(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.STOP.getKey())).count());
|
|
|
+ workerUserCount.setYlz(websitUsers.stream().filter(item -> item.getExamineStatus().equals(ExamineWorkerStatusEnum.QUIT.getKey())).count());
|
|
|
+ return workerUserCount;
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
}
|