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);
}
}