diff --git a/staging/sanitation/egov-indexer/egov-fsm.yaml b/staging/sanitation/egov-indexer/egov-fsm.yaml index 6ee1bba48..02487ac8e 100644 --- a/staging/sanitation/egov-indexer/egov-fsm.yaml +++ b/staging/sanitation/egov-indexer/egov-fsm.yaml @@ -2,7 +2,7 @@ ServiceMaps: serviceName: fsm version: 1.0.0 mappings: - - topic: save-fsm-application + - topic: pg-save-fsm-application configKey: INDEX indexes: - name: fsm @@ -48,7 +48,7 @@ ServiceMaps: - inJsonPath: $.MdmsRes.tenant.tenants outJsonPath: $.Data.tenantData - - topic: update-fsm-application + - topic: pg-update-fsm-application configKey: INDEX indexes: - name: fsm @@ -108,7 +108,7 @@ ServiceMaps: - inJsonPath: $.MdmsRes.tenant.tenants outJsonPath: $.Data.tenantData - - topic: update-fsm-workflow-application + - topic: pg-update-fsm-workflow-application configKey: INDEX indexes: - name: fsm diff --git a/staging/sanitation/egov-indexer/egov-pqm-service.yml b/staging/sanitation/egov-indexer/egov-pqm-service.yml index 7db8dc3ed..eff53daca 100644 --- a/staging/sanitation/egov-indexer/egov-pqm-service.yml +++ b/staging/sanitation/egov-indexer/egov-pqm-service.yml @@ -2,7 +2,7 @@ ServiceMaps: serviceName: pqm-service inbox version: 1.0.0 mappings: - - topic: save-test-event-application + - topic: pg-save-test-event-application configKey: INDEX indexes: - name: pqm-application @@ -43,7 +43,7 @@ ServiceMaps: - inJsonPath: $.processInstance outJsonPath: $.Data.currentProcessInstance - - topic: update-test-event-application + - topic: pg-update-test-event-application configKey: INDEX indexes: - name: pqm-application diff --git a/staging/sanitation/egov-indexer/egov-vehicle.yaml b/staging/sanitation/egov-indexer/egov-vehicle.yaml index 73ab7347d..c43909bc6 100644 --- a/staging/sanitation/egov-indexer/egov-vehicle.yaml +++ b/staging/sanitation/egov-indexer/egov-vehicle.yaml @@ -2,7 +2,7 @@ ServiceMaps: serviceName: vehicle version: 1.0.0 mappings: - - topic: save-vehicle-application + - topic: pg-save-vehicle-application configKey: INDEX indexes: - name: vehicle @@ -29,7 +29,7 @@ ServiceMaps: - inJsonPath: $.MdmsRes.tenant.tenants outJsonPath: $.Data.tenantData - - topic: save-vehicle-trip + - topic: pg-save-vehicle-trip configKey: INDEX indexes: - name: vehicletrip @@ -80,7 +80,7 @@ ServiceMaps: - inJsonPath: $.MdmsRes.FSM.FSTPPlantInfo outJsonPath: $.Data.fstpPlantInfo - - topic: update-vehicle-trip + - topic: pg-update-vehicle-trip configKey: INDEX indexes: - name: vehicletrip @@ -131,7 +131,7 @@ ServiceMaps: - inJsonPath: $.MdmsRes.FSM.FSTPPlantInfo outJsonPath: $.Data.fstpPlantInfo - - topic: update-workflow-vehicle-trip + - topic: pg-update-workflow-vehicle-trip configKey: INDEX indexes: - name: vehicletrip diff --git a/staging/sanitation/egov-indexer/egov-vendor.yaml b/staging/sanitation/egov-indexer/egov-vendor.yaml index b76fd28ff..3819142c6 100644 --- a/staging/sanitation/egov-indexer/egov-vendor.yaml +++ b/staging/sanitation/egov-indexer/egov-vendor.yaml @@ -2,7 +2,7 @@ ServiceMaps: serviceName: vendor version: 1.0.0 mappings: - - topic: save-vendor-application + - topic: pg-save-vendor-application configKey: INDEX indexes: - name: vendor diff --git a/staging/sanitation/egov-indexer/fsm-inbox-indexer.yml b/staging/sanitation/egov-indexer/fsm-inbox-indexer.yml index 576ec091d..c41f74766 100644 --- a/staging/sanitation/egov-indexer/fsm-inbox-indexer.yml +++ b/staging/sanitation/egov-indexer/fsm-inbox-indexer.yml @@ -2,7 +2,7 @@ ServiceMaps: serviceName: fsm-Event indexer version: 1.0.0 mappings: - - topic: index-fsm-events + - topic: pg-index-fsm-events configKey: INDEX indexes: - name: fsm-application diff --git a/staging/sanitation/egov-indexer/payment-indexer.yml b/staging/sanitation/egov-indexer/payment-indexer.yml index 60f7dca5a..937218623 100644 --- a/staging/sanitation/egov-indexer/payment-indexer.yml +++ b/staging/sanitation/egov-indexer/payment-indexer.yml @@ -2,7 +2,7 @@ ServiceMaps: serviceName: Collection Services version: 1.0.0 mappings: - - topic: egov.collection.payment-create + - topic: pg-egov.collection.payment-create configKey: INDEX indexes: - name: paymentsindex-v1 @@ -54,7 +54,7 @@ ServiceMaps: outJsonPath: $.Data.tenantData - - topic: egov.collection.payment-update + - topic: pg-egov.collection.payment-update configKey: INDEX indexes: - name: paymentsindex-v1 diff --git a/staging/sanitation/egov-indexer/pqm-anomaly-finder-indexer.yml b/staging/sanitation/egov-indexer/pqm-anomaly-finder-indexer.yml index 4e240aba9..036db0701 100644 --- a/staging/sanitation/egov-indexer/pqm-anomaly-finder-indexer.yml +++ b/staging/sanitation/egov-indexer/pqm-anomaly-finder-indexer.yml @@ -2,7 +2,7 @@ ServiceMaps: serviceName: pqm-anomaly-finder version: 1.0.0 mappings: - - topic: save-pqm-test-anomaly-details + - topic: pg-save-pqm-test-anomaly-details configKey: INDEX indexes: - name: pqm-anomaly-finder diff --git a/staging/sanitation/egov-indexer/pqm-service-indexer.yml b/staging/sanitation/egov-indexer/pqm-service-indexer.yml index 26b73a600..75aab3c17 100644 --- a/staging/sanitation/egov-indexer/pqm-service-indexer.yml +++ b/staging/sanitation/egov-indexer/pqm-service-indexer.yml @@ -2,7 +2,7 @@ ServiceMaps: serviceName: pqm-service version: 1.0.0 mappings: - - topic: save-test-application + - topic: pg-save-test-application configKey: INDEX indexes: - name: pqm-service @@ -36,7 +36,7 @@ ServiceMaps: - inJsonPath: $.MdmsRes.tenant.tenants outJsonPath: $.Data.tenantData - - topic: update-test-application + - topic: pg-update-test-application configKey: INDEX indexes: - name: pqm-service diff --git a/staging/sanitation/egov-persister/fsm-calculator-persister.yaml b/staging/sanitation/egov-persister/fsm-calculator-persister.yaml index c1560c9c4..c7faeb62f 100644 --- a/staging/sanitation/egov-persister/fsm-calculator-persister.yaml +++ b/staging/sanitation/egov-persister/fsm-calculator-persister.yaml @@ -3,11 +3,11 @@ serviceMaps: mappings: - version: 1.0 description: Persists FSM-CALCULATOR Application details in eg_billing_slab table - fromTopic: save-fsm-billing-slab + fromTopic: pg-save-fsm-billing-slab isTransaction: true queryMaps: - - query: INSERT INTO public.eg_billing_slab(id,tenantid,capacityfrom,capacityto,propertytype,slum,price,status,createdby,lastmodifiedby,createdtime,lastmodifiedtime) VALUES (?,?,?,?,?,?,?,?,?,?,?,?); + - query: INSERT INTO pg.eg_billing_slab(id,tenantid,capacityfrom,capacityto,propertytype,slum,price,status,createdby,lastmodifiedby,createdtime,lastmodifiedtime) VALUES (?,?,?,?,?,?,?,?,?,?,?,?); basePath: billingSlab jsonMaps: - jsonPath: $.billingSlab.id @@ -36,16 +36,16 @@ serviceMaps: - version: 1.0 description: updates FSM-CALCULATOR Application details in eg_billing_slab table - fromTopic: update-fsm-billing-slab + fromTopic: pg-update-fsm-billing-slab isTransaction: true queryMaps: - - query: INSERT INTO public.eg_billing_slab_auditlog SELECT * FROM public.eg_billing_slab WHERE id =? + - query: INSERT INTO pg.eg_billing_slab_auditlog SELECT * FROM pg.eg_billing_slab WHERE id =? basePath: billingSlab jsonMaps: - jsonPath: $.billingSlab.id - - query: UPDATE public.eg_billing_slab SET tenantid=?, capacityfrom=?, capacityto=?, propertytype=?, slum=?, price=?, status=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=? + - query: UPDATE pg.eg_billing_slab SET tenantid=?, capacityfrom=?, capacityto=?, propertytype=?, slum=?, price=?, status=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=? basePath: billingSlab jsonMaps: - jsonPath: $.billingSlab.tenantId diff --git a/staging/sanitation/egov-persister/fsm-persister.yaml b/staging/sanitation/egov-persister/fsm-persister.yaml index d73e8a4a3..61b2d17a8 100644 --- a/staging/sanitation/egov-persister/fsm-persister.yaml +++ b/staging/sanitation/egov-persister/fsm-persister.yaml @@ -3,11 +3,11 @@ serviceMaps: mappings: - version: 1.0 description: Persists FSM Application details in eg_fsm_application table - fromTopic: save-fsm-application + fromTopic: pg-save-fsm-application isTransaction: true queryMaps: - - query: INSERT INTO eg_fsm_application( id, applicationno, tenantid, additionaldetails, accountid, description, applicationstatus, source, sanitationtype, propertyusage, nooftrips, status, vehicle_id, vehicletype, vehicleCapacity, paymentPreference,advanceAmount, applicationType, oldApplicationNo, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ,?, ?, ?, ?, ?, ?, ?, ?, ?, ?,?, ?); + - query: INSERT INTO pg.eg_fsm_application( id, applicationno, tenantid, additionaldetails, accountid, description, applicationstatus, source, sanitationtype, propertyusage, nooftrips, status, vehicle_id, vehicletype, vehicleCapacity, paymentPreference,advanceAmount, applicationType, oldApplicationNo, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ,?, ?, ?, ?, ?, ?, ?, ?, ?, ?,?, ?); basePath: fsm jsonMaps: - jsonPath: $.fsm.id @@ -59,7 +59,7 @@ serviceMaps: - jsonPath: $.fsm.auditDetails.lastModifiedTime - - query: INSERT INTO eg_fsm_address(id, tenantid, doorno, plotno, landmark, city, district, region, state, country, locality, pincode, additionalDetails, buildingname, street,slumname, fsm_id, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_fsm_address(id, tenantid, doorno, plotno, landmark, city, district, region, state, country, locality, pincode, additionalDetails, buildingname, street,slumname, fsm_id, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: fsm.address jsonMaps: @@ -109,7 +109,7 @@ serviceMaps: - - query: INSERT INTO eg_fsm_geolocation( id, latitude, longitude, additionaldetails, address_id) VALUES (?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_fsm_geolocation( id, latitude, longitude, additionaldetails, address_id) VALUES (?, ?, ?, ?, ?); basePath: fsm.address.geoLocation jsonMaps: - jsonPath: $.fsm.address.geoLocation.id @@ -128,7 +128,7 @@ serviceMaps: - jsonPath: $.fsm.address.id - - query: INSERT INTO eg_fsm_pit_detail( id, tenantid, height, length, width, diameter, distancefromroad, fsm_id, additionaldetails, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_fsm_pit_detail( id, tenantid, height, length, width, diameter, distancefromroad, fsm_id, additionaldetails, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: fsm.pitDetail jsonMaps: @@ -163,16 +163,16 @@ serviceMaps: - version: 1.0 description: Persists FSM Application details in eg_fsm_application table - fromTopic: update-fsm-application + fromTopic: pg-update-fsm-application isTransaction: true queryMaps: - - query: INSERT INTO eg_fsm_application_auditlog SELECT * FROM eg_fsm_application WHERE id =? + - query: INSERT INTO pg.eg_fsm_application_auditlog SELECT * FROM pg.eg_fsm_application WHERE id =? basePath: fsm jsonMaps: - jsonPath: $.fsm.id - - query: UPDATE eg_fsm_application SET additionaldetails=?, description=?, applicationstatus=?, source=?, sanitationtype=?, propertyusage=?, nooftrips=?, status=?, vehicle_id=?, vehicletype=?,vehicleCapacity=?, paymentPreference=?,advanceAmount=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=?, possible_srv_date=?, dso_id=? where id=? + - query: UPDATE pg.eg_fsm_application SET additionaldetails=?, description=?, applicationstatus=?, source=?, sanitationtype=?, propertyusage=?, nooftrips=?, status=?, vehicle_id=?, vehicletype=?,vehicleCapacity=?, paymentPreference=?,advanceAmount=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=?, possible_srv_date=?, dso_id=? where id=? basePath: fsm jsonMaps: - jsonPath: $.fsm.additionalDetails @@ -217,12 +217,12 @@ serviceMaps: - jsonPath: $.fsm.id - - query: INSERT INTO eg_fsm_address_auditlog SELECT * FROM eg_fsm_address WHERE id =?; + - query: INSERT INTO pg.eg_fsm_address_auditlog SELECT * FROM pg.eg_fsm_address WHERE id =?; basePath: fsm.address jsonMaps: - jsonPath: $.fsm.address.id - - query: UPDATE eg_fsm_address SET doorno=?, plotno=?, landmark=?, city=?, district=?, region=?, state=?,slumname=?, country=?, locality=?, pincode=?, additionalDetails=?, buildingname=?, street=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=? + - query: UPDATE pg.eg_fsm_address SET doorno=?, plotno=?, landmark=?, city=?, district=?, region=?, state=?,slumname=?, country=?, locality=?, pincode=?, additionalDetails=?, buildingname=?, street=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=? basePath: fsm.address jsonMaps: @@ -266,12 +266,12 @@ serviceMaps: - jsonPath: $.fsm.address.id - - query: INSERT INTO eg_fsm_geolocation_auditlog SELECT * FROM eg_fsm_geolocation WHERE id =?; + - query: INSERT INTO pg.eg_fsm_geolocation_auditlog SELECT * FROM pg.eg_fsm_geolocation WHERE id =?; basePath: fsm.address.geoLocation jsonMaps: - jsonPath: $.fsm.address.geoLocation.id - - query: UPDATE eg_fsm_geolocation SET latitude=?, longitude=?, additionaldetails=? where id=? + - query: UPDATE pg.eg_fsm_geolocation SET latitude=?, longitude=?, additionaldetails=? where id=? basePath: fsm.address.geoLocation jsonMaps: - jsonPath: $.fsm.address.geoLocation.latitude @@ -288,12 +288,12 @@ serviceMaps: - jsonPath: $.fsm.address.geoLocation.id - - query: INSERT INTO eg_fsm_pit_detail_auditlog SELECT * FROM eg_fsm_pit_detail WHERE id =?; + - query: INSERT INTO pg.eg_fsm_pit_detail_auditlog SELECT * FROM pg.eg_fsm_pit_detail WHERE id =?; basePath: fsm.pitDetail jsonMaps: - jsonPath: $.fsm.pitDetail.id - - query: UPDATE eg_fsm_pit_detail SET additionaldetails=?,height=?, length=?, width=?, diameter=?, distancefromroad=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=? + - query: UPDATE pg.eg_fsm_pit_detail SET additionaldetails=?,height=?, length=?, width=?, diameter=?, distancefromroad=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=? basePath: fsm.pitDetail jsonMaps: @@ -323,17 +323,17 @@ serviceMaps: - version: 1.0 description: Persists FSM Application details in eg_fsm_application table - fromTopic: update-fsm-workflow-application + fromTopic: pg-update-fsm-workflow-application isTransaction: true queryMaps: - - query: INSERT INTO eg_fsm_application_auditlog SELECT * FROM eg_fsm_application WHERE id =? + - query: INSERT INTO pg.eg_fsm_application_auditlog SELECT * FROM pg.eg_fsm_application WHERE id =? basePath: fsm jsonMaps: - jsonPath: $.fsm.id - - query: UPDATE eg_fsm_application SET additionaldetails=?, applicationstatus=?, vehicle_id =?, vehicletype=?, lastmodifiedby=?, lastmodifiedtime=?, possible_srv_date=?, dso_id=? where id=? + - query: UPDATE pg.eg_fsm_application SET additionaldetails=?, applicationstatus=?, vehicle_id =?, vehicletype=?, lastmodifiedby=?, lastmodifiedtime=?, possible_srv_date=?, dso_id=? where id=? basePath: fsm jsonMaps: - jsonPath: $.fsm.additionalDetails @@ -357,13 +357,13 @@ serviceMaps: - jsonPath: $.fsm.id - - query: INSERT INTO eg_fsm_pit_detail_auditlog SELECT * FROM eg_fsm_pit_detail WHERE id =? + - query: INSERT INTO pg.eg_fsm_pit_detail_auditlog SELECT * FROM pg.eg_fsm_pit_detail WHERE id =? basePath: fsm.pitDetail jsonMaps: - jsonPath: $.fsm.pitDetail.id - - query: UPDATE eg_fsm_pit_detail SET additionaldetails=?,height=?, length=?, width=?, diameter=?, distancefromroad=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=? + - query: UPDATE pg.eg_fsm_pit_detail SET additionaldetails=?,height=?, length=?, width=?, diameter=?, distancefromroad=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=? basePath: fsm.pitDetail jsonMaps: @@ -393,11 +393,11 @@ serviceMaps: - version: 1.0 description: "Persists FSTP-employee mapping in eg_fsm_plantmapping table" - fromTopic: save-plant-map-application + fromTopic: pg-save-plant-map-application isTransaction: true queryMaps: - - query: INSERT INTO eg_fsm_plantmapping( id, tenantId, status, employeeUuid, plantCode, createdBy, lastmodifiedBy, createdTime, lastmodifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_fsm_plantmapping( id, tenantId, status, employeeUuid, plantCode, createdBy, lastmodifiedBy, createdTime, lastmodifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: plantMapping jsonMaps: - jsonPath: $.plantMapping.id @@ -420,11 +420,11 @@ serviceMaps: - version: 1.0 description: "Update FSTP-employee mapping in eg_fsm_plantmapping table" - fromTopic: update-plant-map-application + fromTopic: pg-update-plant-map-application isTransaction: true queryMaps: - - query: UPDATE eg_fsm_plantmapping SET status=?, employeeuuid=?, plantcode=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=?; + - query: UPDATE pg.eg_fsm_plantmapping SET status=?, employeeuuid=?, plantcode=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? where id=?; basePath: plantMapping jsonMaps: @@ -447,11 +447,11 @@ serviceMaps: - version: 1.0 description: Vehicle Trip details in eg_vehicle_trip and in eg_vehicle_trip_detail table - fromTopic: update-vehicle-trip-Details + fromTopic: pg-update-vehicle-trip-Details isTransaction: true queryMaps: - - query: UPDATE eg_vehicle_trip_detail SET status=?, lastmodifiedby=?, lastmodifiedtime=? WHERE id=?; + - query: UPDATE pg.eg_vehicle_trip_detail SET status=?, lastmodifiedby=?, lastmodifiedtime=? WHERE id=?; basePath: $.vehicleTrip.*.tripDetails.* jsonMaps: @@ -463,7 +463,7 @@ serviceMaps: - jsonPath: $.vehicleTrip.*.tripDetails.*.id - - query: UPDATE eg_vehicle_trip SET status=?, lastmodifiedby=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vehicle_trip SET status=?, lastmodifiedby=?, lastmodifiedtime=? WHERE id=? basePath: $.vehicleTrip.* jsonMaps: @@ -477,10 +477,10 @@ serviceMaps: - version: 1.0 description: Insert FSM Application worker details in eg_fsm_application_worker table - fromTopic: create-fsm-application-workers + fromTopic: pg-create-fsm-application-workers isTransaction: true queryMaps: - - query: INSERT INTO eg_fsm_application_worker( id, tenantId, application_id, individual_id, workerType, status, additionaldetails, createdBy, lastmodifiedBy, createdTime, lastmodifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_fsm_application_worker( id, tenantId, application_id, individual_id, workerType, status, additionaldetails, createdBy, lastmodifiedBy, createdTime, lastmodifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.workers.* jsonMaps: - jsonPath: $.workers.*.id @@ -499,10 +499,10 @@ serviceMaps: - version: 1.0 description: Update FSM Application worker details in eg_fsm_application_worker table - fromTopic: update-fsm-application-workers + fromTopic: pg-update-fsm-application-workers isTransaction: true queryMaps: - - query: UPDATE eg_fsm_application_worker SET workerType=?, status=?, additionaldetails=?, createdBy=?, lastmodifiedBy=?, createdTime=?, lastmodifiedTime=? WHERE id=?; + - query: UPDATE pg.eg_fsm_application_worker SET workerType=?, status=?, additionaldetails=?, createdBy=?, lastmodifiedBy=?, createdTime=?, lastmodifiedTime=? WHERE id=?; basePath: $.workers.* jsonMaps: - jsonPath: $.workers.*.workerType diff --git a/staging/sanitation/egov-persister/pqm-anomaly-finder-persister.yaml b/staging/sanitation/egov-persister/pqm-anomaly-finder-persister.yaml index 0fd3a0bf1..ad43d783f 100644 --- a/staging/sanitation/egov-persister/pqm-anomaly-finder-persister.yaml +++ b/staging/sanitation/egov-persister/pqm-anomaly-finder-persister.yaml @@ -3,10 +3,10 @@ serviceMaps: mappings: - version: 1.0 description: Persists PQM Test Anomaly Data in eg_pqm_anomaly_details table - fromTopic: save-pqm-test-anomaly-details + fromTopic: pg-save-pqm-test-anomaly-details isTransaction: true queryMaps: - - query: INSERT INTO eg_pqm_anomaly_details(id, tenantId, testId, plantCode, anomalyType, description, referenceId, resolutionStatus, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_anomaly_details(id, tenantId, testId, plantCode, anomalyType, description, referenceId, resolutionStatus, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.pqmAnomalys.* jsonMaps: - jsonPath: $.pqmAnomalys.*.id @@ -26,7 +26,7 @@ serviceMaps: - jsonPath: $.pqmAnomalys.*.auditDetails.createdTime - jsonPath: $.pqmAnomalys.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_pqm_anomaly_details_auditlog(id, tenantId, testId, plantCode, anomalyType, description, referenceId, resolutionStatus, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_anomaly_details_auditlog(id, tenantId, testId, plantCode, anomalyType, description, referenceId, resolutionStatus, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.pqmAnomalys.* jsonMaps: - jsonPath: $.pqmAnomalys.*.id diff --git a/staging/sanitation/egov-persister/pqm-persister.yaml b/staging/sanitation/egov-persister/pqm-persister.yaml index 22562e8f1..1d2605db1 100644 --- a/staging/sanitation/egov-persister/pqm-persister.yaml +++ b/staging/sanitation/egov-persister/pqm-persister.yaml @@ -3,10 +3,10 @@ serviceMaps: mappings: - version: 1.0 description: Persists PQM Test Data in eg_pqm_tests table - fromTopic: save-test-application + fromTopic: pg-save-test-application isTransaction: true queryMaps: - - query: INSERT INTO eg_pqm_tests(id,testId, tenantId, testCode, plantCode, processCode, stageCode, materialCode, deviceCode, sourceType, status, wfStatus, scheduledDate, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_tests(id,testId, tenantId, testCode, plantCode, processCode, stageCode, materialCode, deviceCode, sourceType, status, wfStatus, scheduledDate, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.* jsonMaps: - jsonPath: $.tests.*.id @@ -32,7 +32,7 @@ serviceMaps: - jsonPath: $.tests.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_pqm_test_result_documents (id, testId, documentUid, documentUri, documentType, filestoreId, isActive, additionalDetails, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_test_result_documents (id, testId, documentUid, documentUri, documentType, filestoreId, isActive, additionalDetails, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.*.documents.* jsonMaps: - jsonPath: $.tests.*.documents.*.id @@ -50,7 +50,7 @@ serviceMaps: - jsonPath: $.tests.*.documents.*.auditDetails.createdTime - jsonPath: $.tests.*.documents.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_pqm_test_criteria_results (id, testId, criteriaCode, resultValue, resultStatus, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_test_criteria_results (id, testId, criteriaCode, resultValue, resultStatus, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.*.testCriteria.* jsonMaps: - jsonPath: $.tests.*.testCriteria.*.id @@ -64,7 +64,7 @@ serviceMaps: - jsonPath: $.tests.*.testCriteria.*.auditDetails.createdTime - jsonPath: $.tests.*.testCriteria.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_pqm_tests_auditlog (id, testId, tenantId, testCode, plantCode, processCode, stageCode, materialCode, deviceCode, sourceType, status, wfStatus, scheduledDate, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_tests_auditlog (id, testId, tenantId, testCode, plantCode, processCode, stageCode, materialCode, deviceCode, sourceType, status, wfStatus, scheduledDate, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.* jsonMaps: - jsonPath: $.tests.*.id @@ -89,7 +89,7 @@ serviceMaps: - jsonPath: $.tests.*.auditDetails.createdTime - jsonPath: $.tests.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_pqm_test_result_documents_auditlog (id, testId, documentUid, documentUri, documentType, filestoreId, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_test_result_documents_auditlog (id, testId, documentUid, documentUri, documentType, filestoreId, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.*.documents.* jsonMaps: - jsonPath: $.tests.*.documents.*.id @@ -107,7 +107,7 @@ serviceMaps: - jsonPath: $.tests.*.documents.*.auditDetails.createdTime - jsonPath: $.tests.*.documents.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_pqm_test_criteria_results_auditlog (id, testId, criteriaCode, resultValue, resultStatus, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_test_criteria_results_auditlog (id, testId, criteriaCode, resultValue, resultStatus, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.*.testCriteria.* jsonMaps: - jsonPath: $.tests.*.testCriteria.*.id @@ -123,11 +123,11 @@ serviceMaps: - version: 1.0 description: Update PQM Application details in eg_pqm_tests table - fromTopic: update-test-application + fromTopic: pg-update-test-application isTransaction: true queryMaps: - - query: UPDATE eg_pqm_tests SET status = ?, wfStatus = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ?, labAssignedTo = ? WHERE testId = ?; + - query: UPDATE pg.eg_pqm_tests SET status = ?, wfStatus = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ?, labAssignedTo = ? WHERE testId = ?; basePath: $.tests.* jsonMaps: - jsonPath: $.tests.*.status @@ -138,11 +138,11 @@ serviceMaps: - jsonPath: $.tests.*.auditDetails.lastModifiedTime - jsonPath: $.tests.*.labAssignedTo - jsonPath: $.tests.*.testId - - query: INSERT INTO eg_pqm_tests_auditlog SELECT * FROM eg_pqm_tests WHERE testId = ? + - query: INSERT INTO pg.eg_pqm_tests_auditlog SELECT * FROM pg.eg_pqm_tests WHERE testId = ? basePath: $.tests.* jsonMaps: - jsonPath: $.tests.*.testId - - query: INSERT INTO eg_pqm_test_result_documents (id, testId, documentUid, documentUri, documentType, filestoreId, isActive, additionalDetails, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_test_result_documents (id, testId, documentUid, documentUri, documentType, filestoreId, isActive, additionalDetails, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.*.documents.* jsonMaps: - jsonPath: $.tests.*.documents.*.id @@ -159,7 +159,7 @@ serviceMaps: - jsonPath: $.tests.*.documents.*.auditDetails.lastModifiedBy - jsonPath: $.tests.*.documents.*.auditDetails.createdTime - jsonPath: $.tests.*.documents.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_pqm_test_result_documents_auditlog (id, testId, documentUid, documentUri, documentType, filestoreId, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_test_result_documents_auditlog (id, testId, documentUid, documentUri, documentType, filestoreId, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.*.documents.* jsonMaps: - jsonPath: $.tests.*.documents.*.id @@ -177,12 +177,12 @@ serviceMaps: - jsonPath: $.tests.*.documents.*.auditDetails.createdTime - jsonPath: $.tests.*.documents.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_pqm_test_criteria_results_auditlog SELECT * FROM eg_pqm_test_criteria_results WHERE id = ? + - query: INSERT INTO pg.eg_pqm_test_criteria_results_auditlog SELECT * FROM eg_pqm_test_criteria_results WHERE id = ? basePath: $.tests.*.testCriteria.* jsonMaps: - jsonPath: $.tests.*.testCriteria.*.id - - query: UPDATE eg_pqm_test_criteria_results SET resultValue = ?, resultStatus = ?, isActive = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE id = ?; + - query: UPDATE pg.eg_pqm_test_criteria_results SET resultValue = ?, resultStatus = ?, isActive = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE id = ?; basePath: $.tests.*.testCriteria.* jsonMaps: - jsonPath: $.tests.*.testCriteria.*.resultValue @@ -197,15 +197,15 @@ serviceMaps: - version: 1.0 description: Update PQM Application details in eg_pqm_tests table - fromTopic: update-workflow-test-application + fromTopic: pg-update-workflow-test-application isTransaction: true queryMaps: - - query: INSERT INTO eg_pqm_tests_auditlog SELECT * FROM eg_pqm_tests WHERE testId = ? + - query: INSERT INTO pg.eg_pqm_tests_auditlog SELECT * FROM pg.eg_pqm_tests WHERE testId = ? basePath: $.tests.* jsonMaps: - jsonPath: $.tests.*.testId - - query: UPDATE eg_pqm_tests SET status = ?,wfStatus = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE testId = ?; + - query: UPDATE pg.eg_pqm_tests SET status = ?,wfStatus = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE testId = ?; basePath: $.tests.* jsonMaps: - jsonPath: $.tests.*.status @@ -216,12 +216,12 @@ serviceMaps: - jsonPath: $.tests.*.auditDetails.lastModifiedTime - jsonPath: $.tests.*.testId - - query: INSERT INTO eg_pqm_test_criteria_results_auditlog SELECT * FROM eg_pqm_test_criteria_results WHERE id = ? + - query: INSERT INTO pg.eg_pqm_test_criteria_results_auditlog SELECT * FROM pg.eg_pqm_test_criteria_results WHERE id = ? basePath: $.tests.*.testCriteria.* jsonMaps: - jsonPath: $.tests.*.testCriteria.*.id - - query: UPDATE eg_pqm_test_criteria_results SET resultValue = ?, resultStatus = ?, isActive = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE id = ?; + - query: UPDATE pg.eg_pqm_test_criteria_results SET resultValue = ?, resultStatus = ?, isActive = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE id = ?; basePath: $.tests.*.testCriteria.* jsonMaps: - jsonPath: $.tests.*.testCriteria.*.resultValue @@ -236,10 +236,10 @@ serviceMaps: - version: 1.0 description: Save plant and user mapping in eq_plant_user_map table - fromTopic: save-plant-user-mapping + fromTopic: pg-save-plant-user-mapping isTransaction: true queryMaps: - - query: INSERT INTO eq_plant_user_map(id, tenantId, plantCode, plantUserUuid, plantUserType, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eq_plant_user_map(id, tenantId, plantCode, plantUserUuid, plantUserType, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.plantUsers.* jsonMaps: - jsonPath: $.plantUsers.*.id @@ -256,7 +256,7 @@ serviceMaps: - jsonPath: $.plantUsers.*.auditDetails.createdTime - jsonPath: $.plantUsers.*.auditDetails.lastModifiedTime - - query: INSERT INTO eq_plant_user_map_auditlog(id, tenantId, plantCode, plantUserUuid, plantUserType, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eq_plant_user_map_auditlog(id, tenantId, plantCode, plantUserUuid, plantUserType, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.plantUsers.* jsonMaps: - jsonPath: $.plantUsers.*.id @@ -275,15 +275,15 @@ serviceMaps: - version: 1.0 description: Update plant and user mapping in eq_plant_user_map table - fromTopic: update-plant-user-mapping + fromTopic: pg-update-plant-user-mapping isTransaction: true queryMaps: - - query: INSERT INTO eq_plant_user_map_auditlog SELECT * FROM eq_plant_user_map WHERE id = ? + - query: INSERT INTO pg.eq_plant_user_map_auditlog SELECT * FROM pg.eq_plant_user_map WHERE id = ? basePath: $.plantUsers.* jsonMaps: - jsonPath: $.plantUsers.*.id - - query: UPDATE eq_plant_user_map SET isActive = ?, additionalDetails = ?::jsonb, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE id = ?; + - query: UPDATE pg.eq_plant_user_map SET isActive = ?, additionalDetails = ?::jsonb, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE id = ?; basePath: $.plantUsers.* jsonMaps: - jsonPath: $.plantUsers.*.isActive @@ -298,10 +298,10 @@ serviceMaps: - version: 1.0 description: Update test result documents - fromTopic: update-test-documents + fromTopic: pg-update-test-documents isTransaction: true queryMaps: - - query: UPDATE eg_pqm_test_result_documents SET documentUid = ?, documentUri = ?, documentType = ?, filestoreId = ?, isActive = ?, additionalDetails = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE id = ?; + - query: UPDATE pg.eg_pqm_test_result_documents SET documentUid = ?, documentUri = ?, documentType = ?, filestoreId = ?, isActive = ?, additionalDetails = ?, createdBy = ?, lastModifiedBy = ?, createdTime = ?, lastModifiedTime = ? WHERE id = ?; basePath: $.tests.*.documents.* jsonMaps: - jsonPath: $.tests.*.documents.*.documentUid @@ -319,7 +319,7 @@ serviceMaps: - jsonPath: $.tests.*.documents.*.id - - query: INSERT INTO eg_pqm_test_result_documents_auditlog (id, testId, documentUid, documentUri, documentType, filestoreId, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_pqm_test_result_documents_auditlog (id, testId, documentUid, documentUri, documentType, filestoreId, additionalDetails, isActive, createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.tests.*.documents.* jsonMaps: - jsonPath: $.tests.*.documents.*.id diff --git a/staging/sanitation/egov-persister/vehicle-persister.yaml b/staging/sanitation/egov-persister/vehicle-persister.yaml index 299feac9b..59bf8e5a2 100644 --- a/staging/sanitation/egov-persister/vehicle-persister.yaml +++ b/staging/sanitation/egov-persister/vehicle-persister.yaml @@ -3,10 +3,10 @@ serviceMaps: mappings: - version: 1.0 description: Persists Vehicle Application details in eg_vehicle table - fromTopic: save-vehicle-application + fromTopic: pg-save-vehicle-application isTransaction: true queryMaps: - - query : INSERT INTO eg_vehicle( id, tenantId, registrationNumber, model, type, tankCapicity, suctionType, pollutionCertiValidTill, InsuranceCertValidTill, fitnessValidTill, roadTaxPaidTill, gpsEnabled, source, status, additionalDetails, owner_id , createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query : INSERT INTO pg.eg_vehicle( id, tenantId, registrationNumber, model, type, tankCapicity, suctionType, pollutionCertiValidTill, InsuranceCertValidTill, fitnessValidTill, roadTaxPaidTill, gpsEnabled, source, status, additionalDetails, owner_id , createdBy, lastModifiedBy, createdTime, lastModifiedTime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: vehicle jsonMaps: - jsonPath: $.vehicle.id @@ -34,16 +34,16 @@ serviceMaps: - version: 1.0 description: Persists Vehicle Application details in eg_vehicle table - fromTopic: update-vehicle-application + fromTopic: pg-update-vehicle-application isTransaction: true queryMaps: - - query : INSERT INTO eg_vehicle_auditlog SELECT * FROM eg_vehicle WHERE id=? + - query : INSERT INTO pg.eg_vehicle_auditlog SELECT * FROM pg.eg_vehicle WHERE id=? basePath: vehicle jsonMaps: - jsonPath: $.vehicle.id - - query : UPDATE eg_vehicle SET tenantId=?, registrationNumber=?, model=?, type=?, tankCapicity=?, suctionType=?, pollutionCertiValidTill=?, InsuranceCertValidTill=?, fitnessValidTill=?, roadTaxPaidTill=?, gpsEnabled=?, source=?, status=?, additionalDetails=?, owner_id =?, createdBy=?, lastModifiedBy=?, createdTime=?, lastModifiedTime=? WHERE id=? + - query : UPDATE pg.eg_vehicle SET tenantId=?, registrationNumber=?, model=?, type=?, tankCapicity=?, suctionType=?, pollutionCertiValidTill=?, InsuranceCertValidTill=?, fitnessValidTill=?, roadTaxPaidTill=?, gpsEnabled=?, source=?, status=?, additionalDetails=?, owner_id =?, createdBy=?, lastModifiedBy=?, createdTime=?, lastModifiedTime=? WHERE id=? basePath: vehicle jsonMaps: - jsonPath: $.vehicle.tenantId @@ -71,11 +71,11 @@ serviceMaps: - version: 1.0 description: Vehicle Trip details in eg_vehicle_log table - fromTopic: save-vehicle-trip + fromTopic: pg-save-vehicle-trip isTransaction: true queryMaps: - - query: INSERT INTO eg_vehicle_trip(id, tenantid, owner_id, driver_id, vehicle_id, applicationno, additionaldetails, status, businessservice, applicationstatus, tripstarttime, tripendtime, volumecarried, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_vehicle_trip(id, tenantid, owner_id, driver_id, vehicle_id, applicationno, additionaldetails, status, businessservice, applicationstatus, tripstarttime, tripendtime, volumecarried, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.vehicleTrip.* jsonMaps: - jsonPath: $.vehicleTrip.*.id @@ -115,7 +115,7 @@ serviceMaps: - jsonPath: $.vehicleTrip.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_vehicle_trip_detail( id, tenantid, trip_id, referenceno, referencestatus, additionaldetails, status, itemstarttime, itemendtime, volume, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_vehicle_trip_detail( id, tenantid, trip_id, referenceno, referencestatus, additionaldetails, status, itemstarttime, itemendtime, volume, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: $.vehicleTrip.*.tripDetails.* jsonMaps: @@ -152,10 +152,10 @@ serviceMaps: - version: 1.0 description: Vehicle Trip details in eg_vehicle_trip table - fromTopic: update-vehicle-trip + fromTopic: pg-update-vehicle-trip isTransaction: true queryMaps: - - query: UPDATE eg_vehicle_trip SET driver_id=?, applicationno=?, additionaldetails=?, status=?, applicationstatus=?, tripstarttime=?, tripendtime=?, volumecarried=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vehicle_trip SET driver_id=?, applicationno=?, additionaldetails=?, status=?, applicationstatus=?, tripstarttime=?, tripendtime=?, volumecarried=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: $.vehicleTrip.* jsonMaps: @@ -188,7 +188,7 @@ serviceMaps: - jsonPath: $.vehicleTrip.*.id - - query: UPDATE eg_vehicle_trip_detail SET referencestatus=?, additionaldetails=?, status=?, itemstarttime=?, itemendtime=?, volume=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vehicle_trip_detail SET referencestatus=?, additionaldetails=?, status=?, itemstarttime=?, itemendtime=?, volume=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: $.vehicleTrip.*.tripDetails.* jsonMaps: @@ -219,10 +219,10 @@ serviceMaps: - version: 1.0 description: Vehicle Trip details in eg_vehicle_trip table - fromTopic: update-workflow-vehicle-trip + fromTopic: pg-update-workflow-vehicle-trip isTransaction: true queryMaps: - - query: UPDATE eg_vehicle_trip SET driver_id=?, applicationno=?, additionaldetails=?, status=?, applicationstatus=?, tripstarttime=?, tripendtime=?, volumecarried=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vehicle_trip SET driver_id=?, applicationno=?, additionaldetails=?, status=?, applicationstatus=?, tripstarttime=?, tripendtime=?, volumecarried=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: $.vehicleTrip.* jsonMaps: @@ -255,7 +255,7 @@ serviceMaps: - jsonPath: $.vehicleTrip.*.id - - query: UPDATE eg_vehicle_trip_detail SET referencestatus=?, additionaldetails=?, status=?, itemstarttime=?, itemendtime=?, volume=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vehicle_trip_detail SET referencestatus=?, additionaldetails=?, status=?, itemstarttime=?, itemendtime=?, volume=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: $.vehicleTrip.*.tripDetails.* jsonMaps: diff --git a/staging/sanitation/egov-persister/vendor-persister.yaml b/staging/sanitation/egov-persister/vendor-persister.yaml index 5c46f67fd..7e2a3a688 100644 --- a/staging/sanitation/egov-persister/vendor-persister.yaml +++ b/staging/sanitation/egov-persister/vendor-persister.yaml @@ -3,11 +3,11 @@ serviceMaps: mappings: - version: 1.0 description: Vendor Registion Application details in eg_vendor table - fromTopic: save-vendor-application + fromTopic: pg-save-vendor-application isTransaction: true queryMaps: - - query: INSERT INTO eg_vendor( id, name, tenantid, additionaldetails, owner_id, description, source, status,agencyType,paymentPreference,createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ); + - query: INSERT INTO pg.eg_vendor( id, name, tenantid, additionaldetails, owner_id, description, source, status,agencyType,paymentPreference,createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ); basePath: vendor jsonMaps: - jsonPath: $.vendor.id @@ -41,7 +41,7 @@ serviceMaps: - jsonPath: $.vendor.auditDetails.lastModifiedTime - - query: INSERT INTO eg_vendor_address(id, tenantid, doorno, plotno, landmark, city, district, region, state, country, locality, pincode, additionalDetails, buildingname, street, vendor_id, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_vendor_address(id, tenantid, doorno, plotno, landmark, city, district, region, state, country, locality, pincode, additionalDetails, buildingname, street, vendor_id, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: vendor.address jsonMaps: - jsonPath: $.vendor.address.id @@ -88,7 +88,7 @@ serviceMaps: - - query: INSERT INTO eg_driver( id, name, tenantid, additionaldetails, owner_id, description, status,licenseNumber, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_driver( id, name, tenantid, additionaldetails, owner_id, description, status,licenseNumber, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: vendor.drivers.* jsonMaps: - jsonPath: $.vendor.drivers.*.id @@ -106,21 +106,21 @@ serviceMaps: - jsonPath: $.vendor.drivers.*.auditDetails.createdTime - jsonPath: $.vendor.drivers.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_vendor_driver( vendor_id, driver_id, vendordriverstatus) VALUES ( ?, ?, ?); + - query: INSERT INTO pg.eg_vendor_driver( vendor_id, driver_id, vendordriverstatus) VALUES ( ?, ?, ?); basePath: vendor.drivers.* jsonMaps: - jsonPath: $.vendor.id - jsonPath: $.vendor.drivers.*.id - jsonPath: $.vendor.drivers.*.vendorDriverStatus - - query: INSERT INTO eg_vendor_vehicle( vendor_id,vechile_id, vendorVehicleStatus) VALUES ( ?, ?, ?); + - query: INSERT INTO pg.eg_vendor_vehicle( vendor_id,vechile_id, vendorVehicleStatus) VALUES ( ?, ?, ?); basePath: vendor.vehicles.* jsonMaps: - jsonPath: $.vendor.id - jsonPath: $.vendor.vehicles.*.id - jsonPath: $.vendor.vehicles.*.vendorVehicleStatus - - query: INSERT INTO eg_vendor_sanitation_worker( id, tenantid, vendor_id, individual_id, additionaldetails, vendor_sw_status, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_vendor_sanitation_worker( id, tenantid, vendor_id, individual_id, additionaldetails, vendor_sw_status, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: vendor.workers.* jsonMaps: - jsonPath: $.vendor.workers.*.id @@ -138,16 +138,16 @@ serviceMaps: - version: 1.0 description: Update Vendor details - fromTopic: update-vendor-application + fromTopic: pg-update-vendor-application isTransaction: true queryMaps: - - query: INSERT INTO eg_vendor_auditlog SELECT * FROM eg_vendor WHERE id=? + - query: INSERT INTO pg.eg_vendor_auditlog SELECT * FROM pg.eg_vendor WHERE id=? basePath: vendor jsonMaps: - jsonPath: $.vendor.id - - query: UPDATE eg_vendor SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, source=?, status=?, agencyType=?, paymentPreference=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vendor SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, source=?, status=?, agencyType=?, paymentPreference=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: vendor jsonMaps: - jsonPath: $.vendor.name @@ -167,12 +167,12 @@ serviceMaps: - jsonPath: $.vendor.auditDetails.lastModifiedTime - jsonPath: $.vendor.id - - query: INSERT INTO eg_vendor_address_auditlog SELECT * FROM eg_vendor_address WHERE id=? + - query: INSERT INTO pg.eg_vendor_address_auditlog SELECT * FROM pg.eg_vendor_address WHERE id=? basePath: vendor.address jsonMaps: - jsonPath: $.vendor.address.id - - query: UPDATE eg_vendor_address SET tenantid=?, doorno=?, plotno=?, landmark=?, city=?, district=?, region=?, state=?, country=?, locality=?, pincode=?, additionalDetails=?, buildingname=?, street=?, vendor_id=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vendor_address SET tenantid=?, doorno=?, plotno=?, landmark=?, city=?, district=?, region=?, state=?, country=?, locality=?, pincode=?, additionalDetails=?, buildingname=?, street=?, vendor_id=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: vendor.address jsonMaps: - jsonPath: $.vendor.address.tenantId @@ -198,12 +198,12 @@ serviceMaps: - jsonPath: $.vendor.address.auditDetails.lastModifiedTime - jsonPath: $.vendor.address.id - - query: INSERT INTO eg_driver_auditlog SELECT * FROM eg_driver WHERE id=? + - query: INSERT INTO pg.eg_driver_auditlog SELECT * FROM pg.eg_driver WHERE id=? basePath: vendor.drivers.* jsonMaps: - jsonPath: $.vendor.drivers.*.id - - query: UPDATE eg_driver SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, status=?, licenseNumber=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_driver SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, status=?, licenseNumber=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: vendor.drivers.* jsonMaps: - jsonPath: $.vendor.drivers.*.name @@ -221,7 +221,7 @@ serviceMaps: - jsonPath: $.vendor.drivers.*.auditDetails.lastModifiedTime - jsonPath: $.vendor.drivers.*.id - - query: UPDATE eg_vendor_sanitation_worker SET tenantid=?, vendor_id= ?, vendor_sw_status=?, additionaldetails=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE individual_id=? + - query: UPDATE pg.eg_vendor_sanitation_worker SET tenantid=?, vendor_id= ?, vendor_sw_status=?, additionaldetails=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE individual_id=? basePath: vendor.workers.* jsonMaps: - jsonPath: $.vendor.workers.*.tenantId @@ -236,14 +236,14 @@ serviceMaps: - jsonPath: $.vendor.workers.*.auditDetails.lastModifiedTime - jsonPath: $.vendor.workers.*.individualId - - query: UPDATE EG_VENDOR_DRIVER SET vendor_id= ?, vendorDriverStatus= ? WHERE DRIVER_ID= ? ; + - query: UPDATE pg.EG_VENDOR_DRIVER SET vendor_id= ?, vendorDriverStatus= ? WHERE DRIVER_ID= ? ; basePath: vendor.drivers.* jsonMaps: - jsonPath: $.vendor.id - jsonPath: $.vendor.drivers.*.vendorDriverStatus - jsonPath: $.vendor.drivers.*.id - - query: UPDATE eg_vendor_vehicle SET vendor_id= ?,vendorVehicleStatus= ? WHERE VECHILE_ID= ? ; + - query: UPDATE pg.eg_vendor_vehicle SET vendor_id= ?,vendorVehicleStatus= ? WHERE VECHILE_ID= ? ; basePath: vendor.vehicles.* jsonMaps: - jsonPath: $.vendor.id @@ -252,16 +252,16 @@ serviceMaps: - version: 1.0 description: Update Vendor details - fromTopic: save-vendordrivervehicle-application + fromTopic: pg-save-vendordrivervehicle-application isTransaction: true queryMaps: - - query: INSERT INTO eg_vendor_auditlog SELECT * FROM eg_vendor WHERE id=? + - query: INSERT INTO pg.eg_vendor_auditlog SELECT * FROM pg.eg_vendor WHERE id=? basePath: vendor jsonMaps: - jsonPath: $.vendor.id - - query: UPDATE eg_vendor SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, source=?, status=?, agencyType=?, paymentPreference=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vendor SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, source=?, status=?, agencyType=?, paymentPreference=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: vendor jsonMaps: - jsonPath: $.vendor.name @@ -281,12 +281,12 @@ serviceMaps: - jsonPath: $.vendor.auditDetails.lastModifiedTime - jsonPath: $.vendor.id - - query: INSERT INTO eg_vendor_address_auditlog SELECT * FROM eg_vendor_address WHERE id=? + - query: INSERT INTO pg.eg_vendor_address_auditlog SELECT * FROM pg.eg_vendor_address WHERE id=? basePath: vendor.address jsonMaps: - jsonPath: $.vendor.address.id - - query: UPDATE eg_vendor_address SET tenantid=?, doorno=?, plotno=?, landmark=?, city=?, district=?, region=?, state=?, country=?, locality=?, pincode=?, additionalDetails=?, buildingname=?, street=?, vendor_id=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_vendor_address SET tenantid=?, doorno=?, plotno=?, landmark=?, city=?, district=?, region=?, state=?, country=?, locality=?, pincode=?, additionalDetails=?, buildingname=?, street=?, vendor_id=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: vendor.address jsonMaps: - jsonPath: $.vendor.address.tenantId @@ -312,12 +312,12 @@ serviceMaps: - jsonPath: $.vendor.address.auditDetails.lastModifiedTime - jsonPath: $.vendor.address.id - - query: INSERT INTO eg_driver_auditlog SELECT * FROM eg_driver WHERE id=? + - query: INSERT INTO pg.eg_driver_auditlog SELECT * FROM pg.eg_driver WHERE id=? basePath: vendor.drivers.* jsonMaps: - jsonPath: $.vendor.drivers.*.id - - query: UPDATE eg_driver SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, status=?, licenseNumber=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_driver SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, status=?, licenseNumber=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: vendor.drivers.* jsonMaps: - jsonPath: $.vendor.drivers.*.name @@ -335,7 +335,7 @@ serviceMaps: - jsonPath: $.vendor.drivers.*.auditDetails.lastModifiedTime - jsonPath: $.vendor.drivers.*.id - - query: INSERT INTO eg_vendor_sanitation_worker( id, tenantid, vendor_id, individual_id, additionaldetails, vendor_sw_status, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_vendor_sanitation_worker( id, tenantid, vendor_id, individual_id, additionaldetails, vendor_sw_status, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: vendor.workers.* jsonMaps: - jsonPath: $.vendor.workers.*.id @@ -351,14 +351,14 @@ serviceMaps: - jsonPath: $.vendor.workers.*.auditDetails.createdTime - jsonPath: $.vendor.workers.*.auditDetails.lastModifiedTime - - query: INSERT INTO eg_vendor_driver(vendor_id, driver_id, vendordriverstatus) VALUES ( ?, ?, ?); + - query: INSERT INTO pg.eg_vendor_driver(vendor_id, driver_id, vendordriverstatus) VALUES ( ?, ?, ?); basePath: vendor.drivers.* jsonMaps: - jsonPath: $.vendor.id - jsonPath: $.vendor.drivers.*.id - jsonPath: $.vendor.drivers.*.vendorDriverStatus - - query: INSERT INTO eg_vendor_vehicle(vendor_id,vechile_id, vendorVehicleStatus) VALUES ( ?, ?, ?); + - query: INSERT INTO pg.eg_vendor_vehicle(vendor_id,vechile_id, vendorVehicleStatus) VALUES ( ?, ?, ?); basePath: vendor.vehicles.* jsonMaps: - jsonPath: $.vendor.id @@ -367,11 +367,11 @@ serviceMaps: - version: 1.0 description: Driver Registration Application details in eg_driver table - fromTopic: save-driver-application + fromTopic: pg-save-driver-application isTransaction: true queryMaps: - - query: INSERT INTO eg_driver( id, name, tenantid, additionaldetails, owner_id, description, status,licenseNumber, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); + - query: INSERT INTO pg.eg_driver( id, name, tenantid, additionaldetails, owner_id, description, status,licenseNumber, createdby, lastmodifiedby, createdtime, lastmodifiedtime) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?); basePath: driver jsonMaps: - jsonPath: $.driver.id @@ -393,16 +393,16 @@ serviceMaps: - version: 1.0 description: Update Driver details - fromTopic: update-driver-application + fromTopic: pg-update-driver-application isTransaction: true queryMaps: - - query: INSERT INTO eg_driver_auditlog SELECT * FROM eg_driver WHERE id=? + - query: INSERT INTO pg.eg_driver_auditlog SELECT * FROM pg.eg_driver WHERE id=? basePath: driver jsonMaps: - jsonPath: $.driver.id - - query: UPDATE eg_driver SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, status=?, licenseNumber=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? + - query: UPDATE pg.eg_driver SET name=?, tenantid=?, additionaldetails=?, owner_id=?, description=?, status=?, licenseNumber=?, createdby=?, lastmodifiedby=?, createdtime=?, lastmodifiedtime=? WHERE id=? basePath: driver jsonMaps: - jsonPath: $.driver.name