fix:glados签到脚本

pom.xml

@@ -48,9 +48,9 @@
             <version>1.0-SNAPSHOT</version>
         </dependency>
         <dependency>
-            <groupId>com.xiang</groupId>
+            <groupId>com.xiang.starter</groupId>
             <artifactId>xmc-http-starter</artifactId>
-            <version>1.0-SNAPSHOT</version>
+            <version>2.0-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>com.xiang</groupId>

script/src/main/java/com/xiang/ServiceScriptApplication.java

@@ -17,7 +17,6 @@ import org.springframework.scheduling.annotation.EnableScheduling;
         "com.xiang.xservice.application.script.glados.repository",
         "com.xiang.xservice.application.script.xb.repository",
         "com.xiang.xservice.common.mapper",
-        "com.xiang.xservice.application.script.jntyzx.mapper"
 })
 @ConfigurationPropertiesScan(basePackages = {
         "com.xiang.xservice.config"

script/src/main/java/com/xiang/xservice/application/script/glados/common/GladosConstants.java

@@ -8,5 +8,5 @@ public class GladosConstants {
 
     public static final String GLADOS_COOKIE = "SL_G_WPT_TO=en; SL_GWPT_Show_Hide_tmp=1; SL_wptGlobTipTmp=1; koa:sess=eyJ1c2VySWQiOjU1OTg1MywiX2V4cGlyZSI6MTc3MjYwNDkyNjI4OCwiX21heEFnZSI6MjU5MjAwMDAwMDB9; koa:sess.sig=OdaqjpLkIp19lXn0lFuOsHX7vEM";
 
-    public static final String GLADOS_CHECK_IN_BODY = "{\"token\":\"glados.one\"}";
+    public static final String GLADOS_CHECK_IN_BODY = "{\"token\":\"glados.cloud\"}";
 }

script/src/main/java/com/xiang/xservice/application/script/glados/common/URLConstants.java

@@ -5,7 +5,7 @@ public class URLConstants {
     /**
      * glados 主域名
      */
-    public static final String GLADOS_URL_PREFIX = "https://www.glados.one";
+    public static final String GLADOS_URL_PREFIX = "https://glados.cloud";
 
     /**
      * 签到

script/src/main/java/com/xiang/xservice/application/script/glados/controller/GLaDOSController.java

@@ -1,11 +1,9 @@
 package com.xiang.xservice.application.script.glados.controller;
 
-import com.xiang.xservice.basic.common.resp.Result;
-import com.xiang.xservice.application.script.glados.entity.req.GladosCheckInReq;
 import com.xiang.xservice.application.script.glados.service.GLaDOSService;
+import com.xiang.xservice.basic.common.resp.Result;
 import lombok.RequiredArgsConstructor;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -21,9 +19,10 @@ public class GLaDOSController {
 
     private final GLaDOSService glaDOSService;
 
-    @PostMapping("/checkIn")
-    public Result<String> checkIn(@RequestBody GladosCheckInReq request) {
-        return Result.success(glaDOSService.checkIn());
+    @GetMapping("/checkIn")
+    public Result<Void> checkIn() {
+        glaDOSService.checkInV2();
+        return Result.success();
     }
 
 }

script/src/main/java/com/xiang/xservice/application/script/glados/entity/resp/CheckInResp.java

@@ -0,0 +1,20 @@
+package com.xiang.xservice.application.script.glados.entity.resp;
+
+import lombok.Data;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-23 09:21
+ */
+@Data
+public class CheckInResp {
+
+    private Long id;
+    private Long userId;
+    private Long time;
+    private String asset;
+    private String business;
+    private String change;
+    private String balance;
+    private String detail;
+}

script/src/main/java/com/xiang/xservice/application/script/glados/schedule/GladosCheckInJob.java

@@ -22,6 +22,6 @@ public class GladosCheckInJob {
     @Scheduled(cron = "0 0 7 1/1 * ?")
     public void checkInJon() {
         log.info("[job] Glados Check In Job start, time:{}", LocalDateTime.now());
-        glaDOSService.checkIn();
+        glaDOSService.checkInV2();
     }
 }

script/src/main/java/com/xiang/xservice/application/script/glados/service/GLaDOSService.java

@@ -10,4 +10,9 @@ public interface GLaDOSService {
      * 签到
      */
     String checkIn();
+
+    /**
+     * 签到
+     */
+    void checkInV2();
 }

script/src/main/java/com/xiang/xservice/application/script/glados/service/GLaDOSServiceImpl.java

@@ -1,10 +1,14 @@
 package com.xiang.xservice.application.script.glados.service;
 
 import com.alibaba.fastjson2.JSONObject;
+import com.alibaba.fastjson2.TypeReference;
 import com.google.common.collect.Maps;
+import com.xiang.xmc.service.http.helper.BaseHttpHelp;
+import com.xiang.xmc.service.http.helper.HttpHelperFactory;
 import com.xiang.xservice.application.script.glados.common.GladosConstants;
 import com.xiang.xservice.application.script.glados.common.URLConstants;
 import com.xiang.xservice.application.script.glados.entity.GladosRunLog;
+import com.xiang.xservice.application.script.glados.entity.resp.CheckInResp;
 import com.xiang.xservice.application.script.glados.entity.resp.GLaDOSResponse;
 import com.xiang.xservice.application.script.glados.repository.GladosMapper;
 import com.xiang.xservice.application.script.xb.entity.pojo.User;
@@ -33,6 +37,8 @@ public class GLaDOSServiceImpl implements GLaDOSService{
 
     private final DingTalkScriptGladosService dingTalkService;
 
+    private final BaseHttpHelp httpHelp = HttpHelperFactory.createSimpleHttp();
+
     /**
      * 签到
      */
@@ -63,6 +69,91 @@ public class GLaDOSServiceImpl implements GLaDOSService{
         return sb.toString();
     }
 
+    @Override
+    public void checkInV2() {
+        List<User> users = gladosMapper.listAllUser();
+        if (CollectionUtils.isEmpty(users)) {
+            return;
+        }
+        for (User user : users) {
+            try {
+                for (int i = 0; i < 3; i++) {
+                    if (checkInV2(user)) {
+                        break;
+                    }
+                    try {
+                        Thread.sleep(10000);
+                    } catch (InterruptedException e) {
+                        log.error("线程暂停10s失败");
+                    }
+                }
+            } catch (Exception e) {
+                log.error("签到失败，", e);
+            }
+        }
+    }
+
+    public boolean checkInV2(User user) {
+        Map<String, String> header = Maps.newHashMap();
+        header.put("Cookie", user.getCookie());
+
+        String response = null;
+
+        try {
+            response = httpHelp.doPost(URLConstants.GLADOS_CHECK_IN_URL, header, GladosConstants.GLADOS_CHECK_IN_BODY);
+        } catch (Exception e) {
+            log.error("http请求异常:{}", user.getEmail());
+            return false;
+        }
+        if (org.apache.commons.lang3.StringUtils.isBlank(response)) {
+            return false;
+        }
+
+        GLaDOSResponse<CheckInResp> gLaDOSResponse = JSONObject.parseObject(response, new TypeReference<GLaDOSResponse<CheckInResp>>() {
+        });
+        if (Objects.isNull(gLaDOSResponse)) {
+            return false;
+        }
+
+        if (0 == gLaDOSResponse.getCode()) {
+            // 成功请求
+            if (Objects.nonNull(gLaDOSResponse.getPoints()) && 0 != gLaDOSResponse.getPoints()) {
+                // 签到成功
+                dingTalkService.sendScriptMsg("[时间：" + LocalDateTime.now() + "] 用户: " +
+                        user.getEmail() + "签到成功，获得积分：" + gLaDOSResponse.getPoints());
+                GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(1).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
+                gladosMapper.insertScriptRunLog(build);
+                return Boolean.TRUE;
+            }
+        }
+
+        if (gLaDOSResponse.getMessage().contains("Repeats")) {
+            if (!CollectionUtils.isEmpty(gLaDOSResponse.getList())) {
+                dingTalkService.sendScriptMsg("用户:" + user.getEmail() + "当前已签到。结果：" + gLaDOSResponse.getList().get(0));
+                GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(1).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
+                gladosMapper.insertScriptRunLog(build);
+                return true;
+            }
+        }
+
+        if (-2 == gLaDOSResponse.getCode()) {
+            log.warn("签到失败，用户:{}, cookie过期:{}", user.getEmail(), gLaDOSResponse.getMessage());
+            String message = "[时间：" + LocalDateTime.now() + "] 用户: " + user.getEmail() + "，签到消息: " + gLaDOSResponse.getMessage() + "手动请求：http://general.xiangtech.xyz:30026/system/glados/checkIn";
+            try {
+                dingTalkService.sendScriptMsg(message);
+                return true;
+            } catch (Exception e) {
+                log.error("发送钉钉消息失败", e);
+            }
+        }
+
+        // 请求异常
+        dingTalkService.sendScriptMsg("用户:" + user.getEmail() + "请求异常，响应结果:" + gLaDOSResponse.getMessage());
+        GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(0).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
+        gladosMapper.insertScriptRunLog(build);
+        return false;
+    }
+
     private boolean checkIn(User user, StringBuffer sb) {
 
         Map<String, String> header = Maps.newHashMap();
@@ -83,18 +174,26 @@ public class GLaDOSServiceImpl implements GLaDOSService{
             log.info("http do post success, response:{}", response);
 
             // 成功签到记录
-            if (0 == gLaDOSResponse.getCode() && Objects.nonNull(gLaDOSResponse.getPoints())) {
-                log.info("签到成功, 签到积分:{}, 签到消息:{}", gLaDOSResponse.getPoints(), gLaDOSResponse.getMessage());
-                sb.append(user.getEmail()).append("签到成功，获得积分：").append(gLaDOSResponse.getPoints()).append("\n");
-                try {
-                    dingTalkService.sendScriptMsg("[时间：" + LocalDateTime.now() + "] 用户: " +
-                            user.getEmail() + "签到成功，获得积分：" + gLaDOSResponse.getPoints());
-                } catch (Exception e) {
-                    log.error("发送钉钉消息失败", e);
+            if (0 == gLaDOSResponse.getCode()) {
+                if (Objects.nonNull(gLaDOSResponse.getPoints())) {
+                    log.info("签到成功, 签到积分:{}, 签到消息:{}", gLaDOSResponse.getPoints(), gLaDOSResponse.getMessage());
+                    sb.append(user.getEmail()).append("签到成功，获得积分：").append(gLaDOSResponse.getPoints()).append("\n");
+                    try {
+                        dingTalkService.sendScriptMsg("[时间：" + LocalDateTime.now() + "] 用户: " +
+                                user.getEmail() + "签到成功，获得积分：" + gLaDOSResponse.getPoints());
+                    } catch (Exception e) {
+                        log.error("发送钉钉消息失败", e);
+                    }
+                    GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(1).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
+                    gladosMapper.insertScriptRunLog(build);
+                    return Boolean.TRUE;
+                } else {
+                    log.info("签到异常, 签到消息:{}", gLaDOSResponse.getMessage());
+                    sb.append(user.getEmail()).append("签到异常，消息：").append(gLaDOSResponse.getMessage());
+                    GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(0).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
+                    gladosMapper.insertScriptRunLog(build);
+                    return Boolean.FALSE;
                 }
-                GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(1).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
-                gladosMapper.insertScriptRunLog(build);
-                return Boolean.TRUE;
             }
 
             // 重复签到，表示当日签到成功

script/src/main/java/com/xiang/xservice/application/script/jntyzx/constants/UrlConstant.java

@@ -1,30 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.constants;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 13:46
- */
-public class UrlConstant {
-
-    /**
-     * 江南体育中心基础URL
-     */
-    private final static String  GNTYZX_BASE_URL = "https://jntyzx.cn:8443";
-
-    /**
-     * 查询当天的场地信息
-     */
-    public final static String QUERY_TODAY_SUBSCRIBE_URL = GNTYZX_BASE_URL + "/GYM-JN/multi/Subscribe/getSubscribeByToday";
-    public final static String QUERY_TOMORROW_SUBSCRIBE_URL = GNTYZX_BASE_URL + "/GYM-JN/multi/Subscribe/getSubscribeByTomorrow";
-
-    /**
-     * 订阅场地
-     */
-    public final static String ADD_SUBSCRIBE = GNTYZX_BASE_URL + "/GYM-JN/multi/Subscribe/addSubscribe";
-
-    /**
-     * 心跳监测接口
-     */
-    public final static String HEALTH_DECLARATION = GNTYZX_BASE_URL + "/GYM-JN//busi/healthDeclaration/addUserPrivacy";
-
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/controller/VenueController.java

@@ -1,51 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.controller;
-
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.SitePositionList;
-import com.xiang.xservice.application.script.jntyzx.service.IVenueService;
-import com.xiang.xservice.application.script.jntyzx.service.IJntyzxHttpService;
-import com.xiang.xservice.basic.common.resp.Result;
-import lombok.RequiredArgsConstructor;
-import org.apache.commons.collections4.CollectionUtils;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 14:28
- */
-@RestController
-@RequiredArgsConstructor
-public class VenueController {
-
-    private final IVenueService venueService;
-    private final IJntyzxHttpService jntyzxHttpService;
-
-    private final static String STATIC_TOKEN = "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJleHAiOjE3NjU3ODQ1NjMsInVzZXJuYW1lIjoid3hfb3Blbl9pZF9vMjFNWDR5N3doWENHanZVVEdQNkNUejJIYkQ4In0.QBzNQNvJZQPZZnzmbU8K5Liz0piHwercrDIq3kirUJk";
-
-    @PostMapping("/queryVenue")
-    public Result<Void> queryVenue() {
-        venueService.queryVenueService();
-        return Result.success();
-    }
-
-    @PostMapping("/getTomorrowVenue")
-    public Result<SitePositionList> getTomorrowVenue() {
-        List<SitePositionList> sitePositionLists = venueService.queryTomorrowVenue();
-        return Result.success(sitePositionLists);
-    }
-
-    @PostMapping("addSubscribe")
-    public Result<Void> addSubscribe() {
-        List<VenueInfoDO> venueInfoDOS = venueService.queryCanBuyVenue();
-        if (CollectionUtils.isEmpty(venueInfoDOS)) {
-            return Result.error("暂无可订购的数据");
-        }
-        jntyzxHttpService.createOrder(venueInfoDOS);
-        return Result.success();
-    }
-
-
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/dto/VenueListDTO.java

@@ -1,34 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.dto;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 13:55
- */
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class VenueListDTO {
-    /**
-     * 时间
-     */
-    private String date;
-
-    /**
-     * 时间
-     */
-    private String sjName;
-
-    /**
-     * 场地名称
-     */
-    private String placeName;
-
-    /**
-     * 联系人
-     */
-    private String contacts;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/pojo/UserTokenInfoDO.java

@@ -1,37 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.pojo;
-
-import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-16 09:18
- */
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-@TableName("jntyzx_user_token_info")
-public class UserTokenInfoDO {
-    private Long id;
-    /**
-     * 用户名
-     */
-    private String name;
-
-    /**
-     * token
-     */
-    private String token;
-
-    /**
-     * wx openid
-     */
-    private String openId;
-
-    /**
-     * 状态(0:禁用 1:启用)
-     */
-    private Integer status;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/pojo/VenueInfoDO.java

@@ -1,72 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.pojo;
-
-import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.math.BigDecimal;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 15:48
- */
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-@TableName("jntyzx_venue_info")
-public class VenueInfoDO {
-    private Long id;
-    /**
-     * 场地名称
-     */
-    private String placeName;
-
-    /**
-     * 所属日期
-     */
-    private LocalDate date;
-
-    /**
-     * 场地信息三方主键
-     */
-    private Long placeMainId;
-
-    /**
-     * 场地id
-     */
-    private Integer placeId;
-
-    /**
-     *
-     */
-    private Integer scheduleId;
-
-    /**
-     * 时间范围
-     */
-    private String sjName;
-
-    /**
-     * 创建时间
-     */
-    private LocalDateTime createTime;
-
-    /**
-     * 联系人
-     */
-    private String contacts;
-
-    /**
-     * 状态
-     */
-    private Integer type;
-
-    private BigDecimal money;
-    private String className;
-    private String classCode;
-    private String appointments;
-    private String cTypeCode;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/req/SubscribeRequest.java

@@ -1,23 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.req;
-
-import com.alibaba.fastjson2.JSONObject;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 16:34
- */
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class SubscribeRequest {
-    private JSONObject jsonObject;
-    private List<SubscribeVo> subscribeVos;
-    private String bookTime;
-    private Integer paymentMethod;
-    private String svCiphertext;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/req/SubscribeVo.java

@@ -1,60 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.req;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.math.BigDecimal;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 16:35
- */
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class SubscribeVo {
-    private int id;
-
-    private String ballCourtId;
-
-    private String sjName;
-
-    private String scheduleId;
-
-    private String placeName;
-
-    private int placeId;
-
-    private String type;
-
-    private String className;
-
-    private String classCode;
-
-    private BigDecimal money;
-
-    private String contacts;
-
-    private String contactNumber;
-
-    private String memberNumber;
-
-    private String appointments;
-
-    private String operator;
-
-    private String endTime;
-
-    private String beginTime;
-
-    private int specOneTimes;
-
-    private String ctypeCode;
-
-    private int isWhole;
-
-    private String orderId;
-
-    private int votesnum;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/JntyzxResponse.java

@@ -1,20 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.resp;
-
-import lombok.Data;
-
-/**
- * @Author: xiang
- * @Date: 2025-05-14 14:38
- */
-@Data
-public class JntyzxResponse<T> {
-    private Boolean success;
-
-    private String message;
-
-    private Integer code;
-
-    private T result;
-
-    private Long timestamp;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/query/QueryVenueResponse.java

@@ -1,16 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.resp.query;
-
-import lombok.Data;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-05-14 14:37
- */
-@Data
-public class QueryVenueResponse {
-    private List<TimeList> timeList;
-
-    private List<VenueList> venue;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/query/SitePositionList.java

@@ -1,56 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.resp.query;
-
-import lombok.Data;
-
-import java.math.BigDecimal;
-
-/**
- * @Author: xiang
- * @Date: 2025-05-14 14:45
- */
-@Data
-public class SitePositionList {
-    private Long id;
-
-    private String ballCourtId;
-
-    private String sjName;
-
-    private String scheduleId;
-
-    private String placeName;
-
-    private Integer placeId;
-
-    private Integer type;
-
-    private String className;
-
-    private String classCode;
-
-    private BigDecimal money;
-
-    private String contacts;
-
-    private String contactNumber;
-
-    private String memberNumber;
-
-    private String appointments;
-
-    private String operator;
-
-    private String endTime;
-
-    private String beginTime;
-
-    private Integer specOneTimes;
-
-    private String ctypeCode;
-
-    private String isWhole;
-
-    private Long orderId;
-
-    private Integer votesnum;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/query/TimeList.java

@@ -1,32 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.resp.query;
-
-import lombok.Data;
-
-/**
- * @Author: xiang
- * @Date: 2025-05-14 14:39
- */
-@Data
-public class TimeList {
-    private Long id;
-    private String name;
-
-    private String beginTime;
-
-    private String endTime;
-
-    private String type;
-
-    private String isenable;
-
-    private String operator;
-
-    private String createtime;
-
-    private String remarks;
-
-    private String default01;
-    private String default02;
-    private String default03;
-    private String votesnum;
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/query/VenueList.java

@@ -1,20 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.entity.resp.query;
-
-import lombok.Data;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-05-14 14:39
- */
-@Data
-public class VenueList {
-
-    private Integer placeId;
-
-    private String placeName;
-
-    private List<SitePositionList> sitePosition;
-
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/IUserTokenInfoManage.java

@@ -1,16 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.manage;
-
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.UserTokenInfoDO;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-16 09:19
- */
-public interface IUserTokenInfoManage extends IService<UserTokenInfoDO>  {
-
-    List<UserTokenInfoDO> listUser();
-    UserTokenInfoDO getByName(String name);
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/IVenueInfoManage.java

@@ -1,18 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.manage;
-
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-
-import java.time.LocalDate;
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 15:50
- */
-public interface IVenueInfoManage extends IService<VenueInfoDO>  {
-
-    List<VenueInfoDO> queryByDate(LocalDate date);
-
-    List<VenueInfoDO> queryByType(LocalDate date, Integer type);
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/UserTokenInfoManageImpl.java

@@ -1,32 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.manage;
-
-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.xservice.application.script.jntyzx.entity.pojo.UserTokenInfoDO;
-import com.xiang.xservice.application.script.jntyzx.mapper.JntyzxUserTokenInfoMapper;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-16 09:19
- */
-@Service
-public class UserTokenInfoManageImpl extends ServiceImpl<JntyzxUserTokenInfoMapper, UserTokenInfoDO> implements IUserTokenInfoManage {
-    @Override
-    public List<UserTokenInfoDO> listUser() {
-        LambdaQueryWrapper<UserTokenInfoDO> lambdaQueryWrapper = Wrappers.lambdaQuery();
-        lambdaQueryWrapper.eq(UserTokenInfoDO::getStatus, 1);
-        return baseMapper.selectList(lambdaQueryWrapper);
-    }
-
-    @Override
-    public UserTokenInfoDO getByName(String name) {
-        LambdaQueryWrapper<UserTokenInfoDO> lambdaQueryWrapper = Wrappers.lambdaQuery();
-        lambdaQueryWrapper.eq(UserTokenInfoDO::getStatus, 1);
-        lambdaQueryWrapper.eq(UserTokenInfoDO::getName, name);
-        return baseMapper.selectOne(lambdaQueryWrapper);
-    }
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/VenueInfoManageImpl.java

@@ -1,33 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.manage;
-
-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.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import com.xiang.xservice.application.script.jntyzx.mapper.JntyzxVenueInfoMapper;
-import org.springframework.stereotype.Service;
-
-import java.time.LocalDate;
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 15:51
- */
-@Service
-public class VenueInfoManageImpl extends ServiceImpl<JntyzxVenueInfoMapper, VenueInfoDO> implements IVenueInfoManage {
-
-    public List<VenueInfoDO> queryByDate(LocalDate now) {
-        LambdaQueryWrapper<VenueInfoDO> lqw = Wrappers.lambdaQuery();
-        lqw.eq(VenueInfoDO::getDate, now);
-        return baseMapper.selectList(lqw);
-    }
-
-    @Override
-    public List<VenueInfoDO> queryByType(LocalDate date, Integer type) {
-        LambdaQueryWrapper<VenueInfoDO> lqw = Wrappers.lambdaQuery();
-        lqw.eq(VenueInfoDO::getDate, date);
-        lqw.eq(VenueInfoDO::getType, type);
-        return baseMapper.selectList(lqw);
-    }
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/mapper/JntyzxUserTokenInfoMapper.java

@@ -1,15 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.mapper;
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.UserTokenInfoDO;
-import org.apache.ibatis.annotations.Mapper;
-import org.springframework.stereotype.Repository;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-16 09:18
- */
-@Mapper
-@Repository
-public interface JntyzxUserTokenInfoMapper extends BaseMapper<UserTokenInfoDO> {
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/mapper/JntyzxVenueInfoMapper.java

@@ -1,15 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.mapper;
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import org.apache.ibatis.annotations.Mapper;
-import org.springframework.stereotype.Repository;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 15:48
- */
-@Mapper
-@Repository
-public interface JntyzxVenueInfoMapper extends BaseMapper<VenueInfoDO> {
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/JtTokenHealthSchedule.java

@@ -1,21 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.schedule;
-
-import com.xiang.xservice.application.script.jntyzx.service.IUserTokenInfoService;
-import lombok.RequiredArgsConstructor;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-16 09:15
- */
-@Component
-@RequiredArgsConstructor
-public class JtTokenHealthSchedule {
-
-    private final IUserTokenInfoService userTokenInfoService;
-    @Scheduled(cron = "0 30 0/2 * * ?")
-    public void flushToken() {
-        userTokenInfoService.flushToken();
-    }
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenuePeekSchedule.java

@@ -1,33 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.schedule;
-
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import com.xiang.xservice.application.script.jntyzx.service.IVenueService;
-import lombok.RequiredArgsConstructor;
-import org.apache.commons.collections4.CollectionUtils;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 16:12
- */
-@Component
-@RequiredArgsConstructor
-public class VenuePeekSchedule {
-
-    private final IVenueService venueService;
-
-    @Scheduled(cron = "5 1 9-20 * * ?")
-    public void peek() {
-        List<VenueInfoDO> venueInfoDOS = venueService.queryCanBuyVenue();
-        if (CollectionUtils.isEmpty(venueInfoDOS)) {
-            return;
-        }
-
-        venueInfoDOS.parallelStream().forEach(item -> {
-            // 请求接口创建订单不支付
-        });
-    }
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenueQuerySchedule.java

@@ -1,150 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.schedule;
-
-import com.google.common.collect.Maps;
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.SitePositionList;
-import com.xiang.xservice.application.script.jntyzx.service.DingTalkScriptVenueService;
-import com.xiang.xservice.application.script.jntyzx.service.IVenueService;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 15:02
- */
-@Slf4j
-@Component
-@RequiredArgsConstructor
-public class VenueQuerySchedule {
-
-    private final IVenueService venueService;
-    private final DingTalkScriptVenueService dingTalkScriptVenueService;
-
-    @Scheduled(cron = "0 30 8 * * ?")
-    public void venueQueryTask() {
-        log.info("每日8:30拉取江体小程序数据定时任务");
-        List<SitePositionList> sitePositionLists = venueService.queryVenueService();
-        // 6-8场地
-        Map<String, List<SitePositionList>> map1 = Maps.newLinkedHashMap();
-        // 8-10场地
-        Map<String, List<SitePositionList>> map2 = Maps.newLinkedHashMap();
-        sitePositionLists.stream()
-                .filter(item -> StringUtils.equals(item.getSjName(), "18:00-19:00") || StringUtils.equals(item.getSjName(), "19:00-20:00")
-                        || StringUtils.equals(item.getSjName(), "20:00-21:00") || StringUtils.equals(item.getSjName(), "21:00-22:00"))
-                .forEach(item -> {
-                    if (StringUtils.equals(item.getSjName(), "18:00-19:00")) {
-                        putIntoMap(item, map1);
-                    }
-                    if (StringUtils.equals(item.getSjName(), "19:00-20:00")) {
-                        putIntoMap(item, map1);
-                    }
-                    if (StringUtils.equals(item.getSjName(), "20:00-21:00")) {
-                        putIntoMap(item, map2);
-                    }
-                    if (StringUtils.equals(item.getSjName(), "21:00-22:00")) {
-                        putIntoMap(item, map2);
-                    }
-                });
-        StringBuffer sb1 = new StringBuffer("查询江体小程序场地信息【18:00-20:00】\n");
-        buildMsg2(map1, sb1);
-        StringBuffer sb2 = new StringBuffer("查询江体小程序场地信息【20:00-22:00】\n");
-        buildMsg2(map2, sb2);
-        dingTalkScriptVenueService.sendScriptMsg(sb1.toString());
-        dingTalkScriptVenueService.sendScriptMsg(sb2.toString());
-    }
-
-    @Scheduled(cron = "0 0/10 9-15 * * ?")
-    public void venueQueryTask4Free() {
-        log.info("每日空闲时刻拉取江体小程序数据定时任务");
-        venueService.queryVenueService();
-    }
-
-    @Scheduled(cron = "1 0/5 15-17 * * ?")
-    public void venueQueryTask4Normal() {
-        log.info("每日正常时刻拉取江体小程序数据定时任务");
-        venueService.queryVenueService();
-    }
-
-    @Scheduled(cron = "2 0/2 17-20 * * ?")
-    public void venueQueryTask4Urgency() {
-        log.info("每日紧急时刻时刻拉取江体小程序数据定时任务");
-        venueService.queryVenueService();
-    }
-
-    @Scheduled(cron = "0 0/1 9-20 * * ?")
-    public void venueCanBuyMsg() {
-        List<VenueInfoDO> venueInfoDOS = venueService.queryCanBuyVenue();
-        if (CollectionUtils.isEmpty(venueInfoDOS)) {
-            return;
-        }
-        // 6-8场地
-        Map<String, List<VenueInfoDO>> map1 = Maps.newLinkedHashMap();
-        // 8-10场地
-        Map<String, List<VenueInfoDO>> map2 = Maps.newLinkedHashMap();
-        venueInfoDOS.stream()
-                .filter(item -> StringUtils.equals(item.getSjName(), "18:00-19:00") || StringUtils.equals(item.getSjName(), "19:00-20:00")
-                        || StringUtils.equals(item.getSjName(), "20:00-21:00") || StringUtils.equals(item.getSjName(), "21:00-22:00"))
-                .forEach(item -> {
-                    if (StringUtils.equals(item.getSjName(), "18:00-19:00")) {
-                        putIntoMap(item, map1);
-                    }
-                    if (StringUtils.equals(item.getSjName(), "19:00-20:00")) {
-                        putIntoMap(item, map1);
-                    }
-                    if (StringUtils.equals(item.getSjName(), "20:00-21:00")) {
-                        putIntoMap(item, map2);
-                    }
-                    if (StringUtils.equals(item.getSjName(), "21:00-22:00")) {
-                        putIntoMap(item, map2);
-                    }
-                });
-        StringBuffer sb1 = new StringBuffer("查询江体小程序场地信息【18:00-20:00】\n");
-        buildMsg(map1, sb1);
-        StringBuffer sb2 = new StringBuffer("查询江体小程序场地信息【20:00-22:00】\n");
-        buildMsg(map2, sb2);
-        dingTalkScriptVenueService.sendScriptMsg(sb1.toString());
-        dingTalkScriptVenueService.sendScriptMsg(sb2.toString());
-    }
-
-    private static void buildMsg(Map<String, List<VenueInfoDO>> map1, StringBuffer sb1) {
-        map1.forEach((k, v) -> {
-            VenueInfoDO sitePositionList1 = v.get(0);
-            VenueInfoDO sitePositionList2 = v.get(1);
-            String contacts = sitePositionList1.getContacts();
-            if (!StringUtils.equals(sitePositionList1.getContacts(), sitePositionList2.getContacts())) {
-                contacts = sitePositionList1.getContacts() + "，" + sitePositionList2.getContacts();
-            }
-            sb1.append(k).append("场地，订购人：").append(contacts).append("\n");
-        });
-    }
-    private static void buildMsg2(Map<String, List<SitePositionList>> map1, StringBuffer sb1) {
-        map1.forEach((k, v) -> {
-            SitePositionList sitePositionList1 = v.get(0);
-            SitePositionList sitePositionList2 = v.get(1);
-            String contacts = sitePositionList1.getContacts();
-            if (!StringUtils.equals(sitePositionList1.getContacts(), sitePositionList2.getContacts())) {
-                contacts = sitePositionList1.getContacts() + "，" + sitePositionList2.getContacts();
-            }
-            sb1.append(k).append("场地，订购人：").append(contacts).append("\n");
-        });
-    }
-
-    private static void putIntoMap(VenueInfoDO item, Map<String, List<VenueInfoDO>> map1) {
-        map1.computeIfAbsent(item.getPlaceName(),
-                k -> new ArrayList<>()
-        ).add(item);
-    }
-    private static void putIntoMap(SitePositionList item, Map<String, List<SitePositionList>> map1) {
-        map1.computeIfAbsent(item.getPlaceName(),
-                k -> new ArrayList<>()
-        ).add(item);
-    }
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/DingTalkScriptVenueService.java

@@ -1,33 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-import com.xiang.xmc.service.message.dingTalk.service.DingTalkService;
-import com.xiang.xservice.config.DingTalkRobotVenueConfig;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-/**
- * @Author: xiang
- * @Date: 2025-08-07 10:30
- */
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class DingTalkScriptVenueService {
-
-    private final DingTalkService dingTalkService;
-    private final DingTalkRobotVenueConfig dingTalkRobotVenueConfig;
-
-    /**
-     * 发送脚本消息
-     * @param msg   消息
-     */
-    public void sendScriptMsg(String msg) {
-        try {
-            dingTalkService.sendRobotMessage(dingTalkRobotVenueConfig.getSecret(), dingTalkRobotVenueConfig.getToken(),
-                    dingTalkRobotVenueConfig.getUsers(), msg);
-        } catch (Exception e) {
-            log.error("信息发送异常, 信息：{}", msg, e);
-        }
-    }
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/IJntyzxHttpService.java

@@ -1,35 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.JntyzxResponse;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.SitePositionList;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 14:47
- */
-public interface IJntyzxHttpService {
-
-    /**
-     * 查询今日可用场地
-     */
-    List<SitePositionList> queryAvailable(String isWeekend, String token);
-    List<SitePositionList> queryAvailableTomorrow(String isWeekend, String token);
-
-    /**
-     * 订单创建
-     * @return
-     */
-    Boolean createOrder(List<VenueInfoDO> venueInfos);
-
-    /**
-     * 心跳监测
-     * @param token     token
-     * @param openId    openid
-     * @return
-     */
-    JntyzxResponse<Void> healthDeclaration(String token, String openId);
-
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/IUserTokenInfoService.java

@@ -1,11 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-16 09:22
- */
-public interface IUserTokenInfoService {
-
-    boolean flushSingleToken(String name);
-    boolean flushToken();
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/IVenueService.java

@@ -1,18 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.SitePositionList;
-
-import java.util.List;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 16:07
- */
-public interface IVenueService {
-
-    List<SitePositionList> queryVenueService();
-    List<SitePositionList> queryTomorrowVenue();
-
-    List<VenueInfoDO> queryCanBuyVenue();
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxHttpServiceImpl.java

@@ -1,179 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-import com.alibaba.fastjson2.JSON;
-import com.alibaba.fastjson2.JSONObject;
-import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
-import com.xiang.xmc.service.http.helper.HttpHelper;
-import com.xiang.xservice.application.script.jntyzx.constants.UrlConstant;
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import com.xiang.xservice.application.script.jntyzx.entity.req.SubscribeRequest;
-import com.xiang.xservice.application.script.jntyzx.entity.req.SubscribeVo;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.JntyzxResponse;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.SitePositionList;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.VenueList;
-import com.xiang.xservice.basic.utils.Base64;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.jetbrains.annotations.NotNull;
-import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
-
-import java.nio.charset.StandardCharsets;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-
-/**
- * @Author: xiang
- * @Date: 2025-05-14 14:07
- */
-@Service
-@RequiredArgsConstructor
-@Slf4j
-public class JntyzxHttpServiceImpl implements IJntyzxHttpService {
-
-    @Override
-    public List<SitePositionList> queryAvailable(String isWeekend, String token) {
-        String url = UrlConstant.QUERY_TODAY_SUBSCRIBE_URL;
-        return querySitePositionInfo(isWeekend, token, url);
-    }
-
-    @NotNull
-    private static List<SitePositionList> querySitePositionInfo(String isWeekend, String token, String url) {
-        Map<String, String> header = Maps.newHashMap();
-        header.put("X-Access-Token", token);
-        String resp = null;
-        Map<String, String> params = Maps.newHashMap();
-        params.put("gid", "03");
-        params.put("isWeekend", isWeekend);
-        try {
-            resp = HttpHelper.doGet(url, header, params);
-        } catch (Exception e) {
-            log.error("[doGet] 江南体育中心查询当天场地 请求失败, url:{}", url);
-            return Lists.newArrayList();
-        }
-        if (StringUtils.isEmpty(resp)) {
-            log.warn("[查询场地] 江南体育中心查询当天场地 请求结果为空, url:{}, resp:{}", url, resp);
-            return Lists.newArrayList();
-        }
-        JSONObject jsonObject = JSON.parseObject(resp);
-        if (Objects.isNull(jsonObject)) {
-            return Lists.newArrayList();
-        }
-        String resultStr = JSON.toJSONString(jsonObject.get("result"));
-        if (StringUtils.isBlank(resultStr)) {
-            return Lists.newArrayList();
-        }
-        JSONObject result = JSON.parseObject(resultStr);
-        if (Objects.isNull(result)) {
-            return Lists.newArrayList();
-        }
-        String venueStr = JSON.toJSONString(result.get("venue"));
-        if (StringUtils.isBlank(venueStr)) {
-            return Lists.newArrayList();
-        }
-        List<VenueList> venueLists = JSON.parseArray(venueStr, VenueList.class);
-        if (CollectionUtils.isEmpty(venueLists)) {
-            return Lists.newArrayList();
-        }
-        List<SitePositionList> res = Lists.newArrayList();
-        for (VenueList venueList : venueLists) {
-            List<SitePositionList> sitePositionList = venueList.getSitePosition();
-            if (CollectionUtils.isEmpty(sitePositionList)) {
-                continue;
-            }
-            res.addAll(sitePositionList);
-        }
-        return res;
-    }
-
-    @Override
-    public List<SitePositionList> queryAvailableTomorrow(String isWeekend, String token) {
-        String url = UrlConstant.QUERY_TOMORROW_SUBSCRIBE_URL;
-        return querySitePositionInfo(isWeekend, token, url);
-    }
-
-    @Override
-    public Boolean createOrder(List<VenueInfoDO> venueInfos) {
-
-        List<SubscribeVo> vos = Lists.newArrayList();
-        for (VenueInfoDO venueInfo : venueInfos) {
-            SubscribeVo subscribeVo = new SubscribeVo();
-            subscribeVo.setId(0);
-            subscribeVo.setBallCourtId("03");
-            subscribeVo.setSjName(venueInfo.getSjName());
-            subscribeVo.setScheduleId(String.valueOf(venueInfo.getScheduleId()));
-            subscribeVo.setPlaceName(venueInfo.getPlaceName());
-            subscribeVo.setPlaceId(venueInfo.getPlaceId());
-            subscribeVo.setType("0");
-            subscribeVo.setClassName(venueInfo.getClassName());
-            subscribeVo.setClassCode(venueInfo.getClassCode());
-            subscribeVo.setMoney(venueInfo.getMoney());
-            subscribeVo.setContacts("0");
-            subscribeVo.setContactNumber(null);
-            subscribeVo.setMemberNumber(null);
-            subscribeVo.setAppointments(venueInfo.getAppointments());
-            subscribeVo.setOperator(null);
-            subscribeVo.setEndTime(null);
-            subscribeVo.setBeginTime(null);
-            subscribeVo.setSpecOneTimes(3);
-            subscribeVo.setCtypeCode(venueInfo.getCTypeCode());
-            subscribeVo.setIsWhole(0);
-            subscribeVo.setOrderId(null);
-            subscribeVo.setVotesnum(1);
-            vos.add(subscribeVo);
-        }
-
-        JSONObject jsonObject = buildParamJsonObj();
-        SubscribeRequest subscribeRequest = new SubscribeRequest();
-
-        subscribeRequest.setSubscribeVos(vos);
-        subscribeRequest.setBookTime(venueInfos.get(0).getAppointments());
-        subscribeRequest.setPaymentMethod(1);
-        subscribeRequest.setSvCiphertext(Base64.encode(JSON.toJSONString(vos).getBytes(StandardCharsets.UTF_8)));
-        subscribeRequest.setJsonObject(jsonObject);
-
-        Map<String, String> params = Maps.newHashMap();
-        params.put("X-Access-Token", "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJleHAiOjE3NjU3ODQ1NjMsInVzZXJuYW1lIjoid3hfb3Blbl9pZF9vMjFNWDR5N3doWENHanZVVEdQNkNUejJIYkQ4In0.QBzNQNvJZQPZZnzmbU8K5Liz0piHwercrDIq3kirUJk");
-        String resp = HttpHelper.doPost(UrlConstant.ADD_SUBSCRIBE, params, JSONObject.toJSONString(subscribeRequest));
-        return null;
-    }
-
-    @Override
-    public JntyzxResponse<Void> healthDeclaration(String token, String openId) {
-        Map<String, String> headers = Maps.newHashMap();
-        headers.put("X-Access-Token", token);
-        Map<String, String> params = Maps.newHashMap();
-        params.put("openId", openId);
-
-        String respStr = HttpHelper.doGet(UrlConstant.HEALTH_DECLARATION, headers, params);
-        if (StringUtils.isBlank(respStr)) {
-            return null;
-        }
-        JntyzxResponse jntyzxResponse = JSON.parseObject(respStr, JntyzxResponse.class);
-        return jntyzxResponse;
-    }
-
-    private static JSONObject buildParamJsonObj() {
-        JSONObject jsonObject = new JSONObject();
-        jsonObject.put("id", "1702581215097257986");
-        jsonObject.put("createBy", null);
-        jsonObject.put("createTime", "2023-09-15 15:12:48");
-        jsonObject.put("updateBy", null);
-        jsonObject.put("updateTime", null);
-        jsonObject.put("sysOrgCode", null);
-        jsonObject.put("openId", "o21MX4y7whXCGjvUTGP6CTz2HbD8");
-        jsonObject.put("nickName", "1");
-        jsonObject.put("unionId", null);
-        jsonObject.put("avatarUrl", "https://thirdwx.qlogo.cn/mmopen/vi_32/POgEwh4mIHO4nibH0KlMECNjjGxQUq24ZEaGT4poC6icRiccVGKSyXwibcPq4BWmiaIGuG1icwxaQX6grC9VemZoJ8rg/132");
-        jsonObject.put("remarks", null);
-        jsonObject.put("default01", null);
-        jsonObject.put("default02", null);
-        jsonObject.put("default03", null);
-        jsonObject.put("default04", null);
-        jsonObject.put("default05", null);
-        return jsonObject;
-    }
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/UserTokenInfoServiceImpl.java

@@ -1,64 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.UserTokenInfoDO;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.JntyzxResponse;
-import com.xiang.xservice.application.script.jntyzx.manage.IUserTokenInfoManage;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-import java.util.Objects;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-16 09:22
- */
-@Service
-@Slf4j
-@RequiredArgsConstructor
-public class UserTokenInfoServiceImpl implements IUserTokenInfoService {
-
-    private final IUserTokenInfoManage userTokenInfoManage;
-    private final IJntyzxHttpService jntyzxHttpService;
-    private final DingTalkScriptVenueService dingTalkScriptVenueService;
-
-
-    @Override
-    public boolean flushSingleToken(String name) {
-        UserTokenInfoDO userTokenInfoDO = userTokenInfoManage.getByName(name);
-        if (Objects.isNull(userTokenInfoDO)) {
-            log.info("用户信息不存在，无需进行监测!");
-            return false;
-        }
-        return healthDeclaration(userTokenInfoDO);
-
-    }
-
-    @Override
-    public boolean flushToken() {
-        List<UserTokenInfoDO> userTokenInfoDOS = userTokenInfoManage.listUser();
-        if (CollectionUtils.isEmpty(userTokenInfoDOS)) {
-            log.info("【心跳监测】查询用户信息为空，无需操作");
-            return true;
-        }
-        userTokenInfoDOS.parallelStream().forEach(this::healthDeclaration);
-        return true;
-    }
-
-    private boolean healthDeclaration(UserTokenInfoDO userTokenInfoDO) {
-        JntyzxResponse<Void> jntyzxResponse = jntyzxHttpService.healthDeclaration(userTokenInfoDO.getToken(), userTokenInfoDO.getOpenId());
-        if (Objects.isNull(jntyzxResponse)) {
-            log.info("用户名:{}心跳监测失败！", userTokenInfoDO.getName());
-        }
-        boolean flag = StringUtils.contains(jntyzxResponse.getMessage(), "已存在");
-        if (flag) {
-            log.info("用户名:{}心跳成功✅✅✅✅✅✅", userTokenInfoDO.getName());
-        } else {
-            dingTalkScriptVenueService.sendScriptMsg("用户名:" + userTokenInfoDO.getName() + "心跳失败，消息:" + jntyzxResponse.getMessage());
-        }
-        return flag;
-    }
-}

script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/VenueServiceImpl.java

@@ -1,98 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
-import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.SitePositionList;
-import com.xiang.xservice.application.script.jntyzx.manage.IVenueInfoManage;
-import com.xiang.xservice.basic.utils.DateUtils;
-import lombok.RequiredArgsConstructor;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.stereotype.Service;
-
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.function.Function;
-import java.util.stream.Collectors;
-
-/**
- * @Author: xiang
- * @Date: 2025-12-15 16:08
- */
-@Service
-@RequiredArgsConstructor
-public class VenueServiceImpl implements IVenueService {
-
-    private final static String STATIC_TOKEN = "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJleHAiOjE3NjU4NTI4MjYsInVzZXJuYW1lIjoid3hfb3Blbl9pZF9vMjFNWDR5N3doWENHanZVVEdQNkNUejJIYkQ4In0.pI1tK1imZdKZWXdHRxseqq87_IarHhiRt-hUdBq8hkg";
-    private final IJntyzxHttpService jntyzxHttpService;
-    private final IVenueInfoManage venueInfoManage;
-
-    @Override
-    public List<SitePositionList> queryVenueService() {
-        List<SitePositionList> sitePositionLists = jntyzxHttpService.queryAvailable("1", STATIC_TOKEN);
-        if (CollectionUtils.isEmpty(sitePositionLists)) {
-            return Lists.newArrayList();
-        }
-        updateDatabase(sitePositionLists);
-        return sitePositionLists;
-    }
-
-    public List<SitePositionList> queryTomorrowVenue() {
-        List<SitePositionList> sitePositionLists = jntyzxHttpService.queryAvailableTomorrow("1", STATIC_TOKEN);
-        if (CollectionUtils.isEmpty(sitePositionLists)) {
-            return Lists.newArrayList();
-        }
-        updateDatabase(sitePositionLists);
-        return sitePositionLists;
-    }
-
-    @Override
-    public List<VenueInfoDO> queryCanBuyVenue() {
-        return venueInfoManage.queryByType(LocalDate.now(), 0);
-    }
-
-    private void updateDatabase(List<SitePositionList> list) {
-        List<VenueInfoDO> venueInfoDOS = venueInfoManage.queryByDate(LocalDate.now());
-        Map<Long, VenueInfoDO> map = Maps.newHashMap();
-        if (CollectionUtils.isNotEmpty(venueInfoDOS)) {
-            map.putAll(venueInfoDOS.stream().filter(Objects::nonNull).collect(Collectors.toMap(VenueInfoDO::getPlaceMainId, Function.identity(), (a, b) -> a)));
-        }
-        List<VenueInfoDO> insertList = Lists.newArrayList();
-        for (SitePositionList sitePositionList : list) {
-            if (map.containsKey(sitePositionList.getId())) {
-                VenueInfoDO venueInfoDO = map.get(sitePositionList.getId());
-                if (!StringUtils.equals(venueInfoDO.getContacts(), sitePositionList.getContacts())
-                        || !Objects.equals(venueInfoDO.getType(), sitePositionList.getType())) {
-                    venueInfoDO.setContacts(sitePositionList.getContacts());
-                    venueInfoDO.setType(sitePositionList.getType());
-                    venueInfoDO.setPlaceMainId(sitePositionList.getId());
-                    venueInfoManage.updateById(venueInfoDO);
-                }
-            } else {
-                VenueInfoDO venueInfoDO = new VenueInfoDO();
-                venueInfoDO.setPlaceName(sitePositionList.getPlaceName());
-                venueInfoDO.setDate(DateUtils.getDateFromStr(sitePositionList.getAppointments()));
-                venueInfoDO.setPlaceMainId(sitePositionList.getId());
-                venueInfoDO.setPlaceId(sitePositionList.getPlaceId());
-                venueInfoDO.setScheduleId(Integer.valueOf(sitePositionList.getScheduleId()));
-                venueInfoDO.setSjName(sitePositionList.getSjName());
-                venueInfoDO.setCreateTime(LocalDateTime.now());
-                venueInfoDO.setContacts(sitePositionList.getContacts());
-                venueInfoDO.setType(sitePositionList.getType());
-                venueInfoDO.setMoney(sitePositionList.getMoney());
-                venueInfoDO.setClassName(sitePositionList.getClassName());
-                venueInfoDO.setClassCode(sitePositionList.getClassCode());
-                venueInfoDO.setAppointments(sitePositionList.getAppointments());
-                venueInfoDO.setCTypeCode(sitePositionList.getCtypeCode());
-                insertList.add(venueInfoDO);
-            }
-        }
-        if (CollectionUtils.isNotEmpty(insertList)) {
-            venueInfoManage.saveBatch(insertList);
-        }
-    }
-}

script/src/main/java/com/xiang/xservice/common/service/ISysConfigService.java

@@ -0,0 +1,12 @@
+package com.xiang.xservice.common.service;
+
+import com.xiang.xservice.common.entity.SysConfigDO;
+
+/**
+ * @Author: xiang
+ * @Date: 2025-12-16 11:19
+ */
+public interface ISysConfigService {
+
+    SysConfigDO getByName(String name);
+}

script/src/main/java/com/xiang/xservice/common/service/SysConfigServiceImpl.java

@@ -0,0 +1,20 @@
+package com.xiang.xservice.common.service;
+
+import com.xiang.xservice.common.entity.SysConfigDO;
+import com.xiang.xservice.common.mapper.SysConfigMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Author: xiang
+ * @Date: 2025-12-16 11:20
+ */
+@Service
+@RequiredArgsConstructor
+public class SysConfigServiceImpl implements ISysConfigService {
+    private final SysConfigMapper sysConfigMapper;
+    @Override
+    public SysConfigDO getByName(String name) {
+        return sysConfigMapper.getByName(name);
+    }
+}

script/src/main/resources/application-prod.yml

@@ -53,3 +53,8 @@ dingtalk:
       secret: SECe10ade3058880b84df5c6f46ab072c11f4ac2a5ef9f134d684705c2a3b004de2
       users:
         - 450841600726084717
+    venue:
+      token: 6a218646972c684c75832b0229ea93a234778af537d7469ce96bef290faf530e
+      secret: SEC9018755ba86d3e5c1ed2fbfa1d6953d84bb2a6c8ebe7ed4e318457bfed5e0465
+      users:
+        - 450841600726084717