TeldSendParkingCouponCarCmd.java
11.6 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
251
252
253
254
package com.java110.acct.cmd.parkingCoupon;
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.dto.parking.ParkingCouponCarDto;
import com.java110.dto.parking.ParkingCouponShopDto;
import com.java110.dto.shop.ShopDto;
import com.java110.dto.shop.StoreShopDto;
import com.java110.dto.store.StoreUserDto;
import com.java110.intf.acct.IParkingCouponCarV1InnerServiceSMO;
import com.java110.intf.acct.IParkingCouponShopV1InnerServiceSMO;
import com.java110.intf.mall.IShopInnerServiceSMO;
import com.java110.intf.shore.IShoreShopV1InnerServiceSMO;
import com.java110.intf.store.IStoreShopCommunityV1InnerServiceSMO;
import com.java110.intf.store.IStoreShopV1InnerServiceSMO;
import com.java110.intf.store.IStoreUserV1InnerServiceSMO;
import com.java110.po.parking.ParkingCouponCarPo;
import com.java110.po.parking.ParkingCouponShopPo;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.exception.CmdException;
import com.java110.utils.lock.DistributedLock;
import com.java110.utils.util.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import java.text.ParseException;
import java.util.List;
/**
* 特来电充电结束通知处理命令类
* 功能：处理特来电充电结束通知，验证商户停车券信息，发放停车券给指定车牌号
* 用途：接收特来电加密报文，解密后处理停车券发放逻辑，返回处理结果给特来电系统
*
* 接口路径示例：
* /app/ext/parkingCoupon.teldSendParkingCouponCar/992020051967020024
* /app/ext/login.getTokenForTeld/992020051967020024
*/
@Java110Cmd(serviceCode = "notification_charge_end_order_info")
public class TeldSendParkingCouponCarCmd extends Cmd {
@Autowired
private IStoreUserV1InnerServiceSMO storeUserV1InnerServiceSMOImpl;
@Autowired
private IStoreShopV1InnerServiceSMO storeShopV1InnerServiceSMOImpl;
@Autowired
private IParkingCouponShopV1InnerServiceSMO parkingCouponShopV1InnerServiceSMOImpl;
@Autowired
private IParkingCouponCarV1InnerServiceSMO parkingCouponCarV1InnerServiceSMOImpl;
/** ID生成前缀 */
public static final String CODE_PREFIX_ID = "10";
/**
* 请求参数验证方法
* 验证请求中是否包含必要的加密报文数据
*
* @param event 命令事件对象
* @param context 命令数据流上下文
* @param reqJson 请求JSON对象
* @throws CmdException 命令异常
* @throws ParseException 解析异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
// 验证请求中必须包含Data字段（加密报文）
Assert.hasKeyAndValue(reqJson, "Data", "未包含加密报文");
}
/**
* 命令执行主方法
* 处理特来电充电结束通知，解密报文，发放停车券，返回处理结果
*
* @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 {
// 从缓存中获取特来电加解密相关配置
String signKey = MappingCache.getValue("TELD_DOMAIN", "SIGN_KEY");
String aesKey = MappingCache.getValue("TELD_DOMAIN", "AES_KEY");
String aesIv = MappingCache.getValue("TELD_DOMAIN", "AES_IV");
// 解密特来电传输的加密数据
String data = TeldUtil.Decrypt(reqJson.getString("Data"), aesKey, aesIv);
// 验证解密后的数据是否为空
if (StringUtil.isEmpty(data)) {
throw new CmdException("未包含报文");
}
// 解析解密后的JSON数据
JSONObject dataObj = JSONObject.parseObject(data);
// 获取充电订单序列号
String StartChargeSeq = dataObj.getString("StartChargeSeq");
// 初始化返回参数默认值（成功状态）
int ConfirmResult = 0; // 确认结果：0-成功，1-失败
int PlateAutResult = 1; // 车牌识别结果：1-识别成功，2-识别失败
int PlateAutFailReason = 0; // 车牌识别失败原因：0-无，6-其他原因
try {
// 执行停车券发放逻辑
doSend(context, dataObj);
} catch (Exception e) {
e.printStackTrace();
// 处理异常时设置失败状态
ConfirmResult = 1; // 确认失败
PlateAutResult = 2; // 车牌识别失败
PlateAutFailReason = 6; // 失败原因：其他
}
// 构建返回给特来电的响应参数
JSONObject paramOut = new JSONObject();
paramOut.put("StartChargeSeq", StartChargeSeq);
paramOut.put("ConfirmResult", ConfirmResult);
paramOut.put("PlateAutResult", PlateAutResult);
paramOut.put("PlateAutFailReason", PlateAutFailReason);
String paramStr = "";
try {
// 生成加密的返回参数
paramStr = TeldUtil.generateReturnParam(paramOut.toJSONString(), aesKey, aesIv, signKey, reqJson.getString("OperatorID"));
} catch (Exception e) {
e.printStackTrace();
}
// 设置HTTP响应
context.setResponseEntity(new ResponseEntity(paramStr, HttpStatus.OK));
}
/**
* 执行停车券发放逻辑
* 验证商户信息，检查停车券库存，发放停车券给指定车牌号
*
* @param context 命令数据流上下文
* @param dataObj 解密后的数据对象
*/
private void doSend(ICmdDataFlowContext context, JSONObject dataObj) {
// 从请求头中获取用户ID
String userId = context.getReqHeaders().get("user-id");
// 根据用户ID查询商户信息
StoreUserDto storeUserDto = new StoreUserDto();
storeUserDto.setUserId(userId);
List<StoreUserDto> storeUserDtos = storeUserV1InnerServiceSMOImpl.queryStoreUsers(storeUserDto);
// 验证商户存在且唯一
Assert.listOnlyOne(storeUserDtos, "商户不存在");
// 根据商户ID查询店铺信息
StoreShopDto storeShopDto = new StoreShopDto();
storeShopDto.setStoreId(storeUserDtos.get(0).getStoreId());
List<ShopDto> storeShops = storeShopV1InnerServiceSMOImpl.queryStoreShops(storeShopDto);
// 验证商户店铺存在
if (storeShops == null || storeShops.size() < 1) {
Assert.listOnlyOne(storeUserDtos, "商户店铺不存在");
}
// 查询商户的停车券库存信息
ParkingCouponShopDto parkingCouponShopDto = new ParkingCouponShopDto();
parkingCouponShopDto.setHasQuantity("Y"); // 只查询有库存的记录
parkingCouponShopDto.setShopId(storeShops.get(0).getShopId());
List<ParkingCouponShopDto> parkingCouponShopDtos = parkingCouponShopV1InnerServiceSMOImpl.queryParkingCouponShops(parkingCouponShopDto);
// 检查停车券库存
if (parkingCouponShopDtos == null || parkingCouponShopDtos.size() < 1) {
throw new CmdException("停车券已用完");
}
// 获取车牌号码
String carNum = dataObj.getString("PlateNum");
int quantity = 0; // 停车券数量
int flag = 0; // 操作标志
// 使用分布式锁确保库存操作的原子性
String requestId = DistributedLock.getLockUUID();
String key = this.getClass().getSimpleName() + parkingCouponShopDtos.get(0).getCouponShopId();
try {
// 获取分布式锁
DistributedLock.waitGetDistributedLock(key, requestId);
// 重新查询停车券库存信息（防止并发问题）
parkingCouponShopDto = new ParkingCouponShopDto();
parkingCouponShopDto.setCouponShopId(parkingCouponShopDtos.get(0).getCouponShopId());
parkingCouponShopDto.setShopId(storeShops.get(0).getShopId());
parkingCouponShopDtos = parkingCouponShopV1InnerServiceSMOImpl.queryParkingCouponShops(parkingCouponShopDto);
// 获取当前库存数量
quantity = Integer.parseInt(parkingCouponShopDtos.get(0).getQuantity());
// 检查库存是否充足
if (quantity < 1) {
throw new CmdException("停车劵不足，请购买");
}
// 更新停车券库存（减1）
ParkingCouponShopPo parkingCouponShopPo = new ParkingCouponShopPo();
parkingCouponShopPo.setCouponShopId(parkingCouponShopDtos.get(0).getCouponShopId());
parkingCouponShopPo.setQuantity((quantity - 1) + "");
flag = parkingCouponShopV1InnerServiceSMOImpl.updateParkingCouponShop(parkingCouponShopPo);
// 检查库存更新是否成功
if (flag < 1) {
throw new CmdException("优惠券递减失败");
}
} finally {
// 释放分布式锁
DistributedLock.releaseDistributedLock(requestId, key);
}
// 构建停车券发放记录
String StartChargeSeq = dataObj.getString("StartChargeSeq");
JSONObject remarkObj = new JSONObject();
remarkObj.put("StartChargeSeq", StartChargeSeq); // 记录充电订单号
// 创建停车券车辆关联记录
ParkingCouponCarPo parkingCouponCarPo = new ParkingCouponCarPo();
parkingCouponCarPo.setCarNum(carNum); // 车牌号
parkingCouponCarPo.setGiveWay("1001"); // 发放方式
parkingCouponCarPo.setCouponShopId(parkingCouponShopDtos.get(0).getCouponShopId()); // 停车券店铺ID
parkingCouponCarPo.setShopId(parkingCouponShopDtos.get(0).getShopId()); // 店铺ID
parkingCouponCarPo.setPccId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID)); // 生成主键ID
parkingCouponCarPo.setCouponId(parkingCouponShopDtos.get(0).getCouponId()); // 优惠券ID
parkingCouponCarPo.setCommunityId(parkingCouponShopDtos.get(0).getCommunityId()); // 项目ID
parkingCouponCarPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); // 开始时间（当前时间）
parkingCouponCarPo.setEndTime(DateUtil.getAddDayString(DateUtil.getCurrentDate(), DateUtil.DATE_FORMATE_STRING_A, 1)); // 结束时间（当前时间+1天）
parkingCouponCarPo.setPaId(parkingCouponShopDtos.get(0).getPaId()); // 停车区域ID
parkingCouponCarPo.setState(ParkingCouponCarDto.STATE_WAIT); // 状态：待使用
parkingCouponCarPo.setTypeCd(parkingCouponShopDtos.get(0).getTypeCd()); // 类型编码
parkingCouponCarPo.setValue(parkingCouponShopDtos.get(0).getValue()); // 优惠券面值
parkingCouponCarPo.setRemark(remarkObj.toJSONString()); // 备注信息（包含充电订单号）
// 保存停车券发放记录
flag = parkingCouponCarV1InnerServiceSMOImpl.saveParkingCouponCar(parkingCouponCarPo);
// 检查保存是否成功
if (flag < 1) {
throw new CmdException("保存数据失败");
}
}
}