diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotReactiveStatusApiImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotReactiveStatusApiImpl.java index a69a76792..779bb3b40 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotReactiveStatusApiImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotReactiveStatusApiImpl.java @@ -37,9 +37,6 @@ public class RobotReactiveStatusApiImpl implements RobotReactiveStatusApi { @Resource private RedisUtil redisUtil; - @Value("${zn.robot_error_level_time:30}") - private Long robotErrorLevelTime; - @Resource private RobotWarnMsgService warnMsgService; @@ -127,8 +124,8 @@ public class RobotReactiveStatusApiImpl implements RobotReactiveStatusApi { msg = warnMsg.getWarnMsg(); } } - redisUtil.set(errorLevelKey, level, robotErrorLevelTime); - redisUtil.set(errorMsgKey, errorMsg, robotErrorLevelTime); + redisUtil.set(errorLevelKey, level); + redisUtil.set(errorMsgKey, errorMsg); warnMsgService.sendWarnMsgToWebsocket(msg); diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/robot/vo/RobotTaskSaveReqVO.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/robot/vo/RobotTaskSaveReqVO.java index 90d677356..bc9f7d549 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/robot/vo/RobotTaskSaveReqVO.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/robot/vo/RobotTaskSaveReqVO.java @@ -22,6 +22,7 @@ public class RobotTaskSaveReqVO { private List taskDetailList; @Schema(description = "物料信息") + @Size(min = 0, max = 100, message = "物料信息输入的数据长度超过限制") private String skuInfo; @Schema(description = "物料批次号") @@ -34,6 +35,7 @@ public class RobotTaskSaveReqVO { private Long priority; @Schema(description = "其他信息") + @Size(min = 0, max = 100, message = "其他信息输入的数据长度超过限制") private String otherMsg; @Schema(description = "循环(0:不循环、1:循环)") diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/log/UserOperationLogServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/log/UserOperationLogServiceImpl.java index 3882d8b8e..38f09f714 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/log/UserOperationLogServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/log/UserOperationLogServiceImpl.java @@ -33,6 +33,9 @@ public class UserOperationLogServiceImpl implements UserOperationLogService { @Override public Long createUserOperationLog(UserOperationLogSaveReqVO createReqVO) { // 插入 + if (createReqVO.getOperateAction().length() > 95) { + createReqVO.setOperateAction(createReqVO.getOperateAction().substring(0,95)); + } UserOperationLogDO userOperationLog = BeanUtils.toBean(createReqVO, UserOperationLogDO.class); userOperationLogMapper.insert(userOperationLog); // 返回 diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/robot/RobotTaskServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/robot/RobotTaskServiceImpl.java index 99f60d124..6375478ee 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/robot/RobotTaskServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/robot/RobotTaskServiceImpl.java @@ -1052,6 +1052,10 @@ public class RobotTaskServiceImpl extends ServiceImpl pageResult = null; PageResult dataPage = new PageResult<>(); List list = new ArrayList<>(); - if (ObjectUtil.isEmpty(pageReqVO.getRobotNo())) { + if (ObjectUtil.isEmpty(pageReqVO.getRobotNo()) && ObjectUtil.isEmpty(pageReqVO.getTaskStage())) { pageResult = taskMapper.selectPage(pageReqVO); dataPage.setTotal(pageResult.getTotal()); list = pageResult.getList(); @@ -1176,8 +1180,24 @@ public class RobotTaskServiceImpl extends ServiceImpl targetList = BeanUtil.copyToList(list, RobotTaskRespVO.class); - for (RobotTaskRespVO robotTaskRespVO : targetList) { - robotTaskRespVO.setDetails(taskDetailMapper.queryByTaskId(robotTaskRespVO.getId())); + if (ObjectUtil.isEmpty(targetList)) { + return dataPage; + } + + List takeIds = targetList.stream().map(RobotTaskRespVO::getId).collect(Collectors.toList()); + List taskDetailDOS = taskDetailMapper.selectList(new LambdaQueryWrapperX() + .in(RobotTaskDetailDO::getRobotTaskId, takeIds)); + + Map> detailMap = taskDetailDOS.stream().collect(Collectors.groupingBy(RobotTaskDetailDO::getRobotTaskId)); + + for (RobotTaskRespVO v : targetList) { + List details = detailMap.get(v.getId()); + if (ObjectUtil.isNotEmpty(pageReqVO.getTaskStage())) { + details = details.stream() + .filter(s -> s.getTaskStage().equals(pageReqVO.getTaskStage())) + .collect(Collectors.toList()); + } + v.setDetails(details); } dataPage.setList(targetList); return dataPage; diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/robot/RobotWarnMsgServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/robot/RobotWarnMsgServiceImpl.java index e8fb36d14..09087d380 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/robot/RobotWarnMsgServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/robot/RobotWarnMsgServiceImpl.java @@ -137,6 +137,9 @@ public class RobotWarnMsgServiceImpl extends ServiceImpl - and t1.task_stage = #{pageReqVO.taskStage} + and t2.task_stage = #{pageReqVO.taskStage} and t2.robot_no like concat('%', #{pageReqVO.robotNo}, '%')