qm_update_works.js 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839
  1. const video_product_controllers = require('./src/data_manager/Controllers/video_product_controllers');
  2. const config = require("./etc/config.json")
  3. const redis_help = require('./src/use_redis');
  4. const CMD = {}
  5. async function processTask(){
  6. try{
  7. const result = await video_product_controllers.getProductDataByBookPlatformAndWordsZero({book_platform:config.platform_qmmf})
  8. console.log("result:",result)
  9. if(result.success){
  10. const product_item = result.data;
  11. let qm_book_data = await require('./src/api/qm_mf/qm_mf_search_book').search_id_new(product_item.product_id)
  12. let words = 1
  13. if(qm_book_data==null){
  14. }else{
  15. words = qm_book_data.words
  16. }
  17. await video_product_controllers.updateData({id:product_item.id},{
  18. words:words
  19. })
  20. }
  21. }catch(e){
  22. console.error("processTask error:",e)
  23. } finally{
  24. global.setTimeout(processTask, 100);
  25. console.log("finish all!!!!!")
  26. }
  27. }
  28. CMD.init = async function(){
  29. redis_help.connect((results)=>{
  30. if(results){
  31. processTask();
  32. }
  33. })
  34. }
  35. CMD.init()