package com.aps.core.service.impl;
|
|
import java.util.List;
|
|
import com.aps.common.core.utils.DateUtils;
|
import com.aps.common.security.utils.SecurityUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.aps.core.mapper.ApsAbnormalProcessAnalysisMapper;
|
import com.aps.core.domain.ApsAbnormalProcessAnalysis;
|
import com.aps.core.service.IApsAbnormalProcessAnalysisService;
|
import org.springframework.transaction.annotation.Transactional;
|
|
/**
|
* 工序异常分析Service业务层处理
|
*
|
* @author zhl
|
* @date 2025-04-21
|
*/
|
@Service
|
public class ApsAbnormalProcessAnalysisServiceImpl implements IApsAbnormalProcessAnalysisService {
|
@Autowired
|
private ApsAbnormalProcessAnalysisMapper apsAbnormalProcessAnalysisMapper;
|
|
/**
|
* 查询工序异常分析
|
*
|
* @param id 工序异常分析主键
|
* @return 工序异常分析
|
*/
|
@Override
|
public ApsAbnormalProcessAnalysis selectApsAbnormalProcessAnalysisById(Long id) {
|
return apsAbnormalProcessAnalysisMapper.selectApsAbnormalProcessAnalysisById(id);
|
}
|
|
/**
|
* 查询工序异常分析列表
|
*
|
* @param apsAbnormalProcessAnalysis 工序异常分析
|
* @return 工序异常分析
|
*/
|
@Override
|
public List<ApsAbnormalProcessAnalysis> selectApsAbnormalProcessAnalysisList(ApsAbnormalProcessAnalysis apsAbnormalProcessAnalysis) {
|
return apsAbnormalProcessAnalysisMapper.selectApsAbnormalProcessAnalysisList(apsAbnormalProcessAnalysis);
|
}
|
|
/**
|
* 新增工序异常分析
|
*
|
* @param apsAbnormalProcessAnalysis 工序异常分析
|
* @return 结果
|
*/
|
@Override
|
public int insertApsAbnormalProcessAnalysis(ApsAbnormalProcessAnalysis apsAbnormalProcessAnalysis) {
|
apsAbnormalProcessAnalysis.setCreateTime(DateUtils.getNowDate());
|
return apsAbnormalProcessAnalysisMapper.insertApsAbnormalProcessAnalysis(apsAbnormalProcessAnalysis);
|
}
|
|
/**
|
* 修改工序异常分析
|
*
|
* @param apsAbnormalProcessAnalysis 工序异常分析
|
* @return 结果
|
*/
|
@Override
|
public int updateApsAbnormalProcessAnalysis(ApsAbnormalProcessAnalysis apsAbnormalProcessAnalysis) {
|
return apsAbnormalProcessAnalysisMapper.updateApsAbnormalProcessAnalysis(apsAbnormalProcessAnalysis);
|
}
|
|
/**
|
* 批量删除工序异常分析
|
*
|
* @param ids 需要删除的工序异常分析主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteApsAbnormalProcessAnalysisByIds(Long[] ids) {
|
return apsAbnormalProcessAnalysisMapper.deleteApsAbnormalProcessAnalysisByIds(ids);
|
}
|
|
/**
|
* 删除工序异常分析信息
|
*
|
* @param id 工序异常分析主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteApsAbnormalProcessAnalysisById(Long id) {
|
return apsAbnormalProcessAnalysisMapper.deleteApsAbnormalProcessAnalysisById(id);
|
}
|
|
/**
|
* 本方法用于从数据库中选择异常信息，并批量保存这些信息
|
* 主要目的是处理异常信息的批量保存，以提高数据处理效率
|
*/
|
@Transactional
|
@Override
|
public int batchSaveAbnormalInfo() {
|
String username = SecurityUtils.getUsername();
|
|
/*先删除旧数据*/
|
apsAbnormalProcessAnalysisMapper.batchRemoveAbnormalInfo();
|
// 选择数据库中的异常信息
|
List<ApsAbnormalProcessAnalysis> list = apsAbnormalProcessAnalysisMapper.selectAbnormalInfoFromStat();
|
// 批量保存选中的异常信息
|
if (!list.isEmpty()) {
|
//遍历list 更新 每条记录的 create_by 字段
|
list.forEach(item -> item.setCreateBy(username));
|
apsAbnormalProcessAnalysisMapper.batchSaveAbnormalInfo(list);
|
}
|
return list.size();
|
}
|
}
|
