siteDTOS = this.importExcel(HazardousChemicalsSiteDTO.class, file, null, null);
+ riskPointInfos = BeanUtil.copyToList(siteDTOS, RiskPointInfo.class);
+ break;
+ }
+
+ return riskPointInfos;
+ }
@ApiOperation(value = "新增接口")
@PostMapping(value = "/add")
diff --git a/casic-warning-analysis/src/main/java/com/casic/missiles/modular/device/dao/DeviceModelRelationMapper.java b/casic-warning-analysis/src/main/java/com/casic/missiles/modular/device/dao/DeviceModelRelationMapper.java
index a5f59b6..945b5d7 100644
--- a/casic-warning-analysis/src/main/java/com/casic/missiles/modular/device/dao/DeviceModelRelationMapper.java
+++ b/casic-warning-analysis/src/main/java/com/casic/missiles/modular/device/dao/DeviceModelRelationMapper.java
@@ -1,23 +1,27 @@
package com.casic.missiles.modular.device.dao;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.casic.missiles.modular.device.model.DeviceModelRelation;
import org.apache.ibatis.annotations.Param;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
import java.util.List;
+
/**
*
- * 设备模型关联 Mapper 接口
+ * 设备模型关联 Mapper 接口
*
*
* @author lwh
* @date 2024-11-20
*/
public interface DeviceModelRelationMapper extends BaseMapper {
-/**
-* 设备模型关联 分页检索
-*/
-List selectDeviceModelRelationPage( @Param("page") Page page,@Param("ew" ) QueryWrapper query);
+ /**
+ * 设备模型关联 分页检索
+ */
+ List selectDeviceModelRelationPage(@Param("page") Page page, @Param("ew") QueryWrapper query);
+
+ List selectDeviceModelRelationList(@Param("ew") QueryWrapper query);
}
diff --git a/casic-server-sync/pom.xml b/casic-server-sync/pom.xml
index 6b35fdc..7ea82c7 100644
--- a/casic-server-sync/pom.xml
+++ b/casic-server-sync/pom.xml
@@ -90,7 +90,7 @@
com.casic
casic-export-support
- ${extension.version}
+ ${export.version}
org.springframework.boot
diff --git a/casic-server-sync/src/main/java/com/casic/missiles/modular/device/controller/GateController.java b/casic-server-sync/src/main/java/com/casic/missiles/modular/device/controller/GateController.java
index 6acb71f..e664540 100644
--- a/casic-server-sync/src/main/java/com/casic/missiles/modular/device/controller/GateController.java
+++ b/casic-server-sync/src/main/java/com/casic/missiles/modular/device/controller/GateController.java
@@ -6,7 +6,6 @@
import com.casic.missiles.core.model.auth.AuthUser;
import com.casic.missiles.core.model.auth.CasicCustomToken;
import com.casic.missiles.core.shiro.ShiroKit;
-import com.casic.missiles.modular.device.service.ISyncService;
import com.casic.missiles.modular.domain.constants.PermissionConstants;
import com.casic.missiles.modular.interfaces.log.LogManager;
import com.casic.missiles.modular.interfaces.log.factory.LogTaskFactory;
@@ -19,11 +18,9 @@
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
-import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
-import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
@Api(tags = "应用网关")
@@ -45,6 +42,7 @@
public void resourceCode(HttpServletRequest request,String x, HttpServletResponse response) throws IOException {
String noPage = getBaseWeb();
try {
+
super.getSession().setAttribute(PermissionConstants.IS_APP, false);
String dnName = request.getHeader("dnname");
log.info("dnName:{}", dnName);
@@ -55,14 +53,15 @@
return;
}
-// String dn = new String(request.getHeader("dnname").getBytes("ISO8859-1"), "UTF-8");
-// String account = getValueByDn(dn, key1);
- String account = x;
+ String dn = new String(request.getHeader("dnname").getBytes("ISO8859-1"), "UTF-8");
+ String account = getValueByDn(dn, key1);
+ //String account = x;
//token自定义
CasicCustomToken token = new CasicCustomToken(account, "password");
token.setType(LoginType.NO_PASSWD);
token.setRememberMe(false);
Subject currentUser = ShiroKit.getSubject();
+
try {
currentUser.login(token);
} catch (Exception e) {
@@ -70,21 +69,22 @@
response.sendRedirect(noPage);
return;
}
+
AuthUser shiroUser = ShiroKit.getUser();
super.getSession().setAttribute("shiroUser", shiroUser);
super.getSession().setAttribute("username", shiroUser.getAccount());
super.getSession().setAttribute(PermissionConstants.SESSION_KEY, shiroUser.getId());
-
LogManager.me().executeLog(LogTaskFactory.loginLog(shiroUser.getId(), clientip, shiroUser.getRoleTips()));
-
ShiroKit.getSession().setAttribute("sessionFlag", true);
String sid = ShiroKit.getSession().getId().toString();
response.sendRedirect(webUrl+"?token=" + sid);
+
} catch (UnsupportedEncodingException e) {
log.error(e.getMessage());
response.sendRedirect(noPage);
}
}
+
private String getBaseWeb(){
String[] parts = webUrl.split("#", 2); // 限制分割后的数组长度为2,避免将#号之后的内容也分割
if (parts.length > 0) {
@@ -93,6 +93,7 @@
}
return "";
}
+
private String getValueByDn(String dn, String key) {
try {
int start = dn.indexOf(key) + 2;
@@ -105,4 +106,5 @@
return dn;
}
}
-}
+
+}
\ No newline at end of file
diff --git a/casic-server-sync/src/main/java/com/casic/missiles/modular/device/service/impl/SyncServiceImpl.java b/casic-server-sync/src/main/java/com/casic/missiles/modular/device/service/impl/SyncServiceImpl.java
index 3bef152..f7d7d17 100644
--- a/casic-server-sync/src/main/java/com/casic/missiles/modular/device/service/impl/SyncServiceImpl.java
+++ b/casic-server-sync/src/main/java/com/casic/missiles/modular/device/service/impl/SyncServiceImpl.java
@@ -45,26 +45,41 @@
this.jdbcTemplate = jdbcTemplate;
}
+ /**
+ * 保存组织管理信息
+ * @param orgDTOS 组织集合
+ */
@Transactional
public void saveDeptList(List orgDTOS) {
+
+ //检索全部同步组织信息
LambdaQueryWrapper query = new LambdaQueryWrapper<>();
query.isNotNull(Dept::getSyncId);
List oldDeptList = deptService.list(query);
Map deptMap = oldDeptList.stream().collect(Collectors.toMap(Dept::getSyncId, (dept -> dept)));
+
+ //迭代组织信息进行维护
for (UumOrganizationDispDTO orgDTO : orgDTOS) {
Dept dept = createDefaultDept();
dept.setFullName(orgDTO.getOrgName());
dept.setSimpleName(orgDTO.getOrgName());
dept.setSyncId(orgDTO.getInternalOrgCode());
+
+ //判断是否已同步该组织信息,已同步则进行数据更新
if (deptMap.containsKey(orgDTO.getInternalOrgCode())) {
dept.setId(deptMap.get(orgDTO.getInternalOrgCode()).getId());
dept.setPid(deptMap.get(orgDTO.getInternalOrgCode()).getPid());
}
+
+ //判断同步类型,
if ("2".equals(orgDTO.getSyncType())) {
+ //设置删除标志
dept.setDelFlag("1");
} else {
dept.setDelFlag("0");
}
+
+ //设置同步父ID设置
dept.setSyncPid(orgDTO.getInternalPOrgCode());
deptService.saveOrUpdate(dept);
}
@@ -97,14 +112,14 @@
Map userMap = users.stream().collect(Collectors.toMap(User::getSyncId, (user -> user)));
List delIds = new ArrayList<>();
for (UumOperatorDTO mdmPerson : uumOperatorDisps) {
- String account = mdmPerson.getHID();
+ String account = mdmPerson.getPID();
User user = null;
- if (userMap.containsKey(mdmPerson.getHID())) {
- user = userMap.get(mdmPerson.getHID());
+ if (userMap.containsKey(mdmPerson.getPID())) {
+ user = userMap.get(mdmPerson.getPID());
} else {
user = createDefaultUser();
}
- user.setSyncId(mdmPerson.getHID());
+ user.setSyncId(mdmPerson.getPID());
//转换为当前系统密级
SecretLevelEnum secretLevelEnum = SecretLevelEnum.valueOfCode(mdmPerson.getSecretLevel());
diff --git a/casic-server/pom.xml b/casic-server/pom.xml
index 4b90eb4..f9120ce 100644
--- a/casic-server/pom.xml
+++ b/casic-server/pom.xml
@@ -53,7 +53,7 @@
com.casic
casic-export-support
- ${extension.version}
+ ${export.version}
org.springframework.boot
diff --git a/casic-server/src/main/java/com/casic/missiles/modular/device/controller/UploadLogController.java b/casic-server/src/main/java/com/casic/missiles/modular/device/controller/UploadLogController.java
index 36bb267..96e082c 100644
--- a/casic-server/src/main/java/com/casic/missiles/modular/device/controller/UploadLogController.java
+++ b/casic-server/src/main/java/com/casic/missiles/modular/device/controller/UploadLogController.java
@@ -78,7 +78,12 @@
public void download(HttpServletResponse response,@PathVariable("path") String path,@PathVariable("url") String url) {
uploadLogService.download(response,path+ File.separator+url);
}
-
+ @BussinessLog(value = "告警图片访问")
+ @ApiOperation(value = "抓拍图片访问")
+ @GetMapping(value = "/alarm/{path}/{url}")
+ public void downloadAlarm(HttpServletResponse response,@PathVariable("path") String path,@PathVariable("url") String url) {
+ uploadLogService.downloadAlarm(response,path+ File.separator+url);
+ }
@ApiIgnore
@ApiOperation(value = "修改接口")
@PostMapping(value = "/update")
diff --git a/casic-server/src/main/java/com/casic/missiles/modular/device/dao/BusDeviceInfoMapper.java b/casic-server/src/main/java/com/casic/missiles/modular/device/dao/BusDeviceInfoMapper.java
index 4f683ef..9337787 100644
--- a/casic-server/src/main/java/com/casic/missiles/modular/device/dao/BusDeviceInfoMapper.java
+++ b/casic-server/src/main/java/com/casic/missiles/modular/device/dao/BusDeviceInfoMapper.java
@@ -4,6 +4,7 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.casic.missiles.modular.device.dto.DeviceBoundaryDTO;
import com.casic.missiles.modular.device.model.BusDeviceInfo;
import com.casic.missiles.modular.device.model.DeviceOnlineLog;
import org.apache.ibatis.annotations.Param;
@@ -25,4 +26,8 @@
List selectBusDeviceInfoPage(@Param("page") Page page, @Param("ew") QueryWrapper query);
List searchStatusByArea(@Param("ew") QueryWrapper query);
+
+ List selectRecognitionUrl(@Param("deviceId")Long deviceId);
+
+ List selectDeviceBoundaryList(@Param("deviceId")Long id);
}
diff --git a/casic-server/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusDeviceInfoMapper.xml b/casic-server/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusDeviceInfoMapper.xml
index 5e198d8..dce80c0 100644
--- a/casic-server/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusDeviceInfoMapper.xml
+++ b/casic-server/src/main/java/com/casic/missiles/modular/device/dao/mapping/BusDeviceInfoMapper.xml
@@ -119,7 +119,23 @@