From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq

---
 fanli/src/main/java/com/yeshi/fanli/controller/client/lijin/UserControllerLijin.java |   74 +++++++++++++++++++++++++++++++++++--
 1 files changed, 70 insertions(+), 4 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/lijin/UserControllerLijin.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/lijin/UserControllerLijin.java
index 3496a91..80c1f6d 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/lijin/UserControllerLijin.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/lijin/UserControllerLijin.java
@@ -1,10 +1,14 @@
 package com.yeshi.fanli.controller.client.lijin;
 
+import com.ks.vip.exception.OrderPayException;
 import com.ks.vip.exception.VipOrderException;
 import com.ks.vip.pojo.DO.VipCenter;
 import com.ks.vip.pojo.DO.VipCenterRecord;
 import com.ks.vip.pojo.DO.VipCombo;
+import com.ks.vip.pojo.DO.VipOrder;
+import com.ks.vip.pojo.DTO.PayWayInfoDTO;
 import com.ks.vip.pojo.Enums.OrderTypeEnum;
+import com.ks.vip.pojo.Enums.PayWayEnum;
 import com.ks.vip.pojo.Enums.VIPEnum;
 import com.ks.vip.service.VipComboService;
 import com.yeshi.fanli.entity.accept.AcceptData;
@@ -21,13 +25,12 @@
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestMapping;
-import org.yeshi.utils.JsonUtil;
-import org.yeshi.utils.MoneyBigDecimalUtil;
-import org.yeshi.utils.TimeUtil;
+import org.yeshi.utils.*;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.JedisPool;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.io.PrintWriter;
 import java.math.BigDecimal;
 import java.util.ArrayList;
@@ -214,8 +217,10 @@
                 name += "-骞村崱";
             } else if (hour > 24 * 31) {
                 name += "-瀛ｅ崱";
-            } else if (hour > 24) {
+            } else if (hour > 24 * 7) {
                 name += "-鏈堝崱";
+            } else if (hour > 24) {
+                name += "-鍛ㄥ崱";
             } else if (hour == 24) {
                 name += "-1澶�";
             } else {
@@ -231,4 +236,65 @@
         out.print(JsonUtil.loadTrueResult(data));
     }
 
+
+    /**
+     * 鍒涘缓VIP璁㈠崟
+     *
+     * @param acceptData
+     * @param uid
+     * @param id
+     * @param payWay     1-鏀粯瀹� 2-寰俊
+     * @param out
+     */
+    @RequestMapping("createVIPOrder")
+    public void createVIPOrder(AcceptData acceptData, Long uid, Long id, int payWay, HttpServletRequest request, PrintWriter out) {
+        try {
+            PayWayInfoDTO payWayInfoDTO = userLijinMnager.createVIPOrder(uid, id, payWay == 1 ? PayWayEnum.alipay : PayWayEnum.weChat, IPUtil.getRemotIP(request));
+            JSONObject data = new JSONObject();
+            if (payWayInfoDTO.getPayWay() == PayWayEnum.alipay) {
+                data.put("url", "http://api.tejia.yeshitv.com/fanli/alipay/printPayForm?formId=" + payWayInfoDTO.getAlipayFormId());
+            } else {
+                data.put("url", payWayInfoDTO.getPayUrl());
+            }
+            out.print(JsonUtil.loadTrueResult(data));
+        } catch (VipOrderException e) {
+            e.printStackTrace();
+            out.print(JsonUtil.loadFalseResult(e.getCode(), "鍒涘缓璁㈠崟鍑洪敊"));
+        }
+    }
+
+    @RequestMapping("checkVIPOrderPay")
+    public void checkPayResult(AcceptData acceptData, String id, PrintWriter out) {
+
+        if (id == null || !NumberUtil.isNumeric(id)) {
+            out.print(JsonUtil.loadFalseResult("id鏍煎紡鏈夎"));
+            return;
+        }
+
+        VipOrder vipOrder = null;
+        try {
+            vipOrder = userLijinMnager.checkPay(Long.parseLong(id));
+        } catch (OrderPayException e) {
+            out.print(JsonUtil.loadFalseResult(e.getMsg()));
+            return;
+        } catch (VipOrderException e) {
+            out.print(JsonUtil.loadFalseResult(e.getMsg()));
+            return;
+        }
+
+        if (vipOrder.getState() == VipOrder.STATE_PAY) {
+            //鏀粯鎴愬姛
+            JSONObject data = new JSONObject();
+            data.put("money", vipOrder.getPayMoney());
+            out.print(JsonUtil.loadTrueResult(data));
+        } else {
+            //鏀粯澶辫触
+            out.print(JsonUtil.loadFalseResult("璁㈠崟灏氭湭鏀粯鎴愬姛"));
+        }
+
+
+    }
+
+
+
 }

--
Gitblit v1.8.0