package com.jcdm.main.da.passingStationCollection.service.impl; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.List; import com.jcdm.common.constant.Constants; import com.jcdm.common.utils.DateUtils; import com.jcdm.main.bs.orderScheduling.domain.BsOrderScheduling; import com.jcdm.main.bs.orderScheduling.mapper.BsOrderSchedulingMapper; import com.jcdm.main.bs.orderScheduling.service.IBsOrderSchedulingService; import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection; import com.jcdm.main.da.passingStationCollection.mapper.DaPassingStationCollectionMapper; import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService; import com.jcdm.main.rm.repairRecord.domain.RmRepairRecord; import com.jcdm.main.rm.repairRecord.mapper.RmRepairRecordMapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.format.annotation.DateTimeFormat; import org.springframework.stereotype.Service; /** * 产品过站采集Service业务层处理 * * @author yyt * @date 2023-12-12 */ @Service public class DaPassingStationCollectionServiceImpl implements IDaPassingStationCollectionService { @Autowired private DaPassingStationCollectionMapper daPassingStationCollectionMapper; @Autowired private RmRepairRecordMapper rmRepairRecordMapper; @Autowired private BsOrderSchedulingMapper bsOrderSchedulingMapper; @Autowired private IBsOrderSchedulingService bsOrderSchedulingService; /** * 查询产品过站采集 * * @param id 产品过站采集主键 * @return 产品过站采集 */ @Override public DaPassingStationCollection selectDaPassingStationCollectionById(Long id) { return daPassingStationCollectionMapper.selectDaPassingStationCollectionById(id); } /** * 查询产品过站采集列表 * * @param daPassingStationCollection 产品过站采集 * @return 产品过站采集 */ @Override public List selectDaPassingStationCollectionList(DaPassingStationCollection daPassingStationCollection) { return daPassingStationCollectionMapper.selectDaPassingStationCollectionList(daPassingStationCollection); } /** * 获取首页单日累计量产数据 * @param fieldName bs * @return list */ @Override public Integer getProduceNumToday(String fieldName) { BsOrderScheduling bsOrderScheduling = new BsOrderScheduling(); bsOrderScheduling.setQueryField(fieldName); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); LocalDateTime startTime = LocalDate.now().atStartOfDay(); LocalDateTime endTime = LocalDate.now().plusDays(1).atStartOfDay(); String s1 = startTime.format(formatter); String s2 = endTime.format(formatter); bsOrderScheduling.setStartTime(s1); bsOrderScheduling.setEndTime(s2); return bsOrderSchedulingMapper.getProduceNumToday(bsOrderScheduling); } /** * 新增产品过站采集 * * @param daPassingStationCollection 产品过站采集 * @return 结果 */ @Override public int insertDaPassingStationCollection(DaPassingStationCollection daPassingStationCollection) { daPassingStationCollection.setCreateTime(DateUtils.getNowDate()); return daPassingStationCollectionMapper.insertDaPassingStationCollection(daPassingStationCollection); } /** * 修改产品过站采集 * * @param daPassingStationCollection 产品过站采集 * @return 结果 */ @Override public int updateDaPassingStationCollection(DaPassingStationCollection daPassingStationCollection) { daPassingStationCollection.setUpdateTime(DateUtils.getNowDate()); return daPassingStationCollectionMapper.updateDaPassingStationCollection(daPassingStationCollection); } /** * 批量删除产品过站采集 * * @param ids 需要删除的产品过站采集主键 * @return 结果 */ @Override public int deleteDaPassingStationCollectionByIds(Long[] ids) { return daPassingStationCollectionMapper.deleteDaPassingStationCollectionByIds(ids); } /** * 删除产品过站采集信息 * * @param id 产品过站采集主键 * @return 结果 */ @Override public int deleteDaPassingStationCollectionById(Long id) { return daPassingStationCollectionMapper.deleteDaPassingStationCollectionById(id); } @Override public void insertRepairRecordByIds(DaPassingStationCollection daPassingStationCollection) { Long[] conditions = daPassingStationCollection.getIds(); for (int i = 0; i < conditions.length; i++) { DaPassingStationCollection result = daPassingStationCollectionMapper.selectDaPassingStationCollectionById(conditions[i]); RmRepairRecord rmRepairRecord = new RmRepairRecord(); rmRepairRecord.setBoxCode(result.getSfcCode()); rmRepairRecord.setProcessesCode(result.getLocationCode()); rmRepairRecord.setOriginalResult(result.getOutRsSign()); rmRepairRecordMapper.insertRmRepairRecord(rmRepairRecord); } } }