package com.mes.bigstoragetask.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.mes.bigstorage.mapper.BigStorageCageDetailsMapper; import com.mes.bigstoragetask.entity.BigStorageCageOutTask; import com.mes.bigstoragetask.mapper.BigStorageCageOutTaskMapper; import com.mes.bigstoragetask.service.BigStorageCageOutTaskService; import com.mes.temperingglass.mapper.TemperingGlassInfoMapper; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.List; /** *

* 服务实现类 *

* * @author zhoush * @since 2024-04-16 */ @Slf4j @Service public class BigStorageCageOutTaskServiceImpl extends ServiceImpl implements BigStorageCageOutTaskService { @Resource TemperingGlassInfoMapper temperingGlassInfoMapper; @Resource BigStorageCageOutTaskMapper bigStorageCageOutTaskMapper; @Resource BigStorageCageDetailsMapper bigStorageCageDetailsMapper; @Override public List querybigStorageCageOutTask(int taskState) { log.info("根据传入的任务状态查询任务信息:" + taskState); LambdaQueryWrapper getOutTaskWrapper = new LambdaQueryWrapper<>(); getOutTaskWrapper.eq(BigStorageCageOutTask::getTaskState, taskState); return baseMapper.selectList(getOutTaskWrapper); } @Override public void updateOutTask() { List bigStorageCageOutTaskList = querybigStorageCageOutTask(1); log.info("查询任务表是否有已完成的出片任务" + bigStorageCageOutTaskList.size()); for (BigStorageCageOutTask bigStorageCageOutTask : bigStorageCageOutTaskList ) { deleteOutTask(bigStorageCageOutTask.getId()); } } @Override public void deleteOutTask(int taskId) { log.info("根据任务id修改钢化小片表状态,删除已完成的出片任务"); temperingGlassInfoMapper.deleteById(taskId); bigStorageCageOutTaskMapper.deleteById(taskId); bigStorageCageDetailsMapper.deleteById(taskId); } }