记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
董敬伟
liquidnet-bus-v1
Commits
28bf62c9
Commit
28bf62c9
authored
Jul 02, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'test'
parents
3eda2846
70f3e5a0
Changes
17
Hide whitespace changes
Inline
Side-by-side
Showing
17 changed files
with
148 additions
and
103 deletions
+148
-103
AdamRedisConst.java
...a/com/liquidnet/service/adam/constant/AdamRedisConst.java
+1
-0
AdamMemberAdminController.java
...b/controller/zhengzai/adam/AdamMemberAdminController.java
+0
-11
AdamSwitchAdminController.java
...b/controller/zhengzai/adam/AdamSwitchAdminController.java
+52
-0
LnsEnum.java
...ain/java/com/liquidnet/commons/lang/constant/LnsEnum.java
+13
-0
CurrentUtil.java
...ain/java/com/liquidnet/commons/lang/util/CurrentUtil.java
+5
-2
liquidnet-service-adam-dev.yml
...us-config/liquidnet-config/liquidnet-service-adam-dev.yml
+3
-0
liquidnet-service-adam-test.yml
...s-config/liquidnet-config/liquidnet-service-adam-test.yml
+3
-0
liquidnet-service-consumer-adam.yml
...nfig/liquidnet-config/liquidnet-service-consumer-adam.yml
+1
-1
liquidnet-service-consumer.yml
...us-config/liquidnet-config/liquidnet-service-consumer.yml
+10
-14
AdamLoginController.java
...iquidnet/service/adam/controller/AdamLoginController.java
+24
-7
AdamMemberOrderController.java
...et/service/adam/controller/AdamMemberOrderController.java
+2
-1
AdamUserController.java
...liquidnet/service/adam/controller/AdamUserController.java
+4
-2
pom.xml
liquidnet-bus-service/liquidnet-service-consumer/pom.xml
+4
-0
ServiceConsumerApplication.java
...ava/com/liquidnet/service/ServiceConsumerApplication.java
+0
-3
KylinUtils.java
.../liquidnet/service/consumer/service/Utils/KylinUtils.java
+21
-58
KylinStationController.java
...dnet/service/kylin/controller/KylinStationController.java
+3
-2
DataImpl.java
...quidnet/service/platform/service/impl/kylin/DataImpl.java
+2
-2
No files found.
liquidnet-bus-api/liquidnet-service-adam-api/src/main/java/com/liquidnet/service/adam/constant/AdamRedisConst.java
View file @
28bf62c9
...
...
@@ -38,6 +38,7 @@ public class AdamRedisConst {
public
static
final
String
SWITCH
=
ADAM
.
concat
(
"switch:"
);
public
static
final
String
SWITCH_BUY_MEMBER
=
SWITCH
.
concat
(
"buy:member"
);
public
static
final
String
SWITCH_GRAY_LOGIN_SMS
=
SWITCH
.
concat
(
"gray:login:sms"
);
/* ----------------------------------------------------------------- */
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/adam/AdamMemberAdminController.java
View file @
28bf62c9
...
...
@@ -103,15 +103,4 @@ public class AdamMemberAdminController {
}
return
ResponseDto
.
success
(
adamMemberCodeAdminService
.
createGiftCode
(
parameter
));
}
@RequiresPermissions
(
"adam:member:switch:buy"
)
@ApiOperation
(
value
=
"开放/限制购买会员"
)
@ApiImplicitParams
({
@ApiImplicitParam
(
type
=
"form"
,
required
=
true
,
dataType
=
"int"
,
name
=
"opt"
,
value
=
"0-限制|1-开放"
,
example
=
"0"
),
})
@PostMapping
(
"switch/buy"
)
public
ResponseDto
<
Object
>
purchaseSwitch
(
@Max
(
1
)
@Min
(
0
)
@RequestParam
int
opt
)
{
redisUtil
.
set
(
AdamRedisConst
.
SWITCH_BUY_MEMBER
,
opt
);
return
ResponseDto
.
success
(
redisUtil
.
get
(
AdamRedisConst
.
SWITCH_BUY_MEMBER
));
}
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/adam/AdamSwitchAdminController.java
0 → 100644
View file @
28bf62c9
package
com
.
liquidnet
.
client
.
admin
.
web
.
controller
.
zhengzai
.
adam
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.service.adam.constant.AdamRedisConst
;
import
com.liquidnet.service.base.ResponseDto
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiImplicitParam
;
import
io.swagger.annotations.ApiImplicitParams
;
import
io.swagger.annotations.ApiOperation
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.shiro.authz.annotation.RequiresPermissions
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RequestParam
;
import
org.springframework.web.bind.annotation.RestController
;
import
javax.validation.constraints.Max
;
import
javax.validation.constraints.Min
;
@Api
(
tags
=
"ADAM配置"
)
@Slf4j
@Validated
@RestController
@RequestMapping
(
"adam/switch"
)
public
class
AdamSwitchAdminController
{
@Autowired
RedisUtil
redisUtil
;
@RequiresPermissions
(
"adam:switch:buy:member"
)
@ApiOperation
(
value
=
"开放/限制购买会员"
)
@ApiImplicitParams
({
@ApiImplicitParam
(
type
=
"form"
,
required
=
true
,
dataType
=
"int"
,
name
=
"opt"
,
value
=
"0-限制|1-开放"
,
example
=
"0"
),
})
@PostMapping
(
"buy/member"
)
public
ResponseDto
<
Object
>
purchaseSwitch
(
@Max
(
1
)
@Min
(
0
)
@RequestParam
int
opt
)
{
redisUtil
.
set
(
AdamRedisConst
.
SWITCH_BUY_MEMBER
,
opt
);
return
ResponseDto
.
success
(
redisUtil
.
get
(
AdamRedisConst
.
SWITCH_BUY_MEMBER
));
}
@RequiresPermissions
(
"adam:switch:gray:login"
)
@ApiOperation
(
value
=
"开放/限制校验证码"
)
@ApiImplicitParams
({
@ApiImplicitParam
(
type
=
"form"
,
required
=
true
,
dataType
=
"int"
,
name
=
"opt"
,
value
=
"0-限制|1-开放"
,
example
=
"0"
),
})
@PostMapping
(
"gray/login"
)
public
ResponseDto
<
Object
>
loginSmsSwitch
(
@Max
(
1
)
@Min
(
0
)
@RequestParam
int
opt
)
{
redisUtil
.
set
(
AdamRedisConst
.
SWITCH_GRAY_LOGIN_SMS
,
0
==
opt
?
612543
:
615243
);
return
ResponseDto
.
success
(
redisUtil
.
get
(
AdamRedisConst
.
SWITCH_GRAY_LOGIN_SMS
));
}
}
liquidnet-bus-common/liquidnet-common-base/src/main/java/com/liquidnet/commons/lang/constant/LnsEnum.java
0 → 100644
View file @
28bf62c9
package
com
.
liquidnet
.
commons
.
lang
.
constant
;
public
final
class
LnsEnum
{
public
enum
ENV
{
dev
,
test
,
prod
;
}
public
static
void
main
(
String
[]
args
)
{
System
.
out
.
println
(
ENV
.
dev
.
name
());
}
}
liquidnet-bus-common/liquidnet-common-base/src/main/java/com/liquidnet/commons/lang/util/CurrentUtil.java
View file @
28bf62c9
...
...
@@ -3,11 +3,14 @@ package com.liquidnet.commons.lang.util;
import
org.apache.commons.lang3.StringUtils
;
import
javax.servlet.http.HttpServletRequest
;
import
java.net.InetAddress
;
import
java.net.UnknownHostException
;
import
java.util.Map
;
public
class
CurrentUtil
{
public
static
final
String
CK_ENV_ACTIVE
=
"spring.profiles.active"
;
public
static
final
String
GRAY_LOGIN_SMS_CODE
=
"111111"
;
/* ======================================================= | */
public
static
final
String
uID
=
"sub"
;
public
static
final
String
uTag
=
"u-tag"
;
public
static
final
String
uToken
=
"authorization"
;
...
...
liquidnet-bus-config/liquidnet-config/liquidnet-service-adam-dev.yml
View file @
28bf62c9
...
...
@@ -29,5 +29,8 @@ liquidnet:
aliyun
:
accessKeyId
:
LTAI4FvoqxJUT5T1ydJSyhUn
accessSecret
:
WNCgFn9dSjnoDdej2YTvR0v0216WWU
reviewer
:
app-login
:
mobile
:
13724286255
#以下为spring各环境个性配置
liquidnet-bus-config/liquidnet-config/liquidnet-service-adam-test.yml
View file @
28bf62c9
...
...
@@ -29,5 +29,8 @@ liquidnet:
aliyun
:
accessKeyId
:
LTAI4FvoqxJUT5T1ydJSyhUn
accessSecret
:
WNCgFn9dSjnoDdej2YTvR0v0216WWU
reviewer
:
app-login
:
mobile
:
13724286255
#以下为spring各环境个性配置
liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-adam.yml
View file @
28bf62c9
...
...
@@ -111,7 +111,7 @@ spring:
url
:
jdbc:mysql://${liquidnet.mysql.urlHostAndPort}/${liquidnet.mysql.database-name}?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&useSSL=false
username
:
${liquidnet.mysql.username}
password
:
${liquidnet.mysql.password}
# type: org.apache.tomcat.jdbc.pool.DataSource
# type: org.apache.tomcat.jdbc.pool.DataSource
driver-class-name
:
com.mysql.cj.jdbc.Driver
hikari
:
maximum-pool-size
:
16
...
...
liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer.yml
View file @
28bf62c9
...
...
@@ -101,26 +101,22 @@ spring:
codec
:
class
:
"
org.redisson.codec.JsonJacksonCodec"
transportMode
:
"
NIO"
data
:
mongodb
:
uri
:
mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}/?authSource=admin&maxPoolSize=2000&waitQueueMultiple=100
sslEnabled
:
${liquidnet.mongodb.sslEnabled}
database
:
${liquidnet.mongodb.database}
datasource
:
name
:
${liquidnet.mysql.database-name}
url
:
jdbc:mysql://${liquidnet.mysql.urlHostAndPort}/${liquidnet.mysql.database-name}?serverTimezone=UTC&characterEncoding=utf-8&useSSL=false
username
:
${liquidnet.mysql.username}
password
:
${liquidnet.mysql.password}
# type: org.apache.tomcat.jdbc.pool.DataSource
# type: org.apache.tomcat.jdbc.pool.DataSource
driver-class-name
:
com.mysql.cj.jdbc.Driver
filters
:
stat
maxActive
:
20
initialSize
:
1
maxWait
:
60000
minIdle
:
1
timeBetweenEvictionRunsMillis
:
60000
minEvictableIdleTimeMillis
:
300000
validationQuery
:
select 'x'
testWhileIdle
:
true
testOnBorrow
:
false
testOnReturn
:
false
poolPreparedStatements
:
true
maxOpenPreparedStatements
:
20
hikari
:
maximum-pool-size
:
45
minimum-idle
:
10
connection-test-query
:
SELECT 1
# -----------------------------------------------------------
# -----------------------------------------------------------
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamLoginController.java
View file @
28bf62c9
...
...
@@ -9,8 +9,10 @@ import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import
com.github.xiaoymin.knife4j.annotations.ApiSupport
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.common.cache.redisson.util.RedisLockUtil
;
import
com.liquidnet.commons.lang.constant.LnsEnum
;
import
com.liquidnet.commons.lang.core.JwtValidator
;
import
com.liquidnet.commons.lang.util.*
;
import
com.liquidnet.service.adam.constant.AdamRedisConst
;
import
com.liquidnet.service.adam.dto.AdamThirdPartParam
;
import
com.liquidnet.service.adam.dto.vo.AdamLoginInfoVo
;
import
com.liquidnet.service.adam.dto.vo.AdamUserInfoVo
;
...
...
@@ -26,6 +28,7 @@ import io.swagger.annotations.ApiOperation;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.core.env.Environment
;
import
org.springframework.util.CollectionUtils
;
import
org.springframework.util.DigestUtils
;
...
...
@@ -67,7 +70,8 @@ public class AdamLoginController {
@Autowired
IAdamUserService
adamUserService
;
@Value
(
"${liquidnet.reviewer.app-login.mobile}"
)
private
String
reviewMobile
;
private
static
final
String
PHP_API_SMS_CODE_SEND
=
"/smsCode"
;
private
static
final
String
PHP_API_SMS_CODE_VALID
=
"/smsValidation"
;
...
...
@@ -174,7 +178,7 @@ public class AdamLoginController {
loginInfoVo
.
setUserInfo
(
userInfoVo
);
loginInfoVo
.
setToken
(
this
.
ssoProcess
(
userInfoVo
));
loginInfoVo
.
getUserInfo
().
setMobile
(
SensitizeUtil
.
custom
(
userInfoVo
.
getMobile
(),
3
,
4
));
log
.
info
(
UserPathDto
.
setData
(
toRegister
?
"注册"
:
"登录"
,
ServletUtils
.
getRequest
().
getParameterMap
(),
loginInfoVo
));
log
.
info
(
UserPathDto
.
setData
(
toRegister
?
"注册"
:
"登录"
,
ServletUtils
.
getRequest
().
getParameterMap
(),
loginInfoVo
));
return
ResponseDto
.
success
(
loginInfoVo
);
}
...
...
@@ -212,7 +216,7 @@ public class AdamLoginController {
loginInfoVo
.
setUserInfo
(
userInfoVo
);
loginInfoVo
.
setToken
(
this
.
ssoProcess
(
userInfoVo
));
loginInfoVo
.
getUserInfo
().
setMobile
(
SensitizeUtil
.
custom
(
userInfoVo
.
getMobile
(),
3
,
4
));
log
.
info
(
UserPathDto
.
setData
(
toRegister
?
"注册"
:
"登录"
,
ServletUtils
.
getRequest
().
getParameterMap
(),
loginInfoVo
));
log
.
info
(
UserPathDto
.
setData
(
toRegister
?
"注册"
:
"登录"
,
ServletUtils
.
getRequest
().
getParameterMap
(),
loginInfoVo
));
return
ResponseDto
.
success
(
loginInfoVo
);
}
...
...
@@ -247,7 +251,7 @@ public class AdamLoginController {
}
loginInfoVo
.
setToken
(
this
.
ssoProcess
(
loginInfoVo
.
getUserInfo
()));
loginInfoVo
.
getUserInfo
().
setMobile
(
SensitizeUtil
.
custom
(
loginInfoVo
.
getUserInfo
().
getMobile
(),
3
,
4
));
log
.
info
(
UserPathDto
.
setData
(
toRegister
?
"注册"
:
"登录"
,
ServletUtils
.
getRequest
().
getParameterMap
(),
loginInfoVo
));
log
.
info
(
UserPathDto
.
setData
(
toRegister
?
"注册"
:
"登录"
,
ServletUtils
.
getRequest
().
getParameterMap
(),
loginInfoVo
));
return
ResponseDto
.
success
(
loginInfoVo
);
}
...
...
@@ -283,8 +287,22 @@ public class AdamLoginController {
/* ---------------------------- Internal Method ---------------------------- */
private
boolean
checkSmsCode
(
String
mobile
,
String
code
)
{
if
(
Arrays
.
asList
(
"dev"
,
"test"
,
"prod"
).
contains
(
env
.
getProperty
(
"spring.profiles.active"
))
&&
"111111"
.
equals
(
code
))
{
return
true
;
Integer
switchGrayLoginSms
=
(
Integer
)
redisUtil
.
get
(
AdamRedisConst
.
SWITCH_GRAY_LOGIN_SMS
);
if
(
null
!=
switchGrayLoginSms
)
{
if
(
switchGrayLoginSms
==
615243
)
{
if
(
CurrentUtil
.
GRAY_LOGIN_SMS_CODE
.
equals
(
code
))
{
return
true
;
}
}
if
(
switchGrayLoginSms
==
612543
)
{
if
(
reviewMobile
.
equals
(
mobile
)
||
Arrays
.
asList
(
LnsEnum
.
ENV
.
dev
.
name
(),
LnsEnum
.
ENV
.
test
.
name
()).
contains
(
env
.
getProperty
(
CurrentUtil
.
CK_ENV_ACTIVE
))
)
{
if
(
CurrentUtil
.
GRAY_LOGIN_SMS_CODE
.
equals
(
code
))
{
return
true
;
}
}
}
}
LinkedMultiValueMap
<
String
,
String
>
paramsMap
=
new
LinkedMultiValueMap
<>();
...
...
@@ -328,7 +346,6 @@ public class AdamLoginController {
private
String
ssoProcess
(
AdamUserInfoVo
userInfoVo
)
{
Map
<
String
,
Object
>
claimsMap
=
new
HashMap
<>();
claimsMap
.
put
(
"sub"
,
userInfoVo
.
getUid
());
// TODO: 2021/5/25 修改手机号更新TOKEN
claimsMap
.
put
(
"mobile"
,
userInfoVo
.
getMobile
());
claimsMap
.
put
(
"nickname"
,
userInfoVo
.
getNickname
());
claimsMap
.
put
(
"type"
,
"user"
);
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamMemberOrderController.java
View file @
28bf62c9
...
...
@@ -5,6 +5,7 @@ import com.github.pagehelper.PageInfo;
import
com.github.xiaoymin.knife4j.annotations.ApiOperationSupport
;
import
com.github.xiaoymin.knife4j.annotations.ApiSupport
;
import
com.liquidnet.common.cache.redisson.util.RedisLockUtil
;
import
com.liquidnet.commons.lang.constant.LnsEnum
;
import
com.liquidnet.commons.lang.util.CurrentUtil
;
import
com.liquidnet.commons.lang.util.HttpUtil
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
...
...
@@ -161,7 +162,7 @@ public class AdamMemberOrderController {
return
"fail"
;
}
if
(!
"dev"
.
equals
(
env
.
getProperty
(
"spring.profiles.active"
)))
{
if
(!
LnsEnum
.
ENV
.
dev
.
name
().
equals
(
env
.
getProperty
(
CurrentUtil
.
CK_ENV_ACTIVE
)))
{
ResponseDto
<
Integer
>
checkOrderResult
=
this
.
checkOrderResult
(
parameter
.
getOrderCode
());
if
(!
checkOrderResult
.
isSuccess
()
||
checkOrderResult
.
getData
()
!=
1
)
{
log
.
warn
(
"###购买会员支付回调支付中心验证不通过,无法处理[{}]"
,
JsonUtils
.
toJson
(
parameter
));
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamUserController.java
View file @
28bf62c9
...
...
@@ -2,6 +2,7 @@ package com.liquidnet.service.adam.controller;
import
com.github.xiaoymin.knife4j.annotations.ApiOperationSupport
;
import
com.github.xiaoymin.knife4j.annotations.ApiSupport
;
import
com.liquidnet.commons.lang.constant.LnsEnum
;
import
com.liquidnet.commons.lang.constant.LnsRegex
;
import
com.liquidnet.commons.lang.util.CurrentUtil
;
import
com.liquidnet.commons.lang.util.HttpUtil
;
...
...
@@ -304,8 +305,9 @@ public class AdamUserController {
private
static
final
String
PHP_API_SMS_CODE_VALID
=
"/smsValidation"
;
private
boolean
checkSmsCode
(
String
mobile
,
String
code
)
{
if
(
Arrays
.
asList
(
"dev"
,
"test"
,
"prod"
).
contains
(
env
.
getProperty
(
"spring.profiles.active"
)))
{
return
"111111"
.
equals
(
code
);
if
(
Arrays
.
asList
(
LnsEnum
.
ENV
.
dev
.
name
(),
LnsEnum
.
ENV
.
test
.
name
()).
contains
(
env
.
getProperty
(
CurrentUtil
.
CK_ENV_ACTIVE
))
&&
CurrentUtil
.
GRAY_LOGIN_SMS_CODE
.
equals
(
code
))
{
return
true
;
}
LinkedMultiValueMap
<
String
,
String
>
paramsMap
=
new
LinkedMultiValueMap
<>();
...
...
liquidnet-bus-service/liquidnet-service-consumer/pom.xml
View file @
28bf62c9
...
...
@@ -41,6 +41,10 @@
<artifactId>
liquidnet-service-kylin-api
</artifactId>
<version>
1.0-SNAPSHOT
</version>
</dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-data-mongodb
</artifactId>
</dependency>
</dependencies>
<build>
...
...
liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/ServiceConsumerApplication.java
View file @
28bf62c9
...
...
@@ -20,9 +20,6 @@ import java.net.UnknownHostException;
import
java.util.Arrays
;
@Slf4j
@EnableAutoConfiguration
(
exclude
=
{
BusAutoConfiguration
.
class
,
MongoAutoConfiguration
.
class
}
)
@SpringBootApplication
(
scanBasePackages
=
{
"com.liquidnet"
})
public
class
ServiceConsumerApplication
implements
CommandLineRunner
{
@Autowired
...
...
liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/Utils/KylinUtils.java
View file @
28bf62c9
...
...
@@ -9,6 +9,9 @@ import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
import
com.liquidnet.service.kylin.dto.vo.returns.KylinOrderListVo
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Query
;
import
org.springframework.stereotype.Component
;
import
java.util.ArrayList
;
...
...
@@ -20,6 +23,8 @@ public class KylinUtils {
@Autowired
private
RedisUtil
redisUtil
;
@Autowired
private
MongoTemplate
mongoTemplate
;
/**
* @param userId 用户id
...
...
@@ -30,12 +35,7 @@ public class KylinUtils {
List
<
KylinOrderListVo
>
vo
=
new
ArrayList
<>();
List
<
KylinOrderListVo
>
redisVo
=
new
ArrayList
();
KylinOrderListVo
voItem
=
new
KylinOrderListVo
();
KylinOrderTicketVo
data
;
if
(
dataSingle
==
null
)
{
data
=
(
KylinOrderTicketVo
)
redisUtil
.
get
(
KylinRedisConst
.
ORDER
+
orderId
);
}
else
{
data
=
dataSingle
;
}
KylinOrderTicketVo
data
=
dataSingle
;
BeanUtils
.
copyProperties
(
data
,
voItem
);
List
<
KylinOrderListVo
>
redisData
=
(
List
<
KylinOrderListVo
>)
redisUtil
.
get
(
KylinRedisConst
.
ORDER_LIST
+
userId
);
if
(
type
==
1
)
{
...
...
@@ -86,7 +86,7 @@ public class KylinUtils {
public
void
changeBuyInfo
(
String
userId
,
String
idCard
,
String
performanceId
,
String
ticketId
,
int
buyCount
)
{
String
redisKey
;
KylinPerformanceVo
vo
=
(
KylinPerformanceVo
)
redisUtil
.
get
(
KylinRedisConst
.
PERFORMANCES
+
performanceId
);
KylinPerformanceVo
vo
=
getPerformanceVo
(
performanceId
);
int
isTrueName
=
vo
.
getIsTrueName
();
String
useTime
=
""
;
HashMap
<
String
,
ArrayList
<
String
>>
allTicketId
=
new
HashMap
<>();
...
...
@@ -123,57 +123,20 @@ public class KylinUtils {
redisUtil
.
decr
(
ticketIdKey
,
Math
.
abs
(
buyCount
));
redisUtil
.
decr
(
performanceIdKey
,
Math
.
abs
(
buyCount
));
}
}
// if (buyCount > 0) {
// redisUtil.incr(ticketIdKey, buyCount);
// if (1 == ticketType) {
// int count = 0;
// for (int i = 0; i < allTicketId.get(useTime).size(); i++) {
// String item = allTicketId.get(useTime).get(i);
// if (allTicketId.get(useTime).size() == 1) {
// redisUtil.incr(performanceIdKey, buyCount);
// break;
// }
// if (null == redisUtil.get(redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + item)) {
// redisUtil.set(redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + item, 0);
// }
// if (i == 0) {
// count = (int) redisUtil.get(redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + item);
// } else {
// if (count != (int) redisUtil.get(redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + item)) {
// redisUtil.incr(performanceIdKey, buyCount);
// break;
// }
// }
// }
// } else {
// redisUtil.incr(performanceIdKey, buyCount);
// }
// } else {
// redisUtil.decr(ticketIdKey, Math.abs(buyCount));
// if (1 == ticketType) {
// int count = 0;
// for (int i = 0; i < allTicketId.get(useTime).size(); i++) {
// String item = allTicketId.get(useTime).get(i);
// if (allTicketId.get(useTime).size() == 1) {
// redisUtil.decr(performanceIdKey, Math.abs(buyCount));
// break;
// }
// if (null == redisUtil.get(redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + item)) {
// redisUtil.set(redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + item, 0);
// }
// if (i == 0) {
// count = (int) redisUtil.get(redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + item);
// } else {
// if (count != (int) redisUtil.get(redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + item)) {
// redisUtil.decr(performanceIdKey, Math.abs(buyCount));
// break;
// }
// }
// }
// } else {
// redisUtil.decr(performanceIdKey, Math.abs(buyCount));
// }
// }
/**
* 根据演出id 获取 演出vo 详情
*
* @param performanceId
* @return
*/
public
KylinPerformanceVo
getPerformanceVo
(
String
performanceId
)
{
if
(
redisUtil
.
hasKey
(
KylinRedisConst
.
PERFORMANCES
+
performanceId
))
{
}
else
{
KylinPerformanceVo
performanceData
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"performancesId"
).
is
(
performanceId
)),
KylinPerformanceVo
.
class
,
KylinPerformanceVo
.
class
.
getSimpleName
());
redisUtil
.
set
(
KylinRedisConst
.
PERFORMANCES
+
performanceId
,
performanceData
);
}
return
(
KylinPerformanceVo
)
redisUtil
.
get
(
KylinRedisConst
.
PERFORMANCES
+
performanceId
);
}
}
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/KylinStationController.java
View file @
28bf62c9
...
...
@@ -2,6 +2,7 @@ package com.liquidnet.service.kylin.controller;
import
com.github.pagehelper.PageInfo
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.commons.lang.constant.LnsEnum
;
import
com.liquidnet.commons.lang.constant.LnsRegex
;
import
com.liquidnet.commons.lang.core.JwtValidator
;
import
com.liquidnet.commons.lang.util.*
;
...
...
@@ -483,8 +484,8 @@ public class KylinStationController {
}
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20602"
));
}
else
{
// 校验验证码
if
(
Arrays
.
asList
(
"dev"
,
"test"
).
contains
(
environment
.
getProperty
(
"spring.profiles.active"
)))
{
if
(
"111111"
.
equals
(
identity
))
{
if
(
Arrays
.
asList
(
LnsEnum
.
ENV
.
dev
.
name
(),
LnsEnum
.
ENV
.
test
.
name
()).
contains
(
environment
.
getProperty
(
CurrentUtil
.
CK_ENV_ACTIVE
)))
{
if
(
CurrentUtil
.
GRAY_LOGIN_SMS_CODE
.
equals
(
identity
))
{
return
this
.
loginAuthentication
(
checkUserVo
);
}
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20002"
));
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java
View file @
28bf62c9
...
...
@@ -307,7 +307,7 @@ public class DataImpl {
tickets
.
setPriceExpress
(
ticketData
.
getBigDecimal
(
"price_express"
));
tickets
.
setPriceDiscountMember
(
new
BigDecimal
(
"0.00"
));
tickets
.
setPriceDiscount
(
new
BigDecimal
(
"0.00"
));
tickets
.
setDescribes
(
ticketData
.
getString
(
"describe
_express
"
));
tickets
.
setDescribes
(
ticketData
.
getString
(
"describe"
));
tickets
.
setDescribeExpress
(
ticketData
.
getString
(
"describe_express"
));
tickets
.
setDescribeElectronic
(
ticketData
.
getString
(
"describe_electronic"
));
tickets
.
setAdvanceMinuteMember
(
5
);
...
...
@@ -345,7 +345,7 @@ public class DataImpl {
ticketStatus
.
setSurplusExchange
(
ticketData
.
getInt
(
"surplus_exchange"
));
ticketStatus
.
setExpressType
(
ticketData
.
getInt
(
"express_type"
));
ticketStatus
.
setIsTrueName
(
ticketData
.
getString
(
"need_id_card"
).
equals
(
"yes"
)
?
1
:
0
);
ticketStatus
.
setLimitCount
(
0
);
ticketStatus
.
setLimitCount
(
ticketData
.
getInt
(
"num_limit_mobile"
)
);
ticketStatus
.
setMemberLimitCount
(
1
);
ticketStatus
.
setIsTransfer
(
0
);
ticketStatus
.
setIsExclusive
(
ticketData
.
getInt
(
"is_exclusive"
));
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment