apsbackend.git - Gitblit

			@@ -1,12 +1,20 @@
			package com.aps.core.service.impl;

			import java.util.List;
			import com.alibaba.fastjson2.JSONArray;
			import com.aps.common.core.utils.DateUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Service;
			import com.aps.core.mapper.ApsBomHeaderMapper;
			import com.aps.core.domain.ApsBom;
			import com.aps.core.domain.ApsBomHeader;
			import com.aps.core.mapper.ApsBomHeaderMapper;
			import com.aps.core.service.IApsBomHeaderService;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.data.redis.core.RedisTemplate;
			import org.springframework.stereotype.Service;

			import java.util.HashMap;
			import java.util.List;
			import java.util.Map;
			import java.util.Set;
			import java.util.stream.Collectors;

			/**
			* BOM Header 数据管理Service业务层处理
			@@ -19,6 +27,9 @@
			{
			@Autowired
			private ApsBomHeaderMapper apsBomHeaderMapper;

			@Autowired
			public RedisTemplate redisTemplate;

			/**
			* 查询BOM Header 数据管理
			@@ -93,4 +104,35 @@
			{
			return apsBomHeaderMapper.deleteApsBomHeaderById(id);
			}

			/**
			* 设置BOM数据到Redis
			* @return
			*/
			@Override
			public boolean setBomDataToRedis(String orgCode) {
			try {
			Set<String> keys = redisTemplate.keys("BOM:BOM_*");
			if (keys != null && !keys.isEmpty()) {
			redisTemplate.delete(keys);
			}
			List<ApsBom> bomRedisData = apsBomHeaderMapper.selectBomRedisData(orgCode);
			Map<String, List<ApsBom>> groupedByMainItemCode = bomRedisData.stream().collect(Collectors.groupingBy(ApsBom::getMainItemCode));
			Map<String, Object> bulkData = new HashMap<>();
			for (Map.Entry<String, List<ApsBom>> entry : groupedByMainItemCode.entrySet()) {
			String mainItemCode = entry.getKey();
			JSONArray jsonArray = JSONArray.from(entry.getValue());
			bulkData.put("BOM:BOM_" + orgCode + "_" + mainItemCode, jsonArray);
			}
			redisTemplate.opsForValue().multiSet(bulkData);
			} catch (Exception e) {
			e.printStackTrace();
			return false;
			}
			return true;
			}
			@Override
			public Integer getBomKeys(String orgCode){
			return redisTemplate.keys("BOM:BOM_"+orgCode+"*").size();
			}
			}