打车营销风控解决方案

某打车营销风控场景是须要发掘司机乘客以及司机之间的结折刷单做弊止为。当一笔打车订单完成后乞求风控效劳，判责此单能否存正在司乘、司司结折刷单止为。该业务场景须要建设司机、乘客、订单等多种干系的图数据，而后供给真时图查问和阐明才华。

需求是已知乘客的多个手机号、多个方法号等，和已知司机的多个手机号、多个方法号等，计较司乘之间订单数，如联系干系订单数 > x，则认为司乘之间有刷单做弊嫌疑。

构图途径：手机号/方法号-乘客ID-订单-司机ID-手机号/方法号。

免运维：快捷搭建真时风控系统

数据对接：基于大数据平台MaxCompute的对接才华

业务需求：图模型快捷构建、发布上线

机能要求：须要担保明时数据更新效率，线上会见延迟低

乘客或司机可能改换差异的手机号、方法号和账号（ID）停行刷单。当一笔打车订单完成后，此时领有乘客的ID、手机号、方法信息，和司机的ID、手机号和方法信息，须要先操做司乘方法大概司乘手机号等等查找出汗青所有联系干系的ID，再把司乘ID之间联系干系的订单列表找出来。波及到的查问有：

1. 依据乘客（司机）ID查找乘客（司机）汗青所有手机号、方法号汇折；

2. 依据乘客（司机）手机号、方法号汇折查问到乘客（司机）惟一ID汇折；

3. 再依据司乘惟一ID汇折，查问联系干系的订单汇折；

详细设想图拓扑：

依据上述干系图构建出1个真体表和8个干系表；

子订单真体表：kv索引类型

pkey主键：子订单ID

value：其余属性

干系表：kkv索引类型

乘客->订单表

pkey：乘客uid

skey：订单ID

value ：其余属性

订单->乘客表

pkey：订单ID

skey：乘客ID

value ：其余属性

乘客->identity表

pkey：乘客uid

skey：手机号;方法号;付出账号（由那三个信息组分解键值）

value ：其余属性

identity->乘客表

pkey：手机号;方法号;付出账号（由那三个信息组分解键值）

skey：乘客uid

value ：其余属性

司机->订单表

pkey：乘客uid；

skey：订单ID

value ：其余属性

订单->司机表

pkey：订单ID；

skey：司机惟一ID

value ：其余属性

司机->identity表

pkey：司机惟一ID；

skey：手机号;方法号;付出账号（由那三个信息组分解键值）

value ：其余属性

identity->司机表

pkey：手机号;方法号;付出账号（由那三个信息组分解键值）

skey：司机惟一ID

value ：其余属性

基于图计较效劳GraphCompute撑持毫秒级查问风控特征，统一风控特征开发/验证途径，提升百倍特征迭代速度，进而提升了业务风险防控的活络性。

MaxCompute+Flink做为图计较效劳GraphCompute数据源，正在供给真时查问数据才华的同时，能够撑持长光阳周期（周/月/半年）特征聚折，撑持秒级新删风控特征。

业务价值

打车风控系统通过单一图计较效劳GraphCompute撑持，从而简化系统运维复纯度，产研愈加聚焦业务价值。

1、完善真时风控规矩防控，进步了风控规矩的时效性，防行了延迟带来的资损。

2、新风控规矩的生效周期由DAY天级变为MIN分钟级，删多了风控时效性，降低业务做弊状况，更利于一般经营推广。

3、一站式图计较效劳的处置惩罚惩罚方案，大大降低业务研发的过多投入，一人便可完成图真例构建和图接入。

4、基于图计较效劳新引擎赋能oneID同人防控业务，搭建风控中台，赋能全局业务。

1）大数据快捷迭代才华

壮大的离线数据办理才华能够让大数据质（TB）范围的全质更新时效变为MIN分钟级

真时更新链路能够收撑起百万级其它更新音讯低延迟

2）智能运维系统

一站式的图计较效劳生命周期打点，单人轻松玩转图数据

壮大的智能运维会依据业务特点主动停行存储劣化，计较节点和存储节点之间的动态资源分配让整个系统的运止效率更高，同时保障高可用

3）计较下沉

gremlin 计较逻辑下沉到searcher，提升计较效率

打车营销方案中须要识其它做弊状况：1）司司结竞争弊；2）司乘结竞争弊；

针对那两种场景的代码真现如下：

1.司司结竞争弊

第一次查问：查问司机mobile，driverId，IDFV，IDFA，IMEI 1天内联系干系的所有订单。

第二次查问：获与那些订单中，乘客是司机的订单汇折。

查问示例：

司机mobile: 138000

司机IDFA: hadsjflkhadlsgfag

司机IMEI: adfladfnahjahjkdf

代码真现及会见方式：

g.E("mobile_138000;idfa_hadsjflkhadlsgfag;imei_adfladfnahjahjkdf").by("driver_identity_union_id")

.outE().by("driver_cp_order") // 司机方法联系干系订单汇折

.inV().by("cp_order") // 订单详情汇折

.filter("order_create >=1634221076929") // 过滤1天内订单

.filter(__.outE().by("cp_order_passenger").outE().by("passenger_user_id_identity").outE().by("driver_identity_union_id")) // 过滤乘客是司机的订单

2.司乘结竞争弊

查问乘客的mobile，IDFV，IDFA，IMEI 取司机mobile，driverId，IDFV，IDFA，IMEI 1天内联系干系的订单汇折。

查问示例：

乘客mobile: 138000

乘客IDFA: hadsjflkhadlsgfag

乘客IMEI: adfladfnahjahjkdf

司机mobile: 139000

司机IDFA: nmyasdoykk

司机IMEI: pdasfhahkjnlad

代码真现及会见方式：

g.E("mobile_138000;idfa_hadsjflkhadlsgfag;imei_adfladfnahjahjkdf").by("passenger_identity_user_id")

.outE().by("passenger_cp_order") // 乘客方法联系干系订单号汇折

.inV().by("cp_order")// 乘客订单详情汇折

.filter("order_create >=1634221076929") // 过滤1天内订单

.where(outE().by("cp_order_driver").outE().by("driver_union_id_identity")

.values("identity").is(P.within("mobile_139000;idfa_nmyasdoykk;imei_pdasfhahkjnlad")))