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.User;
|
import com.stylefeng.guns.modular.system.model.UserInfo;
|
import com.stylefeng.guns.modular.system.service.IDriverService;
|
import com.stylefeng.guns.modular.system.service.IUserService;
|
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.QuartzEnum;
|
import com.stylefeng.guns.modular.system.util.quartz.model.QuartzJob;
|
import lombok.extern.slf4j.Slf4j;
|
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;
|
|
/**
|
* 订单司机超时提醒任务
|
* @author zhibing.pu
|
* @Date 2024/4/18 15:19
|
*/
|
@Slf4j
|
@Component
|
public class OrderTimeOutJob extends QuartzJob {
|
|
@Resource
|
private PushUtil pushUtil;
|
@Resource
|
private IOrderPrivateCarService orderPrivateCarService;
|
@Resource
|
private IOrderLogisticsService orderLogisticsService;
|
@Resource
|
private IDriverService driverService;
|
@Resource
|
private UserInfoMapper userInfoMapper;
|
|
|
|
@Override
|
public QuartzJob buildQuartzJob() {
|
return buildQuartzJob(QuartzEnum.JOB_NAME.getValue());
|
}
|
|
@Override
|
public QuartzJob buildQuartzJob(String name) {
|
return buildQuartzJob(name, QuartzEnum.DEFAULT_GROUP.getValue());
|
}
|
|
@Override
|
public QuartzJob buildQuartzJob(String name, String group) {
|
return buildQuartzJob(name, QuartzEnum.DEFAULT_GROUP.getValue(), null);
|
}
|
|
@Override
|
public QuartzJob buildQuartzJob(String name, String group, JobDataMap jobDataMap) {
|
QuartzJob job = new OrderTimeOutJob();
|
if(ToolUtil.isNotEmpty(name)){
|
job.setName(name);
|
}else{
|
job.setName(QuartzEnum.JOB_NAME.getValue());
|
}
|
if(ToolUtil.isNotEmpty(group)){
|
job.setGroup(group);
|
}else{
|
job.setGroup(QuartzEnum.DEFAULT_GROUP.getValue());
|
}
|
if(null != jobDataMap){
|
job.setJobDataMap(jobDataMap);
|
}
|
return job;
|
}
|
|
/**
|
* 执行的业务逻辑
|
* @param jobExecutionContext 定时任务上下文对象
|
*/
|
@Override
|
public void run(JobExecutionContext jobExecutionContext) {
|
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);
|
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);
|
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);
|
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);
|
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;
|
}
|
}
|
|
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);
|
}
|
|
|
|
/**
|
* 初始化任务对象
|
* @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);
|
}
|
}
|
