From 55f49e493396d14689103f1912cb77fd653461cc Mon Sep 17 00:00:00 2001
From: liuhaonan <konodioda2333@vip.qq.com>
Date: 星期二, 22 三月 2022 18:00:21 +0800
Subject: [PATCH] c3m预付款以及ip音柱完善
---
ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3mOrderService.java | 46 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 46 insertions(+), 0 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3mOrderService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3mOrderService.java
index eb60f18..29b6dac 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3mOrderService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3mOrderService.java
@@ -1,11 +1,20 @@
package com.sandu.ximon.admin.service;
+import com.alibaba.fastjson.JSON;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.service.impl.BaseServiceImpl;
+import com.sandu.ximon.admin.config.C3mRedisConfig;
import com.sandu.ximon.admin.pay.wx.WxFastPayService;
import com.sandu.ximon.admin.security.SecurityUtils;
+import com.sandu.ximon.admin.security.order.OrderQueryListener;
+import com.sandu.ximon.admin.security.order.OrderScanType;
import com.sandu.ximon.admin.utils.AliPayUtils;
+import com.sandu.ximon.admin.utils.RedisUtils;
+import com.sandu.ximon.admin.vo.C3mOrderVO;
+import com.sandu.ximon.dao.domain.C3mCharging;
import com.sandu.ximon.dao.domain.C3mOrder;
+import com.sandu.ximon.dao.domain.Pole;
+import com.sandu.ximon.dao.enums.C3mRedisConstant;
import com.sandu.ximon.dao.enums.OrderStatus;
import com.sandu.ximon.dao.enums.OrderType;
import com.sandu.ximon.dao.mapper.C3mOrderMapper;
@@ -23,8 +32,11 @@
@AllArgsConstructor
public class C3mOrderService extends BaseServiceImpl<C3mOrderMapper, C3mOrder> {
+ private final RedisUtils redisUtils;
+ private final PoleService poleService;
private final C3mOrderMapper c3mOrderMapper;
private final WxFastPayService fastPayService;
+ private final OrderQueryListener orderQueryListener;
public boolean orderRefund(String outTradeNo, Double refundAmount/*, Long userId, String username*/) {
Long userId = SecurityUtils.getUserId();
@@ -91,4 +103,38 @@
return false;
}
}
+
+ public C3mOrder advancePayOrder(Long streetlightId, C3mCharging c3m, String orderType, Double totalAmount,
+ Integer subscribeChargingCapacity) {
+
+ // 鍒ゆ柇璇ュ厖鐢垫々鏄惁瀛樺湪姝ｅ湪杩涜涓殑璁㈠崟
+ String chargingJson = redisUtils.get(C3mRedisConstant.C3_CHARGING_ORDER.getCode() + c3m.getC3Mac());
+ if (null != chargingJson) {
+ return null;
+ }
+ Pole pole = poleService.getById(streetlightId);
+ if (null == pole) {
+ return null;
+ }
+ // 鐢熸垚璁㈠崟锛屽苟鍔犺浇鍒皉edis缂撳瓨锛岃缃秴鏃舵椂闂翠负5鍒嗛挓
+ C3mOrder c3mOrderEntity = new C3mOrderVO().generateOrder(
+ streetlightId,
+ pole.getDeviceCode(),
+ c3m.getC3Mac(),
+ OrderType.getOrderType(orderType),
+ totalAmount,
+ subscribeChargingCapacity
+ );
+ // 鍔犺浇鍒皉edis缂撳瓨涓�, 鏌ヨ妯″潡鑷姩鏌ヨ鐘舵�佸苟澶勭悊
+ boolean b = redisUtils.set(
+ C3mRedisConstant.C3_NO_PAY_ORDER.getCode() + c3m.getC3Mac() + c3mOrderEntity.getOutTradeNo(),
+ JSON.toJSONString(c3mOrderEntity),
+ C3mRedisConfig.ORDER_MAX_TIME
+ );
+ // 鎺ㄩ�佸埌鑷姩鏌ヨ妯″潡锛岃繘琛屾壂鎻忓惎鍔�
+ orderQueryListener.startScan(OrderScanType.C3M.getType());
+ return b ? c3mOrderEntity : null;
+ }
+
+
}
--
Gitblit v1.9.3