jk_bigdata_gateway/001_h511/imageCapture/getconf.py

import datetime
import json
import pymysql
import os
import sys
import time
import requests
import base64
import configparser
from sanic import Sanic
from sanic.response import text, json
from sanic_cors import CORS, cross_origin
from sanic import response
from mysqlDataBase import MysqldbOperational
from configobj import ConfigObj

app = Sanic(__name__)
CORS(app)

@app.route('/marinePlatform/v1/devices/frameExtractionSetting', methods=['POST'])
async def capture_getconf(request):
    result = updata_conf(request.json)
    return response.text(result)


def update_sql_splicing(tablename, attrs_dict, cond_dict):
    """更新数据
        args：
            tablename  ：表名字
            attrs_dict  ：更改属性键值对字典
            cond_dict  ：更新条件字典

        example：
            params = {"name" : "caixinglong", "age" : "38"}
            cond_dict = {"name" : "liuqiao", "age" : "18"}
            mydb.update(table, params, cond_dict)
    """
    attrs_list = []
    consql = ' '
    for y in attrs_dict:
        if not isinstance(attrs_dict[y], str):
            attrs_dict[y] = str(attrs_dict[y])
    for x in cond_dict:
        if not isinstance(cond_dict[x], str):
            cond_dict[x] = str(cond_dict[x])
    for tmpkey, tmpvalue in attrs_dict.items():
        attrs_list.append("`" + tmpkey + "`" + "=" + "\'" + tmpvalue + "\'")
    attrs_sql = ",".join(attrs_list)
    #print("attrs_sql:", attrs_sql)
    if cond_dict != '':
        for k, v in cond_dict.items():
            if isinstance(v, str):
                v = "\'" + v + "\'"
            consql = consql + "`" + tablename + "`." + "`" + k + "`" + '=' + v + ' and '
    consql = consql + ' 1=1 '
    sql = "UPDATE %s SET %s where%s" % (tablename, attrs_sql, consql)
    #print(sql)
    return sql

def updata_conf(json_in):
    cond_dict = {"conf_type": 'camera_capture'}
    json_in["is_read"] = "0"
    try:
        db = pymysql.connect(mysql_host, mysql_username, mysql_password, mysql_database)
        sql = update_sql_splicing('camera_strategy_table', json_in, cond_dict)
        cursor = db.cursor()
        cursor.execute(sql)
        db.commit()
        db.close()
        return 'SUCCESS'
    except:
        return 'ERROR'


@app.route('/marinePlatform/v2/data/history', methods=['POST'])
async def delete_file(request):
    try:
        if request.json['token'] == token:
            result = find_and_delete_file(file_dir,request.json['fileNames'])
            return response.text(result)
        else:
            #return response.text('ERROR')
            return response.text('Token not exist')

    except:
        #return response.text('ERROR')
        return response.text('data format error!')


def find_and_delete_file(file_dir,name_list):
    #result_list = []
    file_exists = True
    for index in range(0,len(name_list)):
        if os.path.exists(file_dir+name_list[index]) == False:
            file_exists = False
            #return "ERROR"
            return "error " + file_dir+name_list[index] + " not find"
    if file_exists == True:
        for index in range(0,len(name_list)):
            #result_dict = {}
            result = delete_single_file(file_dir,name_list[index])
            #result_dict["file_name"] = result_dict
            #result_dict["delete"] = result
            #result_list.append(result_dict)
        return "SUCCESS"
        #return result_list


def delete_single_file(file_dir,file_name):
    try:
        os.remove(file_dir+file_name)
        return True
    except:
        return False 




# ===============================================================================
# =================================== 新增部分 ===================================
# ===============================================================================


@app.route('/marinePlatform/v1/app/appToken', methods=['POST'])
async def update_token(request):
    """
    下行数据：下发平台验证token
    :param request:
    :return:
    """
    print("下发平台验证token request.json=", request.json)
    if request.json['old-token'] == token:
        # noinspection PyBroadException
        try:
            change_config = ConfigObj("config.ini", encoding='UTF8')
            # 修改配置文件中的token
            change_config['General']['token'] = request.json['token']
            change_config.write()

            result = "SUCCESS"
        except Exception as e:
            print("e=", e)
            result = "ERROR"
    else:
        result = "token 验证失败！"
    print("下发平台验证token result", result)
    return response.text(result)



@app.route('/marinePlatform/v1/data/extremeModeSetting', methods=['POST'])
async def set_extreme_mode(request):
    """
    设置极端模式规则
    :param request:
    :return:
    """
    if request.json['token'] == token:
        extreme_case_make_id = request.json["extreme_case_make_id"]
        posterize_rule = request.json["posterize_rule"]
        '''未完成...'''
    else:
        print("token 验证失败！")



@app.route('/marinePlatform/v1/devices/delFrameExtraction', methods=['POST'])
async def del_camera(request):
    """
    下行数据：删除摄像头
    :param request:
    :return:
    """
    print("删除摄像头 request.json=", request.json)

    receive_args = request.json
    if receive_args['token'] == token:
        if "id" in request.json.keys():
            camera_id = receive_args["id"]
            del_sql = "DELETE FROM camera_configuration_table WHERE camera_id in %s;"
            if camera_configuration_sql.commit_sql(del_sql, camera_id):
                result = "SUCCESS"
            else:
                result = "ERROR"
        else:
            result = "未传入摄像头id"
    else:
        result = "token 验证失败！"
    print("删除摄像头 result", result)
    return response.text(result)



@app.route('/marinePlatform/v1/devices/setVideoRecognize', methods=['POST'])
async def camera_image_recognize_conf(request):
    """
    下行数据：设置摄像头图像识别
    :param request:
    :return:
    """
    print("设置摄像头图像识别 request.json=", request.json)
    result = process_args(request.json)
    print("设置摄像头图像识别 result", result)

    return response.text(result)




def process_args(receive_args):
    """
    处理接收到的参数
    :param receive_args:
    :return:
    """
    if receive_args['token'] == token:
        value = []
        value.append(receive_args["camera_id"])
        value.append(int(receive_args["recognize_rate"]))
        value.append(receive_args["camera_ip"])
        value.append(int(receive_args["nvr_port"]))
        value.append(receive_args["user_name"])
        value.append(receive_args["password"])
        value.append(receive_args["channel_id"])

        insert_sql = "INSERT INTO camera_configuration_table " \
                     "(camera_id,recognize_rate,camera_ip,nvr_port, user_name,password,channel_id) " \
                     "VALUES %s;"
        if camera_configuration_sql.commit_sql(insert_sql, value):
            result = "SUCCESS"
        else:
            result = "ERROR"
    else:
        result = "token 验证失败！"
    return result







if __name__ == "__main__":
    file_dir = r'/home/sencott/imageCapture/HDU/'

    # 创建读取配置文件对象
    config = configparser.ConfigParser()
    config.read("config.ini", encoding="utf-8")

    # 获取通用配置项
    section = "General"  # 读取的部section标签
    token = config.get(section, 'token')
    mysql_host = config.get(section, 'mysqlHost')
    mysql_username = config.get(section, 'mysqlUsername')
    mysql_password = config.get(section, 'mysqlPassword')
    mysql_port = config.getint(section, 'mysqlPort')

    # 获取特有配置项
    mysql_database = config.get('api', 'mysqlDatabase')
    camera_configuration_sql = MysqldbOperational(host=mysql_host,
                                                   username=mysql_username,
                                                   password=mysql_password,
                                                   port=mysql_port,
                                                   database=mysql_database)


    app.run(host="0.0.0.0", port=8765, workers=1, debug=False, access_log=False)