Commit 274fd1e2 by 宋珺琪

预警模型and预警模型规则

parent c07d8117
package com.founder.commonutils.model.newPublicEntity.WarningEntity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
import java.util.Date;
/**
* @description 预警模型
* @date 2023-03-02
*/
@Data
@ApiModel("预警模型")
public class SkWarning implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 模型名称
*/
@ApiModelProperty("模型名称")
private String mxmc;
/**
* 模型编号(m开头)
*/
@TableId(type = IdType.INPUT)
@ApiModelProperty("模型编号(m开头)")
private String mxbh;
/**
* 模型描述
*/
@ApiModelProperty("模型描述")
private String mxms;
/**
* 侦察阶段代码(多个逗号隔开)
*/
@ApiModelProperty("侦察阶段代码(多个逗号隔开)")
private String zcjddm;
/**
* 侦察阶段名称(多个逗号隔开)
*/
@ApiModelProperty("侦察阶段名称(多个逗号隔开)")
private String zcjdmc;
/**
* 案件类别代码(多个逗号隔开)
*/
@ApiModelProperty("案件类别代码(多个逗号隔开)")
private String ajlbdm;
/**
* 案例类别名称(多个逗号隔开)
*/
@ApiModelProperty("案例类别名称(多个逗号隔开)")
private String ajlbmc;
/**
* 小类案别代码(多个逗号隔开)
*/
@ApiModelProperty("小类案别代码(多个逗号隔开)")
private String xlabdm;
/**
* 小类案别名称(多个逗号隔开)
*/
@ApiModelProperty("小类案别名称(多个逗号隔开)")
private String xlabmc;
/**
* 细案类别代码(多个逗号隔开)
*/
@ApiModelProperty("细案类别代码(多个逗号隔开)")
private String xalbdm;
/**
* 细案类别名称(多个逗号隔开)
*/
@ApiModelProperty("细案类别名称(多个逗号隔开)")
private String xmlbmc;
/**
* 录入时间
*/
@ApiModelProperty("录入时间")
@DateTimeFormat(pattern = "yyyy-MM-ss HH:mm:ss")
private Date lrsj;
/**
* 更新时间
*/
@ApiModelProperty("更新时间")
@DateTimeFormat(pattern = "yyyy-MM-ss HH:mm:ss")
private Date gxsj;
@ApiModelProperty(value = "开始时间")
@TableField(exist = false)
private String startTime;
@ApiModelProperty(value = "结束时间")
@TableField(exist = false)
private String endTime;
@ApiModelProperty(value = "当前第几页")
@TableField(exist = false)
private int page;
@ApiModelProperty(value = "每页多少行")
@TableField(exist = false)
private int limit;
}
package com.founder.commonutils.model.newPublicEntity.WarningEntity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
import java.util.Date;
/**
* @description 预警模型规则
* @date 2023-03-02
*/
@Data
@ApiModel("预警模型规则")
public class SkWarningRule implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 信息主键编号(r开头)
*/
@TableId(type = IdType.INPUT)
@ApiModelProperty("信息主键编号(r开头)")
private String xxzjbh;
/**
* 关联模型编号
*/
@ApiModelProperty("关联模型编号")
private String glmxbh;
/**
* 时间范围
*/
@ApiModelProperty("时间范围")
private String sjfw;
/**
* 时间字段(日期为当年)
*/
@ApiModelProperty("时间字段(日期为当年)")
private String sjzd;
/**
* 统计计算
*/
@ApiModelProperty("统计计算")
private String tjjs;
/**
* 图例描述
*/
@ApiModelProperty("图例描述")
private String tlms;
/**
* 图例颜色(多个逗号隔开)
*/
@ApiModelProperty("图例颜色(多个逗号隔开)")
private String tlys;
/**
* 其他规则1
*/
@ApiModelProperty("其他规则1")
private String rule1;
/**
* 其他规则2
*/
@ApiModelProperty("其他规则2")
private String rule2;
/**
* 其他规则3
*/
@ApiModelProperty("其他规则3")
private String rule3;
/**
* 其他规则4
*/
@ApiModelProperty("其他规则4")
private String rule4;
/**
* 其他规则5
*/
@ApiModelProperty("其他规则5")
private String rule5;
/**
* 录入时间
*/
@ApiModelProperty("录入时间")
@DateTimeFormat(pattern = "yyyy-MM-ss HH:mm:ss")
private Date lrsj;
/**
* 更新时间
*/
@ApiModelProperty("更新时间")
@DateTimeFormat(pattern = "yyyy-MM-ss HH:mm:ss")
private Date gxsj;
@ApiModelProperty(value = "开始时间")
@TableField(exist = false)
private String startTime;
@ApiModelProperty(value = "结束时间")
@TableField(exist = false)
private String endTime;
@ApiModelProperty(value = "当前第几页")
@TableField(exist = false)
private int page;
@ApiModelProperty(value = "每页多少行")
@TableField(exist = false)
private int limit;
}
\ No newline at end of file
package com.founder.commonutils.model.newPublicEntity.WarningEntity;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
@Data
public class WaringVo implements Serializable {
/**
* 模型编号(m开头)
*/
@ApiModelProperty("模型编号(m开头)")
private String mxbh;
/**
* 模型名称
*/
@ApiModelProperty("模型名称")
private String mxmc;
/**
* 模型描述
*/
@ApiModelProperty("模型描述")
private String mxms;
/**
* 侦察阶段代码(多个逗号隔开)
*/
@ApiModelProperty("侦察阶段代码(多个逗号隔开)")
private String zcjddm;
/**
* 侦察阶段名称(多个逗号隔开)
*/
@ApiModelProperty("侦察阶段名称(多个逗号隔开)")
private String zcjdmc;
/**
* 案件类别代码(多个逗号隔开)
*/
@ApiModelProperty("案件类别代码(多个逗号隔开)")
private String ajlbdm;
/**
* 案例类别名称(多个逗号隔开)
*/
@ApiModelProperty("案例类别名称(多个逗号隔开)")
private String ajlbmc;
/**
* 小类案别代码(多个逗号隔开)
*/
@ApiModelProperty("小类案别代码(多个逗号隔开)")
private String xlabdm;
/**
* 小类案别名称(多个逗号隔开)
*/
@ApiModelProperty("小类案别名称(多个逗号隔开)")
private String xlabmc;
/**
* 细案类别代码(多个逗号隔开)
*/
@ApiModelProperty("细案类别代码(多个逗号隔开)")
private String xalbdm;
/**
* 细案类别名称(多个逗号隔开)
*/
@ApiModelProperty("细案类别名称(多个逗号隔开)")
private String xmlbmc;
/**
* 时间范围
*/
@ApiModelProperty("时间范围")
private String sjfw;
/**
* 时间字段(日期为当年)
*/
@ApiModelProperty("时间字段(日期为当年)")
private String sjzd;
/**
* 统计计算
*/
@ApiModelProperty("统计计算")
private String tjjs;
/**
* 图例描述
*/
@ApiModelProperty("图例描述")
private String tlms;
/**
* 图例颜色(多个逗号隔开)
*/
@ApiModelProperty("图例颜色(多个逗号隔开)")
private String tlys;
/**
* 其他规则1
*/
@ApiModelProperty("其他规则1")
private String rule1;
/**
* 其他规则2
*/
@ApiModelProperty("其他规则2")
private String rule2;
/**
* 其他规则3
*/
@ApiModelProperty("其他规则3")
private String rule3;
/**
* 其他规则4
*/
@ApiModelProperty("其他规则4")
private String rule4;
/**
* 其他规则5
*/
@ApiModelProperty("其他规则5")
private String rule5;
}
package com.founder.servicebase.controller;
import com.founder.servicebase.logs.OperLog;
import com.founder.servicebase.logs.OperationType;
import com.founder.servicebase.meassage.WebSocketServer;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
......@@ -23,6 +25,7 @@ public class WebSocketController {
@PostMapping("single")
@ApiOperation(value = "单发")
@OperLog(message = "单发",operation = OperationType.QUERY)
public void SingleMessage(String userId, String message, HttpServletRequest request) throws IOException {
WebSocketServer. SendMessage(WebSocketServer. map. get (userId),userId+"的任务:"+"已完成!"+message,"单发接口测试","10086",request);
}
......@@ -36,6 +39,7 @@ public class WebSocketController {
*/
@PostMapping("bunch")
@ApiOperation(value = "群发")
@OperLog(message = "群发",operation = OperationType.QUERY)
public void bunchMessage(@RequestParam("userId")List<String> userId,@RequestParam("message") String message,HttpServletRequest request) throws IOException {
WebSocketServer. BroadCastInfo(userId,message+"后台返回群发的消息" +"已完成!","群发接口测试",request);
......
......@@ -322,6 +322,8 @@ public class SkPointlocationController extends ApiController implements ExcelCon
}
@PostMapping("fc")
@ApiOperation(value = "查询时空设备fc")
@OperLog(message = "查询时空设备fc", operation = OperationType.QUERY)
public MapRestResult fc(@RequestBody SkPointlocationParams skPointlocationParams) {
QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("isDeleted", "0");
......
package com.founder.publicapi.controller.SkWarningService;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.founder.commonutils.model.newPublicEntity.MapRestResult;
import com.founder.commonutils.model.newPublicEntity.WarningEntity.SkWarning;
import com.founder.commonutils.model.newPublicEntity.WarningEntity.SkWarningRule;
import com.founder.commonutils.model.newPublicEntity.WarningEntity.WaringVo;
import com.founder.commonutils.util.KeyUtilNaotu;
import com.founder.publicapi.mapper.mysqlMapper.WarningMapper;
import com.founder.publicapi.mapper.mysqlMapper.WarningRuleMapper;
import com.founder.servicebase.logs.OperLog;
import com.founder.servicebase.logs.OperationType;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.Date;
@RestController
@RequestMapping("/Warning")
@Api(tags = "预警模型")
public class WarningController {
@Autowired
WarningMapper warningMapper;
@Autowired
WarningRuleMapper warningRuleMapper;
// 提供新增两个和查询接口一个(根据模型编号查询出两张表的内容)
@PostMapping("WarningAdd")
@ApiOperation(value = "预警模型新增")
@OperLog(message = "预警模型新增", operation = OperationType.ADD)
public MapRestResult WarningAdd(@RequestBody SkWarning skWarning ) {
skWarning.setMxbh(KeyUtilNaotu.getJzKey("M"));
skWarning.setLrsj(new Date());
skWarning.setGxsj(new Date());
int insert = warningMapper.insert(skWarning);
if (insert > 0){
return new MapRestResult(200,"新增成功", skWarning);
} else {
return new MapRestResult().error("保存失败");
}
}
@PostMapping("WarningDelete")
@ApiOperation(value = "预警模型删除")
@OperLog(message = "预警模型删除", operation = OperationType.DELETE)
public MapRestResult WarningDelete(@RequestBody SkWarning skWarning){
UpdateWrapper<SkWarning> wrapper = new UpdateWrapper<>();
wrapper.eq("mxbh", skWarning.getMxbh());
wrapper.set("gxsj",new Date());
int i = warningMapper.update(skWarning,wrapper);
if (i > 0){
return new MapRestResult(200,"删除成功", skWarning);
} else {
return new MapRestResult().error("删除失败");
}
}
@PostMapping("WarningUpdate")
@ApiOperation(value = "预警模型修改")
@OperLog(message = "预警模型修改", operation = OperationType.UPDATE)
public MapRestResult WarningUpdate(@RequestBody SkWarning skWarning){
UpdateWrapper<SkWarning> wrapper = new UpdateWrapper<>();
wrapper.eq("mxbh", skWarning.getMxbh());
wrapper.set("gxsj",new Date());
int update = warningMapper.update(skWarning, wrapper);
if (update > 0){
return new MapRestResult(200,"修改成功", skWarning);
} else {
return new MapRestResult().error("修改失败");
}
}
@PostMapping("WarningSelect")
@ApiOperation(value = "预警模型查询")
@OperLog(message = "预警模型修改", operation = OperationType.QUERY)
public MapRestResult WarningSelect(@RequestBody SkWarning skWarning){
QueryWrapper<SkWarning> wrapper = new QueryWrapper<>();
//模型编号
wrapper.eq(StringUtils.isNotEmpty(skWarning.getMxbh()),"mxbh", skWarning.getMxbh());
//模型名称
wrapper.like(StringUtils.isNotEmpty(skWarning.getMxmc()),"mxmc", skWarning.getMxmc());
//模型描述
wrapper.like(StringUtils.isNotEmpty(skWarning.getMxms()),"mxms", skWarning.getMxms());
if (ObjectUtil.isNotNull( skWarning.getStartTime()) && ObjectUtil.isNotNull(skWarning.getEndTime())) {
wrapper.apply("gxsj between'" + skWarning.getStartTime().toString() + "' and '" + skWarning.getEndTime().toString() +"'" );
} else if (ObjectUtil.isNotNull( skWarning.getStartTime())) {
wrapper.apply("gxsj >= '" + skWarning.getStartTime().toString() +"'" );
} else if (ObjectUtil.isNotNull(skWarning.getEndTime())) {
wrapper.apply("gxsj <= '" + skWarning.getEndTime().toString() +"'" );
}
wrapper.orderByDesc("gxsj");
// wrapper.eq("is_deleted","0");
IPage iPage = warningMapper.selectPage(new Page(skWarning.getPage(), skWarning.getLimit()), wrapper);
return new MapRestResult(200,"ok",iPage.getTotal(),iPage.getRecords());
}
@PostMapping("ruleAdd")
@ApiOperation(value = "预警模型规则新增")
@OperLog(message = "预警模型规则新增", operation = OperationType.ADD)
public MapRestResult ruleAdd(@RequestBody SkWarningRule skWarningRule ) {
skWarningRule.setXxzjbh(KeyUtilNaotu.getJzKey("R"));
skWarningRule.setLrsj(new Date());
skWarningRule.setGxsj(new Date());
int insert = warningRuleMapper.insert(skWarningRule);
if (insert > 0){
return new MapRestResult(200,"新增成功", skWarningRule);
} else {
return new MapRestResult().error("保存失败");
}
}
@PostMapping("ruleDelete")
@ApiOperation(value = "预警模型规则删除")
@OperLog(message = "预警模型规则删除", operation = OperationType.DELETE)
public MapRestResult ruleDelete(@RequestBody SkWarningRule skWarningRule){
UpdateWrapper<SkWarningRule> wrapper = new UpdateWrapper<>();
wrapper.eq("xxzjbh", skWarningRule.getXxzjbh());
wrapper.set("gxsj",new Date());
int i = warningRuleMapper.update(skWarningRule,wrapper);
if (i > 0){
return new MapRestResult(200,"删除成功", skWarningRule);
} else {
return new MapRestResult().error("删除失败");
}
}
@PostMapping("ruleUpdate")
@ApiOperation(value = "预警模型规则修改")
@OperLog(message = "预警模型规则修改", operation = OperationType.UPDATE)
public MapRestResult ruleUpdate(@RequestBody SkWarningRule skWarningRule){
UpdateWrapper<SkWarningRule> wrapper = new UpdateWrapper<>();
wrapper.eq("xxzjbh", skWarningRule.getXxzjbh());
wrapper.set("gxsj",new Date());
int update = warningRuleMapper.update(skWarningRule, wrapper);
if (update > 0){
return new MapRestResult(200,"修改成功", skWarningRule);
} else {
return new MapRestResult().error("修改失败");
}
}
@PostMapping("ruleSelect")
@ApiOperation(value = "预警模型规则查询")
@OperLog(message = "预警模型规则查询", operation = OperationType.QUERY)
public MapRestResult ruleSelect(@RequestBody SkWarningRule skWarningRule){
QueryWrapper<SkWarningRule> wrapper = new QueryWrapper<>();
//xxzjbh
wrapper.eq(StringUtils.isNotEmpty(skWarningRule.getXxzjbh()),"xxzjbh", skWarningRule.getXxzjbh());
//关联模型编号
wrapper.eq(StringUtils.isNotEmpty(skWarningRule.getGlmxbh()),"glmxbh", skWarningRule.getGlmxbh());
if (ObjectUtil.isNotNull( skWarningRule.getStartTime()) && ObjectUtil.isNotNull(skWarningRule.getEndTime())) {
wrapper.apply("gxsj between'" + skWarningRule.getStartTime().toString() + "' and '" + skWarningRule.getEndTime().toString() +"'" );
} else if (ObjectUtil.isNotNull( skWarningRule.getStartTime())) {
wrapper.apply("gxsj >= '" + skWarningRule.getStartTime().toString() +"'" );
} else if (ObjectUtil.isNotNull(skWarningRule.getEndTime())) {
wrapper.apply("gxsj <= '" + skWarningRule.getEndTime().toString() +"'" );
}
wrapper.orderByDesc("gxsj");
// wrapper.eq("is_deleted","0");
IPage iPage = warningRuleMapper.selectPage(new Page(skWarningRule.getPage(), skWarningRule.getLimit()), wrapper);
return new MapRestResult(200,"ok",iPage.getTotal(),iPage.getRecords());
}
@PostMapping("SelectBymxbh")
@ApiOperation(value = "根据模型编号查询所有")
@OperLog(message = "根据模型编号查询所有", operation = OperationType.QUERY)
public MapRestResult SelectBymxbh(@RequestBody SkWarning skWarning){
QueryWrapper<SkWarning> wrapper = new QueryWrapper<>();
wrapper.eq(StringUtils.isNotEmpty(skWarning.getMxbh()),"mxbh", skWarning.getMxbh());
SkWarning skWarning1 = warningMapper.selectOne(wrapper);
QueryWrapper<SkWarningRule> wrapper1 = new QueryWrapper<>();
wrapper1.eq(StringUtils.isNotEmpty(skWarning.getMxbh()),"glmxbh", skWarning.getMxbh());
SkWarningRule skWarningRule = warningRuleMapper.selectOne(wrapper1);
WaringVo waringVo = new WaringVo();
BeanUtils.copyProperties(skWarning1,waringVo);
BeanUtils.copyProperties(skWarningRule,waringVo);
return new MapRestResult(200,"ok",waringVo);
}
}
package com.founder.publicapi.controller.yangyang;
import com.baomidou.mybatisplus.annotation.TableField;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.io.Serializable;
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value="TbStZtryShgx", description="在逃人员社会关系")
public class TbStZtryShgx implements Serializable {
@ApiModelProperty(value = "证件号码")
private String zjhm;
@ApiModelProperty(value = "比中姓名")
private String bzxm;
@ApiModelProperty(value = "比中证件号码")
private String bzzjhm;
@ApiModelProperty(value = "关联关系代码")
private String glgxdm;
@ApiModelProperty(value = "关联描述")
private String glms;
@ApiModelProperty(value = "社会标签代码")
private String shbqdm;
@ApiModelProperty(value = "社会标签描述")
private String shbqms;
@ApiModelProperty(value = "亲密度")
private String qmd;
@ApiModelProperty(value = "最新关联时间")
private String glsj;
@ApiModelProperty(value = "比对时间")
private String bdsj;
@ApiModelProperty(value = "是否重点人员 是1")
private String sfzdry;
@TableField(exist = false)
private int page;//当前第几页
@TableField(exist = false)
private int limit;//每页多少行
}
package com.founder.publicapi.controller.yangyang;
import com.baomidou.mybatisplus.annotation.TableField;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.io.Serializable;
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value="TbStZtryShgxDetail", description="在逃人员社会关系详情")
public class TbStZtryShgxDetail implements Serializable {
@ApiModelProperty(value = "证件号码")
private String zjhm;
@ApiModelProperty(value = "比中证件号码")
private String bzzjhm;
@ApiModelProperty(value = "标识号")
private String bsh;
@ApiModelProperty(value = "地点 起始点-目的地")
private String address;
@ApiModelProperty(value = "时间")
private String sj;
@ApiModelProperty(value = "社会标签")
private String shbq;
@ApiModelProperty(value = "社会标签描述")
private String shbqms;
@ApiModelProperty(value = "比中描述")
private String bzms;
@TableField(exist = false)
private int page;//当前第几页
@TableField(exist = false)
private int limit;//每页多少行
}
package com.founder.publicapi.controller.yangyang;
import lombok.Data;
import java.util.List;
@Data
public class ZtryShgxDetailResult {
//根节点
private ShgxResult nodes;
//关系节点
private List<ShgxResult> GxNodes;
}
package com.founder.publicapi.mapper.mysqlMapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.publicapi.controller.yangyang.TbStZtryShgxDetail;
import org.springframework.stereotype.Repository;
@Repository
public interface TbStZtryShgxDetailMapper extends BaseMapper<TbStZtryShgxDetail> {
}
package com.founder.publicapi.mapper.mysqlMapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.publicapi.controller.yangyang.TbStZtryShgx;
import org.springframework.stereotype.Repository;
/**
* TbStZtryShgx表数据库访问层
*/
@Repository
public interface TbStZtryShgxMapper extends BaseMapper<TbStZtryShgx> {
}
package com.founder.publicapi.mapper.mysqlMapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.model.newPublicEntity.WarningEntity.SkWarning;
public interface WarningMapper extends BaseMapper<SkWarning> {
}
package com.founder.publicapi.mapper.mysqlMapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.founder.commonutils.model.newPublicEntity.WarningEntity.SkWarningRule;
public interface WarningRuleMapper extends BaseMapper<SkWarningRule> {
}
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