#pragma warning (disable: 4996) 
#pragma warning (disable: 4819) 
#pragma warning (disable: 4995) 

#include <tc/tc.h>
#include "mdbks_register.h"

#include <ict/ict_userservice.h>
#include <tccore/custom.h>
#include <epm/epm_toolkit_tc_utils.h>
#include <tccore/aom.h>
#include <tccore/aom_prop.h>
#include <tccore/item.h>
#include <bom/bom.h>
#include "ps/ps.h";
#include "ps/vrule.h"
#include "sstream"
#include <tccore/grm.h>
#include "epm/epm.h"
#include "sa/sa.h"
#include "libxl.h"
#include <map>
#include "epm/signoff.h"
#include <ctime>
#include <vector>
#include <locale>
#include <codecvt>
#include "ae/dataset.h"
#include <iostream>
#include <stdlib.h>
#include <tccore/aom.h>
#include <tc/emh.h>
#include <ict/ict_userservice.h>
#include <tc/tc.h>
#include <tccore/tctype.h>
#include <sa/tcfile.h>
#include <ss/ss_errors.h>
#include <string.h>
#include <time.h>
#include <tccore/project.h>

#include "tchar.h"
#include <ics/ics.h>
#include "ocilib.h"
#include <tc/preferences.h>


#include<winsock.h>  
#include<iostream>  
#include<string>

using namespace std;
//#pragma comment(lib, "WS2_32.lib")
#pragma comment(lib, "WSOCK32.lib")
extern "C" int POM_AM__set_application_bypass(logical bypass);


// 比较两个由 char* 表示的纯数字字符串的大小
// 返回值：
//   1  : str1 > str2
//   0  : str1 == str2
//  -1  : str1 < str2
int compareNumericStrings(const char* str1, const char* str2) {
	// 处理空指针
	if (!str1 || !str2) {
		std::cerr << "Error: Null pointer provided." << std::endl;
		return 0; // 或者抛出异常
	}

	int len1 = strlen(str1);
	int len2 = strlen(str2);

	// 跳过前导零，找到第一个非零字符的位置
	int i = 0, j = 0;
	while (i < len1 && str1[i] == '0') i++;
	while (j < len2 && str2[j] == '0') j++;

	// 计算有效数字长度
	int effectiveLen1 = len1 - i;
	int effectiveLen2 = len2 - j;

	// 首先比较有效数字的长度
	if (effectiveLen1 > effectiveLen2) return 1;
	if (effectiveLen1 < effectiveLen2) return -1;

	// 长度相同，逐位比较
	while (i < len1 && j < len2) {
		if (str1[i] > str2[j]) return 1;
		if (str1[i] < str2[j]) return -1;
		i++;
		j++;
	}

	// 所有位都相等
	return 0;
}

string getIP()
{
	WSADATA WSAData;
	char hostName[256];
	if (!WSAStartup(MAKEWORD(2, 0), &WSAData))
	{
		if (!gethostname(hostName, sizeof(hostName)))
		{
			hostent* host = gethostbyname(hostName);
			if (host != NULL)
			{
				return inet_ntoa(*(struct in_addr*)*host->h_addr_list);
			}
		}
	}
	return "Get IP failed.";
}

// 判断字符串str是否以suffix结尾
int endsWith(const char* str, const char* suffix) {
	size_t lenStr = strlen(str);
	size_t lenSuffix = strlen(suffix);

	// 如果suffix比str还要长，肯定不匹配
	if (lenSuffix > lenStr) return 0;

	// 检查str的末尾是否与suffix完全一致
	return strncmp(str + lenStr - lenSuffix, suffix, lenSuffix) == 0;
}

int JK_Send_SRM(EPM_action_message_t msg)
{
	char* log_file = NULL;

	printf("创建日志文件\n");
	//char* TO_SRM = (char*)malloc(sizeof("TO_SRM"));
	char tc_log_file_name[128] = "";
	strcpy(tc_log_file_name, "TO_SRM");
	CreateLogFile(tc_log_file_name, &log_file);


	WriteLog("*******************************************************************************\n");
	WriteLog("*           JK_Send_SRM  is starting                  *\n");
	WriteLog("*******************************************************************************\n");

	int ifail = ITK_ok, att_cnt = 0;
	tag_t task_tag = NULLTAG, rootTask_tag = NULLTAG, * attachments = NULL;

	string ip = getIP();
	WriteLog("ip=================================================%s\n", getIP().c_str());



	//获取首选项路径
	char* prePath = NULL;
	char* urlPath = NULL;
	int c_sql_value_count = 0;
	char** option_values;
	ITKCALL(PREF_ask_char_value("JK8_To_SRM_Filepath", 0, &prePath));

	ITKCALL(PREF_ask_char_values("JK8_To_SRM_Connet_DB_Info", &c_sql_value_count, &option_values));

	if (strcmp(getIP().c_str(), "10.200.2.42") == 0) {
		ITKCALL(PREF_ask_char_value("JK8_To_SRM_Filepath", 2, &urlPath));
	}
	else {
		ITKCALL(PREF_ask_char_value("JK8_To_SRM_Filepath", 1, &urlPath));
	}
	WriteLog("获取首选项完成\n");

	string errorMessage = "";
	//获取当前触发的任务
	task_tag = msg.task;
	//获取根流程节点
	ifail = EPM_ask_root_task(task_tag, &rootTask_tag);
	//获取目标引用对象
	ifail = EPM_ask_attachments(rootTask_tag, EPM_target_attachment, &att_cnt, &attachments);
	WriteLog("流程目标个数:%d\n", att_cnt);
	for (int i = 0; i < att_cnt; i++)
	{
		tag_t tagt = NULLTAG;
		tagt = attachments[i];
		char* itemId = NULL;
		char* revision = NULL;
		char* ChangeNo = NULL;
		char* MaterialDesc = NULL;
		char* EcrNo = NULL;
		char* type = NULL;
		ITKCALL(AOM_ask_value_string(tagt, "object_type", &type));
		WriteLog("类型===%s\n", type);
		if (strcmp(type, "JK8PartDraw_CADRevision") == 0) {
		
			//获取当前时间
			string newTime = "";
			time_t curtime2;
			time(&curtime2);
			tm* nowtime = localtime(&curtime2);
			// 输出tm结构的年月日
			cout << "年: " << 1900 + nowtime->tm_year << endl;
			cout << "月: " << 1 + nowtime->tm_mon << endl;
			cout << "日: " << nowtime->tm_mday << endl;
			newTime.append(std::to_string(1900 + nowtime->tm_year)).append("-").append(std::to_string(1 + nowtime->tm_mon)).append("-").append(std::to_string(nowtime->tm_mday)).append(" ").append(std::to_string(nowtime->tm_hour)).append(":").append(std::to_string(nowtime->tm_min)).append(":").append(std::to_string(nowtime->tm_sec));
			WriteLog("newTime===%s\n", newTime.c_str());
			ITKCALL(AOM_ask_value_string(tagt, "item_id", &itemId));
			WriteLog("itemId===%s\n", itemId);

			
		
			printf("0000000000000000\n");
			if (strstr(itemId, "DWG")) {
				//获取图纸属性

				// 获取图纸的文件路径
					//创建id的文件夹
				string tzFinalPath = "";
				string bgFinalPath = "";
				string tzPath = "";
				string tzUrlPath = "";
				string mdTz = "md ";
				tzPath.append(prePath).append("/").append(itemId);
				tzUrlPath.append(urlPath).append("/").append(itemId);
				printf("tzPath===%s\n", tzPath.c_str());
				//创建id的文件夹
				//if (_access(tzPath.c_str(), 0) != 0) {//判断ID的文件夹否存在
					//创建文件夹
				system(mdTz.append("\"").append(tzPath).append("\"").c_str());
				//	}
					//获取版本下的数据集
				int dataset_num = 0;
				tag_t* dataset_tags = NULL;
				char* origin_file_name = NULL;
				tag_t* ref_object = NULL;
				int n_found = 0;
				char* file_type = NULL;
				ITKCALL(AOM_ask_value_tags(tagt, "IMAN_specification", &dataset_num, &dataset_tags));
				for (int k = 0; k < dataset_num; k++) {
					string exportName = "";
					ITKCALL(AOM_ask_value_string(dataset_tags[k], "object_type", &file_type));

					if (strstr(file_type, "JK8_AutoCAD")) {
						ITKCALL(AE_ask_dataset_named_refs(dataset_tags[k], &n_found, &ref_object));
						if (n_found > 0) {
							int timeS = 0;
							int timeF = 0;
							tag_t ref_objectF = NULLTAG;
							string origin_file_nameStr;
							for (int x = 0; x < n_found; x++) {
								ITKCALL(AOM_ask_value_string(ref_object[x], "original_file_name", &origin_file_name));
								ITKCALL(AOM_ask_value_int(ref_object[x], "time_last_modified", &timeS));

								printf("current_name========%s\n", origin_file_name);
								printf("timeS========%d\n", timeS);
									if (endsWith(origin_file_name, ".dwg")) {
										printf("%s 结尾是 .dwg\n", origin_file_name);
										
										if (timeF == 0) {
											origin_file_nameStr = origin_file_name;
											ref_objectF = ref_object[x];
											timeF = timeS;
											printf("timeF========%d\n", timeF);
										}
										else {
										
											if (timeS > timeF) {
												origin_file_nameStr = origin_file_name;
												ref_objectF = ref_object[x];
												timeF = timeS;
												printf("timeF2========%d\n", timeF);
											}
										
										}

									}

							
							}




							if (ref_objectF != NULLTAG) {
								// 使用 remove() 函数删除文件
								if (remove(exportName.append(tzPath).append("/").append(origin_file_nameStr).c_str()) == 0) {
									printf("---------------D。\n");
								}
								else {
									printf("FFFFFFFFFFFFFFFF");
								}
								ITKCALL(IMF_export_file(ref_objectF, exportName.c_str()));
								printf("exportName========%s\n", exportName.c_str());
								tzFinalPath.append(tzUrlPath).append("/").append(origin_file_nameStr).append(";");
							
							}

							
						}
					}
				}
				DOFREE(origin_file_name);
				DOFREE(file_type);

				//获取版本
				ITKCALL(AOM_ask_value_string(tagt, "item_revision_id", &revision));
				std::string str(revision);
				// 找到第一个非零字符的位置
				size_t pos = str.find_first_not_of('0');

				if (pos != std::string::npos) {
					// 如果找到了非零字符，从该位置开始截取字符串
					str = str.substr(pos);
				}
				else {
					// 如果全是零，设置为空字符串
					str.clear();
				}
				//versionStr.erase(versionStr.begin());
				//变更单号
				int bgdh_num = 0;
				tag_t* bgdh_tags = NULL;
				ITKCALL(AOM_ask_value_tags(tagt, "JK8CADRelation", &bgdh_num, &bgdh_tags));
				if (bgdh_num > 0) {
					ITKCALL(AOM_ask_value_string(bgdh_tags[0], "item_id", &EcrNo));
					string bgPath = "";
					string bgUrlPath = "";
					string mdBg = "md ";
					string mdBgBg = "md ";
					bgPath.append(prePath).append("/").append(itemId);
					bgUrlPath.append(urlPath).append("/").append(itemId);
					//创建id的文件夹
					//if (_access(bgPath.c_str(), 0) != 0) {//判断ID的文件夹否存在
						//创建文件夹
					system(mdBg.append("\"").append(bgPath).append("\"").c_str());
					//}
					bgPath.append("/").append("变更通知单");
					bgUrlPath.append("/").append("变更通知单");
					system(mdBgBg.append("\"").append(bgPath).append("\"").c_str());
					//变更单文件路径
						//获取版本下的数据集
					int dataset_num = 0;
					tag_t* dataset_tags = NULL;
					char* origin_file_name = NULL;
					tag_t* ref_object = NULL;
					int n_found = 0;
					char* file_type = NULL;
					ITKCALL(AOM_ask_value_tags(bgdh_tags[0], "IMAN_specification", &dataset_num, &dataset_tags));
					for (int k = 0; k < dataset_num; k++) {
						string exportName = "";
						ITKCALL(AOM_ask_value_string(dataset_tags[k], "object_type", &file_type));
						printf("file_type===%s\n", file_type);
						if (strstr(file_type, "MSWordX") || strstr(file_type, "MS WordX")) {
							ITKCALL(AE_ask_dataset_named_refs(dataset_tags[k], &n_found, &ref_object));
							if (n_found > 0) {

								ITKCALL(AOM_ask_value_string(ref_object[0], "original_file_name", &origin_file_name));
								printf("current_name========%s\n", origin_file_name);
								// 使用 remove() 函数删除文件
								if (remove(exportName.append(bgPath).append("/").append(origin_file_name).c_str()) == 0) {
									printf("---------------D。\n");
								}
								else {
									printf("FFFFFFFFFFFFFFFF");
								}
								ITKCALL(IMF_export_file(ref_object[0], exportName.c_str()));
								printf("exportName========%s\n", exportName.c_str());
								bgFinalPath.append(bgUrlPath).append("/").append(origin_file_name).append(";");
							}
						}
					}
					DOFREE(origin_file_name);
					DOFREE(file_type);

				}

				//获取文件路径

				//获取物料
				char* wlItenId = "";
				int material_num = 0;
				tag_t* material_tags = NULL;
				ITKCALL(AOM_ask_value_tags(tagt, "representation_for", &material_num, &material_tags));
				WriteLog("representation_for下对象个数%d\n", material_num);
				for (int j = 0; j < material_num; j++) {//一个物料一个数据
					ITKCALL(AOM_ask_value_string(material_tags[j], "object_desc", &MaterialDesc));
					ITKCALL(AOM_ask_value_string(material_tags[j], "item_id", &wlItenId));

					string sql = "select * from CHINT_CHECK_TITLE_TEMPLATE where drawingno = '%s' ";

					if (ConnServer(option_values[0], option_values[1], option_values[2]))//"tc11","infodba","//172.16.50.40/tc11"    "TC12","infodba","172.16.68.13/tc1"
					{
						WriteLog("提示:中间数据表访问失败\n");
						EMH_store_error_s1(EMH_severity_user_error, EMH_USER_error_base, "中间数据表访问失败!\n"); //错误弹窗
						return ifail;
					}
					else {


						string selectSql = "select * from TC_TO_SRM  where MaterialCode = '%s' and  ChangeNo = '%s' and DesignID = '%s'";
						char selectRecord[400];
						sprintf(selectRecord, selectSql.c_str(), wlItenId, str.c_str(), itemId);
						printf("selectSql ===> %s\n", selectRecord);
						int outputColumn = 0, outputValueCount = 0;
						char*** outputValue = NULL;
						QuerySQLNoInputParam(selectRecord, &outputColumn, &outputValueCount, &outputValue);
						printf("outputValueCount===%d\n", outputValueCount);
						if (outputValueCount > 0) {
							char sql[1024] = "\0";
							sprintf(sql, "update TC_TO_SRM set MaterialDesc = '%s',FilePath = '%s',EcrNo = '%s',EcrFile = '%s',SendTime =  TO_DATE('%s', 'YYYY-MM-DD HH24:MI:SS') where MaterialCode = '%s' and  ChangeNo = '%s' and DesignID = '%s'" , MaterialDesc, tzFinalPath.c_str(), EcrNo, bgFinalPath.c_str(), newTime.c_str(), wlItenId, str.c_str(), itemId);

							WriteLog("提示:sql==%s\n", sql);
							if (ExecuteSQLNoInputParam(sql) == -1)
							{
								WriteLog("提示:数据更新 失败, %s \n", sql);
								EMH_store_error_s1(EMH_severity_user_error, EMH_USER_error_base, "数据库更新失败!\n"); //错误弹窗
								return 0;
							}
							else {
								ExecuteSQLNoInputParam("commit");
								WriteLog("id:%s更新完成!\n", itemId);
							}
						}
						else {
							char sql[1024] = "\0";
							sprintf(sql, "insert into TC_TO_SRM(MaterialCode,ChangeNo,MaterialDesc,DesignID,FilePath,EcrNo,EcrFile,SendTime) values('%s','%s','%s','%s','%s','%s','%s',TO_DATE('%s', 'YYYY-MM-DD HH24:MI:SS'))", wlItenId, str.c_str(), MaterialDesc, itemId, tzFinalPath.c_str(), EcrNo, bgFinalPath.c_str(), newTime.c_str());

							WriteLog("提示:sql==%s\n", sql);
							if (ExecuteSQLNoInputParam(sql) == -1)
							{
								WriteLog("提示:数据插入 失败, %s \n", sql);
								EMH_store_error_s1(EMH_severity_user_error, EMH_USER_error_base, "数据库插入失败!\n"); //错误弹窗
								return 0;
							}
							else {
								ExecuteSQLNoInputParam("commit");
								WriteLog("id:%s插入完成!\n",itemId);
							}
						}
						


						
					}

				}
				DOFREE(wlItenId);
			}
		
		}

		WriteLog("DOFREE start\n");
		DOFREE(itemId);
		DOFREE(revision);
		DOFREE(ChangeNo);
		DOFREE(MaterialDesc);
		DOFREE(EcrNo);
		DOFREE(type);
		WriteLog("DOFREE  end\n");

		
	}
	WriteLog("JK_Send_SRM正常退出1!\n");
	WriteLog("*******************************************************************************\n");
	WriteLog("*           JK_Send_SRM  is ending                  *\n");
	WriteLog("*******************************************************************************\n");
	
	CloseLog();
	return 0;
}