package com.matrix.system.hive.service.imp;
|
|
import com.matrix.core.constance.MatrixConstance;
|
import com.matrix.core.exception.GlobleException;
|
import com.matrix.core.pojo.PaginationVO;
|
import com.matrix.core.tools.DateUtil;
|
import com.matrix.core.tools.WebUtil;
|
import com.matrix.system.common.bean.SysUsers;
|
import com.matrix.system.constance.Dictionary;
|
import com.matrix.system.hive.bean.SysInstoreDetail;
|
import com.matrix.system.hive.bean.SysInstoreInfo;
|
import com.matrix.system.hive.bean.SysShopInfo;
|
import com.matrix.system.hive.bean.SysStoreInfo;
|
import com.matrix.system.hive.dao.*;
|
import com.matrix.system.hive.plugin.util.CollectionUtils;
|
import com.matrix.system.hive.plugin.util.MoneyUtil;
|
import com.matrix.system.hive.service.SysInstoreInfoService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
|
/**
|
* @date 2016-07-15 13:10
|
*/
|
@Service("sysInstoreInfoService")
|
public class SysInstoreInfoServiceImpl implements SysInstoreInfoService {
|
|
@Autowired
|
private SysInstoreInfoDao sysInstoreInfoDao;
|
@Autowired
|
private SysInstoreDetailDao sysInstoreDetailDao;
|
@Autowired
|
private SysStoreInfoDao sysStoreInfoDao;
|
@Autowired
|
private SysGoodsDao goodsDao;
|
@Autowired
|
private SysShopInfoDao shopInfoDao;
|
@Autowired
|
private SysInstoreDetailDao instoreDetailDao;
|
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int add(SysInstoreInfo sysInstoreInfo) {
|
sysInstoreInfo.setCheckStatus(Dictionary.CHECK_STATUS_DSH);
|
// 设置入库单编号
|
sysInstoreInfo.setInstoreId(DateUtil.getTimeMark());
|
// SysShopInfo info = shopInfoDao.selectByShopName(Dictionary.SHOP_NAME_ZONGDIAN);
|
// // 系统限制入库只能入库到总店,总店不存在则
|
// if (info == null) {
|
// throw new GlobleException("总店仓库不存在,请添加!");
|
// }
|
// 插入
|
int i = sysInstoreInfoDao.insert(sysInstoreInfo);
|
// 设置总金额，并更新
|
sysInstoreInfo.setSumall(savevDetatil(sysInstoreInfo));
|
sysInstoreInfoDao.update(sysInstoreInfo);
|
return i;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int modify(SysInstoreInfo sysInstoreInfo) {
|
Long id = sysInstoreInfo.getId();
|
SysInstoreInfo getInstoreInfo = sysInstoreInfoDao.selectById(id);
|
// 已经审核过的单据不能在修改
|
if (!getInstoreInfo.getCheckStatus().equals(Dictionary.CHECK_STATUS_DSH) && !getInstoreInfo.getCheckStatus().equals(Dictionary.CHECK_STATUS_SHWTG)) {
|
throw new GlobleException("已审核，不能再修改");
|
}
|
sysInstoreInfo.setCheckStatus(Dictionary.CHECK_STATUS_DSH);
|
// 设置总金额
|
sysInstoreInfo.setSumall(savevDetatil(sysInstoreInfo));
|
return sysInstoreInfoDao.update(sysInstoreInfo);
|
}
|
|
/**
|
* 保存入库单明细,返回总价
|
*
|
* @param sysInstoreInfo
|
* @author jiangyouyao
|
*/
|
private double savevDetatil(SysInstoreInfo sysInstoreInfo) {
|
// 1.删除入库单的明细
|
sysInstoreDetailDao.deleteByInstoreId(sysInstoreInfo.getId());
|
// 计算入库总额
|
Double total = 0.0;
|
// 2.添加新的入库明细
|
List<SysInstoreDetail> instoreDetailsFromObj = sysInstoreInfo.getInstoreDetails();
|
List<SysInstoreDetail> addList = new ArrayList<SysInstoreDetail>();
|
if (!instoreDetailsFromObj.isEmpty()) {
|
for (SysInstoreDetail sysInstoreDetail : instoreDetailsFromObj) {
|
if (sysInstoreDetail.getSkuId() != null && (!sysInstoreDetail.getSkuId().equals(""))) {
|
// 计算金额
|
total = MoneyUtil.add(MoneyUtil.mul(Double.parseDouble(sysInstoreDetail.getAmount() + ""),
|
sysInstoreDetail.getPrice()), total);
|
sysInstoreDetail.setInstoreId(sysInstoreInfo.getId());
|
// 设置小计
|
sysInstoreDetail.setPriceTotal(MoneyUtil.mul(Double.parseDouble(sysInstoreDetail.getAmount() + ""),
|
sysInstoreDetail.getPrice()));
|
addList.add(sysInstoreDetail);
|
}
|
}
|
sysInstoreDetailDao.batchInsert(addList);
|
}
|
return total;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int remove(List<Long> list) {
|
for (Long id : list) {
|
// 取出入库单
|
SysInstoreInfo sysInstoreInfo = this.sysInstoreInfoDao.selectById(id);
|
// 验证状态是否为待审核，待审核的才能删除
|
if (!sysInstoreInfo.getCheckStatus().equals(Dictionary.CHECK_STATUS_DSH)) {
|
throw new GlobleException("编号为" + sysInstoreInfo.getInstoreId() + "的入库单已审核，不能被删除");
|
}
|
// 如果存在明细,把明细也删除
|
sysInstoreDetailDao.deleteByInstoreId(sysInstoreInfo.getId());
|
}
|
return sysInstoreInfoDao.deleteByIds(list);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int removeById(Long id) {
|
|
SysInstoreInfo sysInstoreInfo = this.sysInstoreInfoDao.selectById(id);
|
|
// 验证状态是否为待审核，待审核的才能删除
|
if (!sysInstoreInfo.getCheckStatus().equals(Dictionary.CHECK_STATUS_DSH)) {
|
throw new GlobleException("编号为" + sysInstoreInfo.getInstoreId() + "的入库单已审核，不能被删除");
|
}
|
List<SysInstoreDetail> instoreDetails = instoreDetailDao.selectByOrderId(sysInstoreInfo.getId());
|
|
if (CollectionUtils.isNotEmpty(instoreDetails)) {
|
sysInstoreDetailDao.deleteByInstoreId(id);
|
return sysInstoreInfoDao.deleteById(id);
|
} else {
|
return 0;
|
}
|
}
|
|
@Override
|
public List<SysInstoreInfo> findInPage(SysInstoreInfo sysInstoreInfo, PaginationVO pageVo) {
|
|
return sysInstoreInfoDao.selectInPage(sysInstoreInfo, pageVo);
|
|
}
|
|
@Override
|
public List<SysInstoreInfo> findByModel(SysInstoreInfo sysInstoreInfo) {
|
|
return sysInstoreInfoDao.selectByModel(sysInstoreInfo);
|
|
}
|
|
@Override
|
public int findTotal(SysInstoreInfo sysInstoreInfo) {
|
|
return sysInstoreInfoDao.selectTotalRecord(sysInstoreInfo);
|
|
}
|
|
@Override
|
public SysInstoreInfo findById(Long id) {
|
|
return sysInstoreInfoDao.selectById(id);
|
|
}
|
|
/**
|
* 入库单审核
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int check(SysInstoreInfo sysInstoreInfo) {
|
// 验证权限
|
SysUsers user = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY);
|
sysInstoreInfo.setAppmanId(user.getSuId());
|
sysInstoreInfo.setShopId(user.getShopId());
|
sysInstoreInfo.setCompanyId(user.getCompanyId());
|
|
SysInstoreInfo checkInStore = sysInstoreInfoDao.selectById(sysInstoreInfo.getId());
|
// if (!checkInStore.getAppmanId().equals(user.getSuId())) {
|
// throw new GlobleException("无权审核该单据!");
|
// }
|
if (!checkInStore.getCheckStatus().equals(Dictionary.CHECK_STATUS_DSH)) {
|
throw new GlobleException("该单据状态为" + checkInStore.getCheckStatus() + ",不可审核!");
|
}
|
sysInstoreInfo.setStoreId(checkInStore.getStoreId());
|
// 修改入库单状态
|
sysInstoreInfo.setCheckStatus(Dictionary.CHECK_STATUS_SHTG);
|
sysInstoreInfoDao.update(sysInstoreInfo);
|
List<SysInstoreDetail> instoreDetails = instoreDetailDao.selectByOrderId(sysInstoreInfo.getId());
|
|
// 需要插入的库存
|
List<SysStoreInfo> newStore = new ArrayList<>();
|
for (SysInstoreDetail instoreDetail : instoreDetails) {
|
SysStoreInfo sysStoreInfo = new SysStoreInfo();
|
sysStoreInfo.setSkuId(instoreDetail.getSkuId());
|
sysStoreInfo.setGoodsPrice(instoreDetail.getPrice());
|
// 所属仓库id
|
sysStoreInfo.setStoreId(sysInstoreInfo.getStoreId());
|
sysStoreInfo.setStoreTotal(new Double(instoreDetail.getAmount() + ""));
|
// 设置批次号
|
int num = sysStoreInfoDao.countDetail(instoreDetail.getSkuId());
|
String batch=DateUtil.dateToString(new Date(), DateUtil.DATE_FORMAT_NO_SPLITE_DD)+"-"+ num;
|
|
sysStoreInfo.setBatch(batch);
|
sysStoreInfo.setTime(new Date());
|
sysStoreInfo.setShopId(user.getShopId());
|
sysStoreInfo.setCompanyId(user.getCompanyId());
|
newStore.add(sysStoreInfo);
|
|
//更新入库记录批次
|
instoreDetail.setBatch(batch);
|
sysInstoreDetailDao.update(instoreDetail);
|
|
}
|
if (!newStore.isEmpty()) {
|
sysStoreInfoDao.batchInsert(newStore);
|
}
|
return 1;
|
}
|
|
/**
|
* 入库单弃审
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int unCheck(SysInstoreInfo sysInstoreInfo) {
|
// 验证权限
|
SysUsers user = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY);
|
sysInstoreInfo.setAppmanId(user.getSuId());
|
sysInstoreInfo.setShopId(user.getShopId());
|
sysInstoreInfo.setCompanyId(user.getCompanyId());
|
|
SysInstoreInfo checkInStore = sysInstoreInfoDao.selectById(sysInstoreInfo.getId());
|
// if (!checkInStore.getAppmanId().equals(user.getSuId())) {
|
// throw new GlobleException("无权撤销该单据!");
|
// }
|
if (!checkInStore.getCheckStatus().equals(Dictionary.CHECK_STATUS_SHTG)) {
|
throw new GlobleException("该单据状态为" + checkInStore.getCheckStatus() + ",不可审核!");
|
}
|
|
// 修改入库单状态
|
sysInstoreInfo.setCheckStatus(Dictionary.CHECK_STATUS_DSH);
|
if (sysInstoreInfo.getAppRemark() != null) {
|
sysInstoreInfo.setAppRemark(sysInstoreInfo.getAppRemark().replace("[弃审]", "") + "[弃审]");
|
} else {
|
sysInstoreInfo.setAppRemark("[弃审]");
|
}
|
sysInstoreInfo.setStoreId(checkInStore.getStoreId());
|
sysInstoreInfoDao.update(sysInstoreInfo);
|
|
// 遍历入库单明细,将产品写入库存
|
List<SysInstoreDetail> instoreDetails = instoreDetailDao.selectByOrderId(sysInstoreInfo.getId());
|
int i = 0;
|
for (SysInstoreDetail instoreDetail : instoreDetails) {
|
SysStoreInfo sysStoreInfo = new SysStoreInfo();
|
sysStoreInfo.setSkuId(instoreDetail.getSkuId());
|
// 所属仓库id
|
sysStoreInfo.setStoreId(checkInStore.getStoreId());
|
sysStoreInfo.setStoreTotal((double) instoreDetail.getAmount());
|
SysStoreInfo storeInfo = sysStoreInfoDao.getStoreByGoodsId(sysStoreInfo);
|
if (storeInfo.getStoreTotal() - sysStoreInfo.getStoreTotal() < 0) {
|
throw new GlobleException(storeInfo.getGoods().getName() + "库存不足,不能撤销该条记录!");
|
}
|
storeInfo.setStoreTotal(storeInfo.getStoreTotal() - sysStoreInfo.getStoreTotal());
|
i = this.sysStoreInfoDao.update(storeInfo);
|
}
|
return i;
|
}
|
|
@Override
|
public int update(SysInstoreInfo sysInstoreInfo) {
|
return sysInstoreInfoDao.update(sysInstoreInfo);
|
}
|
|
|
}
|
