Commit a12e064f by liulianglang

数据资源统计

parent 0ea683e3
...@@ -162,6 +162,7 @@ public class GjController { ...@@ -162,6 +162,7 @@ public class GjController {
return R.error(e.getMessage()); return R.error(e.getMessage());
} }
} }
//车辆电子违章
@PostMapping("/getClwzgjCount") @PostMapping("/getClwzgjCount")
public R getClwzgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) { public R getClwzgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try { try {
...@@ -174,6 +175,151 @@ public class GjController { ...@@ -174,6 +175,151 @@ public class GjController {
return R.error(e.getMessage()); return R.error(e.getMessage());
} }
} }
//交警违法记录
@PostMapping("/getJqwfjlgjCount")
public R getJqwfjlgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getJqwfjlgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//滴滴司机
@PostMapping("/getDdsjgjCount")
public R getDdsjgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getDdsjgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//强制隔离戒毒
@PostMapping("/getQzgljdgjCount")
public R getQzgljdgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getQzgljdgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//机动车
@PostMapping("/getJdcgjCount")
public R getJdcgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getJdcgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//出入境证件信息
@PostMapping("/getCrjzjxxgjCount")
public R getCrjzjxxgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getCrjzjxxgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//驾驶证信息
@PostMapping("/getJszxxgjCount")
public R getJszxxgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getJszxxgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//企业信息基本信息
@PostMapping("/getQyxxgjCount")
public R getQyxxgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getQyxxgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//从业人员基本信息基本信息
@PostMapping("/getCyryjbxxgjCount")
public R getCyryjbxxgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getCyryjbxxgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//教育厅毕业生基本信息
@PostMapping("/getJytbysjbxxgjCount")
public R getJytbysjbxxgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getJytbysjbxxgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//监管戒毒所人员基本信息
@PostMapping("/getJgjdsxxgjCount")
public R getJgjdsxxgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getJgjdsxxgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
//拘留所人员基本信息
@PostMapping("/getJlsxxgjCount")
public R getJlsxxgjCount(@RequestBody ZyfwQueryParam zyfwQueryParam) {
try {
HttpServletRequest request = IpADdress.getRequest();
Long total = gjService.getJlsxxgjCount(request,zyfwQueryParam.getIsZl());
System.out.println("ldzs="+total);
return R.ok().data("total", total);
} catch (Exception e) {
return R.error(e.getMessage());
}
}
/** /**
* 车牌号获取车主信息 * 车牌号获取车主信息
* @param xyrParam * @param xyrParam
......
...@@ -22,10 +22,29 @@ public interface GjService { ...@@ -22,10 +22,29 @@ public interface GjService {
Long getThdjgjCount(HttpServletRequest request,String isZl); Long getThdjgjCount(HttpServletRequest request,String isZl);
Long getClwzgjCount(HttpServletRequest request,String isZl); Long getClwzgjCount(HttpServletRequest request,String isZl);
Long getJqwfjlgjCount(HttpServletRequest request,String isZl);
Long getDdsjgjCount(HttpServletRequest request,String isZl);
Long getQzgljdgjCount(HttpServletRequest request,String isZl);
Long getJdcgjCount(HttpServletRequest request,String isZl);
Long getCrjzjxxgjCount(HttpServletRequest request,String isZl);
Long getJszxxgjCount(HttpServletRequest request,String isZl);
Long getQyxxgjCount(HttpServletRequest request,String isZl);
Long getCyryjbxxgjCount(HttpServletRequest request,String isZl);
Long getJytbysjbxxgjCount(HttpServletRequest request,String isZl);
Long getJgjdsxxgjCount(HttpServletRequest request,String isZl);
Long getJlsxxgjCount(HttpServletRequest request,String isZl);
Map<String, Object> getBlzz(HttpServletRequest request) throws Exception; Map<String, Object> getBlzz(HttpServletRequest request) throws Exception;
Map<String, Object> getWbxx(HttpServletRequest request, XyrParam xyrParam) throws Exception; Map<String, Object> getWbxx(HttpServletRequest request, XyrParam xyrParam) throws Exception;
......
...@@ -269,6 +269,391 @@ public class GjServiceImpl implements GjService { ...@@ -269,6 +269,391 @@ public class GjServiceImpl implements GjService {
@Override @Override
public Long getJqwfjlgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM vehicle_trail03 where _type='jjwfjl' ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getDdsjgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_type01.ddsjxsxx ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getQzgljdgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM case_type01 where _type='dxfqzgljdjds' ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getJdcgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_trail01 where _type= 'jdc' ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getCrjzjxxgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_trail01.crjzjxx ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getJszxxgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_trail01.jjjsz ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getQyxxgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_type01.qyxxjbxx ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getCyryjbxxgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_type01.bs_sqjw_cyry ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getJytbysjbxxgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_type01.gxjytbys ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getJgjdsxxgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_type01.jgjdsryxx ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Long getJlsxxgjCount(HttpServletRequest request,String isZl) {
if("1".equals(isZl)){
return 0L;
}else {
String sql2 = "select count(*) FROM people_type01.jgjlsry ";
Map<String, Object> map2 = EsUtils.newQueryEs(request, sql2);
//查询全国常口信息
String num = "";
String StrData2 = map2.get("data").toString();
int total2 = (int) map2.get("count");
JSONArray backBodyJson2 = JSONArray.parseArray(StrData2);
System.out.println(backBodyJson2.toJSONString());
// 首先把字符串转成 JSONArray 对象
if (backBodyJson2.size() > 0) {
for (int i = 0; i < backBodyJson2.size(); i++) {
Face mapnr = new Face();
JSONObject job = backBodyJson2.getJSONObject(i); // 遍历 jsonarray 数组,把每一个对象转成 json 对象
// 得到 每个对象中的属性值
num = job.getString("count"); //总数
}
}
if(StringUtils.isNoneBlank(num)){
return Long.parseLong(num);
}else {
return 0L;
}
}
}
@Override
public Map<String, Object> getBlzz(HttpServletRequest request) throws Exception { public Map<String, Object> getBlzz(HttpServletRequest request) throws Exception {
List<Face> list=sysGnsyrzOpenApiDao.queryList(); List<Face> list=sysGnsyrzOpenApiDao.queryList();
List<Face> result2 = new ArrayList<>(); List<Face> result2 = new ArrayList<>();
......
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