Fx.object

Map masterData = [
  "name": "主从同时新建1",  //主属性是String类型
  "owner" : ['1000'],       //人员字段是List类型
  "field_4zWog__c": [       //附件，人员字段是List<Map>，有filename，path，size，ext四个字段
    [
      "filename":"新建选择业务类型.png",
      "path":"N_202302_16_4acf04c3eb5046c08316e6e5da78ddfa",
      "size":80848,
      "ext":"png"
    ]
  ],
  "field_p1M7F__c": Date.now().toTimestamp(), //日期，时间和日期时间字段都是时间戳Long
  "field_6Lol2__c": Time.now().toTimestamp(),
]

Map detailData = [
     "object_detail1__c":[["name":"张三1","customFiled__c":"test1"],["name":"李四1","customField__c":"test2"]],
     "object_detail2__c":[["name":"张三2","customFiled__c":"test1"],["name":"李四2","customField__c":"test2"]]
]

def ret = Fx.object.create("object_1yO4J__c", masterData, detailData, CreateAttribute.builder().build()).result() as Map
log.info(ret)

List dataList = [
  [
    "name": "主属性",
    "owner" : ['1000'],
    "field_p1M7F__c": Date.now().toTimestamp(),
    "field_6Lol2__c": Time.now().toTimestamp(),
  ]
]

def ret = Fx.object.batchCreate("AccountObj", dataList, CreateAttribute.builder().build()).result() as List
log.info(ret)

String objectAPIName = 'object_s82CA__c'
String dataId = '64b1113e87ec1c0001bfc102'
Map updateData = [
  "name":"sss"
]
def (Boolean error, Map data, String errorMessage) =  Fx.object.update(objectAPIName, dataId, updateData, UpdateAttribute.builder().triggerWorkflow(true).build())
if (error) {
  log.info("error:" + errorMessage )
}
log.info(data)

String objectApiName = "object_qs2nb__c"
String objectId = "607d5e3dd02b9f00016507d8"
def objectMap = ["name":"校验"]
def detailMap = [
                 "object1":[["name": "我是从对象1，我被函数更改了"]],
                 "object2":[["name": "我是从对象2，我被函数更改了"]]
                 ]

def result = Fx.object.update(objectApiName, objectId, objectMap, detailMap, ActionAttribute.create()).result() as Map
log.info(result)

String objectApiName = "object_1yO4J__c"
QueryTemplate query = QueryTemplate.AND(
  ["name":QueryOperator.EQ("主从同时新建1")]
)
def result = Fx.object.update(objectApiName, query, ["field__c": "test"], UpdateAttribute.builder().build()).result() as String
log.info(result)

Map data = ["object_describe_api_name":"object_227xW__c","field_rT3cG__c":"函数测试12"]
def ret = Fx.object.duplicateSearch("object_227xW__c", "NEW", data, null, 1, 20).result() as Map
log.info(ret)

//批量更新的数据
Map batch = [ '60acc4a2d040a70001886739': [ 'field_5h77a__c': 'test1' ], '60acc482d040a70001886582': [ 'field_5h77a__c': 'test2' ] ]
//指定更新的字段
List fields = ['field_5h77a__c']
def rst = Fx.object.batchUpdate('object_8N0H2__c', batch, fields, BatchUpdateAttribute.builder().build()).result() as List
log.info(rst)

Fx.object.directDelete("AccountObj","60057c76a3836900012xxxx").result()

Fx.object.batchDelete("AccountObj",["60057c76a383690001243bb4","63243fd69d5de8000144c323"]).result()

def ret = Fx.object.find("AccountObj", //查询客户对象
             FQLAttribute.builder()
                .columns(["_id", "name"]) //返回的数据id
                .queryTemplate(QueryTemplate.AND(["_id": QueryOperator.EQ("6177cde7a0cb410001930ad0")]))
                .build(),
             SelectAttribute.builder().build()).result() as QueryResult
log.info(ret)

def ret = Fx.object.findOne("AccountObj", //查询客户对象
             FQLAttribute.builder()
                .columns(["_id", "name"]) //返回的数据id
                .queryTemplate( QueryTemplate.AND(["_id": QueryOperator.EQ("6177cde7a0cb410001930ad0")] ))
                .build(),
             SelectAttribute.builder()
                .build()).result() as Map;
log.info(ret)

def ret = Fx.object.findById("AccountObj", //查询客户对象
             "6177cde7a0cb410001930ad0",
             FQLAttribute.builder()
                .columns(["_id","name"]) //返回的数据id
                .build(),
             SelectAttribute.builder()
                .build()).result() as Map;
log.info(ret)

def ret = Fx.object.findByIds("AccountObj", //查询客户对象
             ["6177cde7a0cb410001930ad0"],
             FQLAttribute.builder()
                .columns(["_id","name"]) //返回的数据id
                .build(),
             SelectAttribute.builder()
                .build()).result() as List;
log.info(ret)

1. 什么是FQL
 FQL是能够在APL里使用的类SQL查询语句，开发人员能够在APL中使用FQL查询企业中的业务数据

2. FQL语法
 SELECT
    字段名1 [, 字段名2 ...]
    [FROM 对象apiName
    [WHERE where_condition]
    [ORDER BY {col_name | expr | position}
      [ASC | DESC], ...]
    [LIMIT {[offset,] row_count | row_count OFFSET offset}]
注意项
-不支持select *查询所有字段，只能通过select field1, field2...按需查找相关字段
-limit默认为10，最大值为100，offset默认为0
-使用OR条件需要单独开通，请联系销售人员下订单开通产品：【对象列表筛选支持或】

3. Where条件支持的操作符
-与查询：AND
 select name from object_227xW__c where (field_rzv5M__c is null and field_rzv5M__c<= 100) order by _id desc limit 10 offset 0;

-或查询：OR（SQL中AND运算符的优先级高于OR运算符，想要优先执行OR运算符时，需要使用括号）
 select name from object_227xW__c where (field_rzv5M__c is null or field_rzv5M__c<= 100) order by _id desc limit 10 offset 0;

-判断相等和不相等：=，!=
 select _id, field_rzv5M__c, name from object_227xW__c where field_oc43W__c = '13988523405' limit 10 offset 0;
 select _id, field_rzv5M__c, name from object_227xW__c where field_oc43W__c != '13988523405' limit 10 offset 0;
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c = 100 limit 10 offset 0;
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c != 100 limit 10 offset 0;

-大于：>，小于：<select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c>100 limit 10 offset 0;
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c<100 limit 10 offset 0;

-大于或等于：>=，小于或等于：=<select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c>= 100 limit 10 offset 0;
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c<= 100 limit 10 offset 0;

-模糊查询：like，not like，当 like 'xx' 没有放 %时相当于=
 select _id, field_rzv5M__c, name from object_227xW__c where field_oc43W__c like '%88523%';
 select _id, field_rzv5M__c, name from object_227xW__c where field_oc43W__c like '%88523';
 select _id, field_rzv5M__c, name from object_227xW__c where field_oc43W__c like '88523%';
 select _id, field_rzv5M__c, name from object_227xW__c where field_oc43W__c not like '%88523%';

-null值判断：is null，is not null
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c is null;
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c is not null;

-数组包含：@>，适用于单选、多选等数据类型为List的字段
 select _id, field_D8JyW__c, name from object_227xW__c where field_D8JyW__c @>ARRAY['option1', 'option2'];

-数组有重叠元素：&&，适用于人员多选，部门多选，比如 ARRAY[1,4,3]&&ARRAY[2,1] = true，有重复元素1，ARRAY[1,4,3]&&ARRAY[2] = false 没有重复元素
 当查询语句中使用&&和其他操作符的组合时，&&需要加上括号，否则会出现解析错误
 例如：select _id, name from object_C0vxo__c where create_time>0 and field_7cQ6y__c&&ARRAY[1000]
 需要改成：select _id, name from object_C0vxo__c where create_time>0 and (field_7cQ6y__c&&ARRAY[1000])
 select _id from object_C0vxo__c where field_7cQ6y__c&&ARRAY[1000];

-in语句：IN，NOT IN
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c IN (21, 100);
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c not IN (21, 100);

-between语句：BETWEEN AND，NOT BETWEEN AND
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c BETWEEN 21 and 100;
 select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c not BETWEEN 21 and 100;

4. 高级用法
-支持字段间的比较，不支持in，between，@>等操作符
 select name from AccountObj where last_modified_time>create_time;
 select name from AccountObj where name != firstName;
 select name from AccountObj where name = firstName;
 select name from AccountObj where name<= firstName;

-聚合查询支持聚合函数count/sum/min/max/avg和分组聚合grooup by（不支持having），
 聚合函数默认会从ES进行聚合，如果对数据一致性有所要求，请指定使用DB进行聚合
 select count(1) from object_227xW__c where field_qC2yp__c is not null
 select sum(field_rzv5M__c) from object_227xW__c where field_qC2yp__c is not null group by field_qC2yp__c
 select max(field_rzv5M__c) from object_227xW__c where field_qC2yp__c is not null group by field_qC2yp__c
 select min(field_rzv5M__c) from object_227xW__c where field_qC2yp__c is not null group by field_qC2yp__c
 select avg(field_rzv5M__c) from object_227xW__c where field_qC2yp__c is not null group by field_qC2yp__c
 // 多聚合函数和和多group by字段
 select avg(field_rzv5M__c), sum(field_rzv5M__c) from object_227xW__c where field_qC2yp__c is not null group by field_qC2yp__c, record_type

-子查询，目前只支持：字段 in/not in (子查询)
 select _id, name from object_qe3x1__c where field_4rSu9__c in (select id from object_227xW__c where name = '2021---07--2207')
 //嵌套子查询
 select _id, name from object_qe3x1__c where field_4rSu9__c in (select id from object_227xW__c where field_09jTD__c in (select id from object_qe3x1__c where name = 'zaishisyice'))

5. 代码案例
注意：Fx.object.select用来普通查询数据时返回值里的data类型是QueryResult，做聚合查询是data的类型是List
//普通用法
String sql = "select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c>100 limit 10 offset 0;"
def rst = Fx.object.select(sql).result() as QueryResult
log.info(rst)

//如果需要查询不包含作废数据、返回满足条件的数据总数
String sql1 = "select _id, field_rzv5M__c, name from object_227xW__c where field_rzv5M__c>100 limit 10 offset 0;"
SelectAttribute att = SelectAttribute.builder()
  .needInvalid(false)
  .build()
def rst1 = Fx.object.select(sql1, att).result() as QueryResult
log.info(rst1)

def objectName = 'object_227xW__c'
def searchValue = 100
def sql = "select _id, field_rzv5M__c, name from ${objectName} where field_rzv5M__c>${searchValue}";
Fx.object.select(sql, SelectAttribute.builder().build(), { list->log.info(list);
}).result();

def result = Fx.object.findWithRelated('object_0uyAd__c', 'field_YjJ6d__c', [["_id":"60868215965b1900014c0d35"]], [:], 1, 0).result() as QueryResult
log.info(result)

def rst = Fx.object.remove("AccountObj","ed47841898054749a2ec9be9e6e5d728").result() as Map

Fx.object.batchRemove("object_oMTq9__c",["id1", "id2"], RemoveAttribute.builder().build()).result()

def result = Fx.object.editTeamMember("AccountObj","36fd270a986842529445bf3d252cca9b",[["userId":"1058","role":4,"permission":1],["userId":"1057","role":3,"permission":2]]).result() as Map
log.info(result)

// 添加人员
def employTeamMember = TeamMemberAttribute.createEmployMember(["1027"],
                                     TeamMemberEnum.Role.NORMAL_STAFF,
                                     TeamMemberEnum.Permission.READONLY)
Fx.object.addTeamMember("object_qep6N__c","61848edfd9007e00019ee222", employTeamMember).result()

// 添加用户组
def groupTeamMember = TeamMemberAttribute.createGroupMember(["6152bd0de3e51c0001ec4de3"],
                                    TeamMemberEnum.Role.NORMAL_STAFF,
                                    TeamMemberEnum.Permission.READONLY)
Fx.object.addTeamMember("object_qep6N__c","61848edfd9007e00019ee222", groupTeamMember).result()

// 添加部门
def deptTeamMember = TeamMemberAttribute.createDepartmentMember(["1008"],
                                        TeamMemberEnum.Role.NORMAL_STAFF,
                                        TeamMemberEnum.Permission.READONLY)
Fx.object.addTeamMember("object_qep6N__c","61848edfd9007e00019ee222", deptTeamMember).result()

// 添加角色
def roleTeamMember = TeamMemberAttribute.createRoleMember(["00000000000000000000000000000009"],
                                        TeamMemberEnum.Role.NORMAL_STAFF,
                                        TeamMemberEnum.Permission.READONLY)
Fx.object.addTeamMember("object_qep6N__c","61848edfd9007e00019ee222", roleTeamMember).result()

// 添加外部人员
def teamMemberEmployee = TeamMemberEmployee.builder()
     .userId("309175511")
     .outTenantId("301185430")
     .build()
def outEmployTeamMember = OutTeamMemberAttribute.createEmployMember([teamMemberEmployee], TeamMemberEnum.Permission.READANDWRITE)
Fx.object.addOutTeamMember("object_qep6N__c","61848edfd9007e00019ee222", outEmployTeamMember).result()

// 添加下游企业
def outTenant = TeamMemberEmployee.builder()
     .userId("300012805")
     .outTenantId("300012805")
     .build()
def outTenantTeamMember = OutTeamMemberAttribute.createOutTenantMember([outTenant], TeamMemberEnum.Permission.READANDWRITE)
Fx.object.addOutTeamMember("object_qep6N__c","61848edfd9007e00019ee222", outTenantTeamMember).result()

// 添加外部角色
def outRoleTeamMember = OutTeamMemberAttribute.createRoleMember(["5d1f28eee4b0896efc933508"], TeamMemberEnum.Permission.READANDWRITE)
Fx.object.addOutTeamMember("object_qep6N__c","61848edfd9007e00019ee222", outRoleTeamMember).result()

// 添加下游企业组
def outTenantGroupTeamMember = OutTeamMemberAttribute.createOutTenantGroupMember(["613880213ed24b000150a713"], TeamMemberEnum.Permission.READANDWRITE)
Fx.object.addOutTeamMember("object_qep6N__c","61848edfd9007e00019ee222", outTenantGroupTeamMember).result()

Fx.object.deleteTeamMember("object_qep6N__c",["61848edfd9007e00019ee222"],[],[["userId":"300012805","outTenantId":""]]).result()

def rst = Fx.object.getTeamMember("AccountObj","83cf73d957924284a96e9c44ebb333ec").result() as List
log.info(rst)

Fx.object.changeOwner("AccountObj","ed47841898054749a2ec9be9e6e5d728","1001").result()

Map changeData1 = [
  "objectId":"5f86b47b1bdac00001f2c300",
  "ownerId":["-10000"]
]
Map changeData2 = [
  "objectId":"5f86b4a71bdac00001f2d232",
  "ownerId":["-10000"]
]
List arg = [changeData1,changeData2]
Fx.object.batchChangeOwner("object_i66LR__c", arg, ActionAttribute.create()).result()

def rst = Fx.object.getOptionName("AccountObj","lock_status","0").result() as String
log.info(rst)

Map plus = ["field_ZszsOc": "18800154471"]
List detailFillValueList = [["field_z5AI0c": "data1填充内容"], ["field_z5AI0c": "data2填充内容"]]
Map detailPlus = ["object_6hN1ic": detailFillValueList]
def rst = Fx.object.copyByRule('object_ob2G0__c','5cedf0137cfed9b33b75ddaa','map_797K4__c',plus,detailPlus).result() as Map

Fx.object.lock('AccountObj','e6a338ae8a944cdfb2bae737db1aa12f', true).result()

Fx.object.unlock('AccountObj','e6a338ae8a944cdfb2bae737db1aa12f', true).result()

Fx.object.batchLock('AccountObj', ["e6a338ae8a944cdfb2bae737db1aa12f"], true).result()

Fx.object.batchUnlock('AccountObj', ["e6a338ae8a944cdfb2bae737db1aa12f"], true).result()

String apiName = "LeadsObj"
String targetDataId = "61b9aed9a3c69e0001351a87"
List sourceDataIds = ["61b9af07a3c69e000135213f"]
Map objectData = [
             "name": "测试合并10",
             "mobile": "18840934501",
             "tel": "18840934501",
             "url": "www.ceshi44.com",
             "remark": "测试销售线索1",
             "source": "2",
             "marketing_event_id": "618a2e8b869433000198ef41",
             "leads_pool_id": "2876c6af7815475893bea6092bbffd02",
             "record_type": "default__c",
             "close_reason": "",
             "back_reason": "",
             "data_own_department": [
             "1001"
         ],
         "mc_exchange_rate": "1.000000",
         "is_duplicated": false,
         "data_own_organization": [
             "999999"
         ],
         "leads_stage_changed_time": 1636873294913,
         ]
Fx.object.merge(apiName, targetDataId, sourceDataIds, objectData).result()

def (Boolean error, List data,String errorMessage) = Fx.object.aggregate("object_227xW__c", Aggregate.MAX("field_rzv5M__c"), [["field_rzv5M__c":Operator.GT(10)]], 'field_qC2yp__c') //最大值
if(error) {
 log.info(errorMessage)
} else {
 log.info(data)
}

def rst = Fx.object.aggregate("object_rqa45__c", Aggregate.AVG("field_VE1by__c"), 2, [["name":Operator.LIKE("name")], FindAttribute.getDefaultFindAttribute()).result() as Map
log.info(rst)

def rst = Fx.object.findDescribe('object_qep6N__c').result() as Map
log.info(data)

def rst = Fx.object.getOptionInfo("object_i66LR__c","record_type").result() as Map
log.info(rst)

Fx.object.bulkDelete("AccountObj", ["60057c76a383690001243bb4", "60057c76a383690001243bb5"]).result()

Fx.object.bulkRecover("AccountObj", ["60057c76a383690001243bb4", "60057c76a383690001243bb5"]).result()

Fx.object.delete("AccountObj", "60057c76a383690001243bb4").result()

def rst = Fx.object.getMappingRule("map_ri5oc__c").result() as Map;
log.info(rst)

def optionAttribute = OptionAttribute.builder()
     .apiName("object_qep6N__c")
     .fieldApiName("field_16Yl4__c")
     .optionValue("C3mG8ou09")
.build()

def rst = Fx.object.getCascadeOption(optionAttribute).result() as Map
log.info(rst)OptionAttribute optionAttribute = OptionAttribute.builder()
     .apiName("object_qep6N__c")
     .fieldApiName("field_16Yl4__c")
     .optionValue("C3mG8ou09")
.build();

Map rst = Fx.object.getCascadeOption(optionAttribute).result();
log.info(rst);

ActionAttribute attribute = ActionAttribute.create()

ActionAttribute.build {
      forceQueryFromDB = false
}

List criteria = [["name": Operator.EQ("测试")]]

List criteria = [["name": Operator.NE("测试")]]

List criteria = [["create_time": Operator.GT(1645427372658)]]

List criteria = [["create_time": Operator.LT(1645427372658)]]

List criteria = [["create_time": Operator.GTE(1645427372658)]]

List criteria = [["create_time": Operator.LTE(1645427372658)]]

List criteria = [["name": Operator.LIKE("易动纷享")]]

List criteria = [["name": Operator.NLIKE("易动纷享")]]

List criteria = [["name": Operator.IN(["易动", "纷享"])]]

List criteria = [["name": Operator.NIN(["易动", "纷享"])]]

List criteria = [["name": Operator.CONTAINS(["易动", "纷享"])]]

List criteria = [["name": Operator.NCONTAINS(["易动", "纷享"])]]

List criteria = [["name": Operator.HASANYOF(["易动", "纷享"])]]

List criteria = [["name": Operator.NHASANYOF(["易动", "纷享"])]]

List criteria = [["name": Operator.EXISTS(true)]]

List criteria = [["name": Operator.STARTWITH("易动")]]

List criteria = [["name": Operator.ENDWITH("易动")]]

List criteria = [["name": Operator.BETWEEN([154542372658, 1645427372658])]]

def teamMemberEmployee = TeamMemberEmployee.builder()
         .userId("309175511")
         .outTenantId("301185430")
         .build()
OutTeamMemberAttribute outEmployTeamMember = OutTeamMemberAttribute.createEmployMember([teamMemberEmployee], TeamMemberEnum.Permission.READANDWRITE)
def outEmployTeamResult = Fx.object.addOutTeamMember("object_qep6N__c","61848edfd9007e00019ee222", outEmployTeamMember)
log.info(outEmployTeamResult)