Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
C
clx-performance
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
姜武杰
clx-performance
Commits
576ece49
提交
576ece49
authored
12月 05, 2023
作者:
huyufan
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
CodeView
上级
2bde9eb2
隐藏空白字符变更
内嵌
并排
正在显示
4 个修改的文件
包含
16 行增加
和
19 行删除
+16
-19
OrderCancelComponent.java
...a/com/clx/performance/component/OrderCancelComponent.java
+2
-2
LargeScreenListener.java
...ava/com/clx/performance/listener/LargeScreenListener.java
+0
-2
LargeScreenServiceImpl.java
.../clx/performance/service/impl/LargeScreenServiceImpl.java
+2
-2
OrderChildServiceImpl.java
...m/clx/performance/service/impl/OrderChildServiceImpl.java
+12
-13
没有找到文件。
performance-web/src/main/java/com/clx/performance/component/OrderCancelComponent.java
浏览文件 @
576ece49
...
...
@@ -265,7 +265,7 @@ public class OrderCancelComponent implements InitializingBean {
String
orderNo
=
orderGoods
.
getOrderNo
();
Optional
<
FeignOrderInfoVO
>
optional
=
orderService
.
getOrderInfo
(
orderNo
);
if
(!
optional
.
isPresent
()){
log
.
error
(
"通过订单号未查询到对应的订单信息,订单号:{}"
,
orderNo
);
log
.
warn
(
"通过订单号未查询到对应的订单信息,订单号:{}"
,
orderNo
);
throw
new
ServiceSystemException
(
PerformanceResultEnum
.
DATA_NOT_FIND
);
}
FeignOrderInfoVO
orderInfo
=
optional
.
get
();
...
...
@@ -318,7 +318,7 @@ public class OrderCancelComponent implements InitializingBean {
}
Result
<
Object
>
result
=
orderFeign
.
rollbackOrderWeight
(
rollbackOrderWeightParam
);
if
(!
result
.
succeed
())
{
log
.
error
(
"订单号:{} 的订单做吨数调整,对应货单号:{} 调整失败,调整吨数:{},调整类型:{}"
,
log
.
warn
(
"订单号:{} 的订单做吨数调整,对应货单号:{} 调整失败,调整吨数:{},调整类型:{}"
,
orderNo
,
orderGoods
.
getOrderGoodsNo
(),
weight
,
updateTypeMsg
);
throw
new
ServiceSystemException
(
PerformanceResultEnum
.
HTTP_ERROR
,
"远程调用更新订单余量失败"
);
}
...
...
performance-web/src/main/java/com/clx/performance/listener/LargeScreenListener.java
浏览文件 @
576ece49
...
...
@@ -50,8 +50,6 @@ public class LargeScreenListener {
@RabbitListener
(
queues
=
RabbitKeyConstants
.
ORDER_LARGE_SCREEN_QUEUE
)
public
void
onMessage
(
String
message
)
{
try
{
log
.
info
(
"接入数据大屏===================================================="
);
log
.
info
(
"已经接入到数据============"
+
JSONUtil
.
parse
(
message
));
FeignOrderVO
orderVO
=
JSONUtil
.
toBean
(
message
,
FeignOrderVO
.
class
);
log
.
info
(
"处理数据大屏标准地址路线监听器执行,订单Id为{},发货地标准地址ID为{},收货地标准地址ID为{}"
,
orderVO
.
getOrderNo
(),
orderVO
.
getSendSystemAddressId
(),
orderVO
.
getReveiveSystemAddressId
());
...
...
performance-web/src/main/java/com/clx/performance/service/impl/LargeScreenServiceImpl.java
浏览文件 @
576ece49
...
...
@@ -60,7 +60,7 @@ public class LargeScreenServiceImpl implements LargeScreenService {
public
List
<
JSONObject
>
emptyCarList
()
{
List
<
String
>
data
=
driverFeign
.
driverTruckList
().
getData
();
String
now
=
DateUtils
.
formatDateTime
(
LocalDateTime
.
now
()
,
"yyyy-MM-dd HH:mm:ss"
).
get
();
String
now
=
DateUtils
.
formatDateTime
(
LocalDateTime
.
now
()).
get
();
List
<
OrderChild
>
orderChildList
=
orderChildDao
.
selectListWithEmptyCarList
();
if
(
CollectionUtils
.
isEmpty
(
orderChildList
))
{
return
null
;
...
...
@@ -99,7 +99,7 @@ public class LargeScreenServiceImpl implements LargeScreenService {
public
List
<
JSONObject
>
weightCarList
()
{
List
<
String
>
data
=
driverFeign
.
driverTruckList
().
getData
();
String
now
=
DateUtils
.
formatDateTime
(
LocalDateTime
.
now
()
,
"yyyy-MM-dd HH:mm:ss"
).
get
();
String
now
=
DateUtils
.
formatDateTime
(
LocalDateTime
.
now
()).
get
();
List
<
OrderChild
>
orderChildList
=
orderChildDao
.
selectListWithEmptyCarList
();
if
(
CollectionUtils
.
isEmpty
(
orderChildList
))
{
return
null
;
...
...
performance-web/src/main/java/com/clx/performance/service/impl/OrderChildServiceImpl.java
浏览文件 @
576ece49
...
...
@@ -1415,27 +1415,26 @@ public class OrderChildServiceImpl implements OrderChildService {
* 更新货单吨数
*/
@Override
public
void
updateOrderGoodsAmountLoad
(
OrderGoods
orderGoods
,
String
childNo
,
BigDecimal
dif
,
Integer
orderGoodsStatus
)
{
public
void
updateOrderGoodsAmountLoad
(
OrderGoods
orderGoods
,
String
childNo
,
BigDecimal
dif
,
Integer
orderGoodsStatus
)
{
//防止状态倒退
if
(
orderGoods
.
getOrderGoodsStatus
().
equals
(
OrderGoodsStatusEnum
.
Status
.
CANCEL
.
getCode
())
||
orderGoods
.
getOrderGoodsStatus
().
equals
(
OrderGoodsStatusEnum
.
Status
.
COMPLETED
.
getCode
())
||
orderGoods
.
getOrderGoodsStatus
().
equals
(
OrderGoodsStatusEnum
.
Status
.
SUCCESS
.
getCode
())
){
)
{
orderGoodsStatus
=
orderGoods
.
getOrderGoodsStatus
();
}
if
(
dif
.
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
//判断是从订单借吨还是直接货单进行扣减(货单剩余吨数小于本运单的修改后的吨数差值)
if
(
orderGoods
.
getResidueTransportWeight
().
compareTo
(
dif
)
<
0
)
{
//货单吨数不够扣减,从订单进行借吨数
orderGoodsService
.
borrowWeight
(
orderGoods
,
childNo
,
orderGoods
.
getResidueTransportWeight
(),
dif
,
dif
.
subtract
(
orderGoods
.
getResidueTransportWeight
()),
OrderGoodsStatusEnum
.
Status
.
GO_TO_SEND
.
getCode
());
}
else
{
// 货单吨数够扣减,直接更新货单剩余吨数和已拉运吨数和状态
orderGoodsDao
.
updateOrderGoodsReduceWeightAndStatus
(
orderGoods
.
getId
(),
dif
,
orderGoodsStatus
);
if
(
dif
.
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
//判断是从订单借吨还是直接货单进行扣减(货单剩余吨数小于本运单的修改后的吨数差值)
if
(
orderGoods
.
getResidueTransportWeight
().
compareTo
(
dif
)
<
0
)
{
//货单吨数不够扣减,从订单进行借吨数
orderGoodsService
.
borrowWeight
(
orderGoods
,
childNo
,
orderGoods
.
getResidueTransportWeight
(),
dif
,
dif
.
subtract
(
orderGoods
.
getResidueTransportWeight
()),
orderGoodsStatus
);
}
else
{
// 货单吨数够扣减,直接更新货单剩余吨数和已拉运吨数和状态
orderGoodsDao
.
updateOrderGoodsReduceWeightAndStatus
(
orderGoods
.
getId
(),
dif
,
orderGoodsStatus
);
}
}
}
}
/**
* 更新定向单状态 (接单)
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论