Commit 1142b3c7 authored by maoying's avatar maoying

修改数据推送导致预案无法启动

parent f448b4dd
...@@ -22,5 +22,5 @@ public interface ImpEquipMapper extends BaseMapper { ...@@ -22,5 +22,5 @@ public interface ImpEquipMapper extends BaseMapper {
Long reservePageCount(); Long reservePageCount();
List<EquipmentDTO> reservePage(long start, int length); List<EquipmentDTO> reservePage(@Param("start") long start,@Param("length") int length);
} }
...@@ -159,7 +159,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService { ...@@ -159,7 +159,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
String nameKey = equipmentSpecificIndex.getNameKey(); String nameKey = equipmentSpecificIndex.getNameKey();
EquipmentSpecificForRiskVo equipmentSpecific = equipmentSpecificMapper.getOneById(eqSpecId); EquipmentSpecificForRiskVo equipmentSpecific = equipmentSpecificMapper.getOneById(eqSpecId);
// 三维屏指标状态推送 // 三维屏指标状态推送
if (nameKeys.contains(nameKey)) { if (nameKey !=null && nameKeys.contains(nameKey)) {
if (equipmentSpecific != null) { if (equipmentSpecific != null) {
equipmentSpecificIndex.setId(equipmentSpecific.getId()); equipmentSpecificIndex.setId(equipmentSpecific.getId());
equipmentSpecificIndex.setName(equipmentSpecific.getName()); equipmentSpecificIndex.setName(equipmentSpecific.getName());
......
...@@ -83,38 +83,39 @@ public class PermissionAspect { ...@@ -83,38 +83,39 @@ public class PermissionAspect {
try { try {
feignClientResult = Privilege.agencyUserClient.getme(); feignClientResult = Privilege.agencyUserClient.getme();
userModel = (AgencyUserModel) feignClientResult.getResult(); userModel = (AgencyUserModel) feignClientResult.getResult();
String userId = null;
} catch (InnerInvokException e) { ReginParams regionParam = new ReginParams();
e.printStackTrace(); if(userModel != null){
} userId = userModel.getUserId();
String userId = null; ReginParams reginParams = JSON.parseObject(redisTemplate.opsForValue().get(buildKey(userModel.getUserId(), token)), ReginParams.class);
ReginParams regionParam = new ReginParams(); if(reginParams == null && userModel.getCompanys().size() > 0){
if(userModel != null){ CompanyModel companyModel = userModel.getCompanys().get(0);
userId = userModel.getUserId(); List<DepartmentModel> deptList = remoteSecurityService.getDepartmentTreeByCompanyId(token, product, appKey, companyModel.getSequenceNbr().toString());
ReginParams reginParams = JSON.parseObject(redisTemplate.opsForValue().get(buildKey(userModel.getUserId(), token)), ReginParams.class); if(deptList.size() > 0){
if(reginParams == null && userModel.getCompanys().size() > 0){ CompanyBo companyBo = convertCompanyModelToBo(companyModel);
CompanyModel companyModel = userModel.getCompanys().get(0); DepartmentBo departmentBo = convertDepartmentModelToBo(deptList.get(0));
List<DepartmentModel> deptList = remoteSecurityService.getDepartmentTreeByCompanyId(token, product, appKey, companyModel.getSequenceNbr().toString()); regionParam.setCompany(companyBo);
if(deptList.size() > 0){ regionParam.setDepartment(departmentBo);
CompanyBo companyBo = convertCompanyModelToBo(companyModel);
DepartmentBo departmentBo = convertDepartmentModelToBo(deptList.get(0));
regionParam.setCompany(companyBo);
regionParam.setDepartment(departmentBo);
}
Map<Long, List<RoleModel>> orgRoles = userModel.getOrgRoles();
List<RoleModel> roleModels = null;
if(!ObjectUtils.isEmpty(orgRoles)) {
for (Map.Entry<Long, List<RoleModel>> entry : orgRoles.entrySet()) {
roleModels = entry.getValue();
break;
} }
Map<Long, List<RoleModel>> orgRoles = userModel.getOrgRoles();
List<RoleModel> roleModels = null;
if(!ObjectUtils.isEmpty(orgRoles)) {
for (Map.Entry<Long, List<RoleModel>> entry : orgRoles.entrySet()) {
roleModels = entry.getValue();
break;
}
}
if(!ObjectUtils.isEmpty(roleModels)){
regionParam.setRole(convertRoleModelToBo(roleModels.get(0)));
}
redisTemplate.opsForValue().set(buildKey(userId, token), JSONObject.toJSONString(regionParam));
} }
if(!ObjectUtils.isEmpty(roleModels)){
regionParam.setRole(convertRoleModelToBo(roleModels.get(0)));
}
redisTemplate.opsForValue().set(buildKey(userId, token), JSONObject.toJSONString(regionParam));
} }
} catch (InnerInvokException e) {
logger.error(e.getMessage());
e.printStackTrace();
} }
} }
private DepartmentBo convertDepartmentModelToBo(DepartmentModel departmentModel){ private DepartmentBo convertDepartmentModelToBo(DepartmentModel departmentModel){
......
...@@ -62,7 +62,7 @@ ...@@ -62,7 +62,7 @@
</trim> </trim>
</select> </select>
<select id="reservePage" resultMap="resultMap"> <select id="reservePage" resultType="com.yeejoin.amos.fas.dao.dto.EquipmentDTO">
SELECT SELECT
a.id, a.id,
a.`name`, a.`name`,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment