From 096296cd7485c5583c8194d88cca700e3c4d84a0 Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期一, 01 十二月 2025 16:50:42 +0800
Subject: [PATCH] 调整基础配置信息查询方式，取消jpa
---
fzzy-igdss-core/src/main/java/com/fzzy/igds/service/DepotConfService.java | 70 +++++++++++++++--------------------
1 files changed, 30 insertions(+), 40 deletions(-)
diff --git a/fzzy-igdss-core/src/main/java/com/fzzy/igds/service/DepotConfService.java b/fzzy-igdss-core/src/main/java/com/fzzy/igds/service/DepotConfService.java
index 1dcfdd3..f4a075c 100644
--- a/fzzy-igdss-core/src/main/java/com/fzzy/igds/service/DepotConfService.java
+++ b/fzzy-igdss-core/src/main/java/com/fzzy/igds/service/DepotConfService.java
@@ -1,9 +1,11 @@
package com.fzzy.igds.service;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.fzzy.igds.constant.RedisConst;
import com.fzzy.igds.domain.Depot;
import com.fzzy.igds.domain.DepotConf;
-import com.fzzy.igds.repository.DepotConfRepository;
+import com.fzzy.igds.mapper.DepotConfMapper;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.StringUtils;
@@ -26,14 +28,14 @@
public class DepotConfService {
@Resource
- private DepotConfRepository depotConfRepository;
+ private DepotConfMapper depotConfMapper;
@Resource
private DepotService depotService;
@Resource
private RedisCache redisCache;
/**
- * jpa鏌ヨ閰嶇疆淇℃伅
+ * 鏌ヨ閰嶇疆淇℃伅
*
* @param companyId
* @param deptId
@@ -44,14 +46,17 @@
if (StringUtils.isEmpty(companyId)) {
companyId = ContextUtil.getCompanyId();
}
- if (StringUtils.isEmpty(deptId)) {
- deptId = ContextUtil.subDeptId(null);
+ QueryWrapper<DepotConf> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("company_id", companyId);
+
+ if(StringUtils.isNotBlank(deptId)){
+ queryWrapper.eq("dept_id", deptId);
}
- return depotConfRepository.getDepotConf(companyId, deptId);
+ return depotConfMapper.selectList(queryWrapper);
}
/**
- * jpa鏇存柊淇濆瓨閰嶇疆淇℃伅
+ * 鏇存柊淇濆瓨閰嶇疆淇℃伅
*
* @param conf
*/
@@ -61,23 +66,31 @@
}
if (StringUtils.isEmpty(conf.getDeptId())) {
conf.setDeptId(ContextUtil.subDeptId(null));
+ }
+
+ if (null == conf.getUpdateBy()) {
conf.setCreateBy(ContextUtil.getLoginUserName());
conf.setCreateTime(new Date());
+
+ conf.setUpdateBy(ContextUtil.getLoginUserName());
+ conf.setUpdateTime(new Date());
+ depotConfMapper.insert(conf);
+ }else {
+ conf.setUpdateBy(ContextUtil.getLoginUserName());
+ conf.setUpdateTime(new Date());
+ depotConfMapper.updateById(conf);
}
- conf.setUpdateBy(ContextUtil.getLoginUserName());
- conf.setUpdateTime(new Date());
- depotConfRepository.save(conf);
flushConfCache(conf.getCompanyId());
}
/**
- * jpa鍒犻櫎閰嶇疆淇℃伅
+ * 鍒犻櫎閰嶇疆淇℃伅
*
* @param conf
* @return
*/
public void deleteDepotConf(DepotConf conf) {
- depotConfRepository.delete(conf);
+ depotConfMapper.deleteById( conf);
//鍒犻櫎閰嶇疆缂撳瓨
this.delCacheDepotConf(conf, conf.getCompanyId());
@@ -91,14 +104,8 @@
*/
public void setCacheDepotConf(List<DepotConf> list, String companyId) {
if (null != list) {
- Depot depot;
String key;
for (DepotConf depotConf : list) {
- depot = depotService.getCacheDepot(companyId, depotConf.getDepotId());
- if (null != depot) {
- depotConf.setDepotName(depot.getName());
- depotConf.setDepotType(depot.getDepotType());
- }
key = RedisConst.buildKey(companyId, RedisConst.KEY_DEPOT_CONF, depotConf.getDepotId());
redisCache.setCacheObject(key, depotConf);
}
@@ -199,30 +206,11 @@
String key = RedisConst.buildKey(companyId, RedisConst.KEY_DEPOT_CONF, depotId);
DepotConf depotConf = redisCache.getCacheObject(key);
if (null == depotConf) {
- depotConf = depotConfRepository.getDepotConfByDepotId(companyId, depotId);
+ depotConf = depotConfMapper.selectById(depotId);
redisCache.setCacheObject(key, depotConf);
}
return depotConf;
- }
-
- /**
- * 鏍规嵁浠撳簱鍒楄〃锛岃嚜鍔ㄧ敓鎴愪粨搴撻厤缃俊鎭�
- * @param companyId
- */
- private void addConfByDepot(String companyId) {
- List<Depot> list = depotService.getCacheDepotList(companyId);
- if (null == list || list.isEmpty()) {
- return;
- }
- DepotConf conf;
- for (Depot depot : list) {
- conf = new DepotConf();
- conf.setDepotId(depot.getId());
- conf.setCompanyId(depot.getCompanyId());
- conf.setDeptId(depot.getDeptId());
- this.saveConf(conf);
- }
}
/**
@@ -234,7 +222,7 @@
companyId = ContextUtil.getCompanyId();
}
- List<DepotConf> list = depotConfRepository.getDepotConfByCompanyId(companyId);
+ List<DepotConf> list = this.getConfList(companyId, null);
this.setCacheDepotConf(list, companyId);
}
@@ -244,6 +232,8 @@
* @param freq
*/
public void updateFreq(String freq) {
- depotConfRepository.updateGrainFreq(ContextUtil.getCompanyId(), ContextUtil.subDeptId(null), freq);
+ UpdateWrapper<DepotConf> updateWrapper = new UpdateWrapper<>();
+ updateWrapper.eq("dept_id", ContextUtil.subDeptId(null)).set("pos_x", freq);
+ depotConfMapper.update(null, updateWrapper);
}
}
--
Gitblit v1.9.3