#include "rb_custom.h" #include "tccore\iman_msg.h" extern "C" int POM_AM__set_application_bypass(logical bypass); int len(char* p) { int i = 0; while (*p++)i++; return i; } bool isFileExists_ifstream(char* name) { ifstream f(name); return f.good(); } int char2int(const char* str) { const char* p = str; bool neg = false; int res = 0; if (*str == '-' || *str == '+') { str++; } while (*str != 0) { if (*str < '0' || *str > '9') { break; } res = res * 10 + *str - '0'; str++; } if (*p == '-') { res = -res; } return res; } void split(char* src, const char* separator, char** dest, int* num) { /* src 源字符串的首地址(buf的地址) separator 指定的分割字符 dest 接收子字符串的数组 num 分割后子字符串的个数 */ char* pNext; int count = 0; if (src == NULL || strlen(src) == 0) //如果传入的地址为空或长度为0，直接终止 return; if (separator == NULL || strlen(separator) == 0) //如未指定分割的字符串，直接终止 return; pNext = (char*)strtok(src, separator); //必须使用(char *)进行强制类型转换(虽然不写有的编译器中不会出现指针错误) while (pNext != NULL) { *dest++ = pNext; ++count; pNext = (char*)strtok(NULL, separator); //必须使用(char *)进行强制类型转换 } *num = count; } int Connor_set_bypass(void* returnValue) { POM_AM__set_application_bypass(true); return 0; } int Connor_close_bypass(void* returnValue) { POM_AM__set_application_bypass(false); return 0; } /** * bypass */ int Connor_bypass(EPM_action_message_t msg) { ECHO("==================bypass START =======================\n"); int ifail = ITK_ok, arg_cnt; char* argflag = NULL, *argvalue = NULL, *arg = NULL; int i = 0, j = 0; BOOL bypass = FALSE; arg_cnt = TC_number_of_arguments(msg.arguments); ECHO("参数个数为：%d\n", arg_cnt); POM_AM__set_application_bypass(true); if (arg_cnt > 0) { for (i = 0; i < arg_cnt; i++) { arg = TC_next_argument(msg.arguments); ifail = ITK_ask_argument_named_value((const char*)arg, &argflag, &argvalue); if (stricmp(argflag, "bypass") == 0) { if (stricmp(argvalue, "true") == 0) { bypass = TRUE; } else if (stricmp(argvalue, "false") == 0) { bypass = FALSE; } } } if (argflag != NULL) { MEM_free(argflag); argflag = NULL; } if (argvalue != NULL) { MEM_free(argvalue); argvalue = NULL; } } printf("bypass=%d /n", bypass); POM_AM__set_application_bypass(bypass); ECHO("==================bypass END =======================\n"); return ifail; } //物料废弃属性值修改 int RB_set_yxq(EPM_action_message_t msg) { printf("===================================\n"); printf("物料废弃属性值修改 开始\n"); printf("===================================\n"); int ifail = ITK_ok; printf("开超级权限\n"); POM_AM__set_application_bypass(true); int c_sql_value_count = 0, values_count = 0; char** c_sql_values, ** values; ITKCALL(PREF_ask_char_values("RB3_SQL_Connect2", &c_sql_value_count, &c_sql_values)); if (c_sql_value_count != 3) { WriteLog("首选项 RB3_SQL_Connect2 配置错误 数量%d ", c_sql_value_count); CloseLog(); return 0; } char* userName; tag_t aUserTag = NULLTAG;//当前用户对象 tag_t task_tag = NULL_TAG, root_task_tag = NULLTAG, *attachments; task_tag = msg.task; int att_cnt = 0, s = 0; EPM_ask_root_task(task_tag, &root_task_tag); EPM_ask_attachments(root_task_tag, EPM_target_attachment, &att_cnt, &attachments); if (ConnServer(c_sql_values[1], c_sql_values[2], c_sql_values[0]))//"tc11","infodba","//172.16.50.40/tc11" "TC12","infodba","172.16.68.13/tc1" { printf("提示:中间数据表访问失败\n"); return ifail; } else { printf("提示:中间数据表访问成功\n"); if (att_cnt > 0) { for (int i = 0; i < att_cnt; i++) { tag_t tagt = NULLTAG; char* type, *id; char* user_id; date_t yxq; char JF_CJSJ[16] = "\0"; tagt = attachments[i];// ITKCALL(AOM_ask_value_string(tagt, "object_type", &type)); ITKCALL(AOM_ask_value_string(tagt, "item_id", &id)); printf("获取用户\n"); s = POM_get_user(&userName, &aUserTag); POM_tag_to_uid(aUserTag, &user_id); //SA_ask_user_identifier2(aUserTag, &user_id); printf("id=%s\n", id); printf("user_id=%s\n", user_id); if (((strstr(type, "Revision") != NULL) || (strstr(type, "revision") != NULL)) && (strstr(type, "Master") == NULL) && (strstr(type, "master") == NULL)) { ITKCALL(AOM_ask_value_date(tagt, "rb3_yxq", &yxq)); printf("yxq.year=%d\n", yxq.year); if (yxq.year == 0) { date_t createDate; ITKCALL(AOM_ask_value_date(tagt, "creation_date", &createDate)); printf("createDate=%d-%d_%d\n", createDate.year, createDate.month, createDate.day); if (createDate.month + 1 <= 9) { createDate.month = createDate.month + 3; sprintf(JF_CJSJ, "%d-%d-%d", createDate.year, createDate.month + 1, createDate.day); } else { createDate.year = createDate.year + 1; createDate.month = createDate.month - 9; sprintf(JF_CJSJ, "%d-%d-%d", createDate.year, createDate.month + 1, createDate.day); } printf("JF_CJSJ=%s\n", JF_CJSJ); AOM_lock(tagt); ITKCALL(AOM_set_value_date(tagt, "rb3_yxq", createDate)); AOM_save(tagt); AOM_unlock(tagt); } else { sprintf(JF_CJSJ, "%d-%d-%d", yxq.year, yxq.month + 1, yxq.day); } printf("JF_CJSJ=%s\n", JF_CJSJ); } char sql1[1024] = "\0"; sprintf(sql1, "insert into RB_YXQ_VALUE(ITEM_ID,USER_ID,YXQ,STATU) values ('%s','%s',to_date ('%s' ,'YYYY-MM-DD' ),'1')", id, user_id, JF_CJSJ); printf("提示:sql1==%s\n", sql1); if (ExecuteSQLNoInputParam(sql1) == -1) { printf("提示:有效期插入数据库 失败, %s \n", sql1); } else { ExecuteSQLNoInputParam("commit"); } } } } DisConnServer(); printf("数据库连接断开\n"); printf("关超级权限\n"); POM_AM__set_application_bypass(false); printf("===================================\n"); printf("物料废弃属性值修改 结束\n"); printf("===================================\n"); return ifail; } //判断流程节点状态 int RB_Process_statu(EPM_rule_message_t msg) { POM_AM__set_application_bypass(true); printf("********RB_Process_statu开始********\n"); int ifail = EPM_go, att_cnt = 0, i = 0, arg_cnt = 0; tag_t task_tag = NULL_TAG, rootTask_tag = NULL_TAG, *attachments; task_tag = msg.task; if (task_tag == NULLTAG) { return -1; } ITKCALL(EPM_ask_root_task(task_tag, &rootTask_tag)); EPM_ask_attachments(rootTask_tag, EPM_target_attachment, &att_cnt, &attachments); for (int i = 0; i < att_cnt; i++) { tag_t tagt = NULLTAG; char* type, *task_type, *task_name, *child_task_name, *rev_type, *child_task_type, *statu_name; int count = 0, task_count = 0; tag_t* tagets, *task_tagets; int n_referencers = 0; int* levels; tag_t* referencers; char** relations; tagt = attachments[i];// boolean flag = true; ITKCALL(AOM_ask_value_string(tagt, "object_type", &type)); printf("type=%s\n", type); if (((strstr(type, "Revision") != NULL) || (strstr(type, "revision") != NULL)) && (strstr(type, "Master") == NULL) && (strstr(type, "master") == NULL) && (strstr(type, "BOM") == NULL) && (strstr(type, "bom") == NULL) && (strstr(type, "Bom") == NULL)) { ITKCALL(AOM_ask_value_tags(tagt, "RB3_BGSQ", &count, &tagets)); if (count > 0) { for (int k = 0; k < count; k++) { ITKCALL(AOM_ask_value_string(tagets[k], "object_type", &rev_type)); if (strcmp("RB3_GGQQRevision", rev_type) == 0) { ITKCALL(WSOM_where_referenced(tagets[k], 1, &n_referencers, &levels, &referencers, &relations)); if (n_referencers > 0) { for (int j = 0; j < n_referencers; j++) { ITKCALL(AOM_ask_value_string(referencers[j], "object_type", &task_type)); ITKCALL(AOM_ask_value_string(referencers[j], "object_name", &task_name)); printf("task_type=%s\n", task_type); printf("task_name=%s\n", task_name); if (strcmp("EPMTask", task_type) == 0 && strcmp("A02 变更申请流程", task_name) == 0) { ITKCALL(AOM_ask_value_string(referencers[j], "fnd0Status", &statu_name)); if (strcmp("已发布", statu_name) == 0) { break; } ITKCALL(AOM_ask_value_tags(referencers[j], "fnd0StartedTasks", &task_count, &task_tagets)); printf("task_count=%d\n", task_count); for (int p = 0; p < task_count; p++) { ITKCALL(AOM_ask_value_string(task_tagets[p], "object_name", &child_task_name)); printf("child_task_name=%s\n", child_task_name); if (strcmp("完成确认", child_task_name) == 0) { flag = false; break; } } if (flag) { ifail = EPM_nogo; EMH_store_error_s1(EMH_severity_information, 278701, "设计变更申请流程未走到完成确认节点，不可以发起流程");//错误弹窗 POM_AM__set_application_bypass(false); return ifail; } } } } } } } else { } } break; } POM_AM__set_application_bypass(false); printf("********RB_Process_statu结束********\n"); return ifail; } //流程提升 int RB_Promote(EPM_action_message_t msg) { POM_AM__set_application_bypass(true); printf("********RB_Promote开始********\n"); int ifail = ITK_ok, att_cnt = 0, i = 0, arg_cnt = 0; tag_t task_tag = NULL_TAG, rootTask_tag = NULL_TAG, *attachments; task_tag = msg.task; if (task_tag == NULLTAG) { return -1; } ITKCALL(EPM_ask_root_task(task_tag, &rootTask_tag)); EPM_ask_attachments(rootTask_tag, EPM_target_attachment, &att_cnt, &attachments); for (int i = 0; i < att_cnt; i++) { tag_t tagt = NULLTAG; char* type, *task_type, *task_name, *rev_type, *child_task_type, *child_task_name; int count = 0, task_count = 0; tag_t* tagets, *task_tagets; int n_referencers = 0; int* levels; tag_t* referencers; char** relations; tagt = attachments[i];// ITKCALL(AOM_ask_value_string(tagt, "object_type", &type)); printf("type=%s\n", type); if (((strstr(type, "Revision") != NULL) || (strstr(type, "revision") != NULL)) && (strstr(type, "Master") == NULL) && (strstr(type, "master") == NULL) && (strstr(type, "BOM") == NULL) && (strstr(type, "bom") == NULL) && (strstr(type, "Bom") == NULL)) { ITKCALL(AOM_ask_value_tags(tagt, "RB3_BGSQ", &count, &tagets)); for (int k = 0; k < count; k++) { ITKCALL(AOM_ask_value_string(tagets[k], "object_type", &rev_type)); if (strcmp("RB3_GGQQRevision", rev_type) == 0) { ITKCALL(WSOM_where_referenced(tagets[k], 1, &n_referencers, &levels, &referencers, &relations)); if (n_referencers > 0) { for (int j = 0; j < n_referencers; j++) { ITKCALL(AOM_ask_value_string(referencers[j], "object_type", &task_type)); ITKCALL(AOM_ask_value_string(referencers[j], "object_name", &task_name)); printf("task_type=%s\n", task_type); printf("task_name=%s\n", task_name); if (strcmp("EPMTask", task_type) == 0 && strcmp("A02 变更申请流程", task_name) == 0) { ITKCALL(AOM_ask_value_tags(referencers[j], "child_tasks", &task_count, &task_tagets)); for (int p = 0; p < task_count; p++) { ITKCALL(AOM_ask_value_string(task_tagets[p], "object_type", &child_task_type)); printf("child_task_type=%s\n", child_task_type); if (strcmp("EPMReviewTask", child_task_type) == 0) { ITKCALL(AOM_ask_value_string(task_tagets[p], "object_name", &child_task_name)); printf("child_task_name=%s\n", child_task_name); if (strcmp("完成确认", child_task_name) == 0) { ITKCALL(EPM_promote_task(task_tagets[p], "")); break; } } } } } } } } } break; } POM_AM__set_application_bypass(false); printf("********RB_Promote结束********\n"); return ITK_ok; } //未设置审核人员流程提升 int RB_Promote_predecess(EPM_action_message_t msg) { printf("===================================\n"); printf("未设置审核人员流程提升 开始 \n"); printf("===================================\n"); int ifail = ITK_ok; int perform_count = 0; int* attach_type; tag_t* perform_attaches = NULLTAG, user_tag; printf("开超级权限\n"); POM_AM__set_application_bypass(true); char* task_name; tag_t itemrevision = NULLTAG; char* rev_id, *rev_name, *proj_id; //流程节点相关 tag_t current_task = NULLTAG, type_tag = NULLTAG; current_task = msg.task; EPM_ask_name2(current_task, &task_name); ECHO("节点名称=%s\n", task_name); int count = 0; tag_t* be_tag = NULLTAG, executor; char* node_task_name; ITKCALL(AOM_ask_value_tags(current_task, "child_tasks", &count, &be_tag)); for (int j = 0; j < count; j++) { EPM_ask_name2(be_tag[j], &node_task_name); ECHO("node_task_name = %s\n", node_task_name); if (stricmp(node_task_name, "select-signoff-team") == 0) { EPM_ask_all_attachments(be_tag[j], &perform_count, &perform_attaches, &attach_type); ECHO("perform_count=%d\n", perform_count); if (perform_count == 0) { ITKCALL(EPM_promote_task(current_task, "")); } } } printf("关闭级权限\n"); POM_AM__set_application_bypass(false); printf("===================================\n"); printf("未设置审核人员流程提升 结束 \n"); printf("===================================\n"); return ifail; } //流程邮件提醒 /* * 变更内容：增加流程参数email，属性值为外部人员邮箱地址，如果为多值，逗号隔开，实现发送内部人员邮箱的同时，发送外部人员的邮箱 * 变更人：hcj * 变更时间：2024/1/31 */ int Connor_Send_Mail_To_All_Users(EPM_action_message_t msg) { bool debug = false; int ifail = ITK_ok, arg_cnt = 0, att_cnt = 0, task_count = 0, user_cnt = 0; char* arg = NULL, *argflag = NULL, *argvalue = NULL, *task_name = NULL, *task_type = NULL; char* user_id = NULL, *user_name = NULL, *job_name = NULL; tag_t task_tag = NULLTAG, rootTask_tag = NULLTAG, user_tag = NULLTAG; tag_t* attachments = NULL, *task_tags = NULL; arg_cnt = TC_number_of_arguments(msg.arguments); vector all_user_tags; vector mail_addrs; tag_t memberTag = NULLTAG; SIGNOFF_TYPE_t memberType; char* outPersonMailAddress = NULL; ITKCALL(POM_get_user(&user_name, &user_tag)); ITKCALL(SA_ask_user_identifier2(user_tag, &user_id)); DOFREE(user_id); printf("=============================================================\n"); printf("开始执行：Connor_Send_Mail_To_All_Users\n"); printf("=============================================================\n"); printf("开超级权限\n"); POM_AM__set_application_bypass(true); task_tag = msg.task; if (task_tag == NULLTAG) { goto end; } //获取外部人员邮箱号 if (arg_cnt > 0) { for (int i = 0; i < arg_cnt; i++) { arg = TC_next_argument(msg.arguments); ITKCALL(ifail = ITK_ask_argument_named_value(arg, &argflag, &argvalue)); if (strcmp(argflag, "email") == 0) { outPersonMailAddress = argvalue; } MEM_free(argflag); MEM_free(argvalue); } } char* task_uid; POM_tag_to_uid(task_tag, &task_uid); time_t t; struct tm* lt; time(&t);//获取Unix时间戳。 lt = localtime(&t);//转为时间结构。 char year[128] = "\0"; //当前年份 sprintf(year, "%d-%d-%d", lt->tm_year + 1900, lt->tm_mon + 1, lt->tm_mday); ITKCALL(ifail = EPM_ask_root_task(task_tag, &rootTask_tag)); ITKCALL(ifail = AOM_ask_value_string(rootTask_tag, "job_name", &job_name)); printf("流程名称：%s\n", job_name); ITKCALL(ifail = EPM_ask_name2(task_tag, &task_name)); ITKCALL(ifail = AOM_ask_value_string(task_tag, "task_type", &task_type)); if (ifail != ITK_ok) { DOFREE(task_name); DOFREE(task_type); } ECHO("task_type = %s\n", task_type); if (strcmp("EPMDoTask", task_type) == 0) { tag_t user_tag = NULLTAG; ITKCALL(ifail = AOM_ask_value_tag(task_tag, "fnd0Performer", &user_tag)); if (user_tag == NULLTAG) { printf("未找到执行者\n"); } char* user_name = NULL, *task_state = NULL; ITKCALL(ifail = AOM_ask_value_string(user_tag, "user_name", &user_name)); ITKCALL(ifail = AOM_ask_value_string(task_tag, "task_state", &task_state)); printf(">> DO任务信息：%s|%s\n", user_name, task_state); all_user_tags.push_back(user_tag); DOFREE(user_name); DOFREE(task_state); } else if (strcmp("EPMPerformSignoffTask", task_type) == 0 || strcmp("EPMAcknowledgeTask", task_type) == 0) { int reviewer_cnt = 0; tag_t* reviewers = NULL; int count = 0; tag_t* be_tag = NULLTAG; char* node_task_name; int* attach_type; ITKCALL(AOM_ask_value_tags(task_tag, "predecessors", &count, &be_tag)); for (int j = 0; j < count; j++) { EPM_ask_name2(be_tag[j], &node_task_name); ECHO("node_task_name = %s\n", node_task_name); if (stricmp(node_task_name, "select-signoff-team") == 0) { EPM_ask_all_attachments(be_tag[j], &reviewer_cnt, &reviewers, &attach_type); ECHO("perform_count=%d\n", reviewer_cnt); for (int k = 0; k < reviewer_cnt; k++) { tag_t reviewer = reviewers[k]; tag_t user_tag = NULLTAG; tag_t group_tag = NULLTAG; EPM_signoff_decision_t decision; char* comment = NULL, *date_str = NULL, *group_full_name = NULL, *user_name = NULL; date_t date; ITKCALL(EPM_ask_signoff_member(reviewer, &memberTag, &memberType)); ITKCALL(SA_ask_groupmember_user(memberTag, &user_tag)); if (user_tag == NULLTAG) { printf(">> %d. 未指派用户\n", k + 1); continue; } ITKCALL(ifail = AOM_ask_value_string(user_tag, "user_name", &user_name)); all_user_tags.push_back(user_tag); DOFREE(comment); DOFREE(user_name); DOFREE(group_full_name); DOFREE(date_str); } break; } } DOFREE(reviewers); } else { printf(">> 未知任务类型\n"); } DOFREE(task_name); DOFREE(task_type); user_cnt = all_user_tags.size(); printf("处理用户数据：%d\n", user_cnt); for (int i = 0; i < user_cnt; i++) { tag_t mail_user = all_user_tags[i], person_tag = NULLTAG; char* user_str = NULL, *mail_str = NULL; ITKCALL(ifail = AOM_ask_value_tag(mail_user, "person", &person_tag)); if (ifail != ITK_ok || person_tag == NULLTAG) { continue; } ITKCALL(ifail = AOM_ask_value_string(person_tag, "PA9", &mail_str)); if (ifail != ITK_ok) { continue; } ITKCALL(ifail = AOM_ask_value_string(mail_user, "user_name", &user_str)); printf(">> %d. %s -> %s\n", i + 1, user_str, mail_str); if (mail_str == NULL || strcmp("", mail_str) == 0 || std::find(mail_addrs.begin(), mail_addrs.end(), mail_str) != mail_addrs.end()) { printf(">> Skip\n"); } else { mail_addrs.push_back(mail_str); } DOFREE(user_str); DOFREE(mail_str); } //解析外部邮箱人员地址 if (outPersonMailAddress!=NULL) { vector mailaddressVector; Split(outPersonMailAddress, ";", mailaddressVector); for (int i = 0; i < mailaddressVector.size(); i++) { mail_addrs.push_back(mailaddressVector[i]); } } user_cnt = mail_addrs.size(); printf("发送邮件：%d", user_cnt); for (int i = 0; i < user_cnt; i++) { char cmd[1024] = ""; char jarfile[512] = ""; string mail_addr = mail_addrs[i]; WriteLog(">> %d. 发送邮件给[%s]", i + 1, mail_addr.c_str()); sprintf(jarfile, "%s\\bin\\EMailSender.jar", getenv("TC_ROOT")); strcpy_s(cmd, "java -jar "); strcat_s(cmd, jarfile); strcat_s(cmd, " \""); strcat_s(cmd, mail_addr.c_str()); strcat_s(cmd, "\" \"【TeamCenter】流程任务提醒\" \""); strcat_s(cmd, "收到"); strcat_s(cmd, job_name); strcat_s(cmd, "任务，请尽快处理!!\""); printf("CMD：%s", cmd); system(cmd); printf("执行完成"); } printf("关超级权限\n"); POM_AM__set_application_bypass(false); end: DOFREE(job_name); DOFREE(attachments); all_user_tags.clear(); printf("=============================================================\n"); printf("执行结束：Connor_Send_Mail_To_All_Users\n"); printf("=============================================================\n"); return ITK_ok; } /* int Connor_Set_Mail_Statu(EPM_action_message_t msg) { bool debug = false; int ifail = ITK_ok, arg_cnt = 0, att_cnt = 0, task_count = 0, user_cnt = 0; char* arg = NULL, * argflag = NULL, * argvalue = NULL, * task_name = NULL, * task_type = NULL; char* user_id = NULL, * user_name = NULL, * job_name = NULL; tag_t task_tag = NULLTAG, rootTask_tag = NULLTAG, user_tag = NULLTAG; tag_t* attachments = NULL, * task_tags = NULL; arg_cnt = TC_number_of_arguments(msg.arguments); vector all_user_tags; vector mail_addrs; ITKCALL(POM_get_user(&user_name, &user_tag)); ITKCALL(SA_ask_user_identifier2(user_tag, &user_id)); DOFREE(user_id); WriteLog("============================================================="); WriteLog("开始执行：Connor_Set_Mail_Statu"); WriteLog("============================================================="); printf("开超级权限\n"); POM_AM__set_application_bypass(true); task_tag = msg.task; if (task_tag == NULLTAG) { goto end; } char* task_uid; POM_tag_to_uid(task_tag, &task_uid); ITKCALL(ifail = EPM_ask_root_task(task_tag, &rootTask_tag)); ITKCALL(ifail = AOM_ask_value_string(rootTask_tag, "job_name", &job_name)); WriteLog("流程名称：%s", job_name); ITKCALL(ifail = EPM_ask_sub_tasks(rootTask_tag, &task_count, &task_tags)); for (int i = 0;i < task_count;i++) { tag_t sub_task = task_tags[i]; ITKCALL(ifail = EPM_ask_name2(sub_task, &task_name)); ITKCALL(ifail = AOM_ask_value_string(sub_task, "task_type", &task_type)); if (ifail != ITK_ok) { DOFREE(task_name); DOFREE(task_type); continue; } WriteLog("%d. 读取任务信息 %s -> %s", i + 1, task_name, task_type); if (strcmp("EPMDoTask", task_type) == 0) { tag_t user_tag = NULLTAG; ITKCALL(ifail = AOM_ask_value_tag(sub_task, "fnd0Performer", &user_tag)); if (user_tag == NULLTAG) { WriteLog("未找到执行者"); continue; } char* user_name = NULL, * task_state = NULL; ITKCALL(ifail = AOM_ask_value_string(user_tag, "user_name", &user_name)); ITKCALL(ifail = AOM_ask_value_string(sub_task, "task_state", &task_state)); WriteLog(">> DO任务信息：%s|%s", user_name, task_state); all_user_tags.push_back(user_tag); DOFREE(user_name); DOFREE(task_state); } else if (strcmp("EPMReviewTask", task_type) == 0 || strcmp("EPMAcknowledgeTask", task_type) == 0) { int reviewer_cnt = 0; tag_t* reviewers = NULL; ITKCALL(ifail = EPM_ask_reviewers(sub_task, &reviewer_cnt, &reviewers)); for (int j = 0;j < reviewer_cnt;j++) { tag_t reviewer = reviewers[j]; tag_t user_tag = NULLTAG; tag_t group_tag = NULLTAG; EPM_signoff_decision_t decision; char* comment = NULL, * date_str = NULL, * group_full_name = NULL, * user_name = NULL; date_t date; ITKCALL(ifail = AOM_ask_value_tag(reviewer, "user", &user_tag)); if (user_tag == NULLTAG) { WriteLog(">> %d. 未指派用户", j + 1); continue; } ITKCALL(ifail = AOM_ask_value_tag(reviewer, "group", &group_tag)); ITKCALL(ifail = AOM_ask_value_string(user_tag, "user_name", &user_name)); ITKCALL(ifail = AOM_ask_value_string(group_tag, "full_name", &group_full_name)); all_user_tags.push_back(user_tag); DOFREE(comment); DOFREE(user_name); DOFREE(group_full_name); DOFREE(date_str); } DOFREE(reviewers); } else { WriteLog(">> 未知任务类型"); } DOFREE(task_name); DOFREE(task_type); } user_cnt = all_user_tags.size(); WriteLog("处理用户数据：%d", user_cnt); for (int i = 0;i < user_cnt;i++) { tag_t mail_user = all_user_tags[i], person_tag = NULLTAG; char* user_str = NULL, * mail_str = NULL; ITKCALL(ifail = AOM_ask_value_tag(mail_user, "person", &person_tag)); if (ifail != ITK_ok || person_tag == NULLTAG) { continue; } ITKCALL(ifail = AOM_ask_value_string(person_tag, "PA9", &mail_str)); if (ifail != ITK_ok) { continue; } ITKCALL(ifail = AOM_ask_value_string(mail_user, "user_name", &user_str)); WriteLog(">> %d. %s -> %s", i + 1, user_str, mail_str); if (mail_str == NULL || strcmp("", mail_str) == 0 || std::find(mail_addrs.begin(), mail_addrs.end(), mail_str) != mail_addrs.end()) { WriteLog(">> Skip"); } else { mail_addrs.push_back(mail_str); } DOFREE(user_str); DOFREE(mail_str); } user_cnt = mail_addrs.size(); int c_sql_value_count = 0; char** c_sql_values; ITKCALL(PREF_ask_char_values("RB3_SQL_Connect2", &c_sql_value_count, &c_sql_values)); if (c_sql_value_count != 3) { WriteLog("首选项 RB3_SQL_Connect2 配置错误 数量%d ", c_sql_value_count); CloseLog(); return 0; } if (ConnServer(c_sql_values[1], c_sql_values[2], c_sql_values[0]))//"tc11","infodba","//172.16.50.40/tc11" "TC12","infodba","172.16.68.13/tc1" { printf("提示:中间数据表访问失败\n"); return ifail; } else { printf("提示:中间数据表访问成功\n"); WriteLog("发送邮件：%d", user_cnt); for (int i = 0; i < user_cnt;i++) { string mail_addr = mail_addrs[i]; char message[512] = "\0"; sprintf(message, "收到%s任务，请尽快处理!!", job_name); char sql1[1024] = "\0"; sprintf(sql1, "insert into RB_EMAIL_VALUE(TASK_UID,USER_EMAIL,EMAIL_TITLE,EMAIL_MESSAGE,STATU)values ('%s','%s','【TeamCenter】流程任务提醒','%s' ,'1')" , task_uid, mail_addr.c_str(), message); printf("提示:sql1==%s\n", sql1); if (ExecuteSQLNoInputParam(sql1) == -1) { printf("提示:有效期插入数据库 失败, %s \n", sql1); } else { ExecuteSQLNoInputParam("commit"); } } } DisConnServer(); printf("数据库连接断开\n"); printf("关超级权限\n"); POM_AM__set_application_bypass(false); end: DOFREE(job_name); DOFREE(attachments); all_user_tags.clear(); WriteLog("============================================================="); WriteLog("执行结束：Connor_Set_Mail_Statu"); WriteLog("============================================================="); return ITK_ok; } */ //java调用发布 参数1:发布的对象 参数2:发布的类型() //public void setReleaseStatus(TCComponent item, String statusName) // throws TCException { // TCUserService userservice = this.session.getUserService(); // // Object[] obj = new Object[2]; // obj[0] = item; // obj[1] = statusName; // userservice.call("connor_set_release_status", obj); // // } int connor_set_release_status(void* returnValue) { int ifail = ITK_ok; tag_t item = NULL_TAG, release_status = NULL_TAG; char* release_name = NULL; tag_t* release_objs = NULL; USERARG_get_tag_argument(&item); USERARG_get_string_argument(&release_name); int temp_count = 1; release_objs = (tag_t*)MEM_alloc(temp_count * sizeof(tag_t)); release_objs[0] = item; ITKCALL(ifail = RELSTAT_create_release_status(release_name, &release_status)); ITKCALL(ifail = RELSTAT_add_release_status(release_status, temp_count, release_objs, TRUE)); if (release_name != NULL) { MEM_free(release_name); } return ITK_ok; } //导入数据集 static int import_dataset_file(tag_t dataset, char* ref_name, char* ext, char* fullfilename, char* original_name) { int ifail = ITK_ok; tag_t new_file_tag = NULLTAG; IMF_file_t file_descriptor = NULL; AOM_refresh(dataset, FALSE); char* new_file_name = NULL; char new_ds_name[WSO_name_size_c + 1] = ""; char* filename = NULL; new_file_name = USER_new_file_name(new_ds_name, ref_name, ext, 0); filename = strrchr(fullfilename, '\\') + 1; if (filename == NULL) return ITK_ok; ECHO("IMF_import_file\n"); //POM_AM__set_application_bypass(true); IMF_import_file(fullfilename, new_file_name, SS_BINARY, &new_file_tag, &file_descriptor); ECHO("IMF_set_original_file_name\n"); IMF_set_original_file_name2(new_file_tag, original_name); IMF_close_file(file_descriptor); AOM_save(new_file_tag); AOM_unlock(new_file_tag); AOM_refresh(new_file_tag, FALSE); //添加至命名引用 //POM_AM__set_application_bypass(true); ITKCALL(AOM_lock(dataset)); ECHO("AE_remove_dataset_named_ref\n"); AE_remove_dataset_named_ref2(dataset, ref_name); AOM_save(dataset); ECHO("AE_add_dataset_named_ref\n"); //POM_AM__set_application_bypass(true); AE_add_dataset_named_ref2(dataset, ref_name, AE_PART_OF, new_file_tag); AOM_save(dataset); AOM_unlock(dataset); //ITKCALL( AOM_refresh( dataset, FALSE ) ); return ifail; } //要挂载的对象,数据集全路径,数据集引用文件名称 不用对pdf发布 int importPdf2(tag_t rev_tag, tag_t rel_tag, const char* pdfFile, char* datasetName, char* pdfName) { tag_t* rfTags, datasetTag = NULLTAG, relation; int ifail = ITK_ok, rfCount = 0; char type_class[WSO_object_type_size_c + 1], *pdfDatasetName; if (datasetTag == NULLTAG) { printf("没有找到PDF数据集%s，开始进行创建\n", datasetName); tag_t pdfTypeTag = NULLTAG, tool = NULLTAG; ITKCALL(ifail = AE_find_datasettype2("PDF", &pdfTypeTag)); ITKCALL(ifail = AE_create_dataset_with_id(pdfTypeTag, datasetName, "dwg", "", "", &datasetTag));//modify 2019 12 31 pdfname->datasetName 2020/10/15描述设置成dwg ITKCALL(ifail = AE_ask_datasettype_def_tool(pdfTypeTag, &tool)); ITKCALL(ifail = AE_set_dataset_tool(datasetTag, tool)); ITKCALL(ifail = AE_set_dataset_format2(datasetTag, "PDF_Reference")); ITKCALL(ifail = AOM_save(datasetTag)); if (datasetTag == NULLTAG) { printf("创建失败\n"); return -1; } else { printf("创建成功\n"); //POM_AM__set_application_bypass(true); //ITKCALL(ifail = ITEM_attach_object_tag(rev_tag, datasetTag, rel_tag)); ITKCALL(ifail = GRM_create_relation(rev_tag, datasetTag, rel_tag, NULLTAG, &relation)); ITKCALL(GRM_save_relation(relation)); ITKCALL(AOM_unlock(relation)); //POM_AM__set_application_bypass(false); if (ifail == ITK_ok) { printf("挂载到版本下成功\n"); } else { printf("挂载到版本下失败\n"); return -1; } } } else { printf("找到PDF数据集%s，开始进行更新数据文件\n", pdfName); } char* pdfFile2 = new char[255]; strcpy(pdfFile2, pdfFile); ITKCALL(ifail = import_dataset_file(datasetTag, "PDF_Reference", "pdf", pdfFile2, pdfName)); if (ifail != ITK_ok) { //WriteLog(dwgName, "上传数据集文件失败"); printf("上传数据集文件失败\n"); } return ifail; } int conventdwg2pdf(tag_t item_rev_tag, tag_t dataset, tag_t rel_tag, char* signoff) { int ifail = ITK_ok; tag_t spec_dataset_rev = NULLTAG, ref_object = NULLTAG; char* ref_object_name = NULL; AE_reference_type_t reference_type; char* datasetName = NULL; AOM_ask_value_string(dataset, "object_name", &datasetName); char datasetName_temp[SS_MAXPATHLEN] = "\0"; POM_AM__set_application_bypass(true); if (strstr(datasetName, ".dwg") != NULL) { char ref_pdf_name_temp[SS_MAXPATHLEN] = "\0"; strncpy(ref_pdf_name_temp, datasetName, strlen(datasetName) - 4); sprintf(datasetName_temp, "%s.pdf", ref_pdf_name_temp); } else { sprintf(datasetName_temp, "%s", datasetName); } AE_ask_dataset_latest_rev(dataset, &spec_dataset_rev); AOM_ask_value_string(spec_dataset_rev, "object_name", &ref_object_name); printf("ref_object_name=%s\n", ref_object_name); char ref_name[WSO_name_size_c + 1] = "RB3_GCAD"; AE_ask_dataset_named_ref2(spec_dataset_rev, ref_name, &reference_type, &ref_object); if (ref_object == NULLTAG) { printf("\nref_object is NULLTAG\n"); return ITK_ok; } printf("\reference_type=%d\n", reference_type); if (reference_type == AE_PART_OF) { char* pathname; IMF_ask_file_pathname2(ref_object, SS_WNT_MACHINE, &pathname); char* origin_file_name; IMF_ask_original_file_name2(ref_object, &origin_file_name); char new_ds_name[WSO_name_size_c + 1] = ""; char* new_file_name = USER_new_file_name(new_ds_name, ref_name, "dwg", 0); char* temp_dir = getenv("TEMP"); char temp_file[SS_MAXPATHLEN] = ""; char dat_file[SS_MAXPATHLEN] = ""; char txttemp[SS_MAXPATHLEN] = "\0"; strcpy(temp_file, temp_dir); strcat(temp_file, "\\"); strcat(temp_file, new_file_name); printf("\ntemp_file=%s\n", temp_file); strncpy(txttemp, temp_file, strlen(temp_file) - 4); sprintf(dat_file, "%s.txt", txttemp); FILE* fpWrite = fopen(dat_file, "w"); fprintf(fpWrite, "%s", signoff); fclose(fpWrite); IMF_export_file(ref_object, temp_file); printf("\n555555555\n"); int iCnt; char* user_lib_env, pTempStr[500]; char local_path[MAX_PATH] = ""; char cmd[256] = ""; strcpy(cmd, "start /wait cad2pdf.exe"); strcat(cmd, " "); strcat(cmd, temp_file);//dwg文件路径 strcat(cmd, " "); strcat(cmd, dat_file);//参数 printf("\n%s\n", cmd); system(cmd); char pdftemp[SS_MAXPATHLEN] = "\0"; char pdf[SS_MAXPATHLEN] = "\0"; if (strstr(temp_file, ".dwg") != NULL) { strncpy(pdftemp, temp_file, strlen(temp_file) - 4); printf("pdftemp=%s\n", pdftemp); sprintf(pdf, "%s.pdf", pdftemp); printf("pdf=%s\n", pdf); //strcpy(user_lib_env, local_path); //pdf=true; int time_2_pdf = 0; for (int time_2_pdf = 0; time_2_pdf < 20; time_2_pdf++) { Sleep(1000); ifail = 1; if ((_access(pdf, 0)) != -1) { printf("找到pdf%s\n", pdf); int size_ftp = 0; struct stat buf; if (stat(pdf, &buf) < 0) { printf("判断pdf大小失败\n"); } else { size_ftp = buf.st_size; } //pdf=true; char* pdf_name; AOM_ask_value_string(item_rev_tag, "object_name", &pdf_name); char ref_pdf_name[SS_MAXPATHLEN] = "\0"; if (strstr(pdf_name, ".dwg") != NULL) { char ref_pdf_name_temp[SS_MAXPATHLEN] = "\0"; strncpy(ref_pdf_name_temp, pdf_name, strlen(pdf_name) - 4); sprintf(ref_pdf_name, "%s.pdf", ref_pdf_name_temp); } else { sprintf(ref_pdf_name, "%s.pdf", pdf_name); } ifail = importPdf2(item_rev_tag, rel_tag, pdf, datasetName_temp, ref_pdf_name); break; } } for (int x = 0; x < 5; x++) { if ((_access(pdf, 0)) == -1) { printf("没有生成的pdf再次执行cmd\n", pdf); system(cmd); for (int time_2_pdf = 0; time_2_pdf < 20; time_2_pdf++) { Sleep(1000); ifail = 1; if ((_access(pdf, 0)) != -1) { //pdf=true; printf("找到pdf%s\n", pdf); int size_ftp = 0; struct stat buf; if (stat(pdf, &buf) < 0) { printf("判断pdf大小失败\n"); } else { size_ftp = buf.st_size; } printf("pdf大小%s--%d\n", pdf, size_ftp); char ref_pdf_name[SS_MAXPATHLEN] = "\0"; if (strstr(datasetName, ".dwg") != NULL) { char ref_pdf_name_temp[SS_MAXPATHLEN] = "\0"; strncpy(ref_pdf_name_temp, datasetName, strlen(datasetName) - 4); sprintf(ref_pdf_name, "%s.pdf", ref_pdf_name_temp); } else { sprintf(ref_pdf_name, "%s.pdf", datasetName); } ifail = importPdf2(item_rev_tag, rel_tag, pdf, datasetName_temp, ref_pdf_name); break; } } } else { break; } } } printf("dwg文件路径=========>%s\n", temp_file); printf("pdf文件路径=========>%s\n", pdf); printf("txt文件路径=========>%s\n", dat_file); //删除缓存 if (access(temp_file, 0) == 0) { unlink(temp_file); } if (access(pdf, 0) == 0) { unlink(pdf); } if (access(dat_file, 0) == 0) { unlink(dat_file); } } if (datasetName != NULL) { MEM_free(datasetName); datasetName = NULL; } if (ref_object_name != NULL) { MEM_free(ref_object_name); ref_object_name = NULL; } POM_AM__set_application_bypass(false); return ifail; } /************************************************************************************************* * *dwg转pdf **************************************************************************************************/ int connor_dwg_to_pdf(void* returnValue) { int ifail = ITK_ok; tag_t item = NULL_TAG, release_status = NULL_TAG; char* release_name = NULL; tag_t* release_objs = NULL; tag_t itemrevision = NULLTAG; USERARG_get_tag_argument(&item); USERARG_get_string_argument(&release_name); //int temp_count = 1; //release_objs = (tag_t*)MEM_alloc(temp_count * sizeof(tag_t)); //release_objs[0] = item; itemrevision = item; //获得数据集 tag_t relation_type = NULLTAG; //tag_t attach_relation_type = NULLTAG; ITKCALL(GRM_find_relation_type(TC_specification_rtype, &relation_type)); tag_t* secondary_objects = NULLTAG; int ds_count = 0; char* dataset_type = NULL, *desc_value = NULL, *file_path = NULL, *desc_path; ITKCALL(GRM_list_secondary_objects_only(itemrevision, relation_type, &ds_count, &secondary_objects)); for (int j = 0; j < ds_count; j++) { printf("进1\n"); ITKCALL(AOM_ask_value_string(secondary_objects[j], "object_type", &dataset_type)); int des_count = 0; tag_t* dess = NULL; char* name; if (strcmp(dataset_type, "RB3_GCAD") != 0) { if (dataset_type != NULL) { MEM_free(dataset_type); dataset_type = NULL; } continue; } ITKCALL(AOM_ask_value_tags(secondary_objects[j], "ref_list", &des_count, &dess)); if (des_count < 1) { printf("该数据集引用数量错误\n"); continue; } printf("开始判断类型\n"); if (strcmp(dataset_type, "RB3_GCAD") == 0) { printf("cad类型\n"); conventdwg2pdf(itemrevision, secondary_objects[j], relation_type, release_name); //signoff_acad(secondary_objects[j]); } MEM_free(dataset_type); } DOFREE(secondary_objects); if (release_name != NULL) { MEM_free(release_name); } return ITK_ok; } std::string string_To_UTF8(const std::string& str) { int nwLen = ::MultiByteToWideChar(CP_ACP, 0, str.c_str(), -1, NULL, 0); wchar_t* pwBuf = new wchar_t[nwLen + 1];//一定要加1，不然会出现尾巴 ZeroMemory(pwBuf, nwLen * 2 + 2); ::MultiByteToWideChar(CP_ACP, 0, str.c_str(), str.length(), pwBuf, nwLen); int nLen = ::WideCharToMultiByte(CP_UTF8, 0, pwBuf, -1, NULL, NULL, NULL, NULL); char* pBuf = new char[nLen + 1]; ZeroMemory(pBuf, nLen + 1); ::WideCharToMultiByte(CP_UTF8, 0, pwBuf, nwLen, pBuf, nLen, NULL, NULL); std::string retStr(pBuf); delete[]pwBuf; delete[]pBuf; pwBuf = NULL; pBuf = NULL; return retStr; } bool sleep_flag = true; size_t req_reply(void* ptr, size_t size, size_t nmemb, void* stream) { if (sleep_flag) { Sleep(1000); sleep_flag = false; } //在注释的里面可以打印请求流，cookie的信息 //cout << "----->reply" << endl; string* str = (string*)stream; //cout << *str << endl; (*str).append((char*)ptr, size * nmemb); return size * nmemb; } string getToken(string url) { CURL* curl = NULL; CURLcode res; string response; string authorization = "Authorization:Bearer "; curl = curl_easy_init(); struct curl_slist* headerlist = NULL, *headerlist2 = NULL; // 设置表头，表头内容可能不同 headerlist = curl_slist_append(headerlist, "Accept-Charset: UTF-8"); headerlist = curl_slist_append(headerlist, "Content-Type: application/json;charset=UTF-8"); curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headerlist); // 设置URL curl_easy_setopt(curl, CURLOPT_URL, url.c_str()); curl_easy_setopt(curl, CURLOPT_POSTFIELDS, ""); //不接收响应头数据0代表不接收 1代表接收 curl_easy_setopt(curl, CURLOPT_HEADER, 1); //设置数据接收和写入函数 curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, req_reply); curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response); // 设置为Post curl_easy_setopt(curl, CURLOPT_POST, 1); // 发送 res = curl_easy_perform(curl); printf("Get Token response:%s\n", response.c_str()); //裁剪token authorization.append(response.substr(response.find("authorization:") + 15, 406));//383 //printf("Authorization:%s\n", authorization); if (res != CURLE_OK) { // 获取详细错误信息 const char* szErr = curl_easy_strerror(res); fprintf(stderr, "curl_easy_perform() failed: %s\n", szErr); } // 清空 curl_easy_cleanup(curl); // 释放表头 curl_slist_free_all(headerlist); return authorization; } void do_Pust(string arg1value, string arg2value, string json_object) { string authorization = getToken(arg2value); ECHO("token:%s\n", authorization.c_str()); const char* curl_url = authorization.c_str(); CURL* curl = NULL; CURLcode res; //string response; curl = curl_easy_init(); struct curl_slist* headerlist = NULL; // 设置表头，表头内容可能不同 headerlist = curl_slist_append(headerlist, "Accept-Charset: UTF-8"); headerlist = curl_slist_append(headerlist, "Content-Type: application/json;charset=UTF-8"); headerlist = curl_slist_append(headerlist, curl_url); //headerlist = curl_slist_append(headerlist, "Authorization:Bearer eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiI2MTc3ZWVlMmU0YjBjNTI1ZjBjOGFlODAsYWRtaW4iLCJpc3MiOiJwaXByb2plY3QuY24iLCJpYXQiOjE2MzUzMjk4NDUsImV4cCI6MTYzNTkzNDY0NX0.ZVJBEVAoN9RhW186L_iKkvRrz_UKYcE8lv78oSYjhgLmBtQe1UM-rtpET3xAtKXWwpTis_ieDHc5nphHpE9JGg"); //headerlist = curl_slist_append(headerlist, "Authorization:Bearer eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiI2MTgyNmYyZmU0YjBjNTI1NjU0OTdiNDAsYWRtaW4iLCJpc3MiOiJwaXByb2plY3QuY24iLCJpYXQiOjE2MzU5NDU1NDMsImV4cCI6MTYzNjU1MDM0M30.Lv0LAP2HFxi_Vbuuracw_U6OKOwZaib7wksFO1ILRQKaHBG3L6JGMv7ppSown-1qeKuoV5PkLPA0guWvhWT8hw"); // 设置URL ECHO("PaiApi%s\n", arg1value.c_str()); curl_easy_setopt(curl, CURLOPT_CUSTOMREQUEST, "POST"); curl_easy_setopt(curl, CURLOPT_URL, arg1value.c_str()); curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1L); curl_easy_setopt(curl, CURLOPT_DEFAULT_PROTOCOL, "https"); curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headerlist); // 设置参数，比如"ParamName1=ParamName1Content&ParamName2=ParamName2Content&..." //ECHO("TOUTF8：%s\n", string_To_UTF8(json_object).c_str()); string data = string_To_UTF8(json_object); const char* curl_data = data.c_str(); curl_easy_setopt(curl, CURLOPT_POSTFIELDS, curl_data); //curl_easy_setopt(curl, CURLOPT_POSTFIELDS, string_To_UTF8(json_object).c_str()); //不接收响应头数据0代表不接收 1代表接收 //curl_easy_setopt(curl, CURLOPT_HEADER, 1); //设置数据接收和写入函数 //curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, req_reply); //curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response); // 设置为Post //curl_easy_setopt(curl, CURLOPT_POST, 1); // 发送 res = curl_easy_perform(curl); //printf("response:%s\n",response.c_str()); if (res != CURLE_OK) { // 获取详细错误信息 const char* szErr = curl_easy_strerror(res); fprintf(stderr, "curl_easy_perform() failed: %s\n", szErr); ECHO("Err:%s\n", szErr); } // 清空 curl_easy_cleanup(curl); // 释放表头 //curl_slist_free_all(headerlist); } int Connor_Send_Delievry_To_Pai(EPM_action_message_t msg) { printf("*************************************************************\n"); printf("* Connor_Send_Delievry_To_Pai is strat ! *\n"); printf("*************************************************************\n"); int ifail = ITK_ok; //参数相关 int att_cnt = 0, arg_cnt = 0; tag_t task_tag = NULLTAG, rootTask_tag = NULLTAG, *attachments = NULLTAG; //获取handler的参数的个数 TC_argument_list_t* arguments = msg.arguments; arg_cnt = TC_number_of_arguments(msg.arguments); ECHO("参数个数为：%d\n", arg_cnt); map paras; for (auto i = 0; i < arg_cnt; i++) { char* temp_key, *temp_val; ITK_ask_argument_named_value(TC_next_argument(arguments), &temp_key, &temp_val); paras[temp_key] = temp_val; } vector relation_types; split(paras["Relation"], ",", &relation_types); ECHO("relation_types num:%d\n", relation_types.size()); char* job_name = NULL;//, task_name[1024] = "", task_id[1024] = ""; //获取当前触发的任务 task_tag = msg.task; //获取根流程节点 ITKCALL(EPM_ask_root_task(task_tag, &rootTask_tag)); //获取目标引用对象 ITKCALL(EPM_ask_attachments(rootTask_tag, EPM_target_attachment, &att_cnt, &attachments)); ECHO("att_cnt:%d\n", att_cnt); /*ITKCALL(AOM_ask_value_string(rootTask_tag, "job_name", &job_name)); ECHO("job_name:%s\n", job_name); char* token = NULL, * ptr = NULL, temp[1024] = ""; token = strtok(job_name, "-"); strcpy(task_id, token); token = strtok(NULL, "-"); strcpy(task_name, token);*/ string json_object; string json_projectUID; for (int i = 0; i < att_cnt; i++) { char* item_id = NULL, *object_name = NULL, *object_type = NULL, *project_uid = NULL, *taskUid = NULL; ITKCALL(AOM_ask_value_string(attachments[i], "object_type", &object_type)); ECHO("object_type:%s\n", object_type); if (strstr(object_type, paras["Target"].c_str()) != NULL) { int master_num = 0, relation_num = 0; tag_t* master_tags = NULLTAG, *relation_tags = NULLTAG; char* deliverable_id = NULL, *deliverable_name = NULL; ITKCALL(AOM_ask_value_string(attachments[i], "object_name", &object_name)); //获取版本表单 IMAN_master_form_rev ITKCALL(AOM_ask_value_tags(attachments[i], "IMAN_master_form_rev", &master_num, &master_tags)); ITKCALL(AOM_ask_value_string(master_tags[0], "rb3_PaiProjectID", &project_uid)); ITKCALL(AOM_ask_value_string(master_tags[0], "user_data_1", &taskUid)); ECHO("taskUid:%s\n", item_id); ECHO("task_name:%s\n", object_name); ECHO("project_uid:%s\n", project_uid); json_object.assign("{"); //json_object.append("\"projectId\":\""); //61a883a7e4b0b0e10cfe9b36\","); /*json_object.append("\"projectId\":\""); json_object.append(project_uid); json_object.append("\",");*/ json_object.append("\"taskUid\":\""); json_object.append(taskUid); json_object.append("\","); json_object.append("\"delivery\":["); for (int z = 0; z < relation_types.size(); z++) { ITKCALL(AOM_ask_value_tags(attachments[i], relation_types[z].c_str(), &relation_num, &relation_tags)); for (int j = 0; j < relation_num; j++) { //获取对象类型 char * relationType = NULL; ITKCALL(AOM_ask_value_string(relation_tags[j], "object_type", &relationType)); if ((strstr(relationType, "Revision") == NULL) || (strstr(relationType, "Master") != NULL) || (strstr(relationType, "master") != NULL) || (strstr(relationType, "BOM") != NULL) || (strstr(relationType, "bom") != NULL) || (strstr(relationType, "Bom") != NULL)) { ITKCALL(POM_tag_to_uid(relation_tags[j], &deliverable_id)); } else { //根据版本获取对象 tag_t item = NULL_TAG; ITEM_ask_item_of_rev(relation_tags[j], &item); ITKCALL(POM_tag_to_uid(item, &deliverable_id)); } //ITKCALL(AOM_ask_value_string(relation_tags[j], "item_id", &deliverable_id)); ITKCALL(AOM_ask_value_string(relation_tags[j], "object_name", &deliverable_name)); json_object.append("{"); json_object.append("\"tcId\":\""); json_object.append(deliverable_id); json_object.append("\",\"tcName\":\""); json_object.append(deliverable_name); json_object.append("\"}"); if (z == relation_types.size() - 1 && j != relation_num - 1) { json_object.append(","); } } } json_object.append("]"); json_object.append("}"); ECHO("json_object:%s\n", json_object.c_str()); do_Pust(paras["SendDeliveryApi"], paras["GetTokenApi"], json_object); if (relation_tags) { MEM_free(relation_tags); relation_tags = NULL; } if (deliverable_id) { MEM_free(deliverable_id); deliverable_id = NULL; } if (deliverable_name) { MEM_free(deliverable_name); deliverable_name = NULL; } } if (object_type) { MEM_free(object_type); object_type = NULL; } if (object_name) { MEM_free(object_name); object_name = NULL; } if (project_uid) { MEM_free(project_uid); project_uid = NULL; } if (item_id) { MEM_free(item_id); item_id = NULL; } } printf("*************************************************************\n"); printf("* Connor_Send_Delievry_To_Pai is end ! *\n"); printf("*************************************************************\n"); return ITK_ok; } //std::string string_To_UTF8(const std::string& str) //{ // int nwLen = ::MultiByteToWideChar(CP_ACP, 0, str.c_str(), -1, NULL, 0); // wchar_t* pwBuf = new wchar_t[nwLen - 1];//一定要加1，不然会出现尾巴 // ZeroMemory(pwBuf, nwLen * 2 + 2); // ::MultiByteToWideChar(CP_ACP, 0, str.c_str(), str.length(), pwBuf, nwLen); // int nLen = ::WideCharToMultiByte(CP_UTF8, 0, pwBuf, -1, NULL, NULL, NULL, NULL); // char* pBuf = new char[nLen + 1]; // ZeroMemory(pBuf, nLen + 1); // ::WideCharToMultiByte(CP_UTF8, 0, pwBuf, nwLen, pBuf, nLen, NULL, NULL); // std::string retStr(pBuf); // delete[]pwBuf; // delete[]pBuf; // pwBuf = NULL; // pBuf = NULL; // return retStr; //} //std::string iso_8859_1_to_utf8(std::string& str) //{ // string strOut; // for (std::string::iterator it = str.begin(); it != str.end(); ++it) // { // uint8_t ch = *it; // if (ch < 0x80) { // strOut.push_back(ch); // } // else { // strOut.push_back(0xc0 | ch >> 6); // strOut.push_back(0x80 | (ch & 0x3f)); // } // } // return strOut; //} //bool sleep_flag = true; //size_t req_reply(void* ptr, size_t size, size_t nmemb, void* stream) //{ // if (sleep_flag) { // Sleep(1000); // sleep_flag = false; // } // // //在注释的里面可以打印请求流，cookie的信息 // //cout << "----->reply" << endl; // string* str = (string*)stream; // //cout << *str << endl; // (*str).append((char*)ptr, size * nmemb); // str = NULL; // return size * nmemb; //} //string getToken(string url) { // CURL* curl = NULL; // CURLcode res; // string response; // string authorization = "Authorization:Bearer "; // curl = curl_easy_init(); // // struct curl_slist* headerlist = NULL, * headerlist2 = NULL; // // // 设置表头，表头内容可能不同 // headerlist = curl_slist_append(headerlist, "Accept-Charset: UTF-8"); // headerlist = curl_slist_append(headerlist, "Content-Type: application/json;charset=UTF-8"); // curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headerlist); // // // 设置URL // curl_easy_setopt(curl, CURLOPT_URL, url.c_str()); // curl_easy_setopt(curl, CURLOPT_POSTFIELDS, ""); // //不接收响应头数据0代表不接收 1代表接收 // curl_easy_setopt(curl, CURLOPT_HEADER, 1); // //设置数据接收和写入函数 // curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, req_reply); // curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void*)&response); // // // 设置为Post // curl_easy_setopt(curl, CURLOPT_POST, 1); // // // 发送 // res = curl_easy_perform(curl); // // //printf("Get Token response:%s\n", response.c_str()); // //裁剪token // authorization.append(response.substr(response.find("authorization:") + 15, 235)); // // //printf("Authorization:%s\n", authorization.c_str()); // if (res != CURLE_OK) // { // // 获取详细错误信息 // const char* szErr = curl_easy_strerror(res); // fprintf(stderr, "curl_easy_perform() failed: %s\n", szErr); // } // // // 清空 // curl_easy_cleanup(curl); // // // 释放表头 // curl_slist_free_all(headerlist); // return authorization; //} // //int Connor_Send_Delievry_To_Pai(EPM_action_message_t msg) { // ECHO("*************************************************************\n"); // ECHO("* Connor_Send_Delievry_To_Pai is strat ! *\n"); // ECHO("*************************************************************\n"); // int ifail = ITK_ok; // //参数相关 // char arg1value[1024], // arg2value[1024], // * argflag = NULL, // * argvalue = NULL, // * arg = NULL; // // int att_cnt = 0, arg_cnt = 0; // tag_t task_tag = NULLTAG, rootTask_tag = NULLTAG, * attachments = NULLTAG; // //获取handler的参数的个数 // arg_cnt = TC_number_of_arguments(msg.arguments); // ECHO("参数个数为：%d\n", arg_cnt); // if (arg_cnt > 0) // { // for (int j = 0;j < arg_cnt;j++) // { // //获取下一个参数（从0开始） // arg = TC_next_argument(msg.arguments); // //获取参数的名称和值 // ifail = ITK_ask_argument_named_value((const char*)arg, &argflag, &argvalue); // if (stricmp(argflag, "SendDeliveryApi") == 0) // { // if (argvalue != NULL) // { // strcpy(arg1value, argvalue); // } // } // if (stricmp(argflag, "GetTokenApi") == 0) // { // if (argvalue != NULL) // { // strcpy(arg2value, argvalue); // } // } // } // MEM_free(argflag); // MEM_free(argvalue); // } // // string authorization = getToken(arg2value); // // ECHO("token:%s\n", authorization.c_str()); // char* job_name = NULL, task_name[1024] = "", task_id[1024] = ""; // //获取当前触发的任务 // task_tag = msg.task; // //获取根流程节点 // ITKCALL(EPM_ask_root_task(task_tag, &rootTask_tag)); // //获取目标引用对象 // ITKCALL(EPM_ask_attachments(rootTask_tag, EPM_target_attachment, &att_cnt, &attachments)); // ECHO("att_cnt:%d\n", att_cnt); // ITKCALL(AOM_ask_value_string(rootTask_tag, "job_name", &job_name)); // ECHO("job_name:%s\n", job_name); // char* token = NULL, * ptr = NULL, temp[1024] = ""; // // token = strtok(job_name, "-"); // strcpy(task_id, token); // // token = strtok(NULL, "-"); // strcpy(task_name, token); // // ECHO("task_id:%s\n", task_id); // ECHO("task_name:%s\n", task_name); // string json_object; // json_object.assign("{"); // json_object.append("\"taskId\":\""); // json_object.append(task_id); // json_object.append("\","); // json_object.append("\"delivery\":["); // for (int i = 0; i < att_cnt; i++) { // char* item_id = NULL, * object_name = NULL, * object_type = NULL; // ITKCALL(AOM_ask_value_string(attachments[i], "object_type", &object_type)); // ECHO("object_type:%s\n", object_type); // if (strstr(object_type, "Revision") != NULL) { // ITKCALL(AOM_ask_value_string(attachments[i], "object_name", &object_name)); // ITKCALL(AOM_ask_value_string(attachments[i], "item_id", &item_id)); // json_object.append("{"); // json_object.append("\"id\":\""); // json_object.append(item_id); // json_object.append("\",\"name\":\""); // json_object.append(object_name); // json_object.append("\"}"); // if (i != att_cnt - 1) { // json_object.append(","); // } // } // if (object_type) { // MEM_free(object_type); // object_type = NULL; // } // if (object_name) { // MEM_free(object_name); // object_name = NULL; // } // if (item_id) { // MEM_free(item_id); // item_id = NULL; // } // // // // } // json_object.append("]"); // json_object.append("}"); // ECHO("json_object:%s\n", json_object.c_str()); // CURL* curl = NULL; // CURLcode res; // string response; // curl = curl_easy_init(); // // struct curl_slist* headerlist = NULL; // // // 设置表头，表头内容可能不同 // headerlist = curl_slist_append(headerlist, "Accept-Charset: UTF-8"); // headerlist = curl_slist_append(headerlist, "Content-Type: application/json;charset=UTF-8"); // headerlist = curl_slist_append(headerlist, authorization.c_str()); // //headerlist = curl_slist_append(headerlist, "Authorization:Bearer eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiI2MTc3ZWVlMmU0YjBjNTI1ZjBjOGFlODAsYWRtaW4iLCJpc3MiOiJwaXByb2plY3QuY24iLCJpYXQiOjE2MzUzMjk4NDUsImV4cCI6MTYzNTkzNDY0NX0.ZVJBEVAoN9RhW186L_iKkvRrz_UKYcE8lv78oSYjhgLmBtQe1UM-rtpET3xAtKXWwpTis_ieDHc5nphHpE9JGg"); // // // // 设置URL // ECHO("PaiApi%s\n", arg1value); // curl_easy_setopt(curl, CURLOPT_CUSTOMREQUEST, "POST"); // curl_easy_setopt(curl, CURLOPT_URL, arg1value); // curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1L); // curl_easy_setopt(curl, CURLOPT_DEFAULT_PROTOCOL, "https"); // curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headerlist); // // 设置参数，比如"ParamName1=ParamName1Content&ParamName2=ParamName2Content&..." // //ECHO("TOUTF8：%s\n", string_To_UTF8(json_object).c_str()); // string data = string_To_UTF8(json_object); // const char* data1 = data.c_str(); // curl_easy_setopt(curl, CURLOPT_POSTFIELDS, data1); // //不接收响应头数据0代表不接收 1代表接收 // curl_easy_setopt(curl, CURLOPT_HEADER, 1); // //设置数据接收和写入函数 // curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, req_reply); // curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void*)&response); // // 设置为Post // //curl_easy_setopt(curl, CURLOPT_POST, 1); // // 发送 // res = curl_easy_perform(curl); // ECHO("response:%s\n",response.c_str()); // if (res != CURLE_OK) // { // // 获取详细错误信息 // const char* szErr = curl_easy_strerror(res); // fprintf(stderr, "curl_easy_perform() failed: %s\n", szErr); // ECHO("Err:%s\n", szErr); // } // // 清空 // curl_easy_cleanup(curl); // // // 释放表头 // curl_slist_free_all(headerlist); // // ECHO("*************************************************************\n"); // ECHO("* Connor_Send_Delievry_To_Pai is end ! *\n"); // ECHO("*************************************************************\n"); // return ITK_ok; //} bool isAttachmentSizeGreaterThan40M(const std::string& attachmentPath) { std::ifstream file(attachmentPath, std::ifstream::binary); if (file) { // 获取文件大小 file.seekg(0, file.end); std::streamsize size = file.tellg(); file.close(); // 将大小转换为MB double sizeInMegaBytes = size / 1024.0 / 1024.0; // 判断是否大于40MB return sizeInMegaBytes > 40.0; } return false; } string getFiles(tag_t target, tag_t relation_type, string & contents) { char* item_id = NULL; ITKCALL(AOM_ask_value_string(target, "item_id", &item_id)); string files_path = ""; char* dataset_type = NULL; tag_t* secondary_objects = NULLTAG; int ds_count = 0; ITKCALL(GRM_list_secondary_objects_only(target, relation_type, &ds_count, &secondary_objects)); char temp_file[SS_MAXPATHLEN] = ""; for (int i = 0; i < ds_count; i++) { printf("进1\n"); ITKCALL(AOM_ask_value_string(secondary_objects[i], "object_type", &dataset_type)); int des_count = 0; tag_t* dess = NULL; printf("dataset_type=%s\n", dataset_type); ITKCALL(AOM_ask_value_tags(secondary_objects[i], "ref_list", &des_count, &dess)); if (des_count < 1) { printf("该数据集引用数量错误\n"); continue; } tag_t ref_object = NULLTAG; AE_reference_type_t reference_type; char ref_name[WSO_name_size_c + 1] = ""; printf("开始判断类型\n"); printf("dataset_type: %s\n", dataset_type); if (strcmp(dataset_type, "PDF") == 0) { printf("PDF类型\n"); strcpy(ref_name, "PDF_Reference"); } else if (strcmp(dataset_type, "MSExcel") == 0 || strcmp(dataset_type, "MSExcelX") == 0) { printf("excel类型\n"); strcpy(ref_name, "excel"); } else if (strcmp(dataset_type, "MSWord") == 0 || strcmp(dataset_type, "MSWordX") == 0) { printf("word类型\n"); strcpy(ref_name, "word"); } else if (strcmp(dataset_type, "RB3_GCAD") == 0) { printf("CAD类型\n"); strcpy(ref_name, "RB3_GCAD"); } else if (strcmp(dataset_type, "Zip") == 0) { printf("ZIP类型\n"); strcpy(ref_name, "ZIPFILE"); } char* datasetName = NULL; char* pathname = NULL; char* origin_file_name = NULL; ITKCALL(AOM_ask_value_string(secondary_objects[i], "object_name", &datasetName)); ITKCALL(AE_ask_dataset_named_ref2(secondary_objects[i], ref_name, &reference_type, &ref_object)); if (ref_object == NULLTAG) { printf("\nref_object is NULLTAG\n"); return ""; } printf("reference_type=%d\n", reference_type); if (reference_type == AE_PART_OF) { ITKCALL(IMF_ask_file_pathname2(ref_object, SS_WNT_MACHINE, &pathname)); IMF_ask_original_file_name2(ref_object, &origin_file_name); printf("origin_file_name=%s\n", origin_file_name); printf("pathname=%s\n", pathname); char* temp_dir = getenv("temp"); strcpy(temp_file, temp_dir); strcat(temp_file, item_id); strcat(temp_file, "-"); strcat(temp_file, origin_file_name); printf("temp_file=%s\n", temp_file); if (isFileExists_ifstream(temp_file)) { cout << temp_file << "文件已经存在!" << endl; remove(temp_file); cout << GetLastError() << endl; } ITKCALL(IMF_export_file(ref_object, temp_file)); } if (datasetName != NULL) { MEM_free(datasetName); datasetName = NULL; } if (pathname != NULL) { MEM_free(pathname); pathname = NULL; } if (origin_file_name != NULL) { MEM_free(origin_file_name); origin_file_name = NULL; } if (strcmp(dataset_type, "Zip") == 0) { printf("压缩包类型判断文件大小\n"); if (isAttachmentSizeGreaterThan40M(temp_file)) { if (dataset_type != NULL) { MEM_free(dataset_type); dataset_type = NULL; } contents.append("-【部分附件大小超过限制,如需请到系统中下载！】"); continue; } } if (dataset_type != NULL) { MEM_free(dataset_type); dataset_type = NULL; } files_path.append(temp_file); if (i < ds_count - 1) { files_path.append("|"); } } if (secondary_objects != NULL) { MEM_free(secondary_objects); secondary_objects = NULL; } return files_path; } //计算分析委托单流程开始邮件提醒 /* * 创建时间：2024/3/14 */ int Connor_JSFX_Start_Send_Mail_To_Users(EPM_action_message_t msg) { bool debug = false; int ifail = ITK_ok, arg_cnt = 0, att_cnt = 0; char* arg = NULL, * argflag = NULL, * argvalue = NULL; tag_t task_tag = NULLTAG, root_task_tag = NULLTAG; tag_t* attachments = NULL; arg_cnt = TC_number_of_arguments(msg.arguments); char mail_address[1024] = ""; printf("=============================================================\n"); printf("开始执行：Connor_JSFX_Send_Mail_To_Users\n"); printf("=============================================================\n"); printf("开超级权限\n"); POM_AM__set_application_bypass(true); task_tag = msg.task; //获取外部人员邮箱号 if (arg_cnt > 0) { for (int i = 0; i < arg_cnt; i++) { arg = TC_next_argument(msg.arguments); ITKCALL(ifail = ITK_ask_argument_named_value(arg, &argflag, &argvalue)); if (strcmp(argflag, "email") == 0) { strcpy(mail_address, argvalue); } MEM_free(argflag); MEM_free(argvalue); } } //解析外部邮箱人员地址 EPM_ask_root_task(task_tag, &root_task_tag); EPM_ask_attachments(root_task_tag, EPM_target_attachment, &att_cnt, &attachments); //邮件标题 string title = ""; //邮件内容 string contents = ""; //输入资料文件路径 string input_file_path = ""; //轴承信息文件路径 string info_file_path = ""; for (int i = 0; i < att_cnt; i++) { tag_t target = attachments[i]; char* type = NULL; ITKCALL(AOM_ask_value_string(target, "object_type", &type)); if (strcmp("RB3_JSFXWTDRevision" , type) == 0) { char* khmc = NULL; char* xmmc = NULL; char** yyly = NULL; int yyly_num = 0; ITKCALL(AOM_ask_value_string(target, "rb3_khmc", &khmc)); ITKCALL(AOM_ask_value_string(target, "rb3_xmmc", &xmmc)); ITKCALL(AOM_UIF_ask_values(target, "rb3_yyly",&yyly_num, &yyly)); //拼接标题 title.append(khmc).append("+").append(xmmc).append("+"); for (int i = 0; i < yyly_num; i++) { title.append(yyly[i]); if (i < yyly_num - 1) { title.append("-"); } } printf("title: %s\n", title.c_str()); char** jsfxxqxm = NULL; char* xmbh = NULL; char* bz = NULL; int jsfxxqxm_num = 0; ITKCALL(AOM_UIF_ask_values(target, "rb3_jsfxxqxm",&jsfxxqxm_num, &jsfxxqxm)); ITKCALL(AOM_ask_value_string(target, "rb3_xmbh", &xmbh)); ITKCALL(AOM_ask_value_string(target, "rb3_bz", &bz)); //拼接内容 contents.append("1、计算分析需求项目："); for (int i = 0; i < jsfxxqxm_num; i++) { contents.append(jsfxxqxm[i]); if (i < jsfxxqxm_num - 1) { contents.append("-"); } } contents.append("2、项目编号：") .append(xmbh).append("3、备注：").append(bz); printf("contents: %s\n", contents.c_str()); DOFREE(khmc); DOFREE(xmmc); DOFREE(yyly); DOFREE(jsfxxqxm); DOFREE(xmbh); DOFREE(bz); //下载附件 tag_t input_relation_type = NULLTAG; ITKCALL(GRM_find_relation_type("RB3_Inputdata", &input_relation_type)); input_file_path = getFiles(target, input_relation_type,contents); tag_t info_relation_type = NULLTAG; ITKCALL(GRM_find_relation_type("RB3_Bearinginformation", &info_relation_type)); info_file_path = getFiles(target, info_relation_type, contents); } DOFREE(type); } DOFREE(attachments); if (strcmp("" , mail_address) != 0 && strcmp("", title.c_str()) != 0 && strcmp("", contents.c_str()) != 0) { char cmd[1024] = ""; char jarfile[512] = ""; WriteLog(">> 发送邮件给[%s]", mail_address); sprintf(jarfile, "%s\\bin\\EMailSender.jar", getenv("TC_ROOT")); strcpy_s(cmd, "java -jar "); strcat_s(cmd, jarfile); strcat_s(cmd, " \""); strcat_s(cmd, mail_address); strcat_s(cmd, "\" \""); strcat_s(cmd, title.c_str()); strcat_s(cmd, "\" \""); strcat_s(cmd, contents.c_str()); if (strcmp("", info_file_path.c_str()) != 0) { strcat_s(cmd, "\" \""); strcat_s(cmd, info_file_path.c_str()); if (strcmp("", input_file_path.c_str()) != 0) { strcat_s(cmd, "|"); strcat_s(cmd, input_file_path.c_str()); } } else { if (strcmp("", input_file_path.c_str()) != 0) { strcat_s(cmd, "\" \""); strcat_s(cmd, input_file_path.c_str()); } } strcat_s(cmd, "\""); printf("CMD：%s", cmd); system(cmd); printf("执行完成\n"); } printf("关超级权限\n"); POM_AM__set_application_bypass(false); printf("=============================================================\n"); printf("执行结束：Connor_JSFX_Send_Mail_To_Users\n"); printf("=============================================================\n"); return ITK_ok; } //计算分析委托单流程完成邮件提醒 /* * 创建时间：2024/3/14 */ int Connor_JSFX_Complete_Send_Mail_To_Users(EPM_action_message_t msg) { bool debug = false; int ifail = ITK_ok, arg_cnt = 0, att_cnt = 0; char* arg = NULL, * argflag = NULL, * argvalue = NULL; tag_t task_tag = NULLTAG, root_task_tag = NULLTAG; tag_t* attachments = NULL; arg_cnt = TC_number_of_arguments(msg.arguments); char mail_address[1024] = ""; printf("=============================================================\n"); printf("开始执行：Connor_JSFX_Complete_Send_Mail_To_Users\n"); printf("=============================================================\n"); printf("开超级权限\n"); POM_AM__set_application_bypass(true); task_tag = msg.task; //获取外部人员邮箱号 if (arg_cnt > 0) { for (int i = 0; i < arg_cnt; i++) { arg = TC_next_argument(msg.arguments); ITKCALL(ifail = ITK_ask_argument_named_value(arg, &argflag, &argvalue)); if (strcmp(argflag, "email") == 0) { strcpy(mail_address, argvalue); } MEM_free(argflag); MEM_free(argvalue); } } EPM_ask_root_task(task_tag, &root_task_tag); EPM_ask_attachments(root_task_tag, EPM_target_attachment, &att_cnt, &attachments); //邮件标题 string title = ""; //计算报告文件路径 string report_file_path = ""; for (int i = 0; i < att_cnt; i++) { tag_t target = attachments[i]; char* type = NULL; ITKCALL(AOM_ask_value_string(target, "object_type", &type)); if (strcmp("RB3_JSFXWTDRevision", type) == 0) { //拼接标题 /* char* khmc = NULL; char* xmmc = NULL; char** yyly = NULL; int yyly_num = 0; ITKCALL(AOM_ask_value_string(target, "rb3_khmc", &khmc)); ITKCALL(AOM_ask_value_string(target, "rb3_xmmc", &xmmc)); ITKCALL(AOM_UIF_ask_values(target, "rb3_yyly", &yyly_num, &yyly)); title.append(khmc).append("+").append(xmmc).append("+"); for (int i = 0; i < yyly_num; i++) { title.append(yyly[i]); if (i < yyly_num - 1) { title.append("-"); } } printf("title: %s", title.c_str()); DOFREE(khmc); DOFREE(xmmc); DOFREE(yyly); */ string contents = ""; //下载附件 tag_t report_relation_type = NULLTAG; ITKCALL(GRM_find_relation_type("RB3_Calculationreport", &report_relation_type)); report_file_path = getFiles(target, report_relation_type, contents); tag_t* secondary_objects = NULLTAG; int ds_count = 0; ITKCALL(GRM_list_secondary_objects_only(target, report_relation_type, &ds_count, &secondary_objects)); if (ds_count > 0) { char* dataset_name = NULL; ITKCALL(AOM_ask_value_string(secondary_objects[0], "object_name", &dataset_name)); if (dataset_name != NULL) { title.append(dataset_name); printf("title22: %s", title.c_str()); MEM_free(dataset_name); dataset_name = NULL; } } } DOFREE(type); } DOFREE(attachments); if (strcmp("", mail_address) != 0 && strcmp("", title.c_str()) != 0) { char cmd[1024] = ""; char jarfile[512] = ""; WriteLog(">> 发送邮件给[%s]", mail_address); sprintf(jarfile, "%s\\bin\\EMailSender.jar", getenv("TC_ROOT")); strcpy_s(cmd, "java -jar "); strcat_s(cmd, jarfile); strcat_s(cmd, " \""); strcat_s(cmd, mail_address); strcat_s(cmd, "\" \""); strcat_s(cmd, title.c_str()); strcat_s(cmd, "\" \""); strcat_s(cmd, "【计算分析委托已完成！】"); if (strcmp("", report_file_path.c_str()) != 0) { strcat_s(cmd, "\" \""); strcat_s(cmd, report_file_path.c_str()); } strcat_s(cmd, "\""); printf("CMD：%s", cmd); system(cmd); printf("执行完成"); } printf("关超级权限\n"); POM_AM__set_application_bypass(false); printf("=============================================================\n"); printf("执行结束：Connor_JSFX_Complete_Send_Mail_To_Users\n"); printf("=============================================================\n"); return ITK_ok; }