diff --git a/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/dto/StoreImportDTO.java b/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/dto/StoreImportDTO.java index 192adcd..ba24a62 100644 --- a/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/dto/StoreImportDTO.java +++ b/chushang-modules/chushang-module-inspection/inspection-feign/src/main/java/com/chushang/inspection/terminal/dto/StoreImportDTO.java @@ -153,7 +153,7 @@ public class StoreImportDTO implements Serializable { */ @ExcelProperty(value = "pos编号") @Size(max = 50, message = "操作员编号不能大于50个字符") - private String userName; + private String adminIds; /** * 客户经理 */ diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/controller/StoreImportController.java b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/controller/StoreImportController.java index 4a8b9b2..3eb5e3a 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/controller/StoreImportController.java +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/controller/StoreImportController.java @@ -78,77 +78,14 @@ public class StoreImportController { @RequiresPermissions("store:import:save") public AjaxResult importStore(@RequestBody List lists) { - storeImportService.saveList(lists); - return AjaxResult.success(); + return AjaxResult.success(storeImportService.confimImport(lists)); } - /** - * 列表确认导入查询 - * - * @param query 条件 - */ - @SysLog(value = "列表确认导入查询", businessType = BusinessType.QUERY) - @GetMapping("/page") - @RequiresPermissions("store:import:page") - public AjaxResult pageList(@Validated StoreImportQuery query) { - CommonParam commonParam = CommonParam.buildPageRequest(); - return AjaxResult.success(storeImportService.pageList(query,commonParam)); - } - /** - * 修改 商户确认导入 - */ - @PostMapping(value = "/update") - @RequiresPermissions("store:import:update") - @SysLog(value = "导入数据删除",businessType = BusinessType.UPDATE) - public AjaxResult update(@RequestBody @Validated(Update.class) StoreImportQuery query){ - - StoreImport storeImport = BeanCopyUtils.copy(query, StoreImport.class); - storeImport.setDeptId(SecurityUtils.getDeptId()); - return AjaxResult.success(storeImportService.updateById(storeImport)); - } - - - /** - * 删除导入数据 - */ - @DeleteMapping(value = "/{ids}") - @RequiresPermissions("store:import:del") - @SysLog(value = "导入数据删除",businessType = BusinessType.DELETE) - public AjaxResult delProject( @PathVariable Long[] ids) - { - return AjaxResult.success(storeImportService.removeByIds(Arrays.asList(ids))); - } - - - /** - * 新增导入数据 - */ - @PostMapping(value = "/save/one") - @SysLog(value = "新增导入数据", businessType = BusinessType.INSERT) - @RequiresPermissions("store:import:save") - public AjaxResult saveOne(@RequestBody @Validated(Create.class) StoreImportQuery query) - { - StoreImport storeImport = BeanCopyUtils.copy(query, StoreImport.class); - storeImport.setDeptId(SecurityUtils.getDeptId()); - return AjaxResult.success(storeImportService.save(storeImport)); - } - - - /** - * 确认导入数据 - */ - @GetMapping(value = "/confirm/{ids}") - @SysLog(value = "确认导入数据", businessType = BusinessType.INSERT) - @RequiresPermissions("store:import:save") - public AjaxResult confimImport(@PathVariable Long[] ids) - { - return AjaxResult.success(storeImportService.confimImport(ids)); - } diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/StoreImportService.java b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/StoreImportService.java index a1df088..2c922a0 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/StoreImportService.java +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/StoreImportService.java @@ -21,8 +21,7 @@ public interface StoreImportService extends IService { PageResult pageList(StoreImportQuery storeImport, CommonParam commonParam); - int confimImport(Long[] ids); + int confimImport(List lists); - void saveList(List dtoList); } diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/impl/StoreImportServiceImpl.java b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/impl/StoreImportServiceImpl.java index 73c6ade..05f1b58 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/impl/StoreImportServiceImpl.java +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/terminal/service/impl/StoreImportServiceImpl.java @@ -1,5 +1,6 @@ package com.chushang.inspection.terminal.service.impl; +import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.ObjectUtil; @@ -12,7 +13,12 @@ import com.chushang.common.mybatis.page.CommonParam; import com.chushang.common.mybatis.utils.PageResult; import com.chushang.common.mybatis.utils.WrapperUtils; import com.chushang.inspection.project.dto.ProjectDTO; +import com.chushang.inspection.project.dto.TaskQuery; +import com.chushang.inspection.project.po.PollingTask; import com.chushang.inspection.project.po.WrkProject; +import com.chushang.inspection.project.service.PollingTaskService; +import com.chushang.inspection.project.vo.ConfigVO; +import com.chushang.inspection.project.vo.TaskVO; import com.chushang.inspection.terminal.dto.StoreImportDTO; import com.chushang.inspection.terminal.mapper.StoreImportMapper; import com.chushang.inspection.terminal.mapper.StoreMapper; @@ -28,6 +34,8 @@ import com.chushang.inspection.terminal.service.StoreImportService; import com.chushang.inspection.terminal.vo.StoreVO; import com.chushang.inspection.terminal.vo.TerminalVO; import com.chushang.inspection.utils.BeanCopyUtils; +import com.chushang.inspection.work.po.WrkImg; +import com.chushang.inspection.work.vo.WrkImgVO; import com.chushang.security.utils.SecurityUtils; import com.google.common.collect.Lists; import lombok.extern.slf4j.Slf4j; @@ -58,6 +66,9 @@ public class StoreImportServiceImpl extends ServiceImpl queryWrapper = WrapperUtils.builder(query, commonParam); @@ -71,15 +82,25 @@ public class StoreImportServiceImpl extends ServiceImpl lists) { int i = 0; - for (Long id : ids) { + for (StoreImportDTO storeImportDTO : lists) { i++; - StoreImport storeImport = getById(id); - if (ObjectUtil.isEmpty(storeImport)) { - throw new RuntimeException("导入失败"); + if (StringUtils.isBlank(storeImportDTO.getTaskName())) { + throw new RuntimeException("任务名称不能为空"); } + + // 通过任务名称查询任务 + List list = pollingTaskService.list(new LambdaQueryWrapper().eq(PollingTask::getName, storeImportDTO.getTaskName())); + if (CollectionUtil.isEmpty(list)){ + throw new RuntimeException("任务名称不存在"); + } + PollingTask topTask = pollingTaskService.getTopTask(list.get(0).getId()); + StoreImport storeImport = BeanCopyUtils.copy(storeImportDTO, StoreImport.class); Store store = BeanCopyUtils.copy(storeImport, Store.class); + store.setTaskId(topTask.getId()); + store.setDeptId(SecurityUtils.getDeptId()); + store.setLowerTaskId(list.get(0).getId()); store.setStoreId(IdUtil.getSnowflake().nextId()); storeMapper.insert(store); Terminal terminal = BeanCopyUtils.copy(storeImport, Terminal.class); @@ -89,26 +110,10 @@ public class StoreImportServiceImpl extends ServiceImpl dtoList) { - for (StoreImportDTO storeImportDTO : dtoList) { - StoreImport copy = BeanCopyUtils.copy(storeImportDTO, StoreImport.class); - copy.setDeptId(SecurityUtils.getDeptId()); - copy.setId(IdUtil.getSnowflake().nextId()); - try { - save(copy); - } catch (Exception e) { - e.printStackTrace(); - log.error("商户导入异常:{}", copy.getStoreName()); - } - } - } }