package com.sooka.sponest.data.digitalwater.controller; import com.alibaba.fastjson.JSON; import com.ruoyi.common.core.constant.DocumentNameConstants; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.web.controller.BaseController; import com.ruoyi.common.core.web.domain.AjaxResult; import com.ruoyi.common.core.web.page.TableDataInfo; import com.ruoyi.common.log.annotation.Log; import com.ruoyi.common.log.enums.BusinessType; import com.ruoyi.common.security.annotation.RequiresPermissions; import com.sooka.sponest.data.base.domain.ESVo; import com.sooka.sponest.data.digitalwater.domain.CenterdataTHydraulicChannelBlueline; import com.sooka.sponest.data.digitalwater.service.ICenterdataTHydraulicChannelBluelineService; import com.sooka.sponest.data.digitalwater.service.ICenterdataTHydraulicReachService; import com.sooka.sponest.data.digitalwater.service.ICenterdataTHydraulicRiverService; import com.sooka.sponest.data.utils.DataConstants; import com.sooka.sponest.data.utils.DataProducerUtil; import com.sooka.sponest.data.utils.ExcelUtil; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletResponse; import java.util.Arrays; import java.util.List; /** * 河道蓝线资源Controller * * @author lyq * @date 2022-11-17 */ @Api(tags = "河道蓝线资源控制器") @RestController @RequestMapping("/channelblueline") public class CenterdataTHydraulicChannelBluelineController extends BaseController { @Autowired private ICenterdataTHydraulicChannelBluelineService centerdataTHydraulicChannelBluelineService; @Autowired private ICenterdataTHydraulicReachService iCenterdataTHydraulicReachService; @Autowired private ICenterdataTHydraulicRiverService iCenterdataTHydraulicRiverService; @Autowired private ICenterdataTHydraulicRiverService centerdataTHydraulicRiverService;//河流Service @Autowired private ICenterdataTHydraulicReachService centerdataTHydraulicReachService;//河段Service /** * 查询河道蓝线资源列表 */ @ApiOperation(value = "查询河道蓝线资源列表", notes = "查询河道蓝线资源列表") @RequiresPermissions("water:channelblueline:list") @GetMapping("/list") public TableDataInfo list(CenterdataTHydraulicChannelBlueline centerdataTHydraulicChannelBlueline) { startPage(); List list = centerdataTHydraulicChannelBluelineService.selectCenterdataTHydraulicChannelBluelineList(centerdataTHydraulicChannelBlueline); return getDataTable(list); } // 远端调用 数字水利远端调用 @ApiOperation(value = "远端调用查询河道蓝线资源", notes = "远端调用查询河道蓝线资源") @PostMapping("/listChannelBlueline") public R> listChannelBlueline(CenterdataTHydraulicChannelBlueline centerdataTHydraulicChannelBlueline) { return R.ok(centerdataTHydraulicChannelBluelineService.selectCenterdataTHydraulicChannelBluelineList(centerdataTHydraulicChannelBlueline)); } /** * 导出河道蓝线资源列表 */ @ApiOperation(value = "导出河道蓝线资源列表", notes = "导出河道蓝线资源列表") @RequiresPermissions("water:channelblueline:export") @Log(title = "河道蓝线资源", businessType = BusinessType.EXPORT) @PostMapping("/export") public void export(HttpServletResponse response, CenterdataTHydraulicChannelBlueline centerdataTHydraulicChannelBlueline) { List list = centerdataTHydraulicChannelBluelineService.selectCenterdataTHydraulicChannelBluelineList(centerdataTHydraulicChannelBlueline); for (CenterdataTHydraulicChannelBlueline tHydraulicChannelBlueline : list) { tHydraulicChannelBlueline.setReach(iCenterdataTHydraulicReachService.selectCenterdataTHydraulicReachById(tHydraulicChannelBlueline.getReach()).getName()); tHydraulicChannelBlueline.setRiver(iCenterdataTHydraulicRiverService.selectCenterdataTHydraulicRiverById(tHydraulicChannelBlueline.getRiver()).getName()); } ExcelUtil util = new ExcelUtil<>(CenterdataTHydraulicChannelBlueline.class); util.exportExcel(response, list, "河道蓝线资源数据"); } /** * 获取河道蓝线资源详细信息 */ @ApiOperation(value = "获取河道蓝线资源详细信息", notes = "获取河道蓝线资源详细信息") @RequiresPermissions("water:channelblueline:query") @GetMapping(value = "/{id}") @ApiImplicitParams(value = { @ApiImplicitParam(name = "id", value = "主键id", dataType = "String", required = true) }) public AjaxResult getInfo(@PathVariable("id") String id) { return AjaxResult.success(centerdataTHydraulicChannelBluelineService.selectCenterdataTHydraulicChannelBluelineById(id)); } /** * 新增河道蓝线资源 */ @ApiOperation(value = "新增河道蓝线资源", notes = "新增河道蓝线资源") @RequiresPermissions("water:channelblueline:add") @Log(title = "河道蓝线资源", businessType = BusinessType.INSERT) @PostMapping public AjaxResult add(@Validated @RequestBody CenterdataTHydraulicChannelBlueline centerdataTHydraulicChannelBlueline) { String tableName = "centerdata_t_hydraulic_channel_blueline"; String[] keys = {"name","dept_id"}; String[] values = {centerdataTHydraulicChannelBlueline.getName(),String.valueOf(centerdataTHydraulicChannelBlueline.getDeptId())}; if(!centerdataTHydraulicChannelBluelineService.uniqueCheck(tableName, keys, values)){ return AjaxResult.error(DataConstants.ERROR_MSG); } int result = centerdataTHydraulicChannelBluelineService.insertCenterdataTHydraulicChannelBlueline(centerdataTHydraulicChannelBlueline); DataProducerUtil.getInstance().publish(new ESVo(DocumentNameConstants.HYDRAULIC_CHANNEL_BLUELINE,BusinessType.INSERT, JSON.toJSONString(centerdataTHydraulicChannelBlueline))); return toAjax(result); } /** * 修改河道蓝线资源 */ @ApiOperation(value = "修改河道蓝线资源", notes = "修改河道蓝线资源") @RequiresPermissions("water:channelblueline:edit") @Log(title = "河道蓝线资源", businessType = BusinessType.UPDATE) @PutMapping public AjaxResult edit(@Validated @RequestBody CenterdataTHydraulicChannelBlueline centerdataTHydraulicChannelBlueline) { String tableName = "centerdata_t_hydraulic_channel_blueline"; String[] keys = {"name" , "id","dept_id"}; String[] values = {centerdataTHydraulicChannelBlueline.getName() , centerdataTHydraulicChannelBlueline.getId(),String.valueOf(centerdataTHydraulicChannelBlueline.getDeptId())}; if(!centerdataTHydraulicChannelBluelineService.uniqueCheck(tableName, keys, values)){ return AjaxResult.error(DataConstants.ERROR_MSG); } int result = centerdataTHydraulicChannelBluelineService.updateCenterdataTHydraulicChannelBlueline(centerdataTHydraulicChannelBlueline); DataProducerUtil.getInstance().publish(new ESVo(DocumentNameConstants.HYDRAULIC_CHANNEL_BLUELINE,BusinessType.UPDATE, JSON.toJSONString(centerdataTHydraulicChannelBlueline))); return toAjax(result); } /** * 删除河道蓝线资源 */ @ApiOperation(value = "删除河道蓝线资源", notes = "删除河道蓝线资源") @RequiresPermissions("water:channelblueline:remove") @Log(title = "河道蓝线资源", businessType = BusinessType.DELETE) @DeleteMapping("/{ids}") @ApiImplicitParams(value = { @ApiImplicitParam(name = "ids", value = "主键id", dataType = "String[]", required = true) }) public AjaxResult remove(@PathVariable String[] ids) { int result = centerdataTHydraulicChannelBluelineService.deleteCenterdataTHydraulicChannelBluelineByIds(ids); List idList = Arrays.asList(ids); DataProducerUtil.getInstance().publish(new ESVo(DocumentNameConstants.HYDRAULIC_CHANNEL_BLUELINE,BusinessType.DELETE, JSON.toJSONString(idList))); return toAjax(result); } }