1

zj

9 days ago 579177ac64462d0fec885eb10af3097245134f80

 trading-order-admin/src/main/java/com/yami/trading/api/controller/ApiC2cOrderController.java

@@ -26,8 +26,10 @@
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

@RestController
@Slf4j
@@ -61,7 +63,7 @@
    public Object order_open(HttpServletRequest request) throws IOException {
        String currency = request.getParameter("currency");
        if (StringUtils.isEmptyString(currency)) {
            throw new YamiShopBindException("支付币种不正确");
            throw new YamiShopBindException("Invalid payment currency");
        }
        String partyId = SecurityUtils.getCurrentUserId();
        String session_token = sessionTokenService.savePut(partyId);
@@ -109,7 +111,7 @@
               party = userService.getById(partyId);
            log.error("用户"+direction+"开始当前用户uid:"+party.getUserCode()+"当前用户名:"+party.getUserName()+"生成的订单号:"+orderNo);
            if (Constants.SECURITY_ROLE_TEST.equals(party.getRoleName())) {
                throw new YamiShopBindException("无权限");
                throw new YamiShopBindException("Permission denied");
            }

            if (!C2cLock.add(partyId)) {
@@ -120,7 +122,7 @@
            Object object = this.sessionTokenService.cacheGet(session_token);
            this.sessionTokenService.del(session_token);
            if (null == object || !partyId.equals((String) object)) {
                throw new YamiShopBindException("请稍后再试");
                throw new YamiShopBindException("Please try again later");
            }

            if (!party.isEnabled()) {
@@ -133,14 +135,14 @@
            String c2c_sell_only_one = sysparaService.find("c2c_sell_only_one").getSvalue();
            if(StringUtils.isNotEmpty(c2c_sell_only_one)&&"1".equals(c2c_sell_only_one)) {
                if(nofinishOrderCount >= 1) {
                    throw new YamiShopBindException("提交失败，当前有未处理订单");
                    throw new YamiShopBindException("Submission failed, pending order exists");
                }
                Long.valueOf(c2c_sell_only_one).longValue();
            }
            Object obj2 = this.sysparaService.find("c2c_nofinish_order_count_max");
            if (null != obj2) {
                if (nofinishOrderCount >= Long.valueOf(this.sysparaService.find("c2c_nofinish_order_count_max").getSvalue()).longValue()) {
                    throw new YamiShopBindException("用户未结束订单数量已达上限");
                    throw new YamiShopBindException("Too many open orders");
                }
            }

@@ -161,34 +163,34 @@
            Object obj1 = this.sysparaService.find("c2c_order_cancel_day_times");
            if (null != obj1) {
                if (orderCancelDayTimes >= Integer.valueOf(this.sysparaService.find("c2c_order_cancel_day_times").getSvalue()).intValue()) {
                    throw new YamiShopBindException("今日取消订单次数太多了，请明日再试");
                    throw new YamiShopBindException("Too many cancellations today, try again tomorrow");
                }
            }

            C2cAdvert c2cAdvert = this.c2cAdvertService.getById(c2c_advert_id);
            if (null == c2cAdvert) {
                throw new YamiShopBindException("广告不存在");
                throw new YamiShopBindException("Advertisement does not exist");
            }

            C2cPaymentMethod method =c2cPaymentMethodService.get(payment_method_id);
            if (null == method) {
                throw new YamiShopBindException("支付方式不存在");
                throw new YamiShopBindException("Payment method does not exist");
            }

            if (StringUtils.isEmptyString(order_type) || !Arrays.asList("by_amount", "by_num").contains(order_type)) {
                throw new YamiShopBindException("订单类型不正确");
                throw new YamiShopBindException("Invalid order type");
            }

            if (C2cOrder.ORDER_TYPE_BY_AMOUNT.equals(order_type)) {
                // 按支付金额支付
                if (StringUtils.isEmptyString(amount) || !StringUtils.isDouble(amount) || Double.valueOf(amount).doubleValue() <= 0) {
                    throw new YamiShopBindException("支付金额不正确");
                    throw new YamiShopBindException("Invalid payment amount");
                }
                coin_amount = "0";
            } else {
                // 按币种数量支付
                if (StringUtils.isEmptyString(coin_amount) || !StringUtils.isDouble(coin_amount) || Double.valueOf(coin_amount).doubleValue() <= 0) {
                    throw new YamiShopBindException("币种数量不正确");
                    throw new YamiShopBindException("Invalid currency amount");
                }
                amount = "0";
            }
@@ -211,6 +213,7 @@
            this.c2cOrderService.saveOpen(c2cOrder,remarks);
            data.put("order_no", c2cOrder.getOrderNo());
            resultObject.setData(data);
            resultObject.setCode(0);
        } catch (BusinessException e) {
            log.error("用户"+direction+"执行异常1当前用户uid:"+party.getUserCode()+"当前用户名:"+party.getUserName()+"生成的订单号:"+orderNo);
            resultObject.setCode(1);
@@ -219,7 +222,8 @@
        } catch (Throwable t) {
            log.error("用户"+direction+"执行异常2当前用户uid:"+party.getUserCode()+"当前用户名:"+party.getUserName()+"生成的订单号:"+orderNo);
            resultObject.setCode(1);
            resultObject.setMsg("程序错误");
            //resultObject.setMsg("程序错误");
            resultObject.setMsg(t.getMessage());
            log.error("error:", t);
        }  finally {
            if (lock) {
@@ -230,4 +234,185 @@
        return resultObject;
    }

    @RequestMapping(action + "pay_finish.action")
    public Object pay_finish(HttpServletRequest request) {
        String order_no = request.getParameter("order_no");
        String safe_password = request.getParameter("safe_password");

        Result resultObject = new Result();

        boolean lock = false;

        try {

            String partyId = SecurityUtils.getCurrentUserId();
            if (null == partyId) {
                throw new BusinessException("Please log in again");
            }

            User party = userService.getById(partyId);
            if (Constants.SECURITY_ROLE_TEST.equals(party.getRoleName())) {
                throw new BusinessException("Permission denied");
            }

            if (!userService.checkLoginSafeword(partyId, safe_password)) {
                throw new BusinessException("Incorrect fund password");
            }

            if (!party.isEnabled()) {
                return Result.succeed("User is locked");
            }

            C2cOrder order = this.c2cOrderService.get(order_no);
            if (null == order) {
                throw new BusinessException("Order does not exist");
            }

            if (partyId.equals(order.getPartyId())) {
                // 用户操作
                if (!"buy".equals(order.getDirection())) {
                    throw new BusinessException("User cannot pay for a sell order");
                }
            } else if (partyId.equals(order.getC2cUserPartyId())) {
                // 承兑商操作
                if (!"sell".equals(order.getDirection())) {
                    throw new BusinessException("Merchant cannot pay for a buy order");
                }
            } else {
                throw new BusinessException("Permission denied");
            }

            if (!"0".equals(order.getState())) {
                throw new BusinessException("Order is not in unpaid status");
            }

            if (!C2cOrderLock.add(order_no)) {
                throw new BusinessException(1, "Please try again later");
            }

            lock = true;

            order.setState("1");
            order.setPayTime(new Date());
            this.c2cOrderService.updateById(order);

            if (Arrays.asList("0", "1").contains(order.getState())) {
                // 只有未付款和已付款的订单存入redis
                redisTemplate.opsForValue().set(RedisKeys.C2C_ORDER_NO + order.getOrderNo(), order);
            } else {
                redisTemplate.delete(RedisKeys.C2C_ORDER_NO + order.getOrderNo());
            }

            // 订单自动取消时间和确认收款超时时间（0未付款/1已付款）
            Map<String, Long> map = (Map<String, Long>) redisTemplate.opsForValue().get(RedisKeys.C2C_ORDER_NO_EXPIRE_TIME);
            if (null == map) {
                map = new ConcurrentHashMap<String, Long>();
            }
            if (!Arrays.asList("0", "1").contains(order.getState())) {
                map.remove(order.getOrderNo() + "_auto_cancel");
                map.remove(order.getOrderNo() + "_expire");
            } else {
                if (Arrays.asList("0").contains(order.getState())) {
                    map.put(order.getOrderNo() + "_auto_cancel", order.getCreateTime().getTime() + (long) order.getExpireTime() * 60 * 1000);
                    map.put(order.getOrderNo() + "_expire", order.getCreateTime().getTime() + (long) order.getExpireTime() * 60 * 1000 * 2);
                } else if (Arrays.asList("1").contains(order.getState())) {
                    map.put(order.getOrderNo() + "_auto_cancel", order.getCreateTime().getTime() + (long) order.getExpireTime() * 60 * 1000);
                    map.put(order.getOrderNo() + "_expire", order.getPayTime().getTime() + (long) order.getExpireTime() * 60 * 1000);
                }
            }
            this.redisTemplate.opsForValue().set(RedisKeys.C2C_ORDER_NO_EXPIRE_TIME, map);

            resultObject.setCode(0);
        } catch (BusinessException e) {
            resultObject.setCode(1);
            resultObject.setMsg(e.getMessage());
            log.error("error: {}", e.getMessage());
        } catch (Throwable t) {
            resultObject.setCode(1);
            //resultObject.setMsg("程序错误");
            resultObject.setMsg(t.getMessage());
            log.error("error:", t);
        } finally {
            if (lock) {
                ThreadUtils.sleep(100);
                C2cOrderLock.remove(order_no);
            }
        }

        return resultObject;
    }

    /**
     * 订单放行
     */
    @RequestMapping(action + "order_pass.action")
    public Object order_pass(HttpServletRequest request) {
        String order_no = request.getParameter("order_no");
        String safe_password = request.getParameter("safe_password");

        Result resultObject = new Result();
        boolean lock = false;
        try {

            String partyId = SecurityUtils.getCurrentUserId();
            if (null == partyId) {
                throw new BusinessException("Please log in again");
            }

            User party = userService.getById(partyId);
            if (Constants.SECURITY_ROLE_TEST.equals(party.getRoleName())) {
                throw new BusinessException("Permission denied");
            }

            if (!C2cOrderLock.add(order_no)) {
                throw new BusinessException(1, "Please try again later");
            }

            lock = true;

            if (!userService.checkLoginSafeword(partyId, safe_password)) {
                throw new BusinessException("Incorrect fund password");
            }
            if (!party.isEnabled()) {
                return Result.succeed("User is locked");
            }

            C2cOrder order = this.c2cOrderService.get(order_no);
            if (null == order || !order.getPartyId().equals(partyId)) {
                throw new BusinessException("Order does not exist");
            }
            if ("0".equals(order.getState())) {
                throw new BusinessException("Unpaid order cannot be released");
            }
            if ("3".equals(order.getState())) {
                resultObject.setCode(0);
                return resultObject;
                //throw new BusinessException("订单已完成，无法放行");
            }
            if ("4".equals(order.getState())) {
                throw new BusinessException("Cancelled order cannot be released");
            }

            this.c2cOrderService.saveOrderPass(order);
            resultObject.setCode(0);
        } catch (BusinessException e) {
            resultObject.setCode(1);
            resultObject.setMsg(e.getMessage());
            log.error("error:{}", e.getMessage());
        } catch (Throwable t) {
            resultObject.setCode(1);
            //resultObject.setMsg("程序错误");
            resultObject.setMsg(t.getMessage());
            log.error("error:", t);
        } finally {
            if (lock) {
                ThreadUtils.sleep(100);
                C2cOrderLock.remove(order_no);
            }
        }

        return resultObject;
    }


}