接入 hades 升级v1.0.4版本

austin-common/src/main/java/com/java3y/austin/common/constant/OfficialAccountParamConstant.java

@@ -39,7 +39,7 @@ public class OfficialAccountParamConstant {
     /**
      * 扫码/关注后/取消关注后的服务号文案
      */
-    public static final String SUBSCRIBE_TIPS = "项目群还有少量名额，添加我的微信 sanwai3y  备注【项目】，我会拉入项目群";
+    public static final String SUBSCRIBE_TIPS = "项目群还有少量名额，添加我的微信 java3yyy  备注【项目】，我会拉入官方项目交流群";
     public static final String SCAN_TIPS = "咋又扫码啦？重新关注一波吧！";
     public static final String UNSUBSCRIBE_TIPS = "老乡别走！";
 

austin-handler/src/main/java/com/java3y/austin/handler/script/impl/YunPianSmsScript.java

@@ -16,8 +16,9 @@ import com.java3y.austin.handler.domain.sms.YunPianSendResult;
 import com.java3y.austin.handler.script.SmsScript;
 import com.java3y.austin.support.domain.SmsRecord;
 import com.java3y.austin.support.utils.AccountUtils;
-import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -28,9 +29,11 @@ import java.util.*;
  * @date 2022年5月23日
  * 发送短信接入文档：https://www.yunpian.com/official/document/sms/zh_CN/domestic_list
  */
-@Slf4j
 @Component("YunPianSmsScript")
 public class YunPianSmsScript implements SmsScript {
+
+    private static Logger log = LoggerFactory.getLogger(YunPianSmsScript.class);
+
     @Autowired
     private AccountUtils accountUtils;
 

austin-support/src/main/java/com/java3y/austin/support/pending/AbstractLazyPending.java

@@ -56,6 +56,12 @@ public abstract class AbstractLazyPending<T> {
                         tasks.add(obj);
                     }
 
+                    // 判断是否停止当前线程
+                    if (stop && CollUtil.isEmpty(tasks)) {
+                        executorService.shutdown();
+                        break;
+                    }
+
                     // 处理条件：1. 数量超限 2. 时间超限
                     if (CollUtil.isNotEmpty(tasks) && dataReady()) {
                         List<T> taskRef = tasks;
@@ -66,11 +72,7 @@ public abstract class AbstractLazyPending<T> {
                         pendingParam.getExecutorService().execute(() -> this.handle(taskRef));
                     }
 
-                    // 判断是否停止当前线程
-                    if (stop && CollUtil.isEmpty(tasks)) {
-                        executorService.shutdown();
-                        break;
-                    }
+
                 } catch (Exception e) {
                     log.error("Pending#initConsumePending failed:{}", Throwables.getStackTraceAsString(e));
                 }

austin-web/src/main/resources/application.properties

@@ -85,7 +85,7 @@ apollo.bootstrap.namespaces=${austin.default.apollo.namespace:boss.austin},dynam
 nacos.config.server-addr=${austin.nacos.addr.ip:austin-nacos}:${austin.nacos.addr.port:8848}
 nacos.config.username=${austin.nacos.username:nacos}
 nacos.config.password=${austin.nacos.password:nacos}
-nacos.config.namespace=${austin.nacos.namespace:60e2b165-d830-4163-a0e9-b97ec2f7164c}
+nacos.config.namespace=${austin.nacos.namespace:hades}
 nacos.config.enabled=${austin.nacos.enabled}
 
 nacos.data-id=${austin.nacos.dataId:austin}
@@ -93,9 +93,8 @@ nacos.group=${austin.nacos.group:DEFAULT_GROUP}
 ########################################## nacos end ##########################################
 
 ########################################## rule Engine start ##########################################
-hades.main.config.enabled=${austin.rule.engine.enabled:false}
-hades.main.config.file-name=${austin.rule.engine.file-name:hades}
-hades.main.config.group-name=${austin.rule.engine.group-name:hades}
+hades.enabled=${austin.rule.engine.enabled:false}
+hades.config-name=${austin.rule.engine.file-name:hades}
 ########################################## rule Engine end ##########################################
 
 ########################################## log start ##########################################

pom.xml

@@ -218,17 +218,17 @@
                 <version>2.2.2</version>
             </dependency>
 
-            <!--hades规则引擎：https://github.com/ZhongFuCheng3y/hades-->
+            <!-- hades规则引擎：https://github.com/ZhongFuCheng3y/hades -->
             <dependency>
                 <groupId>io.github.ZhongFuCheng3y</groupId>
                 <artifactId>hades-nacos-starter</artifactId>
-                <version>1.0.3</version>
+                <version>1.0.4</version>
             </dependency>
             <!--用hades规则引擎用nacos做演示，apollo注释掉-->
             <!--            <dependency>-->
             <!--                <groupId>io.github.ZhongFuCheng3y</groupId>-->
             <!--                <artifactId>hades-apollo-starter</artifactId>-->
-            <!--                <version>1.0.3</version>-->
+            <!--                <version>1.0.4</version>-->
             <!--            </dependency>-->
         </dependencies>
     </dependencyManagement>