根据站点id 查询分账配置加缓存

jsowell-admin/src/test/java/SpringBootTestController.java

@@ -136,6 +136,9 @@ public class SpringBootTestController {
     @Autowired
     private PileMsgRecordService pileMsgRecordService;
 
+    @Autowired
+    private StationSplitConfigService stationSplitConfigService;
+
     @Autowired
     private PileStationInfoService pileStationInfoService;
 
@@ -157,9 +160,6 @@ public class SpringBootTestController {
     @Autowired
     private MemberService memberService;
 
-    @Autowired
-    private StationSplitConfigService stationSplitConfigService;
-
     @Autowired
     private OrderService orderService;
 
@@ -3951,4 +3951,11 @@ public class SpringBootTestController {
         List<DivMember> divMemberList = orderBasicInfoService.calculationOfSplitAmount(stationSplitConfigList, afterSettleOrderDTO, null);
         System.out.println(JSON.toJSONString(divMemberList));
     }
+
+    @Test
+    public void queryByStationIdTest() {
+        String stationId = "2";
+        List<StationSplitConfig> stationSplitConfigs = stationSplitConfigService.queryByStationId(stationId);
+        System.out.println(JSON.toJSONString(stationSplitConfigs));
+    }
 }

jsowell-common/src/main/java/com/jsowell/common/constant/CacheConstants.java

@@ -354,4 +354,9 @@ public class CacheConstants {
 	 * 根据桩号查询计费模板
 	 */
     public static final String BILLING_TEMPLATE_BY_PILE_SN = "billing_template_by_pile_sn:";
+
+	/**
+	 * 根据站点id查询分账配置
+	 */
+	public static final String QUERY_STATION_SPLIT_CONFIG = "query_station_split_config:";
 }

jsowell-pile/src/main/java/com/jsowell/pile/service/impl/StationSplitConfigServiceImpl.java

@@ -1,7 +1,10 @@
 package com.jsowell.pile.service.impl;
 
+import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Lists;
+import com.jsowell.common.constant.CacheConstants;
 import com.jsowell.common.constant.Constants;
+import com.jsowell.common.core.redis.RedisCache;
 import com.jsowell.common.enums.DelFlagEnum;
 import com.jsowell.common.exception.BusinessException;
 import com.jsowell.common.util.DateUtils;
@@ -23,6 +26,7 @@ import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.util.Date;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 @Service
 public class StationSplitConfigServiceImpl implements StationSplitConfigService{
@@ -33,9 +37,25 @@ public class StationSplitConfigServiceImpl implements StationSplitConfigService{
     @Autowired
     private AdapayMemberAccountService adapayMemberAccountService;
 
+    @Autowired
+    private RedisCache redisCache;
+
+    /**
+     * 根据站点ID查询站点分账配置, 加缓存
+     * @param stationId
+     * @return
+     */
     @Override
     public List<StationSplitConfig> queryByStationId(String stationId) {
-        return stationSplitConfigMapper.queryByStationId(stationId);
+        String redisKey = CacheConstants.QUERY_STATION_SPLIT_CONFIG + stationId;
+        List<StationSplitConfig> stationSplitConfigs = redisCache.getCacheList(redisKey);
+        if (CollectionUtils.isEmpty(stationSplitConfigs)) {
+            stationSplitConfigs = stationSplitConfigMapper.queryByStationId(stationId);
+            if (CollectionUtils.isNotEmpty(stationSplitConfigs)) {
+                redisCache.batchSetCacheList(ImmutableMap.of(redisKey, stationSplitConfigs), 30, TimeUnit.MINUTES);
+            }
+        }
+        return stationSplitConfigs;
     }
 
     @Override