yuyang/XH-Power-Cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新订单结算报文的结算时间写入缓存

Browse Source
This commit is contained in:
panshuling321 2022-08-29 15:20:22 +08:00
parent 40c5654555
commit 5cdd792800
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/OrderDataLogic.java
View File

@ -6,7 +6,6 @@ import com.xhpc.common.api.PileOrderService;
import com.xhpc.common.core.domain.R; import com.xhpc.common.core.domain.R;
import com.xhpc.common.data.redis.CacheOrderData; import com.xhpc.common.data.redis.CacheOrderData;
import com.xhpc.common.data.up.OrderData; import com.xhpc.common.data.up.OrderData;
import com.xhpc.pp.controller.ChargingController;
import com.xhpc.pp.tx.ServiceParameter; import com.xhpc.pp.tx.ServiceParameter;
import com.xhpc.pp.tx.ServiceResult; import com.xhpc.pp.tx.ServiceResult;
import com.xhpc.pp.tx.logic.ServiceLogic; import com.xhpc.pp.tx.logic.ServiceLogic;
@ -67,6 +66,7 @@ public class OrderDataLogic implements ServiceLogic {
cacheOrder.put("status", "已结束"); cacheOrder.put("status", "已结束");
cacheOrder.put("stopReason", translate(cacheOrderData.getStopReason())); cacheOrder.put("stopReason", translate(cacheOrderData.getStopReason()));
cacheOrder.put("stopReasonHex", cacheOrderData.getStopReason()); cacheOrder.put("stopReasonHex", cacheOrderData.getStopReason());
cacheOrder.put("stopTime", cacheOrderData.getEndTime());
REDIS.setCacheMap(orderkey, cacheOrder); REDIS.setCacheMap(orderkey, cacheOrder);
String gunkey = "gun:".concat(orderData.getPileNo()).concat(orderData.getGunId()); String gunkey = "gun:".concat(orderData.getPileNo()).concat(orderData.getGunId());
Map<String, Object> cacheGun = REDIS.getCacheMap(gunkey); Map<String, Object> cacheGun = REDIS.getCacheMap(gunkey);

4
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/PileStartChargingDataLogic.java
View File

@ -112,8 +112,8 @@ public class PileStartChargingDataLogic implements ServiceLogic {
REDIS.setCacheMapValue("gun:".concat(connectorId), "orderkey", orderNo); REDIS.setCacheMapValue("gun:".concat(connectorId), "orderkey", orderNo);
String pushOrderKey = orderkey.replace("order:", "pushOrder:"); String pushOrderKey = orderkey.replace("order:", "pushOrder:");
Map map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
map.put("startChargeSeqStat", Integer.valueOf(2)); map.put("startChargeSeqStat", 2);
REDIS.setCacheMap(pushOrderKey, map); REDIS.setCacheMap(pushOrderKey, map);
resultStr = "00"; resultStr = "00";

1
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RealtimeDataLogic.java
View File

@ -147,6 +147,7 @@ public class RealtimeDataLogic implements ServiceLogic {
cacheOrder.put("totalPower", cacheRealtimeData.getChargingDegree() / 10000.0); cacheOrder.put("totalPower", cacheRealtimeData.getChargingDegree() / 10000.0);
cacheOrder.put("totalMoney", cacheRealtimeData.getAmountCharged() / 10000.0); cacheOrder.put("totalMoney", cacheRealtimeData.getAmountCharged() / 10000.0);
cacheOrder.put("realtimeDataList", realtimeDataList); cacheOrder.put("realtimeDataList", realtimeDataList);
cacheOrder.put("lastOrderTime", DateUtil.now());
R r1 = pileOrderService.pileRimeOrder(orderNo); R r1 = pileOrderService.pileRimeOrder(orderNo);
String msg = r1.getMsg(); String msg = r1.getMsg();
if (msg!=null && msg.contains("无效订单")) { if (msg!=null && msg.contains("无效订单")) {