物联网+罗刹马户又鸟饮食 简单

#  -*- coding: UTF-8 -*-

# MindPlus
# Python
import base64
from io import BytesIO
from PIL import Image
from pinpong.extension.unihiker import *
from pinpong.board import Board,Pin
from dfrobot_rp2040_sci import *
from unihiker import GUI
import siot
import time
import cv2


u_gui=GUI()
siot.init(client_id="",server="10.1.2.3",port=1883,user="siot",password="dfrobot")
Board().begin()
siot.connect()
siot.loop()

def frame2base64(frame):
    frame = cv2.cvtColor(frame, cv2.COLOR_BGR2RGB)
    img = Image.fromarray(frame) #将每一帧转为Image
    output_buffer = BytesIO() #创建一个BytesIO
    img.save(output_buffer, format='JPEG') #写入output_buffer
    byte_data = output_buffer.getvalue() #在内存中读取
    base64_data = base64.b64encode(byte_data) #转为BASE64
    return base64_data #转码成功 返回base64编码

def base642base64(frame):
    data=str('data:image/png;base64,')
    base64data = str(frame2base64(frame))
    framedata = base64data[2:(len(base64data)-1)]
    base642base64_data = data + str(framedata)
    return base642base64_data
vd = cv2.VideoCapture()
vd.open(-1)
while not (vd.isOpened()):
    print("摄像头初始化中....")
print("摄像头初始化完成")
u_gui.draw_image(image="2.png",x=0,y=0)
siot.getsubscribe(topic="siot/实时监控")
siot.getsubscribe(topic="siot/光照数值")
siot.getsubscribe(topic="siot/空气质量")
SCI1 = DFRobot_RP2040_SCI_IIC(addr=0x21)
while SCI1.begin() != 0:
    print("Initialization Sensor Universal Adapter Board failed.")
    time.sleep(1)
print("Initialization Sensor Universal Adapter Board done.")

while True:
    if vd.grab():
        ret, grab = vd.read()
        siot.publish_save(topic="siot/实时监控", data=base642base64(grab))
    else:
        print("没有下一帧")
    siot.publish_save(topic="siot/光照数值", data=light.read())
    siot.publish_save(topic="siot/空气质量", data=(str(SCI1.get_value1(SCI1.eALL,"PM1.0")) + str((str("，") + str((str(SCI1.get_value1(SCI1.eALL,"PM2.5")) + str((str("，") + str(SCI1.get_value1(SCI1.eALL,"PM10"))))))))))
    if (light.read() < 230):
        p_p24_out=Pin(Pin.P24, Pin.OUT)
        p_p24_out.write_digital(1)
    else:
        p_p24_out=Pin(Pin.P24, Pin.OUT)
        p_p24_out.write_digital(0)

/*!
 * MindPlus
 * mpython
 *
 */
#include <MPython.h>
#include <DFRobot_Servo.h>
#include <DFRobot_HuskyLens.h>
// 创建对象
DFRobot_HuskyLens huskylens;
Servo             servo_P0;
Servo             servo_P1;
Servo             servo_P8;


// 主程序开始
void setup() {
	mPython.begin();
	servo_P0.attach(P0);
	servo_P1.attach(P1);
	servo_P8.attach(P8);
	display.setCursor(16, 5);
	display.print("欢迎来到罗刹国");
	huskylens.beginI2CUntilSuccess();
	huskylens.writeAlgorithm(ALGORITHM_TAG_RECOGNITION);
	servo_P0.angle(abs(0));
	servo_P1.angle(abs(0));
}
void loop() {
	huskylens.request();
	if (huskylens.isLearned(1)) {
		if (huskylens.isAppear(1,HUSKYLENSResultBlock)) {
			rgb.write(0, 0xFF0000);
			display.setCursorLine(3);
			display.printLine("马 户");
			servo_P8.angle(abs(70));
			delay(3000);
			buzz.freq(880, BEAT_1);
			delay(1000);
			servo_P8.angle(abs(0));
			rgb.write(0, 0x000000);
			display.fillInLine(3, 0);
		}
	}
	if (huskylens.isLearned(2)) {
		if (huskylens.isAppear(2,HUSKYLENSResultBlock)) {
			rgb.write(1, 0x0000FF);
			display.setCursorLine(4);
			display.printLine("又鸟");
			servo_P1.angle(abs(70));
			delay(3000);
			buzz.freq(880, BEAT_1);
			delay(1000);
			servo_P1.angle(abs(0));
			display.fillInLine(4, 0);
			rgb.write(1, 0x000000);
		}
	}
}