Skip to content

M
map-parent
Commit eef34124 by Jbb
Options

查询代码 有点问题

parent 11939a4e
Showing with 189 additions and 787 deletions
common/common_utils/src/main/java/com/founder/commonutils/util/ReadRequest.java deleted 100644 → 0
package com.founder.commonutils.util;
import javax.servlet.http.HttpServletRequest;
import java.io.BufferedReader;
import java.io.IOException;
public class ReadRequest {
public static String ReadAsChars(HttpServletRequest request) {
BufferedReader bf = null;
StringBuilder sb = new StringBuilder();
try {
bf = request.getReader();
String st;
while ((st = bf.readLine()) != null) {
sb.append(new String(st.getBytes(), "UTF-8"));
}
bf.close();
} catch (IOException e) {
e.printStackTrace();
} finally {
if (null != bf) {
try {
bf.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return sb.toString();
}
}
common/common_utils/src/main/java/com/founder/commonutils/util/TokenUtils.java
......@@ -20,6 +20,11 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;
/**
......
common/common_utils/src/main/java/com/founder/commonutils/viewEntity/AccidentPoint.java deleted 100644 → 0
package com.founder.commonutils.viewEntity;
import java.io.Serializable;
import java.util.Date;
public class AccidentPoint implements Serializable {
private String xxzjbh;
private double lat; //纬度
private double lon; //经度
private String title; //事故提示
private Date time; //事故时间
public String getXxzjbh() {
return xxzjbh;
}
public void setXxzjbh(String xxzjbh) {
this.xxzjbh = xxzjbh;
}
public double getLat() {
return lat;
}
public void setLat(double lat) {
this.lat = lat;
}
public double getLon() {
return lon;
}
public void setLon(double lon) {
this.lon = lon;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public Date getTime() {
return time;
}
public void setTime(Date time) {
this.time = time;
}
}
common/common_utils/src/main/java/com/founder/commonutils/viewEntity/LayerInfo.java deleted 100644 → 0
package com.founder.commonutils.viewEntity;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
/**
* 用来查询的图层信息的实体
*/
public class LayerInfo implements Serializable {
private String name;//图层名称
private String lrr;//录入人
private int count;
private String xxzjbh;//主键编号
private String gl_xxzjbh;//关联主键
private BigDecimal x;//经度
private BigDecimal y;//维度
private String title;//标题
private String time;//数据时间
public LayerInfo() {
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getLrr() {
return lrr;
}
public void setLrr(String lrr) {
this.lrr = lrr;
}
public int getCount() {
return count;
}
public void setCount(int count) {
this.count = count;
}
public String getXxzjbh() {
return xxzjbh;
}
public void setXxzjbh(String xxzjbh) {
this.xxzjbh = xxzjbh;
}
public String getGl_xxzjbh() {
return gl_xxzjbh;
}
public void setGl_xxzjbh(String gl_xxzjbh) {
this.gl_xxzjbh = gl_xxzjbh;
}
public BigDecimal getX() {
return x;
}
public void setX(BigDecimal x) {
this.x = x;
}
public BigDecimal getY() {
return y;
}
public void setY(BigDecimal y) {
this.y = y;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getTime() {
return time;
}
public void setTime(String time) {
this.time = time;
}
}
common/common_utils/src/main/java/com/founder/commonutils/viewEntity/PageInfo.java 0 → 100644
package com.founder.commonutils.viewEntity;
import lombok.Data;
import java.io.Serializable;
/**
* 分页实体
*/
@Data
public class PageInfo implements Serializable {
private Integer size;
private Integer pageNo;
}
common/common_utils/src/main/java/com/founder/commonutils/viewEntity/TbStLayer.java
......@@ -15,7 +15,7 @@ import java.util.List;
@Accessors(chain = true)
@TableName("tb_st_layer")
@ApiModel(value="图层对象", description="图层信息数据")
public class TbStLayer {
public class TbStLayer extends PageInfo {
@TableId(value = "xxzjbh")
private String xxzjbh;
private String name;
......@@ -29,5 +29,7 @@ public class TbStLayer {
private String gxdwdc;
private Date gxsj;
private List<TbStLayerData> stLayerDataList;
private String startTime;
private String endTime;
private Integer count;
}
common/common_utils/src/main/java/com/founder/commonutils/viewEntity/TbStLayerData.java
package com.founder.commonutils.viewEntity;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.util.Date;
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("tb_st_layer_data")
@ApiModel(value="图层数据对象", description="图层数据")
public class TbStLayerData implements Serializable {
@TableId(value = "xxzjbh")
private String xxzjbh;
private String gl_xxzjbh;
private double x; //经度
......
pom.xml
......@@ -77,6 +77,11 @@
<artifactId>velocity-engine-core</artifactId>
<version>${velocity.version}</version>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>4.2.1</version>
</dependency>
<!-- 数据库驱动包 -->
<!-- <dependency>
......
service/pom.xml
......@@ -67,6 +67,11 @@
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>4.2.1</version>
</dependency>
<!--ojdbc-->
<!-- <dependency>
<groupId>org.oracle</groupId>
......
service/view/src/main/java/com/founder/view/config/EduConfig.java
......@@ -26,4 +26,6 @@ public class EduConfig {
public PaginationInterceptor paginationInterceptor() {
return new PaginationInterceptor();
}
}
service/view/src/main/java/com/founder/view/controller/AccidentPointController.java deleted 100644 → 0
package com.founder.view.controller;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.util.KeyUtil;
import com.founder.commonutils.util.LngLonUtil;
import com.founder.commonutils.viewEntity.AccidentPoint;
import com.founder.view.service.AccidentPointService;
import io.swagger.annotations.Api;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.xssf.usermodel.XSSFRow;
import org.apache.poi.xssf.usermodel.XSSFSheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@Api(description = "经纬度上传")
@RestController
@RequestMapping("/xy")
public class AccidentPointController {
@Resource
AccidentPointService accidentPointService;
@RequestMapping("/uploadExcel")
public MapRestResult uploadDown(@RequestParam("excelFile") MultipartFile excelFile, HttpServletResponse response) {
try {
InputStream is = excelFile.getInputStream();
XSSFWorkbook sheets = new XSSFWorkbook(is);
XSSFSheet sheetAt = sheets.getSheetAt(0);
//获取excel有多少行
int lastRowNum = sheetAt.getLastRowNum();
List<AccidentPoint> pointList = new ArrayList<>();
for (int i = 1; i <= lastRowNum; i++) {
AccidentPoint point = new AccidentPoint();
String id = KeyUtil.getUUIDKey("xy");
point.setXxzjbh(id);
XSSFRow row = sheetAt.getRow(i);
//获取excel有多少列
short lastCellNum = row.getLastCellNum();
//判断经纬度是否符合要求
//检车一下数据是否能正常读取.....
/*double x = 0.0;
double y = 0.0;
String title = "";
String dateTime = "";
if(row.getCell(0) != null && row.getCell(1) != null){
x = row.getCell(0).getNumericCellValue();
y = row.getCell(1).getNumericCellValue();
title = row.getCell(2).getStringCellValue();
dateTime = row.getCell(3).getStringCellValue();
System.out.println(x + "==========" + y + "=========" + title + "=========" + dateTime);
}*/
DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
try {
//验证经纬度是否是八位小数以内
boolean isTrue = LngLonUtil.verifyLongAndLat(row.getCell(0).getNumericCellValue(), row.getCell(1).getNumericCellValue());
if(isTrue){//这里可以不用for循环 因为excel列数比较少
for (int j = 0; j < lastCellNum; j++) {
if(j == 0){
double x = row.getCell(0).getNumericCellValue();
point.setLon(x);
}
if(j == 1){
double y = row.getCell(1).getNumericCellValue();
point.setLat(y);
}
if(j == 2){
String title = row.getCell(2).getStringCellValue();
point.setTitle(title);
}
if(j == 3){
String dateTimeStr = row.getCell(3).getStringCellValue();
Date dateTime = df.parse(dateTimeStr);
point.setTime(dateTime);
}
}
}else {
//经度小数点后超过了八位
double x = 0;
double y = 0;
if(row.getCell(0).getNumericCellValue() + "" .length() > 12){
String xStr = row.getCell(0).getNumericCellValue() + "".substring(0, 12);
x = Double.parseDouble(xStr);
}
if(row.getCell(1).getNumericCellValue() + "" .length() > 11){
String yStr = row.getCell(0).getNumericCellValue() + "".substring(0, 11);
y = Double.parseDouble(yStr);
}
for (int j = 0; j < lastCellNum; j++) {
if(j == 0){
//x = row.getCell(0).getNumericCellValue();
point.setLon(x);
}
if(j == 1){
//y = row.getCell(1).getNumericCellValue();
point.setLat(y);
}
if(j == 2){
String title = row.getCell(2).getStringCellValue();
point.setTitle(title);
}
if(j == 3){
String dateTimeStr = row.getCell(3).getStringCellValue();
Date dateTime = df.parse(dateTimeStr);
point.setTime(dateTime);
}
}
}
accidentPointService.save(point);
} catch (Exception e) {
//具体的错误数据保存到这里
//e.printStackTrace();
pointList.add(point);
}
}
//输出流写入到excel中
HSSFWorkbook wb = new HSSFWorkbook();
HSSFSheet sheet = wb.createSheet();
//给个标题头
HSSFRow rowTitle = sheet.createRow(0);
rowTitle.createCell(0).setCellValue("经度");
rowTitle.createCell(1).setCellValue("纬度");
rowTitle.createCell(2).setCellValue("标题");
rowTitle.createCell(3).setCellValue("时间");
for (int i = 0; i < pointList.size(); i++) {
AccidentPoint accidentPoint = pointList.get(i);
double lon = accidentPoint.getLon();
double lat = accidentPoint.getLat();
String title = accidentPoint.getTitle();
Date time = accidentPoint.getTime();
HSSFRow rowData = sheet.createRow(i + 1);
rowData.createCell(0).setCellValue(lon);
rowData.createCell(1).setCellValue(lat);
rowData.createCell(2).setCellValue(title);
rowData.createCell(3).setCellValue(time);
}
//通过输出流下载
ServletOutputStream outputStream = response.getOutputStream();
//设置文件响应输出格式
response.setContentType("application/vnd.ms-excel");
response.setHeader("Content-Disposition", "attachment;filename=error.xls");
wb.write(outputStream);
outputStream.flush();
outputStream.close();
wb.close();
} catch (Exception e) {
e.printStackTrace();
}
return MapRestResult.ok();
}
}
service/view/src/main/java/com/founder/view/controller/QueryDataController.java deleted 100644 → 0
package com.founder.view.controller;
import com.alibaba.fastjson.JSONObject;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.util.ReadRequest;
import com.founder.commonutils.viewEntity.LayerInfo;
import com.founder.view.service.QueryByTimeUserService;
import io.swagger.annotations.Api;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
@Api(description = "根据时间和用户查询")
@Controller
@RequestMapping("/layer")
public class QueryDataController {
@Autowired
QueryByTimeUserService queryByTimeUserService;
@RequestMapping(value = "/query", method = RequestMethod.POST, produces = "text/plain;charset=UTF-8")
@CrossOrigin
public MapRestResult queryByTimeUser(HttpServletRequest request, HttpServletResponse response) throws Exception {
JSONObject json = new JSONObject();
try {
String para = ReadRequest.ReadAsChars(request);
JSONObject object = JSONObject.parseObject(para);
String starTime = object.getString("starTime");
String endTime = object.getString("endTime");
String userName = object.getString("userName");
List<LayerInfo> resList = queryByTimeUserService.queryByTimeUser(starTime,endTime,userName);
return MapRestResult.build(200,"查询成功",resList);
}catch (Exception e){
e.printStackTrace();
return MapRestResult.error("查询失败");
}
}
}
service/view/src/main/java/com/founder/view/controller/TbStLayerController.java
package com.founder.view.controller;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.util.KeyUtil;
import com.founder.commonutils.util.LngLonUtil;
import com.founder.commonutils.viewEntity.TbStLayer;
import com.founder.commonutils.viewEntity.TbStLayerData;
import com.founder.view.service.TbStLayerDataService;
import com.founder.view.service.TbStLayerService;
import io.swagger.annotations.Api;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.xssf.usermodel.XSSFRow;
import org.apache.poi.xssf.usermodel.XSSFSheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@Api(description = "图层数据")
@RestController
@RequestMapping("/tbStLayer")
public class TbStLayerController {
@Resource
TbStLayerDataService tbStLayerDataService;
@Resource
TbStLayerService tbStLayerService;
@RequestMapping("getLayer")
public MapRestResult getLayer() {
return null;
@RequestMapping("/getLayers")
public MapRestResult getLayers(@RequestBody TbStLayer tbStLayer) {
return tbStLayerService.getLayers(tbStLayer,tbStLayer.getPageNo(),tbStLayer.getSize());
}
}
service/view/src/main/java/com/founder/view/mapper/TbStAsjBzMapper.java deleted 100644 → 0
package com.founder.view.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.asjEntity.TbXwAsjbz;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* 案事件标注Mapper 接口
* </p>
*
* @author yangyang
* @since 2021-03-05
*/
@Mapper
public interface TbStAsjBzMapper extends BaseMapper<TbXwAsjbz> {
}
service/view/src/main/java/com/founder/view/mapper/TbStAsjMapper.java deleted 100644 → 0
package com.founder.view.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.asjEntity.CbxszAndXlaj;
import com.founder.commonutils.asjEntity.TbStAsj;
import com.founder.commonutils.publicEntity.Receiving;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
/**
* <p>
* 案事件基本信息 Mapper 接口
* </p>
*
* @author Guojunfeng
* @since 2021-03-03
*/
@Mapper
public interface TbStAsjMapper extends BaseMapper<TbStAsj> {
List<String> getXszajbhByAsjbh(@Param(value = "asjbh")String asjbh);
List<String> getXlajbhByAsjbh(@Param(value = "asjbh")String asjbh);
List<CbxszAndXlaj> GetlistXszXgaj(Map map);
List<CbxszAndXlaj> GetlistCbzXgaj(Map map);
String getNameByCode(Map<String,String> map);
List<TbStAsj> selectAsjxxByReceivingList(Receiving receiving);
List<TbStAsj> selectTlAsjxx(Receiving receiving);
List<Map<String,Object>> getAsjxxByZjhm(@Param(value = "zjhm")String zjhm);
}
service/view/src/main/java/com/founder/view/mapper/TbStLayerDataMapper.java
......@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.viewEntity.TbStLayerData;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* <p>
* 用户登录 Mapper 接口
......@@ -18,4 +20,6 @@ public interface TbStLayerDataMapper extends BaseMapper<TbStLayerData> {
void deleteByGlId(String layerId);
List<TbStLayerData> selectByGlId(String layerId);
}
service/view/src/main/java/com/founder/view/mapper/TbStLayerMapper.java
package com.founder.view.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.founder.commonutils.viewEntity.TbStLayer;
import com.founder.commonutils.viewEntity.TbStLayerData;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* <p>
* 用户登录 Mapper 接口
......@@ -18,4 +22,5 @@ import org.apache.ibatis.annotations.Mapper;
public interface TbStLayerMapper extends BaseMapper<TbStLayer> {
List<TbStLayer> selectLayers(TbStLayer tbStLayer);
}
service/view/src/main/java/com/founder/view/mapper/xml/AccidentPointMapper.xml deleted 100644 → 0
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.founder.view.mapper.AccidentPointMapper">
</mapper>
service/view/src/main/java/com/founder/view/mapper/xml/TbStAsjBzMapper.xml deleted 100644 → 0
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.founder.view.mapper.TbStAsjBzMapper">
</mapper>
service/view/src/main/java/com/founder/view/mapper/xml/TbStLayerDataMapper.xml
......@@ -4,4 +4,7 @@
<delete id="deleteByGlId" parameterType="String">
delete from tb_st_layer_data where gl_xxzjbh = #{layerId}
</delete>
<select id="selectByGlId" parameterType="String" resultType="com.founder.commonutils.viewEntity.TbStLayerData">
select * from tb_st_layer_data where gl_xxzjbh = #{layerId}
</select>
</mapper>
service/view/src/main/java/com/founder/view/mapper/xml/TbStLayerMapper.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.founder.view.mapper.TbStLayerMapper">
<resultMap id="tbStLayer" type="com.founder.commonutils.viewEntity.TbStLayer">
<result column="xxzjbh" property="xxzjbh" jdbcType="VARCHAR"></result>
<result column="name" property="name" jdbcType="VARCHAR"></result>
<result column="threshold" property="threshold" jdbcType="DOUBLE"></result>
<result column="lrr" property="lrr" jdbcType="VARCHAR"></result>
<result column="lrdwdm" property="lrdwdm" jdbcType="VARCHAR"></result>
<result column="lrdwdc" property="lrdwdc" jdbcType="VARCHAR"></result>
<result column="lrsj" property="lrsj" jdbcType="TIMESTAMP"></result>
<result column="gxr" property="gxr" jdbcType="VARCHAR"></result>
<result column="gxdwdm" property="gxdwdm" jdbcType="VARCHAR"></result>
<result column="gxdwdc" property="gxdwdc" jdbcType="VARCHAR"></result>
<result column="gxsj" property="gxsj" jdbcType="VARCHAR"></result>
<result column="count" property="count" jdbcType="TIMESTAMP"></result>
</resultMap>
<select id="selectLayers" parameterType="com.founder.commonutils.viewEntity.TbStLayer" resultMap="tbStLayer">
select * from tb_st_layer t1 where 1=1
<if test="lrr!='' and lrr!=null">
and t1.lrr like CONCAT('%',#{lrr},'%')
</if>
<if test="startTime!='' and startTime!=null">
and t1.lrsj <![CDATA[>=]]> #{startTime}
</if>
<if test="endTime!='' and endTime!=null">
and t1.lrsj <![CDATA[<=]]> #{endTime}
</if>
</select>
</mapper>
service/view/src/main/java/com/founder/view/service/AccidentPointService.java deleted 100644 → 0
package com.founder.view.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.founder.commonutils.viewEntity.AccidentPoint;
public interface AccidentPointService extends IService<AccidentPoint> {
}
service/view/src/main/java/com/founder/view/service/QueryByTimeUserService.java deleted 100644 → 0
package com.founder.view.service;
import java.util.List;
public interface QueryByTimeUserService {
public List queryByTimeUser(String starTime, String endTime, String userName);
}
service/view/src/main/java/com/founder/view/service/SysUsersService.java deleted 100644 → 0
package com.founder.view.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.founder.commonutils.publicEntity.SysUser;
public interface SysUsersService extends IService<SysUser> {
}
service/view/src/main/java/com/founder/view/service/TbStAsjBzService.java deleted 100644 → 0
package com.founder.view.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.founder.commonutils.asjEntity.TbXwAsjbz;
/**
* <p>
* 案事件基本信息 服务类
* </p>
*
* @author yangyang
* @since 2021-03-0
*/
public interface TbStAsjBzService extends IService<TbXwAsjbz> {
}
service/view/src/main/java/com/founder/view/service/TbStAsjService.java deleted 100644 → 0
package com.founder.view.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.founder.commonutils.asjEntity.CbxszAndXlaj;
import com.founder.commonutils.asjEntity.TbStAsj;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.publicEntity.Receiving;
import java.util.List;
import java.util.Map;
/**
* <p>
* 案事件基本信息 服务类
* </p>
*
* @author Guojunfeng
* @since 2021-03-03
*/
public interface TbStAsjService extends IService<TbStAsj> {
List<String> getXszajbhByAsjbh(String asjbh);
List<String> getXlajbhByAsjbh(String asjbh);
List<CbxszAndXlaj> GetlistXszXgaj(Map map);
List<CbxszAndXlaj> GetlistCbzXgaj(Map map);
String getNameByCode(Map<String,String> map);
List<TbStAsj> selectAsjxxList(Receiving receiving);
MapRestResult selectTlAsjxxList(Receiving receiving);
List<Map<String,Object>> getAsjxxByZjhm(String zjhm);
List<Map<String,Object>> getqgAsjxxByZjhm(String zjhm,String ssdw);
}
service/view/src/main/java/com/founder/view/service/TbStLayerService.java
package com.founder.view.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.viewEntity.TbStLayer;
import com.founder.commonutils.viewEntity.TbStLayerData;
import java.util.List;
public interface TbStLayerService extends IService<TbStLayer> {
MapRestResult<TbStLayer> getLayers(TbStLayer tbStLayer, Integer pageNo, Integer size);
}
service/view/src/main/java/com/founder/view/service/impl/AccidentPointServiceImpl.java deleted 100644 → 0
package com.founder.view.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.commonutils.viewEntity.AccidentPoint;
import com.founder.view.mapper.AccidentPointMapper;
import com.founder.view.service.AccidentPointService;
import org.springframework.stereotype.Service;
@Service
public class AccidentPointServiceImpl extends ServiceImpl<AccidentPointMapper, AccidentPoint> implements AccidentPointService {
}
service/view/src/main/java/com/founder/view/service/impl/QueryByTimeUserServiceImpl.java deleted 100644 → 0
package com.founder.view.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.commonutils.viewEntity.TbStLayerData;
import com.founder.commonutils.viewEntity.LayerInfo;
import com.founder.view.mapper.TbStLayerDataMapper;
import com.founder.view.service.QueryByTimeUserService;
import org.springframework.stereotype.Service;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
@Service("queryByTimeUserService")
public class QueryByTimeUserServiceImpl extends ServiceImpl<TbStLayerDataMapper, TbStLayerData> implements QueryByTimeUserService {
@Override
public List<LayerInfo> queryByTimeUser(String starTime, String endTime, String userName) {
List<LayerInfo> resList = new ArrayList<LayerInfo>();
Connection con=null;//连接接口
PreparedStatement pstmt=null;//准备语句接口
ResultSet rs=null;//结果集
try {
Class.forName("com.mysql.cj.jdbc.Driver");//加载驱动类
//test数据库地址
String url="jdbc:mysql://47.92.48.137:3900/gkpt?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";
con= DriverManager.getConnection(url,"root","gkptCcYy123");//连接数据库
String sql = "SELECT count(*) as count,t2.name,t2.lrr,t1.* " +
"FROM(select * from tb_st_layer_data WHERE time > ? and time <= ?) as t1 left join tb_st_layer t2 on t1.gl_xxzjbh=t2.xxzjbh WHERE t2.lrr=?";
pstmt=con.prepareStatement(sql);//创建准备语句对象
//pstmt.setString(1,"张三");//查询条件，1指的是第一个？，有几个？必须指定几个值。
//pstmt.setString(1,"男");
pstmt.setString(1,starTime);//查询条件
pstmt.setString(2,endTime);
pstmt.setString(3,userName);
rs=pstmt.executeQuery();
LayerInfo layerInfo = new LayerInfo();
while (rs.next()){//按行输出
layerInfo.setCount(rs.getInt("count"));
layerInfo.setName(rs.getString("name"));
layerInfo.setLrr(rs.getString("lrr"));
layerInfo.setXxzjbh(rs.getString("xxzjbh"));
layerInfo.setGl_xxzjbh(rs.getString("gl_xxzjbh"));
layerInfo.setX(rs.getBigDecimal("x"));
layerInfo.setY(rs.getBigDecimal("y"));
layerInfo.setTitle(rs.getString("title"));
layerInfo.setTime(rs.getString("time"));
resList.add(layerInfo);
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally{
if (rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(pstmt!=null){
try {
pstmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (con!=null){
try {
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return resList;
}
}
service/view/src/main/java/com/founder/view/service/impl/SysUsersServiceImpl.java deleted 100644 → 0
package com.founder.view.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.view.mapper.SysUsersMapper;
import com.founder.view.service.SysUsersService;
import com.founder.commonutils.publicEntity.SysUser;
import org.springframework.stereotype.Service;
@Service
public class SysUsersServiceImpl extends ServiceImpl<SysUsersMapper, SysUser> implements SysUsersService {
}
service/view/src/main/java/com/founder/view/service/impl/TbStAsjBzServiceImpl.java deleted 100644 → 0
package com.founder.view.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.view.mapper.TbStAsjBzMapper;
import com.founder.view.service.TbStAsjBzService;
import com.founder.commonutils.asjEntity.TbXwAsjbz;
import org.springframework.stereotype.Service;
/**
* <p>
* 案事件基本信息 服务实现类
* </p>
*
* @author yangyang
* @since 2021-03-03
*/
@Service
public class TbStAsjBzServiceImpl extends ServiceImpl<TbStAsjBzMapper, TbXwAsjbz> implements TbStAsjBzService {
}
service/view/src/main/java/com/founder/view/service/impl/TbStAsjServiceImpl.java deleted 100644 → 0
package com.founder.view.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.view.mapper.TbStAsjMapper;
//import com.founder.view.qgxzMapper.TbStAsjqgMapper;
import com.founder.view.service.TbStAsjService;
import com.founder.commonutils.asjEntity.CbxszAndXlaj;
import com.founder.commonutils.asjEntity.TbStAsj;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.publicEntity.Receiving;
import com.founder.commonutils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/**
* <p>
* 案事件基本信息 服务实现类
* </p>
*
* @author Guojunfeng
* @since 2021-03-03
*/
@Service
public class TbStAsjServiceImpl extends ServiceImpl<TbStAsjMapper, TbStAsj> implements TbStAsjService {
@Autowired
private TbStAsjMapper tbStAsjMapper;
//@Autowired
//private TbStAsjqgMapper tbStAsjqgMapper;
@Override
public List<String> getXszajbhByAsjbh(String asjbh) {
return tbStAsjMapper.getXszajbhByAsjbh(asjbh);
}
@Override
public List<String> getXlajbhByAsjbh(String asjbh) {
return tbStAsjMapper.getXlajbhByAsjbh(asjbh);
}
@Override
public List<CbxszAndXlaj> GetlistXszXgaj(Map map) {
return tbStAsjMapper.GetlistXszXgaj(map);
}
@Override
public List<CbxszAndXlaj> GetlistCbzXgaj(Map map) {
return tbStAsjMapper.GetlistCbzXgaj(map);
}
@Override
public String getNameByCode(Map<String,String> map){
return tbStAsjMapper.getNameByCode(map);
}
@Override
public List<TbStAsj> selectAsjxxList(Receiving receiving) {
return tbStAsjMapper.selectAsjxxByReceivingList(receiving);
}
//utils.StringUtil
@Override
public MapRestResult selectTlAsjxxList(Receiving receiving) {
if(StringUtil.isEmpty(receiving.getQsjd())||StringUtil.isEmpty(receiving.getJsjd())||StringUtil.isEmpty(receiving.getQswd())||StringUtil.isEmpty(receiving.getJswd())){
return MapRestResult.error("起始经纬度不能为空");
}else if(StringUtil.isEmpty(receiving.getAsjfssj_asjfskssj_start())||StringUtil.isEmpty(receiving.getAsjfssj_asjfskssj_end())){
return MapRestResult.error("时间段不能为空");
}else if(StringUtil.isEmpty(receiving.getAjzlb())&&StringUtil.isEmpty(receiving.getAjxzlb())&&StringUtil.isEmpty(receiving.getXalbdmbcms())){
return MapRestResult.error("案件标签为空，无法推算同类案件");
}else{
return MapRestResult.build(200,"同类案件查询成功",tbStAsjMapper.selectTlAsjxx(receiving));
}
}
@Override
public List<Map<String, Object>> getAsjxxByZjhm(String zjhm) {
return tbStAsjMapper.getAsjxxByZjhm(zjhm);
}
@Override
public List<Map<String, Object>> getqgAsjxxByZjhm(String zjhm, String ssdw) {
return null;
}
/*@Override
public List<Map<String, Object>> getqgAsjxxByZjhm(String zjhm,String ssdw) {
return tbStAsjqgMapper.getqgAsjxxByZjhm(zjhm,ssdw);
}*/
}
service/view/src/main/java/com/founder/view/service/impl/TbStLayerServiceImpl.java
package com.founder.view.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.viewEntity.TbStLayer;
import com.founder.commonutils.viewEntity.TbStLayerData;
import com.founder.view.mapper.TbStLayerDataMapper;
import com.founder.view.mapper.TbStLayerMapper;
import com.founder.view.service.TbStLayerDataService;
import com.founder.view.service.TbStLayerService;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
@Service
public class TbStLayerServiceImpl extends ServiceImpl<TbStLayerMapper, TbStLayer> implements TbStLayerService {
@Resource
TbStLayerMapper tbStLayerMapper;
@Resource
TbStLayerDataMapper tbStLayerDataMapper;
@Override
public MapRestResult<TbStLayer> getLayers(TbStLayer tbStLayer, Integer pageNo, Integer size) {
try {
pageNo = 1;
size= 10;
PageHelper.startPage(pageNo,size);
//List<TbStLayer> tbStLayerList = new ArrayList<>();
List<TbStLayer> tbStLayers = tbStLayerMapper.selectLayers(tbStLayer);
if(tbStLayers != null && tbStLayers.size() > 0){
for (TbStLayer stLayer : tbStLayers) {
List<TbStLayerData> tbStLayerDataList = tbStLayerDataMapper.selectByGlId(stLayer.getXxzjbh());
tbStLayer.setCount(tbStLayerDataList.size());
}
}
PageInfo<TbStLayer> pageInfo = new PageInfo<>(tbStLayers);
return MapRestResult.build(200,"图层信息查询成功！",pageInfo.getTotal(),pageInfo);
} catch (Exception e) {
e.printStackTrace();
return MapRestResult.build(500,"图层信息查询失败！",null,null);
}
}
}
service/view/src/test/java/com/founder/demo/CodeGenerator.java
......@@ -9,8 +9,21 @@ import com.baomidou.mybatisplus.generator.config.PackageConfig;
import com.baomidou.mybatisplus.generator.config.StrategyConfig;
import com.baomidou.mybatisplus.generator.config.rules.DateType;
import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
import com.founder.commonutils.util.KeyUtil;
import com.founder.commonutils.viewEntity.TbStLayerData;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.xssf.usermodel.XSSFRow;
import org.apache.poi.xssf.usermodel.XSSFSheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.junit.Test;
import java.io.FileInputStream;
import java.io.InputStream;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
/**
* @author
* @since 2018/12/13
......@@ -87,4 +100,55 @@ public class CodeGenerator {
// 6、执行
mpg.execute();
}
@Test
public void testExcel() throws Exception {
InputStream is = new FileInputStream("C:\\Users\\JBB\\Desktop\\工作目录\\excel\\模板.xlsx");
XSSFWorkbook sheets = new XSSFWorkbook(is);
XSSFSheet sheetAt = sheets.getSheetAt(0);
//获取excel有多少行
int lastRowNum = sheetAt.getLastRowNum();
List<TbStLayerData> pointList = new ArrayList<>();
DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
for (int i = 1; i <= lastRowNum; i++) {
TbStLayerData point = new TbStLayerData();
String id = KeyUtil.getUUIDKey("D");
point.setXxzjbh(id);
//point.setGl_xxzjbh(layerId);
XSSFRow row = sheetAt.getRow(i);
//获取excel有多少列
short lastCellNum = row.getLastCellNum();
//判断经纬度是否符合要求
//检车一下数据是否能正常读取.....
/*double jd = 0.0;
double wd = 0.0;*/
String jdStr = "";
String wdStr = "";
String titleStr = "";
String dateStr = "";
if (row.getCell(0) != null && row.getCell(1) != null) {
row.getCell(0).setCellType(Cell.CELL_TYPE_STRING);
row.getCell(1).setCellType(Cell.CELL_TYPE_STRING);
/*int cellType = row.getCell(0).getCellType();
int cellType2 = row.getCell(1).getCellType();
if (cellType == 0) {
jd = row.getCell(0).getNumericCellValue();
} else if (cellType == 1) {
jdStr = row.getCell(0).getStringCellValue();
point.setxStr(jdStr);
}
if (cellType2 == 0) {
wd = row.getCell(1).getNumericCellValue();
} else if (cellType2 == 1) {
wdStr = row.getCell(1).getStringCellValue();
point.setyStr(wdStr);
}*/
jdStr = row.getCell(0).getStringCellValue();
wdStr = row.getCell(1).getStringCellValue();
titleStr = row.getCell(2).getStringCellValue();
dateStr = row.getCell(3).getStringCellValue();
System.out.println(jdStr + "====" + wdStr + "=====" + titleStr + "=========" + dateStr);
//System.out.println(jd + "====" + jdStr + "======" + wd + "====" + wdStr + "=====" + titleStr + "=========" + dateStr);
}
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment