switch_ctrl.c 82 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455
  1. #include "switch_ctrl.h"
  2. #include "sqlite_handle.h"
  3. #include "modbus_handle.h"
  4. /// @brief 获取继电器板类型以及通道
  5. /// @param manger
  6. /// @param saddr
  7. /// @param type
  8. /// @param chn
  9. /// @return
  10. int g_switch_get_type(void* manger,int saddr, int* type,int* chn,int nPowerType)
  11. {
  12. if(nPowerType==SmartPDU_AC||nPowerType==SmartPDU_Tree_AC_One_B) //交流无法使用需要
  13. {
  14. int ret = 0 ;
  15. unsigned short data_temp = 0 ;
  16. ret = g_modbus_read_reg(manger,saddr,_SWITCH_TYPE_CHN_INFO,&data_temp);
  17. //ret = g_modbus_read_reg(manger,saddr,_SWITCH_DCPDU_TYPE_CHN_INFO,&data_temp);
  18. if(ret!=TRUE)
  19. {
  20. log_w("%s",modbus_strerror(errno));
  21. return -1 ;
  22. }
  23. *type = (data_temp>>8)&0xFF;
  24. *chn = data_temp&0xFF;
  25. return 0;
  26. }
  27. else{
  28. //32位读取
  29. int ret = 0 ;
  30. unsigned short data_temp[4];
  31. memset(data_temp,0,sizeof(data_temp));
  32. // ret = g_modbus_read_reg(manger,saddr,_SWITCH_TYPE_CHN_INFO,data_temp);
  33. // if(ret!=TRUE)
  34. ret = g_modbus_read_x_reg(manger,saddr,_SWITCH_DCPDU_TYPE_CHN_INFO, 2, data_temp);
  35. log_d("ret:%d saddr:%d data:%d,%d.\n",ret,saddr,data_temp[1],data_temp[0]);
  36. if (ret<=0)
  37. {
  38. log_w("Modbus Error:%s\n",modbus_strerror(errno));
  39. return -1 ;
  40. }
  41. *type = (data_temp[0]>>8)&0xFF;
  42. *chn = data_temp[0]&0xFF;
  43. return 0;
  44. }
  45. }
  46. /// @brief 获取单相小电流继电器板信息
  47. /// @param manger
  48. /// @param saddr
  49. /// @param chn
  50. /// @param _power
  51. /// @return
  52. int g_switch_get_ac_single_s_cur_info(void* manger,int saddr,unsigned char chn,PowerInfo* _power,PowerWarningInfo* _warning)
  53. {
  54. int ret = 0 ;
  55. unsigned int offset = 0;
  56. unsigned int val = 0 ;
  57. unsigned short data_temp[12] = {0};
  58. unsigned short status_temp = 0 ;
  59. if(chn>=8)
  60. return -1;
  61. offset = _SWITCH_AC_SINGLE_S_CUR_INFO+chn*12;
  62. //读取12个寄存器
  63. ret = g_modbus_read_x_reg(manger,saddr,offset,12,data_temp);
  64. if(ret<=0)
  65. return -1 ;
  66. //解电压数据
  67. val = (data_temp[1]<<16)|data_temp[0];
  68. _power->voltage = val/1000.0;
  69. //解电流数据
  70. val = (data_temp[3]<<16)|data_temp[2];
  71. _power->current = val/1000.0;
  72. //解功率数据
  73. val = (data_temp[5]<<16)|data_temp[4];
  74. _power->power = val/1000.0;
  75. //解频率数据
  76. val = (data_temp[7]<<16)|data_temp[6];
  77. _power->freq = val/1000.0;
  78. //解耗电量数据
  79. val = (data_temp[9]<<16)|data_temp[8];
  80. _power->consumption = val/1000.0;
  81. //解功率因素数据
  82. val = (data_temp[11]<<16)|data_temp[10];
  83. _power->factor = val/1000.0;
  84. #if(0)
  85. printf("---------%d---------------\n",chn);
  86. printf("voltage:%0.2f\n", _power->voltage);
  87. printf("current:%0.2f\n", _power->current);
  88. printf("power:%0.2f\n", _power->power);
  89. printf("freq:%0.2f\n", _power->freq);
  90. printf("consumption:%0.2f\n", _power->consumption);
  91. printf("factor:%0.2f\n", _power->factor);
  92. printf("-----------------------\n");
  93. #endif
  94. //获取开关状态
  95. offset = _SWITCH_AC_SINGLE_S_STS_INFO+chn;
  96. ret = g_modbus_read_reg(manger,saddr,offset,&status_temp);
  97. if(ret!=TRUE)
  98. return -1 ;
  99. _power->status = status_temp & BIT_00;
  100. _warning->w_voltage_up = status_temp & WARNING_V_UP;
  101. _warning->w_voltage_down = status_temp & WARNING_V_DOWN;
  102. _warning->w_current = status_temp & WARNING_A_UP;
  103. _warning->w_power = status_temp & WARNING_W_UP;
  104. _warning->w_consumption = status_temp & WARNING_P_UP;
  105. return 0;
  106. }
  107. int g_switch_get_ac_single_s_all_cur_info(void* manger,int saddr,int nNumb,PowerInfo* _power,PowerWarningInfo* _warning)
  108. {
  109. unsigned int offset = 0;
  110. unsigned int val = 0;
  111. unsigned short data_temp[96] = {0};
  112. unsigned int status_temp = 0;
  113. int ret = 0;
  114. offset = _SWITCH_AC_SINGLE_S_CUR_INFO;
  115. // 读取4个寄存器
  116. // 读取寄存器
  117. memset(data_temp, 0, sizeof(data_temp));
  118. ret = g_modbus_read_x_reg(manger, saddr, offset, 12*nNumb, data_temp);
  119. if (ret < 0)
  120. {
  121. log_w("g_switch_get_s_ac_in_info:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  122. // log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  123. return ret;
  124. }
  125. // 解电压数据
  126. for (size_t i = 0; i < nNumb; i++)
  127. {
  128. int Index = i * 12;
  129. // 解电压数据
  130. val = (data_temp[1 + Index] << 16) | data_temp[0 + Index];
  131. _power[i].voltage = val / 1000.0;
  132. // 解电流数据
  133. val = (data_temp[3 + Index] << 16) | data_temp[2 + Index];
  134. _power[i].current = val / 1000.0;
  135. // 解功率数据
  136. val = (data_temp[5 + Index] << 16) | data_temp[4 + Index];
  137. _power[i].power = val / 1000.0;
  138. // 解频率数据
  139. val = (data_temp[7 + Index] << 16) | data_temp[6 + Index];
  140. _power[i].freq = val / 1000.0;
  141. // 解耗电量数据
  142. val = (data_temp[9 + Index] << 16) | data_temp[8 + Index];
  143. _power[i].consumption = val / 1000.0;
  144. // 解功率因素数据
  145. val = (data_temp[11 + Index] << 16) | data_temp[10 + Index];
  146. _power[i].factor = val / 1000.0;
  147. }
  148. offset = _SWITCH_AC_SINGLE_S_STS_INFO;
  149. memset(data_temp, 0,sizeof(data_temp));
  150. ret = g_modbus_read_x_reg(manger, saddr, offset, 8, data_temp);
  151. // 解控制数据
  152. if (ret < 0)
  153. {
  154. return ret;
  155. }
  156. for (size_t i = 0; i < nNumb; i++)
  157. {
  158. status_temp=data_temp[i];
  159. _power[i].status = status_temp & (BIT_00);
  160. _warning[i].w_voltage_up = status_temp & (WARNING_V_UP);
  161. _warning[i].w_voltage_down = status_temp & (WARNING_V_DOWN);
  162. _warning[i].w_current = status_temp & (WARNING_A_UP);
  163. _warning[i].w_power = status_temp & (WARNING_W_UP);
  164. _warning[i].w_consumption = status_temp & (WARNING_P_UP);
  165. }
  166. return 0;
  167. }
  168. /// @brief 获取单相大电流继电器板信息
  169. /// @param manger
  170. /// @param saddr
  171. /// @param chn
  172. /// @param _power
  173. /// @return
  174. int g_switch_get_ac_single_b_cur_info(void* manger,int saddr,unsigned char chn,PowerInfo* _power,PowerWarningInfo* _warning)
  175. {
  176. unsigned int offset = 0;
  177. unsigned int val = 0 ;
  178. unsigned short data_temp[12] = {0};
  179. unsigned short status_temp = 0 ;
  180. if(chn>=4)
  181. return -1;
  182. offset = _SWITCH_AC_SINGLE_B_CUR_INFO+chn*12;
  183. //读取12个寄存器
  184. g_modbus_read_x_reg(manger,saddr,offset,12,data_temp);
  185. //解电压数据
  186. val = (data_temp[0]<<16)|data_temp[1];
  187. _power->voltage = val;
  188. //解电流数据
  189. val = (data_temp[2]<<16)|data_temp[3];
  190. _power->current = val;
  191. //解功率数据
  192. val = (data_temp[4]<<16)|data_temp[5];
  193. _power->power = val;
  194. //解频率数据
  195. val = (data_temp[6]<<16)|data_temp[7];
  196. _power->freq = val;
  197. //解耗电量数据
  198. val = (data_temp[8]<<16)|data_temp[9];
  199. _power->consumption = val;
  200. //解功率因素数据
  201. val = (data_temp[10]<<16)|data_temp[11];
  202. _power->factor = val;
  203. //获取开关状态
  204. offset = _SWITCH_AC_SINGLE_B_STS_INFO+chn;
  205. g_modbus_read_reg(manger,saddr,offset,&status_temp);
  206. _power->status = status_temp & BIT_00;
  207. _warning->w_voltage_up = status_temp & WARNING_V_UP;
  208. _warning->w_voltage_down = status_temp & WARNING_V_DOWN;
  209. _warning->w_current = status_temp & WARNING_A_UP;
  210. _warning->w_power = status_temp & WARNING_W_UP;
  211. _warning->w_consumption = status_temp & WARNING_P_UP;
  212. return 0;
  213. }
  214. /// @brief 获取直流继电器一路输出信息
  215. /// @param manger
  216. /// @param saddr
  217. /// @param chn
  218. /// @param _power
  219. /// @return
  220. int g_switch_get_dc_out_info(void* manger,int saddr,unsigned char chn,PowerInfo* _power,PowerWarningInfo* _warning)
  221. {
  222. unsigned int offset = 0;
  223. unsigned int val = 0 ;
  224. unsigned short data_temp[12] = {0};
  225. unsigned short status_temp = 0 ;
  226. if(chn>=1)
  227. return -1;
  228. offset = _SWITCH_DC_OUT_INFO+chn*6;
  229. //读取12个寄存器
  230. g_modbus_read_x_reg(manger,saddr,offset,6,data_temp);
  231. //解电压数据
  232. val = (data_temp[0]<<16)|data_temp[1];
  233. _power->voltage = val;
  234. //解电流数据
  235. val = (data_temp[2]<<16)|data_temp[3];
  236. _power->current = val;
  237. //解功率数据
  238. val = (data_temp[4]<<16)|data_temp[5];
  239. _power->power = val;
  240. //获取开关状态
  241. offset = _SWITCH_DC_STS_INFO;
  242. g_modbus_read_reg(manger,saddr,offset,&status_temp);
  243. //_power->status = status_temp;
  244. _power->status = status_temp & BIT_00;
  245. _warning->w_voltage_up = status_temp & WARNING_V_UP;
  246. _warning->w_voltage_down = status_temp & WARNING_V_DOWN;
  247. _warning->w_current = status_temp & WARNING_A_UP;
  248. _warning->w_power = status_temp & WARNING_W_UP;
  249. _warning->w_consumption = status_temp & WARNING_P_UP;
  250. return 0;
  251. }
  252. /// @brief 获取直流总输入信息
  253. /// @param manger
  254. /// @param saddr
  255. /// @param _power
  256. /// @param _sensorVal
  257. /// @return
  258. int g_switch_get_dc_in_info(void* manger,int saddr,PowerInfo* _power,SenorTempVal* _sensorVal)
  259. {
  260. unsigned int offset = 0;
  261. unsigned int val = 0 ;
  262. unsigned short data_temp[12] = {0};
  263. offset = _SWITCH_DC_IN_INFO;
  264. //读取12个寄存器
  265. g_modbus_read_x_reg(manger,saddr,offset,8,data_temp);
  266. //解电压数据
  267. val = (data_temp[0]<<16)|data_temp[1];
  268. _power->voltage = val;
  269. //解电流数据
  270. val = (data_temp[2]<<16)|data_temp[3];
  271. _power->current = val;
  272. //解功率数据
  273. val = (data_temp[4]<<16)|data_temp[5];
  274. _power->power = val;
  275. //解温度数据
  276. val = data_temp[6];
  277. _sensorVal->temperature = val;
  278. //解湿度数据
  279. val = data_temp[7];
  280. _sensorVal->humidity = val;
  281. return 0;
  282. }
  283. /// @brief 设置AC单相小电流通道开启延时时间
  284. /// @param manger
  285. /// @param saddr
  286. /// @param chn
  287. /// @param time 单位ms
  288. /// @return
  289. int g_switch_set_ac_single_s_start_time_delay(void* manger,int saddr,unsigned char chn,unsigned int time)
  290. {
  291. unsigned int offset = 0;
  292. if(chn>=8)
  293. return -1;
  294. offset = _SWITCH_AC_SINGLE_S_START_DELAY_TIME+chn;
  295. int reg=g_modbus_write_reg(manger,saddr,offset,time);
  296. if (reg>=0)
  297. {
  298. log_d("StartDelayTime_Addr:%d OffSet:%d Time:%d Ret=%d",saddr,offset,time,reg);
  299. }
  300. else
  301. {
  302. log_w("StartDelayTime_Addr:%d OffSet:%d Time:%d Ret=%d:%s",saddr,offset,time,reg,modbus_strerror(errno));
  303. }
  304. return reg ;
  305. }
  306. /// @brief 设置AC单相小电流通道关闭延时时间
  307. /// @param manger
  308. /// @param saddr
  309. /// @param chn
  310. /// @param time 单位ms
  311. /// @return
  312. int g_switch_set_ac_single_s_stop_time_delay(void* manger,int saddr,unsigned char chn,unsigned int time)
  313. {
  314. unsigned int offset = 0;
  315. if(chn>=8)
  316. return -1;
  317. offset = _SWITCH_AC_SINGLE_S_STOP_DELAY_TIME+chn;
  318. int reg=g_modbus_write_reg(manger,saddr,offset,time);
  319. if (reg>=0)
  320. {
  321. log_d("StopDelayTime_Addr:%d OffSet:%d Time:%d Ret=%d",saddr,offset,time,reg);
  322. }
  323. else
  324. {
  325. log_w("StopDelayTime_Addr:%d OffSet:%d Time:%d Ret=%d:%s",saddr,offset,time,reg,modbus_strerror(errno));
  326. }
  327. return reg;
  328. }
  329. /// @brief 设置AC单相大电流通道开启延时时间
  330. /// @param manger
  331. /// @param saddr
  332. /// @param chn
  333. /// @param time
  334. /// @return
  335. int g_switch_set_ac_single_b_start_time_delay(void* manger,int saddr,unsigned char chn,unsigned int time)
  336. {
  337. unsigned int offset = 0;
  338. if(chn>=4)
  339. return -1;
  340. offset = _SWITCH_AC_SINGLE_B_START_DELAY_TIME+chn*2;
  341. return g_modbus_write_x_reg(manger,saddr,offset,2,(unsigned short*)&time);
  342. }
  343. /// @brief 设置AC单相大电流通道关闭延时时间
  344. /// @param manger
  345. /// @param saddr
  346. /// @param chn
  347. /// @param time
  348. /// @return
  349. int g_switch_set_ac_single_b_stop_time_delay(void* manger,int saddr,unsigned char chn,unsigned int time)
  350. {
  351. unsigned int offset = 0;
  352. if(chn>=4)
  353. return -1;
  354. offset = _SWITCH_AC_SINGLE_B_STOP_DELAY_TIME+chn*2;
  355. return g_modbus_write_x_reg(manger,saddr,offset,2,(unsigned short*)&time);
  356. }
  357. /// @brief 设置直流继电器控制板
  358. /// @param manger
  359. /// @param saddr
  360. /// @param time
  361. /// @return
  362. int g_switch_set_dc_start_time_delay(void* manger,int saddr,unsigned int time)
  363. {
  364. unsigned int offset = 0;
  365. offset = _SWITCH_DC_START_DELAY_TIME;
  366. return g_modbus_write_x_reg(manger,saddr,offset,2,(unsigned short*)&time) ;
  367. }
  368. /// @brief 设置直流继电器控制板
  369. /// @param manger
  370. /// @param saddr
  371. /// @param time
  372. /// @return
  373. int g_switch_set_dc_stop_time_delay(void* manger,int saddr,unsigned int time)
  374. {
  375. unsigned int offset = 0;
  376. offset = _SWITCH_DC_STOP_DELAY_TIME;
  377. return g_modbus_write_x_reg(manger,saddr,offset,2,(unsigned short*)&time);
  378. }
  379. /// @brief 设置单相小电流通道开关状态
  380. /// @param manger
  381. /// @param saddr
  382. /// @param chn
  383. /// @param sts
  384. /// @return
  385. int g_switch_set_ac_single_s_chn_ctrl(void* manger,int saddr,unsigned char chn,unsigned short sts)
  386. {
  387. unsigned int offset = 0;
  388. if(chn>=8)
  389. return -1;
  390. offset = _SWITCH_AC_SINGLE_S_CHN_STS+chn;
  391. return g_modbus_write_reg(manger,saddr,offset,sts);
  392. }
  393. /// @brief 设置单相小电流所有通道开关状态
  394. /// @param manger
  395. /// @param saddr
  396. /// @param sts
  397. /// @return
  398. int g_switch_set_ac_single_s_ctrl(void* manger,int saddr,unsigned short* sts,int nsize)
  399. {
  400. if (nsize < 1 || nsize > 8)
  401. {
  402. return 0 ;
  403. }
  404. unsigned int offset = 0;
  405. offset = _SWITCH_AC_SINGLE_S_CHN_STS;
  406. return g_modbus_write_x_reg(manger,saddr,offset,nsize,sts); ;
  407. }
  408. /// @brief 设置单相大电流通道开关状态
  409. /// @param manger
  410. /// @param saddr
  411. /// @param chn
  412. /// @param sts
  413. /// @return
  414. int g_switch_set_ac_single_b_chn_ctrl(void* manger,int saddr,unsigned char chn,unsigned short sts)
  415. {
  416. unsigned int offset = 0;
  417. if(chn>=4)
  418. return -1;
  419. offset = _SWITCH_AC_SINGLE_S_CHN_STS+chn;
  420. g_modbus_write_reg(manger,saddr,offset,offset);
  421. return 0 ;
  422. }
  423. /// @brief 设置单相大电流所有通道开关状态
  424. /// @param manger
  425. /// @param saddr
  426. /// @param sts
  427. /// @return
  428. int g_switch_set_ac_single_b_ctrl(void* manger,int saddr,unsigned short* sts,int nsize)
  429. {
  430. if (nsize < 1 || nsize > 4)
  431. {
  432. return 0 ;
  433. }
  434. unsigned int offset = 0;
  435. offset = _SWITCH_AC_SINGLE_S_CHN_STS;
  436. g_modbus_write_x_reg(manger,saddr,offset,nsize,sts);
  437. return 0 ;
  438. }
  439. /// @brief 设置直流所有通道开关状态
  440. /// @param manger
  441. /// @param saddr
  442. /// @param sts
  443. /// @return
  444. int g_switch_set_dc_ctrl(void* manger,int saddr,unsigned short sts)
  445. {
  446. unsigned int offset = 0;
  447. offset = _SWITCH_DC_STS;
  448. g_modbus_write_reg(manger,saddr,offset,sts);
  449. return 0 ;
  450. }
  451. /// @brief 设置单相小电流通道超限报警
  452. /// @param manger
  453. /// @param saddr
  454. /// @param chn
  455. /// @param _global_over_manager
  456. /// @return
  457. int g_switch_set_ac_single_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  458. {
  459. unsigned int offset = 0;
  460. unsigned int data_temp = 0 ;
  461. unsigned short data_buf[16] = {0};
  462. //电压上限
  463. data_temp = (_global_over_manager->product_vol_upper_threshold*1000);
  464. data_buf[0] = data_temp;
  465. data_buf[1] = data_temp>>16;
  466. //电压下限
  467. data_temp = (_global_over_manager->product_vol_lower_threshold*1000);
  468. data_buf[2] = data_temp;
  469. data_buf[3] = data_temp>>16;
  470. //电流上限
  471. data_temp = (_global_over_manager->product_cur_upper_threshold*1000);
  472. data_buf[4] = data_temp;
  473. data_buf[5] = data_temp>>16;
  474. //电流下限
  475. data_temp = (0);
  476. data_buf[6] = data_temp;
  477. data_buf[7] = data_temp>>16;
  478. //功率上限
  479. data_temp = (_global_over_manager->product_pwr_upper_threshold*1000);
  480. data_buf[8] = data_temp;
  481. data_buf[9] = data_temp>>16;
  482. //功率下限
  483. data_temp = 0;
  484. data_buf[10] = data_temp;
  485. data_buf[11] = data_temp>>16;
  486. //电能上限
  487. data_temp = (_global_over_manager->product_pwrcon_upper_threshold*1000);
  488. data_buf[12] = data_temp;
  489. data_buf[13] = data_temp>>16;
  490. //电能下限
  491. data_temp = 0;
  492. data_buf[14] = data_temp;
  493. data_buf[15] = data_temp>>16;
  494. offset = _SWITCH_AC_SINGLE_S_Threshold+chn*16;
  495. int ret= g_modbus_write_x_reg(manger,saddr,offset,16,data_buf);
  496. //log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  497. return ret;
  498. }
  499. int g_switch_set_ac_reset(void *manger, int saddr)
  500. {
  501. return 0;
  502. }
  503. /// @brief 设置单相小电流通道KB
  504. /// @param manger
  505. /// @param saddr
  506. /// @param chn
  507. /// @param sts
  508. /// @return
  509. int g_switch_set_ac_single_s_kb_val(void* manger,int saddr,unsigned char chn,SwitchKbVal* _kb_val)
  510. {
  511. unsigned int offset = 0;
  512. unsigned int rval = 0 ;
  513. unsigned short data_temp[8] = {0};
  514. if(chn>=8)
  515. return -1;
  516. offset = _SWITCH_AC_SINGLE_S_KB_VAL+chn*8;
  517. data_temp[0] = (unsigned short)_kb_val->voltage_k;
  518. data_temp[1] = (unsigned short)((_kb_val->voltage_k-data_temp[0])*1000);
  519. data_temp[2] = (unsigned short)_kb_val->voltage_b;
  520. data_temp[3] = (unsigned short)((_kb_val->voltage_b-data_temp[2])*1000);
  521. data_temp[4] = (unsigned short)_kb_val->current_k;
  522. data_temp[5] = (unsigned short)((_kb_val->current_k-data_temp[4])*1000);
  523. data_temp[6] = (unsigned short)_kb_val->current_b;
  524. data_temp[7] = (unsigned short)((_kb_val->current_b-data_temp[6])*1000);
  525. g_modbus_write_x_reg(manger,saddr,offset,8,data_temp);
  526. return 0 ;
  527. }
  528. /// @brief 设置单相大电流通道KB
  529. /// @param manger
  530. /// @param saddr
  531. /// @param chn
  532. /// @param _kb_val
  533. /// @return
  534. int g_switch_set_ac_single_b_kb_val(void* manger,int saddr,unsigned char chn,SwitchKbVal* _kb_val)
  535. {
  536. unsigned int offset = 0;
  537. unsigned int rval = 0 ;
  538. unsigned short data_temp[8] = {0};
  539. if(chn>=4)
  540. return -1;
  541. offset = _SWITCH_AC_SINGLE_B_KB_VAL+chn*8;
  542. data_temp[0] = (unsigned short)_kb_val->voltage_k;
  543. data_temp[1] = (unsigned short)((_kb_val->voltage_k-data_temp[0])*1000);
  544. data_temp[2] = (unsigned short)_kb_val->voltage_b;
  545. data_temp[3] = (unsigned short)((_kb_val->voltage_b-data_temp[2])*1000);
  546. data_temp[4] = (unsigned short)_kb_val->current_k;
  547. data_temp[5] = (unsigned short)((_kb_val->current_k-data_temp[4])*1000);
  548. data_temp[6] = (unsigned short)_kb_val->current_b;
  549. data_temp[7] = (unsigned short)((_kb_val->current_b-data_temp[6])*1000);
  550. g_modbus_write_x_reg(manger,saddr,offset,8,data_temp);
  551. return 0 ;
  552. }
  553. /// @brief 设置直流KB值
  554. /// @param manger
  555. /// @param saddr
  556. /// @param _kb_val
  557. /// @return
  558. int g_switch_set_dc_kb_val(void* manger,int saddr,SwitchKbVal* _kb_val)
  559. {
  560. unsigned short offset = 0;
  561. unsigned short data_temp[8] = {0};
  562. offset = _SWITCH_DC_KB_VAL;
  563. data_temp[0] = (unsigned short)_kb_val->voltage_k;
  564. data_temp[1] = (unsigned short)((_kb_val->voltage_k-data_temp[0])*1000);
  565. data_temp[2] = (unsigned short)_kb_val->voltage_b;
  566. data_temp[3] = (unsigned short)((_kb_val->voltage_b-data_temp[2])*1000);
  567. data_temp[4] = (unsigned short)_kb_val->current_k;
  568. data_temp[5] = (unsigned short)((_kb_val->current_k-data_temp[4])*1000);
  569. data_temp[6] = (unsigned short)_kb_val->current_b;
  570. data_temp[7] = (unsigned short)((_kb_val->current_b-data_temp[6])*1000);
  571. g_modbus_write_x_reg(manger,saddr,offset,8, data_temp);
  572. return 0 ;
  573. }
  574. /// @brief 通用设置通道起始延时时间
  575. /// @param manger 管理类
  576. /// @param ntype 通道类型
  577. /// @param saddr 地址
  578. /// @param chn 偏移
  579. /// @param time 延时毫秒(ms)
  580. /// @return 0:成功 1失败
  581. int g_switch_set_all_start_time_delay(void* manger,int ntype,int saddr,unsigned char chn,unsigned int time)
  582. {
  583. switch (ntype)
  584. {
  585. case AC_SINGLE_S_TYPE:
  586. case AC_SINGLE_B_TYPE:
  587. {
  588. return g_switch_set_ac_single_s_start_time_delay(manger,saddr,(chn-1),time);
  589. }
  590. break;
  591. case DC_OUT_TYPE:
  592. {
  593. //g_switch_set_dc_start_time_delay(manger,saddr,chn,time);
  594. }
  595. break;
  596. case DCPDU_TYPE:
  597. {
  598. return g_switch_set_dcpdu_start_time_delay(manger, saddr,(chn-1), time/1000);
  599. }
  600. break;
  601. case TREE_AC_TYPE:
  602. {
  603. int ret = 0;
  604. if (__globalDeviceManage._globalDevInfo.product_pwr_type == SmartPDU_Tree_AC_Tree)
  605. {
  606. ret = g_switch_set_t_ac_start_time_delay(manger, saddr, (chn - 1) * 3, time / 1000);
  607. if (ret < 0)
  608. {
  609. ret = g_switch_set_t_ac_start_time_delay(manger, saddr, (chn - 1) * 3, time / 1000);
  610. if (ret < 0)
  611. return ret;
  612. }
  613. ret = g_switch_set_t_ac_start_time_delay(manger, saddr, (chn - 1) * 3 + 1, time / 1000);
  614. if (ret < 0)
  615. {
  616. ret = g_switch_set_t_ac_start_time_delay(manger, saddr, (chn - 1) * 3 + 1, time / 1000);
  617. if (ret < 0)
  618. return ret;
  619. }
  620. ret = g_switch_set_t_ac_start_time_delay(manger, saddr, (chn - 1) * 3 + 2, time / 1000);
  621. if (ret < 0)
  622. {
  623. ret = g_switch_set_t_ac_start_time_delay(manger, saddr, (chn - 1) * 3 + 2, time / 1000);
  624. if (ret < 0)
  625. return ret;
  626. return ret;
  627. }
  628. }
  629. else
  630. {
  631. ret = g_switch_set_t_ac_start_time_delay(manger, saddr, (chn - 1), time / 1000);
  632. if (ret < 0)
  633. {
  634. ret = g_switch_set_t_ac_start_time_delay(manger, saddr, (chn - 1), time / 1000);
  635. if (ret < 0)
  636. return ret;
  637. }
  638. }
  639. return 0;
  640. }
  641. case AC_MULTI_S_TYPE:
  642. case AC_MULTI_B_TYPE:
  643. case DC_IN_TYPE:
  644. default:
  645. return 1;
  646. break;
  647. }
  648. return 1;
  649. }
  650. /// @brief 通用设置通道起始延时时间
  651. /// @param manger 管理类
  652. /// @param ntype 通道类型
  653. /// @param saddr 地址
  654. /// @param chn 偏移
  655. /// @param time 延时毫秒(ms)
  656. /// @return 0:成功 1失败
  657. int g_switch_set_all_stop_time_delay(void* manger,int ntype,int saddr,unsigned char chn,unsigned int time)
  658. {
  659. switch (ntype)
  660. {
  661. case AC_SINGLE_S_TYPE:
  662. case AC_SINGLE_B_TYPE:
  663. {
  664. return g_switch_set_ac_single_s_stop_time_delay(manger, saddr, (chn - 1), time);
  665. }
  666. break;
  667. case DC_OUT_TYPE:
  668. {
  669. }
  670. break;
  671. case DCPDU_TYPE:
  672. {
  673. return g_switch_set_dcpdu_stop_time_delay(manger, saddr,(chn-1), time/1000);
  674. }
  675. break;
  676. case TREE_AC_TYPE:
  677. {
  678. int ret = 0;
  679. if (__globalDeviceManage._globalDevInfo.product_pwr_type == SmartPDU_Tree_AC_Tree)
  680. {
  681. ret = g_switch_set_t_ac_stop_time_delay(manger, saddr, (chn - 1) * 3, time / 1000);
  682. if (ret < 0)
  683. {
  684. ret = g_switch_set_t_ac_stop_time_delay(manger, saddr, (chn - 1) * 3, time / 1000);
  685. if (ret < 0)
  686. return ret;
  687. }
  688. ret = g_switch_set_t_ac_stop_time_delay(manger, saddr, (chn - 1) * 3 + 1, time / 1000);
  689. if (ret < 0)
  690. {
  691. ret = g_switch_set_t_ac_stop_time_delay(manger, saddr, (chn - 1) * 3 + 1, time / 1000);
  692. if (ret < 0)
  693. return ret;
  694. }
  695. ret = g_switch_set_t_ac_stop_time_delay(manger, saddr, (chn - 1) * 3 + 2, time / 1000);
  696. if (ret < 0)
  697. {
  698. ret = g_switch_set_t_ac_stop_time_delay(manger, saddr, (chn - 1) * 3 + 2, time / 1000);
  699. if (ret < 0)
  700. return ret;
  701. }
  702. }
  703. else
  704. {
  705. ret = g_switch_set_t_ac_stop_time_delay(manger, saddr, (chn - 1), time / 1000);
  706. if (ret < 0)
  707. {
  708. ret = g_switch_set_t_ac_stop_time_delay(manger, saddr, (chn - 1), time / 1000);
  709. if (ret < 0)
  710. return ret;
  711. }
  712. }
  713. return 0;
  714. }
  715. case AC_MULTI_S_TYPE:
  716. case AC_MULTI_B_TYPE:
  717. case DC_IN_TYPE:
  718. default:
  719. return 1;
  720. break;
  721. }
  722. return 1;
  723. }
  724. /// @brief 通用设置通道控制
  725. /// @param manger 管理类
  726. /// @param ntype 通道类型
  727. /// @param saddr 地址
  728. /// @param chn 偏移
  729. /// @param sts open/close
  730. /// @return 0:成功 1失败
  731. int g_switch_set_all_chn_ctrl(void* manger,GlobalPowerManger* _globalPowerMangerTemp,int saddr,unsigned char chn,unsigned short sts,bool isgroup)
  732. {
  733. switch (_globalPowerMangerTemp->product_ch_type)
  734. {
  735. case AC_SINGLE_S_TYPE:
  736. case AC_SINGLE_B_TYPE:
  737. {
  738. /* if (sts == 1)*/
  739. {
  740. if (_globalPowerMangerTemp->global_over_manager->product_vol_upper_enable == 1)
  741. sts |= ENABLE_V_UP;
  742. if (_globalPowerMangerTemp->global_over_manager->product_vol_lower_enable == 1)
  743. sts |= ENABLE_V_DOWN;
  744. if (_globalPowerMangerTemp->global_over_manager->product_cur_upper_enable == 1)
  745. sts |= ENABLE_A_UP;
  746. if (_globalPowerMangerTemp->global_over_manager->product_pwr_upper_enable == 1)
  747. sts |= ENABLE_W_UP;
  748. if (_globalPowerMangerTemp->global_over_manager->product_pwrcon_upper_enable == 1)
  749. sts |= ENABLE_P_UP;
  750. }
  751. return g_switch_set_ac_single_s_chn_ctrl(manger, saddr, (chn - 1), sts);
  752. }
  753. break;
  754. /*
  755. case AC_SINGLE_B_TYPE:
  756. {
  757. if (sts==1)
  758. {
  759. if(_globalPowerMangerTemp->global_over_manager->product_vol_upper_enable==1)sts|=ENABLE_V_UP;
  760. if(_globalPowerMangerTemp->global_over_manager->product_vol_lower_enable==1)sts|=ENABLE_V_DOWN;
  761. if(_globalPowerMangerTemp->global_over_manager->product_cur_upper_enable==1)sts|=ENABLE_A_UP;
  762. if(_globalPowerMangerTemp->global_over_manager->product_pwr_upper_enable==1)sts|=ENABLE_W_UP;
  763. if(_globalPowerMangerTemp->global_over_manager->product_pwrcon_upper_enable==1)sts|=ENABLE_P_UP;
  764. }
  765. return g_switch_set_ac_single_b_chn_ctrl(manger,saddr,(chn-1),sts);
  766. }
  767. break;*/
  768. case DC_OUT_TYPE:
  769. {
  770. // return g_switch_set_dc_ctrl();
  771. }
  772. break;
  773. case DCPDU_TYPE:
  774. {
  775. return g_switch_set_dcpdu_chn_ctrl(manger, saddr, (chn - 1), sts);
  776. }
  777. break;
  778. case TREE_AC_TYPE:
  779. {
  780. int t_ac_CtrlType=0;
  781. int nRet = 0;
  782. GlobalTreeACManager *_globalTACManager = NULL;
  783. list_for_each_entry(_globalTACManager, &_globalPowerMangerTemp->list_Tree_AC, list_Tree_AC)
  784. {
  785. t_ac_CtrlType=_globalTACManager->product_ph_outputType;
  786. }
  787. if (t_ac_CtrlType == 2&&__globalDeviceManage._globalDevInfo.product_pwr_type == SmartPDU_Tree_AC_Tree)
  788. {
  789. unsigned short phsts=0;
  790. list_for_each_entry(_globalTACManager, &_globalPowerMangerTemp->list_Tree_AC, list_Tree_AC)
  791. {
  792. if (/*sts == 1&&*/_globalTACManager->product_ph_outputStatus==1)
  793. {
  794. phsts=sts;
  795. if (_globalTACManager->global_over_manager->product_vol_upper_enable == 1)
  796. phsts |= ENABLE_TAC_V_UP;
  797. if (_globalTACManager->global_over_manager->product_vol_lower_enable == 1)
  798. phsts |= ENABLE_TAC_V_DOWN;
  799. if (_globalTACManager->global_over_manager->product_cur_upper_enable == 1)
  800. phsts |= ENABLE_TAC_A_UP;
  801. if (_globalTACManager->global_over_manager->product_pwr_upper_enable == 1)
  802. phsts |= ENABLE_TAC_W_UP;
  803. if (_globalTACManager->global_over_manager->product_pwrcon_upper_enable == 1)
  804. phsts |= ENABLE_TAC_P_UP;
  805. }else{
  806. phsts=0;
  807. }
  808. nRet= g_switch_set_t_ac_phchn_ctrl(manger, _globalTACManager->product_saddr, _globalTACManager->product_ch_addr - 1, phsts);
  809. if (nRet<0)
  810. {
  811. log_w("g_switch_set_t_ac_phchn_ctrl addr:%d chn:%d Error: %s",_globalTACManager->product_saddr, _globalTACManager->product_ch_addr - 1,modbus_strerror(errno));
  812. nRet= g_switch_set_t_ac_phchn_ctrl(manger, saddr, _globalTACManager->product_ch_addr - 1, phsts);
  813. if (nRet<0)
  814. {
  815. log_w("reset g_switch_set_t_ac_phchn_ctrl Error: %s",modbus_strerror(errno));
  816. return nRet;
  817. }
  818. }
  819. }
  820. return 1;
  821. }
  822. else
  823. {
  824. //if (sts == 1)
  825. {
  826. if (_globalPowerMangerTemp->global_over_manager->product_vol_upper_enable == 1)
  827. sts |= ENABLE_TAC_V_UP;
  828. if (_globalPowerMangerTemp->global_over_manager->product_vol_lower_enable == 1)
  829. sts |= ENABLE_TAC_V_DOWN;
  830. if (_globalPowerMangerTemp->global_over_manager->product_cur_upper_enable == 1)
  831. sts |= ENABLE_TAC_A_UP;
  832. if (_globalPowerMangerTemp->global_over_manager->product_pwr_upper_enable == 1)
  833. sts |= ENABLE_TAC_W_UP;
  834. if (_globalPowerMangerTemp->global_over_manager->product_pwrcon_upper_enable == 1)
  835. sts |= ENABLE_TAC_P_UP;
  836. }
  837. /*
  838. if (isgroup)
  839. {
  840. sts |= ENABLE_TAC_STIME;
  841. sts |= ENABLE_TAC_ETIME;
  842. }*/
  843. if (__globalDeviceManage._globalDevInfo.product_pwr_type == SmartPDU_Tree_AC_One)
  844. {
  845. return g_switch_set_t_ac_phchn_ctrl(manger, saddr, (chn - 1), sts);
  846. }else{
  847. return g_switch_set_t_ac_chn_ctrl(manger, saddr, (chn - 1), sts);
  848. }
  849. }
  850. }
  851. case AC_MULTI_S_TYPE:
  852. case AC_MULTI_B_TYPE:
  853. case DC_IN_TYPE:
  854. default:
  855. return 1;
  856. break;
  857. }
  858. return 1;
  859. }
  860. int g_switch_set_all_ctrl(void* manger,int ntype,int saddr,unsigned short sts)
  861. {
  862. GlobalPowerManger* _globalPowerMangerTemp = NULL ;
  863. unsigned short switch_ctrl[AC_SINGLE_S_CUR_CHN_NUM] = {0};
  864. for (size_t i = 0; i < AC_SINGLE_S_CUR_CHN_NUM; i++)
  865. {
  866. switch_ctrl[i] = sts ;
  867. }
  868. switch (ntype)
  869. {
  870. case AC_SINGLE_S_TYPE:
  871. {
  872. int nchNum=0;
  873. list_for_each_entry(_globalPowerMangerTemp, &__globalDeviceManage._globalPowerManger.list, list)
  874. {
  875. if(_globalPowerMangerTemp->product_saddr != saddr)continue;
  876. int nchAddr=_globalPowerMangerTemp->product_ch_addr-1;
  877. if(_globalPowerMangerTemp->global_over_manager->product_vol_upper_enable==1)switch_ctrl[nchAddr]|=ENABLE_V_UP;
  878. if(_globalPowerMangerTemp->global_over_manager->product_vol_lower_enable==1)switch_ctrl[nchAddr]|=ENABLE_V_DOWN;
  879. if(_globalPowerMangerTemp->global_over_manager->product_cur_upper_enable==1)switch_ctrl[nchAddr]|=ENABLE_A_UP;
  880. if(_globalPowerMangerTemp->global_over_manager->product_pwr_upper_enable==1)switch_ctrl[nchAddr]|=ENABLE_W_UP;
  881. if(_globalPowerMangerTemp->global_over_manager->product_pwrcon_upper_enable==1)switch_ctrl[nchAddr]|=ENABLE_P_UP;
  882. int nStatus=switch_ctrl[nchAddr]&BIT_00;
  883. if(nStatus==1)
  884. {
  885. switch_ctrl[nchAddr]|=ENABLE_ALL_UP;
  886. }else{
  887. switch_ctrl[nchAddr]|=ENABLE_ALL_DOWN;
  888. }
  889. nchNum++;
  890. }
  891. return g_switch_set_ac_single_s_ctrl(manger, saddr, switch_ctrl,nchNum);
  892. }
  893. break;
  894. case AC_SINGLE_B_TYPE:
  895. {
  896. int nchNum=0;
  897. list_for_each_entry(_globalPowerMangerTemp, &__globalDeviceManage._globalPowerManger.list, list)
  898. {
  899. if(_globalPowerMangerTemp->product_saddr != saddr)continue;
  900. int nchAddr=_globalPowerMangerTemp->product_ch_addr-1;
  901. if(_globalPowerMangerTemp->global_over_manager->product_vol_upper_enable==1)switch_ctrl[nchAddr]|=ENABLE_V_UP;
  902. if(_globalPowerMangerTemp->global_over_manager->product_vol_lower_enable==1)switch_ctrl[nchAddr]|=ENABLE_V_DOWN;
  903. if(_globalPowerMangerTemp->global_over_manager->product_cur_upper_enable==1)switch_ctrl[nchAddr]|=ENABLE_A_UP;
  904. if(_globalPowerMangerTemp->global_over_manager->product_pwr_upper_enable==1)switch_ctrl[nchAddr]|=ENABLE_W_UP;
  905. if(_globalPowerMangerTemp->global_over_manager->product_pwrcon_upper_enable==1)switch_ctrl[nchAddr]|=ENABLE_P_UP;
  906. int nStatus=switch_ctrl[nchAddr]&BIT_00;
  907. if(nStatus==1)
  908. {
  909. switch_ctrl[nchAddr]|=ENABLE_ALL_UP;
  910. }else{
  911. switch_ctrl[nchAddr]|=ENABLE_ALL_DOWN;
  912. }
  913. nchNum++;
  914. }
  915. return g_switch_set_ac_single_b_ctrl(manger,saddr,switch_ctrl,nchNum);
  916. }
  917. break;
  918. case DC_OUT_TYPE:
  919. {
  920. //return g_switch_set_dc_ctrl();
  921. }
  922. break;
  923. case DCPDU_TYPE:
  924. {
  925. return g_switch_set_dcpdu_ctrl(manger, saddr, switch_ctrl);
  926. }
  927. break;
  928. case TREE_AC_TYPE:
  929. {
  930. return g_switch_set_t_ac_ctrl(manger, saddr,switch_ctrl);
  931. }
  932. case AC_MULTI_S_TYPE:
  933. case AC_MULTI_B_TYPE:
  934. case DC_IN_TYPE:
  935. default:
  936. return 1;
  937. break;
  938. }
  939. return 1;
  940. }
  941. int g_switch_set_all_single_threshold(void* manger,int ntype,int saddr,char chn,GlobalPowerManger* _globalPowerMangerTemp)
  942. {
  943. int ret =0;
  944. int sts=_globalPowerMangerTemp->_PowerInfo.status;
  945. GlobalOverManager* _global_over_manager=_globalPowerMangerTemp->global_over_manager;
  946. if (chn == 0)
  947. {
  948. ret = g_switch_set_t_ac_in_threshold(manger, 1, _global_over_manager);
  949. }
  950. else
  951. {
  952. switch (ntype)
  953. {
  954. case AC_SINGLE_S_TYPE:
  955. case AC_SINGLE_B_TYPE:
  956. {
  957. ret = g_switch_set_ac_single_threshold(manger, saddr, (chn - 1), _global_over_manager);
  958. if (_globalPowerMangerTemp->global_over_manager->product_vol_upper_enable == 1)
  959. sts |= ENABLE_V_UP;
  960. if (_globalPowerMangerTemp->global_over_manager->product_vol_lower_enable == 1)
  961. sts |= ENABLE_V_DOWN;
  962. if (_globalPowerMangerTemp->global_over_manager->product_cur_upper_enable == 1)
  963. sts |= ENABLE_A_UP;
  964. if (_globalPowerMangerTemp->global_over_manager->product_pwr_upper_enable == 1)
  965. sts |= ENABLE_W_UP;
  966. if (_globalPowerMangerTemp->global_over_manager->product_pwrcon_upper_enable == 1)
  967. sts |= ENABLE_P_UP;
  968. return g_switch_set_ac_single_s_chn_ctrl(manger, saddr, (chn - 1), sts);
  969. }
  970. break;
  971. case DC_OUT_TYPE:
  972. {
  973. // return g_switch_set_dc_ctrl();
  974. }
  975. break;
  976. case DCPDU_TYPE:
  977. {
  978. ret = g_switch_set_dcpdu_max_vol_threshold(manger, saddr, (chn - 1), _global_over_manager);
  979. ret = g_switch_set_dcpdu_min_vol_threshold(manger, saddr, (chn - 1), _global_over_manager);
  980. ret = g_switch_set_dcpdu_max_cur_threshold(manger, saddr, (chn - 1), _global_over_manager);
  981. return ret;
  982. }
  983. break;
  984. case TREE_AC_TYPE:
  985. {
  986. ret = g_switch_set_t_ac_max_vol_threshold(manger, saddr, (chn - 1), _global_over_manager);
  987. if (ret < 0)
  988. {
  989. log_e("Threshold Set Error=%s", modbus_strerror(errno));
  990. }
  991. ret = g_switch_set_t_ac_min_vol_threshold(manger, saddr, (chn - 1), _global_over_manager);
  992. if (ret < 0)
  993. {
  994. log_e("Threshold Set Error=%s", modbus_strerror(errno));
  995. }
  996. ret = g_switch_set_t_ac_max_cur_threshold(manger, saddr, (chn - 1), _global_over_manager);
  997. if (ret < 0)
  998. {
  999. log_e("Threshold Set Error=%s", modbus_strerror(errno));
  1000. }
  1001. ret = g_switch_set_t_ac_max_power_threshold(manger, saddr, (chn - 1), _global_over_manager);
  1002. if (ret < 0)
  1003. {
  1004. log_e("Threshold Set Error=%s", modbus_strerror(errno));
  1005. }
  1006. ret = g_switch_set_t_ac_max_pwrcon_threshold(manger, saddr, (chn - 1), _global_over_manager);
  1007. if (ret < 0)
  1008. {
  1009. log_e("Threshold Set Error=%s", modbus_strerror(errno));
  1010. }
  1011. ret = g_switch_set_t_ac_alarm_ctrl(manger, saddr, (chn - 1), _global_over_manager);
  1012. if (ret < 0)
  1013. {
  1014. log_e("Threshold AlarmCtrl Set Error=%s", modbus_strerror(errno));
  1015. }
  1016. if (_globalPowerMangerTemp->global_over_manager->product_vol_upper_enable == 1)
  1017. sts |= ENABLE_TAC_V_UP;
  1018. if (_globalPowerMangerTemp->global_over_manager->product_vol_lower_enable == 1)
  1019. sts |= ENABLE_TAC_V_DOWN;
  1020. if (_globalPowerMangerTemp->global_over_manager->product_cur_upper_enable == 1)
  1021. sts |= ENABLE_TAC_A_UP;
  1022. if (_globalPowerMangerTemp->global_over_manager->product_pwr_upper_enable == 1)
  1023. sts |= ENABLE_TAC_W_UP;
  1024. if (_globalPowerMangerTemp->global_over_manager->product_pwrcon_upper_enable == 1)
  1025. sts |= ENABLE_TAC_P_UP;
  1026. if (__globalDeviceManage._globalDevInfo.product_pwr_type == SmartPDU_Tree_AC_One)
  1027. {
  1028. return g_switch_set_t_ac_phchn_ctrl(manger, saddr, (chn - 1), sts);
  1029. }else{
  1030. return g_switch_set_t_ac_chn_ctrl(manger, saddr, (chn - 1), sts);
  1031. }
  1032. return ret;
  1033. }
  1034. break;
  1035. case AC_MULTI_S_TYPE:
  1036. case AC_MULTI_B_TYPE:
  1037. case DC_IN_TYPE:
  1038. default:
  1039. return 1;
  1040. break;
  1041. }
  1042. }
  1043. return 1;
  1044. }
  1045. int g_switch_get_all_out_info(void* manger,int ntype,int saddr,int nNumb,PowerInfo* _power,PowerWarningInfo* _warning)
  1046. {
  1047. switch (ntype)
  1048. {
  1049. case AC_SINGLE_S_TYPE:
  1050. case AC_SINGLE_B_TYPE:
  1051. {
  1052. return g_switch_get_ac_single_s_all_cur_info(manger, saddr, nNumb, _power, _warning);
  1053. }
  1054. break;
  1055. case DCPDU_TYPE:
  1056. {
  1057. return g_switch_get_dcpdu_all_out_info(manger, saddr, nNumb, _power, _warning);
  1058. }
  1059. break;
  1060. case TREE_AC_TYPE:
  1061. {
  1062. return g_switch_get_t_ac_all_out_info(manger, saddr, nNumb, _power, _warning);
  1063. }
  1064. break;
  1065. case AC_MULTI_S_TYPE:
  1066. case AC_MULTI_B_TYPE:
  1067. case DC_IN_TYPE:
  1068. default:
  1069. return 1;
  1070. break;
  1071. }
  1072. return 1;
  1073. }
  1074. int g_switch_get_all_reset(void* manger,int ntype,int saddr)
  1075. {
  1076. switch (ntype)
  1077. {
  1078. case AC_SINGLE_S_TYPE:
  1079. case AC_SINGLE_B_TYPE:
  1080. {
  1081. return g_switch_set_ac_reset(manger, saddr);
  1082. }
  1083. break;
  1084. case DCPDU_TYPE:
  1085. {
  1086. return g_switch_set_dcpdu_reset(manger, saddr);
  1087. }
  1088. break;
  1089. case TREE_AC_TYPE:
  1090. {
  1091. return g_switch_set_t_ac_reset(manger, saddr);
  1092. }
  1093. break;
  1094. case AC_MULTI_S_TYPE:
  1095. case AC_MULTI_B_TYPE:
  1096. case DC_IN_TYPE:
  1097. default:
  1098. return 1;
  1099. break;
  1100. }
  1101. return 1;
  1102. }
  1103. int g_switch_get_dcpdu_out_info(void* manger,int saddr,unsigned char chn,PowerInfo* _power,PowerWarningInfo* _warning)
  1104. {
  1105. unsigned int offset = 0;
  1106. unsigned int val = 0 ;
  1107. unsigned short data_temp[12] = {0};
  1108. unsigned int status_temp = 0 ;
  1109. offset = _SWITCH_DCPDU_OUT_INFO + chn * 4;
  1110. //读取4个寄存器
  1111. int ret = g_modbus_read_x_reg(manger,saddr,offset,8,data_temp);
  1112. //解电压数据
  1113. float value = (data_temp[1] << 16) + data_temp[0];
  1114. _power->voltage = value / 1000.0;
  1115. //解电流数据
  1116. value = (data_temp[3] << 16) + data_temp[2];
  1117. _power->current = value / 1000.0;
  1118. //解功率数据
  1119. value = (data_temp[5] << 16) + data_temp[4];
  1120. _power->power = value / 1000.0;
  1121. value = (data_temp[7] << 16) + data_temp[6];
  1122. _power->consumption = value / 1000.0;
  1123. //获取开关状态
  1124. offset = _SWITCH_DCPDU_STS_INFO;
  1125. memset(data_temp,0,sizeof(data_temp));
  1126. ret = g_modbus_read_x_reg(manger,saddr,offset, 2, data_temp);
  1127. status_temp = (data_temp[1] << 16) + data_temp[0];
  1128. _power->status = (status_temp >> chn) & 0x1;
  1129. //获取故障状态
  1130. offset = _SWITCH_DCPDU_STS_ERROR;
  1131. memset(data_temp,0,sizeof(data_temp));
  1132. ret = g_modbus_read_x_reg(manger,saddr,offset, 2, data_temp);
  1133. status_temp = (data_temp[1] << 16) + data_temp[0];
  1134. _warning->w_voltage_up = (status_temp >> chn) & 0x1;
  1135. return ret;
  1136. }
  1137. int g_switch_get_dcpdu_all_out_info(void* manger,int saddr,int nNumb,PowerInfo* _power,PowerWarningInfo* _warning)
  1138. {
  1139. unsigned int offset = 0;
  1140. unsigned int value = 0;
  1141. unsigned short data_temp[64] = {0};
  1142. unsigned int status_temp = 0;
  1143. int ret = 0;
  1144. offset = _SWITCH_DCPDU_OUT_INFO;
  1145. // 读取4个寄存器
  1146. // 读取寄存器
  1147. memset(data_temp, 0, sizeof(data_temp));
  1148. //一次读2个
  1149. /*
  1150. ret = g_modbus_read_x_reg(manger, saddr, offset, 16, data_temp);
  1151. if (ret < 0)
  1152. {
  1153. log_w("g_switch_get_t_dcpdu_info:addrs:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1154. // log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  1155. return ret;
  1156. }
  1157. offset = _SWITCH_T_AC_OUT_INFO + 8;
  1158. unsigned short *DataTemp = data_temp + 16;
  1159. ret = g_modbus_read_x_reg(manger, saddr, offset, 16, DataTemp);
  1160. if (ret < 0)
  1161. {
  1162. log_w("g_switch_get_t_dcpdu_info:addrs:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1163. // log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  1164. return ret;
  1165. }
  1166. offset = _SWITCH_T_AC_OUT_INFO + 16;
  1167. DataTemp = data_temp + 32;
  1168. ret = g_modbus_read_x_reg(manger, saddr, offset, 16, DataTemp);
  1169. if (ret < 0)
  1170. {
  1171. log_w("g_switch_get_t_dcpdu_info:addrs:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1172. // log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  1173. return ret;
  1174. }
  1175. offset = _SWITCH_T_AC_OUT_INFO + 24;
  1176. DataTemp = data_temp + 48;
  1177. ret = g_modbus_read_x_reg(manger, saddr, offset, 16, DataTemp);
  1178. if (ret < 0)
  1179. {
  1180. log_w("g_switch_get_t_dcpdu_info:addrs:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1181. // log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  1182. return ret;
  1183. }
  1184. */
  1185. //一次读4个
  1186. ret = g_modbus_read_x_reg(manger, saddr, offset, 32, data_temp);
  1187. if (ret < 0)
  1188. {
  1189. log_w("g_switch_get_t_dcpdu_info:addrs:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1190. // log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  1191. return ret;
  1192. }
  1193. offset = _SWITCH_DCPDU_OUT_INFO + 16;
  1194. unsigned short *DataTemp = data_temp + 32;
  1195. ret = g_modbus_read_x_reg(manger, saddr, offset, 32, DataTemp);
  1196. if (ret < 0)
  1197. {
  1198. log_w("g_switch_get_t_dcpdu_info:addrs:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1199. // log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  1200. return ret;
  1201. }
  1202. // 解电压数据
  1203. for (size_t i = 0; i < nNumb; i++)
  1204. {
  1205. int Index = i * 8;
  1206. // 解电压数据
  1207. float value = (data_temp[1 + Index] << 16) + data_temp[0 + Index];
  1208. _power[i].voltage = value / 1000.0;
  1209. // 解电流数据
  1210. value = (data_temp[3 + Index] << 16) + data_temp[2 + Index];
  1211. _power[i].current = value / 1000.0;
  1212. // 解功率数据
  1213. value = (data_temp[5 + Index] << 16) + data_temp[4 + Index];
  1214. _power[i].power = value / 1000.0;
  1215. value = (data_temp[7 + Index] << 16) + data_temp[6 + Index];
  1216. _power[i].consumption = value / 1000.0;
  1217. }
  1218. offset = _SWITCH_DCPDU_STS_INFO;
  1219. // 读取寄存器
  1220. memset(data_temp, 0, sizeof(data_temp));
  1221. ret = g_modbus_read_x_reg(manger, saddr, offset, 2, data_temp);
  1222. // 解控制数据
  1223. if (ret < 0)
  1224. {
  1225. return ret;
  1226. }
  1227. for (size_t i = 0; i < nNumb; i++)
  1228. {
  1229. status_temp = (data_temp[1] << 16) + data_temp[0];
  1230. _power[i].status = (status_temp >> i) & 0x1;
  1231. }
  1232. // 获取故障状态
  1233. offset = _SWITCH_DCPDU_STS_ERROR;
  1234. memset(data_temp, 0, sizeof(data_temp));
  1235. ret = g_modbus_read_x_reg(manger, saddr, offset, 2, data_temp);
  1236. if (ret < 0)
  1237. {
  1238. return ret;
  1239. }
  1240. for (size_t i = 0; i < nNumb; i++)
  1241. {
  1242. status_temp = (data_temp[1] << 16) + data_temp[0];
  1243. _warning[i].w_voltage_up = (status_temp >> i) & 0x1;
  1244. }
  1245. return 0;
  1246. }
  1247. int g_switch_get_dcpdu_in_info(void* manger,int saddr,PowerInfo* _power)
  1248. {
  1249. unsigned int offset = 0;
  1250. unsigned int value = 0 ;
  1251. unsigned short data_temp[18] = {0};
  1252. offset = _SWITCH_DCPDU_IN_INFO;
  1253. //读取4个寄存器
  1254. g_modbus_read_x_reg(manger,saddr,offset,16,data_temp);
  1255. //解电压数据
  1256. value = (data_temp[1] << 16) + data_temp[0];
  1257. _power->voltage = value / 1000.0;
  1258. //解电流数据
  1259. value = (data_temp[3] << 16) + data_temp[2];
  1260. _power->current = value / 1000.0;
  1261. //解功率数据
  1262. value = (data_temp[5] << 16) + data_temp[4];
  1263. _power->power = value / 1000.0;
  1264. value = (data_temp[7] << 16) + data_temp[6];
  1265. _power->consumption = value / 1000.0;
  1266. return 0;
  1267. }
  1268. int g_switch_get_dcpdu_start_time_delay(void* manger,int saddr,unsigned int* time)
  1269. {
  1270. unsigned int offset = 0;
  1271. unsigned short data_temp[16];
  1272. offset = _SWITCH_DCPDU_START_DELAY_TIME;
  1273. int ret = g_modbus_read_x_reg(manger,saddr,offset,16,data_temp);
  1274. unsigned int value = 0;
  1275. for(int i = 0; i < 8; i++)
  1276. {
  1277. value = (data_temp[i * 2 + 1] << 16) + data_temp[i * 2];
  1278. time[i] = value;
  1279. }
  1280. return ret;
  1281. }
  1282. int g_switch_get_dcpdu_stop_time_delay(void* manger,int saddr,unsigned int* time)
  1283. {
  1284. unsigned int offset = 0;
  1285. unsigned short data_temp[16];
  1286. offset = _SWITCH_DCPDU_STOP_DELAY_TIME;
  1287. int ret = g_modbus_read_x_reg(manger,saddr,offset,16,data_temp);
  1288. unsigned int value = 0;
  1289. for(int i = 0; i < 8; i++)
  1290. {
  1291. value = (data_temp[i * 2 + 1] << 16) + data_temp[i * 2];
  1292. time[i] = value;
  1293. }
  1294. return ret;
  1295. }
  1296. int g_switch_set_dcpdu_start_time_delay(void* manger,int saddr, int ch,unsigned int time)
  1297. {
  1298. unsigned int offset = 0;
  1299. unsigned short data_temp[4];
  1300. offset = _SWITCH_DCPDU_START_DELAY_TIME + ch ;
  1301. data_temp[0] = time & 0xFFFF;
  1302. data_temp[1] = (time >> 16) & 0XFFFF;
  1303. int reg = g_modbus_write_x_reg(manger,saddr,offset,2,data_temp);
  1304. if (reg>=0)
  1305. {
  1306. log_d("StartDelayTime_Addr:%d ch:%d OffSet:%d Time:%d Ret=%d",saddr,ch,offset,time,reg);
  1307. }
  1308. else
  1309. {
  1310. log_w("StartDelayTime_Addr:%d ch:%d OffSet:%d Time:%d Ret=%d:%s",saddr,ch,offset,time,reg,modbus_strerror(errno));
  1311. }
  1312. return reg;
  1313. }
  1314. int g_switch_set_dcpdu_stop_time_delay(void* manger,int saddr, int ch, unsigned int time)
  1315. {
  1316. unsigned int offset = 0;
  1317. unsigned short data_temp[4];
  1318. offset = _SWITCH_DCPDU_STOP_DELAY_TIME + ch;
  1319. data_temp[0] = time & 0XFFFF;
  1320. data_temp[1] = (time >> 16) & 0xFFFF;
  1321. int reg = g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1322. if (reg>=0)
  1323. {
  1324. log_d("StopDelayTime_Addr:%d ch:%d OffSet:%d Time:%d Ret=%d",saddr,ch,offset,time,reg);
  1325. }
  1326. else
  1327. {
  1328. log_w("StopDelayTime_Addr:%d ch:%d OffSet:%d Time:%d Ret=%d:%s",saddr,ch,offset,time,reg,modbus_strerror(errno));
  1329. }
  1330. return reg;
  1331. }
  1332. int g_switch_set_dcpdu_chn_ctrl(void* manger,int saddr,unsigned char chn,unsigned short sts)
  1333. {
  1334. unsigned int offset = 0;
  1335. if(chn > 8 || chn < 0) return -1;
  1336. offset = _SWITCH_DCPDU_STS_INFO;
  1337. unsigned short data_temp[2];
  1338. //memset(data_temp,0,sizeof(data_temp));
  1339. int ret=g_modbus_read_x_reg_delay(manger,saddr,offset,2, data_temp);
  1340. if (ret<0)
  1341. {
  1342. log_w("Ctrl Error Ret=%d:%s",ret,modbus_strerror(errno));
  1343. return -1;
  1344. }
  1345. log_w("Ctrl get addr%d Mark=%d,%d",saddr,data_temp[1],data_temp[0]);
  1346. unsigned short mask = ~(1 << chn);
  1347. data_temp[0] &= mask;
  1348. data_temp[0] |= (sts << chn);
  1349. log_w("Ctrl set addr%d chn %d Mark=%d,%d",saddr,chn,data_temp[1],data_temp[0]);
  1350. return g_modbus_write_x_reg(manger,saddr,offset, 2, data_temp);
  1351. }
  1352. //一次性刷新一个板子的数据
  1353. int g_switch_set_dcpdu_chns_ctrl(void* manger,int saddr,unsigned short sts,int nSet)
  1354. {
  1355. unsigned int offset = 0;
  1356. offset = _SWITCH_DCPDU_STS_INFO;
  1357. unsigned short data_temp[2];
  1358. //memset(data_temp,0,sizeof(data_temp));
  1359. int ret=g_modbus_read_x_reg_delay(manger,saddr,offset,2, data_temp);
  1360. if (ret<0)
  1361. {
  1362. log_w("Ctrl Error Ret=%d:%s",ret,modbus_strerror(errno));
  1363. return -1;
  1364. }
  1365. log_w("Ctrl get addr%d Mark=%d,%d",saddr,data_temp[1],data_temp[0]);
  1366. if (nSet==0)
  1367. { //关闭
  1368. sts=~sts;
  1369. data_temp[0] &= sts;
  1370. }else{
  1371. //开启
  1372. data_temp[0] |= sts;
  1373. }
  1374. log_w("Ctrl set addr%d Mark=%d,%d",saddr,data_temp[1],data_temp[0]);
  1375. return g_modbus_write_x_reg(manger,saddr,offset, 2, data_temp);
  1376. }
  1377. int g_switch_set_dcpdu_ctrl(void* manger,int saddr,unsigned short* sts)
  1378. {
  1379. unsigned int offset = 0;
  1380. unsigned short data_temp[2];
  1381. if (sts[0] == 1)
  1382. {
  1383. offset = _SWITCH_DCPDU_ALL_OPEN_INFO;
  1384. data_temp[0] = 0xFFFF;
  1385. data_temp[1] = 0xFFFF;
  1386. }
  1387. else
  1388. {
  1389. offset = _SWITCH_DCPDU_ALL_CLOSE_INFO;
  1390. data_temp[0] = 0;
  1391. data_temp[1] = 0;
  1392. }
  1393. return g_modbus_write_x_reg(manger,saddr,offset, 2, data_temp);
  1394. }
  1395. int g_switch_get_dcpdu_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1396. {
  1397. unsigned int offset = 0;
  1398. unsigned short data_temp[4];
  1399. memset(data_temp,0,sizeof(data_temp));
  1400. unsigned int value = 0;
  1401. offset = _SWITCH_DCPDU_MAX_VOL_THRESHOLD + chn;
  1402. int ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1403. value = (data_temp[1] << 16) + data_temp[0];
  1404. _global_over_manager->product_vol_upper_threshold = value / 1000.0;
  1405. offset = _SWITCH_DCPDU_MIN_VOL_THRESHOLD + chn;
  1406. ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1407. value = (data_temp[1] << 16) + data_temp[0];
  1408. _global_over_manager->product_vol_lower_threshold = value / 1000.0;
  1409. offset = _SWITCH_DCPDU_MAX_CUR_THRESHOLD + chn;
  1410. ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1411. value = (data_temp[1] << 16) + data_temp[0];
  1412. _global_over_manager->product_cur_upper_threshold = value / 1000.0;
  1413. offset = _SWITCH_DCPDU_MIN_CUR_THRESHOLD + chn;
  1414. ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1415. value = (data_temp[1] << 16) + data_temp[0];
  1416. _global_over_manager->product_cur_lower_threshold = value / 1000.0;
  1417. return ret;
  1418. }
  1419. int g_switch_set_dcpdu_max_vol_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1420. {
  1421. unsigned int offset = 0;
  1422. unsigned short data_temp[4];
  1423. memset(data_temp,0,sizeof(data_temp));
  1424. unsigned int value = 0;
  1425. offset = _SWITCH_DCPDU_MAX_VOL_THRESHOLD + chn;
  1426. value = _global_over_manager->product_vol_upper_threshold * 1000;
  1427. data_temp[0] = value & 0XFFFF;
  1428. data_temp[1] = (value >> 16) & 0xFFFF;
  1429. return g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1430. }
  1431. int g_switch_set_dcpdu_min_vol_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1432. {
  1433. unsigned int offset = 0;
  1434. unsigned short data_temp[4];
  1435. memset(data_temp,0,sizeof(data_temp));
  1436. unsigned int value = 0;
  1437. offset = _SWITCH_DCPDU_MIN_VOL_THRESHOLD + chn;
  1438. value = _global_over_manager->product_vol_lower_threshold * 1000;
  1439. data_temp[0] = value & 0XFFFF;
  1440. data_temp[1] = (value >> 16) & 0xFFFF;
  1441. return g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1442. }
  1443. int g_switch_set_dcpdu_max_cur_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1444. {
  1445. unsigned int offset = 0;
  1446. unsigned short data_temp[4];
  1447. memset(data_temp,0,sizeof(data_temp));
  1448. unsigned int value = 0;
  1449. offset = _SWITCH_DCPDU_MAX_CUR_THRESHOLD + chn;
  1450. value = _global_over_manager->product_cur_upper_threshold * 1000;
  1451. data_temp[0] = value & 0XFFFF;
  1452. data_temp[1] = (value >> 16) & 0xFFFF;
  1453. return g_modbus_write_x_reg(manger,saddr,offset, 2, data_temp);
  1454. }
  1455. int g_switch_set_dcpdu_min_cur_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1456. {
  1457. unsigned int offset = 0;
  1458. unsigned short data_temp[4];
  1459. memset(data_temp,0,sizeof(data_temp));
  1460. unsigned int value = 0;
  1461. offset = _SWITCH_DCPDU_MIN_CUR_THRESHOLD + chn;
  1462. value = _global_over_manager->product_cur_lower_threshold * 1000;
  1463. data_temp[0] = value & 0XFFFF;
  1464. data_temp[1] = (value >> 16) & 0xFFFF;
  1465. return g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1466. }
  1467. int g_switch_set_dcpdu_reset(void* manger,int saddr)
  1468. {
  1469. return 0;
  1470. }
  1471. int g_switch_get_t_ac_out_info(void* manger,int saddr,unsigned char chn,PowerInfo* _power,PowerWarningInfo* _warning)
  1472. {
  1473. unsigned int offset = 0;
  1474. unsigned int val = 0 ;
  1475. unsigned short data_temp[16] = {0};
  1476. unsigned int status_temp = 0 ;
  1477. offset = _SWITCH_T_AC_OUT_INFO + chn * 8;
  1478. //读取4个寄存器
  1479. int ret = g_modbus_read_x_reg(manger,saddr,offset,16,data_temp);
  1480. //解电压数据
  1481. float value = (data_temp[1] << 16) + data_temp[0];
  1482. _power->voltage = value / 1000.0;
  1483. //解电流数据
  1484. value = (data_temp[3] << 16) + data_temp[2];
  1485. _power->current = value / 1000.0;
  1486. //解功率数据
  1487. value = (data_temp[5] << 16) + data_temp[4];
  1488. _power->power = value / 1000.0;
  1489. //无功
  1490. value = (data_temp[7] << 16) + data_temp[6];
  1491. //视在功率
  1492. value = (data_temp[9] << 16) + data_temp[8];
  1493. //解频率数据
  1494. val = (data_temp[11]<<16)+data_temp[10];
  1495. _power->freq = val/1000.0;
  1496. //解耗电量数据
  1497. val = (data_temp[13]<<16)+data_temp[12];
  1498. _power->consumption = val/1000.0;
  1499. //解功率因素数据
  1500. val = (data_temp[15]<<16)+data_temp[14];
  1501. _power->factor = val/1023.0;
  1502. //获取开关状态
  1503. offset = _SWITCH_T_AC_OUT_ENABLE+ chn;
  1504. memset(data_temp,0,sizeof(data_temp));
  1505. ret = g_modbus_read_x_reg(manger,saddr,offset, 2,data_temp);
  1506. _power->status = data_temp[0] & BIT_00;
  1507. //获取故障状态
  1508. offset = _SWITCH_T_AC_OUT_ERROR+ chn;
  1509. memset(data_temp,0,sizeof(data_temp));
  1510. ret = g_modbus_read_x_reg(manger,saddr,offset, 2,data_temp);
  1511. _warning->w_voltage_up = data_temp[0] & BIT_00;
  1512. _warning->w_voltage_down = data_temp[0] & BIT_01;
  1513. _warning->w_current = data_temp[0] & BIT_02;
  1514. _warning->w_power = data_temp[0] & BIT_03;
  1515. _warning->w_consumption = data_temp[0] & BIT_04;
  1516. return ret;
  1517. }
  1518. int g_switch_get_t_ac_all_out_info(void* manger,int saddr,int nNumb,PowerInfo* _power,PowerWarningInfo* _warning)
  1519. {
  1520. unsigned int offset = 0;
  1521. unsigned int val = 0 ;
  1522. unsigned short data_temp[144] = {0};
  1523. unsigned int status_temp = 0 ;
  1524. offset = _SWITCH_T_AC_OUT_INFO;
  1525. //读取4个寄存器
  1526. int ret = g_modbus_read_x_reg(manger, saddr, offset, 80, data_temp);
  1527. if (ret < 0)
  1528. {
  1529. log_w("g_switch_get_T_ac_in_info:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1530. return ret;
  1531. }
  1532. offset = _SWITCH_T_AC_OUT_INFO+40;
  1533. unsigned short* DataTemp=data_temp+80;
  1534. ret = g_modbus_read_x_reg(manger, saddr, offset, 64, DataTemp);
  1535. if (ret < 0)
  1536. {
  1537. log_w("g_switch_get_T_ac_in_info:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1538. return ret;
  1539. }
  1540. //offset = _SWITCH_T_AC_OUT_INFO+48;
  1541. //DataTemp=data_temp+96;
  1542. // ret = g_modbus_read_x_reg(manger, saddr, offset, 48, DataTemp);
  1543. // if (ret < 0)
  1544. //{
  1545. // log_w("g_switch_get_T_ac_in_info:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1546. // return ret;
  1547. // }
  1548. for (size_t i = 0; i < nNumb; i++)
  1549. {
  1550. int Index = i * 16;
  1551. // 解电压数据
  1552. float value = (data_temp[1+Index] << 16) + data_temp[0+Index];
  1553. _power[i].voltage = value / 1000.0;
  1554. // 解电流数据
  1555. value = (data_temp[3+Index] << 16) + data_temp[2+Index];
  1556. _power[i].current = value / 1000.0;
  1557. // 解功率数据
  1558. value = (data_temp[5+Index] << 16) + data_temp[4+Index];
  1559. _power[i].power = value / 1000.0;
  1560. // 无功
  1561. value = (data_temp[7+Index] << 16) + data_temp[6+Index];
  1562. // 视在功率
  1563. value = (data_temp[9+Index] << 16) + data_temp[8+Index];
  1564. // 解频率数据
  1565. val = (data_temp[11+Index] << 16) + data_temp[10+Index];
  1566. _power[i].freq = val / 1000.0;
  1567. // 解耗电量数据
  1568. val = (data_temp[13+Index] << 16) + data_temp[12+Index];
  1569. _power[i].consumption = val / 1000.0;
  1570. // 解功率因素数据
  1571. val = (data_temp[15+Index] << 16) + data_temp[14+Index];
  1572. _power[i].factor = val / 1023.0;
  1573. }
  1574. //获取通道开关状态及零线状态
  1575. //_SWITCH_T_AC_OUT_ENABLE +18
  1576. //_SWITCH_T_AC_NF_STATUS +2
  1577. offset = _SWITCH_T_AC_OUT_ENABLE;
  1578. memset(data_temp,0,sizeof(data_temp));
  1579. ret = g_modbus_read_x_reg(manger,saddr,offset, 20,data_temp);
  1580. if (ret < 0)
  1581. {
  1582. log_w("g_switch_get_T_ac_in_info:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1583. return ret;
  1584. }
  1585. for (size_t i = 0; i < nNumb; i++)
  1586. {
  1587. int Index = i * 2;
  1588. _power[i].status = data_temp[0+Index] & BIT_00;
  1589. _power[i].NF_status = data_temp[18] & BIT_00;
  1590. }
  1591. //获取零线状态
  1592. /*offset = _SWITCH_T_AC_NF_STATUS;
  1593. memset(data_temp,0,sizeof(data_temp));
  1594. ret = g_modbus_read_x_reg(manger,saddr,offset, 2,data_temp);
  1595. if (ret < 0)
  1596. {
  1597. log_w("g_switch_get_T_ac_in_info:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1598. return ret;
  1599. }
  1600. for (size_t i = 0; i < nNumb; i++)
  1601. {
  1602. _power[i].NF_status = data_temp[18] & BIT_00;
  1603. }*/
  1604. //获取故障状态
  1605. offset = _SWITCH_T_AC_OUT_ERROR;
  1606. memset(data_temp,0,sizeof(data_temp));
  1607. ret = g_modbus_read_x_reg(manger,saddr,offset, 18,data_temp);
  1608. if (ret < 0)
  1609. {
  1610. log_w("g_switch_get_T_ac_in_info:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1611. return ret;
  1612. }
  1613. for (size_t i = 0; i < nNumb; i++)
  1614. {
  1615. int Index = i * 2;
  1616. _warning[i].w_voltage_up = data_temp[0+Index] & BIT_00;
  1617. _warning[i].w_voltage_down = data_temp[0+Index] & BIT_01;
  1618. _warning[i].w_current = data_temp[0+Index] & BIT_02;
  1619. _warning[i].w_power = data_temp[0+Index] & BIT_03;
  1620. _warning[i].w_consumption = data_temp[0+Index] & BIT_04;
  1621. }
  1622. return ret;
  1623. }
  1624. int g_switch_get_t_ac_start_time_delay(void* manger,int saddr,unsigned int* time)
  1625. {
  1626. unsigned int offset = 0;
  1627. unsigned short data_temp[16];
  1628. offset = _SWITCH_T_AC_START_DELAY_TIME;
  1629. int ret = g_modbus_read_x_reg(manger,saddr,offset,16,data_temp);
  1630. unsigned int value = 0;
  1631. for(int i = 0; i < 8; i++)
  1632. {
  1633. value = (data_temp[i * 2 + 1] << 16) + data_temp[i * 2];
  1634. time[i] = value;
  1635. }
  1636. return ret;
  1637. }
  1638. int g_switch_get_t_ac_stop_time_delay(void* manger,int saddr,unsigned int* time)
  1639. {
  1640. unsigned int offset = 0;
  1641. unsigned short data_temp[16];
  1642. offset = _SWITCH_T_AC_STOP_DELAY_TIME;
  1643. int ret = g_modbus_read_x_reg(manger,saddr,offset,16,data_temp);
  1644. unsigned int value = 0;
  1645. for(int i = 0; i < 8; i++)
  1646. {
  1647. value = (data_temp[i * 2 + 1] << 16) + data_temp[i * 2];
  1648. time[i] = value;
  1649. }
  1650. return ret;
  1651. }
  1652. int g_switch_get_t_ac_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1653. {
  1654. unsigned int offset = 0;
  1655. unsigned short data_temp[4];
  1656. memset(data_temp,0,sizeof(data_temp));
  1657. unsigned int value = 0;
  1658. float fvalue=0.0;
  1659. offset = _SWITCH_T_AC_MAX_VOL_THRESHOLD + chn;
  1660. int ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1661. value = (data_temp[1] << 16) + data_temp[0];
  1662. fvalue=(float)value;
  1663. _global_over_manager->product_vol_upper_threshold = fvalue / 1000.0;
  1664. offset = _SWITCH_T_AC_MIN_VOL_THRESHOLD + chn;
  1665. ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1666. value = (data_temp[1] << 16) + data_temp[0];
  1667. fvalue=(float)value;
  1668. _global_over_manager->product_vol_lower_threshold = fvalue / 1000.0;
  1669. offset = _SWITCH_T_AC_MAX_CUR_THRESHOLD + chn;
  1670. ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1671. value = (data_temp[1] << 16) + data_temp[0];
  1672. fvalue=(float)value;
  1673. _global_over_manager->product_cur_upper_threshold = fvalue / 1000.0;
  1674. offset = _SWITCH_T_AC_MAX_PWR_THRESHOLD + chn;
  1675. ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1676. value = (data_temp[1] << 16) + data_temp[0];
  1677. fvalue=(float)value;
  1678. _global_over_manager->product_pwr_upper_threshold = fvalue / 1000.0;
  1679. offset = _SWITCH_T_AC_MAX_PWRCON_THRESHOLD + chn;
  1680. ret = g_modbus_read_x_reg(manger,saddr,offset,2,data_temp);
  1681. value = (data_temp[1] << 16) + data_temp[0];
  1682. fvalue=(float)value;
  1683. _global_over_manager->product_pwrcon_upper_threshold = fvalue / 1000.0;
  1684. return ret;
  1685. }
  1686. int g_switch_set_t_ac_max_vol_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1687. {
  1688. unsigned int offset = 0;
  1689. unsigned short data_temp[4];
  1690. memset(data_temp,0,sizeof(data_temp));
  1691. unsigned int value = 0;
  1692. offset = _SWITCH_T_AC_MAX_VOL_THRESHOLD + chn;
  1693. value = _global_over_manager->product_vol_upper_threshold * 1000;
  1694. data_temp[0] = value & 0XFFFF;
  1695. data_temp[1] = (value >> 16) & 0xFFFF;
  1696. return g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1697. }
  1698. int g_switch_set_t_ac_min_vol_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1699. {
  1700. unsigned int offset = 0;
  1701. unsigned short data_temp[4];
  1702. memset(data_temp,0,sizeof(data_temp));
  1703. unsigned int value = 0;
  1704. offset = _SWITCH_T_AC_MIN_VOL_THRESHOLD + chn;
  1705. value = _global_over_manager->product_vol_lower_threshold * 1000;
  1706. data_temp[0] = value & 0XFFFF;
  1707. data_temp[1] = (value >> 16) & 0xFFFF;
  1708. return g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1709. }
  1710. int g_switch_set_t_ac_max_cur_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1711. {
  1712. unsigned int offset = 0;
  1713. unsigned short data_temp[4];
  1714. memset(data_temp,0,sizeof(data_temp));
  1715. unsigned int value = 0;
  1716. offset = _SWITCH_T_AC_MAX_CUR_THRESHOLD + chn;
  1717. value = _global_over_manager->product_cur_upper_threshold * 1000;
  1718. data_temp[0] = value & 0XFFFF;
  1719. data_temp[1] = (value >> 16) & 0xFFFF;
  1720. return g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1721. }
  1722. int g_switch_set_t_ac_max_power_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1723. {
  1724. unsigned int offset = 0;
  1725. unsigned short data_temp[4];
  1726. memset(data_temp,0,sizeof(data_temp));
  1727. unsigned int value = 0;
  1728. offset = _SWITCH_T_AC_MAX_PWR_THRESHOLD + chn;
  1729. value = _global_over_manager->product_pwr_upper_threshold * 1000;
  1730. data_temp[0] = value & 0XFFFF;
  1731. data_temp[1] = (value >> 16) & 0xFFFF;
  1732. return g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1733. }
  1734. int g_switch_set_t_ac_max_pwrcon_threshold(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1735. {
  1736. unsigned int offset = 0;
  1737. unsigned short data_temp[4];
  1738. memset(data_temp,0,sizeof(data_temp));
  1739. unsigned int value = 0;
  1740. offset = _SWITCH_T_AC_MAX_PWRCON_THRESHOLD + chn;
  1741. value = _global_over_manager->product_pwrcon_upper_threshold * 1000;
  1742. data_temp[0] = value & 0XFFFF;
  1743. data_temp[1] = (value >> 16) & 0xFFFF;
  1744. return g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1745. }
  1746. //报警控制方式
  1747. int g_switch_set_t_ac_alarm_ctrl(void* manger,int saddr,char chn,GlobalOverManager* _global_over_manager)
  1748. {
  1749. unsigned int offset = 0;
  1750. offset = _SWITCH_T_AC_ALARM_CTRL+chn;
  1751. int nStatus = 0;
  1752. if(_global_over_manager->product_vol_over_upper_threshold_ctrl==1)nStatus|=BIT_01;
  1753. if(_global_over_manager->product_vol_over_lower_threshold_ctrl==1)nStatus|=BIT_02;
  1754. if(_global_over_manager->product_cur_over_upper_threshold_ctrl==1)nStatus|=BIT_00;
  1755. if(_global_over_manager->product_pwr_over_upper_threshold_ctrl==1)nStatus|=BIT_03;
  1756. if(_global_over_manager->product_pwrcon_over_upper_threshold_ctrl==1)nStatus|=BIT_04;
  1757. return g_modbus_write_reg(manger,saddr,offset,nStatus);
  1758. }
  1759. /**
  1760. * @brief 设置 AC 告警丢失相位
  1761. *
  1762. * 通过给定的管理器对象,设置 AC 告警丢失相位的状态。
  1763. *
  1764. * @param manger 管理器对象指针
  1765. * @param saddr 地址
  1766. * @param MissStatus 丢失相位状态指针
  1767. *
  1768. * @return 返回操作结果,成功返回 0,失败返回非零值
  1769. */
  1770. int g_switch_set_t_ac_alarm_missing_ph(void* manger,int saddr,int* MissStatus)
  1771. {
  1772. unsigned int offset = 0;
  1773. unsigned int value = 0;
  1774. unsigned short data_temp[6] = {0};
  1775. unsigned int status_temp = 0;
  1776. int ret = 0;
  1777. offset = _SWITCH_T_AC_ALARM_MISSING_PH;
  1778. // 读取4个寄存器
  1779. // 读取寄存器
  1780. memset(data_temp, 0, sizeof(data_temp));
  1781. //一次读4个
  1782. ret = g_modbus_read_x_reg(manger, saddr, offset, 6, data_temp);
  1783. if (ret < 0)
  1784. {
  1785. log_w("g_switch_get_t_dcpdu_info:addrs:%d OffSet:%d Ret=%d:%s", saddr, offset, ret, modbus_strerror(errno));
  1786. // log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  1787. return ret;
  1788. }
  1789. for(int i = 0; i < 3; i++)
  1790. {
  1791. value = 0;
  1792. if(data_temp[i * 2]>0)
  1793. {
  1794. value=1;
  1795. }
  1796. MissStatus[i] = value;
  1797. }
  1798. return 0;
  1799. }
  1800. int g_switch_set_t_ac_start_time_delay(void* manger,int saddr,int ch, unsigned int time)
  1801. {
  1802. unsigned int offset = 0;
  1803. unsigned short data_temp[4];
  1804. offset = _SWITCH_T_AC_START_DELAY_TIME + ch ;
  1805. data_temp[0] = time & 0xFFFF;
  1806. data_temp[1] = (time >> 16) & 0XFFFF;
  1807. int reg = g_modbus_write_x_reg(manger,saddr,offset,2,data_temp);
  1808. if (reg>=0)
  1809. {
  1810. log_d("StartDelayTime_Addr:%d ch:%d OffSet:%d Time:%d Ret=%d",saddr,ch,offset,time,reg);
  1811. }
  1812. else
  1813. {
  1814. log_w("StartDelayTime_Addr:%d ch:%d OffSet:%d Time:%d Ret=%d:%s",saddr,ch,offset,time,reg,modbus_strerror(errno));
  1815. }
  1816. return reg;
  1817. }
  1818. int g_switch_set_t_ac_stop_time_delay(void* manger,int saddr,int ch, unsigned int time)
  1819. {
  1820. unsigned int offset = 0;
  1821. unsigned short data_temp[4];
  1822. offset = _SWITCH_T_AC_STOP_DELAY_TIME + ch;
  1823. data_temp[0] = time & 0XFFFF;
  1824. data_temp[1] = (time >> 16) & 0xFFFF;
  1825. int reg = g_modbus_write_x_reg(manger,saddr,offset,2, data_temp);
  1826. if (reg>=0)
  1827. {
  1828. log_d("StopDelayTime_Addr:%d ch:%d OffSet:%d Time:%d Ret=%d",saddr,ch,offset,time,reg);
  1829. }
  1830. else
  1831. {
  1832. log_w("StopDelayTime_Addr:%d ch:%d OffSet:%d Time:%d Ret=%d:%s",saddr,ch,offset,time,reg,modbus_strerror(errno));
  1833. }
  1834. return reg;
  1835. }
  1836. int g_switch_set_t_ac_chn_ctrl(void* manger,int saddr,unsigned char chn,unsigned short sts)
  1837. {
  1838. unsigned int offset = 0;
  1839. if(chn > 3 || chn < 0) return -1;
  1840. unsigned short data_temp[2];
  1841. memset(data_temp,0,sizeof(data_temp));
  1842. if(chn>=3)
  1843. return -1;
  1844. offset = _SWITCH_T_AC_CH_OUT_ENABLE+chn;
  1845. data_temp[0]=sts;
  1846. return g_modbus_write_x_reg(manger,saddr,offset, 2, data_temp);
  1847. }
  1848. int g_switch_set_t_ac_chn_NF_ctrl(void* manger,int saddr,unsigned char chn,unsigned short sts)
  1849. {
  1850. unsigned int offset = 0;
  1851. if(chn > 3 || chn < 0) return -1;
  1852. unsigned short data_temp[2];
  1853. memset(data_temp,0,sizeof(data_temp));
  1854. if(chn>=3)
  1855. return -1;
  1856. offset = _SWITCH_T_AC_NF_STATUS;
  1857. data_temp[0]=sts;
  1858. data_temp[1]=0;
  1859. return g_modbus_write_x_reg(manger,saddr,offset, 2, data_temp);
  1860. }
  1861. int g_switch_set_t_ac_phchn_ctrl(void* manger,int saddr,unsigned char chn,unsigned short sts)
  1862. {
  1863. //三个一组进行设置
  1864. unsigned int offset = 0;
  1865. if(chn > 9 || chn < 0) return -1;
  1866. unsigned short data_temp[2];
  1867. memset(data_temp,0,sizeof(data_temp));
  1868. if(chn>=9)
  1869. return -1;
  1870. offset = _SWITCH_T_AC_OUT_ENABLE+chn;
  1871. data_temp[0]=sts;
  1872. return g_modbus_write_x_reg(manger,saddr,offset, 2, data_temp);
  1873. }
  1874. int g_switch_set_t_ac_ctrl(void* manger,int saddr,unsigned short* sts)
  1875. {
  1876. unsigned int offset = 0;
  1877. unsigned short data_temp[2];
  1878. if (sts[0] == 1)
  1879. {
  1880. offset = _SWITCH_T_AC_ALL_OPEN_INFO;
  1881. data_temp[0] = 0xFFFF;
  1882. data_temp[1] = 0xFFFF;
  1883. }
  1884. else
  1885. {
  1886. offset = _SWITCH_T_AC_ALL_CLOSE_INFO;
  1887. data_temp[0] = 0;
  1888. data_temp[1] = 0;
  1889. }
  1890. return g_modbus_write_x_reg(manger,saddr,offset, 2, data_temp);
  1891. }
  1892. //重置通道状态
  1893. int g_switch_set_t_ac_phchn_reset(void *manger, int saddr, int nChn)
  1894. {
  1895. if (saddr <= 0 || saddr >= MAX_CHN_COUNT)
  1896. {
  1897. return -1;
  1898. }
  1899. unsigned int offset = 0;
  1900. unsigned short data_temp[2];
  1901. int ret = 0;
  1902. // 重置耗电量
  1903. offset = _SWITCH_T_AC_RESET_CONSUMPTION_PH+nChn;
  1904. data_temp[0] = 1;
  1905. data_temp[1] = 1;
  1906. ret = g_modbus_write_x_reg(manger, saddr, offset, 2, data_temp);
  1907. if (ret < 0)
  1908. {
  1909. return ret;
  1910. }
  1911. return 0;
  1912. }
  1913. //重设板子信息
  1914. int g_switch_set_t_ac_reset(void* manger,int saddr)
  1915. {
  1916. if (saddr <= 0 || saddr >= MAX_CHN_COUNT)
  1917. {
  1918. return -1;
  1919. }
  1920. unsigned int offset = 0;
  1921. unsigned short data_temp[10];
  1922. int ret=0;
  1923. //重置耗电量
  1924. offset = _SWITCH_T_AC_RESET_CONSUMPTION;
  1925. data_temp[0] = data_temp[1] = data_temp[2] = 1;
  1926. ret= g_modbus_write_x_reg(manger,saddr,offset,3,data_temp);
  1927. if (ret<0)
  1928. {
  1929. return ret;
  1930. }
  1931. //初始化报警阈值
  1932. unsigned short data_temp1[18];
  1933. memset(data_temp1,0,sizeof(data_temp1));
  1934. unsigned int value = 0;
  1935. offset = _SWITCH_T_AC_MAX_VOL_THRESHOLD;
  1936. ret = g_modbus_write_x_reg(manger,saddr,offset,18,data_temp1);
  1937. if (ret<0)
  1938. {
  1939. return ret;
  1940. }
  1941. offset = _SWITCH_T_AC_MIN_VOL_THRESHOLD;
  1942. ret = g_modbus_write_x_reg(manger,saddr,offset,18,data_temp1);
  1943. if (ret<0)
  1944. {
  1945. return ret;
  1946. }
  1947. offset = _SWITCH_T_AC_MAX_CUR_THRESHOLD;
  1948. ret = g_modbus_write_x_reg(manger,saddr,offset,18,data_temp1);
  1949. if (ret<0)
  1950. {
  1951. return ret;
  1952. }
  1953. offset = _SWITCH_T_AC_MAX_PWR_THRESHOLD;
  1954. ret = g_modbus_write_x_reg(manger,saddr,offset,18,data_temp1);
  1955. if (ret<0)
  1956. {
  1957. return ret;
  1958. }
  1959. offset = _SWITCH_T_AC_MAX_PWRCON_THRESHOLD;
  1960. ret = g_modbus_write_x_reg(manger,saddr,offset,18,data_temp1);
  1961. if (ret<0)
  1962. {
  1963. return ret;
  1964. }
  1965. if (__globalDeviceManage._all_ctrl_board[saddr].product_saddr<=0)
  1966. {
  1967. return -1;
  1968. }
  1969. PowerInfo* pPowerInfo= __globalDeviceManage._all_ctrl_board[saddr]._PowerInfo;
  1970. if (pPowerInfo!=NULL)
  1971. {
  1972. for (size_t i = 0; i < __globalDeviceManage._all_ctrl_board[saddr].product_number; i++)
  1973. {
  1974. memset(data_temp1, 0, sizeof(data_temp1));
  1975. offset = _SWITCH_T_AC_OUT_ENABLE + i;
  1976. data_temp1[0] = pPowerInfo[i].status;
  1977. ret = g_modbus_write_x_reg(manger, saddr, offset, 2, data_temp1);
  1978. if (ret < 0)
  1979. {
  1980. return ret;
  1981. }
  1982. }
  1983. }
  1984. if (ret<0)
  1985. {
  1986. return ret;
  1987. }
  1988. return 0;
  1989. }
  1990. //输入状态及报警
  1991. int g_switch_get_t_ac_in_info(void* manger,int saddr,PowerInfo* _power,PowerWarningInfo *_warning)
  1992. {
  1993. unsigned int offset = 0;
  1994. unsigned int value = 0 ;
  1995. unsigned short data_temp[24] = {0};
  1996. int ret=0;
  1997. offset = _SWITCH_T_AC_IN_INFO;
  1998. //读取4个寄存器
  1999. //读取寄存器
  2000. memset(data_temp,0,sizeof(data_temp));
  2001. ret = g_modbus_read_x_reg(manger,saddr,offset,24,data_temp);
  2002. if (ret<0)
  2003. {
  2004. log_w("g_switch_get_t_ac_in_info:%d OffSet:%d Ret=%d:%s",saddr,offset,ret,modbus_strerror(errno));
  2005. //log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  2006. return ret;
  2007. }
  2008. //解电压数据
  2009. for (size_t i = 0; i < 3; i++)
  2010. {
  2011. int Index=i*2;
  2012. value = (data_temp[1+Index] << 16) + data_temp[0+Index];
  2013. _power[i].voltage = value / 1000.0;
  2014. //解电流数据
  2015. value = (data_temp[7+Index] << 16) + data_temp[6+Index];
  2016. _power[i].current = value / 1000.0;
  2017. //解功率数据
  2018. value = (data_temp[13+Index] << 16) + data_temp[12+Index];
  2019. _power[i].power = value / 1000.0;
  2020. value = (data_temp[19+Index] << 16) + data_temp[18+Index];
  2021. _power[i].consumption = value / 1000.0;
  2022. }
  2023. offset = _SWITCH_T_AC_IN_ERROR;
  2024. //读取寄存器
  2025. memset(data_temp,0,sizeof(data_temp));
  2026. ret = g_modbus_read_x_reg(manger,saddr,offset, 2,data_temp);
  2027. //解报警数据
  2028. if (ret<0)
  2029. {
  2030. return ret;
  2031. }
  2032. for (size_t i = 0; i < 3; i++)
  2033. {
  2034. _warning[i].w_voltage_up = data_temp[0] & (BIT_00<<i);
  2035. _warning[i].w_voltage_down = data_temp[0] & (BIT_03<<i);
  2036. _warning[i].w_current = data_temp[0] & (BIT_06<<i);
  2037. _warning[i].w_power = data_temp[1] & (BIT_00<<i);
  2038. _warning[i].w_consumption = data_temp[1] & (BIT_03<<i);
  2039. //_warning[i].w_phase_loss = data_temp[1] & (BIT_06<<i);
  2040. }
  2041. return 0;
  2042. }
  2043. //阈值获取
  2044. int g_switch_get_t_ac_in_threshold(void* manger,int saddr,GlobalOverManager* _global_over_manager)
  2045. {
  2046. unsigned int offset = 0;
  2047. unsigned short data_temp[10] = {0};
  2048. memset(data_temp, 0, sizeof(data_temp));;
  2049. offset = _SWITCH_T_AC_SINGLE_IN_Threshold;
  2050. int ret= g_modbus_read_x_reg(manger,saddr,offset,10,data_temp);
  2051. unsigned int value = 0;
  2052. float fvalue=0.0;
  2053. //电压上限
  2054. value = (data_temp[1] << 16) + data_temp[0];
  2055. fvalue=(float)value;
  2056. _global_over_manager->product_vol_upper_threshold = fvalue / 1000.0;
  2057. //电压下限
  2058. value = (data_temp[3] << 16) + data_temp[2];
  2059. fvalue=(float)value;
  2060. _global_over_manager->product_vol_lower_threshold = fvalue / 1000.0;
  2061. //电流上限
  2062. value = (data_temp[5] << 16) + data_temp[4];
  2063. fvalue=(float)value;
  2064. _global_over_manager->product_cur_upper_threshold = fvalue / 1000.0;
  2065. //功率上限
  2066. value = (data_temp[7] << 16) + data_temp[6];
  2067. fvalue=(float)value;
  2068. _global_over_manager->product_pwr_upper_threshold = fvalue / 1000.0;
  2069. //电能上限
  2070. value = (data_temp[9] << 16) + data_temp[8];
  2071. fvalue=(float)value;
  2072. _global_over_manager->product_pwrcon_upper_threshold = fvalue / 1000.0;
  2073. //log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  2074. return ret;
  2075. }
  2076. //阈值设置
  2077. int g_switch_set_t_ac_in_threshold(void* manger,int saddr,GlobalOverManager* _global_over_manager)
  2078. {
  2079. unsigned int offset = 0;
  2080. unsigned int data_temp = 0 ;
  2081. unsigned short data_buf[10] = {0};
  2082. int ret= 0;
  2083. memset(data_buf, 0, sizeof(data_buf));;
  2084. offset = _SWITCH_T_AC_SINGLE_IN_Threshold;
  2085. //电压上限
  2086. data_temp = (_global_over_manager->product_vol_upper_threshold*1000);
  2087. data_buf[0] = data_temp;
  2088. data_buf[1] = data_temp>>16;
  2089. ret=g_modbus_write_x_reg(manger,saddr,offset,2,data_buf);
  2090. //电压下限
  2091. data_temp = (_global_over_manager->product_vol_lower_threshold*1000);
  2092. data_buf[0] = data_temp;
  2093. data_buf[1] = data_temp>>16;
  2094. ret=g_modbus_write_x_reg(manger,saddr,offset+1,2,data_buf);
  2095. //电流上限
  2096. data_temp = (_global_over_manager->product_cur_upper_threshold*1000);
  2097. data_buf[0] = data_temp;
  2098. data_buf[1] = data_temp>>16;
  2099. ret=g_modbus_write_x_reg(manger,saddr,offset+2,2,data_buf);
  2100. //功率上限
  2101. data_temp = (_global_over_manager->product_pwr_upper_threshold*1000);
  2102. data_buf[0] = data_temp;
  2103. data_buf[1] = data_temp>>16;
  2104. ret=g_modbus_write_x_reg(manger,saddr,offset+3,2,data_buf);
  2105. //电能上限
  2106. data_temp = (_global_over_manager->product_pwrcon_upper_threshold*1000);
  2107. data_buf[0] = data_temp;
  2108. data_buf[1] = data_temp>>16;
  2109. ret=g_modbus_write_x_reg(manger,saddr,offset+4,2,data_buf);
  2110. //int ret= g_modbus_write_x_reg(manger,saddr,offset,10,data_buf);
  2111. if (ret<0)
  2112. {
  2113. log_d("threshold_Addr:%d OffSet:%d Ret=%d",saddr,offset,ret);
  2114. return ret;
  2115. }
  2116. memset(data_buf, 0, sizeof(data_buf));;
  2117. if(_global_over_manager->product_vol_upper_enable==1)data_buf[0]|=ENABLE_TAC_V_UP;
  2118. if(_global_over_manager->product_vol_lower_enable==1)data_buf[0]|=ENABLE_TAC_V_DOWN;
  2119. if(_global_over_manager->product_cur_upper_enable==1)data_buf[0]|=ENABLE_TAC_A_UP;
  2120. if(_global_over_manager->product_pwr_upper_enable==1)data_buf[0]|=ENABLE_TAC_W_UP;
  2121. if(_global_over_manager->product_pwrcon_upper_enable==1)data_buf[0]|=ENABLE_TAC_P_UP;
  2122. offset = _SWITCH_T_AC_IN_ENABLE;
  2123. ret= g_modbus_write_x_reg(manger,saddr,offset,2,data_buf);
  2124. return ret;
  2125. }
  2126. /**
  2127. * @brief 获取 GPIO 状态
  2128. *
  2129. * 根据给定的 GPIO 编号,获取 GPIO 的状态(高电平或低电平)。
  2130. *
  2131. * @param ngpio GPIO 编号
  2132. * @param status 用于存储 GPIO 状态的指针
  2133. *
  2134. * @return 成功返回 0,失败返回非 0 错误码
  2135. */
  2136. int g_switch_get_gpio_status(int ngpio,int* nStatus)
  2137. {
  2138. char value_path[64];
  2139. char buf[3]; // 用于存储读取到的GPIO值,通常为'0'或'1'
  2140. ssize_t bytesRead;
  2141. int fd;
  2142. // 构造GPIO值的路径
  2143. snprintf(value_path, sizeof(value_path), GPIO_VALUE_PATH, ngpio);
  2144. // 打开GPIO值文件以读取
  2145. fd = open(value_path, O_RDONLY);
  2146. if (fd == -1) {
  2147. perror("Failed to open GPIO value for reading");
  2148. return -1;
  2149. }
  2150. // 读取GPIO的值
  2151. bytesRead = read(fd, buf, sizeof(buf) - 1);
  2152. if (bytesRead == -1) {
  2153. perror("Failed to read from GPIO value");
  2154. close(fd);
  2155. return -2;
  2156. }
  2157. if (nStatus==NULL)
  2158. {
  2159. perror("Failed to IO_nStatus NULL");
  2160. close(fd);
  2161. return -3;
  2162. }
  2163. // 确保字符串以null终止
  2164. buf[bytesRead] = '\0';
  2165. // 打印读取到的GPIO值
  2166. // printf("GPIO %d value: %s\n", GPIO_PE3, buf);
  2167. if (buf[0]=='0')
  2168. {
  2169. *nStatus=1;
  2170. }else{
  2171. *nStatus=0;
  2172. }
  2173. // 关闭文件描述符
  2174. close(fd);
  2175. return 0;
  2176. }
  2177. /**
  2178. * @brief 清除全局电源管理器
  2179. *
  2180. * 清除指定的全局电源管理器对象,并释放相关资源。
  2181. *
  2182. * @param _globalDeviceManager 全局电源管理器对象指针
  2183. *
  2184. * @return 返回值表示操作是否成功,成功返回0,失败返回非0值
  2185. */
  2186. int power_clear(GlobalPowerManger *globalPowerManager)
  2187. {
  2188. GlobalPowerManger* _globalPowerMangerTemp,* pos;
  2189. GlobalTreeACManager *_pTreeACPowerPhData,*pos1;
  2190. _PowerDSManage_t* _powerDsManageTemp,*pos2;
  2191. if (globalPowerManager == NULL)
  2192. {
  2193. return -1;
  2194. }
  2195. list_for_each_entry_safe(_globalPowerMangerTemp, pos, &globalPowerManager->list, list)
  2196. {
  2197. if (_globalPowerMangerTemp == NULL)
  2198. {
  2199. continue;
  2200. }
  2201. #if 0
  2202. list_for_each_entry_safe(_powerDsManageTemp, pos2,&_globalPowerMangerTemp->list_DS, list)
  2203. {
  2204. list_del(&_powerDsManageTemp->list);
  2205. free(_powerDsManageTemp);
  2206. }
  2207. list_for_each_entry_safe(_pTreeACPowerPhData, pos1,&_globalPowerMangerTemp->list_Tree_AC, list_Tree_AC)
  2208. {
  2209. list_del(&_pTreeACPowerPhData->list_Tree_AC);
  2210. if(_pTreeACPowerPhData->global_over_manager) {
  2211. free(_pTreeACPowerPhData->global_over_manager);
  2212. }
  2213. free(_pTreeACPowerPhData);
  2214. }
  2215. #endif
  2216. list_del(&_globalPowerMangerTemp->list);
  2217. if (_globalPowerMangerTemp->global_over_manager)
  2218. {
  2219. free(_globalPowerMangerTemp->global_over_manager);
  2220. }
  2221. if (_globalPowerMangerTemp->_PowerSXManage)
  2222. {
  2223. free(_globalPowerMangerTemp->_PowerSXManage);
  2224. }
  2225. free(_globalPowerMangerTemp);
  2226. }
  2227. return 0;
  2228. }
  2229. /**
  2230. * @brief 重新加载电源管理对象
  2231. *
  2232. * 清除指定的全局电源管理器对象,并重新加载相关资源。
  2233. *
  2234. * @param nCtrlType 0:全新设备,1:刷新设备
  2235. *
  2236. * @return 返回值表示操作是否成功,成功返回0,失败返回非0值
  2237. */
  2238. int ResetChmData(int nCtrlType)
  2239. {
  2240. // 搜索子地址
  2241. int ret = 0;
  2242. int chn = 1;
  2243. int type = 0;
  2244. int nGroups=8;
  2245. GlobalDeviceManager* _globalDeviceManager=&__globalDeviceManage;
  2246. __globalDeviceManage.useSlaveCount = 0;
  2247. power_clear(&_globalDeviceManager->_globalPowerManger);
  2248. _globalDeviceManager->_all_ctrl_board[0].product_saddr = 0;
  2249. _globalDeviceManager->_all_ctrl_board[0].product_number = 1;
  2250. _globalDeviceManager->_all_ctrl_board[0].product_type = 9;
  2251. GlobalPowerManger *_globalPowerMangerTemp = (GlobalPowerManger *)malloc(sizeof(GlobalPowerManger));
  2252. if (_globalPowerMangerTemp == NULL)
  2253. {
  2254. log_e("_globalPowerManger malloc error.\n");
  2255. return -1;
  2256. }
  2257. memset(_globalPowerMangerTemp, 0, sizeof(GlobalPowerManger));
  2258. _globalPowerMangerTemp->global_over_manager = (GlobalOverManager *)malloc(sizeof(GlobalOverManager));
  2259. if (_globalPowerMangerTemp->global_over_manager == NULL)
  2260. {
  2261. log_e("_globalPowerManger->global_over_manager malloc error.\n");
  2262. return -1;
  2263. }
  2264. memset(_globalPowerMangerTemp->global_over_manager, 0, sizeof(GlobalOverManager));
  2265. ret = dev_get_power_manage_info(_globalDeviceManager->db,
  2266. _globalDeviceManager->_globalDevInfo.product_id,
  2267. 0,
  2268. 1,
  2269. _globalPowerMangerTemp);
  2270. if(ret == -1)
  2271. {
  2272. _globalPowerMangerTemp->product_id = _globalDeviceManager->_globalDevInfo.product_id;
  2273. _globalPowerMangerTemp->product_saddr = 0;
  2274. _globalPowerMangerTemp->product_ch_id = chn;
  2275. _globalPowerMangerTemp->product_ch_addr = 1;
  2276. sprintf(_globalPowerMangerTemp->product_ch_name, "CH%d", _globalPowerMangerTemp->product_ch_id);
  2277. _globalPowerMangerTemp->product_ch_type = type;
  2278. _globalPowerMangerTemp->product_ch_status = 0;
  2279. _globalPowerMangerTemp->product_ch_NF_status = 0;
  2280. _globalPowerMangerTemp->product_ch_start_delay = 1000 * (chn % nGroups != 0 ? chn % nGroups : nGroups);
  2281. _globalPowerMangerTemp->product_ch_stop_delay = 1000 * (chn % nGroups != 0 ? chn % nGroups : nGroups);
  2282. if(dev_insert_power_manage_info(_globalDeviceManager->db,
  2283. _globalDeviceManager->_globalDevInfo.product_id,
  2284. _globalPowerMangerTemp->product_ch_id,
  2285. _globalPowerMangerTemp) != 0)
  2286. {
  2287. log_e("address %d chn %d data inserted error.\n", 0, chn);
  2288. return 0;
  2289. }
  2290. }
  2291. list_add_tail(&_globalPowerMangerTemp->list, &_globalDeviceManager->_globalPowerManger.list);
  2292. char strLog[200]={"MODBUS"};
  2293. sprintf(strLog,"%s$|$通道",language_alarm_Init_Success[0]);
  2294. char number[10];
  2295. sprintf(number,"%d",chn-1);
  2296. dev_Alarm_Run_message(_globalDeviceManager,strLog,number);
  2297. //dev_get_power_ds(_globalDeviceManager->db,&_globalDeviceManager->_globalPowerManger,NULL);
  2298. return ret;
  2299. }