From 2f432f52c1cfb1567dadcf6e040c5d38b0a26a79 Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期五, 28 十一月 2025 17:31:49 +0800
Subject: [PATCH] 数量检测配置页面
---
fzzy-igdss-view/src/main/java/com/fzzy/igds/DeviceIotPR.java | 132 ++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 132 insertions(+), 0 deletions(-)
diff --git a/fzzy-igdss-view/src/main/java/com/fzzy/igds/DeviceIotPR.java b/fzzy-igdss-view/src/main/java/com/fzzy/igds/DeviceIotPR.java
new file mode 100644
index 0000000..59e6614
--- /dev/null
+++ b/fzzy-igdss-view/src/main/java/com/fzzy/igds/DeviceIotPR.java
@@ -0,0 +1,132 @@
+package com.fzzy.igds;
+
+import com.bstek.dorado.annotation.DataProvider;
+import com.bstek.dorado.annotation.DataResolver;
+import com.bstek.dorado.annotation.Expose;
+import com.bstek.dorado.data.entity.EntityState;
+import com.bstek.dorado.data.entity.EntityUtils;
+import com.bstek.dorado.data.provider.Page;
+import com.fzzy.igds.domain.DeviceIot;
+import com.fzzy.igds.service.DeviceIotService;
+import com.fzzy.igds.utils.ContextUtil;
+import com.ruoyi.common.utils.StringUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.jpa.domain.Specification;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+import javax.annotation.Resource;
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Predicate;
+import javax.persistence.criteria.Root;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Description
+ * @Author CZT
+ * @Date 2025/11/28 14:53
+ */
+@Component
+public class DeviceIotPR {
+
+ @Resource
+ private DeviceIotService deviceIotService;
+
+ /**
+ * 鏌ヨ璁惧,灏嗘搷浣滀俊鎭皟鏁翠负绌�
+ *
+ * deviceIotPR#loadDeviceIotPage
+ *
+ * @param page
+ * @param param
+ * @return
+ */
+ @DataProvider
+ public void loadDeviceIotPage(Page<DeviceIot> page, Map<String, Object> param) {
+ if (null == param) {
+ param = new HashMap<>();
+ }
+ Map<String, Object> finalParam = param;
+
+ //澶氬弬鏁板垎椤垫煡璇�
+ Pageable pageable = PageRequest.of(page.getPageNo() - 1, page.getPageSize(), Sort.Direction.ASC, DeviceIot.SORT_PROP);
+ Specification<DeviceIot> specification = new Specification<DeviceIot>() {
+ private static final long serialVersionUID = 1L;
+
+ public Predicate toPredicate(Root<DeviceIot> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
+ List<Predicate> predicates = new ArrayList<Predicate>(); //鎵�鏈夌殑鏂█
+
+ Predicate predicate1 = cb.equal(root.get("companyId"), ContextUtil.getCompanyId());
+ predicates.add(predicate1);
+ predicate1 = cb.equal(root.get("deptId"), ContextUtil.subDeptId(null));
+ predicates.add(predicate1);
+
+ String key = (String) finalParam.get("depotId");
+ if (StringUtils.isNotEmpty(key)) {
+ predicate1 = cb.equal(root.get("depotId"), key);
+ predicates.add(predicate1);
+ }
+ key = (String) finalParam.get("type");
+ if (StringUtils.isNotEmpty(key)) {
+ predicate1 = cb.equal(root.get("type"), key);
+ predicates.add(predicate1);
+ }
+ key = (String) finalParam.get("serId");
+ if (StringUtils.isNotEmpty(key)) {
+ predicate1 = cb.equal(root.get("serId"), key);
+ predicates.add(predicate1);
+ }
+
+ return cb.and(predicates.toArray(new Predicate[0]));
+ }
+ };
+ org.springframework.data.domain.Page<DeviceIot> japPage = deviceIotService.findAll(specification, pageable);
+ page.setEntityCount((int) japPage.getTotalElements());
+ page.setEntities(japPage.getContent());
+ }
+
+ /**
+ * 淇濆瓨 devicePR#saveAll
+ *
+ * @param depotDeviceIots
+ * @return
+ */
+ @DataResolver
+ @Transactional
+ public String saveAll(List<DeviceIot> depotDeviceIots) {
+ String msg = "";
+ DeviceIot deviceIot;
+ for (DeviceIot depotDeviceIot : depotDeviceIots) {
+ EntityState state = EntityUtils.getState(depotDeviceIot);
+ deviceIot = new DeviceIot();
+ BeanUtils.copyProperties(depotDeviceIot, deviceIot);
+ if (state == EntityState.NEW) {
+ deviceIotService.updateDeviceIot(deviceIot);
+ msg = "娣诲姞鎴愬姛!";
+ }
+ if (state == EntityState.DELETED) {
+ deviceIotService.delDepotDeviceIot(deviceIot);
+ msg = "鍒犻櫎鎴愬姛!";
+ }
+ if (state == EntityState.MODIFIED) {
+ deviceIotService.updateDeviceIot(deviceIot);
+ msg = "淇敼鎴愬姛!";
+ }
+ }
+ return msg;
+ }
+
+ /**
+ * devicePR#refreshCache
+ */
+ @Expose
+ public void refreshCache(){
+ deviceIotService.refreshCache(null);
+ }
+}
--
Gitblit v1.9.3