package doumeemes.service.ext.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import doumeemes.core.constants.ResponseStatus;
|
import doumeemes.core.exception.BusinessException;
|
import doumeemes.core.model.LoginUserInfo;
|
import doumeemes.core.model.PageData;
|
import doumeemes.core.model.PageWrap;
|
import doumeemes.core.utils.Constants;
|
import doumeemes.core.utils.redis.RedisUtil;
|
import doumeemes.dao.business.WOutboundMapper;
|
import doumeemes.dao.business.WTransferMapper;
|
import doumeemes.dao.business.WorkorderMapper;
|
import doumeemes.dao.business.model.*;
|
import doumeemes.dao.ext.*;
|
import doumeemes.dao.ext.dto.QueryBarcodeParamExtDTO;
|
import doumeemes.dao.ext.dto.QueryCompanyExtDTO;
|
import doumeemes.dao.ext.vo.BarcodeParamContent;
|
import doumeemes.dao.ext.vo.BarcodeParamExtListVO;
|
import doumeemes.dao.ext.vo.CompanyExtListVO;
|
import doumeemes.service.ext.BarcodeParamExtService;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* 二维码设置Service实现
|
* @author 江蹄蹄
|
* @date 2022/04/20 11:01
|
*/
|
@Service
|
public class BarcodeParamExtServiceImpl implements BarcodeParamExtService {
|
|
@Autowired
|
private RedisTemplate<String, Object> redisTemplate;
|
@Autowired
|
private CompanyExtMapper companyExtMapper;
|
@Autowired
|
private BarcodeParamExtMapper barcodeParamExtMapper;
|
@Autowired
|
private MaterialExtMapper materialExtMapper;
|
@Autowired
|
private WTransferMapper wTransferMapper;
|
@Autowired
|
private WOutboundMapper wOutboundMapper;
|
@Autowired
|
private AppliancesExtMapper appliancesExtMapper;
|
@Autowired
|
private WarehouseExtMapper warehouseExtMapper;
|
@Autowired
|
private WarehouseLocationExtMapper warehouseLocationExtMapper;
|
@Autowired
|
private WorkorderMapper workorderMapper;
|
@Autowired
|
private DeviceExtMapper deviceExtMapper;
|
@Autowired
|
private CompanyUserExtMapper companyUserExtMapper;
|
|
@Override
|
public PageData<BarcodeParamExtListVO> findPage(PageWrap<QueryBarcodeParamExtDTO> pageWrap) {
|
PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity());
|
List<BarcodeParamExtListVO> result = barcodeParamExtMapper.selectList(pageWrap.getModel());
|
return PageData.from(new PageInfo<>(result));
|
}
|
@Override
|
public void initParamData(Company com){
|
String[] names = new String[]{"WL","CK","HW","GD","GZ","S","YG","ZKD","CKD","RKD","K"};
|
BarcodeParam param = new BarcodeParam();
|
param.setCreateTime(new Date());
|
param.setStatus(Constants.ONE);
|
param.setDepartId(com.getRootDepartment().getId());
|
param.setRootDepartId(com.getRootDepartment().getId());
|
param.setDeleted(Constants.ZERO);
|
for(int i=0;i<10;i++){
|
param.setPrefix(names[i]);
|
param.setType(i);
|
barcodeParamExtMapper.insert(param);
|
}
|
CompanyExtListVO c = new CompanyExtListVO();
|
c.setId(com.getId());
|
loadCom(c);
|
}
|
|
|
@Override
|
public void loadCom(CompanyExtListVO com ) {
|
QueryBarcodeParamExtDTO d = new QueryBarcodeParamExtDTO();
|
d.setDeleted(Constants.ZERO);
|
d.setDmodelCompanyId(com.getId());
|
//查询全部企业部门信息
|
List<BarcodeParamExtListVO> clist = barcodeParamExtMapper.selectList(d);
|
//加入redis缓存，以企业id为编码，缓存企业二维码
|
RedisUtil.addObject(redisTemplate,Constants.RedisKeys.COM_BARCODE_KEY+com.getId(),clist);
|
}
|
@Override
|
public BarcodeParamExtListVO getByCode(Integer comId,Integer departId,String code){
|
if(comId==null || StringUtils.isBlank(code)){
|
return null;
|
}
|
//查询缓存数据
|
List<BarcodeParamExtListVO> clist = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_BARCODE_KEY+comId,ArrayList.class);
|
if(clist!=null){
|
for(BarcodeParamExtListVO model:clist){
|
if(StringUtils.isNotBlank(model.getPrefix()) && code.startsWith(model.getPrefix()) &&Constants.equalsInteger(model.getDepartId(),departId) ){
|
return model;
|
}
|
}
|
}
|
return null;
|
|
}
|
@Override
|
public BarcodeParamExtListVO getByCodeId(Integer comId,Integer departId, Integer brcode){
|
if(comId==null || brcode == null){
|
return null;
|
}
|
//查询缓存数据
|
List<BarcodeParamExtListVO> clist = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_BARCODE_KEY+comId,ArrayList.class);
|
if(clist!=null){
|
for(BarcodeParamExtListVO model:clist){
|
if(Constants.equalsInteger(brcode,model.getId())&&Constants.equalsInteger(model.getDepartId(),departId)){
|
return model;
|
}
|
}
|
}
|
|
return null;
|
|
}
|
@Override
|
public Integer getByType(Integer comId,Integer departId, Integer type){
|
if(comId==null || type == null){
|
return null;
|
}
|
//查询缓存数据
|
List<BarcodeParamExtListVO> clist = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_BARCODE_KEY+comId,ArrayList.class);
|
if(clist!=null){
|
for(BarcodeParamExtListVO model:clist){
|
if(Constants.equalsInteger(type,model.getType())&&Constants.equalsInteger(model.getDepartId(),departId)){
|
return model.getId();
|
}
|
}
|
}
|
return null;
|
|
}
|
|
|
|
@Override
|
public BarcodeParamContent getBarcodeContent(String code, LoginUserInfo loginUserInfo){
|
BarcodeParamContent barcodeParamContent = new BarcodeParamContent();
|
if(loginUserInfo.getComDepartment().getId()==null || StringUtils.isBlank(code)){
|
return null;
|
}
|
//查询缓存数据
|
List<BarcodeParamExtListVO> clist = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_BARCODE_KEY+loginUserInfo.getCompany().getId(),ArrayList.class);
|
if(clist!=null){
|
for(BarcodeParamExtListVO model:clist){
|
if(Constants.equalsInteger(model.getDepartId(),loginUserInfo.getComDepartment().getId()) && StringUtils.isNotBlank(model.getPrefix()) && code.startsWith(model.getPrefix())){
|
barcodeParamContent.setBarcodeType(model.getType());
|
if(model.getType() == Constants.BARCODEPARAM_TYPE.material){
|
Material material = materialExtMapper.selectOne(new QueryWrapper<Material>()
|
.eq("CODE",code.replaceFirst(model.getPrefix(),""))
|
.eq("QRCODE_ID",model.getId())
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(material)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(material.getId());
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.warehouse){
|
Warehouse warehouse = warehouseExtMapper.selectOne(new QueryWrapper<Warehouse>()
|
.eq("CODE", code.replaceFirst(model.getPrefix(),""))
|
.eq("QRCODE", model.getId())
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(warehouse)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(warehouse.getId());
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.localtion){
|
WarehouseLocation warehouseLocation = warehouseLocationExtMapper.selectOne(new QueryWrapper<WarehouseLocation>()
|
.eq("CODE", code.replaceFirst(model.getPrefix(),""))
|
.eq("QRCODE", model.getId())
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(warehouseLocation)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(warehouseLocation.getId());
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.workorder){
|
Workorder workorder = workorderMapper.selectOne(new QueryWrapper<Workorder>()
|
.eq("CODE", code.replaceFirst(model.getPrefix(),""))
|
.eq("QRCODE_ID", model.getId())
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(workorder)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(workorder.getId());
|
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.appliance){
|
Appliances appliances = appliancesExtMapper.selectOne(new QueryWrapper<Appliances>()
|
.eq("CODE", code.replaceFirst(model.getPrefix(),""))
|
.eq("BRCODE", model.getId())
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId()).last(" limit 1")
|
);
|
if(Objects.isNull(appliances)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(appliances.getId());
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.device){
|
Device device = deviceExtMapper.selectOne(new QueryWrapper<Device>()
|
.eq("CODE", code.replaceFirst(model.getPrefix(),""))
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(device)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(device.getId());
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.user){
|
CompanyUser companyUser = companyUserExtMapper.selectOne(new QueryWrapper<CompanyUser>()
|
.eq("CODE", code.replaceFirst(model.getPrefix(),""))
|
.eq("QRCODEID", model.getId())
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(companyUser)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(companyUser.getId());
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.transfer){
|
WTransfer wTransfer = wTransferMapper.selectOne(new QueryWrapper<WTransfer>()
|
.eq("CODE",code)
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(wTransfer)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(wTransfer.getId());
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.out){
|
WOutbound wOutbound = wOutboundMapper.selectOne(new QueryWrapper<WOutbound>()
|
.eq("CODE",code)
|
.eq("TYPE",Constants.ZERO)
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(wOutbound)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(wOutbound.getId());
|
}else if(model.getType() == Constants.BARCODEPARAM_TYPE.in){
|
WOutbound wOutbound = wOutboundMapper.selectOne(new QueryWrapper<WOutbound>()
|
.eq("CODE",code)
|
.eq("TYPE",Constants.ONE)
|
.eq("ROOT_DEPART_ID",loginUserInfo.getRootDepartment().getId())
|
);
|
if(Objects.isNull(wOutbound)){
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到数据信息");
|
}
|
barcodeParamContent.setId(wOutbound.getId());
|
}else{
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未匹配到条码类别：【"+model.getType()+"】");
|
}
|
return barcodeParamContent;
|
}
|
}
|
}
|
throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "未读取到条码分类信息，请检查条码信息");
|
}
|
|
|
@Override
|
public void loadAll() {
|
QueryCompanyExtDTO dto = new QueryCompanyExtDTO();
|
dto.setDeleted(Constants.ZERO);
|
//查询全部企业信息
|
List<CompanyExtListVO> list = companyExtMapper.selectList(dto);
|
if(list != null && list.size()>0){
|
QueryBarcodeParamExtDTO d = new QueryBarcodeParamExtDTO();
|
d.setDeleted(Constants.ZERO);
|
//查询全部企业部门信息
|
List<BarcodeParamExtListVO> codeList = barcodeParamExtMapper.selectList(d);
|
for(CompanyExtListVO com : list){
|
//当前企业的全部部门信息
|
List<BarcodeParamExtListVO> clist = getAllBarcodeByComId(com.getId(),codeList);
|
//加入redis缓存，以企业id为编码，缓存企业二维码
|
RedisUtil.addObject(redisTemplate,Constants.RedisKeys.COM_BARCODE_KEY+com.getId(),clist);
|
}
|
}
|
}
|
/**
|
* 根据企业编码获取二维码配置
|
* @param id
|
* @param alllist
|
* @return
|
*/
|
private List<BarcodeParamExtListVO> getAllBarcodeByComId(Integer id, List<BarcodeParamExtListVO> alllist) {
|
List<BarcodeParamExtListVO> list = null;
|
if(alllist!= null){
|
for(BarcodeParamExtListVO d :alllist){
|
if(d.getDmodel()!=null && Constants.equalsInteger(id,d.getDmodel().getCompanyId())){
|
if(list == null){
|
list = new ArrayList<>();
|
}
|
list.add(d);
|
}
|
}
|
}
|
return list;
|
}
|
}
|
