LingangEquipmentHeartbeatController.java 7.21 KB
package com.ruoyi.controller.equipment.heartbeat;

import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.ResponseResult;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.domain.OrderEntity;
import com.ruoyi.domain.equipment.heartbeat.LingangEquipmentHeartbeat;
import com.ruoyi.domain.equipment.heartbeat.dto.LingangEquipmentHeartbeatAddDTO;
import com.ruoyi.domain.equipment.heartbeat.dto.LingangEquipmentHeartbeatQueryDTO;
import com.ruoyi.domain.equipment.heartbeat.dto.LingangEquipmentHeartbeatUpdateDTO;
import com.ruoyi.domain.equipment.heartbeat.vo.LingangEquipmentHeartbeatVO;
import com.ruoyi.service.equipment.heartbeat.LingangEquipmentHeartbeatService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletResponse;
import javax.validation.Valid;
import java.util.Date;
import java.util.List;


@RestController
@Api(tags = "设备心跳包")
@RequestMapping("LinGang/equipment/heartbeat")
public class LingangEquipmentHeartbeatController extends BaseController {
    @Autowired
    private LingangEquipmentHeartbeatService lingangEquipmentHeartbeatService;

    @ApiOperation("分页查询")
    @PreAuthorize("@ss.hasPermi('LinGang:equipment:heartbeat:list:limit:page:limit')")
    @PostMapping(value = "/list/limit/{page}/{pageLimit}")
    public String listLimit(@ModelAttribute LingangEquipmentHeartbeatQueryDTO request, @ModelAttribute OrderEntity orderEntity, @PathVariable Integer page, @PathVariable Integer pageLimit, org.springframework.ui.Model model) {

        LingangEquipmentHeartbeat entity = convert(request);
        IPage<LingangEquipmentHeartbeat> response = lingangEquipmentHeartbeatService.pageList(new Page<LingangEquipmentHeartbeat>(page, pageLimit), entity, orderEntity);

        return JSON.toJSONString(convert(response));
    }

    @ApiOperation("根据ID查询详情")
    @GetMapping(value = "/view/{id}")
    public ResponseResult view(@PathVariable("id") Long id, org.springframework.ui.Model model) {
        LingangEquipmentHeartbeat source = lingangEquipmentHeartbeatService.getById(id);

        return ResponseResult.success(convert(source));
    }


    @PreAuthorize("@ss.hasPermi('LinGang:equipment:heartbeat:export')")
    @ApiOperation("导出")
    @PostMapping("/export")
    public void export(HttpServletResponse response, @RequestBody LingangEquipmentHeartbeatQueryDTO request) {
        LingangEquipmentHeartbeat entity = convert(request);
        List<LingangEquipmentHeartbeat> list = lingangEquipmentHeartbeatService.list(entity);
        ExcelUtil<LingangEquipmentHeartbeat> util = new ExcelUtil<LingangEquipmentHeartbeat>(LingangEquipmentHeartbeat.class);
        util.exportExcel(response, list, "LingangEquipmentHeartbeat");
    }

    @ApiOperation("添加")
    @PreAuthorize("@ss.hasPermi('LinGang:equipment:heartbeat:add')")
    @PostMapping(value = "/add")
    public ResponseResult add(@Valid @ModelAttribute LingangEquipmentHeartbeatAddDTO request, BindingResult bindingResult) {
        if (bindingResult.hasErrors()) {
            return ResponseResult.error(bindingResult.getFieldError().getDefaultMessage());
        }
        LingangEquipmentHeartbeat entity = convert(request);
        entity.setCreateBy(getUserId());
        entity.setCreateTime(new Date());
        int count = lingangEquipmentHeartbeatService.insertSelective(entity);
        return count > 0 ? ResponseResult.success(Boolean.TRUE) : ResponseResult.error("添加数据失败,请稍后再试");
    }

    @ApiOperation("修改")
    @PreAuthorize("@ss.hasPermi('LinGang:equipment:heartbeat:update')")
    @PostMapping(value = "/update")
    public ResponseResult update(@Valid @ModelAttribute LingangEquipmentHeartbeatUpdateDTO request, BindingResult bindingResult) {
        if (bindingResult.hasErrors()) {
            return ResponseResult.error(bindingResult.getFieldError().getDefaultMessage());
        }
        LingangEquipmentHeartbeat entity = convert(request);
        entity.setUpdateby(getUserId());
        entity.setUpdateTime(new Date());
        boolean flag = lingangEquipmentHeartbeatService.updateByPrimaryKey(entity);
        return flag ? ResponseResult.success(Boolean.TRUE) : ResponseResult.error("修改数据失败,请稍后再试");
    }

    @PreAuthorize("@ss.hasPermi('LinGang:equipment:heartbeat:del')")
    @ApiOperation("删除数据")
    @GetMapping(value = "/del/{id}")
    public ResponseResult delById(@PathVariable("id") Long id) {
        boolean flag = lingangEquipmentHeartbeatService.deleteById(id);
        return flag ? ResponseResult.success(Boolean.TRUE) : ResponseResult.error("操作数据失败,请稍后再试");
    }

    private LingangEquipmentHeartbeat convert(LingangEquipmentHeartbeatQueryDTO source) {
        return java.util.Optional.ofNullable(source).map(sc -> {
            LingangEquipmentHeartbeat target = new LingangEquipmentHeartbeat();
            BeanUtils.copyProperties(sc, target);
            return target;
        }).orElse(null);
    }

    private LingangEquipmentHeartbeat convert(LingangEquipmentHeartbeatUpdateDTO source) {
        return java.util.Optional.ofNullable(source).map(sc -> {
            LingangEquipmentHeartbeat target = new LingangEquipmentHeartbeat();
            BeanUtils.copyProperties(sc, target);
            return target;
        }).orElse(null);
    }


    private LingangEquipmentHeartbeat convert(LingangEquipmentHeartbeatAddDTO source) {
        return java.util.Optional.ofNullable(source).map(sc -> {
            LingangEquipmentHeartbeat target = new LingangEquipmentHeartbeat();
            BeanUtils.copyProperties(sc, target);
            return target;
        }).orElseGet(null);
    }

    private LingangEquipmentHeartbeatVO convert(LingangEquipmentHeartbeat source) {
        return java.util.Optional.ofNullable(source).map(sc -> {
            LingangEquipmentHeartbeatVO target = new LingangEquipmentHeartbeatVO();
            BeanUtils.copyProperties(source, target);
            return target;
        }).orElseGet(null);
    }

    private List<LingangEquipmentHeartbeatVO> convert(List<LingangEquipmentHeartbeat> sources) {
        return java.util.Optional.ofNullable(sources).map(scs -> {
            return scs.stream().map(source -> {
                return convert(source);
            }).collect(java.util.stream.Collectors.toList());
        }).orElseGet(null);
    }

    private IPage<LingangEquipmentHeartbeatVO> convert(IPage<LingangEquipmentHeartbeat> sources) {
        return java.util.Optional.ofNullable(sources).map(scs -> {
            IPage<LingangEquipmentHeartbeatVO> target = new Page();
            BeanUtils.copyProperties(scs, target);
            List<LingangEquipmentHeartbeatVO> voNames = convert(scs.getRecords());
            target.setRecords(voNames);

            return target;
        }).orElseGet(null);
    }
}