diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java index 2337dc5f..c154b6b3 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/api/XhpcPileOrderController.java @@ -30,6 +30,8 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS; + @RestController public class XhpcPileOrderController extends BaseController { @@ -248,6 +250,7 @@ public class XhpcPileOrderController extends BaseController { //费率计费模型 List rateModelList = xhpcChargeOrderService.getRateModelId(xhpcChargeOrder.getRateModelId()); for (XhpcRate xhpcRate:rateModelList) { + System.out.println(">>>>>>"+xhpcRate.getRateValue()); if("00".equals(xhpcRate.getRateValue())){ t1powerFee = xhpcRate.getPowerFee(); } @@ -373,6 +376,8 @@ public class XhpcPileOrderController extends BaseController { map.put("userId", userId); JSONObject json = new JSONObject(map); webSocketService.getMessage(userId+"",json.toString()); + + }catch (Exception e){ e.printStackTrace(); return R.fail(500,"添加订单回调失败"); diff --git a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java index 42a04ff4..26a549ee 100644 --- a/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java +++ b/xhpc-modules/xhpc-order/src/main/java/com/xhpc/order/service/impl/XhpcRealTimeOrderServiceImpl.java @@ -26,6 +26,8 @@ import java.util.*; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS; + /** * @author yuyang * @date 2021/8/7 15:07 @@ -440,6 +442,8 @@ public class XhpcRealTimeOrderServiceImpl implements IXhpcRealTimeOrderService { xhpcHistoryOrderService.insert(xhpcHistoryOrder); xhpcChargeOrderService.updateXhpcChargeOrder(xhpcChargeOrder); + + redisService.deleteObject("pushOrder:"+xhpcChargeOrder.getSerialNumber()); }