productDev/yunyibao.git

			@@ -2,7 +2,6 @@

			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.constants.ResponseStatus;
			@@ -15,13 +14,13 @@
			import com.doumee.core.utils.Utils;
			import com.doumee.core.utils.aliyun.ALiYunUtil;
			import com.doumee.dao.business.*;
			import com.doumee.dao.business.dto.CountCyclePriceDTO;
			import com.doumee.dao.business.dto.InsuranceApplyOptDTO;
			import com.doumee.dao.business.dto.InsuranceApplyQueryDTO;
			import com.doumee.dao.business.dto.SmsCheckDTO;
			import com.doumee.dao.business.dto.*;
			import com.doumee.dao.business.join.*;
			import com.doumee.dao.business.model.*;
			import com.doumee.dao.business.vo.ApplyPowerVO;
			import com.doumee.dao.business.vo.CountCyclePriceVO;
			import com.doumee.dao.business.vo.dataBoard.InsuranceDataVO;
			import com.doumee.dao.system.SystemUserMapper;
			import com.doumee.dao.system.model.SystemUser;
			import com.doumee.service.business.InsuranceApplyService;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			@@ -37,6 +36,8 @@
			import io.swagger.models.auth.In;
			import org.apache.commons.lang3.StringUtils;
			import org.apache.shiro.SecurityUtils;
			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;
			@@ -57,14 +58,12 @@
			public class InsuranceApplyServiceImpl implements InsuranceApplyService {
			@Value("${debug_model}")
			private boolean debugModel;

			@Autowired
			private InsuranceApplyMapper insuranceApplyMapper;
			@Autowired
			private SmsEmailService smsEmailService;
			@Autowired
			private ApplyChangeJoinMapper applyChangeMapper;

			@Autowired
			private SystemDictDataBiz systemDictDataBiz;
			@Autowired
			@@ -73,38 +72,30 @@
			private CompanyMapper companyMapper;
			@Autowired
			private MemberInsuranceJoinMapper memberInsuranceJoinMapper;

			@Autowired
			private ApplyDetailMapper applyDetailMapper;
			@Autowired
			private ApplyDetailJoinMapper applyDetailJoinMapper;

			@Autowired
			private ApplyLogMapper applyLogMapper;
			@Autowired
			private SignService signService;
			@Autowired
			private MultifileMapper multifileMapper;

			@Autowired
			private ApplyLogJoinMapper applyLogJoinMapper;

			@Autowired
			private SolutionsMapper solutionsMapper;

			@Autowired
			private MemberMapper memberMapper;
			@Autowired
			private MemberJoinMapper memberJoinMapper;
			@Autowired
			private DuSolutionMapper duSolutionMapper;
			@Autowired
			private DuSolutionJoinMapper duSolutionJoinMapper;
			@Autowired
			private DuWorktypeMapper duWorktypeMapper;
			@Autowired
			private DuWorkTypeJoinMapper duWorkTypeJoinMapper;

			@Autowired
			private SolutionWorktypeJoinMapper solutionWorktypeJoinMapper;
			@Autowired
			private NoticesMapper noticesMapper;
			@Autowired
			@@ -113,221 +104,16 @@
			private UnionChangeJoinMapper unionChangeJoinMapper;
			@Autowired
			private CompanySolutionMapper companySolutionMapper;

			@Override
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			public Integer back(InsuranceApply insuranceApply) {
			if(insuranceApply.getId() == null \|\|StringUtils.isBlank(insuranceApply.getCheckInfo())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());
			if(model == null \|\|!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
			if(Objects.isNull(solutions)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
			}
			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			InsuranceApply update = new InsuranceApply();
			if(Constants.equalsInteger(solutions.getType(),Constants.ZERO)){
			if(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			update.setStatus(Constants.InsuranceApplyStatus.FAIL_RETURN.getKey());
			}else{
			if( !(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_MEMBER_LIST_SIGNATURE.getKey())
			\|\| Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
			\|\| Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey()))){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			update.setStatus(Constants.InsuranceApplyStatus.WTB_RETURN.getKey());
			}

			update.setEditDate(new Date());
			update.setEditor(user.getId());
			update.setCheckDate(update.getEditDate());
			update.setCheckInfo(insuranceApply.getCheckInfo());
			update.setCheckUserId(user.getId());
			update.setId(model.getId());
			insuranceApplyMapper.updateById(update);

			//存储待办信息
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
			//删除其他待办
			noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
			.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
			.eq(Notices::getObjId,insuranceApply.getId()));
			Notices notices = new Notices(noticeObjectType,Constants.ONE,insuranceApply.getId(),solutions.getName(),
			model.getCompanyId(), Constants.NoticeType.FOUR);
			noticesMapper.insert(notices);
			@Autowired
			private ContractJoinMapper contractJoinMapper;
			@Autowired
			private SystemUserMapper systemUserMapper;
			@Autowired
			private CompanyDepartmentMapper companyDepartmentMapper;


			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.PLATFORM_RETURN;
			String info =applyLogType.getInfo();
			info = info.replace("${param}", update.getCheckInfo());
			ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);
			return 1;

			}
			@Override
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			public Integer closeWtbForShop(InsuranceApply insuranceApply) {
			if(insuranceApply.getId() == null \|\|StringUtils.isBlank(insuranceApply.getCheckInfo())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());

			if(model == null \|\|!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			//只有审核通过的状态可关闭
			if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_BUSINESS_CHECK_PASS.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			InsuranceApply update = new InsuranceApply();
			update.setEditDate(new Date());
			update.setEditor(user.getId());
			update.setStatus(Constants.InsuranceApplyStatus.WTB_CLOSED.getKey());
			update.setCheckDate(update.getEditDate());
			update.setCheckInfo(insuranceApply.getCheckInfo());
			update.setCheckUserId(user.getId());
			update.setId(model.getId());
			insuranceApplyMapper.updateById(update);

			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.SHOP_CLOSE_WTB_APPLY;
			String info =applyLogType.getInfo();
			info = info.replace("${param}", update.getCheckInfo());
			ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);
			return 1;
			}

			@Override
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			public Integer uploadBaoxiandan(InsuranceApply insuranceApply) {
			if(insuranceApply.getId() == null
			\|\| insuranceApply.getCode() == null
			\|\| insuranceApply.getStartTime() == null
			\|\| insuranceApply.getBaoxiandanFile() == null
			\|\|StringUtils.isBlank( insuranceApply.getBaoxiandanFile() .getFileurl())
			\|\|StringUtils.isBlank( insuranceApply.getBaoxiandanFile() .getName())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}

			InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());
			if(model == null \|\|!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.SIGNATURE.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			if(model.getApplyEndTime()== null \|\| model.getStartTime().getTime()>model.getApplyEndTime().getTime() ){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请生效周期时间不符合要求，请确认后修改重试~");
			}
			//计算实际截止时间
			Date actEndTime = new Date(model.getApplyEndTime().getTime() + (insuranceApply.getStartTime().getTime() - model.getApplyStartTime().getTime()));
			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			InsuranceApply update = new InsuranceApply();
			update.setEditDate(new Date());
			update.setEditor(user.getId());
			update.setStatus(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
			update.setCheckDate(update.getEditDate());
			update.setCheckInfo(insuranceApply.getCheckInfo());
			update.setCheckUserId(user.getId());
			update.setId(model.getId());
			update.setCode(insuranceApply.getCode());
			update.setEndTime(actEndTime);
			update.setStartTime(insuranceApply.getStartTime());
			CountCyclePriceDTO countCyclePriceDTO = new CountCyclePriceDTO();
			countCyclePriceDTO.setSolutionsId(model.getSolutionId());
			countCyclePriceDTO.setStartDate(insuranceApply.getStartTime());
			update.setFinalEndTime(this.getCountCyclePriceVO(countCyclePriceDTO).getEndDate());
			insuranceApplyMapper.updateById(update);

			//修改明细行的开始结束日期
			applyDetailMapper.update(null,new UpdateWrapper<ApplyDetail>().lambda()
			.set(ApplyDetail::getStartTime,insuranceApply.getStartTime())
			.set(ApplyDetail::getEndTime,actEndTime)
			.eq(ApplyDetail::getApplyId,model.getId()));

			multifileMapper.update(null,new UpdateWrapper<Multifile>().lambda()
			.eq(Multifile::getIsdeleted,Constants.ZERO)
			.eq(Multifile::getObjType,Constants.MultiFile.BD_DONE_PDF.getKey())
			.eq(Multifile::getObjId,update.getId())
			.set(Multifile::getIsdeleted,Constants.ONE)
			.set(Multifile::getEditDate,update.getEditDate())
			.set(Multifile::getEditor,update.getEditor())
			);

			insuranceApply.getBaoxiandanFile().setIsdeleted(Constants.ZERO);
			insuranceApply.getBaoxiandanFile().setCreator(user.getId());
			insuranceApply.getBaoxiandanFile().setObjId(update.getId());
			insuranceApply.getBaoxiandanFile().setCreateDate(update.getEditDate());
			insuranceApply.getBaoxiandanFile().setObjType(Constants.MultiFile.BD_DONE_PDF.getKey());
			insuranceApply.getBaoxiandanFile().setType(Constants.TWO);
			multifileMapper.insert(insuranceApply.getBaoxiandanFile());
			update.setBaoxiandanFile(insuranceApply.getBaoxiandanFile());

			noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,Constants.NoticeObjectType.INSURANCE_APPLY.getKey())
			.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
			.eq(Notices::getObjId,insuranceApply.getId()));

			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.UPLOAD_INSURANCE;
			String info = "";
			if(model.getApplyStartTime()!=null && model.getApplyStartTime().getTime()/1000!= insuranceApply.getStartTime().getTime()/1000){
			info =applyLogType.getInfo();
			info = info.replace("${param1}",DateUtil.getPlusTime2(model.getStartTime()));
			info = info.replace("${param2}",DateUtil.getPlusTime2(insuranceApply.getStartTime()));
			}
			ApplyLog log = new ApplyLog(update,applyLogType.getName(), info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);


			//存储员工信息投保记录
			//查询单据明细记录
			MPJLambdaWrapper<ApplyDetail> queryWrapper = new MPJLambdaWrapper<>();
			queryWrapper.selectAll(ApplyDetail.class);
			queryWrapper.selectAs(DispatchUnit::getName,ApplyDetail::getDuName);
			queryWrapper.selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode);
			queryWrapper.selectAs(Solutions::getId,ApplyDetail::getSolutionId);
			queryWrapper.selectAs(Solutions::getName,ApplyDetail::getSolutionName);
			queryWrapper.selectAs(Worktype::getName,ApplyDetail::getWorkTypeName);
			queryWrapper.selectAs(Member::getIdcardNo,ApplyDetail::getIdcardNo);
			queryWrapper.selectAs(Member::getName,ApplyDetail::getMemberName);
			queryWrapper.leftJoin(DispatchUnit.class,DispatchUnit::getId,ApplyDetail::getDuId);
			queryWrapper.leftJoin(Worktype.class,Worktype::getId,ApplyDetail::getWorktypeId);
			queryWrapper.leftJoin(Member.class,Member::getId,ApplyDetail::getMemberId);
			queryWrapper.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId);
			queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId);
			queryWrapper.eq(ApplyDetail::getApplyId,insuranceApply.getId());
			List<ApplyDetail> applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,queryWrapper);

			if(CollectionUtils.isNotEmpty(applyDetailList)){
			List<MemberInsurance> memberInsuranceList = new ArrayList<>();
			for (ApplyDetail applyDetail:applyDetailList) {
			MemberInsurance memberInsurance = new MemberInsurance(applyDetail,user.getId());
			memberInsurance.setRelationType(Constants.ZERO);
			memberInsuranceList.add(memberInsurance);

			memberMapper.update(null,new UpdateWrapper<Member>()
			.lambda()
			.set(Member::getStartTime,memberInsurance.getStartTime())
			.set(Member::getEndTime,memberInsurance.getEndTime())
			.set(Member::getDuId,memberInsurance.getDuId())
			.set(Member::getWorktypeId,memberInsurance.getWorktypeId())
			.eq(Member::getId, memberInsurance.getMemberId())
			);

			}
			memberInsuranceJoinMapper.insertBatchSomeColumn(memberInsuranceList);
			}

			this.updateApplyCurrentFee(insuranceApply.getId(),null);
			return 1;
			}

			@Override
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			@@ -345,8 +131,11 @@
			if(model == null \|\|!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请当前不支持该操作~");
			if(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey()) \|\|
			Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_DONE.getKey()) ){
			if(model.getStartTime().getTime()<System.currentTimeMillis()){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请当前不支持该操作~");
			}
			}

			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			@@ -390,82 +179,7 @@
			return 1;

			}
			@Override
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			public Integer dealBackApply(InsuranceApply insuranceApply) {
			if(insuranceApply.getId() == null \|\|StringUtils.isBlank(insuranceApply.getCheckInfo())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());

			if(model == null \|\|!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}

			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			Constants.ApplyLogType applyLogType = null;
			String info = "";
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
			//处理退回申请通知
			noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
			.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
			.eq(Notices::getObjId,insuranceApply.getId()));
			InsuranceApply update = new InsuranceApply();
			if(insuranceApply.getDealBackApply() ==1){
			//如果是驳回,只能可驳回已签章状态下的退回申请状态进行操作
			if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey())\|\|
			Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE.getKey())\|\|
			Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD.getKey())\|\|
			Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_PASS.getKey()))
			){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			applyLogType = Constants.ApplyLogType.PLATFORM_UN_AGREE_BACK;
			info = applyLogType.getInfo();
			info = info.replace("${param}", insuranceApply.getCheckInfo());
			if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey())){
			update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey());
			}else if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE.getKey())){
			update.setStatus(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey());
			}else if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD.getKey())){
			update.setStatus(Constants.InsuranceApplyStatus.UPLOAD.getKey());
			}else if( Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_PASS.getKey())){
			update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey());
			}
			}else{
			//如果是同意,两种申请退回状态都可操作
			if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_SIGNATURE.getKey())
			\|\|Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_WAIT_SIGNATURE.getKey())
			\|\|Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_UPLOAD.getKey()))){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			applyLogType = Constants.ApplyLogType.PLATFORM_AGREE_BACK;
			update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey());


			//通知企业已退回
			Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
			if(Objects.nonNull(solutions)){
			Notices notices = new Notices(noticeObjectType,Constants.ONE,insuranceApply.getId(),solutions.getName(),
			insuranceApply.getCompanyId(), Constants.NoticeType.FOUR);
			noticesMapper.insert(notices);
			}
			}
			update.setEditDate(new Date());
			update.setEditor(user.getId());
			update.setCheckDate(update.getEditDate());
			update.setCheckInfo(insuranceApply.getCheckInfo());
			update.setCheckUserId(user.getId());
			update.setId(model.getId());
			insuranceApplyMapper.updateById(update);


			ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);
			return 1;


			}

			@Override
			public String getSignLink(Integer id) {
			@@ -494,7 +208,7 @@
			if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			Company company = user.getCompany();
			Company company = user.getShowCompany();
			if(debugModel){
			company = companyMapper.selectById(model.getCompanyId());
			}
			@@ -531,7 +245,6 @@
			return link;
			}


			public String uploadSignFile(String link){
			try {
			String bucketName = systemDictDataBiz.queryByCode(Constants.OSS,Constants.BUCKETNAME).getCode();
			@@ -549,31 +262,48 @@
			}catch (Exception e){
			}
			return null;

			}


			public Multifile uploadSignedFileDo(InsuranceApply model,String fileurl,String fullUrl) {
			InsuranceApply update = new InsuranceApply();
			Boolean retrial = false;
			Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
			if(Constants.equalsInteger(solutions.getRetrial(),Constants.ONE)){
			ApplyLog applyLog = applyLogMapper.selectOne(new QueryWrapper<ApplyLog>().lambda()
			.eq(ApplyLog::getObjId,model.getId())
			.eq(ApplyLog::getObjType,Constants.ApplyLogType.PLATFORM_CHECK_PASS.getKey())
			.orderByDesc(ApplyLog::getCreateDate)
			.last(" limit 1 ")
			);
			if(Objects.nonNull(applyLog)){
			SystemUser systemUser = systemUserMapper.selectById(applyLog.getCreator());
			if(Objects.nonNull(systemUser) && Objects.nonNull(systemUser.getDepartmentId())){
			CompanyDepartment companyDepartment = companyDepartmentMapper.selectById(systemUser.getDepartmentId());
			if(Objects.nonNull(companyDepartment)&&Objects.nonNull(companyDepartment.getHeadId())){
			retrial = true;
			update.setRetrialId(companyDepartment.getHeadId());
			}
			}
			}
			}
			update.setEditDate(new Date());
			update.setEditor(model.getCreator());
			update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey());
			update.setStatus(retrial?Constants.InsuranceApplyStatus.REEXAMINE.getKey():Constants.InsuranceApplyStatus.SIGNATURE.getKey());
			update.setCheckDate(update.getEditDate());
			update.setCheckInfo("企业完成签署");
			update.setCheckUserId(model.getCreator());
			update.setId(model.getId());
			insuranceApplyMapper.updateById(update);

			//存储待办信息
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
			//删除其他待办
			noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
			noticesMapper.delete(new QueryWrapper<Notices>().lambda()
			.eq(Notices::getObjType,noticeObjectType.getKey())
			.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
			.eq(Notices::getObjId,model.getId()));
			//平台待办
			Notices notices = new Notices(noticeObjectType,Constants.ZERO,model.getId(),model.getSolutionsName(),model.getCompanyId(),Constants.NoticeType.TWO);
			noticesMapper.insert(notices);

			CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>().lambda()
			.eq(CompanySolution::getIsdeleted,Constants.ZERO)
			.eq(CompanySolution::getSolutionId,model.getSolutionId())
			@@ -586,7 +316,6 @@
			model.getId(),model.getSolutionsName(),companySolution.getShopId(),Constants.NoticeType.ZERO);
			noticesMapper.insert(shopNotices);
			}

			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			@@ -622,7 +351,6 @@
			update.setCheckInfo("企业完成签署方案确认书");
			update.setId(model.getId());
			insuranceApplyMapper.updateById(update);

			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			@@ -635,7 +363,6 @@
			f.setInfo("企业完成签署方案确认书");
			f.setName("方案确认书.pdf");
			multifileMapper.insert(f);

			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.WTB_FINISH_FAQRS;
			ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
			,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			@@ -660,7 +387,6 @@
			update.setCheckUserId(model.getCreator());
			update.setId(model.getId());
			insuranceApplyMapper.updateById(update);

			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			@@ -673,7 +399,6 @@
			f.setInfo("委托保企业完成签署投保申请书");
			f.setName("投保申请书.pdf");
			multifileMapper.insert(f);

			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.SIGNATURE;
			ApplyLog log = new ApplyLog(update,applyLogType.getName(), null
			,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			@@ -697,7 +422,6 @@
			update.setCheckUserId(model.getCreator());
			update.setId(model.getId());
			insuranceApplyMapper.updateById(update);

			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			@@ -710,15 +434,11 @@
			f.setInfo("企业完成签署人员名单");
			f.setName("人员名单.pdf");
			multifileMapper.insert(f);



			//数据日志
			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.WTB_FINISH_MEMBER_LIST;
			ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
			,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);

			Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
			//待办通知
			if(Objects.nonNull(solutions)&&Objects.nonNull(solutions.getShopId())){
			@@ -728,12 +448,9 @@
			notices.setParam1(model.getId().toString());
			noticesMapper.insert(notices);
			}


			return f;
			}



			public Multifile uploadChangeSignedFileDo(ApplyChange model,String fileurl,String fullurl) {
			Integer companyId = model.getCompanyId();
			ApplyChange update = new ApplyChange();
			@@ -745,7 +462,6 @@
			update.setCheckUserId(model.getCreator());
			update.setId(model.getId());
			applyChangeMapper.updateById(update);

			//存储待办信息
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.APPLY_CHANGE;
			if(model.getType().equals(Constants.ONE)){
			@@ -759,7 +475,6 @@
			companyId, Constants.NoticeType.TWO);
			notices.setParam1(model.getApplyId().toString());
			noticesMapper.insert(notices);

			Solutions solutions = solutionsMapper.selectById(model.getSolutionsId());
			//商户待办
			if(Objects.nonNull(solutions)&&Objects.nonNull(solutions.getShopId())){
			@@ -768,7 +483,6 @@
			notices.setParam1(model.getApplyId().toString());
			noticesMapper.insert(shopNotices);
			}

			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			@@ -781,15 +495,12 @@
			f.setInfo("企业申请表签署文件");
			f.setName("签章申请表.pdf");
			multifileMapper.insert(f);

			Constants.ApplyLogType applyLogType =Constants.equalsInteger(Constants.ZERO,model.getType())? Constants.ApplyLogType.CA_JIAJIAN_APPLY_SIGN: Constants.ApplyLogType.CA_CHANGUNIT_APPLY_SIGN;
			ApplyLog log = new ApplyLog(update,applyLogType.getName(), null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);

			startSendEmail(f,model.getCompanyName(),model.getSolutionsName(),model.getSolutionEmail());
			return f;
			}


			public Multifile uploadChangeMemberListSignedFileDo(ApplyChange model,String fileurl,String fullurl) {
			ApplyChange update = new ApplyChange();
			@@ -801,7 +512,6 @@
			update.setCheckUserId(model.getCreator());
			update.setId(model.getId());
			applyChangeMapper.updateById(update);

			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			@@ -818,12 +528,9 @@
			f.setInfo("企业完成签署人员名单");
			f.setName("签章人员名单.pdf");
			multifileMapper.insert(f);

			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_WTB_FINISH_MEMBER_LIST;
			ApplyLog log = new ApplyLog(update,applyLogType.getName(), null,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);


			Solutions solutions = solutionsMapper.selectById(model.getSolutionsId());
			//待办通知
			if(Objects.nonNull(solutions)&&Objects.nonNull(solutions.getShopId())){
			@@ -850,9 +557,9 @@
			UnionApply update = new UnionApply();
			update.setEditDate(new Date());
			update.setEditor(model.getCreator());
			update.setStatus(Constants.UnionApplyStatus.UPLOAD_INSURANCE_POLICY.getKey());
			update.setStatus(Objects.nonNull(model.getRetrialId())?Constants.UnionApplyStatus.RETRIAL.getKey() : Constants.UnionApplyStatus.UPLOAD_INSURANCE_POLICY.getKey());
			update.setCheckDate(update.getEditDate());
			update.setCheckInfo("商户完成签署");
			update.setCheckInfo(Objects.nonNull(model.getRetrialId())?"待复审":"完成签署");
			update.setCheckUserId(model.getCreator());
			update.setId(model.getId());
			unionApplyJoinMapper.updateById(update);
			@@ -869,12 +576,31 @@
			f.setInfo("商户签署投保单");
			f.setName("商户签署投保单.pdf");
			multifileMapper.insert(f);
			List<InsuranceApply> insuranceApplyList = insuranceApplyJoinMapper.selectList(new QueryWrapper<InsuranceApply>().
			lambda().eq(InsuranceApply::getUnionApplyId,model.getId()));
			if(CollectionUtils.isNotEmpty(insuranceApplyList)){
			for (InsuranceApply insuranceApply:insuranceApplyList) {

			f.setId(null);
			f.setIsdeleted(Constants.ZERO);
			f.setCreateDate(new Date());
			f.setObjType(Constants.MultiFile.BD_SIGNED_PDF.getKey());
			f.setType(Constants.TWO);
			f.setObjId(insuranceApply.getId());
			f.setInfo("投保单");
			f.setName("投保单.pdf");
			multifileMapper.insert(f);
			insuranceApplyJoinMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda()
			.set(InsuranceApply::getUnionApplyTbdStatus,Constants.TWO)
			.set(InsuranceApply::getEditDate,new Date())
			.eq(InsuranceApply::getId,insuranceApply.getId())
			);
			}
			}
			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.IA_HBD_SIGNATURE_TBD;
			ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
			,model.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(model));
			applyLogMapper.insert(log);

			return f;
			}

			@@ -893,7 +619,6 @@
			update.setStatus(Constants.UnionChangeStatus.UPLOAD_INSURANCE_POLICY.getKey());
			update.setId(model.getId());
			unionChangeJoinMapper.updateById(update);

			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			@@ -906,11 +631,119 @@
			f.setInfo("投保申请单 -申请单");
			f.setName("投保申请单.pdf");
			multifileMapper.insert(f);

			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_HBD_SIGNATURE_TBD;
			ApplyLog log = new ApplyLog(model,applyLogType.getName(), null
			,model.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(model));
			applyLogMapper.insert(log);
			return f;
			}

			public Multifile uploadContractFirstSignedFileDo(Contract model,String fileurl,String fullUrl) {
			Contract update = new Contract();
			update.setEditDate(new Date());
			update.setEditor(model.getCreator());
			update.setFileSignUrl(fileurl);
			update.setStatus(Constants.equalsInteger(model.getType(),Constants.ZERO)?Constants.ONE:Constants.THREE);
			update.setId(model.getId());
			contractJoinMapper.updateById(update);
			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			f.setObjId(update.getId());
			f.setCreateDate(update.getEditDate());
			f.setObjType(Constants.MultiFile.CONTRACT_FIRST_PDF.getKey());
			f.setType(Constants.TWO);
			f.setFileurl(fileurl);
			f.setFileurlFull(fullUrl);
			f.setInfo("合同签署文件");
			f.setName("合同签署文件.pdf");
			multifileMapper.insert(f);
			//存储待办信息
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.CONTRACT;
			//删除其他待办
			noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
			.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
			.eq(Notices::getObjId,model.getId()));
			//双方签署才会发新通知
			if(Constants.equalsInteger(model.getType(),Constants.ZERO)){
			Notices notices = new Notices(noticeObjectType,
			Constants.equalsInteger(model.getSignType(),Constants.ZERO)?Constants.TWO:Constants.ONE
			,model.getId(),this.getNoticeInfo(model,companyMapper.selectById(model.getCompanyId())),model.getCompanyId(),Constants.NoticeType.ZERO);
			noticesMapper.insert(notices);
			}
			return f;
			}

			public String getNoticeInfo(Contract contract,Company company){
			String noticeInfo = contract.getName();
			//商户信息
			if(Constants.equalsInteger(contract.getSignType(),Constants.TWO)){
			Company shop = companyMapper.selectById(contract.getPartyCompanyId());
			noticeInfo = noticeInfo + "("+shop.getName()+"/"+company.getName()+")";
			}else{
			noticeInfo = noticeInfo + "(平台/"+company.getName()+")";
			}
			return noticeInfo;
			}

			public Multifile uploadContractDoneSignedFileDo(Contract model,String fileurl,String fullUrl) {
			Contract update = new Contract();
			update.setEditDate(new Date());
			update.setEditor(model.getCreator());
			update.setDoneFileUrl(fileurl);
			update.setStatus(Constants.THREE);
			update.setId(model.getId());
			contractJoinMapper.updateById(update);
			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			f.setObjId(update.getId());
			f.setCreateDate(update.getEditDate());
			f.setObjType(Constants.MultiFile.CONTRACT_DONE_PDF.getKey());
			f.setType(Constants.TWO);
			f.setFileurl(fileurl);
			f.setFileurlFull(fullUrl);
			f.setInfo("合同签署文件");
			f.setName("合同签署文件.pdf");
			multifileMapper.insert(f);
			//存储待办信息
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.CONTRACT;
			//删除其他待办
			noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
			.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
			.eq(Notices::getObjId,model.getId()));
			return f;
			}


			public Multifile uploadCompanySolutionSignedFileDo(CompanySolution model,String fileurl,String fullUrl) {
			CompanySolution update = new CompanySolution();
			update.setEditDate(new Date());
			update.setEditor(model.getCreator());
			update.setFileSignUrl(fileurl);
			update.setSignStatus(Constants.ONE);
			update.setSignUserId(model.getEditor());
			update.setSignDate(new Date());
			update.setId(model.getId());
			companySolutionMapper.updateById(update);
			Multifile f = new Multifile();
			f.setIsdeleted(Constants.ZERO);
			f.setCreator(model.getCreator());
			f.setObjId(update.getId());
			f.setCreateDate(update.getEditDate());
			f.setObjType(Constants.MultiFile.COMPANY_SOLUTION_SIGN_PDF.getKey());
			f.setType(Constants.TWO);
			f.setFileurl(fileurl);
			f.setFileurlFull(fullUrl);
			f.setInfo("方案确认书");
			f.setName("方案确认书.pdf");
			multifileMapper.insert(f);
			//存储待办信息
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.SOLUTIONS;
			//删除其他待办
			noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey())
			.ne(Notices::getType,Constants.NoticeType.SIX.getStatus())
			.eq(Notices::getObjId,model.getId()));

			return f;
			}
			@@ -927,6 +760,24 @@
			if(file!=null && file.isFile()){
			Map<String,Object> files = new HashMap<>();
			files.put("name",f.getName());
			files.put("file",file);
			email.setFileList(new ArrayList<>());
			email.getFileList().add(files);
			smsEmailService.sendEmail(email);
			file.delete();//发送后删除临时文件
			}
			}

			@Override
			public void testSendEmail(){
			SmsEmail email = new SmsEmail();
			email.setTitle("测试邮件");
			email.setEmail("94314517@qq.com");
			email.setContent("来自企业【测试企业】关于保险方案【测试方案】的测试邮件");
			File file = Constants.getFileByNetFile("https://yybred.oss-cn-hangzhou.aliyuncs.com/apply/20250116/600faf2f-5ba2-44e2-9a96-c99052dc013d.pdf","1111.pdf");
			if(file!=null && file.isFile()){
			Map<String,Object> files = new HashMap<>();
			files.put("name","测试文件");
			files.put("file",file);
			email.setFileList(new ArrayList<>());
			email.getFileList().add(files);
			@@ -995,7 +846,6 @@
			// return;
			}
			}

			//委托保企业签署人员名单
			applyList = insuranceApplyJoinMapper.selectJoinList(InsuranceApply.class,
			new MPJLambdaWrapper<InsuranceApply>()
			@@ -1054,9 +904,6 @@
			// return;
			}
			}



			List<ApplyChange> chagneList = applyChangeMapper.selectJoinList(ApplyChange.class,
			new MPJLambdaWrapper<ApplyChange>()
			.selectAll(ApplyChange.class)
			@@ -1087,7 +934,6 @@
			// return;
			}
			}

			//委托保加减保/换厂签署人员名单
			chagneList = applyChangeMapper.selectJoinList(ApplyChange.class,
			new MPJLambdaWrapper<ApplyChange>()
			@@ -1119,12 +965,6 @@
			// return;
			}
			}



			/**
			*合并投保单签署业务
			*/
			List<UnionApply> unionApplyList = unionApplyJoinMapper.selectJoinList(UnionApply.class,
			new MPJLambdaWrapper<UnionApply>()
			.selectAll(UnionApply.class)
			@@ -1145,10 +985,6 @@
			uploadUnionApplySignedFileDo(model,fileUrl,path+fileUrl);
			}
			}

			/**
			*合并加减保换厂签署业务
			*/
			List<UnionChange> unionChangeList = unionChangeJoinMapper.selectJoinList(UnionChange.class,
			new MPJLambdaWrapper<UnionChange>()
			.selectAll(UnionChange.class)
			@@ -1169,10 +1005,67 @@
			uploadUnionChangeSignedFileDo(model,fileUrl,path+fileUrl);
			}
			}



			List<Contract> contractFirstList = contractJoinMapper.selectJoinList(Contract.class,
			new MPJLambdaWrapper<Contract>()
			.selectAll(Contract.class)
			.eq(Contract::getStatus,Constants.ZERO)
			.isNotNull(Contract::getApplyNo));
			if(contractFirstList !=null && contractFirstList.size()>0 ){
			for(Contract contract : contractFirstList){
			String status = signService.linkFileStatus(contract.getApplyNo());
			if(!StringUtils.equals(status,"3")){
			continue;
			}
			String link = signService.linkFile(contract.getApplyNo());
			String fileUrl = uploadSignFile(link);
			if(StringUtils.isBlank(fileUrl)){
			//如果下载失败，清除合同，下次签章重新生成新合同
			continue;
			}
			uploadContractFirstSignedFileDo(contract,fileUrl,path+fileUrl);
			}
			}
			List<Contract> contractDoneList = contractJoinMapper.selectJoinList(Contract.class,
			new MPJLambdaWrapper<Contract>()
			.selectAll(Contract.class)
			.eq(Contract::getStatus,Constants.ONE)
			.isNotNull(Contract::getDoneApplyNo));
			if(contractDoneList !=null && contractDoneList.size()>0 ){
			for(Contract contract : contractDoneList){
			String status = signService.linkFileStatus(contract.getDoneApplyNo());
			if(!StringUtils.equals(status,"3")){
			continue;
			}
			String link = signService.linkFile(contract.getDoneApplyNo());
			String fileUrl = uploadSignFile(link);
			if(StringUtils.isBlank(fileUrl)){
			//如果下载失败，清除合同，下次签章重新生成新合同
			continue;
			}
			uploadContractDoneSignedFileDo(contract,fileUrl,path+fileUrl);
			}
			}
			List<CompanySolution> companySolutionList = companySolutionMapper.selectList(
			new QueryWrapper<CompanySolution>().lambda()
			.eq(CompanySolution::getSignStatus,Constants.ZERO)
			.isNotNull(CompanySolution::getApplyNo));
			if(companySolutionList !=null && companySolutionList.size()>0 ){
			for(CompanySolution companySolution : companySolutionList){
			String status = signService.linkFileStatus(companySolution.getApplyNo());
			if(!StringUtils.equals(status,"3")){
			continue;
			}
			String link = signService.linkFile(companySolution.getApplyNo());
			String fileUrl = uploadSignFile(link);
			if(StringUtils.isBlank(fileUrl)){
			//如果下载失败，清除合同，下次签章重新生成新合同
			continue;
			}
			uploadCompanySolutionSignedFileDo(companySolution,fileUrl,path+fileUrl);
			}
			}
			}

			@Override
			public String dealSignResult(NotifyDataReq data){
			if(data.getApplyNo() == null ){
			@@ -1215,6 +1108,19 @@
			if(StringUtils.isNotBlank(r)){
			return r;
			}
			r = dealContractFirstBiz(path,data,"合同我方签署");
			if(StringUtils.isNotBlank(r)){
			return r;
			}
			r = dealContractDoneBiz(path,data,"合同企业/商户签署");
			if(StringUtils.isNotBlank(r)){
			return r;
			}
			r = dealCompanySolutionBiz(path,data,"企业签署方案确认书");
			if(StringUtils.isNotBlank(r)){
			return r;
			}

			}
			return "无处理数据";
			}
			@@ -1244,6 +1150,100 @@
			unionChangeJoinMapper.update(null,new UpdateWrapper<UnionChange>().lambda()
			.set(UnionChange::getSignApplyNo,null)
			.eq(UnionChange::getSignApplyNo,data.getApplyNo()));
			return title+"合同拒签处理成功";
			}
			}
			return title+"状态已流转，不做处理";
			}

			private String dealContractFirstBiz(String path, NotifyDataReq data, String title) {
			Contract contract = contractJoinMapper.selectOne(new QueryWrapper<Contract>()
			.lambda().
			eq(Contract::getApplyNo,data.getApplyNo())
			.last(" limit 1")
			);

			if(contract == null){
			return null;
			}
			if( Constants.equalsInteger(contract.getStatus(),Constants.ONE)){
			if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
			//完成签署已完成操作
			String link = signService.linkFile(contract.getApplyNo());
			String fileUrl = uploadSignFile(link);
			if(StringUtils.isBlank(fileUrl)){
			//如果下载失败，清除合同，下次签章重新生成新合同
			return title+"合同下载失败，等待下次推送处理";
			}

			uploadContractFirstSignedFileDo(contract,fileUrl,path+fileUrl);
			return title+"状态处理成功";
			}else{
			//如果已拒签，清除合同，下次签章重新生成新合同
			contractJoinMapper.update(null,new UpdateWrapper<Contract>().lambda()
			.set(Contract::getApplyNo,null)
			.eq(Contract::getApplyNo,data.getApplyNo()));
			return title+"合同拒签处理成功";
			}
			}
			return title+"状态已流转，不做处理";
			}

			private String dealContractDoneBiz(String path, NotifyDataReq data, String title) {
			Contract contract = contractJoinMapper.selectOne(new QueryWrapper<Contract>()
			.lambda().
			eq(Contract::getDoneApplyNo,data.getApplyNo())
			.last(" limit 1")
			);
			if(contract == null){
			return null;
			}
			if( Constants.equalsInteger(contract.getStatus(),Constants.THREE)){
			if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
			//完成签署已完成操作
			String link = signService.linkFile(contract.getDoneApplyNo());
			String fileUrl = uploadSignFile(link);
			if(StringUtils.isBlank(fileUrl)){
			//如果下载失败，清除合同，下次签章重新生成新合同
			return title+"合同下载失败，等待下次推送处理";
			}
			uploadContractDoneSignedFileDo(contract,fileUrl,path+fileUrl);
			return title+"状态处理成功";
			}else{
			//如果已拒签，清除合同，下次签章重新生成新合同
			contractJoinMapper.update(null,new UpdateWrapper<Contract>().lambda()
			.set(Contract::getDoneApplyNo,null)
			.eq(Contract::getDoneApplyNo,data.getApplyNo()));
			return title+"合同拒签处理成功";
			}
			}
			return title+"状态已流转，不做处理";
			}
			private String dealCompanySolutionBiz(String path, NotifyDataReq data, String title) {
			CompanySolution companySolution = companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>()
			.lambda().
			eq(CompanySolution::getApplyNo,data.getApplyNo())
			.last(" limit 1")
			);
			if(companySolution == null){
			return null;
			}
			if( Constants.equalsInteger(companySolution.getSignStatus(),Constants.ZERO)){
			if(Constants.equalsInteger(data.getSignStatus(), Constants.THREE )){
			//完成签署已完成操作
			String link = signService.linkFile(companySolution.getApplyNo());
			String fileUrl = uploadSignFile(link);
			if(StringUtils.isBlank(fileUrl)){
			//如果下载失败，清除合同，下次签章重新生成新合同
			return title+"合同下载失败，等待下次推送处理";
			}
			uploadCompanySolutionSignedFileDo(companySolution,fileUrl,path+fileUrl);
			return title+"状态处理成功";
			}else{
			//如果已拒签，清除合同，下次签章重新生成新合同
			companySolutionMapper.update(null,new UpdateWrapper<CompanySolution>().lambda()
			.set(CompanySolution::getApplyNo,null)
			.eq(CompanySolution::getApplyNo,data.getApplyNo()));
			return title+"合同拒签处理成功";
			}
			}
			@@ -1521,75 +1521,6 @@
			}


			@Override
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			public Integer uploadToubaodan(InsuranceApply insuranceApply) {
			if(insuranceApply.getId() == null
			\|\| insuranceApply.getToubaodanFile() == null
			\|\|StringUtils.isBlank( insuranceApply.getToubaodanFile() .getFileurl())
			\|\|StringUtils.isBlank( insuranceApply.getToubaodanFile() .getName())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());
			if(model == null \|\|!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.UPLOAD.getKey())
			\|\| Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey())
			\|\| Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.PLATFORM_CHECK_PASS.getKey()))){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}

			Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
			if(Objects.isNull(solutions)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
			}

			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			InsuranceApply update = new InsuranceApply();
			update.setEditDate(new Date());
			update.setEditor(user.getId());
			update.setStatus(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey());
			update.setCheckDate(update.getEditDate());
			update.setCheckInfo(insuranceApply.getCheckInfo());
			update.setCheckUserId(user.getId());
			update.setId(model.getId());
			insuranceApplyMapper.updateById(update);

			multifileMapper.update(null,new UpdateWrapper<Multifile>().lambda()
			.eq(Multifile::getIsdeleted,Constants.ZERO)
			.eq(Multifile::getObjType,Constants.MultiFile.BD_APPLY_PDF.getKey())
			.eq(Multifile::getObjId,update.getId())
			.set(Multifile::getIsdeleted,Constants.ONE)
			.set(Multifile::getEditDate,update.getEditDate())
			.set(Multifile::getEditor,update.getEditor())
			);
			insuranceApply.getToubaodanFile().setIsdeleted(Constants.ZERO);
			insuranceApply.getToubaodanFile().setCreator(user.getId());
			insuranceApply.getToubaodanFile().setObjId(update.getId());
			insuranceApply.getToubaodanFile().setCreateDate(update.getEditDate());
			insuranceApply.getToubaodanFile().setObjType(Constants.MultiFile.BD_APPLY_PDF.getKey());
			insuranceApply.getToubaodanFile().setType(Constants.TWO);
			multifileMapper.insert(insuranceApply.getToubaodanFile());
			update.setToubaodanFile(insuranceApply.getToubaodanFile());

			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.WAIT_SIGNATURE;
			String info =applyLogType.getInfo();
			// info = info.replace("${param}", update.getCheckInfo());
			ApplyLog log = new ApplyLog(update,applyLogType.getName(),StringUtils.isNotBlank(update.getCheckInfo())?info:"",update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);

			//删除其他待办
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
			noticesMapper.delete(new QueryWrapper<Notices>().lambda().eq(Notices::getObjType,noticeObjectType.getKey()).eq(Notices::getObjId,insuranceApply.getId()));

			Notices notices = new Notices(noticeObjectType,Constants.ONE,model.getId(),solutions.getName(),
			model.getCompanyId(), Constants.NoticeType.ONE);
			noticesMapper.insert(notices);

			return 1;

			}

			/**
			* 审核通过或者不通过
			@@ -1598,7 +1529,7 @@
			*/
			@Override
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			public Integer check(InsuranceApply insuranceApply) {
			public Integer check(InsuranceApply insuranceApply,UnionApplyServiceImpl unionApplyServiceImpl) {
			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			if(insuranceApply.getId() == null){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			@@ -1617,9 +1548,6 @@
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			}else{
			if(!Constants.equalsObject(user.getType(),Constants.TWO)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非商户端无法进行该操作");
			}
			//委托保待签署、待审核可进行退回操作
			if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())
			\|\|Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
			@@ -1678,8 +1606,122 @@
			}
			ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);
			return 1;
			//2024年11月8日16:12:43 如果是委托投保单则自动创建合并单数据
			if(Constants.equalsInteger(insuranceApply.getDealBackApply(),Constants.ZERO) && Constants.equalsObject(solutions.getType(),Constants.ONE)){
			SaveUnionApplyDTO saveUnionApplyDTO = new SaveUnionApplyDTO();
			List<Integer> applyIds = new ArrayList<Integer>();
			applyIds.add(update.getId());
			saveUnionApplyDTO.setApplyIds(applyIds);
			saveUnionApplyDTO.setBaseSolutionId(solutions.getBaseId());
			saveUnionApplyDTO.setStartDate(model.getStartTime());
			saveUnionApplyDTO.setEndDate(model.getEndTime());
			unionApplyServiceImpl.merge(saveUnionApplyDTO);
			}

			return 1;
			}

			/**
			* 复审审核通过或者不通过
			* @param insuranceApply
			* @return
			*/
			@Override
			@Transactional(rollbackFor = {Exception.class,BusinessException.class})
			public Integer reexamineCheck(InsuranceApply insuranceApply) {
			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			if(insuranceApply.getId() == null){
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			InsuranceApply model = insuranceApplyMapper.selectById(insuranceApply.getId());

			if(model == null \|\|!Constants.equalsInteger(model.getIsdeleted(),Constants.ZERO)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			Solutions solutions = solutionsMapper.selectById(model.getSolutionId());
			if(Objects.isNull(solutions)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询方案信息");
			}
			if(Constants.equalsObject(solutions.getType(),Constants.ZERO)){
			if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.REEXAMINE.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			}else{
			if(Constants.equalsObject(user.getType(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"企业用户无法进行该操作");
			}
			//如果是商户端，则只能由指定人进行处理
			if(Constants.equalsInteger(user.getType(),Constants.TWO)){
			if(!Constants.equalsInteger(model.getRetrialId(),user.getId())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的复审数据，无法进行审批");
			}
			}else{
			//如果是平台端，根据人员类型处理如果是固定人员则不限制其他人员需要比对
			if(!user.getFixed()){
			if(!Constants.equalsInteger(model.getRetrialId(),user.getId())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的复审数据，无法进行审批");
			}
			}
			}
			//委托保待签署、待审核可进行退回操作
			if(!(Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())
			\|\|Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE.getKey())
			\|\|Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_COMPANY_MEMBER_LIST_SIGNATURE.getKey())
			)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			}

			Constants.ApplyLogType applyLogType = null;
			InsuranceApply update = new InsuranceApply();
			update.setEditDate(new Date());
			update.setEditor(user.getId());
			update.setCheckDate(update.getEditDate());
			update.setCheckInfo(insuranceApply.getCheckInfo());
			update.setCheckUserId(user.getId());
			update.setId(model.getId());
			if(insuranceApply.getDealBackApply() ==1){
			//如果是不通过
			applyLogType = Constants.ApplyLogType.PLATFORM_RETURN ;
			update.setStatus(Constants.InsuranceApplyStatus.PLATFORM_RETURN.getKey());
			if(Constants.equalsObject(solutions.getType(),Constants.ONE)){
			update.setStatus(Constants.InsuranceApplyStatus.WTB_RETURN.getKey());
			}
			}else{
			applyLogType = Constants.ApplyLogType.PLATFORM_CHECK_PASS;
			if(Constants.equalsObject(solutions.getType(),Constants.ONE)){
			update.setStatus(Constants.InsuranceApplyStatus.WTB_BUSINESS_CHECK_PASS.getKey());
			}else{
			update.setStatus(Constants.InsuranceApplyStatus.SIGNATURE.getKey());
			}
			}
			insuranceApplyMapper.updateById(update);

			//存储待办信息
			Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.INSURANCE_APPLY;
			if(Constants.equalsObject(solutions.getType(),Constants.ZERO)) {
			//删除其他待办
			noticesMapper.delete(new QueryWrapper<Notices>().lambda()
			.eq(Notices::getObjType, noticeObjectType.getKey())
			.ne(Notices::getType, Constants.NoticeType.SIX.getStatus())
			.eq(Notices::getObjId, model.getId()));
			}else{
			//删除全部待办
			noticesMapper.delete(new QueryWrapper<Notices>().lambda()
			.eq(Notices::getObjType, noticeObjectType.getKey())
			.eq(Notices::getObjId, model.getId()));
			}


			String info =applyLogType.getInfo();
			if(StringUtils.isNotBlank(update.getCheckInfo())){
			info = info.replace("${param}", update.getCheckInfo());
			}else{
			info = null;
			}
			ApplyLog log = new ApplyLog(update,applyLogType.getName(),info,update.getId(),applyLogType.getKey(),JSONObject.toJSONString(model), JSONObject.toJSONString(update));
			applyLogMapper.insert(log);
			return 1;
			}


			@@ -1690,14 +1732,18 @@
			\|\| Objects.isNull(insuranceApply.getSolutionId())
			\|\| Objects.isNull(insuranceApply.getApplyStartTime())
			\|\| Objects.isNull(insuranceApply.getApplyEndTime())
			\|\| Objects.isNull(insuranceApply.getCompanyId())
			\|\| !CollectionUtils.isNotEmpty(insuranceApply.getApplyDetailList())
			) {
			throw new BusinessException(ResponseStatus.BAD_REQUEST);
			}
			LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			if(!loginUserInfo.getType().equals(Constants.ONE)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户类型错误：非企业用户无法进行该操作");

			Company company = companyMapper.selectById(insuranceApply.getCompanyId());
			if(Objects.isNull(company) \|\| Constants.equalsInteger(company.getType(),Constants.ONE)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"企业信息错误，请确认!");
			}

			Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());
			if(Objects.isNull(solutions)){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"未查询到方案信息");
			@@ -1716,7 +1762,6 @@
			throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"保单生效起期错误");
			}
			}

			List<ApplyDetail> applyDetailList = insuranceApply.getApplyDetailList();
			//判断是否存在重复信息
			List<String> idCardList = applyDetailList.stream().map(i->i.getIdcardNo()).collect(Collectors.toList());
			@@ -1726,14 +1771,13 @@
			}
			Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.UPLOAD;
			if(solutions.getType().equals(Constants.ONE)){
			insuranceApplyStatus = Constants.InsuranceApplyStatus.WTB_UPLOAD;
			insuranceApplyStatus = Constants.InsuranceApplyStatus.WTB_COMPANY_APPLY_SIGNATURE;
			}
			insuranceApply.setCreateDate(new Date());
			insuranceApply.setCreator(loginUserInfo.getId());
			insuranceApply.setEditor(loginUserInfo.getId());
			insuranceApply.setEditDate(new Date());
			insuranceApply.setIsdeleted(Constants.ZERO);
			insuranceApply.setCompanyId(loginUserInfo.getCompanyId());
			insuranceApply.setCheckInfo(insuranceApplyStatus.getName());
			insuranceApply.setStartTime(insuranceApply.getApplyStartTime());
			insuranceApply.setCheckDate(new Date());
			@@ -1749,18 +1793,16 @@
			insuranceApply.setEndTime(countCyclePriceVO.getEndDate());
			insuranceApply.setFinalEndTime(countCyclePriceVO.getEndDate());
			insuranceApplyMapper.insert(insuranceApply);


			//处理下级数据
			this.dealApplyDetailData(insuranceApply,solutions,applyDetailList,loginUserInfo,countCyclePriceVO,true);
			InsuranceApply updBean = new InsuranceApply();
			updBean.setId(insuranceApply.getId());
			updBean.setFee(applyDetailList.stream().map(ApplyDetail::getFee).reduce(BigDecimal.ZERO,BigDecimal::add));
			insuranceApplyMapper.updateById(updBean);

			//存储日志数据
			Constants.ApplyLogType applyLogType = Constants.ApplyLogType.UPLOAD;
			String info =applyLogType.getInfo();
			// info = info.replace("${param}", update.getCheckInfo());
			ApplyLog log = new ApplyLog(insuranceApply,applyLogType.getName(),info,insuranceApply.getId(),applyLogType.getKey(),null, null);
			applyLogMapper.insert(log);

			@@ -1790,8 +1832,6 @@
			}
			return insuranceApply.getId();
			}




			@Override
			@@ -1879,42 +1919,65 @@




			private static Logger logger = LoggerFactory.getLogger(InsuranceApplyServiceImpl.class);

			public void dealApplyDetailData(InsuranceApply insuranceApply,Solutions solutions,List<ApplyDetail> applyDetailList,
			LoginUserInfo loginUserInfo,CountCyclePriceVO countCyclePriceVO,Boolean checkNewData){
			//查询保险方案下的所有派遣单位
			List<DuSolution> duSolutionList = duSolutionJoinMapper.selectJoinList(DuSolution.class,new MPJLambdaWrapper<DuSolution>()
			.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(checkNewData,DispatchUnit::getDataType,Constants.TWO)
			.eq(DuSolution::getStatus,Constants.ONE)
			.eq(DuSolution::getSolutionId,insuranceApply.getSolutionId())
			.apply(" t1.BASE_ID in ( select du.id from dispatch_unit du where du.STATUS = 0 and du.ISDELETED = 0 ) ")
			);
			if(!CollectionUtils.isNotEmpty(duSolutionList)){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到派遣单位信息，请确保派遣单位和工作配置并审核通过！");
			Long start = System.currentTimeMillis();
			logger.error("处理保单数据开始时间:=========================>"+start);
			//2024年11月6日15:01:34 加入方案配置了有派遣单位才会去验证派遣单位数据
			List<DuSolution> duSolutionList = new ArrayList<>();
			List<DuWorktype> duWorktypeList = new ArrayList<>();
			List<Integer> worktypeIdList = new ArrayList<>();
			if(Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)){
			//查询保险方案下的所有派遣单位
			duSolutionList = duSolutionJoinMapper.selectJoinList(DuSolution.class,new MPJLambdaWrapper<DuSolution>()
			.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(checkNewData,DispatchUnit::getDataType,Constants.TWO)
			.eq(DuSolution::getStatus,Constants.ONE)
			.eq(DuSolution::getSolutionId,insuranceApply.getSolutionId())
			.apply(" t1.BASE_ID in ( select du.id from dispatch_unit du where du.STATUS = 0 and du.ISDELETED = 0 ) ")
			);
			if(!CollectionUtils.isNotEmpty(duSolutionList)){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到派遣单位信息，请确保派遣单位和工作配置并审核通过！");
			}
			//查询所有派遣单位下的工种
			List<Integer> duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList());
			duWorktypeList = duWorkTypeJoinMapper.selectJoinList(DuWorktype.class,new MPJLambdaWrapper<DuWorktype>()
			.selectAll(DuWorktype.class)
			.innerJoin(Worktype.class,Worktype::getId,DuWorktype::getWorkTypeId)
			.eq(DuWorktype::getIsdeleted,Constants.ZERO)
			.eq(DuWorktype::getStatus,Constants.ONE)
			.eq(checkNewData,Worktype::getDataType,Constants.TWO)
			.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<SolutionWorktype> solutionWorktypeList = solutionWorktypeJoinMapper.selectList(new QueryWrapper<SolutionWorktype>().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());
			}
			//查询所有派遣单位下的工种
			List<Integer> duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList());
			List<DuWorktype> duWorktypeList = duWorkTypeJoinMapper.selectJoinList(DuWorktype.class,new MPJLambdaWrapper<DuWorktype>()
			.selectAll(DuWorktype.class)
			.innerJoin(Worktype.class,Worktype::getId,DuWorktype::getWorkTypeId)
			.eq(DuWorktype::getIsdeleted,Constants.ZERO)
			.eq(DuWorktype::getStatus,Constants.ONE)
			.eq(checkNewData,Worktype::getDataType,Constants.TWO)
			.in(DuWorktype::getDuSolutionId,duSolutionIdList));
			if(!CollectionUtils.isNotEmpty(duWorktypeList)){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，保险方案下未查询到工种信息，请确保派遣单位和工作配置并审核通过！");
			}

			if(CollectionUtils.isNotEmpty(applyDetailList)){
			List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda()
			.eq(Member::getCompanyId,insuranceApply.getCompanyId())
			.eq(Member::getIsdeleted,Constants.ZERO));

			List<String> idCodeList = new ArrayList<>();
			for (ApplyDetail applyDetail:applyDetailList) {
			idCodeList.add(applyDetail.getIdcardNo());
			}
			List<ApplyDetail> allDetailList = this.getMemberSolutionList(solutions.getParentId(),idCodeList, insuranceApply.getStartTime()
			,insuranceApply.getEndTime(),insuranceApply.getId());
			List<Member> addMemberList = new ArrayList<>();
			for (int i = 0; i < applyDetailList.size(); i++) {
			ApplyDetail applyDetail = applyDetailList.get(i);
			@@ -1938,27 +2001,32 @@
			}
			member.setIdcardNo(applyDetail.getIdcardNo());
			member.setApplyId(insuranceApply.getId());
			member.setStartTime(applyDetail.getStartTime());
			member.setEndTime(applyDetail.getEndTime());
			member.setDuId(applyDetail.getDuId());
			member.setWorktypeId(applyDetail.getWorktypeId());
			addMemberList.add(member);
			}
			//查询人员信息是否存在相同的方案下是否存在冲突数据
			this.checkMemberSolution( applyDetail.getIdcardNo(),allDetailList,applyDetail.getMemberName());
			// this.checkMemberSolutionOld(solutions.getParentId(),member.getIdcardNo(),member.getName(),insuranceApply.getStartTime(),insuranceApply.getEndTime(),insuranceApply.getId());
			}
			if(CollectionUtils.isNotEmpty(addMemberList)){
			memberJoinMapper.insertBatchSomeColumn(addMemberList);
			memberJoinMapper.insert(addMemberList);
			}
			memberList.addAll(addMemberList);
			for (int i = 0; i < applyDetailList.size(); i++) {
			Long singlStart = System.currentTimeMillis();
			logger.error("处理保单单条数据开始时间:=========================>"+singlStart);
			ApplyDetail applyDetail = applyDetailList.get(i);
			if(Objects.isNull(applyDetail)
			\|\|StringUtils.isBlank(applyDetail.getIdcardNo())
			\|\|StringUtils.isBlank(applyDetail.getMemberName())
			\|\|Objects.isNull(applyDetail.getDuId())
			\|\| (Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)&&Objects.isNull(applyDetail.getDuId()))
			\|\|Objects.isNull(applyDetail.getWorktypeId())
			){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，投保员工信息数据缺失，请按照要求填写员工的有效信息！");
			}
			applyDetail.setId(null);
			applyDetail.setChangeStatus(Constants.ZERO);
			applyDetail.setCreateDate(new Date());
			applyDetail.setCreator(loginUserInfo.getId());
			applyDetail.setIsdeleted(Constants.ZERO);
			@@ -1966,6 +2034,15 @@
			applyDetail.setEndTime(insuranceApply.getApplyEndTime());
			applyDetail.setSortnum(i);
			applyDetail.setApplyId(insuranceApply.getId());

			//根据员工身份证进行判断年龄
			long age = Constants.getAgeByIdCard(applyDetail.getIdcardNo());
			if(Objects.isNull(age)
			\|\| age > solutions.getMaxAge()
			\|\| age < solutions.getMinAge()){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"【"+applyDetail.getMemberName()+"】员工年龄超出方案配置,方案配置【"+solutions.getMinAge()+" - "+solutions.getMaxAge()+"】！");
			}

			Member member = null;
			if(Objects.isNull(applyDetail.getMemberId())){
			if(CollectionUtils.isNotEmpty(memberList)){
			@@ -1979,9 +2056,8 @@
			member.setApplyId(insuranceApply.getId());
			member.setDuId(applyDetail.getDuId());
			member.setWorktypeId(applyDetail.getWorktypeId());
			member.setStartTime(applyDetail.getStartTime());
			member.setEndTime(applyDetail.getEndTime());
			memberMapper.updateById(member);
			applyDetail.setMemberName(member.getName());
			}
			}else{
			member = memberMapper.selectById(applyDetail.getMemberId());
			@@ -1991,17 +2067,8 @@
			member.setApplyId(insuranceApply.getId());
			member.setDuId(applyDetail.getDuId());
			member.setWorktypeId(applyDetail.getWorktypeId());
			member.setStartTime(applyDetail.getStartTime());
			member.setEndTime(applyDetail.getEndTime());
			memberMapper.updateById(member);
			}

			//根据员工身份证进行判断年龄
			long age = Constants.getAgeByIdCard(member.getIdcardNo());
			if(Objects.isNull(age)
			\|\| age > solutions.getMaxAge()
			\|\| age < solutions.getMinAge()){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"【"+applyDetail.getMemberName()+"】员工年龄超出方案配置,方案配置【"+solutions.getMinAge()+" - "+solutions.getMaxAge()+"】！");
			applyDetail.setMemberName(member.getName());
			}
			applyDetail.setMemberId(member.getId());
			applyDetail.setIdcardNo(member.getIdcardNo());
			@@ -2017,18 +2084,208 @@
			applyDetail.getFee().divide(new BigDecimal(maxDays),7,RoundingMode.HALF_UP)
			);
			//验证派遣单位信息是否存在
			if(duSolutionList.stream().filter(d->d.getDispatchUnitId().equals(applyDetail.getDuId())).collect(Collectors.toList()).size()<=Constants.ZERO){
			throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+applyDetail.getIdcardNo()+"】员工派遣单位未查询到！");
			if(Constants.equalsInteger(solutions.getHasDispatchUnit(),Constants.ZERO)){
			if(duSolutionList.stream().filter(d->d.getDispatchUnitId().equals(applyDetail.getDuId())).collect(Collectors.toList()).size()<=Constants.ZERO){
			throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+applyDetail.getIdcardNo()+"】员工派遣单位未查询到！");
			}
			}
			if(duWorktypeList.stream().filter(d->d.getWorkTypeId().equals(applyDetail.getWorktypeId()))
			if(worktypeIdList.stream().filter(d->Constants.equalsInteger(d,applyDetail.getWorktypeId()))
			.collect(Collectors.toList()).size()<=Constants.ZERO){
			throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"【"+applyDetail.getMemberName()+applyDetail.getIdcardNo()+"】员工工种信息未查询到！");
			}
			Long singlEnd = System.currentTimeMillis();
			logger.error("处理保单单条数据结束时间:=========================>"+singlEnd+";耗时：====》"+(singlStart-singlEnd));
			}
			applyDetailJoinMapper.insertBatchSomeColumn(applyDetailList);
			Long end = System.currentTimeMillis();
			logger.error("处理单数据结束时间:=========================>"+end +";耗时：====》"+(end-start));
			applyDetailMapper.insert(applyDetailList);
			}
			}


			/**
			* 查询会员信息在方案下是否存在冲突数据
			*/
			public void checkMemberSolution(String idCode,List<ApplyDetail> allDetailList,String memberName){
			List<ApplyDetail> applyDetailList = getMemberSolutionListByIdcode(idCode,allDetailList);
			if(applyDetailList.size() >Constants.ZERO){
			String companyName = applyDetailList.get(Constants.ZERO).getCompanyName();
			if(StringUtils.isNotBlank(companyName)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】已在【"+companyName+"】存在保险,请联系客服确认");
			}else{
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
			}

			};
			}

			// @Override
			// public void checkMemberSolutionOld(Integer solutionParentId,String idCode, String memberName, Date startTime,Date endTime,Integer applyId){
			// List<ApplyDetail> applyDetailList = new ArrayList<>();
			// try {
			// applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,
			// new MPJLambdaWrapper<ApplyDetail>()
			// .selectAll(ApplyDetail.class)
			// .selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode)
			// .selectAs(Company::getName,ApplyDetail::getCompanyName)
			// .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
			// .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
			// .leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
			// .eq(ApplyDetail::getIdcardNo,idCode)
			// .eq(ApplyDetail::getIsdeleted,Constants.ZERO)
			// .eq(Solutions::getParentId,solutionParentId)
			// .ne(Objects.nonNull(applyId),InsuranceApply::getId,applyId)
			// .notIn(InsuranceApply::getStatus
			// ,Constants.InsuranceApplyStatus.FAIL_RETURN.getKey()
			// ,Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_PASS.getKey()
			// ,Constants.InsuranceApplyStatus.CLOSE.getKey()
			// ,Constants.InsuranceApplyStatus.WTB_RETURN.getKey()
			// ,Constants.InsuranceApplyStatus.WTB_CLOSED.getKey() )
			// .apply(" ( " +
			// " '"+DateUtil.getPlusTime(startTime)+"' <= t.start_time AND t.start_time < '"+DateUtil.getPlusTime(endTime)+"' " +
			// " or " +
			// " ( '"+DateUtil.getPlusTime(startTime)+"' < t.end_time AND t.end_time < '"+DateUtil.getPlusTime(endTime)+"' ) " +
			// " or " +
			// " ( '"+DateUtil.getPlusTime(startTime)+"' > t.start_time AND '"+DateUtil.getPlusTime(endTime)+"' < t.end_time )" +
			// " ) " ));
			// }catch (Exception e){
			// }
			// if(applyDetailList.size() >Constants.ZERO){
			// String companyName = applyDetailList.get(Constants.ZERO).getCompanyName();
			// if(StringUtils.isNotBlank(companyName)){
			// throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】已在【"+companyName+"】存在保险,请联系客服确认");
			// }else{
			// throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
			// }
			//
			// };
			// }
			private List<ApplyDetail> getMemberSolutionListByIdcode(String idCode, List<ApplyDetail> allDetailList) {
			if(allDetailList == null \|\| allDetailList.size()==0){
			return new ArrayList<>();
			}
			List<ApplyDetail> list = new ArrayList<>();
			for(ApplyDetail d : allDetailList){
			if(StringUtils.equals(d.getIdcardNo(),idCode)){
			list.add(d);
			}
			}
			return list;
			}

			public List<ApplyDetail> getMemberSolutionList(Integer solutionParentId,List<String> idCodeList, Date startTime,Date endTime,Integer applyId){
			List<ApplyDetail> applyDetailList = new ArrayList<ApplyDetail>();
			try {
			applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,
			new MPJLambdaWrapper<ApplyDetail>()
			.selectAll(ApplyDetail.class)
			.selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode)
			.selectAs(Company::getName,ApplyDetail::getCompanyName)
			.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
			.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
			.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
			.in(ApplyDetail::getIdcardNo,idCodeList)
			.eq(ApplyDetail::getIsdeleted,Constants.ZERO)
			.eq(Solutions::getParentId,solutionParentId)
			.ne(Objects.nonNull(applyId),InsuranceApply::getId,applyId)
			.notIn(InsuranceApply::getStatus
			,Constants.InsuranceApplyStatus.FAIL_RETURN.getKey()
			,Constants.InsuranceApplyStatus.COMPANY_BACK_APPLY_PASS.getKey()
			,Constants.InsuranceApplyStatus.CLOSE.getKey()
			,Constants.InsuranceApplyStatus.WTB_RETURN.getKey()
			,Constants.InsuranceApplyStatus.WTB_CLOSED.getKey() )
			.apply(" ( " +
			" '"+DateUtil.getPlusTime(startTime)+"' <= t.start_time AND t.start_time < '"+DateUtil.getPlusTime(endTime)+"' " +
			" or " +
			" ( '"+DateUtil.getPlusTime(startTime)+"' < t.end_time AND t.end_time < '"+DateUtil.getPlusTime(endTime)+"' ) " +
			" or " +
			" ( '"+DateUtil.getPlusTime(startTime)+"' > t.start_time AND '"+DateUtil.getPlusTime(endTime)+"' < t.end_time )" +
			" ) " ));
			}catch (Exception e){
			}
			return applyDetailList;
			}


			public static void checkStaticMemberSolutionNew(Integer solutionId,Integer memberId,String memberIdCard,String memberName,Date startTime,
			Date endTime,ApplyDetailJoinMapper applyDetailJoinMapper){
			List<ApplyDetail> applyDetailList = new ArrayList<ApplyDetail>();
			try {
			applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,
			new MPJLambdaWrapper<ApplyDetail>()
			.selectAll(ApplyDetail.class)
			.selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode)
			.selectAs(Company::getName,ApplyDetail::getCompanyName)
			.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
			.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
			.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
			.eq(ApplyDetail::getIdcardNo,memberIdCard)
			.eq(Solutions::getBaseId,solutionId)
			.eq(ApplyDetail::getIsdeleted,Constants.ZERO)
			.notIn(InsuranceApply::getStatus
			,Constants.InsuranceApplyStatus.CLOSE.getKey()
			,Constants.InsuranceApplyStatus.WTB_CLOSED.getKey() )
			.apply(" ( " +
			" '"+DateUtil.getPlusTime(startTime)+"' <= t.start_time AND t.start_time < '"+DateUtil.getPlusTime(endTime)+"' " +
			" or " +
			" ( '"+DateUtil.getPlusTime(startTime)+"' < t.end_time AND t.end_time < '"+DateUtil.getPlusTime(endTime)+"' ) " +
			" or " +
			" ( '"+DateUtil.getPlusTime(startTime)+"' > t.start_time AND '"+DateUtil.getPlusTime(endTime)+"' < t.end_time )" +
			" ) " ));
			}catch (Exception e){

			}
			if(applyDetailList.size() >Constants.ZERO){
			String companyName = applyDetailList.get(Constants.ZERO).getCompanyName();
			String idCode = applyDetailList.get(Constants.ZERO).getIdcardNo();
			if(StringUtils.isNotBlank(companyName)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】已在【"+companyName+"】存在保险,请联系客服确认");
			}else{
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
			}
			};

			}

			public static void checkStaticMemberSolution(Integer solutionId,Integer memberId,String memberIdCard,String memberName,Date startTime,
			Date endTime,ApplyDetailJoinMapper applyDetailJoinMapper){
			List<ApplyDetail> applyDetailList = new ArrayList<ApplyDetail>();
			try {
			applyDetailList = applyDetailJoinMapper.selectJoinList(ApplyDetail.class,
			new MPJLambdaWrapper<ApplyDetail>()
			.selectAll(ApplyDetail.class)
			.selectAs(InsuranceApply::getCode,ApplyDetail::getApplyCode)
			.selectAs(Company::getName,ApplyDetail::getCompanyName)
			.leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyDetail::getApplyId)
			.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
			.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
			.eq(ApplyDetail::getIdcardNo,memberIdCard)
			.eq(Solutions::getBaseId,solutionId)
			.eq(ApplyDetail::getIsdeleted,Constants.ZERO)
			.notIn(InsuranceApply::getStatus
			,Constants.InsuranceApplyStatus.CLOSE.getKey()
			,Constants.InsuranceApplyStatus.WTB_CLOSED.getKey() )
			.apply(" ( " +
			" '"+DateUtil.getPlusTime(startTime)+"' <= t.start_time AND t.start_time < '"+DateUtil.getPlusTime(endTime)+"' " +
			" or " +
			" ( '"+DateUtil.getPlusTime(startTime)+"' < t.end_time AND t.end_time < '"+DateUtil.getPlusTime(endTime)+"' ) " +
			" or " +
			" ( '"+DateUtil.getPlusTime(startTime)+"' > t.start_time AND '"+DateUtil.getPlusTime(endTime)+"' < t.end_time )" +
			" ) " ));
			}catch (Exception e){

			}
			if(applyDetailList.size() >Constants.ZERO){
			String companyName = applyDetailList.get(Constants.ZERO).getCompanyName();
			String idCode = applyDetailList.get(Constants.ZERO).getIdcardNo();
			if(StringUtils.isNotBlank(companyName)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】已在【"+companyName+"】存在保险,请联系客服确认");
			}else{
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该员工【"+memberName+" "+idCode+"】在该保险方案下已存在投保记录，无法进行该操作");
			}
			};

			}

			@Override
			public void deleteById(Integer id) {
			@@ -2112,48 +2369,71 @@
			MPJLambdaWrapper<InsuranceApply> queryWrapper = new MPJLambdaWrapper<>();
			Utils.MP.blankToNull(pageWrap.getModel());

			/* //数据权限开始--------------------start----------------
			LoginUserInfo userInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			if(userInfo!=null && userInfo.getDepartIdList()!=null){
			if( userInfo.getDepartIdList().size() ==0){
			//只看自己
			queryWrapper.and(wrapper ->{
			wrapper.eq(InsuranceApply::getCreator,userInfo.getId());
			});
			}else{
			//权限范围内
			queryWrapper.and(wrapper ->{
			wrapper.in(SystemUser::getDepartmentId ,userInfo.getDepartIdList());
			});
			}
			}*/


			List<Integer> statusList = this.getCollectStatus(pageWrap.getModel().getStatusCollect());

			queryWrapper.selectAll(InsuranceApply.class);
			queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName);
			queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
			queryWrapper.selectAs(Solutions::getType,InsuranceApply::getSolutionType);
			queryWrapper.selectAs(Solutions::getHasDispatchUnit,InsuranceApply::getHasDispatchUnit);
			queryWrapper.selectAs(Solutions::getMaxAge,InsuranceApply::getMaxAge);
			queryWrapper.selectAs(Solutions::getMinAge,InsuranceApply::getMinAge);
			queryWrapper.selectAs(Solutions::getPrice,InsuranceApply::getPrice);
			queryWrapper.selectAs(Solutions::getTimeUnit,InsuranceApply::getTimeUnit);
			queryWrapper.select(" DATEDIFF( t.END_TIME ,now() ) AS loseEfficacyDays ");
			queryWrapper.select("( select ifnull(sum(ad.FEE),0) from apply_chagne_detail ad left join apply_change a on a.id = ad.APPLY_CHANGE_ID where t.id = a.APPLY_ID and a.status = 2 )",InsuranceApply::getChangeMoney);
			// queryWrapper.select(" case when t.START_TIME > now() then 0 when t.END_TIME >= now() then DATEDIFF( now() ,t.START_TIME ) when t.END_TIME <= now() then DATEDIFF( t.END_TIME, t.START_TIME )+1 else 0 end loseEfficacyDays ");
			queryWrapper.select(" DATEDIFF( t.END_TIME, t.START_TIME )+1 as loseEfficacyDays ");
			queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id ) as insureNum");
			queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum");
			queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id and a.status in ( 5 , 27 ) where ad.apply_id = t.id and ad.END_TIME > now() and ad.START_TIME < now() ) as guaranteeNum");
			if(!Objects.isNull(pageWrap.getModel())&&!Objects.isNull(pageWrap.getModel().getType())){
			queryWrapper.select(" ifnull(( select sum(td.fee) from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ),0) as taxesMoney");
			queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status = 1 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast ");
			}
			queryWrapper.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId);
			queryWrapper.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId);
			queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,InsuranceApply::getCreator);
			queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO);
			queryWrapper.eq(pageWrap.getModel().getBaseSolutionId()!=null,Solutions::getBaseId,pageWrap.getModel().getBaseSolutionId());
			queryWrapper.in(statusList.size()>0,InsuranceApply::getStatus,statusList);
			queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getSolutionName()),Solutions::getName,pageWrap.getModel().getSolutionName());
			if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.YGQ.getKey()) ){
			//如果是已過期
			// queryWrapper.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
			queryWrapper.lt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
			}else if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.BZZ.getKey()) ){
			//如果是保障中
			// queryWrapper.eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey());
			queryWrapper.gt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
			}
			// if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.YGQ.getKey()) ){
			// //如果是已过期
			// queryWrapper.lt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
			// }else if(Constants.equalsInteger(pageWrap.getModel().getStatusCollect(),Constants.ApplyCollectStatus.BZZ.getKey()) ){
			// //如果是保障中
			// queryWrapper.gt(InsuranceApply::getEndTime, Utils.Date.getStart(new Date()));
			// }
			LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();

			//企业人员查看本企业数据
			if(loginUserInfo.getType().equals(Constants.ONE)){
			queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId());
			//2024年10月29日15:14:28 加入企业合并2类投保数据
			if(pageWrap.getModel().getSolutionType()!=null && Constants.equalsInteger(pageWrap.getModel().getSolutionType(),Constants.ZERO)){
			queryWrapper.eq(Solutions::getType,pageWrap.getModel().getSolutionType());
			}
			}else if(loginUserInfo.getType().equals(Constants.TWO)){
			//如果是商户查看
			if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType().equals(0)){
			if(pageWrap.getModel().getSolutionType()!=null && Constants.equalsInteger(pageWrap.getModel().getSolutionType(),Constants.ZERO)){
			queryWrapper.exists("select cs.id from company_solution cs left join solutions s on cs.solution_id=s.id where cs.isdeleted=0 and s.base_id=t1.base_id and cs.shop_id="+loginUserInfo.getCompanyId());
			}else if(pageWrap.getModel().getSolutionType()!=null && pageWrap.getModel().getSolutionType() ==1){
			}else if(pageWrap.getModel().getSolutionType()!=null && Constants.equalsInteger(pageWrap.getModel().getSolutionType(),Constants.ONE)){
			queryWrapper.eq(Solutions::getShopId,loginUserInfo.getCompanyId());
			}else{
			queryWrapper.apply("((t1.type=0 and exists(select cs.id from company_solution cs left join solutions s on cs.solution_id=s.id where cs.isdeleted=0 and s.base_id=t1.base_id and cs.shop_id="+loginUserInfo.getCompanyId()+")) or (" +
			@@ -2203,6 +2483,18 @@
			if (pageWrap.getModel().getStatus() != null) {
			queryWrapper.in(InsuranceApply::getStatus, pageWrap.getModel().getStatus().split(","));
			}

			if (pageWrap.getModel().getTimeOut() != null) {
			if(Constants.equalsInteger(pageWrap.getModel().getTimeOut(),Constants.ZERO)){
			queryWrapper.apply(" t.START_TIME > now() ");
			}else if(Constants.equalsInteger(pageWrap.getModel().getTimeOut(),Constants.ONE)){
			queryWrapper.apply(" now() between t.START_TIME and t.END_TIME ");
			}else if(Constants.equalsInteger(pageWrap.getModel().getTimeOut(),Constants.TWO)){
			queryWrapper.apply(" t.END_TIME < now() ");
			}else if(Constants.equalsInteger(pageWrap.getModel().getTimeOut(),Constants.THREE)){
			queryWrapper.apply(" t.END_TIME > now() ");
			}
			}
			if (pageWrap.getModel().getLoseEfficacy() != null && pageWrap.getModel().getLoseEfficacy() ==1) {
			queryWrapper.apply(" DATEDIFF(t.END_TIME,CURRENT_DATE() ) <= 5 and t.END_TIME >= now() ");
			}
			@@ -2221,25 +2513,15 @@
			PageData<InsuranceApply> pageData = PageData.from(insuranceApplyJoinMapper.selectJoinPage(page,InsuranceApply.class, queryWrapper));
			if(pageData.getRecords()!=null){
			for (InsuranceApply apply : pageData.getRecords()){
			initApplyStatus(apply) ;
			Constants.initApplyStatus(apply) ;
			apply.setChangeMoney(Constants.getTwoPoint(apply.getChangeMoney()));
			apply.setFee(Constants.getTwoPoint(apply.getFee()));
			}
			}
			return pageData;
			}

			public void initApplyStatus(InsuranceApply apply){
			apply.setStatusCollect(Constants.InsuranceApplyStatus.getCollectStatus(apply.getStatus()));
			if(Constants.equalsInteger(apply.getStatus(),Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
			\|\| Constants.equalsInteger(apply.getStatus(),Constants.InsuranceApplyStatus.WTB_DONE.getKey())){
			//如果已完成
			if(apply.getEndTime()==null \|\| System.currentTimeMillis()>apply.getEndTime().getTime()){
			apply.setStatusCollect(Constants.THREE);//已过期
			}
			}
			setServiceDays(apply);
			apply.setStatusInfo(Constants.ApplyCollectStatus.getName(apply.getStatusCollect()));

			}

			@Override
			public List<InsuranceApply> findListByDTO(InsuranceApplyQueryDTO model) {
			@@ -2251,6 +2533,7 @@
			queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName);
			queryWrapper.selectAs(Solutions::getType,InsuranceApply::getSolutionType);
			queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id ) as insureNum");
			queryWrapper.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id and a.status in ( 5 , 27 ) where ad.apply_id = t.id and ad.END_TIME > now() and ad.START_TIME < now() ) as guaranteeNum");
			queryWrapper.select(" ( select max(ac.APPLY_START_TIME) from apply_change ac where ac.apply_id = t.id and ac.status = 2 ) as lastChangeDate");
			queryWrapper.select(" ( select sum(td.fee) from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id ) as taxesMoney ");
			queryWrapper.select(" ( select td.CREATE_DATE from taxes ts inner join tax_detial td on td.TAX_ID = ts.id where ts.status != 2 and td.INSURANCE_APPLY_ID = t.id order by td.CREATE_DATE desc limit 1 ) as taxesLast ");
			@@ -2393,26 +2676,33 @@
			.selectAs(Solutions::getTimeUnit,InsuranceApply::getTimeUnit)
			.selectAs(Solutions::getType,InsuranceApply::getSolutionType)
			.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
			.selectAs(Solutions::getHasDispatchUnit,InsuranceApply::getHasDispatchUnit)
			.selectAs(Company::getName,InsuranceApply::getCompanyName)
			.selectAs(Solutions::getCorrectWarnTime,InsuranceApply::getCorrectWarnTime)
			.select("( select ifnull(sum(ad.FEE),0) from apply_chagne_detail ad left join apply_change a on a.id = ad.APPLY_CHANGE_ID where t.id = a.APPLY_ID and a.status = 2 )",InsuranceApply::getChangeMoney)
			.select(" ( select max(ac.APPLY_START_TIME) from apply_change ac where ac.apply_id = t.id and ac.status = 2 ) as lastChangeDate")
			.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id ) as insureNum")
			.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum")
			.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id and a.status in ( 5 , 27 ) where ad.apply_id = t.id and ad.END_TIME > now() and ad.START_TIME < now() ) as guaranteeNum")
			.select(" t3.name as shopName")
			.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
			.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
			.leftJoin(Company.class,Company::getId,Solutions::getShopId)
			.eq(InsuranceApply::getId,id)
			.last("limit 1");

			InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectJoinOne(InsuranceApply.class,wrapper);
			if(Objects.isNull(insuranceApply)){
			throw new BusinessException(ResponseStatus.DATA_EMPTY);
			}
			this.dealDataDetail(insuranceApply);
			return insuranceApply;
			}

			public void dealDataDetail(InsuranceApply insuranceApply){
			Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId());
			if(Objects.isNull(solutions)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到方案信息");
			}
			insuranceApply.setCorrectWarnTime(solutions.getCorrectWarnTime());
			if(solutions.getDataType().equals(Constants.ONE)){
			Solutions newVersionSolution = solutionsMapper.selectOne(new QueryWrapper<Solutions>().lambda().eq(Solutions::getBaseId,solutions.getBaseId()).eq(Solutions::getDataType,Constants.TWO).last("limit 1"));
			if(Objects.isNull(newVersionSolution)){
			@@ -2425,9 +2715,11 @@
			if(insuranceApply.getStartTime().compareTo(new Date())<0 && insuranceApply.getEndTime().compareTo(new Date()) > 0 ){
			insuranceApply.setLoseEfficacyDays(DateUtil.daysBetweenDates(insuranceApply.getEndTime(),new Date()));
			}
			initApplyStatus(insuranceApply);
			Constants.initApplyStatus(insuranceApply);
			//查询附件数据
			initImgData(insuranceApply);
			insuranceApply.setChangeMoney(Constants.getTwoPoint(insuranceApply.getChangeMoney()));
			insuranceApply.setFee(Constants.getTwoPoint(insuranceApply.getFee()));
			//查询操作记录
			List<ApplyLog> applyLogList = applyLogJoinMapper.selectJoinList(ApplyLog.class,
			new MPJLambdaWrapper<ApplyLog>()
			@@ -2442,29 +2734,25 @@
			.orderByAsc(ApplyLog::getCreateDate)
			);
			insuranceApply.setApplyLogList(applyLogList);
			return insuranceApply;
			}

			private void setServiceDays(InsuranceApply insuranceApply) {
			//设置在保时长（天数）
			insuranceApply.setServiceDays(Constants.ZERO);
			if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
			\|\| insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WTB_DONE.getKey())){
			//如果当前时间大于结束日期则使用结束日期对比开始日期
			if(DateUtil.compareDate(new Date(),insuranceApply.getEndTime())>=Constants.ZERO){
			insuranceApply.setServiceDays(
			DateUtil.daysBetweenDates(insuranceApply.getEndTime(),insuranceApply.getStartTime())+1
			);
			}else if(DateUtil.compareDate(insuranceApply.getStartTime(),new Date())>=Constants.ZERO){
			//未开始
			insuranceApply.setServiceDays(Constants.ZERO);
			}else{
			insuranceApply.setServiceDays(DateUtil.daysBetweenDates(new Date(),insuranceApply.getStartTime())+1);
			}
			}
			}


			private void initImgData(InsuranceApply model) {
			String path = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()
			+systemDictDataBiz.queryByCode(Constants.OSS,Constants.APPLY_FILE).getCode();
			//查询方案确认书
			CompanySolution companySolution =companySolutionMapper.selectOne(new QueryWrapper<CompanySolution>().lambda().eq(CompanySolution::getSolutionId,model.getSolutionId()).eq(CompanySolution::getCompanyId,model.getCompanyId()).last("limit 1"));
			if(Objects.nonNull(companySolution)){
			Multifile multifile = multifileMapper.selectOne(new QueryWrapper<Multifile>().lambda()
			.eq(Multifile::getObjId,companySolution.getId())
			.eq(Multifile::getObjType,Constants.MultiFile.COMPANY_SOLUTION_SIGN_PDF.getKey())
			.eq(Multifile::getIsdeleted,Constants.ZERO).last("limit 1"));
			if(Objects.nonNull(multifile)){
			multifile.setFileurlFull(path + multifile.getFileurl());
			model.setFanganFile(multifile);
			}
			}
			List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda()
			.eq(Multifile::getObjId, model.getId())
			.in(Multifile::getObjType,Arrays.asList(new Integer[]{Constants.MultiFile.BD_APPLY_PDF.getKey()
			@@ -2475,8 +2763,6 @@
			.eq(Multifile::getIsdeleted,Constants.ZERO)
			.orderByAsc(Multifile::getId));
			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;
			@@ -2494,22 +2780,7 @@
			}else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.MEMBER_LIST_LATTER.getKey())){
			//申请单
			model.setShenqingdanFile(f);
			}else if(Constants.equalsInteger(f.getObjType(),Constants.MultiFile.WTB_CONFIRMATION_LATTER.getKey())){
			//签署后确认书
			model.setFanganFile(f);
			}

			// if(model.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())){
			// //如果当前时间大于结束日期则使用结束日期对比开始日期
			// if(DateUtil.compareDate(new Date(),model.getEndTime())>=Constants.ZERO){
			// model.setServiceDays(DateUtil.daysBetweenDates(model.getEndTime(),model.getStartTime()));
			// }else if(DateUtil.compareDate(model.getStartTime(),new Date())>=Constants.ZERO){
			// //未开始
			// model.setServiceDays(Constants.ZERO);
			// }else{
			// model.setServiceDays(DateUtil.daysBetweenDates(new Date(),model.getStartTime()));
			// }
			// }
			}
			}
			}
			@@ -2520,7 +2791,8 @@
			.selectAs(Solutions::getName,InsuranceApply::getSolutionsName)
			.selectAs(Solutions::getType,InsuranceApply::getSolutionType)
			.selectAs(Company::getName,InsuranceApply::getCompanyName)
			.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id and ad.END_TIME > now() ) as guaranteeNum")
			.select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad where ad.apply_id = t.id ) as insureNum")
			.select(" ifnull(( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad inner join insurance_apply a on ad.apply_id = a.id and a.status in ( 5 , 27 ) where ad.apply_id = t.id and ad.END_TIME > now() and ad.START_TIME < now() ),0) as guaranteeNum")
			.leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
			.leftJoin(Company.class,Company::getId,InsuranceApply::getCompanyId)
			.eq(InsuranceApply::getId,model.getId())
			@@ -2542,7 +2814,7 @@
			//查询明细
			List<ApplyDetail> detailList =applyDetailJoinMapper.selectJoinList(ApplyDetail.class,wrapper1);
			if(detailList!=null){
			insuranceApply.setInsureNum(detailList.size());
			// insuranceApply.setInsureNum(detailList.size());
			insuranceApply.setApplyDetailList(detailList);
			}
			insuranceApply.setRemark(model.getRemark());
			@@ -2626,11 +2898,6 @@
			noticesMapper.insert(shopNotices);
			}






			}else if(insuranceApplyOptDTO.getOptType().equals(Constants.TWO)){
			insuranceApplyStatus = Constants.InsuranceApplyStatus.CLOSE;
			if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.CLOSE.getKey())){
			@@ -2713,6 +2980,7 @@
			BigDecimal sumAmount = BigDecimal.ZERO;
			List<ApplyDetail> applyDetailList = applyDetailMapper
			.selectList(new QueryWrapper<ApplyDetail>().lambda()
			.ne(ApplyDetail::getChangeStatus,Constants.TWO)
			.eq(ApplyDetail::getApplyId,insuranceApply.getId()));
			if(CollectionUtils.isNotEmpty(applyDetailList)){
			for (ApplyDetail applyDetail: applyDetailList) {
			@@ -2728,16 +2996,15 @@
			applyDetail.setCurrentFee(applyDetail.getFee());
			applyDetailMapper.updateById(applyDetail);
			}
			sumAmount = sumAmount.add(applyDetail.getCurrentFee());
			if(Constants.equalsInteger(applyDetail.getChangeStatus(),Constants.ZERO) \|\| applyDetail.getEndTime().getTime()>System.currentTimeMillis()){
			sumAmount = sumAmount.add(applyDetail.getCurrentFee());
			}
			}
			}
			insuranceApply.setCurrentFee(sumAmount);
			insuranceApplyMapper.updateById(insuranceApply);
			}
			}
			// if(1==1){
			// throw new BusinessException(ResponseStatus.NOT_ALLOWED);
			// }
			}


			@@ -2822,7 +3089,7 @@
			if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_UPLOAD.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			Company company = user.getCompany();
			Company company = user.getShowCompany();
			if(debugModel){
			company = companyMapper.selectById(model.getCompanyId());
			}
			@@ -2907,7 +3174,7 @@
			throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该申请状态已流转，当前不支持签章操作！");
			}
			LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
			Company company = user.getCompany();
			Company company = user.getShowCompany();
			if(debugModel){
			company = companyMapper.selectById(model.getCompanyId());
			}
			@@ -2921,10 +3188,11 @@
			if(solutions.getType().equals(Constants.ZERO)){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，非委托保方案保单，无法进行该操作!");
			}
			String fileUrl = ExcelExporter.build(InsuranceApply.class).exportApplyExcelToPdf(model,"人员名单");
			String fileUrl = ExcelExporter.build(InsuranceApply.class).exportApplyExcelToPdf(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.applySignLocalFile(company.getName(),company.getName(),fileUrl,company.getCode(),company.getEmail(),"投保名单签章",company.getSignId(),notifyUrl);
			String applyNo = signService.applySignLocalFileByParam(company.getName(),company.getName(),fileUrl,company.getCode(),company.getEmail(),"投保名单签章",company.getSignId(),notifyUrl,new Float(0.7));
			// String applyNo = signService.applySign(company.getName(),fileUrl,company.getName(),company.getCode(),company.getEmail(),model.getSignKeyword(),company.getSignId(),notifyUrl);
			if(StringUtils.isBlank(applyNo) ){
			throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，获取在线签章地址失败，请稍后重试！");
			}
			@@ -2987,7 +3255,7 @@
			if(!Constants.equalsInteger(model.getStatus(),Constants.InsuranceApplyStatus.WTB_TOUBAOING.getKey())){
			throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，该申请状态已流转，当前不支持该操作~");
			}
			Company company = user.getCompany();
			Company company = user.getShowCompany();
			if(debugModel){
			company = companyMapper.selectById(model.getCompanyId());
			}
			@@ -3021,4 +3289,42 @@
			return link;
			}





			/**
			* 根据保单查询是否可以进行加减保操作
			* @param applyPowerDTO
			* @return
			*/
			@Override
			public ApplyPowerVO getApplyPower(ApplyPowerDTO applyPowerDTO){
			if(Objects.isNull(applyPowerDTO)
			\|\| Objects.isNull(applyPowerDTO.getApplyId())){
			throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"参数错误");
			}
			if(Objects.isNull(applyPowerDTO.getBeginDate())){
			applyPowerDTO.setBeginDate(new Date());
			}
			InsuranceApply insuranceApply = insuranceApplyMapper.selectById(applyPowerDTO.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(),"未查询到方案信息");
			}
			ApplyPowerVO applyPowerVO = Constants.getApplyPowerStatic(applyPowerDTO,insuranceApply,solutions);
			return applyPowerVO;
			}




			}