ISTE-44: Added demand change audit db script from ws-calculator service

egovernments · May 24, 2024 · f87fb13 · f87fb13
1 parent 3504cdd
commit f87fb13
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/...al-services/ws-calculator/src/main/java/org/egov/wscalculation/service/DemandService.java b/...al-services/ws-calculator/src/main/java/org/egov/wscalculation/service/DemandService.java
@@ -284,7 +284,6 @@ private List<Demand> createDemand(RequestInfo requestInfo, List<Calculation> cal
 							createdby(requestInfo.getUserInfo().getUuid()).
 							createdtime(System.currentTimeMillis()).build();
 					WsDemandChangeAuditRequestWrapper wsDemandChangeAuditRequestWrapper = WsDemandChangeAuditRequestWrapper.builder().wsDemandChangeAuditRequest(wsDemandChangeAuditRequest).build();
-					log.info("WsDemandChangeAuditRequestWrapper:"+wsDemandChangeAuditRequestWrapper);
 					producer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequestWrapper);
 				});
 			}
@@ -901,7 +900,8 @@ public List<Demand> updateDemands(GetBillCriteria getBillCriteria, RequestInfoWr
 									data(demand).
 									createdby(demand.getAuditDetails().getCreatedBy()).
 									createdtime(demand.getAuditDetails().getLastModifiedTime()).build();
-							producer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequest);
+							WsDemandChangeAuditRequestWrapper wsDemandChangeAuditRequestWrapper = WsDemandChangeAuditRequestWrapper.builder().wsDemandChangeAuditRequest(wsDemandChangeAuditRequest).build();
+							producer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequestWrapper);
 						});
 					}
 					DemandRequest request = DemandRequest.builder().demands(demandsToBeUpdated).requestInfo(requestInfo).build();
@@ -975,7 +975,8 @@ private List<Demand> updateDemandForCalculation(RequestInfo requestInfo, List<Ca
 							data(dem).
 							createdby(dem.getAuditDetails().getCreatedBy()).
 							createdtime(dem.getAuditDetails().getLastModifiedTime()).build();
-					producer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequest);
+					WsDemandChangeAuditRequestWrapper wsDemandChangeAuditRequestWrapper = WsDemandChangeAuditRequestWrapper.builder().wsDemandChangeAuditRequest(wsDemandChangeAuditRequest).build();
+					producer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequestWrapper);
 				});
 			}
 			demandRes = demandRepository.updateDemand(requestInfo, demands);
@@ -1418,7 +1419,8 @@ public int compare(Demand d1, Demand d2) {
 						data(demand).
 						createdby(demand.getAuditDetails().getCreatedBy()).
 						createdtime(demand.getAuditDetails().getLastModifiedTime()).build();
-				producer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequest);
+				WsDemandChangeAuditRequestWrapper wsDemandChangeAuditRequestWrapper = WsDemandChangeAuditRequestWrapper.builder().wsDemandChangeAuditRequest(wsDemandChangeAuditRequest).build();
+				producer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequestWrapper);
 			});
 		}
 		demandRepository.updateDemand(requestInfo, demands);

diff --git a/.../ws-calculator/src/main/java/org/egov/wscalculation/service/WSCalculationServiceImpl.java b/.../ws-calculator/src/main/java/org/egov/wscalculation/service/WSCalculationServiceImpl.java
@@ -129,7 +129,8 @@ public List<Calculation> getCalculation(CalculationReq request) {
 							data(demand).
 							createdby(demand.getAuditDetails().getCreatedBy()).
 							createdtime(demand.getAuditDetails().getLastModifiedTime()).build();
-					wsCalculationProducer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequest);
+					WsDemandChangeAuditRequestWrapper wsDemandChangeAuditRequestWrapper = WsDemandChangeAuditRequestWrapper.builder().wsDemandChangeAuditRequest(wsDemandChangeAuditRequest).build();
+					wsCalculationProducer.push(config.getSaveDemandAudit(), wsDemandChangeAuditRequestWrapper);
 				});
 			}
 			demandRepository.updateDemand(request.getRequestInfo(), searchResult);