package com.ruoyi.business.service.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.business.entity.Production;
|
import com.ruoyi.business.entity.ProductionScheduling;
|
import com.ruoyi.business.mapper.ProductionMapper;
|
import com.ruoyi.business.mapper.ProductionSchedulingMapper;
|
import com.ruoyi.business.service.ProductionSchedulingService;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.system.mapper.SysUserMapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.math.BigDecimal;
|
import java.util.Arrays;
|
import java.util.List;
|
|
/**
|
* @author :yys
|
* @date : 2025/8/25 16:38
|
*/
|
@Service
|
@Slf4j
|
public class ProductionSchedulingServiceImpl extends ServiceImpl<ProductionSchedulingMapper, ProductionScheduling> implements ProductionSchedulingService {
|
|
@Autowired
|
private ProductionSchedulingMapper productionSchedulingMapper;
|
|
@Autowired
|
private ProductionMapper productionMapper;
|
|
@Autowired
|
private SysUserMapper sysUserMapper;
|
|
@Autowired
|
private ProductionMasterServiceImpl productionMasterService;
|
|
@Override
|
public IPage<ProductionScheduling> listPage(Page<ProductionScheduling> page, ProductionScheduling productionScheduling) {
|
return productionSchedulingMapper.listPage(page, productionScheduling);
|
}
|
|
@Override
|
public boolean addProductionScheduling(List<ProductionScheduling> productionScheduling) {
|
if (CollectionUtils.isEmpty(productionScheduling)) {
|
return false;
|
}
|
BigDecimal reduce = productionScheduling.stream()
|
.map(ProductionScheduling::getSchedulingNum)
|
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
if(reduce.compareTo(productionScheduling.get(0).getProductionQuantity()) < 0){
|
return false;
|
}
|
Production production = productionMapper.selectById(productionScheduling.get(0).getProductionId());
|
if(production == null){
|
throw new RuntimeException("生产订单为空");
|
}
|
production.setStatus(2);
|
if(reduce.compareTo(productionScheduling.get(0).getProductionQuantity()) == 0){
|
production.setStatus(3);
|
}
|
productionMapper.updateById(production);
|
for (ProductionScheduling scheduling : productionScheduling) {
|
SysUser sysUser = sysUserMapper.selectUserById(scheduling.getSchedulingUserId());
|
if(sysUser == null) throw new RuntimeException("排产人员不存在");
|
scheduling.setStatus(1);
|
scheduling.setSchedulingUserName(sysUser.getNickName());
|
productionSchedulingMapper.insert(scheduling);
|
}
|
return true;
|
}
|
|
@Override
|
public boolean work(ProductionScheduling productionScheduling) {
|
ProductionScheduling productionScheduling1 = productionSchedulingMapper.selectById(productionScheduling.getId());
|
if(productionScheduling1 == null){
|
throw new RuntimeException("生产报工不存在");
|
}
|
Production production = productionMapper.selectById(productionScheduling1.getProductionId());
|
if(production == null){
|
throw new RuntimeException("生产订单为空");
|
}
|
production.setProductionQuantity(productionScheduling.getSuccessNum());
|
production.setProducerId(productionScheduling.getSchedulingUserId());
|
// 入库
|
productionMasterService.insertPendingInventory(Arrays.asList(production));
|
// 修改报工表的入库数量
|
|
productionScheduling1.setSuccessNum(productionScheduling1.getSuccessNum().add(productionScheduling.getSuccessNum()));
|
productionScheduling1.setStatus(2);
|
// 入库数量 == 排产数量 则修改生产订单状态
|
if(productionScheduling1.getSuccessNum().compareTo(productionScheduling1.getSchedulingNum()) == 0){
|
productionScheduling1.setStatus(3);
|
}
|
productionSchedulingMapper.updateById(productionScheduling1);
|
return true;
|
}
|
}
|
