From e196f42e9a977c0b2f8452dce875b110fb76e92f Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期六, 28 六月 2025 16:40:41 +0800
Subject: [PATCH] 实时数据统计曲线-核容设备初稿
---
src/main/java/com/whyc/service/WorkflowDeviceService.java | 26 ++++++++++++++++++++++++++
1 files changed, 26 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/whyc/service/WorkflowDeviceService.java b/src/main/java/com/whyc/service/WorkflowDeviceService.java
index 8bc2317..286cb2f 100644
--- a/src/main/java/com/whyc/service/WorkflowDeviceService.java
+++ b/src/main/java/com/whyc/service/WorkflowDeviceService.java
@@ -1,7 +1,11 @@
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;
@@ -16,4 +20,26 @@
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