1.修改查询视频视频点播巡检结果，在MonitorService中将listChannelPlayStates做成调度任务，每天的6点5分执行一次，查询当前时间截止向前推1天
This commit is contained in:
parent
50fbfd6645
commit
d8fb61bfb6
|
|
@ -0,0 +1,23 @@
|
|||
package com.hisense.monitormanage.controller;
|
||||
|
||||
import com.hisense.monitormanage.service.SJZTService;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@RestController
|
||||
@RequestMapping("api/project")
|
||||
public class SJZTController {
|
||||
@Autowired
|
||||
private SJZTService sjztService;
|
||||
|
||||
@GetMapping("listSJZTDatas")
|
||||
public List<Map> listSJZTDatas(){
|
||||
return sjztService.listSJZTDatas();
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,165 @@
|
|||
package com.hisense.monitormanage.entity;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
|
||||
import java.time.LocalDateTime;
|
||||
|
||||
/**
|
||||
* @author admin
|
||||
* @version 1.0.0
|
||||
* @ClassName CaseCityLaw.java
|
||||
* @Description 城市执法案件类
|
||||
* @createTime 2022年05月13日 15:32:00
|
||||
*/
|
||||
public class CaseCityLaw {
|
||||
@TableId(type = IdType.ASSIGN_ID)
|
||||
private Long id;
|
||||
private String ajbs;
|
||||
private String rwh;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime ajjlsj;
|
||||
private String dzms;
|
||||
private String wtms;
|
||||
private String wtlybs;
|
||||
private String wtlymc;
|
||||
private String ajlxbs;
|
||||
private String ajlxmc;
|
||||
private String wtlxbs;
|
||||
private String wtlxmc;
|
||||
private String dlbs;
|
||||
private String dlmc;
|
||||
private String xlbs;
|
||||
private String xlmc;
|
||||
private String wtlxdm;
|
||||
private String bjbm;
|
||||
private String qbs;
|
||||
private String qmc;
|
||||
private String jdbs;
|
||||
private String jdmc;
|
||||
private String sqbs;
|
||||
private String sqmc;
|
||||
private String wgbs;
|
||||
private String wgmc;
|
||||
private String zrwgbs;
|
||||
private String zrwgmc;
|
||||
private String dlbs2;
|
||||
private String dlmc2;
|
||||
private String dllxbs;
|
||||
private String dllxmc;
|
||||
private double xzb;
|
||||
private double yzb;
|
||||
private String hdsxbs;
|
||||
private String wtdjbs;
|
||||
private String wtdjmc;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime pqsj;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime ajjssj;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime ajzfsj;
|
||||
private String ywbs;
|
||||
private String ywmc;
|
||||
private String tlxsys;
|
||||
private String latjbs;
|
||||
private String latjmc;
|
||||
private String jatjbs;
|
||||
private String jatjmc;
|
||||
private String ajxsbh;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime ajzxhdsj;
|
||||
private String ajgkbs;
|
||||
private String jjhts;
|
||||
private String jjyqs;
|
||||
private String yjzbbs;
|
||||
private String yjzbmc;
|
||||
private String ejzbbs;
|
||||
private String ejzbmc;
|
||||
private String mqsbzrzt;
|
||||
private String zsqybs;
|
||||
private String zsqymc;
|
||||
private String zsjdbs;
|
||||
private String zsjdmc;
|
||||
private String zssqbs;
|
||||
private String zssqmc;
|
||||
private String dxlx;
|
||||
private String dxly;
|
||||
private String dxsbrxm;
|
||||
private String sfbmbs;
|
||||
private String czsxcqjaaqjacqwjayqja;
|
||||
private String sbtpsl;
|
||||
private String cztpsl;
|
||||
private String clssqy;
|
||||
private String clssgs;
|
||||
private String sbqy;
|
||||
private String sfxhfsf;
|
||||
private String sqbhfsf;
|
||||
private String mydmyybbmy;
|
||||
private String hfnr;
|
||||
private String bslly;
|
||||
private String sfggdxl;
|
||||
private String bmyly;
|
||||
private String zjbjs;
|
||||
private String tsyqs;
|
||||
private String jalxbs;
|
||||
private String zdajshztzzy;
|
||||
private String sfzdajzzy;
|
||||
private String zflas;
|
||||
private String zfajh;
|
||||
private String zfrwh;
|
||||
private String czgwbs;
|
||||
private String czgw;
|
||||
private String dbs;
|
||||
private String dfdbs;
|
||||
private String asdfdbs;
|
||||
private String csdfdbs;
|
||||
private String mydpf;
|
||||
private String glajbs;
|
||||
private String yqcs;
|
||||
private String gzcs;
|
||||
private String jxid;
|
||||
private String jxmc;
|
||||
private String csbs;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime dbsj;
|
||||
private String dbrybs;
|
||||
private String dbryxm;
|
||||
private String fjfz;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime ldsj;
|
||||
private String sfdybs;
|
||||
private String cxbls;
|
||||
private String ldbs;
|
||||
private String ldmc;
|
||||
private String xybs;
|
||||
private String xymc;
|
||||
private String gdlxbs;
|
||||
private String gdlx;
|
||||
private String zajrwh;
|
||||
private String zajbzw1zrw0zrw1ptrw;
|
||||
private String zxpccgh;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime scpqsj;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime zhycpqsj;
|
||||
private String bqzd;
|
||||
private String dpbs;
|
||||
private String wjlxid;
|
||||
private String bjys;
|
||||
private String ztys;
|
||||
private String sbrssbm;
|
||||
private String yczjdzpwgkehtbs1htg0whtg;
|
||||
private String yczjdzpwgkehtcs;
|
||||
private String wgxggajfsdgaryhdpch;
|
||||
private String wgxggdhhm;
|
||||
private String xflb;
|
||||
private String yjjbajje;
|
||||
private String yqajstgyqdzpdbjrw1;
|
||||
private String sqjaj;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime operatetime;
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime updatetime;
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,18 @@
|
|||
package com.hisense.monitormanage.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.hisense.monitormanage.entity.CaseCityLaw;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author admin
|
||||
* @version 1.0.0
|
||||
* @ClassName CaseCityLawMapper.java
|
||||
* @Description TODO
|
||||
* @createTime 2022年05月13日 16:22:00
|
||||
*/
|
||||
public interface CaseCityLawMapper extends BaseMapper<CaseCityLaw> {
|
||||
public void batchSave(List<Map> list);
|
||||
}
|
||||
|
|
@ -0,0 +1,192 @@
|
|||
package com.hisense.monitormanage.service;
|
||||
|
||||
import cn.hutool.crypto.SecureUtil;
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.google.common.collect.Lists;
|
||||
import com.hisense.monitormanage.mapper.CaseCityLawMapper;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.http.HttpEntity;
|
||||
import org.springframework.http.HttpHeaders;
|
||||
import org.springframework.http.HttpMethod;
|
||||
import org.springframework.http.ResponseEntity;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.util.LinkedMultiValueMap;
|
||||
import org.springframework.util.MultiValueMap;
|
||||
import org.springframework.web.client.RestTemplate;
|
||||
|
||||
import java.io.UnsupportedEncodingException;
|
||||
import java.net.URLEncoder;
|
||||
import java.time.LocalDate;
|
||||
import java.time.LocalDateTime;
|
||||
import java.time.format.DateTimeFormatter;
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author admin
|
||||
* @version 1.0.0
|
||||
* @ClassName SJZTService.java
|
||||
* @Description 数交中台service
|
||||
* @createTime 2022年05月12日 18:00:00
|
||||
*/
|
||||
@Service
|
||||
@Slf4j
|
||||
public class SJZTService {
|
||||
@Autowired
|
||||
private RestTemplate restTemplate;
|
||||
@Autowired
|
||||
private CaseCityLawMapper caseCityLawMapper;
|
||||
|
||||
//数交中台
|
||||
//1.登录
|
||||
public String sjztToken () {
|
||||
String url = "http://120.221.95.13:9090/apin/authorization/oauth/token";
|
||||
HttpHeaders headers = new HttpHeaders();
|
||||
headers.add("Authorization", "Basic dGVzdF9jbGllbnQ6ZTk4OWQ0NmZkYmMxYzM3NmMxOWE0M2FhZjg1MjI3YTQ=");
|
||||
headers.add("Content-Type", "application/x-www-form-urlencoded");
|
||||
|
||||
MultiValueMap map = new LinkedMultiValueMap();
|
||||
map.add("username", "qdsyn");
|
||||
String sigin = SecureUtil.md5("Qdsyn123!");
|
||||
map.add("password", sigin);//Qdsyn123!,需要MD5加密
|
||||
map.add("scope", "read");
|
||||
map.add("grant_type", "password");
|
||||
map.add("vc", "NO");
|
||||
|
||||
HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
|
||||
ResponseEntity<JSONObject> responseEntity;
|
||||
try {
|
||||
responseEntity = restTemplate.exchange(url, HttpMethod.POST, request, JSONObject.class);
|
||||
JSONObject jsonObject = responseEntity.getBody();
|
||||
if (jsonObject.getBooleanValue("success") == true) {
|
||||
JSONObject resultJson = jsonObject.getJSONObject("result");
|
||||
return resultJson.getString("accessToken");
|
||||
} else {
|
||||
return null;
|
||||
}
|
||||
} catch (Exception e) {
|
||||
log.info("[qidiToken] exception:{}", e.getMessage());
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
//从接口获取案件数据
|
||||
public List<Map> listSJZTDatas() {
|
||||
String token = this.sjztToken();
|
||||
HttpHeaders headers = new HttpHeaders();
|
||||
headers.add("Authorization", "Bearer " + token);
|
||||
|
||||
Map<String,Object> map = new HashMap<>();
|
||||
JSONObject search = new JSONObject();
|
||||
search.put("opt","LIKE");
|
||||
search.put("key","AJJLSJ");
|
||||
// search.put("val",this.dateStr());
|
||||
search.put("val","2017");
|
||||
|
||||
// search.put("opt","EQ");
|
||||
// search.put("key","SPEED");
|
||||
// search.put("val","0");
|
||||
// JSONArray searchArray = new JSONArray();
|
||||
// searchArray.add(search);
|
||||
// String encode = "";
|
||||
// try {
|
||||
// encode = URLEncoder.encode(JSONObject.toJSONString(searchArray), "UTF-8").replace("+", "%20");
|
||||
// } catch (UnsupportedEncodingException e) {
|
||||
// e.printStackTrace();
|
||||
// }
|
||||
map.put("json",search);
|
||||
int i = 1;
|
||||
int roundCount = 0;
|
||||
int count = 0;
|
||||
List<Map> maps = new ArrayList<>();
|
||||
do{
|
||||
String url = "http://120.221.95.13:9090/catalog/resCatalogApply/getData/UC_QUERY_QDZWT_307013311122000064_1?pageSize=10000&pageNo={1}&search=[{2}]";
|
||||
//String url = "http://120.221.95.13:9090/catalog/resCatalogApply/getData/UC_QUERY_QDZWT_307013311122000064_1?pageSize=1&pageNo=1&search={json}";
|
||||
HttpEntity<Map> httpEntity = new HttpEntity<>(null, headers);
|
||||
ResponseEntity<JSONObject> responseEntity;
|
||||
try {
|
||||
responseEntity = restTemplate.exchange(url, HttpMethod.GET, httpEntity, JSONObject.class,i,search);
|
||||
|
||||
JSONObject jsonObject = responseEntity.getBody();
|
||||
count = jsonObject.getIntValue("count");
|
||||
JSONArray jsonArray = jsonObject.getJSONArray("list");
|
||||
log.info("[listSJZTDatas] 返回数据的数量:{}",jsonArray.size());
|
||||
maps.addAll(JSONObject.parseArray(JSONObject.toJSONString(jsonArray), Map.class));
|
||||
i++;
|
||||
roundCount = i*10000;
|
||||
} catch (Exception e) {
|
||||
log.info("[listSJZTDatas] exception:{}", e.getMessage());
|
||||
return null;
|
||||
}
|
||||
} while(roundCount <=count);
|
||||
System.out.println(maps.size());
|
||||
return maps;
|
||||
}
|
||||
|
||||
//保存案件数据
|
||||
public void batchSave(){
|
||||
String token = this.sjztToken();
|
||||
HttpHeaders headers = new HttpHeaders();
|
||||
headers.add("Authorization", "Bearer " + token);
|
||||
|
||||
Map<String,Object> map = new HashMap<>();
|
||||
JSONObject search = new JSONObject();
|
||||
search.put("opt","LIKE");
|
||||
search.put("key","AJJLSJ");
|
||||
search.put("val","2017");
|
||||
|
||||
map.put("json",search);
|
||||
int i = 1;
|
||||
int roundCount = 0;
|
||||
int count = 0;
|
||||
List<Map> mapList = new ArrayList<>();
|
||||
do{
|
||||
String url = "http://120.221.95.13:9090/catalog/resCatalogApply/getData/UC_QUERY_QDZWT_307013311122000064_1?pageSize=10000&pageNo={1}&search=[{2}]";
|
||||
//String url = "http://120.221.95.13:9090/catalog/resCatalogApply/getData/UC_QUERY_QDZWT_307013311122000064_1?pageSize=1&pageNo=1&search={json}";
|
||||
HttpEntity<Map> httpEntity = new HttpEntity<>(null, headers);
|
||||
ResponseEntity<JSONObject> responseEntity;
|
||||
try {
|
||||
responseEntity = restTemplate.exchange(url, HttpMethod.GET, httpEntity, JSONObject.class,i,search);
|
||||
|
||||
JSONObject jsonObject = responseEntity.getBody();
|
||||
count = jsonObject.getIntValue("count");
|
||||
JSONArray jsonArray = jsonObject.getJSONArray("list");
|
||||
mapList.addAll(JSONObject.parseArray(JSONObject.toJSONString(jsonArray), Map.class));
|
||||
i++;
|
||||
roundCount = i*10000;
|
||||
} catch (Exception e) {
|
||||
log.info("[SJZTService-batchSave] exception:{}", e.getMessage());
|
||||
}
|
||||
} while(roundCount <=count);
|
||||
System.out.println(mapList.size());
|
||||
List<List<Map>> lists = Lists.partition(mapList,200);
|
||||
try{
|
||||
lists.forEach(l->caseCityLawMapper.batchSave(l));
|
||||
}catch (Exception e){
|
||||
log.error("[SJZTService batchsave Exception]:",e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
//获取当前日期的时间串，2022-05-08 00:00:00
|
||||
private String dateTimeStr(){
|
||||
LocalDate localDate = LocalDate.now();
|
||||
LocalDate yestDay = localDate.minusDays(1);
|
||||
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
||||
LocalDateTime dateTime = LocalDateTime.of(yestDay.getYear(),yestDay.getMonth(),yestDay.getDayOfMonth(),0,0,0);
|
||||
return dateTime.format(formatter);
|
||||
}
|
||||
//获取当前日期的时间串，2022-05-08
|
||||
private String dateStr(){
|
||||
LocalDate localDate = LocalDate.now();
|
||||
LocalDate yestDay = localDate.minusDays(1);
|
||||
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
||||
|
||||
return yestDay.format(formatter);
|
||||
}
|
||||
}
|
||||
|
|
@ -11,7 +11,7 @@ spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
|
|||
spring.datasource.name=defaultDataSource
|
||||
# 数据库连接地址
|
||||
#spring.datasource.url=jdbc:mysql://15.72.183.91:3306/monitor_manage?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
|
||||
spring.datasource.url=jdbc:mysql://15.72.183.91:3306/monitor_manage?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
|
||||
spring.datasource.url=jdbc:mysql://15.72.183.91:3306/monitor_manage?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=true&serverTimezone=GMT%2B8
|
||||
# 数据库用户名&密码：
|
||||
spring.datasource.username=root
|
||||
spring.datasource.password=w@CmM1mBVQkPhdrc
|
||||
|
|
|
|||
|
|
@ -0,0 +1,22 @@
|
|||
<?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.hisense.monitormanage.mapper.CaseCityLawMapper">
|
||||
|
||||
<insert id="batchSave" parameterType="java.util.List">
|
||||
INSERT INTO t_case_citylaw
|
||||
(ajjlsj,dzms,wtms,wtlybs,wtlymc,ajlxbs,ajlxmc,dlbs,dlmc,xlbs,xlmc,qbs,qmc,jdbs,
|
||||
jdmc,sqbs,sqmc,xab,yzb,pqsj,sjjssj,ajzfsj,casxcqjaaqjacqwjayqja,sbtpsl,catpsl
|
||||
)
|
||||
VALUES
|
||||
<foreach collection="list" item="item" separator="," >
|
||||
(
|
||||
#{item.AJJLSJ},#{item.DZMS},#{item.WTMS},#{item.WTLYBS},#{item.WTLYMC},
|
||||
#{item.AJLXBS},#{item.AJLXMC},#{item.DLBS},#{item.DLMC},#{item.XLBS},
|
||||
#{item.XLMC},#{item.QBS},#{item.QMC},#{item.JDBS},#{item.JDMC},#{item.SQBS},
|
||||
#{item.SQMC},#{item.XZB},#{item.YZB},#{item.PQSJ},#{item.AJJSSJ},#{item.AJZFSJ},
|
||||
#{item.CZSXCQJAAQJACQWJAYQJA},#{item.SBTPSL},#{item.CZTPSL}
|
||||
)
|
||||
</foreach>
|
||||
</insert>
|
||||
|
||||
</mapper>
|
||||
Loading…
Reference in New Issue