UpdatePayFeeBatchCmd.java
7.05 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
/*
* Copyright 2017-2020 吴学文 and java110 team.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.java110.fee.cmd.payFeeBatch;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.dto.meter.MeterWaterDto;
import com.java110.dto.payFee.PayFeeBatchDto;
import com.java110.intf.fee.*;
import com.java110.po.fee.PayFeePo;
import com.java110.po.payFee.PayFeeBatchPo;
import com.java110.po.payFee.PayFeeRulePo;
import com.java110.po.payFee.PayFeeRuleBillPo;
import com.java110.utils.constant.StateConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import com.java110.core.log.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
/**
* 类表述：更新
* 服务编码：payFeeBatch.updatePayFeeBatch
* 请求路劲：/app/payFeeBatch.UpdatePayFeeBatch
* add by 吴学文 at 2021-09-22 18:00:14 mail: 928255095@qq.com
* open source address: https://gitee.com/wuxw7/MicroCommunity
* 官网：http://www.homecommunity.cn
* 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
* // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
*/
/**
* 批量缴费更新命令类
* 负责处理批量缴费的更新操作，包括批量缴费状态的更新以及相关数据的清理
* 当批量缴费审核通过或拒绝时，执行相应的业务逻辑处理
*
* @author 吴学文
* @version 1.0
* @since 2021-09-22
*/
@Java110Cmd(serviceCode = "payFeeBatch.updatePayFeeBatch")
public class UpdatePayFeeBatchCmd extends Cmd {
private static Logger logger = LoggerFactory.getLogger(UpdatePayFeeBatchCmd.class);
/**
* 批量缴费V1服务接口
*/
@Autowired
private IPayFeeBatchV1InnerServiceSMO payFeeBatchV1InnerServiceSMOImpl;
/**
* 费用服务接口
*/
@Autowired
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
/**
* 水表抄表记录服务接口
*/
@Autowired
private IMeterWaterV1InnerServiceSMO meterWaterV1InnerServiceSMOImpl;
/**
* 缴费规则账单服务接口
*/
@Autowired
private IPayFeeRuleBillV1InnerServiceSMO payFeeRuleBillV1InnerServiceSMOImpl;
/**
* 缴费规则服务接口
*/
@Autowired
private IPayFeeRuleV1InnerServiceSMO payFeeRuleV1InnerServiceSMOImpl;
/**
* 参数校验方法
* 验证请求参数是否完整和有效
*
* @param event 命令事件对象
* @param cmdDataFlowContext 命令数据流上下文
* @param reqJson 请求的JSON数据
* @throws CmdException 当参数验证失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
// 验证必要参数是否存在
Assert.hasKeyAndValue(reqJson, "batchId", "batchId不能为空");
Assert.hasKeyAndValue(reqJson, "communityId", "communityId不能为空");
Assert.hasKeyAndValue(reqJson, "state", "状态不能为空");
Assert.hasKeyAndValue(reqJson, "msg", "消息不能为空");
}
/**
* 执行批量缴费更新命令
* 根据审核状态更新批量缴费信息，并在审核通过时清理相关数据
* 注意：此方法未开启事务，因为删除操作可能涉及大量数据，避免事务压力过大
*
* @param event 命令事件对象
* @param cmdDataFlowContext 命令数据流上下文
* @param reqJson 请求的JSON数据
* @throws CmdException 当更新操作失败时抛出异常
*/
@Override
//@Java110Transactional
//这里不开启事务，删除可能几千条 事务压力太大
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 将请求JSON数据转换为批量缴费PO对象
PayFeeBatchPo payFeeBatchPo = BeanConvertUtil.covertBean(reqJson, PayFeeBatchPo.class);
// 根据审核状态设置批量缴费状态
if (StateConstant.AGREE_AUDIT.equals(reqJson.getString("state"))) {
// 审核通过，设置状态为成功
payFeeBatchPo.setState(PayFeeBatchDto.STATE_SUCCESS);
} else {
// 审核拒绝，设置状态为失败
payFeeBatchPo.setState(PayFeeBatchDto.STATE_FAIL);
}
// 更新批量缴费信息
int flag = payFeeBatchV1InnerServiceSMOImpl.updatePayFeeBatch(payFeeBatchPo);
// 检查更新是否成功
if (flag < 1) {
throw new CmdException("更新数据失败");
}
// 如果批量缴费状态为失败，直接返回成功响应
if (PayFeeBatchDto.STATE_FAIL.equals(payFeeBatchPo.getState())) {
cmdDataFlowContext.setResponseEntity(ResultVo.success());
return;
}
// 审核通过时，清理相关数据
// 删除批量缴费对应的费用记录
PayFeePo feePo = new PayFeePo();
feePo.setBatchId(payFeeBatchPo.getBatchId());
feePo.setCommunityId(payFeeBatchPo.getCommunityId());
feeInnerServiceSMOImpl.deleteFeesByBatch(feePo);
// 删除批量缴费对应的抄表记录
MeterWaterDto meterWaterDto = new MeterWaterDto();
meterWaterDto.setCommunityId(payFeeBatchPo.getCommunityId());
meterWaterDto.setBatchId(payFeeBatchPo.getBatchId());
meterWaterV1InnerServiceSMOImpl.deleteMeterWaterByBatch(meterWaterDto);
// 删除批量缴费对应的账单费用数据
PayFeeRuleBillPo payFeeRuleBillPo = new PayFeeRuleBillPo();
payFeeRuleBillPo.setCommunityId(payFeeBatchPo.getCommunityId());
payFeeRuleBillPo.setBatchId(payFeeBatchPo.getBatchId());
payFeeRuleBillV1InnerServiceSMOImpl.deletePayFeeRuleBill(payFeeRuleBillPo);
// 删除批量缴费对应的账单数据
PayFeeRulePo payFeeRulePo = new PayFeeRulePo();
payFeeRulePo.setCommunityId(payFeeBatchPo.getCommunityId());
payFeeRulePo.setBatchId(payFeeBatchPo.getBatchId());
payFeeRuleV1InnerServiceSMOImpl.deletePayFeeRule(payFeeRulePo);
// 设置成功响应
cmdDataFlowContext.setResponseEntity(ResultVo.success());
}
}