feat(api): 修改创建商品接口

api.py

@@ -181,7 +181,7 @@ def get_schema_request(req: GetSchemaRequest):
 @sync_router.post(
 @sync_router.post(
     "/create_goods",
     "/create_goods",
     status_code=status.HTTP_200_OK,
     status_code=status.HTTP_200_OK,
-    summary="获取类目参数",
+    summary="创建商品",
 )
 )
 def create_goods_request(req: CreateGoodsRequest):
 def create_goods_request(req: CreateGoodsRequest):
     return execute_create_goods(req.headers, req.proxy_url, req.data)
     return execute_create_goods(req.headers, req.proxy_url, req.data)

service/doudian_service.py

 import json
 import json
 import time
 import time
+from json import JSONDecoder
 from urllib.parse import urlencode
 from urllib.parse import urlencode
 
 
 import execjs
 import execjs
@@ -77,9 +78,14 @@ def create_goods(headers: dict, proxy_url: str, data):
     a_bogus = generate_a_bogus(params, data, ua)
     a_bogus = generate_a_bogus(params, data, ua)
     params['a_bogus'] = a_bogus
     params['a_bogus'] = a_bogus
     proxies = check_proxy(proxy_url)
     proxies = check_proxy(proxy_url)
-    response = doudian_request("POST", url, params=params, proxies=proxies, json=data, headers=headers)
-    return response
-
+    try:
+        response = requests.post(url, params=params, proxies=proxies, json=data, headers=headers)
+        if response.status_code == 200:
+            return response.json()
+        else:
+            raise Exception(f'请求失败 --> {response.text}')
+    except Exception:
+        raise Exception(f'请求失败 --> {response.text}')
 
 
 def create_global_promotion(params:str | dict,data: dict,headers: dict, proxy_url: str):
 def create_global_promotion(params:str | dict,data: dict,headers: dict, proxy_url: str):
     """创建全域推广"""
     """创建全域推广"""

task_worker.py

@@ -217,15 +217,9 @@ def execute_get_schema(headers: dict, proxy_url: str, category_id: str):
 def execute_create_goods(headers: dict, proxy_url: str, data):
 def execute_create_goods(headers: dict, proxy_url: str, data):
     """获取类目参数"""
     """获取类目参数"""
     try:
     try:
-        response = create_goods(headers, proxy_url, data)
-        result = response.get('data', {})
-        logger.success(f'创建商品成功-->{str(result)[:200]}·······{str(result)[-200:]}')
-        return {
-            'code': 200,
-            'msg': 'success',
-            'data': result,
-            'error_type': ''
-        }
+        result = create_goods(headers, proxy_url, data)
+        logger.success(f'创建商品成功-->{result}')
+        return result
     except AppError as e:
     except AppError as e:
         logger.error(f'创建商品失败-->{e.msg}')
         logger.error(f'创建商品失败-->{e.msg}')
         return {
         return {
@@ -238,7 +232,7 @@ def execute_create_goods(headers: dict, proxy_url: str, data):
         logger.error(f'创建商品错误-->{e}')
         logger.error(f'创建商品错误-->{e}')
         return {
         return {
             'code': 500,
             'code': 500,
-            'msg': f'创建商品错误:{str(e)[:1000]}',
+            'msg': f'创建商品错误:{str(e):}',
             'data': None,
             'data': None,
             'error_type': 'InternalError'
             'error_type': 'InternalError'
         }
         }