From a8296ef06369452e9151624b6ac4e7cb12a394e3 Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期三, 21 一月 2026 16:06:18 +0800
Subject: [PATCH] 导入数据模板下载

---
 fzzy-igdss-view/src/main/java/com/fzzy/igds/SecCameraPR.java |  245 ++++++++++++++++++++----------------------------
 1 files changed, 102 insertions(+), 143 deletions(-)

diff --git a/fzzy-igdss-view/src/main/java/com/fzzy/igds/SecCameraPR.java b/fzzy-igdss-view/src/main/java/com/fzzy/igds/SecCameraPR.java
index 5190e2f..8f362b2 100644
--- a/fzzy-igdss-view/src/main/java/com/fzzy/igds/SecCameraPR.java
+++ b/fzzy-igdss-view/src/main/java/com/fzzy/igds/SecCameraPR.java
@@ -4,6 +4,10 @@
 import com.bstek.dorado.annotation.DataResolver;
 import com.bstek.dorado.annotation.Expose;
 import com.bstek.dorado.data.provider.Page;
+import com.fzzy.igds.camera.ApiCameraManager;
+import com.fzzy.igds.camera.data.ApiCameraData;
+import com.fzzy.igds.camera.data.ApiCameraResp;
+import com.fzzy.igds.data.IgdsBaseParam;
 import com.fzzy.igds.domain.Camera;
 import com.fzzy.igds.service.SecCameraService;
 import com.fzzy.igds.utils.ContextUtil;
@@ -11,19 +15,10 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.domain.PageRequest;
-import org.springframework.data.domain.Pageable;
-import org.springframework.data.domain.Sort;
-import org.springframework.data.jpa.domain.Specification;
 import org.springframework.stereotype.Component;
-import javax.persistence.criteria.CriteriaBuilder;
-import javax.persistence.criteria.CriteriaQuery;
-import javax.persistence.criteria.Predicate;
-import javax.persistence.criteria.Root;
-import java.util.ArrayList;
-import java.util.HashMap;
+
+import javax.annotation.Resource;
 import java.util.List;
-import java.util.Map;
 
 /**
  * @Description
@@ -34,150 +29,114 @@
 @Component
 public class SecCameraPR {
 
-	@Autowired
-	private SecCameraService secCameraService;
+    @Autowired
+    private SecCameraService secCameraService;
+    @Resource
+    private ApiCameraManager apiCameraManager;
 
-	/**
-	 * secCameraPR#listPageCamera 鏍规嵁鏉′欢鑾峰彇鎵�鏈夌殑鎽勫儚鏈洪厤缃俊鎭�
-	 * 
-	 * @param param
-	 */
-	@DataProvider
-	public void listPageCamera(Page<Camera> page, Map<String, Object> param) {
-		org.springframework.data.domain.Page<Camera> japPage = pageCamera(page, param);
-		page.setEntityCount((int) japPage.getTotalElements());
-		page.setEntities(japPage.getContent());
-	}
 
-	public org.springframework.data.domain.Page<Camera> pageCamera(Page<Camera> page, Map<String, Object> param) {
-		if (null == param) {
-			param = new HashMap<>();
-		}
-		Map<String, Object> finalParam = param;
+    /**
+     * secCameraPR#listPageCamera 鏍规嵁鏉′欢鑾峰彇鎵�鏈夌殑鎽勫儚鏈洪厤缃俊鎭�
+     *
+     * @param param
+     */
+    @DataProvider
+    public void listPageCamera(Page<Camera> page, Camera param) {
+        com.baomidou.mybatisplus.extension.plugins.pagination.Page<Camera> corePage = new com.baomidou.mybatisplus.extension.plugins.pagination.Page<>(page.getPageNo(), page.getPageSize());
 
-		//澶氬弬鏁板垎椤垫煡璇�
-		Pageable pageable = PageRequest.of(page.getPageNo() - 1, page.getPageSize(), Sort.Direction.ASC, Camera.SORT_PROP);
-		Specification<Camera> specification = new Specification<Camera>() {
-			private static final long serialVersionUID = 1L;
+        if (null == param) {
+            param = new Camera();
+        }
+        Camera camera = new Camera();
+        BeanUtils.copyProperties(param, camera);
+        secCameraService.listPageCamera(corePage, camera);
 
-			public Predicate toPredicate(Root<Camera> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
-				List<Predicate> predicates = new ArrayList<Predicate>(); //鎵�鏈夌殑鏂█
+        // 閲嶆柊灏佽
+        page.setEntities(corePage.getRecords());
+        page.setEntityCount(Integer.parseInt(String.valueOf(corePage.getTotal())));
+    }
 
-				Predicate predicate1 = cb.equal(root.get("companyId"), ContextUtil.getCompanyId());
-				predicates.add(predicate1);
-				Predicate predicate2 = cb.equal(root.get("deptId"), ContextUtil.subDeptId(null));
-				predicates.add(predicate2);
+    /**
+     * secCameraPR#listCamera 鑾峰彇鎵�鏈夌殑鎽勫儚鏈洪厤缃俊鎭�
+     * ${dorado.getDataProvider("secCameraPR#listCamera").getResult()}
+     *
+     * @return
+     */
+    @DataProvider
+    public List<Camera> listCamera(String deptId) {
+        return secCameraService.listCamera(null, deptId);
+    }
 
-				String key = (String) finalParam.get("bizType");
-				if (StringUtils.isNotEmpty(key)) {
-					Predicate predicate3 = cb.equal(root.get("bizType"), key);
-					predicates.add(predicate3);
-				}
-				key = (String) finalParam.get("name");
-				if (StringUtils.isNotEmpty(key)) {
-					Predicate predicate4 = cb.like(root.get("name"), "%" + key + "%");
-					predicates.add(predicate4);
-				}
-				key = (String) finalParam.get("brand");
-				if (StringUtils.isNotEmpty(key)) {
-					Predicate predicate5 = cb.equal(root.get("brand"), key);
-					predicates.add(predicate5);
-				}
-				key = (String) finalParam.get("spjklx");
-				if (StringUtils.isNotEmpty(key)) {
-					Predicate predicate5 = cb.equal(root.get("spjklx"), key);
-					predicates.add(predicate5);
-				}
-				key = (String) finalParam.get("spdwlx");
-				if (StringUtils.isNotEmpty(key)) {
-					Predicate predicate5 = cb.equal(root.get("spdwlx"), key);
-					predicates.add(predicate5);
-				}
-				return cb.and(predicates.toArray(new Predicate[0]));
-			}
-		};
-		org.springframework.data.domain.Page<Camera> japPage = secCameraService.findAll(specification, pageable);
-		return japPage;
-	}
+    /**
+     * secCameraPR#saveCamera
+     *
+     * @param data
+     */
+    @DataResolver
+    public void saveCamera(Camera data) {
+        Camera secCamera = new Camera();
+        BeanUtils.copyProperties(data, secCamera);
+        secCameraService.saveCamera(secCamera);
+    }
 
-	/**
-	 * secCameraPR#listCamera 鑾峰彇鎵�鏈夌殑鎽勫儚鏈洪厤缃俊鎭�
-	 * ${dorado.getDataProvider("secCameraPR#listCamera").getResult()}
-	 * @return
-	 */
-	@DataProvider
-	public List<Camera> listCamera() {
-		return secCameraService.listCamera();
-	}
+    /**
+     * secCameraPR#delCamera
+     *
+     * @param data
+     * @return
+     */
+    @Expose
+    public String delCamera(Camera data) {
+        Camera secCamera = new Camera();
+        BeanUtils.copyProperties(data, secCamera);
+        return secCameraService.delCamera(secCamera);
+    }
 
-	/**
-	 * secCameraPR#saveCamera
-	 * 
-	 * @param data
-	 */
-	@DataResolver
-	public void saveCamera(Camera data) {
-		Camera secCamera = new Camera();
-		BeanUtils.copyProperties(data, secCamera);
-		secCameraService.saveCamera(secCamera);
-	}
+    /***
+     * secCameraPR#refreshCache
+     * @return
+     */
+    @Expose
+    public String refreshCache() {
+        secCameraService.refreshCache(ContextUtil.getCompanyId());
+        return null;
+    }
 
-	/**
-	 * secCameraPR#delCamera
-	 * 
-	 * @param data
-	 * @return
-	 */
-	@Expose
-	public String delCamera(Camera data) {
-		Camera secCamera = new Camera();
-		BeanUtils.copyProperties(data, secCamera);
-		return secCameraService.delCamera(secCamera);
-	}
-	
-	/***
-	 * secCameraPR#refreshCache
-	 * @return
-	 */
-	@Expose
-	public String refreshCache() {
-		secCameraService.refreshCache(ContextUtil.getCompanyId());
-		return null;
-	}
 
-	/***
-	 * securityPR#flushByMedia
-	 *
-	 * 鑾峰彇鎽勫儚澶村垪琛ㄤ俊鎭�
-	 * @return
-	 */
-	@Expose
-	public String flushByMedia(String playType) {
+    /***
+     * securityPR#flushByMedia
+     *
+     * 鏍规嵁搴撳尯缂栫爜鍙婃挱鏀炬柟寮忥紝鍚屾鐩戞帶淇℃伅
+     * @return
+     */
+    @DataResolver
+    public String flushByMedia(Camera param) {
 
-		if (null == playType){
-			return "娌℃湁閫夋嫨鎾斁鏂瑰紡锛屾墽琛屽け璐�";
-		}
+        if (StringUtils.isBlank(param.getPlayType())) {
+            return "娌℃湁閫夋嫨鎾斁鏂瑰紡锛屼笉鎵ц锛�";
+        }
+        if (StringUtils.isBlank(param.getDeptId())) {
+            return "娌℃湁鍚屾搴撳尯锛屼笉鎵ц1";
+        }
+        try {
+            //閫氳繃缁熶竴鍏ュ彛鑾峰彇鎾斁鍦板潃
+            ApiCameraData apiCameraData = new ApiCameraData();
+            apiCameraData.setCompanyId(ContextUtil.getCompanyId());
+            apiCameraData.setDeptId(param.getDeptId());
 
-//		try {
-//			if (CameraUtil.PLAY_TYPE_MEDIA_HIK.equals(playType)) {
-//				ApiCameraData apiCameraData = new ApiCameraData();
-//				apiCameraData.setCompanyId(ContextUtil.getCompanyId());
-//				apiCameraData.setDeptId(ContextUtil.subDeptId(null));
-//				apiCameraData.setPlayType(playType);
-//				List<SecCameraDto> list = apiCameraManager.getApiCameraService(playType).searchCamera(apiCameraData);
-//				if(list == null){
-//					return "鍚屾澶辫触锛�";
-//				}else {
-//					return "鍚屾鎴愬姛锛�";
-//				}
-//			}
-			return "褰撳墠鎾斁鏂瑰紡娌℃湁姝ゅ姛鑳斤紒";
-//
-//		}catch (Exception e){
-//			log.error("-----鍚屾鎽勫儚澶村垪琛ㄥけ璐�-----鍘熷洜={}", e.toString());
-//			return "杩滅▼鎺ュ彛鏈嶅姟寮傚父锛岃鏍告煡鍚庨噸璇曪紒";
-//		}
+            //鏍规嵁鎾斁鏂瑰紡鑾峰彇瀵瑰簲鐨勬挱鏀惧湴鍧�
+            List<Camera> cameras = apiCameraManager.getApiCameraService(param.getPlayType()).searchCamera(apiCameraData);
+            if (cameras == null) {
+                return "鍚屾澶辫触锛�";
+            } else {
+                return null;
+            }
 
-	}
+        } catch (Exception e) {
+            log.error("-----鍚屾鎽勫儚澶村垪琛ㄥけ璐�-----鍘熷洜={}", e.toString());
+            return "杩滅▼鎺ュ彛鏈嶅姟寮傚父锛岃鏍告煡鍚庨噸璇曪紒";
+        }
+
+    }
 
 }

--
Gitblit v1.9.3