Sahan

.env

@@ -2,7 +2,7 @@ DB_PORT = 3306
 DB_HOST=elder.cetbof2tejqh.us-west-2.rds.amazonaws.com
 DB_USER=admin
 DB_PASS=vwFB.T{*rBOb
-MYSQL_DB=elder
+MYSQL_DB=eldernew
 APP_PORT=3000
 JSONSALTA=hbn111
-JSONRSALTA=hbn1112
+JSONRSALTA=hbn1112

api/agent/agent.conrollers.js

@@ -1,9 +1,12 @@
 const {
   getAgentByAgentID,
+  getAgentByElderID,
+  getQulifyAgentByElderID,
   getAgent,
   createAgent,
   updateAgent,
   deleteAgent,
+  updateDisqulifyAgent,
 } = require("./agent.services");
 
 const { sign } = require("jsonwebtoken");
@@ -30,6 +33,44 @@ module.exports = {
       });
     });
   },
+  getAgentByElderID: (req, res) => {
+    const elder_id = req.params.elder_id;
+    getAgentByElderID(elder_id, (err, results) => {
+      if (err) {
+        console.log(err);
+        return;
+      }
+      if (!results) {
+        return res.json({
+          success: 0,
+          message: "Record not found",
+        });
+      }
+      return res.json({
+        success: 1,
+        data: results,
+      });
+    });
+  },
+  getQulifyAgentByElderID: (req, res) => {
+    const elder_id = req.auth.result.id;
+    getQulifyAgentByElderID(elder_id, (err, results) => {
+      if (err) {
+        console.log(err);
+        return;
+      }
+      if (!results) {
+        return res.json({
+          success: 0,
+          message: "Record not found",
+        });
+      }
+      return res.json({
+        success: 1,
+        data: results,
+      });
+    });
+  },
   getAgent: (req, res) => {
     // console.log(req.auth);
 
@@ -63,6 +104,7 @@ module.exports = {
   },
   createAgent: (req, res) => {
     const body = req.body;
+    //req.body.elder_id = req.auth.result.id;
     createAgent(body, (err, result) => {
       if (err) {
         console.log(err);
@@ -77,9 +119,98 @@ module.exports = {
       });
     });
   },
-  updateAgent: (req, res) => {
+
+  updateCorrectAgent: (req, res) => {
+    const eid = req.body.elder_id;
+    getAgentByElderID(eid, (err, resultsA) => {
+      if (err) {
+        console.log(err);
+        return;
+      }
+      if (!resultsA) {
+        return res.json({
+          success: 0,
+          message: "Record Not Found",
+        });
+      }
+      if (resultsA.agent_id != req.body.agent_id) {
+        deleteAgent(resultsA, (error, results) => {
+          if (error) {
+            console.log(error);
+            return res.status(500).json({
+              success: 0,
+              message: "database Connection error",
+            });
+          }
+          if (!results) {
+            return res.json({
+              success: 0,
+              message: "Record Not Found",
+            });
+          }
+
+          const body = {
+            added_gramanildari_id: req.auth.result.id,
+            gramaniladari_verify_comment: req.body.gramaniladari_verify_comment,
+            agent_id: req.body.agent_id,
+          };
+          updateAgent(body, (err, results) => {
+            if (err) {
+              console.log(err);
+              return res.status(500).json({
+                success: 0,
+                message: "Database Connection error",
+              });
+            }
+
+            if (!results) {
+              return res.json({
+                success: 0,
+                message: "Record Not Found",
+              });
+            }
+
+            return res.status(200).json({
+              success: 1,
+              message: "Delete and  Updated Succecfully",
+              data: results,
+            });
+          });
+        });
+      } else {
+        const body = {
+          added_gramanildari_id: req.auth.result.id,
+          gramaniladari_verify_comment: req.body.gramaniladari_verify_comment,
+          agent_id: req.body.agent_id,
+        };
+        updateAgent(body, (err, results) => {
+          if (err) {
+            console.log(err);
+            return res.status(500).json({
+              success: 0,
+              message: "Database Connection error",
+            });
+          }
+
+          if (!results) {
+            return res.json({
+              success: 0,
+              message: "Record Not Found",
+            });
+          }
+
+          return res.status(200).json({
+            success: 1,
+            message: "Updated Succecfully",
+            data: results,
+          });
+        });
+      }
+    });
+  },
+  updateDisqulifyAgent: (req, res) => {
     const body = req.body;
-    updateAgent(body, (err, results) => {
+    updateDisqulifyAgent(body, (err, results) => {
       if (err) {
         console.log(err);
         return res.status(500).json({
@@ -102,6 +233,7 @@ module.exports = {
       });
     });
   },
+
   deleteAgent: (req, res) => {
     const body = req.body;
     deleteAgent(body, (error, results) => {

api/agent/agent.routers.js

@@ -1,18 +1,25 @@
 const router = require("express").Router();
 const {
   getAgentByAgentID,
+  getAgentByElderID,
+  getQulifyAgentByElderID,
   getAgent,
   createAgent,
-  updateAgent,
+  updateCorrectAgent,
   deleteAgent,
+  updateDisqulifyAgent
 } = require("./agent.conrollers");
 const { checkToken } = require("../../auth/token_validation");
 
+router.get("/qulify", checkToken, getQulifyAgentByElderID);
+router.get("/elder/:elder_id", checkToken, getAgentByElderID);
+router.get("/aid/:elder_id", checkToken, getAgentByAgentID);
 router.post("/", checkToken, createAgent);
 
 router.get("/", checkToken, getAgent);
-router.get("/:elder_id", checkToken, getAgentByAgentID);
-router.patch("/", checkToken, updateAgent);
+
+router.patch("/disq", checkToken, updateDisqulifyAgent);
+router.patch("/", checkToken, updateCorrectAgent);
 router.delete("/", checkToken, deleteAgent);
 
 module.exports = router;

api/agent/agent.services.js

@@ -2,7 +2,31 @@ const pool = require("../../config/database");
 module.exports = {
   getAgentByAgentID: (elder_id, callBack) => {
     pool.query(
-      "SELECT * FROM `agent` WHERE `agent_id` =?",
+      "SELECT * FROM `agent` WHERE `is_deleted` = '0' AND`agent_id` =?",
+      [elder_id],
+      (error, results, fields) => {
+        if (error) {
+          return callBack(error);
+        }
+        return callBack(null, results[0]);
+      }
+    );
+  },
+  getAgentByElderID: (elder_id, callBack) => {
+    pool.query(
+      "SELECT * FROM `agent` WHERE `elder_id` =? AND `is_deleted` = 0",
+      [elder_id],
+      (error, results, fields) => {
+        if (error) {
+          return callBack(error);
+        }
+        return callBack(null, results[0]);
+      }
+    );
+  },
+  getQulifyAgentByElderID: (elder_id, callBack) => {
+    pool.query(
+      "SELECT * FROM `agent` WHERE `agent_is_avilable`='1' AND `added_gramanildari_id` IS NOT NULL AND `elder_id` =? AND `is_deleted` = 0",
       [elder_id],
       (error, results, fields) => {
         if (error) {
@@ -26,14 +50,15 @@ module.exports = {
   },
   createAgent: (data, callBack) => {
     pool.query(
-      "INSERT INTO `agent`( `elder_id`, `name`, `nic`, `address`, `phone`, `email`,`relation_with_elder`) VALUES (?, ?, ?, ?, ?, ? , ?)",
+      "INSERT INTO `agent`( `elder_id`, `name`, `nic`, `address`, `phone`, `email`,`pic`,`relation_with_elder`) VALUES (?, ?, ?, ?, ?, ? ,?, ?)",
       [
         data.elder_id,
         data.name,
         data.nic,
         data.address,
         data.phone,
         data.email,
+        data.pic,
         data.relation_with_elder,
       ],
       (error, results, fields) => {
@@ -46,15 +71,10 @@ module.exports = {
   },
   updateAgent: (data, callBack) => {
     pool.query(
-      "UPDATE `agent` SET `elder_id`=?,`name`=?,`nic`=?,`address`=?,`phone`=?,`email`=? ,`relation_with_elder`=? WHERE `agent_id`=?",
+      "UPDATE `agent` SET `agent_is_avilable`='1',`added_gramanildari_id`=?, `gramaniladari_verify_comment`=? WHERE `agent_id`=?",
       [
-        data.elder_id,
-        data.name,
-        data.nic,
-        data.address,
-        data.phone,
-        data.email,
-        data.relation_with_elder,
+        data.added_gramanildari_id,
+        data.gramaniladari_verify_comment,
         data.agent_id,
       ],
       (error, results, fields) => {
@@ -65,6 +85,21 @@ module.exports = {
       }
     );
   },
+  updateDisqulifyAgent: (data, callBack) => {
+    pool.query(
+      "UPDATE `agent` SET `agent_is_avilable`='0', `gramaniladari_verify_comment`=? WHERE `agent_id`=?",
+      [
+        data.gramaniladari_verify_comment,
+        data.agent_id
+      ],
+      (error, results, fields) => {
+        if (error) {
+          return callBack(error);
+        }
+        return callBack(null, results);
+      }
+    );
+  },
   deleteAgent: (data, callBack) => {
     pool.query(
       "UPDATE `agent` SET  `is_deleted`='1' WHERE `agent_id`=?",