| | |
|---|
| | | if(null != settlementAllocation){ |
|---|
| | | JSONObject jsonObject = JSON.parseObject(settlementAllocation.getContent()); |
|---|
| | | Double maxPrice = jsonObject.getDouble("maxPrice"); |
|---|
| | | Integer type1 = jsonObject.getInteger("type"); |
|---|
| | | if(null != maxPrice){ |
|---|
| | | List<SettlementDetail> settlementDetailList = settlementDetailService.selectList(new EntityWrapper<SettlementDetail>().eq("driverId", driver.getId()) |
|---|
| | | .isNull("settlementRecordId").last(" and DATE_FORMAT(now(), '%Y-%m-%d') = DATE_FORMAT(createTime, '%Y-%m-%d')")); |
|---|
| | |
|---|
| | | //日结算 |
|---|
| | | if(maxPrice.compareTo(total.doubleValue()) <= 0){ |
|---|
| | | SettlementRecord settlementRecord = settlementRecordService.selectOne(new EntityWrapper<SettlementRecord>().eq("driverId", orderLogistics.getDriverId()) |
|---|
| | | .eq("type", 1).eq("paymentStatus", 1).last(" and day = DATE_FORMAT(now(), '%Y-%m-%d')")); |
|---|
| | | .eq("type", type1).eq("paymentStatus", 1).last(" and day = DATE_FORMAT(now(), '%Y-%m-%d')")); |
|---|
| | | if(null == settlementRecord){ |
|---|
| | | settlementRecord = new SettlementRecord(); |
|---|
| | | settlementRecord.setDay(new Date()); |
|---|
| | | settlementRecord.setDriverId(orderLogistics.getDriverId()); |
|---|
| | | settlementRecord.setType(1); |
|---|
| | | settlementRecord.setType(type1); |
|---|
| | | settlementRecord.setPaymentStatus(1); |
|---|
| | | settlementRecord.setPayMoney(total.doubleValue()); |
|---|
| | | settlementRecord.setInsertTime(new Date()); |
|---|
| | |
|---|
| | | detail.setSettlementRecordId(settlementRecord.getId()); |
|---|
| | | settlementDetailService.updateById(detail); |
|---|
| | | } |
|---|
| | | //强制司机下班 |
|---|
| | | DriverWork driverWork = driverWorkService.selectOne(new EntityWrapper<DriverWork>() |
|---|
| | | .eq("driverId", orderLogistics.getDriverId()).eq("state", 1)); |
|---|
| | | if(null != driverWork){ |
|---|
| | | driverWork.setEndTime(new Date()); |
|---|
| | | driverWork.setState(2); |
|---|
| | | driverWorkService.updateById(driverWork); |
|---|
| | | driver.setState(1); |
|---|
| | | driverService.updateById(driver); |
|---|
| | | Car car = carService.selectById(driver.getCarId()); |
|---|
| | | if(!org.apache.shiro.util.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)){ |
|---|
| | | fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); |
|---|
| | | fleetEngineUtil.updateVehicles("OFFLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); |
|---|
| | | }else{ |
|---|
| | | fleetEngineUtil.updateVehicles("OFFLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | }).start(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
