接处警信息修改

develop
hanrenchun 9 months ago
parent 6b83a9fd8d
commit bf60b15bc7

@ -22,86 +22,103 @@ public class MetaAlarmInfo implements Serializable {
@TableId(type = IdType.AUTO) @TableId(type = IdType.AUTO)
private Long id; private Long id;
@TableField(value = "alarm_code")
private String alarmCode; private String alarmCode;
/** /**
* *
*/ */
@TableField(value = "police_receiver_name")
private String policeReceiverName; private String policeReceiverName;
/** /**
* *
*/ */
@TableField(value = "alarm_response_unit")
private String alarmResponseUnit; private String alarmResponseUnit;
/** /**
* *
*/ */
@TableField(value = "alarm_response_time")
private String alarmResponseTime; private String alarmResponseTime;
/** /**
* *
*/ */
@TableField(value = "alarm_response_content")
private String alarmResponseContent; private String alarmResponseContent;
/** /**
* *
*/ */
@TableField(value = "alarm_response_type_name")
private String alarmResponseTypeName; private String alarmResponseTypeName;
/** /**
* *
*/ */
@TableField(value = "informant_name")
private String informantName; private String informantName;
/** /**
* *
*/ */
@TableField(value = "informant_phone")
private String informantPhone; private String informantPhone;
/** /**
* *
*/ */
@TableField(value = "informant_time")
private String informantTime; private String informantTime;
/** /**
* *
*/ */
@TableField(value = "alarm_address")
private String alarmAddress; private String alarmAddress;
/** /**
* *
*/ */
@TableField(value = "longitude")
private BigDecimal longitude; private BigDecimal longitude;
/** /**
* *
*/ */
@TableField(value = "latitude")
private BigDecimal latitude; private BigDecimal latitude;
/** /**
* *
*/ */
@TableField(value = "create_time")
private Date createTime; private Date createTime;
/** /**
* *
*/ */
@TableField(value = "create_by")
private Integer createBy; private Integer createBy;
/** /**
* *
*/ */
@TableField(value = "update_time")
private Date updateTime; private Date updateTime;
/** /**
* *
*/ */
@TableField(value = "update_by")
private Integer updateBy; private Integer updateBy;
/** /**
* 0:,1: * 0:,1:
*/ */
@TableField(value = "is_active")
private Integer isActive; private Integer isActive;
// @TableField(exist = false) // @TableField(exist = false)

@ -24,65 +24,78 @@ public class MetaHandleAlarmInfo implements Serializable {
/** /**
* *
*/ */
@TableField(value = "alarm_code")
private String alarmCode; private String alarmCode;
/** /**
* *
*/ */
@TableField(value = "handle_alarm_unit")
private String handleAlarmUnit; private String handleAlarmUnit;
/** /**
* *
*/ */
@TableField(value = "handle_alarm_time")
private String handleAlarmTime; private String handleAlarmTime;
/** /**
* *
*/ */
@TableField(value = "handle_alarm_content")
private String handleAlarmContent; private String handleAlarmContent;
/** /**
* *
*/ */
@TableField(value = "handle_alarm_address")
private String handleAlarmAddress; private String handleAlarmAddress;
/** /**
* *
*/ */
@TableField(value = "handle_alarm_user")
private String handleAlarmUser; private String handleAlarmUser;
/** /**
* *
*/ */
@TableField(value = "handle_alarm_user_code")
private String handleAlarmUserCode; private String handleAlarmUserCode;
/** /**
* *
*/ */
@TableField(value = "handle_alarm_result")
private String handleAlarmResult; private String handleAlarmResult;
/** /**
* *
*/ */
@TableField(value = "create_time")
private Date createTime; private Date createTime;
/** /**
* *
*/ */
@TableField(value = "create_by")
private Integer createBy; private Integer createBy;
/** /**
* *
*/ */
@TableField(value = "update_time")
private Date updateTime; private Date updateTime;
/** /**
* *
*/ */
@TableField(value = "update_by")
private Integer updateBy; private Integer updateBy;
/** /**
* 0:,1: * 0:,1:
*/ */
@TableField(value = "is_active")
private Integer isActive; private Integer isActive;
@TableField(exist = false) @TableField(exist = false)

@ -7,6 +7,7 @@ import com.ssf.mysqloracletest.domain.MetaAlarmInfo;
import com.ssf.mysqloracletest.service.JcjJjxxViewMysqlService; import com.ssf.mysqloracletest.service.JcjJjxxViewMysqlService;
import com.ssf.mysqloracletest.service.MetaAlarmInfoService; import com.ssf.mysqloracletest.service.MetaAlarmInfoService;
import com.ssf.mysqloracletest.utils.ConfigParam; import com.ssf.mysqloracletest.utils.ConfigParam;
import com.ssf.mysqloracletest.utils.NumKit;
import com.ssf.mysqloracletest.utils.StringKit; import com.ssf.mysqloracletest.utils.StringKit;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -106,23 +107,15 @@ public class AlarmInfoTask {
//alarm_response_unit<-----JJDWMC接警单位名称 //alarm_response_unit<-----JJDWMC接警单位名称
alarmInfo.setAlarmResponseUnit(jjxxViewMysqlCp.getJJDWMC()); alarmInfo.setAlarmResponseUnit(jjxxViewMysqlCp.getJJDWMC());
if (jjxxViewMysqlCp.getWDZB() != null) { if (jwd.getGIS_Y() != null) {
//转换类型
BigDecimal WDZBDecimal = new BigDecimal(jwd.getWDZB());
//latitude(纬度)<-----WDZB纬度坐标
alarmInfo.setLatitude(WDZBDecimal);
} else {
//latitude(纬度)<-----WDZB纬度坐标 //latitude(纬度)<-----WDZB纬度坐标
alarmInfo.setLatitude(null); alarmInfo.setLatitude(NumKit.checkBigDecimal(jwd.getGIS_Y()));
} }
if (jjxxViewMysqlCp.getJDZB() != null) { if (jwd.getGIS_X() != null) {
BigDecimal JDZBDecimal = new BigDecimal(jwd.getJDZB());
//longitude(经度)<-----JDZB经度坐标
alarmInfo.setLatitude(JDZBDecimal);
} else {
//longitude(经度)<-----JDZB经度坐标 //longitude(经度)<-----JDZB经度坐标
alarmInfo.setLongitude(null); alarmInfo.setLongitude(NumKit.checkBigDecimal(jwd.getGIS_X()));
} }
boolean b = alarmInfoService.save(alarmInfo); boolean b = alarmInfoService.save(alarmInfo);

@ -165,7 +165,7 @@ public class JcjCjxxTask {
//1 去mysql查出当前最大时间 //1 去mysql查出当前最大时间
JcjCjxxViewMysql cjxxViewMysql = cjxxMysqlService.selectRecordOrderByRksj(); JcjCjxxViewMysql cjxxViewMysql = cjxxMysqlService.selectRecordOrderByRksj();
//2 用得到的最大时间去oracle 查询大于这个时间的记录 //2 用得到的最大时间去oracle 查询大于这个时间的记录
List<JcjCjxxViewOracle> list = cjxxOracleService.getRealTimeRecording(cjxxViewMysql.getCJSJ()); List<JcjCjxxViewOracle> list = cjxxOracleService.getRealTimeRecording(cjxxViewMysql.getWS_RKSJ());
//3 解析入库 //3 解析入库
for (JcjCjxxViewOracle cjxx : list) { for (JcjCjxxViewOracle cjxx : list) {
JcjCjxxViewMysql sBean = new JcjCjxxViewMysql(); JcjCjxxViewMysql sBean = new JcjCjxxViewMysql();

Loading…
Cancel
Save