@@ -172,6 +172,7 @@ public function processProcessingResults($params)
172
172
$ modulesConfig =Zend_Registry::get ('configsModules ' );
173
173
174
174
$ modelLoad = new MIDAS_ModelLoader ();
175
+ $ itempolicyuserModel = $ modelLoad ->loadModel ('Itempolicyuser ' );
175
176
$ userModel = $ modelLoad ->loadModel ('User ' );
176
177
$ folderModel = $ modelLoad ->loadModel ('Folder ' );
177
178
$ itemModel = $ modelLoad ->loadModel ('Item ' );
@@ -180,11 +181,20 @@ public function processProcessingResults($params)
180
181
$ job = $ jobModel ->load ($ params ['job_id ' ]);
181
182
182
183
$ userDao = $ userModel ->load ($ params ['userKey ' ]);
184
+ $ creatorDao = $ userModel ->load ($ params ['creator_id ' ]);
183
185
184
- $ folder = $ folderModel ->load ($ params ['ouputFolders ' ][0 ]);
186
+ if (isset ($ params ['ouputFolders ' ][0 ]))
187
+ {
188
+ $ folder = $ folderModel ->load ($ params ['ouputFolders ' ][0 ]);
189
+ }
190
+ else
191
+ {
192
+ $ folder = $ userDao ->getPrivateFolder ();
193
+ }
185
194
186
195
$ componentLoader = new MIDAS_ComponentLoader ();
187
196
$ uploadComponent = $ componentLoader ->loadComponent ('Upload ' );
197
+ $ params ['outputKeys ' ] = array ();
188
198
189
199
foreach ($ params ['output ' ] as $ file )
190
200
{
@@ -196,6 +206,7 @@ public function processProcessingResults($params)
196
206
$ filepath = str_replace (". " .$ tmpArray [1 ].". " , ". " , $ filepath );
197
207
rename ($ oldfilepath , $ filepath );
198
208
$ item = $ uploadComponent ->createUploadedItem ($ userDao , basename ($ filepath ), $ filepath , $ folder );
209
+ $ params ['outputKeys ' ][$ tmpArray [1 ]][] = $ item ->getKey ();
199
210
$ jobModel ->addItemRelation ($ job , $ item , MIDAS_REMOTEPROCESSING_RELATION_TYPE_OUPUT );
200
211
// add parameter metadata
201
212
if (is_numeric ($ tmpArray [1 ]) && isset ($ params ['parametersList ' ]) && isset ($ params ['optionMatrix ' ]))
@@ -219,10 +230,13 @@ public function processProcessingResults($params)
219
230
}
220
231
if (isset ($ params ['log ' ]) && !empty ($ params ['log ' ]))
221
232
{
233
+ $ jobComponenet = $ componentLoader ->loadComponent ('Job ' , 'remoteprocessing ' );
234
+ $ xmlResults = $ jobComponenet ->computeLogs ($ job , $ params ['log ' ], $ params );
222
235
$ logFile = BASE_PATH .'/tmp/misc/ ' .uniqid ();
223
- file_put_contents ($ logFile , $ params ['log ' ]);
224
- $ item = $ uploadComponent ->createUploadedItem ($ userDao , 'log.txt ' , $ logFile , $ folder );
225
- $ jobModel ->addItemRelation ($ job , $ item , MIDAS_REMOTEPROCESSING_RELATION_TYPE_OUPUT );
236
+ file_put_contents ($ logFile , $ xmlResults );
237
+ $ item = $ uploadComponent ->createUploadedItem ($ userDao , 'job- ' .$ params ['job_id ' ].'_results.xml ' , $ logFile , $ folder );
238
+ $ itempolicyuserModel ->createPolicy ($ creatorDao , $ item , MIDAS_POLICY_READ );
239
+ $ jobModel ->addItemRelation ($ job , $ item , MIDAS_REMOTEPROCESSING_RELATION_TYPE_RESULTS );
226
240
unlink ($ logFile );
227
241
}
228
242
}
0 commit comments