From bc25523bd723e92e85f3463edca27f0fe18a7a71 Mon Sep 17 00:00:00 2001
From: DESKTOP-LMJ82IJ\Eno <creaycat@gmail.com>
Date: 星期日, 13 四月 2025 16:49:19 +0800
Subject: [PATCH] #修改 收货单据界面优化修改

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeviceSiteServiceImpl.java |   55 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 55 insertions(+), 0 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeviceSiteServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeviceSiteServiceImpl.java
index e19660b..2a1a189 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeviceSiteServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeviceSiteServiceImpl.java
@@ -1,12 +1,67 @@
 package com.vincent.rsf.server.manager.service.impl;
 
+import com.alibaba.fastjson.JSONArray;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.vincent.rsf.framework.exception.CoolException;
+import com.vincent.rsf.server.manager.controller.params.DeviceSiteParame;
 import com.vincent.rsf.server.manager.mapper.DeviceSiteMapper;
 import com.vincent.rsf.server.manager.entity.DeviceSite;
 import com.vincent.rsf.server.manager.service.DeviceSiteService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Objects;
 
 @Service("deviceSiteService")
 public class DeviceSiteServiceImpl extends ServiceImpl<DeviceSiteMapper, DeviceSite> implements DeviceSiteService {
 
+    /**
+     * 鍒濆鍖栫珯鐐�
+     * @param param
+     * @return
+     */
+    @Override
+    public boolean initSites(DeviceSiteParame param) {
+        if (param.getFlagInit() == 1) {
+            List<DeviceSite> list = this.list(new LambdaQueryWrapper<DeviceSite>().select(DeviceSite::getId).last("limit 1"));
+            if (!list.isEmpty()) {
+                if (!this.remove(new LambdaQueryWrapper<>())) {
+                    throw new CoolException("鍒濆鍖栧け璐ワ細 鍒犻櫎绔欑偣澶辫触锛侊紒");
+                }
+            }
+        }
+        if (Objects.isNull(param.getDeviceSites()) || StringUtils.isBlank(param.getDeviceSites())) {
+            throw new CoolException("鍒濆鍖栧け璐ワ細 璁惧浣滀笟绔欑偣涓嶈兘涓虹┖锛侊紒");
+        }
+        if (Objects.isNull(param.getSites()) || StringUtils.isBlank(param.getSites())) {
+            throw new CoolException("鍒濆鍖栧け璐�: 浣滀笟绔欑偣涓嶈兘涓虹┖锛侊紒");
+        }
+        if (Objects.isNull(param.getTypeIds()) || param.getTypeIds().isEmpty()) {
+            throw new CoolException("鍒濆鍖栧け璐ワ細 浣滀笟绫诲瀷涓嶈兘涓虹┖锛侊紒");
+        }
+        List<String> sites = Arrays.asList(StringUtils.split(param.getSites(), ","));
+        List<String> dvSites = Arrays.asList(StringUtils.split(param.getDeviceSites(), ","));
+        List<DeviceSite> deviceSites =  new ArrayList<>();
+        for (String site : sites) {
+            for (String deviceSite : dvSites) {
+                for (Long id : param.getTypeIds()) {
+                    DeviceSite site1 = new DeviceSite();
+                    site1.setType(id + "")
+                            .setSite(site)
+                            .setDevice(param.getDeviceType())
+                            .setDeviceSite(deviceSite)
+                            .setDeviceCode(param.getDeviceCode());
+                    deviceSites.add(site1);
+                }
+            }
+        }
+        if (!this.saveBatch(deviceSites)) {
+            throw new CoolException("鍒濆鍖栧け璐ワ細 鏁版嵁淇濆瓨澶辫触锛侊紒");
+        }
+        return true;
+    }
 }

--
Gitblit v1.9.1