deviceMonitor/dao/machinery_dao.py

from common.mysql_db import MysqlUtil
from datetime import datetime


def insert_machinery(param):
    print(param)
    sql = "insert into dv_machinery_data " \
          "(machinery_code, machinery_name, run_data, parser_data, create_time, update_time)" \
          " values (%s,%s,%s,%s,%s,%s)"
    mysql = MysqlUtil()
    result = mysql.insert(sql, param)
    return result


def query_machinery_data():
    mysql = MysqlUtil()
    sql = "select * from dv_machinery_data"
    result = mysql.query_all(sql)
    return result


def query_machinery():
    mysql = MysqlUtil()
    sql = "select dm.machinery_name, dm.machinery_code, dmp.wirte_code from dv_machinery dm inner join dv_machinery_param dmp on dm.machinery_id = dmp.machinery_id"
    result = mysql.query_all(sql)
    return result


if __name__ == "__main__":
    today = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    param = ['009', 'test', '010304438F51ECE241', '9008.00', today, today]
    print(insert_machinery(param))