package com.doumee.service.business.impl; import com.alibaba.fastjson.JSONObject; 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.DateUtil; import com.doumee.core.utils.Utils; import com.doumee.core.utils.aliyun.ALiYunUtil; import com.doumee.dao.business.*; import com.doumee.dao.business.dto.CountCyclePriceDTO; import com.doumee.dao.business.dto.InsuranceApplyOptDTO; import com.doumee.dao.business.dto.InsuranceApplyQueryDTO; import com.doumee.dao.business.join.ApplyDetailJoinMapper; import com.doumee.dao.business.join.ApplyLogJoinMapper; import com.doumee.dao.business.join.InsuranceApplyJoinMapper; import com.doumee.dao.business.model.*; import com.doumee.dao.business.vo.CountCyclePriceVO; import com.doumee.dao.system.model.SystemUser; import com.doumee.service.business.InsuranceApplyService; 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.doumee.service.business.third.SignService; import com.github.xiaoymin.knife4j.core.util.CollectionUtils; import com.github.yulichang.wrapper.MPJLambdaWrapper; import com.jzq.common.bean.sign.NotifyDataReq; import io.swagger.models.auth.In; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; /** * 投保申请信息表Service实现 * @author 江蹄蹄 * @date 2024/01/16 10:03 */ @Service public class InsuranceApplyServiceImpl implements InsuranceApplyService { @Value("${debug_model}") private boolean debugModel; @Autowired private InsuranceApplyMapper insuranceApplyMapper; @Autowired private ApplyChangeMapper applyChangeMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private InsuranceApplyJoinMapper insuranceApplyJoinMapper; @Autowired private CompanyMapper companyMapper; @Autowired private ApplyDetailMapper applyDetailMapper; @Autowired private ApplyDetailJoinMapper applyDetailJoinMapper; @Autowired private ApplyLogMapper applyLogMapper; @Autowired private SignService signService; @Autowired private MultifileMapper multifileMapper; @Autowired private ApplyLogJoinMapper applyLogJoinMapper; @Autowired private SolutionsMapper solutionsMapper; @Autowired private MemberMapper memberMapper; @Autowired private DuSolutionMapper duSolutionMapper; @Autowired private DuWorktypeMapper duWorktypeMapper; @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer back(InsuranceApply insuranceApply) { if(insuranceApply.getId() == null ||StringUtils.isBlank(insuranceApply.getCheckInfo())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); InsuranceApply update = new InsuranceApply(); update.setEditDate(new Date()); update.setEditor(user.getId()); update.setStatus(Constants.InsuranceApplyStatus.FAIL_RETURN.getKey()); update.setCheckDate(update.getEditDate()); update.setCheckInfo(insuranceApply.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); insuranceApplyMapper.updateById(update); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.PLATFORM_RETURN; String info =applyLogType.getInfo(); info = info.replace("${param}", update.getCheckInfo()); ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return 1; } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer uploadBaoxiandan(InsuranceApply insuranceApply) { if(insuranceApply.getId() == null || insuranceApply.getCode() == null || insuranceApply.getStartTime() == null || insuranceApply.getBaoxiandanFile() == null ||StringUtils.isBlank( insuranceApply.getBaoxiandanFile() .getFileurl()) ||StringUtils.isBlank( insuranceApply.getBaoxiandanFile() .getName())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.SIGNATURE.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } if(model.getApplyEndTime()== null || model.getStartTime().getTime()>model.getApplyEndTime().getTime() ){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请生效周期时间不符合要求，请确认后修改重试~"); } //计算实际截止时间 Date actEndTime = new Date(model.getApplyEndTime().getTime() + (insuranceApply.getStartTime().getTime() - model.getApplyStartTime().getTime())); LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); InsuranceApply update = new InsuranceApply(); update.setEditDate(new Date()); update.setEditor(user.getId()); update.setStatus(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()); update.setCheckDate(update.getEditDate()); update.setCheckInfo(insuranceApply.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); update.setCode(insuranceApply.getCode()); update.setEndTime(actEndTime); update.setStartTime(insuranceApply.getStartTime()); insuranceApplyMapper.updateById(update); insuranceApply.getBaoxiandanFile().setIsdeleted(Constants.ZERO); insuranceApply.getBaoxiandanFile().setCreator(user.getId()); insuranceApply.getBaoxiandanFile().setObjId(update.getId()); insuranceApply.getBaoxiandanFile().setCreateDate(update.getEditDate()); insuranceApply.getBaoxiandanFile().setObjType(Constants.MultiFile.BD_DONE_PDF.getKey()); insuranceApply.getBaoxiandanFile().setType(Constants.TWO); multifileMapper.insert(insuranceApply.getBaoxiandanFile()); update.setBaoxiandanFile(insuranceApply.getBaoxiandanFile()); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.UPLOAD_INSURANCE; String info = ""; if(model.getApplyStartTime()!=null && model.getApplyStartTime().getTime()/1000!= insuranceApply.getStartTime().getTime()/1000){ info =applyLogType.getInfo(); info = info.replace("${param1}",DateUtil.getPlusTime2(model.getApplyEndTime())); info = info.replace("${param2}",DateUtil.getPlusTime2(insuranceApply.getStartTime())); } ApplyLog log = new ApplyLog(update,applyLogType.getName(), info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return 1; } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer editBaoxiandan(InsuranceApply param) { if(param.getId() == null || param.getCode() == null || param.getBaoxiandanFile() == null || param.getCheckInfo() == null ||StringUtils.isBlank( param.getBaoxiandanFile().getFileurl()) ||StringUtils.isBlank( param.getBaoxiandanFile() .getName())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } InsuranceApply model = insuranceApplyMapper.selectById(param.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请当前不支持该操作~"); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); InsuranceApply update = new InsuranceApply(); update.setEditDate(new Date()); update.setEditor(user.getId()); update.setCheckDate(update.getEditDate()); update.setCheckInfo(param.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); update.setCode(param.getCode()); insuranceApplyMapper.updateById(update); //删除原有的保单信息 multifileMapper.delete(new UpdateWrapper().lambda() .set(Multifile::getIsdeleted,Constants.ZERO) .eq(Multifile::getIsdeleted,Constants.ZERO) .eq(Multifile::getObjId,update.getId()) .eq(Multifile::getObjType,Constants.MultiFile.BD_DONE_PDF.getKey()) ); param.getBaoxiandanFile().setIsdeleted(Constants.ZERO); param.getBaoxiandanFile().setObjId(update.getId()); param.getBaoxiandanFile().setCreator(user.getId()); param.getBaoxiandanFile().setCreateDate(update.getEditDate()); param.getBaoxiandanFile().setObjType(Constants.MultiFile.BD_DONE_PDF.getKey()); param.getBaoxiandanFile().setType(Constants.TWO); multifileMapper.insert(param.getBaoxiandanFile()); update.setStatus(model.getStatus()); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.PALTFORM_EDIT_BD; String info = applyLogType.getInfo(); info = info.replace("${param}",param.getCheckInfo()); ApplyLog log = new ApplyLog(update,applyLogType.getName(), info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return 1; } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer dealBackApply(InsuranceApply insuranceApply) { if(insuranceApply.getId() == null ||StringUtils.isBlank(insuranceApply.getCheckInfo())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); Constants.ApplyLogType applyLogType = null; String info = ""; InsuranceApply update = new InsuranceApply(); if(insuranceApply.getDealBackApply() ==1){ //如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作 if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } applyLogType = Constants.ApplyLogType.PLATFORM_UN_AGREE_BACK; info = applyLogType.getInfo(); info = info.replace("${param}", insuranceApply.getCheckInfo()); update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey()); }else{ //如果是同意,两种申请退回状态都可操作 if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey()) ||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE.getKey()) ||Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD.getKey()))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } applyLogType = Constants.ApplyLogType.PLATFORM_AGREE_BACK; if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey())){ update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey()); }else if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE.getKey())){ update.setStatus(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey()); }else if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD.getKey())){ update.setStatus(Constants.InsuranceApplyStatus.UPLOAD.getKey()); } } update.setEditDate(new Date()); update.setEditor(user.getId()); update.setCheckDate(update.getEditDate()); update.setCheckInfo(insuranceApply.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); insuranceApplyMapper.updateById(update); ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return 1; } @Override public String getSignLink(Integer id) { if(id == null ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } MPJLambdaWrapper wrapper= new MPJLambdaWrapper() .selectAll(InsuranceApply.class) .selectAs(Solutions::getSignKeyword,InsuranceApply::getSignKeyword) .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .eq(InsuranceApply::getId,id) .last("limit 1"); InsuranceApply model = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); Constants.ApplyLogType applyLogType = null; String info = ""; //如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作 if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } Company company = user.getCompany(); if(debugModel){ company = companyMapper.selectById(model.getCompanyId()); } if(company== null || StringUtils.isBlank( company.getEmail()) || !Constants.equalsInteger(company.getSignStatus(),Constants.THREE)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，企业尚未具备在线签章条件，请联系平台管理员确认~"); } Multifile f = multifileMapper.selectOne(new QueryWrapper().lambda() .eq(Multifile::getObjId,model.getId()) .eq(Multifile::getObjType,Constants.MultiFile.BD_APPLY_PDF.getKey()) .eq(Multifile::getIsdeleted,Constants.ZERO).last("limit 1")); if(f == null || StringUtils.isBlank(f.getFileurl())){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取待签章文件失败，请联系平台管理员确认投保单是否正确！"); } String url = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode()+f.getFileurl(); String notifyUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SIGN_DONE_NOTIFY_URL).getCode(); notifyUrl = notifyUrl.replace("${type}","0").replace("${id}",model.getId().toString()); String applyNo = signService.applySign(company.getName(),url,company.getName(),company.getCode(),company.getEmail(),model.getSignKeyword(),company.getSignId(),notifyUrl); if(StringUtils.isBlank(applyNo) ){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！"); } String link = signService.signLink(applyNo,company.getName(),company.getCode()); if(StringUtils.isBlank(link) ){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！"); } InsuranceApply update= new InsuranceApply(); update.setId(model.getId()); update.setEditor(user.getId()); update.setEditDate(new Date()); update.setSignApplyNo(applyNo); insuranceApplyMapper.updateById(update); return link; } public String uploadSignFile(String link){ try { String bucketName = systemDictDataBiz.queryByCode(Constants.OSS,Constants.BUCKETNAME).getCode(); String access_id= systemDictDataBiz.queryByCode(Constants.OSS,Constants.ACCESS_ID).getCode(); String access_key= systemDictDataBiz.queryByCode(Constants.OSS,Constants.ACCESS_KEY).getCode(); String endpoint = systemDictDataBiz.queryByCode(Constants.OSS,Constants.ENDPOINT).getCode(); String folder = systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode(); String tempFileName = DateUtil.getNowShortDate() + "/" + UUID.randomUUID().toString() + ".pdf"; String key = folder + tempFileName;// 文件名 ALiYunUtil obs = new ALiYunUtil(endpoint,access_id, access_key); if (obs.uploadOnlineObject(link,bucketName, key,null)) { // 移动成功,返回文件名 return tempFileName; } }catch (Exception e){ } return null; } public Integer uploadSignedFileDo(InsuranceApply model,String fileurl) { InsuranceApply update = new InsuranceApply(); update.setEditDate(new Date()); update.setEditor(model.getCreator()); update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey()); update.setCheckDate(update.getEditDate()); update.setCheckInfo("企业完成签署"); update.setCheckUserId(model.getCreator()); update.setId(model.getId()); insuranceApplyMapper.updateById(update); Multifile f = new Multifile(); f.setIsdeleted(Constants.ZERO); f.setCreator(model.getCreator()); f.setObjId(update.getId()); f.setCreateDate(update.getEditDate()); f.setObjType(Constants.MultiFile.BD_SIGNED_PDF.getKey()); f.setType(Constants.TWO); f.setFileurl(fileurl); f.setName("投保单签约合同.pdf"); multifileMapper.insert(f); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.SIGNATURE; ApplyLog log = new ApplyLog(update,applyLogType.getName(), null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return 1; } public Integer uploadChangeSignedFileDo(ApplyChange model,String fileurl) { ApplyChange update = new ApplyChange(); update.setEditDate(new Date()); update.setEditor(model.getCreator()); update.setStatus(Constants.ApplyChangeStatus.SIGNATURE.getKey()); update.setCheckDate(update.getEditDate()); update.setCheckInfo("企业完成签署"); update.setCheckUserId(model.getCreator()); update.setId(model.getId()); applyChangeMapper.updateById(update); Multifile f = new Multifile(); f.setIsdeleted(Constants.ZERO); f.setCreator(model.getCreator()); f.setObjId(update.getId()); f.setCreateDate(update.getEditDate()); f.setObjType(Constants.equalsInteger(Constants.ZERO,model.getType())?Constants.MultiFile.CA_APPLY_JIAJIAN_SIGN.getKey() : Constants.MultiFile.CA_APPLY_CHANGEUNIT_SIGN.getKey()); f.setType(Constants.TWO); f.setFileurl(fileurl); f.setName("签章申请表.pdf"); multifileMapper.insert(f); Constants.ApplyLogType applyLogType =Constants.equalsInteger(Constants.ZERO,model.getType())? Constants.ApplyLogType.CA_JIAJIAN_APPLY_SIGN: Constants.ApplyLogType.CA_CHANGUNIT_APPLY_SIGN; ApplyLog log = new ApplyLog(update,applyLogType.getName(), null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return 1; } @Override public void dealWaitSignedData(){ List applyList = insuranceApplyMapper.selectList(new QueryWrapper().lambda() .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WAIT_SIGNATURE) .isNotNull(InsuranceApply::getSignApplyNo)); if(applyList !=null && applyList.size()>0 ){ for(InsuranceApply model : applyList){ String link = signService.linkFile(model.getSignApplyNo()); String fileUrl = uploadSignFile(link); if(StringUtils.isBlank(fileUrl)){ //如果下载失败，清除合同，下次签章重新生成新合同 return; } uploadSignedFileDo(model,fileUrl); return; } } List chagneList = applyChangeMapper.selectList(new QueryWrapper().lambda() .eq(ApplyChange::getStatus,Constants.ApplyChangeStatus.UPLOAD) .isNotNull(ApplyChange::getSignApplyNo)); if(chagneList !=null && chagneList.size()>0 ){ for(ApplyChange model : chagneList){ String link = signService.linkFile(model.getSignApplyNo()); String fileUrl = uploadSignFile(link); if(StringUtils.isBlank(fileUrl)){ //如果下载失败，清除合同，下次签章重新生成新合同 return; } uploadChangeSignedFileDo(model,fileUrl); return; } } } @Override public void dealSignResult(NotifyDataReq data){ if(data.getApplyNo() == null ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){ //如果已保全,可下载签约附件 InsuranceApply model = insuranceApplyMapper.selectOne(new QueryWrapper().lambda().eq(InsuranceApply::getSignApplyNo,data.getApplyNo()).last("limit 1" )); if(model != null && Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){ //完成签署已完成操作 String link = signService.linkFile(data.getApplyNo()); String fileUrl = uploadSignFile(link); if(StringUtils.isBlank(fileUrl)){ //如果下载失败，清除合同，下次签章重新生成新合同 return; } uploadSignedFileDo(model,fileUrl); return; } ApplyChange applyChange = applyChangeMapper.selectOne(new QueryWrapper().lambda().eq(ApplyChange::getSignApplyNo,data.getApplyNo()).last("limit 1" )); if(applyChange != null &&Constants.equalsInteger(applyChange.getStatus(),Constants.ApplyChangeStatus.UPLOAD.getKey())){ String link = signService.linkFile(data.getApplyNo()); String fileUrl = uploadSignFile(link); if(StringUtils.isBlank(fileUrl)){ //如果下载失败，清除合同，下次签章重新生成新合同 return; } uploadChangeSignedFileDo(applyChange,fileUrl); } }else if(Constants.equalsInteger(data.getSignStatus(), Constants.TWO )){ //如果已拒签，清除合同，下次签章重新生成新合同 insuranceApplyMapper.update(null,new UpdateWrapper().lambda() .set(InsuranceApply::getSignApplyNo,null) .eq(InsuranceApply::getSignApplyNo,data.getApplyNo())); //如果已拒签，清除合同，下次签章重新生成新合同 applyChangeMapper.update(null,new UpdateWrapper().lambda() .set(ApplyChange::getSignApplyNo,null) .eq(ApplyChange::getSignApplyNo,data.getApplyNo())); } } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer uploadToubaodan(InsuranceApply insuranceApply) { if(insuranceApply.getId() == null || insuranceApply.getToubaodanFile() == null ||StringUtils.isBlank( insuranceApply.getToubaodanFile() .getFileurl()) ||StringUtils.isBlank( insuranceApply.getToubaodanFile() .getName())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD.getKey()) || Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); InsuranceApply update = new InsuranceApply(); update.setEditDate(new Date()); update.setEditor(user.getId()); update.setStatus(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey()); update.setCheckDate(update.getEditDate()); update.setCheckInfo(insuranceApply.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); insuranceApplyMapper.updateById(update); insuranceApply.getToubaodanFile().setIsdeleted(Constants.ZERO); insuranceApply.getToubaodanFile().setCreator(user.getId()); insuranceApply.getToubaodanFile().setObjId(update.getId()); insuranceApply.getToubaodanFile().setCreateDate(update.getEditDate()); insuranceApply.getToubaodanFile().setObjType(Constants.MultiFile.BD_APPLY_PDF.getKey()); insuranceApply.getToubaodanFile().setType(Constants.TWO); multifileMapper.insert(insuranceApply.getToubaodanFile()); update.setToubaodanFile(insuranceApply.getToubaodanFile()); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.WAIT_SIGNATURE; String info =applyLogType.getInfo(); // info = info.replace("${param}", update.getCheckInfo()); ApplyLog log = new ApplyLog(update,applyLogType.getName(),StringUtils.isNotBlank(update.getCheckInfo())?info:"",update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return 1; } /** * 审核通过或者不通过 * @param insuranceApply * @return */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer check(InsuranceApply insuranceApply) { if(insuranceApply.getId() == null || StringUtils.isBlank(insuranceApply.getCheckInfo())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } Constants.ApplyLogType applyLogType = null; LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); InsuranceApply update = new InsuranceApply(); update.setEditDate(new Date()); update.setEditor(user.getId()); update.setCheckDate(update.getEditDate()); update.setCheckInfo(insuranceApply.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); if(insuranceApply.getDealBackApply() ==1){ //如果是不通过 applyLogType = Constants.ApplyLogType.PLATFORM_RETURN ; update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey()); }else{ applyLogType = Constants.ApplyLogType.PLATFORM_CHECK_PASS; update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()); } insuranceApplyMapper.updateById(update); String info =applyLogType.getInfo(); info = info.replace("${param}", update.getCheckInfo()); ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return 1; } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer create(InsuranceApply insuranceApply) { if (Objects.isNull(insuranceApply) || Objects.isNull(insuranceApply.getSolutionId()) || Objects.isNull(insuranceApply.getApplyStartTime()) || Objects.isNull(insuranceApply.getApplyEndTime()) || !CollectionUtils.isNotEmpty(insuranceApply.getApplyDetailList()) ) { throw new BusinessException(ResponseStatus.BAD_REQUEST); } LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(!loginUserInfo.getType().equals(Constants.ONE)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户类型错误：非企业用户无法进行该操作"); } List applyDetailList = insuranceApply.getApplyDetailList(); //判断是否存在重复信息 List idCardList = applyDetailList.stream().map(i->i.getIdcardNo()).collect(Collectors.toList()); Set set = new HashSet<>(idCardList); if(idCardList.size() != set.size()){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"员工信息存在重复信息"); } Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.UPLOAD; insuranceApply.setCreateDate(new Date()); insuranceApply.setCreator(loginUserInfo.getId()); insuranceApply.setIsdeleted(Constants.ZERO); insuranceApply.setCompanyId(loginUserInfo.getCompanyId()); insuranceApply.setCheckInfo(insuranceApplyStatus.getName()); insuranceApply.setStartTime(insuranceApply.getApplyStartTime()); insuranceApply.setEndTime(insuranceApply.getApplyEndTime()); insuranceApply.setCheckDate(new Date()); insuranceApply.setCurrentFee(BigDecimal.ZERO); insuranceApply.setCheckUserId(loginUserInfo.getId()); insuranceApply.setStatus(insuranceApplyStatus.getKey()); insuranceApplyMapper.insert(insuranceApply); //处理下级数据 this.dealApplyDetailData(insuranceApply,applyDetailList,loginUserInfo); InsuranceApply updBean = new InsuranceApply(); updBean.setId(insuranceApply.getId()); updBean.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add)); insuranceApplyMapper.updateById(updBean); //存储日志数据 this.saveApplyLog(insuranceApply,insuranceApplyStatus,null); return insuranceApply.getId(); } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer updateData(InsuranceApply insuranceApply) { if (Objects.isNull(insuranceApply) || Objects.isNull(insuranceApply.getId()) || Objects.isNull(insuranceApply.getSolutionId()) || Objects.isNull(insuranceApply.getApplyStartTime()) || Objects.isNull(insuranceApply.getApplyEndTime()) || !CollectionUtils.isNotEmpty(insuranceApply.getApplyDetailList()) ) { throw new BusinessException(ResponseStatus.BAD_REQUEST); } LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(!loginUserInfo.getType().equals(Constants.ONE)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户类型错误：非企业用户无法进行该操作"); } InsuranceApply dbInsuranceApply = insuranceApplyMapper.selectById(insuranceApply.getId()); if(Objects.isNull(dbInsuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到修改对象信息"); } if(!(dbInsuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey()) || dbInsuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.FAIL_RETURN.getKey())) ){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"状态错误，当前状态无法进行该操作"); } List applyDetailList = insuranceApply.getApplyDetailList(); //判断是否存在重复信息 List idCardList = applyDetailList.stream().map(i->i.getIdcardNo()).collect(Collectors.toList()); Set set = new HashSet<>(idCardList); if(idCardList.size() != set.size()){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"员工信息存在重复信息"); } Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.UPLOAD; insuranceApply.setEditDate(new Date()); insuranceApply.setEditor(loginUserInfo.getId()); insuranceApply.setIsdeleted(Constants.ZERO); insuranceApply.setCompanyId(loginUserInfo.getCompanyId()); insuranceApply.setCheckInfo(insuranceApplyStatus.getName()); insuranceApply.setStartTime(insuranceApply.getApplyStartTime()); insuranceApply.setEndTime(insuranceApply.getApplyEndTime()); insuranceApply.setCheckDate(new Date()); insuranceApply.setCurrentFee(BigDecimal.ZERO); insuranceApply.setCheckUserId(loginUserInfo.getId()); insuranceApply.setStatus(insuranceApplyStatus.getKey()); applyDetailMapper.delete(new QueryWrapper().lambda().eq(ApplyDetail::getApplyId,insuranceApply.getId())); //处理下级数据 this.dealApplyDetailData(insuranceApply,applyDetailList,loginUserInfo); insuranceApply.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add)); insuranceApplyMapper.updateById(insuranceApply); //存储日志数据 this.saveApplyLog(insuranceApply,insuranceApplyStatus,null); return insuranceApply.getId(); } public void dealApplyDetailData(InsuranceApply insuranceApply,List applyDetailList,LoginUserInfo loginUserInfo){ Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息"); } //查询保险方案下的所有派遣单位 List duSolutionList = duSolutionMapper.selectList(new QueryWrapper().lambda() .eq(DuSolution::getIsdeleted,Constants.ZERO) .eq(DuSolution::getStatus,Constants.ONE) .eq(DuSolution::getSolutionId,insuranceApply.getSolutionId())); if(!CollectionUtils.isNotEmpty(duSolutionList)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"数据异常：保险方案下未查询到派遣单位"); } //查询所有派遣单位下的工种 List duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList()); List duWorktypeList = duWorktypeMapper.selectList(new QueryWrapper().lambda() .eq(DuWorktype::getIsdeleted,Constants.ZERO) .eq(DuWorktype::getStatus,Constants.ONE) .in(DuWorktype::getDuSolutionId,duSolutionIdList)); if(!CollectionUtils.isNotEmpty(duWorktypeList)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"数据异常：保险方案下未查询到工种信息"); } if(CollectionUtils.isNotEmpty(applyDetailList)){ for (int i = 0; i < applyDetailList.size(); i++) { ApplyDetail applyDetail = applyDetailList.get(i); if(Objects.isNull(applyDetail) ||StringUtils.isBlank(applyDetail.getIdcardNo()) ||StringUtils.isBlank(applyDetail.getMemberName()) ||Objects.isNull(applyDetail.getDuId()) ||Objects.isNull(applyDetail.getWorktypeId()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"投保员工信息数据缺失"); } applyDetail.setCreateDate(new Date()); applyDetail.setCreator(loginUserInfo.getId()); applyDetail.setIsdeleted(Constants.ZERO); applyDetail.setStartTime(insuranceApply.getApplyStartTime()); applyDetail.setEndTime(insuranceApply.getApplyEndTime()); applyDetail.setSortnum(i); applyDetail.setApplyId(insuranceApply.getId()); Member member = new Member(); if(Objects.isNull(applyDetail.getMemberId())){ //查询是否存在该用户 member = memberMapper.selectOne(new QueryWrapper().lambda() .eq(Member::getCompanyId,insuranceApply.getCompanyId()) .eq(Member::getIsdeleted,Constants.ZERO) .eq(Member::getIdcardNo,applyDetail.getIdcardNo()) .last(" limit 1") ); if(Objects.isNull(member)){ member = new Member(); member.setCreateDate(new Date()); member.setCreator(loginUserInfo.getId()); member.setIsdeleted(Constants.ZERO); member.setName(applyDetail.getMemberName()); member.setCompanyId(insuranceApply.getCompanyId()); member.setSex(Constants.getSexByIdCard(applyDetail.getIdcardNo())); member.setIdcardNo(applyDetail.getIdcardNo()); member.setApplyId(insuranceApply.getId()); member.setDuId(applyDetail.getDuId()); member.setWorktypeId(applyDetail.getWorktypeId()); memberMapper.insert(member); }else{ member.setApplyId(insuranceApply.getId()); member.setDuId(applyDetail.getDuId()); member.setWorktypeId(applyDetail.getWorktypeId()); memberMapper.updateById(member); } }else{ member = memberMapper.selectById(applyDetail.getMemberId()); if(Objects.isNull(member)){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+"】员工信息存在异常数据！"); } member.setApplyId(insuranceApply.getId()); member.setDuId(applyDetail.getDuId()); member.setWorktypeId(applyDetail.getWorktypeId()); memberMapper.updateById(member); } applyDetail.setMemberId(member.getId()); applyDetail.setIdcardNo(member.getIdcardNo()); applyDetail.setSex(member.getSex()); applyDetail.setFee(Constants.countDetailFee(solutions,insuranceApply.getApplyEndTime(),insuranceApply.getApplyStartTime())); //验证派遣单位信息是否存在 if(duSolutionList.stream().filter(d->d.getDispatchUnitId().equals(applyDetail.getDuId())).collect(Collectors.toList()).size()<=Constants.ZERO){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+"】员工派遣单位未查询到！"); } if(duWorktypeList.stream().filter(d->d.getWorkTypeId().equals(applyDetail.getWorktypeId())) .collect(Collectors.toList()).size()<=Constants.ZERO){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+"】员工工种信息未查询到！"); } } applyDetailJoinMapper.insertBatchSomeColumn(applyDetailList); } } public void saveApplyLog(InsuranceApply insuranceApply,Constants.InsuranceApplyStatus insuranceApplyStatus,String content){ LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); ApplyLog applyLog = new ApplyLog(); applyLog.setCreateDate(new Date()); applyLog.setCreator(loginUserInfo.getId()); applyLog.setIsdeleted(Constants.ZERO); applyLog.setApplyId(insuranceApply.getId()); applyLog.setTitle(insuranceApplyStatus.getName()); applyLog.setContent(content); applyLog.setObjType(insuranceApplyStatus.getKey()); applyLog.setObjId( insuranceApply.getId()); applyLog.setStatus(insuranceApply.getStatus()); applyLogMapper.insert(applyLog); } // public BigDecimal countDetailFee(Solutions solutions ,Date startDate,Date endDate){ // //查询保险实际周期 // Integer cycle = DateUtil.calculateBetween(endDate,startDate,solutions.getDataType()); // if(cycle==-1){ // throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"日期信息错误!"); // } // return solutions.getPrice().multiply(new BigDecimal(cycle)); // } // public static void main(String[] args) { // Date date1 = DateUtil.StringToDate("2023-03-01 00:00:00"); // Date date2 = DateUtil.StringToDate("2023-04-01 00:00:00"); // System.out.println(DateUtil.calculateBetween(date1,date2,0)); // System.out.println(DateUtil.calculateBetween(date1,date2,1)); // System.out.println(DateUtil.calculateBetween(date1,date2,2)); // System.out.println(DateUtil.calculateBetween(date1,date2,3)); // // } @Override public void deleteById(Integer id) { insuranceApplyMapper.deleteById(id); } @Override public void delete(InsuranceApply insuranceApply) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(insuranceApply); insuranceApplyMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } insuranceApplyMapper.deleteBatchIds(ids); } @Override public void updateById(InsuranceApply insuranceApply) { insuranceApplyMapper.updateById(insuranceApply); } @Override public void updateByIdInBatch(List insuranceApplys) { if (CollectionUtils.isEmpty(insuranceApplys)) { return; } for (InsuranceApply insuranceApply: insuranceApplys) { this.updateById(insuranceApply); } } @Override public InsuranceApply findById(Integer id) { return insuranceApplyMapper.selectById(id); } @Override public InsuranceApply findOne(InsuranceApply insuranceApply) { QueryWrapper wrapper = new QueryWrapper<>(insuranceApply); return insuranceApplyMapper.selectOne(wrapper); } @Override public List findList(InsuranceApply insuranceApply) { QueryWrapper wrapper = new QueryWrapper<>(insuranceApply); return insuranceApplyMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); List statusList = Constants.InsuranceApplyStatus.getKesByStatus(pageWrap.getModel().getStatusCollect()); queryWrapper.selectAll(InsuranceApply.class); queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName); queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName); queryWrapper.select(" DATEDIFF( t.END_TIME ,now() ) AS loseEfficacyDays "); queryWrapper.select(" ( select count(1) from apply_detail ad where ad.apply_id = t.id ) as insureNum"); if(!Objects.isNull(pageWrap.getModel())&&!Objects.isNull(pageWrap.getModel().getType())){ queryWrapper.select(" ( select sum(td.fee) from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ) as taxesMoney"); queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast "); } queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId); queryWrapper.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId); queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO); queryWrapper.eq(pageWrap.getModel().getBaseSolutionId()!=null,Solutions::getBaseId,pageWrap.getModel().getBaseSolutionId()); queryWrapper.in(statusList.size()>0,InsuranceApply::getStatus,statusList); if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.THREE) ){ queryWrapper.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()); queryWrapper.lt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date())); } //企业人员查看本企业数据 if(loginUserInfo.getType().equals(Constants.ONE)){ queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); } if (pageWrap.getModel().getSolutionId() != null) { queryWrapper.eq(InsuranceApply::getSolutionId, pageWrap.getModel().getSolutionId()); } if (pageWrap.getModel().getEndTimeS() != null) { queryWrapper.ge(InsuranceApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTimeS())); } if (pageWrap.getModel().getEndTimeE() != null) { queryWrapper.le(InsuranceApply::getEndTime, Utils.Date.getEnd(pageWrap.getModel().getEndTimeE())); } if (pageWrap.getModel().getStartTimeS() != null) { queryWrapper.ge(InsuranceApply::getStartTime, Utils.Date.getStart(pageWrap.getModel().getStartTimeS())); } if (pageWrap.getModel().getStartTimeE() != null) { queryWrapper.le(InsuranceApply::getStartTime, Utils.Date.getEnd(pageWrap.getModel().getStartTimeE())); } if (pageWrap.getModel().getCreateTimeS() != null) { queryWrapper.ge(InsuranceApply::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateTimeS())); } if (pageWrap.getModel().getCreateTimeE() != null) { queryWrapper.le(InsuranceApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateTimeE())); } if (pageWrap.getModel().getType() != null) { queryWrapper.eq(Solutions::getType, pageWrap.getModel().getType()); } if (pageWrap.getModel().getCode() != null) { queryWrapper.eq(InsuranceApply::getCode, pageWrap.getModel().getCode()); } if (pageWrap.getModel().getStatus() != null) { queryWrapper.eq(InsuranceApply::getStatus, pageWrap.getModel().getStatus()); } if(CollectionUtils.isNotEmpty(pageWrap.getSorts())){ for(PageWrap.SortData sortData: pageWrap.getSorts()) { if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { queryWrapper.orderByDesc(sortData.getProperty()); } else { queryWrapper.orderByAsc(sortData.getProperty()); } } }else{ queryWrapper.orderByDesc(InsuranceApply::getCreateDate); } PageData pageData = PageData.from(insuranceApplyJoinMapper.selectJoinPage(page,InsuranceApply.class, queryWrapper)); if(pageData.getRecords()!=null){ for (InsuranceApply apply : pageData.getRecords()){ initApplyStatus(apply) ; } } return pageData; } public void initApplyStatus(InsuranceApply apply){ apply.setStatusCollect(Constants.InsuranceApplyStatus.getCollectStatus(apply.getStatus())); if(Constants.equalsInteger(apply.getStatusCollect(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){ //如果已完成 if(apply.getEndTime()==null || System.currentTimeMillis()>apply.getEndTime().getTime()){ apply.setStatusCollect(Constants.THREE);//已过期 } } setServiceDays(apply); apply.setStatusInfo(Constants.ApplyCollectStatus.getName(apply.getStatusCollect())); } @Override public List findListByDTO(InsuranceApplyQueryDTO model) { LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(InsuranceApply.class); queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName); queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName); queryWrapper.select(" ( select sum(td.fee) from taxes ts inner join tax_detial td on ts.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ) as taxesMoney "); queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on ts.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast "); queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId); queryWrapper.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId); queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO); //企业人员查看本企业数据 if(loginUserInfo.getType().equals(Constants.ONE)){ queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); } if (model.getSolutionId() != null) { queryWrapper.eq(InsuranceApply::getSolutionId, model.getSolutionId()); } if (model.getEndTimeS() != null) { queryWrapper.ge(InsuranceApply::getEndTime, Utils.Date.getStart(model.getEndTimeS())); } if (model.getEndTimeE() != null) { queryWrapper.le(InsuranceApply::getEndTime, Utils.Date.getEnd(model.getEndTimeE())); } if (model.getStartTimeS() != null) { queryWrapper.ge(InsuranceApply::getStartTime, Utils.Date.getStart(model.getStartTimeS())); } if (model.getStartTimeE() != null) { queryWrapper.le(InsuranceApply::getStartTime, Utils.Date.getEnd(model.getStartTimeE())); } if (model.getCreateTimeS() != null) { queryWrapper.ge(InsuranceApply::getCreateDate, Utils.Date.getStart(model.getCreateTimeS())); } if (model.getCreateTimeE() != null) { queryWrapper.le(InsuranceApply::getCreateDate, Utils.Date.getEnd(model.getCreateTimeE())); } if (model.getType() != null) { queryWrapper.eq(Solutions::getType, model.getType()); } if (model.getCode() != null) { queryWrapper.eq(InsuranceApply::getCode, model.getCode()); } if (model.getStatus() != null) { queryWrapper.eq(InsuranceApply::getStatus, model.getStatus()); } if (CollectionUtils.isNotEmpty(model.getIds())) { queryWrapper.in(InsuranceApply::getId, model.getIds()); } List list = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class, queryWrapper); return list; } @Override public long count(InsuranceApply insuranceApply) { QueryWrapper wrapper = new QueryWrapper<>(insuranceApply); return insuranceApplyMapper.selectCount(wrapper); } @Override public InsuranceApply findDetail(Integer id) { MPJLambdaWrapper wrapper= new MPJLambdaWrapper() .selectAll(InsuranceApply.class) .selectAs(Solutions::getName,InsuranceApply::getSolutionsName) .selectAs(Company::getName,ApplyLog::getCompanyName) .select(" ( select count(1) from apply_detail ad where ad.apply_id = t.id ) as insureNum") .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) .eq(InsuranceApply::getId,id) .last("limit 1"); InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } initApplyStatus(insuranceApply); //查询附件数据 initImgData(insuranceApply); //查询操作记录 List applyLogList = applyLogJoinMapper.selectJoinList(ApplyLog.class, new MPJLambdaWrapper() .selectAll(ApplyLog.class) .selectAs(SystemUser::getRealname,ApplyLog::getCreatorName) .selectAs(Company::getName,ApplyLog::getCompanyName) .leftJoin(SystemUser.class,SystemUser::getId,ApplyLog::getCreator) .leftJoin(Company.class,Company::getId,SystemUser::getCompanyId) .eq(ApplyLog::getApplyId,insuranceApply.getId()) .orderByAsc(ApplyLog::getCreateDate) ); insuranceApply.setApplyLogList(applyLogList); return insuranceApply; } private void setServiceDays(InsuranceApply insuranceApply) { //设置在保时长（天数） insuranceApply.setServiceDays(Constants.ZERO); if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){ //如果当前时间大于结束日期 则使用结束日期对比开始日期 if(DateUtil.compareDate(new Date(),insuranceApply.getEndTime())>=Constants.ZERO){ insuranceApply.setServiceDays(DateUtil.daysBetweenDates(insuranceApply.getEndTime(),insuranceApply.getStartTime())); }else if(DateUtil.compareDate(insuranceApply.getStartTime(),new Date())>=Constants.ZERO){ //未开始 insuranceApply.setServiceDays(Constants.ZERO); }else{ insuranceApply.setServiceDays(DateUtil.daysBetweenDates(new Date(),insuranceApply.getStartTime())); } } } private void initImgData(InsuranceApply model) { List multifiles = multifileMapper.selectList(new QueryWrapper().lambda() .eq(Multifile::getObjId,model.getId()) .in(Multifile::getObjType,Arrays.asList(new Integer[]{Constants.MultiFile.BD_APPLY_PDF.getKey() ,Constants.MultiFile.BD_SIGNED_PDF.getKey() ,Constants.MultiFile.BD_DONE_PDF.getKey()})) .eq(Multifile::getIsdeleted,Constants.ZERO)); if(multifiles!=null){ String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode() +systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode(); for(Multifile f : multifiles){ if(StringUtils.isBlank(f.getFileurl())){ continue; } f.setFileurlFull(path+f.getFileurl()); if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.BD_APPLY_PDF.getKey())){ //签署前的投保单 model.setToubaodanFile(f); }else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.BD_SIGNED_PDF.getKey())){ //签署后的投保单 model.setToubaodanSignedFile(f); }else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.BD_DONE_PDF.getKey())){ //最終保险单 model.setBaoxiandanFile(f); } if(model.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){ //如果当前时间大于结束日期 则使用结束日期对比开始日期 if(DateUtil.compareDate(new Date(),model.getEndTime())>=Constants.ZERO){ model.setServiceDays(DateUtil.daysBetweenDates(model.getEndTime(),model.getStartTime())); }else if(DateUtil.compareDate(model.getStartTime(),new Date())>=Constants.ZERO){ //未开始 model.setServiceDays(Constants.ZERO); }else{ model.setServiceDays(DateUtil.daysBetweenDates(new Date(),model.getStartTime())); } } } } } @Override public InsuranceApply findDetailForExport(InsuranceApply model){ MPJLambdaWrapper wrapper= new MPJLambdaWrapper() .selectAll(InsuranceApply.class) .selectAs(Solutions::getName,InsuranceApply::getSolutionsName) .selectAs(Company::getName,InsuranceApply::getCompanyName) .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) .eq(InsuranceApply::getId,model.getId()) .last("limit 1"); InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } MPJLambdaWrapper wrapper1= new MPJLambdaWrapper() .selectAll(ApplyDetail.class) .selectAs(Worktype::getName,ApplyDetail::getWorkTypeName) .selectAs(DispatchUnit::getName,ApplyDetail::getDuName) .leftJoin(Worktype.class,Worktype::getId,ApplyDetail::getWorktypeId) .leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyDetail::getDuId) .eq(ApplyDetail::getApplyId,model.getId()); //查询明细 List detailList =applyDetailJoinMapper.selectJoinList(ApplyDetail.class,wrapper1); if(detailList!=null){ insuranceApply.setInsureNum(detailList.size()); insuranceApply.setApplyDetailList(detailList); } insuranceApply.setRemark(model.getRemark()); return insuranceApply; } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void applyOpt(InsuranceApplyOptDTO insuranceApplyOptDTO){ if(Objects.isNull(insuranceApplyOptDTO) ||Objects.isNull(insuranceApplyOptDTO.getApplyId()) ||StringUtils.isBlank(insuranceApplyOptDTO.getOptIllustration())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(loginUserInfo.getType().equals(Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业端用户无法进行该操作"); } InsuranceApply insuranceApply = insuranceApplyMapper.selectById(insuranceApplyOptDTO.getApplyId()); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(insuranceApply.getIsdeleted().equals(Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"数据已删除,无法进行该操作"); } //-----TODU-------RJ-------完善退回状态分开标记------------------ Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE; if(insuranceApplyOptDTO.getOptType().equals(Constants.ONE)){ if(!(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD.getKey()) ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey()) ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey()))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态非可申请退回!"); } if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD.getKey())){ insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD; }else if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){ insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE; }else if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey())){ insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE; } }else if(insuranceApplyOptDTO.getOptType().equals(Constants.TWO)){ insuranceApplyStatus = Constants.InsuranceApplyStatus.CLOSE; if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.CLOSE.getKey())){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"已关闭，请勿重复操作"); } if(!(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey()) ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey()) ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态非可申请退回!"); } } insuranceApply.setStatus(insuranceApplyStatus.getKey()); insuranceApply.setCheckDate(new Date()); insuranceApply.setCheckInfo(insuranceApplyOptDTO.getOptIllustration()); insuranceApply.setCheckUserId(loginUserInfo.getId()); insuranceApplyMapper.updateById(insuranceApply); //存储日志数据 Constants.ApplyLogType applyLogType = Constants.ApplyLogType.COMPANY_APPLY_RETURN; String info =applyLogType.getInfo(); info = info.replace("${param}", insuranceApplyOptDTO.getOptIllustration()); ApplyLog log = new ApplyLog(insuranceApply,applyLogType.getName(),info,insuranceApply.getId(),applyLogType.getKey(),JSONObject.toJSONString(insuranceApply), JSONObject.toJSONString(insuranceApply)); applyLogMapper.insert(log); // this.saveApplyLog(insuranceApply,insuranceApplyStatus,null); } /** * 更新保单实际金额 */ @Override @Transactional(rollbackFor = {Exception.class}) public void updateApplyCurrentFee(){ List insuranceApplyList = insuranceApplyMapper.selectList(new QueryWrapper().lambda() .eq(InsuranceApply::getIsdeleted,Constants.ZERO) .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) .ge(InsuranceApply::getStartTime,DateUtil.getDate(new Date(),"yyyy-MM-dd") + " 00:00:00") .le(InsuranceApply::getEndTime,DateUtil.getDate(new Date(),"yyyy-MM-dd") + " 23:59:59") ); if(CollectionUtils.isNotEmpty(insuranceApplyList)){ for (InsuranceApply insuranceApply:insuranceApplyList) { Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ continue; } BigDecimal sumAmount = BigDecimal.ZERO; List applyDetailList = applyDetailMapper.selectList(new QueryWrapper().lambda().eq(ApplyDetail::getApplyId,insuranceApply.getId())); if(CollectionUtils.isNotEmpty(applyDetailList)){ for (ApplyDetail applyDetail: applyDetailList) { applyDetail.setCurrentFee(Constants.countDetailFee(solutions,new Date(),applyDetail.getStartTime())); applyDetailMapper.updateById(applyDetail); sumAmount = sumAmount.add(applyDetail.getCurrentFee()); } } insuranceApply.setCurrentFee(sumAmount); insuranceApplyMapper.updateById(insuranceApply); } } } @Override public CountCyclePriceVO getCountCyclePriceVO(CountCyclePriceDTO countCyclePriceDTO){ if(Objects.isNull(countCyclePriceDTO) || Objects.isNull(countCyclePriceDTO.getSolutionsId()) || Objects.isNull(countCyclePriceDTO.getStartDate()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } Solutions solutions = solutionsMapper.selectById(countCyclePriceDTO.getSolutionsId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); } CountCyclePriceVO countCyclePriceVO = new CountCyclePriceVO(); if(solutions.getInsureCycleUnit().equals(Constants.ZERO)){ countCyclePriceVO.setEndDate(DateUtil.afterDateByType(countCyclePriceDTO.getStartDate(),0,solutions.getInsureCycle())); }else if(solutions.getInsureCycleUnit().equals(Constants.TWO)){ Integer monthDays = DateUtil.monthDays(countCyclePriceDTO.getStartDate()); Date afterDate = DateUtil.afterDateByType(countCyclePriceDTO.getStartDate(),0,monthDays); countCyclePriceVO.setEndDate(DateUtil.afterDateByType(afterDate,0,-1)); }else if(solutions.getInsureCycleUnit().equals(Constants.THREE)){ Date afterDate = DateUtil.afterDateByType(countCyclePriceDTO.getStartDate(),2,solutions.getInsureCycle()); countCyclePriceVO.setEndDate(DateUtil.afterDateByType(afterDate,0,-1)); } countCyclePriceVO.setCyclePrice(Constants.countDetailFee(solutions,countCyclePriceVO.getEndDate(),countCyclePriceDTO.getStartDate())); return countCyclePriceVO; } }