Commit 8348d81d by huangfusuper

增加事务

parent 2ed6c96e
...@@ -20,7 +20,6 @@ import org.springframework.web.filter.CorsFilter; ...@@ -20,7 +20,6 @@ import org.springframework.web.filter.CorsFilter;
@SpringBootApplication @SpringBootApplication
@RpcService(http_type = true) @RpcService(http_type = true)
@EnablePluginClient @EnablePluginClient
@EnableTransactionManagement
public class AdminApplication { public class AdminApplication {
public static void main(String[] args) { public static void main(String[] args) {
SpringApplication.run(AdminApplication.class,args); SpringApplication.run(AdminApplication.class,args);
......
...@@ -28,6 +28,7 @@ import org.apache.commons.lang3.StringUtils; ...@@ -28,6 +28,7 @@ import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource; import javax.annotation.Resource;
...@@ -60,6 +61,7 @@ public class ApiNodeServiceImpl implements ApiNodeService { ...@@ -60,6 +61,7 @@ public class ApiNodeServiceImpl implements ApiNodeService {
@Override @Override
@Transactional(propagation = Propagation.NESTED )
public String runNode(String param) { public String runNode(String param) {
ValidationUtil.dataNotBank(param, "请求参数不允许为空!"); ValidationUtil.dataNotBank(param, "请求参数不允许为空!");
RunNode runNode = JSON.parseObject(param, RunNode.class); RunNode runNode = JSON.parseObject(param, RunNode.class);
......
...@@ -116,7 +116,6 @@ public class JobTaskRunLogServiceImpl implements JobTaskRunLogService { ...@@ -116,7 +116,6 @@ public class JobTaskRunLogServiceImpl implements JobTaskRunLogService {
} }
@Override @Override
@Transactional(rollbackFor = Exception.class)
public int saveJobTaskRunLog(JobTaskRunLogWithBLOBs jobTaskRunLog) { public int saveJobTaskRunLog(JobTaskRunLogWithBLOBs jobTaskRunLog) {
log.debug("--------------saveJobTaskRunLog start【{}】------------------------",jobTaskRunLog); log.debug("--------------saveJobTaskRunLog start【{}】------------------------",jobTaskRunLog);
return jobTaskRunLogMapper.saveJobTaskRunLog(jobTaskRunLog); return jobTaskRunLogMapper.saveJobTaskRunLog(jobTaskRunLog);
......
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