feat:江体小程序场地信息拉取定时任务

xservice-core/src/main/java/com/xiang/app/modules/jntyzx/service/IUserTokenInfoService.java

@@ -1,11 +1,16 @@
 package com.xiang.app.modules.jntyzx.service;
 
+import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO;
+
+import java.util.List;
+
 /**
  * @Author: xiang
  * @Date: 2025-12-16 09:22
  */
 public interface IUserTokenInfoService {
 
+    List<UserTokenInfoDO> getAvailableUser();
     String getToken(String name);
     boolean flushSingleToken(String name);
     boolean flushToken();

xservice-core/src/main/java/com/xiang/app/modules/jntyzx/service/IVenueService.java

@@ -16,4 +16,11 @@ public interface IVenueService {
     List<SitePositionList> queryTomorrowVenue();
     List<VenueInfoDO> queryCanBuyVenue();
     List<VenueInfoDO> queryToday6210VenueInfo();
+
+    /**
+     * 更新场地信息
+     * @param sitePositionLists
+     * @return
+     */
+    boolean saveOrUpdateTodayVenueInfo(List<SitePositionList> sitePositionLists);
 }

xservice-core/src/main/java/com/xiang/app/modules/jntyzx/service/impl/UserTokenInfoServiceImpl.java

@@ -29,6 +29,11 @@ public class UserTokenInfoServiceImpl implements IUserTokenInfoService {
     private final JtDingTalkFactory jtDingTalkFactory;
 
 
+    @Override
+    public List<UserTokenInfoDO> getAvailableUser() {
+        return userTokenInfoManage.listUser();
+    }
+
     @Override
     public String getToken(String name) {
         UserTokenInfoDO userTokenInfoDO = userTokenInfoManage.getByName(name);

xservice-core/src/main/java/com/xiang/app/modules/jntyzx/service/impl/VenueServiceImpl.java

@@ -74,6 +74,59 @@ public class VenueServiceImpl implements IVenueService {
         return venueInfoDOS.stream().filter(item -> VenueInfoUtils.get628VenueInfo(item) || VenueInfoUtils.get8210VenueInfo(item)).toList();
     }
 
+    @Override
+    public boolean saveOrUpdateTodayVenueInfo(List<SitePositionList> sitePositionLists) {
+        List<VenueInfoDO> venueInfoDOS = venueInfoManage.queryByDate(LocalDate.now());
+        Map<String, Map<String, VenueInfoDO>> map = Maps.newHashMap();
+        if (CollectionUtils.isNotEmpty(sitePositionLists)) {
+            Map<String, List<VenueInfoDO>> map1 = venueInfoDOS.stream().collect(Collectors.groupingBy(VenueInfoDO::getPlaceName));
+            map1.forEach((placeName, venueInfos) -> {
+                Map<String, VenueInfoDO> venueInfoDOMap = venueInfoDOS.stream().collect(Collectors.toMap(VenueInfoDO::getSjName, Function.identity(), (a, b) -> a));
+                map.put(placeName, venueInfoDOMap);
+            });
+        }
+
+        for (SitePositionList sitePositionList : sitePositionLists) {
+            if (map.containsKey(sitePositionList.getPlaceName())) {
+                Map<String, VenueInfoDO> venueInfoDOMap = map.get(sitePositionList.getPlaceName());
+                if (venueInfoDOMap.containsKey(sitePositionList.getSjName())) {
+                    VenueInfoDO venueInfoDO = venueInfoDOMap.get(sitePositionList.getSjName());
+                    venueInfoDO.setPlaceName(sitePositionList.getPlaceName());
+                    venueInfoDO.setPlaceMainId(sitePositionList.getId());
+                    venueInfoDO.setPlaceId(sitePositionList.getPlaceId());
+                    venueInfoDO.setScheduleId(Integer.valueOf(sitePositionList.getScheduleId()));
+                    venueInfoDO.setSjName(sitePositionList.getSjName());
+                    venueInfoDO.setContacts(sitePositionList.getContacts());
+                    venueInfoDO.setType(sitePositionList.getType());
+                    venueInfoDO.setMoney(sitePositionList.getMoney());
+                    venueInfoDO.setClassName(sitePositionList.getClassName());
+                    venueInfoDO.setClassCode(sitePositionList.getClassCode());
+                    venueInfoDO.setAppointments(sitePositionList.getAppointments());
+                    venueInfoDO.setCTypeCode(sitePositionList.getCtypeCode());
+                    venueInfoManage.updateById(venueInfoDO);
+                } else {
+                    VenueInfoDO venueInfoDO = new VenueInfoDO();
+                    venueInfoDO.setDate(LocalDate.now());
+                    venueInfoDO.setCreateTime(LocalDateTime.now());
+                    venueInfoDO.setPlaceName(sitePositionList.getPlaceName());
+                    venueInfoDO.setPlaceMainId(sitePositionList.getId());
+                    venueInfoDO.setPlaceId(sitePositionList.getPlaceId());
+                    venueInfoDO.setScheduleId(Integer.valueOf(sitePositionList.getScheduleId()));
+                    venueInfoDO.setSjName(sitePositionList.getSjName());
+                    venueInfoDO.setContacts(sitePositionList.getContacts());
+                    venueInfoDO.setType(sitePositionList.getType());
+                    venueInfoDO.setMoney(sitePositionList.getMoney());
+                    venueInfoDO.setClassName(sitePositionList.getClassName());
+                    venueInfoDO.setClassCode(sitePositionList.getClassCode());
+                    venueInfoDO.setAppointments(sitePositionList.getAppointments());
+                    venueInfoDO.setCTypeCode(sitePositionList.getCtypeCode());
+                    venueInfoManage.save(venueInfoDO);
+                }
+            }
+        }
+        return true;
+    }
+
     private void updateDatabase(List<SitePositionList> list, boolean isToday) {
         List<VenueInfoDO> venueInfoDOS = Lists.newArrayList();
         if (isToday) {

xservice-core/src/main/java/com/xiang/app/modules/jntyzx/utils/VenueInfoUtils.java

@@ -1,6 +1,7 @@
 package com.xiang.app.modules.jntyzx.utils;
 
 import com.xiang.app.modules.jntyzx.entity.pojo.VenueInfoDO;
+import com.xiang.app.modules.jntyzx.entity.resp.query.SitePositionList;
 import org.apache.commons.lang3.StringUtils;
 
 /**
@@ -21,4 +22,7 @@ public class VenueInfoUtils {
     public static boolean get8210VenueInfo(VenueInfoDO venueInfoDO) {
         return StringUtils.equals(venueInfoDO.getSjName(), "20:00-21:00") || StringUtils.equals(venueInfoDO.getSjName(), "21:00-22:00");
     }
+    public static boolean get8210VenueInfo(SitePositionList sitePositionList) {
+        return StringUtils.equals(sitePositionList.getSjName(), "20:00-21:00") || StringUtils.equals(sitePositionList.getSjName(), "21:00-22:00");
+    }
 }

xservice-server/src/main/java/com/xiang/app/schedule/jntyzx/JtVenuePullTask.java

@@ -0,0 +1,70 @@
+package com.xiang.app.schedule.jntyzx;
+
+import com.xiang.app.common.service.dingtalk.JtDingTalkFactory;
+import com.xiang.app.modules.jntyzx.entity.pojo.UserTokenInfoDO;
+import com.xiang.app.modules.jntyzx.entity.resp.query.SitePositionList;
+import com.xiang.app.modules.jntyzx.service.IJntyzxHttpService;
+import com.xiang.app.modules.jntyzx.service.IUserTokenInfoService;
+import com.xiang.app.modules.jntyzx.service.IVenueService;
+import com.xiang.app.modules.jntyzx.utils.VenueInfoUtils;
+import com.xiang.core.quartz.annotation.XxzJob;
+import com.xiang.xservice.basic.utils.DateUtils;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Objects;
+
+@Component
+@Slf4j
+@RequiredArgsConstructor
+public class JtVenuePullTask {
+
+    private final IUserTokenInfoService userTokenInfoService;
+    private final IJntyzxHttpService jntyzxHttpService;
+    private final JtDingTalkFactory jtDingTalkFactory;
+    private final IVenueService venueService;
+
+    @XxzJob(name = "jtVenueInfoPullTask")
+    public void handler() {
+        log.info("【Venue】江体小程序场地数据拉取定时任务启动!!!time:{}", System.currentTimeMillis());
+        List<UserTokenInfoDO> availableUser = userTokenInfoService.getAvailableUser();
+        if (CollectionUtils.isEmpty(availableUser)) {
+            log.info("当前无可用用户查询场地信息！");
+            return;
+        }
+        String token;
+        for (UserTokenInfoDO userTokenInfoDO : availableUser) {
+            if (Objects.isNull(userTokenInfoDO)) {
+                continue;
+            }
+            token = userTokenInfoDO.getToken();
+            if (StringUtils.isBlank(token)) {
+                continue;
+            }
+            List<SitePositionList> sitePositionLists = jntyzxHttpService.queryAvailable("1", token);
+            if (CollectionUtils.isEmpty(sitePositionLists)) {
+                continue;
+            }
+            venueService.saveOrUpdateTodayVenueInfo(sitePositionLists);
+
+            sitePositionLists = sitePositionLists.stream().filter(VenueInfoUtils::get8210VenueInfo).toList();
+            if (CollectionUtils.isEmpty(sitePositionLists)) {
+                return;
+            }
+            sitePositionLists = sitePositionLists.stream().filter(item -> StringUtils.equals(item.getContacts(), "0")).toList();
+            if (CollectionUtils.isEmpty(sitePositionLists)) {
+                return;
+            }
+            StringBuffer msg = new StringBuffer("查询到20:00-22:00空闲场地信息===>时间:" + DateUtils.getDateFromDate(LocalDate.now()) + "\n");
+            sitePositionLists.forEach(item -> {
+                msg.append(item.getPlaceName()).append("\n");
+            });
+            jtDingTalkFactory.sendMsg(msg.toString());
+        }
+    }
+}