From 0d35ca6cbe31b2cb2010b66b086acc1cb19ae270 Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期二, 16 四月 2024 11:50:21 +0800
Subject: [PATCH] 修改接口路径

---
 hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downworkstation/service/impl/DownWorkstationServiceImpl.java |  125 ++++++++++++++++++++++++++++++++++++++---
 1 files changed, 116 insertions(+), 9 deletions(-)

diff --git a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downworkstation/service/impl/DownWorkstationServiceImpl.java b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downworkstation/service/impl/DownWorkstationServiceImpl.java
index 0cedd56..2752c15 100644
--- a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downworkstation/service/impl/DownWorkstationServiceImpl.java
+++ b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downworkstation/service/impl/DownWorkstationServiceImpl.java
@@ -1,20 +1,127 @@
 package com.mes.downworkstation.service.impl;
 
-import com.mes.downworkstation.entity.DownWorkstation;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mes.downglassinfo.entity.DownGlassTask;
+import com.mes.downworkstation.entity.DownWorkstation;
+import com.mes.downworkstation.entity.DownWorkstationTask;
 import com.mes.downworkstation.mapper.DownWorkstationMapper;
+import com.mes.downworkstation.mapper.DownWorkstationTaskMapper;
 import com.mes.downworkstation.service.DownWorkstationService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
-/**
- * <p>
- *  鏈嶅姟瀹炵幇绫�
- * </p>
- *
- * @author zhoush
- * @since 2024-03-27
- */
+import java.util.List;
+import java.util.Map;
+
 @Service
 public class DownWorkstationServiceImpl extends ServiceImpl<DownWorkstationMapper, DownWorkstation> implements DownWorkstationService {
 
+    @Autowired
+    private DownWorkstationMapper downWorkstationMapper;
+    private DownWorkstationTaskMapper downWorkstationTaskMapper;
+
+
+
+//    @Override
+//    public List<DownWorkstation> gettwoDownWorkstations() {
+//        return downWorkstationMapper.getDownWorkstationsInRange(6,10);
+//    }
+//鑾峰彇鎬绘暟閲�
+    @Override
+    public int getTotalQuantity(int workstationId) {
+        QueryWrapper<DownWorkstation> queryWrapper = new QueryWrapper<>();
+        queryWrapper.select("total_quantity")
+                .eq("workstation_id", workstationId);
+
+        DownWorkstation result = baseMapper.selectOne(queryWrapper);
+        return result != null ? result.getTotalquantity() : 0;
+    }
+
+//    @Override
+//    public int getTotalQuantity(int workstationId) {
+//        Integer totalQuantity = downWorkstationMapper.getTotalQuantity(workstationId);
+//        return totalQuantity != null ? totalQuantity : 0;
+//    }
+
+//    @Override
+//    public int getRacksNumber(int workstationId) {
+//        Integer racksNumber = downWorkstationMapper.getRacksNumber(workstationId);
+//        return racksNumber != null ? racksNumber : 0;
+//    }
+    //鏍规嵁鏉′欢鑾峰彇钀芥灦鏁伴噺
+    @Override
+    public int getRacksNumber(int workstationId) {
+        QueryWrapper<DownWorkstation> queryWrapper = new QueryWrapper<>();
+        queryWrapper.select("racks_number")
+                .eq("workstation_id", workstationId);
+
+        DownWorkstation result = baseMapper.selectOne(queryWrapper);
+        return result != null ? result.getRacksnumber() : 0;
+    }
+//鏍规嵁鏉′欢鑾峰彇宸ヤ綅鐜荤拑淇℃伅
+    @Override
+    public List<DownWorkstation> getoneDownWorkstations(int startId, int endId) {
+        QueryWrapper<DownWorkstation> queryWrapper = new QueryWrapper<>();
+        queryWrapper.between("workstation_id", startId, endId);
+
+        return baseMapper.selectList(queryWrapper);
+    }
+
+
+//
+
+
+    @Override
+    public void updateracksnumber(String flowCardId, int racksNumber) {
+        UpdateWrapper<DownWorkstation> updateWrapper = new UpdateWrapper<>();
+        updateWrapper.set("racks_number",racksNumber).eq("flow_card_id", flowCardId);
+        baseMapper.update(null, updateWrapper);
+    }
+
+
+
+    @Override
+    public int updateFlowCardIdAndCount(String flowCardId, int glassInfoCount, int workstationId) {
+        UpdateWrapper<DownWorkstation> updateWrapper = new UpdateWrapper<>();
+        updateWrapper.set("total_quantity", glassInfoCount)
+                .set("flow_card_id", flowCardId)
+                .eq("workstation_id", workstationId);
+
+        return baseMapper.update(null, updateWrapper);
+    }
+
+    @Override
+    public void clearFlowCardId(int workstationId) {
+        UpdateWrapper<DownWorkstation> updateWrapper = new UpdateWrapper<>();
+        updateWrapper.set("flow_card_id", null)
+                .set("total_quantity", 0)
+                .set("racks_number", 0)
+                .eq("workstation_id", workstationId);
+
+        baseMapper.update(null, updateWrapper);
+    }
+
+
+
+
+
+
+
+
+
+    @Transactional
+    public void crossDatabaseQuery() {
+        // 浠� MySQL 鏁版嵁搴撲腑鏌ヨ鏁版嵁锛屽彧杩斿洖涓�鏉$鍚堟潯浠剁殑鏁版嵁
+        DownWorkstation downWorkstation = downWorkstationTaskMapper.selectdownWorkstationstate();
+
+        // 浠� SQL Server 鏁版嵁搴撲腑鏌ヨ鏁版嵁
+        List<DownWorkstationTask> downWorkstationTasks = downWorkstationTaskMapper.selectList();
+
+
+
+    }
+
 }

--
Gitblit v1.8.0