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

update 打印日志

Browse Source
This commit is contained in:
autumn.g@foxmail.com
2023-11-14 15:23:48 +08:00
parent 8aea7716f9
commit c6463a3db2
3 changed files with 27 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
jsowell-admin/src/main/java/com/jsowell/web/controller/pile/PileConnectorInfoController.java
View File

@@ -81,6 +81,7 @@ public class PileConnectorInfoController extends BaseController {
@Log(title = "充电桩枪口信息", businessType = BusinessType.UPDATE) @Log(title = "充电桩枪口信息", businessType = BusinessType.UPDATE)
@PostMapping("/updateParkNo") @PostMapping("/updateParkNo")
public RestApiResponse<?> updateParkNo(@RequestBody UpdateConnectorParkNoDTO dto) { public RestApiResponse<?> updateParkNo(@RequestBody UpdateConnectorParkNoDTO dto) {
logger.info("修改车位号 param:{}", JSONObject.toJSONString(dto));
RestApiResponse<?> response = null; RestApiResponse<?> response = null;
try { try {
int i = pileConnectorInfoService.updateConnectorParkNo(dto); int i = pileConnectorInfoService.updateConnectorParkNo(dto);

7
jsowell-common/src/main/java/com/jsowell/common/constant/CacheConstants.java
View File

@@ -98,7 +98,9 @@ public class CacheConstants {
*/ */
public static final String GET_ORDER_INFO_BY_ORDER_CODE = "get_order_info_by_order_code:"; public static final String GET_ORDER_INFO_BY_ORDER_CODE = "get_order_info_by_order_code:";
// 通过交易流水号查询订单信息 /**
* 通过交易流水号查询订单信息
*/
public static final String GET_ORDER_INFO_BY_TRANSACTION_CODE = "get_order_info_by_transaction_code:"; public static final String GET_ORDER_INFO_BY_TRANSACTION_CODE = "get_order_info_by_transaction_code:";
/** /**
@@ -106,6 +108,9 @@ public class CacheConstants {
*/ */
public static final String PILE_REAL_TIME_MONITOR_DATA = "pile_real_time_monitor_data:"; public static final String PILE_REAL_TIME_MONITOR_DATA = "pile_real_time_monitor_data:";
/**
* 充电桩充电状态
*/
public static final String PILE_IS_CHARGING = "pile_is_charging:"; public static final String PILE_IS_CHARGING = "pile_is_charging:";
/** /**

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

@@ -125,22 +125,28 @@ public class PileConnectorInfoServiceImpl implements IPileConnectorInfoService {
} }
/** /**
* 公共方法 根据桩编号删除redis缓存 * 公共方法 根据桩编号或者枪口号删除redis缓存
*/ */
private void deleteRedisByPileSn(String pileSn) { private void deleteRedisByPileSnOrPileConnectorCode(String pileSn, String pileConnectorCode) {
List<String> keys = Lists.newArrayList(); List<String> keys = Lists.newArrayList();
// 删除枪口信息缓存 if (StringUtils.isNotBlank(pileSn)) {
keys.add(CacheConstants.SELECT_PILE_CONNECTOR_INFO_LIST + pileSn); // 删除枪口信息缓存
// 删除充电桩详情缓存 keys.add(CacheConstants.SELECT_PILE_CONNECTOR_INFO_LIST + pileSn);
keys.add(CacheConstants.PILE_DETAIL_KEY + pileSn);
// 删除充电桩枪口状态缓存 // 删除充电桩详情缓存
Set<String> scan = redisCache.scan(CacheConstants.PILE_CONNECTOR_STATUS_KEY + pileSn + "*"); keys.add(CacheConstants.PILE_DETAIL_KEY + pileSn);
if (CollectionUtils.isNotEmpty(scan)) {
keys.addAll(scan);
} }
if (StringUtils.isNotBlank(pileConnectorCode)) {
// 删除充电桩枪口状态缓存
keys.add(CacheConstants.PILE_CONNECTOR_STATUS_KEY + pileConnectorCode);
}
// 批量删除 // 批量删除
log.info("批量删除缓存 pileSn:{}, keys:{}", pileSn, keys); if (CollectionUtils.isNotEmpty(keys)) {
redisCache.deleteObject(keys); redisCache.deleteObject(keys);
}
log.info("批量删除缓存 pileSn:{}, pileConnectorCode:{}, keys:{}", pileSn, pileConnectorCode, keys);
} }
/** /**
@@ -578,7 +584,7 @@ public class PileConnectorInfoServiceImpl implements IPileConnectorInfoService {
String pileSn = pileConnectorCode.substring(0, pileConnectorCode.length() - 2); String pileSn = pileConnectorCode.substring(0, pileConnectorCode.length() - 2);
// 只修改一个枪口的状态 // 只修改一个枪口的状态
num = pileConnectorInfoMapper.updateConnectorStatus(pileConnectorCode, status); num = pileConnectorInfoMapper.updateConnectorStatus(pileConnectorCode, status);
deleteRedisByPileSn(pileSn); deleteRedisByPileSnOrPileConnectorCode(pileSn, pileConnectorCode);
redisCache.setCacheObject(redisKey, status, CacheConstants.cache_expire_time_3m); redisCache.setCacheObject(redisKey, status, CacheConstants.cache_expire_time_3m);
// 异步放缓存 // 异步放缓存
@@ -745,7 +751,7 @@ public class PileConnectorInfoServiceImpl implements IPileConnectorInfoService {
int i = pileConnectorInfoMapper.updatePileConnectorInfo(info); int i = pileConnectorInfoMapper.updatePileConnectorInfo(info);
// 删除缓存 // 删除缓存
String pileSn = dto.getPileSn(); String pileSn = dto.getPileSn();
deleteRedisByPileSn(pileSn); deleteRedisByPileSnOrPileConnectorCode(pileSn, null);
return i; return i;
} }