|
|
|
@ -175,6 +175,8 @@ public class ChanjetSchedule {
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
|
|
public void queryProcessBom(String projectOrderCode) throws ChanjetApiException {
|
|
|
|
|
TenantContextHolder.setTenantId(new Long(2));
|
|
|
|
|
// 存在新物料标记位
|
|
|
|
|
final Boolean[] hasNewMat = {false};
|
|
|
|
|
List<ProjectOrderSubDO> projectOrderSubDOS = projectOrderSubMapper.selectListAll(projectOrderCode);
|
|
|
|
|
List<String> codes = new ArrayList<>();
|
|
|
|
|
if(CollUtil.isNotEmpty(projectOrderSubDOS)){
|
|
|
|
@ -183,6 +185,12 @@ public class ChanjetSchedule {
|
|
|
|
|
List<BomMaterialVO> bomMaterialVOS = queryProcessBom(so.getProjectSubCode(), so.getWarehouseId());
|
|
|
|
|
if (CollUtil.isNotEmpty(bomMaterialVOS)) {
|
|
|
|
|
|
|
|
|
|
bomMaterialVOS.forEach(mo->{
|
|
|
|
|
if(materialMapper.selectOne(MaterialDO::getCode,mo.getProjectSubCode())==null){
|
|
|
|
|
hasNewMat[0] = true;
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
List<TplusLastestBomDO> insertList = BeanUtils.toBean(bomMaterialVOS, TplusLastestBomDO.class);
|
|
|
|
|
|
|
|
|
|
insertList.forEach(xo -> {
|
|
|
|
@ -198,6 +206,10 @@ public class ChanjetSchedule {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
if(hasNewMat[0]){
|
|
|
|
|
// 存在新的物料,则同步物料信息
|
|
|
|
|
chanjetManager.queryMaterial();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|