package com.nanometer.smartlab.service;
|
|
import java.math.BigDecimal;
|
import java.math.BigInteger;
|
import java.util.*;
|
|
import javax.annotation.Resource;
|
|
import com.nanometer.smartlab.dao.OpeApplyDao;
|
import com.nanometer.smartlab.entity.*;
|
import com.nanometer.smartlab.entity.enumtype.ValidFlag;
|
import com.nanometer.smartlab.exception.AlarmCode;
|
import com.nanometer.smartlab.exception.AlarmException;
|
import com.nanometer.smartlab.util.IDUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
import org.apache.log4j.Logger;
|
import org.springframework.dao.DataAccessException;
|
import org.springframework.dao.DataIntegrityViolationException;
|
import org.springframework.dao.DuplicateKeyException;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.nanometer.smartlab.dao.BaseMetaDao;
|
import com.nanometer.smartlab.dao.OpeWarehouseReserveDao;
|
import com.nanometer.smartlab.entity.enumtype.ArrivalStatus;
|
import com.nanometer.smartlab.entity.enumtype.OperateStatus;
|
import com.nanometer.smartlab.entity.enumtype.StoreType;
|
import com.nanometer.smartlab.exception.BusinessException;
|
import com.nanometer.smartlab.exception.ExceptionEnumCode;
|
import com.nanometer.smartlab.util.MessageUtil;
|
|
/**
|
* Created by maweiqing on 17/12/12.
|
*/
|
@Service("opeWarehouseReserveService")
|
public class OpeWarehouseReserveServiceImpl implements OpeWarehouseReserveService {
|
|
private static Logger logger = Logger.getLogger(OpeWarehouseReserveService.class);
|
|
@Resource(name = "opeWarehouseReserveDao")
|
OpeWarehouseReserveDao opeWarehouseReserveDao;
|
|
@Resource
|
private OpeReagentStatusService opeReagentStatusService;
|
|
@Resource
|
private OpeUseFlowService opeUseFlowService;
|
@Resource
|
private OpeWarehouseReserveService opeWarehouseReserveService;
|
|
@Resource(name="baseMetaDao")
|
private BaseMetaDao baseMetaDao;
|
|
@Resource(name="opeApplyDao")
|
private OpeApplyDao opeApplyDao;
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public List<OpeWarehouseReserve> getOpeWarehouseReserveList(String reagentId, String supplierId, Integer first,
|
Integer pageSize) {
|
try {
|
Map<String, Object> params = new HashMap<String, Object>();
|
params.put("reagentId", reagentId);
|
params.put("supplierId", supplierId);
|
params.put("first", first);
|
params.put("pageSize", pageSize);
|
return this.opeWarehouseReserveDao.getOpeWarehouseReserveList(params);
|
} catch (DataAccessException e) {
|
logger.error(e.getMessage(), e);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
|
}
|
}
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public int getOpeWarehouseReserveTotalCount(String reagentId, String supplierId) {
|
try {
|
Map<String, Object> params = new HashMap<String, Object>();
|
params.put("reagentId", reagentId);
|
params.put("supplierId", supplierId);
|
return this.opeWarehouseReserveDao.getOpeWarehouseReserveTotalCount(params);
|
} catch (DataAccessException e) {
|
logger.error(e.getMessage(), e);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
|
}
|
}
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public List<OpeWarehouseReserve> getOpeWarehouseReserveListByName(String reagentId, String supplierId, Integer first,
|
Integer pageSize) {
|
try {
|
Map<String, Object> params = new HashMap<String, Object>();
|
params.put("reagentName", reagentId);
|
params.put("supplierId", supplierId);
|
params.put("first", first);
|
params.put("pageSize", pageSize);
|
return this.opeWarehouseReserveDao.getOpeWarehouseReserveList(params);
|
} catch (DataAccessException e) {
|
logger.error(e.getMessage(), e);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
|
}
|
}
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public int getOpeWarehouseReserveTotalCountByName(String reagentId, String supplierId) {
|
try {
|
Map<String, Object> params = new HashMap<String, Object>();
|
params.put("reagentName", reagentId);
|
params.put("supplierId", supplierId);
|
return this.opeWarehouseReserveDao.getOpeWarehouseReserveTotalCount(params);
|
} catch (DataAccessException e) {
|
logger.error(e.getMessage(), e);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
|
}
|
}
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public OpeWarehouseReserve getOpeWarehouseReserveBy(String reagentId, String articleNumber){
|
OpeWarehouseReserve ope=new OpeWarehouseReserve();
|
ope.setReagentId(reagentId);
|
ope.setArticleNumber(articleNumber);
|
return this.opeWarehouseReserveDao.getOpeWarehouseReserve(ope);
|
}
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public OpeWarehouseReserve getOpeWarehouseReserve(String reagentId, String articleNumber) {
|
try {
|
Map<String, Object> params = new HashMap<String, Object>();
|
params.put("reagentId", reagentId);
|
params.put("articleNumber", articleNumber);
|
List<OpeWarehouseReserve> list = this.opeWarehouseReserveDao.getOpeWarehouseReserveList(params);
|
if (list != null && list.size() > 0) {
|
return list.get(0);
|
}
|
|
return null;
|
} catch (DataAccessException e) {
|
logger.error(e.getMessage(), e);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
|
}
|
}
|
@Transactional(propagation = Propagation.REQUIRED)
|
public OpeWarehouseReserve getOpeWarehouseReserve2(String reagentId, String articleNumber,String warehouseId) {
|
try {
|
Map<String, Object> params = new HashMap<String, Object>();
|
params.put("reagentId", reagentId);
|
params.put("articleNumber", articleNumber);
|
params.put("warehouseId", warehouseId);
|
List<OpeWarehouseReserve> list = this.opeWarehouseReserveDao.getOpeWarehouseReserveList(params);
|
if (list != null && list.size() > 0) {
|
return list.get(0);
|
}
|
|
return null;
|
} catch (DataAccessException e) {
|
logger.error(e.getMessage(), e);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
|
}
|
}
|
@Transactional(propagation = Propagation.REQUIRED)
|
public OpeWarehouseReserve insertOpeWarehouseReserve(OpeWarehouseReserve opeWarehouseReserve) {
|
try {
|
if (opeWarehouseReserve.getId() == null) {
|
opeWarehouseReserve.setId(IDUtils.uuid());
|
}
|
this.opeWarehouseReserveDao.insertOpeWarehouseReserve(opeWarehouseReserve);
|
return opeWarehouseReserve;
|
} catch (DuplicateKeyException ex) {
|
logger.warn(ex.getMessage(), ex);
|
throw new AlarmException(AlarmCode.DATA_DUPLICATE,
|
MessageUtil.getMessage(AlarmCode.DATA_DUPLICATE.getCode()));
|
} catch (DataIntegrityViolationException ex) {
|
logger.warn(ex.getMessage(), ex);
|
throw new AlarmException(AlarmCode.DATA_CONFICT, MessageUtil.getMessage(AlarmCode.DATA_CONFICT.getCode()));
|
} catch (DataAccessException ex) {
|
logger.error(ex.getMessage(), ex);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex);
|
}
|
}
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public boolean updateOpeWarehouseReserve(OpeWarehouseReserve opeWarehouseReserve) {
|
try {
|
int row = this.opeWarehouseReserveDao.updateOpeWarehouseReserve(opeWarehouseReserve);
|
|
return row != 0;
|
} catch (DuplicateKeyException ex) {
|
logger.warn(ex.getMessage(), ex);
|
throw new AlarmException(AlarmCode.DATA_DUPLICATE,
|
MessageUtil.getMessage(AlarmCode.DATA_DUPLICATE.getCode()));
|
} catch (DataIntegrityViolationException ex) {
|
logger.warn(ex.getMessage(), ex);
|
throw new AlarmException(AlarmCode.DATA_CONFICT, MessageUtil.getMessage(AlarmCode.DATA_CONFICT.getCode()));
|
} catch (DataAccessException ex) {
|
logger.error(ex.getMessage(), ex);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex);
|
}
|
}
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public void claimForPerson(List<OpeApplyReserve> selectedListForPerson,String userId,String projectNum){
|
try{
|
for(OpeApplyReserve app:selectedListForPerson){
|
List<String> reagentCodes = app.getReagentCode();
|
if (reagentCodes != null && reagentCodes.size() > 0) {
|
List<OpeReagentStatus> ss=new ArrayList<>();
|
for (String opeReagentStatusId : reagentCodes) {
|
OpeReagentStatus opeReagentStatus = this.opeReagentStatusService.getOpeReagentStatus(opeReagentStatusId);
|
opeReagentStatus.setUserId(userId);
|
opeReagentStatus.setProjectNum(projectNum);
|
//boolean flag = this.opeReagentStatusService.updateReagentStatus(opeReagentStatus);
|
this.opeReagentStatusService.updateReagentStatus(opeReagentStatus);
|
ss.add(opeReagentStatus);
|
}
|
/*HashSet<String> set=new HashSet<>();//存放批号
|
for(int i=0;i<ss.size();i++){
|
set.add(ss.get(i).getArticleNumber());
|
}
|
for(String string: set){
|
int count=0;//相同批号出现的次数
|
String reid="";
|
for(int j=0;j<ss.size();j++){
|
if(string.equals(ss.get(j).getArticleNumber())){
|
count++;
|
reid=ss.get(j).getReagentId();
|
}
|
}
|
OpeWarehouseReserve wa=opeWarehouseReserveService.getOpeWarehouseReserveBy(reid,string);
|
System.out.println("原库存="+wa.getReserve());
|
System.out.println("领用数量="+count);
|
wa.setReserve(wa.getReserve()-count);
|
opeWarehouseReserveDao.updateOpeWarehouseReserve(wa);
|
}*/
|
}
|
//OpeWarehouseReserve wa=opeWarehouseReserveService.getOpeWarehouseReserveBy(app.getReagent().getId(),app.getArticleNumber());
|
OpeApplyReserve re=new OpeApplyReserve();
|
re.setUsed(app.getSelectNum()+app.getUsed());
|
re.setId(app.getId());
|
//System.out.println(wa.getReserve());
|
//wa.setReserve(wa.getReserve()-app.getSelectNum());
|
opeApplyDao.updateOpeApplyUsed(re);//修改已领数量
|
//opeWarehouseReserveDao.updateOpeWarehouseReserve(wa);
|
}
|
|
} catch (DuplicateKeyException ex) {
|
logger.warn(ex.getMessage(), ex);
|
throw new AlarmException(AlarmCode.DATA_DUPLICATE,
|
MessageUtil.getMessage(AlarmCode.DATA_DUPLICATE.getCode()));
|
} catch (DataIntegrityViolationException ex) {
|
logger.warn(ex.getMessage(), ex);
|
throw new AlarmException(AlarmCode.DATA_CONFICT, MessageUtil.getMessage(AlarmCode.DATA_CONFICT.getCode()));
|
} catch (DataAccessException ex) {
|
logger.error(ex.getMessage(), ex);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex);
|
}
|
}
|
|
// 仓库领用
|
@Transactional(propagation = Propagation.REQUIRED)
|
public void claim(List<OpeWarehouseReserve> selectedList, String userId,String projectNum) {
|
try {
|
for (OpeWarehouseReserve opeWarehouseReserve : selectedList) {
|
List<String> reagentCodes = opeWarehouseReserve.getReagentCodes();
|
if (reagentCodes != null && reagentCodes.size() > 0) {
|
for (String opeReagentStatusId : reagentCodes) {
|
OpeReagentStatus opeReagentStatus = this.opeReagentStatusService
|
.getOpeReagentStatus(opeReagentStatusId);
|
opeReagentStatus.setUserId(userId);
|
opeReagentStatus.setProjectNum(projectNum);
|
//boolean flag = this.opeReagentStatusService.updateReagentStatus(opeReagentStatus);
|
this.opeReagentStatusService.updateReagentStatus(opeReagentStatus);
|
//if (flag) {
|
//opeWarehouseReserve.setReserve(opeWarehouseReserve.getReserve() - 1);
|
//opeWarehouseReserve.setSelectNum(0);
|
//}
|
}
|
}
|
opeWarehouseReserve.setReserve(opeWarehouseReserve.getReserve()-opeWarehouseReserve.getSelectNum());
|
opeWarehouseReserveDao.updateOpeWarehouseReserve(opeWarehouseReserve);
|
}
|
} catch (DuplicateKeyException ex) {
|
logger.warn(ex.getMessage(), ex);
|
throw new AlarmException(AlarmCode.DATA_DUPLICATE,
|
MessageUtil.getMessage(AlarmCode.DATA_DUPLICATE.getCode()));
|
} catch (DataIntegrityViolationException ex) {
|
logger.warn(ex.getMessage(), ex);
|
throw new AlarmException(AlarmCode.DATA_CONFICT, MessageUtil.getMessage(AlarmCode.DATA_CONFICT.getCode()));
|
} catch (DataAccessException ex) {
|
logger.error(ex.getMessage(), ex);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR,
|
MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex);
|
}
|
}
|
|
public void reagentDStore2(List<OpeApply> reagentDStoreList, String loginUserId){
|
if (reagentDStoreList == null) {
|
return;
|
}
|
OpeReagentStatus opeReagentStatus = null;
|
BigInteger startReagentCode = null;
|
BigInteger endReagentCode = null;
|
String reagentCode = null;
|
OpeWarehouseReserve opeWarehouseReserve = null;
|
OpeUseFlow opeUseFlow = null;
|
for (OpeApply opeApply : reagentDStoreList) {
|
startReagentCode = new BigInteger(opeApply.getStartReagentCode());
|
endReagentCode = new BigInteger(opeApply.getEndReagentCode());
|
|
// 条形码可能以0开头，所以需要补0
|
int len = opeApply.getStartReagentCode().length() - String.valueOf(startReagentCode).length();
|
/*System.out.println("aaaaaaaaaa="+opeApply.getStartReagentCode());
|
System.out.println("bbbbbbbbbb="+String.valueOf(startReagentCode));
|
if(1==1){
|
return;
|
}*/
|
String temp = "";
|
for (int i = 0; i < len; i++) {
|
temp += "0";
|
}
|
for (BigInteger i = startReagentCode; i.compareTo(endReagentCode) < 1; i = i.add(BigInteger.ONE)) {
|
reagentCode = temp + String.valueOf(i);
|
if (this.opeReagentStatusService.isOpeReagentStatusExist(reagentCode)) {//条码存在
|
//throw new BusinessException(ExceptionEnumCode.REAGENT_CODE_EXIST, "入库试剂：" + opeApply.getReagent().getName() + "的试剂条形码[" + reagentCode + "]已存在。");
|
// 试剂最新状态update
|
opeReagentStatus=this.opeReagentStatusService.getOpeReagentStatusByReagentCode(reagentCode);
|
//opeReagentStatus = new OpeReagentStatus();
|
//opeReagentStatus.setId(id);
|
//opeReagentStatus.setReagentId(opeApply.getReagent().getId());
|
opeReagentStatus.setArticleNumber(opeApply.getArticleNumber());
|
opeReagentStatus.setReagentCode(reagentCode);
|
opeReagentStatus.setStatus(ArrivalStatus.NOREGISTER);
|
opeReagentStatus.setHouseId(opeApply.getHouseId());
|
opeReagentStatus.setContainerId(opeApply.getContainerId());
|
opeReagentStatus.setUserId(loginUserId);
|
//opeReagentStatus.setPlace(opeApply.getPlaceId());
|
//opeReagentStatus.setRemainder(opeApply.getReagent().getMainMetering()!=null?(new BigDecimal(opeApply.getReagent().getMainMetering())):new BigDecimal(0));
|
//opeReagentStatus.setStoreType(StoreType.DIRECTSTORE);
|
this.opeReagentStatusService.updateReagentStatus2(opeReagentStatus);
|
|
// 试剂使用情况领用insert
|
/*OpeUseFlow ouf=new OpeUseFlow();
|
ouf.setReagentCode(opeReagentStatus.getReagentCode());
|
ouf.setStatus(opeReagentStatus.getStatus());
|
ouf.setHouseId(opeReagentStatus.getHouseId());
|
ouf.setContainerId(opeReagentStatus.getContainerId());
|
ouf.setUserId(opeReagentStatus.getUserId());
|
ouf.setPlace(opeReagentStatus.getPlace());
|
ouf.setRemainder(opeApply.getReagent().getMainMetering()!=null?(new BigDecimal(opeApply.getReagent().getMainMetering())):new BigDecimal(0));
|
ouf.setStoreType(StoreType.DIRECTSTORE);
|
|
Map<String, String> metaMap2 = new HashMap<>();
|
metaMap2.put("groupId", "operate_status");
|
metaMap2.put("metaKey", String.valueOf(OperateStatus.WAREHOUSEOUT.getKey()));
|
List<BaseMeta> baseMetaList2 = baseMetaDao.getBaseMetaList(metaMap2);
|
ouf.setOperateState(baseMetaList2.get(0).getId());
|
this.opeUseFlowService.insertOpeUseFlow(ouf);*/
|
}else{//条码不存在
|
// 试剂最新状态insert
|
opeReagentStatus = new OpeReagentStatus();
|
opeReagentStatus.setReagentId(opeApply.getReagent().getId());
|
opeReagentStatus.setArticleNumber(opeApply.getArticleNumber());
|
opeReagentStatus.setReagentCode(reagentCode);
|
opeReagentStatus.setStatus(ArrivalStatus.NOREGISTER);
|
opeReagentStatus.setHouseId(opeApply.getHouseId());
|
opeReagentStatus.setContainerId(opeApply.getContainerId());
|
opeReagentStatus.setUserId(loginUserId);
|
//opeReagentStatus.setPlace(opeApply.getPlaceId());
|
//opeReagentStatus.setRemainder(opeApply.getReagent().getMainMetering()!=null?(new BigDecimal(opeApply.getReagent().getMainMetering())):new BigDecimal(0));
|
opeReagentStatus.setStoreType(StoreType.DIRECTSTORE);
|
this.opeReagentStatusService.insertOpeReagentStatus(opeReagentStatus);
|
|
// 试剂使用情况入库insert
|
opeUseFlow = new OpeUseFlow();
|
opeUseFlow.setReagentCode(opeReagentStatus.getReagentCode());
|
opeUseFlow.setStatus(opeReagentStatus.getStatus());
|
opeUseFlow.setHouseId(opeReagentStatus.getHouseId());
|
opeUseFlow.setContainerId(opeReagentStatus.getContainerId());
|
opeUseFlow.setUserId(opeReagentStatus.getUserId());
|
opeUseFlow.setPlace(opeReagentStatus.getPlace());
|
opeUseFlow.setRemainder(opeApply.getReagent().getMainMetering()!=null?opeApply.getReagent().getMainMetering():new BigDecimal(0));
|
opeUseFlow.setStoreType(StoreType.DIRECTSTORE);
|
|
Map<String, String> metaMap = new HashMap<>();
|
metaMap.put("groupId", "operate_status");
|
metaMap.put("metaKey", String.valueOf(OperateStatus.WAREHOUSEIN.getKey()));
|
List<BaseMeta> baseMetaList = baseMetaDao.getBaseMetaList(metaMap);
|
opeUseFlow.setOperateState(baseMetaList.get(0).getId());
|
this.opeUseFlowService.insertOpeUseFlow(opeUseFlow);
|
// 试剂使用情况领用insert
|
OpeUseFlow ouf=new OpeUseFlow();
|
ouf.setReagentCode(opeReagentStatus.getReagentCode());
|
ouf.setStatus(opeReagentStatus.getStatus());
|
ouf.setHouseId(opeReagentStatus.getHouseId());
|
ouf.setContainerId(opeReagentStatus.getContainerId());
|
ouf.setUserId(opeReagentStatus.getUserId());
|
ouf.setPlace(opeReagentStatus.getPlace());
|
ouf.setRemainder(opeApply.getReagent().getMainMetering()!=null?opeApply.getReagent().getMainMetering():new BigDecimal(0));
|
ouf.setStoreType(StoreType.DIRECTSTORE);
|
|
Map<String, String> metaMap2 = new HashMap<>();
|
metaMap2.put("groupId", "operate_status");
|
metaMap2.put("metaKey", String.valueOf(OperateStatus.WAREHOUSEOUT.getKey()));
|
List<BaseMeta> baseMetaList2 = baseMetaDao.getBaseMetaList(metaMap2);
|
ouf.setOperateState(baseMetaList2.get(0).getId());
|
this.opeUseFlowService.insertOpeUseFlow(ouf);
|
}
|
}
|
|
}
|
}
|
|
@Override
|
public List<OpeWarehouseReserve> selectByReId(String id) {
|
return this.opeWarehouseReserveDao.selectByReId(id);
|
}
|
|
@Override
|
public void updateByReId(String newReId, String oldReId) {
|
Map<String, Object> params=new HashMap();
|
params.put("newReId",newReId);
|
params.put("oldReId",oldReId);
|
this.opeWarehouseReserveDao.updateByReId(params);
|
}
|
|
@Override
|
@Transactional
|
public void insertOpeWarehouseReserve2(OpeApplyReserve opeApplyReserve, OpeOrder oo) {
|
|
OpeWarehouseReserve ope = new OpeWarehouseReserve();
|
//库存为到货数量
|
ope.setReserve(opeApplyReserve.getArrivalNum());
|
//仓库
|
ope.setWarehouseId(opeApplyReserve.getHouseId());
|
//试剂
|
ope.setReagentId(opeApplyReserve.getReagent().getId());
|
//订单编号
|
ope.setOrderCode(oo.getOrderCode());
|
// 申购编号
|
ope.setApplyCode(opeApplyReserve.getApplyCode());
|
//批号
|
ope.setArticleNumber(opeApplyReserve.getArticleNumber());
|
ope.setId(IDUtils.uuid());
|
opeWarehouseReserveDao.insertOpeWarehouseReserve2(ope);
|
|
}
|
|
@Transactional(propagation = Propagation.REQUIRED)
|
public void reagentDStore(List<OpeApply> reagentDStoreList, String loginUserId) {
|
|
if (reagentDStoreList == null) {
|
return;
|
}
|
|
OpeReagentStatus opeReagentStatus = null;
|
BigInteger startReagentCode = null;
|
BigInteger endReagentCode = null;
|
String reagentCode = null;
|
OpeWarehouseReserve opeWarehouseReserve = null;
|
OpeUseFlow opeUseFlow = null;
|
for (OpeApply opeApply : reagentDStoreList) {
|
//不输入条形码
|
if(opeApply.getStartReagentCode()==null ||
|
opeApply.getStartReagentCode().equals("") ||
|
opeApply.getEndReagentCode()==null ||
|
opeApply.getEndReagentCode().equals("")){
|
}else{//输入条形码
|
|
startReagentCode = new BigInteger(opeApply.getStartReagentCode());
|
endReagentCode = new BigInteger(opeApply.getEndReagentCode());
|
|
// 条形码可能以0开头，所以需要补0
|
int len = opeApply.getStartReagentCode().length() - String.valueOf(startReagentCode).length();
|
String temp = "";
|
for (int i = 0; i < len; i++) {
|
temp += "0";
|
}
|
|
for (BigInteger i = startReagentCode; i.compareTo(endReagentCode) < 1; i = i.add(BigInteger.ONE)) {
|
reagentCode = temp + String.valueOf(i);
|
if (this.opeReagentStatusService.isOpeReagentStatusExist(reagentCode)) {
|
throw new BusinessException(ExceptionEnumCode.REAGENT_CODE_EXIST, "入库试剂：" + opeApply.getReagent().getName() + "的试剂条形码[" + reagentCode + "]已存在。");
|
}
|
|
// 试剂最新状态insert
|
opeReagentStatus = new OpeReagentStatus();
|
opeReagentStatus.setReagentId(opeApply.getReagent().getId());
|
opeReagentStatus.setArticleNumber(opeApply.getArticleNumber());
|
opeReagentStatus.setReagentCode(reagentCode);
|
opeReagentStatus.setStatus(ArrivalStatus.WAREHOUSE);
|
opeReagentStatus.setHouseId(opeApply.getHouseId());
|
opeReagentStatus.setContainerId(opeApply.getContainerId());
|
opeReagentStatus.setUserId(loginUserId);
|
opeReagentStatus.setPlace(opeApply.getPlaceId());
|
opeReagentStatus.setRemainder(opeApply.getReagent().getMainMetering()!=null?(opeApply.getReagent().getMainMetering()):new BigDecimal(0));
|
opeReagentStatus.setStoreType(StoreType.DIRECTSTORE);
|
this.opeReagentStatusService.insertOpeReagentStatus(opeReagentStatus);
|
|
// 试剂使用情况insert
|
opeUseFlow = new OpeUseFlow();
|
opeUseFlow.setReagentCode(opeReagentStatus.getReagentCode());
|
opeUseFlow.setStatus(opeReagentStatus.getStatus());
|
opeUseFlow.setHouseId(opeReagentStatus.getHouseId());
|
opeUseFlow.setContainerId(opeReagentStatus.getContainerId());
|
opeUseFlow.setUserId(opeReagentStatus.getUserId());
|
opeUseFlow.setPlace(opeReagentStatus.getPlace());
|
opeUseFlow.setRemainder(opeApply.getReagent().getMainMetering()!=null?(opeApply.getReagent().getMainMetering()):new BigDecimal(0));
|
opeUseFlow.setStoreType(StoreType.DIRECTSTORE);
|
|
Map<String, String> metaMap = new HashMap<>();
|
metaMap.put("groupId", "operate_status");
|
metaMap.put("metaKey", String.valueOf(OperateStatus.WAREHOUSEIN.getKey()));
|
List<BaseMeta> baseMetaList = baseMetaDao.getBaseMetaList(metaMap);
|
opeUseFlow.setOperateState(baseMetaList.get(0).getId());
|
|
|
this.opeUseFlowService.insertOpeUseFlow(opeUseFlow);
|
}
|
}
|
|
|
// 仓库库存update
|
opeWarehouseReserve = this.opeWarehouseReserveService.getOpeWarehouseReserve2(opeApply.getReagent().getId(), opeApply.getArticleNumber(),opeApply.getHouseId());
|
if (opeWarehouseReserve == null) {
|
opeWarehouseReserve = new OpeWarehouseReserve();
|
opeWarehouseReserve.setReagentId(opeApply.getReagent().getId());
|
opeWarehouseReserve.setArticleNumber(opeApply.getArticleNumber());
|
opeWarehouseReserve.setReserve(0);
|
opeWarehouseReserve.setWarehouseId(opeApply.getHouseId());
|
}
|
opeWarehouseReserve.setReserve(opeWarehouseReserve.getReserve() + opeApply.getArrivalNum());
|
if (StringUtils.isBlank(opeWarehouseReserve.getId())) {
|
this.opeWarehouseReserveService.insertOpeWarehouseReserve(opeWarehouseReserve);
|
} else {
|
this.opeWarehouseReserveService.updateOpeWarehouseReserve(opeWarehouseReserve);
|
}
|
}
|
}
|
|
}
|
