记得上下班打卡 | 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
92572e0a
Commit
92572e0a
authored
Sep 18, 2021
by
anjiabin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
提交chime配置
parent
413b943c
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
120 additions
and
3 deletions
+120
-3
FeignKylinForChimeClient.java
...net/service/feign/kylin/api/FeignKylinForChimeClient.java
+57
-0
SecuringRequestInterceptor.java
...ervice/feign/kylin/config/SecuringRequestInterceptor.java
+37
-0
KylinMyPerformancesController.java
...rvice/kylin/controller/KylinMyPerformancesController.java
+26
-3
No files found.
liquidnet-bus-feign/liquidnet-api-feign-kylin/src/main/java/com/liquidnet/service/feign/kylin/api/FeignKylinForChimeClient.java
0 → 100644
View file @
92572e0a
package
com
.
liquidnet
.
service
.
feign
.
kylin
.
api
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.feign.kylin.config.SecuringRequestInterceptor
;
import
com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo
;
import
feign.hystrix.FallbackFactory
;
import
org.springframework.cloud.openfeign.FeignClient
;
import
org.springframework.stereotype.Component
;
import
org.springframework.web.bind.annotation.GetMapping
;
import
org.springframework.web.bind.annotation.RequestParam
;
import
java.util.HashMap
;
import
java.util.List
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: FeignKylinForChimeClient
* @Package com.liquidnet.service.feign.kylin.api
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/11 18:20
*/
@Component
@FeignClient
(
name
=
"liquidnet-service-kylin"
,
contextId
=
"FeignKylinForChimeClient"
,
path
=
""
,
url
=
"${liquidnet.service.kylin.url}"
,
fallback
=
FallbackFactory
.
Default
.
class
,
configuration
=
SecuringRequestInterceptor
.
class
)
public
interface
FeignKylinForChimeClient
{
@GetMapping
(
"myPerformance/performancesList"
)
ResponseDto
<
List
<
KylinPerformanceVo
>>
myPerformancesList
();
@GetMapping
(
"performance/localList"
)
ResponseDto
<
HashMap
<
String
,
Object
>>
localList
(
@RequestParam
(
value
=
"cityName"
,
defaultValue
=
""
)
String
cityName
,
@RequestParam
(
value
=
"days"
,
defaultValue
=
"0"
)
int
days
,
@RequestParam
(
value
=
"type"
,
defaultValue
=
"0"
)
int
type
,
@RequestParam
(
value
=
"isDiscount"
,
defaultValue
=
""
)
Integer
isDiscount
,
@RequestParam
(
value
=
"isAdvance"
,
defaultValue
=
""
)
Integer
isAdvance
,
@RequestParam
(
value
=
"isExclusive"
,
defaultValue
=
""
)
Integer
isExclusive
,
// 排序
@RequestParam
(
value
=
"orderBy"
,
defaultValue
=
""
)
String
orderBy
,
@RequestParam
(
value
=
"sort"
,
defaultValue
=
""
)
String
sort
);
// @GetMapping(value = "/performance/list")
// ResponseDto<List<KylinPerformanceVo>> performanceList(@RequestParam("performancesIds") String... performancesIds);
@GetMapping
(
"myPerformance/getDetail"
)
ResponseDto
<
KylinPerformanceVo
>
getDetail
(
@RequestParam
(
"performancesId"
)
String
performancesId
);
}
liquidnet-bus-feign/liquidnet-api-feign-kylin/src/main/java/com/liquidnet/service/feign/kylin/config/SecuringRequestInterceptor.java
0 → 100644
View file @
92572e0a
package
com
.
liquidnet
.
service
.
feign
.
kylin
.
config
;
import
feign.RequestInterceptor
;
import
feign.RequestTemplate
;
import
org.springframework.stereotype.Component
;
import
org.springframework.web.context.request.RequestContextHolder
;
import
org.springframework.web.context.request.ServletRequestAttributes
;
import
javax.servlet.http.HttpServletRequest
;
import
java.util.Enumeration
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: 解决feign调用传递header问题
* @class: SecuringRequestInterceptor
* @Package com.liquidnet.service.chime.config
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/11 19:22
*/
@Component
public
class
SecuringRequestInterceptor
implements
RequestInterceptor
{
@Override
public
void
apply
(
RequestTemplate
requestTemplate
)
{
ServletRequestAttributes
attributes
=
(
ServletRequestAttributes
)
RequestContextHolder
.
getRequestAttributes
();
HttpServletRequest
request
=
attributes
.
getRequest
();
Enumeration
<
String
>
headerNames
=
request
.
getHeaderNames
();
if
(
headerNames
!=
null
)
{
while
(
headerNames
.
hasMoreElements
())
{
String
name
=
headerNames
.
nextElement
();
String
values
=
request
.
getHeader
(
name
);
requestTemplate
.
header
(
name
,
values
);
}
}
}
}
\ No newline at end of file
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/KylinMyPerformancesController.java
View file @
92572e0a
package
com
.
liquidnet
.
service
.
kylin
.
controller
;
import
com.liquidnet.service.base.ErrorMapping
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo
;
import
com.liquidnet.service.kylin.service.impl.KylinPerformancesServiceImpl
;
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.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.GetMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RestController
;
import
org.springframework.web.bind.annotation.*
;
import
java.util.List
;
...
...
@@ -36,4 +37,26 @@ public class KylinMyPerformancesController {
List
<
KylinPerformanceVo
>
result
=
kylinPerformancesService
.
myPerformancesList
();
return
ResponseDto
.
success
(
result
);
}
@GetMapping
(
"getDetail"
)
@ApiOperation
(
"演出详情"
)
@ApiImplicitParams
({
@ApiImplicitParam
(
type
=
"path"
,
dataType
=
"String"
,
name
=
"performancesId"
,
value
=
"演出id"
,
required
=
true
)
})
public
ResponseDto
<
KylinPerformanceVo
>
getDetail
(
@RequestParam
(
"performancesId"
)
String
performancesId
)
{
try
{
KylinPerformanceVo
result
=
kylinPerformancesService
.
detail
(
performancesId
,
0
,
0
,
"0"
);
if
(
result
!=
null
)
{
return
ResponseDto
.
success
(
result
);
}
else
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20700"
));
}
}
catch
(
Exception
e
)
{
log
.
error
(
"演出详情Error"
,
e
);
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20700"
));
}
}
}
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