package cn.iocoder.yudao.module.mes.controller.admin.safety;
import cn.iocoder.yudao.framework.common.pojo.*;
import cn.iocoder.yudao.module.mes.controller.admin.safety.vo.risk.SafetyRiskSourceSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.safety.SafetyRiskSourceDO;
import cn.iocoder.yudao.module.mes.service.safety.SafetyRiskSourceService;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.List;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;

@RestController @RequestMapping("/safety/risk-source") @Validated
public class SafetyRiskSourceController {
    @Resource private SafetyRiskSourceService service;
    @GetMapping("/page") @PreAuthorize("@ss.hasPermission('safety:risk:query')")
    public CommonResult<PageResult<SafetyRiskSourceDO>> page(@Valid PageParam page,@RequestParam(value="name",required=false) String name){return success(service.page(page,name));}
    @PostMapping("/create") @PreAuthorize("@ss.hasPermission('safety:risk:create')")
    public CommonResult<Long> create(@Valid @RequestBody SafetyRiskSourceSaveReqVO req){req.setId(null);return success(service.save(req));}
    @PutMapping("/update") @PreAuthorize("@ss.hasPermission('safety:risk:update')")
    public CommonResult<Boolean> update(@Valid @RequestBody SafetyRiskSourceSaveReqVO req){if(req.getId()==null)throw cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.invalidParamException("危险源编号不能为空");service.save(req);return success(true);}
    @DeleteMapping("/delete") @PreAuthorize("@ss.hasPermission('safety:risk:delete')")
    public CommonResult<Boolean> delete(@RequestParam("id") Long id){service.delete(id);return success(true);}

    /** 用设备采集数据刷新已绑定设备的危险源，返回本次报警清单。 */
    @PostMapping("/refresh") @PreAuthorize("@ss.hasPermission('safety:risk:update')")
    public CommonResult<List<SafetyRiskSourceDO>> refreshFromCollect(){return success(service.refreshFromCollect());}
}