| | |
| | | import com.ruoyi.common.utils.DateUtils; |
| | | import com.ruoyi.common.utils.StringUtils; |
| | | import com.ruoyi.common.utils.security.ShiroUtils; |
| | | import com.ruoyi.doublePrevention.entity.PreventRiskDangerCheckAndMeasure; |
| | | import com.ruoyi.doublePrevention.entity.PreventRiskDangerCheckLog; |
| | | import com.ruoyi.doublePrevention.service.RiskService; |
| | | import com.ruoyi.doublePrevention.service.baseService.PreventRiskDangerCheckAndMeasureService; |
| | | import com.ruoyi.framework.web.domain.AjaxResult; |
| | | import com.ruoyi.project.mobile.domain.ApiRequestHeader; |
| | | import com.ruoyi.project.mobile.domain.ApiResult; |
| | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.ObjectUtils; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | |
| | | @Autowired |
| | | private RiskService riskService; |
| | | |
| | | @Autowired |
| | | private PreventRiskDangerCheckAndMeasureService preventRiskDangerCheckAndMeasureService; |
| | | /** |
| | | * 获取定时任务隐患列表 |
| | | * |
| | |
| | | }); |
| | | |
| | | |
| | | |
| | | hiddenDangerCheckService.updateHiddenDangerCheck(hiddenDangerCheck); |
| | | |
| | | hdcpService.getTaskCountTotal(Long.valueOf(header.userId));//查询未执行任务总数量并推送 |
| | |
| | | |
| | | |
| | | /** |
| | | * 设置为记录正常 |
| | | * 设置为记录正常 // todo |
| | | */ |
| | | public ApiResult editPointScheduleSetNormal(String str, ApiRequestHeader header) { |
| | | //验证userId,loginName,token,deviceType,deviceId,appType 是否一致 |
| | |
| | | hdcp.setWhetherDanger(TrHiddenDangerCheckConstants.WHETHER_DANGER_NOT);//是否为隐患(正常) |
| | | hdcp.setScheduleCheckStatus(TrHiddenDangerCheckConstants.CHECK_STATUS_ALREADY_CHECK);//排查状态(已排查) |
| | | hdcpService.updateHiddenDangerCheckPoint(hdcp); |
| | | |
| | | PreventRiskDangerCheckAndMeasure dangerCheckPointInfo = preventRiskDangerCheckAndMeasureService.getByDangerCheckPointId(hdcp.getId()); |
| | | int result = riskService.updateCheckLog(dangerCheckPointInfo.getCheckId(), hdcp);// todo |
| | | if (result < 1){ |
| | | return ApiResult.error("隐患排查记录附属表:写入手机识别码错误"); |
| | | } |
| | | |
| | | hdcpService.getTaskCountTotal(Long.valueOf(header.userId));//查询未执行任务总数量并推送 |
| | | |
| | |
| | | |
| | | /** |
| | | * 本次查询结果 :如果未上报过隐患,必定为空 |
| | | * ?同一个检查任务,同一个排查点,可能多次上报隐患。 |
| | | * 同一个检查任务,同一个排查点,可能多次上报隐患。 |
| | | * 本次查询未用到id,导致数据不唯一 |
| | | * */ |
| | | List<HiddenDangerCheckPoint> queryExistList = hdcpService.selectHiddenDangerCheckPointList(queryExist); |
| | |
| | | throw new RuntimeException("添加隐患附属信息失败"); |
| | | } |
| | | |
| | | PreventRiskDangerCheckAndMeasure dangerCheckPointInfo = preventRiskDangerCheckAndMeasureService.getByDangerCheckPointId(hdcp.getId()); |
| | | riskService.updateCheckLog(dangerCheckPointInfo.getCheckId(), hdcp); |
| | | |
| | | }else{ |
| | | hdcp.setUpdateBy(user.getLoginName()); |
| | | hdcp.setUpdateTime(DateUtils.getNowDate()); |
| | |
| | | if (result< 1){ |
| | | throw new RuntimeException("添加隐患附属信息失败"); |
| | | } |
| | | |
| | | PreventRiskDangerCheckAndMeasure dangerCheckPointInfo = preventRiskDangerCheckAndMeasureService.getByDangerCheckPointId(hdcp.getId()); |
| | | riskService.updateCheckLog(dangerCheckPointInfo.getCheckId(), hdcp); |
| | | } |
| | | hdcpService.getTaskCountTotal(Long.valueOf(header.userId));//查询未执行任务总数量并推送 |
| | | |