维修记录指派

Lius

2025-04-25 8e9471d884fe129a1b36310d19771d087952ab57

 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/MesPartProcessInfoJob.java

@@ -72,37 +72,36 @@
        log.info("定时获取MES系统加工个数任务 MesPartProcessInfoJob start!  时间:" + DateUtils.getNow());
        long startTime = System.currentTimeMillis();
        try {
            if (StringUtils.isNotBlank(parameter)) {
                String date = "";
                if (StringUtils.isNotBlank(this.parameter)) {
                    date = DateUtils.format(DateUtils.toDate(this.parameter, DateUtils.STRDATE), DateUtils.STR_DATE);
                } else {
                    date = DateUtils.format(DateUtils.getNow(), DateUtils.STR_DATE);
                }
                mdcJcRcJobreportService.remove(new LambdaQueryWrapper<MdcJcRcJobreport>().eq(MdcJcRcJobreport::getTheDate, date));
            String date = "";
            if (StringUtils.isNotBlank(this.parameter)) {
                date = DateUtils.format(DateUtils.toDate(this.parameter, DateUtils.STRDATE), DateUtils.STR_DATE);
            } else {
                date = DateUtils.format(DateUtils.getNow(), DateUtils.STR_DATE);
            }

                //获取设备列表
                List<MdcEquipment> mdcEquipmentList = mdcEquipmentService.list();
                if (mdcEquipmentList != null && !mdcEquipmentList.isEmpty()) {
                    List<String> equipmentIdList = mdcEquipmentList.stream().map(MdcEquipment::getEquipmentId).collect(Collectors.toList());
                    List<MesRcJobreport> mesRcJobreportList = mesRcJobreportService.findPartProcessInfo(date, equipmentIdList);
                    if (mesRcJobreportList != null && !mesRcJobreportList.isEmpty()) {
                        List<MdcJcRcJobreport> mdcJcRcJobreportList = new ArrayList<>();
                        for (MesRcJobreport mesRcJobreport : mesRcJobreportList) {
                            MdcJcRcJobreport mdcJcRcJobreport = new MdcJcRcJobreport();
                            mdcJcRcJobreport.setEquipmentId(mesRcJobreport.getDeviceNumber());
                            mdcJcRcJobreport.setOkuqty(mesRcJobreport.getOkuqty().intValue());
                            mdcJcRcJobreport.setProcessCount(mesRcJobreport.getQty().intValue());
                            mdcJcRcJobreport.setTheDate(date);
                            mdcJcRcJobreportList.add(mdcJcRcJobreport);
                        }
                        if (!mdcEquipmentList.isEmpty()) {
                            mdcJcRcJobreportService.saveBatch(mdcJcRcJobreportList);
                        }
            mdcJcRcJobreportService.remove(new LambdaQueryWrapper<MdcJcRcJobreport>().eq(MdcJcRcJobreport::getTheDate, date));

            //获取设备列表
            List<MdcEquipment> mdcEquipmentList = mdcEquipmentService.list();
            if (mdcEquipmentList != null && !mdcEquipmentList.isEmpty()) {
                List<String> equipmentIdList = mdcEquipmentList.stream().map(MdcEquipment::getEquipmentId).collect(Collectors.toList());
                List<MesRcJobreport> mesRcJobreportList = mesRcJobreportService.findPartProcessInfo(date, equipmentIdList);
                if (mesRcJobreportList != null && !mesRcJobreportList.isEmpty()) {
                    List<MdcJcRcJobreport> mdcJcRcJobreportList = new ArrayList<>();
                    for (MesRcJobreport mesRcJobreport : mesRcJobreportList) {
                        MdcJcRcJobreport mdcJcRcJobreport = new MdcJcRcJobreport();
                        mdcJcRcJobreport.setEquipmentId(mesRcJobreport.getDeviceNumber());
                        mdcJcRcJobreport.setOkuqty(mesRcJobreport.getOkuqty().intValue());
                        mdcJcRcJobreport.setProcessCount(mesRcJobreport.getQty().intValue());
                        mdcJcRcJobreport.setTheDate(date);
                        mdcJcRcJobreportList.add(mdcJcRcJobreport);
                    }
                    if (!mdcEquipmentList.isEmpty()) {
                        mdcJcRcJobreportService.saveBatch(mdcJcRcJobreportList);
                    }
                }

            }

            quartzLog.setIsSuccess(0);
        } catch (Exception e) {
            quartzLog.setIsSuccess(-1);