From ffb758283ece163e04c629def3bd700d292d7f89 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期二, 16 四月 2024 10:12:06 +0800
Subject: [PATCH] 上片模块配置pp表多数据源(可供其他模块配置多数据源参考)

---
 UnLoadGlassModule/src/main/java/com/mes/mapper/DownWorkstationMapper.java |   29 +++++++++++++++++++++++++++--
 1 files changed, 27 insertions(+), 2 deletions(-)

diff --git a/UnLoadGlassModule/src/main/java/com/mes/mapper/DownWorkstationMapper.java b/UnLoadGlassModule/src/main/java/com/mes/mapper/DownWorkstationMapper.java
index 31f6a44..3d00318 100644
--- a/UnLoadGlassModule/src/main/java/com/mes/mapper/DownWorkstationMapper.java
+++ b/UnLoadGlassModule/src/main/java/com/mes/mapper/DownWorkstationMapper.java
@@ -1,6 +1,5 @@
 package com.mes.mapper;
 
-import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.annotation.InterceptorIgnore;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.mes.entity.DownGlassInfo;
@@ -10,12 +9,12 @@
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
+import java.util.Map;
 
 @Mapper
 @Component
 @Repository
 @InterceptorIgnore(tenantLine = "true")
-@DS("hangzhoumes") // 鎸囧畾浣跨敤 hangzhoumes 鏁版嵁婧�
 public interface DownWorkstationMapper extends BaseMapper<DownWorkstation> {
 //鏍规嵁宸ヤ綅ID鍜岃澶嘔D鏇存柊宸ヤ綅鐘舵��
     @Update("UPDATE down_workstation SET work_state = #{workState} " +
@@ -66,4 +65,30 @@
 
     @Update("UPDATE down_workstation_task SET state = 0 WHERE flow_card_id = #{flowCardId}")
     void update_task_state_to_zero(@Param("flowCardId") String flowCardId);
+
+
+@Select(" SELECT * FROM down_workstation WHERE workstation_id >= 1 AND workstation_id <= 5")
+    List<DownWorkstation> getoneDownWorkstations();
+
+
+    @Select(" SELECT * FROM down_workstation WHERE workstation_id >= 6 AND workstation_id <= 10")
+    List<DownWorkstation> gettwoDownWorkstations();
+
+
+
+    @Select("SELECT DISTINCT  flowcard_id from glass_info")
+    @ResultType(Map.class)
+    List<Map<String, Object>> getflowCardId();
+
+    @Update("UPDATE down_workstation SET flow_card_id = NULL, total_quantity = 0, racks_number = 0 WHERE workstation_id = #{workstationId}")
+    void clearFlowCardInfoByWorkstationId(@Param("workstationId") int workstationId);
+
+    // 鑾峰彇鎬绘暟閲�
+    @Select("SELECT total_quantity FROM down_workstation WHERE workstation_id = #{workstationId}")
+    int getTotalQuantity(@Param("workstationId") int workstationId);
+
+    // 鑾峰彇钀芥灦鏁伴噺
+    @Select("SELECT racks_number FROM down_workstation WHERE workstation_id = #{workstationId}")
+    int getRacksNumber(@Param("workstationId") int workstationId);
+
 }

--
Gitblit v1.8.0