更新活化

whycxzp

2025-04-14 cafb1288d41201c33b12bdfb979734241bfb296a

更新活化

 src/main/java/com/whyc/controller/AbeStateController.java

New file
@@ -0,0 +1,26 @@
package com.whyc.controller;

import com.whyc.dto.Response;
import com.whyc.service.AbeStateService;
import io.swagger.annotations.Api;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Api(tags = "活化测试状态")
@RestController
@RequestMapping("abeState")
public class AbeStateController {

    @Autowired
    private AbeStateService service;


    @PostMapping("stopHuoHua")
    public Response stopHuoHua(){
        return service.stopHuoHua();
    }


}

 src/main/java/com/whyc/pojo/db_abe_ram/AbeState.java

@@ -65,5 +65,7 @@
    @TableField("comm_totalcount")
    private Integer commTotalCount;

    private Integer opCmd;


}

 src/main/java/com/whyc/service/AbeStateService.java

@@ -1,16 +1,22 @@
package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.whyc.dto.Response;
import com.whyc.mapper.AbeStateMapper;
import com.whyc.pojo.db_abe_ram.AbeState;
import com.whyc.util.ActionUtil;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class AbeStateService {

    public static final int CMD_StopHuoHua_Test                         = 0x20;       //停止活化测试
    public static final int CMD_StopHuoHua_TestAck                     = 0x21;       //停止活化测试成功

    @Resource
    private AbeStateMapper mapper;
@@ -21,4 +27,48 @@
        AbeState abeState = mapper.selectOne(query);
        return new Response<AbeState>().set(1,abeState);
    }

    public Response stopHuoHua() {
        boolean flag = sendCmdToDev(CMD_StopHuoHua_Test);
        return new Response().set(1,flag?1:0,flag?"停止活化测试成功":"停止活化测试失败");
    }

    public boolean sendCmdToDev(int opCmd) {
        int m_cmd = opCmd;
        int m_cmd_ack = opCmd;
        switch(m_cmd) {
            case CMD_StopHuoHua_Test: m_cmd_ack = CMD_StopHuoHua_TestAck; break;
            default:
                return false;
        }
        //更新op_cmd
        UpdateWrapper<AbeState> updateWrapper = Wrappers.update();
        updateWrapper.set("op_cmd",m_cmd);
        int flag=mapper.update((AbeState) ActionUtil.objeNull,updateWrapper);
        boolean res_exe = false;
        if(flag>0)
        {
            QueryWrapper<AbeState> queryWrapper = Wrappers.query();
            queryWrapper.last(" limit 1");
            for(int n=0; n<80; n++)
            {

                AbeState param=mapper.selectOne(queryWrapper);
                if(param!=null){
                    if(param.getOpCmd()==m_cmd_ack){
                        res_exe = true;
                        break;
                    }
                    try {
                        Thread.sleep(250);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }else {
                    break;
                }
            }
        }
        return res_exe;
    }
}