package com.mes.downglassinfo.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.mes.downglassinfo.entity.DownGlassTask; import com.mes.downglassinfo.mapper.DownGlassTaskMapper; import com.mes.downglassinfo.service.DownGlassTaskService; import org.springframework.stereotype.Service; import java.util.List; /** *

* 服务实现类 *

* * @author zhoush * @since 2024-04-07 */ @Service public class DownGlassTaskServiceImpl extends ServiceImpl implements DownGlassTaskService { @Override public List getUnloadingTaskState() { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("task_stauts", 1); return baseMapper.selectList(queryWrapper); } @Override public void updateTaskStateToZero(long id) { UpdateWrapper updateWrapper = new UpdateWrapper<>(); updateWrapper.set("task_stauts", 0).eq("id", id); baseMapper.update(null, updateWrapper); } @Override public void deleteTask(String id) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(DownGlassTask::getFlowCardId, id); baseMapper.delete(queryWrapper); } @Override public DownGlassTask selectLastOutCacheInfo(String endCell) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("task_type", "2") .eq("task_status", "2") .eq("end_cell", endCell) .last("LIMIT 1"); return baseMapper.selectOne(queryWrapper); } @Override public Integer insertCacheTask(DownGlassTask downGlassTask) { DownGlassTask glassInfo = new DownGlassTask(); glassInfo.setId(downGlassTask.getId()); glassInfo.setStartCell(downGlassTask.getStartCell()); glassInfo.setEndCell(downGlassTask.getEndCell()); glassInfo.setTaskType(downGlassTask.getTaskType()); glassInfo.setWidth(downGlassTask.getWidth()); glassInfo.setHeight(downGlassTask.getHeight()); glassInfo.setFilmsid(downGlassTask.getFilmsid()); glassInfo.setThickness(downGlassTask.getThickness()); glassInfo.setFlowCardId(downGlassTask.getFlowCardId()); glassInfo.setTaskStauts(0); // 默认任务状态为0 int rows = baseMapper.insert(glassInfo); return rows > 0 ? rows : null; } }