From 64339f138206592dd60431c78c7b597b16ba3ee4 Mon Sep 17 00:00:00 2001 From: Ziin Date: Mon, 18 Aug 2025 17:45:49 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E6=94=B9=E4=B8=BB=E6=92=AD=E5=88=86?= =?UTF-8?q?=E9=85=8D=E7=8A=B6=E6=80=81=E6=97=B6=E4=BC=9A=E5=90=8C=E6=AD=A5?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=A7=9F=E6=88=B7=E4=B8=8B=E6=89=80=E6=9C=89?= =?UTF-8?q?=E5=90=8C=E5=90=8D=E4=B8=BB=E6=92=AD=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../EmployeeHostsServiceImpl.java | 21 ++++++++++++++++++- 1 file changed, 20 insertions(+), 1 deletion(-) diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsServiceImpl.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsServiceImpl.java index f6cd346..0498d65 100644 --- a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsServiceImpl.java +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsServiceImpl.java @@ -10,12 +10,17 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.annotation.Resource; + +import org.springframework.util.StopWatch; import org.springframework.validation.annotation.Validated; import org.springframework.transaction.annotation.Transactional; import java.util.*; +import java.util.stream.Collectors; + import cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts.vo.*; import cn.iocoder.yudao.module.tkdata.dal.dataobject.employeehosts.EmployeeHostsDO; import cn.iocoder.yudao.framework.common.pojo.PageResult; @@ -37,6 +42,7 @@ import static cn.iocoder.yudao.module.tkdata.enums.ErrorCodeConstants.EMPLOYEE_H */ @Service @Validated +@Slf4j public class EmployeeHostsServiceImpl implements EmployeeHostsService { @Resource @@ -119,6 +125,7 @@ public class EmployeeHostsServiceImpl implements EmployeeHostsService { for (EmployeeHostsSaveReqVO employeeHostsSaveReqVO : hostsList) { NewHostsDO newHostsDO = new NewHostsDO(); newHostsDO.setId(employeeHostsSaveReqVO.getId()); + newHostsDO.setHostsId(employeeHostsSaveReqVO.getHostsId()); newHostsDO.setUserId(employeeHostsSaveReqVO.getUserId()); newHostsDO.setIsAssigned(1); newHostsDOArrayList.add(newHostsDO); @@ -126,8 +133,20 @@ public class EmployeeHostsServiceImpl implements EmployeeHostsService { employeeHostsDO.setOperationStatus(0); employeeHostsDOS.add(employeeHostsDO); } + Long tenantId = TenantContextHolder.getTenantId(); int i = employeeHostsMapper.batchInsertIgnore(employeeHostsDOS); - newHostsMapper.updateBatch(newHostsDOArrayList); + LambdaUpdateWrapper lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); + + List hostsIds = newHostsDOArrayList.stream() + .map(NewHostsDO::getHostsId) + .collect(Collectors.toList()); + int update = newHostsMapper.update(lambdaUpdateWrapper + .in(NewHostsDO::getHostsId,hostsIds) + .eq(NewHostsDO::getTenantId, tenantId) + .set(NewHostsDO::getIsAssigned, 1)); + log.info("修改租户:{}下 {} 个主播分配状态，共更新 {} 条记录",tenantId,hostsIds.size(),update); + +// newHostsMapper.updateBatch(newHostsDOArrayList); return i; }