一、同步前自定义函数执行支持数据过滤
即函中返回结果中包含"isExec":"false"，即该次同步将不再往后执行，目标数据将不会做出相应的更改。
测试场景：在自定义函数返回的Map中加入"isExec":"false"，或"isExec":false目标数据将不会发生更改。
函数代码：
Map map = ["details":syncArg.details, "objectData":syncArg.objectData, "isExec":"false" ]; return map;二、同步中执行自定义函数
函数执行后，在函数中编写的映射值修改，企业id和对象apiName不会更改。
测试场景：只有新增数据，才会携带从对象；更新时会更新对象映射值，因此如果没有对从对象做出特殊鉴别，更新的对象将不区分主从对象，一律更新，主从对象名称都会更新为自定义函数赋值
函数代码：
log.info("事件类型：" + syncArg.destEventType); log.info(syncArg.objectData); log.info(syncArg.details); Map objectData = syncArg.objectData as Map; objectData.name = "自定义函数修改" Map map = ["details":syncArg.details, "objectData":syncArg.objectData]; log.info(map); return map;三、同步后执行自定义函数
函数执行后，在函数中编写的映射值修改，企业id和对象apiName不会更改。
测试场景：数据同步不会受到影响，只是将数据传给自定义函数即可，需要通过查看日志进行判断
函数代码：
Map map = ["details":context.details, "objectData":context.data, "afterSync" : "yes001"]; return map;具体入参字段（如果不清楚入参有什么字段就先把函数写好，然后打印入参看一下，注意新增和更新入参不一样）和函数例子如下
同步前：通过数据范围的校验之后
主要入参字段：
{ "destObjectApiName": "",//目标对象apiName "sourceData": {"字段apiName":"字段值"}//对象字段信息 }简单例子：
log.info(syncArg); String destObjApiName=syncArg["destObjectApiName"] as String; log.info("destObjectApiName:"+destObjApiName); if("object_xo21i__c"==destObjApiName){ return syncArg; } Map objectData=syncArg["objectData"] as Map; String customerCode=objectData["customerCodeHead"] as String; syncArg["isExec"]=false;//把这个字段设置为false,会过滤掉这条数据不同步 return syncArg;同步中：写入目标系统之前
主要入参字段：
{ "destDetailSyncDataIdAndDestDataMap": {"":{"字段apiName":"字段值"}},//目标对象明细 "destData": {"字段apiName":"字段值"}//目标对象字段信息 //如果新增主对象在destData,明细数据在destDetailSyncDataIdAndDestDataMap，如果是更新主从数据都在destData（更新是单独更新的） }简单例子：
//修改customerShortName字段值 log.info(syncArg); syncArg["objectData"]["customerShortName"]="dddddd" log.info(syncArg); return syncArg;同步后：写入目标系统之后
主要入参字段：
{ "sourceDataId": "5fead1146660700001170e3d",//源数据id，只有crm->erp方向有这个字段 "sourceObjectApiName": "AccountObj",//源对象apiName "completeDataWriteResult": {//写入目标数据的结果 "detailWriteResults": [],//明细数据结果 "errCode": 0, "success": true, "destEventType": 1, "errMsg": "success", "writeResult": {//主数据结果，errCode为s106240000成功，其他的失败接口返回的错误码 "errCode": 5001, "success": false, "syncDataId": "3ab1c2c2ffe04111b3e713632d5a4f76", "errMsg": "预处理服务调用错误:调用外部http接口失败,错误信息：100,SAP系统BP名称已创建，不允许重复创建。::errCode=s306240003", "destDetailSyncDataIdAndDestDataMap": {} } }, "destObjectApiName": "AccountObj_1el03su6s",//目标数据对象apiName "objectData": {//目标数据 "tenant_id": "706089",//企业ei "object_describe_api_name": "AccountObj_1el03su6s",//对象apiName "_id": "5fead2696532bf0001e524e4" }, "details": {},//明细数据 }简单例子：
//crm->erp，把目标对象的id写到crm源对象 log.info(syncArg) if(syncArg["objectData"]["_id"]!=null&&syncArg["objectData"]["_id"]!="" &&syncArg["sourceDataId"]!=null&&syncArg["sourceDataId"]!=""){ String destDataId=syncArg["objectData"]["_id"] as String;//目标数据id String sourceDataId=syncArg["sourceDataId"] as String;//源数据id String errCode=syncArg["completeDataWriteResult"]["writeResult"]["errCode"]as String; log.info("--"+errCode) if (errCode =="0"){//&&destDataId.length()<11 def (Boolean error,Map data,String errorMessage) = Fx.object.update("AccountObj",sourceDataId, ["field_b25i7__c":destDataId],true); log.info(errorMessage) } } return syncArg;四、 登录k3的webapi获取数据
//定义请求参数，url,用户名，密码，数据中心
String url = "";//http://jxsz.fortiddns.com:58000/k3cloud/
String userName = "";
String passWord = "";
String acctId = "";//62415a905fb572
//请求头
Map headMap = ["Content-Type":"application/json"];
//金蝶k3c登录授权处理，登录授权需要参数：URL地址，登录用户名，密码，语言，数据中心ID,调用方法名
String login = "Kingdee.BOS.WebApi.ServicesStub.AuthService.ValidateUser.common.kdsvc";
//查询接口方法
String queryMethod = "Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc";
Map bodyMap1 = [:];
//返回结构
Map returnMap = [:];
bodyMap1.put("lcid", "2052");
bodyMap1.put("userName", userName);
bodyMap1.put("passWord", passWord);
bodyMap1.put("acctId", acctId);
StringBody body = StringBody.builder().content(bodyMap1).build()
Request request = Request.builder()
.method("POST")
.url(url+login)
.timeout(7000)
.retryCount(0)
.header("Content-Type","application/json")
.body(body)
.build()
def(Boolean error1, HttpResult data1, String errorMessage1) = Fx.http.execute(request);
if(error1){
log.info("调用登录接口异常："+errorMessage1)
}
//从登录结果取kdservice-sessionid和ASP.NET_SessionId
Map headers = data1["headers"] as Map;
if(headers==null){
Fx.message.throwErrorMessage("登录失败："+data1);
}
String Cookies = headers["Cookies"] as String;
log.info("Cookies是"+Cookies);
String sessionid=Cookies.split(";")[0];
String NET_SessionId=Cookies.split(";")[1];
sessionid=sessionid.split("=")[1];
NET_SessionId=NET_SessionId.split("=")[1];
//请求体
Map bodyMap = [:];
//返回最大行数
Integer TopRowCount=0;
//需查询的字段key集合
String FieldKeys="FCUSTID,FNumber";
//业务对象表单Id,
String FormId="BD_Customer";
//查询条件
String FilterString="FNumber != ''";
//最大行数
Integer Limit=10;
//开始行索引
Integer StartRow=0;
//组合参数
//组合查询条件参数
Map data = ["TopRowCount":TopRowCount,"FieldKeys":FieldKeys,"FormId":FormId,"FilterString":FilterString,"Limit":Limit,"StartRow":StartRow];
bodyMap.put("data", data);
//查询数据
StringBody body1 = StringBody.builder().content(bodyMap).build()
Request request1 = Request.builder()
.method("POST")
.url(url+queryMethod)
.timeout(7000)
.retryCount(0)
.header("Content-Type","application/json")
.header("kdservice-sessionid",sessionid)
.header("ASP.NET_SessionId",NET_SessionId)
.body(body1)
.build()
//log.info(url+method);
def(Boolean error, HttpResult Result, String Message) = Fx.http.execute(request1);
log.info("返回的数据信息为："+Result);
//开始处理数据
String contentStr = Result["content"] as String;
if(contentStr){
//查询失败
if(contentStr.contains("ResponseStatus")){
Fx.message.throwErrorMessage(contentStr);
}
//有数据就开始处理，返回为空就跳过
List contentList = Fx.json.parseList(contentStr);
log.info("contentList："+contentList);
String[] keyList = FieldKeys.split(",");
contentList.each{ item ->
List eachDataList=item as List;
log.info("eachDataList:"+eachDataList)
Map eachData=[:]
//每一条数据
eachDataList.eachWithIndex{ value,int i ->
eachData.put(keyList[i], value)
}
log.info("eachData:"+eachData)
}
}