=== modified file 'dhis-2/dhis-services/dhis-service-dxf2/src/main/java/org/hisp/dhis/dxf2/events/event/JdbcEventStore.java' --- dhis-2/dhis-services/dhis-service-dxf2/src/main/java/org/hisp/dhis/dxf2/events/event/JdbcEventStore.java 2015-04-21 16:11:31 +0000 +++ dhis-2/dhis-services/dhis-service-dxf2/src/main/java/org/hisp/dhis/dxf2/events/event/JdbcEventStore.java 2015-04-21 16:44:14 +0000 @@ -102,7 +102,7 @@ event = new Event(); event.setEvent( rowSet.getString( "psi_uid" ) ); - event.setTrackedEntityInstance( rowSet.getString( "pa_uid" ) ); + event.setTrackedEntityInstance( rowSet.getString( "tei_uid" ) ); event.setStatus( EventStatus.valueOf( rowSet.getString( "psi_status" ) ) ); event.setProgram( IdSchemes.getValue( rowSet.getString( "p_uid" ), rowSet.getString( "p_code" ), idSchemes.getProgramIdScheme() ) ); @@ -205,20 +205,22 @@ SqlHelper hlp = new SqlHelper(); String sql = - "select pa.uid as tei_uid, pi.uid as pi_uid, pi.status as pi_status, pi.followup as pi_followup, p.uid as p_uid, p.code as p_code, " + - "p.type as p_type, ps.uid as ps_uid, ps.code as ps_code, ps.capturecoordinates as ps_capturecoordinates, pa.uid as pa_uid, " + + "select pi.uid as pi_uid, pi.status as pi_status, pi.followup as pi_followup, p.uid as p_uid, p.code as p_code, " + + "p.type as p_type, ps.uid as ps_uid, ps.code as ps_code, ps.capturecoordinates as ps_capturecoordinates, " + "psi.uid as psi_uid, psi.status as psi_status, ou.uid as ou_uid, ou.code as ou_code, ou.name as ou_name, " + "psi.executiondate as psi_executiondate, psi.duedate as psi_duedate, psi.completeduser as psi_completeduser, " + "psi.longitude as psi_longitude, psi.latitude as psi_latitude, psi.created as psi_created, psi.lastupdated as psi_lastupdated, " + "psinote.trackedentitycommentid as psinote_id, psinote.commenttext as psinote_value, " + "psinote.createddate as psinote_storeddate, psinote.creator as psinote_storedby, " + - "pdv.value as pdv_value, pdv.storedby as pdv_storedby, pdv.providedelsewhere as pdv_providedelsewhere, de.uid as de_uid, de.code as de_code " + + "pdv.value as pdv_value, pdv.storedby as pdv_storedby, pdv.providedelsewhere as pdv_providedelsewhere, " + + "de.uid as de_uid, de.code as de_code, tei.uid as tei_uid " + "from programstageinstance psi " + "inner join programinstance pi on pi.programinstanceid=psi.programinstanceid " + "inner join program p on p.programid=pi.programid " + "inner join programstage ps on ps.programid=p.programid " + "left join programstageinstancecomments psic on psi.programstageinstanceid=psic.programstageinstanceid " + - "left join trackedentitycomment psinote on psic.trackedentitycommentid=psinote.trackedentitycommentid "; + "left join trackedentitycomment psinote on psic.trackedentitycommentid=psinote.trackedentitycommentid " + + "left join trackedentityinstance tei on tei.trackedentityinstanceid=pi.trackedentityinstanceid "; if ( params.getEventStatus() == null || EventStatus.isExistingEvent( params.getEventStatus() ) ) { @@ -226,19 +228,16 @@ } else { - sql += - "left join trackedentityinstance tei on tei.trackedentityinstanceid=pi.trackedentityinstanceid " + - "left join organisationunit ou on (tei.organisationunitid=ou.organisationunitid) "; + sql += "left join organisationunit ou on (tei.organisationunitid=ou.organisationunitid) "; } sql += "left join trackedentitydatavalue pdv on psi.programstageinstanceid=pdv.programstageinstanceid " + - "left join dataelement de on pdv.dataelementid=de.dataelementid " + - "left join trackedentityinstance pa on pa.trackedentityinstanceid=pi.trackedentityinstanceid "; + "left join dataelement de on pdv.dataelementid=de.dataelementid "; if ( trackedEntityInstanceId != null ) { - sql += hlp.whereAnd() + " pa.trackedentityinstanceid=" + trackedEntityInstanceId + " "; + sql += hlp.whereAnd() + " tei.trackedentityinstanceid=" + trackedEntityInstanceId + " "; } if ( params.getProgram() != null )