autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-07-14 19:18:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

取消缓存

Browse Source
This commit is contained in:
Guoqs
2024-09-09 19:46:21 +08:00
parent 723ab3529b
commit 766e6124e5
6 changed files with 69 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/JumpController.java
View File

@@ -117,12 +117,12 @@ public class JumpController extends BaseController {
// String pileSn = StringUtils.substring(pileConnectorCode, 0, 14); // String pileSn = StringUtils.substring(pileConnectorCode, 0, 14);
String pileSn = YKCUtils.getPileSn(pileConnectorCode); String pileSn = YKCUtils.getPileSn(pileConnectorCode);
logger.info("查询充电枪口详情, 截取桩号:{}, pileSn:{}", pileConnectorCode, pileSn); logger.info("查询充电枪口详情, 截取桩号:{}, pileSn:{}", pileConnectorCode, pileSn);
try { // try {
// 如果对接了类似华为平台的第三方平台，先修改一下枪口状态 // // 如果对接了类似华为平台的第三方平台，先修改一下枪口状态
updateThirdPartyConnectorStatus(pileSn); // updateThirdPartyConnectorStatus(pileSn);
}catch (Exception e) { // }catch (Exception e) {
logger.error("修改第三方平台枪口状态 error", e); // logger.error("修改第三方平台枪口状态 error", e);
} // }
try { try {
String memberId = null; String memberId = null;

26
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileBasicInfoServiceImpl.java
View File

@@ -11,7 +11,10 @@ import com.jsowell.common.core.domain.ykc.YKCFrameTypeCode;
import com.jsowell.common.core.redis.RedisCache; import com.jsowell.common.core.redis.RedisCache;
import com.jsowell.common.enums.DelFlagEnum; import com.jsowell.common.enums.DelFlagEnum;
import com.jsowell.common.enums.lianlian.LianLianPileStatusEnum; import com.jsowell.common.enums.lianlian.LianLianPileStatusEnum;
import com.jsowell.common.enums.ykc.*; import com.jsowell.common.enums.ykc.PileConnectorDataBaseStatusEnum;
import com.jsowell.common.enums.ykc.PileConnectorStatusEnum;
import com.jsowell.common.enums.ykc.PileStatusEnum;
import com.jsowell.common.enums.ykc.ReturnCodeEnum;
import com.jsowell.common.exception.BusinessException; import com.jsowell.common.exception.BusinessException;
import com.jsowell.common.util.*; import com.jsowell.common.util.*;
import com.jsowell.pile.domain.*; import com.jsowell.pile.domain.*;
@@ -47,7 +50,6 @@ import java.math.BigDecimal;
import java.math.RoundingMode; import java.math.RoundingMode;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.*; import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
@@ -125,15 +127,17 @@ public class PileBasicInfoServiceImpl implements PileBasicInfoService {
@Override @Override
public PileBasicInfo selectPileBasicInfoBySN(String pileSn) { public PileBasicInfo selectPileBasicInfoBySN(String pileSn) {
// 加缓存 // 加缓存
String redisKey = CacheConstants.SELECT_PILE_BASIC_INFO_BY_SN + pileSn; // String redisKey = CacheConstants.SELECT_PILE_BASIC_INFO_BY_SN + pileSn;
PileBasicInfo pileBasicInfo = redisCache.getCacheObject(redisKey); // PileBasicInfo pileBasicInfo = redisCache.getCacheObject(redisKey);
if (pileBasicInfo == null) { // if (pileBasicInfo == null) {
// 查数据库 // // 查数据库
pileBasicInfo = pileBasicInfoMapper.selectPileBasicInfoBySn(pileSn); // pileBasicInfo = pileBasicInfoMapper.selectPileBasicInfoBySn(pileSn);
if (pileBasicInfo != null) { // if (pileBasicInfo != null) {
redisCache.setCacheObject(redisKey, pileBasicInfo, 15, TimeUnit.MINUTES); // redisCache.setCacheObject(redisKey, pileBasicInfo, 15, TimeUnit.MINUTES);
} // }
} // }
PileBasicInfo pileBasicInfo = pileBasicInfoMapper.selectPileBasicInfoBySn(pileSn);
return pileBasicInfo; return pileBasicInfo;
} }

20
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileBillingTemplateServiceImpl.java
View File

@@ -606,15 +606,17 @@ public class PileBillingTemplateServiceImpl implements PileBillingTemplateServic
@Override @Override
public List<BillingTemplateVO> queryStationBillingTemplateListForUniApp(String stationId) { public List<BillingTemplateVO> queryStationBillingTemplateListForUniApp(String stationId) {
// 加缓存 // 加缓存
String redisKey = CacheConstants.QUERY_STATION_BILLING_TEMPLATE_LIST + stationId; // String redisKey = CacheConstants.QUERY_STATION_BILLING_TEMPLATE_LIST + stationId;
List<BillingTemplateVO> voList = redisCache.getCacheList(redisKey); // List<BillingTemplateVO> voList = redisCache.getCacheList(redisKey);
if (CollectionUtils.isEmpty(voList)) { // if (CollectionUtils.isEmpty(voList)) {
voList = pileBillingTemplateMapper.queryStationBillingTemplateList(stationId); // voList = pileBillingTemplateMapper.queryStationBillingTemplateList(stationId);
if (CollectionUtils.isNotEmpty(voList)) { // if (CollectionUtils.isNotEmpty(voList)) {
redisCache.setCacheList(redisKey, voList); // redisCache.setCacheList(redisKey, voList);
redisCache.expire(redisKey, 15, TimeUnit.MINUTES); // redisCache.expire(redisKey, 15, TimeUnit.MINUTES);
} // }
} // }
List<BillingTemplateVO> voList = pileBillingTemplateMapper.queryStationBillingTemplateList(stationId);
return voList; return voList;
} }

29
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileConnectorInfoServiceImpl.java
View File

@@ -48,7 +48,6 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
@@ -120,18 +119,22 @@ public class PileConnectorInfoServiceImpl implements PileConnectorInfoService {
@Override @Override
public List<PileConnectorInfo> selectPileConnectorInfoList(String pileSn) { public List<PileConnectorInfo> selectPileConnectorInfoList(String pileSn) {
// 取缓存 // 取缓存
String redisKey = CacheConstants.SELECT_PILE_CONNECTOR_INFO_LIST + pileSn; // String redisKey = CacheConstants.SELECT_PILE_CONNECTOR_INFO_LIST + pileSn;
List<PileConnectorInfo> result = redisCache.getCacheObject(redisKey); // List<PileConnectorInfo> result = redisCache.getCacheObject(redisKey);
if (CollectionUtils.isEmpty(result)) { // if (CollectionUtils.isEmpty(result)) {
// 缓存为空，查数据库 // // 缓存为空，查数据库
PileConnectorInfo pileConnectorInfo = new PileConnectorInfo(); // PileConnectorInfo pileConnectorInfo = new PileConnectorInfo();
pileConnectorInfo.setPileSn(pileSn); // pileConnectorInfo.setPileSn(pileSn);
result = selectPileConnectorInfoList(pileConnectorInfo); // result = selectPileConnectorInfoList(pileConnectorInfo);
if (CollectionUtils.isNotEmpty(result)) { // if (CollectionUtils.isNotEmpty(result)) {
// 查询数据库不为空，存redis 2分钟 // // 查询数据库不为空，存redis 2分钟
redisCache.setCacheObject(redisKey, result, 5, TimeUnit.MINUTES); // redisCache.setCacheObject(redisKey, result, 5, TimeUnit.MINUTES);
} // }
} // }
PileConnectorInfo pileConnectorInfo = new PileConnectorInfo();
pileConnectorInfo.setPileSn(pileSn);
List<PileConnectorInfo> result = selectPileConnectorInfoList(pileConnectorInfo);
return result; return result;
} }

19
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileModelInfoServiceImpl.java
View File

@@ -13,7 +13,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.List; import java.util.List;
import java.util.Objects;
/** /**
* 充电桩型号信息Service业务层处理 * 充电桩型号信息Service业务层处理
@@ -122,14 +121,16 @@ public class PileModelInfoServiceImpl implements PileModelInfoService {
@Override @Override
public PileModelInfoVO getPileModelInfoByModelId(Long modelId) { public PileModelInfoVO getPileModelInfoByModelId(Long modelId) {
String redisKey = CacheConstants.GET_PILE_MODEL_INFO_BY_MODEL_ID + modelId; // String redisKey = CacheConstants.GET_PILE_MODEL_INFO_BY_MODEL_ID + modelId;
PileModelInfoVO modelInfoVO = redisCache.getCacheObject(redisKey); // PileModelInfoVO modelInfoVO = redisCache.getCacheObject(redisKey);
if (Objects.isNull(modelInfoVO)) { // if (Objects.isNull(modelInfoVO)) {
modelInfoVO = pileModelInfoMapper.getPileModelInfoByModelId(modelId); // modelInfoVO = pileModelInfoMapper.getPileModelInfoByModelId(modelId);
if (Objects.nonNull(modelInfoVO)) { // if (Objects.nonNull(modelInfoVO)) {
redisCache.setCacheObject(redisKey, modelInfoVO, CacheConstants.cache_expire_time_1d); // redisCache.setCacheObject(redisKey, modelInfoVO, CacheConstants.cache_expire_time_1d);
} // }
} // }
PileModelInfoVO modelInfoVO = pileModelInfoMapper.getPileModelInfoByModelId(modelId);
return modelInfoVO; return modelInfoVO;
} }

20
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileStationInfoServiceImpl.java
View File

@@ -20,7 +20,9 @@ import com.jsowell.pile.domain.PileBasicInfo;
import com.jsowell.pile.domain.PileStationInfo; import com.jsowell.pile.domain.PileStationInfo;
import com.jsowell.pile.domain.SettleOrderReport; import com.jsowell.pile.domain.SettleOrderReport;
import com.jsowell.pile.domain.ThirdpartyParkingConfig; import com.jsowell.pile.domain.ThirdpartyParkingConfig;
import com.jsowell.pile.dto.*; import com.jsowell.pile.dto.FastCreateStationDTO;
import com.jsowell.pile.dto.QueryStationDTO;
import com.jsowell.pile.dto.QueryStationInfoDTO;
import com.jsowell.pile.dto.amap.GetStationInfoDTO; import com.jsowell.pile.dto.amap.GetStationInfoDTO;
import com.jsowell.pile.dto.business.StationBusinessAnalyzeInfoDTO; import com.jsowell.pile.dto.business.StationBusinessAnalyzeInfoDTO;
import com.jsowell.pile.dto.business.StationStatisticsInfoDTO; import com.jsowell.pile.dto.business.StationStatisticsInfoDTO;
@@ -51,7 +53,6 @@ import java.text.DecimalFormat;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
import java.util.*; import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.function.Function; import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@@ -107,13 +108,14 @@ public class PileStationInfoServiceImpl implements PileStationInfoService {
@Override @Override
public PileStationInfo selectPileStationInfoById(Long id) { public PileStationInfo selectPileStationInfoById(Long id) {
// 加缓存 // 加缓存
String redisKey = CacheConstants.SELECT_PILE_STATION_INFO_BY_ID + id; // String redisKey = CacheConstants.SELECT_PILE_STATION_INFO_BY_ID + id;
PileStationInfo pileStationInfo = redisCache.getCacheObject(redisKey); // PileStationInfo pileStationInfo = redisCache.getCacheObject(redisKey);
if (pileStationInfo == null) { // if (pileStationInfo == null) {
// 查数据库 // // 查数据库
pileStationInfo = pileStationInfoMapper.selectPileStationInfoById(id); // pileStationInfo = pileStationInfoMapper.selectPileStationInfoById(id);
redisCache.setCacheObject(redisKey, pileStationInfo, 15, TimeUnit.MINUTES); // redisCache.setCacheObject(redisKey, pileStationInfo, 15, TimeUnit.MINUTES);
} // }
PileStationInfo pileStationInfo = pileStationInfoMapper.selectPileStationInfoById(id);
return pileStationInfo; return pileStationInfo;
} }