fieldMap = Arrays.stream(properties).collect(Collectors.toMap(Property::getName,
- property -> Util.null2String(property.getValue())));
- String salaryAcctRecordId = fieldMap.get(salaryAcctRecordIdField);
- if (!NumberUtil.isNumber(salaryAcctRecordId)) {
- requestInfo.getRequestManager().setMessage("核算记录id不为数字");
- return FAILURE_AND_CONTINUE;
- }
- User user = new User();
- user.setUid(1);
- user.setLoginid("sysadmin");
- SalaryAcctRecordPO salaryAcctRecordPO = getSalaryAcctRecordService(user).getById(Long.valueOf(salaryAcctRecordId));
- if (salaryAcctRecordPO == null) {
- requestInfo.getRequestManager().setMessage("核算记录不存在或已被删除");
- return FAILURE_AND_CONTINUE;
- }
- salaryAcctRecordPO.setApprovalStatus(status);
- getSalaryAcctRecordMapper().updateIgnoreNull(salaryAcctRecordPO);
- } catch (Exception e) {
- log.error("审批状态更新失败", e);
- requestInfo.getRequestManager().setMessage(e.getMessage());
- return FAILURE_AND_CONTINUE;
- }
- return SUCCESS;
- }
-}
diff --git a/src/com/engine/salary/annotation/Auth.java b/src/com/engine/salary/annotation/Auth.java
deleted file mode 100644
index 78cc19097..000000000
--- a/src/com/engine/salary/annotation/Auth.java
+++ /dev/null
@@ -1,29 +0,0 @@
-package com.engine.salary.annotation;
-
-import com.engine.salary.enums.auth.AuthCheckTypeEnum;
-
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * 权限验证字段
- * Copyright: Copyright (c) 2022
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target(ElementType.TYPE)
-@Retention(RetentionPolicy.RUNTIME)
-public @interface Auth {
- String page();
-
- AuthCheckTypeEnum checkType() default AuthCheckTypeEnum.TAX_EMP;
-
- String taxAgentIdField() default "taxAgentId";
- String employeeIdField() default "employeeId";
- String sobIdField() default "salarySobId";
- String optsField() default "opts";
-}
diff --git a/src/com/engine/salary/annotation/AuthField.java b/src/com/engine/salary/annotation/AuthField.java
deleted file mode 100644
index b51cd44f3..000000000
--- a/src/com/engine/salary/annotation/AuthField.java
+++ /dev/null
@@ -1,22 +0,0 @@
-package com.engine.salary.annotation;
-
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * 权限验证字段
- * Copyright: Copyright (c) 2022
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target(ElementType.FIELD)
-@Retention(RetentionPolicy.RUNTIME)
-public @interface AuthField {
-
- String fieldType();
-
-}
diff --git a/src/com/engine/salary/annotation/AuthOpt.java b/src/com/engine/salary/annotation/AuthOpt.java
deleted file mode 100644
index e4ffcb499..000000000
--- a/src/com/engine/salary/annotation/AuthOpt.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package com.engine.salary.annotation;
-
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * 权限验证字段
- * Copyright: Copyright (c) 2022
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target(ElementType.FIELD)
-@Retention(RetentionPolicy.RUNTIME)
-public @interface AuthOpt {
-
-}
diff --git a/src/com/engine/salary/annotation/Encrypt.java b/src/com/engine/salary/annotation/Encrypt.java
deleted file mode 100644
index c61e1de44..000000000
--- a/src/com/engine/salary/annotation/Encrypt.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package com.engine.salary.annotation;
-
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * 加密字段，用于标注需加解密的字段
- * Copyright: Copyright (c) 2022
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target(ElementType.FIELD)
-@Retention(RetentionPolicy.RUNTIME)
-public @interface Encrypt {
-
-}
diff --git a/src/com/engine/salary/annotation/I18n.java b/src/com/engine/salary/annotation/I18n.java
deleted file mode 100644
index ca9b71fd8..000000000
--- a/src/com/engine/salary/annotation/I18n.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package com.engine.salary.annotation;
-
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * 国际化标识
- * Copyright: Copyright (c) 2024
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target(ElementType.FIELD)
-@Retention(RetentionPolicy.RUNTIME)
-public @interface I18n {
-
-}
diff --git a/src/com/engine/salary/annotation/SalaryFormulaVar.java b/src/com/engine/salary/annotation/SalaryFormulaVar.java
deleted file mode 100644
index 2e3077158..000000000
--- a/src/com/engine/salary/annotation/SalaryFormulaVar.java
+++ /dev/null
@@ -1,27 +0,0 @@
-package com.engine.salary.annotation;
-
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * 薪资公式计算器-变量
- * Copyright: Copyright (c) 2022
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target({ElementType.FIELD})
-@Retention(RetentionPolicy.RUNTIME)
-public @interface SalaryFormulaVar {
-
- int labelId();
-
- String defaultLabel();
-
- String dataType();
-
- String fieldId() default "";
-}
diff --git a/src/com/engine/salary/annotation/SalaryTable.java b/src/com/engine/salary/annotation/SalaryTable.java
deleted file mode 100644
index ef0b19884..000000000
--- a/src/com/engine/salary/annotation/SalaryTable.java
+++ /dev/null
@@ -1,69 +0,0 @@
-package com.engine.salary.annotation;
-
-
-import com.cloudstore.eccom.pc.table.WeaTableType;
-
-import java.lang.annotation.*;
-
-/**
- * 数据列表
- * Copyright: Copyright (c) 2022
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Documented
-public @interface SalaryTable {
-
- String pageId() default "";
-
- /**
- * 数据库字段，以','分割,例如:"id, name, description"
- */
- String fields() default "";
-
- /**
- * 表名 ,例如:"FROM hrsa_tax_agent"
- */
- String fromSql() default "";
-
- /**
- * 条件
- */
- String where() default "";
-
- /**
- * 分组
- */
- String groupby() default "";
-
-
- /**
- * 排序
- */
- String orderby() default "";
-
- /**
- * 主键
- */
- String primarykey() default "";
-
- /**
- * 去重
- */
- boolean distinct() default false;
-
- /**
- * 操作按钮
- */
- SalaryTableOperate[] operates() default {};
-
- /**
- * 列表选择框
- */
- WeaTableType tableType() default WeaTableType.NONE;
-
-}
diff --git a/src/com/engine/salary/annotation/SalaryTableColumn.java b/src/com/engine/salary/annotation/SalaryTableColumn.java
deleted file mode 100644
index 94d93a5cf..000000000
--- a/src/com/engine/salary/annotation/SalaryTableColumn.java
+++ /dev/null
@@ -1,34 +0,0 @@
-package com.engine.salary.annotation;
-
-import java.lang.annotation.*;
-
-/**
- * 数据列表表头
- * Copyright: Copyright (c) 2022
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target({ElementType.FIELD})
-@Retention(RetentionPolicy.RUNTIME)
-@Documented
-public @interface SalaryTableColumn {
-
- String text() default "";
-
- int labelId() default -1;
-
- String width() default "";
-
- String column() default "";
-
- boolean display() default true;
-
- String orderkey() default "";
-
- String transmethod() default "";
-
- // 额外参数
- String otherPara() default "";
-}
diff --git a/src/com/engine/salary/annotation/SalaryTableOperate.java b/src/com/engine/salary/annotation/SalaryTableOperate.java
deleted file mode 100644
index f9f69c16b..000000000
--- a/src/com/engine/salary/annotation/SalaryTableOperate.java
+++ /dev/null
@@ -1,27 +0,0 @@
-package com.engine.salary.annotation;
-
-import java.lang.annotation.*;
-
-/**
- * 列表操作按钮
- * Copyright: Copyright (c) 2022
- * Company: 泛微软件
- *
- * @author qiantao
- * @version 1.0
- **/
-@Target({ElementType.ANNOTATION_TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Documented
-public @interface SalaryTableOperate {
-
- String text() default "";
-
- int labelId() default -1;
-
- String href() default "";
-
- String index() default "0";
-
-
-}
diff --git a/src/com/engine/salary/annotation/TableTitle.java b/src/com/engine/salary/annotation/TableTitle.java
deleted file mode 100644
index 427aa8862..000000000
--- a/src/com/engine/salary/annotation/TableTitle.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package com.engine.salary.annotation;
-
-import java.lang.annotation.*;
-
-@Target({ElementType.FIELD})
-@Retention(RetentionPolicy.RUNTIME)
-@Documented
-public @interface TableTitle {
- String title();
- String dataIndex();
- String key();
- boolean display() default true;
-}
diff --git a/src/com/engine/salary/biz/AddUpDeductionBiz.java b/src/com/engine/salary/biz/AddUpDeductionBiz.java
deleted file mode 100644
index 3e7f8330c..000000000
--- a/src/com/engine/salary/biz/AddUpDeductionBiz.java
+++ /dev/null
@@ -1,171 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.encrypt.EncryptUtil;
-import com.engine.salary.entity.datacollection.AddUpDeduction;
-import com.engine.salary.entity.datacollection.dto.AddUpDeductionDTO;
-import com.engine.salary.entity.datacollection.dto.AddUpDeductionRecordDTO;
-import com.engine.salary.entity.datacollection.param.AddUpDeductionQueryParam;
-import com.engine.salary.mapper.datacollection.AddUpDeductionMapper;
-import com.engine.salary.util.SalaryI18nUtil;
-import com.google.common.collect.Lists;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-import weaver.general.BaseBean;
-
-import java.util.ArrayList;
-import java.util.List;
-
-public class AddUpDeductionBiz extends BaseBean {
-
- private final EncryptUtil encryptUtil = new EncryptUtil();
-
-
- /**
- * 关联查询查询列表
- *
- * @param param
- * @return
- */
- public List list(AddUpDeductionQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpDeductionMapper mapper = sqlSession.getMapper(AddUpDeductionMapper.class);
- List list = mapper.list(param);
- encryptUtil.decryptList(list, AddUpDeductionDTO.class);
- SalaryI18nUtil.i18nList(list);
- return list;
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 条件查询
- *
- * @param param
- * @return
- */
- public List listSome(AddUpDeduction param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpDeductionMapper mapper = sqlSession.getMapper(AddUpDeductionMapper.class);
- if (CollectionUtils.isNotEmpty(param.getEmployeeIds())) {
- List addUpDeductions = new ArrayList<>();
- List> partition = Lists.partition(param.getEmployeeIds(), 500);
- partition.forEach(l -> {
- param.setEmployeeIds(l);
- addUpDeductions.addAll(mapper.listSome(param));
- });
- return encryptUtil.decryptList(addUpDeductions, AddUpDeduction.class);
- } else {
- List addUpDeductions = mapper.listSome(param);
- return encryptUtil.decryptList(addUpDeductions, AddUpDeduction.class);
- }
- } finally {
- sqlSession.close();
- }
- }
-
-
- /**
- * 根据id获取
- *
- * @param id
- * @return
- */
- public AddUpDeduction getById(Long id) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpDeductionMapper mapper = sqlSession.getMapper(AddUpDeductionMapper.class);
- AddUpDeduction byId = mapper.getById(id);
- return encryptUtil.decrypt(byId, AddUpDeduction.class);
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 详情列表
- *
- * @param param
- * @return
- */
- public List recordList(AddUpDeductionQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpDeductionMapper mapper = sqlSession.getMapper(AddUpDeductionMapper.class);
- List addUpDeductionRecordStrDTOS = mapper.recordList(param);
- encryptUtil.decryptList(addUpDeductionRecordStrDTOS, AddUpDeductionRecordDTO.class);
- SalaryI18nUtil.i18nList(addUpDeductionRecordStrDTOS);
- return addUpDeductionRecordStrDTOS;
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 批量插入
- *
- * @param param
- * @return
- */
- public void batchSave(List param) {
- if (CollectionUtils.isEmpty(param)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpDeductionMapper mapper = sqlSession.getMapper(AddUpDeductionMapper.class);
- encryptUtil.encryptList(param, AddUpDeduction.class);
- List> partition = Lists.partition(param, 100);
- partition.forEach(mapper::insertData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 批量插入
- *
- * @param param
- * @return
- */
- public void batchUpdate(List param) {
- if (CollectionUtils.isEmpty(param)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpDeductionMapper mapper = sqlSession.getMapper(AddUpDeductionMapper.class);
- encryptUtil.encryptList(param, AddUpDeduction.class);
- List> partition = Lists.partition(param, 100);
- partition.forEach(mapper::updateData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
-
-
-
-
- public void batchDeleteByIDS(List ids) {
- if (CollectionUtils.isEmpty(ids)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpDeductionMapper mapper = sqlSession.getMapper(AddUpDeductionMapper.class);
- List> partition = Lists.partition(ids, 100);
- partition.forEach(mapper::deleteData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
-
-}
diff --git a/src/com/engine/salary/biz/AddUpSituationBiz.java b/src/com/engine/salary/biz/AddUpSituationBiz.java
deleted file mode 100644
index 41068ef88..000000000
--- a/src/com/engine/salary/biz/AddUpSituationBiz.java
+++ /dev/null
@@ -1,191 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.encrypt.EncryptUtil;
-import com.engine.salary.entity.datacollection.AddUpSituation;
-import com.engine.salary.entity.datacollection.dto.AddUpSituationRecordDTO;
-import com.engine.salary.entity.datacollection.param.AddUpSituationQueryParam;
-import com.engine.salary.mapper.datacollection.AddUpSituationMapper;
-import com.google.common.collect.Lists;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-import weaver.general.BaseBean;
-
-import java.util.*;
-import java.util.stream.Collectors;
-
-public class AddUpSituationBiz extends BaseBean {
-
- private EncryptUtil encryptUtil = new EncryptUtil();
-
-
- /**
- * 条件查询
- *
- * @param param
- * @return
- */
- public List listSome(AddUpSituation param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpSituationMapper mapper = sqlSession.getMapper(AddUpSituationMapper.class);
- if (CollectionUtils.isNotEmpty(param.getEmployeeIds())) {
- List addUpSituations = new ArrayList<>();
- List> partition = Lists.partition((List) param.getEmployeeIds(), 500);
- partition.forEach(l -> {
- param.setEmployeeIds(l);
- addUpSituations.addAll(mapper.listSome(param));
- });
- return encryptUtil.decryptList(addUpSituations, AddUpSituation.class);
- } else {
- List addUpSituations = mapper.listSome(param);
- return encryptUtil.decryptList(addUpSituations, AddUpSituation.class);
- }
- } finally {
- sqlSession.close();
- }
- }
-
-
- /**
- * 根据id获取
- *
- * @param id
- * @return
- */
- public AddUpSituation getById(Long id) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpSituationMapper mapper = sqlSession.getMapper(AddUpSituationMapper.class);
- AddUpSituation byId = mapper.getById(id);
- return encryptUtil.decrypt(byId, AddUpSituation.class);
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 详情列表
- *
- * @param param
- * @return
- */
- public List recordList(AddUpSituationQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpSituationMapper mapper = sqlSession.getMapper(AddUpSituationMapper.class);
- List addUpSituationRecordDTOS = mapper.recordList(param);
- return encryptUtil.decryptList(addUpSituationRecordDTOS, AddUpSituationRecordDTO.class);
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 批量插入
- *
- * @param param
- * @return
- */
- public void batchSave(List param) {
- if (CollectionUtils.isEmpty(param)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpSituationMapper mapper = sqlSession.getMapper(AddUpSituationMapper.class);
- encryptUtil.encryptList(param, AddUpSituation.class);
- List> partition = Lists.partition(param, 50);
- partition.forEach(mapper::insertData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 批量插入
- *
- * @param param
- * @return
- */
- public void batchUpdate(List param) {
- if (CollectionUtils.isEmpty(param)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpSituationMapper mapper = sqlSession.getMapper(AddUpSituationMapper.class);
- encryptUtil.encryptList(param, AddUpSituation.class);
- List> partition = Lists.partition(param, 50);
- partition.forEach(mapper::updateData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
-
- public void handleImportData(List pos) {
- if (CollectionUtils.isEmpty(pos)) {
- return;
- }
- AddUpSituation po = pos.get(0);
- // 多条相同人的则以第一条为准，如果逆序排列（用于重复的则以最后一条为准）Collections.reverse(pos);
- // 去重（通过记录的唯一条件(申报月份，人员id，个税扣缴义务人id)拼接）
- List finalPos = pos.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(f -> f.getEmployeeId() + "-" + f.getTaxAgentId()))), ArrayList::new));
- // 查询已有数据
- List list = listSome(AddUpSituation.builder().taxYearMonth(po.getTaxYearMonth()).build());
- // 待修改的 本地已存在则更新【交集】
- List updateList = list.stream().map(m -> {
- Optional optional = finalPos.stream().filter(p -> (p.getEmployeeId() + "-" + p.getTaxAgentId()).equals(m.getEmployeeId() + "-" + m.getTaxAgentId())).findFirst();
- AddUpSituation temp = null;
- if (optional.isPresent()) {
- temp = optional.get();
- // 换成本地库的id
- temp.setId(m.getId());
- }
- return temp;
- }).filter(Objects::nonNull).collect(Collectors.toList());
- // 待新增的 导入比本地多，则新增【差集(导入 - local)】
- List saveList = finalPos.stream().map(m -> {
- Optional optional = list.stream().filter(p -> (p.getEmployeeId() + "-" + p.getTaxAgentId()).equals(m.getEmployeeId() + "-" + m.getTaxAgentId())).findFirst();
- AddUpSituation temp = null;
- if (!optional.isPresent()) {
- temp = m;
- }
- return temp;
- }).filter(Objects::nonNull).collect(Collectors.toList());
-
- // 修改
- if (CollectionUtils.isNotEmpty(updateList)) {
- batchUpdate(updateList);
- }
- // 保存
- if (CollectionUtils.isNotEmpty(saveList)) {
- batchSave(saveList);
- }
- }
-
-
- /**
- * @return void
- * @description 批量删除数据
- * @author Harryxzy
- * @date 2022/10/27 22:39
- */
- public void batchDeleteByIDS(List deleteIds) {
- if (CollectionUtils.isEmpty(deleteIds)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AddUpSituationMapper mapper = sqlSession.getMapper(AddUpSituationMapper.class);
- List> partition = Lists.partition(deleteIds, 100);
- partition.forEach(mapper::deleteData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-}
diff --git a/src/com/engine/salary/biz/AttendQuoteBiz.java b/src/com/engine/salary/biz/AttendQuoteBiz.java
deleted file mode 100644
index f4a2dc2bb..000000000
--- a/src/com/engine/salary/biz/AttendQuoteBiz.java
+++ /dev/null
@@ -1,66 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.entity.datacollection.dto.AttendQuoteListDTO;
-import com.engine.salary.entity.datacollection.param.AttendQuoteQueryParam;
-import com.engine.salary.entity.datacollection.po.AttendQuotePO;
-import com.engine.salary.mapper.datacollection.AttendQuoteMapper;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-
-import java.util.List;
-
-public class AttendQuoteBiz {
-
- public List list(AttendQuoteQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteMapper mapper = sqlSession.getMapper(AttendQuoteMapper.class);
- return mapper.list(param);
- } finally {
- sqlSession.close();
- }
- }
-
- public void deleteByIds(List unAccountingIds) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteMapper mapper = sqlSession.getMapper(AttendQuoteMapper.class);
- mapper.deleteByIds(unAccountingIds);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- public List listSome(AttendQuotePO param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteMapper mapper = sqlSession.getMapper(AttendQuoteMapper.class);
- return mapper.listSome(param);
- } finally {
- sqlSession.close();
- }
- }
-
- public void updateById(AttendQuotePO attendQuote) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteMapper mapper = sqlSession.getMapper(AttendQuoteMapper.class);
- mapper.updateIgnoreNull(attendQuote);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- public void insert(AttendQuotePO attendQuote) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteMapper mapper = sqlSession.getMapper(AttendQuoteMapper.class);
- mapper.insertIgnoreNull(attendQuote);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-}
diff --git a/src/com/engine/salary/biz/AttendQuoteDataBiz.java b/src/com/engine/salary/biz/AttendQuoteDataBiz.java
deleted file mode 100644
index f3b456fdf..000000000
--- a/src/com/engine/salary/biz/AttendQuoteDataBiz.java
+++ /dev/null
@@ -1,67 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.entity.datacollection.dto.AttendQuoteDataBaseDTO;
-import com.engine.salary.entity.datacollection.param.AttendQuoteDataQueryParam;
-import com.engine.salary.entity.datacollection.po.AttendQuoteDataPO;
-import com.engine.salary.mapper.datacollection.AttendQuoteDataMapper;
-import com.engine.salary.util.SalaryI18nUtil;
-import com.google.common.collect.Lists;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-
-import java.util.List;
-
-public class AttendQuoteDataBiz {
-
- public List list(AttendQuoteDataQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataMapper mapper = sqlSession.getMapper(AttendQuoteDataMapper.class);
- List list = mapper.list(param);
- return SalaryI18nUtil.i18nList(list);
- } finally {
- sqlSession.close();
- }
- }
-
- public List listSome(AttendQuoteDataQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataMapper mapper = sqlSession.getMapper(AttendQuoteDataMapper.class);
- return mapper.listSome(param);
- } finally {
- sqlSession.close();
- }
- }
-
-
-
- public void deleteByAttendQuoteIds(List unAccountingIds) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataMapper mapper = sqlSession.getMapper(AttendQuoteDataMapper.class);
- mapper.deleteByAttendQuoteIds(unAccountingIds);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
-
- }
-
- public void insertData(List pos) {
- if(CollectionUtils.isEmpty(pos)){
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataMapper mapper = sqlSession.getMapper(AttendQuoteDataMapper.class);
- List> partition = Lists.partition(pos, 100);
- partition.forEach(mapper::insertData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
-}
diff --git a/src/com/engine/salary/biz/AttendQuoteDataValueBiz.java b/src/com/engine/salary/biz/AttendQuoteDataValueBiz.java
deleted file mode 100644
index f80b1aa36..000000000
--- a/src/com/engine/salary/biz/AttendQuoteDataValueBiz.java
+++ /dev/null
@@ -1,93 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.entity.datacollection.po.AttendQuoteDataValuePO;
-import com.engine.salary.mapper.datacollection.AttendQuoteDataValueMapper;
-import com.google.common.collect.Lists;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-
-import java.util.ArrayList;
-import java.util.List;
-
-public class AttendQuoteDataValueBiz {
-
- /**
- * 根据考勤引用字段表的主键id删除
- *
- * @param attendQuoteDataIds
- */
- public void deleteByAttendQuoteDataIds(List attendQuoteDataIds) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataValueMapper mapper = sqlSession.getMapper(AttendQuoteDataValueMapper.class);
- List> partition = Lists.partition(attendQuoteDataIds, 500);
- partition.forEach(mapper::deleteByAttendQuoteDataIds);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
-
- public List listSome(AttendQuoteDataValuePO param) {
- List list = new ArrayList<>();
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataValueMapper mapper = sqlSession.getMapper(AttendQuoteDataValueMapper.class);
-
- List employeeIds = param.getEmployeeIds();
- if (CollectionUtils.isNotEmpty(employeeIds)) {
- List> partition = Lists.partition(employeeIds, 100);
- partition.forEach(empIds -> {
- param.setEmployeeIds(empIds);
- list.addAll(mapper.listSome(param));
- });
- } else {
- list.addAll(mapper.listSome(param));
- }
- } finally {
- sqlSession.close();
- }
- return list;
- }
-
- public void insertData(List values) {
- if (CollectionUtils.isEmpty(values)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataValueMapper mapper = sqlSession.getMapper(AttendQuoteDataValueMapper.class);
- List> partition = Lists.partition(values, 100);
- partition.forEach(mapper::insertData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- public void deleteByAttendQuoteIds(List quoteIds) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataValueMapper mapper = sqlSession.getMapper(AttendQuoteDataValueMapper.class);
- mapper.deleteByAttendIds(quoteIds);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- public void updateDataValue(AttendQuoteDataValuePO po) {
-
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteDataValueMapper mapper = sqlSession.getMapper(AttendQuoteDataValueMapper.class);
- mapper.updateDataValueByFiledIdAndEmployeeId(po);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
-
- }
-}
diff --git a/src/com/engine/salary/biz/AttendQuoteFieldBiz.java b/src/com/engine/salary/biz/AttendQuoteFieldBiz.java
deleted file mode 100644
index 70d7c72fb..000000000
--- a/src/com/engine/salary/biz/AttendQuoteFieldBiz.java
+++ /dev/null
@@ -1,108 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.entity.datacollection.dto.AttendQuoteFieldListDTO;
-import com.engine.salary.entity.datacollection.param.AttendQuoteFieldQueryParam;
-import com.engine.salary.entity.datacollection.po.AttendQuoteFieldPO;
-import com.engine.salary.mapper.datacollection.AttendQuoteFieldMapper;
-import com.google.common.collect.Lists;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-
-import java.util.Collection;
-import java.util.List;
-
-public class AttendQuoteFieldBiz {
-
- public List listSome(AttendQuoteFieldPO param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteFieldMapper mapper = sqlSession.getMapper(AttendQuoteFieldMapper.class);
- return mapper.listSome(param);
- } finally {
- sqlSession.close();
- }
- }
-
- public void save(AttendQuoteFieldPO po) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteFieldMapper mapper = sqlSession.getMapper(AttendQuoteFieldMapper.class);
- mapper.insertIgnoreNull(po);
-
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- public AttendQuoteFieldPO getById(Long id) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteFieldMapper mapper = sqlSession.getMapper(AttendQuoteFieldMapper.class);
- return mapper.getById(id);
- } finally {
- sqlSession.close();
- }
- }
-
- public void update(AttendQuoteFieldPO po) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteFieldMapper mapper = sqlSession.getMapper(AttendQuoteFieldMapper.class);
- mapper.updateIgnoreNull(po);
-
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
-
- }
-
- public List list(AttendQuoteFieldQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteFieldMapper mapper = sqlSession.getMapper(AttendQuoteFieldMapper.class);
- return mapper.list(param);
- } finally {
- sqlSession.close();
- }
- }
-
- public void deleteByIds(Collection ids) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteFieldMapper mapper = sqlSession.getMapper(AttendQuoteFieldMapper.class);
- mapper.deleteByIds(ids);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- public void saveBatch(List saves) {
- if(CollectionUtils.isEmpty(saves)){
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteFieldMapper mapper = sqlSession.getMapper(AttendQuoteFieldMapper.class);
- List> partition = Lists.partition(saves, 100);
- partition.forEach(mapper::saveBatch);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- public void deleteAttendByCode(AttendQuoteFieldQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteFieldMapper mapper = sqlSession.getMapper(AttendQuoteFieldMapper.class);
- mapper.deleteAttendByCode(param);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-}
diff --git a/src/com/engine/salary/biz/AttendQuoteFieldSettingBiz.java b/src/com/engine/salary/biz/AttendQuoteFieldSettingBiz.java
deleted file mode 100644
index 28266a88b..000000000
--- a/src/com/engine/salary/biz/AttendQuoteFieldSettingBiz.java
+++ /dev/null
@@ -1,46 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.entity.datacollection.po.AttendQuoteFieldSettingPO;
-import com.engine.salary.enums.datacollection.AttendQuoteSourceTypeEnum;
-import com.engine.salary.mapper.datacollection.AttendQuoteSyncSetMapper;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-
-import java.util.List;
-
-public class AttendQuoteFieldSettingBiz {
- public List getAttendQuoteFieldSetting(AttendQuoteSourceTypeEnum sourceType) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteSyncSetMapper mapper = sqlSession.getMapper(AttendQuoteSyncSetMapper.class);
- return mapper.listSome(AttendQuoteFieldSettingPO.builder().sourceType(sourceType.getValue()).build());
- } finally {
- sqlSession.close();
- }
- }
-
-
- public void insert(AttendQuoteFieldSettingPO po) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteSyncSetMapper mapper = sqlSession.getMapper(AttendQuoteSyncSetMapper.class);
- mapper.insertIgnoreNull(po);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- public void updateById(AttendQuoteFieldSettingPO po) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- AttendQuoteSyncSetMapper mapper = sqlSession.getMapper(AttendQuoteSyncSetMapper.class);
- mapper.updateIgnoreNull(po);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
-
-}
diff --git a/src/com/engine/salary/biz/EmployBiz.java b/src/com/engine/salary/biz/EmployBiz.java
deleted file mode 100644
index 6de561546..000000000
--- a/src/com/engine/salary/biz/EmployBiz.java
+++ /dev/null
@@ -1,247 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.entity.datacollection.DataCollectionEmployee;
-import com.engine.salary.entity.hrm.DeptInfo;
-import com.engine.salary.entity.hrm.PositionInfo;
-import com.engine.salary.entity.hrm.SubCompanyInfo;
-import com.engine.salary.entity.salarysob.param.SalarySobRangeEmpQueryParam;
-import com.engine.salary.mapper.datacollection.EmployMapper;
-import com.google.common.collect.Lists;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-import weaver.general.BaseBean;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-
-public class EmployBiz extends BaseBean {
-
- public List listAll(){
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.listAll();
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 查询人员列表
- *
- * @return
- */
- public List listEmployee() {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.listEmployee();
- } finally {
- sqlSession.close();
- }
- }
-
- public List getEmployeeByIds(List list) {
- if (CollectionUtils.isEmpty(list)) {
- return new ArrayList<>();
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- List dataList = new ArrayList<>();
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- List> partition = Lists.partition(list, 1000);
- for (List longs : partition) {
- dataList.addAll(mapper.getEmployeeByIds(longs));
- }
- return dataList;
- } finally {
- sqlSession.close();
- }
- }
-
- public List getEmployeeByIdsIncludeAccountType(List list) {
- if (CollectionUtils.isEmpty(list)) {
- return new ArrayList<>();
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- List dataList = new ArrayList<>();
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- List> partition = Lists.partition(list, 1000);
- for (List longs : partition) {
- dataList.addAll(mapper.getEmployeeByIdsIncludeAccountType(longs));
- }
- return dataList;
- } finally {
- sqlSession.close();
- }
- }
-
- public List getEmployeeByIdsAll(List list) {
- if (CollectionUtils.isEmpty(list)) {
- return new ArrayList<>();
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- List employeeList = new ArrayList<>();
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- List> partition = Lists.partition(list, 1000);
- partition.forEach(e->{
- List employeeByIdsAll = mapper.getEmployeeByIdsAll(e);
- employeeList.addAll(employeeByIdsAll);
- });
- return employeeList;
- } finally {
- sqlSession.close();
- }
- }
-
-
- /**
- * 岗位信息
- *
- * @param list
- * @return
- */
- public List listPositionInfo(List list) {
- if (CollectionUtils.isEmpty(list)) {
- return new ArrayList<>();
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.listPositionInfo(list);
- } finally {
- sqlSession.close();
- }
- }
-
- public PositionInfo getPositionInfoById(Long positionId) {
- if (positionId == null) {
- return null;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.getPositionInfoById(positionId);
- } finally {
- sqlSession.close();
- }
- }
-
- public List listByParams(List includeQueryParams) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- List emps = new ArrayList<>();
- List> partition = Lists.partition(includeQueryParams, 100);
- partition.forEach(list->{
- emps.addAll(mapper.listByParams(list));
- });
- return emps;
- } finally {
- sqlSession.close();
- }
- }
-
- public List listByVirtualParams(List virtualQueryParams) {
- if (CollectionUtils.isEmpty(virtualQueryParams)) {
- return Collections.emptyList();
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- List emps = new ArrayList<>();
- List> partition = Lists.partition(virtualQueryParams, 100);
- partition.forEach(list->{
- emps.addAll(mapper.listByVirtualParams(list));
- });
- return emps;
- } finally {
- sqlSession.close();
- }
- }
-
- public DataCollectionEmployee getEmployeeById(Long employeeId) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.getEmployeeById(employeeId);
- } finally {
- sqlSession.close();
- }
- }
-
- public List getDeptInfoList(List list) {
- if (CollectionUtils.isEmpty(list)) {
- return new ArrayList<>();
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.getDeptInfoList(list);
- } finally {
- sqlSession.close();
- }
- }
-
- public List getSubCompanyInfoList(List list) {
- if (CollectionUtils.isEmpty(list)) {
- return new ArrayList<>();
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.getSubCompanyInfoList(list);
- } finally {
- sqlSession.close();
- }
- }
-
- public SubCompanyInfo getSubCompanyInfoById(Long subCompanyId) {
- if (subCompanyId == null) {
- return null;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.getSubCompanyInfoById(subCompanyId);
- } finally {
- sqlSession.close();
- }
- }
-
-
- public List listAllForReport() {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.listAllForReport();
- } finally {
- sqlSession.close();
- }
- }
-
- public List listByDismissDate(String dismissDate) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.listByDismissDate(dismissDate);
- } finally {
- sqlSession.close();
- }
- }
-
- public DeptInfo getDeptInfoById(Long departmentId) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- EmployMapper mapper = sqlSession.getMapper(EmployMapper.class);
- return mapper.getDeptInfoById(departmentId);
- } finally {
- sqlSession.close();
- }
- }
-
-}
diff --git a/src/com/engine/salary/biz/OtherDeductionBiz.java b/src/com/engine/salary/biz/OtherDeductionBiz.java
deleted file mode 100644
index 175a65c40..000000000
--- a/src/com/engine/salary/biz/OtherDeductionBiz.java
+++ /dev/null
@@ -1,226 +0,0 @@
-package com.engine.salary.biz;
-
-import com.engine.salary.config.SalaryElogConfig;
-import com.engine.hrmelog.entity.dto.LoggerContext;
-import com.engine.salary.encrypt.EncryptUtil;
-import com.engine.salary.entity.datacollection.dto.OtherDeductionRecordDTO;
-import com.engine.salary.entity.datacollection.param.OtherDeductionQueryParam;
-import com.engine.salary.entity.datacollection.po.OtherDeductionPO;
-import com.engine.salary.enums.OperateTypeEnum;
-import com.engine.salary.mapper.datacollection.OtherDeductionMapper;
-import com.engine.salary.util.SalaryDateUtil;
-import com.engine.salary.util.SalaryEntityUtil;
-import com.engine.salary.util.SalaryI18nUtil;
-import com.google.common.collect.Lists;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.ibatis.session.SqlSession;
-import weaver.conn.mybatis.MyBatisFactory;
-import weaver.general.BaseBean;
-import weaver.hrm.User;
-
-import java.util.*;
-import java.util.stream.Collectors;
-
-public class OtherDeductionBiz extends BaseBean {
-
- private EncryptUtil encryptUtil = new EncryptUtil();
-
- /**
- * 条件查询
- *
- * @param param
- * @return
- */
- public List listSome(OtherDeductionPO param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- OtherDeductionMapper mapper = sqlSession.getMapper(OtherDeductionMapper.class);
- if (CollectionUtils.isNotEmpty(param.getEmployeeIds())) {
- List> partition = Lists.partition(param.getEmployeeIds(), 500);
- List otherDeductionPOS = new ArrayList<>();
- partition.forEach(l -> {
- param.setEmployeeIds(l);
- otherDeductionPOS.addAll(mapper.listSome(param));
- });
- return encryptUtil.decryptList(otherDeductionPOS, OtherDeductionPO.class);
- }else {
- List otherDeductionPOS = mapper.listSome(param);
- return encryptUtil.decryptList(otherDeductionPOS, OtherDeductionPO.class);
- }
- } finally {
- sqlSession.close();
- }
- }
-
-
- /**
- * 根据id获取
- *
- * @param id
- * @return
- */
- public OtherDeductionPO getById(Long id) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- OtherDeductionMapper mapper = sqlSession.getMapper(OtherDeductionMapper.class);
- OtherDeductionPO byId = mapper.getById(id);
- return encryptUtil.decrypt(byId, OtherDeductionPO.class);
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 详情列表
- *
- * @param param
- * @return
- */
- public List recordList(OtherDeductionQueryParam param) {
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- OtherDeductionMapper mapper = sqlSession.getMapper(OtherDeductionMapper.class);
- List otherDeductionRecordDTOS = mapper.recordList(param);
- return encryptUtil.decryptList(otherDeductionRecordDTOS, OtherDeductionRecordDTO.class);
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 批量插入
- *
- * @param param
- * @return
- */
- public void batchSave(List param) {
- if (CollectionUtils.isEmpty(param)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- OtherDeductionMapper mapper = sqlSession.getMapper(OtherDeductionMapper.class);
- encryptUtil.encryptList(param, OtherDeductionPO.class);
- List> partition = Lists.partition(param, 100);
- partition.forEach(mapper::insertData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
- /**
- * 批量插入
- *
- * @param param
- * @return
- */
- public void batchUpdate(List param) {
- if (CollectionUtils.isEmpty(param)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- OtherDeductionMapper mapper = sqlSession.getMapper(OtherDeductionMapper.class);
- encryptUtil.encryptList(param, OtherDeductionPO.class);
- List> partition = Lists.partition(param, 100);
- partition.forEach(mapper::updateData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-
-
- /**
- * 处理导入数据
- *
- * @param pos
- */
- public void handleImportData(List pos, User user) {
- if (CollectionUtils.isEmpty(pos)) {
- return;
- }
- OtherDeductionPO po = pos.get(0);
- // 多条相同人的则以第一条为准，如果逆序排列（用于重复的则以最后一条为准）Collections.reverse(pos);
- // 去重（通过记录的唯一条件(申报月份，人员id，个税扣缴义务人id)拼接）
- List finalPos = pos.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(f -> f.getEmployeeId() + "-" + f.getTaxAgentId()))), ArrayList::new));
- // 查询已有数据
- List list = listSome(OtherDeductionPO.builder().declareMonth(po.getDeclareMonth()).build());
- // 待修改的 本地已存在则更新【交集】
- List updateList = list.stream().map(m -> {
- Optional optional = finalPos.stream().filter(p -> (p.getEmployeeId() + "-" + p.getTaxAgentId()).equals(m.getEmployeeId() + "-" + m.getTaxAgentId())).findFirst();
- OtherDeductionPO temp = null;
- if (optional.isPresent()) {
- temp = optional.get();
- // 换成本地库的id
- temp.setId(m.getId());
- }
- return temp;
- }).filter(Objects::nonNull).collect(Collectors.toList());
- // 待新增的 导入比本地多，则新增【差集(导入 - local)】
- List saveList = finalPos.stream().map(m -> {
- Optional optional = list.stream().filter(p -> (p.getEmployeeId() + "-" + p.getTaxAgentId()).equals(m.getEmployeeId() + "-" + m.getTaxAgentId())).findFirst();
- OtherDeductionPO temp = null;
- if (!optional.isPresent()) {
- temp = m;
- }
- return temp;
- }).filter(Objects::nonNull).collect(Collectors.toList());
-
- // 修改
- if (CollectionUtils.isNotEmpty(updateList)) {
- batchUpdate(updateList);
- }
- // 保存
- if (CollectionUtils.isNotEmpty(saveList)) {
- batchSave(saveList);
- }
-
- // 记录日志
- // 根据月份、人员id查出保存的数据
- List empIds = saveList.stream().map(OtherDeductionPO::getEmployeeId).collect(Collectors.toList());
- List insertList = listSome(OtherDeductionPO.builder().declareMonth(po.getDeclareMonth()).employeeIds(empIds).build());
- Map insertMap = SalaryEntityUtil.convert2Map(insertList, p -> p.getTaxAgentId() + "-" + SalaryDateUtil.getFormatYearMonth(p.getDeclareMonth()) + "-" + p.getEmployeeId());
- saveList.forEach(save -> {
- OtherDeductionPO otherDeductionPO = insertMap.get(save.getTaxAgentId() + "-" + SalaryDateUtil.getFormatYearMonth(save.getDeclareMonth()) + "-" + save.getEmployeeId());
- if (otherDeductionPO != null) {
- updateList.add(otherDeductionPO);
- }
- });
-
- if (CollectionUtils.isNotEmpty(updateList)) {
- String name = SalaryDateUtil.getFormatYearMonth(po.getDeclareMonth());
- LoggerContext loggerContext = new LoggerContext<>();
- loggerContext.setUser(user);
- loggerContext.setTargetName(SalaryI18nUtil.getI18nLabel( 0, "其他免税扣除 ") + name);
- loggerContext.setOperateType(OperateTypeEnum.EXCEL_IMPORT.getValue());
- loggerContext.setOperateTypeName(SalaryI18nUtil.getI18nLabel( 0, "导入"));
- loggerContext.setOperatedesc(SalaryI18nUtil.getI18nLabel( 0, "其他免税扣除") + name);
- loggerContext.setNewValueList(updateList);
- SalaryElogConfig.otherDeductionLoggerTemplate.write(loggerContext);
- }
- }
-
-
- /**
- * @return void
- * @description 批量删除
- * @author Harryxzy
- * @date 2022/10/27 16:07
- */
- public void batchDeleteByIDS(List deleteIds) {
- if (CollectionUtils.isEmpty(deleteIds)) {
- return;
- }
- SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
- try {
- OtherDeductionMapper mapper = sqlSession.getMapper(OtherDeductionMapper.class);
- List> partition = Lists.partition(deleteIds, 100);
- partition.forEach(mapper::deleteData);
- sqlSession.commit();
- } finally {
- sqlSession.close();
- }
- }
-}
diff --git a/src/com/engine/salary/biz/SIAccountBiz.java b/src/com/engine/salary/biz/SIAccountBiz.java
deleted file mode 100644
index 6cc08b93c..000000000
--- a/src/com/engine/salary/biz/SIAccountBiz.java
+++ /dev/null
@@ -1,2683 +0,0 @@
-package com.engine.salary.biz;
-
-import cn.hutool.core.util.ObjectUtil;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.TypeReference;
-import com.api.formmode.mybatis.util.SqlProxyHandle;
-import com.engine.common.util.ServiceUtil;
-import com.engine.core.impl.Service;
-import com.engine.salary.cache.SalaryCacheKey;
-import com.engine.salary.constant.SalaryDefaultTenantConstant;
-import com.engine.salary.encrypt.EncryptUtil;
-import com.engine.salary.entity.progress.ProgressDTO;
-import com.engine.salary.entity.siaccount.dto.InsuranceAccountViewListDTO;
-import com.engine.salary.entity.siaccount.dto.SIAccountUtilDTO;
-import com.engine.salary.entity.siaccount.param.*;
-import com.engine.salary.entity.siaccount.po.*;
-import com.engine.salary.entity.siarchives.po.*;
-import com.engine.salary.entity.sicategory.po.ICategoryPO;
-import com.engine.salary.entity.sischeme.po.InsuranceSchemeDetailPO;
-import com.engine.salary.entity.taxagent.po.TaxAgentPO;
-import com.engine.salary.enums.siaccount.*;
-import com.engine.salary.enums.sicategory.*;
-import com.engine.salary.exception.SalaryRunTimeException;
-import com.engine.salary.mapper.siaccount.*;
-import com.engine.salary.mapper.siarchives.FundSchemeMapper;
-import com.engine.salary.mapper.siarchives.InsuranceBaseInfoMapper;
-import com.engine.salary.mapper.siarchives.OtherSchemeMapper;
-import com.engine.salary.mapper.siarchives.SocialSchemeMapper;
-import com.engine.salary.mapper.sicategory.ICategoryMapper;
-import com.engine.salary.mapper.sischeme.InsuranceSchemeDetailMapper;
-import com.engine.salary.mapper.taxagent.TaxAgentMapper;
-import com.engine.salary.service.ProgressService;
-import com.engine.salary.service.SalaryEmployeeService;
-import com.engine.salary.service.TaxAgentService;
-import com.engine.salary.service.impl.ProgressServiceImpl;
-import com.engine.salary.service.impl.SalaryEmployeeServiceImpl;
-import com.engine.salary.service.impl.TaxAgentServiceImpl;
-import com.engine.salary.sys.constant.SalarySysConstant;
-import com.engine.salary.sys.entity.po.SalarySysConfPO;
-import com.engine.salary.sys.entity.vo.OrderRuleVO;
-import com.engine.salary.sys.enums.SalaryAcctEmployeeRuleEnum;
-import com.engine.salary.sys.service.SalarySysConfService;
-import com.engine.salary.sys.service.impl.SalarySysConfServiceImpl;
-import com.engine.salary.util.SalaryAssert;
-import com.engine.salary.util.SalaryDateUtil;
-import com.engine.salary.util.SalaryEntityUtil;
-import com.engine.salary.util.SalaryI18nUtil;
-import com.engine.salary.util.db.IdGenerator;
-import com.engine.salary.util.db.MapperProxyFactory;
-import com.engine.salary.util.page.PageInfo;
-import com.engine.salary.util.page.SalaryPageUtil;
-import com.engine.salary.util.valid.ValidUtil;
-import com.google.common.collect.Lists;
-import com.wbi.util.StringUtil;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.commons.lang.math.NumberUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.BeanUtils;
-import weaver.hrm.User;
-
-import java.math.BigDecimal;
-import java.text.SimpleDateFormat;
-import java.util.*;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.function.Function;
-import java.util.regex.Pattern;
-import java.util.stream.Collectors;
-
-/**
- * @Author weaver_cl
- * @Description:
- * @Date 2022/4/11
- * @Version V1.0
- **/
-@Slf4j
-public class SIAccountBiz extends Service {
-
- private SIArchivesBiz siArchivesBiz = new SIArchivesBiz();
-
-
- private EncryptUtil encryptUtil = new EncryptUtil();
-
- private TaxAgentService getTaxAgentService() {
- return ServiceUtil.getService(TaxAgentServiceImpl.class, user);
- }
-
- private SalaryEmployeeService getSalaryEmployeeService() {
- return ServiceUtil.getService(SalaryEmployeeServiceImpl.class, user);
- }
-
- private InsuranceAccountBatchMapper getInsuranceAccountBatchMapper() {
- return SqlProxyHandle.getProxy(InsuranceAccountBatchMapper.class);
- }
-
-
- private InsuranceAccountDetailMapper getInsuranceAccountDetailMapper() {
- return SqlProxyHandle.getProxy(InsuranceAccountDetailMapper.class);
- }
-
- private SIAccountUtilMapper getSIAccountUtilMapper() {
- return MapperProxyFactory.getProxy(SIAccountUtilMapper.class);
- }
-
- private InsuranceAccountInspectMapper getInsuranceAccountInspectMapper() {
- return MapperProxyFactory.getProxy(InsuranceAccountInspectMapper.class);
- }
-
- private InsuranceBaseInfoMapper getInsuranceBaseInfoMapper() {
- return MapperProxyFactory.getProxy(InsuranceBaseInfoMapper.class);
- }
-
- private SocialSchemeMapper getSocialSchemeMapper() {
- return MapperProxyFactory.getProxy(SocialSchemeMapper.class);
- }
-
- private FundSchemeMapper getFundSchemeMapper() {
- return MapperProxyFactory.getProxy(FundSchemeMapper.class);
- }
-
- private OtherSchemeMapper getOtherSchemeMapper() {
- return MapperProxyFactory.getProxy(OtherSchemeMapper.class);
- }
-
- private SalarySysConfService getSalarySysConfService(User user) {
- return ServiceUtil.getService(SalarySysConfServiceImpl.class, user);
- }
-
- private InsuranceCompensationMapper getInsuranceCompensationMapper() {
- return MapperProxyFactory.getProxy(InsuranceCompensationMapper.class);
- }
-
- private ProgressService getSalaryAcctProgressService(User user) {
- return (ProgressService) ServiceUtil.getService(ProgressServiceImpl.class, user);
- }
-
- private SalaryEmployeeService getSalaryEmployeeService(User user) {
- return ServiceUtil.getService(SalaryEmployeeServiceImpl.class, user);
- }
-
-
- private SIAccountDetailTempMapper getSIAccountDetailTempMapper() {
- return MapperProxyFactory.getProxy(SIAccountDetailTempMapper.class);
- }
-
- private InsuranceSchemeDetailMapper getInsuranceSchemeDetailMapper() {
- return MapperProxyFactory.getProxy(InsuranceSchemeDetailMapper.class);
- }
-
- private ICategoryMapper getICategoryMapper() {
- return MapperProxyFactory.getProxy(ICategoryMapper.class);
- }
-
- private TaxAgentMapper getTaxAgentMapper() {
- return MapperProxyFactory.getProxy(TaxAgentMapper.class);
- }
-
- public PageInfo listPage(InsuranceAccountBatchParam queryParam) {
- List list = getInsuranceAccountBatchMapper().list(queryParam);
- PageInfo