New file |
| | |
| | | package com.mes.edgstoragetask.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.mes.bigstoragetask.entity.BigStorageCageFeedTask; |
| | | import com.mes.bigstoragetask.mapper.BigStorageCageFeedTaskMapper; |
| | | import com.mes.edgstoragetask.entity.TaskCache; |
| | | import com.mes.edgstoragetask.mapper.TaskCacheMapper; |
| | | import com.mes.edgstoragetask.service.TaskCacheService; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import org.springframework.beans.factory.annotation.Qualifier; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * <p> |
| | | * 服务实现类 |
| | | * </p> |
| | | * |
| | | * @author zhoush |
| | | * @since 2024-04-16 |
| | | */ |
| | | @Qualifier("") |
| | | @Service |
| | | public class TaskCacheServiceImpl extends ServiceImpl<TaskCacheMapper, TaskCache> implements TaskCacheService { |
| | | @Resource |
| | | private BigStorageCageFeedTaskMapper bigStorageCageFeedTaskMapper; |
| | | @Override |
| | | public int judgeTasktype(){ |
| | | //判断根据当前卧转立任务与磨边线任务判断是否启动卧转立 |
| | | // for (int i=1;i<=2;i++){ |
| | | // //查询卧转立当前任务 |
| | | // int width=5000; |
| | | // int num=0; |
| | | // List<BigStorageCageFeedTask> bgStorageCageFeedTask =bigStorageCageFeedTaskMapper.(); |
| | | // //查询磨边线当前任务 |
| | | // LambdaQueryWrapper<TaskCache> taskCacheWrapper=new LambdaQueryWrapper<>(); |
| | | // taskCacheWrapper.eq(TaskCache::getTaskStauts,"0"); |
| | | // List<TaskCache> taskCacheList=taskCacheService.list(taskCacheWrapper); |
| | | // //判断当前线路还需要再上几片才能满足小车宽度 |
| | | // for (TaskCache taskCache:taskCacheList |
| | | // ) { |
| | | // if(taskCache.getId().equals("1")){ |
| | | // //进片车宽度减去小片宽度 |
| | | // } |
| | | // } |
| | | // //片数小于等于2时另一条线卧转立启动 |
| | | // log.info("发送卧转立启动信号"); |
| | | // } |
| | | return 0; |
| | | } |
| | | } |