bparamhandler.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677
  1. // 模块控制接口-基站参数
  2. // 秒寻科技
  3. // zt 2024-02-16
  4. package bparamhandler
  5. import (
  6. "fmt"
  7. "ipsomc/core/dao/mysql/mysqlmodel"
  8. "ipsomc/core/gin/bind"
  9. "ipsomc/core/gin/resp"
  10. "ipsomc/module/bparam/bparamapi"
  11. "ipsomc/module/bparam/bparamlogic"
  12. "ipsomc/module/bparam/bparammodel"
  13. "ipsomc/module/bparam/bparamoam"
  14. "ipsomc/public"
  15. "time"
  16. "github.com/gin-gonic/gin"
  17. )
  18. type BparamHan struct {
  19. bindApi bind.BindApi
  20. bparamApi bparamapi.BparamApi
  21. bparamLgc bparamlogic.BparamLgc
  22. bparamOamApi bparamoam.BparamOam
  23. }
  24. // 新增基站基本参数
  25. func (obj *BparamHan) AddBtsBaseParamHan(c *gin.Context) {
  26. dataModel := new(bparammodel.BtsBaseParam)
  27. //把前端数据绑定到模型上
  28. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  29. resp.RespFail(c, "数据错误")
  30. return
  31. }
  32. //保存数据
  33. if err := obj.bparamApi.AddBtsBaseParam(dataModel); err != nil {
  34. resp.RespFail(c, err.Error())
  35. return
  36. }
  37. //返回数据
  38. resp.RespId(c, dataModel.ID)
  39. }
  40. // 修改
  41. func (obj *BparamHan) UpdateBtsBaseParamHan(c *gin.Context) {
  42. dataModel := new(bparammodel.BtsBaseParam)
  43. dataMap := make(map[string]interface{})
  44. //把前端数据绑定到模型
  45. if err := obj.bindApi.Bind2Map(c, dataModel, dataMap); err != nil {
  46. resp.RespFail(c, err.Error())
  47. return
  48. }
  49. //保存数据
  50. if err := obj.bparamApi.UpdateBtsBaseParam(dataModel, dataMap); err != nil {
  51. resp.RespFail(c, err.Error())
  52. return
  53. }
  54. //返回数据
  55. resp.RespOk(c)
  56. }
  57. // 删除
  58. func (obj *BparamHan) DeleteBtsBaseParamHan(c *gin.Context) {
  59. dataModel := new(bparammodel.BtsBaseParam)
  60. //把前端数据绑定到模型
  61. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  62. resp.RespFail(c, "数据解析错误")
  63. return
  64. }
  65. if err := obj.bparamApi.DeleteBtsBaseParam(dataModel); err != nil {
  66. resp.RespFail(c, err.Error())
  67. return
  68. }
  69. //返回数据
  70. resp.RespOk(c)
  71. }
  72. // 查询单条记录
  73. func (obj *BparamHan) GetBtsBaseParamByIdHan(c *gin.Context) {
  74. dataModel := new(bparammodel.BtsBaseParam)
  75. //把前端数据绑定到模型
  76. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  77. resp.RespFail(c, "数据解析错误")
  78. return
  79. }
  80. if err := obj.bparamApi.GetBtsBaseParamById(dataModel); err != nil {
  81. resp.RespFail(c, err.Error())
  82. return
  83. }
  84. //返回数据
  85. resp.RespData(c, dataModel)
  86. }
  87. // 查询满足条件的所有记录
  88. func (obj *BparamHan) GetBtsBaseParamListHan(c *gin.Context) {
  89. dataModel := new(bparammodel.BtsBaseParam)
  90. listParam := new(mysqlmodel.ListParam)
  91. dataList := []bparammodel.BtsBaseParam{}
  92. //把前端数据绑定到模型
  93. if err := obj.bindApi.Bind2Query(c, listParam); err != nil {
  94. resp.RespFail(c, "数据解析错误")
  95. return
  96. }
  97. //查询满足条件的记录
  98. err := obj.bparamApi.GetBtsBaseParamList(dataModel, listParam, &dataList)
  99. if err != nil {
  100. resp.RespFail(c, err.Error())
  101. return
  102. }
  103. //更新基站在线状态
  104. existFlag := false
  105. if len(public.Gpub_mapHeart) > 0 {
  106. //更新基站状态
  107. for i, btsParam := range dataList {
  108. existFlag = false
  109. //修改基站状态
  110. for _, v := range public.Gpub_mapHeart {
  111. if btsParam.ProjectID == v.ProjectID && btsParam.BtsID == v.BtsID {
  112. dataList[i].Status = 2 //在线
  113. existFlag = true
  114. break
  115. }
  116. }
  117. if !existFlag && btsParam.Status == 2 {
  118. dataList[i].Status = 1 //离线
  119. }
  120. }
  121. }
  122. //返回记录
  123. resp.RespList(c, dataList)
  124. }
  125. // 分页查询
  126. func (obj *BparamHan) GetBtsBaseParamPageListHan(c *gin.Context) {
  127. dataModel := new(bparammodel.BtsBaseParam)
  128. pageListParam := new(mysqlmodel.PageListParam)
  129. dataList := []bparammodel.BtsBaseParam{}
  130. //把前端数据绑定到模型
  131. if err := obj.bindApi.Bind2PageQuery(c, pageListParam); err != nil {
  132. resp.RespFail(c, "数据解析错误")
  133. return
  134. }
  135. pageListData, err := obj.bparamApi.GetBtsBaseParamPageList(dataModel, pageListParam, &dataList)
  136. if err != nil {
  137. resp.RespFail(c, err.Error())
  138. return
  139. }
  140. //更新基站在线状态
  141. existFlag := false
  142. if len(public.Gpub_mapHeart) > 0 {
  143. //更新基站状态
  144. for i, btsParam := range dataList {
  145. existFlag = false
  146. //修改基站状态
  147. for _, v := range public.Gpub_mapHeart {
  148. if btsParam.ProjectID == v.ProjectID && btsParam.BtsID == v.BtsID {
  149. dataList[i].Status = 2 //在线
  150. existFlag = true
  151. break
  152. }
  153. }
  154. if !existFlag && btsParam.Status == 2 {
  155. dataList[i].Status = 1 //离线
  156. }
  157. }
  158. }
  159. resp.RespList(c, pageListData)
  160. }
  161. // 移动端查询基站参数
  162. func (obj *BparamHan) GetMobileBtsParamListHan(c *gin.Context) {
  163. dataModel := new(bparammodel.BtsBaseParam)
  164. //把前端数据绑定到模型
  165. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  166. resp.RespFail(c, "数据解析错误")
  167. return
  168. }
  169. //查询满足条件的
  170. dataList, err := obj.bparamApi.GetMobileBtsParamList(dataModel)
  171. if err != nil {
  172. resp.RespFail(c, "查询数据错误")
  173. return
  174. }
  175. println(dataList)
  176. //返回记录
  177. resp.RespList(c, dataList)
  178. }
  179. // 本地网管新增基站基本参数
  180. func (obj *BparamHan) GuiUploadBtsBaseParamAddHan(c *gin.Context) {
  181. dataModel := new(bparammodel.BtsBaseParam)
  182. //把前端数据绑定到模型上
  183. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  184. resp.RespFail(c, "数据错误")
  185. return
  186. }
  187. //保存数据
  188. if err := obj.bparamApi.AddBtsBaseParam(dataModel); err != nil {
  189. resp.RespFail(c, err.Error())
  190. return
  191. }
  192. //返回数据
  193. resp.RespId(c, dataModel.ID)
  194. }
  195. // 本地网管修改基站基本参数
  196. func (obj *BparamHan) GuiUploadBtsBaseParamUpdateHan(c *gin.Context) {
  197. dataModel := new(bparammodel.BtsBaseParam)
  198. dataMap := make(map[string]interface{})
  199. //把前端数据绑定到模型
  200. if err := obj.bindApi.Bind2Map(c, dataModel, dataMap); err != nil {
  201. resp.RespFail(c, err.Error())
  202. return
  203. }
  204. //保存数据
  205. if err := obj.bparamLgc.UploadBparamLgc(dataModel, dataMap); err != nil {
  206. resp.RespFail(c, err.Error())
  207. return
  208. }
  209. //返回数据
  210. resp.RespOk(c)
  211. }
  212. //***********************************以上是http命令**********************************************
  213. //**********************************************************************************************
  214. //***********************************下面是socket命令********************************************
  215. // 保存http请求通道
  216. func (obj *BparamHan) SaveRequestChan(httpReqChan chan interface{}, ProjectID int, BtsID int, mcpCmdType uint8, moduleId uint8) {
  217. requestIdStr := fmt.Sprintf("%08X", ProjectID) + "-" + fmt.Sprintf("%08X", BtsID) + "-" + fmt.Sprintf("%d", mcpCmdType) + "-" + fmt.Sprintf("%d", moduleId)
  218. public.Gpub_mutex.Lock()
  219. public.Gpub_mapChan[requestIdStr] = httpReqChan //保存通道
  220. public.Gpub_mutex.Unlock()
  221. }
  222. // 返回数据并删除http请求通道
  223. func (obj *BparamHan) RespDataWithChan(c *gin.Context, httpReqChan chan interface{}, ProjectID int, BtsID int, mcpCmdType uint8, moduleId uint8) {
  224. requestIdStr := fmt.Sprintf("%08X", ProjectID) + "-" + fmt.Sprintf("%08X", BtsID) + "-" + fmt.Sprintf("%d", mcpCmdType) + "-" + fmt.Sprintf("%d", moduleId)
  225. //把数据返回给客户端
  226. select {
  227. case v := <-httpReqChan:
  228. resp.RespData(c, v) //数据返回前端
  229. case <-time.After(10 * time.Second): // 10秒超时
  230. resp.RespFail(c, "查询超时")
  231. }
  232. close(httpReqChan) //关闭通道
  233. public.Gpub_mutex.Lock()
  234. delete(public.Gpub_mapChan, requestIdStr)
  235. public.Gpub_mutex.Unlock()
  236. }
  237. // 查询基站设备参数
  238. func (obj *BparamHan) GetBtsOamParamDeviceHan(c *gin.Context) {
  239. dataModel := new(bparammodel.BtsBaseParam)
  240. //把前端数据绑定到模型上
  241. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  242. resp.RespFail(c, "数据错误")
  243. return
  244. }
  245. //生成并保存http请求通道
  246. httpReqChan := make(chan interface{})
  247. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_DEVICE)
  248. //查询基站参数
  249. if err := obj.bparamOamApi.OamQueryDeviceParam(dataModel); err != nil {
  250. resp.RespFail(c, "查询数据错误")
  251. }
  252. //返回数据并删除http请求通道
  253. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_DEVICE)
  254. }
  255. // 查询基站网管参数
  256. func (obj *BparamHan) GetBtsOamParamNetworkHan(c *gin.Context) {
  257. dataModel := new(bparammodel.BtsBaseParam)
  258. //把前端数据绑定到模型上
  259. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  260. resp.RespFail(c, "数据错误")
  261. return
  262. }
  263. //生成并保存http请求通道
  264. httpReqChan := make(chan interface{})
  265. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_NETWORK)
  266. //查询基站参数
  267. if err := obj.bparamOamApi.OamQueryNetworkParam(dataModel); err != nil {
  268. resp.RespFail(c, "查询数据错误")
  269. }
  270. //返回数据并删除http请求通道
  271. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_NETWORK)
  272. }
  273. // 设置基站网管参数
  274. func (obj *BparamHan) SetBtsOamParamNetworkHan(c *gin.Context) {
  275. dataModel := new(bparammodel.BtsBaseParam)
  276. //把前端数据绑定到模型上
  277. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  278. resp.RespFail(c, "数据错误")
  279. return
  280. }
  281. //生成并保存http请求通道
  282. httpReqChan := make(chan interface{})
  283. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_NETWORK)
  284. //设置基站参数
  285. if err := obj.bparamOamApi.OamSetNetworkParam(dataModel); err != nil {
  286. resp.RespFail(c, "设置数据错误")
  287. }
  288. //返回数据并删除http请求通道
  289. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_NETWORK)
  290. }
  291. // 查询基站同步参数
  292. func (obj *BparamHan) GetBtsOamParamSyncHan(c *gin.Context) {
  293. dataModel := new(bparammodel.BtsBaseParam)
  294. //把前端数据绑定到模型上
  295. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  296. resp.RespFail(c, "数据错误")
  297. return
  298. }
  299. //生成并保存http请求通道
  300. httpReqChan := make(chan interface{})
  301. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_SYNC)
  302. //查询基站参数
  303. if err := obj.bparamOamApi.OamQuerySyncParam(dataModel); err != nil {
  304. resp.RespFail(c, "查询数据错误")
  305. }
  306. //返回数据并删除http请求通道
  307. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_SYNC)
  308. }
  309. // 设置基站同步参数
  310. func (obj *BparamHan) SetBtsOamParamSyncHan(c *gin.Context) {
  311. dataModel := new(bparammodel.BtsBaseParam)
  312. //把前端数据绑定到模型上
  313. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  314. resp.RespFail(c, "数据错误")
  315. return
  316. }
  317. //生成并保存http请求通道
  318. httpReqChan := make(chan interface{})
  319. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_SYNC)
  320. //设置基站参数
  321. if err := obj.bparamOamApi.OamSetSyncParam(dataModel); err != nil {
  322. resp.RespFail(c, "设置数据错误")
  323. }
  324. //返回数据并删除http请求通道
  325. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_SYNC)
  326. }
  327. // 查询基站增益参数
  328. func (obj *BparamHan) GetBtsOamParamGainHan(c *gin.Context) {
  329. dataModel := new(bparammodel.BtsDeviceParam)
  330. //把前端数据绑定到模型上
  331. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  332. resp.RespFail(c, "数据错误")
  333. return
  334. }
  335. //生成并保存http请求通道
  336. httpReqChan := make(chan interface{})
  337. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_GAIN)
  338. //查询基站参数
  339. if err := obj.bparamOamApi.OamQueryGainParam(dataModel); err != nil {
  340. resp.RespFail(c, "查询数据错误")
  341. }
  342. //返回数据并删除http请求通道
  343. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_GAIN)
  344. }
  345. // 设置基站增益参数
  346. func (obj *BparamHan) SetBtsOamParamGainHan(c *gin.Context) {
  347. dataModel := new(bparammodel.BtsBaseParam)
  348. //把前端数据绑定到模型上
  349. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  350. resp.RespFail(c, "数据错误")
  351. return
  352. }
  353. //生成并保存http请求通道
  354. httpReqChan := make(chan interface{})
  355. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_GAIN)
  356. //设置基站参数
  357. if err := obj.bparamOamApi.OamSetGainParam(dataModel); err != nil {
  358. resp.RespFail(c, "设置数据错误")
  359. }
  360. //返回数据并删除http请求通道
  361. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_GAIN)
  362. }
  363. // 查询安装参数
  364. func (obj *BparamHan) GetBtsOamParamInstallHan(c *gin.Context) {
  365. dataModel := new(bparammodel.BtsDeviceParam)
  366. //把前端数据绑定到模型上
  367. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  368. resp.RespFail(c, "数据错误")
  369. return
  370. }
  371. //生成并保存http请求通道
  372. httpReqChan := make(chan interface{})
  373. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_INSTALL)
  374. //查询基站参数
  375. if err := obj.bparamOamApi.OamQueryInstallParam(dataModel); err != nil {
  376. resp.RespFail(c, "查询数据错误")
  377. }
  378. //返回数据并删除http请求通道
  379. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_INSTALL)
  380. }
  381. // 配置基站参数
  382. func (obj *BparamHan) SetBtsOamParamInstallHan(c *gin.Context) {
  383. dataModel := new(bparammodel.BtsBaseParam)
  384. //把前端数据绑定到模型上
  385. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  386. resp.RespFail(c, "数据错误")
  387. return
  388. }
  389. //生成并保存http请求通道
  390. httpReqChan := make(chan interface{})
  391. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_INSTALL)
  392. //设置基站参数
  393. if err := obj.bparamOamApi.OamSetInstallParam(dataModel); err != nil {
  394. resp.RespFail(c, "设置数据错误")
  395. }
  396. //返回数据并删除http请求通道
  397. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_INSTALL)
  398. }
  399. // 查询基站参数
  400. func (obj *BparamHan) GetBtsOamParamBtsHan(c *gin.Context) {
  401. dataModel := new(bparammodel.BtsDeviceParam)
  402. //把前端数据绑定到模型上
  403. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  404. resp.RespFail(c, "数据错误")
  405. return
  406. }
  407. //生成并保存http请求通道
  408. httpReqChan := make(chan interface{})
  409. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_BTS)
  410. //查询基站参数
  411. if err := obj.bparamOamApi.OamQueryBtsParam(dataModel); err != nil {
  412. resp.RespFail(c, "查询数据错误")
  413. }
  414. //返回数据并删除http请求通道
  415. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_BTS)
  416. }
  417. // 配置基站参数
  418. func (obj *BparamHan) SetBtsOamParamBtsHan(c *gin.Context) {
  419. dataModel := new(bparammodel.BtsBaseParam)
  420. //把前端数据绑定到模型上
  421. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  422. resp.RespFail(c, "数据错误")
  423. return
  424. }
  425. //生成并保存http请求通道
  426. httpReqChan := make(chan interface{})
  427. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_BTS)
  428. //设置基站参数
  429. if err := obj.bparamOamApi.OamSetBtsParam(dataModel); err != nil {
  430. resp.RespFail(c, "设置数据错误")
  431. }
  432. //返回数据并删除http请求通道
  433. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_BTS)
  434. }
  435. // 查询定位类型参数
  436. func (obj *BparamHan) GetBtsOamParamLocationTypeHan(c *gin.Context) {
  437. dataModel := new(bparammodel.BtsDeviceParam)
  438. //把前端数据绑定到模型上
  439. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  440. resp.RespFail(c, "数据错误")
  441. return
  442. }
  443. //生成并保存http请求通道
  444. httpReqChan := make(chan interface{})
  445. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_BTS)
  446. //查询基站参数
  447. if err := obj.bparamOamApi.OamQueryLocationTypeParam(dataModel); err != nil {
  448. resp.RespFail(c, "查询数据错误")
  449. }
  450. //返回数据并删除http请求通道
  451. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_BTS)
  452. }
  453. // 配置定位类型参数
  454. func (obj *BparamHan) SetBtsOamParamLocationTypeHan(c *gin.Context) {
  455. dataModel := new(bparammodel.BtsBaseParam)
  456. //把前端数据绑定到模型上
  457. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  458. resp.RespFail(c, "数据错误")
  459. return
  460. }
  461. //生成并保存http请求通道
  462. httpReqChan := make(chan interface{})
  463. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_BTS)
  464. //设置基站参数
  465. if err := obj.bparamOamApi.OamSetLocationTypeParam(dataModel); err != nil {
  466. resp.RespFail(c, "设置数据错误")
  467. }
  468. //返回数据并删除http请求通道
  469. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_BTS)
  470. }
  471. // 查询rtc参数
  472. func (obj *BparamHan) GetBtsOamParamRtcHan(c *gin.Context) {
  473. dataModel := new(bparammodel.BtsBaseParam)
  474. //把前端数据绑定到模型上
  475. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  476. resp.RespFail(c, "数据错误")
  477. return
  478. }
  479. //生成并保存http请求通道
  480. httpReqChan := make(chan interface{})
  481. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_RTC)
  482. //查询基站参数
  483. if err := obj.bparamOamApi.OamQueryRtcParam(dataModel); err != nil {
  484. resp.RespFail(c, "查询数据错误")
  485. }
  486. //返回数据并删除http请求通道
  487. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_QUERY, public.BTS_MODULE_RTC)
  488. }
  489. // 配置rtc参数
  490. func (obj *BparamHan) SetBtsOamParamRtcHan(c *gin.Context) {
  491. dataModel := new(bparammodel.BtsBaseParam)
  492. //把前端数据绑定到模型上
  493. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  494. resp.RespFail(c, "数据错误")
  495. return
  496. }
  497. //生成并保存http请求通道
  498. httpReqChan := make(chan interface{})
  499. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_RTC)
  500. //设置基站参数
  501. if err := obj.bparamOamApi.OamSetRtcParam(dataModel); err != nil {
  502. resp.RespFail(c, "设置数据错误")
  503. }
  504. //返回数据并删除http请求通道
  505. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_RTC)
  506. }
  507. // 保存参数
  508. func (obj *BparamHan) SaveOamParamHan(c *gin.Context) {
  509. dataModel := new(bparammodel.BtsBaseParam)
  510. //把前端数据绑定到模型上
  511. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  512. resp.RespFail(c, "数据错误")
  513. return
  514. }
  515. //生成并保存http请求通道
  516. httpReqChan := make(chan interface{})
  517. obj.SaveRequestChan(httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_GAIN)
  518. //设置基站参数
  519. if err := obj.bparamOamApi.OamSaveParam(dataModel); err != nil {
  520. resp.RespFail(c, "设置数据错误")
  521. }
  522. //返回数据并删除http请求通道
  523. obj.RespDataWithChan(c, httpReqChan, dataModel.ProjectID, dataModel.BtsID, public.BTS_MCP_SET, public.BTS_MODULE_GAIN)
  524. }
  525. // 复位基站
  526. func (obj *BparamHan) ResetBtsHan(c *gin.Context) {
  527. dataModel := new(bparammodel.BtsBaseParam)
  528. //把前端数据绑定到模型上
  529. if err := obj.bindApi.Bind2Model(c, dataModel); err != nil {
  530. resp.RespFail(c, "数据错误")
  531. return
  532. }
  533. //设置基站参数
  534. if err := obj.bparamOamApi.OamResetBts(dataModel); err != nil {
  535. resp.RespFail(c, "设置数据错误")
  536. }
  537. resp.RespOk(c)
  538. }