智盟项目
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

svc_tik_tok_task.go 17 KiB

1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
1 vuosi sitten
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355
  1. package svc
  2. import (
  3. "applet/app/cfg"
  4. offical "applet/app/db/official"
  5. md2 "applet/app/es/md"
  6. md3 "applet/app/md"
  7. "applet/app/task/md"
  8. "applet/app/utils"
  9. "applet/app/utils/cache"
  10. "code.fnuoos.com/go_rely_warehouse/zyos_go_es.git/es"
  11. "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/tik_tok"
  12. zhios_third_party_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils"
  13. "encoding/json"
  14. "fmt"
  15. "github.com/jinzhu/copier"
  16. "github.com/syyongx/php2go"
  17. "github.com/tidwall/gjson"
  18. "strings"
  19. "time"
  20. )
  21. func TikTokTask() {
  22. //doc, _ := es.FirstDoc(md2.ZhiosTikTokTaskEsIndex, "tik_tok_task_tt99fdef4006c36ff001")
  23. //fmt.Println(string(doc.Source))
  24. //return
  25. //es.CreateIndexIfNotExists(md2.ZhiosTikTokTaskEsIndex, md2.ZhiosTikTokTaskEsMapping)
  26. //es.CreateIndexIfNotExists(md2.ZhiosTikTokTaskDetailEsIndex, md2.ZhiosTikTokTaskDetailEsMapping)
  27. appidList := offical.MasterListCfgGetOneData("0", "tik_tok_task_appid")
  28. split := strings.Split(appidList, ";")
  29. for _, v := range split {
  30. endTime := time.Now().Unix()
  31. startTime := endTime - 7*86400
  32. if endTime > time.Now().Unix() {
  33. endTime = time.Now().Unix()
  34. }
  35. param := map[string]interface{}{
  36. "appid": v,
  37. "create_start_time": startTime,
  38. "create_end_time": endTime,
  39. }
  40. api, _ := tik_tok.TaskApi("query_app_task_id/", TikTokTaskToken(), zhios_third_party_utils.SerializeStr(param))
  41. taskIds := gjson.Get(api, "data.task_ids").String()
  42. fmt.Println(taskIds)
  43. if taskIds == "" || taskIds == "[]" {
  44. fmt.Println(endTime)
  45. offical.MasterListCfgSave("0", "tik_tok_task_appid_time_"+v, utils.Int64ToStr(endTime))
  46. continue
  47. }
  48. CommAddTask("tik_tok_task_"+v, taskIds)
  49. var tmp = make([]int64, 0)
  50. json.Unmarshal([]byte(taskIds), &tmp)
  51. GetTaskDetail(v, tmp)
  52. fmt.Println(endTime)
  53. offical.MasterListCfgSave("0", "tik_tok_task_appid_time_"+v, utils.Int64ToStr(endTime))
  54. }
  55. }
  56. func GetTaskDetail(appId string, tmp []int64) {
  57. data := md3.KujiangData
  58. var kujiang []md.KuJiang
  59. json.Unmarshal([]byte(data), &kujiang)
  60. kujiangMap := make(map[string]md.KuJiang)
  61. for _, v := range kujiang {
  62. kujiangMap[utils.IntToStr(v.BookId)] = v
  63. }
  64. xinghes := map[string]string{
  65. "7373480427329159203": "https://pan.baidu.com/s/1-OYIB1RmTXl3SeynP3Dy7Q?pwd=d2tx",
  66. "7372912752035119144": "https://pan.baidu.com/s/1ICIGA5SBCXNwugJM3IxaoA?pwd=eae0",
  67. "7372349272928403482": "https://pan.baidu.com/s/1zms9c0CG07-2kZVFKxYzVw?pwd=fie2",
  68. "7372080132082778152": "https://pan.baidu.com/s/125VKEkXRa3FkgTdR7gqhvw?pwd=wrbx",
  69. "7372009394361401344": "https://pan.baidu.com/s/1acDqOnZEfv6IIFEAUl5ffQ?pwd=1nyb",
  70. "7372013980895985701": "https://pan.baidu.com/s/1azZYwHx1jWLjtz8gc2leFA?pwd=a53c",
  71. "7371376162850750501": "https://pan.baidu.com/s/14vjCx7AKi0gIsljs-0XGuw?pwd=ib54",
  72. "7371371539645661211": "https://pan.baidu.com/s/1Xy0x6qlQDjR7LIjkX01nGA?pwd=oik9",
  73. "7371366982576308287": "https://pan.baidu.com/s/1VjwcogPOHuy25te9zEBERw?pwd=29sq",
  74. "7371001858434793526": "https://pan.baidu.com/s/1lcXNSZ9z6be83v4UehkM-w?pwd=oy0r",
  75. "7371001571926081590": "https://pan.baidu.com/s/1ETttvHJd2_fDNuJRuCaKsQ?pwd=dv28",
  76. "7370904753900945460": "https://pan.baidu.com/s/1PVM9Jpaf93V_--0d1UW9Dg?pwd=bogh",
  77. "7370911902962221119": "https://pan.baidu.com/s/1DQAvDk8zE0glH81TRvQhfg?pwd=ye4u",
  78. "7370857345389297699": "https://pan.baidu.com/s/1MhJYTpXqUgPnOrJ2mvVClQ?pwd=mo78",
  79. "7369875298587836455": "https://pan.baidu.com/s/1P5mGA0QKiRcHHgE1Bzz1cg?s4pn",
  80. "7369875429492113419": "https: //pan.baidu.com/s/1ZHldm5KDXka_5arInJiDQw?pwd=avqw",
  81. "7369888148781809698": "https://pan.baidu.com/s/1ErZRBvvMOQlaZcyuDHfB_g?pwd=lo2y",
  82. "7369813564837642281": "https://pan.baidu.com/s/1-Ks0ArP_8mKIsNgDAqI7PA?pwd=d86a",
  83. "7369751707867283506": "https://pan.baidu.com/s/14qOLJey1bWEA0pqFF6xhgw?pwd=5cmc",
  84. "7369503459801956371": "https://pan.baidu.com/s/1vyXKrJeuvx5x4w-acbVa6A?pwd=qugd",
  85. "7369391591624163364": "https://pan.baidu.com/s/1eM2tbZ8yj6zIDqovSO49_A?pwd=aqg2",
  86. "7369392341066498111": "https://pan.baidu.com/s/12t76uMp_3sn8hdMDoXwppg?pwd=tpfe",
  87. "7369148051795017740": "https://pan.baidu.com/s/13_S-8fE21nqSofjgx_rWKw?pwd=uns8",
  88. "7369059651461283894": "https://pan.baidu.com/s/1Fqbpz35M8dwxX8tFhpyQhQ?pwd=uexq",
  89. "7369037096285175808": "https://pan.baidu.com/s/1_Y2LnJeAG1-QJUCNegiKuA?pwd=jcjv",
  90. "7368762632674803751": "https://pan.baidu.com/s/1bjiyXlw_sMQ9YR4YALu3ZQ?pwd=aic8",
  91. "7368679769661079564": "https://pan.baidu.com/s/1Rrqm6C_VCP9pTLIiytJFew?pwd=0w3y",
  92. "7368678622070489139": "https://pan.baidu.com/s/1ImxFZxOihIxmpKs7FQNC-A?pwd=6dgz",
  93. "7368653781052981283": "https://pan.baidu.com/s/15jtQvEYxQujqY3C_zeE_fA?pwd=mcy5",
  94. "7368329261691961371": "https://pan.baidu.com/s/171ZRDKRRU3aP7ZMBDy0vsQ?pwd=sipq",
  95. "7368324603678031882": "https://pan.baidu.com/s/1B5Qh3vs3Ivfk8rTLCc1tng?pwd=emws",
  96. "7367710375317520399": "https://pan.baidu.com/s/1aEaDUhSM-4VDTxn40wXm3A?pwd=6e8b",
  97. "7367316323904372772": "https://pan.baidu.com/s/1kf58ZCgI0BgCLQapMfrTbQ?pwd=cceg",
  98. "7366906746314555404": "https://pan.baidu.com/s/1MNfbPba3Nt2pTnHTfBUEBA?pwd=ew3v",
  99. "7366486018851209235": "https://pan.baidu.com/s/1QWF63ao80TT3BAMV0-QpRA?pwd=rcs5",
  100. "7366151010714157097": "https://pan.baidu.com/s/1055EkwtBxPM0Sw6L5gOCFw?pwd=1sq9",
  101. "7366102746245726248": "https://pan.baidu.com/s/1WzXSrkemz0Hm0DTNcmTpxA?pwd=y2j0",
  102. "7365004815451062312": "https://pan.baidu.com/s/1q2XYO3GraSEvdX2F3JcX4Q?pwd=glby",
  103. "7364352540936290358": "https://pan.baidu.com/s/11JDyHl97egRjDKxnH9D7rQ?pwd=mr0l",
  104. "7363525995279745035": "https://pan.baidu.com/s/1te89FR6rULnXV7g5BaRIPA?pwd=hx47",
  105. "7363532419464429619": "https://pan.baidu.com/s/1JBXBddSdLeZn-BOFYCjQrA?pwd=y1iu",
  106. "7363505120711098368": "https://pan.baidu.com/s/1iAP5OSU46CFz0vyOYGOBCA?pwd=ft2t",
  107. "7363505153716125731": "https://pan.baidu.com/s/1Lpuc4iUBWxndb1xTcRoicQ?pwd=390v",
  108. "7363505437439918121": "https://pan.baidu.com/s/1Y_RnixE05gaMptBrhC0DQw?pwd=n3ni",
  109. "7363157598629068819": "https://pan.baidu.com/s/1NPtnl5EBK7jRRgk7kSStPg?pwd=86p6",
  110. "7363157659111211027": "https://pan.baidu.com/s/1PO8ulobc-54is1QBikJSEQ?pwd=gfek",
  111. "7362021099053383714": "https://pan.baidu.com/s/19mqfaAt5zovNO1sb0e-bxw?pwd=qae9",
  112. "7361723753094610980": "https://pan.baidu.com/s/1oybfSKC4FUWGw81DH6wqXw?pwd=a83p",
  113. "7361713709670006810": "https://pan.baidu.com/s/1r0EAT_q6DKFatnbwXZfeTw?pwd=7h74",
  114. "7361659856501129279": "https://pan.baidu.com/s/1XtOabN5ZGsxG9x_CjF2Aig?pwd=ztet",
  115. "7361314021947015222": "https://pan.baidu.com/s/1Wq3RyPsSUw1PBXqPD7nHCA?pwd=hxip",
  116. "7360937011936510006": "https://pan.baidu.com/s/1WlN5HLmcaADy0jGdiCaGFQ?pwd=tiwb",
  117. "7359423244304269350": "https://pan.baidu.com/s/1_c4cXt25ky2yDOXm2kmL5A?pwd=bcrq",
  118. "7359058838047162368": "https://pan.baidu.com/s/1HkBnlRR27JBKsQheTJxmcQ?pwd=3kcd",
  119. "7358681447030390784": "https://pan.baidu.com/s/1oWMuF5itpF77lls_vSGqJA?pwd=p3wc",
  120. "7358322670871576616": "https://pan.baidu.com/s/13RET87iAbgZlj-jn5mUwUg?pwd=y9rd",
  121. "7357194974695391268": "https://pan.baidu.com/s/1cBU9PIXW99Y5W1XhvdPIpA?pwd=uxc6",
  122. "7356840659325583414": "https://pan.baidu.com/s/1znMbDDAnIRQ7PwtiznOvTQ?pwd=9nj7",
  123. "7356392523553636364": "https://pan.baidu.com/s/17YWBPOVbIi1QR-uKAAJEvQ?pwd=pph1",
  124. "7355357328834658319": "https://pan.baidu.com/s/1uoDFjFm9iWt5eXGCYwx0Sg?pwd=9i8p",
  125. "7353386971026309183": "https://pan.baidu.com/s/1LCgvkFblrE43e4JtxSOR4Q?pwd=svb5",
  126. "7350898126372323369": "https://pan.baidu.com/s/1P6E4vYl-2x0s_qw1X5oviQ?pwd=84xz",
  127. "7350859162219184139": "https://pan.baidu.com/s/1mUHucK0x5af8G40hJbLzqw?pwd=0dh1",
  128. "7349282971213512754": "https://pan.baidu.com/s/18QgGyqjzW7aImhQ8a2_SJQ?pwd=aswx",
  129. "7348970835950043147": "https://pan.baidu.com/s/1JEL9kvkrvzcZUKwexlhPhw?pwd=gadt",
  130. "7348684759972724745": "https://pan.baidu.com/s/1sqnsG74rqE8vKVz4-mibgw?pwd=q7us",
  131. "7348649376765460531": "https://pan.baidu.com/s/18AIW_J7XHGZFbEsa4zbEZw?pwd=akgy",
  132. "7348320058776502322": "https://pan.baidu.com/s/1RImOhdsbwT-d58U8x9Cl7g?pwd=5oy1",
  133. "7348220904138227746": "https://pan.baidu.com/s/1WL1ZCM5w9opVJRHq2_tQkg?pwd=08gs",
  134. "7347939532555304972": "https://pan.baidu.com/s/1A3vmJaRPU9YFmNZje9ttDw?pwd=2vjp",
  135. "7347576656296443941": "https://pan.baidu.com/s/106MDSCSM7BCTx_1kex65gA?pwd=t1gm",
  136. "7346064108011257897": "https://pan.baidu.com/s/1NY7JuB-2KUlvtbKZqI7vew?pwd=kpt4",
  137. "7345229086283055156": "https://pan.baidu.com/s/1mkkF_bhOh3E7sZf6ymIv0g?pwd=zl3m",
  138. "7344970667663589410": "https://pan.baidu.com/s/17e5bb0dGQ183zHWkO49cmg?pwd=l193",
  139. "7343744932248600616": "https://pan.baidu.com/s/1vL1g1aGhgXMtNEah4TQFxw?pwd=ub0r",
  140. "7342692698744193063": "https://pan.baidu.com/s/1MOaSBkuHGzvv9n1GPc-B3Q?pwd=69fg",
  141. "7340706698497212455": "https://pan.baidu.com/s/1vB8aG2U3kserxWsm3bR1Zg?pwd=qszf",
  142. "7340019974860914715": "https://pan.baidu.com/s/1bykE9LVcNCePutJ4Rmz14A?pwd=dvrx",
  143. "7338982451538133026": "https://pan.baidu.com/s/10GqBT2oBHTdIrtLvm7C3Mg?pwd=203x",
  144. "7336393071648587816": "https://pan.baidu.com/s/1Zl0zxZg3dcTuGsge8pD-SA?pwd=este",
  145. "7335313319047315456": "https://pan.baidu.com/s/1QQZQlgy-WN9hXKjSe59smg?pwd=klno",
  146. "7334158528300482571": "https://pan.baidu.com/s/1DuWh9nZwec3uTAoqwLzIEA?pwd=qs0v",
  147. "7333417334876454949": "https://pan.baidu.com/s/1l5FvB35F9YPnwllSpYPvSA?pwd=ogdy",
  148. "7333416896286507044": "https://pan.baidu.com/s/1S2E0DXe1w6z5kU5r9fGGoQ?pwd=k0br",
  149. "7332303743809011739": "https://pan.baidu.com/s/1S4I4smzV8I3-jytmua1kLg?pwd=2zhv",
  150. "7331643707597864997": "https://pan.baidu.com/s/1WWMY8bWnNLSxCaD0x_Gv0Q?pwd=scm5",
  151. "7331637776204480575": "https://pan.baidu.com/s/1PAYJUrYhZ71XivTZFSxw5Q?pwd=v1n7",
  152. "7330834016368623657": "https://pan.baidu.com/s/1yB46HJtIjjffc0w8RmeRTQ?pwd=x1v3",
  153. "7330529933564919823": "https://pan.baidu.com/s/1PzKUtgetU8bVTILFYxSrNQ?pwd=ul4a",
  154. "7330518079224512550": "https://pan.baidu.com/s/1I1o9UV89oYCVmzJc5bCe1g?pwd=5nxe",
  155. "7327911477510209548": "https://pan.baidu.com/s/1ebMtvlMV2UCCvTOx7znFsA?pwd=d00o",
  156. "7326049857058177024": "https://pan.baidu.com/s/1WtKwzdeiPQz0AjKzieU_6w?pwd=prkh",
  157. "7324972262531153959": "https://pan.baidu.com/s/1qZCfNogUvYWWlkJ225qNQQ?pwd=l0ui",
  158. "7324518583126753314": "https://pan.baidu.com/s/1yf7X6iI6bPYcJNLKTdd8QQ?pwd=kyvc",
  159. "7324525415568015411": "https://pan.baidu.com/s/1ZxrZMbySTtMX_5F0eW24Aw?pwd=2hht",
  160. "7324518767126429734": "https://pan.baidu.com/s/1J7CJYI76-I-9APIq1pzE5A?pwd=ai6t",
  161. "7324518642941476905": "https://pan.baidu.com/s/1t3tcaGhCjsTwRSTXQJ4_-g?pwd=s9d9",
  162. "7324518215852228644": "https://pan.baidu.com/s/1w7qG9kSfpZD1hCohnU8vUQ?pwd=0a3w",
  163. "7324510965024751650": "https://pan.baidu.com/s/1bzzIqBftk030n8ZRddnnRA?pwd=6k6e",
  164. "7320876050387353611": "https://pan.baidu.com/s/1Y6oe-upHqA72ivDp4MWBUA?pwd=04th",
  165. "7318971545959170058": "https://pan.baidu.com/s/1jEOgXAR7e5Oqd3KZ2e1zyg?pwd=wvb9",
  166. "7313727507914686476": "https://pan.baidu.com/s/1awg3uiLk5t1EJPGiUXhxyQ?pwd=ppwu",
  167. "7313751212422201379": "https://pan.baidu.com/s/1awg3uiLk5t1EJPGiUXhxyQ?pwd=ppwu",
  168. "7312337908660437004": "https://pan.baidu.com/s/1Q-6nsaWTmj3UWCdSdOQErw?pwd=4sl3",
  169. "7312292128947257383": "https://pan.baidu.com/s/1D71HmPOWkAeBmVk9ujU8dQ?pwd=ta3n",
  170. "7312294620745056267": "https://pan.baidu.com/s/1CI0fC50UWsxKLcQ4AIlUhQ?pwd=pi51",
  171. "7312295241607790643": "https://pan.baidu.com/s/1-8w4R1ypihnHw-djYQHXcg?pwd=p5h8",
  172. "7312292122370031670": "https://pan.baidu.com/s/1pZM-FzOQQrZjhgQ_Kn1nAQ?pwd=ryu0",
  173. "7312291614532599843": "https://pan.baidu.com/s/16794mteTYOn6nzu8k1gIBg?pwd=xdsg",
  174. "7312007303753957395": "https://pan.baidu.com/s/1hEyBrPTm0Rtkl1mP-1myxQ?pwd=di9v",
  175. }
  176. for _, v := range tmp {
  177. time.Sleep(time.Microsecond * 1000)
  178. param := map[string]interface{}{
  179. "appid": appId,
  180. "query_params_type": "1",
  181. "query_params_content": utils.Int64ToStr(v),
  182. "page_no": "1",
  183. "page_size": "10",
  184. }
  185. api, _ := tik_tok.TaskApi("query_task_info/", TikTokTaskToken(), zhios_third_party_utils.SerializeStr(param))
  186. detail := gjson.Get(api, "data.tasks").String()
  187. if detail == "" {
  188. fmt.Println("失败", v)
  189. continue
  190. }
  191. var tmpDetail = make([]md.TikTokTaskDetail, 0)
  192. json.Unmarshal([]byte(detail), &tmpDetail)
  193. for _, v1 := range tmpDetail {
  194. var tmpIn md.TikTokTaskDetailSecond
  195. err := copier.Copy(&tmpIn, &v1)
  196. fmt.Println(err)
  197. tmpIn.OrientedTalentRelList = utils.SerializeStr(v1.OrientedTalentRelList)
  198. tmpIn.ReferMaCaptures = utils.SerializeStr(v1.ReferMaCaptures)
  199. tmpIn.TaskTags = utils.SerializeStr(v1.TaskTags)
  200. tmpIn.ReferVideoCaptures = utils.SerializeStr(v1.ReferVideoCaptures)
  201. videoTmpStr := "bookId="
  202. if tmpIn.Appid == "tt38e94e54a7d70c4601" {
  203. videoTmpStr = "cid="
  204. } else if strings.Contains(tmpIn.StartPage, "novelid=") {
  205. videoTmpStr = "novelid="
  206. } else if strings.Contains(tmpIn.StartPage, "book_id=") {
  207. videoTmpStr = "book_id="
  208. } else if strings.Contains(tmpIn.StartPage, "video_id=") {
  209. videoTmpStr = "video_id="
  210. }
  211. ex := strings.Split(tmpIn.StartPage, videoTmpStr)
  212. if len(ex) > 1 {
  213. exSecond := strings.Split(ex[1], "&")
  214. tmpIn.VideoId = exSecond[0]
  215. }
  216. if tmpIn.VideoId == "" {
  217. fmt.Println("失败", tmpIn)
  218. continue
  219. }
  220. if tmpIn.Status != 2 {
  221. tmpIn.TaskEndTime = int(time.Now().Unix() - 10)
  222. }
  223. for _, v2 := range md.TaskAddList {
  224. if tmpIn.Appid == v2["name"] { //
  225. tmp2 := md.Cinema5bmsData{
  226. Description: "",
  227. ImageUrl: tmpIn.TaskIcon,
  228. Material: "",
  229. OnlineTime: time.Unix(int64(tmpIn.TaskStartTime), 0).Format("2006-01-02 15:04:05"),
  230. Type: v2["second_type"],
  231. Title: tmpIn.TaskName,
  232. UpdateTime: int(time.Now().Unix()),
  233. Time: tmpIn.TaskStartTime,
  234. Appid: v2["name"],
  235. Id: utils.StrToInt(tmpIn.VideoId),
  236. IsClose: 0,
  237. IsHot: 0,
  238. FirstCate: v2["type"],
  239. SecondCate: "",
  240. Platform: "",
  241. }
  242. if v2["second_type"] == "xinghe" {
  243. tmp2.Material = xinghes[utils.Int64ToStr(tmpIn.TaskId)]
  244. }
  245. uniqueId := php2go.Md5(tmp2.Appid + "_" + tmp2.Type + "_" + tmp2.FirstCate + "_" + utils.IntToStr(tmp2.Id))
  246. if tmp2.Appid == "ttbed9c86421e54c8501" {
  247. doc, _ := es.FirstDoc(md2.ZhiosNewVideo, uniqueId)
  248. if tmpIn.TaskEndTime > int(time.Now().Unix()) {
  249. tmp2.Platform = "tikTok"
  250. }
  251. if doc != nil && strings.Contains(gjson.Get(string(doc.Source), "platform").String(), "kuaishou") {
  252. if tmpIn.TaskEndTime > int(time.Now().Unix()) {
  253. tmp2.Platform = "tikTok,kuaishou"
  254. } else {
  255. tmp2.Platform = "kuaishou"
  256. }
  257. }
  258. jiang, ok := kujiangMap[tmpIn.VideoId]
  259. if ok {
  260. tmp2.Material = jiang.WebDiskUrl
  261. }
  262. } else {
  263. tmp2.Platform = "tikTok"
  264. if tmpIn.TaskEndTime < int(time.Now().Unix()) {
  265. tmp2.IsClose = 1
  266. }
  267. }
  268. if tmp2.Platform == "" {
  269. tmp2.IsClose = 1
  270. }
  271. fmt.Println(uniqueId)
  272. tmp2.Key = uniqueId
  273. commAddNew(uniqueId, tmp2)
  274. }
  275. }
  276. CommAddTaskDetail(utils.Int64ToStr(tmpIn.TaskId), tmpIn)
  277. }
  278. }
  279. }
  280. func CommAddTask(uniqueId string, taskIds string) {
  281. doc, _ := es.FirstDoc(md2.ZhiosTikTokTaskEsIndex, uniqueId)
  282. if doc == nil {
  283. var tmpData = map[string]string{
  284. "task_ids": taskIds,
  285. }
  286. createDocRet, err := es.CreateDoc(md2.ZhiosTikTokTaskEsIndex, uniqueId, tmpData)
  287. if err != nil {
  288. return
  289. }
  290. fmt.Printf("CreateDoc ==> %+v \n\n", createDocRet)
  291. } else {
  292. source := doc.Source
  293. tmpData := make(map[string]string)
  294. json.Unmarshal(source, &tmpData)
  295. var tmpOld = make([]int64, 0)
  296. json.Unmarshal([]byte(tmpData["task_ids"]), &tmpOld)
  297. var tmp = make([]int64, 0)
  298. json.Unmarshal([]byte(taskIds), &tmp)
  299. tmp = utils.MergeArr(tmpOld, tmp)
  300. tmp = utils.UniqueArr(tmp)
  301. tmpData = map[string]string{
  302. "task_ids": utils.SerializeStr(tmp),
  303. }
  304. createDocRet, err := es.UpdateDoc(md2.ZhiosTikTokTaskEsIndex, uniqueId, tmpData)
  305. if err != nil {
  306. return
  307. }
  308. fmt.Printf("CreateDoc ==> %+v \n\n", createDocRet)
  309. }
  310. }
  311. func CommAddTaskDetail(uniqueId string, tmp md.TikTokTaskDetailSecond) {
  312. doc, _ := es.FirstDoc(md2.ZhiosTikTokTaskDetailEsIndex, uniqueId)
  313. if doc == nil {
  314. createDocRet, err := es.CreateDoc(md2.ZhiosTikTokTaskDetailEsIndex, uniqueId, tmp)
  315. if err != nil {
  316. return
  317. }
  318. fmt.Printf("CreateDoc ==> %+v \n\n", createDocRet)
  319. } else {
  320. createDocRet, err := es.UpdateDoc(md2.ZhiosTikTokTaskDetailEsIndex, uniqueId, tmp)
  321. if err != nil {
  322. return
  323. }
  324. fmt.Printf("CreateDoc ==> %+v \n\n", createDocRet)
  325. }
  326. }
  327. func TikTokTaskToken() string {
  328. tikTokOpenAppkey := offical.MasterListCfgGetOneData("0", "tik_tok_task_open_appkey")
  329. tikTokOpenAppSecret := offical.MasterListCfgGetOneData("0", "tik_tok_task_open_app_secret")
  330. args := map[string]string{
  331. "appkey": tikTokOpenAppkey,
  332. "appSecret": tikTokOpenAppSecret,
  333. }
  334. key := "tikTok_client_" + args["appkey"]
  335. tokeStr, err := cache.GetString(key)
  336. if cfg.Prd == false {
  337. return tokeStr
  338. }
  339. if tokeStr == "" || err != nil {
  340. token := tik_tok.GetClientToken(args)
  341. if token["tik_tok_acc_token"] != "" {
  342. tokeStr = token["tik_tok_acc_token"]
  343. cache.SetEx(key, token["tik_tok_acc_token"], utils.StrToInt(token["expires_in"]))
  344. }
  345. }
  346. return tokeStr
  347. }