From 351b9a53cb9ecebdf8f79db0117f540d9c42c2a4 Mon Sep 17 00:00:00 2001
From: whycrzg <ruanzhigang@whycst.com>
Date: 星期二, 23 二月 2021 17:19:23 +0800
Subject: [PATCH] update
---
src/main/java/com/fgkj/services/User_task_paramService.java | 69 +++++++++++++++++++++++-----------
1 files changed, 47 insertions(+), 22 deletions(-)
diff --git a/src/main/java/com/fgkj/services/User_task_paramService.java b/src/main/java/com/fgkj/services/User_task_paramService.java
index 84885b8..ccccccf 100644
--- a/src/main/java/com/fgkj/services/User_task_paramService.java
+++ b/src/main/java/com/fgkj/services/User_task_paramService.java
@@ -1,30 +1,43 @@
package com.fgkj.services;
-import java.util.ArrayList;
-import java.util.List;
-
-import com.fgkj.mapper.DAOHelper;
-import com.fgkj.mapper.impl.User_infMapper;
-import com.fgkj.db.DBUtil;
import com.fgkj.dto.ServiceModel;
import com.fgkj.dto.User_inf;
import com.fgkj.dto.User_task_param;
+import com.fgkj.mapper.impl.User_infMapper;
import com.fgkj.mapper.impl.User_task_paramMapper;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.TransactionDefinition;
+import org.springframework.transaction.TransactionStatus;
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.annotation.Resource;
@Service
public class User_task_paramService {
- @Autowired
+ @Resource
private User_task_paramMapper mapper;
- @Autowired
+ @Resource
private User_infMapper userInfMapper;
+ @Autowired
+ DataSourceTransactionManager dataSourceTransactionManager;
+ @Autowired
+ TransactionDefinition transactionDefinition;
//4.2浣滀笟鍙傛暟(鏂板浣滀笟鍙傛暟)
- public ServiceModel add(Object obj) {
+ public ServiceModel add(User_task_param obj) {
ServiceModel model = new ServiceModel();
- Boolean bl=mapper.add(obj);
+ Boolean bl= null;
+ try {
+ bl = mapper.add(obj);
+ } catch (Exception e) {
+ e.printStackTrace();
+ model.setMsg("娣诲姞澶辫触!");
+ return model;
+ }
if(bl){
model.setCode(1);
model.setMsg("娣诲姞鎴愬姛!");
@@ -36,9 +49,16 @@
}
//4.2浣滀笟鍙傛暟(淇敼鎿嶄綔/閲嶅懡鍚嶆搷浣�)
- public ServiceModel update(Object obj) {
+ public ServiceModel update(User_task_param obj) {
ServiceModel model = new ServiceModel();
- Boolean bl=mapper.update(obj);
+ Boolean bl= null;
+ try {
+ bl = mapper.update(obj);
+ } catch (Exception e) {
+ e.printStackTrace();
+ model.setMsg("淇敼澶辫触!");
+ return model;
+ }
if(bl){
model.setCode(1);
model.setMsg("淇敼鎴愬姛!");
@@ -50,20 +70,24 @@
}
//4.2浣滀笟鍙傛暟锛堜竴娆′慨鏀瑰涓綔涓氬弬鏁帮級
- public ServiceModel updatePro(Object obj){
+ public ServiceModel updatePro(List<User_task_param> list){
+ TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
ServiceModel model = new ServiceModel();
- List<User_task_param> list=(List<User_task_param>) obj;
- ArrayList<String> sql_str = new ArrayList<String>();//瀛樻斁鎵�鏈夌殑sql璇彞
+ //TODO perry寰呮煡
+ boolean flag=true;
if(list!=null && list.size()>0){
for(int i=0;i<list.size();i++){
- sql_str.add(mapper.updatePro(list.get(i)));
+ if (!(mapper.updatePro(list.get(i))>0)){
+ flag=false;
+ }
}
}
- boolean flag= DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
if(flag){
+ dataSourceTransactionManager.commit(transactionStatus);
model.setCode(1);
model.setMsg("淇敼鎴愬姛");
}else{
+ dataSourceTransactionManager.rollback(transactionStatus);
model.setCode(0);
model.setMsg("淇敼澶辫触");
}
@@ -71,9 +95,9 @@
}
//4.2浣滀笟鍙傛暟(鍒犻櫎)
- public ServiceModel delete(Object obj) {
+ public ServiceModel delete(User_task_param obj) {
ServiceModel model = new ServiceModel();
- Boolean bl=mapper.del(obj);
+ Boolean bl=mapper.del(obj)>0;
if(bl){
model.setCode(1);
model.setMsg("鍒犻櫎鎴愬姛!");
@@ -84,17 +108,18 @@
return model;
}
//4.2鏍规嵁鍙傛暟id鏌ュ熀鏈弬鏁板拰妯℃澘鍙傛暟
- public ServiceModel serchByCondition(Object obj){
+ public ServiceModel serchByCondition(User_task_param obj){
ServiceModel model = new ServiceModel();
User_inf uinf=new User_inf();
List<User_task_param> list=mapper.serchByCondition(obj);
for (int i=0;i<list.size();i++) {
String uids=list.get(i).getTp_master_id();
+ if (uids.length()<1) uids="0";
int uid=Integer.parseInt(uids);
- uinf.setUId(uid);
+ uinf.setuId(uid);
List<User_inf> listu=userInfMapper.serchUname(uinf);
if(listu.size()>0&&listu!=null){
- uids=listu.get(0).getUName();
+ uids=listu.get(0).getuName();
}
list.get(i).setTp_master_id(uids);
}
--
Gitblit v1.9.1