port.c 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547
  1. /*
  2. * FreeModbus Libary: BARE Demo Application
  3. * Copyright (C) 2006 Christian Walter <wolti@sil.at>
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation; either version 2 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program; if not, write to the Free Software
  17. * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  18. *
  19. * File: $Id$
  20. */
  21. /* ----------------------- Modbus includes ----------------------------------*/
  22. #include "mb.h"
  23. #include "mbport.h"
  24. #include "Main.h"
  25. #include "string.h"
  26. #include "At24cxx.h"
  27. #include "ReadEeprom.h"
  28. #include "gd32e230x_conf.h"
  29. #include "Timer.h"
  30. /* ----------------------- Defines ------------------------------------------*/
  31. //输入寄存器
  32. #define REG_INPUT_START 3000
  33. #define REG_INPUT_NREGS 4
  34. //保持寄存器
  35. #define REG_HOLD_START 4000
  36. #define REG_HOLD_NREGS 1500
  37. //线圈
  38. #define REG_COILS_START 0
  39. #define REG_COILS_NREGS 4
  40. //开关寄存器
  41. #define REG_DISCRETE_START 1000
  42. #define REG_DISCRETE_NREGS 4
  43. /* ----------------------- Static variables ---------------------------------*/
  44. static USHORT usRegInputStart = REG_INPUT_START;
  45. static USHORT usRegInputBuf[REG_INPUT_NREGS];
  46. static USHORT usRegHoldStart = REG_HOLD_START;
  47. static USHORT usRegHoldBuf[REG_HOLD_NREGS];
  48. static USHORT usRegCoilsStart = REG_COILS_START;
  49. static uint8_t usRegCoilsBuf[REG_COILS_NREGS];
  50. static USHORT usRegDiscreteStart = REG_DISCRETE_START;
  51. static uint8_t usRegDiscreteBuf[REG_DISCRETE_NREGS];
  52. extern unsigned long int Delay_Ms;
  53. extern unsigned char detection_value;
  54. /* ----------------------- Start implementation -----------------------------*/
  55. //int
  56. //main( void )
  57. //{
  58. // eMBErrorCode eStatus;
  59. // eStatus = eMBInit( MB_RTU, 0x0A, 0, 38400, MB_PAR_EVEN );
  60. // /* Enable the Modbus Protocol Stack. */
  61. // eStatus = eMBEnable( );
  62. // for( ;; )
  63. // {
  64. // ( void )eMBPoll( );
  65. // /* Here we simply count the number of poll cycles. */
  66. // usRegInputBuf[0]++;
  67. // }
  68. //}
  69. /****************************************************************************
  70. * 名 称:eMBRegInputCB
  71. * 功 能:读取输入寄存器,对应功能码是 04 eMBFuncReadInputRegister
  72. * 入口参数:pucRegBuffer: 数据缓存区,用于响应主机
  73. * usAddress: 寄存器地址
  74. * usNRegs: 要读取的寄存器个数
  75. * 出口参数:
  76. * 注 意:上位机发来的 帧格式是: SlaveAddr(1 Byte)+FuncCode(1 Byte)
  77. * +StartAddrHiByte(1 Byte)+StartAddrLoByte(1 Byte)
  78. * +LenAddrHiByte(1 Byte)+LenAddrLoByte(1 Byte)+
  79. * +CRCAddrHiByte(1 Byte)+CRCAddrLoByte(1 Byte)
  80. * 3 区
  81. ****************************************************************************/
  82. eMBErrorCode
  83. eMBRegInputCB( UCHAR * pucRegBuffer, USHORT usAddress, USHORT usNRegs )
  84. {
  85. eMBErrorCode eStatus = MB_ENOERR;
  86. int iRegIndex;
  87. usAddress = usAddress - 1;
  88. if( ( usAddress >= REG_INPUT_START ) && ( usAddress + usNRegs <= REG_INPUT_START + REG_INPUT_NREGS ) )
  89. {
  90. iRegIndex = ( int )( usAddress - usRegInputStart );
  91. while( usNRegs > 0 )
  92. {
  93. *pucRegBuffer++ = ( unsigned char )( usRegInputBuf[iRegIndex] >> 8 );
  94. *pucRegBuffer++ = ( unsigned char )( usRegInputBuf[iRegIndex] & 0xFF );
  95. iRegIndex++;
  96. usNRegs--;
  97. }
  98. }
  99. else
  100. {
  101. eStatus = MB_ENOREG;
  102. }
  103. return eStatus;
  104. }
  105. /****************************************************************************
  106. * 名 称:eMBRegHoldingCB
  107. * 功 能:对应功能码有:06 写保持寄存器 eMBFuncWriteHoldingRegister
  108. * 16 写多个保持寄存器 eMBFuncWriteMultipleHoldingRegister
  109. * 03 读保持寄存器 eMBFuncReadHoldingRegister
  110. * 23 读写多个保持寄存器 eMBFuncReadWriteMultipleHoldingRegister
  111. * 入口参数:pucRegBuffer: 数据缓存区,用于响应主机
  112. * usAddress: 寄存器地址
  113. * usNRegs: 要读写的寄存器个数
  114. * eMode: 功能码
  115. * 出口参数:
  116. * 注 意:4 区
  117. ****************************************************************************/
  118. //unsigned int test1;
  119. //unsigned int test2;
  120. //unsigned int test3;
  121. //unsigned int test4;
  122. //unsigned long int test5=0x12345678;
  123. //USHORT test6[20];
  124. //unsigned char test[200]={0};
  125. unsigned char Chal_num;
  126. unsigned char WusNRegs;
  127. unsigned int WiRegIndex;
  128. unsigned int WeeiRegIndex;
  129. unsigned char Eeprom_Wbuf[200];
  130. extern ACDC_Wann_Read_Reg_t ACDC_Wann_All;
  131. extern EE_ACDC_ThresVal_struct_ReadReg EE_ACDC_All_ThrVal;
  132. extern EE_ACDC_State_All_Reg_En_t EE_ACDC_State_All_en;
  133. extern ACDC_Over_Func_WriteReg ACDC_Over_AllWriteReg;
  134. extern ACDC_Wann_Read_Reg_t ACDC_Wann_All;
  135. extern AC_Ele_struct_ReadReg AC_Ele_ReadReg_All;
  136. eMBErrorCode
  137. eMBRegHoldingCB( UCHAR * pucRegBuffer, USHORT usAddress, USHORT usNRegs, eMBRegisterMode eMode )
  138. {
  139. eMBErrorCode eStatus = MB_ENOERR;
  140. int iRegIndex;
  141. usAddress = usAddress - 1;
  142. if((usAddress >= REG_HOLD_START) && ((usAddress+usNRegs) <= (REG_HOLD_START + REG_HOLD_NREGS)))
  143. {
  144. iRegIndex = (int)(usAddress - usRegHoldStart);
  145. WiRegIndex = iRegIndex;
  146. switch(eMode)
  147. {
  148. case MB_REG_READ://读寄存器
  149. if((usAddress==Devid_ChalNumAddr)&&(usNRegs==Devid_ChalNumQua)) //读取设备类型和通道
  150. usRegHoldBuf[iRegIndex]= Devid_ChalNum;
  151. else if((usAddress>=AC_Sing_EleSmaAddr)&&(usAddress<=(AC_Sing_EleSmaAddr+AC_Sing_EleSmaQua)))//读取通道的参数
  152. {
  153. Chal_num = (usAddress-AC_Sing_EleSmaAddr)/12; //获取是哪个通道的数据
  154. memcpy(&usRegHoldBuf[iRegIndex],&AC_Ele_ReadReg[Chal_num],usNRegs*2);
  155. if(usAddress==AC_Sing_EleSmaAddr)
  156. Start_Read_Flag = 1;
  157. // else if(usAddress==(AC_Sing_EleSmaAddr+12*(RelaySlaveChaNum-1)))
  158. // Start_Read_Flag = 0;
  159. }
  160. else if((usAddress>=AC_Sing_State_SmaAddr)&&(usAddress<=(AC_Sing_State_SmaAddr+AC_Sing_State_SmaQua)))//读取通道的状态
  161. {
  162. Chal_num = (usAddress-AC_Sing_State_SmaAddr); //获取是哪个通道的数据
  163. //增加其他的状态,开关状态在继电器动作的函数中进行跟新
  164. for(int chn = 0; chn < usNRegs; chn++)
  165. {
  166. EE_ACDC_State_ReadRegTrue[chn].ACDC_Vol_Upthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Vol_Upthr_En;
  167. EE_ACDC_State_ReadRegTrue[chn].ACDC_Vol_Upthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Vol_Upthr_Warn;
  168. EE_ACDC_State_ReadRegTrue[chn].ACDC_Vol_Downthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Vol_Downthr_En;
  169. EE_ACDC_State_ReadRegTrue[chn].ACDC_Vol_Downthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Vol_Downthr_Warn;
  170. EE_ACDC_State_ReadRegTrue[chn].ACDC_Cur_Upthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Cur_Upthr_En;
  171. EE_ACDC_State_ReadRegTrue[chn].ACDC_Cur_Upthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Cur_Upthr_Warn;
  172. EE_ACDC_State_ReadRegTrue[chn].ACDC_Pow_Upthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Pow_Upthr_En;
  173. EE_ACDC_State_ReadRegTrue[chn].ACDC_Pow_Upthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Pow_Upthr_Warn;
  174. EE_ACDC_State_ReadRegTrue[chn].ACDC_Ele_Upthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Ele_Upthr_En;
  175. EE_ACDC_State_ReadRegTrue[chn].ACDC_Ele_Upthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Ele_Upthr_Warn;
  176. }
  177. memcpy(&usRegHoldBuf[iRegIndex],&EE_ACDC_State_ReadRegTrue[Chal_num],usNRegs*2);
  178. }else if((usAddress>=AC_Sing_Total_Consumer_Addr)&&(usAddress<=AC_Sing_Total_Consumer_Addr+AC_Sing_Total_ConsumerQua))
  179. {
  180. Chal_num = (usAddress-AC_Sing_Total_Consumer_Addr)/2;
  181. memcpy(&usRegHoldBuf[iRegIndex],&EE_ACDC_Total_Consum_Read_Reg[Chal_num],usNRegs*2);
  182. }else if((usAddress >= AC_Sing_All_Chn_ConsumerAddr) &&(usAddress <= AC_Sing_All_Chn_ConsumerAddr + AC_Sing_All_Chn_ConsumerQua))
  183. {
  184. memcpy(&usRegHoldBuf[iRegIndex],&ACDC_Total_All_Chn_Read_Reg,usNRegs*2);
  185. }else if(usAddress == AC_Sing_Detection_Addr)
  186. {
  187. memcpy(&usRegHoldBuf[iRegIndex],&detection_value,usNRegs*2);
  188. }else if(usAddress == AC_Sing_All_Over_Func_Wann_Addr)
  189. {
  190. memcpy(&usRegHoldBuf[iRegIndex],&ACDC_Wann_All,2);
  191. }else if(usAddress >= AC_Sing_All_EleSmaAddr && usAddress <= (AC_Sing_All_EleSmaAddr+AC_Sing_All_EleSmaQua))
  192. {
  193. Start_Read_Flag = 1;
  194. int base_addr = usAddress -AC_Sing_All_EleSmaAddr;
  195. uint32_t * base = (uint32_t *)(&AC_Ele_ReadReg_All);
  196. base += base_addr;
  197. memcpy(&usRegHoldBuf[iRegIndex],base,usNRegs*2);
  198. }
  199. while(usNRegs > 0)
  200. {
  201. *pucRegBuffer++ = (uint8_t)(usRegHoldBuf[iRegIndex] >> 8);
  202. *pucRegBuffer++ = (uint8_t)(usRegHoldBuf[iRegIndex] & 0xFF);
  203. iRegIndex++;
  204. usNRegs--;
  205. }
  206. break;
  207. case MB_REG_WRITE://写寄存器
  208. WusNRegs = usNRegs;
  209. while(usNRegs > 0)
  210. {
  211. usRegHoldBuf[iRegIndex] = *pucRegBuffer++ << 8;
  212. usRegHoldBuf[iRegIndex] |= *pucRegBuffer++;
  213. iRegIndex++;
  214. usNRegs--;
  215. }
  216. if((usAddress>=AC_Sing_Dela_OnSmaAddr)&&(usAddress<=AC_Sing_Dela_OnSmaAddr+AC_Sing_Dela_OnSmaQua)) //设置通道之间的开启延时
  217. {
  218. WeeiRegIndex = (int)(usAddress - AC_Sing_Dela_OnSmaAddr);
  219. Chal_num = (usAddress-AC_Sing_Dela_OnSmaAddr); //设置哪个通道的延时
  220. // memcpy(&ACDC_Delay_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs); //将接收的数据放入写结构体中
  221. memcpy(&EE_ACDC_Delay_ReadReg_On[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入读结构体中
  222. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  223. AT24CxxWrite(Eepr_AC_Sing_Dela_OnSmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  224. memcpy(&Sort_Onbuf,&EE_ACDC_Delay_ReadReg_On,Eepr_AC_Sing_Dela_OnSmaQua); //将数据进行排序,然后存入数组中,确保开关的时序
  225. Bubble_Sort(Sort_Onbuf,RelaySlaveChaNum);
  226. // AT24CxxRead(Eepr_AC_Sing_DelaSmaAddr+WusNRegs*2, test, Eepr_AC_Sing_DelaSmaQua); //从eeprom中读出通道延时数据
  227. // memcpy(&EE_ACDC_Delay_ReadReg1,&test,Eepr_AC_Sing_DelaSmaQua); //将数据拷贝到指定的结构体,可能需要注意大小端问题
  228. }
  229. else if((usAddress>=AC_Sing_Dela_OffSmaAddr)&&(usAddress<=AC_Sing_Dela_OffSmaAddr+AC_Sing_Dela_OffSmaQua)) //设置通道之间的关闭延时
  230. {
  231. WeeiRegIndex = (int)(usAddress - AC_Sing_Dela_OffSmaAddr);
  232. Chal_num = (usAddress-AC_Sing_Dela_OffSmaAddr); //设置哪个通道的延时
  233. // memcpy(&ACDC_Delay_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs); //将接收的数据放入写结构体中
  234. memcpy(&EE_ACDC_Delay_ReadReg_Off[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入读结构体中
  235. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  236. AT24CxxWrite(Eepr_AC_Sing_Dela_OffSmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  237. memcpy(&Sort_Offbuf,&EE_ACDC_Delay_ReadReg_Off,Eepr_AC_Sing_Dela_OffSmaQua); //将数据进行排序,然后存入数组中
  238. Bubble_Sort(Sort_Offbuf,RelaySlaveChaNum);
  239. // AT24CxxRead(Eepr_AC_Sing_DelaSmaAddr+WusNRegs*2, test, Eepr_AC_Sing_DelaSmaQua); //从eeprom中读出通道延时数据
  240. // memcpy(&EE_ACDC_Delay_ReadReg1,&test,Eepr_AC_Sing_DelaSmaQua); //将数据拷贝到指定的结构体,可能需要注意大小端问题
  241. }
  242. else if((usAddress>=AC_Sing_State_SmaWAddr)&&(usAddress<=AC_Sing_State_SmaWAddr+AC_Sing_State_SmaWQua))//设置通道的状态
  243. {
  244. WeeiRegIndex = (int)(usAddress - AC_Sing_State_SmaWAddr);
  245. Chal_num = (usAddress-AC_Sing_State_SmaWAddr); //设置哪个通道的状态
  246. // memcpy(&ACDC_State_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs); //将接收的数据放入写结构体中
  247. memcpy(&EE_ACDC_State_ReadReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2);//将接收的数据放入读结构体中
  248. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_V_TopThres <= THRESHOULD_JUDGMENT)
  249. {
  250. EE_ACDC_State_ReadReg[Chal_num].ACDC_Vol_Upthr_En = false;
  251. }
  252. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_V_DownThres <= THRESHOULD_JUDGMENT)
  253. {
  254. EE_ACDC_State_ReadReg[Chal_num].ACDC_Vol_Downthr_En = false;
  255. }
  256. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_I_TopThres <= THRESHOULD_JUDGMENT)
  257. {
  258. EE_ACDC_State_ReadReg[Chal_num].ACDC_Cur_Upthr_En = false;
  259. }
  260. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_P_TopThres <= THRESHOULD_JUDGMENT)
  261. {
  262. EE_ACDC_State_ReadReg[Chal_num].ACDC_Pow_Upthr_En = false;
  263. }
  264. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_E_TopThres <= THRESHOULD_JUDGMENT)
  265. {
  266. EE_ACDC_State_ReadReg[Chal_num].ACDC_Ele_Upthr_En = false;
  267. }
  268. memcpy(&Eeprom_Wbuf,&EE_ACDC_State_ReadReg[Chal_num],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  269. AT24CxxWrite(Eepr_AC_Sing_State_SmaWAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  270. if((WusNRegs==RelaySlaveChaNum)&&(EE_ACDC_State_ReadReg[0].ACDC_Cha_On_Off_State==true)&&(EE_ACDC_State_ReadReg[0].ACDC_ALLCha_On_State==true))//通过下发的通道数和开关状态可以判断为全开
  271. {
  272. All_On_Flag = 1; //全开标志置1
  273. timer_enable(TIMER14);
  274. Delay_Ms_2 = 0;
  275. }
  276. else if((WusNRegs==RelaySlaveChaNum)&&(EE_ACDC_State_ReadReg[0].ACDC_Cha_On_Off_State==false)&&(EE_ACDC_State_ReadReg[0].ACDC_ALLCha_Off_State==true))//通过下发的通道数和开关状态可以判断为全关
  277. {
  278. All_Off_Flag = 1; //全关标志置1
  279. timer_enable(TIMER14);
  280. Delay_Ms_2 = 0;
  281. }
  282. else
  283. {
  284. RelayState();
  285. }
  286. }
  287. else if((usAddress>=AC_Sing_Thr_SmaAddr)&&(usAddress<=AC_Sing_Thr_SmaAddr+AC_Sing_Thr_SmaQua))//设置通道的阈值
  288. {
  289. WeeiRegIndex = (int)(usAddress - AC_Sing_Thr_SmaAddr);
  290. Chal_num = (usAddress-AC_Sing_Thr_SmaAddr)/16; //设置哪个通道的阈值
  291. // memcpy(&ACDC_ThresVal_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入写结构体中
  292. memcpy(&EE_ACDC_ThresVal_ReadReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入读结构体中
  293. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_V_TopThres <= THRESHOULD_JUDGMENT)
  294. {
  295. EE_ACDC_State_ReadReg[Chal_num].ACDC_Vol_Upthr_En = false;
  296. }
  297. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_V_DownThres <= THRESHOULD_JUDGMENT)
  298. {
  299. EE_ACDC_State_ReadReg[Chal_num].ACDC_Vol_Downthr_En = false;
  300. }
  301. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_I_TopThres <= THRESHOULD_JUDGMENT)
  302. {
  303. EE_ACDC_State_ReadReg[Chal_num].ACDC_Cur_Upthr_En = false;
  304. }
  305. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_P_TopThres <= THRESHOULD_JUDGMENT)
  306. {
  307. EE_ACDC_State_ReadReg[Chal_num].ACDC_Pow_Upthr_En = false;
  308. }
  309. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_E_TopThres <= THRESHOULD_JUDGMENT)
  310. {
  311. EE_ACDC_State_ReadReg[Chal_num].ACDC_Ele_Upthr_En = false;
  312. }
  313. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  314. AT24CxxWrite(Eepr_AC_Sing_Thr_SmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  315. }
  316. else if((usAddress>=AC_Sing_Coef_SmaAddr)&&(usAddress<=AC_Sing_Coef_SmaAddr+AC_Sing_Coef_SmaQua))//设置通道的系数
  317. {
  318. WeeiRegIndex = (int)(usAddress - AC_Sing_Coef_SmaAddr);
  319. Chal_num = (usAddress-AC_Sing_Coef_SmaAddr)/8; //设置哪个通道的系数
  320. // memcpy(&ACDC_Coef_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入写结构体中
  321. memcpy(&EE_ACDC_Coef_ReadReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入读结构体中
  322. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  323. AT24CxxWrite(Eepr_AC_Sing_Coef_SmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  324. }else if((usAddress>=AC_Sing_Channel_Func)&&(usAddress<=AC_Sing_Channel_Func+AC_Sing_Channel_FuncQua))
  325. {
  326. WeeiRegIndex = (int)(usAddress - AC_Sing_Channel_Func);
  327. memcpy(&ACDC_Over_WriteReg[WeeiRegIndex],&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  328. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  329. AT24CxxWrite(Eepr_AC_Sing_Channel_Func_SmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2);
  330. }else if(usAddress >= AC_Sing_Clear_Consumer && usAddress <= AC_Sing_Clear_Consumer+ AC_Sing_Clear_ConsumerQua)
  331. {
  332. //WeeiRegIndex = (int)(usAddress - AC_Sing_Clear_Consumer);
  333. Chal_num = usAddress-AC_Sing_Clear_Consumer;
  334. //AT24CxxRead(Eepr_AC_Sing_Total_Consumer_addr, Eeprom_Rbuf, Eepr_AC_Sing_Total_Consumer_SmaQua);
  335. uint16_t recive = 0;
  336. memcpy(&recive,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  337. EE_ACDC_Consumer_Clear[Chal_num].flag = 1;
  338. EE_ACDC_Consumer_Clear[Chal_num].value = recive;
  339. consumer_clear_flag = 1;
  340. }else if(usAddress == AC_Sing_Clear_Consumer_all)
  341. {
  342. uint16_t recive = 0;
  343. memcpy(&recive,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  344. consumer_clear_flag = 1;
  345. for(int i = 0; i < RelaySlaveChaNum;i++)
  346. {
  347. EE_ACDC_Consumer_Clear[i].flag = 1;
  348. EE_ACDC_Consumer_Clear[i].value = recive;
  349. }
  350. }else if(usAddress >= AC_Sing_All_Thr_SmaAddr && (usAddress <=(AC_Sing_All_Thr_SmaAddr + AC_Sing_All_Thr_SmaAddr_Qua)))
  351. {
  352. WeeiRegIndex = (int)(usAddress - AC_Sing_Thr_SmaAddr);
  353. //Chal_num = (usAddress-AC_Sing_All_Thr_SmaAddr)/16;
  354. memcpy(&EE_ACDC_All_ThrVal,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  355. if(EE_ACDC_All_ThrVal.ACDC_V_TopThres <= THRESHOULD_JUDGMENT)
  356. {
  357. EE_ACDC_State_All_en.ACDC_Vol_Upper_En = false;
  358. }else
  359. {
  360. EE_ACDC_State_All_en.ACDC_Vol_Upper_En = true;
  361. }
  362. if(EE_ACDC_All_ThrVal.ACDC_V_DownThres <= THRESHOULD_JUDGMENT)
  363. {
  364. EE_ACDC_State_All_en.ACDC_Vol_Lower_En= false;
  365. }else
  366. {
  367. EE_ACDC_State_All_en.ACDC_Vol_Lower_En= true;
  368. }
  369. if(EE_ACDC_All_ThrVal.ACDC_I_TopThres <= THRESHOULD_JUDGMENT)
  370. {
  371. EE_ACDC_State_All_en.ACDC_Current_Upper_En = false;
  372. }else
  373. {
  374. EE_ACDC_State_All_en.ACDC_Current_Upper_En= true;
  375. }
  376. if(EE_ACDC_All_ThrVal.ACDC_P_TopThres <= THRESHOULD_JUDGMENT)
  377. {
  378. EE_ACDC_State_All_en.ACDC_Power_Upper_En = false;
  379. }else
  380. {
  381. EE_ACDC_State_All_en.ACDC_Power_Upper_En = true;
  382. }
  383. if(EE_ACDC_All_ThrVal.ACDC_E_TopThres <= THRESHOULD_JUDGMENT)
  384. {
  385. EE_ACDC_State_All_en.ACDC_Consumer_Upper_En = false;
  386. }else
  387. {
  388. EE_ACDC_State_All_en.ACDC_Consumer_Upper_En= true;
  389. }
  390. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  391. AT24CxxWrite(Eepr_AC_Sing_All_Thr_SmaAddr,Eeprom_Wbuf, WusNRegs*2);
  392. }else if(usAddress == AC_Sing_All_Over_FuncAddr)
  393. {
  394. memcpy(&ACDC_Over_AllWriteReg,&usRegHoldBuf[WiRegIndex],2);
  395. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],2);
  396. AT24CxxWrite(Eepr_AC_Sing_All_Over_SmaAddr,Eeprom_Wbuf,2);
  397. }
  398. }
  399. }
  400. else//错误
  401. {
  402. eStatus = MB_ENOREG;
  403. }
  404. return eStatus;
  405. }
  406. /****************************************************************************
  407. * 名 称:eMBRegCoilsCB
  408. * 功 能:对应功能码有:01 读线圈 eMBFuncReadCoils
  409. * 05 写线圈 eMBFuncWriteCoil
  410. * 15 写多个线圈 eMBFuncWriteMultipleCoils
  411. * 入口参数:pucRegBuffer: 数据缓存区,用于响应主机
  412. * usAddress: 线圈地址
  413. * usNCoils: 要读写的线圈个数
  414. * eMode: 功能码
  415. * 出口参数:
  416. * 注 意:如继电器
  417. * 0 区
  418. ****************************************************************************/
  419. eMBErrorCode
  420. eMBRegCoilsCB( UCHAR * pucRegBuffer, USHORT usAddress, USHORT usNCoils, eMBRegisterMode eMode )
  421. {
  422. eMBErrorCode eStatus = MB_ENOERR;
  423. USHORT iRegIndex;
  424. USHORT usCoilGroups = ((usNCoils - 1) / 8 + 1);
  425. UCHAR ucStatus = 0;
  426. UCHAR ucBits = 0;
  427. UCHAR ucDisp = 0;
  428. usAddress = usAddress - 1;
  429. if((usAddress >= REG_COILS_START) && ((usAddress + usNCoils) <= (REG_COILS_START + REG_COILS_NREGS)))
  430. {
  431. iRegIndex = (int)(usAddress - usRegCoilsStart);
  432. switch(eMode)
  433. {
  434. case MB_REG_READ://读线圈
  435. while(usCoilGroups--)
  436. {
  437. ucDisp = 0;
  438. ucBits = 8;
  439. while((usNCoils--) != 0 && (ucBits--) != 0)
  440. {
  441. ucStatus |= (usRegCoilsBuf[iRegIndex++] << (ucDisp++));
  442. }
  443. *pucRegBuffer++ = ucStatus;
  444. }
  445. break;
  446. case MB_REG_WRITE://写线圈
  447. while(usCoilGroups--)
  448. {
  449. ucStatus = *pucRegBuffer++;
  450. ucBits = 8;
  451. while((usNCoils--) != 0 && (ucBits--) != 0)
  452. {
  453. usRegCoilsBuf[iRegIndex++] = ucStatus & 0X01;
  454. ucStatus >>= 1;
  455. }
  456. }
  457. }
  458. }
  459. else//错误
  460. {
  461. eStatus = MB_ENOREG;
  462. }
  463. return eStatus;
  464. }
  465. /****************************************************************************
  466. * 名 称:eMBRegDiscreteCB
  467. * 功 能:读取离散寄存器,对应功能码有:02 读离散寄存器 eMBFuncReadDiscreteInputs
  468. * 入口参数:pucRegBuffer: 数据缓存区,用于响应主机
  469. * usAddress: 寄存器地址
  470. * usNDiscrete: 要读取的寄存器个数
  471. * 出口参数:
  472. * 注 意:1 区
  473. ****************************************************************************/
  474. eMBErrorCode
  475. eMBRegDiscreteCB( UCHAR * pucRegBuffer, USHORT usAddress, USHORT usNDiscrete )
  476. {
  477. eMBErrorCode eStatus = MB_ENOERR;
  478. USHORT iRegIndex;
  479. USHORT usDiscreteGroups = ((usNDiscrete - 1) / 8 + 1);
  480. UCHAR ucStatus = 0;
  481. UCHAR ucBits = 0;
  482. UCHAR ucDisp = 0;
  483. usAddress = usAddress - 1;
  484. if((usAddress >= REG_DISCRETE_START) && ((usAddress + usNDiscrete) <= (REG_DISCRETE_START + REG_DISCRETE_NREGS)))
  485. {
  486. iRegIndex = (int)(usAddress - usRegDiscreteStart);
  487. while(usDiscreteGroups--)
  488. {
  489. ucDisp = 0;
  490. ucBits = 8;
  491. while((usNDiscrete--) != 0 && (ucBits--) != 0)
  492. {
  493. if(usRegDiscreteBuf[iRegIndex])
  494. {
  495. ucStatus |= (1 << ucDisp);
  496. }
  497. ucDisp++;
  498. }
  499. *pucRegBuffer++ = ucStatus;
  500. }
  501. }
  502. else//错误
  503. {
  504. eStatus = MB_ENOREG;
  505. }
  506. return eStatus;
  507. }