package com.iailab.module.data.point.controller.admin; import com.fasterxml.jackson.annotation.JsonFormat; import com.iailab.framework.apilog.core.annotation.ApiAccessLog; import com.iailab.framework.common.pojo.CommonResult; import com.iailab.framework.common.pojo.PageParam; import com.iailab.framework.common.pojo.PageResult; import com.iailab.framework.common.util.object.ConvertUtils; import com.iailab.framework.excel.core.util.ExcelUtils; import com.iailab.module.data.api.dto.ApiPointValueQueryDTO; import com.iailab.module.data.channel.common.service.ChannelSourceService; import com.iailab.module.data.common.enums.DataSourceType; import com.iailab.module.data.influxdb.service.InfluxDBService; import com.iailab.module.data.point.dto.DaPointDTO; import com.iailab.module.data.point.entity.DaPointEntity; import com.iailab.module.data.point.service.DaPointService; import com.iailab.module.data.point.vo.*; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.Parameters; import io.swagger.v3.oas.annotations.tags.Tag; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.transaction.annotation.Transactional; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import javax.validation.Valid; import java.io.IOException; import java.math.BigDecimal; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; import static com.iailab.framework.common.pojo.CommonResult.success; import static com.iailab.framework.apilog.core.enums.OperateTypeEnum.EXPORT; /** * @author lirm * @Description * @createTime 2024å¹´09月2æ—¥ */ @Tag(name = "æ•°æ®é‡‡é›†ï¼Œæµ‹ç‚¹") @RestController @RequestMapping("/data/da/point") @Validated public class DaPointController { @Resource private DaPointService daPointService; @Resource private InfluxDBService influxDBService; @PreAuthorize("@ss.hasPermission('data:point:query')") @GetMapping("page") public CommonResult<PageResult<DaPointDTO>> page(@Valid DaPointPageReqVO reqVO) { PageResult<DaPointDTO> page = daPointService.queryPage(reqVO); return success(page); } @PreAuthorize("@ss.hasPermission('data:point:query')") @GetMapping("/list") @Operation(summary = "列表") public CommonResult<List<DaPointDTO>> list(@Valid @RequestParam Map<String, Object> params) { List<DaPointDTO> list = daPointService.list(params); return success(list); } @PreAuthorize("@ss.hasPermission('data:point:query')") @GetMapping("/info/{id}") public CommonResult<DaPointDTO> info(@PathVariable("id") String id) { DaPointDTO info = daPointService.info(id); return success(info); } @PreAuthorize("@ss.hasPermission('data:point:create')") @PostMapping("create") public CommonResult<Boolean> create(@RequestBody DaPointDTO daPointDTO) { String id = UUID.randomUUID().toString(); daPointDTO.setId(id); daPointService.add(daPointDTO); return success(true); } @PreAuthorize("@ss.hasPermission('data:point:update')") @PutMapping("/update") public CommonResult<Boolean> update(@RequestBody DaPointDTO daPointDTO) { daPointService.update(daPointDTO); return success(true); } @PreAuthorize("@ss.hasPermission('data:point:delete')") @DeleteMapping("/delete") public CommonResult<Boolean> delete(String id) { daPointService.delete(new String[]{id}); return success(true); } @PreAuthorize("@ss.hasPermission('data:point:query')") @GetMapping("pointNo") public CommonResult<List<DaPointDTO>> getPoint(@RequestParam Map<String, Object> params) { List<DaPointDTO> list = daPointService.list(params); return new CommonResult<List<DaPointDTO>>().setData(list); } @PreAuthorize("@ss.hasPermission('data:point:update')") @PutMapping("/enable") @Operation(summary = "å¯ç”¨") @Transactional public CommonResult<Boolean> enable(@RequestBody String[] ids) { daPointService.enableByIds(ids); return success(true); } @PreAuthorize("@ss.hasPermission('data:point:update')") @PutMapping("/disable") @Operation(summary = "ç¦ç”¨") @Transactional public CommonResult<Boolean> disable(@RequestBody String[] ids) { daPointService.disableByIds(ids); return success(true); } @GetMapping("/export") @Operation(summary = "导出测点列表") @PreAuthorize("@ss.hasPermission('data:point:export')") @ApiAccessLog(operateType = EXPORT) public void exportPointList(@Validated DaPointPageReqVO exportReqVO, HttpServletResponse response) throws IOException { exportReqVO.setPageSize(PageParam.PAGE_SIZE_NONE); List<DaPointExcelVO> dataList = new ArrayList<>(); List<DaPointDTO> measurePointList = daPointService.getMeasurePoint(exportReqVO); dataList.addAll(ConvertUtils.sourceToTarget(measurePointList, DaPointExcelVO.class)); List<DaPointDTO> mathPointList = daPointService.getMathPoint(exportReqVO); dataList.addAll(ConvertUtils.sourceToTarget(mathPointList, DaPointExcelVO.class)); List<DaPointDTO> constantPointList = daPointService.getConstantPoint(exportReqVO); dataList.addAll(ConvertUtils.sourceToTarget(constantPointList, DaPointExcelVO.class)); ExcelUtils.write(response, "测点列表.xls", "测点列表", DaPointExcelVO.class, dataList); } @GetMapping("/exportValue") @Operation(summary = "导出测点数æ®") @PreAuthorize("@ss.hasPermission('data:point:export')") @ApiAccessLog(operateType = EXPORT) public void exportPointValue(@RequestParam("pointNo") String pointNo, @RequestParam("start") String start, @RequestParam("end") String end, HttpServletResponse response) throws IOException { SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); ApiPointValueQueryDTO queryDto = new ApiPointValueQueryDTO(); List<String> pointNos = new ArrayList<>(); pointNos.add(pointNo); queryDto.setPointNos(pointNos); try { if (start == null) { queryDto.setStart(new Date()); } else { queryDto.setStart(formatter.parse(start)); } if (end == null) { queryDto.setEnd(new Date()); } else { queryDto.setStart(formatter.parse(end)); } } catch (ParseException e) { e.printStackTrace(); } List<PointValueExportVO> dointValueExportlist = influxDBService.exportPointValue(queryDto); ExcelUtils.write(response, "测点数æ®.xls", "æ•°æ®", PointValueExportVO.class, dointValueExportlist); } @GetMapping("/get-import-template") @Operation(summary = "获得导入测点模æ¿") public void importTemplate(HttpServletResponse response) throws IOException { // 手动创建导出 demo List<PointImportExcelVO> list = Arrays.asList( PointImportExcelVO.builder().pointName("测点1").pointType("MEASURE").dataType("float").valueType("SIMULATE") .storeType(null).unit("t(éžå¿…填)").unittransfactor(new BigDecimal(1)).defaultValue(new BigDecimal(0)).maxValue(new BigDecimal(10000000.000000)).minValue(new BigDecimal(0)) .minfreqid("1min").remark("备注(éžå¿…填)").sourceType(DataSourceType.HTTP.getCode()) .sourceName("").tagNo("SARD1200G00102RC001") .build() ); // 输出 ExcelUtils.write(response, "测点导入模æ¿.xlsx", "测点列表", PointImportExcelVO.class, list); } @PostMapping("/import") @Operation(summary = "导入测点") @Parameters({ @Parameter(name = "file", description = "Excel 文件", required = true), @Parameter(name = "updateSupport", description = "是å¦æ”¯æŒæ›´æ–°ï¼Œé»˜è®¤ä¸º false", example = "true") }) // @PreAuthorize("@ss.hasPermission('data:point:import')") public CommonResult<PointImportRespVO> importExcel(@RequestParam("file") MultipartFile file, @RequestParam(value = "updateSupport", required = false, defaultValue = "false") Boolean updateSupport) throws Exception { List<PointImportExcelVO> list = ExcelUtils.read(file, PointImportExcelVO.class); return success(daPointService.importPointList(list, updateSupport)); } }