From 1140f80aefef30b543c99aaed47bcbca731b24e2 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期五, 08 十二月 2023 18:21:40 +0800 Subject: [PATCH] 海康接口对接开发 --- server/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java | 46 ++++++++++++++++++++++++++++------------------ 1 files changed, 28 insertions(+), 18 deletions(-) diff --git a/server/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java b/server/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java index fafb7f7..79bd91b 100644 --- a/server/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java +++ b/server/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java @@ -1,29 +1,24 @@ package com.doumee.api.business; import com.doumee.api.BaseController; -import com.doumee.core.annotation.excel.ExcelExporter; import com.doumee.core.annotation.pr.PreventRepeat; import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest; import com.doumee.core.haikang.model.param.request.ParkListRequest; -import com.doumee.core.haikang.service.HKService; +import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest; +import com.doumee.core.haikang.model.param.request.event.acs.EventAcsRequest; +import com.doumee.core.haikang.model.param.request.event.parks.EventParkRequest; +import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest; import com.doumee.core.model.ApiResponse; -import com.doumee.core.model.PageData; -import com.doumee.core.model.PageWrap; -import com.doumee.dao.business.model.Device; -import com.doumee.service.business.DeviceService; -import com.doumee.service.business.HkSyncService; import com.doumee.service.business.impl.hksync.HkSyncDeviceServiceImpl; import com.doumee.service.business.impl.hksync.HkSyncParkServiceImpl; import com.doumee.service.business.impl.hksync.HkSyncPrivilegeServiceImpl; +import com.doumee.service.business.impl.hksync.HkSyncPushServiceImpl; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; -import org.apache.shiro.authz.annotation.RequiresPermissions; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletResponse; -import java.util.ArrayList; -import java.util.List; /** * @author 姹熻箘韫� @@ -40,6 +35,8 @@ private HkSyncParkServiceImpl hkSyncParkService; @Autowired private HkSyncPrivilegeServiceImpl hkSyncPrivilegeService; + @Autowired + private HkSyncPushServiceImpl hkSyncPushService; @PreventRepeat @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ラ棬绂佽澶囨帴鍙�") @@ -58,19 +55,32 @@ return ApiResponse.success(result); } @PreventRepeat - @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ュ仠杞﹀簱鎺ュ彛") + @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ヨ瀹㈡潈闄愮粍鎺ュ彛") @PostMapping("/getPrivilege") // @RequiresPermissions("business:hksync:privilege") - public ApiResponse getPrivilege(@RequestBody ParkListRequest param) { - String result = hkSyncPrivilegeService.syncHkParks(param); + public ApiResponse getPrivilege(@RequestBody PrivilegeGroupRequest param) { + String result = hkSyncPrivilegeService.syncPrivilege(param); return ApiResponse.success(result); } @PreventRepeat - @ApiOperation("銆愭捣搴枫�戜簨浠惰闃呮帹閫佸鎺ュ鐞嗘帴鍙�") - @PostMapping("/push") -// @RequiresPermissions("business:hksync:privilege") - public ApiResponse push(@RequestBody ParkListRequest param) { - String result = hkSyncPrivilegeService.syncHkParks(param); + @ApiOperation("銆愭捣搴枫�戦棬绂佷簨浠惰闃呮帹閫佸鎺ュ鐞嗘帴鍙�") + @PostMapping("/push/acs") + public ApiResponse pushAcs(@RequestBody EventAcsRequest param, HttpServletResponse response) { + String result = hkSyncPushService.dealAcsEvent(param,response); + return ApiResponse.success(result); + } + @PreventRepeat + @ApiOperation("銆愭捣搴枫�戣瀹簨浠惰闃呮帹閫佸鎺ュ鐞嗘帴鍙�") + @PostMapping("/push/visit") + public ApiResponse pushVisit(@RequestBody EventVisitRequest param, HttpServletResponse response) { + String result = hkSyncPushService.dealVisitEvent(param,response); + return ApiResponse.success(result); + } + @PreventRepeat + @ApiOperation("銆愭捣搴枫�戝仠杞﹀満浜嬩欢璁㈤槄鎺ㄩ�佸鎺ュ鐞嗘帴鍙�") + @PostMapping("/push/parks") + public ApiResponse pushParks(@RequestBody EventParkRequest param, HttpServletResponse response) { + String result = hkSyncPushService.dealParkEvent(param,response); return ApiResponse.success(result); } } -- Gitblit v1.9.3