Commit cccf78c7 by 程裕兵

feat:CashierEvent

parent fb429e15
package com.jiejing.fitness.finance.service.pay.impl;
import static com.jiejing.fitness.enums.finance.BrandCashierTransStateEnum.PAY_FAIL;
import static com.jiejing.fitness.enums.finance.BrandCashierTransStateEnum.PAY_IN;
import static com.jiejing.fitness.enums.finance.BrandCashierTransStateEnum.PAY_SUCCESS;
import static java.util.stream.Collectors.toList;
import com.alibaba.fastjson.JSON;
......@@ -218,7 +221,13 @@ public class PayServiceImpl implements PayService {
private void triggerCashierEvent(Long id) {
// 发布收银事件
StudioCashierRecord record = studioCashierRecordRpService.getById(id).orElse(null);
EventAgent.of(CashierEvent.class).triggerEvent(BeanUtil.map(record, CashierEvent.class));
if (null == record) {
return;
}
if (Lists.newArrayList(PAY_SUCCESS.getCode(), PAY_IN.getCode(), PAY_FAIL.getCode())
.contains(record.getTransState())) {
EventAgent.of(CashierEvent.class).triggerEvent(BeanUtil.map(record, CashierEvent.class));
}
}
private List<Long> getAdminIds(Long studioId) {
......@@ -273,11 +282,11 @@ public class PayServiceImpl implements PayService {
}
private boolean isPayFail(BrandCashierTransStateEnum state) {
return BrandCashierTransStateEnum.PAY_FAIL == state;
return PAY_FAIL == state;
}
private boolean isPaySuccess(BrandCashierTransStateEnum state) {
return BrandCashierTransStateEnum.PAY_SUCCESS == state || BrandCashierTransStateEnum.PAY_IN == state;
return PAY_SUCCESS == state || PAY_IN == state;
}
private Pair<PartyToMerchant, StudioVO> checkBeforeMerchantPay(StudioMerchantPayParams params) {
......
package com.jiejing.fitness.finance.service.pay.impl;
import static com.jiejing.fitness.enums.finance.BrandCashierTransStateEnum.PAY_FAIL;
import static com.jiejing.fitness.enums.finance.BrandCashierTransStateEnum.PAY_IN;
import static com.jiejing.fitness.enums.finance.BrandCashierTransStateEnum.PAY_SUCCESS;
import static com.jiejing.fitness.enums.finance.BrandCashierTransStateEnum.REFUND_FAIL;
import static com.jiejing.fitness.enums.finance.BrandCashierTransStateEnum.REFUND_SUCCESS;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
......@@ -163,7 +169,13 @@ public class RefundServiceImpl implements RefundService {
private void triggerCashierEvent(Long id) {
// 发布收银事件
StudioCashierRecord record = studioCashierRecordRpService.getById(id).orElse(null);
EventAgent.of(CashierEvent.class).triggerEvent(BeanUtil.map(record, CashierEvent.class));
if (null == record) {
return;
}
if (Lists.newArrayList(REFUND_FAIL.getCode(), REFUND_SUCCESS.getCode())
.contains(record.getTransState())) {
EventAgent.of(CashierEvent.class).triggerEvent(BeanUtil.map(record, CashierEvent.class));
}
}
private void doAfterRefund(RefundEvent event, StudioCashierRecord record) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment