package com.gk.firework.Service.ServiceImpl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gk.firework.Config.DataSource.MybatisPlusConfig;
|
import com.gk.firework.Domain.Exception.BusinessException;
|
import com.gk.firework.Domain.ProductLocusInfo;
|
import com.gk.firework.Domain.Utils.StringUtils;
|
import com.gk.firework.Domain.Vo.DirectionDetail;
|
import com.gk.firework.Domain.Vo.FireworkDeal;
|
import com.gk.firework.Domain.Vo.ProductLocusVo;
|
import com.gk.firework.Domain.Vo.ProductVo;
|
import com.gk.firework.Mapper.ProductLocusInfoMapper;
|
import com.gk.firework.Service.ProductLocusService;
|
import com.gk.firework.Service.ProductService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.Comparator;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author : jingjy
|
* @date : 2021/3/24 14:34
|
*/
|
@Service("ProductLocusService")
|
public class ProductLocusServiceImpl extends ServiceImpl<ProductLocusInfoMapper, ProductLocusInfo> implements ProductLocusService {
|
@Autowired
|
private ProductService productService;
|
@Autowired
|
private ProductLocusInfoMapper productLocusInfoMapper;
|
|
@Override
|
public int insertProductLocus(ProductLocusInfo productLocusInfo) {
|
int i = 0;
|
if (productLocusInfo == null){
|
return i;
|
}
|
String slice = productService.getSlice(productLocusInfo.getDirectioncode());
|
i = productLocusInfoMapper.insertProductLocus(productLocusInfo, slice);
|
return i;
|
}
|
|
@Override
|
public int insertBatch(List<ProductLocusInfo> productLocusInfos) {
|
int i = 0;
|
if (productLocusInfos == null || productLocusInfos.size() == 0){
|
return i;
|
}
|
for (ProductLocusInfo productLocusInfo : productLocusInfos){
|
i = insertProductLocus(productLocusInfo);
|
}
|
return i;
|
}
|
|
/**
|
* @Description: 条码流向查询
|
* @date 2021/4/14 16:01
|
*/
|
@Override
|
public List<ProductLocusVo> getFlow(String directionCode) {
|
|
ArrayList<ProductLocusVo> result = new ArrayList<>();
|
//判空和长度判断
|
if (StringUtils.isBlank(directionCode)) throw new BusinessException("流向码不能为空");
|
if (FireworkDeal.isNotDirectionCode(directionCode)) throw new BusinessException("流向码非法");
|
//根据创建时间倒叙排序
|
DirectionDetail directionDetail = FireworkDeal.dealDirectionCode(directionCode);
|
List<ProductVo> productVos = new ArrayList<>();
|
ProductVo productVo = productService.selectVoByDirection(directionCode);
|
if (productVo == null) throw new BusinessException("产品不存在");
|
String slice = productService.getSlice(directionCode);
|
//22位码
|
if (FireworkDeal.is22Characters(directionCode)){
|
FireworkDeal.getProductVos(directionCode,directionDetail,directionDetail,productVos,productVo);
|
if (productVos.size() < 1) throw new BusinessException("产品流向码出现问题");
|
List<String> codes= new ArrayList<>();
|
for (ProductVo product : productVos) {
|
codes.add(product.getDirectionCode());
|
}
|
//22位查询
|
List<ProductLocusVo> flow_22 = productLocusInfoMapper.selectLists(directionCode, slice);
|
if (flow_22.size() < 1) throw new BusinessException("查询结果不存在");
|
result.addAll(flow_22);
|
//19位查询
|
List<ProductLocusVo> flow_19 = productLocusInfoMapper.selectFlowByCodes(codes, slice);
|
assert flow_19.size() > 0;
|
result.addAll(flow_19);
|
}else{
|
//19位查询
|
List<ProductLocusVo> flow_19 = productLocusInfoMapper.selectLists(directionCode,slice);
|
//19找22位箱
|
Integer boxNumber = productVo.getBoxNumber();
|
String serialNo = directionDetail.getSerialNo();
|
Integer serial = Integer.parseInt(serialNo);
|
int left_open_interval = serial - boxNumber;
|
int right_close_interval = serial;
|
List<String> codes = new ArrayList<>();
|
for (int i = left_open_interval + 1; i <= right_close_interval; i++) {
|
int abs = Math.abs(i);
|
String itemCode = directionDetail.getItemCode();
|
String dateCode = directionDetail.getDateCode();
|
String serials = String.format("%05d", abs);
|
String boxNumberCode = String.format("%03d", boxNumber);
|
String code = String.format("%s%s%s%s", itemCode, dateCode, serials, boxNumberCode);
|
codes.add(code);
|
}
|
List<ProductLocusVo> flow_22 = productLocusInfoMapper.selectFlowByCodes(codes,slice);
|
assert flow_22.size() > 0;
|
result.addAll(flow_22);
|
result.addAll(flow_19);
|
}
|
|
if (result.size() >0 )
|
return result.stream().sorted(Comparator.comparing(ProductLocusVo::getCreateddate).reversed()).collect(Collectors.toList());
|
|
return result;
|
}
|
|
@Override
|
public int saveBatchLocus(List<ProductLocusInfo> productLocuses) {
|
if (productLocuses == null || productLocuses.size() == 0) {
|
throw new BusinessException("系统入参为空");
|
}
|
return productLocusInfoMapper.insertBatch(productLocuses);
|
}
|
}
|
