对比新文件 |
| | |
| | | package com.gk.firework.Service.ServiceImpl; |
| | | |
| | | import com.baomidou.mybatisplus.core.metadata.OrderItem; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.gk.firework.Domain.Enterprise; |
| | | import com.gk.firework.Domain.SelfCheckReport; |
| | | import com.gk.firework.Domain.Utils.JsonUtils; |
| | | import com.gk.firework.Domain.Utils.PageInfo; |
| | | import com.gk.firework.Domain.Vo.SelfCheckReportSearchVo; |
| | | import com.gk.firework.Domain.Vo.SelfCheckReportVo; |
| | | import com.gk.firework.Mapper.EnterpriseMapper; |
| | | import com.gk.firework.Mapper.SelfCheckReportMapper; |
| | | import com.gk.firework.Service.EnterpriseService; |
| | | import com.gk.firework.Service.SelfCheckReportService; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | @Service("SelfCheckReportService") |
| | | public class SelfCheckReportServiceImpl extends ServiceImpl<SelfCheckReportMapper,SelfCheckReport> implements SelfCheckReportService { |
| | | |
| | | @Autowired |
| | | SelfCheckReportMapper selfCheckReportMapper; |
| | | |
| | | @Autowired |
| | | EnterpriseService enterpriseService; |
| | | |
| | | |
| | | @Override |
| | | public int createNewReport(SelfCheckReportVo reportVo) { |
| | | if(checkVoForCreate(reportVo) == false){ |
| | | return 0; |
| | | } |
| | | SelfCheckReport selfCheckReport = null; |
| | | Enterprise e = enterpriseService.getById(reportVo.getEid()); |
| | | if(e!= null){ |
| | | selfCheckReport = new SelfCheckReport(); |
| | | Date sysTime = new Date(); |
| | | selfCheckReport.setEid(e.getId()); |
| | | selfCheckReport.setEname(e.getEnterprisename()); |
| | | selfCheckReport.setChecktime(sysTime); |
| | | selfCheckReport.setPrice(reportVo.getPrice()); |
| | | if(reportVo.getStatus()==1 || reportVo.getStatus()==2){ |
| | | selfCheckReport.setStatus(reportVo.getStatus()); |
| | | } |
| | | else{ |
| | | selfCheckReport.setStatus((byte)1); |
| | | } |
| | | selfCheckReport.setYhdesc(reportVo.getYhdesc()); |
| | | selfCheckReport.setYhlevel(reportVo.getYhlevel()); |
| | | selfCheckReport.setSolution(reportVo.getSolution()); |
| | | selfCheckReport.setEndtime(reportVo.getEndtime()); |
| | | selfCheckReport.setChargeperson(reportVo.getChargeperson()); |
| | | } |
| | | if(selfCheckReport!=null){ |
| | | return selfCheckReportMapper.insert(selfCheckReport); |
| | | }else { |
| | | return 0; |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public SelfCheckReport getSelfCheckReportById(Long id) { |
| | | return selfCheckReportMapper.selectByReportId(id); |
| | | } |
| | | |
| | | @Override |
| | | public int updateSelfCheckReport(SelfCheckReportVo reportVo) { |
| | | SelfCheckReport report = selfCheckReportMapper.selectByReportId(reportVo.getId()); |
| | | if(report == null){ |
| | | return 0; |
| | | } |
| | | if(!report.getEid().equals(reportVo.getEid())){ |
| | | return 0; |
| | | } |
| | | if(report.getStatus() == 2){ |
| | | return 0; |
| | | } |
| | | if(report.getStatus() ==1 && reportVo.getStatus() == 2){ |
| | | report.setStatus((byte) 2); |
| | | } |
| | | if(!reportVo.getChargeperson().isEmpty()){ |
| | | report.setChargeperson(reportVo.getChargeperson()); |
| | | } |
| | | if(!reportVo.getYhdesc().isEmpty()){ |
| | | report.setYhdesc(reportVo.getYhdesc()); |
| | | } |
| | | if(reportVo.getEndtime() != null){ |
| | | report.setEndtime(reportVo.getEndtime()); |
| | | } |
| | | if(!reportVo.getSolution().isEmpty()){ |
| | | report.setSolution(reportVo.getSolution()); |
| | | } |
| | | if(reportVo.getYhlevel() == 1 || reportVo.getYhlevel() == 2){ |
| | | report.setYhlevel(reportVo.getYhlevel()); |
| | | } |
| | | report.setPrice(reportVo.getPrice()); |
| | | return selfCheckReportMapper.updateReport(report); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public List<SelfCheckReport> findSelfCheckReportList(Long enterpriseId, Byte status,Byte yhlevel) { |
| | | return selfCheckReportMapper.selectReportListByCondition(enterpriseId,status,yhlevel); |
| | | } |
| | | |
| | | @Override |
| | | public List<SelfCheckReport> findSelfCheckReportListWithAllCondition(SelfCheckReportSearchVo searchVo) { |
| | | //1、解析企业ID集合 |
| | | List<Long> eidList = null; |
| | | //优先级别:1-指定企业ID,2-指定企业名称。3-指定省市区范围 |
| | | if(searchVo.getEid() != null && searchVo.getEid().longValue() > 0){ |
| | | if(enterpriseService.getById(searchVo.getEid())!=null){ |
| | | eidList = new ArrayList<>(); |
| | | eidList.add(searchVo.getEid()); |
| | | }else { |
| | | return null; |
| | | } |
| | | }else if(searchVo.getEname() != null && !searchVo.getEname().isEmpty()){ |
| | | List<Enterprise> list = enterpriseService.selectEnterpriseListByNameLike(searchVo.getEname()); |
| | | if(list != null && list.size() >0){ |
| | | eidList = new ArrayList<>(); |
| | | for(Enterprise e : list){ |
| | | eidList.add(e.getId()); |
| | | } |
| | | }else { |
| | | return null; |
| | | } |
| | | }else if(searchVo.getProvince()!=null && !searchVo.getProvince().isEmpty()){ |
| | | List<Enterprise> enterpriseList = enterpriseService.findEnterpriseListByLocation(searchVo.getProvince(),searchVo.getCity(),searchVo.getDistrict(),searchVo.getStreet(),searchVo.getCommittee()); |
| | | if(enterpriseList!=null){ |
| | | eidList = new ArrayList<>(); |
| | | for(Enterprise e : enterpriseList){ |
| | | eidList.add(e.getId()); |
| | | } |
| | | } |
| | | if(eidList == null || eidList.size()<=0 ){ |
| | | return null; |
| | | } |
| | | } |
| | | //2、设定分页参数 |
| | | if (searchVo.getPage()==null || searchVo.getPage() <=0){ |
| | | //未指定页数,默认第1页 |
| | | searchVo.setPage(1); |
| | | } |
| | | if(searchVo.getPageSize() == null || searchVo.getPageSize() <= 0){ |
| | | //未指定页大小,默认20条 |
| | | searchVo.setPageSize(20); |
| | | } |
| | | Page<SelfCheckReport> page = new Page<>(searchVo.getPage(),searchVo.getPageSize()); |
| | | List<OrderItem> orderItems = new ArrayList<>(); |
| | | OrderItem orderItem = new OrderItem(); |
| | | orderItem.setAsc(false); |
| | | orderItem.setColumn("id"); |
| | | orderItems.add(orderItem); |
| | | page.setOrders(orderItems); |
| | | //3、查找 |
| | | List<SelfCheckReport> list = null; |
| | | list = selfCheckReportMapper.selectReportListWithEnterpriseIdList(eidList,searchVo.getStatus(),searchVo.getYhlevel(),searchVo.getStartTime(),searchVo.getEndTime(),page); |
| | | searchVo.setTotalCount(page.getTotal()); |
| | | return list; |
| | | } |
| | | |
| | | /** |
| | | * 新增隐患信息参数检查 |
| | | * @param reportVo |
| | | * @return |
| | | */ |
| | | private boolean checkVoForCreate(SelfCheckReportVo reportVo){ |
| | | if(reportVo.getStatus()<1 ||reportVo.getStatus()>2){ |
| | | return false; |
| | | } |
| | | if(reportVo.getYhlevel() <1 || reportVo.getYhlevel() >2){ |
| | | return false; |
| | | } |
| | | if(reportVo.getChargeperson().isEmpty() || reportVo.getYhdesc().isEmpty() || reportVo.getSolution().isEmpty()){ |
| | | return false; |
| | | } |
| | | if(reportVo.getPrice().intValue()<0){ |
| | | return false; |
| | | } |
| | | if(reportVo.getEndtime().before(new Date())){ |
| | | return false; |
| | | } |
| | | return true; |
| | | } |
| | | } |