package com.doumee.service.business.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.model.LoginUserInfo;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.Constants.DeclareStatus;
|
import com.doumee.core.utils.Constants.ProjectRecord;
|
import com.doumee.core.utils.DateUtil;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.*;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.business.vo.DeclareServiceVo;
|
import com.doumee.dao.system.model.SystemUser;
|
import com.doumee.service.business.*;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.github.yulichang.query.MPJQueryWrapper;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.shiro.SecurityUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* 服务结构上传服务记录表Service实现
|
*
|
* @author 江蹄蹄
|
* @date 2023/02/15 08:55
|
*/
|
@Service
|
public class DeclareServiceServiceImpl implements DeclareServiceService {
|
|
@Autowired
|
private DeclareServiceMapper declareServiceMapper;
|
|
@Autowired
|
private DeclaresMapper declaresMapper;
|
|
@Autowired
|
private MultifileService multifileService;
|
|
@Autowired
|
private ProjectService projectService;
|
|
@Autowired
|
private DeclareDiagnoseMapper declareDiagnoseMapper;
|
|
@Autowired
|
private ProjectDiagnoseMapper projectDiagnoseMapper;
|
|
@Autowired
|
private DeclareHistoryMapper declareHistoryMapper;
|
@Autowired
|
private DeclareDoneMapper declareDoneMapper;
|
|
@Autowired
|
private DeclareServiceJoinMapper declareServiceJoinMapper;
|
@Autowired
|
private DeclaresJoinMapper declaresJoinMapper;
|
@Autowired
|
private DeclareExpertMapper declareExpertMapper;
|
|
@Autowired
|
private DeclareDiagnoseService declareDiagnoseService;
|
@Lazy
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
|
@Override
|
public Integer create(DeclareService declareService) {
|
declareServiceMapper.insert(declareService);
|
return declareService.getId();
|
}
|
|
@Override
|
public void deleteById(Integer id) {
|
declareServiceMapper.deleteById(id);
|
}
|
|
@Override
|
public void delete(DeclareService declareService) {
|
UpdateWrapper<DeclareService> deleteWrapper = new UpdateWrapper<>(declareService);
|
declareServiceMapper.delete(deleteWrapper);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<Integer> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
declareServiceMapper.deleteBatchIds(ids);
|
}
|
|
@Override
|
public void updateById(DeclareService declareService) {
|
declareServiceMapper.updateById(declareService);
|
}
|
|
@Override
|
public void updateByIdInBatch(List<DeclareService> declareServices) {
|
if (CollectionUtils.isEmpty(declareServices)) {
|
return;
|
}
|
for (DeclareService declareService : declareServices) {
|
this.updateById(declareService);
|
}
|
}
|
|
@Override
|
public DeclareService findById(Integer id) {
|
return declareServiceMapper.selectById(id);
|
}
|
|
@Override
|
public DeclareService findOne(DeclareService declareService) {
|
QueryWrapper<DeclareService> wrapper = new QueryWrapper<>(declareService);
|
return declareServiceMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<DeclareService> findList(DeclareService declareService) {
|
QueryWrapper<DeclareService> wrapper = new QueryWrapper<>(declareService);
|
return declareServiceMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<DeclareService> findPage(PageWrap<DeclareService> pageWrap) {
|
IPage<DeclareService> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<DeclareService> queryWrapper = new MPJLambdaWrapper<>();
|
pageWrap.getModel().setIsdeleted(Constants.ZERO);
|
queryWrapper.selectAll(DeclareService.class);
|
queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,DeclareService::getCreator);
|
queryWrapper.selectAs(SystemUser::getRealname,DeclareService::getCreatorName);
|
Utils.MP.blankToNull(pageWrap.getModel());
|
if (pageWrap.getModel().getId() != null) {
|
queryWrapper.eq(DeclareService::getId, pageWrap.getModel().getId());
|
}
|
if (pageWrap.getModel().getCreator() != null) {
|
queryWrapper.eq(DeclareService::getCreator, pageWrap.getModel().getCreator());
|
}
|
if (pageWrap.getModel().getCreateDate() != null) {
|
queryWrapper.ge(DeclareService::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
|
queryWrapper.le(DeclareService::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
|
}
|
if (pageWrap.getModel().getEditor() != null) {
|
queryWrapper.eq(DeclareService::getEditor, pageWrap.getModel().getEditor());
|
}
|
if (pageWrap.getModel().getEditDate() != null) {
|
queryWrapper.ge(DeclareService::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
|
queryWrapper.le(DeclareService::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
|
}
|
if (pageWrap.getModel().getIsdeleted() != null) {
|
queryWrapper.eq(DeclareService::getIsdeleted, pageWrap.getModel().getIsdeleted());
|
}
|
if (pageWrap.getModel().getRemark() != null) {
|
queryWrapper.eq(DeclareService::getRemark, pageWrap.getModel().getRemark());
|
}
|
if (pageWrap.getModel().getDeclareId() != null) {
|
queryWrapper.eq(DeclareService::getDeclareId, pageWrap.getModel().getDeclareId());
|
}
|
if (pageWrap.getModel().getContent() != null) {
|
queryWrapper.eq(DeclareService::getContent, pageWrap.getModel().getContent());
|
}
|
if (pageWrap.getModel().getServiceDate() != null) {
|
queryWrapper.ge(DeclareService::getServiceDate, Utils.Date.getStart(pageWrap.getModel().getServiceDate()));
|
queryWrapper.le(DeclareService::getServiceDate, Utils.Date.getEnd(pageWrap.getModel().getServiceDate()));
|
}
|
if (pageWrap.getModel().getStatus() != null) {
|
queryWrapper.eq(DeclareService::getStatus, pageWrap.getModel().getStatus());
|
}
|
if (pageWrap.getModel().getType() != null) {
|
queryWrapper.eq(DeclareService::getType, pageWrap.getModel().getType());
|
}
|
for (PageWrap.SortData sortData : pageWrap.getSorts()) {
|
if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
|
queryWrapper.orderByDesc(sortData.getProperty());
|
} else {
|
queryWrapper.orderByAsc(sortData.getProperty());
|
}
|
}
|
IPage<DeclareService> result = declareServiceJoinMapper.selectJoinPage(page,DeclareService.class,queryWrapper);
|
if (result.getRecords().size() > 0) {
|
String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.PROJECT_FILE).getCode();
|
for (int i = 0; i < result.getRecords().size(); i++) {
|
DeclareService query = result.getRecords().get(i);
|
Multifile mu = new Multifile();
|
mu.setIsdeleted(Constants.ZERO);
|
mu.setObjId(query.getId());
|
// mu.setType(Constants.TWO);
|
// mu.setObjType(Constants.MultiFile.BUSINESS_UP_SERVICE.getKey());
|
mu.setTypeList(new ArrayList<>());
|
if(Constants.equalsInteger(query.getType(),Constants.ONE)){
|
mu.getTypeList().add(Constants.MultiFile.BUSINESS_HC.getKey());
|
mu.getTypeList().add(Constants.MultiFile.BUSINESS_HC_EXTRA.getKey());
|
}else{
|
mu.getTypeList().add(Constants.MultiFile.BUSINESS_UP_SERVICE.getKey());
|
mu.getTypeList().add(Constants.MultiFile.BUSINESS_UP_EXTRA.getKey());
|
}
|
List<Multifile> allList = multifileService.findList(mu);
|
List<Multifile> filelist = new ArrayList<>();
|
List<Multifile> extralist = new ArrayList<>();
|
if(allList!=null){
|
allList.forEach(r->{
|
if(StringUtils.isNoneBlank(r.getFileurl())){
|
r.setFileurlfull(path+r.getFileurl());
|
}
|
if(Constants.equalsInteger(query.getType(),Constants.ONE)){
|
if(Constants.equalsInteger(Constants.MultiFile.BUSINESS_HC.getKey(),r.getObjType())){
|
filelist.add(r);
|
}
|
if( Constants.equalsInteger(Constants.MultiFile.BUSINESS_HC_EXTRA.getKey(),r.getObjType())){
|
extralist.add(r);
|
}
|
}
|
if(Constants.equalsInteger(query.getType(),Constants.ZERO)){
|
if(Constants.equalsInteger(Constants.MultiFile.BUSINESS_UP_SERVICE.getKey(),r.getObjType())){
|
filelist.add(r);
|
}
|
if( Constants.equalsInteger(Constants.MultiFile.BUSINESS_UP_EXTRA.getKey(),r.getObjType())){
|
extralist.add(r);
|
}
|
}
|
});
|
}
|
query.setFileList(filelist);
|
query.setFileExtraList(extralist);
|
}
|
}
|
return PageData.from(result);
|
}
|
|
@Override
|
public long count(DeclareService declareService) {
|
QueryWrapper<DeclareService> wrapper = new QueryWrapper<>(declareService);
|
return declareServiceMapper.selectCount(wrapper);
|
}
|
@Override
|
public List<DeclareDone> doneServiceList(DeclareService declareService){
|
DeclareServiceVo dsv = new DeclareServiceVo();
|
dsv.setDeclareId(declareService.getDeclareId());
|
List<DeclareDone> finishServiceData = getFinishServiceData(dsv);
|
if(finishServiceData!=null){
|
finishServiceData.forEach(s->{
|
Multifile mf = new Multifile();
|
mf.setIsdeleted(Constants.ZERO);
|
mf.setObjId(s.getId());
|
//完成服务资料 企业评分
|
mf.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS_EXTRA.getKey());
|
List<Multifile> fileExtraList =getMultiFileList(mf);
|
s.setFileExtraList(fileExtraList);
|
mf.setObjType(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
List<Multifile> fileScoreList =getMultiFileList(mf);
|
s.setFileScoreList(fileScoreList);
|
mf.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
List<Multifile> fileDiagnosisList =getMultiFileList(mf);
|
s.setFileDiagnosisList(fileDiagnosisList);
|
DeclareDiagnose dd=new DeclareDiagnose();
|
dd.setIsdeleted(Constants.ZERO);
|
dd.setDeclareId(s.getId());
|
List<DeclareDiagnose> ddList= declareDiagnoseService.findList(dd);
|
s.setDeclareDiagnoseList(ddList);
|
});
|
}
|
return finishServiceData;
|
}
|
|
@Override
|
public List<DeclareService> findByDeclareId(DeclareService declareService) {
|
|
if(declareService.getDeclareId()== null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
Declares declares = declaresMapper.selectById(declareService.getDeclareId());
|
if(declares==null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
|
QueryWrapper<DeclareDone> wrapper = new QueryWrapper<>();
|
wrapper.lambda().eq(DeclareDone::getDeclareId,declareService.getDeclareId())
|
.orderByDesc(DeclareDone::getCreateDate);
|
List<DeclareDone> declareDones = declareDoneMapper.selectList(wrapper);
|
|
|
QueryWrapper<DeclareHistory> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(DeclareHistory::getDeclareId,declareService.getDeclareId())
|
.eq(DeclareHistory::getStatus, DeclareStatus.BACK_SERVER_ING.getKey())
|
.orderByDesc(DeclareHistory::getCreateDate);
|
List<DeclareService> list = new ArrayList<>();
|
for (DeclareDone s : declareDones){
|
DeclareService service = new DeclareService();
|
service.setDiagnoseScore(s.getDiagnoseScore());
|
service.setDiagnoseDate(s.getDiagnoseDate());
|
service.setDeclareStatus(declares.getStatus());
|
//查询完成服务数据
|
Multifile mf = new Multifile();
|
mf.setType(Constants.TWO);
|
mf.setObjId(s.getId());
|
// BeanUtils.copyProperties(list.get(0), dsv);
|
//完成服务资料 企业评分
|
mf.setObjType(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
service.setFileScoreList(getMultiFileList(mf));
|
//完成服务资料 诊断报告
|
mf.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
service.setFileDiagnosisList(getMultiFileList(mf));
|
if(Constants.formatIntegerNum(declares.getStatus()) >= DeclareStatus.SERVICE_DONE.getKey()){
|
//如果已经完成服务，则返回实际填写数据，诊断填写信息
|
DeclareDiagnose dd=new DeclareDiagnose();
|
dd.setIsdeleted(Constants.ZERO);
|
dd.setDeclareId(declareService.getDeclareId());
|
List<DeclareDiagnose> ddList= declareDiagnoseService.findList(dd);
|
declareService.setDeclareDiagnoseList(ddList);
|
}
|
list.add(service);
|
};
|
// list.add(findByDeclareId2(declareService));
|
return list;
|
}
|
|
@Override
|
public DeclareService findByDeclareId2(DeclareService declareService) {
|
if(declareService.getDeclareId()== null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
Declares declares = declaresMapper.selectById(declareService.getDeclareId());
|
if(declares==null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
|
ProjectDiagnose p = new ProjectDiagnose();
|
p.setProjectId(declares.getProjectId());
|
p.setIsdeleted(Constants.ZERO);
|
QueryWrapper<ProjectDiagnose> wrapper1 = new QueryWrapper<>(p);
|
wrapper1.lambda().orderByAsc(ProjectDiagnose::getSortnum);
|
DeclareDone declareDone = null;
|
if(Constants.formatIntegerNum(declares.getStatus()) >= DeclareStatus.SERVICE_DONE.getKey()){
|
//如果已经完成服务，则返回实际填写数据，诊断填写信息
|
/* DeclareDiagnose dd=new DeclareDiagnose();
|
dd.setIsdeleted(Constants.ZERO);
|
dd.setDeclareId(declareService.getDeclareId());
|
List<DeclareDiagnose> ddList= declareDiagnoseService.findList(dd);
|
declareService.setDeclareDiagnoseList(ddList);*/
|
|
QueryWrapper<DeclareDone> wrapper = new QueryWrapper<>();
|
wrapper.lambda().eq(DeclareDone::getDeclareId,declareService.getDeclareId())
|
.orderByDesc(DeclareDone::getCreateDate).last("limit 1");
|
|
|
declareDone = declareDoneMapper.selectOne(wrapper);
|
|
if (Objects.nonNull(declareDone)){
|
declareService.setDiagnoseDate(declareDone.getDiagnoseDate());
|
declareService.setDiagnoseScore(declareDone.getDiagnoseScore());
|
Multifile query = new Multifile();
|
query.setIsdeleted(Constants.ZERO);
|
query.setObjId(declareDone.getId());
|
//完成服务资料 企业评分
|
query.setObjType(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
List<Multifile> fileList =getMultiFileList(query);
|
declareService.setFileExtraList(fileList);
|
|
//完成服务资料 企业评分
|
query.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS_EXTRA.getKey());
|
List<Multifile> fileExtraList =getMultiFileList(query);
|
declareService.setFileExtraList(fileExtraList);
|
|
query.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
List<Multifile> fileDiagnosisList =getMultiFileList(query);
|
declareService.setFileDiagnosisList(fileDiagnosisList);
|
|
}
|
|
}else{
|
QueryWrapper<DeclareDone> wrapper = new QueryWrapper<>();
|
wrapper.lambda()
|
.eq(DeclareDone::getIsdeleted,Constants.ZERO)
|
.eq(DeclareDone::getDeclareId,declareService.getDeclareId())
|
.orderByDesc(DeclareDone::getCreateDate).last("limit 1");
|
|
declareDone = declareDoneMapper.selectOne(wrapper);
|
|
|
/*ProjectDiagnose p = new ProjectDiagnose();
|
p.setProjectId(declares.getProjectId());
|
p.setIsdeleted(Constants.ZERO);
|
QueryWrapper<ProjectDiagnose> wrapper1 = new QueryWrapper<>(p);
|
if (Objects.nonNull(declareDone)){
|
wrapper1.select("*,(select b.content from declare_diagnose b where b.isdeleted=0 and b.declare_id="+declareDone.getId()+" and b.diagnose_id=project_diagnose.id) as saveContent");
|
}
|
wrapper1.lambda().orderByAsc(ProjectDiagnose::getSortnum);
|
List<ProjectDiagnose> pList = projectDiagnoseMapper.selectList(wrapper1);*/
|
|
|
if (Objects.nonNull(declareDone)){
|
declareService.setDiagnoseDate(declareDone.getDiagnoseDate());
|
declareService.setDiagnoseScore(declareDone.getDiagnoseScore());
|
Multifile query = new Multifile();
|
query.setIsdeleted(Constants.ZERO);
|
query.setObjId(declareDone.getId());
|
//完成服务资料 企业评分
|
query.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS_EXTRA.getKey());
|
List<Multifile> fileList =getMultiFileList(query);
|
declareService.setFileExtraList(fileList);
|
|
query.setObjType(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
List<Multifile> fileScoreList =getMultiFileList(query);
|
declareService.setFileScoreList(fileScoreList);
|
|
query.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
List<Multifile> fileDiagnosisList =getMultiFileList(query);
|
declareService.setFileDiagnosisList(fileDiagnosisList);
|
|
DeclareDiagnose dd=new DeclareDiagnose();
|
dd.setIsdeleted(Constants.ZERO);
|
dd.setDeclareId(declareDone.getId());
|
List<DeclareDiagnose> ddList= declareDiagnoseService.findList(dd);
|
declareService.setDeclareDiagnoseList(ddList);
|
}
|
|
}
|
if(CollectionUtils.isEmpty(declareService.getDeclareDiagnoseList())){
|
if (Objects.nonNull(declareDone)) {
|
wrapper1.select("*,(select b.content from declare_diagnose b where b.isdeleted=0 and b.declare_id=" + declareDone.getId() + " and b.diagnose_id=project_diagnose.id) as saveContent");
|
}
|
List<ProjectDiagnose> pList = projectDiagnoseMapper.selectList(wrapper1);
|
if(pList!=null && pList.size()>0 && CollectionUtils.isEmpty(declareService.getDeclareDiagnoseList())){
|
List<DeclareDiagnose> dpList = null;
|
for(ProjectDiagnose d : pList){
|
DeclareDiagnose t = new DeclareDiagnose();
|
t.setDiagnoseId(d.getId());
|
t.setName(d.getName());
|
t.setContent(StringUtils.defaultString(d.getSaveContent(),d.getContent()));
|
if(dpList == null){
|
dpList = new ArrayList<>();
|
}
|
dpList.add(t);
|
}
|
declareService.setDeclareDiagnoseList(dpList);
|
}
|
}
|
|
return declareService;
|
}
|
public DeclareService findByDeclareId3(DeclareService declareService) {
|
if(declareService.getDeclareId()== null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
Declares declares = declaresMapper.selectById(declareService.getDeclareId());
|
if(declares==null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
|
if(Constants.formatIntegerNum(declares.getStatus()) >= DeclareStatus.SERVICE_DONE.getKey()){
|
//如果已经完成服务，则返回实际填写数据，诊断填写信息
|
/* DeclareDiagnose dd=new DeclareDiagnose();
|
dd.setIsdeleted(Constants.ZERO);
|
dd.setDeclareId(declareService.getDeclareId());
|
List<DeclareDiagnose> ddList= declareDiagnoseService.findList(dd);
|
declareService.setDeclareDiagnoseList(ddList);*/
|
|
QueryWrapper<DeclareDone> wrapper = new QueryWrapper<>();
|
wrapper.lambda().eq(DeclareDone::getDeclareId,declareService.getDeclareId())
|
.orderByDesc(DeclareDone::getCreateDate).last("limit 1");
|
|
|
DeclareDone declareDone = declareDoneMapper.selectOne(wrapper);
|
|
if (Objects.nonNull(declareDone)){
|
declareService.setDiagnoseDate(declareDone.getDiagnoseDate());
|
declareService.setDiagnoseScore(declareDone.getDiagnoseScore());
|
Multifile query = new Multifile();
|
query.setIsdeleted(Constants.ZERO);
|
query.setObjId(declareDone.getId());
|
//完成服务资料 企业评分
|
query.setObjType(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
List<Multifile> fileList =getMultiFileList(query);
|
declareService.setFileExtraList(fileList);
|
|
//完成服务资料 企业评分
|
query.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS_EXTRA.getKey());
|
List<Multifile> fileExtraList =getMultiFileList(query);
|
declareService.setFileExtraList(fileExtraList);
|
|
query.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
List<Multifile> fileDiagnosisList =getMultiFileList(query);
|
declareService.setFileDiagnosisList(fileDiagnosisList);
|
|
}
|
|
}else{
|
ProjectDiagnose p = new ProjectDiagnose();
|
p.setProjectId(declares.getProjectId());
|
p.setIsdeleted(Constants.ZERO);
|
List<ProjectDiagnose> pList = projectDiagnoseMapper.selectList(
|
new QueryWrapper<>(p)
|
// .select("*,(select b.content from declare_diagnose b where b.isdeleted=0 and b.declare_id="+declares.getId()+" and b.diagnose_id=project_diagnose.id) as saveContent")
|
.lambda().orderByAsc(ProjectDiagnose::getSortnum));
|
|
|
QueryWrapper<DeclareDone> wrapper = new QueryWrapper<>();
|
wrapper.lambda()
|
.eq(DeclareDone::getIsdeleted,Constants.ZERO)
|
.eq(DeclareDone::getDeclareId,declareService.getDeclareId())
|
.orderByDesc(DeclareDone::getCreateDate).last("limit 1");
|
|
|
DeclareDone declareDone = declareDoneMapper.selectOne(wrapper);
|
if (Objects.nonNull(declareDone)){
|
declareService.setDiagnoseDate(declareDone.getDiagnoseDate());
|
declareService.setDiagnoseScore(declareDone.getDiagnoseScore());
|
Multifile query = new Multifile();
|
query.setIsdeleted(Constants.ZERO);
|
query.setObjId(declareDone.getId());
|
//完成服务资料 企业评分
|
query.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS_EXTRA.getKey());
|
List<Multifile> fileList =getMultiFileList(query);
|
declareService.setFileExtraList(fileList);
|
|
query.setObjType(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
List<Multifile> fileScoreList =getMultiFileList(query);
|
declareService.setFileScoreList(fileScoreList);
|
|
query.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
List<Multifile> fileDiagnosisList =getMultiFileList(query);
|
declareService.setFileDiagnosisList(fileDiagnosisList);
|
|
DeclareDiagnose dd=new DeclareDiagnose();
|
dd.setIsdeleted(Constants.ZERO);
|
dd.setDeclareId(declareDone.getId());
|
List<DeclareDiagnose> ddList= declareDiagnoseService.findList(dd);
|
declareService.setDeclareDiagnoseList(ddList);
|
}
|
|
if(pList!=null && pList.size()>0 && CollectionUtils.isEmpty(declareService.getDeclareDiagnoseList())){
|
List<DeclareDiagnose> dpList = null;
|
for(ProjectDiagnose d : pList){
|
DeclareDiagnose t = new DeclareDiagnose();
|
t.setDiagnoseId(d.getId());
|
t.setName(d.getName());
|
t.setContent(StringUtils.defaultString(d.getSaveContent(),d.getContent()));
|
if(dpList == null){
|
dpList = new ArrayList<>();
|
}
|
dpList.add(t);
|
}
|
declareService.setDeclareDiagnoseList(dpList);
|
}
|
}
|
return declareService;
|
}
|
|
|
/**
|
* 上传核查资料
|
*
|
* @param declareService
|
*/
|
@Override
|
public void uploadHCData(DeclareService declareService) throws BusinessException {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if (declareService.getDeclareId() == null
|
|| declareService.getStatus() == null
|
|| declareService.getType() == null) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
if (declareService.getStatus().intValue() == 1 && (
|
declareService.getServiceDate() == null
|
|| CollectionUtils.isEmpty(declareService.getFileList()))) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
/*
|
if (declareService.getStatus().intValue() == 0 && (
|
StringUtils.isEmpty(declareService.getDiagnoseDate())
|
&& CollectionUtils.isEmpty(declareService.getFileList()) )) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
*/
|
Declares declares = declaresMapper.selectById(declareService.getDeclareId());
|
//判断当前操作是否合法
|
isOptionValid(declares,user,declareService.getType());
|
Declares updateModel = new Declares();
|
DeclareService ingModel = getIngServiceData(declareService);
|
DeclareHistory history= new DeclareHistory();
|
if(Constants.equalsInteger(declareService.getType(),Constants.ONE)){
|
//综合服务单位诊断资料上传
|
sdUploadFiles( declares,declareService,user,ingModel,history);
|
}else{
|
//服务机构上传服务资料
|
soUploadFiles( declares,updateModel,declareService,user,ingModel,history);
|
}
|
if(history!=null && history.getCreateDate()!=null){
|
String checkinfo = history.getCheckInfo().replace("${param2}", Constants.UserType.getInfo(user.getType()))
|
.replace("${param3}", StringUtils.defaultString(user.getRealname(),""))
|
.replace("${param4}", Constants.DeclareStatus.getInfo(declares.getStatus()));
|
history.setCheckInfo(checkinfo);
|
}
|
if(updateModel.getEditDate()!=null){
|
//如果需要更新主表，这更新
|
updateModel.setCheckInfo(history.getCheckInfo());
|
updateModel.setCheckor(history.getCheckor());
|
updateModel.setCheckType(history.getType());
|
declaresMapper.updateById(updateModel);
|
}
|
dealFiles(declareService,ingModel,user);
|
}
|
|
private void dealFiles(DeclareService declareService, DeclareService ingModel, LoginUserInfo user) {
|
// Integer objType = Constants.MultiFile.BUSINESS_UP_SERVICE.getKey();
|
// if (Constants.equalsInteger(declareService.getType(),Constants.ONE )) {
|
// //综合单位上传核查资料
|
// objType =(Constants.MultiFile.BUSINESS_HC.getKey());
|
// }
|
if(ingModel != null){
|
//删除原有的附件
|
Multifile multifile = new Multifile();
|
multifile.setIsdeleted(Constants.ZERO);
|
multifile.setObjId(declareService.getId());
|
multifile.setTypeList(new ArrayList<>());
|
//删除企业评分上传
|
multifile.getTypeList().add(Constants.equalsInteger(declareService.getType(),Constants.ONE)? Constants.MultiFile.BUSINESS_HC.getKey(): Constants.MultiFile.BUSINESS_UP_SERVICE.getKey());
|
//删除诊断报告上传
|
multifile.getTypeList().add(Constants.equalsInteger(declareService.getType(),Constants.ONE)? Constants.MultiFile.BUSINESS_HC_EXTRA.getKey(): Constants.MultiFile.BUSINESS_UP_EXTRA.getKey());
|
// multifile.setObjType(objType);
|
multifileService.delete(multifile);
|
}
|
for(Multifile table : declareService.getFileList()){
|
//录入新增的附件
|
table.setIsdeleted(Constants.ZERO);
|
table.setCreateDate(new Date());
|
table.setObjId(declareService.getId());
|
table.setType(Constants.TWO);
|
table.setObjType(Constants.equalsInteger(declareService.getType(),Constants.ONE)? Constants.MultiFile.BUSINESS_HC.getKey(): Constants.MultiFile.BUSINESS_UP_SERVICE.getKey());
|
multifileService.create(table);
|
}
|
if(declareService.getFileExtraList() !=null ){
|
for(Multifile table : declareService.getFileExtraList()){
|
//录入新增的附件
|
table.setIsdeleted(Constants.ZERO);
|
table.setCreateDate(new Date());
|
table.setObjId(declareService.getId());
|
table.setType(Constants.TWO);
|
table.setObjType(Constants.equalsInteger(declareService.getType(),Constants.ONE)? Constants.MultiFile.BUSINESS_HC_EXTRA.getKey(): Constants.MultiFile.BUSINESS_UP_EXTRA.getKey());
|
multifileService.create(table);
|
}
|
}
|
|
}
|
|
/**
|
* 服务机构上传服务资料
|
* @param declares
|
* @param updateModel
|
* @param declareService
|
* @param user
|
* @param ingModel
|
* @param history
|
*/
|
private void soUploadFiles(Declares declares,Declares updateModel, DeclareService declareService, LoginUserInfo user, DeclareService ingModel, DeclareHistory history) {
|
Date date = new Date();
|
if(Constants.equalsInteger(declareService.getStatus(),Constants.ONE)){
|
//如果是保存，判断是否首次，如果是首次更新申报记录状态
|
if (Constants.equalsInteger(declares.getStatus(), Constants.DeclareStatus.SELECTED_SO.getKey())) {
|
//为空 代表第一次上传 第一次上传更新declares 状态为诊断中
|
updateModel = new Declares();
|
updateModel.setId(declares.getId());
|
updateModel.setStatus(Constants.DeclareStatus.SERVING.getKey());
|
updateModel.setEditDate(date);
|
updateModel.setEditor(user.getId());
|
declaresMapper.updateById(updateModel);
|
}
|
history.setIsdeleted(Constants.ZERO);
|
history.setCreator(user.getId());
|
history.setCreateDate(date);
|
history.setDeclareId(declares.getId());
|
history.setCheckor(user.getId());
|
history.setType(ProjectRecord.SO_SERVICE_UPLOAD.getKey());
|
history.setCheckInfo(ProjectRecord.SO_SERVICE_UPLOAD.getNoteinfo());
|
//如果是提交
|
if(ingModel !=null){
|
//有历史数据,直接更新资料数据
|
declareService.setEditor(user.getId());
|
declareService.setEditDate(date);
|
declareService.setId(ingModel.getId());
|
declareService.setStatus(Constants.ONE);
|
declareService.setCreator(user.getId());
|
declareServiceMapper.updateById(declareService);
|
}else{
|
declareService.setCreator(user.getId());
|
declareService.setCreateDate(date);
|
declareService.setStatus(Constants.ONE);
|
declareService.setIsdeleted(Constants.ZERO);
|
declareServiceMapper.insert(declareService);
|
}
|
}else{
|
//如果是保存
|
if(ingModel !=null){
|
//有历史数据,直接更新资料数据
|
declareService.setEditor(user.getId());
|
declareService.setEditDate(date);
|
declareService.setId(ingModel.getId());
|
declareServiceMapper.updateById(declareService);
|
}else{
|
declareService.setCreator(user.getId());
|
declareService.setCreateDate(date);
|
declareService.setStatus(Constants.ZERO);
|
declareService.setIsdeleted(Constants.ZERO);
|
declareServiceMapper.insert(declareService);
|
}
|
}
|
}
|
/**
|
* 综合服务单位诊断资料上传
|
*/
|
private void sdUploadFiles(Declares declares, DeclareService declareService, LoginUserInfo user, DeclareService ingModel, DeclareHistory history) {
|
Date date =new Date();
|
if(Constants.equalsInteger(declareService.getStatus(),Constants.ONE)){
|
//如果是提交
|
history.setIsdeleted(Constants.ZERO);
|
history.setCreator(user.getId());
|
history.setCreateDate(date);
|
history.setDeclareId(declares.getId());
|
history.setCheckor(user.getId());
|
history.setType(ProjectRecord.SD_SERVICE_UPLOAD.getKey());
|
history.setCheckInfo(ProjectRecord.SD_SERVICE_UPLOAD.getNoteinfo());
|
if(ingModel !=null){
|
//有历史数据,直接更新资料数据
|
declareService.setEditor(user.getId());
|
declareService.setEditDate(date);
|
declareService.setId(ingModel.getId());
|
declareService.setStatus(Constants.ONE);
|
declareService.setCreator(user.getId());
|
declareServiceMapper.updateById(declareService);
|
}else{
|
declareService.setCreator(user.getId());
|
declareService.setCreateDate(date);
|
declareService.setStatus(Constants.ONE);
|
declareService.setIsdeleted(Constants.ZERO);
|
declareServiceMapper.insert(declareService);
|
}
|
}else{
|
//如果是保存
|
if(ingModel !=null){
|
//有历史数据,直接更新资料数据
|
declareService.setEditor(user.getId());
|
declareService.setEditDate(date);
|
declareService.setId(ingModel.getId());
|
declareServiceMapper.updateById(declareService);
|
}else{
|
declareService.setCreator(user.getId());
|
declareService.setCreateDate(date);
|
declareService.setStatus(Constants.ZERO);
|
declareService.setIsdeleted(Constants.ZERO);
|
declareServiceMapper.insert(declareService);
|
}
|
}
|
}
|
|
private DeclareService getIngServiceData(DeclareService declareService) {
|
DeclareService tp = new DeclareService();
|
tp.setType(declareService.getType());
|
tp.setIsdeleted(Constants.ZERO);
|
tp.setStatus(Constants.ZERO);
|
tp.setDeclareId(declareService.getDeclareId());
|
return declareServiceMapper.selectOne(new QueryWrapper<>(tp).last(" limit 1"));
|
}
|
|
private void isOptionValid(Declares declares, LoginUserInfo user,Integer type) {
|
if(Constants.equalsInteger(type,Constants.ONE)){
|
//综合服务单位诊断资料上传
|
if(!(Constants.formatIntegerNum(user.getType()) == Constants.UserType.SD_ADMIN.getKey()||
|
Constants.formatIntegerNum(user.getType()) == Constants.UserType.SD_CHILD.getKey())) {
|
//用户角色必须是综合服务单位
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您没有当前操作权限！");
|
}
|
if(Constants.formatIntegerNum(user.getType()) != Constants.UserType.SD_ADMIN.getKey()&&!(Constants.equalsInteger(declares.getSdUserId(),user.getId())&&
|
Constants.equalsInteger(user.getType() , Constants.UserType.SD_CHILD.getKey()))) {
|
//子账号只能操作自己负责的数据
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您没有当前操作权限！");
|
}
|
if(!(Constants.equalsInteger(declares.getStatus(), DeclareStatus.SELECTED_SO.getKey())||Constants.equalsInteger(declares.getStatus(), DeclareStatus.SERVING.getKey()))){
|
//只有诊断中的申报记录可进行该操作
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，该企业报名状态已流转，不允许当前操作！");
|
}
|
}else{
|
//服务机构上传服务资料
|
if(!Constants.equalsInteger(user.getCompanyId(),declares.getSoId())){
|
//只能操作分配到自己的数据记录
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您没有当前操作权限！");
|
}
|
if(!(Constants.formatIntegerNum(user.getType()) == Constants.UserType.SO_ADMIN.getKey()||
|
Constants.formatIntegerNum(user.getType()) == Constants.UserType.SO_CHILD.getKey())) {
|
//用户角色必须是服務机构
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您没有当前操作权限！");
|
}
|
if(Constants.formatIntegerNum(user.getType()) != Constants.UserType.SO_ADMIN.getKey()&&!(Constants.equalsInteger(declares.getSoUserId(),user.getId())&&
|
Constants.equalsInteger(user.getType() , Constants.UserType.SO_CHILD.getKey()))) {
|
//子账号只能操作自己负责的数据
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您没有当前操作权限！");
|
}
|
if(!(Constants.equalsInteger(declares.getStatus(), DeclareStatus.SERVING.getKey())
|
||Constants.equalsInteger(declares.getStatus(), DeclareStatus.SELECTED_SO.getKey())
|
||Constants.equalsInteger(declares.getStatus(), DeclareStatus.BACK_SERVER_ING.getKey()))){
|
//只有诊断中和已分配服务机构的申报记录可进行该操作
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，该企业报名状态已流转，不允许当前操作！");
|
}
|
|
}
|
}
|
|
|
/**
|
* 服务机构服务完成和保存
|
*
|
* @param declareService
|
*/
|
@Transactional(rollbackFor = {BusinessException.class, Exception.class})
|
@Override
|
public void finishHCData(DeclareService declareService) throws BusinessException {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if ( declareService.getDeclareId() == null ) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
Declares declares = declaresMapper.selectById(declareService.getDeclareId());
|
DeclareService queryds = new DeclareService();
|
queryds.setDeclareId(declares.getId());
|
queryds.setIsdeleted(Constants.ZERO);
|
queryds.setStatus(Constants.ONE);
|
List<DeclareService> dsList = declareServiceMapper.selectList(new QueryWrapper<>(queryds));
|
|
Project project = projectService.findById(declares.getProjectId());
|
//数据校验有效性
|
isfinishHCParamValid( declareService,declares,project, dsList,user,Constants.DeclareStatus.SERVING.getKey());
|
//更新诊断资料
|
DeclareDone doneModel = updataHCData(declareService,declares,user,Constants.ZERO);
|
//新增完成服务数据
|
fileHCUpload(declareService,user,doneModel);
|
}
|
|
/**
|
* 服务机构退回修改提交和保存
|
* @param declareService
|
* @throws BusinessException
|
*/
|
@Transactional(rollbackFor = {BusinessException.class, Exception.class})
|
@Override
|
public void editHCData(DeclareService declareService) throws BusinessException {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if ( declareService.getDeclareId() == null ) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
Declares declares = declaresMapper.selectById(declareService.getDeclareId());
|
Project project = projectService.findById(declares.getProjectId());
|
//数据校验有效性
|
isfinishHCParamValid( declareService,declares,project, null,user, DeclareStatus.BACK_SERVER_ING.getKey());;
|
//更新诊断资料
|
DeclareDone doneModel = updataHCData(declareService,declares,user,Constants.ONE);
|
//新增完成服务数据
|
fileHCUpload(declareService,user,doneModel);
|
|
}
|
|
|
/**
|
* 数据有效性校验 参
|
* @param declareService
|
* @param declares
|
* @param project
|
* @param user
|
*/
|
private void isfinishHCParamValid(DeclareService declareService, Declares declares, Project project, List<DeclareService> dsList, LoginUserInfo user,Integer status) {
|
if(declares == null ||Constants.equalsInteger(declares.getIsdeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，申报信息不存在，请返回刷新重试！");
|
}
|
if(project == null ){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，申报项目信息不存在，请返回刷新重试！");
|
}
|
if(declareService.getStatus() == null || declareService.getDeclareId() == null){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
if (Constants.equalsInteger(declareService.getStatus(),Constants.ONE) &&
|
( declareService.getDiagnoseDate() == null
|
// || declareService.getDiagnoseScore() == null
|
|| CollectionUtils.isEmpty(declareService.getFileDiagnosisList())
|
// || CollectionUtils.isEmpty(declareService.getFileScoreList())
|
)
|
) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
QueryWrapper<ProjectDiagnose> wrapper = new QueryWrapper<>();
|
wrapper.lambda().eq(ProjectDiagnose::getProjectId,project.getId());
|
wrapper.lambda().eq(ProjectDiagnose::getIsdeleted,Constants.ZERO);
|
Integer integer = projectDiagnoseMapper.selectCount(wrapper);
|
|
if (integer > Constants.ZERO && CollectionUtils.isEmpty(declareService.getDeclareDiagnoseList())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "项目配置诊断报告详情为必填项");
|
}
|
if(!Constants.equalsInteger(declareService.getStatus(),Constants.ZERO) && declareService.getDeclareDiagnoseList() !=null){
|
for (int i = 0; i < declareService.getDeclareDiagnoseList().size(); i++) {
|
DeclareDiagnose dd = declareService.getDeclareDiagnoseList().get(i);
|
|
ProjectDiagnose pd = projectDiagnoseMapper.selectById(dd.getDiagnoseId());
|
if(Objects.isNull(pd)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "对不起，诊断数据有误，请尝试返回刷新重试！");
|
}
|
if (dd.getDiagnoseId() == null || StringUtils.isEmpty(dd.getContent())) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
}
|
}
|
|
if (!Constants.equalsInteger(declares.getStatus(), status)) {
|
//诊断中状态可进行该操作
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，该申报信息状态已流转，不能进行该操作！");
|
}
|
//限制次数不配置表示不限制
|
if (Constants.equalsInteger(Constants.DeclareStatus.SERVING.getKey(),status) && Constants.formatIntegerNum(project.getServiceLimt() ) >0 &&( dsList == null ||dsList.size()<Constants.formatIntegerNum(project.getServiceLimt() ))) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "不允许完成服务，项目要求至少完成" +Constants.formatIntegerNum(project.getServiceLimt()) + "次资料上传");
|
}
|
}
|
|
public DeclareDone updataHCData(DeclareService declareService, Declares declares, LoginUserInfo user ,Integer doneType){
|
Date date = new Date();
|
//完成服务记录赋值----------start
|
DeclareDone declareDone = new DeclareDone();
|
declareDone.setCreator(user.getId());
|
declareDone.setCreateDate(date);
|
declareDone.setStatus(declareService.getStatus());
|
declareDone.setIsdeleted(Constants.ZERO);
|
declareDone.setDeclareId(declares.getId());
|
declareDone.setType(doneType);//第一次服务完成
|
declareDone.setDiagnoseScore(declareService.getDiagnoseScore());
|
declareDone.setDiagnoseDate(declareService.getDiagnoseDate());
|
|
//删除保存中数据
|
declareDoneMapper.update(null,new LambdaUpdateWrapper<>(new DeclareDone())
|
.eq(DeclareDone::getDeclareId,declareDone.getDeclareId())
|
.eq(DeclareDone::getIsdeleted,Constants.ZERO)
|
.eq(DeclareDone::getStatus,Constants.ZERO)
|
.set(DeclareDone::getIsdeleted,Constants.ONE));
|
|
//完成服务记录赋值----------end
|
if (Constants.equalsInteger(declareService.getStatus(), Constants.ONE)) {
|
//审核记录表
|
DeclareHistory declareHistory = new DeclareHistory();
|
declareHistory.setCreateDate(date);
|
declareHistory.setCreator(user.getId());
|
declareHistory.setIsdeleted(Constants.ZERO);
|
declareHistory.setCheckInfo(declares.getCheckInfo());
|
declareHistory.setDeclareId(declares.getId());
|
declareHistory.setCheckDate(date);
|
declareHistory.setCheckor(user.getId());
|
if(Constants.equalsInteger(Constants.ZERO,doneType)){
|
//如果是第一次完成服务
|
declareHistory.setType(Constants.ProjectRecord.SO_DONE_SERVICE.getKey());
|
declareHistory.setStatus(Constants.DeclareStatus.SERVICE_DONE.getKey());
|
declareHistory.setCheckInfo( ProjectRecord.SO_DONE_SERVICE.getNoteinfo().replace("${param2}", Constants.UserType.getName(user.getType()))
|
.replace("${param3}", StringUtils.defaultString(user.getUsername(),""))
|
.replace("${param4}",Constants.DeclareStatus.getNoteinfo(declareHistory.getStatus())));
|
}else{
|
//如果是服务退回修改重新提交
|
declareHistory.setType(ProjectRecord.SO_BACK_SUBMIT.getKey());
|
declareHistory.setStatus(DeclareStatus.BACK_SERVER_DONE.getKey());
|
declareHistory.setCheckInfo( ProjectRecord.SO_BACK_SUBMIT.getNoteinfo().replace("${param2}", Constants.UserType.getName(user.getType()))
|
.replace("${param3}", StringUtils.defaultString(user.getUsername(),""))
|
.replace("${param4}",Constants.DeclareStatus.getNoteinfo(declareHistory.getStatus())));
|
}
|
declareHistoryMapper.insert(declareHistory);
|
|
//提交 更改状态
|
declares.setStatus(declareHistory.getStatus());
|
declares.setCheckType(declareHistory.getType());
|
declares.setCheckDate(declareHistory.getCheckDate());
|
declares.setCheckInfo(declareHistory.getCheckInfo());
|
|
//如果提交状态,完成服务记录响应提交字段赋值
|
declareDone.setSubmitDate(date);
|
declareDone.setSubmitUserId(user.getId());
|
}
|
|
// declares.setDiagnoseScore(declareService.getDiagnoseScore());
|
// declares.setDiagnoseDate(declareService.getDiagnoseDate());
|
declares.setEditor(user.getId());
|
declares.setEditDate(date);
|
declaresMapper.updateById(declares);
|
|
return declareDone;
|
}
|
|
public void fileHCUpload(DeclareService declareService, LoginUserInfo user, DeclareDone doneModel ){
|
//完成服务记录数
|
declareDoneMapper.insert(doneModel);
|
|
Multifile mu1 = new Multifile();
|
mu1.setIsdeleted(Constants.ZERO);
|
mu1.setObjId(doneModel.getId());
|
mu1.setType(Constants.TWO);
|
mu1.setTypeList(new ArrayList<>());
|
//删除企业评分上传
|
mu1.getTypeList().add(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
//删除诊断报告上传
|
mu1.getTypeList().add(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
//删除诊断补充上传
|
mu1.getTypeList().add(Constants.MultiFile.BUSINESS_DIAGNOSIS_EXTRA.getKey());
|
//mu1.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
multifileService.delete(mu1);
|
|
//企业评分上传
|
if (!CollectionUtils.isEmpty(declareService.getFileScoreList())) {
|
|
declareService.getFileScoreList().forEach(table -> {
|
Multifile multifile = new Multifile();
|
multifile.setIsdeleted(Constants.ZERO);
|
multifile.setCreateDate(new Date());
|
multifile.setObjId(doneModel.getId());
|
multifile.setName(table.getName());
|
multifile.setType(Constants.TWO);
|
multifile.setFileurl(table.getFileurl());
|
multifile.setObjType(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
multifileService.create(multifile);
|
});
|
}
|
|
|
//诊断报告
|
if (!CollectionUtils.isEmpty(declareService.getFileDiagnosisList())) {
|
declareService.getFileDiagnosisList().forEach(table -> {
|
Multifile multifile = new Multifile();
|
multifile.setIsdeleted(Constants.ZERO);
|
multifile.setCreateDate(new Date());
|
multifile.setObjId(doneModel.getId());
|
multifile.setName(table.getName());
|
multifile.setType(Constants.TWO);
|
multifile.setFileurl(table.getFileurl());
|
multifile.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
multifileService.create(multifile);
|
});
|
}
|
|
if( !CollectionUtils.isEmpty(declareService.getFileExtraList())){
|
for(Multifile table : declareService.getFileExtraList()){
|
//录入新增的附件
|
table.setIsdeleted(Constants.ZERO);
|
table.setCreateDate(new Date());
|
table.setObjId(doneModel.getId());
|
table.setType(Constants.TWO);
|
table.setObjType( Constants.MultiFile.BUSINESS_DIAGNOSIS_EXTRA.getKey());
|
multifileService.create(table);
|
}
|
}
|
|
|
if(declareService.getDeclareDiagnoseList()!=null){
|
declareService.getDeclareDiagnoseList().stream().forEach(table -> {
|
|
DeclareDiagnose query=new DeclareDiagnose();
|
query.setIsdeleted(Constants.ZERO);
|
query.setDeclareId(doneModel.getId());
|
query.setDiagnoseId(table.getDiagnoseId());
|
DeclareDiagnose dd = declareDiagnoseMapper.selectOne(new QueryWrapper<>(query)
|
.last("limit 1")
|
);
|
ProjectDiagnose pd = projectDiagnoseMapper.selectById(table.getDiagnoseId());
|
table.setDeclareId(doneModel.getId());
|
table.setSortnum(pd.getSortnum());
|
table.setName(pd.getName());
|
if (dd!=null&&dd.getId() != null) {
|
table.setEditDate(new Date());
|
table.setEditor(user.getId());
|
table.setId(dd.getId());
|
declareDiagnoseMapper.updateById(table);
|
} else {
|
table.setCreateDate(new Date());
|
table.setCreator(user.getId());
|
table.setIsdeleted(Constants.ZERO);
|
declareDiagnoseMapper.insert(table);
|
}
|
});
|
}
|
|
|
}
|
|
|
/**
|
* 根据申报信息编码获取服务详情
|
*
|
* @param declareService
|
*/
|
@Override
|
public DeclareServiceVo serviceDetail(DeclareService declareService) throws BusinessException {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if(declareService.getDeclareId()==null){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "申报信息编码不能为空");
|
}
|
MPJLambdaWrapper<Declares> declaresMPJLambdaWrapper = new MPJLambdaWrapper<>();
|
declaresMPJLambdaWrapper.selectAll(Declares.class);
|
declaresMPJLambdaWrapper.leftJoin(Company.class,Company::getId,Declares::getSoId);
|
declaresMPJLambdaWrapper.leftJoin(Labels.class,Labels::getId,Company::getIndustryId);
|
declaresMPJLambdaWrapper.leftJoin(Labels.class,Labels::getId,Company::getNatureId);
|
declaresMPJLambdaWrapper.leftJoin(Labels.class,Labels::getId,Company::getLabelId);
|
declaresMPJLambdaWrapper.select("t2.name as indusrtyName ");
|
declaresMPJLambdaWrapper.select("t3.name as natureName ");
|
declaresMPJLambdaWrapper.select("t4.name as labelName ");
|
declaresMPJLambdaWrapper.selectAs(Company::getRegisterDate,Declares::getRegisterDate);
|
declaresMPJLambdaWrapper.selectAs(Company::getName,Declares::getCompanyName);
|
declaresMPJLambdaWrapper.selectAs(Company::getAreaId,Declares::getAreaId);
|
declaresMPJLambdaWrapper.selectAs(Company::getCreditCode,Declares::getCreditCode);
|
declaresMPJLambdaWrapper.selectAs(Company::getAddress,Declares::getAddress);
|
declaresMPJLambdaWrapper.eq(Declares::getId,declareService.getDeclareId());
|
//查询服务机构数据
|
Declares declares = declaresJoinMapper.selectJoinOne(Declares.class,declaresMPJLambdaWrapper.last("limit 1" ));
|
MPJLambdaWrapper<DeclareService> wrapper = new MPJLambdaWrapper<>();
|
wrapper.selectAll(DeclareService.class);
|
wrapper.selectAs(Declares::getDiagnoseScore,DeclareService::getDiagnoseScore);
|
wrapper.selectAs(Declares::getDiagnoseDate,DeclareService::getDiagnoseDate);
|
wrapper.selectAs(Declares::getStatus,DeclareService::getDeclareStatus);
|
wrapper.selectAs(SystemUser::getRealname,DeclareService::getCreatorName);
|
// wrapper.selectAs(Company::getName,DeclareService::getCompanyName);
|
// wrapper.selectAs(Company::getCreditCode,DeclareService::getCreditCode);
|
// wrapper.selectAs(Company::getAddress,DeclareService::getAddress);
|
// wrapper.selectAs(Company::getRegisterDate,DeclareService::getRegisterDate);
|
// wrapper.selectAs(Company::getLinkName,DeclareService::getLinkName);
|
// wrapper.selectAs(Company::getLinkPhone,DeclareService::getLinkPhone);
|
wrapper.leftJoin(Declares.class,Declares::getId,DeclareService::getDeclareId);
|
wrapper.leftJoin(Company.class,Company::getId,Declares::getCompanyId);
|
wrapper.leftJoin(SystemUser.class,SystemUser::getId,DeclareService::getCreator);
|
wrapper.eq(DeclareService::getDeclareId,declareService.getDeclareId());
|
wrapper.eq(DeclareService::getIsdeleted,Constants.ZERO);
|
wrapper.eq(DeclareService::getStatus,Constants.ONE);
|
// wrapper.eq(Declares::getIsdeleted,Constants.ZERO);
|
// wrapper.eq(Company::getIsdeleted,Constants.ZERO);
|
wrapper.orderByAsc(DeclareService::getCreateDate);
|
|
List<DeclareService> list = declareServiceJoinMapper.selectJoinList(DeclareService.class,wrapper);
|
DeclareServiceVo dsv=new DeclareServiceVo();
|
if(declares!=null){
|
//服务机构企业信息
|
dsv.setDeclareId(declareService.getDeclareId());
|
dsv.setCompanyName(declares.getCompanyName());
|
dsv.setAddress(declares.getAddress());
|
dsv.setCreditCode(declares.getCreditCode());
|
dsv.setRegisterDate(declares.getRegisterDate());
|
dsv.setNatureName(declares.getNatureName());
|
dsv.setIndusrtyName(declares.getIndusrtyName());
|
dsv.setLinkName(declares.getLinkname());
|
dsv.setLinkPhone(declares.getLinkphone());
|
// dsv.setDiagnoseDate(declares.getDiagnoseDate());
|
// dsv.setDiagnoseScore(Constants.formatBigdecimal(declares.getDiagnoseScore()));
|
dsv.setStatus(Constants.formatIntegerNum(declares.getStatus()));
|
dsv.setLabelName(declares.getLabelName());
|
if(Constants.equalsInteger(dsv.getStatus(), DeclareStatus.SERVICE_DONE.getKey())
|
||Constants.equalsInteger(dsv.getStatus(), DeclareStatus.SELECT_EXPERT.getKey())
|
||Constants.equalsInteger(dsv.getStatus(), DeclareStatus.DONE.getKey())){
|
dsv.setServiceDone(Constants.ONE);
|
}
|
}
|
|
//获取完成服务资料
|
getFinishServiceData(dsv);
|
|
//服务机构数据
|
List<DeclareService> dsServiceList=new ArrayList<>();
|
//诊断资料
|
List<DeclareService> dsZHList=new ArrayList<>();
|
Multifile mu = new Multifile();
|
list.stream().forEach(table -> {
|
mu.setObjId(table.getId());
|
Integer id = table.getId();
|
if(Constants.equalsInteger(table.getType(),Constants.ZERO)){
|
//服务资料上传数据
|
|
mu.setTypeList(new ArrayList<>());
|
mu.getTypeList().add(Constants.MultiFile.BUSINESS_UP_SERVICE.getKey());
|
mu.getTypeList().add(Constants.MultiFile.BUSINESS_UP_EXTRA.getKey());
|
List<Multifile> allList =getMultiFileList(mu);
|
if(allList !=null ){
|
List<Multifile> filelist = new ArrayList<>();
|
List<Multifile> extralist = new ArrayList<>();
|
allList.forEach(item -> {
|
if(Constants.equalsInteger(item.getObjType(),Constants.MultiFile.BUSINESS_UP_SERVICE.getKey())){
|
filelist.add(item);//服务资料
|
}else if(Constants.equalsInteger(item.getObjType(),Constants.MultiFile.BUSINESS_UP_EXTRA.getKey())){
|
extralist.add(item);//补充资料
|
}
|
});
|
table.setFileList(filelist);
|
table.setFileExtraList(extralist);
|
}
|
dsServiceList.add(table);
|
}else if(Constants.equalsInteger(table.getType(),Constants.ONE)){
|
//综合服务单位审核资料
|
mu.setTypeList(new ArrayList<>());
|
mu.getTypeList().add(Constants.MultiFile.BUSINESS_HC.getKey());
|
mu.getTypeList().add(Constants.MultiFile.BUSINESS_HC_EXTRA.getKey());
|
List<Multifile> allList =getMultiFileList(mu);
|
List<Multifile> filelist = new ArrayList<>();
|
List<Multifile> extralist = new ArrayList<>();
|
allList.forEach(item -> {
|
if(Constants.equalsInteger(item.getObjType(),Constants.MultiFile.BUSINESS_HC.getKey())){
|
filelist.add(item);//服务资料
|
}else if(Constants.equalsInteger(item.getObjType(),Constants.MultiFile.BUSINESS_HC_EXTRA.getKey())){
|
extralist.add(item);//补充资料
|
}
|
});
|
table.setFileDiagnosisList(filelist);
|
table.setFileExtraList(extralist);
|
|
dsZHList.add(table);
|
}
|
});
|
//获取专家评分数据
|
initExpertScoreRecode(dsv,declares,user);
|
|
dsv.setDsServiceList(dsServiceList);
|
if(Constants.equalsInteger(user.getType(),Constants.UserType.SJ.getKey())
|
||Constants.equalsInteger(user.getType(),Constants.UserType.SJ_CHILD.getKey())
|
|| Constants.equalsInteger(user.getType(),Constants.UserType.SD_ADMIN.getKey())
|
|| Constants.equalsInteger(user.getType(),Constants.UserType.SD_CHILD.getKey())
|
|| Constants.equalsInteger(user.getType(),Constants.UserType.COMPANY.getKey())){
|
//市局、综合服务单位查看核查资料
|
dsv.setDsZHList(dsZHList);
|
}
|
return dsv;
|
}
|
|
/**
|
* 获取专家评分数据
|
*/
|
private void initExpertScoreRecode(DeclareServiceVo dsv, Declares declares, LoginUserInfo user) {
|
if(Constants.equalsInteger(user.getType(),Constants.UserType.SJ.getKey())
|
||Constants.equalsInteger(user.getType(),Constants.UserType.SJ_CHILD.getKey())
|
|| Constants.equalsInteger(user.getType(),Constants.UserType.SO_ADMIN.getKey())
|
|| Constants.equalsInteger(user.getType(),Constants.UserType.SO_ADMIN.getKey())
|
|| Constants.equalsInteger(user.getType(),Constants.UserType.EXPERT.getKey())
|
|| Constants.equalsInteger(user.getType(),Constants.UserType.SD_ADMIN.getKey())
|
|| Constants.equalsInteger(user.getType(),Constants.UserType.SD_CHILD.getKey())){
|
//服务机构、专家、市局、综合服务单位查看专家评分数据
|
DeclareExpert declareExpert=new DeclareExpert();
|
declareExpert.setIsdeleted(Constants.ZERO);
|
declareExpert.setDeclareId(declares.getId());
|
DeclareExpert de= declareExpertMapper.selectOne(new QueryWrapper<>(declareExpert)
|
.select("declare_expert.* ,(select s.REALNAME from system_user s where s.id = declare_expert.EXPERT_ID and s.DELETED=0) as realZJName ")
|
.last("limit 1"));
|
if(de != null){
|
dsv.setDeclareExpert(de);
|
Multifile f = new Multifile();
|
f.setObjId(de.getId());
|
f.setObjType(Constants.MultiFile.BUSINESS_EXPERT.getKey());
|
dsv.setDeclareExpertFiles(getMultiFileList(f));
|
}
|
}
|
}
|
|
|
public List<Multifile> getMultiFileList(Multifile multifile){
|
multifile.setIsdeleted(Constants.ZERO);
|
List<Multifile> filelist = multifileService.findList(multifile);
|
if(filelist!=null && filelist.size()>0){
|
String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode();
|
path += systemDictDataBiz.queryByCode(Constants.OSS,Constants.PROJECT_FILE).getCode();
|
for(Multifile f : filelist){
|
if(StringUtils.isNoneBlank(f.getFileurl())){
|
f.setFileurlfull(path + f.getFileurl());
|
}
|
}
|
}
|
return filelist;
|
}
|
|
|
public List<DeclareDone> getFinishServiceData(DeclareServiceVo dsv ){
|
DeclareDone d = new DeclareDone();
|
d.setDeclareId(dsv.getDeclareId());
|
d.setIsdeleted(Constants.ZERO);
|
//查询完成服务数据
|
List<DeclareDone> list = declareDoneMapper.selectList(new QueryWrapper<>(d).lambda().orderByAsc(DeclareDone::getCreateDate));
|
if(list.size()>0){
|
Multifile mf = new Multifile();
|
mf.setIsdeleted(Constants.ZERO);
|
for(DeclareDone model :list){
|
mf.setObjId(model.getId());
|
//完成服务资料 企业评分
|
// mf.setObjType(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
mf.setTypeList(new ArrayList<>());
|
mf.getTypeList().add(Constants.MultiFile.BUSINESS_SCORE.getKey());
|
mf.getTypeList().add(Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey());
|
mf.getTypeList().add(Constants.MultiFile.BUSINESS_DIAGNOSIS_EXTRA.getKey());
|
|
List<Multifile> allFileList =getMultiFileList(mf);
|
List<Multifile> fileList =new ArrayList<>();
|
List<Multifile> extraList =new ArrayList<>();
|
List<Multifile> scoreList =new ArrayList<>();
|
if(allFileList!=null){
|
for(Multifile f :allFileList){
|
if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.BUSINESS_DIAGNOSIS.getKey())){
|
fileList.add(f);
|
}else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.BUSINESS_SCORE.getKey())){
|
scoreList.add(f);
|
}else{
|
//补充资料
|
extraList.add(f);
|
}
|
}
|
}
|
model.setFileDiagnosisList(fileList);
|
model.setFileScoreList(scoreList);
|
model.setFileExtraList(extraList);
|
//诊断填写信息
|
DeclareDiagnose dd=new DeclareDiagnose();
|
dd.setIsdeleted(Constants.ZERO);
|
dd.setDeclareId(model.getId());
|
List<DeclareDiagnose> ddList= declareDiagnoseService.findList(dd);
|
model.setDeclareDiagnoseList(ddList);
|
mf.setObjId(model.getId());
|
}
|
}
|
dsv.setDeclareDoneList(list);
|
return list;
|
}
|
|
}
|
