fixes

.gitignore

@@ -43,4 +43,11 @@ bin/
 application.yaml
 initial-data.sql
 app.yaml
-*.env.json
+*.env.json
+
+### API Logs ###
+api.log
+api.2024*
+
+### Excel FIles ###
+./excel

.idea/dataSources.xml

@@ -6,6 +6,24 @@
       <synchronize>true</synchronize>
       <jdbc-driver>org.postgresql.Driver</jdbc-driver>
       <jdbc-url>jdbc:postgresql://192.168.64.6:5432/uiapp</jdbc-url>
+      <jdbc-additional-properties>
+        <property name="com.intellij.clouds.kubernetes.db.host.port" />
+        <property name="com.intellij.clouds.kubernetes.db.enabled" value="false" />
+        <property name="com.intellij.clouds.kubernetes.db.resource.type" value="Deployment" />
+        <property name="com.intellij.clouds.kubernetes.db.container.port" />
+      </jdbc-additional-properties>
+      <working-dir>$ProjectFileDir$</working-dir>
+    </data-source>
+    <data-source source="LOCAL" name="arsalan_rmc_module_app@10.10.10.211" uuid="572880af-561c-4a5a-90bd-e024c09c674b">
+      <driver-ref>postgresql</driver-ref>
+      <synchronize>true</synchronize>
+      <jdbc-driver>org.postgresql.Driver</jdbc-driver>
+      <jdbc-url>jdbc:postgresql://10.10.10.211:5432/arsalan_rmc_module_app</jdbc-url>
+      <jdbc-additional-properties>
+        <property name="com.intellij.clouds.kubernetes.db.host.port" />
+        <property name="com.intellij.clouds.kubernetes.db.enabled" value="false" />
+        <property name="com.intellij.clouds.kubernetes.db.container.port" />
+      </jdbc-additional-properties>
       <working-dir>$ProjectFileDir$</working-dir>
     </data-source>
   </component>

.idea/misc.xml

@@ -4,10 +4,13 @@
   <component name="FrameworkDetectionExcludesConfiguration">
     <file type="web" url="file://$PROJECT_DIR$" />
   </component>
-  <component name="NimToolchainService">
+  <component name="MavenProjectsManager">
-    <option name="rootPaths">
+    <option name="originalFiles">
-      <list />
+      <list>
+        <option value="$PROJECT_DIR$/../txn_workflow/pom.xml" />
+      </list>
     </option>
+    <option name="workspaceImportForciblyTurnedOn" value="true" />
   </component>
   <component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK">
     <output url="file://$PROJECT_DIR$/out" />

.idea/vcs.xml

@@ -1,7 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="VcsDirectoryMappings">
-    <mapping directory="$PROJECT_DIR$/../rmc-modules-app" vcs="Git" />
     <mapping directory="$PROJECT_DIR$" vcs="Git" />
   </component>
 </project>

api.http

@@ -5,10 +5,22 @@ Authorization: {{auth-token}}
 
 {
   "data": {
-    "number": "KA01HD6667",
+    "number": "KA01HD6677",
     "owner": "gowthaman"
   },
-  "uniqueIdentifier": "KA01HD6667"
+  "uniqueIdentifier": ""
+}
+
+### create row
+POST http://localhost:9001/api/vendor/po
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+{
+  "data": {
+    "name": "arsalan",
+    "rating": 5
+  }
 }
 
 ### create row, with autogenerated identifier
@@ -23,14 +35,30 @@ Authorization: {{auth-token}}
   }
 }
 
+### create row, with autogenerated identifier
+POST http://localhost:9001/api/purchaseOrder
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+{
+  "vendor" : "arslan",
+  "products": ["chairs", "tables"]
+}
+
+
+
 ### get row
-GET http://localhost:9001/api/vehicle/TN38BA5009
+GET http://localhost:9001/api/log/log-0000000001
+Authorization: Bearer {{auth-token}}
+
+### get row
+GET http://localhost:9001/api/vehicle/KA01HD6667
 Authorization: Bearer {{auth-token}}
 
 ### query row
 POST http://localhost:9001/api/vehicle/query
 Content-Type: application/json
-Authorization: set-auth-token
+Authorization: {{set-auth-token}}
 
 {
   "sql": "select sys_pk, tenant_id, deleted_on, deleted_by, deleted, version, created_at, modified_at, created_by, modified_by, data, tags, comments, unique_identifier, entity_name from data_model where data ->> 'number' = :number",
@@ -40,7 +68,7 @@ Authorization: set-auth-token
 }
 
 ### update field
-PATCH http://localhost:9001/api/vehicle/KA01MU0556
+PATCH http://localhost:9001/api/vehicle/KA01HD6667
 Content-Type: application/json
 Authorization: {{auth-token}}
 
@@ -51,9 +79,9 @@ Authorization: {{auth-token}}
 
 
 ### upate a row
-PUT http://localhost:9001/api/vehicle/KA03HD6064
+PUT http://localhost:9001/api/vehicle/KA01HD6667
 Content-Type: application/json
-Authorization: set-auth-token
+Authorization: {{auth-token}}
 
 {
   "number": "KA03HD6064",
@@ -62,5 +90,298 @@ Authorization: set-auth-token
 }
 
 ### delete a row
-DELETE  http://localhost:9001/api/vehicle/KA01MU0556
+DELETE  http://localhost:9001/api/vehicle/KA01HD6667
-Authorization: {{auth-token}}
+Authorization: {{auth-token}}
+
+### get po for id
+GET  http://localhost:9001/api/vendor/product
+Authorization: {{auth-token}}
+
+### get product for id
+GET  http://localhost:9001/api/vendor/product/7
+Authorization: {{auth-token}}
+
+### get row
+GET http://localhost:9001/api/vendor/product/7
+Authorization: Bearer {{auth-token}}
+
+### create product
+POST http://localhost:9001/api/vendor/product
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+{
+    "name": "Shirt",
+    "description": "Black Shirt",
+    "hsnCode": "BSM1XL"
+
+}
+
+### update field
+PATCH http://localhost:9001/api/vendor/product/11
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+
+### upate a row
+PUT http://localhost:9001/api/vendor/product/11
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+
+### delete a row
+DELETE  http://localhost:9001/api/vendor/product/2
+Authorization: {{auth-token}}
+
+### create vendor
+POST http://localhost:9001/api/vendor/
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+{
+  "name": "arsalan",
+  "msme": "1234",
+  "gstNumber": "GST123",
+  "address": "Bangalore",
+  "rating": 2,
+  "contacts": [
+    {
+      "name": "contact1",
+      "email": "abc@cyz.com",
+      "mobile": "01234567890"
+    }
+  ]
+}
+
+### create batch vendor
+POST http://localhost:9001/api/vendor/batch
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+[
+  {
+    "name": "john",
+    "description": "5678",
+    "hsnCode": "5678",
+    "gstNumber": "GST567",
+    "address": "Mumbai",
+    "rating": 4,
+    "contacts": [
+      {
+        "name": "contact1",
+        "email": "xyz@abc.com",
+        "phone": "9876543210"
+      }
+    ]
+  },
+  {
+    "name": "emma",
+    "description": "7890",
+    "hsnCode": "7890",
+    "gstNumber": "GST789",
+    "address": "Delhi",
+    "rating": 3,
+    "contacts": [
+      {
+        "name": "contact2",
+        "email": "def@uvw.com",
+        "phone": "8765432109"
+      }
+    ]
+  },
+  {
+    "name": "alex",
+    "description": "2345",
+    "hsnCode": "2345",
+    "gstNumber": "GST234",
+    "address": "Chennai",
+    "rating": 5,
+    "contacts": [
+      {
+        "name": "contact3",
+        "email": "ghi@rst.com",
+        "phone": "7654321098"
+      }
+    ]
+  }
+]
+
+### GET ALL VENDORS
+POST http://localhost:9001/api/vendor/getAll
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+{
+  "common": {
+    "sortAsc": true
+  },
+  "vendorFilters": {
+    "nameLike": "a"
+  }
+}
+
+### create batch pos
+POST http://localhost:9001/api/vendor/po/batch
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+[
+  {
+    "products": [
+      {
+        "productId": "1232",
+        "productName": "chair",
+        "unitPrice": 34.2,
+        "quantity": 10,
+        "description": "wooden chair"
+      }
+    ],
+    "referenceQuotation": "12323",
+    "totalAmount": 342,
+    "poNum": "1",
+    "poDate": "2024-01-10",
+    "validTill": "2024-02-10",
+    "tnc": ["tnc1", "tnc2"]
+  },
+  {
+    "products": [
+      {
+        "productId": "5678",
+        "productName": "table",
+        "unitPrice": 45.5,
+        "quantity": 5,
+        "description": "glass table"
+      }
+    ],
+    "referenceQuotation": "56789",
+    "totalAmount": 227.5,
+    "poNum": "2",
+    "poDate": "2024-10-25",
+    "validTill": "2024-10-25",
+    "tnc": ["tnc3", "tnc4"]
+  },
+  {
+    "products": [
+      {
+        "productId": "91011",
+        "productName": "lamp",
+        "unitPrice": 15.75,
+        "quantity": 20,
+        "description": "floor lamp"
+      }
+    ],
+    "referenceQuotation": "9101112",
+    "totalAmount": 315,
+    "poNum": "3",
+    "poDate": "2024-10-25",
+    "validTill": "2024-12-25",
+    "tnc": ["tnc5", "tnc6"]
+  }
+]
+
+### GET ALL POS
+POST http://localhost:9001/api/vendor/po/getAll
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+{
+  "common" : {},
+  "poFilters": {}
+}
+
+### CREATE QUOTES
+POST http://localhost:9001/api/vendor/quote/batch
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+[
+  {
+    "products": [
+      {
+        "productId": "1232",
+        "productName": "chair",
+        "unitPrice": 34.2,
+        "quantity": 10,
+        "description": "wooden chair"
+      }
+    ],
+    "reqForQuoteNum": "12323",
+    "totalAmount": 342,
+    "quoteNum": "1",
+    "quoteDate": "2024-10-24",
+    "validTill": "2024-11-24",
+    "tnc": ["tnc1", "tnc2"]
+  },
+  {
+    "products": [
+      {
+        "productId": "5678",
+        "productName": "table",
+        "unitPrice": 45.5,
+        "quantity": 5,
+        "description": "glass table"
+      }
+    ],
+    "reqForQuoteNum": "56789",
+    "totalAmount": 227.5,
+    "quoteNum": "2",
+    "quoteDate": "2024-10-25",
+    "validTill": "2024-11-25",
+    "tnc": ["tnc3", "tnc4"]
+  },
+  {
+    "products": [
+      {
+        "productId": "91011",
+        "productName": "lamp",
+        "unitPrice": 15.75,
+        "quantity": 20,
+        "description": "floor lamp"
+      }
+    ],
+    "reqForQuoteNum": "9101112",
+    "totalAmount": 315,
+    "quoteNum": "3",
+    "quoteDate": "2024-10-25",
+    "validTill": "2024-12-25",
+    "tnc": ["tnc5", "tnc6"]
+  }
+]
+
+
+### GET ALL QUOTES
+POST http://localhost:9001/api/vendor/quote/getAll
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+{
+  "common" : {},
+  "quoteFilters": {}
+}
+
+
+### GET ALL PRODUCTS
+POST http://localhost:9001/api/vendor/product/getAll
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+{
+  "common" : {},
+  "quoteFilters": {}
+}
+
+### GET NEXT PO SEQ NUMBER
+GET http://localhost:9001/api/vendor/po/next
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+
+### GET NEXT QUOTE SEW NUMBER
+GET http://localhost:9001/api/vendor/quote/next
+Content-Type: application/json
+Authorization: {{auth-token}}
+
+### GET NEXT INCOMING SEW NUMBER
+GET http://localhost:9001/api/vendor/incoming/next
+Content-Type: application/json
+Authorization: {{auth-token}}

app-sample.yaml

@@ -12,13 +12,14 @@ app:
   cache:
     redis_uri: redis://127.0.0.1:6379/0
   iam:
-    url: https://auth.compegence.com
+    url: https://auth.readymixerp.com
-    realm: forewarn-dev
+    realm: rmc-dev
     client_redirect_uri: http://localhost:9001/auth/code
-    client: forewarn
+    client: rmc
   scripts:
     path: /Users/gowthaman.b/IdeaProjects/rmc_modules_api/src/main/resources/scripts
   security:
+    enforce_role_restriction: 'true'
     private_key: |-
       -----BEGIN PRIVATE KEY-----
       MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQD4ba8OhlyB9MUx

app_conf.yaml

@@ -0,0 +1,61 @@
+#DO Not edit this file, copy to your HOME Directory and then rename it to app.yaml and then edit it
+app:
+  db:
+    pass: password
+    url: jdbc:postgresql://10.10.10.211/arsalan_rmc_module_app
+    user: arsalan
+    name: arsalan_rmc_module_app	
+    run_migration: 'true'
+  cors:
+    enabled: 'true'
+    hosts: www.readymixerp.com,app.readymixerp.com
+  port: '9001'
+  cache:
+    redis_uri: redis://10.10.10.112:6379/
+  iam:
+    url: https://auth.readymixerp.com
+    realm: rmc-dev
+    client_redirect_uri: http://localhost:9001/auth/code
+    client: rmc
+  scripts:
+    path: /Users/gowthaman.b/IdeaProjects/rmc_modules_api/src/main/resources/scripts
+  security:
+    private_key: |-
+      -----BEGIN PRIVATE KEY-----
+      MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQD4ba8OhlyB9MUx
+      MFmT8c9sOKqXOG6ZM6qLxr5SnY1au47rYsHXt8Hb+tTUxpkf+5bndaZYGVgQ1mtw
+      eEVj3qZq9A+FnxxwZ9uIIdbOUPvsZLzNYnK3bFFRsmWMf30gDs6ZdS63b2tnXXE0
+      aoItwVguElUKVXKUymS0VlBB0ZLCYTlD6Q4sDm7HGXJZj5kVNVbBCBe42yLx8Y1F
+      TyNL8nPSS+SAdLUaPJ/6j+741+exAIOc0rSBJOMF0XNOwBZ85EuOiPa0e1sUz0qj
+      VfmZyeRFxkSWJBnqum1jrVFp55bMb37DYtZa0aFIcPdDfY42frDlPLcI4zzRwCn3
+      ggHL/nL9AgMBAAECggEAJ85sxu8zl8/l4EsG3M8EdVWidrGgUyRgDElFCiLcWVta
+      prqVJIt5YNYRJU5J5Jc2fRGxHPEOrJVW84IUsvskVQM/ZiHyd3ZvdaGKdFZYpO5t
+      VvGSlR53l0IhGxal24L+isCn7X+ec5pu6b8JQJX4RbBConHCTDdz/yDMzQcXiiqj
+      ezzSovZ1Xy/2dn7sOTFtEZi47d3AhBnjh8Xqk3Dc9UChooxuIU6WEbqWFxEkbzJS
+      sXIv9xADVDqFqjHGv6Tk1W+y7y8M2EHosJfhO0LmWFL7nUdw0WSJV+UqQxHrUSJs
+      SnYHkKRTYl2ljpjkuECp/YqUqdlNq/5T5jBE6cyopwKBgQD6+XGZfssdAqfnaEK2
+      nHdUAdklUFAFQpSmwIUwTZEHDC/CD+ErVjfbEfZ2mFOvWAIMwLmiLFuDT7E5sHaT
+      K4A2DQ8KyU3iJkH4nhxdYepLc7MSYElkn6fHNrXcJ9vPACmrtoa9rVW/LpAjsRq6
+      fDxLo12/+EmFvpZ0oEAIQXk6ZwKBgQD9ZzBgPapI8m7cjcdojqq0dJ2M5Sw7Bx5n
+      VFOC3H4Cx0xWTdwwZ9CZQ4v/XiiHiUGzwhfkNJ2x3DdpUCkPDD8o3cFXPRW4GsjD
+      kv/D0kL/JJAesG9XB9yMTMBoe2yGMudDVc7SYgUI2YXhmHYkpcjSzM0DftLL2Z47
+      GY1h385Q+wKBgGTRxe/Kfp+lzHtqZ7ph+pG1uFyD+dFTINIn7pkr38G8BIdpx6OY
+      HBIWEjMsGBoNOa2T0j6yoQSMA/7Pw6J1TCjqcAt+OJpLkh7krTJaPjuXO+163qDc
+      fhLKCJ5rKKLsRtEjHtedhR+q/d5IrBsUA0jDVMrkW+ytVlV9dpuaaa+rAoGASON8
+      m8JBD/iEAPbbK+0VlxCQHO3ymgwDJ8+usc6AhIYVJCIDOv0xmFRAmbTYzZuihXVH
+      8AFedsGUQrunA8gPBs86hMByVeGGbBMFdKsvUDqRJfK0JAGD4+tT0PnnjnZn5Qty
+      kTtWnWQMSYbUPNhe+pukQOQi+DXheLhx3XxF2S8CgYEAopLjGIR/xeuV7QkGJfCO
+      d2wEJROBPd3pbDlR4fLDO8RCw3irFYQgQd9WgGJY5KgyfjKLHkK7DMQKn+/yfUp5
+      UKeesBDXATpyQQrpfoKIhhZKtYphOwvIzugtLsd5sza++sjC9RwkRmYr0rzlHdUl
+      vtr3fru0Bzven2MeiQnqmCM=
+      -----END PRIVATE KEY-----
+    public_key: |-
+      -----BEGIN PUBLIC KEY-----
+      MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA+G2vDoZcgfTFMTBZk/HP
+      bDiqlzhumTOqi8a+Up2NWruO62LB17fB2/rU1MaZH/uW53WmWBlYENZrcHhFY96m
+      avQPhZ8ccGfbiCHWzlD77GS8zWJyt2xRUbJljH99IA7OmXUut29rZ11xNGqCLcFY
+      LhJVClVylMpktFZQQdGSwmE5Q+kOLA5uxxlyWY+ZFTVWwQgXuNsi8fGNRU8jS/Jz
+      0kvkgHS1Gjyf+o/u+NfnsQCDnNK0gSTjBdFzTsAWfORLjoj2tHtbFM9Ko1X5mcnk
+      RcZEliQZ6rptY61RaeeWzG9+w2LWWtGhSHD3Q32ONn6w5Ty3COM80cAp94IBy/5y
+      /QIDAQAB
+      -----END PUBLIC KEY-----

build.gradle.kts

@@ -1,8 +1,11 @@
+import com.github.jengelman.gradle.plugins.shadow.tasks.ShadowJar
+
 plugins {
     kotlin("jvm") version "1.9.22"
     kotlin("kapt") version "1.9.22"
     id("idea")
     id("io.ebean") version "13.23.2"
+    id("com.github.johnrengelman.shadow") version "8.1.1"
     application
 }
 
@@ -34,6 +37,12 @@ dependencies {
     implementation("org.bouncycastle:bcprov-jdk18on:1.76")
     implementation("org.bouncycastle:bcpkix-jdk18on:1.76")
     implementation("org.yaml:snakeyaml:2.2")
+    implementation("io.minio:minio:8.5.7")
+    implementation("org.apache.httpcomponents:httpclient:4.5.14")
+    implementation("org.apache.poi:poi:5.0.0")
+    implementation("org.apache.poi:poi-ooxml:5.0.0")
+    implementation("com.google.code.gson:gson:2.8.8")
+
     api ("net.cactusthorn.config:config-core:0.81")
     api ("net.cactusthorn.config:config-yaml:0.81")
     kapt("net.cactusthorn.config:config-compiler:0.81")
@@ -48,6 +57,18 @@ kotlin {
     jvmToolchain(17)
 }
 
+tasks {
+    named<ShadowJar>("shadowJar") {
+        archiveBaseName.set("rest-api")
+        mergeServiceFiles()
+        manifest {
+            attributes(mapOf("Main-Class" to "com.restapi.MainKt"))
+        }
+        isZip64 = true
+    }
+}
+
+
 application {
     mainClass.set("com.restapi.MainKt")
 }

src/main/kotlin/com/restapi/AppAccessManager.kt

@@ -42,6 +42,7 @@ class AppAccessManager : AccessManager {
                     Role.DbOps -> listOf("ROLE_DB_OPS")
                     Role.Entity -> loadEntityActionRole(entity, action)
                     is Role.Standard -> role.action.toList().map { "ROLE_${entity}_${it}" }
+                    is Role.Explicit -> role.roles.toList() + listOf("ROLE_ADMIN")
                 }.map(String::uppercase)
             }
 

src/main/kotlin/com/restapi/Main.kt

@@ -4,7 +4,7 @@ import com.fasterxml.jackson.databind.JsonMappingException
 import com.restapi.config.*
 import com.restapi.config.AppConfig.Companion.appConfig
 import com.restapi.config.Auth.validateAuthToken
-import com.restapi.controllers.Entities
+import com.restapi.controllers.*
 import com.restapi.domain.DataNotFoundException
 import com.restapi.domain.Session.currentTenant
 import com.restapi.domain.Session.currentUser
@@ -15,7 +15,9 @@ import io.ebean.DataIntegrityException
 import io.ebean.DuplicateKeyException
 import io.javalin.Javalin
 import io.javalin.apibuilder.ApiBuilder.*
-import io.javalin.http.*
+import io.javalin.http.ContentType
+import io.javalin.http.Context
+import io.javalin.http.UnauthorizedResponse
 import io.javalin.http.util.NaiveRateLimit
 import io.javalin.http.util.RateLimitUtil
 import io.javalin.json.JavalinJackson
@@ -60,6 +62,7 @@ fun main(args: Array<String>) {
         }
         .routes {
             path("/auth") {
+
                 get("/endpoint", Auth::endPoint)
                 get("/init", Auth::init)
                 get("/code", Auth::code)
@@ -74,10 +77,10 @@ fun main(args: Array<String>) {
                     TimeUnit.MINUTES
                 )
 
-                val authToken = ctx.header("Authorization")
+                val authToken = ctx.getAuthHeader() ?: throw UnauthorizedResponse()
-                    ?.replace("Bearer ", "")
+
-                    ?.replace("Bearer: ", "")
+
-                    ?.trim() ?: throw UnauthorizedResponse()
+                //there are 2 scenarios, 1) auth user for admin 2) non user for flow, we need to handle both
 
                 setAuthorizedUser(validateAuthToken(authToken = authToken))
 
@@ -96,16 +99,140 @@ fun main(args: Array<String>) {
                 it.header("X-Signature", signPayload(outEncoded))
 
                 if (appConfig.enforcePayloadEncryption()) {
-                    //todo:, encrypt and set the response back to user
+                    //todo: encrypt and send the response back to user
                 }
 
             }
             path("/api") {
+
                 post("/audit/{action}") {
                     logger.warn("User ${currentUser()} of tenant ${currentTenant()} has performed ${it.pathParam("action")} @ ${LocalDateTime.now()}")
                     it.json(mapOf("status" to true))
                 }
 
+                path("/vendor") {
+                    path("/") {
+                        post("", VendorCtrl::create, Roles(Role.Explicit("ROLE_VENDOR_CREATE")))
+                        post("/batch", VendorCtrl::createBatch, Roles(Role.Explicit("ROLE_VENDOR_CREATE")))
+                        get("/{id}", VendorCtrl::get, Roles(Role.Explicit("ROLE_VENDOR_VIEW", "ROLE_VENDOR_CREATE")))
+                        post(
+                            "/getAll",
+                            VendorCtrl::getAll,
+                            Roles(Role.Explicit("ROLE_VENDOR_VIEW", "ROLE_VENDOR_CREATE"))
+                        )
+                        get(
+                            "quotes/{id}",
+                            VendorCtrl::getQuotes,
+                            Roles(Role.Explicit("ROLE_QUOTE_VIEW", "ROLE_QUOTE_CREATE", "ROLE_VENDOR_VIEW"))
+                        )
+                        get("pos/{id}", VendorCtrl::getPos, Roles(Role.Explicit("ROLE_PO_VIEW", "ROLE_PO_CREATE`")))
+                        put("/rate/{id}/{rating}", VendorCtrl::rate, Roles(Role.Explicit("ROLE_VENDOR_CREATE")))
+                        put("/{id}", VendorCtrl::update, Roles(Role.Explicit("ROLE_VENDOR_CREATE")))
+                    }
+                    path("/incoming") {
+                        post("", IncomingInventoryCtrl::create, Roles(Role.Explicit("ROLE_INVENTORY_CREATE")))
+                        get("/next", IncomingInventoryCtrl::getNextNum, Roles(Role.Explicit("ROLE_INVENTORY_CREATE")))
+                        get(
+                            "/{id}",
+                            IncomingInventoryCtrl::get,
+                            Roles(Role.Explicit("ROLE_INVENTORY_VIEW", "ROLE_INVENTORY_CREATE"))
+                        )
+                        put("/{id}", IncomingInventoryCtrl::update, Roles(Role.Explicit("ROLE_INVENTORY_CREATE")))
+                        post(
+                            "/getAll",
+                            IncomingInventoryCtrl::getAll,
+                            Roles(Role.Explicit("ROLE_INVENTORY_CREATE", "ROLE_INVENTORY_VIEW"))
+                        )
+                    }
+                    path("/outgoing") {
+                        post("", OutgoingInventoryCtrl::create, Roles(Role.Explicit("ROLE_INVENTORY_CREATE")))
+                        get("/next", OutgoingInventoryCtrl::getNextNum, Roles(Role.Explicit("ROLE_INVENTORY_CREATE")))
+                        get(
+                            "/{id}",
+                            OutgoingInventoryCtrl::get,
+                            Roles(Role.Explicit("ROLE_INVENTORY_VIEW", "ROLE_INVENTORY_CREATE"))
+                        )
+                        put("/{id}", OutgoingInventoryCtrl::update, Roles(Role.Explicit("ROLE_INVENTORY_CREATE")))
+                        post(
+                            "/getAll",
+                            OutgoingInventoryCtrl::getAll,
+                            Roles(Role.Explicit("ROLE_INVENTORY_CREATE", "ROLE_INVENTORY_VIEW"))
+                        )
+                    }
+                    path("/po") {
+                        get("/next", PurchaseOrderCtrl::getNextNum, Roles(Role.Explicit("ROLE_PO_CREATE")))
+                        post("", PurchaseOrderCtrl::create, Roles(Role.Explicit("ROLE_PO_CREATE")))
+                        post("/batch", PurchaseOrderCtrl::createBatch, Roles(Role.Explicit("ROLE_PO_CREATE")))
+                        post(
+                            "/getAll",
+                            PurchaseOrderCtrl::getAll,
+                            Roles(Role.Explicit("ROLE_PO_CREATE", "ROLE_PO_VIEW", "ROLE_VENDOR_CREATE"))
+                        )
+                        get(
+                            "/{id}",
+                            PurchaseOrderCtrl::get,
+                            Roles(Role.Explicit("ROLE_PO_CREATE", "ROLE_PO_VIEW", "ROLE_QUOTE_CREATE"))
+                        )
+                        put("/{id}", PurchaseOrderCtrl::update, Roles(Role.Explicit("ROLE_PO_CREATE")))
+                        put("/approve/{id}", PurchaseOrderCtrl::approve, Roles(Role.Explicit()))
+                        put("/reject/{id}", PurchaseOrderCtrl::reject, Roles(Role.Explicit()))
+                        get("/refQuote/{id}", PurchaseOrderCtrl::quoteReference, Roles(Role.Explicit("ROLE_PO_CREATE")))
+                    }
+                    path("/quote") {
+                        get("/next", QuotationCtrl::getNextNum, Roles(Role.Explicit("ROLE_QUOTE_CREATE")))
+                        post("", QuotationCtrl::create, Roles(Role.Explicit("ROLE_QUOTE_CREATE")))
+                        post("/batch", QuotationCtrl::createBatch, Roles(Role.Explicit("ROLE_QUOTE_CREATE")))
+                        post(
+                            "/getAll",
+                            QuotationCtrl::getAll,
+                            Roles(Role.Explicit("ROLE_QUOTE_CREATE", "ROLE_QUOTE_VIEW"))
+                        )
+                        get("/{id}", QuotationCtrl::get, Roles(Role.Explicit("ROLE_QUOTE_VIEW", "ROLE_QUOTE_CREATE")))
+                        put("/{id}", QuotationCtrl::update, Roles(Role.Explicit("ROLE_QUOTE_CREATE")))
+                        delete("/{id}", QuotationCtrl::delete, Roles(Role.Explicit("ROLE_QUOTE_CREATE")))
+                    }
+                    path("/product") {
+                        post("", ProductCtrl::create, Roles(Role.Explicit("ROLE_PRODUCT_CREATE")))
+                        put("/{id}", ProductCtrl::update, Roles(Role.Explicit("ROLE_PRODUCT_CREATE")))
+                        delete("/{id}", ProductCtrl::delete, Roles(Role.Explicit("ROLE_PRODUCT_CREATE")))
+                        patch("/{id}", ProductCtrl::patch, Roles(Role.Explicit("ROLE_PRODUCT_CREATE")))
+                        post("/getAll", ProductCtrl::getAll, Roles(Role.Explicit("ROLE_PRODUCT_VIEW")))
+                        get("/{id}", ProductCtrl::get, Roles(Role.Explicit("ROLE_PRODUCT_VIEW")))
+                    }
+                    path("/doc") {
+                        post("", DocumentCtrl::create, Roles(Role.Explicit("ROLE_DOC_CREATE")))
+                        //why type and refid are clubbed ??
+                        get(
+                            "/{type}/{refId}",
+                            DocumentCtrl::getWithRefId,
+                            Roles(Role.Explicit("ROLE_DOC_VIEW", "ROLE_PRODUCT_CREATE"))
+                        )
+                        get("/{id}", DocumentCtrl::get, Roles(Role.Explicit("ROLE_DOC_VIEW", "ROLE_PRODUCT_CREATE")))
+                        get(
+                            "/print/{id}",
+                            DocumentCtrl::print,
+                            Roles(Role.Explicit("ROLE_DOC_CREATE", "ROLE_DOC_VIEW"))
+                        )
+                        delete("/{id}", DocumentCtrl::delete, Roles(Role.Explicit("ROLE_DOC_CREATE")))
+                    }
+                    path("/reqForQuote") {
+                        post(
+                            "",
+                            RequestForQuote::create,
+                            Roles(Role.Explicit("ROLE_QUOTE_CREATE", "ROLE_PO_CREATE", "ROLE_RFQ_CREATE"))
+                        )
+                        get(
+                            "/{id}",
+                            RequestForQuote::get,
+                            Roles(Role.Explicit("ROLE_RFQ_CREATE", "ROLE_RFQ_VIEW", "ROLE_QUOTE_VIEW", "ROLE_PO_VIEW"))
+                        )
+                        put(
+                            "/{id}",
+                            RequestForQuote::update,
+                            Roles(Role.Explicit("ROLE_QUOTE_CREATE", "ROLE_PO_CREATE", "ROLE_RFQ_CREATE"))
+                        )
+                    }
+                }
                 post("/script/database/{name}", Entities::executeStoredProcedure, Roles(adminRole, Role.DbOps))
                 post("/script/{file}/{name}", Entities::executeScript, Roles(adminRole, Role.DbOps))
 
@@ -126,9 +253,14 @@ fun main(args: Array<String>) {
         .exception(DuplicateKeyException::class.java, Exceptions.dupKeyExceptionHandler)
         .exception(DataIntegrityException::class.java, Exceptions.dataIntegrityException)
         .exception(DataNotFoundException::class.java, Exceptions.dataNotFoundException)
-        .exception(IllegalArgumentException::class.java,Exceptions.illegalArgumentException)
+        .exception(IllegalArgumentException::class.java, Exceptions.illegalArgumentException)
         .exception(JsonMappingException::class.java, Exceptions.jsonMappingException)
         .exception(InvalidJwtException::class.java, Exceptions.invalidJwtException)
         .start(appConfig.portNumber())
 }
 
+private fun Context.getAuthHeader() = header("Authorization")
+    ?.replace("Bearer ", "")
+    ?.replace("Bearer: ", "")
+    ?.trim()
+

src/main/kotlin/com/restapi/Test.kt

@@ -0,0 +1,74 @@
+package com.restapi
+
+import com.fasterxml.jackson.core.JsonParser
+import com.fasterxml.jackson.databind.DeserializationContext
+import com.fasterxml.jackson.databind.JsonDeserializer
+import com.fasterxml.jackson.databind.JsonNode
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize
+import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
+import com.fasterxml.jackson.module.kotlin.readValue
+import com.restapi.controllers.QueryParam
+import com.restapi.controllers.RawQuery
+
+class FDeserializer : JsonDeserializer<F>() {
+    override fun deserialize(p: JsonParser, p1: DeserializationContext?): F {
+        //custom logic to do thia
+        val node = p.readValueAsTree<JsonNode>()
+
+        if (node.isObject) {
+            if (node.has("name")) {
+                return F.P(name = node.get("name").textValue())
+            } else if (node.has("num")) {
+                return F.Q(num = node.get("num").textValue())
+            } else if (node.has("tag")) {
+                return F.D(tag = node.get("tag").textValue())
+            }
+
+        } else {
+            //incorrect
+        }
+        throw IllegalArgumentException()
+    }
+
+}
+val om = jacksonObjectMapper()
+
+@JsonDeserialize(using = FDeserializer::class)
+sealed interface F {
+    data class P(val name: String) : F
+    data class Q(val num: String) : F
+    data class D(val tag: String) : F
+}
+
+val j = """
+    {"name":"a"}
+""".trimIndent()
+
+val j2 = """
+    {"num":"a"}
+""".trimIndent()
+
+val j3 = """
+    {"tag":"a"}
+""".trimIndent()
+
+val j4 = """
+    {
+    "sql":"aaaa",
+    "params": {
+            "a":"b",
+            "c": {
+                "type":"STRING",
+                "value":"aaaa"
+             }
+            
+        }
+    }
+""".trimIndent()
+
+fun main() {
+    println(om.readValue<F>(j))
+    println(om.readValue<F>(j2))
+    println(om.readValue<F>(j3))
+    println(om.readValue<RawQuery>(j4))
+}

src/main/kotlin/com/restapi/config/AppConfig.kt

@@ -81,6 +81,21 @@ interface AppConfig {
     @Key("app.security.public_key")
     fun publicKey(): Optional<String>
 
+    @Key("app.locate.api_key")
+    fun locateApiKey(): Optional<String>
+
+    @Key("app.s3.url")
+    fun s3Url(): Optional<String>
+
+    @Key("app.s3.bucket")
+    fun s3Bucket(): Optional<String>
+
+    @Key("app.s3.access_key")
+    fun s3AccessKey(): Optional<String>
+
+    @Key("app.s3.secret_key")
+    fun s3SecretKey(): Optional<String>
+
     companion object {
         val appConfig: AppConfig = ConfigFactory.builder().build().create(AppConfig::class.java)
     }

src/main/kotlin/com/restapi/config/Auth.kt

@@ -62,8 +62,8 @@ object Auth {
         .setRequireExpirationTime()
         .setAllowedClockSkewInSeconds(30)
         .setRequireSubject()
-        .setExpectedIssuer(getAuthEndpoint().issuer)
         .setExpectedAudience("account")
+        .setExpectedIssuer(getAuthEndpoint().issuer)
         .setVerificationKeyResolver(HttpsJwksVerificationKeyResolver(HttpsJwks(getAuthEndpoint().jwksUri)))
         .build()
 
@@ -235,6 +235,7 @@ enum class Action {
 sealed class Role {
     open class Standard(vararg val action: Action) : Role()
     data object Entity : Role()
+    open class Explicit(vararg val roles: String) : Role()
     data object DbOps : Role()
 }
 

src/main/kotlin/com/restapi/controllers/Entities.kt

@@ -12,11 +12,9 @@ import com.restapi.domain.Session.findDataModelByEntityAndUniqId
 import com.restapi.integ.Scripting
 import io.ebean.CallableSql
 import io.ebean.RawSqlBuilder
-import io.javalin.http.BadRequestResponse
+import io.javalin.http.*
-import io.javalin.http.Context
-import io.javalin.http.NotFoundResponse
-import io.javalin.http.bodyAsClass
 import org.slf4j.LoggerFactory
+import java.io.FileInputStream
 import java.sql.Types
 import java.time.LocalDate
 import java.time.LocalDateTime
@@ -371,4 +369,538 @@ object Entities {
     } catch (e: Exception) {
         false
     }
-}
+}
+
+data class Filters(val common: CommonFilters, val custom: CustomFilters)
+data class SequenceNumber(val number: String)
+data class BatchPos(val pos: List<PurchaseOrder>)
+object PurchaseOrderCtrl {
+
+    fun getNextNum(ctx: Context) {
+        val prefix = "PO/"
+        val cnt = database.find(PurchaseOrder::class.java)
+            .findCount()
+            .toString()
+            .padStart(6, '0')
+        val seq = SequenceNumber(prefix + cnt)
+        ctx.json(seq).status(HttpStatus.OK)
+    }
+
+    fun get(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val po = database.find(PurchaseOrder::class.java, id) ?: throw NotFoundResponse("po not found for $id")
+        ctx.json(po).status(HttpStatus.OK)
+    }
+
+    data class PF(val common: CommonFilters, val poFilters: POFilters)
+
+    fun getAll(ctx: Context) {
+        val filters = ctx.bodyAsClass<PF>()
+        val pos = searchPos(filters.common, filters.poFilters)
+        val excel = ctx.queryParam("excel")
+        if (excel != null) {
+            exportPos(pos)
+            val inputStream = FileInputStream("./excel/Pos.xls")
+            ctx.result(inputStream).status(HttpStatus.OK)
+        } else {
+            ctx.json(pos).status(HttpStatus.OK)
+        }
+    }
+
+    fun create(ctx: Context) {
+        val po = ctx.bodyAsClass<PurchaseOrder>()
+        val prods = po.products
+        if (prods.isEmpty()) {
+            ctx.json(mapOf("error" to "empty product list")).status(HttpStatus.BAD_REQUEST)
+            return
+        }
+        database.save(po)
+        ctx.json(po).status(HttpStatus.CREATED)
+    }
+
+    fun createBatch(ctx: Context) {
+        val pos = ctx.bodyAsClass<List<PurchaseOrder>>()
+        val txn = database.beginTransaction()
+        try {
+            txn.isBatchMode = true
+            for (po in pos) database.save(po)
+            txn.commit()
+            ctx.status(HttpStatus.CREATED).result("POS Created")
+        } catch (e: Exception) {
+            txn.rollback()
+            ctx.status(HttpStatus.INTERNAL_SERVER_ERROR).result("Pos Creation failed" + e.message)
+        } finally {
+            txn.end()
+        }
+        ctx.result("pos batch created").status(HttpStatus.CREATED)
+    }
+
+    fun approve(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val po = database.find(PurchaseOrder::class.java, id) ?: throw NotFoundResponse("po not found for $id")
+        po.approvalStatus = ApprovalStatus.APPROVED
+        po.save()
+        ctx.json(po).status(HttpStatus.CREATED)
+        //reject all other pos pertaining to the same tx ??
+    }
+
+    fun reject(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val po = database.find(PurchaseOrder::class.java, id) ?: throw NotFoundResponse("po not found for $id")
+        po.apply {
+            approvalStatus = ApprovalStatus.REJECTED
+            save()
+        }
+        ctx.json(po).status(HttpStatus.CREATED)
+    }
+
+    fun quoteReference(ctx: Context) {
+        //gets the quote reference on which this po is based on
+        val id = ctx.pathParam("id")
+        val quote = database.find(Quotation::class.java)
+            .where()
+            .eq("referenceQuotation", id)
+            ?: throw NotFoundResponse("reference quotation not found for po $id")
+        ctx.json(quote)
+    }
+
+    fun update(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val po = database.find(PurchaseOrder::class.java, id) ?: throw NotFoundResponse("po not found for $id")
+        val updatedPo = ctx.bodyAsClass<PurchaseOrder>()
+        po.patchValues(updatedPo)
+        po.update()
+        ctx.json(po).status(HttpStatus.OK)
+    }
+
+    fun delete(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val po = database.find(PurchaseOrder::class.java, id) ?: throw NotFoundResponse("no po found with id $id")
+        database.delete(po)
+        ctx.status(HttpStatus.OK)
+    }
+}
+
+data class ProductSearch(
+    var isSort: String? = null
+
+)
+
+object ProductCtrl {
+    fun get(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val product = database.find(Product::class.java)
+            .where()
+            .eq("sys_pk", id.toLong())
+            .findOne()
+            ?: throw NotFoundResponse("Product not found for $id")
+        ctx.json(product).status(HttpStatus.OK)
+    }
+
+    data class PF(val common: CommonFilters, val productFilters: ProductFilters)
+
+    fun getAll(ctx: Context) {
+        val filters = ctx.bodyAsClass<PF>()
+        val prods = searchProducts(filters.common, filters.productFilters)
+        val excel = ctx.queryParam("excel")
+        if (excel != null) {
+            exportProds(prods)
+            val inputStream = FileInputStream("./excel/Products.xls")
+            ctx.result(inputStream).status(HttpStatus.OK)
+
+        } else {
+            ctx.json(prods).status(HttpStatus.OK)
+        }
+    }
+
+    fun create(ctx: Context) {
+        val product = ctx.bodyAsClass<Product>()
+        database.save(product)
+        ctx.json(product).status(HttpStatus.CREATED)
+    }
+
+    fun delete(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val prod = database.find(Product::class.java, id) ?: throw NotFoundResponse("no product found with id $id")
+        database.delete(prod)
+        ctx.status(HttpStatus.OK)
+    }
+
+    fun patch(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val patchValues = ctx.bodyAsClass<Map<String, Any>>()
+        database.beginTransaction().use {
+            patchValues.entries.forEach { en ->
+                val key = en.key
+                val value = en.value
+                database.sqlUpdate("update products set $key = ? where id = ?").apply {
+                    setParameter(1, value)
+                    setParameter(2, id)
+                    execute()
+                }
+            }
+            it.commit()
+        }
+    }
+
+    fun update(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val product = database.find(Product::class.java, id) ?: throw NotFoundResponse("product not found for $id")
+        val updatedProduct = ctx.bodyAsClass<Product>()
+        product.patchValues(updatedProduct)
+        product.update()
+        ctx.json(product).status(HttpStatus.OK)
+    }
+
+
+    @JvmStatic
+    fun main(args: Array<String>) {
+
+        val patchValues = mapOf("name" to 1)
+        val id = 1;
+        database.beginTransaction().use {
+            patchValues.entries.forEach { en ->
+                val key = en.key
+                val value = en.value
+
+                database.sqlUpdate("update product set $key = ? where sys_pk = ?").apply {
+                    setParameter(1, value)
+                    setParameter(2, id)
+
+                    execute()
+                }
+            }
+            it.commit()
+        }
+    }
+
+}
+
+object QuotationCtrl {
+    fun getNextNum(ctx: Context) {
+        val prefix = "QUOTE/"
+        val cnt = database.find(Quotation::class.java)
+            .findCount()
+            .toString()
+            .padStart(6, '0')
+        val seq = SequenceNumber(prefix + cnt)
+        ctx.json(seq).status(HttpStatus.OK)
+    }
+
+    fun get(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val quote = database.find(Quotation::class.java, id) ?: throw NotFoundResponse("quote not found for $id")
+        ctx.status(HttpStatus.OK)
+        ctx.json(quote)
+    }
+
+    data class QF(val common: CommonFilters, val quoteFilters: QuoteFilters)
+
+    fun getAll(ctx: Context) {
+        val filters = ctx.bodyAsClass<QF>()
+        val excel: String? = ctx.queryParam("excel")
+        val quotes = searchQuotes(filters.common, filters.quoteFilters)
+        if (excel != null) {
+            exportQuotations(quotes)
+            val inputStream = FileInputStream("./excel/Quotes.xls")
+            ctx.result(inputStream).status(HttpStatus.OK)
+        } else {
+            ctx.json(quotes).status(HttpStatus.OK)
+        }
+    }
+
+    fun create(ctx: Context) {
+        val quote = ctx.bodyAsClass<Quotation>()
+        //validation
+        val prods = quote.products
+        if (prods.isEmpty()) {
+            ctx.json(mapOf("error" to "empty product list")).status(HttpStatus.BAD_REQUEST)
+            return
+        }
+        database.save(quote)
+        ctx.json(quote).status(HttpStatus.CREATED)
+    }
+
+    fun createBatch(ctx: Context) {
+        val quotes = ctx.bodyAsClass<List<Quotation>>()
+        val txn = database.beginTransaction()
+        try {
+            txn.isBatchMode = true
+            for (quote in quotes) database.save(quote)
+            txn.commit()
+            ctx.status(HttpStatus.CREATED).result("Quotes Created")
+        } catch (e: Exception) {
+            txn.rollback()
+            ctx.status(HttpStatus.INTERNAL_SERVER_ERROR).result("Quotes Creation failed" + e.message)
+        } finally {
+            txn.end()
+        }
+        ctx.result("Quotes batch created").status(HttpStatus.CREATED)
+    }
+
+    fun delete(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val quote = database.find(Quotation::class.java, id) ?: throw NotFoundResponse("no quote found with id $id")
+        database.delete(quote)
+        ctx.status(HttpStatus.OK)
+    }
+
+    fun update(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val quote = database.find(Quotation::class.java, id) ?: throw NotFoundResponse("quote not found for $id")
+        val updatedQuote = ctx.bodyAsClass<Quotation>()
+        quote.patchValues(updatedQuote)
+        quote.update()
+        ctx.json(quote).status(HttpStatus.OK)
+    }
+}
+
+object DocumentCtrl {
+    fun get(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val doc = database.find(Document::class.java, id) ?: throw NotFoundResponse("no doc found with id $id")
+        ctx.status(HttpStatus.OK)
+        ctx.json(doc)
+    }
+
+    fun create(ctx: Context) {
+        val doc = ctx.bodyAsClass<Document>()
+        database.save(doc)
+        ctx.status(HttpStatus.CREATED)
+        ctx.json(doc)
+    }
+
+    fun print(ctx: Context) {
+        //would be handled in the frontend ??
+    }
+
+    fun delete(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val doc = database.find(Document::class.java, id) ?: throw NotFoundResponse("no document found with id $id")
+        database.delete(doc)
+        ctx.status(HttpStatus.OK)
+    }
+
+    fun getWithRefId(ctx: Context) {
+        //fetches a particular doc (po, quote) with ref id
+        val refId = ctx.pathParam("refId")
+        val doc = database.find(Document::class.java)
+            .where()
+            .eq("typeOfDoc", DocType.valueOf(ctx.pathParam("type")))
+            .eq("refIdOfDoc", refId)
+            ?: throw NotFoundResponse("no doc found for refId $refId")
+        ctx.status(HttpStatus.OK)
+        ctx.json(doc)
+    }
+
+}
+
+object VendorCtrl {
+    val logger = LoggerFactory.getLogger("Vendor")
+    fun get(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val vendor = database.find(Vendor::class.java, id) ?: throw NotFoundResponse("no vendor found with id $id")
+        ctx.status(HttpStatus.OK)
+        ctx.json(vendor)
+    }
+
+    data class VF(val common: CommonFilters, val vendorFilters: VendorFilters)
+
+    fun getAll(ctx: Context) {
+        val filters = ctx.bodyAsClass<VF>()
+        logger.info("filters = {}", filters)
+        val excel: String? = ctx.queryParam("excel")
+        val vendors = searchVendors(filters.common, filters.vendorFilters)
+        if (excel !== null) {
+            exportVendors(vendors)
+            val inputStream = FileInputStream("./excel/VendorList.xls")
+            ctx.result(inputStream).status(HttpStatus.OK)
+        } else {
+            ctx.json(vendors).status(HttpStatus.OK)
+        }
+    }
+
+    fun createBatch(ctx: Context) {
+        val vendors = ctx.bodyAsClass<List<Vendor>>()
+        database.saveAll(vendors)
+    }
+
+    fun create(ctx: Context) {
+        val vendor = ctx.bodyAsClass<Vendor>()
+        database.save(vendor)
+        ctx.status(HttpStatus.CREATED)
+        ctx.json(vendor)
+    }
+
+    fun update(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val vendor = database.find(Vendor::class.java, id) ?: throw NotFoundResponse("vendor not found for $id")
+        val updatedVendor = ctx.bodyAsClass<Vendor>()
+        vendor.patchValues(updatedVendor)
+        vendor.update()
+        ctx.json(vendor).status(HttpStatus.OK)
+    }
+
+    fun delete(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val vendor = database.find(Vendor::class.java, id) ?: throw NotFoundResponse("no vendor found with id $id")
+        database.delete(vendor)
+        ctx.status(HttpStatus.OK)
+    }
+
+    fun getQuotes(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val quotes = database.find(Quotation::class.java)
+            .where()
+            .eq("vendor", database.find(Vendor::class.java, id) ?: throw NotFoundResponse("vendor not found for $id"))
+            .findList()
+        ctx.json(quotes).status(HttpStatus.OK)
+    }
+
+    fun getPos(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val pos = database.find(PurchaseOrder::class.java)
+            .where()
+            .eq("vendor", database.find(Vendor::class.java, id) ?: throw NotFoundResponse("vendor not found for $id"))
+            .findList()
+        ctx.json(pos).status(HttpStatus.OK)
+    }
+
+    fun rate(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val rating1 = ctx.pathParam("rating").toDouble()
+
+        database.find(Vendor::class.java, id)?.let {
+            it.rating = rating1
+            it.save()
+        } ?: throw NotFoundResponse("vendor not found for id $id")
+
+
+        ctx.result("rating changed").status(HttpStatus.OK)
+    }
+}
+
+object RequestForQuote {
+    fun create(ctx: Context) {
+        val rfq = ctx.bodyAsClass<ReqForQuote>()
+        database.save(rfq)
+        //ctx.result("request for quote created")
+        //ctx.json(rfq)
+        ctx.status(HttpStatus.CREATED)
+        ctx.json("asss")
+    }
+
+    fun get(ctx: Context) {
+        val id = ctx.pathParam("id")
+        val rfq = database.find(ReqForQuote::class.java, id)
+            ?: throw NotFoundResponse("request for quote not found for id $id")
+        ctx.status(HttpStatus.OK)
+        ctx.json(rfq)
+    }
+
+    fun update(ctx: Context) {
+        //shuld we compare the new body fields with preexisting ones and prepare a sql query to update those fields??
+
+    }
+}
+
+object IncomingInventoryCtrl {
+    fun create(ctx: Context) {
+        val ticket = ctx.bodyAsClass<IncomingInventory>()
+        database.save(ticket)
+        ctx.json(ticket).status(HttpStatus.CREATED)
+    }
+
+    fun update(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val ticket =
+            database.find(IncomingInventory::class.java, id) ?: throw NotFoundResponse("quote not found for $id")
+        val updatedTicket = ctx.bodyAsClass<IncomingInventory>()
+        ticket.patchValues(updatedTicket)
+        ticket.update()
+        ctx.json(ticket).status(HttpStatus.OK)
+    }
+
+    fun get(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val ticket = database.find(IncomingInventory::class.java, id)
+            ?: throw NotFoundResponse("No incoming inventory ticket found with id $id")
+        ctx.json(ticket).status(HttpStatus.OK)
+    }
+
+    data class IIF(val common: CommonFilters, val incomingInventoryFilters: IncomingInventoryFilters)
+
+    fun getAll(ctx: Context) {
+        val filters = ctx.bodyAsClass<IIF>()
+        val tickets = searchIncomingInventory(filters.common, filters.incomingInventoryFilters)
+        val excel = ctx.queryParam("excel")
+        if (excel !== null) {
+            exportIncomingInventory(tickets)
+            val inputStream = FileInputStream("./excel/IncomingInventory.xls")
+            ctx.result(inputStream).status(HttpStatus.OK)
+        } else {
+            ctx.json(tickets).status(HttpStatus.OK)
+        }
+    }
+
+    fun getNextNum(ctx: Context) {
+        val prefix = "MRN/"
+        val cnt = database.find(IncomingInventory::class.java)
+            .findCount()
+            .toString()
+            .padStart(6, '0')
+        val seq = SequenceNumber(prefix + cnt)
+        ctx.json(seq).status(HttpStatus.OK)
+    }
+}
+
+object OutgoingInventoryCtrl {
+    fun create(ctx: Context) {
+        val ticket = ctx.bodyAsClass<OutgoingInventory>()
+        database.save(ticket)
+        ctx.json(ticket).status(HttpStatus.CREATED)
+    }
+
+    fun update(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val ticket =
+            database.find(OutgoingInventory::class.java, id) ?: throw NotFoundResponse("quote not found for $id")
+        val updatedTicket = ctx.bodyAsClass<OutgoingInventory>()
+        ticket.patchValues(updatedTicket)
+        ticket.update()
+        ctx.json(ticket).status(HttpStatus.OK)
+    }
+
+    fun get(ctx: Context) {
+        val id = ctx.pathParam("id").toLong()
+        val ticket = database.find(OutgoingInventory::class.java, id)
+            ?: throw NotFoundResponse("No incoming inventory ticket found with id $id")
+        ctx.json(ticket).status(HttpStatus.OK)
+    }
+
+    data class OIF(val common: CommonFilters, val outgoingInventoryFilters: OutgoingInventoryFilters)
+
+    fun getAll(ctx: Context) {
+        val filters = ctx.bodyAsClass<OIF>()
+        val tickets = searchOutgoingInventory(filters.common, filters.outgoingInventoryFilters)
+        val excel = ctx.queryParam("excel")
+        if (excel !== null) {
+            exportOutgoingInventory(tickets)
+            val inputStream = FileInputStream("./excel/OutgoingInventory.xls")
+            ctx.result(inputStream).status(HttpStatus.OK)
+        } else {
+            ctx.json(tickets).status(HttpStatus.OK)
+        }
+    }
+
+    fun getNextNum(ctx: Context) {
+        println("inside next num")
+        val prefix = "MDN/"
+        val cnt = database.find(OutgoingInventory::class.java)
+            .findCount()
+            .toString()
+            .padStart(6, '0')
+        val seq = SequenceNumber(prefix + cnt)
+        ctx.json(seq).status(HttpStatus.OK)
+    }
+}

src/main/kotlin/com/restapi/controllers/Excel.kt

@@ -0,0 +1,587 @@
+package com.restapi.controllers
+
+import com.google.gson.Gson
+import com.restapi.domain.*
+import com.restapi.domain.Document
+import com.restapi.domain.PurchaseOrder
+import com.restapi.domain.Quotation
+import com.restapi.domain.Session.currentUser
+import org.apache.poi.hssf.usermodel.HSSFSheet
+import org.apache.poi.hssf.usermodel.HSSFWorkbook
+import com.restapi.domain.Session.database
+import com.restapi.domain.Vendor
+import org.apache.poi.hssf.usermodel.DVConstraint
+import org.apache.poi.hssf.usermodel.HSSFDataValidation
+import org.apache.poi.ss.usermodel.Cell
+import org.apache.poi.ss.usermodel.CellType
+import org.apache.poi.ss.usermodel.DateUtil
+import org.apache.poi.ss.usermodel.Workbook
+import org.apache.poi.ss.usermodel.WorkbookFactory
+import org.apache.poi.ss.util.CellRangeAddressList
+import java.io.File
+import java.io.FileInputStream
+import java.io.FileOutputStream
+import java.text.SimpleDateFormat
+import java.time.LocalDate
+import java.time.ZoneId
+import java.util.*
+
+fun createHeaderRow(cols: List<String>, sh: HSSFSheet, wb: Workbook) {
+    val boldFont = wb.createFont()
+    boldFont.bold = true
+    val style = wb.createCellStyle()
+    style.setFont(boldFont)
+    style.locked = true
+
+    sh.createRow(0).apply {
+        cols.forEachIndexed { index, value ->
+            val cell = createCell(index)
+            cell.setCellValue(value)
+            cell.setCellStyle(style)
+        }
+    }
+}
+
+fun String.parseDate(format: String): Date? {
+    val locale = Locale.getDefault()
+    return try {
+        SimpleDateFormat(format, locale).parse(this)
+    } catch (e: Exception) {
+        null
+    }
+}
+
+fun dateFromCellHelper(cell: Cell): LocalDate? {
+    val date = when (cell.cellType) {
+        CellType.STRING -> cell.stringCellValue.parseDate("yyyy-MM-dd")
+        CellType.NUMERIC -> {
+            if (DateUtil.isCellDateFormatted(cell)) {
+                cell.getDateCellValue()
+            } else {
+                null
+            }
+        }
+
+        else -> null
+    }
+    return date?.toInstant()?.atZone(ZoneId.systemDefault())?.toLocalDate()
+}
+
+fun stringFromCellHelper(cell: Cell): String {
+    val string = when (cell.cellType) {
+        CellType.NUMERIC -> cell.numericCellValue.toString()
+        CellType.STRING -> cell.stringCellValue
+        else -> ""
+    }
+    return string
+}
+
+fun doubleFromCellHelper(cell: Cell): Double {
+    val double = when (cell.cellType) {
+        CellType.NUMERIC -> cell.numericCellValue
+        CellType.STRING -> cell.stringCellValue.toDoubleOrNull()
+        else -> 0.0
+    }
+    return double ?: 0.0
+}
+
+fun longIntFromCellHelper(cell: Cell): Long {
+    val long = when (cell.cellType) {
+        CellType.NUMERIC -> cell.numericCellValue.toLong()
+        CellType.STRING -> cell.stringCellValue.toLong()
+        else -> 0
+    }
+    return long
+}
+
+enum class FileType {
+    QUOTES, POS, VENDORS, PRODS, DOCS
+}
+
+enum class EnumFor {
+    UOM, DocType
+}
+fun saveExcelFileLocally(fileName: String, wb: Workbook) {
+    val path = "./excel/"
+    val out = FileOutputStream(path + fileName)
+    wb.use {
+        it.write(out)
+    }
+    out.close()
+}
+
+fun TemplateExcelFile(fileType: FileType) {
+    when (fileType) {
+        FileType.QUOTES -> {
+            val headers: List<String> = listOf(
+                "Quotation Number",
+                "Date",
+                "Open Till",
+                "Product Id",
+                "Product Name",
+                "Product Unit Price",
+                "Quantity",
+                "Vendor Name",
+                "Vendor Address",
+                "RFQ Number",
+                "Total Amount",
+                "Terms and Conditions"
+            )
+            val wb = HSSFWorkbook()
+            val sh = wb.createSheet()
+            createHeaderRow(headers, sh, wb)
+            saveExcelFileLocally("Quotes_Template.xls", wb)
+        }
+
+        FileType.POS -> {
+            val headers: List<String> = listOf(
+                "Number",
+                "Date",
+                "Open Till",
+                "Reference Quotation Number",
+                "Vendor Name",
+                "Vendor Address",
+                "Product Id",
+                "Product Name",
+                "Unit Price",
+                "Quantity",
+                "Total Amount",
+                "Terms and Conditions"
+            )
+            val wb = HSSFWorkbook()
+            val sh = wb.createSheet()
+            createHeaderRow(headers, sh, wb)
+            saveExcelFileLocally("Purchase_Order_Template.xls", wb)
+        }
+
+        FileType.VENDORS -> {
+            val headers: List<String> = listOf(
+                "Name",
+                "MSME",
+                "GST Number",
+                "Address",
+                "Rating",
+                "Contact Name",
+                "Contact Email",
+                "Contact Mobile"
+            )
+            val wb = HSSFWorkbook()
+            val sh = wb.createSheet()
+            createHeaderRow(headers, sh, wb)
+            saveExcelFileLocally("Vendors_Template.xls", wb)
+        }
+
+        FileType.PRODS -> {
+            val headers: List<String> = listOf("Id", "Name", "Description", "HSN Code", "UOM")
+            val wb = HSSFWorkbook()
+            val sh = wb.createSheet()
+            createHeaderRow(headers, sh, wb)
+            val r0 = CellRangeAddressList(0, 1000, 4, 4)
+            val dv0 = HSSFDataValidation(
+                r0,
+                DVConstraint.createExplicitListConstraint(arrayOf("LTR", "MTR", "NOS", "ALL"))
+            ).apply {
+                suppressDropDownArrow = true
+            }
+            sh.addValidationData(dv0)
+            saveExcelFileLocally("Products_Template.xls", wb)
+        }
+
+        FileType.DOCS -> {
+
+        }
+    }
+}
+
+fun exportQuotations(quotes: List<Quotation>) {
+    val wb = HSSFWorkbook()
+    val sh = wb.createSheet()
+
+    val headers: List<String> = listOf(
+        "Quotation Number",
+        "Date",
+        "Open Till",
+        "Product Id",
+        "Product Name",
+        "Product Unit Price",
+        "Quantity",
+        "Vendor Name",
+        "Vendor Address",
+        "RFQ Number",
+        "Total AMount",
+        "Terms and Conditions"
+    )
+    createHeaderRow(headers, sh, wb)
+    var rowCnt = 1
+    for (quote in quotes) {
+        val prodCnt = quote.products.size
+
+        for (j in 0..<prodCnt) {
+            val row = sh.createRow(rowCnt++)
+            var i = 0;
+            row.createCell(i++).setCellValue(quote.quoteNum)
+            row.createCell(i++).setCellValue(quote.quoteDate)
+            row.createCell(i++).setCellValue(quote.validTill)
+            //6 would be repeated
+            row.createCell(i++).setCellValue(quote.products[j].productId)
+            row.createCell(i++).setCellValue(quote.products[j].productName)
+            row.createCell(i++).setCellValue(quote.products[j].unitPrice)
+            row.createCell(i++).setCellValue(quote.products[j].quantity)
+
+            row.createCell(i++).setCellValue(quote.vendor?.name)
+            row.createCell(i++).setCellValue(quote.vendor?.address)
+
+            row.createCell(i++).setCellValue(quote.reqForQuoteNum)
+            row.createCell(i++).setCellValue(quote.totalAmount)
+
+            row.createCell(i++).setCellValue(quote.tnc?.joinToString(";"))
+        }
+    }
+    saveExcelFileLocally("Quotes.xls", wb)
+}
+
+fun exportVendors(vendors: List<Vendor>) {
+    val wb = HSSFWorkbook()
+    val sh = wb.createSheet()
+
+    val headers: List<String> =
+        listOf("No.", "Name", "MSME", "GST Number", "Address", "Rating", "Contact Name", "Contact Email", "Contact Mobile")
+    createHeaderRow(headers, sh, wb)
+
+    val totalCols = headers.size
+    var rowCnt = 1
+
+    for (vendor in vendors) {
+        val contactCnt = vendor.contacts.size
+        for (j in 0..<contactCnt) {
+            val row = sh.createRow(rowCnt++)
+            var i = 0
+            row.createCell(i++).setCellValue((rowCnt - 1).toString())
+            row.createCell(i++).setCellValue(vendor.name)
+            row.createCell(i++).setCellValue(vendor.msme)
+            row.createCell(i++).setCellValue(vendor.gstNumber)
+            row.createCell(i++).setCellValue(vendor.address)
+            row.createCell(i++).setCellValue(vendor.rating)
+            row.createCell(i++).setCellValue(vendor.contacts[j].name)
+            row.createCell(i++).setCellValue(vendor.contacts[j].email)
+            row.createCell(i++).setCellValue(vendor.contacts[j].mobile)
+        }
+    }
+    saveExcelFileLocally("VendorList.xls", wb)
+}
+
+fun exportProds(prods: List<Product>) {
+    val wb = HSSFWorkbook()
+    val sh = wb.createSheet()
+
+    val headers: List<String> = listOf("Id", "Name", "Description", "HSN Code", "UOM")
+    createHeaderRow(headers, sh, wb)
+
+    var rowCnt = 1
+
+    for (prod in prods) {
+        val row = sh.createRow(rowCnt++)
+        var i = 0
+        row.createCell(i++).setCellValue(prod.id.toString())
+        row.createCell(i++).setCellValue(prod.name)
+        row.createCell(i++).setCellValue(prod.description)
+        row.createCell(i++).setCellValue(prod.hsnCode)
+        row.createCell(i++).setCellValue(prod.uom?.name)
+    }
+    saveExcelFileLocally("Products.xls", wb)
+}
+
+fun exportPos(pos: List<PurchaseOrder>) {
+    val wb = HSSFWorkbook()
+    val sh = wb.createSheet()
+
+    val headers: List<String> = listOf(
+        "Number",
+        "Date",
+        "Open Till",
+        "Reference Quotation Number",
+        "Vendor Name",
+        "Vendor Address",
+        "Product Id",
+        "Product Name",
+        "Unit Price",
+        "Quantity",
+        "Total Amount",
+        "Terms and Conditions"
+    )
+    createHeaderRow(headers, sh, wb)
+
+    var rowCnt = 1
+    for (po in pos) {
+        val prodCnt = po.products.size
+
+        for (j in 0..<prodCnt) {
+            val row = sh.createRow(rowCnt++)
+            var i = 0
+            row.createCell(i++).setCellValue(po.poNum)
+            row.createCell(i++).setCellValue(po.poDate)
+            row.createCell(i++).setCellValue(po.validTill)
+            row.createCell(i++).setCellValue(po.referenceQuotation)
+            row.createCell(i++).setCellValue(po.vendor?.name)
+            row.createCell(i++).setCellValue(po.vendor?.address)
+
+            //6 would be repeated
+            row.createCell(i++).setCellValue(po.products[j].productId)
+            row.createCell(i++).setCellValue(po.products[j].productName)
+            row.createCell(i++).setCellValue(po.products[j].unitPrice)
+            row.createCell(i++).setCellValue(po.products[j].quantity)
+
+            row.createCell(i++).setCellValue(po.totalAmount)
+            row.createCell(i++).setCellValue(po.tnc?.joinToString(";"))
+        }
+    }
+    saveExcelFileLocally("Pos.xls", wb)
+}
+
+fun exportIncomingInventory(tickets : List<IncomingInventory>) {
+    val wb = HSSFWorkbook()
+    val sh = wb.createSheet()
+
+    val headers: List<String> = listOf(
+        "MRN",
+        "Date",
+        "Vendor Name",
+        "Vendor Bill Number",
+        "Vendor Bill Amount",
+        "Product Id",
+        "Product Name",
+        "Unit Price",
+        "Quantity",
+    )
+    createHeaderRow(headers, sh, wb)
+
+    var rowCnt = 1
+    for (ticket in tickets) {
+        val prodCnt = ticket.products?.size
+
+        for (j in 0..<prodCnt!!) {
+            val row = sh.createRow(rowCnt++)
+            var i = 0
+            row.createCell(i++).setCellValue(ticket.mrn)
+            row.createCell(i++).setCellValue(ticket.date)
+            row.createCell(i++).setCellValue(ticket.vendor?.name)
+            row.createCell(i++).setCellValue(ticket.vendorBillNum)
+            row.createCell(i++).setCellValue(ticket.vendorBillAmount)
+
+            //6 would be repeated
+            row.createCell(i++).setCellValue(ticket.products!![j].productId)
+            row.createCell(i++).setCellValue(ticket.products!![j].productName)
+            row.createCell(i++).setCellValue(ticket.products!![j].unitPrice)
+            row.createCell(i++).setCellValue(ticket.products!![j].quantity)
+
+        }
+    }
+    saveExcelFileLocally("IncomingInventory.xls", wb)
+}
+
+fun exportOutgoingInventory(tickets : List<OutgoingInventory>) {
+    val wb = HSSFWorkbook()
+    val sh = wb.createSheet()
+
+    val headers: List<String> = listOf(
+        "MDN",
+        "Date",
+        "Out Mode",
+        "Purpose",
+        "Product Id",
+        "Product Name",
+        "Unit Price",
+        "Quantity",
+    )
+    createHeaderRow(headers, sh, wb)
+
+    var rowCnt = 1
+    for (ticket in tickets) {
+        val prodCnt = ticket.products?.size
+
+        for (j in 0..<prodCnt!!) {
+            val row = sh.createRow(rowCnt++)
+            var i = 0
+            row.createCell(i++).setCellValue(ticket.mdn)
+            row.createCell(i++).setCellValue(ticket.date)
+            row.createCell(i++).setCellValue(ticket.outMode.toString())
+            row.createCell(i++).setCellValue(ticket.purpose)
+
+            //6 would be repeated
+            row.createCell(i++).setCellValue(ticket.products!![j].productId)
+            row.createCell(i++).setCellValue(ticket.products!![j].productName)
+            row.createCell(i++).setCellValue(ticket.products!![j].unitPrice)
+            row.createCell(i++).setCellValue(ticket.products!![j].quantity)
+
+        }
+    }
+    saveExcelFileLocally("OutgoingInventory.xls", wb)
+}
+fun main() {
+    //ImportFromExcel(FileType.QUOTES, "C:\\Users\\arsalan\\Downloads\\Book.xlsx")
+    TemplateExcelFile(FileType.PRODS)
+}
+
+fun ImportFromExcel(fileType: FileType, filePath: String) {
+    val wb = WorkbookFactory.create(File(filePath))
+    val sh = wb.getSheetAt(0)
+
+    when (fileType) {
+        FileType.QUOTES -> {
+            //Quote Number, ProductName, Product Quantity, Total Amount, RFQ Number, Quote Date, Valid Till, TNC[], Documents[]
+            val quotesMap: MutableMap<String, Quotation> = mutableMapOf()
+            val quotesList: List<Quotation> = mutableListOf()
+            sh.rowIterator().forEach { row ->
+                if (row == null) {
+                    //reached eof
+                    return@forEach
+                }
+                val quoteNumber = stringFromCellHelper(row.getCell(0))
+                val quoteDt = dateFromCellHelper(row.getCell(1))
+                val rfqNum = stringFromCellHelper(row.getCell(2))
+                val quoteValidTill = dateFromCellHelper(row.getCell(3))
+                val vendorName = stringFromCellHelper(row.getCell(4))
+                val vendorGstNum = stringFromCellHelper(row.getCell(5))
+                val vendorAddress = stringFromCellHelper(row.getCell(6))
+                val prodName = stringFromCellHelper(row.getCell(7))
+                val prodQuantity = doubleFromCellHelper(row.getCell(8))
+                val prodUnitPrice = doubleFromCellHelper(row.getCell(9))
+                val totalQuoteAmount = doubleFromCellHelper(row.getCell(10))
+                val prod = POProducts("", prodName, prodUnitPrice, prodQuantity)
+
+                if (quotesMap.containsKey(quoteNumber)) {
+                    //duplicated row
+                    quotesMap.get(quoteNumber)?.products?.add(prod)
+                } else {
+                    val v = Vendor()
+                    v.apply {
+                        name = vendorName
+                        address = vendorAddress
+                        gstNumber = vendorGstNum
+                    }
+                    val quote = Quotation()
+                    quote.apply {
+                        quoteNum = quoteNumber
+                        quoteDate = quoteDt
+                        reqForQuoteNum = rfqNum
+                        validTill = quoteValidTill
+                        products = mutableListOf(prod)
+                        vendor = v
+                        totalAmount = totalQuoteAmount
+                    }
+                    quotesMap.put(quoteNumber, quote)
+                }
+            }
+            //docs, tncs
+            // println("$quotesMap")
+
+//            quotesMap.forEach { (k, v) ->
+//                println("$v")
+//            }
+        }
+
+        FileType.POS -> {
+            //poNum, poDate, validTill, refQuoteNum, prodName, prodQuantity, totalAmount, products, vendorName, vendorGst, vendorAddress, tnc[]. docs[]
+            val PoMap: MutableMap<String, PurchaseOrder> = mutableMapOf()
+            sh.rowIterator().forEach { row ->
+                if (row == null) return@forEach
+                val poNum = stringFromCellHelper(row.getCell(0))
+                val poDate = dateFromCellHelper(row.getCell(1))
+                val refQuoteNum = stringFromCellHelper(row.getCell(2))
+                val poValidTill = dateFromCellHelper(row.getCell(3))
+                val prodName = stringFromCellHelper(row.getCell(4))
+                val prodQuantity = doubleFromCellHelper(row.getCell(5))
+                val vendorName = stringFromCellHelper(row.getCell(6))
+                val vendorGstNum = stringFromCellHelper(row.getCell(7))
+                val vendorAddress = stringFromCellHelper(row.getCell(8))
+                val totalPoAmount = doubleFromCellHelper(row.getCell(9))
+                //tncs, docs
+
+                val prod = POProducts("", prodName, 0.0, prodQuantity, "")
+                if (PoMap.containsKey(poNum)) {
+                    //repeated row
+                    PoMap.get(poNum)?.products?.add(prod)
+                } else {
+                    val vendor = Vendor()
+                    vendor.name = vendorName
+                    vendor.address = vendorAddress
+                    vendor.gstNumber = vendorGstNum
+                    val po = PurchaseOrder()
+                    po.poNum = poNum
+                    po.poDate = poDate
+                    po.referenceQuotation = refQuoteNum
+                    po.validTill = poValidTill
+                    PoMap.put(poNum, po)
+                }
+            }
+        }
+
+        FileType.VENDORS -> {
+            sh.rowIterator().forEach { row ->
+                //name, msme, gstNum, addresss, rating, contacts
+                if (row == null) return@forEach
+                val name = stringFromCellHelper(row.getCell(0))
+                val msme = stringFromCellHelper(row.getCell(1))
+                val gstNum = stringFromCellHelper(row.getCell(2))
+                val address = stringFromCellHelper(row.getCell(3))
+                val rating = doubleFromCellHelper(row.getCell(4))
+
+                //vendor object
+                val vendor = Vendor()
+                vendor.name = name
+                vendor.address = address
+                vendor.msme = msme
+                vendor.gstNumber = gstNum
+                vendor.rating = rating
+            }
+        }
+
+        FileType.PRODS -> {
+            sh.rowIterator().forEach { row ->
+                if (row == null) return@forEach
+                //id, name, description, hsnCode, uom
+                val prodId = longIntFromCellHelper(row.getCell(0))
+                val prodName = stringFromCellHelper(row.getCell(1))
+                val prodDesc = stringFromCellHelper(row.getCell(2))
+                val prodHsnCode = stringFromCellHelper(row.getCell(3))
+                val prodUom = stringFromCellHelper(row.getCell(4))
+
+                //new prod object
+                val prod = Product()
+                prod.id = prodId
+                prod.name = prodName
+                prod.description = prodDesc
+                prod.hsnCode = prodHsnCode
+                prod.uom = when (prodUom) {
+                    "nos" -> UOM.NOS
+                    "ltr" -> UOM.LTR
+                    "mtr" -> UOM.MTR
+                    else -> UOM.ALL
+                }
+            }
+        }
+
+        FileType.DOCS -> {
+            sh.rowIterator().forEach { row ->
+                //Document Name, Document Type, RefID, url
+                if (row == null) return@forEach
+                val docName = stringFromCellHelper(row.getCell(0))
+                val docType = stringFromCellHelper(row.getCell(1))
+                val refId = stringFromCellHelper(row.getCell(2))
+                val url = stringFromCellHelper(row.getCell(3))
+
+                //new doc object
+                val doc = Document()
+                doc.name = docName
+                doc.typeOfDoc = when (docType) {
+                    "quote" -> DocType.QUOTE
+                    "po" -> DocType.PO
+                    "invoice" -> DocType.INVOICE
+                    else -> DocType.ALL
+                }
+                doc.refIdOfDoc = refId.toLong()
+                doc.url = url
+            }
+        }
+    }
+}

src/main/kotlin/com/restapi/controllers/Filters.kt

@@ -0,0 +1,228 @@
+package com.restapi.controllers
+
+import com.restapi.domain.*
+import com.restapi.domain.Session.database
+import java.time.LocalDate
+
+//constants
+const val IGNORE = "%"
+val baseDate: LocalDate = LocalDate.of(1500, 1, 1)
+val maxDate: LocalDate = LocalDate.of(3000, 1, 1)
+const val RATING_MAX = 10.0
+const val RATING_MIN = 0.0
+
+//common filters would be used by most of the handlers
+//require a list of vendor ids to be passed
+data class CommonFilters(
+    val from: LocalDate = baseDate,
+    val to: LocalDate = maxDate,
+    val vendor: List<Long>? = null,
+    val sortAsc: Boolean = true,
+    val sortBy: String = IGNORE
+)
+
+interface CustomFilters {}
+
+data class POFilters(
+    val poNumLike: String = IGNORE,
+    val totalAmountExceeds: Long = Long.MIN_VALUE,
+    val totalAmountLessThan: Long = Long.MAX_VALUE,
+    val validAfter: LocalDate = baseDate,
+    val validBefore: LocalDate = maxDate,
+    val refQuotation: String = IGNORE,
+) : CustomFilters
+
+data class ProductFilters(
+    val nameLike: String = IGNORE,
+    val hsnLike: String = IGNORE,
+    val uom: UOM = UOM.ALL,
+) : CustomFilters
+
+data class DocumentFilters(
+    val nameLike: String = IGNORE,
+    val typeOfDoc: DocType = DocType.ALL,
+    val docDateFrom: LocalDate = baseDate,
+    val docDataTo: LocalDate = maxDate,
+) : CustomFilters
+
+data class RFQFilters(
+    val validBefore: LocalDate = maxDate,
+    val validAfter: LocalDate = baseDate,
+    val reqForQuoteNumLike: String = IGNORE,
+) : CustomFilters
+
+data class QuoteFilters(
+    val quoteNumLike: String = IGNORE,
+    val validBefore: LocalDate = maxDate,
+    val validAfter: LocalDate = baseDate,
+    val totalAmountExceeds: Long = Long.MIN_VALUE,
+    val totalAmountLessThan: Long = Long.MAX_VALUE,
+) : CustomFilters
+
+data class VendorFilters(
+    val nameLike: String = IGNORE,
+    val msmeLike: String = IGNORE,
+    val gstNumLike: String = IGNORE,
+    val addressLike: String = IGNORE,
+    val ratingExceeds: Double = RATING_MIN,
+    val ratingLessThan: Double = RATING_MAX,
+) : CustomFilters
+
+data class IncomingInventoryFilters(
+    val mrnLike: String = IGNORE,
+    val vehicleLike: String = IGNORE,
+    val vendorBillAmountExceeds: Double = Double.MIN_VALUE,
+    val vendorBillAmountLessThan: Double = Double.MAX_VALUE
+) : CustomFilters
+
+data class OutgoingInventoryFilters(
+    val mdnLike: String = IGNORE,
+    val purposeLike: String = IGNORE,
+    val personLike: String = IGNORE,
+    val vehicleLike: String = IGNORE,
+    val outMode: OutMode = OutMode.ALL
+) : CustomFilters
+
+fun <T> applyVendorHelper(q: io.ebean.ExpressionList<T>, vids: List<Long>?) {
+    if (vids.isNullOrEmpty()) return
+//    q.apply {
+//        q.`in`("vendor", vids)
+//    }
+//    println(vids)
+//    println(vids[0])
+    q.eq("vendor_sys_pk", vids[0])
+}
+
+fun <T> applySortHelper(q: io.ebean.ExpressionList<T>, sortBy: String, asc: Boolean) {
+    if (sortBy == IGNORE) return;
+    val order = if (asc) "ASC" else "DESC"
+    q.orderBy("$sortBy $order")
+}
+
+fun <T> applyFromToHelper(q: io.ebean.ExpressionList<T>, fromDate: LocalDate, toDate: LocalDate, colName: String) {
+    q.ge(colName, fromDate)
+        .le(colName, toDate)
+}
+
+fun <T> applyCommonFilters(q: io.ebean.ExpressionList<T>, commonFilters: CommonFilters) {
+    applyVendorHelper<T>(q, commonFilters.vendor)
+    applySortHelper<T>(q, commonFilters.sortBy, commonFilters.sortAsc)
+}
+
+fun searchQuotes(commonFilters: CommonFilters, quoteFilters: QuoteFilters): List<Quotation> {
+    val q = database.find(Quotation::class.java)
+        .where()
+        .ge("quoteDate", commonFilters.from)
+        .le("quoteDate", commonFilters.to)
+        .ge("validTill", quoteFilters.validAfter)
+        .le("validTill", quoteFilters.validBefore)
+        .ge("totalAmount", quoteFilters.totalAmountExceeds)
+        .le("totalAmount", quoteFilters.totalAmountLessThan)
+        .ilike("quoteNum", "%" + quoteFilters.quoteNumLike + "%")
+    applyFromToHelper(q, commonFilters.from, commonFilters.to, "quoteDate")
+    applyVendorHelper(q, commonFilters.vendor)
+    applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
+    return q.findList()
+}
+
+fun searchVendors(commonFilters: CommonFilters, vendorFilters: VendorFilters): List<Vendor> {
+    val q = database.find(Vendor::class.java)
+        .where()
+        .ge("rating", vendorFilters.ratingExceeds)
+        .le("rating", vendorFilters.ratingLessThan)
+        .ilike("name", "%" + vendorFilters.nameLike + "%")
+        .ilike("msme", "%" + vendorFilters.msmeLike + "%")
+        .ilike("gstNumber", "%" + vendorFilters.gstNumLike + "%")
+        .ilike("address", "%" + vendorFilters.addressLike + "%")
+    applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
+    return q.findList()
+}
+
+fun searchProducts(commonFilters: CommonFilters, productFilters: ProductFilters): List<Product> {
+    val q = database.find(Product::class.java)
+        .where()
+        .ilike("name", "%" + productFilters.nameLike + "%")
+        .ilike("hsnCode", "%" + productFilters.hsnLike + "%")
+
+    if (productFilters.uom != UOM.ALL) {
+        q.eq("uom", productFilters.uom)
+    }
+    applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
+    return q.findList()
+}
+
+fun searchDocs(commonFilters: CommonFilters, documentFilters: DocumentFilters): List<Document> {
+    val q = database.find(Document::class.java)
+        .where()
+        .apply {
+            if (documentFilters.typeOfDoc != DocType.ALL) {
+                this.eq("docType", documentFilters.typeOfDoc)
+            }
+        }
+        .ilike("name", "%" + documentFilters.nameLike + "%")
+    applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
+    applyVendorHelper(q, commonFilters.vendor)
+    return q.findList()
+}
+
+fun searchPos(commonFilters: CommonFilters, poFilters: POFilters?): List<PurchaseOrder> {
+    val poFilters = poFilters ?: POFilters()
+    val q = database.find(PurchaseOrder::class.java)
+        .where()
+        .ge("totalAmount", poFilters.totalAmountExceeds)
+        .le("totalAmount", poFilters.totalAmountLessThan)
+        .ge("validTill", poFilters.validAfter)
+        .le("validTill", poFilters.validBefore)
+        .ilike("poNum", "%" + poFilters.poNumLike + "%")
+        .ilike("referenceQuotation", "%" + poFilters.refQuotation + "%")
+    applyFromToHelper(q, commonFilters.from, commonFilters.to, "poDate")
+    applyVendorHelper(q, commonFilters.vendor)
+    applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
+    return q.findList()
+}
+
+fun searchRFQ(commonFilters: CommonFilters, rfqFilters: RFQFilters): List<ReqForQuote> {
+    val q = database.find(ReqForQuote::class.java)
+        .where()
+        .ge("validTill", rfqFilters.validAfter)
+        .le("validTill", rfqFilters.validBefore)
+        .ilike("reqForQuoteNum", "%" + rfqFilters.reqForQuoteNumLike + "%")
+    applyVendorHelper(q, commonFilters.vendor)
+    applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
+    return q.findList()
+}
+
+fun searchIncomingInventory(
+    commonFilters: CommonFilters,
+    incomingInventoryFilters: IncomingInventoryFilters
+): List<IncomingInventory> {
+    val q = database.find(IncomingInventory::class.java)
+        .where()
+        .ge("vendorBillAmount", incomingInventoryFilters.vendorBillAmountExceeds)
+        .le("vendorBillAmount", incomingInventoryFilters.vendorBillAmountLessThan)
+        .ilike("mrn", "%" + incomingInventoryFilters.mrnLike + "%")
+        .ilike("vehicle", "%" + incomingInventoryFilters.vehicleLike + "%")
+    applyFromToHelper(q, commonFilters.from, commonFilters.to, "date")
+    applyVendorHelper(q, commonFilters.vendor)
+    applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
+    return q.findList()
+}
+
+fun searchOutgoingInventory(
+    commonFilters: CommonFilters,
+    outgoingInventoryFilters: OutgoingInventoryFilters
+): List<OutgoingInventory> {
+    val q = database.find(OutgoingInventory::class.java)
+        .where()
+        .ilike("mdn", "%" + outgoingInventoryFilters.mdnLike + "%")
+        .ilike("purpose", "%" + outgoingInventoryFilters.purposeLike + "%")
+       // .ilike("person", "%" + outgoingInventoryFilters.personLike + "%")
+        //.ilike("vehicle", "%" + outgoingInventoryFilters.vehicleLike + "%")
+    if (outgoingInventoryFilters.outMode != OutMode.ALL) {
+        q.eq("outMode", outgoingInventoryFilters.outMode)
+    }
+    applyFromToHelper(q, commonFilters.from, commonFilters.to, "date")
+    applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
+
+    return q.findList()
+}

src/main/kotlin/com/restapi/domain/db.kt

@@ -30,6 +30,7 @@ import java.security.spec.PKCS8EncodedKeySpec
 import java.security.spec.X509EncodedKeySpec
 import java.time.LocalDateTime
 import java.util.*
+import kotlin.collections.HashMap
 import kotlin.jvm.optionals.getOrDefault
 
 
@@ -137,7 +138,27 @@ object Session {
 
 
     }
+    fun a(){
+        val a = HashMap<String,String>()
+        a.put("a", "b");
+        a.put("a", "b");
+        a.put("a", "b");
+        a.put("a", "b");
 
+        val b = HashMap<String,String>().apply {
+            put("a", "b");
+            put("a", "b");
+            put("a", "b");
+            put("a", "b");
+        }
+
+        val c: String? = ""
+        val x = c?.get(1)
+
+        c?.apply {
+            //will work only when c is not null
+        }
+    }
     private val sc = DatabaseConfig().apply {
         loadFromProperties(Properties().apply {
             setProperty("datasource.db.username", appConfig.dbUser())
@@ -180,7 +201,7 @@ object Session {
         val s = database
             .sqlQuery("SELECT nextval('${seqName(entity)}');")
             .findOne()?.getLong("nextval") ?: throw DataNotFoundException
-        return String.format("%s-%s", entity, "$s".padStart(10, '0'))
+        return "$entity-${"$s".padStart(10, '0')}"
     }
 
     val redis = JedisPooled(appConfig.redisUri().getOrDefault("redis://localhost:6739/0"))

src/main/kotlin/com/restapi/domain/migration.kt

@@ -8,7 +8,7 @@ object DBMigration {
     private fun create(){
         val dbMigration: DbMigration = DbMigration.create()
         dbMigration.setPlatform(Platform.POSTGRES)
-
+        //dbMigration.setGeneratePendingDrop("1.8")
         dbMigration.generateMigration()
     }
 

src/main/kotlin/com/restapi/domain/models.kt

@@ -5,21 +5,21 @@ import com.fasterxml.jackson.databind.DeserializationContext
 import com.fasterxml.jackson.databind.JsonDeserializer
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize
 import io.ebean.Model
-import io.ebean.annotation.DbArray
+import io.ebean.annotation.*
-import io.ebean.annotation.DbDefault
-import io.ebean.annotation.DbJsonB
 import io.ebean.annotation.Index
-import io.ebean.annotation.Platform
+import java.time.LocalDate
-import io.ebean.annotation.SoftDelete
-import io.ebean.annotation.TenantId
-import io.ebean.annotation.WhenCreated
-import io.ebean.annotation.WhenModified
-import io.ebean.annotation.WhoCreated
-import io.ebean.annotation.WhoModified
 import java.time.LocalDateTime
 import javax.persistence.*
 
 data class Comments(val text: String = "", val by: String = "", val at: LocalDateTime = LocalDateTime.now())
+data class POProducts(
+    val productId: String = "",
+    val productName: String = "",
+    val unitPrice: Double = 0.0,
+    val quantity: Double = 0.0,
+    val description: String = ""
+)
+
 
 enum class ApprovalStatus {
     PENDING, APPROVED, REJECTED
@@ -48,7 +48,6 @@ abstract class BaseModel : Model() {
     var modifiedAt: LocalDateTime? = null
 
 
-
     @WhoCreated
     var createdBy: String = ""
 
@@ -61,6 +60,7 @@ abstract class BaseModel : Model() {
 
     @DbDefault("0")
     var currentApprovalLevel: Int = 0
+
     @DbDefault("0")
     var requiredApprovalLevels: Int = 0
 
@@ -110,11 +110,17 @@ open class AuditLog : BaseTenantModel() {
     var uniqueIdentifier: String = ""
 
     @DbJsonB
-    @Index(definition = "create index audit_log_values_idx on audit_log using GIN (data)", platforms = [Platform.POSTGRES])
+    @Index(
+        definition = "create index audit_log_values_idx on audit_log using GIN (data)",
+        platforms = [Platform.POSTGRES]
+    )
     var data: Map<String, Any> = hashMapOf()
 
     @DbJsonB
-    @Index(definition = "create index audit_log_changes_idx on audit_log using GIN (changes)", platforms = [Platform.POSTGRES])
+    @Index(
+        definition = "create index audit_log_changes_idx on audit_log using GIN (changes)",
+        platforms = [Platform.POSTGRES]
+    )
     var changes: Map<String, Any> = hashMapOf()
 }
 
@@ -171,7 +177,7 @@ enum class JobType {
 
 @Entity
 @Index(unique = true, name = "sql_unique_id", columnNames = ["entity_name", "sql_id", "tenant_id"])
-open class SqlModel : BaseTenantModel(){
+open class SqlModel : BaseTenantModel() {
 
     @JsonDeserialize(using = SafeStringDeserializer::class)
     var sqlId: String = ""
@@ -181,6 +187,7 @@ open class SqlModel : BaseTenantModel(){
     @Column(columnDefinition = "text")
     var sql: String = ""
 }
+
 @Entity
 open class JobModel : BaseTenantModel() {
     @Index(unique = true)
@@ -216,6 +223,20 @@ open class DataModel : BaseTenantModel() {
 
 }
 
+
+@Entity
+@Index(unique = true, name = "unique_session_id", columnNames = ["session_id"])
+open class AnonSession : BaseTenantModel() {
+
+    var sessionId: String? = null
+    var ip: String? = null
+    var firstSeenAt: LocalDateTime? = null
+    var lastSeenAt: LocalDateTime? = null
+
+    @DbJsonB
+    var headerMap: Map<String, String> = hashMapOf()
+}
+
 class SafeStringDeserializer : JsonDeserializer<String>() {
     private val regex = Regex("^[a-zA-Z0-9\\-_\\.]+$")
 
@@ -225,5 +246,215 @@ class SafeStringDeserializer : JsonDeserializer<String>() {
         if (!regex.matches(text)) throw IllegalArgumentException()
         return text
     }
+}
+
+data class ContactPerson(val name: String = "", val email: String = "", val mobile: String = "")
+
+@Entity
+open class Vendor : BaseTenantModel() {
+    fun patchValues(updatedVendor: Vendor) {
+        this.name = updatedVendor.name
+        this.msme = updatedVendor.msme
+        this.gstNumber = updatedVendor.gstNumber
+        this.address = updatedVendor.address
+        this.rating = updatedVendor.rating
+        this.contacts = updatedVendor.contacts
+    }
+
+    var name: String = ""
+    var msme: String = ""
+    var gstNumber: String = ""
+    var address: String = ""
+    var rating: Double = 0.0
+
+    @DbJsonB
+    var contacts: List<ContactPerson> = mutableListOf()
+}
+
+@Entity
+open class PurchaseOrder : BaseTenantModel() {
+    fun patchValues(updatedPo: PurchaseOrder) {
+        this.poDate = updatedPo.poDate
+        this.validTill = updatedPo.validTill
+        this.tnc = updatedPo.tnc
+        this.products = updatedPo.products
+        this.vendor = updatedPo.vendor
+        this.documents = updatedPo.documents
+        this.totalAmount = updatedPo.totalAmount
+    }
+
+    @DbJsonB
+    var products: MutableList<POProducts> = mutableListOf()
+
+    @ManyToOne
+    var vendor: Vendor? = null
+    var referenceQuotation: String? = ""
+    var totalAmount: Double = 0.0
+    var poNum: String = ""
+    var poDate: LocalDate? = null
+    var validTill: LocalDate? = null
+
+    @DbArray
+    var tnc: List<String>? = arrayListOf()
+
+    @DbArray
+    var documents: List<String>? = arrayListOf()
+}
+
+enum class UOM {
+    NOS, LTR, MTR, ALL
+}
+
+enum class TypeOfProduct {
+    RAW_MATERIAL
+}
+
+@Entity
+open class Product : BaseTenantModel() {
+    fun patchValues(updatedProduct: Product) {
+        this.name = updatedProduct.name
+        this.description = updatedProduct.description
+        this.hsnCode = updatedProduct.hsnCode
+        this.uom = updatedProduct.uom
+    }
+
+    var id: Long? = null
+    var name: String = ""
+    var description: String = ""
+    var hsnCode: String = ""
+
+    @Enumerated(EnumType.STRING)
+    var uom: UOM? = null
+
+    @Enumerated(EnumType.STRING)
+    var type: TypeOfProduct? = null
+
 
 }
+
+@Entity
+open class Quotation : BaseTenantModel() {
+    fun patchValues(updatedQuote: Quotation) {
+        this.quoteDate = updatedQuote.quoteDate
+        this.vendorQuoteNum = updatedQuote.vendorQuoteNum
+        this.validTill = updatedQuote.validTill
+        this.reqForQuoteNum = updatedQuote.reqForQuoteNum
+        this.tnc = updatedQuote.tnc
+        this.products = updatedQuote.products
+        this.vendor = updatedQuote.vendor
+        this.documents = updatedQuote.documents
+        this.totalAmount = updatedQuote.totalAmount
+    }
+
+    @DbJsonB
+    var products: MutableList<POProducts> = mutableListOf()
+
+    @ManyToOne
+    var vendor: Vendor? = null
+    var totalAmount: Double = 0.0
+
+    var reqForQuoteNum: String? = ""
+    var quoteNum: String = ""
+    var vendorQuoteNum: String? = ""
+    var quoteDate: LocalDate? = null
+    var validTill: LocalDate? = null
+
+    @DbArray
+    var tnc: List<String>? = arrayListOf()
+
+    @DbArray
+    var documents: List<String>? = arrayListOf()
+
+    var taxesIncluded: Boolean ?= null
+}
+
+enum class DocType {
+    PO, QUOTE, INVOICE, ALL
+}
+
+@Entity
+open class Document : BaseTenantModel() {
+    var name: String = ""
+
+    @Enumerated(EnumType.STRING)
+    var typeOfDoc: DocType? = null
+
+    //could be quoteNum, PoNum, InvoiceNum
+    var refIdOfDoc: Long? = null
+    var description: String = ""
+    var url: String = ""
+    var docDate: LocalDate? = null
+}
+
+enum class RFQStatus {
+    DELIVERED, PO, QUOTE, CANCELLED
+}
+
+@Entity
+open class ReqForQuote : BaseTenantModel() {
+    @DbArray
+    var potentialVendors: List<Long>? = null
+
+    @Enumerated(EnumType.STRING)
+    var status: RFQStatus? = null
+
+    @DbJsonB
+    var products: List<POProducts>? = null
+    var reqForQuoteNum: String? = null
+    var openTill: LocalDate? = null
+}
+
+@Entity
+open class IncomingInventory : BaseTenantModel() {
+    fun patchValues(updated: IncomingInventory) {
+        this.date = updated.date
+        this.vendorBillNum = updated.vendorBillNum
+        this.vendorBillAmount = updated.vendorBillAmount
+        this.vehicle = updated.vehicle
+        this.products = updated.products
+        this.vendor = updated.vendor
+    }
+
+    var mrn: String? = null
+    var date: LocalDate? = null
+    var vendorBillNum: String? = null
+    var vendorBillAmount: Double = 0.0
+    var vehicle: String = ""
+
+    @DbJsonB
+    var products: List<POProducts>? = null
+
+    @ManyToOne
+    var vendor: Vendor? = null
+}
+
+
+enum class OutMode {
+    PERSON, VEHICLE, ALL
+}
+
+@Entity
+open class OutgoingInventory : BaseTenantModel() {
+    fun patchValues(updated: OutgoingInventory) {
+        this.date = updated.date
+        this.products = updated.products
+        this.purpose = updated.purpose
+        this.outMode = updated.outMode
+        this.person = updated.person
+        this.vehicle = updated.vehicle
+
+    }
+
+    var mdn: String? = null
+    var date: LocalDate? = null
+
+    @DbJsonB
+    var products: List<POProducts>? = null
+    var purpose: String? = null
+
+    @Enumerated(EnumType.STRING)
+    var outMode: OutMode? = null
+
+    var person: String? = null
+    var vehicle: String? = null
+}

src/main/kotlin/com/restapi/integ/ExternalAPI.kt

@@ -0,0 +1,190 @@
+package com.restapi.integ
+
+import com.fasterxml.jackson.annotation.JsonProperty
+import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
+import com.fasterxml.jackson.module.kotlin.readValue
+import com.restapi.config.AppConfig
+import io.minio.MinioClient
+import io.minio.UploadObjectArgs
+import org.apache.http.client.methods.HttpGet
+import org.apache.http.client.utils.URIBuilder
+import org.apache.http.impl.client.HttpClients
+import org.apache.http.message.BasicNameValuePair
+import org.apache.http.util.EntityUtils
+import org.slf4j.LoggerFactory
+import java.io.File
+
+val logger = LoggerFactory.getLogger("ExternalAPI")
+
+object S3 {
+    private val s3Url = AppConfig.appConfig.s3Url().orElse("s3.amazonaws.com")
+    private val minioClient: MinioClient by lazy {
+        MinioClient.builder()
+            .endpoint("https://$s3Url")
+            .credentials(
+                AppConfig.appConfig.s3AccessKey().orElseThrow(),
+                AppConfig.appConfig.s3SecretKey().orElseThrow()
+            ).build()
+    }
+
+    fun uploadFilesToS3(f: File, name: String): Result<String> {
+        val objStore: String = AppConfig.appConfig.s3Bucket().orElseThrow()
+        logger.warn("Trying to upload Object ${f.absolutePath} -> $objStore")
+
+        try {
+            minioClient.uploadObject(
+                UploadObjectArgs.builder()
+                    .bucket(objStore)
+                    .`object`(name)
+                    .filename(f.absolutePath)
+                    .build()
+            )
+            return Result.success("https://${objStore}.${s3Url}/$name")
+        } catch (e: Exception) {
+            logger.warn("Error in file Upload ${f.absolutePath} ==> ${e.message} => Objstore[${objStore}]")
+            return Result.failure(e)
+        }
+    }
+
+}
+
+
+data class LoqateFullAddrResponse(
+    @JsonProperty("Items")
+    val items: List<Item>
+) {
+    data class Item(
+        @JsonProperty("AdminAreaCode")
+        val adminAreaCode: String,
+        @JsonProperty("AdminAreaName")
+        val adminAreaName: String,
+        @JsonProperty("Barcode")
+        val barcode: String,
+        @JsonProperty("Block")
+        val block: String,
+        @JsonProperty("BuildingName")
+        val buildingName: String,
+        @JsonProperty("BuildingNumber")
+        val buildingNumber: String,
+        @JsonProperty("City")
+        val city: String,
+        @JsonProperty("Company")
+        val company: String,
+        @JsonProperty("CountryIso2")
+        val countryIso2: String,
+        @JsonProperty("CountryIso3")
+        val countryIso3: String,
+        @JsonProperty("CountryIsoNumber")
+        val countryIsoNumber: String,
+        @JsonProperty("CountryName")
+        val countryName: String,
+        @JsonProperty("DataLevel")
+        val dataLevel: String,
+        @JsonProperty("Department")
+        val department: String,
+        @JsonProperty("District")
+        val district: String,
+        @JsonProperty("DomesticId")
+        val domesticId: String,
+        @JsonProperty("Field1")
+        val field1: String,
+        @JsonProperty("Field10")
+        val field10: String,
+        @JsonProperty("Field11")
+        val field11: String,
+        @JsonProperty("Field12")
+        val field12: String,
+        @JsonProperty("Field13")
+        val field13: String,
+        @JsonProperty("Field14")
+        val field14: String,
+        @JsonProperty("Field15")
+        val field15: String,
+        @JsonProperty("Field16")
+        val field16: String,
+        @JsonProperty("Field17")
+        val field17: String,
+        @JsonProperty("Field18")
+        val field18: String,
+        @JsonProperty("Field19")
+        val field19: String,
+        @JsonProperty("Field2")
+        val field2: String,
+        @JsonProperty("Field20")
+        val field20: String,
+        @JsonProperty("Field3")
+        val field3: String,
+        @JsonProperty("Field4")
+        val field4: String,
+        @JsonProperty("Field5")
+        val field5: String,
+        @JsonProperty("Field6")
+        val field6: String,
+        @JsonProperty("Field7")
+        val field7: String,
+        @JsonProperty("Field8")
+        val field8: String,
+        @JsonProperty("Field9")
+        val field9: String,
+        @JsonProperty("Id")
+        val id: String,
+        @JsonProperty("Label")
+        val label: String,
+        @JsonProperty("Language")
+        val language: String,
+        @JsonProperty("LanguageAlternatives")
+        val languageAlternatives: String,
+        @JsonProperty("Line1")
+        val line1: String,
+        @JsonProperty("Line2")
+        val line2: String,
+        @JsonProperty("Line3")
+        val line3: String,
+        @JsonProperty("Line4")
+        val line4: String,
+        @JsonProperty("Line5")
+        val line5: String,
+        @JsonProperty("Neighbourhood")
+        val neighbourhood: String,
+        @JsonProperty("POBoxNumber")
+        val pOBoxNumber: String,
+        @JsonProperty("PostalCode")
+        val postalCode: String,
+        @JsonProperty("Province")
+        val province: String,
+        @JsonProperty("ProvinceCode")
+        val provinceCode: String,
+        @JsonProperty("ProvinceName")
+        val provinceName: String,
+        @JsonProperty("SecondaryStreet")
+        val secondaryStreet: String,
+        @JsonProperty("SortingNumber1")
+        val sortingNumber1: String,
+        @JsonProperty("SortingNumber2")
+        val sortingNumber2: String,
+        @JsonProperty("Street")
+        val street: String,
+        @JsonProperty("SubBuilding")
+        val subBuilding: String,
+        @JsonProperty("Type")
+        val type: String
+    )
+}
+
+object LoqateAPI {
+    //todo: add search?
+    fun findFullAddr(id: String): LoqateFullAddrResponse {
+        //https://api.addressy.com/Capture/Interactive/Retrieve/v1.2/
+        return HttpClients.createDefault().use { h ->
+            val key = AppConfig.appConfig.locateApiKey().orElseThrow()
+            val ub = URIBuilder("https://api.addressy.com/Capture/Interactive/Retrieve/v1.2/json3.ws")
+                .setParameters(
+                    BasicNameValuePair("Key", key),
+                    BasicNameValuePair("Id", id)
+                ).build()
+            h.execute(HttpGet(ub)).use {
+                jacksonObjectMapper().readValue(EntityUtils.toString(it.entity))
+            }
+        }
+    }
+}

src/main/resources/dbmigration/1.1.sql

@@ -0,0 +1,27 @@
+-- apply changes
+create table anon_session (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  first_seen_at                 timestamp,
+  last_seen_at                  timestamp,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  session_id                    varchar(255),
+  ip                            varchar(255),
+  header_map                    jsonb not null,
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_anon_session_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint unique_session_id unique (session_id),
+  constraint pk_anon_session primary key (sys_pk)
+);
+

src/main/resources/dbmigration/1.10__dropsFor_1.7.sql

@@ -0,0 +1,2 @@
+-- apply alter tables
+alter table incoming_inventory drop column vendor_bil_num;

src/main/resources/dbmigration/1.11__dropsFor_1.8.sql

@@ -0,0 +1,3 @@
+-- apply alter tables
+alter table incoming_inventory drop column mdn;
+alter table outgoing_inventory drop column mrn;

src/main/resources/dbmigration/1.2.sql

@@ -0,0 +1,140 @@
+-- apply changes
+create table document (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  name                          varchar(255) not null,
+  type_of_doc                   varchar(255) not null,
+  description                   varchar(255) not null,
+  url                           varchar(255) not null,
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_document_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint pk_document primary key (sys_pk)
+);
+
+create table product (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  name                          varchar(255) not null,
+  description                   varchar(255) not null,
+  hsn_code                      varchar(255) not null,
+  uom                           varchar(3),
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_product_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint ck_product_uom check ( uom in ('NOS','LTR','MTR')),
+  constraint pk_product primary key (sys_pk)
+);
+
+create table purchase_order (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  vendor_sys_pk                 bigint,
+  total_amount                  integer not null,
+  po_date                       date,
+  valid_till                    date,
+  documents                     bigint[] not null,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  products                      jsonb not null,
+  reference_quotation           varchar(255) not null,
+  po_num                        varchar(255) not null,
+  tnc                           varchar[] not null,
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_purchase_order_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint pk_purchase_order primary key (sys_pk)
+);
+
+create table quotation (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  vendor_sys_pk                 bigint,
+  total_amount                  integer not null,
+  quote_date                    date,
+  valid_till                    date,
+  documents                     bigint[] not null,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  products                      jsonb not null,
+  quote_num                     varchar(255) not null,
+  tnc                           varchar[] not null,
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_quotation_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint pk_quotation primary key (sys_pk)
+);
+
+create table vendor (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  rating                        float not null,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  name                          varchar(255) not null,
+  msme                          varchar(255) not null,
+  gst_number                    varchar(255) not null,
+  address                       varchar(255) not null,
+  contacts                      jsonb not null,
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_vendor_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint pk_vendor primary key (sys_pk)
+);
+
+-- foreign keys and indices
+create index ix_purchase_order_vendor_sys_pk on purchase_order (vendor_sys_pk);
+alter table purchase_order add constraint fk_purchase_order_vendor_sys_pk foreign key (vendor_sys_pk) references vendor (sys_pk) on delete restrict on update restrict;
+
+create index ix_quotation_vendor_sys_pk on quotation (vendor_sys_pk);
+alter table quotation add constraint fk_quotation_vendor_sys_pk foreign key (vendor_sys_pk) references vendor (sys_pk) on delete restrict on update restrict;
+

src/main/resources/dbmigration/1.3.sql

@@ -0,0 +1,43 @@
+-- drop dependencies
+alter table document drop constraint if exists ck_document_type_of_doc;
+alter table product drop constraint if exists ck_product_uom;
+-- apply changes
+create table req_for_quote (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  potential_vendors             bigint[],
+  open_till                     date,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  status                        varchar(9),
+  products                      jsonb,
+  req_for_quote_num             varchar(255),
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_req_for_quote_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint ck_req_for_quote_status check ( status in ('DELIVERED','PO','QUOTE','CANCELLED')),
+  constraint pk_req_for_quote primary key (sys_pk)
+);
+
+-- apply alter tables
+alter table document alter column type_of_doc type varchar(7) using type_of_doc::varchar(7);
+alter table document alter column type_of_doc drop not null;
+alter table document add column if not exists ref_id varchar(255);
+alter table document add column if not exists doc_date date;
+alter table product add column if not exists id bigint;
+alter table purchase_order alter column reference_quotation drop not null;
+alter table purchase_order alter column total_amount type float using total_amount::float;
+alter table quotation alter column total_amount type float using total_amount::float;
+alter table quotation add column if not exists req_for_quote_num varchar(255);
+-- apply post alter
+alter table document add constraint ck_document_type_of_doc check ( type_of_doc in ('PO','QUOTE','INVOICE','ALL'));
+alter table product add constraint ck_product_uom check ( uom in ('NOS','LTR','MTR','ALL'));

src/main/resources/dbmigration/1.4.sql

@@ -0,0 +1,8 @@
+-- apply alter tables
+alter table purchase_order alter column tnc drop not null;
+alter table purchase_order alter column documents type varchar[] using documents::varchar[];
+alter table purchase_order alter column documents drop not null;
+alter table quotation alter column tnc drop not null;
+alter table quotation alter column documents type varchar[] using documents::varchar[];
+alter table quotation alter column documents drop not null;
+alter table quotation add column if not exists vendor_quote_num varchar(255);

src/main/resources/dbmigration/1.5.sql

@@ -0,0 +1,2 @@
+-- apply alter tables
+alter table document add column if not exists ref_id_of_doc bigint;

src/main/resources/dbmigration/1.6.sql

@@ -0,0 +1,64 @@
+-- apply changes
+create table incoming_inventory (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  date                          date,
+  vendor_bill_amount            float not null,
+  vendor_sys_pk                 bigint,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  mdn                           varchar(255) not null,
+  vendor_bil_num                varchar(255) not null,
+  vehicle                       varchar(255) not null,
+  products                      jsonb,
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_incoming_inventory_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint pk_incoming_inventory primary key (sys_pk)
+);
+
+create table outgoing_inventory (
+  sys_pk                        bigint generated by default as identity not null,
+  deleted_on                    timestamp,
+  current_approval_level        integer default 0 not null,
+  required_approval_levels      integer default 0 not null,
+  date                          date,
+  deleted                       boolean default false not null,
+  version                       integer default 1 not null,
+  created_at                    timestamp default 'now()' not null,
+  modified_at                   timestamp default 'now()' not null,
+  deleted_by                    varchar(255),
+  approval_status               varchar(8) default 'APPROVED' not null,
+  tags                          varchar[] default '{}' not null,
+  comments                      jsonb default '[]' not null,
+  tenant_id                     varchar(255) not null,
+  mrn                           varchar(255) not null,
+  purpose                       varchar(255),
+  out_mode                      varchar(7),
+  person                        varchar(255),
+  vehicle                       varchar(255),
+  created_by                    varchar(255) not null,
+  modified_by                   varchar(255) not null,
+  constraint ck_outgoing_inventory_approval_status check ( approval_status in ('PENDING','APPROVED','REJECTED')),
+  constraint ck_outgoing_inventory_out_mode check ( out_mode in ('PERSON','VEHICLE','ALL')),
+  constraint pk_outgoing_inventory primary key (sys_pk)
+);
+
+-- apply alter tables
+alter table product add column if not exists type varchar(12);
+alter table quotation add column if not exists taxes_included boolean;
+-- apply post alter
+alter table product add constraint ck_product_type check ( type in ('RAW_MATERIAL'));
+-- foreign keys and indices
+create index ix_incoming_inventory_vendor_sys_pk on incoming_inventory (vendor_sys_pk);
+alter table incoming_inventory add constraint fk_incoming_inventory_vendor_sys_pk foreign key (vendor_sys_pk) references vendor (sys_pk) on delete restrict on update restrict;
+

src/main/resources/dbmigration/1.7.sql

@@ -0,0 +1,2 @@
+-- apply alter tables
+alter table incoming_inventory add column if not exists vendor_bill_num varchar(255);

src/main/resources/dbmigration/1.8.sql

@@ -0,0 +1,4 @@
+-- apply alter tables
+alter table incoming_inventory add column if not exists mrn varchar(255);
+alter table outgoing_inventory add column if not exists mdn varchar(255);
+alter table outgoing_inventory add column if not exists products jsonb;

src/main/resources/dbmigration/1.9__dropsFor_1.5.sql

@@ -0,0 +1,2 @@
+-- apply alter tables
+alter table document drop column ref_id;

src/main/resources/dbmigration/model/1.1.model.xml

@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply">
+        <createTable name="anon_session" pkName="pk_anon_session">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_anon_session_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="session_id" type="varchar"/>
+            <column name="ip" type="varchar"/>
+            <column name="first_seen_at" type="localdatetime"/>
+            <column name="last_seen_at" type="localdatetime"/>
+            <column name="header_map" type="jsonb" notnull="true"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+            <uniqueConstraint name="unique_session_id" columnNames="session_id" oneToOne="false" nullableColumns="session_id"/>
+        </createTable>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.10__dropsFor_1.7.model.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply" dropsFor="1.7">
+        <dropColumn columnName="vendor_bil_num" tableName="incoming_inventory"/>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.11__dropsFor_1.8.model.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply" dropsFor="1.8">
+        <dropColumn columnName="mdn" tableName="incoming_inventory"/>
+        <dropColumn columnName="mrn" tableName="outgoing_inventory"/>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.2.model.xml

@@ -0,0 +1,121 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply">
+        <createTable name="document" pkName="pk_document">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_document_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="name" type="varchar" notnull="true"/>
+            <column name="type_of_doc" type="varchar" notnull="true"/>
+            <column name="description" type="varchar" notnull="true"/>
+            <column name="url" type="varchar" notnull="true"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+        </createTable>
+        <createTable name="product" pkName="pk_product">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_product_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="name" type="varchar" notnull="true"/>
+            <column name="description" type="varchar" notnull="true"/>
+            <column name="hsn_code" type="varchar" notnull="true"/>
+            <column name="uom" type="varchar(3)" checkConstraint="check ( uom in ('NOS','LTR','MTR'))" checkConstraintName="ck_product_uom"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+        </createTable>
+        <createTable name="purchase_order" pkName="pk_purchase_order">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_purchase_order_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="products" type="jsonb" notnull="true"/>
+            <column name="vendor_sys_pk" type="bigint" references="vendor.sys_pk" foreignKeyName="fk_purchase_order_vendor_sys_pk" foreignKeyIndex="ix_purchase_order_vendor_sys_pk"/>
+            <column name="reference_quotation" type="varchar" notnull="true"/>
+            <column name="total_amount" type="integer" notnull="true"/>
+            <column name="po_num" type="varchar" notnull="true"/>
+            <column name="po_date" type="date"/>
+            <column name="valid_till" type="date"/>
+            <column name="tnc" type="varchar[]" notnull="true"/>
+            <column name="documents" type="bigint[]" notnull="true"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+        </createTable>
+        <createTable name="quotation" pkName="pk_quotation">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_quotation_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="products" type="jsonb" notnull="true"/>
+            <column name="vendor_sys_pk" type="bigint" references="vendor.sys_pk" foreignKeyName="fk_quotation_vendor_sys_pk" foreignKeyIndex="ix_quotation_vendor_sys_pk"/>
+            <column name="total_amount" type="integer" notnull="true"/>
+            <column name="quote_num" type="varchar" notnull="true"/>
+            <column name="quote_date" type="date"/>
+            <column name="valid_till" type="date"/>
+            <column name="tnc" type="varchar[]" notnull="true"/>
+            <column name="documents" type="bigint[]" notnull="true"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+        </createTable>
+        <createTable name="vendor" pkName="pk_vendor">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_vendor_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="name" type="varchar" notnull="true"/>
+            <column name="msme" type="varchar" notnull="true"/>
+            <column name="gst_number" type="varchar" notnull="true"/>
+            <column name="address" type="varchar" notnull="true"/>
+            <column name="rating" type="double" notnull="true"/>
+            <column name="contacts" type="jsonb" notnull="true"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+        </createTable>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.3.model.xml

@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply">
+        <alterColumn columnName="type_of_doc" tableName="document" type="varchar(7)" currentType="varchar" notnull="false" currentNotnull="true" checkConstraint="check ( type_of_doc in ('PO','QUOTE','INVOICE','ALL'))" checkConstraintName="ck_document_type_of_doc"/>
+        <addColumn tableName="document">
+            <column name="ref_id" type="varchar"/>
+            <column name="doc_date" type="date"/>
+        </addColumn>
+        <alterColumn columnName="uom" tableName="product" checkConstraint="check ( uom in ('NOS','LTR','MTR','ALL'))" checkConstraintName="ck_product_uom"/>
+        <addColumn tableName="product">
+            <column name="id" type="bigint"/>
+        </addColumn>
+        <alterColumn columnName="reference_quotation" tableName="purchase_order" currentType="varchar" notnull="false" currentNotnull="true"/>
+        <alterColumn columnName="total_amount" tableName="purchase_order" type="double" currentType="integer" currentNotnull="true"/>
+        <alterColumn columnName="total_amount" tableName="quotation" type="double" currentType="integer" currentNotnull="true"/>
+        <addColumn tableName="quotation">
+            <column name="req_for_quote_num" type="varchar"/>
+        </addColumn>
+        <createTable name="req_for_quote" pkName="pk_req_for_quote">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_req_for_quote_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="potential_vendors" type="bigint[]"/>
+            <column name="status" type="varchar(9)" checkConstraint="check ( status in ('DELIVERED','PO','QUOTE','CANCELLED'))" checkConstraintName="ck_req_for_quote_status"/>
+            <column name="products" type="jsonb"/>
+            <column name="req_for_quote_num" type="varchar"/>
+            <column name="open_till" type="date"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+        </createTable>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.4.model.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply">
+        <alterColumn columnName="tnc" tableName="purchase_order" currentType="varchar[]" notnull="false" currentNotnull="true"/>
+        <alterColumn columnName="documents" tableName="purchase_order" type="varchar[]" currentType="bigint[]" notnull="false" currentNotnull="true"/>
+        <alterColumn columnName="tnc" tableName="quotation" currentType="varchar[]" notnull="false" currentNotnull="true"/>
+        <alterColumn columnName="documents" tableName="quotation" type="varchar[]" currentType="bigint[]" notnull="false" currentNotnull="true"/>
+        <addColumn tableName="quotation">
+            <column name="vendor_quote_num" type="varchar"/>
+        </addColumn>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.5.model.xml

@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply">
+        <addColumn tableName="document">
+            <column name="ref_id_of_doc" type="bigint"/>
+        </addColumn>
+    </changeSet>
+    <changeSet type="pendingDrops">
+        <dropColumn columnName="ref_id" tableName="document"/>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.6.model.xml

@@ -0,0 +1,58 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply">
+        <createTable name="incoming_inventory" pkName="pk_incoming_inventory">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_incoming_inventory_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="mdn" type="varchar" notnull="true"/>
+            <column name="date" type="date"/>
+            <column name="vendor_bil_num" type="varchar" notnull="true"/>
+            <column name="vendor_bill_amount" type="double" notnull="true"/>
+            <column name="vehicle" type="varchar" notnull="true"/>
+            <column name="products" type="jsonb"/>
+            <column name="vendor_sys_pk" type="bigint" references="vendor.sys_pk" foreignKeyName="fk_incoming_inventory_vendor_sys_pk" foreignKeyIndex="ix_incoming_inventory_vendor_sys_pk"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+        </createTable>
+        <createTable name="outgoing_inventory" pkName="pk_outgoing_inventory">
+            <column name="sys_pk" type="bigint" primaryKey="true"/>
+            <column name="deleted_on" type="localdatetime"/>
+            <column name="deleted_by" type="varchar"/>
+            <column name="current_approval_level" type="integer" defaultValue="0" notnull="true"/>
+            <column name="required_approval_levels" type="integer" defaultValue="0" notnull="true"/>
+            <column name="approval_status" type="varchar(8)" defaultValue="'APPROVED'" notnull="true" checkConstraint="check ( approval_status in ('PENDING','APPROVED','REJECTED'))" checkConstraintName="ck_outgoing_inventory_approval_status"/>
+            <column name="tags" type="varchar[]" defaultValue="'{}'" notnull="true"/>
+            <column name="comments" type="jsonb" defaultValue="'[]'" notnull="true"/>
+            <column name="tenant_id" type="varchar" notnull="true"/>
+            <column name="mrn" type="varchar" notnull="true"/>
+            <column name="date" type="date"/>
+            <column name="purpose" type="varchar"/>
+            <column name="out_mode" type="varchar(7)" checkConstraint="check ( out_mode in ('PERSON','VEHICLE','ALL'))" checkConstraintName="ck_outgoing_inventory_out_mode"/>
+            <column name="person" type="varchar"/>
+            <column name="vehicle" type="varchar"/>
+            <column name="deleted" type="boolean" defaultValue="false" notnull="true"/>
+            <column name="version" type="integer" defaultValue="1" notnull="true"/>
+            <column name="created_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="modified_at" type="localdatetime" defaultValue="'now()'" notnull="true"/>
+            <column name="created_by" type="varchar" notnull="true"/>
+            <column name="modified_by" type="varchar" notnull="true"/>
+        </createTable>
+        <addColumn tableName="product">
+            <column name="type" type="varchar(12)" checkConstraint="check ( type in ('RAW_MATERIAL'))" checkConstraintName="ck_product_type"/>
+        </addColumn>
+        <addColumn tableName="quotation">
+            <column name="taxes_included" type="boolean"/>
+        </addColumn>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.7.model.xml

@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply">
+        <addColumn tableName="incoming_inventory">
+            <column name="vendor_bill_num" type="varchar"/>
+        </addColumn>
+    </changeSet>
+    <changeSet type="pendingDrops">
+        <dropColumn columnName="vendor_bil_num" tableName="incoming_inventory"/>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.8.model.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply">
+        <addColumn tableName="incoming_inventory">
+            <column name="mrn" type="varchar"/>
+        </addColumn>
+        <addColumn tableName="outgoing_inventory">
+            <column name="mdn" type="varchar"/>
+            <column name="products" type="jsonb"/>
+        </addColumn>
+    </changeSet>
+    <changeSet type="pendingDrops">
+        <dropColumn columnName="mdn" tableName="incoming_inventory"/>
+        <dropColumn columnName="mrn" tableName="outgoing_inventory"/>
+    </changeSet>
+</migration>

src/main/resources/dbmigration/model/1.9__dropsFor_1.5.model.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<migration xmlns="http://ebean-orm.github.io/xml/ns/dbmigration">
+    <changeSet type="apply" dropsFor="1.5">
+        <dropColumn columnName="ref_id" tableName="document"/>
+    </changeSet>
+</migration>

src/main/resources/logback.xml

@@ -1,4 +1,19 @@
 <configuration>
+    <appender name="ROLLING" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>api.log</file>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <FileNamePattern>api.%d{yyyy-MM-dd}.%i.log.gz</FileNamePattern>
+            <MaxHistory>30</MaxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy
+                    class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>100MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
     <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
         <encoder>
             <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
@@ -14,5 +29,6 @@
 
     <root level="info">
         <appender-ref ref="STDOUT" />
+        <appender-ref ref="ROLLING" />
     </root>
 </configuration>