applicationcontrol.java

一个基于sensor的中间件

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package Application;

import java.io.*;
import java.net.*;
import java.util.*;
import javax.comm.*;

/**
 *
 * @author Administrator
 */
public class ApplicationControl {
    static Enumeration portList;
    static CommPortIdentifier portId;
    static OutputStream outputStream;
    static OutputStream outputStream2;
    Thread readThread;
    InputStream inputStream;
    static SerialPort serialPort;
    static SerialPort serialPort1;
    static BufferedReader buf;
    static PrintWriter toServer;

    public static void main(String[] args) throws IOException {
//        Ircontrol rcontrol = new Ircontrol();
        Plccontrol pcontrol = new Plccontrol();
        Delay delay = new Delay();
        int maxarrnum = 1;
        String query[];
        query = new String[maxarrnum];
        query[0] = "query♥query q is w:Enterence(?x,w:_IN) and w:Name(?x,w:_cheon);♥comeback";

        int loop = 1;

        portList = CommPortIdentifier.getPortIdentifiers();

        while (portList.hasMoreElements()) {
            portId = (CommPortIdentifier) portList.nextElement();
            if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
                if (portId.getName().equals("COM6")) {
                    Client reader = new Client();
                }
            }
        }

        while (loop == 1) {
            try {
                Socket s = new Socket("localhost", 3000);

                final Reader fromServer = new InputStreamReader(s.getInputStream());

                toServer = new PrintWriter(new OutputStreamWriter(s.getOutputStream()));
                BufferedReader fromUser = new BufferedReader(new InputStreamReader(System.in));
                final PrintWriter toUser = new PrintWriter(new OutputStreamWriter(System.out));
                toUser.println("Connected to " + s.getInetAddress() + ":" + s.getPort());
                toUser.flush();
                UserInput ui = new UserInput(fromServer, toUser);
                ui.start();
                for (int i = 0; i < maxarrnum; i++) {
                    toServer.println(query[i]);
                    System.out.println(query[i]);
                    toServer.flush();
                }

                String line;

                ///가전기기 ID등록///////////////////////////////////////////////////
                // admin.admin - admin 
                // 1.에어컨 - aircon 
                // 2.히터 - heater
                // 3.커튼 - curtain
                // 4.컴퓨터 - computer
                // 5.세탁기 - washingmachine
                // 6.환풍기 - fan
                // 7.가습기 - humidifier
                // 8.tv - tv
                // 9.전등1 - lamp1
                // 10.전등2 - lamp2
                // 11.전등3 - lamp3
                // 12.전등4 - lamp4
                // 13.전등5 - lamp5
                // 14.전등6 - lamp6
                // 15.
                /////////////ui///////////////////////////////////////////////////////////

                /////////////////////////////////////////////////////////////////////////
                //가습기 ir명령문id(id : 7)
                //7.1 : 전원
                //7.2 : 조명
                //7.3 : 자동
                //7.4 : 분무량
                //7.5 : 시간설정
                //7.6 : 가습량조절
                /////////////////////////////////////////////////////////////////////////


                //가전기기 선택유무 판단////////////////////////////////////////////////
                while ((line = fromUser.readLine()) != null) {
                    if (line.equals("admin")) {
                        line = "registration��admin";
                    } else if (line.equals("1")) {
                        line = "registration��aircon";
                    } else if (line.equals("2")) {
                        line = "registration��heater";
                    } else if (line.equals("3")) {
                        line = "registration��curtain";
                    } else if (line.equals("4")) {
                        line = "registration��computer";
                    } else if (line.equals("5")) {
                        line = "registration��washingmachine";
                    } else if (line.equals("6")) {
                        line = "registration��fan";
                    } else if (line.equals("7")) {
                        line = "registration��humidifier";
                    } else if (line.equals("8")) {
                        line = "registration��tv";
                    } else if (line.equals("quit")) {
                        line = "order��quit";
                    } else if (line.equals("7.1")) {
                        line = "humidifier.power";
                        rcontrol.Ircontrol(line, serialPort);
//					delay.time(5000);
//					line = "humidifier.light";
//					rcontrol.Ircontrol(line,serialPort1);
//					line = "order��interorder��humidifier.power";
                        continue;
                    } else if (line.equals("7.2")) {
                        line = "humidifier.light";
                        rcontrol.Ircontrol(line, serialPort1);
//					line = "order��interorder��humidifier.light";
                        continue;
                    } else if (line.equals("7.3")) {
                        line = "humidifier.auto";
                        rcontrol.Ircontrol(line, serialPort);
//					line = "order��interorder��humidifier.auto";
                        continue;
                    } else if (line.equals("7.4")) {
                        line = "humidifier.amount";
                        rcontrol.Ircontrol(line, serialPort);
//					line = "order��interorder��humidifier.amount";
                        continue;
                    } else if (line.equals("7.5")) {
                        line = "humidifier.time";
                        rcontrol.Ircontrol(line, serialPort);
//					line = "order��interorder��humidifier.time";
                        continue;
                    } else if (line.equals("7.6")) {
                        line = "humidifier.spray";
                        rcontrol.Ircontrol(line, serialPort);
//					line = "order��interorder��humidifier.spray";
                        continue;
                    } else if (line.equals("9.1")) {
                        line = "Lamp";
                        pcontrol.LightControl(line, serialPort1);
                        continue;
                    } else if (line.equals("9.2")) {
                        line = "Lamp.TurnOff";
                        pcontrol.LightControl(line, serialPort1);
                        continue;
                    } else if (line.equals("9.3")) {
                        line = "j";
                        pcontrol.Plccontrol(line, serialPort1);
//					line = "order��interorder��humidifier.spray";
                        continue;
                    } else if (line.equals("9.4")) {
                        line = "k";
                        pcontrol.Plccontrol(line, serialPort1);
//					line = "order��interorder��humidifier.spray";
                        continue;
                    } else if (line.equals("9.5")) {
                        line = "l";
                        pcontrol.Plccontrol(line, serialPort1);
//					line = "order��interorder��humidifier.spray";
                        continue;
                    } else if (line.equals("9.6")) {
                        line = "m";
                        pcontrol.Plccontrol(line, serialPort1);
//					line = "order��interorder��humidifier.spray";
                        continue;
                    } else {
                        continue;
                    }
                    toServer.println(line);
                    toServer.flush();
                }

                //EOF�� ������, �����带 �����Ų��.
                ui.stop();

                //���� b��; ��´�.
                s.close();
                toUser.println("connection closed by client.");
                toUser.flush();

            } //if anything goes wring, print an error message
            catch (Exception e) {
                System.err.println(e);
                System.err.println("Usage: java Client <hostname> <port>");
            }


        }
    }
}