From c4915b17c84cfd77bdc809b78949613f426f6970 Mon Sep 17 00:00:00 2001 From: Xiang Date: Tue, 16 Dec 2025 11:04:51 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E8=AE=A2=E5=8D=95=E5=88=9B=E5=BB=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../jntyzx/controller/VenueController.java | 11 +--- .../jntyzx/entity/pojo/OrderInfoDO.java | 55 +++++++++++++++++++ .../jntyzx/manage/IOrderCreateInfoManage.java | 13 +++++ .../manage/OrderCreateInfoManageImpl.java | 16 ++++++ .../mapper/JntyzxOrderCreateInfoMapper.java | 15 +++++ .../jntyzx/service/JntyzxHttpServiceImpl.java | 13 +++++ 6 files changed, 114 insertions(+), 9 deletions(-) create mode 100644 script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/pojo/OrderInfoDO.java create mode 100644 script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/IOrderCreateInfoManage.java create mode 100644 script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/OrderCreateInfoManageImpl.java create mode 100644 script/src/main/java/com/xiang/xservice/application/script/jntyzx/mapper/JntyzxOrderCreateInfoMapper.java diff --git a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/controller/VenueController.java b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/controller/VenueController.java index e515825..f523445 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/controller/VenueController.java +++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/controller/VenueController.java @@ -57,20 +57,13 @@ public class VenueController { if (StringUtils.isBlank(token)) { return Result.error("暂无可订购的用户"); } - for (String placeName : map.keySet()) { + map.keySet().parallelStream().forEach(placeName -> { List venueInfoDOList = map.get(placeName); Boolean order = jntyzxHttpService.createOrder(venueInfoDOList, token); if (order) { dingTalkScriptVenueService.sendScriptMsg("场地：" + placeName + "下单成功，请付款！时间:" + LocalDateTime.now()); } - } -// map.keySet().forEach(placeName -> { -// List venueInfoDOList = map.get(placeName); -// Boolean order = jntyzxHttpService.createOrder(venueInfoDOList, token); -// if (order) { -// dingTalkScriptVenueService.sendScriptMsg("场地：" + placeName + "下单成功，请付款！时间:" + LocalDateTime.now()); -// } -// }); + }); return Result.success(); } diff --git a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/pojo/OrderInfoDO.java b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/pojo/OrderInfoDO.java new file mode 100644 index 0000000..6f60d9a --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/entity/pojo/OrderInfoDO.java @@ -0,0 +1,55 @@ +package com.xiang.xservice.application.script.jntyzx.entity.pojo; + +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.time.LocalDate; +import java.time.LocalDateTime; + +/** + * @Author: xiang + * @Date: 2025-12-16 10:57 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@TableName("jntyzx_order_create_info") +public class OrderInfoDO { + private Long id; + /** + * 订单id + */ + private String orderId; + + /** + * 参数 + */ + private String params; + + /** + * 创建时间 + */ + private LocalDateTime createTime; + + /** + * 订单创建人 + */ + private String username; + + /** + * 场地号 + */ + private String placeName; + + /** + * 所属日期 + */ + private LocalDate date; + + /** + * 订单状态 （0:待付款，1:已付款） + */ + private Integer orderStatus; +} diff --git a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/IOrderCreateInfoManage.java b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/IOrderCreateInfoManage.java new file mode 100644 index 0000000..44505aa --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/IOrderCreateInfoManage.java @@ -0,0 +1,13 @@ +package com.xiang.xservice.application.script.jntyzx.manage; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.xiang.xservice.application.script.jntyzx.entity.pojo.OrderInfoDO; + +/** + * @Author: xiang + * @Date: 2025-12-16 10:59 + */ +public interface IOrderCreateInfoManage extends IService { + + +} diff --git a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/OrderCreateInfoManageImpl.java b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/OrderCreateInfoManageImpl.java new file mode 100644 index 0000000..68321ea --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/manage/OrderCreateInfoManageImpl.java @@ -0,0 +1,16 @@ +package com.xiang.xservice.application.script.jntyzx.manage; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.xiang.xservice.application.script.jntyzx.entity.pojo.OrderInfoDO; +import com.xiang.xservice.application.script.jntyzx.mapper.JntyzxOrderCreateInfoMapper; +import org.springframework.stereotype.Service; + +/** + * @Author: xiang + * @Date: 2025-12-16 10:59 + */ +@Service +public class OrderCreateInfoManageImpl extends ServiceImpl implements IOrderCreateInfoManage { + + +} diff --git a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/mapper/JntyzxOrderCreateInfoMapper.java b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/mapper/JntyzxOrderCreateInfoMapper.java new file mode 100644 index 0000000..c30d54d --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/mapper/JntyzxOrderCreateInfoMapper.java @@ -0,0 +1,15 @@ +package com.xiang.xservice.application.script.jntyzx.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.xiang.xservice.application.script.jntyzx.entity.pojo.OrderInfoDO; +import org.apache.ibatis.annotations.Mapper; +import org.springframework.stereotype.Repository; + +/** + * @Author: xiang + * @Date: 2025-12-16 10:58 + */ +@Mapper +@Repository +public interface JntyzxOrderCreateInfoMapper extends BaseMapper { +} diff --git a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxHttpServiceImpl.java b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxHttpServiceImpl.java index 52943d1..28be250 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxHttpServiceImpl.java +++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/service/JntyzxHttpServiceImpl.java @@ -9,6 +9,7 @@ import com.xiang.xmc.service.cache.service.IRedisService; import com.xiang.xmc.service.http.helper.HttpHelper; import com.xiang.xservice.application.script.jntyzx.constants.RedisKeyConstant; import com.xiang.xservice.application.script.jntyzx.constants.UrlConstant; +import com.xiang.xservice.application.script.jntyzx.entity.pojo.OrderInfoDO; import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO; import com.xiang.xservice.application.script.jntyzx.entity.req.SubscribeRequest; import com.xiang.xservice.application.script.jntyzx.entity.req.SubscribeVo; @@ -16,6 +17,7 @@ import com.xiang.xservice.application.script.jntyzx.entity.resp.JntyzxResponse; import com.xiang.xservice.application.script.jntyzx.entity.resp.OrderCreateResp; import com.xiang.xservice.application.script.jntyzx.entity.resp.query.SitePositionList; import com.xiang.xservice.application.script.jntyzx.entity.resp.query.VenueList; +import com.xiang.xservice.application.script.jntyzx.manage.IOrderCreateInfoManage; import com.xiang.xservice.basic.utils.Base64; import com.xiang.xservice.basic.utils.JsonUtils; import lombok.RequiredArgsConstructor; @@ -27,6 +29,7 @@ import org.springframework.util.CollectionUtils; import java.nio.charset.StandardCharsets; import java.time.LocalDate; +import java.time.LocalDateTime; import java.util.List; import java.util.Map; import java.util.Objects; @@ -41,6 +44,7 @@ import java.util.Objects; public class JntyzxHttpServiceImpl implements IJntyzxHttpService { private final IRedisService redisService; + private final IOrderCreateInfoManage orderCreateInfoManage; @Override public List queryAvailable(String isWeekend, String token) { @@ -161,6 +165,15 @@ public class JntyzxHttpServiceImpl implements IJntyzxHttpService { if (Objects.nonNull(createResp)) { String orderId = createResp.getId(); redisService.set(RedisKeyConstant.JNTYZX_ORDER_CREATE_KEY + orderId, String.valueOf(System.currentTimeMillis())); + OrderInfoDO orderInfoDO = new OrderInfoDO(); + orderInfoDO.setOrderId(orderId); + orderInfoDO.setParams(JsonUtils.toJsonString(subscribeRequest)); + orderInfoDO.setCreateTime(LocalDateTime.now()); + orderInfoDO.setUsername(token); + orderInfoDO.setPlaceName(vos.get(0).getPlaceName()); + orderInfoDO.setDate(LocalDate.now()); + orderInfoDO.setOrderStatus(0); + orderCreateInfoManage.save(orderInfoDO); return true; } }