Diff: main.cpp

Revision:

16:847c028f4130

Parent:

15:04b37f329c84

Child:

17:b60549bc8626

--- a/main.cpp	Thu Aug 25 12:58:12 2016 +0000
+++ b/main.cpp	Thu Feb 16 14:43:17 2017 +0000
@@ -1,56 +1,108 @@
+#include "mbed.h"
+//#include "DataLoggerRS232.h"
 #include "mbed.h"
 #include "mDot.h"
 #include "MTSLog.h"
 #include <string>
 #include <vector>
 #include <algorithm>
+#include <math.h>
 
+#define RETURN_OK              0
+#define RETURN_ERR            -1
+//define baudrate
+#define PC_BAUDRATE            115200
+#define CARD_MACHINE_BAUDRATE  19200
 
-const char TURNON[]  = "ON";
-const char TURNOFF[] = "OFF";
+#define COMMAND_LENGTH         7
+#define RESPONSE_LENGTH        16
+#define RINGBUFFER_SIZE        100
+
+#define READ_PERIOD            1
+#define SEND_PERIOD            5
+
+const char readCmd[COMMAND_LENGTH] = {0x09,0x41,0x31,0x46,0x33,0x46,0x0d};
+
+char readBuf[RESPONSE_LENGTH] = {0};
+char ringBuffer[RINGBUFFER_SIZE][RESPONSE_LENGTH] = {0};
 
-bool cmpStr(char* str1, const char* str2, int len)
-{
-     int k;
-     for (k=0; k<len; k++){
-         if (str1[k] != str2[k]) return false;
-     }
-     return true;    
-}
+unsigned int inIndex  = 0;
+unsigned int outIndex = 0;
+
+/* functions prototype */
+void readCardID(void);
+void sendCardID(void);
+
+void my_strcpy(char *dst, char *src);
+void my_strclear(char *str, unsigned int len);
 
-DigitalOut Alarm(PB_0);
+int configNetwork(void);
+int joinNetwork(void);
+int send_data(char *str);
 
-//defined for mDot SVB debug, comment it if applying for whole system
-//#define NO_MULTITECH_GATEWAY
+/* Global variables */
+Serial pc       (USBTX, USBRX);  // tx, rx
+Serial cm_rs485 (PA_2,PA_3);     // tx, rx
 
-// these options must match the settings on your Conduit
-// uncomment the following lines and edit their values to match your configuration
+mDot* dot;
+
 static std::string config_network_name = "chinaiot";
 static std::string config_network_pass = "password";
 static uint8_t config_frequency_sub_band = 2; 
 
-int main() {
+int main() 
+{    
+    int32_t ret;
+
+    pc.baud(PC_BAUDRATE);
+    pc.printf("\n\r\n\r\n\r");
+    pc.printf("============================================\n\r");
+    pc.printf("SiFOX remote card read system!\n\r");
+    pc.printf("============================================\n\r");
+    pc.printf("PC COM RS232 baudrate: %d \n\r", PC_BAUDRATE);
+    cm_rs485.baud(CARD_MACHINE_BAUDRATE);
+    cm_rs485.format(9,SerialBase::Even,1);
+    pc.printf("Card Machine RS485 baudrate: %d!\n\r", CARD_MACHINE_BAUDRATE);
+
+    //*******************************************
+    // Configurate Network
+    //*******************************************
+    ret = configNetwork();
+    if(ret != RETURN_OK)         
+        dot->sleep(5, mDot::RTC_ALARM); //sleep a while and restart
+    
+    //*******************************************
+    // Join Network
+    //*******************************************
+    ret = joinNetwork();
+    if(ret != RETURN_OK)         
+        dot->sleep(5, mDot::RTC_ALARM); //sleep a while and restart
+   
+    pc.printf("Wait 15S or card machine booting...\n\r");
+    wait(15); 
+    
+    while(1) {
+        /* Read Card ID */
+        readCardID();
+        
+        /* Send Card ID to gateway */
+        sendCardID();
+        
+        /* wait a while */
+        wait(2);          
+    }
+}
+
+    
+int configNetwork(void)
+{
     int32_t ret; 
-    mDot* dot;
-    std::vector<uint8_t> sendData, recvData;
-    std::vector<uint8_t> sendData1,sendData2, sendData3, sendData4;
-    char recvBuf[11];
-    int send_failed;
-    int  i;
-    //bool alarm_on;
-    std::string data_str1 = "REQ1";
-    std::string data_str2 = "REQ2";
-    std::string data_str3 = "REQ3";
-    std::string data_str4 = "REQ4";
-    bool a1, a2, a3, a4;
+    
+    dot = mDot::getInstance();
     
- 
-    // get a mDot handle
-    dot = mDot::getInstance();
-
     // print library version information
-    logInfo("version: %s", dot->getId().c_str());
-
+    pc.printf("version: %s\n\r", dot->getId().c_str());
+    
     //*******************************************
     // configuration
     //*******************************************
@@ -65,214 +117,219 @@
     // frequency sub band is only applicable in the 915 (US) frequency band
     // if using a MultiTech Conduit gateway, use the same sub band as your Conduit (1-8) - the mDot will use the 8 channels in that sub band
     // if using a gateway that supports all 64 channels, use sub band 0 - the mDot will use all 64 channels
-    logInfo("setting frequency sub band");
+    pc.printf("Setting frequency sub band\n\r");
     if ((ret = dot->setFrequencySubBand(config_frequency_sub_band)) != mDot::MDOT_OK) {
-        logError("failed to set frequency sub band %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
+        pc.printf("Error:failed to set frequency sub band %d:%s\n\r", ret, mDot::getReturnCodeString(ret).c_str());
+        return RETURN_ERR;
     }
 
-    logInfo("setting network name");
+    pc.printf("Setting network name\n\r");
     if ((ret = dot->setNetworkName(config_network_name)) != mDot::MDOT_OK) {
-        logError("failed to set network name %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
+        pc.printf("Error:failed to set network name %d:%s\n\r", ret, mDot::getReturnCodeString(ret).c_str());
+        return RETURN_ERR;
     }
 
-    logInfo("setting network password");
+    pc.printf("Setting network password\n\r");
     if ((ret = dot->setNetworkPassphrase(config_network_pass)) != mDot::MDOT_OK) {
-        logError("failed to set network password %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
+        pc.printf("Error:failed to set network password %d:%s\n\r", ret, mDot::getReturnCodeString(ret).c_str());
+        return RETURN_ERR;
     }
-
+    
     // a higher spreading factor allows for longer range but lower throughput
     // in the 915 (US) frequency band, spreading factors 7 - 10 are available
     // in the 868 (EU) frequency band, spreading factors 7 - 12 are available
-    logInfo("setting TX spreading factor");
+    pc.printf("Setting TX spreading factor\n\r");
     if ((ret = dot->setTxDataRate(mDot::SF_10)) != mDot::MDOT_OK) {
-        logError("failed to set TX datarate %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
+        pc.printf("Error:failed to set TX datarate %d:%s\n\r", ret, mDot::getReturnCodeString(ret).c_str());
+        return RETURN_ERR;
     }
 
     // request receive confirmation of packets from the gateway
-    logInfo("enabling ACKs");
+    pc.printf("Enabling ACKs\n\r");
     if ((ret = dot->setAck(1)) != mDot::MDOT_OK) {
-        logError("failed to enable ACKs %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
+        pc.printf("Error:failed to enable ACKs %d:%s\n\r", ret, mDot::getReturnCodeString(ret).c_str());
+        return RETURN_OK;
     }
 
     // save this configuration to the mDot's NVM
-    logInfo("saving config");
+    pc.printf("Saving config\n\r");
     if (! dot->saveConfig()) {
-        logError("failed to save configuration");
+        pc.printf("Error:failed to save configuration\n\r");
     }
-    //*******************************************
-    // end of configuration
-    //*******************************************
-
-    // attempt to join the network
-    logInfo("joining network");
-    while ((ret = dot->joinNetwork()) != mDot::MDOT_OK) {
-        logError("failed to join network %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
-        // in the 868 (EU) frequency band, we need to wait until another channel is available before transmitting again
-        osDelay(std::max((uint32_t)1000, (uint32_t)dot->getNextTxMs()));
-    }
-   
-    // format data for sending to the gateway
-    for (std::string::iterator it = data_str1.begin(); it != data_str1.end(); it++)
-        sendData1.push_back((uint8_t) *it);
     
-    // format data for sending to the gateway
-    for (std::string::iterator it = data_str2.begin(); it != data_str2.end(); it++)
-        sendData2.push_back((uint8_t) *it);
-        
-    // format data for sending to the gateway
-    for (std::string::iterator it = data_str3.begin(); it != data_str3.end(); it++)
-        sendData3.push_back((uint8_t) *it);
+    return RETURN_OK;
+}   // end of configuration
 
-    // format data for sending to the gateway
-    for (std::string::iterator it = data_str4.begin(); it != data_str4.end(); it++)
-        sendData4.push_back((uint8_t) *it);
-        
-    send_failed = 0;              
-    while (true) {         
-            // send the data to the gateway
-            if ((ret = dot->send(sendData1)) != mDot::MDOT_OK) {
-               send_failed++; 
-               logError("failed to send", ret, mDot::getReturnCodeString(ret).c_str());
-               osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-            } else { 
-                send_failed=0;            
-                logInfo("successfully sent data to gateway");  
-                for(i=0;i<11;i++)recvBuf[i]=0; //clear recv buffer
-                recvData.clear(); //clear recv data
-                if ((ret = dot->recv(recvData)) != mDot::MDOT_OK) {
-                   logError("failed to recv: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
-                } else {
-                   //logInfo("datasize = %d", recvData.size());
-                   for(i=0; i< recvData.size(); i++ )
-                     recvBuf[i] = recvData[i];
-                   //logInfo("RECV:%s", recvBuf);
-                   if(cmpStr(recvBuf, TURNON, 2)){
-                      a1 = true;
-                      logInfo("A1 is on!"); 
-                    } 
-                    if(cmpStr(recvBuf, TURNOFF, 3)){
-                      a1 = false;
-                      logInfo("A1 is off!"); 
-                    }    
-                } 
-            }
-            
-            osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
 
-            // send the data to the gateway
-            if ((ret = dot->send(sendData2)) != mDot::MDOT_OK) {
-               send_failed++; 
-               logError("failed to send", ret, mDot::getReturnCodeString(ret).c_str());
-               osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-            } else { 
-                send_failed=0;            
-                logInfo("successfully sent data to gateway");  
-                for(i=0;i<11;i++)recvBuf[i]=0; //clear recv buffer
-                recvData.clear(); //clear recv data
-                if ((ret = dot->recv(recvData)) != mDot::MDOT_OK) {
-                   logError("failed to recv: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
-                } else {
-                   //logInfo("datasize = %d", recvData.size());
-                   for(i=0; i< recvData.size(); i++ )
-                     recvBuf[i] = recvData[i];
-                   //logInfo("RECV:%s", recvBuf);
-                   if(cmpStr(recvBuf, TURNON, 2)){
-                      a2 = true;
-                      logInfo("A2 is on!"); 
-                    } 
-                    if(cmpStr(recvBuf, TURNOFF, 3)){
-                      a2 = false;
-                      logInfo("A2 is off!"); 
-                    }    
-                } 
-            }
-            
-            osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-
-            // send the data to the gateway
-            if ((ret = dot->send(sendData3)) != mDot::MDOT_OK) {
-               send_failed++; 
-               logError("failed to send", ret, mDot::getReturnCodeString(ret).c_str());
-               osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-            } else { 
-                send_failed=0;            
-                logInfo("successfully sent data to gateway");  
-                for(i=0;i<11;i++)recvBuf[i]=0; //clear recv buffer
-                recvData.clear(); //clear recv data
-                if ((ret = dot->recv(recvData)) != mDot::MDOT_OK) {
-                   logError("failed to recv: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
-                } else {
-                   //logInfo("datasize = %d", recvData.size());
-                   for(i=0; i< recvData.size(); i++ )
-                     recvBuf[i] = recvData[i];
-                   //logInfo("RECV:%s", recvBuf);
-                   if(cmpStr(recvBuf, TURNON, 2)){
-                      a3 = true;
-                      logInfo("A3 is on!"); 
-                    } 
-                    if(cmpStr(recvBuf, TURNOFF, 3)){
-                      a3 = false;
-                      logInfo("A3 is off!"); 
-                    }    
-                } 
-            }
-            
-            osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-            
-            // send the data to the gateway
-            if ((ret = dot->send(sendData4)) != mDot::MDOT_OK) {
-               send_failed++; 
-               logError("failed to send", ret, mDot::getReturnCodeString(ret).c_str());
-               osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-            } else { 
-                send_failed=0;            
-                logInfo("successfully sent data to gateway");  
-                for(i=0;i<11;i++)recvBuf[i]=0; //clear recv buffer
-                recvData.clear(); //clear recv data
-                if ((ret = dot->recv(recvData)) != mDot::MDOT_OK) {
-                   logError("failed to recv: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
-                } else {
-                   //logInfo("datasize = %d", recvData.size());
-                   for(i=0; i< recvData.size(); i++ )
-                     recvBuf[i] = recvData[i];
-                   //logInfo("RECV:%s", recvBuf);
-                   if(cmpStr(recvBuf, TURNON, 2)){
-                      a4 = true;
-                      logInfo("A4 is on!"); 
-                    } 
-                    if(cmpStr(recvBuf, TURNOFF, 3)){
-                      a4 = false;
-                      logInfo("A4 is off!"); 
-                    }    
-                } 
-            }
-            osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-            
-            if(a1 || a2 || a3 || a4){
-                logInfo("============================");
-                logInfo("Alarm is ON");
-                Alarm = 1;
-            }else{
-                logInfo("============================");
-                logInfo("Alarm is OFF");
-                Alarm = 0;
-            }
-            
-            osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-                         
-        
-        if(send_failed>=3){
-           send_failed=0;           
-           // attempt to rejoin the network
-           logInfo("Attemp to rejoin network....");
-           if ((ret = dot->joinNetworkOnce()) != mDot::MDOT_OK) {
-                logError("Failed to rejoin network!"); // %d:%s", ret, mDot::getReturnCodeString(ret).c_str());
-           }else{
-                logInfo("Rejoin network successfully!");   
-           } 
-           osDelay(std::max((uint32_t)5000, (uint32_t)dot->getNextTxMs()));
-        }
-        
+int joinNetwork(void)
+{    
+    int32_t ret,i; 
+    std::vector<uint8_t> sendData;
+    char _header[] = "ChongQi!";
+    
+    // attempt to join the network
+    pc.printf("Joining network...\n\r");
+    
+    while ((ret = dot->joinNetwork()) != mDot::MDOT_OK) {
+        pc.printf("Error: failed to join network %d:%s\n\r", ret, mDot::getReturnCodeString(ret).c_str());
+        // in the 868 (EU) frequency band, we need to wait until another channel is available before transmitting again
+        return RETURN_ERR;
     }
 
+    sendData.clear(); 
+    // format data for sending to the gateway
+    for( i=0; i< strlen(_header); i++ )
+               sendData.push_back( _header[i] );
+               
+    // send the data to the gateway
+    pc.printf("Send header to the gateway\n\r");
+
+    if ((ret = dot->send(sendData)) != mDot::MDOT_OK) {
+        pc.printf("Error: failed to send %d:%s\n\r", ret, mDot::getReturnCodeString(ret).c_str());
+        return RETURN_ERR;
+    } else {
+        pc.printf("Successfully sent data to gateway\n\r");
+    } 
+    
+    return RETURN_OK;
 }
+
+int send_data(char *str)
+{
+    int32_t i, ret;
+    std::vector<uint8_t> sendData;
+    
+    //Send the data to Gateway
+    sendData.clear();   
+    // probably not the most efficent way to do this
+    for(i=0; i< strlen(str); i++ )
+        sendData.push_back(str[i] );
+        
+    // send the data to the gateway
+    pc.printf("Send %s to Gateway \n\r", str); 
+    
+    if ((ret = dot->send(sendData)) != mDot::MDOT_OK) {
+        pc.printf("Error:failed to send\n\r", ret, mDot::getReturnCodeString(ret).c_str());
+        return RETURN_ERR;
+    } else {            
+        pc.printf("Sent data to gateway successfully!\n\r");
+    }
+    return RETURN_OK;
+}
+
+
+void my_strcpy(char *dst, char *src)
+{
+    int j=0;
+    
+    while(src[j] != 0)
+    {
+        dst[j] = src[j];
+        j++;
+    }       
+}
+
+
+void my_strclear(char *str, unsigned int len)
+{
+    unsigned int j;
+    for(j=0; j<len; j++)str[j]=0;  
+}
+
+
+void readCardID(void)
+{
+      unsigned int i;
+      char chr;
+      
+      //pc.printf("Read Tick!\n\r");
+      
+      /* clear the read buffer */
+      my_strclear(readBuf, RESPONSE_LENGTH);
+        
+      pc.printf("Send the READ command!\n\r");//, &readCmd[1]);
+      if(cm_rs485.writeable()){
+            for(i=0; i<COMMAND_LENGTH; i++){
+               cm_rs485.putc(readCmd[i]);
+            }            
+      }
+      
+      /* read the response */
+      chr = cm_rs485.getc();
+      i = 0;
+      while(chr != 0x0d)
+      {
+            readBuf[i] = chr;
+            i++;
+            chr = cm_rs485.getc();
+      }  
+        
+      /* print the response for debug */
+      pc.printf("Response[ASCII]:");
+        
+      for(i=0; i< RESPONSE_LENGTH; i++){
+           pc.printf("%0X ", readBuf[i]);
+           if (readBuf[i] == 0) break;
+      } 
+      pc.printf("Response[Text]:%s\n\r", &readBuf[3]);
+      
+      /* add to ringBuffer if valid */
+    if((readBuf[3] != 0) && (readBuf[4] != 0)){ 
+      if((readBuf[3]!= '3') && (readBuf[4] !='C')) //valid response
+      {
+          my_strcpy(ringBuffer[inIndex], &readBuf[3]); //strim the 3 bytes prehead
+          //pc.printf("addr = 0x%0X, inIndex = %d\n\r", &ringBuffer[inIndex],inIndex);
+          inIndex++;
+          if(inIndex >= RINGBUFFER_SIZE) inIndex = 0;
+          if(ringBuffer[inIndex][0] != 0)  //is not empty
+          {
+              pc.printf("Warning! Ringbuffer overflow at [%d]!\n\r", inIndex);
+              pc.printf("Please have a check of the network!\n\r");
+              pc.printf("Data in ring buffer:\n\r");
+              for(i=0; i<RINGBUFFER_SIZE; i++)
+              {
+                  pc.printf("Data[%d]: %s \n\r", i, ringBuffer[i]);
+              }
+              
+              wait(10); //in seconds
+          }
+      }
+    }
+}
+
+void sendCardID(void)
+{
+    int32_t ret;
+    
+    //pc.printf("Send Tick!\n\r");
+    /*send the data */
+    if(ringBuffer[outIndex][0] != 0) //not empty
+    {
+        pc.printf("Send dada[%s] to Gateway!\n\r", ringBuffer[outIndex]);
+      #ifndef NO_MULTITECH_GATEWAY  
+        /* t.b.d : send data though LoRA */
+        if(send_data(ringBuffer[outIndex]) != RETURN_OK)
+        {
+           pc.printf("Failed to send data to netwotk!\n\r");
+           pc.printf("Rejoin network and try one more time!\n\r");
+                       // attempt to rejoin the network
+           pc.printf("Attemp to rejoin network....\n\r");
+           if ((ret = dot->joinNetworkOnce()) != mDot::MDOT_OK) {
+                pc.printf("Failed to rejoin network! %d:%s \n\r", ret, mDot::getReturnCodeString(ret).c_str());
+                return;
+           }else{
+                pc.printf("Rejoin network successfully!");
+                if(send_data(ringBuffer[outIndex]) != RETURN_OK) return;  //abort to send       
+           } 
+        }
+       #endif 
+        //clear the buffer
+        my_strclear(ringBuffer[outIndex], RESPONSE_LENGTH);
+        outIndex++;
+        if(outIndex >= RINGBUFFER_SIZE)outIndex = 0;
+    }else{ //empty
+        pc.printf("Nothing to send!\n\r");
+        //wait(10);
+    }
+    
+}
\ No newline at end of file