diff --git a/pqs-common/common-influxdb/src/main/java/com/njcn/influxdb/mapper/InfluxDBResultMapperCn.java b/pqs-common/common-influxdb/src/main/java/com/njcn/influxdb/mapper/InfluxDBResultMapperCn.java index 05d364fa1..0b959fbc9 100644 --- a/pqs-common/common-influxdb/src/main/java/com/njcn/influxdb/mapper/InfluxDBResultMapperCn.java +++ b/pqs-common/common-influxdb/src/main/java/com/njcn/influxdb/mapper/InfluxDBResultMapperCn.java @@ -334,6 +334,17 @@ public class InfluxDBResultMapperCn { return true; } + if (LocalDateTime.class.isAssignableFrom(fieldType)) { + LocalDateTime localDateTime; + if (value instanceof String) { + localDateTime = LocalDateTime.ofInstant(Instant.from(DateTimeFormatter.ISO_DATE_TIME.parse(String.valueOf(value))), ZoneId.systemDefault()); + } else { + throw new InfluxDBMapperException("Unsupported type " + field.getClass() + " for field " + field.getName()); + } + field.set(object, localDateTime); + return true; + } + return false; } diff --git a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/param/DeviceInfoParam.java b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/param/DeviceInfoParam.java index 1bc52d1ac..f89e5b923 100644 --- a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/param/DeviceInfoParam.java +++ b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/param/DeviceInfoParam.java @@ -130,10 +130,12 @@ public class DeviceInfoParam implements Serializable { @ApiModelProperty("开始时间") @Pattern(regexp = PatternRegex.TIME_FORMAT, message = "时间格式错误") + @NotBlank(message = "起始时间不可为空") private String searchBeginTime; @ApiModelProperty("结束时间") @Pattern(regexp = PatternRegex.TIME_FORMAT, message = "时间格式错误") + @NotBlank(message = "结束时间不可为空") private String searchEndTime; @ApiModelProperty("时间范围标志 0.查询展示天 1.查询展示月") @@ -146,10 +148,12 @@ public class DeviceInfoParam implements Serializable { public static class CompareBusinessParam extends BusinessParam{ @ApiModelProperty("比较开始时间") + @NotBlank(message = "比较开始时间不可为空") @Pattern(regexp = PatternRegex.TIME_FORMAT, message = "时间格式错误") private String periodBeginTime; @ApiModelProperty("比较结束时间") + @NotBlank(message = "比较结束时间不可为空") @Pattern(regexp = PatternRegex.TIME_FORMAT, message = "时间格式错误") private String periodEndTime; diff --git a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/AreaLineInfoVO.java b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/AreaLineInfoVO.java index c4c858afe..03361b843 100644 --- a/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/AreaLineInfoVO.java +++ b/pqs-device/device-api/src/main/java/com/njcn/device/pojo/vo/AreaLineInfoVO.java @@ -1,7 +1,9 @@ package com.njcn.device.pojo.vo; import io.swagger.annotations.ApiModelProperty; +import lombok.AllArgsConstructor; import lombok.Data; +import lombok.NoArgsConstructor; import java.io.Serializable; import java.math.BigDecimal; @@ -12,6 +14,8 @@ import java.math.BigDecimal; * @date 2022/6/29 */ @Data +@AllArgsConstructor +@NoArgsConstructor public class AreaLineInfoVO implements Serializable { @ApiModelProperty(name = "lineId",value = "监测点id") diff --git a/pqs-device/device-boot/src/main/java/com/njcn/device/controller/TerminalTreeController.java b/pqs-device/device-boot/src/main/java/com/njcn/device/controller/TerminalTreeController.java index c7dd616d4..de6a6a8c1 100644 --- a/pqs-device/device-boot/src/main/java/com/njcn/device/controller/TerminalTreeController.java +++ b/pqs-device/device-boot/src/main/java/com/njcn/device/controller/TerminalTreeController.java @@ -68,7 +68,6 @@ public class TerminalTreeController extends BaseController { @OperateInfo(info = LogEnum.BUSINESS_MEDIUM) @PostMapping("getTerminalTreeForFive") @ApiImplicitParam(name = "deviceInfoParam", value = "台账查询参数", required = true) - @Validated public HttpResult> getTerminalTreeForFive(@RequestBody @Validated DeviceInfoParam deviceInfoParam){ String methodDescribe = getMethodDescribe("getTerminalTreeForFive"); List tree = terminalTreeService.getTerminalTreeForFive(deviceInfoParam); diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetailNew.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetailNew.java index 9ee1a9dcf..7f427ddc9 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetailNew.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/EventDetailNew.java @@ -6,6 +6,7 @@ import org.influxdb.annotation.Measurement; import org.springframework.format.annotation.DateTimeFormat; import java.time.Instant; +import java.time.LocalDateTime; /** * @author cdf @@ -22,7 +23,7 @@ public class EventDetailNew { @Column(name = "time") @DateTimeFormat(pattern = "yyyy-mm-dd") - private Instant timeId; + private LocalDateTime timeId; @Column(name = "event_describe") private String eventDescribe; diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/mapper/UserRoleMapper.java b/pqs-user/user-boot/src/main/java/com/njcn/user/mapper/UserRoleMapper.java index b25390f88..76a86a4df 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/mapper/UserRoleMapper.java +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/mapper/UserRoleMapper.java @@ -1,6 +1,7 @@ package com.njcn.user.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.user.pojo.po.Role; import com.njcn.user.pojo.po.UserRole; import org.apache.ibatis.annotations.Param; @@ -21,4 +22,14 @@ public interface UserRoleMapper extends BaseMapper { * @return */ List selectUserRole(@Param("ids")List ids); + + + /** + * 根据用户id获取角色详情 + * @param userId 用户id + * @author cdf + * @date 2022/9/8 + * @return 角色结果集 + */ + List getRoleListByUserId(String userId); } diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/mapper/mapping/UserRoleMapper.xml b/pqs-user/user-boot/src/main/java/com/njcn/user/mapper/mapping/UserRoleMapper.xml index cd6cf1ea7..bee0470d9 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/mapper/mapping/UserRoleMapper.xml +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/mapper/mapping/UserRoleMapper.xml @@ -10,4 +10,12 @@ #{item} + + + diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/service/IRoleService.java b/pqs-user/user-boot/src/main/java/com/njcn/user/service/IRoleService.java index f21a9d4f3..848addf42 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/service/IRoleService.java +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/service/IRoleService.java @@ -78,4 +78,6 @@ public interface IRoleService extends IService { boolean deleteRole(List ids); Boolean selectRelevance(List ids); + + } diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/service/IUserRoleService.java b/pqs-user/user-boot/src/main/java/com/njcn/user/service/IUserRoleService.java index 997d211a6..cbf39b586 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/service/IUserRoleService.java +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/service/IUserRoleService.java @@ -1,6 +1,7 @@ package com.njcn.user.service; import com.baomidou.mybatisplus.extension.service.IService; +import com.njcn.user.pojo.po.Role; import com.njcn.user.pojo.po.UserRole; import java.util.List; @@ -45,4 +46,14 @@ public interface IUserRoleService extends IService { * @date 2022/1/13 14:14 */ boolean updateUserRole(String id,List roles); + + + /** + * 根据用户id获取角色详情 + * @param userId 用户id + * @author cdf + * @date 2022/9/8 + * @return 角色结果集 + */ + List getRoleListByUserId(String userId); } diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/ComponentServiceImpl.java b/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/ComponentServiceImpl.java index a97cbf977..a6a4c94ce 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/ComponentServiceImpl.java +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/ComponentServiceImpl.java @@ -11,10 +11,12 @@ import com.njcn.user.pojo.constant.FunctionState; import com.njcn.user.pojo.dto.ComponentDTO; import com.njcn.user.pojo.param.ComponentParam; import com.njcn.user.pojo.po.Component; +import com.njcn.user.pojo.po.Role; import com.njcn.user.pojo.vo.ComponentVO; import com.njcn.user.service.IComponentService; import com.njcn.user.service.IRoleComponentService; import com.njcn.user.service.IRoleService; +import com.njcn.user.service.IUserRoleService; import com.njcn.web.utils.RequestUtil; import lombok.AllArgsConstructor; import org.springframework.stereotype.Service; @@ -26,7 +28,7 @@ import java.util.stream.Stream; /** *

- * 服务实现类 + * 服务实现类 *

* * @author hongawen @@ -40,25 +42,27 @@ public class ComponentServiceImpl extends ServiceImpl getComponentTree() { List list = new ArrayList<>(); List componentList = componentMapper.getAllComponent(); - componentList.forEach(item->{ + componentList.forEach(item -> { ComponentVO componentVO = new ComponentVO(); BeanUtil.copyProperties(item, componentVO); componentVO.setFunctionGroup(Arrays.stream(item.getFunctionGroup().split(",")).map(s -> Integer.valueOf(s.trim())).collect(Collectors.toList())); list.add(componentVO); }); return list.stream() - .filter(fun -> Objects.equals(ComponentState.FATHER_PID,fun.getPid())) + .filter(fun -> Objects.equals(ComponentState.FATHER_PID, fun.getPid())) .peek(funS -> funS.setChildren(getChildCategoryList(funS, list))) .collect(Collectors.toList()); } @@ -102,31 +106,35 @@ public class ComponentServiceImpl extends ServiceImpl getUserComponentTree() { List result = new ArrayList<>(); List componentVOList = new ArrayList<>(); - List roleList = roleService.getIdByUserId(RequestUtil.getUserIndex()); - if (!CollectionUtils.isEmpty(roleList)){ - List componentList = roleComponentService.selectRoleComponent(roleList); - if (!CollectionUtils.isEmpty(componentList)){ - List list = componentMapper.getComponentByList(componentList); - list.forEach(item->{ - ComponentVO componentVO = new ComponentVO(); - BeanUtil.copyProperties(item, componentVO); - componentVO.setFunctionGroup(Arrays.stream(item.getFunctionGroup().split(",")).map(s -> Integer.valueOf(s.trim())).collect(Collectors.toList())); - componentVOList.add(componentVO); - }); - result = componentVOList.stream() - .filter(fun -> Objects.equals(ComponentState.FATHER_PID,fun.getPid())) - .peek(funS -> funS.setChildren(getChildCategoryList(funS, componentVOList))) - .collect(Collectors.toList()); + List roleList = iUserRoleService.getRoleListByUserId(RequestUtil.getUserIndex()); + if (!CollectionUtils.isEmpty(roleList)) { + List list; + if (roleList.stream().anyMatch(item -> "root".equals(item.getCode()))) { + list = componentMapper.getAllComponent(); + } else { + List componentList = roleComponentService.selectRoleComponent(roleList.stream().map(Role::getId).collect(Collectors.toList())); + list = componentMapper.getComponentByList(componentList); } + + list.forEach(item -> { + ComponentVO componentVO = new ComponentVO(); + BeanUtil.copyProperties(item, componentVO); + componentVO.setFunctionGroup(Arrays.stream(item.getFunctionGroup().split(",")).map(s -> Integer.valueOf(s.trim())).collect(Collectors.toList())); + componentVOList.add(componentVO); + }); + result = componentVOList.stream() + .filter(fun -> Objects.equals(ComponentState.FATHER_PID, fun.getPid())) + .peek(funS -> funS.setChildren(getChildCategoryList(funS, componentVOList))) + .collect(Collectors.toList()); } return result; } /** - * 递归组装组件表 + * 递归组装组件表 */ private List getChildCategoryList(ComponentVO currMenu, List categories) { - return categories.stream().filter(o -> Objects.equals(o.getPid(),currMenu.getId())) + return categories.stream().filter(o -> Objects.equals(o.getPid(), currMenu.getId())) .peek(o -> o.setChildren(getChildCategoryList(o, categories))) .collect(Collectors.toList()); } diff --git a/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/UserRoleServiceImpl.java b/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/UserRoleServiceImpl.java index ebdd71e10..797aee610 100644 --- a/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/UserRoleServiceImpl.java +++ b/pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/UserRoleServiceImpl.java @@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.njcn.user.mapper.UserMapper; import com.njcn.user.mapper.UserRoleMapper; +import com.njcn.user.pojo.po.Role; import com.njcn.user.pojo.po.UserRole; import com.njcn.user.service.IUserRoleService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -94,4 +95,9 @@ public class UserRoleServiceImpl extends ServiceImpl i // } return true; } + + @Override + public List getRoleListByUserId(String userId) { + return this.baseMapper.getRoleListByUserId(userId); + } }