批量更新 一个事物中去掉stat

src/main/java/com/ylcm/sys/controller/AdTheatreController.java

@@ -16,12 +16,7 @@ import com.ylcm.sys.domain.AdTv;
 import com.ylcm.sys.excel.listener.BaseExcelListener;
 import com.ylcm.sys.excel.model.AdTheatreExcelDTO;
 import com.ylcm.sys.form.AdTheatreForm;
-import com.ylcm.sys.service.AdMediaService;
-import com.ylcm.sys.service.AdPlatformService;
-import com.ylcm.sys.service.AdProductService;
-import com.ylcm.sys.service.AdTheatreService;
-import com.ylcm.sys.service.AdTheatreTvService;
-import com.ylcm.sys.service.AdTvService;
+import com.ylcm.sys.service.*;
 import com.ylcm.sys.vo.AdTheatreVO;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections.CollectionUtils;
@@ -60,6 +55,8 @@ public class AdTheatreController extends BaseController{
 	private AdPlatformService adPlatformService;
 	@Resource
 	private AdMediaService adMediaService;
+	@Resource
+	private AdTheatreTvStatService adTheatreTvStatService;
 
 	/**
 	 * to 列表页面
@@ -253,9 +250,14 @@ public class AdTheatreController extends BaseController{
 				tvList.add(dto.toAdTheatreTv());
 			}
 			// 入库
-			msg = adTheatreService.batchAdd(list, tvList);
+			List<AdTheatre> adTheatres = adTheatreService.batchAdd(list, tvList);
+
+			for (AdTheatre adTheatre:adTheatres) {
+				adTheatreTvStatService.saveStatByTheatreTv(adTheatre);
+			}
+
 			// 判断执行结果
-			if ("ok".equals(msg)) {
+			if (adTheatres != null) {
 				request.setAttribute("repeat", 0);
 				request.setAttribute("code", Constants.CODE_SUCCESS);
 				request.setAttribute("msg", msg);

src/main/java/com/ylcm/sys/service/AdTheatreService.java

@@ -32,7 +32,7 @@ public interface AdTheatreService extends IService<AdTheatre> {
      * @param tvList 电视剧收视数据
      * @return 执行结果：errorMsg or ok
      */
-    String batchAdd(List<AdTheatre> list, List<AdTheatreTv> tvList) throws Exception;
+    List<AdTheatre> batchAdd(List<AdTheatre> list, List<AdTheatreTv> tvList) throws Exception;
 
     String deleteById(Integer id);
 

src/main/java/com/ylcm/sys/service/AdTheatreTvService.java

@@ -15,6 +15,13 @@ public interface AdTheatreTvService extends IService<AdTheatreTv> {
 
     AdTheatreTv getByTheatreId(Integer adTheatreId);
 
+    String add1(AdTheatreTv record);
+
+    /**
+     * 带更新stat
+     * @param record
+     * @return
+     */
     String add(AdTheatreTv record);
 
 }

src/main/java/com/ylcm/sys/service/impl/AdTheatreServiceImpl.java

@@ -73,7 +73,7 @@ public class AdTheatreServiceImpl extends ServiceImpl<AdTheatreMapper, AdTheatre
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public String batchAdd(List<AdTheatre> list, List<AdTheatreTv> tvList) throws Exception {
+    public List<AdTheatre> batchAdd(List<AdTheatre> list, List<AdTheatreTv> tvList) throws Exception {
         if (list.size() != tvList.size()){
             throw new Exception("批量新增error：剧场ListSize != 收视率ListSize");
         }
@@ -93,9 +93,10 @@ public class AdTheatreServiceImpl extends ServiceImpl<AdTheatreMapper, AdTheatre
              */
             AdTheatreTv theatreTv = tvList.get(i);
             theatreTv.setAdTheatreId(record.getId());
-            adTheatreTvService.add(theatreTv);
+            adTheatreTvService.add1(theatreTv);
+
         }
-        return "ok";
+        return list;
     }
 
     @Transactional(rollbackFor = Exception.class)

src/main/java/com/ylcm/sys/service/impl/AdTheatreTvServiceImpl.java

@@ -43,6 +43,24 @@ public class AdTheatreTvServiceImpl extends ServiceImpl<AdTheatreTvMapper, AdThe
 
     @Override
     @Transactional(rollbackFor = Exception.class)
+    public String add1(AdTheatreTv record) {
+        AdTheatreTv old = getByTheatreId(record.getAdTheatreId());
+        if (old == null){
+            // insert
+            baseMapper.insert(record);
+        } else {
+            // update
+            record.setId(old.getId());
+            baseMapper.updateById(record);
+        }
+
+//        AdTheatre adTheatre = adTheatreService.getById(record.getAdTheatreId());
+//        adTheatreTvStatService.saveStatByTheatreTv(adTheatre);
+        return "ok";
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
     public String add(AdTheatreTv record) {
         AdTheatreTv old = getByTheatreId(record.getAdTheatreId());
         if (old == null){