From 44504bd041f8dc3c97d1a9079c773a2f88b3d977 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期六, 08 二月 2025 09:39:33 +0800
Subject: [PATCH] fix(datasource): 修改默认数据源名称和数据库名称

---
 hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/uppattenusage/service/impl/UpPattenUsageServiceImpl.java |   25 ++++++++++++++++++++++++-
 1 files changed, 24 insertions(+), 1 deletions(-)

diff --git a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/uppattenusage/service/impl/UpPattenUsageServiceImpl.java b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/uppattenusage/service/impl/UpPattenUsageServiceImpl.java
index ae9625e..47ff42e 100644
--- a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/uppattenusage/service/impl/UpPattenUsageServiceImpl.java
+++ b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/uppattenusage/service/impl/UpPattenUsageServiceImpl.java
@@ -54,6 +54,20 @@
     }
 
     @Override
+    public List<UpPattenUsage> selectLoadTask(Integer cell) {
+        //鑾峰彇姝e湪涓婄墖鐨勪换鍔d
+        Engineering engineering= engineeringService.selectInitiates(1,cell);
+        //log.info("灏嗗弬鏁颁紶鍏ュ埌鏌ヨ绫婚噷{}",engineering);
+        if(engineering!=null){
+            LambdaQueryWrapper<UpPattenUsage> wrapper = new LambdaQueryWrapper<>();
+            wrapper.eq(UpPattenUsage::getEngineeringId, engineering.getEngineerId());
+            return this.list(wrapper);
+        } else {
+            return null;
+        }
+    }
+
+    @Override
     public List<UpPattenUsage> selectUpPattenUsage(UpPattenUsage upPattenUsage) {
         LambdaQueryWrapper<UpPattenUsage> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(UpPattenUsage::getEngineeringId, upPattenUsage.getEngineeringId());
@@ -106,9 +120,9 @@
         String engineerId = upPattenUsage.get(0).getEngineeringId();
         int count = this.count(new LambdaQueryWrapper<UpPattenUsage>().eq(UpPattenUsage::getEngineeringId, engineerId));
         if (count <=0){
+            //淇濆瓨鍘熺墖浣跨敤璇︽儏琛�
             this.saveBatch(upPattenUsage);
         }
-        //淇濆瓨鍘熺墖浣跨敤璇︽儏琛�
     }
 
     @Override
@@ -137,6 +151,15 @@
     }
 
     @Override
+    public void deleteTask(String engineerId) {
+        QueryWrapper<UpPattenUsage> wrapper = new QueryWrapper<>();
+        wrapper.eq("engineering_id",engineerId);
+        this.remove(wrapper);
+    }
+
+
+
+    @Override
     public UpPattenUsage selectOverTask() {
         QueryWrapper<UpPattenUsage>wrapper = new QueryWrapper<>();
         wrapper.gt("state",0)

--
Gitblit v1.8.0