临时提交-已经与app端对接完成

16639036659

2023-06-26 28f6c716269ce5435b103137dd7ec1f1f9ab19ba

 src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventRiskDangerCheckLogServiceImpl.java

@@ -1,10 +1,15 @@
package com.ruoyi.doublePrevention.service.baseService.impl;



import com.ruoyi.doublePrevention.entity.PreventRiskDangerCheckLog;

import com.ruoyi.doublePrevention.enums.E;

import com.ruoyi.doublePrevention.exception.AusinessException;

import com.ruoyi.doublePrevention.repository.PreventRiskDangerCheckLogRepository;

import com.ruoyi.doublePrevention.repository.param.HandlerReportParam;

import com.ruoyi.doublePrevention.service.baseService.PreventRiskDangerCheckLogService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;



import java.util.List;



@Service("PreventRiskDangerCheckLogService")

public class PreventRiskDangerCheckLogServiceImpl implements PreventRiskDangerCheckLogService {

@@ -26,4 +31,41 @@
    public int deleteDangerCheck(Long checkId) {

        return  preventRiskDangerCheckLogRepository.deleteDangerCheck(checkId);

    }





    /**

     * 检索需要上报的任务记录

     * */

    @Override

    public List<PreventRiskDangerCheckLog> listReportTask() {

        return preventRiskDangerCheckLogRepository.listReportTask();

    }

    /**

     * 修改上报的数据状态

     * */

    @Override

    public int updateTaskReportStatus(HandlerReportParam handlerReportParam) {

        int result = preventRiskDangerCheckLogRepository.updateEventReportStatus(handlerReportParam);

        if (result < 1){

            throw new AusinessException(E.UPDATE_FAIL.getCode(), "安全风险事件-更新上报状态失败");

        }

        return result;

    }

    /**

     * 查询by checkId

     * */

    @Override

    public PreventRiskDangerCheckLog getByDangerCheckByCheckId(Long checkId) {

        return preventRiskDangerCheckLogRepository.getByDangerCheckByCheckId(checkId);

    }



    @Override

    public PreventRiskDangerCheckLog getByDangerCheckByJobId(Long jobId) {

        return preventRiskDangerCheckLogRepository.getByDangerCheckByJobId(jobId);

    }



    @Override

    public int updateCheckLog(Long checkId, Long mobileCode) {

        return preventRiskDangerCheckLogRepository.updateCheckLog(checkId, mobileCode);

    }

}