COM.LTE Module(SIM7600G)でデータ送信ができません
-
タイトル
M5stack basicを用いて、COM.LTE Module(SIM7600G)によりデータ送信をする方法がわかりません。
詳しい状況の説明
Arduino言語により、m5stack basicを用いたCOM.LTE Module(SIM7600G)の簡易的な通信システムを制作しています。
データはGoogleスプレッドシートに表示させたいと考えています。
wifi通信を用いた場合では、意図した通りにGoogleスプレッドシートにデータが表示されました。ところが、COM Xを用いた際には表示されないため困っています。
通信強度とインターネット接続状況を確認するために、
COM.LTEModule(SIM7600G)の公式HPよりArduino Example Code
（https://docs.m5stack.com/en/module/comx_lte）
に記載されていたサンプルコードを用いました。ATコマンドを用いたプログラムのため、ネットワークの登録状況を確認するコマンドの「AT＋CREG?」を使用しました。結果は
AT＋CREG?
＋CREG?：0,3
OKとなったためインターネットには接続できていると考えています。
ですがデータ通信を行うことができませんでした。
wifi通信を用いた場合ではGoogleスプレッドシートにデータが表示されました。データ送信はHTTPリクエストのPOST通信を使用。以下の記事を参考にしました。
（https://msr-r.net/m5stack-googlesheets/）COM XのLTEを用いた形でデータ送信を完成させたいと考えておりますが
どのようにすれば良いのかアドバイスをいただけないでしょうか。使用しているUIFlowやArduinoライブラリのバージョン
- Arduino IDE 2.3.3
コード
[M5stack basic のコード]
#include <M5Stack.h>
#include <stdint.h>
#include <vector>
#include "TFTTerminal.h"#include <WiFi.h> //serial通信のinclude
#include <WiFiMulti.h>
#include <HTTPClient.h>
#include <ArduinoJson.h>TFT_eSprite Disbuff = TFT_eSprite(&M5.Lcd);
TFT_eSprite TerminalBuff = TFT_eSprite(&M5.Lcd);
TFTTerminal terminal(&TerminalBuff);
TaskHandle_t xhandle_lte_event = NULL;
SemaphoreHandle_t command_list_samap;const int capacity = JSON_OBJECT_SIZE(2); //serial通信をする
StaticJsonDocument<capacity> json_request;
char buffer[255];
const char url = "＊＊＊＊＊";
unsigned long counter = 0;
unsigned long tick = 0;
const char data = "Hello World";const String sim_apn = "ppsim.jp";
const String sim_user = "pp@sim";
const String sim_pass = "jpn";typedef enum {
kQUERY_MO = 0,
KTEST_MO,
kASSIGN_MO,
kACTION_MO,
kQUERY_MT,
kTEST_MT,
kASSIGN_MT,
kACTION_MT,
kINFORM
} LTEMsg_t;typedef enum {
kErrorSendTimeOUT = 0xe1,
kErrorReError = 0xe2,
kErroeSendError = 0xe3,
kSendReady = 0,
kSending = 1,
kWaitforMsg = 2,
kWaitforRead = 3,
kReOK
} LTEState_t;struct ATCommand {
uint8_t command_type;
String str_command;
uint16_t send_max_number;
uint16_t max_time;
uint8_t state;
String read_str;
uint16_t _send_count;
uint16_t _send_time_count;} user;
using namespace std;
vector<ATCommand> serial_at;
String zmmi_str;
void LTEModuleTask(void* arg) {
int Number = 0;
String restr;
while (1) {
xSemaphoreTake(command_list_samap, portMAX_DELAY);if (Serial2.available() != 0) { String str = Serial2.readString(); restr += str; if (restr.indexOf("\r\n") != -1) { } if (restr.indexOf("+ZMMI:") != -1) { zmmi_str = restr; } else if ((restr.indexOf("OK") != -1) || (restr.indexOf("ERROR") != -1)) { Serial.print(restr); if (restr.indexOf("OK") != -1) { if ((serial_at[0].command_type == kACTION_MO) || (serial_at[0].command_type == kASSIGN_MO)) { serial_at.erase(serial_at.begin()); Serial.printf("erase now %d\n", serial_at.size()); } else { serial_at[0].read_str = restr; serial_at[0].state = kWaitforRead; } } else if (restr.indexOf("ERROR") != -1) { serial_at[0].state = kErrorReError; } else { } restr.clear(); } } if (serial_at.empty() != true) { Number = 0; switch (serial_at[0].state) { case kSendReady: Serial.printf(serial_at[0].str_command.c_str()); Serial2.write(serial_at[0].str_command.c_str()); serial_at[0].state = kSending; break; case kSending: if (serial_at[0]._send_time_count > 0) { serial_at[0]._send_time_count--; } else { serial_at[0].state = kWaitforMsg; } /* code */ break; case kWaitforMsg: if (serial_at[0]._send_count > 0) { serial_at[0]._send_count--; serial_at[0]._send_time_count = serial_at[0].max_time; Serial.printf(serial_at[0].str_command.c_str()); Serial2.write(serial_at[0].str_command.c_str()); restr.clear(); serial_at[0].state = 1; } else { serial_at[0].state = kErrorSendTimeOUT; } /* code */ break; case kWaitforRead: /* code */ break; case 4: /* code */ break; case kErrorSendTimeOUT: /* code */ break; case 0xe2: /* code */ break; default: break; } } xSemaphoreGive(command_list_samap); delay(10); }}
void AddMsg(String str, uint8_t type, uint16_t sendcount, uint16_t sendtime) {
struct ATCommand newcommand;
newcommand.str_command = str;
newcommand.command_type = type;
newcommand.max_time = sendtime;
newcommand.send_max_number = sendcount;
newcommand.state = 0;
newcommand._send_count = sendcount;
newcommand._send_time_count = sendtime;
xSemaphoreTake(command_list_samap, portMAX_DELAY);
serial_at.push_back(newcommand);
xSemaphoreGive(command_list_samap);
}uint8_t readSendState(uint32_t number) {
xSemaphoreTake(command_list_samap, portMAX_DELAY);
uint8_t restate = serial_at[number].state;
xSemaphoreGive(command_list_samap);
return restate;
}uint32_t getATMsgSize() {
xSemaphoreTake(command_list_samap, portMAX_DELAY);
uint32_t restate = serial_at.size();
xSemaphoreGive(command_list_samap);
return restate;
}
String ReadMsgstr(uint32_t number) {
xSemaphoreTake(command_list_samap, portMAX_DELAY);
String restate = serial_at[number].read_str;
xSemaphoreGive(command_list_samap);
return restate;
}bool EraseFirstMsg() {
xSemaphoreTake(command_list_samap, portMAX_DELAY);
serial_at.erase(serial_at.begin());
xSemaphoreGive(command_list_samap);
return true;
}uint16_t GetstrNumber(String Str, uint32_t* ptrbuff) {
uint16_t count = 0;
String Numberstr;
int indexpos = 0;
while (Str.length() > 0) {
indexpos = Str.indexOf(",");
if (indexpos != -1) {
Numberstr = Str.substring(0, Str.indexOf(","));
Str = Str.substring(Str.indexOf(",") + 1, Str.length());
ptrbuff[count] = Numberstr.toInt();
count++;
} else {
ptrbuff[count] = Str.toInt();
count++;
break;
}
}
return count;
}
vector<String> restr_v;
uint16_t GetstrNumber(String StartStr, String EndStr, String Str) {
uint16_t count = 0;
String Numberstr;
int indexpos = 0;Str = Str.substring(Str.indexOf(StartStr) + StartStr.length(), Str.indexOf(EndStr)); Str.trim(); restr_v.clear(); while (Str.length() > 0) { indexpos = Str.indexOf(","); if (indexpos != -1) { Numberstr = Str.substring(0, Str.indexOf(",")); Str = Str.substring(Str.indexOf(",") + 1, Str.length()); restr_v.push_back(Numberstr); count++; } else { restr_v.push_back(Numberstr); ; count++; break; } } return count;}
String getReString(uint16_t Number) {
if (restr_v.empty()) {
return String("");
}
return restr_v.at(Number);
}uint16_t GetstrNumber(String StartStr, String EndStr, String Str,
uint32_t* ptrbuff) {
uint16_t count = 0;
String Numberstr;
int indexpos = 0;Str = Str.substring(Str.indexOf(StartStr) + StartStr.length(), Str.indexOf(EndStr)); Str.trim(); while (Str.length() > 0) { indexpos = Str.indexOf(","); if (indexpos != -1) { Numberstr = Str.substring(0, Str.indexOf(",")); Str = Str.substring(Str.indexOf(",") + 1, Str.length()); ptrbuff[count] = Numberstr.toInt(); count++; } else { ptrbuff[count] = Str.toInt(); count++; break; } } return count;}
uint32_t numberbuff[128];
String readstr;bool isLTEConnected() {
AddMsg("AT+CREG?\r\n", kQUERY_MT, 1000, 1000);
while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) {
delay(50);
}
String response = ReadMsgstr(0);
EraseFirstMsg();// CREG応答が「+CREG: 0,1」「+CREG: 0,2」「+CREG: 0,3」であれば、ネットワークに登録されている if (response.indexOf("+CREG: 0,1") != -1 || response.indexOf("+CREG: 0,2") != -1 || response.indexOf("+CREG: 0,3") != -1 ) { terminal.println("LTE connected to network."); return true; } else { terminal.println("LTE not connected to network."); return false; }}
bool isInternetConnected() {
HTTPClient http;// GoogleのURLで接続確認 if (!http.begin("http://www.google.com")) { terminal.println("HTTPClient init failed"); return false; } int httpCode = http.GET(); // GETリクエストを送信 if (httpCode == 200) { terminal.println("Internet is connected."); http.end(); return true; } else { terminal.printf("Internet connection failed. HTTP Code: %d\n", httpCode); http.end(); return false; }}
uint8_t restate;
void setup() {
// put your setup code here, to run once:
M5.begin(true, true, true, false);
Serial2.begin(115200, SERIAL_8N1, 5, 13);Disbuff.createSprite(320, 20); Disbuff.fillRect(0, 0, 320, 20, BLACK); Disbuff.drawRect(0, 0, 320, 20, Disbuff.color565(36, 36, 36)); Disbuff.pushSprite(0, 0); TerminalBuff.createSprite(120, 220); TerminalBuff.fillRect(0, 0, 120, 220, BLACK); TerminalBuff.drawRect(0, 0, 120, 220, Disbuff.color565(36, 36, 36)); TerminalBuff.pushSprite(0, 20); terminal.setGeometry(0, 20, 120, 220); pinMode(2, OUTPUT); digitalWrite(2, 0); Disbuff.setTextColor(WHITE); Disbuff.setTextSize(1); for (int i = 0; i < 100; i++) { Disbuff.fillRect(0, 0, 320, 20, Disbuff.color565(36, 36, 36)); Disbuff.pushSprite(0, 0); Disbuff.setCursor(7, 7); Disbuff.printf("Reset Module %02d", i); Disbuff.pushSprite(0, 0); delay(10); } digitalWrite(2, 1); xTaskCreate(LTEModuleTask, "LTEModuleTask", 1024 * 2, (void*)0, 4, &xhandle_lte_event); command_list_samap = xSemaphoreCreateMutex(); xSemaphoreGive(command_list_samap); AddMsg("AT+CSQ\r\n", kQUERY_MT, 1000, 1000); while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) delay(50); restate = readSendState(0); readstr = ReadMsgstr(0).c_str(); EraseFirstMsg(); terminal.print(readstr); AddMsg("AT+CREG?\r\n", kQUERY_MT, 1000, 1000); while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) delay(50); restate = readSendState(0); readstr = ReadMsgstr(0).c_str(); EraseFirstMsg(); terminal.print(readstr); AddMsg("AT+CGDCONT = 1, \"IP\", \"ppsim.jp\"\r\n", kASSIGN_MT, 1000, 1000); while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) delay(50); restate = readSendState(0); readstr = ReadMsgstr(0).c_str(); EraseFirstMsg(); terminal.print(readstr); AddMsg("AT+CGAUTH = 1, \"pp@sim\", \"jpn\"\r\n", kASSIGN_MT, 1000, 1000); while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) delay(50); restate = readSendState(0); readstr = ReadMsgstr(0).c_str(); EraseFirstMsg(); terminal.print(readstr); // LTE接続確認 if (isLTEConnected()) { // インターネット接続確認 if (isInternetConnected()) { terminal.println("SIM card is connected to the internet."); } else { terminal.println("SIM card is not connected to the internet."); } } else { terminal.println("No LTE network connection."); }}
void loop() {
M5.update();if (M5.BtnA.wasPressed()) { terminal.println("A button OK"); counter++; tick = millis(); json_request["counter"] = counter; json_request["tick"] = tick; serializeJson(json_request, Serial); Serial.println(""); serializeJson(json_request, buffer, sizeof(buffer)); terminal.println(buffer); delay(500); HTTPClient http; if (!http.begin(url)) { terminal.println("HTTPClient init failed"); return; // 接続失敗の場合は処理を中断 } http.addHeader("Content-Type", "application/json"); delay(500); terminal.println("post ready"); int status_code = http.POST((uint8_t*)buffer, strlen(buffer)); Serial.printf("status_code=%d\r\n", status_code); if (status_code != 200) { terminal.printf("HTTP POST failed, status code: %d\n", status_code); } else { Stream* resp = http.getStreamPtr(); DynamicJsonDocument json_response(255); deserializeJson(json_response, *resp); serializeJson(json_response, Serial); Serial.println(); } http.end(); } /* if (M5.BtnB.wasPressed()) { delay(1000); esp_sleep_enable_timer_wakeup(10000); esp_sleep_enable_ext0_wakeup((gpio_num_t)M5.BtnA.wasPressed(), 0); esp_deep_sleep_start(); } */ if (M5.BtnC.wasPressed()) { while(1){ AddMsg("AT+CSQ\r\n", kQUERY_MT, 1000, 1000); while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) delay(50); restate = readSendState(0); readstr = ReadMsgstr(0).c_str(); EraseFirstMsg(); terminal.print(readstr); AddMsg("AT+CREG?\r\n", kQUERY_MT, 1000, 1000); while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) delay(50); restate = readSendState(0); readstr = ReadMsgstr(0).c_str(); EraseFirstMsg(); terminal.print(readstr); delay(500); M5.update(); if (M5.BtnA.wasPressed()) { AddMsg("ATD13800088888;\r\n", kQUERY_MT, 1000, 1000); while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) delay(50); Serial.printf("Read state = %d \n", readSendState(0)); readstr = ReadMsgstr(0).c_str(); Serial.print(readstr); while (1) { M5.update(); if (M5.BtnA.wasPressed()) break; delay(100); } EraseFirstMsg(); AddMsg("AT+CHUP\r\n", kASSIGN_MO, 1000, 1000); } if (M5.BtnB.wasPressed()) { delay(1000); esp_sleep_enable_timer_wakeup(10000); esp_sleep_enable_ext0_wakeup((gpio_num_t)M5.BtnA.wasPressed(), 0); esp_deep_sleep_start(); } } }}
[Googleスプレッドシートのコード]
function doGet(e) {
let id = '＊＊＊＊＊';
let sheetName = 'シート1';
var result;if (e.parameter == undefined) { result = 'Parameter undefined'; } else { var sheet = SpreadsheetApp.openById(id).getSheetByName(sheetName); var newRow = sheet.getLastRow() + 1; var rowData = []; rowData[0] = new Date(); rowData[1] = e.parameter.chipid; rowData[2] = e.parameter.val0; rowData[3] = e.parameter.val1; rowData[4] = e.parameter.val2; var newRange = sheet.getRange(newRow, 1, 1, rowData.length); newRange.setValues([rowData]); result = 'Ok'; } return ContentService.createTextOutput(result);}
ターミナルコマンド [シリアルモニタ] `` command `` OK AT+CSQ AT+CSQ AT+CSQ +CSQ: 20,99 OK AT+CREG? +CREG: 0,3 OK AT+CGDCONT = 1, "IP", "ppsin.jp" OK AT+CGAUTH = 1, "pp@sin", "jpn" ERROR AT+CREG? +CREG: 0,3 OK ("counter":1,"tick":98705] status_code=-1 [M５stack basic の画面] `` command `` OK +CREG: 0,3 OK OK LTE connected to net work. Internet connection failed. HTTP Code:-1 SIM card is not connected to the internet. A button OK ("counter" : 1, "tick" : 98705) post ready HTTP POST failed, status code : -1 -
データ通信を行うことができたので、共有させていただきます。
SIM7600のデータシートを参照し、通信を行うことができました。
COM.LTE Module(SIM7600G)を使用することで、長距離におけるデータ伝送が可能です。使用する方がいましたら、参考にしてください。
Va10, Va11, Va12にセンサで取得したデータを代入することで、
観測機器を製作できます。[ M5stack Basic code ]
#include <M5Stack.h> #include <stdint.h> #include <vector> #include "TFTTerminal.h" /*serial通信のinclude #include <WiFi.h> #include <WiFiMulti.h> #include <HTTPClient.h> #include <ArduinoJson.h> */ TFT_eSprite Disbuff = TFT_eSprite(&M5.Lcd); TFT_eSprite TerminalBuff = TFT_eSprite(&M5.Lcd); TFTTerminal terminal(&TerminalBuff); TaskHandle_t xhandle_lte_event = NULL; SemaphoreHandle_t command_list_samap; uint32_t numberbuff[128]; String readstr; uint8_t restate; char buffer[255]; uint32_t interval = 1; // unit:sec uint16_t chipid = ESP.getEfuseMac() % 10000; const char* deployid = "AKfycbw1vfUnV_E6B9O0tWaKMPKXkvahMsXIG-jrpk2SS2a1kGAAz59iQy1_p_H7kp7x8VnKsg"; const char *send_url = "https://script.google.com/macros/s/AKfycbyMcbm5u-ySil5s6LF6__EyyAVYMt9idkIRBaRBWk3ut3jR3A9VFe7lobGQE9qdBHuR/exec"; unsigned long counter = 0; unsigned long tick = 0; const char* data = "Hello World"; const String sim_apn = "ppsim.jp"; const String sim_user = "pp@sim"; const String sim_pass = "jpn"; typedef enum { kQUERY_MO = 0, KTEST_MO, kASSIGN_MO, kACTION_MO, kQUERY_MT, kTEST_MT, kASSIGN_MT, kACTION_MT, kINFORM } LTEMsg_t; typedef enum { kErrorSendTimeOUT = 0xe1, kErrorReError = 0xe2, kErroeSendError = 0xe3, kSendReady = 0, kSending = 1, kWaitforMsg = 2, kWaitforRead = 3, kReOK } LTEState_t; struct ATCommand { uint8_t command_type; String str_command; uint16_t send_max_number; uint16_t max_time; uint8_t state; String read_str; uint16_t _send_count; uint16_t _send_time_count; } user; using namespace std; vector<ATCommand> serial_at; String zmmi_str; void LTEModuleTask(void* arg) { int Number = 0; String restr; while (1) { xSemaphoreTake(command_list_samap, portMAX_DELAY); if (Serial2.available() != 0) { String str = Serial2.readString(); restr += str; if (restr.indexOf("\r\n") != -1) { } if (restr.indexOf("+ZMMI:") != -1) { zmmi_str = restr; } else if ((restr.indexOf("OK") != -1) || (restr.indexOf("ERROR") != -1)) { Serial.print(restr); if (restr.indexOf("OK") != -1) { if ((serial_at[0].command_type == kACTION_MO) || (serial_at[0].command_type == kASSIGN_MO)) { serial_at.erase(serial_at.begin()); Serial.printf("erase now %d\n", serial_at.size()); } else { serial_at[0].read_str = restr; serial_at[0].state = kWaitforRead; } } else if (restr.indexOf("ERROR") != -1) { serial_at[0].state = kErrorReError; } else { } restr.clear(); } } if (serial_at.empty() != true) { Number = 0; switch (serial_at[0].state) { case kSendReady: Serial.printf(serial_at[0].str_command.c_str()); Serial2.write(serial_at[0].str_command.c_str()); serial_at[0].state = kSending; break; case kSending: if (serial_at[0]._send_time_count > 0) { serial_at[0]._send_time_count--; } else { serial_at[0].state = kWaitforMsg; } /* code */ break; case kWaitforMsg: if (serial_at[0]._send_count > 0) { serial_at[0]._send_count--; serial_at[0]._send_time_count = serial_at[0].max_time; Serial.printf(serial_at[0].str_command.c_str()); Serial2.write(serial_at[0].str_command.c_str()); restr.clear(); serial_at[0].state = 1; } else { serial_at[0].state = kErrorSendTimeOUT; } /* code */ break; case kWaitforRead: /* code */ break; case 4: /* code */ break; case kErrorSendTimeOUT: /* code */ break; case 0xe2: /* code */ break; default: break; } } xSemaphoreGive(command_list_samap); delay(10); } } void AddMsg(String str, uint8_t type, uint16_t sendcount, uint16_t sendtime) { struct ATCommand newcommand; newcommand.str_command = str; newcommand.command_type = type; newcommand.max_time = sendtime; newcommand.send_max_number = sendcount; newcommand.state = 0; newcommand._send_count = sendcount; newcommand._send_time_count = sendtime; xSemaphoreTake(command_list_samap, portMAX_DELAY); serial_at.push_back(newcommand); xSemaphoreGive(command_list_samap); while ((readSendState(0) == kSendReady) || (readSendState(0) == kSending) || (readSendState(0) == kWaitforMsg)) delay(50); restate = readSendState(0); readstr = ReadMsgstr(0).c_str(); EraseFirstMsg(); terminal.print(readstr); } uint8_t readSendState(uint32_t number) { xSemaphoreTake(command_list_samap, portMAX_DELAY); uint8_t restate = serial_at[number].state; xSemaphoreGive(command_list_samap); return restate; } uint32_t getATMsgSize() { xSemaphoreTake(command_list_samap, portMAX_DELAY); uint32_t restate = serial_at.size(); xSemaphoreGive(command_list_samap); return restate; } String ReadMsgstr(uint32_t number) { xSemaphoreTake(command_list_samap, portMAX_DELAY); String restate = serial_at[number].read_str; xSemaphoreGive(command_list_samap); return restate; } bool EraseFirstMsg() { xSemaphoreTake(command_list_samap, portMAX_DELAY); serial_at.erase(serial_at.begin()); xSemaphoreGive(command_list_samap); return true; } uint16_t GetstrNumber(String Str, uint32_t* ptrbuff) { uint16_t count = 0; String Numberstr; int indexpos = 0; while (Str.length() > 0) { indexpos = Str.indexOf(","); if (indexpos != -1) { Numberstr = Str.substring(0, Str.indexOf(",")); Str = Str.substring(Str.indexOf(",") + 1, Str.length()); ptrbuff[count] = Numberstr.toInt(); count++; } else { ptrbuff[count] = Str.toInt(); count++; break; } } return count; } vector<String> restr_v; uint16_t GetstrNumber(String StartStr, String EndStr, String Str) { uint16_t count = 0; String Numberstr; int indexpos = 0; Str = Str.substring(Str.indexOf(StartStr) + StartStr.length(), Str.indexOf(EndStr)); Str.trim(); restr_v.clear(); while (Str.length() > 0) { indexpos = Str.indexOf(","); if (indexpos != -1) { Numberstr = Str.substring(0, Str.indexOf(",")); Str = Str.substring(Str.indexOf(",") + 1, Str.length()); restr_v.push_back(Numberstr); count++; } else { restr_v.push_back(Numberstr); ; count++; break; } } return count; } String getReString(uint16_t Number) { if (restr_v.empty()) { return String(""); } return restr_v.at(Number); } uint16_t GetstrNumber(String StartStr, String EndStr, String Str, uint32_t* ptrbuff) { uint16_t count = 0; String Numberstr; int indexpos = 0; Str = Str.substring(Str.indexOf(StartStr) + StartStr.length(), Str.indexOf(EndStr)); Str.trim(); while (Str.length() > 0) { indexpos = Str.indexOf(","); if (indexpos != -1) { Numberstr = Str.substring(0, Str.indexOf(",")); Str = Str.substring(Str.indexOf(",") + 1, Str.length()); ptrbuff[count] = Numberstr.toInt(); count++; } else { ptrbuff[count] = Str.toInt(); count++; break; } } return count; } //データ送信プログラム void addRowToGoogleSheetsdoGet(float val0, float val1, float val2) { //URL //String url = "https://script.google.com/macros/s/" + String(deployid) + "/exec?chipid=ESP" + String(chipid) + "&val0=" + String(val0) + "&val1=" + String(val1) + "&val2=" + String(val2); String url = String(send_url) + "?chipid=ESP" + String(chipid) + "&val0=" + String(val0) + "&val1=" + String(val1) + "&val2=" + String(val2); terminal.println("[HTTP] begin..."); terminal.println(url); terminal.println("[HTTP] POST..."); // コンテンツタイプの設定 AddMsg("AT+HTTPPARA=\"CONTENT\",\"application/json\"\r\n", kASSIGN_MT, 1000, 1000); // AT commmand : URLの設定 & http post（今回はURLにデータを追加している） AddMsg("AT+HTTPPARA=\"URL\",\"" + url + "\"\r\n", kASSIGN_MT, 1000, 1000); delay(1000); terminal.println("[HTTP] GET..."); // HTTP GET リクエスト AddMsg("AT+HTTPACTION=0\r\n", kASSIGN_MT, 5000, 5000); delay(1000); } //データdopost送信プログラム void addRowToGoogleSheetsdoPost(float val0, float val1, float val2) { //URL //String url = "https://script.google.com/macros/s/" + String(deployid) + "/exec?chipid=ESP" + String(chipid) + "&val0=" + String(val0) + "&val1=" + String(val1) + "&val2=" + String(val2); //String url = String(send_url) + "?chipid=ESP" + String(chipid) + "&val0=" + String(val0) + "&val1=" + String(val1) + "&val2=" + String(val2); String jsonPayload = "{\"chipid\":\"ESP" + String(chipid) + "\", \"val0\":" + String(val0) + ", \"val1\":" + String(val1) + ", \"val2\":" + String(val2) + "}"; terminal.println("[HTTP] begin..."); terminal.println("[HTTP] POST..."); // HTTPヘッダーを設定 AddMsg("AT+HTTPPARA=\"URL\",\"" + String(send_url) + "\"\r\n", kASSIGN_MT, 1000, 1000); AddMsg("AT+HTTPPARA=\"CONTENT\",\"application/json\"\r\n", kASSIGN_MT, 1000, 1000); // データを送信 AddMsg("AT+HTTPDATA=" + String(jsonPayload.length()) + ",10000\r\n", kASSIGN_MT, 1000, 1000); delay(100); AddMsg(jsonPayload + "\r\n", kASSIGN_MT, 1000, 1000); delay(100); AddMsg("AT+HTTPACTION=1\r\n", kASSIGN_MT, 5000, 5000); delay(1000); terminal.println("[HTTP] GET..."); // HTTP GET リクエスト AddMsg("AT+HTTPACTION=0\r\n", kASSIGN_MT, 5000, 5000); delay(1000); } void setup() { // put your setup code here, to run once: M5.begin(true, true, true, false); //LCD, SDカード, serial, I2Cの有効無効 Serial2.begin(115200, SERIAL_8N1, 5, 13); Disbuff.createSprite(320, 20); Disbuff.fillRect(0, 0, 320, 20, BLACK); Disbuff.drawRect(0, 0, 320, 20, Disbuff.color565(36, 36, 36)); Disbuff.pushSprite(0, 0); TerminalBuff.createSprite(120, 220); TerminalBuff.fillRect(0, 0, 120, 220, BLACK); TerminalBuff.drawRect(0, 0, 120, 220, Disbuff.color565(36, 36, 36)); TerminalBuff.pushSprite(0, 20); terminal.setGeometry(0, 20, 120, 220); pinMode(2, OUTPUT); digitalWrite(2, 0); Disbuff.setTextColor(WHITE); Disbuff.setTextSize(1); for (int i = 0; i < 100; i++) { Disbuff.fillRect(0, 0, 320, 20, Disbuff.color565(36, 36, 36)); Disbuff.pushSprite(0, 0); Disbuff.setCursor(7, 7); Disbuff.printf("Reset Module %02d", i); Disbuff.pushSprite(0, 0); delay(10); } digitalWrite(2, 1); xTaskCreate(LTEModuleTask, "LTEModuleTask", 1024 * 2, (void*)0, 4, &xhandle_lte_event); command_list_samap = xSemaphoreCreateMutex(); xSemaphoreGive(command_list_samap); terminal.println("Initializing SIM7600..."); // モジュール起動確認 AddMsg("AT\r\n", kQUERY_MT, 1000, 1000); // 機能の追加（フルモード） AddMsg("AT+CFUN=1\r\n", kQUERY_MT, 1000, 1000); // LTE接続 AddMsg("AT+CGATT=1\r\n", kQUERY_MT, 1000, 1000); // 通信強度 AddMsg("AT+CSQ\r\n", kQUERY_MT, 1000, 1000); // インターネット登録状況 AddMsg("AT+CREG?\r\n", kQUERY_MT, 1000, 1000); // APN設定 AddMsg("AT+CGDCONT = 1, \"IP\", \"" + sim_apn + "\"\r\n", kASSIGN_MT, 1000, 1000); // 認証情報の設定 : 無くても良い //AddMsg("AT+CGAUTH = 1, \"" + sim_user + "\", \"" + sim_pass + "\"\r\n", kASSIGN_MT, 1000, 1000); // PDPコンテキスト有効化 AddMsg("AT+CGACT=1,1\r\n", kQUERY_MT, 1000, 1000); // HTTP機能の初期化 AddMsg("AT+HTTPINIT\r\n", kQUERY_MT, 1000, 1000); // PDPコンテキストを設定 AddMsg("AT+HTTPPARA=\"CID\",1\r\n", kQUERY_MT, 1000, 1000); } void loop() { M5.update(); float val0 = random(0, 1000) / 10.0; float val1 = random(0, 1000) / 10.0; float val2 = random(0, 1000) / 10.0; terminal.print("ESP"); terminal.println(chipid); terminal.printf("[val0] %.1f\n[val1] %.1f\n[val2] %.1f\n", val0, val1, val2); addRowToGoogleSheetsdoGet(val0, val1, val2); //addRowToGoogleSheetsdoPost(val0, val1, val2); delay(interval * 1000); if (M5.BtnC.wasPressed()) { terminal.println("Restarting..."); delay(1000); esp_restart(); // ESP32をリセット } delay(1000); esp_sleep_enable_timer_wakeup(10000); esp_sleep_enable_ext0_wakeup((gpio_num_t)M5.BtnA.wasPressed(), 0); esp_deep_sleep_start(); } /*本来のhttp post方法（仮）----------------------------------------------------- // URL を設定 AddMsg("AT+HTTPPARA=\"URL\",\"" + url + "\"\r\n", kASSIGN_MT, 1000, 1000); // コンテンツのタイプを設定（JSON 例） AddMsg("AT+HTTPPARA=\"CONTENT\",\"application/json\"\r\n", kASSIGN_MT, 1000, 1000); // 送信データの準備（例：50バイトのデータを10秒以内に送信） AddMsg("AT+HTTPDATA=50,10000\r\n", kASSIGN_MT, 1000, 1000); delay(100); // 少し待機 // 送信する JSON データを設定（例） AddMsg("{\"temperature\":25.5,\"humidity\":60}\r\n", kASSIGN_MT, 1000, 1000); delay(100); // HTTP POST を開始 AddMsg("AT+HTTPACTION=1\r\n", kASSIGN_MT, 1000, 1000); delay(5000); // 応答待機 // レスポンスを取得（HTTP GET） AddMsg("AT+HTTPREAD\r\n", kASSIGN_MT, 1000, 1000); --------------------------------------------------------------------------------*/[ Google Spread Sheet code ]
function doGet(e) { Logger.log("Received GET request: " + JSON.stringify(e)); var sheet = SpreadsheetApp.getActiveSpreadsheet().getSheetByName('シート1'); if (!sheet) { return ContentService.createTextOutput("Error: Sheet not found").setMimeType(ContentService.MimeType.TEXT); } // パラメータを取得 var chipid = e.parameter.chipid || "Unknown"; var val0 = parseFloat(e.parameter.val0) || 0; var val1 = parseFloat(e.parameter.val1) || 0; var val2 = parseFloat(e.parameter.val2) || 0; // スプレッドシートにデータを記録 sheet.insertRowBefore(2); sheet.getRange(2, 1).setValue(new Date()); // 受信日時 sheet.getRange(2, 2).setValue(chipid); sheet.getRange(2, 3).setValue(val0); sheet.getRange(2, 4).setValue(val1); sheet.getRange(2, 5).setValue(val2); return ContentService.createTextOutput("Data received successfully").setMimeType(ContentService.MimeType.TEXT); }以下は本プログラムの動作及び、システム構成です。
Hello! It looks like you're interested in this conversation, but you don't have an account yet.
Getting fed up of having to scroll through the same posts each visit? When you register for an account, you'll always come back to exactly where you were before, and choose to be notified of new replies (either via email, or push notification). You'll also be able to save bookmarks and upvote posts to show your appreciation to other community members.
With your input, this post could be even better 💗
Register Login