add

conf/application.conf

+[SERVICE]
+port=2747
+host=0.0.0.0
+version_no=1.0.0
+workers=1
+module_name=$APP_NAME
+enable_traceback = True
+secure_cookie=$SECURE_COOKIE
+
+[MONGO_DB]
+uri= "mongodb://192.168.0.220:2747/"
+

scripts/config/__init__.py

+from configparser import ConfigParser
+
+config = ConfigParser()
+config.read(f"config/application.conf")
+
+class Configconstant:
+    temp = config.get("SERVICE", "port")
+    sn=config.get("MONGO_DB","url")
\ No newline at end of file

scripts/core/handler/task1.py

+import pymongo
+import pandas as pd
+from pydantic import BaseModel
+
+myclient = pymongo.MongoClient("mongodb://192.168.0.220:2747/")
+mydb = myclient["factory"]
+mycol = mydb["status"]
+mycol.find()
+
+class Employee_details(BaseModel):
+
+    id: str
+    certificate_number: int
+    business_name: str
+    date: str
+    result: str
+    sector: str
+    address: dict
+# #
+
+dblist = myclient.list_database_names()
+if "factory" in dblist:
+    print("The database exists.")
+
+
+
+class Task1:
+
+    def read_violation(self):
+        agg = list(mycol.aggregate(
+            [
+                {
+                    '$project': {
+                        '_id': '$business_name',
+                        'result': 'Violation Issued'
+                    }
+                }, {
+                '$group': {
+                    '_id': '$_id',
+                    'heghest': {
+                        '$max': '$result'
+                    }
+                }
+            }, {
+                '$sort': {
+                    'highest': -1
+                }
+            }
+            ]))
+        return (agg[0])
+
+
+    def read_noviolation(self):
+        r = mycol.find({"result": "No Violation Issued"})
+        lst = []
+        for i in r:
+            lst.append(i["business_name"])
+        return lst
+
+
+
+
+
+
+
+
+    # class Employee_details(BaseModel):
+    # )
+    #     id: str
+    #     certificate_number: int
+    #     business_name: str
+    #     date: str
+    #     result: str
+    #     sector: str
+    #     address: dict
+
+
+
+    def Fnd(self):
+        q = mycol.find({})
+        if q:
+            a = []
+            for i in q:
+                d = {'Business Name': i['business_name'], 'Date': i["date"], 'Result': i["result"]}
+                a.append(d)
+            a = pd.DataFrame(a)
+            return (a.to_excel("incpection.xlsx", sheet_name="mySheet", index=False))
+        else:
+            return "no data"
+
+
+
+
+
+
+    def Insert(user):
+        mycol.insert_one(user.dict())
+        return "Inserted"
+
+    def check_result(business_name, record_type):
+        x = business_name
+        y = record_type
+        cnt = mycol.count_documents({'$and':[{'business_name':x},{'result':y}]})
+        return str(cnt) +" " +str( y)
\ No newline at end of file

scripts/services/task1.py

+from fastapi import APIRouter
+from scripts.core.handler.task1 import Task1
+report_router= APIRouter()
+@report_router.get("/getdata1")
+def most_violation():
+    return Task1().read_violation()
+
+@report_router.get("/getdata2")
+def no_violation():
+    return Task1().read_noviolation()
+
+@report_router.get('/getdata')
+def get_data():
+    return Task1().Fnd()
+
+@report_router.get('/getDetails')
+def checkdata(business_name ,record_type):
+    return Task1().check_result(business_name ,record_type)
\ No newline at end of file