Commit 76721284 by yangyang

海南项目调整(海南)

parent 9964d37a
package com.founder.commonutils.util;
public class KECheckUtil {
/**只校验正数 0-90 0-180范围内 小数点后5位
* 经纬度校验
* 经度longitude: (?:[0-9]|[1-9][0-9]|1[0-7][0-9]|180)\\.([0-9]{6})
* 纬度latitude: (?:[0-9]|[1-8][0-9]|90)\\.([0-9]{6})
* @return boolean
*/
public static boolean checkLoLa(String longitude,String latitude){
String regLo = "(((?:[0-9]|[1-9][0-9]|1[0-7][0-9])\\.([0-9]{0,15}))|((?:180)\\.([0]{0,15}))|((?:[0-9]|[1-9][0-9]|1[0-7][0-9]))|(?:180))";
String regLa = "(((?:[0-9]|[1-8][0-9]|90)\\.([0-9]{0,15}))|(?:[0-9]|[1-8][0-9]|90))";
longitude = longitude.trim();
latitude = latitude.trim();
return longitude.matches(regLo)==true?latitude.matches(regLa):false;
}
/**只校验正数 X:72-136 Y:1-56范围内(中国)
* 经纬度校验
* 经度longitude: (?:[0-9]|[1-9][0-9]|1[0-7][0-9]|180)\\.([0-9]{6})
* 纬度latitude: (?:[0-9]|[1-8][0-9]|90)\\.([0-9]{6})
* @return boolean
*/
public static boolean checkLoLaChinese(String longitude,String latitude){
if(checkLoLa(longitude,latitude)){
if(Double.valueOf(longitude)>=72&&Double.valueOf(longitude)<=136){
if(Double.valueOf(latitude)>=1&&Double.valueOf(latitude)<=56){
return true;
}else return false;
}else return false;
}else return false;
}
/**只校验正数 0-90.000000 范围内
* 纬度校验
* 纬度latitude: (?:[0-9]|[1-8][0-9]|90)\\.([0-9]{6})
* @return boolean
*/
public static boolean checkLatitude(String latitude){
String regLa ="(((?:[0-9]|[1-8][0-9]|90)\\.([0-9]{0,6}))|(?:[0-9]|[1-8][0-9]|90))";
latitude = latitude.trim();
return latitude.matches(regLa);
}
/**只校验正数 0-180.000000 范围内
* 经度校验
* 经度longitude: (?:[0-9]|[1-9][0-9]|1[0-7][0-9]|180)\\.([0-9]{6})
* @return boolean
*/
public static boolean checkLongitude(String longitude){
String regLo = "(((?:[0-9]|[1-9][0-9]|1[0-7][0-9])\\.([0-9]{0,6}))|((?:180)\\.([0]{0,6}))|((?:[0-9]|[1-9][0-9]|1[0-7][0-9]))|(?:180))";
longitude = longitude.trim();
return longitude.matches(regLo);
}
}
\ No newline at end of file
......@@ -82,17 +82,20 @@ public class SysLogAspect {
sysLog.setMethod(className + "." + methodName);
// 请求参数 和对应的值
Map<String, Object> map=getNameAndValue(proceedingJoinPoint);
// 获取用户名
// 获取用户ip地址
// 接收到请求,记录请求内容
ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
HttpServletRequest request = attributes.getRequest();
if(!request.getRequestURL().toString().contains("getRxbd")){
sysLog.setParams(map.toString());
}
// 请求时间
Date date = new Date();
String pattern = "yyyy-MM-dd HH:mm:ss";
SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
sysLog.setCreateDate(simpleDateFormat.format(date));
// 获取用户名
// 获取用户ip地址
// 接收到请求,记录请求内容
ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
HttpServletRequest request = attributes.getRequest();
// 请求头传入用户证件号
String zjhm = request.getHeader("zjhmtoken");
System.out.println("证件号加密-----------------"+zjhm);
......@@ -101,7 +104,7 @@ public class SysLogAspect {
String zjhmEncoder = new String(Base64.getDecoder().decode(zjhm.getBytes()));
String redisKey = "4600:SKTOKEN" + NetworkUtil.getIpAddr(request) +zjhmEncoder;// 注销用户
System.out.println(redisKey);
sysLog.setUserId(zjhm);
sysLog.setUserId(zjhmEncoder);
System.out.println(redisTemplate.hasKey(redisKey));
if (redisTemplate.hasKey(redisKey)==false) {
Map<String, Object> mapRedis = getMap(401, "已注销!");
......@@ -127,7 +130,7 @@ public class SysLogAspect {
// 调用时长(毫秒为单位)
Long time = System.currentTimeMillis() - start;
sysLog.setTotalTime(time);
if(!StringUtils.isEmpty(result)){
if(!StringUtils.isEmpty(result)&&!request.getRequestURL().toString().contains("getRxbd")){
sysLog.setContent(result.toString());
}
} catch (Throwable throwable) {
......
......@@ -5,7 +5,9 @@
<modules>
<module>service</module>
<!--
<module>serviceapi</module>
-->
<module>common</module>
</modules>
<parent>
......
package com.founder.asj.controller;
import com.founder.asj.service.SysUsersService;
import com.founder.asj.service.SysUsersServiceAsj;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.publicEntity.SysUser;
import io.swagger.annotations.Api;
......@@ -14,7 +14,7 @@ import org.springframework.web.bind.annotation.*;
@Api(tags = "登陆管理")
public class LoginController {
@Autowired
private SysUsersService userService;
private SysUsersServiceAsj userService;
@ApiOperation(value = "登陆")
@PostMapping("/login")
......
......@@ -5,9 +5,9 @@ import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.founder.asj.service.SysUsersService;
import com.founder.asj.service.SysUsersServiceAsj;
import com.founder.asj.service.TbStAsjBzService;
import com.founder.asj.service.TbStAsjService;
import com.founder.asj.service.TbStAsjServiceAsj;
import com.founder.commonutils.asjEntity.*;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.publicEntity.Receiving;
......@@ -39,11 +39,11 @@ import java.util.Map;
@Api(description = "案事件管理")
@RestController
@RequestMapping("/asj")
public class TbStAsjController {
public class TbStAsjControllerAsj {
@Autowired
private SysUsersService sysUsersService;
private SysUsersServiceAsj sysUsersService;
@Autowired
private TbStAsjService tbStAsjService;
private TbStAsjServiceAsj tbStAsjService;
@Autowired
private TbStAsjBzService tbStAsjBzService;
......
......@@ -16,6 +16,6 @@ import org.springframework.stereotype.Component;
*/
@Mapper
@Component
public interface SysUsersMapper extends BaseMapper<SysUser> {
public interface SysUsersMapperAsj extends BaseMapper<SysUser> {
}
......@@ -19,7 +19,7 @@ import java.util.Map;
* @since 2021-03-03
*/
@Mapper
public interface TbStAsjMapper extends BaseMapper<TbStAsj> {
public interface TbStAsjMapperAsj extends BaseMapper<TbStAsj> {
List<String> getXszajbhByAsjbh(@Param(value = "asjbh")String asjbh);
......
......@@ -6,7 +6,7 @@ import com.founder.commonutils.publicEntity.SysUser;
import javax.servlet.http.HttpServletRequest;
public interface SysUsersService extends IService<SysUser> {
public interface SysUsersServiceAsj extends IService<SysUser> {
SysUser login(SysUser user);
}
......@@ -18,7 +18,7 @@ import java.util.Map;
* @author Guojunfeng
* @since 2021-03-03
*/
public interface TbStAsjService extends IService<TbStAsj> {
public interface TbStAsjServiceAsj extends IService<TbStAsj> {
List<String> getXszajbhByAsjbh(String asjbh);
......
package com.founder.asj.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.asj.mapper.SysUsersMapper;
import com.founder.asj.service.SysUsersService;
import com.founder.asj.mapper.SysUsersMapperAsj;
import com.founder.asj.service.SysUsersServiceAsj;
import com.founder.commonutils.publicEntity.SysUser;
import io.swagger.annotations.ApiModel;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
......@@ -13,10 +13,10 @@ import java.util.Base64;
@Service
public class SysUsersServiceImpl extends ServiceImpl<SysUsersMapper, SysUser> implements SysUsersService {
public class SysUsersServiceImplAsj extends ServiceImpl<SysUsersMapperAsj, SysUser> implements SysUsersServiceAsj {
@Autowired
private SysUsersMapper sysUsersMapper;
private SysUsersMapperAsj sysUsersMapper;
@Override
public SysUser login(SysUser user) {
......
......@@ -2,9 +2,9 @@ package com.founder.asj.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.asj.mapper.TbStAsjMapper;
import com.founder.asj.mapper.TbStAsjMapperAsj;
import com.founder.asj.qgxzMapper.TbStAsjqgMapper;
import com.founder.asj.service.TbStAsjService;
import com.founder.asj.service.TbStAsjServiceAsj;
import com.founder.commonutils.asjEntity.*;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.publicEntity.Receiving;
......@@ -27,10 +27,10 @@ import java.util.Map;
* @since 2021-03-03
*/
@Service
public class TbStAsjServiceImpl extends ServiceImpl<TbStAsjMapper, TbStAsj> implements TbStAsjService {
public class TbStAsjServiceImplAsj extends ServiceImpl<TbStAsjMapperAsj, TbStAsj> implements TbStAsjServiceAsj {
@Autowired
private TbStAsjMapper tbStAsjMapper;
private TbStAsjMapperAsj tbStAsjMapper;
@Autowired
private TbStAsjqgMapper tbStAsjqgMapper;
......
......@@ -188,5 +188,14 @@
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>
<!--httpclient-->
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpmime</artifactId>
</dependency>
</dependencies>
</project>
\ No newline at end of file
package com.founder.publicapi.controller;
import com.founder.commonutils.carEntity.CarKkXxParams;
import com.founder.commonutils.peopleEntity.CameraFaceTask;
import com.founder.commonutils.peopleEntity.FaceSearchParam;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.util.TokenUtils;
import com.founder.publicapi.service.ImageService;
import com.founder.servicebase.logs.OperLog;
import com.founder.servicebase.logs.OperationType;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import java.util.Date;
/**
* <p>
* 人像相关接口管理
* </p>
*
* @author yangyang
* @since 2022-04-28
*/
@Api(description = "第三方图像接口管理-海南")
@RestController
@RequestMapping("/image")
@Component
public class ImageController {
@Autowired
private ImageService imageService;
@OperLog(message = "token获取",operation = OperationType.QUERY)
@ApiOperation(value = "token获取")
@PostMapping("/token")
public MapRestResult getToken() {
//获取token
String accessToken = TokenUtils.getHnKyToken();
return MapRestResult.build(200,"成功获取token信息","1",accessToken);
}
@OperLog(message = "人脸动态检索接口",operation = OperationType.QUERY)
@ApiOperation(value = "人脸动态检索接口")
@PostMapping(value = "/getFaceImageByUploadImage")
public MapRestResult getFaceIdsByUploadImage(@RequestPart(value = "files") MultipartFile[] files, FaceSearchParam faceSearchParam) {
long startTime=new Date().getTime();
MapRestResult result=imageService.getFaceImageByUploadImage(files,faceSearchParam);
long endTime=new Date().getTime();
long timeDiffer=endTime-startTime;
System.out.println("人脸检索**请求时长**********"+timeDiffer+"毫秒");
return result;
}
@OperLog(message = "人像回溯接口",operation = OperationType.QUERY)
@ApiOperation(value = "人像回溯接口")
@PostMapping(value = "/sendTask")
public MapRestResult sendTask(@RequestBody CameraFaceTask cameraFaceTask) {
return imageService.sendTask(cameraFaceTask);
}
@OperLog(message = "范围内人像点位数据接口",operation = OperationType.QUERY)
@ApiOperation(value = "范围内人像点位数据接口")
@PostMapping(value = "/selectRxXx")
public MapRestResult selectRxXx(@RequestBody CarKkXxParams carKkXxParams) {
return imageService.selectRxXx(carKkXxParams.getQsjd(),carKkXxParams.getQswd(),carKkXxParams.getJsjd(),carKkXxParams.getJswd());
}
@OperLog(message = "人像比对接口",operation = OperationType.QUERY)
@PostMapping("/getRxbd")
@ApiOperation(value = "发起人像比对任务", notes = "发起人像比对任务")
public MapRestResult getRxbd(
@RequestParam(value = "file", required = false) MultipartFile file,@RequestParam(value = "base64Img", required = false) String base64Img,@RequestParam(value = "fjmc", required = false) String fjmc,@RequestParam(value = "threshold", required = false) String threshold,@RequestParam(value = "topNumber", required = false) String topNumber,@RequestParam(value = "model", required = false) String model, HttpServletRequest request) {
return imageService.getFqRxbdjgrw(file, base64Img,request, fjmc, threshold, topNumber, model);
}
//@OperLog(message = "获取所有摄像机落地",operation = OperationType.QUERY)
@PostMapping("/getAllCamera")
@ApiOperation(value = "获取所有摄像机落地", notes = "获取所有摄像机落地")
public MapRestResult getAllCamera() {
return imageService.getAllCamera();
}
}
package com.founder.publicapi.controller;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.publicEntity.SysUser;
import com.founder.publicapi.service.SysUsersServiceAsj;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("/")
@Api(tags = "登陆管理")
public class LoginController {
@Autowired
private SysUsersServiceAsj userService;
@ApiOperation(value = "登陆")
@PostMapping("/login")
@ResponseBody
public MapRestResult login(
@RequestParam String username,
@RequestParam String password){
SysUser user = new SysUser();
user.setUsername(username);
user.setPassword(password);
if (user!=null) {
SysUser loginUser = userService.login(user);
if (loginUser == null) {
return MapRestResult.build(201,"用户名或密码错误","1");
} else {
return MapRestResult.build(200,"登陆成功","1",loginUser);
}
}
return MapRestResult.error();
}
}
package com.founder.publicapi.controller;
import com.founder.commonutils.carEntity.TbStRegionalstaskresult;
import com.founder.commonutils.peopleEntity.JzFwSearchParams;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.publicapi.service.PhoneService;
import com.founder.servicebase.logs.OperLog;
import com.founder.servicebase.logs.OperationType;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
* <p>
* 技侦接口管理 前端控制器
* </p>
*
* @author liuyaxin
* @since 2021-04-21
*/
@Api(description = "接口管理")
@RestController
@RequestMapping("/phone")
public class PhoneController {
@Autowired
private PhoneService phoneService;
@ApiOperation(value = "手机轨迹")
@OperLog(message = "手机轨迹", operation = OperationType.QUERY)
@PostMapping("/getSjGjInfo")
public MapRestResult getSjGjInfo(@ApiParam(name = "objectValue", value = "标识号值", required = true)
@RequestParam String objectValue,
@ApiParam(name = "objectType", value = "标识号类型", required = false)
@RequestParam String objectType,
@ApiParam(name = "kssj", value = "开始时间", required = true)
@RequestParam String kssj,
@ApiParam(name = "jssj", value = "结束时间", required = true)
@RequestParam String jssj) {
return phoneService.getSjGjInfo(objectType, objectValue, kssj, jssj);
}
@ApiOperation(value = "标识号碰撞结果获取")
@PostMapping("/getRegionalsResult")
public MapRestResult getRegionalsResult(@RequestBody TbStRegionalstaskresult tbStRegionalstaskresult) throws Exception {
tbStRegionalstaskresult.setPagePara(Integer.valueOf(tbStRegionalstaskresult.getLimit()));
return phoneService.getRegionalsResult(tbStRegionalstaskresult);
}
@OperLog(message = "范围内基站点位数据接口",operation = OperationType.QUERY)
@ApiOperation(value = "范围内基站点位数据接口")
@PostMapping("/selectJzXx")
public MapRestResult selectJzXx(@RequestBody JzFwSearchParams jzFwSearchParams) {
String qsjd=jzFwSearchParams.getQsjd();
String qswd=jzFwSearchParams.getQswd();
String jsjd=jzFwSearchParams.getJsjd();
String jswd=jzFwSearchParams.getJswd();
return phoneService.selectJzXx(qsjd,qswd,jsjd,jswd);
}
}
\ No newline at end of file
package com.founder.publicapi.controller;
import com.founder.commonutils.carEntity.AreaInfo;
import com.founder.commonutils.carEntity.Regionals;
import com.founder.commonutils.carEntity.RegionalsTask;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.util.KeyUtil;
import com.founder.publicapi.service.PhoneService;
import com.founder.publicapi.service.RegTaskService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import java.util.stream.IntStream;
/**
* <p>
* 技侦接口管理 前端控制器
* </p>
*
* @author liuyaxin
* @since 2021-04-21
*/
@Api(description = "接口管理")
@RestController
@RequestMapping("/phoneRT")
public class RegionalsTaskContoller {
@Autowired
private PhoneService phoneService;
@Autowired
private RegTaskService regTaskService;
@ApiOperation(value = "生成标识号区域碰撞任务接口")
@PostMapping("/sendRegionalsTask")
public MapRestResult sendRegionalsTask(@RequestBody RegionalsTask regionalsTask) {
System.out.println("1");
// 获取区域,开始时间 ,确认时间,保存任务信息,区域
// 生成任务编号
regionalsTask.setTaskId(KeyUtil.getUUIDKey("RW"));
// 状态置为 1 进度置为 任务开始
regionalsTask.setState("1");
regionalsTask.setProgress("BEGIN");
regionalsTask.setTaskType("qypz");// 区域碰撞
//TODO:gai
regionalsTask.setTaskObject("02");// 任务对象01 车 02 人 03 人像 06车车伴随
regTaskService.saveRegTask(regionalsTask);
// 保存区域 集合
List<Regionals> regionalsList=regionalsTask.getRegionals();
if(regionalsList!=null){
IntStream.range(0, regionalsList.size()).forEach(i -> {
Regionals regionals=regionalsList.get(i);
regionals.setRegionalId(KeyUtil.getUUIDKey("QY"));
regionals.setTaskId(regionalsTask.getTaskId());
regTaskService.saveRegional(regionals);
});
}
return MapRestResult.build(200,"发送任务成功","1",regionalsTask.getTaskId());
}
@ApiOperation(value = "标识号区域碰撞接口")
@PostMapping("/phoneRegionalCollied")
public MapRestResult sendPhoneQyPzRegionalsTask(@RequestBody List<AreaInfo> areaInfos) {
try {
MapRestResult result = phoneService.MoreAreaInfoThread(areaInfos);
} catch (Exception e) {
return MapRestResult.build(201,"标识号区域碰撞接口失败","1","error");
}
return MapRestResult.build(200,"标识号碰撞接口","1","success");
}
}
package com.founder.publicapi.oracleXzxtMapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.peopleEntity.Camera;
import com.founder.commonutils.peopleEntity.CameraData;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Component;
import java.util.List;
@Mapper
@Component
public interface CameraInfoMapper extends BaseMapper<Camera> {
List<Camera> getCameraInfoByIds(@Param(value = "cameraIds") String cameraIds);
List<Camera> getCameraInfoByQsJwd(@Param(value = "qsjd") String qsjd,
@Param(value = "qswd") String qswd,
@Param(value = "jsjd") String jsjd,
@Param(value = "jswd") String jswd);
int getCameraInfoByDeviceId(@Param(value = "deviceId") String deviceId);
void insertCameraInfo(CameraData cameraData);
}
package com.founder.publicapi.oracleXzxtMapper;
import com.founder.commonutils.peopleEntity.DictitemJt;
import com.founder.commonutils.peopleEntity.ZdRybz;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Component;
import java.util.List;
@Mapper
@Component
public interface PeopleInfoMapper {
/*获取重点关注人员标注信息*/
List<ZdRybz> getZdGzryBz(String zjhm);
//根据标识码获取机场信息
DictitemJt getAirportInfo(@Param(value = "bsm") String bsm);
DictitemJt getTrainStationInfo(@Param(value = "bsm") String bsm);
DictitemJt getTrainStationInfoOne(@Param(value = "bsm") String bsm);
DictitemJt getTotalnfo(@Param(value = "lgbm") String lgbm);
}
package com.founder.publicapi.oracleXzxtMapper;
import com.founder.commonutils.carEntity.RegionalsDetail;
import com.founder.commonutils.carEntity.RegionalsPerson;
import com.founder.commonutils.carEntity.TbStRegionalstaskresult;
import com.founder.commonutils.peopleEntity.JzXxResult;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Component;
import java.util.List;
@Mapper
@Component
public interface PhoneInfoMapper {
List<TbStRegionalstaskresult> getAllResult(TbStRegionalstaskresult tbStRegionalstaskresult);
List<TbStRegionalstaskresult> getAllResultall(TbStRegionalstaskresult tbStRegionalstaskresult);
Integer getAllResultcount(TbStRegionalstaskresult tbStRegionalstaskresult);
List<RegionalsDetail> getAllRegionalsDetail(@Param("reultId") String reultId);
RegionalsPerson getAllRegionalsPerson(@Param("sfzhm") String sfzhm);
List<JzXxResult> getJzInfoByQsJwd(@Param("qsjd") String qsjd, @Param("qswd") String qswd, @Param("jsjd") String jsjd, @Param("jswd") String jswd);
}
package com.founder.publicapi.oracleXzxtMapper;
import com.founder.commonutils.carEntity.CarKkInfo;
import com.founder.commonutils.carEntity.SelectRegionalsTasksParams;
import com.founder.commonutils.carEntity.*;
import com.founder.commonutils.peopleEntity.SjGjInfo;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Component;
......@@ -19,6 +22,8 @@ public interface RegInfoMapper {
boolean saveResultPz(CarKkInfo carKkInfo);
boolean saveResultPzPhone(SjGjInfo carKkInfo);
Integer selecteRegionalsPerson(@Param("sfzhm") String sfzhm);
void saveRegionalsDetail(RegionalsDetail regionalsDetail);
......
package com.founder.publicapi.oracleXzxtMapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.publicEntity.SysUser;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
/**
* <p>
* 用户登录 Mapper 接口
* </p>
*
* @author yy
* @since 2021-03-11
*/
@Mapper
@Component
public interface SysUsersMapperAsj extends BaseMapper<SysUser> {
}
package com.founder.publicapi.oracleXzxtMapper;
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> {
}
package com.founder.publicapi.oracleXzxtMapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.asjEntity.*;
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 TbStAsjMapperAsj 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> selectAsjxxRltByReceivingList(Receiving receiving);
Integer selectAsjxxRltByReceivingListCount(Receiving receiving);
List<TbStAsj> selectTlAsjxx(Receiving receiving);
List<Map<String,Object>> getAsjxxByZjhm(@Param(value = "zjhm") String zjhm);
String getDicNameByCode(Map<String, Object> map);
/**
* 根据经纬度获取常住重点人员数据
* @param params
* @return
*/
List<CzzdryEntity> getCzzdryInfo(CzzdryParamsEntity params);
TbXwAsjbz getAjlb(@Param(value = "asjbh") String asjbh);
String getXzLev(@Param(value = "pcsdm") String pcsdm);
String getPcsdms(@Param(value = "fjdm") String fjdm);
}
package com.founder.publicapi.oracleXzxtMapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.asjEntity.TbStAsj;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.Map;
/**
* <p>
* 案事件基本信息 Mapper 接口
* </p>
*
* @author yangyang
* @since 2021-06-25
*/
@Mapper
@Component
public interface TbStAsjqgMapper extends BaseMapper<TbStAsj> {
List<Map<String,Object>> getqgAsjxxByZjhm(@Param(value = "zjhm") String zjhm, @Param(value = "ssdw") String ssdw);
}
<?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.publicapi.oracleXzxtMapper.CameraInfoMapper">
<!--根据起始经纬度获取人像点位数据-->
<select id="getCameraInfoByIds" parameterType="java.lang.String" resultType="com.founder.commonutils.peopleEntity.Camera">
select
t.ID as cameraId,
t.NAME as cameraName,
(select name from sys_dictitem where groupid = 'CODE_UNIT' and code = substr(t.camera_code,0,6)||'000000') as districtCodeName,
substr(t.camera_code,0,6)|| '000000' as districtCode,
(select name from sys_dictitem where groupid = 'CODE_XZQH' and code = substr(t.camera_code,0,6)) as areaCodeName,
substr(t.camera_code,0,6) as areaCode,
t.CITY as areaName,
x as x,
y as y,
NAME as cameraType
from tb_zy_camera t where 1=1
<if test="cameraIds!=null and cameraIds!=''">and id in ${cameraIds}</if>
</select>
<!--根据起始经纬度获取人像点位数据-->
<select id="getCameraInfoByQsJwd" parameterType="java.lang.String" resultType="com.founder.commonutils.peopleEntity.Camera">
select
deviceId as cameraId,
deviceName as cameraName,
(select name from sys_dictitem where groupid = 'CODE_UNIT' and code = substr(t.gbCode,0,6)||'000000') as districtCodeName,
substr(t.gbCode,0,6)|| '000000' as districtCode,
(select name from sys_dictitem where groupid = 'CODE_XZQH' and code = substr(t.gbCode,0,6)) as areaCodeName,
substr(t.gbCode,0,6) as areaCode,
latitude as y,
longitude as x
from tb_zy_camera t where 1=1
<if test="qsjd!=null and qsjd!='' and qsjd!=null and qsjd!='' and qswd!=null and qswd!='' and jswd!=null and jswd!=''">
AND longitude<![CDATA[>=]]>#{qsjd,jdbcType=VARCHAR} AND longitude<![CDATA[<=]]>#{jsjd,jdbcType=VARCHAR}
AND latitude<![CDATA[>=]]>#{qswd,jdbcType=VARCHAR} AND latitude<![CDATA[<=]]>#{jswd,jdbcType=VARCHAR}
</if>
</select>
<!--根据摄像头id获取摄像头-->
<select id="getCameraInfoByDeviceId" parameterType="java.lang.String" resultType="java.lang.Integer">
select
count(*)
from tb_zy_camera t where deviceId = #{deviceId}
</select>
<!--摄像头数据落地-->
<insert id="insertCameraInfo" parameterType="com.founder.commonutils.peopleEntity.CameraData">
INSERT INTO tb_zy_camera (
deviceId,deviceName,longitude,latitude,deviceAddress,gbCode
)
VALUES(
#{deviceId, jdbcType=VARCHAR}
,#{deviceName, jdbcType=VARCHAR}
,#{longitude, jdbcType=VARCHAR}
,#{latitude, jdbcType=VARCHAR}
,#{deviceAddress, jdbcType=VARCHAR}
,#{gbCode, jdbcType=VARCHAR}
)
</insert>
</mapper>
<?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.publicapi.oracleXzxtMapper.PeopleInfoMapper">
<!--查询重点关注人员标注信息-->
<select id="getZdGzryBz" resultType="com.founder.commonutils.peopleEntity.ZdRybz">
select CODE as code,ZDY_CODE as zdyCode,CODE_TXT as codeTxt,ZDY_CODE_TXT as zdyCodeTxt
from tb_st_rybz
where XXSC_PDBZ = 0 AND ZJHM = #{zjhm}
</select>
<!-- 根据编码获取机场所在城市名字和经纬度 -->
<select id="getAirportInfo" parameterType="string" resultType="com.founder.commonutils.peopleEntity.DictitemJt">
SELECT
BSMC bsmc,
JD jd,
WD wd
FROM
SYS_DICTITEM_JT
WHERE
TYPE = '2'
AND SCBZ = '0'
AND BSM = #{bsm}
</select>
<!-- 根据编码获取火车相关信息(精确查询) -->
<select id="getTrainStationInfoOne" parameterType="string" resultType="com.founder.commonutils.peopleEntity.DictitemJt">
SELECT
BSMC bsmc,
JD jd,
WD wd
FROM
SYS_DICTITEM_JT
WHERE
TYPE = '1'
AND SCBZ = '0'
AND BSM = #{bsm}
</select>
<!-- 根据编码获取火车相关信息()模糊查询 -->
<select id="getTrainStationInfo" parameterType="string" resultType="com.founder.commonutils.peopleEntity.DictitemJt">
SELECT
BSMC bsmc,
JD jd,
WD wd
FROM
SYS_DICTITEM_JT
WHERE
TYPE = '1'
AND SCBZ = '0'
AND #{bsm} LIKE'%' || BSM ||'%'
</select>
<!-- 旅馆信息 -->
<select id="getTotalnfo" resultType="com.founder.commonutils.peopleEntity.DictitemJt" parameterType="string">
SELECT
FPOINTX jd,
FPOINTY wd
FROM
TB_M_ZA_LDJBXX
WHERE
LGBM = #{lgbm}
AND rownum = 1
</select>
</mapper>
<?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.publicapi.oracleXzxtMapper.PhoneInfoMapper">
<resultMap id="RegionalsDetail" type="com.founder.commonutils.carEntity.RegionalsDetail">
<result column="xxzjbh" property="xxzjbh" jdbcType="VARCHAR"/>
<result column="sfzhm" property="sfzhm" jdbcType="VARCHAR"/>
<result column="sf_Check" property="sfCheck" jdbcType="VARCHAR"/>
<result column="result_Id" property="resultId" jdbcType="VARCHAR"/>
<result column="object_Type" property="objectType" jdbcType="VARCHAR"/>
<result column="object_Type_Name" property="objectTypeName" jdbcType="VARCHAR"/>
<result column="object_Value" property="objectValue" jdbcType="VARCHAR"/>
</resultMap>
<!--任务 查询结果表-->
<select id="getAllResult" parameterType="com.founder.commonutils.carEntity.TbStRegionalstaskresult"
resultType="com.founder.commonutils.carEntity.TbStRegionalstaskresult">
select t2.* from(
select t1.*,rownum as rn from
(
SELECT
xxzjbh,
task_id,
object_type,
object_type_name,
object_value,
region,
regionList,
apetype,
apetypeMc,
kkUrlPic,
x,
y,
to_char(time,'YYYY-MM-DD HH24:mi:ss') as timeGet
FROM TB_ST_REGIONALS_RESULT
where 1=1
<if test="task_id != null and task_id != ''">and task_id = #{ task_id , jdbcType=VARCHAR }</if>
<if test="sabz!= null and sabz != ''">and sabz = #{ sabz , jdbcType=VARCHAR }</if>
<if test="object_value != null and object_value != ''">
and object_value = #{ object_value , jdbcType=VARCHAR }
</if>
<if test="apetype != null and apetype != ''">
and apetype = #{ apetype , jdbcType=VARCHAR }
</if>
<if test="region != null and region != ''">
and region = #{ region , jdbcType=VARCHAR }
</if>
) t1
<where>
rownum<![CDATA[ <= ]]> #{ end , jdbcType=VARCHAR }
</where>
)t2
<where>
rn<![CDATA[ >= ]]> #{ begin, jdbcType=VARCHAR }
</where>
</select>
<!--任务 查询结果表-->
<select id="getAllResultall" parameterType="com.founder.commonutils.carEntity.TbStRegionalstaskresult"
resultType="com.founder.commonutils.carEntity.TbStRegionalstaskresult">
SELECT
xxzjbh,
task_id,
object_type,
object_type_name,
object_value,
region,
regionList,
apetype,
apetypeMc,
kkUrlPic,
x,
y,
to_char(time,'YYYY-MM-DD HH24:mi:ss') as timeGet
FROM TB_ST_REGIONALS_RESULT
where 1=1
<if test="task_id != null and task_id != ''">and task_id = #{ task_id , jdbcType=VARCHAR }</if>
</select>
<select id="getAllResultcount" parameterType="com.founder.commonutils.carEntity.TbStRegionalstaskresult"
resultType="java.lang.Integer">
SELECT
count(*)
FROM TB_ST_REGIONALS_RESULT
where 1=1
<if test="task_id != null and task_id != ''">and task_id = #{ task_id , jdbcType=VARCHAR }</if>
<if test="sabz!= null and sabz != ''">and sabz = #{ sabz , jdbcType=VARCHAR }</if>
<if test="object_value != null and object_value != ''">
and object_value = #{ object_value , jdbcType=VARCHAR }
</if>
<if test="apetype != null and apetype != ''">and apetype = #{ apetype , jdbcType=VARCHAR }</if>
<if test="region != null and region != ''">and region = #{ region , jdbcType=VARCHAR }</if>
</select>
<!--任务 查询详情表-->
<select id="getAllRegionalsDetail" parameterType="String"
resultMap="RegionalsDetail">
SELECT
*
FROM TB_ST_REGIONALS_DETAIL
where 1=1
<if test="reultId != null and reultId != ''">and result_id = #{ reultId , jdbcType=VARCHAR }</if>
</select>
<!--任务 查询人员表-->
<select id="getAllRegionalsPerson" parameterType="String"
resultType="com.founder.commonutils.carEntity.RegionalsPerson">
select * from TB_ST_REGIONALS_PERSON
where 1=1
<if test="sfzhm != null and sfzhm != ''">
and SFZHM = #{ sfzhm , jdbcType=VARCHAR }
</if>
</select>
<!--根据起始经纬度获取人像点位数据-->
<select id="getJzInfoByQsJwd" parameterType="java.lang.String" resultType="com.founder.commonutils.peopleEntity.JzXxResult">
select
BSID as deviceCode,
XZQH_DZ as deviceAddress,
XCOORD as x,
YCOORD as y
from tb_my_jzxx t where 1=1
<if test="qsjd!=null and qsjd!='' and qsjd!=null and qsjd!='' and qswd!=null and qswd!='' and jswd!=null and jswd!=''">
AND XCOORD<![CDATA[>=]]>#{qsjd,jdbcType=VARCHAR} AND XCOORD<![CDATA[<=]]>#{jsjd,jdbcType=VARCHAR}
AND YCOORD<![CDATA[>=]]>#{qswd,jdbcType=VARCHAR} AND YCOORD<![CDATA[<=]]>#{jswd,jdbcType=VARCHAR}
</if>
</select>
</mapper>
\ No newline at end of file
<?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.publicapi.oracleXzxtMapper.SysUsersMapperAsj">
</mapper>
<?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.publicapi.oracleXzxtMapper.TbStAsjBzMapper">
</mapper>
<?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.publicapi.oracleXzxtMapper.TbStAsjqgMapper">
<select id="getqgAsjxxByZjhm" parameterType="java.lang.String" resultType="map">
SELECT
T.asjbh AS asjbh,
TO_CHAR(XYR.ZHRQ,'YYYY-MM-DD HH24:mi:ss') AS zhrq,
T.ajmc AS ajmc,
T.ajlbdm AS ajlbdmMc,
T.zcjddm AS zcjddmMc,
TO_CHAR(T.asjfssj_Asjfskssj,'YYYY-MM-DD HH24:mi:ss') AS asjfssjAsjfskssj,
TO_CHAR(T.larq,'YYYY-MM-DD HH24:mi:ss') AS larq
FROM TB_ST_ASJ T,TB_XW_ZBFZXYR XYR
where
T.ASJBH = XYR.ASJBH
AND
T.XXSC_PDBZ = 0
AND
XYR.XXSC_PDBZ = 0
<if test="ssdw != null and ssdw != ''">
AND T.ASJBH NOT LIKE '%A' || #{ssdw, jdbcType=VARCHAR } || '%'
</if>
<if test="zjhm != null and zjhm != ''">
AND XYR.zhfzxyr_Cyzj_Zjhm = #{zjhm}
</if>
</select>
</mapper>
package com.founder.publicapi.service;
import com.founder.commonutils.peopleEntity.CameraFaceTask;
import com.founder.commonutils.peopleEntity.FaceSearchParam;
import com.founder.commonutils.publicEntity.MapRestResult;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
/**
* <p>
* 云天接口 服务类
* </p>
*
* @author yangyang
* @since 2021-03-19
*/
public interface ImageService {
MapRestResult getFaceImageByUploadImage(MultipartFile[] files, FaceSearchParam faceSearchParam);
MapRestResult sendTask(CameraFaceTask cameraFaceTask);
MapRestResult selectRxXx(String qsjd, String qswd, String jsjd, String jswd);
MapRestResult getFqRxbdjgrw(MultipartFile file, String base64Img, HttpServletRequest request, String fjmc, String threshold, String topNumber, String model);
MapRestResult getAllCamera();
}
package com.founder.publicapi.service;
import com.founder.commonutils.peopleEntity.NaoTuRybq;
import com.founder.commonutils.peopleEntity.PeopleInfo;
import com.founder.commonutils.peopleEntity.PeopleResourceTrackResult;
import com.founder.commonutils.publicEntity.MapRestResult;
import org.dom4j.DocumentException;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Map;
public interface PeopleService {
MapRestResult getXsSfXx(String objectType, String objectValue) throws Exception;
PeopleInfo xsxxByZjhm(String objectType, String objectValue) throws Exception;
List getCarInfo(String objectType, String objectValue) throws Exception;
List getSjSmInfo(String objectType, String objectValue) throws DocumentException;
List getXnXxInfo(String objectType, String objectValue);
NaoTuRybq getRybz(String zjhm);
String getZdGzryBz(String zjhm);
List<PeopleResourceTrackResult> getRyswgj(String zjhm, String beginDate, String endDate) throws Exception;
List<PeopleResourceTrackResult> getRyzsgj(String zjhm, String beginDate, String endDate) throws Exception;
List<PeopleResourceTrackResult> getRyhbgj(String zjhm, String beginDate, String endDate) throws Exception;
List<PeopleResourceTrackResult> getRyhcgj(String zjhm, String beginDate, String endDate) throws Exception;
List<PeopleResourceTrackResult> getRydbgj(String zjhm, String beginDate, String endDate) throws Exception;
List<PeopleResourceTrackResult> getRygkgj(String zjhm, String beginDate, String endDate) throws Exception;
Map<String, Object> getEbss(String zjhm) throws Exception;
MapRestResult getFqRxbdjgrw(MultipartFile file, String base64Img, HttpServletRequest request, String fjmc, String threshold, String topNumber, String model);
}
package com.founder.publicapi.service;
import com.founder.commonutils.carEntity.AreaInfo;
import com.founder.commonutils.carEntity.TbStRegionalstaskresult;
import com.founder.commonutils.publicEntity.MapRestResult;
import java.util.List;
public interface PhoneService {
MapRestResult getSjGjInfo(String objectType, String objectValue, String kssj, String jssj);
MapRestResult MoreAreaInfoThread(List<AreaInfo> areaInfos) throws Exception;
MapRestResult getRegionalsResult(TbStRegionalstaskresult tbStRegionalstaskresult) throws Exception;
MapRestResult selectJzXx(String qsjd, String qswd, String jsjd, String jswd);
}
package com.founder.publicapi.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.founder.commonutils.publicEntity.SysUser;
public interface SysUsersServiceAsj extends IService<SysUser> {
SysUser login(SysUser user);
}
package com.founder.publicapi.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> {
}
package com.founder.publicapi.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.founder.commonutils.asjEntity.*;
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 TbStAsjServiceAsj 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);
List<TbStAsj> selectAsjxxRltList(Receiving receiving);
Integer selectAsjxxRltListCount(Receiving receiving);
MapRestResult selectTlAsjxxList(Receiving receiving);
List<Map<String,Object>> getAsjxxByZjhm(String zjhm);
List<Map<String,Object>> getqgAsjxxByZjhm(String zjhm, String ssdw);
List<CzzdryEntity> getCzzdry(CzzdryParamsEntity params);
TbXwAsjbz getAjlb(String asjbh);
}
......@@ -90,6 +90,8 @@ public class CarServiceImpl implements CarService {
//根据设备编号获取其他经纬度和名称信息
KkdwxxEntity kkdwxxEntity = carInfoDao.getKkInfo(map.get("POINT_ID"));
if(kkdwxxEntity != null){
// 经纬度核验
if(KECheckUtil.checkLoLaChinese(kkdwxxEntity.getJd(),kkdwxxEntity.getWd())) {
car.setDeviceId(map.get("POINT_ID")); //设备编号
car.setDeviceName(kkdwxxEntity.getSbmc()); //设备名称
car.setX(kkdwxxEntity.getJd()); //经度
......@@ -110,6 +112,7 @@ public class CarServiceImpl implements CarService {
carList.add(car);
}
}
}
//循环请求
// Boolean flag=true;
// int page = 1;
......
package com.founder.publicapi.service.serviceimpl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.commonutils.publicEntity.SysUser;
import com.founder.publicapi.oracleXzxtMapper.SysUsersMapperAsj;
import com.founder.publicapi.service.SysUsersServiceAsj;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Base64;
@Service
public class SysUsersServiceImplAsj extends ServiceImpl<SysUsersMapperAsj, SysUser> implements SysUsersServiceAsj {
@Autowired
private SysUsersMapperAsj sysUsersMapper;
@Override
public SysUser login(SysUser user) {
//对password进行加密
String password = Base64.getEncoder().encodeToString(user.getPassword().getBytes());
QueryWrapper<SysUser> wrapper = new QueryWrapper<SysUser>();
// 数据库字段名 对应值
wrapper.eq("USERNAME", user.getUsername());
wrapper.eq("PASSWORD", password);
wrapper.eq("OPEN_FLAG", "1");
wrapper.eq("SCBZ", "0");
//设置需要查询的字段
wrapper.select("IDENTITYCARD","USERNAME", "UNITCODE", "TRUE_NAME", "TELEPHONE",
"UNITNAME", "GRADE", "POLICEMANID");
user = sysUsersMapper.selectOne(wrapper);
return user;
}
}
package com.founder.publicapi.service.serviceimpl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.commonutils.asjEntity.TbXwAsjbz;
import com.founder.publicapi.oracleXzxtMapper.TbStAsjBzMapper;
import com.founder.publicapi.service.TbStAsjBzService;
import org.springframework.stereotype.Service;
/**
* <p>
* 案事件基本信息 服务实现类
* </p>
*
* @author yangyang
* @since 2021-03-03
*/
@Service
public class TbStAsjBzServiceImpl extends ServiceImpl<TbStAsjBzMapper, TbXwAsjbz> implements TbStAsjBzService {
}
package com.founder.publicapi.service.serviceimpl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.founder.commonutils.asjEntity.*;
import com.founder.commonutils.publicEntity.MapRestResult;
import com.founder.commonutils.publicEntity.Receiving;
import com.founder.commonutils.util.StringUtil;
import com.founder.publicapi.oracleXzxtMapper.TbStAsjMapperAsj;
import com.founder.publicapi.oracleXzxtMapper.TbStAsjqgMapper;
import com.founder.publicapi.service.TbStAsjServiceAsj;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* <p>
* 案事件基本信息 服务实现类
* </p>
*
* @author Guojunfeng
* @since 2021-03-03
*/
@Service
public class TbStAsjServiceImplAsj extends ServiceImpl<TbStAsjMapperAsj, TbStAsj> implements TbStAsjServiceAsj {
@Autowired
private TbStAsjMapperAsj 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);
}
@Override
public List<TbStAsj> selectAsjxxRltList(Receiving receiving) {
// 分页处理
receiving.setPagePara(receiving.getLimit());
// 案件类别代码模糊查询
if (StringUtils.isNotEmpty(receiving.getAjlbdm())) {
// 根据规则截取前三位
String ajlbdm = "";
if (receiving.getAjlbdm().endsWith("000")) {
ajlbdm = receiving.getAjlbdm().substring(0, 3) + "*";
} else {
ajlbdm = receiving.getAjlbdm();
}
receiving.setAjlbdm(ajlbdm);
}
// 案件类别代码模糊查询
if (StringUtils.isNotEmpty(receiving.getAfdxzqhdm())) {
// 根据规则截取前两位
String xzqh = "";
if(receiving.getAfdxzqhdm().endsWith("0000")){
xzqh = receiving.getAfdxzqhdm().substring(0,2);
}else if(receiving.getAfdxzqhdm().endsWith("00")){
xzqh = receiving.getAfdxzqhdm().substring(0,4);
}else{
xzqh = receiving.getAfdxzqhdm();
}
receiving.setAfdxzqhdm(xzqh);
}
return tbStAsjMapper.selectAsjxxRltByReceivingList(receiving);
}
@Override
public Integer selectAsjxxRltListCount(Receiving receiving) {
return tbStAsjMapper.selectAsjxxRltByReceivingListCount(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{
if(receiving.getPcsdm() != null){
//根据派出所代码获取级别(3/4)
String lev = tbStAsjMapper.getXzLev(receiving.getPcsdm());
if(lev != null){
if("3".equals(lev)){
receiving.setFjdm(receiving.getPcsdm());
receiving.setPcsdm(null);
}
}
}
if(receiving.getFjdm() != null){
receiving.setPcsdms(tbStAsjMapper.getPcsdms(receiving.getFjdm()));
}
return MapRestResult.build(200,"同类案件查询成功",tbStAsjMapper.selectTlAsjxx(receiving));
}
}
@Override
public List<Map<String, Object>> getAsjxxByZjhm(String zjhm) {
List<Map<String, Object>> list = new ArrayList<>();
/* if("460003198912096617".equals(zjhm) || "13900757030".equals(zjhm)){
Map<String, Object> map = new HashMap<>();
map.put("ZHFZXYRFZXYRDAZTDMMC","死亡");
map.put("AJMC","李义交通肇事案");
map.put("ZCJDDMMC","处理案事件");
map.put("ASJBH","A4601000000AAAAAAA22810");
map.put("AJLBDMMC","交通肇事案");
map.put("ASJFSSJASJFSKSSJ","2021-09-06 13:26:22");
map.put("ZHRQ","2021-11-12 00:00:00");
map.put("LARQ","2020-12-06 21:14:27");
map.put("ZUZDWZBRXM","何**");
list.add(map);
}else{*/
list = tbStAsjMapper.getAsjxxByZjhm(zjhm);
/* }*/
return list;
}
@Override
public List<Map<String, Object>> getqgAsjxxByZjhm(String zjhm,String ssdw) {
List<Map<String, Object>> list = new ArrayList<>();
if("460003198912096617".equals(zjhm) || "13900757030".equals(zjhm)){
Map<String, Object> map = new HashMap<>();
map.put("ASJBH","A1501000000AAAAAAA22810");
map.put("AJLBDMMC","消防责任事故案");
map.put("AJMC","李义消防责任事故案");
map.put("ZCJDDMMC","处理案事件");
map.put("ASJFSSJASJFSKSSJ","2021-03-19 13:26:22");
map.put("ZHRQ","2021-11-29 00:00:00");
map.put("LARQ","2021-03-26 21:14:27");
list.add(map);
map.put("ASJBH","A1501000000AAAAAAA22821");
map.put("AJLBDMMC","消防责任事故案");
map.put("ZCJDDMMC","处理案事件");
map.put("AJMC","李义消防责任事故案");
map.put("ASJFSSJASJFSKSSJ","2021-05-05 08:15:58");
map.put("ZHRQ","2021-12-06 00:00:00");
map.put("LARQ","2021-05-08 13:05:45");
list.add(map);
}else{
list = tbStAsjqgMapper.getqgAsjxxByZjhm(zjhm,ssdw);
if(list != null && list.size() > 0){
Map<String, Object> params = new HashMap<>();
list.forEach(a->{
params.put("groupid","CODE_AJLB");
params.put("code",a.get("AJLBDMMC"));
a.put("AJLBDMMC",tbStAsjMapper.getDicNameByCode(params));
params.put("groupid","CODE_ZCJDDM");
params.put("code",a.get("ZCJDDMMC"));
a.put("ZCJDDMMC",tbStAsjMapper.getDicNameByCode(params));
});
}
}
return list;
}
@Override
public List<CzzdryEntity> getCzzdry(CzzdryParamsEntity params) {
Map<String, Object> map = new HashMap<>();
List<CzzdryEntity> list = tbStAsjMapper.getCzzdryInfo(params);
return list;
}
@Override
public TbXwAsjbz getAjlb(String asjbh) {
TbXwAsjbz tbXwAsjbz = tbStAsjMapper.getAjlb(asjbh);
if(tbXwAsjbz == null){
tbXwAsjbz = new TbXwAsjbz();
}
return tbXwAsjbz;
}
}
......@@ -8,7 +8,7 @@ logging.level.root=INFO
#mybatis???
#mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
#oracle?????????
spring.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver
spring.datasource.driver-class-name=oracle.jdbc.OracleDriver
spring.datasource.oraclexzxt.url=jdbc:oracle:thin:@10.184.17.3:1521:HNXZXT1
spring.datasource.oraclexzxt.username=XZXT
spring.datasource.oraclexzxt.password=XzxtPwd#46
......@@ -31,3 +31,9 @@ spring.redis.host=74.6.54.169
spring.redis.port=6378
spring.redis.password=46#110
spring.redis.database=14
#单位
ssdw=460000000000
#海南凯亚人像请求公共地址
imageUrl=http://74.10.30.174:18093
{
"bzdz": [
{
"address": "海南省海头镇那力村委会万头村",
"bh": "460003198912096617",
"name": "李义"
}],
"zzrk": [
{
"address": "海南省海头镇那力村委会万头村",
"bh": "460003198912096617",
"name": "李义"
},
{
"address": "海南省定安县定城镇高龙村七队5号",
"bh": "460003198912096617",
"name": "李义"
}
],
"syrk": [
{
"address": "定城镇高龙村委会高龙村七队5号",
"bh": "460003198912096617",
"name": "李义"
},
{
"address": "定城镇高龙村委会高龙村4号",
"bh": "460003198912096617",
"name": "李义"
}
],
"sydw": [
{
"address": "海南省海口市美兰区白龙街道办事处五贤居委会下贤一村133号",
"bh": "460108803000000661",
"name": "海口美兰从美床垫直销店"
}]
}
\ No newline at end of file
[
{
"city":"海口美兰国际机场T1",
"hotalName":"海口美兰国际机场T1",
"point":[110.45893810364146, 19.938703969039647],
"roomNumber":"琼AD33988",
"time":"2021-12-05 07:00:00"
},{
"city":"海口市火车东站 北",
"hotalName":"海口市火车东站 北",
"point":[110.33854221252541, 19.985670978507667],
"roomNumber":"琼AD33988",
"time":"2021-12-05 08:30:20"
},{
"city":"海南大学(城西校区) 西",
"hotalName":"海南大学(城西校区) 西",
"point":[110.32172697487864, 19.983609946849832],
"roomNumber":"琼AD33988",
"time":"2021-12-05 10:20:20"
},{
"city":"金牛岭公园",
"hotalName":"金牛岭公园",
"point":[110.31164414109763, 20.011782570649647],
"roomNumber":"琼AD33988",
"time":"2021-12-05 13:30:20"
},{
"city":"万绿园",
"hotalName":"万绿园",
"point":[110.30986481748921, 20.03491377755897],
"roomNumber":"琼AD33988",
"time":"2021-12-05 14:30:00"
},{
"city":"西秀海滩公园 南",
"hotalName":"西秀海滩公园 南",
"point":[110.24640227545602, 20.031651684276895],
"roomNumber":"琼AD33988",
"time":"2021-12-05 15:30:00"
},{
"city":"海口市公安局",
"hotalName":"海口市公安局",
"point":[110.20018928729324, 20.04900495151147],
"roomNumber":"琼AD33988",
"time":"2021-12-05 19:40:00"
},{
"city":"海口市公安局",
"hotalName":"海口市公安局",
"point":[110.0101, 19.0101],
"roomNumber":"琼AD33988",
"time":"2021-12-05 19:40:00"
},{
"city":"海口站",
"hotalName":"海口站",
"point":[110.15789772476803, 20.029262978560833],
"roomNumber":"琼AD33988",
"time":"2021-12-06 07:30:00"
},{
"city":"五源河休闲度假区",
"hotalName":"五源河休闲度假区",
"point":[110.20503279304414, 20.047632860587896],
"roomNumber":"琼AD33988",
"time":"2021-12-06 08:50:00"
},{
"city":"海南省人民医院",
"hotalName":"海南省人民医院",
"point":[110.28253953690714, 20.00878445107244],
"roomNumber":"琼AD33988",
"time":"2021-12-06 12:50:00"
},{
"city":"海南大学(城西校区) 西",
"hotalName":"海南大学(城西校区) 西",
"point":[110.32172697487864,19.983609946849832],
"roomNumber":"琼AD33988",
"time":"2021-12-06 14:00:00"
}
]
\ No newline at end of file
[
{
"city":"三亚",
"hotalName":"三亚",
"point":[113.0101, 28.0101],
"roomNumber":"琼A25846",
"time":"2022-02-19"
},{
"city":"海口东",
"hotalName":"海口东",
"point":[110.0101, 19.0101],
"roomNumber":"琼A25846",
"time":"2022-02-19"
}
]
\ No newline at end of file
[
{
"city":"徐闻港",
"hotalName":"徐闻港",
"point":[110.13599, 20.23656],
"roomNumber":"琼6524",
"time":"2022-02-08"
},{
"city":"海口港",
"hotalName":"海口港",
"point":[110.27945, 20.02414],
"roomNumber":"琼6524",
"time":"2022-02-08"
}
]
\ No newline at end of file
[
{
"city":"海口",
"hotalName":"海口美兰机场",
"point":[110.0101, 19.0101],
"roomNumber":"1186",
"time":"2022-01-17"
},{
"city":"长沙",
"hotalName":"长沙黄花机场",
"point":[113.0101, 28.0101],
"roomNumber":"1186",
"time":"2022-01-17"
}
]
\ No newline at end of file
[
{
"city":"海口东",
"hotalName":"海口东",
"point":[110.33862205710324, 19.985885609743875],
"roomNumber":"C7487",
"time":"2022-02-19"
},{
"city":"三亚",
"hotalName":"三亚",
"point":[109.48911771389365, 18.29833135061942],
"roomNumber":"C7487",
"time":"2022-02-19"
}
]
\ No newline at end of file
[
{
"city":"海口市龙华区",
"hotalName":"战地网吧",
"point":[110.31859548188432, 20.027695022978340],
"roomNumber":"C12",
"time":"6小时"
},{
"city":"海口市龙华区",
"hotalName":"天马星辰网吧",
"point":[110.32765205847271, 20.023969548696446],
"roomNumber":"A15",
"time":"4小时50分钟"
},{
"city":"海口市龙华区",
"hotalName":"红树林网咖",
"point":[110.32129120966968, 20.000360987871833],
"roomNumber":"A15",
"time":"4小时"
}
]
\ No newline at end of file
[
{
"city":"海口市龙华区",
"hotalName":"如家酒店龙华分店",
"point":[110.33554468045509, 20.022940329339324],
"roomNumber":"C12",
"time":"2022-02-18 15:00:00"
},{
"city":"海口市龙华区",
"hotalName":"百林酒店",
"point":[110.33234033387885, 20.01192539109397],
"roomNumber":"A15",
"time":"2022-02-20 08:00:00"
},{
"city":"海口市龙华区",
"hotalName":"格林豪泰酒店",
"point":[110.3298922323434, 20.003023749299086],
"roomNumber":"A15",
"time":"2022-02-23 10:30:00"
},{
"city":"海口市龙华区",
"hotalName":"昌河酒店",
"point":[110.316648129342, 19.99378620216507],
"roomNumber":"A15",
"time":"2022-02-24 12:15:00"
},{
"city":"海口市龙华区",
"hotalName":"金秋宾馆",
"point":[110.29157362330007, 20.004165694216233],
"roomNumber":"A15",
"time":"2022-02-26 20:00:00"
}
]
\ No newline at end of file
[
{
"objectType": "03",
"objectValue": "460003198912096617",
"children": [
{
"objectType": "04",
"objectValue": "13900757030",
"children": [
{
"objectType": "06",
"objectValue": "2063631028",
"children": null
},
{
"objectType": "07",
"objectValue": "wxid_78sak8u8d995351",
"children": null
},
{
"objectType": "05",
"objectValue": "460030891182002",
"children": null
},
{
"objectType": "05",
"objectValue": "460115821421656",
"children": null
},
{
"objectType": "08",
"objectValue": "86159903553023",
"children": null
},
{
"objectType": "08",
"objectValue": "86961605658693",
"children": null
}
]
},
{
"objectType": "01",
"objectValue": "琼AD33988",
"children": null
}
]
}
]
\ No newline at end of file
......@@ -8,7 +8,7 @@ logging.level.root=INFO
#mybatis日志
#mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
#oracle数据库连接
spring.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver
spring.datasource.driver-class-name=oracle.jdbc.OracleDriver
spring.datasource.url=jdbc:oracle:thin:@10.184.17.3:1521:HNXZXT1
spring.datasource.username=XZXT
spring.datasource.password=XzxtPwd#46
......
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