tcp.ino 33 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184
  1. #include <ESP8266WiFi.h>
  2. #include "string.h"
  3. #include <string.h>
  4. #include <stdio.h>
  5. #include <SoftwareSerial.h>
  6. //串口缓存区改C:\Users\liuhao\AppData\Local\Arduino15\packages\esp8266\hardware\esp8266\2.7.4\cores\esp8266\HardwareSerial.cpp
  7. #ifndef D5
  8. #if defined(ESP8266)
  9. #define D5 (14)
  10. #define D6 (12)
  11. #define D7 (13)
  12. #define D8 (15)
  13. #define TX (1)
  14. #elif defined(ESP32)
  15. #define D5 (18)
  16. #define D6 (19)
  17. #define D7 (23)
  18. #define D8 (5)
  19. #define TX (1)
  20. #endif
  21. #endif
  22. #ifdef ESP32
  23. #define BAUD_RATE 9600
  24. #else
  25. #define BAUD_RATE 9600
  26. #endif
  27. // Reminder: the buffer size optimizations here, in particular the isrBufSize that only accommodates
  28. // a single 8N1 word, are on the basis that any char written to the loopback SoftwareSerial adapter gets read
  29. // before another write is performed. Block writes with a size greater than 1 would usually fail.
  30. SoftwareSerial swSer;
  31. //定义可连接的客户端数目最大值
  32. #define MAX_SRV_CLIENTS 3
  33. #define Serial_RX_MAXSIZE 256
  34. #define TCP_RX_MAXSIZE 256
  35. const char* ssid = "ESP8266";
  36. const char* password = "12345678";
  37. WiFiServer server(60000);
  38. WiFiClient serverClients[MAX_SRV_CLIENTS];
  39. unsigned char Serial_Buffer[Serial_RX_MAXSIZE]={0};
  40. uint32_t timeTick = 0;
  41. unsigned int buffUartIndex = 0;
  42. unsigned long preUartTick = 0;
  43. int LED_PIN=2;//GPIO2--D0 模块自带的led
  44. int connectedCnt=0;
  45. String Rxstr="";
  46. char getflag=0;
  47. char SendBuff[20]={0};
  48. int openCnt=0;
  49. int volt=0;
  50. /*****************使用摄像头发送宏开关*************************/
  51. #ifndef USING_CAMERA_FOR_MMS
  52. #define USING_CAMERA_FOR_MMS 1
  53. #endif
  54. /******************使用SD卡存储图片宏开关*************************/
  55. #ifndef USING_SAVE_SD
  56. #define USING_SAVE_SD 0
  57. #endif
  58. typedef unsigned char u8;
  59. typedef unsigned short int u16;
  60. typedef unsigned int u32;
  61. #define USART1_RECEIVE_BUFSIZE 100
  62. #define USART1_MAX_SIZE 96
  63. #define USART2_RECEIVE_BUFSIZE 2048
  64. #define USART2_MAX_SIZE 4996
  65. #define second 1000000
  66. #define L_TIME (1*second)
  67. #define Z_TIME (10*second)
  68. #define HH_TIME (90*second)
  69. #define H_TIME (30*second) //设置串口接收的等待时间
  70. //硬件引脚定义
  71. #define camer_pwerH() GPIO_SetBits(GPIOA,GPIO_Pin_1)
  72. #define camer_pwerL() GPIO_ResetBits(GPIOA,GPIO_Pin_1)
  73. //用户自定义宏变量
  74. //#define N_BYTE 512 //每次读取N_BYTE字节,N_BYTE必须是8的倍数
  75. #define N_BYTE 1024 //每次读取N_BYTE字节,N_BYTE必须是8的倍数
  76. //#define N_BYTE 224 //每次读取N_BYTE字节,N_BYTE必须是8的倍数/
  77. #define IMAGE_SIZE_160X120 0x22
  78. #define IMAGE_SIZE_320X240 0x11
  79. #define IMAGE_SIZE_640X480 0x00
  80. #define COMPRESS_RATE_36 0x36 //该压缩率是默认压缩率,160x120和320x240可用此压缩率
  81. #define COMPRESS_RATE_60 0x60 //640X480尺寸,默认压缩率36会占用45K左右的空间
  82. //选择60压缩率可将45K压缩到20K左右
  83. typedef enum
  84. {
  85. SERIAL_NUM_0 = 0x00,
  86. SERIAL_NUM_1,
  87. SERIAL_NUM_2,
  88. SERIAL_NUM_3,
  89. SERIAL_NUM_5,
  90. SERIAL_NUM_6,
  91. SERIAL_NUM_7,
  92. SERIAL_NUM_8,
  93. SERIAL_NUM_9,
  94. SERIAL_NUM_10
  95. }nSerialNum;
  96. //extern const nSerialNum SerialNum_Byte;
  97. //
  98. //extern u8 g_SerialNumber;
  99. //extern volatile u8 cameraReady;
  100. //extern u32 picLen;//图片长度
  101. //串口驱动接口函数,移植时需要修改接口函数
  102. void cam_write(const u8 *buf,u8 len);
  103. u16 cam_receiver( u8 *buf,u16 send_len);
  104. void server_sendByte(u8 *data,u32 len);
  105. // 应用实例函数
  106. u8 CameraDemoApp(u8 Serialnumber,u8 nCameraImageSize);
  107. u8 camera_init(u8 Serialnumber,u8 nSetImageSize);
  108. u8 send_cmd(const u8 *cmd,u8 n0,const u8 *rev,u8 n1);
  109. void SetSerailNumber(u8 *DstCmd, const u8 *SrcCmd, u8 SrcCmdLength,
  110. u8 *DstRcv, const u8 *SrcRcv, u8 SrcRcvLength,u8 nID);
  111. //摄像头属性设置:复位/图片尺寸大小/图片压缩率
  112. u8 send_reset(u8 Serialnumber);
  113. u8 current_photo_size(u8 Serialnumber,u8 * nImageSize);
  114. u8 send_photo_size(u8 Serialnumber,u8 nImageSize);
  115. u8 send_compress_rate(u8 Serialnumber,u8 nCompressRate);
  116. void UART1Write(char *data,u32 len) ;
  117. //移动侦测控制函数
  118. u8 send_motion_sensitivity(u8 Serialnumber);
  119. u8 send_open_motion(u8 Serialnumber);
  120. u8 send_close_motion(u8 Serialnumber);
  121. u8 Motion_Detecte_Idle(u8 *pSerialnumber);
  122. //拍照处理函数
  123. u8 send_photoBuf_cls(u8 Serialnumber);
  124. u8 send_start_photo(u8 Serialnumber);
  125. u32 send_read_len(u8 Serialnumber);
  126. u8 send_get_photo(u16 add,u16 read_len,u8 *buf,u8 Serialnumber);
  127. #define CLEAR_FRAME 1 //去掉返回图片数据携带的协议头和尾76 00 32 00
  128. #define ECHO_CMD_DEBUG_INFO 0 //1,开启指令调试;0,关闭
  129. #define ID_SERIAL_NUM 1 //序号在数组的所在位置
  130. //复位指令与复位回复
  131. const u8 reset_rsp[] = {0x76,0x00,0x26,0x00};
  132. const u8 reset_cmd[] = {0x56,0x00,0x26,0x00};
  133. //清除图片缓存指令与回复
  134. const u8 photoBufCls_cmd [] = {0x56,0x00,0x36,0x01,0x02};
  135. const u8 photoBufCls_rsp[] = {0x76,0x00,0x36,0x00,0x00};
  136. //拍照指令与回复
  137. const u8 start_photo_cmd[] = {0x56,0x00,0x36,0x01,0x00};
  138. const u8 start_photo_rsp[] = {0x76,0x00,0x36,0x00,0x00};
  139. //读图片长度指令与回复
  140. //图片长度指令回复的前7个字节是固定的,最后2个字节表示图片的长度
  141. //如0xA0,0x00,10进制表示是40960,即图片长度(大小)为40K
  142. const u8 read_len_cmd[] = {0x56,0x00,0x34,0x01,0x00};
  143. const u8 read_len_rsp[] = {0x76,0x00,0x34,0x00,0x04,0x00,0x00};
  144. //读图片数据指令与回复
  145. //get_photo_cmd前6个字节是固定的,
  146. //第9,10字节是图片的起始地址
  147. //第13,14字节是图片的末尾地址,即本次读取的长度
  148. //如果是一次性读取,第9,10字节的起始地址是0x00,0x00;
  149. //第13,14字节是图片长度的高字节,图片长度的低字节(如0xA0,0x00)
  150. //如果是分次读取,每次读N字节(N必须是8的倍数)长度,
  151. //则起始地址最先从0x00,0x00读取N长度(即N & 0xff00, N & 0x00ff),
  152. //后几次读的起始地址就是上一次读取数据的末尾地址
  153. const u8 get_photo_cmd [] = {0x56,0x00,0x32,0x0C,0x00,0x0A,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xFF };
  154. const u8 get_photo_rsp [] = {0x76,0x00,0x32,0x00,0x00};
  155. //设置压缩率指令与回复,最后1个字节为压缩率选项
  156. //范围是:00 - FF
  157. //默认压缩率是36
  158. const u8 set_compress_cmd [] = {0x56,0x00,0x31,0x05,0x01,0x01,0x12,0x04,0x36};
  159. const u8 compress_rate_rsp [] = {0x76,0x00,0x31,0x00,0x00};
  160. //设置图片尺寸指令与回复
  161. //set_photo_size_cmd最后1个字节的意义
  162. //0x22 - 160X120
  163. //0x11 - 320X240
  164. //0x00 - 640X480
  165. const u8 set_photo_size_cmd [] = {0x56,0x00,0x31,0x05,0x04,0x01,0x00,0x19,0x11};
  166. const u8 set_photo_size_rsp [] = {0x76,0x00,0x31,0x00,0x00 };
  167. //读取图片尺寸指令与回复
  168. //read_photo_size_rsp最后1个字节的意义
  169. //0x22 - 160X120
  170. //0x11 - 320X240
  171. //0x00 - 640X480
  172. const u8 read_photo_size_cmd [] = {0x56,0x00,0x30,0x04,0x04,0x01,0x00,0x19};
  173. const u8 read_photo_size_rsp [] = {0x76,0x00,0x30,0x00,0x01,0x00};
  174. //移动侦测指令
  175. //motion_enable_cmd 打开移动侦测
  176. //motion_disable_cmd 关闭移动侦测
  177. const u8 motion_enable_cmd [] = {0x56,0x00,0x37,0x01,0x01};
  178. const u8 motion_disable_cmd [] = {0x56,0x00,0x37,0x01,0x00};
  179. const u8 motion_rsp [] = {0x76,0x00,0x37,0x00,0x00};
  180. //当系统检测到有移动时,自动从串口输出motio_detecte
  181. const u8 motion_detecte [] = {0x76,0x00,0x39,0x00,0x00};
  182. //移动侦测灵敏度设置
  183. const u8 motion_sensitivity_cmd [] = {0x56,0x00,0x31,0x05,0x01,0x01,0x1A,0x6E,0x03};
  184. const u8 motion_sensitivity_rsp [] = {0x76,0x00,0x31,0x00,0x00};
  185. volatile u8 cameraReady = 0;
  186. u32 picLen = 0; //数据长度
  187. //CommandPacket和ResponsePacket用于拷贝只读区的指令及应答到内存
  188. u8 CommandPacket[16];
  189. u8 ResponsePacket[7];
  190. //const nSerialNum SerialNum_Byte;//序列号枚举变量
  191. u8 g_SerialNumber = 0;//串口上报移动侦测时保存的当前序列号
  192. u8 usa1_buf[USART1_RECEIVE_BUFSIZE] = {0};
  193. u8 gprs_buf[USART2_RECEIVE_BUFSIZE] = {0};
  194. void UART3Write(u8 *data,u32 len) //发送n个字符
  195. {
  196. Serial.write(&data[0],len);
  197. }
  198. void UART1Write(char *data,u32 len) //发送n个字符
  199. {
  200. u16 i;
  201. if( len == 0)
  202. {
  203. for(i = 0;data[i] != '\0';i++)
  204. {
  205. swSer.write(data[i]);
  206. }
  207. }
  208. else
  209. {
  210. for(i = 0;i < len;i++)
  211. {
  212. swSer.write(data[i]);
  213. }
  214. }
  215. }
  216. //等待接收数据 接收到的数据,接收到的个数等待接收的时间
  217. u16 UART3_Receiver_buf(u8 *data,u32 len,u32 time)
  218. {
  219. u16 i=0;
  220. u32 time0=0;
  221. while(1)
  222. {
  223. if(Serial.available() > 0) {
  224. data[i]=Serial.read();
  225. time0 = 0;
  226. i++;
  227. if( i == len && (len != 0) )
  228. {
  229. break;
  230. }
  231. yield();
  232. }else
  233. {
  234. if( time0 > 10000 )
  235. break;
  236. else
  237. time0++;
  238. }
  239. }
  240. return i;
  241. // u16 i=0;
  242. // u32 time0=0;
  243. // i = USART_ReceiveData(USART1);
  244. // while((USART_GetFlagStatus(USART1,USART_FLAG_RXNE)) == RESET)
  245. // {
  246. // delay_us(1);
  247. // time0++;
  248. // if( time0 > time)
  249. // {
  250. // return 0;
  251. // }
  252. // }
  253. // data[0] = USART_ReceiveData(USART1);
  254. // i = 1;
  255. // time0 = 0;
  256. // while(1)
  257. // {
  258. // if(USART_GetFlagStatus(USART1,USART_FLAG_RXNE) != RESET)
  259. // {
  260. // time0 = 0;
  261. // data[i] = USART_ReceiveData(USART1);
  262. // i++;
  263. // if( i == len && (len != 0) )
  264. // {
  265. // break;
  266. // }
  267. // }
  268. // else
  269. // {
  270. // if( time0 > 10000 )
  271. // break;
  272. // else
  273. // time0++;
  274. // }
  275. // }
  276. // return i;
  277. }
  278. /****************************************************************
  279. 函数名:SetSerailNumber
  280. 函数描述: 修改协议中的序号
  281. 输入参数:目标指令缓存首地址,源指令首地址,源指令长度,
  282. 目标应答缓存首地址,源应答首地址,源应答长度,需要修改的
  283. 序号值
  284. 返回:无
  285. ******************************************************************/
  286. void SetSerailNumber(u8 *DstCmd, const u8 *SrcCmd, u8 SrcCmdLength,
  287. u8 *DstRsp, const u8 *SrcRsp, u8 SrcRspLength,u8 nID)
  288. {
  289. memset(&CommandPacket,0,sizeof(CommandPacket));
  290. memset(&ResponsePacket,0,sizeof(ResponsePacket));
  291. memcpy(DstCmd,SrcCmd,SrcCmdLength);
  292. memcpy(DstRsp,SrcRsp,SrcRspLength);
  293. DstCmd[ID_SERIAL_NUM] = nID & 0xFF;
  294. DstRsp[ID_SERIAL_NUM] = nID & 0xFF;
  295. }
  296. /****************************************************************
  297. 函数名:cam_write
  298. 函数描述: 接口函数,写入控制摄像头的串口
  299. 输入参数:数据的首地址,长度
  300. 返回:无
  301. ******************************************************************/
  302. void cam_write(const u8 *buf,u8 len)
  303. {
  304. //需要调试时开启,观察打印的数据,这里使用串口2调试
  305. #if ECHO_CMD_DEBUG_INFO
  306. UART1Write("\r\n",0);
  307. UART1Write((u8 *)buf,len);
  308. UART1Write("\r\n",0);
  309. #endif
  310. //写串口驱动函数
  311. UART3Write((u8 *)buf,len);
  312. }
  313. /****************************************************************
  314. 函数名:cam_receiver
  315. 函数描述:接口函数,读取控制摄像头的串口
  316. 输出参数:接收数据的地址,长度
  317. 返回:接收到数据个数
  318. ******************************************************************/
  319. u16 cam_receiver(u8 *buf,u16 send_len)
  320. {
  321. u16 i = 0;
  322. i = UART3_Receiver_buf(buf,send_len,L_TIME);
  323. #if ECHO_CMD_DEBUG_INFO
  324. UART1Write("\r\n",0);
  325. UART1Write(buf,send_len);
  326. UART1Write("\r\n",0);
  327. #endif
  328. return i;
  329. }
  330. /****************************************************************
  331. 函数名:camera_init
  332. 函数描述:摄像头初始化
  333. 输入参数:序列号,需要设置的图片尺寸
  334. 返回:初始化成功返回1,初始化失败返回0
  335. ******************************************************************/
  336. u8 camera_init(u8 Serialnumber,u8 nSetImageSize)
  337. {
  338. u8 CurrentImageSize = 0xFF;
  339. u8 CurrentCompressRate = COMPRESS_RATE_36;
  340. //读取当前的图片尺寸到currentImageSize
  341. if ( !current_photo_size(Serialnumber,&CurrentImageSize))
  342. {
  343. UART1Write("\r\nread_photo_size error\r\n",0);
  344. return 0;
  345. }
  346. //判断是否需要修改图片尺寸
  347. if(nSetImageSize != CurrentImageSize)
  348. {
  349. //设置图片尺寸,设置后复位生效,该项设置后会永久保存
  350. if ( !send_photo_size(Serialnumber,nSetImageSize))
  351. {
  352. UART1Write("\r\nset_photo_size error\r\n",0);
  353. return 0;
  354. }
  355. else
  356. {
  357. //复位生效
  358. if ( !send_reset(Serialnumber))
  359. {
  360. UART1Write("\r\reset error\r\n",0);
  361. return 0;
  362. }
  363. delay(1000);
  364. CurrentImageSize = nSetImageSize;
  365. }
  366. }
  367. //给不同图片尺寸设置适当的图片压缩率
  368. if(nSetImageSize == CurrentImageSize)
  369. {
  370. switch(CurrentImageSize)
  371. {
  372. case IMAGE_SIZE_160X120:
  373. case IMAGE_SIZE_320X240:
  374. CurrentCompressRate = COMPRESS_RATE_36;
  375. break;
  376. case IMAGE_SIZE_640X480:
  377. CurrentCompressRate = COMPRESS_RATE_60;
  378. break;
  379. default:
  380. break;
  381. }
  382. }
  383. //设置图片压缩率,该项不保存,每次上电后需重新设置
  384. if ( !send_compress_rate(Serialnumber,CurrentCompressRate))
  385. {
  386. UART1Write("\r\nsend_compress_rate error\r\n",0);
  387. return 0;
  388. }
  389. //这里要注意,设置压缩率后要延时
  390. delay(100);
  391. return 1;
  392. }
  393. /****************************************************************
  394. 函数名:send_cmd
  395. 函数描述:发送指令并识别指令返回
  396. 输入参数:指令的首地址,指令的长度,匹配指令的首地址,需验证的个数
  397. 返回:成功返回1,失败返回0
  398. ******************************************************************/
  399. u8 send_cmd( const u8 *cmd,u8 n0,const u8 *rev,u8 n1)
  400. {
  401. u8 i;
  402. u8 tmp[5] = {0x00,0x00,0x00,0x00,0x00};
  403. cam_write(cmd, n0);
  404. if ( !cam_receiver(tmp,5) )
  405. {
  406. return 0;
  407. }
  408. //检验数据
  409. for (i = 0; i < n1; i++)
  410. {
  411. if (tmp[i] != rev[i])
  412. {
  413. return 0;
  414. }
  415. }
  416. return 1;
  417. }
  418. /****************************************************************
  419. 函数名:current_photo_size
  420. 函数描述:读取当前设置的图片尺寸
  421. 输入参数:Serialnumber序列号,nImageSize传递图片尺寸的引用变量
  422. 返回:成功返回1,失败返回0
  423. ******************************************************************/
  424. u8 current_photo_size(u8 Serialnumber,u8 * nImageSize)
  425. {
  426. u8 i;
  427. u8 tmp[6] = {0x00,0x00,0x00,0x00,0x00,0x00};
  428. SetSerailNumber( CommandPacket,
  429. read_photo_size_cmd,
  430. sizeof(read_photo_size_cmd),
  431. ResponsePacket,
  432. read_photo_size_rsp,
  433. sizeof(read_photo_size_rsp),
  434. Serialnumber );
  435. cam_write(CommandPacket, sizeof(read_photo_size_cmd));
  436. if ( !cam_receiver(tmp,6) )
  437. {
  438. return 0;
  439. }
  440. //检验数据,对比前5个字节
  441. for (i = 0; i < 5; i++)
  442. {
  443. if (tmp[i] != ResponsePacket[i])
  444. {
  445. return 0;
  446. }
  447. }
  448. //最后一个字节表示当前的图片大小
  449. *nImageSize = tmp[5];
  450. return 1;
  451. }
  452. /****************************************************************
  453. 函数名:send_photo_size
  454. 函数描述:设置拍照的图片尺寸(可选择:160X120,320X240,640X480)
  455. 输入参数:序列号,需要设置的图片尺寸
  456. 返回:成功返回1,失败返回0
  457. ******************************************************************/
  458. u8 send_photo_size(u8 Serialnumber,u8 nImageSize)
  459. {
  460. u8 i;
  461. SetSerailNumber( CommandPacket,
  462. set_photo_size_cmd,
  463. sizeof(set_photo_size_cmd),
  464. ResponsePacket,
  465. set_photo_size_rsp,
  466. sizeof(set_photo_size_rsp),
  467. Serialnumber );
  468. CommandPacket [sizeof(set_photo_size_cmd) - 1] = nImageSize;
  469. i = send_cmd( CommandPacket,
  470. sizeof(set_photo_size_cmd),
  471. ResponsePacket,
  472. sizeof(set_photo_size_rsp) );
  473. return i;
  474. }
  475. /****************************************************************
  476. 函数名:send_reset
  477. 函数描述:发送复位指令复位后要延时1-2秒
  478. 输入参数:序列号
  479. 返回:成功返回1 失败返回0
  480. ******************************************************************/
  481. u8 send_reset(u8 Serialnumber)
  482. {
  483. u8 i;
  484. //复制命令与应答,修改序号
  485. SetSerailNumber( CommandPacket,
  486. reset_cmd,
  487. sizeof(reset_cmd),
  488. ResponsePacket,
  489. reset_rsp,
  490. sizeof(reset_rsp),
  491. Serialnumber );
  492. i = send_cmd( CommandPacket,
  493. sizeof(reset_cmd),
  494. ResponsePacket,
  495. sizeof(reset_rsp) );
  496. return i;
  497. }
  498. /****************************************************************
  499. 函数名:send_stop_photo
  500. 函数描述:清空图片缓存
  501. 输入参数:序列号
  502. 返回:成功返回1,失败返回0
  503. ******************************************************************/
  504. u8 send_photoBuf_cls(u8 Serialnumber)
  505. {
  506. u8 i;
  507. SetSerailNumber( CommandPacket,
  508. photoBufCls_cmd,
  509. sizeof(photoBufCls_cmd),
  510. ResponsePacket,
  511. photoBufCls_rsp,
  512. sizeof(photoBufCls_rsp),
  513. Serialnumber );
  514. i = send_cmd( CommandPacket,
  515. sizeof(photoBufCls_cmd),
  516. ResponsePacket,
  517. sizeof(photoBufCls_rsp) );
  518. return i;
  519. }
  520. /****************************************************************
  521. 函数名:send_compress_rate
  522. 函数描述:发送设置图片压缩率
  523. 输入参数:序列号
  524. 返回:成功返回1,失败返回0
  525. ******************************************************************/
  526. u8 send_compress_rate(u8 Serialnumber,u8 nCompressRate)
  527. {
  528. u8 i;
  529. SetSerailNumber( CommandPacket,
  530. set_compress_cmd,
  531. sizeof(set_compress_cmd),
  532. ResponsePacket,
  533. compress_rate_rsp,
  534. sizeof(compress_rate_rsp),
  535. Serialnumber );
  536. if(nCompressRate > 0x36)
  537. {
  538. //最后一个字节表示压缩率
  539. CommandPacket [sizeof(set_compress_cmd) - 1] = nCompressRate;
  540. }
  541. i = send_cmd( CommandPacket,
  542. sizeof(set_compress_cmd),
  543. ResponsePacket,
  544. sizeof(compress_rate_rsp) );
  545. return i;
  546. }
  547. /****************************************************************
  548. 函数名:send_start_photo
  549. 函数描述:发送开始拍照的指令
  550. 输入参数:序列号
  551. 返回:识别成功返回1 失败返回0
  552. ******************************************************************/
  553. u8 send_start_photo(u8 Serialnumber)
  554. {
  555. u8 i;
  556. SetSerailNumber( CommandPacket,
  557. start_photo_cmd,
  558. sizeof(start_photo_cmd),
  559. ResponsePacket,
  560. start_photo_rsp,
  561. sizeof(start_photo_rsp),
  562. Serialnumber );
  563. i = send_cmd( CommandPacket,
  564. sizeof(start_photo_cmd),
  565. ResponsePacket,
  566. sizeof(start_photo_rsp) );
  567. return i;
  568. }
  569. /****************************************************************
  570. 函数名:send_read_len
  571. 函数描述:读取拍照后的图片长度,即图片占用空间大小
  572. 输入参数:序列号
  573. 返回:图片的长度
  574. ******************************************************************/
  575. u32 send_read_len(u8 Serialnumber)
  576. {
  577. u8 i;
  578. u32 len;
  579. u8 tmp[9];
  580. SetSerailNumber( CommandPacket,
  581. read_len_cmd,
  582. sizeof(read_len_cmd),
  583. ResponsePacket,
  584. read_len_rsp,
  585. sizeof(read_len_rsp),
  586. Serialnumber );
  587. //发送读图片长度指令
  588. cam_write(CommandPacket, 5);
  589. if ( !cam_receiver(tmp,9))
  590. {
  591. return 0;
  592. }
  593. //检验数据
  594. for (i = 0; i < 7; i++)
  595. {
  596. if ( tmp[i] != ResponsePacket[i])
  597. {
  598. return 0;
  599. }
  600. }
  601. len = (u32)tmp[7] << 8;//高字节
  602. len |= tmp[8];//低字节
  603. return len;
  604. }
  605. /****************************************************************
  606. 函数名:send_get_photo
  607. 函数描述:读取图片数据
  608. 输入参数:读图片起始地址StaAdd,
  609. 读取的长度readLen ,
  610. 接收数据的缓冲区buf
  611. 序列号
  612. 返回:成功返回1,失败返回0
  613. FF D8 ... FF D9 是JPG的图片格式
  614. 1.一次性读取的回复格式:76 00 32 00 00 FF D8 ... FF D9 76 00 32 00 00
  615. 2.分次读取,每次读N字节,循环使用读取图片数据指令读取M次或者(M + 1)次读取完毕:
  616. 如第一次执行后回复格式
  617. 76 00 32 00 <FF D8 ... N> 76 00 32 00
  618. 下次执行读取指令时,起始地址需要偏移N字节,即上一次的末尾地址,回复格式
  619. 76 00 32 00 <... N> 76 00 32 00
  620. ......
  621. 76 00 32 00 <... FF D9> 76 00 32 00 //lastBytes <= N
  622. Length = N * M 或 Length = N * M + lastBytes
  623. ******************************************************************/
  624. u8 send_get_photo(u16 staAdd,u16 readLen,u8 *buf,u8 Serialnumber)
  625. {
  626. u8 i = 0;
  627. u8 *ptr = NULL;
  628. SetSerailNumber( CommandPacket,
  629. get_photo_cmd,
  630. sizeof(get_photo_cmd),
  631. ResponsePacket,
  632. get_photo_rsp,
  633. sizeof(get_photo_rsp),
  634. Serialnumber );
  635. //装入起始地址高低字节
  636. CommandPacket[8] = (staAdd >> 8) & 0xff;
  637. CommandPacket[9] = staAdd & 0xff;
  638. //装入末尾地址高低字节
  639. CommandPacket[12] = (readLen >> 8) & 0xff;
  640. CommandPacket[13] = readLen & 0xff;
  641. //执行指令
  642. cam_write(CommandPacket,16);
  643. //等待图片数据存储到buf,超时或无数据回复则返回0
  644. if ( !cam_receiver(buf,readLen + 10))
  645. {
  646. return 0;
  647. }
  648. //检验帧头76 00 32 00 00
  649. for (i = 0; i < 5; i++)
  650. {
  651. if ( buf[i] != ResponsePacket[i] )
  652. {
  653. return 0;
  654. }
  655. }
  656. //检验帧尾76 00 32 00 00
  657. for (i = 0; i < 5; i++)
  658. {
  659. if ( buf[i + 5 + readLen] != ResponsePacket[i] )
  660. {
  661. return 0;
  662. }
  663. }
  664. //宏开关选择丢弃/保留 帧头帧尾76 00 32 00 00
  665. #if CLEAR_FRAME
  666. // memcpy(buf,buf + 5,read_len);
  667. ptr = buf;
  668. for (; readLen > 0; ++ptr)
  669. {
  670. *(ptr) = *(ptr + 5);
  671. readLen--;
  672. }
  673. #endif
  674. return 1;
  675. }
  676. /****************************************************************
  677. 函数名:send_open_motion
  678. 函数描述:发送打开移动侦测指令
  679. 输入参数:序列号
  680. 返回:识别成功返回1 失败返回0
  681. ******************************************************************/
  682. u8 send_motion_sensitivity(u8 Serialnumber)
  683. {
  684. u8 i;
  685. SetSerailNumber( CommandPacket,
  686. motion_sensitivity_cmd,
  687. sizeof(motion_sensitivity_cmd),
  688. ResponsePacket,
  689. motion_sensitivity_rsp,
  690. sizeof(motion_sensitivity_rsp),
  691. Serialnumber );
  692. i = send_cmd( CommandPacket,
  693. sizeof(motion_sensitivity_cmd),
  694. ResponsePacket,
  695. sizeof(motion_sensitivity_rsp) );
  696. return i;
  697. }
  698. /****************************************************************
  699. 函数名:send_open_motion
  700. 函数描述:发送打开移动侦测指令
  701. 输入参数:序列号
  702. 返回:识别成功返回1 失败返回0
  703. ******************************************************************/
  704. u8 send_open_motion(u8 Serialnumber)
  705. {
  706. u8 i;
  707. SetSerailNumber( CommandPacket,
  708. motion_enable_cmd,
  709. sizeof(motion_enable_cmd),
  710. ResponsePacket,
  711. motion_rsp,
  712. sizeof(motion_rsp),
  713. Serialnumber );
  714. i = send_cmd( CommandPacket,
  715. sizeof(motion_enable_cmd),
  716. ResponsePacket,
  717. sizeof(motion_rsp) );
  718. return i;
  719. }
  720. /****************************************************************
  721. 函数名:send_close_motion
  722. 函数描述:发送关闭移动侦测指令
  723. 输入参数:序列号
  724. 返回:识别成功返回1 失败返回0
  725. ******************************************************************/
  726. u8 send_close_motion(u8 Serialnumber)
  727. {
  728. u8 i;
  729. SetSerailNumber( CommandPacket,
  730. motion_disable_cmd,
  731. sizeof(motion_disable_cmd),
  732. ResponsePacket,
  733. motion_rsp,
  734. sizeof(motion_rsp),
  735. Serialnumber );
  736. i = send_cmd( CommandPacket,
  737. sizeof(motion_disable_cmd),
  738. ResponsePacket,
  739. sizeof(motion_rsp) );
  740. return i;
  741. }
  742. /****************************************************************
  743. 函数名:Motion_Detecte_Idle
  744. 函数描述: 等待移动侦测事件,该函数可在RS485同时接多个摄像头时,传递
  745. 当前是第几个序列号上报移动侦测
  746. 输入参数:传递一个指针变量
  747. 返回:成功返回1 失败返回0
  748. ******************************************************************/
  749. u8 Motion_Detecte_Idle(u8 *pSerialnumber)
  750. {
  751. u8 tmp[5] = {0x00,0x00,0x00,0x00,0x00};
  752. if ( !cam_receiver(tmp,5) )
  753. {
  754. return 0;
  755. }
  756. //检验数据
  757. //全部有5个数据,只校验4个,其中数组下标为1是序列号
  758. if(!(tmp[0] == motion_detecte[0] &&
  759. tmp[2] == motion_detecte[2] &&
  760. tmp[3] == motion_detecte[3] &&
  761. tmp[4] == motion_detecte[4] ))
  762. {
  763. return 0;
  764. }
  765. //取出序列号
  766. *pSerialnumber = tmp[1];
  767. return 1;
  768. }
  769. u8 sendComBuff[8]={0};
  770. /****************************************************************
  771. 函数名:CameraDemoApp
  772. 函数描述:摄像头应用实例
  773. 输入参数:序列号,图片尺寸
  774. 返回:成功返回1,失败返回0
  775. ******************************************************************/
  776. u8 CameraDemoApp(u8 Serialnumber,u8 nCameraImageSize)
  777. {
  778. u16 cntM = 0,lastBytes = 0,i = 0;
  779. #if USING_SAVE_SD
  780. FRESULT res;
  781. u8 pname[20];
  782. u8 Issuccess = 0;
  783. u32 defaultbw = 1;
  784. #endif
  785. //初始化摄像头
  786. cameraReady = camera_init(Serialnumber,nCameraImageSize);
  787. if(!cameraReady)
  788. {
  789. return 0;
  790. }
  791. //清空图片缓存
  792. if( !send_photoBuf_cls(Serialnumber) )
  793. {
  794. return 0;
  795. }
  796. //开始拍照
  797. if( !send_start_photo(Serialnumber) )
  798. {
  799. return 0;
  800. }
  801. else
  802. {
  803. //读取拍照后的图片长度
  804. picLen = send_read_len(Serialnumber);
  805. }
  806. if( !picLen )
  807. {
  808. return 0;
  809. }
  810. else
  811. {
  812. cntM = picLen / N_BYTE;
  813. lastBytes = picLen % N_BYTE;
  814. }
  815. sendComBuff[0]=0xaa;
  816. sendComBuff[5]=0x05; //图像命令
  817. sendComBuff[6]=0xaf;
  818. sendComBuff[1]=picLen>>24;
  819. sendComBuff[2]=picLen>>16;
  820. sendComBuff[3]=picLen>>8;
  821. sendComBuff[4]=picLen;
  822. //UART2Write(sendComBuff,7);
  823. server_sendByte(sendComBuff,7);
  824. delay(100);
  825. //分M次,每次读N_BYTE字节
  826. if( cntM )
  827. {
  828. for( i = 0; i < cntM; i++)
  829. {
  830. memset(gprs_buf, 0, sizeof(gprs_buf));
  831. //按图片长度读取数据
  832. if( !send_get_photo( i * N_BYTE,
  833. N_BYTE,
  834. gprs_buf,
  835. Serialnumber) )
  836. {
  837. return 0;
  838. }
  839. else
  840. {
  841. //此分支可将图片数据输出到指定的串口
  842. //如接口函数,将图片数据写入到串口2
  843. //uart1_putchar(0x15);//发送标识符
  844. server_sendByte(gprs_buf,N_BYTE);
  845. }
  846. delay(50);
  847. }
  848. }
  849. //剩余图片长度
  850. if(lastBytes)
  851. {
  852. memset(gprs_buf, 0, sizeof(gprs_buf));
  853. //读取剩余长度
  854. if( !send_get_photo( i * N_BYTE,
  855. lastBytes,
  856. gprs_buf,
  857. Serialnumber) )
  858. {
  859. return 0;
  860. }
  861. else
  862. {
  863. // uart1_putchar(0x15);//发送标识符
  864. //UART2Write(gprs_buf,lastBytes);//发送图片数据
  865. server_sendByte(gprs_buf,lastBytes);
  866. }
  867. delay(50);
  868. }
  869. return 1;
  870. }
  871. void function_Star(){
  872. static int led_State=0;
  873. digitalWrite(LED_PIN,led_State);
  874. led_State=(~led_State);
  875. }
  876. /*
  877. 检查串口是否有数据
  878. */
  879. void Usart_RxTask(void)
  880. {
  881. unsigned char i =0;
  882. if (Serial.available() > 0)
  883. {
  884. uint8_t t = Serial.read();
  885. Serial_Buffer[buffUartIndex++] = t;
  886. preUartTick = millis();
  887. if (buffUartIndex >= Serial_RX_MAXSIZE - 1) {
  888. buffUartIndex = Serial_RX_MAXSIZE - 2;
  889. preUartTick = preUartTick - 10;
  890. }
  891. }
  892. if (buffUartIndex > 0 && (millis() - preUartTick >= 10))
  893. { //data ready
  894. Serial_Buffer[buffUartIndex] = 0x00;
  895. if(strstr((char*)&Serial_Buffer[0],"esp_get")!=NULL)
  896. {
  897. getflag=1;
  898. }
  899. if(strstr((char*)&Serial_Buffer[0],"esp_close")!=NULL)
  900. {
  901. getflag=0;
  902. }
  903. // 将UART端口数据推送到所有已连接的telnet客户端,实现双向通信
  904. for(i = 0; i < MAX_SRV_CLIENTS; i++){
  905. if (serverClients[i] && serverClients[i].connected()){
  906. serverClients[i].write(&Serial_Buffer[0], buffUartIndex);
  907. delay(1);
  908. }
  909. }
  910. buffUartIndex = 0;
  911. }
  912. }
  913. void server_sendByte(u8 *data,u32 len)
  914. {
  915. int i=0;
  916. for(i = 0; i < MAX_SRV_CLIENTS; i++){
  917. if (serverClients[i] && serverClients[i].connected()){
  918. serverClients[i].write(&data[0], len);
  919. delay(1);
  920. }
  921. }
  922. }
  923. void setup() {
  924. swSer.begin(BAUD_RATE, SWSERIAL_8N1, D5, D6, false, 95, 11);
  925. for (char ch = ' '; ch <= 'z'; ch++) {
  926. swSer.write(ch);
  927. }
  928. swSer.println("");
  929. WiFi.softAP(ssid, password);
  930. swSer.println();
  931. swSer.print("IP address: ");
  932. swSer.println(WiFi.softAPIP());
  933. pinMode(LED_PIN,OUTPUT);//设置对应引脚为输出模式
  934. digitalWrite(LED_PIN,HIGH);
  935. //启动UART传输和服务器
  936. server.begin();
  937. server.setNoDelay(true);//停止小包合并发送
  938. swSer.print("Ready! Use 'telnet ");
  939. swSer.print(WiFi.localIP());//获得服务器本地IP
  940. Serial.begin(115200);
  941. //摄像头模块初始化
  942. if (!camera_init(SERIAL_NUM_0,IMAGE_SIZE_160X120))
  943. {
  944. while(1)
  945. {
  946. swSer.println("\r\nCamera Init fail!\r\n");
  947. delay(1000); //
  948. }
  949. }
  950. else
  951. {
  952. swSer.println("\r\nCamera Init Success!\r\n");
  953. // GPIO_ResetBits(GPIOC,GPIO_Pin_13);
  954. // delay_ms(200); //在上电复位后要等1-2秒摄像头才能接收指令
  955. // GPIO_SetBits(GPIOC,GPIO_Pin_13);//初始化成功短鸣一声并亮灯
  956. // delay_ms(200); //在上电复位后要等1-2秒摄像头才能接收指令
  957. // GPIO_SetBits(GPIOC,GPIO_Pin_13);//初始化成功 亮灯
  958. }
  959. }
  960. void loop() {
  961. uint8_t i;
  962. //检测服务器端是否有活动的客户端连接
  963. if (server.hasClient()){
  964. for(i = 0; i < MAX_SRV_CLIENTS; i++){
  965. //查找空闲或者断开连接的客户端,并置为可用
  966. if (!serverClients[i] || !serverClients[i].connected()){
  967. if(serverClients[i]) serverClients[i].stop();
  968. serverClients[i] = server.available();
  969. swSer.print("New client: "); swSer.println(i);
  970. continue;
  971. }
  972. }
  973. //若没有可用客户端,则停止连接
  974. WiFiClient serverClient = server.available();
  975. serverClient.stop();
  976. }
  977. //检查客户端的数据
  978. for(i = 0; i < MAX_SRV_CLIENTS; i++){
  979. if (serverClients[i] && serverClients[i].connected()){
  980. if(serverClients[i].available()){
  981. //从Telnet客户端获取数据,并推送到URAT端口
  982. while(serverClients[i].available())
  983. {
  984. Rxstr = serverClients[i].readStringUntil('\r\n');
  985. if(Rxstr.indexOf("esp_get")!=-1)
  986. {
  987. getflag=1;
  988. }
  989. if(Rxstr.indexOf("esp_close")!=-1)
  990. {
  991. getflag=0;
  992. }
  993. swSer.println(Rxstr);
  994. }
  995. }
  996. }
  997. }
  998. //Usart_RxTask();
  999. if(getflag==1)
  1000. {
  1001. CameraDemoApp(SERIAL_NUM_0,IMAGE_SIZE_160X120);
  1002. getflag=0;
  1003. }
  1004. delay(1);
  1005. }