PRODUCT_FACTORY.js 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381
  1. const CMD = {}
  2. const video_product_controllers = require('../src/data_manager/Controllers/video_product_controllers');
  3. const filter_data_controllers = require('../src/data_manager/Controllers/filter_data_controllers');
  4. const get_fq_book_tab_controllers = require('../src/data_manager/Controllers/get_fq_book_tab_controllers');
  5. const video_applet_product_controllers = require('../src/data_manager/Controllers/video_applet_product_controllers');
  6. const redis_help = require('../src/use_redis');
  7. const axios = require('axios');
  8. const config = require('../etc/config.json');
  9. const HttpClient = require('../src/HttpClient');
  10. const helper = require('../src/helper');
  11. const tools = require('../tools');
  12. const time_count = 2000;
  13. const task_queue = []
  14. async function processTask(){
  15. try{
  16. let isPauseTask = await redis_help.getKeyValue("isPauseTask")
  17. if(isPauseTask=="true"){
  18. return
  19. }
  20. let isInsertTask = false
  21. let FilterConfig = await redis_help.getKeyValue("FilterConfig")
  22. FilterConfig = JSON.parse(FilterConfig)
  23. let result = await filter_data_controllers.getFilterDataByStatus({ status: 0 });
  24. if(result.success){
  25. let tg_platform_id = result.data.tg_platform_id
  26. //判断是否存在这本书
  27. if(tg_platform_id==1){
  28. let hy_book_result = await video_product_controllers.getProductData({ book_id: result.data.book_id });
  29. if(hy_book_result.success){
  30. result.data.words = hy_book_result.data.words
  31. result.data.genre = hy_book_result.data.genre
  32. result.data.book_id = hy_book_result.data.product_id
  33. result.data.book_name = hy_book_result.data.product_name
  34. }else{
  35. isInsertTask = true
  36. }
  37. }else if(tg_platform_id==2){ //番茄
  38. //获取番茄书库的书
  39. let fq_book_result = await get_fq_book_tab_controllers.getData({ book_id: result.data.book_id });
  40. if(fq_book_result.success){//如果番茄书库里有这本书
  41. result.data.genre = fq_book_result.data.info.genre
  42. result.data.book_id = fq_book_result.data.book_id
  43. result.data.book_name = fq_book_result.data.info.book_name
  44. result.data.words = fq_book_result.data.info.word_number
  45. //获取商品库的商品
  46. let product_result = await video_product_controllers.getProductData({ book_id: fq_book_result.data.book_id });
  47. //如果商品库没有这个商品
  48. if(!product_result.success){ //如果只是 get_fq_book 有, 书库里没有
  49. fq_book_result.data.tg_platform_id = result.data.tg_platform_id
  50. //如果是长篇短篇符合
  51. if(CMD.isGenre(FilterConfig,result.data.genre)){
  52. await CMD.insert_product(result.data)
  53. }
  54. }
  55. }else{
  56. isInsertTask = true
  57. }
  58. }
  59. if(!isInsertTask){
  60. await CMD.update_filter_data(FilterConfig,result.data)
  61. }else{
  62. await filter_data_controllers.updateFilterData({id:result.data.id},{status:1})
  63. task_queue.push({result:result})
  64. }
  65. }
  66. }catch(e){
  67. await filter_data_controllers.updateFilterData({id:result.data.id},{status:2})
  68. } finally{
  69. global.setTimeout(processTask, 500);
  70. }
  71. }
  72. async function processCreateTask(){
  73. try{
  74. if(task_queue.length>0){
  75. let task_queue_item = task_queue.pop()
  76. let FilterConfig = await redis_help.getKeyValue("FilterConfig")
  77. FilterConfig = JSON.parse(FilterConfig)
  78. let result = task_queue_item.result
  79. let tg_platform_id = result.data.tg_platform_id
  80. if(tg_platform_id==1){
  81. let hy_book_data = await require('./collect_hy_book').runTask(result.data)
  82. if(CMD.isGenre(FilterConfig,hy_book_data.genre)){
  83. await CMD.insert_product(hy_book_data)
  84. }
  85. result.data.words = hy_book_data.words
  86. result.data.genre = hy_book_data.genre
  87. result.data.book_id = hy_book_data.book_id
  88. result.data.book_name = hy_book_data.book_name
  89. }else if(tg_platform_id==2){
  90. let client = new HttpClient()
  91. let sid_tt = await tools.getFqSidtt()
  92. let response = await client.proxyRequest( helper.getFqRequestOpt(result.data.book_id,sid_tt))
  93. let obj = response['data']
  94. let book_name = obj['novel_data'].book_name
  95. let book_id = obj['novel_data'].book_id
  96. let genre = CMD.getFqGenre(obj['novel_data'].genre)
  97. let words = obj['novel_data'].word_number
  98. let fq_book_data = {book_name:book_name,book_id:book_id,genre:genre,words:words,info:JSON.stringify(obj['novel_data'])}
  99. let fq_book = {}
  100. fq_book.key = result.data.book_id
  101. // console.log("response:",obj,sid_tt)
  102. await CMD.add_fq_book(fq_book,fq_book_data)
  103. let product_result = await video_product_controllers.getProductData({ book_id: fq_book_data.book_id });
  104. if(!product_result.success){ //如果书库也没有
  105. fq_book.tg_platform_id = result.data.tg_platform_id
  106. if(CMD.isGenre(FilterConfig,fq_book_data.genre)){
  107. fq_book_data.tg_platform_id = result.data.tg_platform_id
  108. await CMD.insert_product(fq_book_data)
  109. }
  110. }
  111. result.data.words = words
  112. result.data.genre = fq_book_data.genre
  113. result.data.book_id = fq_book_data.book_id
  114. result.data.book_name = fq_book_data.book_name
  115. }
  116. await CMD.update_filter_data(FilterConfig,result.data)
  117. }
  118. }catch(e){
  119. filter_data_controllers.updateFilterData({id:result.data.id},{status:2})
  120. console.log("processCreateTask:",e)
  121. } finally{
  122. global.setTimeout(processCreateTask, time_count);
  123. }
  124. }
  125. CMD.init = async function(){
  126. redis_help.connect((results)=>{
  127. if(results){
  128. }
  129. })
  130. processTask();
  131. processCreateTask();
  132. }
  133. CMD.getFqGenre = function(genre){
  134. if(genre=="0"){
  135. return 1;
  136. }
  137. if(genre=="8"){
  138. return 3;
  139. }
  140. if(genre=="202"){
  141. return 202;
  142. }
  143. return 999;
  144. }
  145. CMD.getAppInfoByPlatformId = function(AppConfig,tg_platform_id){
  146. for (let index = 0; index < AppConfig.length; index++) {
  147. const element = AppConfig[index];
  148. if(element.tg_platform_id==tg_platform_id){
  149. return element
  150. }
  151. }
  152. return null
  153. }
  154. CMD.isBlackBook = function(all_black_books,book_id){
  155. if(all_black_books==null){
  156. return false
  157. }
  158. for (let index = 0; index < all_black_books.length; index++) {
  159. const black_book = all_black_books[index];
  160. if(black_book.product_id==book_id){
  161. return true
  162. }
  163. }
  164. return false
  165. }
  166. CMD.getMainInfoByAppid = function(MainConfig,app_id){
  167. let list = []
  168. for (let index = 0; index < MainConfig.length; index++) {
  169. const element = MainConfig[index];
  170. if(element.app_id==app_id){
  171. list.push(element)
  172. }
  173. }
  174. return list
  175. }
  176. CMD.isGenre = function(FilterConfig,genre){
  177. let is_need = false
  178. //判断长篇短篇是否是要的数据
  179. for (let index = 0; index < FilterConfig.genre.length; index++) {
  180. const element = FilterConfig.genre[index];
  181. if(genre==element){
  182. is_need = true
  183. break
  184. }
  185. }
  186. return is_need
  187. }
  188. function deepCopy3(obj) {
  189. return JSON.parse(JSON.stringify(obj));
  190. }
  191. CMD.update_filter_data = async function(FilterConfig,data) {
  192. if(CMD.isGenre(FilterConfig,data.genre)){
  193. try{
  194. await CMD.video_product_material(data)
  195. }catch(e){
  196. console.log("video_product_material error:",e)
  197. }
  198. await filter_data_controllers.updateFilterData({id:data.id},{status:1,book_id:data.book_id,book_name:data.book_name,genre:data.genre,words:data.words})
  199. //创建一个小程序
  200. let AppConfig = await redis_help.getKeyValue("AppConfig")
  201. AppConfig = JSON.parse(AppConfig)
  202. let AppInfo = CMD.getAppInfoByPlatformId(AppConfig,data.tg_platform_id)
  203. data.app_id = AppInfo.app_id
  204. let PlatformInfo = await redis_help.getKeyValue("PlatformConfig")
  205. PlatformInfo = JSON.parse(PlatformInfo)
  206. if(PlatformInfo==null){
  207. return console.error("平台配置错误:",data)
  208. }
  209. let MainConfig = await redis_help.getKeyValue("MainConfig")
  210. MainConfig = JSON.parse(MainConfig)
  211. let list = CMD.getMainInfoByAppid(MainConfig,data.app_id)
  212. if(list.length<0){
  213. return console.error("获取主体错误:",data)
  214. }
  215. let black_books = await redis_help.getKeyValue("all_black_books")
  216. if(black_books!=null){
  217. black_books = JSON.parse(black_books)
  218. }
  219. for (let index = 0; index < list.length; index++) {
  220. const main_info = list[index];
  221. data.main_id = main_info.id
  222. data.main_name = main_info.main_name
  223. if(main_info.tg_link_config==undefined||main_info.tg_link_config==null){
  224. console.error("主体配置推广链接错误:",main_info)
  225. }else{
  226. if(!CMD.isBlackBook(black_books,data.book_id)){
  227. //符合标准进行创建表
  228. const result = await video_applet_product_controllers.getAppletProductData({book_id:data.book_id,main_id:data.main_id})
  229. if(!result.success){
  230. //没有找到 可以创建
  231. await video_applet_product_controllers.createAppletProductData({
  232. book_platform:data.tg_platform_id,
  233. product_name:data.book_name,
  234. product_id:data.book_id,
  235. dy_small_program_start:"",
  236. dy_small_program_start_data:"",
  237. dy_small_applet_app_id:data.app_id,
  238. status:0,
  239. main_id:data.main_id,
  240. promotion_id:"",
  241. wait_status:0,
  242. })
  243. }
  244. }
  245. }
  246. }
  247. }else{
  248. await filter_data_controllers.updateFilterData({id:data.id},{status:2,book_id:data.book_id,book_name:data.book_name,genre:data.genre})
  249. }
  250. }
  251. CMD.video_product_material = async function(data){
  252. let url = config.isDebug?config.debug_supdate_config.host:config.release_supdate_config.host
  253. url = url+'/sapi/video_product_material/supdate';
  254. const formData = new FormData();
  255. formData.append('data',JSON.stringify({
  256. dy_id:data.video_id,
  257. dy_url:data.video_link,
  258. product_id:data.book_id,
  259. product_name:data.book_name,
  260. d_z_number:data.like_num,
  261. collect_number:data.kepp_num,
  262. comment_number: data.comment_num,
  263. forward_number: data.shared_num,
  264. book_platform: data.tg_platform_id,
  265. title: data.title,
  266. yun_fabu_time:data.publish_time
  267. }))
  268. return await axios.post(url, formData, {
  269. headers: {
  270. 'Content-Type': 'multipart/form-data'
  271. }
  272. })
  273. .then(response => {
  274. if(response.data.code===10000){
  275. console.log("插入任务表成功:", response.data);
  276. }else{
  277. console.log("插入任务表失败:", formData);
  278. }
  279. })
  280. .catch(error => {
  281. console.error("插入任务表失败:", error,formData);
  282. });
  283. }
  284. CMD.insert_product = async function(data){
  285. return await video_product_controllers.createProductData({
  286. book_platform:data.tg_platform_id,
  287. product_name:data.book_name,
  288. genre:data.genre,
  289. product_id:data.book_id,
  290. words:data.words
  291. })
  292. }
  293. CMD.add_fq_book = async function(data,response){
  294. let book_name = response.book_name
  295. let book_id = response.book_id
  296. let genre = response.genre
  297. let words = response.word_number
  298. data.genre = 0
  299. if(genre=="0"){
  300. data.genre = 1;
  301. }
  302. if(genre=="8"){
  303. data.genre = 3;
  304. }
  305. if(genre=="202"){
  306. data.genre = 202;
  307. }
  308. data.words = words
  309. data.book_name = book_name
  310. data.book_id = book_id
  311. let tab = {
  312. book_key:data.key,
  313. book_id:data.book_id,
  314. info:JSON.stringify(response)
  315. }
  316. if(tab.book_id==undefined){
  317. throw "tab.book_id==undefined"
  318. }
  319. // console.log("tab:",tab,data)
  320. return await get_fq_book_tab_controllers.createData( tab)
  321. }
  322. CMD.build_check_url = function(data){
  323. let url = 'https://clipvideoup.s6kuwan.com/sapi/check/get_check_url';
  324. const formData = new FormData();
  325. formData.append('platform_id', data.book_platform);
  326. formData.append('cp_spread_id', data.promotion_id);
  327. // console.log("formData:", formData);
  328. axios.post(url, formData, {
  329. headers: {
  330. 'Content-Type': 'multipart/form-data'
  331. }
  332. })
  333. .then(response => {
  334. if(response.data.code==10000){
  335. CMD.update_video_applet_product({promotion_id:data.promotion_id,
  336. product_id:data.product_id,check_url:response.data.content.check_url
  337. })
  338. }
  339. })
  340. .catch(error => {
  341. console.error('create_link was an error!', error);
  342. });
  343. }
  344. CMD.update_video_applet_product = function(data){
  345. sql_task_help.update('UPDATE video_applet_product SET status = ?, wait_status = ? , check_url = ? WHERE promotion_id = ? and product_id = ?',
  346. [1,1,data.check_url,data.promotion_id,data.product_id],
  347. ()=>{
  348. console.log("update_video_applet_product:更新成功!")
  349. })
  350. }
  351. CMD.init()