From 64f046ed41c2ae607dc065c82b6d454f64e90584 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期四, 19 六月 2025 21:52:33 +0800
Subject: [PATCH] 预警分析管理-电源告警
---
src/main/java/com/whyc/service/WorkflowDeviceService.java | 45 +++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 45 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/whyc/service/WorkflowDeviceService.java b/src/main/java/com/whyc/service/WorkflowDeviceService.java
new file mode 100644
index 0000000..286cb2f
--- /dev/null
+++ b/src/main/java/com/whyc/service/WorkflowDeviceService.java
@@ -0,0 +1,45 @@
+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.whyc.mapper.WorkflowDeviceMapper;
+import com.whyc.pojo.web_site.WorkflowDevice;
+import com.whyc.util.ActionUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class WorkflowDeviceService {
+
+ @Autowired
+ private WorkflowDeviceMapper mapper;
+
+ public void addBatch(List<WorkflowDevice> deviceList) {
+ mapper.insertBatchSomeColumn(deviceList);
+ }
+
+ public List<WorkflowDevice> getByMainId(Integer relatedId) {
+ QueryWrapper<WorkflowDevice> query = Wrappers.query();
+ query.eq("main_id",relatedId);
+ return mapper.selectList(query);
+ }
+
+ public void setQuantityUnprocessedZero(Integer relatedId) {
+ UpdateWrapper<WorkflowDevice> update = Wrappers.update();
+ update.set("quantity_unprocessed",0).eq("main_id",relatedId);
+ mapper.update((WorkflowDevice) ActionUtil.objeNull,update);
+ }
+
+ public void updateQuantityUnprocessedBatch(List<WorkflowDevice> deviceRelatedListInDB) {
+ for (int i = 0; i < deviceRelatedListInDB.size(); i++) {
+ WorkflowDevice deviceRelatedInDB = deviceRelatedListInDB.get(i);
+ UpdateWrapper<WorkflowDevice> update = Wrappers.update();
+ update.set("quantity_unprocessed",deviceRelatedInDB.getQuantityUnprocessed())
+ .eq("id",deviceRelatedInDB.getId());
+ mapper.update((WorkflowDevice) ActionUtil.objeNull,update);
+ }
+ }
+}
--
Gitblit v1.9.1