oss-流程简述

《oss-流程简述》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、OSS流程简述1、CRM购物车下单SELECTDISTINCTol.ol_nbr,bf.flow_inst_id流程实例ID,op.redu_access_number接入号FROMso.order_listolJOINso.b2o_flowbusbfONbf.ol_id=ol.ol_id–购物车和流程实例关系表JOINso.busi_orderboONbo.ol_id=bf.ol_id–购物车和业务动作JOINso.prod_orderpoONpo.bo_id=bo.bo_id–bo动作和产品JOINi

2、nst.offer_prodopONop.prod_id=po.prod_idWHEREol.ol_nbr=’12201203260024653889′;2、调动流程总线启动流程select*fromWF_MESSAGE_RECEIVE_EVENTWFWHEREWF.RECEIVE_DATEbetweento_date(’2012/02/0800:00:00′,‘yyyy/mm/ddhh24:mi:ss’)andto_date(’2012/02/0900:00:00′,‘yyyy/mm/ddhh24:mi

3、:ss’);3、流程总线返回流程实例ID(CRM记录下来)selectf.*fromso.order_listoljoinso.b2o_flowbusfonf.ol_id=ol.ol_idwhere–ol.ol_nbr=’12201202080024642764′f.flow_inst_id=3095734、流程总线向OD派单，OD落地消息，并生成环节单，用MQ消息放到MQ队列补充：OD去取MQ消息，放到事件表WF_EVENT_OD表中。—MQ落地表SELECTa.flow_id,a.event_idFR

4、OMwf_event_odaWHEREa.flow_id=319170–OD环节消息接收事件UNIONSELECTb.flow_id,b.event_idFROMhis_wf_event_odbWHEREb.flow_id=319170;—侦听MQ落地表，生成环节单SELECT*FROMsrv_tache_orderaWHEREa.flow_id=319170;—主表SELECT*FROMsrv_crm_tache_orderaWHEREa.to_id=12000000004725;—CRM受理环节单从表

5、，这个里面包含了CRM送来的购物车报文—购物车id查PSO_IDSELECT*/*distinct(B2P.PSO_ID)*/FROMSRV_B2O_BUSI_ORDER_2_PSOB2PWHEREB2P.ACTION_IDIN(SELECTB2O.ACTION_IDFROMSRV_B2O_BUSI_ORDERB2OWHEREB2O.TO_IDIN(selectss.to_idfromSRV_CRM_TACHE_ORDERsswheress.ol_nbr=’12201203060024648437′));

6、5、OD根据流程实例ID通过数据总线到crm取购物车报文（问题一：CRM送的内容不对，修改报文继续走下去6、OD定单分解短流程实例id查PSO_IDSELECTdistinct(B2P.PSO_ID)FROMSRV_B2O_BUSI_ORDER_2_PSOB2PWHEREB2P.ACTION_IDIN(SELECTB2O.ACTION_IDFROMSRV_B2O_BUSI_ORDERB2OWHEREB2O.TO_IDIN(SELECTO.TO_IDFROMSRV_TACHE_ORDEROWHEREO.FL

7、OW_ID=123357));环节单拆分、合单、压单（OD，生成以产品服务、产品服务定单为粒度的定单，产品服务定单生成资源变更单——涉及到的表select*fromsrv_b2o_busi_order;——–购物车照业务动作拆分select*fromsrv_prod_serv;——–产品服务定单（业务动作合并成产品服务)——合并基本思路为同产品、同购物车、同一开通时间的业务动作进行合单，产品服务和能力、资源服务关联select*fromsrv_prod_serv_order;——–产品服务定单，和产品服务

8、在同一事务中生成，轻载，数据放在产品服务中select*fromsrv_res_order;——–资源变更单，开通、工程所有需求都转化成同构的资源变更单select*fromsrv_work_order;——–资源变更单下挂工单select*fromsrv_ro_flow;——–资源变更流程——综合查询语句selectdistincta.ol_nbr,a.flow_id,c.pso_id,d.ro_id,e.flow_id,g