From 729a5a0592cac7750e8b476c5fcb25bfc3ff8d25 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期日, 27 七月 2025 09:06:31 +0800
Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/QianYunTong
---
UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java | 5291 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 2,633 insertions(+), 2,658 deletions(-)
diff --git a/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java b/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
index 9ff2ccc..85a8d0c 100644
--- a/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
+++ b/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
@@ -3,7 +3,6 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
-import com.aliyun.oss.ServiceException;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.stylefeng.guns.core.util.ToolUtil;
@@ -48,6 +47,7 @@
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
import java.util.*;
+import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.stream.Collectors;
@@ -55,2689 +55,2664 @@
@Service
public class OrderPrivateCarServiceImpl extends ServiceImpl<OrderPrivateCarMapper, OrderPrivateCar> implements IOrderPrivateCarService {
-
- @Resource
- private OrderPrivateCarMapper orderPrivateCarMapper;
-
- @Resource
- private CarServiceMapper carServiceMapper;
-
- @Resource
- private OrderTaxiMapper orderTaxiMapper;
-
- @Resource
- private SensitiveWordsMapper sensitiveWordsMapper;
-
- @Resource
- private UserActivityDiscount1Mapper userActivityDiscount1Mapper;
-
- @Resource
- private SysIntegralMapper sysIntegralMapper;
-
- @Resource
- private OrderCrossCityMapper orderCrossCityMapper;
-
- @Resource
- private RegionMapper regionMapper;
-
- @Autowired
- private DateUtil dateUtil;
-
- @Autowired
- private IUserInfoService userInfoService;
-
- @Autowired
- private IDriverService driverService;
-
- @Autowired
- private IDriverServiceService driverServiceService;
-
- @Autowired
- private PushUtil pushUtil;
-
- @Autowired
- private ICompanyCityService companyCityService;
-
- @Autowired
- private IPushOrderService pushOrderService;
-
- @Autowired
- private ISystemNoticeService systemNoticeService;
-
- @Autowired
- private ICancleOrderService cancleOrderService;
-
- @Autowired
- private IOrderCancelService orderCancelService;
-
- @Autowired
- private RestTemplate internalRestTemplate;
-
- @Autowired
- private IPaymentRecordService paymentRecordService;
-
- @Autowired
- private ITransactionDetailsService transactionDetailsService;
-
- @Autowired
- private ChinaMobileUtil chinaMobileUtil;
-
- @Autowired
- private IIncomeService incomeService;
-
- @Autowired
- private IUserCouponRecordService userCouponRecordService;
-
- @Autowired
- private IUserRedPacketRecordService userRedPacketRecordService;
-
- @Autowired
- private ICompanyService companyService;
-
- @Autowired
- private IUserActivityRedenvelopeService userActivityRedenvelopeService;
-
- @Resource
- private RedisTemplate<String, Object> redisTemplate;
-
- @Autowired
- private GDFalconUtil gdFalconUtil;
-
- @Autowired
- private GDMapGeocodingUtil gdMapGeocodingUtil;
-
- @Autowired
- private GDMapElectricFenceUtil gdMapElectricFenceUtil;
-
- @Autowired
- private IOrderPositionService orderPositionService;
-
- @Autowired
- private PushMinistryOfTransportUtil pushMinistryOfTransportUtil;
-
- @Autowired
- private IOrderCrossCityService orderCrossCityService;
-
- @Autowired
- private IOrderTaxiService orderTaxiService;
-
- @Autowired
- private PayMoneyUtil payMoneyUtil;
-
- @Autowired
- private IOrderLogisticsService orderLogisticsService;
-
- @Autowired
- private ITaxiCardPaymentService taxiCardPaymentService;
-
- @Autowired
- private ITaxiCardService taxiCardService;
-
- @Autowired
- private IOpenCityService openCityService;
-
- @Autowired
- private IUserUserService userUserService;
-
- @Autowired
- private IUserTaxiCardService userTaxiCardService;
-
- @Autowired
- private IRegionService regionService;
-
- public static List<Integer> orderIds = new ArrayList<>();
-
- @Value("${callbackPath}")
- private String callbackPath;
-
- @Value("${pushMinistryOfTransport}")
- private boolean pushMinistryOfTransport;
-
- @Autowired
- private ITbSpellOrderRuleService spellOrderRuleService;
-
- @Autowired
- private GeodesyUtil geodesyUtil;
-
- private Lock lock = new ReentrantLock();
-
- /**
- * 专车下单操作
- * @param serverCarModelId 服务车型id
- * @param travelTime 出行时间
- * @param reservation 是否预约（1=否，2=是）
- * @param instead 是否代下单（0=否，1=是）
- * @param startLon 起点经度
- * @param startLat 起点纬度
- * @param startAddress 起点详细地址
- * @param endLon 终点经度
- * @param endLat 终点纬度
- * @param endAddress 终点详细地址
- * @param name 乘客姓名
- * @param phone 乘客电话
- * @return
- * @throws Exception
- */
- @Override
- public synchronized ResultUtil<BaseWarpper> saveOrderPrivateCar(Integer serverCarModelId, Date travelTime, Integer reservation, Integer instead, String placementLon, String placementLat, String startLon, String startLat,
- String startAddress, String endLon, String endLat, String endAddress, String name, String phone, Integer orderSource, Integer driverId, Integer type, Integer uid,Integer peopleNum,Integer rideType) throws Exception {
- BaseWarpper baseWarpper = new BaseWarpper();
- if (lock.tryLock()) {
- try{
- //如果出行时间大于当前10分钟则默认为预约单
- if(travelTime.getTime() > (System.currentTimeMillis() + 600000)){
- reservation = 2;
- }
- /**
- * 1.出租车、专车、跨城有待支付的订单不能叫车
- * 2.小件物流有未完成的订单可以下跨城、专车、出租车
- * 3.出租车、专车、跨城有预约单可以下即时单
- */
- List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
- if(orderPrivateCars.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
- if(list.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
- if(orderCrossCities1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- if(reservation == 1){
- orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
- if(orderPrivateCars.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
- if(list.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- }
-
- List<OrderPrivateCar> orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, null, 3, 7, 12);
- if(orderPrivateCars1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- List<OrderTaxi> list1 = orderTaxiMapper.queryByState_(uid, null, 3, 7, 12);
- if(list1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- List<OrderCrossCity> orderCrossCities11 = orderCrossCityMapper.queryByState(uid, 7, 12);
- if(orderCrossCities11.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- if(reservation == 1){
- orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
- if(orderPrivateCars1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- list1 = orderTaxiMapper.queryByState_(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
- if(list1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- }
-
-
-
-
- startAddress = startAddress.replaceAll("& #40;", "(");
- startAddress = startAddress.replaceAll("& #41;", ")");
- endAddress = endAddress.replaceAll("& #40;", "(");
- endAddress = endAddress.replaceAll("& #41;", ")");
- if((orderSource == 1 || orderSource == 3) && null == serverCarModelId){
- return ResultUtil.error("请选择服务车型");
- }
-
- OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
- orderPrivateCar.setPeopleNum(peopleNum);
- orderPrivateCar.setRideType(rideType);
- orderPrivateCar.setType(type);
- orderPrivateCar.setUserId(uid);
- orderPrivateCar.setServerCarModelId(serverCarModelId);
- orderPrivateCar.setOrderNum(this.getOrderNum());
- orderPrivateCar.setPlacementLon(Double.valueOf(placementLon));
- orderPrivateCar.setPlacementLat(Double.valueOf(placementLat));
- Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
- orderPrivateCar.setPlacementAddress(geocode.get("address"));
- orderPrivateCar.setStartLon(Double.valueOf(startLon));
- orderPrivateCar.setStartLat(Double.valueOf(startLat));
- orderPrivateCar.setStartAddress(startAddress);
- orderPrivateCar.setEndLon(Double.valueOf(endLon));
- orderPrivateCar.setEndLat(Double.valueOf(endLat));
- orderPrivateCar.setEndAddress(endAddress);
- orderPrivateCar.setSubstitute(instead);
- orderPrivateCar.setPassengers(name);
- orderPrivateCar.setPassengersPhone(phone);
- // TODO: 2023/11/4 无法修改
- Map<String,String> distanceMap = gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
- orderPrivateCar.setEstimateMileage(Double.valueOf(distanceMap.get("distance")));
- orderPrivateCar.setEstimateTime(Double.valueOf(distanceMap.get("duration"))/60);
- if(instead == 0 || ToolUtil.isEmpty(orderPrivateCar.getPassengers())){
- UserInfo userInfo = userInfoService.selectById(uid);
- if(ToolUtil.isEmpty(userInfo.getPhone())){
- return ResultUtil.error("请先绑定手机号码");
- }
- orderPrivateCar.setPassengers(userInfo.getName());
- orderPrivateCar.setPassengersPhone(userInfo.getPhone());
- }
- orderPrivateCar.setState(1);
- orderPrivateCar.setInsertTime(new Date());
- orderPrivateCar.setTravelTime(travelTime);
- orderPrivateCar.setOrderType(reservation);
- orderPrivateCar.setOrderSource(orderSource);
- if(orderSource == 2){//扫码下单
- Driver driver = driverService.selectById(driverId);
- if(null == driver){
- return ResultUtil.error("司机信息有误，无法完成下单");
- }
- if(driver.getAuthState() == 1){
- return ResultUtil.error("司机信息还未完成审核，无法完成下单");
- }
- if(driver.getAuthState() == 3){
- return ResultUtil.error("司机账户已被冻结，无法提供服务");
- }
- if(driver.getAuthState() == 4){
- return ResultUtil.error("司机信息未通过审核，无法提供服务");
- }
- if(driver.getState() == 1){
- return ResultUtil.error("司机还未上线，无法提供服务");
- }
- if(driver.getState() == 3){
- return ResultUtil.error("司机正在服务中，无法提供服务");
- }
- // Integer orderType = orderPrivateCar.getRideType()==1?1:orderPrivateCar.getRideType()==2?9:8;
- Integer orderType = 1;
- Integer integer = driverServiceService.query_(driverId, orderType);
- if(null == integer){
- return ResultUtil.error("该司机不能服务此业务");
- }
-
- orderPrivateCar.setDriverId(driverId);
- orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
- driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
- orderPrivateCar.setState(2);
- orderPrivateCar.setCarId(driver.getCarId());
- CarService query1 = carServiceMapper.query(1, driver.getCarId());
- orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
- orderPrivateCar.setSnatchOrderTime(new Date());
-
- // //调用高德创建轨迹
- // String s = gdFalconUtil.selectTerminal(driver.getPhone());
- // String track = gdFalconUtil.createTrack(s);
- // orderPrivateCar.setTrackId(track);
- //
- //调用移动的小号接口
- Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
- if(String.valueOf(map.get("code")).equals("200")){
- orderPrivateCar.setTelX(map.get("telX"));
- orderPrivateCar.setBindId(map.get("bindId"));
- }
-
- driver.setState(3);
- driverService.updateById(driver);
- }
- //判断独享，一口价，拼车
- if(orderPrivateCar.getRideType()!=3){
- orderPrivateCar.setTotalPeopleNum(peopleNum);
- orderPrivateCar.setIsReassign(1);
- orderPrivateCar.setIsDelete(1);
- this.insert(orderPrivateCar);
-
- if(orderSource == 2){//扫码下单
- new Thread(new Runnable() {
- @Override
- public void run() {
- pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
- pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0);
- pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
- }
- }).start();
- }
-
- //推单操作-独享
- if(orderPrivateCar.getState() == 1){
- this.pushOrder(orderPrivateCar);
- }
- }else{
- OrderPrivateCar orderPrivateCar1 = null;
- //判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
- List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).in("state","2,3,4").le("totalPeopleNum",4-peopleNum));
- for(OrderPrivateCar order:orderList){
- TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
- if(spellOrderRule!=null){
- JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
- //判断时间
-
- if(travelTime.getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")*60000L && travelTime.getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")*60000L){
- // Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
- // Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
- // TODO: 2023/11/4 已改成计算直线距离
- Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
- Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
- //判断距离
- if(dis1<=jsonObject.getInteger("num1")*1000 && dis2<=jsonObject.getInteger("num2")*1000){
- orderPrivateCar1=order;
- break;
- }
- }
- }
- }
- if(orderPrivateCar1==null){
- orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).eq("state",5).le("totalPeopleNum",4-peopleNum));
- for(OrderPrivateCar order:orderList){
- TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
- if(spellOrderRule!=null){
- JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
- //判断时间
- if(travelTime.getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")*60000L && travelTime.getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")*60000L){
- String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
- // Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
- // Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
-
- // TODO: 2023/11/4 已改成计算直线距离
- Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
- Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
- //判断距离
- if(dis1<=jsonObject.getInteger("num3")*1000 && dis2<=jsonObject.getInteger("num4")*1000){
- orderPrivateCar1=order;
- break;
- }
- }
- }
- }
- }
- if(orderPrivateCar1==null){
- orderPrivateCar.setTotalPeopleNum(peopleNum);
- orderPrivateCar.setIsReassign(1);
- orderPrivateCar.setIsDelete(1);
- this.insert(orderPrivateCar);
- this.pushOrder(orderPrivateCar);
- }else{
- Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
- orderPrivateCar.setDriverId(driverId);
- orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
- driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
- orderPrivateCar.setState(2);
- orderPrivateCar.setDriverId(driver.getId());
- orderPrivateCar.setCarId(driver.getCarId());
- CarService query1 = carServiceMapper.query(1, driver.getCarId());
- orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
- orderPrivateCar.setSnatchOrderTime(new Date());
- orderPrivateCar.setTotalPeopleNum(peopleNum+orderPrivateCar1.getTotalPeopleNum());
- orderPrivateCar.setIsReassign(1);
- orderPrivateCar.setIsDelete(1);
- orderPrivateCar.setPid(orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid());
- this.insert(orderPrivateCar);
- //修改总订单人数
- OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
- orderPrivateCar2.setSpellSuccess(1);
- orderPrivateCar2.setTotalPeopleNum(peopleNum+orderPrivateCar1.getTotalPeopleNum());
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
- //
- //调用移动的小号接口
- Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
- if(String.valueOf(map.get("code")).equals("200")){
- orderPrivateCar.setTelX(map.get("telX"));
- orderPrivateCar.setBindId(map.get("bindId"));
- }
- new Thread(new Runnable() {
- @Override
- public void run() {
- pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
- pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
- pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
-
- }
- }).start();
- List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()));
- for(OrderPrivateCar orderPrivateCar3:orderList1){
- pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
- }
- OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
- pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
- }
-
- }
-
-
- //添加消息
- systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);
- baseWarpper.setId(orderPrivateCar.getId());
- }catch (Exception e) {
- e.printStackTrace();
- } finally {
- lock.unlock();
- }
- }else {
- return ResultUtil.error("系统繁忙，请稍后再试！");
- }
- return ResultUtil.success(baseWarpper);
- }
-
-
- /**
- * 批量订单
- *
- * @throws Exception
- */
- @Override
- public ResultUtil<BaseWarpper> saveOrderPrivateCars(String serverCarModel, Date travelTime, Integer reservation, Integer instead, String placementLon, String placementLat, String startLon, String startLat, String startAddress, String endLon,
- String endLat, String endAddress, String name, String phone, Integer orderSource, Integer driverId, Integer uid, Integer peopleNum) throws Exception {
- BaseWarpper baseWarpper = new BaseWarpper();
- if (lock.tryLock()) {
- try {
- //如果出行时间大于当前10分钟则默认为预约单
- if (travelTime.getTime() > (System.currentTimeMillis() + 600000)) {
- reservation = 2;
- }
-
- /**
- * 1.出租车、专车、跨城有待支付的订单不能叫车
- * 2.小件物流有未完成的订单可以下跨城、专车、出租车
- * 3.出租车、专车、跨城有预约单可以下即时单
- */
- List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
- if(orderPrivateCars.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
- if(list.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
- if(orderCrossCities1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- if(reservation == 1){
- orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
- if(orderPrivateCars.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
- if(list.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- }
-
-
- List<OrderPrivateCar> orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, null, 3, 7, 12);
- if(orderPrivateCars1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- List<OrderTaxi> list1 = orderTaxiMapper.queryByState_(uid, null, 3, 7, 12);
- if(list1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- List<OrderCrossCity> orderCrossCities11 = orderCrossCityMapper.queryByState(uid, 7, 12);
- if(orderCrossCities11.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- if(reservation == 1){
- orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
- if(orderPrivateCars1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- list1 = orderTaxiMapper.queryByState_(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
- if(list1.size() > 0){
- return ResultUtil.error("有未完成的订单");
- }
- }
-
- startAddress = startAddress.replaceAll("& #40;", "(");
- startAddress = startAddress.replaceAll("& #41;", ")");
- endAddress = endAddress.replaceAll("& #40;", "(");
- endAddress = endAddress.replaceAll("& #41;", ")");
- if(ToolUtil.isEmpty(serverCarModel)){
- return ResultUtil.error("请选择服务车型");
- }
-
- OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
- orderPrivateCar.setPeopleNum(peopleNum);
- orderPrivateCar.setType(3);
- orderPrivateCar.setUserId(uid);
- orderPrivateCar.setServerCarModel(serverCarModel);
- orderPrivateCar.setOrderNum(this.getOrderNum());
- orderPrivateCar.setPlacementLon(Double.valueOf(placementLon));
- orderPrivateCar.setPlacementLat(Double.valueOf(placementLat));
- Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
- orderPrivateCar.setPlacementAddress(geocode.get("address"));
- orderPrivateCar.setStartLon(Double.valueOf(startLon));
- orderPrivateCar.setStartLat(Double.valueOf(startLat));
- orderPrivateCar.setStartAddress(startAddress);
- orderPrivateCar.setEndLon(Double.valueOf(endLon));
- orderPrivateCar.setEndLat(Double.valueOf(endLat));
- orderPrivateCar.setEndAddress(endAddress);
- orderPrivateCar.setSubstitute(instead);
- orderPrivateCar.setPassengers(name);
- orderPrivateCar.setPassengersPhone(phone);
- // TODO: 2023/11/4 无法修改
- Map<String,String> distanceMap = gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
- orderPrivateCar.setEstimateMileage(Double.valueOf(distanceMap.get("distance")));
- orderPrivateCar.setEstimateTime(Double.valueOf(distanceMap.get("duration"))/60);
- if(instead == 0 || ToolUtil.isEmpty(orderPrivateCar.getPassengers())){
- UserInfo userInfo = userInfoService.selectById(uid);
- if(ToolUtil.isEmpty(userInfo.getPhone())){
- return ResultUtil.error("请先绑定手机号码");
- }
- orderPrivateCar.setPassengers(userInfo.getName());
- orderPrivateCar.setPassengersPhone(userInfo.getPhone());
- }
- orderPrivateCar.setState(1);
- orderPrivateCar.setInsertTime(new Date());
- orderPrivateCar.setTravelTime(travelTime);
- orderPrivateCar.setOrderType(reservation);
- orderPrivateCar.setOrderSource(orderSource);
- orderPrivateCar.setTotalPeopleNum(peopleNum);
- orderPrivateCar.setIsReassign(1);
- orderPrivateCar.setIsDelete(1);
- this.insert(orderPrivateCar);
-
- //判断独享，一口价，拼车
- JSONArray jsonArray = JSON.parseArray(serverCarModel);
- for (int i = 0; i < jsonArray.size(); i++) {
- JSONObject jsonObject1 = jsonArray.getJSONObject(i);
- Integer serverCarModelId = jsonObject1.getInteger("serverCarModelId");
- Integer rideType = jsonObject1.getInteger("rideType");
- if(0 == serverCarModelId){
- OrderTaxi orderTaxi = new OrderTaxi();
- orderTaxi.setId(orderPrivateCar.getId());
- orderTaxi.setState(1);
- orderTaxi.setUserId(orderPrivateCar.getUserId());
- orderTaxi.setStartLon(orderPrivateCar.getStartLon());
- orderTaxi.setStartLat(orderPrivateCar.getStartLat());
- orderTaxiService.pushOrder(orderTaxi, 3);
- }
-
- if(rideType!=3){
- //推单操作-独享
- this.pushOrder(orderPrivateCar.getId(), rideType, serverCarModelId, orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat());
- }else{
- OrderPrivateCar orderPrivateCar1 = null;
- //判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
- List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).in("state","2,3,4").le("totalPeopleNum",4-peopleNum));
- for(OrderPrivateCar order:orderList){
- TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
- if(spellOrderRule!=null){
- JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
- //判断时间
-
- if(travelTime.getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")*60000L && travelTime.getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")*60000L){
- // Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
- // Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
- // TODO: 2023/11/4 已改成计算直线距离
- Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
- Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
- //判断距离
- if(dis1<=jsonObject.getInteger("num1")*1000 && dis2<=jsonObject.getInteger("num2")*1000){
- orderPrivateCar1=order;
- break;
- }
- }
- }
- }
- if(orderPrivateCar1==null){
- orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).eq("state",5).le("totalPeopleNum",4-peopleNum));
- for(OrderPrivateCar order:orderList){
- TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
- if(spellOrderRule!=null){
- JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
- //判断时间
- if(travelTime.getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")*60000L && travelTime.getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")*60000L){
- String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
- // Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
- // Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
-
- // TODO: 2023/11/4 已改成计算直线距离
- Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
- Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
- //判断距离
- if(dis1<=jsonObject.getInteger("num3")*1000 && dis2<=jsonObject.getInteger("num4")*1000){
- orderPrivateCar1=order;
- break;
- }
- }
- }
- }
- }
- if(orderPrivateCar1==null){
- this.pushOrder(orderPrivateCar.getId(), rideType, serverCarModelId, orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat());
- }else{
- Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
- orderPrivateCar.setDriverId(driverId);
- orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
- driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
- orderPrivateCar.setState(2);
- orderPrivateCar.setDriverId(driver.getId());
- orderPrivateCar.setCarId(driver.getCarId());
- CarService query1 = carServiceMapper.query(1, driver.getCarId());
- orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
- orderPrivateCar.setRideType(3);
- orderPrivateCar.setSnatchOrderTime(new Date());
- orderPrivateCar.setTotalPeopleNum(peopleNum+orderPrivateCar1.getTotalPeopleNum());
- orderPrivateCar.setIsReassign(1);
- orderPrivateCar.setIsDelete(1);
- orderPrivateCar.setPid(orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid());
- this.insertOrUpdate(orderPrivateCar);
- //修改总订单人数
- OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
- orderPrivateCar2.setSpellSuccess(1);
- orderPrivateCar2.setTotalPeopleNum(peopleNum+orderPrivateCar1.getTotalPeopleNum());
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
- //
- //调用移动的小号接口
- Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
- if(String.valueOf(map.get("code")).equals("200")){
- orderPrivateCar.setTelX(map.get("telX"));
- orderPrivateCar.setBindId(map.get("bindId"));
- }
- new Thread(new Runnable() {
- @Override
- public void run() {
- pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
- pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
- pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
-
- }
- }).start();
- List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()));
- for(OrderPrivateCar orderPrivateCar3:orderList1){
- pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
- }
- OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
- pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
- }
- }
- }
-
- //添加消息
- systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);
-
- baseWarpper.setId(orderPrivateCar.getId());
- }catch (Exception e) {
- e.printStackTrace();
- } finally {
- lock.unlock();
- }
- }else {
- return ResultUtil.error("系统繁忙，请稍后再试！");
- }
- return ResultUtil.success(baseWarpper);
- }
-
- /**
- * 下单后继续等待
- * @param id
- * @return
- * @throws Exception
- */
- @Override
- public ResultUtil pushOrderPrivateCar(Integer id) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(id);
- if(null == orderPrivateCar){
- return ResultUtil.error("推送订单失败，订单信息有误");
- }
- if(orderPrivateCar.getState() != 1){
- return ResultUtil.error("订单已被司机接单，不能重复推送");
- }
- //处理摆渡订单的继续推单操作
- if(orderPrivateCar.getType() == 2){
- OrderCrossCityServiceImpl.pushEndMap.put(orderPrivateCar.getCrossCityOrderId(), false);//还原标识数据
- List<OrderPrivateCar> list = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
- List<Map<String, Integer>> orders = new ArrayList<>();
- for(OrderPrivateCar orderPrivateCar1 : list){
- if(orderPrivateCar1.getState() != 1){
- return ResultUtil.error("订单已被司机接单，推单取消");
- }
- Map<String, Integer> map = new HashMap<>();
- map.put("orderType", 1);
- map.put("orderId", orderPrivateCar1.getId());
- orders.add(map);
- }
- List<OrderTaxi> list1 = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
- for(OrderTaxi orderTaxi : list1){
- if(orderTaxi.getState() != 1){
- return ResultUtil.error("订单已被司机接单，推单取消");
- }
- Map<String, Integer> map = new HashMap<>();
- map.put("orderType", 2);
- map.put("orderId", orderTaxi.getId());
- orders.add(map);
- }
- //开始重新推单
- orderCrossCityService.pushOrder(orders);
-
- }else{
- //判断独享，一口价，拼车
- if(orderPrivateCar.getRideType()!=3){
- this.pushOrder(orderPrivateCar);
- }else{
- OrderPrivateCar orderPrivateCar1 = null;
- //判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
- List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).in("state","2,3,4").le("totalPeopleNum",4-orderPrivateCar.getPeopleNum()));
- for(OrderPrivateCar order:orderList){
- TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
- if(spellOrderRule!=null){
- JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
- //判断时间
- if(orderPrivateCar.getTravelTime().getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")*60000L && orderPrivateCar.getTravelTime().getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")*60000L){
+
+ public static List<Integer> orderIds = new ArrayList<>();
+ @Resource
+ private OrderPrivateCarMapper orderPrivateCarMapper;
+ @Resource
+ private CarServiceMapper carServiceMapper;
+ @Resource
+ private OrderTaxiMapper orderTaxiMapper;
+ @Resource
+ private SensitiveWordsMapper sensitiveWordsMapper;
+ @Resource
+ private UserActivityDiscount1Mapper userActivityDiscount1Mapper;
+ @Resource
+ private SysIntegralMapper sysIntegralMapper;
+ @Resource
+ private OrderCrossCityMapper orderCrossCityMapper;
+ @Resource
+ private RegionMapper regionMapper;
+ @Autowired
+ private DateUtil dateUtil;
+ @Autowired
+ private IUserInfoService userInfoService;
+ @Autowired
+ private IDriverService driverService;
+ @Autowired
+ private IDriverServiceService driverServiceService;
+ @Autowired
+ private PushUtil pushUtil;
+ @Autowired
+ private ICompanyCityService companyCityService;
+ @Autowired
+ private IPushOrderService pushOrderService;
+ @Autowired
+ private ISystemNoticeService systemNoticeService;
+ @Autowired
+ private ICancleOrderService cancleOrderService;
+ @Autowired
+ private IOrderCancelService orderCancelService;
+ @Autowired
+ private RestTemplate internalRestTemplate;
+ @Autowired
+ private IPaymentRecordService paymentRecordService;
+ @Autowired
+ private ITransactionDetailsService transactionDetailsService;
+ @Autowired
+ private ChinaMobileUtil chinaMobileUtil;
+ @Autowired
+ private IIncomeService incomeService;
+ @Autowired
+ private IUserCouponRecordService userCouponRecordService;
+ @Autowired
+ private IUserRedPacketRecordService userRedPacketRecordService;
+ @Autowired
+ private ICompanyService companyService;
+ @Autowired
+ private IUserActivityRedenvelopeService userActivityRedenvelopeService;
+ @Resource
+ private RedisTemplate<String, Object> redisTemplate;
+ @Autowired
+ private GDFalconUtil gdFalconUtil;
+ @Autowired
+ private GDMapGeocodingUtil gdMapGeocodingUtil;
+ @Autowired
+ private GDMapElectricFenceUtil gdMapElectricFenceUtil;
+ @Autowired
+ private IOrderPositionService orderPositionService;
+ @Autowired
+ private PushMinistryOfTransportUtil pushMinistryOfTransportUtil;
+ @Autowired
+ private IOrderCrossCityService orderCrossCityService;
+ @Autowired
+ private IOrderTaxiService orderTaxiService;
+ @Autowired
+ private PayMoneyUtil payMoneyUtil;
+ @Autowired
+ private IOrderLogisticsService orderLogisticsService;
+ @Autowired
+ private ITaxiCardPaymentService taxiCardPaymentService;
+ @Autowired
+ private ITaxiCardService taxiCardService;
+ @Autowired
+ private IOpenCityService openCityService;
+ @Autowired
+ private IUserUserService userUserService;
+ @Autowired
+ private IUserTaxiCardService userTaxiCardService;
+ @Autowired
+ private IRegionService regionService;
+ @Value("${callbackPath}")
+ private String callbackPath;
+
+ @Value("${pushMinistryOfTransport}")
+ private boolean pushMinistryOfTransport;
+
+ @Autowired
+ private ITbSpellOrderRuleService spellOrderRuleService;
+
+ @Autowired
+ private GeodesyUtil geodesyUtil;
+
+ private Lock lock = new ReentrantLock();
+ @Autowired
+ private AppOrderController appOrderController;
+
+ /**
+ * 专车下单操作
+ *
+ * @param serverCarModelId 服务车型id
+ * @param travelTime 出行时间
+ * @param reservation 是否预约（1=否，2=是）
+ * @param instead 是否代下单（0=否，1=是）
+ * @param startLon 起点经度
+ * @param startLat 起点纬度
+ * @param startAddress 起点详细地址
+ * @param endLon 终点经度
+ * @param endLat 终点纬度
+ * @param endAddress 终点详细地址
+ * @param name 乘客姓名
+ * @param phone 乘客电话
+ * @return
+ * @throws Exception
+ */
+ @Override
+ public synchronized ResultUtil<BaseWarpper> saveOrderPrivateCar(Integer serverCarModelId, Date travelTime, Integer reservation, Integer instead, String placementLon, String placementLat, String startLon, String startLat,
+ String startAddress, String endLon, String endLat, String endAddress, String name, String phone, Integer orderSource, Integer driverId, Integer type, Integer uid, Integer peopleNum, Integer rideType) throws Exception {
+ BaseWarpper baseWarpper = new BaseWarpper();
+ if (lock.tryLock()) {
+ try {
+ //如果出行时间大于当前10分钟则默认为预约单
+ if (travelTime.getTime() > (System.currentTimeMillis() + 600000)) {
+ reservation = 2;
+ }
+ /**
+ * 1.出租车、专车、跨城有待支付的订单不能叫车
+ * 2.小件物流有未完成的订单可以下跨城、专车、出租车
+ * 3.出租车、专车、跨城有预约单可以下即时单
+ */
+ List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
+ if (orderPrivateCars.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
+ if (list.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
+ if (orderCrossCities1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ if (reservation == 1) {
+ orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
+ if (orderPrivateCars.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
+ if (list.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ }
+
+ List<OrderPrivateCar> orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, null, 3, 7, 12);
+ if (orderPrivateCars1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ List<OrderTaxi> list1 = orderTaxiMapper.queryByState_(uid, null, 3, 7, 12);
+ if (list1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ List<OrderCrossCity> orderCrossCities11 = orderCrossCityMapper.queryByState(uid, 7, 12);
+ if (orderCrossCities11.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ if (reservation == 1) {
+ orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
+ if (orderPrivateCars1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ list1 = orderTaxiMapper.queryByState_(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
+ if (list1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ }
+
+
+ startAddress = startAddress.replaceAll("& #40;", "(");
+ startAddress = startAddress.replaceAll("& #41;", ")");
+ endAddress = endAddress.replaceAll("& #40;", "(");
+ endAddress = endAddress.replaceAll("& #41;", ")");
+ if ((orderSource == 1 || orderSource == 3) && null == serverCarModelId) {
+ return ResultUtil.error("请选择服务车型");
+ }
+
+ OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
+ orderPrivateCar.setPeopleNum(peopleNum);
+ orderPrivateCar.setRideType(rideType);
+ orderPrivateCar.setType(type);
+ orderPrivateCar.setUserId(uid);
+ orderPrivateCar.setServerCarModelId(serverCarModelId);
+ orderPrivateCar.setOrderNum(this.getOrderNum());
+ orderPrivateCar.setPlacementLon(Double.valueOf(placementLon));
+ orderPrivateCar.setPlacementLat(Double.valueOf(placementLat));
+ Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
+ orderPrivateCar.setPlacementAddress(geocode.get("address"));
+ orderPrivateCar.setStartLon(Double.valueOf(startLon));
+ orderPrivateCar.setStartLat(Double.valueOf(startLat));
+ orderPrivateCar.setStartAddress(startAddress);
+ orderPrivateCar.setEndLon(Double.valueOf(endLon));
+ orderPrivateCar.setEndLat(Double.valueOf(endLat));
+ orderPrivateCar.setEndAddress(endAddress);
+ orderPrivateCar.setSubstitute(instead);
+ orderPrivateCar.setPassengers(name);
+ orderPrivateCar.setPassengersPhone(phone);
+ // TODO: 2023/11/4 无法修改
+ Map<String, String> distanceMap = gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
+ orderPrivateCar.setEstimateMileage(Double.valueOf(distanceMap.get("distance")));
+ orderPrivateCar.setEstimateTime(Double.valueOf(distanceMap.get("duration")) / 60);
+ if (instead == 0 || ToolUtil.isEmpty(orderPrivateCar.getPassengers())) {
+ UserInfo userInfo = userInfoService.selectById(uid);
+ if (ToolUtil.isEmpty(userInfo.getPhone())) {
+ return ResultUtil.error("请先绑定手机号码");
+ }
+ orderPrivateCar.setPassengers(userInfo.getName());
+ orderPrivateCar.setPassengersPhone(userInfo.getPhone());
+ }
+ orderPrivateCar.setState(1);
+ orderPrivateCar.setInsertTime(new Date());
+ orderPrivateCar.setTravelTime(travelTime);
+ orderPrivateCar.setOrderType(reservation);
+ orderPrivateCar.setOrderSource(orderSource);
+ if (orderSource == 2) {//扫码下单
+ Driver driver = driverService.selectById(driverId);
+ if (null == driver) {
+ return ResultUtil.error("司机信息有误，无法完成下单");
+ }
+ if (driver.getAuthState() == 1) {
+ return ResultUtil.error("司机信息还未完成审核，无法完成下单");
+ }
+ if (driver.getAuthState() == 3) {
+ return ResultUtil.error("司机账户已被冻结，无法提供服务");
+ }
+ if (driver.getAuthState() == 4) {
+ return ResultUtil.error("司机信息未通过审核，无法提供服务");
+ }
+ if (driver.getState() == 1) {
+ return ResultUtil.error("司机还未上线，无法提供服务");
+ }
+ if (driver.getState() == 3) {
+ return ResultUtil.error("司机正在服务中，无法提供服务");
+ }
+ // Integer orderType = orderPrivateCar.getRideType()==1?1:orderPrivateCar.getRideType()==2?9:8;
+ Integer orderType = 1;
+ Integer integer = driverServiceService.query_(driverId, orderType);
+ if (null == integer) {
+ return ResultUtil.error("该司机不能服务此业务");
+ }
+
+ orderPrivateCar.setDriverId(driverId);
+ orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
+ driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
+ orderPrivateCar.setState(2);
+ orderPrivateCar.setCarId(driver.getCarId());
+ CarService query1 = carServiceMapper.query(1, driver.getCarId());
+ orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
+ orderPrivateCar.setSnatchOrderTime(new Date());
+
+ // //调用高德创建轨迹
+ // String s = gdFalconUtil.selectTerminal(driver.getPhone());
+ // String track = gdFalconUtil.createTrack(s);
+ // orderPrivateCar.setTrackId(track);
+ //
+ //调用移动的小号接口
+// Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
+// if (String.valueOf(map.get("code")).equals("200")) {
+// orderPrivateCar.setTelX(map.get("telX"));
+// orderPrivateCar.setBindId(map.get("bindId"));
+// }
+
+ driver.setState(3);
+ driverService.updateById(driver);
+ }
+ //判断独享，一口价，拼车
+ if (orderPrivateCar.getRideType() != 3) {
+ orderPrivateCar.setTotalPeopleNum(peopleNum);
+ orderPrivateCar.setIsReassign(1);
+ orderPrivateCar.setIsDelete(1);
+ this.insert(orderPrivateCar);
+
+ if (orderSource == 2) {//扫码下单
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
+ pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0);
+ pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
+ }
+ }).start();
+ }
+
+ //推单操作-独享
+ if (orderPrivateCar.getState() == 1) {
+ this.pushOrder(orderPrivateCar);
+ }
+ } else {
+ OrderPrivateCar orderPrivateCar1 = null;
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ //判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
+ List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).in("state", "2,3,4").le("totalPeopleNum", 4 - peopleNum));
+ for (OrderPrivateCar order : orderList) {
+
+ TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
+ if (spellOrderRule != null) {
+ JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
+ //判断时间
+
+ if (travelTime.getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && travelTime.getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
+ // Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
+ // Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
+ // TODO: 2023/11/4 已改成计算直线距离
+ Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
+ Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
+ //判断距离
+ if (dis1 <= jsonObject.getInteger("num1") * 1000 && dis2 <= jsonObject.getInteger("num2") * 1000) {
+ orderPrivateCar1 = order;
+ break;
+ }
+ }
+ }
+ }
+ if (orderPrivateCar1 == null) {
+ orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).eq("state", 5).le("totalPeopleNum", 4 - peopleNum));
+ for (OrderPrivateCar order : orderList) {
+ TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
+ if (spellOrderRule != null) {
+ JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
+ //判断时间
+ if (travelTime.getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && travelTime.getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
+ String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
+ // Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
+ // Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
+
+ // TODO: 2023/11/4 已改成计算直线距离
+ Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
+ Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
+ //判断距离
+ if (dis1 <= jsonObject.getInteger("num3") * 1000 && dis2 <= jsonObject.getInteger("num4") * 1000) {
+ orderPrivateCar1 = order;
+ break;
+ }
+ }
+ }
+ }
+ }
+ if (orderPrivateCar1 == null) {
+ orderPrivateCar.setTotalPeopleNum(peopleNum);
+ orderPrivateCar.setIsReassign(1);
+ orderPrivateCar.setIsDelete(1);
+ this.insert(orderPrivateCar);
+ this.pushOrder(orderPrivateCar);
+ } else {
+ Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
+ orderPrivateCar.setDriverId(driverId);
+ orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
+ driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
+ orderPrivateCar.setState(2);
+ orderPrivateCar.setDriverId(driver.getId());
+ orderPrivateCar.setCarId(driver.getCarId());
+ CarService query1 = carServiceMapper.query(1, driver.getCarId());
+ orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
+ orderPrivateCar.setSnatchOrderTime(new Date());
+ orderPrivateCar.setTotalPeopleNum(peopleNum + orderPrivateCar1.getTotalPeopleNum());
+ orderPrivateCar.setIsReassign(1);
+ orderPrivateCar.setIsDelete(1);
+ orderPrivateCar.setPid(orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid());
+ this.insert(orderPrivateCar);
+ //修改总订单人数
+ OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
+ orderPrivateCar2.setSpellSuccess(1);
+ orderPrivateCar2.setTotalPeopleNum(peopleNum + orderPrivateCar1.getTotalPeopleNum());
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
+ //
+ //调用移动的小号接口
+// Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
+// if (String.valueOf(map.get("code")).equals("200")) {
+// orderPrivateCar.setTelX(map.get("telX"));
+// orderPrivateCar.setBindId(map.get("bindId"));
+// }
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
+ pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
+ pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
+
+ }
+ }).start();
+ List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid()));
+ for (OrderPrivateCar orderPrivateCar3 : orderList1) {
+ pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
+ }
+ OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
+ pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
+ }
+
+ }
+
+
+ //添加消息
+ systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);
+ baseWarpper.setId(orderPrivateCar.getId());
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ lock.unlock();
+ }
+ } else {
+ return ResultUtil.error("系统繁忙，请稍后再试！");
+ }
+ return ResultUtil.success(baseWarpper);
+ }
+
+ /**
+ * 批量订单
+ *
+ * @throws Exception
+ */
+ @Override
+ public ResultUtil<BaseWarpper> saveOrderPrivateCars(String serverCarModel, Date travelTime, Integer reservation, Integer instead, String placementLon, String placementLat, String startLon, String startLat, String startAddress, String endLon,
+ String endLat, String endAddress, String name, String phone, Integer orderSource, Integer driverId, Integer uid, Integer peopleNum) throws Exception {
+ BaseWarpper baseWarpper = new BaseWarpper();
+ String key = "saveOrderPrivateCar:" + uid;
+ Boolean hasKey = redisTemplate.hasKey(key);
+ if (!hasKey) {
+ redisTemplate.opsForValue().set(key, uid, 30, TimeUnit.SECONDS);
+ try {
+ //如果出行时间大于当前10分钟则默认为预约单
+ if (travelTime.getTime() > (System.currentTimeMillis() + 600000)) {
+ reservation = 2;
+ }
+
+ /**
+ * 1.出租车、专车、跨城有待支付的订单不能叫车
+ * 2.小件物流有未完成的订单可以下跨城、专车、出租车
+ * 3.出租车、专车、跨城有预约单可以下即时单
+ */
+ List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
+ if (orderPrivateCars.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
+ if (list.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
+ if (orderCrossCities1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ if (reservation == 1) {
+ orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
+ if (orderPrivateCars.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
+ if (list.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ }
+
+
+ List<OrderPrivateCar> orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, null, 3, 7, 12);
+ if (orderPrivateCars1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ List<OrderTaxi> list1 = orderTaxiMapper.queryByState_(uid, null, 3, 7, 12);
+ if (list1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ List<OrderCrossCity> orderCrossCities11 = orderCrossCityMapper.queryByState(uid, 7, 12);
+ if (orderCrossCities11.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ if (reservation == 1) {
+ orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
+ if (orderPrivateCars1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ list1 = orderTaxiMapper.queryByState_(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
+ if (list1.size() > 0) {
+ return ResultUtil.error("有未完成的订单");
+ }
+ }
+
+ startAddress = startAddress.replaceAll("& #40;", "(");
+ startAddress = startAddress.replaceAll("& #41;", ")");
+ endAddress = endAddress.replaceAll("& #40;", "(");
+ endAddress = endAddress.replaceAll("& #41;", ")");
+ if (ToolUtil.isEmpty(serverCarModel)) {
+ return ResultUtil.error("请选择服务车型");
+ }
+
+ OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
+ orderPrivateCar.setPeopleNum(peopleNum);
+ orderPrivateCar.setType(3);
+ orderPrivateCar.setUserId(uid);
+ orderPrivateCar.setServerCarModel(serverCarModel);
+ orderPrivateCar.setOrderNum(this.getOrderNum());
+ orderPrivateCar.setPlacementLon(Double.valueOf(placementLon));
+ orderPrivateCar.setPlacementLat(Double.valueOf(placementLat));
+ Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
+ orderPrivateCar.setPlacementAddress(geocode.get("address"));
+ orderPrivateCar.setStartLon(Double.valueOf(startLon));
+ orderPrivateCar.setStartLat(Double.valueOf(startLat));
+ orderPrivateCar.setStartAddress(startAddress);
+ orderPrivateCar.setEndLon(Double.valueOf(endLon));
+ orderPrivateCar.setEndLat(Double.valueOf(endLat));
+ orderPrivateCar.setEndAddress(endAddress);
+ orderPrivateCar.setSubstitute(instead);
+ orderPrivateCar.setPassengers(name);
+ orderPrivateCar.setPassengersPhone(phone);
+ // TODO: 2023/11/4 无法修改
+ Map<String, String> distanceMap = gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
+ orderPrivateCar.setEstimateMileage(Double.valueOf(distanceMap.get("distance")));
+ orderPrivateCar.setEstimateTime(Double.valueOf(distanceMap.get("duration")) / 60);
+ if (instead == 0 || ToolUtil.isEmpty(orderPrivateCar.getPassengers())) {
+ UserInfo userInfo = userInfoService.selectById(uid);
+ if (ToolUtil.isEmpty(userInfo.getPhone())) {
+ return ResultUtil.error("请先绑定手机号码");
+ }
+ orderPrivateCar.setPassengers(userInfo.getName());
+ orderPrivateCar.setPassengersPhone(userInfo.getPhone());
+ }
+ orderPrivateCar.setState(1);
+ orderPrivateCar.setInsertTime(new Date());
+ orderPrivateCar.setTravelTime(travelTime);
+ orderPrivateCar.setOrderType(reservation);
+ orderPrivateCar.setOrderSource(orderSource);
+ orderPrivateCar.setTotalPeopleNum(peopleNum);
+ orderPrivateCar.setIsReassign(1);
+ orderPrivateCar.setIsDelete(1);
+ this.insert(orderPrivateCar);
+
+ //判断独享，一口价，拼车
+ JSONArray jsonArray = JSON.parseArray(serverCarModel);
+ for (int i = 0; i < jsonArray.size(); i++) {
+ JSONObject jsonObject1 = jsonArray.getJSONObject(i);
+ Integer serverCarModelId = jsonObject1.getInteger("serverCarModelId");
+ Integer rideType = jsonObject1.getInteger("rideType");
+ if (0 == serverCarModelId) {
+ OrderTaxi orderTaxi = new OrderTaxi();
+ orderTaxi.setId(orderPrivateCar.getId());
+ orderTaxi.setState(1);
+ orderTaxi.setUserId(orderPrivateCar.getUserId());
+ orderTaxi.setStartLon(orderPrivateCar.getStartLon());
+ orderTaxi.setStartLat(orderPrivateCar.getStartLat());
+ orderTaxiService.pushOrder(orderTaxi, 3);
+ }
+
+ if (rideType != 3) {
+ //推单操作-独享
+ this.pushOrder(orderPrivateCar.getId(), rideType, serverCarModelId, orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat());
+ } else {
+ OrderPrivateCar orderPrivateCar1 = null;
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ //判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
+ List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).in("state", "2,3,4").le("totalPeopleNum", 4 - peopleNum));
+ for (OrderPrivateCar order : orderList) {
+ TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
+ if (spellOrderRule != null) {
+ JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
+ //判断时间
+
+ if (travelTime.getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && travelTime.getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
+ // Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
+ // Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
+ // TODO: 2023/11/4 已改成计算直线距离
+ Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
+ Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
+ //判断距离
+ if (dis1 <= jsonObject.getInteger("num1") * 1000 && dis2 <= jsonObject.getInteger("num2") * 1000) {
+ orderPrivateCar1 = order;
+ break;
+ }
+ }
+ }
+ }
+ if (orderPrivateCar1 == null) {
+ orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).eq("state", 5).le("totalPeopleNum", 4 - peopleNum));
+ for (OrderPrivateCar order : orderList) {
+ TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
+ if (spellOrderRule != null) {
+ JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
+ //判断时间
+ if (travelTime.getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && travelTime.getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
+ String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
+ // Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
+ // Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
+
+ // TODO: 2023/11/4 已改成计算直线距离
+ Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
+ Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
+ //判断距离
+ if (dis1 <= jsonObject.getInteger("num3") * 1000 && dis2 <= jsonObject.getInteger("num4") * 1000) {
+ orderPrivateCar1 = order;
+ break;
+ }
+ }
+ }
+ }
+ }
+ if (orderPrivateCar1 == null) {
+ this.pushOrder(orderPrivateCar.getId(), rideType, serverCarModelId, orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat());
+ } else {
+ Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
+ orderPrivateCar.setDriverId(driverId);
+ orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
+ driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
+ orderPrivateCar.setState(2);
+ orderPrivateCar.setDriverId(driver.getId());
+ orderPrivateCar.setCarId(driver.getCarId());
+ CarService query1 = carServiceMapper.query(1, driver.getCarId());
+ orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
+ orderPrivateCar.setRideType(3);
+ orderPrivateCar.setSnatchOrderTime(new Date());
+ orderPrivateCar.setTotalPeopleNum(peopleNum + orderPrivateCar1.getTotalPeopleNum());
+ orderPrivateCar.setIsReassign(1);
+ orderPrivateCar.setIsDelete(1);
+ orderPrivateCar.setPid(orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid());
+ this.insertOrUpdate(orderPrivateCar);
+ //修改总订单人数
+ OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
+ orderPrivateCar2.setSpellSuccess(1);
+ orderPrivateCar2.setTotalPeopleNum(peopleNum + orderPrivateCar1.getTotalPeopleNum());
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
+ //
+ //调用移动的小号接口
+// Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
+// if (String.valueOf(map.get("code")).equals("200")) {
+// orderPrivateCar.setTelX(map.get("telX"));
+// orderPrivateCar.setBindId(map.get("bindId"));
+// }
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
+ pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
+ pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
+
+ }
+ }).start();
+ List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid()));
+ for (OrderPrivateCar orderPrivateCar3 : orderList1) {
+ pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
+ }
+ OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
+ pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
+ }
+ }
+ }
+
+ //添加消息
+ systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);
+
+ baseWarpper.setId(orderPrivateCar.getId());
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ redisTemplate.delete(key);
+ }
+ } else {
+ return ResultUtil.error("系统繁忙，请稍后再试！");
+ }
+ return ResultUtil.success(baseWarpper);
+ }
+
+ /**
+ * 下单后继续等待
+ *
+ * @param id
+ * @return
+ * @throws Exception
+ */
+ @Override
+ public ResultUtil pushOrderPrivateCar(Integer id) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(id);
+ if (null == orderPrivateCar) {
+ return ResultUtil.error("推送订单失败，订单信息有误");
+ }
+ if (orderPrivateCar.getState() != 1) {
+ return ResultUtil.error("订单已被司机接单，不能重复推送");
+ }
+ //处理摆渡订单的继续推单操作
+ if (orderPrivateCar.getType() == 2) {
+ OrderCrossCityServiceImpl.pushEndMap.put(orderPrivateCar.getCrossCityOrderId(), false);//还原标识数据
+ List<OrderPrivateCar> list = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
+ List<Map<String, Integer>> orders = new ArrayList<>();
+ for (OrderPrivateCar orderPrivateCar1 : list) {
+ if (orderPrivateCar1.getState() != 1) {
+ return ResultUtil.error("订单已被司机接单，推单取消");
+ }
+ Map<String, Integer> map = new HashMap<>();
+ map.put("orderType", 1);
+ map.put("orderId", orderPrivateCar1.getId());
+ orders.add(map);
+ }
+ List<OrderTaxi> list1 = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
+ for (OrderTaxi orderTaxi : list1) {
+ if (orderTaxi.getState() != 1) {
+ return ResultUtil.error("订单已被司机接单，推单取消");
+ }
+ Map<String, Integer> map = new HashMap<>();
+ map.put("orderType", 2);
+ map.put("orderId", orderTaxi.getId());
+ orders.add(map);
+ }
+ //开始重新推单
+ orderCrossCityService.pushOrder(orders);
+
+ } else {
+ //判断独享，一口价，拼车
+ if (orderPrivateCar.getRideType() != 3) {
+ this.pushOrder(orderPrivateCar);
+ } else {
+ OrderPrivateCar orderPrivateCar1 = null;
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ //判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
+ List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).in("state", "2,3,4").le("totalPeopleNum", 4 - orderPrivateCar.getPeopleNum()));
+ for (OrderPrivateCar order : orderList) {
+ TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
+ if (spellOrderRule != null) {
+ JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
+ //判断时间
+ if (orderPrivateCar.getTravelTime().getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && orderPrivateCar.getTravelTime().getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
- // TODO: 2023/11/4 已改成计算直线距离
- Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
- Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
- //判断距离
- if(dis1<=jsonObject.getInteger("num1")*1000 && dis2<=jsonObject.getInteger("num2")*1000){
- orderPrivateCar1=orderPrivateCar;
- break;
- }
- }
- }
- }
- if(orderPrivateCar1==null){
- orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).eq("state",5).le("totalPeopleNum",4-orderPrivateCar.getPeopleNum()));
- for(OrderPrivateCar order:orderList){
- TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
- if(spellOrderRule!=null){
- JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
- //判断时间
- if(orderPrivateCar.getTravelTime().getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")*60000L && orderPrivateCar.getTravelTime().getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")*60000L){
- String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
+ // TODO: 2023/11/4 已改成计算直线距离
+ Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
+ Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
+ //判断距离
+ if (dis1 <= jsonObject.getInteger("num1") * 1000 && dis2 <= jsonObject.getInteger("num2") * 1000) {
+ orderPrivateCar1 = orderPrivateCar;
+ break;
+ }
+ }
+ }
+ }
+ if (orderPrivateCar1 == null) {
+ orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).eq("state", 5).le("totalPeopleNum", 4 - orderPrivateCar.getPeopleNum()));
+ for (OrderPrivateCar order : orderList) {
+ TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
+ if (spellOrderRule != null) {
+ JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
+ //判断时间
+ if (orderPrivateCar.getTravelTime().getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && orderPrivateCar.getTravelTime().getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
+ String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
- // TODO: 2023/11/4 已改成计算直线距离
- Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
- Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
- //判断距离
- if(dis1<=jsonObject.getInteger("num3")*1000 && dis2<=jsonObject.getInteger("num4")*1000){
- orderPrivateCar1=order;
- break;
- }
- }
- }
- }
- }
- if(orderPrivateCar1==null){
- this.pushOrder(orderPrivateCar);
- }else{
- Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
- orderPrivateCar.setDriverId(orderPrivateCar1.getDriverId());
- orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
- driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
- orderPrivateCar.setState(2);
- orderPrivateCar.setCarId(driver.getCarId());
- orderPrivateCar.setDriverId(driver.getId());
- CarService query1 = carServiceMapper.query(1, driver.getCarId());
- orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
- orderPrivateCar.setSnatchOrderTime(new Date());
-
- orderPrivateCar.setTotalPeopleNum(orderPrivateCar.getPeopleNum()+orderPrivateCar1.getTotalPeopleNum());
- orderPrivateCar.setPid(orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid());
- orderPrivateCar.setIsReassign(1);
- orderPrivateCar.setIsDelete(1);
- this.updateById(orderPrivateCar);
- //修改总订单人数
- OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
- orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getPeopleNum()+orderPrivateCar1.getTotalPeopleNum());
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
- //调用移动的小号接口
- Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
- if(String.valueOf(map.get("code")).equals("200")){
- orderPrivateCar.setTelX(map.get("telX"));
- orderPrivateCar.setBindId(map.get("bindId"));
- }
- new Thread(new Runnable() {
- @Override
- public void run() {
- pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, 2, 0);
- pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
- pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
- }
- }).start();
- List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()));
- for(OrderPrivateCar orderPrivateCar3:orderList1){
- pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
- }
- OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
- pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
- }
- }
-
- }
- return ResultUtil.success();
- }
-
- @Override
- public ResultUtil<BaseWarpper> queryCancleAmount(Integer id) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(id);
- if(null == orderPrivateCar){
- return ResultUtil.error("获取数据失败，订单信息有误");
- }
- double amount = 0;
- CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, orderPrivateCar.getCompanyId());
- if(null != orderPrivateCar.getDriverId() &&
- (orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < new Date().getTime()){//收费的情况
- if(null != query){
- amount += query.getMoney();
- }
- }
- BaseWarpper baseWarpper = new BaseWarpper();
- baseWarpper.setAmount(amount);
- return ResultUtil.success(baseWarpper);
- }
-
- @Override
- public ResultUtil addCancle(Integer id, String reason, String remark, Integer uid) throws Exception {
- if(ToolUtil.isNotEmpty(remark)){
- if(ToolUtil.isNotEmpty(remark)){
- List<SensitiveWords> sensitiveWords = sensitiveWordsMapper.selectList(null);
- for(SensitiveWords s : sensitiveWords){
- remark = remark.replaceAll(s.getContent(), "***");
- }
- }
- }
-
- OrderPrivateCar orderPrivateCar = this.selectById(id);
- Integer integer = null;
- if(null == orderPrivateCar){
- return ResultUtil.error("取消订单失败，订单信息有误");
- }
+ // TODO: 2023/11/4 已改成计算直线距离
+ Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
+ Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
+ //判断距离
+ if (dis1 <= jsonObject.getInteger("num3") * 1000 && dis2 <= jsonObject.getInteger("num4") * 1000) {
+ orderPrivateCar1 = order;
+ break;
+ }
+ }
+ }
+ }
+ }
+ if (orderPrivateCar1 == null) {
+ this.pushOrder(orderPrivateCar);
+ } else {
+ Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
+ orderPrivateCar.setDriverId(orderPrivateCar1.getDriverId());
+ orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
+ driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
+ orderPrivateCar.setState(2);
+ orderPrivateCar.setCarId(driver.getCarId());
+ orderPrivateCar.setDriverId(driver.getId());
+ CarService query1 = carServiceMapper.query(1, driver.getCarId());
+ orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
+ orderPrivateCar.setSnatchOrderTime(new Date());
+
+ orderPrivateCar.setTotalPeopleNum(orderPrivateCar.getPeopleNum() + orderPrivateCar1.getTotalPeopleNum());
+ orderPrivateCar.setPid(orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid());
+ orderPrivateCar.setIsReassign(1);
+ orderPrivateCar.setIsDelete(1);
+ this.updateById(orderPrivateCar);
+ //修改总订单人数
+ OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
+ orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getPeopleNum() + orderPrivateCar1.getTotalPeopleNum());
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
+ //调用移动的小号接口
+// Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
+// if (String.valueOf(map.get("code")).equals("200")) {
+// orderPrivateCar.setTelX(map.get("telX"));
+// orderPrivateCar.setBindId(map.get("bindId"));
+// }
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, 2, 0);
+ pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
+ pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
+ }
+ }).start();
+ List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid()));
+ for (OrderPrivateCar orderPrivateCar3 : orderList1) {
+ pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
+ }
+ OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
+ pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
+ }
+ }
+
+ }
+ return ResultUtil.success();
+ }
+
+ @Override
+ public ResultUtil<BaseWarpper> queryCancleAmount(Integer id) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(id);
+ if (null == orderPrivateCar) {
+ return ResultUtil.error("获取数据失败，订单信息有误");
+ }
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ double amount = 0;
+ CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, openCity.getId());
+ if (null != orderPrivateCar.getDriverId() &&
+ (orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < new Date().getTime()) {//收费的情况
+ if (null != query) {
+ amount += query.getMoney();
+ }
+ }
+ BaseWarpper baseWarpper = new BaseWarpper();
+ baseWarpper.setAmount(amount);
+ return ResultUtil.success(baseWarpper);
+ }
+
+ @Override
+ public ResultUtil addCancle(Integer id, String reason, String remark, Integer uid) throws Exception {
+ if (ToolUtil.isNotEmpty(remark)) {
+ if (ToolUtil.isNotEmpty(remark)) {
+ List<SensitiveWords> sensitiveWords = sensitiveWordsMapper.selectList(null);
+ for (SensitiveWords s : sensitiveWords) {
+ remark = remark.replaceAll(s.getContent(), "***");
+ }
+ }
+ }
+
+ OrderPrivateCar orderPrivateCar = this.selectById(id);
+ Integer integer = null;
+ if (null == orderPrivateCar) {
+ return ResultUtil.error("取消订单失败，订单信息有误");
+ }
// if(orderPrivateCar.getState() == 4){
// return ResultUtil.error("司机已到达预约点，取消会产生一定的费用");
// }
- if(orderPrivateCar.getState() >= 5 && orderPrivateCar.getState() != 11){
- return ResultUtil.error("取消订单失败，不合法的操作");
- }
- Integer number1 = this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
- Integer number2 = this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
- if(number1+number2==1){
- OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
- orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getTotalPeopleNum()-orderPrivateCar.getPeopleNum());
- orderPrivateCar2.setSpellSuccess(0);
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
-
- }else{
- OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
- orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getTotalPeopleNum()-orderPrivateCar.getPeopleNum());
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
- this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
- }
- if(null == orderPrivateCar.getDriverId()){//没有接单的情况
- if(orderPrivateCar.getType() == 2){//摆渡车
- OrderCrossCityServiceImpl.pushEndMap.remove(orderPrivateCar.getCrossCityOrderId());//删除标识数据
- List<OrderPrivateCar> list = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
- for(OrderPrivateCar orderPrivateCar1 : list){
- orderCancelService.saveData(orderPrivateCar1.getId(), 1, "无司机接单", "无司机接单", null, null, 2, 1, uid);
- orderPrivateCar1.setState(10);
- this.updateById(orderPrivateCar1);
- }
- List<OrderTaxi> list1 = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
- for(OrderTaxi orderTaxi : list1){
- orderCancelService.saveData(orderTaxi.getId(), 2, "无司机接单", "无司机接单", null, null, 2, 1, uid);
- orderTaxi.setState(10);
- orderTaxiService.updateById(orderTaxi);
- }
- }else{
- integer = orderCancelService.saveData(id, 1, "无司机接单", "无司机接单", null, null, 2, 1, uid);
- orderPrivateCar.setState(10);
- this.updateById(orderPrivateCar);
- }
- }else {
- CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, orderPrivateCar.getCompanyId());
- if (null != query) {
- if ((orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < System.currentTimeMillis() && query.getMoney().compareTo(0D) > 0) {//收费的情况
- orderPrivateCar.setState(12);
- this.updateById(orderPrivateCar);
- integer = orderCancelService.saveData(id, 1, reason, remark, null, query.getMoney(), 1, 1, uid);
- } else {
- integer = orderCancelService.saveData(id, 1, reason, remark, null, null, 2, 1, uid);
-
- orderPrivateCar.setState(10);
- this.updateById(orderPrivateCar);
- }
- this.deleteTask(id);//删除定时任务
-
- new Thread(new Runnable() {
- @Override
- public void run() {
- pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
- System.err.println("推送取消操作---------------------");
- }
- }).start();
-
- //修改司机为空闲
- Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
- driver.setState(2);
- driverService.updateById(driver);
-
- // 解绑手机
-
- //解除小号绑定
- if(orderPrivateCar.getBindId() != null){
- Map<String, String> map = chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 86400000));
- }
- }else{
- return ResultUtil.error("请完善后台取消规则设置");
- }
-
- }
-
- new Thread(new Runnable() {
- @Override
- public void run() {
- if(pushMinistryOfTransport){
- //上传数据
- pushMinistryOfTransportUtil.orderCancel(orderPrivateCar.getId());
- }
- }
- }).start();
-
- //添加消息
- systemNoticeService.addSystemNotice(1, "您已成功取消出行订单，谢谢使用！", orderPrivateCar.getUserId(), 1);
- Map<String, Object> map = new HashMap<>();
- map.put("id", integer);
- return ResultUtil.success(map);
- }
-
-
- /**
- * 取消订单操作
- * @param id
- * @return
- * @throws Exception
- */
- @Override
- @Transactional(propagation = Propagation.REQUIRES_NEW)
- public ResultUtil cancleOrderPrivateCar(Integer id, Integer payType, Integer cancleId, Integer type) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(id);
- Integer uid = orderPrivateCar.getUserId();
- UserInfo userInfo = userInfoService.selectById(uid);
- ResultUtil resultUtil = ResultUtil.success(new Object());
-
- if(null == orderPrivateCar){
- return ResultUtil.error("取消订单失败，订单信息有误", "");
- }
- if(orderPrivateCar.getState() != 12){
- return ResultUtil.error("取消订单失败，不合法的操作", "");
- }
- OrderCancel orderCancel = null;
- if(null == cancleId){
- orderCancel = orderCancelService.query(id, 1, null, null, 1);
- }else{
- orderCancel = orderCancelService.selectById(cancleId);
- }
-
- CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, orderPrivateCar.getCompanyId());
- if(null != query){
- if(payType == 1){//微信支付
- String value = (String) redisTemplate.opsForValue().get("appletOpenId");
- String appletsOpenId = null;
- if(ToolUtil.isNotEmpty(value)){
- JSONObject jsonObject = JSON.parseObject(value);
- appletsOpenId = jsonObject.getString(uid.toString());
- }else{
- appletsOpenId = userInfo.getAppletsOpenId();
- }
- orderCancel.setPayType(1);
- orderCancelService.updateById(orderCancel);
- String app = type == 1 ? "APP" : "JSAPI";
- resultUtil = payMoneyUtil.weixinpay("订单取消", "", id + "_1_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/wxCancelOrderTaxi", app, userInfo.getAppletsOpenId());
- paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 1, query.getMoney(), "", 1);//添加预支付数据
- }
- if(payType == 2){//支付宝支付
- orderCancel.setPayType(2);
- orderCancelService.updateById(orderCancel);
-
- resultUtil = payMoneyUtil.alipay("订单取消", "订单取消", "", id + "_1_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/aliCancelOrderTaxi");
- paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 2, query.getMoney(), "", 1);//添加预支付数据
- }
- if(payType == 3){//余额支付
- if (userInfo.getBalance() != null && userInfo.getBalance() < query.getMoney()) {
- return ResultUtil.error("余额不足，无法完成支付");
- }
+ if (orderPrivateCar.getState() >= 5 && orderPrivateCar.getState() != 11) {
+ return ResultUtil.error("取消订单失败，不合法的操作");
+ }
+ Integer number1 = this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
+ Integer number2 = this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
+ if (number1 + number2 == 1) {
+ OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
+ orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getTotalPeopleNum() - orderPrivateCar.getPeopleNum());
+ orderPrivateCar2.setSpellSuccess(0);
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
+
+ } else {
+ OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
+ orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getTotalPeopleNum() - orderPrivateCar.getPeopleNum());
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
+ this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
+ }
+ if (null == orderPrivateCar.getDriverId()) {//没有接单的情况
+ if (orderPrivateCar.getType() == 2) {//摆渡车
+ OrderCrossCityServiceImpl.pushEndMap.remove(orderPrivateCar.getCrossCityOrderId());//删除标识数据
+ List<OrderPrivateCar> list = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
+ for (OrderPrivateCar orderPrivateCar1 : list) {
+ orderCancelService.saveData(orderPrivateCar1.getId(), 1, "无司机接单", "无司机接单", null, null, 2, 1, uid);
+ orderPrivateCar1.setState(10);
+ this.updateById(orderPrivateCar1);
+ }
+ List<OrderTaxi> list1 = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
+ for (OrderTaxi orderTaxi : list1) {
+ orderCancelService.saveData(orderTaxi.getId(), 2, "无司机接单", "无司机接单", null, null, 2, 1, uid);
+ orderTaxi.setState(10);
+ orderTaxiService.updateById(orderTaxi);
+ }
+ } else {
+ integer = orderCancelService.saveData(id, 1, "无司机接单", "无司机接单", null, null, 2, 1, uid);
+ orderPrivateCar.setState(10);
+ this.updateById(orderPrivateCar);
+ }
+ } else {
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, openCity.getId());
+ if (null != query) {
+ if ((orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < System.currentTimeMillis() && query.getMoney().compareTo(0D) > 0) {//收费的情况
+ orderPrivateCar.setState(12);
+ this.updateById(orderPrivateCar);
+ integer = orderCancelService.saveData(id, 1, reason, remark, null, query.getMoney(), 1, 1, uid);
+ } else {
+ integer = orderCancelService.saveData(id, 1, reason, remark, null, null, 2, 1, uid);
+
+ orderPrivateCar.setState(10);
+ this.updateById(orderPrivateCar);
+ }
+ this.deleteTask(id);//删除定时任务
+
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
+ System.err.println("推送取消操作---------------------");
+ }
+ }).start();
+
+ //修改司机为空闲
+ Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
+ driver.setState(2);
+ driverService.updateById(driver);
+
+ // 解绑手机
+
+ //解除小号绑定
+ if (orderPrivateCar.getBindId() != null) {
+ Map<String, String> map = chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 86400000));
+ }
+ } else {
+ return ResultUtil.error("请完善后台取消规则设置");
+ }
+
+ }
+
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ if (pushMinistryOfTransport) {
+ //上传数据
+ pushMinistryOfTransportUtil.orderCancel(orderPrivateCar.getId());
+ }
+ }
+ }).start();
+
+ //添加消息
+ systemNoticeService.addSystemNotice(1, "您已成功取消出行订单，谢谢使用！", orderPrivateCar.getUserId(), 1);
+ Map<String, Object> map = new HashMap<>();
+ map.put("id", integer);
+ return ResultUtil.success(map);
+ }
+
+ /**
+ * 取消订单操作
+ *
+ * @param id
+ * @return
+ * @throws Exception
+ */
+ @Override
+ @Transactional(propagation = Propagation.REQUIRES_NEW)
+ public ResultUtil cancleOrderPrivateCar(Integer id, Integer payType, Integer cancleId, Integer type) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(id);
+ Integer uid = orderPrivateCar.getUserId();
+ UserInfo userInfo = userInfoService.selectById(uid);
+ ResultUtil resultUtil = ResultUtil.success(new Object());
+
+ if (null == orderPrivateCar) {
+ return ResultUtil.error("取消订单失败，订单信息有误", "");
+ }
+ if (orderPrivateCar.getState() != 12) {
+ return ResultUtil.error("取消订单失败，不合法的操作", "");
+ }
+ OrderCancel orderCancel = null;
+ if (null == cancleId) {
+ orderCancel = orderCancelService.query(id, 1, null, null, 1);
+ } else {
+ orderCancel = orderCancelService.selectById(cancleId);
+ }
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, openCity.getId());
+ if (null != query) {
+ if (payType == 1) {//微信支付
+ String value = (String) redisTemplate.opsForValue().get("appletOpenId");
+ String appletsOpenId = null;
+ if (ToolUtil.isNotEmpty(value)) {
+ JSONObject jsonObject = JSON.parseObject(value);
+ appletsOpenId = jsonObject.getString(uid.toString());
+ } else {
+ appletsOpenId = userInfo.getAppletsOpenId();
+ }
+ orderCancel.setPayType(1);
+ orderCancelService.updateById(orderCancel);
+ String app = type == 1 ? "APP" : "JSAPI";
+ resultUtil = payMoneyUtil.weixinpay("订单取消", "", id + "_1_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/wxCancelOrderTaxi", app, userInfo.getAppletsOpenId());
+ paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 1, query.getMoney(), "", 1);//添加预支付数据
+ }
+ if (payType == 2) {//支付宝支付
+ orderCancel.setPayType(2);
+ orderCancelService.updateById(orderCancel);
+
+ resultUtil = payMoneyUtil.alipay("订单取消", "订单取消", "", id + "_1_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/aliCancelOrderTaxi");
+ paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 2, query.getMoney(), "", 1);//添加预支付数据
+ }
+ if (payType == 3) {//余额支付
+ if (userInfo.getBalance() != null && userInfo.getBalance() < query.getMoney()) {
+ return ResultUtil.error("余额不足，无法完成支付");
+ }
// resultUtil= appOrderController.moneyPay(id,userInfo.getId(),query.getMoney());
// if(resultUtil.getCode()==500){
// return ResultUtil.error("电子余额不足，无法完成支付");
// }
- userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(query.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
- //添加交易明细
- transactionDetailsService.saveData(uid, "快车取消订单", query.getMoney(), 2, 1, 1, 1, id);
- userInfoService.updateById(userInfo);
-
- //解除小号绑定
- if (orderPrivateCar.getBindId() != null) {
- chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 600000));
- }
-
- orderPrivateCar.setState(10);
- orderPrivateCar.setTelX("");
- orderPrivateCar.setBindId("");
- this.updateById(orderPrivateCar);
-
- orderCancel.setState(2);
- orderCancel.setPayType(3);
- orderCancelService.updateById(orderCancel);
-
- //添加已收入明细
- incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, query.getMoney());
-
- this.deleteTask(id);//删除定时任务
-
- //添加消息
- systemNoticeService.addSystemNotice(1, "您已使用余额成功支付取消订单费用，谢谢使用！", orderPrivateCar.getUserId(), 1);
-
- }else if(payType == 4){
- Double payMoney = orderPrivateCar.getOrderMoney();
- Integer integer = paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 4, query.getMoney(), "", 1);
- resultUtil = appOrderController.placeAnOrder(new BigDecimal(query.getMoney()), 4,id,1,integer);
-
- }
- }
- return resultUtil;
- }
-
- @Override
- public Map<String, Object> queryOrderInfo(Integer uid, Integer orderId) throws Exception {
- Map<String, Object> map = orderPrivateCarMapper.queryOrderInfo(orderId);
- if(null == map){
- OrderTaxi orderTaxi = orderTaxiService.selectOne(new EntityWrapper<OrderTaxi>()
- .eq("userId", uid)
- .eq("isDelete", 1)
- .in("state", Arrays.asList(2, 3, 4, 5, 6, 7))
- );
- return orderTaxiService.queryOrderInfo(orderTaxi.getId());
- }
- if(null != map.get("reassignNotice") && Integer.valueOf(String.valueOf(map.get("reassignNotice"))) == 2){//改派完成，重新获取了新的司机数据，开始修改数据防止继续调用
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- orderPrivateCar.setReassignNotice(0);
- this.updateById(orderPrivateCar);
- }
- if(Integer.valueOf(String.valueOf(map.get("state"))) == 11){
- map.put("state", map.get("oldState"));
- }
- if(Integer.valueOf(String.valueOf(map.get("state"))) ==7 && (map.get("responsibilityType")==null || Integer.valueOf(String.valueOf(map.get("responsibilityType")))<4)){
- map.put("appealButton", 1);
- }
- if(map.get("abnormalIntro")!=null){
- map.put("appealStatus", 1);
- }
-
-
- if(Integer.valueOf(String.valueOf(map.get("state"))) != 8 && Integer.valueOf(String.valueOf(map.get("state"))) != 9){
- map.put("redPacketMoney", null);
- map.put("couponMoney", null);
- }
-
- String driverId = (String) redisTemplate.opsForValue().get("DEVICE_" + map.get("driverId"));
- map.put("device", ToolUtil.isNotEmpty(driverId) ? 2 : 1);
- map.put("orderType", 1);
- return map;
- }
-
- /**
- * 获取服务中的订单数据
- * @param uid
- * @return
- * @throws Exception
- */
- @Override
- public OrderServerWarpper queryOrderServer(Integer orderId, Integer uid) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- if(null == orderPrivateCar){
- return orderTaxiService.queryOrderServer(orderId, uid);
- }
- //计算预计距离和剩余时间
- String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(orderPrivateCar.getDriverId()));
- if(null == value || "".equals(value)){
- System.err.println("司机没有上传位置信息");
-
- //调用获取轨迹中的数据
- List<Map<String, Object>> list = orderPositionService.queryTrack(orderId, 2);
- if(list.size() > 0){
- Map<String, Object> map = list.get(list.size() - 1);
- value = map.get("lon") + "," + map.get("lat");
- }
-
- }
-
- OrderServerWarpper orderServerWarpper = new OrderServerWarpper();
- orderServerWarpper.setOrderId(orderPrivateCar.getId());
- orderServerWarpper.setOrderType(1);
- orderServerWarpper.setState(orderPrivateCar.getState());
- orderServerWarpper.setLon(null != value ? value.split(",")[0] : "0.0");
- orderServerWarpper.setLat(null != value ? value.split(",")[1] : "0.0");
- orderServerWarpper.setReassignNotice(orderPrivateCar.getReassignNotice());
- if(orderPrivateCar.getState() == 2 || orderPrivateCar.getState() == 3){//前往预约地
- // TODO: 2023/11/4 无法修改
- Map<String, String> distance = gdMapElectricFenceUtil.getDistance(value, orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), 1);
- String d = "0";
- String t = "0";
- if(null == distance){
- System.err.println("查询距离出错了");
- }else{
- d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString();
- t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + "";
- }
- orderServerWarpper.setReservationMileage(d);
- orderServerWarpper.setReservationTime(t);
- orderServerWarpper.setServedMileage("0");
- orderServerWarpper.setServedTime("0");
- orderServerWarpper.setLaveMileage("0");
- orderServerWarpper.setLaveTime("0");
- }
- if(orderPrivateCar.getState() == 5 || orderPrivateCar.getState() == 6){//服务中
- // TODO: 2023/11/4 无法修改
- Map<String, String> distance = gdMapElectricFenceUtil.getDistance(value, orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
- String d = "0";
- String t = "0";
- if(null == distance){
- System.err.println("查询距离出错了");
- }else{
- d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString();
- t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + "";
- }
- orderServerWarpper.setReservationMileage("0");
- orderServerWarpper.setReservationTime("0");
- orderServerWarpper.setServedMileage(String.valueOf((null == orderPrivateCar.getMileage() ? 0 : orderPrivateCar.getMileage()) / 1000));
- orderServerWarpper.setServedTime(Long.valueOf((new Date().getTime() - orderPrivateCar.getStartServiceTime().getTime()) / 60000).intValue() + "");
- orderServerWarpper.setLaveMileage(d);
- orderServerWarpper.setLaveTime(t);
- }
-
- return orderServerWarpper;
- }
-
-
-
-
-
- @Override
- public synchronized String getOrderNum() throws Exception{
- SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
- return "PR" + sdf.format(new Date()) + UUIDUtil.getRandomCode(5);
- }
-
- /**
- * 删除定时任务
- * @param orderId
- */
- @Override
- public void deleteTask(Integer orderId){
- //发送验证码短信
- HttpHeaders headers = new HttpHeaders();
- // 以表单的方式提交
- headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
- //将请求头部和参数合成一个请求
- MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
- params.add("orderId", orderId + "");
- params.add("orderType", "1");
- HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(params, headers);
- String s = internalRestTemplate.postForObject("http://driver-server/base/netty/deleteTask", requestEntity, String.class);
- JSONObject jsonObject = JSON.parseObject(s, JSONObject.class);
- if(jsonObject.getIntValue("code") != 200){
- System.err.println("调用driver-server出错了");
- }
- }
-
- @Override
- public Map<String, Object> queryBalance(Integer orderId, Integer uid) throws Exception {
- Map<String, Object> map = new HashMap<>();
- UserInfo userInfo = userInfoService.selectById(uid);
- map.put("balance", userInfo.getBalance());
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- int i = userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney());
- i = i + userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney());
- map.put("coupon", i);
- return map;
- }
-
- @Override
- public PreferentialDataVo queryBalance1(Integer orderId, Integer uid) throws Exception {
- UserInfo userInfo = userInfoService.selectById(uid);
- PreferentialDataVo preferentialDataVo = new PreferentialDataVo();
- preferentialDataVo.setBalance(userInfo.getBalance());
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- Integer ids = userInfoService.getDiscount();
- if(ids!=null){
- List<UserActivityDiscount1> userActivityId = userActivityDiscount1Mapper.selectList(new EntityWrapper<UserActivityDiscount1>().eq("userActivityId", ids));
- if(userActivityId.size()>0){
-
- preferentialDataVo.setDiscount(userActivityId.get(0).getSpecial());
- }
- }
- // 查出当前用户的红包 并将订单的修改
- List<UserRedPacketRecord> userRedPacketRecords = userRedPacketRecordService.selectList(new EntityWrapper<UserRedPacketRecord>().eq("userId", uid).eq("state", 1).gt("expirationTime", new Date()).gt("endTime", new Date()));
- if(userRedPacketRecords.size()>0){
-
- preferentialDataVo.setRedPacket(userRedPacketRecords.get(0).getMoney());
- orderPrivateCar.setRedPacketId(userRedPacketRecords.get(0).getId());
- orderPrivateCar.setRedPacketMoney(userRedPacketRecords.get(0).getMoney());
- this.updateById(orderPrivateCar);
- }
-
-
- //获取优惠券中最优数据
- List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderPrivateCar.getCompanyId()).eq("state", 1).le("money",orderPrivateCar.getOrderMoney()).in("couponUseType", Arrays.asList(0, 1)).eq("userId", uid).where("now() < expirationTime"));
- Integer id = null;
- Double price = 0d;
- Integer type = 0;
- for (UserCouponRecord userCouponRecord : list){
- if(userCouponRecord.getCouponType() == 1){//抵扣券
- if(price.compareTo(userCouponRecord.getMoney()) < 0){
- price = userCouponRecord.getMoney();
- id = userCouponRecord.getId();
- type = 1;
- }
- }else{//满减券
- if(orderPrivateCar.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) >= 0 && price.compareTo(userCouponRecord.getMoney()) < 0){
- price = userCouponRecord.getMoney();
- id = userCouponRecord.getId();
- type = 1;
- }
- }
- }
-
- //获取打车卡中最优数
- Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
- CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
- if(null == companyCity){
- companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
- }
- if(null == companyCity){
- companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
- }
- List<UserTaxiCard> userTaxiCards =new ArrayList<>();
- if(companyCity!=null) {
- userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().like("companyCityId", "%" + companyCity.getId() + "%")
- .in("type", Arrays.asList(1, 2, 3, 4)).eq("userId", uid).where("now() between startTime and endTime"));
- }
- //全国卡
- List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
- if(taxiCards.size() > 0) {
- List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
- .in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
- userTaxiCards.addAll(userTaxiCards2);
- }
- //亲密账户中有相同的卡优先使用自己的
- // 因为比对中只有优惠金额最高的才会被替换，所以先查找自己的数据再查找亲密账户的数据
- Map<String, Object> map = getOptimalTaxiCards(orderPrivateCar, price, id, type, userTaxiCards);
- price = Double.valueOf(map.get("price").toString());
- id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
- type = Integer.valueOf(map.get("type").toString());
-
- //亲密账户
- List<UserTaxiCard> userTaxiCards_ = new ArrayList<>();
- List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
- CompanyCity finalCompanyCity = companyCity;
- bindUserId.forEach(userUser -> {
- if(finalCompanyCity!=null) {
- List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(1, 2, 3, 4))
- .like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
- userTaxiCards_.addAll(userTaxiCards1);
- }
-
- //全国卡
- if(taxiCards.size() > 0) {
- List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
- .in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
- userTaxiCards_.addAll(userTaxiCards2);
- }
- });
- map = getOptimalTaxiCards(orderPrivateCar, price, id, type, userTaxiCards_);
- price = Double.valueOf(map.get("price").toString());
- id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
- type = Integer.valueOf(map.get("type").toString());
- System.out.println(price);
- System.out.println(orderPrivateCar.getOrderMoney());
- System.out.println(type);
-
- if(orderPrivateCar.getOrderMoney()!=null && price<=orderPrivateCar.getOrderMoney() || type==2){
- preferentialDataVo.setDiscountAmount(price);
- preferentialDataVo.setType(type);
- preferentialDataVo.setObjectId(id);
- }
- return preferentialDataVo;
- }
-
-
- /**
- * 获取最优打车卡数据
- * @param orderPrivateCar
- * @param price
- * @param id
- * @param type
- * @param userTaxiCards
- * @throws Exception
- */
- public Map<String, Object> getOptimalTaxiCards(OrderPrivateCar orderPrivateCar, Double price, Integer id, Integer type, List<UserTaxiCard> userTaxiCards) throws Exception{
- Map<String, Object> map = new HashMap<>();
- for(UserTaxiCard t : userTaxiCards){
- JSONObject jsonObject = JSON.parseObject(t.getContent());
- List<Integer> integers = jsonObject.getJSONArray("businessTypes").toJavaList(Integer.class);
- if(!integers.contains(1)){
- continue;
- }
- if(t.getType() == 1){//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
- Integer time = jsonObject.getInteger("time");
- if(time == 0){
- continue;
- }
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- Double discount = jsonObject.getDouble("discount");
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- Date date = new Date();
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
- Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- double v = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
- if(price.compareTo(v) < 0){
- price = v;
- id = t.getId();
- type = 2;
- }
- if(price.compareTo(v) < 0){
- price = v;
- id = t.getId();
- type = 2;
- }
- }
- }
-
- }
- if(t.getType() == 2){//优惠卡{"businessTypes":[1,2,3],"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"fullReduction":[[50,3],[100,5],[150,10]]}
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- Date date = new Date();
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
- Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- for(int j = fullReduction.size() - 1; j >= 0; j--){
- JSONArray jsonArray = fullReduction.getJSONArray(j);
- Double p = jsonArray.getDouble(0);//满金额
- Double y = jsonArray.getDouble(1);//优惠金额
- if(orderPrivateCar.getOrderMoney().compareTo(p) >= 0 && price.compareTo(y) < 0){
- price = y;
- id = t.getId();
- type = 2;
- }
- }
- }
- }
- }
- if(t.getType() == 3){//次数卡{"businessTypes":[1,2,3],"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"time":1,"discountAmount":10}
- Integer time = jsonObject.getInteger("time");
- if(time == 0){
- continue;
- }
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- Double discountAmount = jsonObject.getDouble("discountAmount");
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- Date date = new Date();
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
- Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- if(price.compareTo(discountAmount) < 0){
- price = discountAmount;
- id = t.getId();
- type = 2;
- }
- }
- }
- }
- if(t.getType() == 4){//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
- Double discount = jsonObject.getDouble("discount");//折扣
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- Date date = new Date();
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
- Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- double v = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
- if(price.compareTo(v) < 0){
- price = v;
- id = t.getId();
- type = 2;
- }
- }
- }
- }
- }
- map.put("price", price);
- map.put("id", id);
- map.put("type", type);
- return map;
- }
-
-
-
-
- @Override
- public List<Map<String, Object>> queryCoupon(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- List<Map<String, Object>> list = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney(), pageNum, size);
- List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney(), pageNum, size);
- list.addAll(list1);
- return list;
- }
-
- @Override
- public List<CouponsListVo> queryCouponList(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
- pageNum = (pageNum - 1) * size;
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- List<CouponsListVo> rows = new ArrayList<>();
- List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderPrivateCar.getCompanyId())
- .eq("state", 1).in("couponUseType", Arrays.asList(0, 1)).eq("userId", uid).where("expirationTime >= now()"));
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- for (UserCouponRecord userCouponRecord : list){
- if(userCouponRecord.getCouponType() == 2){//满减券
- if(orderPrivateCar.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) < 0){
- continue;
- }
- }
- CouponsListVo couponsListVo = new CouponsListVo();
- couponsListVo.setId(userCouponRecord.getId());
- couponsListVo.setDataType(1);
- couponsListVo.setMoney(userCouponRecord.getMoney());
- couponsListVo.setUserType(userCouponRecord.getCouponUseType());
- couponsListVo.setTime(sdf.format(userCouponRecord.getExpirationTime()));
- couponsListVo.setType(userCouponRecord.getCouponType());
- couponsListVo.setFullMoney(userCouponRecord.getFullMoney());
- couponsListVo.setState(userCouponRecord.getState());
- Company company = companyService.selectById(userCouponRecord.getCompanyId());
- couponsListVo.setCompany(company.getName());
- rows.add(couponsListVo);
- }
-
- Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
- CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
- if(null == companyCity){
- companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
- }
- if(null == companyCity){
- companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
- }
- List<UserTaxiCard> userTaxiCards ;
- if(companyCity!=null){
- userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
- .in("type", Arrays.asList(1, 2, 3, 4)).like("companyCityId", "%" + companyCity.getId() + "%").where("now() between startTime and endTime"));
- }else {
- userTaxiCards =new ArrayList<>();
- }
-
- //全国卡
- List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
- if(taxiCards.size() > 0) {
- List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
- .in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
- userTaxiCards.addAll(userTaxiCards1);
- }
-
-
- //亲密账户
- List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
- CompanyCity finalCompanyCity = companyCity;
- bindUserId.forEach(userUser -> {
- if(finalCompanyCity!=null) {
- List<UserTaxiCard> taxiCardPayments1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(1, 2, 3, 4))
- .like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
- userTaxiCards.addAll(taxiCardPayments1);
- }
-
- //全国卡
- if(taxiCards.size() > 0) {
- List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
- .in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
- userTaxiCards.addAll(userTaxiCards1);
- }
- });
-
- for(UserTaxiCard t : userTaxiCards){
- try {
- CouponsListVo couponsListVo = new CouponsListVo();
- couponsListVo.setId(t.getId());
- couponsListVo.setDataType(2);
- couponsListVo.setUserType(1);
- couponsListVo.setTime(sdf.format(t.getEndTime()));
- couponsListVo.setState(1);
- couponsListVo.setTaxiCardType(t.getType());
- Company company = companyService.selectById(t.getCompanyId());
- couponsListVo.setCompany(company.getName());
- couponsListVo.setName(taxiCardService.selectById(t.getTaxiCardId()).getName());
-
-
- JSONObject jsonObject = JSON.parseObject(t.getContent());
- JSONArray businessTypes = jsonObject.getJSONArray("businessTypes");
- if(!businessTypes.toJavaList(Integer.class).contains(1)){
- continue;
- }
- if(t.getType() == 1){//{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
- Integer time = jsonObject.getInteger("time");
- if(time == 0){
- continue;
- }
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
- boolean b = true;
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
- Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- b = false;
- break;
- }
- }
- if(b){
- continue;
- }
- couponsListVo.setMoney(jsonObject.getDouble("discount"));
- couponsListVo.setType(1);
- }
- if(t.getType() == 2){//{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]}
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
- boolean b = true;
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
- Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- b = false;
- break;
- }
- }
- if(b){
- continue;
- }
- JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
- b = true;
- for(int i = fullReduction.size() - 1; i >= 0; i--){
- JSONArray jsonArray = fullReduction.getJSONArray(i);
- Double m = jsonArray.getDouble(0);
- Double j = jsonArray.getDouble(1);
- if(orderPrivateCar.getOrderMoney().compareTo(m) >= 0){
- couponsListVo.setFullMoney(m);
- couponsListVo.setMoney(j);
- b = false;
- break;
- }
- }
- if(b){
- continue;
- }
- couponsListVo.setType(2);
- }
- if(t.getType() == 3){//{"businessTypes":[1,2,3],"time":1,"discountAmount":10}
- Integer time = jsonObject.getInteger("time");
- if(time == 0){
- continue;
- }
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
- boolean b = true;
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
- Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- b = false;
- break;
- }
- }
- if(b){
- continue;
- }
- couponsListVo.setFullMoney(0D);
- couponsListVo.setMoney(jsonObject.getDouble("discountAmount"));
- couponsListVo.setType(2);
- }
- if(t.getType() == 4){//{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
- boolean b = true;
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
- Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- b = false;
- break;
- }
- }
- if(b){
- continue;
- }
- couponsListVo.setMoney(jsonObject.getDouble("discount"));
- couponsListVo.setType(1);
- }
-
-
- String str = "";
- TaxiCard taxiCard = taxiCardService.selectById(t.getTaxiCardId());
- if(taxiCard.getTaxiCardType() == 1){
- String[] split = taxiCard.getCompanyCityId().split(";");
- for(String c : split){
- CompanyCity companyCity1 = companyCityService.selectById(c);
- if(ToolUtil.isNotEmpty(companyCity1.getAreaCode())){
- Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getAreaCode()));
- str += region.getName() + ";";
- continue;
- }
- if(ToolUtil.isNotEmpty(companyCity1.getCityCode())){
- Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getCityCode()));
- str += region.getName() + ";";
- continue;
- }
- if(ToolUtil.isNotEmpty(companyCity1.getProvinceCode())){
- Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getProvinceCode()));
- str += region.getName() + ";";
- continue;
- }
- }
- }else{
- str = "全国;";
- }
- couponsListVo.setCity(str.substring(0, str.length() - 1));
-
-
- rows.add(couponsListVo);
- }catch (Exception e){
- e.printStackTrace();
- }
- }
- Collections.sort(rows, new Comparator<CouponsListVo>() {
- public int compare(CouponsListVo s1, CouponsListVo s2) {
- return Integer.compare(s1.getId(), s2.getId());
- }
- });
-
- if(rows.size() >= (pageNum + 1) * size){
- rows = rows.subList(pageNum, pageNum + size);
- }else if(pageNum < rows.size() && rows.size() < (pageNum + 1) * size){
- rows = rows.subList(pageNum, rows.size());
- }else{
- rows = new ArrayList<>();
- }
- System.out.println(rows);
- System.out.println(orderPrivateCar.getOrderMoney());
- rows = rows.stream().filter(e->e.getMoney()<=orderPrivateCar.getOrderMoney() || e.getDataType()==2).collect(Collectors.toList());
- System.out.println(rows);
- return rows;
- }
-
- @Override
- public ResultUtil payPrivateCarOrder(Integer payType, Integer orderId, Integer couponId, Integer type) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- if(orderPrivateCar.getState() == 8 || orderPrivateCar.getState() == 9){
- return ResultUtil.error("订单已完成支付，不允许重复支付", "");
- }
- if(orderPrivateCar.getState() != 7){
- return ResultUtil.error("订单不在待支付状态，不允许支付", "");
- }
- Integer uid = orderPrivateCar.getUserId();
- Double orderMoney = orderPrivateCar.getOrderMoney();
- UserInfo userInfo = userInfoService.selectById(uid);
- ResultUtil resultUtil = ResultUtil.success(new Object());
- orderPrivateCar.setCouponMoney(0D);//初始化历史数据
- orderPrivateCar.setCouponId(null);
-
- //计算优惠券
- UserCouponRecord userCouponRecord = null;
- if(null != couponId){
- userCouponRecord = userCouponRecordService.selectById(couponId);
- if(userCouponRecord.getCompanyId() != orderPrivateCar.getCompanyId()){
- return ResultUtil.error("优惠券不能用于此订单", "");
- }
- if(userCouponRecord.getState() == 2){
- return ResultUtil.error("优惠券已使用", "");
- }
- if(userCouponRecord.getState() == 3){
- return ResultUtil.error("优惠券已过期", "");
- }
- if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1){
- return ResultUtil.error("优惠券不能用于此类型订单", "");
- }
- if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){
- return ResultUtil.error("优惠券不能用于此订单", "");
- }
- orderMoney = orderMoney - userCouponRecord.getMoney();
- orderPrivateCar.setCouponMoney(userCouponRecord.getMoney());
- orderPrivateCar.setCouponId(couponId);
- }
-
-
- //计算红包
- UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
- if(null != query && query.getMoney().compareTo(orderMoney) < 0){
- orderMoney = orderMoney - query.getMoney();
- orderPrivateCar.setRedPacketMoney(query.getMoney());
- orderPrivateCar.setRedPacketId(query.getId());
- }
-
- //计算折扣
- UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
- if(null != query2){
- Double special = query2.getSpecial();
- orderPrivateCar.setDiscount(special);
- double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
- if(orderMoney.compareTo(v) > 0){
- orderPrivateCar.setDiscountMoney(orderMoney - v);
- orderPrivateCar.setActivityId(query2.getId());
- orderMoney = v;
- }
- }
- orderMoney = orderMoney < 0 ? 0 : orderMoney;
- if(payType == 1){//微信支付
- String app = type == 1 ? "APP" : "JSAPI";
- resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
- paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据
- }
- if(payType == 2) {//支付宝支付
- resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
- paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 2, orderMoney, "", 1);//添加预支付数据
- }
- if(payType == 3){//余额支付
- if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){
- return ResultUtil.error("余额不足，无法完成支付", "");
- }
-
- userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
-
- SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
- userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
-
- //添加交易明细
- transactionDetailsService.saveData(uid, "快车订单", orderMoney, 2, 1, 1, 1, orderId);
- userInfoService.updateById(userInfo);
-
- orderPrivateCar.setState(8);
- orderPrivateCar.setPayType(3);
- orderPrivateCar.setPayMoney(orderMoney);
-
- //处理优惠券和红包
- if(null != userCouponRecord){
- userCouponRecord.setState(2);
- userCouponRecord.setEndTime(new Date());
- userCouponRecordService.updateById(userCouponRecord);
- }
- if(null != query){
- query.setState(2);
- query.setEndTime(new Date());
- userRedPacketRecordService.updateById(query);
- }
- //添加收入
- Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
- orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));
-
- // TODO: 2020/5/24 这里需要给司机和用户推送订单状态
- new Thread(new Runnable() {
- @Override
- public void run() {
- pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
- pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
- }
- }).start();
-
- systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付，谢谢使用！", uid, 1);
-
- new Thread(new Runnable() {
- @Override
- public void run() {
- if(pushMinistryOfTransport){//上传数据
- pushMinistryOfTransportUtil.operatePay(orderId);
- }
- }
- }).start();
- }
-
- this.updateAllColumnById(orderPrivateCar);
- return resultUtil;
- }
-
-
- @Override
- @Transactional(propagation = Propagation.REQUIRES_NEW)
- public ResultUtil payPrivateCarOrder1(Integer payType, Integer orderId, Integer objectId, Integer objectType, Integer type) throws Exception {
-
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- if(orderPrivateCar.getState() == 8 || orderPrivateCar.getState() == 9){
- return ResultUtil.error("订单已完成支付，不允许重复支付", new ArrayList<>());
- }
- if(orderPrivateCar.getState() != 7){
- return ResultUtil.error("订单不在待支付状态，不允许支付", new ArrayList<>());
- }
- Integer uid = orderPrivateCar.getUserId();
- Double orderMoney = orderPrivateCar.getOrderMoney();
- UserInfo userInfo = userInfoService.selectById(uid);
- ResultUtil resultUtil = ResultUtil.success(new Object());
- orderPrivateCar.setCouponMoney(0D);//初始化历史数据
- orderPrivateCar.setCouponId(null);
- System.out.println("!!!"+orderMoney+"!!!!");
- //计算优惠券
- UserCouponRecord userCouponRecord = null;
- if(null != objectId && objectType == 1){
- userCouponRecord = userCouponRecordService.selectById(objectId);
- if(userCouponRecord.getCompanyId() != orderPrivateCar.getCompanyId()){
- return ResultUtil.error("优惠券不能用于此订单", new ArrayList<>());
- }
- if(userCouponRecord.getState() == 2){
- return ResultUtil.error("优惠券已使用", new ArrayList<>());
- }
- if(userCouponRecord.getState() == 3){
- return ResultUtil.error("优惠券已过期", new ArrayList<>());
- }
- if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1){
- return ResultUtil.error("优惠券不能用于此类型订单", new ArrayList<>());
- }
- if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){
- return ResultUtil.error("优惠券不能用于此订单", new ArrayList<>());
- }
- orderMoney = orderMoney - userCouponRecord.getMoney();
- orderPrivateCar.setCouponMoney(userCouponRecord.getMoney());
- orderPrivateCar.setCouponId(objectId);
- System.out.println("!!!"+orderMoney+"!!!!");
- }
-
- //打车卡
- UserTaxiCard userTaxiCard = null;
- if(null != objectId && objectType == 2){
- userTaxiCard = userTaxiCardService.selectById(objectId);
- TaxiCard taxiCard = taxiCardService.selectById(userTaxiCard.getTaxiCardId());
- if(taxiCard.getTaxiCardType() == 1 && userTaxiCard.getCompanyId() != orderPrivateCar.getCompanyId()){
- return ResultUtil.error("打车卡不能用于此订单", new ArrayList<>());
- }
- if(System.currentTimeMillis() > userTaxiCard.getEndTime().getTime()){
- return ResultUtil.error("打车卡已过期", new ArrayList<>());
- }
- if(userTaxiCard.getType() == 1 || userTaxiCard.getType() == 3){
- Integer time = JSON.parseObject(userTaxiCard.getContent()).getInteger("time");
- if(0 == time){
- return ResultUtil.error("打车卡已使用完", new ArrayList<>());
- }
- }
- List<Integer> integers = JSON.parseObject(userTaxiCard.getContent()).getJSONArray("businessTypes").toJavaList(Integer.class);
- if(!integers.contains(1)){
- return ResultUtil.error("打车卡不能用于此类型订单", new ArrayList<>());
- }
-
- Double yh = 0D;
- JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
- if(userTaxiCard.getType() == 1){//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- Double discount = jsonObject.getDouble("discount");
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- Date date = new Date();
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
- Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- yh = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
- jsonObject.put("time", jsonObject.getInteger("time") - 1);
- userTaxiCard.setContent(jsonObject.toJSONString());
- break;
- }
- }
-
- }
- if(userTaxiCard.getType() == 2){//优惠卡{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]}
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- Date date = new Date();
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
- Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- for(int j = fullReduction.size() - 1; j >= 0; j--){
- JSONArray jsonArray = fullReduction.getJSONArray(j);
- Double p = jsonArray.getDouble(0);//满金额
- if(orderPrivateCar.getOrderMoney().compareTo(p) >= 0){
- yh = jsonArray.getDouble(1);//优惠金额
- break;
- }
- }
- }
- }
-
- }
- if(userTaxiCard.getType() == 3){//次数卡{"businessTypes":[1,2,3],"time":1,"discountAmount":10}
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- Date date = new Date();
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
- Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- yh = jsonObject.getDouble("discountAmount");
- jsonObject.put("time", jsonObject.getInteger("time") - 1);
- userTaxiCard.setContent(jsonObject.toJSONString());
- }
- }
-
- }
- if(userTaxiCard.getType() == 4){//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
- Double discount = jsonObject.getDouble("discount");//折扣
- JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- Date date = new Date();
- for(int i = 0; i < timeQuantum.size(); i++){
- String[] split = timeQuantum.getString(i).split(" - ");
- Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
- Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
- if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
- yh = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
- break;
- }
- }
- }
-
- orderMoney = orderMoney - yh;
- orderPrivateCar.setTaxiCardId(userTaxiCard.getTaxiCardId());
- orderPrivateCar.setUserTaxiCardId(objectId);
- orderPrivateCar.setDiscountAmount(yh);
- }
-
- System.out.println("!!!"+orderMoney+"!!!!");
-
- //计算红包
- UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
- if(null != query && query.getMoney().compareTo(orderMoney) < 0){
- orderMoney = orderMoney - query.getMoney();
- orderPrivateCar.setRedPacketMoney(query.getMoney());
- orderPrivateCar.setRedPacketId(query.getId());
- }
-
- System.out.println("!!!"+orderMoney+"!!!!");
- //计算折扣
- UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
- if(null != query2){
- Double special = query2.getSpecial();
- orderPrivateCar.setDiscount(special);
- double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
- if(orderMoney.compareTo(v) > 0){
- orderPrivateCar.setDiscountMoney(orderMoney - v);
- orderPrivateCar.setActivityId(query2.getId());
- orderMoney = v;
- }
- }
- orderMoney = new BigDecimal(orderMoney).setScale(2, RoundingMode.HALF_UP).doubleValue();
- System.out.println("!!!"+orderMoney+"!!!!");
- orderMoney = orderMoney < 0 ? 0 : orderMoney;
- if(payType == 1){//微信支付
- if(orderMoney == 0){
- return ResultUtil.error("请使用余额支付");
- }
- String app = type == 1 ? "APP" : "JSAPI";
- resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
- paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据
- }
- if(payType == 2) {//支付宝支付
- if(orderMoney == 0){
- return ResultUtil.error("请使用余额支付");
- }
- resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
- paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 2, orderMoney, "", 1);//添加预支付数据
- }
- if(payType == 3){//余额支付
- if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){
- return ResultUtil.error("余额不足，无法完成支付");
- }
+ userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(query.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+ //添加交易明细
+ transactionDetailsService.saveData(uid, "快车取消订单", query.getMoney(), 2, 1, 1, 1, id);
+ userInfoService.updateById(userInfo);
+
+ //解除小号绑定
+ if (orderPrivateCar.getBindId() != null) {
+ chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 600000));
+ }
+
+ orderPrivateCar.setState(10);
+ orderPrivateCar.setTelX("");
+ orderPrivateCar.setBindId("");
+ this.updateById(orderPrivateCar);
+
+ orderCancel.setState(2);
+ orderCancel.setPayType(3);
+ orderCancelService.updateById(orderCancel);
+
+ //添加已收入明细
+ incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, query.getMoney());
+
+ this.deleteTask(id);//删除定时任务
+
+ //添加消息
+ systemNoticeService.addSystemNotice(1, "您已使用余额成功支付取消订单费用，谢谢使用！", orderPrivateCar.getUserId(), 1);
+
+ } else if (payType == 4) {
+ Double payMoney = orderPrivateCar.getOrderMoney();
+ Integer integer = paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 4, query.getMoney(), "", 1);
+ resultUtil = appOrderController.placeAnOrder(new BigDecimal(query.getMoney()), 4, id, 1, integer);
+
+ }
+ }
+ return resultUtil;
+ }
+
+
+ @Override
+ public Map<String, Object> queryOrderInfo(Integer uid, Integer orderId) throws Exception {
+ Map<String, Object> map = orderPrivateCarMapper.queryOrderInfo(orderId);
+ if(null == map){
+ OrderTaxi orderTaxi = orderTaxiService.selectOne(new EntityWrapper<OrderTaxi>()
+ .eq("userId", uid)
+ .eq("isDelete", 1)
+ .in("state", Arrays.asList(2, 3, 4, 5, 6, 7))
+ );
+ return orderTaxiService.queryOrderInfo(orderTaxi.getId());
+ }
+ if(null != map.get("reassignNotice") && Integer.valueOf(String.valueOf(map.get("reassignNotice"))) == 2){//改派完成，重新获取了新的司机数据，开始修改数据防止继续调用
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ orderPrivateCar.setReassignNotice(0);
+ this.updateById(orderPrivateCar);
+ }
+ if(Integer.valueOf(String.valueOf(map.get("state"))) == 11){
+ map.put("state", map.get("oldState"));
+ }
+ if(Integer.valueOf(String.valueOf(map.get("state"))) ==7 && (map.get("responsibilityType")==null || Integer.valueOf(String.valueOf(map.get("responsibilityType")))<4)){
+ map.put("appealButton", 1);
+ }
+ if(map.get("abnormalIntro")!=null){
+ map.put("appealStatus", 1);
+ }
+
+
+ if(Integer.valueOf(String.valueOf(map.get("state"))) != 8 && Integer.valueOf(String.valueOf(map.get("state"))) != 9){
+ map.put("redPacketMoney", null);
+ map.put("couponMoney", null);
+ }
+
+ String driverId = (String) redisTemplate.opsForValue().get("DEVICE_" + map.get("driverId"));
+ map.put("device", ToolUtil.isNotEmpty(driverId) ? 2 : 1);
+ map.put("orderType", 1);
+ return map;
+ }
+
+ /**
+ * 获取服务中的订单数据
+ * @param uid
+ * @return
+ * @throws Exception
+ */
+ @Override
+ public OrderServerWarpper queryOrderServer(Integer orderId, Integer uid) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ if(null == orderPrivateCar){
+ return orderTaxiService.queryOrderServer(orderId, uid);
+ }
+ //计算预计距离和剩余时间
+ String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(orderPrivateCar.getDriverId()));
+ if(null == value || "".equals(value)){
+ System.err.println("司机没有上传位置信息");
+
+ //调用获取轨迹中的数据
+ List<Map<String, Object>> list = orderPositionService.queryTrack(orderId, 2);
+ if(list.size() > 0){
+ Map<String, Object> map = list.get(list.size() - 1);
+ value = map.get("lon") + "," + map.get("lat");
+ }
+
+ }
+
+ OrderServerWarpper orderServerWarpper = new OrderServerWarpper();
+ orderServerWarpper.setOrderId(orderPrivateCar.getId());
+ orderServerWarpper.setOrderType(1);
+ orderServerWarpper.setState(orderPrivateCar.getState());
+ orderServerWarpper.setLon(null != value ? value.split(",")[0] : "0.0");
+ orderServerWarpper.setLat(null != value ? value.split(",")[1] : "0.0");
+ orderServerWarpper.setReassignNotice(orderPrivateCar.getReassignNotice());
+ if(orderPrivateCar.getState() == 2 || orderPrivateCar.getState() == 3){//前往预约地
+ // TODO: 2023/11/4 无法修改
+ Map<String, String> distance = gdMapElectricFenceUtil.getDistance(value, orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), 1);
+ String d = "0";
+ String t = "0";
+ if(null == distance){
+ System.err.println("查询距离出错了");
+ }else{
+ d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString();
+ t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + "";
+ }
+ orderServerWarpper.setReservationMileage(d);
+ orderServerWarpper.setReservationTime(t);
+ orderServerWarpper.setServedMileage("0");
+ orderServerWarpper.setServedTime("0");
+ orderServerWarpper.setLaveMileage("0");
+ orderServerWarpper.setLaveTime("0");
+ }
+ if(orderPrivateCar.getState() == 5 || orderPrivateCar.getState() == 6){//服务中
+ // TODO: 2023/11/4 无法修改
+ Map<String, String> distance = gdMapElectricFenceUtil.getDistance(value, orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
+ String d = "0";
+ String t = "0";
+ if(null == distance){
+ System.err.println("查询距离出错了");
+ }else{
+ d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString();
+ t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + "";
+ }
+ orderServerWarpper.setReservationMileage("0");
+ orderServerWarpper.setReservationTime("0");
+ orderServerWarpper.setServedMileage(String.valueOf((null == orderPrivateCar.getMileage() ? 0 : orderPrivateCar.getMileage()) / 1000));
+ orderServerWarpper.setServedTime(Long.valueOf((new Date().getTime() - orderPrivateCar.getStartServiceTime().getTime()) / 60000).intValue() + "");
+ orderServerWarpper.setLaveMileage(d);
+ orderServerWarpper.setLaveTime(t);
+ }
+
+ return orderServerWarpper;
+ }
+
+
+ @Override
+ public synchronized String getOrderNum() throws Exception {
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
+ return "PR" + sdf.format(new Date()) + UUIDUtil.getRandomCode(5);
+ }
+
+ /**
+ * 删除定时任务
+ *
+ * @param orderId
+ */
+ @Override
+ public void deleteTask(Integer orderId) {
+ //发送验证码短信
+ HttpHeaders headers = new HttpHeaders();
+ // 以表单的方式提交
+ headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
+ //将请求头部和参数合成一个请求
+ MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
+ params.add("orderId", orderId + "");
+ params.add("orderType", "1");
+ HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(params, headers);
+ String s = internalRestTemplate.postForObject("http://driver-server/base/netty/deleteTask", requestEntity, String.class);
+ JSONObject jsonObject = JSON.parseObject(s, JSONObject.class);
+ if (jsonObject.getIntValue("code") != 200) {
+ System.err.println("调用driver-server出错了");
+ }
+ }
+
+ @Override
+ public Map<String, Object> queryBalance(Integer orderId, Integer uid) throws Exception {
+ Map<String, Object> map = new HashMap<>();
+ UserInfo userInfo = userInfoService.selectById(uid);
+ map.put("balance", userInfo.getBalance());
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ int i = userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney());
+ i = i + userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney());
+ map.put("coupon", i);
+ return map;
+ }
+
+ @Override
+ public PreferentialDataVo queryBalance1(Integer orderId, Integer uid) throws Exception {
+ UserInfo userInfo = userInfoService.selectById(uid);
+ PreferentialDataVo preferentialDataVo = new PreferentialDataVo();
+ preferentialDataVo.setBalance(userInfo.getBalance());
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ Integer ids = userInfoService.getDiscount();
+ if (ids != null) {
+ List<UserActivityDiscount1> userActivityId = userActivityDiscount1Mapper.selectList(new EntityWrapper<UserActivityDiscount1>().eq("userActivityId", ids));
+ if (userActivityId.size() > 0) {
+
+ preferentialDataVo.setDiscount(userActivityId.get(0).getSpecial());
+ }
+ }
+ // 查出当前用户的红包 并将订单的修改
+ List<UserRedPacketRecord> userRedPacketRecords = userRedPacketRecordService.selectList(new EntityWrapper<UserRedPacketRecord>().eq("userId", uid).eq("state", 1).gt("expirationTime", new Date()).gt("endTime", new Date()));
+ if (userRedPacketRecords.size() > 0) {
+
+ preferentialDataVo.setRedPacket(userRedPacketRecords.get(0).getMoney());
+ orderPrivateCar.setRedPacketId(userRedPacketRecords.get(0).getId());
+ orderPrivateCar.setRedPacketMoney(userRedPacketRecords.get(0).getMoney());
+ this.updateById(orderPrivateCar);
+ }
+
+
+ //获取优惠券中最优数据
+ List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderPrivateCar.getCompanyId()).eq("state", 1).le("money", orderPrivateCar.getOrderMoney()).in("couponUseType", Arrays.asList(0, 1)).eq("userId", uid).where("now() < expirationTime"));
+ Integer id = null;
+ Double price = 0d;
+ Integer type = 0;
+ for (UserCouponRecord userCouponRecord : list) {
+ if (userCouponRecord.getCouponType() == 1) {//抵扣券
+ if (price.compareTo(userCouponRecord.getMoney()) < 0) {
+ price = userCouponRecord.getMoney();
+ id = userCouponRecord.getId();
+ type = 1;
+ }
+ } else {//满减券
+ if (orderPrivateCar.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) >= 0 && price.compareTo(userCouponRecord.getMoney()) < 0) {
+ price = userCouponRecord.getMoney();
+ id = userCouponRecord.getId();
+ type = 1;
+ }
+ }
+ }
+
+ //获取打车卡中最优数
+ Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
+ if (null == companyCity) {
+ companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
+ }
+ if (null == companyCity) {
+ companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
+ }
+ List<UserTaxiCard> userTaxiCards = new ArrayList<>();
+ if (companyCity != null) {
+ userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().like("companyCityId", "%" + companyCity.getId() + "%")
+ .in("type", Arrays.asList(1, 2, 3, 4)).eq("userId", uid).where("now() between startTime and endTime"));
+ }
+ //全国卡
+ List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
+ if (taxiCards.size() > 0) {
+ List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
+ .in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
+ userTaxiCards.addAll(userTaxiCards2);
+ }
+ //亲密账户中有相同的卡优先使用自己的
+ // 因为比对中只有优惠金额最高的才会被替换，所以先查找自己的数据再查找亲密账户的数据
+ Map<String, Object> map = getOptimalTaxiCards(orderPrivateCar, price, id, type, userTaxiCards);
+ price = Double.valueOf(map.get("price").toString());
+ id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
+ type = Integer.valueOf(map.get("type").toString());
+
+ //亲密账户
+ List<UserTaxiCard> userTaxiCards_ = new ArrayList<>();
+ List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
+ CompanyCity finalCompanyCity = companyCity;
+ bindUserId.forEach(userUser -> {
+ if (finalCompanyCity != null) {
+ List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(1, 2, 3, 4))
+ .like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
+ userTaxiCards_.addAll(userTaxiCards1);
+ }
+
+ //全国卡
+ if (taxiCards.size() > 0) {
+ List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
+ .in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
+ userTaxiCards_.addAll(userTaxiCards2);
+ }
+ });
+ map = getOptimalTaxiCards(orderPrivateCar, price, id, type, userTaxiCards_);
+ price = Double.valueOf(map.get("price").toString());
+ id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
+ type = Integer.valueOf(map.get("type").toString());
+ System.out.println(price);
+ System.out.println(orderPrivateCar.getOrderMoney());
+ System.out.println(type);
+
+ if (orderPrivateCar.getOrderMoney() != null && price <= orderPrivateCar.getOrderMoney() || type == 2) {
+ preferentialDataVo.setDiscountAmount(price);
+ preferentialDataVo.setType(type);
+ preferentialDataVo.setObjectId(id);
+ }
+ return preferentialDataVo;
+ }
+
+ /**
+ * 获取最优打车卡数据
+ *
+ * @param orderPrivateCar
+ * @param price
+ * @param id
+ * @param type
+ * @param userTaxiCards
+ * @throws Exception
+ */
+ public Map<String, Object> getOptimalTaxiCards(OrderPrivateCar orderPrivateCar, Double price, Integer id, Integer type, List<UserTaxiCard> userTaxiCards) throws Exception {
+ Map<String, Object> map = new HashMap<>();
+ for (UserTaxiCard t : userTaxiCards) {
+ JSONObject jsonObject = JSON.parseObject(t.getContent());
+ List<Integer> integers = jsonObject.getJSONArray("businessTypes").toJavaList(Integer.class);
+ if (!integers.contains(1)) {
+ continue;
+ }
+ if (t.getType() == 1) {//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
+ Integer time = jsonObject.getInteger("time");
+ if (time == 0) {
+ continue;
+ }
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ Double discount = jsonObject.getDouble("discount");
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date date = new Date();
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
+ Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ double v = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+ if (price.compareTo(v) < 0) {
+ price = v;
+ id = t.getId();
+ type = 2;
+ }
+ if (price.compareTo(v) < 0) {
+ price = v;
+ id = t.getId();
+ type = 2;
+ }
+ }
+ }
+
+ }
+ if (t.getType() == 2) {//优惠卡{"businessTypes":[1,2,3],"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"fullReduction":[[50,3],[100,5],[150,10]]}
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date date = new Date();
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
+ Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ for (int j = fullReduction.size() - 1; j >= 0; j--) {
+ JSONArray jsonArray = fullReduction.getJSONArray(j);
+ Double p = jsonArray.getDouble(0);//满金额
+ Double y = jsonArray.getDouble(1);//优惠金额
+ if (orderPrivateCar.getOrderMoney().compareTo(p) >= 0 && price.compareTo(y) < 0) {
+ price = y;
+ id = t.getId();
+ type = 2;
+ }
+ }
+ }
+ }
+ }
+ if (t.getType() == 3) {//次数卡{"businessTypes":[1,2,3],"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"time":1,"discountAmount":10}
+ Integer time = jsonObject.getInteger("time");
+ if (time == 0) {
+ continue;
+ }
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ Double discountAmount = jsonObject.getDouble("discountAmount");
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date date = new Date();
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
+ Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ if (price.compareTo(discountAmount) < 0) {
+ price = discountAmount;
+ id = t.getId();
+ type = 2;
+ }
+ }
+ }
+ }
+ if (t.getType() == 4) {//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
+ Double discount = jsonObject.getDouble("discount");//折扣
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date date = new Date();
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
+ Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ double v = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+ if (price.compareTo(v) < 0) {
+ price = v;
+ id = t.getId();
+ type = 2;
+ }
+ }
+ }
+ }
+ }
+ map.put("price", price);
+ map.put("id", id);
+ map.put("type", type);
+ return map;
+ }
+
+ @Override
+ public List<Map<String, Object>> queryCoupon(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ List<Map<String, Object>> list = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney(), pageNum, size);
+ List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney(), pageNum, size);
+ list.addAll(list1);
+ return list;
+ }
+
+ @Override
+ public List<CouponsListVo> queryCouponList(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
+ pageNum = (pageNum - 1) * size;
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ List<CouponsListVo> rows = new ArrayList<>();
+ List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderPrivateCar.getCompanyId())
+ .eq("state", 1).in("couponUseType", Arrays.asList(0, 1)).eq("userId", uid).where("expirationTime >= now()"));
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ for (UserCouponRecord userCouponRecord : list) {
+ if (userCouponRecord.getCouponType() == 2) {//满减券
+ if (orderPrivateCar.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) < 0) {
+ continue;
+ }
+ }
+ CouponsListVo couponsListVo = new CouponsListVo();
+ couponsListVo.setId(userCouponRecord.getId());
+ couponsListVo.setDataType(1);
+ couponsListVo.setMoney(userCouponRecord.getMoney());
+ couponsListVo.setUserType(userCouponRecord.getCouponUseType());
+ couponsListVo.setTime(sdf.format(userCouponRecord.getExpirationTime()));
+ couponsListVo.setType(userCouponRecord.getCouponType());
+ couponsListVo.setFullMoney(userCouponRecord.getFullMoney());
+ couponsListVo.setState(userCouponRecord.getState());
+ Company company = companyService.selectById(userCouponRecord.getCompanyId());
+ couponsListVo.setCompany(company.getName());
+ rows.add(couponsListVo);
+ }
+
+ Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
+ if (null == companyCity) {
+ companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
+ }
+ if (null == companyCity) {
+ companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
+ }
+ List<UserTaxiCard> userTaxiCards;
+ if (companyCity != null) {
+ userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
+ .in("type", Arrays.asList(1, 2, 3, 4)).like("companyCityId", "%" + companyCity.getId() + "%").where("now() between startTime and endTime"));
+ } else {
+ userTaxiCards = new ArrayList<>();
+ }
+
+ //全国卡
+ List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
+ if (taxiCards.size() > 0) {
+ List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
+ .in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
+ userTaxiCards.addAll(userTaxiCards1);
+ }
+
+
+ //亲密账户
+ List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
+ CompanyCity finalCompanyCity = companyCity;
+ bindUserId.forEach(userUser -> {
+ if (finalCompanyCity != null) {
+ List<UserTaxiCard> taxiCardPayments1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(1, 2, 3, 4))
+ .like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
+ userTaxiCards.addAll(taxiCardPayments1);
+ }
+
+ //全国卡
+ if (taxiCards.size() > 0) {
+ List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
+ .in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
+ userTaxiCards.addAll(userTaxiCards1);
+ }
+ });
+
+ for (UserTaxiCard t : userTaxiCards) {
+ try {
+ CouponsListVo couponsListVo = new CouponsListVo();
+ couponsListVo.setId(t.getId());
+ couponsListVo.setDataType(2);
+ couponsListVo.setUserType(1);
+ couponsListVo.setTime(sdf.format(t.getEndTime()));
+ couponsListVo.setState(1);
+ couponsListVo.setTaxiCardType(t.getType());
+ Company company = companyService.selectById(t.getCompanyId());
+ couponsListVo.setCompany(company.getName());
+ couponsListVo.setName(taxiCardService.selectById(t.getTaxiCardId()).getName());
+
+
+ JSONObject jsonObject = JSON.parseObject(t.getContent());
+ JSONArray businessTypes = jsonObject.getJSONArray("businessTypes");
+ if (!businessTypes.toJavaList(Integer.class).contains(1)) {
+ continue;
+ }
+ if (t.getType() == 1) {//{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
+ Integer time = jsonObject.getInteger("time");
+ if (time == 0) {
+ continue;
+ }
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
+ boolean b = true;
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
+ Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ b = false;
+ break;
+ }
+ }
+ if (b) {
+ continue;
+ }
+ couponsListVo.setMoney(jsonObject.getDouble("discount"));
+ couponsListVo.setType(1);
+ }
+ if (t.getType() == 2) {//{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]}
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
+ boolean b = true;
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
+ Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ b = false;
+ break;
+ }
+ }
+ if (b) {
+ continue;
+ }
+ JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
+ b = true;
+ for (int i = fullReduction.size() - 1; i >= 0; i--) {
+ JSONArray jsonArray = fullReduction.getJSONArray(i);
+ Double m = jsonArray.getDouble(0);
+ Double j = jsonArray.getDouble(1);
+ if (orderPrivateCar.getOrderMoney().compareTo(m) >= 0) {
+ couponsListVo.setFullMoney(m);
+ couponsListVo.setMoney(j);
+ b = false;
+ break;
+ }
+ }
+ if (b) {
+ continue;
+ }
+ couponsListVo.setType(2);
+ }
+ if (t.getType() == 3) {//{"businessTypes":[1,2,3],"time":1,"discountAmount":10}
+ Integer time = jsonObject.getInteger("time");
+ if (time == 0) {
+ continue;
+ }
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
+ boolean b = true;
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
+ Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ b = false;
+ break;
+ }
+ }
+ if (b) {
+ continue;
+ }
+ couponsListVo.setFullMoney(0D);
+ couponsListVo.setMoney(jsonObject.getDouble("discountAmount"));
+ couponsListVo.setType(2);
+ }
+ if (t.getType() == 4) {//{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
+ boolean b = true;
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
+ Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ b = false;
+ break;
+ }
+ }
+ if (b) {
+ continue;
+ }
+ couponsListVo.setMoney(jsonObject.getDouble("discount"));
+ couponsListVo.setType(1);
+ }
+
+
+ String str = "";
+ TaxiCard taxiCard = taxiCardService.selectById(t.getTaxiCardId());
+ if (taxiCard.getTaxiCardType() == 1) {
+ String[] split = taxiCard.getCompanyCityId().split(";");
+ for (String c : split) {
+ CompanyCity companyCity1 = companyCityService.selectById(c);
+ if (ToolUtil.isNotEmpty(companyCity1.getAreaCode())) {
+ Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getAreaCode()));
+ str += region.getName() + ";";
+ continue;
+ }
+ if (ToolUtil.isNotEmpty(companyCity1.getCityCode())) {
+ Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getCityCode()));
+ str += region.getName() + ";";
+ continue;
+ }
+ if (ToolUtil.isNotEmpty(companyCity1.getProvinceCode())) {
+ Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getProvinceCode()));
+ str += region.getName() + ";";
+ continue;
+ }
+ }
+ } else {
+ str = "全国;";
+ }
+ couponsListVo.setCity(str.substring(0, str.length() - 1));
+
+
+ rows.add(couponsListVo);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ Collections.sort(rows, new Comparator<CouponsListVo>() {
+ public int compare(CouponsListVo s1, CouponsListVo s2) {
+ return Integer.compare(s1.getId(), s2.getId());
+ }
+ });
+
+ if (rows.size() >= (pageNum + 1) * size) {
+ rows = rows.subList(pageNum, pageNum + size);
+ } else if (pageNum < rows.size() && rows.size() < (pageNum + 1) * size) {
+ rows = rows.subList(pageNum, rows.size());
+ } else {
+ rows = new ArrayList<>();
+ }
+ System.out.println(rows);
+ System.out.println(orderPrivateCar.getOrderMoney());
+ rows = rows.stream().filter(e -> e.getMoney() <= orderPrivateCar.getOrderMoney() || e.getDataType() == 2).collect(Collectors.toList());
+ System.out.println(rows);
+ return rows;
+ }
+
+ @Override
+ public ResultUtil payPrivateCarOrder(Integer payType, Integer orderId, Integer couponId, Integer type) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ if (orderPrivateCar.getState() == 8 || orderPrivateCar.getState() == 9) {
+ return ResultUtil.error("订单已完成支付，不允许重复支付", "");
+ }
+ if (orderPrivateCar.getState() != 7) {
+ return ResultUtil.error("订单不在待支付状态，不允许支付", "");
+ }
+ Integer uid = orderPrivateCar.getUserId();
+ Double orderMoney = orderPrivateCar.getOrderMoney();
+ UserInfo userInfo = userInfoService.selectById(uid);
+ ResultUtil resultUtil = ResultUtil.success(new Object());
+ orderPrivateCar.setCouponMoney(0D);//初始化历史数据
+ orderPrivateCar.setCouponId(null);
+
+ //计算优惠券
+ UserCouponRecord userCouponRecord = null;
+ if (null != couponId) {
+ userCouponRecord = userCouponRecordService.selectById(couponId);
+ if (userCouponRecord.getCompanyId() != orderPrivateCar.getCompanyId()) {
+ return ResultUtil.error("优惠券不能用于此订单", "");
+ }
+ if (userCouponRecord.getState() == 2) {
+ return ResultUtil.error("优惠券已使用", "");
+ }
+ if (userCouponRecord.getState() == 3) {
+ return ResultUtil.error("优惠券已过期", "");
+ }
+ if (userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1) {
+ return ResultUtil.error("优惠券不能用于此类型订单", "");
+ }
+ if (userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0) {
+ return ResultUtil.error("优惠券不能用于此订单", "");
+ }
+ orderMoney = orderMoney - userCouponRecord.getMoney();
+ orderPrivateCar.setCouponMoney(userCouponRecord.getMoney());
+ orderPrivateCar.setCouponId(couponId);
+ }
+
+
+ //计算红包
+ UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
+ if (null != query && query.getMoney().compareTo(orderMoney) < 0) {
+ orderMoney = orderMoney - query.getMoney();
+ orderPrivateCar.setRedPacketMoney(query.getMoney());
+ orderPrivateCar.setRedPacketId(query.getId());
+ }
+
+ //计算折扣
+ UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
+ if (null != query2) {
+ Double special = query2.getSpecial();
+ orderPrivateCar.setDiscount(special);
+ double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
+ if (orderMoney.compareTo(v) > 0) {
+ orderPrivateCar.setDiscountMoney(orderMoney - v);
+ orderPrivateCar.setActivityId(query2.getId());
+ orderMoney = v;
+ }
+ }
+ orderMoney = orderMoney < 0 ? 0 : orderMoney;
+ if (payType == 1) {//微信支付
+ String app = type == 1 ? "APP" : "JSAPI";
+ resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
+ paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据
+ }
+ if (payType == 2) {//支付宝支付
+ resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
+ paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 2, orderMoney, "", 1);//添加预支付数据
+ }
+ if (payType == 3) {//余额支付
+ if (userInfo.getBalance() == null || userInfo.getBalance() < orderMoney) {
+ return ResultUtil.error("余额不足，无法完成支付", "");
+ }
+
+ userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
+ userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
+
+ //添加交易明细
+ transactionDetailsService.saveData(uid, "快车订单", orderMoney, 2, 1, 1, 1, orderId);
+ userInfoService.updateById(userInfo);
+
+ orderPrivateCar.setState(8);
+ orderPrivateCar.setPayType(3);
+ orderPrivateCar.setPayMoney(orderMoney);
+
+ //处理优惠券和红包
+ if (null != userCouponRecord) {
+ userCouponRecord.setState(2);
+ userCouponRecord.setEndTime(new Date());
+ userCouponRecordService.updateById(userCouponRecord);
+ }
+ if (null != query) {
+ query.setState(2);
+ query.setEndTime(new Date());
+ userRedPacketRecordService.updateById(query);
+ }
+ //添加收入
+ Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
+ orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));
+
+ // TODO: 2020/5/24 这里需要给司机和用户推送订单状态
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
+ pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
+ }
+ }).start();
+
+ systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付，谢谢使用！", uid, 1);
+
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ if (pushMinistryOfTransport) {//上传数据
+ pushMinistryOfTransportUtil.operatePay(orderId);
+ }
+ }
+ }).start();
+ }
+
+ this.updateAllColumnById(orderPrivateCar);
+ return resultUtil;
+ }
+
+ @Override
+ @Transactional(propagation = Propagation.REQUIRES_NEW)
+ public ResultUtil payPrivateCarOrder1(Integer payType, Integer orderId, Integer objectId, Integer objectType, Integer type) throws Exception {
+
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ if (orderPrivateCar.getState() == 8 || orderPrivateCar.getState() == 9) {
+ return ResultUtil.error("订单已完成支付，不允许重复支付", new ArrayList<>());
+ }
+ if (orderPrivateCar.getState() != 7) {
+ return ResultUtil.error("订单不在待支付状态，不允许支付", new ArrayList<>());
+ }
+ Integer uid = orderPrivateCar.getUserId();
+ Double orderMoney = orderPrivateCar.getOrderMoney();
+ UserInfo userInfo = userInfoService.selectById(uid);
+ ResultUtil resultUtil = ResultUtil.success(new Object());
+ orderPrivateCar.setCouponMoney(0D);//初始化历史数据
+ orderPrivateCar.setCouponId(null);
+ System.out.println("!!!" + orderMoney + "!!!!");
+ //计算优惠券
+ UserCouponRecord userCouponRecord = null;
+ if (null != objectId && objectType == 1) {
+ userCouponRecord = userCouponRecordService.selectById(objectId);
+ if (userCouponRecord.getCompanyId() != orderPrivateCar.getCompanyId()) {
+ return ResultUtil.error("优惠券不能用于此订单", new ArrayList<>());
+ }
+ if (userCouponRecord.getState() == 2) {
+ return ResultUtil.error("优惠券已使用", new ArrayList<>());
+ }
+ if (userCouponRecord.getState() == 3) {
+ return ResultUtil.error("优惠券已过期", new ArrayList<>());
+ }
+ if (userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1) {
+ return ResultUtil.error("优惠券不能用于此类型订单", new ArrayList<>());
+ }
+ if (userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0) {
+ return ResultUtil.error("优惠券不能用于此订单", new ArrayList<>());
+ }
+ orderMoney = orderMoney - userCouponRecord.getMoney();
+ orderPrivateCar.setCouponMoney(userCouponRecord.getMoney());
+ orderPrivateCar.setCouponId(objectId);
+ System.out.println("!!!" + orderMoney + "!!!!");
+ }
+
+ //打车卡
+ UserTaxiCard userTaxiCard = null;
+ if (null != objectId && objectType == 2) {
+ userTaxiCard = userTaxiCardService.selectById(objectId);
+ TaxiCard taxiCard = taxiCardService.selectById(userTaxiCard.getTaxiCardId());
+ if (taxiCard.getTaxiCardType() == 1 && userTaxiCard.getCompanyId() != orderPrivateCar.getCompanyId()) {
+ return ResultUtil.error("打车卡不能用于此订单", new ArrayList<>());
+ }
+ if (System.currentTimeMillis() > userTaxiCard.getEndTime().getTime()) {
+ return ResultUtil.error("打车卡已过期", new ArrayList<>());
+ }
+ if (userTaxiCard.getType() == 1 || userTaxiCard.getType() == 3) {
+ Integer time = JSON.parseObject(userTaxiCard.getContent()).getInteger("time");
+ if (0 == time) {
+ return ResultUtil.error("打车卡已使用完", new ArrayList<>());
+ }
+ }
+ List<Integer> integers = JSON.parseObject(userTaxiCard.getContent()).getJSONArray("businessTypes").toJavaList(Integer.class);
+ if (!integers.contains(1)) {
+ return ResultUtil.error("打车卡不能用于此类型订单", new ArrayList<>());
+ }
+
+ Double yh = 0D;
+ JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
+ if (userTaxiCard.getType() == 1) {//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ Double discount = jsonObject.getDouble("discount");
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date date = new Date();
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
+ Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ yh = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+ jsonObject.put("time", jsonObject.getInteger("time") - 1);
+ userTaxiCard.setContent(jsonObject.toJSONString());
+ break;
+ }
+ }
+
+ }
+ if (userTaxiCard.getType() == 2) {//优惠卡{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]}
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date date = new Date();
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
+ Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ for (int j = fullReduction.size() - 1; j >= 0; j--) {
+ JSONArray jsonArray = fullReduction.getJSONArray(j);
+ Double p = jsonArray.getDouble(0);//满金额
+ if (orderPrivateCar.getOrderMoney().compareTo(p) >= 0) {
+ yh = jsonArray.getDouble(1);//优惠金额
+ break;
+ }
+ }
+ }
+ }
+
+ }
+ if (userTaxiCard.getType() == 3) {//次数卡{"businessTypes":[1,2,3],"time":1,"discountAmount":10}
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date date = new Date();
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
+ Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ yh = jsonObject.getDouble("discountAmount");
+ jsonObject.put("time", jsonObject.getInteger("time") - 1);
+ userTaxiCard.setContent(jsonObject.toJSONString());
+ }
+ }
+
+ }
+ if (userTaxiCard.getType() == 4) {//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
+ Double discount = jsonObject.getDouble("discount");//折扣
+ JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date date = new Date();
+ for (int i = 0; i < timeQuantum.size(); i++) {
+ String[] split = timeQuantum.getString(i).split(" - ");
+ Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
+ Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
+ if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
+ yh = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
+ break;
+ }
+ }
+ }
+
+ orderMoney = orderMoney - yh;
+ orderPrivateCar.setTaxiCardId(userTaxiCard.getTaxiCardId());
+ orderPrivateCar.setUserTaxiCardId(objectId);
+ orderPrivateCar.setDiscountAmount(yh);
+ }
+
+ System.out.println("!!!" + orderMoney + "!!!!");
+
+ //计算红包
+ UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
+ if (null != query && query.getMoney().compareTo(orderMoney) < 0) {
+ orderMoney = orderMoney - query.getMoney();
+ orderPrivateCar.setRedPacketMoney(query.getMoney());
+ orderPrivateCar.setRedPacketId(query.getId());
+ }
+
+ System.out.println("!!!" + orderMoney + "!!!!");
+ //计算折扣
+ UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
+ if (null != query2) {
+ Double special = query2.getSpecial();
+ orderPrivateCar.setDiscount(special);
+ double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
+ if (orderMoney.compareTo(v) > 0) {
+ orderPrivateCar.setDiscountMoney(orderMoney - v);
+ orderPrivateCar.setActivityId(query2.getId());
+ orderMoney = v;
+ }
+ }
+ orderMoney = new BigDecimal(orderMoney).setScale(2, RoundingMode.HALF_UP).doubleValue();
+ System.out.println("!!!" + orderMoney + "!!!!");
+ orderMoney = orderMoney < 0 ? 0 : orderMoney;
+ if (payType == 1) {//微信支付
+ if (orderMoney == 0) {
+ return ResultUtil.error("请使用余额支付");
+ }
+ String app = type == 1 ? "APP" : "JSAPI";
+ resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
+ paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据
+ }
+ if (payType == 2) {//支付宝支付
+ if (orderMoney == 0) {
+ return ResultUtil.error("请使用余额支付");
+ }
+ resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
+ paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 2, orderMoney, "", 1);//添加预支付数据
+ }
+ if (payType == 3) {//余额支付
+ if (userInfo.getBalance() == null || userInfo.getBalance() < orderMoney) {
+ return ResultUtil.error("余额不足，无法完成支付");
+ }
// if(orderMoney > 0){
// resultUtil= appOrderController.moneyPay(orderId,userInfo.getId(),orderMoney);
// if(resultUtil.getCode()==500){
// return ResultUtil.error("电子余额不足，无法完成支付");
// }
// }
- userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
-
- SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
- if(null != query1){
- userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
- }
-
- //添加交易明细
- transactionDetailsService.saveData(uid, "快车订单", orderMoney, 2, 1, 1, 1, orderId);
- userInfoService.updateById(userInfo);
-
- orderPrivateCar.setState(8);
- orderPrivateCar.setPayType(3);
- orderPrivateCar.setPayMoney(orderMoney);
-
- //处理优惠券和红包
- if(null != userCouponRecord){
- userCouponRecord.setState(2);
- userCouponRecord.setEndTime(new Date());
- userCouponRecordService.updateById(userCouponRecord);
- }
- //处理打车卡
- if(null != userTaxiCard){
- userTaxiCardService.updateById(userTaxiCard);
- }
- if(null != query){
- query.setState(2);
- query.setEndTime(new Date());
- userRedPacketRecordService.updateById(query);
- }
-
- //添加收入
- Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
- orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));
-
- // TODO: 2020/5/24 这里需要给司机和用户推送订单状态
- new Thread(new Runnable() {
- @Override
- public void run() {
- pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
- pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
- }
- }).start();
-
- systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付，谢谢使用！", uid, 1);
-
- new Thread(new Runnable() {
- @Override
- public void run() {
- if(pushMinistryOfTransport){//上传数据
- pushMinistryOfTransportUtil.operatePay(orderId);
- }
- }
- }).start();
- }else if(payType == 4){
- if(orderMoney == 0){
- return ResultUtil.error("请使用余额支付");
- }
- Integer integer = paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 4, orderMoney, "", 1);
- resultUtil = appOrderController.placeAnOrder(new BigDecimal(orderMoney), 4,orderId,6,integer);
-
- }
-
- this.updateAllColumnById(orderPrivateCar);
- return resultUtil;
- }
- @Autowired
- private AppOrderController appOrderController;
-
- @Override
- public synchronized ResultUtil<BaseWarpper> queryRedMoney(Integer orderId) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- Integer companyId = orderPrivateCar.getCompanyId();
-
- Map<String, Object> query = userActivityRedenvelopeService.query(companyId, orderPrivateCar.getTravelTime());
- Double money = 0D;
- BaseWarpper baseWarpper = new BaseWarpper();
- if(null != query){
- Integer type = Integer.valueOf(String.valueOf(query.get("type")));
- if(type == 1){//固定金额
- money = Double.valueOf(String.valueOf(query.get("money")));
- }else{//随机金额
- Double startMoney = Double.valueOf(String.valueOf(query.get("startMoney")));
- Double endMoney = Double.valueOf(String.valueOf(query.get("endMoney")));
- int i = new BigDecimal(endMoney).subtract(new BigDecimal(startMoney)).intValue();
- Random random = new Random();
- int num = random.nextInt(i);
- money = new BigDecimal(startMoney).add(new BigDecimal(num)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
- }
- //判断当前红包是否大于剩余可领取总金额
- if(money.compareTo(Double.valueOf(query.get("lavePrice").toString())) > 0){
- baseWarpper.setAmount(0D);
- return ResultUtil.success(baseWarpper);
- }
- }
- baseWarpper.setAmount(money);
-
- if(money > 0){
- //添加临时红包数据
- UserRedPacketRecord userRedPacketRecord = new UserRedPacketRecord();
- userRedPacketRecord.setMoney(money);
- Calendar calendar = Calendar.getInstance();
- calendar.setTime(new Date());
- calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(query.get("effective"))));
- userRedPacketRecord.setExpirationTime(calendar.getTime());
- userRedPacketRecord.setInsertTime(new Date());
- userRedPacketRecord.setCompanyId(Integer.valueOf(String.valueOf(query.get("companyId"))));
- userRedPacketRecord.setState(0);
- userRedPacketRecord.setOrderId(orderPrivateCar.getId());
- userRedPacketRecord.setOrderType(1);
- userRedPacketRecord.setUserId(orderPrivateCar.getUserId());
- userRedPacketRecordService.insert(userRedPacketRecord);
- }
-
- // 获取平台电子账簿 当前用户电子账簿
- appOrderController.moneyPay(orderPrivateCar.getId(),orderPrivateCar.getUserId(),money);
-
- return ResultUtil.success(baseWarpper);
- }
-
-
- @Override
- public synchronized ResultUtil shareRedEnvelope(Integer orderId) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- UserRedPacketRecord query = userRedPacketRecordService.query_(orderPrivateCar.getUserId(), orderPrivateCar.getCompanyId(), 0, 1, null);
- if(null != query){
- Double money = query.getMoney();
- Map<String, Object> map = userActivityRedenvelopeService.query(orderPrivateCar.getCompanyId(), orderPrivateCar.getTravelTime());
- Double laveMoney = Double.valueOf(String.valueOf(map.get("laveMoney")));
- if(money.compareTo(laveMoney) > 0){
- return ResultUtil.error("手速太慢了，红包已派发完啦！");
- }
- //判断当前红包是否大于剩余可领取总金额
- if(money.compareTo(Double.valueOf(map.get("lavePrice").toString())) > 0){
- return ResultUtil.error("手速太慢了，红包已派发完啦！");
- }
- double v = new BigDecimal(laveMoney).subtract(new BigDecimal(money)).doubleValue();
-
- UserActivityRedenvelope id = userActivityRedenvelopeService.selectById(String.valueOf(map.get("id")));
- id.setLaveMoney(v);
- id.setLavePrice(new BigDecimal(id.getLavePrice() - money).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
- userActivityRedenvelopeService.updateById(id);
-
- query.setState(1);
- query.setRedPacketActivityId(id.getId());
- userRedPacketRecordService.updateById(query);
- }
- return ResultUtil.success();
- }
-
-
- /**
- * 取消订单支付后的处理
- * @param id 订单=id
- * @param order_id 工行支付单号
- * @param type 1=微信，2=支付宝
- * @throws Exception
- */
- @Override
- public void payCancelOrderPrivateCar(Integer id, String order_id, Integer type) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(id);
- PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getUserId(), 1, Integer.valueOf(id), 1, type, 1);
- if(null != query){
- //添加交易明细
- transactionDetailsService.saveData(orderPrivateCar.getUserId(), "快车取消订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
- orderPrivateCar.setState(10);
- //解除小号绑定
- if(orderPrivateCar.getBindId() != null){
- chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 600000));
- }
- orderPrivateCar.setBindId("");
- orderPrivateCar.setTelX("");
- this.updateById(orderPrivateCar);
-
- query.setState(2);
- query.setCode(order_id);
- paymentRecordService.updateById(query);
-
- OrderCancel query1 = orderCancelService.query(query.getOrderId(), query.getOrderType(), query.getAmount(), query.getPayType(), 1);
- if (null != query1){
- query1.setState(2);
- orderCancelService.updateById(query1);
- }
-
- //添加已收入明细
- incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, query.getAmount());
-
- this.deleteTask(orderPrivateCar.getId());//删除定时任务
-
- // TODO: 2020/5/24 这里需要给司机和用户推送订单状态
+ userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
+ if (null != query1) {
+ userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
+ }
+
+ //添加交易明细
+ transactionDetailsService.saveData(uid, "快车订单", orderMoney, 2, 1, 1, 1, orderId);
+ userInfoService.updateById(userInfo);
+
+ orderPrivateCar.setState(8);
+ orderPrivateCar.setPayType(3);
+ orderPrivateCar.setPayMoney(orderMoney);
+
+ //处理优惠券和红包
+ if (null != userCouponRecord) {
+ userCouponRecord.setState(2);
+ userCouponRecord.setEndTime(new Date());
+ userCouponRecordService.updateById(userCouponRecord);
+ }
+ //处理打车卡
+ if (null != userTaxiCard) {
+ userTaxiCardService.updateById(userTaxiCard);
+ }
+ if (null != query) {
+ query.setState(2);
+ query.setEndTime(new Date());
+ userRedPacketRecordService.updateById(query);
+ }
+
+ //添加收入
+ Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
+ orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));
+
+ // TODO: 2020/5/24 这里需要给司机和用户推送订单状态
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
+ pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
+ }
+ }).start();
+
+ systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付，谢谢使用！", uid, 1);
+
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ if (pushMinistryOfTransport) {//上传数据
+ pushMinistryOfTransportUtil.operatePay(orderId);
+ }
+ }
+ }).start();
+ } else if (payType == 4) {
+ if (orderMoney == 0) {
+ return ResultUtil.error("请使用余额支付");
+ }
+ Integer integer = paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 4, orderMoney, "", 1);
+ resultUtil = appOrderController.placeAnOrder(new BigDecimal(orderMoney), 4, orderId, 6, integer);
+
+ }
+
+ this.updateAllColumnById(orderPrivateCar);
+ return resultUtil;
+ }
+
+ @Override
+ public synchronized ResultUtil<BaseWarpper> queryRedMoney(Integer orderId) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ Integer companyId = orderPrivateCar.getCompanyId();
+
+ Map<String, Object> query = userActivityRedenvelopeService.query(companyId, orderPrivateCar.getTravelTime());
+ Double money = 0D;
+ BaseWarpper baseWarpper = new BaseWarpper();
+ if (null != query) {
+ Integer type = Integer.valueOf(String.valueOf(query.get("type")));
+ if (type == 1) {//固定金额
+ money = Double.valueOf(String.valueOf(query.get("money")));
+ } else {//随机金额
+ Double startMoney = Double.valueOf(String.valueOf(query.get("startMoney")));
+ Double endMoney = Double.valueOf(String.valueOf(query.get("endMoney")));
+ int i = new BigDecimal(endMoney).subtract(new BigDecimal(startMoney)).intValue();
+ Random random = new Random();
+ int num = random.nextInt(i);
+ money = new BigDecimal(startMoney).add(new BigDecimal(num)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
+ }
+ //判断当前红包是否大于剩余可领取总金额
+ if (money.compareTo(Double.valueOf(query.get("lavePrice").toString())) > 0) {
+ baseWarpper.setAmount(0D);
+ return ResultUtil.success(baseWarpper);
+ }
+ }
+ baseWarpper.setAmount(money);
+
+ if (money > 0) {
+ //添加临时红包数据
+ UserRedPacketRecord userRedPacketRecord = new UserRedPacketRecord();
+ userRedPacketRecord.setMoney(money);
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(new Date());
+ calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(query.get("effective"))));
+ userRedPacketRecord.setExpirationTime(calendar.getTime());
+ userRedPacketRecord.setInsertTime(new Date());
+ userRedPacketRecord.setCompanyId(Integer.valueOf(String.valueOf(query.get("companyId"))));
+ userRedPacketRecord.setState(0);
+ userRedPacketRecord.setOrderId(orderPrivateCar.getId());
+ userRedPacketRecord.setOrderType(1);
+ userRedPacketRecord.setUserId(orderPrivateCar.getUserId());
+ userRedPacketRecordService.insert(userRedPacketRecord);
+ }
+
+ // 获取平台电子账簿 当前用户电子账簿
+ appOrderController.moneyPay(orderPrivateCar.getId(), orderPrivateCar.getUserId(), money);
+
+ return ResultUtil.success(baseWarpper);
+ }
+
+ @Override
+ public synchronized ResultUtil shareRedEnvelope(Integer orderId) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ UserRedPacketRecord query = userRedPacketRecordService.query_(orderPrivateCar.getUserId(), orderPrivateCar.getCompanyId(), 0, 1, null);
+ if (null != query) {
+ Double money = query.getMoney();
+ Map<String, Object> map = userActivityRedenvelopeService.query(orderPrivateCar.getCompanyId(), orderPrivateCar.getTravelTime());
+ Double laveMoney = Double.valueOf(String.valueOf(map.get("laveMoney")));
+ if (money.compareTo(laveMoney) > 0) {
+ return ResultUtil.error("手速太慢了，红包已派发完啦！");
+ }
+ //判断当前红包是否大于剩余可领取总金额
+ if (money.compareTo(Double.valueOf(map.get("lavePrice").toString())) > 0) {
+ return ResultUtil.error("手速太慢了，红包已派发完啦！");
+ }
+ double v = new BigDecimal(laveMoney).subtract(new BigDecimal(money)).doubleValue();
+
+ UserActivityRedenvelope id = userActivityRedenvelopeService.selectById(String.valueOf(map.get("id")));
+ id.setLaveMoney(v);
+ id.setLavePrice(new BigDecimal(id.getLavePrice() - money).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+ userActivityRedenvelopeService.updateById(id);
+
+ query.setState(1);
+ query.setRedPacketActivityId(id.getId());
+ userRedPacketRecordService.updateById(query);
+ }
+ return ResultUtil.success();
+ }
+
+ /**
+ * 取消订单支付后的处理
+ *
+ * @param id 订单=id
+ * @param order_id 工行支付单号
+ * @param type 1=微信，2=支付宝
+ * @throws Exception
+ */
+ @Override
+ public void payCancelOrderPrivateCar(Integer id, String order_id, Integer type) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(id);
+ PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getUserId(), 1, Integer.valueOf(id), 1, type, 1);
+ if (null != query) {
+ //添加交易明细
+ transactionDetailsService.saveData(orderPrivateCar.getUserId(), "快车取消订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
+ orderPrivateCar.setState(10);
+ //解除小号绑定
+ if (orderPrivateCar.getBindId() != null) {
+ chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 600000));
+ }
+ orderPrivateCar.setBindId("");
+ orderPrivateCar.setTelX("");
+ this.updateById(orderPrivateCar);
+
+ query.setState(2);
+ query.setCode(order_id);
+ paymentRecordService.updateById(query);
+
+ OrderCancel query1 = orderCancelService.query(query.getOrderId(), query.getOrderType(), query.getAmount(), query.getPayType(), 1);
+ if (null != query1) {
+ query1.setState(2);
+ orderCancelService.updateById(query1);
+ }
+
+ //添加已收入明细
+ incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, query.getAmount());
+
+ this.deleteTask(orderPrivateCar.getId());//删除定时任务
+
+ // TODO: 2020/5/24 这里需要给司机和用户推送订单状态
// new Thread(new Runnable() {
// @Override
// public void run() {
// pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
// }
// }).start();
+
+ //添加消息
+ systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : (type == 2 ? "支付宝" : "云闪付")) + "成功支付取消订单费用，谢谢使用！", orderPrivateCar.getUserId(), 1);
+ } else {
+ System.err.println("预支付数据异常（orderId = " + id + ")");
+ }
+ }
+
+ @Override
+ public void payOrderPrivateCarCallback(Integer id, String order_id, Integer type) throws Exception {
+ OrderPrivateCar orderPrivateCar = this.selectById(id);
+ PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getUserId(), 1, Integer.valueOf(id), 1, type, 1);
+ if (null != query && query.getState() == 1) {
+ //添加交易明细
+ transactionDetailsService.saveData(orderPrivateCar.getUserId(), "快车订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
+ orderPrivateCar.setState(8);
+ orderPrivateCar.setPayType(type);
+ orderPrivateCar.setPayMoney(query.getAmount());
+
+ UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
+ userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
+ userInfoService.updateById(userInfo);
+
+ //处理优惠券和红包
+ if (null != orderPrivateCar.getCouponId()) {
+ UserCouponRecord userCouponRecord = userCouponRecordService.selectById(orderPrivateCar.getCouponId());
+ userCouponRecord.setState(2);
+ userCouponRecord.setEndTime(new Date());
+ userCouponRecordService.updateById(userCouponRecord);
+ }
+ if (null != orderPrivateCar.getUserTaxiCardId()) {
+ UserTaxiCard userTaxiCard = userTaxiCardService.selectById(orderPrivateCar.getUserTaxiCardId());
+ if (userTaxiCard.getType() == 1 || userTaxiCard.getType() == 3) {
+ JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
+ jsonObject.put("time", jsonObject.getInteger("time") - 1);
+ userTaxiCard.setContent(jsonObject.toJSONString());
+ userTaxiCardService.updateById(userTaxiCard);
+ }
+ }
+ if (null != orderPrivateCar.getRedPacketId()) {
+ UserRedPacketRecord userRedPacketRecord = userRedPacketRecordService.selectById(orderPrivateCar.getRedPacketId());
+ userRedPacketRecord.setState(2);
+ userRedPacketRecord.setEndTime(new Date());
+ userRedPacketRecordService.updateById(userRedPacketRecord);
+ }
+
+
+ query.setState(2);
+ query.setCode(order_id);
+ paymentRecordService.updateById(query);
+
+ //添加收入
+ Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
+ orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));
+ this.updateById(orderPrivateCar);
+
+ // TODO: 2020/5/24 这里需要给司机和用户推送订单状态
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
+ pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
+ }
+ }).start();
+
+ systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : (type == 2 ? "支付宝" : "云闪付")) + "成功完成出行订单支付，谢谢使用！", orderPrivateCar.getUserId(), 1);
+
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ if (pushMinistryOfTransport) {//上传数据
+ pushMinistryOfTransportUtil.operatePay(orderPrivateCar.getId());
+ }
+ }
+ }).start();
+
+ } else {
+ System.err.println("预支付数据异常（orderId = " + id + ")");
+ }
+ }
+
+ @Override
+ public List<OrderPrivateCar> queryOrder(Integer uid, Integer... state) throws Exception {
+ return orderPrivateCarMapper.queryByState_(uid, state);
+ }
+
+ @Override
+ public List<Map<String, Object>> queryMyOrderList(Integer uid, Integer pageNum, Integer size) throws Exception {
+ pageNum = (pageNum - 1) * size;
+ List<Map<String, Object>> maps = orderPrivateCarMapper.queryMyOrderList(uid, pageNum, size);
+ for (Map<String, Object> map : maps) {
+ if (Integer.valueOf(String.valueOf(map.get("state"))) == 11) {
+ map.put("state", map.get("oldState"));
+ }
+ }
+ return maps;
+ }
+
+ @Override
+ public List<Map<String, Object>> queryInvoiceOrder(Integer type, Date startTime, Date endTime, Double startMoney, Double endMoney, Integer uid) throws Exception {
+ startTime = dateUtil.getStartOrEndDate(startTime, "start");
+ endTime = dateUtil.getStartOrEndDate(endTime, "end");
+ return orderPrivateCarMapper.queryInvoiceOrder(type, startTime, endTime, startMoney, endMoney, uid);
+ }
+
+
+ @Override
+ public List<Map<String, Object>> queryMyTravelRecord(Integer uid) throws Exception {
+ return orderPrivateCarMapper.queryMyTravelRecord(uid);
+ }
+
- //添加消息
- systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : (type==2?"支付宝":"云闪付")) + "成功支付取消订单费用，谢谢使用！", orderPrivateCar.getUserId(), 1);
- }else{
- System.err.println("预支付数据异常（orderId = " + id + ")");
- }
- }
-
- @Override
- public void payOrderPrivateCarCallback(Integer id, String order_id, Integer type) throws Exception {
- OrderPrivateCar orderPrivateCar = this.selectById(id);
- PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getUserId(), 1, Integer.valueOf(id), 1, type, 1);
- if(null != query && query.getState() == 1){
- //添加交易明细
- transactionDetailsService.saveData(orderPrivateCar.getUserId(), "快车订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
- orderPrivateCar.setState(8);
- orderPrivateCar.setPayType(type);
- orderPrivateCar.setPayMoney(query.getAmount());
-
- UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
- SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
- userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
- userInfoService.updateById(userInfo);
-
- //处理优惠券和红包
- if(null != orderPrivateCar.getCouponId()){
- UserCouponRecord userCouponRecord = userCouponRecordService.selectById(orderPrivateCar.getCouponId());
- userCouponRecord.setState(2);
- userCouponRecord.setEndTime(new Date());
- userCouponRecordService.updateById(userCouponRecord);
- }
- if(null != orderPrivateCar.getUserTaxiCardId()){
- UserTaxiCard userTaxiCard = userTaxiCardService.selectById(orderPrivateCar.getUserTaxiCardId());
- if(userTaxiCard.getType() == 1 || userTaxiCard.getType() == 3){
- JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
- jsonObject.put("time", jsonObject.getInteger("time") - 1);
- userTaxiCard.setContent(jsonObject.toJSONString());
- userTaxiCardService.updateById(userTaxiCard);
- }
- }
- if(null != orderPrivateCar.getRedPacketId()){
- UserRedPacketRecord userRedPacketRecord = userRedPacketRecordService.selectById(orderPrivateCar.getRedPacketId());
- userRedPacketRecord.setState(2);
- userRedPacketRecord.setEndTime(new Date());
- userRedPacketRecordService.updateById(userRedPacketRecord);
- }
-
-
- query.setState(2);
- query.setCode(order_id);
- paymentRecordService.updateById(query);
-
- //添加收入
- Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
- orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));
- this.updateById(orderPrivateCar);
-
- // TODO: 2020/5/24 这里需要给司机和用户推送订单状态
- new Thread(new Runnable() {
- @Override
- public void run() {
- pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
- pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
- }
- }).start();
-
- systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信": (type==2?"支付宝":"云闪付")) + "成功完成出行订单支付，谢谢使用！", orderPrivateCar.getUserId(), 1);
-
- new Thread(new Runnable() {
- @Override
- public void run() {
- if(pushMinistryOfTransport){//上传数据
- pushMinistryOfTransportUtil.operatePay(orderPrivateCar.getId());
- }
- }
- }).start();
-
- }else{
- System.err.println("预支付数据异常（orderId = " + id + ")");
- }
- }
-
- @Override
- public List<OrderPrivateCar> queryOrder(Integer uid, Integer... state) throws Exception {
- return orderPrivateCarMapper.queryByState_(uid, state);
- }
-
- @Override
- public List<Map<String, Object>> queryMyOrderList(Integer uid, Integer pageNum, Integer size) throws Exception {
- pageNum = (pageNum - 1) * size;
- List<Map<String, Object>> maps = orderPrivateCarMapper.queryMyOrderList(uid, pageNum, size);
- for(Map<String, Object> map : maps){
- if(Integer.valueOf(String.valueOf(map.get("state"))) == 11){
- map.put("state", map.get("oldState"));
- }
- }
- return maps;
- }
-
- @Override
- public List<Map<String, Object>> queryInvoiceOrder(Integer type, Date startTime, Date endTime, Double startMoney, Double endMoney, Integer uid) throws Exception {
- startTime = dateUtil.getStartOrEndDate(startTime, "start");
- endTime = dateUtil.getStartOrEndDate(endTime, "end");
- return orderPrivateCarMapper.queryInvoiceOrder(type, startTime, endTime, startMoney, endMoney, uid);
- }
-
- public void pushOrder(Integer id, Integer rideType, Integer serverCarModelId, Double startLon, Double startLat) throws Exception{
- new Thread(new Runnable() {
- @Override
- public void run() {
- try {
- Integer orderType = rideType==1?1:rideType==2?9:8;
- orderIds.add(id);//添加记录，防止调用接口重复提醒无人接单
- String vehicle = (String) redisTemplate.opsForValue().get("VEHICLE");
- List<Integer> integers = new ArrayList<>();
- if(ToolUtil.isNotEmpty(vehicle)){
- integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
- }
- Company query = companyCityService.query(startLon.toString(), startLat.toString());//获取起点所属分公司
- List<PushOrder> querys = pushOrderService.querys(null, 1, query.getId());//获取需要推送的次数
- for(int i = 1; i <= querys.size(); i++){
- OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(id);
- if (null == orderPrivateCar || orderPrivateCar.getState() > 1) {
- break;
- }
- PushOrder pushOrder = pushOrderService.querys(i, 1, query.getId()).get(0);
- System.out.println("pushOrder:"+pushOrder);
- int i2 = pushOrder.getPushTime() / 10;
- if(i2==0){
- i2=1;
- }
- for (int i1 = 0; i1 < i2 ; i1++) {
- if (orderPrivateCar.getState() > 1) {
- break;
- }
- //获取空闲司机
- List<Driver> list = driverService.queryIdleDriver(orderType, serverCarModelId, startLon, startLat, pushOrder.getPushDistance(), null);//所有附近空闲司机
- if (list.size() > 0) {
- double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
- int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
- lastIndex = lastIndex == 0 ? list.size() : lastIndex;
- list = list.subList(0, lastIndex);//获取空闲司机中占比数据
- for (Driver driver : list) {//开始进行推送
- boolean bo = false;
- for (Integer integer : integers) {
- if (integer.compareTo(driver.getId()) == 0) {
- bo = true;
- break;
- }
- }
- if (bo) {
- continue;
- }
- pushUtil.pushOrderState(2, driver.getId(), id, 1, 1, pushOrder.getPushTime());
- }
- }
- Thread.sleep(10000);//设置等待时间
- Integer state = orderPrivateCarMapper.selectById(orderPrivateCar.getId()).getState();
- if (state > 1) {
- orderIds.remove(orderPrivateCar.getId());
- break;
- }
- if (i == querys.size()) {
- pushUtil.pushEndPush(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1);
- orderIds.remove(orderPrivateCar.getId());
- }
- }
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }).start();
- }
-
- @Override
- public List<Map<String, Object>> queryMyTravelRecord(Integer uid) throws Exception {
- return orderPrivateCarMapper.queryMyTravelRecord(uid);
- }
-
- /**
- * 推送抢单数据
- * @param orderPrivateCar
- * @throws Exception
- */
- public void pushOrder(OrderPrivateCar orderPrivateCar) throws Exception{
- new Thread(new Runnable() {
- @Override
- public void run() {
- try {
- Integer id = orderPrivateCar.getId();
- Integer orderType = orderPrivateCar.getRideType()==1?1:orderPrivateCar.getRideType()==2?9:8;
- orderIds.add(orderPrivateCar.getId());//添加记录，防止调用接口重复提醒无人接单
- String vehicle = (String) redisTemplate.opsForValue().get("VEHICLE");
- List<Integer> integers = new ArrayList<>();
- if(ToolUtil.isNotEmpty(vehicle)){
- integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
- }
- Company query = companyCityService.query(String.valueOf(orderPrivateCar.getStartLon()), String.valueOf(orderPrivateCar.getStartLat()));//获取起点所属分公司
- List<PushOrder> querys = pushOrderService.querys(null, 1, query.getId());//获取需要推送的次数
- for(int i = 1; i <= querys.size()+5; i++){
- OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(id);
- if (null == orderPrivateCar || orderPrivateCar.getState() > 1) {
- break;
- }
- PushOrder pushOrder = pushOrderService.querys(i, 1, query.getId()).get(0);
- System.out.println("pushOrder:"+pushOrder);
- int i2 = pushOrder.getPushTime() / 10;
- if(i2==0){
- i2=1;
- }
- for (int i1 = 0; i1 < i2 ; i1++) {
- if (orderPrivateCar.getState() > 1) {
- break;
- }
- //获取空闲司机
- List<Driver> list = driverService.queryIdleDriver(orderType, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机
- if (list.size() > 0) {
- double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
- int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
- lastIndex = lastIndex == 0 ? list.size() : lastIndex;
- list = list.subList(0, lastIndex);//获取空闲司机中占比数据
- for (Driver driver : list) {//开始进行推送
- boolean bo = false;
- for (Integer integer : integers) {
- if (integer.compareTo(driver.getId()) == 0) {
- bo = true;
- break;
- }
- }
- if (bo) {
- continue;
- }
- pushUtil.pushOrderState(2, driver.getId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), pushOrder.getPushTime());
- }
- }
- Thread.sleep(10000);//设置等待时间
- Integer state = orderPrivateCar.getState();
- if (state > 1) {
- orderIds.remove(orderPrivateCar.getId());
- return;
- }
- if (i == querys.size()+5 && state == 1) {
- pushUtil.pushEndPush(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1);
- orderIds.remove(orderPrivateCar.getId());
- }
- }
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }).start();
- }
-
-
- /**
- * 获取红包使用记录
- * @param uid
- * @return
- * @throws Exception
- */
- @Override
- public List<Map<String, Object>> queryRedEnvelope(Integer uid) throws Exception {
- return orderPrivateCarMapper.queryRedEnvelope(uid);
- }
-
- /**
- * 获取下单推送完后没有司机接单的提醒
- * @return
- * @throws Exception
- */
- @Override
- public EndPushWarpper queryEndPush(Integer uid) throws Exception {
- List<OrderPrivateCar> list = orderPrivateCarMapper.queryByState(uid, null, null, 1);
- EndPushWarpper endPushWarpper = new EndPushWarpper();
- if(list.size() > 0){
- OrderPrivateCar orderPrivateCar = list.get(0);
- if(!orderIds.contains(orderPrivateCar.getId())){
- endPushWarpper.setOrderId(orderPrivateCar.getId());
- endPushWarpper.setOrderType(1);
- endPushWarpper.setState(1);
- List<PushOrder> querys = pushOrderService.querys(null, 2, orderPrivateCar.getCompanyId());//获取需要推送的次数
- int time = 0;
- for(int i = 1; i <= querys.size()+5; i++){
- PushOrder pushOrder = pushOrderService.querys(i, 2, orderPrivateCar.getCompanyId()).get(0);
- time += pushOrder.getPushTime() * 1000;
- }
- //当前时间减去推单总时间大于下单时间
- if((System.currentTimeMillis() - time) > orderPrivateCar.getInsertTime().getTime()){
- endPushWarpper.setState(2);
- }
- }
- }
- return endPushWarpper;
- }
-
-
- @Override
- @Transactional(propagation = Propagation.REQUIRES_NEW)
- public ResultUtil payThankYouFee(Integer uid, Integer orderId, Double money, Integer payType, Integer type) throws Exception {
- UserInfo userInfo = userInfoService.selectById(uid);
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- ResultUtil resultUtil = ResultUtil.success();
- if(payType == 1){//微信支付
- String app = type == 1 ? "APP" : "JSAPI";
- resultUtil = payMoneyUtil.weixinpay("感谢费", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/wxPayThankYouFee", app, userInfo.getAppletsOpenId());
- paymentRecordService.saveData(3, uid, 1, orderId, 1, 1, money, "", 1);//添加预支付数据
- }
- if(payType == 2){//支付宝支付
- resultUtil = payMoneyUtil.alipay("感谢费", "感谢费", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/aliPayThankYouFee");
- paymentRecordService.saveData(3, uid, 1, orderId, 1, 2, money, "", 1);//添加预支付数据
- }
- if(payType == 3) {//余额支付
- if (userInfo.getBalance() == null || userInfo.getBalance() < money) {
- return ResultUtil.error("余额不足，无法完成支付");
- }
+
+ /**
+ * 获取下单推送完后没有司机接单的提醒
+ *
+ * @return
+ * @throws Exception
+ */
+ @Override
+ public EndPushWarpper queryEndPush(Integer uid) throws Exception {
+ List<OrderPrivateCar> list = orderPrivateCarMapper.queryByState(uid, null, null, 1);
+ EndPushWarpper endPushWarpper = new EndPushWarpper();
+ if (list.size() > 0) {
+ OrderPrivateCar orderPrivateCar = list.get(0);
+ if (!orderIds.contains(orderPrivateCar.getId())) {
+ endPushWarpper.setOrderId(orderPrivateCar.getId());
+ endPushWarpper.setOrderType(1);
+ endPushWarpper.setState(1);
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ List<PushOrder> querys = pushOrderService.querys(null, 2, openCity.getId());//获取需要推送的次数
+ int time = 0;
+ for (int i = 1; i <= querys.size() + 5; i++) {
+ int finalI = i;
+ PushOrder pushOrder = querys.stream().filter(s -> s.getType() == (finalI <= 3 ? finalI : 3)).findFirst().orElse(null);
+ time += pushOrder.getPushTime() * 1000;
+ }
+ //当前时间减去推单总时间大于下单时间
+ if ((System.currentTimeMillis() - time) > orderPrivateCar.getInsertTime().getTime()) {
+ endPushWarpper.setState(2);
+ }
+ }
+ }
+ return endPushWarpper;
+ }
+
+ /**
+ * 获取红包使用记录
+ *
+ * @param uid
+ * @return
+ * @throws Exception
+ */
+ @Override
+ public List<Map<String, Object>> queryRedEnvelope(Integer uid) throws Exception {
+ return orderPrivateCarMapper.queryRedEnvelope(uid);
+ }
+
+ @Override
+ @Transactional(propagation = Propagation.REQUIRES_NEW)
+ public ResultUtil payThankYouFee(Integer uid, Integer orderId, Double money, Integer payType, Integer type) throws Exception {
+ UserInfo userInfo = userInfoService.selectById(uid);
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ ResultUtil resultUtil = ResultUtil.success();
+ if (payType == 1) {//微信支付
+ String app = type == 1 ? "APP" : "JSAPI";
+ resultUtil = payMoneyUtil.weixinpay("感谢费", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/wxPayThankYouFee", app, userInfo.getAppletsOpenId());
+ paymentRecordService.saveData(3, uid, 1, orderId, 1, 1, money, "", 1);//添加预支付数据
+ }
+ if (payType == 2) {//支付宝支付
+ resultUtil = payMoneyUtil.alipay("感谢费", "感谢费", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/aliPayThankYouFee");
+ paymentRecordService.saveData(3, uid, 1, orderId, 1, 2, money, "", 1);//添加预支付数据
+ }
+ if (payType == 3) {//余额支付
+ if (userInfo.getBalance() == null || userInfo.getBalance() < money) {
+ return ResultUtil.error("余额不足，无法完成支付");
+ }
// resultUtil= appOrderController.moneyPay(orderId,userInfo.getId(),money);
// if(resultUtil.getCode()==500){
// return ResultUtil.error("电子余额不足，无法完成支付");
// }
- userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
-
- SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
- userInfo.setIntegral(userInfo.getIntegral() + (money.intValue() * query1.getIntegral()));//积分
-
- //添加交易明细
- transactionDetailsService.saveData(uid, "快车订单-感谢费", money, 2, 1, 1, 1, orderId);
- userInfoService.updateById(userInfo);
-
- orderPrivateCar.setThankYouFee(money);
- this.updateById(orderPrivateCar);
-
- //添加已收入明细
- incomeService.saveData(2, orderPrivateCar.getDriverId(), 6, orderPrivateCar.getId(), 1, money);
- Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
- driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
- driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
- driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
- driverService.updateById(driver);
- systemNoticeService.addSystemNotice(1, "您已使用余额成功完成感谢费支付，谢谢使用！", uid, 1);
-
- }
- if(payType==4){
- Double payMoney = orderPrivateCar.getThankYouFee();
- Integer integer = paymentRecordService.saveData(3, uid, 1, orderId, 1, 4, money, "", 1);
- resultUtil = appOrderController.placeAnOrder(new BigDecimal(money), 4,orderId,11,integer);
- }
- return resultUtil;
- }
-
- @Override
- public void payThankYouFeeCallback(Integer orderId, String order_id, Integer payType) throws Exception {
- System.out.println(orderId+"_"+order_id+"_"+payType);
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
- System.out.println("用户"+userInfo);
- PaymentRecord query = paymentRecordService.query(3, userInfo.getId(), 1, orderId, 1, payType, 1);
- System.out.println("query:"+query);
- query.setState(2);
- query.setCode(order_id);
- paymentRecordService.updateById(query);
- System.out.println(orderPrivateCar.getCompanyId());
- SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
- System.out.println("query1:"+query1);
- userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
-
- //添加交易明细
- transactionDetailsService.saveData(userInfo.getId(), "快车订单-感谢费", query.getAmount(), 2, 1, 1, 1, orderId);
- userInfoService.updateById(userInfo);
-
- orderPrivateCar.setThankYouFee(query.getAmount());
- this.updateById(orderPrivateCar);
-
- //添加已收入明细
- incomeService.saveData(2, orderPrivateCar.getDriverId(), 6, orderPrivateCar.getId(), 1, query.getAmount());
- Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
- driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
- driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
- driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
- driverService.updateById(driver);
- systemNoticeService.addSystemNotice(1, "您已使用" + (payType == 1 ? "微信" : (payType==2?"支付宝":"云闪付")) + "成功完成感谢费支付，谢谢使用！", userInfo.getId(), 1);
- System.out.println("出租车感谢费ok");
- }
-
- @Override
- public List<Map<String, Object>> queryOrderInfo2(Integer orderId, Integer state, String lon, String lat) {
- return this.baseMapper.queryOrderInfo2(orderId,state,lon,lat);
- }
-
- /**
- * 获取专车未支付订单
- * @param uid
- * @return
- */
- @Override
- public List<UnPayOrderVO> getUnpayPrivateOrders(Integer uid) {
- EntityWrapper<OrderPrivateCar> wrapper = new EntityWrapper<>();
- wrapper.eq("userId", uid);
- wrapper.eq("state", 7);
- //查出未支付订单
- List<OrderPrivateCar> orderPrivateCars = this.selectList(wrapper);
- List<UnPayOrderVO> unPayOrderVOList = new ArrayList<>();
- for (OrderPrivateCar order : orderPrivateCars) {
- UnPayOrderVO vo = new UnPayOrderVO();
- // 复制属性
- //添加司机信息
- DriverInfoWarpper driverInfoWarpper = new DriverInfoWarpper();
- Driver driver = driverService.selectById(order.getDriverId());
- BeanUtils.copyProperties(driver, driverInfoWarpper);
- vo.setDriverInfoWarpper(driverInfoWarpper);
- //其余信息
- BeanUtils.copyProperties(order, vo);
- unPayOrderVOList.add(vo);
- }
-
- return unPayOrderVOList;
- }
-
- @Override
- public void addAppeal(Integer uid, Integer orderId,String abnormalIntro, String abnormalImg) {
- OrderPrivateCar orderPrivateCar = this.selectById(orderId);
- if(orderPrivateCar.getState()!=7 || orderPrivateCar.getAbnormalIntro()!=null){
- throw new RuntimeException("此订单无法申诉");
- }
- orderPrivateCar.setAbnormalIntro(abnormalIntro);
- orderPrivateCar.setAbnormalImg(abnormalImg);
- orderPrivateCar.setAbnormal(1);
- this.baseMapper.updateById(orderPrivateCar);
-
- }
+ userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
+ userInfo.setIntegral(userInfo.getIntegral() + (money.intValue() * query1.getIntegral()));//积分
+
+ //添加交易明细
+ transactionDetailsService.saveData(uid, "快车订单-感谢费", money, 2, 1, 1, 1, orderId);
+ userInfoService.updateById(userInfo);
+
+ orderPrivateCar.setThankYouFee(money);
+ this.updateById(orderPrivateCar);
+
+ //添加已收入明细
+ incomeService.saveData(2, orderPrivateCar.getDriverId(), 6, orderPrivateCar.getId(), 1, money);
+ Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
+ driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+ driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+ driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+ driverService.updateById(driver);
+ systemNoticeService.addSystemNotice(1, "您已使用余额成功完成感谢费支付，谢谢使用！", uid, 1);
+
+ }
+ if (payType == 4) {
+ Double payMoney = orderPrivateCar.getThankYouFee();
+ Integer integer = paymentRecordService.saveData(3, uid, 1, orderId, 1, 4, money, "", 1);
+ resultUtil = appOrderController.placeAnOrder(new BigDecimal(money), 4, orderId, 11, integer);
+ }
+ return resultUtil;
+ }
+
+ @Override
+ public void payThankYouFeeCallback(Integer orderId, String order_id, Integer payType) throws Exception {
+ System.out.println(orderId + "_" + order_id + "_" + payType);
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
+ System.out.println("用户" + userInfo);
+ PaymentRecord query = paymentRecordService.query(3, userInfo.getId(), 1, orderId, 1, payType, 1);
+ System.out.println("query:" + query);
+ query.setState(2);
+ query.setCode(order_id);
+ paymentRecordService.updateById(query);
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
+ System.out.println("query1:" + query1);
+ userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
+
+ //添加交易明细
+ transactionDetailsService.saveData(userInfo.getId(), "快车订单-感谢费", query.getAmount(), 2, 1, 1, 1, orderId);
+ userInfoService.updateById(userInfo);
+
+ orderPrivateCar.setThankYouFee(query.getAmount());
+ this.updateById(orderPrivateCar);
+
+ //添加已收入明细
+ incomeService.saveData(2, orderPrivateCar.getDriverId(), 6, orderPrivateCar.getId(), 1, query.getAmount());
+ Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
+ driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+ driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+ driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+ driverService.updateById(driver);
+ systemNoticeService.addSystemNotice(1, "您已使用" + (payType == 1 ? "微信" : (payType == 2 ? "支付宝" : "云闪付")) + "成功完成感谢费支付，谢谢使用！", userInfo.getId(), 1);
+ System.out.println("出租车感谢费ok");
+ }
+
+ @Override
+ public List<Map<String, Object>> queryOrderInfo2(Integer orderId, Integer state, String lon, String lat) {
+ return this.baseMapper.queryOrderInfo2(orderId, state, lon, lat);
+ }
+
+ /**
+ * 获取专车未支付订单
+ *
+ * @param uid
+ * @return
+ */
+ @Override
+ public List<UnPayOrderVO> getUnpayPrivateOrders(Integer uid) {
+ EntityWrapper<OrderPrivateCar> wrapper = new EntityWrapper<>();
+ wrapper.eq("userId", uid);
+ wrapper.eq("state", 7);
+ //查出未支付订单
+ List<OrderPrivateCar> orderPrivateCars = this.selectList(wrapper);
+ List<UnPayOrderVO> unPayOrderVOList = new ArrayList<>();
+ for (OrderPrivateCar order : orderPrivateCars) {
+ UnPayOrderVO vo = new UnPayOrderVO();
+ // 复制属性
+ //添加司机信息
+ DriverInfoWarpper driverInfoWarpper = new DriverInfoWarpper();
+ Driver driver = driverService.selectById(order.getDriverId());
+ BeanUtils.copyProperties(driver, driverInfoWarpper);
+ vo.setDriverInfoWarpper(driverInfoWarpper);
+ //其余信息
+ BeanUtils.copyProperties(order, vo);
+ unPayOrderVOList.add(vo);
+ }
+
+ return unPayOrderVOList;
+ }
+
+ public void pushOrder(Integer id, Integer rideType, Integer serverCarModelId, Double startLon, Double startLat) throws Exception {
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ Integer orderType = rideType == 1 ? 1 : rideType == 2 ? 9 : 8;
+ orderIds.add(id);//添加记录，防止调用接口重复提醒无人接单
+ String vehicle = (String) redisTemplate.opsForValue().get("VEHICLE");
+ List<Integer> integers = new ArrayList<>();
+ if (ToolUtil.isNotEmpty(vehicle)) {
+ integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
+ }
+ OpenCity openCity = openCityService.openCity1(startLon.toString(), startLat.toString());
+ List<PushOrder> querys = pushOrderService.querys(null, 1, openCity.getId());//获取需要推送的次数
+ //整轮派单结束，若无司机接单，系统自动增加派单5轮，若增加5轮后任无司机接单，则系统结束派单，乘客端显示无司机接单、是否再次打车
+ for (int i = 1; i <= querys.size() + 5; i++) {
+ OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(id);
+ if (null == orderPrivateCar || orderPrivateCar.getState() > 1) {
+ break;
+ }
+ int finalI = i;
+ PushOrder pushOrder = querys.stream().filter(s -> s.getType() == (finalI <= 3 ? finalI : 3)).findFirst().orElse(null);
+ System.out.println("pushOrder:" + pushOrder);
+ int i2 = pushOrder.getPushTime() / 10;
+ if (i2 == 0) {
+ i2 = 1;
+ }
+ for (int i1 = 0; i1 < i2; i1++) {
+ if (orderPrivateCar.getState() > 1) {
+ break;
+ }
+ //获取空闲司机
+ List<Driver> list = driverService.queryIdleDriver(orderType, serverCarModelId, startLon, startLat, pushOrder.getPushDistance(), null);//所有附近空闲司机
+ if (list.size() > 0) {
+ double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
+ int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
+ lastIndex = lastIndex == 0 ? list.size() : lastIndex;
+ list = list.subList(0, lastIndex);//获取空闲司机中占比数据
+ for (Driver driver : list) {//开始进行推送
+ boolean bo = false;
+ for (Integer integer : integers) {
+ if (integer.compareTo(driver.getId()) == 0) {
+ bo = true;
+ break;
+ }
+ }
+ if (bo) {
+ continue;
+ }
+ pushUtil.pushOrderState(2, driver.getId(), id, 1, 1, pushOrder.getPushTime());
+ }
+ }
+ Thread.sleep(10000);//设置等待时间
+ Integer state = orderPrivateCarMapper.selectById(orderPrivateCar.getId()).getState();
+ if (state > 1) {
+ orderIds.remove(orderPrivateCar.getId());
+ break;
+ }
+ if (i == querys.size() + 5) {
+ pushUtil.pushEndPush(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1);
+ orderIds.remove(orderPrivateCar.getId());
+ }
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }).start();
+ }
+
+ /**
+ * 推送抢单数据
+ *
+ * @param orderPrivateCar
+ * @throws Exception
+ */
+ public void pushOrder(OrderPrivateCar orderPrivateCar) throws Exception {
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ Integer id = orderPrivateCar.getId();
+ Integer orderType = orderPrivateCar.getRideType() == 1 ? 1 : orderPrivateCar.getRideType() == 2 ? 9 : 8;
+ orderIds.add(orderPrivateCar.getId());//添加记录，防止调用接口重复提醒无人接单
+ String vehicle = (String) redisTemplate.opsForValue().get("VEHICLE");
+ List<Integer> integers = new ArrayList<>();
+ if (ToolUtil.isNotEmpty(vehicle)) {
+ integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
+ }
+ OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+ List<PushOrder> querys = pushOrderService.querys(null, 1, openCity.getId());//获取需要推送的次数
+ for (int i = 1; i <= querys.size() + 5; i++) {
+ OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(id);
+ if (null == orderPrivateCar || orderPrivateCar.getState() > 1) {
+ break;
+ }
+ int finalI = i;
+ PushOrder pushOrder = querys.stream().filter(s -> s.getType() == (finalI <= 3 ? finalI : 3)).findFirst().orElse(null);
+ System.out.println("pushOrder:" + pushOrder);
+ int i2 = pushOrder.getPushTime() / 10;
+ if (i2 == 0) {
+ i2 = 1;
+ }
+ for (int i1 = 0; i1 < i2; i1++) {
+ if (orderPrivateCar.getState() > 1) {
+ break;
+ }
+ //获取空闲司机
+ List<Driver> list = driverService.queryIdleDriver(orderType, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机
+ if (list.size() > 0) {
+ double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
+ int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
+ lastIndex = lastIndex == 0 ? list.size() : lastIndex;
+ list = list.subList(0, lastIndex);//获取空闲司机中占比数据
+ for (Driver driver : list) {//开始进行推送
+ boolean bo = false;
+ for (Integer integer : integers) {
+ if (integer.compareTo(driver.getId()) == 0) {
+ bo = true;
+ break;
+ }
+ }
+ if (bo) {
+ continue;
+ }
+ pushUtil.pushOrderState(2, driver.getId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), pushOrder.getPushTime());
+ }
+ }
+ Thread.sleep(10000);//设置等待时间
+ Integer state = orderPrivateCar.getState();
+ if (state > 1) {
+ orderIds.remove(orderPrivateCar.getId());
+ return;
+ }
+ if (i == querys.size() + 5 && state == 1) {
+ pushUtil.pushEndPush(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1);
+ orderIds.remove(orderPrivateCar.getId());
+ }
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }).start();
+ }
+
+
+
+
+ @Override
+ public void addAppeal(Integer uid, Integer orderId,String abnormalIntro, String abnormalImg) {
+ OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+ if(orderPrivateCar.getState()!=7 || orderPrivateCar.getAbnormalIntro()!=null){
+ throw new RuntimeException("此订单无法申诉");
+ }
+ orderPrivateCar.setAbnormalIntro(abnormalIntro);
+ orderPrivateCar.setAbnormalImg(abnormalImg);
+ orderPrivateCar.setAbnormal(1);
+ this.baseMapper.updateById(orderPrivateCar);
+
+ }
}
--
Gitblit v1.7.1