|
|
@@ -15,7 +15,9 @@ import cn.iocoder.yudao.module.pms.dal.mysql.iotprojectinfo.IotProjectInfoMapper
|
|
|
import cn.iocoder.yudao.module.pms.dal.mysql.iotprojecttask.IotProjectTaskMapper;
|
|
|
import cn.iocoder.yudao.module.pms.service.iotprojectinfo.IotProjectInfoService;
|
|
|
import cn.iocoder.yudao.module.supplier.service.product.SupplierService;
|
|
|
+import cn.iocoder.yudao.module.system.controller.admin.dept.vo.dept.DeptListReqVO;
|
|
|
import cn.iocoder.yudao.module.system.dal.dataobject.dept.DeptDO;
|
|
|
+import cn.iocoder.yudao.module.system.dal.mysql.dept.DeptMapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
@@ -28,6 +30,7 @@ import java.util.concurrent.atomic.AtomicReference;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
|
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
|
|
|
import static cn.iocoder.yudao.module.pms.enums.ErrorCodeConstant.IOT_PROJECT_TASK_NOT_EXISTS;
|
|
|
|
|
|
/**
|
|
|
@@ -48,6 +51,8 @@ public class IotProjectTaskServiceImpl implements IotProjectTaskService {
|
|
|
private SupplierService iotSupplierService;
|
|
|
@Resource
|
|
|
private IotProjectInfoMapper iotProjectInfoMapper;
|
|
|
+ @Resource
|
|
|
+ private DeptMapper deptMapper;
|
|
|
|
|
|
@Override
|
|
|
public Long createIotProjectTask(IotProjectTaskSaveReqVO createReqVO) {
|
|
|
@@ -253,6 +258,19 @@ public class IotProjectTaskServiceImpl implements IotProjectTaskService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ List<Long> qualifiedDeptIds = new ArrayList<>();
|
|
|
+ // 根据部门名称 模糊搜索
|
|
|
+ if (StrUtil.isNotBlank(vo.getDeptName())) {
|
|
|
+ // 根据名称查询部门id
|
|
|
+ DeptListReqVO reqVO = new DeptListReqVO();
|
|
|
+ reqVO.setName(vo.getDeptName());
|
|
|
+ List<DeptDO> qualifiedDepts = deptMapper.selectList(reqVO);
|
|
|
+ qualifiedDeptIds = convertList(qualifiedDepts, DeptDO::getId);
|
|
|
+ if (CollUtil.isEmpty(qualifiedDeptIds)) {
|
|
|
+ return new PageResult<>(new ArrayList<>(), 0l);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
IPage<IotProjectTaskDO> taskDOIPage = iotProjectTaskMapper.taskList(Page.of(vo.getPageNo(), vo.getPageSize()),
|
|
|
vo.getCompanyId(),
|
|
|
vo.getManufactureName(),
|
|
|
@@ -261,6 +279,7 @@ public class IotProjectTaskServiceImpl implements IotProjectTaskService {
|
|
|
vo.getWellName(),
|
|
|
vo.getCreateTime(),
|
|
|
departmentIds,
|
|
|
+ qualifiedDeptIds,
|
|
|
projectIds,
|
|
|
vo.getPlatformFlag());
|
|
|
return new PageResult<>(taskDOIPage.getRecords(), taskDOIPage.getTotal());
|