|
|
@@ -3,57 +3,45 @@ package org.springblade.client.port.controller;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
-import io.undertow.attribute.SubstituteEmptyWrapper;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
-import lombok.Data;
|
|
|
-import oracle.jdbc.proxy.annotation.Post;
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
-import org.springblade.client.container.service.BasicContainerDescService;
|
|
|
-import org.springblade.client.container.service.BasicContainerTypeService;
|
|
|
import org.springblade.client.dto.BasicPortDescDTO;
|
|
|
-import org.springblade.client.entity.BasicContainerType;
|
|
|
import org.springblade.client.entity.BasicPortDesc;
|
|
|
import org.springblade.client.entity.BasicPortType;
|
|
|
-import org.springblade.client.goods.enums.GoodsTypeEnum;
|
|
|
+import org.springblade.client.entity.BasicPortTypeDesc;
|
|
|
import org.springblade.client.port.service.BasicPortDescService;
|
|
|
import org.springblade.client.port.service.BasicPortTypeDescService;
|
|
|
import org.springblade.client.port.service.BasicPortTypeService;
|
|
|
-import org.springblade.client.vo.GoodsTypeVO;
|
|
|
import org.springblade.client.vo.PortTypeVO;
|
|
|
import org.springblade.core.secure.BladeUser;
|
|
|
import org.springblade.core.secure.utils.AuthUtil;
|
|
|
import org.springblade.core.secure.utils.SecureUtil;
|
|
|
import org.springblade.core.tenant.annotation.NonDS;
|
|
|
import org.springblade.core.tool.api.R;
|
|
|
-import org.springblade.core.tool.utils.Func;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springblade.core.tool.utils.StringUtil;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
import springfox.documentation.annotations.ApiIgnore;
|
|
|
|
|
|
import java.util.*;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
@NonDS
|
|
|
@ApiIgnore
|
|
|
@RestController
|
|
|
-@RequestMapping("/port")
|
|
|
@AllArgsConstructor
|
|
|
-public class PortController
|
|
|
-{
|
|
|
- @Autowired
|
|
|
- private BasicPortDescService basicPortDescService;
|
|
|
- @Autowired
|
|
|
- private BasicPortTypeService basicPortTypeService;
|
|
|
- @Autowired
|
|
|
- private BasicPortTypeDescService midBasicPortTypeDescService;
|
|
|
- @Autowired
|
|
|
- private BasicContainerDescService basicContainerDescService;
|
|
|
- @Autowired
|
|
|
- private BasicContainerTypeService basicContainerTypeService;
|
|
|
+@RequestMapping("/port")
|
|
|
+
|
|
|
+public class PortController {
|
|
|
+
|
|
|
+ private final BasicPortDescService basicPortDescService;
|
|
|
+
|
|
|
+ private final BasicPortTypeService basicPortTypeService;
|
|
|
+
|
|
|
+ private final BasicPortTypeDescService basicPortTypeDescService;
|
|
|
|
|
|
@GetMapping("list")
|
|
|
public R list(@RequestParam(name = "current", defaultValue = "1") Integer current,
|
|
|
@@ -63,27 +51,24 @@ public class PortController
|
|
|
@RequestParam(name = "unCode", required = false) String unCode,
|
|
|
@RequestParam(name = "typeId", required = false) Long typeId,
|
|
|
@RequestParam(name = "status", required = false) String status,
|
|
|
- @RequestParam(name = "enName",required = false) String enName)
|
|
|
- {
|
|
|
- Page<BasicPortDescDTO> page=new Page<>(current,size);
|
|
|
- IPage<BasicPortDescDTO> iPage = basicPortDescService.listBasicPortDesc(page, name, lines, unCode, status,typeId,AuthUtil.getTenantId(),enName);
|
|
|
+ @RequestParam(name = "enName", required = false) String enName) {
|
|
|
+ Page<BasicPortDescDTO> page = new Page<>(current, size);
|
|
|
+ IPage<BasicPortDescDTO> iPage = basicPortDescService.listBasicPortDesc(page, name, lines, unCode, status, typeId, AuthUtil.getTenantId(), enName);
|
|
|
return R.data(iPage);
|
|
|
}
|
|
|
|
|
|
- @PostMapping("add")
|
|
|
- public R add (@RequestBody BasicPortDescDTO dto)
|
|
|
- {
|
|
|
+ @PostMapping("add")
|
|
|
+ public R add(@RequestBody BasicPortDescDTO dto) {
|
|
|
dto.setTenantId(AuthUtil.getTenantId());
|
|
|
dto.setCreateTime(new Date());
|
|
|
dto.setCreateUser(SecureUtil.getUserId());
|
|
|
dto.setCreateUserName(SecureUtil.getUser().getUserName());
|
|
|
basicPortDescService.addBasicPortDesc(dto);
|
|
|
- return R.success("操作成功");
|
|
|
+ return R.success("操作成功");
|
|
|
}
|
|
|
|
|
|
@PutMapping("edit")
|
|
|
- public R edit( @RequestBody BasicPortDescDTO body )
|
|
|
- {
|
|
|
+ public R edit(@RequestBody BasicPortDescDTO body) {
|
|
|
body.setUpdateTime(new Date());
|
|
|
body.setUpdateUser(SecureUtil.getUserId());
|
|
|
body.setUpdateUserName(SecureUtil.getUser().getUserName());
|
|
|
@@ -92,9 +77,8 @@ public class PortController
|
|
|
}
|
|
|
|
|
|
@DeleteMapping("delete")
|
|
|
- public R delete(@RequestParam(name = "id", required = true) Long id)
|
|
|
- {
|
|
|
- List<Long> ids= Arrays.asList(id);
|
|
|
+ public R delete(@RequestParam(name = "id", required = true) Long id) {
|
|
|
+ List<Long> ids = Arrays.asList(id);
|
|
|
basicPortDescService.deleteLogic(ids);
|
|
|
return R.success("操作成功");
|
|
|
}
|
|
|
@@ -102,28 +86,25 @@ public class PortController
|
|
|
@GetMapping("type/list")
|
|
|
public R typeList(@RequestParam(name = "current", defaultValue = "1") Integer current,
|
|
|
@RequestParam(name = "size", defaultValue = "10") Integer size,
|
|
|
- @RequestParam(name = "portName", required = false) String portName ,
|
|
|
+ @RequestParam(name = "portName", required = false) String portName,
|
|
|
@RequestParam(name = "status", required = false) Integer status,
|
|
|
- @RequestParam(name = "parentId", required = false) Long parentId)
|
|
|
-
|
|
|
- {
|
|
|
- LambdaQueryWrapper<BasicPortType> typeLambdaQueryWrapper=new LambdaQueryWrapper<>();
|
|
|
+ @RequestParam(name = "parentId", required = false) Long parentId) {
|
|
|
+ LambdaQueryWrapper<BasicPortType> typeLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
typeLambdaQueryWrapper
|
|
|
- .eq(BasicPortType::getTenantId,AuthUtil.getTenantId())
|
|
|
- .like(StringUtils.isNotBlank(portName),BasicPortType::getName,portName)
|
|
|
- .eq(status!=null,BasicPortType::getStatus,status)
|
|
|
- .eq(parentId!=null,BasicPortType::getParentId,parentId)
|
|
|
- .orderByDesc(BasicPortType::getCreateTime);
|
|
|
- Page<BasicPortType> page=new Page<>(current,size);
|
|
|
- IPage<BasicPortType> iPage=basicPortTypeService.page(page,typeLambdaQueryWrapper);
|
|
|
+ .eq(BasicPortType::getTenantId, AuthUtil.getTenantId())
|
|
|
+ .like(StringUtils.isNotBlank(portName), BasicPortType::getName, portName)
|
|
|
+ .eq(status != null, BasicPortType::getStatus, status)
|
|
|
+ .eq(parentId != null, BasicPortType::getParentId, parentId)
|
|
|
+ .orderByDesc(BasicPortType::getCreateTime);
|
|
|
+ Page<BasicPortType> page = new Page<>(current, size);
|
|
|
+ IPage<BasicPortType> iPage = basicPortTypeService.page(page, typeLambdaQueryWrapper);
|
|
|
List<BasicPortType> records = iPage.getRecords();
|
|
|
- if(!CollectionUtils.isEmpty(records))
|
|
|
- {
|
|
|
- records.forEach(e->{
|
|
|
- LambdaQueryWrapper<BasicPortType> basicPortTypeLambdaQueryWrapper=new LambdaQueryWrapper<>();
|
|
|
- basicPortTypeLambdaQueryWrapper.eq(BasicPortType::getParentId,e.getId());
|
|
|
+ if (!CollectionUtils.isEmpty(records)) {
|
|
|
+ records.forEach(e -> {
|
|
|
+ LambdaQueryWrapper<BasicPortType> basicPortTypeLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ basicPortTypeLambdaQueryWrapper.eq(BasicPortType::getParentId, e.getId());
|
|
|
int count = basicPortTypeService.count(basicPortTypeLambdaQueryWrapper);
|
|
|
- e.setHasChildren(count>0?true:false);
|
|
|
+ e.setHasChildren(count > 0);
|
|
|
});
|
|
|
}
|
|
|
|
|
|
@@ -131,27 +112,24 @@ public class PortController
|
|
|
}
|
|
|
|
|
|
@GetMapping("getPortTypeList")
|
|
|
- public List<BasicPortType> getPortTypeList( @RequestParam(name = "pid", required = false) Long pid)
|
|
|
- {
|
|
|
- LambdaQueryWrapper<BasicPortType> lambdaQueryWrapper=new LambdaQueryWrapper<>();
|
|
|
- lambdaQueryWrapper.eq(pid!=null,BasicPortType::getParentId,pid);
|
|
|
- lambdaQueryWrapper.eq(BasicPortType::getTenantId,AuthUtil.getTenantId());
|
|
|
+ public List<BasicPortType> getPortTypeList(@RequestParam(name = "pid", required = false) Long pid) {
|
|
|
+ LambdaQueryWrapper<BasicPortType> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ lambdaQueryWrapper.eq(pid != null, BasicPortType::getParentId, pid);
|
|
|
+ lambdaQueryWrapper.eq(BasicPortType::getTenantId, AuthUtil.getTenantId());
|
|
|
List<BasicPortType> typeList = basicPortTypeService.list(lambdaQueryWrapper);
|
|
|
- if(!CollectionUtils.isEmpty(typeList))
|
|
|
- {
|
|
|
- typeList.forEach(e->{
|
|
|
- LambdaQueryWrapper<BasicPortType> basicPortTypeLambdaQueryWrapper=new LambdaQueryWrapper<>();
|
|
|
- basicPortTypeLambdaQueryWrapper.eq(BasicPortType::getParentId,e.getId());
|
|
|
+ if (!CollectionUtils.isEmpty(typeList)) {
|
|
|
+ typeList.forEach(e -> {
|
|
|
+ LambdaQueryWrapper<BasicPortType> basicPortTypeLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ basicPortTypeLambdaQueryWrapper.eq(BasicPortType::getParentId, e.getId());
|
|
|
int count = basicPortTypeService.count(basicPortTypeLambdaQueryWrapper);
|
|
|
- e.setHasChildren(count>0?true:false);
|
|
|
+ e.setHasChildren(count > 0);
|
|
|
});
|
|
|
}
|
|
|
return typeList;
|
|
|
}
|
|
|
|
|
|
@PostMapping("type/add")
|
|
|
- public R typeList(@RequestBody BasicPortType portType )
|
|
|
- {
|
|
|
+ public R typeList(@RequestBody BasicPortType portType) {
|
|
|
portType.setTenantId(AuthUtil.getTenantId());
|
|
|
portType.setCreateTime(new Date());
|
|
|
portType.setCreateUser(SecureUtil.getUserId());
|
|
|
@@ -161,8 +139,7 @@ public class PortController
|
|
|
}
|
|
|
|
|
|
@PutMapping("type/edit")
|
|
|
- public R typeEdit(@RequestBody BasicPortType portType)
|
|
|
- {
|
|
|
+ public R typeEdit(@RequestBody BasicPortType portType) {
|
|
|
portType.setUpdateTime(new Date());
|
|
|
portType.setUpdateUser(SecureUtil.getUserId());
|
|
|
portType.setUpdateUserName(SecureUtil.getUser().getUserName());
|
|
|
@@ -171,17 +148,15 @@ public class PortController
|
|
|
}
|
|
|
|
|
|
@DeleteMapping("type/delete")
|
|
|
- public R typeDelet(@RequestParam(name = "id", required = true) Long id)
|
|
|
- {
|
|
|
- LambdaQueryWrapper<BasicPortType> typeLambdaQueryWrapper=new LambdaQueryWrapper<>();
|
|
|
- typeLambdaQueryWrapper.eq(BasicPortType::getParentId,id);
|
|
|
- int count=basicPortTypeService.count(typeLambdaQueryWrapper);
|
|
|
- if(count>0)
|
|
|
- {
|
|
|
+ public R typeDelet(@RequestParam(name = "id", required = true) Long id) {
|
|
|
+ LambdaQueryWrapper<BasicPortType> typeLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ typeLambdaQueryWrapper.eq(BasicPortType::getParentId, id);
|
|
|
+ int count = basicPortTypeService.count(typeLambdaQueryWrapper);
|
|
|
+ if (count > 0) {
|
|
|
throw new RuntimeException("存在子项无法删除");
|
|
|
}
|
|
|
|
|
|
- List<Long> ids= Arrays.asList(id);
|
|
|
+ List<Long> ids = Arrays.asList(id);
|
|
|
basicPortTypeService.deleteLogic(ids);
|
|
|
return R.success("操作成功");
|
|
|
}
|
|
|
@@ -195,28 +170,45 @@ public class PortController
|
|
|
}
|
|
|
|
|
|
@GetMapping("listPort")
|
|
|
- public List<Map<String,Object>> listPort()
|
|
|
- {
|
|
|
- List<Map<String,Object>> result=new ArrayList<>();
|
|
|
+ public List<Map<String, Object>> listPort() {
|
|
|
+ List<Map<String, Object>> result = new ArrayList<>();
|
|
|
List<BasicPortDesc> list = basicPortDescService.list();
|
|
|
- if(!CollectionUtils.isEmpty(list))
|
|
|
- {
|
|
|
- list.forEach(e->{
|
|
|
- Map<String,Object> model=new HashMap();
|
|
|
- model.put("id",e.getId());
|
|
|
- model.put("name",e.getName());
|
|
|
+ if (!CollectionUtils.isEmpty(list)) {
|
|
|
+ list.forEach(e -> {
|
|
|
+ Map<String, Object> model = new HashMap<>();
|
|
|
+ model.put("id", e.getId());
|
|
|
+ model.put("name", e.getName());
|
|
|
result.add(model);
|
|
|
});
|
|
|
}
|
|
|
return result;
|
|
|
}
|
|
|
+
|
|
|
@GetMapping("/portList")
|
|
|
- public R<List<BasicPortDesc>> portList(BasicPortDesc basicPortDesc){
|
|
|
+ public R<List<BasicPortDesc>> portList(BasicPortDesc basicPortDesc) {
|
|
|
basicPortDesc.setIsDeleted(0);
|
|
|
basicPortDesc.setTenantId(SecureUtil.getTenantId());
|
|
|
- return R.data(basicPortDescService.list(new QueryWrapper<BasicPortDesc>().setEntity(basicPortDesc)));
|
|
|
- }
|
|
|
+ QueryWrapper<BasicPortDesc> queryWrapper = new QueryWrapper<BasicPortDesc>().setEntity(basicPortDesc);
|
|
|
+
|
|
|
+ if (StringUtil.isNotBlank(basicPortDesc.getTypeName())) {
|
|
|
+ List<Long> typeIdList = basicPortTypeService.list(new LambdaQueryWrapper<BasicPortType>()
|
|
|
+ .select(BasicPortType::getId)
|
|
|
+ .eq(BasicPortType::getName, basicPortDesc)
|
|
|
+ .eq(BasicPortType::getTenantId, AuthUtil.getTenantId())
|
|
|
+ .eq(BasicPortType::getIsDeleted, 0)
|
|
|
+ ).stream().map(BasicPortType::getId).collect(Collectors.toList());
|
|
|
+
|
|
|
+ List<Long> descIdList = basicPortTypeDescService.list(new LambdaQueryWrapper<BasicPortTypeDesc>()
|
|
|
+ .select(BasicPortTypeDesc::getPortsId)
|
|
|
+ .in(BasicPortTypeDesc::getPortsTypeId, typeIdList)
|
|
|
+ .eq(BasicPortTypeDesc::getIsDeleted, 0)
|
|
|
+ ).stream().map(BasicPortTypeDesc::getPortsId).collect(Collectors.toList());
|
|
|
+
|
|
|
+ queryWrapper.in("id", descIdList);
|
|
|
+ }
|
|
|
|
|
|
+ return R.data(basicPortDescService.list(queryWrapper));
|
|
|
+ }
|
|
|
|
|
|
|
|
|
}
|