From 0749ab9d5b50a519d958fb29bcb05187ef48c3d7 Mon Sep 17 00:00:00 2001
From: sy <sy666666>
Date: Wed, 2 Aug 2023 16:31:59 +0800
Subject: [PATCH] =?UTF-8?q?=E8=96=AA=E9=85=AC=E7=B3=BB=E7=BB=9F-=E7=A6=8F?=
 =?UTF-8?q?=E5=88=A9=E6=A1=A3=E6=A1=88=EF=BC=8C=E5=A2=9E=E9=87=8F=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=A4=84=E7=90=86=E4=B8=AD=E7=9B=B8=E5=85=B3=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=E6=B7=BB=E5=8A=A0=E5=BC=80=E5=85=B3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/SIArchivesServiceImpl.java       | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/src/com/engine/salary/service/impl/SIArchivesServiceImpl.java b/src/com/engine/salary/service/impl/SIArchivesServiceImpl.java
index 69ac06b3d..dbfde3e87 100644
--- a/src/com/engine/salary/service/impl/SIArchivesServiceImpl.java
+++ b/src/com/engine/salary/service/impl/SIArchivesServiceImpl.java
@@ -43,6 +43,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StopWatch;
+import weaver.general.BaseBean;
 import weaver.general.Util;
 import weaver.hrm.User;
 
@@ -58,6 +59,9 @@ import java.util.stream.Collectors;
  **/
 @Slf4j
 public class SIArchivesServiceImpl extends Service implements SIArchivesService {
+    private final BaseBean baseBean = new BaseBean();
+
+    private final Boolean isLog = "true".equals(baseBean.getPropValue("hrmSalary", "log"));
 
     private SIArchivesBiz siArchivesBiz = new SIArchivesBiz();
 
@@ -290,6 +294,9 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 List<InsuranceArchivesBaseInfoPO> toStayDelList = changeData.getBaseInfoUpdateTodoList().stream()
                         .filter(f -> f.getRunStatus().equals(EmployeeStatusEnum.STAY_DEL.getValue()))
                         .collect(Collectors.toList());
+                if (isLog) {
+                    log.info("福利档案-待减员明细:{}", toStayDelList);
+                }
                 if (toStayDelList.size() > 0) {
                     List<List<InsuranceArchivesBaseInfoPO>> partitionUpdateEndTime = Lists.partition(toStayDelList, 100);
                     partitionUpdateEndTime.forEach(part->{
@@ -310,7 +317,9 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 List<InsuranceArchivesBaseInfoPO> delList = changeData.getBaseInfoUpdateTodoList().stream()
                         .filter(f -> f.getDeleteType().equals(DeleteTypeEnum.DELETED.getValue()))
                         .collect(Collectors.toList());
-                log.info("福利档案-逻辑删除明细:{}", delList);
+                if (isLog) {
+                    log.info("福利档案-逻辑删除明细:{}", delList);
+                }
                 if (delList.size() > 0) {
                     for (InsuranceArchivesBaseInfoPO po : delList) {
                         getSocialSchemeMapper().deleteByEmployeeIdAndPayOrg(InsuranceArchivesSocialSchemePO.builder()
@@ -330,7 +339,9 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 sw.stop();
                 //修改福利档案基础信息
                 sw.start("增量数据中待更新数据入库");
-                log.info("福利档案-增量数据中待更新数据入库:{}", changeData.getBaseInfoUpdateTodoList());
+                if (isLog) {
+                    log.info("福利档案-增量数据中待更新数据入库明细:{}", changeData.getBaseInfoUpdateTodoList());
+                }
                 List<List<InsuranceArchivesBaseInfoPO>> partitionUpdateBase = Lists.partition(changeData.getBaseInfoUpdateTodoList(), 100);
                 partitionUpdateBase.forEach(part-> getInsuranceBaseInfoMapper().batchUpdate(part));
                 sw.stop();