From ad6dfb8323ab40ca8fe4fed94722c755d89c3203 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期三, 28 二月 2024 15:14:47 +0800
Subject: [PATCH] 整理
---
server/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java | 84 ++++++++++++++++++++++++++++++++++-------
1 files changed, 69 insertions(+), 15 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 1a0ddb4..98132b6 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,25 +1,30 @@
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.service.HKService;
+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.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 姹熻箘韫�
@@ -31,15 +36,64 @@
public class HkSyncController extends BaseController {
@Autowired
- private HkSyncService hkSyncService;
+ private HkSyncDeviceServiceImpl hkSyncDeviceService;
+ @Autowired
+ private HkSyncParkServiceImpl hkSyncParkService;
+ @Autowired
+ private HkSyncPrivilegeServiceImpl hkSyncPrivilegeService;
+ @Autowired
+ private HkSyncPushServiceImpl hkSyncPushService;
@PreventRepeat
- @ApiOperation("鍏ㄩ噺鍚屾闂ㄧ璁惧鎺ュ彛")
- @PostMapping("/getDevices")
+ @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ラ棬绂佽澶囨帴鍙�")
+ @PostMapping("/syncDevices")
@RequiresPermissions("business:hksync:device")
- public ApiResponse getDevices(@RequestBody AcsDeviceListRequest param) {
- hkSyncService.syncHkDevices(param);
+ public ApiResponse syncHkDevices(@RequestBody AcsDeviceListRequest param) {
+ String result = hkSyncDeviceService.syncHkDevices(param);
+ return ApiResponse.success(result);
+ }
+ @PreventRepeat
+ @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ュ仠杞﹀簱鎺ュ彛")
+ @PostMapping("/syncParks")
+ @RequiresPermissions("business:hksync:park")
+ public ApiResponse syncHkParks(@RequestBody ParkListRequest param) {
+ String result = hkSyncParkService.syncHkParks(param);
+ return ApiResponse.success(result);
+ }
+ @PreventRepeat
+ @ApiOperation("銆愭捣搴枫�戝叏閲忓悓姝ヨ瀹㈡潈闄愮粍鎺ュ彛")
+ @PostMapping("/syncPrivilege")
+ @RequiresPermissions("business:hksync:privilege")
+ public ApiResponse syncPrivilege(@RequestBody PrivilegeGroupRequest param) {
+ String result = hkSyncPrivilegeService.syncPrivilege(param);
+ return ApiResponse.success(result);
+ }
+ @PreventRepeat
+ @ApiOperation("銆愭捣搴枫�戦棬绂佷簨浠惰闃呮帹閫佸鎺ュ鐞嗘帴鍙�")
+ @PostMapping("/push/acs")
+ public ApiResponse pushAcs( HttpServletRequest request,@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);
+ }
+ @PreventRepeat
+ @ApiOperation("銆愭捣搴枫�戝彇娑堣闃呬簨浠�")
+ @PostMapping("/cancelEventSub")
+ public ApiResponse cancelEventSub(@RequestBody EventSubRequest param, HttpServletResponse response) {
+ hkSyncPushService.cancelEventSub();
return ApiResponse.success(null);
}
-
}
--
Gitblit v1.9.3