口令提交过渡页

Administrator

2025-02-17 7c733388b5e071fedd9b6b2ab4b000f0a5416784

口令提交过渡页

 src/main/java/com/taoke/autopay/controller/WebApiController.java

@@ -9,6 +9,7 @@
import com.taoke.autopay.exception.KeyOrderException;
import com.taoke.autopay.exception.KeyVerifyException;
import com.taoke.autopay.exception.WxOrderCountException;
import com.taoke.autopay.manager.PayCountVerifyManager;
import com.taoke.autopay.service.KeyOrderService;
import com.taoke.autopay.service.SystemConfigService;
import com.taoke.autopay.service.WxUserService;
@@ -17,6 +18,7 @@
import net.sf.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@@ -47,9 +49,11 @@

    @Resource
    private SystemConfigService systemConfigService;
    @Autowired
    private PayCountVerifyManager payCountVerifyManager;


    private void addKey(SubmitKeyInfo keyInfo, Long wxUid) throws KeyVerifyException, KeyOrderException, WxOrderCountException {
    private KeyOrder addKey(SubmitKeyInfo keyInfo, Long wxUid) throws KeyVerifyException, KeyOrderException, WxOrderCountException {

        // 查询没有处理的数量
        long notProcessCount = keyOrderService.countUserNotDoOrder(wxUid, new Date(System.currentTimeMillis() - 1000*60*30));
@@ -106,8 +110,7 @@
            orderUpdate.setDistributeTime(new Date());
            keyOrderService.update(orderUpdate);
        }


        return order;
    }

    private void verifySubmitKey(String key) throws Exception {
@@ -121,6 +124,7 @@
    }

    private Map<String, IPUtil.IPInfo> ipInfoMap=new HashMap<>();

    @ResponseBody
    @RequestMapping(value = "submitKeyV4")
    public String submitKeyV4(SubmitKeyInfo keyInfo, HttpSession session, HttpServletRequest request) {
@@ -186,8 +190,10 @@
        wxLogger.info("微信有授权:" + session.getId());
        LogUtil.loggerDebug.warn("GEO信息：{}-{}-{}", user.getId(),ip, new Gson().toJson(ipInfoMap.get(ip)));
        try {
            addKey(keyInfo, user.getId());
            return JsonUtil.loadTrueResult("");
            KeyOrder order = addKey(keyInfo, user.getId());
            JSONObject data = new JSONObject();
            data.put("id", order.getId());
            return JsonUtil.loadTrueResult(data);
        } catch (KeyOrderException e) {
            e.printStackTrace();
            return JsonUtil.loadFalseResult(e.getMessage());
@@ -260,7 +266,6 @@
                return;
            }
        } catch (Exception e) {
            e.printStackTrace();
            wxLogger.error("授权失败：{}", e.getMessage());
            if (!StringUtil.isNullOrEmpty(referer)) {
                Map<String, String> params = HttpUtil.getPramsFromUrl(referer);
@@ -271,4 +276,64 @@
        response.sendRedirect(failLink);
    }


    /**
     * 查询口令提交结果
     *
     * @param id
     * @param request
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "queryKeyResult")
    public String queryKeyResult(String id, HttpServletRequest request) {
        KeyOrder keyOrder = keyOrderService.selectById(id);
        if (keyOrder == null) {
            return JsonUtil.loadFalseResult("口令不存在");
        }
        String desc = "";
        switch (keyOrder.getState()) {
            case KeyOrder.STATE_NOT_PROCESS:
                if (keyOrder.getDistributeClientUid() == null) {
                    desc = "口令已提交，等待支付中...";
                } else {
                    desc = "支付排队中...";
                }
                break;
            case KeyOrder.STATE_NOT_PAY:
                desc = "正在支付...";
                break;
            case KeyOrder.STATE_PAY:
                desc = "支付成功";
                break;
            case KeyOrder.STATE_REJECT_PAY:
                desc = keyOrder.getStateDesc();
                break;
        }
        JSONObject data = new JSONObject();
        data.put("state_desc", desc);
        data.put("finish", keyOrder.getState() == KeyOrder.STATE_PAY || keyOrder.getState() == KeyOrder.STATE_REJECT_PAY ? 1 : 0);
        return JsonUtil.loadTrueResult(data);
    }

    /**
     * 查询支付剩余次数
     *
     * @param session
     * @param request
     * @return
     */

    @ResponseBody
    @RequestMapping(value = "queryPayLeftCount")
    public String queryPayLeftCount(HttpSession session, HttpServletRequest request) {
        WxUserInfo user = (WxUserInfo) session.getAttribute(Constant.SESSION_KEY_USER);
        if (user == null || user.getId() == null) {
            return JsonUtil.loadFalseResult("用户尚未登录");
        }
        // 查询支付剩余次数
        Map<Integer, Long> map = payCountVerifyManager.computeUserLeftPayCount(user.getId());
        return JsonUtil.loadTrueResult(new Gson().toJson(map));
    }

}

 src/main/java/com/taoke/autopay/manager/PayCountVerifyManager.java

@@ -10,6 +10,10 @@
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 支付次数管理器
@@ -25,6 +29,7 @@

    /**
     *  验证支付次数
     *
     * @param uid
     * @param orderType
     * @param orderChannel
@@ -45,5 +50,34 @@
        }
    }

    /**
     * 计算用户剩余支付次数
     *
     * @param uid
     */
    public Map<Integer,Long> computeUserLeftPayCount(Long uid) {
        Map<Integer,Long> map=new HashMap<>();
        OrderCountTypeEnum[] orderTypes = {OrderCountTypeEnum.DY_ORDER_PAY, OrderCountTypeEnum.KS_ORDER_PAY};
        OrderChannelEnum[] orderChannels = {OrderChannelEnum.cyx, OrderChannelEnum.bps, OrderChannelEnum.own};
        for (OrderCountTypeEnum type : orderTypes) {
            List<Long> countList=new ArrayList<>();
            for (OrderChannelEnum orderChannel : orderChannels) {
                long todayCount = wxUserOrderCountService.sum(uid, type, orderChannel, TimeUtil.getGernalTime(System.currentTimeMillis(), Constant.DB_DAY_FORMAT));
                long totalCount = wxUserOrderCountService.sum(uid, type, null, null);
                int maxPayCount = userSettingService.getLimitCountByTotalCount(type.getType(), totalCount, orderChannel);
                long leftCount = maxPayCount - todayCount;
                countList.add(leftCount);
            }
            long maxCount=0;
            for (Long count : countList) {
                if(count>maxCount){
                    maxCount=count;
                }
            }
            map.put(type.getType(),Math.min( maxCount, 50));
        }
        return map;
    }


}

 src/main/resources/static/index3.html

@@ -99,6 +99,7 @@
                        if(response.code==0){
                            layer.msg("提交成功");
                             $(".edit").val("");
                             window.location.href ="result.html?id="+response.data.id;
                        } else if(response.code==1001){
                            window.location.replace(response.data.link);
                        }else{

 src/main/resources/static/result.html

New file
@@ -0,0 +1,137 @@
<!DOCTYPE html>
<html>
<head>
    <meta charset="utf-8">
    <meta name="viewport"
          content="width=device-width, viewport-fit=cover, initial-scale=1,minimum-scale=1,maximum-scale=1,user-scalable=no"/>
    <title>支付结果</title>
    <link rel="stylesheet" type="text/css" href="layui/css/layui.css"/>
    <script src="js/jquery.min.js"></script>
    <script src="layui/layui.js"></script>
    <style>
        body {
            background: #FFF;
        }

        .container {
            display: flex;
            align-items: center;
            flex-direction: column;
        }


        .btn {
            background-color: #FF2B4B;
            border-radius: 0.5rem;
            width: 80%;
            margin-top: 2rem;
            font-size: 1.2rem;
        }

        #result_desc {
            font-size: 1rem;
            color: red;
            margin-top: 0.2rem;
        }

        .left-count span{
            background-color: #FF2B4B;
            color: white;
            border-radius: 0.2rem;
            margin: 0.2rem;
            padding: 0 1rem;
        }



        .left-count{
            display: flex;
            justify-content: space-around;
            padding: 1rem 0;
            visibility: hidden;
        }

        .invalid{
            background-color: gray;
        }

    </style>
</head>
<body>

<div class="container">

    <div class="left-count">
        <span id="dy">抖音剩余--次</span>
        <span id="ks">快手剩余--次</span>
    </div>

    <div></div>

    <div style="display: block;width: 80%;padding: 2rem 0rem;">
        <div >提交结果：</div>
        <div id="result_desc"></div>
    </div>

    <button class="layui-btn btn invalid" >继续提交口令</button>

</div>

<script>
    $(function () {
        function getQueryString(name) {
            console.log(window.location.search)
            var reg = new RegExp("(^|&)" + name + "=([^&]*)(&|$)", "i");
            var r = window.location.search.substr(1).match(reg);
            if (r != null)
                return unescape(decodeURI(r[2]));
            return null;
        }

        function queryResult(id) {
            $.post("/webapi/queryKeyResult", {"id": id}, function (response) {
                if (response.code == 0) {
                    if (response.data.finish == 0) {
                        setTimeout(function () {
                            queryResult(id);
                        }, 2000);
                    }else{
                        $(".btn").removeClass("invalid");
                    }
                    $("#result_desc").html(response.data["state_desc"]);
                } else {
                    layer.msg(response.msg);
                }
            }, 'json').fail(function (jqXHR, textStatus, errorThrown) {
                layer.msg("网络请求失败");
            });
        }

        function queryPayLeftCount(){
            $.post("/webapi/queryPayLeftCount", {}, function (response) {
                if (response.code == 0) {
                 $("#dy").html( "抖音剩余"+ response.data["1"]+"次");
                 $("#ks").html( "快手剩余"+ response.data["2"]+"次");
                 $(".left-count").css("visibility","visible");
                }
            }, 'json').fail(function (jqXHR, textStatus, errorThrown) {
                layer.msg("网络请求失败");
            });
        }

        let id = getQueryString("id");
        queryResult(id);
        queryPayLeftCount();
        $(".btn").click(function () {
            if(!$(".btn").hasClass("invalid"))
            {
                history.go(-1);
            }
        });
    });

</script>


</body>
</html>

 src/test/java/com/taoke/autopay/KeyTest.java

@@ -1,5 +1,6 @@
package com.taoke.autopay;

import com.google.gson.Gson;
import com.taoke.autopay.dao.KeyOrderMapper;
import com.taoke.autopay.dto.DYOrderDto;
import com.taoke.autopay.entity.KeyOrder;
@@ -10,9 +11,11 @@
import com.taoke.autopay.exception.KeyVerifyException;
import com.taoke.autopay.exception.WxOrderCountException;
import com.taoke.autopay.manager.OrderPayFailProcessor;
import com.taoke.autopay.manager.PayCountVerifyManager;
import com.taoke.autopay.service.*;
import com.taoke.autopay.utils.AlipayOrderUtil;
import com.taoke.autopay.utils.Constant;
import com.taoke.autopay.utils.JsonUtil;
import com.taoke.autopay.utils.TimeUtil;
import com.taoke.autopay.vo.SubmitKeyInfo;
import org.junit.jupiter.api.Test;
@@ -23,6 +26,7 @@
import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * @author hxh
@@ -194,5 +198,15 @@
        System.out.println(notProcessCount);
    }

    @Resource
    private PayCountVerifyManager payCountVerifyManager;

    @Test
    public void test4(){
        Long uid = 2L;
        Map<Integer,Long> map =  payCountVerifyManager.computeUserLeftPayCount(uid);
       System.out.println(new Gson().toJson(map));
    }


}