|
@@ -3,10 +3,8 @@ package com.ruoyi.warehouseBusiness.service.impl;
|
|
|
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
-import com.ruoyi.basicData.domain.TGoods;
|
|
|
-import com.ruoyi.basicData.mapper.TCorpsMapper;
|
|
|
-import com.ruoyi.basicData.mapper.TGoodsMapper;
|
|
|
-import com.ruoyi.basicData.mapper.TWarehouseMapper;
|
|
|
+import com.ruoyi.basicData.domain.*;
|
|
|
+import com.ruoyi.basicData.mapper.*;
|
|
|
import com.ruoyi.common.core.domain.AjaxResult;
|
|
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
|
|
import com.ruoyi.common.core.domain.model.LoginUser;
|
|
@@ -50,9 +48,15 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
private TCorpsMapper tCorpsMapper;
|
|
|
|
|
|
@Autowired
|
|
|
+ private TFeesMapper tFeesMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
private TWarehouseMapper tWarehouseMapper;
|
|
|
|
|
|
@Autowired
|
|
|
+ private TWarehouseAreaMapper tWarehouseAreaMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
private TEnclosureMapper tEnclosureMapper;
|
|
|
|
|
|
@Autowired
|
|
@@ -80,56 +84,91 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
Map<String, Object> map = new HashMap<>();
|
|
|
// 查询仓库主表数据
|
|
|
TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fId);
|
|
|
+ // 客户表
|
|
|
+ List<TCorps> corpsList = new ArrayList<>();
|
|
|
+ // 用户表
|
|
|
+ List<SysUser> sysUserList = new ArrayList<>();
|
|
|
+ // 仓库表
|
|
|
+ List<TWarehouse> warehouseList = new ArrayList<>();
|
|
|
+ // 商品
|
|
|
+ List<TGoods> goodsList = new ArrayList<>();
|
|
|
+ // 费用
|
|
|
+ List<TFees> feesList = new ArrayList<>();
|
|
|
+ // 库区
|
|
|
+ List<TWarehouseArea> warehouseAreaList = new ArrayList<>();
|
|
|
+
|
|
|
if (!StringUtils.isNull(tWarehousebills)) {
|
|
|
- // 查询货权方 以及 经营单位
|
|
|
- map.put("warehouse", tWarehouseMapper.selectTWarehouseById(tWarehousebills.getfWarehouseid()));
|
|
|
- // 查询联系人
|
|
|
- map.put("sysUser", sysUserMapper.selectUserByUserName(tWarehousebills.getfContacts()));
|
|
|
// 查询货权方
|
|
|
- map.put("fCorps", tCorpsMapper.selectTCorpsById(tWarehousebills.getfCorpid()));
|
|
|
- // 查询 经营单位
|
|
|
- map.put("fSbu", tCorpsMapper.selectTCorpsById(tWarehousebills.getfSbu()));
|
|
|
- // 查询所属部门
|
|
|
- map.put("dept", sysDeptMapper.selectDeptById(tWarehousebills.getfDeptid()));
|
|
|
+ TCorps corps = tCorpsMapper.selectTCorpsById(tWarehousebills.getfCorpid());
|
|
|
+ if (StringUtils.isNotNull(corps)) {
|
|
|
+ corpsList.add(corps);
|
|
|
+ }
|
|
|
+ // 查询联系人
|
|
|
+ SysUser sysUser = sysUserMapper.selectUserByUserName(tWarehousebills.getfContacts());
|
|
|
+ if (StringUtils.isNotNull(sysUser)) {
|
|
|
+ sysUserList.add(sysUser);
|
|
|
+ }
|
|
|
+ // 查询仓库
|
|
|
+ TWarehouse tWarehouse = tWarehouseMapper.selectTWarehouseById(tWarehousebills.getfWarehouseid());
|
|
|
+ if (StringUtils.isNotNull(tWarehouse)) {
|
|
|
+ warehouseList.add(tWarehouse);
|
|
|
+ }
|
|
|
+ // 查询经营单位
|
|
|
+ TCorps corp = tCorpsMapper.selectTCorpsById(tWarehousebills.getfSbu());
|
|
|
+ if (StringUtils.isNotNull(corp)) {
|
|
|
+ corpsList.add(corp);
|
|
|
+ }
|
|
|
map.put("warehousebills", tWarehousebills);
|
|
|
}
|
|
|
// 查询仓库明细从表数据
|
|
|
TWarehousebillsitems tWarehousebillsitems = new TWarehousebillsitems();
|
|
|
tWarehousebillsitems.setfPid(fId);
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
List<TWarehousebillsitems> warehousebillsitems = tWarehousebillsitemsMapper.selectTWarehousebillsitemsList(tWarehousebillsitems);
|
|
|
-// List<TWarehousebillsitems> warehousebillsitems = tWarehousebillsitemsMapper.selectList(new EntityWrapper<TWarehousebillsitems>().eq("f_pid", ));
|
|
|
- if (!StringUtils.isEmpty(warehousebillsitems)) {
|
|
|
- List<TGoods> goodsList = new ArrayList<>();
|
|
|
+ if (StringUtils.isNotEmpty(warehousebillsitems)) {
|
|
|
for (TWarehousebillsitems wb : warehousebillsitems) {
|
|
|
TGoods tGoods = tGoodsMapper.selectTGoodsById(wb.getfGoodsid());
|
|
|
- if (!StringUtils.isNull(tGoods)) {
|
|
|
+ if (StringUtils.isNotNull(tGoods)) {
|
|
|
goodsList.add(tGoods);
|
|
|
}
|
|
|
+ TWarehouseArea warehouseArea = tWarehouseAreaMapper.selectTWarehouseAreaById(wb.getfWarehouselocid());
|
|
|
+ if (StringUtils.isNotNull(warehouseArea)) {
|
|
|
+ warehouseAreaList.add(warehouseArea);
|
|
|
+ }
|
|
|
}
|
|
|
- map.put("goodsList", goodsList);
|
|
|
map.put("warehouseBillsItem", warehousebillsitems);
|
|
|
}
|
|
|
+
|
|
|
// 查询仓库费用明细表数据
|
|
|
TWarehousebillsfees tWarehousebillsfees = new TWarehousebillsfees();
|
|
|
tWarehousebillsfees.setfPid(fId);
|
|
|
List<TWarehousebillsfees> warehousebillsfees = tWarehousebillsfeesMapper.selectTWarehousebillsfeesList(tWarehousebillsfees);
|
|
|
-// List<TWarehousebillsfees> warehousebillsfees = tWarehousebillsfeesMapper.selectList(new EntityWrapper<TWarehousebillsfees>().eq("f_pid", fId));
|
|
|
- if (!StringUtils.isEmpty(warehousebillsfees)) {
|
|
|
+ if (StringUtils.isNotEmpty(warehousebillsfees)) {
|
|
|
+ for (TWarehousebillsfees fees : warehousebillsfees) {
|
|
|
+ TCorps corps = tCorpsMapper.selectTCorpsById(fees.getfCorpid());
|
|
|
+ if (StringUtils.isNotNull(corps)) {
|
|
|
+ corpsList.add(corps);
|
|
|
+ }
|
|
|
+ TFees tFees = tFeesMapper.selectTFeesById(fees.getfFeeid());
|
|
|
+ if (StringUtils.isNotNull(tFees)) {
|
|
|
+ feesList.add(tFees);
|
|
|
+ }
|
|
|
+ }
|
|
|
map.put("warehousebillsfees", warehousebillsfees);
|
|
|
}
|
|
|
// 查询附件表数据
|
|
|
TEnclosure enclosure = new TEnclosure();
|
|
|
enclosure.setfPid(fId);
|
|
|
List<TEnclosure> enclosures = tEnclosureMapper.selectTEnclosureList(enclosure);
|
|
|
-// List<TEnclosure> enclosures = tEnclosureMapper.selectList(new EntityWrapper<TEnclosure>().eq("f_pid", fId));
|
|
|
- if (!StringUtils.isEmpty(enclosures)) {
|
|
|
+ if (StringUtils.isNotEmpty(enclosures)) {
|
|
|
map.put("enclosures", enclosures);
|
|
|
}
|
|
|
+ map.put("corps", corpsList);
|
|
|
+ map.put("goodsList", goodsList);
|
|
|
+ map.put("feesList", feesList);
|
|
|
+ map.put("sysUser", sysUserList);
|
|
|
+ map.put("warehouse", warehouseList);
|
|
|
+ map.put("warehouseAreas", warehouseAreaList);
|
|
|
+ map.put("dept", sysDeptMapper.selectDeptById(tWarehousebills.getfDeptid()));
|
|
|
return map;
|
|
|
}
|
|
|
|
|
@@ -219,7 +258,12 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
|
|
|
@Transactional
|
|
|
public int updateTWhgenlegData(TWarehousebillsitems warehousebillsitems, long whgenlegId, String billtype) {
|
|
|
- return tWhgenlegMapper.updateTWhgenlegData(whgenlegId, billtype, warehousebillsitems);
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ System.out.println(warehousebillsitems.toString());
|
|
|
+ map.put("whgenlegId", whgenlegId);
|
|
|
+ map.put("billType", billtype);
|
|
|
+ map.put("warehousebillsitems", warehousebillsitems);
|
|
|
+ return tWhgenlegMapper.updateTWhgenlegData(map);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -241,23 +285,24 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
Long fPid = null;
|
|
|
TWarehouseBills warehouseBills = JSONArray.parseObject(tWarehouseBills, TWarehouseBills.class);
|
|
|
if (StringUtils.isNull(warehouseBills.getfId())) {
|
|
|
+ // 如果是新数据
|
|
|
warehouseBills.setCreateBy(loginUser.getUser().getUserName());
|
|
|
warehouseBills.setfBilltype(billsType);
|
|
|
warehouseBills.setfBsdeptid(loginUser.getUser().getDeptId());
|
|
|
// 提交时: 生流水号
|
|
|
- if(warehouseBills.getfBillstatus().equals("1")){
|
|
|
+ if (warehouseBills.getfBillstatus().equals("6")) {
|
|
|
// 业务编码
|
|
|
- String billNo= billnoSerialServiceImpl.getBillNo("SJRK",warehouseBills.getfBsdate());
|
|
|
+ String billNo = billnoSerialServiceImpl.getBillNo("SJRK", warehouseBills.getfBsdate());
|
|
|
warehouseBills.setfBillno(billNo);
|
|
|
// 存货编码
|
|
|
Date time = new Date();
|
|
|
- String bscorpno= billnoSerialServiceImpl.getCorpNo(warehouseBills.getfCorpid(),time);
|
|
|
+ String bscorpno = billnoSerialServiceImpl.getCorpNo(warehouseBills.getfCorpid(), time);
|
|
|
warehouseBills.setfBscorpno(bscorpno);
|
|
|
}
|
|
|
tWarehouseBillsMapper.insertTWarehousebills(warehouseBills);
|
|
|
- fPid=warehouseBills.getfId();
|
|
|
+ fPid = warehouseBills.getfId();
|
|
|
} else {
|
|
|
- fPid=warehouseBills.getfId();
|
|
|
+ fPid = warehouseBills.getfId();
|
|
|
warehouseBills.setUpdateBy(loginUser.getUser().getUserName());
|
|
|
warehouseBills.setUpdateTime(new Date());
|
|
|
tWarehouseBillsMapper.updateTWarehousebills(warehouseBills);
|
|
@@ -278,7 +323,7 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
}
|
|
|
}
|
|
|
// 附件添加
|
|
|
- if (tWhgenleg != null) {
|
|
|
+ if (StringUtils.isNotNull(tWhgenleg)) {
|
|
|
JSONArray jsonDrArray = JSONArray.parseArray(tWhgenleg);
|
|
|
List<TEnclosure> tEnclosureList = JSONObject.parseArray(jsonDrArray.toJSONString(), TEnclosure.class);
|
|
|
for (TEnclosure tEnclosure : tEnclosureList) {
|
|
@@ -294,11 +339,11 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
List<TWarehousebillsfees> warehousebillsfeesDrList = JSONObject.parseArray(jsonDrArray.toJSONString(), TWarehousebillsfees.class);
|
|
|
for (TWarehousebillsfees wbDr : warehousebillsfeesDrList) {
|
|
|
// 检验 数量*单价=金额
|
|
|
- if(wbDr.getfQty()!=null && ! wbDr.getfQty().equals("")
|
|
|
- && wbDr.getfUnitprice()!=null && ! wbDr.getfUnitprice().equals("") ){
|
|
|
+ if (wbDr.getfQty() != null && !wbDr.getfQty().equals("")
|
|
|
+ && wbDr.getfUnitprice() != null && !wbDr.getfUnitprice().equals("")) {
|
|
|
BigDecimal fqty = wbDr.getfQty();
|
|
|
BigDecimal funitprice = wbDr.getfUnitprice();
|
|
|
- Long result=check(fqty,funitprice);
|
|
|
+ Long result = check(fqty, funitprice);
|
|
|
wbDr.setfAmount(result);
|
|
|
}
|
|
|
wbDr.setfPid(fPid);
|
|
@@ -314,11 +359,11 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
List<TWarehousebillsfees> warehousebillsfeesCrList = JSONObject.parseArray(jsonCrArray.toJSONString(), TWarehousebillsfees.class);
|
|
|
for (TWarehousebillsfees wbCr : warehousebillsfeesCrList) {
|
|
|
// 检验 数量*单价=金额
|
|
|
- if(wbCr.getfQty()!=null && ! wbCr.getfQty().equals("")
|
|
|
- && wbCr.getfUnitprice()!=null && ! wbCr.getfUnitprice().equals("") ){
|
|
|
+ if (wbCr.getfQty() != null && !wbCr.getfQty().equals("")
|
|
|
+ && wbCr.getfUnitprice() != null && !wbCr.getfUnitprice().equals("")) {
|
|
|
BigDecimal fqty = wbCr.getfQty();
|
|
|
BigDecimal funitprice = wbCr.getfUnitprice();
|
|
|
- Long result=check(fqty,funitprice);
|
|
|
+ Long result = check(fqty, funitprice);
|
|
|
wbCr.setfAmount(result);
|
|
|
}
|
|
|
wbCr.setfPid(fPid);
|
|
@@ -334,16 +379,16 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
JSONArray warehouseJSON = JSONArray.parseArray(tWarehousebillsitems);
|
|
|
List<TWarehousebillsitems> warehousebillsitemsList = JSONObject.parseArray(warehouseJSON.toJSONString(), TWarehousebillsitems.class);
|
|
|
for (TWarehousebillsitems wbItem : warehousebillsitemsList) {
|
|
|
- TWhgenleg tWhgenle=queryTWhgenleg(warehouseBills,wbItem);
|
|
|
- if(StringUtils.isNull(tWhgenle)){ // 为空添加库存总账
|
|
|
- SysUser sysUser=new SysUser();
|
|
|
+ TWhgenleg tWhgenle = queryTWhgenleg(warehouseBills, wbItem);
|
|
|
+ if (StringUtils.isNull(tWhgenle)) { // 为空添加库存总账
|
|
|
+ SysUser sysUser = new SysUser();
|
|
|
sysUser.setUserName(loginUser.getUser().getUserName());
|
|
|
- instalTWhgenleg(warehouseBills,wbItem,sysUser);
|
|
|
- }else { // 非空修改库存总账 fBillstatus : 1 入库提交、 3 撤销入库 ; billtype : SJRK 入库 、SJRKRevoke 撤销入库
|
|
|
- if(warehouseBills.getfBillstatus().equals("1")){
|
|
|
- updateTWhgenlegData(wbItem,tWhgenle.getfId(),"SJRK");
|
|
|
- } else if (warehouseBills.getfBillstatus().equals("3")){
|
|
|
- updateTWhgenlegData(wbItem,tWhgenle.getfId(),"SJRKRevoke");
|
|
|
+ instalTWhgenleg(warehouseBills, wbItem, sysUser);
|
|
|
+ } else { // 非空修改库存总账 fBillstatus : 6 入库提交、 3 撤销入库 ; billtype : SJRK 入库 、SJRKRevoke 撤销入库
|
|
|
+ if (warehouseBills.getfBillstatus().equals("6")) {
|
|
|
+ updateTWhgenlegData(wbItem, tWhgenle.getfId(), "SJRK");
|
|
|
+ } else if (warehouseBills.getfBillstatus().equals("3")) {
|
|
|
+ updateTWhgenlegData(wbItem, tWhgenle.getfId(), "SJRKRevoke");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -363,7 +408,6 @@ public class TWarehouseBillsServiceImpl implements ITWarehouseBillsService {
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
/**
|
|
|
* 修改详情主表
|
|
|
*
|