package com.doumee.service.business.impl; import cn.hutool.core.util.IdcardUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.extension.api.R; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.annotation.excel.ExcelExporter; import com.doumee.core.annotation.excel.Reflections; 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.dao.business.*; import com.doumee.dao.business.dto.*; import com.doumee.dao.business.join.*; import com.doumee.dao.business.model.*; import com.doumee.dao.business.vo.ChangeDealTypeVO; import com.doumee.dao.business.vo.CountCyclePriceVO; import com.doumee.dao.system.model.SystemUser; import com.doumee.service.business.ApplyChangeService; 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.InsuranceApplyService; import com.doumee.service.business.SmsEmailService; import com.doumee.service.business.third.SignService; import com.github.xiaoymin.knife4j.core.util.CollectionUtils; import com.github.yulichang.wrapper.MPJLambdaWrapper; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.checkerframework.checker.units.qual.A; import org.slf4j.Logger; import org.slf4j.LoggerFactory; 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.math.RoundingMode; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Objects; import java.util.stream.Collectors; /** * 加减保换厂申请信息表Service实现 * @author 江蹄蹄 * @date 2024/01/16 10:03 */ @Service public class ApplyChangeServiceImpl implements ApplyChangeService { @Autowired private ApplyChangeMapper applyChangeMapper; @Autowired private DuSolutionJoinMapper duSolutionJoinMapper; @Autowired private InsuranceApplyMapper insuranceApplyMapper; @Autowired private CompanySolutionMapper companySolutionMapper; @Autowired private ApplyChangeJoinMapper applyChangeJoinMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private CompanyMapper companyMapper; @Autowired private SignService signService; @Autowired private ApplyChagneDetailJoinMapper applyChagneDetailJoinMapper; @Autowired private ApplyDetailJoinMapper applyDetailJoinMapper; @Autowired private SettleClaimsMapper settleClaimsMapper; @Autowired private MemberInsuranceJoinMapper memberInsuranceJoinMapper; @Autowired private ApplyChangeDetailJoinMapper applyChangeDetailJoinMapper; @Autowired private MemberMapper memberMapper; @Autowired private SolutionWorktypeJoinMapper solutionWorktypeJoinMapper; @Autowired private MultifileMapper multifileMapper; @Autowired private DuSolutionMapper duSolutionMapper; @Autowired private DuWorktypeMapper duWorktypeMapper; @Autowired private ApplyLogMapper applyLogMapper; @Value("${debug_model}") private boolean debugModel; @Autowired private ApplyLogJoinMapper applyLogJoinMapper; @Autowired private SolutionsMapper solutionsMapper; @Autowired private SmsEmailService smsEmailService; @Autowired private NoticesMapper noticesMapper; /** * 平台退回申请 * @param param * @return */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer back(ApplyChange param) { if(param.getId() == null ||StringUtils.isBlank(param.getCheckInfo())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } ApplyChange model = applyChangeMapper.selectById(param.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } InsuranceApply insuranceApply = insuranceApplyMapper.selectById(model.getApplyId()); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(insuranceApply.getIsdeleted().equals(Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"数据已删除,无法进行该操作"); } Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息"); } if(Constants.equalsInteger(solutions.getType(),Constants.ZERO)){ if(Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.APPROVE.getKey())){ //已提交和已完成状态不支持审核不通过 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } }else if(Constants.equalsInteger(solutions.getType(),Constants.ZERO)){ if(Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.UPLOAD.getKey()) || Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.SIGNATURE.getKey()) ){ //已提交和已完成状态不支持审核不通过 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); ApplyChange update = new ApplyChange(); update.setEditDate(new Date()); update.setEditor(user.getId()); update.setStatus(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey()); update.setCheckDate(update.getEditDate()); update.setCheckInfo(param.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); applyChangeMapper.updateById(update); //存储待办信息 Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; if(model.getType().equals(Constants.ONE)){ noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; } //删除其他待办 noticesMapper.delete(new QueryWrapper().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,model.getId())); Notices notices = new Notices(noticeObjectType,Constants.ONE,model.getId(),solutions.getName(), insuranceApply.getCompanyId(), Constants.NoticeType.FOUR); // notices.setParam1(insuranceApply.getId().toString()); noticesMapper.insert(notices); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_PLATFORM_CHECK_PASS_NO; 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 uploadPidan(ApplyChange param) { if(param.getId() == null || param.getValidCode() == null || param.getApplyStartTime() == null || CollectionUtils.isEmpty(param.getPidanFileList()) // || param.getPidanFile() == null // ||StringUtils.isBlank( param.getPidanFile().getFileurl()) // ||StringUtils.isBlank( param.getPidanFile() .getName()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } ApplyChange model = applyChangeMapper.selectById(param.getId()); InsuranceApply insuranceApply = insuranceApplyMapper.selectById(model.getApplyId()); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保单信息"); } if(model.getType().equals(Constants.ZERO)){ if(param.getDelValidTime() == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } if(!(param.getApplyStartTime().getTime()>=insuranceApply.getStartTime().getTime()&¶m.getApplyStartTime().getTime()<=insuranceApply.getEndTime().getTime())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"批增日期必须处于保单申请日期内"); } if(!(param.getDelValidTime().getTime()>=insuranceApply.getStartTime().getTime()&¶m.getDelValidTime().getTime()<=insuranceApply.getEndTime().getTime())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"批减日期必须处于保单申请日期内"); } }else{ if(param.getApplyStartTime().getTime() pidanFileList = param.getPidanFileList(); for (Multifile pidanFile:pidanFileList) { if(StringUtils.isBlank( pidanFile.getFileurl()) ||StringUtils.isBlank( pidanFile .getName())) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"批单文件参数错误"); } pidanFile.setIsdeleted(Constants.ZERO); pidanFile.setCreator(user.getId()); pidanFile.setObjId(update.getId()); pidanFile.setCreateDate(update.getEditDate()); pidanFile.setObjType(Constants.MultiFile.CA_PD_PDF.getKey()); pidanFile.setType(Constants.TWO); } multifileMapper.insertBatchSomeColumn(pidanFileList); update.setApplyId(model.getApplyId()); if(Constants.equalsInteger(model.getType(),Constants.ZERO)){ //如果是加减保申请 处理加减保明细数据 dealDetailsValidTime(update,insuranceApply); }else{ //如果是换厂申请 处理明细数据 dealDetailsDUdata(update,insuranceApply); } applyChangeMapper.updateById(update); Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; if(model.getType().equals(Constants.ONE)){ noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; } //删除其他待办 noticesMapper.delete(new QueryWrapper().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,model.getId())); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_PLATFORM_APPROVE; String info = ""; if(model.getValidTime()!=null && model.getValidTime().getTime()/1000!= param.getApplyStartTime().getTime()/1000){ info =applyLogType.getInfo(); info = info.replace("${param1}",DateUtil.getPlusTime2(model.getValidTime())); info = info.replace("${param2}",DateUtil.getPlusTime2(param.getApplyStartTime())); } ApplyLog log = new ApplyLog(update,applyLogType.getName(), info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update)); applyLogMapper.insert(log); return model.getApplyId(); } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer editPidan(ApplyChange param) { if(param.getId() == null || param.getValidCode() == null || param.getCheckInfo() == null || CollectionUtils.isEmpty(param.getPidanFileList()) // || param.getPidanFile() == null // ||StringUtils.isBlank( param.getPidanFile().getFileurl()) // ||StringUtils.isBlank( param.getPidanFile() .getName()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } ApplyChange model = applyChangeMapper.selectById(param.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.APPROVE.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请当前不支持该操作~"); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); ApplyChange update = new ApplyChange(); 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.setValidCode(param.getValidCode()); applyChangeMapper.updateById(update); //修改员工保单记录 memberInsuranceJoinMapper.update(null,new UpdateWrapper() .lambda() .set(MemberInsurance::getPdCode,param.getValidCode()) .eq(MemberInsurance::getRelationType,Constants.ONE) .eq(MemberInsurance::getApplyChangeId,model.getId()) ); //删除原有的保单信息 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.CA_PD_PDF.getKey()) ); List pidanFileList = param.getPidanFileList(); for (Multifile pidanFile:pidanFileList) { if(StringUtils.isBlank( pidanFile.getFileurl()) ||StringUtils.isBlank( pidanFile .getName())) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"批单文件参数错误"); } pidanFile.setIsdeleted(Constants.ZERO); pidanFile.setCreator(user.getId()); pidanFile.setObjId(update.getId()); pidanFile.setCreateDate(update.getEditDate()); pidanFile.setObjType(Constants.MultiFile.CA_PD_PDF.getKey()); pidanFile.setType(Constants.TWO); } multifileMapper.insertBatchSomeColumn(param.getPidanFileList()); // param.getPidanFile().setIsdeleted(Constants.ZERO); // param.getPidanFile().setObjId(update.getId()); // param.getPidanFile().setCreator(user.getId()); // param.getPidanFile().setCreateDate(update.getEditDate()); // param.getPidanFile().setObjType(Constants.MultiFile.CA_PD_PDF.getKey()); // param.getPidanFile().setType(Constants.TWO); // multifileMapper.insert(param.getPidanFile()); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_PALTFORM_EDIT_PIDAN; 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; } /** * 处理换厂明细数据 * @param update */ private void dealDetailsDUdata(ApplyChange update,InsuranceApply insuranceApply) { List detailList = applyChagneDetailJoinMapper.selectJoinList(ApplyChagneDetail.class, new MPJLambdaWrapper() .selectAll(ApplyChagneDetail.class) .selectAs(Solutions::getTimeUnit,ApplyChagneDetail::getSolutionTimeUnit) .selectAs(Solutions::getPrice,ApplyChagneDetail::getSolutionPrice) .selectAs(Solutions::getId,ApplyChagneDetail::getSolutionId) .selectAs(Solutions::getName,ApplyChagneDetail::getSolutionsName) .selectAs(Worktype::getName,ApplyChagneDetail::getWorkTypeName) .selectAs(DispatchUnit::getName,ApplyChagneDetail::getDuName) .selectAs(Member::getIdcardNo,ApplyChagneDetail::getIdcardNo) .selectAs(Member::getName, ApplyChagneDetail::getMemberName) .selectAs(InsuranceApply::getCode,ApplyChagneDetail::getApplyCode) .leftJoin(Member.class, Member::getId, ApplyChagneDetail::getMemberId) .leftJoin(ApplyChange.class, ApplyChange::getId, ApplyChagneDetail::getApplyChangeId) .leftJoin(InsuranceApply.class, InsuranceApply::getId, ApplyChange::getApplyId) .leftJoin(Solutions.class, Solutions::getId, InsuranceApply::getSolutionId) .leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getWorktypeId) .leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getDuId) .eq(ApplyChagneDetail::getApplyChangeId,update.getId()) .eq(ApplyChagneDetail::getIsdeleted,Constants.ZERO) ); if(detailList ==null || detailList.size()==0){ return; } //实际批单生效日期 Date applyStartTime = DateUtil.getMontageDate(update.getApplyStartTime(),1); for(ApplyChagneDetail detail : detailList){ if(applyDetailJoinMapper.selectCount(new QueryWrapper() .lambda() .eq(ApplyDetail::getApplyId,update.getApplyId()) .eq(ApplyDetail::getIdcardNo,detail.getIdcardNo()) .le(ApplyDetail::getStartTime,applyStartTime) .ge(ApplyDetail::getEndTime,applyStartTime) )<=Constants.ZERO){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "当前保单下，换厂人员【" + detail.getMemberName() + "】未查询到符合批单日期的数据"); } //查询员工是在主单下 是否存在生效中的数据 ApplyDetail oldModel = applyDetailJoinMapper.selectOne(new QueryWrapper().lambda() .eq(ApplyDetail::getApplyId, update.getApplyId()) .eq(ApplyDetail::getMemberId, detail.getMemberId()) .le(ApplyDetail::getStartTime,applyStartTime) .ge(ApplyDetail::getEndTime,applyStartTime) .orderByDesc(ApplyDetail::getCreateDate) .last("limit 1")); if(oldModel == null ){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，用户【"+detail.getMemberName()+"】原保单信息有误，批单日期未在保单日期内！"); } MemberInsurance memberInsurance = new MemberInsurance(detail,update,update.getEditor(),null,insuranceApply.getSolutionId()); memberInsurance.setSolutionId(detail.getSolutionId()); memberInsurance.setWorktypeName(detail.getWorkTypeName()); memberInsurance.setDuName(detail.getDuName()); memberInsurance.setApplyChangeId(detail.getApplyChangeId()); memberInsurance.setSolutionName(detail.getSolutionsName()); memberInsurance.setPdCode(update.getValidCode()); memberInsurance.setBdCode(insuranceApply.getCode()); memberInsurance.setRelationType(Constants.ONE); memberInsurance.setStartTime(DateUtil.getMontageDate(update.getApplyStartTime(),1)); memberInsurance.setRelationId(oldModel.getId()); memberInsurance.setIsValid(Constants.ZERO); memberInsuranceJoinMapper.insert(memberInsurance); applyDetailJoinMapper.update(null, new UpdateWrapper().lambda() .set(ApplyDetail::getEditor,update.getEditor()) .set(ApplyDetail::getEditDate,update.getEditDate()) .set(ApplyDetail::getDuId,detail.getDuId()) .set(ApplyDetail::getWorktypeId,detail.getWorktypeId()) .eq(ApplyDetail::getId,oldModel.getId()) ); memberInsuranceJoinMapper.update(null,new UpdateWrapper().lambda() .eq(MemberInsurance::getApplyId,update.getApplyId()) .le(MemberInsurance::getStartTime,applyStartTime) .ge(MemberInsurance::getEndTime,applyStartTime) .set(insuranceApply.getStartTime().compareTo(update.getApplyStartTime())!=0, MemberInsurance::getEndTime,DateUtil.getMontageDate(update.getApplyStartTime(), 3)) .set(insuranceApply.getStartTime().compareTo(update.getApplyStartTime())==0, MemberInsurance::getEndTime,DateUtil.getMontageDate(update.getApplyStartTime(), 2)) .ne(MemberInsurance::getId,memberInsurance.getId()) // .eq(MemberInsurance::getRelationId,oldModel.getId()) ); //如果实际批单日期 和 原记录日期相等 则直接修改记录派遣单位与工种信息 // if(applyStartTime.compareTo(oldModel.getStartTime())!=Constants.ZERO){ // //当前日期大于批单日期 需要回滚数据实际数据 // Boolean flag = DateUtil.getMontageDate(new Date(),2).compareTo(DateUtil.getMontageDate(update.getApplyStartTime(),2))>0; // //换厂后历史记录的费用 fee // Integer days = DateUtil.daysBetweenDates(DateUtil.getMontageDate(update.getApplyStartTime(),3),DateUtil.getMontageDate(oldModel.getStartTime(),1))+1; // BigDecimal oldFee = this.getApplyPrice(update.getApplyId(),days); // BigDecimal fee = oldModel.getFee(); // BigDecimal oldCurrentFee = oldModel.getCurrentFee(); // // applyDetailJoinMapper.update(null, new UpdateWrapper().lambda() // .set(ApplyDetail::getEditor,update.getEditor()) // .set(ApplyDetail::getEditDate,update.getEditDate()) // .set(ApplyDetail::getEndTime,DateUtil.getMontageDate(update.getApplyStartTime(),3)) // .set(ApplyDetail::getFee,oldFee) // .set(flag,ApplyDetail::getCurrentFee,oldFee) // .eq(ApplyDetail::getId,oldModel.getId()) // ); // // //修改 员工投保明细记录 历史数据 // memberInsuranceJoinMapper.update(null,new UpdateWrapper().lambda() // .set(MemberInsurance::getEndTime,update.getApplyStartTime()) // .set(MemberInsurance::getFee,oldFee) // .eq(MemberInsurance::getRelationId,oldModel.getId()) // ); // // ApplyDetail applyDetail = new ApplyDetail(); // applyDetail.setApplyId(oldModel.getApplyId()); // applyDetail.setCreateDate(new Date()); // applyDetail.setCreator(update.getEditor()); // applyDetail.setMemberId(oldModel.getMemberId()); // applyDetail.setIdcardNo(detail.getIdcardNo()); // applyDetail.setSex(Constants.getSexByIdCard(detail.getIdcardNo())); // applyDetail.setMemberName(detail.getMemberName()); // applyDetail.setStartTime(DateUtil.getMontageDate(update.getApplyStartTime(),1)); // applyDetail.setEndTime(endDate); // applyDetail.setDuId(detail.getDuId()); // applyDetail.setWorktypeId(detail.getWorktypeId()); // applyDetail.setIdcardNo(oldModel.getIdcardNo()); // applyDetail.setFee(fee.subtract(oldFee)); // applyDetail.setIsdeleted(Constants.ZERO); // if(flag){ // applyDetail.setCurrentFee(oldCurrentFee.multiply(oldFee)); // }else{ // applyDetail.setCurrentFee(BigDecimal.ZERO); // } // applyDetail.setSex(oldModel.getSex()); // applyDetail.setMemberName(oldModel.getMemberName()); // applyDetail.setFromId(detail.getId()); // applyDetailJoinMapper.insert(applyDetail); // // MemberInsurance memberInsurance = new MemberInsurance(applyDetail,update.getId()); // memberInsurance.setSolutionId(detail.getSolutionId()); // memberInsurance.setWorktypeName(detail.getWorkTypeName()); // memberInsurance.setDuName(detail.getDuName()); // memberInsurance.setApplyChangeId(detail.getApplyChangeId()); // memberInsurance.setSolutionName(detail.getSolutionsName()); // memberInsurance.setPdCode(update.getValidCode()); // memberInsurance.setBdCode(insuranceApply.getCode()); // memberInsurance.setRelationType(Constants.ONE); // memberInsuranceJoinMapper.insert(memberInsurance); // }else{ // applyDetailJoinMapper.update(null, new UpdateWrapper().lambda() // .set(ApplyDetail::getEditor,update.getEditor()) // .set(ApplyDetail::getEditDate,update.getEditDate()) // .set(ApplyDetail::getDuId,detail.getDuId()) // .set(ApplyDetail::getWorktypeId,detail.getWorktypeId()) // .eq(ApplyDetail::getId,oldModel.getId()) // ); // //员工投保明细记录 历史数据 // memberInsuranceJoinMapper.update(null,new UpdateWrapper().lambda() // .set(MemberInsurance::getDuId,detail.getDuId()) // .set(MemberInsurance::getDuName,detail.getDuName()) // .set(MemberInsurance::getWorktypeId,detail.getWorktypeId()) // .set(MemberInsurance::getWorktypeName,detail.getWorkTypeName()) // .eq(MemberInsurance::getRelationId,oldModel.getId()) // ); // } Member member = memberMapper.selectById(detail.getMemberId()); if(Objects.isNull(member)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到员工数据"); } member.setApplyId(update.getApplyId()); member.setDuId(detail.getDuId()); member.setWorktypeId(detail.getWorktypeId()); // member.setStartTime(detail.getStartTime()); // member.setEndTime(detail.getEndTime()); memberMapper.updateById(member); applyChangeDetailJoinMapper.update(null,new UpdateWrapper().lambda() .set(ApplyChagneDetail::getStartTime,DateUtil.getMontageDate(update.getApplyStartTime(), 1)) .eq(ApplyChagneDetail::getId,detail.getId()) ); } } /** * 处理加减保明细数据 * @param update */ private void dealDetailsValidTime(ApplyChange update,InsuranceApply insuranceApply) { List detailList = applyChagneDetailJoinMapper.selectJoinList(ApplyChagneDetail.class, new MPJLambdaWrapper() .selectAll(ApplyChagneDetail.class) .selectAs(Member::getIdcardNo,ApplyChagneDetail::getIdcardNo) .selectAs(Solutions::getTimeUnit, ApplyChagneDetail::getSolutionTimeUnit) .selectAs(Solutions::getPrice, ApplyChagneDetail::getSolutionPrice) .selectAs(Worktype::getName, ApplyChagneDetail::getWorkTypeName) .selectAs(DispatchUnit::getName, ApplyChagneDetail::getDuName) .selectAs(Member::getName, ApplyChagneDetail::getMemberName) .selectAs(Solutions::getName,ApplyChagneDetail::getSolutionsName) .selectAs(InsuranceApply::getCode,ApplyChagneDetail::getApplyCode) .leftJoin(ApplyChange.class, ApplyChange::getId, ApplyChagneDetail::getApplyChangeId) .leftJoin(Member.class, Member::getId, ApplyChagneDetail::getMemberId) .leftJoin(InsuranceApply.class, InsuranceApply::getId, ApplyChange::getApplyId) .leftJoin(Solutions.class, Solutions::getId, InsuranceApply::getSolutionId) .leftJoin(Worktype.class, Worktype::getId, ApplyChagneDetail::getWorktypeId) .leftJoin(DispatchUnit.class, DispatchUnit::getId, ApplyChagneDetail::getDuId) .eq(ApplyChagneDetail::getApplyChangeId, update.getId()) .eq(ApplyChagneDetail::getIsdeleted, Constants.ZERO)); if (detailList == null || detailList.size() == 0) { return; } BigDecimal totalFee = new BigDecimal(0); BigDecimal currentFee = new BigDecimal(0); //投保记录 加保数据加入新数据 减保数据 修改老数据 List memberInsuranceList = new ArrayList<>(); Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保险方案"); } List addList = detailList.stream().filter(f->Constants.equalsInteger(f.getType(),Constants.ZERO)).collect(Collectors.toList()); List reduceList = detailList.stream().filter(f->Constants.equalsInteger(f.getType(),Constants.ONE)).collect(Collectors.toList()); //减保业务 for (ApplyChagneDetail detail:reduceList) { Member member = memberMapper.selectById(detail.getMemberId()); if(Objects.isNull(member)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到员工数据"); } //减保操作 //查询员工是在主单下 是否存在生效中的数据 ApplyDetail oldModel = applyDetailJoinMapper.selectOne(new QueryWrapper().lambda() .eq(ApplyDetail::getApplyId, update.getApplyId()) .eq(ApplyDetail::getMemberId, detail.getMemberId()) .orderByDesc(ApplyDetail::getCreateDate) .last("limit 1")); // if (oldModel == null || oldModel.getStartTime() == null || oldModel.getStartTime().getTime() > update.getApplyStartTime().getTime()) { // throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，用户【" + detail.getMemberName() + "】原保单信息有误，当前申请不支持减保处理！"); // } // if(!(oldModel.getStartTime().getTime()<=update.getDelValidTime().getTime()&& oldModel.getEndTime().getTime()>=update.getDelValidTime().getTime())){ // throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，用户【" + detail.getMemberName() + "】减保日期未在保单记录日期中！"); // } if (oldModel == null || oldModel.getEndTime() == null || oldModel.getEndTime().getTime() < update.getDelValidTime().getTime()) { throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，用户【" + detail.getMemberName() + "】原保单信息有误，当前申请不支持减保处理！"); } BigDecimal sumFee = Objects.isNull(insuranceApply.getServerCost())? solutions.getPrice(): solutions.getPrice().add(insuranceApply.getServerCost()); // 减保后 总费用 默认为减保后为 0 BigDecimal updateFee = BigDecimal.ZERO; // 减保后 批单日期 默认为 批单减保日期 00:00:00 Date delValidTime = update.getDelValidTime(); //当审批时间 大于 申请的时间时 计算实际减少金额 因为已扣金额会大于 应扣金额 BigDecimal updateCurrentFee = BigDecimal.ZERO; //如果批单日期 大于 员工保单的开始日期 if(update.getDelValidTime().getTime() > oldModel.getStartTime().getTime()){ //批单日期 大于 保单开日期 获取实际的批单结束日期 计算实际减保后总费用 delValidTime = DateUtil.getMontageDate(update.getDelValidTime(), 3); updateFee = Constants.reduceFee( solutions, sumFee ,insuranceApply.getStartTime(),insuranceApply.getFinalEndTime(),oldModel.getStartTime(),delValidTime ) ; }else{ delValidTime = oldModel.getStartTime(); updateFee = BigDecimal.ZERO; } if (oldModel.getStartTime().getTime() < System.currentTimeMillis()) { //// 2024年5月8日17:37:23 修改 计算产生费用 updateCurrentFee = Constants.produceFee(solutions,sumFee,insuranceApply.getStartTime(),insuranceApply.getEndTime(), oldModel.getStartTime() ); } UpdateWrapper updateWrapper = new UpdateWrapper(); updateWrapper.lambda() .setSql(" fee = " + updateFee) .setSql(" current_fee = " + updateCurrentFee) .set(ApplyDetail::getEndTime, delValidTime) .set(update.getDelValidTime().getTime() <= oldModel.getStartTime().getTime(),ApplyDetail::getChangeStatus,Constants.TWO) .set(ApplyDetail::getEditor, update.getEditor()) .set(ApplyDetail::getEditDate, update.getEditDate()) .eq(ApplyDetail::getId, oldModel.getId()); BigDecimal reduceMoney = BigDecimal.ZERO; if(Constants.equalsInteger(solutions.getDelOnlyReplace(),Constants.ONE) && Constants.equalsInteger(solutions.getTimeUnit(),solutions.getInsureCycleUnit())){ if(delValidTime.getTime()<=oldModel.getStartTime().getTime()){ updateFee = BigDecimal.ZERO; updateWrapper.lambda().set(ApplyDetail::getFee,updateFee) .set(ApplyDetail::getChangeStatus,Constants.TWO); }else{ reduceMoney = solutions.getPrice().multiply(new BigDecimal(-1)); //标记数据已被替换 updateWrapper.lambda().set(ApplyDetail::getReduceMoney,reduceMoney) .set(ApplyDetail::getChangeStatus,Constants.ONE); } detail.setApplyDetailId(oldModel.getId()); } applyDetailJoinMapper.update(null, updateWrapper); totalFee = totalFee.add(updateFee).subtract(oldModel.getFee()).add(reduceMoney); currentFee = currentFee.add(updateCurrentFee); List oldMemberInsurance = memberInsuranceJoinMapper.selectList( new QueryWrapper().lambda() .eq(MemberInsurance::getIsValid,Constants.ZERO) .eq(MemberInsurance::getRelationId,oldModel.getId())); for (MemberInsurance memberInsurance:oldMemberInsurance) { //记录数据早于批单日期 if(memberInsurance.getStartTime().getTime()>delValidTime.getTime()){ memberInsurance.setIsValid(Constants.ONE); }else if(memberInsurance.getEndTime().getTime()>=delValidTime.getTime() && memberInsurance.getStartTime().getTime()<=delValidTime.getTime()){ memberInsurance.setFee(updateFee); memberInsurance.setEndTime(delValidTime); } memberInsuranceJoinMapper.updateById(memberInsurance); } //修改 员工投保明细记录 历史数据 // memberInsuranceJoinMapper.update(null, new UpdateWrapper().lambda() // .setSql(" fee = " + updateFee) // .set(MemberInsurance::getEndTime, delValidTime) // .eq(MemberInsurance::getRelationId, oldModel.getId()) // ); //修改业务明细行数据实际批单日期 applyChangeDetailJoinMapper.update(null,new UpdateWrapper().lambda() .set(ApplyChagneDetail::getFee,updateFee.subtract(oldModel.getFee())) .set( ApplyChagneDetail::getEndTime, delValidTime) .eq(ApplyChagneDetail::getId,detail.getId()) ); member.setApplyId(update.getApplyId()); member.setDuId(detail.getDuId()); member.setWorktypeId(detail.getWorktypeId()); member.setStartTime(detail.getStartTime()); member.setEndTime(detail.getEndTime()); memberMapper.updateById(member); } //加保业务 for (int i = 0; i < addList.size(); i++) { ApplyChagneDetail detail = addList.get(i); Member member = memberMapper.selectById(detail.getMemberId()); if (Objects.isNull(member)) { throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到员工数据"); } //查询人员信息是否存在相同的方案下是否存在 冲突数据 InsuranceApplyServiceImpl.checkStaticMemberSolution(solutions.getBaseId(), member.getId(),member.getIdcardNo(),member.getName(),detail.getStartTime(),detail.getEndTime(), applyDetailJoinMapper); //查询加保人员是否存在 冲突的 保单明细数据 if(applyDetailJoinMapper.selectCount(new QueryWrapper() .lambda() .eq(ApplyDetail::getApplyId,update.getApplyId()) .eq(ApplyDetail::getIdcardNo,detail.getIdcardNo()) .le(ApplyDetail::getStartTime,DateUtil.getMontageDate(update.getApplyStartTime(),1)) .ge(ApplyDetail::getEndTime,DateUtil.getMontageDate(detail.getEndTime(),2)) )>Constants.ZERO){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "当前保单下，加保人员【" + detail.getMemberName() + "】存在日期冲突的数据"); } //加保 ApplyDetail add = new ApplyDetail(); add.setApplyId(update.getApplyId()); add.setValidCode(update.getValidCode()); add.setFee(detail.getFee()); add.setIsdeleted(Constants.ZERO); add.setCreator(update.getEditor()); add.setCreateDate(update.getEditDate()); add.setMemberId(detail.getMemberId()); add.setMemberName(detail.getMemberName()); add.setWorktypeId(detail.getWorktypeId()); add.setIsdeleted(Constants.ZERO); add.setIdcardNo(detail.getIdcardNo()); add.setSex(Constants.getSexByIdCard(detail.getIdcardNo())); add.setMemberName(detail.getMemberName()); add.setRemark(detail.getRemark()); add.setDuId(detail.getDuId()); add.setStartTime(DateUtil.getMontageDate(update.getApplyStartTime(), 1)); add.setEndTime(DateUtil.getMontageDate(detail.getEndTime(), 2)); add.setFee(Constants.addFee(solutions,solutions.getPrice(),insuranceApply.getStartTime(),insuranceApply.getFinalEndTime(),update.getApplyStartTime(),insuranceApply.getEndTime())); add.setChangeStatus(Constants.ZERO); if(Constants.equalsInteger(solutions.getDelOnlyReplace(),Constants.ONE) && Constants.equalsInteger(solutions.getTimeUnit(),solutions.getInsureCycleUnit()) && i < reduceList.size()){ add.setReduceId(reduceList.get(i).getId()); } if(new Date().compareTo(DateUtil.getMontageDate(detail.getStartTime(), 2))>=0){ //2024年5月8日17:37:23 修改 计算产生费用 add.setCurrentFee( Constants.produceFee(solutions,add.getFee(),add.getStartTime(),add.getEndTime(),add.getStartTime()) ); }else{ add.setCurrentFee(BigDecimal.ZERO); } applyDetailJoinMapper.insert(add); //如果不是替换业务的加保数据 则添加实际产生费用 detail.setFee(Objects.isNull(add.getReduceId())?add.getFee():BigDecimal.ZERO); totalFee = totalFee.add(add.getFee()); if(Objects.isNull(add.getReduceId())){ currentFee = currentFee.add(add.getCurrentFee()); } MemberInsurance memberInsurance = new MemberInsurance(detail, update, update.getEditor(), add.getId(),solutions.getId()); memberInsurance.setStartTime(add.getStartTime()); memberInsurance.setEndTime(add.getEndTime()); memberInsurance.setRelationType(Constants.ONE); memberInsuranceList.add(memberInsurance); applyChangeDetailJoinMapper.update(null,new UpdateWrapper().lambda() .set(ApplyChagneDetail::getFee,add.getFee()) .set(ApplyChagneDetail::getStartTime,DateUtil.getMontageDate(update.getApplyStartTime(), 1)) .eq(ApplyChagneDetail::getId,detail.getId()) ); member.setApplyId(update.getApplyId()); member.setDuId(detail.getDuId()); member.setWorktypeId(detail.getWorktypeId()); member.setStartTime(detail.getStartTime()); member.setEndTime(detail.getEndTime()); memberMapper.updateById(member); } if (memberInsuranceList != null && memberInsuranceList.size() > 0) { memberInsuranceJoinMapper.insertBatchSomeColumn(memberInsuranceList); } if (totalFee.compareTo(new BigDecimal(0)) != 0) { //如果保单金额发生编码，更新总保单金额 insuranceApplyMapper.update(null, new UpdateWrapper().lambda() .setSql(" fee = ifnull(fee,0)+" + totalFee) .setSql(" current_fee = ifnull(current_fee,0)+" + currentFee) .set(InsuranceApply::getEditor, update.getEditor()) .set(InsuranceApply::getEditDate, update.getEditDate()) .eq(InsuranceApply::getId, update.getApplyId()) ); } update.setFee(totalFee); } /** * 平台退回申请 * @param param * @return */ @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer dealBackApply(ApplyChange param) { if(param.getId() == null ||StringUtils.isBlank(param.getCheckInfo())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } ApplyChange model = applyChangeMapper.selectById(param.getId()); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } InsuranceApply insuranceApply = insuranceApplyMapper.selectById(model.getApplyId()); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(insuranceApply.getIsdeleted().equals(Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"数据已删除,无法进行该操作"); } Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息"); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); Constants.ApplyLogType applyLogType = null; String info = ""; ApplyChange update = new ApplyChange(); Constants.NoticeType noticeType = Constants.NoticeType.FOUR; if(param.getDealBackApply() ==1){ //如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作 if(!(Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) ||Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey())) ){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } if(Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey())){ update.setStatus(Constants.ApplyChangeStatus.SIGNATURE.getKey()); }else { update.setStatus(Constants.ApplyChangeStatus.UPLOAD.getKey()); } applyLogType = Constants.ApplyLogType.CA_PALTFORM_REFUSE_APPLY; info = applyLogType.getInfo(); info = info.replace("${param}", param.getCheckInfo()); noticeType = Constants.NoticeType.FIVE; }else{ //如果是同意,两种申请退回状态都可操作 if(!(Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) ||Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } update.setStatus(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey()); applyLogType = Constants.ApplyLogType.CA_PLATFORM_AGREE_BACK_APPLY; } update.setEditDate(new Date()); update.setEditor(user.getId()); //同意退回，直接回到最初状态，如果驳回退回申请，则保单状态回到待上传保险单 update.setCheckDate(update.getEditDate()); update.setCheckInfo(param.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); applyChangeMapper.updateById(update); //存储待办信息 Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; if(model.getType().equals(Constants.ONE)){ noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; } //删除其他待办 noticesMapper.delete(new QueryWrapper().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,model.getId())); Notices notices = new Notices(noticeObjectType,Constants.ONE,model.getId(),solutions.getName(), insuranceApply.getCompanyId(), noticeType); noticesMapper.insert(notices); 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(ApplyChange applyChange) { if(applyChange.getType().equals(Constants.ZERO)){ //2024年5月9日14:59:24 修改 默认入当前天 applyChange.setValidTime(DateUtil.getMontageDate(new Date(),1)); } if (Objects.isNull(applyChange) || Objects.isNull(applyChange.getApplyId()) || Objects.isNull(applyChange.getValidTime()) || Objects.isNull(applyChange.getType()) || !(applyChange.getType().equals(Constants.ZERO) || applyChange.getType().equals(Constants.ONE)) ) { 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 insuranceApply = insuranceApplyMapper.selectById(applyChange.getApplyId()); if (Objects.isNull(insuranceApply)) { throw new BusinessException(ResponseStatus.DATA_EMPTY); } if (!(Constants.equalsInteger(insuranceApply.getStatus(), Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) ||Constants.equalsInteger(insuranceApply.getStatus(), Constants.InsuranceApplyStatus.WTB_DONE.getKey()) )) { throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "保单状态错误"); } if (DateUtil.compareDate(insuranceApply.getEndTime(),new Date()) >= Constants.ZERO ) { throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "保单已过保，无法进行该操作"); } Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保险方案"); } CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper().lambda() .eq(CompanySolution::getCompanyId,insuranceApply.getCompanyId()) .eq(CompanySolution::getSolutionBaseId,solutions.getBaseId()) .eq(CompanySolution::getIsdeleted,Constants.ZERO) .last(" limit 1 ") ); if(Objects.isNull(companySolution)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到企业分配保险方案信息"); } //查询保单下是否存在进行中的加减保/换厂单据 if(applyChangeMapper.selectCount(new QueryWrapper().lambda() .eq(ApplyChange::getApplyId,insuranceApply.getId()) .notIn(ApplyChange::getStatus,Constants.ApplyChangeStatus.APPROVE.getKey(),Constants.ApplyChangeStatus.CLOSE.getKey()) )>Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "存在进行中的加减保/换厂申请"); }; applyChange.setCreateDate(new Date()); applyChange.setCreator(loginUserInfo.getId()); applyChange.setEditor(loginUserInfo.getId()); applyChange.setEditDate(new Date()); applyChange.setIsdeleted(Constants.ZERO); //根据申请日期 处理加减保的 实际生效日期 if(applyChange.getType().equals(Constants.ZERO)){ initJJBValidTime(applyChange,insuranceApply,solutions); }else{ applyChange.setApplyStartTime(applyChange.getValidTime()); } applyChange.setStatus(Constants.ZERO); applyChangeMapper.insert(applyChange); BigDecimal fee = this.dealApplyChangeData(applyChange,insuranceApply,companySolution,solutions,loginUserInfo,BigDecimal.ZERO); ApplyChange applyChangeFee = new ApplyChange(); applyChangeFee.setId(applyChange.getId()); applyChangeFee.setFee(fee); applyChangeMapper.updateById(applyChangeFee); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_COMPANY_COMMIT; ApplyLog log = new ApplyLog(applyChange,applyLogType.getName(),"",applyChange.getId(),applyLogType.getKey(), null, null); applyLogMapper.insert(log); // if(1==1){ // throw new BusinessException(ResponseStatus.DATA_EMPTY ); // } return applyChange.getId(); } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer update(ApplyChange applyChange) { if(applyChange.getType().equals(Constants.ZERO)){ //2024年5月9日14:59:24 修改 默认入当前天 applyChange.setValidTime(DateUtil.getMontageDate(new Date(),1)); } if (Objects.isNull(applyChange) || Objects.isNull(applyChange.getId()) || Objects.isNull(applyChange.getApplyId()) // || Objects.isNull(applyChange.getValidTime()) || Objects.isNull(applyChange.getType()) || !(applyChange.getType().equals(Constants.ZERO) || applyChange.getType().equals(Constants.ONE)) ){ 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(), "用户类型错误：非企业用户无法进行该操作"); // }*/ ApplyChange dbApplyChange = applyChangeMapper.selectById(applyChange.getId()); if(Objects.isNull(dbApplyChange)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(! (dbApplyChange.getStatus().equals(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey()) || dbApplyChange.getStatus().equals(Constants.ApplyChangeStatus.PALTFORM_CHECK_PASS_NO.getKey()) ) ){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "业务保申请单状态错误"); } InsuranceApply insuranceApply = insuranceApplyMapper.selectById(applyChange.getApplyId()); if (Objects.isNull(insuranceApply)) { throw new BusinessException(ResponseStatus.DATA_EMPTY); } if (!(Constants.equalsInteger(insuranceApply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) ||Constants.equalsInteger(insuranceApply.getStatus(),Constants.InsuranceApplyStatus.WTB_DONE.getKey()) )) { throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "保单状态错误"); } if (DateUtil.compareDate(insuranceApply.getEndTime(),new Date()) >= Constants.ZERO ) { throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "保单已过保，无法进行该操作"); } // if (DateUtil.compareDate(applyChange.getValidTime(),insuranceApply.getStartTime()) > Constants.ZERO) { // applyChange.setValidTime(insuranceApply.getStartTime()); // } Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保险方案"); } if(solutions.getDataType().equals(Constants.ONE)){ solutions = solutionsMapper.selectOne(new QueryWrapper().lambda() .eq(Solutions::getBaseId,solutions.getBaseId()).eq(Solutions::getDataType,Constants.TWO).last("limit 1")); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到方案最新版本信息"); } } CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper().lambda() .eq(CompanySolution::getCompanyId,loginUserInfo.getCompanyId()) .eq(CompanySolution::getSolutionBaseId,solutions.getBaseId()) .eq(CompanySolution::getIsdeleted,Constants.ZERO) .last(" limit 1 ") ); if(Objects.isNull(companySolution)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到企业分配保险方案信息"); } //申请时间必须处于保单的时间范围内 // if (!(DateUtil.compareDate( insuranceApply.getStartTime(),applyChange.getValidTime()) >= Constants.ZERO // && DateUtil.compareDate( applyChange.getValidTime(),insuranceApply.getEndTime()) >= Constants.ZERO)) { // throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "申请日期未处于保单日期内，无法进行该操作"); // } //查询保单下是否存在进行中的加减保/换厂单据 if(applyChangeMapper.selectCount(new QueryWrapper().lambda() .eq(ApplyChange::getApplyId,insuranceApply.getId()) .ne(ApplyChange::getId,applyChange.getId()) .notIn(ApplyChange::getStatus,Constants.ApplyChangeStatus.APPROVE.getKey(),Constants.ApplyChangeStatus.CLOSE.getKey()) )>Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "存在进行中的加减保/换厂申请"); }; if(applyChange.getType().equals(Constants.ZERO)){ //处理期望生效日期 initJJBValidTime(applyChange,insuranceApply,solutions); }else{ applyChange.setApplyStartTime(applyChange.getValidTime()); } applyChange.setEditDate(new Date()); applyChange.setEditor(loginUserInfo.getId()); applyChange.setStatus(Constants.ZERO); //删除历史数据 applyChagneDetailJoinMapper.delete(new QueryWrapper().lambda().eq(ApplyChagneDetail::getApplyChangeId,applyChange.getId())); BigDecimal fee = this.dealApplyChangeData(applyChange,insuranceApply,companySolution,solutions,loginUserInfo,BigDecimal.ZERO); applyChange.setFee(fee); applyChangeMapper.updateById(applyChange); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_UPLOAD_AGAIN; String info =applyLogType.getInfo(); info = info.replace("${param}", ""); ApplyLog log = new ApplyLog(applyChange,applyLogType.getName(),info,applyChange.getId(),applyLogType.getKey(), null, null); applyLogMapper.insert(log); Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; if(applyChange.getType().equals(Constants.ONE)){ noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; } noticesMapper.delete(new QueryWrapper().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,applyChange.getId())); return applyChange.getId(); } private void initJJBValidTime(ApplyChange applyChange, InsuranceApply insuranceApply, Solutions solutions) { if( applyChange.getValidTime().getTime()>=insuranceApply.getStartTime().getTime() && Objects.nonNull(solutions.getAddValidDays())){ //如果保单已生效，按照t+n的规则 applyChange.setApplyStartTime( DateUtil.afterDateByType(applyChange.getValidTime(),0,solutions.getAddValidDays()) ); }else{ //如果保单未生或者没有配置生效天数，设置期望生效日期为保单生效开始时间 applyChange.setApplyStartTime(applyChange.getValidTime().getTime()>=insuranceApply.getStartTime().getTime()?applyChange.getValidTime():insuranceApply.getStartTime()); } if(applyChange.getValidTime().getTime()>=insuranceApply.getStartTime().getTime() &&Objects.nonNull(solutions.getDelValidDays())){ applyChange.setDelValidTime( DateUtil.afterDateByType(applyChange.getValidTime(),0,solutions.getDelValidDays()) ); }else{ applyChange.setDelValidTime(applyChange.getValidTime().getTime()>=insuranceApply.getStartTime().getTime()?applyChange.getValidTime():insuranceApply.getStartTime()); } //仅支持替换 保证加减保日期为同一天 if(Constants.equalsInteger(solutions.getDelOnlyReplace(),Constants.ONE)){ applyChange.setApplyStartTime( applyChange.getDelValidTime() ); } } private static Logger logger = LoggerFactory.getLogger(ApplyChangeServiceImpl.class); public BigDecimal dealApplyChangeData(ApplyChange applyChange,InsuranceApply insuranceApply ,CompanySolution companySolution,Solutions solutions,LoginUserInfo loginUserInfo,BigDecimal fee){ Long start = System.currentTimeMillis(); logger.error("处理加减保保单数据开始时间:=========================>"+start); if(Constants.equalsInteger(applyChange.getType(),Constants.ZERO)){ if(Objects.nonNull(solutions.getDelOnlyReplace())&& solutions.getDelOnlyReplace().equals(Constants.ONE)){ if(applyChange.getDelDetailList().size() > applyChange.getAddDetailList().size()){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该保险方案仅支持替换（减保人数不得大于加保人数）"); } } } List duSolutionList = new ArrayList<>(); List duWorktypeList = new ArrayList<>(); List worktypeIdList = new ArrayList<>(); if(Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)){ //查询保险方案下的所有派遣单位 duSolutionList = duSolutionJoinMapper.selectJoinList(DuSolution.class,new MPJLambdaWrapper() .selectAll(DuSolution.class) .innerJoin(DispatchUnit.class,DispatchUnit::getId,DuSolution::getDispatchUnitId) .eq(DispatchUnit::getCompanyId,insuranceApply.getCompanyId()) .eq(DispatchUnit::getIsdeleted,Constants.ZERO) .eq(DispatchUnit::getUnitStatus,Constants.ONE) .eq(DuSolution::getIsdeleted,Constants.ZERO) .eq(DuSolution::getStatus,Constants.ONE) .eq(DuSolution::getSolutionId,companySolution.getSolutionId())); if(!CollectionUtils.isNotEmpty(duSolutionList)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"数据异常：保险方案下未查询到派遣单位"); } //查询所有派遣单位下的工种 List duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList()); 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(), "数据异常：保险方案下未查询到工种信息"); } worktypeIdList = duWorktypeList.stream().map(i->i.getWorkTypeId()).collect(Collectors.toList()); }else{ //查询方案下所有工种数据 List solutionWorktypeList = solutionWorktypeJoinMapper.selectList(new QueryWrapper().lambda().eq(SolutionWorktype::getSolutionId,solutions.getId())); if(CollectionUtils.isEmpty(solutionWorktypeList)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到工种信息"); } worktypeIdList = solutionWorktypeList.stream().map(i->i.getWorktypeId()).collect(Collectors.toList()); } ApplyChangeCyclePriceDTO applyChangeCyclePriceDTO = new ApplyChangeCyclePriceDTO(); applyChangeCyclePriceDTO.setApplyId(insuranceApply.getId()); //减保数据 List delDetailList = applyChange.getDelDetailList(); //加保数据 List addDetailList = applyChange.getAddDetailList(); //换厂业务 List changeDetailList = applyChange.getChangeDetailList(); if(CollectionUtils.isEmpty(delDetailList) && CollectionUtils.isEmpty(addDetailList) && CollectionUtils.isEmpty(changeDetailList)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，未添加人员数据无法进行提交"); } if (CollectionUtils.isNotEmpty(addDetailList)) { if(Objects.isNull(solutions.getCanAdd()) || solutions.getCanAdd().equals(Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该保险方案无法进行加保"); } //验证是否存在重复数据 List idcarNo = addDetailList.stream().map(m->m.getIdcardNo()).collect(Collectors.toList()); Set set = new HashSet<>(idcarNo); if(idcarNo.size() != set.size()){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"对不起，人员录入数据存在相同数据！"); } BigDecimal sumPrice = Objects.isNull(insuranceApply.getServerCost())?solutions.getPrice():solutions.getPrice().add(insuranceApply.getServerCost()); BigDecimal detailFee = Constants.addFee(solutions, sumPrice ,insuranceApply.getStartTime(),insuranceApply.getFinalEndTime(), applyChange.getApplyStartTime(),insuranceApply.getEndTime()); this.addChangeDetail(applyChange,addDetailList,duSolutionList,insuranceApply,solutions,loginUserInfo,detailFee,delDetailList.size(),worktypeIdList); fee = addDetailList.stream().map(ApplyChagneDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add); } if (CollectionUtils.isNotEmpty(delDetailList)) { //验证是否存在重复数据 List idcarNo = delDetailList.stream().map(m->m.getIdcardNo()).collect(Collectors.toList()); Set set = new HashSet<>(idcarNo); if(idcarNo.size() != set.size()){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"对不起，人员录入数据存在相同数据！"); } if(Objects.isNull(solutions.getCanReduce()) || solutions.getCanReduce().equals(Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该保险方案无法进行减保"); } this.delChangeDetail(applyChange,delDetailList,insuranceApply,solutions,loginUserInfo, BigDecimal.ZERO, DateUtil.getMontageDate(applyChange.getDelValidTime(),3)); fee = fee.add(delDetailList.stream().map(ApplyChagneDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add)); } //换厂业务 if (CollectionUtils.isNotEmpty(changeDetailList)) { if(Objects.isNull(solutions.getCanChangeUnit()) || solutions.getCanChangeUnit().equals(Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该保险方案无法进行换厂操作"); } //验证是否存在重复数据 List idcarNo = changeDetailList.stream().map(m->m.getIdcardNo()).collect(Collectors.toList()); Set set = new HashSet<>(idcarNo); if(idcarNo.size() != set.size()){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"对不起，人员录入数据存在相同数据！"); } this.changeDetail(applyChange,changeDetailList,duSolutionList,loginUserInfo,solutions,worktypeIdList); } Long end = System.currentTimeMillis(); logger.error("处理加减保保单数据结束时间:=========================>"+end +";单条耗时：====》"+(end-start)); return fee; } public void saveApplyLog(ApplyChange applyChange,Constants.ApplyLogType applyLogType,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(applyChange.getApplyId()); applyLog.setTitle(applyLogType.getName()); if(StringUtils.isNotBlank(content)){ applyLog.setContent(applyLogType.getInfo().replace("${param}",content)); } applyLog.setObjType(applyLogType.getKey()); applyLog.setObjId( applyChange.getId()); applyLog.setStatus(applyChange.getStatus()); applyLogMapper.insert(applyLog); } /** * 减保数据处理 * @param applyChange * @param delDetailList * @param loginUserInfo */ public void delChangeDetail(ApplyChange applyChange ,List delDetailList,InsuranceApply insuranceApply,Solutions solutions, LoginUserInfo loginUserInfo,BigDecimal detailFee,Date endTime){ if(DateUtil.getMontageDate(applyChange.getDelValidTime(),3).getTime()>insuranceApply.getEndTime().getTime()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保生效期不能晚于保单结束日期"); } for (ApplyChagneDetail applyChagneDetail : delDetailList) { if (Objects.isNull(applyChagneDetail.getMemberId())) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】必填项缺失"); } //2024-10-29 15:17:54 查询是否已出险 已出险无法进行投保 if(settleClaimsMapper.selectCount(new QueryWrapper().lambda() .eq(SettleClaims::getInsuranceApplyId,applyChange.getApplyId()) .eq(SettleClaims::getMemberId,applyChagneDetail.getMemberId()) .in(SettleClaims::getStatus,Constants.SettleClaimsStatus.DEAL_ING.getKey() ,Constants.SettleClaimsStatus.CONFIRM_INFORMATION.getKey() ,Constants.SettleClaimsStatus.FINISH_ACCEPTANCE.getKey()) )>Constants.ZERO){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】已出险无法进行减保"); }; //2024-10-29 15:17:54 查询人员是否已减保 已减保后无法再次减保 // if(applyChangeDetailJoinMapper.selectJoinCount(new MPJLambdaWrapper() // .leftJoin(ApplyChange.class,ApplyChange::getId,ApplyChagneDetail::getApplyChangeId) // .eq(ApplyChagneDetail::getType,Constants.ONE) // .eq(ApplyChange::getApplyId,applyChange.getApplyId()) // .eq(ApplyChagneDetail::getMemberId,applyChagneDetail.getMemberId()) // .notIn(ApplyChange::getStatus,Constants.ApplyChangeStatus.CLOSE.getKey() // ,Constants.ApplyChangeStatus.PALTFORM_CHECK_PASS_NO.getKey() // ) // )>Constants.ZERO){ // throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】已减保无法再次进行减保"); // }; //2025-1-16 09:11:14 根据查询当前人员最后一次的加减保记录 如果最后一条记录是加保进入 则可以减保 如果最后一条记录是减保记录 则不可以减保 如果为空 这可以进行操作 ApplyChagneDetail lastApplyChagneDetail = applyChangeDetailJoinMapper.selectJoinOne(ApplyChagneDetail.class, new MPJLambdaWrapper() .leftJoin(ApplyChange.class,ApplyChange::getId,ApplyChagneDetail::getApplyChangeId) .ne(ApplyChagneDetail::getType,Constants.TWO) .eq(ApplyChange::getApplyId,applyChange.getApplyId()) .eq(ApplyChagneDetail::getMemberId,applyChagneDetail.getMemberId()) .notIn(ApplyChange::getStatus,Constants.ApplyChangeStatus.CLOSE.getKey() ,Constants.ApplyChangeStatus.PALTFORM_CHECK_PASS_NO.getKey() ) .orderByDesc(ApplyChagneDetail::getId) .last(" limit 1 ") ); if(Objects.nonNull(lastApplyChagneDetail)){ if(Constants.equalsInteger(lastApplyChagneDetail.getType(),Constants.ONE)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】已减保无法再次进行减保"); } } //查询减保人员是否存在 冲突的 保单明细数据 if(applyDetailJoinMapper.selectCount(new QueryWrapper() .lambda() .eq(ApplyDetail::getApplyId,applyChange.getApplyId()) .eq(ApplyDetail::getIdcardNo,applyChagneDetail.getIdcardNo()) // .le(ApplyDetail::getStartTime,DateUtil.getMontageDate(applyChange.getDelValidTime(),1)) .ge(ApplyDetail::getEndTime,DateUtil.getMontageDate(applyChange.getDelValidTime(),3)) )<=Constants.ZERO){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "当前保单下，减保人员【" + applyChagneDetail.getMemberName() + "】未查询到符合批单日期的数据"); } Member member = memberMapper.selectById(applyChagneDetail.getMemberId()); if (Objects.isNull(member)) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】未查询到系统人员信息"); } //查询员工是否存在 0待签署 1已签章 的此类业务保数据 同一主单下 if (applyChagneDetailJoinMapper.selectJoinCount( new MPJLambdaWrapper() .leftJoin(ApplyChange.class, ApplyChange::getId, ApplyChagneDetail::getApplyChangeId) .eq(ApplyChange::getApplyId,applyChange.getApplyId()) .eq(ApplyChagneDetail::getMemberId, applyChagneDetail.getMemberId()) .in(ApplyChange::getStatus, Constants.ZERO, Constants.ONE) ) > Constants.ZERO) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】存在申请中的加减保/换厂单据"); } //查询员工是在主单下 是否存在生效中的数据 List applyDetailList = applyDetailJoinMapper.selectList(new QueryWrapper().lambda() .eq(ApplyDetail::getIsdeleted,Constants.ZERO) .eq(ApplyDetail::getApplyId, applyChange.getApplyId()) .eq(ApplyDetail::getMemberId, applyChagneDetail.getMemberId()) // .le(ApplyDetail::getStartTime,DateUtil.getMontageDate(applyChange.getDelValidTime(),1)) .ge(ApplyDetail::getEndTime,DateUtil.getMontageDate(applyChange.getDelValidTime(),3)) .orderByDesc(ApplyDetail::getCreateDate)); if (applyDetailList.size() > Constants.ONE) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】保单信息异常，存在多条数据"); } ApplyDetail applyDetail = applyDetailList.get(Constants.ZERO); if (applyChange.getValidTime().compareTo(applyDetail.getEndTime()) > 0) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "减保人员【" + applyChagneDetail.getMemberName() + "】保单保障日期至：【" + applyDetail.getEndTime() + "】无法通过本次申请"); } if(!Constants.equalsInteger(applyDetail.getChangeStatus(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"减保人员【" + applyChagneDetail.getMemberName() + "】保单信息异常,数据已被减保无法再次减保"); } applyChagneDetail.setCreateDate(new Date()); applyChagneDetail.setCreator(loginUserInfo.getId()); applyChagneDetail.setIsdeleted(Constants.ZERO); applyChagneDetail.setApplyChangeId(applyChange.getId()); applyChagneDetail.setType(Constants.ONE); applyChagneDetail.setApplyDetailId(applyDetail.getId()); applyChagneDetail.setStartTime(applyDetail.getStartTime()); if(endTime.getTime() addDetailList, List duSolutionList, InsuranceApply insuranceApply,Solutions solutions,LoginUserInfo loginUserInfo,BigDecimal detailFee,Integer delSize, List worktypeIdList){ if(applyChange.getApplyStartTime().getTime()>insuranceApply.getEndTime().getTime()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保生效期不能大于保单结束日期"); } for (int i = 0; i < addDetailList.size(); i++) { ApplyChagneDetail applyChagneDetail = addDetailList.get(i); if ( Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO) && Objects.isNull(applyChagneDetail.getDuId()) || Objects.isNull(applyChagneDetail.getWorktypeId()) || StringUtils.isBlank(applyChagneDetail.getIdcardNo()) ) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】必填项缺失"); } //查询加保人员是否存在 冲突的 保单明细数据 if(applyDetailJoinMapper.selectCount(new QueryWrapper() .lambda() .eq(ApplyDetail::getApplyId,applyChange.getApplyId()) .eq(ApplyDetail::getIdcardNo,applyChagneDetail.getIdcardNo()) .le(ApplyDetail::getStartTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(),1)) .ge(ApplyDetail::getEndTime,DateUtil.getMontageDate(insuranceApply.getEndTime(),2)) )>Constants.ZERO){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "当前保单下，加保人员【" + applyChagneDetail.getMemberName() + "】存在日期冲突的数据"); } ApplyDetail applyDetail = applyDetailJoinMapper.selectOne(new QueryWrapper() .lambda() .eq(ApplyDetail::getApplyId,applyChange.getApplyId()).last("limit 1")); if(Objects.isNull(applyDetail)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "保单中未存在明细记录"); } applyChagneDetail.setPrice(applyDetail.getPrice()); applyChagneDetail.setCreateDate(new Date()); applyChagneDetail.setCreator(loginUserInfo.getId()); applyChagneDetail.setIsdeleted(Constants.ZERO); applyChagneDetail.setApplyChangeId(applyChange.getId()); applyChagneDetail.setStartTime(DateUtil.getMontageDate(applyChange.getApplyStartTime(),1)); applyChagneDetail.setEndTime(DateUtil.getMontageDate(insuranceApply.getEndTime(),2)); applyChagneDetail.setType(Constants.ZERO); Member member = new Member(); if(Objects.isNull(applyChagneDetail.getMemberId())){ //查询是否存在该用户 member = memberMapper.selectOne(new QueryWrapper().lambda() .eq(Member::getCompanyId,insuranceApply.getCompanyId()) .eq(Member::getIsdeleted,Constants.ZERO) .eq(Member::getIdcardNo,applyChagneDetail.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(applyChagneDetail.getMemberName()); member.setCompanyId(insuranceApply.getCompanyId()); member.setSex(Constants.getSexByIdCard(applyChagneDetail.getIdcardNo())); if(!IdcardUtil.isValidCard(applyChagneDetail.getIdcardNo())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"加保员工信息身份证信息错误["+member.getName()+"]"); } member.setIdcardNo(applyChagneDetail.getIdcardNo()); member.setApplyId(insuranceApply.getId()); member.setDuId(applyChagneDetail.getDuId()); member.setWorktypeId(applyChagneDetail.getWorktypeId()); memberMapper.insert(member); }else{ member.setApplyId(insuranceApply.getId()); member.setDuId(applyChagneDetail.getDuId()); member.setWorktypeId(applyChagneDetail.getWorktypeId()); memberMapper.updateById(member); } applyChagneDetail.setMemberId(member.getId()); }else{ member = memberMapper.selectById(applyChagneDetail.getMemberId()); if(Objects.isNull(member)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】未查询到系统人员信息"); } member.setApplyId(insuranceApply.getId()); member.setDuId(applyChagneDetail.getDuId()); member.setWorktypeId(applyChagneDetail.getWorktypeId()); member.setStartTime(applyChagneDetail.getStartTime()); member.setEndTime(applyChagneDetail.getEndTime()); memberMapper.updateById(member); } //查询人员信息是否存在相同的方案下是否存在 冲突数据 InsuranceApplyServiceImpl.checkStaticMemberSolution(solutions.getBaseId(), applyChagneDetail.getMemberId(),applyChagneDetail.getIdcardNo(),applyChagneDetail.getMemberName(),applyChange.getApplyStartTime(),insuranceApply.getEndTime(), applyDetailJoinMapper); //根据员工身份证进行判断年龄 long age = Constants.getAgeByIdCard(member.getIdcardNo()); if(Objects.isNull(age) || age > solutions.getMaxAge() || age < solutions.getMinAge()){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"【"+applyChagneDetail.getMemberName()+"】员工年龄超出方案配置 方案配置【"+solutions.getMinAge()+" - "+solutions.getMaxAge()+"】存在异常数据！"); } //查询员工是否存在 0待签署 1已签章 的此类业务保数据 同一主单下 if (applyChagneDetailJoinMapper.selectJoinCount( new MPJLambdaWrapper() .leftJoin(ApplyChange.class, ApplyChange::getId, ApplyChagneDetail::getApplyChangeId) .eq(ApplyChagneDetail::getMemberId, applyChagneDetail.getMemberId()) .eq(ApplyChange::getApplyId,applyChange.getApplyId()) .in(ApplyChange::getStatus, Constants.ZERO, Constants.ONE) ) > Constants.ZERO) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】存在申请中的加减保/换厂单据"); } //查询员工是在主单下 是否存在生效中的数据 if(!Objects.isNull(applyChagneDetail.getMemberId())){ if (applyDetailJoinMapper.selectCount(new QueryWrapper().lambda() .eq(ApplyDetail::getApplyId, applyChange.getApplyId()) .eq(ApplyDetail::getMemberId, applyChagneDetail.getMemberId()) .le(ApplyDetail::getStartTime, "now()") .ge(ApplyDetail::getEndTime, "now()") ) > Constants.ZERO) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "加保人员【" + applyChagneDetail.getMemberName() + "】存在保障中的保单信息，无法进行加保"); } } //验证派遣单位信息 与工种信息 是否存在 if(Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)){ if (duSolutionList.stream().filter(d -> d.getDispatchUnitId().equals(applyChagneDetail.getDuId())).collect(Collectors.toList()).size() <= Constants.ZERO) { throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "【" + applyChagneDetail.getMemberName() + "】员工派遣单位未查询到！"); } } if (worktypeIdList.stream().filter(d -> Constants.equalsInteger(d,applyChagneDetail.getWorktypeId())) .collect(Collectors.toList()).size() <= Constants.ZERO) { throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "【" + applyChagneDetail.getMemberName() + "】员工工种信息未查询到！"); } applyChagneDetail.setMemberId(member.getId()); //如果是减保业务为仅替换 且 方案的扣费周期和总周期相等 则处理减保费用 if(Constants.equalsInteger(solutions.getDelOnlyReplace(),Constants.ONE) && Constants.equalsInteger(solutions.getTimeUnit(),solutions.getInsureCycleUnit()) && delSize> i){ applyChagneDetail.setFee(BigDecimal.ZERO); }else{ applyChagneDetail.setFee(detailFee); } applyChagneDetailJoinMapper.insert(applyChagneDetail); } } /** * 换厂业务 * @param applyChange * @param duSolutionList * @param changeDetailList * @param loginUserInfo */ public void changeDetail(ApplyChange applyChange ,List changeDetailList ,List duSolutionList,LoginUserInfo loginUserInfo,Solutions solutions ,List worktypeIdList){ for (ApplyChagneDetail applyChagneDetail : changeDetailList) { if (Objects.isNull(applyChagneDetail.getMemberId()) || (Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO) && Objects.isNull(applyChagneDetail.getOldDuId())) || Objects.isNull(applyChagneDetail.getOldWorktypeId()) || (Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO) && Objects.isNull(applyChagneDetail.getDuId())) || Objects.isNull(applyChagneDetail.getWorktypeId()) ) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】必填项缺失"); } //查询换厂人员是否存在 有效的保单明细数据 if(applyDetailJoinMapper.selectCount(new QueryWrapper() .lambda() .eq(ApplyDetail::getApplyId,applyChange.getApplyId()) .eq(ApplyDetail::getIdcardNo,applyChagneDetail.getIdcardNo()) .le(ApplyDetail::getStartTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(),1)) .ge(ApplyDetail::getEndTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(),1)) )<=Constants.ZERO){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "当前保单下，换厂人员【" + applyChagneDetail.getMemberName() + "】未查询到符合批单日期的数据"); } Member member = memberMapper.selectById(applyChagneDetail.getMemberId()); if (Objects.isNull(member)) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】未查询到系统人员信息"); } //查询员工是否存在 0待签署 1已签章 的此类业务保数据 同一主单下 if (applyChagneDetailJoinMapper.selectJoinCount( new MPJLambdaWrapper() .leftJoin(ApplyChange.class, ApplyChange::getId, ApplyChagneDetail::getApplyChangeId) .eq(ApplyChagneDetail::getMemberId, applyChagneDetail.getMemberId()) .eq(ApplyChange::getApplyId, applyChange.getApplyId()) .in(ApplyChange::getStatus, Constants.ZERO, Constants.ONE) ) > Constants.ZERO) { throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】存在申请中的加减保/换厂单据"); } //查询员工是在主单下 是否存在生效中的数据 List applyDetailList = applyDetailJoinMapper.selectList(new QueryWrapper().lambda() .eq(ApplyDetail::getIsdeleted,Constants.ZERO) .eq(ApplyDetail::getApplyId, applyChange.getApplyId()) .eq(ApplyDetail::getMemberId, applyChagneDetail.getMemberId()) .le(ApplyDetail::getStartTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(),1)) .ge(ApplyDetail::getEndTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(),1))); if(applyDetailList.size()>Constants.ONE){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】保单信息异常，存在多条数据"); }else if(applyDetailList.size()==Constants.ZERO){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】未查询到投保记录"); } ApplyDetail applyDetail = applyDetailList.get(Constants.ZERO); if(applyChange.getValidTime().compareTo( applyDetail.getEndTime())>0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】保单保障日期至：【"+DateUtil.getDate(applyDetail.getEndTime(),"yyyy-MM-dd HH:mm:ss")+"】无法通过本次申请"); } if(Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)){ //验证派遣单位信息 与工种信息 是否存在 if (duSolutionList.stream().filter(d -> d.getDispatchUnitId().equals(applyChagneDetail.getDuId())).collect(Collectors.toList()).size() <= Constants.ZERO) { throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】员工派遣单位未查询到！"); } } if (worktypeIdList.stream().filter(d -> Constants.equalsInteger(d,applyChagneDetail.getWorktypeId())) .collect(Collectors.toList()).size() <= Constants.ZERO) { throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】员工工种信息未查询到！"); } if((Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO) && applyChagneDetail.getOldDuId().equals(applyChagneDetail.getDuId())) && applyChagneDetail.getOldWorktypeId().equals(applyChagneDetail.getWorktypeId())){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(), "换厂人员【" + applyChagneDetail.getMemberName() + "】换厂数据相同！"); } applyChagneDetail.setPrice(applyDetail.getPrice()); applyChagneDetail.setCreateDate(new Date()); applyChagneDetail.setCreator(loginUserInfo.getId()); applyChagneDetail.setIsdeleted(Constants.ZERO); applyChagneDetail.setApplyChangeId(applyChange.getId()); applyChagneDetail.setType(Constants.TWO); applyChagneDetail.setStartTime(applyDetail.getStartTime()); applyChagneDetail.setEndTime(applyDetail.getEndTime()); applyChagneDetailJoinMapper.insert(applyChagneDetail); member.setApplyId(applyChange.getApplyId()); member.setDuId(applyChagneDetail.getDuId()); member.setWorktypeId(applyChagneDetail.getWorktypeId()); // member.setStartTime(applyChagneDetail.getStartTime()); // member.setEndTime(applyChagneDetail.getEndTime()); memberMapper.updateById(member); } } @Override public void deleteById(Integer id) { applyChangeMapper.deleteById(id); } @Override public void delete(ApplyChange applyChange) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(applyChange); applyChangeMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } applyChangeMapper.deleteBatchIds(ids); } @Override public void updateById(ApplyChange applyChange) { applyChangeMapper.updateById(applyChange); } @Override public void updateByIdInBatch(List applyChanges) { if (CollectionUtils.isEmpty(applyChanges)) { return; } for (ApplyChange applyChange: applyChanges) { this.updateById(applyChange); } } @Override public ApplyChange findById(Integer id) { return applyChangeMapper.selectById(id); } @Override public ApplyChange findOne(ApplyChange applyChange) { QueryWrapper wrapper = new QueryWrapper<>(applyChange); return applyChangeMapper.selectOne(wrapper); } @Override public List findList(ApplyChange applyChange) { QueryWrapper wrapper = new QueryWrapper<>(applyChange); return applyChangeMapper.selectList(wrapper); } @Override public List findListByApplyId(Integer applyId,Integer type) { List applyChangeList = applyChangeMapper.selectList(new QueryWrapper() .lambda().eq(ApplyChange::getApplyId,applyId) .eq(Objects.nonNull(type),ApplyChange::getType,type) .in(ApplyChange::getStatus,Constants.ApplyChangeStatus.APPROVE.getKey()) ); return applyChangeList; } @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()); ApplyChange model = pageWrap.getModel() ; queryWrapper .selectAll(ApplyChange.class) .selectAs(InsuranceApply::getCode,ApplyChange::getApplyCode) .selectAs( Solutions::getType,InsuranceApply::getSolutionType) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 0 )",ApplyChange::getAddNum) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 1 )",ApplyChange::getDelNum) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 2 )",ApplyChange::getChangeNum) .select("( select ifnull(sum(ad.FEE),0) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID )",ApplyChange::getChangeMoney) .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .eq(!Objects.isNull(model.getType()),ApplyChange::getType,model.getType()) .eq(ApplyChange::getIsdeleted,Constants.ZERO) .eq(!Objects.isNull(model.getStatus())&&!model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus,model.getStatus()) .in(!Objects.isNull(model.getStatus())&&model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus, Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey(), Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) .eq(!Objects.isNull(model.getSolutionType()),Solutions::getType,model.getSolutionType()) .eq(!Objects.isNull(model.getCompanyId()),InsuranceApply::getCompanyId,model.getCompanyId()) .eq(!Objects.isNull(model.getSolutionsId()),ApplyChange::getSolutionsId,model.getSolutionsId()) .ge(StringUtils.isNotBlank(model.getCreateDateS()),ApplyChange::getCreateDate, model.getCreateDateS()+" 00:00:00" ) .le(StringUtils.isNotBlank(model.getCreateDateE()),ApplyChange::getCreateDate, model.getCreateDateE()+" 23:59:59" ); if(loginUserInfo.getType().equals(Constants.TWO)){ //如果是商户查看 if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType() ==0){ queryWrapper.exists("select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t1.company_id and cs.shop_id="+loginUserInfo.getCompanyId()); }else if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType() ==1){ queryWrapper.eq(Solutions::getShopId,loginUserInfo.getCompanyId()); }else{ queryWrapper.apply("((t1.type=0 and exists(select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t1.company_id and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" + "t2.type=1 and t2.shop_id="+loginUserInfo.getCompanyId()+"))") ; } } for(PageWrap.SortData sortData: pageWrap.getSorts()) { if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { queryWrapper.orderByDesc(sortData.getProperty()); } else { queryWrapper.orderByAsc(sortData.getProperty()); } } PageData pageData = PageData.from(applyChangeJoinMapper.selectJoinPage(page,ApplyChange.class, queryWrapper)); return pageData; } @Override public long count(ApplyChange applyChange) { QueryWrapper wrapper = new QueryWrapper<>(applyChange); return applyChangeMapper.selectCount(wrapper); } @Override public PageData findPageForCompany(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); ApplyChange model = pageWrap.getModel() ; queryWrapper .selectAll(ApplyChange.class) .selectAs(InsuranceApply::getCode,ApplyChange::getApplyCode) .selectAs(Solutions::getName,ApplyChange::getSolutionsName) .selectAs(Solutions::getType,ApplyChange::getSolutionType) .selectAs(Company::getName,ApplyChange::getCompanyName) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 0 )",ApplyChange::getAddNum) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 1 )",ApplyChange::getDelNum) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 2 )",ApplyChange::getChangeNum) .select("( select ifnull(sum(ad.FEE),0) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID )",ApplyChange::getChangeMoney) .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) .eq(!Objects.isNull(model.getType()),ApplyChange::getType,model.getType()) .eq(ApplyChange::getIsdeleted,Constants.ZERO) .eq(!Objects.isNull(model.getStatus())&&!model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus,model.getStatus()) .in(!Objects.isNull(model.getStatus())&&model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus, Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey(), Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) .eq(!Objects.isNull(model.getUnionApplyId()),InsuranceApply::getUnionApplyId,model.getUnionApplyId()) .eq(!Objects.isNull(model.getCompanyId()),InsuranceApply::getCompanyId,model.getCompanyId()) .eq(!Objects.isNull(model.getSolutionType()),Solutions::getType,model.getSolutionType()) .eq(!Objects.isNull(model.getApplyId()),ApplyChange::getApplyId,model.getApplyId()) .eq(!Objects.isNull(model.getBaseSolutionsId()),Solutions::getBaseId,model.getBaseSolutionsId()) .like(StringUtils.isNotBlank(model.getSolutionsName()),Solutions::getName,model.getSolutionsName()) .ge(StringUtils.isNotBlank(model.getCreateDateS()),ApplyChange::getCreateDate, model.getCreateDateS()+" 00:00:00" ) .le(StringUtils.isNotBlank(model.getCreateDateE()),ApplyChange::getCreateDate, model.getCreateDateE()+" 23:59:59" ) .ge(StringUtils.isNotBlank(model.getApplyStartS()),ApplyChange::getApplyStartTime, model.getApplyStartS()+" 00:00:00" ) .le(StringUtils.isNotBlank(model.getApplyStartE()),ApplyChange::getApplyStartTime, model.getApplyStartE()+" 23:59:59" ); LoginUserInfo loginUserInfo =(LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); //企业人员查看本企业数据 if(loginUserInfo.getType().equals(Constants.ONE)){ queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); }else if(loginUserInfo.getType().equals(Constants.TWO)){ //如果是商户查看 if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType() ==0){ queryWrapper.exists("select cs.id from company_solution cs where cs.isdeleted=0 AND cs.SOLUTION_ID = t1.SOLUTION_ID and cs.shop_id="+loginUserInfo.getCompanyId()); }else if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType() ==1){ queryWrapper.eq(Solutions::getShopId,loginUserInfo.getCompanyId()); }else{ queryWrapper.apply("((t2.type=0 and exists(select cs.id from company_solution cs where cs.isdeleted=0 AND cs.SOLUTION_ID = t1.SOLUTION_ID and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" + "t2.type=1 and t2.shop_id="+loginUserInfo.getCompanyId()+"))") ; } }else{ if(loginUserInfo.getCompanyIdList()!=null && loginUserInfo.getCompanyIdList().size()>0){ queryWrapper.in(InsuranceApply::getCompanyId, loginUserInfo.getCompanyIdList()); }else{ queryWrapper.eq(InsuranceApply::getCompanyId, -1); } queryWrapper.eq(pageWrap.getModel().getCompanyId()!=null,InsuranceApply::getCompanyId, pageWrap.getModel().getCompanyId()); } queryWrapper.orderByDesc(ApplyDetail::getCreateDate); PageData pageData = PageData.from(applyChangeJoinMapper.selectJoinPage(page,ApplyChange.class, queryWrapper)); for (ApplyChange applyChange:pageData.getRecords()) { applyChange.setChangeMoney(Constants.getTwoPoint(applyChange.getChangeMoney())); applyChange.setFee(Constants.getTwoPoint(applyChange.getFee())); } return pageData; } @Override public List monthTotalList(ApplyChange model){ if(model.getApplyId() ==null || model.getYear() == null){ return new ArrayList<>(); } MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper .select("count(t.id)",ApplyChange::getCountNum) .select("sum(t.fee)",ApplyChange::getFee) .select("DATE_FORMAT(t.create_date, '%Y-%m')",ApplyChange::getMonth) .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .eq(!Objects.isNull(model.getType()),ApplyChange::getType,model.getType()) .eq(ApplyChange::getApplyId,model.getApplyId()) .eq(!Objects.isNull(model.getStatus())&&!model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus,model.getStatus()) .in(!Objects.isNull(model.getStatus())&&model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()), ApplyChange::getStatus, Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey(), Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) .eq(ApplyChange::getIsdeleted,Constants.ZERO) .eq(!Objects.isNull(model.getSolutionType()),Solutions::getType,model.getSolutionType()) .eq(!Objects.isNull(model.getBaseSolutionsId()),Solutions::getBaseId,model.getBaseSolutionsId()) .like(StringUtils.isNotBlank(model.getSolutionsName()),Solutions::getName,model.getSolutionsName()) .ge( ApplyChange::getCreateDate, model.getYear()+"-01-01 00:00:00" ) .lt(ApplyChange::getCreateDate, (model.getYear()+1)+"-01-01 00:00:00") .groupBy("month" ); /* LoginUserInfo loginUserInfo =(LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); //企业人员查看本企业数据 if(loginUserInfo.getType().equals(Constants.ONE)){ queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); }else if(loginUserInfo.getType().equals(Constants.TWO)){ //如果是商户查看 if(model.getSolutionType()!=null && model.getSolutionType() ==0){ queryWrapper.exists("select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t1.company_id and cs.shop_id="+loginUserInfo.getCompanyId()); }else if(model.getSolutionType()!=null && model.getSolutionType() ==1){ queryWrapper.eq(Solutions::getShopId,loginUserInfo.getCompanyId()); }else{ queryWrapper.apply("((t2.type=0 and exists(select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t1.company_id and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" + "t2.type=1 and t2.shop_id="+loginUserInfo.getCompanyId()+"))") ; } }else{ if(loginUserInfo.getCompanyIdList()!=null && loginUserInfo.getCompanyIdList().size()>0){ queryWrapper.in(InsuranceApply::getCompanyId, loginUserInfo.getCompanyIdList()); }else{ queryWrapper.eq(InsuranceApply::getCompanyId, -1); } queryWrapper.eq(model.getCompanyId()!=null,InsuranceApply::getCompanyId, model.getCompanyId()); }*/ List list =applyChangeJoinMapper.selectJoinList(ApplyChange.class,queryWrapper); for (ApplyChange applyChange:list) { applyChange.setFee(Constants.getTwoPoint(applyChange.getFee())); } List result = new ArrayList<>(); for (int i = 1; i <= 12; i++) { if(i<10){ result.add(getMonthDayFromList(model.getYear() +"-0"+i,list)); }else{ result.add(getMonthDayFromList(model.getYear() +"-"+i,list)); } } return result; } private ApplyChange getMonthDayFromList(String s, List list) { for(ApplyChange d : list){ if(StringUtils.equals(s,d.getMonth())){ return d; } } ApplyChange d = new ApplyChange(); d.setMonth(s); d.setFee(new BigDecimal(0)); d.setCountNum(0); return d; } @Override public List findListForCompany(ApplyChange model) { MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper .selectAll(ApplyChange.class) .selectAs(InsuranceApply::getCode,ApplyChange::getApplyCode) .selectAs(InsuranceApply::getStartTime,ApplyChange::getStartTime) .selectAs(InsuranceApply::getCode,ApplyChange::getValidCode) .selectAs(InsuranceApply::getEndTime,ApplyChange::getEndTime) .selectAs(Solutions::getName,ApplyChange::getSolutionsName) .selectAs(Solutions::getType,ApplyChange::getSolutionType) .selectAs(Solutions::getHasDispatchUnit,ApplyChange::getHasDispatchUnit) .selectAs(Company::getName,ApplyChange::getCompanyName) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 0 )",ApplyChange::getAddNum) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 1 )",ApplyChange::getDelNum) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 2 )",ApplyChange::getChangeNum) .select("( select ifnull(sum(ad.FEE),0) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID )",ApplyChange::getChangeMoney) .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) .eq(!Objects.isNull(model.getType()),ApplyChange::getType,model.getType()) .eq(ApplyChange::getIsdeleted,Constants.ZERO) .eq(!Objects.isNull(model.getStatus())&&!model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()),ApplyChange::getStatus,model.getStatus()) .in(!Objects.isNull(model.getStatus())&&model.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()), ApplyChange::getStatus, Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey(), Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) .eq(!Objects.isNull(model.getUnionApplyId()),InsuranceApply::getUnionApplyId,model.getUnionApplyId()) // .eq(!Objects.isNull(model.getSolutionsId()),ApplyChange::getSolutionsId,model.getSolutionsId()) .eq(!Objects.isNull(model.getSolutionType()),Solutions::getType,model.getSolutionType()) .eq(!Objects.isNull(model.getApplyId()),ApplyChange::getApplyId,model.getApplyId()) .eq(!Objects.isNull(model.getUnionChangeId()),ApplyChange::getUnionChangeId,model.getUnionChangeId()) .eq(!Objects.isNull(model.getBaseSolutionsId()),Solutions::getBaseId,model.getBaseSolutionsId()) .like(StringUtils.isNotBlank(model.getSolutionsName()),Solutions::getName,model.getSolutionsName()) .ge(StringUtils.isNotBlank(model.getCreateDateS()),ApplyChange::getCreateDate, model.getCreateDateS()+" 00:00:00" ) .le(StringUtils.isNotBlank(model.getCreateDateE()),ApplyChange::getCreateDate, model.getCreateDateE()+" 23:59:59" ) .ge(StringUtils.isNotBlank(model.getApplyStartS()),ApplyChange::getApplyStartTime, model.getApplyStartS()+" 00:00:00" ) .le(StringUtils.isNotBlank(model.getApplyStartE()),ApplyChange::getApplyStartTime, model.getApplyStartE()+" 23:59:59" ); LoginUserInfo loginUserInfo =(LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); //企业人员查看本企业数据 if(loginUserInfo.getType().equals(Constants.ONE)){ queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); }else if(loginUserInfo.getType().equals(Constants.TWO)){ //如果是商户查看 if(model.getSolutionType()!=null && model.getSolutionType() ==0){ queryWrapper.exists("select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t1.company_id and cs.shop_id="+loginUserInfo.getCompanyId()); }else if(model.getSolutionType()!=null && model.getSolutionType() ==1){ queryWrapper.eq(Solutions::getShopId,loginUserInfo.getCompanyId()); }else{ queryWrapper.apply("((t2.type=0 and exists(select cs.id from company_solution cs where cs.isdeleted=0 and cs.company_id=t1.company_id and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" + "t2.type=1 and t2.shop_id="+loginUserInfo.getCompanyId()+"))") ; } }else{ if(loginUserInfo.getCompanyIdList()!=null && loginUserInfo.getCompanyIdList().size()>0){ queryWrapper.in(InsuranceApply::getCompanyId, loginUserInfo.getCompanyIdList()); }else{ queryWrapper.eq(InsuranceApply::getCompanyId, -1); } queryWrapper.eq(model.getCompanyId()!=null,InsuranceApply::getCompanyId, model.getCompanyId()); } queryWrapper.orderByDesc(ApplyDetail::getCreateDate); List list =applyChangeJoinMapper.selectJoinList(ApplyChange.class,queryWrapper); if(Constants.equalsObject(model.getGetFiles(),Constants.ONE)){ //如果是合并单,需要查询附件信息 initFileForList(list); } return list; } private void initFileForList(List list) { List objList = new ArrayList<>(); if(list!=null && list.size()>0){ for(ApplyChange param : list){ objList.add(param.getId()); } }else{ return; } List multifiles = multifileMapper.selectList(new QueryWrapper().lambda() .in(Multifile::getObjId,objList) .in(Multifile::getObjType,Arrays.asList(new Integer[]{Constants.MultiFile.CA_PD_PDF.getKey()})) .eq(Multifile::getIsdeleted,Constants.ZERO) .orderByAsc(Multifile::getId)); if(multifiles!=null && multifiles.size()>0){ String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode() +systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode(); for(ApplyChange model : list){ List multifileList = multifiles.stream().filter(m->Constants.equalsInteger(m.getObjId(), model.getId())&& Constants.equalsInteger(m.getObjType(), Constants.MultiFile.CA_PD_PDF.getKey())).collect(Collectors.toList()); if(CollectionUtils.isNotEmpty(multifileList)){ for (Multifile multifile:multifileList) { multifile.setFileurlFull(path + multifile.getFileurl()); } model.setPidanFileList(multifileList); } } } } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void changeOpt(ApplyChangeOptDTO applyChangeOptDTO){ if(Objects.isNull(applyChangeOptDTO) ||Objects.isNull(applyChangeOptDTO.getApplyId()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); ApplyChange applyChange = applyChangeMapper.selectById(applyChangeOptDTO.getApplyId()); if(Objects.isNull(applyChange)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到单据数据"); } InsuranceApply insuranceApply = insuranceApplyMapper.selectById(applyChange.getApplyId()); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保单数据"); } if(applyChange.getIsdeleted().equals(Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"数据已删除,无法进行该操作"); } Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); } Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_PLATFORM_CHECK_PASS_NO; Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; if(applyChange.getType().equals(Constants.ONE)){ noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; } if(applyChangeOptDTO.getOptType().equals(3)){ //发起退回申请 if(!loginUserInfo.getType().equals(Constants.ONE)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非企业端用户无法进行该操作"); } if(!(applyChange.getStatus().equals(Constants.ApplyChangeStatus.UPLOAD.getKey()) || applyChange.getStatus().equals(Constants.ApplyChangeStatus.SIGNATURE.getKey()))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进退回申请!"); } if(applyChange.getStatus().equals(Constants.ApplyChangeStatus.UPLOAD.getKey())){ applyChange.setStatus(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()); }else{ applyChange.setStatus(Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()); } //存储待办信息 //删除其他待办 noticesMapper.delete(new QueryWrapper().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,applyChange.getId())); Notices notices = new Notices(noticeObjectType,Constants.ZERO,applyChange.getId(),solutions.getName(), insuranceApply.getCompanyId(), Constants.NoticeType.THREE); noticesMapper.insert(notices); //商户待办 if(Objects.nonNull(solutions.getShopId())){ Notices shopNotices = new Notices(noticeObjectType,Constants.TWO, applyChange.getId(),solutions.getName(),solutions.getShopId(),Constants.NoticeType.THREE); noticesMapper.insert(shopNotices); } }else if(applyChangeOptDTO.getOptType().equals(4)){ applyLogType = Constants.ApplyLogType.CA_PLATFORM_AGREE_BACK_APPLY; //平台同意退回 if(loginUserInfo.getType().equals(Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非平台端用户无法进行该操作"); } if(!(applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()) ||applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) )){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进行该操作!"); } }else if(applyChangeOptDTO.getOptType().equals(5)){ applyLogType = Constants.ApplyLogType.CA_PALTFORM_REFUSE_APPLY; //平台驳回退回 if(loginUserInfo.getType().equals(Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非平台端用户无法进行该操作"); } if(!(applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey()) ||applyChangeOptDTO.getOptType().equals(Constants.ApplyChangeStatus.RETURN_APPLY_SIGNATURE.getKey()) )){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进行该操作!"); } if(applyChange.getStatus().equals(Constants.ApplyChangeStatus.RETURN_APPLY_UPLOAD.getKey())){ applyChange.setStatus(Constants.ApplyChangeStatus.UPLOAD.getKey()); }else{ applyChange.setStatus(Constants.ApplyChangeStatus.SIGNATURE.getKey()); } }else if(applyChangeOptDTO.getOptType().equals(6)){ //企业关闭 applyLogType = Constants.ApplyLogType.CA_COMPANY_CLOSE; if(!(applyChange.getStatus().equals(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey()) ||applyChange.getStatus().equals(Constants.ApplyChangeStatus.CHECHED_PASSED.getKey()))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"数据状态错误无法进行该操作!"); } applyChange.setStatus(Constants.ApplyChangeStatus.CLOSE.getKey()); //存储待办信息 //删除其他待办 noticesMapper.delete(new QueryWrapper().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,applyChange.getId())); }else{ throw new BusinessException(ResponseStatus.BAD_REQUEST ); } applyChange.setEditor(loginUserInfo.getId()); applyChange.setEditDate(new Date()); applyChangeMapper.updateById(applyChange); String info = applyLogType.getInfo(); if(StringUtils.isNotBlank(applyChangeOptDTO.getOptIllustration())){ info = info.replace("${param}", applyChangeOptDTO.getOptIllustration()); }else{ info = info.replace("${param}", ""); } ApplyLog log = new ApplyLog(applyChange,applyLogType.getName(),info,applyChange.getId(),applyLogType.getKey(), null, null); applyLogMapper.insert(log); } @Override public ApplyChange findDetail(Integer id){ MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(ApplyChange.class) .selectAs(InsuranceApply::getCode,ApplyChange::getApplyCode) .selectAs(Company::getId,ApplyChange::getCompanyId) .selectAs(Company::getName,ApplyChange::getCompanyName) .selectAs(InsuranceApply::getStartTime,ApplyChange::getStartTime) .selectAs(InsuranceApply::getEndTime,ApplyChange::getEndTime) .selectAs(Solutions::getName,ApplyChange::getSolutionsName) .selectAs(Solutions::getType,ApplyChange::getSolutionType) .selectAs(Solutions::getId,ApplyChange::getSolutionsId) .selectAs(Solutions::getDelOnlyReplace,ApplyChange::getDelOnlyReplace) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 0 )",ApplyChange::getAddNum) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 1 )",ApplyChange::getDelNum) .select("( select count(1) from apply_chagne_detail ad where t.id = ad.APPLY_CHANGE_ID and ad.TYPE = 2 )",ApplyChange::getChangeNum) .select(" ( select max(ac.APPLY_START_TIME) from apply_change ac where ac.apply_id = t.apply_id and ac.status = 2 ) as lastChangeDate") .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) .eq(ApplyChange::getId,id); ApplyChange applyChange = applyChangeJoinMapper.selectOne(queryWrapper); //查询操作记录 List applyLogList = applyLogJoinMapper.selectJoinList(ApplyLog.class, new MPJLambdaWrapper() .selectAll(ApplyLog.class) .selectAs(SystemUser::getRealname,ApplyLog::getCreatorName) .selectAs(SystemUser::getType,ApplyLog::getCreatorType) .selectAs(Company::getName,ApplyLog::getCompanyName) .leftJoin(SystemUser.class,SystemUser::getId,ApplyLog::getCreator) .leftJoin(Company.class,Company::getId,SystemUser::getCompanyId) .in(ApplyLog::getObjType,Constants.ApplyLogType.getTypeList(Constants.ONE)) .eq(ApplyLog::getObjId,applyChange.getId()) .orderByAsc(ApplyLog::getCreateDate) ); applyChange.setApplyLogList(applyLogList); applyChange.setFee(Constants.getTwoPoint(applyChange.getFee())); List multifiles = multifileMapper.selectList(new QueryWrapper().lambda() .eq(Multifile::getObjId, applyChange.getId() ) // .in(Multifile::getObjType, Arrays.asList(new Integer[]{Constants.MultiFile.CA_APPLY_JIAJIAN_SIGN.getKey() // ,Constants.MultiFile.CA_PD_PDF.getKey() // ,Constants.MultiFile.CA_APPLY_CHANGEUNIT_SIGN.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.CA_APPLY_JIAJIAN_SIGN.getKey())){ //签署后申请单 applyChange.setApplyFile(f); }else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.CA_APPLY_CHANGEUNIT_SIGN.getKey())){ //签署后申请单 applyChange.setApplyUnitFile(f); } // else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.CA_PD_PDF.getKey())){ // //签署后的投保单 // applyChange.setPidanFile(f); // } } List multifileList = multifiles.stream().filter(m->Constants.equalsInteger(m.getObjId(), applyChange.getId())&& Constants.equalsInteger(m.getObjType(), Constants.MultiFile.CA_PD_PDF.getKey())).collect(Collectors.toList()); if(CollectionUtils.isNotEmpty(multifileList)){ for (Multifile multifile:multifileList) { multifile.setFileurlFull(path + multifile.getFileurl()); } applyChange.setPidanFileList(multifileList); } } return applyChange; } /** * 导出换厂申请表 * @param param * @return */ @Override public ApplyChange exportChangeUnitExcel(ApplyChange param){ ApplyChange model = findJoinDetail(param); if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getIsdeleted())){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } //查询明细 List detailList =findJoinChangeDetailList(model); model.setChangeDetailList(detailList!=null?detailList:new ArrayList<>()); model.setChangeNum(model.getChangeDetailList().size()); return model; } /** * 导出换厂申请表 * @param param * @return */ @Override public String getSignLinkJiajiabao(ApplyChange param){ ApplyChange model = exportJiajianBaoExcel(param); return getOnlineSignLink(model); } /** * 导出换厂申请表 * @param param * @return */ @Override public String getSignLinkChangeUnit(ApplyChange param){ ApplyChange model = exportChangeUnitExcel(param); return getOnlineSignLink(model); } private String getOnlineSignLink(ApplyChange model) { if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getIsdeleted())){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(!Constants.equalsInteger(Constants.ZERO,model.getStatus())){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该申请状态已流转，当前不支持签章操作！"); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); InsuranceApply insuranceApply = insuranceApplyMapper.selectById(model.getApplyId()); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询保单信息"); } Company company = companyMapper.selectById(insuranceApply.getCompanyId()); if(Objects.isNull(company)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到企业信息"); } String companyName = company.getName(); String creditCode = company.getCode(); String email = company.getEmail(); /*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(),"对不起，企业尚未具备在线签章条件，请联系平台管理员确认~"); } Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); } String fileUrl = null; if(Constants.equalsObject(model.getType(), Constants.ONE)){ fileUrl = ExcelExporter.build(ApplyChange.class).exportChangeUnitExcelToPdf(model,"换厂申请表","投保企业"); }else{ fileUrl = ExcelExporter.build(ApplyChange.class).exportJiajianBaoExcelToPdf(model,"加减保申请表","投保企业"); } 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.applySignLocalFileByParam(company.getName(),company.getName(),fileUrl,company.getCode(),company.getEmail(),"投保企业签章",company.getSignId(),notifyUrl,new Float(0.7)); //临时使用 // fileUrl = // "https://yybred.oss-cn-hangzhou.aliyuncs.com/apply/20241120/1c80f0d7-ab35-4355-b9fe-944464643115.pdf"; // String applyNo = signService.applySign(companyName,fileUrl,companyName,creditCode,email,"人员名单签章",null,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(),"对不起，获取在线签章地址失败，请稍后重试！"); } ApplyChange update= new ApplyChange(); update.setId(model.getId()); update.setEditor(user.getId()); update.setEditDate(new Date()); update.setSignApplyNo(applyNo); applyChangeMapper.updateById(update); return link; } /** * 导出加减保申请表 * @param param * @return */ @Override public ApplyChange exportJiajianBaoExcel(ApplyChange param){ ApplyChange model = findJoinDetail(param); if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getIsdeleted())){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } //查询明细 List detailList =findJoinDetailList(model); model.setAddDetailList(new ArrayList<>()); model.setDelDetailList(new ArrayList<>()); if(detailList!=null){ for(ApplyChagneDetail ad :detailList){ if(Constants.equalsInteger(ad.getType(),Constants.ZERO)){ model.getAddDetailList().add(ad); }else{ model.getDelDetailList().add(ad); } } } model.setDelNum(model.getDelDetailList().size()); model.setAddNum(model.getAddDetailList().size()); return model; } private ApplyChange findJoinDetail(ApplyChange param) { MPJLambdaWrapper wrapper= new MPJLambdaWrapper() .selectAll(ApplyChange.class) .selectAs(Solutions::getName,ApplyChange::getSolutionsName) .selectAs(Company::getName,ApplyChange::getCompanyName) .selectAs(InsuranceApply::getCompanyId,ApplyChange::getCompanyId) .selectAs(InsuranceApply::getCode,ApplyChange::getApplyCode) .selectAs(InsuranceApply::getStartTime,ApplyChange::getStartTime) .selectAs(InsuranceApply::getEndTime,ApplyChange::getEndTime) .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId) .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId) .eq(ApplyChange::getId,param.getId()) .last("limit 1"); ApplyChange model = applyChangeJoinMapper.selectJoinOne(ApplyChange.class,wrapper); return model; } private List findJoinDetailList(ApplyChange model) { MPJLambdaWrapper wrapper1= new MPJLambdaWrapper() .selectAll(ApplyChagneDetail.class) .selectAs(Member::getName,ApplyChagneDetail::getMemberName) .selectAs(Member::getSex,ApplyChagneDetail::getSex) .selectAs(Member::getIdcardNo,ApplyChagneDetail::getMemberIdcardNo) .selectAs(Worktype::getName,ApplyChagneDetail::getWorkTypeName) .selectAs(DispatchUnit::getName,ApplyChagneDetail::getDuName) .leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getWorktypeId) .leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getDuId) .leftJoin(Member.class,Member::getId,ApplyChagneDetail::getMemberId) .eq(ApplyChagneDetail::getIsdeleted,Constants.ZERO) .eq(ApplyChagneDetail::getApplyChangeId,model.getId()); //查询明细 List detailList =applyChagneDetailJoinMapper.selectJoinList(ApplyChagneDetail.class,wrapper1); return detailList; } private List findJoinChangeDetailList(ApplyChange model) { MPJLambdaWrapper wrapper1= new MPJLambdaWrapper() .selectAll(ApplyChagneDetail.class) .selectAs(Member::getName,ApplyChagneDetail::getMemberName) .selectAs(Member::getSex,ApplyChagneDetail::getSex) .select("t1.name as worktypeName") .select("t2.name as duName") .select("t3.name as oldWorktypeName") .select("t4.name as oldDuName") .selectAs(Member::getSex,ApplyChagneDetail::getSex) .selectAs(Member::getIdcardNo,ApplyChagneDetail::getMemberIdcardNo) .leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getWorktypeId) .leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getDuId) .leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getOldWorktypeId) .leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getOldDuId) .leftJoin(Member.class,Member::getId,ApplyChagneDetail::getMemberId) .eq(ApplyChagneDetail::getIsdeleted,Constants.ZERO) .eq(ApplyChagneDetail::getApplyChangeId,model.getId()); //查询明细 List detailList =applyChagneDetailJoinMapper.selectJoinList(ApplyChagneDetail.class,wrapper1); return detailList; } /** * 加减保申请时 查询加减金额 * @param applyChangeCyclePriceDTO * @return */ @Override public CountCyclePriceVO getChangeCountCyclePriceVO(ApplyChangeCyclePriceDTO applyChangeCyclePriceDTO){ if(Objects.isNull(applyChangeCyclePriceDTO) || Objects.isNull(applyChangeCyclePriceDTO.getApplyId()) || Objects.isNull(applyChangeCyclePriceDTO.getValidTime())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } InsuranceApply insuranceApply = insuranceApplyMapper.selectById(applyChangeCyclePriceDTO.getApplyId()); if(Objects.isNull(insuranceApply)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保单"); } Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); } ApplyDetail applyDetail = applyDetailJoinMapper.selectOne(new QueryWrapper().lambda().eq(ApplyDetail::getIsdeleted,Constants.ZERO).eq(ApplyDetail::getApplyId,insuranceApply.getId()).last("limit 1")); if(Objects.isNull(applyDetail)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保单明细记录"); } //根据批单日期 和 结束日期 计算金额 //验证批单日期是否在当前日期后 且 在保单结束日期前 申请时间必须处于保单的时间范围内 // if (!(DateUtil.compareDate( insuranceApply.getStartTime(),applyChangeCyclePriceDTO.getValidTime()) >= Constants.ZERO // && DateUtil.compareDate( applyChangeCyclePriceDTO.getValidTime(),insuranceApply.getEndTime()) >= Constants.ZERO)) { // throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "申请日期未处于保单日期内，无法进行该操作"); // } BigDecimal sumPrice = Objects.isNull(insuranceApply.getServerCost())?solutions.getPrice():solutions.getPrice().add(insuranceApply.getServerCost()); CountCyclePriceVO returnCountCyclePriceVO = new CountCyclePriceVO(); Date addStartTime = DateUtil.afterDateByType(applyChangeCyclePriceDTO.getValidTime(),0,solutions.getAddValidDays()); if(addStartTime.getTime() queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(ApplyChagneDetail.class); queryWrapper.select("t2.name",ApplyChagneDetail::getWorkTypeName); queryWrapper.select("t3.name",ApplyChagneDetail::getDuName); queryWrapper.select("t4.name",ApplyChagneDetail::getOldWorkTypeName); queryWrapper.select("t5.name",ApplyChagneDetail::getOldDuName); queryWrapper.selectAs(Member::getName,ApplyChagneDetail::getMemberName); queryWrapper.selectAs(Member::getSex,ApplyChagneDetail::getSex); queryWrapper.selectAs(Member::getIdcardNo,ApplyChagneDetail::getMemberIdcardNo); queryWrapper.leftJoin(Member.class,Member::getId,ApplyChagneDetail::getMemberId); queryWrapper.leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getWorktypeId); queryWrapper.leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getDuId); queryWrapper.leftJoin(Worktype.class,Worktype::getId,ApplyChagneDetail::getOldWorktypeId); queryWrapper.leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyChagneDetail::getOldDuId); queryWrapper.eq(ApplyChagneDetail::getApplyChangeId,applyChangeId); List list = applyChangeDetailJoinMapper.selectJoinList(ApplyChagneDetail.class, queryWrapper); for (ApplyChagneDetail applyChagneDetail:list) { applyChagneDetail.setAge(Constants.getAgeByIdCard(applyChagneDetail.getMemberIdcardNo())); } if(CollectionUtils.isNotEmpty(list)){ model.setAddDetailList(list.stream().filter(m->m.getType().equals(Constants.ZERO)).collect(Collectors.toList())); model.setDelDetailList(list.stream().filter(m->m.getType().equals(Constants.ONE)).collect(Collectors.toList())); model.setChangeDetailList(list.stream().filter(m->m.getType().equals(Constants.TWO)).collect(Collectors.toList())); } return model; } /** * 人员名单签章 */ @Override public String getChangeMemberListOnlineSignLink(SmsCheckDTO smsCheckDTO) { if(Objects.isNull(smsCheckDTO) || Objects.isNull(smsCheckDTO.getBusinessId()) // || StringUtils.isBlank(smsCheckDTO.getCode()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } ApplyChange model = this.queryApplyChangeData(smsCheckDTO.getBusinessId()); if(Objects.isNull(model)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询加减保/换厂信息"); } if(Objects.isNull(model) ||! Constants.equalsInteger(Constants.ZERO,model.getIsdeleted())){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); Company 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(),"对不起，企业尚未具备在线签章条件，请联系平台管理员确认~"); } Solutions solutions = solutionsMapper.selectById(model.getSolutionsId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); } String fileUrl = null; if(solutions.getType().equals(Constants.ONE)){ if(!Constants.equalsInteger(Constants.ZERO,model.getStatus())){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该申请状态已流转，当前不支持签章操作！"); } if(Constants.equalsObject(model.getType(), Constants.ONE)){ fileUrl = ExcelExporter.build(ApplyChange.class).exportChangeUnitExcelToPdf(model,"换厂申请表","被保险人"); }else{ fileUrl = ExcelExporter.build(ApplyChange.class).exportJiajianBaoExcelToPdf(model,"加减保申请表","被保险人"); } String notifyUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SIGN_DONE_NOTIFY_URL).getCode(); notifyUrl = notifyUrl.replace("${type}","0").replace("${id}",model.getId().toString()); //临时使用 // fileUrl = "https://yybred.oss-cn-hangzhou.aliyuncs.com/apply/20241230/a0d128f2-ba6c-4ad4-b86b-b2610a513d41.pdf"; // String applyNo = signService.applySignDoByParam(company.getName(),fileUrl,company.getName(),company.getCode(),company.getEmail(),"人员名单签章",company.getSignId(),notifyUrl,new Float(0.7)); String applyNo = signService.applySignLocalFileByParam(company.getName(),company.getName(),fileUrl,company.getCode(),company.getEmail(),"人员名单签章",company.getSignId(),notifyUrl,new Float(0.7)); 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(),"对不起，获取在线签章地址失败，请稍后重试！"); } ApplyChange update= new ApplyChange(); update.setId(model.getId()); update.setEditor(user.getId()); update.setEditDate(new Date()); update.setSignMemberListNo(applyNo); applyChangeMapper.updateById(update); return link; }else{ if(model.getType().equals(Constants.ONE)){ return this.getSignLinkChangeUnit(model); }else{ return this.getSignLinkJiajiabao(model); } } } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer check(ApplyChange applyChange,UnionChangeServiceImpl unionChangeService) { LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(!(Constants.equalsInteger(user.getType(),Constants.ZERO) || Constants.equalsInteger(user.getType(),Constants.TWO))){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户端无法进行该操作"); } if(applyChange.getId() == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } if(Objects.isNull(applyChange)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } ApplyChange model = applyChangeJoinMapper.selectJoinOne(ApplyChange.class, new MPJLambdaWrapper() .selectAll(ApplyChange.class) .selectAs(InsuranceApply::getSolutionId,ApplyChange::getSolutionsId) .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId) .eq(ApplyChange::getId,applyChange.getId()) .last(" limit 1") ); if(model == null ||!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } Solutions solutions = solutionsMapper.selectById(model.getSolutionsId()); if(Objects.isNull(solutions)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息"); } if(solutions.getType().equals(Constants.ZERO)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"直保单据无法进行该操作"); }else{ if(!Constants.equalsInteger(model.getStatus(),Constants.ApplyChangeStatus.SIGNATURE.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~"); } } ApplyChange update = new ApplyChange(); update.setEditDate(new Date()); update.setEditor(user.getId()); update.setCheckDate(update.getEditDate()); update.setCheckInfo(applyChange.getCheckInfo()); update.setCheckUserId(user.getId()); update.setId(model.getId()); if(applyChange.getDealBackApply() ==1){ //如果是不通过 update.setStatus(Constants.ApplyChangeStatus.PLATFORM_AGREE.getKey()); }else{ update.setStatus(Constants.ApplyChangeStatus.CHECHED_PASSED.getKey()); } applyChangeJoinMapper.updateById(update); Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_HBD_AUDIT; String info = applyChange.getCheckInfo(); if(StringUtils.isNotBlank(applyChange.getCheckInfo())){ info = info.replace("${param}", applyChange.getCheckInfo()); }else{ info = info.replace("${param}", ""); } ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(), null, null); applyLogMapper.insert(log); Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE; if(Constants.equalsInteger(model.getType(),Constants.ONE)){ noticeObjectType = Constants.NoticeObjectType.CHANGE_FACTORY; } //删除全部待办 noticesMapper.delete(new QueryWrapper().lambda() .eq(Notices::getObjType, noticeObjectType.getKey()) .eq(Notices::getObjId, model.getId())); if(Constants.equalsInteger(applyChange.getDealBackApply(),Constants.ZERO)){ InsuranceApply insuranceApply = insuranceApplyMapper.selectById(model.getApplyId()); if(Objects.isNull(insuranceApply)||Objects.isNull(insuranceApply.getUnionApplyId())){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到保单数据"); } SaveUnionChangeDTO saveUnionChangeDTO = new SaveUnionChangeDTO(); saveUnionChangeDTO.setApplyDate(model.getValidTime()); List applyIds = new ArrayList<>(); applyIds.add(model.getId()); saveUnionChangeDTO.setApplyIds(applyIds); saveUnionChangeDTO.setApplyChange(model); saveUnionChangeDTO.setUnionApplyId(insuranceApply.getUnionApplyId()); saveUnionChangeDTO.setBusinessType(model.getType()); if(Constants.equalsInteger(user.getType(),Constants.TWO)){ saveUnionChangeDTO.setShopId(user.getCompanyId()); }else{ CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper() .lambda().eq(CompanySolution::getSolutionBaseId,solutions.getBaseId()) .eq(CompanySolution::getCompanyId,insuranceApply.getCompanyId()).last(" limit 1 ")); if(Objects.isNull(companySolution)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到企业方案信息"); } saveUnionChangeDTO.setShopId(companySolution.getShopId()); } unionChangeService.merge(saveUnionChangeDTO); } return 1; } // BigDecimal cycle1 = new BigDecimal(days).divide(insureCycleUnit.getDays(),0,RoundingMode.CEILING); // // if(solutions.getTimeUnit().equals(Constants.TimeUnit.MONTH.getValue())){ // if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.HALF_MONTH.getValue())){ // BigDecimal cycle = new BigDecimal(days).divide(Constants.InsureCycleUnit.HALF_MONTH.getDays(),0,RoundingMode.CEILING); // return fee.multiply(cycle).divide(new BigDecimal(2),2, RoundingMode.HALF_UP); // }else{ // throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"方案配置错误"); // } // }else if(solutions.getTimeUnit().equals(Constants.TimeUnit.QUARTER.getValue())){ // if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.HALF_MONTH.getValue())){ // BigDecimal cycle = new BigDecimal(days).divide(Constants.InsureCycleUnit.HALF_MONTH.getDays(),0,RoundingMode.CEILING); // return fee.multiply(cycle).divide(new BigDecimal(6),2, RoundingMode.HALF_UP); // }else if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.MONTH.getValue())){ // BigDecimal cycle = new BigDecimal(DateUtil.getDifferenceMonths(new Date(),startTime)); // return fee.multiply(cycle).divide(new BigDecimal(3),2, RoundingMode.HALF_UP); // }else{ // throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"方案配置错误"); // } // }else if(solutions.getTimeUnit().equals(Constants.TimeUnit.HALF_YEAR.getValue())){ // if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.HALF_MONTH.getValue())){ // BigDecimal cycle = new BigDecimal(days).divide(Constants.InsureCycleUnit.HALF_MONTH.getDays(),0,RoundingMode.CEILING); // return fee.multiply(cycle).divide(new BigDecimal(12),2, RoundingMode.HALF_UP); // }else if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.MONTH.getValue())){ // BigDecimal cycle = new BigDecimal(DateUtil.getDifferenceMonths(new Date(),startTime)); // return fee.multiply(cycle).divide(new BigDecimal(6),2, RoundingMode.HALF_UP); // }else if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.QUARTER.getValue())){ // BigDecimal cycle = new BigDecimal(DateUtil.getDifferenceMonths(new Date(),startTime)); // cycle = cycle.divide(new BigDecimal(3),0,RoundingMode.CEILING); // return fee.multiply(cycle).divide(new BigDecimal(2),2, RoundingMode.HALF_UP); // }else{ // throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"方案配置错误"); // } // }else if(solutions.getTimeUnit().equals(Constants.TimeUnit.YEAR.getValue())){ // if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.HALF_MONTH.getValue())){ // BigDecimal cycle = new BigDecimal(days).divide(Constants.InsureCycleUnit.HALF_MONTH.getDays(),0,RoundingMode.CEILING); // return fee.multiply(cycle).divide(new BigDecimal(24),2, RoundingMode.HALF_UP); // }else if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.MONTH.getValue())){ // BigDecimal cycle = new BigDecimal(DateUtil.getDifferenceMonths(new Date(),startTime)); // return fee.multiply(cycle).divide(new BigDecimal(12),2, RoundingMode.HALF_UP); // }else if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.QUARTER.getValue())){ // BigDecimal cycle = new BigDecimal(DateUtil.getDifferenceMonths(new Date(),startTime)); // cycle = cycle.divide(new BigDecimal(3),0,RoundingMode.CEILING); // return fee.multiply(cycle).divide(new BigDecimal(4),2, RoundingMode.HALF_UP); // }else if(solutions.getInsureCycleUnit().equals(Constants.InsureCycleUnit.HALF_YEAR.getValue())){ // BigDecimal cycle = new BigDecimal(DateUtil.getDifferenceMonths(new Date(),startTime)); // cycle = cycle.divide(new BigDecimal(6),0,RoundingMode.CEILING); // return fee.multiply(cycle).divide(new BigDecimal(2),2, RoundingMode.HALF_UP); // }else{ // throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"方案配置错误"); // } // }else{ // throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"方案配置错误"); // } }