From ce1e1dc15cbea0944a5f0f5279e42396034b1f78 Mon Sep 17 00:00:00 2001
From: Lius <Lius2225@163.com>
Date: 星期二, 21 一月 2025 09:03:06 +0800
Subject: [PATCH] 计算OEE接口

---
 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcOeeInfoController.java      |   14 ++++
 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcOeeInfoServiceImpl.java   |   87 +++++++++++++++++++++++++++++
 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcOeeInfoService.java           |    8 ++
 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java |    2 
 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcOeeComputeVo.java                   |   13 ++++
 5 files changed, 123 insertions(+), 1 deletions(-)

diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcOeeInfoController.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcOeeInfoController.java
index 40df540..642d400 100644
--- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcOeeInfoController.java
+++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcOeeInfoController.java
@@ -12,6 +12,7 @@
 import org.jeecg.common.system.vo.LoginUser;
 import org.jeecg.modules.mdc.entity.MdcOeeInfo;
 import org.jeecg.modules.mdc.service.IMdcOeeInfoService;
+import org.jeecg.modules.mdc.vo.MdcOeeComputeVo;
 import org.jeecg.modules.mdc.vo.MdcOeeInfoVo;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.servlet.ModelAndView;
@@ -83,4 +84,17 @@
         return mdcOeeInfoService.exportXls(userId, mdcOeeInfoVo);
     }
 
+    /**
+     * 璁$畻OEE
+     *
+     * @return
+     */
+    @AutoLog(value = "OEE琛�-璁$畻OEE")
+    @ApiOperation(value = "OEE琛�-璁$畻OEE", notes = "OEE琛�-璁$畻OEE")
+    @PostMapping(value = "/computeOee")
+    public Result<?> computeOee(@RequestBody MdcOeeComputeVo mdcOeeComputeVo) {
+        mdcOeeInfoService.computeOee(mdcOeeComputeVo);
+        return Result.OK("璁$畻鎴愬姛锛�");
+    }
+
 }
diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcOeeInfoService.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcOeeInfoService.java
index 4b4e2cb..f9bcaea 100644
--- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcOeeInfoService.java
+++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/IMdcOeeInfoService.java
@@ -4,6 +4,7 @@
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import org.jeecg.modules.mdc.entity.MdcOeeInfo;
+import org.jeecg.modules.mdc.vo.MdcOeeComputeVo;
 import org.jeecg.modules.mdc.vo.MdcOeeInfoVo;
 import org.springframework.web.servlet.ModelAndView;
 
@@ -42,4 +43,11 @@
      * @return
      */
     ModelAndView exportXls(String userId, MdcOeeInfoVo mdcOeeInfoVo);
+
+    /**
+     * 璁$畻OEE
+     * @param mdcOeeComputeVo
+     */
+    void computeOee(MdcOeeComputeVo mdcOeeComputeVo);
+
 }
diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java
index 565ccfa..11909c7 100644
--- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java
+++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java
@@ -464,7 +464,7 @@
             result.put("runData", runData);
 
             // 鏌ヨ鍧愭爣淇℃伅
-            if (!mdcEquipmentDetailedDto.getDriveType().equals("ZUOLAN") || !mdcEquipmentDetailedDto.getDriveType().equals("CurrentState")) {
+            if (!"ZUOLAN".equals(mdcEquipmentDetailedDto.getDriveType()) && !"CurrentState".equals(mdcEquipmentDetailedDto.getDriveType())) {
                 EquipmentXYZ equipmentXYZ = equipmentXYZService.getByEquipmentId(mdcEquipmentDetailedDto.getEquipmentId());
                 if (equipmentXYZ != null) {
                     Map<String, Object> map = new HashMap<>();
diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcOeeInfoServiceImpl.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcOeeInfoServiceImpl.java
index 18d0f4a..a8ec2dc 100644
--- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcOeeInfoServiceImpl.java
+++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcOeeInfoServiceImpl.java
@@ -13,6 +13,7 @@
 import org.jeecg.modules.mdc.mapper.MdcOeeInfoMapper;
 import org.jeecg.modules.mdc.service.*;
 import org.jeecg.modules.mdc.util.DateUtils;
+import org.jeecg.modules.mdc.vo.MdcOeeComputeVo;
 import org.jeecg.modules.mdc.vo.MdcOeeInfoVo;
 import org.jeecgframework.poi.excel.def.NormalExcelConstants;
 import org.jeecgframework.poi.excel.entity.ExportParams;
@@ -154,6 +155,92 @@
     }
 
     /**
+     * 璁$畻OEE
+     * @param mdcOeeComputeVo
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void computeOee(MdcOeeComputeVo mdcOeeComputeVo) {
+        List<MdcOeeInfo> result = new ArrayList<>();
+        String startDate = mdcOeeComputeVo.getStartDate();
+        String endDate = mdcOeeComputeVo.getEndDate();
+        List<String> dateList = DateUtils.getDatesStringList(DateUtils.getShortDate(startDate), DateUtils.getShortDate(endDate));
+        if (!dateList.isEmpty()) {
+            //鑾峰彇璁惧鍒楄〃
+            List<MdcEquipment> equipmentList = mdcEquipmentService.list();
+
+            for (String validDate : dateList) {
+                try {
+                    this.remove(new LambdaQueryWrapper<MdcOeeInfo>().eq(MdcOeeInfo::getTheDate, validDate));
+                } catch (Exception e) {
+                    log.error("鍙傛暟鏍煎紡涓嶅", e);
+                }
+                for (MdcEquipment mdcEquipment : equipmentList) {
+                    String equipmentId = mdcEquipment.getEquipmentId();
+                    MdcOeeInfo mdcOeeInfo = new MdcOeeInfo();
+                    // 璁惧缂栧彿
+                    mdcOeeInfo.setEquipmentId(equipmentId);
+                    // 璁$畻鏃ユ湡
+                    mdcOeeInfo.setTheDate(validDate);
+                    // 宸ヤ綔鏃ュ巻鏃堕棿(min) --- 鎸夋瘡澶�24灏忔椂绠�
+                    mdcOeeInfo.setCalendarLong(1440);
+                    // 璁″垝鍋滄満鏃堕棿(min) --- 鎸夌淮鎶ゆ暟鎹粺璁″綋澶╂�绘椂闀�
+                    Integer planCloseLong = mdcPlanCloseService.findPlanTimeDuration(equipmentId, validDate, CommonConstant.CLOSE_TYPE_1);
+                    mdcOeeInfo.setPlanCloseLong(planCloseLong);
+                    // 璐熻嵎鏃堕棿(min) --- 鏃ュ巻宸ヤ綔鏃堕棿-璁″垝鍋滄満鏃堕棿
+                    Integer loadLong = mdcOeeInfo.getCalendarLong() - planCloseLong;
+                    mdcOeeInfo.setLoadLong(loadLong);
+                    // 闈炶鍒掑仠鏈烘椂闂�(min) --- 鎸夌淮鎶ゆ暟鎹粺璁″綋澶╂�绘椂闀�
+                    Integer noPlanCloseLong = mdcPlanCloseService.findPlanTimeDuration(equipmentId, validDate, CommonConstant.CLOSE_TYPE_2);
+                    mdcOeeInfo.setNoplanCloseLong(noPlanCloseLong);
+                    // 寮�鍔ㄦ椂闂�(min) --- 璐熻嵎鏃堕棿-闈炶鍒掑仠鏈烘椂闂�
+                    int actuateLong = loadLong - noPlanCloseLong;
+                    mdcOeeInfo.setActuateLong(actuateLong);
+                    // 鏃堕棿寮�鍔ㄧ巼 --- 寮�鍔ㄦ椂闂�/璐熻嵎鏃堕棿
+                    BigDecimal timeActuationRate = new BigDecimal(actuateLong).divide(new BigDecimal(loadLong), 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP);
+                    mdcOeeInfo.setTimeActuationRate(timeActuationRate);
+                    // 鏈夋晥杩愯鏃堕棿 --- 鎸夐渶姹傜淮鎶ら浂浠跺姞宸ユ�绘椂闀縷|绯荤粺涓昏酱璐熻浇鏃堕棿
+                    Integer effectiveRunLong = 0;
+                    Integer totalProcessLong = mdcPartProcessInfoService.selectTotalProcessLong(equipmentId, validDate);
+                    if (totalProcessLong == 0) {
+                        //鏌ヨ璁惧杩愯鏃堕棿
+                        effectiveRunLong = mdcEquipmentStatisticalInfoService.selectProcessLong(equipmentId, validDate.replace("-", ""));
+                    } else {
+                        effectiveRunLong = totalProcessLong;
+                    }
+                    mdcOeeInfo.setEffectiveRunLong(effectiveRunLong);
+                    // 鎬ц兘寮�鍔ㄧ巼 --- 鏈夋晥杩愯鏃堕棿/寮�鍔ㄦ椂闂�
+                    BigDecimal performanceRate = BigDecimal.ZERO;
+                    if (effectiveRunLong != 0 && actuateLong != 0) {
+                        performanceRate = new BigDecimal(effectiveRunLong).divide(new BigDecimal(actuateLong), 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP);
+                    }
+                    mdcOeeInfo.setPerformanceRate(performanceRate);
+                    // 鍔犲伐闆朵欢鏁伴噺 --- 鎸夌淮鎶ゆ暟鎹粺璁″綋澶�
+                    Integer processCount = mdcPartProcessInfoService.selectTotalProcessCount(equipmentId, validDate);
+                    mdcOeeInfo.setProcessCount(processCount);
+                    // 鍚堟牸闆朵欢鏁伴噺 --- 鎸夌淮鎶ゆ暟鎹粺璁″綋澶�
+                    Integer passCount = mdcPartProcessInfoService.selectTotalPassCount(equipmentId, validDate);
+                    mdcOeeInfo.setPassCount(passCount);
+                    // 鍚堟牸鐜� --- 鍚堟牸鏁�/鍔犲伐鏁�
+                    BigDecimal passRate = BigDecimal.ZERO;
+                    if (processCount != 0 && passCount != 0) {
+                        passRate = new BigDecimal(passCount).divide(new BigDecimal(processCount), 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP);
+                    }
+                    mdcOeeInfo.setPassRate(passRate);
+                    // OEE --- 鏃堕棿寮�鍔ㄧ巼 * 鎬ц兘寮�鍔ㄧ巼 * 涓�娆″悎鏍肩巼
+                    BigDecimal oee = BigDecimal.ZERO;
+                    if (!timeActuationRate.equals(BigDecimal.ZERO) && !performanceRate.equals(BigDecimal.ZERO) && !passRate.equals(BigDecimal.ZERO)) {
+                        oee = timeActuationRate.multiply(performanceRate).multiply(passRate).divide(new BigDecimal("10000"), 4, RoundingMode.HALF_UP);
+                    }
+                    mdcOeeInfo.setOee(oee);
+                    result.add(mdcOeeInfo);
+                }
+            }
+        }
+        super.saveBatch(result);
+    }
+
+    /**
      * 璁$畻oee
      * @param dateTime 鍙傛暟
      */
diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcOeeComputeVo.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcOeeComputeVo.java
new file mode 100644
index 0000000..b23a4c9
--- /dev/null
+++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/vo/MdcOeeComputeVo.java
@@ -0,0 +1,13 @@
+package org.jeecg.modules.mdc.vo;
+
+import lombok.Data;
+
+/**
+ * @author Lius
+ * @date 2025/1/20 14:41
+ */
+@Data
+public class MdcOeeComputeVo {
+    private String startDate;
+    private String endDate;
+}

--
Gitblit v1.9.3