Kaynağa Gözat

pc端软件安装包上传下载查询删除操作1

lhq 4 yıl önce
ebeveyn
işleme
5b65fa1e3d
1 değiştirilmiş dosya ile 29 ekleme ve 9 silme
  1. 29 9
      Controller/PcInfo.py

+ 29 - 9
Controller/PcInfo.py

@@ -43,6 +43,8 @@ class PcInfo(View):
 
             if operation == 'query':
                 return self.query(request_dict, response)
+            elif operation == 'queryall':
+                return self.queryall(request_dict, response)
             elif operation == 'addandupload':   # 上传到服务器
                 return self.addandupload(request_dict, response, request)
             elif operation == 'download':   # 服务器下载
@@ -82,12 +84,12 @@ class PcInfo(View):
                 return response.json(174)
             try:
                 # 安装包上传到服务器本地
-                # file_path = 'static/pc/' + pc_name + '/' + bundle_version + '/' + pc_version + '/' + pc_test
                 file_path = 'static/pc/' + pc_name + '/' + bundle_version + '_' + pc_version + '_' + pc_test
                 if not os.path.exists(file_path):
                     os.makedirs(os.path.join(BASE_DIR, file_path))
                 file_path = file_path + '/' + str(file_name)
                 upload_path = os.path.join(BASE_DIR, file_path)
+                print('upload_path:', upload_path)
                 with open(upload_path, 'wb+') as destination:
                     for chunk in file_name.chunks():
                         destination.write(chunk)
@@ -135,6 +137,29 @@ class PcInfo(View):
         else:
             return response.json(173)
 
+    def queryall(self, request_dict, response):
+        token = request_dict.get('token', None)
+        tko = TokenObject(token)
+        response.lang = tko.lang
+        if tko.code != 0:
+            return response.json(tko.code)
+        userID = tko.userID
+        if not userID:
+            return response.json(104)
+        page = int(request_dict.get('page', None))
+        line = int(request_dict.get('line', None))
+        if page is None or line is None:
+            return response.json(444, 'page,line')
+        queryset = Pc_Info.objects.all()
+        if queryset.exists():
+            count = queryset.count()
+            res = queryset[(page - 1) * line:page * line]
+            send_json = CommonService.qs_to_dict(res)
+            send_json['count'] = count
+            return response.json(0, send_json)
+        else:
+            return response.json(173)
+
     def download(self, request_dict, response):
         pc_name = request_dict.get('pc_name', None)
         bundle_version = request_dict.get('bundle_version', None)
@@ -184,16 +209,11 @@ class PcInfo(View):
         userID = tko.userID
         if not userID:
             return response.json(104)
-        pc_name = request_dict.get('pc_name', None)
-        bundle_version = request_dict.get('bundle_version', None)
-        pc_version = request_dict.get('pc_version', None)
-        pc_test = request_dict.get('pc_test', None)
-        param_flag = CommonService.get_param_flag(
-            data=[pc_name, bundle_version, pc_version, pc_test])
+        id = request_dict.get('id', None)
+        param_flag = CommonService.get_param_flag(data=[id])
         if param_flag is not True:
             return response.json(444)
-        file = Pc_Info.objects.filter(pc_name=pc_name, bundle_version=bundle_version, pc_version=pc_version,
-                                      pc_test=pc_test)
+        file = Pc_Info.objects.filter(id=id)
         if not file.exists():
             return response.json(173)
         try: