Objets communiquants et gestion de l'énergie : Différence entre versions

#include <XBee.h>

// Define variables, pins..
int sensorTempPin = 0;
int Temp;
int sensorLightPin = 1;
int Light;

uint8_t values[] = { 0, 0, 0, 0 };
XBee xbee =  XBee();
XBeeResponse response = XBeeResponse();
Rx16Response rx = Rx16Response();
Tx16Request tx = Tx16Request(0x1111, values, sizeof(values));
TxStatusResponse txStatus = TxStatusResponse();

 void setup()
{
   // Initialise xbee / serial
  xbee.begin(9600);
  Serial.begin(9600);
} 

 void loop()
{
   // Read the values on analog pins
  Light = analogRead(sensorLightPin);
  Temp = analogRead(sensorTempPin);

  // Listens on the Xbee protocol for any packet incoming.
  xbee.readPacket();

  if(xbee.getResponse().isAvailable()){
     // Got something
    Serial.print("Got something\n");
     // Break the 10-bits of information retrieved from light
     // and temperature into 2 bytes for each.
    values[0] = Temp >> 8 & 0xff;
    values[1] = Temp & 0xff;
    values[2] = Light >> 8 & 0xff;
    values[3] = Light & 0xff;
    Serial.print(values[0]);
    
     // Sending values to server
    xbee.send(tx);
    
     // After sending a tx request, we expect a status response
     // from the server
     // Wait up to 5 seconds for the status response

    if (xbee.readPacket(5000)) {
       // We got a response!
      Serial.print("We got a response\n");
      
       // It should be a znet tx status
      if (xbee.getResponse().getApiId() == TX_STATUS_RESPONSE) {
        xbee.getResponse().getZBTxStatusResponse(txStatus);
        
         // get the delivery status, the fifth byte
        if (txStatus.getStatus() == SUCCESS){
           // Success! Time to celebrate
          Serial.print("SUCCESS! Time to celebrate\n");
        } else {
          // The remote XBee did not receive our packet. Is it powered on?
         Serial.print("The remote Xbee did not receive our packet\n");
        }
      }
    } else {
      // local XBee did not provide a timely TX Status Response -- should not happen
     Serial.print("Local Xbee did not provide a timely TX Status Response\n");
    }
    
  }
 
  delay(500);
}

public class main {

	public static SQLinker linker;
	public static Xbee xbee;
	
	public static void main(String[] args){
		String address = new String("jdbc:mysql://sitedb.polytech-lille.net/cdelberg?");
		String user = new String("user=cdelberg&password=myLo9ufonese");
		String COM;
		

                // We ask the user on the Communication Port to connect the XBee
		System.out.println("Please enter the Communication port of the Xbee");
		Scanner sc = new Scanner(System.in);
		COM = sc.next();
		System.out.println("COM port changed to: "+COM);
		
                //Creation of the Variables that will be used to connect to the Database and the Xbee
		linker = new SQLinker(address, user);
		linker.FillArdList();	
		xbee = new Xbee(COM);
		
                //Creating the Updates Threads
		W8Thread thread1 = new W8Thread();
		thread1.start();
		UpTestThread thread2 = new UpTestThread();
		thread2.start();
		
                //We now allow the user to enter a command
		String command;
		System.out.println("vous pouvez maintenant lancer une commande si vous le souhaitez");
		System.out.println("tapez help pour plus d'informations");
		boolean exit=false;
		
		while(exit==false){
			command=sc.next();
			
			if(command.equals("help")){
				System.out.println("print => affiche la liste des arduinos");
				System.out.println("exit => ferme le programme");
			}
			if(command.equals("print")){linker.PrintArdList();}
			if(command.equals("exit")){exit=true;}
		
		}
		//if the user ask to stop the program, it will do those final commands
		sc.close();
		thread1.stop();
		thread2.stop();
		xbee.XbeeClosing();	
		//System.out.println("Program finished successfully");
		
	}

} 

public class SQLinker {
 	
	Connection connect;
	Statement stmt;
	PreparedStatement pst;
	ResultSet rs;
	int[] ArdList = new int[10];
	int[][] ArdListMatrix = new int[10][2];
	String[] table = {"Battery", "Light", "Temperature", "Updating"};
	//List of variables used to connect to the database and store some informations
	
	//Constructor, create a connection when called
	public SQLinker(String address, String user){
		
		try{
			Class.forName("com.mysql.jdbc.Driver").newInstance();
		} catch(Exception ex){
			System.out.println("can't register the Driver");
		}
		
		try{
			connect = DriverManager.getConnection(address+user);
			stmt = connect.createStatement();
		} catch(Exception ex){
		    System.out.println("connection issue");
			System.out.println("SQLException: " + ex.getMessage());
		}
		if (connect!= null){
			System.out.println("connected to the database " + address);
		}
		
	}
	//Fill a matrix with the list of Arduinos stored in the database
	public void FillArdList(){
		try{
			rs = stmt.executeQuery("SELECT Arduino FROM Arduinos");
			int i=0;
			int m,c,d,u;
			while(rs.next()){
				ArdList[i] = Integer.parseInt(rs.getString(1));
				m=ArdList[i]/1000;
				c=(ArdList[i]-m*1000)/100;
				d=(ArdList[i]-m*1000-c*100)/10;
				u=(ArdList[i]-m*1000-c*100-d*10);
				ArdListMatrix[i][0]=(m*10+c);
				ArdListMatrix[i][1]=(d*10+u);				
				i++;
			}
			ArdList[i]=-1;
		} catch (SQLException e){
			System.out.println("SQLException: " + e.getMessage());
		    System.out.println("SQLState: " + e.getSQLState());
		    System.out.println("VendorError: " + e.getErrorCode());
		} 
	}
	
	//print the list of arduinos stored in the program
	public void PrintArdList(){
		int i=0;
		while(ArdList[i]!=-1){
			i++;
			System.out.println("Code Arduino n°"+i+": "+ArdList[i]);

		}
	}
	
	//Print the values of a specific arduino
	public void PrintArdValues(int ard){
		for(int i=0; i<=2;i++){
			
			try {
				rs = stmt.executeQuery("SELECT " +table[i]+" FROM Arduinos WHERE Arduino ="+ard);
			} catch (SQLException e) {
				e.printStackTrace();
			}
			try {
				while(rs.next()){
					System.out.println(table[i] +"=" + rs.getString(1));
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}
	}

	//print the values of every arduino stored in the program
	public void PrintAllArdValues(){
		int i=0;
		while(ArdList[i]!=-1){
			this.PrintArdValues(i);
		}
	}
	
	//set the values obtained from an arduino to the database
	public void SetArdValues(int Ard, int[] values){
		int i=0;
		while(values[i]!=-1){
			
			try {
				pst = connect.prepareStatement("UPDATE Arduinos SET "+table[values[i]]+" = "+values[i+1] +"  WHERE Arduino ="+Ard);
				pst.executeUpdate();
			} catch (SQLException e){
				e.printStackTrace();
			}


			i+=2;
		}
	}

	//verify if an update as been demanded by a user on the website
	public int CheckUpdate(){
		int i=0;
		int ret=0;
		while(ArdList[i]!=-1 && ret!=1){
			try {
				rs = stmt.executeQuery("SELECT Updating FROM Arduinos WHERE Arduino ="+ArdList[i]);
				while(rs.next()){
					ret = Integer.parseInt(rs.getString(1));
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
			i++;
		}
		return ret; //return 1 if update demanded
		
	}
}