#include "updateMaterial.h"


void printfMaterial(MaterialBean bean)
{
	stringstream ss;
	ss.str("");
	ss<<"[MaterialBean pmpcCode="<<bean.pmpcCode;
	ss<<",goodsCode="<<bean.goodsCode;
	ss<<",goodsName="<<bean.goodsName;
	ss<<",unitCode="<<bean.unitCode;
	ss<<",spec="<<bean.spec;
	ss<<",bpNo="<<bean.bpNo;
	ss<<",state="<<bean.state;
	ss<<",code="<<bean.code;
	ss<<",teRe="<<bean.teRe;
	ss<<",companyCode="<<bean.companyCode;
	ss<<",userID="<<bean.userID<<" ]";
	LINFO<<ss.str().c_str();
}












char* stringToCharP(std::string str){	
	// 初始化 result 
	char* result = new char[str.length()+1];	
	// 赋值 result
	strcpy_s(result,str.length()+1,str.c_str());	
	return result;
}


string GBKToUTF8(const std::string& strGBK)
{
	string strOutUTF8 = "";
	WCHAR * str1;
	int n = MultiByteToWideChar(CP_ACP, 0, strGBK.c_str(), -1, NULL, 0);
	str1 = new WCHAR[n];
	MultiByteToWideChar(CP_ACP, 0, strGBK.c_str(), -1, str1, n);
	n = WideCharToMultiByte(CP_UTF8, 0, str1, -1, NULL, 0, NULL, NULL);
	char * str2 = new char[n];
	WideCharToMultiByte(CP_UTF8, 0, str1, -1, str2, n, NULL, NULL);
	strOutUTF8 = str2;
	delete[]str1;
	str1 = NULL;
	delete[]str2;
	str2 = NULL;
	return strOutUTF8;
}
string proProcessCreate(tag_t rev,string &process_name)
{
	int ifail = 0,att_type = EPM_target_attachment;
	//rev_tag,
	tag_t  process_template, process = NULLTAG, *t;
	//printf("流程名称:%s\r\n",process_name.c_str());
	//printf("GBK转化流程名称:%s\r\n",GBKToUTF8(process_name).c_str());
	SAFECALL(EPM_find_process_template(GBKToUTF8(process_name).c_str(), &process_template));
	SAFECALL(ifail = EPM_create_process(GBKToUTF8(process_name).c_str(), "", process_template, 1, &rev,
		&att_type, &process));
	//SAFECALL(EPM_find_process_template(process_name.c_str(), &process_template));
	///SAFECALL(ifail = EPM_create_process(process_name.c_str(), "", process_template, 1, &rev_tag,
		
	tag_t user;
	SAFECALL(SA_find_user2("dcproxy", &user));	
	if (ifail != 0) {
		const char **err;
		int n_ifails;
		const int *e, *e2;
		stringstream err_ss;
		EMH_ask_errors(&n_ifails, &e, &e2, &err);
		int n_end = n_ifails > 3 ? n_ifails - 3 : 0;
		for (auto i = n_ifails - 1; i >= n_end; i--) {
			err_ss << err[i];
		}
		return err_ss.str();
	}
}
//物料更新	更新物料状态
void updatePart(tag_t rev,MaterialBean bean,bool flag)
{
	//LINFO<<"更新";
	//printfMaterial(bean);
	tag_t item;
	ITEM_ask_item_of_rev(rev,&item);
	char * item_id,*item_id2;
	AOM_ask_value_string(rev,"item_id",&item_id);
	AOM_ask_value_string(item,"item_id",&item_id2);
	//LINFO<<"版本item_id:"<<item_id<<";对象item_id:"<<item_id2;
	SAFECALL(AOM_lock(item));
	SAFECALL(AOM_set_value_string(item,"object_name",bean.goodsName.c_str()));
	SAFECALL(AOM_set_value_string(item,"zt2_unit",bean.unitCode.c_str()));
	if(flag)
	{
		LINFO<<"更改ID";
		SAFECALL(ITEM_set_id(item,bean.goodsCode.c_str()));
	}
	SAFECALL(AOM_save(item));
	//SAFECALL(AOM_refresh(item,TRUE));
	SAFECALL(AOM_unlock(item));
	
	SAFECALL(AOM_lock(rev));
	SAFECALL(AOM_set_value_string(rev,"object_name",bean.goodsName.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_MaterialNo",bean.goodsCode.c_str()));
	SAFECALL(AOM_set_value_string(rev,"object_desc",bean.spec.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_TechRequirements",bean.teRe.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_State",bean.state.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_ClassificationCode",bean.pmpcCode.c_str()));
	SAFECALL(AOM_save(rev));	
	SAFECALL(AOM_unlock(rev));	
}

//物料更新	不更新状态
void updatePart2(tag_t rev,MaterialBean bean,bool flag)
{
	//LINFO<<"更新";
	//printfMaterial(bean);
	tag_t item;
	ITEM_ask_item_of_rev(rev,&item);
	char * item_id,*item_id2;
	AOM_ask_value_string(rev,"item_id",&item_id);
	AOM_ask_value_string(item,"item_id",&item_id2);
	//LINFO<<"版本item_id:"<<item_id<<";对象item_id:"<<item_id2;
	SAFECALL(AOM_lock(item));
	SAFECALL(AOM_set_value_string(item,"object_name",bean.goodsName.c_str()));
	SAFECALL(AOM_set_value_string(item,"zt2_unit",bean.unitCode.c_str()));
	if(flag)
	{
		LINFO<<"更改ID";
		SAFECALL(ITEM_set_id(item,bean.goodsCode.c_str()));
	}
	SAFECALL(AOM_save(item));
	//SAFECALL(AOM_refresh(item,TRUE));
	SAFECALL(AOM_unlock(item));
	
	SAFECALL(AOM_lock(rev));
	SAFECALL(AOM_set_value_string(rev,"object_name",bean.goodsName.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_MaterialNo",bean.goodsCode.c_str()));
	SAFECALL(AOM_set_value_string(rev,"object_desc",bean.spec.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_TechRequirements",bean.teRe.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_State",bean.state.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_ClassificationCode",bean.pmpcCode.c_str()));
	SAFECALL(AOM_save(rev));	
	SAFECALL(AOM_unlock(rev));	
}

//物料创建
tag_t createPart(MaterialBean bean)
{
	tag_t item,rev;
	BusinessObject* item_i=nullptr;
	CreateInput* itemCreateInput =static_cast<CreateInput*>(BusinessObjectRegistry::instance().createInputObject(
									"Part", OPERATIONINPUT_CREATE));
	SAFECALL(itemCreateInput->setString("object_name", bean.goodsName, false));
	SAFECALL(itemCreateInput->setString("item_id",bean.goodsCode,false));
	
	item_i =BusinessObjectRegistry::instance().createBusinessObject(itemCreateInput);
	tag_t uom;
	UOM_find_by_name("ZT2_zhongliang", &uom);
	if (uom) {
		item_i->setTag("uom_tag", uom, false);
	}
	SAFECALL(AOM_save_with_extensions(item_i->getTag()));
	item = item_i->getTag();
	SAFECALL(ITEM_ask_latest_rev(item,&rev));
	ITEM_ask_item_of_rev(rev,&item);
	SAFECALL(AOM_lock(item));
	SAFECALL(AOM_set_value_string(item,"zt2_unit",bean.unitCode.c_str()));	
	SAFECALL(AOM_save(item));
	SAFECALL(AOM_unlock(item));
	SAFECALL(AOM_refresh(item,TRUE));
	SAFECALL(AOM_lock(rev));
	SAFECALL(AOM_set_value_string(rev,"object_name",bean.goodsName.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_MaterialNo",bean.goodsCode.c_str()));
	SAFECALL(AOM_set_value_string(rev,"object_desc",bean.spec.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_TechRequirements",bean.teRe.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_State",bean.state.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_ClassificationCode",bean.pmpcCode.c_str()));
	SAFECALL(AOM_save(rev));
	SAFECALL(AOM_unlock(rev));
	SAFECALL(AOM_refresh(rev,TRUE));
	return rev;
}

//物料创建
tag_t createPart(string &id)
{
	tag_t item,rev;
	BusinessObject* item_i=nullptr;
	CreateInput* itemCreateInput =static_cast<CreateInput*>(BusinessObjectRegistry::instance().createInputObject(
									"Part", OPERATIONINPUT_CREATE));
	SAFECALL(itemCreateInput->setString("object_name", id, false));
	SAFECALL(itemCreateInput->setString("item_id",id,false));
	
	item_i =BusinessObjectRegistry::instance().createBusinessObject(itemCreateInput);
	tag_t uom;
	UOM_find_by_name("ZT2_zhongliang", &uom);
	if (uom) {
		item_i->setTag("uom_tag", uom, false);
	}
	SAFECALL(AOM_save_with_extensions(item_i->getTag()));
	item = item_i->getTag();
	SAFECALL(ITEM_ask_latest_rev(item,&rev));
	ITEM_ask_item_of_rev(rev,&item);
	SAFECALL(AOM_lock(item));
	//SAFECALL(AOM_set_value_string(item,"zt2_unit",bean.unitCode.c_str()));	
	SAFECALL(AOM_save(item));
	SAFECALL(AOM_unlock(item));
	SAFECALL(AOM_refresh(item,TRUE));
	SAFECALL(AOM_lock(rev));
	SAFECALL(AOM_set_value_string(rev,"object_name",id.c_str()));
	SAFECALL(AOM_set_value_string(rev,"zt2_MaterialNo",id.c_str()));
	//SAFECALL(AOM_set_value_string(rev,"object_desc",bean.spec.c_str()));
	//SAFECALL(AOM_set_value_string(rev,"zt2_TechRequirements",bean.teRe.c_str()));
	//SAFECALL(AOM_set_value_string(rev,"zt2_State",bean.state.c_str()));
	//SAFECALL(AOM_set_value_string(rev,"zt2_ClassificationCode",bean.pmpcCode.c_str()));
	SAFECALL(AOM_save(rev));
	SAFECALL(AOM_unlock(rev));
	SAFECALL(AOM_refresh(rev,TRUE));
	return rev;
}

void updateMaterial()
{
	LINFO<<"物料更新开始-------------"<<getTime();
	/*
	MaterialBean bean;
	bean.goodsCode="20200813";
	bean.goodsName="徐波涛测试";
	bean.pmpcCode="1000020200813";
	bean.spec="2X4X100 8ZDK.358.001 S";
	bean.state="D1";
	bean.unitCode="ST";
	printf("开始创建对象\r\n");
	POM_AM__set_application_bypass(true);
	tag_t rev =createPart(bean);
	printf("创建对象结束\r\n");
	string process_name = "TCM Release Process";
	int rel_cnt;
	tag_t *rels;
	SAFECALL(AOM_ask_value_tags(rev, "release_status_list", &rel_cnt, &rels));		//未发布,下一个
	if (rel_cnt < 1)
	{
		printf("未发布\r\n");
		proProcessCreate(rev,process_name);
		printf("流程发布结束");
	}else
	{
		printf("已发布\r\n");
	}
	*/
	
	db db;
	SAConnection conn;
	SACommand command;
	int pref_cnt;
	char **pref_vals;
	PREF_ask_char_values("database_tc", &pref_cnt, &pref_vals);
	try{
		stringstream ss;
		ss << pref_vals[0] << ':' << pref_vals[1] << '/' << pref_vals[2];		
		conn.Connect(ss.str().c_str(), pref_vals[3], pref_vals[4],
			SA_Oracle_Client);

		//ss << "10.128.155.88" << ':' << "1521" << '/' << "testdb";
		//conn.Connect(ss.str().c_str(), "infodba", "infodba",
		//	SA_Oracle_Client);
		command.setConnection(&conn);
		db.command = &command;
		vector<MaterialBean> materials = db.getMaterials();
		POM_AM__set_application_bypass(true);
		int size = materials.size();
		string process_name = "TCM Release Process";
		for(auto i=0;i<size;i++)
		{
			MaterialBean bean = materials[i];
			tag_t item = NULLTAG,rev = NULLTAG;
			char *zt2_MaterialNo;
			string p_status="1";
			string p_rec_date=getTime();
			printfMaterial(bean);
			if(bean.goodsCode.empty())
			{
				LINFO<<"异常物料----->";
				p_status="-1";
				//printfMaterial(bean);
				continue;
			}
			ITEM_find_item(bean.goodsCode.c_str(),&item);
			if(item)
			{
				ITEM_ask_latest_rev(item,&rev);
			}

			if(bean.code == 0)
			{
				
				bean.code = db.getCodeByGoodsCode(bean.goodsCode);			
				if(bean.code==0)
				{
					bean.code = db.getCode();
				}
				LINFO<<"CODE为0-->新Code:"+bean.code;
				if(item)
				{					
					char *uid ;
					ITK__convert_tag_to_uid(rev,&uid);
					bean.puid = uid;
					LINFO<<"更新物料(无需更改ID)开始-->"<<bean.goodsCode.c_str();
					updatePart(rev,bean,false);
					LINFO<<"物料更新结束-->";
				}else
				{
					LINFO<<"--新建对象开始:"<<bean.goodsCode.c_str();
					rev = createPart(bean);
					char *uid ;
					ITK__convert_tag_to_uid(rev,&uid);
					bean.puid = uid;
					LINFO<<"--新建对象结束:"<<bean.goodsCode.c_str();
				}
			}else
			{
				LINFO<<"CODE不为0-->"<<bean.code;
				vector<string> vecs = db.queryByCode(bean.code);
				bool flag  = false;
				if(vecs.size()==2)
				{
					//printf("userID:%s,puid:%s;\r\n",bean.userID.c_str(),bean.puid.c_str());
					bean.puid = vecs[0];					
					bean.userID = vecs[1];
					//printf("userID:%s,puid:%s;\r\n",bean.userID.c_str(),bean.puid.c_str());

					flag = true;
				}
				LINFO<<"Code["<<bean.code<<"]记录原UID-->["<<bean.puid.c_str()<<"];用户:["<<bean.userID.c_str()<<"]";
				if(bean.puid.empty())
				{
					LINFO<<"puid为空";
					if(item)
					{
						//ITEM_ask_latest_rev(item,&rev);
						char *uid ;
						ITK__convert_tag_to_uid(rev,&uid);
						bean.puid = uid;
						LINFO<<"更新物料(无需更改ID)开始-->"<<bean.goodsCode.c_str();
						updatePart(rev,bean,false);
						LINFO<<"物料更新结束-->";					
					}else
					{
						LINFO<<"记录为["<<bean.code<<"]的数据未记录对象，------->新建";
						rev = createPart(bean);
						char *uid ;
						ITK__convert_tag_to_uid(rev,&uid);
						bean.puid = uid;
						LINFO<<"新建结束";
					}
				}else
				{
					LINFO<<"PUID不为空";
					tag_t uid_rev = NULLTAG;
					ITK__convert_uid_to_tag(bean.puid.c_str(),&uid_rev);
					//char *item_id;
					if(uid_rev && item)
					{
						LINFO<<"物料编码对象存在，原UID对象存在";
						SAFECALL(AOM_ask_value_string(uid_rev,"zt2_MaterialNo",&zt2_MaterialNo));
						char *item_id;
						SAFECALL(AOM_ask_value_string(uid_rev,"item_id",&item_id));
						string MaterialNo = zt2_MaterialNo;
						if(strcmp(item_id,bean.goodsCode.c_str())==0)
						{
							LINFO<<"物料更新-->"<<bean.goodsCode.c_str();
							rev = uid_rev;
							updatePart(uid_rev,bean,false);
							LINFO<<"物料更新结束";
						}else
						{
							LINFO<<"异常;UID对象[item_id="<<item_id<<",uid="<<bean.puid.c_str()<<"];物料对象[ID="<<bean.goodsCode.c_str()<<"]";
							p_status = "-1";
							if(!MaterialNo.empty() && strcmp(zt2_MaterialNo,bean.goodsCode.c_str())!=0)
							{
								LINFO<<"数据异常----Code="<<bean.code<<";物料编码="<<bean.goodsCode.c_str();
								p_status="-1";
							}

						}
							
							
					}else
					{
						//1.物料编码对象存在，原UID对象不存在,更新
						if(item)
						{
							LINFO<<"物料编码对象存在，原UID对象不存在,更新";
							//ITEM_ask_latest_rev(item,&rev);
							char *uid ;
							ITK__convert_tag_to_uid(rev,&uid);
							bean.puid = uid;
							LINFO<<"更新物料(无需更改ID)开始-->"<<bean.goodsCode.c_str();
							updatePart(rev,bean,false);
							LINFO<<"物料更新结束-->";
						}
						//2.原UID对象存在，物料编码对象不存在
						else if(uid_rev)
						{
							LINFO<<"原UID对象存在，物料编码对象不存在";
							char *item_id;
							SAFECALL(AOM_ask_value_string(uid_rev,"item_id",&item_id));
							LINFO<<"原ID["<<item_id<<"],新ID["<<bean.goodsCode.c_str()<<"]";
							rev = uid_rev;
							//无需更改ID更新
							if(strcmp(item_id,bean.goodsCode.c_str())==0)
							{
								LINFO<<"更新物料(无需更改ID)开始-->"<<bean.goodsCode.c_str();
								updatePart(uid_rev,bean,false);
								LINFO<<"物料更新结束-->";							
							}else
							{
							LINFO<<"更新物料(更改ID)开始-->"<<bean.goodsCode.c_str();
							updatePart(uid_rev,bean,true);
							LINFO<<"物料更新结束-->";							
							}
						}					
					}
				}
				if(flag)
				{
					db.updateMaterial2(p_status,bean.code,bean.goodsCode);
				}
			}
			if(rev)
			{
				int rel_cnt;
				tag_t *rels;
				SAFECALL(AOM_ask_value_tags(rev, "release_status_list", &rel_cnt, &rels));		//未发布,下一个
				if (rel_cnt < 1)
				{
					LINFO<<"版本发布------->";
					proProcessCreate(rev,process_name);
				}
			}
			db.updateMaterial1(p_status,p_rec_date,bean.puid,bean.userID,bean.code,bean.goodsCode);
		}			
		conn.Disconnect();

	}catch(SAException e)
	{
		printf("异常\n");
		e.ErrMessage();
		LINFO<<e.ErrMessage().GetMultiByteChars();
		printf(e.ErrMessage());
	}
	
	LINFO<<"物料更新结束-------------";
}