保存0x13, 0x17, 0x19, 0x23中的soc

This commit is contained in:
Guoqs
2024-12-12 11:36:54 +08:00
parent c833d8c182
commit b395de00c1
6 changed files with 14 additions and 1 deletions

View File

@@ -394,6 +394,7 @@ public class YKCUtils {
/** /**
* 保存soc * 保存soc
* 默认保存7天
* @param transactionCode * @param transactionCode
* @param soc * @param soc
*/ */

View File

@@ -229,9 +229,11 @@ public class BMSDemandAndChargerOutputHandler extends AbstractYkcHandler {
.pileVoltageOutput(pileVoltageOutput) .pileVoltageOutput(pileVoltageOutput)
.pileCurrentOutput(pileCurrentOutput) .pileCurrentOutput(pileCurrentOutput)
.chargingTime(chargingTime) .chargingTime(chargingTime)
.build(); .build();
// 保存此订单的soc
YKCUtils.saveSOC(transactionCode, soc);
// 调用方法存入缓存 // 调用方法存入缓存
pileBasicInfoService.saveBMSDemandAndChargerOutputInfo2Redis(bmsDemandAndChargerOutputData); pileBasicInfoService.saveBMSDemandAndChargerOutputInfo2Redis(bmsDemandAndChargerOutputData);

View File

@@ -115,6 +115,9 @@ public class ChargeEndHandler extends AbstractYkcHandler {
} }
updateOrder.setUpdateTime(nowDate); updateOrder.setUpdateTime(nowDate);
orderBasicInfoService.updateOrderBasicInfo(updateOrder); orderBasicInfoService.updateOrderBasicInfo(updateOrder);
// 保存此订单的soc
YKCUtils.saveSOC(transactionCode, stopSoc);
} }
return null; return null;

View File

@@ -157,6 +157,9 @@ public class ParameterConfigurationHandler extends AbstractYkcHandler {
.build(); .build();
orderBasicInfoService.updateOrderBasicInfo(orderBasicInfo); orderBasicInfoService.updateOrderBasicInfo(orderBasicInfo);
log.info("更新订单起始SOC, orderCode:{}, transactionCode:{}, startSoc:{}", orderInfo.getOrderCode(), transactionCode, soc); log.info("更新订单起始SOC, orderCode:{}, transactionCode:{}, startSoc:{}", orderInfo.getOrderCode(), transactionCode, soc);
// 保存此订单的soc
YKCUtils.saveSOC(transactionCode, data.getSoc());
} }
return null; return null;

View File

@@ -288,6 +288,9 @@ public class UploadRealTimeMonitorHandler extends AbstractYkcHandler {
// 查询数据库中该订单当前信息 // 查询数据库中该订单当前信息
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode); OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
if (Objects.nonNull(orderInfo)) { if (Objects.nonNull(orderInfo)) {
// 保存此订单的soc
YKCUtils.saveSOC(transactionCode, realTimeMonitorData.getSOC());
if (StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.ORDER_COMPLETE.getValue()) if (StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.ORDER_COMPLETE.getValue())
|| StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.STAY_SETTLEMENT.getValue())) { || StringUtils.equals(orderInfo.getOrderStatus(), OrderStatusEnum.STAY_SETTLEMENT.getValue())) {
// 在订单状态为 订单完成或待结算,不保存 // 在订单状态为 订单完成或待结算,不保存

View File

@@ -666,6 +666,7 @@ public class PileBasicInfoServiceImpl implements PileBasicInfoService {
* 0x23信息设置缓存 (缓存时间3天) * 0x23信息设置缓存 (缓存时间3天)
* @param data * @param data
*/ */
@Override
public void saveBMSDemandAndChargerOutputInfo2Redis(BMSDemandAndChargerOutputData data) { public void saveBMSDemandAndChargerOutputInfo2Redis(BMSDemandAndChargerOutputData data) {
if (StringUtils.equals(data.getTransactionCode(), Constants.ILLEGAL_TRANSACTION_CODE)) { if (StringUtils.equals(data.getTransactionCode(), Constants.ILLEGAL_TRANSACTION_CODE)) {
return; return;