08接收任务

一、接收任务

接收任务（receivetask）即等待任务，接收任务是一个简单任务，它会等待对应消息的到达。当前，官方只实现了这个任务的java语义。 当流程达到接收任务，流程状态会保存到数据库中。在任务创建后，意味着流程会进入等待状态，直到引擎接收了一个特定的消息， 这会触发流程穿过接收任务继续执行。

1、流程图

 

 

代码实现：

    //运行流程

    @test

    public void dotask() {

        runtimeservice runtimeservice = this.processengine.getruntimeservice();

        string processdefinitionkey = "myprocess";

        processinstance processinstance = runtimeservice.startprocessinstancebykey(processdefinitionkey);

        system.out.println("流程启动成功:" + processinstance.getid());

        

        /** 使用流程变量设置当日销售额，用来传递业务参数 */

        int value = 0;// 应该是去查询数据库，进行汇总 ---耗时操作

        int trynum=0;//尝试汇总次数

        while (true) {

            trynum++;

            try {

                value = this.hzxx();

                break;

            } catch (exception e) {

                e.printstacktrace();

                if(trynum==10) {

                    system.out.println("尝试10次汇总。全部失败，已终止汇总");

                    break;

                }

            }

        }

        runtimeservice.setvariable(processinstance.getid(), "当前的销售额", value);

        

        /** 向后执行一步，如果流程处于等待状态，使得流程继续执行 */

        runtimeservice.signal(processinstance.getid());

        

        /** 从流程变量中获取汇总当日销售额的值 */

        integer salemoney = (integer) runtimeservice//

                .getvariable(processinstance.getid(), "当前的销售额");

        system.out.println(salemoney);

        system.out.println("发送短信");

        boolean flag = false;

        int num = 0;

        do {

            flag = send();

            num++;

            if (num == 10) {

                system.out.println("尝试10次发送。全部失败，已终止发送");

                break;

            }

        } while (!flag);

        /** 向后执行一步，如果流程处于等待状态，使得流程继续执行 */

        runtimeservice.signal(processinstance.getid());

        system.out.println("流程执行完成");

    }

    //汇总信息

    public integer hzxx() {

        // 查询数据库

        system.out.println("数据汇总中....");

        try {

            thread.sleep(2000);

        } catch (exception e) {

            e.printstacktrace();

        }

        system.out.println("数据汇总完成");

        return 10000;

    }

    //发送短信

    private boolean send() {

        system.out.println("发送成功");

        return true;

    }