| | |
|---|
| | | MPJLambdaWrapperX<MesProTaskDO> query = new MPJLambdaWrapperX<>(); |
|---|
| | | query.selectAll(MesProTaskDO.class); |
|---|
| | | // 待报工台账：进行中的任务（排除已完成/已取消），且仍有待报工量 |
|---|
| | | query.in(MesProTaskDO::getStatus, MesProTaskStatusEnum.PREPARE.getStatus(),MesProTaskStatusEnum.PAUSED.getStatus()); |
|---|
| | | query.in(MesProTaskDO::getStatus, MesProTaskStatusEnum.PREPARE.getStatus(), |
|---|
| | | MesProTaskStatusEnum.PRODUCING.getStatus(), MesProTaskStatusEnum.PARTIAL_FINISHED.getStatus(), |
|---|
| | | MesProTaskStatusEnum.PAUSED.getStatus()); |
|---|
| | | query.apply("(quantity - IFNULL(produced_quantity, 0)) > 0"); |
|---|
| | | query.likeIfPresent(MesProTaskDO::getCode, reqVO.getCode()) |
|---|
| | | .likeIfPresent(MesProTaskDO::getName, reqVO.getName()) |
|---|
| | |
|---|
| | | .betweenIfPresent(MesProTaskDO::getCreateTime, reqVO.getCreateTime()) |
|---|
| | | .orderByDesc(MesProTaskDO::getId); |
|---|
| | | return selectPage(reqVO, query); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 按工作站统计待报工任务数，口径与 {@link #selectPendingFeedbackPage} 一致 |
|---|
| | | * |
|---|
| | | * @return 每行包含 workstation_id、pending_count |
|---|
| | | */ |
|---|
| | | default List<Map<String, Object>> selectPendingFeedbackCountByWorkstation() { |
|---|
| | | return selectMaps(new QueryWrapper<MesProTaskDO>() |
|---|
| | | .select("workstation_id", "COUNT(*) AS pending_count") |
|---|
| | | .in("status", MesProTaskStatusEnum.PREPARE.getStatus(), |
|---|
| | | MesProTaskStatusEnum.PRODUCING.getStatus(), MesProTaskStatusEnum.PARTIAL_FINISHED.getStatus(), |
|---|
| | | MesProTaskStatusEnum.PAUSED.getStatus()) |
|---|
| | | .apply("(quantity - IFNULL(produced_quantity, 0)) > 0") |
|---|
| | | .isNotNull("workstation_id") |
|---|
| | | .groupBy("workstation_id")); |
|---|
| | | } |
|---|
| | | |
|---|
| | | default List<MesProTaskDO> selectListByWorkOrderId(Long workOrderId) { |
|---|
| | |
|---|
| | | .eq(MesProTaskDO::getId, id) |
|---|
| | | .setSql("produced_quantity = IFNULL(produced_quantity, 0) + " + incrProducedQuantity) |
|---|
| | | .setSql("qualify_quantity = IFNULL(qualify_quantity, 0) + " + incrQualifyQuantity) |
|---|
| | | .setSql("unqualify_quantity = IFNULL(unqualify_quantity, 0) + " + incrUnqualifyQuantity)); |
|---|
| | | .setSql("unqualify_quantity = IFNULL(unqualify_quantity, 0) + " + incrUnqualifyQuantity) |
|---|
| | | .setSql("status = CASE WHEN IFNULL(produced_quantity, 0) > 0 THEN " |
|---|
| | | + MesProTaskStatusEnum.PARTIAL_FINISHED.getStatus() + " ELSE " |
|---|
| | | + MesProTaskStatusEnum.PRODUCING.getStatus() + " END") |
|---|
| | | .setSql("first_feedback_time = IFNULL(first_feedback_time, NOW())") |
|---|
| | | .setSql("last_feedback_time = NOW()")); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 查询工作站上正在运行的任务：生产中、部分完成、已停工 |
|---|
| | | * |
|---|
| | | * <p>数采模块根据设备上报的数据定位当前任务时使用。</p> |
|---|
| | | */ |
|---|
| | | default MesProTaskDO selectRunningTaskByWorkstationId(Long workstationId) { |
|---|
| | | return selectOne(new LambdaQueryWrapperX<MesProTaskDO>() |
|---|
| | | .eq(MesProTaskDO::getWorkstationId, workstationId) |
|---|
| | | .in(MesProTaskDO::getStatus, MesProTaskStatusEnum.PRODUCING.getStatus(), |
|---|
| | | MesProTaskStatusEnum.PARTIAL_FINISHED.getStatus(), MesProTaskStatusEnum.PAUSED.getStatus()) |
|---|
| | | .orderByDesc(MesProTaskDO::getLastFeedbackTime) |
|---|
| | | .orderByDesc(MesProTaskDO::getId) |
|---|
| | | .last("LIMIT 1")); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
