Selaa lähdekoodia

运行记录1219-运行记录日报设备查询优化3

yuanchao 1 viikko sitten
vanhempi
commit
a6fcfbbe08

+ 10 - 3
yudao-module-pms/yudao-module-pms-biz/src/main/java/cn/iocoder/yudao/module/pms/controller/admin/iotopeationfill/IotOpeationFillController.java

@@ -1,6 +1,7 @@
 package cn.iocoder.yudao.module.pms.controller.admin.iotopeationfill;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.iocoder.yudao.framework.tenant.core.util.TenantUtils;
 import cn.iocoder.yudao.module.pms.controller.admin.iotmodeltemplateattrs.vo.IotModelTemplateAttrsRespVO;
 import cn.iocoder.yudao.module.pms.controller.admin.iotopeationfill.vo.*;
 import cn.iocoder.yudao.module.pms.controller.admin.iotrhdailyreport.vo.IotRhDailyReportSaveReqVO;
@@ -597,13 +598,19 @@ public class IotOpeationFillController {
 
         // 3. 批量执行(MyBatis批量操作)
         if (!insertList.isEmpty()) {
-            iotOpeationFillService.batchInsertLogs(insertList); // 批量插入
+            TenantUtils.execute(1L, () -> {
+                iotOpeationFillService.batchInsertLogs(insertList); // 批量插入
+            });
         }
         if (!updateList.isEmpty()) {
-            iotOpeationFillService.batchUpdateLogs(updateList); // 批量更新普通日志
+            TenantUtils.execute(1L, () -> {
+                iotOpeationFillService.batchUpdateLogs(updateList); // 批量更新普通日志
+            });
         }
         if (!updateSumList.isEmpty()) {
-            iotOpeationFillService.batchUpdateSumLogs(updateSumList); // 批量更新累计日志
+            TenantUtils.execute(1L, () -> {
+                iotOpeationFillService.batchUpdateSumLogs(updateSumList); // 批量更新累计日志
+            });
         }
     }