From c7be7e1fcd9bb0e813b78b08cd45191883af9ce3 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期五, 19 一月 2024 15:34:06 +0800 Subject: [PATCH] 111 --- server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java | 325 ++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 266 insertions(+), 59 deletions(-) diff --git a/server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java index 4f02e2b..0942fdd 100644 --- a/server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java +++ b/server/service/src/main/java/com/doumee/service/business/impl/InsuranceApplyServiceImpl.java @@ -1,25 +1,43 @@ package com.doumee.service.business.impl; +import com.doumee.core.constants.ResponseStatus; +import com.doumee.core.exception.BusinessException; +import com.doumee.core.model.LoginUserInfo; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; +import com.doumee.core.utils.Constants; +import com.doumee.core.utils.DateUtil; import com.doumee.core.utils.Utils; -import com.doumee.dao.business.InsuranceApplyMapper; -import com.doumee.dao.business.model.InsuranceApply; +import com.doumee.dao.business.*; +import com.doumee.dao.business.dto.InsuranceApplyOptDTO; +import com.doumee.dao.business.dto.InsuranceApplyQueryDTO; +import com.doumee.dao.business.join.ApplyLogJoinMapper; +import com.doumee.dao.business.join.InsuranceApplyJoinMapper; +import com.doumee.dao.business.model.*; +import com.doumee.dao.system.model.SystemUser; import com.doumee.service.business.InsuranceApplyService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.github.xiaoymin.knife4j.core.util.CollectionUtils; +import com.github.yulichang.wrapper.MPJLambdaWrapper; +import io.swagger.models.auth.In; +import jdk.internal.jline.internal.Log; +import org.apache.commons.lang3.StringUtils; +import org.apache.shiro.SecurityUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import org.springframework.util.CollectionUtils; +import org.springframework.transaction.annotation.Transactional; -import java.util.List; +import java.math.BigDecimal; +import java.util.*; +import java.util.stream.Collectors; /** * 鎶曚繚鐢宠淇℃伅琛⊿ervice瀹炵幇 * @author 姹熻箘韫� - * @date 2024/01/15 15:07 + * @date 2024/01/16 10:03 */ @Service public class InsuranceApplyServiceImpl implements InsuranceApplyService { @@ -27,11 +45,157 @@ @Autowired private InsuranceApplyMapper insuranceApplyMapper; + @Autowired + private InsuranceApplyJoinMapper insuranceApplyJoinMapper; + + @Autowired + private ApplyDetailMapper applyDetailMapper; + + @Autowired + private ApplyLogMapper applyLogMapper; + + @Autowired + private ApplyLogJoinMapper applyLogJoinMapper; + + @Autowired + private SolutionsMapper solutionsMapper; + + @Autowired + private MemberMapper memberMapper; + @Autowired + private DuSolutionMapper duSolutionMapper; + @Autowired + private DuWorktypeMapper duWorktypeMapper; + @Override + @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Integer create(InsuranceApply insuranceApply) { + if (Objects.isNull(insuranceApply) + || Objects.isNull(insuranceApply.getSolutionId()) + || Objects.isNull(insuranceApply.getApplyStartTime()) + || Objects.isNull(insuranceApply.getApplyEndTime()) + || !CollectionUtils.isNotEmpty(insuranceApply.getApplyDetailList()) + ) { + throw new BusinessException(ResponseStatus.BAD_REQUEST); + } + LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); + if(!loginUserInfo.getType().equals(Constants.ONE)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛绫诲瀷閿欒锛氶潪浼佷笟鐢ㄦ埛鏃犳硶杩涜璇ユ搷浣�"); + } + Solutions solutions = solutionsMapper.selectById(insuranceApply.getSolutionId()); + if(Objects.isNull(solutions)){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鏈煡璇㈠埌鏂规淇℃伅"); + } + + List<ApplyDetail> applyDetailList = insuranceApply.getApplyDetailList(); + //鍒ゆ柇鏄惁瀛樺湪閲嶅淇℃伅 + List<Integer> memberIdList = applyDetailList.stream().map(i->i.getMemberId()).collect(Collectors.toList()); + Set<Integer> set = new HashSet<>(memberIdList); + if(memberIdList.size() != set.size()){ + throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"鍛樺伐淇℃伅瀛樺湪閲嶅淇℃伅"); + } + Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.UPLOAD; + insuranceApply.setCreateDate(new Date()); + insuranceApply.setCreator(loginUserInfo.getId()); + insuranceApply.setIsdeleted(Constants.ZERO); + insuranceApply.setCompanyId(loginUserInfo.getCompanyId()); + insuranceApply.setCheckInfo(insuranceApplyStatus.getName()); + insuranceApply.setCheckDate(new Date()); + insuranceApply.setCheckUserId(loginUserInfo.getId()); + insuranceApply.setStatus(insuranceApplyStatus.getKey()); insuranceApplyMapper.insert(insuranceApply); + //鏌ヨ淇濋櫓鏂规涓嬬殑鎵�鏈夋淳閬e崟浣� + List<DuSolution> duSolutionList = duSolutionMapper.selectList(new QueryWrapper<DuSolution>().lambda() + .eq(DuSolution::getIsdeleted,Constants.ZERO) + .eq(DuSolution::getStatus,Constants.ONE) + .eq(DuSolution::getSolutionId,insuranceApply.getSolutionId())); + if(!CollectionUtils.isNotEmpty(duSolutionList)){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鏁版嵁寮傚父锛氫繚闄╂柟妗堜笅鏈煡璇㈠埌娲鹃仯鍗曚綅"); + } + //鏌ヨ鎵�鏈夋淳閬e崟浣嶄笅鐨勫伐绉� + List<Integer> duSolutionIdList = duSolutionList.stream().map(i->i.getId()).collect(Collectors.toList()); + List<DuWorktype> duWorktypeList = duWorktypeMapper.selectList(new QueryWrapper<DuWorktype>().lambda() + .eq(DuWorktype::getIsdeleted,Constants.ZERO) + .eq(DuWorktype::getStatus,Constants.ONE) + .in(DuWorktype::getDuSolutionId,duSolutionIdList)); + if(!CollectionUtils.isNotEmpty(duWorktypeList)){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鏁版嵁寮傚父锛氫繚闄╂柟妗堜笅鏈煡璇㈠埌宸ョ淇℃伅"); + } + for (int i = 0; i < applyDetailList.size(); i++) { + ApplyDetail applyDetail = applyDetailList.get(i); + if(Objects.isNull(applyDetail) + ||Objects.isNull(applyDetail.getMemberId()) + ||Objects.isNull(applyDetail.getDuId()) + ||Objects.isNull(applyDetail.getWorktypeId()) + ){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鎶曚繚鍛樺伐淇℃伅鏁版嵁缂哄け"); + } + applyDetail.setCreateDate(new Date()); + applyDetail.setCreator(loginUserInfo.getId()); + applyDetail.setIsdeleted(Constants.ZERO); + applyDetail.setSortnum(i); + applyDetail.setApplyId(insuranceApply.getId()); + if(Objects.isNull(applyDetail.getMemberId())){ + throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"銆�"+applyDetail.getMemberName()+"銆戝憳宸ヤ俊鎭瓨鍦ㄥ紓甯告暟鎹紒"); + } + Member member = memberMapper.selectById(applyDetail.getMemberId()); + if(Objects.isNull(member)){ + throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"銆�"+applyDetail.getMemberName()+"銆戝憳宸ヤ俊鎭瓨鍦ㄥ紓甯告暟鎹紒"); + } + applyDetail.setIdcardNo(member.getIdcardNo()); + applyDetail.setSex(member.getSex()); + applyDetail.setFee(this.countDetailFee(solutions,insuranceApply.getApplyEndTime(),insuranceApply.getApplyStartTime())); + //楠岃瘉娲鹃仯鍗曚綅淇℃伅鏄惁瀛樺湪 + if(duSolutionList.stream().filter(d->d.getDispatchUnitId().equals(applyDetail.getDuId())).collect(Collectors.toList()).size()<=Constants.ZERO){ + throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"銆�"+applyDetail.getMemberName()+"銆戝憳宸ユ淳閬e崟浣嶆湭鏌ヨ鍒帮紒"); + } + if(duWorktypeList.stream().filter(d->d.getDuSolutionId().equals(applyDetail.getDuId())&&d.getWorkTypeId().equals(applyDetail.getWorktypeId())) + .collect(Collectors.toList()).size()<=Constants.ZERO){ + throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"銆�"+applyDetail.getMemberName()+"銆戝憳宸ュ伐绉嶄俊鎭湭鏌ヨ鍒帮紒"); + } + applyDetailMapper.insert(applyDetail); + } + //瀛樺偍鏃ュ織鏁版嵁 + this.saveApplyLog(insuranceApply,insuranceApplyStatus,null); return insuranceApply.getId(); } + + public void saveApplyLog(InsuranceApply insuranceApply,Constants.InsuranceApplyStatus insuranceApplyStatus,String content){ + LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); + ApplyLog applyLog = new ApplyLog(); + applyLog.setCreateDate(new Date()); + applyLog.setCreator(loginUserInfo.getId()); + applyLog.setIsdeleted(Constants.ZERO); + applyLog.setApplyId(insuranceApply.getId()); + applyLog.setTitle(insuranceApplyStatus.getName()); + applyLog.setContent(content); + applyLog.setObjType(insuranceApplyStatus.getKey()); + applyLog.setObjId(Integer.toString(insuranceApply.getId())); + applyLog.setStatus(insuranceApply.getStatus()); + applyLogMapper.insert(applyLog); + } + + + + public BigDecimal countDetailFee(Solutions solutions ,Date startDate,Date endDate){ + //鏌ヨ淇濋櫓瀹為檯鍛ㄦ湡 + Integer cycle = DateUtil.calculateBetween(endDate,startDate,solutions.getDataType()); + if(cycle==-1){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鏃ユ湡淇℃伅閿欒!"); + } + return solutions.getPrice().multiply(new BigDecimal(cycle)); + } + +// public static void main(String[] args) { +// Date date1 = DateUtil.StringToDate("2023-03-01 00:00:00"); +// Date date2 = DateUtil.StringToDate("2023-04-01 00:00:00"); +// System.out.println(DateUtil.calculateBetween(date1,date2,0)); +// System.out.println(DateUtil.calculateBetween(date1,date2,1)); +// System.out.println(DateUtil.calculateBetween(date1,date2,2)); +// System.out.println(DateUtil.calculateBetween(date1,date2,3)); +// +// } + @Override public void deleteById(Integer id) { @@ -85,73 +249,46 @@ } @Override - public PageData<InsuranceApply> findPage(PageWrap<InsuranceApply> pageWrap) { + public PageData<InsuranceApply> findPage(PageWrap<InsuranceApplyQueryDTO> pageWrap) { + LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); IPage<InsuranceApply> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); - QueryWrapper<InsuranceApply> queryWrapper = new QueryWrapper<>(); + MPJLambdaWrapper<InsuranceApply> queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); - if (pageWrap.getModel().getId() != null) { - queryWrapper.lambda().eq(InsuranceApply::getId, pageWrap.getModel().getId()); - } - if (pageWrap.getModel().getCreator() != null) { - queryWrapper.lambda().eq(InsuranceApply::getCreator, pageWrap.getModel().getCreator()); - } - if (pageWrap.getModel().getCreateDate() != null) { - queryWrapper.lambda().ge(InsuranceApply::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); - queryWrapper.lambda().le(InsuranceApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); - } - if (pageWrap.getModel().getEditor() != null) { - queryWrapper.lambda().eq(InsuranceApply::getEditor, pageWrap.getModel().getEditor()); - } - if (pageWrap.getModel().getEditDate() != null) { - queryWrapper.lambda().ge(InsuranceApply::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); - queryWrapper.lambda().le(InsuranceApply::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); - } - if (pageWrap.getModel().getIsdeleted() != null) { - queryWrapper.lambda().eq(InsuranceApply::getIsdeleted, pageWrap.getModel().getIsdeleted()); - } - if (pageWrap.getModel().getRemark() != null) { - queryWrapper.lambda().eq(InsuranceApply::getRemark, pageWrap.getModel().getRemark()); - } - if (pageWrap.getModel().getSortnum() != null) { - queryWrapper.lambda().eq(InsuranceApply::getSortnum, pageWrap.getModel().getSortnum()); + queryWrapper.selectAll(InsuranceApply.class); + queryWrapper.selectAs(Company::getName,InsuranceApply::getCompanyName); + queryWrapper.selectAs(Solutions::getName,InsuranceApply::getSolutionsName); + queryWrapper.eq(InsuranceApply::getIsdeleted,Constants.ZERO); + //浼佷笟浜哄憳鏌ョ湅鏈紒涓氭暟鎹� + if(loginUserInfo.getType().equals(Constants.ONE)){ + queryWrapper.eq(InsuranceApply::getCompanyId, loginUserInfo.getCompanyId()); } if (pageWrap.getModel().getSolutionId() != null) { - queryWrapper.lambda().eq(InsuranceApply::getSolutionId, pageWrap.getModel().getSolutionId()); + queryWrapper.eq(InsuranceApply::getSolutionId, pageWrap.getModel().getSolutionId()); } - if (pageWrap.getModel().getCompanyId() != null) { - queryWrapper.lambda().eq(InsuranceApply::getCompanyId, pageWrap.getModel().getCompanyId()); + if (pageWrap.getModel().getEndTimeS() != null) { + queryWrapper.ge(InsuranceApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTimeS())); } - if (pageWrap.getModel().getApplyEndTime() != null) { - queryWrapper.lambda().ge(InsuranceApply::getApplyEndTime, Utils.Date.getStart(pageWrap.getModel().getApplyEndTime())); - queryWrapper.lambda().le(InsuranceApply::getApplyEndTime, Utils.Date.getEnd(pageWrap.getModel().getApplyEndTime())); + if (pageWrap.getModel().getEndTimeE() != null) { + queryWrapper.le(InsuranceApply::getEndTime, Utils.Date.getEnd(pageWrap.getModel().getEndTimeE())); } - if (pageWrap.getModel().getApplyStartTime() != null) { - queryWrapper.lambda().ge(InsuranceApply::getApplyStartTime, Utils.Date.getStart(pageWrap.getModel().getApplyStartTime())); - queryWrapper.lambda().le(InsuranceApply::getApplyStartTime, Utils.Date.getEnd(pageWrap.getModel().getApplyStartTime())); + if (pageWrap.getModel().getStartTimeS() != null) { + queryWrapper.ge(InsuranceApply::getStartTime, Utils.Date.getStart(pageWrap.getModel().getStartTimeS())); } - if (pageWrap.getModel().getEndTime() != null) { - queryWrapper.lambda().ge(InsuranceApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTime())); - queryWrapper.lambda().le(InsuranceApply::getEndTime, Utils.Date.getEnd(pageWrap.getModel().getEndTime())); + if (pageWrap.getModel().getStartTimeE() != null) { + queryWrapper.le(InsuranceApply::getStartTime, Utils.Date.getEnd(pageWrap.getModel().getStartTimeE())); } - if (pageWrap.getModel().getStartTime() != null) { - queryWrapper.lambda().ge(InsuranceApply::getStartTime, Utils.Date.getStart(pageWrap.getModel().getStartTime())); - queryWrapper.lambda().le(InsuranceApply::getStartTime, Utils.Date.getEnd(pageWrap.getModel().getStartTime())); + if (pageWrap.getModel().getCreateTimeS() != null) { + queryWrapper.ge(InsuranceApply::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateTimeS())); } - if (pageWrap.getModel().getCheckDate() != null) { - queryWrapper.lambda().ge(InsuranceApply::getCheckDate, Utils.Date.getStart(pageWrap.getModel().getCheckDate())); - queryWrapper.lambda().le(InsuranceApply::getCheckDate, Utils.Date.getEnd(pageWrap.getModel().getCheckDate())); + if (pageWrap.getModel().getCreateTimeE() != null) { + queryWrapper.le(InsuranceApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateTimeE())); } - if (pageWrap.getModel().getCheckInfo() != null) { - queryWrapper.lambda().eq(InsuranceApply::getCheckInfo, pageWrap.getModel().getCheckInfo()); - } - if (pageWrap.getModel().getCheckUserId() != null) { - queryWrapper.lambda().eq(InsuranceApply::getCheckUserId, pageWrap.getModel().getCheckUserId()); - } + if (pageWrap.getModel().getCode() != null) { - queryWrapper.lambda().eq(InsuranceApply::getCode, pageWrap.getModel().getCode()); + queryWrapper.eq(InsuranceApply::getCode, pageWrap.getModel().getCode()); } if (pageWrap.getModel().getStatus() != null) { - queryWrapper.lambda().eq(InsuranceApply::getStatus, pageWrap.getModel().getStatus()); + queryWrapper.eq(InsuranceApply::getStatus, pageWrap.getModel().getStatus()); } for(PageWrap.SortData sortData: pageWrap.getSorts()) { if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { @@ -160,12 +297,82 @@ queryWrapper.orderByAsc(sortData.getProperty()); } } - return PageData.from(insuranceApplyMapper.selectPage(page, queryWrapper)); + PageData<InsuranceApply> pageData = PageData.from(insuranceApplyJoinMapper.selectJoinPage(page,InsuranceApply.class, queryWrapper)); + return pageData; } + + @Override public long count(InsuranceApply insuranceApply) { QueryWrapper<InsuranceApply> wrapper = new QueryWrapper<>(insuranceApply); return insuranceApplyMapper.selectCount(wrapper); } + + + + @Override + public InsuranceApply findDetail(Integer id) { + InsuranceApply insuranceApply = insuranceApplyMapper.selectById(id); + if(Objects.isNull(insuranceApply)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY); + } + insuranceApply.setInsureNum(applyDetailMapper.selectCount(new QueryWrapper<ApplyDetail>().lambda().eq(ApplyDetail::getApplyId,insuranceApply.getId()) + .eq(ApplyDetail::getIsdeleted,Constants.ZERO))); + + //鏌ヨ鎿嶄綔璁板綍 + List<ApplyLog> applyLogList = applyLogJoinMapper.selectJoinList(ApplyLog.class, + new MPJLambdaWrapper<ApplyLog>() + .selectAll(ApplyLog.class) + .selectAs(Member::getName,ApplyLog::getCreatorName) + .selectAs(Company::getName,ApplyLog::getCompanyName) + .leftJoin(Member.class,Member::getId,ApplyLog::getCreator) + .leftJoin(Company.class,Company::getId,Member::getCompanyId) + .eq(ApplyLog::getApplyId,insuranceApply.getId()) + .orderByAsc(ApplyLog::getCreateDate) + ); + insuranceApply.setApplyLogList(applyLogList); + return insuranceApply; + } + + + @Override + @Transactional(rollbackFor = {Exception.class,BusinessException.class}) + public void applyReturn(InsuranceApplyOptDTO insuranceApplyOptDTO){ + if(Objects.isNull(insuranceApplyOptDTO) + ||Objects.isNull(insuranceApplyOptDTO.getApplyId()) + ||StringUtils.isBlank(insuranceApplyOptDTO.getOptIllustration())){ + throw new BusinessException(ResponseStatus.BAD_REQUEST); + } + LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); + if(loginUserInfo.getType().equals(Constants.ZERO)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"闈炰紒涓氱鐢ㄦ埛鏃犳硶杩涜璇ユ搷浣�"); + } + InsuranceApply insuranceApply = insuranceApplyMapper.selectById(insuranceApplyOptDTO.getApplyId()); + if(Objects.isNull(insuranceApply)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY); + } + if(insuranceApply.getIsdeleted().equals(Constants.ONE)){ + throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"鏁版嵁宸插垹闄�,鏃犳硶杩涜璇ユ搷浣�"); + } + if(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.COMPANY_APPLY_RETURN.getKey())){ + throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"閫�鍥炵敵璇蜂腑锛岃鍕块噸澶嶆搷浣�"); + } + if(!(insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.UPLOAD.getKey()) + ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.WAIT_SIGNATURE.getKey()) + ||insuranceApply.getStatus().equals(Constants.InsuranceApplyStatus.SIGNATURE.getKey()))){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏁版嵁鐘舵�侀潪鍙敵璇烽��鍥�!"); + } + Constants.InsuranceApplyStatus insuranceApplyStatus = Constants.InsuranceApplyStatus.COMPANY_APPLY_RETURN; + insuranceApply.setStatus(insuranceApplyStatus.getKey()); + insuranceApply.setCheckDate(new Date()); + insuranceApply.setCheckInfo(insuranceApplyOptDTO.getOptIllustration()); + insuranceApply.setCheckUserId(loginUserInfo.getId()); + insuranceApplyMapper.updateById(insuranceApply); + //瀛樺偍鏃ュ織鏁版嵁 + this.saveApplyLog(insuranceApply,insuranceApplyStatus,null); + + } + + } -- Gitblit v1.9.3