gate.go 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620
  1. package v1
  2. import (
  3. "fmt"
  4. "git.getensh.com/common/gopkgs/logger"
  5. "git.getensh.com/common/gopkgs/tasker/httptasker"
  6. "git.getensh.com/common/gopkgs/util"
  7. "github.com/gin-gonic/gin"
  8. "go.uber.org/zap"
  9. "net/http"
  10. "property-household-gateway/errors"
  11. param_v1 "property-household-gateway/param/v1"
  12. "property-household-gateway/pb"
  13. "property-household-gateway/pb/v1"
  14. "property-household-gateway/utils"
  15. )
  16. //
  17. // @Summary 门禁列表
  18. // @Description 门禁列表
  19. // @Tags 门禁
  20. // @Accept json
  21. // @Produce json
  22. // @Param token header string true " "
  23. // @Param garden_id query int true "小区id"
  24. // @Success 200 {object} v1.GateListResponse
  25. // @Failure 500 {object} base.HTTPError
  26. // @Router /api/v1/gate [get]
  27. func (c *Controller) GateList(ctx *gin.Context) {
  28. // 解析参数
  29. req := &param_v1.GateListRequest{}
  30. parseParamTask := func() error {
  31. err := util.ShouldBind(ctx, &req.Header, nil, &req.GateListQuery, nil)
  32. if err != nil {
  33. logger.Error("func",
  34. zap.String("call", "util.ShouldBind"),
  35. zap.String("error", err.Error()))
  36. return errors.ParamsError
  37. }
  38. if req.GardenId == 0 {
  39. return errors.ParamsError
  40. }
  41. return nil
  42. }
  43. // 业务处理
  44. handleServiceTask := func() error {
  45. tokenInfo, err := utils.GetJwtTokenInfo(ctx)
  46. if err != nil {
  47. return err
  48. }
  49. resp := param_v1.GateListResponse{}
  50. greq := &v1.GardenHouseholdUnitIdsRequest{GardenId: req.GardenId, Uids: []int64{tokenInfo.Uid}}
  51. greply, err := pb.Garden.GardenHouseholdUnitIds(ctx, greq)
  52. if err != nil {
  53. s, _ := json.MarshalToString(greq)
  54. logger.Error("func",
  55. zap.String("call", "Garden.GardenHouseholdUnitIds"),
  56. zap.String("params", s),
  57. zap.String("error", err.Error()))
  58. return errors.ErrorTransForm(err)
  59. }
  60. if len(greply.List) == 0 {
  61. ctx.JSON(http.StatusOK, resp)
  62. return nil
  63. }
  64. rpcReq := &v1.GateUnitDeviceRequest{
  65. GardenId: req.GardenId,
  66. UnitId: greply.List[0].UnitIds,
  67. }
  68. rpcRsp, err := pb.Device.GateUnitDevice(ctx, rpcReq)
  69. if err != nil {
  70. s, _ := json.MarshalToString(req)
  71. logger.Error("func",
  72. zap.String("call", "Device.GateUnitDevice"),
  73. zap.String("params", s),
  74. zap.String("error", err.Error()))
  75. return errors.ErrorTransForm(err)
  76. }
  77. if rpcRsp.List == nil {
  78. rpcRsp.List = make([]*v1.GateItem, 0)
  79. }
  80. resp.Data = *rpcRsp
  81. ctx.JSON(http.StatusOK, resp)
  82. return nil
  83. }
  84. // 执行任务
  85. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  86. }
  87. //
  88. // @Summary 录入人脸
  89. // @Description 录入人脸
  90. // @Tags 门禁
  91. // @Accept json
  92. // @Produce json
  93. // @Param token header string true " "
  94. // @Param body body v1.GateUserPicAddBody true " "
  95. // @Success 200 {object} v1.GateUserPicAddResponse
  96. // @Failure 500 {object} base.HTTPError
  97. // @Router /api/v1/gate/face [post]
  98. func (c *Controller) GateUserPicAdd(ctx *gin.Context) {
  99. // 解析参数
  100. req := &param_v1.GateUserPicAddRequest{}
  101. parseParamTask := func() error {
  102. err := util.ShouldBind(ctx, &req.Header, nil, nil, &req.GateUserPicAddBody)
  103. if err != nil {
  104. logger.Error("func",
  105. zap.String("call", "util.ShouldBind"),
  106. zap.String("error", err.Error()))
  107. return errors.ParamsError
  108. }
  109. if req.GardenId == 0 {
  110. return errors.ParamsError
  111. }
  112. return nil
  113. }
  114. // 业务处理
  115. handleServiceTask := func() error {
  116. tokenInfo, err := utils.GetJwtTokenInfo(ctx)
  117. if err != nil {
  118. return err
  119. }
  120. resp := param_v1.GateUserPicAddResponse{}
  121. rpcReq := &v1.GateUserPicAddRequest{
  122. GardenId: req.GardenId,
  123. PicUrl: req.PicUrl,
  124. Uid: tokenInfo.Uid,
  125. Phone: tokenInfo.Phone,
  126. //todo
  127. IdNumber: tokenInfo.IdNumber,
  128. Name: tokenInfo.RealName,
  129. }
  130. _, err = pb.Device.GateUserPicAdd(ctx, rpcReq)
  131. if err != nil {
  132. s, _ := json.MarshalToString(req)
  133. logger.Error("func",
  134. zap.String("call", "Device.GateUserPicAdd"),
  135. zap.String("params", s),
  136. zap.String("error", err.Error()))
  137. return errors.ErrorTransForm(err)
  138. }
  139. ctx.JSON(http.StatusOK, resp)
  140. return nil
  141. }
  142. // 执行任务
  143. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  144. }
  145. //
  146. // @Summary 人脸信息
  147. // @Description 人脸信息
  148. // @Tags 门禁
  149. // @Accept json
  150. // @Produce json
  151. // @Param token header string true " "
  152. // @Param garden_id query int true "小区id"
  153. // @Success 200 {object} v1.GateUserPicInfoResponse
  154. // @Failure 500 {object} base.HTTPError
  155. // @Router /api/v1/gate/face [get]
  156. func (c *Controller) GateUserPicInfo(ctx *gin.Context) {
  157. // 解析参数
  158. req := &param_v1.GateUserPicInfoRequest{}
  159. parseParamTask := func() error {
  160. err := util.ShouldBind(ctx, &req.Header, nil, &req.GateUserPicInfoQuery, nil)
  161. if err != nil {
  162. logger.Error("func",
  163. zap.String("call", "util.ShouldBind"),
  164. zap.String("error", err.Error()))
  165. return errors.ParamsError
  166. }
  167. if req.GardenId == 0 {
  168. return errors.ParamsError
  169. }
  170. return nil
  171. }
  172. // 业务处理
  173. handleServiceTask := func() error {
  174. tokenInfo, err := utils.GetJwtTokenInfo(ctx)
  175. if err != nil {
  176. return err
  177. }
  178. resp := param_v1.GateUserPicInfoResponse{}
  179. rpcReq := &v1.GateUserPicInfoRequest{
  180. GardenId: req.GardenId,
  181. Uid: tokenInfo.Uid,
  182. }
  183. rpcRsp, err := pb.Device.GateUserPicInfo(ctx, rpcReq)
  184. if err != nil {
  185. s, _ := json.MarshalToString(req)
  186. logger.Error("func",
  187. zap.String("call", "Device.GateUserPicInfo"),
  188. zap.String("params", s),
  189. zap.String("error", err.Error()))
  190. return errors.ErrorTransForm(err)
  191. }
  192. resp.Data = *rpcRsp
  193. ctx.JSON(http.StatusOK, resp)
  194. return nil
  195. }
  196. // 执行任务
  197. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  198. }
  199. //
  200. // @Summary 是否有人脸设备
  201. // @Description 是否有人脸设备
  202. // @Tags 门禁
  203. // @Accept json
  204. // @Produce json
  205. // @Param token header string true " "
  206. // @Param garden_id query int true "小区id"
  207. // @Success 200 {object} v1.GateHasFaceResponse
  208. // @Failure 500 {object} base.HTTPError
  209. // @Router /api/v1/gate/has_face_device [get]
  210. func (c *Controller) GateHasFace(ctx *gin.Context) {
  211. // 解析参数
  212. req := &param_v1.GateHasFaceRequest{}
  213. parseParamTask := func() error {
  214. err := util.ShouldBind(ctx, &req.Header, nil, &req.GateHasFaceQuery, nil)
  215. if err != nil {
  216. logger.Error("func",
  217. zap.String("call", "util.ShouldBind"),
  218. zap.String("error", err.Error()))
  219. return errors.ParamsError
  220. }
  221. if req.GardenId == 0 {
  222. return errors.ParamsError
  223. }
  224. return nil
  225. }
  226. // 业务处理
  227. handleServiceTask := func() error {
  228. tokenInfo, err := utils.GetJwtTokenInfo(ctx)
  229. if err != nil {
  230. return err
  231. }
  232. resp := param_v1.GateHasFaceResponse{}
  233. greq := &v1.GardenHouseholdUnitIdsRequest{GardenId: req.GardenId, Uids: []int64{tokenInfo.Uid}}
  234. greply, err := pb.Garden.GardenHouseholdUnitIds(ctx, greq)
  235. if err != nil {
  236. s, _ := json.MarshalToString(greq)
  237. logger.Error("func",
  238. zap.String("call", "Garden.GardenHouseholdUnitIds"),
  239. zap.String("params", s),
  240. zap.String("error", err.Error()))
  241. return errors.ErrorTransForm(err)
  242. }
  243. if len(greply.List) == 0 {
  244. ctx.JSON(http.StatusOK, resp)
  245. return nil
  246. }
  247. rpcReq := &v1.GateUnitDeviceRequest{
  248. GardenId: req.GardenId,
  249. UnitId: greply.List[0].UnitIds,
  250. OnlyHas: true,
  251. }
  252. rpcRsp, err := pb.Device.GateUnitDevice(ctx, rpcReq)
  253. if err != nil {
  254. s, _ := json.MarshalToString(req)
  255. logger.Error("func",
  256. zap.String("call", "Device.GateUnitDevice"),
  257. zap.String("params", s),
  258. zap.String("error", err.Error()))
  259. return errors.ErrorTransForm(err)
  260. }
  261. resp.Data.HasFaceDevice = rpcRsp.HasDevice
  262. ctx.JSON(http.StatusOK, resp)
  263. return nil
  264. }
  265. // 执行任务
  266. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  267. }
  268. //
  269. // @Summary 门禁二维码
  270. // @Description 门禁二维码
  271. // @Tags 门禁
  272. // @Accept json
  273. // @Produce json
  274. // @Param token header string true " "
  275. // @Param garden_id query int true "小区id"
  276. // @Success 200 {object} v1.GateQcodeResponse
  277. // @Failure 500 {object} base.HTTPError
  278. // @Router /api/v1/gate/qcode [get]
  279. func (c *Controller) GateQcode(ctx *gin.Context) {
  280. // 解析参数
  281. req := &param_v1.GateQcodeRequest{}
  282. parseParamTask := func() error {
  283. err := util.ShouldBind(ctx, &req.Header, nil, &req.GateQcodeQuery, nil)
  284. if err != nil {
  285. logger.Error("func",
  286. zap.String("call", "util.ShouldBind"),
  287. zap.String("error", err.Error()))
  288. return errors.ParamsError
  289. }
  290. if req.GardenId == 0 {
  291. return errors.ParamsError
  292. }
  293. return nil
  294. }
  295. // 业务处理
  296. handleServiceTask := func() error {
  297. tokenInfo, err := utils.GetJwtTokenInfo(ctx)
  298. if err != nil {
  299. return errors.TokenFailedError
  300. }
  301. resp := param_v1.GateQcodeResponse{}
  302. rpcReq := &v1.GateQcodeRequest{
  303. GardenId: req.GardenId,
  304. Uid: tokenInfo.Uid,
  305. }
  306. rpcRsp, err := pb.Household.GateQcode(ctx, rpcReq)
  307. if err != nil {
  308. s, _ := json.MarshalToString(req)
  309. logger.Error("func",
  310. zap.String("call", "Household.GateQcode"),
  311. zap.String("params", s),
  312. zap.String("error", err.Error()))
  313. return errors.ErrorTransForm(err)
  314. }
  315. resp.Data = *rpcRsp
  316. ctx.JSON(http.StatusOK, resp)
  317. return nil
  318. }
  319. // 执行任务
  320. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  321. }
  322. //
  323. // @Summary 门禁访客邀约二维码
  324. // @Description 门禁访客邀约二维码
  325. // @Tags 门禁
  326. // @Accept json
  327. // @Produce json
  328. // @Param token header string true " "
  329. // @Param device_id query int true "设备id"
  330. // @Param garden_id query int true "小区id"
  331. // @Param start query int true "开始时间戳"
  332. // @Param end query int true "截止时间戳"
  333. // @Param visitor_name query string true "访客姓名"
  334. // @Param visitor_phone query string true "访客联系方式"
  335. // @Param comment query string true "访问是由"
  336. // @Success 200 {object} v1.GateQcodeVisitorResponse
  337. // @Failure 500 {object} base.HTTPError
  338. // @Router /api/v1/gate/qcode_visitor [get]
  339. func (c *Controller) GateQcodeVisitor(ctx *gin.Context) {
  340. // 解析参数
  341. req := &param_v1.GateQcodeVisitorRequest{}
  342. parseParamTask := func() error {
  343. err := util.ShouldBind(ctx, &req.Header, nil, &req.GateQcodeVisitorQuery, nil)
  344. if err != nil {
  345. logger.Error("func",
  346. zap.String("call", "util.ShouldBind"),
  347. zap.String("error", err.Error()))
  348. return errors.ParamsError
  349. }
  350. if req.GardenId == 0 {
  351. return errors.ParamsError
  352. }
  353. return nil
  354. }
  355. // 业务处理
  356. handleServiceTask := func() error {
  357. tokenInfo, err := utils.GetJwtTokenInfo(ctx)
  358. if err != nil {
  359. return errors.TokenFailedError
  360. }
  361. resp := param_v1.GateQcodeVisitorResponse{}
  362. rpcReq := &v1.GateQcodeRequest{
  363. GardenId: req.GardenId,
  364. DeviceId: req.DeviceId,
  365. Uid: tokenInfo.Uid,
  366. Visitor: true,
  367. VisitorStart: req.Start,
  368. VisitorEnd: req.End,
  369. VisitorName: req.VisitorName,
  370. VisitorPhone: req.VisitorPhone,
  371. UserName: tokenInfo.RealName,
  372. Phone: tokenInfo.Phone,
  373. Comment: req.Comment,
  374. }
  375. rpcRsp, err := pb.Household.GateQcode(ctx, rpcReq)
  376. if err != nil {
  377. s, _ := json.MarshalToString(req)
  378. logger.Error("func",
  379. zap.String("call", "Household.GateQcode"),
  380. zap.String("params", s),
  381. zap.String("error", err.Error()))
  382. return errors.ErrorTransForm(err)
  383. }
  384. resp.Data = *rpcRsp
  385. ctx.JSON(http.StatusOK, resp)
  386. return nil
  387. }
  388. // 执行任务
  389. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  390. }
  391. //
  392. // @Summary 我的邀约
  393. // @Description 我的邀约
  394. // @Tags 门禁
  395. // @Accept json
  396. // @Produce json
  397. // @Param token header string true " "
  398. // @Param page query int false " "
  399. // @Param page_size query int false " "
  400. // @Param gate_id query int false "门禁id选填"
  401. // @Success 200 {object} v1.GateVisitorListResponse
  402. // @Failure 500 {object} base.HTTPError
  403. // @Router /api/v1/gate/visitor [get]
  404. func (c *Controller) GateVisitorList(ctx *gin.Context) {
  405. // 解析参数
  406. req := &param_v1.GateVisitorListRequest{}
  407. parseParamTask := func() error {
  408. err := util.ShouldBind(ctx, &req.Header, nil, &req.GateVisitorListQuery, nil)
  409. if err != nil {
  410. logger.Error("func",
  411. zap.String("call", "util.ShouldBind"),
  412. zap.String("error", err.Error()))
  413. return errors.ParamsError
  414. }
  415. return nil
  416. }
  417. // 业务处理
  418. handleServiceTask := func() error {
  419. tokenInfo, err := utils.GetJwtTokenInfo(ctx)
  420. if err != nil {
  421. return err
  422. }
  423. resp := param_v1.GateVisitorListResponse{}
  424. rpcReq := &v1.GateVisitorListRequest{
  425. Page: req.Page,
  426. PageSize: req.PageSize,
  427. DeviceId: req.GateId,
  428. Uid: tokenInfo.Uid,
  429. }
  430. fmt.Printf("token:%v\n", tokenInfo.Uid)
  431. rpcRsp, err := pb.Device.GateVisitorList(ctx, rpcReq)
  432. if err != nil {
  433. s, _ := json.MarshalToString(req)
  434. logger.Error("func",
  435. zap.String("call", "Device.GateVisitorList"),
  436. zap.String("params", s),
  437. zap.String("error", err.Error()))
  438. return errors.ErrorTransForm(err)
  439. }
  440. if rpcRsp.List == nil {
  441. rpcRsp.List = make([]*v1.GateVisitorListItem, 0)
  442. }
  443. resp.Data = *rpcRsp
  444. ctx.JSON(http.StatusOK, resp)
  445. return nil
  446. }
  447. // 执行任务
  448. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  449. }
  450. //
  451. // @Summary 删除访客记录
  452. // @Description 删除访客记录
  453. // @Tags 门禁
  454. // @Accept json
  455. // @Produce json
  456. // @Param token header string true " "
  457. // @Param id query int true " 记录id"
  458. // @Success 200 {object} v1.GateVisitorDelResponse
  459. // @Failure 500 {object} base.HTTPError
  460. // @Router /api/v1/gate/visitor [delete]
  461. func (c *Controller) GateVisitorDel(ctx *gin.Context) {
  462. // 解析参数
  463. req := &param_v1.GateVisitorDelRequest{}
  464. parseParamTask := func() error {
  465. err := util.ShouldBind(ctx, &req.Header, nil, &req.GateVisitorDelQuery, nil)
  466. if err != nil {
  467. logger.Error("func",
  468. zap.String("call", "util.ShouldBind"),
  469. zap.String("error", err.Error()))
  470. return errors.ParamsError
  471. }
  472. return nil
  473. }
  474. // 业务处理
  475. handleServiceTask := func() error {
  476. tokenInfo, err := utils.GetJwtTokenInfo(ctx)
  477. if err != nil {
  478. return err
  479. }
  480. resp := param_v1.GateVisitorDelResponse{}
  481. rpcReq := &v1.GateVisitorDelRequest{
  482. Id: req.Id,
  483. Uid: tokenInfo.Uid,
  484. }
  485. _, err = pb.Device.GateVisitorDel(ctx, rpcReq)
  486. if err != nil {
  487. s, _ := json.MarshalToString(req)
  488. logger.Error("func",
  489. zap.String("call", "Device.GateVisitorDel"),
  490. zap.String("params", s),
  491. zap.String("error", err.Error()))
  492. return errors.ErrorTransForm(err)
  493. }
  494. ctx.JSON(http.StatusOK, resp)
  495. return nil
  496. }
  497. // 执行任务
  498. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  499. }
  500. //
  501. // @Summary 访客获取到的分享页面
  502. // @Description 访客获取到的分享页面
  503. // @Tags 门禁
  504. // @Accept json
  505. // @Produce json
  506. // @Param id query int true " 访客邀约记录id"
  507. // @Success 200 {object} v1.GateVisitorPageResponse
  508. // @Failure 500 {object} base.HTTPError
  509. // @Router /api/v1/gate/visitor/share [get]
  510. func (c *Controller) GateVisitorPage(ctx *gin.Context) {
  511. // 解析参数
  512. req := &param_v1.GateVisitorPageRequest{}
  513. parseParamTask := func() error {
  514. err := util.ShouldBind(ctx, nil, nil, &req.GateVisitorPageQuery, nil)
  515. if err != nil {
  516. logger.Error("func",
  517. zap.String("call", "util.ShouldBind"),
  518. zap.String("error", err.Error()))
  519. return errors.ParamsError
  520. }
  521. return nil
  522. }
  523. // 业务处理
  524. handleServiceTask := func() error {
  525. resp := param_v1.GateVisitorPageResponse{}
  526. rpcReq := &v1.GateVisitorListRequest{
  527. Id: req.Id,
  528. }
  529. rpcRsp, err := pb.Device.GateVisitorList(ctx, rpcReq)
  530. if err != nil {
  531. s, _ := json.MarshalToString(req)
  532. logger.Error("func",
  533. zap.String("call", "Device.GateVisitorList"),
  534. zap.String("params", s),
  535. zap.String("error", err.Error()))
  536. return errors.ErrorTransForm(err)
  537. }
  538. if len(rpcRsp.List) == 0 {
  539. return errors.ErrRecordNotFound
  540. }
  541. resp.Data = *rpcRsp.List[0]
  542. ctx.JSON(http.StatusOK, resp)
  543. return nil
  544. }
  545. // 执行任务
  546. httptasker.Exec(ctx, parseParamTask, handleServiceTask)
  547. }