From 5fa707dbeb602e1552adde328c308f73e5ccf709 Mon Sep 17 00:00:00 2001
From: verou <857149855@qq.com>
Date: 星期四, 27 三月 2025 14:22:49 +0800
Subject: [PATCH] Merge branch 'devlop' of http://47.97.1.152:5880/r/wms-master into devlop

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeviceSiteServiceImpl.java |   61 ++++++++++++++++++++++++++++++
 1 files changed, 61 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
new file mode 100644
index 0000000..9328ef1
--- /dev/null
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeviceSiteServiceImpl.java
@@ -0,0 +1,61 @@
+package com.vincent.rsf.server.manager.service.impl;
+
+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) {
+            if (!this.remove(new LambdaQueryWrapper<>())) {
+                throw new CoolException("鍒濆鍖栧け璐ワ細 鍒犻櫎绔欑偣澶辫触锛侊紒");
+            }
+        }
+        if (Objects.isNull(param.getDeviceSites()) || param.getDeviceSites().isEmpty()) {
+            throw new CoolException("鍒濆鍖栧け璐ワ細 璁惧浣滀笟绔欑偣涓嶈兘涓虹┖锛侊紒");
+        }
+        if (Objects.isNull(param.getSites()) || param.getSites().isEmpty()) {
+            throw new CoolException("鍒濆鍖栧け璐�: 浣滀笟绔欑偣涓嶈兘涓虹┖锛侊紒");
+        }
+        if (Objects.isNull(param.getTypeIds()) || param.getTypeIds().isEmpty()) {
+            throw new CoolException("鍒濆鍖栧け璐ワ細 浣滀笟绫诲瀷涓嶈兘涓虹┖锛侊紒");
+        }
+        List<DeviceSite> deviceSites =  new ArrayList<>();
+        for (String site : param.getSites()) {
+            for (String deviceSite : param.getDeviceSites()) {
+                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