Browse Source

仓库管理、商品管理

zhanglei
fanzongzhe 1 year ago
parent
commit
411d7dd013
  1. 2
      yxt-as/src/main/java/com/yxt/anrui/as/biz/asbusrepairbillreversesettle/AsBusrepairBillReverseSettleMapper.xml
  2. 73
      yxt-as/src/main/java/com/yxt/anrui/as/biz/asbusrepairbillreversesettle/AsBusrepairBillReverseSettleService.java
  3. 12
      yxt-as/src/main/java/com/yxt/anrui/as/biz/asbusreservebill/AsBusreserveBillService.java
  4. 4
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoDto.java
  5. 5
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoMapper.java
  6. 25
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoMapper.xml
  7. 7
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoQuery.java
  8. 97
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoService.java
  9. 3
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoVo.java
  10. 2
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpu.java
  11. 7
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpuListQuery.java
  12. 4
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpuMapper.java
  13. 17
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpuMapper.xml
  14. 18
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpuService.java
  15. 5
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsType.java
  16. 4
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeDto.java
  17. 4
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeMapper.java
  18. 22
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeMapper.xml
  19. 6
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeQuery.java
  20. 102
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeService.java
  21. 2
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeVo.java
  22. 2
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnit.java
  23. 2
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitDto.java
  24. 4
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitMapper.java
  25. 22
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitMapper.xml
  26. 7
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitQuery.java
  27. 96
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitService.java
  28. 2
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitVo.java
  29. 2
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerDto.java
  30. 4
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerMapper.java
  31. 22
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerMapper.xml
  32. 6
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerQuery.java
  33. 97
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerService.java
  34. 2
      yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerVo.java
  35. 22
      yxt-base-biz/src/main/java/com/yxt/base/feign/portal/privilege/PrivilegeQuery.java
  36. 21
      yxt-base-biz/src/main/java/com/yxt/base/feign/portal/sysuser/OrgList.java
  37. 28
      yxt-base-biz/src/main/java/com/yxt/base/feign/portal/sysuser/SysUserFeign.java
  38. 97
      yxt-base-biz/src/main/java/com/yxt/base/feign/portal/sysuser/SysUserVo.java
  39. 2
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaDto.java
  40. 4
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaMapper.java
  41. 13
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaMapper.xml
  42. 8
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaQuery.java
  43. 78
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaService.java
  44. 1
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaVo.java
  45. 3
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeDto.java
  46. 5
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeMapper.java
  47. 25
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeMapper.xml
  48. 8
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeQuery.java
  49. 92
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeService.java
  50. 2
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeVo.java
  51. 3
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoDto.java
  52. 4
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoMapper.java
  53. 17
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoMapper.xml
  54. 7
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoQuery.java
  55. 115
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoService.java
  56. 1
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackDto.java
  57. 4
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackMapper.java
  58. 17
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackMapper.xml
  59. 8
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackQuery.java
  60. 53
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackService.java
  61. 2
      yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackVo.java

2
yxt-as/src/main/java/com/yxt/anrui/as/biz/asbusrepairbillreversesettle/AsBusrepairBillReverseSettleMapper.xml

@ -60,7 +60,9 @@
as_busrepair_bill_reverse_settle AS s
LEFT JOIN as_busrepair_bill AS b ON s.sourceSid = b.sid
LEFT JOIN as_busrepair_bill_vech AS v ON b.sid = v.billSid
LEFT JOIN anrui_portal.sys_organization as so ON s.deptSid = so.sid
<where> ${ew.sqlSegment} </where>
ORDER BY s.createTime,s.id DESC
</select>
<select id="selBySourceSid" resultType="java.lang.Integer">
SELECT

73
yxt-as/src/main/java/com/yxt/anrui/as/biz/asbusrepairbillreversesettle/AsBusrepairBillReverseSettleService.java

@ -112,43 +112,42 @@ public class AsBusrepairBillReverseSettleService extends MybatisBaseService<AsBu
AsBusrepairBillReverseSettleQuery query = pq.getParams();
QueryWrapper<AsBusrepairBillReverseSettle> qw = new QueryWrapper<>();
if (StringUtils.isNotBlank(query.getMenuUrl())) {
// PrivilegeQuery privilegeQuery = new PrivilegeQuery();
// privilegeQuery.setOrgPath(query.getOrgPath());
// privilegeQuery.setMenuUrl(query.getMenuUrl());
// privilegeQuery.setUserSid(query.getUserSid());
// ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
// if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
// //数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
// String orgSidPath = query.getOrgPath();
// orgSidPath = orgSidPath + "/";
// int i1 = orgSidPath.indexOf("/");
// int i2 = orgSidPath.indexOf("/", i1 + 1);
// int i3 = orgSidPath.indexOf("/", i2 + 1);
// int i4 = orgSidPath.indexOf("/", i3 + 1);
// String orgLevelKey = defaultIdReltBean.getData();
// if ("1".equals(orgLevelKey)) {
// orgSidPath = orgSidPath.substring(0, i1);
// qw.like("s.orgSidPath", orgSidPath);
// } else if ("2".equals(orgLevelKey)) {
// orgSidPath = orgSidPath.substring(0, i2);
// qw.like("s.orgSidPath", orgSidPath);
// } else if ("3".equals(orgLevelKey)) {
// orgSidPath = orgSidPath.substring(0, i3);
// qw.like("s.orgSidPath", orgSidPath);
// } else if ("4".equals(orgLevelKey)) {
// orgSidPath = orgSidPath.substring(0, i4);
// qw.like("s.orgSidPath", orgSidPath);
// } else if ("5".equals(orgLevelKey)) {
// qw.eq("s.createBySid", query.getUserSid());
// } else {
// PagerVo<AsBusrepairBillReverseSettleVo> p = new PagerVo<>();
// return p;
// }
// } else {
// PagerVo<AsBusrepairBillReverseSettleVo> p = new PagerVo<>();
// return p;
// }
// qw.orderByDesc("s.createTime");
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(query.getOrgPath());
privilegeQuery.setMenuUrl(query.getMenuUrl());
privilegeQuery.setUserSid(query.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = query.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("so.orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("so.orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("so.orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("so.orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("s.createBySid", query.getUserSid());
} else {
PagerVo<AsBusrepairBillReverseSettleVo> p = new PagerVo<>();
return p;
}
} else {
PagerVo<AsBusrepairBillReverseSettleVo> p = new PagerVo<>();
return p;
}
}
if (StringUtils.isNotBlank(query.getUseOrgName())) {
qw.like("s.useOrgName", query.getUseOrgName());

12
yxt-as/src/main/java/com/yxt/anrui/as/biz/asbusreservebill/AsBusreserveBillService.java

@ -227,6 +227,12 @@ public class AsBusreserveBillService extends MybatisBaseService<AsBusreserveBill
sid = dtoSid;
AsBusreserveBill bill = fetchBySid(dtoSid);
BeanUtil.copyProperties(dto, bill, "id", "sid");
if (StringUtils.isBlank(dto.getReserveStart())) {
bill.setReserveStart(null);
}
if (StringUtils.isBlank(dto.getReserveEnd())) {
bill.setReserveEnd(null);
}
baseMapper.updateById(bill);
asBusreserveBillSitemService.delByMainSid(dtoSid);
List<AsbillSitemVo> sitemVos = dto.getSitemVos();
@ -242,6 +248,12 @@ public class AsBusreserveBillService extends MybatisBaseService<AsBusreserveBill
AsBusreserveBill entity = new AsBusreserveBill();
sid = entity.getSid();
BeanUtil.copyProperties(dto, entity, "id", "sid");
if (StringUtils.isBlank(dto.getReserveStart())) {
entity.setReserveStart(null);
}
if (StringUtils.isBlank(dto.getReserveEnd())) {
entity.setReserveEnd(null);
}
String orgPath = dto.getOrgPath();
entity.setOrgSidPath(orgPath);
ResultBean<String> orgSidByPath = sysStaffOrgFeign.getOrgSidByPath(orgPath);

4
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoDto.java

@ -24,4 +24,8 @@ public class BaseBrandInfoDto implements Dto {
private String letter;//品牌的首字母大写
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
private String userSid;
private String orgPath;
}

5
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoMapper.java

@ -16,5 +16,10 @@ import java.util.List;
@Mapper
public interface BaseBrandInfoMapper extends BaseMapper<BaseBrandInfo> {
int updateBySidIsDelete(List<String> list);
IPage<BaseBrandInfoVo> listPage(IPage<BaseBrandInfo> page, @Param(Constants.WRAPPER) QueryWrapper<BaseBrandInfo> qw);
BaseBrandInfo checkForInsert(@Param("brandCode") String brandCode, @Param("deptSid") String deptSid);
BaseBrandInfo checkForUpdate(@Param("brandCode") String brandCode, @Param("useOrgSid")String useOrgSid, @Param("sid") String sid);
}

25
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoMapper.xml

@ -5,13 +5,30 @@
<!-- ${ew.customSqlSegment} -->
<select id="listPage" resultType="com.yxt.base.biz.base.basebrandinfo.BaseBrandInfoVo">
select
*
from base_brand_info
SELECT
b.*
FROM
base_brand_info as b
LEFT JOIN anrui_portal.sys_organization as s ON b.useOrgSid = s.sid
<where>
${ew.sqlSegment}
</where>
</select>
<select id="checkForInsert" resultType="com.yxt.base.biz.base.basebrandinfo.BaseBrandInfo">
select *
from base_brand_info
where brandCode = #{brandCode}
and useOrgSid = #{deptSid}
and isDelete = 0
</select>
<select id="checkForUpdate" resultType="com.yxt.base.biz.base.basebrandinfo.BaseBrandInfo">
select *
from base_brand_info
where brandCode = #{brandCode}
and useOrgSid = #{useOrgSid}
and isDelete = 0
and sid !=#{sid}
</select>
<update id="updateBySidIsDelete">
UPDATE base_brand_info
SET isDelete=1
@ -20,4 +37,4 @@
#{item}
</foreach>
</update>
</mapper>
</mapper>

7
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoQuery.java

@ -1,6 +1,7 @@
package com.yxt.base.biz.base.basebrandinfo;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -10,4 +11,10 @@ import lombok.Data;
@Data
public class BaseBrandInfoQuery implements Query {
private String name;
@ApiModelProperty("使用组织sid")
private String orgPath;
private String userSid;
@ApiModelProperty("菜单url")
private String menuUrl;
}

97
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoService.java

@ -4,6 +4,12 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateTime;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yxt.base.biz.base.basegoodsspu.BaseGoodsSpuListVo;
import com.yxt.base.feign.portal.privilege.PrivilegeQuery;
import com.yxt.base.feign.portal.sysorganization.SysOrganizationFeign;
import com.yxt.base.feign.portal.sysorganization.SysOrganizationVo;
import com.yxt.base.feign.portal.sysstafforg.SysStaffOrgFeign;
import com.yxt.base.feign.portal.sysuser.SysUserFeign;
import com.yxt.common.base.config.component.FileUploadComponent;
import com.yxt.common.base.service.MybatisBaseService;
import com.yxt.common.base.utils.PagerUtil;
@ -29,16 +35,56 @@ import java.util.stream.Collectors;
public class BaseBrandInfoService extends MybatisBaseService<BaseBrandInfoMapper, BaseBrandInfo> {
@Autowired
private FileUploadComponent fileUploadComponent;
@Autowired
private SysUserFeign sysUserFeign;
@Autowired
private SysOrganizationFeign sysOrganizationFeign;
@Autowired
private SysStaffOrgFeign sysStaffOrgFeign;
public ResultBean<PagerVo<BaseBrandInfoVo>> listPage(PagerQuery<BaseBrandInfoQuery> pq) {
ResultBean rb = ResultBean.fireFail();
BaseBrandInfoQuery query = pq.getParams();
QueryWrapper<BaseBrandInfo> qw = new QueryWrapper<>();
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(query.getOrgPath());
privilegeQuery.setMenuUrl(query.getMenuUrl());
privilegeQuery.setUserSid(query.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = query.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("s.orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("s.orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("s.orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("s.orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("b..createBySid", query.getUserSid());
} else {
PagerVo<BaseGoodsSpuListVo> p = new PagerVo<>();
return rb.success().setData(p);
}
} else {
PagerVo<BaseGoodsSpuListVo> p = new PagerVo<>();
return rb.success().setData(p);
}
if(StringUtils.isNotBlank(query.getName())){
qw.like("brandName",query.getName());
qw.like("b.brandName",query.getName());
}
qw.ne("isDelete","1");
qw.ne("b.isDelete","1");
IPage<BaseBrandInfo> page = PagerUtil.queryToPage(pq);
IPage<BaseBrandInfoVo> pagging = baseMapper.listPage(page, qw);
PagerVo<BaseBrandInfoVo> p = PagerUtil.pageToVo(pagging, null);
@ -61,6 +107,7 @@ public class BaseBrandInfoService extends MybatisBaseService<BaseBrandInfoMapper
public ResultBean<String> saveOrUpdate(BaseBrandInfoDto dto) {
ResultBean rb = ResultBean.fireFail();
String sid = "";
String orgPath = dto.getOrgPath();
if (StringUtils.isNotBlank(dto.getSid())) {
sid = dto.getSid();
BaseBrandInfo wmsGoodsBrand = fetchBySid(dto.getSid());
@ -71,16 +118,47 @@ public class BaseBrandInfoService extends MybatisBaseService<BaseBrandInfoMapper
// wmsGoodsBrand.setBigPic(path);
// }
wmsGoodsBrand.setModifyTime(new Date());
baseMapper.updateById(wmsGoodsBrand);
} else {
BaseBrandInfo goods=baseMapper.selectOne(new QueryWrapper<BaseBrandInfo>().eq("brandName",dto.getBrandName()));
BaseBrandInfo goods=baseMapper.checkForUpdate(dto.getBrandCode(),wmsGoodsBrand.getUseOrgSid(),sid);
if(null!=goods){
return rb.setMsg("商品名不能重复");
return rb.setMsg("品牌代码不能重复");
}
baseMapper.updateById(wmsGoodsBrand);
} else {
BaseBrandInfo wmsGoodsBrand = new BaseBrandInfo();
sid = wmsGoodsBrand.getSid();
BeanUtil.copyProperties(dto, wmsGoodsBrand, "id", "sid");
wmsGoodsBrand.setCreateTime(new DateTime());
wmsGoodsBrand.setCreateBySid(dto.getUserSid());
String deptName = "";
String deptSid = "";
String createOrgSid = "";
if (StringUtils.isNotBlank(orgPath)) {
List<String> split = Arrays.asList(orgPath.split("/"));
if (split.size() > 1) {
//获取本级sid获取本级部门信息
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(split.size() - 2)).getData();
SysOrganizationVo sysOrganization1 = sysOrganizationFeign.fetchBySid(split.get(split.size() - 1)).getData();
deptName = sysOrganization.getName() + "/" + sysOrganization1.getName();
deptName = sysOrganization1.getName();
deptSid = sysOrganization1.getSid();
} else {
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(0)).getData();
deptName = sysOrganization.getName();
deptName = sysOrganization.getName();
deptSid = sysOrganization.getSid();
}
wmsGoodsBrand.setUseOrgSid(deptSid);
createOrgSid = sysStaffOrgFeign.getOrgSidByPath(orgPath).getData();
//创建组织使用组织
ResultBean<SysOrganizationVo> organizationResultBean = sysOrganizationFeign.fetchBySid(createOrgSid);
if (organizationResultBean.getData() != null) {
wmsGoodsBrand.setCreateOrgSid(createOrgSid);
}
}
BaseBrandInfo goods=baseMapper.checkForInsert(dto.getBrandCode(),deptSid);
if(null!=goods){
return rb.setMsg("品牌代码不能重复");
}
// if (StringUtils.isNotBlank(dto.getBigPic())) {
// String urlPrefix = fileUploadComponent.getUrlPrefix();
// String path = dto.getBigPic().substring(urlPrefix.length());
@ -97,6 +175,9 @@ public class BaseBrandInfoService extends MybatisBaseService<BaseBrandInfoMapper
BaseBrandInfo wmsGoodsBrand = fetchBySid(sid);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
BeanUtil.copyProperties(wmsGoodsBrand, vo);
if (null != wmsGoodsBrand) {
vo.setUserSid(wmsGoodsBrand.getCreateBySid());
}
// if (null != wmsGoodsBrand) {
//
// if (StringUtils.isNotBlank(wmsGoodsBrand.getBigPic())) {

3
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basebrandinfo/BaseBrandInfoVo.java

@ -29,4 +29,7 @@ public class BaseBrandInfoVo implements Vo {
private String letter;//品牌的首字母大写
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
private String userSid;
private String orgPath;
}

2
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpu.java

@ -30,6 +30,4 @@ public class BaseGoodsSpu extends BaseEntity {
private String isListed;//是否上架
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
private String useOrgName;//使用组织
private String createOrgName;//创建组织
}

7
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpuListQuery.java

@ -1,6 +1,7 @@
package com.yxt.base.biz.base.basegoodsspu;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -11,7 +12,11 @@ import lombok.Data;
@Data
public class BaseGoodsSpuListQuery implements Query {
private String orgPath; //组织全路径
@ApiModelProperty("使用组织sid")
private String orgPath;
private String userSid;
@ApiModelProperty("菜单url")
private String menuUrl;
private String useOrgName;//部门
private String createOrgName;//分公司
private String goodsName;//商品名称

4
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpuMapper.java

@ -20,4 +20,8 @@ public interface BaseGoodsSpuMapper extends BaseMapper<BaseGoodsSpu> {
IPage<BaseGoodsSpuListVo> goodsListPage(IPage<BaseGoodsSpu> page,@Param(Constants.WRAPPER) QueryWrapper<BaseGoodsSpu> qw);
void delBySpuSid(@Param("sid") String sid);
BaseGoodsSpu checkForInsert(@Param("goodsCode")String goodsCode, @Param("deptSid")String deptSid);
BaseGoodsSpu checkForUpdate(@Param("goodsCode")String goodsCode,@Param("useOrgSid") String useOrgSid, @Param("sid")String sid);
}

17
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpuMapper.xml

@ -65,9 +65,26 @@ WHERE
LEFT JOIN base_goods_type as t ON p.goodsTypeSid = t.sid
LEFT JOIN base_brand_info as b ON p.brandSid = b.sid
LEFT JOIN base_manufacturer as m ON p.manufacturerSid = m.sid
LEFT JOIN anrui_portal.sys_organization as u ON p.useOrgSid = u.sid
LEFT JOIN anrui_portal.sys_organization as c ON p.createOrgSid = c.sid
<where>
${ew.sqlSegment}
</where>
ORDER BY p.sortNo asc
</select>
<select id="checkForInsert" resultType="com.yxt.base.biz.base.basegoodsspu.BaseGoodsSpu">
select *
from base_goods_spu
where goodsCode = #{goodsCode}
and useOrgSid = #{deptSid}
and isDelete = 0
</select>
<select id="checkForUpdate" resultType="com.yxt.base.biz.base.basegoodsspu.BaseGoodsSpu">
select *
from base_goods_unit
where unitName = #{unitName}
and useOrgSid = #{useOrgSid}
and isDelete = 0
and sid != #{sid}
</select>
</mapper>

18
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsspu/BaseGoodsSpuService.java

@ -252,14 +252,15 @@ public class BaseGoodsSpuService extends MybatisBaseService<BaseGoodsSpuMapper,
}
BaseGoodsSpu spun = baseMapper.selectOne(new QueryWrapper<BaseGoodsSpu>().eq("sid", dto.getSid()));
if (spun != null) {
if (!spun.getSid().equals(dto.getSid())) {
return rb.setMsg("商品编码重复");
}
sid = dto.getSid();
BaseGoodsSpu wmsGoods = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, wmsGoods, "id", "sid");
wmsGoods.setModifyTime(new Date());
wmsGoods.setGoodsPY(PinYinUtils.sx(wmsGoods.getGoodsName()));
BaseGoodsSpu spu = baseMapper.checkForUpdate(dto.getGoodsCode(),wmsGoods.getUseOrgSid(),sid);
if (spu != null) {
return rb.setMsg("商品编码重复");
}
baseMapper.updateById(wmsGoods);
//商品sku
BaseGoodsSku skuUpdate = baseGoodsSkuService.getOneBySpuSid(sid);
@ -357,10 +358,7 @@ public class BaseGoodsSpuService extends MybatisBaseService<BaseGoodsSpuMapper,
baseGoodsSkuExtendService.insert(skuExtend);
}
} else {
BaseGoodsSpu spu = baseMapper.selectOne(new QueryWrapper<BaseGoodsSpu>().eq("goodsCode", dto.getGoodsCode()));
if (spu != null) {
return rb.setMsg("商品编码重复");
}
BaseGoodsSpu wmsGoods = new BaseGoodsSpu();
sid = wmsGoods.getSid();
BeanUtil.copyProperties(dto, wmsGoods, "id", "sid");
@ -383,17 +381,19 @@ public class BaseGoodsSpuService extends MybatisBaseService<BaseGoodsSpuMapper,
deptName = sysOrganization.getName();
deptSid = sysOrganization.getSid();
}
wmsGoods.setUseOrgName(deptName);
wmsGoods.setUseOrgSid(deptSid);
createOrgSid = sysStaffOrgFeign.getOrgSidByPath(orgPath).getData();
//创建组织使用组织
ResultBean<SysOrganizationVo> organizationResultBean = sysOrganizationFeign.fetchBySid(createOrgSid);
if (organizationResultBean.getData() != null) {
wmsGoods.setCreateOrgName(organizationResultBean.getData().getName());
wmsGoods.setCreateOrgSid(createOrgSid);
}
}
wmsGoods.setGoodsPY(PinYinUtils.sx(wmsGoods.getGoodsName()));
BaseGoodsSpu spu = baseMapper.checkForInsert(dto.getGoodsCode(),deptSid);
if (spu != null) {
return rb.setMsg("商品编码重复");
}
baseMapper.insert(wmsGoods);
//商品sku
BaseGoodsSku sku = new BaseGoodsSku();

5
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsType.java

@ -12,12 +12,13 @@ public class BaseGoodsType extends BaseEntity {
private String goodsTypeName;//商品类别名称
private String goodsTypeCode;//类别编码
private String percentageRate;//提成比例
private String percentageAmount;//提成金额
private Double percentageAmount;//提成金额
private String pSid;//父级sid
private String isParent;//是否为父节点,0为否,1为是,0标识为叶子节点
private String isGoodsID;//是否一品一码 0 否 1是
private String sortNo;//排序
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
private String outStockRule;//出库规则
private String outStockRule;//出库规则 先进先出0、先进后出1、保质期优先2
private String outStockRuleValue;//出库规则 先进先出0、先进后出1、保质期优先2
}

4
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeDto.java

@ -31,5 +31,7 @@ public class BaseGoodsTypeDto implements Dto {
private String pName;//创建组织sid
private String sids;//父级sid
private String outStockRule;//出库规则
private String outStockRuleValue;//出库规则 先进先出0、先进后出1、保质期优先2
private String userSid;
private String orgPath;
}

4
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeMapper.java

@ -17,4 +17,8 @@ import java.util.List;
public interface BaseGoodsTypeMapper extends BaseMapper<BaseGoodsType> {
IPage<BaseGoodsTypeVo> listPage(IPage<BaseGoodsType> page, @Param(Constants.WRAPPER) QueryWrapper<BaseGoodsType> qw);
int updateBySidIsDelete(List<String> list);
BaseGoodsType checkForInsert(@Param("goodsTypeCode") String goodsTypeCode, @Param("deptSid") String deptSid);
BaseGoodsType checkForUpdate(@Param("goodsTypeCode")String goodsTypeCode,@Param("deptSid") String useOrgSid, @Param("sid")String sid);
}

22
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeMapper.xml

@ -6,12 +6,28 @@
<select id="listPage" resultType="com.yxt.base.biz.base.basegoodstype.BaseGoodsTypeVo">
select
*
from base_goods_type
p.*
from base_goods_type as p
LEFT JOIN anrui_portal.sys_organization as u ON p.useOrgSid = u.sid
<where>
${ew.sqlSegment}
</where>
</select>
<select id="checkForInsert" resultType="com.yxt.base.biz.base.basegoodstype.BaseGoodsType">
select *
from base_goods_type
where goodsTypeCode = #{goodsTypeCode}
and useOrgSid = #{deptSid}
and isDelete = 0
</select>
<select id="checkForUpdate" resultType="com.yxt.base.biz.base.basegoodstype.BaseGoodsType">
select *
from base_goods_type
where goodsTypeCode = #{goodsTypeCode}
and useOrgSid = #{deptSid}
and isDelete = 0
and sid != #{sid}
</select>
<update id="updateBySidIsDelete">
UPDATE base_goods_type
SET isDelete=1
@ -20,4 +36,4 @@
#{item}
</foreach>
</update>
</mapper>
</mapper>

6
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeQuery.java

@ -1,6 +1,7 @@
package com.yxt.base.biz.base.basegoodstype;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -13,4 +14,9 @@ public class BaseGoodsTypeQuery implements Query {
private String code;//编码
private String goodID;//是否一品一码(goodID),0否,1是
private String outStockRule;//出库规则(先进先出0、先进后出1、保质期优先2)
@ApiModelProperty("使用组织sid")
private String orgPath;
private String userSid;
@ApiModelProperty("菜单url")
private String menuUrl;
}

102
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeService.java

@ -4,12 +4,20 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateTime;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yxt.base.biz.base.basebrandinfo.BaseBrandInfo;
import com.yxt.base.biz.base.basegoodsspu.BaseGoodsSpuListVo;
import com.yxt.base.feign.portal.privilege.PrivilegeQuery;
import com.yxt.base.feign.portal.sysorganization.SysOrganizationFeign;
import com.yxt.base.feign.portal.sysorganization.SysOrganizationVo;
import com.yxt.base.feign.portal.sysstafforg.SysStaffOrgFeign;
import com.yxt.base.feign.portal.sysuser.SysUserFeign;
import com.yxt.common.base.service.MybatisBaseService;
import com.yxt.common.base.utils.PagerUtil;
import com.yxt.common.base.utils.StringUtils;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
@ -25,25 +33,68 @@ import java.util.stream.Collectors;
@Service
public class BaseGoodsTypeService extends MybatisBaseService<BaseGoodsTypeMapper, BaseGoodsType> {
@Autowired
private SysUserFeign sysUserFeign;
@Autowired
private SysOrganizationFeign sysOrganizationFeign;
@Autowired
private SysStaffOrgFeign sysStaffOrgFeign;
public ResultBean<PagerVo<BaseGoodsTypeVo>> listPage(PagerQuery<BaseGoodsTypeQuery> pq) {
ResultBean rb = ResultBean.fireFail();
BaseGoodsTypeQuery query = pq.getParams();
QueryWrapper<BaseGoodsType> qw = new QueryWrapper<>();
if (StringUtils.isNotBlank(query.getMenuUrl())) {
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(query.getOrgPath());
privilegeQuery.setMenuUrl(query.getMenuUrl());
privilegeQuery.setUserSid(query.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = query.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("u.orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("u.orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("u.orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("u.orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("p.createBySid", query.getUserSid());
} else {
PagerVo<BaseGoodsTypeVo> p = new PagerVo<>();
return rb.success().setData(p);
}
} else {
PagerVo<BaseGoodsTypeVo> p = new PagerVo<>();
return rb.success().setData(p);
}
}
if(StringUtils.isNotBlank(query.getName())){
qw.like("goodsTypeName",query.getName());
qw.like("p.goodsTypeName",query.getName());
}
if(StringUtils.isNotBlank(query.getCode())){
qw.like("goodsTypeCode",query.getCode());
qw.like("p.goodsTypeCode",query.getCode());
}
if(StringUtils.isNotBlank(query.getGoodID())){
qw.eq("isGoodsID",query.getGoodID());
qw.eq("p.isGoodsID",query.getGoodID());
}
if(StringUtils.isNotBlank(query.getOutStockRule())){
qw.eq("outStockRule",query.getOutStockRule());
qw.eq("p.outStockRule",query.getOutStockRule());
}
qw.ne("isDelete","1");
qw.orderByDesc("sortNo");
qw.ne("p.isDelete","1");
qw.orderByAsc("sortNo");
IPage<BaseGoodsType> page = PagerUtil.queryToPage(pq);
IPage<BaseGoodsTypeVo> pagging = baseMapper.listPage(page, qw);
PagerVo<BaseGoodsTypeVo> p = PagerUtil.pageToVo(pagging, null);
@ -70,6 +121,7 @@ public class BaseGoodsTypeService extends MybatisBaseService<BaseGoodsTypeMapper
ResultBean rb = ResultBean.fireFail();
String sid = "";
dto.setPSid(dto.getSids());
String orgPath = dto.getOrgPath();
if (StringUtils.isNotBlank(dto.getSid())) {
sid = dto.getSid();
BaseGoodsType wmsGoodsType = fetchBySid(dto.getSid());
@ -79,6 +131,10 @@ public class BaseGoodsTypeService extends MybatisBaseService<BaseGoodsTypeMapper
if(StringUtils.isBlank(wmsGoodsType.getPSid())){
wmsGoodsType.setIsParent("1");
}
BaseGoodsType goods=baseMapper.checkForUpdate(dto.getGoodsTypeCode(),wmsGoodsType.getUseOrgSid(),sid);
if(null!=goods){
return rb.setMsg("类别编码不能重复");
}
baseMapper.updateById(wmsGoodsType);
} else {
BaseGoodsType wmsGoods = new BaseGoodsType();
@ -86,9 +142,40 @@ public class BaseGoodsTypeService extends MybatisBaseService<BaseGoodsTypeMapper
BeanUtil.copyProperties(dto, wmsGoods, "id", "sid");
wmsGoods.setCreateTime(new DateTime());
wmsGoods.setIsParent("0");
wmsGoods.setCreateBySid(dto.getUserSid());
if(StringUtils.isBlank(wmsGoods.getPSid())){
wmsGoods.setIsParent("1");
}
String deptName = "";
String deptSid = "";
String createOrgSid = "";
if (StringUtils.isNotBlank(orgPath)) {
List<String> split = Arrays.asList(orgPath.split("/"));
if (split.size() > 1) {
//获取本级sid获取本级部门信息
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(split.size() - 2)).getData();
SysOrganizationVo sysOrganization1 = sysOrganizationFeign.fetchBySid(split.get(split.size() - 1)).getData();
deptName = sysOrganization.getName() + "/" + sysOrganization1.getName();
deptName = sysOrganization1.getName();
deptSid = sysOrganization1.getSid();
} else {
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(0)).getData();
deptName = sysOrganization.getName();
deptName = sysOrganization.getName();
deptSid = sysOrganization.getSid();
}
wmsGoods.setUseOrgSid(deptSid);
createOrgSid = sysStaffOrgFeign.getOrgSidByPath(orgPath).getData();
//创建组织使用组织
ResultBean<SysOrganizationVo> organizationResultBean = sysOrganizationFeign.fetchBySid(createOrgSid);
if (organizationResultBean.getData() != null) {
wmsGoods.setCreateOrgSid(createOrgSid);
}
}
BaseGoodsType goods=baseMapper.checkForInsert(dto.getGoodsTypeCode(),deptSid);
if(null!=goods){
return rb.setMsg("类别编码不能重复");
}
baseMapper.insert(wmsGoods);
}
return rb.success().setMsg("成功");
@ -110,6 +197,7 @@ public class BaseGoodsTypeService extends MybatisBaseService<BaseGoodsTypeMapper
vo.setPName(wmsGoodsType1.getGoodsTypeName());
}
vo.setSids(wmsGoodsType.getPSid());
vo.setUserSid(wmsGoodsType.getCreateBySid());
if(StringUtils.isNotBlank(wmsGoodsType.getOutStockRule())){
if(wmsGoodsType.getOutStockRule().equals("0")){
vo.setOutStockRuleValue("先进先出");

2
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodstype/BaseGoodsTypeVo.java

@ -37,4 +37,6 @@ public class BaseGoodsTypeVo implements Vo {
private String outStockRule;//出库规则
private String sids;//创建组织sid
private String outStockRuleValue;//出库规则
private String userSid;
private String orgPath;
}

2
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnit.java

@ -11,4 +11,6 @@ import lombok.Data;
public class BaseGoodsUnit extends BaseEntity {
private String unitName;//单位名称
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
}

2
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitDto.java

@ -24,4 +24,6 @@ public class BaseGoodsUnitDto implements Dto {
private String state;
private String isDelete;
private String unitName;//单位名称
private String userSid;
private String orgPath;
}

4
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitMapper.java

@ -17,4 +17,8 @@ import java.util.List;
public interface BaseGoodsUnitMapper extends BaseMapper<BaseGoodsUnit> {
IPage<BaseGoodsUnitVo> listPage(IPage<BaseGoodsUnit> page, @Param(Constants.WRAPPER) QueryWrapper<BaseGoodsUnit> qw);
int updateBySidIsDelete(List<String> list);
BaseGoodsUnit checkForInsert(@Param("unitName") String unitName,@Param("deptSid") String deptSid);
BaseGoodsUnit checkForUpdate(@Param("unitName")String unitName, @Param("deptSid")String useOrgSid, @Param("sid")String sid);
}

22
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitMapper.xml

@ -6,12 +6,28 @@
<select id="listPage" resultType="com.yxt.base.biz.base.basegoodsunit.BaseGoodsUnitVo">
select
*
from base_goods_unit
p.*
from base_goods_unit as p
LEFT JOIN anrui_portal.sys_organization as u ON p.useOrgSid = u.sid
<where>
${ew.sqlSegment}
</where>
</select>
<select id="checkForInsert" resultType="com.yxt.base.biz.base.basegoodsunit.BaseGoodsUnit">
select *
from base_goods_unit
where unitName = #{unitName}
and useOrgSid = #{deptSid}
and isDelete = 0
</select>
<select id="checkForUpdate" resultType="com.yxt.base.biz.base.basegoodsunit.BaseGoodsUnit">
select *
from base_goods_unit
where unitName = #{unitName}
and useOrgSid = #{deptSid}
and isDelete = 0
and sid != #{sid}
</select>
<update id="updateBySidIsDelete">
UPDATE base_goods_unit
SET isDelete=1
@ -20,4 +36,4 @@
#{item}
</foreach>
</update>
</mapper>
</mapper>

7
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitQuery.java

@ -1,6 +1,7 @@
package com.yxt.base.biz.base.basegoodsunit;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -10,4 +11,10 @@ import lombok.Data;
@Data
public class BaseGoodsUnitQuery implements Query {
private String name;
@ApiModelProperty("使用组织sid")
private String orgPath;
private String userSid;
@ApiModelProperty("菜单url")
private String menuUrl;
}

96
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitService.java

@ -4,12 +4,20 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateTime;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yxt.base.biz.base.basemanufacturer.BaseManufacturer;
import com.yxt.base.biz.base.basemanufacturer.BaseManufacturerVo;
import com.yxt.base.feign.portal.privilege.PrivilegeQuery;
import com.yxt.base.feign.portal.sysorganization.SysOrganizationFeign;
import com.yxt.base.feign.portal.sysorganization.SysOrganizationVo;
import com.yxt.base.feign.portal.sysstafforg.SysStaffOrgFeign;
import com.yxt.base.feign.portal.sysuser.SysUserFeign;
import com.yxt.common.base.service.MybatisBaseService;
import com.yxt.common.base.utils.PagerUtil;
import com.yxt.common.base.utils.StringUtils;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
@ -24,16 +32,58 @@ import java.util.stream.Collectors;
*/
@Service
public class BaseGoodsUnitService extends MybatisBaseService<BaseGoodsUnitMapper, BaseGoodsUnit> {
@Autowired
private SysUserFeign sysUserFeign;
@Autowired
private SysOrganizationFeign sysOrganizationFeign;
@Autowired
private SysStaffOrgFeign sysStaffOrgFeign;
public ResultBean<PagerVo<BaseGoodsUnitVo>> listPage(PagerQuery<BaseGoodsUnitQuery> pq) {
ResultBean rb = ResultBean.fireFail();
BaseGoodsUnitQuery query = pq.getParams();
QueryWrapper<BaseGoodsUnit> qw = new QueryWrapper<>();
if (StringUtils.isNotBlank(query.getMenuUrl())) {
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(query.getOrgPath());
privilegeQuery.setMenuUrl(query.getMenuUrl());
privilegeQuery.setUserSid(query.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = query.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("u.orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("u.orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("u.orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("u.orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("p.createBySid", query.getUserSid());
} else {
PagerVo<BaseGoodsUnitVo> p = new PagerVo<>();
return rb.success().setData(p);
}
} else {
PagerVo<BaseGoodsUnitVo> p = new PagerVo<>();
return rb.success().setData(p);
}
}
if(StringUtils.isNotBlank(query.getName())){
qw.like("unitName",query.getName());
qw.like("p.unitName",query.getName());
}
qw.eq("p.isDelete","0");
IPage<BaseGoodsUnit> page = PagerUtil.queryToPage(pq);
IPage<BaseGoodsUnitVo> pagging = baseMapper.listPage(page, qw);
PagerVo<BaseGoodsUnitVo> p = PagerUtil.pageToVo(pagging, null);
@ -48,11 +98,16 @@ public class BaseGoodsUnitService extends MybatisBaseService<BaseGoodsUnitMapper
public ResultBean<String> saveOrUpdate(BaseGoodsUnitDto dto) {
ResultBean rb = ResultBean.fireFail();
String sid = "";
String orgPath = dto.getOrgPath();
if (StringUtils.isNotBlank(dto.getSid())) {
sid = dto.getSid();
BaseGoodsUnit wmsGoodsType = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, wmsGoodsType, "id", "sid");
wmsGoodsType.setModifyTime(new Date());
BaseGoodsUnit m=baseMapper.checkForUpdate(dto.getUnitName(),wmsGoodsType.getUseOrgSid(),sid);
if(null!=m){
return rb.setMsg("计量单位名称重复不能重复");
}
baseMapper.updateById(wmsGoodsType);
} else {
BaseGoodsUnit wmsGoods = new BaseGoodsUnit();
@ -64,6 +119,38 @@ public class BaseGoodsUnitService extends MybatisBaseService<BaseGoodsUnitMapper
// String path = dto.getPicUrl().substring(urlPrefix.length());
// lpkGoods.setPicUrl(path);
// }
wmsGoods.setCreateBySid(dto.getUserSid());
String deptName = "";
String deptSid = "";
String createOrgSid = "";
if (StringUtils.isNotBlank(orgPath)) {
List<String> split = Arrays.asList(orgPath.split("/"));
if (split.size() > 1) {
//获取本级sid获取本级部门信息
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(split.size() - 2)).getData();
SysOrganizationVo sysOrganization1 = sysOrganizationFeign.fetchBySid(split.get(split.size() - 1)).getData();
deptName = sysOrganization.getName() + "/" + sysOrganization1.getName();
deptName = sysOrganization1.getName();
deptSid = sysOrganization1.getSid();
} else {
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(0)).getData();
deptName = sysOrganization.getName();
deptName = sysOrganization.getName();
deptSid = sysOrganization.getSid();
}
wmsGoods.setUseOrgSid(deptSid);
createOrgSid = sysStaffOrgFeign.getOrgSidByPath(orgPath).getData();
//创建组织使用组织
ResultBean<SysOrganizationVo> organizationResultBean = sysOrganizationFeign.fetchBySid(createOrgSid);
if (organizationResultBean.getData() != null) {
wmsGoods.setCreateOrgSid(createOrgSid);
}
}
BaseGoodsUnit m=baseMapper.checkForInsert(dto.getUnitName(),deptSid);
if(null!=m){
return rb.setMsg("计量单位名称重复不能重复");
}
baseMapper.insert(wmsGoods);
}
return rb.success().setMsg("成功");
@ -76,6 +163,7 @@ public class BaseGoodsUnitService extends MybatisBaseService<BaseGoodsUnitMapper
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
BeanUtil.copyProperties(wmsGoodsType, vo);
if (null != wmsGoodsType) {
vo.setUserSid(wmsGoodsType.getCreateBySid());
// BeanUtil.copyProperties(wmsGoodsType, vo);
// if (StringUtils.isNotBlank(wmsGoods.getPicUrl())) {
// vo.setPicUrl(fileUploadComponent.getUrlPrefix() + wmsGoods.getPicUrl());

2
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basegoodsunit/BaseGoodsUnitVo.java

@ -24,4 +24,6 @@ public class BaseGoodsUnitVo implements Vo {
private String state;
private String isDelete;
private String unitName;//单位名称
private String userSid;
private String orgPath;
}

2
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerDto.java

@ -32,4 +32,6 @@ public class BaseManufacturerDto implements Dto {
private String sortNo;//排序
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
private String userSid;
private String orgPath;
}

4
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerMapper.java

@ -19,4 +19,8 @@ public interface BaseManufacturerMapper extends BaseMapper<BaseManufacturer> {
List<BaseManufacturerVo> getAllTypeByUseOrgSid(@Param("useOrgSid") String useOrgSid);
int updateBySidIsDelete(List<String> list);
BaseManufacturer checkForInsert(@Param("manufacturerCode")String manufacturerCode,@Param("deptSid") String deptSid);
BaseManufacturer checkForUpdate(@Param("manufacturerCode")String manufacturerCode,@Param("useOrgSid") String useOrgSid, @Param("sid")String sid);
}

22
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerMapper.xml

@ -6,8 +6,9 @@
<select id="listPage" resultType="com.yxt.base.biz.base.basemanufacturer.BaseManufacturerVo">
select
*
from base_manufacturer
p.*
from base_manufacturer as p
LEFT JOIN anrui_portal.sys_organization as u ON p.useOrgSid = u.sid
<where>
${ew.sqlSegment}
</where>
@ -17,6 +18,21 @@
from base_manufacturer
where useOrgSid = #{useOrgSid}
</select>
<select id="checkForInsert" resultType="com.yxt.base.biz.base.basemanufacturer.BaseManufacturer">
select *
from base_manufacturer
where manufacturerCode = #{manufacturerCode}
and useOrgSid = #{deptSid}
and isDelete = 0
</select>
<select id="checkForUpdate" resultType="com.yxt.base.biz.base.basemanufacturer.BaseManufacturer">
select *
from base_manufacturer
where manufacturerCode = #{manufacturerCode}
and useOrgSid = #{deptSid}
and isDelete = 0
and sid != #{sid}
</select>
<update id="updateBySidIsDelete">
UPDATE base_manufacturer
SET isDelete=1
@ -25,4 +41,4 @@
#{item}
</foreach>
</update>
</mapper>
</mapper>

6
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerQuery.java

@ -1,6 +1,7 @@
package com.yxt.base.biz.base.basemanufacturer;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -10,4 +11,9 @@ import lombok.Data;
@Data
public class BaseManufacturerQuery implements Query {
private String name;
@ApiModelProperty("使用组织sid")
private String orgPath;
private String userSid;
@ApiModelProperty("菜单url")
private String menuUrl;
}

97
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerService.java

@ -4,12 +4,20 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateTime;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yxt.base.biz.base.basegoodstype.BaseGoodsType;
import com.yxt.base.biz.base.basegoodstype.BaseGoodsTypeVo;
import com.yxt.base.feign.portal.privilege.PrivilegeQuery;
import com.yxt.base.feign.portal.sysorganization.SysOrganizationFeign;
import com.yxt.base.feign.portal.sysorganization.SysOrganizationVo;
import com.yxt.base.feign.portal.sysstafforg.SysStaffOrgFeign;
import com.yxt.base.feign.portal.sysuser.SysUserFeign;
import com.yxt.common.base.service.MybatisBaseService;
import com.yxt.common.base.utils.PagerUtil;
import com.yxt.common.base.utils.StringUtils;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
@ -24,17 +32,59 @@ import java.util.stream.Collectors;
*/
@Service
public class BaseManufacturerService extends MybatisBaseService<BaseManufacturerMapper, BaseManufacturer> {
@Autowired
private SysUserFeign sysUserFeign;
@Autowired
private SysOrganizationFeign sysOrganizationFeign;
@Autowired
private SysStaffOrgFeign sysStaffOrgFeign;
public ResultBean<PagerVo<BaseManufacturerVo>> listPage(PagerQuery<BaseManufacturerQuery> pq) {
ResultBean rb = ResultBean.fireFail();
BaseManufacturerQuery query = pq.getParams();
QueryWrapper<BaseManufacturer> qw = new QueryWrapper<>();
if (StringUtils.isNotBlank(query.getMenuUrl())) {
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(query.getOrgPath());
privilegeQuery.setMenuUrl(query.getMenuUrl());
privilegeQuery.setUserSid(query.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = query.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("u.orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("u.orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("u.orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("u.orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("p.createBySid", query.getUserSid());
} else {
PagerVo<BaseManufacturerVo> p = new PagerVo<>();
return rb.success().setData(p);
}
} else {
PagerVo<BaseManufacturerVo> p = new PagerVo<>();
return rb.success().setData(p);
}
}
if(StringUtils.isNotBlank(query.getName())){
qw.like("manufacturerName",query.getName());
qw.like("p.manufacturerName",query.getName());
}
qw.ne("isDelete","1");
qw.orderByDesc("sortNo");
qw.ne("p.isDelete","1");
qw.orderByAsc("p.sortNo");
IPage<BaseManufacturer> page = PagerUtil.queryToPage(pq);
IPage<BaseManufacturerVo> pagging = baseMapper.listPage(page, qw);
PagerVo<BaseManufacturerVo> p = PagerUtil.pageToVo(pagging, null);
@ -51,11 +101,16 @@ public class BaseManufacturerService extends MybatisBaseService<BaseManufacturer
public ResultBean<String> saveOrUpdate(BaseManufacturerDto dto) {
ResultBean rb = ResultBean.fireFail();
String sid = "";
String orgPath = dto.getOrgPath();
if (StringUtils.isNotBlank(dto.getSid())) {
sid = dto.getSid();
BaseManufacturer wmsManufacturer = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, wmsManufacturer, "id", "sid");
wmsManufacturer.setModifyTime(new Date());
BaseManufacturer m=baseMapper.checkForUpdate(dto.getManufacturerCode(),wmsManufacturer.getUseOrgSid(),sid);
if(null!=m){
return rb.setMsg("厂家编码不能重复");
}
baseMapper.updateById(wmsManufacturer);
} else {
BaseManufacturer wmsManufacturer = new BaseManufacturer();
@ -67,6 +122,37 @@ public class BaseManufacturerService extends MybatisBaseService<BaseManufacturer
// String path = dto.getPicUrl().substring(urlPrefix.length());
// lpkGoods.setPicUrl(path);
// }
wmsManufacturer.setCreateBySid(dto.getUserSid());
String deptName = "";
String deptSid = "";
String createOrgSid = "";
if (StringUtils.isNotBlank(orgPath)) {
List<String> split = Arrays.asList(orgPath.split("/"));
if (split.size() > 1) {
//获取本级sid获取本级部门信息
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(split.size() - 2)).getData();
SysOrganizationVo sysOrganization1 = sysOrganizationFeign.fetchBySid(split.get(split.size() - 1)).getData();
deptName = sysOrganization.getName() + "/" + sysOrganization1.getName();
deptName = sysOrganization1.getName();
deptSid = sysOrganization1.getSid();
} else {
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(0)).getData();
deptName = sysOrganization.getName();
deptName = sysOrganization.getName();
deptSid = sysOrganization.getSid();
}
wmsManufacturer.setUseOrgSid(deptSid);
createOrgSid = sysStaffOrgFeign.getOrgSidByPath(orgPath).getData();
//创建组织使用组织
ResultBean<SysOrganizationVo> organizationResultBean = sysOrganizationFeign.fetchBySid(createOrgSid);
if (organizationResultBean.getData() != null) {
wmsManufacturer.setCreateOrgSid(createOrgSid);
}
}
BaseManufacturer m=baseMapper.checkForInsert(dto.getManufacturerCode(),deptSid);
if(null!=m){
return rb.setMsg("厂家编码不能重复");
}
baseMapper.insert(wmsManufacturer);
}
return rb.success().setMsg("成功");
@ -79,6 +165,7 @@ public class BaseManufacturerService extends MybatisBaseService<BaseManufacturer
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
if (null != wmsManufacturer) {
BeanUtil.copyProperties(wmsManufacturer, vo);
vo.setUserSid(wmsManufacturer.getCreateBySid());
// if (StringUtils.isNotBlank(wmsGoods.getPicUrl())) {
// vo.setPicUrl(fileUploadComponent.getUrlPrefix() + wmsGoods.getPicUrl());
// }

2
yxt-base-biz/src/main/java/com/yxt/base/biz/base/basemanufacturer/BaseManufacturerVo.java

@ -33,4 +33,6 @@ public class BaseManufacturerVo implements Vo {
private String sortNo;//排序
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
private String userSid;
private String orgPath;
}

22
yxt-base-biz/src/main/java/com/yxt/base/feign/portal/privilege/PrivilegeQuery.java

@ -0,0 +1,22 @@
package com.yxt.base.feign.portal.privilege;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @description: 权限角色层级
* @author: dimengzhe
* @date: 2023/5/23
**/
@Data
public class PrivilegeQuery {
@ApiModelProperty("菜单路由")
private String menuUrl;
@ApiModelProperty("组织全路径sid")
private String orgPath;
@ApiModelProperty("菜单sid")
private String menuSid;
@ApiModelProperty("用户sid")
private String userSid;
}

21
yxt-base-biz/src/main/java/com/yxt/base/feign/portal/sysuser/OrgList.java

@ -0,0 +1,21 @@
package com.yxt.base.feign.portal.sysuser;
import com.yxt.common.core.vo.Vo;
import lombok.Data;
/**
* @Author dimengzhe
* @Date 2022/9/21 9:26
* @Description
*/
@Data
public class OrgList implements Vo {
private static final long serialVersionUID = -2867882982421321776L;
private String orgName;
private String orgPath;
private String deptName;
private String deptSid;
}

28
yxt-base-biz/src/main/java/com/yxt/base/feign/portal/sysuser/SysUserFeign.java

@ -0,0 +1,28 @@
package com.yxt.base.feign.portal.sysuser;
import com.yxt.base.feign.portal.privilege.PrivilegeQuery;
import com.yxt.common.core.result.ResultBean;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@Api(tags = "用户表")
@FeignClient(
contextId = "anrui-portal-SysUser",
name = "anrui-portal",
path = "v1/sysuser")
public interface SysUserFeign {
@ApiOperation(value = "查询角色权限的层级获取权限id")
@PostMapping(value = "/selectPrivilegeLevel")
ResultBean<String> selectPrivilegeLevel(@RequestBody PrivilegeQuery query);
@ApiOperation("根据sid获取一条记录")
@GetMapping("/fetchBySid/{sid}")
public ResultBean<SysUserVo> fetchBySid(@PathVariable("sid") String sid);
}

97
yxt-base-biz/src/main/java/com/yxt/base/feign/portal/sysuser/SysUserVo.java

@ -0,0 +1,97 @@
package com.yxt.base.feign.portal.sysuser;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.yxt.common.core.vo.Vo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.ArrayList;
import java.util.List;
/**
* Project: anrui_portal(门户建设) <br/>
* File: SysUserVo.java <br/>
* Class: com.yxt.anrui.portal.api.sysuser.SysUserVo <br/>
* Description: 用户表 视图数据对象. <br/>
* Copyright: Copyright (c) 2011 <br/>
* Company: https://gitee.com/liuzp315 <br/>
* Makedate: 2021-08-03 00:24:30 <br/>
*
* @author liupopo
* @version 1.0
* @since 1.0
*/
@ApiModel(value = "用户表 视图数据对象", description = "用户表 视图数据对象")
@Data
@NoArgsConstructor
public class SysUserVo implements Vo {
private static final long serialVersionUID = 2415131854581950721L;
@ApiModelProperty("部门sid")
private String departmentSid;
@ApiModelProperty("部门名称")
private String departmentName;
@ApiModelProperty("上级部门名称-本级部门名称 岗位名称")
@JsonProperty("pNameAndDepartmentNameAndPostName")
private String pNameAndDepartmentNameAndPostName;
@ApiModelProperty("岗位名称")
private String postName;
@ApiModelProperty("岗位Sid")
private String postSid;
@ApiModelProperty("单位sid")
private String organizationSid;
@ApiModelProperty("单位名称")
private String organizationName;
@ApiModelProperty("用户姓名")
private String name;
@ApiModelProperty("登录名,登录名不能相同")
private String userName;
@ApiModelProperty("id")
private Integer id;
@ApiModelProperty("用户sid")
private String sid;
@ApiModelProperty("是否是管理员:1管理员,2一般用户,0是超级管理员,3尚无单位人员")
private String isAdmin;
@ApiModelProperty("角色名称")
private String roleName;
@ApiModelProperty("关联的人员sid")
private String staffSid;
@ApiModelProperty("手机号")
private String mobile;
@ApiModelProperty(value = "禁用状态")
private String isEnable;
@ApiModelProperty("用户类型:1员工、2客户、3供应商")
private String userType;
@ApiModelProperty("用户类型:1、2、3")
private String userTypeKey;
@ApiModelProperty("用户头像")
private String headImage;
@ApiModelProperty("组织名称")
private String orgNamePath;
@ApiModelProperty("组织sid")
private String orgSidPath;
@ApiModelProperty(value = "token")
private String token;
@ApiModelProperty(value = "角色sids")
private List<String> roleSids = new ArrayList<>();
private List<OrgList> orgList = new ArrayList<>();
@ApiModelProperty("默认的组织机构sid全路径")
private String defaultOrgPath;
@ApiModelProperty("默认的组织机构名称全路径")
private String defaultOrgPathName;
private String defaultDeptName;
private String defaultDeptSid;
@ApiModelProperty("是否需要更换密码")
private Boolean needResetPsd;
@ApiModelProperty("工号")
private String jobNumber;
}

2
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaDto.java

@ -24,5 +24,5 @@ public class WmsWarehouseAreaDto implements Dto {
private String volume;//库位容量
private String unit;//计量单位
private String areaTypeSid;//货区类型
private String userSid; //用户sid
}

4
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaMapper.java

@ -21,4 +21,8 @@ public interface WmsWarehouseAreaMapper extends BaseMapper<WmsWarehouseArea> {
int updateBySidIsDelete(List<String> list);
@Select("select * from wms_warehouse_area where warehouseSid = #{ckSid}")
List<WmsWarehouseAreaAllVo> selectAll(String ckSid);
WmsWarehouseArea checkForInsert(@Param("areaCode")String areaCode, @Param("warehouseSid")String warehouseSid);
WmsWarehouseArea checkForUpdate(@Param("areaCode")String areaCode,@Param("warehouseSid") String warehouseSid, @Param("sid")String sid);
}

13
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaMapper.xml

@ -10,25 +10,32 @@
from wms_warehouse_area a
left join wms_warehouse_info b on b.sid=a.warehouseSid
left join wms_warehouse_area_type c on c.sid =a.areaTypeSid
LEFT JOIN anrui_portal.sys_organization as s ON b.useOrgSid = s.sid
<where>
${ew.sqlSegment}
</where>
</select>
<select id="initialization" resultType="com.yxt.wms.biz.base.wmswarehousearea.WmsWarehouseAreaVo">
select
a.*,b.warehouseName as warehouseName,c.warehouseAreaTypeName as areaTypeName
a.*,a.createBySid as userSid,b.warehouseName as warehouseName,c.warehouseAreaTypeName as areaTypeName
from wms_warehouse_area a
left join wms_warehouse_info b on b.sid=a.warehouseSid
left join wms_warehouse_area_type c on c.sid =a.areaTypeSid
where a.sid =#{sid}
</select>
<select id="checkForInsert" resultType="com.yxt.wms.biz.base.wmswarehousearea.WmsWarehouseArea">
select * from wms_warehouse_area where areaCode =#{areaCode} and warehouseSid =#{warehouseSid} and isDelete=0
</select>
<select id="checkForUpdate" resultType="com.yxt.wms.biz.base.wmswarehousearea.WmsWarehouseArea">
select * from wms_warehouse_area where areaCode =#{areaCode} and warehouseSid =#{warehouseSid} and sid !=#{sid} and isDelete=0
</select>
<update id="updateBySidIsDelete">
UPDATE wms_warehouse_area
UPDATE wms_warehouse_area
SET isDelete=1
where sid in
<foreach collection="list" item="item" index="index" open="(" separator="," close=")">
#{item}
</foreach>
</update>
</mapper>
</mapper>

8
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaQuery.java

@ -1,6 +1,7 @@
package com.yxt.wms.biz.base.wmswarehousearea;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -13,4 +14,11 @@ public class WmsWarehouseAreaQuery implements Query {
private String code;//编码
private String warehouseSid;//仓库
private String areaTypeSid;//库区类型
@ApiModelProperty("菜单路由")
private String menuUrl;
@ApiModelProperty("组织全路径sid")
private String orgPath;
@ApiModelProperty("用户sid")
private String userSid;
}

78
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaService.java

@ -10,6 +10,11 @@ import com.yxt.common.base.utils.StringUtils;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import com.yxt.wms.biz.base.wmswarehouseinfo.WmsWarehouseInfoVo;
import com.yxt.wms.feign.portal.privilege.PrivilegeQuery;
import com.yxt.wms.feign.portal.sysuser.SysUserFeign;
import lombok.experimental.Accessors;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Arrays;
@ -23,35 +28,73 @@ import java.util.stream.Collectors;
*/
@Service
public class WmsWarehouseAreaService extends MybatisBaseService<WmsWarehouseAreaMapper, WmsWarehouseArea> {
@Autowired
private SysUserFeign sysUserFeign;
public ResultBean<PagerVo<WmsWarehouseAreaVo>> listPage(PagerQuery<WmsWarehouseAreaQuery> pq) {
ResultBean rb = ResultBean.fireFail();
WmsWarehouseAreaQuery query = pq.getParams();
QueryWrapper<WmsWarehouseArea> qw = new QueryWrapper<>();
if(StringUtils.isNotBlank(query.getName())){
qw.like("areaName",query.getName());
// PrivilegeQuery privilegeQuery = new PrivilegeQuery();
// privilegeQuery.setOrgPath(query.getOrgPath());
// privilegeQuery.setMenuUrl(query.getMenuUrl());
// privilegeQuery.setUserSid(query.getUserSid());
// ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
// if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
// //数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
// String orgSidPath = query.getOrgPath();
// orgSidPath = orgSidPath + "/";
// int i1 = orgSidPath.indexOf("/");
// int i2 = orgSidPath.indexOf("/", i1 + 1);
// int i3 = orgSidPath.indexOf("/", i2 + 1);
// int i4 = orgSidPath.indexOf("/", i3 + 1);
// String orgLevelKey = defaultIdReltBean.getData();
// if ("1".equals(orgLevelKey)) {
// orgSidPath = orgSidPath.substring(0, i1);
// qw.like("s.orgSidPath", orgSidPath);
// } else if ("2".equals(orgLevelKey)) {
// orgSidPath = orgSidPath.substring(0, i2);
// qw.like("s.orgSidPath", orgSidPath);
// } else if ("3".equals(orgLevelKey)) {
// orgSidPath = orgSidPath.substring(0, i3);
// qw.like("s.orgSidPath", orgSidPath);
// } else if ("4".equals(orgLevelKey)) {
// orgSidPath = orgSidPath.substring(0, i4);
// qw.like("s.orgSidPath", orgSidPath);
// } else if ("5".equals(orgLevelKey)) {
// qw.eq("a.createBySid", query.getUserSid());
// } else {
// PagerVo<WmsWarehouseAreaVo> p = new PagerVo<>();
// return rb.success().setData(p);
// }
// } else {
// PagerVo<WmsWarehouseAreaVo> p = new PagerVo<>();
// return rb.success().setData(p);
// }
if (StringUtils.isNotBlank(query.getName())) {
qw.like("a.areaName", query.getName());
}
if(StringUtils.isNotBlank(query.getCode())){
qw.like("areaCode",query.getCode());
if (StringUtils.isNotBlank(query.getCode())) {
qw.like("a.areaCode", query.getCode());
}
if(StringUtils.isNotBlank(query.getWarehouseSid())){
qw.eq("b.sid",query.getWarehouseSid());
if (StringUtils.isNotBlank(query.getWarehouseSid())) {
qw.eq("b.sid", query.getWarehouseSid());
}
if(StringUtils.isNotBlank(query.getAreaTypeSid())){
qw.eq("c.sid",query.getAreaTypeSid());
if (StringUtils.isNotBlank(query.getAreaTypeSid())) {
qw.eq("c.sid", query.getAreaTypeSid());
}
qw.ne("a.isDelete","1");
qw.ne("a.isDelete", "1");
IPage<WmsWarehouseArea> page = PagerUtil.queryToPage(pq);
IPage<WmsWarehouseAreaVo> pagging = baseMapper.listPage(page, qw);
PagerVo<WmsWarehouseAreaVo> p = PagerUtil.pageToVo(pagging, null);
List<WmsWarehouseAreaVo> records = pagging.getRecords();
return rb.success().setData(p);
}
public ResultBean<WmsWarehouseAreaVo> getAllType() {
ResultBean rb = ResultBean.fireFail();
List<WmsWarehouseArea> pagging = baseMapper.selectList(new QueryWrapper<WmsWarehouseArea>().eq("isEnable",1)
.ne("isDelete","1"));
List<WmsWarehouseArea> pagging = baseMapper.selectList(new QueryWrapper<WmsWarehouseArea>().eq("isEnable", 1)
.ne("isDelete", "1"));
return rb.success().setData(pagging);
}
@ -60,15 +103,24 @@ public class WmsWarehouseAreaService extends MybatisBaseService<WmsWarehouseArea
String sid = "";
if (StringUtils.isNotBlank(dto.getSid())) {
sid = dto.getSid();
WmsWarehouseArea area = baseMapper.checkForUpdate(dto.getAreaCode(),dto.getWarehouseSid(),sid);
if (null != area) {
return rb.setMsg("同一个仓库下的库区编码不能重复。");
}
WmsWarehouseArea wmsWarehouseArea = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, wmsWarehouseArea, "id", "sid");
wmsWarehouseArea.setModifyTime(new Date());
baseMapper.updateById(wmsWarehouseArea);
} else {
WmsWarehouseArea area = baseMapper.checkForInsert(dto.getAreaCode(),dto.getWarehouseSid());
if (null != area) {
return rb.setMsg("同一个仓库下的库区编码不能重复。");
}
WmsWarehouseArea wmsWarehouseArea = new WmsWarehouseArea();
sid = wmsWarehouseArea.getSid();
BeanUtil.copyProperties(dto, wmsWarehouseArea, "id", "sid");
wmsWarehouseArea.setCreateTime(new DateTime());
wmsWarehouseArea.setCreateBySid(dto.getUserSid());
baseMapper.insert(wmsWarehouseArea);
}
return rb.success().setMsg("成功");
@ -94,7 +146,7 @@ public class WmsWarehouseAreaService extends MybatisBaseService<WmsWarehouseArea
int count = baseMapper.updateBySidIsDelete(Arrays.stream(sids).collect(Collectors.toList()));
}
public ResultBean updateIsEnable(String sid,String isEnable) {
public ResultBean updateIsEnable(String sid, String isEnable) {
ResultBean rb = ResultBean.fireFail();
WmsWarehouseArea wmsWarehouseArea = fetchBySid(sid);
if (null != wmsWarehouseArea) {

1
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehousearea/WmsWarehouseAreaVo.java

@ -31,4 +31,5 @@ public class WmsWarehouseAreaVo implements Vo {
private String areaTypeSid;//货区类型
private String warehouseName;//仓库名称
private String areaTypeName;//货区类型名称
private String userSid;
}

3
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeDto.java

@ -21,5 +21,6 @@ public class WmsWarehouseAreaTypeDto implements Dto {
private String warehouseAreaTypeName;//库位类型名称
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
private String orgPath;
private String userSid;
}

5
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeMapper.java

@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.yxt.wms.biz.base.wmswarehouseinfo.WmsWarehouseInfo;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@ -18,4 +19,8 @@ public interface WmsWarehouseAreaTypeMapper extends BaseMapper<WmsWarehouseAreaT
IPage<WmsWarehouseAreaTypeVo> listPage(IPage<WmsWarehouseAreaType> page, @Param(Constants.WRAPPER) QueryWrapper<WmsWarehouseAreaType> qw);
WmsWarehouseAreaTypeVo initialization (@Param("sid") String sid);
int updateBySidIsDelete(List<String> list);
WmsWarehouseAreaType checkCode(@Param("warehouseAreaTypeName")String warehouseAreaTypeName, @Param("deptSid") String deptSid);
WmsWarehouseAreaType checkCodeForUpdate(@Param("warehouseAreaTypeName")String warehouseAreaTypeName, @Param("deptSid")String useOrgSid, @Param("sid")String sid);
}

25
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeMapper.xml

@ -6,17 +6,32 @@
<select id="listPage" resultType="com.yxt.wms.biz.base.wmswarehouseareatype.WmsWarehouseAreaTypeVo">
select
a.*
a.*
from wms_warehouse_area_type a
LEFT JOIN anrui_portal.sys_organization as s ON a.useOrgSid = s.sid
<where>
${ew.sqlSegment}
</where>
</select>
<select id="initialization" resultType="com.yxt.wms.biz.base.wmswarehouseareatype.WmsWarehouseAreaTypeVo">
select
a.*
select a.*,
a.createBySid as userSid
from wms_warehouse_area_type a
where a.sid =#{sid}
where a.sid = #{sid}
</select>
<select id="checkCode" resultType="com.yxt.wms.biz.base.wmswarehouseareatype.WmsWarehouseAreaType">
select *
from wms_warehouse_area_type
where warehouseAreaTypeName = #{warehouseAreaTypeName}
and useOrgSid = #{deptSid} and isDelete=0
</select>
<select id="checkCodeForUpdate"
resultType="com.yxt.wms.biz.base.wmswarehouseareatype.WmsWarehouseAreaType">
select *
from wms_warehouse_area_type
where warehouseAreaTypeName = #{warehouseAreaTypeName}
and useOrgSid = #{deptSid}
and sid != #{sid} and isDelete=0
</select>
<update id="updateBySidIsDelete">
UPDATE wms_warehouse_area_type
@ -26,4 +41,4 @@
#{item}
</foreach>
</update>
</mapper>
</mapper>

8
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeQuery.java

@ -1,6 +1,7 @@
package com.yxt.wms.biz.base.wmswarehouseareatype;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -10,4 +11,11 @@ import lombok.Data;
@Data
public class WmsWarehouseAreaTypeQuery implements Query {
private String name;
@ApiModelProperty("菜单路由")
private String menuUrl;
@ApiModelProperty("组织全路径sid")
private String orgPath;
@ApiModelProperty("用户sid")
private String userSid;
}

92
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeService.java

@ -10,6 +10,14 @@ import com.yxt.common.base.utils.StringUtils;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import com.yxt.wms.biz.base.wmswarehouseinfo.WmsWarehouseInfo;
import com.yxt.wms.biz.base.wmswarehouserack.WmsWarehouseRackVo;
import com.yxt.wms.feign.portal.privilege.PrivilegeQuery;
import com.yxt.wms.feign.portal.sysorganization.SysOrganizationFeign;
import com.yxt.wms.feign.portal.sysorganization.SysOrganizationVo;
import com.yxt.wms.feign.portal.sysstafforg.SysStaffOrgFeign;
import com.yxt.wms.feign.portal.sysuser.SysUserFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Arrays;
@ -23,16 +31,56 @@ import java.util.stream.Collectors;
*/
@Service
public class WmsWarehouseAreaTypeService extends MybatisBaseService<WmsWarehouseAreaTypeMapper, WmsWarehouseAreaType> {
@Autowired
private SysUserFeign sysUserFeign;
@Autowired
private SysOrganizationFeign sysOrganizationFeign;
@Autowired
private SysStaffOrgFeign sysStaffOrgFeign;
public ResultBean<PagerVo<WmsWarehouseAreaTypeVo>> listPage(PagerQuery<WmsWarehouseAreaTypeQuery> pq) {
ResultBean rb = ResultBean.fireFail();
WmsWarehouseAreaTypeQuery query = pq.getParams();
QueryWrapper<WmsWarehouseAreaType> qw = new QueryWrapper<>();
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(query.getOrgPath());
privilegeQuery.setMenuUrl(query.getMenuUrl());
privilegeQuery.setUserSid(query.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = query.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("s.orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("s.orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("s.orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("s.orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("a.createBySid", query.getUserSid());
} else {
PagerVo<WmsWarehouseAreaTypeVo> p = new PagerVo<>();
return rb.success().setData(p);
}
} else {
PagerVo<WmsWarehouseAreaTypeVo> p = new PagerVo<>();
return rb.success().setData(p);
}
if(StringUtils.isNotBlank(query.getName())){
qw.like("warehouseAreaTypeName",query.getName());
qw.like("a.warehouseAreaTypeName",query.getName());
}
qw.ne("isDelete","1");
qw.ne("a.isDelete","1");
IPage<WmsWarehouseAreaType> page = PagerUtil.queryToPage(pq);
IPage<WmsWarehouseAreaTypeVo> pagging = baseMapper.listPage(page, qw);
PagerVo<WmsWarehouseAreaTypeVo> p = PagerUtil.pageToVo(pagging, null);
@ -49,17 +97,53 @@ public class WmsWarehouseAreaTypeService extends MybatisBaseService<WmsWarehouse
public ResultBean<String> saveOrUpdate(WmsWarehouseAreaTypeDto dto) {
ResultBean rb = ResultBean.fireFail();
String sid = "";
String orgPath = dto.getOrgPath();
if (StringUtils.isNotBlank(dto.getSid())) {
sid = dto.getSid();
WmsWarehouseAreaType wmsWarehouseArea = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, wmsWarehouseArea, "id", "sid");
wmsWarehouseArea.setModifyTime(new Date());
WmsWarehouseAreaType areaType = baseMapper.checkCodeForUpdate(dto.getWarehouseAreaTypeName(),wmsWarehouseArea.getUseOrgSid(),sid);
if (areaType != null) {
return rb.setMsg("库区类型名称重复");
}
baseMapper.updateById(wmsWarehouseArea);
} else {
WmsWarehouseAreaType wmsWarehouseArea = new WmsWarehouseAreaType();
sid = wmsWarehouseArea.getSid();
BeanUtil.copyProperties(dto, wmsWarehouseArea, "id", "sid");
wmsWarehouseArea.setCreateTime(new DateTime());
wmsWarehouseArea.setCreateBySid(dto.getUserSid());
String deptName = "";
String deptSid = "";
String createOrgSid = "";
if (StringUtils.isNotBlank(orgPath)) {
List<String> split = Arrays.asList(orgPath.split("/"));
if (split.size() > 1) {
//获取本级sid获取本级部门信息
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(split.size() - 2)).getData();
SysOrganizationVo sysOrganization1 = sysOrganizationFeign.fetchBySid(split.get(split.size() - 1)).getData();
deptName = sysOrganization.getName() + "/" + sysOrganization1.getName();
deptName = sysOrganization1.getName();
deptSid = sysOrganization1.getSid();
} else {
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(0)).getData();
deptName = sysOrganization.getName();
deptName = sysOrganization.getName();
deptSid = sysOrganization.getSid();
}
wmsWarehouseArea.setUseOrgSid(deptSid);
createOrgSid = sysStaffOrgFeign.getOrgSidByPath(orgPath).getData();
//创建组织使用组织
ResultBean<SysOrganizationVo> organizationResultBean = sysOrganizationFeign.fetchBySid(createOrgSid);
if (organizationResultBean.getData() != null) {
wmsWarehouseArea.setCreateOrgSid(createOrgSid);
}
}
WmsWarehouseAreaType areaType = baseMapper.checkCode(dto.getWarehouseAreaTypeName(),deptSid);
if (areaType != null) {
return rb.setMsg("库区类型名称重复");
}
baseMapper.insert(wmsWarehouseArea);
}
return rb.success().setMsg("成功");

2
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseareatype/WmsWarehouseAreaTypeVo.java

@ -26,4 +26,6 @@ public class WmsWarehouseAreaTypeVo implements Vo {
private String warehouseAreaTypeName;//库位类型名称
private String useOrgSid;//使用组织sid
private String createOrgSid;//创建组织sid
private String orgPath;
private String userSid;
}

3
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoDto.java

@ -39,4 +39,7 @@ public class WmsWarehouseInfoDto implements Dto {
private String createOrgSid;//创建组织sid
// private List<WmsWarehouseExtendDto> wmsWarehouseExtendDtos;
private WmsWarehouseExtendDto wmsWarehouseExtendDto;
private String userSid; //登录用户sid
private String orgPath; //组织全路径
}

4
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoMapper.java

@ -23,4 +23,8 @@ public interface WmsWarehouseInfoMapper extends BaseMapper<WmsWarehouseInfo> {
int updateBySidIsDelete(List<String> list);
@Select("select * from wms_warehouse_info")
List<WmsWarehouseAreaAllVo> selectAll();
WmsWarehouseInfo checkCode(@Param("warehouseCode") String warehouseCode, @Param("useOrgSid")String useOrgSid);
WmsWarehouseInfo checkCodeForUpdate(@Param("warehouseCode")String warehouseCode,@Param("useOrgSid") String useOrgSid, @Param("sid")String sid);
}

17
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoMapper.xml

@ -5,12 +5,21 @@
<!-- ${ew.customSqlSegment} -->
<select id="listPage" resultType="com.yxt.wms.biz.base.wmswarehouseinfo.WmsWarehouseInfoVo">
select
*
from wms_warehouse_info
SELECT
w.*
FROM
wms_warehouse_info as w
LEFT JOIN anrui_portal.sys_organization as s ON w.useOrgSid = s.sid
<where>
${ew.sqlSegment}
</where>
ORDER BY w.sortNo ASC
</select>
<select id="checkCode" resultType="com.yxt.wms.biz.base.wmswarehouseinfo.WmsWarehouseInfo">
select * from wms_warehouse_info where warehouseCode =#{warehouseCode} and useOrgSid = #{useOrgSid} and isDelete=0
</select>
<select id="checkCodeForUpdate" resultType="com.yxt.wms.biz.base.wmswarehouseinfo.WmsWarehouseInfo">
select * from wms_warehouse_info where warehouseCode =#{warehouseCode} and useOrgSid = #{useOrgSid} and sid != #{sid} and isDelete=0
</select>
<update id="updateBySidIsDelete">
UPDATE wms_warehouse_info
@ -21,4 +30,4 @@
</foreach>
</update>
</mapper>
</mapper>

7
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoQuery.java

@ -1,6 +1,7 @@
package com.yxt.wms.biz.base.wmswarehouseinfo;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -12,4 +13,10 @@ public class WmsWarehouseInfoQuery implements Query {
private String name;
private String code;
private String address;
@ApiModelProperty("菜单路由")
private String menuUrl;
@ApiModelProperty("组织全路径sid")
private String orgPath;
@ApiModelProperty("用户sid")
private String userSid;
}

115
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouseinfo/WmsWarehouseInfoService.java

@ -14,6 +14,11 @@ import com.yxt.wms.biz.base.wmswarehousearea.WmsWarehouseAreaAllVo;
import com.yxt.wms.biz.base.wmswarehouseextend.WmsWarehouseExtend;
import com.yxt.wms.biz.base.wmswarehouseextend.WmsWarehouseExtendService;
import com.yxt.wms.biz.base.wmswarehouseextend.WmsWarehouseExtendVo;
import com.yxt.wms.feign.portal.privilege.PrivilegeQuery;
import com.yxt.wms.feign.portal.sysorganization.SysOrganizationFeign;
import com.yxt.wms.feign.portal.sysorganization.SysOrganizationVo;
import com.yxt.wms.feign.portal.sysstafforg.SysStaffOrgFeign;
import com.yxt.wms.feign.portal.sysuser.SysUserFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -33,22 +38,62 @@ public class WmsWarehouseInfoService extends MybatisBaseService<WmsWarehouseInfo
@Autowired
WmsWarehouseExtendService wmsWarehouseExtendService;
@Autowired
private SysUserFeign sysUserFeign;
@Autowired
private SysOrganizationFeign sysOrganizationFeign;
@Autowired
private SysStaffOrgFeign sysStaffOrgFeign;
public ResultBean<PagerVo<WmsWarehouseInfoVo>> listPage(PagerQuery<WmsWarehouseInfoQuery> pq) {
ResultBean rb = ResultBean.fireFail();
WmsWarehouseInfoQuery query = pq.getParams();
QueryWrapper<WmsWarehouseInfo> qw = new QueryWrapper<>();
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(query.getOrgPath());
privilegeQuery.setMenuUrl(query.getMenuUrl());
privilegeQuery.setUserSid(query.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = query.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("s.orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("s.orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("s.orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("s.orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("w.createBySid", query.getUserSid());
} else {
PagerVo<WmsWarehouseInfoVo> p = new PagerVo<>();
return rb.success().setData(p);
}
} else {
PagerVo<WmsWarehouseInfoVo> p = new PagerVo<>();
return rb.success().setData(p);
}
if(StringUtils.isNotBlank(query.getName())){
qw.like("warehouseName",query.getName());
qw.like("w.warehouseName",query.getName());
}
if(StringUtils.isNotBlank(query.getCode())){
qw.like("warehouseCode",query.getCode());
qw.like("w.warehouseCode",query.getCode());
}
if(StringUtils.isNotBlank(query.getAddress())){
qw.like("address",query.getAddress());
qw.like("w.address",query.getAddress());
}
qw.ne("isDelete",1);
qw.orderByDesc("sortNo");
qw.ne("w.isDelete",1);
IPage<WmsWarehouseInfo> page = PagerUtil.queryToPage(pq);
IPage<WmsWarehouseInfoVo> pagging = baseMapper.listPage(page, qw);
PagerVo<WmsWarehouseInfoVo> p = PagerUtil.pageToVo(pagging, null);
@ -64,32 +109,68 @@ public class WmsWarehouseInfoService extends MybatisBaseService<WmsWarehouseInfo
public ResultBean<String> saveOrUpdate(WmsWarehouseInfoDto dto) {
ResultBean rb = ResultBean.fireFail();
String sid = "";
String orgPath = dto.getOrgPath();
if (StringUtils.isNotBlank(dto.getSid())) {
sid = dto.getSid();
WmsWarehouseInfo wmsWarehouse = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, wmsWarehouse, "id", "sid");
wmsWarehouse.setModifyTime(new Date());
WmsWarehouseInfo warehouseInfo = baseMapper.checkCodeForUpdate(dto.getWarehouseCode(),wmsWarehouse.getUseOrgSid(),sid);
if (warehouseInfo != null) {
return rb.setMsg("仓库编码重复");
}
baseMapper.updateById(wmsWarehouse);
// for (WmsWarehouseExtendDto wmsWarehouseExtendDto : dto.getWmsWarehouseExtendDtos()) {
// wmsWarehouseExtendDto.setWarehouseSid(wmsWarehouse.getSid());
// }
if(dto.getWmsWarehouseExtendDto()!=null){
dto.getWmsWarehouseExtendDto().setWarehouseSid(wmsWarehouse.getSid());
wmsWarehouseExtendService.saveOrUpdate(dto.getWmsWarehouseExtendDto());
}
// if(dto.getWmsWarehouseExtendDto()!=null){
// dto.getWmsWarehouseExtendDto().setWarehouseSid(wmsWarehouse.getSid());
// wmsWarehouseExtendService.saveOrUpdate(dto.getWmsWarehouseExtendDto());
// }
} else {
WmsWarehouseInfo wmsWarehouse = new WmsWarehouseInfo();
sid = wmsWarehouse.getSid();
BeanUtil.copyProperties(dto, wmsWarehouse, "id", "sid");
wmsWarehouse.setCreateTime(new DateTime());
wmsWarehouse.setCreateBySid(dto.getUserSid());
String deptName = "";
String deptSid = "";
String createOrgSid = "";
if (StringUtils.isNotBlank(orgPath)) {
List<String> split = Arrays.asList(orgPath.split("/"));
if (split.size() > 1) {
//获取本级sid获取本级部门信息
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(split.size() - 2)).getData();
SysOrganizationVo sysOrganization1 = sysOrganizationFeign.fetchBySid(split.get(split.size() - 1)).getData();
deptName = sysOrganization.getName() + "/" + sysOrganization1.getName();
deptName = sysOrganization1.getName();
deptSid = sysOrganization1.getSid();
} else {
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(split.get(0)).getData();
deptName = sysOrganization.getName();
deptName = sysOrganization.getName();
deptSid = sysOrganization.getSid();
}
wmsWarehouse.setUseOrgSid(deptSid);
createOrgSid = sysStaffOrgFeign.getOrgSidByPath(orgPath).getData();
//创建组织使用组织
ResultBean<SysOrganizationVo> organizationResultBean = sysOrganizationFeign.fetchBySid(createOrgSid);
if (organizationResultBean.getData() != null) {
wmsWarehouse.setCreateOrgSid(createOrgSid);
}
}
WmsWarehouseInfo warehouseInfo = baseMapper.checkCode(dto.getWarehouseCode(),deptSid);
if (warehouseInfo != null) {
return rb.setMsg("仓库编码重复");
}
baseMapper.insert(wmsWarehouse);
// for (WmsWarehouseExtendDto wmsWarehouseExtendDto : dto.getWmsWarehouseExtendDtos()) {
// wmsWarehouseExtendDto.setWarehouseSid(wmsWarehouse.getSid());
// }
if(dto.getWmsWarehouseExtendDto()!=null){
dto.getWmsWarehouseExtendDto().setWarehouseSid(wmsWarehouse.getSid());
wmsWarehouseExtendService.saveOrUpdate(dto.getWmsWarehouseExtendDto());
}
// if(dto.getWmsWarehouseExtendDto()!=null){
// dto.getWmsWarehouseExtendDto().setWarehouseSid(wmsWarehouse.getSid());
// wmsWarehouseExtendService.saveOrUpdate(dto.getWmsWarehouseExtendDto());
// }
}
@ -131,7 +212,11 @@ public class WmsWarehouseInfoService extends MybatisBaseService<WmsWarehouseInfo
ResultBean rb = ResultBean.fireFail();
WmsWarehouseInfo wmsWarehouse = fetchBySid(sid);
if (null != wmsWarehouse) {
wmsWarehouse.setIsEnable(Integer.parseInt(isEnable));
if (isEnable.equals("1")) {
wmsWarehouse.setUsageStatus(isEnable);
} else if (isEnable.equals("2")) {
wmsWarehouse.setUsageStatus("0");
}
baseMapper.updateById(wmsWarehouse);
}
return rb.success().setMsg("成功");

1
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackDto.java

@ -22,4 +22,5 @@ public class WmsWarehouseRackDto implements Dto {
private String rackCode;//货架编码
private String warehouseSid;//仓库sid
private String locationSid;//库位sid
private String userSid;
}

4
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackMapper.java

@ -19,4 +19,8 @@ public interface WmsWarehouseRackMapper extends BaseMapper<WmsWarehouseRack> {
IPage<WmsWarehouseRackVo> listPage(IPage<WmsWarehouseRack> page, @Param(Constants.WRAPPER) QueryWrapper<WmsWarehouseRack> qw);
WmsWarehouseRackVo initialization (@Param("sid") String sid);
int updateBySidIsDelete(List<String> list);
WmsWarehouseRack checkForInsert(@Param("rackCode")String rackCode, @Param("locationSid")String locationSid);
WmsWarehouseRack checkForUpdate(@Param("rackCode")String rackCode,@Param("locationSid") String locationSid, @Param("sid")String sid);
}

17
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackMapper.xml

@ -10,18 +10,31 @@
from wms_warehouse_rack a
left join wms_warehouse_area b on b.sid =a.locationSid
left join wms_warehouse_info c on c.sid = a.warehouseSid
LEFT JOIN anrui_portal.sys_organization as s ON c.useOrgSid = s.sid
<where>
${ew.sqlSegment}
</where>
</select>
<select id="initialization" resultType="com.yxt.wms.biz.base.wmswarehouserack.WmsWarehouseRackVo">
select
a.*,b.areaName as locationName ,c.warehouseName as warehouseName
a.*,a.createBySid as userSid,b.areaName as locationName ,c.warehouseName as warehouseName
from wms_warehouse_rack a
left join wms_warehouse_area b on b.sid =a.locationSid
left join wms_warehouse_info c on c.sid = a.warehouseSid
where a.sid =#{sid}
</select>
<select id="checkForInsert" resultType="com.yxt.wms.biz.base.wmswarehouserack.WmsWarehouseRack">
select
*
from wms_warehouse_rack
where rackCode =#{rackCode} and locationSid =#{locationSid} and isDelete=0
</select>
<select id="checkForUpdate" resultType="com.yxt.wms.biz.base.wmswarehouserack.WmsWarehouseRack">
select
*
from wms_warehouse_rack
where rackCode =#{rackCode} and locationSid =#{locationSid} and sid !=#{sid} and isDelete=0
</select>
<update id="updateBySidIsDelete">
UPDATE wms_warehouse_rack
SET isDelete=1
@ -31,4 +44,4 @@
</foreach>
</update>
</mapper>
</mapper>

8
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackQuery.java

@ -1,6 +1,7 @@
package com.yxt.wms.biz.base.wmswarehouserack;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
@ -13,4 +14,11 @@ public class WmsWarehouseRackQuery implements Query {
private String code;//编码
private String warehouseSid;//仓库
private String areaTypeSid;//库区类型
@ApiModelProperty("菜单路由")
private String menuUrl;
@ApiModelProperty("组织全路径sid")
private String orgPath;
@ApiModelProperty("用户sid")
private String userSid;
}

53
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackService.java

@ -10,6 +10,11 @@ import com.yxt.common.base.utils.StringUtils;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import com.yxt.wms.biz.base.wmswarehousearea.WmsWarehouseArea;
import com.yxt.wms.biz.base.wmswarehousearea.WmsWarehouseAreaVo;
import com.yxt.wms.feign.portal.privilege.PrivilegeQuery;
import com.yxt.wms.feign.portal.sysuser.SysUserFeign;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
@ -24,12 +29,49 @@ import java.util.stream.Collectors;
*/
@Service
public class WmsWarehouseRackService extends MybatisBaseService<WmsWarehouseRackMapper, WmsWarehouseRack> {
@Autowired
private SysUserFeign sysUserFeign;
public ResultBean<PagerVo<WmsWarehouseRackVo>> listPage(PagerQuery<WmsWarehouseRackQuery> pq) {
ResultBean rb = ResultBean.fireFail();
WmsWarehouseRackQuery query = pq.getParams();
QueryWrapper<WmsWarehouseRack> qw = new QueryWrapper<>();
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(query.getOrgPath());
privilegeQuery.setMenuUrl(query.getMenuUrl());
privilegeQuery.setUserSid(query.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = query.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("s.orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("s.orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("s.orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("s.orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("a.createBySid", query.getUserSid());
} else {
PagerVo<WmsWarehouseRackVo> p = new PagerVo<>();
return rb.success().setData(p);
}
} else {
PagerVo<WmsWarehouseRackVo> p = new PagerVo<>();
return rb.success().setData(p);
}
if(StringUtils.isNotBlank(query.getName())){
qw.like("rackName",query.getName());
}
@ -61,15 +103,24 @@ public class WmsWarehouseRackService extends MybatisBaseService<WmsWarehouseRack
String sid = "";
if (StringUtils.isNotBlank(dto.getSid())) {
sid = dto.getSid();
WmsWarehouseRack rack = baseMapper.checkForUpdate(dto.getRackCode(),dto.getLocationSid(),sid);
if (null != rack) {
return rb.setMsg("同一个库区下的库位编码不能重复。");
}
WmsWarehouseRack wmsWarehouseRack = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, wmsWarehouseRack, "id", "sid");
wmsWarehouseRack.setModifyTime(new Date());
baseMapper.updateById(wmsWarehouseRack);
} else {
WmsWarehouseRack rack = baseMapper.checkForInsert(dto.getRackCode(),dto.getLocationSid());
if (null != rack) {
return rb.setMsg("同一个库区下的库位编码不能重复。");
}
WmsWarehouseRack wmsWarehouseRack = new WmsWarehouseRack();
sid = wmsWarehouseRack.getSid();
BeanUtil.copyProperties(dto, wmsWarehouseRack, "id", "sid");
wmsWarehouseRack.setCreateTime(new DateTime());
wmsWarehouseRack.setCreateBySid(dto.getUserSid());
baseMapper.insert(wmsWarehouseRack);
}
return rb.success().setMsg("成功");

2
yxt-wms-biz/src/main/java/com/yxt/wms/biz/base/wmswarehouserack/WmsWarehouseRackVo.java

@ -29,5 +29,5 @@ public class WmsWarehouseRackVo implements Vo {
private String locationSid;//库位sid
private String warehouseName;//仓库名称
private String locationName;//库位名称
private String userSid;
}

Loading…
Cancel
Save