car-wash-java/car-wash-service/src/main/java/com/kym/service/miniapp/impl/WashOrderServiceImpl.java

package com.kym.service.miniapp.impl;

import cn.dev33.satoken.stp.StpUtil;
import com.github.pagehelper.PageHelper;
import com.kym.common.exception.BusinessException;
import com.kym.common.utils.CommUtil;
import com.kym.common.utils.OrderUtils;
import com.kym.entity.common.PageBean;
import com.kym.entity.common.PageParams;
import com.kym.entity.miniapp.Account;
import com.kym.entity.miniapp.User;
import com.kym.entity.miniapp.WashOrder;
import com.kym.entity.miniapp.queryParams.DeviceQueryParams;
import com.kym.entity.miniapp.queryParams.WashOrderQueryParams;
import com.kym.entity.miniapp.vo.WashOrderVo;
import com.kym.mapper.miniapp.WashOrderMapper;
import com.kym.service.awoara.AwoaraService;
import com.kym.service.miniapp.AccountService;
import com.kym.service.miniapp.WashOrderService;
import com.kym.service.mybatisplus.MyBaseServiceImpl;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;

/**
 * <p>
 * 洗车订单表 服务实现类
 * </p>
 *
 * @author skyline
 * @since 2024-09-11
 */
@Service
public class WashOrderServiceImpl extends MyBaseServiceImpl<WashOrderMapper, WashOrder> implements WashOrderService {

    private final AwoaraService awoaraService;
    private final AccountService accountService;

    public WashOrderServiceImpl(AwoaraService awoaraService, AccountService accountService) {
        this.awoaraService = awoaraService;
        this.accountService = accountService;
    }

    /**
     * 创建订单（启动洗车机）
     *
     * @param params
     * @return
     */
    @Override
    public String createOrder(DeviceQueryParams params) {
        // 校验余额
        var account = accountService.getAccountByUserId(StpUtil.getLoginIdAsLong());
        if (account.getBalance() < Account.MIN_BALANCE) {
            throw new BusinessException("余额不足，请保持余额不低于2元！");
        }

        // 校验用户是否有未完结的订单
        var unfinishedOrder = lambdaQuery()
                .eq(WashOrder::getUserId, StpUtil.getLoginIdAsLong())
                .eq(WashOrder::getOrderStatus, WashOrder.ORDER_STATUS_开机)
                .or()
                .eq(WashOrder::getPayStatus, WashOrder.PAY_STATUS_未支付)
                .list();
        if (!unfinishedOrder.isEmpty()) {
            throw new BusinessException("您有未完结的订单！");
        }

        var memberName = StpUtil.getSession().getString(User.ST_SESSION_KEY_MOBILE);
        var orderId = OrderUtils.getOrderNo();

        // 请求阿里云lot
        var createOrder = awoaraService.createOrder(params.getProductKey(), params.getDeviceName(),
                orderId,
                memberName,
                account.getBalance(),
                Account.NO_DISCOUNT,
                // 本次开机最大消费金额，减去0.5元，防止延时导致超消费
                account.getBalance() - 50);
        var washOrder = new WashOrder()
                .setUserId(StpUtil.getLoginIdAsLong())
                .setStationId(params.getStationId())
                .setProductKey(params.getProductKey())
                .setDeviceName(params.getDeviceName())
                .setOpenType(WashOrder.START_CLOSE_TYPE_网络)
                .setOrderId(orderId)
                .setOrderIdLocal(createOrder.getOrder_id_local())
                .setMemberDiscount(Account.NO_DISCOUNT)
                .setPrepayMoney(account.getBalance() - 50)
                .setStartTime(LocalDateTime.now())
                .setOrderStatus(WashOrder.ORDER_STATUS_开机)
                .setPayStatus(WashOrder.PAY_STATUS_未支付);
        save(washOrder);
        return orderId;
    }

    @Override
    public void closeOrder(DeviceQueryParams params) {
        var order = lambdaQuery()
                .eq(WashOrder::getProductKey, params.getProductKey())
                .eq(WashOrder::getDeviceName, params.getDeviceName())
                .eq(WashOrder::getOrderStatus, WashOrder.ORDER_STATUS_开机)
                .eq(WashOrder::getPayStatus, WashOrder.PAY_STATUS_未支付)
                .one();
        if (order != null) {
            awoaraService.closeOrder(params.getProductKey(), params.getDeviceName(), order.getOrderId());
        }
    }

    /**
     * 查询订单详情
     *
     * @param params
     * @return
     */
    @Override
    public WashOrder queryOrder(WashOrderQueryParams params) {
        // 非实时数据
        return lambdaQuery()
                .eq(WashOrder::getOrderId, params.getOrderId())
                .one();
    }

    /**
     * 当前用户订单列表
     *
     * @param params
     * @return
     */
    @Override
    public PageBean<WashOrderVo> listMyWashOrder(PageParams params) {
        PageHelper.startPage(params.getPageNum(), params.getPageSize());
        var res = lambdaQuery()
                .eq(WashOrder::getUserId, StpUtil.getLoginIdAsLong())
                .orderByDesc(WashOrder::getId)
                .list();
        var voList = res.stream().map(order -> {
            var vo = new WashOrderVo();
            BeanUtils.copyProperties(order, vo);
            return vo;
        }).toList();
        return new PageBean<>(voList);
    }


    //region 管理后台
    @Override
    public PageBean<WashOrderVo> list(WashOrderQueryParams query) {
        PageHelper.startPage(query.getPageNum(), query.getPageSize());
        var res = lambdaQuery()
                .eq(CommUtil.isNotEmptyAndNull(query.getStationId()), WashOrder::getStationId, query.getStationId())
                .like(CommUtil.isNotEmptyAndNull(query.getOrderId()), WashOrder::getOrderId, query.getOrderId())
                .orderByDesc(WashOrder::getId)
                .list();
        var voList = res.stream().map(order -> {
            var vo = new WashOrderVo();
            BeanUtils.copyProperties(order, vo);
            return vo;
        }).toList();
        return new PageBean<>(voList);
    }

    @Override
    public WashOrder detail(long id) {
        return getById(id);
    }
    //endregion
}