From ef270bd1855b5ce3f398c5df024840a498e33a8f Mon Sep 17 00:00:00 2001
From: MercuryZ <zdmisif@126.com>
Date: 星期四, 31 三月 2022 14:09:17 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3mOrderService.java | 140 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 140 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
new file mode 100644
index 0000000..29b6dac
--- /dev/null
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3mOrderService.java
@@ -0,0 +1,140 @@
+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;
+import lombok.AllArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+/**
+ * @Author liuhaonan
+ * @Date 2022/3/10 14:24
+ * @Version 1.0
+ */
+@Service
+@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();
+ String username = SecurityUtils.getUsername();
+ C3mOrder orderByOutTradeNo = c3mOrderMapper.getOrderByOutTradeNo(outTradeNo);
+ if (orderByOutTradeNo.getTotalAmount() < refundAmount) {
+ throw new BusinessException("閫�娆鹃噾棰濋敊璇�,涓嶈兘澶т簬浠樻閲戦");
+ }
+ if (null == orderByOutTradeNo) {
+ return false;
+ } else {
+ orderByOutTradeNo.setRefundAmount(refundAmount);
+ return c3mOrderRefund(orderByOutTradeNo, "椤甸潰API閫�娆�", userId, username);
+ }
+
+
+ }
+
+
+ private boolean c3mOrderRefund(C3mOrder C3mOrder, String msg, Long userId, String username) {
+ // 杩涜閫�娆撅紝璁剧疆璁㈠崟鐘舵�佷负宸查��娆�
+ boolean b = false;
+ if (C3mOrder.getOrderType().equals(OrderType.ALIPAY.getCode())) {
+ b = AliPayUtils.alipayrefund(
+ C3mOrder.getPoleId(),
+ C3mOrder.getOutTradeNo(),
+ C3mOrder.getRefundAmount());
+ } else if (C3mOrder.getOrderType().equals(OrderType.WXPAY.getCode())) {
+ // 杩涜寰俊閫�娆�
+ b = fastPayService.refund(
+ C3mOrder.getTotalAmount(),
+ C3mOrder.getRefundAmount(),
+ C3mOrder.getOutTradeNo(),
+ C3mOrder.getPoleId()
+ );
+ }
+ C3mOrder.setRefundTimestamp(new Date().getTime());
+ C3mOrder.setRefundMsg(msg);
+ if (b) {
+ C3mOrder.setOrderStatus(OrderStatus.REFUND.getStatus());
+ c3mOrderMapper.updateRefundOrder(C3mOrder);
+ /* logService.log(
+ userId,
+ ServerTask.SERVER_TASK,
+ "C3m璁㈠崟澶勭悊",
+ null,
+ "{ 鎿嶄綔鑰�("+username+")" +
+ "璁㈠崟閫�娆�: "+C3mOrder.getOutTradeNo()
+ +",璁㈠崟鎬婚噾棰�:"+C3mOrder.getTotalAmount()
+ +",閫�娆鹃噾棰�: "+C3mOrder.getTotalAmount()+"}");*/
+ return true;
+ } else {
+ C3mOrder.setOrderStatus(OrderStatus.REFUND_FAILED.getStatus());
+ c3mOrderMapper.updateRefundOrder(C3mOrder);
+ /* logService.log(
+ userId,
+ ServerTask.SERVER_TASK,
+ "C3m璁㈠崟澶勭悊",
+ null,
+ "{ 鎿嶄綔鑰�("+username+")" +
+ "璁㈠崟閫�娆�(澶辫触): "+C3mOrder.getOutTradeNo()
+ +",璁㈠崟鎬婚噾棰�:"+C3mOrder.getTotalAmount()
+ +",閫�娆鹃噾棰�: "+C3mOrder.getTotalAmount()+"}");*/
+ 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