package com.gk.hotwork.Service.ServiceImpl;
|
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gk.hotwork.Domain.CompanyInfo;
|
import com.gk.hotwork.Domain.SafetyFacilityInspection;
|
import com.gk.hotwork.Domain.SafetyFacilityProcessflow;
|
import com.gk.hotwork.Domain.SafetyInspectionItemDeduction;
|
import com.gk.hotwork.Domain.UserInfo;
|
import com.gk.hotwork.Mapper.CompanyInfoMapper;
|
import com.gk.hotwork.Mapper.SafetyFacilityInspectionMapper;
|
import com.gk.hotwork.Mapper.SafetyFacilityProcessflowMapper;
|
import com.gk.hotwork.Mapper.UserInfoMapper;
|
import com.gk.hotwork.Service.SafetyFacilityInspectionService;
|
|
@Service("SafetyFacilityInspectionService")
|
@Transactional
|
public class SafetyFacilityInspectionImpl extends ServiceImpl<SafetyFacilityInspectionMapper, SafetyFacilityInspection>
|
implements SafetyFacilityInspectionService {
|
|
@Autowired
|
private SafetyFacilityInspectionMapper safetyFacilityInspectionMapper;
|
|
@Autowired
|
private SafetyFacilityProcessflowMapper safetyFacilityProcessflowMapper;
|
|
@Autowired
|
private UserInfoMapper userInfoMapper;
|
|
@Autowired
|
private CompanyInfoMapper companyInfoMapper;
|
|
@Override
|
public IPage<SafetyFacilityInspection> selectPage(Page<SafetyFacilityInspection> page, Map<String, Object> filter,
|
UserInfo user) {
|
Date date = new Date();
|
|
if (user.getType() == 3 ) {
|
filter.put("createBy", user.getUsername());
|
}
|
if (user.getType() == 4) {
|
filter.put("expert", user.getId());
|
}
|
if (user.getType() == 2) {
|
QueryWrapper<CompanyInfo> queryWrapper = new QueryWrapper<CompanyInfo>();
|
queryWrapper.eq("city", user.getCity());
|
queryWrapper.eq("province", user.getProvince());
|
List<CompanyInfo> list = companyInfoMapper.selectList(queryWrapper);
|
List<String> companyList = new ArrayList<String>();
|
for (CompanyInfo companyInfo : list) {
|
companyList.add(companyInfo.getCompany());
|
}
|
filter.put("company", companyList);
|
}
|
if("安科院".equals(user.getCompany())){
|
filter.remove("createBy");
|
filter.remove("company");
|
}
|
|
IPage<SafetyFacilityInspection> res = safetyFacilityInspectionMapper.selectPages(page, filter);
|
List<SafetyFacilityInspection> list = new ArrayList<SafetyFacilityInspection>();
|
for (SafetyFacilityInspection safetyFacilityInspection : res.getRecords()) {
|
if (safetyFacilityInspection.getProgress() == 10 && safetyFacilityInspection.getReviewTime() != null && safetyFacilityInspection.getReviewTime().before(date)) {
|
safetyFacilityInspection.setProgress(11);
|
this.updateById(safetyFacilityInspection);
|
SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
|
flow.setCheckTime(new Date());
|
flow.setValidFlag(Byte.valueOf("1"));
|
flow.setCreateBy("SYSTEM");
|
flow.setUpdateTime(date);
|
flow.setCreateTime(date);
|
flow.setProgressName("评审中");
|
flow.setResult("预置时间到");
|
flow.setLinkInspectionId(safetyFacilityInspection.getId());
|
flow.setProcessBy(user.getRealname());
|
safetyFacilityProcessflowMapper.insert(flow);
|
safetyFacilityProcessflowMapper.modPending(safetyFacilityInspection.getId());
|
}
|
|
if (safetyFacilityInspection.getProgress() == 20 && safetyFacilityInspection.getExamineTime() != null && safetyFacilityInspection.getExamineTime().before(date)) {
|
safetyFacilityInspection.setProgress(21);
|
this.updateById(safetyFacilityInspection);
|
SafetyFacilityProcessflow flow = new SafetyFacilityProcessflow();
|
flow.setCheckTime(new Date());
|
flow.setValidFlag(Byte.valueOf("1"));
|
flow.setCreateBy("SYSTEM");
|
flow.setUpdateTime(date);
|
flow.setCreateTime(date);
|
flow.setProgressName("审查中");
|
flow.setResult("预置时间到");
|
flow.setLinkInspectionId(safetyFacilityInspection.getId());
|
flow.setProcessBy(user.getRealname());
|
safetyFacilityProcessflowMapper.insert(flow);
|
safetyFacilityProcessflowMapper.modPending(safetyFacilityInspection.getId());
|
}
|
|
if (safetyFacilityInspection.getExpert() != null) {
|
String[] expertIds = safetyFacilityInspection.getExpert().split(",");
|
String expertName = "";
|
List<UserInfo> temp = userInfoMapper.selectBatchIds(Arrays.asList(expertIds));
|
for (UserInfo userInfo : temp) {
|
expertName += "," + userInfo.getRealname();
|
}
|
safetyFacilityInspection.setExpertName(expertName.substring(1));
|
}
|
list.add(safetyFacilityInspection);
|
}
|
res.setRecords(list);
|
return res;
|
|
}
|
|
@Override
|
public void addOne(SafetyFacilityInspection param, UserInfo user) {
|
Date date = new Date();
|
String username = user.getUsername();
|
param.setValidFlag(Byte.valueOf("1"));
|
param.setCreateBy(username);
|
param.setUpdateTime(date);
|
param.setCreateTime(date);
|
param.setSubmitDate(param.getSubmitDate() == null ? date : param.getSubmitDate());
|
param.setProgress(Integer.valueOf(0));
|
param.setCompany(param.getCompany() == null ? user.getCompany() : param.getCompany());
|
this.save(param);
|
}
|
|
@Override
|
public void modOne(SafetyFacilityInspection param, UserInfo user) {
|
param.setUpdateTime(new Date());
|
this.updateById(param);
|
}
|
|
@Override
|
public void delOne(Long id, UserInfo user) {
|
SafetyFacilityInspection object = safetyFacilityInspectionMapper.selectByPrimaryKey(id);
|
object.setValidFlag(Byte.valueOf("0"));
|
object.setUpdateTime(new Date());
|
this.updateById(object);
|
|
}
|
|
@Override
|
public SafetyFacilityInspection selectByPrimaryKey(Long id, UserInfo user) {
|
return safetyFacilityInspectionMapper.selectByPrimaryKey(id);
|
}
|
}
|
