Const.scala

package com.hikcreate.data.constant

import com.hikcreate.data.model.TableKey
import com.hikcreate.data.util.Config

object Const {

  Config.load("conf.properties")

  val bootstrap: String = Config.getString("kafka.bootstrap.servers")
  val zkKafka: String = Config.getString("kafka.zookerper.servers")

  val applicationTopic: Array[String] = Config.getString("application.kafka.topic").split(",")
  val basicsInfoTopic:Array[String] = Config.getString("basicsInfo.kafka.topic").split(",")
  val hiveGroupId: String = Config.getString("hive.group.id")
  val igniteGroupId: String = Config.getString("ignite.group.id")
  val basicsGroupId:String = Config.getString("basics.group.id")

  val hivePoolName = "hive"
  val hiveDriver: String = Config.getString("hive.driver")
  val hiveUrl: String = Config.getString("hive.url")
  val hiveUsername: String = Config.getString("hive.username")
  val hivePassword: String = Config.getString("hive.password")
  val areaCodeAndAddressUrl:String=Config.getString("areaCodeAndAddress.Url")
  val unKnownTable:String = Config.getString("hive.unknown.table")

  val warnTypes:  Array[String] = Config.getString("warnTypes").split(",")

  val tableMap = Map(
    //链路管理
    TableKey(Some("0x1001"),None)->Config.getString("hive.UP_CONNECT_REQ.table"),//主链路登录
    TableKey(Some("0x1003"),None)->Config.getString("hive.UP_DISCONNECT_REQ.table"),//主链路注销
    TableKey(Some("0x1005"),None)->Config.getString("hive.UP_LINKTEST_REQ.table"),//主链路链路保持
    TableKey(Some("0x1007"),None)->Config.getString("hive.UP_DISCONNECT_INFORM.table"),//主链路断开
    TableKey(Some("0x9001"),None)->Config.getString("hive.DOWN_CONNECT.table"),//从链路连接成功
    TableKey(Some("0x9006"),None)->Config.getString("hive.DOWN_LINKTEST.table"),//从链路连接保持应答
    //车辆动态信息交换类
    TableKey(Some("0x1200"),Some("0x1201"))->Config.getString("hive.UP_EXG_MSG_REGISTER.table"),//上传车辆注册信息消息
    TableKey(Some("0x1200"),Some("0x1202"))->Config.getString("hive.UP_EXG_MSG_REAL_LOCATION.table"),//实时上传车辆定位消息
    TableKey(Some("0x1200"),Some("0x1203"))->Config.getString("hive.KAFKA_UP_EXG_MSG_HISTORY_LOCATION.table"),////车辆定位信息补报
    TableKey(Some("0x1200"),Some("0x120B"))->Config.getString("hive.UP_EXG_MSG_TAKE_EWAYBILL_ACK.table"),//上报车辆电子运单
    //车辆报警信息交互业务类
    TableKey(Some("0x1400"),Some("0x1402"))->Config.getString("hive.UP_WARN_MSG_ADPT_INFO.table"),//上报报警信息消息
    TableKey(Some("0x1400"),Some("0x1401"))->Config.getString("hive.KAFKA_UP_WARN_MSG_URGE_TODO.table"),//报警督办请求信息
    TableKey(Some("0x9400"),Some("0x9401"))->Config.getString("hive.KAFKA_DOWN_WARN_MSG_URGE_TODO.table"),//报警督办应答消息
    //车辆监管业务类
    //TableKey(Some("0x1500"),Some("0x1504"))->Config.getString("hive.UP_CTRL_MSG_TAKE_TRAVEL.table"),//上报车辆行驶记录
    //车辆静态信息交换业务类
    TableKey(Some("0x1600"),Some("0x1601"))->Config.getString("hive.UP_BASE_MSG_VEHICLE_ADDED.table"),//补报车辆静态信息
    //智能视频动态信息交换消息类
    TableKey(Some("0x1D00"),Some("0x1D01"))->Config.getString("hive.UP_PREVENTION_EXG_MSG_DEVICE_PARAM.table"),//视频报警设备参数查询请求
    TableKey(Some("0x1D00"),Some("0x1d02"))->Config.getString("hive.UP_PREVENTION_EXG_MSG_REPORT_DRIVER.table"),//定时上传驾驶员身份识别信息
    TableKey(Some("0x1C00"),Some("0x1c02"))->Config.getString("hive.UP_PREVENTION_MSG_FILE_COMPLETE.table"),//智能视频报警附件上传结果上报
    //基础信息类
    TableKey(None,Some("baseIntoPlatformInfo"))->Config.getString("hive.KAFKA_base_into_platform_info.table"),//接入平台
    TableKey(None,Some("baseIntoEnterpriseInfo"))->Config.getString("hive.KAFKA_base_into_enterprise_info.table"),//企业信息
    TableKey(None,Some("baseIntoVehicleInfo"))->Config.getString("hive.KAFKA_base_into_vehicle_info.table"),//接入车辆
    TableKey(None,Some("baseDataDisplayConfig"))->Config.getString("hive.KAFKA_base_data_display_config.table"),//数据展示配置
    TableKey(None,Some("baseWarningType"))->Config.getString("hive.KAFKA_base_warning_type.table")//报警类型配置
  )
}