From d23d253c12006b66a503bbbc34a30b7d0f52a75a Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期五, 16 八月 2024 18:26:33 +0800 Subject: [PATCH] 最新版本 --- server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/HkSyncCloudController.java | 54 +++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 43 insertions(+), 11 deletions(-) diff --git a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/HkSyncCloudController.java b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/HkSyncCloudController.java index 7bb21a8..48c67b6 100644 --- a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/HkSyncCloudController.java +++ b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/HkSyncCloudController.java @@ -3,21 +3,17 @@ import com.doumee.api.BaseController; import com.doumee.config.annotation.CloudRequiredPermission; import com.doumee.core.annotation.pr.PreventRepeat; -import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest; -import com.doumee.core.haikang.model.param.request.EventSubRequest; -import com.doumee.core.haikang.model.param.request.ParkListRequest; -import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest; +import com.doumee.core.haikang.model.param.request.*; 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.utils.Constants; -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 com.doumee.dao.business.model.Device; +import com.doumee.service.business.impl.hksync.*; 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.*; @@ -33,6 +29,8 @@ public class HkSyncCloudController extends BaseController { @Autowired + private HkSyncPlatformsServiceImpl hkSyncPlatformsService; + @Autowired private HkSyncDeviceServiceImpl hkSyncDeviceService; @Autowired private HkSyncParkServiceImpl hkSyncParkService; @@ -40,13 +38,47 @@ private HkSyncPrivilegeServiceImpl hkSyncPrivilegeService; @Autowired private HkSyncPushServiceImpl hkSyncPushService; - + @Autowired + private HkSyncLoginAuthServiceImpl hkSyncLoginAuthService; + @PreventRepeat + @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ユ湀鍙颁俊鎭帴鍙�") + @PostMapping("/syncPlatforms") + @CloudRequiredPermission("business:hksync:platforms") + public ApiResponse syncPlatforms(@RequestBody PlatformsListRequest param) { + String result = hkSyncPlatformsService.syncPlatforms(param); + return ApiResponse.success(result); + } + @PreventRepeat + @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ユ湀鍙扮姸鎬佷俊鎭帴鍙�") + @PostMapping("/syncPlatformStatus") + @CloudRequiredPermission("business:hksync:platforms") + public ApiResponse syncPlatformStatus(@RequestBody PlatformStatusRequest param) { + String result = hkSyncPlatformsService.getPlatformStatus(param); + return ApiResponse.success(result); + } @PreventRepeat @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ラ棬绂佽澶囨帴鍙�") @PostMapping("/syncDevices") @CloudRequiredPermission("business:hksync:device") - public ApiResponse syncHkDevices(@RequestBody AcsDeviceListRequest param,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ - String result = hkSyncDeviceService.syncHkDevices(param); + public ApiResponse syncHkDevices(@RequestBody Device param, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ + String result = null; + if(Constants.equalsInteger(param.getType(),Constants.ZERO)){ + result = hkSyncDeviceService.syncHkDevices(param); + }else if(Constants.equalsInteger(param.getType(),Constants.TWO)){ + //鍚屾LED + result = hkSyncDeviceService.syncHkLed(param); + }else if(Constants.equalsInteger(param.getType(),Constants.THREE)){ + //鍚屾骞挎挱 + result = hkSyncDeviceService.syncHkBroadcast(param); + } + return ApiResponse.success(result); + } + @PreventRepeat + @ApiOperation("銆愭捣搴枫�戣幏鍙栫粍浠舵巿鏉冪櫥褰曞湴鍧�鎺ュ彛") + @PostMapping("/getServiceUrl") + public ApiResponse getServiceUrl(@RequestBody HKGetServiceLoginUrlRequest param,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ + param.setUsername(this.getLoginUser(token).getUsername()); + String result = hkSyncLoginAuthService.getServiceUrl(param); return ApiResponse.success(result); } @PreventRepeat -- Gitblit v1.9.3