package com.boying.controller.phone;
|
|
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.apache.commons.io.FileUtils;
|
import org.apache.commons.io.FilenameUtils;
|
import org.apache.commons.io.IOUtils;
|
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.http.MediaType;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartHttpServletRequest;
|
|
import javax.persistence.criteria.CriteriaBuilder;
|
import javax.persistence.criteria.CriteriaQuery;
|
import javax.persistence.criteria.Predicate;
|
import javax.persistence.criteria.Root;
|
import javax.servlet.ServletOutputStream;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.File;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.util.*;
|
|
@RestController
|
@RequestMapping("ticket")
|
public class TicketController extends BaseController{
|
|
@Autowired
|
private TicketService ticketService;
|
@Autowired
|
private SystemConfigProperties systemConfigProperties;
|
@Autowired
|
private UserService userService;
|
@Autowired
|
private ViolationTypeService violationTypeService;
|
@Autowired
|
private TicketBlackService ticketBlackService;
|
@Autowired
|
private OrderRecordService orderRecordService;
|
@Autowired
|
private StreetLogoService streetLogoService;
|
|
//图片回显
|
@RequestMapping(value = "/showImg", method = RequestMethod.GET)
|
public void getAwardAsByteArray(HttpServletResponse response, HttpServletRequest request) throws IOException {
|
String result = request.getParameter("result");
|
InputStream in = null;
|
in = FileUtils.openInputStream(new File(systemConfigProperties.getUploadImgPath()+result));
|
response.setContentType(MediaType.IMAGE_PNG_VALUE);
|
ServletOutputStream out = response.getOutputStream();
|
try {
|
IOUtils.copy(in, out);
|
out.close();
|
in.close();
|
} catch (IOException e) {
|
|
}
|
}
|
|
@PostMapping("findPage")
|
public Object findPage(int page,int pageSize,Integer type){
|
Pageable pageable = PageRequest.of(page-1,pageSize, Sort.Direction.DESC,"id");
|
if(type==null){
|
Specification<Ticket> specification = 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("status").as(Integer.class), 0));
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
return success("",ticketService.findPage(pageable,specification));
|
}else{
|
Specification<Ticket> specification = 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("type").as(Integer.class), type));
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
return success("",ticketService.findPage(pageable,specification));
|
}
|
|
}
|
|
|
@PostMapping("save")
|
public Object save(Ticket ticket,HttpServletRequest request) throws IOException{
|
String imgStr = "";
|
MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
|
List<MultipartFile> imgs = multipartRequest.getFiles("imgs");
|
for(MultipartFile imageFile:imgs){
|
if (imageFile != null) {
|
String fileExtension = FilenameUtils.getExtension(imageFile.getOriginalFilename());//获取后缀
|
String newFileName = System.currentTimeMillis() + "." + fileExtension;//图片名称
|
imgStr+=newFileName+",";
|
String newFilePath = systemConfigProperties.getUploadImgPath() + newFileName;//上传路径
|
File destFile = new File(newFilePath);
|
FileUtils.writeByteArrayToFile(destFile, imageFile.getBytes());
|
}
|
}
|
ticket.setImg(imgStr);
|
|
if(ticket.getUserId()!=null){
|
User user = (User) userService.findById(ticket.getUserId());
|
ticket.setUserName(user.getName());
|
}
|
if(ticket.getViolationTypeId()!=null){
|
ViolationType violationType = (ViolationType) violationTypeService.findById(ticket.getViolationTypeId());
|
ticket.setViolationTypeName(violationType.getName());
|
ticket.setMoney(violationType.getMoney());
|
}
|
if(ticket.getId()==null){
|
ticket.setCode(System.currentTimeMillis()+"");
|
updateBlackTicket(ticket);
|
}
|
|
ticket.setStatus(1);//已处理
|
|
ticketService.save(ticket);
|
if(StringUtil.isNullOrEmpty(ticket.getQrUrl())){
|
ticket.setQrUrl(systemConfigProperties.getIp2()+"#/index?id="+ticket.getId());
|
ticketService.save(ticket);
|
}
|
|
if(!StringUtil.isNullOrEmpty(ticket.getLng())&&!StringUtil.isNullOrEmpty(ticket.getLat())){
|
saveLogo(ticket.getAddress(),ticket.getLng(),ticket.getLat());
|
}
|
return success("保存成功",ticket);
|
}
|
|
@PostMapping("save2")
|
public Object save2(Ticket ticket) throws IOException{
|
if(ticket.getUserId()!=null){
|
User user = (User) userService.findById(ticket.getUserId());
|
ticket.setUserName(user.getName());
|
}
|
if(ticket.getViolationTypeId()!=null){
|
ViolationType violationType = (ViolationType) violationTypeService.findById(ticket.getViolationTypeId());
|
ticket.setViolationTypeName(violationType.getName());
|
ticket.setMoney(violationType.getMoney());
|
}
|
if(ticket.getId()==null){
|
ticket.setCode(System.currentTimeMillis()+"");
|
}
|
|
updateBlackTicket(ticket);
|
|
ticketService.save(ticket);
|
ticket.setQrUrl(systemConfigProperties.getIp2()+"#/index?id="+ticket.getId());
|
ticket.setType(1);
|
ticketService.save(ticket);
|
return success("保存成功",ticket);
|
}
|
|
@PostMapping("delete")
|
public Object delete(Long id){
|
Ticket ticket = (Ticket) ticketService.findById(id);
|
ticket.setStatus(3);
|
ticketService.save(ticket);
|
return success("操作成功");
|
}
|
|
public void saveLogo(String name,String lng,String lat){
|
if(StringUtil.isNullOrEmpty(name)||StringUtil.isNullOrEmpty(lng)){
|
return;
|
}
|
StreetLogo logo = new StreetLogo();
|
logo.setLat(lat);
|
logo.setLng(lng);
|
logo.setName(name);
|
streetLogoService.save(logo);
|
}
|
|
private void updateBlackTicket(Ticket ticket){
|
Specification<TicketBlack> specification = new Specification<TicketBlack>() {
|
@Override
|
public Predicate toPredicate(Root<TicketBlack> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
|
List<Predicate> list = new ArrayList<Predicate>();
|
if(!StringUtil.isNullOrEmpty(ticket.getCarNo())){
|
list.add(cb.equal(root.get("carNo").as(String.class), ticket.getCarNo()));
|
}
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
List<TicketBlack> all = ticketBlackService.findAll(specification);
|
if(all.size()==0){
|
TicketBlack tb = new TicketBlack();
|
tb.setCarNo(ticket.getCarNo());
|
tb.setCarType(ticket.getCarType());
|
tb.setColor(ticket.getColor());
|
tb.setViolationCount(1);
|
ticketBlackService.save(tb);
|
}else {
|
TicketBlack ticketBlack = all.get(0);
|
//ticketBlack.setStatus(1);
|
ticketBlack.setViolationCount(ticketBlack.getViolationCount()+1);
|
ticketBlackService.save(ticketBlack);
|
}
|
}
|
|
@PostMapping("getZhiFa")
|
public Object getZhiFa(Integer status,int page,int pageSize){
|
Pageable pageable = PageRequest.of(page-1,pageSize, Sort.Direction.DESC,"id");
|
Specification<Ticket> specification = 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("status").as(String.class), status));
|
list.add(cb.equal(root.get("type").as(String.class), 1));
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
|
Page<Ticket> page1 = ticketService.findPage(pageable, specification);
|
return success("请求成功",page1);
|
}
|
|
@PostMapping("getCar")
|
public Object getCar(String carNo,int page,int pageSize,int type){
|
Pageable pageable = PageRequest.of(page-1,pageSize, Sort.Direction.DESC,"id");
|
Specification<TicketBlack> specification = new Specification<TicketBlack>() {
|
@Override
|
public Predicate toPredicate(Root<TicketBlack> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
|
List<Predicate> list = new ArrayList<Predicate>();
|
// if(type==1){
|
// list.add(cb.equal(root.get("status").as(String.class), type));
|
// }
|
if(type==2){
|
list.add(cb.equal(root.get("blackType").as(String.class), 1));
|
}
|
if(!StringUtil.isNullOrEmpty(carNo)){
|
list.add(cb.like(root.get("carNo").as(String.class), "%"+carNo+"%"));
|
}
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
|
Page<TicketBlack> page1 = ticketBlackService.findPage(pageable,specification);
|
return success("请求成功",page1);
|
}
|
|
@PostMapping("getCarList")
|
public Object getCarList(String carNo,int page,int pageSize){
|
Pageable pageable = PageRequest.of(page-1,pageSize, Sort.Direction.DESC,"id");
|
Specification<Ticket> specification = new Specification<Ticket>() {
|
@Override
|
public Predicate toPredicate(Root<Ticket> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
|
List<Predicate> list = new ArrayList<Predicate>();
|
if(!StringUtil.isNullOrEmpty(carNo)){
|
list.add(cb.like(root.get("carNo").as(String.class), "%"+carNo+"%"));
|
}
|
Predicate[] arr = new Predicate[list.size()];
|
cq.where(list.toArray(arr));
|
return null;
|
}
|
};
|
|
Page<Ticket> page1 = ticketService.findPage(pageable, specification);
|
return success("请求成功",page1);
|
}
|
|
|
@PostMapping("noFound")
|
public Object noFound(Long ticketId,String remark){
|
Ticket ticket = (Ticket) ticketService.findById(ticketId);
|
ticket.setStatus(2);
|
ticket.setRemark(remark);
|
ticketService.save(ticket);
|
return success("请求成功");
|
}
|
|
@PostMapping("getStatisticByYear")
|
public Object getStatistic(int year){
|
Map<String,Object> map = new HashMap<>();
|
List<Object> list = new ArrayList<>();
|
Date yearFirst = DateUtil.getYearFirst(year);
|
Date yearLast = DateUtil.getYearLast(year);
|
long count = orderRecordService.countByYear(yearFirst,yearLast);
|
Double money = orderRecordService.sumByYear(yearFirst,yearLast);
|
map.put("yearCount",count);
|
map.put("yearMoney",money);
|
|
Calendar cal = Calendar.getInstance();
|
int month = cal.get(Calendar.MONTH) + 1;
|
int year2 = cal.get(Calendar.YEAR);
|
if(year==year2){
|
for(int i=month;i>0;i--){
|
list.add(getStatisticByMonth(year,i));
|
}
|
}
|
map.put("list",list);
|
return success("请求成功",map);
|
}
|
|
public Object getStatisticByMonth(int year,int month){
|
Map<String,Object> map = new HashMap<>();
|
map.put("year",year);
|
map.put("month",month);
|
Date yearFirst = DateUtil.getFirstDayOfMonth(year,month);
|
Date yearLast = DateUtil.getLastDayOfMonth(year,month);
|
long count = orderRecordService.countByYear(yearFirst,yearLast);
|
Double money = orderRecordService.sumByYear(yearFirst,yearLast);
|
map.put("monthCount",count);
|
map.put("monthMoney",money);
|
return map;
|
}
|
|
@PostMapping("getOrderList")
|
public Object getOrderList(int year,int month){
|
|
Date yearFirst = DateUtil.getFirstDayOfMonth(year,month);
|
Date yearLast = DateUtil.getLastDayOfMonth(year,month);
|
List<OrderRecord> page1 = orderRecordService.findAll2(yearFirst,yearLast);
|
return success("请求成功",page1);
|
}
|
|
@PostMapping("findById")
|
public Object findById(Long id){
|
Ticket ticket = (Ticket) ticketService.findById(id);
|
if(ticket.getViolationTypeId()!=null){
|
ViolationType violationType = (ViolationType) violationTypeService.findById(ticket.getViolationTypeId());
|
ticket.setUserName(violationType.getCode());
|
ticket.setRemark(violationType.getContent());
|
}
|
return success("请求成功",ticket);
|
}
|
}
|
