20220902

xiaoyong931011

2022-09-07 65e5e0a89ae66f3966290af58db5ed82f66531c1

20220902

 src/main/java/cc/mrbird/febs/pay/service/impl/XcxPayServiceImpl.java

@@ -17,9 +17,13 @@
import cc.mrbird.febs.pay.util.WechatConfigure;
import cc.mrbird.febs.pay.util.WeixinServiceUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.text.StrFormatter;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.extra.spring.SpringUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.dynamic.datasource.toolkit.Base64;
@@ -32,6 +36,7 @@
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import cn.hutool.core.io.FileUtil;

import java.io.*;
import java.math.BigDecimal;
@@ -248,38 +253,78 @@

    @Override
    public FebsResponse generateQrCode(WxGenerateQrCodeDto wxGenerateQrCodeDto) {
        String base64 = null;
//        try {
//            RestTemplate restTemplate = new RestTemplate();
//            String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" + redisUtils.get(WechatConfigure.WX_ACCESS_TOKEN_REDIS_KEY);
//            Map<String, Object> params = new HashMap<>();
//            params.put("scene", wxGenerateQrCodeDto.getScene());
//            params.put("page", wxGenerateQrCodeDto.getPage());
//            params.put("width", 430);
//            ResponseEntity<byte[]> responseEntity = restTemplate.postForEntity(url, params, byte[].class);
//            log.info(String.valueOf(JSONUtil.parse(responseEntity)));
//            if (responseEntity.getStatusCode() == HttpStatus.OK) {
//                byte[] body = responseEntity.getBody();
//                InputStream inputStream = new ByteArrayInputStream(body);
//                // 将获取流转为base64格式
//                byte[] data = null;
//                ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
//                byte[] buff = new byte[100];
//                int rc = 0;
//                while ((rc = inputStream.read(buff, 0, 100)) > 0) {
//                    swapStream.write(buff, 0, rc);
//                }
//                data = swapStream.toByteArray();
//                base64 = Base64.byteArrayToBase64(data);
//                inputStream.close();
//                swapStream.close();
//
//                return new FebsResponse().success().data(body);
//            }
//        } catch (IOException e) {
//            throw new ApiException("生成二维码失败");
//        }
        return new FebsResponse().success();
        String randomNum = MallUtils.getRandomNum(5);
        String imgName="user_" + randomNum + "_acode_1.jpg";
        String codeImgPath = generateAcode(wxGenerateQrCodeDto.getScene(), wxGenerateQrCodeDto.getPage(), imgName, "800px", null);
        return new FebsResponse().success().data(codeImgPath);
    }


    /**
     * 生成小程序码
     * @param scene 参数
     * @param path  跳转路径
     * @param imgName  图片唯一名称
     * @return
     */
    //图片上传路径
    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 imgPath=IMG_UPLOAD_PATH+imgName;
        if(!FileUtil.exist(imgPath)){

            cn.hutool.json.JSONObject obj = JSONUtil.createObj();
            //调用二维码接口
            String url = null;
            if (type == null) {
                // 该接口无数量限制，但是 scene 传参最大字符长度为32个字符
                url = StrFormatter.format("https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token={}",redisUtils.get(WechatConfigure.WX_ACCESS_TOKEN_REDIS_KEY).toString());
                obj.put("scene", scene);
                obj.put("path", path);
            } else {
                // 该接口存在数量限制, 总共可生成10w个, 但参数是接在path后面
                url = StrFormatter.format("https://api.weixin.qq.com/wxa/getwxacode?access_token={}", redisUtils.get(WechatConfigure.WX_ACCESS_TOKEN_REDIS_KEY).toString());
                obj.put("path", path + "?" + scene );
            }

            //最小 280px，最大 1280px
            obj.put("width", width);
            obj.put("auto_color", false);
            cn.hutool.json.JSONObject obj2 = JSONUtil.createObj();
            obj2.put("r", 0);
            obj2.put("g", 0);
            obj2.put("b", 0);
            obj.put("line_color", obj2);
            //是否需要透明底色，为 true 时，生成透明底色的小程序码
            obj.put("is_hyaline", false);
            try {
                HttpResponse execute = HttpRequest.post(url).body(obj.toString(), "application/json").execute();
                InputStream inputStream = execute.bodyStream();
                File file = new File(imgPath);
                FileUtil.writeFromStream(inputStream, file);
                long uploadUrl = FileUtil.size(file);
                //小于10kb重新生成
                if(uploadUrl<=10240){
                    log.error("生成微信小程序码失败:图片大小异常：{}",uploadUrl);
                    return null;
                }
            } catch (Exception e) {
                log.error("生成微信小程序码失败",e);
                return null;
            }

        }else {
            //判断文件是否正常 不正常 删除
            File file = new File(imgPath);
            long uploadUrl = FileUtil.size(file);
            if(uploadUrl<=10240){
                FileUtil.del(file);
                return null;
            }
        }
        log.debug("生成微信小程序码成功，路径：" + imgPath);
        return urlPrefix+"/"+imgName;
    }

    /**

 src/main/resources/mapper/modules/MallLeaderAchieveMapper.xml

@@ -51,7 +51,7 @@
                <if test="record.invitedId != null and record.invitedId != ''">
                    and a.unique_code = #{record.invitedId}
                </if>
                <if test="record.createdTime!=null">
                <if test="record.createdTime != null and record.createdTime != ''">
                    and date_format(a.CREATED_TIME, '%Y-%m-%d') = #{record.createdTime}
                </if>
            </if>

 src/test/java/cc/mrbird/febs/ProfitTest.java

@@ -210,7 +210,7 @@
    @Test
    public void qrcodeBase64(){
        WxGenerateQrCodeDto wxGenerateQrCodeDto = new WxGenerateQrCodeDto();
        wxGenerateQrCodeDto.setPage("wxGenerateQrCodeDto");
        wxGenerateQrCodeDto.setPage("pages/index/index");
        wxGenerateQrCodeDto.setScene("15");
        FebsResponse febsResponse = iXcxPayService.generateQrCode(wxGenerateQrCodeDto);
        String data = febsResponse.get("data").toString();