feat:zlb脚本

src/main/java/com/xiang/service/module/jntyzx/zlb/constants/ZlbUrlConstants.java

@@ -0,0 +1,49 @@
+package com.xiang.service.module.jntyzx.zlb.constants;
+
+public class ZlbUrlConstants {
+    /**
+     * 获取验证码接口
+     */
+    public static final String captchaUrl = "https://asian.hzsports.net/sendMessageServer/in/captcha/genCaptcha";
+    /**
+     * 获取图片轨迹接口
+     */
+    public static final String getCaptchaUrl = "http://118.31.116.52:5700/captcha";
+    /**
+     * 下单接口
+     */
+    public static final String newOrderUrl = "https://asian.hzsports.net/sportticketserver/site/sitePlaceOrder";
+    /**
+     * 获取用户信息接口
+     */
+    public static final String getUserInfoUrl = "https://asian.hzsports.net/sportthirdserver/zjmanage/getUserInfo";
+    /**
+     * 获取场地接口
+     */
+    public static final String getSiteInfoUrl = "https://asian.hzsports.net/sportticketserver/site/selectTicketListBy";
+    /**
+     * 获取订单接口
+     */
+    public static final String getOrderInfoUrl = "https://asian.hzsports.net/sportticketserver/orderV2/listSiteAndTicket";
+    /**
+     * 获取订单详情接口
+     */
+    public static final String getOrderDetailUrl = "https://asian.hzsports.net/sportticketserver/orderV2/siteDetail/%s";
+    /**
+     * 退单接口
+     */
+    public static final String getOrderRefundUrl = "https://asian.hzsports.net/sportticketserver/orderV2/refund";
+    /**
+     * 取消接口
+     */
+    public static final String getOrderCancelUrl = "https://asian.hzsports.net/sportticketserver/orderV2/cancel";
+
+
+    public static final String siteStr = "{\"stadiumId\":\"49\",\"siteItemId\":1940,\"belongDate\":\"%s\",\"channelType\":6}";
+    public static final String siteWqStr = "{\"stadiumId\":\"360112\",\"siteItemId\":1148,\"belongDate\":\"%s\",\"channelType\":6}";
+    public static final String refundStr = "{\"detailOrderId\":%s,\"detailOrderIds\":[%s],\"type\":2}";
+    public static final String cancelStr = "{\"orderId\":%s,\"type\":2}";
+
+    public static final String REDIS_PREFIX = "order:renew";
+}
+

src/main/java/com/xiang/service/module/jntyzx/zlb/schedule/ZlbTaskConfig.java

@@ -0,0 +1,4 @@
+package com.xiang.service.module.jntyzx.zlb.schedule;
+
+public class ZlbTaskConfig {
+}

src/main/java/com/xiang/service/module/jntyzx/zlb/service/ZlbService.java

@@ -0,0 +1,43 @@
+package com.xiang.service.module.jntyzx.zlb.service;
+
+
+import com.xiang.common.pojo.jntyzx.zlb.ZlbUserInfo;
+import com.xiang.common.utils.OkHttpUtil;
+
+import java.io.IOException;
+import java.util.Map;
+
+/**
+ * @author caoliang
+ * @version 1.0
+ * @date 2025-06-19 23:26:08
+ * @Description：***
+ */
+public interface ZlbService {
+    void queryZLbSiteInfo(String ymdDate,Integer type) throws Exception;
+
+    String getKey(String tokenId, OkHttpUtil client) throws IOException;
+
+
+    void testJs(String token, String name) throws IOException;
+
+    Map<String, String> getHeaders(String tokenId);
+
+    String buildSiteOrder(ZlbUserInfo zlbUserInfo, String secretKey, String day) throws Exception;
+
+    void createOrder(ZlbUserInfo zlbUserInfo) throws Exception;
+
+    String createOrderWq(ZlbUserInfo zlbUserInfo) throws Exception;
+
+    String buildNewOrder(String siteOrderDetailsStr, OkHttpUtil client) throws IOException;
+
+    void deleteRedis(String name);
+
+    void installRedis(String name);
+
+    void jianlou(String name, String day,long  time) throws Exception;
+
+    void refundOrder(String refundName,  String day) throws Exception;
+
+    void cancelOrder(String cancelName, String day) throws Exception;
+}

src/main/java/com/xiang/service/module/jntyzx/zlb/service/ZlbServiceImpl.java

@@ -0,0 +1,600 @@
+package com.xiang.service.module.jntyzx.zlb.service;
+
+import cn.hutool.http.HttpRequest;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONArray;
+import com.alibaba.fastjson2.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.xiang.common.factory.JntyzxDingTalkFactory;
+import com.xiang.common.pojo.jntyzx.zlb.*;
+import com.xiang.common.utils.AESECBUtils;
+import com.xiang.common.utils.DateUtils;
+import com.xiang.common.utils.OkHttpUtil;
+import com.xiang.service.module.jntyzx.zlb.constants.ZlbUrlConstants;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.io.IOException;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+
+
+@Service
+@Slf4j
+public class ZlbServiceImpl implements ZlbService {
+
+
+    @Resource
+    private ZlbSiteInfoService zlbSiteInfoService;
+    @Resource
+    private ZlbTokenInfoService zlbTokenInfoService;
+    @Autowired
+    private JntyzxDingTalkFactory jntyzxDingTalkFactory;
+    @Autowired
+    private ZlbUserInfoService zlbUserInfoService;
+    @Autowired
+    private RedisTemplate redisTemplate;
+
+
+    @Override
+    public void queryZLbSiteInfo(String ymdDate, Integer type) throws Exception {
+        log.info("开始查询场地信息");
+        LambdaQueryWrapper<ZlbSiteInfo> wrapper1 = Wrappers.lambdaQuery();
+        wrapper1.eq(ZlbSiteInfo::getType, type);
+        wrapper1.eq(ZlbSiteInfo::getBelongDate, ymdDate);
+        List<ZlbSiteInfo> zlbSiteInfoList1 = zlbSiteInfoService.list(wrapper1);
+        if (!zlbSiteInfoList1.isEmpty()) {
+            if (type == 1) {
+                dayinLog(zlbSiteInfoList1);
+                return;
+            } else {
+                zlbSiteInfoService.remove(wrapper1);
+            }
+        }
+        jntyzxDingTalkFactory.sendMsg(type + "没有查到" + ymdDate + "的场地,开始补齐");
+        OkHttpUtil client = OkHttpUtil.getInstance();
+        LambdaQueryWrapper<ZlbTokenInfo> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(ZlbTokenInfo::getName, "Xiang");
+        ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.getOne(wrapper);
+        List<ZlbSiteInfo> zlbSiteInfoList = new ArrayList<>();
+        String tokenId = zlbTokenInfo.getTokenId();
+        String key = getKey(tokenId, client);
+        log.info("tokenId==>{}", tokenId);
+        String siteOrderDetailsStr = "";
+        if (type.equals(1)) {
+            siteOrderDetailsStr = String.format(ZlbUrlConstants.siteStr, ymdDate);
+        } else if (type.equals(2)) {
+            siteOrderDetailsStr = String.format(ZlbUrlConstants.siteWqStr, ymdDate);
+        }
+        String reEncrypted = AESECBUtils.encrypt(siteOrderDetailsStr, key);
+        ZlbSiteRequest zlbSiteRequest = new ZlbSiteRequest();
+        zlbSiteRequest.setDataStr(reEncrypted);
+        zlbSiteRequest.setStadiumId("49");
+        zlbSiteRequest.setSiteItemId(1940);
+        String jsonString = JSON.toJSONString(zlbSiteRequest);
+        log.info("json:{}", jsonString);
+        //请求场地信息
+        Map<String, String> headers = getHeaders(tokenId);
+        String siteInfo = client.postJson(ZlbUrlConstants.getSiteInfoUrl, headers, jsonString);
+        log.info("请求场地返回信息： \n {}", siteInfo);
+        JSONObject jsonObject = JSONObject.parseObject(siteInfo);
+        JSONObject data = jsonObject.getJSONObject("data");
+        String listString = data.getString("list");
+        List<ZlbSiteInfo> zlbSiteInfos = JSONArray.parseArray(listString, ZlbSiteInfo.class);
+        for (ZlbSiteInfo zlbSiteInfo : zlbSiteInfos) {
+            Integer ticketType = zlbSiteInfo.getTicketType();
+            if (ticketType == 1 && type == 1) {//代表可以抢的场地号
+                zlbSiteInfo.setType(1);
+                zlbSiteInfoList.add(zlbSiteInfo);
+            }
+            if (ticketType == 4 && type == 1) {//代表可以抢的场地号
+                zlbSiteInfo.setType(4);
+                zlbSiteInfoList.add(zlbSiteInfo);
+            }
+            if (type == 2) {//代表可以抢的场地号
+                zlbSiteInfo.setType(2);
+                zlbSiteInfoList.add(zlbSiteInfo);
+            }
+        }
+        if (!zlbSiteInfoList.isEmpty()) {
+
+            zlbSiteInfoService.saveBatch(zlbSiteInfoList);
+        }
+        if (type.equals(1)) {
+            dayinLog(zlbSiteInfoList);
+        }
+    }
+
+    private void dayinLog(List<ZlbSiteInfo> zlbSiteInfoList1) {
+        Map<String, List<ZlbSiteInfo>> collect = zlbSiteInfoList1.stream().collect(Collectors.groupingBy(ZlbSiteInfo::getDayEffectiveTimes));
+        List<ZlbSiteInfo> zlbSiteInfos6_8 = collect.get("18:00");
+        List<ZlbSiteInfo> zlbSiteInfos8_10 = collect.get("20:00");
+        List<String> collect1 = zlbSiteInfos6_8.stream().map(ZlbSiteInfo::getPlaceName).collect(Collectors.toList());
+        List<String> collect2 = zlbSiteInfos8_10.stream().map(ZlbSiteInfo::getPlaceName).collect(Collectors.toList());
+        jntyzxDingTalkFactory.sendMsg("查询到后天场地6-8" + collect1);
+        jntyzxDingTalkFactory.sendMsg("查询到后天场地8-10" + collect2);
+    }
+
+    @Override
+    public String getKey(String tokenId, OkHttpUtil client) throws IOException {
+        Map<String, String> headers = getHeaders(tokenId);
+        String response = client.postJson(ZlbUrlConstants.getUserInfoUrl, headers, "{}");
+        log.info("获取用户信息返回:{}", response);
+        if (StringUtils.isNotBlank(response)) {
+            JSONObject jsonObject = JSONObject.parseObject(response);
+            String code = jsonObject.getString("code");
+            if ("200".equals(code)) {
+                JSONObject data = jsonObject.getJSONObject("data");
+                String secretKey = data.getString("secretKey");
+                //截取密钥前16位
+                return secretKey.substring(0, 16);
+            }
+        }
+        return "未登录";
+    }
+
+    @Override
+    public Map<String, String> getHeaders(String tokenId) {
+        Map<String, String> headers = new HashMap<>();
+        headers.put("Host", "asian.hzsports.net");
+        headers.put("Accept", "*/*");
+        headers.put("Sec-Fetch-Site", "cross-site");
+        headers.put("Accept-Language", "zh-CN,zh;q=0.9");
+        headers.put("Accept-Encoding", "gzip, deflate, br");
+        headers.put("token", tokenId);
+        headers.put("yayunToken", tokenId);
+        headers.put("Origin", "https://mapi.zjzwfw.gov.cn");
+        headers.put("User-Agent", "Mozilla/5.0 (iPhone; CPU iPhone OS 18_6_2 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/22G100 Ariver/1.0.10 Jupiter/1.0.0 000001@ZLB_iphone_7.28.0 hanweb_iphone_/hanweb/dtdreamweb/bundleVersion7.28.0");
+        headers.put("Referer", "https://mapi.zjzwfw.gov.cn/");
+        headers.put("Connection", "keep-alive");
+        headers.put("Content-Type", "application/json;charset=UTF-8");
+        headers.put("Sec-Fetch-Dest", "empty");
+        headers.put("Sec-Fetch-Mode", "cors");
+        return headers;
+    }
+
+    @Override
+    public String buildSiteOrder(ZlbUserInfo zlbUserInfo, String secretKey, String day) throws Exception {
+        //获取配置的场地号
+        log.info("secretKey:{}", secretKey);
+        String placeName = zlbUserInfo.getPlaceName();
+        String siteTimeName = zlbUserInfo.getSiteTimeName();
+        LambdaQueryWrapper<ZlbSiteInfo> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(ZlbSiteInfo::getPlaceName, placeName);
+        wrapper.eq(ZlbSiteInfo::getDayEffectiveTimes, siteTimeName);
+        wrapper.eq(ZlbSiteInfo::getBelongDate, day);
+        ZlbSiteInfo zlbSiteInfo = zlbSiteInfoService.getOne(wrapper);
+        if (zlbSiteInfo != null) {
+            ZlbOrderJson zlbOrderJson = new ZlbOrderJson();
+            zlbOrderJson.setAmount(zlbSiteInfo.getAmount());
+            zlbOrderJson.setBelongDate(zlbSiteInfo.getBelongDate());
+            zlbOrderJson.setDayEffectiveTimes(zlbSiteInfo.getDayEffectiveTimes());
+            zlbOrderJson.setDayOverdueTimes(zlbSiteInfo.getDayOverdueTimes());
+            zlbOrderJson.setPlaceName(zlbSiteInfo.getPlaceName());
+            zlbOrderJson.setSiteId(zlbSiteInfo.getSiteId());
+            zlbOrderJson.setSiteItemId(zlbSiteInfo.getSiteItemId());
+            zlbOrderJson.setSiteRuleId(zlbSiteInfo.getSiteRuleId());
+            zlbOrderJson.setSiteTicketId(zlbSiteInfo.getSiteTicketId());
+            zlbOrderJson.setPayChannel(2);
+            List<ZlbOrderJson> zlbOrderJsons = new ArrayList<>();
+            zlbOrderJsons.add(zlbOrderJson);
+            String jsonString = JSON.toJSONString(zlbOrderJsons);
+            return AESECBUtils.encrypt(jsonString, secretKey);
+        }
+        return "";
+    }
+
+    @Override
+    public void createOrder(ZlbUserInfo zlbUserInfo) throws Exception {
+        Date date = DateUtils.addDate(new Date(), 1);
+        String day = DateUtils.format(date, DateUtils.ENUM_FORMAT_YMD);
+        String name = zlbUserInfo.getName();
+        String placeName = zlbUserInfo.getPlaceName();
+        String siteTimeName = zlbUserInfo.getSiteTimeName();
+        //获取Token
+        ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.queryByName(name);
+        OkHttpUtil client = OkHttpUtil.getInstance();
+        String tokenId = zlbTokenInfo.getTokenId();
+        String secretKey = getKey(tokenId, client);
+        //组装场地信息
+        String siteOrderDetailsStr = buildSiteOrder(zlbUserInfo, secretKey, day);
+        //加密
+
+        for (int i = 1; i < 12; i++) {
+            String response1 = sendOrder(siteOrderDetailsStr, zlbTokenInfo.getTokenId(), client);
+            String str = buildOrder(name, response1, placeName, siteTimeName);
+            if ("下单成功".equals(str)) {
+                return;
+            }
+            if ("您选择场地已被售出".equals(str)) {
+                return;
+            }
+        }
+    }
+
+    public String buildOrder(String name, String response, String placeName, String siteTimeName) throws InterruptedException {
+        String orderId = "";
+        log.info("订单接口返回结果==> \n {}", response);
+        JSONObject jsonObject = JSONObject.parseObject(response);
+        if (jsonObject.getInteger("code") == 200) {
+            jntyzxDingTalkFactory.sendMsg(name + "订单接口下单返回成功请2分钟内付款√√√√√√场地号:" + placeName + "时间:" + siteTimeName);
+            JSONObject data = jsonObject.getJSONObject("data");
+            orderId = data.getString("orderId");
+            log.info("{}订单{}创建成功", name, orderId);
+            String redisKey = ZlbUrlConstants.REDIS_PREFIX + "_" + orderId + "_" + name;
+            redisTemplate.opsForValue().set(redisKey, name);
+            redisTemplate.expire(redisKey, 123, TimeUnit.SECONDS);
+            return "下单成功";
+        } else if (response.contains("场地不在可售时间内")) {
+            return "下单失败";
+        } else if (response.contains("下单失败")) {
+            return "下单失败";
+        } else if (response.contains("您选择场地已被售出")) {
+            return "您选择场地已被售出";
+        } else if (response.contains("此票超过用户每日订场次数")) {
+            return "下单失败";
+        } else if (response.contains("您有一笔待支付的订场订单")) {
+            Thread.sleep(1000);
+            return "您有一笔待支付的订场订单";
+        } else if (response.contains("场地火爆")) {
+            log.info("{}场地火爆下单返回失败暂停1s下单 \n{}", name, response);
+            return "下单失败";
+        } else {
+            log.info("{}订单接口下单返回失败 \n{}", name, response);
+        }
+        return orderId;
+    }
+
+    @Override
+    public String createOrderWq(ZlbUserInfo zlbUserInfo) throws Exception {
+        String orderId = "";
+        Date date = DateUtils.addDate(new Date(), 3);
+        String day = DateUtils.format(date, DateUtils.ENUM_FORMAT_YMD);
+        String name = zlbUserInfo.getName();
+        String placeName = zlbUserInfo.getPlaceName();
+        String siteTimeName = zlbUserInfo.getSiteTimeName();
+        //获取Token
+        ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.queryByName(name);
+        String siteOrderDetailsStr = buildSiteOrderList(zlbUserInfo, zlbTokenInfo.getSecretKey(), day);
+        //组装参数加密
+        for (int i = 1; i < 10; i++) {
+            String response = sendOrderWq(siteOrderDetailsStr, zlbTokenInfo.getTokenId());
+            log.info("订单接口返回结果==> \n {}", response);
+            JSONObject jsonObject = JSONObject.parseObject(response);
+            if (jsonObject.getInteger("code") == 200) {
+                jntyzxDingTalkFactory.sendMsg(name + "订单接口下单返回成功请2分钟内付款√√√√√√场地号:" + placeName + "时间:" + siteTimeName);
+                JSONObject data = jsonObject.getJSONObject("data");
+                orderId = data.getString("orderId");
+                return orderId;
+            } else if (response.contains("下单失败")) {
+                jntyzxDingTalkFactory.sendMsg(response);
+                return "";
+            } else if (response.contains("场地不在可售时间内")) {
+                jntyzxDingTalkFactory.sendMsg(response);
+                return "";
+            } else if (response.contains("您选择场地已被售出")) {
+                jntyzxDingTalkFactory.sendMsg(name + "订单接口下单返回失败 \n" + response);
+                return "";
+            } else if (response.contains("此票超过用户每日订场次数")) {
+                jntyzxDingTalkFactory.sendMsg(name + "订单接口下单返回失败 \n" + response);
+                return "";
+            } else if (response.contains("您有一笔待支付的订场订单")) {
+                jntyzxDingTalkFactory.sendMsg(name + "订单接口下单返回失败 \n" + response);
+                Thread.sleep(1500);
+            } else if (response.contains("场地火爆")) {
+                log.info("{}场地火爆下单返回失败暂停1s下单 \n{}", name, response);
+                Thread.sleep(200);
+            } else {
+                jntyzxDingTalkFactory.sendMsg(name + "订单接口下单返回失败请检查日志重试第" + i + "次××××××==> \n" + response);
+            }
+        }
+        return orderId;
+    }
+
+    private String sendOrderWq(String siteOrderDetailsStr, String tokenId) throws IOException {
+        OkHttpUtil client = OkHttpUtil.getInstance();
+        Map<String, String> headers = getHeaders(tokenId);
+        ZlbOrderWqInfo zlbOrderInfo = new ZlbOrderWqInfo();
+        zlbOrderInfo.setSiteOrderDetailsStr(siteOrderDetailsStr);
+        String jsonString = JSON.toJSONString(zlbOrderInfo);
+        log.info("json:\n {}", jsonString);
+        return client.postJson(ZlbUrlConstants.newOrderUrl, headers, jsonString);
+    }
+
+    private String buildSiteOrderList(ZlbUserInfo zlbUserInfo, String secretKey, String day) throws Exception {
+        //获取配置的场地号
+        log.info("secretKey:{}", secretKey);
+        String placeName = zlbUserInfo.getPlaceName();
+        String siteTimeName = zlbUserInfo.getSiteTimeName();
+        String[] siteTimeNameList = siteTimeName.split(",");
+        LambdaQueryWrapper<ZlbSiteInfo> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(ZlbSiteInfo::getPlaceName, placeName);
+        wrapper.in(ZlbSiteInfo::getDayEffectiveTimes, Arrays.asList(siteTimeNameList));
+        wrapper.eq(ZlbSiteInfo::getBelongDate, day);
+        List<ZlbSiteInfo> zlbSiteInfoList = zlbSiteInfoService.list(wrapper);
+        if (CollectionUtils.isNotEmpty(zlbSiteInfoList)) {
+            List<ZlbOrderWqJson> zlbOrderJsons = new ArrayList<>();
+            for (ZlbSiteInfo zlbSiteInfo : zlbSiteInfoList) {
+                ZlbOrderWqJson zlbOrderJson = new ZlbOrderWqJson();
+                zlbOrderJson.setIssueIds(null);
+                zlbOrderJson.setIssueAmount(0);
+                zlbOrderJson.setCardOrderId(null);
+                zlbOrderJson.setAmount(zlbSiteInfo.getAmount());
+                zlbOrderJson.setBelongDate(zlbSiteInfo.getBelongDate());
+                zlbOrderJson.setDayEffectiveTimes(zlbSiteInfo.getDayEffectiveTimes());
+                zlbOrderJson.setDayOverdueTimes(zlbSiteInfo.getDayOverdueTimes());
+                zlbOrderJson.setPlaceName(zlbSiteInfo.getPlaceName());
+                zlbOrderJson.setSaasTicketId(zlbSiteInfo.getSaasTicketId());
+                zlbOrderJson.setSiteId(zlbSiteInfo.getSiteId());
+                zlbOrderJson.setSiteItemId(zlbSiteInfo.getSiteItemId());
+                zlbOrderJson.setSiteRuleId(zlbSiteInfo.getSiteRuleId());
+                zlbOrderJson.setSiteTicketId(zlbSiteInfo.getSiteTicketId());
+                zlbOrderJson.setPayChannel(2);
+                zlbOrderJsons.add(zlbOrderJson);
+            }
+            String jsonString = com.alibaba.fastjson.JSON.toJSONString(zlbOrderJsons, SerializerFeature.WriteMapNullValue);
+            return AESECBUtils.encrypt(jsonString, secretKey);
+        }
+        return "";
+
+    }
+
+    private String sendOrder(String siteOrderDetailsStr, String token, OkHttpUtil client) throws Exception {
+        //请求参数以及图片验证码
+        String newOrderJson = buildNewOrder(siteOrderDetailsStr, client);
+        Map<String, String> headers = getHeaders(token);
+        return client.postJson(ZlbUrlConstants.newOrderUrl, headers, newOrderJson);
+    }
+
+    @Override
+    public String buildNewOrder(String siteOrderDetailsStr, OkHttpUtil client) throws IOException {
+        //获取图片验证码
+        String s = client.postJson(ZlbUrlConstants.captchaUrl, null, "{}");
+        //获取验证码轨迹
+        String track = HttpRequest.post(ZlbUrlConstants.getCaptchaUrl).body(s).execute().body();
+        ZlbOrderInfo zlbOrderInfo = JSONObject.parseObject(track, ZlbOrderInfo.class);
+        zlbOrderInfo.setSiteOrderDetailsStr(siteOrderDetailsStr);
+        String jsonString = JSON.toJSONString(zlbOrderInfo);
+        log.info("json:\n {}", jsonString);
+        return jsonString;
+    }
+
+    @Override
+    public void deleteRedis(String name) {
+        // 定义模糊匹配模式
+        String pattern = ZlbUrlConstants.REDIS_PREFIX + "_*_" + name;
+        // 查找所有匹配的键
+        Set<String> keys = redisTemplate.keys(pattern);
+        // 批量删除
+        if (!keys.isEmpty()) {
+            redisTemplate.delete(keys);
+        }
+    }
+
+    @Override
+    public void installRedis(String name) {
+        String redisKey = ZlbUrlConstants.REDIS_PREFIX + "_" + 123456 + "_" + name;
+        redisTemplate.opsForValue().set(redisKey, name);
+        redisTemplate.expire(redisKey, 1234, TimeUnit.SECONDS);
+    }
+
+    public static volatile boolean running = true;
+
+    @Override
+    public void jianlou(String name, String day, long time) throws Exception {
+        jntyzxDingTalkFactory.sendMsg(name + "自定义捡漏开始捡漏时间:" + day + "    捡漏人:" + name + "    捡漏间隔:" + time + "ms");
+        //获取Token
+        ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.queryByName(name);
+        String tokenId = zlbTokenInfo.getTokenId();
+        //代理ip
+        OkHttpUtil client = OkHttpUtil.getInstance();
+        String secretKey = getKey(tokenId, client);
+        if ("未登录".equals(secretKey)) {
+            jntyzxDingTalkFactory.sendMsg(name + "未登录请检查登录信息");
+            return;
+        }
+        log.info("开始捡漏:{}", name);
+        String siteOrderDetailsStr = String.format(ZlbUrlConstants.siteStr, day);
+        String reEncrypted = AESECBUtils.encrypt(siteOrderDetailsStr, secretKey);
+        ZlbSiteRequest zlbSiteRequest = new ZlbSiteRequest();
+        zlbSiteRequest.setDataStr(reEncrypted);
+        String jsonString = JSON.toJSONString(zlbSiteRequest);
+        //请求场地信息
+        Map<String, String> headers = new HashMap<>();
+        headers.put("token", tokenId);
+        int count = 0;
+        long startTime = System.currentTimeMillis();
+        // 可重用对象
+        JSONObject jsonObject = null;
+        List<ZlbSiteInfo> zlbSiteInfos = null;
+        running = true;
+        while (running) {
+            try {
+                String siteInfo = client.postJson(ZlbUrlConstants.getSiteInfoUrl, headers, jsonString);
+                if (StringUtils.isEmpty(siteInfo)) {
+                    return;
+                }
+                // log.info("请求场地返回信息： \n {}", siteInfo);
+                jsonObject = JSONObject.parseObject(siteInfo);
+                JSONObject data = jsonObject.getJSONObject("data");
+                String listString = data.getString("list");
+                zlbSiteInfos = JSONArray.parseArray(listString, ZlbSiteInfo.class);
+                for (ZlbSiteInfo zlbSiteInfo : zlbSiteInfos) {
+                    Integer ticketType = zlbSiteInfo.getTicketType();
+                    if (ticketType == 1) {//代表可以抢的场地号
+                        jntyzxDingTalkFactory.sendMsg(day + "ZLb捡漏发现场地:" + zlbSiteInfo.getPlaceName() + "时间点:" + zlbSiteInfo.getDayEffectiveTimes());
+                        ZlbOrderJson zlbOrderJson = new ZlbOrderJson();
+                        zlbOrderJson.setAmount(zlbSiteInfo.getAmount());
+                        zlbOrderJson.setBelongDate(zlbSiteInfo.getBelongDate());
+                        zlbOrderJson.setDayEffectiveTimes(zlbSiteInfo.getDayEffectiveTimes());
+                        zlbOrderJson.setDayOverdueTimes(zlbSiteInfo.getDayOverdueTimes());
+                        zlbOrderJson.setPlaceName(zlbSiteInfo.getPlaceName());
+                        zlbOrderJson.setSiteId(zlbSiteInfo.getSiteId());
+                        zlbOrderJson.setSiteItemId(zlbSiteInfo.getSiteItemId());
+                        zlbOrderJson.setSiteRuleId(zlbSiteInfo.getSiteRuleId());
+                        zlbOrderJson.setSiteTicketId(zlbSiteInfo.getSiteTicketId());
+                        zlbOrderJson.setPayChannel(2);
+                        List<ZlbOrderJson> zlbOrderJsons = new ArrayList<>();
+                        zlbOrderJsons.add(zlbOrderJson);
+                        String jsonStr = JSON.toJSONString(zlbOrderJsons);
+                        String encrypt = AESECBUtils.encrypt(jsonStr, secretKey);
+                        //拿到请求参数准备发请求
+                        String response = sendPost(client, headers, encrypt);
+                        log.info("请求参数： \n {}", jsonStr);
+                        JSONObject jsonObject22 = JSONObject.parseObject(response);
+                        if (jsonObject22.getInteger("code") == 200) {
+                            jntyzxDingTalkFactory.sendMsg(name + "ZLb捡漏场地成功请及时付款" + zlbSiteInfo.getPlaceName() + "时间:" + zlbSiteInfo.getDayEffectiveTimes());
+                            JSONObject data1 = jsonObject22.getJSONObject("data");
+                            String orderId = data1.getString("orderId");
+                            log.info("{}订单{}创建成功", name, orderId);
+                            String redisKey = ZlbUrlConstants.REDIS_PREFIX + "_" + orderId + "_" + name;
+                            redisTemplate.opsForValue().set(redisKey, name);
+                            redisTemplate.expire(redisKey, 120, TimeUnit.SECONDS);
+                            running = false;
+                        } else {
+                            jntyzxDingTalkFactory.sendMsg(name + "ZLb捡漏场地失败请查看日志" + response);
+                        }
+                    }
+                }
+                count++;
+                if (count % 30 == 0) {
+                    long duration = System.currentTimeMillis() - startTime;
+                    log.info("监控循环性能 已访问接口次数:{} - 平均每次循环耗时: {}ms", count, duration / 30);
+                    startTime = System.currentTimeMillis();
+                }
+                //休息5s
+                Thread.sleep(time);
+            } catch (Exception e) {
+                log.error("请求场地信息异常:{}", e.getMessage());
+                jntyzxDingTalkFactory.sendMsg(name + "ZLb自定义捡漏异常请查看日志");
+                e.printStackTrace();
+            }
+
+        }
+        log.info("捡漏结束");
+        jntyzxDingTalkFactory.sendMsg("自定义捡漏结束");
+    }
+
+    @Override
+    public void refundOrder(String refundName, String day) throws Exception {
+        //找到退款人的token
+        ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.getOne(new LambdaQueryWrapper<ZlbTokenInfo>().eq(ZlbTokenInfo::getName, refundName));
+        if (zlbTokenInfo == null) {
+            jntyzxDingTalkFactory.sendMsg("退款失败,请检查是否录入退款人登录信息-->" + refundName);
+        }
+        OkHttpUtil client = OkHttpUtil.getInstance();
+        //获取退款人的订单列表
+        String s = client.postJson(ZlbUrlConstants.getOrderInfoUrl, getHeaders(zlbTokenInfo.getTokenId()), "{\"curPage\":1,\"maxPage\":10,\"state\":2,\"type\":2}");
+        log.info("{}订单列表==> \n {}", refundName, s);
+        //获取当前日期下的orderId
+        JSONObject jsonObject = JSONObject.parseObject(s);
+        JSONObject data = jsonObject.getJSONObject("data");
+        if (data.getInteger("total").equals(0)) {
+            jntyzxDingTalkFactory.sendMsg("退款失败,请检查是否存在待使用订单-->" + refundName);
+            return;
+        }
+        JSONArray list = data.getJSONArray("list");
+        for (int i = 0; i < list.size(); i++) {
+            JSONObject jsonObject1 = list.getJSONObject(i);
+            String orderId = jsonObject1.getString("orderId");
+            Integer stadiumId = jsonObject1.getInteger("stadiumId");
+            String validity = jsonObject1.getString("validity");
+            log.info("stadiumId:{} ,validity:{},orderId:{}", stadiumId, validity, orderId);
+            if (stadiumId.equals(49) && validity.contains(day)) {
+                //拿到订单详情
+                String orderDetailStr = client.postJson(String.format(ZlbUrlConstants.getOrderDetailUrl, orderId), getHeaders(zlbTokenInfo.getTokenId()), "{}");
+                log.info("{}订单详情==> \n {}", orderId, orderDetailStr);
+                JSONObject jsonObject2 = JSONObject.parseObject(orderDetailStr);
+                JSONObject data1 = jsonObject2.getJSONObject("data");
+                JSONArray ticketInfos = data1.getJSONArray("ticketInfos");
+                for (int j = 0; j < ticketInfos.size(); j++) {
+                    JSONObject ticketInfo = ticketInfos.getJSONObject(j);
+                    String detailOrderId = ticketInfo.getString("detailOrderId");
+                    //取消订单
+                    String cancelOrder = client.postJson(ZlbUrlConstants.getOrderRefundUrl, getHeaders(zlbTokenInfo.getTokenId()), String.format(ZlbUrlConstants.refundStr, orderId, detailOrderId));
+                    log.info("{}退款订单==> \n {}", refundName, cancelOrder);
+                    if (cancelOrder.contains("退款成功")) {
+                        jntyzxDingTalkFactory.sendMsg(refundName + "退款成功");
+                    }
+                }
+            }
+
+        }
+
+    }
+
+    @Override
+    public void cancelOrder(String cancelName, String day) throws Exception {
+        //找到取消人的token
+        ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.getOne(new LambdaQueryWrapper<ZlbTokenInfo>().eq(ZlbTokenInfo::getName, cancelName));
+        if (zlbTokenInfo == null) {
+            jntyzxDingTalkFactory.sendMsg("取消失败,请检查是否录入取消人登录信息-->" + cancelName);
+        }
+        OkHttpUtil client = OkHttpUtil.getInstance();
+        //获取取消人的订单列表
+        String s = client.postJson(ZlbUrlConstants.getOrderInfoUrl, getHeaders(zlbTokenInfo.getTokenId()), "{\"curPage\":1,\"maxPage\":10,\"state\":1,\"type\":2}");
+        log.info("{}订单列表==> \n {}", cancelName, s);
+        //获取当前日期下的orderId
+        JSONObject jsonObject = JSONObject.parseObject(s);
+        JSONObject data = jsonObject.getJSONObject("data");
+        if (data.getInteger("total").equals(0)) {
+            jntyzxDingTalkFactory.sendMsg("取消失败,请检查是否存在待使用订单-->" + cancelName);
+            return;
+        }
+        JSONArray list = data.getJSONArray("list");
+        for (int i = 0; i < list.size(); i++) {
+            JSONObject jsonObject1 = list.getJSONObject(i);
+            String orderId = jsonObject1.getString("orderId");
+            Integer stadiumId = jsonObject1.getInteger("stadiumId");
+            String validity = jsonObject1.getString("validity");
+            log.info("stadiumId:{} ,validity:{},orderId:{}", stadiumId, validity, orderId);
+            if (stadiumId.equals(49) && validity.contains(day)) {
+                //取消订单,并直接删除redis相关信息
+                String cancelOrder = client.postJson(ZlbUrlConstants.getOrderCancelUrl, getHeaders(zlbTokenInfo.getTokenId()), String.format(ZlbUrlConstants.cancelStr, orderId));
+                deleteRedis(orderId);
+                log.info("{}取消订单==> \n {}", cancelName, cancelOrder);
+                if (cancelOrder.contains("取消成功")) {
+                    jntyzxDingTalkFactory.sendMsg(cancelName + "取消成功");
+                }
+            }
+        }
+    }
+
+    private String sendPost(OkHttpUtil client, Map<String, String> headers, String encrypt) throws IOException {
+        String newOrderJson = buildNewOrder(encrypt, client);
+        String response = null;
+        try {
+            response = client.postJson(ZlbUrlConstants.newOrderUrl, headers, newOrderJson);
+            log.info("抢场地返回信息： \n {}", response);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        return response;
+    }
+
+    @Override
+    public void testJs(String token, String name) throws IOException {
+        log.info("获取到name:{},token:{}", name, token);
+        LambdaQueryWrapper<ZlbTokenInfo> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(ZlbTokenInfo::getName, name);
+        ZlbTokenInfo tokenInfo = zlbTokenInfoService.getOne(wrapper);
+        if (tokenInfo != null) {
+            tokenInfo.setTokenId(token);
+            tokenInfo.setUpdatedDate(new Date());
+            zlbTokenInfoService.update(tokenInfo, wrapper);
+            jntyzxDingTalkFactory.sendMsg(name + "更新token为" + token);
+        } else {
+            jntyzxDingTalkFactory.sendMsg(name + "更新token失败没有该用户-->" + name);
+        }
+    }
+}
+
+

src/main/java/com/xiang/service/module/jntyzx/zlb/service/ZlbSiteInfoService.java

@@ -0,0 +1,13 @@
+package com.xiang.service.module.jntyzx.zlb.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.xiang.common.pojo.jntyzx.zlb.ZlbSiteInfo;
+
+/**
+* @author a123
+* @description 针对表【zlb_site_info】的数据库操作Service
+* @createDate 2025-06-19 23:32:29
+*/
+public interface ZlbSiteInfoService extends IService<ZlbSiteInfo> {
+
+}

src/main/java/com/xiang/service/module/jntyzx/zlb/service/ZlbSiteInfoServiceImpl.java

@@ -0,0 +1,21 @@
+package com.xiang.service.module.jntyzx.zlb.service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xiang.common.mapper.ZlbSiteInfoMapper;
+import com.xiang.common.pojo.jntyzx.zlb.ZlbSiteInfo;
+import org.springframework.stereotype.Service;
+
+/**
+* @author a123
+* @description 针对表【zlb_site_info】的数据库操作Service实现
+* @createDate 2025-06-19 23:32:29
+*/
+@Service
+public class ZlbSiteInfoServiceImpl extends ServiceImpl<ZlbSiteInfoMapper, ZlbSiteInfo>
+    implements ZlbSiteInfoService {
+
+}
+
+
+
+

src/main/java/com/xiang/service/module/jntyzx/zlb/service/ZlbTokenInfoService.java

@@ -0,0 +1,14 @@
+package com.xiang.service.module.jntyzx.zlb.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.xiang.common.pojo.jntyzx.zlb.ZlbTokenInfo;
+
+/**
+* @author a123
+* @description 针对表【zlb_token_info】的数据库操作Service
+* @createDate 2025-06-20 23:51:24
+*/
+public interface ZlbTokenInfoService extends IService<ZlbTokenInfo> {
+
+    ZlbTokenInfo queryByName(String name);
+}

src/main/java/com/xiang/service/module/jntyzx/zlb/service/ZlbTokenInfoServiceImpl.java

@@ -0,0 +1,29 @@
+package com.xiang.service.module.jntyzx.zlb.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xiang.common.mapper.ZlbTokenInfoMapper;
+import com.xiang.common.pojo.jntyzx.zlb.ZlbTokenInfo;
+import org.springframework.stereotype.Service;
+
+/**
+* @author a123
+* @description 针对表【zlb_token_info】的数据库操作Service实现
+* @createDate 2025-06-20 23:51:24
+*/
+@Service
+public class ZlbTokenInfoServiceImpl extends ServiceImpl<ZlbTokenInfoMapper, ZlbTokenInfo>
+    implements ZlbTokenInfoService {
+
+    @Override
+    public ZlbTokenInfo queryByName(String name) {
+        LambdaQueryWrapper<ZlbTokenInfo> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(ZlbTokenInfo::getName, name);
+        return this.getOne(wrapper);
+    }
+}
+
+
+
+

src/main/java/com/xiang/service/module/jntyzx/zlb/service/ZlbUserInfoService.java

@@ -0,0 +1,8 @@
+package com.xiang.service.module.jntyzx.zlb.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.xiang.common.pojo.jntyzx.zlb.ZlbUserInfo;
+
+public interface ZlbUserInfoService extends IService<ZlbUserInfo> {
+
+}

src/main/java/com/xiang/service/module/jntyzx/zlb/service/ZlbUserInfoServiceImpl.java

@@ -0,0 +1,16 @@
+package com.xiang.service.module.jntyzx.zlb.service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xiang.common.mapper.ZlbUserInfoMapper;
+import com.xiang.common.pojo.jntyzx.zlb.ZlbUserInfo;
+import org.springframework.stereotype.Service;
+
+@Service
+public class ZlbUserInfoServiceImpl extends ServiceImpl<ZlbUserInfoMapper, ZlbUserInfo>
+    implements ZlbUserInfoService {
+
+}
+
+
+
+