Compare commits
14 Commits
2b60e9cc29
...
Vinay
| Author | SHA1 | Date | |
|---|---|---|---|
| cfa3a7e289 | |||
| d23ac5261d | |||
| 976aebec5b | |||
| a3f7614979 | |||
| 8745db2127 | |||
| 438daacdc6 | |||
|
|
dd55cd22cf | ||
|
|
aa97275b9c | ||
|
|
cfdb792aa5 | ||
| cb184dee3b | |||
| 043cddcaa0 | |||
|
|
20f6abf3b7 | ||
|
|
f440ca89f3 | ||
|
|
1abf482a7a |
18
.idea/dataSources.xml
generated
18
.idea/dataSources.xml
generated
@@ -6,6 +6,24 @@
|
|||||||
<synchronize>true</synchronize>
|
<synchronize>true</synchronize>
|
||||||
<jdbc-driver>org.postgresql.Driver</jdbc-driver>
|
<jdbc-driver>org.postgresql.Driver</jdbc-driver>
|
||||||
<jdbc-url>jdbc:postgresql://192.168.64.6:5432/uiapp</jdbc-url>
|
<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>
|
<working-dir>$ProjectFileDir$</working-dir>
|
||||||
</data-source>
|
</data-source>
|
||||||
</component>
|
</component>
|
||||||
|
|||||||
2
.idea/vcs.xml
generated
2
.idea/vcs.xml
generated
@@ -1,8 +1,6 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
<project version="4">
|
<project version="4">
|
||||||
<component name="VcsDirectoryMappings">
|
<component name="VcsDirectoryMappings">
|
||||||
<mapping directory="$PROJECT_DIR$/../rmc-modules-app" vcs="Git" />
|
|
||||||
<mapping directory="$PROJECT_DIR$" vcs="Git" />
|
<mapping directory="$PROJECT_DIR$" vcs="Git" />
|
||||||
<mapping directory="$PROJECT_DIR$/../txn_workflow" vcs="Git" />
|
|
||||||
</component>
|
</component>
|
||||||
</project>
|
</project>
|
||||||
78
api.http
78
api.http
@@ -5,10 +5,22 @@ Authorization: {{auth-token}}
|
|||||||
|
|
||||||
{
|
{
|
||||||
"data": {
|
"data": {
|
||||||
"number": "KA01HD6667",
|
"number": "KA01HD6677",
|
||||||
"owner": "gowthaman"
|
"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
|
### create row, with autogenerated identifier
|
||||||
@@ -23,6 +35,18 @@ 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 row
|
||||||
GET http://localhost:9001/api/log/log-0000000001
|
GET http://localhost:9001/api/log/log-0000000001
|
||||||
Authorization: Bearer {{auth-token}}
|
Authorization: Bearer {{auth-token}}
|
||||||
@@ -34,7 +58,7 @@ Authorization: Bearer {{auth-token}}
|
|||||||
### query row
|
### query row
|
||||||
POST http://localhost:9001/api/vehicle/query
|
POST http://localhost:9001/api/vehicle/query
|
||||||
Content-Type: application/json
|
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",
|
"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",
|
||||||
@@ -68,3 +92,51 @@ Authorization: {{auth-token}}
|
|||||||
### delete a row
|
### delete a row
|
||||||
DELETE http://localhost:9001/api/vehicle/KA01HD6667
|
DELETE http://localhost:9001/api/vehicle/KA01HD6667
|
||||||
Authorization: {{auth-token}}
|
Authorization: {{auth-token}}
|
||||||
|
|
||||||
|
### get products
|
||||||
|
GET http://localhost:9001/api/vendor/product
|
||||||
|
Authorization: {{auth-token}}
|
||||||
|
|
||||||
|
### get products by hsn code
|
||||||
|
GET http://localhost:9001/api/vendor/product/#123
|
||||||
|
Authorization: {{auth-token}}
|
||||||
|
|
||||||
|
### create excel for products
|
||||||
|
POST http://localhost:9001/api/vendor/product/product-excel
|
||||||
|
Authorization: {{auth-token}}
|
||||||
|
|
||||||
|
### excel read
|
||||||
|
GET http://localhost:9001/api/vendor/product/validation
|
||||||
|
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/#1
|
||||||
|
Authorization: {{auth-token}}
|
||||||
|
|
||||||
|
###
|
||||||
|
POST http://localhost:9001/api/vendor/product/import
|
||||||
|
Authorization: {{auth-token}}
|
||||||
@@ -19,6 +19,7 @@ app:
|
|||||||
scripts:
|
scripts:
|
||||||
path: /Users/gowthaman.b/IdeaProjects/rmc_modules_api/src/main/resources/scripts
|
path: /Users/gowthaman.b/IdeaProjects/rmc_modules_api/src/main/resources/scripts
|
||||||
security:
|
security:
|
||||||
|
enforce_role_restriction: 'true'
|
||||||
private_key: |-
|
private_key: |-
|
||||||
-----BEGIN PRIVATE KEY-----
|
-----BEGIN PRIVATE KEY-----
|
||||||
MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQD4ba8OhlyB9MUx
|
MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQD4ba8OhlyB9MUx
|
||||||
|
|||||||
@@ -36,6 +36,8 @@ dependencies {
|
|||||||
implementation("org.yaml:snakeyaml:2.2")
|
implementation("org.yaml:snakeyaml:2.2")
|
||||||
implementation("io.minio:minio:8.5.7")
|
implementation("io.minio:minio:8.5.7")
|
||||||
implementation("org.apache.httpcomponents:httpclient:4.5.14")
|
implementation("org.apache.httpcomponents:httpclient:4.5.14")
|
||||||
|
implementation("org.apache.poi:poi:5.2.3")
|
||||||
|
implementation("org.apache.poi:poi-ooxml:5.2.3")
|
||||||
api ("net.cactusthorn.config:config-core:0.81")
|
api ("net.cactusthorn.config:config-core:0.81")
|
||||||
api ("net.cactusthorn.config:config-yaml:0.81")
|
api ("net.cactusthorn.config:config-yaml:0.81")
|
||||||
kapt("net.cactusthorn.config:config-compiler:0.81")
|
kapt("net.cactusthorn.config:config-compiler:0.81")
|
||||||
|
|||||||
@@ -42,6 +42,7 @@ class AppAccessManager : AccessManager {
|
|||||||
Role.DbOps -> listOf("ROLE_DB_OPS")
|
Role.DbOps -> listOf("ROLE_DB_OPS")
|
||||||
Role.Entity -> loadEntityActionRole(entity, action)
|
Role.Entity -> loadEntityActionRole(entity, action)
|
||||||
is Role.Standard -> role.action.toList().map { "ROLE_${entity}_${it}" }
|
is Role.Standard -> role.action.toList().map { "ROLE_${entity}_${it}" }
|
||||||
|
is Role.Explicit -> role.roles
|
||||||
}.map(String::uppercase)
|
}.map(String::uppercase)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -4,9 +4,10 @@ import com.fasterxml.jackson.databind.JsonMappingException
|
|||||||
import com.restapi.config.*
|
import com.restapi.config.*
|
||||||
import com.restapi.config.AppConfig.Companion.appConfig
|
import com.restapi.config.AppConfig.Companion.appConfig
|
||||||
import com.restapi.config.Auth.validateAuthToken
|
import com.restapi.config.Auth.validateAuthToken
|
||||||
import com.restapi.controllers.Entities
|
import com.restapi.controllers.*
|
||||||
import com.restapi.domain.DataNotFoundException
|
import com.restapi.domain.DataNotFoundException
|
||||||
import com.restapi.domain.Session
|
import com.restapi.domain.Product
|
||||||
|
import com.restapi.domain.Session.a
|
||||||
import com.restapi.domain.Session.currentTenant
|
import com.restapi.domain.Session.currentTenant
|
||||||
import com.restapi.domain.Session.currentUser
|
import com.restapi.domain.Session.currentUser
|
||||||
import com.restapi.domain.Session.objectMapper
|
import com.restapi.domain.Session.objectMapper
|
||||||
@@ -24,6 +25,7 @@ import io.javalin.http.util.RateLimitUtil
|
|||||||
import io.javalin.json.JavalinJackson
|
import io.javalin.json.JavalinJackson
|
||||||
import org.jose4j.jwt.consumer.InvalidJwtException
|
import org.jose4j.jwt.consumer.InvalidJwtException
|
||||||
import org.slf4j.LoggerFactory
|
import org.slf4j.LoggerFactory
|
||||||
|
import java.io.InputStream
|
||||||
import java.security.MessageDigest
|
import java.security.MessageDigest
|
||||||
import java.time.LocalDateTime
|
import java.time.LocalDateTime
|
||||||
import java.util.*
|
import java.util.*
|
||||||
@@ -111,34 +113,158 @@ fun main(args: Array<String>) {
|
|||||||
it.json(mapOf("status" to true))
|
it.json(mapOf("status" to true))
|
||||||
}
|
}
|
||||||
|
|
||||||
post("/script/database/{name}", Entities::executeStoredProcedure, Roles(adminRole, Role.DbOps))
|
path("/vendor") {
|
||||||
post("/script/{file}/{name}", Entities::executeScript, Roles(adminRole, Role.DbOps))
|
path("/") {
|
||||||
|
post("", Vendor::create, Roles(Role.Explicit(listOf("ROLE_VENDOR_CREATE", "ROLE_ADMIN"))))
|
||||||
|
get(
|
||||||
|
"",
|
||||||
|
Vendor::get,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_VENDOR_VIEW", "ROLE_VENDOR_CREATE", "ROLE_ADMIN")))
|
||||||
|
)
|
||||||
|
get(
|
||||||
|
"quotes/{id}",
|
||||||
|
Vendor::getQuotes,
|
||||||
|
Roles(
|
||||||
|
Role.Explicit(
|
||||||
|
listOf(
|
||||||
|
"ROLE_ADMIN",
|
||||||
|
"ROLE_QUOTE_VIEW",
|
||||||
|
"ROLE_QUOTE_CREATE",
|
||||||
|
"ROLE_VENDOR_VIEW"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
get(
|
||||||
|
"pos/{id}",
|
||||||
|
Vendor::getPos,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_ADMIN", "ROLE_PO_VIEW", "ROLE_PO_CREATE`")))
|
||||||
|
)
|
||||||
|
put("/rate/{id}/{rating}", Vendor::rate, Roles(Role.Explicit(listOf("ROLE_VENDOR_CREATE"))))
|
||||||
|
}
|
||||||
|
path("/po") {
|
||||||
|
post("", PurchaseOrder::create, Roles(Role.Explicit(listOf("ROLE_PO_CREATE", "ROLE_ADMIN"))))
|
||||||
|
get(
|
||||||
|
"/{id}",
|
||||||
|
PurchaseOrder::get,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_PO_CREATE", "ROLE_PO_VIEW", "ROLE_QUOTE_CREATE")))
|
||||||
|
)
|
||||||
|
put(
|
||||||
|
"/approve/{id}",
|
||||||
|
PurchaseOrder::approve,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_ADMIN", "ROLE_APPROVE")))
|
||||||
|
)
|
||||||
|
put(
|
||||||
|
"/reject/{id}",
|
||||||
|
PurchaseOrder::reject,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_ADMIN", "ROLE_APPROVE")))
|
||||||
|
)
|
||||||
|
get(
|
||||||
|
"/refQuote/{id}",
|
||||||
|
PurchaseOrder::quoteReference,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_PO_CREATE", "ROLE_PO_VIEW")))
|
||||||
|
)
|
||||||
|
}
|
||||||
|
path("/quote") {
|
||||||
|
post("", Quotation::create, Roles(Role.Explicit(listOf("ROLE_QUOTE_CREATE", "ROLE_ADMIN"))))
|
||||||
|
get(
|
||||||
|
"/{id}",
|
||||||
|
Quotation::get,
|
||||||
|
Roles(
|
||||||
|
Role.Explicit(
|
||||||
|
listOf(
|
||||||
|
"ROLE_QUOTE_VIEW",
|
||||||
|
"ROLE_ADMIN",
|
||||||
|
"ROLE_PO_CREATE",
|
||||||
|
"ROLE_QUOTE_CREATE"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
get(
|
||||||
|
"/po/{id}",
|
||||||
|
Quotation::generatePO,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_ADMIN", "ROLE_PO_CRETE")))
|
||||||
|
)
|
||||||
|
get(
|
||||||
|
"/rfq/{rfqNum}",
|
||||||
|
Quotation::reqForQuote,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_QUOTE_CREATE", "ROLE_QUOTE_VIEW")))
|
||||||
|
)
|
||||||
|
delete(
|
||||||
|
"/{id}",
|
||||||
|
Quotation::delete,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_QUOTE_CREATE", "ROLE_ADMIN")))
|
||||||
|
)
|
||||||
|
}
|
||||||
|
path("/product") {
|
||||||
|
post("", ProductCtrl::create, Roles(Role.Explicit(listOf("ROLE_PRODUCT_CREATE", "ROLE_ADMIN"))))
|
||||||
|
get("/{hsnCode}", ProductCtrl::get, Roles(Role.Explicit(listOf("ROLE_PRODUCT_VIEW", "ROLE_ADMIN"))))
|
||||||
|
patch("/{id}", ProductCtrl::patch, Roles(Role.Explicit(listOf("ROLE_PRODUCT_UPDATE", "ROLE_ADMIN"))))
|
||||||
|
put("/{id}", ProductCtrl::update, Roles(Role.Explicit(listOf("ROLE_PRODUCT_UPDATE", "ROLE_ADMIN"))))
|
||||||
|
delete("/{id}", ProductCtrl::delete, Roles(Role.Explicit(listOf("ROLE_PRODUCT_DELETE", "ROLE_ADMIN"))))
|
||||||
|
get("", ProductCtrl::getAll, Roles(Role.Explicit(listOf("ROLE_PRODUCT_VIEW", "ROLE_ADMIN"))))
|
||||||
|
post("/product-excel", ProductCtrl::prodExcel)
|
||||||
|
post("/import") {ctx -> ctx.json(excelToDb())}
|
||||||
|
}
|
||||||
|
path("/doc") {
|
||||||
|
post("", Document::create, Roles(Role.Explicit(listOf("ROLE_DOC_CREATE", "ROLE_ADMIN"))))
|
||||||
|
//why type and refid are clubbed ??
|
||||||
|
get(
|
||||||
|
"/{type}/{refId}",
|
||||||
|
Document::getWithRefId,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_DOC_VIEW", "ROLE_ADMIN", "ROLE_PRODUCT_CREATE")))
|
||||||
|
)
|
||||||
|
get(
|
||||||
|
"/{id}",
|
||||||
|
Document::get,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_DOC_VIEW", "ROLE_ADMIN", "ROLE_PRODUCT_CREATE")))
|
||||||
|
)
|
||||||
|
get(
|
||||||
|
"/print/{id}",
|
||||||
|
Document::print,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_DOC_CREATE", "ROLE_DOC_VIEW")))
|
||||||
|
)
|
||||||
|
delete("/{id}", Document::delete, Roles(Role.Explicit(listOf("ROLE_DOC_CREATE"))))
|
||||||
|
}
|
||||||
|
path("/reqForQuote") {
|
||||||
|
post("", RequestForQuote::create, Roles(Role.Explicit(listOf("ROLE_RFQ_CREATE"))))
|
||||||
|
get(
|
||||||
|
"/{id}",
|
||||||
|
RequestForQuote::get,
|
||||||
|
Roles(Role.Explicit(listOf("ROLE_RFQ_CREATE", "ROLE_RFQ_VIEW")))
|
||||||
|
)
|
||||||
|
put("/{id}", RequestForQuote::update, Roles(Role.Explicit(listOf("ROLE_RFQ_CREATE"))))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
post("/script/database/{name}", Entities::executeStoredProcedure, Roles(adminRole, Role.DbOps))
|
||||||
|
post("/script/{file}/{name}", Entities::executeScript, Roles(adminRole, Role.DbOps))
|
||||||
|
|
||||||
get("/{entity}/{id}", Entities::view, Roles(adminRole, viewRole))
|
get("/{entity}/{id}", Entities::view, Roles(adminRole, viewRole))
|
||||||
post("/{entity}/query/{id}", Entities::sqlQueryById, Roles(adminRole, viewRole))
|
post("/{entity}/query/{id}", Entities::sqlQueryById, Roles(adminRole, viewRole))
|
||||||
post("/{entity}/query", Entities::sqlQueryRaw, Roles(adminRole, viewRole))
|
post("/{entity}/query", Entities::sqlQueryRaw, Roles(adminRole, viewRole))
|
||||||
post("/{entity}", Entities::create, Roles(adminRole, createRole))
|
post("/{entity}", Entities::create, Roles(adminRole, createRole))
|
||||||
|
|
||||||
put("/{entity}/approve/{id}", Entities::approve, Roles(adminRole, approveOrRejectRole))
|
put("/{entity}/approve/{id}", Entities::approve, Roles(adminRole, approveOrRejectRole))
|
||||||
put("/{entity}/reject/{id}", Entities::reject, Roles(adminRole, approveOrRejectRole))
|
put("/{entity}/reject/{id}", Entities::reject, Roles(adminRole, approveOrRejectRole))
|
||||||
put("/{entity}/{action}/{id}", Entities::action, Roles(adminRole, Role.Entity))
|
put("/{entity}/{action}/{id}", Entities::action, Roles(adminRole, Role.Entity))
|
||||||
|
|
||||||
put("/{entity}/{id}", Entities::update, Roles(adminRole, updateRole))
|
put("/{entity}/{id}", Entities::update, Roles(adminRole, updateRole))
|
||||||
patch("/{entity}/{id}", Entities::patch, Roles(adminRole, updateRole))
|
patch("/{entity}/{id}", Entities::patch, Roles(adminRole, updateRole))
|
||||||
delete("/{entity}/{id}", Entities::delete, Roles(adminRole, Role.Standard(Action.DELETE)))
|
delete("/{entity}/{id}", Entities::delete, Roles(adminRole, Role.Standard(Action.DELETE)))
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
.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(JsonMappingException::class.java, Exceptions.jsonMappingException)
|
||||||
|
.exception(InvalidJwtException::class.java, Exceptions.invalidJwtException)
|
||||||
|
.start(appConfig.portNumber())
|
||||||
}
|
}
|
||||||
.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(JsonMappingException::class.java, Exceptions.jsonMappingException)
|
|
||||||
.exception(InvalidJwtException::class.java, Exceptions.invalidJwtException)
|
|
||||||
.start(appConfig.portNumber())
|
|
||||||
}
|
|
||||||
|
|
||||||
private fun Context.getAuthHeader() = header("Authorization")
|
private fun Context.getAuthHeader() = header("Authorization")
|
||||||
?.replace("Bearer ", "")
|
?.replace("Bearer ", "")
|
||||||
?.replace("Bearer: ", "")
|
?.replace("Bearer: ", "")
|
||||||
?.trim()
|
?.trim()
|
||||||
|
|
||||||
|
|||||||
@@ -62,6 +62,7 @@ object Auth {
|
|||||||
.setRequireExpirationTime()
|
.setRequireExpirationTime()
|
||||||
.setAllowedClockSkewInSeconds(30)
|
.setAllowedClockSkewInSeconds(30)
|
||||||
.setRequireSubject()
|
.setRequireSubject()
|
||||||
|
.setExpectedAudience("account")
|
||||||
.setExpectedIssuer(getAuthEndpoint().issuer)
|
.setExpectedIssuer(getAuthEndpoint().issuer)
|
||||||
.setVerificationKeyResolver(HttpsJwksVerificationKeyResolver(HttpsJwks(getAuthEndpoint().jwksUri)))
|
.setVerificationKeyResolver(HttpsJwksVerificationKeyResolver(HttpsJwks(getAuthEndpoint().jwksUri)))
|
||||||
.build()
|
.build()
|
||||||
@@ -234,6 +235,7 @@ enum class Action {
|
|||||||
sealed class Role {
|
sealed class Role {
|
||||||
open class Standard(vararg val action: Action) : Role()
|
open class Standard(vararg val action: Action) : Role()
|
||||||
data object Entity : Role()
|
data object Entity : Role()
|
||||||
|
data class Explicit(val roles: List<String>) : Role()
|
||||||
data object DbOps : Role()
|
data object DbOps : Role()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -6,17 +6,24 @@ import com.fasterxml.jackson.databind.JsonDeserializer
|
|||||||
import com.fasterxml.jackson.databind.JsonNode
|
import com.fasterxml.jackson.databind.JsonNode
|
||||||
import com.fasterxml.jackson.databind.annotation.JsonDeserialize
|
import com.fasterxml.jackson.databind.annotation.JsonDeserialize
|
||||||
import com.restapi.domain.*
|
import com.restapi.domain.*
|
||||||
|
import com.restapi.domain.Product
|
||||||
|
import com.restapi.domain.PurchaseOrder
|
||||||
|
import com.restapi.domain.Quotation
|
||||||
import com.restapi.domain.Session.currentUser
|
import com.restapi.domain.Session.currentUser
|
||||||
import com.restapi.domain.Session.database
|
import com.restapi.domain.Session.database
|
||||||
import com.restapi.domain.Session.findDataModelByEntityAndUniqId
|
import com.restapi.domain.Session.findDataModelByEntityAndUniqId
|
||||||
|
import com.restapi.domain.Vendor
|
||||||
import com.restapi.integ.Scripting
|
import com.restapi.integ.Scripting
|
||||||
import io.ebean.CallableSql
|
import io.ebean.CallableSql
|
||||||
import io.ebean.RawSqlBuilder
|
import io.ebean.RawSqlBuilder
|
||||||
import io.javalin.http.BadRequestResponse
|
import io.javalin.http.*
|
||||||
import io.javalin.http.Context
|
import org.apache.poi.ss.usermodel.Cell
|
||||||
import io.javalin.http.NotFoundResponse
|
import org.apache.poi.ss.usermodel.CellType
|
||||||
import io.javalin.http.bodyAsClass
|
import org.apache.poi.ss.usermodel.WorkbookFactory
|
||||||
import org.slf4j.LoggerFactory
|
import org.slf4j.LoggerFactory
|
||||||
|
import java.io.File
|
||||||
|
import java.io.FileInputStream
|
||||||
|
import java.io.InputStream
|
||||||
import java.sql.Types
|
import java.sql.Types
|
||||||
import java.time.LocalDate
|
import java.time.LocalDate
|
||||||
import java.time.LocalDateTime
|
import java.time.LocalDateTime
|
||||||
@@ -372,3 +379,225 @@ object Entities {
|
|||||||
false
|
false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
object PurchaseOrder {
|
||||||
|
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)
|
||||||
|
}
|
||||||
|
fun create(ctx :Context){
|
||||||
|
val po = ctx.bodyAsClass<PurchaseOrder>()
|
||||||
|
database.save(po)
|
||||||
|
ctx.result("po 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.result("po with id $id approved")
|
||||||
|
//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.approvalStatus = ApprovalStatus.REJECTED
|
||||||
|
po.save()
|
||||||
|
ctx.result("po with id $id rejected")
|
||||||
|
}
|
||||||
|
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)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
data class ProductSearch(
|
||||||
|
var isSort: String? = null
|
||||||
|
)
|
||||||
|
|
||||||
|
object ProductCtrl {
|
||||||
|
fun get(ctx :Context){
|
||||||
|
val hsnCode = ctx.pathParam("hsnCode")
|
||||||
|
val product = database.find(Product::class.java, hsnCode) ?: throw NotFoundResponse("Product not found for $hsnCode")
|
||||||
|
|
||||||
|
ctx.json(product)
|
||||||
|
}
|
||||||
|
fun getAll(ctx: Context){
|
||||||
|
val productList = Session.database.find(Product::class.java)
|
||||||
|
.findList()
|
||||||
|
//.sortedBy { it.hsnCode }
|
||||||
|
|
||||||
|
ctx.json(productList)
|
||||||
|
}
|
||||||
|
fun create(ctx :Context){
|
||||||
|
val product = ctx.bodyAsClass<Product>()
|
||||||
|
database.save(product)
|
||||||
|
}
|
||||||
|
|
||||||
|
fun delete(ctx: Context) {
|
||||||
|
val id = ctx.pathParam("id")
|
||||||
|
val product = database.delete(Product::class.java, id)
|
||||||
|
}
|
||||||
|
|
||||||
|
fun patch(ctx: Context) {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
fun update(ctx: Context) {
|
||||||
|
|
||||||
|
}
|
||||||
|
fun prodExcel(it: Context) {
|
||||||
|
val product = database.find(Product::class.java).findList()
|
||||||
|
it.result(CreateExcel(product)).contentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
|
||||||
|
.header("Content-Disposition", "attachment; filename=\"product.xlsx\"")
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
object Quotation {
|
||||||
|
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.json(quote)
|
||||||
|
}
|
||||||
|
fun create(ctx :Context){
|
||||||
|
val quote = ctx.bodyAsClass<Quotation>()
|
||||||
|
//we have to check if the quotation created date is below the expiry of rfq
|
||||||
|
val rfq = database.find(com.restapi.domain.ReqForQuote::class.java)
|
||||||
|
.where()
|
||||||
|
.eq("reqForQuoteNum", quote.reqForQuoteNum)
|
||||||
|
.findOne()
|
||||||
|
if(rfq != null){
|
||||||
|
//compare dates
|
||||||
|
if(quote.quoteDate!! <= rfq.openTill) {
|
||||||
|
//valid
|
||||||
|
database.save(quote)
|
||||||
|
ctx.result("quote created")
|
||||||
|
}else {
|
||||||
|
ctx.result("request for quote closed")
|
||||||
|
}
|
||||||
|
}else {
|
||||||
|
throw NotFoundResponse("request for quote not found for this quotation")
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
fun delete(ctx :Context){
|
||||||
|
val id = ctx.pathParam("id")
|
||||||
|
val quote = database.find(Quotation::class.java, id) ?: throw NotFoundResponse("quote not found for id $id")
|
||||||
|
quote.delete()
|
||||||
|
ctx.result("quote with $id deleted")
|
||||||
|
}
|
||||||
|
fun generatePO(ctx :Context){
|
||||||
|
//user should be redirected to a po form submission with prefilled values
|
||||||
|
//create a PO object with values from the quote and then send it as body to vendor/po/create ??
|
||||||
|
|
||||||
|
}
|
||||||
|
fun reqForQuote(ctx :Context){
|
||||||
|
val reqForQuoteNum = ctx.pathParam(("rfqNum"))
|
||||||
|
val rfq = database.find(RequestForQuote::class.java)
|
||||||
|
.where()
|
||||||
|
.eq("reqForQuoteNum", reqForQuoteNum)
|
||||||
|
?: throw NotFoundResponse("request for quote not found for this quotation")
|
||||||
|
ctx.json(rfq)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
object Document {
|
||||||
|
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.json(doc)
|
||||||
|
}
|
||||||
|
fun create(ctx :Context){
|
||||||
|
val doc = ctx.bodyAsClass<Document>()
|
||||||
|
database.save(doc)
|
||||||
|
ctx.result("doc created")
|
||||||
|
}
|
||||||
|
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 doc found with id $id")
|
||||||
|
//doc.delete()
|
||||||
|
ctx.result("document deleted")
|
||||||
|
}
|
||||||
|
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("refId", refId)
|
||||||
|
?: throw NotFoundResponse("no doc found for refId $refId")
|
||||||
|
ctx.json(doc)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
object Vendor {
|
||||||
|
fun get(ctx :Context){
|
||||||
|
val id = ctx.pathParam("id")
|
||||||
|
val vendor = database.find(Vendor::class.java, id) ?: throw NotFoundResponse("no vendor found with id $id")
|
||||||
|
ctx.json(vendor)
|
||||||
|
}
|
||||||
|
fun create(ctx :Context){
|
||||||
|
val vendor = ctx.bodyAsClass<Vendor>()
|
||||||
|
database.save(vendor)
|
||||||
|
ctx.result("vendor created")
|
||||||
|
}
|
||||||
|
fun update(ctx :Context){
|
||||||
|
|
||||||
|
}
|
||||||
|
fun delete(ctx :Context){
|
||||||
|
|
||||||
|
}
|
||||||
|
fun getQuotes(ctx :Context){
|
||||||
|
val id = ctx.pathParam("id")
|
||||||
|
val quotes = database.find(Quotation::class.java)
|
||||||
|
.where()
|
||||||
|
.eq("vendor", id)
|
||||||
|
.findList()
|
||||||
|
ctx.json(quotes)
|
||||||
|
}
|
||||||
|
fun getPos(ctx :Context){
|
||||||
|
val id = ctx.pathParam("id")
|
||||||
|
val pos = database.find(PurchaseOrder::class.java)
|
||||||
|
.where()
|
||||||
|
.eq("vendor", id)
|
||||||
|
.findList()
|
||||||
|
ctx.json(pos)
|
||||||
|
}
|
||||||
|
fun rate(ctx :Context){
|
||||||
|
val id = ctx.pathParam("id")
|
||||||
|
val rating = ctx.pathParam("rating").toDouble()
|
||||||
|
val vendor = database.find(Vendor::class.java, id) ?: throw NotFoundResponse("vendor not found for id $id")
|
||||||
|
//could place some rating validation checks
|
||||||
|
vendor.rating = rating
|
||||||
|
vendor.save()
|
||||||
|
ctx.result("rating changed")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
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.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??
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
184
src/main/kotlin/com/restapi/controllers/Excel.kt
Normal file
184
src/main/kotlin/com/restapi/controllers/Excel.kt
Normal file
@@ -0,0 +1,184 @@
|
|||||||
|
package com.restapi.controllers
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.databind.DeserializationFeature
|
||||||
|
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule
|
||||||
|
import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
|
||||||
|
import com.restapi.domain.Product
|
||||||
|
import com.restapi.domain.Session
|
||||||
|
import com.restapi.domain.Session.database
|
||||||
|
import com.restapi.domain.UOM
|
||||||
|
import io.ebean.text.json.JsonContext
|
||||||
|
import io.javalin.http.Context
|
||||||
|
import org.apache.poi.ss.usermodel.Cell
|
||||||
|
import org.apache.poi.ss.usermodel.CellType
|
||||||
|
import org.apache.poi.ss.usermodel.Row
|
||||||
|
import org.apache.poi.ss.usermodel.WorkbookFactory
|
||||||
|
import org.apache.poi.xssf.usermodel.XSSFWorkbook
|
||||||
|
import java.io.ByteArrayInputStream
|
||||||
|
import java.io.ByteArrayOutputStream
|
||||||
|
import java.io.FileInputStream
|
||||||
|
import java.io.InputStream
|
||||||
|
|
||||||
|
fun CreateExcel(productList: List<Product>): InputStream {
|
||||||
|
val wb = XSSFWorkbook()
|
||||||
|
val sh = wb.createSheet()
|
||||||
|
val rows: Row = sh.createRow(0)
|
||||||
|
rows.createCell(0).setCellValue("Name")
|
||||||
|
rows.createCell(1).setCellValue("Description")
|
||||||
|
rows.createCell(2).setCellValue("HSN")
|
||||||
|
rows.createCell(3).setCellValue("UOM")
|
||||||
|
|
||||||
|
var rowNum = 1
|
||||||
|
for (product in productList) {
|
||||||
|
val row: Row = sh.createRow(rowNum++)
|
||||||
|
|
||||||
|
row.createCell(0).setCellValue(product.name)
|
||||||
|
row.createCell(1).setCellValue(product.description)
|
||||||
|
row.createCell(2).setCellValue(product.hsnCode)
|
||||||
|
|
||||||
|
val uomCell: Cell = row.createCell(3)
|
||||||
|
uomCell.setCellValue(product.uom?.name ?: "")
|
||||||
|
}
|
||||||
|
|
||||||
|
val baos = ByteArrayOutputStream()
|
||||||
|
wb.write(baos)
|
||||||
|
wb.close()
|
||||||
|
|
||||||
|
return ByteArrayInputStream(baos.toByteArray())
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
data class validateExcel(
|
||||||
|
val name: String,
|
||||||
|
val description: String,
|
||||||
|
val hsnCode: String,
|
||||||
|
val ok: Boolean,
|
||||||
|
val err: String,
|
||||||
|
)
|
||||||
|
|
||||||
|
val app_common_om = jacksonObjectMapper().apply {
|
||||||
|
registerModule(JavaTimeModule())
|
||||||
|
configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
|
||||||
|
}
|
||||||
|
|
||||||
|
fun ExcelRead(): String{
|
||||||
|
val inputStream = FileInputStream("C:\\Users\\vinay\\IdeaProjects\\readymixerp_modules_api_git\\product-4.xlsx")
|
||||||
|
val workbook = WorkbookFactory.create(inputStream)
|
||||||
|
val workSheet = workbook.getSheetAt(0)
|
||||||
|
var h = true
|
||||||
|
//Header check
|
||||||
|
if(workSheet.getRow(0).getCell(0).stringCellValue.equals("Name")) {
|
||||||
|
if (workSheet.getRow(0).getCell(1).stringCellValue.equals("Description")) {
|
||||||
|
if (workSheet.getRow(0).getCell(2).stringCellValue.equals("HSN")) {
|
||||||
|
if (workSheet.getRow(0).getCell(3).stringCellValue.equals("UOM")) {
|
||||||
|
h = false
|
||||||
|
}else return "Header UOM mismatch"
|
||||||
|
}else return "Header-HSN mismatch"
|
||||||
|
}else return "Header-Desc mismatch"
|
||||||
|
}else return "Header-Name mismatch"
|
||||||
|
|
||||||
|
val resp = arrayListOf<validateExcel>()
|
||||||
|
|
||||||
|
if(h==false) {
|
||||||
|
workSheet.rowIterator().forEach { row ->
|
||||||
|
|
||||||
|
if (row == null) return@forEach
|
||||||
|
|
||||||
|
if (h) {
|
||||||
|
|
||||||
|
val pName = row.getCell(0).run {
|
||||||
|
when {
|
||||||
|
this == null -> ""
|
||||||
|
this.cellType == CellType.STRING -> this.stringCellValue
|
||||||
|
else -> ""
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
val pDesc = row.getCell(1).run {
|
||||||
|
when {
|
||||||
|
this == null -> ""
|
||||||
|
this.cellType == CellType.STRING -> this.stringCellValue
|
||||||
|
else -> ""
|
||||||
|
}
|
||||||
|
}
|
||||||
|
val pHsn = row.getCell(2).run {
|
||||||
|
when {
|
||||||
|
this == null -> ""
|
||||||
|
this.cellType == CellType.STRING -> this.stringCellValue
|
||||||
|
else -> ""
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (pName.isEmpty() && pDesc.isEmpty() && pHsn.isEmpty()) {
|
||||||
|
return@forEach
|
||||||
|
}
|
||||||
|
if (pName.isEmpty()) {
|
||||||
|
resp.add(
|
||||||
|
validateExcel(
|
||||||
|
name = pName,
|
||||||
|
description = pDesc,
|
||||||
|
hsnCode = pHsn,
|
||||||
|
ok = false,
|
||||||
|
err = "Product name is required"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
return@forEach
|
||||||
|
}
|
||||||
|
if (pDesc.isEmpty()) {
|
||||||
|
resp.add(
|
||||||
|
validateExcel(
|
||||||
|
name = pName,
|
||||||
|
description = pDesc,
|
||||||
|
hsnCode = pHsn,
|
||||||
|
ok = false,
|
||||||
|
err = "Product description is required"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
return@forEach
|
||||||
|
}
|
||||||
|
if (pHsn.isEmpty()) {
|
||||||
|
resp.add(
|
||||||
|
validateExcel(
|
||||||
|
name = pName,
|
||||||
|
description = pDesc,
|
||||||
|
hsnCode = pHsn,
|
||||||
|
ok = false,
|
||||||
|
err = "Product HSN is required"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
return@forEach
|
||||||
|
}
|
||||||
|
}
|
||||||
|
h = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return app_common_om.writeValueAsString(resp)
|
||||||
|
}
|
||||||
|
|
||||||
|
fun excelToDb(): List<Product> {
|
||||||
|
val inputStream = FileInputStream("C:\\Users\\vinay\\IdeaProjects\\readymixerp_modules_api_git\\product-4.xlsx")
|
||||||
|
val workbook = WorkbookFactory.create(inputStream)
|
||||||
|
val workSheet = workbook.getSheetAt(0)
|
||||||
|
|
||||||
|
for (row in workSheet) {
|
||||||
|
val cell1Value = row.getCell(0).stringCellValue
|
||||||
|
val cell2Value = row.getCell(1).stringCellValue
|
||||||
|
val cell3Value = row.getCell(2).stringCellValue
|
||||||
|
val cell4Value = row.getCell(3).stringCellValue
|
||||||
|
|
||||||
|
val prod = Product()
|
||||||
|
prod.name = cell1Value
|
||||||
|
prod.description = cell2Value
|
||||||
|
prod.hsnCode = cell3Value
|
||||||
|
prod.uom = when(cell4Value) {
|
||||||
|
"nos" -> UOM.NOS
|
||||||
|
"ltr" -> UOM.LTR
|
||||||
|
"mtr" -> UOM.MTR
|
||||||
|
else -> UOM.ALL
|
||||||
|
}
|
||||||
|
database.saveAll(prod)
|
||||||
|
}
|
||||||
|
val productList = Session.database.find(Product::class.java).findList()
|
||||||
|
return productList
|
||||||
|
}
|
||||||
|
|
||||||
145
src/main/kotlin/com/restapi/controllers/Filters.kt
Normal file
145
src/main/kotlin/com/restapi/controllers/Filters.kt
Normal file
@@ -0,0 +1,145 @@
|
|||||||
|
package com.restapi.controllers
|
||||||
|
|
||||||
|
import com.restapi.domain.*
|
||||||
|
import com.restapi.domain.PurchaseOrder
|
||||||
|
import com.restapi.domain.Quotation
|
||||||
|
import java.time.LocalDate
|
||||||
|
import com.restapi.domain.Session.database
|
||||||
|
|
||||||
|
//constants
|
||||||
|
const val IGNORE = "%"
|
||||||
|
val baseDate :LocalDate = LocalDate.MIN
|
||||||
|
val maxDate :LocalDate = LocalDate.MAX
|
||||||
|
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 fromDate :LocalDate = baseDate,
|
||||||
|
val toDate :LocalDate = maxDate,
|
||||||
|
val vendor :List<Long>? = null,
|
||||||
|
val sortAsc :Boolean = true,
|
||||||
|
val sortBy :String = IGNORE
|
||||||
|
)
|
||||||
|
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,
|
||||||
|
)
|
||||||
|
data class ProductFilters (
|
||||||
|
val nameLike :String = IGNORE,
|
||||||
|
val hsnLike :String = IGNORE,
|
||||||
|
val uom :UOM = UOM.ALL,
|
||||||
|
)
|
||||||
|
data class DocumentFilters (
|
||||||
|
val nameLike :String = IGNORE,
|
||||||
|
val typeOfDoc :DocType = DocType.ALL,
|
||||||
|
)
|
||||||
|
data class RFQFilters (
|
||||||
|
val validBefore :LocalDate = maxDate,
|
||||||
|
val validAfter :LocalDate = baseDate,
|
||||||
|
val reqForQuoteNumLike :String = IGNORE,
|
||||||
|
)
|
||||||
|
data class QuoteFilters (
|
||||||
|
val quoteNumLike :String = IGNORE,
|
||||||
|
val validBefore :LocalDate = baseDate,
|
||||||
|
val validAfter :LocalDate = maxDate,
|
||||||
|
val totalAmountExceeds :Long = Long.MIN_VALUE,
|
||||||
|
val totalAmountLessThan :Long = Long.MAX_VALUE,
|
||||||
|
)
|
||||||
|
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,
|
||||||
|
)
|
||||||
|
fun<T> applyVendorHelper(q :io.ebean.ExpressionList<T>, vids :List<Long>?) {
|
||||||
|
if (vids.isNullOrEmpty()) return
|
||||||
|
q.apply {
|
||||||
|
q.`in`("vendor", vids)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
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> 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()
|
||||||
|
.between("quoteDate", commonFilters.fromDate, commonFilters.toDate)
|
||||||
|
.ilike("quoteNum", quoteFilters.quoteNumLike )
|
||||||
|
.ge("validTill",quoteFilters.validAfter)
|
||||||
|
.le("validTill", quoteFilters.validBefore)
|
||||||
|
.le("totalAmount", quoteFilters.totalAmountLessThan)
|
||||||
|
.ge("totalAmount", quoteFilters.totalAmountExceeds)
|
||||||
|
.apply {
|
||||||
|
if(!commonFilters.vendor?.isEmpty()!!){
|
||||||
|
commonFilters.vendor.let { this.`in`("vendor", it) }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
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("gstNum", vendorFilters.gstNumLike)
|
||||||
|
.ilike("address", vendorFilters.addressLike)
|
||||||
|
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)
|
||||||
|
return q.findList()
|
||||||
|
}
|
||||||
|
fun searchPos(commonFilters: CommonFilters, poFilters: POFilters) : List<PurchaseOrder> {
|
||||||
|
val q = database.find(PurchaseOrder::class.java)
|
||||||
|
.where()
|
||||||
|
.between("totalAmount", poFilters.totalAmountExceeds, poFilters.totalAmountLessThan)
|
||||||
|
.between("validTill", poFilters.validAfter, poFilters.validBefore)
|
||||||
|
.ilike("poNum", poFilters.poNumLike )
|
||||||
|
.ilike("referenceQuotation", poFilters.refQuotation )
|
||||||
|
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()
|
||||||
|
.between("validTill", rfqFilters.validAfter, rfqFilters.validBefore)
|
||||||
|
.ilike("reqForQuoteNum", rfqFilters.reqForQuoteNumLike)
|
||||||
|
applyVendorHelper(q, commonFilters.vendor)
|
||||||
|
applySortHelper(q, commonFilters.sortBy, commonFilters.sortAsc)
|
||||||
|
return q.findList()
|
||||||
|
}
|
||||||
|
|
||||||
|
fun searchProduct(commonFilters: CommonFilters, productFilters: ProductFilters): List<Product> {
|
||||||
|
val p = database.find(Product::class.java)
|
||||||
|
.where()
|
||||||
|
.ilike("hsnCode", productFilters.hsnLike)
|
||||||
|
.ilike("Pname", productFilters.nameLike)
|
||||||
|
applySortHelper(p, commonFilters.sortBy, commonFilters.sortAsc)
|
||||||
|
return p.findList()
|
||||||
|
}
|
||||||
@@ -7,11 +7,13 @@ import com.fasterxml.jackson.databind.annotation.JsonDeserialize
|
|||||||
import io.ebean.Model
|
import io.ebean.Model
|
||||||
import io.ebean.annotation.*
|
import io.ebean.annotation.*
|
||||||
import io.ebean.annotation.Index
|
import io.ebean.annotation.Index
|
||||||
|
import java.time.LocalDate
|
||||||
import java.time.LocalDateTime
|
import java.time.LocalDateTime
|
||||||
|
import java.util.*
|
||||||
import javax.persistence.*
|
import javax.persistence.*
|
||||||
|
|
||||||
data class Comments(val text: String = "", val by: String = "", val at: LocalDateTime = LocalDateTime.now())
|
data class Comments(val text: String = "", val by: String = "", val at: LocalDateTime = LocalDateTime.now())
|
||||||
|
data class POProducts(val productId: String = "", val unitPrice :Double = 0.0, val quantity: Double = 0.0, val description :String = "")
|
||||||
enum class ApprovalStatus {
|
enum class ApprovalStatus {
|
||||||
PENDING, APPROVED, REJECTED
|
PENDING, APPROVED, REJECTED
|
||||||
}
|
}
|
||||||
@@ -214,6 +216,8 @@ open class DataModel : BaseTenantModel() {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@Entity
|
@Entity
|
||||||
@Index(unique = true, name = "unique_session_id", columnNames = ["session_id"])
|
@Index(unique = true, name = "unique_session_id", columnNames = ["session_id"])
|
||||||
open class AnonSession : BaseTenantModel() {
|
open class AnonSession : BaseTenantModel() {
|
||||||
@@ -236,5 +240,95 @@ class SafeStringDeserializer : JsonDeserializer<String>() {
|
|||||||
if (!regex.matches(text)) throw IllegalArgumentException()
|
if (!regex.matches(text)) throw IllegalArgumentException()
|
||||||
return text
|
return text
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
data class ContactPerson(val name: String, val email: String, val mobile: String)
|
||||||
|
@Entity
|
||||||
|
open class Vendor :BaseTenantModel() {
|
||||||
|
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() {
|
||||||
|
@DbJsonB
|
||||||
|
var products :MutableList<POProducts> = mutableListOf()
|
||||||
|
@ManyToOne
|
||||||
|
var vendor :Vendor? = null
|
||||||
|
var referenceQuotation :String = ""
|
||||||
|
var totalAmount :Int = 0
|
||||||
|
var poNum: String = ""
|
||||||
|
var poDate: LocalDate? = null
|
||||||
|
var validTill: LocalDate? = null
|
||||||
|
@DbArray
|
||||||
|
var tnc: List<String> = arrayListOf()
|
||||||
|
@DbArray
|
||||||
|
var documents: MutableList<Long> = arrayListOf()
|
||||||
|
}
|
||||||
|
|
||||||
|
enum class UOM {
|
||||||
|
NOS, LTR, MTR, ALL
|
||||||
|
}
|
||||||
|
|
||||||
|
@Entity
|
||||||
|
open class Product :BaseTenantModel() {
|
||||||
|
var id: Int? = null
|
||||||
|
var name :String = ""
|
||||||
|
var description :String = ""
|
||||||
|
var hsnCode :String = ""
|
||||||
|
@Enumerated(EnumType.STRING)
|
||||||
|
var uom: UOM? = null
|
||||||
|
}
|
||||||
|
|
||||||
|
@Entity
|
||||||
|
open class Quotation :BaseTenantModel() {
|
||||||
|
@DbJsonB
|
||||||
|
var products :MutableList<POProducts> = mutableListOf()
|
||||||
|
@ManyToOne
|
||||||
|
var vendor :Vendor? = null
|
||||||
|
var totalAmount :Long = 0
|
||||||
|
|
||||||
|
var reqForQuoteNum: String = ""
|
||||||
|
var quoteNum: String = ""
|
||||||
|
var quoteDate: LocalDate? = null
|
||||||
|
var validTill: LocalDate? = null
|
||||||
|
@DbArray
|
||||||
|
var tnc: List<String> = arrayListOf()
|
||||||
|
|
||||||
|
@DbArray
|
||||||
|
var documents: MutableList<Long> = arrayListOf()
|
||||||
|
}
|
||||||
|
|
||||||
|
enum class DocType{
|
||||||
|
PO, QUOTE, INVOICE, ALL
|
||||||
|
}
|
||||||
|
@Entity
|
||||||
|
open class Document :BaseTenantModel() {
|
||||||
|
var name :String = ""
|
||||||
|
@Enumerated(EnumType.STRING)
|
||||||
|
var typeOfDoc :DocType? = null
|
||||||
|
var refId: Long? = null
|
||||||
|
var description :String = ""
|
||||||
|
var url :String = ""
|
||||||
|
}
|
||||||
|
|
||||||
|
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
|
||||||
|
@DbArray
|
||||||
|
var docs :List<Document>? = null
|
||||||
|
@DbJsonB
|
||||||
|
var products :List<POProducts>? = null
|
||||||
|
var reqForQuoteNum: String = ""
|
||||||
|
var openTill: LocalDate? = null
|
||||||
}
|
}
|
||||||
140
src/main/resources/dbmigration/1.2.sql
Normal file
140
src/main/resources/dbmigration/1.2.sql
Normal file
@@ -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;
|
||||||
|
|
||||||
121
src/main/resources/dbmigration/model/1.2.model.xml
Normal file
121
src/main/resources/dbmigration/model/1.2.model.xml
Normal file
@@ -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>
|
||||||
Reference in New Issue
Block a user