From 48984da72dd03b6b0cce54433215abfc402a4ea5 Mon Sep 17 00:00:00 2001
From: zhangherong <571457620@qq.com>
Date: 星期五, 18 四月 2025 16:58:07 +0800
Subject: [PATCH] art: 设备管理-点检工单-自动生成点检,点检过期未保养标记过期

---
 lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java |   93 +++++++++++++++++++++++++++-------------------
 1 files changed, 55 insertions(+), 38 deletions(-)

diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java
index 55fcc20..6a381ad 100644
--- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java
+++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java
@@ -3,6 +3,7 @@
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -23,7 +24,6 @@
 import org.jeecg.modules.eam.entity.EamEquipment;
 import org.jeecg.modules.eam.entity.EamInspectionOrder;
 import org.jeecg.modules.eam.entity.EamInspectionOrderDetail;
-import org.jeecg.modules.eam.entity.EamWeekMaintenanceOrder;
 import org.jeecg.modules.eam.mapper.EamInspectionOrderMapper;
 import org.jeecg.modules.eam.request.EamInspectionOrderQuery;
 import org.jeecg.modules.eam.request.EamInspectionOrderRequest;
@@ -51,7 +51,7 @@
 /**
  * @Description: 鐐规宸ュ崟
  * @Author: jeecg-boot
- * @Date:   2025-04-02
+ * @Date: 2025-04-02
  * @Version: V1.0
  */
 @Service("IEamInspectionOrderService")
@@ -132,19 +132,31 @@
     }
 
     @Override
+    public List<EamInspectionOrder> selectUnCompleteOrder(String expiredDate) {
+        LambdaQueryWrapper<EamInspectionOrder> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.lt(EamInspectionOrder::getInspectionDate, expiredDate);
+        List<String> unCompleteStatus = new ArrayList<>();
+        unCompleteStatus.add(InspectionStatus.WAIT_INSPECTION.name());
+        unCompleteStatus.add(InspectionStatus.UNDER_INSPECTION.name());
+        queryWrapper.in(EamInspectionOrder::getInspectionStatus, unCompleteStatus);
+        queryWrapper.orderByAsc(EamInspectionOrder::getInspectionDate);
+        return eamInspectionOrderMapper.selectList(queryWrapper);
+    }
+
+    @Override
     @Transactional(rollbackFor = Exception.class)
     public boolean addInspectionOrder(EamInspectionOrderRequest eamInspectionOrderRequest) {
         EamInspectionOrder eamInspectionOrder = new EamInspectionOrder();
-        BeanUtils.copyProperties(eamInspectionOrderRequest,eamInspectionOrder);
+        BeanUtils.copyProperties(eamInspectionOrderRequest, eamInspectionOrder);
         //淇敼鐘舵��
-        if (StrUtil.isNotBlank(eamInspectionOrderRequest.getOperator())){
+        if (StrUtil.isNotBlank(eamInspectionOrderRequest.getOperator())) {
             eamInspectionOrder.setInspectionStatus(InspectionStatus.UNDER_INSPECTION.name());
-        }else {
+        } else {
             eamInspectionOrder.setInspectionStatus(InspectionStatus.WAIT_INSPECTION.name());
         }
         save(eamInspectionOrder);
         //澶勭悊鏄庣粏鏁版嵁
-        if(CollectionUtil.isNotEmpty(eamInspectionOrderRequest.getTableDetailList())) {
+        if (CollectionUtil.isNotEmpty(eamInspectionOrderRequest.getTableDetailList())) {
             eamInspectionOrderRequest.getTableDetailList().forEach(tableDetail -> {
                 tableDetail.setOrderId(eamInspectionOrder.getId());
                 tableDetail.setId(null);
@@ -152,7 +164,7 @@
             eamInspectionOrderDetailService.saveBatch(eamInspectionOrderRequest.getTableDetailList());
         }
         //澶勭悊闄勪欢
-        if(CollectionUtil.isNotEmpty(eamInspectionOrderRequest.getFileList())) {
+        if (CollectionUtil.isNotEmpty(eamInspectionOrderRequest.getFileList())) {
             FileUploadResult fileUploadResult = eamInspectionOrderRequest.getFileList().get(0);
             ObjectMapper mapper = new ObjectMapper();
             try {
@@ -162,7 +174,7 @@
                 log.error("JSON杞崲澶辫触锛�" + e.getMessage(), e);
             }
         }
-        if (StrUtil.isNotBlank(eamInspectionOrderRequest.getOperator())){
+        if (StrUtil.isNotBlank(eamInspectionOrderRequest.getOperator())) {
             triggerProcess(eamInspectionOrder);
         }
         return true;
@@ -170,6 +182,7 @@
 
     /**
      * 瑙﹀彂娴佺▼
+     *
      * @param eamInspectionOrder
      * @return
      */
@@ -177,26 +190,26 @@
         EamEquipment equipment = eamEquipmentService.getById(eamInspectionOrder.getEquipmentId());
         if (equipment == null) {
             return false;
-        }else {
+        } else {
             eamInspectionOrder.setEquipmentCode(equipment.getEquipmentCode());
         }
         System.out.println("璁惧鐐规锛�" + eamInspectionOrder.getId());
-        flowCommonService.initActBusiness("宸ュ崟鍙凤細"+eamInspectionOrder.getOrderNum()+"璁惧缂栧彿"+eamInspectionOrder.getEquipmentCode()+"杩涜璁惧鐐规",
+        flowCommonService.initActBusiness("宸ュ崟鍙凤細" + eamInspectionOrder.getOrderNum() + "璁惧缂栧彿" + eamInspectionOrder.getEquipmentCode() + "杩涜璁惧鐐规",
                 eamInspectionOrder.getId(), "IEamInspectionOrderService", "eam_inspection", null);
         Map<String, Object> variables = new HashMap<>();
         variables.put("dataId", eamInspectionOrder.getId());
-        if (StrUtil.isEmpty(eamInspectionOrder.getRemark())){
+        if (StrUtil.isEmpty(eamInspectionOrder.getRemark())) {
             variables.put("organization", "鏂板鐐规宸ュ崟榛樿鍚姩娴佺▼");
             variables.put("comment", "鏂板鐐规宸ュ崟榛樿鍚姩娴佺▼");
-        }else {
+        } else {
             variables.put("organization", eamInspectionOrder.getRemark());
             variables.put("comment", eamInspectionOrder.getRemark());
         }
-        variables.put("proofreading",true);
-        List<String> usernames=new ArrayList<>();
+        variables.put("proofreading", true);
+        List<String> usernames = new ArrayList<>();
         usernames.add(eamInspectionOrder.getOperator());
         variables.put("NextAssignee", usernames);
-        Result result= flowDefinitionService.startProcessInstanceByKey("eam_inspection", variables);
+        Result result = flowDefinitionService.startProcessInstanceByKey("eam_inspection", variables);
         return result.isSuccess();
     }
 
@@ -205,7 +218,7 @@
     public boolean editInspectionOrder(EamInspectionOrderRequest eamInspectionOrderRequest) {
         EamInspectionOrder eamInspectionOrder = new EamInspectionOrder();
         BeanUtils.copyProperties(eamInspectionOrderRequest, eamInspectionOrder);
-        if (StrUtil.isNotEmpty(eamInspectionOrder.getOperator())){
+        if (StrUtil.isNotEmpty(eamInspectionOrder.getOperator())) {
             eamInspectionOrder.setInspectionStatus(InspectionStatus.UNDER_INSPECTION.name());
         }
         super.updateById(eamInspectionOrder);
@@ -224,16 +237,17 @@
 
     /**
      * 棰嗗彇鐐规宸ュ崟
+     *
      * @param id
      * @return
      */
     @Override
-    public boolean takeInspectionOrder(String id){
+    public boolean takeInspectionOrder(String id) {
         LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
-        EamInspectionOrder eamInspectionOrder=this.getById(id);
-        if (eamInspectionOrder==null) {
+        EamInspectionOrder eamInspectionOrder = this.getById(id);
+        if (eamInspectionOrder == null) {
             return false;
-        }else {
+        } else {
             eamInspectionOrder.setOperator(user.getUsername());
             //淇敼鐘舵��
             eamInspectionOrder.setInspectionStatus(InspectionStatus.UNDER_INSPECTION.name());
@@ -245,15 +259,16 @@
 
     /**
      * 浣滃簾鐐规宸ュ崟
+     *
      * @param id
      * @return
      */
     @Override
-    public boolean cancelInspectionOrder(String id){
+    public boolean cancelInspectionOrder(String id) {
         EamInspectionOrder eamInspectionOrder = this.getById(id);
         if (eamInspectionOrder == null) {
             return false;
-        }else {
+        } else {
             eamInspectionOrder.setInspectionStatus(InspectionStatus.ABOLISH.name());
             return updateById(eamInspectionOrder);
         }
@@ -261,6 +276,7 @@
 
     /**
      * 鐐规娴佺▼
+     *
      * @param eamInspectionOrderRequest
      * @return
      */
@@ -314,7 +330,7 @@
             updateEamInspectionOrder(eamInspectionOrder);
 
             //鏌ヨ鏁版嵁,杩涜璁惧缁翠慨澶勭悊
-            if (eamInspectionOrder.getInspectionStatus().equals(InspectionStatus.WAIT_CONFIRM.name())){
+            if (eamInspectionOrder.getInspectionStatus().equals(InspectionStatus.WAIT_CONFIRM.name())) {
                 updateEamInspectionOrderDetail(eamInspectionOrder);
             }
 
@@ -323,7 +339,6 @@
             return Result.error("鎿嶄綔澶辫触锛�" + e.getMessage());
         }
     }
-
 
 
     private boolean isValidRequest(EamInspectionOrderRequest request) {
@@ -438,40 +453,42 @@
 
     /**
      * 璁惧鏄惁瀛樺湪寮傚父,骞惰繘琛岃澶囩淮淇�
+     *
      * @param eamInspectionOrder
      */
     private void updateEamInspectionOrderDetail(EamInspectionOrder eamInspectionOrder) {
         List<EamInspectionOrderDetail> eamInspectionOrderDetails = eamInspectionOrderDetailService
                 .list(new QueryWrapper<EamInspectionOrderDetail>()
-                        .eq("order_id", eamInspectionOrder.getId()).eq("report_flag","1").eq("inspection_result", "2"));
+                        .eq("order_id", eamInspectionOrder.getId()).eq("report_flag", "1").eq("inspection_result", "2"));
         eamReportRepairService.reportRepairFromInspection(eamInspectionOrder.getEquipmentId(), eamInspectionOrder.getOperator(), eamInspectionOrderDetails);
     }
 
     /**
      * 鎵归噺浣滃簾涓庨鍙�
+     *
      * @param ids
      * @param type
      * @return
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public Result<?> batchCancelOrTakeInspectionOrder(String ids, String type){
+    public Result<?> batchCancelOrTakeInspectionOrder(String ids, String type) {
         if (type == null) {
             return Result.error("璇烽�夋嫨鎿嶄綔绫诲瀷");
         }
         LoginUser loginUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
         List<String> list = Arrays.asList(ids.split(","));
-        QueryWrapper<EamInspectionOrder> queryWrapper =new QueryWrapper<>();
+        QueryWrapper<EamInspectionOrder> queryWrapper = new QueryWrapper<>();
         queryWrapper.in("id", list);
         queryWrapper.eq("inspection_status", InspectionStatus.WAIT_INSPECTION.name());
-        List<EamInspectionOrder> eamInspectionOrderList =this.list(queryWrapper);
-        if (!eamInspectionOrderList.isEmpty()){
+        List<EamInspectionOrder> eamInspectionOrderList = this.list(queryWrapper);
+        if (!eamInspectionOrderList.isEmpty()) {
             eamInspectionOrderList.forEach(eamInspectionOrder -> {
                 eamInspectionOrder.setInspectionStatus(type);
-                if (InspectionStatus.UNDER_INSPECTION.name().equals(type)){
+                if (InspectionStatus.UNDER_INSPECTION.name().equals(type)) {
                     eamInspectionOrder.setOperator(loginUser.getUsername());
                     this.triggerProcess(eamInspectionOrder);
-                }else {
+                } else {
                     eamInspectionOrder.setOperator(null);
                 }
             });
@@ -482,13 +499,13 @@
 
 
     @Override
-    public Result<?> selectVoById(String id){
-        List<EamInspectionOrder> eamInspectionOrders=this.list(new QueryWrapper<EamInspectionOrder>().eq("id", id));
-        List<EamInspectionOrderRequest> eamInspectionOrderRequestList=new ArrayList<>();
+    public Result<?> selectVoById(String id) {
+        List<EamInspectionOrder> eamInspectionOrders = this.list(new QueryWrapper<EamInspectionOrder>().eq("id", id));
+        List<EamInspectionOrderRequest> eamInspectionOrderRequestList = new ArrayList<>();
         eamInspectionOrders.forEach(eamInspectionOrder -> {
-            EamInspectionOrderRequest eamInspectionOrderRequest=new EamInspectionOrderRequest();
-            BeanUtils.copyProperties(eamInspectionOrder,eamInspectionOrderRequest);
-            List<EamInspectionOrderDetail> eamInspectionOrderDetails=eamInspectionOrderDetailService
+            EamInspectionOrderRequest eamInspectionOrderRequest = new EamInspectionOrderRequest();
+            BeanUtils.copyProperties(eamInspectionOrder, eamInspectionOrderRequest);
+            List<EamInspectionOrderDetail> eamInspectionOrderDetails = eamInspectionOrderDetailService
                     .list(new QueryWrapper<EamInspectionOrderDetail>().eq("order_id", eamInspectionOrder.getId()));
             eamInspectionOrderRequest.setTableDetailList(eamInspectionOrderDetails);
             eamInspectionOrderRequestList.add(eamInspectionOrderRequest);
@@ -517,7 +534,7 @@
     public List<String> flowCandidateUsernamesOfTask(String taskNameId, Map<String, Object> values) {
         //涓氬姟鏄惁骞查娴佺▼锛屼笟鍔″共棰勶紝娴佺▼骞查锛屾寚瀹氫汉鍛樿繘琛屽鐞�
         //鑾峰彇涓嬩竴姝ュ鐞嗕汉
-        Object object=values.get("NextAssignee");
+        Object object = values.get("NextAssignee");
         return (List<String>) object;
     }
 }

--
Gitblit v1.9.3