黔云通
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
liujie
7 天以前 1d07ee4cfa2965587f092e5295ce96f4079268b4 
 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("获取二维码失败");


    }