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.LogUtil;
|
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.SysOutStore;
|
import com.matrix.system.hive.bean.SysOutStoreItem;
|
import com.matrix.system.hive.bean.SysShopInfo;
|
import com.matrix.system.hive.bean.SysStoreInfo;
|
import com.matrix.system.hive.dao.SysOutStoreDao;
|
import com.matrix.system.hive.dao.SysOutStoreItemDao;
|
import com.matrix.system.hive.dao.SysStoreInfoDao;
|
import com.matrix.system.hive.service.CodeService;
|
import com.matrix.system.hive.service.SysOutStoreService;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Random;
|
|
/**
|
* @date 2016-07-25 12:43
|
*/
|
@Service("sysOutStoreService")
|
public class SysOutStoreServiceImpl implements SysOutStoreService {
|
|
@Autowired
|
private SysOutStoreDao sysOutStoreDao;
|
@Autowired
|
private SysOutStoreItemDao sysOutStoreItemDao;
|
@Autowired
|
private SysStoreInfoDao storeInfoDao;
|
@Autowired
|
private CodeService codeService;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int add(SysOutStore sysOutStore) {
|
SysUsers sysUsers = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
sysOutStore.setStaffId(sysUsers.getSuId());
|
sysOutStore.setOutStoreNo(codeService.getOutStoreCode());
|
sysOutStore.setShopId(sysUsers.getShopId());
|
sysOutStore.setCompanyId(sysUsers.getCompanyId());
|
List<SysOutStoreItem> items = sysOutStore.getOutStoreItems();
|
|
|
int i = sysOutStoreDao.insert(sysOutStore);
|
//添加新的明细
|
for (SysOutStoreItem item : items) {
|
if (item.getSkuId() != null) {
|
item.setOutStoreId(sysOutStore.getId());
|
|
SysStoreInfo storeInfo = storeInfoDao.selectById(item.getStoreId());
|
if (storeInfo.getStoreTotal() < item.getAmount()) {
|
throw new GlobleException("存在产品消耗量大于库存量");
|
}
|
storeInfo.setStoreTotal(storeInfo.getStoreTotal() - item.getAmount());
|
sysOutStoreItemDao.insert(item);
|
storeInfoDao.update(storeInfo);
|
}
|
}
|
return i;
|
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int modify(SysOutStore sysOutStore) {
|
|
List<SysOutStoreItem> items = sysOutStore.getOutStoreItems();
|
List<SysOutStoreItem> delItems = sysOutStoreDao.selectById(sysOutStore.getId()).getOutStoreItems();
|
List<Long> ids = new ArrayList<>();
|
//批量删除原有的明细，把id放到一个集合中，在数据库中使用批量删除
|
for (SysOutStoreItem delObj : delItems) {
|
ids.add(delObj.getId());
|
sysOutStoreItemDao.deleteByIds(ids);
|
}
|
//添加新的明细
|
for (SysOutStoreItem item : items) {
|
if (item.getSkuId() != null) {
|
item.setOutStoreId(sysOutStore.getId());
|
sysOutStoreItemDao.insert(item);
|
}
|
}
|
|
return sysOutStoreDao.update(sysOutStore);
|
|
}
|
|
@Override
|
public int remove(List<Long> list) {
|
|
return sysOutStoreDao.deleteByIds(list);
|
|
}
|
|
@Override
|
public int removeById(Long id) {
|
|
return sysOutStoreDao.deleteById(id);
|
|
}
|
|
@Override
|
public List<SysOutStore> findInPage(SysOutStore sysOutStore, PaginationVO pageVo) {
|
|
return sysOutStoreDao.selectInPage(sysOutStore, pageVo);
|
|
}
|
|
@Override
|
public List<SysOutStore> findByModel(SysOutStore sysOutStore) {
|
|
return sysOutStoreDao.selectByModel(sysOutStore);
|
|
}
|
|
@Override
|
public int findTotal(SysOutStore sysOutStore) {
|
|
return sysOutStoreDao.selectTotalRecord(sysOutStore);
|
|
}
|
|
@Override
|
public SysOutStore findById(Long id) {
|
SysOutStore sysOutStore = sysOutStoreDao.selectById(id);
|
List<SysOutStoreItem> list = sysOutStoreItemDao.selectByOrderId(id);
|
sysOutStore.setOutStoreItems(list);
|
return sysOutStore;
|
|
}
|
|
@Override
|
public int checkInfo(SysOutStore sysOutStore) {
|
SysOutStore queryStore = sysOutStoreDao.selectById(sysOutStore.getId());
|
List<SysOutStoreItem> list = queryStore.getOutStoreItems();
|
int flag = 0;
|
for (SysOutStoreItem item : list) {
|
SysStoreInfo storeInfo = null;// storeInfoDao.selectStoInfo(item.getSkuId(), queryStore.getShopId());
|
if (storeInfo != null) {
|
Double total = storeInfo.getStoreTotal() - (item.getAmount() / storeInfo.getGoods().getVolume());
|
if (total >= 0) {
|
flag++;
|
// 计算剩余瓶数
|
storeInfo.setStoreTotal(total);
|
storeInfoDao.update(storeInfo);
|
} else {
|
throw new GlobleException("配料失败：【" + storeInfo.getGoods().getName() + "库存不足】");
|
}
|
} else {
|
throw new GlobleException(
|
"配料失败：【" + item.getGoods().getName() + "本店不存在】");
|
}
|
}
|
queryStore.setCheckStatus(Dictionary.OUT_STORE_ALREADY_CHECK);
|
sysOutStoreDao.update(queryStore);
|
return flag;
|
}
|
|
|
}
|
