Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
M
mall-server
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
JIRA
JIRA
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
yimu
mall-server
Commits
5306c8ba
Commit
5306c8ba
authored
Mar 08, 2022
by
wlx@33.cn
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修正取消订单接口多次触发,修正用户资产记录状态枚举魔鬼数字
parent
ee22b299
Expand all
Show whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
62 additions
and
41 deletions
+62
-41
OrderServiceImpl.java
...all/server/admin/order/service/impl/OrderServiceImpl.java
+11
-11
UserAssetServiceImpl.java
...server/front/asset/service/impl/UserAssetServiceImpl.java
+7
-3
AssetRecordTypeEnum.java
.../com/fzm/mall/server/front/enums/AssetRecordTypeEnum.java
+4
-0
RewardConsumer.java
...com/fzm/mall/server/front/mq/consumer/RewardConsumer.java
+3
-1
DeliveryServiceImpl.java
.../server/front/order/service/impl/DeliveryServiceImpl.java
+7
-7
OrderServiceImpl.java
...all/server/front/order/service/impl/OrderServiceImpl.java
+27
-18
UserServiceImpl.java
.../mall/server/front/user/service/impl/UserServiceImpl.java
+3
-1
No files found.
mall-server-admin/src/main/java/com/fzm/mall/server/admin/order/service/impl/OrderServiceImpl.java
View file @
5306c8ba
...
@@ -133,17 +133,6 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
...
@@ -133,17 +133,6 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
}
}
/**
/**
* 商品订单退款-积分还原,商品币还原
* <p>
* 审核通过:1.币:根据order_detail的coin和number,将user_asset对应的冻结数量frozen扣除,通过链上方法还给商家
* 2.积分:根据order_info的amount,将积分还给买家
* 审核不通过:
* 1.币:根据order_detail的coin和number,将user_asset对应的冻结数量frozen扣除,加到可用资产amount
*
*/
integralDeduction
(
oid
,
order
.
getUid
(),
order
.
getAmount
(),
order
.
getMerchantId
(),
orderDetailList
,
isApproved
);
/**
* 更改order_refund中的记录状态
* 更改order_refund中的记录状态
*/
*/
synchroRefundReturnState
(
oid
,
isApproved
,
remark
);
synchroRefundReturnState
(
oid
,
isApproved
,
remark
);
...
@@ -163,6 +152,17 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
...
@@ -163,6 +152,17 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
*/
*/
OrderLog
log
=
new
OrderLog
(
oid
,
orderState
,
operation
,
adminId
,
remark
);
OrderLog
log
=
new
OrderLog
(
oid
,
orderState
,
operation
,
adminId
,
remark
);
orderLogService
.
save
(
log
);
orderLogService
.
save
(
log
);
/**
* 商品订单退款-积分还原,商品币还原
* <p>
* 审核通过:1.币:根据order_detail的coin和number,将user_asset对应的冻结数量frozen扣除,通过链上方法还给商家
* 2.积分:根据order_info的amount,将积分还给买家
* 审核不通过:
* 1.币:根据order_detail的coin和number,将user_asset对应的冻结数量frozen扣除,加到可用资产amount
*
*/
integralDeduction
(
oid
,
order
.
getUid
(),
order
.
getAmount
(),
order
.
getMerchantId
(),
orderDetailList
,
isApproved
);
}
}
/**
/**
...
...
mall-server-front/src/main/java/com/fzm/mall/server/front/asset/service/impl/UserAssetServiceImpl.java
View file @
5306c8ba
...
@@ -20,6 +20,7 @@ import com.fzm.mall.server.front.asset.service.IUserAssetService;
...
@@ -20,6 +20,7 @@ import com.fzm.mall.server.front.asset.service.IUserAssetService;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.fzm.mall.server.front.base.PageVO
;
import
com.fzm.mall.server.front.base.PageVO
;
import
com.fzm.mall.server.front.constant.StateConst
;
import
com.fzm.mall.server.front.constant.StateConst
;
import
com.fzm.mall.server.front.enums.AssetRecordTypeEnum
;
import
com.fzm.mall.server.front.enums.CoinNameEnum
;
import
com.fzm.mall.server.front.enums.CoinNameEnum
;
import
com.fzm.mall.server.front.enums.QueueTTLTypeEnum
;
import
com.fzm.mall.server.front.enums.QueueTTLTypeEnum
;
import
com.fzm.mall.server.front.goods.model.GoodSpu
;
import
com.fzm.mall.server.front.goods.model.GoodSpu
;
...
@@ -202,7 +203,8 @@ public class UserAssetServiceImpl extends ServiceImpl<UserAssetMapper, UserAsset
...
@@ -202,7 +203,8 @@ public class UserAssetServiceImpl extends ServiceImpl<UserAssetMapper, UserAsset
record
.
setAmount
(
amount
);
record
.
setAmount
(
amount
);
record
.
setUid
(
uid
);
record
.
setUid
(
uid
);
record
.
setCoin
(
coin
);
record
.
setCoin
(
coin
);
record
.
setType
(
6
);
//数字资产转账-转出
//数字资产转账-转出
record
.
setType
(
AssetRecordTypeEnum
.
DIGITAL_TRAN_OUT
.
getType
());
record
.
setHash
(
hash
);
record
.
setHash
(
hash
);
record
.
setFlowId
(
flowId
);
record
.
setFlowId
(
flowId
);
record
.
setStatus
(
3
);
//支付中
record
.
setStatus
(
3
);
//支付中
...
@@ -216,7 +218,8 @@ public class UserAssetServiceImpl extends ServiceImpl<UserAssetMapper, UserAsset
...
@@ -216,7 +218,8 @@ public class UserAssetServiceImpl extends ServiceImpl<UserAssetMapper, UserAsset
recordOther
.
setAmount
(
amount
);
recordOther
.
setAmount
(
amount
);
recordOther
.
setUid
(
otherUid
);
recordOther
.
setUid
(
otherUid
);
recordOther
.
setCoin
(
coin
);
recordOther
.
setCoin
(
coin
);
recordOther
.
setType
(
5
);
//数字资产转帐-转入
//数字资产转帐-转入
record
.
setType
(
AssetRecordTypeEnum
.
DIGITAL_TRAN_IN
.
getType
());
recordOther
.
setHash
(
hash
);
recordOther
.
setHash
(
hash
);
recordOther
.
setFlowId
(
flowId
);
recordOther
.
setFlowId
(
flowId
);
recordOther
.
setStatus
(
2
);
recordOther
.
setStatus
(
2
);
...
@@ -564,7 +567,8 @@ public class UserAssetServiceImpl extends ServiceImpl<UserAssetMapper, UserAsset
...
@@ -564,7 +567,8 @@ public class UserAssetServiceImpl extends ServiceImpl<UserAssetMapper, UserAsset
userAssetRecord
.
setCoin
(
CoinNameEnum
.
MALLCOIN
.
value
());
userAssetRecord
.
setCoin
(
CoinNameEnum
.
MALLCOIN
.
value
());
userAssetRecord
.
setFlowId
(
OrderUtil
.
getFlowId
());
userAssetRecord
.
setFlowId
(
OrderUtil
.
getFlowId
());
userAssetRecord
.
setUid
(
uid
);
userAssetRecord
.
setUid
(
uid
);
userAssetRecord
.
setType
(
19
);
//评论奖励
userAssetRecord
.
setType
(
AssetRecordTypeEnum
.
COMMENT_REWARD
.
getType
());
userAssetRecord
.
setStatus
(
2
);
userAssetRecord
.
setStatus
(
2
);
userAssetRecord
.
setNote
(
commentId
);
userAssetRecord
.
setNote
(
commentId
);
userAssetRecord
.
setOtherSide
(
"平台"
);
userAssetRecord
.
setOtherSide
(
"平台"
);
...
...
mall-server-front/src/main/java/com/fzm/mall/server/front/enums/AssetRecordTypeEnum.java
View file @
5306c8ba
...
@@ -2,6 +2,10 @@ package com.fzm.mall.server.front.enums;
...
@@ -2,6 +2,10 @@ package com.fzm.mall.server.front.enums;
public
enum
AssetRecordTypeEnum
{
public
enum
AssetRecordTypeEnum
{
//数字资产转帐-转入
DIGITAL_TRAN_IN
(
5
),
//数字资产转账-转出
DIGITAL_TRAN_OUT
(
6
),
//积分充值
//积分充值
INTEGRAL_RECHARGE
(
7
),
INTEGRAL_RECHARGE
(
7
),
//积分抵扣
//积分抵扣
...
...
mall-server-front/src/main/java/com/fzm/mall/server/front/mq/consumer/RewardConsumer.java
View file @
5306c8ba
...
@@ -8,6 +8,7 @@ import com.fzm.mall.server.front.asset.model.po.AssetRecord;
...
@@ -8,6 +8,7 @@ import com.fzm.mall.server.front.asset.model.po.AssetRecord;
import
com.fzm.mall.server.front.asset.service.IUserAssetRecordService
;
import
com.fzm.mall.server.front.asset.service.IUserAssetRecordService
;
import
com.fzm.mall.server.front.asset.service.IUserAssetService
;
import
com.fzm.mall.server.front.asset.service.IUserAssetService
;
import
com.fzm.mall.server.front.constant.MALLGlobalConfig
;
import
com.fzm.mall.server.front.constant.MALLGlobalConfig
;
import
com.fzm.mall.server.front.enums.AssetRecordTypeEnum
;
import
com.fzm.mall.server.front.enums.CoinNameEnum
;
import
com.fzm.mall.server.front.enums.CoinNameEnum
;
import
com.fzm.mall.server.front.order.model.Pay
;
import
com.fzm.mall.server.front.order.model.Pay
;
import
com.fzm.mall.server.front.user.model.Member
;
import
com.fzm.mall.server.front.user.model.Member
;
...
@@ -63,7 +64,8 @@ public class RewardConsumer {
...
@@ -63,7 +64,8 @@ public class RewardConsumer {
assetRecord
.
setFlowId
(
OrderUtil
.
getFlowId
());
assetRecord
.
setFlowId
(
OrderUtil
.
getFlowId
());
assetRecord
.
setStatus
(
2
);
assetRecord
.
setStatus
(
2
);
assetRecord
.
setCoin
(
CoinNameEnum
.
MALLCOIN
.
value
());
assetRecord
.
setCoin
(
CoinNameEnum
.
MALLCOIN
.
value
());
assetRecord
.
setType
(
22
);
//22注册奖励
assetRecord
.
setType
(
AssetRecordTypeEnum
.
REGISTER_REWARD
.
getType
());
assetRecord
.
setAmount
(
oprationPopularizeCommission
.
getRegisterAward
());
assetRecord
.
setAmount
(
oprationPopularizeCommission
.
getRegisterAward
());
userAssetRecordService
.
save
(
assetRecord
);
userAssetRecordService
.
save
(
assetRecord
);
}
}
...
...
mall-server-front/src/main/java/com/fzm/mall/server/front/order/service/impl/DeliveryServiceImpl.java
View file @
5306c8ba
...
@@ -16,10 +16,7 @@ import com.fzm.mall.server.front.asset.service.IUserAssetService;
...
@@ -16,10 +16,7 @@ import com.fzm.mall.server.front.asset.service.IUserAssetService;
import
com.fzm.mall.server.front.base.PageVO
;
import
com.fzm.mall.server.front.base.PageVO
;
import
com.fzm.mall.server.front.base.ResponseVO
;
import
com.fzm.mall.server.front.base.ResponseVO
;
import
com.fzm.mall.server.front.constant.MallResponseEnum
;
import
com.fzm.mall.server.front.constant.MallResponseEnum
;
import
com.fzm.mall.server.front.enums.CoinNameEnum
;
import
com.fzm.mall.server.front.enums.*
;
import
com.fzm.mall.server.front.enums.GoodsRedisEnum
;
import
com.fzm.mall.server.front.enums.QueueTTLTypeEnum
;
import
com.fzm.mall.server.front.enums.QueueTypeEnum
;
import
com.fzm.mall.server.front.goods.service.IGoodSkuPropService
;
import
com.fzm.mall.server.front.goods.service.IGoodSkuPropService
;
import
com.fzm.mall.server.front.goods.service.ISkuService
;
import
com.fzm.mall.server.front.goods.service.ISkuService
;
import
com.fzm.mall.server.front.merchant.model.Merchant
;
import
com.fzm.mall.server.front.merchant.model.Merchant
;
...
@@ -105,7 +102,8 @@ public class DeliveryServiceImpl extends ServiceImpl<DeliveryMapper, Delivery> i
...
@@ -105,7 +102,8 @@ public class DeliveryServiceImpl extends ServiceImpl<DeliveryMapper, Delivery> i
record
.
setUid
(
uid
);
record
.
setUid
(
uid
);
record
.
setCoin
(
coin
);
record
.
setCoin
(
coin
);
record
.
setAmount
(
BigDecimal
.
valueOf
(
number
));
record
.
setAmount
(
BigDecimal
.
valueOf
(
number
));
record
.
setType
(
18
);
//提货
//18、提货
record
.
setType
(
AssetRecordTypeEnum
.
DRAW_GOODS
.
getType
());
record
.
setStatus
(
2
);
//成功
record
.
setStatus
(
2
);
//成功
record
.
setFlowId
(
OrderUtil
.
getFlowId
());
record
.
setFlowId
(
OrderUtil
.
getFlowId
());
record
.
setNote
(
"提货"
);
record
.
setNote
(
"提货"
);
...
@@ -246,7 +244,8 @@ public class DeliveryServiceImpl extends ServiceImpl<DeliveryMapper, Delivery> i
...
@@ -246,7 +244,8 @@ public class DeliveryServiceImpl extends ServiceImpl<DeliveryMapper, Delivery> i
record
.
setCoin
(
coin
);
record
.
setCoin
(
coin
);
record
.
setAmount
(
num
);
record
.
setAmount
(
num
);
record
.
setHash
(
hash
);
record
.
setHash
(
hash
);
record
.
setType
(
18
);
//提货
//18、提货
record
.
setType
(
AssetRecordTypeEnum
.
DRAW_GOODS
.
getType
());
boolean
saveReco
=
userAssetRecordService
.
save
(
record
);
boolean
saveReco
=
userAssetRecordService
.
save
(
record
);
if
(!
saveReco
)
{
if
(!
saveReco
)
{
TransactionAspectSupport
.
currentTransactionStatus
().
setRollbackOnly
();
TransactionAspectSupport
.
currentTransactionStatus
().
setRollbackOnly
();
...
@@ -349,7 +348,8 @@ public class DeliveryServiceImpl extends ServiceImpl<DeliveryMapper, Delivery> i
...
@@ -349,7 +348,8 @@ public class DeliveryServiceImpl extends ServiceImpl<DeliveryMapper, Delivery> i
record
.
setAmount
(
numBig
);
record
.
setAmount
(
numBig
);
record
.
setUid
(
uid
);
record
.
setUid
(
uid
);
record
.
setCoin
(
coin
);
record
.
setCoin
(
coin
);
record
.
setType
(
18
);
//提货
//18、提货
record
.
setType
(
AssetRecordTypeEnum
.
DRAW_GOODS
.
getType
());
record
.
setHash
(
hash
);
record
.
setHash
(
hash
);
record
.
setFlowId
(
OrderUtil
.
getFlowId
());
record
.
setFlowId
(
OrderUtil
.
getFlowId
());
record
.
setAmount
(
postFee
);
record
.
setAmount
(
postFee
);
...
...
mall-server-front/src/main/java/com/fzm/mall/server/front/order/service/impl/OrderServiceImpl.java
View file @
5306c8ba
This diff is collapsed.
Click to expand it.
mall-server-front/src/main/java/com/fzm/mall/server/front/user/service/impl/UserServiceImpl.java
View file @
5306c8ba
...
@@ -9,6 +9,7 @@ import com.fzm.mall.server.front.asset.model.UserAsset;
...
@@ -9,6 +9,7 @@ import com.fzm.mall.server.front.asset.model.UserAsset;
import
com.fzm.mall.server.front.asset.model.UserAssetRecord
;
import
com.fzm.mall.server.front.asset.model.UserAssetRecord
;
import
com.fzm.mall.server.front.asset.service.IUserAssetRecordService
;
import
com.fzm.mall.server.front.asset.service.IUserAssetRecordService
;
import
com.fzm.mall.server.front.asset.service.IUserAssetService
;
import
com.fzm.mall.server.front.asset.service.IUserAssetService
;
import
com.fzm.mall.server.front.enums.AssetRecordTypeEnum
;
import
com.fzm.mall.server.front.enums.CoinNameEnum
;
import
com.fzm.mall.server.front.enums.CoinNameEnum
;
import
com.fzm.mall.server.front.enums.QueueTypeEnum
;
import
com.fzm.mall.server.front.enums.QueueTypeEnum
;
import
com.fzm.mall.server.front.mq.MsgProducer
;
import
com.fzm.mall.server.front.mq.MsgProducer
;
...
@@ -124,7 +125,8 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IU
...
@@ -124,7 +125,8 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IU
assetRecord
.
setFlowId
(
OrderUtil
.
getFlowId
());
assetRecord
.
setFlowId
(
OrderUtil
.
getFlowId
());
assetRecord
.
setStatus
(
2
);
assetRecord
.
setStatus
(
2
);
assetRecord
.
setCoin
(
CoinNameEnum
.
MALLCOIN
.
value
());
assetRecord
.
setCoin
(
CoinNameEnum
.
MALLCOIN
.
value
());
assetRecord
.
setType
(
23
);
//注册奖励
assetRecord
.
setType
(
AssetRecordTypeEnum
.
REGISTER_REWARD
.
getType
());
assetRecord
.
setAmount
(
new
BigDecimal
(
register_reward
.
getDictValue
()));
assetRecord
.
setAmount
(
new
BigDecimal
(
register_reward
.
getDictValue
()));
assetRecordService
.
save
(
assetRecord
);
assetRecordService
.
save
(
assetRecord
);
}
else
{
}
else
{
...
...
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