jiyufei
2 months ago
parent
94da8191b6
commit
f261ec9b04
@ -0,0 +1,168 @@
|
|||||||
|
package jnpf.dataUtil;
|
||||||
|
|
||||||
|
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
|
import jnpf.entity.*;
|
||||||
|
import jnpf.service.*;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
@DS("master")
|
||||||
|
public class MasterDataService {
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysSupplierInformationService yysSupplierInformationService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysSupplierClassService yysSupplierClassService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysMaterialInformationService yysMaterialInformationService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysMaterialClassService yysMaterialClassService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysUnitInformationService yysUnitInformationService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysBillMaterialService yysBillMaterialService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysSubsetMaterialService yysSubsetMaterialService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysInventoryQueryService yysInventoryQueryService;
|
||||||
|
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysDeviceDataService yysDeviceDataService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysDeviceWarnStatisticsService yysDeviceWarnStatisticsService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private YysDeviceWarnService yysDeviceWarnService;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 供应商查询
|
||||||
|
**/
|
||||||
|
public List<String> getSupplierIds() {
|
||||||
|
return yysSupplierInformationService.list(new LambdaQueryWrapper<>(YysSupplierInformationEntity.class).isNull(YysSupplierInformationEntity::getDeleteMark))
|
||||||
|
.stream().map(YysSupplierInformationEntity::getSupplierId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveSupplierBatch(List<YysSupplierInformationEntity> result) {
|
||||||
|
return yysSupplierInformationService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 供应商分类查询
|
||||||
|
**/
|
||||||
|
public List<String> getSupplierClassIds() {
|
||||||
|
return yysSupplierClassService.list(new LambdaQueryWrapper<>(YysSupplierClassEntity.class).isNull(YysSupplierClassEntity::getDeleteMark))
|
||||||
|
.stream().map(YysSupplierClassEntity::getClassId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveSupplierClassBatch(List<YysSupplierClassEntity> result) {
|
||||||
|
return yysSupplierClassService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 物料信息查询
|
||||||
|
**/
|
||||||
|
public List<String> getMaterialInfoIds() {
|
||||||
|
return yysMaterialInformationService.list(new LambdaQueryWrapper<>(YysMaterialInformationEntity.class).isNull(YysMaterialInformationEntity::getDeleteMark))
|
||||||
|
.stream().map(YysMaterialInformationEntity::getMaterialId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveMaterialInfoBatch(List<YysMaterialInformationEntity> result) {
|
||||||
|
return yysMaterialInformationService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 物料分类查询
|
||||||
|
**/
|
||||||
|
public List<String> getMaterialClassIds() {
|
||||||
|
return yysMaterialClassService.list(new LambdaQueryWrapper<>(YysMaterialClassEntity.class).isNull(YysMaterialClassEntity::getDeleteMark))
|
||||||
|
.stream().map(YysMaterialClassEntity::getClassId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveMaterialClassBatch(List<YysMaterialClassEntity> result) {
|
||||||
|
return yysMaterialClassService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 单位查询
|
||||||
|
**/
|
||||||
|
public List<String> getUnitIds() {
|
||||||
|
return yysUnitInformationService.list(new LambdaQueryWrapper<>(YysUnitInformationEntity.class).isNull(YysUnitInformationEntity::getDeleteMark))
|
||||||
|
.stream().map(YysUnitInformationEntity::getUnitId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveUnitBatch(List<YysUnitInformationEntity> result) {
|
||||||
|
return yysUnitInformationService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 物料清单
|
||||||
|
**/
|
||||||
|
public List<String> getBillIds() {
|
||||||
|
return yysBillMaterialService.list(new LambdaQueryWrapper<>(YysBillMaterialEntity.class).isNull(YysBillMaterialEntity::getDeleteMark))
|
||||||
|
.stream().map(YysBillMaterialEntity::getId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveBillBatch(List<YysBillMaterialEntity> result) {
|
||||||
|
return yysBillMaterialService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveSubsetBatch(List<YysSubsetMaterialEntity> result) {
|
||||||
|
return yysSubsetMaterialService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 库存查询
|
||||||
|
**/
|
||||||
|
public List<String> getInventoryIds() {
|
||||||
|
return yysInventoryQueryService.list(new LambdaQueryWrapper<>(YysInventoryQueryEntity.class).isNull(YysInventoryQueryEntity::getDeleteMark))
|
||||||
|
.stream().map(YysInventoryQueryEntity::getId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveInventoryBatch(List<YysInventoryQueryEntity> result) {
|
||||||
|
return yysInventoryQueryService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
/***********************************分割线 数采专用*********************************************/
|
||||||
|
public List<Long> getSCDeviceDataIds() {
|
||||||
|
LambdaQueryWrapper<YysDeviceDataEntity> wrapper = new LambdaQueryWrapper<>(YysDeviceDataEntity.class);
|
||||||
|
wrapper.isNull(YysDeviceDataEntity::getDeleteMark);
|
||||||
|
List<YysDeviceDataEntity> list1 = yysDeviceDataService.list(wrapper);
|
||||||
|
return list1.stream().map(YysDeviceDataEntity::getSyncId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public void saveSCDeviceDataBatch(List<YysDeviceDataEntity> result) {
|
||||||
|
yysDeviceDataService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public List<Long> getSCDeviceWarnIds() {
|
||||||
|
LambdaQueryWrapper<YysDeviceWarnStatisticsEntity> wrapper = new LambdaQueryWrapper<>(YysDeviceWarnStatisticsEntity.class);
|
||||||
|
wrapper.isNull(YysDeviceWarnStatisticsEntity::getDeleteMark);
|
||||||
|
List<YysDeviceWarnStatisticsEntity> list1 = yysDeviceWarnStatisticsService.list(wrapper);
|
||||||
|
return list1.stream().map(YysDeviceWarnStatisticsEntity::getSyncId).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean saveSCDeviceWarnBatch(List<YysDeviceWarnStatisticsEntity> result) {
|
||||||
|
return yysDeviceWarnStatisticsService.saveBatch(result);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void syncCount(List<YysDeviceWarnStatisticsEntity> collect) {
|
||||||
|
yysDeviceWarnService.syncCount(collect);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
Loading…
Reference in new issue