DataCollectionDevice/apis/max_from_database.py

from abstract_api import AbstractApi
from apis.operate_mysql import OperateMysql

class Max_from_database(AbstractApi):
    
    def operation(self, request):
        operate_mysql = OperateMysql()
        basic_data = request['basic_data']
        serial_number = basic_data.replace('c', '')
        res1 = operate_mysql.return_result(request, serial_number)

        sql1 = "SELECT %s, CAST(times AS CHAR) as times FROM %s WHERE times > \'%s\' and times < \'%s\' ORDER BY %s desc limit 1;" % (basic_data, res1['table_name'], res1['begin_time'], res1['end_time'], basic_data)
        res2 = operate_mysql.execute_sql(sql1)
        if len(res2) != 0:
            res = {request['keys'][0]: res2[0][basic_data], request['keys'][1]: res2[0]['times']}
            return res
        else:
            return None