@RestResource(urlMapping = '/SBG200/*')
global with sharing class SBG200Rest {

	global class GeDatas {
		public NFMUtil.Monitoring Monitoring;
		public GeData[] Partners;
	}

	//合作伙伴抬头层级
	global class GeData {
		public License_Info[] License_Info;

		public String CompanyCode;		//公司代码
		public Boolean IfControl;		//是否严格管控
	}

	//证照层级
	global class License_Info {
		public Detail_Info[] Detail_Info;

		public String LicenseType;		//证照类型
		public String BusLicenseNo;		//证照号
		public String ValidFrom;		//期限效期从
		public String ValidTo;			//期限效期至
	}
	//证照明细层级
	global class Detail_Info {

		public String ProName;			//装置名称
		public String ProSerial;		//辐射产品系列
		public String Quantity;			//数量
		public String Category;			//活动种类

	}


	@HttpPost
	global static void execute() {
		// 取得接口传输内容
		String strData = RestContext.request.requestBody.toString();
		GeDatas ges = (GeDatas) JSON.deserializeStrict(strData, GeDatas.class);

		if (ges == null ) {
			return;
		}

		NFMUtil.Monitoring Monitoring = ges.Monitoring;
		if (Monitoring == null) {
			return;
		}

		BatchIF_Log__c rowData = NFMUtil.saveRowData(Monitoring, 'SBG200', ges.Partners);
		if (String.isBlank(rowData.Log__c) == false) {
			executefuture(rowData.Id);
		}
		// JSONを戻す
		RestResponse res = RestContext.response;
		res.addHeader('Content-Type', 'application/json');
		res.statusCode = 200;
		String jsonResponse = '{"status": "0", "Message":""}';
		res.responseBody = blob.valueOf(jsonResponse);
		return;
	}

	@future
	global static void executefuture(String rowData_Id) {
		main(rowData_Id);
	}

	global static void main(String rowData_Id) {
		Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt);
		BatchIF_Log__c rowData = [Select Id, Name, Log__c, ErrorLog__c, Log2__c, Log3__c, Log4__c, Log5__c, Log6__c, Log7__c, Log8__c, Log9__c, Log10__c, Log11__c, Log12__c, MessageGroupNumber__c, retry_cnt__c from BatchIF_Log__c where RowDataFlg__c = true and Id = :rowData_Id];
		String logstr = rowData.MessageGroupNumber__c + ' start\n';
		BatchIF_Log__c iflog = new BatchIF_Log__c();
		iflog.Type__c = 'SBG200';
		iflog.MessageGroupNumber__c = rowData.MessageGroupNumber__c;
		iflog.Log__c = logstr;
		iflog.ErrorLog__c = '';
		insert iflog;

		String rowDataStr = NFMUtil.getRowDataStr(rowData);
		List<GeData> geDataList = (List<GeData>) JSON.deserialize(rowDataStr, List<GeData>.class);
		if (geDataList == null || geDataList.size() == 0) {
			return;
		}

		//证照转换表
		Map<String, String> transferLicenseTypeMap = NFMUtil.BatchIF_Transfer('License_Information__c');
		//证照明细转换表
		Map<String, String> certificationDetailTransferMap = NFMUtil.BatchIF_Transfer('CertificationDetails__c');

		Savepoint sp = Database.setSavepoint();
		try {

			List<GeData> satisfyGeDataList = SatisfyGeData(geDataList, iflog);

			if ( satisfyGeDataList.size() > 0) {

				Map<String, Account> accountMap = existAccountMap(satisfyGeDataList);

				if ( accountMap.size() > 0 ) {

					deleteAccountLicenseInformation(accountMap);

					insertLicense_Information(satisfyGeDataList, accountMap, transferLicenseTypeMap, iflog, certificationDetailTransferMap);
				} else {

				}
			}

			logstr += '\nend';
			rowData.retry_cnt__c = 0;

		} catch (Exception ex) {

			Database.rollback(sp);
			System.debug(Logginglevel.ERROR, 'SBG200_' + rowData.MessageGroupNumber__c + ':' + ex.getMessage());
			System.debug(Logginglevel.ERROR, 'SBG200_' + rowData.MessageGroupNumber__c + ':' + ex.getStackTraceString());
			logstr += '\n' + ex.getMessage();
			iflog.ErrorLog__c = ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + iflog.ErrorLog__c;

			if (rowData.retry_cnt__c == null) rowData.retry_cnt__c = 0;
			if (rowData.retry_cnt__c < batch_retry_max_cnt) {
				rowData.retry_cnt__c++;
				LogAutoSendSchedule.assignOneMinute();
			}
			if (rowData.retry_cnt__c >= batch_retry_max_cnt) {
				rowData.ErrorLog__c = ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + rowData.ErrorLog__c + '错误次数已经超过自动收信设定的最大次数，请手动收信';
			}
		}

		update rowData;
		iflog.Log__c = logstr;
		if (iflog.Log__c.length() > 131072) {
			iflog.Log__c = iflog.Log__c.subString(0, 131065) + ' ...';
		}
		if (iflog.ErrorLog__c.length() > 32768) {
			iflog.ErrorLog__c = iflog.ErrorLog__c.subString(0, 32760) + ' ...';
		}
		update iflog;
	}

	public static void insertLicense_Information(List<GeData> satisfyGeDataList, Map<String, Account> existAccountMap,
	        Map<String, String> transferLicenseTypeMap, BatchIF_Log__c iflog, Map<String, String> certificationDetailTransferMap) {

		System.debug('insertLicense_Information--->Start');

		Map<String, License_Info> satisfyLicenseInfoMap = new Map<String, License_Info>();
		//Boolean ifControl = false;
		Map<String,GeData> geDatalMap = new  Map<String,GeData>();
		for (GeData gedata : satisfyGeDataList) {
			geDatalMap.put(gedata.CompanyCode,gedata);
			//ifControl = gedata.IfControl;
			//System.label.IfControlRadiation = gedata.IfControl;
			for (License_Info licenseInfo : gedata.License_Info) {

				if (String.isBlank(licenseInfo.LicenseType) || String.isBlank(licenseInfo.BusLicenseNo) ||
				        String.isBlank(licenseInfo.ValidFrom) || String.isBlank(licenseInfo.ValidTo)) {
					continue;
				}

				String companyCodes = gedata.CompanyCode + ';' + licenseInfo.LicenseType;
				satisfyLicenseInfoMap.put(companyCodes, licenseInfo);
			}
		}

		if ( satisfyLicenseInfoMap.size() > 0 ) {

			List<License_Information__c> licenseInformationList = new List<License_Information__c>();
			List<CertificationDetails__c>  certificationDetailsList = new List<CertificationDetails__c>();
			Map<String, List<CertificationDetails__c>> LicenseDetailsMap = new Map<String, List<CertificationDetails__c>>();

			for (String companyCodes : satisfyLicenseInfoMap.keySet()) {

				License_Info license = satisfyLicenseInfoMap.get(companyCodes);
				String companyCode = companyCodes.split(';')[0];

				String licenseType =  FieldTransformation(companyCode, transferLicenseTypeMap, 'LicenseType__c', license.LicenseType, iflog, 'LicenseType');

				if (licenseType.equals('Invalid')) {
					continue;
				}

				License_Information__c  licenseInformation = new License_Information__c();
				licenseInformation.LicenseType__c = licenseType ;
				licenseInformation.BusinessLicense__c = license.BusLicenseNo ;
				licenseInformation.ValidFrom__c = NFMUtil.parseStr2Date(license.ValidFrom, false) ;
				licenseInformation.ValidTo__c = NFMUtil.parseStr2Date(license.ValidTo, false) ;
				licenseInformation.LicenseAndAccount__c = existAccountMap.get(companyCode).Id;
				licenseInformation.Name = existAccountMap.get(companyCode).Name + licenseType;
				//辐射安全许可证
				if ( license.LicenseType == '08' && license.Detail_Info != null) {
					licenseInformation.IfControl__c = geDatalMap.get(companyCode).IfControl;
					LicenseDetailsMap.putAll(SatisfyLicenseDetailsMap(companyCode, license.Detail_Info, certificationDetailTransferMap, iflog));
				}

				licenseInformationList.add(licenseInformation);
			}

			if ( licenseInformationList.size() > 0 ) {

				upsert licenseInformationList;

				if ( LicenseDetailsMap.size() > 0) {

					insertCertificationDetail(LicenseDetailsMap, licenseInformationList);
				}
			}
		}

		System.debug('insertLicense_Information--->End');
	}
	//保存证照明细
	public static void insertCertificationDetail (Map<String, List<CertificationDetails__c>> LicenseDetailsMap,
	        List<License_Information__c> licenseInformationList) {

		System.debug('insertCertificationDetail--->Start');
		System.debug('LicenseDetailsMap---->' + LicenseDetailsMap);
		List<String> licenseInformationIdList = new List<String>();
		for (License_Information__c licenseInformation : licenseInformationList) {

			if ( licenseInformation.LicenseType__c == '辐射安全许可证' ) {

				licenseInformationIdList.add(licenseInformation.Id);
			}
		}
		System.debug('licenseInformationIdList----->' + licenseInformationIdList);
		List<License_Information__c> existList = [select id, Name, LicenseAndAccount__r.ManagementCode_Ext__c
		        from License_Information__c where Id In :licenseInformationIdList];
		Map<String, License_Information__c> existLicenseInformationMap = new Map<String, License_Information__c>();
		System.debug('existList---->' + existList);
		for (License_Information__c licenseInformation : existList) {

			String accountManagementCode = licenseInformation.LicenseAndAccount__r.ManagementCode_Ext__c;
			existLicenseInformationMap.put(accountManagementCode, licenseInformation);
		}
		System.debug('existLicenseInformationMap---->' + existLicenseInformationMap);
		List<CertificationDetails__c> insertCertificationDetailList = new List<CertificationDetails__c>();
		for ( String companyCode : LicenseDetailsMap.keySet()) {

			for ( CertificationDetails__c certificationDetail : LicenseDetailsMap.get(companyCode)) {

				if (existLicenseInformationMap.containsKey(companyCode)) {

					certificationDetail.LicenseInformation__c = existLicenseInformationMap.get(companyCode).Id;
					insertCertificationDetailList.add(certificationDetail);
				}

			}
		}
		System.debug('insertCertificationDetailList----->' + insertCertificationDetailList);

		if (insertCertificationDetailList.size() > 0) {

			upsert insertCertificationDetailList;
		}


		System.debug('insertCertificationDetail--->End');
	}

	//获取符合的证照明细,并给证照明细赋值
	public static Map<String, List<CertificationDetails__c>> SatisfyLicenseDetailsMap(String  companyCode,
	        List<Detail_Info> licenseDetailS, Map<String, String> certificationDetailTransferMap, BatchIF_Log__c iflog) {

		System.debug('SatisfyLicenseDetailsMap--->Start');
		Map<String, CertificationDetails__c> certificationDetailMap = new Map<String, CertificationDetails__c>();
		Map<String, List<CertificationDetails__c>> result = new Map<String, List<CertificationDetails__c>>();
		List<CertificationDetails__c> certificationDetailList = new List<CertificationDetails__c>();
		for (Detail_Info detailInfo : licenseDetailS) {

			if (String.isBlank(detailInfo.ProSerial) || String.isBlank(detailInfo.Quantity) ||
			        String.isBlank(detailInfo.Category)  ) {

				continue;
			}

			String licenseType =  FieldTransformation(companyCode, certificationDetailTransferMap, 'ProdustionType__c', detailInfo.ProSerial, iflog, 'ProSerial');
			if (licenseType.equals('Invalid')) {
				continue;
			}
			//String licenseType =  FieldTransformation(bpCode, certificationDetailTransferMap, 'ProductModel__c', detailInfo.ProSerial, iflog, 'ProSerial');
			Integer quantity = Integer.valueof(detailInfo.Quantity);
			String  remarks = detailInfo.ProName + '(' + quantity + ')';
			String key = licenseType + '-' + detailInfo.Category;
			if (!certificationDetailMap.containsKey(key)) {

				//CertificationDetails__c detail = new CertificationDetails__c();
				//detail.ProductModel__c = licenseType;
				//detail.ProductModelNumber__c = Integer.valueOf(detailInfo.Quantity);
				//detail.ActivitieTypes__c = detailInfo.Category;
				//detail.DeviceName__c = detailInfo.ProName;
				CertificationDetails__c detail = new CertificationDetails__c();
				detail.ProdustionType__c = licenseType;
				detail.ProductModelNumber__c = quantity;
				detail.ActivitieTypes__c = detailInfo.Category;
				detail.DeviceName__c = detailInfo.ProName;
				detail.Remarks__c = remarks;
				certificationDetailMap.put(key, detail);
			} else {
				certificationDetailMap.get(key).ProductModelNumber__c += quantity;
				certificationDetailMap.get(key).DeviceName__c += '/' + detailInfo.ProName;
				certificationDetailMap.get(key).Remarks__c += '/' + remarks;

			}
			
		}
		if ( certificationDetailMap.size() > 0 ) {
			for (CertificationDetails__c detail : certificationDetailMap.values()) {
				//result.add(detail);
				certificationDetailList.add(detail);
			}
		}

		result.put(companyCode, certificationDetailList);
		System.debug('SatisfyLicenseDetailsMap--->End');
		return result;
	}

	public static Map<String, Account> existAccountMap(List<GeData> satisfyGeDataList) {

		System.debug('existAccountMap--->Start');
		//更新客户，同时获取客户的编码和Id
		Map<String, Account> result = new Map<String, Account>();
		Map<String, GeData> companyCodeMap = new Map<String, GeData>();

		for (GeData gedata : satisfyGeDataList) {

			companyCodeMap.put(geData.CompanyCode, gedata);
		}

		List<Account> existAccountList = [select Id, Name, ManagementCode_Ext__c
		                                  from Account where ManagementCode_Ext__c In :companyCodeMap.keySet()];
		if ( existAccountList.size() > 0) {

			for (Account account : existAccountList) {

				//if (companyCodeMap.containsKey(account.ManagementCode_Ext__c)) {

				//	//更新客户"是否严格管控"字段
				//	account.IfControl__c = companyCodeMap.get(account.ManagementCode_Ext__c).IfControl;
				//}

				result.put(account.ManagementCode_Ext__c, account);
			}

			//upsert existAccountList;
		}
		System.debug('existAccountMap--->End');
		return result;
	}

	public static List<GeData> SatisfyGeData( List<GeData> geDataList, BatchIF_Log__c iflog) {

		List<GeData> result = new List<GeData>();
		for (GeData geData : geDataList) {

			if (String.isBlank(geData.CompanyCode)) {

				iflog.ErrorLog__c += 'CompanyCode of is required,This data is skipped.\n';
				continue;
			}

			if (gedata.License_Info == null) {
				continue;
			}

			result.add(geData);
		}

		return result;
	}

	//转换前后的值的对比
	public static String FieldTransformation(String bpCode, Map<String, String> transformation, String api, String toConvertStr, BatchIF_Log__c iflog, String receivesField ) {
		String afterTransformation = NFMUtil.getMapValue(transformation, api, toConvertStr, iflog);

		if (String.isNotBlank(afterTransformation) && !afterTransformation.equals(toConvertStr)) {

			return afterTransformation;
		}  else if (String.isNotBlank(afterTransformation) && afterTransformation.equals(toConvertStr)) {
			return afterTransformation;
		} else {

			iflog.ErrorLog__c += 'BPCode[ ' + bpCode + ' ] of ' + receivesField + ' [ ' + toConvertStr + ' ]' + ' is  Invalid,This data is skipped.\n';
			return 'Invalid';
		}
	}

	public static void deleteAccountLicenseInformation(Map<String, Account> accountMap) {

		System.debug('deleteAccountLicenseInformation--->Start');
		List<License_Information__c> existList = [select id, Name, AccountManagementCode__c
		        from License_Information__c where AccountManagementCode__c In :accountMap.keySet()];

		if (existList.size() > 0) {
			delete existList;
		}
		System.debug('deleteAccountLicenseInformation--->End');
	}
}