| | |
|---|
| | | import com.aps.core.domain.ApsStandardProcessRouteHeader; |
|---|
| | | import com.aps.core.mapper.ApsStandardProcessRouteHeaderMapper; |
|---|
| | | import com.aps.core.service.IApsStandardProcessRouteHeaderService; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.data.redis.core.RedisTemplate; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | |
|---|
| | | * @date 2025-05-06 |
|---|
| | | */ |
|---|
| | | @Service |
|---|
| | | @Slf4j |
|---|
| | | public class ApsStandardProcessRouteHeaderServiceImpl implements IApsStandardProcessRouteHeaderService |
|---|
| | | { |
|---|
| | | @Autowired |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public boolean setProcessRouteDataToRedis(String orgCode) { |
|---|
| | | try { |
|---|
| | | log.info("开始同步标准工艺路线数据至Redis"); |
|---|
| | | Set<String> keys = redisTemplate.keys("ROUTE:ROUTE_*"); |
|---|
| | | if (keys != null && !keys.isEmpty()) { |
|---|
| | | redisTemplate.delete(keys); |
|---|
| | |
|---|
| | | bulkData.put("ROUTE:ROUTE_"+jsonObject.getString("org_code")+"_"+jsonObject.getString("item_code"), jsonObject.getBigDecimal("standardtime")); |
|---|
| | | } |
|---|
| | | redisTemplate.opsForValue().multiSet(bulkData); |
|---|
| | | log.info("完成同步标准工艺路线数据至Redis"); |
|---|
| | | return true; |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | log.error("同步标准工艺路线数据至Redis失败"+e.getMessage()); |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | } |
|---|
