From 70a46cd5e65b1ee16fb4bb4954a01129e6898b6d Mon Sep 17 00:00:00 2001 From: sfd <sun.sunshine@163.com> Date: 星期一, 12 五月 2025 18:29:37 +0800 Subject: [PATCH] Merge branch 'dev' of http://192.168.50.149:8085/r/aps-backend into dev --- aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsMaterialStorageManagementServiceImpl.java | 49 +++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 43 insertions(+), 6 deletions(-) diff --git a/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsMaterialStorageManagementServiceImpl.java b/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsMaterialStorageManagementServiceImpl.java index 623b13b..47d6e6c 100644 --- a/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsMaterialStorageManagementServiceImpl.java +++ b/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsMaterialStorageManagementServiceImpl.java @@ -1,17 +1,20 @@ package com.aps.core.service.impl; -import java.util.List; -import java.util.Optional; - import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONObject; import com.aps.common.core.utils.DateUtils; +import com.aps.common.core.utils.StringUtils; +import com.aps.core.domain.ApsMaterialStorageManagement; +import com.aps.core.mapper.ApsMaterialStorageManagementMapper; +import com.aps.core.service.IApsMaterialStorageManagementService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; -import com.aps.core.mapper.ApsMaterialStorageManagementMapper; -import com.aps.core.domain.ApsMaterialStorageManagement; -import com.aps.core.service.IApsMaterialStorageManagementService; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.Optional; /** * 鐗╂枡搴撳瓨绠$悊Service涓氬姟灞傚鐞� @@ -146,4 +149,38 @@ // 杩斿洖搴撳瓨淇℃伅瀵硅薄 return ams; } + + /** + * 璁剧疆搴撳瓨鏁版嵁鍒皉edis + * @param orgCode + * @return + */ + @Override + public boolean setStorageDataToRedis(String orgCode) { + try { + ApsMaterialStorageManagement temp = new ApsMaterialStorageManagement(); + if(!StringUtils.isEmpty(orgCode)){ + temp.setApplicableFactories(orgCode); + } + List<ApsMaterialStorageManagement> list = apsMaterialStorageManagementMapper.selectApsMaterialStorageManagementList(temp); + Map<String, Object> bulkData = new HashMap<>(); + list.forEach(apsMaterialStorageManagement -> { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("id", apsMaterialStorageManagement.getId()); + jsonObject.put("itemNumber", apsMaterialStorageManagement.getItemNumber()); + jsonObject.put("remainderStock", apsMaterialStorageManagement.getRemainderStock()); + jsonObject.put("applicableFactories", apsMaterialStorageManagement.getApplicableFactories()); + bulkData.put("MaterialStorage:Material_"+apsMaterialStorageManagement.getApplicableFactories()+"_"+apsMaterialStorageManagement.getItemNumber(), jsonObject); + }); + redisTemplate.opsForValue().multiSet(bulkData); + } catch (Exception e) { + e.printStackTrace(); + return false; + } +// Set<String> keys = redisTemplate.keys("MaterialStorage:Material_*"); +// if (keys != null && !keys.isEmpty()) { +// redisTemplate.delete(keys); +// } + return true; + } } -- Gitblit v1.9.3