package com.stylefeng.guns.modular.system.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.stylefeng.guns.core.util.ToolUtil;
|
import com.stylefeng.guns.modular.system.dao.CarServiceMapper;
|
import com.stylefeng.guns.modular.system.dao.OrderCrossCityMapper;
|
import com.stylefeng.guns.modular.system.dao.OrderPrivateCarMapper;
|
import com.stylefeng.guns.modular.system.dao.OrderTaxiMapper;
|
import com.stylefeng.guns.modular.system.model.*;
|
import com.stylefeng.guns.modular.system.service.*;
|
import com.stylefeng.guns.modular.system.util.*;
|
import com.stylefeng.guns.modular.system.warpper.BaseWarpper;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
|
@Service
|
public class OrderPrivateCarServiceImpl extends ServiceImpl<OrderPrivateCarMapper, OrderPrivateCar> implements IOrderPrivateCarService {
|
|
@Resource
|
private OrderPrivateCarMapper orderPrivateCarMapper;
|
|
@Autowired
|
private IDispatchService dispatchService;
|
|
@Autowired
|
private IOrderCancelService orderCancelService;
|
|
@Autowired
|
private PushMinistryOfTransportUtil pushMinistryOfTransportUtil;
|
|
@Autowired
|
private PushUtil pushUtil;
|
|
@Autowired
|
private IDriverService driverService;
|
|
@Autowired
|
private ISystemNoticeService systemNoticeService;
|
|
@Autowired
|
private IUserInfoService userInfoService;
|
|
@Autowired
|
private GDMapGeocodingUtil gdMapGeocodingUtil;
|
|
@Autowired
|
private IDriverServiceService driverServiceService;
|
|
@Resource
|
private CarServiceMapper carServiceMapper;
|
|
@Autowired
|
private ChinaMobileUtil chinaMobileUtil;
|
|
@Resource
|
private OrderTaxiMapper orderTaxiMapper;
|
|
@Resource
|
private OrderCrossCityMapper orderCrossCityMapper;
|
|
@Value("${callbackPath}")
|
private String callbackPath;
|
|
@Value("${pushMinistryOfTransport}")
|
private boolean pushMinistryOfTransport;
|
|
|
/**
|
* 获取订单列表
|
* @param search
|
* @param orderSource
|
* @param state
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public List<Map<String, Object>> queryOrderList(String search, String orderSource, String state, Integer pageNum, Integer size, Integer uid) throws Exception {
|
Dispatch dispatch = dispatchService.selectById(uid);
|
Integer companyId = null != dispatch.getFranchiseeId() ? dispatch.getFranchiseeId() : dispatch.getCompanyId();
|
pageNum = (pageNum - 1) * size;
|
List<String> orderSources = null;
|
if(ToolUtil.isNotEmpty(orderSource)){
|
orderSources = Arrays.asList(orderSource.split(","));
|
}
|
List<String> states = null;
|
if(ToolUtil.isNotEmpty(state)){
|
states = Arrays.asList(state.split(","));
|
}
|
return orderPrivateCarMapper.queryOrderList(search, orderSources, states, companyId, pageNum, size);
|
}
|
|
|
/**
|
* 获取订单详情
|
* @param orderId
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public Map<String, Object> queryOrderInfo(Integer orderId) throws Exception {
|
return orderPrivateCarMapper.queryOrderInfo(orderId);
|
}
|
|
|
/**
|
* 取消订单
|
* @param orderId
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil cancelOrder(Integer orderId) throws Exception {
|
OrderPrivateCar orderPrivateCar = this.selectById(orderId);
|
if(orderPrivateCar.getState() == 10 || orderPrivateCar.getState() == 12){
|
return ResultUtil.error("不允许重复取消");
|
}
|
if(orderPrivateCar.getState() == 8 || orderPrivateCar.getState() == 9){
|
return ResultUtil.error("订单已完成，不允许取消");
|
}
|
orderPrivateCar.setState(10);
|
this.updateById(orderPrivateCar);
|
|
//添加取消记录
|
OrderCancel orderCancel = new OrderCancel();
|
orderCancel.setOrderId(orderId);
|
orderCancel.setOrderType(1);
|
orderCancel.setReason("调度端取消");
|
orderCancel.setRemark("调度端取消");
|
orderCancel.setState(2);
|
orderCancel.setInsertTime(new Date());
|
orderCancel.setUserType(2);
|
orderCancelService.insert(orderCancel);
|
|
new Thread(new Runnable() {//发送消息提醒
|
@Override
|
public void run() {
|
pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderId, 1, 10, 0);
|
if(null != orderPrivateCar.getDriverId()){
|
//修改司机为空闲
|
Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
|
driver.setState(2);
|
driverService.updateById(driver);
|
pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderId, 1, 10, 0);
|
}
|
}
|
}).start();
|
//添加消息
|
systemNoticeService.addSystemNotice(1, "调度已成功取消出行订单，谢谢使用！", orderPrivateCar.getUserId(), 1);
|
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
if(pushMinistryOfTransport){//上传数据
|
pushMinistryOfTransportUtil.orderCancel(orderId);
|
}
|
}
|
}).start();
|
|
return ResultUtil.success();
|
}
|
|
@Override
|
public ResultUtil saveOrderPrivateCar(Integer uid, Integer serverCarModelId, Date travelTime, Integer orderType, String placementLon, String placementLat, String startLon, String startLat, String startAddress, String endLon, String endLat, String endAddress, String passengers, String passengersPhone, Integer driverId) throws Exception {
|
//如果出行时间大于当前10分钟则默认为预约单
|
Integer reservation = 1;
|
if(travelTime.getTime() > (System.currentTimeMillis() + 600000)){
|
reservation = 2;
|
}
|
Dispatch dispatch = dispatchService.selectById(uid);
|
|
UserInfo userInfo = userInfoService.selectOne(new EntityWrapper<UserInfo>().eq("phone", passengersPhone).ne("flag", 3));
|
if(userInfo == null){
|
userInfo = new UserInfo();
|
userInfo.setName(passengers);
|
userInfo.setPhone(passengersPhone);
|
userInfo.setCompanyId(dispatch.getCompanyId());
|
userInfo.setState(1);
|
userInfo.setFlag(1);
|
userInfo.setInsertTime(new Date());
|
userInfoService.insert(userInfo);
|
}
|
|
/**
|
* 1.出租车、专车、跨城有待支付的订单不能叫车
|
* 2.小件物流有未完成的订单可以下跨城、专车、出租车
|
* 3.出租车、专车、跨城有预约单可以下即时单
|
*/
|
List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(userInfo.getId(), null, 1, 7, 12);
|
if(orderPrivateCars.size() > 0){
|
return ResultUtil.error("乘客有未完成的订单");
|
}
|
List<OrderTaxi> list = orderTaxiMapper.queryByState(userInfo.getId(), null, 1, 7, 12);
|
if(list.size() > 0){
|
return ResultUtil.error("乘客有未完成的订单");
|
}
|
List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(userInfo.getId(), 7, 12);
|
if(orderCrossCities1.size() > 0){
|
return ResultUtil.error("乘客有未完成的订单");
|
}
|
if(reservation == 1){
|
orderPrivateCars = orderPrivateCarMapper.queryByState(userInfo.getId(), 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
|
if(orderPrivateCars.size() > 0){
|
return ResultUtil.error("乘客有未完成的订单");
|
}
|
list = orderTaxiMapper.queryByState(userInfo.getId(), 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
|
if(list.size() > 0){
|
return ResultUtil.error("乘客有未完成的订单");
|
}
|
}
|
|
startAddress = startAddress.replaceAll("& #40;", "(");
|
startAddress = startAddress.replaceAll("& #41;", ")");
|
endAddress = endAddress.replaceAll("& #40;", "(");
|
endAddress = endAddress.replaceAll("& #41;", ")");
|
OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
|
orderPrivateCar.setType(1);
|
orderPrivateCar.setUserId(userInfo.getId());
|
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(0);
|
orderPrivateCar.setPassengers(passengers);
|
orderPrivateCar.setPassengersPhone(passengersPhone);
|
orderPrivateCar.setState(1);
|
orderPrivateCar.setInsertTime(new Date());
|
orderPrivateCar.setTravelTime(travelTime);
|
orderPrivateCar.setOrderType(reservation);
|
orderPrivateCar.setOrderSource(5);
|
if(null != driverId){
|
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("司机正在服务中，无法提供服务");
|
}
|
List<DriverService> query = driverServiceService.query(driverId, 1);
|
if(query.size() == 0){
|
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);
|
}
|
|
orderPrivateCar.setIsReassign(1);
|
orderPrivateCar.setIsDelete(1);
|
this.insert(orderPrivateCar);
|
|
UserInfo finalUserInfo = userInfo;
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
pushUtil.pushOrderState(1, finalUserInfo.getId(), orderPrivateCar.getId(), 1, 2, 0);
|
pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0);
|
pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
|
}
|
}).start();
|
|
//添加消息
|
systemNoticeService.addSystemNotice(1, "您的专车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);
|
|
BaseWarpper baseWarpper = new BaseWarpper();
|
baseWarpper.setId(orderPrivateCar.getId());
|
return ResultUtil.success(baseWarpper);
|
}
|
|
|
public synchronized String getOrderNum() throws Exception{
|
int size = this.selectCount(null);
|
return "PRIVATE" + String.valueOf(1000000 + size + 1).substring(1);
|
}
|
}
|
