记得上下班打卡 | 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
1d7e0f04
Commit
1d7e0f04
authored
Mar 07, 2022
by
张国柄
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
+API:服务内部调用入场人、会员信息查询;
parent
5fbee84f
Changes
5
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
46 additions
and
14 deletions
+46
-14
FeignAdamBaseClient.java
...liquidnet/service/feign/adam/api/FeignAdamBaseClient.java
+27
-5
AdamEntersController.java
...quidnet/service/adam/controller/AdamEntersController.java
+3
-2
AdamMemberController.java
...quidnet/service/adam/controller/AdamMemberController.java
+1
-1
AdamRscController.java
.../liquidnet/service/adam/controller/AdamRscController.java
+12
-3
AdamRdmService.java
...va/com/liquidnet/service/adam/service/AdamRdmService.java
+3
-3
No files found.
liquidnet-bus-feign/liquidnet-api-feign-adam/src/main/java/com/liquidnet/service/feign/adam/api/FeignAdamBaseClient.java
View file @
1d7e0f04
...
@@ -7,6 +7,7 @@ import com.liquidnet.service.adam.dto.vo.AdamAddressesVo;
...
@@ -7,6 +7,7 @@ import com.liquidnet.service.adam.dto.vo.AdamAddressesVo;
import
com.liquidnet.service.adam.dto.vo.AdamEntersVo
;
import
com.liquidnet.service.adam.dto.vo.AdamEntersVo
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.base.ResponseDto
;
import
feign.hystrix.FallbackFactory
;
import
feign.hystrix.FallbackFactory
;
import
io.swagger.annotations.ApiOperation
;
import
org.springframework.cloud.openfeign.FeignClient
;
import
org.springframework.cloud.openfeign.FeignClient
;
import
org.springframework.stereotype.Component
;
import
org.springframework.stereotype.Component
;
import
org.springframework.web.bind.annotation.GetMapping
;
import
org.springframework.web.bind.annotation.GetMapping
;
...
@@ -25,6 +26,9 @@ import java.util.List;
...
@@ -25,6 +26,9 @@ import java.util.List;
fallback
=
FallbackFactory
.
Default
.
class
)
fallback
=
FallbackFactory
.
Default
.
class
)
public
interface
FeignAdamBaseClient
{
public
interface
FeignAdamBaseClient
{
/**
* 不推荐使用,建议使用`rsc/inquire/enters`
*/
@GetMapping
(
"enters/query/depth"
)
@GetMapping
(
"enters/query/depth"
)
ResponseDto
<
AdamEntersVo
>
queryEnters
(
@RequestParam
(
"entersId"
)
String
entersId
,
ResponseDto
<
AdamEntersVo
>
queryEnters
(
@RequestParam
(
"entersId"
)
String
entersId
,
@RequestParam
(
"uid"
)
String
uid
);
@RequestParam
(
"uid"
)
String
uid
);
...
@@ -33,22 +37,40 @@ public interface FeignAdamBaseClient {
...
@@ -33,22 +37,40 @@ public interface FeignAdamBaseClient {
ResponseDto
<
AdamAddressesVo
>
queryAddresses
(
@RequestParam
(
value
=
"addrId"
)
String
addrId
,
ResponseDto
<
AdamAddressesVo
>
queryAddresses
(
@RequestParam
(
value
=
"addrId"
)
String
addrId
,
@RequestParam
(
value
=
"uid"
)
String
uid
);
@RequestParam
(
value
=
"uid"
)
String
uid
);
/* -------------------------------------------------------------------- */
@PostMapping
(
"rsc/inquire/cuinfo"
)
@PostMapping
(
"rsc/inquire/cuinfo"
)
ResponseDto
<
List
<
AdamChimeUinfoDto
>>
queryForChimeUserInfo
(
@RequestBody
AdamChimeUinfoReq
req
);
ResponseDto
<
List
<
AdamChimeUinfoDto
>>
queryForChimeUserInfo
(
@RequestBody
AdamChimeUinfoReq
req
);
@PostMapping
(
"rsc/inquire/sendMsgToRedis"
)
@PostMapping
(
"rsc/inquire/sendMsgToRedis"
)
ResponseDto
<
Boolean
>
sendMsgToRedis
(
@RequestParam
(
"redisKey"
)
String
redisKey
,
@RequestParam
(
"jsonParamStr"
)
String
jsonParamStr
);
ResponseDto
<
Boolean
>
sendMsgToRedis
(
@RequestParam
(
"redisKey"
)
String
redisKey
,
@RequestParam
(
"jsonParamStr"
)
String
jsonParamStr
);
@PostMapping
(
value
=
{
"rsc/reg/mobile"
})
@PostMapping
(
value
=
{
"rsc/reg/mobile"
})
ResponseDto
<
AdamUserInfoVo
>
registerByMobile
(
@Pattern
(
regexp
=
"\\d{11}"
,
message
=
"手机号格式有误"
)
ResponseDto
<
AdamUserInfoVo
>
registerByMobile
(
@Pattern
(
regexp
=
"\\d{11}"
,
message
=
"手机号格式有误"
)
@RequestParam
(
value
=
"mobile"
)
String
mobile
);
@RequestParam
(
value
=
"mobile"
)
String
mobile
);
/**
* 入场人信息查取
*
* @param entersIds List<String>:入场人ID集合
* @param uid 用户ID
* @return ResponseDto<List < AdamEntersVo>>
*/
@GetMapping
(
"rsc/inquire/enters"
)
ResponseDto
<
List
<
AdamEntersVo
>>
querysEnters
(
@NotBlank
(
message
=
"入场人ID不能为空(多个ID以,分隔)"
)
@RequestParam
List
<
String
>
entersIds
,
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
);
@GetMapping
(
"rsc/inquire/member"
)
ResponseDto
<
AdamUserMemberVo
>
queryMember
(
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
);
/* -------------------------------------------------------------------- */
@PostMapping
(
value
=
{
"login/silent_mobile"
})
@PostMapping
(
value
=
{
"login/silent_mobile"
})
ResponseDto
<
AdamLoginInfoVo
>
loginBySilentMobile
(
@Pattern
(
regexp
=
"\\d{11}"
,
message
=
"手机号格式有误"
)
ResponseDto
<
AdamLoginInfoVo
>
loginBySilentMobile
(
@Pattern
(
regexp
=
"\\d{11}"
,
message
=
"手机号格式有误"
)
@NotBlank
(
message
=
"手机号不能为空"
)
@NotBlank
(
message
=
"手机号不能为空"
)
@RequestParam
(
value
=
"mobile"
)
String
mobile
,
@RequestParam
(
value
=
"mobile"
)
String
mobile
,
@NotBlank
(
message
=
"临时票据不能为空"
)
@NotBlank
(
message
=
"临时票据不能为空"
)
@RequestParam
(
value
=
"otp"
)
String
otp
);
@RequestParam
(
value
=
"otp"
)
String
otp
);
@GetMapping
(
value
=
"member/check/depth"
,
headers
=
{
"Inner-Required=1"
})
@GetMapping
(
value
=
"member/check/depth"
,
headers
=
{
"Inner-Required=1"
})
ResponseDto
<
Boolean
>
isMember
(
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
(
value
=
"uid"
)
String
uid
);
ResponseDto
<
Boolean
>
isMember
(
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
(
value
=
"uid"
)
String
uid
);
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamEntersController.java
View file @
1d7e0f04
...
@@ -24,6 +24,7 @@ import org.springframework.web.bind.annotation.*;
...
@@ -24,6 +24,7 @@ import org.springframework.web.bind.annotation.*;
import
javax.validation.Valid
;
import
javax.validation.Valid
;
import
javax.validation.constraints.NotBlank
;
import
javax.validation.constraints.NotBlank
;
import
java.util.Arrays
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Optional
;
import
java.util.Optional
;
import
java.util.regex.Pattern
;
import
java.util.regex.Pattern
;
...
@@ -204,7 +205,7 @@ public class AdamEntersController {
...
@@ -204,7 +205,7 @@ public class AdamEntersController {
@ApiOperation
(
value
=
"入场人详情"
)
@ApiOperation
(
value
=
"入场人详情"
)
@PostMapping
(
"query"
)
@PostMapping
(
"query"
)
public
ResponseDto
<
List
<
AdamEntersVo
>>
query
(
@NotBlank
(
message
=
"入场人ID不能为空"
)
@RequestParam
String
entersIds
)
{
public
ResponseDto
<
List
<
AdamEntersVo
>>
query
(
@NotBlank
(
message
=
"入场人ID不能为空"
)
@RequestParam
String
entersIds
)
{
List
<
AdamEntersVo
>
vos
=
adamRdmService
.
getEntersVoByUidEntersIds
(
CurrentUtil
.
getCurrentUid
(),
entersIds
.
split
(
","
));
List
<
AdamEntersVo
>
vos
=
adamRdmService
.
getEntersVoByUidEntersIds
(
CurrentUtil
.
getCurrentUid
(),
Arrays
.
asList
(
entersIds
.
split
(
","
)
));
if
(!
CollectionUtils
.
isEmpty
(
vos
))
{
if
(!
CollectionUtils
.
isEmpty
(
vos
))
{
for
(
AdamEntersVo
vo
:
vos
)
{
for
(
AdamEntersVo
vo
:
vos
)
{
vo
.
setName
(
SensitizeUtil
.
chineseName
(
vo
.
getName
()));
vo
.
setName
(
SensitizeUtil
.
chineseName
(
vo
.
getName
()));
...
@@ -231,7 +232,7 @@ public class AdamEntersController {
...
@@ -231,7 +232,7 @@ public class AdamEntersController {
/* ------------------------------------------------------------|@API:RSC */
/* ------------------------------------------------------------|@API:RSC */
@ApiOperationSupport
(
order
=
99
)
@ApiOperationSupport
(
order
=
99
)
@ApiOperation
(
value
=
"
@API:入场人详情"
,
notes
=
"查取用户指定入场人详情,响应说明[`success`: true-成功返回信息,false-未查询到信息]
"
)
@ApiOperation
(
value
=
"
不推荐使用@API:入场人详情"
,
notes
=
"不推荐使用,建议使用`rsc/inquire/enters`
"
)
@GetMapping
(
"query/depth"
)
@GetMapping
(
"query/depth"
)
public
ResponseDto
<
AdamEntersVo
>
queryForDepth
(
@NotBlank
(
message
=
"入场人ID不能为空"
)
@RequestParam
String
entersId
,
public
ResponseDto
<
AdamEntersVo
>
queryForDepth
(
@NotBlank
(
message
=
"入场人ID不能为空"
)
@RequestParam
String
entersId
,
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
)
{
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
)
{
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamMemberController.java
View file @
1d7e0f04
...
@@ -175,7 +175,7 @@ public class AdamMemberController {
...
@@ -175,7 +175,7 @@ public class AdamMemberController {
}
}
@ApiOperationSupport
(
order
=
98
)
@ApiOperationSupport
(
order
=
98
)
@ApiOperation
(
value
=
"
@API:是否会员[新老]"
,
notes
=
"AdamUserMemberVo
"
)
@ApiOperation
(
value
=
"
不推荐使用@API:是否会员[新老]"
,
notes
=
"不推荐使用,建议使用`rsc/inquire/member`
"
)
@GetMapping
(
"check/depth/new"
)
@GetMapping
(
"check/depth/new"
)
public
ResponseDto
<
AdamUserMemberVo
>
isMemberNew
(
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
)
{
public
ResponseDto
<
AdamUserMemberVo
>
isMemberNew
(
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
)
{
AdamUserMemberVo
userMemberInfo
=
adamRdmService
.
getUserMemberVoByUid
(
uid
);
AdamUserMemberVo
userMemberInfo
=
adamRdmService
.
getUserMemberVoByUid
(
uid
);
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamRscController.java
View file @
1d7e0f04
...
@@ -24,8 +24,10 @@ import org.springframework.validation.annotation.Validated;
...
@@ -24,8 +24,10 @@ import org.springframework.validation.annotation.Validated;
import
org.springframework.web.bind.annotation.*
;
import
org.springframework.web.bind.annotation.*
;
import
javax.validation.constraints.NotBlank
;
import
javax.validation.constraints.NotBlank
;
import
javax.validation.constraints.NotNull
;
import
javax.validation.constraints.Pattern
;
import
javax.validation.constraints.Pattern
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.Arrays
;
import
java.util.List
;
import
java.util.List
;
@ApiSupport
(
order
=
10080
)
@ApiSupport
(
order
=
10080
)
...
@@ -67,12 +69,19 @@ public class AdamRscController {
...
@@ -67,12 +69,19 @@ public class AdamRscController {
@ApiOperationSupport
(
order
=
20
)
@ApiOperationSupport
(
order
=
20
)
@ApiOperation
(
value
=
"@API:入场人列表"
,
notes
=
"查取用户指定入场人列表"
)
@ApiOperation
(
value
=
"@API:入场人列表"
,
notes
=
"查取用户指定入场人列表"
)
@GetMapping
(
"inquire/enters"
)
@GetMapping
(
"inquire/enters"
)
public
ResponseDto
<
List
<
AdamEntersVo
>>
querys
ForDepth
(
@NotBlank
(
message
=
"入场人ID不能为空(多个ID以,分隔)"
)
@RequestParam
String
entersIds
,
public
ResponseDto
<
List
<
AdamEntersVo
>>
querys
Enters
(
@NotNull
(
message
=
"入场人ID不能为空"
)
@RequestParam
List
<
String
>
entersIds
,
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
)
{
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
)
{
List
<
AdamEntersVo
>
vos
=
adamRdmService
.
getEntersVoByUidEntersIds
(
uid
,
entersIds
.
split
(
","
)
);
List
<
AdamEntersVo
>
vos
=
entersIds
.
isEmpty
()
?
null
:
adamRdmService
.
getEntersVoByUidEntersIds
(
uid
,
entersIds
);
return
CollectionUtils
.
isEmpty
(
vos
)
?
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"10105"
))
:
ResponseDto
.
success
(
vos
);
return
CollectionUtils
.
isEmpty
(
vos
)
?
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"10105"
))
:
ResponseDto
.
success
(
vos
);
}
}
@ApiOperationSupport
(
order
=
21
)
@ApiOperation
(
value
=
"@API:会员信息[新老]"
,
notes
=
"AdamUserMemberVo"
)
@GetMapping
(
"inquire/member"
)
public
ResponseDto
<
AdamUserMemberVo
>
queryMember
(
@NotBlank
(
message
=
"用户ID不能为空"
)
@RequestParam
String
uid
)
{
return
ResponseDto
.
success
(
adamRdmService
.
getUserMemberVoByUid
(
uid
));
}
@ApiOperationSupport
(
order
=
30
)
@ApiOperationSupport
(
order
=
30
)
@ApiOperation
(
value
=
"@API:票务下单所需信息查询"
,
notes
=
"包括是否会员、收货地址及入场人信息"
)
@ApiOperation
(
value
=
"@API:票务下单所需信息查询"
,
notes
=
"包括是否会员、收货地址及入场人信息"
)
@PostMapping
(
"inquire/of_buy_ticket"
)
@PostMapping
(
"inquire/of_buy_ticket"
)
...
@@ -92,7 +101,7 @@ public class AdamRscController {
...
@@ -92,7 +101,7 @@ public class AdamRscController {
}
}
if
(!
StringUtils
.
isEmpty
(
entersIds
))
{
if
(!
StringUtils
.
isEmpty
(
entersIds
))
{
List
<
AdamEntersVo
>
entersVos
=
adamRdmService
.
getEntersVoByUidEntersIds
(
uid
,
entersIds
.
split
(
","
));
List
<
AdamEntersVo
>
entersVos
=
adamRdmService
.
getEntersVoByUidEntersIds
(
uid
,
Arrays
.
asList
(
entersIds
.
split
(
","
)
));
vo
.
setEntersVos
(
entersVos
);
vo
.
setEntersVos
(
entersVos
);
}
}
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/AdamRdmService.java
View file @
1d7e0f04
...
@@ -384,10 +384,10 @@ public class AdamRdmService {
...
@@ -384,10 +384,10 @@ public class AdamRdmService {
return
CollectionUtils
.
isEmpty
(
vos
)
?
null
:
vos
.
stream
().
filter
(
r
->
r
.
getEntersId
().
equals
(
entersId
)).
findAny
().
orElse
(
null
);
return
CollectionUtils
.
isEmpty
(
vos
)
?
null
:
vos
.
stream
().
filter
(
r
->
r
.
getEntersId
().
equals
(
entersId
)).
findAny
().
orElse
(
null
);
}
}
public
List
<
AdamEntersVo
>
getEntersVoByUidEntersIds
(
String
uid
,
String
...
entersIds
)
{
public
List
<
AdamEntersVo
>
getEntersVoByUidEntersIds
(
String
uid
,
List
<
String
>
entersIds
)
{
List
<
String
>
entersIdList
=
Arrays
.
asList
(
entersIds
);
//
List<String> entersIdList = Arrays.asList(entersIds);
List
<
AdamEntersVo
>
vos
=
this
.
getEntersVoByUid
(
uid
);
List
<
AdamEntersVo
>
vos
=
this
.
getEntersVoByUid
(
uid
);
return
CollectionUtils
.
isEmpty
(
vos
)
?
null
:
vos
.
stream
().
filter
(
r
->
entersId
List
.
contains
(
r
.
getEntersId
())).
collect
(
Collectors
.
toList
());
return
CollectionUtils
.
isEmpty
(
vos
)
?
null
:
vos
.
stream
().
filter
(
r
->
entersId
s
.
contains
(
r
.
getEntersId
())).
collect
(
Collectors
.
toList
());
}
}
public
void
delEntersVoByUid
(
String
uid
)
{
public
void
delEntersVoByUid
(
String
uid
)
{
...
...
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