单片机教程网

电脑版
提示:原网页已由神马搜索转码, 内容由www.51hei.com提供.
查看:102|回复:0
打印上一主题下一主题

用esp32-cam向巴法云发送图片,同时小程序获取

[复制链接]
跳转到指定楼层
楼主
ID:1089516发表于 2024-5-6 21:24|只看该作者|只看大图回帖奖励
  1. #include< WiFi.h>
  2. #include< WiFiClient.h>
  3. #include< ArduinoJson.h>
  4. #include< HTTPClient.h>
  5. #include< EEPROM.h>
  6. #include< Ticker.h>
  7. #include "DHT.h" //加载DHT11的库
  8. #include "esp_http_client.h"
  9. #include "esp_camera.h"
  10. #include "configuration.h"
  11. #include "camera_pins.h"

  13. char config_flag = 0;   //配网成功标识
  14. //tcp客户端相关
  15. String TcpClient_Buff = "";
  16. unsigned int TcpClient_BuffIndex = 0;
  17. unsigned long TcpClient_preTick = 0;
  18. unsigned long preHeartTick = 0;//心跳
  19. unsigned long preTCPStartTick = 0;//连接
  20. String over_int = "false";
  21. bool preTCPConnected = false;
  22. String UID = "c124bafd03ba4909b1f7794c3e38af32";   //巴法云私钥
  23. String TOPIC = "mytrash";   //主题名字
  24. //图像拍照上传相关
  25. int capture_interval = 5 * 1000;                 // 20秒上传一次
  26. const char* uid = "c124bafd03ba4909b1f7794c3e38af32";  //私钥
  27. const char* topic = "mytrash";                 //主题
  28. const char* wechatMsg = "";                   //如果不为空，会推送到
  29. const char* wecomMsg = "";                     //如果不为空，会推送到企业，推送到企业的消息
  30. const char* urlPath = "";                     //如果不为空，会生成自定义图片链接，自定义图片上传后返回的图片url，url前一部分为巴法云域名，第二部分：私钥+主题名的md5值，第三部分为设置的图片链接值。
  31. bool flashRequired = true;                   //闪光灯，true是打开闪光灯
  32. const int brightLED = 4;                     //闪光灯引脚
  33. const int sensorPin = 14; // 溢出检测引脚
  34. unsigned char sendp = 0;
  35. int sensorValue = 0;
  36. int connect_time = 0;

  38. const char* post_url = "imagesbemfa/upload/v1/upimages.php";  // 默认上传地址
  39. static String httpResponseString;                             //接收服务器返回信息
  40. bool internet_connected = false;
  41. long current_millis;
  42. long last_capture_millis = 0;

  44. // Bright LED (Flash)
  45. const int ledFreq = 50;       // PWM settings
  46. const int ledChannel = 15;     // camera uses timer1
  47. const int ledRresolution = 8;  // resolution (8 = from 0 to 255)

  49. struct config_type
  50. {
  51.   char stassid[32];
  52.   char stapsw[64];
  53.    char cuid[40];
  54.    char ctopic[32];
  55.   uint8_t reboot;
  56.   uint8_t magic;
  57. };
  58. config_type config;

  60. WiFiClient TCPclient;
  61. Ticker delayTimer;
  62. DHT dht(DHTPIN, DHTTYPE);//声明 dht 函数

  64. /**
  65. * 存储配网信息
  66. */
  67. void saveConfig()
  68. {
  69.   int rand_key;
  70.   uint8_t mac[6];
  71.   WiFi.macAddress(mac);
  72.   config.reboot = 0;
  73.   EEPROM.begin(512);
  74.   uint8_t *p = (uint8_t*)(&config);
  75.   for (int i = 0; i< sizeof(config); i++)
  76.   {
  77.    EEPROM.write(i, *(p + i));
  78.   }
  79.   EEPROM.commit();
  80. }

  82. void delayRestart(float t)
  83. {
  84.   delayTimer.attach(t, []()
  85.   {
  86.    ESP.restart();
  87.   });
  88. }

  90. /**
  91. * airkiss配网
  92. */
  93. void doSmartconfig()
  94. {
  95.   Serial.println("waiting for WeChat Config.....");
  96.   Serial.print("*");
  97.   Serial.print("*");
  98.   Serial.print("*");
  99.   Serial.print("*");
  100.   Serial.print("*");
  101.   Serial.println("*");
  102.   WiFi.mode(WIFI_STA);
  103.   WiFi.stopSmartConfig();
  104.   WiFi.beginSmartConfig();
  105.   int cnt = 0;
  106.   bool flag_ok = false;
  107.   while (!WiFi.smartConfigDone())
  108.   {
  109.    delay(300);
  110.    if (flag_ok == true) continue;
  111.    if (WiFi.smartConfigDone())
  112.    {
  113.        strcpy(config.stassid, WiFi.SSID().c_str());
  114.        strcpy(config.stapsw, WiFi.psk().c_str());
  115.        config.magic = MAGIC_NUMBER;
  116.        saveConfig();
  117.        flag_ok = true;
  118.    }
  119.    cnt++;
  120.    if (cnt >= 600)
  121.    {
  122.      delayRestart(0);
  123.    }
  124.   }
  125. }

  127. /**
  128. * 设置SmartConfig
  129. */
  130. void setConfig()
  131. {
  132.    String mac = WiFi.macAddress().substring(8);//取mac地址做主题用
  133.    mac.replace(":", "");//去掉:号
  134.    WiFiClient client_bemfa_WiFiClient;
  135.    HTTPClient http_bemfa_HTTPClient;
  136.    http_bemfa_HTTPClient.begin(client_bemfa_WiFiClient,"//probemfa/vv/setSmartConfig?version=1&user="+mac);
  137.    int httpCode = http_bemfa_HTTPClient.GET();
  138.    if (httpCode == 200)
  139.    {
  140.      Serial.println("wifi smartconfig ok");
  141.    }
  142.    http_bemfa_HTTPClient.end();
  143. }

  145. /**
  146. * 初始化wifi信息，并连接路由器网络
  147. */
  148. void initWiFi()
  149. {
  150.   char temp[32];
  151.   uint8_t mac[6];
  152.   WiFi.macAddress(mac);
  153.   //sprintf(temp, "%s_%02X%02X%02X", HOST_NAME, mac[3], mac[4], mac[5]);
  154.   WiFi.hostname(temp);
  155.   if(WiFi.status() != WL_CONNECTED)
  156.   {
  157.    WiFi.disconnect();//断开连接
  158.    WiFi.mode(WIFI_STA);//STA模式
  159.    WiFi.begin(config.stassid, config.stapsw);//连接路由器
  160.   }
  161.   Serial.print("Waiting for connect");
  162.   while (WiFi.status() != WL_CONNECTED)
  163.   {//检查是否连接成功
  164.    delay(500);
  165.    Serial.print(".");
  166.    connect_time++;
  167.    if(connect_time >= 360)
  168.    {
  169.      connect_time = 0;
  170.      Serial.println("wifi connect faild");
  171.    }
  172.   }
  173.   if(config_flag == 1)
  174.   {
  175.    setConfig();
  176.   }
  177.   Serial.println("wifi is connected");
  178.   //Serial.print("ssid:");
  179.   //Serial.println(WiFi.SSID());
  180.   //Serial.print("psw:");
  181.   //Serial.println(WiFi.psk());
  182.   WiFi.softAP(temp);
  183. }

  185. /**
  186. * 加载存储的信息，并检查是否进行了反复5次重启恢复出厂信息
  187. */
  188. uint8_t *p = (uint8_t*)(&config);
  189. void loadConfig()
  190. {
  191.    uint8_t mac[6];
  192.    WiFi.macAddress(mac);
  193.    EEPROM.begin(512);
  194.    for (int i = 0; i< sizeof(config); i++)
  195.    {
  196.      *(p + i) = EEPROM.read(i);
  197.    }
  198.    config.reboot = config.reboot + 1;
  199.    if(config.reboot>=4)
  200.    {
  201.        restoreFactory();
  202.    }
  203.    if(config.magic != MAGIC_NUMBER)
  204.    {
  205.      config_flag = 1;
  206.    }
  207.    EEPROM.begin(512);
  208.    for (int i = 0; i< sizeof(config); i++)
  209.    {
  210.      EEPROM.write(i, *(p + i));
  211.    }
  212.    EEPROM.commit();
  213.    delay(2000);
  214.    EEPROM.begin(512);
  215.    config.reboot = 0;
  216.    for (int i = 0; i< sizeof(config); i++)
  217.    {
  218.      EEPROM.write(i, *(p + i));
  219.    }
  220.    EEPROM.commit();
  221.    delay(2000);
  222. }

  224. /**
  225. * 恢复出厂设置，清除存储的wifi信息
  226. */
  227. void restoreFactory(){
  228.    Serial.println("Restore Factory.......");
  229.    config.magic = 0x00;
  230.    strcpy(config.stassid, "");
  231.    strcpy(config.stapsw, "");
  232.    config.magic = 0x00;
  233.    saveConfig();
  234.    delayRestart(1);
  235.    while (1)
  236.    {
  237.      delay(100);
  238.    }
  239. }

  241. /**
  242. * 检查是否需要airkiss配网
  243. */
  244. void waitKey()
  245. {
  246.   if(config_flag == 1)
  247.   {
  248.    doSmartconfig();
  249.   }
  250. }

  252. /*
  253.   *发送数据到TCP服务器
  254. */
  255. void sendtoTCPServer(String p)
  256. {
  257.   if (!TCPclient.connected())
  258.   {
  259.    //Serial.println("Client is not readly");
  260.    return;
  261.   }
  262.   TCPclient.print(p);
  263.   //Serial.println("[Send to TCPServer]:String");
  264. }

  266. /*
  267.   *初始化和服务器建立连接
  268. */
  269. void startTCPClient()
  270. {
  271.   if(TCPclient.connect(TCP_SERVER_ADDR, atoi(TCP_SERVER_PORT)))
  272.   {
  273.    //Serial.print("\nINFO:Connected to server:");
  274.    //Serial.printf("%s:%d\r\n",TCP_SERVER_ADDR,atoi(TCP_SERVER_PORT));
  275.    preTCPConnected = true;
  276.    preHeartTick = millis();
  277.    TCPclient.setNoDelay(true);
  278.    sendtoTCPServer("cmd=1&uid="+UID+"&topic="+TOPIC+"\r\n");
  279.   }
  280.   else
  281.   {
  282.    //Serial.print("INFO:Failed connected to server:");
  283.    //Serial.println(TCP_SERVER_ADDR);
  284.    TCPclient.stop();
  285.    preTCPConnected = false;
  286.   }
  287.   preTCPStartTick = millis();
  288. }

  290. /*
  291.   *检查数据，发送数据
  292. */
  293. void doTCPClientTick()
  294. {
  295. //检查是否断开，断开后重连
  296.   if(WiFi.status() != WL_CONNECTED) return;
  297.   if (!TCPclient.connected())
  298.   {//断开重连
  299.    if(preTCPConnected == true)
  300.    {
  301.      preTCPConnected = false;
  302.      preTCPStartTick = millis();
  303.      Serial.println("TCP Client disconnected");
  304.      TCPclient.stop();
  305.    }
  306.    else if(millis() - preTCPStartTick > 1*1000)//重新连接
  307.      startTCPClient();
  308.   }
  309.   else
  310.   {
  311.    if (TCPclient.available())
  312.    {//收数据
  313.      char c =TCPclient.read();
  314.      TcpClient_Buff +=c;
  315.      TcpClient_BuffIndex++;
  316.      TcpClient_preTick = millis();
  317.      if(TcpClient_BuffIndex>=MAX_PACKETSIZE - 1)
  318.      {
  319.        TcpClient_BuffIndex = MAX_PACKETSIZE-2;
  320.        TcpClient_preTick = TcpClient_preTick - 200;
  321.      }
  322.      preHeartTick = millis();
  323.    }
  324.    if(millis() - preHeartTick >= upDataTime)
  325.    {//上传数据
  326.      preHeartTick = millis();
  327.      float h = dht.readHumidity();//读取湿度
  328.      float t = dht.readTemperature();//读取摄氏度
  329.      if (isnan(h) || isnan(t))
  330.      {
  331.        Serial.println("Failed to read from DHT sensor!");
  332.        return;
  333.      } //检查抓取是否成功
  334.      /*********************数据上传*******************/
  335.      String upstr = "";
  336.      String uart_str = "";
  337.      upstr = "cmd=2&uid="+UID+"&topic="+TOPIC+"&msg=#"+over_int+"#"+t+"#"+h+"\r\n";
  338.      sendtoTCPServer(upstr);
  339.      uart_str = "DATA#"+over_int+"#"+t+"#"+h+"\r\n";
  340.      Serial.print(uart_str);
  341.      upstr = "";
  342.    }
  343.   }
  344.   if((TcpClient_Buff.length() >= 1)&& (millis() - TcpClient_preTick>=200))
  345.   {//data ready
  346.    TCPclient.flush();
  347.    //Serial.print("Buff:");
  348.    //Serial.println(TcpClient_Buff);
  349.    TcpClient_Buff="";
  350.    TcpClient_BuffIndex = 0;
  351.   }
  352. }

  354. // change illumination LED brightness
  355. void brightLed(byte ledBrightness) {
  356.   ledcWrite(ledChannel, ledBrightness);  // change LED brightness (0 - 255)
  357. }

  359. // ----------------------------------------------------------------
  360. //     set up PWM for the illumination LED (flash)
  361. // ----------------------------------------------------------------
  362. // note: I am not sure PWM is very reliable on the esp32cam - requires more testing
  363. void setupFlashPWM() {
  364.   ledcSetup(ledChannel, ledFreq, ledRresolution);
  365.   ledcAttachPin(brightLED, ledChannel);
  366.   brightLed(0);
  367. }

  369. void Setint(){
  370.   sendp = 1;
  371. }

  373. void setup() {
  374.   Serial.begin(115200);
  375.   pinMode(brightLED, OUTPUT);   // flash LED
  376.   pinMode(sensorPin, INPUT); // 将引脚设置为输入模式
  377.   digitalWrite(brightLED, LOW);  // led off = Low
  378.   attachInterrupt(2, Setint, FALLING);  //当电平发生变化时，触发中断
  379.   attachInterrupt(13, restoreFactory, FALLING);  //当电平发生变化时，触发中断
  380.   dht.begin(); //启动传感器
  381.   camera_config_t config;
  382.   config.ledc_channel = LEDC_CHANNEL_0;
  383.   config.ledc_timer = LEDC_TIMER_0;
  384.   config.pin_d0 = Y2_GPIO_NUM;
  385.   config.pin_d1 = Y3_GPIO_NUM;
  386.   config.pin_d2 = Y4_GPIO_NUM;
  387.   config.pin_d3 = Y5_GPIO_NUM;
  388.   config.pin_d4 = Y6_GPIO_NUM;
  389.   config.pin_d5 = Y7_GPIO_NUM;
  390.   config.pin_d6 = Y8_GPIO_NUM;
  391.   config.pin_d7 = Y9_GPIO_NUM;
  392.   config.pin_xclk = XCLK_GPIO_NUM;
  393.   config.pin_pclk = PCLK_GPIO_NUM;
  394.   config.pin_vsync = VSYNC_GPIO_NUM;
  395.   config.pin_href = HREF_GPIO_NUM;
  396.   config.pin_sscb_sda = SIOD_GPIO_NUM;
  397.   config.pin_sscb_scl = SIOC_GPIO_NUM;
  398.   config.pin_pwdn = PWDN_GPIO_NUM;
  399.   config.pin_reset = RESET_GPIO_NUM;
  400.   config.xclk_freq_hz = 20000000;
  401.   config.frame_size = FRAMESIZE_UXGA;
  402.   config.pixel_format = PIXFORMAT_JPEG;  // for streaming
  403.   config.grab_mode = CAMERA_GRAB_WHEN_EMPTY;
  404.   config.fb_location = CAMERA_FB_IN_PSRAM;
  405.   config.jpeg_quality = 10;
  406.   config.fb_count = 1;

  408.   // if PSRAM IC present, init with UXGA resolution and higher JPEG quality
  409.   //               for larger pre-allocated frame buffer.
  410.   if (config.pixel_format == PIXFORMAT_JPEG) {
  411.    if (psramFound()) {
  412.      config.jpeg_quality = 10;
  413.      config.fb_count = 2;
  414.      config.grab_mode = CAMERA_GRAB_LATEST;

  416.    } else {
  417.      // Limit the frame size when PSRAM is not available
  418.      config.frame_size = FRAMESIZE_SVGA;
  419.      config.fb_location = CAMERA_FB_IN_DRAM;
  420.    }
  421.   } else {
  422.    // Best option for face detection/recognition
  423.    config.frame_size = FRAMESIZE_240X240;
  424. #if CONFIG_IDF_TARGET_ESP32S3
  425.    config.fb_count = 2;
  426. #endif
  427.   }

  429. #if defined(CAMERA_MODEL_ESP_EYE)
  430.   pinMode(13, INPUT_PULLUP);
  431.   pinMode(14, INPUT_PULLUP);
  432. #endif

  434.   // camera init
  435.   esp_err_t err = esp_camera_init(&config);
  436.   if (err != ESP_OK) {
  437.    //Serial.printf("Camera init failed with error 0x%x", err);
  438.    return;
  439.   }

  441.   sensor_t* s = esp_camera_sensor_get();
  442.   // initial sensors are flipped vertically and colors are a bit saturated
  443.   if (s->id.PID == OV3660_PID) {
  444.    s->set_vflip(s, 1);       // flip it back
  445.    s->set_brightness(s, 1);   // up the brightness just a bit
  446.    s->set_saturation(s, -2);  // lower the saturation
  447.   }


  450. #if defined(CAMERA_MODEL_M5STACK_WIDE) || defined(CAMERA_MODEL_M5STACK_ESP32CAM)
  451.   s->set_vflip(s, 1);
  452.   s->set_hmirror(s, 1);
  453. #endif

  455. #if defined(CAMERA_MODEL_ESP32S3_EYE)
  456.   s->set_vflip(s, 1);
  457. #endif

  459.   loadConfig();
  460.   waitKey();
  461.   initWiFi();
  462.   //Serial.print("Camera Ready!:");
  463.   //Serial.println(WiFi.localIP());
  464.   setupFlashPWM();  // configure PWM for the illumination LED
  465. }

  467. /********http请求处理函数*********/
  468. esp_err_t _http_event_handler(esp_http_client_event_t* evt) {
  469.   if (evt->event_id == HTTP_EVENT_ON_DATA) {
  470.    httpResponseString.concat((char*)evt->data);
  471.   }
  472.   return ESP_OK;
  473. }

  475. static esp_err_t take_send_photo() {
  476.   if (flashRequired) {
  477.    brightLed(255);
  478.    delay(300);
  479.   }
  480.   //Serial.println("take_send_photo...");
  481.   camera_fb_t* fb = NULL;
  482.   esp_err_t res = ESP_OK;
  483.   fb = esp_camera_fb_get();
  484.   if (flashRequired) brightLed(0);  // change LED brightness back to previous state

  486.   if (!fb) {
  487.    //Serial.println("Camera capture failed...");
  488.    return ESP_FAIL;
  489.   }

  491.   httpResponseString = "";
  492.   esp_http_client_handle_t http_client;
  493.   esp_http_client_config_t config_client = { 0 };
  494.   config_client.url = post_url;
  495.   config_client.event_handler = _http_event_handler;
  496.   config_client.method = HTTP_METHOD_POST;
  497.   http_client = esp_http_client_init(&config_client);
  498.   esp_http_client_set_post_field(http_client, (const char*)fb->buf, fb->len);  //设置http发送的内容和长度
  499.   esp_http_client_set_header(http_client, "Content-Type", "image/jpg");       //设置http头部字段
  500.   esp_http_client_set_header(http_client, "Authorization", uid);           //设置http头部字段
  501.   esp_http_client_set_header(http_client, "Authtopic", topic);             //设置http头部字段
  502.   esp_http_client_set_header(http_client, "wechatmsg", wechatMsg);         //设置http头部字段
  503.   esp_http_client_set_header(http_client, "wecommsg", wecomMsg);           //设置http头部字段
  504.   esp_http_client_set_header(http_client, "picpath", urlPath);             //设置http头部字段
  505.   esp_err_t err = esp_http_client_perform(http_client);                 //发送http请求
  506.   if (err == ESP_OK) {
  507.    //json数据解析
  508.    StaticJsonDocument<200> doc;
  509.    DeserializationError error = deserializeJson(doc, httpResponseString);
  510.    if (error) {
  511.      //Serial.print(F("deserializeJson() failed: "));
  512.      //Serial.println(error.c_str());
  513.    }
  514.   }
  515.   //Serial.println("Taking picture END");
  516.   esp_camera_fb_return(fb);
  517.   esp_http_client_cleanup(http_client);
  518.   return res;
  519. }

  521. void loop()
  522. {
  523.   sensorValue = digitalRead(sensorPin); // 读取引脚的电平
  524.   if (sensorValue == HIGH)
  525.   {
  526.    over_int = "true";
  527.   }
  528.   else
  529.   {
  530.    over_int = "false";
  531.   }
  532.   doTCPClientTick();
  533.   // current_millis = millis();
  534.   // if (current_millis - last_capture_millis > capture_interval)
  535.   // {
  536.   //   last_capture_millis = millis();
  537.   //   take_send_photo();
  538.   // }
  539.   if (sendp == 1)
  540.   {  // Take another picture
  541.    take_send_photo();
  542.    sendp = 0;
  543.   }
  544. }
复制代码

图片1.png(688.86 KB, 下载次数: 0)

图片1.png

esp32camv2.zip

6.9 KB, 下载次数: 2, 下载积分: 黑币 -5

esp32-cam代码

trash.zip

7.63 KB, 下载次数: 2, 下载积分: 黑币 -5

小程序代码

评分

黑币 +50
收起理由
+ 50
共享资料的黑币奖励！

查看全部评分

手机版|小黑屋|51黑电子论坛|51黑电子论坛6群QQ管理员QQ:125739409;技术交流QQ群281945664

Powered by 单片机教程网