处理pg数据库适配问题

1、批量新建核算记录并核算。
2、批量归档
3、批量重新核算
薪资核算：
1、批量新建核算记录并核算。
2、批量归档
3、批量重新核算
工资单：
1、批量发放
2、批量撤回
申报表：
1、批量申报

resource/WEB-INF/prop/hrmSalary.properties

@@ -1,5 +1,5 @@
 log=false
 defaultCloseNonStandard149=true
 AESEncryptScrect=990EB004A1C862721C1513AE90038C9E
-version=2.19.1.2501.01
+version=2.19.2.2501.01
 openFormulaForcedEditing=false

resource/sqlupgrade/PG/sql202410090103.sql

@@ -1,54 +1,35 @@
-alter table hrsa_bill_detail_temp add subcompany_name varchar2(200) NULL;
-/
+alter table hrsa_bill_detail_temp add subcompany_name varchar(200) NULL;
 
-alter table hrsa_bill_detail_temp add subcompany_id NUMBER null;
-/
+alter table hrsa_bill_detail_temp add subcompany_id bigint null;
 
-alter table hrsa_bill_detail_temp add department_name varchar2(200) NULL;
-/
+alter table hrsa_bill_detail_temp add department_name varchar(200) NULL;
 
-alter table hrsa_bill_detail_temp add department_id NUMBER null;
-/
+alter table hrsa_bill_detail_temp add department_id bigint null;
 
-alter table hrsa_bill_detail_temp add jobtitle_name varchar2(200) NULL;
-/
+alter table hrsa_bill_detail_temp add jobtitle_name varchar(200) NULL;
 
-alter table hrsa_bill_detail_temp add jobtitle_id NUMBER NULL;
-/
+alter table hrsa_bill_detail_temp add jobtitle_id bigint NULL;
 
-alter table hrsa_bill_detail_temp add jobcall varchar2(200) NULL;
-/
+alter table hrsa_bill_detail_temp add jobcall varchar(200) NULL;
 
-alter table hrsa_bill_detail_temp add jobcall_id NUMBER NULL;
-/
+alter table hrsa_bill_detail_temp add jobcall_id bigint NULL;
 
-alter table hrsa_bill_detail_temp add status varchar2(200) NULL;
-/
+alter table hrsa_bill_detail_temp add status varchar(200) NULL;
 
+alter table hrsa_bill_detail add subcompany_name varchar(200) NULL;
 
-alter table hrsa_bill_detail add subcompany_name varchar2(200) NULL;
-/
+alter table hrsa_bill_detail add subcompany_id bigint null;
 
-alter table hrsa_bill_detail add subcompany_id NUMBER null;
-/
+alter table hrsa_bill_detail add department_name varchar(200) NULL;
 
-alter table hrsa_bill_detail add department_name varchar2(200) NULL;
-/
+alter table hrsa_bill_detail add department_id bigint null;
 
-alter table hrsa_bill_detail add department_id NUMBER null;
-/
+alter table hrsa_bill_detail add jobtitle_name varchar(200) NULL;
 
-alter table hrsa_bill_detail add jobtitle_name varchar2(200) NULL;
-/
+alter table hrsa_bill_detail add jobtitle_id bigint NULL;
 
-alter table hrsa_bill_detail add jobtitle_id NUMBER NULL;
-/
+alter table hrsa_bill_detail add jobcall varchar(200) NULL;
 
-alter table hrsa_bill_detail add jobcall varchar2(200) NULL;
-/
+alter table hrsa_bill_detail add jobcall_id bigint NULL;
 
-alter table hrsa_bill_detail add jobcall_id NUMBER NULL;
-/
-
-alter table hrsa_bill_detail add status varchar2(200) NULL;
-/
+alter table hrsa_bill_detail add status varchar(200) NULL;

resource/sqlupgrade/PG/sql202501150103.sql

@@ -1,41 +1,42 @@
-CREATE TABLE hrsa_hrm_snapshot  (
-                                    ID bigint(0) NOT NULL,
+CREATE TABLE hrsa_hrm_snapshot
+(
+                                    ID bigint NOT NULL,
                                     snapshot_time timestamp,
-                                    employee_id bigint(0),
+                                    employee_id bigint,
                                     loginid varchar(100),
                                     LASTNAME varchar(60),
                                     SEX char(1),
                                     BIRTHDAY char(10) ,
-                                    NATIONALITY int(0) ,
+                                    NATIONALITY int ,
                                     MARITALSTATUS char(1) ,
                                     TELEPHONE varchar(60),
                                     MOBILE varchar(60) ,
                                     MOBILECALL varchar(60) ,
                                     EMAIL varchar(60),
-                                    LOCATIONID int(0),
+                                    LOCATIONID int,
                                     WORKROOM varchar(60),
                                     HOMEADDRESS varchar(100),
                                     RESOURCETYPE char(1) ,
                                     STARTDATE char(10) ,
                                     ENDDATE char(10),
-                                    JOBTITLE int(0) ,
+                                    JOBTITLE int ,
                                     JOBTITLENAME varchar(200) ,
                                     JOBACTIVITYDESC varchar(200),
-                                    JOBLEVEL int(0) ,
-                                    SECLEVEL int(0) ,
-                                    DEPARTMENTID int(0) ,
+                                    JOBLEVEL int ,
+                                    SECLEVEL int ,
+                                    DEPARTMENTID int ,
                                     DEPARTMENTNAME varchar(200) ,
-                                    SUBCOMPANYID1 int(0) ,
+                                    SUBCOMPANYID1 int ,
                                     SUBCOMPANYNAME varchar(200) ,
-                                    COSTCENTERID int(0) ,
-                                    MANAGERID int(0) ,
-                                    ASSISTANTID int(0),
-                                    BANKID1 int(0) ,
+                                    COSTCENTERID int ,
+                                    MANAGERID int ,
+                                    ASSISTANTID int,
+                                    BANKID1 int ,
                                     ACCOUNTID1 varchar(100) ,
                                     LASTLOGINDATE char(10) ,
                                     CERTIFICATENUM varchar(60) ,
                                     NATIVEPLACE varchar(100) ,
-                                    EDUCATIONLEVEL int(0) ,
+                                    EDUCATIONLEVEL int ,
                                     BEMEMBERDATE char(10) ,
                                     BEPARTYDATE char(10) ,
                                     WORKCODE varchar(60) ,
@@ -44,8 +45,8 @@ CREATE TABLE hrsa_hrm_snapshot  (
                                     RESIDENTPLACE varchar(200) ,
                                     POLICY varchar(30) ,
                                     DEGREE varchar(30) ,
-                                    USEKIND int(0) ,
-                                    JOBCALL int(0) ,
+                                    USEKIND int ,
+                                    JOBCALL int ,
                                     jobcallname varchar(200) ,
                                     ACCUMFUNDACCOUNT varchar(30),
                                     BIRTHPLACE varchar(60) ,
@@ -54,14 +55,14 @@ CREATE TABLE hrsa_hrm_snapshot  (
                                     RESIDENTPOSTCODE varchar(60) ,
                                     EXTPHONE varchar(50) ,
                                     MANAGERSTR varchar(500),
-                                    STATUS int(0) ,
+                                    STATUS int ,
                                     FAX varchar(60) ,
                                     ISLABOUUNION char(1),
                                     TEMPRESIDENTNUMBER varchar(60),
                                     PROBATIONENDDATE char(10),
-                                    COUNTRYID int(0) ,
-                                    ACCOUNTTYPE int(0) ,
-                                    BELONGTO int(0) ,
+                                    COUNTRYID int ,
+                                    ACCOUNTTYPE int ,
+                                    BELONGTO int ,
                                     ACCOUNTNAME varchar(200) ,
                                     companystartdate varchar(10),
                                     workstartdate varchar(10) ,

resource/wiki/人员生成不了档案.sql

@@ -6,5 +6,5 @@ and employee_id not in
 where tax_agent_id =扣缴义务人id and delete_type = 0)
 
 
-update hrsa_tax_agent_emp set delete_type = 3
+update hrsa_tax_agent_emp set delete_type = 3  where  delete_type = 0
 where tax_agent_id=扣缴义务人id and delete_type = 0 and employee_id not in (select employee_id from hrsa_salary_archive where tax_agent_id =扣缴义务人id and delete_type = 0)

resource/wiki/删除档案.txt

@@ -18,7 +18,8 @@ update  hrsa_salary_archive set delete_type=3 where tax_agent_id=扣缴义务人
 
 
 二、删除停薪员工档案
-update hrsa_salary_archive   set delete_type=3 where run_status  in ('STOP_FROM_PENDING','STOP_FROM_SUSPEND')
+update hrsa_salary_archive   set delete_type=3 where delete_type=0      and run_status  in ('STOP_FROM_PENDING','STOP_FROM_SUSPEND')
+update  hrsa_salary_archive_item set delete_type=3 where delete_type=0
 
 二、删除停薪员工社保档案
 update hrsa_insurance_base_info set delete_type=3 where run_status  in ('4','5')
@@ -28,10 +29,10 @@ update hrsa_insurance_base_info set delete_type=3 where run_status  in ('4','5')
 
 
 --删除社保福利档案
-update hrsa_insurance_base_info set delete_type=3  WHERE employee_id = ? and payment_organization =?
-update hrsa_social_archives set delete_type=3  WHERE employee_id = ? and payment_organization =?
-update hrsa_fund_archives set delete_type=3  WHERE employee_id = ? and payment_organization =?
-update hrsa_other_archives set delete_type=3  WHERE employee_id = ? and payment_organization =?
+update hrsa_insurance_base_info set delete_type=3  WHERE delete_type=0 and  employee_id = ? and payment_organization =?
+update hrsa_social_archives set delete_type=3  WHERE delete_type=0 and  employee_id = ? and payment_organization =?
+update hrsa_fund_archives set delete_type=3  WHERE delete_type=0 and  employee_id = ? and payment_organization =?
+update hrsa_other_archives set delete_type=3  WHERE delete_type=0 and  employee_id = ? and payment_organization =?
 
 -- 删除薪资档案
 update hrsa_salary_archive  set delete_type=3  where employee_id = ? and tax_agent_id=?
@@ -45,4 +46,13 @@ update hrsa_other_archives set delete_type=3;
 update hrsa_tax_agent_emp set delete_type=3;
 
 
+-- 删除核算记录
+update hrsa_salary_acct_record set delete_type=3 where delete_type=0 and id= 核算记录id;
+update hrsa_salary_acct_emp   set delete_type=3 where delete_type=0 and salary_acct_record_id=核算记录id;
+update hrsa_salary_acct_result set delete_type=3 where delete_type=0 and salary_acct_record_id = 核算记录id;
+
+--删除工资单信息
+update hrsa_salary_send set delete_type=3 where delete_type=0 and  salary_accounting_id = 核算记录id;
+update hrsa_salary_send_info set delete_type=3 where delete_type=0 and salary_acct_record_id = 核算记录id;
+
 

src/com/engine/salary/entity/salaryBill/bo/SalaryBillBO.java

@@ -267,7 +267,7 @@ public class SalaryBillBO {
             }
             Util_Message.store(messageBean);
         } catch (IOException e) {
-            log.error("消息发送失败",e);
+            log.error("消息发送失败", e);
         }
     }
 
@@ -649,7 +649,8 @@ public class SalaryBillBO {
                     } else {
                         for (Object keyName : e.keySet()) {
                             if ((salaryItem.getId() + SalaryArchiveConstant.DYNAMIC_SUFFIX).equals(keyName.toString())) {
-                                boolean isHide = (isHideNull && StringUtils.isEmpty(e.getOrDefault(keyName.toString(), StringUtils.EMPTY).toString()))
+                                String itemValue = Util.null2String(e.get(keyName.toString()));
+                                boolean isHide = (isHideNull && StringUtils.isEmpty(itemValue))
                                         ||
                                         (isHideZero && NumberUtils.isCreatable(e.getOrDefault(keyName.toString(), "0").toString())
                                                 && BigDecimal.ZERO.compareTo(new BigDecimal(e.getOrDefault(keyName.toString(), "0").toString())) == 0);
@@ -660,7 +661,7 @@ public class SalaryBillBO {
                                     emailContent.append("</th>");
 
                                     emailContent.append("<td style=\"padding: 16px 24px;display: table-cell;flex: 1;color: #000000d9;font-size: 12px;line-height: 1.5715;word-break: break-word;overflow-wrap: break-word;border-collapse: collapse;border: 1px solid rgba(0,0,0,.06);\">");
-                                    emailContent.append(e.get(keyName.toString()));
+                                    emailContent.append(itemValue.replaceAll("null", ""));
                                     emailContent.append("</td>");
                                 }
                                 break;
@@ -729,7 +730,8 @@ public class SalaryBillBO {
                     SalaryTemplateSalaryItemListDTO salaryItem = itemPartition.get(i);
                     for (Object keyName : e.keySet()) {
                         if ((salaryItem.getId() + SalaryArchiveConstant.DYNAMIC_SUFFIX).equals(keyName.toString())) {
-                            boolean isHide = (isHideNull && StringUtils.isEmpty(e.getOrDefault(keyName.toString(), StringUtils.EMPTY).toString()))
+                            String itemValue = Util.null2String(e.get(keyName.toString()));
+                            boolean isHide = (isHideNull && StringUtils.isEmpty(itemValue))
                                     ||
                                     (isHideZero && NumberUtils.isCreatable(e.getOrDefault(keyName.toString(), "0").toString())
                                             && BigDecimal.ZERO.compareTo(new BigDecimal(e.getOrDefault(keyName.toString(), "0").toString())) == 0);
@@ -740,7 +742,7 @@ public class SalaryBillBO {
                                 emailContent.append("</th>");
 
                                 emailContent.append("<td style=\"padding: 16px 24px;display: table-cell;flex: 1;color: #000000d9;font-size: 12px;line-height: 1.5715;word-break: break-word;overflow-wrap: break-word;border-collapse: collapse;border: 1px solid rgba(0,0,0,.06);\">");
-                                emailContent.append(e.get(keyName.toString()));
+                                emailContent.append(itemValue.replaceAll("null", ""));
                                 emailContent.append("</td>");
                             }
                             break;
@@ -867,7 +869,7 @@ public class SalaryBillBO {
         if ("text".equals(wmClassify)) {
             wmTextFieldIds = (List<String>) salaryBillWatermark.getWmSetting().getOrDefault("wmSelectedFieldIds", Collections.emptyList());
 
-            List<String> empFields = Arrays.asList(HRM_Name, HRM_Num, HRM_Mobile, HRM_Email, HRM_CurrentOperatorId, HRM_Department);
+            List<String> empFields = Arrays.asList(HRM_Name, HRM_Num, HRM_Mobile, HRM_Email, HRM_CurrentOperatorId, HRM_Department, HRM_SecondDepartment);
             if (wmTextFieldIds.contains(HRM_SecondDepartment)) {
                 // 需要查分部
                 salaryBillWatermark.getWmSetting().put("needQuerySubDepart", true);

src/com/engine/salary/entity/salaryBill/param/SalarySendBatParam.java

@@ -0,0 +1,27 @@
+package com.engine.salary.entity.salaryBill.param;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * 工资单批量操作参数
+ * <p>Copyright: Copyright (c) 2024</p>
+ * <p>Company: 泛微软件</p>
+ *
+ * @author qiantao
+ * @version 1.0
+ **/
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class SalarySendBatParam {
+
+//    工资单发放Id
+    private List<Long> salarySendIds;
+
+}

src/com/engine/salary/entity/salaryacct/bo/SalaryAcctConsolidatedTaxBO.java

@@ -1,5 +1,6 @@
 package com.engine.salary.entity.salaryacct.bo;
 
+import cn.hutool.core.util.StrUtil;
 import com.engine.salary.constant.TaxDeclarationDataIndexConstant;
 import com.engine.salary.entity.salaryacct.po.SalaryAcctResultPO;
 import com.engine.salary.entity.salaryitem.po.SalaryItemPO;
@@ -73,6 +74,9 @@ public class SalaryAcctConsolidatedTaxBO {
                     .filter(e -> Objects.equals(e.getSalaryItemId(), optional.get()))
                     .map(e -> SalaryEntityUtil.empty2Zero(e.getResultValue()))
                     .reduce(BigDecimal.ZERO, BigDecimal::add);
+            if (StrUtil.isBlank(resultValue)) {
+                resultValue = "0.00";
+            }
             return new BigDecimal(resultValue).add(income).toPlainString();
         }
         // 个税调差为0
@@ -98,6 +102,9 @@ public class SalaryAcctConsolidatedTaxBO {
                         .map(e -> SalaryEntityUtil.empty2Zero(e.getResultValue()))
                         .reduce(BigDecimal.ZERO, BigDecimal::add);
             }
+            if (StrUtil.isBlank(resultValue)) {
+                resultValue = "0.00";
+            }
             return new BigDecimal(resultValue).add(refundedOrSupplementedTax).subtract(taxAdjustment).toPlainString();
         }
         return resultValue;

src/com/engine/salary/entity/salaryacct/param/SalaryAcctBatParam.java

@@ -0,0 +1,34 @@
+package com.engine.salary.entity.salaryacct.param;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 批量操作参数
+ * <p>Copyright: Copyright (c) 2024</p>
+ * <p>Company: 泛微软件</p>
+ *
+ * @author qiantao
+ * @version 1.0
+ **/
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class SalaryAcctBatParam {
+
+    //薪资所属月
+    private Date salaryMonth;
+    //薪资账套id
+    private List<Long> salarySobIds;
+    //备注
+    private String description;
+
+
+    private List<Long> salaryAcctRecordIds;
+}

src/com/engine/salary/entity/salaryacct/param/SalaryAcctCalculateParam.java

@@ -20,7 +20,7 @@ import java.util.Collection;
 @Builder
 @NoArgsConstructor
 @AllArgsConstructor
-public class SalaryAcctCalculateParam {
+public class SalaryAcctCalculateParam  {
 
    //核算人员的id,不是employeeId而是salaryAcctEmpId
     private Collection<Long> ids;

src/com/engine/salary/entity/salarysob/bo/SalarySobItemAggregateBO.java

@@ -144,7 +144,7 @@ public class SalarySobItemAggregateBO {
                             .canEdit(openFormulaForcedEditing || Objects.equals(salaryItemPO.getCanEdit(), 1))
                             .canDelete(openFormulaForcedEditing || salaryItemPO.getCanDelete() == null || Objects.equals(salaryItemPO.getCanDelete(), 1))
                             .width(salaryItemPO.getWidth())
-                            .defaultValue(salaryItemPO.getDefaultValue())
+                            .defaultValue(salarySobItemPO.getDefaultValue())
                             .build());
                 }
             }

src/com/engine/salary/entity/siaccount/param/AccountBatParam.java

@@ -0,0 +1,40 @@
+package com.engine.salary.entity.siaccount.param;
+
+
+import com.engine.salary.util.valid.DataCheck;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class AccountBatParam {
+
+    //账单月份")
+    //@NotNull
+    @DataCheck(require = true,message = "账单月份不能为空")
+    private String billMonth;
+
+    //备注")
+    //@Length(max = 60)
+    @DataCheck(max = 60,message = "备注长度不能超过60个字符")
+    private String remarks;
+
+
+    /**
+     * 个税扣缴义务人id
+     */
+    @DataCheck(require = true,message = "个税扣缴义务人不能为空")
+    private List<Long> paymentOrganizations;
+
+
+
+    private List<Long> ids;
+
+}

src/com/engine/salary/entity/taxdeclaration/bo/TaxDeclarationBO.java

@@ -722,6 +722,7 @@ public class TaxDeclarationBO {
     private static String findStringValue(String fieldCode, Map<Long, List<SalaryAcctResultPO>> resultMap, Map<String, Long> salaryItemMap) {
         return resultMap.getOrDefault(salaryItemMap.getOrDefault(fieldCode, 0L), Collections.emptyList()).stream()
                 .map(SalaryAcctResultPO::getResultValue)
+                .filter(Objects::nonNull)
                 .findFirst().orElse("");
     }
 

src/com/engine/salary/entity/taxdeclaration/dto/TaxDeclarationListDTO.java

@@ -37,6 +37,10 @@ public class TaxDeclarationListDTO {
     @TableTitle(title = "薪资类型", dataIndex = "incomeCategory", key = "incomeCategory")
     private String incomeCategory;
 
+    @JsonFormat(pattern = "yyyy-MM", timezone = "GMT+8")
+    @TableTitle(title = "税款所属期", dataIndex = "taxCycle", key = "taxCycle")
+    private Date taxCycle;
+
     @JsonFormat(pattern = "yyyy-MM", timezone = "GMT+8")
     @TableTitle(title = "薪资所属月", dataIndex = "salaryMonth", key = "salaryMonth")
     private Date salaryMonth;
@@ -47,10 +51,6 @@ public class TaxDeclarationListDTO {
     @TableTitle(title = "个税扣缴义务人", dataIndex = "taxAgentName", key = "taxAgentName")
     private String taxAgentName;
 
-    @JsonFormat(pattern = "yyyy-MM", timezone = "GMT+8")
-    @TableTitle(title = "税款所属期", dataIndex = "taxCycle", key = "taxCycle")
-    private Date taxCycle;
-
     //@TableTitle(title = "操作人id", dataIndex = "operateEmployeeId", key = "operateEmployeeId")
     private Long operateEmployeeId;
 

src/com/engine/salary/entity/taxdeclaration/param/TaxDeclarationBatParam.java

@@ -0,0 +1,54 @@
+package com.engine.salary.entity.taxdeclaration.param;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.YearMonth;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 生成个税申报表参数
+ * <p>Copyright: Copyright (c) 2022</p>
+ * <p>Company: 泛微软件</p>
+ *
+ * @author qiantao
+ * @version 1.0
+ **/
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class TaxDeclarationBatParam {
+
+    /**
+     * 个税申报id
+     */
+    private Long taxDeclarationId;
+
+    /**
+     * 薪资所属月
+     */
+    private YearMonth salaryMonth;
+
+    /**
+     * 个税扣缴义务人
+     */
+    private List<Long> taxAgentIds;
+
+    /**
+     * 备注
+     */
+    private String description;
+
+    private String salaryMonthStr;
+
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+    private Date taxCycle;
+
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+    private Date salaryDate;
+}

src/com/engine/salary/entity/taxdeclaration/param/TaxDeclarationListQueryParam.java

@@ -1,9 +1,14 @@
 package com.engine.salary.entity.taxdeclaration.param;
 
 import com.engine.salary.common.BaseQueryParam;
-import lombok.*;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
 
-import java.time.YearMonth;
+
+import java.util.Date;
 
 /**
  * 个税申报记录查询条件
@@ -20,12 +25,13 @@ import java.time.YearMonth;
 public class TaxDeclarationListQueryParam extends BaseQueryParam {
 
     //薪资所属月范围起点
-    private YearMonth fromSalaryMonth;
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+    private Date fromSalaryMonth;
 
-   //薪资所属月范围终点
-    private YearMonth endSalaryMonth;
+    //薪资所属月范围终点
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+    private Date endSalaryMonth;
 
-    private String fromSalaryMonthStr;
-
-    private String endSalaryMonthStr;
+    //个税扣缴义务人菜单")
+    private String taxAgentName;
 }

src/com/engine/salary/entity/taxdeclaration/po/TaxDeclarationPO.java

@@ -86,6 +86,13 @@ public class TaxDeclarationPO {
     LocalDateRange salaryMonths;
 
 
+    //"开始日期
+    private Date taxCycleFromDate;
+
+    //结束日期
+    private Date taxCycleEndDate;
+
+
 
     private Collection<Long> taxAgentIds;
 }

src/com/engine/salary/mapper/archive/SalaryArchiveMapper.xml

@@ -620,9 +620,7 @@
             </trim>
             <trim prefix="pay_end_date =case" suffix="end,">
                 <foreach collection="collection" item="item" index="index">
-                    <if test="item.payEndDate!=null">
-                        when id=#{item.id} then #{item.payEndDate}
-                    </if>
+                    when id=#{item.id} then #{item.payEndDate}
                 </foreach>
             </trim>
             <trim prefix="update_time =case" suffix="end,">
@@ -650,9 +648,7 @@
                 <if test="item.payStartDate != null">
                     pay_start_date=#{item.payStartDate},
                 </if>
-                <if test="item.payEndDate != null">
                     pay_end_date=#{item.payEndDate},
-                </if>
             </set>
             WHERE id = #{item.id} AND delete_type = 0
 

src/com/engine/salary/mapper/datacollection/EmployMapper.xml

@@ -11,6 +11,7 @@
                e.workcode,
                e.certificatenum as idNo,
                e.accounttype as accountType,
+               e.sex as sex,
                'false' as extEmp
         from hrmresource e
                  left join hrmdepartment d on e.departmentid = d.id
@@ -21,6 +22,7 @@
     <select id="getEmployeeByIds" resultType="com.engine.salary.entity.datacollection.DataCollectionEmployee">
         select e.id as employeeId,
         e.lastname as username,
+        e.sex as sex,
         e.certificatenum as idNo,
         e.status as status,
         e.workcode as workcode,
@@ -41,6 +43,7 @@
     <select id="getEmployeeByIdsIncludeAccountType" resultType="com.engine.salary.entity.datacollection.DataCollectionEmployee">
         select e.id as employeeId,
         e.lastname as username,
+        e.sex as sex,
         e.certificatenum as idNo,
         e.status as status,
         e.workcode as workcode,
@@ -122,6 +125,7 @@
         select e.id as employeeId,
         e.lastname as username,
         e.status as status,
+        e.sex as sex,
         e.certificatenum as idNo,
         e.workcode as workcode,
         d.departmentname as departmentName,
@@ -228,6 +232,7 @@
         select e.id               as employeeId,
                e.lastname         as username,
                e.status           as status,
+               e.sex as sex,
                e.certificatenum   as idNo,
                e.workcode         as workcode,
                d.departmentname   as departmentName,
@@ -282,6 +287,7 @@
                e.lastname         as username,
                e.status           as status,
                e.workcode         as workcode,
+               e.sex as sex,
                e.certificatenum   as idNo,
                e.companystartdate as companystartdate,
                e.mobile           as mobile,
@@ -303,6 +309,7 @@
                e.status           as status,
                e.workcode         as workcode,
                e.certificatenum   as idNo,
+               e.sex as sex,
                e.companystartdate as companystartdate,
                e.mobile           as mobile,
                e.accounttype as accountType,
@@ -323,6 +330,7 @@
                e.status           as status,
                e.workcode         as workcode,
                e.certificatenum   as idNo,
+               e.sex as sex,
                e.companystartdate as companystartdate,
                e.mobile           as mobile,
                e.departmentid     as departmentId,
@@ -486,6 +494,7 @@
                e.lastname         as username,
                e.status           as status,
                e.certificatenum   as idNo,
+               e.sex as sex,
                e.workcode         as workcode,
                e.companystartdate as companystartdate,
                e.mobile           as mobile,
@@ -561,6 +570,7 @@
         e.lastname as username,
         e.status as status,
         e.certificatenum as idNo,
+        e.sex as sex,
         e.workcode as workcode,
         d.departmentname as departmentName,
         d.id as departmentId,

src/com/engine/salary/mapper/salarybill/SalaryBillItemNameMapper.xml

@@ -290,7 +290,7 @@
             </trim>
             <trim prefix="update_time = case" suffix="end,">
                 <foreach collection="collection" item="item" index="index">
-                    WHEN id = #{item.id} THEN #{item.updateTime}
+                    WHEN id = #{item.id} THEN #{item.updateTime,jdbcType=TIMESTAMP}
                 </foreach>
             </trim>
         </trim>

src/com/engine/salary/mapper/salarybill/SalarySendInfoMapper.xml

@@ -632,7 +632,7 @@
         <if test="param.startSalaryMonth != null">
             AND t1.salary_month >= #{param.startSalaryMonth}
         </if>
-        ORDER BY t1.id DESC
+        ORDER BY t1.salary_month DESC
     </select>
 
 

src/com/engine/salary/mapper/salarysob/SalarySobEmpFieldMapper.xml

@@ -370,7 +370,7 @@
             </trim>
             <trim prefix="update_time = case" suffix="end,">
                 <foreach collection="collection" item="item" index="index">
-                    WHEN id = #{item.id} THEN #{item.updateTime}
+                    WHEN id = #{item.id} THEN #{item.updateTime,jdbcType=TIMESTAMP}
                 </foreach>
             </trim>
         </trim>

src/com/engine/salary/mapper/siarchives/InsuranceBaseInfoMapper.xml

@@ -367,7 +367,7 @@
             </trim>
             <trim prefix="update_time = case" suffix="end,">
                 <foreach collection="collection" item="item" index="index">
-                    WHEN id = #{item.id} THEN #{item.updateTime}
+                    WHEN id = #{item.id} THEN #{item.updateTime,jdbcType=TIMESTAMP}
                 </foreach>
             </trim>
             <trim prefix="delete_type = case" suffix="end,">

src/com/engine/salary/mapper/siarchives/SocialSchemeMapper.xml

@@ -377,7 +377,7 @@
         WHERE
         1=1
         AND base.delete_type = 0
-        AND base.employee_type is null
+        AND (base.employee_type is null or base.employee_type = 0)
         <include refid="condition"></include>
         <if test="param.orderRule != null">
             ORDER BY ${param.orderRule.orderRule} ${param.orderRule.ascOrDesc}

src/com/engine/salary/mapper/taxdeclaration/TaxDeclarationMapper.xml

@@ -61,6 +61,12 @@
         <if test="salaryMonths != null and salaryMonths.endDate != null">
             AND salary_month <![CDATA[ <= ]]> #{salaryMonths.endDate}
         </if>
+        <if test="taxCycleFromDate != null">
+            AND tax_cycle <![CDATA[ >= ]]> #{taxCycleFromDate}
+        </if>
+        <if test="taxCycleEndDate != null">
+            AND tax_cycle <![CDATA[ <= ]]> #{taxCycleEndDate}
+        </if>
         <if test="taxAgentIds != null and taxAgentIds.size()>0">
             AND tax_agent_id IN
             <foreach collection="taxAgentIds" open="(" item="id" separator="," close=")">

src/com/engine/salary/report/entity/param/SalaryStatisticsDataPerspectiveQueryParam.java

@@ -45,6 +45,9 @@ public class SalaryStatisticsDataPerspectiveQueryParam extends BaseQueryParam {
     //个税扣缴义务人配置
     private List<Long> taxAgent;
 
+    @JsonIgnore
+    private List<Long> salarySob;
+
     @JsonIgnore
     //收入所得项目配置
     private List<Integer> incomeCategory;

src/com/engine/salary/report/service/impl/SalaryStatisticsReportServiceImpl.java

@@ -469,12 +469,21 @@ public class SalaryStatisticsReportServiceImpl extends Service implements Salary
         if (reportPO.getTaxAgentSetting() != null) {
             param.setTaxAgent(((List<Map>) JSON.parseArray(reportPO.getTaxAgentSetting(), Map.class)).stream().map(m -> Long.valueOf(m.get(key).toString())).collect(Collectors.toList()));
         }
+        if (reportPO.getSalarySobSetting() != null) {
+            param.setSalarySob(((List<Map>) JSON.parseArray(reportPO.getSalarySobSetting(), Map.class)).stream().map(m -> Long.valueOf(m.get(key).toString())).collect(Collectors.toList()));
+        }
         if (reportPO.getSubCompanySetting() != null) {
             param.setSubCompany(((List<Map>) JSON.parseArray(reportPO.getSubCompanySetting(), Map.class)).stream().map(m -> Long.valueOf(m.get(key).toString())).collect(Collectors.toList()));
         }
         if (reportPO.getDepartSetting() != null) {
             param.setDepart(((List<Map>) JSON.parseArray(reportPO.getDepartSetting(), Map.class)).stream().map(m -> Long.valueOf(m.get(key).toString())).collect(Collectors.toList()));
         }
+        if (reportPO.getPositionSetting() != null) {
+            param.setPosition(((List<Map>) JSON.parseArray(reportPO.getPositionSetting(), Map.class)).stream().map(m -> Long.valueOf(m.get(key).toString())).collect(Collectors.toList()));
+        }
+        if (reportPO.getStatusSetting() != null) {
+            param.setStatus(((List<Map>) JSON.parseArray(reportPO.getStatusSetting(), Map.class)).stream().map(m -> m.get(key).toString()).collect(Collectors.toList()));
+        }
         if (reportPO.getEmployeeSetting() != null) {
             param.setEmployee(((List<Map>) JSON.parseArray(reportPO.getEmployeeSetting(), Map.class)).stream().map(m -> Long.valueOf(m.get(key).toString())).collect(Collectors.toList()));
         }
@@ -521,7 +530,7 @@ public class SalaryStatisticsReportServiceImpl extends Service implements Salary
             throw new SalaryRunTimeException("该维度值中无数据！");
         }
         // 同一个人放在一起
-        listByDimensionValue = listByDimensionValue.stream().sorted(Comparator.comparing(SalaryAcctEmployeePO::getEmployeeId)).collect(Collectors.toList());
+        listByDimensionValue = listByDimensionValue.stream().sorted((a,b)-> b.getSalaryMonth().compareTo(a.getSalaryMonth())).collect(Collectors.toList());
         List<SalaryAcctEmployeePO> salaryAcctEmployeePOList = SalaryPageUtil.subList(param.getCurrent(), param.getPageSize(), listByDimensionValue);
 
         // 获取此分页的核算人员

src/com/engine/salary/report/wrapper/SalaryStatisticsEmployeeWrapper.java

@@ -334,7 +334,7 @@ public class SalaryStatisticsEmployeeWrapper extends Service {
                     sumRow.add(Util.null2String(countResult.get(weaTableColumnGroup.getColumn())));
                 }
             } else {
-                sumRow.add(Util.null2String(countResult.get(weaTableColumnGroup.getColumn())));
+                sumRow.add("");
             }
         }
         rowList.add(sumRow);

src/com/engine/salary/service/SIAccountService.java

@@ -320,5 +320,13 @@ public interface SIAccountService {
     void cacheWelfareField(List<String> welfareNames);
 
     void cacheBalanceWelfareField(List<String> welfareNames);
+
+    void batSave(AccountBatParam param);
+
+    void batDelete(AccountBatParam param);
+
+    void batFile(AccountBatParam param);
+
+    void batSocialSecurityBenefitsRecalculate(AccountBatParam batParam);
 }
 

src/com/engine/salary/service/SalaryAcctRecordService.java

@@ -1,6 +1,7 @@
 package com.engine.salary.service;
 
 import com.engine.salary.common.LocalDateRange;
+import com.engine.salary.entity.salaryacct.param.SalaryAcctBatParam;
 import com.engine.salary.entity.salaryacct.param.SalaryAcctRecordQueryParam;
 import com.engine.salary.entity.salaryacct.param.SalaryAcctRecordSaveParam;
 import com.engine.salary.entity.salaryacct.po.SalaryAcctRecordPO;
@@ -210,4 +211,11 @@ public interface SalaryAcctRecordService {
     List<SalaryAcctRecordPO> listSome(SalaryAcctRecordPO po);
 
     void updateDate(Long id, Date updateTime);
+
+    void batSave(SalaryAcctBatParam saveParam);
+
+    void batFile(SalaryAcctBatParam param);
+
+    void batReCalculate(SalaryAcctBatParam param);
+
 }

src/com/engine/salary/service/impl/AttendQuoteDataServiceImpl.java

@@ -275,7 +275,7 @@ public class AttendQuoteDataServiceImpl extends Service implements AttendQuoteDa
                     .collect(Collectors.toList());
 
             effectiveFields.forEach(attendQuoteField -> {
-                        header.add(attendQuoteField.getFieldName());
+                        header.add(Util.formatMultiLang(attendQuoteField.getFieldName(), String.valueOf(user.getLanguage())));
                     }
             );
         }
@@ -606,7 +606,7 @@ public class AttendQuoteDataServiceImpl extends Service implements AttendQuoteDa
             header.add(SalaryI18nUtil.getI18nLabel(86317, "证件号码"));
             // 动态列
             for (AttendQuoteFieldPO attendQuoteField : attendQuoteFields) {
-                header.add(attendQuoteField.getFieldName());
+                header.add(Util.formatMultiLang(attendQuoteField.getFieldName(), String.valueOf(user.getLanguage())));
             }
             List<List<Object>> rows = new ArrayList<>();
             rows.add(header);

src/com/engine/salary/service/impl/AttendQuoteFieldServiceImpl.java

@@ -27,6 +27,7 @@ import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.BeanUtils;
+import weaver.general.Util;
 import weaver.hrm.User;
 
 import java.util.*;
@@ -292,7 +293,7 @@ public class AttendQuoteFieldServiceImpl extends Service implements AttendQuoteF
                 Map<String, String> column = columnsOptional.get();
                 updates.add(AttendQuoteFieldPO.builder()
                         .code(column.get("code"))
-                        .fieldName(column.get("name"))
+                        .fieldName(Util.formatMultiLang(column.get("name"), String.valueOf(user.getLanguage())))
                         .updateTime(now)
                         .build());
             }
@@ -312,7 +313,7 @@ public class AttendQuoteFieldServiceImpl extends Service implements AttendQuoteF
             Optional<Map<String, String>> columnsOptional = columns.stream().filter(column -> code.equals(column.get("code"))).findFirst();
             if (columnsOptional.isPresent()) {
                 Map<String, String> column = columnsOptional.get();
-                saves.add(buildAttendQuoteField(column.get("code"), column.get("name")));
+                saves.add(buildAttendQuoteField(column.get("code"), Util.formatMultiLang(column.get("name"), String.valueOf(user.getLanguage()))));
             }
         }
         if (CollectionUtils.isNotEmpty(saves)) {

src/com/engine/salary/service/impl/AttendQuoteFieldSettingServiceImpl.java

@@ -57,7 +57,7 @@ public class AttendQuoteFieldSettingServiceImpl extends Service implements Atten
     @Override
     public List<AttendQuoteFieldSettingListDTO> list(AttendQuoteFieldSettingQueryParam queryParam) {
         //同步字段
-        getAttendQuoteFieldService(user).syncAttendFields();
+//        getAttendQuoteFieldService(user).syncAttendFields();
         // 获取字段设置
         List<AttendQuoteFieldSettingPO> list = biz.getAttendQuoteFieldSetting(queryParam.getSourceType());
 

src/com/engine/salary/service/impl/RecordsBuildServiceImpl.java

@@ -93,7 +93,7 @@ public class RecordsBuildServiceImpl extends Service implements RecordsBuildServ
         Map<Long, DataCollectionEmployee> collect = employeeByIds.stream().collect(Collectors.toMap(DataCollectionEmployee::getEmployeeId, Function.identity()));
         list.forEach(item -> {
             Map<String, Object> record = new HashMap<>();
-            DataCollectionEmployee simpleEmployee = collect.get(item.getEmployeeId());
+            DataCollectionEmployee simpleEmployee = collect.get(item.getEmployeeId()) ==null?new DataCollectionEmployee():collect.get(item.getEmployeeId());
             record.put("id", item.getId());
             record.put("employeeId", item.getEmployeeId());
             record.put("billMonth", item.getBillMonth());

src/com/engine/salary/service/impl/RemoteExcelServiceImpl.java

@@ -34,6 +34,7 @@ import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import weaver.general.Util;
 import weaver.hrm.User;
 
 import java.lang.reflect.Field;
@@ -476,7 +477,7 @@ public class RemoteExcelServiceImpl extends Service implements RemoteExcelServic
         List<FormulaVar> formulaVars = fields.stream().map(e -> {
             FormulaVar formulaVar = new FormulaVar();
             formulaVar.setFieldId(referenceEnum.getValue() + SalaryFormulaFieldConstant.FIELD_ID_SEPARATOR + e.getId());
-            formulaVar.setName(e.getFieldName());
+            formulaVar.setName(Util.formatMultiLang(e.getFieldName(), String.valueOf(user.getLanguage())));
             formulaVar.setSource("" + referenceEnum.getValue());
             formulaVar.setFieldType(DataType.NUMBER);
             return formulaVar;

src/com/engine/salary/service/impl/SIAComparisonResultServiceImpl.java

@@ -172,7 +172,8 @@ public class SIAComparisonResultServiceImpl extends Service implements SIACompar
         List<InsuranceArchivesBaseInfoPO> baseInfoPOList = getInsuranceBaseInfoMapper().listAll();
         List<Long> canAccountIds = baseInfoPOList.stream()
                 .filter(f->f.getPaymentOrganization().toString().equals(queryParam.getPaymentOrganization())
-                        && (f.getRunStatus().equals(EmployeeStatusEnum.PAYING.getValue()) || f.getRunStatus().equals(EmployeeStatusEnum.STAY_DEL.getValue())))
+                        && !f.getRunStatus().equals(EmployeeStatusEnum.STAY_ADD.getValue())
+                )
                 .map(InsuranceArchivesBaseInfoPO::getEmployeeId)
                 .collect(Collectors.toList());
         accountExportPOS = accountExportPOS.stream().filter(v -> canAccountIds.contains(v.getEmployeeId())).collect(Collectors.toList());

src/com/engine/salary/service/impl/SIAccountServiceImpl.java

@@ -1736,7 +1736,7 @@ public class SIAccountServiceImpl extends Service implements SIAccountService {
 //                Long taxAgentId = 0L;
 
                 List<InsuranceAccountDetailPO> list = new ArrayList<>();
-
+                String username = (String) map.getOrDefault("姓名", "");
                 String billMonth = (String) map.getOrDefault("账单月份", "");
                 String taxAgentName = (String) map.getOrDefault("个税扣缴义务人", "");
                 String supplementaryMonth = (String) map.getOrDefault("补缴月份", "");
@@ -1840,11 +1840,11 @@ public class SIAccountServiceImpl extends Service implements SIAccountService {
                             //校验补缴人员是否存在福利档案基础信息，并且runStatus处于正在缴纳或者待减员
                             InsuranceArchivesBaseInfoPO insuranceBaseInfo = getInsuranceBaseInfoMapper().getOneByEmployeeIdAndPayOrg(paymentOrganization, employeeId);
                             if (insuranceBaseInfo == null || !(insuranceBaseInfo.getRunStatus().equals(EmployeeStatusEnum.STAY_DEL.getValue()) || insuranceBaseInfo.getRunStatus().equals(EmployeeStatusEnum.PAYING.getValue())) ) {
-                                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0, "补缴人员中存在未设置福利档案人员或相关人员不在福利在缴人员中，不可新建补缴信息！"));
+                                throw new SalaryRunTimeException(username + SalaryI18nUtil.getI18nLabel(0, "补缴未设置福利档案人员或不在福利在缴人员中，不可新建补缴信息！"));
                             }
                             List<Long> empIdsInPayMonthRange = listCanPayEmpIds(paymentOrganization, billMonth.substring(0, 7));
                             if (!empIdsInPayMonthRange.contains(employeeId)) {
-                                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(99920, "无核算人员"));
+                                throw new SalaryRunTimeException(username + SalaryI18nUtil.getI18nLabel(99920, "无核算人员"));
                             }
                             DataCollectionEmployee employee = getSalaryEmployeeService(user).getEmployeeById(employeeId);
                             // 封装InsuranceAccountDetailPO
@@ -6802,6 +6802,55 @@ public class SIAccountServiceImpl extends Service implements SIAccountService {
         Util_DataCache.setObjVal(cacheKey, JsonUtil.toJsonString(welfareNames));
     }
 
+    @Override
+    public void batSave(AccountBatParam accountBatParam) {
+        List<Long> paymentOrganizations = accountBatParam.getPaymentOrganizations();
+        for (Long paymentOrganization : paymentOrganizations) {
+            AccountParam param = AccountParam.builder()
+                    .billMonth(accountBatParam.getBillMonth())
+                    .paymentOrganization(paymentOrganization)
+                    .flag(true)
+                    .remarks(accountBatParam.getRemarks())
+                    .build();
+            save(param);
+        }
+    }
+
+    @Override
+    public void batDelete(AccountBatParam batParam) {
+        List<Long> ids = batParam.getIds();
+        for (Long id : ids) {
+            InsuranceAccountBatchPO po = getInsuranceAccountBatchMapper().getById(id);
+            AccountParam param = AccountParam.builder()
+                    .billMonth(po.getBillMonth())
+                    .paymentOrganization(po.getPaymentOrganization())
+                    .build();
+            delete(param);
+        }
+    }
+
+    @Override
+    public void batFile(AccountBatParam batParam) {
+        List<Long> ids = batParam.getIds();
+        for (Long id : ids) {
+            InsuranceAccountBatchPO po = getInsuranceAccountBatchMapper().getById(id);
+            AccountParam param = AccountParam.builder()
+                    .billMonth(po.getBillMonth())
+                    .paymentOrganization(po.getPaymentOrganization())
+                    .build();
+            file(param);
+        }
+    }
+
+    @Override
+    public void batSocialSecurityBenefitsRecalculate(AccountBatParam batParam) {
+        List<Long> ids = batParam.getIds();
+        for (Long id : ids) {
+            InsuranceAccountBatchPO param = InsuranceAccountBatchPO.builder().id(id).build();
+            socialSecurityBenefitsRecalculate(param);
+        }
+    }
+
     public void accountOtherView(InsuranceAccountViewListDTO dto, List<InsuranceAccountDetailPO> pos) {
         int otherNum = 0;
         BigDecimal otherPaySum = new BigDecimal("0");

src/com/engine/salary/service/impl/SIArchivesServiceImpl.java

@@ -2881,12 +2881,22 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 if (otherPaymentBaseString != null) {
                     updateOtherInfo.setOtherPaymentBaseString(otherPaymentBaseString);
                 }
+                if (!welBaseDiffSign) {
+                    otherPaymentBaseString = adaptWelBaseLimit(updateOtherInfo.getOtherSchemeId(), updateOtherInfo.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                    if (otherPaymentBaseString != null) {
+                        updateOtherInfo.setOtherPaymentBaseString(otherPaymentBaseString);
+                    }
+                }
             } else {
                 StringBuilder errorMsg = new StringBuilder("");
                 if (!checkWelBaseLimit(updateOtherInfo.getOtherSchemeId(),updateOtherInfo.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_PERSON.getValue(), errorMsg)) {
                     // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"其他福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
                     combineErrorMsg = "其他福利个人： " + errorMsg;
                 }
+                if ( (!welBaseDiffSign) && (!checkWelBaseLimit(updateOtherInfo.getOtherSchemeId(),updateOtherInfo.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg))) {
+                    // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"其他福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
+                    combineErrorMsg = "其他福利公司： " + errorMsg;
+                }
             }
             //需要拆分个人和公司福利基数时
             if (welBaseDiffSign) {
@@ -2952,12 +2962,22 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 if (otherPaymentBaseString != null) {
                     insertOtherInfo.setOtherPaymentBaseString(otherPaymentBaseString);
                 }
+                if (!welBaseDiffSign) {
+                    otherPaymentBaseString = adaptWelBaseLimit(insertOtherInfo.getOtherSchemeId(), insertOtherInfo.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                    if (otherPaymentBaseString != null) {
+                        insertOtherInfo.setOtherPaymentBaseString(otherPaymentBaseString);
+                    }
+                }
             } else {
                 StringBuilder errorMsg = new StringBuilder("");
                 if (!checkWelBaseLimit(insertOtherInfo.getOtherSchemeId(),insertOtherInfo.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_PERSON.getValue(), errorMsg)) {
                     // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"其他福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
                     combineErrorMsg = "其他福利个人：" + errorMsg;
                 }
+                if ( (!welBaseDiffSign) && (!checkWelBaseLimit(insertOtherInfo.getOtherSchemeId(),insertOtherInfo.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg))) {
+                    // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"其他福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
+                    combineErrorMsg = "其他福利公司：" + errorMsg;
+                }
             }
             //需要拆分个人和公司福利基数时
             if (welBaseDiffSign) {
@@ -3092,12 +3112,22 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 if (fundPaymentBaseString != null) {
                     updateFundInfo.setFundPaymentBaseString(fundPaymentBaseString);
                 }
+                if (!welBaseDiffSign) {
+                    fundPaymentBaseString = adaptWelBaseLimit(updateFundInfo.getFundSchemeId(), updateFundInfo.getFundPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                    if (fundPaymentBaseString != null) {
+                        updateFundInfo.setFundPaymentBaseString(fundPaymentBaseString);
+                    }
+                }
             } else {
                 StringBuilder errorMsg = new StringBuilder("");
                 if (!checkWelBaseLimit(updateFundInfo.getFundSchemeId(),updateFundInfo.getFundPaymentBaseString(), PaymentScopeEnum.SCOPE_PERSON.getValue(), errorMsg)) {
                     // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"公积金福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
                     combineErrorMsg = "公积金个人" + errorMsg;
                 }
+                if ( (!welBaseDiffSign) && (!checkWelBaseLimit(updateFundInfo.getFundSchemeId(),updateFundInfo.getFundPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg))) {
+                    // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"公积金福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
+                    combineErrorMsg = "公积金公司" + errorMsg;
+                }
             }
 
             //需要拆分个人和公司福利基数时
@@ -3168,12 +3198,22 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 if (fundPaymentBaseString != null) {
                     insertFundInfo.setFundPaymentBaseString(fundPaymentBaseString);
                 }
+                if (!welBaseDiffSign) {
+                    fundPaymentBaseString = adaptWelBaseLimit(insertFundInfo.getFundSchemeId(), insertFundInfo.getFundPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                    if (fundPaymentBaseString != null) {
+                        insertFundInfo.setFundPaymentBaseString(fundPaymentBaseString);
+                    }
+                }
             } else {
                 StringBuilder errorMsg = new StringBuilder("");
                 if (!checkWelBaseLimit(insertFundInfo.getFundSchemeId(),insertFundInfo.getFundPaymentBaseString(), PaymentScopeEnum.SCOPE_PERSON.getValue(), errorMsg)) {
                     // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"公积金福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
                     combineErrorMsg = "公积金个人：" + errorMsg;
                 }
+                if ((!welBaseDiffSign) && (!checkWelBaseLimit(insertFundInfo.getFundSchemeId(),insertFundInfo.getFundPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg))) {
+                    // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"公积金福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
+                    combineErrorMsg = "公积金公司：" + errorMsg;
+                }
             }
 
             //需要拆分个人和公司福利基数时
@@ -3315,12 +3355,22 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 if (socialPaymentBaseString != null) {
                     updateSocialInfo.setSocialPaymentBaseString(socialPaymentBaseString);
                 }
+                if (!welBaseDiffSign) {
+                    socialPaymentBaseString = adaptWelBaseLimit(updateSocialInfo.getSocialSchemeId(), updateSocialInfo.getSocialPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                    if (socialPaymentBaseString != null) {
+                        updateSocialInfo.setSocialPaymentBaseString(socialPaymentBaseString);
+                    }
+                }
             } else {
                 StringBuilder errorMsg = new StringBuilder("");
                 if (!checkWelBaseLimit(updateSocialInfo.getSocialSchemeId(),updateSocialInfo.getSocialPaymentBaseString(), PaymentScopeEnum.SCOPE_PERSON.getValue(), errorMsg)) {
                     // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"社保福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
                     combineErrorMsg = "社保个人：" + errorMsg;
                 }
+                if ((!welBaseDiffSign) && (!checkWelBaseLimit(updateSocialInfo.getSocialSchemeId(),updateSocialInfo.getSocialPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg))) {
+                    // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"社保福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
+                    combineErrorMsg = "社保公司：" + errorMsg;
+                }
             }
 
             //需要拆分个人和公司福利基数时
@@ -3390,12 +3440,22 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
                 if (socialPaymentBaseString != null) {
                     insertSocialInfo.setSocialPaymentBaseString(socialPaymentBaseString);
                 }
+                if (!welBaseDiffSign) {
+                    socialPaymentBaseString = adaptWelBaseLimit(insertSocialInfo.getSocialSchemeId(), insertSocialInfo.getSocialPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                    if (socialPaymentBaseString != null) {
+                        insertSocialInfo.setSocialPaymentBaseString(socialPaymentBaseString);
+                    }
+                }
             } else {
                 StringBuilder errorMsg = new StringBuilder("");
                 if (!checkWelBaseLimit(insertSocialInfo.getSocialSchemeId(),insertSocialInfo.getSocialPaymentBaseString(), PaymentScopeEnum.SCOPE_PERSON.getValue(), errorMsg)) {
                     // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"社保福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
                     combineErrorMsg = "社保个人：" + errorMsg;
                 }
+                if ((!welBaseDiffSign) && (!checkWelBaseLimit(insertSocialInfo.getSocialSchemeId(),insertSocialInfo.getSocialPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg))) {
+                    // throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(0,"社保福利明细中的基数更新内容不符合相关基数上下限要求，请检查后重试！"));
+                    combineErrorMsg = "社保公司：" + errorMsg;
+                }
             }
             //需要拆分个人和公司福利基数时
             if (welBaseDiffSign) {

src/com/engine/salary/service/impl/SICompensationServiceImpl.java

@@ -1,7 +1,6 @@
 package com.engine.salary.service.impl;
 
 import com.alibaba.fastjson.JSON;
-import com.alipay.oceanbase.jdbc.StringUtils;
 import com.cloudstore.eccom.pc.table.WeaTable;
 import com.cloudstore.eccom.pc.table.WeaTableColumn;
 import com.engine.common.util.ServiceUtil;
@@ -41,6 +40,7 @@ import com.engine.salary.util.db.MapperProxyFactory;
 import com.engine.salary.util.page.Column;
 import com.google.common.collect.Lists;
 import com.engine.salary.util.db.IdGenerator;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import weaver.hrm.User;
 

src/com/engine/salary/service/impl/SIRepairServiceImpl.java

@@ -387,11 +387,15 @@ public class SIRepairServiceImpl extends Service implements SIRepairService {
                 && (projects.contains(ProjectTypeEnum.MEDICAL_INSURANCE.getValue()))) {
             if (socialSchemePO != null && (StringUtils.isNotBlank(socialSchemePO.getSocialPaymentBaseString()) || StringUtils.isNotBlank(socialSchemePO.getSocialPaymentComBaseString()))) {
                 Map<String, String> socialMap = JSON.parseObject(socialSchemePO.getSocialPaymentBaseString(), new HashMap<String, String>().getClass());
-                socialMap = socialMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()) || "9002".equals(e.getKey()))
-                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                if(socialMap!=null){
+                    socialMap = socialMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()) || "9002".equals(e.getKey()))
+                            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                }
                 Map<String, String> socialComMap = JSON.parseObject(socialSchemePO.getSocialPaymentComBaseString(), new HashMap<String, String>().getClass());
-                socialComMap = socialComMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()) || "9002".equals(e.getKey()))
-                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                if(socialComMap!=null){
+                    socialComMap = socialComMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()) || "9002".equals(e.getKey()))
+                            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                }
                 List<String> socialIds = new ArrayList<>();
                 socialIds.addAll(socialMap == null ? Collections.emptyList() : socialMap.keySet());
                 socialIds.addAll(socialComMap == null ? Collections.emptyList() : socialMap.keySet());
@@ -434,12 +438,16 @@ public class SIRepairServiceImpl extends Service implements SIRepairService {
                 && (!projects.contains(ProjectTypeEnum.MEDICAL_INSURANCE.getValue()))) {
             if (socialSchemePO != null && (StringUtils.isNotBlank(socialSchemePO.getSocialPaymentBaseString()) || StringUtils.isNotBlank(socialSchemePO.getSocialPaymentComBaseString()))) {
                 Map<String, String> socialMap = JSON.parseObject(socialSchemePO.getSocialPaymentBaseString(), new HashMap<String, String>().getClass());
-                socialMap = socialMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()))
-                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                if (socialMap != null) {
+                    socialMap = socialMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()))
+                            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                }
 
                 Map<String, String> socialComMap = JSON.parseObject(socialSchemePO.getSocialPaymentComBaseString(), new HashMap<String, String>().getClass());
-                socialComMap = socialComMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()))
-                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                if (socialComMap != null) {
+                    socialComMap = socialComMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()))
+                            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                }
                 List<String> socialIds = new ArrayList<>();
                 socialIds.addAll(socialMap == null ? Collections.emptyList() : socialMap.keySet());
                 socialIds.addAll(socialComMap == null ? Collections.emptyList() :socialComMap.keySet());
@@ -482,11 +490,15 @@ public class SIRepairServiceImpl extends Service implements SIRepairService {
                 && (projects.contains(ProjectTypeEnum.MEDICAL_INSURANCE.getValue()))) {
             if (socialSchemePO != null && (StringUtils.isNotBlank(socialSchemePO.getSocialPaymentBaseString()) || StringUtils.isNotBlank(socialSchemePO.getSocialPaymentComBaseString()))) {
                 Map<String, String> socialMap = JSON.parseObject(socialSchemePO.getSocialPaymentBaseString(), new HashMap<String, String>().getClass());
-                socialMap = socialMap.entrySet().stream().filter(e -> "9002".equals(e.getKey()))
-                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                if(socialMap!=null){
+                    socialMap = socialMap.entrySet().stream().filter(e -> "9002".equals(e.getKey()))
+                            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                }
                 Map<String, String> socialComMap = JSON.parseObject(socialSchemePO.getSocialPaymentComBaseString(), new HashMap<String, String>().getClass());
-                socialComMap = socialComMap.entrySet().stream().filter(e -> "9002".equals(e.getKey()))
-                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                if(socialComMap !=null){
+                    socialComMap = socialComMap.entrySet().stream().filter(e -> "9002".equals(e.getKey()))
+                            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+                }
                 List<String> socialIds = new ArrayList<>();
                 socialIds.addAll(socialMap == null ? Collections.emptyList() : socialMap.keySet());
                 socialIds.addAll(socialComMap == null ? Collections.emptyList() : socialComMap.keySet());

src/com/engine/salary/service/impl/SISchemeServiceImpl.java

@@ -1432,6 +1432,14 @@ public class SISchemeServiceImpl extends Service implements SISchemeService {
 
             Boolean otherCheckBase = getSIArchivesService(user).checkWelBaseLimit(insuranceArchivesOtherSchemePO.getOtherSchemeId(), insuranceArchivesOtherSchemePO.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_PERSON.getValue(), errorMsg);
 
+            Boolean socialCheckBase2 = true;
+            Boolean fundCheckBase2 = true;
+            Boolean otherCheckBase2 = true;
+            if (!welBaseDiffSign) {
+                socialCheckBase2 = getSIArchivesService(user).checkWelBaseLimit(insuranceArchivesSocialSchemePO.getSocialSchemeId(), insuranceArchivesSocialSchemePO.getSocialPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg);
+                fundCheckBase2 = getSIArchivesService(user).checkWelBaseLimit(insuranceArchivesFundSchemePO.getFundSchemeId(), insuranceArchivesFundSchemePO.getFundPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg);
+                otherCheckBase2 = getSIArchivesService(user).checkWelBaseLimit(insuranceArchivesOtherSchemePO.getOtherSchemeId(), insuranceArchivesOtherSchemePO.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg);
+            }
             Boolean socialCheckComBase = true;
             Boolean fundCheckComBase = true;
             Boolean otherCheckComBase = true;
@@ -1440,17 +1448,17 @@ public class SISchemeServiceImpl extends Service implements SISchemeService {
                 fundCheckComBase = getSIArchivesService(user).checkWelBaseLimit(insuranceArchivesFundSchemePO.getFundSchemeId(), insuranceArchivesFundSchemePO.getFundPaymentComBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg);
                 otherCheckComBase = getSIArchivesService(user).checkWelBaseLimit(insuranceArchivesOtherSchemePO.getOtherSchemeId(), insuranceArchivesOtherSchemePO.getOtherPaymentComBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue(), errorMsg);
             }
-            if (socialCheckBase && fundCheckBase && otherCheckBase && socialCheckComBase && fundCheckComBase && otherCheckComBase) {
+            if (socialCheckBase && fundCheckBase && otherCheckBase && socialCheckBase2 && fundCheckBase2 && otherCheckBase2 && socialCheckComBase && fundCheckComBase && otherCheckComBase) {
                 insuranceArchivesAccountPOS.add(insuranceArchivesAccountPO);
             } else {
                 String checkMessage = "该条数据中";
-                if (!socialCheckBase || !socialCheckComBase) {
+                if (!socialCheckBase || !socialCheckBase2 || !socialCheckComBase) {
                     checkMessage = checkMessage + "社保福利基数、";
                 }
-                if (!fundCheckBase || !fundCheckComBase) {
+                if (!fundCheckBase || !fundCheckBase2 || !fundCheckComBase) {
                     checkMessage = checkMessage + "公积金福利基数、";
                 }
-                if (!otherCheckBase || !otherCheckComBase) {
+                if (!otherCheckBase || !otherCheckBase2 || !otherCheckComBase) {
                     checkMessage = checkMessage + "其他福利基数、";
                 }
                 checkMessage = checkMessage.substring(0, checkMessage.length() - 1);
@@ -1470,6 +1478,14 @@ public class SISchemeServiceImpl extends Service implements SISchemeService {
             insuranceArchivesSocialSchemePO.setSocialPaymentBaseString(newSocialPaymentBaseString);
             insuranceArchivesFundSchemePO.setFundPaymentBaseString(newFundPaymentBaseString);
             insuranceArchivesOtherSchemePO.setOtherPaymentBaseString(newOtherPaymentBaseString);
+            if (!welBaseDiffSign) {
+                newSocialPaymentBaseString = getSIArchivesService(user).checkAndBuildWelBaseWithLimit(insuranceArchivesSocialSchemePO.getSocialSchemeId(), insuranceArchivesSocialSchemePO.getSocialPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                newFundPaymentBaseString = getSIArchivesService(user).checkAndBuildWelBaseWithLimit(insuranceArchivesFundSchemePO.getFundSchemeId(), insuranceArchivesFundSchemePO.getFundPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                newOtherPaymentBaseString = getSIArchivesService(user).checkAndBuildWelBaseWithLimit(insuranceArchivesOtherSchemePO.getOtherSchemeId(), insuranceArchivesOtherSchemePO.getOtherPaymentBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());
+                insuranceArchivesSocialSchemePO.setSocialPaymentBaseString(newSocialPaymentBaseString);
+                insuranceArchivesFundSchemePO.setFundPaymentBaseString(newFundPaymentBaseString);
+                insuranceArchivesOtherSchemePO.setOtherPaymentBaseString(newOtherPaymentBaseString);
+            }
 
             if (welBaseDiffSign) {
                 String newSocialPaymentComBaseString = getSIArchivesService(user).checkAndBuildWelBaseWithLimit(insuranceArchivesSocialSchemePO.getSocialSchemeId(), insuranceArchivesSocialSchemePO.getSocialPaymentComBaseString(), PaymentScopeEnum.SCOPE_COMPANY.getValue());

src/com/engine/salary/service/impl/SalaryAcctExcelServiceImpl.java

@@ -405,11 +405,13 @@ public class SalaryAcctExcelServiceImpl extends Service implements SalaryAcctExc
         if (openSum != null && StringUtils.isNotBlank(openSum.getConfValue()) && OpenEnum.parseByValue(openSum.getConfValue()) == OpenEnum.OPEN) {
             total = true;
             Map<String, Object> sumRow = getSalaryAcctResultService(user).sumRow(queryParam);
-            sumRow.forEach((k, v) -> {
-                if (NumberUtils.isCreatable(v.toString())) {
-                    sumRow.put(k, new BigDecimal(v.toString()));
-                }
-            });
+            if (sumRow != null) {
+                sumRow.forEach((k, v) -> {
+                    if (NumberUtils.isCreatable(v.toString())) {
+                        sumRow.put(k, new BigDecimal(v.toString()));
+                    }
+                });
+            }
             if (sumRow != null) {
                 sumRow.put("taxAgentName", "总计");
                 resultMapList.add(sumRow);
@@ -1437,7 +1439,7 @@ public class SalaryAcctExcelServiceImpl extends Service implements SalaryAcctExc
                     loggerContext.setOperateType(OperateTypeEnum.EXCEL_IMPORT.getValue());
                     loggerContext.setOperateTypeName(SalaryI18nUtil.getI18nLabel(0, "导入薪资核算数据"));
                     loggerContext.setOperatedesc(SalaryI18nUtil.getI18nLabel(0, "导入薪资核算数据 ") + targetName);
-                    loggerContext.setOldValueList(list4log);
+                    loggerContext.setNewValueList(list4log);
                     SalaryElogConfig.salaryAcctRecordLoggerTemplate.write(loggerContext);
 
 //                    //报表

src/com/engine/salary/service/impl/SalaryAcctRecordServiceImpl.java

@@ -4,11 +4,12 @@ import cn.hutool.core.collection.CollUtil;
 import com.api.formmode.mybatis.util.SqlProxyHandle;
 import com.engine.common.util.ServiceUtil;
 import com.engine.core.impl.Service;
+import com.engine.hrmelog.entity.dto.LoggerContext;
 import com.engine.salary.common.LocalDateRange;
 import com.engine.salary.config.SalaryElogConfig;
-import com.engine.hrmelog.entity.dto.LoggerContext;
 import com.engine.salary.entity.salaryBill.po.SalarySendPO;
 import com.engine.salary.entity.salaryacct.bo.SalaryAcctRecordBO;
+import com.engine.salary.entity.salaryacct.param.SalaryAcctBatParam;
 import com.engine.salary.entity.salaryacct.param.SalaryAcctRecordQueryParam;
 import com.engine.salary.entity.salaryacct.param.SalaryAcctRecordSaveParam;
 import com.engine.salary.entity.salaryacct.po.SalaryAcctEmployeePO;
@@ -40,6 +41,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.math.NumberUtils;
 import weaver.hrm.User;
 
+import java.time.YearMonth;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -659,9 +661,9 @@ public class SalaryAcctRecordServiceImpl extends Service implements SalaryAcctRe
             throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(98819, "薪资核算结果还未归档，可直接核算"));
         }
         // 税款所在年的日期范围（第一天～最后一天）
-        LocalDateRange yearRange = SalaryDateUtil.localDate2YearRange(salaryAcctRecordPO.getSalaryMonth());
+        LocalDateRange yearRange = SalaryDateUtil.localDate2YearRange(salaryAcctRecordPO.getTaxCycle());
         if (Objects.isNull(yearRange)) {
-            throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(84026, "薪资所属月为空"));
+            throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(84026, "税款所属期为空"));
         }
         // 查询税款所在年的该个税扣缴义务人所有薪资核算记录
         // 获取账套所属个税扣缴义务人的核算记录
@@ -678,13 +680,13 @@ public class SalaryAcctRecordServiceImpl extends Service implements SalaryAcctRe
         if (!taxDeclarationFunctionEnum.getValue().equals(TaxDeclarationFunctionEnum.CLOSURE.getValue())) {
             // 如果已经存在之后月份的薪资核算记录了，就不允许重新核算本月了
             SalaryAcctRecordPO afterSalaryAcctRecordPO = selfSalaryAcctRecordPOS.stream()
-                    .filter(po -> po.getSalaryMonth().compareTo(salaryAcctRecordPO.getSalaryMonth()) > 0)
+                    .filter(po -> po.getTaxCycle().compareTo(salaryAcctRecordPO.getTaxCycle()) > 0)
                     .findAny()
                     .orElse(null);
             if (Objects.nonNull(afterSalaryAcctRecordPO)) {
                 throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(105826, "已经存在{0}的薪资核算记录了，不能重新核算{1}的薪资了")
-                        .replace("{0}", SalaryDateUtil.localDate2YearMonth(afterSalaryAcctRecordPO.getSalaryMonth()).toString())
-                        .replace("{1}", SalaryDateUtil.localDate2YearMonth(salaryAcctRecordPO.getSalaryMonth()).toString()));
+                        .replace("{0}", SalaryDateUtil.localDate2YearMonth(afterSalaryAcctRecordPO.getTaxCycle()).toString())
+                        .replace("{1}", SalaryDateUtil.localDate2YearMonth(salaryAcctRecordPO.getTaxCycle()).toString()));
             }
         }
 
@@ -845,4 +847,38 @@ public class SalaryAcctRecordServiceImpl extends Service implements SalaryAcctRe
     public void updateDate(Long id, Date updateTime) {
         getSalaryAcctRecordMapper().updateDate(id, updateTime);
     }
+
+    @Override
+    public void batSave(SalaryAcctBatParam saveParam) {
+
+        List<Long> salarySobIds = saveParam.getSalarySobIds();
+        YearMonth salaryMonth = SalaryDateUtil.localDate2YearMonth(saveParam.getSalaryMonth());
+        for (int i = 0; i < salarySobIds.size(); i++) {
+            Long salarySobId = salarySobIds.get(i);
+            SalaryAcctRecordSaveParam param = SalaryAcctRecordSaveParam.builder()
+                    .salarySobId(salarySobId)
+                    .salaryMonth(salaryMonth)
+                    .description(saveParam.getDescription())
+                    .build();
+            save(param);
+        }
+    }
+
+    @Override
+    public void batFile(SalaryAcctBatParam param) {
+        List<Long> salaryAcctRecordIds = param.getSalaryAcctRecordIds();
+        for (int i = 0; i < salaryAcctRecordIds.size(); i++) {
+            Long recordId = salaryAcctRecordIds.get(i);
+            file(recordId);
+        }
+    }
+
+    @Override
+    public void batReCalculate(SalaryAcctBatParam param) {
+        List<Long> salaryAcctRecordIds = param.getSalaryAcctRecordIds();
+        for (int i = 0; i < salaryAcctRecordIds.size(); i++) {
+            Long recordId = salaryAcctRecordIds.get(i);
+            reCalculate(recordId);
+        }
+    }
 }

src/com/engine/salary/service/impl/SalaryAcctResultServiceImpl.java

@@ -1,5 +1,6 @@
 package com.engine.salary.service.impl;
 
+import cn.hutool.core.collection.CollUtil;
 import com.engine.common.util.ServiceUtil;
 import com.engine.core.impl.Service;
 import com.engine.hrmelog.entity.dto.LoggerContext;
@@ -326,14 +327,25 @@ public class SalaryAcctResultServiceImpl extends Service implements SalaryAcctRe
         if (CollectionUtils.isNotEmpty(otherConditions)) {
             List<Long> items = SalaryEntityUtil.properties(otherConditions, SalaryAcctResultQueryParam.OtherCondition::getItemId, Collectors.toList());
             List<SalaryAcctResultPO> list = listBySalaryAcctRecordIdsAndSalaryItemIds(Collections.singletonList(queryParam.getSalaryAcctRecordId()), items);
-            for (int i = 0; i < otherConditions.size(); i++) {
-                SalaryAcctResultQueryParam.OtherCondition otherCondition = otherConditions.get(i);
-                Long itemId = otherCondition.getItemId();
-                FilterEnum filter = otherCondition.getFilter();
-                List<String> params = otherCondition.getParams();
-                list = list.stream().filter(a -> Objects.equals(a.getSalaryItemId(), itemId)).filter(a -> filter.filter(params).test(a.getResultValue())).collect(Collectors.toList());
+            Map<Long, List<SalaryAcctResultPO>> acctEmpResultsMap = SalaryEntityUtil.group2Map(list, SalaryAcctResultPO::getSalaryAcctEmpId);
+            Set<Long> removeAcctEmpIds = new HashSet<>();
+            for (Long acctEmpId : acctEmpResultsMap.keySet()) {
+                List<SalaryAcctResultPO> acctEmpResults = acctEmpResultsMap.get(acctEmpId);
+                //如果有一个条件不成立就删除
+                for (int i = 0; i < otherConditions.size(); i++) {
+                    SalaryAcctResultQueryParam.OtherCondition otherCondition = otherConditions.get(i);
+                    Long itemId = otherCondition.getItemId();
+                    FilterEnum filter = otherCondition.getFilter();
+                    List<String> params = otherCondition.getParams();
+                    for (SalaryAcctResultPO po : acctEmpResults) {
+                        if(Objects.equals(po.getSalaryItemId(), itemId) && !filter.filter(params).test(po.getResultValue())){
+                            removeAcctEmpIds.add(po.getSalaryAcctEmpId());
+                        }
+                    }
+                }
             }
-            List<Long> salaryAcctEmpId = SalaryEntityUtil.properties(list, SalaryAcctResultPO::getSalaryAcctEmpId, Collectors.toList());
+            acctEmpResultsMap.keySet().removeAll(removeAcctEmpIds);
+            List<Long> salaryAcctEmpId = Lists.newArrayList(acctEmpResultsMap.keySet());
 
             if (CollectionUtils.isEmpty(salaryAcctEmpId)) {
                 //条件不满足直接返回空列表
@@ -1052,7 +1064,14 @@ public class SalaryAcctResultServiceImpl extends Service implements SalaryAcctRe
 
     @Override
     public void updateLockStatusByParam(SalaryAcctResultUpdateLockStatusParam updateParam) {
-        List<SalaryAcctEmployeePO> salaryAcctEmployees = getSalaryAcctEmployeeService(user).listBySalaryAcctRecordId(updateParam.getSalaryAcctRecordId());
+        Set<Long> acctEmpIds = updateParam.getAcctEmpIds();
+        List<SalaryAcctEmployeePO> salaryAcctEmployees;
+        if (CollUtil.isNotEmpty(acctEmpIds)) {
+            salaryAcctEmployees = getSalaryAcctEmployeeService(user).listByIds(acctEmpIds);
+        } else {
+            salaryAcctEmployees = getSalaryAcctEmployeeService(user).listBySalaryAcctRecordId(updateParam.getSalaryAcctRecordId());
+        }
+
         if (CollectionUtils.isEmpty(salaryAcctEmployees)) {
             return;
         }

src/com/engine/salary/service/impl/SalaryArchiveItemServiceImpl.java

@@ -656,8 +656,6 @@ public class SalaryArchiveItemServiceImpl extends Service implements SalaryArchi
     public XSSFWorkbook exportAdjustRecordList(SalaryItemAdjustRecordQueryParam queryParam) {
         // 1.工作簿名称
         String sheetName = SalaryI18nUtil.getI18nLabel(85368, "薪资项目调整记录");
-        // 获取所有可被引用的薪资项目
-        List<SalaryItemPO> salaryItems = salaryItemMapper.getCanAdjustSalaryItems();
         String[] header = {
                 SalaryI18nUtil.getI18nLabel(85429, "姓名"),
                 SalaryI18nUtil.getI18nLabel(86187, "员工状态"),

src/com/engine/salary/service/impl/SalaryArchiveServiceImpl.java

@@ -543,7 +543,7 @@ public class SalaryArchiveServiceImpl extends Service implements SalaryArchiveSe
         // 1.工作簿名称
         String sheetName = SalaryI18nUtil.getI18nLabel(85368, "薪资档案");
         // 获取所有可被引用的薪资项目
-        List<SalaryItemPO> salaryItems = salaryItemMapper.getCanAdjustSalaryItems();
+        List<SalaryItemPO> salaryItems = getSalaryArchiveItemService(user).getCanAdjustSalaryItems();
         Object[] header = {
                 new WeaTableColumnGroup("150px", SalaryI18nUtil.getI18nLabel(85429, "姓名"), "", "", 0),
                 new WeaTableColumnGroup("150px", SalaryI18nUtil.getI18nLabel(86184, "个税扣缴义务人"), "", "", 0),

src/com/engine/salary/service/impl/SalaryEmployeeServiceImpl.java

@@ -1,5 +1,6 @@
 package com.engine.salary.service.impl;
 
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.NumberUtil;
 import com.alibaba.fastjson.JSON;
 import com.api.formmode.mybatis.util.SqlProxyHandle;
@@ -174,7 +175,7 @@ public class SalaryEmployeeServiceImpl extends Service implements SalaryEmployee
         }
 
         //外部人员
-        if(hasExtEmp){
+        if (hasExtEmp) {
             List<SalarySobExtRangePO> salarySobExtRangePOS = getSalarySobExtRangeService(user).listBySalarySobId(salarySobId);
             if (CollectionUtils.isNotEmpty(salarySobExtRangePOS)) {
                 List<Long> ids = SalaryEntityUtil.properties(salarySobExtRangePOS, SalarySobExtRangePO::getTargetId, Collectors.toList());
@@ -418,20 +419,24 @@ public class SalaryEmployeeServiceImpl extends Service implements SalaryEmployee
 
         result.addAll(employBiz.listByVirtualParams(virtualParams));
 
-        List<Long> empIds = new ArrayList<>();
-        includeQueryParams.stream()
-                .filter(param -> param.getTargetType().equals(TargetTypeEnum.SQL.name()))
-                .forEach(param -> {
-                    String sql = param.getTarget();
-                    RecordSet rs = new RecordSet();
-                    if (rs.execute(sql)) {
-                        while (rs.next()) {
-                            empIds.add((long) rs.getInt("id"));
-                        }
+        for (SalarySobRangeEmpQueryParam  param:includeQueryParams) {
+            if(param.getTargetType().equals(TargetTypeEnum.SQL.name())){
+                List<Long> empIds = new ArrayList<>();
+                String sql = param.getTarget();
+                RecordSet rs = new RecordSet();
+                if (rs.execute(sql)) {
+                    while (rs.next()) {
+                        empIds.add((long) rs.getInt("id"));
                     }
-                });
-        List<DataCollectionEmployee> employees = getSalaryEmployeeService(user).getEmployeeByIdsAll(empIds);
-        result.addAll(employees);
+                }
+                if(CollUtil.isNotEmpty(empIds)){
+                    Collection<String> employeeStatus = param.getEmployeeStatus();
+                    List<DataCollectionEmployee> employeeByIdsAll = getSalaryEmployeeService(user).getEmployeeByIdsAll(empIds);
+                    List<DataCollectionEmployee> collect = employeeByIdsAll.stream().filter(e -> employeeStatus.contains(e.getStatus())).collect(Collectors.toList());
+                    result.addAll(collect);
+                }
+            }
+        }
 
         // 从hrmresource和hrmresourcevirtual可能获取到重复人员数据，需要根据人员id去重
         result = result.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparingLong(DataCollectionEmployee::getEmployeeId))), ArrayList::new));

src/com/engine/salary/service/impl/SalarySendServiceImpl.java

@@ -485,6 +485,11 @@ public class SalarySendServiceImpl extends Service implements SalarySendService
         if (salarySendInfo == null) {
             throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(100511, "工资单信息不存在"));
         }
+
+        if (!Objects.equals(salarySendInfo.getSendStatus(), 1)) {
+            throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(100511, "工资单信息不存在"));
+        }
+
         Long employeeId = salarySendInfo.getEmployeeId();
         if (currentEmployeeId.compareTo(employeeId) != 0) {
 
@@ -1343,7 +1348,6 @@ public class SalarySendServiceImpl extends Service implements SalarySendService
     }
 
 
-
     @Override
     public Map<String, Object> withdraw(SalarySendWithdrawParam param) {
         if (param.getSalarySendId() == null) {

src/com/engine/salary/service/impl/TaxDeclarationServiceImpl.java

@@ -1,5 +1,6 @@
 package com.engine.salary.service.impl;
 
+import cn.hutool.core.util.StrUtil;
 import com.engine.common.util.ServiceUtil;
 import com.engine.core.impl.Service;
 import com.engine.hrmelog.entity.dto.LoggerContext;
@@ -9,6 +10,7 @@ import com.engine.salary.entity.salaryacct.po.SalaryAcctRecordPO;
 import com.engine.salary.entity.salaryacct.po.SalaryAcctResultPO;
 import com.engine.salary.entity.salaryitem.po.SalaryItemPO;
 import com.engine.salary.entity.salarysob.po.SalarySobPO;
+import com.engine.salary.entity.taxagent.param.TaxAgentQueryParam;
 import com.engine.salary.entity.taxagent.po.TaxAgentPO;
 import com.engine.salary.entity.taxdeclaration.bo.TaxDeclarationBO;
 import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationListQueryParam;
@@ -114,15 +116,12 @@ public class TaxDeclarationServiceImpl extends Service implements TaxDeclaration
 
         // 分页参数
         TaxDeclarationPO po = TaxDeclarationPO.builder().build();
-        LocalDateRange localDateRange = new LocalDateRange();
         if (Objects.nonNull(queryParam.getFromSalaryMonth())) {
-            localDateRange.setFromDate(SalaryDateUtil.localDateToDate(queryParam.getFromSalaryMonth().atDay(1)));
+            po.setTaxCycleFromDate(queryParam.getFromSalaryMonth());
         }
         if (Objects.nonNull(queryParam.getEndSalaryMonth())) {
-            localDateRange.setEndDate(SalaryDateUtil.localDateToDate(queryParam.getEndSalaryMonth().atEndOfMonth()));
+            po.setTaxCycleEndDate(queryParam.getEndSalaryMonth());
         }
-        po.setSalaryMonths(localDateRange);
-
 
         // 分权
         Boolean openDevolution = getTaxAgentService(user).isNeedAuth(currentEmployeeId);
@@ -138,6 +137,15 @@ public class TaxDeclarationServiceImpl extends Service implements TaxDeclaration
 
         // 查询个税申报表
         List<TaxDeclarationPO> taxDeclarationPOS = getTaxDeclarationMapper().listSome(po);
+
+
+        if (StrUtil.isNotBlank(queryParam.getTaxAgentName())) {
+            List<TaxAgentPO> taxAgentPOs = getTaxAgentService(user).list(TaxAgentQueryParam.builder().name(queryParam.getTaxAgentName()).build());
+            Set<Long> taxAgentIds = SalaryEntityUtil.properties(taxAgentPOs, TaxAgentPO::getId);
+            taxDeclarationPOS = taxDeclarationPOS.stream().filter(tax -> taxAgentIds.contains(tax.getTaxAgentId())).collect(Collectors.toList());
+        }
+
+
         return SalaryPageUtil.buildPage(queryParam.getCurrent(), queryParam.getPageSize(),
                 taxDeclarationPOS, TaxDeclarationPO.class);
 

src/com/engine/salary/util/SalaryEntityUtil.java

@@ -135,6 +135,15 @@ public class SalaryEntityUtil {
                 .collect(Collectors.toMap(keyMapper, valueMapper, (a, b) -> a));
     }
 
+    public static <T, K, V> Map<K, V> convert2LinkedMap(Collection<T> objs, Function<T, K> keyMapper, Function<T, V> valueMapper) {
+        if (CollectionUtils.isEmpty(objs)) {
+            return Maps.newHashMap();
+        }
+        return objs.stream()
+                .filter(e -> valueMapper.apply(e) != null && keyMapper.apply(e) != null)
+                .collect(Collectors.toMap(keyMapper, valueMapper, (a, b) -> a, LinkedHashMap::new));
+    }
+
     public static <R, T> Map<R, List<T>> group2Map(Collection<T> objs, Function<T, R> function) {
         if (CollectionUtils.isEmpty(objs)) {
             return Maps.newHashMap();

src/com/engine/salary/util/SalaryTokenUtil.java

@@ -134,12 +134,15 @@ public class SalaryTokenUtil {
             // 对秘钥进行加密传输，防止篡改数据
             secret = rsa.encrypt(null, (String) (datas.get("secrit")), null, "utf-8", spk, false);
             // secret存库
-            String date = SalaryDateUtil.getFormatLocalDateTime(LocalDateTime.now());
-            sql = String.format("insert into hrsa_salary_sys_conf(id, conf_key, conf_value, title, module, order_weight, delete_type, create_time, update_time) values (%s,'%s','%s','%s','%s',%s,%s,'%s','%s')",
+            String date = "'"+SalaryDateUtil.getFormatLocalDateTime(LocalDateTime.now())+"'";
+            if(rs.getDBType().equalsIgnoreCase("oracle")){
+                date = String.format("to_date(%s,'yyyy-mm-dd hh24:mi:ss')", date);
+            }
+            sql = String.format("insert into hrsa_salary_sys_conf(id, conf_key, conf_value, title, module, order_weight, delete_type, create_time, update_time) values (%s,'%s','%s','%s','%s',%s,%s,%s,%s)",
                     IdGenerator.generate(), "SALARY_TOKEN_SECRET", secret, "token", "basic",0,0,date,date);
             rs.execute(sql);
             // 保存spk
-            sql = String.format("insert into hrsa_salary_sys_conf(id, conf_key, conf_value, title, module, order_weight, delete_type, create_time, update_time) values (%s,'%s','%s','%s','%s',%s,%s,'%s','%s')",
+            sql = String.format("insert into hrsa_salary_sys_conf(id, conf_key, conf_value, title, module, order_weight, delete_type, create_time, update_time) values (%s,'%s','%s','%s','%s',%s,%s,%s,%s)",
                     IdGenerator.generate(), "SALARY_TOKEN_SPK", spk, "spk", "basic",0,0,date,date);
             rs.execute(sql);
         }

src/com/engine/salary/util/excel/ExcelUtil.java

@@ -1,5 +1,6 @@
 package com.engine.salary.util.excel;
 
+import cn.hutool.core.util.StrUtil;
 import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationLaborListDTO;
 import com.engine.salary.util.SalaryDateUtil;
 import com.engine.salary.util.SalaryI18nUtil;
@@ -139,8 +140,10 @@ public class ExcelUtil {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof BigDecimal) {
                     cell.setCellType(CellType.NUMERIC);
                     cell.setCellValue(o == null ? 0 : ((BigDecimal) o).doubleValue());
@@ -235,8 +238,10 @@ public class ExcelUtil {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof BigDecimal) {
                     cell.setCellType(CellType.NUMERIC);
                     cell.setCellValue(o == null ? 0 : ((BigDecimal) o).doubleValue());
@@ -311,8 +316,10 @@ public class ExcelUtil {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof BigDecimal) {
                     cell.setCellType(CellType.NUMERIC);
                     cell.setCellValue(o == null ? 0 : ((BigDecimal) o).doubleValue());
@@ -377,8 +384,10 @@ public class ExcelUtil {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof Boolean) {
                     cell.setCellType(CellType.BOOLEAN);
                     cell.setCellValue(String.valueOf(o));
@@ -458,8 +467,10 @@ public class ExcelUtil {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof Boolean) {
                     cell.setCellType(CellType.BOOLEAN);
                     cell.setCellValue(String.valueOf(o));

src/com/engine/salary/util/excel/ExcelUtilPlus.java

@@ -1,11 +1,13 @@
 package com.engine.salary.util.excel;
 
+import cn.hutool.core.util.StrUtil;
 import com.engine.salary.component.WeaTableColumnGroup;
 import com.engine.salary.util.SalaryDateUtil;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.poi.ss.usermodel.*;
 import org.apache.poi.ss.util.CellRangeAddress;
 import org.apache.poi.xssf.usermodel.*;
+import weaver.wechat.util.Utils;
 
 import java.awt.Color;
 import java.math.BigDecimal;
@@ -131,10 +133,10 @@ public class ExcelUtilPlus {
         for (int i = 0; i < header.size(); i++) {
             WeaTableColumnGroup columnGroupItem = (WeaTableColumnGroup) header.get(i);
             XSSFCell rowZeroCell = row0.createCell(i, CellType.STRING);
-            rowZeroCell.setCellValue(columnGroupItem.getText().toString());
+            rowZeroCell.setCellValue(columnGroupItem.getText());
             rowZeroCell.setCellStyle(titleCellStyle);
             //设置列宽
-            sheet.setColumnWidth(i, Math.min(255, Math.max(12, columnGroupItem.getText().length() * 4)) * 256);
+            sheet.setColumnWidth(i, Math.min(255, Math.max(12, Utils.null2String(columnGroupItem.getText()).length() * 4)) * 256);
             patternList.add(columnGroupItem.getPattern());
         }
 
@@ -190,8 +192,10 @@ public class ExcelUtilPlus {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof BigDecimal) {
                     if (lastRowRed && rowIndex == rowList.size() - 1) {
                         cell.setCellStyle(numberRedCellStyleMap.get(patternList.get(cellIndex)));
@@ -199,8 +203,7 @@ public class ExcelUtilPlus {
                         cell.setCellStyle(numberCellStyleMap.get(patternList.get(cellIndex)));
                     }
                     cell.setCellType(CellType.NUMERIC);
-                    double value = o == null ? 0 : ((BigDecimal) o).doubleValue();
-                    cell.setCellValue(o == null ? 0 : ((BigDecimal) o).doubleValue());
+                    cell.setCellValue(((BigDecimal) o).doubleValue());
                 } else if (o instanceof Boolean) {
                     cell.setCellType(CellType.BOOLEAN);
                     cell.setCellValue(String.valueOf(o));
@@ -220,6 +223,7 @@ public class ExcelUtilPlus {
         }
         return workbook;
     }
+
     public static XSSFWorkbook genWorkbookV2(List<List<Object>> rowList, String sheetName) {
         XSSFWorkbook workbook = new XSSFWorkbook();
 
@@ -280,11 +284,13 @@ public class ExcelUtilPlus {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof BigDecimal) {
                     cell.setCellType(CellType.NUMERIC);
-                    cell.setCellValue(o == null ? 0 : ((BigDecimal) o).doubleValue());
+                    cell.setCellValue(((BigDecimal) o).doubleValue());
                 } else if (o instanceof Boolean) {
                     cell.setCellType(CellType.BOOLEAN);
                     cell.setCellValue(String.valueOf(o));
@@ -367,8 +373,10 @@ public class ExcelUtilPlus {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof Boolean) {
                     cell.setCellType(CellType.BOOLEAN);
                     cell.setCellValue(String.valueOf(o));
@@ -476,11 +484,13 @@ public class ExcelUtilPlus {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof BigDecimal) {
                     cell.setCellType(CellType.NUMERIC);
-                    cell.setCellValue(o == null ? 0 : ((BigDecimal) o).doubleValue());
+                    cell.setCellValue(((BigDecimal) o).doubleValue());
                 } else if (o instanceof Boolean) {
                     cell.setCellType(CellType.BOOLEAN);
                     cell.setCellValue(String.valueOf(o));
@@ -674,8 +684,10 @@ public class ExcelUtilPlus {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof BigDecimal) {
                     if (lastRowRed && rowIndex == rowList.size() - 1) {
                         cell.setCellStyle(numberRedCellStyleMap.get(patternList.get(cellIndex)));
@@ -839,8 +851,10 @@ public class ExcelUtilPlus {
                 }
                 Object o = infoList.get(cellIndex);
                 if (o instanceof String) {
-                    cell.setCellType(CellType.STRING);
-                    cell.setCellValue(String.valueOf(o));
+                    if (StrUtil.isNotBlank(String.valueOf(o))) {
+                        cell.setCellType(CellType.STRING);
+                        cell.setCellValue(String.valueOf(o));
+                    }
                 } else if (o instanceof BigDecimal) {
                     cell.setCellType(CellType.NUMERIC);
                     cell.setCellValue(o == null ? 0 : ((BigDecimal) o).doubleValue());

src/com/engine/salary/util/valid/ValidUtil.java

@@ -250,7 +250,9 @@ public class ValidUtil {
                                 .replace("ｂｅｔｗｅｅｎ", "between")
                                 .replace("ＢＥＴＷＥＥＮ", "BETWEEN")
                                 .replace("ｕｎｉｏｎ", "union")
-                                .replace("ＵＮＩＯＮ", "UNION");
+                                .replace("ＵＮＩＯＮ", "UNION")
+                                .replace("ｓｕｂｓｔｒ", "substr")
+                                .replace("ＳＵＢＳＴＲ", "SUBSTR");
                     }
                     setValue(t, field.getName(), result);
                 } else if (valueTypeEnum == ValueTypeEnum.OBJECT) {

src/com/engine/salary/web/SIAccountController.java

@@ -217,6 +217,38 @@ public class SIAccountController {
         return new ResponseResult<AccountParam, String>(user).run(getService(user)::save, param);
     }
 
+    @POST
+    @Path("/batSave")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batSave(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody AccountBatParam param) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<AccountBatParam, String>(user).run(getService(user)::batSave, param);
+    }
+
+    @POST
+    @Path("/batDelete")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batDelete(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody AccountBatParam param) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<AccountBatParam, String>(user).run(getService(user)::batDelete, param);
+    }
+
+    @POST
+    @Path("/batFile")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batFile(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody AccountBatParam param) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<AccountBatParam, String>(user).run(getService(user)::batFile, param);
+    }
+
+    @POST
+    @Path("/batSocialSecurityBenefitsRecalculate")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batSocialSecurityBenefitsRecalculate(@Context HttpServletRequest request, @Context HttpServletResponse response,@RequestBody AccountBatParam batParam ){
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<AccountBatParam, String>(user).run(getService(user)::batSocialSecurityBenefitsRecalculate,batParam);
+    }
+
 
     /**
      * 正常缴纳页核算

src/com/engine/salary/web/SalaryAcctController.java

@@ -141,6 +141,43 @@ public class SalaryAcctController {
         return new ResponseResult<Long, Long>(user).run(getSalaryAcctRecordWrapper(user)::reCalculate, param.getSalaryAcctRecordId());
     }
 
+    //薪资核算
+    @POST
+    @Path("/batAccounting")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batAccounting(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody SalaryAcctBatParam param) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<SalaryAcctBatParam, String>(user).run(getSalaryAcctRecordWrapper(user)::batCalculate, param);
+    }
+
+    //保存薪资核算的基本信息
+    @POST
+    @Path("/basic/batSave")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batSave(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody SalaryAcctBatParam param) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<SalaryAcctBatParam, Long>(user).run(getSalaryAcctRecordWrapper(user)::batSave, param);
+    }
+
+
+    //归档薪资核算记录
+    @POST
+    @Path("/batFile")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batFile(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody SalaryAcctBatParam param) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<SalaryAcctBatParam, Long>(user).run(getSalaryAcctRecordWrapper(user)::batFile, param);
+    }
+
+    //重新核算
+    @POST
+    @Path("/batReAccounting")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batReAccounting(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody SalaryAcctBatParam param) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<SalaryAcctBatParam, Long>(user).run(getSalaryAcctRecordWrapper(user)::batReCalculate, param);
+    }
+
     //判断是否存在合并计税
     @GET
     @Path("/hasConsolidatedTax")

src/com/engine/salary/web/SalaryBillController.java

@@ -480,6 +480,29 @@ public class SalaryBillController {
         return new ResponseResult<SalarySendWithdrawParam, Map<String, Object>>(user).run(getSalarySendWrapper(user)::withdraw, queryParam);
     }
 
+    @POST
+    @Path("/send/batGrant")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batGrant(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody SalarySendBatParam queryParam) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<SalarySendBatParam, String>(user).run(getSalarySendWrapper(user)::batGrant, queryParam);
+    }
+
+    /**
+     * 工资单撤回
+     *
+     * @param queryParam
+     * @return
+     */
+    @POST
+    @Path("/send/batWithdraw")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batWithdraw(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody SalarySendBatParam queryParam) {
+        User user = HrmUserVarify.getUser(request, response);
+        return new ResponseResult<SalarySendBatParam, String>(user).run(getSalarySendWrapper(user)::batWithdraw, queryParam);
+    }
+
+
     /**
      * 工资单发放详情列表的高级搜索
      *

src/com/engine/salary/web/TaxDeclarationController.java

@@ -4,6 +4,7 @@ import com.engine.common.util.ServiceUtil;
 import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationFormDTO;
 import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationInfoDTO;
 import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationListDTO;
+import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationBatParam;
 import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationDetailListQueryParam;
 import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationListQueryParam;
 import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationSaveParam;
@@ -31,7 +32,6 @@ import javax.ws.rs.core.Response;
 import javax.ws.rs.core.StreamingOutput;
 import java.io.UnsupportedEncodingException;
 import java.net.URLEncoder;
-import java.text.ParseException;
 import java.time.LocalDate;
 
 
@@ -58,10 +58,8 @@ public class TaxDeclarationController {
     @POST
     @Path("/list")
     @Produces(MediaType.APPLICATION_JSON)
-    public String list(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody TaxDeclarationListQueryParam queryParam) throws ParseException {
+    public String list(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody TaxDeclarationListQueryParam queryParam){
         User user = HrmUserVarify.getUser(request, response);
-        queryParam.setFromSalaryMonth(SalaryDateUtil.String2YearMonth(queryParam.getFromSalaryMonthStr() == null ? "" : queryParam.getFromSalaryMonthStr()));
-        queryParam.setEndSalaryMonth(SalaryDateUtil.String2YearMonth(queryParam.getEndSalaryMonthStr() == null ? "" : queryParam.getEndSalaryMonthStr()));
         return new ResponseResult<TaxDeclarationListQueryParam, PageInfo<TaxDeclarationListDTO>>(user).run(getTaxDeclarationWrapper(user)::listPage, queryParam);
     }
 
@@ -102,6 +100,15 @@ public class TaxDeclarationController {
         return new ResponseResult<TaxDeclarationSaveParam, Long>(user).run(getTaxDeclarationWrapper(user)::save, param);
     }
 
+    @POST
+    @Path("/batSave")
+    @Produces(MediaType.APPLICATION_JSON)
+    public String batSave(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody TaxDeclarationBatParam param) {
+        User user = HrmUserVarify.getUser(request, response);
+        param.setSalaryMonth(SalaryDateUtil.String2YearMonth(param.getSalaryMonthStr()));
+        return new ResponseResult<TaxDeclarationBatParam, Long>(user).run(getTaxDeclarationWrapper(user)::batSave, param);
+    }
+
     //个税申报表详情列表
     @POST
     @Path("/detail/list")

src/com/engine/salary/wrapper/AttendQuoteDataWrapper.java

@@ -92,7 +92,7 @@ public class AttendQuoteDataWrapper extends Service {
             attendQuoteFields.stream()
                     .filter(attendQuoteField->effectiveColumns.contains(Util.null2String(attendQuoteField.getId())))
                     .forEach(attendQuoteField -> {
-                        columns.add(Column.builder().title(attendQuoteField.getFieldName())
+                        columns.add(Column.builder().title(Util.formatMultiLang(attendQuoteField.getFieldName(), String.valueOf(user.getLanguage())))
                                 .dataIndex(attendQuoteField.getId() + "_attendQuoteData")
                                 .key(attendQuoteField.getId() + "_attendQuoteData").display(Boolean.TRUE).build());
                     }

src/com/engine/salary/wrapper/SalaryAcctRecordWrapper.java

@@ -10,12 +10,13 @@ import com.engine.salary.entity.salaryacct.bo.SalaryAcctRecordBO;
 import com.engine.salary.entity.salaryacct.dto.SalaryAcctEmployeeCountDTO;
 import com.engine.salary.entity.salaryacct.dto.SalaryAcctRecordFormDTO;
 import com.engine.salary.entity.salaryacct.dto.SalaryAcctRecordListDTO;
+import com.engine.salary.entity.salaryacct.param.SalaryAcctBatParam;
+import com.engine.salary.entity.salaryacct.param.SalaryAcctCalculateParam;
 import com.engine.salary.entity.salaryacct.param.SalaryAcctRecordQueryParam;
 import com.engine.salary.entity.salaryacct.param.SalaryAcctRecordSaveParam;
 import com.engine.salary.entity.salaryacct.po.SalaryAcctRecordPO;
 import com.engine.salary.entity.salaryacct.po.SalaryAcctSobConfigPO;
 import com.engine.salary.entity.salarysob.dto.SalarySobCycleDTO;
-import com.engine.salary.entity.salarysob.po.SalaryApprovalRulePO;
 import com.engine.salary.entity.salarysob.po.*;
 import com.engine.salary.entity.taxagent.po.TaxAgentPO;
 import com.engine.salary.enums.salaryaccounting.SalaryAcctRecordStatusEnum;
@@ -55,6 +56,9 @@ public class SalaryAcctRecordWrapper extends Service implements SalaryAcctRecord
     private SalaryAcctRecordService getSalaryAcctRecordService(User user) {
         return ServiceUtil.getService(SalaryAcctRecordServiceImpl.class, user);
     }
+    private SalaryAcctResultWrapper getSalaryAcctResultWrapper(User user) {
+        return ServiceUtil.getService(SalaryAcctResultWrapper.class, user);
+    }
 
     private SalarySobService getSalarySobService(User user) {
         return ServiceUtil.getService(SalarySobServiceImpl.class, user);
@@ -396,4 +400,28 @@ public class SalaryAcctRecordWrapper extends Service implements SalaryAcctRecord
     public void updateSobConfig(Long id) {
         getSalaryAcctSobConfigService(user).updateBySalaryAcctRecordId(id);
     }
+
+
+    public void batSave(SalaryAcctBatParam param) {
+        getSalaryAcctRecordService(user).batSave(param);
+    }
+
+
+    public void batFile(SalaryAcctBatParam param) {
+        getSalaryAcctRecordService(user).batFile(param);
+    }
+
+    public void batReCalculate(SalaryAcctBatParam param) {
+        getSalaryAcctRecordService(user).batReCalculate(param);
+
+    }
+
+    public void batCalculate(SalaryAcctBatParam param) {
+        List<Long> salaryAcctRecordIds = param.getSalaryAcctRecordIds();
+        for (int i = 0; i < salaryAcctRecordIds.size(); i++) {
+            Long recordId = salaryAcctRecordIds.get(i);
+            SalaryAcctCalculateParam calculateParam = SalaryAcctCalculateParam.builder().salaryAcctRecordId(recordId).build();
+            getSalaryAcctResultWrapper(user).calculate(calculateParam);
+        }
+    }
 }

src/com/engine/salary/wrapper/SalaryArchiveWrapper.java

@@ -541,9 +541,6 @@ public class SalaryArchiveWrapper extends Service {
         return map;
     }
 
-    public Map<String, Object> selectSalaryArchiveColumns(String importType) {
-        return getSalaryArchiveService(user).selectSalaryArchiveColumns(SalaryArchiveImportTypeEnum.parseByValue(importType));
-    }
 
 
     public Map<String, Object> checkSalaryArchiveInit(SalaryArchiveImportActionParam importData) {

src/com/engine/salary/wrapper/SalarySendWrapper.java

@@ -130,9 +130,9 @@ public class SalarySendWrapper extends Service implements SalarySendWrapperProxy
 
             list.stream().forEach(dto -> {
                 // 回算过，但是查看的是普通工资单（不能查看详情）;回算过，但是查看的是回算工资单（可以发）；记录没回算过（可以发）
-                if(Objects.equals(dto.getSalaryAcctRecordType(), NumberUtils.INTEGER_ONE) &&  Objects.equals(dto.getSalaryAcctType(),NumberUtils.INTEGER_ZERO)){
+                if (Objects.equals(dto.getSalaryAcctRecordType(), NumberUtils.INTEGER_ONE) && Objects.equals(dto.getSalaryAcctType(), NumberUtils.INTEGER_ZERO)) {
                     dto.setCanSeeDetail(false);
-                }else{
+                } else {
                     dto.setCanSeeDetail(true);
                 }
             });
@@ -155,7 +155,7 @@ public class SalarySendWrapper extends Service implements SalarySendWrapperProxy
                         e.setTemplate(NumberUtils.INTEGER_ONE.equals(e.getSalaryAcctType()) ? salaryTemplatePO.getReplenishName() : salaryTemplatePO.getName());
                         e.setTemplateId(salaryTemplatePO.getId());
                         if ((salaryTemplatePO.getAckFeedbackStatus() != null && salaryTemplatePO.getAckFeedbackStatus() == 1) ||
-                                (salaryTemplatePO.getFeedbackStatus() != null && salaryTemplatePO.getFeedbackStatus() == 1)  ) {
+                                (salaryTemplatePO.getFeedbackStatus() != null && salaryTemplatePO.getFeedbackStatus() == 1)) {
                             e.setAckFeedbackStatus(1);
                         } else {
                             e.setAckFeedbackStatus(0);
@@ -701,6 +701,7 @@ public class SalarySendWrapper extends Service implements SalarySendWrapperProxy
 
     /**
      * 发送短信验证码
+     *
      * @param param 短信验证码发送参数
      */
     public void sendMobileCode(SMSCodeSendParam param) {
@@ -709,6 +710,7 @@ public class SalarySendWrapper extends Service implements SalarySendWrapperProxy
 
     /**
      * 校验短信验证码
+     *
      * @param param
      * @return
      */
@@ -719,7 +721,7 @@ public class SalarySendWrapper extends Service implements SalarySendWrapperProxy
     public PayrollCheckTypeEnum payrollCheckType() {
         SalarySysConfPO conf = getSalarySysConfService(user).getOneByCode(SalarySysConstant.SALARY_PAYROLL_CHECK_TYPE);
 
-        if(conf == null){
+        if (conf == null) {
             return PayrollCheckTypeEnum.PWD;
         }
 
@@ -727,14 +729,14 @@ public class SalarySendWrapper extends Service implements SalarySendWrapperProxy
     }
 
     public void confirmSalaryBill(Long salaryInfoId) {
-        if(ObjectUtil.isNull(salaryInfoId)){
+        if (ObjectUtil.isNull(salaryInfoId)) {
             throw new SalaryRunTimeException("工资单id不能为空！");
         }
         getSalaryBillService(user).confirmSalaryBill(salaryInfoId);
     }
 
     public void feedBackSalaryBill(Long salaryInfoId) {
-        if(ObjectUtil.isNull(salaryInfoId)){
+        if (ObjectUtil.isNull(salaryInfoId)) {
             throw new SalaryRunTimeException("工资单id不能为空！");
         }
         getSalaryBillService(user).feedBackSalaryBill(salaryInfoId);
@@ -751,4 +753,50 @@ public class SalarySendWrapper extends Service implements SalarySendWrapperProxy
     public String genPdfBeforeExport(SalaryExportPdfParam salaryExportPdfParam) {
         return getSalaryBillService(user).genPdfBeforeExport(salaryExportPdfParam);
     }
+
+
+    public String batGrant(SalarySendBatParam param) {
+        List<Long> salarySendIds = param.getSalarySendIds();
+
+        int successCount = 0;
+        int failCount = 0;
+        String failMsg = "";
+        for (int i = 0; i < salarySendIds.size(); i++) {
+            try {
+                Long sendId = salarySendIds.get(i);
+                SalarySendGrantParam grantParam = SalarySendGrantParam.builder()
+                        .salarySendId(sendId)
+                        .build();
+                grant(grantParam);
+                successCount++;
+            } catch (Exception e) {
+                failCount++;
+                failMsg = failMsg + "第" + (i + 1) + "个发放失败！失败原因：" + e.getMessage() + "\n";
+            }
+        }
+
+        return String.format("成功：" + successCount + "个，失败：" + failCount + "个%s", failCount == 0 ? "" : "，失败原因：" + failMsg);
+    }
+
+    public String batWithdraw(SalarySendBatParam param) {
+        List<Long> salarySendIds = param.getSalarySendIds();
+
+        int successCount = 0;
+        int failCount = 0;
+        String failMsg = "";
+        for (int i = 0; i < salarySendIds.size(); i++) {
+            try {
+                Long sendId = salarySendIds.get(i);
+                SalarySendWithdrawParam grantParam = SalarySendWithdrawParam.builder()
+                        .salarySendId(sendId)
+                        .build();
+                withdraw(grantParam);
+            } catch (Exception e) {
+                failCount++;
+                failMsg = failMsg + "第" + (i + 1) + "个撤回失败！失败原因：" + e.getMessage() + "\n";
+            }
+
+        }
+        return String.format("成功：" + successCount + "个，失败：" + failCount + "个%s", failCount == 0 ? "" : "，失败原因：" + failMsg);
+    }
 }

src/com/engine/salary/wrapper/SalarySobRangeWrapper.java

@@ -97,7 +97,10 @@ public class SalarySobRangeWrapper extends Service {
                                 .replace("ｂｅｔｗｅｅｎ", "between")
                                 .replace("ＢＥＴＷＥＥＮ", "BETWEEN")
                                 .replace("ｕｎｉｏｎ", "union")
-                                .replace("ＵＮＩＯＮ", "UNION"));
+                                .replace("ＵＮＩＯＮ", "UNION")
+                                .replace("ｓｕｂｓｔｒ", "substr")
+                                .replace("ＳＵＢＳＴＲ", "SUBSTR")
+                        );
                     }
                 });
 
@@ -127,7 +130,10 @@ public class SalarySobRangeWrapper extends Service {
                                 .replace("ｂｅｔｗｅｅｎ", "between")
                                 .replace("ＢＥＴＷＥＥＮ", "BETWEEN")
                                 .replace("ｕｎｉｏｎ", "union")
-                                .replace("ＵＮＩＯＮ", "UNION"));
+                                .replace("ＵＮＩＯＮ", "UNION")
+                                .replace("ｓｕｂｓｔｒ", "substr")
+                                .replace("ＳＵＢＳＴＲ", "SUBSTR")
+                        );
                     }
                 });
 

src/com/engine/salary/wrapper/TaxAgentWrapper.java

@@ -365,7 +365,10 @@ public class TaxAgentWrapper extends Service {
                                 .replace("ｂｅｔｗｅｅｎ", "between")
                                 .replace("ＢＥＴＷＥＥＮ", "BETWEEN")
                                 .replace("ｕｎｉｏｎ", "union")
-                                .replace("ＵＮＩＯＮ", "UNION"));
+                                .replace("ＵＮＩＯＮ", "UNION")
+                                .replace("ｓｕｂｓｔｒ", "substr")
+                                .replace("ＳＵＢＳＴＲ", "SUBSTR")
+                        );
                     }
                 });
 
@@ -399,7 +402,10 @@ public class TaxAgentWrapper extends Service {
                                 .replace("ｂｅｔｗｅｅｎ", "between")
                                 .replace("ＢＥＴＷＥＥＮ", "BETWEEN")
                                 .replace("ｕｎｉｏｎ", "union")
-                                .replace("ＵＮＩＯＮ", "UNION"));
+                                .replace("ＵＮＩＯＮ", "UNION")
+                                .replace("ｓｕｂｓｔｒ", "substr")
+                                .replace("ＳＵＢＳＴＲ", "SUBSTR")
+                        );
                     }
                 });
 

src/com/engine/salary/wrapper/TaxDeclarationWrapper.java

@@ -9,6 +9,7 @@ import com.engine.salary.entity.taxdeclaration.bo.TaxDeclarationBO;
 import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationFormDTO;
 import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationInfoDTO;
 import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationListDTO;
+import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationBatParam;
 import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationListQueryParam;
 import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationSaveParam;
 import com.engine.salary.entity.taxdeclaration.po.TaxDeclarationPO;
@@ -158,4 +159,20 @@ public class TaxDeclarationWrapper extends Service {
     public void withDrawTaxDeclaration(Long taxDeclarationId) {
         getTaxDeclarationService(user).withDrawTaxDeclaration(taxDeclarationId);
     }
+
+    public void batSave(TaxDeclarationBatParam param) {
+        List<Long> taxAgentIds = param.getTaxAgentIds();
+        for (int i = 0; i < taxAgentIds.size(); i++) {
+            Long taxAgentId = taxAgentIds.get(i);
+            TaxDeclarationSaveParam saveParam = TaxDeclarationSaveParam.builder()
+                    .salaryMonth(param.getSalaryMonth())
+                    .taxAgentId(taxAgentId)
+                    .description(param.getDescription())
+                    .taxCycle(param.getTaxCycle())
+                    .salaryDate(param.getSalaryDate())
+                    .build();
+            save(saveParam);
+        }
+
+    }
 }