java/IgoTravel.git

			@@ -38,6 +38,8 @@
			import org.jsoup.nodes.Document;
			import org.jsoup.nodes.Element;
			import org.jsoup.select.Elements;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.http.HttpEntity;
			@@ -60,6 +62,8 @@

			@Service
			public class OrderPrivateCarServiceImpl extends ServiceImpl<OrderPrivateCarMapper, OrderPrivateCar> implements IOrderPrivateCarService {

			private Logger log = LoggerFactory.getLogger(OrderPrivateCarServiceImpl.class);

			@Resource
			private OrderPrivateCarMapper orderPrivateCarMapper;
			@@ -426,14 +430,21 @@
			new Timer().schedule(new TimerTask() {
			@Override
			public void run() {
			Process process = null;
			try {
			process = Runtime.getRuntime().exec("sudo rm -rf /home/igotechgh/nginx/html/files/audio/" + fileName);
			} catch (IOException e) {
			throw new RuntimeException(e);
			}
			if (process != null) {
			process.destroy();
			// 使用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);
			@@ -543,14 +554,21 @@
			new Timer().schedule(new TimerTask() {
			@Override
			public void run() {
			Process process = null;
			try {
			process = Runtime.getRuntime().exec("sudo rm -rf /home/igotechgh/nginx/html/files/audio/" + fileName);
			} catch (IOException e) {
			throw new RuntimeException(e);
			}
			if (process != null) {
			process.destroy();
			// 使用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);
			@@ -843,7 +861,7 @@
			if((orderPrivateCar.getState() == 10 \|\| orderPrivateCar.getState() == 12) && null != orderPrivateCar.getDriverId()){
			fleetEngineUtil.updateTrip("CANCELED", null, null, orderPrivateCar.getTripId(), null, null, null, null);
			}

			log.warn("取消订单：{} {}", System.currentTimeMillis(), orderPrivateCar.getTrackId());
			//添加消息
			systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功取消出行订单，谢谢使用！" : language == 2 ? "You've cancelled the ride order successfully, thank you for using I-GO " : "Vous avez annulé la commande de course avec succès, merci d’utiliser I-GO", orderPrivateCar.getUserId(), 1);
			Map<String, Object> map = new HashMap<>();
			@@ -1072,14 +1090,21 @@
			new Timer().schedule(new TimerTask() {
			@Override
			public void run() {
			Process process = null;
			try {
			process = Runtime.getRuntime().exec("sudo rm -rf /home/igotechgh/nginx/html/files/audio/" + fileName);
			} catch (IOException e) {
			throw new RuntimeException(e);
			}
			if (process != null) {
			process.destroy();
			// 使用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);
			@@ -1270,11 +1295,11 @@
			userRedPacketRecord.setEndTime(new Date());
			userRedPacketRecord.setState(2);
			multiply1 = multiply1.subtract(remainingAmount).setScale(2, RoundingMode.HALF_EVEN);
			jsonObject.put("money", remainingAmount);
			jsonObject.put("money", remainingAmount.setScale(2, RoundingMode.HALF_EVEN));
			jsonArray.add(jsonObject);
			}else if(remainingAmount.compareTo(multiply1) > 0){
			userRedPacketRecord.setRemainingAmount(remainingAmount.subtract(multiply1).setScale(2, RoundingMode.HALF_EVEN).doubleValue());
			jsonObject.put("money", multiply1);
			jsonObject.put("money", multiply1.setScale(2, RoundingMode.HALF_EVEN));
			jsonArray.add(jsonObject);
			multiply1 = BigDecimal.ZERO;
			}
			@@ -2382,7 +2407,50 @@
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, "");
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, "");
			pushUtil.pushOfflinePayment(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getPayMoney());
			Integer language1 = driver.getLanguage();
			String text = "";
			switch (language1){
			case 1:
			text = "客户已选择支付现金，因此您必须收款。确定您已收到此订单费用：现金GHS " + orderPrivateCar.getPayMoney();
			break;
			case 2:
			text = "The client chose to pay in cash, so you must collect the payment.Confirm if you received the charge for this order: Cash GHS " + orderPrivateCar.getPayMoney();
			break;
			case 3:
			text = "Le client a choisi de payer en espèces, vous devez donc encaisser le paiement.Confirmez si vous avez reçu les frais pour cette commande : Espèces GHS " + orderPrivateCar.getPayMoney();
			break;

			}
			String audioUrl = "";
			String fileName = "offlinePayment" + orderPrivateCar.getDriverId() + UUIDUtil.getRandomCode(5) + ".mp3";
			try {
			audioUrl = TextToSpeechUtil.create(language1 == 1 ? "cmn-CN" : language1 == 2 ? "en-US" : "fr-FR", text, fileName);
			} catch (Exception e) {
			throw new RuntimeException(e);
			}
			//定时任务删除语音文件
			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);
			pushUtil.pushOfflinePayment(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getPayMoney(), audioUrl);
			}
			}).start();