From 6927d3bed414fb1a44312668d4e9d91d62e91b3f Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 09 七月 2024 00:43:50 +0800
Subject: [PATCH] 口令付款不依赖与订单
---
src/main/java/com/taoke/autopay/controller/WebApiController.java | 210 ++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 195 insertions(+), 15 deletions(-)
diff --git a/src/main/java/com/taoke/autopay/controller/WebApiController.java b/src/main/java/com/taoke/autopay/controller/WebApiController.java
index dafd7b6..094cfda 100644
--- a/src/main/java/com/taoke/autopay/controller/WebApiController.java
+++ b/src/main/java/com/taoke/autopay/controller/WebApiController.java
@@ -1,11 +1,20 @@
package com.taoke.autopay.controller;
+import com.taoke.autopay.dto.WXAppInfoDto;
import com.taoke.autopay.entity.KeyOrder;
+import com.taoke.autopay.entity.SystemConfigKeyEnum;
+import com.taoke.autopay.entity.WxUserInfo;
import com.taoke.autopay.exception.KeyOrderException;
+import com.taoke.autopay.exception.WxOrderCountException;
import com.taoke.autopay.factory.OrderFactory;
import com.taoke.autopay.service.KeyOrderService;
-import com.taoke.autopay.utils.JsonUtil;
-import com.taoke.autopay.utils.StringUtil;
+import com.taoke.autopay.service.SystemConfigService;
+import com.taoke.autopay.service.WxUserOrderCountService;
+import com.taoke.autopay.service.WxUserService;
+import com.taoke.autopay.utils.*;
+import com.taoke.autopay.vo.SubmitKeyInfo;
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
@@ -14,35 +23,51 @@
import org.yeshi.utils.UrlUtils;
import javax.annotation.Resource;
+import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
+import java.io.IOException;
import java.io.PrintWriter;
+import java.math.BigDecimal;
import java.util.Date;
+import java.util.HashSet;
import java.util.List;
+import java.util.Set;
@Controller
@RequestMapping("webapi")
public class WebApiController {
Logger logger = LoggerFactory.getLogger(WebApiController.class);
+ Logger wxLogger = LoggerFactory.getLogger("wxLogger");
+
+
@Resource
private KeyOrderService keyOrderService;
+ @Resource
+ private WxUserService wxUserService;
+
+ @Resource
+ private SystemConfigService systemConfigService;
@ResponseBody
@RequestMapping(value = "submitKey")
- public String submitKey(String key) {
- if(StringUtil.isNullOrEmpty(key)){
- return JsonUtil.loadFalseResult(0,"璇蜂笂浼爇ey");
+ public String submitKey(String key) {
+ if(1>0){
+ return JsonUtil.loadFalseResult(0, "鎺ュ彛宸插叧闂�");
}
- List<String> urllist = UrlUtils.parseUrlsFromText(key);
- if(urllist.isEmpty()||!urllist.get(0).contains("ur.alipay.com")){
- return JsonUtil.loadFalseResult("鏀粯瀹濆彛浠や笉姝ｇ‘");
- }
+ if (StringUtil.isNullOrEmpty(key)) {
+ return JsonUtil.loadFalseResult(0, "璇蜂笂浼爇ey");
+ }
+ List<String> urllist = UrlUtils.parseUrlsFromText(key);
+ if (urllist.isEmpty() || !urllist.get(0).contains("ur.alipay.com")) {
+ return JsonUtil.loadFalseResult("鏀粯瀹濆彛浠や笉姝ｇ‘");
+ }
try {
- KeyOrder order = keyOrderService.addKeyOrder(key);
-
- Long uid = keyOrderService.getCanDistributeUid();
- if(uid!=null){
- KeyOrder orderUpdate=new KeyOrder();
+ KeyOrder order = keyOrderService.addKeyOrder(new SubmitKeyInfo(key), null, TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyyMMdd"));
+ Long uid = keyOrderService.getCanDistributeUid();
+ if (uid != null) {
+ KeyOrder orderUpdate = new KeyOrder();
orderUpdate.setId(order.getId());
orderUpdate.setDistributeClientUid(uid);
orderUpdate.setDistributeTime(new Date());
@@ -51,8 +76,163 @@
return JsonUtil.loadTrueResult("");
} catch (KeyOrderException e) {
e.printStackTrace();
- return JsonUtil.loadFalseResult(e.getMessage());
+ return JsonUtil.loadFalseResult(e.getMessage());
+ } catch (WxOrderCountException e) {
+ return JsonUtil.loadFalseResult("浠婃棩瓒呰繃鏈�澶ф彁浜ゆ鏁�");
}
}
+ private void addKey(SubmitKeyInfo keyInfo, Long wxUid) throws KeyOrderException, WxOrderCountException {
+ KeyOrder order = keyOrderService.addKeyOrder(keyInfo, wxUid, TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyyMMdd"));
+ Long uid = keyOrderService.getCanDistributeUid();
+ if (uid != null) {
+ KeyOrder orderUpdate = new KeyOrder();
+ orderUpdate.setId(order.getId());
+ orderUpdate.setDistributeClientUid(uid);
+ orderUpdate.setDistributeTime(new Date());
+ keyOrderService.update(orderUpdate);
+ }
+
+
+ }
+
+ @ResponseBody
+ @RequestMapping(value = "submitKeyV2")
+ public String submitKeyV2(SubmitKeyInfo keyInfo, HttpSession session) {
+ WxUserInfo user = (WxUserInfo) session.getAttribute(Constant.SESSION_KEY_USER);
+ if (StringUtil.isNullOrEmpty(keyInfo.getKey())) {
+ return JsonUtil.loadFalseResult(0, "璇蜂笂浼爇ey");
+ }
+ List<String> urllist = UrlUtils.parseUrlsFromText(keyInfo.getKey());
+ if (urllist.isEmpty() || !urllist.get(0).contains("ur.alipay.com")) {
+ return JsonUtil.loadFalseResult("鏀粯瀹濆彛浠や笉姝ｇ‘");
+ }
+
+ if (user == null) {
+ // 鍏堜繚瀛楰EY
+// SESSION_KEY_TEMP_ALIPAY_KEY
+ session.setAttribute(Constant.SESSION_KEY_TEMP_ALIPAY_KEY, keyInfo);
+ wxLogger.info("寰俊娌℃湁鎺堟潈:" + session.getId());
+ String redictLink = systemConfigService.getValueCache(SystemConfigKeyEnum.WX_REDIRECT_LINK);
+ if (StringUtil.isNullOrEmpty(redictLink)) {
+ return JsonUtil.loadFalseResult("鏃犳硶鑾峰彇鍒版巿鏉冮摼鎺�");
+ }
+ // 娌℃湁鐧诲綍锛岃繑鍥炵櫥褰曢摼鎺�
+ JSONObject root = new JSONObject();
+ root.put("link", redictLink);
+ return JsonUtil.loadTrueResult(Constant.RESULT_CODE_NEED_LOGIN, root);
+ }
+ wxLogger.info("寰俊鏈夋巿鏉�:" + session.getId());
+
+ try {
+ addKey(keyInfo, user.getId());
+ return JsonUtil.loadTrueResult("");
+ } catch (KeyOrderException e) {
+ e.printStackTrace();
+ return JsonUtil.loadFalseResult(e.getMessage());
+ } catch (WxOrderCountException e) {
+ return JsonUtil.loadFalseResult(e.getMessage());
+ }
+ }
+
+ /**
+ * @author hxh
+ * @description 甯﹀彛浠や笌閲戦鐨勫彛浠ゆ彁浜ゆ帴鍙�
+ * @date 0:12 2024/7/9
+ * @param: keyInfo
+ * @param: session
+ * @return java.lang.String
+ **/
+ @ResponseBody
+ @RequestMapping(value = "submitKeyV3")
+ public String submitKeyV3(SubmitKeyInfo keyInfo, HttpSession session) {
+ WxUserInfo user = (WxUserInfo) session.getAttribute(Constant.SESSION_KEY_USER);
+ if (StringUtil.isNullOrEmpty(keyInfo.getKey())) {
+ return JsonUtil.loadFalseResult(0, "璇蜂笂浼爇ey");
+ }
+ if (StringUtil.isNullOrEmpty(keyInfo.getMoney())) {
+ return JsonUtil.loadFalseResult(0, "璇蜂笂浼爉oney");
+ }
+ List<String> urllist = UrlUtils.parseUrlsFromText(keyInfo.getKey());
+ if (urllist.isEmpty() || !urllist.get(0).contains("ur.alipay.com")) {
+ return JsonUtil.loadFalseResult("鏀粯瀹濆彛浠や笉姝ｇ‘");
+ }
+ // 楠岃瘉鎻愪氦鏃堕棿
+ String timeStr = systemConfigService.getValueCache(SystemConfigKeyEnum.KEY_SUBMIT_TIME_RANGE);
+ if(StringUtil.isNullOrEmpty(timeStr)){
+ return JsonUtil.loadFalseResult("灏氭湭閰嶇疆鐢熸晥鏃堕棿");
+ }
+ String startTime = timeStr.split(",")[0].trim().replace(":","");
+ String endTime = timeStr.split(",")[1].trim().replace(":","");
+ String now = TimeUtil.getGernalTime(System.currentTimeMillis(),"HHmmss");
+ if(Integer.parseInt(now)<Integer.parseInt(startTime)||Integer.parseInt(now)>Integer.parseInt(endTime)){
+ return JsonUtil.loadFalseResult(String.format("鍙ｄ护鎻愪氦鏃堕棿娈典负锛�%s-%s",timeStr.split(",")[0],timeStr.split(",")[1]));
+ }
+ // 楠岃瘉鎻愪氦鐨勯噾棰濇槸鍚︽纭�
+ String moneyStr = systemConfigService.getValueCache(SystemConfigKeyEnum.PAY_MONEY_LIST);
+ if(StringUtil.isNullOrEmpty(moneyStr)){
+ return JsonUtil.loadFalseResult("灏氭湭閰嶇疆閲戦");
+ }
+ JSONArray array=JSONArray.fromObject(moneyStr);
+ Set<String> moneySet=new HashSet<>();
+ for(int i=0;i<array.size();i++){
+ moneySet.add(MoneyUtil.getMoneyStr(new BigDecimal(array.optString(i))));
+ }
+ if(!moneySet.contains(MoneyUtil.getMoneyStr(new BigDecimal(keyInfo.getMoney())))){
+ return JsonUtil.loadFalseResult("鎻愪氦閲戦涓嶇鍚堣姹�");
+ }
+ if (user == null) {
+ // 鍏堜繚瀛楰EY
+// SESSION_KEY_TEMP_ALIPAY_KEY
+ session.setAttribute(Constant.SESSION_KEY_TEMP_ALIPAY_KEY, keyInfo);
+ wxLogger.info("寰俊娌℃湁鎺堟潈:" + session.getId());
+ String redictLink = systemConfigService.getValueCache(SystemConfigKeyEnum.WX_REDIRECT_LINK);
+ if (StringUtil.isNullOrEmpty(redictLink)) {
+ return JsonUtil.loadFalseResult("鏃犳硶鑾峰彇鍒版巿鏉冮摼鎺�");
+ }
+ // 娌℃湁鐧诲綍锛岃繑鍥炵櫥褰曢摼鎺�
+ JSONObject root = new JSONObject();
+ root.put("link", redictLink);
+ return JsonUtil.loadTrueResult(Constant.RESULT_CODE_NEED_LOGIN, root);
+ }
+ wxLogger.info("寰俊鏈夋巿鏉�:" + session.getId());
+ try {
+ addKey(keyInfo, user.getId());
+ return JsonUtil.loadTrueResult("");
+ } catch (KeyOrderException e) {
+ e.printStackTrace();
+ return JsonUtil.loadFalseResult(e.getMessage());
+ } catch (WxOrderCountException e) {
+ return JsonUtil.loadFalseResult(e.getMessage());
+ }
+ }
+
+ @RequestMapping(value = "wxLogin")
+ public void wxLogin(String code, String state, HttpServletResponse response, HttpSession session) throws IOException {
+ // 鏍规嵁code鑾峰彇openid
+ wxLogger.info("寰俊鎺堟潈鍥炶皟锛歿} code-{}", session.getId(), code);
+ String failLink = systemConfigService.getValueCache(SystemConfigKeyEnum.WX_LOGIN_FAIL_LINK);
+ try {
+ WXAppInfoDto wxApp = systemConfigService.getWxAppInfoCache();
+ String successLink = systemConfigService.getValueCache(SystemConfigKeyEnum.WX_LOGIN_SUCCESS_LINK);
+ WxApiUtil.WXAccessTokenInfo tokenInfo = WxApiUtil.getAcessTokenInfo(code, wxApp);
+ if (tokenInfo != null && !StringUtil.isNullOrEmpty(tokenInfo.getOpenid())) {
+ WxUserInfo user = wxUserService.login(tokenInfo.getOpenid());
+ session.setAttribute(Constant.SESSION_KEY_USER, user);
+ wxLogger.info("寰俊淇濆瓨鐢ㄦ埛淇℃伅锛歿} id-{}", session.getId(), user.getId());
+ SubmitKeyInfo alipayKeyInfo = (SubmitKeyInfo) session.getAttribute(Constant.SESSION_KEY_TEMP_ALIPAY_KEY);
+ wxLogger.info("浠巗ession璇诲彇鍒発ey锛歿}", alipayKeyInfo);
+ if (alipayKeyInfo != null) {
+ addKey(alipayKeyInfo, user.getId());
+ }
+ response.sendRedirect(successLink);
+ return;
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ wxLogger.error("鎺堟潈澶辫触锛歿}", e.getMessage());
+ }
+ response.sendRedirect(failLink);
+ }
+
}
--
Gitblit v1.8.0