文件 · EYE · CharlesGuo11 / Heart-Rate Esp32s3-Box_AED · GitCode

//下载gitee工具
git clone https://gitee.com/EspressifSystems/esp-gitee-tools.git
//下载指定版本的esp-idf（此处采用稳定版本V4.4）
git clone -b release/v4.4 https://gitee.com/EspressifSystems/esp-idf.git
//进入工具目录，执行命令更新子模块（user部分为你的用户名）
cd esp-gitee-tools
./submodule-update.sh ~/user/esp/esp-idf
git clone --recursive https://github.com/espressif/esp-who.git
cd esp-who
get_idf
idf.py set-target [SoC] #[SOC]替换成目标芯片，如esp32s3
idf.py build
idf.py flash monitor
        //解码成功的，创建socket
        int serveSocket;
        int clientSocket;
        struct sockaddr_in server_addr;
        struct sockaddr_in client_addr;
        socklen_t sin_size;
        memset(&server_addr,0,sizeof(server_addr)); //数据初始化--清零
        server_addr.sin_family=AF_INET; //设置为IP通信
        server_addr.sin_addr.s_addr=INADDR_ANY;//服务器IP地址--允许连接到所有本地地址上
        server_addr.sin_port=htons(8888); //服务器端口号
        /*创建服务器端套接字--IPv4协议，面向连接通信，TCP协议*/
        if((serveSocket=socket(PF_INET,SOCK_STREAM,0))<0)
        {
            ESP_LOGE(TAG, "socket error");
            return 1;
        }
        /*将套接字绑定到服务器的网络地址上*/
        if(bind(serveSocket,(struct sockaddr *)&server_addr,sizeof(struct sockaddr))<0)
        {
            ESP_LOGE(TAG, "bind error");
            return 1;
        }
        ESP_LOGE(TAG, "server scocket created");
        /*监听连接请求--监听队列长度为1*/
        if(listen(serveSocket,1)<0)
        {
            ESP_LOGE(TAG, "listen error");
            return 1;
        };
        sin_size=sizeof(struct sockaddr_in);
        if((clientSocket=accept(serveSocket,(struct sockaddr *)&client_addr,&sin_size))<0)
        {
            ESP_LOGE(TAG, "accept error");
            return 1;
        }
        ESP_LOGE(TAG, "sending pic size %d"， (int)_jpg_buf_len);
        char lenStr[128];
        itoa(_jpg_buf_len,lenStr,10);
        send(clientSocket,lenStr,strlen(lenStr),0);
        ESP_LOGE(TAG,"size was sent");
        ESP_LOGE(TAG,"sending pic");
        send(clientSocket,(char*)_jpg_buf,_jpg_buf_len*8,0);
        if((clientSocket=accept(serveSocket,(struct sockaddr *)&client_addr,&sin_size))<0)
        {
            ESP_LOGE(TAG, "accept error");
            return 1;
        }
        ESP_LOGE(TAG, "all recieved");
        close(serveSocket);
import socket

'''建立连接，进入httpd的函数内部确保socket能够脸上'''
url = '172.20.10.5'#局域网ip
port = 81#固定端口
http_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#连接到芯片
http_sock.connect((url, port))
request_url = 'GET /stream HTTP/1.1\r\nHost: 172.20.10.5\r\nConnection: close\r\n\r\n'
http_sock.send(request_url.encode())

'''图片传输socket'''
#连接
port = 8888
pic_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
pic_sock.connect((url, port))
#接收长度socket
arrayLength = int(pic_sock.recv(10000));
byteStreamLength = 8*arrayLength;
#接收比特
picByteStream = pic_sock.recv(byteStreamLength);
#通过比特流方式写入文件
image = open("test.jpq", "wb");
for i in range(0,arrayLength):
    image.write(picByteStream[i].to_bytes(1,byteorder="little",signed=False));
# 连接断开
pic_sock.close();
http_sock.close();
def face_register():#人脸注册
    path1 = '/home/gcl/rPPG-master/list/'
    datanames1 = os.listdir(path1)
    for i in datanames1:
        file_path1 = '/home/gcl/rPPG-master/list/' + i
        image1 = get_file_content(file_path1)
        groupId = "group1"
        userId = os.path.splitext(i)[0]
        """ 调用人脸注册 """
        result = client.addUser(image1, imageType, groupId, userId)

def face_detect():#人脸检测
    global username
    username = 'none'
    path2 = '/home/gcl/rPPG-master/pending/'
    datanames2 = os.listdir(path2)
    for i in datanames2:
        file_path2 = '/home/gcl/rPPG-master/pending/01.jpg'
        image = get_file_content(file_path2)
        # 人脸识别：标框和性别
        options = {}
        options["face_field"] = "gender"
        options["max_face_num"] = 10
        # 调用人脸识别函数
        result1 = client.detect(image, imageType, options)
        # 人脸搜素
        groupIdList = "group1"
        options = {}
        options["max_face_num"] = 5
        options["match_threshold"] = 70
        result2 = client.multiSearch(image, imageType, groupIdList, options)
        scoremax = 0
        username = "null"
        for item in result2['result']['face_list']:
            if item['user_list']:
                for user in item['user_list']:
                    if user["score"] > scoremax:
                        scoremax = user["score"]
                        username = user['user_id']
        return username

def face_recoginition():#人脸识别
    image = cv2.VideoCapture('rtsp://172.20.10.5')
    ret, frame = image.read()
    if ret:
        cv2.imwrite(r"/home/gcl/rPPG-master/pending/01.jpg", frame)
        name = face_detect()
        with open("name.txt", "w") as f:
            f.write(str(name))
git clone https://github.com/nasir6/rPPG.git
cd rPPG
pip install -r requirements.txt #下载项目所需要的安装包依赖
python3 run.py --source=0 --frame-rate=25 #以每秒25帧的速率运行
apt-get update （更新数据源）
apt-get install mysql-server （安装mysql服务端）
mysql_secure_installation （确认权限）
mysql> create user 'userName'@'%' identified by 'pwd'; （创建用户，并指定密码）
mysql> grant all privileges on *.* to 'userName'@'%'; （为该用户授予全部表的访问权限）
function fnOpen(){
   chart.open(
   {
    rect : {x : 50,y : 130,w : 510,h : 350},
           bg : '#FFFFFF',
           coordinate : {
           yAxis : {max : 125,min : 0,step : 25,width : 40,size : 12,color : '#FF5255'},
           xAxis : {max:24,min: 0,step:6,minStep : 1,minStepGap:20,height : 30,size : 12,color: '#FF5255'},
           border : {size : 0.5,color : '#52FF55'},
           brokenLine : {color : '#FF5255',width : 2.5}},
           shadow : [],
           datas : cors,
           fixedOn : api.frameName},
		   function(ret) {
           if (ret) {
           chartID = ret.id;//打开成功之后，对图表的id进行赋值
           }});
   }
function updateCors(){
    //如果已经建立了连接
    if(database.isConnected()){
    //模拟数据更新
    var heartRate = Math.floor(Math.random()*25+50);//随机生成50-75的取整心率数据
    database.update(
    {sql: "insert into heartRate values('gcl',"+heartRate+", now());"},
    function(ret){}
    )//插入到数据库当中，插入的表项是（用户名，心率，sql自带的当前时间函数 ）
    //查找心率
    database.query(
    //从表中查找用户ID是gcl的心率
    {sql: "select rate from heartRate where userID ='xxx';"},
    function(ret){
    //回调函数
    //从返回的JSON文件当中取出result结果集
    var heartRateSet = ret["result"];
    //由于可能存在查到一半数据库就关闭了，判断结果集有没有元素
    if(heartRateSet!=[]){
    //有元素，将存储坐标的cors数组进行初始化
    cors=[];
    for(i=0;i<heartRateSet.length;i++){
        var x = i;
        var y = heartRateSet[i]["rate"];//取出结果集当中存储的数据库表当中，“rate”对应的数字即心率
        cors.push({xValue: x, yValue: y});//按照api需要的格式插入到坐标数组}
   }})}}
function UIButton_open() {
   btn1.open({
              rect: { x: 47,y: 550,w: 515,h: 50 },
              corner: 5,
              border:{ borderColor: 'FF5474',borderWidth: '0' },
              bg: {normal: '#FFFFFF',
                   highlight: '#B6B6B6',
                   active: '#FFFFFF'},
              title: {size: 14,highlight: '隐藏折线图',active: '隐藏折线图',normal: '隐藏折线图',highlightColor: '#0D0D0D',
              activeColor: '#0D0D0D',normalColor: '#0D0D0D',alignment: 'center',},
              fixedOn: api.frameName,
              fixed: true,
      		  move: true},
function(ret, err) {
			  if (ret) {fnHide}
   			  else {alert(JSON.stringify(err));}
              });