[type-c] pythonサービス センサ値、書込み。(MYSQL db)

========================================================
参考の記事
http://kuc-arc-f.com/agri/?product=product-post-3
========================================================

ARDUINO - RasPi で、シリアル通信行い。
マインコン側のセンサ値を。
登録テーブルに、登録判定、登録行います。

#code
https://github.com/kuc-arc-f/python-server-typ-c2


# センサ系処理
クラス:
https://github.com/kuc-arc-f/python-server-typ-c2/blob/master/agri_serial/com_sensor.py

#登録判定
MYSQL側で判定、最後のレコード日付と、現在比較。
既定秒数以上なら、書込み。

	def Is_addSensor(self, mc_id, nSec):
	ret=False
	iCt=0
	clsConst = com_appConst.appConstClass()
	connection = MySQLdb.connect(host=clsConst.mHost, db=clsConst.mDB_NAME, user=clsConst.mUser, passwd=clsConst.mPass, charset="utf8")
	cursor = connection.cursor()
	dic = {"id": 0L, "creat_dt" : ""}
	sSql="select id, DATE_FORMAT(created,'%Y-%m-%d %H:%i:%s') as creat_dt"
	sSql=sSql+" from t_sensors where mc_id ="+mc_id
	sSql=sSql+" ORDER BY created desc limit 1"
	#print( "sSql="+ sSql)
	cursor.execute( sSql )
	result = cursor.fetchall()
	for row in result:
	iCt=iCt+1
	dic["id"] =row[0]
	dic["creat_dt"] =row[1]
	cursor.close()
	if iCt==0:
	return True
	cursor = connection.cursor()
	sSql="SELECT TIMESTAMPDIFF(SECOND, '" +dic["creat_dt"] + "', now()) as sec_num;"
	#print( "sSql="+ sSql)
	cursor.execute( sSql )
	result = cursor.fetchall()
	dfSec=0
	for row in result:
	dfSec =row[0]
	#print("dfSec="+str(dfSec))
	cursor.close()
	connection.close()
	if(dfSec > nSec ):
	return True
	return ret

view raw gistfile1.txt hosted with ❤ by GitHub

#登録
MYSQLに、センサ値など登録。

	def saveSensor(self, getDat, datMc):
	ret=False
	clsConst = com_appConst.appConstClass()
	connection = MySQLdb.connect(host=clsConst.mHost, db=clsConst.mDB_NAME, user=clsConst.mUser, passwd=clsConst.mPass, charset="utf8")
	if(datMc["vnum_1"]==1):
	cursor = connection.cursor()
	sSql=u"INSERT INTO t_sensors (mc_id"
	sSql=sSql+",vnum"
	sSql=sSql+",snum"
	sSql=sSql+",created"
	sSql=sSql+") values ("
	sSql=sSql+getDat["mc_id"]
	sSql=sSql+",1"
	sSql=sSql+","+getDat["snum_1"]
	sSql=sSql+",now() );"
	cursor.execute(sSql)
	connection.commit()
	cursor.close()

view raw gistfile1.txt hosted with ❤ by GitHub

*) 開発者向けのまとめ記事

http://knaka0209.blogspot.jp/2015/04/agri.html