package com.java110.acct.cmd.parkingCoupon;
|
|
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.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;
|
|
public static final String CODE_PREFIX_ID = "10";
|
|
@Override
|
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
|
Assert.hasKeyAndValue(reqJson, "Data", "未包含加密报文");
|
|
}
|
|
@Override
|
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("未包含报文");
|
}
|
|
JSONObject dataObj = JSONObject.parseObject(data);
|
|
String StartChargeSeq = dataObj.getString("StartChargeSeq");
|
int ConfirmResult = 0;
|
int PlateAutResult = 1;
|
int PlateAutFailReason = 0;
|
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();
|
}
|
|
context.setResponseEntity(new ResponseEntity(paramStr, HttpStatus.OK));
|
|
}
|
|
private void doSend(ICmdDataFlowContext context, JSONObject dataObj) {
|
String userId = context.getReqHeaders().get("user-id");
|
|
|
StoreUserDto storeUserDto = new StoreUserDto();
|
storeUserDto.setUserId(userId);
|
List<StoreUserDto> storeUserDtos = storeUserV1InnerServiceSMOImpl.queryStoreUsers(storeUserDto);
|
Assert.listOnlyOne(storeUserDtos, "商户不存在");
|
|
StoreShopDto storeShopDto = new StoreShopDto();
|
storeUserDto.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("停车劵不足，请购买");
|
}
|
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());
|
parkingCouponCarPo.setShopId(parkingCouponShopDtos.get(0).getShopId());
|
parkingCouponCarPo.setPccId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
|
parkingCouponCarPo.setCouponId(parkingCouponShopDtos.get(0).getCouponId());
|
parkingCouponCarPo.setCommunityId(parkingCouponShopDtos.get(0).getCommunityId());
|
parkingCouponCarPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
|
parkingCouponCarPo.setEndTime(DateUtil.getAddDayString(DateUtil.getCurrentDate(), DateUtil.DATE_FORMATE_STRING_A, 1));
|
parkingCouponCarPo.setPaId(parkingCouponShopDtos.get(0).getPaId());
|
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("保存数据失败");
|
}
|
}
|
}
|
