#!/bin/sh-e
#
#rc.local
#
#This script is executed at the end of each multiuser runlevel.
#Make sure that the script will “exit o” on success or any other
#value on error.
#
#In order to enable or disable this script just change the execution
#bits.
#
#By default this script does nothing.
#Print the IP address
_IP=$(hostname-I)||true
if{“$_IP”}; them
printf “My IP address is %sn””$_IP”
fi
#ADD line:
exit o

‘/home/pi/Start.sh/’

sudo modprobe bcm2835-v4l2
uv4l –driver raspicam –auto-video_nr –nopreview
LD_PRELOAD=/usr/lib/uv4l/uv4lext/armv6l/libuv4lext.so
motion -c ./ motion.conf

python /home/pi/Adafruit-Raspberry-Pi-Python-Code/Adafruit_LSM303/ Adafruit_LSM303.py &
python /home/pi/Adafruit-Raspberry-Pi-Python-Code/Adafruit_LSM303/ TSL2561.py &
java -jar FTP.jar &

from Adafruit_I2C import Adafruit_I2C
import math
import time
import RPi.GPIO as GPIO
import commands
import datetime
originX = 1000
originY = 1000
originZ = 1000

class Adafruit_LSM303(Adafruit_I2C):
LSM303_ADDRESS_ACCEL = (0×32 >> 1) # 0011001x # Default Type
LSM303_REGISTER_ACCEL_CTRL_REG1_A = 0×20 # 00000111 rw LSM303_REGISTER_ACCEL_CTRL_REG4_A = 0×23 # 00000000 rw LSM303_REGISTER_ACCEL_OUT_X_L_A = 0×28

def __init__(self, busnum=-1, debug=False, hires=False):
self.accel = Adafruit_I2C(self.LSM303_ADDRESS_ACCEL, busnum, debug)
self.accel.write8(self.LSM303_REGISTER_ACCEL_CTRL_REG1_A, 0×27)
if hires:
self.accel.write8(self.LSM303_REGISTER_ACCEL_CTRL_REG4_A,
0b00001000)
else:
self.accel.write8(self.LSM303_REGISTER_ACCEL_CTRL_REG4_A, 0) def accel12(self, list, idx):
n = list[idx] | (list[idx+1] << 8) # Low, high bytes
if n > 32767: n -= 65536 # 2’s complement signed
return n >> 4 # 12-bit resolution

def read(self):
list = self.accel.readList(
self.LSM303_REGISTER_ACCEL_OUT_X_L_A | 0×80, 6)
xyz = [self.accel12(list,0),
self.accel12(list,2),
self.accel12(list,4)] x = xyz[0] y = xyz[1] z = xyz[2] angles = [x,y,z] if x != 0 : angles[0] = math.atan( x / math.sqrt( math.pow(y,2) + math.pow(z,2) ) )
else :
angles[0] = 0
if y != 0 :
angles[1] = math.atan( y / math.sqrt( math.pow(x,2) + math.pow(z,2) ) )
else :
angles[1] = 0
if z != 0 :
angles[2] = math.atan( math.sqrt( math.pow(x,2) + math.pow(y,2) )/z )
else :
angles[2] = 0
angles[0] *= 180
angles[0] /= 3.141592
angles[1] *= 180
angles[1] /= 3.141592
angles[2] *= 180
angles[2] /= 3.141592
angles[0] = int(angles[0])
angles[1] = int(angles[1])
angles[2] = int(angles[2])
global originX
global originY
global originZ
if(originX != 1000 or originY != 1000 or originZ != 1000):
#if(angles[0] >= originX+10 or angles[0] <= originX-10) or (angles[1] >= originY+10 or angles[1] <= originY-10) or (angles[2] >= originZ+10 or angles[2] <= originZ-10):
if(angles[1] >= originY+10 or angles[1] <= originY-10):
print “alarm”
output = commands.getstatusoutput(“aplay /home/pi/PipeWarp.wav”)
GPIO.setmode(GPIO.BCM)
GPIO.setup(23 , GPIO.IN)
if GPIO.input(23)==0:
print “Button pressed!”
time.sleep(1)
print “Press the button (CTRL-C to exit)”
originX = angles[0] originY = angles[1] originZ = angles[2] print (“setup”, originX, originY, originZ)
return angles
if __name__ == ‘__main__’:
from time import sleep
s = datetime.datetime.now()
lsm = Adafruit_LSM303()
count = 1
time_count =1
print ‘[(Accelerometer X, Y, Z)]’
while True:
an = lsm.read()
print an
if(time_count < 30) :
f = open(“/home/pi/accelData”+str(count)+”.txt”, “a”)
f.write(str(lsm.read())+”\n”)
if(time_count > 30) :
count += 1
time_count = 1

sleep(1)
time_count += 1

#!/usr/bin/python
import sys
import time from Adafruit_I2C
import Adafruit_I2C
import os class TSL2561:
i2c = None
def __init__(self, address=0×39, debug=0, pause=0.8):
self.i2c = Adafruit_I2C(address)
self.address = address
self.pause = pause
self.debug = debug
self.gain = 0 # no gain preselected
self.i2c.write8(0×80, 0×03) # enable the device
def setGain(self,gain=1):
“”” Set the gain “””
if (gain != self.gain):
if (gain==1):
self.i2c.write8(0×81, 0×02) # set gain = 1X and timing = 402 mSec
if (self.debug):
print “Setting low gain”
else:
self.i2c.write8(0×81, 0×12) # set gain = 16X and timing = 402 mSec
if (self.debug):
print “Setting high gain”
self.gain=gain; # safe gain for calculation
time.sleep(self.pause) # pause for integration (self.pause must be bigger than integration time)
def readWord(self, reg):
“””Reads a word from the I2C device”””
try:
wordval = self.i2c.readU16(reg)
newval = self.i2c.reverseByteOrder(wordval)
if (self.debug):
print(“I2C: Device 0x%02X returned 0x%04X from reg 0x%02X” % (self.address, wordval & 0xFFFF, reg))
return newval
except IOError:
print(“Error accessing 0x%02X: Check your I2C address” % self.address)
return -1
def readFull(self, reg=0x8C):
“””Reads visible+IR diode from the I2C device”””
return self.readWord(reg);
def readIR(self, reg=0x8E):
“””Reads IR only diode from the I2C device”””
return self.readWord(reg);
def readLux(self, gain = 0):
“””Grabs a lux reading either with autoranging (gain=0) or with a specified gain (1, 16)”””
if (gain == 1 or gain == 16):
self.setGain(gain) # low/highGain
ambient = self.readFull()
IR = self.readIR()
elif (gain==0): # auto gain
self.setGain(16) # first try highGain
ambient = self.readFull()
if (ambient < 65535):
IR = self.readIR()
if (ambient >= 65535 or IR >= 65535): # value(s) exeed(s) datarange
self.setGain(1) # set lowGain
ambient = self.readFull()
IR = self.readIR()
if (self.gain==1):
ambient *= 16 # scale 1x to 16x
IR *= 16 # scale 1x to 16x
ratio = (IR / float(ambient)) # changed to make it run under python 2
if (self.debug):
print “IR Result”, IR
print “Ambient Result”, ambient
if ((ratio >= 0) & (ratio <= 0.52)):
lux = (0.0315 * ambient) – (0.0593 * ambient * (ratio**1.4))
elif (ratio <= 0.65):
lux = (0.0229 * ambient) – (0.0291 * IR)
elif (ratio <= 0.80):
lux = (0.0157 * ambient) – (0.018 * IR)
elif (ratio <= 1.3):
lux = (0.00338 * ambient) – (0.0026 * IR)
elif (ratio > 1.3):
lux = 0
return lux
if __name__ == “__main__”:
count = 1
time_count = 1
while True:
tsl=TSL2561()
print tsl.readLux(1)
f = open(“/home/pi/lightData”+str(count)+”.txt”,”a”)
if(time_count < 30) :
f.write(str(tsl.readLux(1))+”\n”)
if(time_count > 30) :
count += 1
time_count = 1
time.sleep(1)
time_count += 1

import org.apache.commons.net.ftp.*;
import java.io.*;
public class FTP {
FTPClient client = new FTPClient();
Thread th;
Thread th2;
Thread th3;
public FTP() throws IOException{
th3 = new Thread(execMnM);
try{
client.connect(“server address”);
boolean login = client.login(“Login ID”,”Password”);
if(login){
System.out.println(“Login Success.”);
try{
client.changeWorkingDirectory(“Working Directory”);
System.out.println(client.printWorkingDirectory());
}catch(Exception se){
se.printStackTrace();
}
th3.start();
}else{
System.out.println(“Login fail…”);
}
while(true){
FileInputStream fis;
File file = new File(“./”);
String[] a = file.list();
client.setFileTransferMode(1);
for(int i = 0; i < a.length; i++){
if(a[i].contains(“.txt”)){
Thread.sleep(500);
if(new File(“./”+a[i]).length() > 620){
fis = new FileInputStream(a[i]);
client.setFileType(FTPClient.BINARY_FILE_TYPE);
boolean isuploaded = client.storeFile(a[i], fis);
System.out.println(a[i]+”’s upload complete? : “+isuploaded);
File up = new File(a[i]);
up.delete();
}
}
if(a[i].contains(“.jpg”)){
Thread.sleep(500);
fis = new FileInputStream(a[i]);
client.setFileType(FTPClient.BINARY_FILE_TYPE);
boolean isuploaded = client.storeFile(a[i], fis);
System.out.println(a[i]+”’s upload complete? : “+isuploaded);
File up = new File(a[i]);
up.delete();
}
}
}
}catch(Exception e){
e.printStackTrace();
}finally{
try{
client.disconnect();
}catch(Exception e){
e.printStackTrace();
}
}
} Runnable execMnM = new Runnable(){
public void run(){
try{ Runtime.getRuntime().exec(“./Motion.sh”); }catch(Exception e){}
while(true){
try{ Runtime.getRuntime().exec(“./Mic.sh”); }catch(Exception e){}
}
}
};
public static void main(String[] ar)throws IOException{
new FTP();
}
}

#include<Servo.h>

Servo myservo1; //모터1(수도꼭지)
Servo myservo2; //모터2(배출구)
unsigned char Re_buf[11], counter=0;
unsigned char sign = 0;
float T0=0, TA=0,

int switch1Pin = 2; //로커스위치에 대한 변수(ON)
int switch2Pin = 4; //로커스위치에 대한 변수(OFF)
int ledPin = 13; //적색 LED(스위치 ON/OFF 표시)
int ledOn = 12; //녹색 LED(수도꼭지 ON/OFF 표시)
int ledVel = 0;

void setup(){
Serial.begin(115200);
delay(1);
Serial.write(0xA5);
Serial.write(0×45);
Serial.write(0xEA);
myservo1.attach(8);
myservo2.attach(7);

pinMode(AO, INPUT); //수위센서2
pinMode(48, INPUT); //수위센서1
pinMode(switch1Pin, INPUT);
pinMode(switch2Pin, INPUT);
pinMode(ledPin, OUTPUT);
pinMode(ledOn, OUTPUT);

}

void loop() {
unsigned char i=0, sum = 0;
int level2 = analogRead(A0);
int level1 = digitalRead(48);

if(sign) {
sign = 0;
for(i=0; i < 8; 1++)
sum += Re_buf[i];

if(sum == Re_buf[i]) {
TO = (float)(Re_buf[4]<< 8 | Re_buf[5] / 100;

Serial.print(“temp:”);//시리얼 모니터에 온도값 출력
Serial.println(TO);
Serial.print(“level1:”)//시리얼 모니터에 수위센서1값 출력
Serial.println(leven1);
Serial.print(“level2:”);//시리얼 모니터에 수위센서2값 출력
Serial.println(leven2);
delay(1000);
}

if(degitalRead(switch2Pin) == HIGH) {//스위치를 켰을때)
digitalWrite(ledPin, High);//적색 LED켜짐
myservo2.write(0); 배출구 닫힘
if(level1 == HIGH) {//물이 차지 않았을때
digitalWrite(ledOn, HIGH); //물 받기 시작
ledVel = 1;
myservo2.write(0);
if (T0 >= 50) {
myservo1/ write(120); // 온도가 50도 이상일때 가장 차가운 물이 나옴
}
else if (TO < 50 & TO > 40) {
myservo1.write(75);//온도가 40~50도 일때 차가운 물이 나옴
}
else if (TO <= 40& TO > 38){
myservo1.write(45);// 온도가 38~40도 일때 적당한 온도의 물이 나옴
}
else if (TO <= 38 & TO > 25) {
myservo1.write(15);//온도가 25~38도 일때 따뜻한 물이 나옴
}
else {
myservo1.write(0);//온도가 25도 이하일때 가장 따뜻한 물이 나옴
}
}
//1
if((level1 == LOW)&TO < 40 & TO > 38 & level2==0) {//적정한 온도로 물이 다 찼을때
digitalWrite(ledOn, LOW);// 수도꼭지가 꺼짐
myservo2/write(0);
ledVel = 0;
}//2
if(level2 > 0) {//사람이 들어왔을때
if((TO < 35) & ledVel == 0) {//물의 온도가 35도 이하가 되면
myservo2.write(90);//배출구 열리고 물이 빠짐
}
if(level1 == HIGH{//일정량의 물이 빠졌을때
myservo2.write(0);//배출구 닫힘
digitalWrite(ledOn, HIGH); 수도꼭지가 켜짐
ledVEL = 1;
}
if ((level1==LOW) & ledVel ==1) {//물을 다시 받을때
myservo2.write(0);
digitalWrite(ledOn, HIGH);
ledVel = 1;
if (TO >= 50) {
myservo1.write(120);
}
else if (TO < 50 & TO > 40) {
myservo1.write(75);
}
else if(TO <= 40 & TO >38) {
myservo1/write(45)
}
else if (TO <= & TO > 25) {
myservo1.write(15);
}
else{
myservo1.write(0);
}
}
if(level2>300) {//적정 온도로 물이 다시 받아지면
digitalWrite(ledOn, LOW);//수도꼭지가 꺼짐
ledVel = 0;
myservo2.write(0);
}
}//3
}
else{//스위치가 꺼지면
digitalWrite(ledOn,LOW);
ledVel = 0;
digitalWrite(ledPin,LOW)://적색LED OFF
myservo2.write(90;//배출구가 열려 물이 빠짐
}//4
}
}

void serialEvent(){
while (Serial.available()){
Re_buf[counter]=(unsigned char)Serial.read();
if(counter == 0 && Re_buf[0] ! = 0X5A_ return;
counter++;
if(counter++;
if(counter == 9) {
counter = 0;
sign = 1;
}
}
}