From 1d07ee4cfa2965587f092e5295ce96f4079268b4 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期六, 26 七月 2025 16:50:11 +0800
Subject: [PATCH] 更新微信三方

---
 DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/api/DriverController.java |   70 +++++++---------------------------
 1 files changed, 15 insertions(+), 55 deletions(-)

diff --git a/DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/api/DriverController.java b/DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/api/DriverController.java
index fe52aee..eeb5a38 100644
--- a/DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/api/DriverController.java
+++ b/DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/api/DriverController.java
@@ -26,7 +26,7 @@
 import com.stylefeng.guns.modular.system.util.ALiSendSms;
 import com.stylefeng.guns.modular.system.util.ResultUtil;
 import com.stylefeng.guns.modular.system.util.WeChatUtil;
-import com.stylefeng.guns.modular.system.util.qianyuntong.NCOSSUtil;
+//import com.stylefeng.guns.modular.system.util.qianyuntong.NCOSSUtil;
 import com.stylefeng.guns.modular.system.util.qianyuntong.QianYunTongConfig;
 import com.stylefeng.guns.modular.system.warpper.*;
 import com.stylefeng.guns.modular.taxi.model.OrderTaxi;
@@ -40,6 +40,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.http.*;
+import org.springframework.util.Base64Utils;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 import org.springframework.web.bind.annotation.*;
@@ -57,6 +58,7 @@
 import java.text.MessageFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 import static org.bouncycastle.cms.RecipientId.password;
@@ -533,13 +535,11 @@
 
 
     @ApiOperation(value = "个人的小程序码(分享码)/链接", tags = {"司机端-首页"}, notes = "")
-    @GetMapping("/api/driver/person-code")
+    @GetMapping("/api/driver/personCode")
     @ApiImplicitParams({
             @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
     })
-    public ResultUtil<HashMap<String, String>> createQRcode(HttpServletRequest request) {
-        InputStream inputStream = null;
-        OutputStream outputStream = null;
+    public ResultUtil<HashMap<String, Object>> personCode(HttpServletRequest request) {
         try {
             Integer uid = driverService.getUserIdFormRedis(request);
             if (null == uid) {
@@ -547,37 +547,26 @@
             }
             Driver driver = driverService.selectById(uid);
             String accessToken=null;
+            Object img = redisTemplate.opsForValue().get("DRIVER_WX_IMG" + uid);
             // 获取调用凭证accessToken
-            if(ToolUtil.isEmpty(driver.getShareImg())|| ToolUtil.isEmpty(driver.getShareImg())){
+            if(ToolUtil.isEmpty(driver.getShareLink())|| ToolUtil.isEmpty(img)){
                 accessToken = getAccessToken();
             }
-            String img=driver.getShareImg();
             int index=0;
 
-            if(ToolUtil.isEmpty(driver.getShareImg())) {
-                index=1;
+            if(ToolUtil.isEmpty(img)) {
                 RestTemplate rest = new RestTemplate();
-                String imgUrl = "";
                 String url = "https://api.weixin.qq.com/cgi-bin/wxaapp/createwxaqrcode?access_token=" + accessToken;
                 Map<String, Object> param = new HashMap<>();
                 param.put("path", "pages/home/home?driverId=" + uid);
                 param.put("width", 430); //二维码尺寸
-                MultiValueMap<String, String> headers = new LinkedMultiValueMap<>();
-                HttpEntity requestEntity = new HttpEntity(param, headers);
-                ResponseEntity<byte[]> entity = rest.exchange(url, HttpMethod.POST, requestEntity, byte[].class, new Object[0]);
-                byte[] result = entity.getBody();
-                inputStream = new ByteArrayInputStream(result);
+                HttpRequest post = HttpUtil.createPost(url);
+                post.body(JSON.toJSONString(param));
 
-                SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
-                // 最后上传生成的文件名
-                String finalFileName = System.currentTimeMillis() + "" + new SecureRandom().nextInt(0x0400) + ".jpg";
-                // oss中的文件夹名
-                String objectName = sdf.format(new Date()) + "/" + finalFileName;
-                String key = "imgs/management/" + objectName;
-                String object = NCOSSUtil.putObject(qianYunTongConfig.getBucketName(), key, inputStream);
-                System.out.println(object);
-                driver.setShareImg(object);
-                img= object;
+                byte[] result = post.execute().bodyBytes();
+                // base64
+                img = Base64.getEncoder().encodeToString(result);
+                redisTemplate.opsForValue().set("DRIVER_WX_IMG" + uid, img,30, TimeUnit.DAYS);
             }
 
             String urlLink = driver.getShareLink();
@@ -602,42 +591,13 @@
                 driverService.updateById(driver);
             }
 
-            HashMap<String, String> stringStringHashMap = new HashMap<>();
+            HashMap<String, Object> stringStringHashMap = new HashMap<>();
             stringStringHashMap.put("url_link",urlLink);
             stringStringHashMap.put("img",img);
-
-
-//            inputStream = new ByteArrayInputStream(result);
-//
-//            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
-//            // 最后上传生成的文件名
-//            String finalFileName = System.currentTimeMillis() + "" + new SecureRandom().nextInt(0x0400) + ".jpg";
-//            // oss中的文件夹名
-//            String objectName = sdf.format(new Date()) + "/" + finalFileName;
-//            // 上传oss
-////            ossUtil.uploadFile2OSS(inputStream, objectName);
-////            //获取文件的URl地址
-////            imgUrl = ossUtil.getImgUrl(objectName);
-//            log.info("imgUrl: "+imgUrl);
             return ResultUtil.success(stringStringHashMap);
 
         } catch (Exception e) {
             log.error("调用小程序生成微信永久小程序码URL接口异常", e);
-        }finally {
-            if(inputStream != null){
-                try {
-                    inputStream.close();
-                } catch (IOException e) {
-                    e.printStackTrace();
-                }
-            }
-            if(outputStream != null){
-                try {
-                    outputStream.close();
-                } catch (IOException e) {
-                    e.printStackTrace();
-                }
-            }
         }
         return ResultUtil.error("获取二维码失败");
     }

--
Gitblit v1.7.1