diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalBaseServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalBaseServiceImpl.java index 5885fd8f1..ae6e436fa 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalBaseServiceImpl.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalBaseServiceImpl.java @@ -53,6 +53,9 @@ import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; +import java.io.FileNotFoundException; +import java.io.FileOutputStream; +import java.io.IOException; import java.time.LocalDate; import java.time.LocalDateTime; import java.util.*; @@ -1898,7 +1901,7 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple if (Objects.isNull(temp)) { temp = assembleLine(substationName, LineBaseEnum.SUB_LEVEL.getCode(), pids.get(LineBaseEnum.GD_LEVEL.getCode()), pids); //处理电压等级字典表 - DictData substationScale = dicDataFeignClient.getDicDataByName(terminalBaseExcel.getSubStationScale()).getData(); + DictData substationScale = dicDataFeignClient.getDicDataByNameAndType(terminalBaseExcel.getSubStationScale(),DicDataTypeEnum.DEV_VOLTAGE_STAND.getName()).getData(); if (Objects.isNull(substationScale)) { terminalBaseExcelMsgs.add(assembleBaseMsg(terminalBaseExcel, "字典电压等级不存在")); continue; @@ -2001,7 +2004,7 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple } } //处理电压等级字典表 - DictData subvScale = dicDataFeignClient.getDicDataByName(terminalBaseExcel.getSubvScale()).getData(); + DictData subvScale = dicDataFeignClient.getDicDataByNameAndType(terminalBaseExcel.getSubvScale(),DicDataTypeEnum.DEV_VOLTAGE_STAND.getName()).getData(); if (Objects.isNull(subvScale)) { terminalBaseExcelMsgs.add(assembleBaseMsg(terminalBaseExcel, "字典电压等级:" + terminalBaseExcel.getSubStationScale() + "不存在")); continue; diff --git a/pqs-system/system-api/src/main/java/com/njcn/system/api/DicDataFeignClient.java b/pqs-system/system-api/src/main/java/com/njcn/system/api/DicDataFeignClient.java index 5675e9773..21c42f76c 100644 --- a/pqs-system/system-api/src/main/java/com/njcn/system/api/DicDataFeignClient.java +++ b/pqs-system/system-api/src/main/java/com/njcn/system/api/DicDataFeignClient.java @@ -31,6 +31,9 @@ public interface DicDataFeignClient { @GetMapping("/getDicDataByName") HttpResult getDicDataByName(@RequestParam("dicName") String dicName); + @GetMapping("/getDicDataByNameAndType") + HttpResult getDicDataByNameAndType(@RequestParam("dicName") String dicName ,@RequestParam("typeName") String typeName); + @GetMapping("/getDicDataByCode") HttpResult getDicDataByCode(@RequestParam("code") String code); diff --git a/pqs-system/system-api/src/main/java/com/njcn/system/api/fallback/DicDataFeignClientFallbackFactory.java b/pqs-system/system-api/src/main/java/com/njcn/system/api/fallback/DicDataFeignClientFallbackFactory.java index c1e75389e..a3a2a459c 100644 --- a/pqs-system/system-api/src/main/java/com/njcn/system/api/fallback/DicDataFeignClientFallbackFactory.java +++ b/pqs-system/system-api/src/main/java/com/njcn/system/api/fallback/DicDataFeignClientFallbackFactory.java @@ -55,6 +55,12 @@ public class DicDataFeignClientFallbackFactory implements FallbackFactory getDicDataByNameAndType(String dicName, String typeName) { + log.error("{}异常,降级处理,异常为:{}","根据字典名称获取字典数据",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } + @Override public HttpResult getDicDataByCode(String code) { log.error("{}异常,降级处理,异常为:{}","根据字典code获取字典数据",cause.toString()); diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/controller/DictDataController.java b/pqs-system/system-boot/src/main/java/com/njcn/system/controller/DictDataController.java index fd9e4b0da..50a1df8bc 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/controller/DictDataController.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/controller/DictDataController.java @@ -17,6 +17,7 @@ import com.njcn.system.pojo.vo.DictDataVO; import com.njcn.system.service.IDictDataService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; @@ -162,6 +163,19 @@ public class DictDataController extends BaseController { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe); } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @GetMapping("/getDicDataByNameAndType") + @ApiOperation("根据字典名称查询字典数据") + @ApiImplicitParams({ + @ApiImplicitParam(name = "dicName", value = "查询参数", required = true), + @ApiImplicitParam(name = "typeName", value = "查询参数", required = true) + }) + public HttpResult getDicDataByNameAndType(@RequestParam("dicName") String dicName,@RequestParam("typeName") String typeName) { + String methodDescribe = getMethodDescribe("getDicDataByNameAndType"); + DictData result = dictDataService.getDicDataByNameAndType(dicName,typeName); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe); + } + @OperateInfo(info = LogEnum.BUSINESS_COMMON) @GetMapping("/getDicDataByCode") @ApiOperation("根据字典code查询字典数据") diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/DictDataMapper.java b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/DictDataMapper.java index 83ef3743e..cab143d49 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/DictDataMapper.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/DictDataMapper.java @@ -12,7 +12,7 @@ import java.util.List; /** *

- * Mapper 接口 + * Mapper 接口 *

* * @author hongawen @@ -22,21 +22,25 @@ public interface DictDataMapper extends BaseMapper { /** * 分页查询字典数据 - * @param page 分页数据 + * + * @param page 分页数据 * @param queryWrapper 查询条件 * @return 字典数据 */ - Page page(@Param("page")Page page, @Param("ew")QueryWrapper queryWrapper); + Page page(@Param("page") Page page, @Param("ew") QueryWrapper queryWrapper); /** * @param dictypeName 字典类型名称 * @return 根据字典类型名称查询字典数据 */ - List getDicDataByTypeName(@Param("dictypeName")String dictypeName); + List getDicDataByTypeName(@Param("dictypeName") String dictypeName); - DictData getDicDataByName(@Param("dicName")String dicName); + DictData getDicDataByName(@Param("dicName") String dicName); + + DictData getDicDataByNameAndType(@Param("dicName") String dicName, @Param("typeName") String typeName); + + DictData getDicDataByCode(@Param("code") String code); - DictData getDicDataByCode(@Param("code")String code); /** * 根据字典类型名称&数据名称获取字典数据 * @@ -44,12 +48,12 @@ public interface DictDataMapper extends BaseMapper { * @param dicDataName 字典数据名称 * @return 字典数据 */ - DictData getDicDataByNameAndTypeName(@Param("dicTypeName")String dicTypeName, @Param("dicDataName")String dicDataName); + DictData getDicDataByNameAndTypeName(@Param("dicTypeName") String dicTypeName, @Param("dicDataName") String dicDataName); /** * @param dictTypeCode 字典类型名称 * @return 根据字典类型名称查询字典数据 */ - List getDicDataByTypeCode(@Param("dictTypeCode")String dictTypeCode); + List getDicDataByTypeCode(@Param("dictTypeCode") String dictTypeCode); } diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/DictDataMapper.xml b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/DictDataMapper.xml index 050842b6c..392cb0710 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/DictDataMapper.xml +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/DictDataMapper.xml @@ -32,6 +32,16 @@ order by sys_dict_data.sort + +