Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes

严智鑫

2024-08-01 903adb90f70518fce4bc22d69008c3eee30e4f89

 hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/storagetask/service/impl/StorageTaskServiceImpl.java

@@ -3,6 +3,14 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import com.mes.loadposition.entity.LoadPosition;

import com.mes.loadposition.mapper.LoadPositionMapper;

import com.mes.rawusage.entity.RawUsage;

import com.mes.rawusage.mapper.RawUsageMapper;

import com.mes.shelfrack.entity.ShelfRack;

import com.mes.shelfrack.entity.request.RawUsageAndShelfRack;

import com.mes.shelfrack.mapper.ShelfRackMapper;

import com.mes.storagetask.entity.request.StorageTaskRequest;

import com.mes.storagetask.mapper.StorageTaskMapper;

import com.mes.storagetask.entity.StorageTask;

import com.mes.storagetask.service.StorageTaskService;

@@ -25,6 +33,13 @@


    @Autowired

    private StorageTaskMapper storageTaskMapper;

    @Autowired

    private LoadPositionMapper loadPositionMapper;

    @Autowired

    private ShelfRackMapper shelfRackMapper;

    @Autowired

    private RawUsageMapper rawUsageMapper;





    @Override

    public List<StorageTask> findList(StorageTask params){

@@ -56,12 +71,97 @@




    @Override

    public  List<Map<String, Object>> Tasks() {

    public   List<StorageTaskRequest>  Tasks() {

        return baseMapper.selectTasks();

    }







    @Override

    public void taskUpdate(StorageTask request) {

        Integer taskId = request.getId();

        String taskType = request.getTaskType();

        String Type = request.getType();

        String taskState = request.getTaskState();

        String shelfRack = request.getShelfRack();

        String loadRack = request.getLoadRack();



        if ("重新开始".equals(Type)) {

            StorageTask storageTask = new StorageTask();

            storageTask.setTaskState("等待中");

            LambdaQueryWrapper<StorageTask> queryWrapper = Wrappers.lambdaQuery(StorageTask.class)

                    .eq(StorageTask::getId, request.getId());

            storageTaskMapper.update(request,queryWrapper);

        } else if ("完成".equals(Type)) {

            StorageTask existingTask = storageTaskMapper.selectById(taskId);

            if (existingTask != null && "正在工作".equals(existingTask.getTaskState())) {

                if ("从仓位到上片位".equals(taskType) || "从仓位到吊装位".equals(taskType)) {

                    LoadPosition loadPosition = new LoadPosition();

                    loadPosition.setState("正在使用");

                    loadPosition.setStorageTaskId(request.getId());

                    LambdaQueryWrapper<LoadPosition> queryWrapper = Wrappers.lambdaQuery(LoadPosition.class)

                            .eq(LoadPosition::getNumber, request.getLoadRack());

                    loadPositionMapper.update(loadPosition, queryWrapper);

                    StorageTask storageTask = new StorageTask();

                    storageTask.setTaskState("正在使用");

                    LambdaQueryWrapper<StorageTask> StorageTaskqueryWrapper = Wrappers.lambdaQuery(StorageTask.class)

                            .eq(StorageTask::getId, request.getId());

                    storageTaskMapper.update(request,StorageTaskqueryWrapper);

                } else if ("从上片位到仓位".equals(taskType)) {

                    LoadPosition loadPosition = new LoadPosition();

                    loadPosition.setState("使用中");

                    loadPosition.setStorageTaskId(null);

                    LambdaQueryWrapper<LoadPosition> queryWrapper = Wrappers.lambdaQuery(LoadPosition.class)

                            .eq(LoadPosition::getNumber, request.getLoadRack());

                    loadPositionMapper.update(loadPosition, queryWrapper);

                    ShelfRack loshelfRack = new ShelfRack();

                    LambdaQueryWrapper<RawUsage> RawUsagequeryWrapper = Wrappers.lambdaQuery(RawUsage.class)

                            .eq(RawUsage::getId,loshelfRack.getRawPackageId());

                    RawUsage RawUsage = rawUsageMapper.selectOne(RawUsagequeryWrapper);

                    if(RawUsage.getLeftPieces()==0){

                        loshelfRack.setState("空闲");

                    }else {

                        loshelfRack.setState("使用中");

                    }

                    LambdaQueryWrapper<ShelfRack> loshelfRackqueryWrapper = Wrappers.lambdaQuery(ShelfRack.class)

                            .eq(ShelfRack::getNumber, request.getLoadRack());

                    shelfRackMapper.update(loshelfRack, loshelfRackqueryWrapper);

                } else if ("从吊装位到仓位".equals(taskType)) {

                    LoadPosition loadPosition = new LoadPosition();

                    loadPosition.setState("空闲");

                    loadPosition.setStorageTaskId(null);

                    LambdaQueryWrapper<LoadPosition> queryWrapper = Wrappers.lambdaQuery(LoadPosition.class)

                            .eq(LoadPosition::getNumber, request.getLoadRack());

                    loadPositionMapper.update(loadPosition, queryWrapper);

                    ShelfRack loshelfRack = new ShelfRack();

                    LambdaQueryWrapper<RawUsage> RawUsagequeryWrapper = Wrappers.lambdaQuery(RawUsage.class)

                            .eq(RawUsage::getId,loshelfRack.getRawPackageId());

                    RawUsage RawUsage = rawUsageMapper.selectOne(RawUsagequeryWrapper);

                    if(RawUsage.getLeftPieces()==1){

                        loshelfRack.setEnableState("启用");

                    }else {

                        loshelfRack.setEnableState(loshelfRack.getEnableState());

                    }

                    loadPosition.setState("使用中");

                    LambdaQueryWrapper<ShelfRack> loshelfRackqueryWrapper = Wrappers.lambdaQuery(ShelfRack.class)

                            .eq(ShelfRack::getNumber, request.getLoadRack());

                    shelfRackMapper.update(loshelfRack, loshelfRackqueryWrapper);

                }

                StorageTask storageTask = new StorageTask();

                storageTask.setTaskState("已完成");

                LambdaQueryWrapper<StorageTask> StorageTaskqueryWrapper = Wrappers.lambdaQuery(StorageTask.class)

                        .eq(StorageTask::getId, request.getId());

                storageTaskMapper.update(storageTask, StorageTaskqueryWrapper);

            }

        } else if ("删除".equals(Type)) {



            LambdaQueryWrapper<StorageTask> StorageTaskqueryWrapper = Wrappers.lambdaQuery(StorageTask.class)

                    .eq(StorageTask::getId, request.getId());

            storageTaskMapper.delete(StorageTaskqueryWrapper);

        }

    }









}