도어락 열기 프로세스 base code

+#-*- coding:utf-8 -*-
+
+import time
+import RPi.GPIO as GPIO
+from multiprocessing import Queue
+import os
+
+PIN = {
+	'Motor_MT_N':17,
+	'Motor_MT_P':4
+}
+
+class Motor:
+	LEFT = 0
+	RIGHT = 1
+
+	def __init__(self):
+		self.pwmN = GPIO.PWM(PIN['Motor_MT_N'], 100)
+		self.pwmP = GPIO.PWM(PIN['Motor_MT_P'], 100)
+		self.pwmN.start(0)
+		self.pwmP.start(0)
+	
+	def rotate(self, direction):
+		if direction == Motor.LEFT:
+			GPIO.output(PIN['Motor_MT_N'], GPIO.HIGH)
+			GPIO.output(PIN['Motor_MT_P'], GPIO.LOW)
+			self.pwmN.ChangeDutyCycle(50)
+		else:
+			GPIO.output(PIN['Motor_MT_N'], GPIO.LOW)
+			GPIO.output(PIN['Motor_MT_P'], GPIO.HIGH)
+			self.pwmP.ChangeDutyCycle(50)
+	
+	def stop(self):
+		self.pwmP.ChangeDutyCycle(0)
+		self.pwmN.ChangeDutyCycle(0)
+
+def RFIDProcess(signalQueue):
+	while True:
+		################## 이곳을 지우고 코드를 작성해주세요 ################
+		# RFID ID가 등록된 기기의 ID인 경우 success에 True를 넣습니다.
+		#
+		# RFID 태그가 된 경우 API에 요청을 보내 (GET /api/device) ID 목록을
+		# 가져온 후 이 목록 안에 태그된 기기의 ID가 있는지 여부를 확인하는 방식으로
+		# 동작하면 될 것 같습니다.
+		#
+		# ID 목록을 미리 받아온 후 비교하도록 하면 ID 목록 업데이트가 안 될 수 있으니
+		# 태그가 된 경우 ID 목록을 받아오도록 해주세요.
+		#
+		# success가 True인 경우 모터가 회전합니다.
+		#
+		# 아래 코드는 테스트를 위한 코드입니다. 아래 코드까지 지우고 작성해주세요.
+		time.sleep(30)
+		success = True
+		##############################################################
+		if success:
+			print("등록된 RFID ID가 확인됨")
+			signalQueue.put("RFID")
+
+def RemoteProcess(signalQueue):
+	while True:
+		################## 이곳을 지우고 코드를 작성해주세요 ################
+		# 원격 잠금해제 요청이 들어온 경우 success에 True를 넣습니다.
+		# 원격 잠금해제 요청은 IPC로 처리합니다.
+		# 지우님과 협업하여 작업해주세요.
+		# 
+		# 제 생각으로는 한 파일에 대해서 (ex ~/IPC.txt) API에서는 write하고
+		# 도어락 프로세스에서는 read하는 방법으로 하면 될 것 같습니다.
+		# 원격 잠금해제 요청이 들어온 경우 API에서 write하도록 하면 되겠죠..?
+		#
+		# success가 True인 경우 모터가 회전합니다.
+		#
+		# 아래 코드는 테스트를 위한 코드입니다. 아래 코드까지 지우고 작성해주세요.
+		time.sleep(13)
+		success = True
+		##############################################################
+		if success:
+			print("원격 잠금해제 요청이 들어옴")
+			signalQueue.put("Remote")
+
+def signalProcess(signalQueue):
+	pid = os.fork()
+	if pid == 0:
+		RFIDProcess(signalQueue)
+	else:
+		RemoteProcess(signalQueue)
+
+def doorProcess(doorQueue):
+	motor = Motor()
+	while True:
+		signal = doorQueue.get()
+		print("{} 신호를 받아 문 열기 동작 수행 시작".format(signal))
+		if signal is not None:
+			print("문 열림")
+			motor.rotate(Motor.LEFT)
+			time.sleep(0.5)
+			motor.stop()
+			time.sleep(5)				# 열린 후 5초 지나면 닫힘
+			print("문 닫힘")
+			motor.rotate(Motor.RIGHT)
+			time.sleep(0.5)
+			motor.stop()
+
+if __name__ == '__main__':
+	try:
+		GPIO.setmode(GPIO.BCM)
+		GPIO.setup(PIN['Motor_MT_N'], GPIO.OUT, initial=GPIO.LOW)
+		GPIO.setup(PIN['Motor_MT_P'], GPIO.OUT, initial=GPIO.LOW)
+		
+		signalQueue = Queue()
+		pid = os.fork()
+		if pid == 0:
+			doorQueue = Queue()
+			pid = os.fork()
+			if pid == 0:
+				while True:
+					signal = signalQueue.get()
+					print("{} 신호가 들어와 전달 준비".format(signal))
+					if signal is not None:
+						doorQueue.put(signal)
+			else:
+				doorProcess(doorQueue)
+		else:
+			signalProcess(signalQueue)
+	except Exception as e:
+		print(e)
+	finally:
+		GPIO.cleanup()
\ No newline at end of file