| | |
|---|
| | | package com.dy.pipIrrApp.issue; |
|---|
| | | |
|---|
| | | import com.dy.common.webUtil.QueryResultVo; |
|---|
| | | import com.dy.pipIrrApp.issue.dto.DtoDeleteParam; |
|---|
| | | import com.dy.pipIrrApp.issue.qo.QoIssueReport; |
|---|
| | | import com.dy.pipIrrGlobal.daoOp.OpeIssueReportMapper; |
|---|
| | | import com.dy.pipIrrGlobal.pojoOp.OpeIssueReport; |
|---|
| | | import com.dy.pipIrrGlobal.voOp.VoIssueReport; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.dubbo.common.utils.PojoUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @author ZhuBaoMin |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 添加巡检员问题上报信息 |
|---|
| | | * 根据条件获取巡检员问题上报记录 |
|---|
| | | * @param queryVo |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public QueryResultVo<List<VoIssueReport>> getIssueReports(QoIssueReport queryVo) { |
|---|
| | | //完善查询充值记录的起止时间 |
|---|
| | | String timeStart = queryVo.getTimeStart(); |
|---|
| | | String timeStop = queryVo.getTimeStop(); |
|---|
| | | if (timeStart != null) { |
|---|
| | | timeStart = timeStart + " 00:00:00"; |
|---|
| | | queryVo.setTimeStart(timeStart); |
|---|
| | | } |
|---|
| | | if (timeStop != null) { |
|---|
| | | timeStop = timeStop + " 23:59:59"; |
|---|
| | | queryVo.setTimeStop(timeStop); |
|---|
| | | } |
|---|
| | | |
|---|
| | | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); |
|---|
| | | |
|---|
| | | Long itemTotal = opeIssueReportMapper.getIssueReportsCount(params); |
|---|
| | | QueryResultVo<List<VoIssueReport>> rsVo = new QueryResultVo<>(); |
|---|
| | | |
|---|
| | | rsVo.pageSize = queryVo.pageSize; |
|---|
| | | rsVo.pageCurr = queryVo.pageCurr; |
|---|
| | | |
|---|
| | | rsVo.calculateAndSet(itemTotal, params); |
|---|
| | | rsVo.obj = opeIssueReportMapper.getIssueReports(params); |
|---|
| | | return rsVo; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 逻辑删除巡检员问题上报，删除前先判断要删除的上报是否存在 |
|---|
| | | * @param po |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | //public Long insertIssueReport(OpeIssueReport po) { |
|---|
| | | // opeIssueReportMapper.insert(po); |
|---|
| | | // return po.getId(); |
|---|
| | | //} |
|---|
| | | public String deleteIssueReport(DtoDeleteParam po) { |
|---|
| | | // 根据上报ID及巡检员ID获取未删除的上报，删除上报判断使用 |
|---|
| | | OpeIssueReport opeIssueReport = opeIssueReportMapper.getReport(po.getIssueReportId(), po.getInspectorId()); |
|---|
| | | if(opeIssueReport == null) { |
|---|
| | | return "您要删除的问题上报不存在"; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(opeIssueReportMapper.deleteIssueReport(po.getIssueReportId()) == 0) { |
|---|
| | | return "巡检员问题上报删除失败"; |
|---|
| | | } |
|---|
| | | |
|---|
| | | return "success"; |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
