WeChatMiniProgramRemoteServiceImpl.java
6.92 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
package com.zteits.pay.biz.wx;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.clouds.common.constants.CodeValKindEnum;
import com.clouds.common.constants.CodeValueEnum;
import com.clouds.common.constants.RedisKeyEnum;
import com.clouds.common.oss.base.OssClientService;
import com.clouds.common.oss.fastdfs.FastDFSOssClientWrapper;
import com.clouds.common.utils.HttpClientUtils;
import com.clouds.common.utils.ResultUtils;
import com.clouds.common.utils.WxConfigUtil;
import com.clouds.common.utils.image.ImageBase64Util;
import com.clouds.common.utils.wx.AccessToken;
import com.clouds.common.utils.wx.AccessTokenUtil;
import com.zteits.clouds.api.apibase.bean.BizResult;
import com.zteits.clouds.api.apibase.constants.BasicEnum;
import com.zteits.clouds.api.apibase.constants.ErrorType;
import com.zteits.clouds.api.apibase.constants.PayTypeEnum;
import com.zteits.clouds.api.apibase.exception.BizException;
import com.zteits.clouds.api.dto.pay.TdCAcctNoSecretDTO;
import com.zteits.clouds.api.dto.pay.param.GetWxUnlimitedQrCodeRequest;
import com.zteits.clouds.api.dto.sys.DataDicKindDetailDTO;
import com.zteits.clouds.api.dto.sys.SysOrgAppIdDTO;
import com.zteits.clouds.api.dto.sys.param.DataDicKindDetailRequest;
import com.zteits.clouds.api.dto.sys.param.SysOrgAppIdQueryRequest;
import com.zteits.clouds.api.service.pay.wx.WeChatMiniProgramRemoteService;
import com.zteits.clouds.api.service.sys.DataDictionaryService;
import com.zteits.clouds.api.service.sys.SysOrgAppIdService;
import com.zteits.pay.biz.AccountRechargeServiceImpl;
import com.zteits.pay.dao.TdBWxConfigDao;
import com.zteits.pay.domain.TdBWxConfig;
import com.zteits.pay.util.FastDFSClientWrapper;
import groovy.util.logging.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import java.net.URLEncoder;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @Author: Tom
* @Date: 2022/8/30 14:26
* @Description:
*/
@Service
public class WeChatMiniProgramRemoteServiceImpl implements WeChatMiniProgramRemoteService {
private static final Logger logger = LoggerFactory.getLogger(WeChatMiniProgramRemoteServiceImpl.class);
/**
* 获取小程序码，适用于需要的码数量极多的业务场景。通过该接口生成的小程序码，永久有效，数量暂无限制。URL
*/
private final String GETUNLIMITED = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?";
@Autowired
private FastDFSClientWrapper fastDFSClientWrapper;
@Autowired
private TdBWxConfigDao tdBWxConfigDao;
@Autowired
private SysOrgAppIdService sysOrgAppIdService;
@Autowired
private DataDictionaryService dataDictionaryService;
@Override
public BizResult<String> getUnlimitedQrCodeUrl(GetWxUnlimitedQrCodeRequest request) {
if (request == null || request.getOrgId() == null || StringUtils.isBlank(request.getScene())){
return new BizResult<>(ErrorType.PARAMM_NULL, "参数为空");
}
SysOrgAppIdQueryRequest sysRequest = new SysOrgAppIdQueryRequest();
sysRequest.setOrgId(request.getOrgId());
sysRequest.setPayType(PayTypeEnum.WXAPPLETS.getValue());
sysRequest.setSysCode(BasicEnum.SYS_CODE.getValue());
BizResult<SysOrgAppIdDTO> appIdDTOBizResult = sysOrgAppIdService.querySysOrgAppIdByOrgIdAndPayType(sysRequest);
SysOrgAppIdDTO sysOrgAppIdDTO = appIdDTOBizResult.getData();
TdBWxConfig tdBWxConfig = tdBWxConfigDao.queryWxConfigByAppId(sysOrgAppIdDTO.getPayAppId());
//微信小程序appId
String wxAppId = tdBWxConfig.getAppid();
//微信小程序appsecret
String wxAppSecret = tdBWxConfig.getAppSecret();
byte[] body = this.getUnlimitedForBytes(wxAppId,wxAppSecret, request.getScene());
if (body == null || body.length == 0) {
logger.info("获取二维码失败,失效accessToken，重新调用");
AccessTokenUtil.deleteAccessToken(wxAppId);
body = this.getUnlimitedForBytes(wxAppId,wxAppSecret, request.getScene());
if (body == null || body.length == 0) {
logger.info("新的accessToken获取二维码依旧失效，抛异常");
}
}
//上传图片到OSS
String url = "";
try {
url = fastDFSClientWrapper.uploadBase64Pic(ImageBase64Util.encode(body), ".jpg",request.getOrgId(),"wx");
} catch (Exception e) {
logger.error("图片上传阿里云失败", e);
}
logger.info("图片完整地址：{}", url);
return new BizResult<>(url);
}
/**
* 调用微信生成二维码，获取bytes
*
* @return
*/
private byte[] getUnlimitedForBytes(String wxAppId, String wxAppSecret, String scene) {
DataDicKindDetailRequest dataDicKindDetailRequest = new DataDicKindDetailRequest();
dataDicKindDetailRequest.setCodeKind(CodeValKindEnum.WX_MINI_CONFIG.name());
dataDicKindDetailRequest.setSysCode(BasicEnum.SYS_CODE.getValue());
BizResult<List<DataDicKindDetailDTO>> bizResult = dataDictionaryService.getDataDictionaryKindDetails(dataDicKindDetailRequest);
List<DataDicKindDetailDTO> dataDicKindDetailDTOS = ResultUtils.getBizResultData(bizResult);
if (CollectionUtils.isEmpty(dataDicKindDetailDTOS)) {
throw new BizException(ErrorType.SYS_CODE_NOT_CONFIG, "字典表未配置" + CodeValKindEnum.WX_MINI_CONFIG.name(), false);
}
Map<String, String> map = dataDicKindDetailDTOS.stream().collect(Collectors.toMap(DataDicKindDetailDTO::getCodeValue, DataDicKindDetailDTO::getCodeValueName));
//要打开的小程序版本。正式版为 release(默认值)，体验版为 trial，开发版为 develop
String envVersion = map.get(CodeValueEnum.WX_MINI_ENV_VERSION.name());
//page
String page = map.get(CodeValueEnum.WX_MINI_CHARGE_PAGE.name());
//获取accessToken
wxAppSecret = WxConfigUtil.decode(wxAppSecret);
AccessToken token = AccessTokenUtil.getToken(wxAppId, wxAppSecret);
String accessToken = token.getAccessToken();
//生成二维码
String url = GETUNLIMITED + "access_token=" + accessToken;
JSONObject params = new JSONObject();
params.put("scene", scene);
if (StringUtils.isNotEmpty(envVersion)) {
//不传递，默认release
params.put("env_version", envVersion);
}
if (StringUtils.isNotEmpty(page)) {
params.put("page", page);
}
params.put("check_path", false);
HttpClientUtils client = new HttpClientUtils();
byte[] body = client.post(url, params.toJSONString());
return body;
}
}