#include"kutil.h"
#include <iostream>
#include <map>
#include <vector>
#include <string>
#include "libxl.h"
#include  <io.h>
#include <direct.h>
#include <cfm/cfm.h>
#include <wchar.h>
#include <locale>
#include <codecvt>
#include <chrono>
#include <Windows.h>
#include <thread>
#include <regex>
#include <res\reservation.h>
#include "libxl.h"
#include <map>
#include <fstream>
#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#include <filesystem>
#include <sys/stat.h>
#include <iostream>
#include <random>
#include <windows.h>
#include <objbase.h>
#include <iostream>


using namespace libxl;
using namespace std::chrono_literals;
using namespace std;

#define debug true
#define ITK_err 919012



// 创建一个函数来写入数据
void writeDataToFile(const std::string& fileName, const std::string& data) {
	// 创建一个输出文件流对象
	std::ofstream outputFile(fileName);

	// 检查文件是否成功打开
	if (outputFile.is_open()) {
		// 写入数据
		outputFile << data;

		// 关闭文件
		outputFile.close();
		std::cout << "Data written to file successfully." << std::endl;
	}
	else {
		std::cerr << "Unable to open file for writing: " << fileName << std::endl;
	}
}

// 生成UUID
char* generateRandomEightDigitNumberAsCharArray() {
	GUID guid;
	if (S_OK == CoCreateGuid(&guid)) {
		// 动态分配足够的内存来存储GUID字符串（包括'\0'）
		char* guidStr = new char[37];

		sprintf(guidStr, "%08lX-%04hX-%04hX-%02hhX%02hhX-%02hhX%02hhX%02hhX%02hhX%02hhX%02hhX",
			guid.Data1, guid.Data2, guid.Data3,
			guid.Data4[0], guid.Data4[1], guid.Data4[2], guid.Data4[3],
			guid.Data4[4], guid.Data4[5], guid.Data4[6], guid.Data4[7]);

		std::cout << "Generated GUID: " << guidStr << std::endl;

		// 返回指向新创建字符串的指针
		return guidStr;
	}
	else {
		std::cerr << "Failed to create a GUID." << std::endl;
		return nullptr; // 出错时返回nullptr
	}
}






int LD_SendECRECN_ToSAPMES(EPM_action_message_t msg) {
	printf("《《《《《《《《《《《《《《《《《《《开始执行LD_SendECRECN_ToSAPMES处理程序》》》》》》》》》》》》》》》》");
	tag_t rootTask_tag = NULLTAG;
	tag_t task = NULLTAG;

	char* arg = NULL, * argflag = NULL, * argvalue = NULL;
	int arg_cnt = TC_number_of_arguments(msg.arguments);
	//流程参数
	char* type = NULL;
	char* relation = NULL;
	char* secondarytype = NULL;
	//目标对象参数
	int doc_num = 0;
	tag_t* doc_tags = NULLTAG;
	//错误信息参数
	string erro2 = "";
	string erro = "";
	//发送信息参数
	int send1 = 0;
	int send2 = 0;
	task = msg.task;
	ITKCALL(EPM_ask_root_task(task, &rootTask_tag));
	if (arg_cnt > 0)
	{
		for (int i = 0; i < arg_cnt; i++)
		{
			arg = TC_next_argument(msg.arguments);
			ITKCALL(ITK_ask_argument_named_value((const char*)arg, &argflag, &argvalue));
			if (strcmp(argflag, "primarytype") == 0) {
				if (argvalue != NULL)
				{
					printf("获取的值%s:\n", argvalue);
					type = argvalue;

				}
			}
			if (strcmp(argflag, "relation") == 0) {
				if (argvalue != NULL)
				{
					printf("获取的值%s:\n", argvalue);
					relation = argvalue;

				}
			}
			if (strcmp(argflag, "secondarytype") == 0) {
				if (argvalue != NULL)
				{
					printf("获取的值%s:\n", argvalue);
					secondarytype = argvalue;

				}
			}
		}
		if (strcmp(type, "") == 0 || strcmp(relation, "") == 0 || strcmp(secondarytype, "") == 0) {
			//返回信息报错提示
			char* error = "请检查流程参数是否有为空或未定义的情况";
			EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", error);
			return 1;
		}
		//获取MES的传递地址
		char* url;
		PREF_ask_char_value("LD_PLM2MES_ECRECN_Config", 0, &url);
		//获取文件传输地址
		char* sendfilepath, *fileURL;

		PREF_ask_char_value("LD_SendECRECN_FileURL", 0, &sendfilepath);
		PREF_ask_char_value("LD_SendECRECN_FileURL", 1, &fileURL);
		//获取流程目标对象版本
		ITKCALL(EPM_ask_attachments(rootTask_tag, EPM_target_attachment, &doc_num, &doc_tags));
		char* flowId = "";
		//获取当前时间
		time_t nowtime;
		time(&nowtime); //获取1970年1月1日0点0分0秒到现在经过的秒数
		tm p;
		localtime_s(&p, &nowtime); //将秒数转换为本地时间,年从1900算起,需要+1900,月为0-11,所以要+1
		char buffer[80];
		//sprintf_s(buffer, "%04d%d%02d%02d%02d%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min, p.tm_sec);
		sprintf_s(buffer, "%04d-%02d-%02d %02d:%02d:%2d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min,p.tm_sec);
		printf("获取的时间：%s\n", buffer);
		if (doc_num>0) {
			//开始循环获取对象传递
			std::stringstream jsonStr;
			jsonStr << "[";
			for (int i = 0; i < doc_num;i++) {
				char* objtype = NULL;
				printf("获取类型\n");
				ITKCALL(AOM_ask_value_string(doc_tags[i], "object_type", &objtype));
				printf("比较%s和%s是否相同\n",type, objtype);
				if (strcmp(type, objtype) == 0) {
					printf("获取到了匹配的类型");
					//判断-primarytype参数中值的对象类型，检查版本上的ld6_ifeffectProds属性值是否包含“无影响”，如包含，则跳过此数据传递
					char* isbaohan;
					ITKCALL(AOM_ask_value_string(doc_tags[i], "item_id", &flowId)); 
					ITKCALL(AOM_ask_value_string(doc_tags[i], "ld6_ifeffectProd", &isbaohan));
					if (strstr(isbaohan,"无影响")!=NULL) {
						printf("当前匹配类型包含无影响，跳过该对象");
						continue;	
					}
					//获取指定关系下的对象
					int das_num = 0;
					tag_t* das_tags;
					ITKCALL(AOM_ask_value_tags(doc_tags[i], relation, &das_num, &das_tags));
					
					if (das_num>0) {
						//获取类型匹配次对象类型
						char* cdxtype = NULL;
						for (int j = 0; j < das_num;j++) {
							//开始拼接字符串组成json数据
							char* MATNR = "", * ZVERSION = "", * ECNDOCU = "", * ECNSTATE = "", * ECRDOCU = "", * ECRSTATE = "", * ZSFYXSC = "", * ZDATE = "", * URLADD = " ";
							ITKCALL(AOM_ask_value_string(das_tags[j], "object_type", &cdxtype));
							if (strstr(secondarytype, cdxtype) != NULL) {
								//获取MATNR物料号
								printf("获取MATNR物料号\n");
								ITKCALL(AOM_ask_value_string(das_tags[j], "item_id", &MATNR));
								printf("获取ZVERSION零件版本\n");
								ITKCALL(AOM_ask_value_string(das_tags[j], "ld6_clientPartRev", &ZVERSION));
								//获取ECNDOCU单号
								/*
								* LD6_ECRRevision时，获取流程目标中类型是LD6_ECRRevision的item_id属性
								* LD6_ECNRevision时，获取流程目标中类型是LD6_ECNRevision的item_id属性
								*/
								if (strcmp(type, "LD6_CNRevision") == 0) {
									ITKCALL(AOM_ask_value_string(doc_tags[i], "item_id", &ECNDOCU));
									date_t time1;
									ITKCALL(AOM_ask_value_date(doc_tags[i], "date_released", &time1));
									if (time1.year == 0) {
										//日期为空
										ECNSTATE = "未关闭";
									}
									else {
										//日期不为空
										ECNSTATE = "已关闭";
									}
									int gx = 0;
									tag_t* gxtag;
									ITKCALL(AOM_ask_value_tags(doc_tags[i], "CMImplements", &gx, &gxtag));
									if (gx > 0) 
									{
										for (int b = 0; b < gx; b++) {
											char* ty;
											ITKCALL(AOM_ask_value_string(gxtag[b], "object_type", &ty));
											if (strcmp("LD6_CRRevision", ty) == 0) {
												ITKCALL(AOM_ask_value_string(gxtag[b], "item_id", &ECRDOCU));
												date_t time;
												ITKCALL(AOM_ask_value_date(gxtag[b], "date_released", &time));
												if (time.year == 0) {
													//日期为空
													ECRSTATE = "未关闭";
												}
												else {
													//日期不为空
													ECRSTATE = "已关闭";
												}
											}
											//获取ZSFYXSC
											ITKCALL(AOM_ask_value_string(doc_tags[i], "ld6_ifeffectProd", &ZSFYXSC));
											//获取时间ZDATE
											ZDATE = buffer;
											//获取URLADD  将规范关系（IMAN_specification）的数据集传递到ftp中，传递URL地址
											int gfnum = 0;
											tag_t* gftag = NULL;
											printf("开始获取规范关系文件\n");
											ITKCALL(AOM_ask_value_tags(doc_tags[i], "IMAN_specification", &gfnum, &gftag));
											//获取数据集的引用对象
											string files = "";

											for (int a = 0; a < gfnum; a++) {
												printf("获取到了规范关系文件，开始遍历\n");
												char* fileName = NULL;
												ITKCALL(AOM_ask_value_string(gftag[a], "object_name", &fileName));
												time_t nowtime;
												time(&nowtime); //获取1970年1月1日0点0分0秒到现在经过的秒数
												tm p;
												localtime_s(&p, &nowtime); //将秒数转换为本地时间,年从1900算起,需要+1900,月为0-11,所以要+1
												char fileDate[128] = "";
												char getbuffer[80];
												sprintf_s(getbuffer, "%04d%d%02d%02d%02d%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min, p.tm_sec);
												//sprintf_s(getbuffer, "%04d年%d月%02d日 %02d:%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min);
												printf("获取的时间：%s\n", getbuffer);
												char sendname[SS_MAXPATHLEN] = "";
												strcat(sendname, getbuffer);
												strcat(sendname, "-");
												char* random = generateRandomEightDigitNumberAsCharArray();
												strcat(sendname, random);
												strcat(sendname, "-");
												strcat(sendname, fileName);
												printf("合并后的字符串： % s\n", sendname);
												printf("开始复制文件到file空间\n");

												tag_t  ref_object = NULLTAG;
												printf("1");
												AE_reference_type_t reference_type;
												printf("2");
												char ref_name[WSO_name_size_c + 1] = "excel";
												ITKCALL(AE_ask_dataset_named_ref2(gftag[a], ref_name, &reference_type, &ref_object));
												printf("3");
												if (reference_type == AE_PART_OF)
												{
													printf("7");
													char temp_file[SS_MAXPATHLEN] = "";
													strcpy(temp_file, sendfilepath);
													strcat(temp_file, "\\");
													strcat(temp_file, sendname);
													printf("temp_file%s", temp_file);
													ITKCALL(IMF_export_file(ref_object, temp_file));
												}
												char temp_fileurl[SS_MAXPATHLEN] = "";
												strcpy(temp_fileurl, fileURL);
												strcat(temp_fileurl, sendname);
												files = files + temp_fileurl + ",";

											}
											if (!files.empty()) {
												files = files.substr(0, files.length() - 1);
											}
											URLADD = const_cast<char*>(files.c_str());
											//开始拼接字符串MATNR,ZVERSION,ECNDOCU,ECNSTATE,ECRDOCU,ECRSTATE,ZSFYXSC,DATE,URLADD;
											jsonStr << "{";
											jsonStr << "\"matnr\":\"" << MATNR << "\",";
											jsonStr << "\"zversion\":\"" << ZVERSION << "\",";
											jsonStr << "\"ecndocu\":\"" << ECNDOCU << "\",";
											jsonStr << "\"ecnstate\":\"" << ECNSTATE << "\",";
											jsonStr << "\"ecrdocu\":\"" << ECRDOCU << "\",";
											jsonStr << "\"ecrstate\":\"" << ECRSTATE << "\",";
											jsonStr << "\"zsfyxsc\":\"" << ZSFYXSC << "\",";
											jsonStr << "\"zdate\":\"" << ZDATE << "\",";
											jsonStr << "\"urladd\":\"" << URLADD << "\"},";
									
										}
									}
									else 
									{
										//获取ZSFYXSC
										ITKCALL(AOM_ask_value_string(doc_tags[i], "ld6_ifeffectProd", &ZSFYXSC));
										//获取时间ZDATE
										ZDATE = buffer;
										//获取URLADD  将规范关系（IMAN_specification）的数据集传递到ftp中，传递URL地址
										int gfnum = 0;
										tag_t* gftag = NULL;
										printf("开始获取规范关系文件\n");
										ITKCALL(AOM_ask_value_tags(doc_tags[i], "IMAN_specification", &gfnum, &gftag));
										//获取数据集的引用对象
										string files = "";

										for (int a = 0; a < gfnum; a++) {
											printf("获取到了规范关系文件，开始遍历\n");
											char* fileName = NULL;
											ITKCALL(AOM_ask_value_string(gftag[a], "object_name", &fileName));
											time_t nowtime;
											time(&nowtime); //获取1970年1月1日0点0分0秒到现在经过的秒数
											tm p;
											localtime_s(&p, &nowtime); //将秒数转换为本地时间,年从1900算起,需要+1900,月为0-11,所以要+1
											char fileDate[128] = "";
											char getbuffer[80];
											sprintf_s(getbuffer, "%04d%d%02d%02d%02d%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min, p.tm_sec);
											//sprintf_s(getbuffer, "%04d年%d月%02d日 %02d:%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min);
											printf("获取的时间：%s\n", getbuffer);
											char sendname[SS_MAXPATHLEN] = "";
											strcat(sendname, getbuffer);
											strcat(sendname, "-");
											char* random = generateRandomEightDigitNumberAsCharArray();
											strcat(sendname, random);
											strcat(sendname, "-");
											strcat(sendname, fileName);
											printf("合并后的字符串： % s\n", sendname);
											printf("开始复制文件到file空间\n");

											tag_t  ref_object = NULLTAG;
											printf("1");
											AE_reference_type_t reference_type;
											printf("2");
											char ref_name[WSO_name_size_c + 1] = "excel";
											ITKCALL(AE_ask_dataset_named_ref2(gftag[a], ref_name, &reference_type, &ref_object));
											printf("3");
											if (reference_type == AE_PART_OF)
											{
												printf("7");
												char temp_file[SS_MAXPATHLEN] = "";
												strcpy(temp_file, sendfilepath);
												strcat(temp_file, "\\");
												strcat(temp_file, sendname);
												printf("temp_file%s", temp_file);
												ITKCALL(IMF_export_file(ref_object, temp_file));
											}
											char temp_fileurl[SS_MAXPATHLEN] = "";
											strcpy(temp_fileurl, fileURL);
											strcat(temp_fileurl, sendname);
											files = files + temp_fileurl + ",";

										}
										if (!files.empty()) {
											files = files.substr(0, files.length() - 1);
										}
										URLADD = const_cast<char*>(files.c_str());
										//开始拼接字符串MATNR,ZVERSION,ECNDOCU,ECNSTATE,ECRDOCU,ECRSTATE,ZSFYXSC,DATE,URLADD;
										jsonStr << "{";
										jsonStr << "\"matnr\":\"" << MATNR << "\",";
										jsonStr << "\"zversion\":\"" << ZVERSION << "\",";
										jsonStr << "\"ecndocu\":\"" << ECNDOCU << "\",";
										jsonStr << "\"ecnstate\":\"" << ECNSTATE << "\",";
										jsonStr << "\"ecrdocu\":\"" << ECRDOCU << "\",";
										jsonStr << "\"ecrstate\":\"" << ECRSTATE << "\",";
										jsonStr << "\"zsfyxsc\":\"" << ZSFYXSC << "\",";
										jsonStr << "\"zdate\":\"" << ZDATE << "\",";
										jsonStr << "\"urladd\":\"" << URLADD << "\"},";
										
									}
									
								}
								else if (strcmp(type, "LD6_CRRevision") == 0) {
									int gx = 0;
									tag_t *gxtag;
									ITKCALL(AOM_ask_value_tags(doc_tags[i], "CMImplementedBy", &gx, &gxtag));
									ITKCALL(AOM_ask_value_string(doc_tags[i], "item_id", &ECRDOCU));
									date_t time1;
									ITKCALL(AOM_ask_value_date(doc_tags[i], "date_released", &time1));
									if (time1.year == 0) {
										//日期为空
										ECRSTATE = "未关闭";
									}
									else {
										//日期不为空
										ECRSTATE = "已关闭";
									}
									for (int b = 0; b < gx;b++) {
										char* ty;
										ITKCALL(AOM_ask_value_string(gxtag[b], "object_type", &ty));
										if (strcmp("LD6_CNRevision",ty) == 0) {
											ITKCALL(AOM_ask_value_string(gxtag[b], "item_id", &ECNDOCU));
											date_t time;
											ITKCALL(AOM_ask_value_date(gxtag[b], "date_released", &time));
											if (time.year == 0) {
												//日期为空
												ECNSTATE = "未关闭";
											}
											else {
												//日期不为空
												ECNSTATE = "已关闭";
											}
										}
										
										//获取ZSFYXSC
										ITKCALL(AOM_ask_value_string(doc_tags[i], "ld6_ifeffectProd", &ZSFYXSC));
										//获取时间ZDATE
										ZDATE = buffer;
										//获取URLADD  将规范关系（IMAN_specification）的数据集传递到ftp中，传递URL地址
										int gfnum = 0;
										tag_t* gftag = NULL;
										printf("开始获取规范关系文件\n");
										ITKCALL(AOM_ask_value_tags(doc_tags[i], "IMAN_specification", &gfnum, &gftag));
										//获取数据集的引用对象
										string files = "";
										for (int a = 0; a < gfnum; a++) {
											printf("获取到了规范关系文件，开始遍历\n");
											char* fileName = NULL;
											ITKCALL(AOM_ask_value_string(gftag[a], "object_name", &fileName));
											time_t nowtime;
											time(&nowtime); //获取1970年1月1日0点0分0秒到现在经过的秒数
											tm p;
											localtime_s(&p, &nowtime); //将秒数转换为本地时间,年从1900算起,需要+1900,月为0-11,所以要+1
											char fileDate[128] = "";
											char getbuffer[80];
											sprintf_s(getbuffer, "%04d%d%02d%02d%02d%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min, p.tm_sec);
											//sprintf_s(getbuffer, "%04d年%d月%02d日 %02d:%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min);
											printf("获取的时间：%s\n", getbuffer);
											char sendname[SS_MAXPATHLEN] = "";
											strcat(sendname, getbuffer);
											strcat(sendname, "-");
											char* random = generateRandomEightDigitNumberAsCharArray();
											strcat(sendname, random);
											strcat(sendname, "-");
											strcat(sendname, fileName);
											printf("合并后的字符串： % s\n", sendname);
											printf("开始复制文件到file空间\n");

											tag_t  ref_object = NULLTAG;
											printf("1");
											AE_reference_type_t reference_type;
											printf("2");
											char ref_name[WSO_name_size_c + 1] = "excel";
											ITKCALL(AE_ask_dataset_named_ref2(gftag[a], ref_name, &reference_type, &ref_object));
											printf("3");
											if (reference_type == AE_PART_OF)
											{
												printf("7");
												char temp_file[SS_MAXPATHLEN] = "";
												strcpy(temp_file, sendfilepath);
												strcat(temp_file, "\\");
												strcat(temp_file, sendname);
												printf("temp_file%s", temp_file);
												ITKCALL(IMF_export_file(ref_object, temp_file));
											}
											char temp_fileurl[SS_MAXPATHLEN] = "";
											strcpy(temp_fileurl, fileURL);
											strcat(temp_fileurl, sendname);
											files = files + temp_fileurl + ",";

										}
										if (!files.empty()) {
											files = files.substr(0, files.length() - 1);
										}
										URLADD = const_cast<char*>(files.c_str());
										//开始拼接字符串MATNR,ZVERSION,ECNDOCU,ECNSTATE,ECRDOCU,ECRSTATE,ZSFYXSC,DATE,URLADD;
										jsonStr << "{";
										jsonStr << "\"matnr\":\"" << MATNR << "\",";
										jsonStr << "\"zversion\":\"" << ZVERSION << "\",";
										jsonStr << "\"ecndocu\":\"" << ECNDOCU << "\",";
										jsonStr << "\"ecnstate\":\"" << ECNSTATE << "\",";
										jsonStr << "\"ecrdocu\":\"" << ECRDOCU << "\",";
										jsonStr << "\"ecrstate\":\"" << ECRSTATE << "\",";
										jsonStr << "\"zsfyxsc\":\"" << ZSFYXSC << "\",";
										jsonStr << "\"zdate\":\"" << ZDATE << "\",";
										jsonStr << "\"urladd\":\"" << URLADD << "\"},";
									}
									
								}

								
							}
							
						}
						
					}
					else {
						/*
						* 如-primarytype参数为LD6_CNRevision,且LD6_CNRevision下-relation参数指定的关系下数据为空，
						则获取LD6_CNRevision下CMImplements关系下的LD6_CRRevision下-relation参数指定的关系下
						-secondarytype参数指定的类型
						*/
						if (strcmp(type,"LD6_CNRevision") == 0) {
							int das_num2 = 0;
							tag_t* das_tags2;
							ITKCALL(AOM_ask_value_tags(doc_tags[i], "CMImplements", &das_num2, &das_tags2));
							if (das_num2 > 0) {
								//获取类型匹配次对象类型
								char* cdxtype = NULL;
								for (int j = 0; j < das_num2; j++) {
									//开始拼接字符串组成json数据
									char* MATNR = "", * ZVERSION = "", * ECNDOCU = "", * ECNSTATE = "", * ECRDOCU = "", * ECRSTATE = "", * ZSFYXSC = "", * ZDATE = "", * URLADD = " ";
									ITKCALL(AOM_ask_value_string(das_tags2[j], "object_type", &cdxtype));
									if (strstr(secondarytype, cdxtype) != NULL) {
										//获取MATNR物料号
										printf("获取MATNR物料号\n");
										ITKCALL(AOM_ask_value_string(das_tags2[j], "item_id", &MATNR));
										printf("获取ZVERSION零件版本\n");
										ITKCALL(AOM_ask_value_string(das_tags2[j], "ld6_clientPartRev", &ZVERSION));
										//获取ECNDOCU单号
										/*
										* LD6_ECRRevision时，获取流程目标中类型是LD6_ECRRevision的item_id属性
										* LD6_ECNRevision时，获取流程目标中类型是LD6_ECNRevision的item_id属性
										*/
										if (strcmp(type, "LD6_CNRevision") == 0) {
											ITKCALL(AOM_ask_value_string(doc_tags[i], "item_id", &ECNDOCU));
											date_t time;
											ITKCALL(AOM_ask_value_date(doc_tags[i], "date_released", &time));
											if (time.year == 0) {
												//日期为空
												ECNSTATE = "未关闭";
											}
											else {
												//日期不为空
												ECNSTATE = "已关闭";
											}
										}
										else if (strcmp(type, "LD6_CRRevision") == 0) {
											ITKCALL(AOM_ask_value_string(doc_tags[i], "item_id", &ECRDOCU));
											date_t time;
											ITKCALL(AOM_ask_value_date(doc_tags[i], "date_released", &time));
											if (time.year == 0) {
												//日期为空
												ECRSTATE = "未关闭";
											}
											else {
												//日期不为空
												ECRSTATE = "已关闭";
											}
										}
										//获取ZSFYXSC
										ITKCALL(AOM_ask_value_string(doc_tags[i], "ld6_ifeffectProd", &ZSFYXSC));
										//获取时间ZDATE
										ZDATE = buffer;
										//获取URLADD  将规范关系（IMAN_specification）的数据集传递到ftp中，传递URL地址
										int gfnum = 0;
										tag_t* gftag;
										ITKCALL(AOM_ask_value_tags(doc_tags[i], "IMAN_specification", &gfnum, &gftag));
										//获取数据集的引用对象
										string files = "";
										for (int a = 0; a < gfnum; a++) {
											char* fileName = NULL;
											ITKCALL(AOM_ask_value_string(gftag[a], "object_name", &fileName));
											time_t nowtime;
											time(&nowtime); //获取1970年1月1日0点0分0秒到现在经过的秒数
											tm p;
											localtime_s(&p, &nowtime); //将秒数转换为本地时间,年从1900算起,需要+1900,月为0-11,所以要+1
											char fileDate[128] = "";
											char getbuffer[80];
											sprintf_s(getbuffer, "%04d%02d%02d%02d%02d%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min, p.tm_sec);
											printf("获取的时间：%s\n", getbuffer);
											char sendname[SS_MAXPATHLEN] = "";
											strcat(sendname, getbuffer);
											strcat(sendname, "-");
											char* random = generateRandomEightDigitNumberAsCharArray();
											strcat(sendname, random);
											strcat(sendname, "-");
											strcat(sendname, fileName);
											printf("合并后的字符串： % s\n", sendname);
											printf("开始复制文件到file空间\n");
											tag_t  ref_object = NULLTAG;
											printf("1");
											AE_reference_type_t reference_type;
											printf("2");
											char ref_name[WSO_name_size_c + 1] = "excel";
											ITKCALL(AE_ask_dataset_named_ref2(gftag[a], ref_name, &reference_type, &ref_object));
											printf("3");
											if (reference_type == AE_PART_OF)
											{
												printf("7");
												char temp_file[SS_MAXPATHLEN] = "";
												strcpy(temp_file, sendfilepath);
												strcat(temp_file, "\\");
												strcat(temp_file, sendname);
												printf("temp_file%s", temp_file);
												ITKCALL(IMF_export_file(ref_object, temp_file));
											}
											char temp_fileurl[SS_MAXPATHLEN] = "";
											strcpy(temp_fileurl, fileURL);
											strcat(temp_fileurl, sendname);
											files = files + temp_fileurl + ",";

										}
										if (!files.empty()) {
											files = files.substr(0, files.length() - 1);
										}
										URLADD = const_cast<char*>(files.c_str());
										//开始拼接字符串MATNR,ZVERSION,ECNDOCU,ECNSTATE,ECRDOCU,ECRSTATE,ZSFYXSC,DATE,URLADD;
										jsonStr << "{";
										jsonStr << "\"matnr\":\"" << MATNR << "\",";
										jsonStr << "\"zversion\":\"" << ZVERSION << "\",";
										jsonStr << "\"ecndocu\":\"" << ECNDOCU << "\",";
										jsonStr << "\"ecnstate\":\"" << ECNSTATE << "\",";
										jsonStr << "\"ecrdocu\":\"" << ECRDOCU << "\",";
										jsonStr << "\"ecrstate\":\"" << ECRSTATE << "\",";
										jsonStr << "\"zsfyxsc\":\"" << ZSFYXSC << "\",";
										jsonStr << "\"zdate\":\"" << ZDATE << "\",";
										jsonStr << "\"urladd\":\"" << URLADD << "\"},";
										
									}
								}

							}
						}
						else {
							char* MATNR = "", * ZVERSION = "", * ECNDOCU = "", * ECNSTATE = "", * ECRDOCU = "", * ECRSTATE = "", * ZSFYXSC = "", * ZDATE = "", * URLADD = " ";
							//获取MATNR物料号
							printf("获取MATNR物料号\n");
							MATNR = " ";
							printf("获取ZVERSION零件版本\n");
							ZVERSION = " ";
							//获取ECNDOCU单号
							/*
							* LD6_ECRRevision时，获取流程目标中类型是LD6_ECRRevision的item_id属性
							* LD6_ECNRevision时，获取流程目标中类型是LD6_ECNRevision的item_id属性
							*/
							if (strcmp(type, "LD6_CNRevision") == 0) {
								ITKCALL(AOM_ask_value_string(doc_tags[i], "item_id", &ECNDOCU));
								date_t time;
								ITKCALL(AOM_ask_value_date(doc_tags[i], "date_released", &time));
								if (time.year == 0) {
									//日期为空
									ECNSTATE = "未关闭";
								}
								else {
									//日期不为空
									ECNSTATE = "已关闭";
								}
							}
							else if (strcmp(type, "LD6_CRRevision") == 0) {
								ITKCALL(AOM_ask_value_string(doc_tags[i], "item_id", &ECRDOCU));
								date_t time;
								ITKCALL(AOM_ask_value_date(doc_tags[i], "date_released", &time));
								if (time.year == 0) {
									//日期为空
									ECRSTATE = "未关闭";
								}
								else {
									//日期不为空
									ECRSTATE = "已关闭";
								}
							}
							//获取ZSFYXSC
							ITKCALL(AOM_ask_value_string(doc_tags[i], "ld6_ifeffectProd", &ZSFYXSC));
							//获取时间ZDATE
							ZDATE = buffer;
							//获取URLADD  将规范关系（IMAN_specification）的数据集传递到ftp中，传递URL地址
							int gfnum = 0;
							tag_t* gftag;
							ITKCALL(AOM_ask_value_tags(doc_tags[i], "IMAN_specification", &gfnum, &gftag));
							//获取数据集的引用对象
							string files = "";
							if (gfnum>0) 
							{
								for (int a = 0; a < gfnum; a++) {
									char* fileName = NULL;
									ITKCALL(AOM_ask_value_string(gftag[a], "object_name", &fileName));
									time_t nowtime;
									time(&nowtime); //获取1970年1月1日0点0分0秒到现在经过的秒数
									tm p;
									localtime_s(&p, &nowtime); //将秒数转换为本地时间,年从1900算起,需要+1900,月为0-11,所以要+1
									char fileDate[128] = "";
									char getbuffer[80];
									sprintf_s(getbuffer, "%04d%02d%02d%02d%02d%02d", 1900 + p.tm_year, p.tm_mon + 1, p.tm_mday, p.tm_hour, p.tm_min, p.tm_sec);
									printf("获取的时间：%s\n", getbuffer);
									char sendname[SS_MAXPATHLEN] = "";
									strcat(sendname, getbuffer);
									strcat(sendname, "-");
									char* random = generateRandomEightDigitNumberAsCharArray();
									strcat(sendname, random);
									strcat(sendname, "-");
									strcat(sendname, fileName);
									printf("合并后的字符串： % s\n", sendname);
									printf("开始复制文件到file空间\n");
									tag_t  ref_object = NULLTAG;
									printf("1");
									AE_reference_type_t reference_type;
									printf("2");
									char ref_name[WSO_name_size_c + 1] = "excel";
									ITKCALL(AE_ask_dataset_named_ref2(gftag[a], ref_name, &reference_type, &ref_object));
									printf("3");
									if (reference_type == AE_PART_OF)
									{
										printf("7");
										char temp_file[SS_MAXPATHLEN] = "";
										strcpy(temp_file, sendfilepath);
										strcat(temp_file, "\\");
										strcat(temp_file, sendname);
										printf("temp_file%s", temp_file);
										ITKCALL(IMF_export_file(ref_object, temp_file));
									}
									char temp_fileurl[SS_MAXPATHLEN] = "";
									strcpy(temp_fileurl, fileURL);
									strcat(temp_fileurl, sendname);
									files = files + temp_fileurl + ",";

								}
							}
							if (!files.empty()) {
								files = files.substr(0, files.length() - 1);
							}
							URLADD = const_cast<char*>(files.c_str());
							//开始拼接字符串MATNR,ZVERSION,ECNDOCU,ECNSTATE,ECRDOCU,ECRSTATE,ZSFYXSC,DATE,URLADD;
							jsonStr << "{";
							jsonStr << "\"matnr\":\"" << MATNR << "\",";
							jsonStr << "\"zversion\":\"" << ZVERSION << "\",";
							jsonStr << "\"ecndocu\":\"" << ECNDOCU << "\",";
							jsonStr << "\"ecnstate\":\"" << ECNSTATE << "\",";
							jsonStr << "\"ecrdocu\":\"" << ECRDOCU << "\",";
							jsonStr << "\"ecrstate\":\"" << ECRSTATE << "\",";
							jsonStr << "\"zsfyxsc\":\"" << ZSFYXSC << "\",";
							jsonStr << "\"zdate\":\"" << ZDATE << "\",";
							jsonStr << "\"urladd\":\"" << URLADD << "\"},";
							
						}
					}				
					break;
				}
			}

			//删除最后一位逗号
			// 获取当前的字符串内容
			std::string str = jsonStr.str();

			// 检查并移除结尾的逗号（如果存在）
			if (!str.empty() && str.back() == ',') {
				str.pop_back();
			}

			// 在字符串末尾添加一个中括号
			str += "]";

			printf("获取的值数组：%s\n", str.c_str());

			if (strcmp(str.c_str(),"[]") == 0) {
				//没有获取到数据 跳过检查
				return 0;
			}

			char* taguid;
			ITK__convert_tag_to_uid(rootTask_tag, &taguid);
			string taguidstring = taguid;
			string inputFile = "D:\\TCTOMAS\\" + taguidstring + "input.txt";

			//将值数组写入本地
			writeDataToFile(inputFile, str.c_str());


			//调用cmd执行jar包，将数据传递到MES和SAP中
			char cmd[4196] = "";
			strcpy(cmd, "java -jar D:\\Siemens\\Teamcenter13\\bin\\sapjco3.jar");
			printf("\n1%s\n", cmd);
			strcat(cmd, " ");
			printf("\n2%s\n", cmd);
			strcat(cmd, url);
			printf("\n3%s\n", cmd);
			strcat(cmd, " ");
			printf("\n4%s\n", cmd);
			strcat(cmd, taguid);
			printf("\n5%s\n", cmd);
			strcat(cmd, " ");
			printf("\n6%s\n", cmd);
			strcat(cmd, "ECNECR");
			printf("\n7%s\n", cmd);
			strcat(cmd, " ");
			printf("\n8%s\n", cmd);
			strcat(cmd, flowId);
			printf("\n9%s\n", cmd);
			system(cmd);

			//读取本地文件获取执行结果
			//读取本地的result文件（SAP）
			string fileid = flowId;
			string MESfile = "D:\\TCTOMAS\\" + fileid + "result.txt";
			std::ifstream file(MESfile);
			if (!file.is_open()) {
				std::cerr << "Failed to open file!" << std::endl;
				char* error = "服务未响应";
				EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", error);
				return 1;
			}
			else {
				std::stringstream buffer1;
				buffer1 << file.rdbuf();
				std::string resultStr = buffer1.str();
				printf("返回的值%s:\n", resultStr.c_str());
				if (strcmp(resultStr.c_str(), "SAP:成功,MES:成功") == 0) {
					return 0;
				}
				else {
					EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", resultStr.c_str());
					return 1;
				}
			}
			return 0;
	}
		}
		else {
			//返回信息报错提示
			char* error = "流程目标下没有对象";
			EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", error);
			return 1;
		}	
}