档案类修复

This commit is contained in:
钱涛 2022-04-06 13:21:30 +08:00
parent 8d9ff236f7
commit 75f64648d6
3 changed files with 11 additions and 11 deletions

View File

@ -2,7 +2,7 @@ package com.engine.salary.biz;
import com.engine.salary.entity.salarysob.po.SalarySobPO;
import com.engine.salary.mapper.salarysob.SalarySobMapper;
import com.engine.salary.util.db.SalarySqlProxyHandle;
import com.engine.salary.util.db.SqlProxyHandle;
import org.apache.ibatis.session.SqlSession;
import weaver.conn.mybatis.MyBatisFactory;
@ -11,7 +11,7 @@ import java.util.List;
public class SalarySobBiz {
public SalarySobPO getById(Long id) {
SalarySobMapper mapper = SalarySqlProxyHandle.getProxy(SalarySobMapper.class);
SalarySobMapper mapper = SqlProxyHandle.getProxy(SalarySobMapper.class);
return mapper.getById(id);
}

View File

@ -90,12 +90,12 @@ public class SalaryArchiveTaxAgentServiceImpl extends Service implements SalaryA
@Override
public String saveTaxAgent(SalaryArchiveTaxAgentSaveParam saveParam) {
SalaryArchiveMapper salaryArchiveMapper = SqlProxyHandle.getProxy(SalaryArchiveMapper.class);
// 校验参数
SalaryArchiveTaxAgentSaveParam.checkParam(saveParam);
// 薪资档案
SalaryArchiveMapper salaryArchiveMapper = SqlProxyHandle.getProxy(SalaryArchiveMapper.class);
SalaryArchivePO salaryArchive = salaryArchiveMapper.getById(saveParam.getSalaryArchiveId());
// 获取当前已生效
SalaryArchiveTaxAgentPO effectiveTaxAgent = getEffectiveTaxAgent(saveParam.getSalaryArchiveId());

View File

@ -7,7 +7,7 @@ import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
public class SalarySqlProxyHandle<T> implements InvocationHandler {
public class SalarySqlProxyHandle implements InvocationHandler {
private Class clazz;
private boolean enableTransactions = false;
private SqlSession session;
@ -36,12 +36,12 @@ public class SalarySqlProxyHandle<T> implements InvocationHandler {
this.session = MyBatisFactory.sqlSessionFactory.openSession();
}
try {
Object target = this.session.getMapper(clazz);
return method.invoke(target, args);
// if (!enableTransactions) {
// this.session.commit();
// }
// return invoke;
Object target = session.getMapper(clazz);
Object invoke = method.invoke(target, args);
if (!enableTransactions) {
session.commit();
}
return invoke;
} finally {
if (!enableTransactions) {
this.session.close();
@ -53,7 +53,7 @@ public class SalarySqlProxyHandle<T> implements InvocationHandler {
ClassLoader loader = Thread.currentThread().getContextClassLoader();
Class<?>[] interfaces = new Class<?>[1];
interfaces[0] = this.clazz;
return Proxy.newProxyInstance(loader, interfaces, this);
return Proxy.newProxyInstance(loader, interfaces, this);
}