From ca01cb6a493c9b3ddf6508a458e6c561fe0f81a8 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期四, 31 十月 2024 16:05:40 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java |   43 ++++++++++++++++++++++---------------------
 1 files changed, 22 insertions(+), 21 deletions(-)

diff --git a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java
index 510e91b..f7019e4 100644
--- a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java
+++ b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java
@@ -170,19 +170,19 @@
 			return AjaxResult.error("设备编号已存在");
 		}
 		//调用华为Iot创建设备
-		AddDevice addDevice = new AddDevice();
-		addDevice.setProductId("66da68d21837002b28b34ec0");
-		addDevice.setNodeId(chargingPile.getCode());
-		addDevice.setDeviceName(chargingPile.getName());
-		addDevice.setDescription(chargingPile.getNumber().toString());
-		AddDeviceResp deviceResp = iotInterfaceClient.addDevice(addDevice).getData();
-		if(null != deviceResp){
-			int httpStatusCode = deviceResp.getHttpStatusCode();
-			if(httpStatusCode == 201){
-				chargingPile.setIotdDeviceId(deviceResp.getDeviceId());
-				this.save(chargingPile);
-			}
-		}
+//		AddDevice addDevice = new AddDevice();
+//		addDevice.setProductId("66da68d21837002b28b34ec0");
+//		addDevice.setNodeId(chargingPile.getCode());
+//		addDevice.setDeviceName(chargingPile.getName());
+//		addDevice.setDescription(chargingPile.getNumber().toString());
+//		AddDeviceResp deviceResp = iotInterfaceClient.addDevice(addDevice).getData();
+//		if(null != deviceResp){
+//			int httpStatusCode = deviceResp.getHttpStatusCode();
+//			if(httpStatusCode == 201){
+//				chargingPile.setIotdDeviceId(deviceResp.getDeviceId());
+//			}
+//		}
+		this.save(chargingPile);
 		return AjaxResult.success();
 	}
 	
@@ -266,12 +266,12 @@
 		for (Integer id : ids) {
 			TChargingPile chargingPile = this.getById(id);
 			//调用华为Iot删除设备
-			if(StringUtils.isNotEmpty(chargingPile.getIotdDeviceId())){
-				DeleteDeviceResp deviceResp = iotInterfaceClient.deleteDevice(chargingPile.getIotdDeviceId()).getData();
-				if(null != deviceResp && deviceResp.getHttpStatusCode() == 0){
-					this.removeById(chargingPile);
-				}
-			}
+//			if(StringUtils.isNotEmpty(chargingPile.getIotdDeviceId())){
+//				DeleteDeviceResp deviceResp = iotInterfaceClient.deleteDevice(chargingPile.getIotdDeviceId()).getData();
+//				if(null != deviceResp && deviceResp.getHttpStatusCode() == 0){
+//				}
+//			}
+			this.removeById(chargingPile);
 		}
 		return AjaxResult.success();
 	}
@@ -482,13 +482,14 @@
 		Set<Integer> siteIds = new HashSet<>();
 		if(0 == query.getSiteId()){
 			SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData();
+			R<Integer> admin = sysUserClient.isAdmin(SecurityUtils.getUserId());
 			Integer roleType = sysUser.getRoleType();
 			Integer objectId = sysUser.getObjectId();
 			if(2 == roleType){
 				siteIds = partnerService.authSite(objectId, SiteMenu.SITE_LIST);
 			}else{
 				//非管理员需要根据角色和用户配置查询允许的站点数据
-				if(!SecurityUtils.isAdmin(SecurityUtils.getUserId())){
+				if(admin.getData()!=1){
 					List<Integer> data = userSiteClient.getSiteIds(sysUser.getUserId()).getData();
                     List<SysUserRoleVo> data2 = sysUserRoleClient.getRoleByUserId(sysUser.getUserId()).getData();
                     List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();
@@ -600,7 +601,7 @@
 				chargingGunService.updateById(chargingGun1);
 				
 				//桩处于正常,桩所属的枪都处于非正常,修改桩状态为异常
-				TChargingPile chargingPile = this.getById(chargingGun1.getChargingPileId());
+				TChargingPile chargingPile = this.getById(chargingGun.getChargingPileId());
 				List<TChargingGun> list1 = chargingGunService.list(new LambdaQueryWrapper<TChargingGun>().eq(TChargingGun::getChargingPileId, chargingPile.getId()).eq(TChargingGun::getDelFlag, 0));
 				int size = list1.stream().filter(s -> s.getStatus() == 1 || s.getStatus() == 7).collect(Collectors.toList()).size();
 				if(chargingPile.getStatus() == 1 && list1.size() == size){

--
Gitblit v1.7.1