diff --git a/src/com/engine/salary/biz/SalarySobBiz.java b/src/com/engine/salary/biz/SalarySobBiz.java index 23b19ca28..bc9dfec8c 100644 --- a/src/com/engine/salary/biz/SalarySobBiz.java +++ b/src/com/engine/salary/biz/SalarySobBiz.java @@ -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); } diff --git a/src/com/engine/salary/service/impl/SalaryArchiveTaxAgentServiceImpl.java b/src/com/engine/salary/service/impl/SalaryArchiveTaxAgentServiceImpl.java index f99f2d1ca..b4de36a65 100644 --- a/src/com/engine/salary/service/impl/SalaryArchiveTaxAgentServiceImpl.java +++ b/src/com/engine/salary/service/impl/SalaryArchiveTaxAgentServiceImpl.java @@ -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()); diff --git a/src/com/engine/salary/util/db/SalarySqlProxyHandle.java b/src/com/engine/salary/util/db/SalarySqlProxyHandle.java index 98a044c1e..55c1a51b7 100644 --- a/src/com/engine/salary/util/db/SalarySqlProxyHandle.java +++ b/src/com/engine/salary/util/db/SalarySqlProxyHandle.java @@ -7,7 +7,7 @@ import java.lang.reflect.InvocationHandler; import java.lang.reflect.Method; import java.lang.reflect.Proxy; -public class SalarySqlProxyHandle implements InvocationHandler { +public class SalarySqlProxyHandle implements InvocationHandler { private Class clazz; private boolean enableTransactions = false; private SqlSession session; @@ -36,12 +36,12 @@ public class SalarySqlProxyHandle 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 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); }