| | |
|---|
| | | public synchronized ResultUtil<BaseWarpper> taxiOrder(OrderTaxi orderTaxi, Integer uid) throws Exception { |
|---|
| | | //定义用户所属公司 |
|---|
| | | UserInfo userInfo1 = userInfoService.selectById(uid); |
|---|
| | | Company query = companyCityService.query1(String.valueOf(orderTaxi.getStartLon()), String.valueOf(orderTaxi.getStartLat())); |
|---|
| | | Company query = companyCityService.query1(orderTaxi.getUserId(), String.valueOf(orderTaxi.getStartLon()), String.valueOf(orderTaxi.getStartLat())); |
|---|
| | | if(null == query){ |
|---|
| | | return ResultUtil.error("出发点暂未开通"); |
|---|
| | | } |
|---|
| | |
|---|
| | | if(ToolUtil.isNotEmpty(vehicle)){ |
|---|
| | | integers = JSON.parseArray(vehicle).toJavaList(Integer.class); |
|---|
| | | } |
|---|
| | | Company query = companyCityService.query1(String.valueOf(orderTaxi.getStartLon()), String.valueOf(orderTaxi.getStartLat()));//获取起点所属分公司 |
|---|
| | | Company query = companyCityService.query1(orderTaxi.getUserId(), String.valueOf(orderTaxi.getStartLon()), String.valueOf(orderTaxi.getStartLat()));//获取起点所属分公司 |
|---|
| | | List<PushOrder> querys = pushOrderService.querys(null, 2, query.getId());//获取需要推送的次数 |
|---|
| | | for(int i = 1; i <= querys.size(); i++){ |
|---|
| | | PushOrder pushOrder = pushOrderService.querys(i, 2, query.getId()).get(0); |
|---|
