记得上下班打卡 | 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
b37193c0
Commit
b37193c0
authored
Jul 02, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/dev' into dev
parents
f53bfc25
384a6b05
Changes
14
Hide whitespace changes
Inline
Side-by-side
Showing
14 changed files
with
161 additions
and
30 deletions
+161
-30
KylinRedisConst.java
...com/liquidnet/service/kylin/constant/KylinRedisConst.java
+2
-2
KylinTableStatusConst.java
...quidnet/service/kylin/constant/KylinTableStatusConst.java
+1
-1
KylinOrderExpressRouteVo.java
...ervice/kylin/dto/vo/express/KylinOrderExpressRouteVo.java
+2
-0
KylinOrderExpressVo.java
...net/service/kylin/dto/vo/express/KylinOrderExpressVo.java
+36
-0
PerformancesExpressServiceImpl.java
...ai/kylin/service/impl/PerformancesExpressServiceImpl.java
+18
-2
DataUtils.java
...iquidnet/client/admin/zhengzai/kylin/utils/DataUtils.java
+15
-0
liquidnet-service-consumer-dev.yml
...onfig/liquidnet-config/liquidnet-service-consumer-dev.yml
+3
-0
liquidnet-service-consumer-test.yml
...nfig/liquidnet-config/liquidnet-service-consumer-test.yml
+3
-0
KylinOrderExpress.java
...com/liquidnet/service/kylin/entity/KylinOrderExpress.java
+1
-1
KylinOrderTicketsServiceImpl.java
...vice/kylin/service/impl/KylinOrderTicketsServiceImpl.java
+2
-2
DataUtils.java
...ain/java/com/liquidnet/service/kylin/utils/DataUtils.java
+8
-4
PerformancesExpressCallbackController.java
...press/shunfeng/PerformancesExpressCallbackController.java
+3
-5
PerformancesExpressCallbackServiceImpl.java
...ress/shunfeng/PerformancesExpressCallbackServiceImpl.java
+32
-12
DataUtils.java
.../java/com/liquidnet/service/platform/utils/DataUtils.java
+35
-1
No files found.
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/constant/KylinRedisConst.java
View file @
b37193c0
...
@@ -16,8 +16,8 @@ public class KylinRedisConst {
...
@@ -16,8 +16,8 @@ public class KylinRedisConst {
public
static
final
String
SURPLUS_EXCHANGE
=
"surplusExchange"
;
public
static
final
String
SURPLUS_EXCHANGE
=
"surplusExchange"
;
public
static
final
String
TICKET
=
"kylin:ticket:id:"
;
public
static
final
String
TICKET
=
"kylin:ticket:id:"
;
public
static
final
String
ORDER
=
"kylin:order:id:"
;
public
static
final
String
ORDER
=
"kylin:order:id:"
;
public
static
final
String
ORDER_ROUTE_INFO
=
"kylin:
:
order:routeInfo:id:"
;
public
static
final
String
ORDER_ROUTE_INFO
=
"kylin:order:routeInfo:id:"
;
public
static
final
String
ORDER_EXPRESS_
STATUS
=
"kylin:
:order:ExpressStatus:id:"
;
public
static
final
String
ORDER_EXPRESS_
INFO
=
"kylin
:order:ExpressStatus:id:"
;
public
static
final
String
ORDER_ENTITIES
=
"kylin:order_entities:id:"
;
public
static
final
String
ORDER_ENTITIES
=
"kylin:order_entities:id:"
;
public
static
final
String
TIMES
=
"kylin:times:id:"
;
public
static
final
String
TIMES
=
"kylin:times:id:"
;
public
static
final
String
AGENT
=
"kylin:agent:info"
;
public
static
final
String
AGENT
=
"kylin:agent:info"
;
...
...
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/constant/KylinTableStatusConst.java
View file @
b37193c0
...
@@ -79,7 +79,7 @@ public class KylinTableStatusConst {
...
@@ -79,7 +79,7 @@ public class KylinTableStatusConst {
/**
/**
* 快递
* 快递
*/
*/
public
static
final
Integer
ORDER_EXPRESS_STATUS1
=
1
;
// 申请 顺丰返回失败
public
static
final
Integer
ORDER_EXPRESS_STATUS1
=
1
;
// 申请 顺丰返回失败
未下单 未发快递
public
static
final
Integer
ORDER_EXPRESS_STATUS2
=
2
;
// 申请 顺丰返回成功 或 通过主动再查询更新
public
static
final
Integer
ORDER_EXPRESS_STATUS2
=
2
;
// 申请 顺丰返回成功 或 通过主动再查询更新
public
static
final
Integer
ORDER_EXPRESS_STATUS3
=
3
;
// 取消
public
static
final
Integer
ORDER_EXPRESS_STATUS3
=
3
;
// 取消
}
}
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/express/KylinOrderExpressRouteVo.java
View file @
b37193c0
...
@@ -23,6 +23,8 @@ public class KylinOrderExpressRouteVo implements Serializable {
...
@@ -23,6 +23,8 @@ public class KylinOrderExpressRouteVo implements Serializable {
private
String
orderExpressRouteId
;
private
String
orderExpressRouteId
;
@ApiModelProperty
(
value
=
"orderExpressId"
)
@ApiModelProperty
(
value
=
"orderExpressId"
)
private
String
orderExpressId
;
private
String
orderExpressId
;
@ApiModelProperty
(
value
=
"orderTicketsId"
)
private
String
orderTicketsId
;
@ApiModelProperty
(
value
=
"路由节点发生的城市"
)
@ApiModelProperty
(
value
=
"路由节点发生的城市"
)
private
String
acceptAddress
;
private
String
acceptAddress
;
@ApiModelProperty
(
value
=
"YYYY-MM-DD"
)
@ApiModelProperty
(
value
=
"YYYY-MM-DD"
)
...
...
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/express/KylinOrderExpressVo.java
0 → 100644
View file @
b37193c0
package
com
.
liquidnet
.
service
.
kylin
.
dto
.
vo
.
express
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
java.io.Serializable
;
import
java.util.List
;
/**
* <p>
* 快递信息
* </p>
*
* @author jiangxiulong
* @since 2021-07-01
*/
@Data
@ApiModel
public
class
KylinOrderExpressVo
implements
Serializable
{
@ApiModelProperty
(
value
=
"orderExpressId"
)
private
String
orderExpressId
;
@ApiModelProperty
(
value
=
"orderTicketsId"
)
private
String
orderTicketsId
;
@ApiModelProperty
(
value
=
"自己的快递单号"
)
private
String
orderExpressCode
;
@ApiModelProperty
(
value
=
"顺丰快递单号"
)
private
String
mailno
;
@ApiModelProperty
(
value
=
"快递状态"
)
private
Integer
expressStatus
;
@ApiModelProperty
(
value
=
"物流数据"
)
List
<
KylinOrderExpressRouteVo
>
routeList
;
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/PerformancesExpressServiceImpl.java
View file @
b37193c0
...
@@ -4,24 +4,28 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
...
@@ -4,24 +4,28 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import
com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper
;
import
com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.liquidnet.client.admin.common.utils.StringUtils
;
import
com.liquidnet.client.admin.common.utils.StringUtils
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.ShunfengSignUtils
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.ShunfengSignUtils
;
import
com.liquidnet.commons.lang.util.*
;
import
com.liquidnet.commons.lang.util.*
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.constant.KylinTableStatusConst
;
import
com.liquidnet.service.kylin.constant.KylinTableStatusConst
;
import
com.liquidnet.service.kylin.dao.*
;
import
com.liquidnet.service.kylin.dao.*
;
import
com.liquidnet.service.kylin.dto.param.*
;
import
com.liquidnet.service.kylin.dto.param.*
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressRouteVo
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressVo
;
import
com.liquidnet.service.kylin.entity.*
;
import
com.liquidnet.service.kylin.entity.*
;
import
com.liquidnet.service.kylin.mapper.*
;
import
com.liquidnet.service.kylin.mapper.*
;
import
com.liquidnet.service.kylin.service.IKylinOrderExpress
;
import
com.liquidnet.service.kylin.service.IKylinOrderExpress
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.scheduling.annotation.Async
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Query
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.time.LocalDateTime
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.List
;
...
@@ -80,6 +84,9 @@ public class PerformancesExpressServiceImpl extends ServiceImpl<KylinOrderExpres
...
@@ -80,6 +84,9 @@ public class PerformancesExpressServiceImpl extends ServiceImpl<KylinOrderExpres
@Autowired
@Autowired
private
KylinOrderExpressRouteMapper
kylinOrderExpressRouteMapper
;
private
KylinOrderExpressRouteMapper
kylinOrderExpressRouteMapper
;
@Autowired
private
DataUtils
dataUtils
;
public
List
<
PerformanceExpressPerformanceListAdminDao
>
getPerformancesList
(
PerformanceExpressSearchAdminParam
performanceExpressSearchAdminParam
)
{
public
List
<
PerformanceExpressPerformanceListAdminDao
>
getPerformancesList
(
PerformanceExpressSearchAdminParam
performanceExpressSearchAdminParam
)
{
List
<
PerformanceExpressPerformanceListAdminDao
>
voList
=
new
ArrayList
();
List
<
PerformanceExpressPerformanceListAdminDao
>
voList
=
new
ArrayList
();
try
{
try
{
...
@@ -192,6 +199,12 @@ public class PerformancesExpressServiceImpl extends ServiceImpl<KylinOrderExpres
...
@@ -192,6 +199,12 @@ public class PerformancesExpressServiceImpl extends ServiceImpl<KylinOrderExpres
kylinOrderExpress
kylinOrderExpress
,
new
UpdateWrapper
<
KylinOrderExpress
>().
in
(
"order_express_id"
,
orderExpressId
)
,
new
UpdateWrapper
<
KylinOrderExpress
>().
in
(
"order_express_id"
,
orderExpressId
)
);
);
KylinOrderExpressVo
kylinOrderExpressVo
=
new
KylinOrderExpressVo
();
BeanUtils
.
copyProperties
(
kylinOrderExpressPre
,
kylinOrderExpressVo
);
kylinOrderExpressVo
.
setMailno
(
kylinOrderExpress
.
getMailno
());
kylinOrderExpressVo
.
setExpressStatus
(
kylinOrderExpress
.
getExpressStatus
());
dataUtils
.
setOrderExpressInfo
(
orderTicketsId
,
kylinOrderExpressVo
);
}
}
}
}
return
ResponseDto
.
success
();
return
ResponseDto
.
success
();
...
@@ -224,6 +237,9 @@ public class PerformancesExpressServiceImpl extends ServiceImpl<KylinOrderExpres
...
@@ -224,6 +237,9 @@ public class PerformancesExpressServiceImpl extends ServiceImpl<KylinOrderExpres
kylinOrderExpress
kylinOrderExpress
,
new
UpdateWrapper
<
KylinOrderExpress
>().
in
(
"order_express_id"
,
orderExpressInfo
.
getOrderExpressId
())
,
new
UpdateWrapper
<
KylinOrderExpress
>().
in
(
"order_express_id"
,
orderExpressInfo
.
getOrderExpressId
())
);
);
dataUtils
.
delOrderExpressInfo
(
orderTicketsId
);
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"orderTicketsId"
).
is
(
orderTicketsId
)),
KylinOrderExpressRouteVo
.
class
.
getSimpleName
());
}
}
}
}
}
}
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/DataUtils.java
View file @
b37193c0
...
@@ -2,6 +2,7 @@ package com.liquidnet.client.admin.zhengzai.kylin.utils;
...
@@ -2,6 +2,7 @@ package com.liquidnet.client.admin.zhengzai.kylin.utils;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo
;
import
com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo
;
import
com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo
;
...
@@ -263,4 +264,18 @@ public class DataUtils {
...
@@ -263,4 +264,18 @@ public class DataUtils {
redisUtil
.
decr
(
performanceIdKey
,
Math
.
abs
(
buyCount
));
redisUtil
.
decr
(
performanceIdKey
,
Math
.
abs
(
buyCount
));
}
}
}
}
/**
* 演出订单快递信息
* @param orderId
* @param kylinOrderExpressVo
*/
public
void
setOrderExpressInfo
(
String
orderId
,
KylinOrderExpressVo
kylinOrderExpressVo
)
{
String
redisKey
=
KylinRedisConst
.
ORDER_EXPRESS_INFO
.
concat
(
orderId
);
redisUtil
.
set
(
redisKey
,
kylinOrderExpressVo
);
}
public
void
delOrderExpressInfo
(
String
orderId
)
{
String
redisKey
=
KylinRedisConst
.
ORDER_EXPRESS_INFO
.
concat
(
orderId
);
redisUtil
.
del
(
redisKey
);
}
}
}
liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-dev.yml
View file @
b37193c0
...
@@ -20,5 +20,8 @@ liquidnet:
...
@@ -20,5 +20,8 @@ liquidnet:
connection-timeout
:
5000
connection-timeout
:
5000
mysql
:
mysql
:
database-name
:
dev_ln_scene
database-name
:
dev_ln_scene
mongodb
:
sslEnabled
:
false
database
:
dev_ln_scene
#以下为spring各环境个性配置
#以下为spring各环境个性配置
\ No newline at end of file
liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-test.yml
View file @
b37193c0
...
@@ -20,5 +20,8 @@ liquidnet:
...
@@ -20,5 +20,8 @@ liquidnet:
connection-timeout
:
3000
connection-timeout
:
3000
mysql
:
mysql
:
database-name
:
test_ln_scene
database-name
:
test_ln_scene
mongodb
:
sslEnabled
:
false
database
:
dev_ln_scene
#以下为spring各环境个性配置
#以下为spring各环境个性配置
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinOrderExpress.java
View file @
b37193c0
...
@@ -26,7 +26,7 @@ public class KylinOrderExpress implements Serializable {
...
@@ -26,7 +26,7 @@ public class KylinOrderExpress implements Serializable {
private
String
orderExpressId
;
private
String
orderExpressId
;
private
String
orderTicketsId
;
private
String
orderTicketsId
;
private
String
O
rderExpressCode
;
private
String
o
rderExpressCode
;
private
String
mailno
;
private
String
mailno
;
private
Integer
expressType
;
private
Integer
expressType
;
private
String
filterResult
;
private
String
filterResult
;
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsServiceImpl.java
View file @
b37193c0
...
@@ -867,7 +867,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
...
@@ -867,7 +867,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
KylinOrderListVo
item
=
voList
.
get
(
i
);
KylinOrderListVo
item
=
voList
.
get
(
i
);
//TODO 顺丰快递
//TODO 顺丰快递
Integer
orderExpressStatus
=
dataUtils
.
getOrderExpress
Status
(
item
.
getOrderTicketsId
());
Integer
orderExpressStatus
=
dataUtils
.
getOrderExpress
Info
(
item
.
getOrderTicketsId
());
item
.
setExpressStatus
(
orderExpressStatus
);
item
.
setExpressStatus
(
orderExpressStatus
);
if
(
item
.
getStatus
().
equals
(
KylinTableStatusConst
.
ORDER_STATUS0
))
{
if
(
item
.
getStatus
().
equals
(
KylinTableStatusConst
.
ORDER_STATUS0
))
{
...
@@ -984,7 +984,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
...
@@ -984,7 +984,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
log
.
debug
(
"获取倒计时 -> time:"
+
(
currentTime
)
+
"毫秒"
);
log
.
debug
(
"获取倒计时 -> time:"
+
(
currentTime
)
+
"毫秒"
);
//TODO 顺丰快递
//TODO 顺丰快递
Integer
orderExpressStatus
=
dataUtils
.
getOrderExpress
Status
(
orderTicketVo
.
getOrderTicketsId
());
Integer
orderExpressStatus
=
dataUtils
.
getOrderExpress
Info
(
orderTicketVo
.
getOrderTicketsId
());
vo
.
setExpressStatus
(
orderExpressStatus
);
vo
.
setExpressStatus
(
orderExpressStatus
);
if
(
null
!=
performanceVo
.
getIsCanRefund
()
&&
performanceVo
.
getIsCanRefund
()
==
1
)
{
if
(
null
!=
performanceVo
.
getIsCanRefund
()
&&
performanceVo
.
getIsCanRefund
()
==
1
)
{
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/utils/DataUtils.java
View file @
b37193c0
...
@@ -3,6 +3,7 @@ package com.liquidnet.service.kylin.utils;
...
@@ -3,6 +3,7 @@ package com.liquidnet.service.kylin.utils;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.commons.lang.util.DateUtil
;
import
com.liquidnet.commons.lang.util.DateUtil
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo
;
import
com.liquidnet.service.kylin.dto.vo.mongo.*
;
import
com.liquidnet.service.kylin.dto.vo.mongo.*
;
...
@@ -646,13 +647,16 @@ public class DataUtils {
...
@@ -646,13 +647,16 @@ public class DataUtils {
}
}
/**
/**
* 获取订单快递状态
* 获取
演出
订单快递状态
*/
*/
public
Integer
getOrderExpress
Status
(
String
orderId
)
{
public
Integer
getOrderExpress
Info
(
String
orderId
)
{
String
redisKey
=
KylinRedisConst
.
ORDER_EXPRESS_
STATUS
.
concat
(
orderId
);
String
redisKey
=
KylinRedisConst
.
ORDER_EXPRESS_
INFO
.
concat
(
orderId
);
if
(!
redisUtil
.
hasKey
(
redisKey
))
{
if
(!
redisUtil
.
hasKey
(
redisKey
))
{
return
1
;
return
1
;
}
else
{
KylinOrderExpressVo
expressInfo
=
(
KylinOrderExpressVo
)
redisUtil
.
get
(
redisKey
);
return
expressInfo
.
getExpressStatus
();
}
}
return
(
Integer
)
redisUtil
.
get
(
redisKey
);
}
}
}
}
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/express/shunfeng/PerformancesExpressCallbackController.java
View file @
b37193c0
...
@@ -2,10 +2,8 @@ package com.liquidnet.service.platform.controller.express.shunfeng;
...
@@ -2,10 +2,8 @@ package com.liquidnet.service.platform.controller.express.shunfeng;
import
com.liquidnet.service.base.ErrorMapping
;
import
com.liquidnet.service.base.ErrorMapping
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.dto.param.PerformanceExpressPushFreightParam
;
import
com.liquidnet.service.kylin.dto.param.PerformanceExpressPushRouteParam
;
import
com.liquidnet.service.kylin.dto.param.PerformanceExpressPushStatusParam
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressRouteVo
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressRouteVo
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressVo
;
import
com.liquidnet.service.platform.service.express.shunfeng.PerformancesExpressCallbackServiceImpl
;
import
com.liquidnet.service.platform.service.express.shunfeng.PerformancesExpressCallbackServiceImpl
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiImplicitParam
;
import
io.swagger.annotations.ApiImplicitParam
;
...
@@ -75,8 +73,8 @@ public class PerformancesExpressCallbackController {
...
@@ -75,8 +73,8 @@ public class PerformancesExpressCallbackController {
@GetMapping
(
"orderRoute/{orderTicketsId}"
)
@GetMapping
(
"orderRoute/{orderTicketsId}"
)
@ApiOperation
(
"获取物流信息"
)
// 前端使用
@ApiOperation
(
"获取物流信息"
)
// 前端使用
@ApiImplicitParam
(
name
=
"orderTicketsId"
,
value
=
"订单ID"
,
required
=
true
,
dataType
=
"String"
,
paramType
=
"path"
)
@ApiImplicitParam
(
name
=
"orderTicketsId"
,
value
=
"订单ID"
,
required
=
true
,
dataType
=
"String"
,
paramType
=
"path"
)
public
ResponseDto
<
List
<
KylinOrderExpressRouteVo
>
>
orderRouteDetail
(
@PathVariable
()
String
orderTicketsId
)
{
public
ResponseDto
<
KylinOrderExpressVo
>
orderRouteDetail
(
@PathVariable
()
String
orderTicketsId
)
{
List
<
KylinOrderExpressRouteVo
>
routeVoList
=
performancesExpressServiceImpl
.
orderRouteDetail
(
orderTicketsId
);
KylinOrderExpressVo
routeVoList
=
performancesExpressServiceImpl
.
orderRouteDetail
(
orderTicketsId
);
if
(
null
!=
routeVoList
)
{
if
(
null
!=
routeVoList
)
{
return
ResponseDto
.
success
(
routeVoList
);
return
ResponseDto
.
success
(
routeVoList
);
}
else
{
}
else
{
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/express/shunfeng/PerformancesExpressCallbackServiceImpl.java
View file @
b37193c0
package
com
.
liquidnet
.
service
.
platform
.
service
.
express
.
shunfeng
;
package
com
.
liquidnet
.
service
.
platform
.
service
.
express
.
shunfeng
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper
;
import
com.baomidou.mybatisplus.core.toolkit.Wrappers
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.commons.lang.util.*
;
import
com.liquidnet.commons.lang.util.*
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.dto.param.*
;
import
com.liquidnet.service.kylin.dto.param.*
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressRouteVo
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressRouteVo
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressVo
;
import
com.liquidnet.service.kylin.dto.vo.mongo.KylinRoadShowVo
;
import
com.liquidnet.service.kylin.entity.*
;
import
com.liquidnet.service.kylin.entity.*
;
import
com.liquidnet.service.kylin.mapper.*
;
import
com.liquidnet.service.kylin.mapper.*
;
import
com.liquidnet.service.kylin.service.IKylinOrderExpress
;
import
com.liquidnet.service.kylin.service.IKylinOrderExpress
;
import
com.liquidnet.service.platform.utils.DataUtils
;
import
com.liquidnet.service.platform.utils.ShunfengSignUtils
;
import
com.liquidnet.service.platform.utils.ShunfengSignUtils
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Query
;
import
org.springframework.data.mongodb.core.query.Query
;
...
@@ -22,7 +27,6 @@ import org.springframework.web.bind.annotation.RequestBody;
...
@@ -22,7 +27,6 @@ import org.springframework.web.bind.annotation.RequestBody;
import
javax.servlet.http.HttpServletRequest
;
import
javax.servlet.http.HttpServletRequest
;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.List
;
/**
/**
...
@@ -61,6 +65,9 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
...
@@ -61,6 +65,9 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
@Autowired
@Autowired
private
RedisUtil
redisUtil
;
private
RedisUtil
redisUtil
;
@Autowired
private
DataUtils
dataUtils
;
public
boolean
orderStatus
(
@RequestBody
String
params
)
{
public
boolean
orderStatus
(
@RequestBody
String
params
)
{
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
params
,
httpServletRequest
);
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
params
,
httpServletRequest
);
if
(
res
)
{
if
(
res
)
{
...
@@ -89,7 +96,7 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
...
@@ -89,7 +96,7 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
public
boolean
orderFreightList
(
@RequestBody
String
params
)
{
public
boolean
orderFreightList
(
@RequestBody
String
params
)
{
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
params
,
httpServletRequest
);
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
params
,
httpServletRequest
);
if
(
true
)
{
if
(
res
)
{
PerformanceExpressPushFreightParam
performanceExpressPushFreightParam
=
JsonUtils
.
fromJson
(
params
,
PerformanceExpressPushFreightParam
.
class
);
PerformanceExpressPushFreightParam
performanceExpressPushFreightParam
=
JsonUtils
.
fromJson
(
params
,
PerformanceExpressPushFreightParam
.
class
);
KylinOrderExpress
orderExpressInfo
=
kylinOrderExpressMapper
.
selectOne
(
new
QueryWrapper
<
KylinOrderExpress
>().
eq
(
"mailno"
,
performanceExpressPushFreightParam
.
getWaybillNo
()));
KylinOrderExpress
orderExpressInfo
=
kylinOrderExpressMapper
.
selectOne
(
new
QueryWrapper
<
KylinOrderExpress
>().
eq
(
"mailno"
,
performanceExpressPushFreightParam
.
getWaybillNo
()));
String
orderExpressId
=
orderExpressInfo
.
getOrderExpressId
();
String
orderExpressId
=
orderExpressInfo
.
getOrderExpressId
();
...
@@ -122,6 +129,11 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
...
@@ -122,6 +129,11 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
String
orderExpressRouteId
=
IDGenerator
.
nextSnowId
();
String
orderExpressRouteId
=
IDGenerator
.
nextSnowId
();
KylinOrderExpress
orderExpressInfo
=
kylinOrderExpressMapper
.
selectOne
(
new
QueryWrapper
<
KylinOrderExpress
>().
eq
(
"mailno"
,
performanceExpressPushRouteParam
.
getMailno
()));
KylinOrderExpress
orderExpressInfo
=
kylinOrderExpressMapper
.
selectOne
(
new
QueryWrapper
<
KylinOrderExpress
>().
eq
(
"mailno"
,
performanceExpressPushRouteParam
.
getMailno
()));
KylinOrderExpress
kylinOrderExpress
=
new
KylinOrderExpress
();
kylinOrderExpress
.
setExpressStatus
(
Integer
.
valueOf
(
performanceExpressPushRouteParam
.
getOpCode
()));
kylinOrderExpressMapper
.
update
(
kylinOrderExpress
,
Wrappers
.
lambdaQuery
(
KylinOrderExpress
.
class
).
eq
(
KylinOrderExpress:
:
getOrderExpressId
,
orderExpressInfo
.
getOrderExpressId
()));
kylinOrderExpressRoute
.
setOrderExpressRouteId
(
orderExpressRouteId
);
kylinOrderExpressRoute
.
setOrderExpressRouteId
(
orderExpressRouteId
);
kylinOrderExpressRoute
.
setOrderExpressId
(
orderExpressInfo
.
getOrderExpressId
());
kylinOrderExpressRoute
.
setOrderExpressId
(
orderExpressInfo
.
getOrderExpressId
());
kylinOrderExpressRoute
.
setAcceptAddress
(
performanceExpressPushRouteParam
.
getAcceptAddress
());
kylinOrderExpressRoute
.
setAcceptAddress
(
performanceExpressPushRouteParam
.
getAcceptAddress
());
...
@@ -130,20 +142,28 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
...
@@ -130,20 +142,28 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
kylinOrderExpressRoute
.
setOpcode
(
performanceExpressPushRouteParam
.
getOpCode
());
kylinOrderExpressRoute
.
setOpcode
(
performanceExpressPushRouteParam
.
getOpCode
());
kylinOrderExpressRoute
.
setCreatedAt
(
DateUtil
.
getNowTime
());
kylinOrderExpressRoute
.
setCreatedAt
(
DateUtil
.
getNowTime
());
kylinOrderExpressRouteMapper
.
insert
(
kylinOrderExpressRoute
);
kylinOrderExpressRouteMapper
.
insert
(
kylinOrderExpressRoute
);
KylinOrderExpressVo
kylinOrderExpressVo
=
new
KylinOrderExpressVo
();
BeanUtils
.
copyProperties
(
orderExpressInfo
,
kylinOrderExpressVo
);
kylinOrderExpressVo
.
setExpressStatus
(
Integer
.
valueOf
(
performanceExpressPushRouteParam
.
getOpCode
()));
dataUtils
.
setOrderExpressInfo
(
orderExpressInfo
.
getOrderTicketsId
(),
kylinOrderExpressVo
);
KylinOrderExpressRouteVo
kylinOrderExpressRouteVo
=
new
KylinOrderExpressRouteVo
();
BeanUtils
.
copyProperties
(
kylinOrderExpressRoute
,
kylinOrderExpressRouteVo
);
kylinOrderExpressRouteVo
.
setOrderTicketsId
(
orderExpressInfo
.
getOrderTicketsId
());
mongoTemplate
.
insert
(
kylinOrderExpressRouteVo
,
KylinOrderExpressRouteVo
.
class
.
getSimpleName
());
dataUtils
.
delOrderExpressRoute
(
orderExpressInfo
.
getOrderTicketsId
());
return
true
;
return
true
;
}
}
return
false
;
return
false
;
}
}
public
List
<
KylinOrderExpressRouteVo
>
orderRouteDetail
(
String
orderTicketsId
)
{
public
KylinOrderExpressVo
orderRouteDetail
(
String
orderTicketsId
)
{
String
redisKey
=
KylinRedisConst
.
ORDER_ROUTE_INFO
.
concat
(
orderTicketsId
);
List
<
KylinOrderExpressRouteVo
>
routeList
=
dataUtils
.
getOrderExpressRoute
(
orderTicketsId
);
if
(!
redisUtil
.
hasKey
(
redisKey
))
{
KylinOrderExpressVo
expressInfo
=
dataUtils
.
getOrderExpressInfo
(
orderTicketsId
);
Query
query
=
new
Query
();
expressInfo
.
setRouteList
(
routeList
);
query
.
addCriteria
(
Criteria
.
where
(
"orderTicketsId"
).
is
(
orderTicketsId
));
return
expressInfo
;
List
<
KylinOrderExpressRouteVo
>
routeList
=
mongoTemplate
.
find
(
query
,
KylinOrderExpressRouteVo
.
class
,
KylinOrderExpressRouteVo
.
class
.
getSimpleName
());
redisUtil
.
set
(
redisKey
,
routeList
);
}
return
(
List
<
KylinOrderExpressRouteVo
>)
redisUtil
.
get
(
redisKey
);
}
}
}
}
\ No newline at end of file
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/DataUtils.java
View file @
b37193c0
...
@@ -5,6 +5,8 @@ import com.liquidnet.common.cache.redis.util.RedisUtil;
...
@@ -5,6 +5,8 @@ import com.liquidnet.common.cache.redis.util.RedisUtil;
import
com.liquidnet.commons.lang.util.DateUtil
;
import
com.liquidnet.commons.lang.util.DateUtil
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressRouteVo
;
import
com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo
;
import
com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo
;
import
com.liquidnet.service.kylin.dto.vo.mongo.*
;
import
com.liquidnet.service.kylin.dto.vo.mongo.*
;
...
@@ -21,7 +23,6 @@ import org.springframework.data.mongodb.core.query.Query;
...
@@ -21,7 +23,6 @@ import org.springframework.data.mongodb.core.query.Query;
import
org.springframework.data.redis.core.RedisTemplate
;
import
org.springframework.data.redis.core.RedisTemplate
;
import
org.springframework.stereotype.Component
;
import
org.springframework.stereotype.Component
;
import
java.math.BigDecimal
;
import
java.text.SimpleDateFormat
;
import
java.text.SimpleDateFormat
;
import
java.time.LocalDateTime
;
import
java.time.LocalDateTime
;
import
java.util.*
;
import
java.util.*
;
...
@@ -595,4 +596,37 @@ public class DataUtils {
...
@@ -595,4 +596,37 @@ public class DataUtils {
redisUtil
.
del
(
KylinRedisConst
.
ORDER_REFUND_BY_ORDER_ID
+
orderId
);
redisUtil
.
del
(
KylinRedisConst
.
ORDER_REFUND_BY_ORDER_ID
+
orderId
);
}
}
/**
* 演出订单快递信息
* @param orderId
* @param kylinOrderExpressVo
*/
public
void
setOrderExpressInfo
(
String
orderId
,
KylinOrderExpressVo
kylinOrderExpressVo
)
{
String
redisKey
=
KylinRedisConst
.
ORDER_EXPRESS_INFO
.
concat
(
orderId
);
redisUtil
.
set
(
redisKey
,
kylinOrderExpressVo
);
}
public
KylinOrderExpressVo
getOrderExpressInfo
(
String
orderId
)
{
String
redisKey
=
KylinRedisConst
.
ORDER_EXPRESS_INFO
.
concat
(
orderId
);
return
(
KylinOrderExpressVo
)
redisUtil
.
get
(
redisKey
);
}
/**
* 演出订单快递路由
*/
public
List
<
KylinOrderExpressRouteVo
>
getOrderExpressRoute
(
String
orderTicketsId
)
{
// 获取
String
redisKey
=
KylinRedisConst
.
ORDER_ROUTE_INFO
.
concat
(
orderTicketsId
);
if
(!
redisUtil
.
hasKey
(
redisKey
))
{
List
<
KylinOrderExpressRouteVo
>
routeVoList
=
mongoTemplate
.
find
(
Query
.
query
(
Criteria
.
where
(
"orderTicketsId"
).
is
(
orderTicketsId
)),
KylinOrderExpressRouteVo
.
class
,
KylinOrderExpressRouteVo
.
class
.
getSimpleName
()
);
redisUtil
.
set
(
redisKey
,
routeVoList
);
}
return
(
List
<
KylinOrderExpressRouteVo
>)
redisUtil
.
get
(
redisKey
);
}
public
void
delOrderExpressRoute
(
String
orderTicketsId
)
{
// 删除
String
redisKey
=
KylinRedisConst
.
ORDER_ROUTE_INFO
.
concat
(
orderTicketsId
);
redisUtil
.
del
(
redisKey
);
}
}
}
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