package com.stylefeng.guns.modular.system.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.amazonaws.services.dynamodbv2.xspec.B;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.plugins.Page;
|
import com.stripe.exception.StripeException;
|
import com.stripe.model.PaymentIntent;
|
import com.stylefeng.guns.modular.system.model.*;
|
import com.stylefeng.guns.modular.system.service.*;
|
import com.stylefeng.guns.modular.system.service.impl.TQuoteServiceImpl;
|
import com.stylefeng.guns.modular.system.utils.PaymentProcessor;
|
import com.stylefeng.guns.modular.system.utils.Server;
|
import com.stylefeng.guns.modular.system.utils.StripePayUtils;
|
import com.stylefeng.guns.modular.system.utils.tips.ErrorTip;
|
import com.stylefeng.guns.modular.system.utils.tips.SuccessTip;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.apache.poi.ss.formula.functions.T;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Controller
|
@Api(tags = "用户端-财务信息")
|
@RequestMapping("/api/tFinance")
|
public class FinanceController {
|
|
|
@Autowired
|
private ITOrderService orderService;
|
|
@Autowired
|
private ITGoodsService goodsService;
|
|
@Autowired
|
private ITUserService itUserService;
|
|
@Autowired
|
private ITQuoteService tQuoteService;
|
|
@Autowired
|
private TUserBankService userBankService;
|
|
@Autowired
|
private ITPriceService priceService;
|
|
|
@ApiOperation(value = "用户端-invocie",notes="用户端-invocie")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
|
@ApiImplicitParam(name = "pageNumber", value = "pageNumber", required = true, dataType = "int",paramType = "query"),
|
@ApiImplicitParam(name = "pageSize", value = "pageSize", required = true, dataType = "int",paramType = "query"),
|
@ApiImplicitParam(name = "time", value = "时间 （时间 - 时间）", required = false, dataType = "String"),
|
@ApiImplicitParam(name = "id", value = "订单id", required = false, dataType = "Long"),
|
@ApiImplicitParam(name = "state", value = "状态 1支付完 2未支付完", required = false, dataType = "int"),
|
@ApiImplicitParam(name = "userId", value = "用户id", required = true, dataType = "int"),
|
})
|
@PostMapping(value = "/list")
|
@ResponseBody
|
public Object list(int pageNumber,int pageSize,String time,Long id,Integer state,int userId) {
|
Page<ReceivableVo> receivableVoPage = new Page<>(pageNumber, pageSize);
|
List<ReceivableVo> receivable = orderService.getReceivable(receivableVoPage, time, id, state, userId);
|
receivableVoPage.setRecords(receivable);
|
return new SuccessTip(receivableVoPage);
|
}
|
|
|
@ApiOperation(value = "用户端-payImmediately",notes="用户端-payImmediately")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
|
@ApiImplicitParam(name = "userId", value = "用户id", required = true, dataType = "int"),
|
})
|
@PostMapping(value = "/payImmediately")
|
@ResponseBody
|
public Object payImmediately(int userId) {
|
// 找出所有未支付完成的订单
|
List<TOrder> orders = orderService.getNoPayOrder(userId);
|
BigDecimal all = new BigDecimal(0);
|
ArrayList<TGoods> goods = new ArrayList<>();
|
for (TOrder order : orders) {
|
BigDecimal allTotal = priceService.selectList(new EntityWrapper<TPrice>().eq("order_id", order.getId())).stream().map(TPrice::getPrice).reduce(BigDecimal.ZERO, BigDecimal::add);
|
BigDecimal paid = order.getPaid();
|
BigDecimal subtract = allTotal.subtract(paid);
|
all = all.add(subtract);
|
TGoods tGoods = goodsService.selectOne(new EntityWrapper<TGoods>().eq("order_id", order.getId()));
|
goods.add(tGoods);
|
}
|
|
HashMap<String, Object> map = new HashMap<>();
|
map.put("money",all);
|
map.put("data",goods);
|
|
return new SuccessTip(map);
|
}
|
|
@ApiOperation(value = "应收款票据详情",notes="应收款票据详情")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
|
@ApiImplicitParam(name = "number", value = "订单id", required = true, dataType = "Long"),
|
})
|
@GetMapping(value = "/listOfReceivablesInfo")
|
@ResponseBody
|
public Object listOfReceivablesInfo(Long number) {
|
return new SuccessTip(orderService.listOfReceivablesInfo(number));
|
}
|
|
@ApiOperation(value = "支付调用",notes="支付调用")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
|
@ApiImplicitParam(name = "id", value = "userid", required = true, dataType = "int"),
|
@ApiImplicitParam(name = "quoteId", value = "需求id", required = false, dataType = "Long"),
|
@ApiImplicitParam(name = "cardId", value = "cardId", required = false, dataType = "Integer"),
|
@ApiImplicitParam(name = "type", value = "type 1额度支付 2全款支付", required = true, dataType = "int"),
|
@ApiImplicitParam(name = "category", value = " 1需求支付 2所有支付", required = true, dataType = "int"),
|
})
|
@GetMapping(value = "/payInfo")
|
@ResponseBody
|
@Transactional(propagation = Propagation.REQUIRES_NEW)
|
public Object payInfo(int id, Long quoteId, Integer cardId, int type, int category) throws StripeException {
|
TUser tUser = itUserService.selectById(id);
|
|
|
try {
|
if (category == 1) {
|
TQuote quote = tQuoteService.selectById(quoteId);
|
// 找出状态为0的订单
|
List<TOrder> orders = orderService.selectList(new EntityWrapper<TOrder>().eq("e_zip_z", quote.getOrderId()).eq("status", 0));
|
// 总金额
|
BigDecimal bigDecimal = new BigDecimal(0);
|
for (TOrder order : orders) {
|
List<TPrice> prices = priceService.selectList(new EntityWrapper<TPrice>().eq("order_id", order.getId()));
|
bigDecimal = bigDecimal.add(prices.stream().map(TPrice::getPrice).reduce(BigDecimal.ZERO,BigDecimal::add));
|
}
|
if (type == 1) {
|
// 可用额度
|
BigDecimal bigDecimal1 = null;
|
String residueLimit = tUser.getResidueLimit();
|
if (residueLimit == null) {
|
bigDecimal1 = new BigDecimal(residueLimit);
|
} else {
|
bigDecimal1 = new BigDecimal(residueLimit);
|
}
|
// 剩余额度
|
BigDecimal subtract = bigDecimal1.subtract(bigDecimal);
|
tUser.setResidueLimit(subtract.toString());
|
orders.forEach(e -> {
|
e.setStatus("2");
|
e.setPayTime(new Date());
|
});
|
orderService.updateBatchById(orders);
|
itUserService.updateById(tUser);
|
quote.setState(4);
|
tQuoteService.updateById(quote);
|
} else {
|
if (tUser.getUserNumber() == null) {
|
return new ErrorTip(5006, "Please bind a card first");
|
}
|
// 找出这张卡
|
TUserBank tUserBank = userBankService.selectById(cardId);
|
String cardToken = tUserBank.getCardToken();
|
// 修改默认支付卡
|
StripePayUtils.updateStripeDefaultCard(tUser.getUserNumber(), cardToken);
|
// String method = PaymentProcessor.getMethod(tUser.getUserNumber());
|
// JSONObject jsonObject = JSON.parseObject(method);
|
// Object id1 = jsonObject.get("id");
|
Boolean pay = StripePayUtils.charge(tUser.getUserNumber(), bigDecimal, "","Continental Cargo Association, Inc.");
|
if (pay) {
|
orders.forEach(e -> {
|
e.setStatus("2");
|
e.setPaid(e.getAllTotal());
|
e.setPayTime(new Date());
|
});
|
orderService.updateBatchById(orders);
|
quote.setState(4);
|
tQuoteService.updateById(quote);
|
}
|
}
|
} else {
|
if (tUser.getUserNumber() == null) {
|
return new ErrorTip(5006, "Please bind a card first");
|
}
|
// 找出所有未支付完成的订单
|
List<TOrder> orders = orderService.getNoPayOrder(id);
|
HashSet<TQuote> tQuotes = new HashSet<>();
|
BigDecimal all = new BigDecimal(0);
|
for (TOrder order : orders) {
|
String s = order.geteZipZ();
|
TQuote quote = tQuoteService.selectOne(new EntityWrapper<TQuote>().eq("order_id", s));
|
quote.setState(4);
|
tQuotes.add(quote);
|
// BigDecimal allTotal = order.getAllTotal();
|
List<TPrice> prices = priceService.selectList(new EntityWrapper<TPrice>().eq("order_id", order.getId()));
|
BigDecimal allTotal = prices.stream().map(TPrice::getPrice).reduce(BigDecimal.ZERO,BigDecimal::add);
|
BigDecimal paid = order.getPaid();
|
BigDecimal subtract = allTotal.subtract(paid);
|
all = all.add(subtract);
|
}
|
// 找出这张卡
|
TUserBank tUserBank = userBankService.selectById(cardId);
|
String cardToken = tUserBank.getCardToken();
|
// 修改默认支付卡
|
StripePayUtils.updateStripeDefaultCard(tUser.getUserNumber(), cardToken);
|
String method = PaymentProcessor.getMethod(tUser.getUserNumber());
|
JSONObject jsonObject = JSON.parseObject(method);
|
Object id1 = jsonObject.get("id");
|
long l = all.multiply(new BigDecimal(100)).longValue();
|
Boolean pay = StripePayUtils.charge(tUser.getUserNumber(), all, "","Continental Cargo Association, Inc.");
|
if (pay) {
|
orders.forEach(e -> {
|
e.setStatus("2");
|
e.setPaid(e.getAllTotal());
|
e.setPayTime(new Date());
|
});
|
orderService.updateBatchById(orders);
|
List<TQuote> collect = tQuotes.stream().collect(Collectors.toList());
|
tQuoteService.updateBatchById(collect);
|
}else {
|
return new ErrorTip(5010, "payment failure");
|
}
|
}
|
return new SuccessTip();
|
} catch (Exception e) {
|
e.printStackTrace();
|
return new ErrorTip(500, "ERROR");
|
}
|
}
|
|
|
}
|
