| package com.doumee.cloud.admin; | 
|   | 
| import com.doumee.api.BaseController; | 
| import com.doumee.config.annotation.CloudRequiredPermission; | 
| import com.doumee.core.annotation.excel.ExcelExporter; | 
| import com.doumee.core.annotation.pr.PreventRepeat; | 
| import com.doumee.core.model.ApiResponse; | 
| import com.doumee.core.model.PageData; | 
| import com.doumee.core.model.PageWrap; | 
| import com.doumee.core.utils.Constants; | 
| import com.doumee.dao.business.model.PlatformWaterGas; | 
| import com.doumee.dao.business.vo.PlatformWaterGasForExcelVO; | 
| import com.doumee.service.business.PlatformWaterGasService; | 
| import io.swagger.annotations.*; | 
| import org.springframework.beans.BeanUtils; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.web.bind.annotation.*; | 
| import org.springframework.web.multipart.MultipartFile; | 
|   | 
| import javax.servlet.http.HttpServletResponse; | 
| import java.io.File; | 
| import java.util.ArrayList; | 
| import java.util.List; | 
| import java.util.Objects; | 
|   | 
| /** | 
|  * @author 江蹄蹄 | 
|  * @date 2024/08/26 16:22 | 
|  */ | 
| @Api(tags = "月台_用水用气信息记录表") | 
| @RestController | 
| @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/business/platformWaterGas") | 
| public class PlatformWaterGasCloudController extends BaseController { | 
|   | 
|     @Autowired | 
|     private PlatformWaterGasService platformWaterGasService; | 
|   | 
|     @PreventRepeat | 
|     @ApiOperation("新建") | 
|     @PostMapping("/create") | 
|     @CloudRequiredPermission("business:platformwatergas:create") | 
|     public ApiResponse create(@RequestBody PlatformWaterGas platformWaterGas,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) { | 
|         platformWaterGas.setLoginUserInfo(getLoginUser(token)); | 
|         return ApiResponse.success(platformWaterGasService.create(platformWaterGas)); | 
|     } | 
|   | 
|     @ApiOperation("根据ID删除") | 
|     @GetMapping("/delete/{id}") | 
|     @CloudRequiredPermission("business:platformwatergas:delete") | 
|     public ApiResponse deleteById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) { | 
|         platformWaterGasService.deleteById(id,getLoginUser(token)); | 
|         return ApiResponse.success(null); | 
|     } | 
|   | 
|     @ApiOperation("批量删除") | 
|     @GetMapping("/delete/batch") | 
|     @CloudRequiredPermission("business:platformwatergas:delete") | 
|     public ApiResponse deleteByIdInBatch(@RequestParam String ids,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) { | 
|         String [] idArray = ids.split(","); | 
|         List<Integer> idList = new ArrayList<>(); | 
|         for (String id : idArray) { | 
|             idList.add(Integer.valueOf(id)); | 
|         } | 
|         platformWaterGasService.deleteByIdInBatch(idList,getLoginUser(token)); | 
|         return ApiResponse.success(null); | 
|     } | 
|   | 
|     @ApiOperation("根据ID修改") | 
|     @PostMapping("/updateById") | 
|     @CloudRequiredPermission("business:platformwatergas:update") | 
|     public ApiResponse updateById(@RequestBody PlatformWaterGas platformWaterGas,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) { | 
|         platformWaterGas.setLoginUserInfo(getLoginUser(token)); | 
|         platformWaterGasService.updateById(platformWaterGas); | 
|         return ApiResponse.success(null); | 
|     } | 
|   | 
|     @ApiOperation("分页查询") | 
|     @PostMapping("/page") | 
|     @CloudRequiredPermission("business:platformwatergas:query") | 
|     public ApiResponse<PageData<PlatformWaterGas>> findPage (@RequestBody PageWrap<PlatformWaterGas> pageWrap,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) { | 
|         return ApiResponse.success(platformWaterGasService.findPage(pageWrap)); | 
|     } | 
|   | 
|     @ApiOperation("导出Excel") | 
|     @PostMapping("/exportExcel") | 
|     @CloudRequiredPermission("business:platformwatergas:exportExcel") | 
|     public void exportExcel (@RequestBody PageWrap<PlatformWaterGas> pageWrap, HttpServletResponse response,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) { | 
|         List<PlatformWaterGas>  waterGasPageData = platformWaterGasService.findPage(pageWrap).getRecords(); | 
|         if(Objects.nonNull(pageWrap.getModel()) | 
|         && Objects.nonNull(pageWrap.getModel().getType()) && !Constants.equalsInteger(pageWrap.getModel().getType(),Constants.TWO)){ | 
|             List<PlatformWaterGasForExcelVO> pageData = new ArrayList<>(); | 
|             for (PlatformWaterGas platformWaterGas:waterGasPageData) { | 
|                 PlatformWaterGasForExcelVO platformWaterGasForExcelVO = new PlatformWaterGasForExcelVO(); | 
|                 BeanUtils.copyProperties(platformWaterGas,platformWaterGasForExcelVO); | 
|                 pageData.add(platformWaterGasForExcelVO); | 
|             } | 
|             ExcelExporter.build(PlatformWaterGasForExcelVO.class).export(pageData, Constants.equalsInteger(pageWrap.getModel().getType(),Constants.ZERO)?"月台_用水信息记录表":"月台_用气信息记录表", response); | 
|         }else{ | 
|             ExcelExporter.build(PlatformWaterGas.class).export(waterGasPageData, "月台_油耗信息记录表", response); | 
|         } | 
|     } | 
|   | 
|   | 
|   | 
|     @ApiOperation(value = "油耗信息导入") | 
|     @PostMapping("/importExcel") | 
|     @ApiImplicitParams({ | 
|             @ApiImplicitParam(name = "file", value = "file", required = true, paramType = "query", dataType = "file", dataTypeClass = File.class), | 
|     }) | 
|     @CloudRequiredPermission("business:platformwatergas:exportExcel") | 
|     public ApiResponse<String> importExcel (@ApiParam(value = "file") MultipartFile file, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { | 
|         return ApiResponse.success(platformWaterGasService.importBatch(file,this.getLoginUser(token))); | 
|     } | 
|   | 
|   | 
|     @ApiOperation("根据ID查询") | 
|     @GetMapping("/{id}") | 
|     @CloudRequiredPermission("business:platformwatergas:query") | 
|     public ApiResponse findById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) { | 
|         return ApiResponse.success(platformWaterGasService.findById(id)); | 
|     } | 
| } |