2022.04.15 修复任务线程比创建任务更快BUG

-GBK

@@ -53,7 +53,7 @@ class Api(ApiTemplate):
             download_process = multiprocessing.Process(target=self.download, args=(task_guid,self.para))
             download_process = multiprocessing.Process(target=self.download, args=(task_guid,self.para))
             download_process.start()
             download_process.start()
 
 
-            task.task_pid = download_process.pid
+            Task.query.filter_by(guid=task_guid).update({"task_pid": download_process.pid})
             db.session.commit()
             db.session.commit()
 
 
             res["data"] = "下载任务已提交!"
             res["data"] = "下载任务已提交!"

@@ -100,7 +100,8 @@ class Api(ApiTemplate):
 
 
             entry_thread = multiprocessing.Process(target=self.entry,args=(self.para.get("task_guid"),))
             entry_thread = multiprocessing.Process(target=self.entry,args=(self.para.get("task_guid"),))
             entry_thread.start()
             entry_thread.start()
-            task.task_pid=entry_thread.pid
+
+            Task.query.filter_by(guid=task_guid).update({"task_pid": entry_thread.pid})
             db.session.commit()
             db.session.commit()
 
 
             res["result"] = True
             res["result"] = True

@@ -52,7 +52,8 @@ class Api(ApiTemplate):
 
 
             refresh_process = multiprocessing.Process(target=self.table_refresh,args=(database,task_guid,self.para.get("creator")))
             refresh_process = multiprocessing.Process(target=self.table_refresh,args=(database,task_guid,self.para.get("creator")))
             refresh_process.start()
             refresh_process.start()
-            task.task_pid = refresh_process.pid
+
+            Task.query.filter_by(guid=task_guid).update({"task_pid":refresh_process.pid})
             db.session.commit()
             db.session.commit()
 
 
             res["msg"] = "数据库更新已提交！"
             res["msg"] = "数据库更新已提交！"

@@ -92,7 +92,7 @@ class Api(ApiTemplate):
             vacuate_process = multiprocessing.Process(target=self.task,args=(table,task_guid))
             vacuate_process = multiprocessing.Process(target=self.task,args=(table,task_guid))
             vacuate_process.start()
             vacuate_process.start()
 
 
-            task.task_pid = vacuate_process.pid
+            Task.query.filter_by(guid=task_guid).update({"task_pid": vacuate_process.pid})
             db.session.commit()
             db.session.commit()
 
 
             res["msg"] = "矢量金字塔构建已提交！"
             res["msg"] = "矢量金字塔构建已提交！"

@@ -97,7 +97,8 @@ class Api(ApiTemplate):
 
 
             vacuate_process = multiprocessing.Process(target=self.task,args=(table,task_guid,grids))
             vacuate_process = multiprocessing.Process(target=self.task,args=(table,task_guid,grids))
             vacuate_process.start()
             vacuate_process.start()
-            task.task_pid = vacuate_process.pid
+
+            Task.query.filter_by(guid=task_guid).update({"task_pid": vacuate_process.pid})
             db.session.commit()
             db.session.commit()
 
 
             res["msg"] = "矢量金字塔构建已提交！"
             res["msg"] = "矢量金字塔构建已提交！"

@@ -34,6 +34,6 @@ def compile(des):
                 shutil.copy(pyc_file,des_pyc_file)
                 shutil.copy(pyc_file,des_pyc_file)
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
-    des="H:\DMapManagerPublish"
+    des="H:\DMapManager"
     compile(des)
     compile(des)