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

Skip to content

L
liquidnet-bus-v1
Commit 3bbee149 authored by anjiabin's avatar anjiabin
Browse files
Options

优化相关策略实现

parent a5fe1534
Show whitespace changes
Inline Side-by-side
Showing with 299 additions and 285 deletions
liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/constant/GalaxyConstant.java
View file @ 3bbee149
......@@ -15,220 +15,4 @@ public class GalaxyConstant {
public static final String REDIS_KET_GALAXY_TRADE="galaxy:trade:order:";
public static final String SERIES_NAME_PREFIX="NOW_ZXL_";// 系列存储目录名称和系列声明
public enum RouterTypeEnum{
ZXINCHAIN("zxinchain","至信链"),
ETH ("eth","以太坊"),
ANTCHAIN ("antchain","蚂蚁链"),
XUPER("xuper","百度超级链");
private String code;
private String message;
RouterTypeEnum(String code, String message) {
this.code = code;
this.message = message;
}
public String getCode() {
return code;
}
}
/**
* 路由业务枚举
*/
public enum SeriesClaimStatusEnum{
SERIES_INIT("init","系列声明数据初始化"),
PROCESSING("processing","系列声明中"),
SUCCESS ("success","系列声明成功"),
FAIL ("fail","系列声明失败");
private String code;
private String message;
SeriesClaimStatusEnum(String code, String message) {
this.code = code;
this.message = message;
}
public String getCode() {
return code;
}
}
/**
* 路由业务枚举
*/
public enum RouterBusinessEnum{
NFT("nft","数字藏品nft"),
DCI ("dci","数字存证dci");
private String code;
private String message;
RouterBusinessEnum(String code, String message) {
this.code = code;
this.message = message;
}
public String getCode() {
return code;
}
}
public enum DeviceFromEnum{
WEB("web",""),
WAP("wap",""),
WAPPAGE("wappage",""),
APP("app",""),
JS("js",""),
APPLET("applet","");
private String code;
private String message;
DeviceFromEnum(String code, String message) {
this.code = code;
this.message = message;
}
public String getCode() {
return code;
}
}
/**
* 注册类型
*/
public enum RegisterTypeEnum{
PERSON("1","企业"),
COMPANY("2","个人");
private String code;
private String message;
RegisterTypeEnum(String code, String message) {
this.code = code;
this.message = message;
}
public RegisterTypeEnum getEnumByCode(String code){
RegisterTypeEnum[] arry = RegisterTypeEnum.values();
for (int i = 0; i < arry.length; i++) {
if (arry[i].getCode().equals(code)) {
return arry[i];
}
}
return null;
}
public String getCode() {
return code;
}
}
public enum CardTypeEnum{
// 1-身份证 2-护照 3-港澳通行证 4-台湾通行证 5-外国人永居身份证 6-港澳台居民居住证 7-其它
ID_CARD("1","身份证"),
ID_CARD_PP("2","护照"),
ID_CARD_HM("3","港澳通行证"),
ID_CARD_TW("4","台湾通行证"),
ID_CARD_FOR("5","外国人永居身份证"),
ID_CARD_HMTW("6","港澳台居民居住证"),
ID_CARD_OTHER("7","其它");
private String code;
private String message;
CardTypeEnum(String code, String message) {
this.code = code;
this.message = message;
}
public CardTypeEnum getEnumByCode(String code){
CardTypeEnum[] arry = CardTypeEnum.values();
for (int i = 0; i < arry.length; i++) {
if (arry[i].getCode().equals(code)) {
return arry[i];
}
}
return null;
}
public String getCode() {
return code;
}
}
/**
* 标记任务状态
*/
public enum TaskStatusEnum{
PROCESSING("0","任务执行中"),
TASK_SUCCESS("1","任务成功"),
TASK_FAIL("2","任务失败");
private String code;
private String message;
TaskStatusEnum(String code, String message) {
this.code = code;
this.message = message;
}
public TaskStatusEnum getEnumByCode(String code){
TaskStatusEnum[] arry = TaskStatusEnum.values();
for (int i = 0; i < arry.length; i++) {
if (arry[i].getCode().equals(code)) {
return arry[i];
}
}
return null;
}
public String getCode() {
return code;
}
public String getMessage(){
return message;
}
}
/**
* 标记任务状态
*/
public enum UserBindStatusEnum{
BIND_PROCESSING("0","绑定中"),
BIND_SUCCESS("1","已绑定"),
BIND_FAIL("2","绑定失败"),
BIND_CANNOT_QUERY("3","未发起过绑定(未查询到)");
private String code;
private String message;
UserBindStatusEnum(String code, String message) {
this.code = code;
this.message = message;
}
public UserBindStatusEnum getEnumByCode(String code){
UserBindStatusEnum[] arry = UserBindStatusEnum.values();
for (int i = 0; i < arry.length; i++) {
if (arry[i].getCode().equals(code)) {
return arry[i];
}
}
return null;
}
public String getCode() {
return code;
}
public String getMessage(){
return message;
}
}
public static void main(String[] args) {
Integer aaa = 1;
if(aaa.toString().equals(RouterTypeEnum.ZXINCHAIN.getCode())){
System.out.println("支付成功");
}
}
}
liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/constant/GalaxyEnum.java 0 → 100644
View file @ 3bbee149
package com.liquidnet.service.galaxy.constant;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: GalaxyConstant
* @Package com.liquidnet.service.galaxy.constant
* @Copyright: LightNet @ Copyright (c) 2022
* @date 2022/3/23 12:25
*/
public class GalaxyEnum {
public enum RouterTypeEnum{
ZXINCHAIN("zxinchain","至信链"),
ETH ("eth","以太坊"),
ANTCHAIN ("antchain","蚂蚁链"),
XUPER("xuper","百度超级链");
private String code;
private String message;
RouterTypeEnum(String code, String message) {
this.code = code;
this.message = message;
}
public String getCode() {
return code;
}
}
/**
* 路由业务枚举
*/
public enum SeriesClaimStatusEnum{
SERIES_INIT("init","系列声明数据初始化"),
PROCESSING("processing","系列声明中"),
SUCCESS ("success","系列声明成功"),
FAIL ("fail","系列声明失败");
private String code;
private String message;
SeriesClaimStatusEnum(String code, String message) {
this.code = code;
this.message = message;
}
public String getCode() {
return code;
}
}
/**
* 路由业务枚举
*/
public enum RouterBusinessEnum{
NFT("nft","数字藏品nft"),
DCI ("dci","数字存证dci");
private String code;
private String message;
RouterBusinessEnum(String code, String message) {
this.code = code;
this.message = message;
}
public String getCode() {
return code;
}
}
public enum DeviceFromEnum{
WEB("web",""),
WAP("wap",""),
WAPPAGE("wappage",""),
APP("app",""),
JS("js",""),
APPLET("applet","");
private String code;
private String message;
DeviceFromEnum(String code, String message) {
this.code = code;
this.message = message;
}
public String getCode() {
return code;
}
}
/**
* 注册类型
*/
public enum RegisterTypeEnum{
PERSON("1","企业"),
COMPANY("2","个人");
private String code;
private String message;
RegisterTypeEnum(String code, String message) {
this.code = code;
this.message = message;
}
public RegisterTypeEnum getEnumByCode(String code){
RegisterTypeEnum[] arry = RegisterTypeEnum.values();
for (int i = 0; i < arry.length; i++) {
if (arry[i].getCode().equals(code)) {
return arry[i];
}
}
return null;
}
public String getCode() {
return code;
}
}
public enum CardTypeEnum{
// 1-身份证 2-护照 3-港澳通行证 4-台湾通行证 5-外国人永居身份证 6-港澳台居民居住证 7-其它
ID_CARD("1","身份证"),
ID_CARD_PP("2","护照"),
ID_CARD_HM("3","港澳通行证"),
ID_CARD_TW("4","台湾通行证"),
ID_CARD_FOR("5","外国人永居身份证"),
ID_CARD_HMTW("6","港澳台居民居住证"),
ID_CARD_OTHER("7","其它");
private String code;
private String message;
CardTypeEnum(String code, String message) {
this.code = code;
this.message = message;
}
public CardTypeEnum getEnumByCode(String code){
CardTypeEnum[] arry = CardTypeEnum.values();
for (int i = 0; i < arry.length; i++) {
if (arry[i].getCode().equals(code)) {
return arry[i];
}
}
return null;
}
public String getCode() {
return code;
}
}
/**
* 标记任务状态
*/
public enum TaskStatusEnum{
PROCESSING("0","任务执行中"),
TASK_SUCCESS("1","任务成功"),
TASK_FAIL("2","任务失败");
private String code;
private String message;
TaskStatusEnum(String code, String message) {
this.code = code;
this.message = message;
}
public TaskStatusEnum getEnumByCode(String code){
TaskStatusEnum[] arry = TaskStatusEnum.values();
for (int i = 0; i < arry.length; i++) {
if (arry[i].getCode().equals(code)) {
return arry[i];
}
}
return null;
}
public String getCode() {
return code;
}
public String getMessage(){
return message;
}
}
/**
* 标记任务状态
*/
public enum UserBindStatusEnum{
BIND_PROCESSING("0","绑定中"),
BIND_SUCCESS("1","已绑定"),
BIND_FAIL("2","绑定失败"),
BIND_CANNOT_QUERY("3","未发起过绑定(未查询到)");
private String code;
private String message;
UserBindStatusEnum(String code, String message) {
this.code = code;
this.message = message;
}
public UserBindStatusEnum getEnumByCode(String code){
UserBindStatusEnum[] arry = UserBindStatusEnum.values();
for (int i = 0; i < arry.length; i++) {
if (arry[i].getCode().equals(code)) {
return arry[i];
}
}
return null;
}
public String getCode() {
return code;
}
public String getMessage(){
return message;
}
}
public static void main(String[] args) {
Integer aaa = 1;
if(aaa.toString().equals(RouterTypeEnum.ZXINCHAIN.getCode())){
System.out.println("支付成功");
}
}
}
liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyBaseReqDto.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.dto.param;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
......@@ -24,7 +24,7 @@ public class GalaxyBaseReqDto implements Serializable,Cloneable{
*/
@ApiModelProperty(position = 1, required = true, value = "路由类型(至信链zxinchain、以太坊eth)")
@NotBlank(message = "路由类型不能为空！")
private String routerType = GalaxyConstant.RouterTypeEnum.ZXINCHAIN.getCode();
private String routerType = GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode();
@Override
public String toString(){
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/eth/service/GalaxyRouterStrategyEthArtworkImpl.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.eth.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.*;
import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategyArtwork;
import com.liquidnet.service.galaxy.router.strategy.annotation.StrategyGalaxyRouterArtworkHandler;
......@@ -19,7 +19,7 @@ import org.springframework.stereotype.Component;
*/
@Slf4j
@Component
@StrategyGalaxyRouterArtworkHandler(GalaxyConstant.RouterTypeEnum.ETH)
@StrategyGalaxyRouterArtworkHandler(GalaxyEnum.RouterTypeEnum.ETH)
public class GalaxyRouterStrategyEthArtworkImpl implements IGalaxyRouterStrategyArtwork {
@Override
public ResponseDto<GalaxyNftImageRespDto> nftImageCheck(GalaxyNftImageReqDto reqDto) {
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/eth/service/GalaxyRouterStrategyEthPublishImpl.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.eth.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishReqDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishRespDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishResultQueryReqDto;
......@@ -22,7 +22,7 @@ import org.springframework.stereotype.Component;
*/
@Slf4j
@Component
@StrategyGalaxyRouterPublishHandler(GalaxyConstant.RouterTypeEnum.ETH)
@StrategyGalaxyRouterPublishHandler(GalaxyEnum.RouterTypeEnum.ETH)
public class GalaxyRouterStrategyEthPublishImpl implements IGalaxyRouterStrategyPublish {
@Override
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/eth/service/GalaxyRouterStrategyEthTradeImpl.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.eth.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.*;
import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategyTrade;
import com.liquidnet.service.galaxy.router.strategy.annotation.StrategyGalaxyRouterTradeHandler;
......@@ -19,7 +19,7 @@ import org.springframework.stereotype.Component;
*/
@Slf4j
@Component
@StrategyGalaxyRouterTradeHandler(GalaxyConstant.RouterTypeEnum.ETH)
@StrategyGalaxyRouterTradeHandler(GalaxyEnum.RouterTypeEnum.ETH)
public class GalaxyRouterStrategyEthTradeImpl implements IGalaxyRouterStrategyTrade {
@Override
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/eth/service/GalaxyRouterStrategyEthUserImpl.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.eth.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryReqDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryRespDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterReqDto;
......@@ -22,7 +22,7 @@ import org.springframework.stereotype.Component;
*/
@Slf4j
@Component
@StrategyGalaxyRouterUserHandler(GalaxyConstant.RouterTypeEnum.ETH)
@StrategyGalaxyRouterUserHandler(GalaxyEnum.RouterTypeEnum.ETH)
public class GalaxyRouterStrategyEthUserImpl implements IGalaxyRouterStrategyUser {
@Override
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/annotation/StrategyGalaxyRouterArtworkHandler.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.strategy.annotation;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import java.lang.annotation.*;
......@@ -18,5 +18,5 @@ import java.lang.annotation.*;
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface StrategyGalaxyRouterArtworkHandler {
GalaxyConstant.RouterTypeEnum value();
GalaxyEnum.RouterTypeEnum value();
}
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/annotation/StrategyGalaxyRouterPublishHandler.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.strategy.annotation;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import java.lang.annotation.*;
......@@ -18,5 +18,5 @@ import java.lang.annotation.*;
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface StrategyGalaxyRouterPublishHandler {
GalaxyConstant.RouterTypeEnum value();
GalaxyEnum.RouterTypeEnum value();
}
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/annotation/StrategyGalaxyRouterTradeHandler.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.strategy.annotation;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import java.lang.annotation.*;
......@@ -18,5 +18,5 @@ import java.lang.annotation.*;
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface StrategyGalaxyRouterTradeHandler {
GalaxyConstant.RouterTypeEnum value();
GalaxyEnum.RouterTypeEnum value();
}
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/annotation/StrategyGalaxyRouterUserHandler.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.strategy.annotation;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import java.lang.annotation.*;
......@@ -18,5 +18,5 @@ import java.lang.annotation.*;
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface StrategyGalaxyRouterUserHandler {
GalaxyConstant.RouterTypeEnum value();
GalaxyEnum.RouterTypeEnum value();
}
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/biz/GalaxyEnumBiz.java
View file @ 3bbee149
......@@ -2,7 +2,7 @@ package com.liquidnet.service.galaxy.router.strategy.biz;
import com.liquidnet.common.third.antchain.constant.AntchainEnum;
import com.liquidnet.common.third.zxlnft.constant.ZxlnftEnum;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
......@@ -21,29 +21,29 @@ public class GalaxyEnumBiz {
* @param code
* @return
*/
public static GalaxyConstant.TaskStatusEnum getTaskStatusEnum(GalaxyConstant.RouterTypeEnum routerTypeEnum, String code){
GalaxyConstant.TaskStatusEnum taskStatusEnum = null;
public static GalaxyEnum.TaskStatusEnum getTaskStatusEnum(GalaxyEnum.RouterTypeEnum routerTypeEnum, String code){
GalaxyEnum.TaskStatusEnum taskStatusEnum = null;
switch (routerTypeEnum.getCode()){
case "zxinchain":
if(code.equalsIgnoreCase(ZxlnftEnum.TaskStatusEnum.PROCESSING.getCode())){
taskStatusEnum = GalaxyConstant.TaskStatusEnum.PROCESSING;
taskStatusEnum = GalaxyEnum.TaskStatusEnum.PROCESSING;
break;
}else if(code.equalsIgnoreCase(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
taskStatusEnum = GalaxyConstant.TaskStatusEnum.TASK_SUCCESS;
taskStatusEnum = GalaxyEnum.TaskStatusEnum.TASK_SUCCESS;
break;
}else if(code.equalsIgnoreCase(ZxlnftEnum.TaskStatusEnum.TASK_FAIL.getCode())){
taskStatusEnum = GalaxyConstant.TaskStatusEnum.TASK_FAIL;
taskStatusEnum = GalaxyEnum.TaskStatusEnum.TASK_FAIL;
break;
}
case "antchain":
if(code.equalsIgnoreCase(AntchainEnum.TaskStatusEnum.PROCESSING.getCode())){
taskStatusEnum = GalaxyConstant.TaskStatusEnum.PROCESSING;
taskStatusEnum = GalaxyEnum.TaskStatusEnum.PROCESSING;
break;
}else if(code.equalsIgnoreCase(AntchainEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
taskStatusEnum = GalaxyConstant.TaskStatusEnum.TASK_SUCCESS;
taskStatusEnum = GalaxyEnum.TaskStatusEnum.TASK_SUCCESS;
break;
}else if(code.equalsIgnoreCase(AntchainEnum.TaskStatusEnum.TASK_FAIL.getCode())){
taskStatusEnum = GalaxyConstant.TaskStatusEnum.TASK_FAIL;
taskStatusEnum = GalaxyEnum.TaskStatusEnum.TASK_FAIL;
break;
}
}
......@@ -56,35 +56,35 @@ public class GalaxyEnumBiz {
* @param code
* @return
*/
public static GalaxyConstant.UserBindStatusEnum getUserBindStatusEnum(String routerType, String code) {
GalaxyConstant.UserBindStatusEnum userBindStatusEnum = null;
public static GalaxyEnum.UserBindStatusEnum getUserBindStatusEnum(String routerType, String code) {
GalaxyEnum.UserBindStatusEnum userBindStatusEnum = null;
switch (routerType) {
case "zxinchain":
if (code.equalsIgnoreCase(ZxlnftEnum.UserBindStatusEnum.BIND_PROCESSING.getCode())) {
userBindStatusEnum = GalaxyConstant.UserBindStatusEnum.BIND_PROCESSING;
userBindStatusEnum = GalaxyEnum.UserBindStatusEnum.BIND_PROCESSING;
break;
} else if (code.equalsIgnoreCase(ZxlnftEnum.UserBindStatusEnum.BIND_SUCCESS.getCode())) {
userBindStatusEnum = GalaxyConstant.UserBindStatusEnum.BIND_SUCCESS;
userBindStatusEnum = GalaxyEnum.UserBindStatusEnum.BIND_SUCCESS;
break;
} else if (code.equalsIgnoreCase(ZxlnftEnum.UserBindStatusEnum.BIND_FAIL.getCode())) {
userBindStatusEnum = GalaxyConstant.UserBindStatusEnum.BIND_FAIL;
userBindStatusEnum = GalaxyEnum.UserBindStatusEnum.BIND_FAIL;
break;
} else if (code.equalsIgnoreCase(ZxlnftEnum.UserBindStatusEnum.BIND_CANNOT_QUERY.getCode())) {
userBindStatusEnum = GalaxyConstant.UserBindStatusEnum.BIND_CANNOT_QUERY;
userBindStatusEnum = GalaxyEnum.UserBindStatusEnum.BIND_CANNOT_QUERY;
break;
}
case "antchain":
if (code.equalsIgnoreCase(AntchainEnum.UserBindStatusEnum.BIND_PROCESSING.getCode())) {
userBindStatusEnum = GalaxyConstant.UserBindStatusEnum.BIND_PROCESSING;
userBindStatusEnum = GalaxyEnum.UserBindStatusEnum.BIND_PROCESSING;
break;
} else if (code.equalsIgnoreCase(AntchainEnum.UserBindStatusEnum.BIND_SUCCESS.getCode())) {
userBindStatusEnum = GalaxyConstant.UserBindStatusEnum.BIND_SUCCESS;
userBindStatusEnum = GalaxyEnum.UserBindStatusEnum.BIND_SUCCESS;
break;
} else if (code.equalsIgnoreCase(AntchainEnum.UserBindStatusEnum.BIND_FAIL.getCode())) {
userBindStatusEnum = GalaxyConstant.UserBindStatusEnum.BIND_FAIL;
userBindStatusEnum = GalaxyEnum.UserBindStatusEnum.BIND_FAIL;
break;
} else if (code.equalsIgnoreCase(AntchainEnum.UserBindStatusEnum.BIND_CANNOT_QUERY.getCode())) {
userBindStatusEnum = GalaxyConstant.UserBindStatusEnum.BIND_CANNOT_QUERY;
userBindStatusEnum = GalaxyEnum.UserBindStatusEnum.BIND_CANNOT_QUERY;
break;
}
}
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinArtworkBiz.java
View file @ 3bbee149
......@@ -16,6 +16,7 @@ import com.liquidnet.commons.lang.util.IDGenerator;
import com.liquidnet.commons.lang.util.StringUtil;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.constant.GalaxyErrorCodeEnum;
import com.liquidnet.service.galaxy.dto.bo.GalaxySeriesInfoBo;
import com.liquidnet.service.galaxy.dto.param.*;
......@@ -116,12 +117,12 @@ public class ZxinArtworkBiz {
//返回参数
String seriesId = null;
String taskId = null;
GalaxySeriesInfoBo seriesInfoBo = dataUtils.getSeriesInfoBo(reqDto.getRouteType(),reqDto.getSkuId());
GalaxySeriesInfoBo seriesInfoBo = dataUtils.getSeriesInfoBo(reqDto.getRouterType(),reqDto.getSkuId());
if(StringUtil.isNotNull(seriesInfoBo)){
/**
* 如果系列声明成功，则不允许继续声明
*/
if(seriesInfoBo.getPublishStatus().equalsIgnoreCase(GalaxyConstant.SeriesClaimStatusEnum.SUCCESS.getCode())){
if(seriesInfoBo.getPublishStatus().equalsIgnoreCase(GalaxyEnum.SeriesClaimStatusEnum.SUCCESS.getCode())){
GalaxyArtSeriesClaimRespDto seriesClaimRespDto = GalaxyArtSeriesClaimRespDto.getNew();
seriesClaimRespDto.setSkuId(seriesInfoBo.getSkuId());
seriesClaimRespDto.setMaterialAccessUrl(seriesInfoBo.getNftUrl());
......@@ -192,7 +193,7 @@ public class ZxinArtworkBiz {
if(seriesInfoBo==null){
seriesInfoBo = this.buildSeriesInfoBo(false,skuId,seriesName,seriesId,totalCount,0l,
author,nftName,nftUrl,displayUrl,nftDesc,nftFlag,sellCount,coverUrl,seriesDesc);
dataUtils.setSeriesInfoBo(reqDto.getRouteType(),reqDto.getSkuId(),seriesInfoBo);
dataUtils.setSeriesInfoBo(reqDto.getRouterType(),reqDto.getSkuId(),seriesInfoBo);
}
return ResponseDto.success(seriesClaimRespDto);
}
......@@ -277,12 +278,12 @@ public class ZxinArtworkBiz {
seriesInfoBo.setTotalCount(totalCount);
seriesInfoBo.setCrtCount(crtCount);
seriesInfoBo.setNftUrl(nftUrl);
seriesInfoBo.setPublishStatus(GalaxyConstant.SeriesClaimStatusEnum.SERIES_INIT.getCode());
seriesInfoBo.setPublishStatus(GalaxyEnum.SeriesClaimStatusEnum.SERIES_INIT.getCode());
if(!isInit){
if(StringUtil.isEmpty(seriesId)){
seriesInfoBo.setPublishStatus(GalaxyConstant.SeriesClaimStatusEnum.PROCESSING.getCode());
seriesInfoBo.setPublishStatus(GalaxyEnum.SeriesClaimStatusEnum.PROCESSING.getCode());
}else{
seriesInfoBo.setPublishStatus(GalaxyConstant.SeriesClaimStatusEnum.SUCCESS.getCode());
seriesInfoBo.setPublishStatus(GalaxyEnum.SeriesClaimStatusEnum.SUCCESS.getCode());
}
}
//以下为购买信息
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinPublishBiz.java
View file @ 3bbee149
......@@ -54,16 +54,16 @@ public class ZxinPublishBiz {
public ResponseDto<GalaxyNftPublishRespDto> nftPublish(GalaxyNftPublishReqDto reqDto) {
//获取订单信息
GalaxyNftOrderBo nftOrderBo = dataUtils.getNftOrderBo(reqDto.getRouteType(),reqDto.getNftOrderPayId());
GalaxyNftOrderBo nftOrderBo = dataUtils.getNftOrderBo(reqDto.getRouterType(),reqDto.getNftOrderPayId());
if(StringUtil.isNotNull(nftOrderBo)&&StringUtil.isNotEmpty(nftOrderBo.getNftId())){
return ResponseDto.failure(GalaxyErrorCodeEnum.PUBLISH_FAIL_ALREADY_EXIST.getCode(),GalaxyErrorCodeEnum.PUBLISH_FAIL_ALREADY_EXIST.getMessage());
}
//获取用户信息
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(reqDto.getRouteType(),reqDto.getUserId());
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(reqDto.getRouterType(),reqDto.getUserId());
//获取sku信息
GalaxySeriesInfoBo seriesInfoBo = dataUtils.getSeriesInfoBo(reqDto.getRouteType(),reqDto.getSkuId());
GalaxySeriesInfoBo seriesInfoBo = dataUtils.getSeriesInfoBo(reqDto.getRouterType(),reqDto.getSkuId());
String author = seriesInfoBo.getAuthor();
String nftName = seriesInfoBo.getNftName();
......@@ -181,7 +181,7 @@ public class ZxinPublishBiz {
nftOrderBo.setNftPrice(seriesInfoBo.getSellCount().longValue());
nftOrderBo.setFromAddress("");
nftOrderBo.setToAddress("");
dataUtils.setNftOrderBo(reqDto.getRouteType(),reqDto.getNftOrderPayId(),nftOrderBo);
dataUtils.setNftOrderBo(reqDto.getRouterType(),reqDto.getNftOrderPayId(),nftOrderBo);
}
return ResponseDto.success(nftPublishRespDto);
}
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinTradeBiz.java
View file @ 3bbee149
......@@ -54,13 +54,13 @@ public class ZxinTradeBiz {
public ResponseDto<GalaxyNftBuyRespDto> nftBuy(GalaxyNftBuyReqDto nftBuyReqDto){
//获取用户信息
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(nftBuyReqDto.getRouteType(),nftBuyReqDto.getUserId());
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(nftBuyReqDto.getRouterType(),nftBuyReqDto.getUserId());
//获取sku信息
GalaxySeriesInfoBo seriesInfoBo = dataUtils.getSeriesInfoBo(nftBuyReqDto.getRouteType(),nftBuyReqDto.getSkuId());
GalaxySeriesInfoBo seriesInfoBo = dataUtils.getSeriesInfoBo(nftBuyReqDto.getRouterType(),nftBuyReqDto.getSkuId());
//获取nftOrder信息
GalaxyNftOrderBo nftOrderBo = dataUtils.getNftOrderBo(nftBuyReqDto.getRouteType(),nftBuyReqDto.getNftOrderPayId());
GalaxyNftOrderBo nftOrderBo = dataUtils.getNftOrderBo(nftBuyReqDto.getRouterType(),nftBuyReqDto.getNftOrderPayId());
//返回参数nftId
String nftId = null;
......@@ -79,10 +79,10 @@ public class ZxinTradeBiz {
public ResponseDto<GalaxyNftPublishAndBuyRespDto> nftPublishAndBuy(GalaxyNftPublishAndBuyReqDto reqDto) {
//获取用户信息
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(reqDto.getRouteType(),reqDto.getUserId());
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(reqDto.getRouterType(),reqDto.getUserId());
//获取sku信息
GalaxySeriesInfoBo seriesInfoBo = dataUtils.getSeriesInfoBo(reqDto.getRouteType(),reqDto.getSkuId());
GalaxySeriesInfoBo seriesInfoBo = dataUtils.getSeriesInfoBo(reqDto.getRouterType(),reqDto.getSkuId());
String author = seriesInfoBo.getAuthor();
String nftName = seriesInfoBo.getNftName();
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinUserBiz.java
View file @ 3bbee149
......@@ -15,7 +15,7 @@ import com.liquidnet.common.third.zxlnft.util.ZxlnftSdkUtil;
import com.liquidnet.commons.lang.util.BASE64Util;
import com.liquidnet.commons.lang.util.StringUtil;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.bo.GalaxyUserInfoBo;
import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryReqDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryRespDto;
......@@ -70,7 +70,7 @@ public class ZxinUserBiz {
String userPubKey = null;
String userPriKey = null;
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(reqDto.getRouteType(),userId);
GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(reqDto.getRouterType(),userId);
if(userInfoBo!=null){
mnemonic = userInfoBo.getMnemonic();
}else{
......@@ -157,7 +157,7 @@ public class ZxinUserBiz {
log.info("nft016Resp 返回结果：{}",nft016Resp.toJson());
//构造返回参数
respDto.setUserId(userId);
respDto.setBlockChainType(GalaxyConstant.RouterTypeEnum.ZXINCHAIN.getCode());
respDto.setBlockChainType(GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode());
respDto.setBlockChainAddress(address);
}else{
return ResponseDto.failure(nft016Resp.getMessage());
......@@ -177,9 +177,9 @@ public class ZxinUserBiz {
userInfoBo.setUserIdentification(userIdentification);
userInfoBo.setUserPubKey(userPubKey);
userInfoBo.setUserPriKey(userPriKey);
userInfoBo.setRouterType(GalaxyConstant.RouterTypeEnum.ZXINCHAIN.getCode());
userInfoBo.setRouterType(GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode());
userInfoBo.setBlockChainAddress(address);
dataUtils.setGalaxyUserInfo(reqDto.getRouteType(),reqDto.getUserId(),userInfoBo);
dataUtils.setGalaxyUserInfo(reqDto.getRouterType(),reqDto.getUserId(),userInfoBo);
}
}
return ResponseDto.success(respDto);
......@@ -194,7 +194,7 @@ public class ZxinUserBiz {
if(zxlnftResponseDto.isSuccess()){
Nft016QueryRsData nft016QueryRsData = zxlnftResponseDto.getData().getList().get(0);
userBindStatusQueryRespDto.setBlockChainAddress(nft016QueryRsData.getAddress());
Integer userBindStatus = Integer.valueOf(GalaxyEnumBiz.getUserBindStatusEnum(reqDto.getRouteType(),nft016QueryRsData.getStatus()).getCode());
Integer userBindStatus = Integer.valueOf(GalaxyEnumBiz.getUserBindStatusEnum(reqDto.getRouterType(),nft016QueryRsData.getStatus()).getCode());
userBindStatusQueryRespDto.setUserBindStatus(userBindStatus);
}else{
return ResponseDto.failure();
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/service/GalaxyRouterStrategyZxlArtworkImpl.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.zxin.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.*;
import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategyArtwork;
import com.liquidnet.service.galaxy.router.strategy.annotation.StrategyGalaxyRouterArtworkHandler;
......@@ -21,7 +21,7 @@ import org.springframework.stereotype.Component;
*/
@Slf4j
@Component
@StrategyGalaxyRouterArtworkHandler(GalaxyConstant.RouterTypeEnum.ZXINCHAIN)
@StrategyGalaxyRouterArtworkHandler(GalaxyEnum.RouterTypeEnum.ZXINCHAIN)
public class GalaxyRouterStrategyZxlArtworkImpl implements IGalaxyRouterStrategyArtwork {
@Autowired
private ZxinArtworkBiz zxinArtworkBiz;
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/service/GalaxyRouterStrategyZxlPublishImpl.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.zxin.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishReqDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishRespDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishResultQueryReqDto;
......@@ -24,7 +24,7 @@ import org.springframework.stereotype.Component;
*/
@Slf4j
@Component
@StrategyGalaxyRouterPublishHandler(GalaxyConstant.RouterTypeEnum.ZXINCHAIN)
@StrategyGalaxyRouterPublishHandler(GalaxyEnum.RouterTypeEnum.ZXINCHAIN)
public class GalaxyRouterStrategyZxlPublishImpl implements IGalaxyRouterStrategyPublish {
@Autowired
private ZxinPublishBiz zxinPublishBiz;
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/service/GalaxyRouterStrategyZxlTradeImpl.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.zxin.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.*;
import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategyTrade;
import com.liquidnet.service.galaxy.router.strategy.annotation.StrategyGalaxyRouterTradeHandler;
......@@ -21,7 +21,7 @@ import org.springframework.stereotype.Component;
*/
@Slf4j
@Component
@StrategyGalaxyRouterTradeHandler(GalaxyConstant.RouterTypeEnum.ZXINCHAIN)
@StrategyGalaxyRouterTradeHandler(GalaxyEnum.RouterTypeEnum.ZXINCHAIN)
public class GalaxyRouterStrategyZxlTradeImpl implements IGalaxyRouterStrategyTrade {
@Autowired
private ZxinTradeBiz zxinTradeBiz;
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/service/GalaxyRouterStrategyZxlUserImpl.java
View file @ 3bbee149
package com.liquidnet.service.galaxy.router.zxin.service;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryReqDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryRespDto;
import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterReqDto;
......@@ -24,7 +24,7 @@ import org.springframework.stereotype.Component;
*/
@Slf4j
@Component
@StrategyGalaxyRouterUserHandler(GalaxyConstant.RouterTypeEnum.ZXINCHAIN)
@StrategyGalaxyRouterUserHandler(GalaxyEnum.RouterTypeEnum.ZXINCHAIN)
public class GalaxyRouterStrategyZxlUserImpl implements IGalaxyRouterStrategyUser {
@Autowired
private ZxinUserBiz zxinUserBiz;
......
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/test/java/com/liquidnet/service/galaxy/TestRedisUtil.java
View file @ 3bbee149
......@@ -2,6 +2,7 @@ package com.liquidnet.service.galaxy;
import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.bo.GalaxyUserInfoBo;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
......@@ -35,7 +36,7 @@ public class TestRedisUtil {
GalaxyUserInfoBo userInfoBo = GalaxyUserInfoBo.getNew();
userInfoBo.setUserId(userId);
String key = GalaxyConstant.REDIS_KET_GALAXY_USER.concat(GalaxyConstant.RouterTypeEnum.ZXINCHAIN.getCode()).concat(":") + userId;
String key = GalaxyConstant.REDIS_KET_GALAXY_USER.concat(GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode()).concat(":") + userId;
redisUtil.getRedisGalaxyUtil().set(key,userInfoBo,keyExpireTime);
}
}
liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/test/java/com/liquidnet/service/galaxy/TestZxinArtworkBiz.java
View file @ 3bbee149
package com.liquidnet.service.galaxy;
import com.liquidnet.service.galaxy.constant.GalaxyConstant;
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;
......@@ -32,7 +32,7 @@ public class TestZxinArtworkBiz {
GalaxyNftUploadReqDto nftUploadReqDto = GalaxyNftUploadReqDto.getNew();
nftUploadReqDto.setSkuId("video_test_001");
nftUploadReqDto.setOriginalNftUrl(oldUrl);
nftUploadReqDto.setRouteType(GalaxyConstant.RouterTypeEnum.ZXINCHAIN.getCode());
nftUploadReqDto.setRouterType(GalaxyEnum.RouterTypeEnum.ZXINCHAIN.getCode());
artworkBiz.nftUpload(nftUploadReqDto);
}
}
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