| package com.doumee.api.business; | 
|   | 
| import com.doumee.api.BaseController; | 
| import com.doumee.core.annotation.excel.ExcelExporter; | 
| import com.doumee.core.annotation.pr.PreventRepeat; | 
| import com.doumee.core.constants.ResponseStatus; | 
| import com.doumee.core.exception.BusinessException; | 
| import com.doumee.core.model.ApiResponse; | 
| import com.doumee.core.model.PageWrap; | 
| import com.doumee.core.model.PageData; | 
| import com.doumee.core.utils.Constants; | 
| import com.doumee.dao.admin.request.UpdateShopSortDTO; | 
| import com.doumee.dao.business.model.Shop; | 
| import com.doumee.dao.business.vo.ShopTreeVo; | 
| import com.doumee.service.business.ShopService; | 
| import io.swagger.annotations.*; | 
| import org.apache.shiro.authz.annotation.RequiresPermissions; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.data.redis.core.RedisTemplate; | 
| import org.springframework.validation.annotation.Validated; | 
| import org.springframework.web.bind.annotation.*; | 
| import org.springframework.web.multipart.MultipartFile; | 
|   | 
| import javax.servlet.http.HttpServletResponse; | 
|   | 
| import java.io.File; | 
| import java.util.ArrayList; | 
| import java.util.List; | 
|   | 
| /** | 
|  * @author 江蹄蹄 | 
|  * @date 2024/07/04 14:40 | 
|  */ | 
| @Api(tags = "志邦组织信息表") | 
| @RestController | 
| @RequestMapping("/business/shop") | 
| public class ShopController extends BaseController { | 
|   | 
|     @Autowired | 
|     private RedisTemplate<String, Object> redisTemplate; | 
|     @Autowired | 
|     private ShopService shopService; | 
|   | 
|     @PreventRepeat | 
|     @ApiOperation("新建") | 
|     @PostMapping("/create") | 
|     @RequiresPermissions("business:shop:create") | 
|     public ApiResponse create(@RequestBody Shop shop) { | 
|         return ApiResponse.success(shopService.create(shop)); | 
|     } | 
|   | 
|     @ApiOperation("根据ID删除") | 
|     @GetMapping("/delete/{id}") | 
|     @RequiresPermissions("business:shop:delete") | 
|     public ApiResponse deleteById(@PathVariable Long id) { | 
|         shopService.deleteById(id); | 
|         return ApiResponse.success(null); | 
|     } | 
|   | 
|     @ApiOperation("批量删除") | 
|     @GetMapping("/delete/batch") | 
|     @RequiresPermissions("business:shop:delete") | 
|     public ApiResponse deleteByIdInBatch(@RequestParam String ids) { | 
|         String [] idArray = ids.split(","); | 
|         List<Long> idList = new ArrayList<>(); | 
|         for (String id : idArray) { | 
|             idList.add(Long.valueOf(id)); | 
|         } | 
|         shopService.deleteByIdInBatch(idList); | 
|         return ApiResponse.success(null); | 
|     } | 
|   | 
|     @ApiOperation("根据ID修改") | 
|     @PostMapping("/updateById") | 
|     @RequiresPermissions("business:shop:update") | 
|     public ApiResponse updateById(@RequestBody Shop shop) { | 
|         shopService.updateById(shop); | 
|         return ApiResponse.success(null); | 
|     } | 
|   | 
|     @ApiOperation("分页查询") | 
|     @PostMapping("/page") | 
|     @RequiresPermissions("business:shop:query") | 
|     public ApiResponse<PageData<Shop>> findPage (@RequestBody PageWrap<Shop> pageWrap) { | 
|         return ApiResponse.success(shopService.findPage(pageWrap)); | 
|     } | 
|     @ApiOperation("组织树查询") | 
|     @GetMapping("/tree") | 
|     @ApiImplicitParams({ | 
|             @ApiImplicitParam(name = "type", dataType = "Integer", value = "组织类型1:一体商 ,2:加盟商,3:店面,4:部门(HR/加),5:虚拟店面(加/虚)"), | 
|     }) | 
|     @RequiresPermissions("business:shop:query") | 
|     public ApiResponse<List<ShopTreeVo>> tree (@RequestParam(required=false) Integer type){ | 
|         return ApiResponse.success(shopService.shopTreeCache(type)); | 
|     } | 
|     @ApiOperation("根据父级编码查询组织") | 
|     @GetMapping("/listByParent") | 
|     @ApiImplicitParams({ | 
|             @ApiImplicitParam(name = "parentId", dataType = "Integer", value = "父级编码"), | 
|     }) | 
|     @RequiresPermissions("business:shop:query") | 
|     public ApiResponse<List<Shop>> listByParent (@RequestParam(required=false) String parentId){ | 
|         return ApiResponse.success(shopService.listByParent(parentId)); | 
|     } | 
|     @ApiOperation(value = "组织信息初始化导入" ,notes = "组织信息初始化导入") | 
|     @PostMapping("/importExcel") | 
|     @ApiImplicitParams({ | 
|             @ApiImplicitParam(name = "file", value = "file", required = true, paramType = "query", dataType = "file", dataTypeClass = File.class), | 
|     }) | 
|     @RequiresPermissions("business:shop:create") | 
|     public ApiResponse<String> importExcel (@ApiParam(value = "file") MultipartFile file ) { | 
|         shopService.importBatch(file); | 
| //        shopService.dealShopNamePath(); | 
|         return ApiResponse.success("操作成功"); | 
|     } | 
|     @ApiOperation(value = "组织Fcode个性化信息导入" ,notes = "组织Fcode个性化信息导入") | 
|     @PostMapping("/importFcodeBatch") | 
|     @ApiImplicitParams({ | 
|             @ApiImplicitParam(name = "file", value = "file", required = true, paramType = "query", dataType = "file", dataTypeClass = File.class), | 
|     }) | 
|     @RequiresPermissions("business:shop:create") | 
|     public ApiResponse<String> importFcodeBatch (@ApiParam(value = "file") MultipartFile file ) { | 
| //        Boolean importing = (Boolean) redisTemplate.opsForValue().get(Constants.RedisKeys.IMPORTING_SHOP); | 
| //        if(importing!=null && importing){ | 
| //            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,已存在导入任务正在执行中,请稍后再试!"); | 
| //        } | 
|         shopService.importFcodeBatch(file); | 
|         return ApiResponse.success("操作成功"); | 
|     } | 
|     @ApiOperation(value = "组织品类初始化导入" ,notes = "组织品类初始化导入") | 
|     @PostMapping("/importCategoryBatch") | 
|     @ApiImplicitParams({ | 
|             @ApiImplicitParam(name = "file", value = "file", required = true, paramType = "query", dataType = "file", dataTypeClass = File.class), | 
|     }) | 
|     @RequiresPermissions("business:shop:create") | 
|     public ApiResponse<String> importCategoryBatch (@ApiParam(value = "file") MultipartFile file ) { | 
| //        Boolean importing = (Boolean) redisTemplate.opsForValue().get(Constants.RedisKeys.IMPORTING_SHOP); | 
| //        if(importing!=null && importing){ | 
| //            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,已存在导入任务正在执行中,请稍后再试!"); | 
| //        } | 
|         shopService.importCategoryBatch(file); | 
|         return ApiResponse.success("操作成功"); | 
|     } | 
|     @ApiOperation(value = "重置上下级关系" ,notes = "重置上下级关系") | 
|     @PostMapping("/resetRelations") | 
|     @RequiresPermissions("business:shop:create") | 
|     public ApiResponse<String> resetRelations ( ) { | 
|         Boolean importing = (Boolean) redisTemplate.opsForValue().get(Constants.RedisKeys.IMPORTING_SHOP); | 
|         if(importing!=null && importing){ | 
|             throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,已存在导入任务正在执行中,请稍后再试!"); | 
|         } | 
|         shopService.dealShopNamePath(); | 
|         return ApiResponse.success("操作成功"); | 
|     } | 
|   | 
|     @ApiOperation("排序") | 
|     @PostMapping("/updateSort") | 
|     @RequiresPermissions("business:shop:sort") | 
|     public ApiResponse updateSort (@Validated @RequestBody UpdateShopSortDTO dto ){ | 
|         shopService.updateSort(dto); | 
|         return ApiResponse.success(null); | 
|     } | 
|   | 
|     @ApiOperation("导出Excel") | 
|     @PostMapping("/exportExcel") | 
|     @RequiresPermissions("business:shop:exportExcel") | 
|     public void exportExcel (@RequestBody PageWrap<Shop> pageWrap, HttpServletResponse response) { | 
|         ExcelExporter.build(Shop.class).export(shopService.findPage(pageWrap).getRecords(), "志邦组织信息表", response); | 
|     } | 
|   | 
|     @ApiOperation("根据ID查询") | 
|     @GetMapping("/{id}") | 
|     @RequiresPermissions("business:shop:query") | 
|     public ApiResponse findById(@PathVariable Long id) { | 
|         return ApiResponse.success(shopService.findById(id)); | 
|     } | 
| } |