add transaksi

api.py

@@ -13,6 +13,9 @@ app.config['MYSQL_DATABASE_HOST'] = 'localhost'
 mysql.init_app(app)
 conn = mysql.connect()
 
+
+
+
 #BARANG
 @app.route('/barang', methods = ['POST'])
 def create_barang():
@@ -80,5 +83,69 @@ def delete_barang(id_barang):
 	else:
 		return '0'
 
+
+
+
+
+#TRANSAKSI
+@app.route('/transaksi', methods = ['POST'])
+def create_transaksi():
+	id_barang = request.form.get('id_barang')
+	nomor_resi = request.form.get('nomor_resi')
+	biaya = request.form.get('biaya')
+	tanggal_transaksi = request.form.get('tanggal_transaksi')
+	id_pegawai = request.form.get('id_pegawai')
+	cur = conn.cursor()
+	sql = "INSERT INTO transaksi VALUES (NULL, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)"
+	output = cur.execute(sql, (id_barang, nomor_resi, biaya, tanggal_transaksi, id_pegawai))
+	if (output):
+		return '1'
+	else:
+		return '0'
+	
+@app.route('/transaksi/<id_transaksi>', methods = ['PUT'])
+def update_transaksi(id_transaksi):
+	id_barang = request.form.get('id_barang')
+	nomor_resi = request.form.get('nomor_resi')
+	biaya = request.form.get('biaya')
+	tanggal_transaksi = request.form.get('tanggal_transaksi')
+	id_pegawai = request.form.get('id_pegawai')
+	cur = conn.cursor()
+	sql = "UPDATE transaksi SET id_barang = %s, nomor_resi = %s, biaya = %s, tanggal_transaksi = %s, id_pegawai = %s WHERE id = %s"
+	output = cur.execute(sql, (id_barang, nomor_resi, biaya, tanggal_transaksi, id_pegawai, id_transaksi))
+	if (output):
+		return '1'
+	else:
+		return '0'
+	
+@app.route('/transaksi/<id_transaksi>', methods = ['GET'])
+def read_transaksi(id_transaksi):
+	cur = conn.cursor()
+	sql = "SELECT * FROM transaksi WHERE id = %s"
+	field = ['id', 'id_barang', 'nomor_resi', 'biaya', 'tanggal_transaksi', 'id_pegawai']
+	cur.execute(sql, (id_transaksi))
+	rv = cur.fetchall()
+	output = {}
+	i = 0
+	if (len(rv) < 1):
+		return '{}'
+	for value in rv[0]:
+		output[field[i]] = value
+		i += 1
+	return json.dumps(output)
+	
+@app.route('/transaksi/<id_transaksi>', methods = ['DELETE'])
+def delete_transaksi(id_transaksi):
+	cur = conn.cursor()
+	sql = "DELETE FROM transaksi WHERE id = %s"
+	output = cur.execute(sql, (id_transaksi))
+	if (output):
+		return '1'
+	else:
+		return '0'
+
+
+
+
 if __name__ == '__main__':
 	app.run(debug=True, threaded=True, host="0.0.0.0", port=4004)