public ProcessResult process()

in schedulerx-demo/schedulerx-example-springboot/src/main/java/com/aliyun/schedulerx/example/processor/TradeOrderJob.java [32:48]

• 16 lines of code
• 4 McCabe index (conditional complexity)

    public ProcessResult process(JobContext context) {
        String taskName = context.getTaskName();
        if (isRootTask(context)) {
            LOGGER.info("start root task");
            List<OrderInfo> orderInfos = getOrderInfos();
            return map(orderInfos, "OrderInfo");
        } else if (taskName.equals("OrderInfo")) {
            OrderInfo orderInfo = (OrderInfo)context.getTask();
            //id_10这个订单，构造一个异常（1/0会抛异常）
            if (orderInfo.getId().equals("id_10")) {
                int a = 1/0;
            }
            LOGGER.info(orderInfo.toString());
            return new ProcessResult(true, String.valueOf(orderInfo.getValue()));
        }
        return new ProcessResult(false);
    }