package com.boying.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.boying.common.BaseController;
|
import com.boying.common.SystemConfigProperties;
|
import com.boying.common.util.DateUtil;
|
import com.boying.common.util.HttpUtil;
|
import com.boying.common.util.StringUtil;
|
import com.boying.entity.*;
|
import com.boying.service.BarrierService;
|
import com.boying.service.EnterParkService;
|
import com.boying.service.OutParkService;
|
import com.boying.service.ParkService;
|
import io.netty.util.internal.ObjectUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.domain.Page;
|
import org.springframework.data.domain.PageRequest;
|
import org.springframework.data.domain.Pageable;
|
import org.springframework.data.domain.Sort;
|
import org.springframework.data.jpa.domain.Specification;
|
import org.springframework.util.ObjectUtils;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.persistence.criteria.CriteriaBuilder;
|
import javax.persistence.criteria.CriteriaQuery;
|
import javax.persistence.criteria.Predicate;
|
import javax.persistence.criteria.Root;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@RestController
|
@RequestMapping("barrier")
|
public class BarrierController extends BaseController {
|
|
@Autowired
|
private BarrierService barrierService;
|
@Autowired
|
private SystemConfigProperties systemConfigProperties;
|
@Autowired
|
private OutParkService outParkService;
|
|
@PostMapping("findPage")
|
public Object findPage(int page,int pageSize,String parkId) {
|
Pageable pageable = PageRequest.of(page-1,pageSize, Sort.Direction.DESC,"id");
|
|
Specification<Barrier> specification = new Specification<Barrier>() {
|
@Override
|
public Predicate toPredicate(Root<Barrier> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
|
List<Predicate> list = new ArrayList<Predicate>();
|
if (!StringUtil.isNullOrEmpty(parkId)) {
|
list.add(cb.equal(root.get("parkId").as(Long.class), parkId));
|
}
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
|
Page<Barrier> pages = barrierService.findPage(pageable,specification);
|
|
for(Barrier barrier:pages.getContent()){
|
long l = new Date().getTime() - barrier.getCreateTime().getTime();
|
System.out.println(l);
|
if(l>10000){
|
barrier.setStatus(1);
|
}
|
}
|
return success("",pages);
|
}
|
|
@PostMapping("save")
|
public Object save(Barrier barrier) {
|
barrierService.save(barrier);
|
return success("保存成功");
|
}
|
|
@PostMapping("delete")
|
public Object delete(Long id) {
|
barrierService.delete(id);
|
return success("删除成功");
|
}
|
|
@PostMapping("findAll")
|
public Object findAll(Long parkId) {
|
if (parkId==null) {
|
return error("未发现该停车场");
|
}
|
Specification<Barrier> specification = new Specification<Barrier>() {
|
@Override
|
public Predicate toPredicate(Root<Barrier> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
|
List<Predicate> list = new ArrayList<Predicate>();
|
list.add(cb.equal(root.get("parkId").as(Long.class), parkId));
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
return success("请求成功",barrierService.findAll(specification));
|
}
|
|
// @PostMapping("open")
|
// public Object open(Long barrierId) {
|
// if (barrierId==null) {
|
// return error("未找到该道闸");
|
// }
|
// Barrier b= (Barrier) barrierService.findById(barrierId);
|
// String res = HttpUtil.get(systemConfigProperties.getIp3()+"?barrierCode="+b.getCode());
|
// JSONObject jsonObject = JSON.parseObject(res);
|
// if(jsonObject.get("result").equals("true")){
|
// return success("请求成功");
|
// }else{
|
// return error("抬杆失败");
|
// }
|
// }
|
|
@PostMapping("open")
|
public Object open(Long barrierId) {
|
Barrier b= (Barrier) barrierService.findById(barrierId);
|
if (b==null) {
|
return error("未找到该道闸");
|
}
|
b.setType2(1);
|
barrierService.save(b);
|
return success("请求成功");
|
}
|
|
@PostMapping("openBarrier")
|
public Object openBarrier(Long barrierId,Integer type) {
|
Barrier b= (Barrier) barrierService.findById(barrierId);
|
if (b==null) {
|
return error("未找到该道闸");
|
}else {
|
if(b.getType() == 1){
|
//入口闸，直接开启
|
b.setType2(1);
|
barrierService.save(b);
|
return success("请求成功");
|
}else {
|
//出口闸，判断状态
|
if(type == null || type == 0){
|
//取消计费
|
OutPark outPark = outParkService.findByCarNoAndBarrierId(b.getCarNo(), b.getId());
|
if(outPark != null){
|
outPark.setPrice(0);
|
outParkService.save(outPark);
|
}
|
b.setType2(1);
|
barrierService.save(b);
|
return success("请求成功");
|
}else {
|
//计费
|
b.setType2(1);
|
barrierService.save(b);
|
return success("请求成功");
|
}
|
}
|
}
|
}
|
}
|
