BruceSun
/
RuoYi-Vue
mirror of https://gitee.com/y_project/RuoYi-Vue.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

增加档口认证时使用的第三方接口、短信验证码

pull/1121/head
梁宇奇 2025-11-20 23:53:39 +08:00
parent 295fbcc651
commit 1032ab5933
5 changed files with 468 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ruoyi-common/src/main/java/com/ruoyi/common/constant/CacheConstants.java
View File

@ -32,12 +32,18 @@ public class CacheConstants {
*/
public static final String SMS_ASSET_CAPTCHA_CODE_KEY = "sms_asset_captcha_codes:";
/**
* 档口认证验证码
*/
public static final String SMS_STORE_AUTH_CAPTCHA_CODE_KEY = "sms_store_auth_captcha_codes:";
/**
* 短信验证码CD中号码
*/
public static final String SMS_ASSET_CAPTCHA_CODE_CD_PHONE_NUM_KEY = "sms_asset_captcha_code_cd_phone_nums:";
public static final String SMS_LOGIN_CAPTCHA_CODE_CD_PHONE_NUM_KEY = "sms_login_captcha_code_cd_phone_nums:";
public static final String SMS_REGISTER_CAPTCHA_CODE_CD_PHONE_NUM_KEY = "sms_register_captcha_code_cd_phone_nums:";
public static final String SMS_STORE_AUTH_CAPTCHA_CODE_CD_PHONE_NUM_KEY = "sms_store_auth_captcha_code_cd_phone_nums:";
/**
* 扫码登录浏览器ID

15
xkt/src/main/java/com/ruoyi/xkt/service/IStoreService.java
View File

@ -224,4 +224,19 @@ public interface IStoreService {
*/
Integer UpdateSpecialAttr(StoreUpdateSpecialDTO specialDTO);
/**
* 发短信验证码（档口认证）
*
* @param phoneNumber
*/
void sendSmsVerificationCode(String phoneNumber);
/**
* 验证短信验证码（档口认证）
*
* @param phoneNumber
* @param code
*/
void validateSmsVerificationCode(String phoneNumber, String code);
}

21
xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreServiceImpl.java
View File

@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.RandomUtil;
import co.elastic.clients.elasticsearch.core.BulkResponse;
import co.elastic.clients.elasticsearch.core.bulk.BulkOperation;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@ -21,6 +22,7 @@ import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.bigDecimal.CollectorsUtil;
import com.ruoyi.framework.es.EsClientWrapper;
import com.ruoyi.framework.sms.SmsClientWrapper;
import com.ruoyi.system.mapper.SysUserMapper;
import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.xkt.domain.*;
@ -81,6 +83,7 @@ public class StoreServiceImpl implements IStoreService {
final StoreCustomerMapper storeCusMapper;
final StoreFactoryMapper storeFactoryMapper;
final IStoreProductDemandTemplateService storeTemplateService;
final SmsClientWrapper smsClient;
@Value("${es.indexName}")
private String ES_INDEX_NAME;
@ -596,6 +599,24 @@ public class StoreServiceImpl implements IStoreService {
return this.storeMapper.updateById(store);
}
@Transactional(readOnly = true)
@Override
public void sendSmsVerificationCode(String phoneNumber) {
boolean success = smsClient.sendVerificationCode(CacheConstants.SMS_STORE_AUTH_CAPTCHA_CODE_CD_PHONE_NUM_KEY,
CacheConstants.SMS_STORE_AUTH_CAPTCHA_CODE_KEY, phoneNumber, RandomUtil.randomNumbers(6));
if (!success) {
throw new ServiceException("短信发送失败");
}
}
@Transactional(readOnly = true)
@Override
public void validateSmsVerificationCode(String phoneNumber, String code) {
boolean match = smsClient.matchVerificationCode(CacheConstants.SMS_STORE_AUTH_CAPTCHA_CODE_KEY, phoneNumber, code);
if (!match) {
throw new ServiceException("验证码错误或已过期");
}
}
/**
* 档口首页今日销售额

108
xkt/src/main/java/com/ruoyi/xkt/thirdpart/lfv2/Lfv2Client.java 100644
View File

@ -0,0 +1,108 @@
package com.ruoyi.xkt.thirdpart.lfv2;
import cn.hutool.core.map.MapUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;
/**
* @author liangyq
* @date 2025-11-20
*/
@Slf4j
@Component
public class Lfv2Client {
private static final String ENT4URL = "https://swent4.market.alicloudapi.com/verify/enterprise4";
private static final String PHONE3URL = "https://swphone3.market.alicloudapi.com/verify/operator3_precision";
@Value("${lfv2.auth:APPCODE 4dd403cda2694a45a1124b09637612b6}")
private String authCode;
/**
* 检查企业四要素
*
* @param creditCode 社会统一信用代码
* @param enterpriseName 企业名
* @param legalPersonName 法人名称
* @param legalIdNumber 法人身份证号
* @return
*/
public boolean checkEnterprise(String creditCode, String enterpriseName, String legalPersonName,
String legalIdNumber) {
Map<String, String> headers = new HashMap<>();
//最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
headers.put("Authorization", authCode);
//根据API的要求，定义相对应的Content-Type
headers.put("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
Map<String, String> body = new HashMap<>();
body.put("credit_code", creditCode);
body.put("enterprise_name", enterpriseName);
body.put("legal_person_name", legalPersonName);
body.put("legal_id_number", legalIdNumber);
try {
String response = httpPost(ENT4URL, headers, body);
log.info("企业四要素接口: {}, {}", body, response);
JSONObject result = JSONUtil.parseObj(response).getJSONObject("result");
Integer r1 = result.getInt("enterprise_name_match");
Integer r2 = result.getInt("credit_code_match");
Integer r3 = result.getInt("legal_person_name_match");
Integer r4 = result.getInt("legal_id_number_match");
return Integer.valueOf(1).equals(r1)
&& Integer.valueOf(1).equals(r2)
&& Integer.valueOf(1).equals(r3)
&& Integer.valueOf(1).equals(r4);
} catch (Exception e) {
log.error("企业四要素接口异常", e);
}
return false;
}
/**
* 检查手机号三要素
*
* @param phoneNumber 手机号
* @param personName 姓名
* @param idNumber 身份证号
* @return
*/
public boolean checkPhone(String phoneNumber, String personName, String idNumber) {
Map<String, String> headers = new HashMap<>();
//最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
headers.put("Authorization", authCode);
//根据API的要求，定义相对应的Content-Type
headers.put("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
Map<String, String> body = new HashMap<>();
body.put("name", personName);
body.put("id_number", idNumber);
body.put("phone_number", phoneNumber);
try {
String response = httpPost(PHONE3URL, headers, body);
log.info("手机号三要素接口: {}, {}", body, response);
Integer checkResult = JSONUtil.parseObj(response).getByPath("result.checkresult", Integer.class);
return Integer.valueOf(1).equals(checkResult);
} catch (Exception e) {
log.error("手机号三要素接口异常", e);
}
return false;
}
private String httpPost(String url, Map<String, String> headers, Map<String, String> body) {
HttpRequest httpRequest = HttpUtil.createPost(url);
if (MapUtil.isNotEmpty(headers)) {
httpRequest.addHeaders(headers);
}
if (MapUtil.isNotEmpty(body)) {
httpRequest.formStr(body);
}
return httpRequest.execute().body();
}
}

318
xkt/src/main/java/com/ruoyi/xkt/thirdpart/lfv2/Lfv2HttpUtil.java 100644
View File

@ -0,0 +1,318 @@
package com.ruoyi.xkt.thirdpart.lfv2;
import cn.hutool.core.util.StrUtil;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpDelete;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
import org.apache.http.conn.ClientConnectionManager;
import org.apache.http.conn.scheme.Scheme;
import org.apache.http.conn.scheme.SchemeRegistry;
import org.apache.http.conn.ssl.SSLSocketFactory;
import org.apache.http.entity.ByteArrayEntity;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* @author liangyq
* @date 2025-11-20
*/
public class Lfv2HttpUtil {
/**
* get
*
* @param host
* @param path
* @param method
* @param headers
* @param querys
* @return
* @throws Exception
*/
public static HttpResponse doGet(String host, String path, String method,
Map<String, String> headers,
Map<String, String> querys)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpGet request = new HttpGet(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
return httpClient.execute(request);
}
/**
* post form
*
* @param host
* @param path
* @param method
* @param headers
* @param querys
* @param bodys
* @return
* @throws Exception
*/
public static HttpResponse doPost(String host, String path, String method,
Map<String, String> headers,
Map<String, String> querys,
Map<String, String> bodys)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPost request = new HttpPost(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
if (bodys != null) {
List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
for (String key : bodys.keySet()) {
nameValuePairList.add(new BasicNameValuePair(key, bodys.get(key)));
}
UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
request.setEntity(formEntity);
}
return httpClient.execute(request);
}
/**
* Post String
*
* @param host
* @param path
* @param method
* @param headers
* @param querys
* @param body
* @return
* @throws Exception
*/
public static HttpResponse doPost(String host, String path, String method,
Map<String, String> headers,
Map<String, String> querys,
String body)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPost request = new HttpPost(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
if (StrUtil.isNotBlank(body)) {
request.setEntity(new StringEntity(body, "utf-8"));
}
return httpClient.execute(request);
}
/**
* Post stream
*
* @param host
* @param path
* @param method
* @param headers
* @param querys
* @param body
* @return
* @throws Exception
*/
public static HttpResponse doPost(String host, String path, String method,
Map<String, String> headers,
Map<String, String> querys,
byte[] body)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPost request = new HttpPost(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
if (body != null) {
request.setEntity(new ByteArrayEntity(body));
}
return httpClient.execute(request);
}
/**
* Put String
*
* @param host
* @param path
* @param method
* @param headers
* @param querys
* @param body
* @return
* @throws Exception
*/
public static HttpResponse doPut(String host, String path, String method,
Map<String, String> headers,
Map<String, String> querys,
String body)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPut request = new HttpPut(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
if (StrUtil.isNotBlank(body)) {
request.setEntity(new StringEntity(body, "utf-8"));
}
return httpClient.execute(request);
}
/**
* Put stream
*
* @param host
* @param path
* @param method
* @param headers
* @param querys
* @param body
* @return
* @throws Exception
*/
public static HttpResponse doPut(String host, String path, String method,
Map<String, String> headers,
Map<String, String> querys,
byte[] body)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPut request = new HttpPut(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
if (body != null) {
request.setEntity(new ByteArrayEntity(body));
}
return httpClient.execute(request);
}
/**
* Delete
*
* @param host
* @param path
* @param method
* @param headers
* @param querys
* @return
* @throws Exception
*/
public static HttpResponse doDelete(String host, String path, String method,
Map<String, String> headers,
Map<String, String> querys)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpDelete request = new HttpDelete(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
return httpClient.execute(request);
}
private static String buildUrl(String host, String path, Map<String, String> querys) throws UnsupportedEncodingException {
StringBuilder sbUrl = new StringBuilder();
sbUrl.append(host);
if (!StrUtil.isBlank(path)) {
sbUrl.append(path);
}
if (null != querys) {
StringBuilder sbQuery = new StringBuilder();
for (Map.Entry<String, String> query : querys.entrySet()) {
if (0 < sbQuery.length()) {
sbQuery.append("&");
}
if (StrUtil.isBlank(query.getKey()) && !StrUtil.isBlank(query.getValue())) {
sbQuery.append(query.getValue());
}
if (!StrUtil.isBlank(query.getKey())) {
sbQuery.append(query.getKey());
if (!StrUtil.isBlank(query.getValue())) {
sbQuery.append("=");
sbQuery.append(URLEncoder.encode(query.getValue(), "utf-8"));
}
}
}
if (0 < sbQuery.length()) {
sbUrl.append("?").append(sbQuery);
}
}
return sbUrl.toString();
}
private static HttpClient wrapClient(String host) {
HttpClient httpClient = new DefaultHttpClient();
if (host.startsWith("https://")) {
sslClient(httpClient);
}
return httpClient;
}
private static void sslClient(HttpClient httpClient) {
try {
SSLContext ctx = SSLContext.getInstance("TLS");
X509TrustManager tm = new X509TrustManager() {
public X509Certificate[] getAcceptedIssuers() {
return null;
}
public void checkClientTrusted(X509Certificate[] xcs, String str) {
}
public void checkServerTrusted(X509Certificate[] xcs, String str) {
}
};
ctx.init(null, new TrustManager[]{tm}, null);
SSLSocketFactory ssf = new SSLSocketFactory(ctx);
ssf.setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
ClientConnectionManager ccm = httpClient.getConnectionManager();
SchemeRegistry registry = ccm.getSchemeRegistry();
registry.register(new Scheme("https", 443, ssf));
} catch (KeyManagementException ex) {
throw new RuntimeException(ex);
} catch (NoSuchAlgorithmException ex) {
throw new RuntimeException(ex);
}
}
}