inventory/modules/api/item.py

import  mysql.connector         as      mariadb

from    config                  import  database
from	scripts			import	loggorilla

class item:

    def __init__(self):
        self.db_main	= mariadb.connect(**database.db_main)
        self.cursor	= self.db_main.cursor(dictionary=True)

    def list(self, params):
        APIADDR         = "/api/invlab/item/list"
        response        = {}
        self.cursor.execute("BEGIN;")
        try:
            ls = []
            self.cursor.execute("SELECT * FROM `item`;")
            l1 = self.cursor.fetchall()
            c1 = 0
            for d1 in l1:
                ls.append({
                    "sku"	:d1["sku"	],
                    "name"	:d1["name"	],
                    "price"	:{
                        "buy":[],
                        "sell":[]
                    }
                })
                self.cursor.execute("SELECT `id`, `currency`, `value`, DATE_FORMAT(`periods`, '%Y-%m-%d %H:%i:%S') AS `periods` from item_price WHERE `sku` = %s AND `type`='buy' ORDER BY periods DESC, id DESC; ", ( d1["sku"], ) )
                ls[c1]["price"]["buy" ] = self.cursor.fetchall()
                self.cursor.execute("SELECT `id`, `currency`, `value`, DATE_FORMAT(`periods`, '%Y-%m-%d %H:%i:%S') AS `periods` from item_price WHERE `sku` = %s AND `type`='sell' ORDER BY periods DESC, id DESC; ", ( d1["sku"], ) )
                ls[c1]["price"]["sell"] = self.cursor.fetchall()
                c1+=1
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"   ] = "success"
            response["desc"     ] = "data collected"
            response["data"     ] = ls
        except Exception as e:
            self.cursor.execute("ROLLBACK;")
            loggorilla.error(APIADDR, str(e) )
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"	] = "failed"
            response["desc"	] = "Internal Server Error. Please contact us if you still have an error."
        finally:
            self.cursor.execute("COMMIT;")
            self.cursor.close()
            self.db_main.close()
        return response

    def detail(self, params):
        APIADDR         = "/api/invlab/item/detail"
        response        = {}
        loggorilla.prcss(APIADDR, "Define parameters")
        sku		= params["sku"]
        self.cursor.execute("BEGIN;")
        try:
            self.cursor.execute("SELECT * FROM `item` WHERE `sku` = %s ;", ( sku, ) )
            r = self.cursor.fetchone()
            data = {
                "sku"	:r["sku"	],
                "name"	:r["name"	],
                "price"	:{
                    "buy":[],
                    "sell":[]
                }
            }
            self.cursor.execute("SELECT `id`, `currency`, `value`, DATE_FORMAT(`periods`, '%Y-%m-%d %H:%i:%S') AS `periods` from item_price WHERE `sku` = %s AND `type`='buy' ORDER BY periods DESC, id DESC; ", ( sku, ) )
            data["price"]["buy" ] = self.cursor.fetchall()
            self.cursor.execute("SELECT `id`, `currency`, `value`, DATE_FORMAT(`periods`, '%Y-%m-%d %H:%i:%S') AS `periods` from item_price WHERE `sku` = %s AND `type`='sell' ORDER BY periods DESC, id DESC; ", ( sku, ) )
            data["price"]["sell"] = self.cursor.fetchall()
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"   ] = "success"
            response["desc"     ] = "data collected"
            response["data"     ] = data
        except Exception as e:
            self.cursor.execute("ROLLBACK;")
            loggorilla.error(APIADDR, str(e) )
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"	] = "failed"
            response["desc"	] = "Internal Server Error. Please contact us if you still have an error."
        finally:
            self.cursor.execute("COMMIT;")
            self.cursor.close()
            self.db_main.close()
        return response

    def add(self, params):
        APIADDR         = "/api/invlab/item/add"
        response        = {}
        loggorilla.prcss(APIADDR, "Define parameters")
        sku		= params["sku"	]
        name            = params["name"	]
        self.cursor.execute("BEGIN;")
        try:
            loggorilla.prcss(APIADDR, "Inserting")
            self.cursor.execute("INSERT INTO `item` VALUES (%s, %s) ;", (sku, name) )
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"   ] = "success"
            response["desc"     ] = "data added"
        except Exception as e:
            self.cursor.execute("ROLLBACK;")
            loggorilla.error(APIADDR, str(e) )
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"	] = "failed"
            response["desc"	] = "Internal Server Error. Please contact us if you still have an error."
        finally:
            self.cursor.execute("COMMIT;")
            self.cursor.close()
            self.db_main.close()
        return response

    def edit(self, params):
        APIADDR		= "/api/invlab/item/edit"
        response	= {}
        loggorilla.prcss(APIADDR, "Define parameters")
        key		= params["sku"	]
        name            = params["name"	]
        self.cursor.execute("BEGIN;")
        try:
            loggorilla.prcss(APIADDR, "Updating")
            self.cursor.execute("UPDATE `item` SET `name` = %s WHERE `sku` = %s ;", (name, key) )
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"   ] = "success"
            response["desc"     ] = "data change"
        except Exception as e:
            self.cursor.execute("ROLLBACK;")
            loggorilla.error(APIADDR, str(e) )
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"	] = "failed"
            response["desc"	] = "Internal Server Error. Please contact us if you still have an error."
        finally:
            self.cursor.execute("COMMIT;")
            self.cursor.close()
            self.db_main.close()
        return response

    def remove(self, params):
        APIADDR		= "/api/invlab/item/remove"
        response	= {}
        loggorilla.prcss(APIADDR, "Define parameters")
        key		= params["sku"	]
        self.cursor.execute("BEGIN;")
        try:
            loggorilla.prcss(APIADDR, "Deleting")
            self.cursor.execute("DELETE FROM `item` WHERE `sku` = %s ;", (key,) )
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"	] = "success"
            response["desc"	] = "data removed"
        except Exception as e:
            self.cursor.execute("ROLLBACK;")
            loggorilla.error(APIADDR, str(e) )
            loggorilla.prcss(APIADDR, "Giving response")
            response["status"	] = "failed"
            response["desc"	] = "Internal Server Error. Please contact us if you still have an error."
        finally:
            self.cursor.execute("COMMIT;")
            self.cursor.close()
            self.db_main.close()
        return response