/**串联问题*/
public with sharing class NFM504Controller {

	public class Tender_element {
		public NFMUtil.Monitoring Monitoring;//请求头
		public Tenders_element[] GeData;//要发送的数据
	}
	public class Tenders_element {
		public String oldProjectId;//要删除招投标的项目Id
		public String oldInfoId;// 要删除招投标的信息Id
		public String newProjectId;// 要保留招投标的项目Id
	}
	public String DTenId;
	public NFM504Controller(String DTenId) {
		this.DTenId = DTenId;
	}

	public NFM504Controller() {

	}
	@future (callout = true)
	public static void sendRequest(String DTenId) {
		Tender_information__c BTenInfo;
		// 删除的招投标
		Tender_information__c DTenInfo = [Select Id, InfoId__c, ProjectId__c, CursorMark__c, Retain_Tender__c From Tender_information__c Where Id = : DTenId];
		if (String.isNotBlank(DTenInfo.Retain_Tender__c)) {
			// 保留的招投标
			BTenInfo = [Select Id, InfoId__c, ProjectId__c, Retain_Tender__c From Tender_information__c Where Id = : DTenInfo.Retain_Tender__c];
		}
		// Monitoringの設定
		Datetime nowDT = Datetime.now();
		String nowStr = nowDT.format('yyyyMMddHHmm');
		Tender_element tenders = new Tender_element();
		tenders.Monitoring = new NFMUtil.Monitoring();
		tenders.Monitoring.Tag                  = 'MSGH';
		tenders.Monitoring.Sender               = 'SFDC';
		tenders.Monitoring.Receiver             = 'SPO';
		tenders.Monitoring.MessageType          = 'NFM504';
		tenders.Monitoring.MessageGroupNumber   = DTenInfo.CursorMark__c;
		tenders.Monitoring.NumberOfRecord       = '2';
		tenders.Monitoring.TransmissionDateTime = nowStr;
		tenders.Monitoring.Text = '';
		BatchIF_Log__c rowData = null;

		//存放报错信息
		BatchIF_Log__c iflog504 = new BatchIF_Log__c();
		iflog504.Type__c = 'NFM501';
		iflog504.RowDataFlg__c = false;
		iflog504.Log__c = ' ';
		iflog504.ErrorLog__c = ' ';
		iflog504.MessageGroupNumber__c = DTenInfo.CursorMark__c;
		// insert iflog504;
		try {
			String token;
			Datetime oldTime;
			// 从转换表中获取token
			BatchIF_Transfer__c token504 = [Select ID, NFM501_Token__c
			                                FROM BatchIF_Transfer__c Where Table__c = 'NFM501Token'];
			token = token504.NFM501_Token__c;
			// 从转换表中获取获取完token的时间
			BatchIF_Transfer__c oldTime504 = [Select ID, NFM501_Gain_End_Time__c
			                                  FROM BatchIF_Transfer__c Where Table__c = 'NFM501GainEndTime'];
			oldTime = oldTime504.NFM501_Gain_End_Time__c;

			// 判断token是否失效（失效条件为30分钟之后），如果失效，重新获取
			Long timeslot;
			Datetime newTime = System.now();
			if (oldTime == null) {
				timeslot = 2800000;
			} else {
				// 当前时间与获取token结束时间的时间差
				timeslot = newTime.getTime() - oldTime.getTime();
			}
			// System.debug('++++1++++' + token + '  : ' + timeslot);
			if (string.isblank(token) || timeslot > 1800000) {
				System.debug('---------1----------');
				NFMUtil.response response = NFMUtil.receiveToken();
				//判断rowdata中数据获取成功与否，如果失败重发三次，如果大于三次则手动操作
				if (String.isBlank(response.responseBody)) {
					// System.debug('response.responseBody:' + response.responseBody);
					iflog504.ErrorLog__c = '504token:' + response.status;
					// rowData.NFM501_Web_Annex_Count__c = 0;
					// if (!Manual_execution502) {
					// NFM501Controller.againSendRequest(iflog502, 'NFM501_Web_Annex_Count__c', rowData);
					// }
					//更新日志数据
					// System.debug('123@@@');
					return;
				}
				token = response.responseBody;
				oldTime = Datetime.now();
				System.debug('---------7----------' + token);
				token504.NFM501_Token__c = token;
				oldTime504.NFM501_Gain_End_Time__c = oldTime;
			}

			tenders.GeData = new List<Tenders_element>();
			Tenders_element tender = new Tenders_element();
			tenders.GeData.add(tender);
			if (String.isNotBlank(DTenInfo.Retain_Tender__c)) {
				tender.newProjectId = BTenInfo.ProjectId__c;
			}
			tender.oldInfoId = DTenInfo.InfoId__c;
			tender.oldProjectId = DTenInfo.ProjectId__c;

			if (tenders.GeData.size() > 0) {
				NFMUtil.Monitoring Monitoring   = new NFMUtil.Monitoring();
				Monitoring.Tag                  = tenders.Monitoring.Tag;
				Monitoring.Sender               = tenders.Monitoring.Sender;
				Monitoring.Receiver             = tenders.Monitoring.Receiver;
				Monitoring.MessageType          = tenders.Monitoring.MessageType;
				Monitoring.MessageGroupNumber   = tenders.Monitoring.MessageGroupNumber;
				Monitoring.NumberOfRecord       = tenders.Monitoring.NumberOfRecord;
				Monitoring.TransmissionDateTime = tenders.Monitoring.TransmissionDateTime;
				Monitoring.Text = '';

				rowData = NFMUtil.makeRowData(Monitoring, 'NFM501', tenders);

				System.debug('---------2----------' + rowData);
				execute(rowData, iflog504, token);
			}
		} catch (Exception ex) {
			iflog504.ErrorLog__c += ex.getMessage() + '\n';
			iflog504.ErrorLog__c += ex.getStackTraceString() + '\n';
		}
		if (rowData != null) {
			upsert rowData;
		}
		System.debug('---------6----------' + rowData);
		upsert iflog504;
		System.debug('---------3----------' + iflog504);
	}
	public static void execute(BatchIF_Log__c rowData, BatchIF_Log__c iflog504, String token) {
		Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt);
		String rowDataStr = 'text=' + NFMUtil.getRowDataStr(rowData);
		System.debug('---------4----------' + rowDataStr);
		try {
			// 向SPO送信
			NFMUtil.sendTenInfo(token, rowDataStr, NFMUtil.NFM504_ENDPOINT);
			rowData.retry_cnt__c = 0;
		} catch (Exception ex) {
			iflog504.ErrorLog__c += ex.getMessage() + '\n';
			iflog504.ErrorLog__c += ex.getStackTraceString() + '\n';
			NFM501Controller.againSendExceptionRequest(iflog504, 'retry_cnt__c', rowData,
			        '504抛出异常：' + ex.getMessage() + '\n' + ex.getStackTraceString()
			        + '\n' + rowData.ErrorLog__c +
			        '错误次数已经超过自动收信设定的最大次数，请手动收信');
		}
		upsert iflog504;
		System.debug('---------5----------' + iflog504);
		upsert rowData;

	}
}