diff options
| author | wanglihui <[email protected]> | 2021-10-25 14:47:22 +0800 |
|---|---|---|
| committer | wanglihui <[email protected]> | 2021-10-25 14:47:22 +0800 |
| commit | 264afdaa3e3d3401155a34d8510c12a191c72ad9 (patch) | |
| tree | ecef4eb42b416442985243e794eb19dc98a77128 /ip-learning-spark | |
| parent | 423e9d9b44a477c8ab89e6dff2d309052a620c94 (diff) | |
增加radius是否活跃判断条件。tsg-v2
Diffstat (limited to 'ip-learning-spark')
| -rw-r--r-- | ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala b/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala index 1a3bad3..9e0bf44 100644 --- a/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala +++ b/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala @@ -140,6 +140,8 @@ object BaseClickhouseData { | AND common_recv_time < ${timeLimit._1} | AND common_subscriber_id != '' | AND radius_framed_ip != '' + | AND radius_packet_type = 4 + | AND radius_acct_status_type = 1 """.stripMargin val sql = s""" @@ -161,6 +163,9 @@ object BaseClickhouseData { | AND common_recv_time < ${timeLimit._1} | AND common_subscriber_id != '' | AND radius_framed_ip != '' + | AND radius_packet_type = 4 + | AND radius_acct_status_type = 1 + | """.stripMargin val sql = s""" |