提供pc上传avss文件接口

Controller/TestApi.py

@@ -167,6 +167,8 @@ class testView(View):
             return self.getForeignWeather(request_dict, response)
         elif operation == 'unionpayback':  # 银联回调
             return self.unionpayback(request_dict, response)
+        elif operation == 'uploadAVSS':  # 银联回调
+            return self.uploadAVSS(request, response)
         else:
             return response.json(414)
 
@@ -1142,3 +1144,22 @@ class testView(View):
     def unionpayback(request_dict, response):
         logging.info('银联回调参数：{}'.format(request_dict))
         return response.json(0)
+
+    @staticmethod
+    def uploadAVSS(request, response):
+        file = request.FILES.get("file", None)
+        file_name = file.name
+        file_key = "pc/{}".format(file_name)
+        try:
+            s3 = AmazonS3Util(AWS_ACCESS_KEY_ID[1], AWS_SECRET_ACCESS_KEY[1], AWS_SES_ACCESS_REGION)
+            # 存储桶
+            bucket = "ansjerfilemanager"
+            s3.upload_file_obj(
+                bucket,
+                file_key,
+                file,
+                {"ContentType": file.content_type, "ACL": "public-read"},
+            )
+            return response.json(0)
+        except Exception as e:
+            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))