Scala 强大的精简语法（示例）

//==================================================mainfunc=======================================================
import java.sql.DriverManager
import model.ConfigModel
import tool.{FileDescription, TaoBaoCategory}
import scala.collection.mutable
import scala.collection.mutable.ListBuffer
import scala.concurrent.{Await, Future}
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.duration.Duration
import scala.util.Try
import scala.xml.XML
import org.json4s._
import org.json4s.native.JsonMethods._
import org.jsoup.Jsoup
import org.jsoup.nodes.Document
import scala.util.{Failure, Success}
def categoryGet(): Unit = {
    var listId = mutable.Map[String, String]()  //用来存目录名称与目录 id
    Try(Jsoup.connect("https://www.taobao.com/").get()) match {
      case Failure(e) =>   //case 模式匹配失败
        println(e.getMessage)
      case Success(doc) => //case 模式匹配成功
        listId = parseDoc(doc)
    }
    System.setProperty("Scala.concurrent.context.maxThreads", "4") //设置并发线程数
    val listBuffer = new ListBuffer[Future[(String,String)]]()
    for ((k,v) <- listId) {
      listBuffer.append(TaoBaoCategory.ReadCategory(k,v))  //所有的并发对象存入 listBuffer
    }
    val f = Future.sequence(listBuffer)
    val result = Await.result(f,Duration.Inf)  //阻塞主线程等待所有 Future 完成，result 将是每个 future 返回(String,String) 的列表
    for ((name,jsondata) <- result) {
      val  jsonObj = parse(jsondata)
      val jsonParse = parse(jsondata).values.asInstanceOf[Map[String,Any]]
      for ((k1,v1) <- jsonParse) {
        val v2 = v1.asInstanceOf[Map[String,Any]].get("value").get.asInstanceOf[Map[String,Any]].get("list").get.asInstanceOf[List[Map[String,Any]]] //获取 list，也就是最后一级目录
        v2.foreach {
          case m: Map[String,Any] => {
            val nameitem = if (!m.get("name").isEmpty) m.get("name").get else Some("")
            val link = if (!m.get("link").isEmpty) m.get("link").get else Some("")
           // println(s"${name} : ${k1}: ${nameitem}: ${link}")
            val str = s"insert into tmitemcatalog(categoryid,firstname,secondname,secondnameurl,status) value('${k1}','${name}','${nameitem}','${link}','1')"
            println(str)
            insertData(str)
          }
        }
      }
    }
  }
    //提取 Map(name->id),只需几行代码
    def parseDoc(doc:Document): mutable.Map[String, String] = {
    val map = scala.collection.mutable.Map[String,String]()
   (doc.select("a[data-cid=\"1\"]").toArray().foreach(x => {val d = XML.loadString(x.toString);map += (d.text -> d.attribute("data-dataid").get.toString())}))
    map //返回
  }

//===========================================TaoBaoCategory============================================================
import scala.concurrent.{Future, Promise}
import scala.io.Source
object TaoBaoCategory {
    //ConfigModel.taoBaoCagetoryUrlGet = "https://tce.alicdn.com/api/data.htm?ids=" 淘宝接口
        def ReadCategory(name: String,id:String,url: String = ConfigModel.taoBaoCagetoryUrlGet): Future[(String,String)] = {
            val p = Promise[(String,String)]  //声明 Promise，使 future 操作更强,更敏捷
            val fileContent = Source.fromURL(url + id,"utf-8").mkString
            p.success((name,fileContent))
            p.future
        }
        //隐式转换如：ReadCategory(1000)，1000 被隐式转成 String 了
        implicit def convertIntToString(arg: Int) = arg.toString
        //隐式转换如：ReadCategory(true)
        implicit def convertBoolToString(arg: Boolean) = if(arg) "true" else "false"
        implicit def convertLongToString(arg: Long) = arg.toString
            //隐式转换如：ReadCategory(3.1415)
        implicit def convertFloatToString(arg: Float) = arg.toString
}

libraryDependencies += "org.scala-lang.modules" %% "scala-xml" % "1.0.4"

libraryDependencies += "org.jsoup" % "jsoup" % "1.8.1"

libraryDependencies += "net.liftweb" %% "lift-json" % "2.6"

libraryDependencies += "org.json4s" % "json4s-native_2.10" % "3.2.4"

libraryDependencies += "mysql" % "mysql-connector-java" % "5.1.4