From 250c85b1ee1a8cdba7667c7aa3bfa87a601f9caa Mon Sep 17 00:00:00 2001 From: Yangk Date: Thu, 15 Jan 2026 10:31:37 +0800 Subject: [PATCH] =?UTF-8?q?feat(mes):=20=E6=96=B0=E5=A2=9E=E7=9C=8B?= =?UTF-8?q?=E6=9D=BF=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 新增看板接口5，返回合格数/不合格数统计数据 - 新增看板接口6，返回产品良率统计数据 --- .../mes/controller/ProdReportController.java | 47 ++- .../mes/service/IProdReportService.java | 334 +++++++++--------- .../service/impl/ProdReportServiceImpl.java | 232 ++++++++---- 3 files changed, 363 insertions(+), 250 deletions(-) diff --git a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/controller/ProdReportController.java b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/controller/ProdReportController.java index 2d4a153c..0b92402c 100644 --- a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/controller/ProdReportController.java +++ b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/controller/ProdReportController.java @@ -1,6 +1,5 @@ package org.dromara.mes.controller; - import jakarta.servlet.http.HttpServletResponse; import lombok.RequiredArgsConstructor; import org.dromara.common.core.domain.R; @@ -18,7 +17,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; - /** * MES生产报表Controller * @@ -40,7 +38,8 @@ public class ProdReportController extends BaseController { * @return */ @GetMapping("/planCompletionRateReport") - public TableDataInfo planCompletionRateReportList(@RequestParam(required = false) Map hashMap, PageQuery pageQuery) { + public TableDataInfo planCompletionRateReportList( + @RequestParam(required = false) Map hashMap, PageQuery pageQuery) { return prodReportService.planCompletionRateReportVoList(hashMap, pageQuery); } @@ -51,12 +50,12 @@ public class ProdReportController extends BaseController { * @return */ @PostMapping("/planCompletionRateReport/export") - public void planCompletionRateReportListExport(@RequestParam(required = false) Map hashMap, HttpServletResponse response) { + public void planCompletionRateReportListExport(@RequestParam(required = false) Map hashMap, + HttpServletResponse response) { List list = prodReportService.planCompletionRateReportVoList(hashMap); ExcelUtil.exportExcel(list, "生产计划完成率报表", PlanCompletionRateReportVo.class, response); } - /** * 生产计划完成率对比报表 * @@ -64,7 +63,8 @@ public class ProdReportController extends BaseController { * @return */ @GetMapping("/planCompletionContrastReport") - public TableDataInfo planCompletionContrastReportVoList(@RequestParam(required = false) Map hashMap, PageQuery pageQuery) { + public TableDataInfo planCompletionContrastReportVoList( + @RequestParam(required = false) Map hashMap, PageQuery pageQuery) { return prodReportService.planCompletionContrastReportVoList(hashMap, pageQuery); } @@ -75,12 +75,12 @@ public class ProdReportController extends BaseController { * @return */ @PostMapping("/planCompletionContrastReport/export") - public void planCompletionContrastReportExport(@RequestParam(required = false) Map hashMap, HttpServletResponse response) { + public void planCompletionContrastReportExport(@RequestParam(required = false) Map hashMap, + HttpServletResponse response) { List list = prodReportService.planCompletionContrastReportVoList(hashMap); ExcelUtil.exportExcel(list, "生产计划完成率对比报表", PlanCompletionContrastReportVo.class, response); } - /** * 大屏设计：生产计划完成率接口 * @@ -123,12 +123,12 @@ public class ProdReportController extends BaseController { return R.ok(vos); } - /** * 报工工时数据报表 */ @GetMapping("/workHourReport") - public TableDataInfo workHourReport(@RequestParam(required = false) Map hashMap, PageQuery pageQuery) { + public TableDataInfo workHourReport(@RequestParam(required = false) Map hashMap, + PageQuery pageQuery) { return prodReportService.workHourReportList(hashMap, pageQuery); } @@ -145,7 +145,8 @@ public class ProdReportController extends BaseController { * 班组作业情况报表 */ @GetMapping("/teamWorkReport") - public TableDataInfo teamWorkReport(@RequestParam(required = false) Map hashMap, PageQuery pageQuery) { + public TableDataInfo teamWorkReport(@RequestParam(required = false) Map hashMap, + PageQuery pageQuery) { return prodReportService.teamWorkReportList(hashMap, pageQuery); } @@ -163,7 +164,8 @@ public class ProdReportController extends BaseController { * 在制品跟踪报表 */ @GetMapping("/wipTrackingReport") - public TableDataInfo wipTrackingReport(@RequestParam(required = false) Map hashMap, PageQuery pageQuery) { + public TableDataInfo wipTrackingReport(@RequestParam(required = false) Map hashMap, + PageQuery pageQuery) { return prodReportService.wipTrackingReportList(hashMap, pageQuery); } @@ -205,7 +207,8 @@ public class ProdReportController extends BaseController { * 工序工单统计（分页，按工序聚合） */ @GetMapping("/processWorkOrderStats/page") - public TableDataInfo> processWorkOrderStatsPage(@RequestParam(required = false) Map hashMap, PageQuery pageQuery) { + public TableDataInfo> processWorkOrderStatsPage(@RequestParam(required = false) Map hashMap, + PageQuery pageQuery) { return prodReportService.processWorkOrderStatsPage(hashMap, pageQuery); } @@ -286,4 +289,22 @@ public class ProdReportController extends BaseController { return R.ok(result); } + /** + * 看板接口5：返回合格数/不合格数统计数据 + */ + @GetMapping("/dashboard/data5") + public R> dashboardData5(@RequestParam(required = false) Map hashMap) { + HashMap vos = prodReportService.getDashboardData5(hashMap); + return R.ok(vos); + } + + /** + * 看板接口6：返回产品良率统计数据 + */ + @GetMapping("/dashboard/data6") + public R> dashboardData6(@RequestParam(required = false) Map hashMap) { + HashMap vos = prodReportService.getDashboardData6(hashMap); + return R.ok(vos); + } + } diff --git a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/IProdReportService.java b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/IProdReportService.java index 40a96081..b2d0af7e 100644 --- a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/IProdReportService.java +++ b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/IProdReportService.java @@ -1,6 +1,5 @@ package org.dromara.mes.service; - import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.mes.domain.vo.*; @@ -17,187 +16,204 @@ import java.util.Map; */ public interface IProdReportService { - /** - * 生产计划完成率报表 - * - * @param hashMap - * @param pageQuery - * @return - */ - TableDataInfo planCompletionRateReportVoList(Map hashMap, PageQuery pageQuery); + /** + * 生产计划完成率报表 + * + * @param hashMap + * @param pageQuery + * @return + */ + TableDataInfo planCompletionRateReportVoList(Map hashMap, PageQuery pageQuery); - /** - * 生产计划完成率报表导出 - * - * @param hashMap - * @return - */ - List planCompletionRateReportVoList(Map hashMap); + /** + * 生产计划完成率报表导出 + * + * @param hashMap + * @return + */ + List planCompletionRateReportVoList(Map hashMap); - /** - * 生产计划完成率对比报表 - * @param hashMap - * @param pageQuery - * @return - */ - TableDataInfo planCompletionContrastReportVoList(Map hashMap, PageQuery pageQuery); + /** + * 生产计划完成率对比报表 + * @param hashMap + * @param pageQuery + * @return + */ + TableDataInfo planCompletionContrastReportVoList(Map hashMap, PageQuery pageQuery); - /** - * 生产计划完成率对比报表导出 - * - * @param hashMap - * @return - */ - List planCompletionContrastReportVoList(Map hashMap); + /** + * 生产计划完成率对比报表导出 + * + * @param hashMap + * @return + */ + List planCompletionContrastReportVoList(Map hashMap); - /** - * 日产量接口 - * @param hashMap - * @return - */ - List> designDailyOutputInformation(Map hashMap); + /** + * 日产量接口 + * @param hashMap + * @return + */ + List> designDailyOutputInformation(Map hashMap); - /** - * 良率汇总（按机台） - * @param hashMap 查询条件 - * @return 列表 */ - List> yieldSummaryByMachine(Map hashMap); + /** + * 良率汇总（按机台） + * @param hashMap 查询条件 + * @return 列表 + */ + List> yieldSummaryByMachine(Map hashMap); - /** - * 良率趋势（日维度） - * @param hashMap 查询条件 - * @return 列表 - */ - List> yieldTrendByDate(Map hashMap); + /** + * 良率趋势（日维度） + * @param hashMap 查询条件 + * @return 列表 + */ + List> yieldTrendByDate(Map hashMap); - /** - * 报工工时数据报表 - * @param hashMap 查询参数 - * @param pageQuery 分页参数 - * @return 表格数据 - */ - TableDataInfo workHourReportList(Map hashMap, PageQuery pageQuery); + /** + * 报工工时数据报表 + * @param hashMap 查询参数 + * @param pageQuery 分页参数 + * @return 表格数据 + */ + TableDataInfo workHourReportList(Map hashMap, PageQuery pageQuery); - /** - * 报工工时数据报表导出 - * @param hashMap 查询参数 - * @return 列表数据 - */ - List workHourReportList(Map hashMap); + /** + * 报工工时数据报表导出 + * @param hashMap 查询参数 + * @return 列表数据 + */ + List workHourReportList(Map hashMap); - /** - * 班组作业情况报表 - * @param hashMap 查询参数 - * @param pageQuery 分页参数 - * @return 表格数据 - */ - TableDataInfo teamWorkReportList(Map hashMap, PageQuery pageQuery); + /** + * 班组作业情况报表 + * @param hashMap 查询参数 + * @param pageQuery 分页参数 + * @return 表格数据 + */ + TableDataInfo teamWorkReportList(Map hashMap, PageQuery pageQuery); - /** - * 班组作业情况报表导出 - * @param hashMap 查询参数 - * @return 列表数据 - */ - List teamWorkReportList(Map hashMap); + /** + * 班组作业情况报表导出 + * @param hashMap 查询参数 + * @return 列表数据 + */ + List teamWorkReportList(Map hashMap); - /** - * 在制品跟踪报表 - * @param hashMap 查询参数 - * @param pageQuery 分页参数 - * @return 表格数据 - */ - TableDataInfo wipTrackingReportList(Map hashMap, PageQuery pageQuery); + /** + * 在制品跟踪报表 + * @param hashMap 查询参数 + * @param pageQuery 分页参数 + * @return 表格数据 + */ + TableDataInfo wipTrackingReportList(Map hashMap, PageQuery pageQuery); - /** - * 在制品跟踪报表导出 - * @param hashMap 查询参数 - * @return 列表数据 - */ - List wipTrackingReportList(Map hashMap); + /** + * 在制品跟踪报表导出 + * @param hashMap 查询参数 + * @return 列表数据 + */ + List wipTrackingReportList(Map hashMap); - /** - * 获取订单的工序进度详情 - * @param productOrderId 产品订单ID - * @return 工序进度列表 - */ -// List getOrderProcessProgress(Long productOrderId); + /** + * 获取订单的工序进度详情 + * @param productOrderId 产品订单ID + * @return 工序进度列表 + */ + // List getOrderProcessProgress(Long productOrderId); - /** - * 转换为导出VO - * @param reportList 在制品跟踪报表列表 - * @return 导出VO列表 - */ - List convertToExportVo(List reportList); + /** + * 转换为导出VO + * @param reportList 在制品跟踪报表列表 + * @return 导出VO列表 + */ + List convertToExportVo(List reportList); - /** - * 小时产量统计（按结束时间小时分桶） - * @param hashMap 查询条件：beginDate/endDate、processId、machineId、shiftId、classTeamId、materialName - * @return 列表：productionDate、hourSlot、productionQuantity、qualifiedQuantity、unqualifiedQuantity - */ - List> hourlyOutputByHour(Map hashMap); + /** + * 小时产量统计（按结束时间小时分桶） + * @param hashMap 查询条件：beginDate/endDate、processId、machineId、shiftId、classTeamId、materialName + * @return 列表：productionDate、hourSlot、productionQuantity、qualifiedQuantity、unqualifiedQuantity + */ + List> hourlyOutputByHour(Map hashMap); - /** - * 工序工单统计（按工序聚合）：完成数量、未完成数量与完成率 - * @param hashMap 查询条件：beginDate/endDate、processId、machineId、shiftId、classTeamId、materialName - * @return 各工序聚合统计列表 - */ - List> processWorkOrderStats(Map hashMap); + /** + * 工序工单统计（按工序聚合）：完成数量、未完成数量与完成率 + * @param hashMap 查询条件：beginDate/endDate、processId、machineId、shiftId、classTeamId、materialName + * @return 各工序聚合统计列表 + */ + List> processWorkOrderStats(Map hashMap); - /** - * 工序工单统计（分页，按工序聚合） - * @param hashMap 查询条件 - * @param pageQuery 分页参数 - * @return 表格数据 - */ - TableDataInfo> processWorkOrderStatsPage(Map hashMap, PageQuery pageQuery); + /** + * 工序工单统计（分页，按工序聚合） + * @param hashMap 查询条件 + * @param pageQuery 分页参数 + * @return 表格数据 + */ + TableDataInfo> processWorkOrderStatsPage(Map hashMap, PageQuery pageQuery); - /** - * 工序工单统计导出（按工序聚合） - * @param hashMap 查询条件 - * @return 导出列表 - */ - List processWorkOrderStatsExport(Map hashMap); + /** + * 工序工单统计导出（按工序聚合） + * @param hashMap 查询条件 + * @return 导出列表 + */ + List processWorkOrderStatsExport(Map hashMap); - /** - * 工序下的计划子节点查询：按 plan_code + process_id 过滤，关联明细表 - * @param hashMap 查询条件：planCode、processId - * @return 计划明细子节点列表 - */ - List> planProcessDetailChildren(Map hashMap); + /** + * 工序下的计划子节点查询：按 plan_code + process_id 过滤，关联明细表 + * @param hashMap 查询条件：planCode、processId + * @return 计划明细子节点列表 + */ + List> planProcessDetailChildren(Map hashMap); - /** - * 按工序查询计划列表（不分页） - * @param hashMap 查询条件：beginDate/endDate、processId、machineId、shiftId、classTeamId、planCode、materialName、materialCode - * @return 计划列表 - */ - List> listPlansByProcess(Map hashMap); + /** + * 按工序查询计划列表（不分页） + * @param hashMap 查询条件：beginDate/endDate、processId、machineId、shiftId、classTeamId、planCode、materialName、materialCode + * @return 计划列表 + */ + List> listPlansByProcess(Map hashMap); - /** - * 看板接口1：返回包含value1-value5的数据列表 - * @param hashMap 查询条件 - * @return 数据列表 - */ - List> getDashboardData1(Map hashMap); + /** + * 看板接口1：返回包含value1-value5的数据列表 + * @param hashMap 查询条件 + * @return 数据列表 + */ + List> getDashboardData1(Map hashMap); - /** - * 看板接口2：返回包含x1和y1数组的数据 - * @param hashMap 查询条件 - * @return 数据对象 - */ - HashMap getDashboardData2(Map hashMap); + /** + * 看板接口2：返回包含x1和y1数组的数据 + * @param hashMap 查询条件 + * @return 数据对象 + */ + HashMap getDashboardData2(Map hashMap); - /** - * 看板接口3：返回包含时间格式x1和y1数组的数据 - * @param hashMap 查询条件 - * @return 数据对象 - */ - HashMap getDashboardData3(Map hashMap); + /** + * 看板接口3：返回包含时间格式x1和y1数组的数据 + * @param hashMap 查询条件 + * @return 数据对象 + */ + HashMap getDashboardData3(Map hashMap); - /** - * 看板接口4：返回包含value1-value4的数据列表 - * @param hashMap 查询条件 - * @return 数据列表 - */ - List> getDashboardData4(Map hashMap); + /** + * 看板接口4：返回包含value1-value4的数据列表 + * @param hashMap 查询条件 + * @return 数据列表 + */ + List> getDashboardData4(Map hashMap); + + /** + * 看板接口5：返回合格数/不合格数统计数据 + * + * @param hashMap 查询条件 + * @return 数据对象（x1: 类别数组, y1: 数值数组） + */ + HashMap getDashboardData5(Map hashMap); + + /** + * 看板接口6：返回产品良率统计数据 + * + * @param hashMap 查询条件 + * @return 数据对象（x1: 产品名称数组, y1: 良率数值数组） + */ + HashMap getDashboardData6(Map hashMap); } diff --git a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/impl/ProdReportServiceImpl.java b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/impl/ProdReportServiceImpl.java index 6bbc3815..91a153a0 100644 --- a/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/impl/ProdReportServiceImpl.java +++ b/ruoyi-modules/hwmom-mes/src/main/java/org/dromara/mes/service/impl/ProdReportServiceImpl.java @@ -43,7 +43,8 @@ public class ProdReportServiceImpl implements IProdReportService { @Override public TableDataInfo planCompletionRateReportVoList(Map hashMap, PageQuery pageQuery) { String tableName = getPlanInfoTableNameByProcessId(Long.parseLong(String.valueOf(hashMap.get("processId")))); - Page page = prodReportMapper.planCompletionRateReportVoList(hashMap, pageQuery.build(), tableName); + Page page = prodReportMapper.planCompletionRateReportVoList(hashMap, + pageQuery.build(), tableName); return TableDataInfo.build(page); } @@ -91,7 +92,7 @@ public class ProdReportServiceImpl implements IProdReportService { if (StringUtils.isNull(processId)) { // 默认返回半制品表 tableName = DatabaseConstants.TABLE_NAME_PROD_PRODUCT_PLAN_DETAIL_PREFIX + "_2"; - }else if (processId == 17L) { + } else if (processId == 17L) { tableName = DatabaseConstants.TABLE_NAME_PROD_PRODUCT_PLAN_DETAIL_PREFIX + "_3"; } else if (processId == 18L) { tableName = DatabaseConstants.TABLE_NAME_PROD_PRODUCT_PLAN_DETAIL_PREFIX + "_4"; @@ -108,9 +109,11 @@ public class ProdReportServiceImpl implements IProdReportService { * @return */ @Override - public TableDataInfo planCompletionContrastReportVoList(Map hashMap, PageQuery pageQuery) { + public TableDataInfo planCompletionContrastReportVoList(Map hashMap, + PageQuery pageQuery) { String tableName = getPlanInfoTableNameByProcessId(Long.parseLong(String.valueOf(hashMap.get("processId")))); - Page page = prodReportMapper.planCompletionContrastReportVoList(hashMap, pageQuery.build(), tableName); + Page page = prodReportMapper.planCompletionContrastReportVoList(hashMap, + pageQuery.build(), tableName); return TableDataInfo.build(page); } @@ -157,7 +160,8 @@ public class ProdReportServiceImpl implements IProdReportService { Long processId = parseProcessId(String.valueOf(hashMap.get("processId"))); String detailTable = getPlanDetailTableNameByProcessId(processId); String planTable = getPlanInfoTableNameByProcessId(processId); - Page page = prodReportMapper.workHourReportList(hashMap, pageQuery.build(), detailTable, planTable); + Page page = prodReportMapper.workHourReportList(hashMap, pageQuery.build(), detailTable, + planTable); return TableDataInfo.build(page); } @@ -188,7 +192,8 @@ public class ProdReportServiceImpl implements IProdReportService { Long processId = parseProcessId(String.valueOf(hashMap.get("processId"))); String detailTable = getPlanDetailTableNameByProcessId(processId); String planTable = getPlanInfoTableNameByProcessId(processId); - Page page = prodReportMapper.teamWorkReportList(hashMap, pageQuery.build(), detailTable, planTable); + Page page = prodReportMapper.teamWorkReportList(hashMap, pageQuery.build(), detailTable, + planTable); return TableDataInfo.build(page); } @@ -202,7 +207,7 @@ public class ProdReportServiceImpl implements IProdReportService { /** * 在制品跟踪报表（分页）- 高性能优化版本 - * @param hashMap 查询参数 + * @param hashMap 查询参数 * @param pageQuery 分页参数 * @return 表格数据 */ @@ -313,10 +318,11 @@ public class ProdReportServiceImpl implements IProdReportService { /** * 批量查询工序进度信息 - * @param orderIds 订单ID列表 + * @param orderIds 订单ID列表 * @param orderProcessMap 结果映射 */ - private void batchQueryProcessProgress(List planCodes, Map> planProcessMap) { + private void batchQueryProcessProgress(List planCodes, + Map> planProcessMap) { // 查询半制品工序进度（prod_plan_info_2） queryProcessProgressByTable(planCodes, "prod_plan_info_2", planProcessMap); @@ -327,27 +333,29 @@ public class ProdReportServiceImpl implements IProdReportService { queryProcessProgressByTable(planCodes, "prod_plan_info_4", planProcessMap); // 对每个计划的工序进度进行排序 - planProcessMap.values().forEach(processList -> - processList.sort((a, b) -> { - if (a.getProcessOrder() == null) return 1; - if (b.getProcessOrder() == null) return -1; - return a.getProcessOrder().compareTo(b.getProcessOrder()); - }) - ); + planProcessMap.values().forEach(processList -> processList.sort((a, b) -> { + if (a.getProcessOrder() == null) + return 1; + if (b.getProcessOrder() == null) + return -1; + return a.getProcessOrder().compareTo(b.getProcessOrder()); + })); } /** * 根据表名查询工序进度信息 - * @param orderIds 订单ID列表 - * @param tableName 表名 + * @param orderIds 订单ID列表 + * @param tableName 表名 * @param orderProcessMap 结果映射 */ - private void queryProcessProgressByTable(List planCodes, String tableName, Map> planProcessMap) { + private void queryProcessProgressByTable(List planCodes, String tableName, + Map> planProcessMap) { try { // 使用批量查询避免 N+1：一次性查询该工序表下所有计划的工序进度 // 返回结果中包含 planCode 字段，便于在此处进行分组 String tenantId = LoginHelper.getTenantId(); - List batchResults = prodReportMapper.getPlansProcessProgressBatch(planCodes, tableName, tenantId); + List batchResults = prodReportMapper.getPlansProcessProgressBatch(planCodes, tableName, + tenantId); if (batchResults != null && !batchResults.isEmpty()) { for (ProcessProgressVo progress : batchResults) { String planCode = progress.getPlanCode(); @@ -364,7 +372,7 @@ public class ProdReportServiceImpl implements IProdReportService { /** * 基于实际工序进度微调计算结果 - * @param vo 在制品跟踪报表VO + * @param vo 在制品跟踪报表VO * @param processProgress 工序进度列表 */ private void adjustProgressCalculation(WipTrackingReportVo vo, List processProgress) { @@ -374,35 +382,35 @@ public class ProdReportServiceImpl implements IProdReportService { try { // 统计工序状态 - long completedCount = processProgress.stream() - .mapToLong(p -> p.getIsCompleted() != null && p.getIsCompleted() == 1 ? 1 : 0) - .sum(); - long inProgressCount = processProgress.stream() - .mapToLong(p -> p.getIsInProgress() != null && p.getIsInProgress() == 1 ? 1 : 0) - .sum(); - long totalCount = processProgress.size(); + long completedCount = processProgress.stream() + .mapToLong(p -> p.getIsCompleted() != null && p.getIsCompleted() == 1 ? 1 : 0) + .sum(); + long inProgressCount = processProgress.stream() + .mapToLong(p -> p.getIsInProgress() != null && p.getIsInProgress() == 1 ? 1 : 0) + .sum(); + long totalCount = processProgress.size(); - // 更新工序统计信息 - vo.setTotalProcessCount(totalCount + "道"); - vo.setTotalProcessCountNum((int) totalCount); + // 更新工序统计信息 + vo.setTotalProcessCount(totalCount + "道"); + vo.setTotalProcessCountNum((int) totalCount); - // 构建在制工序名称（进行中的工序） - String wipProcesses = processProgress.stream() - .filter(p -> p.getIsInProgress() != null && p.getIsInProgress() == 1) - .map(ProcessProgressVo::getProcessName) - .filter(Objects::nonNull) - .collect(Collectors.joining(",")); + // 构建在制工序名称（进行中的工序） + String wipProcesses = processProgress.stream() + .filter(p -> p.getIsInProgress() != null && p.getIsInProgress() == 1) + .map(ProcessProgressVo::getProcessName) + .filter(Objects::nonNull) + .collect(Collectors.joining(",")); - // 构建剩余工序名称（未派工和已派工但未开始的工序） - String remainingProcesses = processProgress.stream() - .filter(p -> (p.getIsCompleted() == null || p.getIsCompleted() == 0) && - (p.getIsInProgress() == null || p.getIsInProgress() == 0)) - .map(ProcessProgressVo::getProcessName) - .filter(Objects::nonNull) - .collect(Collectors.joining(",")); + // 构建剩余工序名称（未派工和已派工但未开始的工序） + String remainingProcesses = processProgress.stream() + .filter(p -> (p.getIsCompleted() == null || p.getIsCompleted() == 0) && + (p.getIsInProgress() == null || p.getIsInProgress() == 0)) + .map(ProcessProgressVo::getProcessName) + .filter(Objects::nonNull) + .collect(Collectors.joining(",")); - vo.setWipProcesses(wipProcesses); - vo.setRemainingProcesses(remainingProcesses); + vo.setWipProcesses(wipProcesses); + vo.setRemainingProcesses(remainingProcesses); } catch (Exception e) { System.out.println("微调进度计算失败，计划编码: " + vo.getPlanCode() + ", 错误: " + e.getMessage()); @@ -452,27 +460,31 @@ public class ProdReportServiceImpl implements IProdReportService { try { // 不依赖 prod_order_info，直接查询三个计划表 String[] planTables = { - DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_2", - DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_3", - DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_4" + DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_2", + DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_3", + DatabaseConstants.TABLE_NAME_PROD_PLAN_INFO_PREFIX + "_4" }; for (String planTableName : planTables) { try { - List processProgress = prodReportMapper.getPlanProcessProgress(planCode, planTableName); + List processProgress = prodReportMapper.getPlanProcessProgress(planCode, + planTableName); if (processProgress != null && !processProgress.isEmpty()) { allProcessProgress.addAll(processProgress); } } catch (Exception e) { // 记录日志但不中断处理 - System.out.println("查询工序进度失败，计划编码: " + planCode + ", 表: " + planTableName + ", 错误: " + e.getMessage()); + System.out.println( + "查询工序进度失败，计划编码: " + planCode + ", 表: " + planTableName + ", 错误: " + e.getMessage()); } } // 按工序顺序排序 allProcessProgress.sort((a, b) -> { - if (a.getProcessOrder() == null) return 1; - if (b.getProcessOrder() == null) return -1; + if (a.getProcessOrder() == null) + return 1; + if (b.getProcessOrder() == null) + return -1; return a.getProcessOrder().compareTo(b.getProcessOrder()); }); @@ -516,10 +528,12 @@ public class ProdReportServiceImpl implements IProdReportService { // 时间字段转换 if (vo.getPlanBeginTime() != null) { - exportVo.setPlanBeginTime(vo.getPlanBeginTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); + exportVo.setPlanBeginTime( + vo.getPlanBeginTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); } if (vo.getRealBeginTime() != null) { - exportVo.setRealBeginTime(vo.getRealBeginTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); + exportVo.setRealBeginTime( + vo.getRealBeginTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); } if (vo.getPlanEndTime() != null) { exportVo.setPlanEndTime(vo.getPlanEndTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); @@ -543,12 +557,13 @@ public class ProdReportServiceImpl implements IProdReportService { processDetail.append("; "); } processDetail.append(process.getProcessName()) - .append("(") - .append(process.getStatusDesc()) - .append(")"); + .append("(") + .append(process.getStatusDesc()) + .append(")"); // 如果有进度百分比，添加进度信息 - if (process.getProcessProgress() != null && process.getProcessProgress().compareTo(BigDecimal.ZERO) > 0) { + if (process.getProcessProgress() != null + && process.getProcessProgress().compareTo(BigDecimal.ZERO) > 0) { processDetail.append(" ").append(process.getProcessProgress()).append("%"); } } @@ -558,8 +573,6 @@ public class ProdReportServiceImpl implements IProdReportService { return exportVo; } - - /** * 根据订单信息确定需要查询的工序ID列表 * @param orderInfo 订单信息 @@ -575,7 +588,8 @@ public class ProdReportServiceImpl implements IProdReportService { if ("2".equals(dispatchType)) { // 工艺路线派工，通过工艺路线ID获取工序列表 - Long routeId = dispatchIdObj instanceof Integer ? ((Integer) dispatchIdObj).longValue() : (Long) dispatchIdObj; + Long routeId = dispatchIdObj instanceof Integer ? ((Integer) dispatchIdObj).longValue() + : (Long) dispatchIdObj; ProdBaseRouteProcessBo bo = new ProdBaseRouteProcessBo(); bo.setRouteId(routeId); List routeProcessList = prodBaseRouteProcessService.queryList(bo); @@ -588,7 +602,8 @@ public class ProdReportServiceImpl implements IProdReportService { } else if ("3".equals(dispatchType)) { // 单工序派工，直接使用dispatchId作为工序ID if (dispatchIdObj != null) { - Long processId = dispatchIdObj instanceof Integer ? ((Integer) dispatchIdObj).longValue() : (Long) dispatchIdObj; + Long processId = dispatchIdObj instanceof Integer ? ((Integer) dispatchIdObj).longValue() + : (Long) dispatchIdObj; processIds.add(processId); } } else { @@ -605,7 +620,6 @@ public class ProdReportServiceImpl implements IProdReportService { return processIds; } - /** * 小时产量统计（按结束时间小时分桶） * @param hashMap 查询条件 @@ -618,7 +632,6 @@ public class ProdReportServiceImpl implements IProdReportService { return prodReportMapper.hourlyOutputByHour(hashMap, detailTable, planTable); } - /** * 工序工单统计（按工序聚合）：完成数量、未完成数量与完成率 * 兼容传入的 processId，用于选择对应的计划表 @@ -630,7 +643,8 @@ public class ProdReportServiceImpl implements IProdReportService { if (tenantId != null && !tenantId.isEmpty()) { hashMap.put("tenantId", tenantId); } - } catch (Exception ignore) {} + } catch (Exception ignore) { + } Long processId = parseProcessId(hashMap.get("processId")); String planTable = getPlanInfoTableNameByProcessId(processId); return prodReportMapper.processWorkOrderStats(hashMap, planTable); @@ -646,7 +660,8 @@ public class ProdReportServiceImpl implements IProdReportService { if (tenantId != null && !tenantId.isEmpty()) { hashMap.put("tenantId", tenantId); } - } catch (Exception ignore) {} + } catch (Exception ignore) { + } Long processId = parseProcessId(hashMap.get("processId")); String planTable = getPlanInfoTableNameByProcessId(processId); Page> mpPage = pageQuery.build(); @@ -686,12 +701,23 @@ public class ProdReportServiceImpl implements IProdReportService { } private Long asLong(Object o) { - if (o == null) return null; - try { return Long.parseLong(String.valueOf(o)); } catch (Exception e) { return null; } + if (o == null) + return null; + try { + return Long.parseLong(String.valueOf(o)); + } catch (Exception e) { + return null; + } } + private BigDecimal asBigDecimal(Object o) { - if (o == null) return BigDecimal.ZERO; - try { return new BigDecimal(String.valueOf(o)); } catch (Exception e) { return BigDecimal.ZERO; } + if (o == null) + return BigDecimal.ZERO; + try { + return new BigDecimal(String.valueOf(o)); + } catch (Exception e) { + return BigDecimal.ZERO; + } } /** @@ -753,7 +779,7 @@ public class ProdReportServiceImpl implements IProdReportService { x1.add("SC_224NE"); x1.add("SC_225NE"); x1.add("SC_226NE"); - + List y1 = new ArrayList<>(); y1.add(5); y1.add(12); @@ -763,7 +789,7 @@ public class ProdReportServiceImpl implements IProdReportService { y1.add(6); y1.add(5); y1.add(6); - + result.put("x1", x1); result.put("y1", y1); return result; @@ -782,14 +808,14 @@ public class ProdReportServiceImpl implements IProdReportService { x1.add("13:01:00"); x1.add("13:02:00"); x1.add("13:03:00"); - + List y1 = new ArrayList<>(); y1.add(3); y1.add(4); y1.add(2); y1.add(5); y1.add(6); - + result.put("x1", x1); result.put("y1", y1); return result; @@ -809,21 +835,71 @@ public class ProdReportServiceImpl implements IProdReportService { item1.put("value3", 100); item1.put("value4", "10次"); result.add(item1); - + HashMap item2 = new HashMap<>(); item2.put("value1", "2"); item2.put("value2", "SC-228NE"); item2.put("value3", 70); item2.put("value4", "7次"); result.add(item2); - + HashMap item3 = new HashMap<>(); item3.put("value1", "3"); item3.put("value2", "SC-228NE"); item3.put("value3", 60); item3.put("value4", "6次"); result.add(item3); - + + return result; + } + + /** + * 看板接口5：返回合格数/不合格数统计数据 + */ + @Override + public HashMap getDashboardData5(Map hashMap) { + HashMap result = new HashMap<>(); + // TODO: 根据实际业务逻辑查询数据 + // 示例数据结构 + List x1 = new ArrayList<>(); + x1.add("合格数"); + x1.add("不合格数"); + + List y1 = new ArrayList<>(); + y1.add("8"); + y1.add("1"); + + result.put("x1", x1); + result.put("y1", y1); + return result; + } + + /** + * 看板接口6：返回产品良率统计数据 + */ + @Override + public HashMap getDashboardData6(Map hashMap) { + HashMap result = new HashMap<>(); + // TODO: 根据实际业务逻辑查询数据 + // 示例数据结构 + List x1 = new ArrayList<>(); + x1.add("产品1"); + x1.add("产品2"); + x1.add("产品3"); + x1.add("产品4"); + x1.add("产品5"); + x1.add("产品6"); + + List y1 = new ArrayList<>(); + y1.add(98); + y1.add(95); + y1.add(93); + y1.add(95); + y1.add(93); + y1.add(97); + + result.put("x1", x1); + result.put("y1", y1); return result; }