OrderServiceImpl.java 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600
  1. package com.goafanti.order.service.impl;
  2. import java.math.BigDecimal;
  3. import java.text.ParseException;
  4. import java.util.ArrayList;
  5. import java.util.Date;
  6. import java.util.HashMap;
  7. import java.util.List;
  8. import java.util.Map;
  9. import java.util.UUID;
  10. import org.apache.commons.lang3.StringUtils;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.stereotype.Service;
  13. import org.springframework.transaction.annotation.Transactional;
  14. import com.goafanti.common.bo.Error;
  15. import com.goafanti.common.constant.AFTConstants;
  16. import com.goafanti.common.constant.ErrorConstants;
  17. import com.goafanti.common.dao.TFundingRecordsMapper;
  18. import com.goafanti.common.dao.TOrderMapper;
  19. import com.goafanti.common.error.BusinessException;
  20. import com.goafanti.common.model.Admin;
  21. import com.goafanti.common.model.TFundingRecords;
  22. import com.goafanti.common.model.TOrder;
  23. import com.goafanti.common.model.User;
  24. import com.goafanti.common.utils.DateUtils;
  25. import com.goafanti.common.utils.DecimalCalculate;
  26. import com.goafanti.core.mybatis.BaseMybatisDao;
  27. import com.goafanti.core.mybatis.JDBCIdGenerator;
  28. import com.goafanti.core.mybatis.page.Pagination;
  29. import com.goafanti.core.shiro.token.TokenManager;
  30. import com.goafanti.order.bo.FundingListBo;
  31. import com.goafanti.order.bo.OperatorActive;
  32. import com.goafanti.order.bo.OrderDetailBo;
  33. import com.goafanti.order.enums.AuditState;
  34. import com.goafanti.order.enums.CommodityType;
  35. import com.goafanti.order.enums.IntentionSate;
  36. import com.goafanti.order.enums.LiquidationSate;
  37. import com.goafanti.order.enums.OrderAction;
  38. import com.goafanti.order.enums.OrderChannel;
  39. import com.goafanti.order.enums.OrderState;
  40. import com.goafanti.order.enums.PayChannel;
  41. import com.goafanti.order.enums.PaymentState;
  42. import com.goafanti.order.enums.TradingState;
  43. import com.goafanti.order.enums.TransactionMode;
  44. import com.goafanti.order.enums.TransactionSubject;
  45. import com.goafanti.order.service.OrderService;
  46. @Service
  47. public class OrderServiceImpl extends BaseMybatisDao<TOrderMapper> implements OrderService {
  48. @Autowired
  49. private TOrderMapper tOrderMapper;
  50. @Autowired
  51. private JDBCIdGenerator idGenerator;
  52. @Autowired
  53. private TFundingRecordsMapper tFundingRecordsMapper;
  54. private final BigDecimal DEFAULT_FIRST_PAYMENT = new BigDecimal(0);// 默认首付价格
  55. private final BigDecimal DEFAULT_COMMODITY_PRICE = new BigDecimal(0);// 默认单价
  56. private final String DEFAULT_PLATFORM_ID = "0";// 平台默认id
  57. private final double DEFAULT_BROKERAGE_PROPORTION = 0; //佣金比例
  58. private final double DEFAULT_COMMODITY_DISCOUNT = 1; //折扣比例
  59. private final String DEFAULT_COMMODITY_MODE = "NO_MODE"; //暂无规格
  60. @Override
  61. public OrderDetailBo selectCommodityDetail(String commodityId, Integer commodityType) {
  62. OrderDetailBo bo = tOrderMapper.selectCommodityDetail(commodityId,commodityType);
  63. bo.setOrderNo(String.valueOf(idGenerator.generateId()));
  64. bo.setCreateTime(DateUtils.formatDate(new Date(),AFTConstants.YYYYMMDDHHMMSS));
  65. bo.setCommodityType(commodityType);
  66. if(StringUtils.isBlank(bo.getFirstPayment()))
  67. bo.setFirstPayment(String.valueOf(DEFAULT_FIRST_PAYMENT.doubleValue()));
  68. return bo;
  69. }
  70. @Override
  71. public int addIntention(Long orderNo, String commodityId, String commodityMode, Integer commodityQuantity,Integer commodityType,
  72. String createTime,String remarks) throws ParseException {
  73. OrderDetailBo bo = tOrderMapper.selectCommodityDetail(commodityId,commodityType);
  74. BigDecimal commodityPrice = StringUtils.isBlank(bo.getCommodityPrice()) ? DEFAULT_COMMODITY_PRICE
  75. : new BigDecimal(DecimalCalculate.mul(Double.valueOf(bo.getCommodityPrice()),DEFAULT_COMMODITY_DISCOUNT));
  76. BigDecimal orderAmount = new BigDecimal(DecimalCalculate.mul(commodityPrice.doubleValue(),Double.valueOf(String.valueOf(commodityQuantity))));
  77. TOrder tOrder = new TOrder();
  78. tOrder.setOrderNo(orderNo);
  79. tOrder.setCommodityId(commodityId);
  80. tOrder.setCreater(TokenManager.getUserToken().getNickname());
  81. tOrder.setCreateTime(DateUtils.parseDate(createTime, AFTConstants.YYYYMMDDHHMMSS));
  82. if(commodityType == CommodityType.DEMAND_PROVIDE.getTypeCode()){
  83. tOrder.setBuyerId(StringUtils.isBlank(bo.getSellerId()) ? DEFAULT_PLATFORM_ID : bo.getSellerId());
  84. tOrder.setSellerId(TokenManager.getUserId());
  85. }else{
  86. tOrder.setBuyerId(TokenManager.getUserId());
  87. tOrder.setSellerId(StringUtils.isBlank(bo.getSellerId()) ? DEFAULT_PLATFORM_ID : bo.getSellerId());
  88. }
  89. tOrder.setCommodityMode(StringUtils.isBlank(commodityMode)?DEFAULT_COMMODITY_MODE: commodityMode);
  90. tOrder.setCommodityType(commodityType);
  91. tOrder.setCommodityQuantity(commodityQuantity);
  92. tOrder.setBrokerageProportion(new BigDecimal(DEFAULT_BROKERAGE_PROPORTION));
  93. tOrder.setBrokerageAmount(new BigDecimal(DecimalCalculate.mul(commodityPrice.doubleValue(), DEFAULT_BROKERAGE_PROPORTION)));
  94. tOrder.setFirstPayment(DEFAULT_FIRST_PAYMENT);
  95. tOrder.setCommodityPrice(commodityPrice);
  96. tOrder.setOrderAmount(orderAmount);
  97. tOrder.setOrderRemarks(remarks);
  98. tOrder.setDeleteSign(Boolean.FALSE);
  99. tOrder.setOrderChannel(OrderChannel.APP.getCode());
  100. setOrderState(OrderAction.ADD_INTENTION, new BigDecimal(0), tOrder, false);
  101. tOrderMapper.insert(tOrder);
  102. return 1;
  103. }
  104. /**
  105. * 订单状态流转
  106. * @param orderStatus
  107. * @param intentionStatus
  108. * @param tradingStatus
  109. * @param paymentStatus
  110. * @param liquidationStatus
  111. * @param actionType
  112. */
  113. public void setOrderState(OrderAction orderAction,BigDecimal changeAmount,TOrder tOrder,boolean confirm){
  114. if(orderAction == OrderAction.ADD_INTENTION){ //添加意向订单
  115. if(tOrder.getOrderStatus() != null || tOrder.getIntentionStatus() != null || tOrder.getTradingStatus() != null
  116. || tOrder.getPaymentStatus() != null || tOrder.getLiquidationStatus() != null
  117. || tOrder.getActuallyBrokerageAmount() != null || tOrder.getActuallyFirstPayment() != null) {
  118. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"添加意向订单"));
  119. }
  120. tOrder.setOrderStatus(OrderState.INTENTION.getCode());
  121. tOrder.setIntentionStatus(IntentionSate.WAIT_SELLER_CONFIRM.getCode());
  122. tOrder.setTradingStatus(TradingState.WAIT_FOR_TRADE.getCode());
  123. tOrder.setPaymentStatus(PaymentState.WAIT_PAY_FIRST_BALANCE.getCode());
  124. tOrder.setLiquidationStatus(LiquidationSate.WAIT_FOR_PAY.getCode());
  125. tOrder.setActuallyFirstPayment(new BigDecimal(0));
  126. tOrder.setActuallyTotalPayment(new BigDecimal(0));
  127. tOrder.setActuallyBrokerageAmount(new BigDecimal(0));
  128. }else if(orderAction == OrderAction.CONFIRM_INTENTION){ //确认意向订单 (用户确认)
  129. if(tOrder.getOrderStatus() != OrderState.INTENTION.getCode()
  130. || tOrder.getIntentionStatus() != IntentionSate.WAIT_SELLER_CONFIRM.getCode()
  131. || tOrder.getTradingStatus() != TradingState.WAIT_FOR_TRADE.getCode()
  132. || tOrder.getPaymentStatus() != PaymentState.WAIT_PAY_FIRST_BALANCE.getCode()
  133. || tOrder.getLiquidationStatus() != LiquidationSate.WAIT_FOR_PAY.getCode()){
  134. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"确认意向订单"));
  135. }
  136. if(confirm){
  137. tOrder.setOrderStatus(OrderState.WAIT_FOR_PAY.getCode());
  138. tOrder.setIntentionStatus(IntentionSate.SELLER_CONFIRM.getCode());
  139. tOrder.setTradingStatus(TradingState.ON_TRADE.getCode());
  140. }else{
  141. tOrder.setOrderStatus(OrderState.CANCELLED.getCode());
  142. tOrder.setIntentionStatus(IntentionSate.SELLER_REFUSE.getCode());
  143. tOrder.setTradingStatus(TradingState.TRADE_FAILED.getCode());
  144. }
  145. }else if(orderAction == OrderAction.CONFIRM_PAY_FOR_FIRST){ // 支付首付(审核员先审核流水)
  146. if(tOrder.getOrderStatus() != OrderState.WAIT_FOR_PAY.getCode()
  147. || tOrder.getIntentionStatus() != IntentionSate.SELLER_CONFIRM.getCode()
  148. || tOrder.getTradingStatus() != TradingState.ON_TRADE.getCode()
  149. || tOrder.getPaymentStatus() != PaymentState.WAIT_PAY_FIRST_BALANCE.getCode()
  150. || tOrder.getLiquidationStatus() != LiquidationSate.WAIT_FOR_PAY.getCode()){
  151. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,""));
  152. }
  153. int boundary = DecimalCalculate.compareTo(
  154. DecimalCalculate.add(tOrder.getActuallyFirstPayment().doubleValue(),changeAmount.doubleValue()),
  155. tOrder.getFirstPayment().doubleValue());
  156. if(boundary == 1){
  157. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"支付首付款"));
  158. }else if(boundary == -1){ //首付待付清 ()
  159. tOrder.setActuallyTotalPayment(
  160. new BigDecimal(DecimalCalculate.add(tOrder.getActuallyTotalPayment().doubleValue(), changeAmount.doubleValue())));
  161. tOrder.setActuallyFirstPayment(
  162. new BigDecimal(DecimalCalculate.add(tOrder.getActuallyFirstPayment().doubleValue(), changeAmount.doubleValue())));
  163. tOrder.setPaymentStatus(PaymentState.WAIT_PAY_FIRST_BALANCE.getCode());
  164. tOrder.setLiquidationStatus(LiquidationSate.PART_PAY.getCode());
  165. }else if(boundary == 0){ //首付已结清
  166. tOrder.setActuallyTotalPayment(
  167. new BigDecimal(DecimalCalculate.add(tOrder.getActuallyTotalPayment().doubleValue(), changeAmount.doubleValue())));
  168. tOrder.setActuallyFirstPayment(
  169. new BigDecimal(DecimalCalculate.add(tOrder.getActuallyFirstPayment().doubleValue(),changeAmount.doubleValue())));
  170. tOrder.setPaymentStatus(PaymentState.ALREADY_FIRST_PAY.getCode());
  171. tOrder.setLiquidationStatus(LiquidationSate.PART_PAY.getCode());
  172. }
  173. }else if(orderAction == OrderAction.CONFIRM_PAY_FOR_LAST){ //支付尾款 (审核员先审核流水)
  174. if(tOrder.getOrderStatus() != OrderState.WAIT_FOR_PAY.getCode()
  175. || tOrder.getIntentionStatus() != IntentionSate.SELLER_CONFIRM.getCode()
  176. || tOrder.getTradingStatus() != TradingState.ON_TRADE.getCode()
  177. || tOrder.getPaymentStatus() != PaymentState.ALREADY_FIRST_PAY.getCode()
  178. || tOrder.getLiquidationStatus() != LiquidationSate.PART_PAY.getCode()){
  179. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"支付尾款"));
  180. }
  181. int boundary = DecimalCalculate.compareTo(
  182. DecimalCalculate.add(tOrder.getActuallyTotalPayment().doubleValue(),changeAmount.doubleValue()),
  183. tOrder.getOrderAmount().doubleValue());
  184. if(boundary == 1){
  185. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"支付尾款"));
  186. }else if(boundary == -1){
  187. tOrder.setActuallyTotalPayment(
  188. new BigDecimal(DecimalCalculate.add(tOrder.getActuallyTotalPayment().doubleValue(), changeAmount.doubleValue())));
  189. tOrder.setPaymentStatus(PaymentState.WAIT_PAY_LAST_BALANCE.getCode());
  190. tOrder.setLiquidationStatus(LiquidationSate.PART_PAY.getCode());
  191. }else if(boundary == 0){
  192. tOrder.setOrderStatus(OrderState.COMPLETED.getCode());
  193. tOrder.setActuallyTotalPayment(
  194. new BigDecimal(DecimalCalculate.add(tOrder.getActuallyTotalPayment().doubleValue(), changeAmount.doubleValue())));
  195. tOrder.setPaymentStatus(PaymentState.ALREADY_LAST_PAY.getCode());
  196. tOrder.setLiquidationStatus(LiquidationSate.FULL_PAY.getCode());
  197. tOrder.setTradingStatus(TradingState.TRADE_SUCCESS.getCode());
  198. }
  199. }else if(orderAction == OrderAction.APPLY_FOR_WITHDRAW){ //提现申请 (用户申请)
  200. if(tOrder.getOrderStatus() != OrderState.COMPLETED.getCode()
  201. || tOrder.getIntentionStatus() != IntentionSate.SELLER_CONFIRM.getCode()
  202. || tOrder.getTradingStatus() != TradingState.TRADE_SUCCESS.getCode()
  203. || tOrder.getPaymentStatus() != PaymentState.ALREADY_LAST_PAY.getCode()
  204. || tOrder.getLiquidationStatus() != LiquidationSate.FULL_PAY.getCode()){
  205. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"等待提现"));
  206. }
  207. tOrder.setLiquidationStatus(LiquidationSate.WAIT_FOR_WITHDRAW.getCode());
  208. }else if(orderAction == OrderAction.CONFIRM_WITHDRAW){ //提现确认 (审核员先审核流水)
  209. if(tOrder.getOrderStatus() != OrderState.COMPLETED.getCode()
  210. || tOrder.getIntentionStatus() != IntentionSate.SELLER_CONFIRM.getCode()
  211. || tOrder.getTradingStatus() != TradingState.TRADE_SUCCESS.getCode()
  212. || tOrder.getPaymentStatus() != PaymentState.ALREADY_LAST_PAY.getCode()
  213. || tOrder.getLiquidationStatus() != LiquidationSate.WAIT_FOR_WITHDRAW.getCode()){
  214. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"确认提现"));
  215. }
  216. tOrder.setLiquidationStatus(LiquidationSate.PAY_SETTLE.getCode());
  217. }else if(orderAction == OrderAction.APPLY_FOR_CANCEL){ //取消订单(用户取消)
  218. boolean flag = true;
  219. if(tOrder.getOrderStatus() == OrderState.CANCELLED.getCode()) flag = false;
  220. if(tOrder.getIntentionStatus() == IntentionSate.SELLER_REFUSE.getCode()
  221. || tOrder.getIntentionStatus() == IntentionSate.BUYER_CANCELLED.getCode()
  222. || tOrder.getIntentionStatus() == IntentionSate.EXPIRED.getCode()){
  223. flag = false;
  224. }
  225. if(tOrder.getTradingStatus() == TradingState.TRADE_FAILED.getCode()) flag = false;
  226. if(tOrder.getPaymentStatus() == PaymentState.WAIT_FOR_REFUND.getCode()
  227. || tOrder.getPaymentStatus() == PaymentState.ALREADY_REFUND.getCode()) flag = false;
  228. if(tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_WITHDRAW.getCode()
  229. || tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_REFUND.getCode()
  230. || tOrder.getLiquidationStatus() == LiquidationSate.REFUND_SETTLE.getCode()){
  231. flag = false;
  232. }
  233. if(!flag) throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"取消订单"));
  234. tOrder.setOrderStatus(OrderState.CANCELLED.getCode());
  235. tOrder.setIntentionStatus(IntentionSate.BUYER_CANCELLED.getCode());
  236. if(tOrder.getTradingStatus() != TradingState.TRADE_SUCCESS.getCode()) tOrder.setTradingStatus(TradingState.TRADE_FAILED.getCode());
  237. if(tOrder.getActuallyTotalPayment().doubleValue() > 0){ //需要退款
  238. tOrder.setPaymentStatus(PaymentState.WAIT_FOR_REFUND.getCode());
  239. tOrder.setLiquidationStatus(LiquidationSate.WAIT_FOR_REFUND.getCode());
  240. }
  241. }else if(orderAction == OrderAction.REFUND_CONFIRM){ //退款确认(审核员)
  242. if(tOrder.getOrderStatus() != OrderState.CANCELLED.getCode()
  243. || tOrder.getIntentionStatus() != IntentionSate.BUYER_CANCELLED.getCode()
  244. || tOrder.getPaymentStatus() != PaymentState.WAIT_FOR_REFUND.getCode()
  245. || tOrder.getLiquidationStatus() != LiquidationSate.WAIT_FOR_REFUND.getCode()){
  246. throw new BusinessException(new Error(ErrorConstants.NOT_ACCORD_WITH_NEXT,"确认退款"));
  247. }
  248. tOrder.setPaymentStatus(PaymentState.ALREADY_REFUND.getCode());
  249. tOrder.setLiquidationStatus(LiquidationSate.REFUND_SETTLE.getCode());
  250. }
  251. }
  252. /**
  253. * 添加流水记录
  254. * @param orderNo 订单编号
  255. * @param creater 创建人
  256. * @param payeeId 收款人
  257. * @param payerId 付款人
  258. * @param remarks 附言
  259. * @param transactionSubject 交易科目
  260. * @param payChannel 支付渠道
  261. * @param transactionMode 支付方式
  262. * @param FundAudit 流水审核
  263. * @return
  264. */
  265. public int addFundRecord(Long orderNo,String creater,String payeeId,String payerId,String remarks,TransactionSubject transactionSubject,PayChannel payChannel,
  266. BigDecimal transactionAmount,TransactionMode transactionMode,AuditState auditState){
  267. TFundingRecords records = new TFundingRecords();
  268. records.setId(UUID.randomUUID().toString());
  269. records.setConfirmSign(auditState.getCode());
  270. records.setCreater(creater);
  271. records.setDeleteSign(Boolean.FALSE);
  272. records.setOrderNo(orderNo);
  273. records.setTransactionAmount(transactionAmount);
  274. records.setPayeeId(payeeId);
  275. records.setPayerId(payerId);
  276. records.setRemarks(remarks);
  277. records.setTransactionAmount(transactionAmount);
  278. records.setTransactionMode(transactionMode.getCode());
  279. records.setTransactionSubject(transactionSubject.getCode());
  280. records.setTransactionChannel(payChannel.getCode());
  281. records.setCreateTime(new Date());
  282. tFundingRecordsMapper.insert(records);
  283. return 1;
  284. }
  285. /**
  286. * 设置按钮状态
  287. * @param tOrder
  288. * @return
  289. */
  290. private OperatorActive setOperatorActive(TOrder tOrder){
  291. OperatorActive active = new OperatorActive();
  292. if (TokenManager.getToken() instanceof User) {
  293. active.setConfirmPayForFirst(false);
  294. active.setConfirmPayForLast(false);
  295. active.setConfirmRefund(false);
  296. active.setConfirmWithdraw(false);
  297. if (TokenManager.getUserId().equals(tOrder.getBuyerId())) { // 买方
  298. active.setConfirmIntention(false);
  299. active.setRefuseIntention(false);
  300. active.setApplyForWithdraw(false);
  301. if (tOrder.getOrderStatus() == OrderState.WAIT_FOR_PAY.getCode()
  302. && tOrder.getIntentionStatus() == IntentionSate.SELLER_CONFIRM.getCode()
  303. && tOrder.getTradingStatus() == TradingState.ON_TRADE.getCode()
  304. && tOrder.getPaymentStatus() == PaymentState.WAIT_PAY_FIRST_BALANCE.getCode()
  305. && tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_PAY.getCode()) {
  306. active.setPayForFirst(true);
  307. } else {
  308. active.setPayForFirst(false);
  309. }
  310. if (tOrder.getOrderStatus() == OrderState.WAIT_FOR_PAY.getCode()
  311. && tOrder.getIntentionStatus() == IntentionSate.SELLER_CONFIRM.getCode()
  312. && tOrder.getTradingStatus() == TradingState.ON_TRADE.getCode()
  313. && tOrder.getPaymentStatus() == PaymentState.ALREADY_FIRST_PAY.getCode()
  314. && tOrder.getLiquidationStatus() == LiquidationSate.PART_PAY.getCode()) {
  315. active.setPayForLast(true);
  316. } else {
  317. active.setPayForLast(false);
  318. }
  319. boolean flag = true;
  320. if (tOrder.getOrderStatus() == OrderState.CANCELLED.getCode())
  321. flag = false;
  322. if (tOrder.getIntentionStatus() == IntentionSate.SELLER_REFUSE.getCode()
  323. || tOrder.getIntentionStatus() == IntentionSate.BUYER_CANCELLED.getCode()
  324. || tOrder.getIntentionStatus() == IntentionSate.EXPIRED.getCode()) {
  325. flag = false;
  326. }
  327. if (tOrder.getTradingStatus() == TradingState.TRADE_FAILED.getCode())
  328. flag = false;
  329. if (tOrder.getPaymentStatus() == PaymentState.WAIT_FOR_REFUND.getCode()
  330. || tOrder.getPaymentStatus() == PaymentState.ALREADY_REFUND.getCode())
  331. flag = false;
  332. if (tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_WITHDRAW.getCode()
  333. || tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_REFUND.getCode()
  334. || tOrder.getLiquidationStatus() == LiquidationSate.REFUND_SETTLE.getCode()) {
  335. flag = false;
  336. }
  337. active.setApplyForCancel(flag);
  338. } else if (TokenManager.getUserId().equals(tOrder.getSellerId())) { //卖方
  339. active.setPayForFirst(false);
  340. active.setPayForLast(false);
  341. active.setApplyForCancel(false);
  342. if (tOrder.getOrderStatus() == OrderState.INTENTION.getCode()
  343. && tOrder.getIntentionStatus() == IntentionSate.WAIT_SELLER_CONFIRM.getCode()
  344. && tOrder.getTradingStatus() == TradingState.WAIT_FOR_TRADE.getCode()
  345. && tOrder.getPaymentStatus() == PaymentState.WAIT_PAY_FIRST_BALANCE.getCode()
  346. && tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_PAY.getCode()) {
  347. active.setConfirmIntention(true);
  348. active.setRefuseIntention(true);
  349. } else {
  350. active.setConfirmIntention(false);
  351. active.setRefuseIntention(false);
  352. }
  353. if (tOrder.getOrderStatus() == OrderState.COMPLETED.getCode()
  354. && tOrder.getIntentionStatus() == IntentionSate.SELLER_CONFIRM.getCode()
  355. && tOrder.getTradingStatus() == TradingState.TRADE_SUCCESS.getCode()
  356. && tOrder.getPaymentStatus() == PaymentState.ALREADY_LAST_PAY.getCode()
  357. && tOrder.getLiquidationStatus() == LiquidationSate.FULL_PAY.getCode()) {
  358. active.setApplyForWithdraw(true);
  359. } else {
  360. active.setApplyForWithdraw(false);
  361. }
  362. } else {
  363. active.setPayForFirst(false);
  364. active.setPayForLast(false);
  365. active.setConfirmIntention(false);
  366. active.setRefuseIntention(false);
  367. active.setApplyForCancel(false);
  368. active.setApplyForWithdraw(false);
  369. }
  370. }
  371. if (TokenManager.getToken() instanceof Admin) {
  372. active.setApplyForCancel(false);
  373. active.setPayForFirst(false);
  374. active.setPayForLast(false);
  375. if (tOrder.getSellerId().equals(DEFAULT_PLATFORM_ID)) { // 平台作为卖方
  376. if (tOrder.getOrderStatus() == OrderState.INTENTION.getCode()
  377. && tOrder.getIntentionStatus() == IntentionSate.WAIT_SELLER_CONFIRM.getCode()
  378. && tOrder.getTradingStatus() == TradingState.WAIT_FOR_TRADE.getCode()
  379. && tOrder.getPaymentStatus() == PaymentState.WAIT_PAY_FIRST_BALANCE.getCode()
  380. && tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_PAY.getCode()) {
  381. active.setConfirmIntention(true);
  382. active.setRefuseIntention(true);
  383. } else {
  384. active.setConfirmIntention(false);
  385. active.setRefuseIntention(false);
  386. }
  387. if (tOrder.getOrderStatus() == OrderState.COMPLETED.getCode()
  388. && tOrder.getIntentionStatus() == IntentionSate.SELLER_CONFIRM.getCode()
  389. && tOrder.getTradingStatus() == TradingState.TRADE_SUCCESS.getCode()
  390. && tOrder.getPaymentStatus() == PaymentState.ALREADY_LAST_PAY.getCode()
  391. && tOrder.getLiquidationStatus() == LiquidationSate.FULL_PAY.getCode()) {
  392. active.setApplyForWithdraw(true);
  393. } else {
  394. active.setApplyForWithdraw(false);
  395. }
  396. }else{
  397. active.setConfirmIntention(false);
  398. active.setApplyForWithdraw(false);
  399. }
  400. //平台作为中间方 确认首付 -尾款-提现-退款
  401. if(tOrder.getOrderStatus() == OrderState.WAIT_FOR_PAY.getCode()
  402. && tOrder.getIntentionStatus() == IntentionSate.SELLER_CONFIRM.getCode()
  403. && tOrder.getTradingStatus() == TradingState.ON_TRADE.getCode()
  404. && tOrder.getPaymentStatus() == PaymentState.WAIT_PAY_FIRST_BALANCE.getCode()
  405. && tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_PAY.getCode()){
  406. active.setConfirmPayForFirst(true);
  407. }else{
  408. active.setConfirmPayForFirst(false);
  409. }
  410. if(tOrder.getOrderStatus() == OrderState.WAIT_FOR_PAY.getCode()
  411. && tOrder.getIntentionStatus() == IntentionSate.SELLER_CONFIRM.getCode()
  412. && tOrder.getTradingStatus() == TradingState.ON_TRADE.getCode()
  413. && tOrder.getPaymentStatus() == PaymentState.ALREADY_FIRST_PAY.getCode()
  414. && tOrder.getLiquidationStatus() == LiquidationSate.PART_PAY.getCode()){
  415. active.setConfirmPayForLast(true);
  416. }else{
  417. active.setConfirmPayForLast(false);
  418. }
  419. if(tOrder.getOrderStatus() == OrderState.COMPLETED.getCode()
  420. && tOrder.getIntentionStatus() == IntentionSate.SELLER_CONFIRM.getCode()
  421. && tOrder.getTradingStatus() == TradingState.TRADE_SUCCESS.getCode()
  422. && tOrder.getPaymentStatus() == PaymentState.ALREADY_LAST_PAY.getCode()
  423. && tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_WITHDRAW.getCode()){
  424. active.setConfirmWithdraw(true);
  425. }else{
  426. active.setConfirmWithdraw(false);
  427. }
  428. if(tOrder.getOrderStatus() == OrderState.CANCELLED.getCode()
  429. && tOrder.getIntentionStatus() == IntentionSate.BUYER_CANCELLED.getCode()
  430. && tOrder.getPaymentStatus() == PaymentState.WAIT_FOR_REFUND.getCode()
  431. && tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_REFUND.getCode()){
  432. active.setConfirmRefund(true);
  433. }else{
  434. active.setConfirmRefund(false);
  435. }
  436. }
  437. return active;
  438. }
  439. @Override
  440. public int updatePayForFirst(Long orderNo, BigDecimal fundAmount,String remarks) {
  441. TOrder tOrder = tOrderMapper.selectByPrimaryKey(orderNo);
  442. addFundRecord(orderNo, TokenManager.getUserToken().getNickname(), DEFAULT_PLATFORM_ID, TokenManager.getUserId(), remarks,
  443. TransactionSubject.SUPPLY_PAY,PayChannel.UNIONPAY, fundAmount, TransactionMode.OFFLINE, AuditState.WAIT_AUDIT);
  444. tOrderMapper.updateByPrimaryKeySelective(tOrder);
  445. return 1;
  446. }
  447. @Override
  448. public int updatePayForLast(Long orderNo, BigDecimal fundAmount, String remarks) {
  449. TOrder tOrder = tOrderMapper.selectByPrimaryKey(orderNo);
  450. addFundRecord(orderNo, TokenManager.getUserToken().getNickname(), DEFAULT_PLATFORM_ID, TokenManager.getUserId(), remarks,
  451. TransactionSubject.SUPPLY_PAY,PayChannel.UNIONPAY, fundAmount, TransactionMode.OFFLINE, AuditState.WAIT_AUDIT);
  452. tOrderMapper.updateByPrimaryKeySelective(tOrder);
  453. return 1;
  454. }
  455. @SuppressWarnings("unchecked")
  456. @Override
  457. public Pagination<OrderDetailBo> selectOrderList(boolean confirm,Integer pageNo,Integer pageSize) {
  458. Map<String, Object> params = new HashMap<String, Object>();
  459. Pagination<OrderDetailBo> result = new Pagination<OrderDetailBo>();
  460. if(!confirm) params.put("intentionStatus", IntentionSate.WAIT_SELLER_CONFIRM.getCode()); //购买意向
  461. params.put("uid", TokenManager.getUserId());
  462. Pagination<TOrder> data = (Pagination<TOrder>)findPage("selectOrderListByPage", "selectOrderListCount", params, pageNo, pageSize);
  463. List<TOrder> list = (List<TOrder>)data.getList();
  464. OrderDetailBo bo = null;
  465. List<OrderDetailBo> boList = new ArrayList<OrderDetailBo>();
  466. if(list.size()>0){
  467. for(TOrder t:list){
  468. bo = tOrderMapper.selectCommodityDetail(t.getCommodityId(),t.getCommodityType());
  469. bo.setOrderNo(String.valueOf(t.getOrderNo()));
  470. bo.setCommodityQuantity(t.getCommodityQuantity());
  471. bo.setCommodityMode(t.getCommodityMode());
  472. bo.setCommodityId(t.getCommodityId());
  473. bo.setCommodityPrice(String.valueOf(t.getCommodityPrice()));
  474. bo.setOrderRemarks(t.getOrderRemarks());
  475. bo.setCreateTime(DateUtils.formatDate(t.getCreateTime(),AFTConstants.YYYYMMDDHHMMSS));
  476. bo.setOrderStatus(OrderState.getStatus(t.getOrderStatus()).getDesc());
  477. bo.setCommodityType(t.getCommodityType());
  478. bo.setOrderAmount(String.valueOf(t.getOrderAmount()));
  479. bo.setFirstPayment(String.valueOf(t.getFirstPayment()));
  480. bo.setOperatorActive(setOperatorActive(t));
  481. boList.add(bo);
  482. }
  483. }
  484. result.setList(boList);
  485. result.setPageNo(data.getPageNo());
  486. result.setPageSize(data.getPageSize());
  487. result.setTotalCount(data.getTotalCount());
  488. result.setFilterNo(data.getFilterNo());
  489. return result;
  490. }
  491. @Override
  492. public OrderDetailBo selectOrderDetail(Long orderNo) {
  493. TOrder t = tOrderMapper.selectByPrimaryKey(orderNo);
  494. OrderDetailBo bo = tOrderMapper.selectCommodityDetail(t.getCommodityId(),t.getCommodityType());
  495. bo.setOrderNo(String.valueOf(t.getOrderNo()));
  496. bo.setCommodityQuantity(t.getCommodityQuantity());
  497. bo.setCommodityMode(t.getCommodityMode());
  498. bo.setCommodityId(t.getCommodityId());
  499. bo.setCommodityPrice(String.valueOf(t.getCommodityPrice()));
  500. bo.setOrderRemarks(t.getOrderRemarks());
  501. bo.setCreateTime(DateUtils.formatDate(t.getCreateTime(),AFTConstants.YYYYMMDDHHMMSS));
  502. bo.setOrderStatus(OrderState.getStatus(t.getOrderStatus()).getDesc());
  503. bo.setCommodityType(t.getCommodityType());
  504. bo.setOrderAmount(String.valueOf(t.getOrderAmount()));
  505. bo.setOperatorActive(setOperatorActive(t));
  506. bo.setFirstPayment(String.valueOf(t.getFirstPayment()));
  507. return bo;
  508. }
  509. @SuppressWarnings("unchecked")
  510. @Override
  511. public Pagination<FundingListBo> selectFundingHistory(Long orderNo,Integer pageNo,Integer pageSize) {
  512. Map<String, Object> params = new HashMap<String, Object>();
  513. if(orderNo != null) params.put("orderNo", orderNo);
  514. params.put("uid", TokenManager.getUserId());
  515. Pagination<FundingListBo> data = (Pagination<FundingListBo>)findPage("selectFundingHistoryByPage","selectFundingHistoryCount", params, pageNo, pageSize);
  516. List<FundingListBo> list = (List<FundingListBo>)data.getList();
  517. OrderDetailBo odBo = null;
  518. if(list.size()>0){
  519. for(FundingListBo bo:list){
  520. odBo = tOrderMapper.selectCommodityDetail(bo.getCommodityId(),bo.getCommodityType());
  521. bo.setCommodityName(odBo.getCommodityName());
  522. bo.setBusinessDesc(setBusinessDesc(bo.getTransactionSubject(),bo.getTransactionAmount()));
  523. }
  524. }
  525. data.setList(list);
  526. return data;
  527. }
  528. @Override
  529. @Transactional
  530. public int updateApplyForWithdraw(Long orderNo,String remarks) {
  531. TOrder tOrder = tOrderMapper.selectByPrimaryKey(orderNo);
  532. BigDecimal transactionAmount = new BigDecimal(DecimalCalculate.sub(tOrder.getActuallyTotalPayment().doubleValue(),
  533. tOrder.getActuallyBrokerageAmount().doubleValue()));
  534. addFundRecord(orderNo, TokenManager.getUserToken().getNickname(), TokenManager.getUserId(), DEFAULT_PLATFORM_ID, remarks,
  535. TransactionSubject.SUPPLY_COLLECT, PayChannel.UNIONPAY,transactionAmount,TransactionMode.OFFLINE, AuditState.WAIT_AUDIT);
  536. setOrderState(OrderAction.APPLY_FOR_WITHDRAW, new BigDecimal(0), tOrder, false);
  537. tOrderMapper.updateByPrimaryKeySelective(tOrder);
  538. return 1;
  539. }
  540. @Override
  541. @Transactional
  542. public int updateApplyForCancel(Long orderNo) {
  543. TOrder tOrder = tOrderMapper.selectByPrimaryKey(orderNo);
  544. setOrderState(OrderAction.APPLY_FOR_CANCEL, new BigDecimal(0), tOrder, false);
  545. if(tOrder.getPaymentStatus() == PaymentState.WAIT_FOR_REFUND.getCode()
  546. && tOrder.getLiquidationStatus() == LiquidationSate.WAIT_FOR_REFUND.getCode()){ //退款
  547. BigDecimal transactionAmount = new BigDecimal(DecimalCalculate.sub(tOrder.getActuallyTotalPayment().doubleValue(),
  548. tOrder.getActuallyBrokerageAmount().doubleValue()));
  549. addFundRecord(orderNo, "平台方", DEFAULT_PLATFORM_ID,TokenManager.getUserId(), "买家取消订单",
  550. TransactionSubject.REFUND, PayChannel.UNIONPAY,transactionAmount,TransactionMode.OFFLINE, AuditState.WAIT_AUDIT);
  551. }
  552. tOrderMapper.updateByPrimaryKeySelective(tOrder);
  553. return 1;
  554. }
  555. /**
  556. *
  557. * @param transactionSubject 交易科目
  558. * @param transactionAmount 交易金额
  559. * @param payeeId 收款人
  560. * @param payerId 付款人
  561. * @return
  562. */
  563. private String setBusinessDesc(Integer transactionSubject,BigDecimal transactionAmount){
  564. String result = "";
  565. if(transactionSubject == TransactionSubject.SUPPLY_PAY.getCode() || transactionSubject == TransactionSubject.REFUND.getCode()){
  566. result = "收入-"+transactionAmount;
  567. }else if(transactionSubject == TransactionSubject.SUPPLY_PAY.getCode()){
  568. result = "支出-"+transactionAmount;
  569. }
  570. return result;
  571. }
  572. @Override
  573. public int updateConfirmIntention(Long orderNo, boolean confirm) {
  574. TOrder tOrder = tOrderMapper.selectByPrimaryKey(orderNo);
  575. setOrderState(OrderAction.CONFIRM_INTENTION, new BigDecimal(0), tOrder, confirm);
  576. tOrderMapper.updateByPrimaryKeySelective(tOrder);
  577. return 1;
  578. }
  579. }