package com.ruoyi.production.service.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.basic.pojo.Customer;
|
import com.ruoyi.common.utils.poi.ExcelUtil;
|
import com.ruoyi.framework.web.domain.AjaxResult;
|
import com.ruoyi.production.dto.ProductProcessDto;
|
import com.ruoyi.production.mapper.ProcessRouteItemMapper;
|
import com.ruoyi.production.mapper.ProductProcessMapper;
|
import com.ruoyi.production.mapper.ProductProcessRouteItemMapper;
|
import com.ruoyi.production.pojo.ProcessRouteItem;
|
import com.ruoyi.production.pojo.ProductProcess;
|
import com.ruoyi.production.pojo.ProductProcessRouteItem;
|
import com.ruoyi.production.service.ProductProcessService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.util.List;
|
|
@Service
|
public class ProductProcessServiceImpl extends ServiceImpl<ProductProcessMapper, ProductProcess> implements ProductProcessService {
|
@Autowired
|
private ProductProcessMapper productProcessMapper;
|
@Autowired
|
private ProcessRouteItemMapper processRouteItemMapper;
|
@Autowired
|
private ProductProcessRouteItemMapper productProcessRouteItemMapper;
|
|
@Override
|
public IPage<ProductProcessDto> listPage(Page page, ProductProcessDto productProcessDto) {
|
return productProcessMapper.listPage(page, productProcessDto);
|
}
|
|
@Override
|
public AjaxResult add(ProductProcessDto productProcessDto) {
|
ProductProcess productProcess = new ProductProcess();
|
BeanUtils.copyProperties(productProcessDto,productProcess);
|
boolean save = productProcessMapper.insert(productProcess) > 0;
|
if (save && ObjectUtils.isNull(productProcessDto.getNo())) {
|
// 根据id生成no字段：GX + 8位数字（不足8位前面补0）
|
String no = "GX" + String.format("%08d", productProcess.getId());
|
productProcess.setNo(no);
|
|
productProcessMapper.updateById(productProcess);
|
return AjaxResult.success();
|
}
|
return AjaxResult.success();
|
}
|
|
@Override
|
public AjaxResult importData(MultipartFile file) {
|
try {
|
ExcelUtil<ProductProcess> util = new ExcelUtil<ProductProcess>(ProductProcess.class);
|
List<ProductProcess> productProcessList = util.importExcel(file.getInputStream());
|
if(CollectionUtils.isEmpty(productProcessList)){
|
return AjaxResult.warn("模板错误或导入数据为空");
|
}
|
this.saveOrUpdateBatch(productProcessList);
|
return AjaxResult.success(true);
|
}catch (Exception e){
|
e.printStackTrace();
|
return AjaxResult.error("导入失败");
|
}
|
}
|
|
@Override
|
public String batchDelete(List<Integer> ids) {
|
//查询是否生产中已经引用了这些工序
|
List<ProcessRouteItem> processRouteItems = processRouteItemMapper.selectList(Wrappers.<ProcessRouteItem>lambdaQuery().in(ProcessRouteItem::getProcessId, ids));
|
List<ProductProcessRouteItem> productProcessRouteItems = productProcessRouteItemMapper.selectList(Wrappers.<ProductProcessRouteItem>lambdaQuery().in(ProductProcessRouteItem::getProcessId, ids));
|
if (!CollectionUtils.isEmpty(processRouteItems) || !CollectionUtils.isEmpty(productProcessRouteItems)){
|
throw new RuntimeException("该工序已经被使用，无法删除");
|
}
|
productProcessMapper.deleteBatchIds(ids);
|
return null;
|
}
|
}
|
