From 5725e0d4bcbc3aa721c1672f43d3e5fa6f06bb2b Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期三, 03 四月 2024 14:02:56 +0800
Subject: [PATCH] git ch

---
 server/service/src/main/java/com/doumee/service/business/impl/UnionChangeServiceImpl.java |   70 ++++++++++++++++++++++++++++++-----
 1 files changed, 60 insertions(+), 10 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 d113bb0..febf8b6 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
@@ -1,5 +1,6 @@
 package com.doumee.service.business.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.doumee.biz.system.SystemDictDataBiz;
 import com.doumee.core.annotation.excel.ExcelExporter;
 import com.doumee.core.constants.ResponseStatus;
@@ -11,13 +12,11 @@
 import com.doumee.core.utils.DateUtil;
 import com.doumee.core.utils.Utils;
 import com.doumee.dao.business.*;
-import com.doumee.dao.business.dto.SaveUnionApplyDTO;
-import com.doumee.dao.business.dto.SaveUnionChangeDTO;
-import com.doumee.dao.business.dto.SmsCheckDTO;
-import com.doumee.dao.business.dto.UnionChangeBXDDTO;
+import com.doumee.dao.business.dto.*;
 import com.doumee.dao.business.join.*;
 import com.doumee.dao.business.model.*;
 import com.doumee.dao.business.vo.CountCyclePriceVO;
+import com.doumee.dao.system.model.SystemUser;
 import com.doumee.service.business.SmsEmailService;
 import com.doumee.service.business.UnionChangeService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -92,6 +91,11 @@
     @Autowired
     private MultifileMapper multifileMapper;
 
+    @Autowired
+    private ApplyLogMapper applyLogMapper;
+
+    @Autowired
+    private ApplyLogJoinMapper applyLogJoinMapper;
     @Override
     public Integer create(UnionChange unionChange) {
         unionChangeMapper.insert(unionChange);
@@ -157,6 +161,23 @@
                         .eq(UnionChange::getId,id)
                         .last(" limit 1 ")
         );
+
+        if(!Objects.isNull(unionChange)){
+            //鏌ヨ鎿嶄綔璁板綍
+            List<ApplyLog> applyLogList = applyLogJoinMapper.selectJoinList(ApplyLog.class,
+                    new MPJLambdaWrapper<ApplyLog>()
+                            .selectAll(ApplyLog.class)
+                            .selectAs(SystemUser::getRealname,ApplyLog::getCreatorName)
+                            .selectAs(Company::getName,ApplyLog::getCompanyName)
+                            .selectAs(SystemUser::getType,ApplyLog::getCreatorType)
+                            .leftJoin(SystemUser.class,SystemUser::getId,ApplyLog::getCreator)
+                            .leftJoin(Company.class,Company::getId,SystemUser::getCompanyId)
+                            .in(ApplyLog::getObjType,Constants.ApplyLogType.getTypeList(Constants.THREE))
+                            .eq(ApplyLog::getApplyId,unionChange.getId())
+                            .orderByAsc(ApplyLog::getCreateDate)
+            );
+            unionChange.setApplyLogList(applyLogList);
+        }
         return unionChange;
     }
 
@@ -179,14 +200,15 @@
         IPage<UnionChange> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
         MPJLambdaWrapper<UnionChange> queryWrapper = new MPJLambdaWrapper<>();
         queryWrapper.selectAll(UnionChange.class);
-        queryWrapper.selectAs(UnionApply::getCode,UnionChange::getApplyCode)
+        queryWrapper.selectAs(UnionApply::getCode,UnionChange::getApplyCode);
+        queryWrapper.selectAs(Solutions::getName,UnionChange::getSolutionsName)
         .select("( select count(1) from apply_chagne_detail ad where t.id = ad.UNION_CHANGE_ID and ad.TYPE = 0  )",UnionChange::getAddNum)
         .select("( select count(1) from apply_chagne_detail ad where t.id = ad.UNION_CHANGE_ID and ad.TYPE = 1  )",UnionChange::getDelNum)
         .select("( select count(1) from apply_chagne_detail ad where t.id = ad.UNION_CHANGE_ID and ad.TYPE = 2  )",UnionChange::getChangeNum);
         queryWrapper.leftJoin(UnionApply.class,UnionApply::getId,UnionChange::getUnionApplyId);
         queryWrapper.leftJoin(Solutions.class,Solutions::getId,UnionApply::getSolutionId);
         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
-        if(user.getType().equals(Constants.TWO)){
+        if(Constants.equalsInteger(user.getType(),Constants.TWO)){
             queryWrapper.eq(UnionChange::getShopId, pageWrap.getModel().getShopId());
         }
         Utils.MP.blankToNull(pageWrap.getModel());
@@ -289,7 +311,7 @@
                         .leftJoin(InsuranceApply.class,InsuranceApply::getId,ApplyChange::getApplyId)
                         .eq(ApplyChange::getIsdeleted, Constants.ZERO)
                         .eq(InsuranceApply::getUnionApplyId,saveUnionChangeDTO.getUnionApplyId())
-                        .eq(ApplyChange::getStatus,Constants.ApplyChangeStatus.PALTFORM_CHECK_PASS.getKey())
+                        .eq(ApplyChange::getStatus,Constants.ApplyChangeStatus.CHECHED_PASSED.getKey())
                         .eq(InsuranceApply::getStatus,Constants.InsuranceApplyStatus.UPLOAD_INSURANCE.getKey())
                         .eq(ApplyChange::getType,saveUnionChangeDTO.getBusinessType())
                         .in(ApplyChange::getId,saveUnionChangeDTO.getApplyIds())
@@ -314,12 +336,20 @@
                 .set(ApplyChange::getUnionChangeId,unionChange.getId())
                 .set(ApplyChange::getCheckDate,new Date())
                 .set(ApplyChange::getCheckUserId,user.getId())
+                .set(ApplyChange::getStatus,Constants.ApplyChangeStatus.WTB_TOUBAOING.getKey())
                 .in(ApplyChange::getId,saveUnionChangeDTO.getApplyIds())
         );
 
         applyChagneDetailJoinMapper.update(null,new UpdateWrapper<ApplyChagneDetail>().lambda()
                 .set(ApplyChagneDetail::getUnionChangeId,unionChange.getId())
                 .in(ApplyChagneDetail::getApplyId,saveUnionChangeDTO.getApplyIds()));
+
+
+        Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_HBD_UPLOAD;
+        ApplyLog log = new ApplyLog(unionChange,applyLogType.getName(), null
+                ,unionChange.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(unionChange));
+        applyLogMapper.insert(log);
+
         return unionChange.getId();
     }
 
@@ -330,16 +360,21 @@
 
     /**
      * 鍙栨秷淇濆崟鍚堝苟
-     * @param id
+     * @param closeDTO
      */
     @Override
     @Transactional(rollbackFor = {Exception.class,BusinessException.class})
-    public void cancelMerge(Integer id){
+    public void cancelMerge(CloseDTO closeDTO){
+        if(Objects.isNull(closeDTO)
+                ||Objects.isNull(closeDTO.getId())
+                ||StringUtils.isBlank(closeDTO.getReason())){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
         if(user.getType().equals(Constants.TWO)){
             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"闈炲晢鎴风敤鎴凤紝鏃犳硶杩涜璇ユ搷浣滐紒");
         }
-        UnionChange unionChange = unionChangeMapper.selectById(id);
+        UnionChange unionChange = unionChangeMapper.selectById(closeDTO.getId());
         if(Objects.isNull(unionChange)||!Constants.equalsInteger(unionChange.getIsdeleted(),Constants.ZERO)){
             throw new BusinessException(ResponseStatus.DATA_EMPTY);
         }
@@ -357,6 +392,7 @@
                 .set(ApplyChange::getUnionChangeId,null)
                 .set(ApplyChange::getCheckDate,new Date())
                 .set(ApplyChange::getCheckUserId,user.getId())
+                .set(ApplyChange::getStatus,Constants.ApplyChangeStatus.CHECHED_PASSED.getKey())
                 .in(ApplyChange::getUnionChangeId,unionChange.getId())
         );
 
@@ -368,6 +404,14 @@
                 .set(UnionChange::getStatus,Constants.UnionApplyStatus.CLOSE.getKey())
                 .eq(UnionChange::getId,unionChange.getId())
         );
+
+        Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_HBD_UPLOAD;
+        String info =applyLogType.getInfo();
+        info = info.replace("${param}", closeDTO.getReason());
+        ApplyLog log = new ApplyLog(unionChange,applyLogType.getName(), info
+                ,unionChange.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(unionChange));
+        applyLogMapper.insert(log);
+
     }
 
 
@@ -589,6 +633,12 @@
                 .set(UnionChange::getEditor,user.getId())
                 .eq(UnionChange::getId,unionChangeBXDDTO.getId())
         );
+
+
+        Constants.ApplyLogType applyLogType = Constants.ApplyLogType.CA_HBD_UPLOAD_INSURANCE;
+        ApplyLog log = new ApplyLog(unionChange,applyLogType.getName(), null
+                ,unionChange.getId(),applyLogType.getKey(),null, JSONObject.toJSONString(unionChange));
+        applyLogMapper.insert(log);
     }
 
 

--
Gitblit v1.9.3