From 9dd5d877978595c27b044b795ea31bc0347438c9 Mon Sep 17 00:00:00 2001
From: nidapeng <jp@doumee.com>
Date: 星期二, 09 四月 2024 19:06:53 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/1.0.1' into 1.0.1

---
 server/service/src/main/java/com/doumee/service/business/impl/UnionChangeServiceImpl.java |  122 ++++++++++++++++++++++++++++++----------
 1 files changed, 92 insertions(+), 30 deletions(-)

diff --git a/server/service/src/main/java/com/doumee/service/business/impl/UnionChangeServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/UnionChangeServiceImpl.java
index 3cc038d..a05336f 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/UnionChangeServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/UnionChangeServiceImpl.java
@@ -178,10 +178,13 @@
             BigDecimal fee = BigDecimal.ZERO;
             for (ApplyChagneDetail applyChagneDetail:applyChangeList) {
                 Integer maxDays = DateUtil.calculateBetween(unionChange.getApplyStartTime(),applyChagneDetail.getEndTime(),0);
+                if(applyChagneDetail.getType().equals(Constants.ONE)){
+                    maxDays = DateUtil.daysBetweenDates(applyChagneDetail.getEndTime(),DateUtil.getMontageDate(unionChange.getApplyStartTime(),3));
+                }
                 if(applyChagneDetail.getType().equals(Constants.ZERO)){
                     fee = fee.add(new BigDecimal(maxDays).multiply(applyChagneDetail.getPrice()));
                 }else{
-                    fee = fee.subtract(new BigDecimal(maxDays).multiply(applyChagneDetail.getPrice()));
+                    fee = fee.subtract(new BigDecimal(maxDays).multiply(applyChagneDetail.getPrice())).add(applyChagneDetail.getFee());
                 }
             }
             unionChange.setFee(fee);
@@ -355,11 +358,16 @@
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
 
-//        UnionApply unionApply = unionApplyMapper.selectById(saveUnionChangeDTO.getUnionApplyId());
-//        if(Objects.isNull(unionApply)){
-//            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鏈煡璇㈠埌鍚堝苟淇濆崟鏁版嵁");
-//        }
-
+        UnionApply unionApply = unionApplyMapper.selectById(saveUnionChangeDTO.getUnionApplyId());
+        if(Objects.isNull(unionApply)){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鏈煡璇㈠埌鍚堝苟淇濆崟鏁版嵁");
+        }
+        //鍒ゆ柇鎵瑰崟鏃ユ湡 鍚堝苟鍗曠殑鎵瑰崟鐢熸晥鏈熷湪涓� 淇濆崟璧锋湡鐨勬鏃� 鍒颁繚鍗曟鏈�
+        //鑾峰彇寮�濮嬫棩鏈熸鏃�
+        if(saveUnionChangeDTO.getApplyDate().getTime()<=DateUtil.afterDateByType(unionApply.getStartTime(),0,1).getTime()
+        || saveUnionChangeDTO.getApplyDate().getTime()> unionApply.getEndTime().getTime()){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍚堝苟鍗曠殑鎵瑰崟鐢熸晥鏈熼敊璇�");
+        }
 
         List<ApplyChange> applyChangeList = applyChangeJoinMapper.selectJoinList(ApplyChange.class,
                 new MPJLambdaWrapper<ApplyChange>()
@@ -631,6 +639,16 @@
         if(!unionChange.getStatus().equals(Constants.UnionChangeStatus.UPLOAD_INSURANCE_POLICY.getKey())){
             throw new BusinessException(ResponseStatus.DATA_ERRO.getCode(),"瀵逛笉璧凤紝鍚堝苟鍗曠姸鎬佸凡娴佽浆");
         }
+        UnionApply unionApply = unionApplyMapper.selectById(unionChange.getUnionApplyId());
+        if(Objects.isNull(unionApply)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鍚堝苟淇濆崟淇℃伅");
+        }
+        //鍒ゆ柇鎵瑰崟鏃ユ湡 鍚堝苟鍗曠殑鎵瑰崟鐢熸晥鏈熷湪涓� 淇濆崟璧锋湡鐨勬鏃� 鍒颁繚鍗曟鏈�
+        //鑾峰彇寮�濮嬫棩鏈熸鏃�
+        if(unionChangeBXDDTO.getApplyDate().getTime()<=DateUtil.afterDateByType(unionApply.getStartTime(),0,1).getTime()
+                || unionChangeBXDDTO.getApplyDate().getTime()> unionApply.getEndTime().getTime()){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍚堝苟鍗曠殑鎵瑰崟鐢熸晥鏈熼敊璇�");
+        }
 
         List<ApplyChange> applyChangeList = applyChangeJoinMapper.selectJoinList(ApplyChange.class,
                 new MPJLambdaWrapper<ApplyChange>()
@@ -686,15 +704,28 @@
                 applyChange.setEditDate(new Date());
                 applyChange.setEditor(user.getId());
                 applyChange.setStatus(Constants.ApplyChangeStatus.APPROVE.getKey());
+                applyChange.setCode(unionChangeBXDDTO.getCode());
+                applyChange.setValidCode(unionChangeBXDDTO.getCode());
+                applyChange.setCheckUserId(user.getId());
                 List<ApplyChagneDetail> allList = applyChagneDetailJoinMapper.selectJoinList(ApplyChagneDetail.class,
-                        new MPJLambdaWrapper<ApplyChagneDetail>().selectAll(ApplyChagneDetail.class)
-                                .selectAs(Member::getName,ApplyChagneDetail::getMemberName )
-                                .selectAs(Member::getIdcardNo,ApplyChagneDetail::getIdcardNo )
-                                .leftJoin(Member.class,Member::getId,ApplyChagneDetail::getMemberId)
+                        new MPJLambdaWrapper<ApplyChagneDetail>()
+                                .selectAll(ApplyChagneDetail.class)
+                                .selectAs(Member::getIdcardNo,ApplyChagneDetail::getIdcardNo)
+                                .selectAs(Solutions::getTimeUnit, ApplyChagneDetail::getSolutionTimeUnit)
+                                .selectAs(Solutions::getPrice, ApplyChagneDetail::getSolutionPrice)
+                                .selectAs(Worktype::getName, ApplyChagneDetail::getWorkTypeName)
+                                .selectAs(DispatchUnit::getName, ApplyChagneDetail::getDuName)
+                                .selectAs(Member::getName, ApplyChagneDetail::getMemberName)
+                                .selectAs(Solutions::getName,ApplyChagneDetail::getSolutionsName)
+                                .selectAs(InsuranceApply::getCode,ApplyChagneDetail::getApplyCode)
+                                .leftJoin(ApplyChange.class, ApplyChange::getId, ApplyChagneDetail::getApplyChangeId)
+                                .leftJoin(Member.class, Member::getId, ApplyChagneDetail::getMemberId)
+                                .leftJoin(InsuranceApply.class, InsuranceApply::getId, ApplyChange::getApplyId)
+                                .leftJoin(Solutions.class, Solutions::getId, InsuranceApply::getSolutionId)
+                                .leftJoin(Worktype.class, Worktype::getId, ApplyChagneDetail::getWorktypeId)
+                                .leftJoin(DispatchUnit.class, DispatchUnit::getId, ApplyChagneDetail::getDuId)
                                 .eq(ApplyChagneDetail::getApplyChangeId,applyChange.getId()));
                 this.dealApplyChangeDetail(applyChange,allList);
-                applyChange.setCode(unionChangeBXDDTO.getCode());
-                applyChange.setCheckUserId(user.getId());
                 applyChangeJoinMapper.updateById(applyChange);
             }
         }
@@ -714,6 +745,9 @@
                 ,unionChange.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(unionChange));
         applyLogMapper.insert(log);
 
+//        if(true){
+//            throw new BusinessException(ResponseStatus.NOT_ALLOWED);
+//        }
     }
 
 
@@ -747,12 +781,6 @@
                     .set(InsuranceApply::getEditDate, applyChange.getEditDate())
                     .eq(InsuranceApply::getId, applyChange.getApplyId())
             );
-//            applyChangeJoinMapper.update(null, new UpdateWrapper<ApplyChange>().lambda()
-//                    .set(ApplyChange::getFee,bigDecimalVO.getTotalFee())
-//                    .set(ApplyChange::getEditor, applyChange.getEditor())
-//                    .set(ApplyChange::getEditDate, applyChange.getEditDate())
-//                    .eq(ApplyChange::getId, applyChange.getApplyId())
-//            );
             applyChange.setFee(bigDecimalVO.getTotalFee());
         }
 
@@ -788,6 +816,8 @@
         }else{
             add.setCurrentFee(BigDecimal.ZERO);
         }
+
+        add.setPrice(detail.getPrice());
         add.setApplyId(applyChange.getApplyId());
         add.setValidCode(applyChange.getValidCode());
         add.setFee(detail.getFee());
@@ -820,7 +850,18 @@
         memberInsurance.setStartTime(add.getStartTime());
         memberInsurance.setEndTime(add.getEndTime());
         memberInsurance.setRelationType(Constants.ONE);
+        memberInsurance.setPdCode(applyChange.getValidCode());
         memberInsuranceJoinMapper.insert(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())
+        );
+
     }
 
     /**
@@ -843,22 +884,22 @@
         BigDecimal pullFee = BigDecimal.ZERO;
         //鍑忎繚鍑忓皯鐨勯噾棰�
         BigDecimal reduceFee = BigDecimal.ZERO;
-        if (DateUtil.calculateBetween(applyChange.getApplyStartTime(),DateUtil.getMontageDate(new Date(), 2),0) > 0) {
+        Date reduceDate = DateUtil.getMontageDate(applyChange.getApplyStartTime(),3);
+        if (reduceDate.getTime() <  DateUtil.getMontageDate(new Date(), 2).getTime()) {
             //璁$畻澶氭墸閲戦
-
-            Integer days = DateUtil.calculateBetween(applyChange.getApplyStartTime(),DateUtil.getMontageDate(new Date(), 2),0);
+            Integer days = DateUtil.calculateBetween(reduceDate,DateUtil.getMontageDate(new Date(), 2),0);
             pullFee = new BigDecimal(days).multiply(detail.getPrice()).multiply(new BigDecimal(-1));
         }
         //璁$畻鎶曚繚鏄庣粏搴斿噺灏戠殑澶╂暟
-        Integer reduceDays = DateUtil.calculateBetween(applyChange.getApplyStartTime(),DateUtil.getMontageDate(oldModel.getEndTime(), 2),0);
+        Integer reduceDays = DateUtil.daysBetweenDates(oldModel.getEndTime(),reduceDate);
         if(reduceDays>0){
             reduceFee = new BigDecimal(reduceDays).multiply(detail.getPrice()).multiply(new BigDecimal(-1));
         }
         applyDetailJoinMapper.update(null, new UpdateWrapper<ApplyDetail>().lambda()
                 .setSql(" fee = ifnull(fee,0)+" + reduceFee)
                 .setSql(" current_fee = ifnull(current_fee,0)+" + pullFee)
-                .set(oldModel.getStartTime().compareTo(applyChange.getApplyStartTime())!=0,ApplyDetail::getEndTime, DateUtil.getMontageDate(applyChange.getApplyStartTime(), 3))
-                .set(oldModel.getStartTime().compareTo(applyChange.getApplyStartTime())==0,ApplyDetail::getEndTime, DateUtil.getMontageDate(applyChange.getApplyStartTime(), 2))
+                .set(oldModel.getStartTime().compareTo(reduceDate)!=0,ApplyDetail::getEndTime, reduceDate)
+                .set(oldModel.getStartTime().compareTo(reduceDate)==0,ApplyDetail::getEndTime, DateUtil.getMontageDate(applyChange.getApplyStartTime(), 2))
                 .set(ApplyDetail::getEditor, applyChange.getEditor())
                 .set(ApplyDetail::getEditDate, applyChange.getEditDate())
                 .eq(ApplyDetail::getId, oldModel.getId())
@@ -870,24 +911,34 @@
         //淇敼 鍛樺伐鎶曚繚鏄庣粏璁板綍 鍘嗗彶鏁版嵁
         memberInsuranceJoinMapper.update(null, new UpdateWrapper<MemberInsurance>().lambda()
                 .setSql(" fee = ifnull(fee,0)+" + reduceFee)
-                .set(oldModel.getStartTime().compareTo(applyChange.getApplyStartTime())!=0,MemberInsurance::getEndTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(), 3))
-                .set(oldModel.getStartTime().compareTo(applyChange.getApplyStartTime())==0,MemberInsurance::getEndTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(), 2))
+                .set(oldModel.getStartTime().compareTo(reduceDate)!=0,MemberInsurance::getEndTime,reduceDate)
+                .set(oldModel.getStartTime().compareTo(reduceDate)==0,MemberInsurance::getEndTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(), 2))
                 .eq(MemberInsurance::getRelationId, oldModel.getId())
+        );
+
+
+        memberMapper.update(null,new UpdateWrapper<Member>()
+                .lambda()
+                .set(Member::getStartTime,oldModel.getStartTime())
+                .set(oldModel.getStartTime().compareTo(reduceDate)!=0,Member::getEndTime,reduceDate)
+                .set(oldModel.getStartTime().compareTo(reduceDate)==0,Member::getEndTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(), 2))
+                .set(Member::getDuId,oldModel.getDuId())
+                .set(Member::getWorktypeId,oldModel.getWorktypeId())
+                .eq(Member::getId, oldModel.getMemberId())
         );
 
         //淇敼涓氬姟鏄庣粏琛屾暟鎹疄闄呮壒鍗曟棩鏈�
         applyChagneDetailJoinMapper.update(null,new UpdateWrapper<ApplyChagneDetail>().lambda()
-                .setSql(" fee = ifnull(fee,0)+" + reduceFee)
-                .set(ApplyChagneDetail::getEndTime,DateUtil.getMontageDate(applyChange.getApplyStartTime(), 3))
+//                .setSql(" fee = ifnull(fee,0)+" + reduceFee)
+                .set(ApplyChagneDetail::getFee,reduceFee)
+                .set(ApplyChagneDetail::getEndTime,reduceDate)
                 .eq(ApplyChagneDetail::getId,detail.getId())
         );
     }
 
     public void otherChangeDetailData(ApplyChange applyChange,ApplyChagneDetail detail){
-
         //瀹為檯鎵瑰崟鐢熸晥鏃ユ湡
         Date applyStartTime = DateUtil.getMontageDate(applyChange.getApplyStartTime(),1);
-
         //鏌ヨ鍑忎繚浜哄憳鏄惁瀛樺湪 鍐茬獊鐨� 淇濆崟鏄庣粏鏁版嵁
         if(applyDetailJoinMapper.selectCount(new QueryWrapper<ApplyDetail>()
                 .lambda()
@@ -991,6 +1042,17 @@
 
         }
 
+        Member member = memberMapper.selectById(detail.getMemberId());
+        if(Objects.isNull(member)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鍛樺伐鏁版嵁");
+        }
+        member.setApplyId(applyChange.getApplyId());
+        member.setDuId(detail.getDuId());
+        member.setWorktypeId(detail.getWorktypeId());
+        member.setStartTime(detail.getStartTime());
+        member.setEndTime(detail.getEndTime());
+        memberMapper.updateById(member);
+
 
 
 

--
Gitblit v1.9.3