fix:glados签到脚本

fix:glados签到球服
fix:glados域名修复
2026-01-23 09:58:46 +08:00 · 2026-01-23 09:35:38 +08:00 · 2026-01-23 09:06:17 +08:00 · 2026-01-15 23:34:26 +08:00 · 2025-12-18 19:21:42 +08:00 · 2025-12-18 10:30:45 +08:00
74 changed files with 606 additions and 1567 deletions
--- a/pom.xml
+++ b/pom.xml
@@ -29,33 +29,38 @@
    <dependencies>
        <dependency>
            <groupId>com.xiang</groupId>
-            <artifactId>xservice-common</artifactId>
-            <version>2.0</version>
+            <artifactId>xmc-mysql-starter</artifactId>
+            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.xiang</groupId>
-            <artifactId>xservice-message-starter</artifactId>
-            <version>2.0</version>
+            <artifactId>xmc-cache-starter</artifactId>
+            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.xiang</groupId>
-            <artifactId>xservice-schedule-starter</artifactId>
-            <version>2.0</version>
+            <artifactId>xmc-common</artifactId>
+            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.xiang</groupId>
-            <artifactId>xservice-cache-starter</artifactId>
-            <version>2.0</version>
+            <artifactId>xmc-message-starter</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>com.xiang.starter</groupId>
+            <artifactId>xmc-http-starter</artifactId>
+            <version>2.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.xiang</groupId>
-            <artifactId>xservice-http-starter</artifactId>
-            <version>2.0</version>
+            <artifactId>xmc-logger-starter</artifactId>
+            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.xiang</groupId>
-            <artifactId>xservice-mysql-starter</artifactId>
-            <version>2.0</version>
+            <artifactId>xmc-schedule-starter</artifactId>
+            <version>1.0-SNAPSHOT</version>
        </dependency>

    </dependencies>
--- a/script/src/main/java/com/xiang/ServiceScriptApplication.java
+++ b/script/src/main/java/com/xiang/ServiceScriptApplication.java
@@ -16,8 +16,7 @@ import org.springframework.scheduling.annotation.EnableScheduling;
        "com.xiang.xservice.application.script.fwd.mapper",
        "com.xiang.xservice.application.script.glados.repository",
        "com.xiang.xservice.application.script.xb.repository",
-        "com.xiang.xservice.application.script.stock.gnshyx.mapper",
-        "com.xiang.xservice.application.script.stock.data.mapper",
+        "com.xiang.xservice.common.mapper",
 })
@ConfigurationPropertiesScan(basePackages = {
        "com.xiang.xservice.config"
--- a/script/src/main/java/com/xiang/xservice/application/script/domain/schedule/DynamicDomainSchedule.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/domain/schedule/DynamicDomainSchedule.java
@@ -19,7 +19,7 @@ public class DynamicDomainSchedule {

    private final IDomainService IDomainService;

-    @Scheduled(cron = "0 0/5 * * * ? ")
+    @Scheduled(cron = "0 0/30 * * * ? ")
    public void dynamicDomainSchedule() {
        String publicIp = "";
        try {
--- a/script/src/main/java/com/xiang/xservice/application/script/domain/service/DingTalkScriptDomainService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/domain/service/DingTalkScriptDomainService.java
@@ -1,6 +1,6 @@
 package com.xiang.xservice.application.script.domain.service;

-import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService;
+import com.xiang.xmc.service.message.dingTalk.service.DingTalkService;
 import com.xiang.xservice.config.DingTalkRobotScriptConfig;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/constants/PriceRange.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/constants/PriceRange.java
@@ -0,0 +1,35 @@
+package com.xiang.xservice.application.script.fwd.constants;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.math.BigDecimal;
+import java.util.Arrays;
+
+@Getter
+@AllArgsConstructor
+public enum PriceRange {
+    RANGE_600_900(0, BigDecimal.valueOf(600), BigDecimal.valueOf(900)),
+    RANGE_900_1300(1, BigDecimal.valueOf(900), BigDecimal.valueOf(1300)),
+    RANGE_1300_1600(2, BigDecimal.valueOf(1300), BigDecimal.valueOf(1600)),
+    RANGE_OVER_1600(3, BigDecimal.valueOf(1600), null),
+    RANGE_UNDER_600(4, null, BigDecimal.valueOf(600));
+
+    private final int index;
+    private final BigDecimal min;
+    private final BigDecimal max;
+
+    public boolean contains(BigDecimal price) {
+        boolean minCondition = min == null || price.compareTo(min) > 0;
+        boolean maxCondition = max == null || price.compareTo(max) <= 0;
+        return minCondition && maxCondition;
+    }
+
+
+    public static PriceRange fromPrice(BigDecimal price) {
+        return Arrays.stream(values())
+                .filter(range -> range.contains(price))
+                .findFirst()
+                .orElseThrow(() -> new IllegalArgumentException("Invalid price: " + price));
+    }
+}
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/constants/UrlConstants.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/constants/UrlConstants.java
@@ -2,8 +2,6 @@ package com.xiang.xservice.application.script.fwd.constants;

 public class UrlConstants {

-    public static final String token = "Bearer eyJhbGciOiJIUzUxMiJ9.eyJjdCI6MTc1MjYzODAwNTUxNywic3ViIjoiTDIxMTQzMjU2NDEiLCJhdWQiOiJMSVZFTEFCIiwiaXNzIjoiVElDS0VUIiwibWlkIjoxNzU4ODA4NTcxMzgzNjcxNTUzLCJ0eXBlIjoiYXBwbGV0IiwiaWF0IjoxNzUyNjM4MDA1LCJkaWQiOiI2RTRDMDQ5RS00RkFBLTQ0NDMtQjI3NC1DNjRBMjZEMUFGNTkiLCJrZXkiOiJMSVZFTEFCIn0.iw1u3LyCYlxYCI1gMwTeuJlPdv-rQKCVlO2ySF_UrJ-lrEH6fm5lGo4wGalLn1qGkyqZaxuTx1K6X7Oy7sHgBA";
-
    /**
     * 芬玩岛的基础URL
     */
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/entity/req/ProjectOrderCreateReq.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/entity/req/ProjectOrderCreateReq.java
@@ -25,4 +25,6 @@ public class ProjectOrderCreateReq {
    private String blackBox;
    private String combineTicketVos;
    private String ordinaryTicketVos;
+    private Integer activityType;
+    private String activityId;
 }
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/schedule/FwdImportantMsgJob.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/schedule/FwdImportantMsgJob.java
@@ -3,12 +3,17 @@ package com.xiang.xservice.application.script.fwd.schedule;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Maps;
-import com.xiang.xservice.basic.utils.DateUtils;
-import com.xiang.xservice.basic.utils.PrimaryKeyUtils;
+import com.xiang.xmc.service.schedule.core.DynamicTaskScheduler;
+import com.xiang.xmc.service.schedule.entity.ScheduledTaskEntity;
+import com.xiang.xmc.service.schedule.entity.TaskConfig;
+import com.xiang.xmc.service.schedule.enums.TaskGroupEnum;
+import com.xiang.xmc.service.schedule.enums.TaskStatusEnum;
+import com.xiang.xmc.service.schedule.service.IDynamicTaskSchedulerService;
 import com.xiang.xservice.application.script.fwd.entity.param.FwdOrderTaskParam;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformConfig;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformProjectInfo;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformSeatInfo;
+import com.xiang.xservice.application.script.fwd.entity.pojo.FUserConfig;
 import com.xiang.xservice.application.script.fwd.entity.resp.http.perform.Perform;
 import com.xiang.xservice.application.script.fwd.entity.resp.http.perform.PerformDetail;
 import com.xiang.xservice.application.script.fwd.entity.resp.http.perform.PerformInfo;
@@ -22,16 +27,15 @@ import com.xiang.xservice.application.script.fwd.service.DingTalkScriptFWDServic
 import com.xiang.xservice.application.script.fwd.service.IPerformService;
 import com.xiang.xservice.application.script.fwd.service.IPerformServiceHttp;
 import com.xiang.xservice.application.script.fwd.utils.TimeSyncUtils;
-import com.xiang.xservice.schedule.core.DynamicTaskScheduler;
-import com.xiang.xservice.schedule.entity.ScheduledTaskEntity;
-import com.xiang.xservice.schedule.entity.TaskConfig;
-import com.xiang.xservice.schedule.enums.TaskGroupEnum;
-import com.xiang.xservice.schedule.enums.TaskStatusEnum;
-import com.xiang.xservice.schedule.service.IDynamicTaskSchedulerService;
+import com.xiang.xservice.basic.utils.DateUtils;
+import com.xiang.xservice.basic.utils.PrimaryKeyUtils;
+import com.xiang.xservice.common.entity.SysConfigDO;
+import com.xiang.xservice.common.mapper.SysConfigMapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -68,6 +72,7 @@ public class FwdImportantMsgJob {
    private final IPerformService iPerformService;
    private final IDynamicTaskSchedulerService dynamicTaskSchedulerService;
    private final IPerformServiceHttp iPerformServiceHttp;
+    private final SysConfigMapper sysConfigMapper;

    @PostConstruct
    public void init() {
@@ -78,7 +83,7 @@ public class FwdImportantMsgJob {
        List<ScheduledTaskEntity> taskList = dynamicTaskSchedulerService.getTaskList(scheduledTaskEntity);
        for (ScheduledTaskEntity taskEntity : taskList) {
            HashMap params = com.alibaba.fastjson2.JSON.parseObject(taskEntity.getParameters(), HashMap.class);
-            FwdOrderTaskParam param = MapUtils.isEmpty(params) ? new FwdOrderTaskParam(null, taskEntity.getId()) : new FwdOrderTaskParam((Long) params.get("projectId"), taskEntity.getId());
+            FwdOrderTaskParam param = MapUtils.isEmpty(params) ? new FwdOrderTaskParam(null, taskEntity.getId()) : new FwdOrderTaskParam(Long.parseLong(params.get("projectId").toString()), taskEntity.getId());
            LocalDateTime runTime = taskEntity.getRunTime().isBefore(TimeSyncUtils.now()) ? TimeSyncUtils.now() : taskEntity.getRunTime();
            dynamicTaskScheduler.schedule(
                    new TaskConfig(taskEntity.getId(), taskEntity.getTaskName(), taskEntity.getTaskGroup(), runTime, params),
@@ -115,6 +120,17 @@ public class FwdImportantMsgJob {
            performConfigMapper.insertPerforms(addList);
        }

+        // 是否下单开关
+        boolean flag = false;
+        SysConfigDO config = sysConfigMapper.getByName("fwd.order.create.switch");
+        if (Objects.nonNull(config)) {
+            if (StringUtils.isNotBlank(config.getValue())) {
+                if (StringUtils.equals(config.getValue(), "true")) {
+                    flag = true;
+                }
+            }
+        }
+
        StringBuilder msg = new StringBuilder("今日" + now + "演唱会门票预售信息:\n");
        for (FPerformProjectInfo data : saleTodayData) {
            msg.append("演唱会名称：").append(data.getProjectName()).append("预售时间:").append(DateUtils.getDateTimeFromDateTime(data.getPreSaleTime())).append("\n");
@@ -122,6 +138,7 @@ public class FwdImportantMsgJob {
            Map<String, Object> params = Maps.newHashMap();
            params.put("projectId", data.getProjectId());
            LocalDateTime runTime = data.getPreSaleTime().isBefore(LocalDateTime.now()) ? LocalDateTime.now().plusMinutes(1) : data.getPreSaleTime();
+            if (flag) {
                dynamicTaskScheduler.schedule(
                        new TaskConfig(taskId, "芬玩岛演唱会抢票-【" + data.getProjectName()  + "】", TaskGroupEnum.SERVICE_FWD_SCHEDULE.getCode(),
                                runTime, params),
@@ -130,6 +147,7 @@ public class FwdImportantMsgJob {
                        TimeSyncUtils.now());
                savaTask(data, taskId, params);
            }
+        }
        msg.append("请注意进行数据库配置的更改！");
        dingTalkScriptFWDService.sendScriptMsg(msg.toString());
        log.info("【芬玩岛】演唱会预售定时任务结束！time:{}", System.currentTimeMillis());
@@ -139,6 +157,9 @@ public class FwdImportantMsgJob {
    @PostMapping("/presaleSeatReminderJob")
    public void  presaleSeatReminderJob() {

+        List<FUserConfig> availableUser = fwdUserConfigMapper.getAvailableUser();
+        String token = availableUser.get(0).getToken();
+
        ScheduledTaskEntity entity = new ScheduledTaskEntity();
        entity.setStatus(TaskStatusEnum.UN_START.getCode());
        List<ScheduledTaskEntity> taskList = dynamicTaskSchedulerService.getTaskList(entity);
@@ -162,7 +183,7 @@ public class FwdImportantMsgJob {
                log.error("异常错误信息:{}", JSON.toJSONString(taskEntity), e);
            }
            if (Objects.nonNull(projectId)) {
-                Perform performsByProjectIdFromHttp = iPerformServiceHttp.getPerformsByProjectIdFromHttp(projectId);
+                Perform performsByProjectIdFromHttp = iPerformServiceHttp.getPerformsByProjectIdFromHttp(projectId, token);
                if (Objects.nonNull(performsByProjectIdFromHttp)) {
                    for (PerformInfo performInfo : performsByProjectIdFromHttp.getPerformInfos()) {
                        for (PerformDetail performDetail : performInfo.getPerformInfo()) {
@@ -171,7 +192,7 @@ public class FwdImportantMsgJob {
                                List<SeatPlan> seatPlans = performDetail.getSeatPlans();
                                Map<Long, SeatPlan> seatPlanMap = seatPlans.stream().collect(Collectors.toMap(SeatPlan::getSeatPlanId, Function.identity(), (a, b) -> a));
                                List<Long> seatPlanIds = seatPlans.stream().map(SeatPlan::getSeatPlanId).collect(Collectors.toList());
-                                List<SeatPlanStatus> seatPlanStatusFromHttp = iPerformServiceHttp.getSeatPlanStatusFromHttp(seatPlanIds);
+                                List<SeatPlanStatus> seatPlanStatusFromHttp = iPerformServiceHttp.getSeatPlanStatusFromHttp(seatPlanIds, token);
                                for (SeatPlanStatus seatPlanStatus : seatPlanStatusFromHttp) {
                                    if (!seatPlanStatus.getSoldOutFlag()) {
                                        FPerformSeatInfo seatInfoBySeatId = iPerformService.getSeatInfoBySeatId(seatPlanStatus.getSeatPlanId());
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/schedule/PullDataFromFWDJob.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/schedule/PullDataFromFWDJob.java
@@ -1,9 +1,7 @@
 package com.xiang.xservice.application.script.fwd.schedule;

 import com.google.common.collect.Lists;
-import com.xiang.xservice.basic.common.req.BaseRequest;
-import com.xiang.xservice.basic.config.MyThreadFactory;
-import com.xiang.xservice.basic.utils.DateUtils;
+import com.xiang.xmc.service.http.helper.HttpRequestHelper;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FAudienceConfig;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformProjectInfo;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformSeatInfo;
@@ -23,7 +21,10 @@ import com.xiang.xservice.application.script.fwd.mapper.FwdPerformProjectInfoMap
 import com.xiang.xservice.application.script.fwd.mapper.FwdPerformSeatInfoMapper;
 import com.xiang.xservice.application.script.fwd.mapper.FwdUserConfigMapper;
 import com.xiang.xservice.application.script.fwd.service.IPerformServiceHttp;
-import com.xiang.xservice.http.helper.HttpRequestHelper;
+import com.xiang.xservice.basic.common.req.BaseRequest;
+import com.xiang.xservice.basic.config.MyThreadFactory;
+import com.xiang.xservice.basic.utils.DateUtils;
+import com.xiang.xservice.basic.utils.RandomCodeUtils;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
@@ -36,7 +37,6 @@ import org.springframework.web.bind.annotation.RestController;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
-import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadPoolExecutor;
@@ -139,6 +139,8 @@ public class PullDataFromFWDJob {
    @Scheduled(cron = "0 0 1 1/1 * ?")
    public void pullPerformDataJobV2() {
        int pageNum = 0;
+        List<FUserConfig> availableUser = userConfigMapper.getAvailableUser();
+        String token = availableUser.get(0).getToken();
        while (true) {
            pageNum++;
            BaseRequest baseRequest = new BaseRequest();
@@ -149,12 +151,12 @@ public class PullDataFromFWDJob {
                break;
            }
            List<ProjectList> projects = projectsResp.getList();
-            List<CompletableFuture<FPerformProjectInfo>> futures = Lists.newArrayList();
+            List<FPerformProjectInfo> results = Lists.newArrayList();
            for (ProjectList project : projects) {
-                CompletableFuture<FPerformProjectInfo> future = CompletableFuture.supplyAsync(() -> handleProjectData(project), es);
-                futures.add(future);
+                FPerformProjectInfo performProjectInfo = handleProjectData(project, token);
+                results.add(performProjectInfo);
            }
-            List<FPerformProjectInfo> results = futures.stream().map(CompletableFuture::join).toList();
+            results = results.stream().filter(Objects::nonNull).toList();
            // 查询演出座位档次信息
            List<FPerformSeatInfo> insertList = Lists.newCopyOnWriteArrayList();
            List<FPerformSeatInfo> updateList = Lists.newCopyOnWriteArrayList();
@@ -164,7 +166,7 @@ public class PullDataFromFWDJob {
                    continue;
                }
                List<Long> seatPlanIds = seatPlans.stream().map(SeatPlan::getSeatPlanId).toList();
-                List<SeatPlanStatus> seatPlanStatusList = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getSeatPlanStatusFromHttp(seatPlanIds), "fetch-seat-plan-status");
+                List<SeatPlanStatus> seatPlanStatusList = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getSeatPlanStatusFromHttp(seatPlanIds, token), "fetch-seat-plan-status");
                if (CollectionUtils.isEmpty(seatPlanStatusList)) {
                    continue;
                }
@@ -186,6 +188,7 @@ public class PullDataFromFWDJob {
                        }
                    }
                }
+                stopThread();
            }
            if (!CollectionUtils.isEmpty(insertList)) {
                performSeatInfoMapper.batchSave(insertList);
@@ -198,14 +201,14 @@ public class PullDataFromFWDJob {
        }
    }

-    private FPerformProjectInfo handleProjectData(ProjectList project) {
+    private FPerformProjectInfo handleProjectData(ProjectList project, String token) {
        // 查询演出的详情
-        ProjectInfoResp projectInfoFromHttp = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getProjectInfoFromHttp(project.getProjectId()), "fetch-project-info");
+        ProjectInfoResp projectInfoFromHttp = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getProjectInfoFromHttp(project.getProjectId(), token), "fetch-project-info");
        if (Objects.isNull(projectInfoFromHttp)) {
            return null;
        }
        // 查询演出信息
-        Perform performsByProjectIdFromHttp = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getPerformsByProjectIdFromHttp(project.getProjectId()), "fetch-perform-by-project-id");
+        Perform performsByProjectIdFromHttp = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getPerformsByProjectIdFromHttp(project.getProjectId(), token), "fetch-perform-by-project-id");
        if (Objects.isNull(performsByProjectIdFromHttp)) {
            return null;
        }
@@ -235,100 +238,17 @@ public class PullDataFromFWDJob {

        }
        projectInfo.setSeatPlans(seats);
+        stopThread();
        return projectInfo;
    }

-
-    public void pullPerformDataJob() {
-        int pageNum = 0;
-        while (true) {
-            pageNum++;
-            BaseRequest baseRequest = new BaseRequest();
-            baseRequest.setCurrent(pageNum);
-            baseRequest.setPageSize(50);
-            // 查询所有的演出
-            ProjectsResp projectsResp = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getShowProjectsFromHttp(baseRequest), "fetch-projects");
-            if (Objects.isNull(projectsResp)) {
-                break;
-            }
-            List<ProjectList> projectLists = projectsResp.getList();
-            if (CollectionUtils.isEmpty(projectLists)) {
-                break;
-            }
-            for (ProjectList projectList : projectLists) {
-                // 查询演出的详情
-                ProjectInfoResp projectInfoFromHttp = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getProjectInfoFromHttp(projectList.getProjectId()), "fetch-project-info");
-                if (Objects.isNull(projectInfoFromHttp)) {
-                    continue;
-                }
-                // 查询演出信息
-                Perform performsByProjectIdFromHttp = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getPerformsByProjectIdFromHttp(projectList.getProjectId()), "fetch-perform-by-project-id");
-                if (Objects.isNull(performsByProjectIdFromHttp)) {
-                    continue;
-                }
-
-                // 查询数据库
-                FPerformProjectInfo projectInfo = performProjectInfoMapper.getProjectByProjectId(performsByProjectIdFromHttp.getProjectId());
-                if (Objects.isNull(projectInfo)) {
-                    // 不存在则新增
-                    saveProjectInfo(projectList, projectInfoFromHttp);
-                } else {
-                    // 存在则更新
-                    buildUpdateProjectInfo(projectList, projectInfo, projectInfoFromHttp);
-                    performProjectInfoMapper.update(projectInfo);
-                }
-
-                // 查询演出信息
-                List<PerformInfo> performInfos = performsByProjectIdFromHttp.getPerformInfos();
-                if (CollectionUtils.isEmpty(performInfos)) {
-                    continue;
-                }
-                // 查询演出座位档次信息
-                List<FPerformSeatInfo> insertList = Lists.newCopyOnWriteArrayList();
-                List<FPerformSeatInfo> updateList = Lists.newCopyOnWriteArrayList();
-                for (PerformInfo performInfo : performInfos) {
-                    List<PerformDetail> performs = performInfo.getPerformInfo();
-                    if (CollectionUtils.isEmpty(performs)) {
-                        continue;
-                    }
-                    for (PerformDetail perform : performs) {
-                        if (CollectionUtils.isEmpty(perform.getSeatPlans())) {
-                            continue;
-                        }
-                        List<Long> seatPlanIds = perform.getSeatPlans().stream().map(SeatPlan::getSeatPlanId).collect(Collectors.toList());
-                        List<SeatPlanStatus> seatPlanStatusList = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.getSeatPlanStatusFromHttp(seatPlanIds), "fetch-seat-plan-status");
-                        if (CollectionUtils.isEmpty(seatPlanStatusList)) {
-                            continue;
-                        }
-                        Map<Long, SeatPlanStatus> map = seatPlanStatusList.stream().collect(Collectors.toMap(SeatPlanStatus::getSeatPlanId, Function.identity(), (a, b) -> a));
-                        Map<Long, FPerformSeatInfo> existSeatMap = performSeatInfoMapper.getPerformSeatInfoBySeatIds(seatPlanIds)
-                                .stream()
-                                .collect(Collectors.toMap(FPerformSeatInfo::getSeatPlanId, Function.identity(), (a, b) -> a));
-                        for (SeatPlan seatPlan : perform.getSeatPlans()) {
-                            if (map.containsKey(seatPlan.getSeatPlanId())) {
-                                SeatPlanStatus value = map.get(seatPlan.getSeatPlanId());
-                                if (existSeatMap.containsKey(seatPlan.getSeatPlanId())) {
-                                    // 更新
-                                    FPerformSeatInfo performSeatInfo = existSeatMap.get(seatPlan.getSeatPlanId());
-                                    performSeatInfo.setSoldStock(value.getSoldOutFlag() ? 1 : 0);
-                                    updateList.add(performSeatInfo);
-                                } else {
-                                    // 新增
-                                    saveSeatInfo(projectList.getProjectId(), seatPlan.getSeatPlanId(), value, seatPlan, insertList);
-                                }
-                            }
-                        }
-                    }
-                }
-                if (!CollectionUtils.isEmpty(insertList)) {
-                    performSeatInfoMapper.batchSave(insertList);
-                }
-                if (!CollectionUtils.isEmpty(updateList)) {
-                    for (FPerformSeatInfo seatInfo : updateList) {
-                        performSeatInfoMapper.update(seatInfo);
-                    }
-                }
-            }
+    private static void stopThread() {
+        try {
+            String random = RandomCodeUtils.getNumberRandomCode(1);
+            log.info("线程暂停:{}s", random);
+            Thread.sleep(Long.parseLong(random) * 1000);
+        } catch (InterruptedException e) {
+            log.error("线程暂停1s失败");
        }
    }

--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/schedule/TicketGrabTask.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/schedule/TicketGrabTask.java
@@ -1,13 +1,13 @@
 package com.xiang.xservice.application.script.fwd.schedule;

 import com.alibaba.fastjson.JSON;
+import com.xiang.xmc.service.schedule.service.IDynamicTaskSchedulerService;
 import com.xiang.xservice.application.script.fwd.entity.param.FwdOrderTaskParam;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FAudienceConfig;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FUserConfig;
 import com.xiang.xservice.application.script.fwd.mapper.FwdAudienceConfigMapper;
 import com.xiang.xservice.application.script.fwd.mapper.FwdUserConfigMapper;
 import com.xiang.xservice.application.script.fwd.service.IPerformService;
-import com.xiang.xservice.schedule.service.IDynamicTaskSchedulerService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;

@@ -45,7 +45,7 @@ public class TicketGrabTask implements Runnable {
            for (FUserConfig userConfig : availableUser) {
                List<FAudienceConfig> audiences = audienceConfigMapper.getAudienceByUserId(userConfig.getId());
                try {
-                    performService.createProjectOrder(param.getProjectId(), audiences.stream().map(FAudienceConfig::getFrequentId).collect(Collectors.toList()));
+                    performService.createProjectOrder(param.getProjectId(), audiences.stream().map(FAudienceConfig::getFrequentId).collect(Collectors.toList()), userConfig.getToken());
                    dynamicTaskSchedulerService.finishTask(param.getTaskId());
                } catch (Exception e) {
                    log.error("创建订单失败", e);
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/server/FwdDataController.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/server/FwdDataController.java
@@ -1,5 +1,6 @@
 package com.xiang.xservice.application.script.fwd.server;

+import com.xiang.xservice.application.script.fwd.mapper.FwdUserConfigMapper;
 import com.xiang.xservice.basic.common.resp.Result;
 import com.xiang.xservice.basic.utils.DateUtils;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformConfig;
@@ -27,13 +28,15 @@ public class FwdDataController {

    private final IPerformService performService;
    private final IPerformServiceHttp performServiceHttp;
+    private final FwdUserConfigMapper userConfigMapper;

    @PostMapping("/refreshData")
    public Result<String> refreshData() {
+        String token = userConfigMapper.getAvailableUser().get(0).getToken();
        List<FPerformConfig> availablePerforms = performService.getAvailablePerform();
        for (FPerformConfig availablePerform : availablePerforms) {
-            ProjectInfoResp info = performServiceHttp.getProjectInfoFromHttp(availablePerform.getProjectId());
-            Perform performsByProjectIdFromHttp = performServiceHttp.getPerformsByProjectIdFromHttp(availablePerform.getProjectId());
+            ProjectInfoResp info = performServiceHttp.getProjectInfoFromHttp(availablePerform.getProjectId(), token);
+            Perform performsByProjectIdFromHttp = performServiceHttp.getPerformsByProjectIdFromHttp(availablePerform.getProjectId(), token);
            FPerformProjectInfo performByProjectId = performService.getPerformByProjectId(availablePerform.getProjectId());
            performByProjectId.setStatus(info.getStatus());
            performByProjectId.setPreSaleTime(DateUtils.getDateTimeFromStr(info.getPreSaleTime()));
@@ -53,7 +56,7 @@ public class FwdDataController {
                        continue;
                    }
                    List<Long> seatIds = seatPlans.stream().map(SeatPlan::getSeatPlanId).collect(Collectors.toList());
-                    List<SeatPlanStatus> seatPlanStatusFromHttp = performServiceHttp.getSeatPlanStatusFromHttp(seatIds);
+                    List<SeatPlanStatus> seatPlanStatusFromHttp = performServiceHttp.getSeatPlanStatusFromHttp(seatIds, token);
                    if (CollectionUtils.isEmpty(seatPlanStatusFromHttp)) {
                        continue;
                    }
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/server/FwdOuterController.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/server/FwdOuterController.java
@@ -1,5 +1,6 @@
 package com.xiang.xservice.application.script.fwd.server;

+import com.xiang.xservice.application.script.fwd.mapper.FwdUserConfigMapper;
 import com.xiang.xservice.basic.common.req.BaseRequest;
 import com.xiang.xservice.basic.common.resp.Result;
 import com.xiang.xservice.application.script.fwd.entity.resp.http.perform.Perform;
@@ -28,6 +29,7 @@ public class FwdOuterController {

    private final IPerformServiceHttp performServiceHttp;
    private final IPerformService performService;
+    private final FwdUserConfigMapper fwdUserConfigMapper;
    private static final List<Long> FREQUENT_IDS = List.of(50438548L, 35320661L, 50436621L, 50442739L);


@@ -39,19 +41,22 @@ public class FwdOuterController {

    @GetMapping("/getProjectInfo/{id}")
    public Result<Perform> getProjectInfo(@PathVariable("id") Long id) {
-        Perform performsByProjectIdFromHttp = performServiceHttp.getPerformsByProjectIdFromHttp(id);
+        String token = fwdUserConfigMapper.getAvailableUser().get(0).getToken();
+        Perform performsByProjectIdFromHttp = performServiceHttp.getPerformsByProjectIdFromHttp(id, token);
        return Result.success("查询成功!", performsByProjectIdFromHttp);
    }

    @GetMapping("/getPerformsByProjectIdFromHttp/{id}")
    public Result<Perform> getPerformsByProjectIdFromHttp(@PathVariable("id") Long id) {
-        Perform performsByProjectIdFromHttp = performServiceHttp.getPerformsByProjectIdFromHttp(id);
+        String token = fwdUserConfigMapper.getAvailableUser().get(0).getToken();
+        Perform performsByProjectIdFromHttp = performServiceHttp.getPerformsByProjectIdFromHttp(id, token);
        return Result.success("查询成功!", performsByProjectIdFromHttp);
    }

    @PostMapping("/createOrder")
    public Result<String> createOrder(Long projectId) throws Exception {
-        if (performService.createProjectOrder(projectId, FREQUENT_IDS)) {
+        String token = fwdUserConfigMapper.getAvailableUser().get(0).getToken();
+        if (performService.createProjectOrder(projectId, FREQUENT_IDS, token)) {
            return Result.success("下单成功!");
        }
        return Result.error("下单失败!");
@@ -59,7 +64,8 @@ public class FwdOuterController {

    @GetMapping("/getSeatPlanStatus")
    public Result<SeatPlanStatus> getSeatPlanStatu (@RequestParam List<Long> ids) {
-        List<SeatPlanStatus> seatPlanStatusFromHttp = performServiceHttp.getSeatPlanStatusFromHttp(ids);
+        String token = fwdUserConfigMapper.getAvailableUser().get(0).getToken();
+        List<SeatPlanStatus> seatPlanStatusFromHttp = performServiceHttp.getSeatPlanStatusFromHttp(ids, token);
        return Result.success("查询成功!", seatPlanStatusFromHttp);
    }

--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/DingTalkScriptFWDService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/DingTalkScriptFWDService.java
@@ -1,6 +1,6 @@
 package com.xiang.xservice.application.script.fwd.service;

-import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService;
+import com.xiang.xmc.service.message.dingTalk.service.DingTalkService;
 import com.xiang.xservice.config.DingTalkRobotScriptConfig;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/IPerformService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/IPerformService.java
@@ -16,7 +16,7 @@ public interface IPerformService {

    List<FPerformSeatInfo> getPerformSeatInfoByProjectId(Long projectId);

-    Boolean createProjectOrder(Long projectId, List<Long> frequentIds) throws Exception;
+    Boolean createProjectOrder(Long projectId, List<Long> frequentIds, String token) throws Exception;

    List<FPerformConfig> getAvailablePerform();

--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/IPerformServiceHttp.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/IPerformServiceHttp.java
@@ -24,7 +24,7 @@ public interface IPerformServiceHttp {
     * @param projectId projectId
     * @return ProjectInfoResp
     */
-    ProjectInfoResp getProjectInfoFromHttp(Long projectId);
+    ProjectInfoResp getProjectInfoFromHttp(Long projectId, String token);

    /**
     * http请求创建演出订单
@@ -38,14 +38,14 @@ public interface IPerformServiceHttp {
     * @param projectId
     * @return
     */
-    Perform getPerformsByProjectIdFromHttp(Long projectId);
+    Perform getPerformsByProjectIdFromHttp(Long projectId, String token);

    /**
     * http请求获取座位状态信息
     * @param seatPlanIds
     * @return
     */
-    List<SeatPlanStatus> getSeatPlanStatusFromHttp(List<Long> seatPlanIds);
+    List<SeatPlanStatus> getSeatPlanStatusFromHttp(List<Long> seatPlanIds, String token);

    /**
     * http请求查询观影人信息
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceHttpServiceImpl.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceHttpServiceImpl.java
@@ -66,11 +66,11 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp {
    }

    @Override
-    public ProjectInfoResp getProjectInfoFromHttp(Long projectId) {
+    public ProjectInfoResp getProjectInfoFromHttp(Long projectId, String token) {
        Map<String, String> params = Maps.newHashMap();
        params.put("project_id", String.valueOf(projectId));
        params.put("v", String.valueOf(Instant.now().getEpochSecond()));
-        String respStr = HttpUtils.doGet(UrlConstants.PROJECTS_INFO_URL, buildFWDHeaders(UrlConstants.token), params);
+        String respStr = HttpUtils.doGet(UrlConstants.PROJECTS_INFO_URL, buildFWDHeaders(token), params);
        if (StringUtils.isBlank(respStr)) {
            return null;
        }
@@ -89,7 +89,7 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp {

    @Override
    public ProjectOrderCreateResp createProjectOrder(ProjectOrderCreateReq req, String token) {
-        String respStr = HttpUtils.doPost(UrlConstants.PROJECT_ORDER_CREATE_URL, buildFWDHeaders(token), JsonUtils.toJsonString(req));
+        String respStr = HttpUtils.doPost(UrlConstants.PROJECT_ORDER_CREATE_URL, buildFWDOrderHeaders(token), JsonUtils.toJsonString(req));
        if (StringUtils.isBlank(respStr)) {
            return null;
        }
@@ -104,19 +104,26 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp {
            return projectOrderCreateResp;
        }
        if (Objects.nonNull(code) && Objects.equals(code, CodeConstants.LIMIT)) {
-            Integer waitTime = new Random().nextInt(10);
+            int waitTime = new Random().nextInt(3);
+            if (Objects.equals(waitTime, 0)) {
+                waitTime = 3;
+            }
+            try {
                log.info("触发FWD限流机制，等待:{}秒后重新发送。", waitTime);
+                Thread.sleep((long) waitTime * 1000);
+            } catch (InterruptedException e) {
+                log.error("线程暂停失败！");
+            }
            return null;
        }
        return null;
    }
-
    @Override
-    public Perform getPerformsByProjectIdFromHttp(Long projectId) {
+    public Perform getPerformsByProjectIdFromHttp(Long projectId, String token) {
        Map<String, String> params = Maps.newHashMap();
        params.put("project_id", String.valueOf(projectId));
        params.put("v", String.valueOf(Instant.now().getEpochSecond()));
-        String respStr = HttpUtils.doGet(UrlConstants.PERFORMS_URL, buildFWDHeaders(UrlConstants.token), params);
+        String respStr = HttpUtils.doGet(UrlConstants.PERFORMS_URL, buildFWDHeaders(token), params);
        if (StringUtils.isBlank(respStr)) {
            return null;
        }
@@ -134,7 +141,7 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp {
    }

    @Override
-    public List<SeatPlanStatus> getSeatPlanStatusFromHttp(List<Long> seatPlanIds) {
+    public List<SeatPlanStatus> getSeatPlanStatusFromHttp(List<Long> seatPlanIds, String token) {
        StringBuilder seatIds = new StringBuilder();
        for (Long seatPlanId : seatPlanIds) {
            seatIds.append(seatPlanId).append(",");
@@ -142,7 +149,7 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp {
        Map<String, String> params = Maps.newHashMap();
        params.put("seatPlanIds", seatIds.substring(0, seatIds.length() - 2));
        params.put("type", "3");
-        String respStr = HttpUtils.doGet(UrlConstants.PROJECT_SEAT_STATUS_URL, buildFWDHeaders(UrlConstants.token), params);
+        String respStr = HttpUtils.doGet(UrlConstants.PROJECT_SEAT_STATUS_URL, buildFWDHeaders(token), params);
        if (StringUtils.isBlank(respStr)) {
            return Lists.newArrayList();
        }
@@ -219,6 +226,20 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp {

    private Map<String, String> buildFWDOrderHeaders(String token) {
        Map<String, String> headers = Maps.newHashMap();
+        headers.put("Host", "api.livelab.com.cn");
+        headers.put("x-fwd-anonymousId", "ocXac5C25MY5O3UM_EfL0oTgm7Jw");
+        headers.put("platform-type", "%E7%BA%B7%E7%8E%A9%E5%B2%9B%E5%BE%AE%E4%BF%A1%E5%B0%8F%E7%A8%8B%E5%BA%8F");
+        headers.put("Authorization", token);
+        headers.put("platform-version", "3.17.1");
+        headers.put("xweb_xhr", "1");
+        headers.put("Content-Type", "application/json");
+        headers.put("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/132.0.0.0 Safari/537.36 MicroMessenger/7.0.20.1781(0x6700143B) NetType/WIFI MiniProgramEnv/Mac MacWechat/WMPF MacWechat/3.8.7(0x13080712) UnifiedPCMacWechat(0xf2641110) XWEB/16730");
+        headers.put("Accept", "*/*");
+        headers.put("Sec-Fetch-Site", "cross-site");
+        headers.put("Sec-Fetch-Mode", "cors");
+        headers.put("Sec-Fetch-Dest", "empty");
+        headers.put("Referer", "https://servicewechat.com/wx5a8f481d967649eb/123/page-frame.html");
+        headers.put("Accept-Language", "zh-CN,zh;q=0.9");
        return headers;
    }
 }
--- a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceImpl.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceImpl.java
@@ -1,7 +1,8 @@
 package com.xiang.xservice.application.script.fwd.service.impl;

-import com.alibaba.fastjson2.JSONObject;
-import com.xiang.xservice.basic.config.MyThreadFactory;
+import com.alibaba.fastjson.JSONObject;
+import com.xiang.xmc.service.http.helper.HttpRequestHelper;
+import com.xiang.xservice.application.script.fwd.constants.PriceRange;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformConfig;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformProjectInfo;
 import com.xiang.xservice.application.script.fwd.entity.pojo.FPerformSeatInfo;
@@ -15,22 +16,27 @@ import com.xiang.xservice.application.script.fwd.mapper.FwdUserConfigMapper;
 import com.xiang.xservice.application.script.fwd.service.DingTalkScriptFWDService;
 import com.xiang.xservice.application.script.fwd.service.IPerformService;
 import com.xiang.xservice.application.script.fwd.service.IPerformServiceHttp;
-import com.xiang.xservice.http.helper.HttpRequestHelper;
+import com.xiang.xservice.basic.config.MyThreadFactory;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.logging.log4j.util.Strings;
 import org.jetbrains.annotations.NotNull;
 import org.springframework.stereotype.Service;

 import java.math.BigDecimal;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.Comparator;
 import java.util.List;
+import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.stream.Collectors;

 /**
 * @Author: xiang
@@ -69,11 +75,7 @@ public class PerformServiceImpl implements IPerformService {
    }

    @Override
-    public Boolean createProjectOrder(Long projectId, List<Long> frequentIds) throws Exception {
-        List<FUserConfig> availableUser = fwdUserConfigMapper.getAvailableUser();
-        if (CollectionUtils.isEmpty(availableUser)) {
-            return Boolean.FALSE;
-        }
+    public Boolean createProjectOrder(Long projectId, List<Long> frequentIds, String token) throws Exception {
        FPerformProjectInfo performByProjectId = getPerformByProjectId(projectId);
        if (Objects.isNull(performByProjectId)) {
            log.info("该projectId:{}暂无演出信息", projectId);
@@ -84,16 +86,41 @@ public class PerformServiceImpl implements IPerformService {
            log.info("该projectId:{}暂无座位信息", projectId);
            return Boolean.FALSE;
        }
-        for (FPerformSeatInfo fPerformSeatInfo : seatInfoByProjectId) {
-            if (1 == fPerformSeatInfo.getSoldOut()) {
-                continue;
-            }
-            ProjectOrderCreateReq projectOrderCreateReq = buildReq(projectId, frequentIds, fPerformSeatInfo);
-            for (int i = 1; i <= 10; i++) {
-                ProjectOrderCreateResp projectOrder = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.createProjectOrder(projectOrderCreateReq, availableUser.get(0).getToken()), "create-project-order");
+        Map<Long, List<FPerformSeatInfo>> performMap = seatInfoByProjectId.stream().filter(item -> 0 == item.getSoldOut()).collect(Collectors.groupingBy(FPerformSeatInfo::getPerformId));
+        // todo 场次座位排序 优先 场次先后顺序 周六>周日>周五>工作日 根据场次分组进行
+        // todo 座位价格排序 优先 600-900 > 900-1300 > 1300-1600 > 1600~* > 0-600
+        for (Long performId : performMap.keySet()) {
+            List<FPerformSeatInfo> fPerformSeatInfos = performMap.get(performId);
+            AtomicReference<BigDecimal> atomicPrice = new AtomicReference<>();
+            fPerformSeatInfos.stream().map(FPerformSeatInfo::getPrice).max(BigDecimal::compareTo).ifPresent(atomicPrice::set);
+            BigDecimal price = atomicPrice.get();
+            // 排序座位
+            /*
+                0: 600-900
+                1: 900-1300
+                2: 1300-1600
+                3: >1600
+                4: <=600
+            */
+            List<Long> seatIds = fPerformSeatInfos.stream()
+                    .collect(Collectors.groupingBy(
+                            seat -> PriceRange.fromPrice(seat.getPrice()),
+                            Collectors.collectingAndThen(Collectors.toList(), list -> {
+                                Collections.shuffle(list);
+                                return list;
+                            })
+                    ))
+                    .entrySet().stream()
+                    .sorted(Comparator.comparing(entry -> entry.getKey().getIndex()))
+                    .flatMap(entry -> entry.getValue().stream())
+                    .map(FPerformSeatInfo::getSeatPlanId)
+                    .collect(Collectors.toList());
+            ProjectOrderCreateReq projectOrderCreateReq = buildReqV2(projectId, frequentIds, seatIds, performId, price);
+            for (int i = 1; i <= 100; i++) {
+                ProjectOrderCreateResp projectOrder = httpRequestHelper.fetchWithRetry(() -> performServiceHttp.createProjectOrder(projectOrderCreateReq, token), "create-project-order");
                if (Objects.nonNull(projectOrder)) {
                    log.info("下单成功，订单信息:{}", JSONObject.toJSONString(projectOrder));
-                    String msg = "【芬玩岛】下单成功✅✅✅，演出名称：" + performByProjectId.getProjectName() + "，请在2分钟内完成付款！";
+                    String msg = "【芬玩岛】下单成功✅✅✅，演出名称：" + performByProjectId.getProjectName() + "，请在5分钟内完成付款！订单号：" + projectOrder.getOrderNo();
                    dingTalkService.sendScriptMsg(msg);
                    return Boolean.TRUE;
                }
@@ -104,22 +131,24 @@ public class PerformServiceImpl implements IPerformService {
    }

    @NotNull
-    private static ProjectOrderCreateReq buildReq(Long projectId, List<Long> frequentIds, FPerformSeatInfo fPerformSeatInfo) {
+    private static ProjectOrderCreateReq buildReqV2(Long projectId, List<Long> frequentIds, List<Long> seatPlanIds, Long perfomrId, BigDecimal price) {
        ProjectOrderCreateReq projectOrderCreateReq = new ProjectOrderCreateReq();
        projectOrderCreateReq.setDeliveryType(1);
        projectOrderCreateReq.setContactName("朱吉祥");
        projectOrderCreateReq.setContactPhone("15858717571");
-        projectOrderCreateReq.setPayment(fPerformSeatInfo.getPrice().multiply(BigDecimal.valueOf(frequentIds.size())).setScale(2));
-        projectOrderCreateReq.setTotalPrice(fPerformSeatInfo.getPrice().multiply(BigDecimal.valueOf(frequentIds.size())).setScale(2, BigDecimal.ROUND_HALF_UP));
-        projectOrderCreateReq.setPerformId(fPerformSeatInfo.getPerformId());
+        projectOrderCreateReq.setPayment(price.multiply(BigDecimal.valueOf(frequentIds.size())).setScale(2));
+        projectOrderCreateReq.setTotalPrice(price.multiply(BigDecimal.valueOf(frequentIds.size())).setScale(2, BigDecimal.ROUND_HALF_UP));
+        projectOrderCreateReq.setPerformId(perfomrId);
        projectOrderCreateReq.setProjectId(projectId.toString());
        projectOrderCreateReq.setPrivilegeCodeList(new ArrayList<>());
        projectOrderCreateReq.setAudienceCount(frequentIds.size());
        projectOrderCreateReq.setFrequentIds(frequentIds);
-        projectOrderCreateReq.setSeatPlanIds(Collections.singletonList(fPerformSeatInfo.getSeatPlanId()));
+        projectOrderCreateReq.setSeatPlanIds(seatPlanIds);
        projectOrderCreateReq.setBlackBox(":0");
        projectOrderCreateReq.setCombineTicketVos(null);
        projectOrderCreateReq.setOrdinaryTicketVos(null);
+        projectOrderCreateReq.setActivityId(Strings.EMPTY);
+        projectOrderCreateReq.setActivityType(0);
        return projectOrderCreateReq;
    }

--- a/script/src/main/java/com/xiang/xservice/application/script/glados/common/GladosConstants.java
+++ b/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\"}";
 }
--- a/script/src/main/java/com/xiang/xservice/application/script/glados/common/URLConstants.java
+++ b/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";

    /**
     * 签到
--- a/script/src/main/java/com/xiang/xservice/application/script/glados/controller/GLaDOSController.java
+++ b/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();
    }

 }
--- a/script/src/main/java/com/xiang/xservice/application/script/glados/entity/resp/CheckInResp.java
+++ b/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;
+}
--- a/script/src/main/java/com/xiang/xservice/application/script/glados/schedule/GladosCheckInJob.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/glados/schedule/GladosCheckInJob.java
@@ -19,9 +19,9 @@ public class GladosCheckInJob {

    private final GLaDOSService glaDOSService;

-    @Scheduled(cron = "0 0 8,16 1/1 * ?")
+    @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();
    }
 }
--- a/script/src/main/java/com/xiang/xservice/application/script/glados/service/DingTalkScriptGladosService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/glados/service/DingTalkScriptGladosService.java
@@ -1,6 +1,6 @@
 package com.xiang.xservice.application.script.glados.service;

-import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService;
+import com.xiang.xmc.service.message.dingTalk.service.DingTalkService;
 import com.xiang.xservice.config.DingTalkRobotScriptConfig;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
--- a/script/src/main/java/com/xiang/xservice/application/script/glados/service/GLaDOSService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/glados/service/GLaDOSService.java
@@ -10,4 +10,9 @@ public interface GLaDOSService {
     * 签到
     */
    String checkIn();
+
+    /**
+     * 签到
+     */
+    void checkInV2();
 }
--- a/script/src/main/java/com/xiang/xservice/application/script/glados/service/GLaDOSServiceImpl.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/glados/service/GLaDOSServiceImpl.java
@@ -1,14 +1,18 @@
 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.xservice.basic.utils.HttpUtils;
+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;
+import com.xiang.xservice.basic.utils.HttpUtils;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -33,6 +37,8 @@ public class GLaDOSServiceImpl implements GLaDOSService{

    private final DingTalkScriptGladosService dingTalkService;

+    private final BaseHttpHelp httpHelp = HttpHelperFactory.createSimpleHttp();
+
    /**
     * 签到
     */
@@ -46,7 +52,16 @@ public class GLaDOSServiceImpl implements GLaDOSService{
        StringBuffer sb = new StringBuffer();
        users.parallelStream().forEach(user -> {
            try {
-                checkIn(user, sb);
+                for (int i = 0; i < 3; i++) {
+                    if (checkIn(user, sb)) {
+                        break;
+                    }
+                    try {
+                        Thread.sleep(10000);
+                    } catch (InterruptedException e) {
+                        log.error("线程暂停10s失败");
+                    }
+                }
            } catch (Exception e) {
                log.error("签到失败，", e);
            }
@@ -54,7 +69,92 @@ public class GLaDOSServiceImpl implements GLaDOSService{
        return sb.toString();
    }

-    private void checkIn(User user, StringBuffer sb) {
+    @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();
        header.put("Cookie", user.getCookie());
@@ -72,7 +172,10 @@ public class GLaDOSServiceImpl implements GLaDOSService{
        GLaDOSResponse gLaDOSResponse =JSONObject.parseObject(response, GLaDOSResponse.class);
        if (Objects.nonNull(gLaDOSResponse)) {
            log.info("http do post success, response:{}", response);
-            if (0 == gLaDOSResponse.getCode() && Objects.nonNull(gLaDOSResponse.getPoints())) {
+
+            // 成功签到记录
+            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 {
@@ -81,11 +184,34 @@ public class GLaDOSServiceImpl implements GLaDOSService{
                    } 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;
                }
+            }
+
+            // 重复签到，表示当日签到成功
            if (1 == gLaDOSResponse.getCode()) {
                log.warn("签到失败，重复签到，用户:{}, 签到消息:{}", user.getEmail(), gLaDOSResponse.getMessage());
                sb.append(user).append("签到失败，重复签到，用户:").append(user).append("，签到消息:").append(gLaDOSResponse.getMessage());
+                try {
+                    dingTalkService.sendScriptMsg("[时间：" + LocalDateTime.now() + "] 用户: " +
+                            user.getEmail() + "当天已经签到成功！获得积分" + gLaDOSResponse.getList().get(0));
+                } 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;
+            }
+
+            // cookie过期
            if (-2 == gLaDOSResponse.getCode()) {
                log.warn("签到失败，用户:{}, cookie过期:{}", user.getEmail(), gLaDOSResponse.getMessage());
                String message = "[时间：" + LocalDateTime.now() + "] 用户: " + user.getEmail() + "，签到消息: " + gLaDOSResponse.getMessage();
@@ -95,15 +221,25 @@ public class GLaDOSServiceImpl implements GLaDOSService{
                    log.error("发送钉钉消息失败", e);
                }
            }
+
+            // 其余的异常情况
            if (gLaDOSResponse.getCode() != 1) {
                log.warn("签到异常，返回的消息:{}", gLaDOSResponse.getMessage());
                sb.append(user.getEmail()).append("签到异常，返回的消息:").append(gLaDOSResponse.getMessage()).append("\n");
            }
-            GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(1).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
+            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;
+            return Boolean.FALSE;
+        } else {
+            try {
+                String mes = "[时间：" + LocalDateTime.now() + "] 用户: " + user.getEmail() + "，签到异常，请求结果为空。";
+                dingTalkService.sendScriptMsg(mes);
+            } catch (Exception e) {
+                log.error("发送钉钉消息失败", e);
+            }
        }
        GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(0).response(response).user(user.getEmail()).userId(user.getId()).build();
        gladosMapper.insertScriptRunLog(build);
+        return Boolean.FALSE;
    }
 }
--- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/JntyzxResponse.java
+++ b/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;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/query/QueryVenueResponse.java
+++ b/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;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/query/SitePositionList.java
+++ b/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;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/query/TimeList.java
+++ b/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;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/resp/query/VenueList.java
+++ b/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;
-
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxService.java
@@ -1,13 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-/**
- * @Author: xiang
- * @Date: 2025-05-14 14:06
- */
-public interface JntyzxService {
-
-    /**
-     * 查询可用场地
-     */
-    void queryAvailable() throws Exception;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxServiceImpl.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxServiceImpl.java
@@ -1,99 +0,0 @@
-package com.xiang.xservice.application.script.jntyzx.service;
-
-import com.alibaba.fastjson2.JSONObject;
-import com.google.common.collect.Maps;
-import com.xiang.xservice.basic.utils.HttpUtils;
-import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService;
-import com.xiang.xservice.application.script.xb.common.URLConstants;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.JntyzxResponse;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.QueryVenueResponse;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.SitePositionList;
-import com.xiang.xservice.application.script.jntyzx.entity.resp.query.VenueList;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
-
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.stream.Collectors;
-
-/**
- * @Author: xiang
- * @Date: 2025-05-14 14:07
- */
-@Service
-@RequiredArgsConstructor
-@Slf4j
-public class JntyzxServiceImpl implements JntyzxService{
-
-
-    private final DingTalkService dingTalkService;
-
-    @Value("${dingtalk.chatId}")
-    private String chatId;
-
-    @Override
-    public void queryAvailable() throws Exception {
-        String url = URLConstants.JNTYZX_QUERY_TODAY_VENUE;
-        Map<String, String> header = Maps.newHashMap();
-        header.put("X-Access-Token", "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJleHAiOjE3NDcyMTAwNzQsInVzZXJuYW1lIjoid3hfb3Blbl9pZF9vMjFNWDR5N3doWENHanZVVEdQNkNUejJIYkQ4In0.0h_cAH_e5cCXDQlQN40jZDBgtfrzQWAmgl3YPQf0d-M");
-        String resp = null;
-        try {
-            resp = HttpUtils.doGet(url, header, null);
-        } catch (Exception e) {
-            log.error("[doGet] 江南体育中心查询当天场地 请求失败, url:{}", url);
-        }
-        if (StringUtils.isEmpty(resp)) {
-            log.warn("[查询场地] 江南体育中心查询当天场地 请求结果为空, url:{}, resp:{}", url, resp);
-        }
-        JntyzxResponse response = JSONObject.parseObject(resp, JntyzxResponse.class);
-        String message = "";
-        if (Objects.nonNull(response)) {
-            if (response.getSuccess()) {
-                log.info("[查询场地] 江南体育中心查询当天场地 请求地址:{}, 请求结果:{}", url, resp);
-                JSONObject object = (JSONObject) response.getResult();
-                if (Objects.nonNull(object)) {
-                    QueryVenueResponse result = object.toJavaObject(QueryVenueResponse.class);
-                    if (Objects.nonNull(result)) {
-                        List<VenueList> venueLists = result.getVenue();
-                        if (!CollectionUtils.isEmpty(venueLists)) {
-                            StringBuilder sb = new StringBuilder();
-                            for (VenueList venue : venueLists) {
-                                List<SitePositionList> positionList = venue.getSitePosition();
-                                positionList = positionList.stream().filter(this::filterTime).collect(Collectors.toList());
-                                for (SitePositionList sitePositionList : positionList) {
-                                    sb.append(venue.getPlaceName()).append(":").append(sitePositionList.getSjName()).append(":预定人：").append(sitePositionList.getContacts()).append("，电话：").append(sitePositionList.getContactNumber()).append("\n");
-                                }
-                            }
-                            message = sb.toString();
-                        }
-                    }
-                }
-            }
-        }
-        if (StringUtils.isNotBlank(message)) {
-            dingTalkService.sendChatMessage(chatId, message);
-        }
-    }
-
-
-    private Boolean filterTime(SitePositionList sitePositionList) {
-        if (StringUtils.equals("18:00-19:00", sitePositionList.getSjName())) {
-            return Boolean.TRUE;
-        }
-        if (StringUtils.equals("19:00-20:00", sitePositionList.getSjName())) {
-            return Boolean.TRUE;
-        }
-        if (StringUtils.equals("20:00-21:00", sitePositionList.getSjName())) {
-            return Boolean.TRUE;
-        }
-        if (StringUtils.equals("21:00-22:00", sitePositionList.getSjName())) {
-            return Boolean.TRUE;
-        }
-        return Boolean.FALSE;
-    }
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/common/constants/RedisConstants.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/common/constants/RedisConstants.java
@@ -1,15 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.common.constants;
-
-import com.xiang.xservice.basic.utils.DateUtils;
-
-import java.time.LocalDate;
-
-public class RedisConstants {
-
-    public static final String MSG_SEND_REDIS_KEY = "stock:msg:send:";
-
-
-    public static String getDate4Key() {
-        return DateUtils.getDateFromDate(LocalDate.now(), "yyyyMMdd");
-    }
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/common/constants/UrlConstants.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/common/constants/UrlConstants.java
@@ -1,9 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.common.constants;
-
-public class UrlConstants {
-
-    /**
-     * 新浪财经 股票数据拉取
-     */
-    public static final String SINA_STOCK_DATA_PULL_URL = "https://hq.sinajs.cn/list=";
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/entity/StockSinaDataRecordDO.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/entity/StockSinaDataRecordDO.java
@@ -1,63 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.entity;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.math.BigDecimal;
-import java.time.LocalDateTime;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class StockSinaDataRecordDO {
-    /**
-     * 主键id
-     */
-    private Long id;
-
-    /**
-     * 股票名称
-     */
-    private String name;
-
-    /**
-     * 今开价格
-     */
-    private BigDecimal jkPrice;
-
-    /**
-     * 昨收价格
-     */
-    private BigDecimal zsPrice;
-
-    /**
-     * 现在价格
-     */
-    private BigDecimal xjPrice;
-
-    /**
-     * 最高价格
-     */
-    private BigDecimal zgPrice;
-
-    /**
-     * 最低价格
-     */
-    private BigDecimal zdPrice;
-
-    /**
-     * 总手数量
-     */
-    private String zsNum;
-
-    /**
-     * 总交易金额
-     */
-    private BigDecimal price;
-
-    /**
-     * 时间
-     */
-    private LocalDateTime updateTime;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/mapper/StockSinaDataRecordPullMapper.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/mapper/StockSinaDataRecordPullMapper.java
@@ -1,15 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.mapper;
-
-import com.xiang.xservice.application.script.stock.data.entity.StockSinaDataRecordDO;
-import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Param;
-import org.springframework.stereotype.Repository;
-
-import java.util.List;
-
-@Repository
-@Mapper
-public interface StockSinaDataRecordPullMapper {
-
-    int batchInsert(@Param("list") List<StockSinaDataRecordDO> list);
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/schedule/DataMsgSendJob.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/schedule/DataMsgSendJob.java
@@ -1,98 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.schedule;
-
-import com.xiang.xservice.basic.utils.DateUtils;
-import com.xiang.xservice.cache.service.IRedisService;
-import com.xiang.xservice.application.script.stock.data.common.constants.RedisConstants;
-import com.xiang.xservice.application.script.stock.data.entity.StockSinaDataRecordDO;
-import com.xiang.xservice.application.script.stock.data.service.DingTalkScriptStockService;
-import com.xiang.xservice.application.script.stock.data.service.IStockDataService;
-import com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO;
-import com.xiang.xservice.application.script.stock.gnshyx.service.ICloudRecordDataService;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import java.time.DayOfWeek;
-import java.time.LocalDateTime;
-import java.time.LocalTime;
-import java.util.List;
-import java.util.Objects;
-import java.util.concurrent.TimeUnit;
-
-@Component
-@Slf4j
-@RequiredArgsConstructor
-public class DataMsgSendJob {
-
-    private final ICloudRecordDataService cloudRecordDataService;
-    private final IStockDataService stockDataService;
-    private final DingTalkScriptStockService dingTalkScriptStockService;
-    private final IRedisService redisService;
-
-    @Scheduled(cron = "0/10 * * * * ?")
-    public void stockGetTargetMsgSend() {
-        if (DateUtils.validWeekTime()) return;
-
-        StringBuilder msg = new StringBuilder();
-        List<StockGnshyxRecordDataDO> list = cloudRecordDataService.getList();
-        for (StockGnshyxRecordDataDO stockGnshyxRecordDataDO : list) {
-            String stockCode = stockGnshyxRecordDataDO.getStockCode();
-            String[] values = stockCode.split("\\.");
-            String c1 = values[1].toLowerCase();
-            String c2 = values[0];
-            String code = c1 + c2;
-            String resp = stockDataService.getStockDataFromHttp(code);
-            StockSinaDataRecordDO recordDO = stockDataService.buildRecordDO(resp);
-            if (Objects.nonNull(recordDO)) {
-                Object o = redisService.hGet(RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), stockGnshyxRecordDataDO.getStockCode());
-                if (Objects.isNull(o)) {
-                    if (recordDO.getXjPrice().compareTo(stockGnshyxRecordDataDO.getAttentionPrice()) > 0) {
-                        msg.append("股票代码:")
-                                .append(stockGnshyxRecordDataDO.getStockCode())
-                                .append("，名称:")
-                                .append(stockGnshyxRecordDataDO.getStockName())
-                                .append(",达到预期的价格：")
-                                .append(stockGnshyxRecordDataDO.getAttentionPrice())
-                                .append(",现在价格:").append(recordDO.getXjPrice())
-                                .append("\n");
-                    }
-                    if (recordDO.getXjPrice().compareTo(stockGnshyxRecordDataDO.getStopPrice()) < 0) {
-                        msg.append("股票代码:")
-                                .append(stockGnshyxRecordDataDO.getStockCode())
-                                .append("，名称:")
-                                .append(stockGnshyxRecordDataDO.getStockName())
-                                .append("达到止损的价格：")
-                                .append(stockGnshyxRecordDataDO.getStopPrice())
-                                .append(",现在价格:").append(recordDO.getXjPrice())
-                                .append("\n");
-                    }
-                    redisService.hSet(RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), stockGnshyxRecordDataDO.getStockCode(), "true");
-                    redisService.expire("xservice-script-center", RedisConstants.MSG_SEND_REDIS_KEY + RedisConstants.getDate4Key(), 10, TimeUnit.DAYS);
-                }
-            }
-        }
-
-        if (StringUtils.isNotBlank(msg)) {
-            log.info("发送钉钉消息:{}", msg);
-            dingTalkScriptStockService.sendScriptMsg(msg.toString());
-        }
-    }
-
-    private static boolean validTime() {
-        if (Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SATURDAY) ||
-                Objects.equals(LocalDateTime.now().getDayOfWeek(), DayOfWeek.SUNDAY)) {
-            log.info("当前时间为：{}", LocalDateTime.now());
-            return false;
-        }
-        LocalTime now = LocalTime.now();
-
-        boolean inMorning = now.isAfter(LocalTime.of(9, 29)) && now.isBefore(LocalTime.of(11, 31));
-        boolean inAfternoon = now.isAfter(LocalTime.of(12, 59)) && now.isBefore(LocalTime.of(15, 1));
-        if (!inAfternoon && !inMorning) {
-            return false;
-        }
-        return true;
-    }
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/schedule/StockDataPullJob.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/schedule/StockDataPullJob.java
@@ -1,64 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.schedule;
-
-import com.alibaba.fastjson.JSON;
-import com.google.common.collect.Lists;
-import com.xiang.xservice.basic.utils.DateUtils;
-import com.xiang.xservice.cache.service.IRedisService;
-import com.xiang.xservice.common.entity.DayResult;
-import com.xiang.xservice.common.enums.RedisConstant;
-import com.xiang.xservice.application.script.stock.data.entity.StockSinaDataRecordDO;
-import com.xiang.xservice.application.script.stock.data.service.IStockDataService;
-import com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO;
-import com.xiang.xservice.application.script.stock.gnshyx.service.ICloudRecordDataService;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.collections4.CollectionUtils;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import java.time.LocalDate;
-import java.util.List;
-import java.util.Objects;
-
-@Component
-@Slf4j
-@RequiredArgsConstructor
-public class StockDataPullJob {
-
-    private final ICloudRecordDataService cloudRecordDataService;
-    private final IStockDataService stockDataService;
-    private final IRedisService redisService;
-    private static final Integer BATCH_SIZE = 500;
-
-    @Scheduled(cron = "*/1 * * * * ?")
-    public void sinaDataPullJob() {
-        if (DateUtils.validWeekTime()) return;
-        LocalDate now = LocalDate.now();
-        String dayResult = (String) redisService.hGet(RedisConstant.DAY_INFO_PREFIX_KEY, DateUtils.getDateFromDate(now));
-        if (com.xiang.xservice.common.utils.DateUtils.validHoliday(JSON.parseObject(dayResult, DayResult.class))) return;
-        log.info(">>>>>>>>>>>>>>>>>新浪财经数据拉取开始>>>>>>>>>>>>>>>>>");
-        List<StockGnshyxRecordDataDO> dataList = cloudRecordDataService.getList();
-        List<StockSinaDataRecordDO> result = Lists.newArrayList();
-        for (StockGnshyxRecordDataDO stockGnshyxRecordDataDO : dataList) {
-            String stockCode = stockGnshyxRecordDataDO.getStockCode();
-            String[] values = stockCode.split("\\.");
-            String c1 = values[1].toLowerCase();
-            String c2 = values[0];
-            String code = c1 + c2;
-            String resp = stockDataService.getStockDataFromHttp(code);
-            StockSinaDataRecordDO stockSinaDataRecordDO = stockDataService.buildRecordDO(resp);
-            if (Objects.nonNull(stockSinaDataRecordDO)) {
-                result.add(stockSinaDataRecordDO);
-            }
-        }
-
-        if (CollectionUtils.isNotEmpty(result)) {
-            if (BATCH_SIZE > result.size()) {
-                Lists.partition(result, BATCH_SIZE).forEach(stockDataService::insertData2DB);
-            } else {
-                stockDataService.insertData2DB(result);
-            }
-        }
-        log.info(">>>>>>>>>>>>>>>>>新浪财经数据拉取结束>>>>>>>>>>>>>>>>>");
-    }
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/service/DingTalkScriptStockService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/service/DingTalkScriptStockService.java
@@ -1,32 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.service;
-
-import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService;
-import com.xiang.xservice.config.DingTalkRobotXbConfig;
-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 DingTalkScriptStockService {
-
-    private final DingTalkService dingTalkService;
-    private final DingTalkRobotXbConfig dingTalkRobotXbConfig;
-
-    /**
-     * 发送脚本消息
-     * @param msg   消息
-     */
-    public void sendScriptMsg(String msg) {
-        try {
-            dingTalkService.sendRobotMessage(dingTalkRobotXbConfig.getSecret(), dingTalkRobotXbConfig.getToken(), dingTalkRobotXbConfig.getUsers(), msg);
-        } catch (Exception e) {
-            log.error("信息发送异常, 信息：{}", msg, e);
-        }
-    }
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/service/IStockDataService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/service/IStockDataService.java
@@ -1,14 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.service;
-
-import com.xiang.xservice.application.script.stock.data.entity.StockSinaDataRecordDO;
-
-import java.util.List;
-
-public interface IStockDataService {
-
-    String getStockDataFromHttp(String stockCode);
-
-    boolean insertData2DB(List<StockSinaDataRecordDO> stockSinaDataRecordDOs);
-
-    StockSinaDataRecordDO buildRecordDO(String resp);
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/data/service/StockDataServiceImpl.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/data/service/StockDataServiceImpl.java
@@ -1,98 +0,0 @@
-package com.xiang.xservice.application.script.stock.data.service;
-
-import com.google.common.collect.Maps;
-import com.xiang.xservice.basic.exception.BusinessException;
-import com.xiang.xservice.basic.utils.HttpUtils;
-import com.xiang.xservice.application.script.stock.data.common.constants.UrlConstants;
-import com.xiang.xservice.application.script.stock.data.entity.StockSinaDataRecordDO;
-import com.xiang.xservice.application.script.stock.data.mapper.StockSinaDataRecordPullMapper;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.stereotype.Service;
-
-import java.math.BigDecimal;
-import java.math.RoundingMode;
-import java.time.LocalDateTime;
-import java.util.List;
-import java.util.Map;
-
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class StockDataServiceImpl implements IStockDataService{
-
-    private final StockSinaDataRecordPullMapper stockSinaDataRecordPullMapper;
-
-    //文灿股份,22.210,22.240,22.070,22.310,21.960,22.070,22.080,5173623, 114323642.000, 2900,  22.070,7600,  22.060,4600,  22.050,2700, 22.040,4700, 22.030,600,   22.080,29800,22.090,3800, 22.100,3000,  22.120,800,   22.130,2025-09-19,15:00:02,00
-    //浦发银行,12.690,12.750,12.810,12.900,12.560,12.800,12.810,79638295,1015780801.000,78500, 12.800,88400, 12.790,151900,12.780,42900,12.770,71700,12.760,841170, 12.810,1100, 12.830,48100,12.860,128600,12.870,116600,12.880,2025-09-19,15:00:03,00,
-    //平安银行,11.410,11.410,11.450,11.510,11.370,11.450,11.460,83465123,955004096.910, 103813,11.450,321000,11.440,198700,11.430,216100,11.420,553000,11.410,15300,11.460,27500,11.470,28400,11.480,175335,11.490,893111,11.500,2025-09-19,15:00:00,00
-
-    @Override
-    public String getStockDataFromHttp(String stockCode) {
-        String url = UrlConstants.SINA_STOCK_DATA_PULL_URL + stockCode;
-
-        Map<String, String> headers = Maps.newHashMap();
-        headers.put("Referer", "https://finance.sina.com.cn");
-        headers.put("User-Agent", "Mozilla/5.0");
-        String resp = HttpUtils.doGet(url, headers, null);
-        if (StringUtils.isBlank(resp)) {
-            log.error("http请求拉取新浪财经股票数据失败, 股票代码:{}, 响应结果:{}", stockCode, resp);
-            throw new BusinessException("拉取数据失败");
-        }
-        return resp;
-    }
-
-    @Override
-    public boolean insertData2DB(List<StockSinaDataRecordDO> stockSinaDataRecordDOs) {
-        return stockSinaDataRecordPullMapper.batchInsert(stockSinaDataRecordDOs) > 0;
-    }
-
-    @Override
-    public StockSinaDataRecordDO buildRecordDO(String resp) {
-        if (resp.contains("=")) {
-            resp = resp.split("=")[1].replace("\"", "").replace(";", "");
-            if (StringUtils.equals(resp, "FAILED")) {
-                return null;
-            }
-            String[] values = resp.split(",");
-
-            // 股票名称
-            String mc = values[0];
-            // 今开价格
-            String jk = values[1];
-            // 昨收价格
-            String zs = values[2];
-            // 现在价格
-            String xj = values[3];
-            // 最高价格
-            String zg = values[4];
-            // 最低价格
-            String zd = values[5];
-            // 总手
-            String zongshou = values[8];
-            // 金额
-            String je = values[9];
-            // 时间
-            String sj = values[values.length - 3];
-            // 日期
-            String rq = values[values.length - 4];
-
-            BigDecimal change = (new BigDecimal(xj).subtract(new BigDecimal(zs))).divide(new BigDecimal(zs), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
-            log.info("股票名称:{}, 当前价格:{}, 昨收价格:{}， 涨跌幅:{}%", mc, xj, zs, change);
-
-            StockSinaDataRecordDO stockSinaDataRecordDO = new StockSinaDataRecordDO();
-            stockSinaDataRecordDO.setName(mc);
-            stockSinaDataRecordDO.setJkPrice(new BigDecimal(jk));
-            stockSinaDataRecordDO.setZsPrice(new BigDecimal(zs));
-            stockSinaDataRecordDO.setXjPrice(new BigDecimal(xj));
-            stockSinaDataRecordDO.setZgPrice(new BigDecimal(zg));
-            stockSinaDataRecordDO.setZdPrice(new BigDecimal(zd));
-            stockSinaDataRecordDO.setZsNum(zs);
-            stockSinaDataRecordDO.setPrice(new BigDecimal(je));
-            stockSinaDataRecordDO.setUpdateTime(LocalDateTime.now());
-            return stockSinaDataRecordDO;
-        }
-        return null;
-    }
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/common/constants/UrlConstant.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/common/constants/UrlConstant.java
@@ -1,12 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.common.constants;
-
-public class UrlConstant {
-
-    public final static String BASE_URL = "https://gnshyx.cloudgn.com";
-
-    public final static String URL_PREFIX = "/prod-api";
-
-    public final static String LAST_PRICE = BASE_URL + "/price/lastprice";
-
-    public final static String LAST_LIST =  BASE_URL + URL_PREFIX + "/public/stockDailySelection/listLast";
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/entity/StockGnshyxRecordDataDO.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/entity/StockGnshyxRecordDataDO.java
@@ -1,78 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.entity;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.math.BigDecimal;
-import java.time.LocalDateTime;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class StockGnshyxRecordDataDO {
-    /**
-     * id
-     */
-    private Long id;
-
-    /**
-     * 名称
-     */
-    private String symbolName;
-
-    /**
-     * 股票名称
-     */
-    private String stockName;
-
-    /**
-     * 目标价格
-     */
-    private BigDecimal attentionPrice;
-
-    /**
-     * 关注价格低位
-     */
-    private BigDecimal targetPriceLow;
-
-    /**
-     * 关注价格高位
-     */
-    private BigDecimal targetPriceHigh;
-
-    /**
-     * 止损价位
-     */
-    private BigDecimal stopPrice;
-
-    /**
-     * 系统每日选择id
-     */
-    private Long stockDailySelectionId;
-
-    /**
-     * 股票代码
-     */
-    private String stockCode;
-
-    /**
-     * 生成时间
-     */
-    private LocalDateTime selectionTime;
-
-    /**
-     * maximum_increase
-     */
-    private String maximumIncrease;
-
-    /**
-     * maximum_increase_seven
-     */
-    private String maximumIncreaseSeven;
-
-    /**
-     * 创建时间
-     */
-    private LocalDateTime createTime;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/entity/resp/GnshyxBaseResp.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/entity/resp/GnshyxBaseResp.java
@@ -1,21 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.entity.resp;
-
-import com.alibaba.fastjson.annotation.JSONField;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class GnshyxBaseResp {
-
-    private Integer code;
-
-    private String msg;
-
-    @JSONField(name = "server_time")
-    private Long serverTime;
-
-    private String data;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/entity/resp/ListLastDataResp.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/entity/resp/ListLastDataResp.java
@@ -1,63 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.entity.resp;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.math.BigDecimal;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ListLastDataResp {
-
-    /**
-     * 选择id
-     */
-    private Long stockDailySelectionId;
-
-    /**
-     * 股票代码
-     */
-    private String stockCode;
-
-    /**
-     * 股票名称
-     */
-    private String stockName;
-
-    /**
-     * 标识名称
-     */
-    private String symbolName;
-
-    /**
-     * 目标价格
-     */
-    private BigDecimal attentionPrice;
-
-    /**
-     * 关注价格低位
-     */
-    private BigDecimal targetPriceLow;
-
-    /**
-     * 关注价格高位
-     */
-    private BigDecimal targetPriceHigh;
-
-    /**
-     * 止损价格
-     */
-    private BigDecimal stopPrice;
-
-
-    private String maximumIncrease;
-
-    private String maximumIncreaseSeven;
-
-    /**
-     * 生成时间
-     */
-    private String selectionTime;
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/enums/GnshyxUrlEnum.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/enums/GnshyxUrlEnum.java
@@ -1,6 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.enums;
-
-public enum GnshyxUrlEnum {
-
-
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/mapper/StockGnshyxRecordDataMapper.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/mapper/StockGnshyxRecordDataMapper.java
@@ -1,29 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.mapper;
-
-import com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO;
-import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Param;
-import org.springframework.stereotype.Repository;
-
-import java.util.List;
-
-@Repository
-@Mapper
-public interface StockGnshyxRecordDataMapper {
-
-    /**
-     * 批量新增
-     * @param entities
-     * @return
-     */
-    int batchInsertRecord(@Param("list") List<StockGnshyxRecordDataDO> entities);
-
-    List<StockGnshyxRecordDataDO> getList();
-
-
-    int insert(StockGnshyxRecordDataDO entity);
-
-    StockGnshyxRecordDataDO getByStockCode(@Param("stockCode") String stockCode);
-
-    int update(StockGnshyxRecordDataDO entity);
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/schedule/CloudRecordDataJob.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/schedule/CloudRecordDataJob.java
@@ -1,82 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.schedule;
-
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
-import com.xiang.xservice.basic.utils.DateUtils;
-import com.xiang.xservice.basic.utils.HttpUtils;
-import com.xiang.xservice.application.script.stock.gnshyx.common.constants.UrlConstant;
-import com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO;
-import com.xiang.xservice.application.script.stock.gnshyx.entity.resp.ListLastDataResp;
-import com.xiang.xservice.application.script.stock.gnshyx.service.ICloudRecordDataService;
-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.time.LocalDateTime;
-import java.util.List;
-import java.util.Objects;
-
-@Slf4j
-@RequiredArgsConstructor
-@Component
-public class CloudRecordDataJob {
-
-    private final ICloudRecordDataService cloudRecordDataService;
-
-    @Scheduled(cron = "0 30 9,14 * * ?")
-    public void gnshyxRecordDataPullJob() {
-        log.info("<<<<<gnshyx数据拉取定时任务开始>>>>>， 时间戳:{}", System.currentTimeMillis());
-
-        String resp = HttpUtils.doGet(UrlConstant.LAST_LIST, null, null);
-        if (StringUtils.isBlank(resp)) {
-            log.error("{}请求失败，响应结果为空, time:{}", UrlConstant.LAST_LIST, System.currentTimeMillis());
-            return;
-        }
-        JSONObject jsonObject = JSONObject.parseObject(resp);
-        Integer code = (Integer) jsonObject.get("code");
-        if (200 == code) {
-            String data = JSON.toJSONString(jsonObject.get("data"));
-            log.info("查询到的数据结果:{}", data);
-            List<ListLastDataResp> dataRespList = JSON.parseArray(data, ListLastDataResp.class);
-            if (CollectionUtils.isNotEmpty(dataRespList)) {
-                for (ListLastDataResp listLastDataResp : dataRespList) {
-                    StockGnshyxRecordDataDO stock = cloudRecordDataService.getByStockCode(listLastDataResp.getStockCode());
-                    if (Objects.nonNull(stock)) {
-                        stock.setSymbolName(listLastDataResp.getSymbolName());
-                        stock.setStockName(listLastDataResp.getStockName());
-                        stock.setAttentionPrice(listLastDataResp.getAttentionPrice());
-                        stock.setTargetPriceLow(listLastDataResp.getTargetPriceLow());
-                        stock.setTargetPriceHigh(listLastDataResp.getTargetPriceHigh());
-                        stock.setStopPrice(listLastDataResp.getStopPrice());
-                        stock.setStockDailySelectionId(listLastDataResp.getStockDailySelectionId());
-                        stock.setStockCode(listLastDataResp.getStockCode());
-                        stock.setSelectionTime(DateUtils.getDateTimeFromStr(listLastDataResp.getSelectionTime()));
-                        stock.setMaximumIncrease(listLastDataResp.getMaximumIncrease());
-                        stock.setMaximumIncreaseSeven(listLastDataResp.getMaximumIncreaseSeven());
-                        stock.setCreateTime(LocalDateTime.now());
-                        cloudRecordDataService.updateRecord(stock);
-                    } else {
-                        StockGnshyxRecordDataDO stockGnshyxRecordDataDO = new StockGnshyxRecordDataDO();
-                        stockGnshyxRecordDataDO.setSymbolName(listLastDataResp.getSymbolName());
-                        stockGnshyxRecordDataDO.setStockName(listLastDataResp.getStockName());
-                        stockGnshyxRecordDataDO.setAttentionPrice(listLastDataResp.getAttentionPrice());
-                        stockGnshyxRecordDataDO.setTargetPriceLow(listLastDataResp.getTargetPriceLow());
-                        stockGnshyxRecordDataDO.setTargetPriceHigh(listLastDataResp.getTargetPriceHigh());
-                        stockGnshyxRecordDataDO.setStopPrice(listLastDataResp.getStopPrice());
-                        stockGnshyxRecordDataDO.setStockDailySelectionId(listLastDataResp.getStockDailySelectionId());
-                        stockGnshyxRecordDataDO.setStockCode(listLastDataResp.getStockCode());
-                        stockGnshyxRecordDataDO.setSelectionTime(DateUtils.getDateTimeFromStr(listLastDataResp.getSelectionTime()));
-                        stockGnshyxRecordDataDO.setMaximumIncrease(listLastDataResp.getMaximumIncrease());
-                        stockGnshyxRecordDataDO.setMaximumIncreaseSeven(listLastDataResp.getMaximumIncreaseSeven());
-                        stockGnshyxRecordDataDO.setCreateTime(LocalDateTime.now());
-                        cloudRecordDataService.insertRecord(stockGnshyxRecordDataDO);
-                    }
-
-                }
-            }
-        }
-    }
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/service/CloudRecordDataServiceImpl.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/service/CloudRecordDataServiceImpl.java
@@ -1,39 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.service;
-
-import com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO;
-import com.xiang.xservice.application.script.stock.gnshyx.mapper.StockGnshyxRecordDataMapper;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-
-@Service
-@RequiredArgsConstructor
-public class CloudRecordDataServiceImpl implements ICloudRecordDataService {
-    private final StockGnshyxRecordDataMapper stockGnshyxRecordDataMapper;
-
-    @Override
-    public Boolean insertRecord(StockGnshyxRecordDataDO entity) {
-        return stockGnshyxRecordDataMapper.insert(entity) > 0;
-    }
-
-    @Override
-    public Boolean batchInsertRecord(List<StockGnshyxRecordDataDO> list) {
-        return stockGnshyxRecordDataMapper.batchInsertRecord(list) > 0;
-    }
-
-    @Override
-    public List<StockGnshyxRecordDataDO> getList() {
-        return stockGnshyxRecordDataMapper.getList();
-    }
-
-    @Override
-    public Boolean updateRecord(StockGnshyxRecordDataDO entity) {
-        return stockGnshyxRecordDataMapper.update(entity) > 0;
-    }
-
-    @Override
-    public StockGnshyxRecordDataDO getByStockCode(String stockCode) {
-        return stockGnshyxRecordDataMapper.getByStockCode(stockCode);
-    }
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/service/ICloudRecordDataService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/stock/gnshyx/service/ICloudRecordDataService.java
@@ -1,18 +0,0 @@
-package com.xiang.xservice.application.script.stock.gnshyx.service;
-
-import com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO;
-
-import java.util.List;
-
-public interface ICloudRecordDataService {
-
-    Boolean insertRecord(StockGnshyxRecordDataDO entity);
-
-    Boolean batchInsertRecord(List<StockGnshyxRecordDataDO> list);
-
-    List<StockGnshyxRecordDataDO> getList();
-
-    Boolean updateRecord(StockGnshyxRecordDataDO entity);
-
-    StockGnshyxRecordDataDO getByStockCode(String stockCode);
-}
--- a/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundInfoQueryJob.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/xb/schedule/xb/FundInfoQueryJob.java
@@ -3,18 +3,18 @@ package com.xiang.xservice.application.script.xb.schedule.xb;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson2.JSONObject;
 import com.google.common.collect.Lists;
-import com.xiang.xservice.basic.config.MyThreadFactory;
-import com.xiang.xservice.basic.utils.DateUtils;
-import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService;
-import com.xiang.xservice.cache.service.IRedisService;
-import com.xiang.xservice.common.entity.DayResult;
-import com.xiang.xservice.common.enums.RedisConstant;
+import com.xiang.xmc.service.cache.service.IRedisService;
+import com.xiang.xmc.service.message.dingTalk.service.DingTalkService;
 import com.xiang.xservice.application.script.xb.entity.pojo.xb.FundMessage;
 import com.xiang.xservice.application.script.xb.entity.pojo.xb.XbFundList;
 import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundInfo;
 import com.xiang.xservice.application.script.xb.entity.response.xbyj.fund.FundList;
 import com.xiang.xservice.application.script.xb.repository.XBFundMapper;
 import com.xiang.xservice.application.script.xb.service.FundService;
+import com.xiang.xservice.basic.config.MyThreadFactory;
+import com.xiang.xservice.basic.utils.DateUtils;
+import com.xiang.xservice.common.entity.DayResult;
+import com.xiang.xservice.common.enums.RedisConstant;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
@@ -75,8 +75,9 @@ public class FundInfoQueryJob {
        // 周六周日过滤
        if (DateUtils.validWeekTime()) return;
        LocalDate now = LocalDate.now();
-        String dayResult = (String) redisService.hGet(RedisConstant.DAY_INFO_PREFIX_KEY, DateUtils.getDateFromDate(now));
-        if (com.xiang.xservice.common.utils.DateUtils.validHoliday(JSON.parseObject(dayResult, DayResult.class))) return;
+        com.alibaba.fastjson.JSONObject dayResult = (com.alibaba.fastjson.JSONObject) redisService.hGet(RedisConstant.DAY_INFO_PREFIX_KEY + RedisConstant.getDate4Key(), DateUtils.getDateFromDate(now));
+        com.xiang.xservice.common.utils.DateUtils dateUtils = new com.xiang.xservice.common.utils.DateUtils(redisService);
+        if (dateUtils.validHoliday(JSON.toJavaObject(dayResult, DayResult.class))) return;

        List<com.xiang.xservice.application.script.xb.entity.pojo.xb.FundInfo> fundInfos = xbFundMapper.queryListIn2Min();
        if (CollectionUtils.isEmpty(fundInfos)) {
--- a/script/src/main/java/com/xiang/xservice/application/script/xb/service/DingTalkRobotService.java
+++ b/script/src/main/java/com/xiang/xservice/application/script/xb/service/DingTalkRobotService.java
@@ -1,6 +1,6 @@
 package com.xiang.xservice.application.script.xb.service;

-import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService;
+import com.xiang.xmc.service.message.dingTalk.service.DingTalkService;
 import com.xiang.xservice.config.DingTalkRobotXbConfig;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
--- a/script/src/main/java/com/xiang/xservice/common/entity/SysConfigDO.java
+++ b/script/src/main/java/com/xiang/xservice/common/entity/SysConfigDO.java
@@ -0,0 +1,23 @@
+package com.xiang.xservice.common.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: xiang
+ * @Date: 2025-12-08 16:39
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class SysConfigDO{
+
+    private Long id;
+    private String name;
+    private String value;
+    private Integer status;
+    private LocalDateTime createTime;
+}
--- a/script/src/main/java/com/xiang/xservice/common/mapper/SysConfigMapper.java
+++ b/script/src/main/java/com/xiang/xservice/common/mapper/SysConfigMapper.java
@@ -0,0 +1,18 @@
+package com.xiang.xservice.common.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.xiang.xservice.common.entity.SysConfigDO;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @Author: xiang
+ * @Date: 2025-12-08 17:01
+ */
+@Mapper
+@Repository
+public interface SysConfigMapper extends BaseMapper<SysConfigDO> {
+
+    SysConfigDO getByName(@Param("name") String name);
+}
--- a/script/src/main/java/com/xiang/xservice/common/schedule/HolidayQueryJob.java
+++ b/script/src/main/java/com/xiang/xservice/common/schedule/HolidayQueryJob.java
@@ -3,9 +3,9 @@ package com.xiang.xservice.common.schedule;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Maps;
+import com.xiang.xmc.service.cache.service.IRedisService;
 import com.xiang.xservice.basic.utils.DateUtils;
 import com.xiang.xservice.basic.utils.HttpUtils;
-import com.xiang.xservice.cache.service.IRedisService;
 import com.xiang.xservice.common.entity.DayResult;
 import com.xiang.xservice.common.enums.RedisConstant;
 import com.xiang.xservice.common.enums.UrlConstant;
--- a/script/src/main/java/com/xiang/xservice/common/service/ISysConfigService.java
+++ b/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);
+}
--- a/script/src/main/java/com/xiang/xservice/common/service/SysConfigServiceImpl.java
+++ b/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);
+    }
+}
--- a/script/src/main/java/com/xiang/xservice/common/utils/DateUtils.java
+++ b/script/src/main/java/com/xiang/xservice/common/utils/DateUtils.java
@@ -1,16 +1,44 @@
 package com.xiang.xservice.common.utils;


+import com.xiang.xmc.service.cache.service.IRedisService;
 import com.xiang.xservice.common.entity.DayResult;
+import lombok.AllArgsConstructor;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;

 /**
 * @Author: xiang
 * @Date: 2025-10-04 10:34
 */
+@Slf4j
+@RequiredArgsConstructor
+@AllArgsConstructor
 public class DateUtils {

-    public static Boolean validHoliday(DayResult result) {
-        return com.xiang.xservice.basic.utils.DateUtils.validHolidayTime(
-                result.getDate(), result.getStatusDesc(), result.getWeek(), result.getStatus());
+    private IRedisService redisService;
+    public Boolean validHoliday(DayResult result) {
+        if (validHolidayTime(result.getDate(), result.getStatusDesc(), result.getWeek(), result.getStatus()))
+            return Boolean.TRUE;
+        return Boolean.FALSE;
+    }
+
+    private Boolean validHolidayTime(String date, String statusDesc, String week, String status) {
+        if (StringUtils.equals(status, "1")) {
+            return Boolean.TRUE;
+        }
+        if (StringUtils.equals(status, "2")) {
+            log.info("当前日期:{}, {}, 是工作日", date, week);
+            return Boolean.FALSE;
+        }
+        if (StringUtils.isEmpty(status)) {
+            if (StringUtils.equals(week, "周六") || StringUtils.equals(week, "周日")) {
+                log.info("当前日期:{}, {}, 是周末", date, week);
+                return Boolean.TRUE;
+            }
+            return Boolean.FALSE;
+        }
+        return Boolean.TRUE;
    }
 }
--- a/script/src/main/java/com/xiang/xservice/config/DingTalkRobotVenueConfig.java
+++ b/script/src/main/java/com/xiang/xservice/config/DingTalkRobotVenueConfig.java
@@ -0,0 +1,20 @@
+package com.xiang.xservice.config;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2025-12-15 15:20
+ */
+@ConfigurationProperties(prefix = "dingtalk.robot.venue")
+@Getter
+@Setter
+public class DingTalkRobotVenueConfig {
+    private String token;
+    private String secret;
+    private List<String> users;
+}
--- a/script/src/main/resources/application-local.yml
+++ b/script/src/main/resources/application-local.yml
@@ -12,16 +12,16 @@ spring:
      primary: master
      datasource:
        master:
-          url: jdbc:mysql://rm-bp15t34gqx62jm069ro.mysql.rds.aliyuncs.com:3306/xservice-script-test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
+          url: jdbc:mysql://120.27.153.87:3306/xservice-script-test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
          username: root
-          password: xb#UWqnhH24&XpX
+          password: sdkljfikdfn@123
          driver-class-name: com.mysql.cj.jdbc.Driver
          sshConnect: false
  redis:
    host: r-bp1wt59a6nfyt4e3ltpd.redis.rds.aliyuncs.com
    port: 6379
    password: Xiang0000  # 如果无密码可以省略
-    database: 0
+    database: 10
    timeout: 5000
    lettuce:
      pool:
@@ -51,3 +51,8 @@ dingtalk:
      secret: SECc09d8aad6635f1a4cbadb7c0ab365523c46299f138438cd885e445e0f5f4d730
      users:
        - 450841600726084717
+    venue:
+      token: 6a218646972c684c75832b0229ea93a234778af537d7469ce96bef290faf530e
+      secret: SEC9018755ba86d3e5c1ed2fbfa1d6953d84bb2a6c8ebe7ed4e318457bfed5e0465
+      users:
+        - 450841600726084717
--- a/script/src/main/resources/application-prod.yml
+++ b/script/src/main/resources/application-prod.yml
@@ -12,15 +12,15 @@ spring:
      primary: master
      datasource:
        master:
-          url: jdbc:mysql://192.168.2.10:3306/xservice-script?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
-          username: root
-          password: Admin@123
+          url: jdbc:mysql://rm-bp15t34gqx62jm069ro.mysql.rds.aliyuncs.com:3306/xservice-script?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
+          username: xservice
+          password: xb#UWqnhH24&XpX
          driver-class-name: com.mysql.cj.jdbc.Driver
          sshConnect: false
  redis:
-    host: 192.168.2.10
+    host: r-bp1wt59a6nfyt4e3ltpd.redis.rds.aliyuncs.com
    port: 6379
-    password: Admin@123  # 如果无密码可以省略
+    password: Xiang0000  # 如果无密码可以省略
    database: 0
    timeout: 5000
    lettuce:
@@ -53,3 +53,8 @@ dingtalk:
      secret: SECe10ade3058880b84df5c6f46ab072c11f4ac2a5ef9f134d684705c2a3b004de2
      users:
        - 450841600726084717
+    venue:
+      token: 6a218646972c684c75832b0229ea93a234778af537d7469ce96bef290faf530e
+      secret: SEC9018755ba86d3e5c1ed2fbfa1d6953d84bb2a6c8ebe7ed4e318457bfed5e0465
+      users:
+        - 450841600726084717
--- a/script/src/main/resources/application-test.yml
+++ b/script/src/main/resources/application-test.yml
@@ -12,16 +12,16 @@ spring:
      primary: master
      datasource:
        master:
-          url: jdbc:mysql://rm-bp15t34gqx62jm069ro.mysql.rds.aliyuncs.com:3306/xservice-script-test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
+          url: jdbc:mysql://120.27.153.87:3306/xservice-script-test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
          username: root
-          password: xb#UWqnhH24&XpX
+          password: sdkljfikdfn@123
          driver-class-name: com.mysql.cj.jdbc.Driver
          sshConnect: false
  redis:
    host: r-bp1wt59a6nfyt4e3ltpd.redis.rds.aliyuncs.com
    port: 6379
    password: Xiang0000 # 如果无密码可以省略
-    database: 0
+    database: 10
    timeout: 5000
    lettuce:
      pool:
--- a/script/src/main/resources/application.yml
+++ b/script/src/main/resources/application.yml
@@ -16,7 +16,7 @@ server:

 spring:
  profiles:
-    active: test
+    active: local
  application:
    name: xservice-script-center
  main:
--- a/script/src/main/resources/logback-spring.xml
+++ b/script/src/main/resources/logback-spring.xml
@@ -17,7 +17,7 @@
        <!--设置输出格式-->
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
-            <pattern>%boldGreen(%contextName): %boldCyan(%d{yyyy-MM-dd HH:mm:ss:SSS}) %highlight([%c]) %boldMagenta([%t]) %boldCyan([%L]) %highlight([traceId:%X{traceId:-},spanId:%X{spanId:-},localIp:%X{localIp:-}]) %boldGreen([%p]) - %msg%n
+            <pattern>%boldGreen(%contextName): %boldCyan(%d{yyyy-MM-dd HH:mm:ss:SSS}) %highlight([%c]) %boldMagenta([%t]) %boldCyan([%L]) %highlight([traceId:%X{traceId:-})] %boldGreen([%p]) - %msg%n
            </pattern>
            <!--设置编码-->
            <charset>UTF-8</charset>
@@ -34,7 +34,7 @@
        </rollingPolicy>
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <!--格式化输出：%d表示日期，%c类名，%t表示线程名，%L行， %p日志级别 %msg：日志消息，%n是换行符  -->
-            <pattern>%contextName: %d{yyyy-MM-dd HH:mm:ss.SSS} [%c][%t][%L][%p] [traceId:%X{traceId:-},spanId:%X{spanId:-},localIp:%X{localIp:-}] - %msg%n</pattern>
+            <pattern>%contextName: %d{yyyy-MM-dd HH:mm:ss.SSS} [%c][%t][%L][%p] [traceId:%X{traceId:-}] - %msg%n</pattern>
            <charset>UTF-8</charset>
        </encoder>
        <!-- 此日志文件只记录debug级别的 -->
@@ -55,7 +55,7 @@
        </rollingPolicy>
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <!--格式化输出：%d表示日期，%c类名，%t表示线程名，%L行， %p日志级别 %msg：日志消息，%n是换行符  -->
-            <pattern>%contextName: %d{yyyy-MM-dd HH:mm:ss.SSS} [%c][%t][%L][%p] [traceId:%X{traceId:-},spanId:%X{spanId:-},localIp:%X{localIp:-}] - %msg%n</pattern>
+            <pattern>%contextName: %d{yyyy-MM-dd HH:mm:ss.SSS} [%c][%t][%L][%p] [traceId:%X{traceId:-}] - %msg%n</pattern>
            <charset>UTF-8</charset>
        </encoder>

@@ -77,7 +77,7 @@
        </rollingPolicy>
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <!--格式化输出：%d表示日期，%c类名，%t表示线程名，%L行， %p日志级别 %msg：日志消息，%n是换行符  -->
-            <pattern>%contextName: %d{yyyy-MM-dd HH:mm:ss.SSS} [%c][%t][%L][%p] [traceId:%X{traceId:-},spanId:%X{spanId:-},localIp:%X{localIp:-}] - %msg%n</pattern>
+            <pattern>%contextName: %d{yyyy-MM-dd HH:mm:ss.SSS} [%c][%t][%L][%p] [traceId:%X{traceId:-}] - %msg%n</pattern>
            <charset>UTF-8</charset>
        </encoder>
        <!-- 此日志文件只记录error级别的 -->
--- a/script/src/main/resources/mapper/SysConfigMapper.xml
+++ b/script/src/main/resources/mapper/SysConfigMapper.xml
@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.xiang.xservice.common.mapper.SysConfigMapper">
+
+    <resultMap id="BaseResultMap" type="com.xiang.xservice.common.entity.SysConfigDO" >
+        <result column="id" property="id"/>
+        <result column="name" property="name" />
+        <result column="value" property="value" />
+        <result column="status" property="status" />
+        <result column="create_time" property="createTime" />
+    </resultMap>
+
+    <sql id="Base_sql">
+        id,
+        name,
+        value,
+        status,
+        create_time
+    </sql>
+
+    <select id="getByName" resultMap="BaseResultMap" parameterType="String">
+        select <include refid="Base_sql"/>
+        from sys_config
+        where name = #{name} and status = 1
+    </select>
+
+
+</mapper>
--- a/script/src/main/resources/mapper/fwd/FwdAudienceConfigMapper.xml
+++ b/script/src/main/resources/mapper/fwd/FwdAudienceConfigMapper.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.fwd.mapper.FwdAudienceConfigMapper">
+<mapper namespace="com.xiang.xservice.application.script.fwd.mapper.FwdAudienceConfigMapper">

    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.fwd.entity.pojo.FAudienceConfig">
        <result column="id" property="id"/>
--- a/script/src/main/resources/mapper/fwd/FwdPerformConfigMapper.xml
+++ b/script/src/main/resources/mapper/fwd/FwdPerformConfigMapper.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.fwd.mapper.FwdPerformConfigMapper">
+<mapper namespace="com.xiang.xservice.application.script.fwd.mapper.FwdPerformConfigMapper">

    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.fwd.entity.pojo.FPerformConfig" >
        <result column="id" property="id"/>
--- a/script/src/main/resources/mapper/fwd/FwdPerformProjectInfoMapper.xml
+++ b/script/src/main/resources/mapper/fwd/FwdPerformProjectInfoMapper.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.fwd.mapper.FwdPerformProjectInfoMapper">
+<mapper namespace="com.xiang.xservice.application.script.fwd.mapper.FwdPerformProjectInfoMapper">

    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.fwd.entity.pojo.FPerformProjectInfo" >
        <result column="id" property="id"/>
--- a/script/src/main/resources/mapper/fwd/FwdPerformProjectSeatInfoMapper.xml
+++ b/script/src/main/resources/mapper/fwd/FwdPerformProjectSeatInfoMapper.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.fwd.mapper.FwdPerformSeatInfoMapper">
+<mapper namespace="com.xiang.xservice.application.script.fwd.mapper.FwdPerformSeatInfoMapper">

    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.fwd.entity.pojo.FPerformSeatInfo" >
        <result column="id" property="id"/>
--- a/script/src/main/resources/mapper/fwd/FwdUserConfigMapper.xml
+++ b/script/src/main/resources/mapper/fwd/FwdUserConfigMapper.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.fwd.mapper.FwdUserConfigMapper">
+<mapper namespace="com.xiang.xservice.application.script.fwd.mapper.FwdUserConfigMapper">

    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.fwd.entity.pojo.FUserConfig" >
        <result column="id" property="id"/>
--- a/script/src/main/resources/mapper/glados/GladosMapper.xml
+++ b/script/src/main/resources/mapper/glados/GladosMapper.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.glados.repository.GladosMapper">
+<mapper namespace="com.xiang.xservice.application.script.glados.repository.GladosMapper">

    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.xb.entity.pojo.User" >
        <result column="id" property="id"/>
--- a/script/src/main/resources/mapper/stock/StockGnshyxRecordDataMapper.xml
+++ b/script/src/main/resources/mapper/stock/StockGnshyxRecordDataMapper.xml
@@ -1,183 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
-        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.stock.gnshyx.mapper.StockGnshyxRecordDataMapper">
-
-    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO" >
-        <result column="id" property="id" />
-        <result column="symbol_name" property="symbolName" />
-        <result column="stock_name" property="stockName" />
-        <result column="attention_price" property="attentionPrice" />
-        <result column="target_price_low" property="targetPriceLow" />
-        <result column="target_price_high" property="targetPriceHigh" />
-        <result column="stop_price" property="stopPrice" />
-        <result column="stock_daily_selection_id" property="stockDailySelectionId" />
-        <result column="stock_code" property="stockCode" />
-        <result column="selection_time" property="selectionTime" />
-        <result column="maximum_increase" property="maximumIncrease" />
-        <result column="maximum_increase_seven" property="maximumIncreaseSeven" />
-        <result column="create_time" property="createTime" />
-    </resultMap>
-
-    <sql id="Base_Column_List">
-        id,
-        symbol_name,
-        stock_name,
-        attention_price,
-        target_price_low,
-        target_price_high,
-        stop_price,
-        stock_daily_selection_id,
-        stock_code,
-        selection_time,
-        maximum_increase,
-        maximum_increase_seven,
-        create_time
-    </sql>
-
-    <insert id="insert" useGeneratedKeys="true" keyColumn="id" keyProperty="id" parameterType="com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO">
-        INSERT INTO stock_gnshyx_record_data
-        <trim prefix="(" suffix=")" suffixOverrides=",">
-            <if test="null != symbolName and '' != symbolName">
-                symbol_name,
-            </if>
-            <if test="null != stockName and '' != stockName">
-                stock_name,
-            </if>
-            <if test="null != attentionPrice ">
-                attention_price,
-            </if>
-            <if test="null != targetPriceLow ">
-                target_price_low,
-            </if>
-            <if test="null != targetPriceHigh ">
-                target_price_high,
-            </if>
-            <if test="null != stopPrice ">
-                stop_price,
-            </if>
-            <if test="null != stockDailySelectionId ">
-                stock_daily_selection_id,
-            </if>
-            <if test="null != stockCode and '' != stockCode">
-                stock_code,
-            </if>
-            <if test="null != selectionTime ">
-                selection_time,
-            </if>
-            <if test="null != maximumIncrease and '' != maximumIncrease">
-                maximum_increase,
-            </if>
-            <if test="null != maximumIncreaseSeven and '' != maximumIncreaseSeven">
-                maximum_increase_seven,
-            </if>
-            <if test="null != createTime ">
-                create_time
-            </if>
-        </trim>
-        <trim prefix="values (" suffix=")" suffixOverrides=",">
-            <if test="null != symbolName and '' != symbolName">
-                #{symbolName},
-            </if>
-            <if test="null != stockName and '' != stockName">
-                #{stockName},
-            </if>
-            <if test="null != attentionPrice ">
-                #{attentionPrice},
-            </if>
-            <if test="null != targetPriceLow ">
-                #{targetPriceLow},
-            </if>
-            <if test="null != targetPriceHigh ">
-                #{targetPriceHigh},
-            </if>
-            <if test="null != stopPrice ">
-                #{stopPrice},
-            </if>
-            <if test="null != stockDailySelectionId ">
-                #{stockDailySelectionId},
-            </if>
-            <if test="null != stockCode and '' != stockCode">
-                #{stockCode},
-            </if>
-            <if test="null != selectionTime ">
-                #{selectionTime},
-            </if>
-            <if test="null != maximumIncrease and '' != maximumIncrease">
-                #{maximumIncrease},
-            </if>
-            <if test="null != maximumIncreaseSeven and '' != maximumIncreaseSeven">
-                #{maximumIncreaseSeven},
-            </if>
-            <if test="null != createTime ">
-                #{createTime}
-            </if>
-        </trim>
-    </insert>
-    <insert id="batchInsertRecord">
-        insert into stock_gnshyx_record_data(symbol_name,
-                                             stock_name,
-                                             attention_price,
-                                             target_price_low,
-                                             target_price_high,
-                                             stop_price,
-                                             stock_daily_selection_id,
-                                             stock_code,
-                                             selection_time,
-                                             maximum_increase,
-                                             maximum_increase_seven,
-                                             create_time)
-        values
-        <foreach collection="list" item="item" separator=",">
-            (
-            #{item.symbolName},
-            #{item.stockName},
-            #{item.attentionPrice},
-            #{item.targetPriceLow},
-            #{item.targetPriceHigh},
-            #{item.stopPrice},
-            #{item.stockDailySelectionId},
-            #{item.stockCode},
-            #{item.selectionTime},
-            #{item.maximumIncrease},
-            #{item.maximumIncreaseSeven},
-            #{item.createTime}
-            )
-        </foreach>
-
-    </insert>
-
-    <delete id="delete" >
-        DELETE FROM stock_gnshyx_record_data
-        WHERE id = #{id}
-    </delete>
-    <select id="getList" resultMap="BaseResultMap">
-        select <include refid="Base_Column_List"/>
-        from stock_gnshyx_record_data where 1=1
-    </select>
-    <select id="getByStockCode" resultMap="BaseResultMap">
-        select <include refid="Base_Column_List"/>
-        from stock_gnshyx_record_data where stock_code = #{stockCode}
-    </select>
-
-    <update id="update" parameterType="com.xiang.xservice.application.script.stock.gnshyx.entity.StockGnshyxRecordDataDO">
-        UPDATE stock_gnshyx_record_data
-        <set>
-            <if test="null != symbolName and '' != symbolName">symbol_name = #{symbolName},</if>
-            <if test="null != stockName and '' != stockName">stock_name = #{stockName},</if>
-            <if test="null != attentionPrice ">attention_price = #{attentionPrice},</if>
-            <if test="null != targetPriceLow ">target_price_low = #{targetPriceLow},</if>
-            <if test="null != targetPriceHigh ">target_price_high = #{targetPriceHigh},</if>
-            <if test="null != stopPrice ">stop_price = #{stopPrice},</if>
-            <if test="null != stockDailySelectionId ">stock_daily_selection_id = #{stockDailySelectionId},</if>
-            <if test="null != stockCode and '' != stockCode">stock_code = #{stockCode},</if>
-            <if test="null != selectionTime ">selection_time = #{selectionTime},</if>
-            <if test="null != maximumIncrease and '' != maximumIncrease">maximum_increase = #{maximumIncrease},</if>
-            <if test="null != maximumIncreaseSeven and '' != maximumIncreaseSeven">maximum_increase_seven = #{maximumIncreaseSeven},</if>
-            <if test="null != createTime ">create_time = #{createTime}</if>
-        </set>
-        WHERE id = #{id}
-    </update>
-
-
-</mapper>
--- a/script/src/main/resources/mapper/stock/StockSinaDataRecordPullMapper.xml
+++ b/script/src/main/resources/mapper/stock/StockSinaDataRecordPullMapper.xml
@@ -1,126 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
-        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.stock.data.mapper.StockSinaDataRecordPullMapper">
-
-    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.stock.data.entity.StockSinaDataRecordDO" >
-        <result column="id" property="id" />
-        <result column="name" property="name" />
-        <result column="jk_price" property="jkPrice" />
-        <result column="zs_price" property="zsPrice" />
-        <result column="xj_price" property="xjPrice" />
-        <result column="zg_price" property="zgPrice" />
-        <result column="zd_price" property="zdPrice" />
-        <result column="zs_num" property="zsNum" />
-        <result column="price" property="price" />
-        <result column="update_time" property="updateTime" />
-    </resultMap>
-
-    <sql id="Base_Column_List">
-        id,
-        name,
-        jk_price,
-        zs_price,
-        xj_price,
-        zg_price,
-        zd_price,
-        zs_num,
-        price,
-        update_time
-    </sql>
-
-    <insert id="insert" useGeneratedKeys="true" keyColumn="id" keyProperty="id" parameterType="com.xiang.xservice.application.script.stock.data.entity.StockSinaDataRecordDO">
-        INSERT INTO stock_sina_record_data
-        <trim prefix="(" suffix=")" suffixOverrides=",">
-            <if test="null != name and '' != name">
-                name,
-            </if>
-            <if test="null != jkPrice ">
-                jk_price,
-            </if>
-            <if test="null != zsPrice ">
-                zs_price,
-            </if>
-            <if test="null != xjPrice ">
-                xj_price,
-            </if>
-            <if test="null != zgPrice ">
-                zg_price,
-            </if>
-            <if test="null != zdPrice ">
-                zd_price,
-            </if>
-            <if test="null != zsNum and '' != zsNum">
-                zs_num,
-            </if>
-            <if test="null != price ">
-                price,
-            </if>
-            <if test="null != updateTime ">
-                update_time
-            </if>
-        </trim>
-        <trim prefix="values (" suffix=")" suffixOverrides=",">
-            <if test="null != name and '' != name">
-                #{name},
-            </if>
-            <if test="null != jkPrice ">
-                #{jkPrice},
-            </if>
-            <if test="null != zsPrice ">
-                #{zsPrice},
-            </if>
-            <if test="null != xjPrice ">
-                #{xjPrice},
-            </if>
-            <if test="null != zgPrice ">
-                #{zgPrice},
-            </if>
-            <if test="null != zdPrice ">
-                #{zdPrice},
-            </if>
-            <if test="null != zsNum and '' != zsNum">
-                #{zsNum},
-            </if>
-            <if test="null != price ">
-                #{price},
-            </if>
-            <if test="null != updateTime ">
-                #{updateTime}
-            </if>
-        </trim>
-    </insert>
-    <insert id="batchInsert">
-        INSERT INTO stock_sina_record_data
-        (name, jk_price, zs_price, xj_price, zg_price, zd_price, zs_num, price, update_time)
-        VALUES
-        <foreach collection="list" item="item" separator=",">
-            (#{item.name}, #{item.jkPrice}, #{item.zsPrice}, #{item.xjPrice},
-            #{item.zgPrice}, #{item.zdPrice}, #{item.zsNum}, #{item.price}, #{item.updateTime})
-        </foreach>
-    </insert>
-
-    <delete id="delete" >
-        DELETE FROM stock_sina_record_data
-        WHERE id = #{id}
-    </delete>
-
-    <update id="update" parameterType="com.xiang.xservice.application.script.stock.data.entity.StockSinaDataRecordDO">
-        UPDATE stock_sina_record_data
-        <set>
-            <if test="null != name and '' != name">name = #{name},</if>
-            <if test="null != jkPrice ">jk_price = #{jkPrice},</if>
-            <if test="null != zsPrice ">zs_price = #{zsPrice},</if>
-            <if test="null != xjPrice ">xj_price = #{xjPrice},</if>
-            <if test="null != zgPrice ">zg_price = #{zgPrice},</if>
-            <if test="null != zdPrice ">zd_price = #{zdPrice},</if>
-            <if test="null != zsNum and '' != zsNum">zs_num = #{zsNum},</if>
-            <if test="null != price ">price = #{price},</if>
-            <if test="null != updateTime ">update_time = #{updateTime}</if>
-        </set>
-        WHERE id = #{id}
-    </update>
-
-
-
-</mapper>
--- a/script/src/main/resources/mapper/xb/XBFundMapper.xml
+++ b/script/src/main/resources/mapper/xb/XBFundMapper.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.xiang.xservice.xb.repository.XBFundMapper">
+<mapper namespace="com.xiang.xservice.application.script.xb.repository.XBFundMapper">

    <resultMap id="BaseResultMap" type="com.xiang.xservice.application.script.xb.entity.pojo.xb.FundInfo" >
        <result column="id" property="id"/>
Author	SHA1	Message	Date
Xiang	217dc6879d	fix:glados签到脚本	2026-01-23 09:58:46 +08:00
Xiang	12728d5c84	fix:glados签到球服	2026-01-23 09:35:38 +08:00
Xiang	8928c076c5	fix:glados域名修复	2026-01-23 09:06:17 +08:00
xiang	ec6723070f	feat:清理代码	2026-01-15 23:34:26 +08:00
xiang	5b9ac21ecf	fix：消息重复发送	2025-12-18 19:21:42 +08:00
Xiang	f3637a80f2	feat：token 更新消息	2025-12-18 10:30:45 +08:00
Xiang	4bc549eebe	fix:token接口，数据获取	2025-12-18 10:11:32 +08:00
Xiang	237fcc7139	fix:token接口，数据获取	2025-12-18 09:28:07 +08:00
Xiang	4277106d00	fix:数据拉取	2025-12-17 09:02:22 +08:00
Xiang	7932222f8e	style:代码格式	2025-12-17 08:41:41 +08:00
Xiang	6d19b1a021	fix: 获取token	2025-12-17 08:41:10 +08:00
xiang	57a28b4049	fix：拉取jt场地数据	2025-12-16 22:38:54 +08:00
Xiang	a3c9e2eb51	feat:下单查询	2025-12-16 16:24:52 +08:00
Xiang	93969624c1	feat:下单定时任务	2025-12-16 14:38:52 +08:00
Xiang	4904be16da	feat:捡漏下单	2025-12-16 11:28:21 +08:00
Xiang	c4915b17c8	feat:订单创建	2025-12-16 11:04:51 +08:00
Xiang	7fce8c91f2	feat:订单创建	2025-12-16 10:57:36 +08:00
Xiang	d942b31c8b	feat:用户token更新	2025-12-16 09:49:40 +08:00
Xiang	d7b49281c1	feat:用户token更新	2025-12-16 09:48:50 +08:00
Xiang	c6817b23fc	feat:用户token更新	2025-12-16 09:43:02 +08:00
Xiang	69257b5c80	feat:场地查询	2025-12-15 17:32:40 +08:00
Xiang	1cd24c78e7	feat:场地查询	2025-12-15 17:20:39 +08:00
Xiang	12c4ccdd5d	fear:场地查询	2025-12-15 16:29:28 +08:00
Xiang	d5c096e7a5	fix:场地信息消息构建BUG	2025-12-15 15:37:04 +08:00
Xiang	b7ecbdfa7a	feat：定时任务查询	2025-12-15 15:28:35 +08:00
Xiang	454d93b5cc	feat：查询江体小程序场地信息	2025-12-15 14:47:14 +08:00
xiang	fd30c72a73	fix：修复	2025-12-13 18:29:55 +08:00
xiang	48590d5d26	fix：修复	2025-12-13 18:29:21 +08:00
xiang	56df38d7c5	Merge remote-tracking branch 'origin/perf/script_app_perf_1208'	2025-12-13 18:20:28 +08:00
xiang	8fbc83bf06	fix：配置文件修改	2025-12-13 18:07:58 +08:00
Xiang	d3920fe6c2	style:删除无用代码	2025-12-09 11:22:33 +08:00
Xiang	1b6b48e8df	doc: 注释	2025-12-09 11:21:59 +08:00
Xiang	2e2e69f139	perf：ddns定时任务时间	2025-12-09 11:17:26 +08:00
Xiang	174b7a269c	perf:节假日holiday校验	2025-12-09 11:15:48 +08:00
Xiang	dd99d2609b	perf:glados签到优化	2025-12-09 11:09:21 +08:00
Xiang	b2b1921c32	perf:删除股票任务，优化fwd下单逻辑	2025-12-08 17:25:21 +08:00
Xiang	54afcf47fc	perf:日志模版修改	2025-11-12 17:11:48 +08:00
Xiang	2b68a860c2	perf:日志模版修改	2025-11-12 17:02:09 +08:00
Xiang	70224d4c3e	perf:下单优化	2025-11-12 16:42:35 +08:00
Xiang	422ae693b2	fix:芬玩岛数据拉取token更新	2025-11-12 16:31:56 +08:00
xiang	7c2b8f4731	fix:类型转换	2025-10-13 21:59:09 +08:00
xiang	bccf5ad774	perf:芬玩岛下单优化1.0	2025-10-10 00:12:40 +08:00
xiang	1e54ee39d4	perf:芬玩岛下单优化1.0	2025-10-09 23:26:13 +08:00
xiang	388287fc65	feat:股票数据拉取	2025-10-09 22:56:50 +08:00
xiang	e65cc97ef9	fix: 节假日校验	2025-10-06 11:20:52 +08:00
xiang	97b4b6a1a8	doc:refactor	2025-10-06 10:45:01 +08:00