package doumeemes.api.ext; 
 | 
  
 | 
import doumeemes.api.BaseController; 
 | 
import doumeemes.core.annotation.excel.ExcelExporter; 
 | 
import doumeemes.core.annotation.pr.PreventRepeat; 
 | 
import doumeemes.core.model.ApiResponse; 
 | 
import doumeemes.core.model.LoginUserInfo; 
 | 
import doumeemes.core.model.PageData; 
 | 
import doumeemes.core.model.PageWrap; 
 | 
import doumeemes.core.utils.Constants; 
 | 
import doumeemes.dao.business.model.BarcodeParam; 
 | 
import doumeemes.dao.business.model.Warehouse; 
 | 
import doumeemes.dao.ext.dto.QueryWStockExtDTO; 
 | 
import doumeemes.dao.ext.dto.QueryWarehouseExtDTO; 
 | 
import doumeemes.dao.ext.vo.WStockExtListVO; 
 | 
import doumeemes.dao.ext.vo.WarehouseExtListVO; 
 | 
import doumeemes.service.business.BarcodeParamService; 
 | 
import doumeemes.service.business.WarehouseService; 
 | 
import doumeemes.service.ext.WStockExtService; 
 | 
import doumeemes.service.ext.WarehouseExtService; 
 | 
import io.swagger.annotations.Api; 
 | 
import io.swagger.annotations.ApiOperation; 
 | 
import org.apache.shiro.SecurityUtils; 
 | 
import org.apache.shiro.authz.annotation.RequiresPermissions; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.web.bind.annotation.*; 
 | 
  
 | 
import javax.servlet.http.HttpServletResponse; 
 | 
import java.util.ArrayList; 
 | 
import java.util.Date; 
 | 
import java.util.List; 
 | 
  
 | 
/** 
 | 
 * 仓库信息接口 
 | 
 * @author 江蹄蹄 
 | 
 * @date 2022/05/05 11:37 
 | 
 */ 
 | 
@RestController 
 | 
@RequestMapping("/ext/warehouseExt") 
 | 
@Api(tags = "仓库信息接口") 
 | 
public class WarehouseExtController extends BaseController { 
 | 
  
 | 
    @Autowired 
 | 
    private WarehouseExtService warehouseExtService; 
 | 
     
 | 
    @Autowired 
 | 
    private WarehouseService warehouseService; 
 | 
  
 | 
    @Autowired 
 | 
    private WStockExtService wStockExtService; 
 | 
  
 | 
    @Autowired 
 | 
    private BarcodeParamService barcodeParamService; 
 | 
  
 | 
  
 | 
    @PreventRepeat 
 | 
    @ApiOperation("新建") 
 | 
    @PostMapping("/create") 
 | 
    @RequiresPermissions("ext:warehouseext:create") 
 | 
    public ApiResponse create(@RequestBody Warehouse warehouse) { 
 | 
  
 | 
        //获取二维码规则 
 | 
        BarcodeParam queryparam=new BarcodeParam(); 
 | 
        queryparam.setDepartId(getLoginUser().getCurComDepartment().getId()); 
 | 
        queryparam.setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        queryparam.setType(Constants.BARCODEPARAM_TYPE.warehouse); 
 | 
        BarcodeParam barcodeParam =barcodeParamService.findOne(queryparam); 
 | 
        if(barcodeParam==null){ 
 | 
            return ApiResponse.failed("请先完善二维码篮筐配置"); 
 | 
        } 
 | 
        warehouse.setQrcode(barcodeParam.getId()); 
 | 
  
 | 
        Warehouse search=new Warehouse(); 
 | 
        search.setDeleted(Constants.ZERO); 
 | 
        search.setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        search.setName(warehouse.getName()); 
 | 
        List<Warehouse> listname= warehouseService.findList(search); 
 | 
  
 | 
        Warehouse search1=new Warehouse(); 
 | 
        search1.setDeleted(Constants.ZERO); 
 | 
        search1.setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        search1.setCode(warehouse.getCode()); 
 | 
        List<Warehouse> listcode= warehouseService.findList(search1); 
 | 
  
 | 
        if(listname.size()>0||listcode.size()>0){ 
 | 
            return ApiResponse.failed("同一组织下编码/名称已存在,不允许添加"); 
 | 
        } 
 | 
  
 | 
        warehouse.setDeleted(Constants.ZERO); 
 | 
        warehouse.setCreateTime(new Date()); 
 | 
        warehouse.setCreateUser(getLoginUser().getId()); 
 | 
        warehouse.setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        warehouse.setDepartId(getLoginUser().getCurComDepartment().getId()); 
 | 
        warehouse.setStatus( Constants.ONE); 
 | 
        return ApiResponse.success(warehouseService.create(warehouse)); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("根据ID删除") 
 | 
    @GetMapping("/delete/{id}") 
 | 
    @RequiresPermissions("ext:warehouseext:delete") 
 | 
    public ApiResponse deleteById(@PathVariable Integer id) { 
 | 
        Warehouse warehouse=new Warehouse(); 
 | 
        warehouse.setId(id); 
 | 
        warehouse.setDeleted(Constants.ONE); 
 | 
        warehouseService.updateById(warehouse); 
 | 
        return ApiResponse.success(null); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("批量删除") 
 | 
    @GetMapping("/delete/batch") 
 | 
    @RequiresPermissions("ext:warehouseext:delete") 
 | 
    public ApiResponse deleteByIds(@RequestParam String ids) { 
 | 
        String [] idArray = ids.split(","); 
 | 
        List<Warehouse> idList = new ArrayList<>(); 
 | 
        for (String id : idArray) { 
 | 
            Warehouse warehouse=new Warehouse(); 
 | 
            warehouse.setDeleted(Constants.ONE); 
 | 
            warehouse.setId(Integer.valueOf(id)); 
 | 
            idList.add(warehouse); 
 | 
        } 
 | 
        warehouseService.updateByIdInBatch(idList); 
 | 
        return ApiResponse.success(null); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("根据ID修改") 
 | 
    @PostMapping("/updateById") 
 | 
    @RequiresPermissions("ext:warehouseext:update") 
 | 
    public ApiResponse updateById(@RequestBody Warehouse warehouse) { 
 | 
        return warehouseService.editUpdateById(warehouse); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("分页查询") 
 | 
    @PostMapping("/page") 
 | 
    @RequiresPermissions("ext:warehouseext:query") 
 | 
    public ApiResponse<PageData<WarehouseExtListVO>> findPage (@RequestBody PageWrap<QueryWarehouseExtDTO> pageWrap) { 
 | 
        pageWrap.getModel().setDeleted(Constants.ZERO); 
 | 
        pageWrap.getModel().setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        pageWrap.getModel().setDepartId(getLoginUser().getCurComDepartment().getId()); 
 | 
        return ApiResponse.success(warehouseExtService.findPage(pageWrap)); 
 | 
    } 
 | 
  
 | 
  
 | 
  
 | 
    @ApiOperation("后台根据权限分页查询") 
 | 
    @PostMapping("/QXpage") 
 | 
    @RequiresPermissions("ext:warehouseext:query") 
 | 
    public ApiResponse<PageData<WarehouseExtListVO>> QXpage (@RequestBody PageWrap<QueryWarehouseExtDTO> pageWrap) { 
 | 
        pageWrap.getModel().setDeleted(Constants.ZERO); 
 | 
        pageWrap.getModel().setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        pageWrap.getModel().setDepartId(getLoginUser().getCurComDepartment().getId()); 
 | 
        return ApiResponse.success(warehouseExtService.QXpage(pageWrap)); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("导出Excel") 
 | 
    @PostMapping("/exportExcel") 
 | 
    @RequiresPermissions("ext:warehouseext:exportExcel") 
 | 
    public void exportExcel (@RequestBody PageWrap<QueryWarehouseExtDTO> pageWrap, HttpServletResponse response) { 
 | 
        ExcelExporter.build(WarehouseExtListVO.class).export(warehouseExtService.findPage(pageWrap).getRecords(), "仓库信息", response); 
 | 
    } 
 | 
  
 | 
    @ApiOperation("根据ID查询") 
 | 
    @GetMapping("/{id}") 
 | 
    @RequiresPermissions("ext:warehouseext:query") 
 | 
    public ApiResponse findById(@PathVariable Integer id) { 
 | 
        return ApiResponse.success(warehouseService.findById(id)); 
 | 
    } 
 | 
  
 | 
  
 | 
    @ApiOperation("查询当前主组织下所有数据") 
 | 
    @PostMapping("/queryAllData") 
 | 
    @RequiresPermissions("ext:warehouseext:queryAllData") 
 | 
    public ApiResponse<List<WarehouseExtListVO>> queryAllData (@RequestBody QueryWarehouseExtDTO pageWrap) { 
 | 
        pageWrap.setDeleted(Constants.ZERO); 
 | 
        pageWrap.setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        pageWrap.setDepartId(getLoginUser().getCurComDepartment().getId()); 
 | 
        return ApiResponse.success(warehouseExtService.queryAllData(pageWrap)); 
 | 
    } 
 | 
  
 | 
  
 | 
    @ApiOperation("新增货位查询当前权限下的数据") 
 | 
    @PostMapping("/queryListByJurisdiction") 
 | 
    public ApiResponse<List<WarehouseExtListVO>> queryListByJurisdiction (@RequestBody QueryWarehouseExtDTO pageWrap) { 
 | 
        pageWrap.setDeleted(Constants.ZERO); 
 | 
        pageWrap.setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        pageWrap.setDepartId(getLoginUser().getCurComDepartment().getId()); 
 | 
        return ApiResponse.success(warehouseExtService.queryListByJurisdiction(pageWrap)); 
 | 
    } 
 | 
  
 | 
    @GetMapping("/upsateStatus") 
 | 
    @RequiresPermissions("ext:warehouselocationext:upsateStatus") 
 | 
    public ApiResponse upsateStatus(@RequestParam String  id,@RequestParam String status) { 
 | 
        Warehouse data=  warehouseService.findById(Integer.valueOf(id)); 
 | 
  
 | 
        QueryWStockExtDTO wStock=new QueryWStockExtDTO(); 
 | 
        wStock.setDeleted(Constants.ZERO); 
 | 
        wStock.setRootDepartId(getLoginUser().getRootDepartment().getId()); 
 | 
        wStock.setWarehouseId(data.getId()); 
 | 
        wStock.setGreaterZero(Constants.ONE); 
 | 
       List<WStockExtListVO> list= wStockExtService.getListBynum(wStock); 
 | 
       if(list.size()>0){ 
 | 
           return ApiResponse.failed("库存的库存量大于0,不允许失效"); 
 | 
       } 
 | 
        data.setStatus(Integer.valueOf(status)); 
 | 
        warehouseService.updateById(data); 
 | 
        return ApiResponse.success(null); 
 | 
    } 
 | 
  
 | 
    @GetMapping("/updateHWStatus") 
 | 
    @RequiresPermissions("ext:warehouselocationext:updateHWStatus") 
 | 
    public ApiResponse updateHWStatus(@RequestParam String  id,@RequestParam String useLocation) { 
 | 
        Warehouse warehouse=new Warehouse(); 
 | 
        warehouse.setId(Integer.valueOf(id)); 
 | 
        warehouse.setUseLocation(Integer.valueOf(useLocation)); 
 | 
       return  warehouseService.updateByCondition(warehouse); 
 | 
    } 
 | 
  
 | 
  
 | 
  
 | 
    @ApiOperation("查询公司级组织下仓库绑定的仓位集合") 
 | 
    @PostMapping("/queryWareHouserAndLocaltion") 
 | 
    public ApiResponse<List<WarehouseExtListVO>> queryWareHouserAndLocaltion (@RequestBody QueryWarehouseExtDTO pageWrap) { 
 | 
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); 
 | 
        pageWrap.setDeleted(Constants.ZERO); 
 | 
        pageWrap.setRootDepartId(user.getRootDepartment().getId()); 
 | 
//        if(!Constants.equalsInteger(user.getCurComDepartment().getId(),user.getRootDepartment().getId())){ 
 | 
            //如果当前选择的公司级组织非根组织信息,只能查看当前选择公司级组织数据 
 | 
            pageWrap.setDepartId(user.getCurComDepartment().getId()); 
 | 
//        } 
 | 
        return ApiResponse.success(warehouseExtService.queryWareHouserAndLocaltion(pageWrap)); 
 | 
    } 
 | 
  
 | 
} 
 |