紧急维修流程通知消息开发+维保流程消息通知完善

src/main/java/org/springblade/modules/business/contraller/MaintenanceController.java

@@ -203,8 +203,10 @@ public class MaintenanceController extends BladeController {
         taskService.updateById(taskOld);
         //发送消息
         String role = "1839536982874193922";
-        User user = userService.getOne(Wrappers.lambdaQuery(User.class).eq(User::getRoleId, role));
+        List<User> userList = userService.list(Wrappers.lambdaQuery(User.class).eq(User::getRoleId, role));
+        for (User user : userList) {
             messageService.saveMessage(task.getTaskCode(), "客户已经确认巡检任务完成", user.getId(), 1);
+        }
         return R.success();
     }
 
@@ -356,8 +358,10 @@ public class MaintenanceController extends BladeController {
         taskService.updateById(taskOld);
         //发送消息
         String role = "1847220301770326017";
-        User user = userService.getOne(Wrappers.lambdaQuery(User.class).eq(User::getRoleId, role));
+        List<User> userList = userService.list(Wrappers.lambdaQuery(User.class).eq(User::getRoleId, role));
+        for (User user : userList) {
             messageService.saveMessage(task.getTaskCode(), "维修方案已被客户驳回，请重新审批", user.getId(), 1);
+        }
         return R.success();
     }
 

src/main/java/org/springblade/modules/business/service/impl/WorkOrderServiceImpl.java

@@ -121,7 +121,7 @@ public class WorkOrderServiceImpl extends BaseServiceImpl<WorkOrderMapper, WorkO
     @Synchronized
     public boolean saveAndSubmit(List<WorkOrderVO> workOrders) {
         String role = "1839536982874193922";
-        User customerService = userService.getOne(Wrappers.lambdaQuery(User.class).eq(User::getRoleId, role));
+        List<User> customerServiceList = userService.list(Wrappers.lambdaQuery(User.class).eq(User::getRoleId, role));
         SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
         Date now = DateUtil.date();
         String todayStr = format.format(now);
@@ -135,7 +135,9 @@ public class WorkOrderServiceImpl extends BaseServiceImpl<WorkOrderMapper, WorkO
             // 查询今天已提报数量
             String hz = count < 9 ? "0" + (count + 1) : count + 1 + "";
             String code = "WX-" + todayStr + "-" + hz;
+            for (User customerService : customerServiceList) {
                 messageService.saveMessage(code, "您有一个需求单需要处理", customerService.getId(), 2);
+            }
             workOrder.setFillingTime(now);
             workOrder.setRequirementCode(code);
             // 待接单
@@ -346,10 +348,12 @@ public class WorkOrderServiceImpl extends BaseServiceImpl<WorkOrderMapper, WorkO
 
         // 更新设备状态为运行中
         deviceService.updateStatus(CommonConstant.DEVICE_RUN_STATUS_WORKING, workOrder.getDeviceId());
-        String role = "1839536982874193922";
-        User user = userService.getOne(Wrappers.lambdaQuery(User.class).eq(User::getRoleId, role));
         //消息发送
+        String role = "1839536982874193922";
+        List<User> userList = userService.list(Wrappers.lambdaQuery(User.class).eq(User::getRoleId, role));
+        for (User user : userList) {
             messageService.saveMessage(workOrder.getRequirementCode(), "已完成维修，请确认客户是否付款", user.getId(), 2);
+        }
 
     }