记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit e48a3cd6 authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

压测提交

parent a7158eb3
Hide whitespace changes
Inline Side-by-side
Showing with 79 additions and 79 deletions
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/docu/mongo_db_ddl.sql
View file @ e48a3cd6
use dev_ln_scene; use test_ln_scene;
// ================================================== 创建集合 // ================================================== 创建集合
db.createCollection("GoblinSelfGoodsCategoryVo"); db.createCollection("GoblinSelfGoodsCategoryVo");
db.createCollection("GoblinStoreGoodsCategoryVo"); db.createCollection("GoblinStoreGoodsCategoryVo");
...@@ -28,34 +28,34 @@ db.createCollection("GoblinOrderSkuVo"); ...@@ -28,34 +28,34 @@ db.createCollection("GoblinOrderSkuVo");
db.createCollection("GoblinSelfMarketingVo"); db.createCollection("GoblinSelfMarketingVo");
db.createCollection("GoblinStoreOrderVo"); db.createCollection("GoblinStoreOrderVo");
// ================================================== 创建分片 // ================================================== 创建分片
sh.enableSharding("dev_ln_scene"); sh.enableSharding("test_ln_scene");
sh.shardCollection("dev_ln_scene.GoblinSelfGoodsCategoryVo",{"cateId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinSelfGoodsCategoryVo",{"cateId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinStoreGoodsCategoryVo",{"cateId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinStoreGoodsCategoryVo",{"cateId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinMgtCategorySpecVo",{"cateId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinMgtCategorySpecVo",{"cateId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinSelfTagVo",{"tagId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinSelfTagVo",{"tagId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinServiceSupportVo",{"ssid":"hashed"}); sh.shardCollection("test_ln_scene.GoblinServiceSupportVo",{"ssid":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinStoreNoticeVo",{"noticeId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinStoreNoticeVo",{"noticeId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinStoreConfigVo",{"storeId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinStoreConfigVo",{"storeId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinStoreInfoVo",{"storeId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinStoreInfoVo",{"storeId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinGoodsInfoVo",{"spuId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinGoodsInfoVo",{"spuId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinGoodsSkuInfoVo",{"skuId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinGoodsSkuInfoVo",{"skuId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinStoreCouponBasicVo",{"storeCouponId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinStoreCouponBasicVo",{"storeCouponId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinUserCouponVo",{"ucouponId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinUserCouponVo",{"ucouponId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinFrontBanner",{"bannerId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinFrontBanner",{"bannerId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinFrontCube",{"cubeId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinFrontCube",{"cubeId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinFrontHotWord",{"hotWordId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinFrontHotWord",{"hotWordId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinFrontMoudleIndex",{"moudleIndexId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinFrontMoudleIndex",{"moudleIndexId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinFrontNavigation",{"navigationId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinFrontNavigation",{"navigationId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinFrontSeckill",{"seckilId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinFrontSeckill",{"seckilId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinFrontSelectGoods",{"selectGoodsId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinFrontSelectGoods",{"selectGoodsId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinShoppingCartVoo",{"goblinShoppingCartId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinShoppingCartVoo",{"goblinShoppingCartId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinBackOrderVo",{"backOrderId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinBackOrderVo",{"backOrderId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinMailVo",{"mailId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinMailVo",{"mailId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinMarketingZhengzaiRelationVo",{"selfMarketId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinMarketingZhengzaiRelationVo",{"selfMarketId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinOrderLogVo",{"selfMarketId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinOrderLogVo",{"orderId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinOrderSkuVo",{"selfMarketId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinOrderSkuVo",{"orderSkuId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinStoreOrderVo",{"orderId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinStoreOrderVo",{"orderId":"hashed"});
sh.shardCollection("dev_ln_scene.GoblinSelfMarketingVo",{"selfMarketId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinSelfMarketingVo",{"selfMarketId":"hashed"});
// ================================================== 创建索引 // ================================================== 创建索引
db.GoblinSelfGoodsCategoryVo.createIndex({cateId:"hashed"}); db.GoblinSelfGoodsCategoryVo.createIndex({cateId:"hashed"});
......
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/GoblinOrderServiceImpl.java
View file @ e48a3cd6
...@@ -416,63 +416,63 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService { ...@@ -416,63 +416,63 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
String payCode; String payCode;
if (preParam.getPriceActual().compareTo(BigDecimal.valueOf(0)) > 0 && !preParam.getPayType().equals("huifu")) { if (preParam.getPriceActual().compareTo(BigDecimal.valueOf(0)) > 0 && !preParam.getPayType().equals("huifu")) {
// 调用支付 // 调用支付
LinkedMultiValueMap<String, String> httpData = CollectionUtil.linkedMultiValueMapStringString(); // LinkedMultiValueMap<String, String> httpData = CollectionUtil.linkedMultiValueMapStringString();
httpData.add("type", "PRODUCT"); // httpData.add("type", "PRODUCT");
httpData.add("price", preParam.getPriceActual().toString()); // httpData.add("price", preParam.getPriceActual().toString());
// httpData.add("price","0.01"); //// httpData.add("price","0.01");
httpData.add("name", preParam.getStoreName()); // httpData.add("name", preParam.getStoreName());
httpData.add("detail", preParam.getSkuName()); // httpData.add("detail", preParam.getSkuName());
httpData.add("orderCode", preParam.getOrderMasterCode()); // httpData.add("orderCode", preParam.getOrderMasterCode());
httpData.add("orderId", preParam.getOrderIdList().substring(1)); // httpData.add("orderId", preParam.getOrderIdList().substring(1));
httpData.add("clientIp", CurrentUtil.getCliIpAddr()); // httpData.add("clientIp", CurrentUtil.getCliIpAddr());
httpData.add("notifyUrl", synUrl); // httpData.add("notifyUrl", synUrl);
httpData.add("createDate", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); // httpData.add("createDate", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
httpData.add("expireTime", preParam.getExpireTime() + ""); // httpData.add("expireTime", preParam.getExpireTime() + "");
httpData.add("payType", preParam.getPayType()); // httpData.add("payType", preParam.getPayType());
httpData.add("deviceFrom", preParam.getDeviceFrom()); // httpData.add("deviceFrom", preParam.getDeviceFrom());
//
// if (preParam.getDeviceFrom().equals("micropay")) {
// httpData.add("authCode", preParam.getAuthCode());
// }
// if (preParam.getDeviceFrom().equals("js") || preParam.getDeviceFrom().equals("applet")) {
// httpData.add("openId", preParam.getOpenId());
// }
// if (preParam.getPayType().equals("alipay") && preParam.getDeviceFrom().equals("wap")) {
// httpData.add("showUrl", preParam.getShowUrl() + preParam.getOrderMasterCode());
// httpData.add("returnUrl", preParam.getReturnUrl() + preParam.getOrderMasterCode());
// }
// if (preParam.getPayType().equals("douyinpay")) {
// httpData.add("showUrl", preParam.getShowUrl() + preParam.getOrderMasterCode());
// httpData.add("returnUrl", preParam.getReturnUrl() + preParam.getOrderMasterCode());
// }
// if (preParam.getPayType().equals("unionpay")) {
// httpData.add("returnUrl", preParam.getReturnUrl() + preParam.getOrderMasterCode());
// }
// LinkedMultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
// header.add("Accept", "application/json;charset=UTF-8");
// String returnData = HttpUtil.post(payUrl, httpData, header);
// log.info("调用 DRAGON 结果 = " + returnData);
// ResponseDto<GoblinPayInnerResultVo> dto = JsonUtils.fromJson(returnData, new TypeReference<ResponseDto<GoblinPayInnerResultVo>>() {
// });
// payInnerResultVo = GoblinPayInnerResultVo.getNew();
// payInnerResultVo.setCode(dto.getData().getCode());
// payInnerResultVo.setOrderCode(dto.getData().getOrderCode());
// payInnerResultVo.setPayData(dto.getData().getPayData());
// payInnerResultVo.setPayType(preParam.getPayType());
// payInnerResultVo.setPrice(preParam.getPriceActual());
// payCode = payInnerResultVo.getCode();
// payInnerResultVo.setShowUrl(preParam.getShowUrl());
// payInnerResultVo.setReturnUrl(preParam.getReturnUrl());
if (preParam.getDeviceFrom().equals("micropay")) {
httpData.add("authCode", preParam.getAuthCode());
}
if (preParam.getDeviceFrom().equals("js") || preParam.getDeviceFrom().equals("applet")) {
httpData.add("openId", preParam.getOpenId());
}
if (preParam.getPayType().equals("alipay") && preParam.getDeviceFrom().equals("wap")) {
httpData.add("showUrl", preParam.getShowUrl() + preParam.getOrderMasterCode());
httpData.add("returnUrl", preParam.getReturnUrl() + preParam.getOrderMasterCode());
}
if (preParam.getPayType().equals("douyinpay")) {
httpData.add("showUrl", preParam.getShowUrl() + preParam.getOrderMasterCode());
httpData.add("returnUrl", preParam.getReturnUrl() + preParam.getOrderMasterCode());
}
if (preParam.getPayType().equals("unionpay")) {
httpData.add("returnUrl", preParam.getReturnUrl() + preParam.getOrderMasterCode());
}
LinkedMultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
header.add("Accept", "application/json;charset=UTF-8");
String returnData = HttpUtil.post(payUrl, httpData, header);
log.info("调用 DRAGON 结果 = " + returnData);
ResponseDto<GoblinPayInnerResultVo> dto = JsonUtils.fromJson(returnData, new TypeReference<ResponseDto<GoblinPayInnerResultVo>>() {
});
payInnerResultVo = GoblinPayInnerResultVo.getNew(); payInnerResultVo = GoblinPayInnerResultVo.getNew();
payInnerResultVo.setCode(dto.getData().getCode()); payInnerResultVo.setCode("压测 code");
payInnerResultVo.setOrderCode(dto.getData().getOrderCode()); payInnerResultVo.setOrderCode(preParam.getOrderMasterCode());
payInnerResultVo.setPayData(dto.getData().getPayData()); payInnerResultVo.setPayData(null);
payInnerResultVo.setPayType(preParam.getPayType()); payInnerResultVo.setPayType(preParam.getPayType());
payInnerResultVo.setPrice(preParam.getPriceActual()); payInnerResultVo.setPrice(preParam.getPriceActual());
payCode = payInnerResultVo.getCode(); payCode = payInnerResultVo.getCode();
payInnerResultVo.setShowUrl(preParam.getShowUrl()); payInnerResultVo.setShowUrl(preParam.getShowUrl());
payInnerResultVo.setReturnUrl(preParam.getReturnUrl()); payInnerResultVo.setReturnUrl(preParam.getReturnUrl());
// payInnerResultVo = GoblinPayInnerResultVo.getNew();
// payInnerResultVo.setCode("压测 code");
// payInnerResultVo.setOrderCode(preParam.getOrderMasterCode());
// payInnerResultVo.setPayData(null);
// payInnerResultVo.setPayType(preParam.getPayType());
// payInnerResultVo.setPrice(preParam.getPriceActual());
// payCode = payInnerResultVo.getCode();
// payInnerResultVo.setShowUrl(preParam.getShowUrl());
// payInnerResultVo.setReturnUrl(preParam.getReturnUrl());
} else if (preParam.getPayType() == null) { } else if (preParam.getPayType() == null) {
isFree = true; isFree = true;
preParam.setPayType("FREE"); preParam.setPayType("FREE");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment