|
|
|
@ -140,46 +140,50 @@ public class AccountRechargeServiceImpl implements AccountRechargeService {
|
|
|
|
|
order.setPayTime(DateUtil.date());
|
|
|
|
|
order.setStatus(DefaultNumberConstants.ONE_NUMBER);
|
|
|
|
|
payOrderRepository.save(order);
|
|
|
|
|
PayOrder updatePayOrder = new PayOrder();
|
|
|
|
|
updatePayOrder.setId(order.getId());
|
|
|
|
|
updatePayOrder.setStatus(2);
|
|
|
|
|
i++;
|
|
|
|
|
//同步数据
|
|
|
|
|
JSONObject jsonObject = requestCore.savePayOrder(order);
|
|
|
|
|
if (jsonObject.get("code").equals("200")) {
|
|
|
|
|
if (DefaultNumberConstants.TWO_HUNDRED == (Integer)jsonObject.get("code")) {
|
|
|
|
|
i++;
|
|
|
|
|
//子账号授权
|
|
|
|
|
JSONObject jsonObject1 = requestCore.authorizeChildrenAccount(order.getMasterUserId(), order.getNickName(), order.getTemplateId());
|
|
|
|
|
if (jsonObject1.get("code").equals("200")) {
|
|
|
|
|
if (DefaultNumberConstants.TWO_HUNDRED == (Integer)jsonObject1.get("code")) {
|
|
|
|
|
i++;
|
|
|
|
|
// 修改账户信息 开通服务
|
|
|
|
|
JSONObject jsonObject2 = requestCore.updateSellerAccount(order);
|
|
|
|
|
if (!jsonObject2.get("code").equals("200")){
|
|
|
|
|
requestCore.rollbackChildrenAccount(order.getMasterUserId(), order.getNickName(), order.getTemplateId());
|
|
|
|
|
requestCore.updatePayOrder(order);
|
|
|
|
|
payOrderRepository.save(updatePayOrder);
|
|
|
|
|
if (DefaultNumberConstants.TWO_HUNDRED != (Integer)jsonObject2.get("code")){
|
|
|
|
|
updateRollBack(order,DefaultNumberConstants.THREE_NUMBER);
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
requestCore.updatePayOrder(order);
|
|
|
|
|
payOrderRepository.save(updatePayOrder);
|
|
|
|
|
updateRollBack(order,DefaultNumberConstants.TWO_NUMBER);
|
|
|
|
|
}
|
|
|
|
|
}else {
|
|
|
|
|
payOrderRepository.save(updatePayOrder);
|
|
|
|
|
updateRollBack(order,DefaultNumberConstants.ONE_NUMBER);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
if (i == 1){
|
|
|
|
|
requestCore.updatePayOrder(order);
|
|
|
|
|
}else if (i == 2){
|
|
|
|
|
requestCore.rollbackChildrenAccount(order.getMasterUserId(), order.getNickName(), order.getTemplateId());
|
|
|
|
|
requestCore.updatePayOrder(order);
|
|
|
|
|
}
|
|
|
|
|
updateRollBack(order,i);
|
|
|
|
|
log.error("the pc response error time {}", LocalTime.now());
|
|
|
|
|
throw new TaoMiCommException(ResponseCode.CALLBACK_FAILED.getDesc());
|
|
|
|
|
}
|
|
|
|
|
return CommonResult.successfulOperation();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void updateRollBack(PayOrder payOrder,int i){
|
|
|
|
|
PayOrder updatePayOrder = new PayOrder();
|
|
|
|
|
updatePayOrder.setId(payOrder.getId());
|
|
|
|
|
if (DefaultNumberConstants.ONE_NUMBER == i){
|
|
|
|
|
updatePayOrder.setOrderStatus(DefaultNumberConstants.ONE_NUMBER);
|
|
|
|
|
payOrderRepository.save(updatePayOrder);
|
|
|
|
|
}else{
|
|
|
|
|
updatePayOrder.setOrderStatus(i);
|
|
|
|
|
updatePayOrder.setOrderNumber(payOrder.getOrderNumber());
|
|
|
|
|
requestCore.updatePayOrder(updatePayOrder);
|
|
|
|
|
payOrderRepository.save(updatePayOrder);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void checkParam(HttpServletRequest request, Map<String, String> params) {
|
|
|
|
|
Map<String, String[]> requestParams = request.getParameterMap();
|
|
|
|
|
if (CollectionUtils.isNotEmpty(requestParams.keySet())) {
|
|
|
|
|