/**********************************************************************
 *
 *
 * @url: /services/apexrest/NFM623Rest
 * @data:
 *  {

    }
*************************************************************************/
@RestResource(urlMapping = '/NFM623/*')
global with sharing class NFM623Rest {
     //add to AWS 回复 start sushanhu 20220225 
     static Boolean SFStatus=true;
     static String SFMessage='';
    //add to AWS 回复 end sushanhu 20220225 
    //新增NFM623Rest 学会·活动参加人员接收数据接口 精琢技术 start

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

    global class GeData {
        public String Num;                              // 活动编码
        public String Name;                             // 活动名称
        public ViewContactIdS[] ViewContactIdS;      //替换为aws存储凭据ID 20220225 sushanhu
        public LabelTypeS[] LabelTypeS;
    }

    global class ViewContactIdS {
    	public String ViewContactId;                     // 直播观看统一用户ID  
    }
    
    global class LabelTypeS {
    	public String LabelType;                         // 标签分类
    	public String Label;                             // 标签内容 
    }

    @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, 'NFM623', ges.GeData);
        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": "Success", "Message":""}';
        // res.responseBody = blob.valueOf(jsonResponse);
        //updata response toAWS 20220225 sushanhu start
        NFMUtil.NFMResponse result = NFMUtil.getNFMResponse();
        result.SFStatus=SFStatus;
        result.SFMessage=SFMessage;
        String jsonResponse =JSON.serialize(result);
        system.debug('result---'+jsonResponse);
        res.responseBody = blob.valueOf(jsonResponse);
        //updata response toAWS 20220225 sushanhu end
        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, retry_cnt__c, 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 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 = 'NFM623';
        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;
        }

		Savepoint sp = Database.setSavepoint();

        try {
            List<Campaign> camInsList = new List<Campaign>();
        	List<CampaignMember__c> camMemInsList = new List<CampaignMember__c>();
            List<CampaignLable__c> camLabInsList = new List<CampaignLable__c>();

            //将市场活动编码存入List,统一用户ID存如Map
            List<String> camNoList = new List<String>();
            List<String> conIDListNew = new List<String>();
            Map<String, String> conIDMapNew = new Map<String, String>();
            List<GeData> geDataListNew = new List<GeData>();
            for (GeData geData : geDataList) {
            	if (String.isBlank(geData.Num)) {
            		//必須項目がない場合、処理と飛ばす
                    iflog.ErrorLog__c += '活动编码不能为空。\n';
                    continue;
            	}
                if (geData.ViewContactIdS == null || geData.ViewContactIdS.size() == 0) {
                    //必須項目がない場合、処理と飛ばす
                    iflog.ErrorLog__c += '统一用户ID不能为空。\n';
                    continue;
                }
                for (ViewContactIdS viewConIdS : geData.ViewContactIdS) {
                    conIDListNew.add(viewConIdS.ViewContactId);
                    conIDMapNew.put(geData.Num, viewConIdS.ViewContactId);
                }
                camNoList.add(geData.Num);
                geDataListNew.add(geData);
            }
            //使用统一用户ID获取客户人员ID、客户人员姓名、医院科室存入Map
            Map<String, Contact> contactMap = new Map<String, Contact>();
            List<String> conIDList = new List<String>();
            if (conIDMapNew.size() > 0) {	
                List<Contact> contactList = [select Id,Name,UnifiedI_Contact_ID__c,
                                            AccountId,Account.Name 
                                            from Contact where UnifiedI_Contact_ID__c in :conIDListNew];
                if (contactList.size() > 0) {
                    //客户人员ID获取成功
                    for (Contact conInfo : contactList) {
                        contactMap.put(conInfo.UnifiedI_Contact_ID__c, conInfo);
                        conIDList.add(conInfo.Id);
                    }
                } 
                //update to 通过aws存储的unified查询 start 20220225
                // List<Contact> contactList = [select Id,Name,AWS_UnifiedI_Contact_ID__c,
                //                             AccountId,Account.Name 
                //                             from Contact where AWS_UnifiedI_Contact_ID__c in :conIDListNew];	
                // if (contactList.size() > 0) {
                //     //客户人员ID获取成功
                //     for (Contact conInfo : contactList) {
                //         contactMap.put(conInfo.AWS_UnifiedI_Contact_ID__c, conInfo);
                //         conIDList.add(conInfo.Id);
                //     }
                // } 
                //update to 通过aws存储的unified查询 20220225 end
            }
            //使用市场活动编码获取市场活动ID和活动名称存入Map
            List<String> camIDList = new List<String>();
            Map<String, Campaign> camOldMap = new Map<String, Campaign>();
            List<Campaign> campList = [select Id, Num__c, Name2__c from Campaign where Num__c in :camNoList];
            if (campList.size() > 0) {
                //市场活动ID获取成功
                for (Campaign camInfo : campList) {
                    camIDList.add(camInfo.Id);
                    camOldMap.put(camInfo.Num__c, camInfo);
                }
            } 
            
            //查询已经存在的市场活动编码下的参会人员ID和统一用户ID
            List<CampaignMember__c>  camMemberList = [select Id,Contact_ID__c,ViewContactId__c,
                                                        Campaign__c,Campaign__r.Num__c 
                                                        from CampaignMember__c where Campaign__c in : camIDList];
            Map<String, String> camContactMap = new Map<String, String>();
            Map<String, String> camViewContactMap = new Map<String, String>();
            if (camMemberList.size() > 0 ) {
                for (CampaignMember__c cm : camMemberList) {
                    camContactMap.put(cm.Contact_ID__c, cm.Campaign__r.Num__c);
                    camViewContactMap.put(cm.ViewContactId__c, cm.Campaign__r.Num__c);
                }
            }
            
            //update to 获取aws 统一凭据关联 sushanhu 20220225 satrt
            // List<CampaignMember__c>  camMemberList = [select Id,Contact_ID__c,AWS_ViewContact_Id__c,
            //                                             Campaign__c,Campaign__r.Num__c 
            //                                             from CampaignMember__c where Campaign__c in : camIDList];
            // Map<String, String> camContactMap = new Map<String, String>();
            // Map<String, String> camViewContactMap = new Map<String, String>();
            // if (camMemberList.size() > 0 ) {
            //     for (CampaignMember__c cm : camMemberList) {
            //         camContactMap.put(cm.Contact_ID__c, cm.Campaign__r.Num__c);
            //         camViewContactMap.put(cm.AWS_ViewContact_Id__c, cm.Campaign__r.Num__c);
            //     }
            // }
             //update to 获取aws 统一凭据关联 sushanhu 20220225 end
            //将原有活动标签对象中市场活动ID和标签活动名称存入Map中
            List<CampaignLable__c> camLabInfoList = [select id,name,Campaign__c,Lable__c,LableType__c from CampaignLable__c where  Campaign__c in : camIDList];
            Map<String, String> camLabInfoMap = new Map<String, String>();
            if (camLabInfoList.size() > 0) {
                for (CampaignLable__c camLabIn : camLabInfoList) {
                    camLabInfoMap.put(camLabIn.Name,camLabIn.Id);
                }
            }
            

            // 将XML各数据项更新到市场活动、学会・活动参加人员及活动标签对象中
            for (GeData geData : geDataListNew) {
                 
                if (camOldMap.get(geData.Num) == null) {
                    iflog.ErrorLog__c += '市场活动编码' + geData.Num +'：不存在\n';
                    continue;
                }
                //插入学会参会人员对象
                for (ViewContactIdS viewConIdS : geData.ViewContactIdS) {
                    CampaignMember__c camMemberInfo = new CampaignMember__c();
                    if (contactMap.get(viewConIdS.ViewContactId) != null) {
                        if (camContactMap.get(contactMap.get(viewConIdS.ViewContactId).ID) != geData.Num) {
                            camMemberInfo.Contact_ID__c = contactMap.get(viewConIdS.ViewContactId).ID;                   //参会人员ID
                            camMemberInfo.Campaign__c = camOldMap.get(geData.Num).ID;                                    //活动ID
                            camMemberInfo.Department_ID__c = contactMap.get(viewConIdS.ViewContactId).AccountId;         //医院科室
                            camMemberInfo.Department__c = contactMap.get(viewConIdS.ViewContactId).Account.Name;         //医院科室（文本）
                            camMemberInfo.Contact__c = contactMap.get(viewConIdS.ViewContactId).Name;                    //客户人员姓名
                            camMemInsList.add(camMemberInfo);
                        }
                        
                    } else {
                        if (camViewContactMap.get(viewConIdS.ViewContactId) != geData.Num) {
                            camMemberInfo.Campaign__c = camOldMap.get(geData.Num).ID;
                            camMemberInfo.ViewContactId__c = viewConIdS.ViewContactId;
                            camMemInsList.add(camMemberInfo);
                        }
                        
                    }
                }
                //插入活动标签对象
                for (LabelTypeS labelTypeS : geData.LabelTypeS) {
                    List<String> lableList = labelTypeS.Label.split(';');
                    if (lableList.size() > 0) {
                        for (Integer i= 0 ; i < lableList.size(); i++) {
                            CampaignLable__c campaignLable = new CampaignLable__c();
                            if (camOldMap.get(geData.Num) != null ) {
                                campaignLable.Campaign__c = camOldMap.get(geData.Num).ID;
                                campaignLable.LableType__c = labelTypeS.LabelType;
                                campaignLable.Lable__c = lableList[i];
                                campaignLable.Name = campaignLable.LableType__c+'-'+campaignLable.Lable__c;
                                if (String.isBlank(camLabInfoMap.get(campaignLable.Name))) {
                                    camLabInsList.add(campaignLable);
                                }
                            }
                        }
                    }
                }
            }
            
            if (camMemInsList.size() > 0) {
                upsert camMemInsList;
                logstr += '学会参会人员更新成功。\n';
            }

            if (camLabInsList.size() > 0) {
                insert camLabInsList;
                logstr += '活动标签更新成功。\n';
            }

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

        } catch (Exception ex) {
            // エラーが発生した場合
            Database.rollback(sp);
            System.debug(Logginglevel.ERROR, 'NFM623_' + rowData.MessageGroupNumber__c + ':' + ex.getMessage());
            System.debug(Logginglevel.ERROR, 'NFM623_' + 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;
    }
    //新增NMF623接口 精琢技术 end
}