网络上的东西收集农业数据

函数解码器(b、港口){var counter = b [0] < < 8) | b [1];var水分= b [2] | b [3] < < 8;var temp = (b [4] [5] | b < < 8) / 100;var lat = (b [6] [7] | b < < 8 | b [8] < < 16 | (b [8] & 0 x80吗?0 xff < < 24: 0)) / 10000;var朗= (b [9] | b [10] < < 8 | b [11] < < 16 | (b [11] & 0 x80吗?0 xff < < 24: 0)) / 10000;返回{field1:计数器,field2:水分,field3: temp,纬度:纬度,经度:经度}}

# include < lmic。h > # include <哈尔/哈尔。h > # include < SPI。双氢睾酮h > # include "。h”# include < Adafruit_GPS。h > # define DHTPIN 5 # define GPSSerial Serial1 # define SOIL_PIN 14 # define SOIL_POWER_PIN 11 # define GPSECHO假/ /设置为“真正的”如果你想调试和听原始GPS句子# define PAYLOAD_SIZE 13 / /发送的字节数+ 2 / / LoRaWAN NwkSKey,网络会话密钥静态常量PROGMEM u1_t NwkSKey [16] = {0 x98, 0 xeb 0 x1a 0 xc5, 0 xf9 0 x20, 0 x15 0 xcd 0 x12 0 xe5 0 x72 0 xff, 0 xcd 0 xe2 0 x94 0 x46};/ / LoRaWAN AppSKey、应用程序会话密钥静态常量u1_t PROGMEM AppSKey [16] = {x4d x28 0×50 0, 0, 0机加区,0 xea, 0 x41 0 x53 0 x7e 0 xca 0 x70、0 xd2 0 x26 0 xcc, 0 x14, 0 x66 0 x19};/ / LoRaWAN终端设备地址(DevAddr)静态常量u4_t DevAddr = 0 x26021115;/ /回调函数只用于无线激活。离开这些变量空,除非你使用了空气激活。空白os_getArtEui (u1_t * buf){}无效os_getDevEui (u1_t * buf){}无效os_getDevKey (u1_t * buf){} / /负载发送到TTN网关静态uint8_t载荷(PAYLOAD_SIZE);静态osjob_t sendjob; // Schedule TX at least this many seconds const unsigned TX_INTERVAL = 60; //was 30 // Pin mapping for Adafruit Feather M0 LoRa const lmic_pinmap lmic_pins = { .nss = 8, .rxtx = LMIC_UNUSED_PIN, .rst = 4, .dio = {3, 6, LMIC_UNUSED_PIN}, .rxtx_rx_active = 0, .rssi_cal = 8, // LBT cal for the Adafruit Feather M0 LoRa, in dB. .spi_freq = 8000000, }; Adafruit_GPS GPS(&GPSSerial); // Connect to the GPS on the hardware port. DHT dht(DHTPIN, DHT22); // Connect to the temperature sensor. uint16_t counter = 0; int32_t myLatitude = -12345; // Initialize for testing before GPS finds a lock. int32_t myLongitude = 54321; // Initialize for testing. int myMoisture = 0; // 10 bit ADC value. float temperatureF = 1111;

无效的设置(){Serial.begin (115200);dht.begin ();以“开始”);/ /设置湿度传感器pinMode电力销(SOIL_POWER_PIN、输出);digitalWrite (SOIL_POWER_PIN、低);GPS.begin (9600);/ / 9600 n mea是默认的波特率。GPS.sendCommand (PMTK_SET_NMEA_OUTPUT_RMCGGA);GPS.sendCommand (PMTK_SET_NMEA_UPDATE_1HZ);/ /设置一个1赫兹更新率。 delay(1000); // Wait for GPS to initialize. // Ask for firmware version GPSSerial.println(PMTK_Q_RELEASE); // Initialize the LMIC. os_init(); // Reset the MAC state. Resetting discards the session and pending data transfers. LMIC_reset(); // Set static session parameters. uint8_t appskey[sizeof(APPSKEY)]; uint8_t nwkskey[sizeof(NWKSKEY)]; memcpy_P(appskey, APPSKEY, sizeof(APPSKEY)); memcpy_P(nwkskey, NWKSKEY, sizeof(NWKSKEY)); LMIC_setSession(0x13, DEVADDR, nwkskey, appskey); LMIC_selectSubBand(1); // Only use the correct The Things Network channels, disable the others. for (int c = 0; c < 72; c++) { if ((c < 8) || (c > 15)) { LMIC_disableChannel(c); } } LMIC_setClockError(MAX_CLOCK_ERROR * 1 / 100); // Disable link check validation LMIC_setLinkCheckMode(0); // TTN uses SF9 for its RX2 window. LMIC.dn2Dr = DR_SF9; // Set data rate and transmit power for uplink (note: txpow seems to be ignored by the library) LMIC_setDrTxpow(DR_SF7, 14); // Start job. processJob(&sendjob); }

无效循环()/ /运行一遍又一遍地{os_runloop_once ();字符c = GPS.read ();如果(GPSECHO) {(c){并(c);}}/ /如果收到一个句子,解析它如果(GPS.newNMEAreceived()){如果(! GPS.parse (GPS.lastNMEA())) / /还设置newNMEAreceived()标记为false返回;}}

空白GetSensorData () {digitalWrite (SOIL_POWER_PIN、高);延迟(1000);myMoisture = analogRead (SOIL_PIN);digitalWrite (SOIL_POWER_PIN、低);双氢睾酮temperatureF =。readTemperature(真正的);系列。println(“水分”+字符串(myMoisture) +“临时工”+字符串(temperatureF));如果(GPS.fix){系列。打印(“位置:”); Serial.print( GPS.latitudeDegrees * 100, 4 ); Serial.print( " break " ); Serial.print( GPS.lat ); Serial.print( ", " ); Serial.print( GPS.longitudeDegrees * 100 , 4 ); Serial.println( GPS.lon ); myLatitude = GPS.latitudeDegrees * 10000; myLongitude = GPS.longitudeDegrees * 10000; } }

空白onEvent (ev_t ev){并(os_getTime ());系列。打印(“:”);开关(ev){案例EV_SCAN_TIMEOUT:以(F (“EV_SCAN_TIMEOUT”));打破;案例EV_BEACON_FOUND:以(F (“EV_BEACON_FOUND”));打破;案例EV_BEACON_MISSED:以(F (“EV_BEACON_MISSED”));打破;案例EV_BEACON_TRACKED:以(F (“EV_BEACON_TRACKED”)); break; case EV_JOINING: Serial.println(F("EV_JOINING")); break; case EV_JOINED: Serial.println(F("EV_JOINED")); break; case EV_JOIN_FAILED: Serial.println(F("EV_JOIN_FAILED")); break; case EV_REJOIN_FAILED: Serial.println(F("EV_REJOIN_FAILED")); break; case EV_TXCOMPLETE: Serial.println(F("EV_TXCOMPLETE (includes waiting for RX windows)")); if (LMIC.txrxFlags & TXRX_ACK) Serial.println(F("Received ack")); if (LMIC.dataLen) { Serial.println(F("Received ")); Serial.println(LMIC.dataLen); Serial.println(F(" bytes of payload")); } // Schedule next transmission os_setTimedCallback(&sendjob, os_getTime() + sec2osticks(TX_INTERVAL), do_send); break; case EV_LOST_TSYNC: Serial.println(F("EV_LOST_TSYNC")); break; case EV_RESET: Serial.println(F("EV_RESET")); break; case EV_RXCOMPLETE: // data received in ping slot Serial.println(F("EV_RXCOMPLETE")); break; case EV_LINK_DEAD: Serial.println(F("EV_LINK_DEAD")); break; case EV_LINK_ALIVE: Serial.println(F("EV_LINK_ALIVE")); break; case EV_TXSTART: Serial.println(F("EV_TXSTART")); break; default: Serial.print(F("Unknown event: ")); Serial.println((unsigned)ev); break; } }

空白processJob (osjob_t * j) {getSensorData ();如果(LMIC。opmode & OP_TXRXPEND) / /检查是否有当前TX / RX工作运行。{系列。println (F (“OP_TXRXPEND,不发送”));其他}{负载[0]=字节(柜台);有效载荷柜台[1]= > > 8;负载[2]=字节(myMoisture);负载[3]= myMoisture > > 8;int shiftTemp = int (temperatureF * 100); // Convet temperature float to integer for sending and save two places. payload[4] = byte(shiftTemp); payload[5] = shiftTemp >> 8; payload[6] = byte(myLatitude); payload[7] = myLatitude >> 8; payload[8] = myLatitude >> 16; payload[9] = byte(myLongitude); payload[10] = myLongitude >> 8; payload[11] = myLongitude >> 16; LMIC_setTxData2(1, payload, sizeof(payload) - 1, 0); // Prepare upstream data transmission at the next possible time. counter++; Serial.println(String(counter)); } // Next TX is scheduled after TX_COMPLETE event.