111

src/main/java/com/dashitech/migration/task/call/CallLogTask.java

@@ -21,7 +21,7 @@ public class CallLogTask extends BaseTask {
     public static Log log = LogFactory.getLog(CallLogTask.class);
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info("通话记录callLog转换开始");
 

src/main/java/com/dashitech/migration/task/call/HjzxRecordTask.java

@@ -21,7 +21,7 @@ public class HjzxRecordTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(HjzxRecordTask.class);
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info("呼叫中心HjzxRecord转换开始");
 

src/main/java/com/dashitech/migration/task/category/IncidentCategoryConfigTask.java

@@ -21,7 +21,7 @@ public class IncidentCategoryConfigTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(IncidentCategoryConfigTask.class);
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         StringBuffer sql = new StringBuffer("SELECT a.version,a.category_id,b._priority as priority,a.duty_id,a.branch_user_group_type as user_group,a.group_id,");
         sql.append("a.user_id,NOW() as add_time,a.branch_id as hos_id FROM itsm_incident_category_usergroup a ");

src/main/java/com/dashitech/migration/task/category/IncidentCategoryTask.java

@@ -20,7 +20,7 @@ public class IncidentCategoryTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(IncidentCategoryTask.class);
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         StringBuffer sql = new StringBuffer("SELECT id,version,category,parentid as parent,delete_flag,quanPinyin as qp,suoPinyin as jp,now() as add_time,");
         sql.append("hierarchy,muti_category,muti_suoPinyin as muti_jp,muti_quanPinyin as muti_qp,IFNULL(branch_id,1) as hos_id ");

src/main/java/com/dashitech/migration/task/consumable/ConsumableHistoryTask.java

@@ -35,7 +35,7 @@ public class ConsumableHistoryTask extends BaseTask {
     private DepartmentTask departmentTask;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info("耗材日志ConsumableHistoryTask转换开始");
 

src/main/java/com/dashitech/migration/task/consumable/ConsumableTask.java

@@ -30,7 +30,7 @@ public class ConsumableTask extends BaseTask {
     private CompanyTask companyTask;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info("耗材ConsumableTask转换开始");
         StringBuffer sql = new StringBuffer("SELECT id,version,NAME,brand_model as model,inventory_num as stock,start_price as price,company_ids as supplier_id,");

src/main/java/com/dashitech/migration/task/consumable/RepairSummaryTask.java

@@ -6,6 +6,7 @@ import com.dashitech.migration.util.JdbcUtil;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 import java.util.Map;
@@ -19,6 +20,7 @@ public class RepairSummaryTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(RepairSummaryTask.class);
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info("汇总单数据RepairSummaryTask开始转换");
         StringBuffer sql = new StringBuffer("select * from itsm_repair_summary");

src/main/java/com/dashitech/migration/task/consumable/SummaryConsumableTask.java

@@ -20,7 +20,7 @@ public class SummaryConsumableTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(SummaryConsumableTask.class);
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info("汇总单耗材数据SummaryConsumableTask转换开始");
         StringBuffer sql = new StringBuffer("SELECT * from itsm_summary_consumables");

src/main/java/com/dashitech/migration/task/incident/IncidentTask.java

@@ -32,7 +32,7 @@ public class IncidentTask extends BaseTask {
     public static Log log = LogFactory.getLog(IncidentTask.class);
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** DepartmentTask start 开始 *** ");
 

src/main/java/com/dashitech/migration/task/other/DictionaryTask.java

@@ -5,6 +5,7 @@ import com.dashitech.migration.core.FieldMapper;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -19,6 +20,7 @@ public class DictionaryTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(DictionaryTask.class);
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
 
     }

src/main/java/com/dashitech/migration/task/solution/SolutionIntroduceTask.java

@@ -26,7 +26,7 @@ public class SolutionIntroduceTask extends BaseTask {
     private UserTask userTask;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info("知识库引用数据SolutionIntroduceTask转换开始");
 

src/main/java/com/dashitech/migration/task/solution/SolutionTask.java

@@ -30,7 +30,7 @@ public class SolutionTask extends BaseTask {
     DictionaryTask dictionaryTask;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info("知识库数据SolutionTask转换开始");
 

src/main/java/com/dashitech/migration/task/uc/CompanyTask.java

@@ -32,7 +32,7 @@ public class CompanyTask extends BaseTask {
 
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** 三方公司CompanyTask转换开始 *** ");
 

src/main/java/com/dashitech/migration/task/uc/DepartmentTask.java

@@ -25,7 +25,7 @@ public class DepartmentTask extends BaseTask {
     public static Log log = LogFactory.getLog(DepartmentTask.class);
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** DepartmentTask start 开始 *** ");
         StringBuffer sql = new StringBuffer("SELECT dept,CODE,parentId,email,delete_flag,address as _address,place_id as floor_id,area_id as building_id,pinyin,");

src/main/java/com/dashitech/migration/task/uc/GroupTask.java

@@ -28,7 +28,7 @@ public class GroupTask extends BaseTask {
     SqlTask hospitalTask;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** 工作组group转换开始 *** ");
 

src/main/java/com/dashitech/migration/task/uc/HospitalConfigTask.java

@@ -24,7 +24,7 @@ public class HospitalConfigTask extends BaseTask {
     public static Log log = LogFactory.getLog(HospitalConfigTask.class);
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** HospitalConfigTask start开始 *** ");
         FieldMapper mapper = new FieldMapper();

src/main/java/com/dashitech/migration/task/uc/HospitalTask.java

@@ -24,7 +24,7 @@ public class HospitalTask extends BaseTask {
     public static Log log = LogFactory.getLog(HospitalTask.class);
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** HospitalTask start开始 *** ");
         if ("xiangyang".equals(appName)) {

src/main/java/com/dashitech/migration/task/uc/RoleUserTask.java

@@ -26,7 +26,7 @@ public class RoleUserTask extends BaseTask {
     SqlTask userTask;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** start RoleUserTask缓存 *** ");
 

src/main/java/com/dashitech/migration/task/uc/UserGroupTask.java

@@ -29,7 +29,7 @@ public class UserGroupTask extends BaseTask {
     public static Log log = LogFactory.getLog(UserGroupTask.class);
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** UserGroupTask 转换 开始 *** ");
 

src/main/java/com/dashitech/migration/task/uc/UserTask.java

@@ -32,7 +32,7 @@ public class UserTask extends BaseTask {
     public static Log log = LogFactory.getLog(UserTask.class);
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         log.info(" *** 用户user转换开始 *** ");
 

src/main/java/com/dashitech/migration/task/workhour/WorkHourManagementTask.java

@@ -6,6 +6,7 @@ import com.dashitech.migration.task.uc.HospitalTask;
 import com.dashitech.migration.util.JdbcUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 import java.util.Map;
@@ -21,6 +22,7 @@ public class WorkHourManagementTask extends BaseTask {
     private HospitalTask hospitalTask;
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void start() {
         StringBuffer sql = new StringBuffer("SELECT id,version,work_unit,work_name,tree_level,parent,wage,");
         sql.append("work_hour_num as work_hour,duty as hos_id,delete_flag FROM itsm_work_hour_management ");