提交

zhangback

2025-12-30 939ee5a461a64b40b23d2b5f51c69dead13ee7e3

 tms/src/main/java/com/ruoyi/tms/service/impl/TmsDispatchOrderServiceImpl.java

@@ -19,6 +19,8 @@
import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.system.service.ISystemDataNoService;
import com.ruoyi.tms.domain.*;
import com.ruoyi.tms.domain.vo.DpDriverDispatchItemVo;
import com.ruoyi.tms.domain.vo.DpDriverDispatchVo;
import com.ruoyi.tms.domain.vo.DriverDispatchVo;
import com.ruoyi.tms.domain.vo.ServiceProviderVo;
import com.ruoyi.tms.mapper.*;
@@ -85,6 +87,8 @@
    private TmsServiceProviderMapper tmsServiceProviderMapper;
    @Resource
    private TmsCustomsServiceProviderMapper tmsCustomsServiceProviderMapper;
    @Resource
    private  TmsTripMapper tmsTripMapper;

    /**
     * 查询调度单管理
@@ -164,6 +168,9 @@
        tmsDispatchOrderNew.setLicensePlate(null);
        tmsDispatchOrderNew.setUpdateBy(null);
        tmsDispatchOrderNew.setId(null);
        tmsDispatchOrderNew.setAccountsReceivableStatus(0);
        tmsDispatchOrderNew.setAccountsPayableStatus(0);



        int i = insertTmsDispatchOrder(tmsDispatchOrderNew);
@@ -194,6 +201,27 @@
        return AjaxResult.success("操作成功");
    }

    @Override
    public AjaxResult close(Integer id) {
        TmsDispatchOrder tmsDispatchOrder = selectTmsDispatchOrderById(id);
        if (tmsDispatchOrder == null){
            return AjaxResult.error("未找到该数据");
        }
        if (tmsDispatchOrder.getIsfk() == 0){
            return AjaxResult.success();
        }
        TmsTrip tmsTrip = tmsTripMapper.selectOne(new LambdaQueryWrapper<TmsTrip>().eq(TmsTrip::getDispatchOrderId, id)
                .eq(TmsTrip::getTripType, 0)
                .orderByDesc(TmsTrip::getId)
                .last("limit 1")
        );

        if (tmsTrip != null){
            return AjaxResult.error("该调度单状态为【在途】，且司机于【"+DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", tmsTrip.getTripTime())+"】已发车，不允许作废，如需取消行程，" +
                    "请通知司机操作返空即可。");
        }
        return AjaxResult.success("操作成功");
    }

    @Override
    public AjaxResult connectHang(TmsDriverDispatch driverDispatch) {
@@ -206,6 +234,27 @@
        return AjaxResult.success();
    }

    @Override
    public AjaxResult closeOrder(TmsDispatchOrder order) {
        TmsDispatchOrder tmsDispatchOrder = selectTmsDispatchOrderById(order.getId());
        if (tmsDispatchOrder == null){
            return AjaxResult.error("未找到该数据");
        }
        AjaxResult close = close(tmsDispatchOrder.getId());
        if (close.isSuccess()){
            tmsDispatchOrder.setStatus(5);
            tmsDispatchOrder.setCloseBy(SecurityUtils.getUsername());
            tmsDispatchOrder.setCloseTime(DateUtils.getNowDate());
            tmsDispatchOrder.setCloseRemark(tmsDispatchOrder.getCloseRemark());
            tmsDispatchOrder.setCloseWhy(tmsDispatchOrder.getCloseWhy());
            tmsDispatchOrderMapper.updateTmsDispatchOrder(tmsDispatchOrder);
            // TODO 加日志

            return AjaxResult.success("操作成功");
        }else{
            return close;
        }
    }

    @Override
    public int customsOrder(TmsDispatchOrder tmsDispatchOrder) {
@@ -676,14 +725,25 @@
                    String receiverRegionCode = tmsDispatchOrder.getEndRegionCode();

                    // 查询应收规则
                    TmsQuoteDetail tmsQuoteDetail = tmsQuoteDetailMapper.selectOne(new LambdaQueryWrapper<TmsQuoteDetail>()
                            .eq(TmsQuoteDetail::getVehicleProviderId, vehicleProviderId)
                            .eq(TmsQuoteDetail::getVehicleType, actualVehicleType)
                            .eq(TmsQuoteDetail::getStartRegionCode, shipperRegionCode)
                            .eq(TmsQuoteDetail::getEndRegionCode, receiverRegionCode)
                            .eq(TmsQuoteDetail::getPlanType, 1)
                            .last("limit 1")
                    );
                    TmsQuoteDetail tmsQuoteDetail =
                            tmsQuoteDetailMapper.selectOne(
                                    new LambdaQueryWrapper<TmsQuoteDetail>()
                                            .eq(TmsQuoteDetail::getVehicleType, actualVehicleType)
                                            .eq(TmsQuoteDetail::getStartRegionCode, shipperRegionCode)
                                            .eq(TmsQuoteDetail::getEndRegionCode, receiverRegionCode)
                                            .eq(TmsQuoteDetail::getPlanType, 1)
                                            .exists(
                                                    "SELECT 1 " +
                                                            "FROM tms_quote_plan tqp " +
                                                            "WHERE tqp.id = tms_quote_detail.quote_plan_id " +
                                                            "AND tqp.provider_id = {0} " +
                                                            "AND tqp.plan_type = 1 " +
                                                            "AND tqp.provider_type = 0",
                                                    vehicleProviderId
                                            )
                                            .last("LIMIT 1")
                            );




@@ -1041,4 +1101,14 @@
        }
        return AjaxResult.success();
    }

    @Override
    public List<DpDriverDispatchVo> selectDpData() {
        return tmsDispatchOrderMapper.selectselectDpData();
    }

    @Override
    public DpDriverDispatchItemVo selectDataByNo(String no) {
        return tmsDispatchOrderMapper.selectDataByNo(no);
    }
}