Commit f9f06365 authored by lvzhuangzhuang's avatar lvzhuangzhuang

数据清洗,添加事务

parent fc9c3e6e
...@@ -15,6 +15,8 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -15,6 +15,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.ruoyi.system.mapper.ActSuppliesHistorydataMapper; import com.ruoyi.system.mapper.ActSuppliesHistorydataMapper;
import com.ruoyi.system.service.IActSuppliesHistorydataService; import com.ruoyi.system.service.IActSuppliesHistorydataService;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.transaction.annotation.Transactional;
/** /**
* 历史数据Service业务层处理 * 历史数据Service业务层处理
...@@ -23,6 +25,7 @@ import com.ruoyi.system.service.IActSuppliesHistorydataService; ...@@ -23,6 +25,7 @@ import com.ruoyi.system.service.IActSuppliesHistorydataService;
* @date 2023-08-01 * @date 2023-08-01
*/ */
@Service @Service
@EnableTransactionManagement
public class ActSuppliesHistorydataServiceImpl implements IActSuppliesHistorydataService public class ActSuppliesHistorydataServiceImpl implements IActSuppliesHistorydataService
{ {
@Autowired @Autowired
...@@ -198,6 +201,7 @@ public class ActSuppliesHistorydataServiceImpl implements IActSuppliesHistorydat ...@@ -198,6 +201,7 @@ public class ActSuppliesHistorydataServiceImpl implements IActSuppliesHistorydat
* @return 结果 * @return 结果
*/ */
@Override @Override
@Transactional
public void addInsertImport(List<ActOperation1> actOperation2s) { public void addInsertImport(List<ActOperation1> actOperation2s) {
//创建新线程 //创建新线程
Thread thread = new Thread(){ Thread thread = new Thread(){
...@@ -263,6 +267,7 @@ public class ActSuppliesHistorydataServiceImpl implements IActSuppliesHistorydat ...@@ -263,6 +267,7 @@ public class ActSuppliesHistorydataServiceImpl implements IActSuppliesHistorydat
* @return 结果 * @return 结果
*/ */
@Override @Override
@Transactional
public void addInsertImportss(List<ActOperation1> actOperation2s) { public void addInsertImportss(List<ActOperation1> actOperation2s) {
Thread thread = new Thread() { Thread thread = new Thread() {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment