修改bug

Pu Zhibing

2025-03-28 8b09fbc19a96b57bf1d0e4d7c79b51a76aeca554

 DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/quartz/jobs/OrderTimeOutJob.java

@@ -1,20 +1,32 @@
package com.stylefeng.guns.modular.system.util.quartz.jobs;

import com.alibaba.fastjson.JSON;
import com.stylefeng.guns.core.util.ToolUtil;
import com.stylefeng.guns.modular.smallLogistics.model.OrderLogistics;
import com.stylefeng.guns.modular.smallLogistics.server.IOrderLogisticsService;
import com.stylefeng.guns.modular.specialTrain.model.OrderPrivateCar;
import com.stylefeng.guns.modular.specialTrain.server.IOrderPrivateCarService;
import com.stylefeng.guns.modular.system.dao.UserInfoMapper;
import com.stylefeng.guns.modular.system.model.Driver;
import com.stylefeng.guns.modular.system.model.UserInfo;
import com.stylefeng.guns.modular.system.service.IDriverService;
import com.stylefeng.guns.modular.system.util.PushUtil;
import com.stylefeng.guns.modular.system.util.TextToSpeechUtil;
import com.stylefeng.guns.modular.system.util.quartz.QuartzUtil;
import com.stylefeng.guns.modular.system.util.quartz.model.QuartzJob;
import lombok.extern.slf4j.Slf4j;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobKey;
import org.quartz.*;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.List;
import java.util.Timer;
import java.util.TimerTask;


/**
 * 订单司机超时提醒任务
@@ -23,7 +35,7 @@
 */
@Slf4j
@Component
public class OrderTimeOutJob extends QuartzJob {
public class OrderTimeOutJob implements Job {
   
   @Resource
   private PushUtil pushUtil;
@@ -31,104 +43,169 @@
   private IOrderPrivateCarService orderPrivateCarService;
   @Resource
   private IOrderLogisticsService orderLogisticsService;
   @Resource
   private IDriverService driverService;
   @Resource
   private UserInfoMapper userInfoMapper;
   
	
	
   @Override
   public QuartzJob buildQuartzJob() {
      return super.buildQuartzJob();
   }
	
   @Override
   public QuartzJob buildQuartzJob(String name) {
      return super.buildQuartzJob(name);
   }
	
   @Override
   public QuartzJob buildQuartzJob(String name, String group) {
      return super.buildQuartzJob(name, group);
   }
	
   @Override
   public QuartzJob buildQuartzJob(String name, String group, JobDataMap jobDataMap) {
      return super.buildQuartzJob(name, group, jobDataMap);
   }
   @Resource
   private QuartzUtil quartzUtil;

   
   /**
    * 执行的业务逻辑
    * @param jobExecutionContext 定时任务上下文对象
    */
   @Override
   public void run(JobExecutionContext jobExecutionContext) {
      JobDataMap jobDataMap = jobExecutionContext.getJobDetail().getJobDataMap();
      Integer driverId = jobDataMap.getIntegerFromString("driverId");
      Integer orderId = jobDataMap.getIntegerFromString("orderId");
      Integer orderType = jobDataMap.getIntegerFromString("orderType");
      JobDetail jobDetail = jobExecutionContext.getJobDetail();
      JobDataMap jobDataMap = jobDetail.getJobDataMap();
      String name = jobDetail.getKey().getName();
      log.info("执行{}定时任务逻辑 JobDataMap：{}", name, JSON.toJSONString(jobDataMap));
      Integer timeOutType = jobDataMap.getIntValue("timeOutType");
      Integer driverId = jobDataMap.getIntValue("driverId");
      Integer orderId = jobDataMap.getIntValue("orderId");
      Integer orderType = jobDataMap.getIntValue("orderType");
      Integer driverTimeout = jobDataMap.getIntValue("driverTimeout");
      long timeOut = jobDataMap.getLongValue("timeOut");
      String describe = jobDataMap.getString("describe");
      Driver driver = driverService.selectById(driverId);
      Integer language = driver.getLanguage();
      if(1 == timeOutType){
         if(orderType == 1){
            describe = language == 1 ? "您已超时" + driverTimeout + "分钟，\n用户可免费取消订单" : language == 2 ? "You are overdue for " + driverTimeout + " minutes,\nThe subscriber could cancel the order for free" : "Vous êtes en retard de " + driverTimeout + " minutes,\nL'abonné peut annuler la commande gratuitement";
         }
         if(orderType == 4){
            describe = language == 1 ? "您已超时" + driverTimeout + "分钟，\n用户可免费取消订单" : language == 2 ? "You are overdue for " + driverTimeout + " minutes,\nThe subscriber could cancel the order for free" : "Vous êtes en retard de " + driverTimeout + " minutes,\nL'abonné peut annuler la commande gratuitement";
         }
      }
      if(2 == timeOutType){
         if(orderType == 1){
            OrderPrivateCar orderPrivateCar = orderPrivateCarService.selectById(orderId);
            UserInfo userInfo = userInfoMapper.selectById(orderPrivateCar.getUserId());
            SimpleDateFormat sdf = new SimpleDateFormat("HH:mm");
            describe = language == 1 ? "您将于" + sdf.format(orderPrivateCar.getTravelTime()) + "去接" + (ToolUtil.isEmpty(userInfo.getFirstName()) ? userInfo.getNickName() : userInfo.getFirstName() + " " + userInfo.getLastName())  + "，请准时！" :
                  language == 2 ? "You are going to pick up " + (ToolUtil.isEmpty(userInfo.getFirstName()) ? userInfo.getNickName() : userInfo.getFirstName() + " " + userInfo.getLastName()) + " at " + sdf.format(orderPrivateCar.getTravelTime()) + ", please be on time. " :
                        "Vous allez chercher " + (ToolUtil.isEmpty(userInfo.getFirstName()) ? userInfo.getNickName() : userInfo.getFirstName() + " " + userInfo.getLastName()) + " à " + sdf.format(orderPrivateCar.getTravelTime()) + ", s’il vous plaît soyez à l’heure.";
         }
         if(orderType == 4){
         }
      }
      if(3 == timeOutType){
         Integer m = Double.valueOf((System.currentTimeMillis() - timeOut) / 60000).intValue();
         if(orderType == 1){
            if(0 == m){
               describe = language == 1 ? "您的打车订单已超时，请抓紧！" : language == 2 ? "Your ride order is overdue, please go faster." : "Votre commande de course est en retard, veuillez aller plus vite.";
            }else{
               describe = language == 1 ? "您的打车订单已超时" + m + "分钟，请抓紧！" : language == 2 ? "Your ride order is overdue for " + m + " minute(s), please go faster." : "Votre commande de course est en retard depuis " + m + " minute(s), veuillez aller plus vite.";
            }
         }
         if(orderType == 4){
            if(0 == m){
               describe = language == 1 ? "您的包裹订单已超时，请抓紧！" : language == 2 ? "Your delivery order is overdue, please go faster." : "Votre commande de Delivery est en retard, veuillez aller plus vite.";
            }else{
               describe = language == 1 ? "您的包裹订单已超时" + m + "分钟，请抓紧！" : language == 2 ? "Your delivery order is overdue for " + m + " minute(s), please go faster." : "Votre commande de livraison est en retard depuis " + m + " minute(s), veuillez aller plus vite.";
            }
         }
      }
		
		
      if(1 == orderType){
         //结束预约单出发循环提醒定时
         OrderPrivateCar orderPrivateCar = orderPrivateCarService.selectById(orderId);
         if(2 != orderPrivateCar.getState()){
         List<Integer> list = Arrays.asList(4, 5, 6, 7, 8, 9, 10, 11, 12);
         if(1 == timeOutType && list.contains(orderPrivateCar.getState())){
            JobKey key = jobExecutionContext.getJobDetail().getKey();
            boolean b = QuartzUtil.deleteQuartzTask(key);
            boolean b = quartzUtil.deleteQuartzTask(key);
            if(!b){
               log.error("定时任务关闭失败：" + key.toString());
            }
            return;
         }
         if(2 == timeOutType && (System.currentTimeMillis() >= timeOut || list.contains(orderPrivateCar.getState()))){
            JobKey key = jobExecutionContext.getJobDetail().getKey();
            boolean b = quartzUtil.deleteQuartzTask(key);
            if(!b){
               log.error("定时任务关闭失败：" + key.toString());
            }
            return;
         }
			
         //结束超时循环提醒定时
         if(3 == timeOutType && list.contains(orderPrivateCar.getState())){
            JobKey key = jobExecutionContext.getJobDetail().getKey();
            boolean b = quartzUtil.deleteQuartzTask(key);
            if(!b){
               log.error("定时任务关闭失败：" + key.toString());
            }
            return;
         }
			
			
      }
      if(4 == orderType){
         OrderLogistics orderLogistics = orderLogisticsService.selectById(orderId);
         if(2 != orderLogistics.getState()){
         List<Integer> list = Arrays.asList(4, 5, 6, 7, 8, 9, 10, 11, 12, 13);
         if(1 == timeOutType && list.contains(orderLogistics.getState())){
            JobKey key = jobExecutionContext.getJobDetail().getKey();
            boolean b = QuartzUtil.deleteQuartzTask(key);
            boolean b = quartzUtil.deleteQuartzTask(key);
            if(!b){
               log.error("定时任务关闭失败：" + key.toString());
            }
            return;
         }
         //结束超时循环提醒定时
         if(3 == timeOutType && list.contains(orderLogistics.getState())){
            JobKey key = jobExecutionContext.getJobDetail().getKey();
            boolean b = quartzUtil.deleteQuartzTask(key);
            if(!b){
               log.error("定时任务关闭失败：" + key.toString());
            }
            return;
         }
      }
      pushUtil.pushOrderTimeOut(2, driverId, orderId, orderType, describe);
		
      String fileName = "orderTimeOut" + driverId + "_" + timeOutType + ".mp3";
      String audioUrl = null;
      try {
         audioUrl = TextToSpeechUtil.create(language == 1 ? "cmn-CN" : language == 2 ? "en-US" : "fr-FR", describe, fileName);
      } catch (Exception e) {
         e.printStackTrace();
      }
		
      //定时任务删除语音文件
      new Timer().schedule(new TimerTask() {
         @Override
         public void run() {
            try {
               // 使用Runtime执行命令
               Process process = Runtime.getRuntime().exec("sudo rm -rf /home/igotechgh/nginx/html/files/audio/" + fileName);
               // 读取命令的输出
               BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
               String line;
               while ((line = reader.readLine()) != null) {
                  System.out.println(line);
               }
               // 等待命令执行完成
               process.waitFor();
               // 关闭流
               reader.close();
            } catch (IOException | InterruptedException e) {
               e.printStackTrace();
            }
         }
      }, 30000);
		
      log.info("开始推送提醒-{}：orderId={};orderType={};timeOutType={};describe={};audioUrl={}", System.currentTimeMillis(), orderId, orderType, timeOutType, describe, audioUrl);
      pushUtil.pushOrderTimeOut(2, driverId, timeOutType, orderId, orderType, describe, audioUrl);
   }
   
   
   /**
    * 初始化任务对象
    * @return
    */
   public static QuartzJob init(){
      return new OrderTimeOutJob().buildQuartzJob();
   }
	
   /**
    * 初始化任务对象
    * @param name
    * @return
    */
   public static QuartzJob init(String name){
      return new OrderTimeOutJob().buildQuartzJob(name);
   @Override
   public void execute(JobExecutionContext jobExecutionContext){
      run(jobExecutionContext);
   }
   
   
   
   /**
    * 初始化任务对象
    * @param name
    * @param group
    * @return
    */
   public static QuartzJob init(String name, String group){
      return new OrderTimeOutJob().buildQuartzJob(name, group);
   }
   
	
	
   /**
    * 初始化任务对象
    * @param name
    * @param group
    * @return
    */
   public static QuartzJob init(String name, String group, JobDataMap jobDataMap){
      return new OrderTimeOutJob().buildQuartzJob(name, group, jobDataMap);
   }
}