DataCollectionDevice/apis/alarm_limit_from_database.py

from abstract_api import AbstractApi
from apis.operate_mysql import OperateMysql


class Alarm_limit_from_database(AbstractApi):

    def operation(self, request):
        operate_mysql = OperateMysql()
        device_name = request['device']
        if device_name == "all":
            sql = "SELECT id,io_point_name,alarm_low_limit,alarm_up_limit FROM data_point_tbl WHERE alarm_low_limit IS NOT Null AND alarm_up_limit IS NOT Null;"
            res = operate_mysql.execute_sql(sql)
        elif isinstance(device_name, list) and device_name:
            device_name = ','.join(["'%s'" % item for item in device_name])
            sql = "SELECT id,io_point_name,alarm_low_limit,alarm_up_limit FROM data_point_tbl WHERE alarm_low_limit IS NOT Null AND alarm_up_limit IS NOT Null AND device_name= ( %s );" % device_name
            res = operate_mysql.execute_sql(sql)
        else:
            res = "传入空列表或参数错误"
        return res