From ade22c0c65473ab6b56ca2bd0dd2c77014eb1f13 Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期一, 01 四月 2024 14:35:41 +0800
Subject: [PATCH] git ch

---
 server/service/src/main/java/com/doumee/service/business/impl/UnionApplyServiceImpl.java |  170 ++++++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 121 insertions(+), 49 deletions(-)

diff --git a/server/service/src/main/java/com/doumee/service/business/impl/UnionApplyServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/UnionApplyServiceImpl.java
index 75b8f44..04b339c 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/UnionApplyServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/UnionApplyServiceImpl.java
@@ -14,14 +14,12 @@
 import com.doumee.dao.business.MultifileMapper;
 import com.doumee.dao.business.SolutionsMapper;
 import com.doumee.dao.business.UnionApplyMapper;
-import com.doumee.dao.business.dto.SaveUnionApplyDTO;
-import com.doumee.dao.business.dto.UnionApplyBXDDDetailTO;
-import com.doumee.dao.business.dto.UnionApplyBXDDTO;
-import com.doumee.dao.business.dto.UploadMultifileDTO;
+import com.doumee.dao.business.dto.*;
 import com.doumee.dao.business.join.ApplyDetailJoinMapper;
 import com.doumee.dao.business.join.InsuranceApplyJoinMapper;
 import com.doumee.dao.business.join.UnionApplyJoinMapper;
 import com.doumee.dao.business.model.*;
+import com.doumee.service.business.SmsEmailService;
 import com.doumee.service.business.UnionApplyService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
@@ -33,9 +31,10 @@
 import org.apache.commons.lang3.StringUtils;
 import org.apache.shiro.SecurityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
-import org.springframework.util.CollectionUtils;
+import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
 
 import java.math.BigDecimal;
 import java.util.ArrayList;
@@ -78,6 +77,12 @@
 
     @Autowired
     private SignService signService;
+
+    @Autowired
+    private SmsEmailService smsEmailService;
+
+    @Value("${debug_model}")
+    private boolean debugModel;
 
     @Override
     public Integer create(UnionApply unionApply) {
@@ -139,75 +144,81 @@
     @Override
     public PageData<UnionApply> findPage(PageWrap<UnionApply> pageWrap) {
         IPage<UnionApply> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
-        QueryWrapper<UnionApply> queryWrapper = new QueryWrapper<>();
+        MPJLambdaWrapper<UnionApply> queryWrapper = new MPJLambdaWrapper<>();
         Utils.MP.blankToNull(pageWrap.getModel());
-
+        queryWrapper.selectAll(UnionApply.class);
+        queryWrapper.leftJoin(Solutions.class,Solutions::getId,UnionApply::getSolutionId);
         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
         if(user.getType().equals(Constants.TWO)){
-            queryWrapper.lambda().eq(UnionApply::getCompanyId, pageWrap.getModel().getCompanyId());
+            queryWrapper.eq(UnionApply::getCompanyId, pageWrap.getModel().getCompanyId());
         }
-
         if (pageWrap.getModel().getId() != null) {
-            queryWrapper.lambda().eq(UnionApply::getId, pageWrap.getModel().getId());
+            queryWrapper.eq(UnionApply::getId, pageWrap.getModel().getId());
         }
         if (pageWrap.getModel().getCreator() != null) {
-            queryWrapper.lambda().eq(UnionApply::getCreator, pageWrap.getModel().getCreator());
+            queryWrapper.eq(UnionApply::getCreator, pageWrap.getModel().getCreator());
+        }
+        if (pageWrap.getModel().getQueryStartTime() != null) {
+            queryWrapper.ge(UnionApply::getCreateDate, pageWrap.getModel().getQueryStartTime() +" 00:00:00" );
+        }
+        if (pageWrap.getModel().getQueryEndTime() != null) {
+            queryWrapper.le(UnionApply::getCreateDate, pageWrap.getModel().getQueryEndTime() +" 23:59:59");
         }
         if (pageWrap.getModel().getCreateDate() != null) {
-            queryWrapper.lambda().ge(UnionApply::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
-            queryWrapper.lambda().le(UnionApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
+            queryWrapper.ge(UnionApply::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
+            queryWrapper.le(UnionApply::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
         }
         if (pageWrap.getModel().getEditor() != null) {
-            queryWrapper.lambda().eq(UnionApply::getEditor, pageWrap.getModel().getEditor());
+            queryWrapper.eq(UnionApply::getEditor, pageWrap.getModel().getEditor());
         }
         if (pageWrap.getModel().getEditDate() != null) {
-            queryWrapper.lambda().ge(UnionApply::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
-            queryWrapper.lambda().le(UnionApply::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
+            queryWrapper.ge(UnionApply::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
+            queryWrapper.le(UnionApply::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
         }
         if (pageWrap.getModel().getIsdeleted() != null) {
-            queryWrapper.lambda().eq(UnionApply::getIsdeleted, pageWrap.getModel().getIsdeleted());
+            queryWrapper.eq(UnionApply::getIsdeleted, pageWrap.getModel().getIsdeleted());
         }
         if (pageWrap.getModel().getRemark() != null) {
-            queryWrapper.lambda().eq(UnionApply::getRemark, pageWrap.getModel().getRemark());
+            queryWrapper.eq(UnionApply::getRemark, pageWrap.getModel().getRemark());
         }
         if (pageWrap.getModel().getSortnum() != null) {
-            queryWrapper.lambda().eq(UnionApply::getSortnum, pageWrap.getModel().getSortnum());
+            queryWrapper.eq(UnionApply::getSortnum, pageWrap.getModel().getSortnum());
         }
         if (pageWrap.getModel().getCompanyId() != null) {
-            queryWrapper.lambda().eq(UnionApply::getCompanyId, pageWrap.getModel().getCompanyId());
+            queryWrapper.eq(UnionApply::getCompanyId, pageWrap.getModel().getCompanyId());
         }
         if (pageWrap.getModel().getEndTime() != null) {
-            queryWrapper.lambda().ge(UnionApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTime()));
-            queryWrapper.lambda().le(UnionApply::getEndTime, Utils.Date.getEnd(pageWrap.getModel().getEndTime()));
+            queryWrapper.ge(UnionApply::getEndTime, Utils.Date.getStart(pageWrap.getModel().getEndTime()));
+            queryWrapper.le(UnionApply::getEndTime, Utils.Date.getEnd(pageWrap.getModel().getEndTime()));
         }
         if (pageWrap.getModel().getStartTime() != null) {
-            queryWrapper.lambda().ge(UnionApply::getStartTime, Utils.Date.getStart(pageWrap.getModel().getStartTime()));
-            queryWrapper.lambda().le(UnionApply::getStartTime, Utils.Date.getEnd(pageWrap.getModel().getStartTime()));
+            queryWrapper.ge(UnionApply::getStartTime, Utils.Date.getStart(pageWrap.getModel().getStartTime()));
+            queryWrapper.le(UnionApply::getStartTime, Utils.Date.getEnd(pageWrap.getModel().getStartTime()));
         }
         if (pageWrap.getModel().getCheckDate() != null) {
-            queryWrapper.lambda().ge(UnionApply::getCheckDate, Utils.Date.getStart(pageWrap.getModel().getCheckDate()));
-            queryWrapper.lambda().le(UnionApply::getCheckDate, Utils.Date.getEnd(pageWrap.getModel().getCheckDate()));
+            queryWrapper.ge(UnionApply::getCheckDate, Utils.Date.getStart(pageWrap.getModel().getCheckDate()));
+            queryWrapper.le(UnionApply::getCheckDate, Utils.Date.getEnd(pageWrap.getModel().getCheckDate()));
         }
         if (pageWrap.getModel().getCheckInfo() != null) {
-            queryWrapper.lambda().eq(UnionApply::getCheckInfo, pageWrap.getModel().getCheckInfo());
+            queryWrapper.eq(UnionApply::getCheckInfo, pageWrap.getModel().getCheckInfo());
         }
         if (pageWrap.getModel().getCheckUserId() != null) {
-            queryWrapper.lambda().eq(UnionApply::getCheckUserId, pageWrap.getModel().getCheckUserId());
+            queryWrapper.eq(UnionApply::getCheckUserId, pageWrap.getModel().getCheckUserId());
         }
         if (pageWrap.getModel().getCode() != null) {
-            queryWrapper.lambda().eq(UnionApply::getCode, pageWrap.getModel().getCode());
+            queryWrapper.eq(UnionApply::getCode, pageWrap.getModel().getCode());
         }
         if (pageWrap.getModel().getStatus() != null) {
-            queryWrapper.lambda().eq(UnionApply::getStatus, pageWrap.getModel().getStatus());
+            queryWrapper.eq(UnionApply::getStatus, pageWrap.getModel().getStatus());
         }
         if (pageWrap.getModel().getCurrentFee() != null) {
-            queryWrapper.lambda().eq(UnionApply::getCurrentFee, pageWrap.getModel().getCurrentFee());
+            queryWrapper.eq(UnionApply::getCurrentFee, pageWrap.getModel().getCurrentFee());
         }
         if (pageWrap.getModel().getFee() != null) {
-            queryWrapper.lambda().eq(UnionApply::getFee, pageWrap.getModel().getFee());
+            queryWrapper.eq(UnionApply::getFee, pageWrap.getModel().getFee());
         }
         if (pageWrap.getModel().getSignApplyNo() != null) {
-            queryWrapper.lambda().eq(UnionApply::getSignApplyNo, pageWrap.getModel().getSignApplyNo());
+            queryWrapper.eq(UnionApply::getSignApplyNo, pageWrap.getModel().getSignApplyNo());
         }
         for(PageWrap.SortData sortData: pageWrap.getSorts()) {
             if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
@@ -216,7 +227,8 @@
                 queryWrapper.orderByAsc(sortData.getProperty());
             }
         }
-        return PageData.from(unionApplyMapper.selectPage(page, queryWrapper));
+        PageData<UnionApply> pageData = PageData.from(unionApplyJoinMapper.selectJoinPage(page,UnionApply.class, queryWrapper));
+        return pageData;
     }
 
     @Override
@@ -233,11 +245,27 @@
                 new MPJLambdaWrapper<UnionApply>()
                         .selectAll(UnionApply.class)
                         .selectAs(Solutions::getName,UnionApply::getSolutionName)
+                        .selectAs(Company::getName,UnionApply::getCompanyName)
                         .select(" ( select count(DISTINCT(ad.MEMBER_ID)) from apply_detail ad  where ad.UNION_APPLY_ID = t.id ) as insureNum")
                         .leftJoin(Solutions.class,Solutions::getId,UnionApply::getSolutionId)
+                        .leftJoin(Company.class,Company::getId,UnionApply::getCompanyId)
                         .eq(UnionApply::getId,applyId)
                         .last(" limit 1 ")
         );
+        unionApply.setServiceDays(Constants.ZERO);
+        if(unionApply.getStatus().equals(Constants.UnionApplyStatus.FINISH.getKey())){
+            //濡傛灉褰撳墠鏃堕棿澶т簬缁撴潫鏃ユ湡 鍒欎娇鐢ㄧ粨鏉熸棩鏈熷姣斿紑濮嬫棩鏈�
+            if(DateUtil.compareDate(new Date(),unionApply.getEndTime())>=Constants.ZERO){
+                unionApply.setServiceDays(
+                        DateUtil.daysBetweenDates(unionApply.getEndTime(),unionApply.getStartTime())+1
+                );
+            }else if(DateUtil.compareDate(unionApply.getStartTime(),new Date())>=Constants.ZERO){
+                //鏈紑濮�
+                unionApply.setServiceDays(Constants.ZERO);
+            }else{
+                unionApply.setServiceDays(DateUtil.daysBetweenDates(new Date(),unionApply.getStartTime())+1);
+            }
+        }
         return unionApply;
     }
 
@@ -264,7 +292,7 @@
                         .selectAs(InsuranceApply::getSolutionBaseId,Solutions::getBaseId)
                         .leftJoin(Solutions.class,Solutions::getId,InsuranceApply::getSolutionId)
                         .eq(InsuranceApply::getIsdeleted, Constants.ZERO)
-                        .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.COMPANY_MEMBER_LIST_SIGNATURE.getKey())
+                        .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_BUSINESS_CHECK_PASS.getKey())
                         .eq(Solutions::getBaseId,saveUnionApplyDTO.getBaseSolutionId())
                         .in(InsuranceApply::getId,saveUnionApplyDTO.getApplyIds())
                         .isNull(InsuranceApply::getUnionApplyId)
@@ -295,6 +323,7 @@
                 .set(InsuranceApply::getUnionApplyId,unionApply.getId())
                 .set(InsuranceApply::getCheckDate,new Date())
                 .set(InsuranceApply::getCheckUserId,user.getId())
+                .set(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_TOUBAOING.getKey())
                 .in(InsuranceApply::getId,saveUnionApplyDTO.getApplyIds()));
 
         applyDetailJoinMapper.update(null,new UpdateWrapper<ApplyDetail>().lambda()
@@ -340,6 +369,7 @@
                 .set(InsuranceApply::getUnionApplyId,null)
                 .set(InsuranceApply::getCheckDate,new Date())
                 .set(InsuranceApply::getCheckUserId,user.getId())
+                .set(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_BUSINESS_CHECK_PASS.getKey())
                 .eq(InsuranceApply::getUnionApplyId,unionApply.getId()));
 
         applyDetailJoinMapper.update(null,new UpdateWrapper<ApplyDetail>().lambda()
@@ -359,8 +389,8 @@
     @Transactional(rollbackFor = {Exception.class,BusinessException.class})
     public void uploadToubaodan(UploadMultifileDTO uploadMultifileDTO){
         if(uploadMultifileDTO.getBusinessId() == null
-                ||StringUtils.isBlank( uploadMultifileDTO.getFilePath())
-                ||StringUtils.isBlank( uploadMultifileDTO.getFileName())){
+                ||StringUtils.isBlank( uploadMultifileDTO.getFileurl())
+                ||StringUtils.isBlank( uploadMultifileDTO.getName())){
             throw  new BusinessException(ResponseStatus.BAD_REQUEST);
         }
         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
@@ -381,6 +411,41 @@
             throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"瀵逛笉璧凤紝鍚堝苟鍗曚笟鍔″凡娴佽浆锛屾偍鏃犳硶杩涜璇ユ搷浣滐紒");
         }
 
+        if(CollectionUtils.isNotEmpty(uploadMultifileDTO.getMultifileList())){
+            List<Multifile> multifileList = uploadMultifileDTO.getMultifileList();
+            for (Multifile multifile:multifileList) {
+                if(Objects.isNull(multifile.getObjId())
+                    ||Objects.isNull(multifile.getName())
+                    ||Objects.isNull(multifile.getFileurl())){
+                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"浼佷笟鎶曚繚鍗曢檮浠跺弬鏁伴敊璇�");
+                }
+                InsuranceApply insuranceApply = insuranceApplyJoinMapper.selectOne(new QueryWrapper<InsuranceApply>().lambda()
+                        .eq(InsuranceApply::getId,multifile.getObjId())
+                        .eq(InsuranceApply::getUnionApplyId,uploadMultifileDTO.getBusinessId())
+                );
+                if(Objects.isNull(insuranceApply)){
+                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"浼佷笟鎶曚繚鍗曟湭鏌ヨ鍒�");
+                }
+
+                multifile.setIsdeleted(Constants.ZERO);
+                multifile.setCreator(user.getId());
+                multifile.setCreateDate(new Date());
+                multifile.setCreateDate(new Date());
+                multifile.setObjType(Constants.MultiFile.COMPANY_TBD_SIGNED.getKey());
+                multifile.setType(Constants.TWO);
+                multifileMapper.insert(multifile);
+
+                insuranceApplyJoinMapper.update(null,new UpdateWrapper<InsuranceApply>().lambda()
+                        .set(InsuranceApply::getUnionApplyTbdStatus,Constants.ONE)
+                        .set(InsuranceApply::getEditDate,new Date())
+                        .set(InsuranceApply::getEditor,user.getId())
+                        .eq(InsuranceApply::getId,multifile.getObjId())
+                );
+
+            }
+        }
+
+
         unionApply.setCheckDate(new Date());
         unionApply.setCheckUserId(user.getId());
         unionApply.setStatus(Constants.UnionApplyStatus.WAIT_SIGNATURE.getKey());
@@ -396,9 +461,12 @@
         multifile.setCreateDate(new Date());
         multifile.setObjType(Constants.MultiFile.HBD_BD_SIGNED_PDF.getKey());
         multifile.setType(Constants.TWO);
-        multifile.setFileurl(uploadMultifileDTO.getFilePath());
-        multifile.setName(uploadMultifileDTO.getFileName());
+        multifile.setFileurl(uploadMultifileDTO.getFileurl());
+        multifile.setName(uploadMultifileDTO.getName());
         multifileMapper.insert(multifile);
+
+
+
 
     }
 
@@ -410,15 +478,22 @@
      */
     @Override
     @Transactional(rollbackFor = {Exception.class,BusinessException.class})
-    public  String getSignLink(Integer id) {
-        if(id == null ){
+    public  String getSignLink(SmsCheckDTO smsCheckDTO) {
+        if(Objects.isNull(smsCheckDTO)
+                || Objects.isNull(smsCheckDTO.getBusinessId())
+                || StringUtils.isBlank(smsCheckDTO.getCode())
+        ){
             throw  new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        //楠岃瘉 楠岃瘉鐮�
+        if(!debugModel){
+            smsEmailService.validateCode(smsCheckDTO.getCode());
         }
         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
         if(!user.getType().equals(Constants.TWO)){
             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"闈炲晢鎴风敤鎴凤紝鏃犳硶杩涜璇ユ搷浣滐紒");
         }
-        UnionApply unionApply = unionApplyJoinMapper.selectById(id);
+        UnionApply unionApply = unionApplyJoinMapper.selectById(smsCheckDTO.getBusinessId());
         if(unionApply == null ||!Constants.equalsInteger(unionApply.getIsdeleted(),Constants.ZERO)){
             throw  new BusinessException(ResponseStatus.DATA_EMPTY);
         }
@@ -540,7 +615,7 @@
                 multifile.setCreator(user.getId());
                 multifile.setCreateDate(new Date());
                 multifile.setObjId(insuranceApply.getId());
-                multifile.setObjType(Constants.MultiFile.COMPANY_TBD_SIGNED_PDF.getKey());
+                multifile.setObjType(Constants.MultiFile.BD_DONE_PDF.getKey());
                 multifile.setType(Constants.TWO);
                 multifile.setFileurl(unionApplyBXDDDetailTO.getFileUrl());
                 multifile.setName(unionApplyBXDDDetailTO.getFileName());
@@ -555,7 +630,8 @@
                             new BigDecimal(applyDetails.size())
                             .multiply(price)
                     )
-                    .set(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
+                    .set(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.WTB_DONE.getKey())
+                    .set(InsuranceApply::getUnionApplyTbdStatus,3)
                     .set(InsuranceApply::getFee,price.multiply(new BigDecimal(applyDetails.size())).multiply(new BigDecimal(maxDays)))
                     .set(InsuranceApply::getCurrentFee,currentFee.multiply(new BigDecimal(applyDetails.size())))
                     .set(InsuranceApply::getStartTime,unionApplyBXDDTO.getStartTime())
@@ -597,16 +673,12 @@
             multifile.setCreator(user.getId());
             multifile.setCreateDate(new Date());
             multifile.setObjId(unionApply.getId());
-            multifile.setObjType(Constants.MultiFile.HBD_BD_APPLY_PDF.getKey());
+            multifile.setObjType(Constants.MultiFile.WTB_BD_DONE_PDF.getKey());
             multifile.setType(Constants.TWO);
             multifile.setFileurl(unionApplyBXDDTO.getFileUrl());
             multifile.setName(unionApplyBXDDTO.getFileName());
             multifileMapper.insert(multifile);
         }
-
-
-
-
     }
 
 

--
Gitblit v1.9.3