414 lines
18 KiB
Java
414 lines
18 KiB
Java
package com.jsh.erp.service.serialNumber;
|
||
|
||
import com.alibaba.fastjson.JSONObject;
|
||
import com.jsh.erp.constants.BusinessConstants;
|
||
import com.jsh.erp.constants.ExceptionConstants;
|
||
import com.jsh.erp.datasource.entities.*;
|
||
import com.jsh.erp.datasource.mappers.*;
|
||
import com.jsh.erp.exception.BusinessRunTimeException;
|
||
import com.jsh.erp.service.depotItem.DepotItemService;
|
||
import com.jsh.erp.service.log.LogService;
|
||
import com.jsh.erp.service.material.MaterialService;
|
||
import com.jsh.erp.service.user.UserService;
|
||
import com.jsh.erp.utils.StringUtil;
|
||
import org.slf4j.Logger;
|
||
import org.slf4j.LoggerFactory;
|
||
import org.springframework.stereotype.Service;
|
||
import org.springframework.transaction.annotation.Transactional;
|
||
import org.springframework.web.context.request.RequestContextHolder;
|
||
import org.springframework.web.context.request.ServletRequestAttributes;
|
||
|
||
import javax.annotation.Resource;
|
||
import javax.servlet.http.HttpServletRequest;
|
||
import java.util.ArrayList;
|
||
import java.util.Date;
|
||
import java.util.List;
|
||
|
||
/**
|
||
* Description
|
||
*
|
||
* @Author: cjl
|
||
* @Date: 2019/1/21 16:33
|
||
*/
|
||
@Service
|
||
public class SerialNumberService {
|
||
private Logger logger = LoggerFactory.getLogger(MaterialService.class);
|
||
|
||
@Resource
|
||
private SerialNumberMapper serialNumberMapper;
|
||
@Resource
|
||
private SerialNumberMapperEx serialNumberMapperEx;
|
||
@Resource
|
||
private MaterialMapperEx materialMapperEx;
|
||
@Resource
|
||
private MaterialMapper materialMapper;
|
||
@Resource
|
||
private UserService userService;
|
||
@Resource
|
||
private LogService logService;
|
||
|
||
|
||
public SerialNumber getSerialNumber(long id) {
|
||
return serialNumberMapper.selectByPrimaryKey(id);
|
||
}
|
||
|
||
public List<SerialNumber> getSerialNumber() {
|
||
SerialNumberExample example = new SerialNumberExample();
|
||
return serialNumberMapper.selectByExample(example);
|
||
}
|
||
|
||
public List<SerialNumberEx> select(String serialNumber, String materialName, Integer offset, Integer rows) {
|
||
return serialNumberMapperEx.selectByConditionSerialNumber(serialNumber, materialName,offset, rows);
|
||
|
||
}
|
||
|
||
public Long countSerialNumber(String serialNumber,String materialName) {
|
||
return serialNumberMapperEx.countSerialNumber(serialNumber, materialName);
|
||
}
|
||
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public int insertSerialNumber(String beanJson, HttpServletRequest request) {
|
||
SerialNumber serialNumber = JSONObject.parseObject(beanJson, SerialNumber.class);
|
||
logService.insertLog(BusinessConstants.LOG_INTERFACE_NAME_SERIAL_NUMBER, BusinessConstants.LOG_OPERATION_TYPE_ADD, request);
|
||
return serialNumberMapper.insertSelective(serialNumber);
|
||
}
|
||
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public int updateSerialNumber(String beanJson, Long id) {
|
||
SerialNumber serialNumber = JSONObject.parseObject(beanJson, SerialNumber.class);
|
||
serialNumber.setId(id);
|
||
int res = serialNumberMapper.updateByPrimaryKeySelective(serialNumber);
|
||
return res;
|
||
}
|
||
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public int deleteSerialNumber(Long id) {
|
||
return serialNumberMapper.deleteByPrimaryKey(id);
|
||
}
|
||
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public int batchDeleteSerialNumber(String ids) {
|
||
List<Long> idList = StringUtil.strToLongList(ids);
|
||
SerialNumberExample example = new SerialNumberExample();
|
||
example.createCriteria().andIdIn(idList);
|
||
return serialNumberMapper.deleteByExample(example);
|
||
}
|
||
|
||
public int checkIsNameExist(Long id, String serialNumber) {
|
||
SerialNumberExample example = new SerialNumberExample();
|
||
example.createCriteria().andIdNotEqualTo(id).andSerialNumberEqualTo(serialNumber).andDeleteFlagNotEqualTo(BusinessConstants.DELETE_FLAG_DELETED);
|
||
List<SerialNumber> list = serialNumberMapper.selectByExample(example);
|
||
return list.size();
|
||
}
|
||
|
||
|
||
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public int batchSetEnable(Boolean enabled, String materialIDs) {
|
||
List<Long> ids = StringUtil.strToLongList(materialIDs);
|
||
SerialNumber serialNumber = new SerialNumber();
|
||
SerialNumberExample example = new SerialNumberExample();
|
||
example.createCriteria().andIdIn(ids);
|
||
return serialNumberMapper.updateByExampleSelective(serialNumber, example);
|
||
}
|
||
|
||
|
||
public List<SerialNumberEx> findById(Long id){
|
||
return serialNumberMapperEx.findById(id);
|
||
}
|
||
|
||
|
||
|
||
|
||
public void checkIsExist(Long id, String materialName, String serialNumber) {
|
||
/**
|
||
* 商品名称不为空时，检查商品名称是否存在
|
||
* */
|
||
if(StringUtil.isNotEmpty(materialName)){
|
||
List<Material> mlist = materialMapperEx.findByMaterialName(materialName);
|
||
if(mlist==null||mlist.size()<1){
|
||
//商品名称不存在
|
||
throw new BusinessRunTimeException(ExceptionConstants.MATERIAL_NOT_EXISTS_CODE,
|
||
ExceptionConstants.MATERIAL_NOT_EXISTS_MSG);
|
||
}else if(mlist.size()>1){
|
||
//商品信息不唯一
|
||
throw new BusinessRunTimeException(ExceptionConstants.MATERIAL_NOT_ONLY_CODE,
|
||
ExceptionConstants.MATERIAL_NOT_ONLY_MSG);
|
||
|
||
}
|
||
}
|
||
/***
|
||
* 判断序列号是否已存在
|
||
* */
|
||
List <SerialNumberEx> list = serialNumberMapperEx.findBySerialNumber(serialNumber);
|
||
if(list!=null&&list.size()>0){
|
||
if(list.size()>1){
|
||
//存在多个同名序列号
|
||
throw new BusinessRunTimeException(ExceptionConstants.SERIAL_NUMBERE_ALREADY_EXISTS_CODE,
|
||
ExceptionConstants.SERIAL_NUMBERE_ALREADY_EXISTS_MSG);
|
||
}else{
|
||
//存在一个序列号
|
||
if(id==null){
|
||
//新增，存在要添加的序列号
|
||
throw new BusinessRunTimeException(ExceptionConstants.SERIAL_NUMBERE_ALREADY_EXISTS_CODE,
|
||
ExceptionConstants.SERIAL_NUMBERE_ALREADY_EXISTS_MSG);
|
||
}
|
||
if(id.equals(list.get(0).getId())){
|
||
//修改的是同一条数据
|
||
}else{
|
||
//存在一条不同的序列号信息
|
||
throw new BusinessRunTimeException(ExceptionConstants.SERIAL_NUMBERE_ALREADY_EXISTS_CODE,
|
||
ExceptionConstants.SERIAL_NUMBERE_ALREADY_EXISTS_MSG);
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 新增序列号信息
|
||
* */
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public SerialNumberEx addSerialNumber(SerialNumberEx serialNumberEx) {
|
||
logService.insertLog(BusinessConstants.LOG_INTERFACE_NAME_SERIAL_NUMBER,BusinessConstants.LOG_OPERATION_TYPE_ADD,
|
||
((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest());
|
||
if(serialNumberEx==null){
|
||
return null;
|
||
}
|
||
/**处理商品id*/
|
||
serialNumberEx.setMaterialId(getSerialNumberMaterialIdByMaterialName(serialNumberEx.getMaterialName()));
|
||
//删除标记,默认未删除
|
||
serialNumberEx.setDeleteFlag(BusinessConstants.DELETE_FLAG_EXISTS);
|
||
//已卖出，默认未否
|
||
serialNumberEx.setIsSell(BusinessConstants.IS_SELL_HOLD);
|
||
Date date=new Date();
|
||
serialNumberEx.setCreateTime(date);
|
||
serialNumberEx.setUpdateTime(date);
|
||
User userInfo=userService.getCurrentUser();
|
||
serialNumberEx.setCreator(userInfo==null?null:userInfo.getId());
|
||
serialNumberEx.setUpdater(userInfo==null?null:userInfo.getId());
|
||
int result=serialNumberMapperEx.addSerialNumber(serialNumberEx);
|
||
if(result==1){
|
||
return serialNumberEx;
|
||
}
|
||
return null;
|
||
}
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public SerialNumberEx updateSerialNumber(SerialNumberEx serialNumberEx) {
|
||
logService.insertLog(BusinessConstants.LOG_INTERFACE_NAME_SERIAL_NUMBER,
|
||
new StringBuffer(BusinessConstants.LOG_OPERATION_TYPE_EDIT).append(serialNumberEx.getId()).toString(),
|
||
((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest());
|
||
if(serialNumberEx==null){
|
||
return null;
|
||
}
|
||
/**处理商品id*/
|
||
serialNumberEx.setMaterialId(getSerialNumberMaterialIdByMaterialName(serialNumberEx.getMaterialName()));
|
||
Date date=new Date();
|
||
serialNumberEx.setUpdateTime(date);
|
||
User userInfo=userService.getCurrentUser();
|
||
serialNumberEx.setUpdater(userInfo==null?null:userInfo.getId());
|
||
int result = serialNumberMapperEx.updateSerialNumber(serialNumberEx);
|
||
if(result==1){
|
||
return serialNumberEx;
|
||
}
|
||
return null;
|
||
}
|
||
/**
|
||
* create by: cjl
|
||
* description:
|
||
* 根据商品名称判断商品名称是否有效
|
||
* create time: 2019/1/23 17:04
|
||
* @Param: materialName
|
||
* @return Long 满足使用条件的商品的id
|
||
*/
|
||
public Long checkMaterialName(String materialName){
|
||
if(StringUtil.isNotEmpty(materialName)) {
|
||
List<Material> mlist = materialMapperEx.findByMaterialName(materialName);
|
||
if (mlist == null || mlist.size() < 1) {
|
||
//商品名称不存在
|
||
throw new BusinessRunTimeException(ExceptionConstants.MATERIAL_NOT_EXISTS_CODE,
|
||
ExceptionConstants.MATERIAL_NOT_EXISTS_MSG);
|
||
}
|
||
if (mlist.size() > 1) {
|
||
//商品信息不唯一
|
||
throw new BusinessRunTimeException(ExceptionConstants.MATERIAL_NOT_ONLY_CODE,
|
||
ExceptionConstants.MATERIAL_NOT_ONLY_MSG);
|
||
|
||
}
|
||
//获得唯一商品
|
||
if (BusinessConstants.ENABLE_SERIAL_NUMBER_NOT_ENABLED.equals(mlist.get(0).getEnableserialnumber())) {
|
||
//商品未开启序列号
|
||
throw new BusinessRunTimeException(ExceptionConstants.MATERIAL_NOT_ENABLE_SERIAL_NUMBER_CODE,
|
||
ExceptionConstants.MATERIAL_NOT_ENABLE_SERIAL_NUMBER_MSG);
|
||
}
|
||
return mlist.get(0).getId();
|
||
}
|
||
return null;
|
||
}
|
||
/**
|
||
* create by: cjl
|
||
* description:
|
||
* 根据商品名称判断给商品添加序列号是否可行
|
||
* 1、根据商品名称必须查询到唯一的商品
|
||
* 2、该商品必须已经启用序列号
|
||
* 3、该商品已绑定序列号数量小于商品现有库存
|
||
* 2019-02-01
|
||
* 用商品的库存去限制序列号的添加有点不合乎道理，去掉此限制
|
||
* create time: 2019/1/23 17:04
|
||
* @Param: materialName
|
||
* @return Long 满足使用条件的商品的id
|
||
*/
|
||
public Long getSerialNumberMaterialIdByMaterialName(String materialName){
|
||
if(StringUtil.isNotEmpty(materialName)){
|
||
//计算商品库存和目前占用的可用序列号数量关系
|
||
//库存=入库-出库
|
||
//入库数量
|
||
Long materialId=checkMaterialName(materialName);
|
||
// int inSum = depotItemService.findByTypeAndMaterialId(BusinessConstants.DEPOTHEAD_TYPE_STORAGE, materialId);
|
||
// //出库数量
|
||
// int outSum = depotItemService.findByTypeAndMaterialId(BusinessConstants.DEPOTHEAD_TYPE_OUT, materialId);
|
||
// //查询当前商品下有效的序列号
|
||
// int serialNumberSum = serialNumberMapperEx.findSerialNumberByMaterialId(materialId);
|
||
// if((inSum-outSum)<=serialNumberSum){
|
||
// throw new BusinessRunTimeException(ExceptionConstants.MATERIAL_SERIAL_NUMBERE_NOT_MORE_THAN_STORAGE_CODE,
|
||
// ExceptionConstants.MATERIAL_SERIAL_NUMBERE_NOT_MORE_THAN_STORAGE_MSG);
|
||
// }
|
||
return materialId;
|
||
}
|
||
return null;
|
||
}
|
||
|
||
/**
|
||
* create by: cjl
|
||
* description:
|
||
* 出库时判断序列号库存是否足够，
|
||
* 同时将对应的序列号绑定单据
|
||
* create time: 2019/1/24 16:24
|
||
* @Param: List<DepotItem>
|
||
* @return void
|
||
*/
|
||
public void checkAndUpdateSerialNumber(DepotItem depotItem,User userInfo) throws Exception{
|
||
if(depotItem!=null){
|
||
//查询商品下已分配的可用序列号数量
|
||
int SerialNumberSum= serialNumberMapperEx.countSerialNumberByMaterialIdAndDepotheadId(depotItem.getMaterialid(),null,BusinessConstants.IS_SELL_HOLD);
|
||
//BasicNumber=OperNumber*ratio
|
||
if((depotItem.getBasicnumber()==null?0:depotItem.getBasicnumber()).intValue()>SerialNumberSum){
|
||
//获取商品名称
|
||
Material material= materialMapper.selectByPrimaryKey(depotItem.getMaterialid());
|
||
throw new BusinessRunTimeException(ExceptionConstants.MATERIAL_SERIAL_NUMBERE_NOT_ENOUGH_CODE,
|
||
String.format(ExceptionConstants.MATERIAL_SERIAL_NUMBERE_NOT_ENOUGH_MSG,material==null?"":material.getName()));
|
||
}
|
||
//商品下序列号充足，分配序列号
|
||
sellSerialNumber(depotItem.getMaterialid(),depotItem.getHeaderid(),(depotItem.getBasicnumber()==null?0:depotItem.getBasicnumber()).intValue(),userInfo);
|
||
}
|
||
|
||
}
|
||
/**
|
||
*
|
||
*
|
||
* */
|
||
/**
|
||
* create by: cjl
|
||
* description:
|
||
* 卖出序列号
|
||
* create time: 2019/1/25 9:17
|
||
* @Param: materialId
|
||
* @Param: depotheadId
|
||
* @Param: isSell 卖出'1'
|
||
* @Param: Count 卖出或者赎回的数量
|
||
* @return com.jsh.erp.datasource.entities.SerialNumberEx
|
||
*/
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public int sellSerialNumber(Long materialId, Long depotheadId,int count,User user) throws Exception{
|
||
return serialNumberMapperEx.sellSerialNumber(materialId,depotheadId,count,new Date(),user==null?null:user.getId());
|
||
}
|
||
|
||
/**
|
||
* create by: cjl
|
||
* description:
|
||
* 赎回序列号
|
||
* create time: 2019/1/25 9:17
|
||
* @Param: materialId
|
||
* @Param: depotheadId
|
||
* @Param: isSell 赎回'0'
|
||
* @Param: Count 卖出或者赎回的数量
|
||
* @return com.jsh.erp.datasource.entities.SerialNumberEx
|
||
*/
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public int cancelSerialNumber(Long materialId, Long depotheadId,int count,User user) throws Exception{
|
||
return serialNumberMapperEx.cancelSerialNumber(materialId,depotheadId,count,new Date(),user==null?null:user.getId());
|
||
}
|
||
|
||
/**
|
||
* create by: cjl
|
||
* description:
|
||
*批量添加序列号
|
||
* create time: 2019/1/29 15:11
|
||
* @Param: materialName
|
||
* @Param: serialNumberPrefix
|
||
* @Param: batAddTotal
|
||
* @Param: remark
|
||
* @return java.lang.Object
|
||
*/
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public void batAddSerialNumber(String materialName, String serialNumberPrefix, Integer batAddTotal, String remark) {
|
||
logService.insertLog(BusinessConstants.LOG_INTERFACE_NAME_SERIAL_NUMBER,
|
||
new StringBuffer(BusinessConstants.LOG_OPERATION_TYPE_BATCH_ADD).append(batAddTotal).append(BusinessConstants.LOG_DATA_UNIT).toString(),
|
||
((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest());
|
||
if(StringUtil.isNotEmpty(materialName)){
|
||
//查询商品id
|
||
Long materialId = checkMaterialName(materialName);
|
||
List<SerialNumberEx> list=null;
|
||
//当前用户
|
||
User userInfo=userService.getCurrentUser();
|
||
Long userId=userInfo==null?null:userInfo.getId();
|
||
Date date = null;
|
||
Long million=null;
|
||
synchronized(this){
|
||
date = new Date();
|
||
million=date.getTime();
|
||
}
|
||
|
||
int insertNum=0;
|
||
StringBuffer prefixBuf=new StringBuffer(serialNumberPrefix).append(million);
|
||
do{
|
||
list=new ArrayList<SerialNumberEx>();
|
||
int forNum = BusinessConstants.BATCH_INSERT_MAX_NUMBER>=batAddTotal?batAddTotal:BusinessConstants.BATCH_INSERT_MAX_NUMBER;
|
||
for(int i=0;i<forNum;i++){
|
||
insertNum++;
|
||
SerialNumberEx each=new SerialNumberEx();
|
||
each.setMaterialId(materialId);
|
||
each.setCreator(userId);
|
||
each.setCreateTime(date);
|
||
each.setUpdater(userId);
|
||
each.setUpdateTime(date);
|
||
each.setRemark(remark);
|
||
each.setSerialNumber(new StringBuffer(prefixBuf.toString()).append(insertNum).toString());
|
||
list.add(each);
|
||
}
|
||
serialNumberMapperEx.batAddSerialNumber(list);
|
||
batAddTotal -= BusinessConstants.BATCH_INSERT_MAX_NUMBER;
|
||
}while(batAddTotal>0);
|
||
}
|
||
}
|
||
/**
|
||
* create by: qiankunpingtai
|
||
* website：http://39.105.146.63/symphony/
|
||
* description:
|
||
* 逻辑删除序列号信息
|
||
* create time: 2019/3/27 17:43
|
||
* @Param: ids
|
||
* @return
|
||
*/
|
||
@Transactional(value = "transactionManager", rollbackFor = Exception.class)
|
||
public int batchDeleteSerialNumberByIds(String ids) {
|
||
logService.insertLog(BusinessConstants.LOG_INTERFACE_NAME_SERIAL_NUMBER,
|
||
new StringBuffer(BusinessConstants.LOG_OPERATION_TYPE_DELETE).append(ids).toString(),
|
||
((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest());
|
||
User userInfo=userService.getCurrentUser();
|
||
String [] idArray=ids.split(",");
|
||
return serialNumberMapperEx.batchDeleteSerialNumberByIds(new Date(),userInfo==null?null:userInfo.getId(),idArray);
|
||
|
||
}
|
||
}
|