[update] 实时数据表迁移到databus

signal-datacenter-service/pom.xml

@@ -21,6 +21,11 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>net.wanji</groupId>
+            <artifactId>wj-databus</artifactId>
+            <version>0.0.1</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>

signal-datacenter-service/src/main/java/net/wanji/datacenter/DataCenterApplication.java

@@ -8,7 +8,7 @@ import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.transaction.annotation.EnableTransactionManagement;
 
 @SpringBootApplication(scanBasePackages = {"net.wanji.datacenter", "net.wanji.common"})
-@MapperScan(basePackages = {"net.wanji.datacenter.mapper"})
+@MapperScan(basePackages = {"net.wanji.datacenter.mapper", "net.wanji.databus.dao.mapper"})
 @EnableTransactionManagement
 @EnableScheduling
 @EnableAsync

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/convert/LanePeriodicDataEventListConvert.java

 package net.wanji.datacenter.pojo.convert;
 
+import net.wanji.databus.po.*;
 import net.wanji.datacenter.pojo.dto.LanePeriodicDataDTO;
-import net.wanji.datacenter.pojo.po.*;
 import org.springframework.stereotype.Component;
 
 import java.util.Date;

signal-datacenter-service/src/main/java/net/wanji/datacenter/service/impl/LanePeriodicDataProcessServiceImpl.java

@@ -3,11 +3,11 @@ package net.wanji.datacenter.service.impl;
 import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import net.wanji.databus.dao.mapper.*;
+import net.wanji.databus.po.*;
 import net.wanji.datacenter.kafka.ConsumerHandler;
-import net.wanji.datacenter.mapper.*;
 import net.wanji.datacenter.pojo.convert.LanePeriodicDataEventListConvert;
 import net.wanji.datacenter.pojo.dto.LanePeriodicDataDTO;
-import net.wanji.datacenter.pojo.po.*;
 import net.wanji.datacenter.service.DataProcessService;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossBaseLaneInfoMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossBaseLaneInfoMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossBaseLaneInfoPO;
+import net.wanji.databus.po.CrossBaseLaneInfoPO;
 import org.apache.ibatis.annotations.Mapper;
 
 /**

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossDataHistMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossDataHistMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
+
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossDataHistPO;
+import net.wanji.databus.po.CrossDataHistPO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossDataRealTimeMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossDataRealTimeMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossDataRealTimePO;
+import net.wanji.databus.po.CrossDataRealTimePO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -15,5 +15,6 @@ import java.util.List;
 @Mapper
 public interface CrossDataRealTimeMapper extends BaseMapper<CrossDataRealTimePO> {
     void insertBatch(@Param("list") List<CrossDataRealTimePO> list);
+
     void deleteBatch(@Param("list") Collection<String> crossIds);
 }

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossDirDataHistMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossDirDataHistMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossDirDataHistPO;
+import net.wanji.databus.po.CrossDirDataHistPO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossDirDataRealTimeMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossDirDataRealTimeMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossDirDataRealTimePO;
+import net.wanji.databus.po.CrossDirDataRealTimePO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossLaneDataHistMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossLaneDataHistMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossLaneDataHistPO;
+import net.wanji.databus.po.CrossLaneDataHistPO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossLaneDataRealTimeMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossLaneDataRealTimeMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossLaneDataRealTimePO;
+import net.wanji.databus.po.CrossLaneDataRealTimePO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossTurnDataHistMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossTurnDataHistMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossTurnDataHistPO;
+import net.wanji.databus.po.CrossTurnDataHistPO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 

signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossTurnDataRealTimeMapper.java → wj-databus/src/main/java/net/wanji/databus/dao/mapper/CrossTurnDataRealTimeMapper.java

-package net.wanji.datacenter.mapper;
+package net.wanji.databus.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import net.wanji.datacenter.pojo.po.CrossTurnDataRealTimePO;
+import net.wanji.databus.po.CrossTurnDataRealTimePO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/AreaDataRealTimePO.java → wj-databus/src/main/java/net/wanji/databus/po/AreaDataRealTimePO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossBaseLaneInfoPO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossBaseLaneInfoPO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossDataHistPO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossDataHistPO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossDataRealTimePO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossDataRealTimePO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossDirDataHistPO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossDirDataHistPO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossDirDataRealTimePO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossDirDataRealTimePO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossLaneDataHistPO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossLaneDataHistPO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossLaneDataRealTimePO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossLaneDataRealTimePO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossTurnDataHistPO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossTurnDataHistPO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossTurnDataRealTimePO.java → wj-databus/src/main/java/net/wanji/databus/po/CrossTurnDataRealTimePO.java

-package net.wanji.datacenter.pojo.po;
+package net.wanji.databus.po;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;

signal-datacenter-service/src/main/resources/mapper/CrossBaseLaneInfoMapper.xml → wj-databus/src/main/resources/mapper/CrossBaseLaneInfoMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossBaseLaneInfoMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossBaseLaneInfoMapper">
 </mapper>
\ No newline at end of file

signal-datacenter-service/src/main/resources/mapper/CrossDataHistMapper.xml → wj-databus/src/main/resources/mapper/CrossDataHistMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossDataHistMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossDataHistMapper">
 
-    <resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossDataHistPO">
+    <resultMap id="BaseResultMap" type="net.wanji.databus.po.CrossDataHistPO">
         <result column="cross_id" property="crossId"></result>
         <result column="status" property="status"></result>
         <result column="type" property="type"></result>
@@ -36,7 +36,7 @@
         flow, flow_rate, speed, queue_length, stop_times, delay_time, sturation, batch_time, gmt_create, gmt_modified
     </sql>
 
-    <insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossDataHistPO">
+    <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossDataHistPO">
         insert into t_cross_data_hist
              (<include refid="Base_Column_List"></include>)
         values

signal-datacenter-service/src/main/resources/mapper/CrossDataRealTimeMapper.xml → wj-databus/src/main/resources/mapper/CrossDataRealTimeMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossDataRealTimeMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossDataRealTimeMapper">
 
-    <resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossDataRealTimePO">
+    <resultMap id="BaseResultMap" type="net.wanji.databus.po.CrossDataRealTimePO">
         <result column="cross_id" property="crossId"></result>
         <result column="status" property="status"></result>
         <result column="type" property="type"></result>
@@ -36,7 +36,7 @@
         flow, flow_rate, speed, queue_length, stop_times, delay_time, sturation, batch_time, gmt_create, gmt_modified
     </sql>
 
-    <insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossDataRealTimePO">
+    <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossDataRealTimePO">
         insert into t_cross_data_realtime
              (<include refid="Base_Column_List"></include>)
         values

signal-datacenter-service/src/main/resources/mapper/CrossDirDataHistMapper.xml → wj-databus/src/main/resources/mapper/CrossDirDataHistMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossDirDataHistMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossDirDataHistMapper">
 
-    <resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossDirDataHistPO">
+    <resultMap id="BaseResultMap" type="net.wanji.databus.po.CrossDirDataHistPO">
         <result column="id" property="id"></result>
         <result column="dir_type" property="dirType"></result>
         <result column="in_out_type" property="inOutType"></result>
@@ -30,7 +30,7 @@
         speed, queue_length, stop_times, delay_time, sturation, batch_time, gmt_create, gmt_modified, effusion_time
     </sql>
 
-    <insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossDirDataHistPO">
+    <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossDirDataHistPO">
         insert into t_cross_dir_data_hist
             (<include refid="Base_Column_List"></include>)
         values

signal-datacenter-service/src/main/resources/mapper/CrossDirDataRealTimeMapper.xml → wj-databus/src/main/resources/mapper/CrossDirDataRealTimeMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossDirDataRealTimeMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossDirDataRealTimeMapper">
 
-    <resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossDirDataRealTimePO">
+    <resultMap id="BaseResultMap" type="net.wanji.databus.po.CrossDirDataRealTimePO">
         <result column="id" property="id"></result>
         <result column="dir_type" property="dirType"></result>
         <result column="in_out_type" property="inOutType"></result>
@@ -30,7 +30,7 @@
         speed, queue_length, stop_times, delay_time, sturation, batch_time, gmt_create, gmt_modified, effusion_time
     </sql>
 
-    <insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossDirDataRealTimePO">
+    <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossDirDataRealTimePO">
         insert into t_cross_dir_data_realtime
             (<include refid="Base_Column_List"></include>)
         values

signal-datacenter-service/src/main/resources/mapper/CrossLaneDataHistMapper.xml → wj-databus/src/main/resources/mapper/CrossLaneDataHistMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossLaneDataHistMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossLaneDataHistMapper">
 
-    <resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossLaneDataHistPO">
+    <resultMap id="BaseResultMap" type="net.wanji.databus.po.CrossLaneDataHistPO">
         <result column="id" property="id"></result>
         <result column="cross_id" property="crossId"></result>
         <result column="flow" property="flow"></result>
@@ -27,7 +27,7 @@
             vehhead_dist, vehhead_time, quality, batch_time, gmt_create, gmt_modified
     </sql>
 
-    <insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossLaneDataHistPO">
+    <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossLaneDataHistPO">
         insert into t_lane_data_hist
         (<include refid="Base_Column_List"></include>)
         values

signal-datacenter-service/src/main/resources/mapper/CrossLaneDataRealTimeMapper.xml → wj-databus/src/main/resources/mapper/CrossLaneDataRealTimeMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossLaneDataRealTimeMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossLaneDataRealTimeMapper">
 
-    <resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossLaneDataRealTimePO">
+    <resultMap id="BaseResultMap" type="net.wanji.databus.po.CrossLaneDataRealTimePO">
         <result column="id" property="id"></result>
         <result column="cross_id" property="crossId"></result>
         <result column="flow" property="flow"></result>
@@ -27,7 +27,7 @@
             vehhead_dist, vehhead_time, quality, batch_time, gmt_create, gmt_modified
     </sql>
 
-    <insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossLaneDataRealTimePO">
+    <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossLaneDataRealTimePO">
         insert into t_lane_data_realtime
         (<include refid="Base_Column_List"></include>)
         values

signal-datacenter-service/src/main/resources/mapper/CrossTurnDataHistMapper.xml → wj-databus/src/main/resources/mapper/CrossTurnDataHistMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossTurnDataHistMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossTurnDataHistMapper">
 
-    <resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossTurnDataRealTimePO">
+    <resultMap id="BaseResultMap" type="net.wanji.databus.po.CrossTurnDataRealTimePO">
         <result column="id" property="id"></result>
         <result column="turn_type" property="turnType"></result>
         <result column="in_dir" property="inDir"></result>
@@ -31,7 +31,7 @@
         stop_times, delay_time, sturation, vehhead_dist, vehhead_time, quality, batch_time, gmt_create, gmt_modified
     </sql>
 
-    <insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossTurnDataRealTimePO">
+    <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossTurnDataRealTimePO">
         insert into t_cross_turn_data_hist
         (<include refid="Base_Column_List"></include>)
         values

signal-datacenter-service/src/main/resources/mapper/CrossTurnDataRealTimeMapper.xml → wj-databus/src/main/resources/mapper/CrossTurnDataRealTimeMapper.xml

 <?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="net.wanji.datacenter.mapper.CrossTurnDataRealTimeMapper">
+<mapper namespace="net.wanji.databus.dao.mapper.CrossTurnDataRealTimeMapper">
 
-    <resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossTurnDataRealTimePO">
+    <resultMap id="BaseResultMap" type="net.wanji.databus.po.CrossTurnDataRealTimePO">
         <result column="id" property="id"></result>
         <result column="turn_type" property="turnType"></result>
         <result column="in_dir" property="inDir"></result>
@@ -31,7 +31,7 @@
         stop_times, delay_time, sturation, vehhead_dist, vehhead_time, quality, batch_time, gmt_create, gmt_modified
     </sql>
 
-    <insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossTurnDataRealTimePO">
+    <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossTurnDataRealTimePO">
         insert into t_cross_turn_data_realtime
         (<include refid="Base_Column_List"></include>)
         values