处警数据清洗

src/main/java/com/ssf/mysqloracletest/domain/JcjCjxxViewMysql.java

@@ -13,113 +13,217 @@ import lombok.Data;
  * @TableName jcj_cjxx_view
  */
 @Data
+@TableName(value = "jcj_cjxx_view")
 public class JcjCjxxViewMysql implements Serializable {
     /**
      *
      */
+    @TableField(value = "CJBH")
     private String CJBH;
+    @TableField(value = "JJBH")
     private String JJBH;
+    @TableField(value = "JJDBH")
     private String JJDBH;
+    @TableField(value = "PJDBH")
     private String PJDBH;
+    @TableField(value = "FKLYH")
     private String FKLYH;
+    @TableField(value = "CJLB")
     private String CJLB;
+    @TableField(value = "CJSJ")
     private String CJSJ;
+    @TableField(value = "DDXCSJ")
     private String DDXCSJ;
+    @TableField(value = "CJXZQH")
     private String CJXZQH;
+    @TableField(value = "CJJLX")
     private String CJJLX;
+    @TableField(value = "CJMLPH")
     private String CJMLPH;
+    @TableField(value = "CJMPHZ")
     private String CJMPHZ;
+    @TableField(value = "CJXZ")
     private String CJXZ;
+    @TableField(value = "SFCS")
     private String SFCS;
+    @TableField(value = "FSYY")
     private String FSYY;
+    @TableField(value = "TQQK")
     private String TQQK;
+    @TableField(value = "JQSX")
     private String JQSX;
+    @TableField(value = "CJR")
     private String CJR;
+    @TableField(value = "CJRHZXS")
     private String CJRHZXS;
+    @TableField(value = "CJRLXFS")
     private String CJRLXFS;
+    @TableField(value = "SFXQ")
     private String SFXQ;
+    @TableField(value = "SFSJSX")
     private String SFSJSX;
+    @TableField(value = "SFSJXX")
     private String SFSJXX;
+    @TableField(value = "CLJGNR")
     private String CLJGNR;
+    @TableField(value = "BCCLJG")
     private String BCCLJG;
+    @TableField(value = "SSXXQK")
     private String SSXXQK;
+    @TableField(value = "CJFKSJ")
     private String CJFKSJ;
+    @TableField(value = "SPSJ")
     private String SPSJ;
+    @TableField(value = "ZBLD")
     private String ZBLD;
+    @TableField(value = "ZBLDXM")
     private String ZBLDXM;
+    @TableField(value = "LDCLSJ")
     private String LDCLSJ;
+    @TableField(value = "CJJG")
     private String CJJG;
+    @TableField(value = "CJYSJSDW")
     private String CJYSJSDW;
+    @TableField(value = "CJYSJSR")
     private String CJYSJSR;
+    @TableField(value = "CJYSJSSJ")
     private String CJYSJSSJ;
+    @TableField(value = "CDJL")
     private String CDJL;
+    @TableField(value = "CDJDC")
     private String CDJDC;
+    @TableField(value = "CDCZ")
     private String CDCZ;
+    @TableField(value = "JJFNS")
     private String JJFNS;
+    @TableField(value = "JJETS")
     private String JJETS;
+    @TableField(value = "JJRZS")
     private String JJRZS;
+    @TableField(value = "JZQZ")
     private String JZQZ;
+    @TableField(value = "JZSY")
     private String JZSY;
+    @TableField(value = "RYSSS")
     private String RYSSS;
+    @TableField(value = "RYSWS")
     private String RYSWS;
+    @TableField(value = "LZSCRS")
     private String LZSCRS;
+    @TableField(value = "PHXXAJ")
     private String PHXXAJ;
+    @TableField(value = "PHXSAJ")
     private String PHXSAJ;
+    @TableField(value = "PHZAAJ")
     private String PHZAAJ;
+    @TableField(value = "TPRF")
     private String TPRF;
+    @TableField(value = "ZHZACY")
     private String ZHZACY;
+    @TableField(value = "ZJJJSS")
     private String ZJJJSS;
+    @TableField(value = "WHSS")
     private String WHSS;
+    @TableField(value = "AJSLR")
     private String AJSLR;
+    @TableField(value = "AJSLDW")
     private String AJSLDW;
+    @TableField(value = "GLAJBH")
     private String GLAJBH;
+    @TableField(value = "GLAJZT")
     private String GLAJZT;
+    @TableField(value = "GIS_X")
     private String GIS_X;
+    @TableField(value = "GIS_Y")
     private String GIS_Y;
+    @TableField(value = "DJDW")
     private String DJDW;
+    @TableField(value = "DJR")
     private String DJR;
+    @TableField(value = "DJSJ")
     private String DJSJ;
+    @TableField(value = "XGR")
     private String XGR;
+    @TableField(value = "XGSJ")
     private String XGSJ;
+    @TableField(value = "XGDW")
     private String XGDW;
+    @TableField(value = "DJRXM")
     private String DJRXM;
+    @TableField(value = "DJDWMC")
     private String DJDWMC;
+    @TableField(value = "XGRXM")
     private String XGRXM;
+    @TableField(value = "XGDWMC")
     private String XGDWMC;
+    @TableField(value = "CJDW")
     private String CJDW;
+    @TableField(value = "CJDWMC")
     private String CJDWMC;
+    @TableField(value = "CJXXDD")
     private String CJXXDD;
+    @TableField(value = "ZBLDDW")
     private String ZBLDDW;
+    @TableField(value = "ZBLDDWMC")
     private String ZBLDDWMC;
+    @TableField(value = "SPXGSJ")
     private String SPXGSJ;
+    @TableField(value = "YZB")
     private String YZB;
+    @TableField(value = "XZB")
     private String XZB;
+    @TableField(value = "BZSJ")
     private String BZSJ;
+    @TableField(value = "BZDW")
     private String BZDW;
+    @TableField(value = "BZR")
     private String BZR;
+    @TableField(value = "BZRXM")
     private String BZRXM;
+    @TableField(value = "BZDWMC")
     private String BZDWMC;
+    @TableField(value = "GXSJ")
     private String GXSJ;
+    @TableField(value = "GXRXM")
     private String GXRXM;
+    @TableField(value = "GXR")
     private String GXR;
+    @TableField(value = "GXDWMC")
     private String GXDWMC;
+    @TableField(value = "GXDW")
     private String GXDW;
+    @TableField(value = "CJLBMC")
     private String CJLBMC;
+    @TableField(value = "CJXZQHMC")
     private String CJXZQHMC;
+    @TableField(value = "CJJLXMC")
     private String CJJLXMC;
+    @TableField(value = "CJMPHZMC")
     private String CJMPHZMC;
+    @TableField(value = "SFCSMC")
     private String SFCSMC;
+    @TableField(value = "FSYYMC")
     private String FSYYMC;
+    @TableField(value = "TQQKMC")
     private String TQQKMC;
+    @TableField(value = "SFXQMC")
     private String SFXQMC;
+    @TableField(value = "CJJGMC")
     private String CJJGMC;
+    @TableField(value = "AJSLRMC")
     private String AJSLRMC;
+    @TableField(value = "AJSLDWMC")
     private String AJSLDWMC;
+    @TableField(value = "GLAJZTMC")
     private String GLAJZTMC;
+    @TableField(value = "WS_RKSJ")
     private String WS_RKSJ;
+    @TableField(value = "WS_XGSJ")
     private String WS_XGSJ;
+    @TableField(value = "WS_YXX")
     private String WS_YXX;
+    @TableField(value = "JQSXMC")
     private String JQSXMC;
+    @TableField(value = "RYWKSJ")
     private String RYWKSJ;
-
 }

src/main/java/com/ssf/mysqloracletest/domain/MetaHandleAlarmInfo.java

@@ -0,0 +1,86 @@
+package com.ssf.mysqloracletest.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 处警信息表
+ * @TableName meta_handle_alarm_info
+ */
+@TableName(value ="meta_handle_alarm_info")
+@Data
+public class MetaHandleAlarmInfo implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 处警单位名称
+     */
+    private String handleAlarmUnit;
+
+    /**
+     * 处警时间
+     */
+    private String handleAlarmTime;
+
+    /**
+     * 处警简要警情
+     */
+    private String handleAlarmContent;
+
+    /**
+     * 处警详细地点
+     */
+    private String handleAlarmAddress;
+
+    /**
+     * 处警人姓名
+     */
+    private String handleAlarmUser;
+
+    /**
+     * 处境人姓名和编码
+     */
+    private String handleAlarmUserCode;
+
+    /**
+     * 处警结果
+     */
+    private String handleAlarmResult;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建者
+     */
+    private Integer createBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新者
+     */
+    private Integer updateBy;
+
+    /**
+     * 0:不活跃,1:活跃
+     */
+    private Integer isActive;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/ssf/mysqloracletest/mapper/MetaHandleAlarmInfoMapper.java

@@ -0,0 +1,18 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author 28758
+* @description 针对表【meta_handle_alarm_info(处警信息表)】的数据库操作Mapper
+* @createDate 2023-12-01 19:02:18
+* @Entity com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo
+*/
+public interface MetaHandleAlarmInfoMapper extends BaseMapper<MetaHandleAlarmInfo> {
+
+}
+
+
+
+

src/main/java/com/ssf/mysqloracletest/service/MetaHandleAlarmInfoService.java

@@ -0,0 +1,13 @@
+package com.ssf.mysqloracletest.service;
+
+import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author 28758
+* @description 针对表【meta_handle_alarm_info(处警信息表)】的数据库操作Service
+* @createDate 2023-12-01 19:02:18
+*/
+public interface MetaHandleAlarmInfoService extends IService<MetaHandleAlarmInfo> {
+
+}

src/main/java/com/ssf/mysqloracletest/service/impl/MetaHandleAlarmInfoServiceImpl.java

@@ -0,0 +1,22 @@
+package com.ssf.mysqloracletest.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
+import com.ssf.mysqloracletest.service.MetaHandleAlarmInfoService;
+import com.ssf.mysqloracletest.mapper.MetaHandleAlarmInfoMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author 28758
+* @description 针对表【meta_handle_alarm_info(处警信息表)】的数据库操作Service实现
+* @createDate 2023-12-01 19:02:18
+*/
+@Service
+public class MetaHandleAlarmInfoServiceImpl extends ServiceImpl<MetaHandleAlarmInfoMapper, MetaHandleAlarmInfo>
+    implements MetaHandleAlarmInfoService{
+
+}
+
+
+
+

src/main/java/com/ssf/mysqloracletest/task/MetaImpUserInfoTask.java

@@ -25,9 +25,9 @@ import java.util.concurrent.Executors;
  *  用户数据接入
  */
 @Component
-public class metaImpUserInfoTask {
+public class MetaImpUserInfoTask {
 
-    private static final Logger logger = LoggerFactory.getLogger(metaImpUserInfoTask.class);
+    private static final Logger logger = LoggerFactory.getLogger(MetaImpUserInfoTask.class);
 
     @Resource
     private ZhxfZdrygkRyjbxxViewMysqlService zdryMysqlService;

src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java

@@ -25,6 +25,7 @@ public class ConfigParam {
 
 
     public static String metaImpUserSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("metaImpUserSwitch"));
+    public static String metaHandleAlarmSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("metaHandleAlarmSwitch"));
 
     //将数据洗进 --->业务表的开关----------------------------------------------------------------------------------------------------------
     public static String NewNsydwSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("NewNsydwSwitch"));