| | |
| | | import java.io.Serializable; |
| | | import java.lang.reflect.InvocationTargetException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.time.LocalDate; |
| | | import java.time.format.DateTimeFormatter; |
| | | import java.util.*; |
| | | |
| | | /** |
| | |
| | | } |
| | | orderList = orderPrivateCarService.queryOrderInfo2(orderId, 6, null, null); |
| | | if (orderInfoWarpper.getState() > 1 && orderInfoWarpper.getDriverId() != 0) { |
| | | String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(orderInfoWarpper.getDriverId())); |
| | | String value = (String) redisTemplate.opsForValue().get("dache:DRIVER" + String.valueOf(orderInfoWarpper.getDriverId())); |
| | | if (value == null || value.equals("")) { |
| | | if (orderList.isEmpty()) { |
| | | orderList = orderPrivateCarService.queryOrderInfo2(orderId, 5, "0", "0"); |
| | |
| | | return ResultUtil.error("请先配置价格规则"); |
| | | } |
| | | Map<String, Object> query1 = systemPriceMapper.query(orderPrivateCar.getCompanyId(), 1, orderPrivateCar.getServerCarModelId(), systemPriceCity.getId()); |
| | | System.out.println("参数:" + orderPrivateCar.getCompanyId() + "|" + orderPrivateCar.getServerCarModelId()); |
| | | System.out.println("query1:" + query1); |
| | | // System.out.println("参数:" + orderPrivateCar.getCompanyId() + "|" + orderPrivateCar.getServerCarModelId()); |
| | | // System.out.println("query1:" + query1); |
| | | //开始根据不同的方式计算金额 |
| | | if (query1 != null) { |
| | | JSONObject jsonObject = JSON.parseObject(query1.get("content").toString());//等待费 |
| | |
| | | case 2: |
| | | return orderTaxiService.payTaxiOrder1(payType, orderId, objectId, objectType, type, path, ip); |
| | | case 3: |
| | | return orderCrossCityService.payCrossCityOrder1(payType, orderId, objectId, objectType, type); |
| | | ResultUtil resultUtil = orderCrossCityService.payCrossCityOrder1(payType, orderId, objectId, objectType, type); |
| | | |
| | | orderCrossCityService.promotion(orderId); |
| | | |
| | | return resultUtil; |
| | | case 4: |
| | | return orderLogisticsService.payLogisticsOrder1(payType, orderId, objectId, objectType, type); |
| | | case 5: |
| | |
| | | if("1".equals(data.getStatus())){ |
| | | return "error"; |
| | | } |
| | | String partnerPayId = data.getPartnerPayId(); |
| | | String orderNo = data.getOrderNo(); |
| | | String payId = data.getPayId(); |
| | | //网约车 |
| | | if(partnerPayId.contains("PR")){ |
| | | partnerPayId = partnerPayId.substring(2); |
| | | orderPrivateCarService.payOrderPrivateCarCallback(Integer.valueOf(partnerPayId), payId, 1); |
| | | if(orderNo.contains("PR")){ |
| | | orderNo = orderNo.substring(2); |
| | | orderPrivateCarService.payOrderPrivateCarCallback(Integer.valueOf(orderNo), payId, 1); |
| | | orderPrivateCarService.promotion(Integer.valueOf(orderNo)); |
| | | } |
| | | //出租车 |
| | | if(partnerPayId.contains("TA")){ |
| | | partnerPayId = partnerPayId.substring(2); |
| | | orderTaxiService.payOrderTaxiCallback(Integer.valueOf(partnerPayId), payId, 1, 0); |
| | | if(orderNo.contains("TA")){ |
| | | orderNo = orderNo.substring(2); |
| | | orderTaxiService.payOrderTaxiCallback(Integer.valueOf(orderNo), payId, 1, 0); |
| | | orderTaxiService.promotion(Integer.valueOf(orderNo)); |
| | | } |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | |
| | | */ |
| | | private void promotion(Integer orderType, Integer orderId) { |
| | | switch (orderType) { |
| | | case 1: |
| | | orderPrivateCarService.promotion(orderId); |
| | | break; |
| | | case 2: |
| | | orderTaxiService.promotion(orderId); |
| | | break; |
| | | case 3: |
| | | orderCrossCityService.promotion(orderId); |
| | | break; |
| | |
| | | List<TripOrderVo> tripOrderVos = processTripOrderVos(orderList); |
| | | String filePath = tripSheetGenerator.generatePdf(tripOrderVos); |
| | | File attachment = new File(filePath); |
| | | emailUtil.sendEmailWithAttachment(tripSheet.getRecipientEmail(), "行程单", "请查收您的行程单", attachment); |
| | | String displayFileName = "贵人家园行程单.pdf"; |
| | | emailUtil.sendEmailWithAttachment(tripSheet.getRecipientEmail(), "行程单", "请查收您的行程单", attachment,displayFileName); |
| | | attachment.delete(); // 发送成功后删除临时文件 |
| | | return ResultUtil.success("邮件发送成功"); |
| | | Map<String, Object> result = new HashMap<>(); |
| | | result.put("orderNum", orderList.size()); |
| | | return ResultUtil.success(result); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | return ResultUtil.error("邮件发送失败"); |
| | | return ResultUtil.error("邮件发送失败"+e.getMessage()); |
| | | } |
| | | } |
| | | /** |