Browse Source

style: 去除无用todo

许家凯 4 years ago
parent
commit
9e7e8de179
18 changed files with 21 additions and 20 deletions
  1. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/chance/creditor_info_add_other.scala
  2. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/bankruptcy_open_case.scala
  3. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_annual_report_out_guarantee.scala
  4. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_bid_list.scala
  5. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_env_punishment.scala
  6. 3 3
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_announcement.scala
  7. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_mortgage.scala
  8. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_publicity.scala
  9. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_transfer.scala
  10. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_mortgage_info.scala
  11. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_public_announcement2_list.scala
  12. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_punishment_info.scala
  13. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_punishment_info_creditchina.scala
  14. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_send_announcement_list.scala
  15. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_stock_announcement.scala
  16. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_zxr_restrict.scala
  17. 2 0
      src/main/scala/com/winhc/bigdata/spark/jobs/inc_company_equity_info.scala
  18. 1 2
      src/main/scala/com/winhc/bigdata/spark/jobs/increment/inc_phx_cid_ads.scala

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/chance/creditor_info_add_other.scala

@@ -315,7 +315,7 @@ object creditor_info_add_other {
     //    val ds = "20200721"
     //    val ds = "20200721"
     val spark = SparkUtils.InitEnv("add_cols_other", map)
     val spark = SparkUtils.InitEnv("add_cols_other", map)
 
 
-    val table = "xjk_tmp_ads_cre_info_test_v2"
+    val table = "xjk_tmp_ads_cre_info_test_v3"
 
 
     val v = add_cols_other(spark, project)
     val v = add_cols_other(spark, project)
     v.prefix(ds, table)
     v.prefix(ds, table)

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/bankruptcy_open_case.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/5
  * @Date 2020/8/5
- * @Description TODO
+ * @Description
  */
  */
 //破产公告
 //破产公告
 case class bankruptcy_open_case() extends CompanyDynamicHandle {
 case class bankruptcy_open_case() extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_annual_report_out_guarantee.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/13
  * @Date 2020/8/13
- * @Description TODO
+ * @Description
  */
  */
 //年报-对外担保
 //年报-对外担保
 case class company_annual_report_out_guarantee()extends CompanyDynamicHandle {
 case class company_annual_report_out_guarantee()extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_bid_list.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/7/28
  * @Date 2020/7/28
- * @Description TODO
+ * @Description
  */
  */
 case class company_bid_list() extends CompanyDynamicHandle {
 case class company_bid_list() extends CompanyDynamicHandle {
   /**
   /**

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_env_punishment.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/7/27
  * @Date 2020/7/27
- * @Description TODO
+ * @Description
  */
  */
 //环保处罚
 //环保处罚
 case class company_env_punishment()extends CompanyDynamicHandle {
 case class company_env_punishment()extends CompanyDynamicHandle {

+ 3 - 3
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_announcement.scala

@@ -5,10 +5,10 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/4
  * @Date 2020/8/4
- * @Description TODO
+ * @Description
  */
  */
 //购地信息
 //购地信息
-case class company_land_announcement()extends CompanyDynamicHandle {
+case class company_land_announcement() extends CompanyDynamicHandle {
   /**
   /**
    * 信息描述
    * 信息描述
    *
    *
@@ -33,7 +33,7 @@ case class company_land_announcement()extends CompanyDynamicHandle {
    * @param new_map
    * @param new_map
    * @return
    * @return
    */
    */
-//  override def get_change_time(new_map: Map[String, String]): String = new_map("biz_date")
+  //  override def get_change_time(new_map: Map[String, String]): String = new_map("biz_date")
 
 
   /**
   /**
    * 风险等级
    * 风险等级

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_mortgage.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/4
  * @Date 2020/8/4
- * @Description TODO
+ * @Description
  */
  */
 //土地抵押
 //土地抵押
 case class company_land_mortgage() extends CompanyDynamicHandle {
 case class company_land_mortgage() extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_publicity.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/4
  * @Date 2020/8/4
- * @Description TODO
+ * @Description
  */
  */
 //地块公示
 //地块公示
 case class company_land_publicity() extends CompanyDynamicHandle {
 case class company_land_publicity() extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_land_transfer.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/4
  * @Date 2020/8/4
- * @Description TODO
+ * @Description
  */
  */
 //土地转让
 //土地转让
 case class company_land_transfer() extends CompanyDynamicHandle {
 case class company_land_transfer() extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_mortgage_info.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/4
  * @Date 2020/8/4
- * @Description TODO
+ * @Description
  */
  */
 //动产抵押
 //动产抵押
 case class company_mortgage_info() extends CompanyDynamicHandle {
 case class company_mortgage_info() extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_public_announcement2_list.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/6
  * @Date 2020/8/6
- * @Description TODO
+ * @Description
  */
  */
 //公示催告
 //公示催告
 case class company_public_announcement2_list()extends CompanyDynamicHandle {
 case class company_public_announcement2_list()extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_punishment_info.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/4
  * @Date 2020/8/4
- * @Description TODO
+ * @Description
  */
  */
 //行政处罚
 //行政处罚
 case class company_punishment_info() extends CompanyDynamicHandle {
 case class company_punishment_info() extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_punishment_info_creditchina.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/4
  * @Date 2020/8/4
- * @Description TODO
+ * @Description
  */
  */
 //行政处罚-信用中国
 //行政处罚-信用中国
 case class company_punishment_info_creditchina() extends CompanyDynamicHandle {
 case class company_punishment_info_creditchina() extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_send_announcement_list.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/12
  * @Date 2020/8/12
- * @Description TODO
+ * @Description
  */
  */
 //送达公告
 //送达公告
 case class company_send_announcement_list()extends CompanyDynamicHandle {
 case class company_send_announcement_list()extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_stock_announcement.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/11
  * @Date 2020/8/11
- * @Description TODO
+ * @Description
  */
  */
 //企业公告
 //企业公告
 case class company_stock_announcement()extends CompanyDynamicHandle {
 case class company_stock_announcement()extends CompanyDynamicHandle {

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/dynamic/tables/company_zxr_restrict.scala

@@ -5,7 +5,7 @@ import com.winhc.bigdata.spark.jobs.dynamic.CompanyDynamicHandle
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/8/14
  * @Date 2020/8/14
- * @Description TODO
+ * @Description
  */
  */
 //限制消费令
 //限制消费令
 case class company_zxr_restrict()extends CompanyDynamicHandle {
 case class company_zxr_restrict()extends CompanyDynamicHandle {

+ 2 - 0
src/main/scala/com/winhc/bigdata/spark/jobs/inc_company_equity_info.scala

@@ -172,6 +172,8 @@ object inc_company_equity_info {
         , "CONCAT_WS('_',cid,main_id)").syn()
         , "CONCAT_WS('_',cid,main_id)").syn()
       import com.winhc.bigdata.spark.implicits.DataFrame2HBaseHelper._
       import com.winhc.bigdata.spark.implicits.DataFrame2HBaseHelper._
 
 
+      //todo 没有写出摘要
+
       val outFields = getColumns("winhc_eci_dev.inc_ads_company_equity_info").map(_.toUpperCase)
       val outFields = getColumns("winhc_eci_dev.inc_ads_company_equity_info").map(_.toUpperCase)
       sql(
       sql(
         s"""
         s"""

+ 1 - 2
src/main/scala/com/winhc/bigdata/spark/jobs/increment/inc_phx_cid_ads.scala

@@ -6,13 +6,12 @@ import com.winhc.bigdata.spark.utils.{BaseUtil, LoggingUtils, SparkUtils}
 import org.apache.spark.sql.SparkSession
 import org.apache.spark.sql.SparkSession
 import org.apache.spark.sql.functions.col
 import org.apache.spark.sql.functions.col
 
 
-import scala.annotation.meta.getter
 import scala.collection.mutable
 import scala.collection.mutable
 
 
 /**
 /**
  * @Author yyn
  * @Author yyn
  * @Date 2020/7/15
  * @Date 2020/7/15
- * @Description TODO
+ * @Description
  */
  */
 object inc_phx_cid_ads extends LoggingUtils {
 object inc_phx_cid_ads extends LoggingUtils {
   var config = mutable.Map(
   var config = mutable.Map(