流程提交和退回的handler - 张永全

 

int v9_demote_to_node(EPM_action_message_t msg) {
int rcode = ITK_ok;
tag_t task = msg.task;
tag_t job_tag = NULLTAG;
tag_t root_task = NULLTAG;
tag_t crtTarget = NULLTAG;
int targetNum = 0;
tag_t* targets = NULL;

int argNumber = 0;

int i = 0;
char status[WSO_name_size_c + 1] = { '\0' };

 

//获取流程目标
ITKCALL(EPM_ask_job(msg.task, &job_tag));
ITKCALL(EPM_ask_root_task(job_tag, &root_task));
ITKCALL(EPM_ask_attachments(root_task, EPM_target_attachment, &targetNum, &targets));

 

//ITKCALL(EPM_trigger_action(msg.task, EPM_demote_action, "自动退回"));
//rcode = EPM_trigger_action(msg.task, EPM_approve_action, "Some comment");
//char* action = "SOA EPM demote action";
//char* comment = "根据属性条件返回到指定节点";
// ==============================================
// 如果当前动作是【驳回/拒绝】
// ==============================================

if (msg.action == EPM_reject_action) {

tag_t current_task = NULLTAG;
char* current_task_type = NULL;
ITKCALL(AOM_ask_value_string(msg.task, "object_type", &current_task_type));
if (strcmp(current_task_type, "EPMPerformSignoffTask") == 0) {
ITKCALL(AOM_ask_value_tag(msg.task, "parent_task", &current_task));
}
else {
current_task = msg.task;
}
//EPM_demote_task(current_task, "DO");

if (current_task) {
logical has_previous_task = true;
while (current_task) {
char* object_name = NULL;
tag_t previous_task = NULLTAG;
ITKCALL(AOM_ask_value_string(current_task, "object_name", &object_name));
ITKCALL(AOM_ask_value_tag(current_task, "previous_task", &previous_task));//predecessors
if (strcmp(object_name, "校对") == 0 && previous_task) {
has_previous_task = false;
}
else {
setOpenByPass();
rcode = EPM_demote_task(current_task, "DO");
char* err_string = NULL;
EMH_ask_error_text(rcode, &err_string);
printf("\nERROR: %d ERROR MSG: %s.\n", rcode, err_string);
SAFE_SM_FREE(err_string);
setCloseByPass();
ITKCALL(AOM_ask_value_tag(current_task, "previous_task", &current_task));
current_task = previous_task;
}
SAFE_SM_FREE(object_name);
}
}
SAFE_SM_FREE(current_task_type);
}
else if (msg.action == EPM_start_action) {
/*放到开始事件上，如果当前节点不是要提升的目的节点，则提升当前节点,*/
char* status = NULL;
ITKCALL(AOM_ask_value_string(msg.task, "object_desc", &status));
if (strcmp(status,"")) {

}
setOpenByPass();
AOM_lock(root_task);
AOM_set_value_string(root_task, "object_desc", "Running");
AOM_save(root_task);
AOM_unlock(root_task);
setCloseByPass();
tag_t current_task = NULLTAG;
char* current_task_type = NULL;
ITKCALL(AOM_ask_value_string(msg.task, "object_type", &current_task_type));
if (strcmp(current_task_type, "EPMPerformSignoffTask") == 0) {
ITKCALL(AOM_ask_value_tag(msg.task, "parent_task", &current_task));
}
else {
current_task = msg.task;
}
char* object_name = NULL;
ITKCALL(AOM_ask_value_string(current_task, "object_name", &object_name));
if (strcmp(object_name, "Approve") != 0) {
setOpenByPass();
EPM_promote_task(current_task, "Approve");
setCloseByPass();
setOpenByPass();
AOM_lock(root_task);
AOM_set_value_string(root_task, "object_desc", "Finish");
AOM_save(root_task);
AOM_unlock(root_task);
}
SAFE_SM_FREE(object_name);
/*//EPM_demote_task(current_task, "DO");
ITKCALL(AOM_ask_value_string(current_task, "object_type", &current_task_type));
if (current_task) {
setOpenByPass();
EPM_promote_task(current_task, "Approve");
setCloseByPass();
logical has_next_task = true;
while (has_next_task && current_task) {
char* object_name = NULL;
ITKCALL(AOM_ask_value_string(current_task, "object_name", &object_name));
if (strcmp(object_name, "Approve")==0) {
has_next_task = false;
}
else {
tag_t* successors = NULL;
int n_successors = 0;
ITKCALL(AOM_ask_value_tags(current_task, "successors",&n_successors,&successors));
if (n_successors > 0) {
for (i = 0; i < n_successors; i++)
setOpenByPass();
ITKCALL(AOM_ask_value_string(successors[i], "object_name", &object_name));
ITKCALL(AOM_ask_value_string(successors[i], "object_type", &current_task_type));

EPM_promote_task(successors[i], "Approve");
setCloseByPass();
current_task = successors[i];
}
else {
has_next_task = false;
}
SAFE_SM_FREE(successors);
}
SAFE_SM_FREE(object_name);
}
}
SAFE_SM_FREE(current_task_type);*/
setCloseByPass();
}
EMH_clear_errors();

return rcode;
}

#ifdef __cplusplus
}
#endif