efile_doc_import.lsc

<?xml version="1.0" encoding="UTF-8"?>
<a:service xmlns:p="uncertain.proc" xmlns:a="http://www.leaf-framework.org/application" xmlns:s="leaf.plugin.script" trace="true">
    <a:init-procedure>
        <s:server-script ><![CDATA[
			 importPackage(Packages.com.hand.hl);
			 importPackage(Packages.com.hand.hlcm);
            try {
                var logger = $logger('server-script');
                var req_date = $ctx.parameter.getChildren();
                var batch_flag=$ctx.parameter.batch_flag;
                var session_id=$ctx.parameter.session_id;
                var batch_id_bm = $bm('efile.EFILE1030.get_tran_batch');
                var batch_id=batch_id_bm.queryAsMap().getChildren()[0].batch_id;
				logger.info(batch_id);
                var batch_databm=$bm('efile.EFILE1030.e_archive_pool_temp_import');
                var batch_dataMap=batch_databm.queryAsMap({
                    session_id : session_id
                });
                var  batch_data=batch_dataMap.getChildren();
                var sys_url_bm = $bm('cont.CON4000.get_sys_url');
                var parameter_code = 'TOKEN_POSTURL';
                var SysposturlQuery = sys_url_bm.queryAsMap({
                    parameter_code: parameter_code
                });
                var posturl = SysposturlQuery.getChildren()[0].parameter_value;
                var parameter_code = 'TOKEN_APPID';
                var SysappidQuery = sys_url_bm.queryAsMap({
                    parameter_code: parameter_code
                });
                var token_appid = SysappidQuery.getChildren()[0].parameter_value;
                var parameter_code = 'TOKEN_APPSECRET';
                var SysappsecretQuery = sys_url_bm.queryAsMap({
                    parameter_code: parameter_code
                });

                 var parameter_code = 'DOC_REQUESTURL';
                 var docUrlQuery = sys_url_bm.queryAsMap({
                      parameter_code: parameter_code
                   });
                 var docUrl = docUrlQuery.getChildren()[0].parameter_value;

                 var parameter_code = 'TOKEN_TYPE';
                 var tokenTypeyQuery = sys_url_bm.queryAsMap({
                      parameter_code: parameter_code
                   });
                var token_type = tokenTypeyQuery.getChildren()[0].parameter_value;
                var token_appsecret = SysappsecretQuery.getChildren()[0].parameter_value;
                var token_savelogs_bm = $bm('efile.EFILE1000.efile_get_token');
                //token是否在有效期内，在有效期内直接获取表中的token
                 var check_token_valid_bm = $bm('efile.EFILE1000.check_token_valid');
                var checkTokenQuery = check_token_valid_bm.queryAsMap();
                var is_valid = checkTokenQuery.getChildren()[0].is_valid;
                var fieldValueList_bm=$bm('efile.EFILE1040.efile_doc_import_query');
                //var je_data_json_bm=$bm('efile.EFILE1040.efile_journal_clob_query');
                var record=[];
                var doc_data=[];
                var batch_num=0;
                if(batch_flag=='Y'){
				   logger.info(batch_data.length);
                   for(var i=0;i<batch_data.length;i++){
				   logger.info(batch_data[i].pool_id);
                     var fieldValueList_data = fieldValueList_bm.queryAsMap({
                      pool_id: batch_data[i].pool_id
                     });


                  var companyCode='HL';
                  var documentTypeCode=batch_data[i].base_archive_code;
                  var originalNumber=batch_data[i].document_info;
				  originalNumber= originalNumber.substr(0,100);
                  var primaryField=batch_data[i].primary_field;
                  var isPaper='true';
                  var documentSource='CM';
                  var ruleOID='';
                  var securityLevelCode='';

                  var fieldValueList=fieldValueList_data.getChildren()[0].fieldValueList;
                  var attlist=[];
                  var filelist=[];


                  if(typeof(fieldValueList)=="undefined"){
                      fieldValueList=[];
                      // if(batch_data[i].je_check_flag=='Y'){
                         //  fieldValueList.push(je_json_data1);
                         //  fieldValueList.push(je_json_data2);
                          // fieldValueList=JSON.stringify(fieldValueList);
                         //  filelist.push(fieldValueList);
                      // }else{
                          filelist='[]' ;
                      //}
                  }else{
                        fieldValueList=fieldValueList.replace('中左括号替换','（');
                        fieldValueList=fieldValueList.replace('中右括号替换','）');
                        fieldValueList=fieldValueList.replace('英左括号替换','(');
                        fieldValueList=fieldValueList.replace('英右括号替换',')');
                        fieldValueList=fieldValueList.substring(17);
                        fieldValueList=JSON.parse(fieldValueList);
                         //if(batch_data[i].je_check_flag=='Y'){
                            //fieldValueList.push(je_json_data1);
                           // fieldValueList.push(je_json_data2);
                       // }
                        fieldValueList=JSON.stringify(fieldValueList);
                        filelist.push(fieldValueList);
                  }


                  var  attachmentList = fieldValueList_data.getChildren()[0].attachmentList;
                   if(typeof(attachmentList)!="undefined"){
                       attachmentList=attachmentList.replace('\s+', '');
                   }
                  if(typeof(attachmentList)=="undefined"){
                        var fils = '{'
		     	 	    +'"companyCode": "'+companyCode
		     	 	+'",'
		     	 	    +'"documentTypeCode": "'+documentTypeCode
		     	 	+'",'
		     	 	    +'"originalNumber": "'+originalNumber
		     	 	+'",'
		     	 	    +'"primaryField": "'+primaryField
		     	 	+'",'
		     	 	    +'"isPaper": "'+isPaper
		     	 	+'",'
		     	 	    +'"documentSource": "'+documentSource
		     	 	+'",'
		     	 	  +'"ruleOID": "'+ruleOID
		     	 	+'",'
		     	 	 +'"securityLevelCode": "'+securityLevelCode
		     	 	+'",'
		     	 	    +'"fieldValueList": '+filelist
		     	 	+'}';
		     	 	  fils=JSON.parse(fils);
		     	 	  doc_data.push(fils);
                  }else{
                    attachmentList=attachmentList.substring(17);
                    attachmentList=JSON.parse(attachmentList);
                    attachmentList=JSON.stringify(attachmentList);
                    attlist.push(attachmentList);

                      var fils = '{'
		     	 	    +'"companyCode": "'+companyCode
		     	 	+'",'
		     	 	    +'"documentTypeCode": "'+documentTypeCode
		     	 	+'",'
		     	 	    +'"originalNumber": "'+originalNumber
		     	 	+'",'
		     	 	    +'"primaryField": "'+primaryField
		     	 	+'",'
		     	 	    +'"isPaper": "'+isPaper
		     	 	+'",'
		     	 	    +'"documentSource": "'+documentSource
		     	 	+'",'
		     	 	  +'"ruleOID": "'+ruleOID
		     	 	+'",'
		     	 	 +'"securityLevelCode": "'+securityLevelCode
		     	 	+'",'
		     	 	 +'"attachmentList": '+attlist
		     	 	+','
		     	 	    +'"fieldValueList": '+filelist
		     	 	+'}';
		     	 		 fils=JSON.parse(fils);
		     	 	     doc_data.push(fils);
                  }
				}



                          if (is_valid =='true') {
                             var SystokenQuery = token_savelogs_bm.queryAsMap();
                             var access_token = SystokenQuery.getChildren()[0].access_token;
                             var doc_data=JSON.stringify(doc_data);
                             //doc_data=doc_data.replace(/[\'\\\\/\b\f\n\r\t]/g, '');
                              logger.info(doc_data);
							  var doc_import=new com.hand.hl.HttpPostUtilNew();
                             var data = doc_import.httpPostDocImport(docUrl,doc_data,access_token, token_type);
                             var json_data = JSON.parse(data);
                             var statusCode =json_data.statusCode;
                             var message =json_data.message;

                             var doc_import_return_bm = $bm('efile.EFILE1040.doc_import_return');
                             doc_data=JSON.parse(doc_data);
                              if(statusCode=='0000'){
                                  for(var i=0;i<doc_data.length;i++){
                                      doc_import_return_bm.insert({
                                          'primary_field': doc_data[i].primaryField,
                                          'post_status':  message,
                                          'post_message': '',
                                          'hly_req_number': batch_id
                                      })
                                  }
                              }else if(statusCode=='500000') {
                                  var result = json_data.result;
                                  for (var i = 0; i < result.length; i++) {
                                      if (result[i].primaryField) {
                                          doc_import_return_bm.insert({
                                              'primary_field': result[i].primaryField,
                                              'post_status': message,
                                              'post_message': result[i].failedMessage,
                                              'hly_req_number': batch_id
                                          })
                                      }
                                  }
                              }else if(statusCode=='500002'){
                                  for(var i=0;i<doc_data.length;i++){
                                      doc_import_return_bm.insert({
                                          'primary_field': doc_data[i].primaryField,
                                          'post_status':  'success',
                                          'post_message': '',
                                          'hly_req_number': batch_id
                                      })
                                  }
                                  var result = json_data.result;
                                  for (var i = 0; i < result.length; i++) {
                                      if (result[i].primaryField) {
                                          doc_import_return_bm.insert({
                                              'primary_field': result[i].primaryField,
                                              'post_status': message,
                                              'post_message': result[i].failedMessage,
                                              'hly_req_number': batch_id
                                          })
                                      }
                                  }

                              }
                             logger.info(data);
                         } else {
                            println("=======有效期外======");
							var  token_get=new com.hand.hlcm.HttpPostUtil();
                            var data = token_get.httpPostGetToken(posturl, token_appid, token_appsecret);
                            var json = JSON.parse(data);
                            var access_token = json.access_token;
                            var status = json.status;
                            var doc_data=JSON.stringify(doc_data);
                            //doc_data=doc_data.replace(/[\'\\\\/\b\f\n\r\t]/g, '');
							  var doc_import=new com.hand.hl.HttpPostUtilNew();
                             var data_result = doc_import.httpPostDocImport(docUrl,doc_data,access_token, token_type);
                             var json_data = JSON.parse(data_result);
                             var statusCode =json_data.statusCode;
                             var message =json_data.message;

                             var doc_import_return_bm = $bm('efile.EFILE1040.doc_import_return');
                              doc_data=JSON.parse(doc_data);
                              if(statusCode=='0000'){
                                  for(var i=0;i<doc_data.length;i++){
                                      doc_import_return_bm.insert({
                                          'primary_field': doc_data[i].primaryField,
                                          'post_status':  message,
                                          'post_message': '',
                                          'hly_req_number': batch_id
                                      })
                                  }
                              }else if(statusCode=='500000'){
                                  var result=json_data.result;
                                  for(var i=0;i<result.length;i++){
                                      if(result[i].primaryField){
                                          doc_import_return_bm.insert({
                                              'primary_field': result[i].primaryField,
                                              'post_status':  message,
                                              'post_message': result[i].failedMessage,
                                              'hly_req_number': batch_id
                                          })
                                      }
                                  }
                              }else if(statusCode=='500002'){
                                  for(var i=0;i<doc_data.length;i++){
                                      doc_import_return_bm.insert({
                                          'primary_field': doc_data[i].primary_field,
                                          'post_status':  'success',
                                          'post_message': '',
                                          'hly_req_number': batch_id
                                      })
                                  }
                                  var result = json_data.result;
                                  for (var i = 0; i < result.length; i++) {
                                      if (result[i].primaryField) {
                                          doc_import_return_bm.insert({
                                              'primary_field': result[i].primaryField,
                                              'post_status': message,
                                              'post_message': result[i].failedMessage,
                                              'hly_req_number': batch_id
                                          })
                                      }
                                  }

                              }


                            if (access_token) {
                                token_savelogs_bm.insert({
                                    'json': data,
                                    'status': 'success'
                                })

                                token_savelogs_bm.update({
                                    'system_source': 'hlcm',
                                    'expires_in': json.expires_in,
                                    'access_token': access_token
                                })

                            }

                            if (status) {
                                var token_savelogs_bm = $bm('efile.EFILE1000.token_savelogs');
                                token_savelogs_bm.insert({
                                    'json': json,
                                    'status': 'fail'
                                });
                            }

                    }
                     doc_data=[];




                }else{
                    for(var i=0;i<req_date.length;i++){
                  var fieldValueList_data = fieldValueList_bm.queryAsMap({
                      pool_id: req_date[i].pool_id
                  });


                       // var je_data_json_data;
                      //  var je_json_data_result;
                      //  var  je_json_data;
                     //   var  je_json_data1;
                     //   var  je_json_data2;
                      //  if(req_date[i].je_check_flag=='Y'){
                      //      je_data_json_data = je_data_json_bm.queryAsMap({
                      //          e_archives_id: req_date[i].e_archives_id,
                        //        document_id: req_date[i].document_id,
                       //         workflow_id: req_date[i].workflow_id
                        //    });
                         //   je_json_data=je_data_json_data.getChildren()[0].je_data_json;
                        //    je_json_data_result=JSON.parse(je_json_data);
                        //    je_json_data1=je_json_data_result[0];
                         //   je_json_data2=je_json_data_result[1];
                       // }

                  var companyCode='HL';
                  var documentTypeCode=req_date[i].base_archive_code;
                  var originalNumber=req_date[i].document_info;
				  originalNumber= originalNumber.substr(0,100);
                  var primaryField=req_date[i].primary_field;
                  var isPaper='true';
                  var documentSource='CM';
                  var ruleOID='';
                  var securityLevelCode='';

                  var fieldValueList=fieldValueList_data.getChildren()[0].fieldValueList;
                  var attlist=[];
                  var filelist=[];

                  if(typeof(fieldValueList)=="undefined"){
                      fieldValueList=[];
                      //if(req_date[i].je_check_flag=='Y'){
                          //fieldValueList.push(je_json_data1);
                          //fieldValueList.push(je_json_data2);
                          //fieldValueList=JSON.stringify(fieldValueList);
                         // filelist.push(fieldValueList);
                      //}else{
                          filelist='[]' ;
                     // }
                  }else{
                        fieldValueList=fieldValueList.replace('中左括号替换','（');
                        fieldValueList=fieldValueList.replace('中右括号替换','）');
                        fieldValueList=fieldValueList.replace('英左括号替换','(');
                        fieldValueList=fieldValueList.replace('英右括号替换',')');
                        fieldValueList=fieldValueList.substring(17);
                        fieldValueList=JSON.parse(fieldValueList);
                       //if(req_date[i].je_check_flag=='Y'){
                            //fieldValueList.push(je_json_data1);
                           // fieldValueList.push(je_json_data2);
                     //  }
                        fieldValueList=JSON.stringify(fieldValueList);
                        filelist.push(fieldValueList);

                  }


                  var  attachmentList = fieldValueList_data.getChildren()[0].attachmentList;
                  if(typeof(attachmentList)!="undefined"){
                      attachmentList=attachmentList.replace('\s+', '');
                  }

                  if(typeof(attachmentList)=="undefined"){
                      var fils = '{'
		     	 	    +'"companyCode": "'+companyCode
		     	 	+'",'
		     	 	    +'"documentTypeCode": "'+documentTypeCode
		     	 	+'",'
		     	 	    +'"originalNumber": "'+originalNumber
		     	 	+'",'
		     	 	    +'"primaryField": "'+primaryField
		     	 	+'",'
		     	 	    +'"isPaper": "'+isPaper
		     	 	+'",'
		     	 	    +'"documentSource": "'+documentSource
		     	 	+'",'
		     	 	  +'"ruleOID": "'+ruleOID
		     	 	+'",'
		     	 	 +'"securityLevelCode": "'+securityLevelCode
		     	 	+'",'
		     	 	    +'"fieldValueList": '+filelist
		     	 	+'}';
		     	 	fils=JSON.parse(fils);
		     	 	doc_data.push(fils);
                  }else{
                    attachmentList=attachmentList.substring(17);
                    attachmentList=JSON.parse(attachmentList);
                    attachmentList=JSON.stringify(attachmentList);
                    attlist.push(attachmentList);

                    var fils = '{'
		     	 	    +'"companyCode": "'+companyCode
		     	 	+'",'
		     	 	    +'"documentTypeCode": "'+documentTypeCode
		     	 	+'",'
		     	 	    +'"originalNumber": "'+originalNumber
		     	 	+'",'
		     	 	    +'"primaryField": "'+primaryField
		     	 	+'",'
		     	 	    +'"isPaper": "'+isPaper
		     	 	+'",'
		     	 	    +'"documentSource": "'+documentSource
		     	 	+'",'
		     	 	  +'"ruleOID": "'+ruleOID
		     	 	+'",'
		     	 	 +'"securityLevelCode": "'+securityLevelCode
		     	 	+'",'
		     	 	 +'"attachmentList": '+attlist
		     	 	+','
		     	 	    +'"fieldValueList": '+filelist
		     	 	+'}';
		     	 	fils=JSON.parse(fils);
		     	 	doc_data.push(fils);
                  }



                }

                 if (is_valid == 'true') {
                             var SystokenQuery = token_savelogs_bm.queryAsMap();
                             var access_token = SystokenQuery.getChildren()[0].access_token;
                             var doc_data=JSON.stringify(doc_data);
                             //doc_data=doc_data.replace(/[\'\\\\/\b\f\n\r\t]/g, '');
                             logger.info(doc_data);
							  var doc_import=new com.hand.hl.HttpPostUtilNew();
                             var data = doc_import.httpPostDocImport(docUrl,doc_data,access_token, token_type);
                             var json_data = JSON.parse(data);
                             var statusCode =json_data.statusCode;
                             var message =json_data.message;

                             var doc_import_return_bm = $bm('efile.EFILE1040.doc_import_return');
                             if(statusCode=='0000'){
                                 for(var i=0;i<req_date.length;i++){
                                     doc_import_return_bm.insert({
                                         'primary_field': req_date[i].primary_field,
                                         'post_status':  message,
                                         'post_message': '',
                                         'hly_req_number': batch_id
                                     })
                                 }
                             }else if(statusCode=='500000'){
                                 var result=json_data.result;
                                 for(var i=0;i<result.length;i++){
                                     if(result[i].primaryField){
                                         doc_import_return_bm.insert({
                                             'primary_field': result[i].primaryField,
                                             'post_status':  message,
                                             'post_message': result[i].failedMessage,
                                             'hly_req_number': batch_id
                                         })
                                     }
                                 }
                             }else if(statusCode=='500002'){
                                 for(var i=0;i<req_date.length;i++){
                                     doc_import_return_bm.insert({
                                         'primary_field': req_date[i].primary_field,
                                         'post_status':  'success',
                                         'post_message': '',
                                         'hly_req_number': batch_id
                                     })
                                 }
                                 var result = json_data.result;
                                 for (var i = 0; i < result.length; i++) {
                                     if (result[i].primaryField) {
                                         doc_import_return_bm.insert({
                                             'primary_field': result[i].primaryField,
                                             'post_status': message,
                                             'post_message': result[i].failedMessage,
                                             'hly_req_number': batch_id
                                         })
                                     }
                                 }

                             }
                             logger.info(data);
                         } else {
                            println("=======有效期外======");
							var  token_get=new com.hand.hlcm.HttpPostUtil();
                            var data = token_get.httpPostGetToken(posturl, token_appid, token_appsecret);
                            var json = JSON.parse(data);
                            var access_token = json.access_token;
                            var status = json.status;
                            var doc_data=JSON.stringify(doc_data);
                            //doc_data=doc_data.replace(/[\'\\\\/\b\f\n\r\t]/g, '');
                             logger.info(doc_data);
							  var doc_import=new com.hand.hl.HttpPostUtilNew();
                             var data_result = doc_import.httpPostDocImport(docUrl,doc_data,access_token, token_type);
                             logger.info(data_result);
                             var json_data = JSON.parse(data_result);
                             var statusCode =json_data.statusCode;
                             var message =json_data.message;
                             var doc_import_return_bm = $bm('efile.EFILE1040.doc_import_return');

                             if(statusCode=='0000'){
                                 for(var i=0;i<req_date.length;i++){
                                     doc_import_return_bm.insert({
                                         'primary_field': req_date[i].primary_field,
                                         'post_status':  message,
                                         'post_message': '',
                                         'hly_req_number': batch_id
                                     })
                                 }
                             }else if(statusCode=='500000'){
                                 var result=json_data.result;
                                 for(var i=0;i<result.length;i++){
                                     if(result[i].primaryField){
                                         doc_import_return_bm.insert({
                                             'primary_field': result[i].primaryField,
                                             'post_status':  message,
                                             'post_message': result[i].failedMessage,
                                             'hly_req_number': batch_id
                                         })
                                     }
                                 }
                             }else if(statusCode=='500002'){
                                 for(var i=0;i<req_date.length;i++){
                                     doc_import_return_bm.insert({
                                         'primary_field': req_date[i].primary_field,
                                         'post_status':  'success',
                                         'post_message': '',
                                         'hly_req_number': batch_id
                                     })
                                 }
                                 var result = json_data.result;
                                 for (var i = 0; i < result.length; i++) {
                                     if (result[i].primaryField) {
                                         doc_import_return_bm.insert({
                                             'primary_field': result[i].primaryField,
                                             'post_status': message,
                                             'post_message': result[i].failedMessage,
                                             'hly_req_number': batch_id
                                         })
                                     }
                                 }

                             }



                            if (access_token) {
                                token_savelogs_bm.insert({
                                    'json': data,
                                    'status': 'success'
                                })

                                token_savelogs_bm.update({
                                    'system_source': 'hlcm',
                                    'expires_in': json.expires_in,
                                    'access_token': access_token
                                })

                            }

                            if (status) {
                                var token_savelogs_bm = $bm('efile.EFILE1000.token_savelogs');
                                token_savelogs_bm.insert({
                                    'json': json,
                                    'status': 'fail'
                                });
                            }

                    }
                }



            } catch (e) {
                println('e：' + e);
            }
        ]]></s:server-script>
    </a:init-procedure>
</a:service>