增加站点同步至飞书表格

jeecg-boot/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/okki/wechatgroup/service/impl/OkkiShopWechatGroupMsgServiceImpl.java

@@ -7,6 +7,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang.StringUtils;
 import org.jeecg.common.util.FastJsonUtil;
+import org.jeecg.common.util.ThreadPoolUtil;
 import org.jeecg.modules.okki.site.entity.OkkiSite;
 import org.jeecg.modules.okki.site.service.IOkkiSiteService;
 import org.jeecg.modules.okki.utils.HttpClientUtils;
@@ -55,10 +56,13 @@ public class OkkiShopWechatGroupMsgServiceImpl extends ServiceImpl<OkkiShopWecha
         List<OkkiShopWechatGroupMsg> shopWechatGroupMsgs = okkiShopWechatGroupMsgMapper.getSiteWechatMsgList(siteId);
         log.info("一共有：{}个站点,需要企业微信群消息", shopWechatGroupMsgs.size());
         for (int i = 0; i < shopWechatGroupMsgs.size(); i++) {
-            OkkiShopWechatGroupMsg okkiShopWechatGroupMsg = shopWechatGroupMsgs.get(i);
-            int maxSeq = okkiShopWechatGroupMsg.getSeq() == 0 ? 1 : okkiShopWechatGroupMsg.getSeq();
-            log.info("开始处理第{}个，站点ID为：{},seq为：{},企业微信群消息", i + 1, okkiShopWechatGroupMsg.getSiteId(), maxSeq);
-            saveWechatGroupMsg(String.valueOf(okkiShopWechatGroupMsg.getSiteId()), maxSeq);
+            int finalI = i;
+            ThreadPoolUtil.execute(()->{
+                OkkiShopWechatGroupMsg okkiShopWechatGroupMsg = shopWechatGroupMsgs.get(finalI);
+                int maxSeq = okkiShopWechatGroupMsg.getSeq() == 0 ? 1 : okkiShopWechatGroupMsg.getSeq();
+                log.info("开始处理第{}个，站点ID为：{},seq为：{},企业微信群消息", finalI + 1, okkiShopWechatGroupMsg.getSiteId(), maxSeq);
+                saveWechatGroupMsg(String.valueOf(okkiShopWechatGroupMsg.getSiteId()), maxSeq);
+            });
         }
     }
 
@@ -70,7 +74,6 @@ public class OkkiShopWechatGroupMsgServiceImpl extends ServiceImpl<OkkiShopWecha
      */
     public void saveWechatGroupMsg(String siteId, Integer minSeq) {
         List<OkkiShopWechatGroupMsg> wechatGroupMsgList = sendWechatGroupMsgRequest(siteId, minSeq);
-        log.info("本次请求企业微信群消息数据:{}", FastJsonUtil.toJSONString(wechatGroupMsgList));
         List<OkkiShopWechatGroupMsg> shopWechatGroupMsgs = new ArrayList<>();
         if (!CollectionUtils.isEmpty(wechatGroupMsgList)) {
             wechatGroupMsgList.forEach(c -> {
@@ -126,7 +129,6 @@ public class OkkiShopWechatGroupMsgServiceImpl extends ServiceImpl<OkkiShopWecha
             String msgResult = HttpClientUtils.doPost(okkiUrl, body);
             // {"code":0,"msg":"success","now":"2024-09-09 09:42:28","data":[]}
             WechatGroupMsgRespDto wechatGroupMsgRespDto = JSONObject.parseObject(msgResult, WechatGroupMsgRespDto.class);
-            log.info("wechatGroupMsgRespDto:{}", FastJsonUtil.toJSONString(wechatGroupMsgRespDto));
             if (wechatGroupMsgRespDto.getCode() != 0) {
                 throw new RuntimeException(wechatGroupMsgRespDto.getMsg());
             }

jeecg-boot/jeecg-module-system/jeecg-system-start/src/main/java/org/jeecg/JeecgSystemApplication.java

@@ -11,6 +11,7 @@ import org.springframework.core.env.Environment;
 
 import java.net.InetAddress;
 import java.net.UnknownHostException;
+import java.util.TimeZone;
 
 /**
 * 单体启动类
@@ -27,6 +28,11 @@ public class JeecgSystemApplication extends SpringBootServletInitializer {
     }
 
     public static void main(String[] args) throws UnknownHostException {
+        // 设置时区为Asia/Shanghai
+        log.info("系统初始化时设置运行时区为：GMT+8");
+        System.setProperty("spring.devtools.restart.enabled", "true");
+        TimeZone.setDefault(TimeZone.getTimeZone("GMT+8"));
+
         ConfigurableApplicationContext application = SpringApplication.run(JeecgSystemApplication.class, args);
         Environment env = application.getEnvironment();
         String ip = InetAddress.getLocalHost().getHostAddress();