From 11edfa154a6f6c48d06de201315b25978601229c Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Wed, 07 Sep 2022 14:29:51 +0800 Subject: [PATCH] 20220902 --- src/main/java/cc/mrbird/febs/pay/service/impl/XcxPayServiceImpl.java | 112 +++++++++++++++++++++++++++++++++++++------------------ 1 files changed, 75 insertions(+), 37 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/pay/service/impl/XcxPayServiceImpl.java b/src/main/java/cc/mrbird/febs/pay/service/impl/XcxPayServiceImpl.java index 4f05fb7..f43d50e 100644 --- a/src/main/java/cc/mrbird/febs/pay/service/impl/XcxPayServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/pay/service/impl/XcxPayServiceImpl.java @@ -158,42 +158,41 @@ @Override public FebsResponse getQrCode(WxGenerateQrCodeDto wxGenerateQrCodeDto) { - //这里调用的是上面的获取access_token方法 - String access_token = redisUtils.get(WechatConfigure.WX_ACCESS_TOKEN_REDIS_KEY).toString(); - String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+access_token; - String scene = wxGenerateQrCodeDto.getScene(); - Map<String, String> param = new HashMap<>(); - param.put("scene",scene); - //这里的page如果没有的话可以不写,默认是跳主页,如果写了没有的页面的话,会返回错误信息 - param.put("page",wxGenerateQrCodeDto.getPage()); - String json = JSON.toJSONString(param); - ByteArrayInputStream inputStream = sendPost(url, json); - try { - System.out.println(inputStream); - //这里判断的是返回的图片还是错误信息,一般错误信息不会大于200 - if (inputStream.available() <= 200){ - ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); - int i; - byte[] buffer = new byte[200]; - while ((i = inputStream.read(buffer)) != -1){ - byteArrayOutputStream.write(buffer,0,i); - } - String str = new String(byteArrayOutputStream.toByteArray()); - System.out.println(str); - //错误信息的格式在官方文档里有 - com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(str); - if ("41030".equals(jsonObject.getString("errcode"))){ - return new FebsResponse().fail().data("所传page页面不存在,或者小程序没有发布"); - }else if ("45009".equals(jsonObject.getString("errcode"))){ - return new FebsResponse().fail().data("调用分钟频率受限"); - } - byteArrayOutputStream.close(); - } - inputStream.close(); - }catch (Exception e){ - return new FebsResponse().fail().data("获取二维码失败"); - } - return new FebsResponse().success().data(inputStream); +// //这里调用的是上面的获取access_token方法 +// String access_token = redisUtils.get(WechatConfigure.WX_ACCESS_TOKEN_REDIS_KEY).toString(); +// String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+access_token; +// String scene = wxGenerateQrCodeDto.getScene(); +// Map<String, String> param = new HashMap<>(); +// param.put("scene",scene); +// //这里的page如果没有的话可以不写,默认是跳主页,如果写了没有的页面的话,会返回错误信息 +// param.put("page",wxGenerateQrCodeDto.getPage()); +// String json = JSON.toJSONString(param); +// ByteArrayInputStream inputStream = sendPost(url, json); +// try { +// System.out.println(inputStream); +// //这里判断的是返回的图片还是错误信息,一般错误信息不会大于200 +// if (inputStream.available() <= 200){ +// ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); +// int i; +// byte[] buffer = new byte[200]; +// while ((i = inputStream.read(buffer)) != -1){ +// byteArrayOutputStream.write(buffer,0,i); +// } +// String str = new String(byteArrayOutputStream.toByteArray()); +// byteArrayOutputStream.close(); +// //错误信息 +// com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(str); +// if ("41030".equals(jsonObject.getString("errcode"))){ +// return new FebsResponse().fail().data("所传page页面不存在,或者小程序没有发布"); +// }else if ("45009".equals(jsonObject.getString("errcode"))){ +// return new FebsResponse().fail().data("调用分钟频率受限"); +// } +// } +// inputStream.close(); +// }catch (Exception e){ +// return new FebsResponse().fail().data("获取二维码失败"); +// } + return new FebsResponse().success(); } @Override @@ -298,11 +297,50 @@ return wxTemplates; } + @Autowired + private MallGoodsMapper mallGoodsMapper; + @Autowired + private MallTeamLeaderMapper mallTeamLeaderMapper; + @Override public FebsResponse generateQrCode(WxGenerateQrCodeDto wxGenerateQrCodeDto) { + Integer type = wxGenerateQrCodeDto.getType(); + if(1 == type){ + long goodsId = StrUtil.isBlank(wxGenerateQrCodeDto.getTypeParam()) ? 0L : Long.parseLong(wxGenerateQrCodeDto.getTypeParam()); + MallGoods mallGoods = mallGoodsMapper.selectById(goodsId); + if(ObjectUtil.isNotNull(mallGoods)){ + String wxCodeImg = mallGoods.getWxCodeImg(); + if(StrUtil.isNotBlank(wxCodeImg)){ + return new FebsResponse().success().data(wxCodeImg); + } + } + } + if(2 == type){ + String uniqueCode = wxGenerateQrCodeDto.getTypeParam(); + MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(uniqueCode); + if(ObjectUtil.isNotNull(mallTeamLeader)){ + String wxCodeImg = mallTeamLeader.getWxCodeImg(); + if(StrUtil.isNotBlank(wxCodeImg)){ + return new FebsResponse().success().data(wxCodeImg); + } + } + } + String randomNum = MallUtils.getRandomNum(5); String imgName="/user_" + randomNum + "_acode_1.jpg"; String codeImgPath = generateAcode(wxGenerateQrCodeDto.getScene(), wxGenerateQrCodeDto.getPage(), imgName, "800px", null); + if(1 == type){ + long goodsId = StrUtil.isBlank(wxGenerateQrCodeDto.getTypeParam()) ? 0L : Long.parseLong(wxGenerateQrCodeDto.getTypeParam()); + MallGoods mallGoods = mallGoodsMapper.selectById(goodsId); + mallGoods.setWxCodeImg(codeImgPath); + mallGoodsMapper.updateById(mallGoods); + } + if(2 == type){ + String uniqueCode = wxGenerateQrCodeDto.getTypeParam(); + MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(uniqueCode); + mallTeamLeader.setWxCodeImg(codeImgPath); + mallTeamLeaderMapper.updateById(mallTeamLeader); + } return new FebsResponse().success().data(codeImgPath); } @@ -363,7 +401,7 @@ //图片上传路径 public static final String IMG_UPLOAD_PATH="/mnt/sdc/webresource/groupbuy/wxcode"; public String generateAcode(String scene,String path,String imgName,String width, Integer type){ - String urlPrefix="http://hwfile.csxuncong.com/groupbuy/wxcode"; + String urlPrefix="https://hwfile.csxuncong.com/groupbuy/wxcode"; String imgPath=IMG_UPLOAD_PATH+imgName; if(!FileUtil.exist(imgPath)){ -- Gitblit v1.9.1