From 973c131193c4dd3e4ed42518177a996a901037ec Mon Sep 17 00:00:00 2001
From: lishuai <260038442@qq.com>
Date: 星期五, 15 十二月 2023 17:57:01 +0800
Subject: [PATCH] 内部员工门禁组
---
server/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java | 81 +++++++++++++++++++++++++++++-----------
1 files changed, 58 insertions(+), 23 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..6dfa1e4 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,29 @@
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.EventSubRequest;
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.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
-import java.util.ArrayList;
-import java.util.List;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
/**
* @author 姹熻箘韫�
@@ -40,37 +40,72 @@
private HkSyncParkServiceImpl hkSyncParkService;
@Autowired
private HkSyncPrivilegeServiceImpl hkSyncPrivilegeService;
+ @Autowired
+ private HkSyncPushServiceImpl hkSyncPushService;
@PreventRepeat
@ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ラ棬绂佽澶囨帴鍙�")
- @PostMapping("/getDevices")
+ @PostMapping("/syncDevices")
// @RequiresPermissions("business:hksync:device")
- public ApiResponse getDevices(@RequestBody AcsDeviceListRequest param) {
+ public ApiResponse syncHkDevices(@RequestBody AcsDeviceListRequest param) {
String result = hkSyncDeviceService.syncHkDevices(param);
return ApiResponse.success(result);
}
@PreventRepeat
@ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ュ仠杞﹀簱鎺ュ彛")
- @PostMapping("/getParks")
+ @PostMapping("/syncParks")
// @RequiresPermissions("business:hksync:park")
- public ApiResponse getParks(@RequestBody ParkListRequest param) {
+ public ApiResponse syncHkParks(@RequestBody ParkListRequest param) {
String result = hkSyncParkService.syncHkParks(param);
return ApiResponse.success(result);
}
@PreventRepeat
- @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ュ仠杞﹀簱鎺ュ彛")
- @PostMapping("/getPrivilege")
+ @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ヨ瀹㈡潈闄愮粍鎺ュ彛")
+ @PostMapping("/syncPrivilege")
// @RequiresPermissions("business:hksync:privilege")
- public ApiResponse getPrivilege(@RequestBody ParkListRequest param) {
- String result = hkSyncPrivilegeService.syncHkParks(param);
+ public ApiResponse syncPrivilege(@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( HttpServletRequest request,@RequestBody EventAcsRequest param, HttpServletResponse response) {
+ try {
+ BufferedReader br = new BufferedReader(new InputStreamReader(request.getInputStream(),"UTF-8"));
+ String line = null;
+ StringBuffer sb = new StringBuffer();
+ while (true) {
+ if (!((line = br.readLine()) != null)) break;
+
+ sb.append(line);
+ }
+ System.out.println(sb.toString());
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ 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);
+ }
+ @PreventRepeat
+ @ApiOperation("銆愭捣搴枫�戝彇娑堣闃呬簨浠�")
+ @PostMapping("/cancelEventSub")
+ public ApiResponse cancelEventSub(@RequestBody EventSubRequest param, HttpServletResponse response) {
+ hkSyncPushService.cancelEventSub();
+ return ApiResponse.success(null);
+ }
}
--
Gitblit v1.9.3