From 3974fad5d836431e417e99220cc07bb5b0aba331 Mon Sep 17 00:00:00 2001
From: zhangback <zhangback@163.com>
Date: 星期一, 08 十二月 2025 14:16:16 +0800
Subject: [PATCH] 提交
---
tms/src/main/java/com/ruoyi/tms/service/impl/TmsTripServiceImpl.java | 206 ++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 194 insertions(+), 12 deletions(-)
diff --git a/tms/src/main/java/com/ruoyi/tms/service/impl/TmsTripServiceImpl.java b/tms/src/main/java/com/ruoyi/tms/service/impl/TmsTripServiceImpl.java
index 04eba79..aaef49c 100644
--- a/tms/src/main/java/com/ruoyi/tms/service/impl/TmsTripServiceImpl.java
+++ b/tms/src/main/java/com/ruoyi/tms/service/impl/TmsTripServiceImpl.java
@@ -1,26 +1,38 @@
package com.ruoyi.tms.service.impl;
-import java.util.List;
+import java.io.File;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.util.*;
-import com.ruoyi.common.utils.DateUtils;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.ruoyi.common.config.RuoYiConfig;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.utils.*;
+
import javax.annotation.Resource;
-import com.ruoyi.common.utils.SecurityUtils;
-import com.ruoyi.tms.domain.TmsDispatchOrder;
-import com.ruoyi.tms.mapper.TmsDispatchOrderMapper;
+import com.ruoyi.common.utils.file.FileUploadUtils;
+import com.ruoyi.common.utils.uuid.Seq;
+import com.ruoyi.system.service.ISysUserService;
+import com.ruoyi.tms.domain.*;
+import com.ruoyi.tms.mapper.*;
+import org.apache.commons.io.FileUtils;
+import org.apache.commons.io.FilenameUtils;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.stereotype.Service;
import org.springframework.scheduling.annotation.Async;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import com.ruoyi.common.utils.PageUtils;
import com.ruoyi.common.constant.Constants;
import com.ruoyi.common.annotation.DataSource;
import com.ruoyi.common.enums.DataSourceType;
import com.ruoyi.common.core.service.BaseService;
-import com.ruoyi.tms.mapper.TmsTripMapper;
-import com.ruoyi.tms.domain.TmsTrip;
import com.ruoyi.tms.service.ITmsTripService;
import com.ruoyi.common.core.text.Convert;
@@ -40,7 +52,23 @@
@Resource
private TmsDispatchOrderMapper tmsDispatchOrderMapper;
+ @Autowired
+ private ISysUserService userService;
+ @Resource
+ private TmsDriverDispatchMapper tmsDriverDispatchMapper;
+
+ @Resource
+ private TmsDriverMapper tmsDriverMapper;
+ @Autowired
+ private TmsVehicleServiceImpl tmsVehicleServiceImpl;
+ @Resource
+ private TmsCarKeyDispatchMapper tmsCarKeyDispatchMapper;
+ @Autowired
+ private RabbitTemplate rabbitTemplate;
+
+ @Autowired
+ private AsyncPdfService asyncPdfService;
/**
* 鏌ヨ琛岀▼
*
@@ -80,6 +108,19 @@
return tmsTripMapper.selectTmsTripList(tmsTrip);
}
+ @Override
+ public List<TmsTrip> tmsTripList(Integer dispatchId) {
+ Integer deviceId = userService.getDeviceId(SecurityUtils.getUserId());
+ if (deviceId == null){
+ return null;
+ }
+ return tmsTripMapper.selectList(new LambdaQueryWrapper<TmsTrip>()
+ .eq(TmsTrip::getDispatchOrderId,dispatchId)
+ .eq(TmsTrip::getDriverId,deviceId)
+ .orderByDesc(TmsTrip::getId)
+ );
+ }
+
/**
* 鏌ヨ琛岀▼鍒楄〃 寮傛 瀵煎嚭
*
@@ -106,8 +147,7 @@
* @return 缁撴灉
*/
@Override
- public int insertTmsTrip(TmsTrip tmsTrip)
- {
+ public int insertTmsTrip(TmsTrip tmsTrip) throws Exception {
Integer dispatchOrderId = tmsTrip.getDispatchOrderId();
TmsDispatchOrder tmsDispatchOrder = tmsDispatchOrderMapper.selectTmsDispatchOrderById(dispatchOrderId);
if (tmsDispatchOrder == null){
@@ -116,15 +156,157 @@
if (tmsDispatchOrder.getStatus() != 1 && tmsDispatchOrder.getStatus() != 2){
throw new RuntimeException("璋冨害鍗曟暟鎹姸鎬佸紓甯�");
}
+ TmsDriver tmsDriver = tmsDriverMapper.selectTmsDriverById(tmsDispatchOrder.getMainDriverId());
+ if (tmsDriver == null){
+ throw new RuntimeException("鏈壘鍒板徃鏈烘暟鎹�");
+ }
+
+
tmsDispatchOrder.setStatus(2);
tmsDispatchOrderMapper.updateTmsDispatchOrder(tmsDispatchOrder);
-
+ tmsTrip.setDriverName(tmsDispatchOrder.getMainDriverName());
+ tmsTrip.setVehicleId(tmsDispatchOrder.getVehicleId());
+ tmsTrip.setVehicleNumber(tmsDispatchOrder.getLicensePlate());
tmsTrip.setCreateBy(SecurityUtils.getUsername());
tmsTrip.setCreateTime(DateUtils.getNowDate());
- return tmsTripMapper.insertTmsTrip(tmsTrip);
+ tmsTripMapper.insertTmsTrip(tmsTrip);
+ if (StringUtils.isNotEmpty(tmsTrip.getSignImg())){
+ asyncPdfService.generateTripPdfAsync(tmsTrip,tmsDispatchOrder,tmsDriver);
+ }
+ // 瀹屾垚韬綋妫�鏌�
+ if (tmsTrip.getTripType() == 1){
+ // 娣诲姞 棰嗛挜鍖� 鎸囦护璁板綍
+ TmsVehicle tmsVehicle = tmsVehicleServiceImpl.selectTmsVehicleById(tmsDispatchOrder.getVehicleId());
+
+ TmsCarKeyDispatch tmsCarKeyDispatch = new TmsCarKeyDispatch();
+ tmsCarKeyDispatch.setDispatchOrderId(dispatchOrderId);
+ tmsCarKeyDispatch.setDispatchOrderNo(tmsDispatchOrder.getDispatchNo());
+ tmsCarKeyDispatch.setDriverId(tmsDriver.getId());
+ tmsCarKeyDispatch.setDriverMobile(tmsDriver.getMobile());
+ tmsCarKeyDispatch.setDriverName(tmsDriver.getDriverName());
+
+ tmsCarKeyDispatch.setVehicleId(tmsDispatchOrder.getVehicleId());
+ tmsCarKeyDispatch.setVehicleLicensePlate(tmsDispatchOrder.getLicensePlate());
+ tmsCarKeyDispatch.setVehicleCarKeyNo(tmsVehicle.getCarKeyNo());
+
+ LocalDateTime plus2Hours = LocalDateTime.now().plusHours(2);
+ Date date = Date.from(plus2Hours.atZone(ZoneId.systemDefault()).toInstant());
+
+ tmsCarKeyDispatch.setCarKeyExpirationTime(date);
+ tmsCarKeyDispatch.setStatus(0);
+ tmsCarKeyDispatchMapper.insertTmsCarKeyDispatch(tmsCarKeyDispatch);
+
+ sendCarKeyDelayMessage(tmsCarKeyDispatch.getId(), 2 * 60 * 60 * 1000L);
+
+ }
+
+
+ return 1;
}
/**
+ * 鍙戦�佸欢杩熸秷鎭�
+ * @param carKeyId car_key id
+ * @param delayMillis 寤惰繜姣鏁�
+ */
+ public void sendCarKeyDelayMessage(Integer carKeyId, long delayMillis) {
+ rabbitTemplate.convertAndSend(
+ "car_key_delay_exchange",
+ "car_key_delay",
+ carKeyId,
+ message -> {
+ message.getMessageProperties().setExpiration(String.valueOf(delayMillis));
+ return message;
+ }
+ );
+ }
+
+
+ @Override
+ public AjaxResult submitDropHook(TmsTrip tmsTrip){
+ Integer dispatchOrderId = tmsTrip.getDispatchOrderId();
+ TmsDispatchOrder tmsDispatchOrder = tmsDispatchOrderMapper.selectTmsDispatchOrderById(dispatchOrderId);
+ if (tmsDispatchOrder == null){
+ throw new RuntimeException("鏈壘鍒拌皟搴﹀崟鏁版嵁");
+ }
+ if (tmsDispatchOrder.getStatus() != 6){
+ throw new RuntimeException("璋冨害鍗曟暟鎹姸鎬佸紓甯�");
+ }
+ tmsDispatchOrderMapper.update(
+ new LambdaUpdateWrapper<TmsDispatchOrder>()
+ .eq(TmsDispatchOrder::getId, dispatchOrderId)
+ .set(TmsDispatchOrder::getStatus, 7)
+ .set(TmsDispatchOrder::getMainDriverId, null)
+ .set(TmsDispatchOrder::getMainDriverName, null)
+ .set(TmsDispatchOrder::getVehicleId, null)
+ .set(TmsDispatchOrder::getLicensePlate, null)
+ );
+
+ tmsDriverDispatchMapper.update(
+ new LambdaUpdateWrapper<TmsDriverDispatch>()
+ .eq(TmsDriverDispatch::getDispatchId, dispatchOrderId)
+ .eq(TmsDriverDispatch::getDriverId, tmsDispatchOrder.getMainDriverId())
+ .set(TmsDriverDispatch::getStatus, 3)
+ );
+ tmsTrip.setDriverName(tmsDispatchOrder.getMainDriverName());
+ tmsTrip.setVehicleId(tmsDispatchOrder.getVehicleId());
+ tmsTrip.setVehicleNumber(tmsDispatchOrder.getLicensePlate());
+ tmsTrip.setCreateBy(SecurityUtils.getUsername());
+ tmsTrip.setCreateTime(DateUtils.getNowDate());
+ tmsTripMapper.insertTmsTrip(tmsTrip);
+ return AjaxResult.success();
+ }
+ @Override
+ public AjaxResult submitPickHook(TmsTrip tmsTrip){
+ Integer dispatchOrderId = tmsTrip.getDispatchOrderId();
+ TmsDispatchOrder tmsDispatchOrder = tmsDispatchOrderMapper.selectTmsDispatchOrderById(dispatchOrderId);
+ if (tmsDispatchOrder == null){
+ throw new RuntimeException("鏈壘鍒拌皟搴﹀崟鏁版嵁");
+ }
+ if (tmsDispatchOrder.getStatus() != 7){
+ throw new RuntimeException("璋冨害鍗曟暟鎹姸鎬佸紓甯�");
+ }
+ Integer driverId = tmsTrip.getDriverId();
+ TmsDriver tmsDriver = tmsDriverMapper.selectTmsDriverById(driverId);
+ TmsDriverDispatch driverDispatch = tmsDriverDispatchMapper.selectOne(new LambdaUpdateWrapper<TmsDriverDispatch>()
+ .eq(TmsDriverDispatch::getDispatchId, dispatchOrderId)
+ .eq(TmsDriverDispatch::getDriverId, driverId)
+ .eq(TmsDriverDispatch::getStatus, 2)
+ );
+ if (driverDispatch == null){
+ throw new RuntimeException("鏈壘鍒板叧鑱旀暟鎹�");
+ }
+
+
+ TmsVehicle tmsVehicle = tmsVehicleServiceImpl.selectTmsVehicleById(driverDispatch.getVehicleId());
+
+ tmsDispatchOrderMapper.update(
+ new LambdaUpdateWrapper<TmsDispatchOrder>()
+ .eq(TmsDispatchOrder::getId, dispatchOrderId)
+ .set(TmsDispatchOrder::getStatus, 2)
+ .set(TmsDispatchOrder::getMainDriverId, tmsDriver.getId())
+ .set(TmsDispatchOrder::getMainDriverName, tmsDriver.getDriverName())
+ .set(TmsDispatchOrder::getVehicleId, tmsVehicle.getId())
+ .set(TmsDispatchOrder::getLicensePlate, tmsVehicle.getLicensePlate())
+ );
+ tmsDriverDispatchMapper.update(
+ new LambdaUpdateWrapper<TmsDriverDispatch>()
+ .eq(TmsDriverDispatch::getDispatchId, dispatchOrderId)
+ .eq(TmsDriverDispatch::getDriverId, tmsTrip.getDriverId())
+ .set(TmsDriverDispatch::getStatus, 4)
+ );
+
+ tmsTrip.setVehicleId(tmsDispatchOrder.getVehicleId());
+ tmsTrip.setVehicleNumber(tmsDispatchOrder.getLicensePlate());
+ tmsTrip.setDriverName(tmsDriver.getDriverName());
+ tmsTrip.setCreateBy(SecurityUtils.getUsername());
+ tmsTrip.setCreateTime(DateUtils.getNowDate());
+ tmsTripMapper.insertTmsTrip(tmsTrip);
+ return AjaxResult.success();
+ }
+
+
+ /**
* 鏂板琛岀▼[鎵归噺]
*
* @param tmsTrips 琛岀▼
--
Gitblit v1.8.0