From 1e54ee39d4b1a0916a05084dd3bbf0e8855a457f Mon Sep 17 00:00:00 2001 From: xiang Date: Thu, 9 Oct 2025 23:26:13 +0800 Subject: [PATCH] =?UTF-8?q?perf:=E8=8A=AC=E7=8E=A9=E5=B2=9B=E4=B8=8B?= =?UTF-8?q?=E5=8D=95=E4=BC=98=E5=8C=961.0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../fwd/entity/req/ProjectOrderCreateReq.java | 2 ++ .../impl/PerformServiceHttpServiceImpl.java | 16 +++++++++++++++- .../fwd/service/impl/PerformServiceImpl.java | 5 +++++ 3 files changed, 22 insertions(+), 1 deletion(-) diff --git a/script/src/main/java/com/xiang/xservice/application/script/fwd/entity/req/ProjectOrderCreateReq.java b/script/src/main/java/com/xiang/xservice/application/script/fwd/entity/req/ProjectOrderCreateReq.java index a5b991e..1a819cc 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/fwd/entity/req/ProjectOrderCreateReq.java +++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/entity/req/ProjectOrderCreateReq.java @@ -25,4 +25,6 @@ public class ProjectOrderCreateReq { private String blackBox; private String combineTicketVos; private String ordinaryTicketVos; + private Integer activityType; + private String activityId; } diff --git a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceHttpServiceImpl.java b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceHttpServiceImpl.java index a0bc378..305a463 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceHttpServiceImpl.java +++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceHttpServiceImpl.java @@ -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; } @@ -219,6 +219,20 @@ public class PerformServiceHttpServiceImpl implements IPerformServiceHttp { private Map buildFWDOrderHeaders(String token) { Map 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; } } diff --git a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceImpl.java b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceImpl.java index e6762e5..dcf9fe0 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceImpl.java +++ b/script/src/main/java/com/xiang/xservice/application/script/fwd/service/impl/PerformServiceImpl.java @@ -19,6 +19,7 @@ import com.xiang.xservice.http.helper.HttpRequestHelper; 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; @@ -31,6 +32,7 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; +import java.util.stream.Collectors; /** * @Author: xiang @@ -84,6 +86,7 @@ public class PerformServiceImpl implements IPerformService { log.info("该projectId:{}暂无座位信息", projectId); return Boolean.FALSE; } + seatInfoByProjectId = seatInfoByProjectId.stream().filter(item -> 0== item.getSoldOut()).collect(Collectors.groupingBy()) for (FPerformSeatInfo fPerformSeatInfo : seatInfoByProjectId) { if (1 == fPerformSeatInfo.getSoldOut()) { continue; @@ -120,6 +123,8 @@ public class PerformServiceImpl implements IPerformService { projectOrderCreateReq.setBlackBox(":0"); projectOrderCreateReq.setCombineTicketVos(null); projectOrderCreateReq.setOrdinaryTicketVos(null); + projectOrderCreateReq.setActivityId(Strings.EMPTY); + projectOrderCreateReq.setActivityType(0); return projectOrderCreateReq; }