Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
I
ims-ci-test
概览
概览
详情
活动
周期分析
版本库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
统计图
问题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程表
图表
维基
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
test-ci
ims-ci-test
Commits
e41eac5b
提交
e41eac5b
authored
11月 10, 2023
作者:
恶龙咆哮
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
修改bug
上级
e87a7d20
显示空白字符变更
内嵌
并排
正在显示
2 个修改的文件
包含
108 行增加
和
89 行删除
+108
-89
OnlyRequirementsInfoId.java
...ava/com/mmc/csf/infomation/vo/OnlyRequirementsInfoId.java
+18
-0
RequirementsServiceImpl.java
...mmc/csf/release/service/impl/RequirementsServiceImpl.java
+90
-89
没有找到文件。
csf-common/csf-common-model/src/main/java/com/mmc/csf/infomation/vo/OnlyRequirementsInfoId.java
0 → 100644
浏览文件 @
e41eac5b
package
com
.
mmc
.
csf
.
infomation
.
vo
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.AllArgsConstructor
;
import
lombok.Data
;
import
lombok.NoArgsConstructor
;
/**
* @author 张培
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public
class
OnlyRequirementsInfoId
{
@ApiModelProperty
(
value
=
"订单id"
)
private
Integer
requirementsInfoId
;
}
release-service/src/main/java/com/mmc/csf/release/service/impl/RequirementsServiceImpl.java
浏览文件 @
e41eac5b
...
@@ -224,11 +224,11 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -224,11 +224,11 @@ public class RequirementsServiceImpl implements RequirementsService {
}
}
Integer
status
=
requirementsDao
.
selectServiceIdByRequireIdAndUserId
(
id
,
userAccountId
);
Integer
status
=
requirementsDao
.
selectServiceIdByRequireIdAndUserId
(
id
,
userAccountId
);
if
(
status
==
null
)
{
if
(
status
==
null
)
{
return
ResultBody
.
success
(
requirementsInfoVO
);
return
ResultBody
.
success
(
requirementsInfoVO
);
}
}
//如果该飞手被拒绝 需要修改当前订单的状态
//如果该飞手被拒绝 需要修改当前订单的状态
if
(
requirementsDao
.
selectServiceIdByRequireIdAndUserId
(
id
,
userAccountId
)
==
11
)
{
if
(
requirementsDao
.
selectServiceIdByRequireIdAndUserId
(
id
,
userAccountId
)
==
11
)
{
requirementsInfoVO
.
setOrderStatus
(
"170"
);
requirementsInfoVO
.
setOrderStatus
(
"170"
);
}
}
return
ResultBody
.
success
(
requirementsInfoVO
);
return
ResultBody
.
success
(
requirementsInfoVO
);
...
@@ -735,7 +735,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -735,7 +735,7 @@ public class RequirementsServiceImpl implements RequirementsService {
Integer
serviceFlowId
=
requirementsServiceDO
.
getServiceFlowId
();
Integer
serviceFlowId
=
requirementsServiceDO
.
getServiceFlowId
();
if
(
serviceFlowId
!=
10
)
{
if
(
serviceFlowId
!=
10
)
{
return
ResultBody
.
error
(
ResultEnum
.
YOU_CANNOT_CANCEL_THE_ORDER_AT_THIS_TIME
.
getResultMsg
());
return
ResultBody
.
error
(
ResultEnum
.
YOU_CANNOT_CANCEL_THE_ORDER_AT_THIS_TIME
.
getResultMsg
());
}
else
{
}
else
{
//修改订单所需人数以及订单状态
//修改订单所需人数以及订单状态
requirementsDao
.
updateRequirementsInfoByRefusePilot
(
requirementsInfoId
);
requirementsDao
.
updateRequirementsInfoByRefusePilot
(
requirementsInfoId
);
Integer
fatherRequireId
=
requirementsDao
.
selectFatherRequireIdBySonId
(
requirementsInfoId
);
Integer
fatherRequireId
=
requirementsDao
.
selectFatherRequireIdBySonId
(
requirementsInfoId
);
...
@@ -1036,12 +1036,12 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1036,12 +1036,12 @@ public class RequirementsServiceImpl implements RequirementsService {
Boolean
condition1
=
false
;
Boolean
condition1
=
false
;
Boolean
condition2
=
false
;
Boolean
condition2
=
false
;
//如果是多人订单 需要判断每一个子订单是否是在 1,10 状态
//如果是多人订单 需要判断每一个子订单是否是在 1,10 状态
if
(
requirementsDao
.
selectRequirementsNum
(
requirementsInfoId
)
>
1
)
{
if
(
requirementsDao
.
selectRequirementsNum
(
requirementsInfoId
)
>
1
)
{
if
(
requirementsDao
.
selectServiceFlowIdByFatherId
(
requirementsInfoId
)
==
0
)
{
if
(
requirementsDao
.
selectServiceFlowIdByFatherId
(
requirementsInfoId
)
==
0
)
{
condition2
=
true
;
condition2
=
true
;
condition1
=
true
;
condition1
=
true
;
}
}
}
else
{
}
else
{
condition1
=
serviceFlowId
==
1
;
condition1
=
serviceFlowId
==
1
;
condition2
=
serviceFlowId
==
10
;
condition2
=
serviceFlowId
==
10
;
}
}
...
@@ -1081,7 +1081,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1081,7 +1081,7 @@ public class RequirementsServiceImpl implements RequirementsService {
requirementsDao
.
updateInfo
(
requirementsInfoId
,
7
);
requirementsDao
.
updateInfo
(
requirementsInfoId
,
7
);
requirementsDao
.
updateFlow
(
requirementsInfoId
,
7
);
requirementsDao
.
updateFlow
(
requirementsInfoId
,
7
);
return
ResultBody
.
success
(
ResultEnum
.
THE_AMOUNT_OF_THE_MISSION_WILL_BE_RETURNED
.
getResultMsg
());
return
ResultBody
.
success
(
ResultEnum
.
THE_AMOUNT_OF_THE_MISSION_WILL_BE_RETURNED
.
getResultMsg
());
}
else
{
}
else
{
return
ResultBody
.
error
(
ResultEnum
.
YOU_CANNOT_CANCEL_THE_ORDER_AT_THIS_TIME
.
getResultMsg
());
return
ResultBody
.
error
(
ResultEnum
.
YOU_CANNOT_CANCEL_THE_ORDER_AT_THIS_TIME
.
getResultMsg
());
}
}
// if (serviceFlowId != 2 && serviceFlowId != 1) {
// if (serviceFlowId != 2 && serviceFlowId != 1) {
...
@@ -1282,30 +1282,30 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1282,30 +1282,30 @@ public class RequirementsServiceImpl implements RequirementsService {
* @return
* @return
*/
*/
@Override
@Override
public
ResultBody
cancelAll
(
LiabilityProblemVO
liabilityProblemVO
,
Integer
userAccountId
,
HttpServletRequest
request
)
{
public
ResultBody
cancelAll
(
LiabilityProblemVO
liabilityProblemVO
,
Integer
userAccountId
,
HttpServletRequest
request
)
{
RequirementsServiceDO
requirementsServiceDO
=
requirementsDao
.
customerDroneFlyerCancel
(
liabilityProblemVO
.
getRequirementsInfoId
());
RequirementsServiceDO
requirementsServiceDO
=
requirementsDao
.
customerDroneFlyerCancel
(
liabilityProblemVO
.
getRequirementsInfoId
());
RequirementsInfoDO
requirementsInfoDO
=
requirementsDao
.
customerPublisherCancel
(
liabilityProblemVO
.
getRequirementsInfoId
(),
userAccountId
);
RequirementsInfoDO
requirementsInfoDO
=
requirementsDao
.
customerPublisherCancel
(
liabilityProblemVO
.
getRequirementsInfoId
(),
userAccountId
);
liabilityProblemVO
.
setUserAccountId
(
userAccountId
);
liabilityProblemVO
.
setUserAccountId
(
userAccountId
);
if
(
requirementsInfoDO
.
getServiceFlowId
()
==
8
||
if
(
requirementsInfoDO
.
getServiceFlowId
()
==
8
||
requirementsInfoDO
.
getServiceFlowId
()==
6
||
requirementsInfoDO
.
getServiceFlowId
()
==
6
||
requirementsInfoDO
.
getServiceFlowId
()==
7
||
requirementsInfoDO
.
getServiceFlowId
()
==
7
||
requirementsInfoDO
.
getServiceFlowId
()==
5
)
{
requirementsInfoDO
.
getServiceFlowId
()
==
5
)
{
return
ResultBody
.
error
(
"客服不能介入当前状态"
);
return
ResultBody
.
error
(
"客服不能介入当前状态"
);
}
}
if
(
requirementsServiceDO
==
null
)
{
if
(
requirementsServiceDO
==
null
)
{
return
ResultBody
.
error
(
"没有人抢单不能判定责任"
);
return
ResultBody
.
error
(
"没有人抢单不能判定责任"
);
}
}
int
i
=
requirementsDao
.
selectCustomer
(
liabilityProblemVO
.
getRequirementsInfoId
());
int
i
=
requirementsDao
.
selectCustomer
(
liabilityProblemVO
.
getRequirementsInfoId
());
if
(
i
!=
0
)
{
if
(
i
!=
0
)
{
return
ResultBody
.
error
(
"请勿重复判定"
);
return
ResultBody
.
error
(
"请勿重复判定"
);
}
}
requirementsDao
.
customerServiceIntervention
(
liabilityProblemVO
);
requirementsDao
.
customerServiceIntervention
(
liabilityProblemVO
);
//双方无责
//双方无责
if
(
liabilityProblemVO
.
getDuty
().
equals
(
1
)){
if
(
liabilityProblemVO
.
getDuty
().
equals
(
1
))
{
requirementsDao
.
updateInfo
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateInfo
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateScene
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateScene
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
WalletFlowVO
walletFlowVO
=
new
WalletFlowVO
();
WalletFlowVO
walletFlowVO
=
new
WalletFlowVO
();
...
@@ -1327,7 +1327,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1327,7 +1327,7 @@ public class RequirementsServiceImpl implements RequirementsService {
}
}
//退发布者费用
//退发布者费用
if
(
requirementsInfoDO
.
getWechatPayOrderNumber
()
!=
null
)
{
if
(
requirementsInfoDO
.
getWechatPayOrderNumber
()
!=
null
)
{
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
applyRefundVO
.
setReason
(
"客服介入退款"
);
applyRefundVO
.
setReason
(
"客服介入退款"
);
applyRefundVO
.
setRefund
(
requirementsInfoDO
.
getWeChat
().
multiply
(
new
BigDecimal
(
100
)).
longValue
());
applyRefundVO
.
setRefund
(
requirementsInfoDO
.
getWeChat
().
multiply
(
new
BigDecimal
(
100
)).
longValue
());
...
@@ -1335,7 +1335,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1335,7 +1335,7 @@ public class RequirementsServiceImpl implements RequirementsService {
applyRefund
(
applyRefundVO
,
request
.
getHeader
(
"token"
));
applyRefund
(
applyRefundVO
,
request
.
getHeader
(
"token"
));
}
}
//退飞手费用
//退飞手费用
if
(
requirementsServiceDO
.
getWechatPayOrderNumber
()
!=
null
)
{
if
(
requirementsServiceDO
.
getWechatPayOrderNumber
()
!=
null
)
{
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
applyRefundVO
.
setReason
(
"客服介入退款"
);
applyRefundVO
.
setReason
(
"客服介入退款"
);
applyRefundVO
.
setRefund
(
requirementsServiceDO
.
getWeChat
().
multiply
(
new
BigDecimal
(
100
)).
longValue
());
applyRefundVO
.
setRefund
(
requirementsServiceDO
.
getWeChat
().
multiply
(
new
BigDecimal
(
100
)).
longValue
());
...
@@ -1343,10 +1343,10 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1343,10 +1343,10 @@ public class RequirementsServiceImpl implements RequirementsService {
applyRefund
(
applyRefundVO
,
request
.
getHeader
(
"token"
));
applyRefund
(
applyRefundVO
,
request
.
getHeader
(
"token"
));
}
}
//退云享金及余额
//退云享金及余额
if
(
requirementsInfoDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
if
(
requirementsInfoDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
requirementsInfoDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
||
requirementsInfoDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
requirementsServiceDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
||
requirementsServiceDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
requirementsServiceDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
)
{
requirementsServiceDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
publisherWalletFlowVO
.
setModeOfPayment
(
500
);
publisherWalletFlowVO
.
setModeOfPayment
(
500
);
publisherWalletFlowVO
.
setUserAccountId
(
requirementsInfoDO
.
getUserAccountId
());
publisherWalletFlowVO
.
setUserAccountId
(
requirementsInfoDO
.
getUserAccountId
());
...
@@ -1363,7 +1363,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1363,7 +1363,7 @@ public class RequirementsServiceImpl implements RequirementsService {
walletFlowVO
.
setPublisherWalletFlowVO
(
publisherWalletFlowVO
);
walletFlowVO
.
setPublisherWalletFlowVO
(
publisherWalletFlowVO
);
walletFlowVO
.
setFlyerWalletFlowVO
(
flyerWalletFlowVO
);
walletFlowVO
.
setFlyerWalletFlowVO
(
flyerWalletFlowVO
);
flyerCancel
(
walletFlowVO
,
request
.
getHeader
(
"token"
));
flyerCancel
(
walletFlowVO
,
request
.
getHeader
(
"token"
));
//给发布者或者飞手发送信息
//给发布者或者飞手发送信息
this
.
publicSendMsgPublishInfoAuth
(
requirementsServiceDO
);
this
.
publicSendMsgPublishInfoAuth
(
requirementsServiceDO
);
...
@@ -1373,17 +1373,17 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1373,17 +1373,17 @@ public class RequirementsServiceImpl implements RequirementsService {
}
}
}
}
//发布者责任
//发布者责任
if
(
liabilityProblemVO
.
getDuty
().
equals
(
2
)){
if
(
liabilityProblemVO
.
getDuty
().
equals
(
2
))
{
// publisherCancel(liabilityProblemVO.getRequirementsInfoId(),requirementsInfoDO.getUserAccountId(),request);
// publisherCancel(liabilityProblemVO.getRequirementsInfoId(),requirementsInfoDO.getUserAccountId(),request);
publisherCancelDuty
(
liabilityProblemVO
.
getRequirementsInfoId
(),
requirementsInfoDO
.
getUserAccountId
(),
request
);
publisherCancelDuty
(
liabilityProblemVO
.
getRequirementsInfoId
(),
requirementsInfoDO
.
getUserAccountId
(),
request
);
requirementsDao
.
updateInfo
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateInfo
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateScene
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateScene
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
return
ResultBody
.
success
();
return
ResultBody
.
success
();
}
}
//飞手责任
//飞手责任
if
(
liabilityProblemVO
.
getDuty
().
equals
(
3
)){
if
(
liabilityProblemVO
.
getDuty
().
equals
(
3
))
{
// droneFlyerCancel(liabilityProblemVO.getRequirementsInfoId(),requirementsServiceDO.getPilotCertificationUserId(),request);
// droneFlyerCancel(liabilityProblemVO.getRequirementsInfoId(),requirementsServiceDO.getPilotCertificationUserId(),request);
droneFlyerCancelDuty
(
liabilityProblemVO
.
getRequirementsInfoId
(),
requirementsServiceDO
.
getPilotCertificationUserId
(),
request
);
droneFlyerCancelDuty
(
liabilityProblemVO
.
getRequirementsInfoId
(),
requirementsServiceDO
.
getPilotCertificationUserId
(),
request
);
requirementsDao
.
updateInfo
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateInfo
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateScene
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
requirementsDao
.
updateScene
(
liabilityProblemVO
.
getRequirementsInfoId
(),
7
);
return
ResultBody
.
success
();
return
ResultBody
.
success
();
...
@@ -1391,7 +1391,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1391,7 +1391,7 @@ public class RequirementsServiceImpl implements RequirementsService {
return
ResultBody
.
success
();
return
ResultBody
.
success
();
}
}
public
ResultBody
publisherCancelDuty
(
Integer
requirementsInfoId
,
Integer
userAccountId
,
HttpServletRequest
request
)
{
public
ResultBody
publisherCancelDuty
(
Integer
requirementsInfoId
,
Integer
userAccountId
,
HttpServletRequest
request
)
{
RequirementsInfoDO
requirementsInfoDO
=
requirementsDao
.
publisherCancel
(
requirementsInfoId
,
userAccountId
);
RequirementsInfoDO
requirementsInfoDO
=
requirementsDao
.
publisherCancel
(
requirementsInfoId
,
userAccountId
);
RequirementsServiceDO
serviceDO
=
requirementsDao
.
serviceReq
(
requirementsInfoId
);
RequirementsServiceDO
serviceDO
=
requirementsDao
.
serviceReq
(
requirementsInfoId
);
if
(
serviceDO
!=
null
)
{
if
(
serviceDO
!=
null
)
{
...
@@ -1534,13 +1534,13 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1534,13 +1534,13 @@ public class RequirementsServiceImpl implements RequirementsService {
if
(
serviceDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
if
(
serviceDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
serviceDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
serviceDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
serviceDO
.
getWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
serviceDO
.
getWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
requirementsInfoDO
.
getLevelCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
requirementsInfoDO
.
getLevelCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
requirementsInfoDO
.
getLevelSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
)
{
requirementsInfoDO
.
getLevelSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
if
(
requirementsInfoDO
.
getOrderLevel
().
equals
(
"RUSH_ORDER"
))
{
if
(
requirementsInfoDO
.
getOrderLevel
().
equals
(
"RUSH_ORDER"
))
{
publisherWalletFlowVO
.
setUrgentYxjAmount
(
requirementsInfoDO
.
getLevelCashAmount
().
negate
());
publisherWalletFlowVO
.
setUrgentYxjAmount
(
requirementsInfoDO
.
getLevelCashAmount
().
negate
());
publisherWalletFlowVO
.
setUrgentSalaryAmount
(
requirementsInfoDO
.
getLevelSalaryAmount
().
negate
());
publisherWalletFlowVO
.
setUrgentSalaryAmount
(
requirementsInfoDO
.
getLevelSalaryAmount
().
negate
());
}
}
if
(
requirementsInfoDO
.
getOrderLevel
().
equals
(
"TOP_ORDER"
))
{
if
(
requirementsInfoDO
.
getOrderLevel
().
equals
(
"TOP_ORDER"
))
{
publisherWalletFlowVO
.
setTopYxjAmount
(
requirementsInfoDO
.
getLevelCashAmount
().
negate
());
publisherWalletFlowVO
.
setTopYxjAmount
(
requirementsInfoDO
.
getLevelCashAmount
().
negate
());
publisherWalletFlowVO
.
setTopSalaryAmount
(
requirementsInfoDO
.
getLevelSalaryAmount
().
negate
());
publisherWalletFlowVO
.
setTopSalaryAmount
(
requirementsInfoDO
.
getLevelSalaryAmount
().
negate
());
}
}
...
@@ -1585,8 +1585,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1585,8 +1585,7 @@ public class RequirementsServiceImpl implements RequirementsService {
}
}
public
ResultBody
droneFlyerCancelDuty
(
Integer
requirementsInfoId
,
Integer
userAccountId
,
HttpServletRequest
request
)
{
public
ResultBody
droneFlyerCancelDuty
(
Integer
requirementsInfoId
,
Integer
userAccountId
,
HttpServletRequest
request
){
RequirementsInfoDO
infoDO
=
requirementsDao
.
publisherCancelFlyer
(
requirementsInfoId
);
RequirementsInfoDO
infoDO
=
requirementsDao
.
publisherCancelFlyer
(
requirementsInfoId
);
RequirementsServiceDO
requirementsServiceDO
=
requirementsDao
.
droneFlyerCancel
(
requirementsInfoId
,
userAccountId
);
RequirementsServiceDO
requirementsServiceDO
=
requirementsDao
.
droneFlyerCancel
(
requirementsInfoId
,
userAccountId
);
IsNullConvertZeroUtil
.
checkIsNull
(
requirementsServiceDO
);
IsNullConvertZeroUtil
.
checkIsNull
(
requirementsServiceDO
);
...
@@ -1734,6 +1733,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1734,6 +1733,7 @@ public class RequirementsServiceImpl implements RequirementsService {
/**
/**
* 给飞手短信
* 给飞手短信
*
* @param requirementsServiceDO
* @param requirementsServiceDO
*/
*/
private
void
publicSendMsgPublishInfoAuth
(
RequirementsServiceDO
requirementsServiceDO
)
{
private
void
publicSendMsgPublishInfoAuth
(
RequirementsServiceDO
requirementsServiceDO
)
{
...
@@ -1953,9 +1953,9 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1953,9 +1953,9 @@ public class RequirementsServiceImpl implements RequirementsService {
publisherWalletFlowVO
.
setUserAccountId
(
amountUpdateDO
.
getUserAccountId
());
publisherWalletFlowVO
.
setUserAccountId
(
amountUpdateDO
.
getUserAccountId
());
publisherWalletFlowVO
.
setOperateUserAccountId
(
amountUpdateDO
.
getUserAccountId
());
publisherWalletFlowVO
.
setOperateUserAccountId
(
amountUpdateDO
.
getUserAccountId
());
String
wechatPayOrderNumber
=
amountUpdateDO
.
getWechatPayOrderNumber
();
String
wechatPayOrderNumber
=
amountUpdateDO
.
getWechatPayOrderNumber
();
if
(
wechatPayOrderNumber
!=
null
)
{
if
(
wechatPayOrderNumber
!=
null
)
{
UserPayInfoVO
userPayInfoVO
=
queryUserPayInfo
(
amountUpdateDO
.
getWechatPayOrderNumber
(),
request
);
UserPayInfoVO
userPayInfoVO
=
queryUserPayInfo
(
amountUpdateDO
.
getWechatPayOrderNumber
(),
request
);
if
(!
userPayInfoVO
.
getTradeState
().
equals
(
"SUCCESS"
)){
if
(!
userPayInfoVO
.
getTradeState
().
equals
(
"SUCCESS"
))
{
return
ResultBody
.
error
(
"支付失败,请重新支付"
);
return
ResultBody
.
error
(
"支付失败,请重新支付"
);
}
}
}
}
...
@@ -1968,16 +1968,16 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -1968,16 +1968,16 @@ public class RequirementsServiceImpl implements RequirementsService {
requirementsDao
.
updateScene
(
amountVO
.
getRequirementsInfoId
(),
8
);
requirementsDao
.
updateScene
(
amountVO
.
getRequirementsInfoId
(),
8
);
requirementsDao
.
updateInfo
(
amountVO
.
getRequirementsInfoId
(),
8
);
requirementsDao
.
updateInfo
(
amountVO
.
getRequirementsInfoId
(),
8
);
int
amountUpdate
=
requirementsDao
.
findAmountUpdate
(
amountUpdateDO
.
getRequirementsInfoId
());
int
amountUpdate
=
requirementsDao
.
findAmountUpdate
(
amountUpdateDO
.
getRequirementsInfoId
());
if
(
amountUpdate
!=
0
)
{
if
(
amountUpdate
!=
0
)
{
return
ResultBody
.
error
(
"只能修改一次不能重复修改"
);
return
ResultBody
.
error
(
"只能修改一次不能重复修改"
);
}
else
{
}
else
{
requirementsDao
.
requirementsAmountUpdate
(
amountUpdateDO
);
requirementsDao
.
requirementsAmountUpdate
(
amountUpdateDO
);
}
}
if
(
amountUpdateDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
if
(
amountUpdateDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
amountUpdateDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
)
{
amountUpdateDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
walletFlowVO
.
setPublisherWalletFlowVO
(
publisherWalletFlowVO
);
walletFlowVO
.
setPublisherWalletFlowVO
(
publisherWalletFlowVO
);
flyerCancelNO
(
walletFlowVO
,
request
.
getHeader
(
"token"
));
flyerCancelNO
(
walletFlowVO
,
request
.
getHeader
(
"token"
));
}
}
//倒计时
//倒计时
...
@@ -2001,7 +2001,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2001,7 +2001,7 @@ public class RequirementsServiceImpl implements RequirementsService {
}
}
@Override
@Override
public
ResultBody
confirmSettlement
(
Integer
userAccountId
,
Integer
requirementsInfoId
,
HttpServletRequest
request
)
{
public
ResultBody
confirmSettlement
(
Integer
userAccountId
,
Integer
requirementsInfoId
,
HttpServletRequest
request
)
{
RequirementsInfoDO
requirementsInfoDO
=
requirementsDao
.
publisherCancelFlyers
(
requirementsInfoId
);
RequirementsInfoDO
requirementsInfoDO
=
requirementsDao
.
publisherCancelFlyers
(
requirementsInfoId
);
ServiceSettleAccountsVO
settleAccountsVO
=
new
ServiceSettleAccountsVO
();
ServiceSettleAccountsVO
settleAccountsVO
=
new
ServiceSettleAccountsVO
();
settleAccountsVO
.
setRequirementsInfoId
(
requirementsInfoId
);
settleAccountsVO
.
setRequirementsInfoId
(
requirementsInfoId
);
...
@@ -2018,9 +2018,9 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2018,9 +2018,9 @@ public class RequirementsServiceImpl implements RequirementsService {
if
(
requirementsInfoDO
==
null
)
{
if
(
requirementsInfoDO
==
null
)
{
return
ResultBody
.
error
(
"结算失败"
);
return
ResultBody
.
error
(
"结算失败"
);
}
}
BigDecimal
earnings
=
BigDecimal
.
ZERO
;
BigDecimal
earnings
=
BigDecimal
.
ZERO
;
//修改金额
//修改金额
if
(
updateAmount
!=
null
)
{
if
(
updateAmount
!=
null
)
{
//继续支付需要扣除金额
//继续支付需要扣除金额
IsNullConvertZeroUtil
.
checkIsNull
(
updateAmount
);
IsNullConvertZeroUtil
.
checkIsNull
(
updateAmount
);
publisherWalletFlowVO
.
setCashAmount
(
requirementsInfoDO
.
getCashAmount
().
negate
());
publisherWalletFlowVO
.
setCashAmount
(
requirementsInfoDO
.
getCashAmount
().
negate
());
...
@@ -2028,8 +2028,8 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2028,8 +2028,8 @@ public class RequirementsServiceImpl implements RequirementsService {
publisherWalletFlowVO
.
setUserAccountId
(
requirementsInfoDO
.
getUserAccountId
());
publisherWalletFlowVO
.
setUserAccountId
(
requirementsInfoDO
.
getUserAccountId
());
publisherWalletFlowVO
.
setOperateUserAccountId
(
userAccountId
);
publisherWalletFlowVO
.
setOperateUserAccountId
(
userAccountId
);
publisherWalletFlowVO
.
setModeOfPayment
(
1000
);
publisherWalletFlowVO
.
setModeOfPayment
(
1000
);
if
(
updateAmount
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
if
(
updateAmount
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
updateAmount
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
)
{
updateAmount
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
BigDecimal
cash
=
publisherWalletFlowVO
.
getCashAmount
().
negate
();
BigDecimal
cash
=
publisherWalletFlowVO
.
getCashAmount
().
negate
();
BigDecimal
salary
=
publisherWalletFlowVO
.
getSalaryAmount
().
negate
();
BigDecimal
salary
=
publisherWalletFlowVO
.
getSalaryAmount
().
negate
();
...
@@ -2040,12 +2040,13 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2040,12 +2040,13 @@ public class RequirementsServiceImpl implements RequirementsService {
// publisherWalletFlowVO.setRefundSalaryAmount(updateAmount.getSalaryAmount().negate());
// publisherWalletFlowVO.setRefundSalaryAmount(updateAmount.getSalaryAmount().negate());
//publisherWalletFlowVO.setRefundCashAmount(updateAmount.getCashAmount().negate());
//publisherWalletFlowVO.setRefundCashAmount(updateAmount.getCashAmount().negate());
}
if
(
updateAmount
.
getReturnCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
||
}
updateAmount
.
getReturnSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
){
if
(
updateAmount
.
getReturnCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
updateAmount
.
getReturnSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
publisherWalletFlowVO
.
setRefundCashAmount
(
updateAmount
.
getReturnCashAmount
());
publisherWalletFlowVO
.
setRefundCashAmount
(
updateAmount
.
getReturnCashAmount
());
publisherWalletFlowVO
.
setRefundSalaryAmount
(
updateAmount
.
getReturnSalaryAmount
());
publisherWalletFlowVO
.
setRefundSalaryAmount
(
updateAmount
.
getReturnSalaryAmount
());
}
}
if
(
updateAmount
.
getReturnWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
if
(
updateAmount
.
getReturnWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
applyRefundVO
.
setReason
(
"飞手确认退款"
);
applyRefundVO
.
setReason
(
"飞手确认退款"
);
applyRefundVO
.
setOutTradeNo
(
updateAmount
.
getWechatPayOrderNumber
());
applyRefundVO
.
setOutTradeNo
(
updateAmount
.
getWechatPayOrderNumber
());
...
@@ -2068,7 +2069,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2068,7 +2069,7 @@ public class RequirementsServiceImpl implements RequirementsService {
flyerWalletFlowVO
.
setOperateUserAccountId
(
userAccountId
);
flyerWalletFlowVO
.
setOperateUserAccountId
(
userAccountId
);
flyerWalletFlowVO
.
setModeOfPayment
(
1000
);
flyerWalletFlowVO
.
setModeOfPayment
(
1000
);
if
(
serviceDO
.
getWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
if
(
serviceDO
.
getWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
applyRefundVO
.
setReason
(
"原路退回"
);
applyRefundVO
.
setReason
(
"原路退回"
);
applyRefundVO
.
setOutTradeNo
(
serviceDO
.
getWechatPayOrderNumber
());
applyRefundVO
.
setOutTradeNo
(
serviceDO
.
getWechatPayOrderNumber
());
...
@@ -2081,10 +2082,10 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2081,10 +2082,10 @@ public class RequirementsServiceImpl implements RequirementsService {
walletFlowVO
.
setPublisherWalletFlowVO
(
publisherWalletFlowVO
);
walletFlowVO
.
setPublisherWalletFlowVO
(
publisherWalletFlowVO
);
walletFlowVO
.
setFlyerWalletFlowVO
(
flyerWalletFlowVO
);
walletFlowVO
.
setFlyerWalletFlowVO
(
flyerWalletFlowVO
);
flyerCancelNO
(
walletFlowVO
,
request
.
getHeader
(
"token"
));
flyerCancelNO
(
walletFlowVO
,
request
.
getHeader
(
"token"
));
BigDecimal
orderEarnings
=
requirementsInfoDO
.
getOrderEarnings
();
BigDecimal
orderEarnings
=
requirementsInfoDO
.
getOrderEarnings
();
BigDecimal
add
=
orderEarnings
.
add
(
earnings
);
BigDecimal
add
=
orderEarnings
.
add
(
earnings
);
requirementsDao
.
updateOrderEarnings
(
add
,
requirementsInfoId
);
requirementsDao
.
updateOrderEarnings
(
add
,
requirementsInfoId
);
requirementsDao
.
updateInfo
(
requirementsInfoId
,
5
);
requirementsDao
.
updateInfo
(
requirementsInfoId
,
5
);
requirementsDao
.
updateScene
(
requirementsInfoId
,
5
);
requirementsDao
.
updateScene
(
requirementsInfoId
,
5
);
return
ResultBody
.
success
();
return
ResultBody
.
success
();
...
@@ -2354,57 +2355,57 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2354,57 +2355,57 @@ public class RequirementsServiceImpl implements RequirementsService {
IsNullConvertZeroUtil
.
checkIsNull
(
serviceDO
);
IsNullConvertZeroUtil
.
checkIsNull
(
serviceDO
);
IsNullConvertZeroUtil
.
checkIsNull
(
requirementsInfoDO
);
IsNullConvertZeroUtil
.
checkIsNull
(
requirementsInfoDO
);
if
(
requirementsInfoDO
.
getServiceFlowId
()
==
5
)
{
if
(
requirementsInfoDO
.
getServiceFlowId
()
==
5
)
{
return
ResultBody
.
error
(
"已结算"
);
return
ResultBody
.
error
(
"已结算"
);
}
}
if
(
requirementsInfoDO
==
null
)
{
if
(
requirementsInfoDO
==
null
)
{
return
ResultBody
.
error
(
"结算失败"
);
return
ResultBody
.
error
(
"结算失败"
);
}
}
BigDecimal
earnings
=
BigDecimal
.
ZERO
;
BigDecimal
earnings
=
BigDecimal
.
ZERO
;
//修改金额
//修改金额
if
(
updateAmount
!=
null
)
{
if
(
updateAmount
!=
null
)
{
//继续支付需要扣除金额
//继续支付需要扣除金额
IsNullConvertZeroUtil
.
checkIsNull
(
updateAmount
);
IsNullConvertZeroUtil
.
checkIsNull
(
updateAmount
);
if
(
updateAmount
.
getUpdateOrderAmount
().
compareTo
(
updateAmount
.
getOrderAmount
())
==-
1
)
{
if
(
updateAmount
.
getUpdateOrderAmount
().
compareTo
(
updateAmount
.
getOrderAmount
())
==
-
1
)
{
if
(
updateAmount
.
getReturnSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
if
(
updateAmount
.
getReturnSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
BigDecimal
orderAmount
=
updateAmount
.
getOrderAmount
();
BigDecimal
orderAmount
=
updateAmount
.
getOrderAmount
();
BigDecimal
returnSalaryAmount
=
updateAmount
.
getReturnSalaryAmount
();
BigDecimal
returnSalaryAmount
=
updateAmount
.
getReturnSalaryAmount
();
BigDecimal
subtract
=
orderAmount
.
subtract
(
returnSalaryAmount
);
BigDecimal
subtract
=
orderAmount
.
subtract
(
returnSalaryAmount
);
publisherWalletFlowVO
.
setSalaryAmount
(
subtract
.
negate
());
publisherWalletFlowVO
.
setSalaryAmount
(
subtract
.
negate
());
if
(
requirementsInfoDO
.
getSalaryAmount
().
compareTo
(
updateAmount
.
getReturnSalaryAmount
())
==
0
)
{
if
(
requirementsInfoDO
.
getSalaryAmount
().
compareTo
(
updateAmount
.
getReturnSalaryAmount
())
==
0
)
{
publisherWalletFlowVO
.
setSalaryAmount
(
BigDecimal
.
ZERO
);
publisherWalletFlowVO
.
setSalaryAmount
(
BigDecimal
.
ZERO
);
}
}
if
(
requirementsInfoDO
.
getSalaryAmount
().
compareTo
(
updateAmount
.
getReturnSalaryAmount
())
==
1
)
{
if
(
requirementsInfoDO
.
getSalaryAmount
().
compareTo
(
updateAmount
.
getReturnSalaryAmount
())
==
1
)
{
publisherWalletFlowVO
.
setSalaryAmount
(
requirementsInfoDO
.
getSalaryAmount
().
subtract
(
updateAmount
.
getReturnSalaryAmount
()).
negate
());
publisherWalletFlowVO
.
setSalaryAmount
(
requirementsInfoDO
.
getSalaryAmount
().
subtract
(
updateAmount
.
getReturnSalaryAmount
()).
negate
());
}
}
}
else
{
}
else
{
publisherWalletFlowVO
.
setSalaryAmount
(
requirementsInfoDO
.
getSalaryAmount
().
negate
());
publisherWalletFlowVO
.
setSalaryAmount
(
requirementsInfoDO
.
getSalaryAmount
().
negate
());
}
}
if
(
updateAmount
.
getReturnCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
if
(
updateAmount
.
getReturnCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
BigDecimal
orderAmount
=
updateAmount
.
getOrderAmount
();
BigDecimal
orderAmount
=
updateAmount
.
getOrderAmount
();
BigDecimal
returnCashAmount
=
updateAmount
.
getReturnCashAmount
();
BigDecimal
returnCashAmount
=
updateAmount
.
getReturnCashAmount
();
BigDecimal
subtract
=
orderAmount
.
subtract
(
returnCashAmount
);
BigDecimal
subtract
=
orderAmount
.
subtract
(
returnCashAmount
);
publisherWalletFlowVO
.
setCashAmount
(
subtract
.
negate
());
publisherWalletFlowVO
.
setCashAmount
(
subtract
.
negate
());
if
(
requirementsInfoDO
.
getCashAmount
().
compareTo
(
updateAmount
.
getReturnCashAmount
())
==
0
)
{
if
(
requirementsInfoDO
.
getCashAmount
().
compareTo
(
updateAmount
.
getReturnCashAmount
())
==
0
)
{
publisherWalletFlowVO
.
setCashAmount
(
BigDecimal
.
ZERO
);
publisherWalletFlowVO
.
setCashAmount
(
BigDecimal
.
ZERO
);
}
}
if
(
updateAmount
.
getReturnCashAmount
().
compareTo
(
requirementsInfoDO
.
getCashAmount
())
==-
1
)
{
if
(
updateAmount
.
getReturnCashAmount
().
compareTo
(
requirementsInfoDO
.
getCashAmount
())
==
-
1
)
{
BigDecimal
cashAmount
=
requirementsInfoDO
.
getCashAmount
();
BigDecimal
cashAmount
=
requirementsInfoDO
.
getCashAmount
();
BigDecimal
returnCashAmount1
=
updateAmount
.
getReturnCashAmount
();
BigDecimal
returnCashAmount1
=
updateAmount
.
getReturnCashAmount
();
BigDecimal
subtract1
=
cashAmount
.
subtract
(
returnCashAmount1
);
BigDecimal
subtract1
=
cashAmount
.
subtract
(
returnCashAmount1
);
publisherWalletFlowVO
.
setCashAmount
(
subtract1
.
negate
());
publisherWalletFlowVO
.
setCashAmount
(
subtract1
.
negate
());
}
}
}
else
{
}
else
{
publisherWalletFlowVO
.
setCashAmount
(
requirementsInfoDO
.
getCashAmount
().
negate
());
publisherWalletFlowVO
.
setCashAmount
(
requirementsInfoDO
.
getCashAmount
().
negate
());
}
}
}
}
if
(
updateAmount
.
getUpdateOrderAmount
().
compareTo
(
updateAmount
.
getOrderAmount
())
==
1
)
{
if
(
updateAmount
.
getUpdateOrderAmount
().
compareTo
(
updateAmount
.
getOrderAmount
())
==
1
)
{
publisherWalletFlowVO
.
setSalaryAmount
(
requirementsInfoDO
.
getSalaryAmount
().
negate
());
publisherWalletFlowVO
.
setSalaryAmount
(
requirementsInfoDO
.
getSalaryAmount
().
negate
());
publisherWalletFlowVO
.
setCashAmount
(
requirementsInfoDO
.
getCashAmount
().
negate
());
publisherWalletFlowVO
.
setCashAmount
(
requirementsInfoDO
.
getCashAmount
().
negate
());
}
}
...
@@ -2412,8 +2413,8 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2412,8 +2413,8 @@ public class RequirementsServiceImpl implements RequirementsService {
publisherWalletFlowVO
.
setUserAccountId
(
requirementsInfoDO
.
getUserAccountId
());
publisherWalletFlowVO
.
setUserAccountId
(
requirementsInfoDO
.
getUserAccountId
());
publisherWalletFlowVO
.
setOperateUserAccountId
(
agreeVO
.
getUserAccountId
());
publisherWalletFlowVO
.
setOperateUserAccountId
(
agreeVO
.
getUserAccountId
());
publisherWalletFlowVO
.
setModeOfPayment
(
1000
);
publisherWalletFlowVO
.
setModeOfPayment
(
1000
);
if
(
updateAmount
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
if
(
updateAmount
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
updateAmount
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
updateAmount
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
BigDecimal
cash
=
publisherWalletFlowVO
.
getCashAmount
().
negate
();
BigDecimal
cash
=
publisherWalletFlowVO
.
getCashAmount
().
negate
();
BigDecimal
salary
=
publisherWalletFlowVO
.
getSalaryAmount
().
negate
();
BigDecimal
salary
=
publisherWalletFlowVO
.
getSalaryAmount
().
negate
();
...
@@ -2424,12 +2425,13 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2424,12 +2425,13 @@ public class RequirementsServiceImpl implements RequirementsService {
// publisherWalletFlowVO.setRefundSalaryAmount(updateAmount.getSalaryAmount().negate());
// publisherWalletFlowVO.setRefundSalaryAmount(updateAmount.getSalaryAmount().negate());
//publisherWalletFlowVO.setRefundCashAmount(updateAmount.getCashAmount().negate());
//publisherWalletFlowVO.setRefundCashAmount(updateAmount.getCashAmount().negate());
}
if
(
updateAmount
.
getReturnCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
||
}
updateAmount
.
getReturnSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)!=
0
){
if
(
updateAmount
.
getReturnCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
updateAmount
.
getReturnSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
publisherWalletFlowVO
.
setRefundCashAmount
(
updateAmount
.
getReturnCashAmount
());
publisherWalletFlowVO
.
setRefundCashAmount
(
updateAmount
.
getReturnCashAmount
());
publisherWalletFlowVO
.
setRefundSalaryAmount
(
updateAmount
.
getReturnSalaryAmount
());
publisherWalletFlowVO
.
setRefundSalaryAmount
(
updateAmount
.
getReturnSalaryAmount
());
}
}
if
(
updateAmount
.
getReturnWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
if
(
updateAmount
.
getReturnWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
applyRefundVO
.
setReason
(
"飞手确认退款"
);
applyRefundVO
.
setReason
(
"飞手确认退款"
);
applyRefundVO
.
setOutTradeNo
(
requirementsInfoDO
.
getWechatPayOrderNumber
());
applyRefundVO
.
setOutTradeNo
(
requirementsInfoDO
.
getWechatPayOrderNumber
());
...
@@ -2438,7 +2440,6 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2438,7 +2440,6 @@ public class RequirementsServiceImpl implements RequirementsService {
}
}
//给飞手金额
//给飞手金额
BigDecimal
updateOrderAmount
=
updateAmount
.
getUpdateOrderAmount
();
BigDecimal
updateOrderAmount
=
updateAmount
.
getUpdateOrderAmount
();
...
@@ -2457,7 +2458,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2457,7 +2458,7 @@ public class RequirementsServiceImpl implements RequirementsService {
/**
/**
* 退飞手金额
* 退飞手金额
*/
*/
if
(
serviceDO
.
getWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
if
(
serviceDO
.
getWeChat
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
)
{
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
ApplyRefundVO
applyRefundVO
=
new
ApplyRefundVO
();
applyRefundVO
.
setReason
(
"原路退回"
);
applyRefundVO
.
setReason
(
"原路退回"
);
applyRefundVO
.
setOutTradeNo
(
serviceDO
.
getWechatPayOrderNumber
());
applyRefundVO
.
setOutTradeNo
(
serviceDO
.
getWechatPayOrderNumber
());
...
@@ -2470,18 +2471,16 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2470,18 +2471,16 @@ public class RequirementsServiceImpl implements RequirementsService {
walletFlowVO
.
setPublisherWalletFlowVO
(
publisherWalletFlowVO
);
walletFlowVO
.
setPublisherWalletFlowVO
(
publisherWalletFlowVO
);
walletFlowVO
.
setFlyerWalletFlowVO
(
flyerWalletFlowVO
);
walletFlowVO
.
setFlyerWalletFlowVO
(
flyerWalletFlowVO
);
flyerCancelNO
(
walletFlowVO
,
request
.
getHeader
(
"token"
));
flyerCancelNO
(
walletFlowVO
,
request
.
getHeader
(
"token"
));
BigDecimal
orderEarnings
=
requirementsInfoDO
.
getOrderEarnings
();
BigDecimal
orderEarnings
=
requirementsInfoDO
.
getOrderEarnings
();
BigDecimal
add
=
orderEarnings
.
add
(
earnings
);
BigDecimal
add
=
orderEarnings
.
add
(
earnings
);
requirementsDao
.
updateOrderEarnings
(
add
,
agreeVO
.
getRequirementsInfoId
());
requirementsDao
.
updateOrderEarnings
(
add
,
agreeVO
.
getRequirementsInfoId
());
requirementsDao
.
updateInfo
(
agreeVO
.
getRequirementsInfoId
(),
5
);
requirementsDao
.
updateInfo
(
agreeVO
.
getRequirementsInfoId
(),
5
);
requirementsDao
.
updateScene
(
agreeVO
.
getRequirementsInfoId
(),
5
);
requirementsDao
.
updateScene
(
agreeVO
.
getRequirementsInfoId
(),
5
);
return
ResultBody
.
success
();
return
ResultBody
.
success
();
}
}
@Override
@Override
public
ResultBody
publishService
(
ServiceRequirementsVO
serviceRequirementsVO
,
HttpServletRequest
request
)
{
public
ResultBody
publishService
(
ServiceRequirementsVO
serviceRequirementsVO
,
HttpServletRequest
request
)
{
...
@@ -2762,7 +2761,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2762,7 +2761,7 @@ public class RequirementsServiceImpl implements RequirementsService {
requirementsDao
.
addPublishService
(
requirementsInfoDO
);
requirementsDao
.
addPublishService
(
requirementsInfoDO
);
RequirementsAmountDO
requirementsAmountDO
=
new
RequirementsAmountDO
(
requirementsInfoDO
);
RequirementsAmountDO
requirementsAmountDO
=
new
RequirementsAmountDO
(
requirementsInfoDO
);
requirementsDao
.
addAmount
(
requirementsAmountDO
);
requirementsDao
.
addAmount
(
requirementsAmountDO
);
if
(
sum
==
1
)
{
if
(
sum
==
1
)
{
requirementsDao
.
insertPlatformOrderEarnings
(
new
BigDecimal
(
0
),
requirementsInfoDO
.
getId
(),
0
);
requirementsDao
.
insertPlatformOrderEarnings
(
new
BigDecimal
(
0
),
requirementsInfoDO
.
getId
(),
0
);
if
(
requirementsAmountDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
if
(
requirementsAmountDO
.
getCashAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
requirementsAmountDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
||
requirementsAmountDO
.
getSalaryAmount
().
compareTo
(
BigDecimal
.
ZERO
)
!=
0
...
@@ -2771,7 +2770,7 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2771,7 +2770,7 @@ public class RequirementsServiceImpl implements RequirementsService {
feignWalletFlow
(
publisherWalletFlowVO
,
request
.
getHeader
(
"token"
));
feignWalletFlow
(
publisherWalletFlowVO
,
request
.
getHeader
(
"token"
));
}
}
return
ResultBody
.
success
();
return
ResultBody
.
success
();
}
else
{
}
else
{
//循环添加子订单
//循环添加子订单
for
(
int
i
=
0
;
i
<
sum
;
i
++)
{
for
(
int
i
=
0
;
i
<
sum
;
i
++)
{
ServiceRequirementsSonDO
requirementsSonDO
=
new
ServiceRequirementsSonDO
(
requirementsInfoDO
);
ServiceRequirementsSonDO
requirementsSonDO
=
new
ServiceRequirementsSonDO
(
requirementsInfoDO
);
...
@@ -2859,17 +2858,17 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2859,17 +2858,17 @@ public class RequirementsServiceImpl implements RequirementsService {
//这是这个订单所需要的总人数
//这是这个订单所需要的总人数
Integer
requireNum
=
grabTheOrderVO
.
getRequireNum
();
Integer
requireNum
=
grabTheOrderVO
.
getRequireNum
();
if
(
requireNum
==
null
||
grabTheOrderVO
.
getRequirementsInfoId
()
==
null
)
{
if
(
requireNum
==
null
||
grabTheOrderVO
.
getRequirementsInfoId
()
==
null
)
{
return
ResultBody
.
error
(
"参数不全"
);
return
ResultBody
.
error
(
"参数不全"
);
}
}
Integer
fatherRequireId
=
null
,
fatherRepertory
=
null
;
Integer
fatherRequireId
=
null
,
fatherRepertory
=
null
;
//requireNum >= 2就说明这个订单是分开的有子订单
//requireNum >= 2就说明这个订单是分开的有子订单
if
(
requireNum
>=
2
)
{
if
(
requireNum
>=
2
)
{
fatherRequireId
=
grabTheOrderVO
.
getRequirementsInfoId
();
fatherRequireId
=
grabTheOrderVO
.
getRequirementsInfoId
();
//不让同一个用户对一个多人订单重复下单
//不让同一个用户对一个多人订单重复下单
if
(
requirementsDao
.
selectBooleanByFatherIdAndUserId
(
fatherRequireId
,
grabTheOrderVO
.
getUserAccountId
())
>
0
)
{
if
(
requirementsDao
.
selectBooleanByFatherIdAndUserId
(
fatherRequireId
,
grabTheOrderVO
.
getUserAccountId
())
>
0
)
{
return
ResultBody
.
error
(
"不能重复抢一个订单"
);
return
ResultBody
.
error
(
"不能重复抢一个订单"
);
}
}
ServiceRequirementsDO
fatherRequirementsInfoDO
=
requirementsDao
.
grabTheOrder
(
fatherRequireId
);
ServiceRequirementsDO
fatherRequirementsInfoDO
=
requirementsDao
.
grabTheOrder
(
fatherRequireId
);
...
@@ -2884,10 +2883,10 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -2884,10 +2883,10 @@ public class RequirementsServiceImpl implements RequirementsService {
//获取没被抢的子订单id
//获取没被抢的子订单id
Integer
requirementsSonInfoId
=
requirementsDao
.
getRequirementsSonInfoId
(
fatherRequireId
);
Integer
requirementsSonInfoId
=
requirementsDao
.
getRequirementsSonInfoId
(
fatherRequireId
);
grabTheOrderVO
.
setRequirementsInfoId
(
requirementsSonInfoId
);
grabTheOrderVO
.
setRequirementsInfoId
(
requirementsSonInfoId
);
}
else
{
}
else
{
//单人被拒绝后也不能再次抢单
//单人被拒绝后也不能再次抢单
Integer
countRefuse
=
requirementsDao
.
selectRequirementsRefuse
(
grabTheOrderVO
.
getRequirementsInfoId
(),
grabTheOrderVO
.
getUserAccountId
());
Integer
countRefuse
=
requirementsDao
.
selectRequirementsRefuse
(
grabTheOrderVO
.
getRequirementsInfoId
(),
grabTheOrderVO
.
getUserAccountId
());
if
(
countRefuse
==
1
)
{
if
(
countRefuse
==
1
)
{
return
ResultBody
.
error
(
"不能重复抢一个订单"
);
return
ResultBody
.
error
(
"不能重复抢一个订单"
);
}
}
}
}
...
@@ -3016,11 +3015,14 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -3016,11 +3015,14 @@ public class RequirementsServiceImpl implements RequirementsService {
// walletFlow(flyerWalletFlowVO, request.getHeader("token"));
// walletFlow(flyerWalletFlowVO, request.getHeader("token"));
// }
// }
//如果是多人订单 还要去修改父订单还需多少人字段
//如果是多人订单 还要去修改父订单还需多少人字段
if
(
requireNum
>=
2
)
{
if
(
requireNum
>=
2
)
{
requirementsDao
.
updateRequirementsInfoRepertory
(
fatherRequireId
,
fatherRepertory
-
1
);
Integer
repertoryNeed
=
requirementsDao
.
selectRepertoryByRequireId
(
fatherRequireId
);
requirementsDao
.
updateRequirementsInfoRepertory
(
fatherRequireId
,
repertoryNeed
);
}
}
OnlyRequirementsInfoId
onlyRequirementsInfoId
=
new
OnlyRequirementsInfoId
();
onlyRequirementsInfoId
.
setRequirementsInfoId
(
grabTheOrderVO
.
getRequirementsInfoId
());
return
ResultBody
.
success
(
);
return
ResultBody
.
success
(
onlyRequirementsInfoId
);
// } else {
// } else {
// //云享金和佣金扣除完成,但是还不足支付订单金额,并且没有选择微信支付,所以支付不合法
// //云享金和佣金扣除完成,但是还不足支付订单金额,并且没有选择微信支付,所以支付不合法
// return ResultBody.success("抢单失败");
// return ResultBody.success("抢单失败");
...
@@ -3199,13 +3201,13 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -3199,13 +3201,13 @@ public class RequirementsServiceImpl implements RequirementsService {
if
(
agreeOrder
)
{
if
(
agreeOrder
)
{
requirementsDao
.
updateScene
(
requireId
,
2
);
requirementsDao
.
updateScene
(
requireId
,
2
);
requirementsDao
.
updateInfo
(
requireId
,
2
);
requirementsDao
.
updateInfo
(
requireId
,
2
);
}
else
{
}
else
{
//修改订单所需人数以及订单状态
//修改订单所需人数以及订单状态
requirementsDao
.
updateRequirementsInfoByRefusePilot
(
requireId
);
requirementsDao
.
updateRequirementsInfoByRefusePilot
(
requireId
);
Integer
fatherRequireId
=
requirementsDao
.
selectFatherRequireIdBySonId
(
requireId
);
Integer
fatherRequireId
=
requirementsDao
.
selectFatherRequireIdBySonId
(
requireId
);
Integer
repertory
=
requirementsDao
.
selectRepertoryByRequireId
(
fatherRequireId
);
Integer
repertory
=
requirementsDao
.
selectRepertoryByRequireId
(
fatherRequireId
);
requirementsDao
.
updateRequirementsInfoRepertory
(
fatherRequireId
,
repertory
);
requirementsDao
.
updateRequirementsInfoRepertory
(
fatherRequireId
,
repertory
);
requirementsDao
.
updateRequirementsService
(
requireId
,
param
.
getPilotCertificationUserId
());
requirementsDao
.
updateRequirementsService
(
requireId
,
param
.
getPilotCertificationUserId
());
//TODO 被拒绝后应该退回飞手的押金
//TODO 被拒绝后应该退回飞手的押金
}
}
...
@@ -3213,7 +3215,6 @@ public class RequirementsServiceImpl implements RequirementsService {
...
@@ -3213,7 +3215,6 @@ public class RequirementsServiceImpl implements RequirementsService {
}
}
public
UserAccountSimpleDTO
feignGetUserSimpleInfo
(
Integer
userAccountId
,
HttpServletRequest
request
)
{
public
UserAccountSimpleDTO
feignGetUserSimpleInfo
(
Integer
userAccountId
,
HttpServletRequest
request
)
{
String
token
=
request
.
getHeader
(
"token"
);
String
token
=
request
.
getHeader
(
"token"
);
HttpHeaders
headers
=
new
HttpHeaders
();
HttpHeaders
headers
=
new
HttpHeaders
();
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论