充电桩

liuhaonan

2022-06-29 be186f360aa619e94988bdaf83486bc69bcaf72c

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/C3mOrderService.java

@@ -9,6 +9,7 @@
import com.sandu.common.execption.BusinessException;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5C3HeartbeatReportInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.C3mRedisConstant;
import com.sandu.ximon.admin.pay.OrderStatusEnums;
import com.sandu.ximon.admin.pay.wx.WxFastPayService;
@@ -26,7 +27,6 @@
import com.sandu.ximon.dao.mapper.C3mOrderMapper;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;
@@ -47,6 +47,12 @@
    private final OrderQueryListener orderQueryListener;
    private final Snowflake snowflake;

    /**
     * 退款
     * @param outTradeNo
     * @param refundAmount
     * @return
     */
    public boolean orderRefund(String outTradeNo, Double refundAmount/*, Long userId, String username*/) {
        Long userId = SecurityUtils.getUserId();
        String username = SecurityUtils.getUsername();
@@ -134,7 +140,7 @@
     * @return
     */
    public C3mOrder advancePayOrder(Long streetlightId, C3mCharging c3m, String orderType, Double totalAmount,
                                    Integer subscribeChargingCapacity) {
                                    Integer subscribeChargingCapacity, String wxCode) {

        //  判断该充电桩是否存在正在进行中的订单
        String chargingJson = redisUtils.get(C3mRedisConstant.C3_CHARGING_ORDER.getCode() + c3m.getC3Mac());
@@ -168,6 +174,7 @@
        c3mOrderEntity.setPoleName(pole.getPoleName());
        c3mOrderEntity.setC3Mac(c3m.getC3Mac());
        c3mOrderEntity.setOrderStatus(0);
        c3mOrderEntity.setUserCode(wxCode);


        //  推送到自动查询模块，进行扫描启动
@@ -221,6 +228,32 @@
    }

    /**
     * 根据灯杆id获取最近一条订单
     */
    public C3mOrder getLastOrderByPoleId(Long poleId) {
        LambdaQueryWrapper<C3mOrder> wrapper = Wrappers.lambdaQuery(C3mOrder.class).eq(C3mOrder::getPoleId, poleId).last("limit 1");
        return getOne(wrapper);
    }


    /**
     * 根据心跳包更新订单状态
     */
    public void updateOrderStatusByHeartbeat(A5C3HeartbeatReportInnerFrame.HeartBeatDataPackage dataPackage) {
        C3mOrder c3mOrder = getOne(Wrappers.lambdaQuery(C3mOrder.class).eq(C3mOrder::getC3Mac, dataPackage.getC3Mac())
                .eq(C3mOrder::getChargingStates,1).last("limit 1"));
        if (c3mOrder == null) {
            return;
        }
        //更新充电总量
        c3mOrder.setActualChargingCapacityHide(Double.parseDouble(dataPackage.getChargedCapacity()));
        //更新剩余金额
        c3mOrder.setSurplusAmount(Double.parseDouble(dataPackage.getRemainingAmount()));
        updateById(c3mOrder);
    }


    /**
     * 订单列表
     *
     * @param baseConditionVO
@@ -232,4 +265,16 @@
        List<C3mOrderBo> list = baseMapper.orderList(userId);
        return list;
    }


    /**
     * 获取创建时间超过10分钟的订单 并且没有支付的订单
     */
    public void getOrderListByCreateTime() {
        // 获取当前时间戳
        long time = new Date().getTime();
        //删除超过10分钟未付款的订单
        remove(Wrappers.lambdaQuery(C3mOrder.class).lt(C3mOrder::getCreateTimestamp, time).eq(C3mOrder::getOrderStatus, 0));
    }

}