#

zjj

2024-03-21 18dd3559d3876ed8e97353cfc20d4c77eea5c8b1

 src/main/java/com/zy/asrs/controller/CommandInfoController.java

@@ -1,5 +1,6 @@
package com.zy.asrs.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
@@ -7,12 +8,21 @@
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.DateUtils;
import com.zy.asrs.entity.CommandInfo;
import com.zy.asrs.entity.TaskWrk;
import com.zy.asrs.service.CommandInfoService;
import com.core.annotations.ManagerAuth;
import com.core.common.BaseRes;
import com.core.common.Cools;
import com.core.common.R;
import com.zy.asrs.service.TaskWrkService;
import com.zy.common.web.BaseController;
import com.zy.core.cache.MessageQueue;
import com.zy.core.enums.CommandStatusType;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.Task;
import com.zy.core.model.command.CommandPackage;
import com.zy.core.model.command.CrnCommand;
import com.zy.core.model.protocol.StaProtocol;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@@ -23,6 +33,9 @@

    @Autowired
    private CommandInfoService commandInfoService;

    @Autowired
    private TaskWrkService taskWrkService;

    @RequestMapping(value = "/commandInfo/{id}/auth")
    @ManagerAuth
@@ -40,7 +53,6 @@
        EntityWrapper<CommandInfo> wrapper = new EntityWrapper<>();
        excludeTrash(param);
        convert(param, wrapper);
        wrapper.in("command_status", "1,2");
        if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));}
        return R.ok(commandInfoService.selectPage(new Page<>(curr, limit), wrapper));
    }
@@ -55,7 +67,6 @@
        EntityWrapper<CommandInfo> wrapper = new EntityWrapper<>();
        excludeTrash(param);
        convert(param, wrapper);
        wrapper.in("command_status", "3");
        if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));}
        return R.ok(commandInfoService.selectPage(new Page<>(curr, limit), wrapper));
    }
@@ -136,4 +147,58 @@
        return R.ok();
    }

    @PostMapping(value = "/commandInfo/executeCommand")
    @ManagerAuth
    public R executeCommand(@RequestParam("id") Integer id) {
        CommandInfo commandInfo = commandInfoService.selectById(id);
        if (commandInfo == null) {
            return R.error("指令不存在");
        }

        TaskWrk taskWrk = taskWrkService.selectByWrkNo(commandInfo.getWrkNo());
        if (Cools.isEmpty(taskWrk)){
            return R.error("任务不存在");
        }
        if (taskWrk.getWrkSts() !=3 && taskWrk.getWrkSts() !=12 ){
            return R.error("任务未处于执行状态");
        }

        commandInfo.setCommandStatus(CommandStatusType.EXECUTE.id);//执行状态
        commandInfo.setExecuteTime(new Date());
        if (commandInfoService.updateById(commandInfo)) {
            //将指令进行投递
            CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);
            SlaveType type = SlaveType.findInstance(commandInfo.getDevice());
            if (type == null) {
                return R.error("未知设备");
            }

            switch (type) {
                case Crn:
                    CrnCommand crnCommand = JSON.parseObject(commandPackage.getCommand().toString(), CrnCommand.class);
                    MessageQueue.offer(type, crnCommand.getCrnNo(), new Task(5, crnCommand));
                    break;
                case Devp:
                    StaProtocol staProtocol = JSON.parseObject(commandPackage.getCommand().toString(), StaProtocol.class);
                    MessageQueue.offer(type, staProtocol.getSiteId(), new Task(3, staProtocol));
                    break;
            }
        }
        return R.ok();
    }

    @PostMapping(value = "/commandInfo/completeCommand")
    @ManagerAuth
    public R completeCommand(@RequestParam("id") Integer id) {
        CommandInfo commandInfo = commandInfoService.selectById(id);
        if (commandInfo == null) {
            return R.error("指令不存在");
        }

        commandInfo.setCommandStatus(CommandStatusType.COMPLETE.id);//完成状态
        commandInfo.setCompleteTime(new Date());
        commandInfoService.updateById(commandInfo);
        return R.ok();
    }

}