blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2022-08-15 109545b7fb882458c1e6ab30d5248420d55fb6fd 
 src/main/java/cc/mrbird/febs/pay/service/impl/XcxPayServiceImpl.java


@@ -1,7 +1,9 @@


package cc.mrbird.febs.pay.service.impl;




import cc.mrbird.febs.common.entity.FebsResponse;


import cc.mrbird.febs.common.enumerates.DataDictionaryEnum;


import cc.mrbird.febs.common.properties.XcxProperties;


import cc.mrbird.febs.common.utils.OssUtils;


import cc.mrbird.febs.common.utils.RedisUtils;


import cc.mrbird.febs.common.utils.SpringContextHolder;


import cc.mrbird.febs.mall.entity.DataDictionaryCustom;


@@ -11,29 +13,28 @@


import cc.mrbird.febs.mall.mapper.DataDictionaryCustomMapper;


import cc.mrbird.febs.mall.mapper.MallMemberMapper;


import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper;


import cc.mrbird.febs.pay.model.BrandWCPayRequestData;


import cc.mrbird.febs.pay.model.OrderStateDto;


import cc.mrbird.febs.pay.model.OrderStateMsgVo;


import cc.mrbird.febs.pay.model.WxTemplateData;


import cc.mrbird.febs.pay.model.*;


import cc.mrbird.febs.pay.service.IXcxPayService;


import cc.mrbird.febs.pay.util.WechatConfigure;


import cc.mrbird.febs.pay.util.WeixinServiceUtil;


import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage;


import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;


import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.util.IdUtil;


import cn.hutool.core.util.StrUtil;


import cn.hutool.json.JSONObject;


import cn.hutool.json.JSONUtil;


import cn.hutool.log.Log;


import com.alibaba.fastjson.JSON;


import com.baomidou.dynamic.datasource.toolkit.Base64;


import com.baomidou.mybatisplus.extension.exceptions.ApiException;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.collections.CollectionUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.http.HttpStatus;


import org.springframework.http.ResponseEntity;


import org.springframework.stereotype.Service;


import org.springframework.web.client.RestTemplate;




import java.io.IOException;


import java.io.*;


import java.math.BigDecimal;


import java.net.*;


import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


@@ -162,6 +163,39 @@


        return wxTemplates;


    }




    @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);


            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();


            }


        } catch (IOException e) {


            throw new ApiException("生成二维码失败");


        }


        return new FebsResponse().success().data(base64);


    }




    /**


     * 根据用户ID和订单ID获取所购买商品名称


     * @return 所含商品名称（多个以"，"隔开）