获取urlscheme优化

zd-modules/zd-base/src/main/java/com/zd/base/message/controller/WechatMsgController.java

@@ -2,6 +2,7 @@ package com.zd.base.message.controller;
 
 import com.zd.base.message.service.IWechatMsgSendService;
 import com.zd.common.core.template.TemplateResult;
+import com.zd.common.core.utils.StringUtils;
 import com.zd.model.domain.R;
 import com.zd.model.domain.ResultData;
 import io.swagger.annotations.Api;
@@ -139,6 +140,10 @@ public class WechatMsgController {
     @ApiOperation(value = "获取UrlScheme")
     @ApiImplicitParam(name = "id",value = "传入id",required = false)
     public ResultData getUrlScheme(@RequestParam(value = "id",required = false)  Long id) {
-        return ResultData.success(sendService.getUrlScheme(id));
+        String urlScheme = sendService.getUrlScheme(id);
+        if(StringUtils.isNotBlank(urlScheme)){
+            return ResultData.success(urlScheme);
+        }
+        return ResultData.fail("");
     }
 }

zd-modules/zd-base/src/main/java/com/zd/base/message/service/impl/WechatMsgSendServiceImpl.java

@@ -293,25 +293,31 @@ public class WechatMsgSendServiceImpl implements IWechatMsgSendService {
      **/
     public String getUrlScheme(Long id) {
         String accessToken = getAccessToken();
-        log.info("获取的token = {}",accessToken);
-        String url = weChatProperties.getUrlScheme()+accessToken;
+        if (StringUtils.isBlank(accessToken)) {
+            log.error("获取token失败！accessToken = {}", accessToken);
+            return "";
+        }
+        String url = weChatProperties.getUrlScheme() + accessToken;
         JSONObject body = new JSONObject();
         JSONObject jumpWxa = new JSONObject();
-        jumpWxa.put("path","/pages/earlyWarningManage/earlyWarningDetail");
-        jumpWxa.put("query","id="+id);
+        jumpWxa.put("path", "/pages/earlyWarningManage/earlyWarningDetail");
+        jumpWxa.put("query", "id=" + id);
         body.put("jump_wxa", jumpWxa);
         body.put("expire_type", "1");
         body.put("expire_interval", "30");
-        log.info("获取UrlScheme url===>>>{}",url);
-        log.info("请求参数===>>>{}",JSON.toJSONString(body));
-        String respData = HttpUtil.post(url,JSON.toJSONString(body));
-        log.info("UrlScheme 返回参数===>>>{}", respData);
-        JSONObject json = JSON.parseObject(respData);
-        if (json.getInteger("errcode") == 0) {
-            String openlink = json.getString("openlink");
-            return openlink;
+        log.info("获取UrlScheme url===>>>{}", url);
+        log.info("请求参数===>>>{}", JSON.toJSONString(body));
+        try {
+            String respData = HttpUtil.post(url, JSON.toJSONString(body));
+            log.info("UrlScheme 返回参数===>>>{}", respData);
+            JSONObject json = JSON.parseObject(respData);
+            if (json.getInteger("errcode") == 0) {
+                String openlink = json.getString("openlink");
+                return openlink;
+            }
+        } catch (Exception e) {
+            log.error("获取UrlScheme异常！==>>{}",e);
         }
-        log.info("生成openlink失败！");
         return "";
     }
 }