blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2023-02-13 fe00af0129ea00d7b3e33af06ab8f48acaf0389c 
 src/main/java/cc/mrbird/febs/pay/service/impl/XcxPayServiceImpl.java


@@ -18,17 +18,11 @@


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.alibaba.fastjson.JSON;


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


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


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.collections.CollectionUtils;


@@ -46,7 +40,6 @@




import java.io.*;


import java.math.BigDecimal;


import java.net.*;


import java.nio.charset.Charset;


import java.util.ArrayList;


import java.util.HashMap;


@@ -87,7 +80,7 @@


        MallMember mallMember = mallMemberMapper.selectById(apiRechargeWalletDto.getMemberId());


        String rechargeNo = "CZ_"+MallUtils.getOrderNum();


        Boolean debug = xcxProperties.getDebug();


        String attrStr = "{'rechargeNo':"+rechargeNo+",'memberId':"+mallMember.getId()+"}";


        String attrStr = "{'rechargeNo':"+rechargeNo+",'memberId':"+mallMember.getId()+",'type':"+apiRechargeWalletDto.getType()+"}";


        if (debug) {


            payData = weixinServiceUtil.createRechargeWallet("[测试]" + productNames, rechargeNo,


                    1, mallMember.getOpenId(), attrStr);


@@ -225,10 +218,10 @@


        orderStateMsgVo.setTemplate_id(info.getTemplateId());//订阅消息模板id


        orderStateMsgVo.setPage(info.getPage());


        Map<String, WxTemplateData> m = new HashMap<>(4);


        m.put("character_string2", new WxTemplateData(info.getOrderNo()));


        m.put("thing11", new WxTemplateData(info.getGoodsName()));


        m.put("amount1", new WxTemplateData(info.getAmount()));


        m.put("character_string9", new WxTemplateData(info.getTakeCode()));


        m.put("thing19", new WxTemplateData(info.getAddressArea()));


        m.put("phone_number18", new WxTemplateData(info.getLeaderPhone()));


        m.put("thing3", new WxTemplateData(info.getGoodsName()));


        m.put("thing15", new WxTemplateData(info.getRemark()));


        orderStateMsgVo.setData(m);


        String s = JSONUtil.toJsonStr(orderStateMsgVo);


        log.info(s);


@@ -286,12 +279,15 @@


    }




    @Override


    public List<String> getTemplateId() {


        List<String> wxTemplates = new ArrayList<>();


        List<DataDictionaryCustom> wxTemplateList = dataDictionaryCustomMapper.selectDicByType(DataDictionaryEnum.WX_TEMPLATE_ID_ONE.getType());


    public List<HashMap<String, String>> getTemplateId() {


        List<HashMap<String, String>> wxTemplates = new ArrayList<>();


        List<DataDictionaryCustom> wxTemplateList = dataDictionaryCustomMapper.selectDicByType(DataDictionaryEnum.WX_TEMPLATE_ID_THREE.getType());


        if(CollUtil.isNotEmpty(wxTemplateList)){


            for(DataDictionaryCustom dic : wxTemplateList){


                wxTemplates.add(dic.getValue());


                HashMap<String, String> objectObjectHashMap = new HashMap<>();


                objectObjectHashMap.put("name",dic.getCode());


                objectObjectHashMap.put("value",dic.getValue());


                wxTemplates.add(objectObjectHashMap);


            }


        }


        return wxTemplates;


@@ -411,24 +407,24 @@


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


                obj.set("scene", scene);


                obj.set("page", 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 );


                obj.set("page", path + "?" + scene );


            }




            //最小 280px，最大 1280px


            obj.put("width", width);


            obj.put("auto_color", false);


            obj.set("width", width);


            obj.set("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);


            obj2.set("r", 0);


            obj2.set("g", 0);


            obj2.set("b", 0);


            obj.set("line_color", obj2);


            //是否需要透明底色，为 true 时，生成透明底色的小程序码


            obj.put("is_hyaline", false);


            obj.set("is_hyaline", false);


            try {


                HttpResponse execute = HttpRequest.post(url).body(obj.toString(), "application/json").execute();


                InputStream inputStream = execute.bodyStream();