Skip to content

Commit

Permalink
Merge pull request #29 from carapai/master
Browse files Browse the repository at this point in the history
Fixed issues in importing importing when already data exists
  • Loading branch information
carapai authored May 5, 2020
2 parents 366e17a + 90afa26 commit 4dbaa43
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 28 deletions.
2 changes: 1 addition & 1 deletion public/manifest.webapp
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
},
"appType": "APP",
"name": "Data Import Wizard",
"version": "1.0.10",
"version": "1.0.11",
"description": "Data Importer Wizard",
"icons": {
"48": "favicon.ico"
Expand Down
44 changes: 17 additions & 27 deletions src/stores/Program.js
Original file line number Diff line number Diff line change
@@ -1,21 +1,13 @@
import {
action,
computed,
observable
} from 'mobx';
import {action, computed, observable} from 'mobx';
import _ from 'lodash';
import moment from 'moment';

import {
NotificationManager
} from 'react-notifications';
import {NotificationManager} from 'react-notifications';

import XLSX from 'xlsx';

import axios from 'axios';
import {
encodeData, groupEntities, isTracker, programUniqueAttribute, programUniqueColumn
} from "../utils/utils";
import {encodeData, groupEntities, isTracker, programUniqueAttribute, programUniqueColumn} from "../utils/utils";
import Param from "./Param";
import OrganisationUnit from "./OrganisationUnit";

Expand Down Expand Up @@ -509,24 +501,22 @@ class Program {
if (this.uniqueIds.length > 0) {
const chunked = _.chunk(this.uniqueIds, 100);
for (const ch of chunked) {
let {rows} = await api.get('trackedEntityInstances/query.json', {
// program: this.id,
let {trackedEntityInstances: data} = await api.get('trackedEntityInstances.json', {
filter: `${this.uniqueAttribute}:IN:${ch.join(';')}`,
ouMode: 'ALL'
ouMode: 'ALL',
fields: 'trackedEntityInstance'
});
if (rows.length > 0) {
const instances = rows.map(r => r[0]).join(';');
const params = {
paging: false,
ouMode: 'ALL',
trackedEntityInstance: instances,
fields: 'trackedEntityInstance,orgUnit,attributes[attribute,value],enrollments[enrollment,program,' +
'trackedEntityInstance,trackedEntityType,trackedEntity,enrollmentDate,incidentDate,orgUnit,events[program,trackedEntityInstance,event,' +
'eventDate,status,completedDate,coordinate,programStage,orgUnit,dataValues[dataElement,value]]]'
};
const {trackedEntityInstances} = await api.get('trackedEntityInstances', params);
foundEntities = [...foundEntities, ...trackedEntityInstances];
}
const instances = data.map(r => r.trackedEntityInstance).join(';');
const params = {
paging: false,
ouMode: 'ALL',
trackedEntityInstance: instances,
fields: 'trackedEntityInstance,orgUnit,attributes[attribute,value],enrollments[enrollment,program,' +
'trackedEntityInstance,trackedEntityType,trackedEntity,enrollmentDate,incidentDate,orgUnit,events[program,trackedEntityInstance,event,' +
'eventDate,status,completedDate,coordinate,programStage,orgUnit,dataValues[dataElement,value]]]'
};
const {trackedEntityInstances} = await api.get('trackedEntityInstances', params);
foundEntities = [...foundEntities, ...trackedEntityInstances];
}
return foundEntities;
}
Expand Down

0 comments on commit 4dbaa43

Please sign in to comment.