package mobvista.dmp.datasource.iqiyi

/**
  * @package: mobvista.dmp.datasource.iqiyi
  * @author: wangjf
  * @date: 2020/5/9
  * @time: 2:15 下午
  * @email: jinfeng.wang@mobvista.com
  * @phone: 152-1062-7698
  */
object Constant {

  case class IQiYiEntity(device_id: String, device_type: String, platform: String, package_name: String, country: String)

  val iqiyi_sql: String =
    s"""
       |SELECT * FROM dwh.etl_iqiyi_install_daily_all WHERE dt = '@date' AND
       |  package_name != '0000000000' AND package_name != 'com.nonepkg.nonepkg'
    """.stripMargin

  val iqiyi_lahuo_sql: String =
    s"""
       |SELECT device_ids FROM dwh.iqiyi_lahuo_result_daily_all WHERE dt = '@date' AND hour BETWEEN '08' AND '15'
    """.stripMargin

  def buildPart(partSize: Int): Seq[String] = {
    var list: scala.List[String] = scala.List()
    for (i <- 0 until partSize) {
      list = list.::(s"CRC32(device_id) % $partSize = $i")
    }
    list = list.reverse
    list
  }

  def buildPartLaHuo(partSize: Int): Seq[String] = {
    var list: scala.List[String] = scala.List()
    for (i <- 0 until partSize) {
      list = list.::(s"CRC32(device_ids) % $partSize = $i")
    }
    list = list.reverse
    list
  }
}