20220810

xiaoyong931011

2022-08-15 109545b7fb882458c1e6ab30d5248420d55fb6fd

20220810

 src/main/java/cc/mrbird/febs/mall/controller/ApiLoginController.java

@@ -3,6 +3,8 @@
import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.mall.dto.*;
import cc.mrbird.febs.mall.service.IApiMallMemberService;
import cc.mrbird.febs.pay.model.WxGenerateQrCodeDto;
import cc.mrbird.febs.pay.service.IXcxPayService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
@@ -28,6 +30,7 @@
public class ApiLoginController {

    private final IApiMallMemberService memberService;
    private final IXcxPayService iXcxPayService;

    @ApiOperation(value = "app注册接口", notes = "app注册接口")
    @PostMapping(value = "/register")
@@ -95,4 +98,13 @@
        return memberService.xcxOpen(apiXcxOpenDto);
    }

    /**
     * 获取分享二维码
     */
    @ApiOperation(value = "获取分享二维码", notes = "获取分享二维码")
    @PostMapping(value = "/generateQrCode")
    public FebsResponse generateQrCode(@RequestBody WxGenerateQrCodeDto wxGenerateQrCodeDto){
        return iXcxPayService.generateQrCode(wxGenerateQrCodeDto);
    }

}

 src/main/java/cc/mrbird/febs/pay/model/WxGenerateQrCodeDto.java

New file
@@ -0,0 +1,20 @@
package cc.mrbird.febs.pay.model;

import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

@Data
public class WxGenerateQrCodeDto {

    //当前小程序相对页面 必须是已经发布的小程序存在的页面(否则报错)，
    // 例如 pages/index/index, 根路径前不要填加 /,不能携带参数(参数请放在scene字段里)，如果不填写这个字段，默认跳主页面

    @ApiModelProperty(value = "跳转路径 例如 pages/index/index")
    private String page;
    //最大32个可见字符，只支持数字，大小写英文以及部分特殊字符：!#$&'()*+,/:;=?@-._~，
    // 其它字符请自行编码为合法字符(因不支持%，中文无法使用 urlencode 处理，请使用其他编码方式)

    @ApiModelProperty(value = "参数 订单id 例如 15")
    private String scene;

}

 src/main/java/cc/mrbird/febs/pay/service/IXcxPayService.java

@@ -1,8 +1,10 @@
package cc.mrbird.febs.pay.service;

import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.mall.entity.MallOrderInfo;
import cc.mrbird.febs.pay.model.BrandWCPayRequestData;
import cc.mrbird.febs.pay.model.OrderStateDto;
import cc.mrbird.febs.pay.model.WxGenerateQrCodeDto;

import java.util.List;

@@ -24,4 +26,9 @@
    void uniformMessageSend(OrderStateDto info);

    List<String> getTemplateId();

    /**
     * 生成小程序二维码
     */
    FebsResponse generateQrCode(WxGenerateQrCodeDto wxGenerateQrCodeDto);
}

 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 所含商品名称（多个以"，"隔开）

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

@@ -1,5 +1,6 @@
package cc.mrbird.febs;

import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.mall.dto.ApiLeaderOrderConfirmDto;
import cc.mrbird.febs.mall.entity.MallOrderInfo;
import cc.mrbird.febs.mall.entity.MallOrderItem;
@@ -9,6 +10,8 @@
import cc.mrbird.febs.mall.service.IApiMallTeamLeaderService;
import cc.mrbird.febs.mall.service.IMallAchieveService;
import cc.mrbird.febs.mall.service.IMemberProfitService;
import cc.mrbird.febs.pay.model.WxGenerateQrCodeDto;
import cc.mrbird.febs.pay.service.IXcxPayService;
import cc.mrbird.febs.rabbit.consumer.AgentConsumer;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
@@ -172,4 +175,16 @@
        }
        return productNames;
    }
    @Autowired
    private IXcxPayService iXcxPayService;

    @Test
    public void qrcode(){
        WxGenerateQrCodeDto wxGenerateQrCodeDto = new WxGenerateQrCodeDto();
        wxGenerateQrCodeDto.setPage("wxGenerateQrCodeDto");
        wxGenerateQrCodeDto.setScene("15");
        FebsResponse febsResponse = iXcxPayService.generateQrCode(wxGenerateQrCodeDto);
        String data = febsResponse.get("data").toString();
        System.out.println(data);
    }
}