#CCSD-69 central Instance changes for fsm and tqm

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

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

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

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

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

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

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

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

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

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