运单预警

performance-web/src/main/java/com/clx/performance/dto/vehiclewarn/VehicleWarnCommonInfoDTO.java

+package com.clx.performance.dto.vehiclewarn;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+@Getter
+@Setter
+@NoArgsConstructor
+public class VehicleWarnCommonInfoDTO {
+
+    BigDecimal[] currentPosition;   //当前位置
+
+    Integer sendAddressDistance;    //距货源地址距离
+    Integer receiveAddressDistance; //距目的地址距离
+
+    Integer sendAddressTime;        //距货源地址时间
+    Integer receiveAddressTime;     //距目的地址时间
+
+    Boolean suspendStatus;          //是否暂停 0:未暂停 1:暂停
+
+    private LocalDateTime lastArriveSendTime;       //最晚到达货源地时间
+    private LocalDateTime lastArriveReceiveTime;    //最晚到达目的地时间
+
+    LocalDateTime currentTime;      //当前时间
+
+}

performance-web/src/main/java/com/clx/performance/service/impl/trace/TruckTraceServiceImpl.java

@@ -27,6 +27,7 @@ import java.util.List;
 @Slf4j
 @Service
 public class TruckTraceServiceImpl implements TruckTraceService {
+    // 停留速度
     private static final Integer PARK_SPEED = 5;
 
     @Autowired
@@ -134,10 +135,11 @@ public class TruckTraceServiceImpl implements TruckTraceService {
     }
 
     @Override
-    public BigDecimal[] getLastPosition(String truckNo, Long userNo) {
+    public BigDecimal[] getCurrentPosition(String truckNo, Long userNo) {
         String beginTime = LocalDateTimeUtils.formatTime(LocalDateTime.now().minusHours(1));
         String endTime = LocalDateTimeUtils.formatTime();
 
+        // 车辆
         List<TruckTraceESPlus> list = truckTraceESPlusMapper.selectList(new LambdaEsQueryWrapper<TruckTraceESPlus>()
                 .eq(TruckTraceESPlus::getTruckNo, truckNo)
                 .ge(TruckTraceESPlus::getGpsTime, beginTime)
@@ -149,6 +151,7 @@ public class TruckTraceServiceImpl implements TruckTraceService {
             return list.get(0).getLocation();
         }
 
+        // 司机
         List<DriverTraceESPlus> list1 = driverTraceESPlusMapper.selectList(new LambdaEsQueryWrapper<DriverTraceESPlus>()
                 .eq(DriverTraceESPlus::getUserNo, userNo)
                 .ge(DriverTraceESPlus::getPositionTime, beginTime)
@@ -168,6 +171,7 @@ public class TruckTraceServiceImpl implements TruckTraceService {
         String beginTime = LocalDateTimeUtils.formatTime(LocalDateTime.now().minusDays(1));
         String endTime = LocalDateTimeUtils.formatTime();
 
+        // 车辆
         List<TruckTraceESPlus> list = truckTraceESPlusMapper.selectList(new LambdaEsQueryWrapper<TruckTraceESPlus>()
                 .eq(TruckTraceESPlus::getTruckNo, truckNo)
                 .gt(TruckTraceESPlus::getSpeed, PARK_SPEED)
@@ -188,6 +192,7 @@ public class TruckTraceServiceImpl implements TruckTraceService {
 
         }
 
+        // 司机
         List<DriverTraceESPlus> list1 = driverTraceESPlusMapper.selectList(new LambdaEsQueryWrapper<DriverTraceESPlus>()
                 .eq(DriverTraceESPlus::getUserNo, userNo)
                 .ge(DriverTraceESPlus::getPositionTime, beginTime)

performance-web/src/main/java/com/clx/performance/service/impl/vehiclewarn/VehicleWarnCommonServiceImpl.java

 package com.clx.performance.service.impl.vehiclewarn;
 
+import com.clx.performance.dao.vehiclewarn.VehicleWarnInfoDao;
+import com.clx.performance.dao.vehiclewarn.VehicleWarnRangeDao;
+import com.clx.performance.dto.gd.GdRouteDTO;
+import com.clx.performance.enums.vehiclewarn.VehicleWarnInfoEnum;
+import com.clx.performance.enums.vehiclewarn.VehicleWarnRangEnum;
+import com.clx.performance.model.OrderChild;
+import com.clx.performance.model.vehiclewarn.VehicleWarnChild;
+import com.clx.performance.model.vehiclewarn.VehicleWarnConfig;
+import com.clx.performance.model.vehiclewarn.VehicleWarnInfo;
+import com.clx.performance.model.vehiclewarn.VehicleWarnRang;
+import com.clx.performance.service.trace.TruckTraceService;
 import com.clx.performance.service.vehiclewarn.VehicleWarnCommonService;
+import com.clx.performance.service.vehiclewarn.VehicleWarnMqService;
+import com.clx.performance.utils.gd.GdService;
+import com.msl.common.exception.ServiceSystemException;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Objects;
+
 @Slf4j
 @Service
 public class VehicleWarnCommonServiceImpl implements VehicleWarnCommonService {
+    private static final Integer MIN_FER_HOUR = 60;
+    private static final Integer SEC_FER_MIN = 60;
+
+    @Autowired
+    private TruckTraceService truckTraceService;
+    @Autowired
+    private GdService gdService;
+    @Autowired
+    private VehicleWarnRangeDao vehicleWarnRangeDao;
+    @Autowired
+    private VehicleWarnInfoDao vehicleWarnInfoDao;
+    @Autowired
+    private VehicleWarnMqService vehicleWarnMqService;
+
+
+    @Override
+    public void vehicleWarnInfoUpdate(OrderChild orderChild, VehicleWarnInfo vehicleWarnInfo, VehicleWarnConfig vehicleWarnConfig){
+
+        // 更新
+        if (vehicleWarnInfo != null && Objects.equals(vehicleWarnInfo.getStatus(), VehicleWarnInfoEnum.Status.INIT.getCode())){
+
+            // 计算下次生效时间
+            LocalDateTime nextTime = vehicleWarnInfo.getWarnTime().plusMinutes(vehicleWarnConfig.getInterval().multiply(new BigDecimal(MIN_FER_HOUR)).intValue());
+            if (nextTime.isAfter(LocalDateTime.now())) {return;}
+
+            vehicleWarnInfo.setWarnTime(LocalDateTime.now());
+            vehicleWarnInfoDao.updateWarn(vehicleWarnInfo);
+            return;
+        }
+
+        // 新增
+        vehicleWarnInfo = new VehicleWarnInfo();
+        vehicleWarnInfo.setWarnConfigId(vehicleWarnConfig.getId());
+        vehicleWarnInfo.setWarnType(vehicleWarnConfig.getWarnType());
+        vehicleWarnInfo.setWarnName(vehicleWarnConfig.getWarnName());
+        vehicleWarnInfo.setWarnName(vehicleWarnConfig.getWarnName());
+        vehicleWarnInfo.setWarnLevel(vehicleWarnConfig.getWarnLevel());
+
+        vehicleWarnInfo.setChildNo(orderChild.getChildNo());
+        vehicleWarnInfo.setSendAddressId(orderChild.getSendAddressId());
+        vehicleWarnInfo.setSendAddress(orderChild.getSendAddress());
+        vehicleWarnInfo.setReceiveAddressId(orderChild.getReceiveAddressId());
+        vehicleWarnInfo.setReceiveAddress(orderChild.getReceiveAddress());
+
+        vehicleWarnInfo.setTruckId(orderChild.getTruckId());
+        vehicleWarnInfo.setTruckNo(orderChild.getTruckNo());
+        vehicleWarnInfo.setDriverUserNo(orderChild.getDriverUserNo());
+        vehicleWarnInfo.setDriverName(orderChild.getDriverName());
+        vehicleWarnInfo.setDriverMobile(orderChild.getDriverMobile());
+
+        vehicleWarnInfo.setTakeTime(orderChild.getPayTime());
+        vehicleWarnInfo.setWarnTime(LocalDateTime.now());
+
+        vehicleWarnInfoDao.saveEntity(vehicleWarnInfo);
+        // 发送mq （预警通知）
+        vehicleWarnMqService.truckWarnNotice(vehicleWarnInfo.getId());
+    }
+
+    /**
+     * 暂停检测
+     */
+    @Override
+    public boolean suspendCheck(VehicleWarnChild vehicleWarnChild, Integer warnConfigId){
+        // 报警暂停
+        List<VehicleWarnRang> vehicleWarnRangList = vehicleWarnRangeDao.ListByWarnConfigId(warnConfigId);
+        if (!vehicleWarnRangList.isEmpty()){
+            for (VehicleWarnRang item : vehicleWarnRangList) {
+                if (Objects.equals(item.getWarnRang(), VehicleWarnRangEnum.WarnRange.ALL.getCode())){
+                    return true;
+                }
+                if (Objects.equals(item.getWarnRang(), VehicleWarnRangEnum.WarnRange.ORDER.getCode())){
+                    if (Objects.equals(vehicleWarnChild.getOrderNo(), item.getOrderNo())) {
+                        return true;
+                    }
+                }
+                if (Objects.equals(item.getWarnRang(), VehicleWarnRangEnum.WarnRange.CHILD.getCode())){
+                    if (Objects.equals(vehicleWarnChild.getChildNo(), item.getChildNo())) {
+                        return true;
+                    }
+                }
+            }
+        }
+
+        return false;
+    }
+
+    /**
+     * 获取当前位置
+     */
+    @Override
+    public BigDecimal[] getCurrentPosition(String truckNo, Long userNo){
+        BigDecimal[] currentPosition = truckTraceService.getCurrentPosition(truckNo, userNo);
+        return currentPosition;
+    }
+
+    /**
+     * 获取需要时间（min）
+     */
+    @Override
+    public int getNeedTime(BigDecimal originLongitude, BigDecimal originLatitude,
+                           BigDecimal destinationLongitude, BigDecimal destinationLatitude){
+        try {
+            List<GdRouteDTO> gdRouteDTOS = gdService.getRoute(originLongitude, originLatitude, destinationLongitude, destinationLatitude);
+
+            if (!gdRouteDTOS.isEmpty()){
+                return gdRouteDTOS.get(0).getDuration() /SEC_FER_MIN;
+            }
+
+        } catch (ServiceSystemException e) {
+            log.info("获取高德线路失败, msg:{}", e.getMessage());
+        }
 
+        return 0;
+    }
 
+    /**
+     * 获取需要时间（min）
+     */
+    @Override
+    public int getNeedTime(BigDecimal[] currentPosition, BigDecimal destinationLongitude, BigDecimal destinationLatitude) {
+        if (currentPosition == null) {return 0;}
+        return getNeedTime(currentPosition[0], currentPosition[1], destinationLongitude, destinationLatitude);
+    }
 }

performance-web/src/main/java/com/clx/performance/service/trace/TruckTraceService.java

@@ -17,7 +17,7 @@ public interface TruckTraceService {
 
     void driverTraceSave(DriverTraceAddParam param);
 
-    BigDecimal[] getLastPosition(String truckNo, Long userNo);
+    BigDecimal[] getCurrentPosition(String truckNo, Long userNo);
 
     int getParkTime(String truckNo, Long userNo);
 }

performance-web/src/main/java/com/clx/performance/service/vehiclewarn/VehicleWarnCommonService.java

 package com.clx.performance.service.vehiclewarn;
 
+import com.clx.performance.model.OrderChild;
+import com.clx.performance.model.vehiclewarn.VehicleWarnChild;
+import com.clx.performance.model.vehiclewarn.VehicleWarnConfig;
+import com.clx.performance.model.vehiclewarn.VehicleWarnInfo;
+
+import java.math.BigDecimal;
+
 public interface VehicleWarnCommonService {
+    void vehicleWarnInfoUpdate(OrderChild orderChild, VehicleWarnInfo vehicleWarnInfo, VehicleWarnConfig vehicleWarnConfig);
+
+    boolean suspendCheck(VehicleWarnChild vehicleWarnChild, Integer warnConfigId);
+
+    BigDecimal[] getCurrentPosition(String truckNo, Long userNo);
+
+    int getNeedTime(BigDecimal originLongitude, BigDecimal originLatitude,
+                    BigDecimal destinationLongitude, BigDecimal destinationLatitude);
+    int getNeedTime(BigDecimal[] currentPosition,
+                    BigDecimal destinationLongitude, BigDecimal destinationLatitude);
 }

performance-web/src/main/java/com/clx/performance/service/vehiclewarn/VehicleWarnSendAddressWarnService.java

 package com.clx.performance.service.vehiclewarn;
 
+import com.clx.performance.dto.vehiclewarn.VehicleWarnCommonInfoDTO;
 import com.clx.performance.model.OrderChild;
 import com.clx.performance.model.vehiclewarn.VehicleWarnChild;
 
 public interface VehicleWarnSendAddressWarnService {
 
-    void gotoSendAddressTimeout(OrderChild orderChild, VehicleWarnChild vehicleWarnChild);
+    void gotoSendAddressTimeout(OrderChild orderChild, VehicleWarnChild vehicleWarnChild, VehicleWarnCommonInfoDTO commonInfo);
+
+    void arriveSendAddressTimeout(OrderChild orderChild, VehicleWarnChild vehicleWarnChild, VehicleWarnCommonInfoDTO commonInfo);
 
-    void arriveSendAddressTimeout(OrderChild orderChild, VehicleWarnChild vehicleWarnChild);
 }