#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 <cstdio>
using namespace libxl;
using namespace std::chrono_literals;
using namespace std;


#define debug true
#define ITK_err 919012




std::string generateJsonString2(char* MATNR, char* FLAG,char * MATEREV,char * ZXPLC) {
	// 拼接JSON字符串
	std::string jsonString = "[\n";
	jsonString += "  {\n";
	jsonString += "    \"MATNR\":\"";
	jsonString += MATNR;
	jsonString += "\",\n";
	jsonString += "    \"MATEREV\":\"";
	jsonString += MATEREV;
	jsonString += "\",\n";
	jsonString += "    \"ZXPLC\":\"";
	jsonString += ZXPLC;
	jsonString += "\",\n";
	jsonString += "    \"FLAG\":\"";
	jsonString += FLAG;
	jsonString += "\"\n"; 
	jsonString += "  }\n";
	jsonString += "]";
	// 返回JSON字符串
	return jsonString;
}
// 转义json字符串
void escapeJson1(std::string& str) {
	int len = str.length();
	int newLen = len;
	for (int i = 0; i < len; i++) {
		if (str[i] == '"' || str[i] == '\\') {
			newLen++;
		}
	}
	std::string escapedStr;
	escapedStr.reserve(newLen);
	for (int i = 0; i < len; i++) {
		if (str[i] == '"' || str[i] == '\\') {
			escapedStr.push_back('\\');
		}
		escapedStr.push_back(str[i]);
	}
	str = escapedStr;
}


/**
 *
 * @handlerName: LD_PartChange
 * @Description: 物料状态解冻\冻结同步接口，1.	用户通过流程触发将物料状态解冻\冻结状态传递给MES和SAP
 * @change 增加接口字段传递 MATEREV字段需要获取-type参数中指定版本上的item_revision_id属性值
		   ZXPLC字段获取-type参数中指定版本上的ld6_ifNewProduct,如未找到此属性，则传递“常规"
 * @changeDate 2024/1/23
 * @author hcj
 */
int LD_PartChange(EPM_action_message_t msg) {
	printf("开始执行");
	int att_cnt = 0;
	int doc_num = 0;
	tag_t rootTask_tag = NULLTAG;
	tag_t task = NULLTAG;
	tag_t* attachments = NULLTAG;
	tag_t* doc_tags = NULLTAG;
	string error;
	char* arg = NULL, * argflag = NULL, * argvalue = NULL;
	int arg_cnt = TC_number_of_arguments(msg.arguments);
	char * FLAG = NULL, * type = NULL;
	task = msg.task;
	string erro2 = "";
	string erro = "";
	int send1 = 0;
	int send2 = 0;
	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, "FLAG") == 0) {
				if (argvalue != NULL)
				{
					printf("获取的值%s:\n", argvalue);
					FLAG = argvalue;
				}
			}
			if (strcmp(argflag, "type") == 0) {
				if (argvalue != NULL)
				{
					printf("获取的值%s:\n", argvalue);
					type = argvalue;
				}
			}
		}
		//获取流程下目标关系下的对象
		printf("获取流程下目标关系下的对象");
		ITKCALL(EPM_ask_attachments(rootTask_tag, EPM_target_attachment, &doc_num, &doc_tags));
		for (int i = 0; i < doc_num; i++) {
			char* objtype = NULL;
			ITKCALL(AOM_ask_value_string(doc_tags[i], "object_type", &objtype));
			if (strstr(type, objtype) != nullptr) {
				//获取物料编码
				char* MATNR = NULL;
				char* MATEREV = NULL;
				char* ZXPLC = "常规";
				ITKCALL(AOM_ask_value_string(doc_tags[i], "item_id", &MATNR));
				ITKCALL(AOM_ask_value_string(doc_tags[i], "item_revision_id", &MATEREV));
				try {
					AOM_ask_value_string(doc_tags[i], "ld6_ifNewProduct", &ZXPLC);
				}
				catch (const std::exception& e) {
					printf("没有获取到属性值ld6_ifNewProduct\n");
				}
				//获取首选项的值
				char* url = NULL;
				PREF_ask_char_value("LD_PLM2MES_PartChange_Config", 0, &url);
				//获取要发送的json字符串
				std::string jsonString = generateJsonString2(MATNR, FLAG, MATEREV, ZXPLC);
				printf("jsonString:%s\n", jsonString.c_str());
				std::regex regex("\\s+");
				std::string result = std::regex_replace(jsonString, regex, "");
				// 转义处理后的json字符串
				escapeJson1(result);
				//调用jar包向接口发送数据
				printf("开始执行cmd方法");
				char cmd[1024] = "";
				strcpy(cmd, "java -jar D:\\Siemens\\Teamcenter13\\bin\\sapjco3.jar");
				strcat(cmd, " ");
				strcat(cmd, " ");
				strcat(cmd, url);
				strcat(cmd, " ");
				strcat(cmd, result.c_str());
				strcat(cmd, " ");
				strcat(cmd, "2");
				printf("\n%s\n", cmd);
				system(cmd);
				//读取本地文件获取执行结果
				
				//读取本地的result文件（SAP）
				string id = MATNR;
				string SAPfile = "D:\\TCTOSAP\\" + id + "result.txt";
				std::ifstream file(SAPfile);
				if (!file.is_open()) {
					std::cerr << "Failed to open file!" << std::endl;
					char* error = "SAP服务未响应";
					EMH_store_error_s1(EMH_severity_error, EMH_AE_error_base,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());	
					AOM_lock(doc_tags[i]);
					if (strcmp(resultStr.c_str(), "同步成功") == 0) {

						ITKCALL(AOM_set_value_string(doc_tags[i], "ld6_partiffrozentosap", "成功"));
					}
					else {
						//EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", resultStr.c_str());
						ITKCALL(AOM_set_value_string(doc_tags[i], "ld6_partiffrozentosap", "失败"));
						erro = erro + resultStr;
					}
					AOM_save(doc_tags[i]);
					AOM_unlock(doc_tags[i]);
					AOM_refresh(doc_tags[i], true);
				}
				//清空result文件的信息
				std::ofstream file8(SAPfile, std::ios::trunc); // 打开文件并设置为写入模式，使用 trunc 模式会清空文件内容
				if (!file8) {
					//删除result文件C:\TCTOLIMS
					remove(SAPfile.c_str());
				}
				else {
					//删除result文件C:\TCTOLIMS
					remove(SAPfile.c_str());
					file8.close(); // 关闭文件流
				}

				//读取本地的result文件（MAS）
				string MASpath = "D:\\TCTOMAS\\" + id + "result.txt";
				std::ifstream file1(MASpath);
				if (!file1.is_open()) {
					std::cerr << "Failed to open file!" << std::endl;
					char* error = "MES服务未响应";
					EMH_store_error_s1(EMH_severity_error, EMH_AE_error_base, error);
					//EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", error);
					return 1;
				}
				else {
					std::stringstream buffer1;
					buffer1 << file1.rdbuf();
					std::string resultStr = buffer1.str();
					printf("返回的值%s:\n", resultStr.c_str());
					if (strcmp(resultStr.c_str(), "保存成功") == 0) {
						ITKCALL(AOM_set_value_string(doc_tags[i], "ld6_partiffrozentomes", "成功"));
					}
					else{
						erro2 = erro2 + resultStr;
						ITKCALL(AOM_set_value_string(doc_tags[i], "ld6_partiffrozentomes", "失败"));
						send2++;
					}
					AOM_save(doc_tags[i]);
					AOM_unlock(doc_tags[i]);
					AOM_refresh(doc_tags[i], true);
					//清空删除文件
					//清空result文件的信息
					std::ofstream file2(MASpath, std::ios::trunc); // 打开文件并设置为写入模式，使用 trunc 模式会清空文件内容
					if (!file2) {
						//删除result文件C:\TCTOLIMS
						remove(MASpath.c_str());
					}
					else {
						//删除result文件C:\TCTOLIMS
						remove(MASpath.c_str());
						file2.close(); // 关闭文件流
					}
				}
			}
		}
		//去掉最后一个逗号
		if (!strcmp(erro.c_str(), "") == 0) {
			size_t lastCommaPos = erro.find_last_of(',');
			if (lastCommaPos != std::string::npos) {
				erro = erro.substr(0, lastCommaPos);

			}
		}
		if (send1 > 0 && send2 > 0) {
			string senderror = "错误信息：发送SAP" + erro + "，发送MES" + erro2;
			EMH_store_error_s1(EMH_severity_error, EMH_AE_error_base, senderror.c_str());
			//EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", senderror.c_str());
			return 1;
		}
		else if (send1 > 0 && send2 == 0) {
			string senderror = "错误信息：发送SAP" + erro;
			EMH_store_error_s1(EMH_severity_error, EMH_AE_error_base, senderror.c_str());
			//EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", senderror.c_str());
			return 1;
		}
		else if (send1 == 0 && send2 > 0) {
			string senderror = "错误信息：发送MES" + erro2;
			EMH_store_error_s1(EMH_severity_error, EMH_AE_error_base, senderror.c_str());
			//EMH_store_error_s2(EMH_severity_error, ITK_err, "提示", senderror.c_str());
			return 1;
		}
	}
	return 0;
}