|
@@ -1,9 +1,11 @@
|
|
|
package cn.iocoder.yudao.module.pms.job;
|
|
|
|
|
|
+import cn.hutool.core.collection.CollUtil;
|
|
|
import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler;
|
|
|
import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore;
|
|
|
import cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder;
|
|
|
import cn.iocoder.yudao.framework.tenant.core.job.TenantJob;
|
|
|
+import cn.iocoder.yudao.framework.tenant.core.util.TenantUtils;
|
|
|
import cn.iocoder.yudao.module.pms.constant.PmsConstants;
|
|
|
import cn.iocoder.yudao.module.pms.controller.admin.iotopeationfill.vo.IotOpeationFillPageReqVO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.iotopeationfill.IotOpeationFillDO;
|
|
@@ -55,7 +57,6 @@ public class IotOperationFillJob implements JobHandler {
|
|
|
|
|
|
|
|
|
@Override
|
|
|
- @TenantIgnore
|
|
|
public String execute(String param) throws Exception {
|
|
|
TenantContextHolder.setIgnore(true);
|
|
|
System.out.println("***********创建运行记录填报工单开始执行*********8");
|
|
@@ -122,7 +123,9 @@ public class IotOperationFillJob implements JobHandler {
|
|
|
.filter(obj -> idList.contains(obj.getUserId()))
|
|
|
.collect(Collectors.toList());
|
|
|
|
|
|
- iotOpeationFillOrderMapper.insertBatch(orderList1);
|
|
|
+ if (CollUtil.isNotEmpty(orderList1)) {
|
|
|
+ TenantUtils.execute(1L, () -> iotOpeationFillOrderMapper.insertBatch(orderList1));
|
|
|
+ }
|
|
|
|
|
|
pmsThreadPoolTaskExecutor.execute(()->{
|
|
|
try{
|