| | |
| | | private IOrderPositionService orderPositionService; |
| | | |
| | | @Autowired |
| | | private PushMinistryOfTransportUtil pushMinistryOfTransportUtil; |
| | | |
| | | @Autowired |
| | | private IOrderCancelService orderCancelService; |
| | | |
| | | @Value("${filePath}") |
| | | private String filePath; |
| | | |
| | | @Value("${pushMinistryOfTransport}") |
| | | private boolean pushMinistryOfTransport; |
| | | |
| | | @Value("${callbackPath}") |
| | | private String callbackPath; |
| | |
| | | * @throws Exception |
| | | */ |
| | | @Override |
| | | public List<Map<String, Object>> queryOrderList(Integer state, Integer driverId) throws Exception { |
| | | return orderCrossCityMapper.queryOrderList(state, driverId); |
| | | public List<Map<String, Object>> queryOrderList(Integer language, Integer state, Integer driverId) throws Exception { |
| | | List<Map<String, Object>> list = orderCrossCityMapper.queryOrderList(state, driverId); |
| | | for (Map<String, Object> map : list) { |
| | | if(null != map.get("time")){ |
| | | String time = map.get("time").toString(); |
| | | map.put("time", DateUtil.conversionFormat(language, time)); |
| | | } |
| | | } |
| | | return list; |
| | | } |
| | | |
| | | /** |
| | |
| | | * @throws Exception |
| | | */ |
| | | @Override |
| | | public List<Map<String, Object>> queryMyAllOrder(Integer state, Integer uid) throws Exception { |
| | | return orderCrossCityMapper.queryMyAllOrder(state, uid); |
| | | public List<Map<String, Object>> queryMyAllOrder(Integer language, Integer state, Integer uid) throws Exception { |
| | | List<Map<String, Object>> list = orderCrossCityMapper.queryMyAllOrder(state, uid); |
| | | for (Map<String, Object> map : list) { |
| | | if(null != map.get("time")){ |
| | | String time = map.get("time").toString(); |
| | | map.put("time", DateUtil.conversionFormat(language, time)); |
| | | } |
| | | } |
| | | return list; |
| | | } |
| | | |
| | | |
| | |
| | | * @throws Exception |
| | | */ |
| | | @Override |
| | | public Map<String, Object> queryOrderInfo(Integer orderId) throws Exception { |
| | | public Map<String, Object> queryOrderInfo(Integer language, Integer orderId) throws Exception { |
| | | Map<String, Object> map = new HashMap<>(); |
| | | OrderCrossCity orderCrossCity = this.selectById(orderId); |
| | | List<Map<String, Object>> order = orderCrossCityMapper.queryOrderInfo(orderCrossCity.getOrderNum()); |
| | |
| | | Double serverMoney = 0D; |
| | | Double totalMoney = 0D; |
| | | for(Map<String, Object> m : order){ |
| | | if(null != m.get("travelTime_")){ |
| | | String travelTime_ = m.get("travelTime_").toString(); |
| | | m.put("travelTime_", DateUtil.conversionFormat1(language, travelTime_)); |
| | | } |
| | | if(null != m.get("travelTime")){ |
| | | String travelTime = m.get("travelTime").toString(); |
| | | m.put("travelTime", DateUtil.conversionFormat(language, travelTime)); |
| | | } |
| | | if(null != m.get("arriveTime")){ |
| | | String arriveTime = m.get("arriveTime").toString(); |
| | | m.put("arriveTime", DateUtil.conversionFormat(language, arriveTime)); |
| | | } |
| | | num += Integer.valueOf(m.get("peopleNumber").toString()); |
| | | totalMoney += Double.valueOf(m.get("payMoney").toString()); |
| | | List<Income> incomes = incomeService.queryData(1, null, 2, Integer.valueOf(m.get("orderId").toString()), 3); |
| | |
| | | orderCrossCity.setState(3); |
| | | orderCrossCity.setSetOutTime(new Date()); |
| | | systemNoticeService.addSystemNotice(1, "司机已出发,请耐心等待", orderCrossCity.getUserId()); |
| | | pushUtil.pushDriverPosition(orderCrossCity.getId(), 3);//主动推送司机定位 |
| | | break; |
| | | case 4://到达预约点,等待客户上车 |
| | | orderCrossCity.setState(4); |
| | |
| | | orderCrossCity.setBoardingTime(new Date()); |
| | | orderCrossCity.setState(5); |
| | | orderCrossCity.setStartServiceTime(new Date()); |
| | | |
| | | pushUtil.pushDriverPosition(orderCrossCity.getId(), 3);//主动推送司机定位 |
| | | break; |
| | | case 6://结束服务 |
| | | orderCrossCity.setGetoffLon(lon); |
| | |
| | | new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | pushUtil.pushOrderState(1, orderCrossCity.getUserId(), orderCrossCity.getId(), 2, orderCrossCity.getState()); |
| | | pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 2, orderCrossCity.getState()); |
| | | pushUtil.pushOrderState(1, orderCrossCity.getUserId(), orderCrossCity.getId(), 2, orderCrossCity.getState(), 0, "", "driver"); |
| | | pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 2, orderCrossCity.getState(), 0, "", "driver"); |
| | | } |
| | | }).start(); |
| | | return ResultUtil.success(); |
| | |
| | | * @throws Exception |
| | | */ |
| | | @Override |
| | | public Map<String, Object> queryOrderCrossCityInfo(Integer orderId) throws Exception { |
| | | return orderCrossCityMapper.queryOrderCrossCityInfo(orderId); |
| | | public Map<String, Object> queryOrderCrossCityInfo(Integer language, Integer orderId) throws Exception { |
| | | Map<String, Object> map = orderCrossCityMapper.queryOrderCrossCityInfo(orderId); |
| | | if(null != map.get("travelTime_")){ |
| | | String travelTime_ = map.get("travelTime_").toString(); |
| | | map.put("travelTime_", DateUtil.conversionFormat1(language, travelTime_)); |
| | | } |
| | | if(null != map.get("arriveTime")){ |
| | | String arriveTime = map.get("arriveTime").toString(); |
| | | map.put("arriveTime", DateUtil.conversionFormat(language, arriveTime)); |
| | | } |
| | | return map; |
| | | } |
| | | |
| | | |
| | |
| | | userInfo = new UserInfo(); |
| | | Integer integer = userInfoMapper.selectCount(null) + 1000001; |
| | | userInfo.setNickName(ToolUtil.isNotEmpty(orderCrossCityWarpper.getPassengers()) ? orderCrossCityWarpper.getPassengers() : "OK" + String.valueOf(integer).substring(1)); |
| | | userInfo.setName(orderCrossCityWarpper.getPassengers()); |
| | | userInfo.setLastName(orderCrossCityWarpper.getPassengers()); |
| | | userInfo.setPhone(orderCrossCityWarpper.getPassengersPhone()); |
| | | userInfo.setState(1); |
| | | userInfo.setFlag(1); |
| | |
| | | //添加已收入明细 |
| | | Line line = lineService.selectById(orderCrossCity.getLineId()); |
| | | Double speMoney = Double.valueOf(line.getRakeRate()); |
| | | BigDecimal d = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100))).setScale(2, BigDecimal.ROUND_HALF_EVEN);//企业收入 |
| | | BigDecimal d = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100), new MathContext(2, RoundingMode.HALF_EVEN)));//企业收入 |
| | | BigDecimal c = new BigDecimal(orderCrossCity.getOrderMoney()).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);//司机收入 |
| | | incomeService.saveData(1, orderCrossCity.getCompanyId(), 2, orderCrossCity.getId(), 1, d.doubleValue()); |
| | | incomeService.saveData(2, orderCrossCity.getDriverId(), 2, orderCrossCity.getId(), 1, c.doubleValue()); |
| | |
| | | new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | pushUtil.pushOrderState(1, orderCrossCity.getUserId(), orderCrossCity.getId(), 3, orderCrossCity.getState()); |
| | | pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState()); |
| | | pushUtil.pushDriverPosition(orderCrossCity.getId(), 3); |
| | | pushUtil.pushOrderState(1, orderCrossCity.getUserId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0, "", "driver"); |
| | | pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0, "", "driver"); |
| | | } |
| | | }).start(); |
| | | |
| | |
| | | //添加已收入明细 |
| | | Line line = lineService.selectById(orderCrossCity.getLineId()); |
| | | Double speMoney = Double.valueOf(line.getRakeRate()); |
| | | BigDecimal d = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100))).setScale(2, BigDecimal.ROUND_HALF_EVEN);//企业收入 |
| | | BigDecimal d = new BigDecimal(orderCrossCity.getOrderMoney()).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100), new MathContext(2, RoundingMode.HALF_EVEN)));//企业收入 |
| | | BigDecimal c = new BigDecimal(orderCrossCity.getOrderMoney()).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);//司机收入 |
| | | incomeService.saveData(1, orderCrossCity.getCompanyId(), 2, orderCrossCity.getId(), 3, d.doubleValue()); |
| | | incomeService.saveData(2, orderCrossCity.getDriverId(), 2, orderCrossCity.getId(), 3, c.doubleValue()); |
| | |
| | | new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | pushUtil.pushOrderState(1, orderCrossCity.getUserId(), orderCrossCity.getId(), 3, orderCrossCity.getState()); |
| | | pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState()); |
| | | pushUtil.pushDriverPosition(orderCrossCity.getId(), 3); |
| | | pushUtil.pushOrderState(1, orderCrossCity.getUserId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0, "", "driver"); |
| | | pushUtil.pushOrderState(2, orderCrossCity.getDriverId(), orderCrossCity.getId(), 3, orderCrossCity.getState(), 0, "", "driver"); |
| | | } |
| | | }).start(); |
| | | |