huimv-new-input/huimv-env-admin/src/main/java/com/huimv/env/admin/controller/TerminalController.java

package com.huimv.env.admin.controller;


import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.huimv.env.admin.common.utils.Result;
import com.huimv.env.admin.common.utils.ResultCode;
import com.huimv.env.admin.entity.Gateway;
import com.huimv.env.admin.entity.Terminal;
import com.huimv.env.admin.entity.vo.*;
import com.huimv.env.admin.service.ITerminalService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * <p>
 * 监测终端 前端控制器
 * </p>
 *
 * @author newspaper
 * @since 2024-05-07
 */
@RestController
@CrossOrigin
@RequestMapping("/terminal")
public class TerminalController {

    @Autowired
    private ITerminalService terminalService;

    @PostMapping("/add")
    public Result add(@RequestBody TerminalAddParam terminalAddParam){
        List<Terminal> terminalList = terminalService.list(new QueryWrapper<Terminal>().lambda()
                .eq(Terminal::getDeviceCode, terminalAddParam.getDeviceCode()));
        if (ObjectUtil.isEmpty(terminalList)){
            return new Result(10001,"终端编号已存在",false);
        }
        Terminal terminal = new Terminal();
        terminal.setDeviceCode(terminalAddParam.getDeviceCode());
        terminal.setGatewayId(terminalAddParam.getGatewayId());
        terminal.setType(terminalAddParam.getType());
        terminal.setFarmId(terminalAddParam.getFarmId());
        terminalService.save(terminal);

        return Result.SUCCESS();
    }

    @PostMapping("/list")
    public Result list(@RequestBody TerminalListParam terminalListParam){
        List<Terminal> terminalList = terminalService.list(new QueryWrapper<Terminal>().lambda()
                .eq(ObjectUtil.isNotEmpty(terminalListParam.getGatewayId()), Terminal::getGatewayId, terminalListParam.getGatewayId()));
        return new Result(ResultCode.SUCCESS,terminalList);
    }

    @PostMapping("/page")
    public Result page(@RequestBody TerminalPageParam terminalPageParam){
        Page<Terminal> page = new Page<>(terminalPageParam.getPageNum(),terminalPageParam.getPageSize());
        Page<Terminal> terminalPage = terminalService.page(page);
        return new Result(ResultCode.SUCCESS,terminalPage);
    }

    @PostMapping("/update")
    public Result update(@RequestBody TerminalUpdateParam terminalUpdateParam){
        List<Terminal> terminalList = terminalService.list(new QueryWrapper<Terminal>().lambda()
                .eq(Terminal::getDeviceCode, terminalUpdateParam.getDeviceCode())
                .ne(Terminal::getId,terminalUpdateParam.getId()));
        if (ObjectUtil.isEmpty(terminalList)){
            return new Result(10001,"终端编号已存在",false);
        }
        Terminal terminal = terminalService.getById(terminalUpdateParam.getId());
        terminal.setDeviceCode(terminalUpdateParam.getDeviceCode());
        terminal.setGatewayId(terminalUpdateParam.getGatewayId());
        terminal.setType(terminalUpdateParam.getType());
        terminal.setFarmId(terminalUpdateParam.getFarmId());
        terminalService.updateById(terminal);
        return Result.SUCCESS();
    }

    @PostMapping("/delete")
    public Result delete(@RequestBody TerminalDeleteParam terminalDeleteParam){
        //TODO 终端删除前判断端口是否存在
//        List<Terminal> terminalList = terminalService.list(new QueryWrapper<Terminal>().lambda().eq(Terminal::getGatewayId, gateWayDeleteParam.getId()));
//        if (ObjectUtil.isEmpty(terminalList)){
//            return new Result(10001,"终端存在下属端口",false);
//        }
        terminalService.removeById(terminalDeleteParam.getId());
        return Result.SUCCESS();
    }


}