修改参数传入 ，支持 canal

lrj

2024-10-25 f6348318d0511d54babc870d5bd7dd9e4ea00313

 src/test/java/org/example/test.groovy

@@ -1,4 +1,5 @@
package com.ycl.scheme;

import java.util.List;
import java.util.ArrayList;
import java.util.ArrayList;
@@ -8,20 +9,22 @@
import  java.time.LocalDate;
class scheme_1 extends AbstractSchemeRunner {
    SchemeService service;
    void run(SchemeService service){
    @Override
    void run(Map<String,Parameter> pars,SchemeService service){
        super.parameters.putAll(pars);
        this.service = service;
        if(func_0() &&func_1() ){
        if(func_0() && func_1() ){
            service.doAction(1)
        }
    }

    def func_0(){
        List<Object> pars = new ArrayList<>();
        def sql= "select count() from t_info where create_time between ? and ?  and  content like '%抢夺%'  and address like '%金牛大道%' "
        def p_0 = LocalDateTime.now();;
        pars.add(p_0);
        def p_1 = LocalDateTime.now().minusDays(5);;
        pars.add(p_1);
        Map<String,Object> pars = new HashMap<>();
        def sql= "select count(*) from t_info where create_time between :beginTime and :endTime  and  content like '%抢夺%'  and address like '%金牛大道%' ";
        def p_beginTime = LocalDateTime.now();
        pars.put('beginTime',p_beginTime);
        def p_endTime = LocalDateTime.now().minusDays(5);
        pars.put('endTime',p_endTime);
        def rs = service.execQuery(sql,pars);
        if(rs > 2){
            return true;
@@ -30,12 +33,12 @@
        }
    }
    def func_1(){
        List<Object> pars = new ArrayList<>();
        def sql= "select  from t_case where create_time between ? and ?  and  content like '%命案%'  and address like '%金牛大道%' "
        def p_0 = LocalDateTime.now();;
        pars.add(p_0);
        def p_1 = LocalDateTime.now().minusDays(5);;
        pars.add(p_1);
        Map<String,Object> pars = new HashMap<>();
        def sql= "select  from t_case where create_time between :beginTime and :endTime  and  content like '%命案%'  and address like '%金牛大道%' ";
        def p_beginTime = LocalDateTime.now();
        pars.put('beginTime',p_beginTime);
        def p_endTime = LocalDateTime.now().minusDays(5);
        pars.put('endTime',p_endTime);
        def rs = service.execQuery(sql,pars);
        if(rs >=2){
            return true;