添加上传图片和视频

service/upload_image_and_video.py

@@ -8,7 +8,8 @@ from loguru import logger
 from requests_toolbelt.multipart.encoder import MultipartEncoder
 from requests_toolbelt.multipart.encoder import MultipartEncoder
 from config import settings
 from config import settings
 from service.doudian_request import doudian_request
 from service.doudian_request import doudian_request
-from service.upload_video import upload_video_with_multithreading, download_video
+from service.upload_video import upload_video_with_multithreading
+from shop import callback_task
 from utils.common import check_proxy
 from utils.common import check_proxy
 
 
 def get_local_path(item_id, url):
 def get_local_path(item_id, url):
@@ -69,7 +70,6 @@ def upload_image_by_bytes(cookies, headers, proxies, image_path_list):
             for fh in file_handles:
             for fh in file_handles:
                 fh.close()
                 fh.close()
     # 返回结果字典
     # 返回结果字典
-    logger.info(result_dict)
     return result_dict
     return result_dict
 
 
 
 
@@ -131,10 +131,11 @@ async def uploadImageAndVideo(task: dict = None):
         "skus": sku_image_dict,
         "skus": sku_image_dict,
         "images": image_dict,
         "images": image_dict,
         "description": description_dict,
         "description": description_dict,
-        "video_list": video_dict
+        "video_list": video_dict,
+        "type": 2
     }
     }
     logger.info(json.dumps(callback_data))
     logger.info(json.dumps(callback_data))
-    # await callback_task(callback_data)
+    await callback_task(callback_data)
 
 
 async def run_in_executor(func, *args):
 async def run_in_executor(func, *args):
     """在异步环境中运行同步函数"""
     """在异步环境中运行同步函数"""