package com.jcdm.main.da.passingStationCollection.service.impl; 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.stereotype.Service; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.List; /** * 产品过站采集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); } } }