diff --git a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsDevModelQueryParm.java b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsDevModelQueryParm.java index a193230..8390037 100644 --- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsDevModelQueryParm.java +++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsDevModelQueryParm.java @@ -47,7 +47,8 @@ public class CsDevModelQueryParm { @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") private String versionEndDate; - + @ApiModelProperty(value = "装置型号") + private String devType; diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDevModelMapper.xml b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDevModelMapper.xml index 252c599..fcff586 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDevModelMapper.xml +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDevModelMapper.xml @@ -33,13 +33,10 @@ - AND a.dev_type_name LIKE concat('%',#{csDevModelQueryParm.devName},'%') + AND a.dev_type_name = #{csDevModelQueryParm.devName} - - - - AND a.name = #{csDevModelQueryParm.name} + AND a.name LIKE concat('%',#{csDevModelQueryParm.name},'%') order by a.version_date desc diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevModelServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevModelServiceImpl.java index 82a38c3..d765531 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevModelServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDevModelServiceImpl.java @@ -1,37 +1,32 @@ package com.njcn.csdevice.service.impl; -import cn.hutool.core.collection.CollUtil; -import com.alibaba.nacos.shaded.com.google.gson.Gson; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.common.pojo.exception.BusinessException; import com.njcn.csdevice.mapper.CsDevModelMapper; -import com.njcn.csdevice.pojo.dto.CsDevModelDto; import com.njcn.csdevice.pojo.param.CsDevModelAddParm; import com.njcn.csdevice.pojo.param.CsDevModelAuditParm; import com.njcn.csdevice.pojo.param.CsDevModelQueryListParm; import com.njcn.csdevice.pojo.param.CsDevModelQueryParm; -import com.njcn.csdevice.pojo.po.CsDataArray; -import com.njcn.csdevice.pojo.po.CsDataSet; import com.njcn.csdevice.pojo.po.CsDevModelPO; import com.njcn.csdevice.pojo.vo.CsDevModelPageVO; import com.njcn.csdevice.service.CsDevModelService; import com.njcn.csdevice.service.ICsDataArrayService; import com.njcn.csdevice.service.ICsDataSetService; -import com.njcn.redis.pojo.enums.AppRedisKey; import com.njcn.redis.utils.RedisUtil; +import com.njcn.system.api.DictTreeFeignClient; +import com.njcn.system.pojo.po.SysDicTreePO; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.sql.Date; -import java.util.ArrayList; -import java.util.List; import java.util.Objects; -import java.util.stream.Collectors; /** * @@ -50,6 +45,7 @@ public class CsDevModelServiceImpl extends ServiceImpl queryPage(CsDevModelQueryParm csDevModelQueryParm) { Page returnpage = new Page<> (csDevModelQueryParm.getPageNum ( ), csDevModelQueryParm.getPageSize ( )); - + if (Objects.nonNull (csDevModelQueryParm.getDevType()) && StringUtils.isNotBlank(csDevModelQueryParm.getDevType())) { + SysDicTreePO po = dictTreeFeignClient.queryById(csDevModelQueryParm.getDevType()).getData(); + if (Objects.isNull (po)) { + throw new BusinessException("装置型号字典缺失"); + } else { + csDevModelQueryParm.setDevName(po.getName()); + } + } returnpage = this.getBaseMapper ().getPage(returnpage,csDevModelQueryParm); return returnpage; }