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());}
|
}
|
