Using Camera module, FTP Client on WIZwiki-W7500, send the image data to FTP Server.
Dependencies: CameraC328 SDFileSystem WIZnetInterface mbed-src
Fork of Camera_FTP_WIZwiki-W7500 by
Prerequisite
This example send the image data acquired from the camera to an FTP Server.
To implement this function, you need a Platform board, network Interface board, camera module.
Available camera modules are C328, LJ-DSC02. Because the cameras listed above all have similar internal protocols.
This example uses LJ-DSC02.
- WIZwiki-W7500 from WIZnet (Platform board and Ethernet I/F board)
- LJ-DSC02 (Camera module)
- FTP Server(AL FTP)
- Micro SD Card
Hardware Configuration
- connect Ethernet Cable & USB Cable
- connect Camera module
Software
Init FTP Server information
static char ID[]={"abc"}; //Set FTPServer Login ID static char PASSWORD[]={"123"}; //Set FTPServer Login Password const char ftpServer_control_ip_addr[] = "192.168.1.2";
Caution
Must fix FTP server ip, id, pass
main.cpp
- Committer:
- Ricky_Kwon
- Date:
- 2017-04-12
- Revision:
- 5:5cc3d57c04f8
- Parent:
- 4:573ca8ea6629
File content as of revision 5:5cc3d57c04f8:
#include "mbed.h" #include "SDFileSystem.h" #include "EthernetInterface.h" #include "CameraC328.h" /* CAMERA */ #define USE_JPEG_HIGH_RESOLUTION 3 //1=80x64 <--- not working -_-;;, 2=160x128, 3=320x240, 4=640x480 /* FTP */ #define USER "user " #define PASS "pass " #define PASV "pasv " #define PORT "port " #define LIST "list " #define STOR "stor " #define RETR "retr " #define END "\r\n" #define FTP_SERVER_PORT 21 #define MAX_SS 256 bool gDataSockReady = false; bool gDataPutGetStart = false; bool ftpclientrun = false; int remote_port; char ftpServer_data_ip_addr[4]={0,}; char ftpServer_data_ip_addr_str[20]={0,}; static char buf[256]; static char ID[]={"abc"}; //Set FTPServer Login ID static char PASSWORD[]={"123"}; //Set FTPServer Login Password enum CommandFirst { f_nocmd, f_put, }; enum CommandSecond { s_nocmd, s_put, }; enum ftpc_datasock_state{ DATASOCK_IDLE, DATASOCK_READY, DATASOCK_START }; struct Command { enum CommandFirst First; enum CommandSecond Second; }; struct ftpc { enum ftpc_datasock_state dsock_state; }; struct ftpc FTPClient; struct Command FTPCommand; /* SD Card filesystem */ SDFileSystem sd(PB_3, PB_2, PB_1, PB_0, "sd"); // WIZwiki-W7500 static FILE *fp_jpeg; char fname[32]; char fname_server[16]; char fnamecnt=0; /* UART */ Serial pc(USBTX, USBRX); char gMsgBuf[10]; char User_Keyboard_MSG_Cnt; /* CAMERA */ CameraC328 camera(PA_13, PA_14, CameraC328::Baud115200); /* Function*/ char* User_Keyboard_MSG(void); int pportc(char * arg); void jpeg_callback(char *buf, size_t siz); void sync(void); void test_jpeg_snapshot_picture(void); int main() { char Msg_c; int remain_filesize; int send_byte; pc.baud(115200); pc.printf("Hello Home Security World!\r\n"); uint8_t mac_addr[6] = {0x00, 0x08, 0xdc, 0x12, 0x34, 0x45}; const char ip_addr[] = "192.168.0.123"; const char mask_addr[] = "255.255.255.0"; const char gateway_addr[] = "192.168.0.1"; const char ftpServer_control_ip_addr[] = "192.168.0.2"; EthernetInterface eth; eth.init(mac_addr, ip_addr, mask_addr, gateway_addr); //Use Static eth.connect(); TCPSocketConnection FTP_CONTROL_SOCK; TCPSocketConnection FTP_DATA_SOCK; sync(); //while 1 while(true) { pc.printf("\r\n----------------------------------------\r\n"); pc.printf("Press menu key\r\n"); pc.printf("----------------------------------------\r\n"); pc.printf("1> Snapshot Picture and Send FTPServer\r\n"); pc.printf("----------------------------------------\r\n"); Msg_c = pc.getc(); if(Msg_c==0x31){ test_jpeg_snapshot_picture(); ftpclientrun = true; while(ftpclientrun){ //while 2 while(!FTP_CONTROL_SOCK.is_connected()){ pc.printf("Connecting...FTPServer\r\nIP:%s, PORT:%d\r\n", ftpServer_control_ip_addr, FTP_SERVER_PORT); FTP_CONTROL_SOCK.connect(ftpServer_control_ip_addr, FTP_SERVER_PORT); FTP_CONTROL_SOCK.set_blocking(false, 15000); // Timeout after (1.5)s }//end of while 2 //while 3 while(true) { //gDataSockReady if if(gDataSockReady){ gDataSockReady = false; //FTPCommand.First switch case switch(FTPCommand.First){ case f_put: FTP_CONTROL_SOCK.send(STOR, sizeof(STOR)-1); FTP_CONTROL_SOCK.send(fname_server, sizeof(fname_server)); FTP_CONTROL_SOCK.send(END, sizeof(END)-1); break; }//end of FTPCommand.First switch case }//end of gDataSockReady if /* received from FTPServer */ int n = FTP_CONTROL_SOCK.receive(buf, sizeof(buf)); if (n <= 0) break; buf[n] = '\0'; pc.printf("\r\nReceived message from server: '%s'\r\n", buf); //buf if if (!strncmp(buf, "220", 3)){ FTP_CONTROL_SOCK.send(USER, sizeof(USER)-1); FTP_CONTROL_SOCK.send(ID, sizeof(ID)); FTP_CONTROL_SOCK.send(END, sizeof(END)-1); } else if(!strncmp(buf, "331", 3)){ FTP_CONTROL_SOCK.send(PASS, sizeof(PASS)-1); FTP_CONTROL_SOCK.send(PASSWORD, sizeof(PASSWORD)); FTP_CONTROL_SOCK.send(END, sizeof(END)-1); } else if(!strncmp(buf, "230", 3)){ FTP_CONTROL_SOCK.send(PASV, sizeof(PASV)-1); FTP_CONTROL_SOCK.send(END, sizeof(END)-1); FTPCommand.First = f_put; } else if(!strncmp(buf, "227", 3)){ if (pportc(buf) == -1){ pc.printf("Bad port syntax\r\n"); } else{ pc.printf("Go Open Data Sock...\r\n "); FTPClient.dsock_state = DATASOCK_READY; } } else if(!strncmp(buf, "150", 3)){ switch(FTPCommand.First){ case f_put: FTPCommand.First = f_nocmd; FTPCommand.Second = s_put; gDataPutGetStart = true; break; } } else if(!strncmp(buf, "226", 3)){ ftpclientrun = false; FTP_CONTROL_SOCK.close(); }//end of buf if //DATASOCK_READY if if(FTPClient.dsock_state == DATASOCK_READY){ while(!FTP_DATA_SOCK.is_connected()){ pc.printf("Connecting...FTPServer Data sock\r\nIP:%s, PORT:%d\r\n", ftpServer_data_ip_addr_str, remote_port); FTP_DATA_SOCK.connect(ftpServer_control_ip_addr, remote_port); FTP_DATA_SOCK.set_blocking(false, 15000); // Timeout after (1.5)s } FTPClient.dsock_state = DATASOCK_IDLE; gDataSockReady = true; }//end of DATASOCK_READY if //gDataPutGetStart if if(gDataPutGetStart){ //FTPCommand.Second switch case switch(FTPCommand.Second){ case s_put: pc.printf("put waiting...\r\n"); fp_jpeg = fopen(fname, "r"); fseek(fp_jpeg, 0, SEEK_END); // seek to end of file remain_filesize = ftell(fp_jpeg); // get current file pointer fseek(fp_jpeg, 0, SEEK_SET); // seek back to beginning of file do{ memset(buf, 0, sizeof(buf)); if(remain_filesize > MAX_SS) send_byte = MAX_SS; else send_byte = remain_filesize; fread (buf, 1, send_byte, fp_jpeg); FTP_DATA_SOCK.send(buf, send_byte); remain_filesize -= send_byte; pc.printf("#"); }while(remain_filesize!=0); fclose(fp_jpeg); gDataPutGetStart = false; FTPCommand.Second = s_nocmd; FTP_DATA_SOCK.close(); break; }//end of FTPCommand.Second switch case }//end of gDataPutGetStart if }//end of while 3 } } }//end of while 1 } char* User_Keyboard_MSG(void) { User_Keyboard_MSG_Cnt = 0; memset(gMsgBuf, 0, sizeof(gMsgBuf)); do{ gMsgBuf[User_Keyboard_MSG_Cnt] = pc.getc(); if(gMsgBuf[User_Keyboard_MSG_Cnt]==0x08){ User_Keyboard_MSG_Cnt--; } else{ User_Keyboard_MSG_Cnt++; } }while(gMsgBuf[User_Keyboard_MSG_Cnt-1]!=0x0d); return gMsgBuf; } int pportc(char * arg) { int i; char* tok=0; strtok(arg,"("); for (i = 0; i < 4; i++) { if(i==0) tok = strtok(NULL,",\r\n"); else tok = strtok(NULL,","); ftpServer_data_ip_addr[i] = (uint8_t)atoi(tok); if (!tok){ pc.printf("bad pport : %s\r\n", arg); return -1; } } remote_port = 0; for (i = 0; i < 2; i++){ tok = strtok(NULL,",\r\n"); remote_port <<= 8; remote_port += atoi(tok); if (!tok){ pc.printf("bad pport : %s\r\n", arg); return -1; } } pc.printf("ip : %d.%d.%d.%d, port : %d\r\n", ftpServer_data_ip_addr[0], ftpServer_data_ip_addr[1], ftpServer_data_ip_addr[2], ftpServer_data_ip_addr[3], remote_port); sprintf(ftpServer_data_ip_addr_str, "%d.%d.%d.%d", ftpServer_data_ip_addr[0], ftpServer_data_ip_addr[1], ftpServer_data_ip_addr[2], ftpServer_data_ip_addr[3]); return 0; } void jpeg_callback(char *buf, size_t siz) { for (int i = 0; i < (int)siz; i++) { fprintf(fp_jpeg, "%c", buf[i]); } } void sync(void) { CameraC328::ErrorNumber err = CameraC328::NoError; err = camera.sync(); if (CameraC328::NoError == err) { printf("[ OK ] : CameraC328::sync\r\n"); } else { printf("[FAIL] : CameraC328::sync (Error=%02X)\r\n", (int)err); } } void test_jpeg_snapshot_picture(void) { CameraC328::ErrorNumber err = CameraC328::NoError; #if (USE_JPEG_HIGH_RESOLUTION==1) err = camera.init(CameraC328::Jpeg, CameraC328::RawResolution80x60, CameraC328::JpegResolution80x64); #elif (USE_JPEG_HIGH_RESOLUTION==2) err = camera.init(CameraC328::Jpeg, CameraC328::RawResolution80x60, CameraC328::JpegResolution160x128); #elif (USE_JPEG_HIGH_RESOLUTION==3) err = camera.init(CameraC328::Jpeg, CameraC328::RawResolution80x60, CameraC328::JpegResolution320x240); #elif (USE_JPEG_HIGH_RESOLUTION==4) err = camera.init(CameraC328::Jpeg, CameraC328::RawResolution80x60, CameraC328::JpegResolution640x480); #endif if (CameraC328::NoError == err) { printf("[ OK ] : CameraC328::init\r\n"); } else { printf("[FAIL] : CameraC328::init (Error=%02X)\r\n", (int)err); } snprintf(fname, sizeof(fname), "/sd/jpss%04d.jpg", fnamecnt); fnamecnt++; for(int i = 0; i < 12; i++){ fname_server[0+i] = fname[4+i]; } fp_jpeg = fopen(fname, "w"); err = camera.getJpegSnapshotPicture(jpeg_callback); if (CameraC328::NoError == err) { printf("[ OK ] : CameraC328::getJpegSnapshotPicture\r\n"); } else { printf("[FAIL] : CameraC328::getJpegSnapshotPicture (Error=%02X)\r\n", (int)err); } fclose(fp_jpeg); }