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 += "-瀛e崱"; - } 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