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

perf:芬玩岛下单优化1.0

Browse Source
This commit is contained in:
xiang
2025-10-09 23:26:13 +08:00
parent 388287fc65
commit 1e54ee39d4
3 changed files with 22 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
script/src/main/java/com/xiang/xservice/application/script/fwd/entity/req/ProjectOrderCreateReq.java
View File

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

16
script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceHttpServiceImpl.java
View File

@@ -89,7 +89,7 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp {
@Override @Override
public ProjectOrderCreateResp createProjectOrder(ProjectOrderCreateReq req, String token) { 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)) { if (StringUtils.isBlank(respStr)) {
return null; return null;
} }
@@ -219,6 +219,20 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp {
private Map<String, String> buildFWDOrderHeaders(String token) { private Map<String, String> buildFWDOrderHeaders(String token) {
Map<String, String> headers = Maps.newHashMap(); 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; return headers;
} }
} }

5
script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceImpl.java
View File

@@ -19,6 +19,7 @@ import com.xiang.xservice.http.helper.HttpRequestHelper;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.logging.log4j.util.Strings;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -31,6 +32,7 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
/** /**
* @Author: xiang * @Author: xiang
@@ -84,6 +86,7 @@ public class PerformServiceImpl implements IPerformService {
log.info("该projectId:{}暂无座位信息", projectId); log.info("该projectId:{}暂无座位信息", projectId);
return Boolean.FALSE; return Boolean.FALSE;
} }
seatInfoByProjectId = seatInfoByProjectId.stream().filter(item -> 0== item.getSoldOut()).collect(Collectors.groupingBy())
for (FPerformSeatInfo fPerformSeatInfo : seatInfoByProjectId) { for (FPerformSeatInfo fPerformSeatInfo : seatInfoByProjectId) {
if (1 == fPerformSeatInfo.getSoldOut()) { if (1 == fPerformSeatInfo.getSoldOut()) {
continue; continue;
@@ -120,6 +123,8 @@ public class PerformServiceImpl implements IPerformService {
projectOrderCreateReq.setBlackBox(":0"); projectOrderCreateReq.setBlackBox(":0");
projectOrderCreateReq.setCombineTicketVos(null); projectOrderCreateReq.setCombineTicketVos(null);
projectOrderCreateReq.setOrdinaryTicketVos(null); projectOrderCreateReq.setOrdinaryTicketVos(null);
projectOrderCreateReq.setActivityId(Strings.EMPTY);
projectOrderCreateReq.setActivityType(0);
return projectOrderCreateReq; return projectOrderCreateReq;
} }