XiangZ/script
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

江体小程序和zlb接口开发 #1

Merged
XiangZ merged 32 commits from feat/script_v1 into master 2026-05-10 09:06:35 +00:00
Conversation 0 Commits 32 Files Changed 171 +728 -13
16 changed files with 728 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 66a69a4968 - Show all commits

10
src/main/java/com/xiang/common/enums/ScheduleEnums.java
View File

@@ -7,8 +7,18 @@ import lombok.Getter;
@AllArgsConstructor
public enum ScheduleEnums {
/**
* 0：glados 1：芬玩岛 2：江体小程序 3：江体zlb 4：DDNS
*/
DOMAIN_DYNAMIC_ANALYSIS_TASK(4, "domain", "domainDynamicAnalysisTask"),
GLADOS_CHECK_IN_TASK(0, "glados", "gladosCheckInTask"),
ZLB_LOGIN_TASK(3, "zlb", "zlbLoginTask"),
ZLB_TOKEN_CHECK_TASK(3, "zlb", "zlbTokenCheckTask"),
ZLB_SITE_QUERY_TASK(3, "zlb", "zlbSiteQueryTask"),
ZLB_SITE_DAY_TASK(3, "zlb", "zlbSiteDayTask"),
ZLB_ORDER_CREATE_TASK(3, "zlb", "zlbOrderCreateTask"),
;
private final Integer modeleCode;

17
src/main/java/com/xiang/common/enums/YcCodeTypeEnum.java Normal file
View File

@@ -0,0 +1,17 @@
package com.xiang.common.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
@Getter
@AllArgsConstructor
public enum YcCodeTypeEnum {
YC_10118(10118, "中文字符 1~4位 plus 其他类型准确率不满足 可使用本类型"),
YC_6246(30100, "通用中文点选1")
;
private final Integer type;
private final String desc;
}

3
src/main/java/com/xiang/common/factory/schedule/BaseScheduleTaskTemplate.java
View File

@@ -9,6 +9,7 @@ import com.xiang.common.service.IScheduleRunLogService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Objects;
@@ -112,7 +113,7 @@ public abstract class BaseScheduleTaskTemplate {
* @param validatedParams 校验通过的参数
* @return 任务执行结果
*/
protected abstract TaskResult doExecute(Object validatedParams);
protected abstract TaskResult doExecute(Object validatedParams) throws Exception;
/**
* 记录成功结果 - 子类可选择性覆写

14
src/main/java/com/xiang/common/pojo/code/YcCodeBaseResponse.java Normal file
View File

@@ -0,0 +1,14 @@
package com.xiang.common.pojo.code;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class YcCodeBaseResponse<T> {
private String msg;
private Integer code;
private T data;
}

14
src/main/java/com/xiang/common/pojo/code/YcCodeDataResp.java Normal file
View File

@@ -0,0 +1,14 @@
package com.xiang.common.pojo.code;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class YcCodeDataResp {
private Integer code;
private String data;
private Double time;
}

24
src/main/java/com/xiang/common/pojo/code/YcCodeRequest.java Normal file
View File

@@ -0,0 +1,24 @@
package com.xiang.common.pojo.code;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class YcCodeRequest {
/**
* 图片
*/
private String image;
/**
* token
*/
private String token;
/**
* 接口类型
*/
private Integer type;
private String extra;
}

21
src/main/java/com/xiang/common/pojo/jntyzx/zlb/ZlbOrderInfo.java
View File

@@ -12,24 +12,25 @@ import java.util.List;
*/
@Data
public class ZlbOrderInfo {
private String id;
private ZlbData data;
private String id;
private ZlbData data;
@Data
public static class ZlbData {
private Integer bgImageWidth;
private Integer bgImageHeight;
private String startTime;
private String stopTime;
private Integer bgImageWidth;
private Integer bgImageHeight;
private String startTime;
private String stopTime;
private List<TrackList> trackList;
@Data
public static class TrackList {
private Integer x;
private Integer y;
private Integer t;
private String type;
private Integer x;
private Integer y;
private Integer t;
private String type;
}
}
private String siteOrderDetailsStr;
}

73
src/main/java/com/xiang/common/service/CodeServiceImpl.java Normal file
View File

@@ -0,0 +1,73 @@
package com.xiang.common.service;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import com.google.common.collect.Maps;
import com.xiang.common.enums.YcCodeTypeEnum;
import com.xiang.common.pojo.code.YcCodeBaseResponse;
import com.xiang.common.pojo.code.YcCodeDataResp;
import com.xiang.common.pojo.code.YcCodeRequest;
import com.xiang.common.utils.HttpService;
import lombok.extern.slf4j.Slf4j;
import org.checkerframework.checker.nullness.qual.Nullable;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.Objects;
@Service
@Slf4j
public class CodeServiceImpl implements ICodeService {
// 云码平台接口api
private static final String YUN_CODE_API_URL = "http://api.jfbym.com/api/YmServer/customApi";
@Override
public String templateCodeResolve(String image) {
YcCodeBaseResponse<YcCodeDataResp> resp = baseCodeResolve(YcCodeTypeEnum.YC_10118.getType(), image, null);
if (Objects.isNull(resp)) {
return null;
}
Integer code = resp.getCode();
if (200 == code) {
String data = resp.getData().getData();
StringBuilder result = new StringBuilder();
for (int i = 0; i < data.length(); i++) {
result.append(data.charAt(i)).append(",");
}
return result.substring(0, result.length() - 1);
}
return null;
}
@Override
public String codeResolve(String image, String extra) {
YcCodeBaseResponse<YcCodeDataResp> resp = baseCodeResolve(YcCodeTypeEnum.YC_6246.getType(), image, extra);
if (Objects.isNull(resp)) {
return null;
}
Integer code = resp.getCode();
if (200 == code) {
return resp.getData().getData();
}
return null;
}
@Override
public YcCodeBaseResponse<YcCodeDataResp> baseCodeResolve(Integer type, String image, String extra) {
HashMap<String, String> header = Maps.newHashMap();
header.put("Content-Type", "application/json");
YcCodeRequest ycCodeRequest = new YcCodeRequest();
ycCodeRequest.setImage(image);
ycCodeRequest.setToken("9LQ1ATKVEeO8Arhq-HavXzpHvkzdZz_r7ydmqlYhp9c");
ycCodeRequest.setType(type);
ycCodeRequest.setExtra(extra);
String resp = HttpService.doPost(YUN_CODE_API_URL, header, JSON.toJSONString(ycCodeRequest));
return JSON.parseObject(resp, new TypeReference<YcCodeBaseResponse<YcCodeDataResp>>() {
});
}
}

14
src/main/java/com/xiang/common/service/ICodeService.java Normal file
View File

@@ -0,0 +1,14 @@
package com.xiang.common.service;
import com.xiang.common.pojo.code.YcCodeBaseResponse;
import com.xiang.common.pojo.code.YcCodeDataResp;
import com.xiang.common.pojo.code.YcCodeRequest;
public interface ICodeService {
String templateCodeResolve(String image);
String codeResolve(String image, String extra);
YcCodeBaseResponse<YcCodeDataResp> baseCodeResolve(Integer type, String image, String extra);
}

138
src/main/java/com/xiang/service/module/jntyzx/zlb/schedule/ZlbLoginTask.java Normal file
View File

@@ -0,0 +1,138 @@
package com.xiang.service.module.jntyzx.zlb.schedule;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.xiang.common.enums.ScheduleEnums;
import com.xiang.common.factory.JntyzxDingTalkFactory;
import com.xiang.common.factory.schedule.BaseScheduleTaskTemplate;
import com.xiang.common.mapper.ZlbLoginInfoMapper;
import com.xiang.common.pojo.jntyzx.zlb.ZlbLoginInfo;
import com.xiang.common.pojo.jntyzx.zlb.ZlbTokenInfo;
import com.xiang.common.pojo.schedule.TaskResult;
import com.xiang.common.service.IScheduleOpeningConfigService;
import com.xiang.common.service.IScheduleRunLogService;
import com.xiang.service.module.jntyzx.zlb.service.ZlbTokenInfoService;
import lombok.extern.slf4j.Slf4j;
import okhttp3.*;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;
@Slf4j
@Component
public class ZlbLoginTask extends BaseScheduleTaskTemplate {
private final ZlbLoginInfoMapper zlbLoginInfoMapper;
private final ZlbTokenInfoService zlbTokenInfoService;
private final JntyzxDingTalkFactory jntyzxDingTalkFactory;
public ZlbLoginTask(IScheduleOpeningConfigService scheduleOpeningConfigService,
IScheduleRunLogService scheduleRunLogService,
ZlbLoginInfoMapper zlbLoginInfoMapper,
ZlbTokenInfoService zlbTokenInfoService,
JntyzxDingTalkFactory jntyzxDingTalkFactory) {
super(scheduleOpeningConfigService, scheduleRunLogService);
this.zlbLoginInfoMapper = zlbLoginInfoMapper;
this.zlbTokenInfoService = zlbTokenInfoService;
this.jntyzxDingTalkFactory = jntyzxDingTalkFactory;
}
@Override
protected String getTaskName() {
return ScheduleEnums.ZLB_LOGIN_TASK.getTaskName();
}
@Override
protected Integer getModule() {
return ScheduleEnums.ZLB_LOGIN_TASK.getModeleCode();
}
@Override
protected String getModuleName() {
return ScheduleEnums.ZLB_LOGIN_TASK.getModule();
}
@Override
protected TaskResult doExecute(Object validatedParams) {
TaskResult taskResult = new TaskResult();
taskResult.setSuccess(true);
List<ZlbLoginInfo> zlbLoginInfos = zlbLoginInfoMapper.selectList(new QueryWrapper<>());
if (CollectionUtils.isEmpty(zlbLoginInfos)) {
taskResult.setSummary("暂无用户信息");
return taskResult;
}
OkHttpClient client = new OkHttpClient.Builder()
.connectTimeout(60, TimeUnit.SECONDS) // 连接超时时间
.readTimeout(60, TimeUnit.SECONDS) // 读取超时时间
.writeTimeout(60, TimeUnit.SECONDS) // 写入超时时间
.build();
StringBuilder sb = new StringBuilder();
for (ZlbLoginInfo zlbLoginInfo : zlbLoginInfos) {
String name = zlbLoginInfo.getName();
try {
MediaType mediaType = MediaType.parse("application/json");
RequestBody body = RequestBody.create(mediaType, "{\"appId\":\"2002207307\"}");
Request request = new Request.Builder()
.url("https://portal.zjzwfw.gov.cn/uc/sso/ticket")
.method("POST", body)
.addHeader("Host", "portal.zjzwfw.gov.cn")
.addHeader("X-App-Id", "")
.addHeader("X-Timestamp", "1761122479")
.addHeader("User-Agent", "000001@ZLB_iphone_7.28.0")
.addHeader("guc-accountType", "person")
// .addHeader("aliyungf_tc", zlbLoginInfo.getAliyungfTc())
.addHeader("Biz-Session-Id", zlbLoginInfo.getBizSessionId())
.addHeader("guc-platform", "app")
.addHeader("X-Access-Id", "szzj")
.addHeader("X-Device-Id", zlbLoginInfo.getXDeviceId())
.addHeader("X-Sign-Type", "SHA256")
.addHeader("guc-endpoint", "C")
.addHeader("X-Sign-Value", zlbLoginInfo.getXSignValue())
.addHeader("Connection", "keep-alive")
.addHeader("token", zlbLoginInfo.getToken())
.addHeader("Accept-Language", "zh-Hans-CN;q=1")
.addHeader("guc-gsid", zlbLoginInfo.getGucGsid())
.addHeader("X-Site-Code", zlbLoginInfo.getXSiteCode())
.addHeader("Accept", "*/*")
.addHeader("OS-Version", "18.6.2")
.addHeader("Cookie", zlbLoginInfo.getCookie())
.addHeader("Content-Type", "application/json")
.build();
Response response = client.newCall(request).execute();
String string = response.body().string();
log.info("{}获取ticketId接口返回:{}", name,string);
JSONObject jsonObject = JSON.parseObject(string
);
JSONObject data = jsonObject.getJSONObject("data");
String ticketId = data.getString("ticketId");
Request.Builder builder = new Request.Builder().url("https://asian.hzsports.net/sportthirdserver/zjmanage/getTydjtLoginInFo4?ticketId=" + ticketId);
// 添加请求头
builder.addHeader("token", "9a422ab8b25d4634ae8efbb965945b46");
Response response1 = client.newCall(builder.build()).execute();
JSONObject jsonObject1 = JSON.parseObject(response1.body().string());
String token = jsonObject1.getString("data");
log.info("{}token=== {}", name, token);
ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.queryByName(name);
zlbTokenInfo.setTokenId(token);
zlbTokenInfo.setUpdatedDate(new Date());
zlbTokenInfoService.updateById(zlbTokenInfo);
} catch (Exception e) {
log.error("{}登录异常", name, e);
sb.append(name).append("用户登录异常.").append(e.getMessage());
jntyzxDingTalkFactory.sendMsg("登录异常:" + name);
}
}
if (StringUtils.isNotBlank(sb)) {
taskResult.setSuccess(false);
taskResult.setSummary(sb.toString());
}
return taskResult;
}
}

137
src/main/java/com/xiang/service/module/jntyzx/zlb/schedule/ZlbOrderTask.java Normal file
View File

@@ -0,0 +1,137 @@
package com.xiang.service.module.jntyzx.zlb.schedule;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.xiang.common.enums.ScheduleEnums;
import com.xiang.common.factory.JntyzxDingTalkFactory;
import com.xiang.common.factory.schedule.BaseScheduleTaskTemplate;
import com.xiang.common.pojo.jntyzx.zlb.ZlbTokenInfo;
import com.xiang.common.pojo.jntyzx.zlb.ZlbUserInfo;
import com.xiang.common.pojo.schedule.TaskResult;
import com.xiang.common.service.IScheduleOpeningConfigService;
import com.xiang.common.service.IScheduleRunLogService;
import com.xiang.common.utils.DateUtils;
import com.xiang.common.utils.OkHttpUtil;
import com.xiang.service.module.jntyzx.zlb.constants.ZlbUrlConstants;
import com.xiang.service.module.jntyzx.zlb.service.ZlbService;
import com.xiang.service.module.jntyzx.zlb.service.ZlbTokenInfoService;
import com.xiang.service.module.jntyzx.zlb.service.ZlbUserInfoService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.io.IOException;
import java.time.Duration;
import java.time.LocalTime;
import java.util.Date;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
@Component
@Slf4j
public class ZlbOrderTask extends BaseScheduleTaskTemplate {
private final ZlbUserInfoService zlbUserInfoService;
private final ZlbService zlbService;
private final ZlbTokenInfoService zlbTokenInfoService;
private final JntyzxDingTalkFactory jntyzxDingTalkFactory;
private final RedisTemplate redisTemplate;
public ZlbOrderTask(IScheduleOpeningConfigService scheduleOpeningConfigService,
IScheduleRunLogService scheduleRunLogService,
ZlbUserInfoService zlbUserInfoService,
ZlbService zlbService,
ZlbTokenInfoService zlbTokenInfoService,
JntyzxDingTalkFactory jntyzxDingTalkFactory,
RedisTemplate redisTemplate) {
super(scheduleOpeningConfigService, scheduleRunLogService);
this.zlbUserInfoService = zlbUserInfoService;
this.zlbService = zlbService;
this.zlbTokenInfoService = zlbTokenInfoService;
this.jntyzxDingTalkFactory = jntyzxDingTalkFactory;
this.redisTemplate = redisTemplate;
}
@Override
protected String getTaskName() {
return ScheduleEnums.ZLB_ORDER_CREATE_TASK.getTaskName();
}
@Override
protected Integer getModule() {
return ScheduleEnums.ZLB_ORDER_CREATE_TASK.getModeleCode();
}
@Override
protected String getModuleName() {
return ScheduleEnums.ZLB_ORDER_CREATE_TASK.getModule();
}
@Override
protected TaskResult doExecute(Object validatedParams) throws Exception {
TaskResult taskResult = new TaskResult();
LambdaQueryWrapper<ZlbUserInfo> wrapper = Wrappers.lambdaQuery();
wrapper.eq(ZlbUserInfo::getIsBook, 0);
wrapper.eq(ZlbUserInfo::getName, "xiang");
Date date = DateUtils.addDate(new Date(), 0);
String day = DateUtils.format(date, DateUtils.ENUM_FORMAT_YMD);
wrapper.eq(ZlbUserInfo::getWeek, DateUtils.getWeekDayTwo(day));
ZlbUserInfo zlbUserInfo = zlbUserInfoService.getOne(wrapper);
if (zlbUserInfo == null) {
taskResult.setSuccess(false);
taskResult.setSummary("用户不存在");
return taskResult;
}
OkHttpUtil client = OkHttpUtil.getInstance();
//使用代理ip
String name = zlbUserInfo.getName();
String placeName = zlbUserInfo.getPlaceName();
String siteTimeName = zlbUserInfo.getSiteTimeName();
//获取Token
ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.queryByName(name);
String tokenId = zlbTokenInfo.getTokenId();
String secretKey = zlbService.getKey(tokenId, client);
String siteOrderDetailsStr = zlbService.buildSiteOrder(zlbUserInfo, secretKey, day);
Map<String, String> headers = zlbService.getHeaders(zlbTokenInfo.getTokenId());
String newOrderJson = zlbService.buildNewOrder(siteOrderDetailsStr, client);
ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
//计算9点到现在的时间差
//获取江体当前时间
LocalTime currentTime = LocalTime.now();
LocalTime targetTime = LocalTime.parse("09:00:11.800");
Duration duration = Duration.between(currentTime, targetTime);
long milliseconds = duration.toMillis();
// executorService.schedule(() -> {
String response = null;
try {
response = client.postJson(ZlbUrlConstants.newOrderUrl, headers, newOrderJson);
} catch (Exception e) {
throw new RuntimeException(e);
}
buildOrder(name, response, placeName, siteTimeName);
// }, milliseconds, TimeUnit.MILLISECONDS);
return taskResult;
}
private void buildOrder(String name, String response, String placeName, String siteTimeName) {
log.info("订单接口返回结果==> \n {}", response);
JSONObject jsonObject = JSONObject.parseObject(response);
if (jsonObject.getInteger("code") == 200) {
jntyzxDingTalkFactory.sendMsg(name + "订单接口下单返回成功请2分钟内付款√√√√√√场地号:" + placeName + "时间:" + siteTimeName);
JSONObject data = jsonObject.getJSONObject("data");
String orderId = data.getString("orderId");
log.info("{}订单{}创建成功", name, orderId);
String redisKey = ZlbUrlConstants.REDIS_PREFIX + "_" + orderId + "_" + name;
redisTemplate.opsForValue().set(redisKey, name);
redisTemplate.expire(redisKey, 120, TimeUnit.SECONDS);
}
}
}

74
src/main/java/com/xiang/service/module/jntyzx/zlb/schedule/ZlbSiteDayTask.java Normal file
View File

@@ -0,0 +1,74 @@
package com.xiang.service.module.jntyzx.zlb.schedule;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.xiang.common.enums.ScheduleEnums;
import com.xiang.common.factory.JntyzxDingTalkFactory;
import com.xiang.common.factory.schedule.BaseScheduleTaskTemplate;
import com.xiang.common.mapper.ZlbOrderInfoMapper;
import com.xiang.common.pojo.jntyzx.zlb.ZlbPayOrder;
import com.xiang.common.pojo.schedule.TaskResult;
import com.xiang.common.service.IScheduleOpeningConfigService;
import com.xiang.common.service.IScheduleRunLogService;
import com.xiang.common.utils.DateUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
@Component
@Slf4j
public class ZlbSiteDayTask extends BaseScheduleTaskTemplate {
private final ZlbOrderInfoMapper zlbOrderInfoMapper;
private final JntyzxDingTalkFactory jntyzxDingTalkFactory;
public ZlbSiteDayTask(IScheduleOpeningConfigService scheduleOpeningConfigService,
IScheduleRunLogService scheduleRunLogService,
ZlbOrderInfoMapper zlbOrderInfoMapper,
JntyzxDingTalkFactory jntyzxDingTalkFactory) {
super(scheduleOpeningConfigService, scheduleRunLogService);
this.zlbOrderInfoMapper = zlbOrderInfoMapper;
this.jntyzxDingTalkFactory = jntyzxDingTalkFactory;
}
@Override
protected String getTaskName() {
return ScheduleEnums.ZLB_SITE_DAY_TASK.getTaskName();
}
@Override
protected Integer getModule() {
return ScheduleEnums.ZLB_SITE_DAY_TASK.getModeleCode();
}
@Override
protected String getModuleName() {
return ScheduleEnums.ZLB_SITE_DAY_TASK.getModule();
}
@Override
protected TaskResult doExecute(Object validatedParams) {
TaskResult taskResult = new TaskResult();
//获取当前时间的后一天
Date date = DateUtils.addDate(new Date(), 1);
String day = DateUtils.format(date, DateUtils.ENUM_FORMAT_YMD);
LambdaQueryWrapper<ZlbPayOrder> wrapper = Wrappers.lambdaQuery();
wrapper.eq(ZlbPayOrder::getDay, day);
wrapper.orderByAsc(ZlbPayOrder::getTime);
List<ZlbPayOrder> zlbPayOrders = zlbOrderInfoMapper.selectList(wrapper);
if (!zlbPayOrders.isEmpty()){
StringBuilder sb = new StringBuilder();
sb.append("预约日期：").append(day).append("\n");
for (ZlbPayOrder zlbPayOrder : zlbPayOrders) {
sb.append("预约人：").append(zlbPayOrder.getName()).append("预约场地：").append(zlbPayOrder.getPlaceName()).append("，").append("预约时间：").append(zlbPayOrder.getTime()).append("，").append("\n");
}
jntyzxDingTalkFactory.sendMsg(sb.toString());
}
taskResult.setSuccess(true);
return taskResult;
}
}

67
src/main/java/com/xiang/service/module/jntyzx/zlb/schedule/ZlbSiteTask.java Normal file
View File

@@ -0,0 +1,67 @@
package com.xiang.service.module.jntyzx.zlb.schedule;
import com.xiang.common.enums.ScheduleEnums;
import com.xiang.common.factory.schedule.BaseScheduleTaskTemplate;
import com.xiang.common.pojo.schedule.TaskResult;
import com.xiang.common.service.IScheduleOpeningConfigService;
import com.xiang.common.service.IScheduleRunLogService;
import com.xiang.common.utils.DateUtils;
import com.xiang.service.module.jntyzx.zlb.service.ZlbService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Date;
@Component
@Slf4j
public class ZlbSiteTask extends BaseScheduleTaskTemplate {
private final ZlbService zlbService;
public ZlbSiteTask(IScheduleOpeningConfigService scheduleOpeningConfigService, IScheduleRunLogService scheduleRunLogService, ZlbService zlbService) {
super(scheduleOpeningConfigService, scheduleRunLogService);
this.zlbService = zlbService;
}
@Override
protected String getTaskName() {
return ScheduleEnums.ZLB_SITE_QUERY_TASK.getTaskName();
}
@Override
protected Integer getModule() {
return ScheduleEnums.ZLB_SITE_QUERY_TASK.getModeleCode();
}
@Override
protected String getModuleName() {
return ScheduleEnums.ZLB_SITE_QUERY_TASK.getModule();
}
@Override
protected TaskResult doExecute(Object validatedParams) {
TaskResult taskResult = new TaskResult();
//获取当前时间的后一天
Date date1 = DateUtils.addDate(new Date(), 2);
Date date2 = DateUtils.addDate(new Date(), 3);
Date date3 = DateUtils.addDate(new Date(), 4);
String day1 = DateUtils.format(date1, DateUtils.ENUM_FORMAT_YMD);
String day2 = DateUtils.format(date2, DateUtils.ENUM_FORMAT_YMD);
String day3 = DateUtils.format(date3, DateUtils.ENUM_FORMAT_YMD);
try {
zlbService.queryZLbSiteInfo(day1, 1);
zlbService.queryZLbSiteInfo(day2, 1);
zlbService.queryZLbSiteInfo(day3, 1);
} catch (Exception e) {
log.error("site task error", e);
taskResult.setSuccess(false);
taskResult.setSummary(e.getMessage());
return taskResult;
}
taskResult.setSuccess(true);
taskResult.setSummary("site task success.");
return taskResult;
}
}

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

@@ -1,4 +1,48 @@
package com.xiang.service.module.jntyzx.zlb.schedule;
import lombok.RequiredArgsConstructor;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@Component
@RequiredArgsConstructor
@RestController
public class ZlbTaskConfig {
private final ZlbLoginTask zlbLoginTask;
private final ZlbTokenRefreshTask zlbTokenRefreshTask;
private final ZlbSiteTask zlbSiteTask;
private final ZlbSiteDayTask zlbSiteDayTask;
private final ZlbOrderTask zlbOrderTask;
@Scheduled(cron = "0 0/30 * * * ?")
@GetMapping("/zlbLoginTask")
public void zlbLoginTask() {
zlbLoginTask.run();
}
@Scheduled(cron = "0 0 8 * * *")
@GetMapping("/zlbTokenRefresh")
public void zlbTokenRefresh() {
zlbTokenRefreshTask.run();
}
@GetMapping("/zlbSiteTask")
public void zlbSiteTask() {
zlbSiteTask.run();
}
@GetMapping("/zlbSiteDayTask")
public void zlbSiteDayTask() {
zlbSiteDayTask.run();
}
@GetMapping("/zlbOrderCreateTask")
public void zlbOrderCreateTask() {
zlbOrderTask.run();
}
}

79
src/main/java/com/xiang/service/module/jntyzx/zlb/schedule/ZlbTokenRefreshTask.java Normal file
View File

@@ -0,0 +1,79 @@
package com.xiang.service.module.jntyzx.zlb.schedule;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.xiang.common.enums.ScheduleEnums;
import com.xiang.common.factory.JntyzxDingTalkFactory;
import com.xiang.common.factory.schedule.BaseScheduleTaskTemplate;
import com.xiang.common.pojo.jntyzx.zlb.ZlbTokenInfo;
import com.xiang.common.pojo.schedule.TaskResult;
import com.xiang.common.service.IScheduleOpeningConfigService;
import com.xiang.common.service.IScheduleRunLogService;
import com.xiang.service.module.jntyzx.zlb.service.ZlbTokenInfoService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
@Component
@Slf4j
public class ZlbTokenRefreshTask extends BaseScheduleTaskTemplate {
private final ZlbTokenInfoService zlbTokenInfoService;
private final JntyzxDingTalkFactory jntyzxDingTalkFactory;
public ZlbTokenRefreshTask(IScheduleOpeningConfigService scheduleOpeningConfigService,
IScheduleRunLogService scheduleRunLogService,
ZlbTokenInfoService zlbTokenInfoService,
JntyzxDingTalkFactory jntyzxDingTalkFactory) {
super(scheduleOpeningConfigService, scheduleRunLogService);
this.zlbTokenInfoService = zlbTokenInfoService;
this.jntyzxDingTalkFactory = jntyzxDingTalkFactory;
}
@Override
protected String getTaskName() {
return ScheduleEnums.ZLB_TOKEN_CHECK_TASK.getTaskName();
}
@Override
protected Integer getModule() {
return ScheduleEnums.ZLB_TOKEN_CHECK_TASK.getModeleCode();
}
@Override
protected String getModuleName() {
return ScheduleEnums.ZLB_TOKEN_CHECK_TASK.getModule();
}
@Override
protected TaskResult doExecute(Object validatedParams) {
TaskResult taskResult = new TaskResult();
taskResult.setSuccess(true);
LambdaQueryWrapper<ZlbTokenInfo> wrapper = Wrappers.lambdaQuery();
wrapper.eq(ZlbTokenInfo::getIsDel, 0);
List<ZlbTokenInfo> list = zlbTokenInfoService.list(wrapper);
StringBuilder sb = new StringBuilder();
for (ZlbTokenInfo zlbTokenInfo : list) {
String name = zlbTokenInfo.getName();
Date updatedDate = zlbTokenInfo.getUpdatedDate();
//判断update时间是不是当前时间相差多少小时
if (new Date().getTime() -updatedDate.getTime() > 1000 * 60 * 60 * 30) {
//超过30小时，则重新获取token
sb.append(name).append(" token已超过30小时请及时更新×××××").append("\n");
}else{
sb.append(name).append(" token可以正常使用无需更新√√√√√").append("\n");
}
}
jntyzxDingTalkFactory.sendMsg(sb.toString());
if (StringUtils.isNotBlank(sb)) {
taskResult.setSummary(sb.toString());
taskResult.setSuccess(false);
}
return taskResult;
}
}

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

@@ -11,6 +11,7 @@ import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.xiang.common.factory.JntyzxDingTalkFactory;
import com.xiang.common.pojo.jntyzx.zlb.*;
import com.xiang.common.service.ICodeService;
import com.xiang.common.utils.AESECBUtils;
import com.xiang.common.utils.DateUtils;
import com.xiang.common.utils.OkHttpUtil;
@@ -42,6 +43,8 @@ public class ZlbServiceImpl implements ZlbService {
private ZlbUserInfoService zlbUserInfoService;
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private ICodeService codeService;
@Override
@@ -62,7 +65,7 @@ public class ZlbServiceImpl implements ZlbService {
jntyzxDingTalkFactory.sendMsg(type + "没有查到" + ymdDate + "的场地,开始补齐");
OkHttpUtil client = OkHttpUtil.getInstance();
LambdaQueryWrapper<ZlbTokenInfo> wrapper = Wrappers.lambdaQuery();
wrapper.eq(ZlbTokenInfo::getName, "Xiang");
wrapper.eq(ZlbTokenInfo::getName, "xiang");
ZlbTokenInfo zlbTokenInfo = zlbTokenInfoService.getOne(wrapper);
List<ZlbSiteInfo> zlbSiteInfoList = new ArrayList<>();
String tokenId = zlbTokenInfo.getTokenId();
@@ -358,8 +361,13 @@ public class ZlbServiceImpl implements ZlbService {
public String buildNewOrder(String siteOrderDetailsStr, OkHttpUtil client) throws IOException {
//获取图片验证码
String s = client.postJson(ZlbUrlConstants.captchaUrl, null, "{}");
JSONObject jsonObject = JSON.parseObject(s);
String templateImage = JSON.toJSONString(jsonObject.get("templateImage"));
String templeCode = codeService.templateCodeResolve(templateImage);
String captcha = JSON.toJSONString(jsonObject.get("captcha"));
String backgroundImage = JSON.toJSONString(JSON.parseObject(captcha).get("backgroundImage"));
String track = codeService.codeResolve(backgroundImage, templeCode);
//获取验证码轨迹
String track = HttpRequest.post(ZlbUrlConstants.getCaptchaUrl).body(s).execute().body();
ZlbOrderInfo zlbOrderInfo = JSONObject.parseObject(track, ZlbOrderInfo.class);
zlbOrderInfo.setSiteOrderDetailsStr(siteOrderDetailsStr);
String jsonString = JSON.toJSONString(zlbOrderInfo);