GiftCouponPropertyCmd.java
12 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
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
/**
* 手工赠送优惠券命令类
*
* 功能描述：该命令类用于处理手工赠送优惠券的业务逻辑，包括验证请求参数、查询业主信息、
* 检查优惠券库存、生成赠送记录、更新库存和为用户添加优惠券等操作。
* 支持普通优惠券和充电券两种类型，充电券会同步到物联网系统。
*
* @author 吴学文
* @version 1.0
* @since 2023
*/
package com.java110.acct.cmd.couponProperty;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.annotation.Java110Transactional;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.doc.annotation.*;
import com.java110.dto.coupon.CouponPropertyPoolDto;
import com.java110.dto.coupon.CouponPropertyPoolConfigDto;
import com.java110.dto.coupon.CouponPropertyUserDto;
import com.java110.dto.owner.OwnerDto;
import com.java110.intf.acct.ICouponPropertyPoolConfigV1InnerServiceSMO;
import com.java110.intf.acct.ICouponPropertyPoolDetailV1InnerServiceSMO;
import com.java110.intf.acct.ICouponPropertyPoolV1InnerServiceSMO;
import com.java110.intf.acct.ICouponPropertyUserV1InnerServiceSMO;
import com.java110.intf.job.IIotInnerServiceSMO;
import com.java110.intf.user.IOwnerV1InnerServiceSMO;
import com.java110.po.coupon.CouponPropertyPoolPo;
import com.java110.po.coupon.CouponPropertyPoolDetailPo;
import com.java110.po.coupon.CouponPropertyUserPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.lock.DistributedLock;
import com.java110.utils.util.Assert;
import com.java110.utils.util.DateUtil;
import com.java110.utils.util.ListUtil;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;
import java.text.ParseException;
import java.util.List;
@Java110CmdDoc(title = "手工赠送优惠券",
description = "一般推荐根据赠送规则，缴费时赠送优惠券给业主，但是也会存在前台手工赠送",
httpMethod = "post",
url = "http://{ip}:{port}/app/couponProperty.couponPropertyUserGiftCar",
resource = "acctDoc",
author = "吴学文",
serviceCode = "couponProperty.giftCouponProperty"
)
@Java110ParamsDoc(params = {
@Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"),
@Java110ParamDoc(name = "tel", length = 12, remark = "业主手机号"),
@Java110ParamDoc(name = "cppId", length = 30, remark = "赠送优惠券"),
@Java110ParamDoc(name = "giftCount", type = "int", length = 11, remark = "赠送数量")
})
@Java110ResponseDoc(
params = {
@Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "返回编号，0 成功 其他失败"),
@Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "成功", remark = "描述"),
}
)
@Java110ExampleDoc(
reqBody = "http://{ip}:{port}/app/parkingArea.listParkingAreas?num=&typeCd=&paId=&page=1&row=10&communityId=2022112555490011",
resBody = "{\"page\":0,\"parkingAreas\":[{\"attrs\":[{\"attrId\":\"112022112796270047\",\"communityId\":\"2022112555490011\",\"listShow\":\"Y\",\"paId\":\"102022112706900045\",\"page\":-1,\"records\":0,\"row\":0,\"specCd\":\"6185-17861\",\"specName\":\"外部编码\",\"specType\":\"2233\",\"statusCd\":\"0\",\"total\":0,\"value\":\"123\"}],\"createTime\":\"2022-11-27 01:48:27\",\"num\":\"A\",\"paId\":\"102022112706900045\",\"remark\":\"\",\"typeCd\":\"1001\"}],\"records\":1,\"rows\":0,\"total\":1}"
)
@Java110Cmd(serviceCode = "couponProperty.giftCouponProperty")
public class GiftCouponPropertyCmd extends Cmd{
@Autowired
private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
@Autowired
private ICouponPropertyPoolV1InnerServiceSMO couponPropertyPoolV1InnerServiceSMOImpl;
@Autowired
private ICouponPropertyPoolDetailV1InnerServiceSMO couponPropertyPoolDetailV1InnerServiceSMOImpl;
@Autowired
private ICouponPropertyPoolConfigV1InnerServiceSMO couponPropertyPoolConfigV1InnerServiceSMOImpl;
@Autowired
private ICouponPropertyUserV1InnerServiceSMO couponPropertyUserV1InnerServiceSMOImpl;
@Autowired
private IIotInnerServiceSMO iotInnerServiceSMOImpl;
/**
* 验证请求参数
*
* 功能描述：验证请求参数是否完整，确保包含必要的参数信息
*
* @param event 命令事件对象
* @param context 命令数据流上下文
* @param reqJson 请求的JSON数据
* @throws CmdException 当参数验证失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 验证小区ID参数
Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区");
// 验证业主手机号参数
Assert.hasKeyAndValue(reqJson, "tel", "未包含业主手机号");
// 验证优惠券ID参数
Assert.hasKeyAndValue(reqJson, "cppId", "未包含停车券");
// 验证赠送数量参数
Assert.hasKeyAndValue(reqJson, "giftCount", "未包含赠送数量");
}
/**
* 执行赠送优惠券命令
*
* 功能描述：处理手工赠送优惠券的核心业务逻辑，包括：
* 1. 查询业主信息
* 2. 获取分布式锁保证数据一致性
* 3. 检查优惠券库存
* 4. 生成赠送记录
* 5. 更新优惠券库存
* 6. 为用户添加优惠券
* 7. 处理充电券的物联网同步
*
* @param event 命令事件对象
* @param context 命令数据流上下文
* @param reqJson 请求的JSON数据
* @throws CmdException 当业务处理失败时抛出异常
* @throws ParseException 当日期解析失败时抛出异常
*/
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
// 构建业主查询条件
OwnerDto ownerDto = new OwnerDto();
ownerDto.setLink(reqJson.getString("tel"));
ownerDto.setCommunityId(reqJson.getString("communityId"));
// 根据手机号查询业主信息
List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
// 验证业主是否存在
if(ListUtil.isNull(ownerDtos)){
throw new CmdException("根据手机号未查询到业主");
}
// 获取分布式锁，防止并发操作
String requestId = DistributedLock.getLockUUID();
String key = this.getClass().getSimpleName() + reqJson.getString("cppId");
try {
// 等待获取分布式锁
DistributedLock.waitGetDistributedLock(key, requestId);
// 查询优惠券信息
CouponPropertyPoolDto couponPropertyPoolDto = new CouponPropertyPoolDto();
couponPropertyPoolDto.setCppId(reqJson.getString("cppId"));
List<CouponPropertyPoolDto> couponPropertyPoolDtos = couponPropertyPoolV1InnerServiceSMOImpl.queryCouponPropertyPools(couponPropertyPoolDto);
// 验证优惠券是否存在
if (ListUtil.isNull(couponPropertyPoolDtos)) {
return;
}
// 获取优惠券库存
int stock = Integer.parseInt(couponPropertyPoolDtos.get(0).getStock());
// 获取赠送数量
int quantity = Integer.parseInt(reqJson.getString("giftCount"));
// 检查库存是否充足
if (stock < quantity) {
return;
}
// 查询优惠券配置信息
CouponPropertyPoolConfigDto couponPropertyPoolConfigDto = new CouponPropertyPoolConfigDto();
couponPropertyPoolConfigDto.setCouponId(reqJson.getString("cppId"));
List<CouponPropertyPoolConfigDto> couponPropertyPoolConfigDtos
= couponPropertyPoolConfigV1InnerServiceSMOImpl.queryCouponPropertyPoolConfigs(couponPropertyPoolConfigDto);
// 构建配置值字符串
String value = "";
for (CouponPropertyPoolConfigDto couponPropertyPoolConfigDto1 : couponPropertyPoolConfigDtos) {
value += (couponPropertyPoolConfigDto1.getName() + ":" + couponPropertyPoolConfigDto1.getColumnValue() + ";");
}
// 生成赠送记录
CouponPropertyPoolDetailPo couponPropertyPoolDetailPo = new CouponPropertyPoolDetailPo();
couponPropertyPoolDetailPo.setCommunityId(couponPropertyPoolDtos.get(0).getCommunityId());
couponPropertyPoolDetailPo.setCouponName(couponPropertyPoolDtos.get(0).getCouponName());
couponPropertyPoolDetailPo.setCppId(couponPropertyPoolDtos.get(0).getCppId());
couponPropertyPoolDetailPo.setDetailId(GenerateCodeFactory.getGeneratorId("11"));
couponPropertyPoolDetailPo.setSendCount(quantity + "");
couponPropertyPoolDetailPo.setUserId(ownerDtos.get(0).getMemberId());
couponPropertyPoolDetailPo.setUserName(ownerDtos.get(0).getName());
couponPropertyPoolDetailPo.setTel(ownerDtos.get(0).getLink());
couponPropertyPoolDetailPo.setValue(value);
// 保存赠送记录
int flag = couponPropertyPoolDetailV1InnerServiceSMOImpl.saveCouponPropertyPoolDetail(couponPropertyPoolDetailPo);
if(flag < 1){
throw new CmdException("保存赠送记录失败");
}
// 更新优惠券库存
CouponPropertyPoolPo couponPropertyPoolPo = new CouponPropertyPoolPo();
couponPropertyPoolPo.setCppId(couponPropertyPoolDtos.get(0).getCppId());
couponPropertyPoolPo.setStock((stock - quantity) + "");
flag = couponPropertyPoolV1InnerServiceSMOImpl.updateCouponPropertyPool(couponPropertyPoolPo);
if(flag < 1){
throw new CmdException("赠送失败");
}
// 为用户添加优惠券
CouponPropertyUserPo couponPropertyUserPo = new CouponPropertyUserPo();
couponPropertyUserPo.setCommunityId(couponPropertyPoolDtos.get(0).getCommunityId());
couponPropertyUserPo.setCppId(couponPropertyPoolDtos.get(0).getCppId());
couponPropertyUserPo.setState(CouponPropertyUserDto.STATE_WAIT);
couponPropertyUserPo.setCouponId(GenerateCodeFactory.getGeneratorId("10"));
couponPropertyUserPo.setCouponName(couponPropertyPoolDtos.get(0).getCouponName());
couponPropertyUserPo.setStock(quantity + "");
couponPropertyUserPo.setToType(couponPropertyPoolDtos.get(0).getToType());
couponPropertyUserPo.setValidityDay(couponPropertyPoolDtos.get(0).getValidityDay());
couponPropertyUserPo.setUserId(ownerDtos.get(0).getMemberId());
couponPropertyUserPo.setUserName(ownerDtos.get(0).getName());
couponPropertyUserPo.setTel(ownerDtos.get(0).getLink());
couponPropertyUserPo.setValue(value);
couponPropertyUserPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B));
// 根据优惠券类型处理不同的业务逻辑
if(CouponPropertyUserDto.TO_TYPE_CHARGE.equals(couponPropertyPoolDtos.get(0).getToType())){
// 处理充电券类型
couponPropertyUserPo.setValue(couponPropertyPoolConfigDtos.get(0).getColumnValue());
// 将充电券同步到物联网系统
iotInnerServiceSMOImpl.sendChargeCoupon(couponPropertyUserPo);
}else{
// 处理普通优惠券类型，保存到用户优惠券表
couponPropertyUserV1InnerServiceSMOImpl.saveCouponPropertyUser(couponPropertyUserPo);
}
} finally {
// 释放分布式锁
DistributedLock.releaseDistributedLock(requestId, key);
}
// 设置成功响应
context.setResponseEntity(ResultVo.success());
}
}