update sleep 120s

src/main/scala/mobvista/dmp/datasource/rtdmp/lazada/ProcessRTJob.scala

@@ -52,16 +52,16 @@ class ProcessRTJob extends CommonSparkJob with Serializable {
       Logic.writeAudienceInfo("lazada", Logic.getAudienceMap(mutable.HashSet(package_name)))
 
       if (map.contains(package_name)) {
-        val uploadArray = new JSONArray()
+        val updateArray = new JSONArray()
         val jsonObject = new JSONObject()
         jsonObject.put("id", map(package_name))
         jsonObject.put("s3_path", s"$output/${package_name}/gaid/")
         jsonObject.put("status", 1)
         jsonObject.put("audience_data_status", 1)
-        uploadArray.add(jsonObject)
-        ServerUtil.upload(uploadArray)
+        updateArray.add(jsonObject)
+        ServerUtil.update(updateArray)
       } else {
-        val updateArray = new JSONArray()
+        val uploadArray = new JSONArray()
         val jsonObject = new JSONObject()
         jsonObject.put("s3_path", s"$output/${package_name}/gaid/")
         jsonObject.put("status", 1)
@@ -74,8 +74,8 @@ class ProcessRTJob extends CommonSparkJob with Serializable {
         jsonObject.put("audience_gender", 3)
         jsonObject.put("audience_count", 1)
         jsonObject.put("is_sync_dmpserver", 1)
-        updateArray.add(jsonObject)
-        ServerUtil.update(updateArray)
+        uploadArray.add(jsonObject)
+        ServerUtil.upload(uploadArray)
       }
     } finally {
       if (sc != null) {