Commit 07e95e9d authored by wanli's avatar wanli

feat(): 更新数据库迁移脚本

parent efdcd111
'''
Author: your name
Date: 2021-07-15 09:33:39
LastEditTime: 2021-07-22 10:27:05
LastEditTime: 2021-07-22 10:35:53
LastEditors: Please set LastEditors
Description: In User Settings Edit
FilePath: \evm-store\tools\build_out\controllers\device.py
......@@ -34,7 +34,6 @@ class DeviceResource(object):
if not user:
return False, ResponseCode.USER_NOT_EXISTS
logger.warn(params)
filters = [DeviceModel.is_delete==False, DeviceModel.create_by==user.id]
if params.get("type"): filters.append(DeviceModel.type==params.get("type"))
if params.get("name"): filters.append(DeviceModel.name==params.get("name"))
......
'''
Author: your name
Date: 2021-07-19 14:29:33
LastEditTime: 2021-07-22 10:01:22
LastEditTime: 2021-07-22 12:41:29
LastEditors: Please set LastEditors
Description: In User Settings Edit
FilePath: \evm-store\tools\build_out\views\api.py
......@@ -30,8 +30,14 @@ from application.signal_manager import signalManager
from models import MyModel, MyModel2
from models.app import AppModel
from models.annex import AnnexModel
from models.monitorSystem import MonitorSystemModel
from models.login import LoginModel
from models.device import DeviceModel
from models.package import PackageModel
from models.monitorEvm import MonitorEvmModel
from models.monitorLvgl import MonitorLvglModel
from models.monitorImage import MonitorImageModel
from models.monitorWatch import MonitorWatchModel
from models.monitorSystem import MonitorSystemModel
from models.app import postAppSchema, deleteAppSchema, getListAppSchema, getListAppsSchema, getAppSchema
from webcreator.log import logger
from webcreator.utils.ccode import convert_string
......@@ -102,9 +108,13 @@ class BuildAppResource(Resource):
def get(self):
try:
# res = db.session.query(AppModel).filter(AppModel.id>1000).update({ 'uuid': uuid.uuid4().hex })
# logger.info(res)
result = db.session.query(AnnexModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
logger.info(item.uuid)
db.session.flush()
db.session.commit()
result = db.session.query(AppModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
......@@ -112,15 +122,56 @@ class BuildAppResource(Resource):
db.session.flush()
db.session.commit()
# result = db.session.query(PackageModel).all()
# print(result)
# for item in result:
# item.uuid = uuid.uuid1().hex
# if item.source == None:
# item.source = 0
# logger.info(item.uuid)
# db.session.flush()
# db.session.commit()
result = db.session.query(LoginModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
logger.info(item.uuid)
db.session.flush()
db.session.commit()
result = db.session.query(DeviceModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
logger.info(item.uuid)
db.session.flush()
db.session.commit()
result = db.session.query(PackageModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
if item.source == None:
item.source = 0
logger.info(item.uuid)
db.session.flush()
db.session.commit()
result = db.session.query(MonitorEvmModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
logger.info(item.uuid)
db.session.flush()
db.session.commit()
result = db.session.query(MonitorLvglModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
logger.info(item.uuid)
db.session.flush()
db.session.commit()
result = db.session.query(MonitorImageModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
logger.info(item.uuid)
db.session.flush()
db.session.commit()
result = db.session.query(MonitorWatchModel).all()
for item in result:
item.uuid = uuid.uuid1().hex
logger.info(item.uuid)
db.session.flush()
db.session.commit()
# result_proxy = conn.execute("select id, host, path, protocol, create_at from monitor_request")
# result = result_proxy.fetchall()
......@@ -130,6 +181,7 @@ class BuildAppResource(Resource):
if not res:
continue
res.is_delete = 0
res.uuid = uuid.uuid1().hex
res.host = item.host
res.path = item.path
res.protocol = item.protocol
......@@ -139,9 +191,6 @@ class BuildAppResource(Resource):
db.session.flush()
db.session.commit()
# result_proxy = conn.execute("select id, uuid, app_name, app_path, app_version, app_info, create_at, create_by, remarks from evm_store_app_logs")
# result = result_proxy.fetchall()
result = db.session.query(MyModel).filter().all()
for item in result:
# print(item[3])
......@@ -165,7 +214,6 @@ class BuildAppResource(Resource):
logger.info(res)
print(item)
db.session.commit()
return response_result(ResponseCode.HTTP_SUCCESS)
except:
traceback.print_exc()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment