diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/common/pojo/entity/MesNotifyMessageEntity.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/common/pojo/entity/MesNotifyMessageEntity.java index 6881af0b..a6ccfbc2 100644 --- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/common/pojo/entity/MesNotifyMessageEntity.java +++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/common/pojo/entity/MesNotifyMessageEntity.java @@ -45,4 +45,15 @@ public class MesNotifyMessageEntity extends BaseEntity { @Schema(description = "接收人ID") private Long receiveUserId; + /** + * 接收人角色ID + */ + @Schema(description = "接收人角色ID") + private Long receiveRoleId; + + /** + * 接收人角色名称 + */ + @Schema(description = "接收人角色名称") + private String receiveRoleName; } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/common/controller/MesNotifyMessageController.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/common/controller/MesNotifyMessageController.java index f218e907..283f6401 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/common/controller/MesNotifyMessageController.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/common/controller/MesNotifyMessageController.java @@ -66,6 +66,7 @@ public class MesNotifyMessageController extends BladeController { @Operation(summary = "分页", description = "传入mesNotifyMessage") public R> page(MesNotifyMessageVO mesNotifyMessage, Query query) { mesNotifyMessage.setReceiveUserId(AuthUtil.getUserId()); + mesNotifyMessage.setReceiveRoleName(AuthUtil.getUserRole()); IPage pages = mesNotifyMessageService.selectMesNotifyMessagePage(new Page<>(query.getCurrent(), query.getSize()), mesNotifyMessage); return R.data(pages); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/common/service/impl/MesNotifyMessageServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/common/service/impl/MesNotifyMessageServiceImpl.java index be937004..7fa24a3f 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/common/service/impl/MesNotifyMessageServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/common/service/impl/MesNotifyMessageServiceImpl.java @@ -57,6 +57,11 @@ public class MesNotifyMessageServiceImpl extends BaseServiceImpl mesNotifyMessageVOList = this.page(page, new LambdaQueryWrapper() .eq(StrUtil.isNotEmpty(mesNotifyMessage.getBizType()), MesNotifyMessageEntity::getBizType, mesNotifyMessage.getBizType()) .like(StrUtil.isNotEmpty(mesNotifyMessage.getContent()), MesNotifyMessageEntity::getContent, mesNotifyMessage.getContent()) + .and(wrapper -> wrapper + .eq(MesNotifyMessageEntity::getReceiveUserId, mesNotifyMessage.getReceiveUserId()) + .or() + .eq(MesNotifyMessageEntity::getReceiveRoleName, mesNotifyMessage.getReceiveRoleName()) + ) .orderByDesc(MesNotifyMessageEntity::getCreateTime)); Page page1 = new Page<>(); if (!mesNotifyMessageVOList.getRecords().isEmpty()){ diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/PlanTestServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/PlanTestServiceImpl.java index f5c35cbb..c0794685 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/PlanTestServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/quality/service/impl/PlanTestServiceImpl.java @@ -149,13 +149,10 @@ public class PlanTestServiceImpl extends BaseServiceImpl prWorkOrderList = workOrderMapper.selectList(new LambdaQueryWrapper() - .eq(WorkOrder::getWpId, planTest.getWpId())); - if (prWorkOrderList == null || prWorkOrderList.isEmpty()){ - return null; - } - JSONObject obj = httpRequestService.testRec(prWorkOrderList.get(0).getWoCode(), planTest.getErpId(),planTest.getDataId()); + // 查询wpCode + WorkPlan workPlan = workPlanService.getById(planTest.getWpId()); + WorkOrder workOrder = workOrderMapper.selectById(workPlan.getWoId()); + JSONObject obj = httpRequestService.testRec(workOrder.getWoCode(), planTest.getErpId(),planTest.getDataId()); if (obj != null) { JSONObject data = obj.getJSONObject("data"); return data.getJSONArray("nodeEndTime");