46 Commits

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
74 changed files with 606 additions and 1567 deletions

29
pom.xml
View File

@@ -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>

View File

@@ -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"

View File

@@ -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 {

View File

@@ -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;

View File

@@ -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));
}
}

View File

@@ -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
*/

View File

@@ -25,4 +25,6 @@ public class ProjectOrderCreateReq {
private String blackBox;
private String combineTicketVos;
private String ordinaryTicketVos;
private Integer activityType;
private String activityId;
}

View File

@@ -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,13 +138,15 @@ 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();
dynamicTaskScheduler.schedule(
new TaskConfig(taskId, "芬玩岛演唱会抢票-【" + data.getProjectName() + "", TaskGroupEnum.SERVICE_FWD_SCHEDULE.getCode(),
runTime, params),
new TicketGrabTask(fwdUserConfigMapper, fwdAudienceConfigMapper, iPerformService,
new FwdOrderTaskParam(data.getProjectId(), taskId), dynamicTaskSchedulerService),
TimeSyncUtils.now());
savaTask(data, taskId, params);
if (flag) {
dynamicTaskScheduler.schedule(
new TaskConfig(taskId, "芬玩岛演唱会抢票-【" + data.getProjectName() + "", TaskGroupEnum.SERVICE_FWD_SCHEDULE.getCode(),
runTime, params),
new TicketGrabTask(fwdUserConfigMapper, fwdAudienceConfigMapper, iPerformService,
new FwdOrderTaskParam(data.getProjectId(), taskId), dynamicTaskSchedulerService),
TimeSyncUtils.now());
savaTask(data, taskId, params);
}
}
msg.append("请注意进行数据库配置的更改!");
dingTalkScriptFWDService.sendScriptMsg(msg.toString());
@@ -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());

View File

@@ -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失败");
}
}

View File

@@ -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);

View File

@@ -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;
}

View File

@@ -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);
}

View File

@@ -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;

View File

@@ -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();

View File

@@ -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请求查询观影人信息

View File

@@ -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);
log.info("触发FWD限流机制等待:{}秒后重新发送。", waitTime);
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;
}
}

View File

@@ -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;
}

View File

@@ -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\"}";
}

View File

@@ -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";
/**
* 签到

View File

@@ -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();
}
}

View File

@@ -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;
}

View File

@@ -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();
}
}

View File

@@ -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;

View File

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

View File

@@ -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,20 +172,46 @@ 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())) {
log.info("签到成功, 签到积分:{}, 签到消息:{}", gLaDOSResponse.getPoints(), gLaDOSResponse.getMessage());
sb.append(user.getEmail()).append("签到成功,获得积分:").append(gLaDOSResponse.getPoints()).append("\n");
try {
dingTalkService.sendScriptMsg("[时间:" + LocalDateTime.now() + "] 用户: " +
user.getEmail() + "签到成功,获得积分:" + gLaDOSResponse.getPoints());
} catch (Exception e) {
log.error("发送钉钉消息失败", e);
// 成功签到记录
if (0 == gLaDOSResponse.getCode()) {
if (Objects.nonNull(gLaDOSResponse.getPoints())) {
log.info("签到成功, 签到积分:{}, 签到消息:{}", gLaDOSResponse.getPoints(), gLaDOSResponse.getMessage());
sb.append(user.getEmail()).append("签到成功,获得积分:").append(gLaDOSResponse.getPoints()).append("\n");
try {
dingTalkService.sendScriptMsg("[时间:" + LocalDateTime.now() + "] 用户: " +
user.getEmail() + "签到成功,获得积分:" + gLaDOSResponse.getPoints());
} catch (Exception e) {
log.error("发送钉钉消息失败", e);
}
GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(1).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
gladosMapper.insertScriptRunLog(build);
return Boolean.TRUE;
} else {
log.info("签到异常, 签到消息:{}", gLaDOSResponse.getMessage());
sb.append(user.getEmail()).append("签到异常,消息:").append(gLaDOSResponse.getMessage());
GladosRunLog build = GladosRunLog.builder().time(LocalDateTime.now()).status(0).code(Integer.valueOf(gLaDOSResponse.getCode().toString())).response(response).user(user.getEmail()).userId(user.getId()).build();
gladosMapper.insertScriptRunLog(build);
return Boolean.FALSE;
}
}
// 重复签到,表示当日签到成功
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;
}
}

View File

@@ -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;
}

View File

@@ -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;
}

View File

@@ -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;
}

View File

@@ -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;
}

View File

@@ -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;
}

View File

@@ -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;
}

View File

@@ -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;
}
}

View File

@@ -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");
}
}

View File

@@ -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=";
}

View File

@@ -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;
}

View File

@@ -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);
}

View File

@@ -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;
}
}

View File

@@ -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(">>>>>>>>>>>>>>>>>新浪财经数据拉取结束>>>>>>>>>>>>>>>>>");
}
}

View File

@@ -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);
}
}
}

View File

@@ -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);
}

View File

@@ -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;
}
}

View File

@@ -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";
}

View File

@@ -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;
}

View File

@@ -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;
}

View File

@@ -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;
}

View File

@@ -1,6 +0,0 @@
package com.xiang.xservice.application.script.stock.gnshyx.enums;
public enum GnshyxUrlEnum {
}

View File

@@ -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);
}

View File

@@ -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);
}
}
}
}
}
}

View File

@@ -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);
}
}

View File

@@ -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);
}

View File

@@ -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)) {

View File

@@ -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;

View File

@@ -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;
}

View File

@@ -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);
}

View File

@@ -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;

View File

@@ -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);
}

View File

@@ -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);
}
}

View File

@@ -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;
}
}

View File

@@ -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;
}

View File

@@ -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

View File

@@ -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

View File

@@ -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:

View File

@@ -16,7 +16,7 @@ server:
spring:
profiles:
active: test
active: local
application:
name: xservice-script-center
main:

View File

@@ -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级别的 -->

View File

@@ -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>

View File

@@ -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"/>

View File

@@ -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"/>

View File

@@ -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"/>

View File

@@ -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"/>

View File

@@ -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"/>

View File

@@ -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"/>

View File

@@ -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>

View File

@@ -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>

View File

@@ -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"/>