While inserting convert from MUT to UTC

Author: HariharanAnantharaman

accessdatareader/src/com/techolution/smartwater/accessdb/AccessDataReadaer.java

@@ -106,7 +106,7 @@ private JSONObject getRowToFlowJson(ResultSet rs) throws SQLException{
 		Date date=new Date(timestamp.getTime());
 		SimpleDateFormat myFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSZ");
 		String dateVal=myFormat.format(date);
-		
+		System.out.println("Date val is:"+dateVal);
 		JSONObject json = new JSONObject();
 		json.put("flow", flow);    
 		json.put("date", dateVal);

connectionstatistics/src/main/java/com/techolution/mauritius/smartwater/connection/service/ConnectionStatisticsService.java

@@ -441,8 +441,9 @@ public void insertData(Telemetry telemetry){
 		}else{
 
 			Calendar date=Calendar.getInstance(TimeZone.getTimeZone(influxProperties.getDatatimezone()));
+			
 			//Date inputDate=telemetry.getDate();
-			Calendar inputCal=Calendar.getInstance();
+			Calendar inputCal=Calendar.getInstance(TimeZone.getTimeZone(influxProperties.getDatatimezone()));
 			inputCal.setTime(telemetry.getDate());
 			date.set(Calendar.YEAR,inputCal.get(Calendar.YEAR));
 			date.set(Calendar.MONTH,inputCal.get(Calendar.MONTH));
@@ -889,7 +890,7 @@ public void insertTimeSeriesData(SeriesPointData pointData){
 
 				Calendar date=Calendar.getInstance(TimeZone.getTimeZone(influxProperties.getDatatimezone()));
 				//Date inputDate=telemetry.getDate();
-				Calendar inputCal=Calendar.getInstance();
+				Calendar inputCal=Calendar.getInstance(TimeZone.getTimeZone(influxProperties.getDatatimezone()));
 				inputCal.setTime(pointData.getTimestamp());
 				date.set(Calendar.YEAR,inputCal.get(Calendar.YEAR));
 				date.set(Calendar.MONTH,inputCal.get(Calendar.MONTH));

notificationservice/src/main/java/com/techolution/mauritius/smartwater/notification/domain/MeterConnection.java

@@ -1,9 +1,11 @@
 package com.techolution.mauritius.smartwater.notification.domain;
 
 import java.io.Serializable;
+import java.util.Set;
 
 import javax.persistence.Entity;
 import javax.persistence.Id;
+import javax.persistence.OneToMany;
 import javax.persistence.Table;
 
 @Entity
@@ -109,5 +111,8 @@ public String getCurrentstatus() {
 	public void setCurrentstatus(String currentstatus) {
 		this.currentstatus = currentstatus;
 	}
+	
+	@OneToMany(mappedBy="house_id")
+	Set<NotificationDetails> notifications;
 
 }

notificationservice/src/main/java/com/techolution/mauritius/smartwater/notification/domain/NotificationDetails.java

@@ -7,6 +7,7 @@
 import javax.persistence.FetchType;
 import javax.persistence.Id;
 import javax.persistence.JoinColumn;
+import javax.persistence.JoinTable;
 import javax.persistence.ManyToOne;
 import javax.persistence.Table;
 
@@ -110,8 +111,8 @@ public void setInformation(String information) {
 	private String information;
 
 
-	/*@ManyToOne(fetch = FetchType.EAGER)
-	@JoinColumn(name="meter_id", nullable=true)
-	private MeterConnection connection ;*/
+	@ManyToOne(fetch = FetchType.EAGER)
+	@JoinTable(name="connection_details",joinColumns= @JoinColumn(name="meter_id", referencedColumnName = "house_id"))
+	private MeterConnection connection ;
 
 }