玩嗨OpenHarmony：基于OpenHarmony的农业喷灌的可视化控制系统-电子发烧友网

原文引自：51CTO 开源基础软件社区 #DAYU200体验官《农业喷灌的可视化控制》

1. 项目背景

“民以食为天”，粮食安全关系一个国家和民族的基本生存，联合国发布《2022年全球粮食危机报告》称全球或面临严重的粮食短缺。粮食生产离不开浇水和施肥，要想获得高产稳产，必须采用更加科学高效的节水灌溉技术，实现水肥一体化作业和管理。喷灌是利用管道将有压水送到灌溉地段，并通过喷头分散成细小水滴，均匀地喷洒到田间，对作物进行灌溉。它作为一种先进的机械化、半机械化灌水方式，可以广泛应用于大田粮食生产。

喷灌的主要优点有：

节水效果显著，水的利用率可达90%。喷灌与地面灌溉相比，1立方米水可以当2立方米水用。
作物增产幅度大，一般可达20%—40%，因增加了15%—20%的播种面积；可改善了田间小气候和农业生态环境。
大大减少了田间渠系建设及管理维护和平整土地等的工作量。
减少了农民用于灌水的费用和用工量，减少生产投入，增加农民收入。
有利于实现农业机械化、自动化，产业化、现代化。
避免由于过量灌溉造成水资源浪费和土壤次生盐碱化。

2. 项目概述本农业喷灌项目采用变频器驱动高效深井泵实现输水管道的恒压和变压控制，用Hi3861承担主控，采用DAYU200做上位机，完成系统的可视化控制。

演示系统由水泵，三叉喷头，支架，管路，变频器，Hi3861开发板和DAYU200开发板共同组成。

最终效果如下：

在庭院中的演示视频如下：https://ost.51cto.com/show/14689

代码仓库：https://gitee.com/hihope_iot/dayu200_demo/tree/master/%23DAYU200%E4%BD%93%E9%AA%8C%E5%AE%98%23%E5%86%9C%E4%B8%9A%E5%96%B7%E7%81%8C%E7%9A%84%E5%8F%AF%E8%A7%86%E5%8C%96%E6%8E%A7%E5%88%B6

3. 上位机-DAYU200

首页界面，点击“开始”按钮进控制页面。

可视化控制页面，点击“启动”和“停止”可以开启和关闭喷灌系统。

DAYU200与主控Hi3861通过Socket进行数据传输，采用TCP协议。

//import需要的socket模块
import socket from '@ohos.net.socket';

//创建一个TCPSocket连接，返回一个TCPSocket对象
let tcp = socket.constructTCPSocketInstance();

//订阅TCPSocket相关的事件
tcp.on('message', value => {
      console.log("on message")
      let buffer = value.message
      let dataView = new DataView(buffer)
      let str = ""
      for (let i = 0;i < dataView.byteLength; ++i) {
        str += String.fromCharCode(dataView.getUint8(i))
      }
      console.log("***on connect received:" + str)
      this.receive_data=str;
    });


    tcp.on('connect', () => {
      console.log("***on connect");
      this.llog="on.con ok";
    });


    tcp.on('close', () => {
      console.log("***on close");
      this.llog="on.close ok";
    });

//绑定本机IP地址和指定的端口，端口使用中也会由系统随机分配
let bindAddress = {
      address: '192.168.*.*',
      port: 1234,
      family: 1
    };


    tcp.bind(bindAddress, err => {
      if (err) {
        console.log('***bind fail');
        return;
      }
      console.log('***bind success');
      this.llog="bind ok";
    });

//连接到主控3861的IP地址和端口
tcp.connect({ address: {address: '192.168.*.*', port: 8888, family: 1} , timeout: 6000}, err => {
      if (err) {
        console.log('***connect fail');
        return;
      }
      console.log('***connect success');
    });

//向3861发送启动指令
this.app_msg = "ON";
    tcp.send({
      data: this.app_msg,
    }, err => {
      if (err) {
        console.log('send fail');
        return;
      }
    });


//向3861发送停止指令
this.app_msg = 'OFF';
    tcp.send({
      data: this.app_msg,
    }, err => {
      if (err) {
        console.log('send fail');
        return;
      }
    });

4.主控-Hi3861

主控-Hi3861使用socket创建TCP服务端，接收来自上位机DAYU200的控制命令，同时回复状态数据到DAYU200。

static void TCPServerTask(void)
{
  //服务端地址信息
  struct sockaddr_in server_sock;
  //客户端地址信息
  struct sockaddr_in client_sock;
  int sin_size;
  struct sockaddr_in *cli_addr;
  //连接Wifi,
  WifiConnect("******", "********");
  //创建socket
  if ((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
  {
    perror("socket is error
");
    exit(1);
  }
  bzero(&server_sock, sizeof(server_sock));
  server_sock.sin_family = AF_INET;
  server_sock.sin_addr.s_addr = htonl(INADDR_ANY);
  server_sock.sin_port = htons(_PROT_);
  //调用bind函数绑定socket和地址
  if (bind(sock_fd, (struct sockaddr *)&server_sock, sizeof(struct sockaddr)) == -1)
  {
    perror("bind is error
");
    exit(1);
  }
  //调用listen函数监听(指定port监听)
  if (listen(sock_fd, TCP_BACKLOG) == -1)
  {
    perror("listen is error
");
    exit(1);
  }
  printf("start accept
");
  //调用accept函数从队列中
  while (1)
  {
    sin_size = sizeof(struct sockaddr_in);
    if ((new_fd = accept(sock_fd, (struct sockaddr *)&client_sock, (socklen_t *)&sin_size)) == -1)
    {
      perror("accept");
      continue;
    }
    cli_addr = malloc(sizeof(struct sockaddr));
    printf("accept addr
");
    if (cli_addr != NULL)
    {
      memcpy(cli_addr, &client_sock, sizeof(struct sockaddr));
    }
    //处理目标
    ssize_t ret;
    while (1)
    {
      if ((ret = recv(new_fd, recvbuf, sizeof(recvbuf), 0)) == -1)
      {
        printf("recv error 
");
      }
      if(NULL != strstr(recvbuf,"ON")) {
          printf("START ON  !
");
        IoTGpioSetOutputVal(8, 1);
          IoTGpioSetOutputVal(14, 1);
      }
          if(NULL != strstr(recvbuf,"OFF")) {
        printf("START OFF !
");
        IoTGpioSetOutputVal(8, 0);
          IoTGpioSetOutputVal(14, 0);
      }
      if ((ret = send(new_fd, buf, strlen(buf) + 1, 0)) == -1)
      {
        perror("send : ");
      }
      sleep(1);
    }
    close(new_fd);
  }
}