OP280/src/com/mes/util/WorkTimer.java

package com.mes.util;

import com.mes.ui.MesClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.awt.*;
import java.util.Timer;
import java.util.TimerTask;

public class WorkTimer {
    private static final Logger log = LoggerFactory.getLogger(WorkTimer.class);


    private static Timer stopTimer = null;
    private static Timer workTimer = null;

    private WorkTimer() {
    }

    public static void start() {
        if(workTimer != null){
            workTimer = null;
        }
        workTimer = new Timer();
        workTimer.schedule(new WorkTimerTask(), 1000, 2000);
    }

    public static void stop() {
        if (workTimer != null) {
            workTimer.cancel();
            workTimer = null;
        }
    }

    // 发送禁止运行的定时任务
    private static class StopTimerTask extends TimerTask {
        @Override
        public void run() {
            try {
                if (MesClient.work_status == 0 || !MesClient.check_quality_result) {
                    ATEQ.stop(); // 发送重置命令, 禁止设备启动
                }
            } catch (Exception e) {
                log.error("向设备发送禁止运行的定时任务报错");
            }
        }
    }

    // 工作流程定时任务
    private static class WorkTimerTask extends TimerTask {
        @Override
        public void run() {
            try { //01031a0000 0800 0100 0080 0700 2e180000e02e00000000000038c7000058b2
                // 如果开始工作，则循环查询实时结果
                if (MesClient.work_status == 1) {
                    ATEQ.RealtimeResult realtimeResult = ATEQ.readRealtimeResult();  // 循环查询实时结果
                    log.info(realtimeResult.toString());
                    Boolean isEnd = false;
                    if(realtimeResult.stepCode == 65535){ // 监测结束
                        if(MesClient.mesStartFlag == 1){
                            isEnd = true;
                        }
                    }else{
                        MesClient.mesStartFlag = 1;
                        MesClient.setMenuStatus("当前步骤:["+realtimeResult.stepCode+"]"+realtimeResult.step, 0); // 当前步骤
                    }

                    // 实时更新显示的压力值和泄漏值
                    MesClient.param1.setText(isEnd ? "" : realtimeResult.pressureValue + " " + realtimeResult.pressureUnit);
                    MesClient.param2.setText(isEnd ? "" : realtimeResult.leakValue + " " + realtimeResult.leakUnit);

                    // 如果从实时结果中得到到测试结束,则查询最后结果,并提交结果
                    if (isEnd) {
                        ATEQ.LastResult lastResult = ATEQ.readLastResult();
                        log.info(lastResult.toString());
                        MesClient.param1.setText(lastResult.pressureValue+lastResult.pressureUnit);

                        if(lastResult.leakValue == 0 && !lastResult.isPass){
                            MesClient.param2.setText("9999");
                        }else{
                            MesClient.param2.setText(lastResult.leakValue+lastResult.leakUnit);
                        }

                        String lastRet = lastResult.isPass ? "OK" : "NG";

                        if(lastRet.equals("OK")){
                            MesClient.result.setText("OK");
                            MesClient.result.setForeground(Color.GREEN);
                        }else{
                            MesClient.result.setText("NG");
                            MesClient.result.setForeground(Color.RED);
                        }

                        String testDate = DateLocalUtils.getCurrentTime();

                        TestParam testParam = new TestParam();
                        testParam.setSn(MesClient.product_sn.getText().trim());
                        testParam.setUcode(MesClient.user_menu.getText().trim());
                        testParam.setLineSn(MesClient.getEffectiveLineSn());
                        testParam.setOprno(MesClient.getEffectiveOprno());
                        testParam.setOprnoTitle(MesClient.configParam.getOprnoTitle());
                        testParam.setParam1(lastResult.pressureValue + "");
                        testParam.setParam2(lastResult.pressureUnit);
                        testParam.setParam3(lastResult.leakValue+"");
                        testParam.setParam4(lastResult.leakUnit);
                        testParam.setParam5(MesClient.programNo.getText().trim());
                        testParam.setResult(lastRet);
                        testParam.setDeviceType("ateq");
                        testParam.setRemark("");
                        testParam.setCreateTime(testDate);
                        MesClient.afterTestSaveAndUpload(testParam);
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
                log.error("工作定时任务报错:"+e.getMessage());
            }
        }
    }


}