22 changed files with 555 additions and 10 deletions
Split View
Diff Options
-
4dating-agency-mall-constant/src/main/java/com/qniao/dam/domian/aggregate/order/constant/OrderBelongingEnum.java
-
6dating-agency-mall-constant/src/main/java/com/qniao/dam/domian/aggregate/product/constant/ProductMainCategoryEnum.java
-
8dating-agency-mall-constant/src/main/java/com/qniao/dam/domian/aggregate/product/constant/ProductSubCategoryEnum.java
-
4dating-agency-mall-constant/src/main/java/com/qniao/dam/domian/aggregate/product/constant/ProductTypeEnum.java
-
2dating-agency-mall-entity/src/main/java/com/qniao/dam/domain/aggregate/order/entity/Order.java
-
5dating-agency-mall-server/pom.xml
-
18dating-agency-mall-server/src/main/java/com/qniao/dam/api/command/bankcard/user/request/BankCardVerifyDto.java
-
8dating-agency-mall-server/src/main/java/com/qniao/dam/api/command/bankcard/user/request/UserCreateBankCardDto.java
-
12dating-agency-mall-server/src/main/java/com/qniao/dam/api/command/bankcard/user/response/BankCardVerifyVo.java
-
10dating-agency-mall-server/src/main/java/com/qniao/dam/api/command/order/user/OrderUserCommandController.java
-
35dating-agency-mall-server/src/main/java/com/qniao/dam/api/command/order/user/request/UserSubmitMatchmakingCornerOrderDto.java
-
9dating-agency-mall-server/src/main/java/com/qniao/dam/api/query/product/user/ProductUserQueryController.java
-
5dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/order/OrderEventHandler.java
-
6dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/bankcard/BankCardApplicationService.java
-
15dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/order/OrderApplicationService.java
-
1dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java
-
3dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/persistent/dao/view/ProductViewDao.java
-
72dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/utils/BankCardUtil.java
-
311dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/utils/HttpUtils.java
-
2dating-agency-mall-server/src/main/java/com/qniao/dam/query/product/ProductQueryService.java
-
6dating-agency-mall-server/src/main/java/com/qniao/dam/query/product/impl/ProductQueryServiceImpl.java
-
23dating-agency-mall-server/src/main/resources/mapper/product/WalletAccountAssociateOrderRecordDao.xml
@ -0,0 +1,18 @@ |
|||
package com.qniao.dam.api.command.bankcard.user.request; |
|||
|
|||
import io.swagger.annotations.ApiModelProperty; |
|||
import lombok.AllArgsConstructor; |
|||
import lombok.Data; |
|||
import lombok.NoArgsConstructor; |
|||
|
|||
@Data |
|||
@AllArgsConstructor |
|||
@NoArgsConstructor |
|||
public class BankCardVerifyDto { |
|||
|
|||
@ApiModelProperty("持卡人姓名") |
|||
private String ownerName; |
|||
|
|||
@ApiModelProperty("卡号") |
|||
private String cardNum; |
|||
} |
|||
@ -0,0 +1,12 @@ |
|||
package com.qniao.dam.api.command.bankcard.user.response; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class BankCardVerifyVo { |
|||
|
|||
private Boolean status; |
|||
|
|||
private String msg; |
|||
|
|||
} |
|||
@ -0,0 +1,35 @@ |
|||
package com.qniao.dam.api.command.order.user.request; |
|||
|
|||
import com.qniao.dam.domain.aggregate.order.entity.Order; |
|||
import com.qniao.dam.domain.aggregate.order.entity.OrderItem; |
|||
import com.qniao.domain.Trans2DomainAssembler; |
|||
import io.swagger.annotations.ApiModelProperty; |
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotNull; |
|||
import java.util.ArrayList; |
|||
import java.util.List; |
|||
|
|||
@Data |
|||
public class UserSubmitMatchmakingCornerOrderDto implements Trans2DomainAssembler<Order> { |
|||
|
|||
@ApiModelProperty("产品规格标识") |
|||
@NotNull(message = "产品规格标识不能为空") |
|||
private Long productSpecId; |
|||
|
|||
@ApiModelProperty("用户名称") |
|||
private String userName; |
|||
|
|||
@Override |
|||
public Order trans2Domain() { |
|||
Order order = new Order(); |
|||
order.setOrderBelongName(userName); |
|||
List<OrderItem> orderItemList = new ArrayList<>(); |
|||
OrderItem orderItem = new OrderItem(); |
|||
orderItem.setProductSpecId(productSpecId); |
|||
orderItem.setQuantity(1); |
|||
orderItemList.add(orderItem); |
|||
order.setOrderItemList(orderItemList); |
|||
return order; |
|||
} |
|||
} |
|||
@ -0,0 +1,72 @@ |
|||
package com.qniao.dam.infrastructure.utils; |
|||
|
|||
import com.alibaba.fastjson.JSON; |
|||
import com.alibaba.fastjson.JSONObject; |
|||
import com.qniao.dam.api.command.bankcard.user.request.BankCardVerifyDto; |
|||
import com.qniao.framework.exception.BizException; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.http.HttpResponse; |
|||
import org.apache.http.util.EntityUtils; |
|||
|
|||
import java.util.HashMap; |
|||
import java.util.Map; |
|||
|
|||
@Slf4j |
|||
public class BankCardUtil { |
|||
|
|||
private static final String authorization = "APPCODE 6fd14ec3939c483a89192c1fcc871c4b"; |
|||
|
|||
public static void getBankCardVerify(BankCardVerifyDto dto) { |
|||
|
|||
String host = "https://kzbank3v1.market.alicloudapi.com"; |
|||
String path = "/api/bankcard2/check"; |
|||
String method = "POST"; |
|||
Map<String, String> headers = new HashMap<String, String>(); |
|||
//最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105 |
|||
headers.put("Authorization", authorization); |
|||
//根据API的要求，定义相对应的Content-Type |
|||
headers.put("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8"); |
|||
Map<String, String> querys = new HashMap<String, String>(); |
|||
Map<String, String> bodys = new HashMap<String, String>(); |
|||
bodys.put("bankcard", dto.getCardNum()); |
|||
bodys.put("name", dto.getOwnerName()); |
|||
|
|||
|
|||
try { |
|||
/** |
|||
* 重要提示如下: |
|||
* HttpUtils请从 |
|||
* https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/src/main/java/com/aliyun/api/gateway/demo/util/HttpUtils.java |
|||
* 下载 |
|||
* |
|||
* 相应的依赖请参照 |
|||
* https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/pom.xml |
|||
*/ |
|||
HttpResponse response = HttpUtils.doPost(host, path, method, headers, querys, bodys); |
|||
|
|||
JSONObject json = JSON.parseObject(EntityUtils.toString(response.getEntity())); |
|||
if (json.getString("success").equals("true")) { |
|||
// 成功 |
|||
JSONObject dataJson = JSON.parseObject(json.getString("data")); |
|||
Integer result = dataJson.getInteger("result"); |
|||
if (result != 0) { |
|||
String desc = dataJson.getString("desc"); |
|||
log.error(desc); |
|||
throw new BizException(desc); |
|||
} |
|||
} else { |
|||
log.error("----------------银行卡二要素校验异常------------------"); |
|||
String msg = json.getString("msg"); |
|||
log.error(msg); |
|||
throw new BizException(msg); |
|||
} |
|||
} catch (BizException e) { |
|||
log.error("银行卡校验异常", e); |
|||
throw new BizException(e.getMessage()); |
|||
} catch (Exception e) { |
|||
log.error("银行卡校验异常", e); |
|||
throw new BizException("银行卡校验异常"); |
|||
} |
|||
} |
|||
|
|||
} |
|||
@ -0,0 +1,311 @@ |
|||
package com.qniao.dam.infrastructure.utils; |
|||
|
|||
import org.apache.commons.lang.StringUtils; |
|||
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; |
|||
|
|||
public class HttpUtils { |
|||
|
|||
/** |
|||
* 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 (StringUtils.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 (StringUtils.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 (!StringUtils.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 (StringUtils.isBlank(query.getKey()) && !StringUtils.isBlank(query.getValue())) { |
|||
sbQuery.append(query.getValue()); |
|||
} |
|||
if (!StringUtils.isBlank(query.getKey())) { |
|||
sbQuery.append(query.getKey()); |
|||
if (!StringUtils.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); |
|||
} |
|||
} |
|||
} |
|||
Write
Preview
Loading…
Cancel
Save