package com.boying.controller;
|
|
import com.boying.common.BaseController;
|
import com.boying.common.SystemConfigProperties;
|
import com.boying.common.util.DateUtil;
|
import com.boying.common.util.StringUtil;
|
import com.boying.entity.*;
|
import com.boying.service.*;
|
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.data.redis.core.StringRedisTemplate;
|
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.beans.Transient;
|
import java.io.BufferedWriter;
|
import java.io.FileWriter;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
import static com.boying.common.util.DateUtil.getMinute;
|
|
@RestController
|
@RequestMapping("outPark")
|
public class OutParkController extends BaseController {
|
|
@Autowired
|
private OutParkService outParkService;
|
@Autowired
|
private EnterParkService enterParkService;
|
@Autowired
|
private BarrierService barrierService;
|
@Autowired
|
private TicketService ticketService;
|
@Autowired
|
private SystemConfigProperties systemConfigProperties;
|
|
@Autowired
|
private CostRuleService costRuleService;
|
@Autowired
|
private ParkService parkService;
|
@Autowired
|
private StringRedisTemplate redisTemplate;
|
|
@PostMapping("findPage")
|
public Object findPage(int page,int pageSize) {
|
Pageable pageable = PageRequest.of(page-1,pageSize, Sort.Direction.DESC,"id");
|
Page<OutPark> pages = outParkService.findPage(pageable);
|
return success("",pages);
|
}
|
|
//道闸code
|
@PostMapping("findByBarrierCode")
|
public Object findById(String code) {
|
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("code2").as(String.class), code));
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
List<Barrier> all = barrierService.findAll(specification);
|
if(all.size()==0){
|
return error("未找到该设备");
|
}else{
|
Barrier barrier = all.get(0);
|
String carNo = barrier.getCarNo();
|
|
OutPark outPark = outParkService.findByCarNoAndBarrierId(carNo,barrier.getId());
|
if(outPark==null){
|
return error("未识别到车牌号");
|
}else{
|
outPark.setParkName(barrier.getName());
|
return success("请求成功",outPark);
|
}
|
}
|
}
|
|
// @PostMapping("save")
|
// public Object save(OutPark outPark,String barrierCode) {
|
// if(StringUtil.isNullOrEmpty(barrierCode)){
|
// return error("barrierCode不能为空");
|
// }
|
// if(StringUtil.isNullOrEmpty(outPark.getCarNo())){
|
// return error("carNo不能为空");
|
// }
|
// if(outPark.getCreateTime()==null){
|
// return error("createTime不能为空");
|
// }
|
//
|
// 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("code").as(String.class), barrierCode));
|
// Predicate[] arr = new Predicate[list.size()];
|
// cq.where(list.toArray(arr));
|
// return null;
|
// }
|
// };
|
// List<Barrier> all = barrierService.findAll(specification);
|
// if(all.size()==0){
|
// return error("未找到该设备");
|
// }else{
|
// Barrier barrier = all.get(0);
|
// outPark.setBarrierId(barrier.getId());
|
// outPark.setParkId(barrier.getParkId());
|
// barrier.setCarNo(outPark.getCarNo());
|
// barrierService.save(barrier);
|
// }
|
// int i = -((int) (outPark.getTime()));
|
// outPark.setEnterTime(getMinute(outPark.getCreateTime(),i));
|
// outParkService.save(outPark);
|
// Map<String,Object> map = new HashMap<>();
|
// map.put("id",outPark.getId());
|
// return success("保存成功",map);
|
// }
|
|
@PostMapping("delete")
|
public Object delete(Long id) {
|
outParkService.delete(id);
|
return success("删除成功");
|
}
|
|
//进停车场接口
|
// @PostMapping("enterPark")
|
// public Object enterPark(EnterPark enterPark,String barrierCode) {
|
// if(StringUtil.isNullOrEmpty(barrierCode)){
|
// return error("barrierCode不能为空");
|
// }
|
// if(StringUtil.isNullOrEmpty(enterPark.getCarNo())){
|
// return error("carNo不能为空");
|
// }
|
// if(enterPark.getCreateTime()==null){
|
// return error("createTime不能为空");
|
// }
|
//
|
// 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("code").as(String.class), barrierCode));
|
// Predicate[] arr = new Predicate[list.size()];
|
// cq.where(list.toArray(arr));
|
// return null;
|
// }
|
// };
|
// List<Barrier> all = barrierService.findAll(specification);
|
// if(all.size()==0){
|
// return error("未找到该设备");
|
// }else{
|
// enterPark.setBarrierId(all.get(0).getId());
|
// enterPark.setParkId(all.get(0).getParkId());
|
// }
|
//
|
// Specification<Ticket> specification2 = new Specification<Ticket>() {
|
// @Override
|
// public Predicate toPredicate(Root<Ticket> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
|
// List<Predicate> list = new ArrayList<Predicate>();
|
// list.add(cb.equal(root.get("carNo").as(String.class), enterPark.getCarNo()));
|
// list.add(cb.notEqual(root.get("payStatus"), 1));
|
// Predicate[] arr = new Predicate[list.size()];
|
// cq.where(list.toArray(arr));
|
// return null;
|
// }
|
// };
|
// List<Ticket> tickets = ticketService.findAll(specification2);
|
// if(tickets.size()>0){
|
// enterPark.setStatus(1);//发现有违章
|
// }
|
//
|
// enterParkService.save(enterPark);
|
// Map<String,Object> map = new HashMap<>();
|
// map.put("id",enterPark.getId());
|
// return success("保存成功",map);
|
// }
|
|
@PostMapping("enterPark2")
|
public Object enterPark(String carNo,Long barrierId,Long parkId,String code2) {
|
Barrier barrier1 = findBarrier(code2);
|
barrierId = barrier1.getId();
|
parkId = barrier1.getParkId();
|
Park park = (Park)parkService.findById(parkId);
|
int num = 0;
|
String s = redisTemplate.opsForValue().get("car_park_" + parkId);
|
if(park != null){
|
num = park.getNum();
|
if(s !=null){
|
if(Integer.parseInt(s) > num){
|
return "null";
|
}
|
}else {
|
s= "0";
|
redisTemplate.opsForValue().set("car_park_" + parkId,s,30, TimeUnit.DAYS);
|
}
|
}
|
enterParkService.deleteByCarNo(carNo,parkId);
|
EnterPark enterPark = new EnterPark();
|
enterPark.setCreateTime(new Date());
|
enterPark.setCarNo(carNo);
|
enterPark.setBarrierId(barrierId);
|
enterPark.setParkId(parkId);
|
|
// Specification<Ticket> specification2 = new Specification<Ticket>() {
|
// @Override
|
// public Predicate toPredicate(Root<Ticket> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
|
// List<Predicate> list = new ArrayList<Predicate>();
|
// list.add(cb.equal(root.get("carNo").as(String.class), enterPark.getCarNo()));
|
// list.add(cb.notEqual(root.get("payStatus"), 1));
|
// Predicate[] arr = new Predicate[list.size()];
|
// cq.where(list.toArray(arr));
|
// return null;
|
// }
|
// };
|
// List<Ticket> tickets = ticketService.findAll(specification2);
|
// if(tickets.size()>0){
|
// enterPark.setStatus(1);//发现有违章
|
// }
|
enterParkService.save(enterPark);
|
int i = Integer.parseInt(s);
|
i++;
|
redisTemplate.opsForValue().set("car_park_" + parkId,Integer.toString(i),30, TimeUnit.DAYS);
|
|
Barrier barrier = (Barrier) barrierService.findById(barrierId);
|
barrier.setType2(1);
|
barrierService.save(barrier);
|
return success("请求成功");
|
}
|
|
@PostMapping("outPark2")
|
public Object outPark(String carNo,Long barrierId,Long parkId,String code2) {
|
String s = "开始执行出场接口------>\n";
|
Barrier barrier1 = findBarrier(code2);
|
barrierId = barrier1.getId();
|
parkId = barrier1.getParkId();
|
OutPark outPark = new OutPark();
|
outPark.setCarNo(carNo);
|
outPark.setParkId(parkId);
|
outPark.setBarrierId(barrierId);
|
outPark.setCreateTime(new Date());
|
outPark.setCode(System.currentTimeMillis()+"");
|
EnterPark enterPark = enterParkService.findByCarNo(carNo).get(0);
|
|
|
if(enterPark==null){
|
s += "未发现入场车辆："+carNo+"\n";
|
writeTxt(s);
|
return error("无进场记录或手机号进出输入不一致",null);
|
}else{
|
s += "发现入场车辆: "+enterPark.getCarNo()+",道闸id为："+enterPark.getBarrierId()+",停车场id："+enterPark.getParkId()+",违章标识："+enterPark.getStatus()+"\n";
|
outPark.setEnterTime(enterPark.getCreateTime());
|
}
|
String redis = redisTemplate.opsForValue().get("car_park_" + parkId);
|
long l = outPark.getCreateTime().getTime() - enterPark.getCreateTime().getTime();
|
s+= "场内时长为："+l+"毫秒,合计为: "+l/(1000*60)+"秒\n";
|
outPark.setTime(l/(1000*60));
|
double money = 0;
|
try {
|
money = costRuleService.getMoney(parkId, enterPark.getCreateTime(), outPark.getCreateTime(), 1);
|
s+="金额为："+money+"\n";
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
outPark.setPrice(Double.valueOf(String.format("%.1f", money)));
|
|
//outPark.setStatus3(findTicket(carNo));
|
outParkService.save(outPark);
|
int i = Integer.parseInt(redis);
|
i--;
|
if(i<0){
|
redisTemplate.opsForValue().set("car_park_" + parkId,"0",30, TimeUnit.DAYS);
|
}else {
|
redisTemplate.opsForValue().set("car_park_" + parkId,Integer.toString(i),30, TimeUnit.DAYS);
|
}
|
|
Barrier barrier = (Barrier) barrierService.findById(barrierId);
|
barrier.setCarNo(carNo);
|
if(outPark.getPrice()==0&&outPark.getStatus3()==0){
|
barrier.setType2(1);
|
}else {
|
barrier.setType2(0);
|
}
|
barrierService.save(barrier);
|
s += "\n";
|
writeTxt(s);
|
return success("请求成功",outPark);
|
}
|
|
|
public Barrier findBarrier(String code2) {
|
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("code2").as(String.class), code2));
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
List<Barrier> all = barrierService.findAll(specification);
|
if(all.size()==0){
|
return null;
|
}else{
|
Barrier barrier = all.get(0);
|
return barrier;
|
}
|
}
|
|
//设备状态接口
|
// @PostMapping("status")
|
// public Object status(String barrierCode) {
|
// 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("code").as(String.class), barrierCode));
|
// Predicate[] arr = new Predicate[list.size()];
|
// cq.where(list.toArray(arr));
|
// return null;
|
// }
|
// };
|
// List<Barrier> all = barrierService.findAll(specification);
|
// if(all.size()==0){
|
// return error("未找到该设备");
|
// }else{
|
// Barrier barrier = all.get(0);
|
// barrier.setCreateTime(new Date());
|
// barrierService.save(barrier);
|
// }
|
// return success("保存成功");
|
// }
|
|
private void writeTxt( String txt)
|
{
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
|
try
|
{
|
FileWriter f = new FileWriter(systemConfigProperties.getLogPath()+sdf.format(new Date())+".txt",true);
|
BufferedWriter bw=new BufferedWriter(f);
|
bw.write(txt);
|
bw.newLine();
|
bw.close();
|
}
|
catch(Exception e)
|
{
|
System.out.println("打印错误");
|
}
|
}
|
}
|
