From f6348318d0511d54babc870d5bd7dd9e4ea00313 Mon Sep 17 00:00:00 2001 From: lrj <386002446@qq.com> Date: 星期五, 25 十月 2024 09:48:20 +0800 Subject: [PATCH] 修改参数传入 ,支持 canal --- src/test/java/org/example/test.groovy | 31 +++++++++++++++++-------------- 1 files changed, 17 insertions(+), 14 deletions(-) diff --git a/src/test/java/org/example/test.groovy b/src/test/java/org/example/test.groovy index 895a94e..9c3e396 100644 --- a/src/test/java/org/example/test.groovy +++ b/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; -- Gitblit v1.8.0