From 4c99ee7028c3fe58a2cd4b8273b22c75c45574fc Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期五, 16 五月 2025 10:27:41 +0800 Subject: [PATCH] 修改文档bug --- DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java | 1898 +++++++++++++++++++++++++++++++++++------------------------ 1 files changed, 1,121 insertions(+), 777 deletions(-) diff --git a/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java b/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java index 16d0c65..68f009a 100644 --- a/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java +++ b/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java @@ -17,9 +17,7 @@ import com.stylefeng.guns.modular.system.model.*; import com.stylefeng.guns.modular.system.service.*; import com.stylefeng.guns.modular.system.util.*; -import com.stylefeng.guns.modular.system.util.GoogleMap.AddressComponentsVo; -import com.stylefeng.guns.modular.system.util.GoogleMap.GoogleMapUtil; -import com.stylefeng.guns.modular.system.util.GoogleMap.ReverseGeocodeVo; +import com.stylefeng.guns.modular.system.util.GoogleMap.*; import com.stylefeng.guns.modular.system.util.itextpdf.HtmlToPdfUtils; import com.stylefeng.guns.modular.system.warpper.*; import com.stylefeng.guns.modular.taxi.service.IOrderTaxiService; @@ -28,6 +26,7 @@ import org.apache.shiro.authc.credential.HashedCredentialsMatcher; import org.apache.shiro.crypto.hash.Md5Hash; import org.apache.shiro.util.ByteSource; +import org.apache.shiro.util.StringUtils; import org.jsoup.Jsoup; import org.jsoup.nodes.Document; import org.jsoup.nodes.Element; @@ -37,10 +36,7 @@ import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; -import java.io.File; -import java.io.FileInputStream; -import java.io.FileOutputStream; -import java.io.FileWriter; +import java.io.*; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.*; @@ -153,6 +149,16 @@ @Autowired private TEmailService emailService; + + @Autowired + private FleetEngineUtil fleetEngineUtil; + + + @Resource + private CarModelMapper carModelMapper; + + @Autowired + private ISettlementRecordService settlementRecordService; @Override @@ -200,10 +206,11 @@ redisUtil.setStrValue(phone, authCode, 5 * 60);//设置五分钟过期 switch (language){ case 1: - sms = "您的验证码为:" + authCode + ",该验证码5分钟内有效,请勿泄漏于他人!"; +// sms = "您的验证码为:" + authCode + ",该验证码5分钟内有效,请勿泄漏于他人!"; + sms = "Your verification code is " + authCode + ", it is valid within 5 minutes, please do not reveal it to others."; break; case 2: - sms = "Your verification code is " + authCode + ",it is valid within 5 minutes, please do not reveal it to others."; + sms = "Your verification code is " + authCode + ", it is valid within 5 minutes, please do not reveal it to others."; break; case 3: sms = "Votre code de validation est " + authCode + " et il est valide pendant 5 minutes. Veuillez ne pas le révéler à d’autres personnes."; @@ -266,7 +273,7 @@ Element email1_user = document.getElementById("email1_user"); email1_user.text("Hello ,"); Element email1_content = document.getElementById("email1_content"); - email1_content.text("Your package pickup code is " + authCode + ", please complete the verification within 5 minutes"); + email1_content.text("Your delivery pickup code is " + authCode + ", please complete the verification within 5 minutes"); } if(3 == language){ document.getElementById("chinese").remove(); @@ -285,7 +292,7 @@ Element email2_user = document.getElementById("email2_user"); email2_user.text("Hello ,"); Element email2_content = document.getElementById("email2_content"); - email2_content.text("Le code de ramassage de votre colis est " + authCode + ", veuillez effectuer la verification dans les 5minutes."); + email2_content.text("Le code de ramassage de votre livraison est " + authCode + ", veuillez effectuer la verification dans les 5minutes."); } EmailUtil.send(email, language == 1 ? "邮箱验证" : language == 2 ? "Verification code" : "Code de validation", document.html()); return ResultUtil.success(); @@ -324,20 +331,22 @@ if(null == driver1 && result.getCode() == 200 && null != uid){ if(type == 2){ Driver driver = driverMapper.selectById(uid); - List<Map<String, Object>> query = driverActivityRegisteredMapper.query(userType, driver.getCompanyId()); + Map<String, Date> date = dateUtil.getStartAndEndDate(new Date()); + List<DriverActivityHistory> list = driverActivityHistoryMapper.queryList(null, 1, 1, date.get("startTime"), date.get("endTime")); BigDecimal bigDecimal = new BigDecimal("0"); - for(Map<String, Object> map : query){ - if(Double.valueOf(String.valueOf(map.get("money"))).compareTo(0D) > 0){ - bigDecimal = bigDecimal.add(new BigDecimal(String.valueOf(map.get("money")))); - incomeService.saveData(2, driver.getId(), 1, Integer.valueOf(String.valueOf(map.get("id"))), null, Double.valueOf(String.valueOf(map.get("money")))); - } + for (DriverActivityHistory driverActivityHistory : list) { + bigDecimal = bigDecimal.add(new BigDecimal(driverActivityHistory.getMoney())); + incomeService.saveData(2, driver.getId(), 1, driverActivityHistory.getId(), null, driverActivityHistory.getMoney()); + driverActivityHistory.setCarryOut(2); + driverActivityHistory.setCompletionTime(new Date()); + driverActivityHistoryMapper.updateById(driverActivityHistory); } driver.setActivityMoney(bigDecimal.add(new BigDecimal(driver.getActivityMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); driver.setLaveActivityMoney(bigDecimal.add(new BigDecimal(driver.getLaveActivityMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); driver.setBalance(bigDecimal.add(new BigDecimal(driver.getBalance())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); driverMapper.updateById(driver); - if(ToolUtil.isNotEmpty(driver.getEmail())){ + if(list.size() > 0 && ToolUtil.isNotEmpty(driver.getEmail())){ String path = templatePath + "driver/index.html"; Document document = Jsoup.parse(new File(path), "UTF-8"); if(1 == language){ @@ -400,11 +409,11 @@ EmailUtil.send(driver.getEmail(), language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document.html()); String randomString = ToolUtil.getRandomString(10); //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); + File file = new File("/home/igotechgh/nginx/html/files/html/"); if(!file.exists()){ file.mkdirs(); } - file = new File("/usr/local/nginx/html/files/html/invitation_" + randomString + ".html"); + file = new File("/home/igotechgh/nginx/html/files/html/invitation_" + randomString + ".html"); if(!file.exists()){ file.createNewFile(); } @@ -413,7 +422,7 @@ fileWriter.flush(); fileWriter.close(); - String link ="http://182.160.16.251:81/files/html/invitation_" + randomString + ".html"; + String link ="https://igo.i-go.group/files/html/invitation_" + randomString + ".html"; TEmail tEmail = new TEmail(); tEmail.setLink(link); tEmail.setUserId(driver.getId()); @@ -512,112 +521,125 @@ if(null != uid){ if(type == 2){ driver = driverMapper.selectById(uid); - List<Map<String, Object>> query = driverActivityRegisteredMapper.query(userType, driver.getCompanyId()); + Map<String, Date> date = dateUtil.getStartAndEndDate(new Date()); + List<DriverActivityHistory> list = driverActivityHistoryMapper.queryList(uid, 1, 1, date.get("startTime"), date.get("endTime")); BigDecimal bigDecimal = new BigDecimal("0"); - for(Map<String, Object> map : query){ - if(Double.valueOf(String.valueOf(map.get("money"))).compareTo(0D) > 0){ - bigDecimal = bigDecimal.add(new BigDecimal(String.valueOf(map.get("money")))); - incomeService.saveData(2, driver.getId(), 1, Integer.valueOf(String.valueOf(map.get("id"))), null, Double.valueOf(String.valueOf(map.get("money")))); - } + for (DriverActivityHistory driverActivityHistory : list) { + bigDecimal = bigDecimal.add(new BigDecimal(driverActivityHistory.getMoney())); + incomeService.saveData(2, driver.getId(), 1, driverActivityHistory.getId(), null, driverActivityHistory.getMoney()); + driverActivityHistory.setCarryOut(2); + driverActivityHistory.setCompletionTime(new Date()); + driverActivityHistoryMapper.updateById(driverActivityHistory); } driver.setActivityMoney(bigDecimal.add(new BigDecimal(driver.getActivityMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); driver.setLaveActivityMoney(bigDecimal.add(new BigDecimal(driver.getLaveActivityMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); driver.setBalance(bigDecimal.add(new BigDecimal(driver.getBalance())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); driverMapper.updateById(driver); - if(ToolUtil.isNotEmpty(driver.getEmail())){ - String path = templatePath + "driver/index.html"; - Document document = Jsoup.parse(new File(path), "UTF-8"); - if(1 == language){ - document.getElementById("english").remove(); - document.getElementById("french").remove(); - document.getElementById("user").remove(); - document.getElementById("settle").remove(); - document.getElementById("pass").remove(); - document.getElementById("email").remove(); - document.getElementById("bill").remove(); - document.getElementById("reward").remove(); - document.getElementById("rewardToday").remove(); - document.getElementById("driverAudit").remove(); - document.getElementById("carAudit").remove(); - - document.getElementsByTag("title").get(0).text("司机奖励通知"); - Element invite_user = document.getElementById("invite_user"); - invite_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element invite_content = document.getElementById("invite_content"); - invite_content.text("您已成功邀请一位司机注册I-GO,获得奖励GHS " + bigDecimal.doubleValue() + ",请查收"); - } - if(2 == language){ - document.getElementById("chinese").remove(); - document.getElementById("french").remove(); - document.getElementById("user1").remove(); - document.getElementById("settle1").remove(); - document.getElementById("pass1").remove(); - document.getElementById("email1").remove(); - document.getElementById("bill1").remove(); - document.getElementById("reward1").remove(); - document.getElementById("rewardToday1").remove(); - document.getElementById("driverAudit1").remove(); - document.getElementById("carAudit1").remove(); - - document.getElementsByTag("title").get(0).text("Reward-driver notice"); - Element invite1_user = document.getElementById("invite1_user"); - invite1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element invite1_content = document.getElementById("invite1_content"); - invite1_content.text("You have succeeded to invite a driver to register with I-GO, so you received a GHS " + bigDecimal.doubleValue() + " bonus, please check your balance."); - } - if(3 == language){ - document.getElementById("chinese").remove(); - document.getElementById("english").remove(); - document.getElementById("user2").remove(); - document.getElementById("settle2").remove(); - document.getElementById("pass2").remove(); - document.getElementById("email2").remove(); - document.getElementById("bill2").remove(); - document.getElementById("reward2").remove(); - document.getElementById("rewardToday2").remove(); - document.getElementById("driverAudit2").remove(); - document.getElementById("carAudit2").remove(); - - document.getElementsByTag("title").get(0).text("Avis de chauffeur de récompense"); - Element invite2_user = document.getElementById("invite2_user"); - invite2_user.text("Bonjour " + driver.getFirstName() + " " + driver.getLastName() + ","); - Element invite2_content = document.getElementById("invite2_content"); - invite2_content.text("Vous avez invité avec succès un conducteur à s’inscrire à i-go pour recevoir une récompense GHS " + bigDecimal.doubleValue() + ". Veuillez vérifier"); - } - EmailUtil.send(driver.getEmail(), language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document.html()); - String randomString = ToolUtil.getRandomString(10); - //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); - if(!file.exists()){ - file.mkdirs(); - } - file = new File("/usr/local/nginx/html/files/html/invitation_" + randomString + ".html"); - if(!file.exists()){ - file.createNewFile(); - } - FileWriter fileWriter = new FileWriter(file); - fileWriter.write(document.html()); - fileWriter.flush(); - fileWriter.close(); - - String link ="http://182.160.16.251:81/files/html/invitation_" + randomString + ".html"; - TEmail tEmail = new TEmail(); - tEmail.setLink(link); - tEmail.setUserId(driver.getId()); - tEmail.setType(2); - tEmail.setName(language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense"); - tEmail.setCreateTime(new Date()); - int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; - String week = EmailUtil.getWeek(language, i); - tEmail.setWeek(week); - boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); - if(am){ - tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); - }else { - tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); - } - emailService.insert(tEmail); + if(list.size() > 0 && ToolUtil.isNotEmpty(driver.getEmail())){ + Driver finalDriver = driver; + BigDecimal finalBigDecimal = bigDecimal; + new Thread(new Runnable() { + @Override + public void run() { + try { + String path = templatePath + "driver/index.html"; + Document document = Jsoup.parse(new File(path), "UTF-8"); + if(1 == language){ + document.getElementById("english").remove(); + document.getElementById("french").remove(); + document.getElementById("user").remove(); + document.getElementById("settle").remove(); + document.getElementById("pass").remove(); + document.getElementById("email").remove(); + document.getElementById("bill").remove(); + document.getElementById("reward").remove(); + document.getElementById("rewardToday").remove(); + document.getElementById("driverAudit").remove(); + document.getElementById("carAudit").remove(); + + document.getElementsByTag("title").get(0).text("司机奖励通知"); + Element invite_user = document.getElementById("invite_user"); + invite_user.text("您好 " + finalDriver.getFirstName() + "" + finalDriver.getLastName() + ","); + Element invite_content = document.getElementById("invite_content"); + invite_content.text("您已成功邀请一位司机注册I-GO,获得奖励GHS " + finalBigDecimal.doubleValue() + ",请查收"); + } + if(2 == language){ + document.getElementById("chinese").remove(); + document.getElementById("french").remove(); + document.getElementById("user1").remove(); + document.getElementById("settle1").remove(); + document.getElementById("pass1").remove(); + document.getElementById("email1").remove(); + document.getElementById("bill1").remove(); + document.getElementById("reward1").remove(); + document.getElementById("rewardToday1").remove(); + document.getElementById("driverAudit1").remove(); + document.getElementById("carAudit1").remove(); + + document.getElementsByTag("title").get(0).text("Reward-driver notice"); + Element invite1_user = document.getElementById("invite1_user"); + invite1_user.text("Hello " + finalDriver.getFirstName() + "" + finalDriver.getLastName() + ","); + Element invite1_content = document.getElementById("invite1_content"); + invite1_content.text("You have succeeded to invite a driver to register with I-GO, so you received a GHS " + finalBigDecimal.doubleValue() + " bonus, please check your balance."); + } + if(3 == language){ + document.getElementById("chinese").remove(); + document.getElementById("english").remove(); + document.getElementById("user2").remove(); + document.getElementById("settle2").remove(); + document.getElementById("pass2").remove(); + document.getElementById("email2").remove(); + document.getElementById("bill2").remove(); + document.getElementById("reward2").remove(); + document.getElementById("rewardToday2").remove(); + document.getElementById("driverAudit2").remove(); + document.getElementById("carAudit2").remove(); + + document.getElementsByTag("title").get(0).text("Avis de chauffeur de récompense"); + Element invite2_user = document.getElementById("invite2_user"); + invite2_user.text("Bonjour " + finalDriver.getFirstName() + " " + finalDriver.getLastName() + ","); + Element invite2_content = document.getElementById("invite2_content"); + invite2_content.text("Vous avez invité avec succès un conducteur à s’inscrire à i-go pour recevoir une récompense GHS " + finalBigDecimal.doubleValue() + ". Veuillez vérifier"); + } + EmailUtil.send(finalDriver.getEmail(), language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document.html()); + String randomString = ToolUtil.getRandomString(10); + //开始生成pdf收据和html收据 + File file = new File("/home/igotechgh/nginx/html/files/html/"); + if(!file.exists()){ + file.mkdirs(); + } + file = new File("/home/igotechgh/nginx/html/files/html/invitation_" + randomString + ".html"); + if(!file.exists()){ + file.createNewFile(); + } + FileWriter fileWriter = new FileWriter(file); + fileWriter.write(document.html()); + fileWriter.flush(); + fileWriter.close(); + + String link ="https://igo.i-go.group/files/html/invitation_" + randomString + ".html"; + TEmail tEmail = new TEmail(); + tEmail.setLink(link); + tEmail.setUserId(finalDriver.getId()); + tEmail.setType(2); + tEmail.setName(language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense"); + tEmail.setCreateTime(new Date()); + int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; + String week = EmailUtil.getWeek(language, i); + tEmail.setWeek(week); + boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); + if(am){ + tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); + }else { + tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); + } + emailService.insert(tEmail); + }catch (Exception e){ + e.printStackTrace(); + } + } + }).start(); } } @@ -855,11 +877,11 @@ EmailUtil.send(driver.getEmail(), language == 1 ? "成功注册" : language == 2 ? "Registered successfully" : "Enregistré avec succès", document1.html()); String randomString = ToolUtil.getRandomString(10); //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); + File file = new File("/home/igotechgh/nginx/html/files/html/"); if(!file.exists()){ file.mkdirs(); } - file = new File("/usr/local/nginx/html/files/html/registration_" + randomString + ".html"); + file = new File("/home/igotechgh/nginx/html/files/html/registration_" + randomString + ".html"); if(!file.exists()){ file.createNewFile(); } @@ -868,7 +890,7 @@ fileWriter.flush(); fileWriter.close(); - String link ="http://182.160.16.251:81/files/html/registration_" + randomString + ".html"; + String link ="https://igo.i-go.group/files/html/registration_" + randomString + ".html"; TEmail tEmail = new TEmail(); tEmail.setLink(link); tEmail.setUserId(driver.getId()); @@ -969,11 +991,11 @@ EmailUtil.send(driver.getEmail(), language == 1 ? "密码重置" : language == 2 ? "Reset password" : "Réinitialiser le mot de passe", document1.html()); String randomString = ToolUtil.getRandomString(10); //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); + File file = new File("/home/igotechgh/nginx/html/files/html/"); if(!file.exists()){ file.mkdirs(); } - file = new File("/usr/local/nginx/html/files/html/reset_" + randomString + ".html"); + file = new File("/home/igotechgh/nginx/html/files/html/reset_" + randomString + ".html"); if(!file.exists()){ file.createNewFile(); } @@ -982,7 +1004,7 @@ fileWriter.flush(); fileWriter.close(); - String link ="http://182.160.16.251:81/files/html/reset_" + randomString + ".html"; + String link ="https://igo.i-go.group/files/html/reset_" + randomString + ".html"; TEmail tEmail = new TEmail(); tEmail.setLink(link); tEmail.setUserId(driver.getId()); @@ -1012,7 +1034,7 @@ */ @Override public Map<String, Object> queryPhone(Double lat, Double lnt) throws Exception { - ReverseGeocodeVo reverseGeocode = GoogleMapUtil.getReverseGeocode(lat, lnt); + ReverseGeocodeVo reverseGeocode = GoogleMapUtil.getReverseGeocode(lat, lnt, null); if(null == reverseGeocode){ System.err.println("获取地址异常"); return null; @@ -1077,6 +1099,38 @@ loginWarpper.setJumpCode("200000"); } } + if(null != driver.getCarId()){ + Car car = carService.selectById(driver.getCarId()); + if(!StringUtils.hasLength(car.getVehicleId())){ + car.setVehicleId(UUIDUtil.getRandomCode()); + carService.updateById(car); + } + new Thread(()->{ + try { + CarModel carModel = carModelMapper.selectById(car.getCarModelId()); + String vehicles = fleetEngineUtil.getVehicles(car.getVehicleId()); + if(ToolUtil.isEmpty(vehicles)) { + boolean createVehicles = fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(!createVehicles){ + for (int i = 0; i < 5; i++) { + createVehicles = fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(createVehicles){ + break; + } + try { + Thread.sleep(5000L); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } + } + } + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); + loginWarpper.setVehicleId(car.getVehicleId()); + } return ResultUtil.success(loginWarpper); } @@ -1089,28 +1143,12 @@ */ @Override public Map<String, Object> queryHomeData(Integer uid, Integer language) throws Exception { + Driver driver = this.selectById(uid); + driver.setLanguage(language); + this.updateById(driver); Map<String, Object> map = driverMapper.queryHomeData(uid); int size = this.queryMyActivity(uid, new Date(), language).size(); map.put("activity", size); - //获取司机待支付的现金支付订单推送司机支付 -// new Thread(new Runnable() { -// @Override -// public void run() { -// List<OrderPrivateCar> orderPrivateCars = orderPrivateCarService.selectList(new EntityWrapper<OrderPrivateCar>().eq("driverId", uid).eq("payType", 4) -// .eq("driverPay", 1).eq("isDelete", 1)); -// if(orderPrivateCars.size() > 0){ -// OrderPrivateCar orderPrivateCar = orderPrivateCars.get(0); -// pushUtil.pushOfflinePayment(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1); -// return; -// } -// List<OrderLogistics> orderLogistics = orderLogisticsService.selectList(new EntityWrapper<OrderLogistics>().eq("driverId", uid).eq("payType", 4) -// .eq("isDelete", 1).eq("driverPay", 1)); -// if(orderLogistics.size() > 0){ -// OrderLogistics orderLogistics1 = orderLogistics.get(0); -// pushUtil.pushOfflinePayment(2, orderLogistics1.getDriverId(), orderLogistics1.getId(), orderLogistics1.getType()); -// } -// } -// }).start(); return map; } @@ -1150,18 +1188,93 @@ public ResultUtil work(Integer uid, String type, Integer language) throws Exception { DriverWork driverWork = driverWorkMapper.queryNewWork(uid, null, 1); Driver driver = this.selectById(uid); + driver.setLanguage(language); + Car car = carService.selectById(driver.getCarId()); + String audioUrl = ""; + LoginWarpper loginWarpper = new LoginWarpper(); if(null != driverWork){//作下班操作 //检测是否有未完成的订单 List<Map<String, Object>> list = orderService.queryOrderList(1, 1, 10, uid, language); if(list.size() > 0){ - return ResultUtil.error(language == 1 ? "还有未完成的订单,不能进行下班操作" : language == 2 ? "There are still outstanding orders, can not be off-duty operation" : "Il y a encore des commandes en suspens qui ne peuvent pas être exécutées"); + return ResultUtil.error(language == 1 ? "还有未完成的订单,不能进行下班操作" : language == 2 ? "Outstanding orders ! So you can't get off work" : "Commandes en suspens ! Vous ne pouvez pas quitter le travail"); } driverWork.setEndTime(new Date()); driverWork.setState(2); driverWorkMapper.updateById(driverWork); driver.setState(1); + + if(!StringUtils.hasLength(car.getVehicleId())){ + car.setVehicleId(UUIDUtil.getRandomCode()); + carService.updateById(car); + } + + //司机下班,修改谷歌上的车辆信息 + new Thread(()->{ + try { + CarModel carModel = carModelMapper.selectById(car.getCarModelId()); + String vehicles = fleetEngineUtil.getVehicles(car.getVehicleId()); + if(ToolUtil.isEmpty(vehicles)){ + boolean createVehicles = fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(!createVehicles){ + for (int i = 0; i < 5; i++) { + createVehicles = fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(createVehicles){ + break; + } + try { + Thread.sleep(5000L); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } + } + + boolean updateVehicles = fleetEngineUtil.updateVehicles("OFFLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(!updateVehicles){ + for (int i = 0; i < 5; i++) { + updateVehicles = fleetEngineUtil.updateVehicles("OFFLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(updateVehicles){ + break; + } + try { + Thread.sleep(5000L); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } + } + }else{ + boolean updateVehicles = fleetEngineUtil.updateVehicles("OFFLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(!updateVehicles){ + for (int i = 0; i < 5; i++) { + updateVehicles = fleetEngineUtil.updateVehicles("OFFLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(updateVehicles){ + break; + } + try { + Thread.sleep(5000L); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } + } + } + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); + switch (language){ + case 1: + audioUrl = "https://igo.i-go.group/files/audio/system/AfterWork-CN.mp3"; + break; + case 2: + audioUrl = "https://igo.i-go.group/files/audio/system/AfterWork-EN.mp3"; + break; + case 3: + audioUrl = "https://igo.i-go.group/files/audio/system/AfterWork-FR.mp3"; + break; + } }else{ - LoginWarpper loginWarpper = new LoginWarpper(); if(driver.getCompanyId()==null){ loginWarpper.setJumpCode("100000"); return ResultUtil.success(loginWarpper); @@ -1178,7 +1291,6 @@ if(driver.getAuthState()==4){ return ResultUtil.error(language == 1 ? "请完善资料后再出车" : language == 2 ? "Please complete data before driving." : "Veuillez compléter les données avant de conduire."); } - Car car = carService.selectById(driver.getCarId()); if(car==null){ return ResultUtil.error(language == 1 ? "请完善资料后再出车" : language == 2 ? "Please complete data before driving." : "Veuillez compléter les données avant de conduire."); } @@ -1188,6 +1300,7 @@ if(car.getAuthState()==4){ return ResultUtil.error(language == 1 ? "请完善资料后再出车" : language == 2 ? "Please complete data before driving." : "Veuillez compléter les données avant de conduire."); } + driverWork = new DriverWork(); driverWork.setState(1); driverWork.setDriverId(uid); @@ -1195,9 +1308,87 @@ driverWork.setType(type); driverWorkMapper.insert(driverWork); driver.setState(2); + + if(!StringUtils.hasLength(car.getVehicleId())){ + car.setVehicleId(UUIDUtil.getRandomCode()); + carService.updateById(car); + } + + //司机上班,修改谷歌上的车辆信息 + new Thread(new Runnable() { + @Override + public void run() { + try { + CarModel carModel = carModelMapper.selectById(car.getCarModelId()); + String vehicles = fleetEngineUtil.getVehicles(car.getVehicleId()); + if(ToolUtil.isEmpty(vehicles)){ + boolean createVehicles = fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(!createVehicles){ + for (int i = 0; i < 5; i++) { + createVehicles = fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(createVehicles){ + break; + } + try { + Thread.sleep(5000L); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } + } + + boolean updateVehicles = fleetEngineUtil.updateVehicles("ONLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(!updateVehicles){ + for (int i = 0; i < 5; i++) { + updateVehicles = fleetEngineUtil.updateVehicles("ONLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(updateVehicles){ + break; + } + try { + Thread.sleep(5000L); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } + } + }else{ + boolean updateVehicles = fleetEngineUtil.updateVehicles("ONLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(!updateVehicles){ + for (int i = 0; i < 5; i++) { + updateVehicles = fleetEngineUtil.updateVehicles("ONLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + if(updateVehicles){ + break; + } + try { + Thread.sleep(5000L); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + } + } + } + }catch (Exception e){ + e.printStackTrace(); + } + } + }).start(); + + switch (language){ + case 1: + audioUrl = "https://igo.i-go.group/files/audio/system/AtWork-CN.mp3"; + break; + case 2: + audioUrl = "https://igo.i-go.group/files/audio/system/AtWork-EN.mp3"; + break; + case 3: + audioUrl = "https://igo.i-go.group/files/audio/system/AtWork-FR.mp3"; + break; + } } this.updateById(driver); - return ResultUtil.success(); + loginWarpper.setAudioUrl(audioUrl); + loginWarpper.setVehicleId(car.getVehicleId()); + return ResultUtil.success(loginWarpper); } @@ -1219,7 +1410,7 @@ //检测是否有未完成的订单 List<Map<String, Object>> list = orderService.queryOrderList(1, 1, 10, uid, language); if(list.size() > 0){ - return ResultUtil.error(language == 1 ? "还有未完成的订单,不能进行下班操作" : language == 2 ? "There are still outstanding orders, can not be off-duty operation" : "Il y a encore des commandes en suspens qui ne peuvent pas être exécutées"); + return ResultUtil.error(language == 1 ? "还有未完成的订单,不能进行下班操作" : language == 2 ? "Outstanding orders ! So you can't get off work" : "Commandes en suspens ! Vous ne pouvez pas quitter le travail"); } driverWork.setEndTime(new Date()); driverWork.setState(2); @@ -1282,7 +1473,7 @@ map.put("service", list.size());//服务中 list = orderTaxiService.queryOrderList(language, 2, uid); map.put("reservation", list.size());//预约 - List<Map<String, Object>> list1 = orderLogisticsService.queryOrderList(uid, language); + List<Map<String, Object>> list1 = orderLogisticsService.queryOrderList(1, uid, language); map.put("small", list1.size());//小件 int size = this.queryMyActivity(uid, new Date(), language).size(); map.put("activity", size);//活动 @@ -1298,12 +1489,12 @@ */ @Override public List<BaseWarpper> queryMyBusiness(Integer uid, Integer language) throws Exception { - List<DriverService> list = driverServiceMapper.queryMyBusiness(uid); + List<Integer> list = Arrays.asList(1, 4); List<BaseWarpper> maps = new ArrayList<>(); - for (DriverService d : list){ + for (Integer d : list){ BaseWarpper baseWarpper = new BaseWarpper(); - baseWarpper.setId(d.getType()); - switch (d.getType()){ + baseWarpper.setId(d); + switch (d){ case 1: baseWarpper.setName(language == 1 ? "打车" : language == 2 ? "Ride" : "Course"); break; @@ -1314,20 +1505,13 @@ baseWarpper.setName(language == 1 ? "跨城出行" : language == 2 ? "Cross-town travel" : "Se déplacer à travers la ville"); break; case 4: - baseWarpper.setName(language == 1 ? "包裹" : language == 2 ? "Package" : "Livraison"); + baseWarpper.setName(language == 1 ? "包裹" : language == 2 ? "Delivery" : "Livraison"); break; case 5: baseWarpper.setName(language == 1 ? "跨城小件物流" : language == 2 ? "Cross-city small parts logistics" : "Logistique des petites pièces à travers la ville"); break; } maps.add(baseWarpper); - } - DriverOrders query = driverOrdersMapper.query(uid, 1); - if(null == query){ - query = new DriverOrders(); - query.setDriverId(uid); - query.setType(1); - driverOrdersMapper.insert(query); } return maps; } @@ -1361,7 +1545,6 @@ driver.setQrCode(QrCodeUtil.getQrCode(uid)); driverMapper.updateById(driver); } - //减去本周的收入 return map; } @@ -1480,11 +1663,11 @@ EmailUtil.send(driver.getEmail(), language == 1 ? "密码重置" : language == 2 ? "Reset password" : "Réinitialiser le mot de passe", document1.html()); String randomString = ToolUtil.getRandomString(10); //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); + File file = new File("/home/igotechgh/nginx/html/files/html/"); if(!file.exists()){ file.mkdirs(); } - file = new File("/usr/local/nginx/html/files/html/reset_" + randomString + ".html"); + file = new File("/home/igotechgh/nginx/html/files/html/reset_" + randomString + ".html"); if(!file.exists()){ file.createNewFile(); } @@ -1493,7 +1676,7 @@ fileWriter.flush(); fileWriter.close(); - String link ="http://182.160.16.251:81/files/html/reset_" + randomString + ".html"; + String link ="https://igo.i-go.group/files/html/reset_" + randomString + ".html"; TEmail tEmail = new TEmail(); tEmail.setLink(link); tEmail.setUserId(driver.getId()); @@ -1630,7 +1813,7 @@ */ @Override public List<Map<String, Object>> queryActivityIncome(Integer language, Integer uid, Integer pageNum, Integer size) throws Exception { - List<Map<String, Object>> query = incomeService.query(language,2, uid, 1, pageNum, size); + List<Map<String, Object>> query = incomeService.query(language,2, uid, Arrays.asList(1), pageNum, size); return query; } @@ -1645,7 +1828,7 @@ */ @Override public List<Map<String, Object>> queryTotalRevenue(Integer language, Integer uid, Integer pageNum, Integer size) throws Exception { - List<Map<String, Object>> query = incomeService.query(language, 2, uid, 2, pageNum, size); + List<Map<String, Object>> query = incomeService.query(language, 2, uid, Arrays.asList(2, 3, 5, 6, 7), pageNum, size); return query; } @@ -1685,7 +1868,7 @@ activityWarpper.setId(driverActivityOnline.getId()); StringBuffer sb = new StringBuffer(language == 1 ? "今日" : language == 2 ? "Today, stay online receiving orders of " : "Aujourd’hui, reste en ligne à recevoir des commandes "); - DriverOnline query = driverOnlineMapper.query(uid, sdf1.format(new Date()), 0); + DriverOnline query = driverOnlineMapper.query(uid, sdf1.format(new Date()), driverActivityOnline.getType(), 0); Integer hour = 0; if(null != query){ hour = Long.valueOf(query.getDuration() / 3600).intValue(); @@ -1701,7 +1884,7 @@ sb.append("城际出行"); continue; case 4: - sb.append(language == 1 ? "包裹" : language == 2 ? "package" : "de colis"); + sb.append(language == 1 ? "包裹" : language == 2 ? "delivery" : "de livraison"); break; } String str = language == 1 ? "累计在线" +driverActivityOnline.getOnline() + "小时奖励GHS" +driverActivityOnline.getMoney(): @@ -1716,17 +1899,91 @@ activityWarpper.setContent(language == 1 ? "今日" + driverActivityOrder.getStart() + "-" + driverActivityOrder.getEnd() + "累计接单" + driverActivityOrder.getOrderNum() + "单奖励GHS" + driverActivityOrder.getMoney(): language == 2 ? "Today " + driverActivityOrder.getStart() + "-" + driverActivityOrder.getEnd() + ", complete " + driverActivityOrder.getOrderNum() + " orders for a reward of GHS" + driverActivityOrder.getMoney() : "Aujourd’hui de " + driverActivityOrder.getStart() + " à " + driverActivityOrder.getEnd() + ", complétez " + driverActivityOrder.getOrderNum() + " commandes pour une récompense de GHS" + driverActivityOrder.getMoney()); - SimpleDateFormat sdf = new SimpleDateFormat("H:m"); - Date start = sdf.parse(driverActivityOrder.getStart()); - Date end = sdf.parse(driverActivityOrder.getEnd()); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date start = sdf.parse(sdf1.format(time) + " " + driverActivityOrder.getStart() + ":00"); + Date end = sdf.parse(sdf1.format(time) + " " + driverActivityOrder.getEnd() + ":59"); Integer integer = orderService.queryOrderNum(uid, start, end); - activityWarpper.setCarryOut(integer > driverActivityOrder.getOrderNum() ? driverActivityOrder.getOrderNum() + "/" + driverActivityOrder.getOrderNum() : integer + "/" + driverActivityOrder.getOrderNum()); + activityWarpper.setCarryOut(integer.compareTo(driverActivityOrder.getOrderNum()) > 0 ? driverActivityOrder.getOrderNum() + "/" + driverActivityOrder.getOrderNum() : integer + "/" + driverActivityOrder.getOrderNum()); break; } list.add(activityWarpper); } return list; } + + + @Override + public List<ActivityWarpper> queryHistoryList(Integer uid, Date time, Integer language) throws Exception { + List<ActivityWarpper> list = new ArrayList<>(); + Map<String, Date> date = dateUtil.getStartAndEndDate(time); + List<DriverActivityHistory> driverActivityHistories = driverActivityHistoryMapper.queryHistoryList(uid, null, null, date.get("startTime"), date.get("endTime")); + + SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd"); + for(DriverActivityHistory dah : driverActivityHistories){ + ActivityWarpper activityWarpper = new ActivityWarpper(); + switch (dah.getType()){ + case 1://邀请司机注册 + DriverActivityRegistered driverActivityRegistered = driverActivityRegisteredMapper.selectById(dah.getActivityId()); + activityWarpper.setId(driverActivityRegistered.getId()); + activityWarpper.setContent(language == 1 ? "邀请司机注册奖励GHS" + driverActivityRegistered.getMoney() : + language == 2 ? " Invite drivers to register for a reward of GHS" + driverActivityRegistered.getMoney(): + "Invitez les chauffeurs à s’inscrire pour une récompense de GHS" + driverActivityRegistered.getMoney()); + break; + case 2://邀请用户注册 + DriverActivityRegistered driverActivityRegistered1 = driverActivityRegisteredMapper.selectById(dah.getActivityId()); + activityWarpper.setId(driverActivityRegistered1.getId()); + activityWarpper.setContent(language == 1 ? "邀请用户注册奖励GHS" + driverActivityRegistered1.getMoney() : + language == 2 ? "Invite users to register for a reward of GHS" + driverActivityRegistered1.getMoney(): + "Invitez les utilisateurs à s’inscrire pour une récompense de GHS" + driverActivityRegistered1.getMoney()); + break; + case 3://累计在线 + DriverActivityOnline driverActivityOnline = driverActivityOnlineMapper.selectById(dah.getActivityId()); + activityWarpper.setId(driverActivityOnline.getId()); + StringBuffer sb = new StringBuffer(language == 1 ? "今日" : + language == 2 ? "Today, stay online receiving orders of " : "Aujourd’hui, reste en ligne à recevoir des commandes "); + DriverOnline query = driverOnlineMapper.query(uid, sdf1.format(new Date()), driverActivityOnline.getType(), 0); + Integer hour = 0; + if(null != query){ + hour = Long.valueOf(query.getDuration() / 3600).intValue(); + } + switch (driverActivityOnline.getType()){ + case 1: + sb.append(language == 1 ? "打车" : language == 2 ? "ride" : "de course"); + break; + case 2: + sb.append("出租车"); + continue; + case 3: + sb.append("城际出行"); + continue; + case 4: + sb.append(language == 1 ? "包裹" : language == 2 ? "delivery" : "de livraison"); + break; + } + String str = language == 1 ? "累计在线" +driverActivityOnline.getOnline() + "小时奖励GHS" +driverActivityOnline.getMoney(): + language == 2 ? " for " + driverActivityOnline.getOnline() + " hours to get a reward of GHS" + driverActivityOnline.getMoney(): + " pendant " + driverActivityOnline.getOnline() + " heures afin d'obtenir une récompense de GHS" + driverActivityOnline.getMoney(); + activityWarpper.setContent(sb.append(str).toString()); + activityWarpper.setCarryOut((dah.getCarryOut() == 2 || hour > driverActivityOnline.getOnline()) ? driverActivityOnline.getOnline() + "/" +driverActivityOnline.getOnline() : hour + "/" + driverActivityOnline.getOnline()); + break; + case 4://订单量 + DriverActivityOrder driverActivityOrder = driverActivityOrderMapper.selectById(dah.getActivityId()); + activityWarpper.setId(driverActivityOrder.getId()); + activityWarpper.setContent(language == 1 ? "今日" + driverActivityOrder.getStart() + "-" + driverActivityOrder.getEnd() + "累计接单" + driverActivityOrder.getOrderNum() + "单奖励GHS" + driverActivityOrder.getMoney(): + language == 2 ? "Today " + driverActivityOrder.getStart() + "-" + driverActivityOrder.getEnd() + ", complete " + driverActivityOrder.getOrderNum() + " orders for a reward of GHS" + driverActivityOrder.getMoney() : + "Aujourd’hui de " + driverActivityOrder.getStart() + " à " + driverActivityOrder.getEnd() + ", complétez " + driverActivityOrder.getOrderNum() + " commandes pour une récompense de GHS" + driverActivityOrder.getMoney()); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date start = sdf.parse(sdf1.format(time) + " " + driverActivityOrder.getStart() + ":00"); + Date end = sdf.parse(sdf1.format(time) + " " + driverActivityOrder.getEnd() + ":59"); + Integer integer = orderService.queryOrderNum(uid, start, end); + activityWarpper.setCarryOut(integer.compareTo(driverActivityOrder.getOrderNum()) > 0 ? driverActivityOrder.getOrderNum() + "/" + driverActivityOrder.getOrderNum() : integer + "/" + driverActivityOrder.getOrderNum()); + break; + } + list.add(activityWarpper); + } + return list; + } + /** @@ -1766,6 +2023,7 @@ for(Map<String, Object> map : query){ for(Driver driver : drivers){ DriverActivityHistory driverActivityHistory = new DriverActivityHistory(); + driverActivityHistory.setDriverActivityId(Integer.valueOf(map.get("driverActivityId").toString())); driverActivityHistory.setActivityId(Integer.valueOf(String.valueOf(map.get("id")))); driverActivityHistory.setType(1); driverActivityHistory.setDriverId(driver.getId()); @@ -1776,104 +2034,115 @@ driverActivityHistoryMapper.insert(driverActivityHistory); if(ToolUtil.isNotEmpty(driver.getEmail())) { - String path1 = templatePath + "driver/index.html"; - Document document1 = Jsoup.parse(new File(path1), "UTF-8"); - if (1 == language) { - document1.getElementById("english").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite").remove(); - document1.getElementById("user").remove(); - document1.getElementById("settle").remove(); - document1.getElementById("pass").remove(); - document1.getElementById("email").remove(); - document1.getElementById("bill").remove(); - document1.getElementById("reward").remove(); - document1.getElementById("driverAudit").remove(); - document1.getElementById("carAudit").remove(); - - document1.getElementsByTag("title").get(0).text("邀请司机奖励(活动)"); - Element rewardToday_user = document1.getElementById("rewardToday_user"); - rewardToday_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday_award = document1.getElementById("rewardToday_award"); - rewardToday_award.text("奖金 GHS" + driverActivityHistory.getMoney()); - Element rewardToday_content = document1.getElementById("rewardToday_content"); - rewardToday_content.text("邀请司机注册即可获得奖励。\n注意此活动是有时间限制的,详情请查看I-GO平台。"); - } - if (2 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite1").remove(); - document1.getElementById("user1").remove(); - document1.getElementById("settle1").remove(); - document1.getElementById("pass1").remove(); - document1.getElementById("email1").remove(); - document1.getElementById("bill1").remove(); - document1.getElementById("reward1").remove(); - document1.getElementById("driverAudit1").remove(); - document1.getElementById("carAudit1").remove(); - - document1.getElementsByTag("title").get(0).text("Invite drivers and earn"); - Element rewardToday1_user = document1.getElementById("rewardToday1_user"); - rewardToday1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday1_award = document1.getElementById("rewardToday1_award"); - rewardToday1_award.text("GHS " + driverActivityHistory.getMoney() + " BONUS"); - Element rewardToday1_content = document1.getElementById("rewardToday1_content"); - rewardToday1_content.text("Get a bonus on I-GO today.\nInvite drivers to register to get the bonus.\nNote that this is a limited-time offer. Check your app for more details."); - } - if (3 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("english").remove(); - document1.getElementById("invite2").remove(); - document1.getElementById("user2").remove(); - document1.getElementById("settle2").remove(); - document1.getElementById("pass2").remove(); - document1.getElementById("email2").remove(); - document1.getElementById("bill2").remove(); - document1.getElementById("reward2").remove(); - document1.getElementById("driverAudit2").remove(); - document1.getElementById("carAudit2").remove(); - - document1.getElementsByTag("title").get(0).text("Invitez des chauffeurs et gagnez de l’argent"); - Element rewardToday2_user = document1.getElementById("rewardToday2_user"); - rewardToday2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday2_award = document1.getElementById("rewardToday2_award"); - rewardToday2_award.text("Bonus GHS " + driverActivityHistory.getMoney()); - Element rewardToday2_content = document1.getElementById("rewardToday2_content"); - rewardToday2_content.text("Obtenez un bonus sur I-GO dès aujourd’hui.\nInvitez les chauffeurs à s’inscrire pour obtenir le bonus.\nNotez qu’il s’agit d’une offre d’une durée limitée. Consultez votre application pour plus de détails."); - } - EmailUtil.send(driver.getEmail(), language == 1 ? "邀请司机奖励(活动)" : language == 2 ? "Invite drivers and earn" : "Invitez des chauffeurs et gagnez de l’argent", document1.html()); - String randomString = ToolUtil.getRandomString(10); - //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); - if(!file.exists()){ - file.mkdirs(); - } - file = new File("/usr/local/nginx/html/files/html/activity_" + randomString + ".html"); - if(!file.exists()){ - file.createNewFile(); - } - FileWriter fileWriter = new FileWriter(file); - fileWriter.write(document1.html()); - fileWriter.flush(); - fileWriter.close(); - - String link ="http://182.160.16.251:81/files/html/activity_" + randomString + ".html"; - TEmail tEmail = new TEmail(); - tEmail.setLink(link); - tEmail.setUserId(driver.getId()); - tEmail.setType(2); - tEmail.setName(language == 1 ? "邀请司机奖励(活动)" : language == 2 ? "Invite drivers and earn" : "Invitez des chauffeurs et gagnez de l’argent"); - tEmail.setCreateTime(new Date()); - int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; - String week = EmailUtil.getWeek(language, i); - tEmail.setWeek(week); - boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); - if(am){ - tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); - }else { - tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); - } - emailService.insert(tEmail); + new Thread(() -> { + try { + String path1 = templatePath + "driver/index.html"; + Document document1 = null; + try { + document1 = Jsoup.parse(new File(path1), "UTF-8"); + } catch (IOException e) { + throw new RuntimeException(e); + } + if (1 == language) { + document1.getElementById("english").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite").remove(); + document1.getElementById("user").remove(); + document1.getElementById("settle").remove(); + document1.getElementById("pass").remove(); + document1.getElementById("email").remove(); + document1.getElementById("bill").remove(); + document1.getElementById("reward").remove(); + document1.getElementById("driverAudit").remove(); + document1.getElementById("carAudit").remove(); + + document1.getElementsByTag("title").get(0).text("邀请司机奖励(活动)"); + Element rewardToday_user = document1.getElementById("rewardToday_user"); + rewardToday_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday_award = document1.getElementById("rewardToday_award"); + rewardToday_award.text("奖金 GHS" + driverActivityHistory.getMoney()); + Element rewardToday_content = document1.getElementById("rewardToday_content"); + rewardToday_content.html("邀请司机注册即可获得奖励。<br/>注意此活动是有时间限制的,详情请查看I-GO平台。"); + } + if (2 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite1").remove(); + document1.getElementById("user1").remove(); + document1.getElementById("settle1").remove(); + document1.getElementById("pass1").remove(); + document1.getElementById("email1").remove(); + document1.getElementById("bill1").remove(); + document1.getElementById("reward1").remove(); + document1.getElementById("driverAudit1").remove(); + document1.getElementById("carAudit1").remove(); + + document1.getElementsByTag("title").get(0).text("Invite drivers and earn"); + Element rewardToday1_user = document1.getElementById("rewardToday1_user"); + rewardToday1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday1_award = document1.getElementById("rewardToday1_award"); + rewardToday1_award.text("GHS " + driverActivityHistory.getMoney() + " BONUS"); + Element rewardToday1_content = document1.getElementById("rewardToday1_content"); + rewardToday1_content.html("Invite drivers to register to get the bonus.<br/>Note that this is a limited-time offer. Check your app for more details."); + } + if (3 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("english").remove(); + document1.getElementById("invite2").remove(); + document1.getElementById("user2").remove(); + document1.getElementById("settle2").remove(); + document1.getElementById("pass2").remove(); + document1.getElementById("email2").remove(); + document1.getElementById("bill2").remove(); + document1.getElementById("reward2").remove(); + document1.getElementById("driverAudit2").remove(); + document1.getElementById("carAudit2").remove(); + + document1.getElementsByTag("title").get(0).text("Invitez des chauffeurs et gagnez de l’argent"); + Element rewardToday2_user = document1.getElementById("rewardToday2_user"); + rewardToday2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday2_award = document1.getElementById("rewardToday2_award"); + rewardToday2_award.text("Bonus GHS " + driverActivityHistory.getMoney()); + Element rewardToday2_content = document1.getElementById("rewardToday2_content"); + rewardToday2_content.html("Invitez les chauffeurs à s’inscrire pour obtenir le bonus.<br/>Notez qu’il s’agit d’une offre d’une durée limitée. Consultez votre application pour plus de détails."); + } + EmailUtil.send(driver.getEmail(), language == 1 ? "邀请司机奖励(活动)" : language == 2 ? "Invite drivers and earn" : "Invitez des chauffeurs et gagnez de l’argent", document1.html()); + String randomString = ToolUtil.getRandomString(10); + //开始生成pdf收据和html收据 + File file = new File("/home/igotechgh/nginx/html/files/html/"); + if(!file.exists()){ + file.mkdirs(); + } + file = new File("/home/igotechgh/nginx/html/files/html/activity_" + randomString + ".html"); + if(!file.exists()){ + file.createNewFile(); + } + FileWriter fileWriter = new FileWriter(file); + fileWriter.write(document1.html()); + fileWriter.flush(); + fileWriter.close(); + + String link ="https://igo.i-go.group/files/html/activity_" + randomString + ".html"; + TEmail tEmail = new TEmail(); + tEmail.setLink(link); + tEmail.setUserId(driver.getId()); + tEmail.setType(2); + tEmail.setName(language == 1 ? "邀请司机奖励(活动)" : language == 2 ? "Invite drivers and earn" : "Invitez des chauffeurs et gagnez de l’argent"); + tEmail.setCreateTime(new Date()); + int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; + String week = EmailUtil.getWeek(language, i); + tEmail.setWeek(week); + boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); + if(am){ + tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); + }else { + tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); + } + emailService.insert(tEmail); + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); } } } @@ -1882,6 +2151,7 @@ for(Map<String, Object> map : query){ for(Driver driver : drivers){ DriverActivityHistory driverActivityHistory = new DriverActivityHistory(); + driverActivityHistory.setDriverActivityId(Integer.valueOf(map.get("driverActivityId").toString())); driverActivityHistory.setActivityId(Integer.valueOf(String.valueOf(map.get("id")))); driverActivityHistory.setType(2); driverActivityHistory.setDriverId(driver.getId()); @@ -1892,104 +2162,110 @@ driverActivityHistoryMapper.insert(driverActivityHistory); if(ToolUtil.isNotEmpty(driver.getEmail())) { - String path1 = templatePath + "driver/index.html"; - Document document1 = Jsoup.parse(new File(path1), "UTF-8"); - if (1 == language) { - document1.getElementById("english").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite").remove(); - document1.getElementById("user").remove(); - document1.getElementById("settle").remove(); - document1.getElementById("pass").remove(); - document1.getElementById("email").remove(); - document1.getElementById("bill").remove(); - document1.getElementById("reward").remove(); - document1.getElementById("driverAudit").remove(); - document1.getElementById("carAudit").remove(); - - document1.getElementsByTag("title").get(0).text("邀请用户奖励(活动)"); - Element rewardToday_user = document1.getElementById("rewardToday_user"); - rewardToday_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday_award = document1.getElementById("rewardToday_award"); - rewardToday_award.text("奖金 GHS" + driverActivityHistory.getMoney()); - Element rewardToday_content = document1.getElementById("rewardToday_content"); - rewardToday_content.text("邀请用户注册即可获得奖励。\n 注意此活动是有时间限制的,详情请查看I-GO平台。"); - } - if (2 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite1").remove(); - document1.getElementById("user1").remove(); - document1.getElementById("settle1").remove(); - document1.getElementById("pass1").remove(); - document1.getElementById("email1").remove(); - document1.getElementById("bill1").remove(); - document1.getElementById("reward1").remove(); - document1.getElementById("driverAudit1").remove(); - document1.getElementById("carAudit1").remove(); - - document1.getElementsByTag("title").get(0).text("Invite users and earn"); - Element rewardToday1_user = document1.getElementById("rewardToday1_user"); - rewardToday1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday1_award = document1.getElementById("rewardToday1_award"); - rewardToday1_award.text("GHS " + driverActivityHistory.getMoney() + " BONUS"); - Element rewardToday1_content = document1.getElementById("rewardToday1_content"); - rewardToday1_content.text("Get a bonus on I-GO today.\nInvite users to register to get the bonus.\nNote that this is a limited-time offer. Check your app for more details."); - } - if (3 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("english").remove(); - document1.getElementById("invite2").remove(); - document1.getElementById("user2").remove(); - document1.getElementById("settle2").remove(); - document1.getElementById("pass2").remove(); - document1.getElementById("email2").remove(); - document1.getElementById("bill2").remove(); - document1.getElementById("reward2").remove(); - document1.getElementById("driverAudit2").remove(); - document1.getElementById("carAudit2").remove(); - - document1.getElementsByTag("title").get(0).text("Invitez des utilisateurs et gagnez de l’argent"); - Element rewardToday2_user = document1.getElementById("rewardToday2_user"); - rewardToday2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday2_award = document1.getElementById("rewardToday2_award"); - rewardToday2_award.text("Bonus GHS " + driverActivityHistory.getMoney()); - Element rewardToday2_content = document1.getElementById("rewardToday2_content"); - rewardToday2_content.text("Obtenez un bonus sur I-GO dès aujourd’hui.\nInvitez les utilisateurs à s’inscrire pour obtenir le bonus.\nNotez qu’il s’agit d’une offre d’une durée limitée. Consultez votre application pour plus de détails."); - } - EmailUtil.send(driver.getEmail(), language == 1 ? "邀请用户奖励(活动)" : language == 2 ? "Invite users and earn" : "Invitez des utilisateurs et gagnez de l’argent", document1.html()); - String randomString = ToolUtil.getRandomString(10); - //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); - if(!file.exists()){ - file.mkdirs(); - } - file = new File("/usr/local/nginx/html/files/html/activity_" + randomString + ".html"); - if(!file.exists()){ - file.createNewFile(); - } - FileWriter fileWriter = new FileWriter(file); - fileWriter.write(document1.html()); - fileWriter.flush(); - fileWriter.close(); - - String link ="http://182.160.16.251:81/files/html/activity_" + randomString + ".html"; - TEmail tEmail = new TEmail(); - tEmail.setLink(link); - tEmail.setUserId(driver.getId()); - tEmail.setType(2); - tEmail.setName(language == 1 ? "邀请用户奖励(活动)" : language == 2 ? "Invite users and earn" : "Invitez des utilisateurs et gagnez de l’argent"); - tEmail.setCreateTime(new Date()); - int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; - String week = EmailUtil.getWeek(language, i); - tEmail.setWeek(week); - boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); - if(am){ - tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); - }else { - tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); - } - emailService.insert(tEmail); + new Thread(() -> { + try { + String path1 = templatePath + "driver/index.html"; + Document document1 = Jsoup.parse(new File(path1), "UTF-8"); + if (1 == language) { + document1.getElementById("english").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite").remove(); + document1.getElementById("user").remove(); + document1.getElementById("settle").remove(); + document1.getElementById("pass").remove(); + document1.getElementById("email").remove(); + document1.getElementById("bill").remove(); + document1.getElementById("reward").remove(); + document1.getElementById("driverAudit").remove(); + document1.getElementById("carAudit").remove(); + + document1.getElementsByTag("title").get(0).text("邀请用户奖励(活动)"); + Element rewardToday_user = document1.getElementById("rewardToday_user"); + rewardToday_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday_award = document1.getElementById("rewardToday_award"); + rewardToday_award.text("奖金 GHS" + driverActivityHistory.getMoney()); + Element rewardToday_content = document1.getElementById("rewardToday_content"); + rewardToday_content.html("邀请用户注册即可获得奖励。<br/> 注意此活动是有时间限制的,详情请查看I-GO平台。"); + } + if (2 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite1").remove(); + document1.getElementById("user1").remove(); + document1.getElementById("settle1").remove(); + document1.getElementById("pass1").remove(); + document1.getElementById("email1").remove(); + document1.getElementById("bill1").remove(); + document1.getElementById("reward1").remove(); + document1.getElementById("driverAudit1").remove(); + document1.getElementById("carAudit1").remove(); + + document1.getElementsByTag("title").get(0).text("Invite users and earn"); + Element rewardToday1_user = document1.getElementById("rewardToday1_user"); + rewardToday1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday1_award = document1.getElementById("rewardToday1_award"); + rewardToday1_award.text("GHS " + driverActivityHistory.getMoney() + " BONUS"); + Element rewardToday1_content = document1.getElementById("rewardToday1_content"); + rewardToday1_content.html("Invite users to register to get the bonus.<br/>Note that this is a limited-time offer. Check your app for more details."); + } + if (3 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("english").remove(); + document1.getElementById("invite2").remove(); + document1.getElementById("user2").remove(); + document1.getElementById("settle2").remove(); + document1.getElementById("pass2").remove(); + document1.getElementById("email2").remove(); + document1.getElementById("bill2").remove(); + document1.getElementById("reward2").remove(); + document1.getElementById("driverAudit2").remove(); + document1.getElementById("carAudit2").remove(); + + document1.getElementsByTag("title").get(0).text("Invitez des utilisateurs et gagnez de l’argent"); + Element rewardToday2_user = document1.getElementById("rewardToday2_user"); + rewardToday2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday2_award = document1.getElementById("rewardToday2_award"); + rewardToday2_award.text("Bonus GHS " + driverActivityHistory.getMoney()); + Element rewardToday2_content = document1.getElementById("rewardToday2_content"); + rewardToday2_content.html("Invitez les utilisateurs à s’inscrire pour obtenir le bonus.<br/>Notez qu’il s’agit d’une offre d’une durée limitée. Consultez votre application pour plus de détails."); + } + EmailUtil.send(driver.getEmail(), language == 1 ? "邀请用户奖励(活动)" : language == 2 ? "Invite users and earn" : "Invitez des utilisateurs et gagnez de l’argent", document1.html()); + String randomString = ToolUtil.getRandomString(10); + //开始生成pdf收据和html收据 + File file = new File("/home/igotechgh/nginx/html/files/html/"); + if(!file.exists()){ + file.mkdirs(); + } + file = new File("/home/igotechgh/nginx/html/files/html/activity_" + randomString + ".html"); + if(!file.exists()){ + file.createNewFile(); + } + FileWriter fileWriter = new FileWriter(file); + fileWriter.write(document1.html()); + fileWriter.flush(); + fileWriter.close(); + + String link ="https://igo.i-go.group/files/html/activity_" + randomString + ".html"; + TEmail tEmail = new TEmail(); + tEmail.setLink(link); + tEmail.setUserId(driver.getId()); + tEmail.setType(2); + tEmail.setName(language == 1 ? "邀请用户奖励(活动)" : language == 2 ? "Invite users and earn" : "Invitez des utilisateurs et gagnez de l’argent"); + tEmail.setCreateTime(new Date()); + int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; + String week = EmailUtil.getWeek(language, i); + tEmail.setWeek(week); + boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); + if(am){ + tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); + }else { + tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); + } + emailService.insert(tEmail); + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); } } } @@ -1999,6 +2275,7 @@ DriverActivityOnline driverActivityOnline = driverActivityOnlineMapper.selectById(Integer.valueOf(String.valueOf(map.get("id")))); for(Driver driver : drivers){ DriverActivityHistory driverActivityHistory = new DriverActivityHistory(); + driverActivityHistory.setDriverActivityId(Integer.valueOf(map.get("driverActivityId").toString())); driverActivityHistory.setActivityId(Integer.valueOf(String.valueOf(map.get("id")))); driverActivityHistory.setType(3); driverActivityHistory.setDriverId(driver.getId()); @@ -2009,104 +2286,110 @@ driverActivityHistoryMapper.insert(driverActivityHistory); if(ToolUtil.isNotEmpty(driver.getEmail())) { - String path1 = templatePath + "driver/index.html"; - Document document1 = Jsoup.parse(new File(path1), "UTF-8"); - if (1 == language) { - document1.getElementById("english").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite").remove(); - document1.getElementById("user").remove(); - document1.getElementById("settle").remove(); - document1.getElementById("pass").remove(); - document1.getElementById("email").remove(); - document1.getElementById("bill").remove(); - document1.getElementById("reward").remove(); - document1.getElementById("driverAudit").remove(); - document1.getElementById("carAudit").remove(); - - document1.getElementsByTag("title").get(0).text("在线时长奖励(活动)"); - Element rewardToday_user = document1.getElementById("rewardToday_user"); - rewardToday_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday_award = document1.getElementById("rewardToday_award"); - rewardToday_award.text("奖金 GHS" + driverActivityHistory.getMoney()); - Element rewardToday_content = document1.getElementById("rewardToday_content"); - rewardToday_content.text("今日累计在线" + driverActivityOnline.getOnline() + "小时即可活动奖励。\n 注意此活动是有时间限制的,详情请查看I-GO平台。"); - } - if (2 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite1").remove(); - document1.getElementById("user1").remove(); - document1.getElementById("settle1").remove(); - document1.getElementById("pass1").remove(); - document1.getElementById("email1").remove(); - document1.getElementById("bill1").remove(); - document1.getElementById("reward1").remove(); - document1.getElementById("driverAudit1").remove(); - document1.getElementById("carAudit1").remove(); - - document1.getElementsByTag("title").get(0).text("Online-duration reward activity"); - Element rewardToday1_user = document1.getElementById("rewardToday1_user"); - rewardToday1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday1_award = document1.getElementById("rewardToday1_award"); - rewardToday1_award.text("GHS " + driverActivityHistory.getMoney() + " BONUS"); - Element rewardToday1_content = document1.getElementById("rewardToday1_content"); - rewardToday1_content.text("Get a bonus for driving on I-GO today.\nStay online for " + driverActivityOnline.getOnline() + " hours to get the bonus.\nNote that this is a limited-time offer. Check your app for more details."); - } - if (3 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("english").remove(); - document1.getElementById("invite2").remove(); - document1.getElementById("user2").remove(); - document1.getElementById("settle2").remove(); - document1.getElementById("pass2").remove(); - document1.getElementById("email2").remove(); - document1.getElementById("bill2").remove(); - document1.getElementById("reward2").remove(); - document1.getElementById("driverAudit2").remove(); - document1.getElementById("carAudit2").remove(); - - document1.getElementsByTag("title").get(0).text("Activité de récompense en ligne"); - Element rewardToday2_user = document1.getElementById("rewardToday2_user"); - rewardToday2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday2_award = document1.getElementById("rewardToday2_award"); - rewardToday2_award.text("Bonus GHS " + driverActivityHistory.getMoney()); - Element rewardToday2_content = document1.getElementById("rewardToday2_content"); - rewardToday2_content.text("Obtenez un bonus pour conduire sur I-GO dès aujourd’hui.\nRestez en ligne pendant " + driverActivityOnline.getOnline() + " heures pour obtenir le bonus.\nNotez qu’il s’agit d’une offre d’une durée limitée. Consultez votre application pour plus de détails."); - } - EmailUtil.send(driver.getEmail(), language == 1 ? "在线时长奖励(活动)" : language == 2 ? "Online-duration reward activity" : "Activité de récompense en ligne", document1.html()); - String randomString = ToolUtil.getRandomString(10); - //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); - if(!file.exists()){ - file.mkdirs(); - } - file = new File("/usr/local/nginx/html/files/html/activity_" + randomString + ".html"); - if(!file.exists()){ - file.createNewFile(); - } - FileWriter fileWriter = new FileWriter(file); - fileWriter.write(document1.html()); - fileWriter.flush(); - fileWriter.close(); - - String link ="http://182.160.16.251:81/files/html/activity_" + randomString + ".html"; - TEmail tEmail = new TEmail(); - tEmail.setLink(link); - tEmail.setUserId(driver.getId()); - tEmail.setType(2); - tEmail.setName(language == 1 ? "在线时长奖励(活动)" : language == 2 ? "Online-duration reward activity" : "Activité de récompense en ligne"); - tEmail.setCreateTime(new Date()); - int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; - String week = EmailUtil.getWeek(language, i); - tEmail.setWeek(week); - boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); - if(am){ - tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); - }else { - tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); - } - emailService.insert(tEmail); + new Thread(() -> { + try { + String path1 = templatePath + "driver/index.html"; + Document document1 = Jsoup.parse(new File(path1), "UTF-8"); + if (1 == language) { + document1.getElementById("english").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite").remove(); + document1.getElementById("user").remove(); + document1.getElementById("settle").remove(); + document1.getElementById("pass").remove(); + document1.getElementById("email").remove(); + document1.getElementById("bill").remove(); + document1.getElementById("reward").remove(); + document1.getElementById("driverAudit").remove(); + document1.getElementById("carAudit").remove(); + + document1.getElementsByTag("title").get(0).text("在线时长奖励(活动)"); + Element rewardToday_user = document1.getElementById("rewardToday_user"); + rewardToday_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday_award = document1.getElementById("rewardToday_award"); + rewardToday_award.text("奖金 GHS" + driverActivityHistory.getMoney()); + Element rewardToday_content = document1.getElementById("rewardToday_content"); + rewardToday_content.html("今日累计在线" + driverActivityOnline.getOnline() + "小时即可活动奖励。<br/> 注意此活动是有时间限制的,详情请查看I-GO平台。"); + } + if (2 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite1").remove(); + document1.getElementById("user1").remove(); + document1.getElementById("settle1").remove(); + document1.getElementById("pass1").remove(); + document1.getElementById("email1").remove(); + document1.getElementById("bill1").remove(); + document1.getElementById("reward1").remove(); + document1.getElementById("driverAudit1").remove(); + document1.getElementById("carAudit1").remove(); + + document1.getElementsByTag("title").get(0).text("Online-duration reward activity"); + Element rewardToday1_user = document1.getElementById("rewardToday1_user"); + rewardToday1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday1_award = document1.getElementById("rewardToday1_award"); + rewardToday1_award.text("GHS " + driverActivityHistory.getMoney() + " BONUS"); + Element rewardToday1_content = document1.getElementById("rewardToday1_content"); + rewardToday1_content.html("Stay online for " + driverActivityOnline.getOnline() + " hours to get the bonus.<br/>Note that this is a limited-time offer. Check your app for more details."); + } + if (3 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("english").remove(); + document1.getElementById("invite2").remove(); + document1.getElementById("user2").remove(); + document1.getElementById("settle2").remove(); + document1.getElementById("pass2").remove(); + document1.getElementById("email2").remove(); + document1.getElementById("bill2").remove(); + document1.getElementById("reward2").remove(); + document1.getElementById("driverAudit2").remove(); + document1.getElementById("carAudit2").remove(); + + document1.getElementsByTag("title").get(0).text("Activité de récompense en ligne"); + Element rewardToday2_user = document1.getElementById("rewardToday2_user"); + rewardToday2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday2_award = document1.getElementById("rewardToday2_award"); + rewardToday2_award.text("Bonus GHS " + driverActivityHistory.getMoney()); + Element rewardToday2_content = document1.getElementById("rewardToday2_content"); + rewardToday2_content.html("Restez en ligne pendant " + driverActivityOnline.getOnline() + " heures pour obtenir le bonus.<br/>Notez qu’il s’agit d’une offre d’une durée limitée. Consultez votre application pour plus de détails."); + } + EmailUtil.send(driver.getEmail(), language == 1 ? "在线时长奖励(活动)" : language == 2 ? "Online-duration reward activity" : "Activité de récompense en ligne", document1.html()); + String randomString = ToolUtil.getRandomString(10); + //开始生成pdf收据和html收据 + File file = new File("/home/igotechgh/nginx/html/files/html/"); + if(!file.exists()){ + file.mkdirs(); + } + file = new File("/home/igotechgh/nginx/html/files/html/activity_" + randomString + ".html"); + if(!file.exists()){ + file.createNewFile(); + } + FileWriter fileWriter = new FileWriter(file); + fileWriter.write(document1.html()); + fileWriter.flush(); + fileWriter.close(); + + String link ="https://igo.i-go.group/files/html/activity_" + randomString + ".html"; + TEmail tEmail = new TEmail(); + tEmail.setLink(link); + tEmail.setUserId(driver.getId()); + tEmail.setType(2); + tEmail.setName(language == 1 ? "在线时长奖励(活动)" : language == 2 ? "Online-duration reward activity" : "Activité de récompense en ligne"); + tEmail.setCreateTime(new Date()); + int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; + String week = EmailUtil.getWeek(language, i); + tEmail.setWeek(week); + boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); + if(am){ + tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); + }else { + tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); + } + emailService.insert(tEmail); + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); } } } @@ -2116,6 +2399,7 @@ DriverActivityOrder driverActivityOrder = driverActivityOrderMapper.selectById(Integer.valueOf(String.valueOf(map.get("id")))); for(Driver driver : drivers){ DriverActivityHistory driverActivityHistory = new DriverActivityHistory(); + driverActivityHistory.setDriverActivityId(Integer.valueOf(map.get("driverActivityId").toString())); driverActivityHistory.setActivityId(Integer.valueOf(String.valueOf(map.get("id")))); driverActivityHistory.setType(4); driverActivityHistory.setDriverId(driver.getId()); @@ -2126,104 +2410,110 @@ driverActivityHistoryMapper.insert(driverActivityHistory); if(ToolUtil.isNotEmpty(driver.getEmail())) { - String path1 = templatePath + "driver/index.html"; - Document document1 = Jsoup.parse(new File(path1), "UTF-8"); - if (1 == language) { - document1.getElementById("english").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite").remove(); - document1.getElementById("user").remove(); - document1.getElementById("settle").remove(); - document1.getElementById("pass").remove(); - document1.getElementById("email").remove(); - document1.getElementById("bill").remove(); - document1.getElementById("reward").remove(); - document1.getElementById("driverAudit").remove(); - document1.getElementById("carAudit").remove(); - - document1.getElementsByTag("title").get(0).text("累计接单奖励(活动)"); - Element rewardToday_user = document1.getElementById("rewardToday_user"); - rewardToday_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday_award = document1.getElementById("rewardToday_award"); - rewardToday_award.text("奖金 GHS" + driverActivityHistory.getMoney()); - Element rewardToday_content = document1.getElementById("rewardToday_content"); - rewardToday_content.text("今日累计完成" + driverActivityOrder.getOrderNum() + "单即可活动奖励。\n 注意此活动是有时间限制的,详情请查看I-GO平台。"); - } - if (2 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite1").remove(); - document1.getElementById("user1").remove(); - document1.getElementById("settle1").remove(); - document1.getElementById("pass1").remove(); - document1.getElementById("email1").remove(); - document1.getElementById("bill1").remove(); - document1.getElementById("reward1").remove(); - document1.getElementById("driverAudit1").remove(); - document1.getElementById("carAudit1").remove(); - - document1.getElementsByTag("title").get(0).text("Cumulative order activity"); - Element rewardToday1_user = document1.getElementById("rewardToday1_user"); - rewardToday1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday1_award = document1.getElementById("rewardToday1_award"); - rewardToday1_award.text("GHS " + driverActivityHistory.getMoney() + " BONUS"); - Element rewardToday1_content = document1.getElementById("rewardToday1_content"); - rewardToday1_content.text("Get a bonus for driving on I-GO today.\nStay online and complete " + driverActivityOrder.getOrderNum() + " trips to get the bonus.\nNote that this is a limited-time offer. Check your app for more details."); - } - if (3 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("english").remove(); - document1.getElementById("invite2").remove(); - document1.getElementById("user2").remove(); - document1.getElementById("settle2").remove(); - document1.getElementById("pass2").remove(); - document1.getElementById("email2").remove(); - document1.getElementById("bill2").remove(); - document1.getElementById("reward2").remove(); - document1.getElementById("driverAudit2").remove(); - document1.getElementById("carAudit2").remove(); - - document1.getElementsByTag("title").get(0).text("Activité cumulée des commandes"); - Element rewardToday2_user = document1.getElementById("rewardToday2_user"); - rewardToday2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element rewardToday2_award = document1.getElementById("rewardToday2_award"); - rewardToday2_award.text("Bonus GHS " + driverActivityHistory.getMoney()); - Element rewardToday2_content = document1.getElementById("rewardToday2_content"); - rewardToday2_content.text("Obtenez un bonus pour conduire sur I-GO dès aujourd’hui.\nRestez en ligne et effectuez " + driverActivityOrder.getOrderNum() + " trajets pour obtenir le bonus.\nNotez qu’il s’agit d’une offre d’une durée limitée. Consultez votre application pour plus de détails."); - } - EmailUtil.send(driver.getEmail(), language == 1 ? "累计接单奖励(活动)" : language == 2 ? "Cumulative order activity" : "Activité cumulée des commandes", document1.html()); - String randomString = ToolUtil.getRandomString(10); - //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); - if(!file.exists()){ - file.mkdirs(); - } - file = new File("/usr/local/nginx/html/files/html/activity_" + randomString + ".html"); - if(!file.exists()){ - file.createNewFile(); - } - FileWriter fileWriter = new FileWriter(file); - fileWriter.write(document1.html()); - fileWriter.flush(); - fileWriter.close(); - - String link ="http://182.160.16.251:81/files/html/activity_" + randomString + ".html"; - TEmail tEmail = new TEmail(); - tEmail.setLink(link); - tEmail.setUserId(driver.getId()); - tEmail.setType(2); - tEmail.setName(language == 1 ? "累计接单奖励(活动)" : language == 2 ? "Cumulative order activity" : "Activité cumulée des commandes"); - tEmail.setCreateTime(new Date()); - int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; - String week = EmailUtil.getWeek(language, i); - tEmail.setWeek(week); - boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); - if(am){ - tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); - }else { - tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); - } - emailService.insert(tEmail); + new Thread(() -> { + try { + String path1 = templatePath + "driver/index.html"; + Document document1 = Jsoup.parse(new File(path1), "UTF-8"); + if (1 == language) { + document1.getElementById("english").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite").remove(); + document1.getElementById("user").remove(); + document1.getElementById("settle").remove(); + document1.getElementById("pass").remove(); + document1.getElementById("email").remove(); + document1.getElementById("bill").remove(); + document1.getElementById("reward").remove(); + document1.getElementById("driverAudit").remove(); + document1.getElementById("carAudit").remove(); + + document1.getElementsByTag("title").get(0).text("累计接单奖励(活动)"); + Element rewardToday_user = document1.getElementById("rewardToday_user"); + rewardToday_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday_award = document1.getElementById("rewardToday_award"); + rewardToday_award.text("奖金 GHS" + driverActivityHistory.getMoney()); + Element rewardToday_content = document1.getElementById("rewardToday_content"); + rewardToday_content.html("今日累计完成" + driverActivityOrder.getOrderNum() + "单即可活动奖励。<br/> 注意此活动是有时间限制的,详情请查看I-GO平台。"); + } + if (2 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite1").remove(); + document1.getElementById("user1").remove(); + document1.getElementById("settle1").remove(); + document1.getElementById("pass1").remove(); + document1.getElementById("email1").remove(); + document1.getElementById("bill1").remove(); + document1.getElementById("reward1").remove(); + document1.getElementById("driverAudit1").remove(); + document1.getElementById("carAudit1").remove(); + + document1.getElementsByTag("title").get(0).text("Cumulative order activity"); + Element rewardToday1_user = document1.getElementById("rewardToday1_user"); + rewardToday1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday1_award = document1.getElementById("rewardToday1_award"); + rewardToday1_award.text("GHS " + driverActivityHistory.getMoney() + " BONUS"); + Element rewardToday1_content = document1.getElementById("rewardToday1_content"); + rewardToday1_content.html("Stay online and complete " + driverActivityOrder.getOrderNum() + " trips to get the bonus.<br/>Note that this is a limited-time offer. Check your app for more details."); + } + if (3 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("english").remove(); + document1.getElementById("invite2").remove(); + document1.getElementById("user2").remove(); + document1.getElementById("settle2").remove(); + document1.getElementById("pass2").remove(); + document1.getElementById("email2").remove(); + document1.getElementById("bill2").remove(); + document1.getElementById("reward2").remove(); + document1.getElementById("driverAudit2").remove(); + document1.getElementById("carAudit2").remove(); + + document1.getElementsByTag("title").get(0).text("Activité cumulée des commandes"); + Element rewardToday2_user = document1.getElementById("rewardToday2_user"); + rewardToday2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element rewardToday2_award = document1.getElementById("rewardToday2_award"); + rewardToday2_award.text("Bonus GHS " + driverActivityHistory.getMoney()); + Element rewardToday2_content = document1.getElementById("rewardToday2_content"); + rewardToday2_content.html("Restez en ligne et effectuez " + driverActivityOrder.getOrderNum() + " trajets pour obtenir le bonus.<br/>Notez qu’il s’agit d’une offre d’une durée limitée. Consultez votre application pour plus de détails."); + } + EmailUtil.send(driver.getEmail(), language == 1 ? "累计接单奖励(活动)" : language == 2 ? "Cumulative order activity" : "Activité cumulée des commandes", document1.html()); + String randomString = ToolUtil.getRandomString(10); + //开始生成pdf收据和html收据 + File file = new File("/home/igotechgh/nginx/html/files/html/"); + if(!file.exists()){ + file.mkdirs(); + } + file = new File("/home/igotechgh/nginx/html/files/html/activity_" + randomString + ".html"); + if(!file.exists()){ + file.createNewFile(); + } + FileWriter fileWriter = new FileWriter(file); + fileWriter.write(document1.html()); + fileWriter.flush(); + fileWriter.close(); + + String link ="https://igo.i-go.group/files/html/activity_" + randomString + ".html"; + TEmail tEmail = new TEmail(); + tEmail.setLink(link); + tEmail.setUserId(driver.getId()); + tEmail.setType(2); + tEmail.setName(language == 1 ? "累计接单奖励(活动)" : language == 2 ? "Cumulative order activity" : "Activité cumulée des commandes"); + tEmail.setCreateTime(new Date()); + int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; + String week = EmailUtil.getWeek(language, i); + tEmail.setWeek(week); + boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); + if(am){ + tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); + }else { + tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); + } + emailService.insert(tEmail); + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); } } } @@ -2238,7 +2528,6 @@ @Override public void taskMinute() throws Exception { Map<String, Date> date = dateUtil.getStartAndEndDate(new Date()); - Integer language = 2; //在线时长 List<DriverActivityHistory> list = driverActivityHistoryMapper.queryList(null, 3, 1, date.get("startTime"), date.get("endTime")); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); @@ -2247,120 +2536,131 @@ if(null == dao){ continue; } - Long duration = Long.valueOf(dao.getOnline() * 3600); - List<DriverOnline> driverOnlines = driverOnlineMapper.queryList(sdf.format(new Date()), duration); - for (DriverOnline driverOnline : driverOnlines) { - if(dah.getDriverId().compareTo(driverOnline.getDriverId()) == 0){ - dah.setCarryOut(2);//完成状态 - driverActivityHistoryMapper.updateById(dah); - //修改余额 - Driver driver = this.selectById(dah.getDriverId()); - driver.setActivityMoney(new BigDecimal(null != driver.getActivityMoney() ? driver.getActivityMoney() : 0) - .add(new BigDecimal(dah.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); - driver.setLaveActivityMoney(new BigDecimal(null != driver.getLaveActivityMoney() ? driver.getLaveActivityMoney() : 0) - .add(new BigDecimal(dah.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); - driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0) - .add(new BigDecimal(dah.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); - this.updateById(driver); - - //添加收入记录 - incomeService.saveData(2, driverOnline.getDriverId(), 1, dao.getId(), null, dah.getMoney()); - - - if(ToolUtil.isNotEmpty(driver.getEmail())) { - String path1 = templatePath + "driver/index.html"; - Document document1 = Jsoup.parse(new File(path1), "UTF-8"); - if (1 == language) { - document1.getElementById("english").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite").remove(); - document1.getElementById("user").remove(); - document1.getElementById("settle").remove(); - document1.getElementById("pass").remove(); - document1.getElementById("email").remove(); - document1.getElementById("bill").remove(); - document1.getElementById("rewardToday").remove(); - document1.getElementById("driverAudit").remove(); - document1.getElementById("carAudit").remove(); - - document1.getElementsByTag("title").get(0).text("司机奖励通知"); - Element reward_user = document1.getElementById("reward_user"); - reward_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element reward_content = document1.getElementById("reward_content"); - reward_content.text("今日累计在线" + dao.getOnline() + "小时,获得奖励GHS" + dah.getMoney() + ",请查收。\n详情请查看I-GO平台。"); + Long duration = Double.valueOf(dao.getOnline() * 3600).longValue(); + List<DriverOnline> driverOnlines = driverOnlineMapper.queryList(sdf.format(new Date()), null, dah.getDriverId(), duration); + if(driverOnlines.size() > 0){ + dah.setCarryOut(2);//完成状态 + dah.setCompletionTime(new Date()); + driverActivityHistoryMapper.updateById(dah); + + redisUtil.remove("driverActivity_" + dah.getDriverId() + "_" + dah.getId()); + + //修改余额 + Driver driver = this.selectById(dah.getDriverId()); + driver.setActivityMoney(new BigDecimal(null != driver.getActivityMoney() ? driver.getActivityMoney() : 0) + .add(new BigDecimal(dah.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + driver.setLaveActivityMoney(new BigDecimal(null != driver.getLaveActivityMoney() ? driver.getLaveActivityMoney() : 0) + .add(new BigDecimal(dah.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0) + .add(new BigDecimal(dah.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + this.updateById(driver); + + //添加收入记录 + incomeService.saveData(2, dah.getDriverId(), 1, dah.getId(), null, dah.getMoney()); + + Integer language = driver.getLanguage(); + if(ToolUtil.isNotEmpty(driver.getEmail())) { + new Thread(new Runnable() { + @Override + public void run() { + try { + String path1 = templatePath + "driver/index.html"; + Document document1 = Jsoup.parse(new File(path1), "UTF-8"); + if (1 == language) { + document1.getElementById("english").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite").remove(); + document1.getElementById("user").remove(); + document1.getElementById("settle").remove(); + document1.getElementById("pass").remove(); + document1.getElementById("email").remove(); + document1.getElementById("bill").remove(); + document1.getElementById("rewardToday").remove(); + document1.getElementById("driverAudit").remove(); + document1.getElementById("carAudit").remove(); + + document1.getElementsByTag("title").get(0).text("司机奖励通知"); + Element reward_user = document1.getElementById("reward_user"); + reward_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element reward_content = document1.getElementById("reward_content"); + reward_content.html("今日累计在线" + dao.getOnline() + "小时,获得奖励GHS" + dah.getMoney() + ",请查收。<br/>详情请查看I-GO平台。"); + } + if (2 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite1").remove(); + document1.getElementById("user1").remove(); + document1.getElementById("settle1").remove(); + document1.getElementById("pass1").remove(); + document1.getElementById("email1").remove(); + document1.getElementById("bill1").remove(); + document1.getElementById("rewardToday1").remove(); + document1.getElementById("driverAudit1").remove(); + document1.getElementById("carAudit1").remove(); + + document1.getElementsByTag("title").get(0).text("Reward-driver notice"); + Element reward1_user = document1.getElementById("reward1_user"); + reward1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element reward1_content = document1.getElementById("reward1_content"); + reward1_content.html("You stayed online for " + dao.getOnline() + " hours today, and got a bonus of GHS" + dah.getMoney() + ", please check.<br/>Check your app for more details."); + } + if (3 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("english").remove(); + document1.getElementById("invite2").remove(); + document1.getElementById("user2").remove(); + document1.getElementById("settle2").remove(); + document1.getElementById("pass2").remove(); + document1.getElementById("email2").remove(); + document1.getElementById("bill2").remove(); + document1.getElementById("rewardToday2").remove(); + document1.getElementById("driverAudit2").remove(); + document1.getElementById("carAudit2").remove(); + + document1.getElementsByTag("title").get(0).text("Avis de chauffeur de récompense"); + Element reward2_user = document1.getElementById("reward2_user"); + reward2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element reward2_content = document1.getElementById("reward2_content"); + reward2_content.html("Vous êtes resté en ligne pendant " + dao.getOnline() + " heures aujourd’hui et avez obtenu un bonus de GHS" + dah.getMoney() + ", veuillez vérifier.<br/>Consultez votre application pour plus de détails."); + } + EmailUtil.send(driver.getEmail(), language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document1.html()); + String randomString = ToolUtil.getRandomString(10); + //开始生成pdf收据和html收据 + File file = new File("/home/igotechgh/nginx/html/files/html/"); + if(!file.exists()){ + file.mkdirs(); + } + file = new File("/home/igotechgh/nginx/html/files/html/rewards_" + randomString + ".html"); + if(!file.exists()){ + file.createNewFile(); + } + FileWriter fileWriter = new FileWriter(file); + fileWriter.write(document1.html()); + fileWriter.flush(); + fileWriter.close(); + + String link ="https://igo.i-go.group/files/html/rewards_" + randomString + ".html"; + TEmail tEmail = new TEmail(); + tEmail.setLink(link); + tEmail.setUserId(driver.getId()); + tEmail.setType(2); + tEmail.setName(language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense"); + tEmail.setCreateTime(new Date()); + int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; + String week = EmailUtil.getWeek(language, i); + tEmail.setWeek(week); + boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); + if(am){ + tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); + }else { + tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); + } + emailService.insert(tEmail); + }catch (Exception e){ + e.printStackTrace(); + } } - if (2 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite1").remove(); - document1.getElementById("user1").remove(); - document1.getElementById("settle1").remove(); - document1.getElementById("pass1").remove(); - document1.getElementById("email1").remove(); - document1.getElementById("bill1").remove(); - document1.getElementById("rewardToday1").remove(); - document1.getElementById("driverAudit1").remove(); - document1.getElementById("carAudit1").remove(); - - document1.getElementsByTag("title").get(0).text("Reward-driver notice"); - Element reward1_user = document1.getElementById("reward1_user"); - reward1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element reward1_content = document1.getElementById("reward1_content"); - reward1_content.text("You stayed online for " + dao.getOnline() + " hours today, and got a bonus of GHS" + dah.getMoney() + ", please check.\nCheck your app for more details."); - } - if (3 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("english").remove(); - document1.getElementById("invite2").remove(); - document1.getElementById("user2").remove(); - document1.getElementById("settle2").remove(); - document1.getElementById("pass2").remove(); - document1.getElementById("email2").remove(); - document1.getElementById("bill2").remove(); - document1.getElementById("rewardToday2").remove(); - document1.getElementById("driverAudit2").remove(); - document1.getElementById("carAudit2").remove(); - - document1.getElementsByTag("title").get(0).text("Avis de chauffeur de récompense"); - Element reward2_user = document1.getElementById("reward2_user"); - reward2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element reward2_content = document1.getElementById("reward2_content"); - reward2_content.text("Vous êtes resté en ligne pendant " + dao.getOnline() + " heures aujourd’hui et avez obtenu un bonus de GHS" + dah.getMoney() + ", veuillez vérifier.\nConsultez votre application pour plus de détails."); - } - EmailUtil.send(driver.getEmail(), language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document1.html()); - String randomString = ToolUtil.getRandomString(10); - //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); - if(!file.exists()){ - file.mkdirs(); - } - file = new File("/usr/local/nginx/html/files/html/rewards_" + randomString + ".html"); - if(!file.exists()){ - file.createNewFile(); - } - FileWriter fileWriter = new FileWriter(file); - fileWriter.write(document1.html()); - fileWriter.flush(); - fileWriter.close(); - - String link ="http://182.160.16.251:81/files/html/rewards_" + randomString + ".html"; - TEmail tEmail = new TEmail(); - tEmail.setLink(link); - tEmail.setUserId(driver.getId()); - tEmail.setType(2); - tEmail.setName(language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense"); - tEmail.setCreateTime(new Date()); - int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; - String week = EmailUtil.getWeek(language, i); - tEmail.setWeek(week); - boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); - if(am){ - tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); - }else { - tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); - } - emailService.insert(tEmail); - } + }).start(); } } } @@ -2372,6 +2672,7 @@ Integer integer = orderService.queryOrderNum(dah.getDriverId(), date.get("startTime"), date.get("endTime")); if(dao.getOrderNum() <= integer){ dah.setCarryOut(2);//完成状态 + dah.setCompletionTime(new Date()); driverActivityHistoryMapper.updateById(dah); //修改余额 Driver driver = this.selectById(dah.getDriverId()); @@ -2384,102 +2685,112 @@ this.updateById(driver); //添加收入记录 - incomeService.saveData(2, dah.getDriverId(), 1, dao.getId(), null, dah.getMoney()); - + incomeService.saveData(2, dah.getDriverId(), 1, dah.getId(), null, dah.getMoney()); + + Integer language = driver.getLanguage(); if(ToolUtil.isNotEmpty(driver.getEmail())) { - String path1 = templatePath + "driver/index.html"; - Document document1 = Jsoup.parse(new File(path1), "UTF-8"); - if (1 == language) { - document1.getElementById("english").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite").remove(); - document1.getElementById("user").remove(); - document1.getElementById("settle").remove(); - document1.getElementById("pass").remove(); - document1.getElementById("email").remove(); - document1.getElementById("bill").remove(); - document1.getElementById("rewardToday").remove(); - document1.getElementById("driverAudit").remove(); - document1.getElementById("carAudit").remove(); - - document1.getElementsByTag("title").get(0).text("司机奖励通知"); - Element reward_user = document1.getElementById("reward_user"); - reward_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element reward_content = document1.getElementById("reward_content"); - reward_content.text("今日累计接单" + dao.getOrderNum() + "单,获得奖励GHS" + dah.getMoney() + ",请查收。\n详情请查看I-GO平台。"); - } - if (2 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("french").remove(); - document1.getElementById("invite1").remove(); - document1.getElementById("user1").remove(); - document1.getElementById("settle1").remove(); - document1.getElementById("pass1").remove(); - document1.getElementById("email1").remove(); - document1.getElementById("bill1").remove(); - document1.getElementById("rewardToday1").remove(); - document1.getElementById("driverAudit1").remove(); - document1.getElementById("carAudit1").remove(); - - document1.getElementsByTag("title").get(0).text("Reward-driver notice"); - Element reward1_user = document1.getElementById("reward1_user"); - reward1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element reward1_content = document1.getElementById("reward1_content"); - reward1_content.text("You completed " + dao.getOrderNum() + " trips today, and got a bonus of GHS" + dah.getMoney() + ", please check.\nCheck your app for more details."); - } - if (3 == language) { - document1.getElementById("chinese").remove(); - document1.getElementById("english").remove(); - document1.getElementById("invite2").remove(); - document1.getElementById("user2").remove(); - document1.getElementById("settle2").remove(); - document1.getElementById("pass2").remove(); - document1.getElementById("email2").remove(); - document1.getElementById("bill2").remove(); - document1.getElementById("rewardToday2").remove(); - document1.getElementById("driverAudit2").remove(); - document1.getElementById("carAudit2").remove(); - - document1.getElementsByTag("title").get(0).text("Avis de chauffeur de récompense"); - Element reward2_user = document1.getElementById("reward2_user"); - reward2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); - Element reward2_content = document1.getElementById("reward2_content"); - reward2_content.text("Vous avez effectué " + dao.getOrderNum() + " trajets aujourd’hui et avez reçu un bonus de GHS" + dah.getMoney() + ", veuillez vérifier.\nConsultez votre application pour plus de détails."); - } - - EmailUtil.send(driver.getEmail(), language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document1.html()); - String randomString = ToolUtil.getRandomString(10); - //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); - if(!file.exists()){ - file.mkdirs(); - } - file = new File("/usr/local/nginx/html/files/html/rewards_" + randomString + ".html"); - if(!file.exists()){ - file.createNewFile(); - } - FileWriter fileWriter = new FileWriter(file); - fileWriter.write(document1.html()); - fileWriter.flush(); - fileWriter.close(); - - String link ="http://182.160.16.251:81/files/html/rewards_" + randomString + ".html"; - TEmail tEmail = new TEmail(); - tEmail.setLink(link); - tEmail.setUserId(driver.getId()); - tEmail.setType(2); - tEmail.setName(language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense"); - tEmail.setCreateTime(new Date()); - int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; - String week = EmailUtil.getWeek(language, i); - tEmail.setWeek(week); - boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); - if(am){ - tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); - }else { - tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); - } - emailService.insert(tEmail); + new Thread(new Runnable() { + @Override + public void run() { + try { + String path1 = templatePath + "driver/index.html"; + Document document1 = Jsoup.parse(new File(path1), "UTF-8"); + if (1 == language) { + document1.getElementById("english").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite").remove(); + document1.getElementById("user").remove(); + document1.getElementById("settle").remove(); + document1.getElementById("pass").remove(); + document1.getElementById("email").remove(); + document1.getElementById("bill").remove(); + document1.getElementById("rewardToday").remove(); + document1.getElementById("driverAudit").remove(); + document1.getElementById("carAudit").remove(); + + document1.getElementsByTag("title").get(0).text("司机奖励通知"); + Element reward_user = document1.getElementById("reward_user"); + reward_user.text("您好 " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element reward_content = document1.getElementById("reward_content"); + reward_content.html("今日累计接单" + dao.getOrderNum() + "单,获得奖励GHS" + dah.getMoney() + ",请查收。<br/>详情请查看I-GO平台。"); + } + if (2 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("french").remove(); + document1.getElementById("invite1").remove(); + document1.getElementById("user1").remove(); + document1.getElementById("settle1").remove(); + document1.getElementById("pass1").remove(); + document1.getElementById("email1").remove(); + document1.getElementById("bill1").remove(); + document1.getElementById("rewardToday1").remove(); + document1.getElementById("driverAudit1").remove(); + document1.getElementById("carAudit1").remove(); + + document1.getElementsByTag("title").get(0).text("Reward-driver notice"); + Element reward1_user = document1.getElementById("reward1_user"); + reward1_user.text("Hello " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element reward1_content = document1.getElementById("reward1_content"); + reward1_content.html("You completed " + dao.getOrderNum() + " trips today, and got a bonus of GHS" + dah.getMoney() + ", please check.<br/>Check your app for more details."); + } + if (3 == language) { + document1.getElementById("chinese").remove(); + document1.getElementById("english").remove(); + document1.getElementById("invite2").remove(); + document1.getElementById("user2").remove(); + document1.getElementById("settle2").remove(); + document1.getElementById("pass2").remove(); + document1.getElementById("email2").remove(); + document1.getElementById("bill2").remove(); + document1.getElementById("rewardToday2").remove(); + document1.getElementById("driverAudit2").remove(); + document1.getElementById("carAudit2").remove(); + + document1.getElementsByTag("title").get(0).text("Avis de chauffeur de récompense"); + Element reward2_user = document1.getElementById("reward2_user"); + reward2_user.text("Cher(ère) " + driver.getFirstName() + "" + driver.getLastName() + ","); + Element reward2_content = document1.getElementById("reward2_content"); + reward2_content.html("Vous avez effectué " + dao.getOrderNum() + " trajets aujourd’hui et avez reçu un bonus de GHS" + dah.getMoney() + ", veuillez vérifier.<br/>Consultez votre application pour plus de détails."); + } + + EmailUtil.send(driver.getEmail(), language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document1.html()); + String randomString = ToolUtil.getRandomString(10); + //开始生成pdf收据和html收据 + File file = new File("/home/igotechgh/nginx/html/files/html/"); + if(!file.exists()){ + file.mkdirs(); + } + file = new File("/home/igotechgh/nginx/html/files/html/rewards_" + randomString + ".html"); + if(!file.exists()){ + file.createNewFile(); + } + FileWriter fileWriter = new FileWriter(file); + fileWriter.write(document1.html()); + fileWriter.flush(); + fileWriter.close(); + + String link ="https://igo.i-go.group/files/html/rewards_" + randomString + ".html"; + TEmail tEmail = new TEmail(); + tEmail.setLink(link); + tEmail.setUserId(driver.getId()); + tEmail.setType(2); + tEmail.setName(language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense"); + tEmail.setCreateTime(new Date()); + int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1; + String week = EmailUtil.getWeek(language, i); + tEmail.setWeek(week); + boolean am = cn.hutool.core.date.DateUtil.isAM(new Date()); + if(am){ + tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin"); + }else { + tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi"); + } + emailService.insert(tEmail); + }catch (Exception e){ + e.printStackTrace(); + } + } + }).start(); } } } @@ -2960,4 +3271,37 @@ public Double getThisWeekMoney(Integer driverId) { return this.baseMapper.getThisWeekMoney(driverId); } + + + /** + * 获取给定车型且空闲的司机 + * @param type + * @param serverCarModelId + * @param lon + * @param lat + * @param distance + * @param companyId + * @return + * @throws Exception + */ + @Override + public List<Driver> queryIdleDriver(Integer userId, Integer type, Integer serverCarModelId, Double lon, Double lat, Double distance, Integer companyId) throws Exception { + List<Driver> drivers = driverMapper.queryIdleDriver_(type, serverCarModelId, companyId); + System.err.println("派单查询的司机:" + JSON.toJSONString(drivers)); + String tripId = redisUtil.getValue("trip" + userId); + List<Driver> list = new ArrayList<>(); + for(Driver driver : drivers){ + String value = redisUtil.getValue("DRIVER" + driver.getId()); + if(ToolUtil.isNotEmpty(value)){ + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(lat, lon, Double.parseDouble(value.split(",")[1]), Double.parseDouble(value.split(",")[0]), tripId); + if(null != distancematrix){ + if(distancematrix.getDistance() < (distance * 1000)){ + list.add(driver); + } + } + + } + } + return list; + } } -- Gitblit v1.7.1