From 526721dd3acad281204e33d53b5168322ee31e56 Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期五, 20 六月 2025 11:34:55 +0800
Subject: [PATCH] 维修调度-报废库

---
 src/main/java/com/whyc/service/DeviceSpareService.java |   25 +++++++++++++++++++++++++
 1 files changed, 25 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/whyc/service/DeviceSpareService.java b/src/main/java/com/whyc/service/DeviceSpareService.java
index c924739..5dd1598 100644
--- a/src/main/java/com/whyc/service/DeviceSpareService.java
+++ b/src/main/java/com/whyc/service/DeviceSpareService.java
@@ -1,6 +1,7 @@
 package com.whyc.service;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -162,4 +163,28 @@
     public void add(List<DeviceSpare> spareList) {
         mapper.insertBatchSomeColumn(spareList);
     }
+
+    public void addOrUpdate(List<DeviceSpare> spareList) {
+        //鏌ヨ搴撲腑鏄惁瀛樺湪璇ヨ澶�,瀛樺湪鍒欏鍔犳暟閲�.
+        for (DeviceSpare spare : spareList) {
+            QueryWrapper<DeviceSpare> query = Wrappers.query();
+            query.eq("name",spare.getName());
+            query.eq("model",spare.getModel());
+            query.eq("version",spare.getVersion());
+            query.eq("brand",spare.getBrand());
+            query.eq("type",spare.getType());
+            query.eq("supplier",spare.getSupplier());
+            query.last(" limit 1");
+            DeviceSpare spareInDB = mapper.selectOne(query);
+            if(spareInDB != null){
+                spareInDB.setQuantity(spareInDB.getQuantity()+spare.getQuantity());
+                mapper.updateById(spareInDB);
+
+            }else{
+                //涓嶅瓨鍦ㄥ垯鏂板
+                mapper.insert(spare);
+            }
+        }
+
+    }
 }

--
Gitblit v1.9.1