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

Skip to content

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

galaxy - goblin 合并

parent 05d5130b
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 232 additions and 2399 deletions
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/pom.xml
View file @ ac00bc74
...@@ -75,7 +75,7 @@ ...@@ -75,7 +75,7 @@
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-galaxy-common</artifactId> <artifactId>liquidnet-service-goblin-common</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
<exclusions> <exclusions>
<exclusion> <exclusion>
......
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/resources/bootstrap-dev.yml
View file @ ac00bc74
...@@ -6,7 +6,7 @@ liquidnet: ...@@ -6,7 +6,7 @@ liquidnet:
username: user username: user
password: user123 password: user123
eureka: eureka:
host: 39.107.71.112:7001 host: 127.0.0.1:7001
# end-dev-这里是配置信息基本值 # end-dev-这里是配置信息基本值
spring: spring:
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/docu/mongo_db_ddl-dev.sql deleted 100644 → 0
View file @ 05d5130b
use dev_ln_scene;
#创建集合
db.createCollection("GalaxyUserInfoVo");
db.createCollection("GalaxySeriesInfoVo");
db.createCollection("GalaxySeriesNftInfoVo");
db.createCollection("GalaxySeriesNftUploadVo");
db.createCollection("GalaxyNftOrderVo");
db.createCollection("GalaxyNftOrderBindVo");
db.createCollection("GalaxyNftOrderFailLogVo");
db.createCollection("GalaxyNftTradeVo");
#创建索引
db.GalaxyUserInfoVo.createIndex({userId:"hashed"});
db.GalaxySeriesInfoVo.createIndex({seriesCode:"hashed"});
db.GalaxySeriesNftInfoVo.createIndex({skuId:"hashed"});
db.GalaxySeriesNftUploadVo.createIndex({skuId:"hashed"});
db.GalaxyNftOrderVo.createIndex({nftOrderPayId:"hashed"});
db.GalaxyNftOrderBindVo.createIndex({nftOrderPayId:"hashed"});
db.GalaxyNftOrderFailLogVo.createIndex({nftOrderPayId:"hashed"});
db.GalaxyNftTradeVo.createIndex({nftId:"hashed"});
#创建分片
sh.enableSharding("dev_ln_scene");
sh.shardCollection("dev_ln_scene.GalaxyUserInfoVo",{"userId":"hashed"});
sh.shardCollection("dev_ln_scene.GalaxySeriesInfoVo",{"seriesCode":"hashed"});
sh.shardCollection("dev_ln_scene.GalaxySeriesNftInfoVo",{"skuId":"hashed"});
sh.shardCollection("dev_ln_scene.GalaxySeriesNftUploadVo",{"skuId":"hashed"});
sh.shardCollection("dev_ln_scene.GalaxyNftOrderVo",{"nftOrderPayId":"hashed"});
sh.shardCollection("dev_ln_scene.GalaxyNftOrderBindVo",{"nftOrderPayId":"hashed"});
sh.shardCollection("dev_ln_scene.GalaxyNftOrderFailLogVo",{"nftOrderPayId":"hashed"});
sh.shardCollection("dev_ln_scene.GalaxyNftTradeVo",{"nftId":"hashed"});
\ No newline at end of file
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/pom.xml deleted 100644 → 0
View file @ 05d5130b
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>liquidnet-service-galaxy</artifactId>
<groupId>com.liquidnet</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>liquidnet-service-galaxy-impl</artifactId>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-common-third-zxlnft</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-common-third-antchain</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-galaxy-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-galaxy-common</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/ServiceGalaxyApplication.java deleted 100644 → 0
View file @ 05d5130b
package com.liquidnet.service;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.core.env.Environment;
import java.net.InetAddress;
import java.util.Arrays;
@Slf4j
@EnableFeignClients
@SpringBootApplication(scanBasePackages = {"com.liquidnet"})
public class ServiceGalaxyApplication implements CommandLineRunner {
@Autowired
private Environment environment;
public static void main(String[] args) {
SpringApplication.run(ServiceGalaxyApplication.class, args);
}
@Override
public void run(String... strings) {
try {
log.info("\n----------------------------------------------------------\n\t" +
"Application '{}' is running! Access URLs:\n\t" +
"Local: \t\thttp://127.0.0.1:{}\n\t" +
"External: \thttp://{}:{}{}/doc.html\n\t" +
"Profile(s): \t{}\n----------------------------------------------------------",
environment.getProperty("spring.application.name"),
environment.getProperty("server.port"),
InetAddress.getLocalHost().getHostAddress(),
environment.getProperty("server.port"),
environment.getProperty("server.servlet.context-path"),
Arrays.toString(environment.getActiveProfiles()));
} catch (Exception e) {
e.printStackTrace();
}
}
}
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/bootstrap-dev.yml deleted 100644 → 0
View file @ 05d5130b
# begin-dev-这里是配置信息基本值
liquidnet:
cloudConfig:
profile: dev
security:
username: user
password: user123
eureka:
host: 39.107.71.112:7001
# end-dev-这里是配置信息基本值
spring:
profiles:
include: service-galaxy
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/bootstrap-prod.yml deleted 100644 → 0
View file @ 05d5130b
# begin-dev-这里是配置信息基本值
liquidnet:
cloudConfig:
profile: prod
security:
username: user
password: user123
eureka:
host: 172.17.207.189:7001
# end-dev-这里是配置信息基本值
spring:
profiles:
include: service-galaxy
\ No newline at end of file
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/bootstrap-service-galaxy.yml deleted 100644 → 0
View file @ 05d5130b
#eurekaServer配置
eureka:
client:
register-with-eureka: false
fetch-registry: true
serviceUrl:
defaultZone: http://${liquidnet.security.username}:${liquidnet.security.password}@${liquidnet.eureka.host}/eureka-server/eureka
#configServer配置
spring:
cloud:
config:
# uri: http://39.105.38.151:7002/support-config
# uri: http://39.106.122.201:7002/support-config
# uri: http://127.0.0.1:7002/support-config
profile: ${liquidnet.cloudConfig.profile}
name: ${spring.application.name} #默认为spring.application.name
discovery:
enabled: true
service-id: liquidnet-support-config
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/bootstrap-test.yml deleted 100644 → 0
View file @ 05d5130b
# begin-dev-这里是配置信息基本值
liquidnet:
cloudConfig:
profile: test
security:
username: user
password: user123
eureka:
host: 172.17.207.177:7001
#instance:
# prefer-ip-address: true
#host: eureka-test-0.eureka-test-svc.zhengzai-test:7001/eureka-server/eureka,eureka-test-1.eureka-test-svc.zhengzai-test:7001/eureka-server/eureka,eureka-test-2.eureka-test-svc.zhengzai-test:7001/eureka-server/eureka
#host: 192.168.193.41:7001
# end-dev-这里是配置信息基本值
spring:
profiles:
include: service-galaxy
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/errors.properties deleted 100644 → 0
View file @ 05d5130b
40001=登录信息有误
40002=账号已在另一台设备登录
40003=登录已过期
# ------------------------ 4开头错误码作系统保留
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/test/java/com/liquidnet/service/galaxy/TestRedisUtil.java deleted 100644 → 0
View file @ 05d5130b
package com.liquidnet.service.galaxy;
import com.liquidnet.common.cache.redis.util.RedisUtil;
import com.liquidnet.commons.lang.util.DateUtil;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.bo.GalaxySeriesNftUploadTempSecretBo;
import com.liquidnet.service.galaxy.dto.bo.GalaxyUserInfoBo;
import com.liquidnet.service.galaxy.utils.GalaxyDataUtils;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: TestRedisUtil
* @Package com.liquidnet.service.galaxy
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2022/3/15 16:26
*/
@Slf4j
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class TestRedisUtil {
// @Autowired
// private RedisDataSourceUtil redisUtil;
@Autowired
private RedisUtil redisUtil;
private long keyExpireTime = 3600*24*30;
@Autowired
private GalaxyDataUtils dataUtils;
@Test
public void testdd(){
// ZxlnftResponseDto responseDto = new ZxlnftResponseDto();
}
@Test
public void testSeriesNftUploadTempSecretBo(){
String uploadSeriesName = "11111111";
GalaxySeriesNftUploadTempSecretBo userInfoBo = GalaxySeriesNftUploadTempSecretBo.getNew();
userInfoBo.setTempSecretId("AKIDmmC9x9YypxXVcjE1_2WQiF2bl-6hjK2rSCL41KZAQ7ww3PRUdxIo7smIkiNNR42A");
userInfoBo.setTempSecretKey("/kqQu5LtPB+QgKu9qxSGPpc2gRGqxI2/Y7mmGsKMunk=");
userInfoBo.setSessionToken("7iDfIMWATI4RHfwyI8y7ayi797w4XH6ad8ff7ac1551061438ecdc80ca75a02a1C7w2Ik6j3f4OR-mJFVEDbBTECA-ZQAoizRqoeU-ngT3hboSVFvxH5Q7m8YiccL805oXIKtEBs-9y1jg1sCA8EaarPXZsqG0rHzG5M9mJouoYKOu1W5wo8U-01X2s5zOtDmN1A-NS6JbAm0USePfVRcDlBX0eJ-4Hn6I-Gkf6g-ZeuB2Y9d4HRCiAbdJgjAPVaP_c4On6ae1WZhX5WynRPk31l-iI91k616h32ID81WbVBqbh0ZPR2c_ojy12tB2OWuQjArHVJ7WsW037WVU3LR2W_ulXH3jiD1wjBxBvWjVR3LJnIp4muomYGSu1a4bpaAhDsirm1rj4JDHWvcQDX0H-nzgkh6_ts3veOrUmeXayNwd0s-WzQnhLPn7F9x9jGDqVUFgLq2dr5OvEnENw73qpE9lU8TFqwwbDMgu9ofnLORwhwRPF7Bd3zYeBadCgE3K-BnuQ7ibs7rKoDg4uI_lrelvVrjAQuGPdodpiCqScekyWjm6uucqsKu7rtzO6-ucE6ai6EtLVCAvqAtQsMRUdWbZtc0J3yFCEKuIXVyfG-Dy202LnWV2_av4iSLcpGMEre7k14g21FfdLLDOxzbJEHpFHlkiLJEguJ0A4I-EgStyRUAtCd-q0JNNMUkoV5rzUONM184dn58e_IUwD53mcioL0CaBKzCJXtSb7CWnxdvNT8vlJ53TQbkMlh2q-qlFAL7QZaQRKFymRO_GU44s1KgrGWLsM2AuofxVKH1fZbXk7KiRV6FtwYbFuXr1DGN6sr1asAZOSIFBAvR7aUaKQfs1ljLIf8iWvyYrU3pM");
userInfoBo.setUploadAddress("https://zhixinliantest-1302317679.cos.ap-guangzhou.myqcloud.com/nft/4e40d5f6f65aa8ec9bc33ab424e0167e68783bbe95d4d265086314d749808eef/NOW_ZXL_NFT_PIC001_test_skuId001/");
userInfoBo.setTimestamp(DateUtil.getNowTime());
dataUtils.setSeriesNftUploadTempSecretBo(uploadSeriesName,userInfoBo);
GalaxySeriesNftUploadTempSecretBo seriesNftUploadTempSecretBo = dataUtils.getSeriesNftUploadTempSecretBo(uploadSeriesName);
System.out.println(seriesNftUploadTempSecretBo.toString());
}
@Test
public void testSet(){
String userId = "test123";
GalaxyUserInfoBo userInfoBo = GalaxyUserInfoBo.getNew();
userInfoBo.setUserId(userId);
String key = GalaxyConstant.REDIS_KEY_GALAXY_USER.concat(GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode()).concat(":") + userId;
// redisUtil.getRedisGalaxyUtil().set(key,userInfoBo,keyExpireTime);
}
@Test
public void testGetNftIdNo(){
String routerType = "zxinchain";
String skuId = "1234567890-sku-010";
// redisUtil.set(GalaxyConstant.REDIS_KEY_GALAXY_PUBLISH_NFT.concat(routerType).concat(":").concat(skuId),2000);
long nftIdNo = dataUtils.incrNftIdNo(routerType,skuId);
// long nftIdNo = dataUtils.getNftIdNo(routerType,skuId);
System.out.println("skuId:"+skuId+" no:"+nftIdNo+" ");
}
}
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/test/java/com/liquidnet/service/galaxy/TestZxinArtworkBiz.java deleted 100644 → 0
View file @ 05d5130b
package com.liquidnet.service.galaxy;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadReqDto;
import com.liquidnet.service.galaxy.router.zxin.biz.ZxinArtworkBiz;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: TestZxinArtworkBiz
* @Package com.liquidnet.service.galaxy
* @Copyright: LightNet @ Copyright (c) 2022
* @date 2022/3/19 16:54
*/
@Slf4j
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class TestZxinArtworkBiz {
private static final String oldUrl = "https://zhixinliantest-1302317679.cos.ap-guangzhou.myqcloud.com/nft/4e40d5f6f65aa8ec9bc33ab424e0167e68783bbe95d4d265086314d749808eef/NOW_ZXL_NFT_PIC001_skuId001_test/2022-03-19/ZXLNFTIMAGE202203191647596747100501.mp4";
@Autowired
private ZxinArtworkBiz artworkBiz;
@Test
public void nftUpload(){
GalaxyNftUploadReqDto nftUploadReqDto = GalaxyNftUploadReqDto.getNew();
nftUploadReqDto.setSkuId("video_test_001");
nftUploadReqDto.setOriginalNftUrl(oldUrl);
nftUploadReqDto.setRouterType(GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode());
artworkBiz.nftUpload(nftUploadReqDto);
}
}
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/test/java/com/liquidnet/service/galaxy/TestZxlnftBiz.java deleted 100644 → 0
View file @ 05d5130b
package com.liquidnet.service.galaxy;
import com.liquidnet.common.third.zxlnft.biz.ZxlnftBiz;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: TestZxlnftBiz
* @Package com.liquidnet.service.zxlnft.test
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2022/2/21 11:44
*/
@Slf4j
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class TestZxlnftBiz {
@Autowired
private ZxlnftBiz zxlnftBiz;
@Test
public void getImageType(){
String url = "https://zhixinliantest-1302317679.cos.ap-guangzhou.myqcloud.com/nft/4e40d5f6f65aa8ec9bc33ab424e0167e68783bbe95d4d265086314d749808eef/ZXLNFTIMAGE202202241512003609141721.jpg";
String imageType = url.substring(url.lastIndexOf("."),url.length());
System.out.println(imageType);
}
@Test
public void buildHeader(){
MultiValueMap<String, String> commonHeader = new LinkedMultiValueMap();
zxlnftBiz.buildHeader(commonHeader);
System.out.println(commonHeader.toString());
}
@Test
public void buildPlatFormHeader(){
MultiValueMap<String, String> commonHeader = new LinkedMultiValueMap();
zxlnftBiz.buildPlatFormHeader(commonHeader);
System.out.println(commonHeader.toString());
}
}
liquidnet-bus-service/liquidnet-service-galaxy/pom.xml deleted 100644 → 0
View file @ 05d5130b
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>liquidnet-bus-service</artifactId>
<groupId>com.liquidnet</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>liquidnet-service-galaxy</artifactId>
<packaging>pom</packaging>
<modules>
<module>liquidnet-service-galaxy-common</module>
<module>liquidnet-service-galaxy-impl</module>
</modules>
<dependencies>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-common-swagger</artifactId>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-common-web</artifactId>
</dependency>
</dependencies>
</project>
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-common/pom.xml → liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-common/pom.xml
View file @ ac00bc74
...@@ -3,13 +3,13 @@ ...@@ -3,13 +3,13 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent> <parent>
<artifactId>liquidnet-service-galaxy</artifactId> <artifactId>liquidnet-service-goblin</artifactId>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<artifactId>liquidnet-service-galaxy-common</artifactId> <artifactId>liquidnet-service-goblin-common</artifactId>
<dependencies> <dependencies>
<dependency> <dependency>
......
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/docu/mongo_db_ddl.sql
View file @ ac00bc74
...@@ -114,6 +114,14 @@ db.createCollection("GoblinUserDigitalArtworkVo"); ...@@ -114,6 +114,14 @@ db.createCollection("GoblinUserDigitalArtworkVo");
db.createCollection("GoblinGoodAnticipateUserVo"); db.createCollection("GoblinGoodAnticipateUserVo");
db.createCollection("GoblinGoodsAnticipateValueVo"); db.createCollection("GoblinGoodsAnticipateValueVo");
db.createCollection("GoblinGoodsAnticipateVo"); db.createCollection("GoblinGoodsAnticipateVo");
db.createCollection("GalaxyUserInfoVo");
db.createCollection("GalaxySeriesInfoVo");
db.createCollection("GalaxySeriesNftInfoVo");
db.createCollection("GalaxySeriesNftUploadVo");
db.createCollection("GalaxyNftOrderVo");
db.createCollection("GalaxyNftOrderBindVo");
db.createCollection("GalaxyNftOrderFailLogVo");
db.createCollection("GalaxyNftTradeVo");
# 索引 # 索引
db.GoblinNftOrderVo.createIndex({orderId:"hashed"}); db.GoblinNftOrderVo.createIndex({orderId:"hashed"});
db.GoblinNftOrderVo.createIndex({orderCode:"hashed"}); db.GoblinNftOrderVo.createIndex({orderCode:"hashed"});
...@@ -129,6 +137,14 @@ db.GoblinGoodAnticipateUserVo.createIndex({skuId:"hashed"}); ...@@ -129,6 +137,14 @@ db.GoblinGoodAnticipateUserVo.createIndex({skuId:"hashed"});
db.GoblinGoodsAnticipateVo.createIndex({antId:"hashed"}); db.GoblinGoodsAnticipateVo.createIndex({antId:"hashed"});
db.GoblinGoodsAnticipateValueVo.createIndex({skuId:"hashed"}); db.GoblinGoodsAnticipateValueVo.createIndex({skuId:"hashed"});
db.GoblinGoodsAnticipateValueVo.createIndex({antId:"hashed"}); db.GoblinGoodsAnticipateValueVo.createIndex({antId:"hashed"});
db.GalaxyUserInfoVo.createIndex({userId:"hashed"});
db.GalaxySeriesInfoVo.createIndex({seriesCode:"hashed"});
db.GalaxySeriesNftInfoVo.createIndex({skuId:"hashed"});
db.GalaxySeriesNftUploadVo.createIndex({skuId:"hashed"});
db.GalaxyNftOrderVo.createIndex({nftOrderPayId:"hashed"});
db.GalaxyNftOrderBindVo.createIndex({nftOrderPayId:"hashed"});
db.GalaxyNftOrderFailLogVo.createIndex({nftOrderPayId:"hashed"});
db.GalaxyNftTradeVo.createIndex({nftId:"hashed"});
# 分片 # 分片
sh.enableSharding("test_ln_scene"); sh.enableSharding("test_ln_scene");
sh.shardCollection("test_ln_scene.GoblinNftOrderVo",{"orderId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinNftOrderVo",{"orderId":"hashed"});
...@@ -136,4 +152,12 @@ sh.shardCollection("test_ln_scene.GoblinNftOrderRefundVo",{"orderRefundId":"hash ...@@ -136,4 +152,12 @@ sh.shardCollection("test_ln_scene.GoblinNftOrderRefundVo",{"orderRefundId":"hash
sh.shardCollection("test_ln_scene.GoblinUserDigitalArtworkVo",{"artworkId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinUserDigitalArtworkVo",{"artworkId":"hashed"});
sh.shardCollection("test_ln_scene.GoblinGoodAnticipateUserVo",{"skuId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinGoodAnticipateUserVo",{"skuId":"hashed"});
sh.shardCollection("test_ln_scene.GoblinGoodsAnticipateValueVo",{"antId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinGoodsAnticipateValueVo",{"antId":"hashed"});
sh.shardCollection("test_ln_scene.GoblinGoodsAnticipateVo",{"antId":"hashed"}); sh.shardCollection("test_ln_scene.GoblinGoodsAnticipateVo",{"antId":"hashed"});
\ No newline at end of file sh.shardCollection("test_ln_scene.GalaxyUserInfoVo",{"userId":"hashed"});
sh.shardCollection("test_ln_scene.GalaxySeriesInfoVo",{"seriesCode":"hashed"});
sh.shardCollection("test_ln_scene.GalaxySeriesNftInfoVo",{"skuId":"hashed"});
sh.shardCollection("test_ln_scene.GalaxySeriesNftUploadVo",{"skuId":"hashed"});
sh.shardCollection("test_ln_scene.GalaxyNftOrderVo",{"nftOrderPayId":"hashed"});
sh.shardCollection("test_ln_scene.GalaxyNftOrderBindVo",{"nftOrderPayId":"hashed"});
sh.shardCollection("test_ln_scene.GalaxyNftOrderFailLogVo",{"nftOrderPayId":"hashed"});
sh.shardCollection("test_ln_scene.GalaxyNftTradeVo",{"nftId":"hashed"});
\ No newline at end of file
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/pom.xml
View file @ ac00bc74
...@@ -54,6 +54,22 @@ ...@@ -54,6 +54,22 @@
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
<scope>compile</scope> <scope>compile</scope>
</dependency> </dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-goblin-common</artifactId>
<version>1.0-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-common-third-zxlnft</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-common-third-antchain</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency> <dependency>
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/aop/GalaxyRequestLogAspect.java → liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/galaxy/aop/GalaxyRequestLogAspect.java
View file @ ac00bc74
//package com.liquidnet.service.galaxy.aop; package com.liquidnet.service.galaxy.aop;//package com.liquidnet.service.galaxy.aop;
// //
//import com.alibaba.fastjson.JSON; //import com.alibaba.fastjson.JSON;
//import com.alibaba.fastjson.serializer.SerializerFeature; //import com.alibaba.fastjson.serializer.SerializerFeature;
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/service/impl/GalaxyPublishServiceImpl.java → liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/galaxy/service/impl/GalaxyPublishServiceImpl.java
View file @ ac00bc74
package com.liquidnet.service.galaxy.service.impl; package com.liquidnet.service.galaxy.service.impl;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.dto.param.*; import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishReqDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishRespDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishResultQueryReqDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishResultQueryRespDto;
import com.liquidnet.service.galaxy.router.strategy.GalaxyRouterStrategyContext; import com.liquidnet.service.galaxy.router.strategy.GalaxyRouterStrategyContext;
import com.liquidnet.service.galaxy.service.IGalaxyPublishService; import com.liquidnet.service.galaxy.service.IGalaxyPublishService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
......
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