Merge branch 'master' into master

austin-common/src/main/java/com/java3y/austin/common/dto/account/YunPianSmsAccount.java

@@ -1,45 +0,0 @@
-package com.java3y.austin.common.dto.account;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * 云片账号信息
- * <p>
- * 参数示例：
- * [{"sms_20":{"url":"https://sms.yunpian.com/v2/sms/tpl_batch_send.json","apikey":"ca55d4c8544444444444622221b5cd7","tpl_id":"533332222282","supplierId":20,"supplierName":"云片"}}]
- *
- * @author 3y
- */
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-public class YunPianSmsAccount {
-
-    /**
-     * apikey
-     */
-    private String apikey;
-    /**
-     * tplId
-     */
-    private String tplId;
-
-    /**
-     * api相关
-     */
-    private String url;
-
-    /**
-     * 标识渠道商Id
-     */
-    private Integer supplierId;
-
-    /**
-     * 标识渠道商名字
-     */
-    private String supplierName;
-}

austin-handler/src/main/java/com/java3y/austin/handler/action/SendMessageAction.java

@@ -10,7 +10,6 @@ import com.java3y.austin.handler.handler.HandlerHolder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-
 /**
  * 发送消息，路由到对应的渠道下发消息
  *
@@ -29,8 +28,8 @@ public class SendMessageAction implements BusinessProcess<TaskInfo> {
         if (ChannelType.MINI_PROGRAM.getCode().equals(taskInfo.getSendChannel())
                 || ChannelType.OFFICIAL_ACCOUNT.getCode().equals(taskInfo.getSendChannel())
                 || ChannelType.ALIPAY_MINI_PROGRAM.getCode().equals(taskInfo.getSendChannel())) {
-            for (String receiver : taskInfo.getReceiver()) {
             TaskInfo taskClone = ObjectUtil.cloneByStream(taskInfo);
+            for (String receiver : taskInfo.getReceiver()) {
                 taskClone.setReceiver(Sets.newHashSet(receiver));
                 handlerHolder.route(taskInfo.getSendChannel()).doHandler(taskClone);
             }

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

@@ -6,6 +6,7 @@ import cn.hutool.core.net.URLEncodeUtil;
 import cn.hutool.core.text.CharSequenceUtil;
 import cn.hutool.core.text.StrPool;
 import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.StrUtil;
 import cn.hutool.http.Header;
 import cn.hutool.http.HttpRequest;
 import com.alibaba.fastjson.JSON;
@@ -82,7 +83,9 @@ public class YunPianSmsScript implements SmsScript {
         params.put("apikey", account.getApikey());
         params.put("mobile", StringUtils.join(smsParam.getPhones(), StrPool.COMMA));
         params.put("tpl_id", account.getTplId());
+        if (CharSequenceUtil.isNotBlank(smsParam.getContent()) && smsParam.getContent().contains(PARAMS_KV_SPLIT_KEY)) {
             params.put("tpl_value", getTplValue(smsParam));
+        }
         return params;
     }
 

austin-support/src/main/java/com/java3y/austin/support/utils/AccountUtils.java

@@ -119,7 +119,7 @@ public class AccountUtils {
      */
     public WxMpService initOfficialAccountService(WeChatOfficialAccount officialAccount) {
         WxMpService wxMpService = new WxMpServiceImpl();
-        WxMpRedisConfigImpl config = new WxMpRedisConfigImpl(redisTemplateWxRedisOps(), ChannelType.ENTERPRISE_WE_CHAT.getAccessTokenPrefix());
+        WxMpRedisConfigImpl config = new WxMpRedisConfigImpl(redisTemplateWxRedisOps(), ChannelType.OFFICIAL_ACCOUNT.getAccessTokenPrefix());
         config.setAppId(officialAccount.getAppId());
         config.setSecret(officialAccount.getSecret());
         config.setToken(officialAccount.getToken());

austin-web/src/main/java/com/java3y/austin/web/exception/ExceptionHandlerAdvice.java

@@ -26,8 +26,9 @@ public class ExceptionHandlerAdvice {
     @ExceptionHandler({Exception.class})
     @ResponseStatus(HttpStatus.OK)
     public BasicResultVO<String> exceptionResponse(Exception e) {
-        log.error(Throwables.getStackTrace(e));
+        String errStackStr = Throwables.getStackTrace(e);
-        return BasicResultVO.fail(RespStatusEnum.ERROR_500, "\r\n" + Throwables.getStackTrace(e) + "\r\n");
+        log.error(errStackStr);
+        return BasicResultVO.fail(RespStatusEnum.ERROR_500, "\r\n" + errStackStr + "\r\n");
     }
 
     @ExceptionHandler({CommonException.class})