package DBtank;
#
# SPDX-License-Identifier: AGPL-3.0-or-later
# Copyright (c) Rainer Gümpelein, TeilRad GmbH
#
use strict;
use warnings;
use POSIX;
use DBI;
use DBI::Const::GetInfoType;
use CGI ':standard';
use Lib::Config;
use Mod::Basework;
use Scalar::Util qw(looks_like_number);
use Config::General;
use Data::Dumper;

my $cf = new Config;
my $bw = new Basework;
my $q = new CGI;
$q->import_names('R');
my $debug = 1;

sub new {
 my $class = shift;
 my $self = {};

 my $globalconf_file = "/var/www/copri4/shareeconf/global.cfg";
 my $conf = Config::General->new($globalconf_file);
 my %globalconf = $conf->getall;
 $self = \%globalconf;

 bless($self,$class);
 return $self;
}

my $today = strftime("%d.%m.%Y",localtime(time));
my $date_time = strftime("%d.%m.%Y %H:%M",localtime(time));
my %varenv = $cf->envonline();

#dbconnect_intern, on default $dbh_intern will be used
my $dbh_intern = &dbconnect(""); 
sub dbconnect {
 my $self = shift;
 my $options ="";
 my $database = "dbi:Pg:dbname=$varenv{dbname};host=$varenv{dbhost};port=5432;options='$options'";
 my $dbh = DBI->connect($database, $varenv{dbuser}, $varenv{dbpassw},{ RaiseError => 1, AutoCommit => 1 }) or die "Can't connect to $varenv{dbname}: $DBI::errstr";
 #$bw->log("--> dbconnect_intern --> $varenv{syshost} ",$database,"");
 return $dbh if($dbh);
}


#dbconnect_extern for copri operator instance
sub dbconnect_extern {
 my $self = shift;
 my $dbname = shift;
 my $client_encoding = shift || "";

 my $instance_type = "operator";
 $instance_type = "primary" if($dbname eq $self->{primary}->{sharee_primary}->{database}->{dbname});

 my $globalconf_file = "/var/www/copri4/shareeconf/global.cfg";
 my $conf = Config::General->new($globalconf_file);
 my %globalconf = $conf->getall;

 #$bw->log("dbconnect_extern call with instance_type:$instance_type and copri_instance:",$dbname,"");

 #keep in mind, only one DB can be returned by this way
 while (my ($key, $value) = each %{ $globalconf{$instance_type} }) {
  if($key eq $dbname){
   $bw->log("dbconnect_XX",$value->{database}->{dbname},"");
   my $database = "dbi:Pg:dbname=$value->{database}->{dbname};host=$value->{database}->{host};port=$value->{database}->{port};options='$value->{database}->{options}'";
   $database .= ";sslmode=$value->{database}->{sslmode}" if($value->{database}->{sslmode} && $value->{database}->{host} ne "localhost");
   my $dbh = DBI->connect($database, $value->{database}->{user}, $value->{database}->{passwd},{ RaiseError => 0, AutoCommit => 1 });
   #$bw->log("--> dbconnect_extern success --> $database, $value->{database}->{user}, $value->{database}->{passwd}",$database,"");
   $dbh->do("set CLIENT_ENCODING TO 'iso-8859-1'") if($client_encoding && $client_encoding eq "iso-8859-1");
   return $dbh if($dbh);
  }
 }
 $bw->log("ERROR, dbconnect_extern call with dbname: $dbname |instance_type:$instance_type","","");
 return "";
}

#get operator conf by oprefix
sub get_operator_conf {
 my $self = shift;
 my $oprefix = shift || "";

 my $globalconf_file = "/var/www/copri4/shareeconf/global.cfg";
 my $conf = Config::General->new($globalconf_file);
 my %globalconf = $conf->getall;

 while (my ($key, $operator) = each %{ $globalconf{operator} }) {
   if($oprefix && $oprefix eq $operator->{oprefix}){
	#$bw->log("get operator conf by oprefix: $oprefix",$operator->{oprefix},"");
	return $operator;
   }
 }
 $bw->log("Cannot get operator conf by oprefix: $oprefix","","");
 return 0;
}

#get dbname because varenv{dbname} seems not stable
sub get_dbname {
 my $self = shift;
 my $dbh = shift || $dbh_intern; 
 my $source = $dbh->get_info( $GetInfoType{SQL_DATABASE_NAME} );
 return $source;
}


#loop extern operator db's for specific tablefield sync
sub update_operatorsloop {
 my $self = shift;
 my $dbname = shift || "";
 my $adrc_id = shift || 0;
 my $todo = shift || "update";

 my $authref = {
                table           => "contentadr",
                fetch           => "one",
                template_id     => "202",
                c_id            => "$adrc_id",
 };
 my $dbh_primary = $self->dbconnect_extern($self->{primary}->{sharee_primary}->{database}->{dbname});
 my $record_primary = { c_id => 0 };
 $record_primary = $self->fetch_record($dbh_primary,$authref) if($adrc_id && $adrc_id > 0);

 $bw->log("update_operatorsloop by copri_instance-dbname: $dbname | owner: $record_primary->{owner}","","");

 my $rows = 0;
 if($record_primary->{c_id}){

   my %operator_hash = ();
   #keep in mind, shareedms-operators updates primary, that's because we have to also loop
     if($record_primary->{txt17}){
       if($record_primary->{txt17} =~ /\w\s\w/){
         %operator_hash = map { $_ => "$self->{operator}{$_}->{operatorApp}" } split(/\s+/,$record_primary->{txt17});
       }else{
         %operator_hash = ( "$record_primary->{txt17}" => "$self->{operator}{$record_primary->{txt17}}->{operatorApp}" );
       }
       foreach my $sharee_operator (keys (%operator_hash)){
	if($sharee_operator =~ /sharee_/){
	 $sharee_operator =~ s/\s//g;
         my $dbh_operator = $self->dbconnect_extern("$sharee_operator");
    	 if($todo eq "update"){

	   	delete $record_primary->{txt17};#operators
   		delete $record_primary->{txt30};#tarifs
   		delete $record_primary->{txt15};#Bonusnr
   		delete $record_primary->{int07};#Rabatt
   		delete $record_primary->{int09};#Service App staff
   		delete $record_primary->{int16};#payone-cron-interval
   		delete $record_primary->{int19};#Ilockit Admin
		#delete $record_primary->{int05};#Web-Login
		#delete $record_primary->{int12};#Vde (remove delete for global setting)
   		delete $record_primary->{int23};#mini_answer count will be saved on operator
		#delete $record_primary->{txt29};#Sonstiges
   		delete $record_primary->{txt35};#Umfragelink

   	   my $update = {
                %$record_primary,
                table   =>      "contentadr",
               };
   	    $bw->log("--> save_account update_operatorsloop $sharee_operator",$update->{c_id},"");

            $bw->log("UPDATE adr from record_primary to operator on loop $sharee_operator",$record_primary->{c_id},"");
	    $rows = $self->update_record($dbh_operator,$update,$record_primary);
	    if($rows != 1 && $record_primary->{int04} && $record_primary->{int13} && $record_primary->{int14}){
              $bw->log("INSERT adr from record_primary to operator on loop $sharee_operator",$record_primary->{c_id},"");
              my $insert = {
                %$record_primary,
                table   =>      "contentadr",
                mtime   =>      'now()',
                };

                my $c_id = $self->insert_contentoid($dbh_operator,$insert,"");
		$rows = 1 if($c_id);

            }
    	 }elsif($todo eq "delete"){
            $bw->log("DELETE adr from operators and at last primary $sharee_operator",$record_primary,"");
	    $rows += $self->delete_content($dbh_operator,"contentadr",$record_primary->{c_id});
	 }
	}
       }
     }
  }
  return $rows;
}#end update_operatorsloop


#CMS-Texte sync primary to operators
sub operators_cms {
 my $self = shift;
 my $dbname = shift || "";
 my $c_id = shift || 0;
 my $todo = shift || "update";

 my $cmsref = {
                table           => "contentuser",
                fetch           => "one",
                template_id     => "194",
                c_id            => "$c_id",
 };
 my $dbh_primary = $self->dbconnect_extern($self->{primary}->{sharee_primary}->{database}->{dbname});
 my $record_primary = { c_id => 0 };
 $record_primary = $self->fetch_record($dbh_primary,$cmsref) if($c_id && $c_id >= 1000);

 my $rows = 0;
 if($record_primary->{c_id}){

     while (my ($key, $op_name) = each %{ $self->{operator} }) {
       if($op_name->{database}->{dbname}){
   	 my $sharee_operator = $op_name->{database}->{dbname};
         my $dbh_operator = $self->dbconnect_extern($sharee_operator);
    	 if($todo eq "update"){
	   $bw->log("UPDATE CMS operator $sharee_operator",$record_primary,"");
   	   my $update = {
                %$record_primary,
                table   =>      "contentuser",
               };

	   $rows = $self->update_record($dbh_operator,$update,$record_primary);
	   if($rows != 1){
              my $insert = {
                %$record_primary,
                table   =>      "contentuser",
                mtime   =>      'now()',
                };

                my $c_id = $self->insert_contentoid($dbh_operator,$insert,"");
		$rows = 1 if($c_id);

            }
    	 }elsif($todo eq "delete"){
	    $bw->log("DELETE CMS operator $sharee_operator",$record_primary,"");
	    $rows += $self->delete_content($dbh_operator,"contentuser",$record_primary->{c_id});
	 }
	}
       }

  }
  return $rows;
}#end operators_cms


#return system and contentadr username by c_id (owner last change)
sub sys_username {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $owner = shift || "";
 my $u_name = "";

 if(looks_like_number($owner)){
  my $channel_map = $self->channel_map();

  foreach my $id (sort { $channel_map->{$a} cmp $channel_map->{$b} } keys (%$channel_map)){
     if($id == $owner){
        $u_name = $channel_map->{$id};
     }
  }

  if(!$u_name){
    my $users_pref = {
        table           => "contentadr",
        fetch           => "one",
	c_id	=> $owner,
      };
    my $ct_users = $self->fetch_tablerecord($dbh,$users_pref);
    $u_name = $ct_users->{txt01};
  }

 }
 return $u_name;
}

#collect serviceapp and DMS users for search select username u_id mapping
sub users_map(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $mapref = shift || "";

 my $and = "";
 if(ref($mapref) eq "HASH"){
  foreach my $key (keys (%$mapref)){
        $and = " and u.$key=$mapref->{$key}" if($key =~ /int/);
  }
 }

 my $sql = "SELECT ct.* FROM contentadr ct, users u WHERE ct.c_id=u.u_id $and";
 my $sth = $dbh->prepare($sql);
 my $rc = $sth->execute();
 my $users_rec = $sth->fetchall_hashref('c_id');
 $bw->log("DBtank users_map:",$sql,"") if($debug);

 return $users_rec;
}


#booking channel id's
#TODO migrate all to global.cfg <merchant_ids>
sub channel_map(){
  my $self = shift;
  my $channel = {
	    #167 => "sig cmd",
	    168 => "shareeio",
	    169 => "sigo connector",
	    172 => "reserve timeout",
	    #173 => "merchant fallback",#mig
	    174 => "cronjob bonus",
	    #175 => "cronjob cpdate",
	    176 => "Mein konrad App",#mig
	    177 => "LastenradBay App",#mig
	    178 => "payone API",
	    179 => "cronjob payone",
	    #181 => "SMS API",
	    #182 => "velofactur API",
            183 => "Ilockit API",
	    #184 => "web App",#mig
	    #185 => "konstanz App",#mig
            186 => "sharee.bike App",#mig
            187 => "shareetool",#mig
            188 => "sys API",
            192 => "web Bayern",
	    #193 => "web demo",#mig
            195 => "web konrad",#mig and import
            196 => "copri",#mig
            197 => "web sharee.bike",#mig
            198 => "primary",#mig
	    294 => "example Web",#mig
	    295 => "example App",#mig
            296 => "example Op",#mig
            298 => "example Pr",#mig
  };
  return $channel;
}


#get tpl
sub get_tpl {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $tpl_id = shift || 0;
 my $sth = $dbh->prepare("SELECT * FROM template WHERE tpl_id='$tpl_id'");
 my $rc = $sth->execute();
 my $tpl = $sth->fetchrow_hashref();
 return $tpl;
}

#all templates
sub collect_tpl(){
 my $self = shift;
 my $tpl_ids = shift || "";
 my $dbh = shift || $dbh_intern;
 my $where = "where tpl_id != 98 and tpl_id != 97";#without meta-Config and EditNode
 $where .= " and tpl_id IN ($tpl_ids)" if($tpl_ids);
 my $sth = $dbh->prepare("SELECT * FROM template $where");
 my $rc = $sth->execute();
 my $tpl_all = $sth->fetchall_hashref("tpl_id");
 return $tpl_all;
}

#get uri_path and meta data like tpl_order by menue path 
sub get_node_meta {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $viewsel = shift;

 my $node_name1 = $q->escapeHTML(@{$viewsel}[-1]);
 my @node_path = ("$node_name1");

 my $where = "WHERE n.main_id=rel.main_id and rel.template_id=tpl.tpl_id and node_name = '$node_name1'";
 pop @{$viewsel};
 my @reverse_viewsel = reverse(@{$viewsel});
 #print Dumper(@reverse_viewsel) . "<br>\n";

 #bsp
 #SELECT * FROM nodes n,relation rel, template tpl WHERE n.main_id=rel.main_id and rel.template_id=tpl.tpl_id and n.node_name = 'Firma' and n.parent_id IN (SELECT n.main_id from nodes n where n.node_name='Einstellung' and n.parent_id IN (SELECT n.main_id from nodes n where n.node_name='JBW'));

 foreach(@reverse_viewsel){
   #print $_ . "<br>\n";
   my $node_nameX = $q->escapeHTML($_);
   push(@node_path, $node_nameX);
   $where .= " and n.parent_id IN (SELECT n.main_id from nodes n where n.node_name='$node_nameX'";
 }

 foreach(@reverse_viewsel){
   $where .= ")";
 }
 my $sql = "SELECT n.owner AS nowner,n.change AS nchange,* FROM nodes n,relation rel, template tpl $where";
 my $sth = $dbh->prepare($sql);
 my $rc = $sth->execute();
 my $nrt = $sth->fetchrow_hashref();

 my @reverse_node_path = reverse(@node_path);
 my $uri_path = "";
 foreach(@reverse_node_path){
   $uri_path .= "$_/";
 }
 $uri_path =~ s/\/$//;
 $bw->log("get_node_meta $uri_path",$sql,"") if($debug);
 #print Dumper($nrt);
 return $nrt;
}

sub get_node {
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $main_id = shift;
  my $sth = $dbh->prepare("SELECT * FROM nodes WHERE main_id=$main_id");
  my $rc = $sth->execute();
  my $node = $sth->fetchrow_hashref();
  return $node;
}

# Nodes einer Ebene
sub collect_node {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $main_id = shift;
 my $sth = $dbh->prepare("SELECT * FROM nodes WHERE parent_id=$main_id");
 my $rc = $sth->execute();
 my $nodes = $sth->fetchall_hashref("main_id");
 my $rows = $sth->rows;
 return ($nodes,$rows);
}

#collect main_ids
sub collect_noderec {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $main_id = shift;

 my $main_ids = "$main_id,";
 my ($main_collect,$rows) = $self->collect_node($dbh,$main_id);
 if(ref($main_collect) eq "HASH"){
   foreach my $id (keys (%$main_collect)){
    if($main_collect->{$id}->{node_name}){
      $main_ids .= "$main_collect->{$id}->{main_id},";
      my ($main_collect2,$rows) = $self->collect_node($dbh,$main_collect->{$id}->{main_id}) if($main_collect->{$id}->{main_id});
      if(ref($main_collect2) eq "HASH"){
       foreach my $id (keys (%$main_collect2)){
        $main_ids .= "$main_collect2->{$id}->{main_id},";
        my ($main_collect3,$rows) = $self->collect_node($dbh,$main_collect2->{$id}->{main_id}) if($main_collect2->{$id}->{main_id});
        if(ref($main_collect3) eq "HASH"){
         foreach my $id (keys (%$main_collect3)){
          $main_ids .= "$main_collect3->{$id}->{main_id},";
         }
        }
       }
      }
    }
   }
  }
  $main_ids =~ s/,$//;
  return $main_ids;
}

#collect relation nodes
sub collect_rel4nodes(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $main_ids = shift;

 my $sth = $dbh->prepare("SELECT * FROM relation rel, nodes nd where rel.main_id=nd.main_id and parent_id IN ($main_ids)");
 my $rc = $sth->execute();
 my $rel4nd = $sth->fetchall_hashref("rel_id");
 return $rel4nd;
}

# Nodes einer Ebene mit relation
sub collect_noderel {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $main_id = shift;
 my $template_id = shift || "";
 #my $where = "WHERE n.main_id=rel.main_id and rel.content_id=0 and n.parent_id=$main_id";
 my $where = "WHERE n.main_id=rel.main_id and rel.content_id=0 and n.parent_id=$main_id and node_public='t'";
 $where .= " and rel.template_id=$template_id" if($template_id);
 my $sth = $dbh->prepare("SELECT * FROM nodes n, relation rel $where");
 my $rc = $sth->execute();
 my $nodes = $sth->fetchall_hashref("main_id");
 my $rows = $sth->rows;
 return ($nodes,$rows);
}

#recursive node runner to get node path
sub recurse_select {
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $main_id = shift || "";
  my $sth = $dbh->prepare("SELECT parent_id,node_name FROM nodes where main_id=$main_id");
  my $rc = $sth->execute();
  my $node = $sth->fetchrow_hashref();
  return ($node->{parent_id},$node->{node_name});
}
sub recurse_node {
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $main_id = shift || "";
  my $depth=$1 if($main_id =~ /^(\d)/);
  my $uri_path = "?failure=recurse_node";
  my @nodes = (); 
  if($main_id && $main_id > 20000){
   $uri_path = "";
   for(my $i=0; $i<$depth;$i++){
	($main_id,my $node_name) = $self->recurse_select($dbh,$main_id) if($main_id);
	push(@nodes, $node_name);
	#print $main_id . "|$node_name\n";
   }
   my @node_path = reverse(@nodes);
   foreach(@node_path){
    $uri_path .= "$_/";
   }
   $uri_path =~ s/\/$//;
  }
  return $uri_path;
}
###############################


#get one subnode
#ex. get contentpos template_id from subnode 
#select n.n_id,n.parent_id,n.main_id,rel.template_id from nodes n, relation rel where n.main_id=rel.main_id and n.parent_id=300029;
# n_id | parent_id | main_id | template_id
#------+-----------+---------+-------------
#  431 |    300029 |  400004 |         401
sub get_subrelnode {
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $main_id = shift;
  my $template_id = shift || "";
  my $node_name = shift || "";
  my $where = "";
  $where .= " and rel.template_id = $template_id" if($template_id);
  $where .= " and n.node_name = '$node_name'" if($node_name);
  my $sql = "SELECT * FROM nodes n, relation rel where n.main_id=rel.main_id and n.parent_id=$main_id $where";
  my $sth = $dbh->prepare($sql);
  my $rc = $sth->execute();
  my $node = $sth->fetchrow_hashref();
  $bw->log("get_subrelnode",$sql,"");
  return $node;
}

#because of different and dynamic pos templates we need template grouping
sub pos_template_group {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $fetch = shift;
 my $ctcp_where = "1=1";

 if($fetch->{table} eq "content" && $fetch->{table_pos} eq "contentpos"){
   $ctcp_where .= " and ct.c_id=cp.cc_id";
 }elsif($fetch->{table} eq "contentadr" && $fetch->{table_pos} eq "contentadrpos"){
   $ctcp_where .= " and ct.c_id=cp.ca_id";
 }

 my $sql = "SELECT tpl_id,tpl_order from template where tpl_id IN (SELECT cp.template_id from $fetch->{table_pos} cp, $fetch->{table} ct where $ctcp_where group by cp.template_id)";

 my $sth = $dbh->prepare($sql);
 my $rc = $sth->execute();
 my $templates = $sth->fetchall_hashref("tpl_id");
     
 $bw->log("pos_template_group",$sql,"");
 return $templates;
}

#fetch relation, template, nodes
sub fetch_rel4tpl4nd(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $fetch = shift;

 $fetch->{content_id}=0 if($fetch->{content_id} eq "null");
 my $where = "WHERE nodes.main_id=relation.main_id and relation.template_id=template.tpl_id";
 $where .= " and nodes.parent_id=$fetch->{parent_id}" if($fetch->{parent_id});
 $where .= " and relation.main_id=$fetch->{main_id}" if($fetch->{main_id});
 $where .= " and relation.content_id=$fetch->{content_id}" if($fetch->{content_id});
 $where .= " and relation.template_id=$fetch->{template_id}" if($fetch->{template_id});
 if($fetch->{template_id1} && $fetch->{template_id2}){
   $where .= " and relation.template_id >= $fetch->{template_id1} and relation.template_id <= $fetch->{template_id2}";
 }
 $where .= " and relation.rel_id=$fetch->{rel_id}" if($fetch->{rel_id});
 $where .= " order by content_id $fetch->{ascdesc}" if($fetch->{ascdesc});

 my $sql = "SELECT * FROM relation,template,nodes $where";
 my $sth = $dbh->prepare($sql);
 my $rc = $sth->execute();

 my $rel = { main_id => 0 };
 if($fetch->{fetch} eq "all" && $fetch->{keyfield}){
   $rel = $sth->fetchall_hashref($fetch->{keyfield});
 }else{
   $rel = $sth->fetchrow_hashref();
 }
 #$bw->log("fetch_rel4tpl4nd ",$sql,"") if($debug);

 return $rel;
}

#all accounting position of contenttrans
sub collect_contenttrans(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $ct_id = shift || "";

 my $sth = $dbh->prepare("SELECT * FROM contenttrans where int20 = $ct_id");
 my $rc = $sth->execute();
 my $cpos = $sth->fetchall_hashref("c_id");
 my $rows = $sth->rows;
 return ($cpos,$rows);
}


#all position of contenttrans
sub collect_contentpos(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $table = shift;
 my $ct_id = shift || "";
 my $where = "where ctt.c_id=pos.ct_id and ctt.c_id='$ct_id'";

 if($ct_id){
  my $sth = $dbh->prepare("SELECT pos.* FROM contenttranspos pos, contenttrans ctt $where");
  my $rc = $sth->execute();
  my $cpos = $sth->fetchall_hashref("c_id");
  my $rows = $sth->rows;
  return ($cpos,$rows);
 }else{
  my $cpos = { c_id => 0 };
  my $rows = 0;
  return ($cpos,$rows);
 }
}

#Collect table ...post
sub collect_post(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $fetch = shift;
 my $count = shift || "";

 my $table;
 my $table_pos;
 my $ct_where = "1=1";
 my $cp_where = "1=1";
 my $ctcp_where = "1=1";
 my $poscid = "";

 if($fetch->{table} eq "content" && $fetch->{table_pos} eq "contentpos"){
   #*2
   $ctcp_where .= " and ct.c_id=cp.cc_id";
   $poscid = "cp.cc_id";
 }elsif($fetch->{table} eq "contentadr" && $fetch->{table_pos} eq "contentadrpos"){
   #*1
   $ctcp_where .= " and ct.c_id=cp.ca_id";
   $poscid = "cp.ca_id";
 }elsif(($fetch->{table} eq "contenttrans" && $fetch->{table_pos} eq "contenttranspos") || ($fetch->{table} eq "contenttver" && $fetch->{table_pos} eq "contenttverpos")){
   #*3
   $ctcp_where .= " and ct.c_id=cp.ct_id";
   $poscid = "cp.ct_id";
 }else{
   return;
 }

 foreach my $key (keys %$fetch){
  if($fetch->{$key}){
   $fetch->{$key} =~ s/^\s//g;
   $fetch->{$key} =~ s/\s$//g;
   my $op = "=";
   my $value = $fetch->{$key};
   ($op, $value) = split(/::/, $fetch->{$key}) if($fetch->{$key} =~ /::/);
   if($key =~ /^(ct_name|txt\d+)$/ && $value){
     if($op eq "IN"){
   	$cp_where .= " and cp.$key $op $value";
     }else{
       if($key eq "txt01" && $value =~ /NaN/){
   	$cp_where .= " and $value";
       }else{
   	$cp_where .= " and cp.$key $op '$value'";
       }
     }
   }elsif($key =~ /ct\.close_time|ct\.state|ct\.int04|ct\.int14/ && $value){#used to get open invoices
      if($key =~ /ct\.state/ && $value eq "null"){	
   	$ct_where .= " and (ct.int04 is null OR ct.int04=0 OR ct.int14 >= 1)";#all un-booked or opos
      }else{
   	$ct_where .= " and $key $op $value";
      }
   }elsif($key =~ /time/ && $value){
     if($value =~ /interval/){
   	$cp_where .= " and cp.$key $op $value";#format like (now() - integer '7 day')
     }elsif($key eq "time_range"){
   	$cp_where .= " and $value";#look at only_first_free
     }else{
   	$cp_where .= " and cp.$key $op '$value'";
     }
   }elsif($key =~ /^(c_id|ca_id|ct_id|owner|barcode|int\d+)$/ && $value){
      if($value eq "null"){
        $cp_where .= " and (cp.$key is null OR cp.$key = 0)";
      }else{
        $cp_where .= " and cp.$key $op $value";
      }
   }elsif($fetch->{catch} && $key eq "template_id" && $value){
   	$cp_where .= " and cp.$key $op $value";
	#}elsif(!$fetch->{catch} && $key =~ /main_id|template_id/ && $value){
	#$ct_where .= " and rel.$key $op $value";
   }
  }
 }

 my $sth = "";
 my $sql = "";
 my $limit = "";
 $limit = "LIMIT $count" if(looks_like_number($count));
 if($fetch->{catch} && $fetch->{catch} eq "content_contentpos"){
   $sql = "SELECT cp.* from $fetch->{table_pos} cp, $fetch->{table} ct where $ctcp_where and $cp_where and $ct_where order by cp.mtime DESC $limit";
   $sth = $dbh->prepare($sql);
 }else{
   #rental pos with capture booking ct.state
   $sql = "SELECT cp.*, ct.state FROM $fetch->{table_pos} cp, $fetch->{table} ct WHERE $cp_where and cp.ct_id=ct.c_id and $ct_where order by cp.mtime ASC";#mtime aufsteigend get last (newest) entry
   $sth = $dbh->prepare($sql);
 }
 $bw->log("DBtank collect_post ",$sql,"") if($debug); 
 my $rc = $sth->execute();

 my $record = { c_id => 0 };
 if($fetch->{fetch} eq "all" && $fetch->{keyfield}){
   $record = $sth->fetchall_hashref($fetch->{keyfield});
 }elsif($fetch->{fetch} eq "one"){
   $record = $sth->fetchrow_hashref();
 }
 return $record;
}

#fetch CMS
#coalesce works only on null values
#It returns the first argument that is not null, from left to right
sub fetch_cms {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $fetch = shift || {};

 my $langfield = "txt02";#default to en
 my $lang = "";
 $lang = lc($fetch->{lang}) if($fetch->{lang});
 $langfield = "txt01" if($lang eq "de");
 $langfield = "txt02" if($lang eq "en");
 $langfield = "txt03" if($lang eq "fr");
 $langfield = "txt04" if($lang eq "es");

 my $wand = "";
 $wand = "and ct_name like '$fetch->{ct_name}%'" if($fetch->{ct_name});
 my $sql = "SELECT ct_name, coalesce($langfield, txt02, txt01) AS txt FROM contentuser, relation where template_id=194 and c_id=content_id $wand";
 my $sth = $dbh->prepare($sql);
 my $rc = $sth->execute();

 my $record = $sth->fetchall_hashref('ct_name');
 return $record;
}#end fetch_cms

#fetch all|one content + relation + nodes
sub fetch_record(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $fetch = shift;
 my $fetch_sql = shift || "";

 my $where = "where ct.c_id=rel.content_id and nd.main_id=rel.main_id";
 $where .= "$fetch_sql" if($fetch_sql);#enhancement to get bike_group OR 
 my $order = "";
 $order = "order by ct.barcode DESC" if($fetch->{table} eq "content");
 
 foreach my $key (keys %$fetch){
  if($fetch->{$key}){
   $fetch->{$key} =~ s/^\s//g;
   $fetch->{$key} =~ s/\s$//g;
   my $op = "=";
   my $value = $fetch->{$key};
   ($op, $value) = split(/::/, $fetch->{$key}) if($fetch->{$key} =~ /::/);
   #$value = $q->escapeHTML($value);#In DB context will always done by API
   #can also be "rel.main_id IN (300005,300024)"
   $where .= " and rel.$key $op $value" if($key =~ /^(parent_id|main_id|template_id|rel_id)$/ && $value);
   if($key =~ /^(ct_name$|txt\d+|uri\d+|state)$/ && $value){
     if($key eq "state" && $value eq "payment_fault"){
	$where .= " and (ct.int14 >= 1 OR ct.int14 = 7)";#OPOS or Zahlungsausfall
     }elsif($value =~ /length/){
	$where .= " and $value";
     }elsif($value eq "null"){
        $where .= " and (ct.$key is null OR ct.$key = '')";
     }else{
     	$where .= " and ct.$key $op '$value'";
     }
   }
   if($key =~ /^(c_id|barcode|int\d+|owner)$/){
    if(looks_like_number($value) || $value eq "null"){
     if($value eq "null"){
        $where .= " and (ct.$key is null OR ct.$key = 0)";
     }else{
       	$where .= " and ct.$key $op $value";
     }
    }elsif($op eq "IN"){
       	$where .= " and ct.$key $op $value";
    }
   }
   if($key =~ /type_id|archive/){
    if(looks_like_number($value) || $value eq "null"){
       	$where .= " and nd.$key $op $value";
    }
   }

   if($key =~ /close_time$/ && $value){
   	$where .= " and ct.$key $op $value";
   }elsif($key =~ /time$/ && $value){
     if($value =~ /interval/){
   	$where .= " and ct.$key $op $value";
     }else{
   	$where .= " and ct.$key $op '$value'";
     }
   }
  }
 }

 #ct.* because of nd.txt01 and ct.txt01 .
 #TODO drop "lang" then set nd.* should be possible
 my $sql = "SELECT ct.*,rel.*,nd.node_name,nd.parent_id,nd.type_id,nd.energy_id,nd.archive FROM $fetch->{table} ct, relation rel, nodes nd $where $order";
 #$bw->log("DBtank fetch_record : ",$sql,"") if($debug);
 my $sth = $dbh->prepare($sql);
 my $rc = $sth->execute();

 my $record = { c_id => 0 };
 if($fetch->{fetch} eq "all" && $fetch->{keyfield}){
   $record = $sth->fetchall_hashref($fetch->{keyfield});
 }elsif($fetch->{fetch} eq "one"){
   $record = $sth->fetchrow_hashref();
 }
 return $record;
}#end fetch_record

#fetch just in one table --> without relation ...
sub fetch_tablerecord(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my ($fetch) = @_;
 my $where = "where 1=1";
 my $source = $dbh->get_info( $GetInfoType{SQL_DATABASE_NAME} );

 foreach my $key (keys %$fetch){
  if($fetch->{$key}){
   $fetch->{$key} =~ s/^\s//g;
   $fetch->{$key} =~ s/\s$//g;
   my $op = "=";
   my $value = $fetch->{$key};
   ($op, $value) = split(/::/, $fetch->{$key}) if($fetch->{$key} =~ /::/);
   #print "$key: $fetch->{$key}|$op, $value\n";
   #$value = $q->escapeHTML($value);#In DB context will always done by API

   if($key =~ /ct_name/ && $value =~ /CAST/){#CAST(c_id AS text)
   	$where .= " and $key $op $value";
   }elsif($key =~ /^(ct_name|txt\d+|state)$/ && $value){
     if($value =~ /length\($key\)/){
        $where .= " and $value";
     }elsif($value eq "null"){
        $where .= " and $key $op $value";
     }elsif($op eq "IN"){
        $where .= " and $key $op $value";
     }else{
   	$where .= " and $key $op '$value'";
     }
   }elsif($key =~ /_itime$/ && $value){
   	$where .= " and itime $op '$value'";
   }elsif($key =~ /start_mtime|end_mtime/ && $value){
	$key =~ s/start_mtime/mtime/;
	$key =~ s/end_mtime/mtime/;
   	$where .= " and $key $op '$value'";
   }elsif($key =~ /time$/ && $value && $value =~ /interval/){#<= (now() - interval '15 minutes')
   	$where .= " and $key $op $value";
   }elsif($key =~ /time$|time\d+/ && $value){
   	$where .= " and $key $op '$value'";
   }elsif($key eq "time_range"){#used for freed_time on request
   	$where .= " and $value";
   }elsif($key =~ /^(c_id|u_id|cc_id|ct_id|ca_id|barcode|int\d+|owner|template_id)$/ && (looks_like_number($value) || $value eq "null")){
     if($value eq "null"){
   	$where .= " and ($key is null OR $key = 0)";
     }elsif($value eq "nullOR1"){
   	$where .= " and ($key is null OR $key = 1)";
     }else{
   	$where .= " and $key $op $value";
     }
   }elsif($key =~ /int\d+/ && $op eq "IN"){
        $where .= " and $key $op $value";
   }
  }
 }

 #prio data with newest end_time
 if($fetch->{table} eq "contenttranspos"){
   $where .= " order by end_time DESC";
 }elsif($fetch->{order}){
   $where .= " order by $fetch->{order} DESC";
 }

 my $sql = "SELECT * FROM $fetch->{table} $where";
 my $sth = $dbh->prepare($sql);
 my $rc = $sth->execute();

 #debug $fetch->{table} eq "contenttranspos" on Failure 758
 #$bw->log("DBtank fetch_tablerecord source-dbname $source:",$sql,"") if($debug && $fetch->{table} eq "contenttranspos");

 my $record = { c_id => 0 };
 if($fetch->{fetch} eq "all" && $fetch->{keyfield}){
   $record = $sth->fetchall_hashref($fetch->{keyfield});
 }elsif($fetch->{fetch} eq "one"){
   $record = $sth->fetchrow_hashref();
 }
 return $record;
}#end fetch_tablerecord

#update sql
sub update_sql(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $update_sql = shift;
 my $rows = 0;

  my $sql = "$update_sql";

  my $sth = $dbh->prepare($sql);
  $rows = $sth->execute();

 $bw->log("DBtank update_sql: $rows",$sql,"") if($debug);

 return $rows;

}

#update one value
sub update_one(){
 my $self = shift;
 my $dbh = shift || $dbh_intern; 
 my $update = shift;
 my $one_in = shift || "";
 my $c_id = shift || "";

 my $rows = 0;
 my $where = "";

  if($update->{table} =~ /content/){
   if($c_id){
    $where = "where c_id = $c_id";
   }elsif($update->{c_id}){
    $where = "where c_id = $update->{c_id}";
   }elsif($update->{barcode}){
    $where = "where barcode = $update->{barcode}";
   }
  }

  if($update->{table} eq "users" && $update->{u_id}){
    $where = "where u_id = $update->{u_id}";
  }
  if($update->{table} eq "nodes" && $update->{main_id}){
    $where = "where main_id = $update->{main_id}";
  }
  if($update->{table} eq "relation" && $update->{main_id}){
    $where = "where main_id = $update->{main_id} and content_id=0";
  }
  if($update->{table} eq "relation" && $update->{rel_id}){
    $where = "where rel_id = $update->{rel_id}";
  }
  if($update->{table} eq "template" && $update->{tpl_id}){
    $where = "where tpl_id = $update->{tpl_id}";
  }


  my $one = $one_in;
  if($update->{table} =~ /^users|relation|node|template/){
    $one .= ",change='now()'" if($update->{change} ne "no_time");
  }else{
    $one .= ",mtime='now()'" if($update->{mtime} ne "no_time");
  }
  $one .= ",owner=$update->{owner}" if($update->{owner});

  #only update if input
  if($where && $one_in){
    my $sql = "UPDATE $update->{table} set $one $where";
    my $sth = $dbh->prepare($sql);
    $rows = $sth->execute();
    $bw->log("DBtank update_one : $rows",$sql,"") if($debug);
  }
  return $rows;
}


#update all
sub update_record(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $update = shift;
 my $record = shift;
 my $where = "";
 my $set = "";
 my $rows = 0;

 #print Dumper($update);
 if(looks_like_number($record->{c_id}) || (looks_like_number($record->{barcode}) && $record->{barcode} > 0)){ 
  if($record->{c_id}){
    $where = "where c_id = $record->{c_id}";
  }else{
    $where = "where barcode = $record->{barcode}";
  }
  foreach my $key (keys %$update){
   $update->{$key} =~ s/^\s//g if($update->{$key});
   $update->{$key} =~ s/\s$//g if($update->{$key});
   my $value = $update->{$key} || "";
   $value = "$update->{$key}" if(looks_like_number($update->{$key}));
   if($key =~ /^(ct_name$|txt\d+|state|start_time|end_time|byte)/){
      if($value && $value eq "null"){
   	$set .= " $key=$value,";
      }else{
   	$set .= " $key='$value',";
      }
   }
   if($key =~ /^(barcode|int\d+|time\d+|owner|owner_end|start_at\d+|end_at\d+)$/){
     $value =~ s/,/\./ if($value);
     if($key =~ /time\d+|start_at\d+|end_at\d+/ && $value && $value =~ /\d+:\d+/){#azn time format
   	$set .= " $key='$value',";
     }elsif(looks_like_number($value) || ($value && $value eq "null")){
       	$set .= " $key=$value,";
     }elsif($key =~ /int\d+/ && !$value){
       	$set .= " $key=null,";#we need this for null values in operators loop
     }
   }
   if($key =~ /(mtime|atime|pay_time|invoice_time|warn_time)$/){
     if($value && $value =~ /^\d{4}-\d{2}-\d{2}\s\d{2}:\d{2}|^\d{2}\.\d{2}\.\d{4}$/){
     	$set .= " $key='$value',";
     }elsif($key =~ /warn_time/ && $value eq "null"){
     	$set .= " $key=null,";
     }else{
     	$set .= " $key='now()',";
     }
   }
  }
 }
 if($set){
   $set =~ s/,$//;
   my $sql = "UPDATE $update->{table} set $set $where";
   my $sth = $dbh->prepare($sql);
   $rows = $sth->execute();
   $bw->log("DBtank update_record : $rows",$sql,"") if($debug);
 }
 return $rows;
}#update_record

#insert content
sub insert_users {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $u_id = shift;
 my $owner = shift;

 my $sql = "INSERT INTO users (u_id,itime,mtime,owner) VALUES ('$u_id','now()','now()','$owner')";
 my $sth = $dbh->prepare($sql);
 my $rows = $sth->execute();
 $bw->log("DBtank INSERT DMS users $rows",$sql,"") if($debug);
 return $u_id;
}

sub select_users(){
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $u_id = shift || 0;
  my $sqlcon = shift || "";#used with "and int09=1"

  my $sql = "SELECT * FROM users WHERE u_id=$u_id $sqlcon";
  my $sth = $dbh->prepare($sql);
  my $rc = $sth->execute();
  my $users = $sth->fetchrow_hashref();
 $bw->log("DBtank SELECT DMS users u_id: $users->{u_id}",$sql,"") if($debug);
  return $users;
}

#insert_content with all
sub insert_contenthash(){
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $table = shift;
  my $sethash = shift;
  my ($keys,$values);
  if(ref($sethash) eq "HASH"){
    foreach my $key (sort (keys(%$sethash))){
        $keys .= $key . ",";
        $values .= "\'$sethash->{$key}\'" . ",";
    }
    $keys =~ s/,$//;
    $values =~ s/,$//;
  }
  #print "$keys --> $values\n";
  my $sth = $dbh->prepare("INSERT INTO $table ($keys) VALUES ($values)");
  my $rows = $sth->execute();
  return $rows;
}

#insert content
sub insert_contentoid {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $insert = shift;
 my $reset_keys = shift || "";

 if($insert->{table} eq "contentadr" && $reset_keys eq "reset_adropkeys"){
                delete $insert->{txt17};#operators
                delete $insert->{txt30};#tarifs
                delete $insert->{txt15};#Bonusnr
                delete $insert->{int05};#Web-Login
                delete $insert->{int07};#Rabatt
                delete $insert->{int09};#Service App staff
                delete $insert->{int16};#payone-cron-interval
                delete $insert->{int19};#Ilockit Admin
		#delete $insert->{int12};#Vde (remove delete for global setting)
                delete $insert->{txt29};#Sonstiges
 }

 my $columns = "";
 my $values = "";

 foreach my $key (keys(%$insert)){
  $insert->{$key} =~ s/^\s//g if($insert->{$key});
  $insert->{$key} =~ s/\s$//g if($insert->{$key});

  if($key =~ /^c_id|ct_name|barcode|txt|int|time|owner|byte/ && ($insert->{$key} || looks_like_number($insert->{$key}))){
   $columns .= "$key,";
   if($key =~ /_id|barcode|int|owner/ && !looks_like_number($insert->{$key})){
     $values .= "null,";
   }else{
     $values .= "'$insert->{$key}',";
   }
  }
  elsif($key =~ /template_id|cc_id|ct_id|ca_id/ && $insert->{table} =~ /contentpos|contentadrpos|contenttranspos|contenttheftpos/){
    $columns .= "$key,";
    if(!looks_like_number($insert->{$key})){
     $values .= "null,";
    }else{
     $values .= "'$insert->{$key}',";
    }
  }
 }

 $columns =~ s/,$//;
 $values =~ s/,$//;

 my $sql = "INSERT INTO $insert->{table} ($columns) VALUES ($values) RETURNING c_id";
 my $sth = $dbh->prepare($sql);
 my $rows = $sth->execute();

 my $last_id;
 $sth->bind_columns(\$last_id);
 my $c_id = $sth->fetchrow_array();
 $bw->log("insert_contentoid c_id: $c_id",$sql,"") if($debug);

 if($insert->{table} =~ /content$|contentadr$|contenttrans$|contenttver$|contentuser$/ && $insert->{main_id} && $insert->{template_id}){
   my $foreignkey = "";
   $foreignkey = "ca_id" if($insert->{table} eq "contentadr");
   $foreignkey = "cc_id" if($insert->{table} eq "content");
   $foreignkey = "ct_id" if($insert->{table} eq "contenttrans");
   $foreignkey = "cu_id" if($insert->{table} eq "contentuser");
   $foreignkey = "cv_id" if($insert->{table} eq "contenttver");
   my $sql_rel = "INSERT INTO relation (main_id,content_id,template_id,change,$foreignkey) VALUES('$insert->{main_id}','$c_id','$insert->{template_id}','now()','$c_id')";
   my $sth3 = $dbh->prepare($sql_rel);
   $sth3->execute();
   $bw->log("insert_contentoid relation c_id: $c_id",$sql_rel,"") if($debug);
 }

 return $c_id;
}#end insert_contentoid


#delete content
sub delete_content(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $table = shift;
 my $c_id = shift || 0;
 my $template_id = shift || "";

 my $rows = 0;
 if($c_id){
   my $where = "c_id=$c_id";
   $where = "template_id = $template_id" if($table eq "contentpos" && $template_id && $c_id eq "all");
   $where = "u_id=$c_id" if($table eq "users");
   my $sql = "DELETE FROM $table WHERE $where";
   my $sth = $dbh->prepare($sql);
   $rows = $sth->execute();
   $bw->log("delete_content : $rows",$sql,"") if($debug);
 }
 return $rows;
}

#collect content with contenttranspos 
sub collect_postime(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $table = shift;
 my $start_date_time = shift;
 my $end_date_time = shift;
 my $start_date2 = shift || "";
 my $end_date2 = shift || "";

 $start_date_time =~ s/,/./g;
 $end_date_time =~ s/,/./g;
 my $where = "where cp.cc_id=c.c_id";
 $where .= " and cp.start_time >= $start_date_time";
 $where .= " and cp.end_time <= $end_date_time";
 $where .= " and (cp.start_time >= '$start_date2' OR cp.end_time >= '$start_date2')" if($start_date2 && $end_date2);
 my $sth = $dbh->prepare("SELECT cp.* from content c, $table cp $where order by cp.end_time");
 my $rc = $sth->execute();
 my $ct = $sth->fetchall_hashref("cc_id");
 return $ct;
}


#collect contenttranspos with contenttrans
sub collect_transpos {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $search = shift;
 my $messaging = shift || 0;

 $search->{offset} = 0 if(!$search->{offset});

 my $where = "where cp.ct_id=ct.c_id";
 $where .= " and cp.int05 is null";#do not select sub workflow docs like storno
 foreach my $key (keys (%$search)){
   $search->{$key} =~ s/^\s//g;
   $search->{$key} =~ s/\s$//g;
   $where .= " and cp.c_id = $search->{$key}" if(($key eq "c_id" || $key eq "cttpos_id") && $search->{$key});
   $where .= " and cp.$key ilike '%$search->{$key}%'" if($key eq "txt08" && $search->{$key});
   $where .= " and cp.int04 = $search->{$key}" if($key eq "int04" && looks_like_number($search->{$key}));
   $where .= " and cp.int06 = $search->{$key}" if($key eq "int06" && looks_like_number($search->{$key}));
   $where .= " and cp.ct_name = '$search->{$key}'" if($key eq "cp_ct_name" && $search->{$key});
   $where .= " and ct.ct_name = '$search->{$key}'" if($key eq "ct_ct_name" && $search->{$key});
   $where .= " and ct.txt06 ilike '$search->{$key}%'" if($key eq "ct_txt06" && $search->{$key});
   $where .= " and cp.$key = '$search->{$key}'" if($key eq "ct_id" && looks_like_number($search->{$key}));
   $where .= " and cp.$key = $search->{$key}" if($key eq "int10" && looks_like_number($search->{$key}));
   $where .= " and cp.$key = $search->{$key}" if($key eq "int20" && looks_like_number($search->{$key}));
   $where .= " and cp.$key = $search->{$key}" if($key eq "barcode" && looks_like_number($search->{$key}));
   $where .= " and cp.$key = $search->{$key}" if($key eq "int12" && looks_like_number($search->{$key}));
   $where .= " and (cp.$key = $search->{$key} OR cp.owner_end = $search->{$key})" if($key eq "owner" && looks_like_number($search->{$key}));
   $where .= " and (cp.$key is $search->{$key} OR cp.$key = 0)" if($key eq "int34" && $search->{$key} eq "null");
   $where .= " and cp.$key ilike '%$search->{$key}%'" if($key eq "txt23" && $search->{$key});
   #debug,log,device,HW
   if($key eq "txt24" && $search->{$key}){
   	$where .= " and (cp.txt24 ilike '%$search->{txt24}%' OR cp.txt25 ilike '%$search->{txt24}%' OR cp.txt26 ilike '%$search->{txt24}%' OR cp.txt21 ilike '%$search->{txt24}%' OR cp.txt27 ilike '%$search->{txt24}%' OR cp.txt28 ilike '%$search->{txt24}%' OR cp.txt29 ilike '%$search->{txt24}%')";
   }
 }

 #adding itime to get also not rental dependent entries
 if($search->{start_date_time} && $search->{end_date_time}){
     $where .= " and ((cp.end_time >= '$search->{start_date_time}' and cp.end_time <= '$search->{end_date_time}' and cp.start_time <= '$search->{end_date_time}') OR (cp.itime >= '$search->{start_date_time}' and cp.itime <= '$search->{end_date_time}'))";
 }elsif($search->{start_time_interval}){
     $where .= " and cp.start_time <= $search->{start_time_interval}";
 }

 $where .= " ORDER BY cp.c_id DESC LIMIT $search->{limit} OFFSET $search->{offset}" if($search->{limit});
 my $sql = "SELECT cp.* from $search->{table} cp, contenttrans ct $where";
 #for system messaging
 if($messaging){
   $sql = "SELECT cp.*,ct.txt07 AS phone,ct.txt08 AS email,ct.txt11 AS lang from $search->{table} cp, contenttrans ct $where";
 }
 my $sth = $dbh->prepare($sql);
 my $rc = $sth->execute();
 my $ct = $sth->fetchall_hashref("c_id");
 #$bw->log("collect_transpos",$sql,"") if($debug);
 return $ct;
}

#collect contenttheftpos
sub collect_theftpos {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $search = shift;

 $search->{offset} = 0 if(!$search->{offset});

 my $where = "where 1=1";
 foreach my $key (keys (%$search)){
  if($search->{$key} =~ /::/ && $key =~ /int\d+/){
   $search->{$key} =~ s/\s//g;
   my $op = "=";
   my $value = $search->{$key};
   ($op, $value) = split(/::/, $search->{$key});
   $where .= " and $key $op $value";
  }elsif($key eq "speedORmeter"){
    $where .= " and $search->{$key}";
  }else{
   $search->{$key} =~ s/\s//g;
   $where .= " and cp.c_id = $search->{$key}" if($key eq "cttpos_id" && $search->{$key});
   $where .= " and cp.end_time >= '$search->{$key}'" if($key eq "start_date_time");
   $where .= " and cp.end_time <= '$search->{$key}'" if($key eq "end_date_time");
   $where .= " and cp.start_time <= '$search->{$key}'" if($key eq "end_date_time");
   $where .= " and cp.$key ilike '%$search->{$key}%'" if($key eq "txt06" && $search->{$key});
   $where .= " and cp.$key = $search->{$key}" if($key eq "int10" && looks_like_number($search->{$key}));#bike_state
   $where .= " and cp.$key = $search->{$key}" if($key eq "int20" && looks_like_number($search->{$key}));#lock_state
   $where .= " and cp.$key = $search->{$key}" if($key eq "barcode" && looks_like_number($search->{$key}));
   $where .= " and cp.$key = $search->{$key}" if($key eq "int12" && looks_like_number($search->{$key}));#flot_id
   $where .= " and cp.$key = $search->{$key}" if($key eq "int13" && looks_like_number($search->{$key}));#deviceId
   $where .= " and cp.$key = $search->{$key}" if($key eq "owner" && looks_like_number($search->{$key}));
  }
 }

 $where .= " ORDER BY cp.c_id DESC LIMIT $search->{limit} OFFSET $search->{offset}" if($search->{limit});
 my $sth = $dbh->prepare("SELECT cp.* from $search->{table} cp $where");
 my $rc = $sth->execute();
 my $ct = $sth->fetchall_hashref("c_id");
 $sth->finish;
 return $ct;
}

# new node
sub insert_nodeoid(){
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $insert = shift;
 my $node_name = $insert->{node_name};
 my $node_path = $insert->{node_name};
 ($node_name,$node_path) = split(/\|/,$node_name) if($node_name =~ /\|/);

  my $sth2 = $dbh->prepare("INSERT INTO nodes (main_id,parent_id,node_name,node_path,n_sort,owner,node_public) VALUES('$insert->{main_id}','$insert->{parent_id}','$node_name','$node_path','$insert->{n_sort}','$insert->{owner}','t')");
  my $rc = $sth2->execute();
  $sth2 = $dbh->prepare("INSERT INTO relation (main_id,template_id,content_id,change) VALUES('$insert->{main_id}','$insert->{template_id}','$insert->{content_id}','now()') RETURNING rel_id");
  $rc = $sth2->execute();

  my $last_id;
  $sth2->bind_columns(\$last_id);
  my $rel_id = $sth2->fetchrow_array();

  return $rel_id;
}

# Delete node and relation! (without content)
sub delete_noderel(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $main_id = shift;

 my $sth = $dbh->prepare("DELETE FROM relation WHERE main_id=$main_id and content_id=0");
 my $rc = $sth->execute();
 $sth = $dbh->prepare("DELETE FROM nodes WHERE main_id=$main_id");
 $rc = $sth->execute();
 $sth->finish();
 return $rc;
}

sub delete_relation(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $rel_id = shift;
 my $sth = $dbh->prepare("DELETE FROM relation WHERE rel_id=$rel_id");
 my $rc = $sth->execute();
 return $rc;
}

sub delete_template(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $tpl_id = shift;
 my $sth = $dbh->prepare("DELETE FROM template WHERE tpl_id=$tpl_id");
 my $rc = $sth->execute();
 return $rc;
}

# get next free node
sub get_freenode(){
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $prefix_id = shift;

  my $s_id = "$prefix_id";
  my $e_id = "$prefix_id";
  $s_id .= "00001";
  $e_id .= "99999";
  my $main_id = "";
  for (my $x_id=$s_id; $x_id < $e_id; $x_id++){
   my $sth1 = $dbh->prepare("SELECT main_id from nodes where main_id='$x_id'");
   my $rc1 = $sth1->execute();
   $main_id = $sth1->fetchrow_array();
   if(!$main_id){
    return $x_id;
   }
  }
}
#

# get next free template id
sub get_freetpl(){
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my ($s_id,$e_id) = @_;
  my $tpl_id = "";
  for (my $x_id=$s_id; $x_id < $e_id; $x_id++){
   my $sth1 = $dbh->prepare("SELECT tpl_id from template where tpl_id='$x_id'");
   my $rc1 = $sth1->execute();
   $tpl_id = $sth1->fetchrow_array();
   if(!$tpl_id){
    return $x_id;
   }
  }
}
#

sub rental_description_template {
 my $self = shift;
 my $varenv = shift;
 my $tpl_order = {
	 1 => {int35 => "$varenv->{cms}->{'tarif-rental-fee'}->{txt}"},#unit_price1
	 2 => {int36 => "$varenv->{cms}->{'tarif-rental-fee-from-second-day'}->{txt}"},#unit_price2
	 #3 => {int37 => "Grundgebühr"},#startup_price
	 4 => {int17 => "$varenv->{cms}->{'tarif-max-fee'}->{txt}"},#max_fee/day
	 5 => {time01 => "$varenv->{cms}->{'tarif-time-unit'}->{txt}"},#unit_time
	 6 => {time02 => "$varenv->{cms}->{'tarif-rental-free-time'}->{txt}"},#free_time
	 7 => {xduration => "$varenv->{cms}->{'tarif-current-rental-period'}->{txt}"},
	 8 => {xprice => "$varenv->{cms}->{'tarif-current-rental-cost'}->{txt}"},
 };
 return $tpl_order;
}

sub time_format {
 my $self = shift;
 my $varenv = shift;
 my $time = shift;
 my $time_unit = "";             
 my $day = "";
 if($time =~ /(\d+) day/){
   $day = $1;
   if($1 > 0 && $1 <= 1){
    $day .= " $varenv->{cms}->{'unit-day'}->{txt} ";
   }else{
    $day .= " $varenv->{cms}->{'unit-days'}->{txt} ";
   }
   $time_unit .= $day;
   $time =~ s/\d+ day //;
 }
 my ($std,$min,$sec) = split(/:/,$time);
 $std =~ s/^0//;
 $min =~ s/^0//;
 $time_unit .= "$std $varenv->{cms}->{'unit-hour'}->{txt} " if($std > 0);
 $time_unit .= "$min $varenv->{cms}->{'unit-minute'}->{txt} " if($min > 0);
 return $time_unit;
}

# copy template
sub copy_template(){
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $master_tpl_id = shift;
  my $new_tpl_id = shift;
  my $new_tpl_name = shift;
  my $owner = shift;

  my $columns = "tpl_name,tpl_order,ct_table,tpl_height,tpl_width,bg_color";
  my $sql = "INSERT INTO template ($columns) SELECT $columns from template where tpl_id=$master_tpl_id RETURNING tpl_id";
  my $sth = $dbh->prepare($sql);
  my $rows = $sth->execute();

  my $last_id;
  $sth->bind_columns(\$last_id);
  my $auto_tpl_id = $sth->fetchrow_array();
  $bw->log("DBtank copy_template : $rows",$sql,"") if($debug);

  my $sth2 = $dbh->prepare("UPDATE template set tpl_id=$new_tpl_id, tpl_name='$new_tpl_name', change='now()',owner=$owner where tpl_id=$auto_tpl_id");
  $rows = $sth2->execute();

  return $new_tpl_id;
}

#copy content
sub copy_content {
  my $self = shift;
  my $dbh = shift || $dbh_intern;
  my $table = shift;
  my $sourcec_id = shift;
  my $targetc_id = shift;
  my $new_ct_name = shift;
  my $owner = shift;
  my $rows = 0;

  my $cref = {
	table => $table,
	fetch => "one",
	c_id => $sourcec_id,
  };
  my $record = { c_id => 0 };
  $record = $self->fetch_record($dbh,$cref);

  if($record->{c_id} > 0){
   delete $record->{c_id};
   delete $record->{ct_name};
   delete $record->{itime};
   delete $record->{mtime};
   delete $record->{owner};

   my $update = {
       	%$record,
       	table => $table,
       	ct_name => $new_ct_name,
        mtime => 'now()',
	owner => $owner,
	c_id => $targetc_id,
   };
   $rows = $self->update_record($dbh,$update,$update);

   if($rows != 1){
       my $newc_id = $self->insert_contentoid($dbh,$update,"");
       $rows = 1 if($newc_id);
   }
  }
  return;
}

#content of txt08 changed to ctadr->{txt01} Name
sub insert_pos(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $ctt_id = shift;
 my $ct = shift || {};
 my $ct_station = shift || {};
 my $ctadr = shift || {};
 my $ct_tariff = shift || "";
 my $endRental = shift || "0000-00-00";
 my $ct_name = shift || "";
 my $status = shift || "";
 my $owner = shift || "";
 my $sig_book = shift || {};

 my $aa_station = $ct_station->{int42} || 0;

 $ct_name = $ct->{barcode} if(!$ct_name);#artikelnr or bikenr
 my $prefix = "";
 $ct_name =~ s/S[1-9]X/SX/;#sig
 $prefix = $1 if($ct_name =~ /^([A-Z]+)(\d+)$/i);

 my $user_name = $ctadr->{txt01};
 $user_name = $ctadr->{txt08} if(!$user_name || $user_name eq "no name");
 
 #int34 is service-staff (no sms message, no aa-station, no max 3 bikes)
 my $staff = 0;
 $staff = 1 if($ctadr->{int09});

 my $deviceId = $ct->{int13} || 0;
 my $bike_charge = $ct->{int19} || 0;
 my $trackon = $ct->{int25} || 0;
 my $bike_type_id = $ct->{type_id} || 0;
 my $from_main_id = $ct->{main_id} || 0;
 my $from_template_id = $ct->{template_id} || 0;
 my $start_station = $ct->{int04} || 0;
 my $end_station = "null";#2023-07-12 will be not set on request.
 my $fibumark = $ct->{int16} || 0;
 my $rabatt = 0;

 my $unit_price = $ct->{int02} || 0;#article price
 my $unit_price1 = 0;
 my $unit_price2 = 0;
 my $start_price = 0;
 my $daymax_price = 0;
 my $startup_price = 0;
 my $abo_price = 0;#not used
 my $unit_time = "00:00";
 my $free_time = "00:00";

 my $tariff_nr = 0;
 my $tariff_desc;
 my $sharing_type = 0;
 my $menge = 0;
 if(ref($ct_tariff) eq "HASH" && $ct_tariff->{barcode}){
   $rabatt = $ctadr->{int07} || 0;
   $unit_price = $ct_tariff->{int02} || 0;#old and should in future not used by rental
   $unit_price1 = $ct_tariff->{int35} || 0;
   $unit_price2 = $ct_tariff->{int36} || 0;
   $start_price = $ct_tariff->{int37} || 0;
   $abo_price = $ct_tariff->{int15} || 0;#not used
   $daymax_price = $ct_tariff->{int17} || 0;
   $tariff_nr = $ct_tariff->{barcode} || 0;
   $tariff_desc = $ct_tariff->{ct_name};
   $unit_time = $ct_tariff->{time01} || "00:00";
   $free_time = $ct_tariff->{time02} || "00:00";
   $sharing_type = $ct_tariff->{int18} || 0;
 }

 my $sth;
 #Verleihräder
 if($ct->{template_id} && $ct->{template_id} == 205){#Leihrad_list
   $sth = $dbh->prepare("INSERT INTO contenttranspos (ct_id,cc_id,ca_id,ct_name,barcode,txt01,txt08,txt02,txt09,txt12,itime,start_time,end_time,int01,int02,int03,int06,txt05,txt06,txt07,int10,int12,template_id,int13,owner,int07,txt04,int09,int17,int15,int11,int18,int19,txt17,txt18,int20,int25,int29,int34,txt22,txt11,int35,int36,int37,int42,time01,time02) VALUES ('$ctt_id','$ct->{c_id}','$ctadr->{c_id}','$ct_name','$ct->{barcode}','$ct->{txt01}','$user_name','$ct->{txt02}','$ctadr->{txt09}','$prefix',now(),now(),'$endRental','1','$unit_price','$menge','$start_station','$ct->{txt06}','$ct->{txt06}','$ct->{txt07}','$status','$from_main_id','$from_template_id','$deviceId','$owner','$rabatt','$tariff_desc','$tariff_nr','$daymax_price','$abo_price','$ct->{int11}','$sharing_type','$bike_charge','$ct->{txt17}','$ct->{txt18}','1','$trackon','$bike_type_id','$staff','$sig_book->{bikeId}','$sig_book->{rentalId}','$unit_price1','$unit_price2','$start_price','$aa_station','$unit_time','$free_time') RETURNING c_id");
 }else{
   $sth = $dbh->prepare("INSERT INTO contenttranspos (ct_id,cc_id,ca_id,ct_name,barcode,txt08,itime,int01,int02,int03,txt01,int10,int12,int16,template_id,owner) VALUES ('$ctt_id','$ct->{c_id}','$ctadr->{c_id}','$ct_name','$ct->{barcode}','$user_name',now(),'1','$unit_price','1','$ct->{txt01}','0','$from_main_id','$fibumark','$from_template_id','$owner') RETURNING c_id");
 }
  my $rows = $sth->execute();
  my $last_id;
  $sth->bind_columns(\$last_id);
  my $c_id = $sth->fetchrow_array();

  if($c_id && $status){
   #update Leihräder in Stammdaten
   my $set2 = "owner=$owner" if($owner);
   $set2 .= ",int10='$status'" if($status);
   $set2 .= ",mtime='now()'";
   my $sth2 = $dbh->prepare("UPDATE content SET $set2 where c_id='$ct->{c_id}'");
   my $rows2 = $sth2->execute();
  }

  return $c_id;
}

# insert contenttrans
sub insert_contenttrans(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $ctadr = shift;
 my $main_id = shift;
 my $tpl_id = shift;
 my $invoice_nr = shift || 0;
 my $owner = shift || 0;

  my $doc_name = "Rechnung";
  $doc_name = "Tagesabschluss" if($tpl_id == 209);
  $doc_name = "Prepaid Account" if($tpl_id == 219);
  $owner="0" if(!$owner);
  my $paymenttype = 0;
  $paymenttype = $ctadr->{int03} if($ctadr->{int03} =~ /^\d+$/);

  my $sth = $dbh->prepare("INSERT INTO contenttrans (ct_name,txt00,int10,int03,txt02,txt01,txt03,txt06,txt07,txt08,txt10,txt11,owner,itime) VALUES('$invoice_nr','$doc_name','$ctadr->{c_id}','$paymenttype','$ctadr->{txt02}','$ctadr->{txt01}','$ctadr->{txt03}','$ctadr->{txt06}','$ctadr->{txt07}','$ctadr->{txt08}','$ctadr->{txt10}','$ctadr->{txt11}','$owner','now()') RETURNING c_id");

  my $rows = $sth->execute();
  my $last_id;
  $sth->bind_columns(\$last_id);
  my $c_id = $sth->fetchrow_array();

  my $sth3 = $dbh->prepare("INSERT INTO relation (ct_id,content_id,template_id,main_id,change) VALUES('$c_id','$c_id','$tpl_id','$main_id','now()')");
  $sth3->execute();
  return $c_id;
}

#compute amount of wawi content
sub update_content4comp(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $c_id = shift || 0;
 my $op = shift;
 my $amount = shift;

 my $where = "c_id=$c_id";
 my $ct_set = "int03=(int03 $op $amount)";
 my $sth = $dbh->prepare("UPDATE content SET $ct_set where $where");
 my $rows = $sth->execute();
 return $rows;
}

#should be in DB
sub evaluationsfragen {
 my $self = shift;
 my $dbh = shift || $dbh_intern;

          my $user_miniquery = {
                        title => "Bitte unterstützen Sie unsere Begleitforschung",
                        subtitle => "Ihre drei Antworten werden anonym gespeichert.",
                        footer => "Herzlichen Dank und viel Spaß bei der nächsten Fahrt!",
                        questions => {
                          q1 => {
                                type => "check_one",
                                quest_text => "1. Frage: Was war der Hauptzweck dieser Ausleihe?",
                                query => {
                                        opt1 => "1. Einkauf",
                                        opt2 => "2. Kinderbeförderung",
                                        opt3 => "3. Freizeitaktivitäten, wie Ausflüge",
                                        opt4 => "4. Nutzung ohne Lastentransport",
                                        opt5 => "5. Gewerbliche Zwecke",
                                        opt6 => "6. Ausprobieren",
                                        opt7 => "7. Sonstiger Zweck"
                                        }
                                },
                          q2 => {
                                type => "check_one",
                                quest_text => "2. Frage: Welches Verkehrsmittel hätten Sie ohne Mietlastenrad für diese Fahrt genutzt?",
                                query => {
                                        opt1 => "1. Fahrrad",
                                        opt2 => "2. Auto",
                                        opt3 => "3. Zu Fuß",
                                        opt4 => "4. Bus/Bahn",
                                        opt5 => "5. Anderes Lastenrad",
                                        opt6 => "6. Motorad/-roller",
                                        opt7 => "7. Keins (ich hätte den Weg nicht gemacht)",
                                        opt7 => "8. Sonstige"
                                        }
                                },
                          q3 => {
                                type => "text",
                                quest_text => "3. Haben Sie Anmerkungen oder Anregungen?",
                                query => {
                                        opt1 => ""
                                        }
                                }
                        }
                };

 return $user_miniquery;
}

#search table content.
sub search_content {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $searchref = shift;
 my $node_meta = shift;
 my $users_dms = shift;
 my $main_ids = shift || 0;
 my $tplids = shift || 0;
 my $v_journal = shift || "";
 my $ck4ex = shift || "";

 my $table = $node_meta->{ct_table};
 $main_ids =~ s/,$//;
 $tplids =~ s/,$//;
 $ck4ex =~ s/\s/,/g;
 $ck4ex =~ s/,$//;

 my $owner = $users_dms->{u_id} || 0;
 my $sort_updown = $users_dms->{"sort_updown_$table"} || "down";
 my $scol = $searchref->{scol} || "mtime";
 my $offset = $searchref->{offset} || 0;
 my $limit = $searchref->{limit} || 200;
 my $export = $searchref->{export} || "";
 my $opos = $searchref->{opos} || 0;

   my $stamp_time = strftime("%d.%m.%Y %H:%M",localtime(time));
   my $debug=0;
   $debug=1;
   open(FILE,">>$varenv{logdir}/Liste3.log") if($debug);
   print FILE "*** $stamp_time search_content3 ***\n" if($debug);
   print FILE Dumper($searchref) if($debug);
   print FILE "$table,$node_meta->{node_name},$owner,$sort_updown,$main_ids,$tplids,$v_journal,$ck4ex\n" if($debug);
   close(FILE) if($debug);

 my $table_pos = $searchref->{table_pos} || "";
 my $txt_where;
 my $cptxt_where;
 my $cpgroup_where;

 my $valref = {};
 my $opref = {};
 foreach my $key (keys(%$searchref)){
  if($searchref->{$key} || $searchref->{$key} eq "0"){

   $valref->{$key} = $searchref->{$key};
   $opref->{$key} = "=";
   ($opref->{$key}, $valref->{$key}) = split(/::/, $searchref->{$key}) if($searchref->{$key} =~ /::/);
   if($key =~ /table_pos/){
        $table_pos = $valref->{$key};
   }
   if($key =~ /c_id|int\d+|barcode|time|sort|owner/){
     $searchref->{$key} =~ s/,/./g;
     if($searchref->{$key} =~ /(\<\=|\>\=|\<|\>|\=)/){
        $opref->{$key} = $1;
     }
     if($searchref->{$key} =~ /([-0-9\.]+)/){
        $valref->{$key} = $1;
     }
     if($searchref->{$key} =~ /null/){
        $opref->{$key} = "is";
     }
     chomp($valref->{$key});
   }
   $valref->{$key} = $q->escapeHTML($valref->{$key});

   if($table_pos =~ /contentpos|contentadrpos|users/){
     if($key =~ /ct_name/){
      $cptxt_where .= " and cp.$key ilike '$valref->{$key}'";
     }elsif($key =~ /txt/){
      $cptxt_where .= " and cp.$key ilike '%$valref->{$key}%'";
     }elsif($key =~ /barcode|int|owner/ && (looks_like_number($valref->{$key}) || $valref->{$key} eq "null")){
      $cptxt_where .= " and cp.$key $opref->{$key} $valref->{$key}";
     }
   }else{
     if($key eq "ct_name" && $valref->{$key} =~ /^\d+$/){
       $txt_where .= " and (ct.$key ilike '$valref->{$key}' OR ct.barcode $opref->{$key} $valref->{$key})";
     }elsif($key eq "ct_name"){
       $txt_where .= " and ct.$key ilike '$valref->{$key}%'";
     }elsif($key =~ /_id|barcode|int\d+|sort|owner/ && (looks_like_number($valref->{$key}) || $valref->{$key} =~ /null|0/)){
       $txt_where .= " and ct.$key $opref->{$key} $valref->{$key}";
     }elsif($key =~ /txt|uri/){
       $txt_where .= " and ct.$key ilike '%$valref->{$key}%'";
     }elsif($key eq "state"){
       #searchs also order_state 
       $txt_where .= " and (ct.state ilike '%$valref->{$key}%' OR ct.txt22 ilike '%$valref->{$key}%')";
     }elsif($key =~ /byte/){
       $txt_where .= " and ct.$key = '\\x$valref->{$key}'";
     }
   }

   if(!$v_journal){
     if($table_pos =~ /contentpos|contentadrpos|users/ && $key =~ /mtime/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
        $cptxt_where .= " and cp.mtime >= '$valref->{$key}'" if($key =~ /start/);
        $cptxt_where .= " and cp.mtime < '$valref->{$key}'" if($key =~ /end/);
     }
     elsif($table_pos =~ /contentpos|contentadrpos|users/ && $key eq "template_id_pos" && $valref->{$key}){
        $cptxt_where .= " and cp.template_id = $valref->{$key}";
     }
     elsif($key =~ /mtime/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
        $txt_where .= " and ct.mtime >= '$valref->{$key}'" if($key =~ /start/);
        $txt_where .= " and ct.mtime < '$valref->{$key}'" if($key =~ /end/);
     }

   }elsif($v_journal){
     if($key =~ /itime/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
        $txt_where .= " and ct.itime >= '$valref->{$key}'" if($key =~ /start/);
        $txt_where .= " and ct.itime < '$valref->{$key}'" if($key =~ /end/);
     }
     if($key =~ /start_mtime/ && $valref->{$key} =~ /^\d+$/){
       $txt_where .= " and ct.int11 = '$valref->{$key}'";#int11 = c_id-abschluss key
     }elsif($key =~ /start_mtime/ && $valref->{$key} =~ /date.*\d+\.\d+\.\d+/){
       $txt_where .= " and ct.mtime >= $valref->{$key}";
     }elsif($key =~ /start_mtime/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
       $txt_where .= " and ct.mtime >= '$valref->{$key}'";
     }
     if($key =~ /end_mtime/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
       $txt_where .= " and ct.mtime < '$valref->{$key}'";
     }
   }
   if($key =~ /start_pay_time/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
       $txt_where .= " and ct.pay_time >= '$valref->{$key}'";
   }
   if($key =~ /end_pay_time/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
       $txt_where .= " and ct.pay_time < '$valref->{$key}'";
   }
   if($key =~ /start_warn_time/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
       $txt_where .= " and ct.warn_time >= '$valref->{$key}'";
   }
   if($key =~ /end_warn_time/ && $valref->{$key} =~ /\d+\.\d+\.\d+/){
       $txt_where .= " and ct.warn_time < '$valref->{$key}'";
   }
  }
 }#
 if($v_journal =~ /Tagesbericht/){
   #$txt_where .= " and (ct.state ~ '[a-z]') and ct.int01 is not null and ct.close_time is null";
   $txt_where .= " and ct.int04 >= 1 and ct.int01 is not null and ct.close_time is null";
   $txt_where .= " and ct.int14 is $opos" if($opos eq "null");
 }

 $txt_where = " and ct.c_id IN ($ck4ex)" if($export eq "check4export" && $ck4ex);
 my $sth = "";
 my $updown = "ASC";
 $updown = "DESC" if($sort_updown eq "down");
 if($v_journal =~ /_parts/){#collects ct_ids
   my $cp_scol = "ct_name";
   $cp_scol = $1 if($scol =~ /(ct_name|barcode|mtime|txt0[1-9]|int0[1-9])/);
   $sth = $dbh->prepare("SELECT cp.* FROM contenttranspos cp WHERE cp.ct_id IN (SELECT ct.c_id FROM relation rel, contenttrans ct WHERE rel.content_id=ct.c_id and rel.main_id IN ($main_ids) and rel.template_id IN ($tplids) $txt_where) $cptxt_where ORDER BY cp.$cp_scol $updown");
 }elsif($valref->{long_rent} || $valref->{start_date_time} =~ /^\d+\.\d+\.\d+/ || $valref->{end_date_time} =~ /^\d+\.\d+\.\d+/ || $cpgroup_where){
   $sth = $dbh->prepare("SELECT * FROM relation rel, $table ct WHERE rel.content_id=ct.c_id and rel.main_id IN ($main_ids) and rel.template_id IN ($tplids) $txt_where and c_id IN (SELECT cp.ct_id from contenttranspos cp WHERE 1=1 $cptxt_where $cpgroup_where) ORDER BY $scol $updown LIMIT $limit OFFSET $offset");
 }elsif($table_pos && $table_pos eq "contentpos"){
   $sth = $dbh->prepare("SELECT cp.* FROM contentpos cp WHERE cp.cc_id IN (SELECT ct.c_id FROM relation rel, content ct WHERE rel.content_id=ct.c_id and rel.main_id IN ($main_ids) and rel.template_id IN ($tplids) $txt_where) $cptxt_where ORDER BY cp.$scol $updown LIMIT $limit OFFSET $offset");
 }elsif($table_pos && $table_pos eq "contentadrpos"){
  if($valref->{template_id_pos} eq 602){#because of user_minianswer have to be anonym
   $sth = $dbh->prepare("SELECT cp.* FROM contentadrpos cp WHERE 1=1 $cptxt_where ORDER BY cp.$scol $updown LIMIT $limit OFFSET $offset");
  }else{
   $sth = $dbh->prepare("SELECT ct.txt01,ct.txt08,cp.c_id,cp.mtime,cp.barcode,cp.int01,cp.txt02 FROM contentadr ct, contentadrpos cp WHERE ct.c_id=cp.ca_id $txt_where $cptxt_where ORDER BY cp.$scol $updown LIMIT $limit OFFSET $offset");
  }
 }elsif($table_pos && $table_pos eq "users"){
   $sth = $dbh->prepare("SELECT cp.* FROM contentadr ct, users cp WHERE ct.c_id=cp.u_id $txt_where $cptxt_where ORDER BY cp.$scol $updown LIMIT $limit OFFSET $offset");

 }else{
   $sth = $dbh->prepare("SELECT * FROM relation rel, $table ct WHERE rel.content_id=ct.c_id and rel.main_id IN ($main_ids) and rel.template_id IN ($tplids) $txt_where ORDER BY $scol $updown LIMIT $limit OFFSET $offset");
 }
 my $rc = $sth->execute();
 my $s_id = "c_id";
 $s_id = "u_id" if($table_pos && $table_pos eq "users");
 my $search = $sth->fetchall_hashref("$s_id");

 return $search;
}

#search json for automcomplete
sub search_json(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $table = shift;
 my $search = shift || "";
 my $template_id = shift || "";
 my $c_id = shift || 0;
 my $catch_equal = shift || 0;

 my $sel = "1=2";
 my $sth = "";
 my $rows = 0;

 if($search =~ /^\d+$/ && $table eq "content"){
   if($catch_equal){
     $sel = "(ct_name ilike '$search' OR CAST(barcode AS text) like '$search') and c_id != $c_id";
   }else{
     $sel = "(ct_name ilike '$search%' OR CAST(barcode AS text) like '$search%') and c_id != $c_id";
   }
   $sth = $dbh->prepare("SELECT  ct.ct_name || ' , ' || ct.barcode || ' , ' || ct.txt01 AS value, ct.ct_name AS spart_ct_name, ct.c_id FROM $table ct, relation rel WHERE ct.c_id=rel.content_id and rel.template_id IN ($template_id) and $sel");
   my $rc = $sth->execute();
   $rows = $sth->rows;

 }elsif($search =~ /\w{3}/ && $table eq "contentadr"){
   my $sel = "txt01 ilike '%$search%'";
   $sth = $dbh->prepare("SELECT ct.txt01 || ', ' || ct.c_id AS value, ct.txt01 AS vorname_name, ct.c_id FROM $table ct, relation rel WHERE ct.c_id=rel.content_id and rel.template_id=$template_id and $sel");
   my $rc = $sth->execute();
   $rows = $sth->rows;
 }

 return ($rows,$sth);
}

#just counting
sub count_content(){
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $table = shift;
 my $main_ids = shift;
 my $tplids = shift;

 $main_ids =~ s/,$//;
 $tplids =~ s/,$//;
 my $where = "WHERE rel.content_id=ct.c_id and rel.main_id IN ($main_ids)";
 $where .= " and rel.template_id IN ($tplids)" if($tplids =~ /\d/);
 my $sth = $dbh->prepare("SELECT DISTINCT(ct.c_id) FROM relation rel, $table ct $where");
 my $rc = $sth->execute();
 my $rows = $sth->rows;
 return $rows;
}

#close transactions by close_trans alias Tagesabschluss
sub update_close_transactions {
 my $self = shift;
 my $dbh = shift || $dbh_intern;
 my $close_ref = shift;

 #close transactions int11 close_trans reference c_id
 my $sth = $dbh->prepare("UPDATE $close_ref->{table} SET close_time='now()',int11=$close_ref->{close_id} where c_id IN (SELECT ct.c_id from $close_ref->{table} ct, relation rel where ct.c_id=rel.content_id and ct.int04 >= 1 and ct.int01 is not null and rel.main_id IN ($close_ref->{source_main_id}) and ct.close_time is null and ct.int14 is null)");
 my $rows = $sth->execute();

 #move/set to journal
 $sth = $dbh->prepare("UPDATE relation SET main_id=$close_ref->{main_id}, template_id=$close_ref->{template_id} where template_id=$close_ref->{source_template_id} and content_id IN (SELECT ct.c_id from $close_ref->{table} ct, relation rel where ct.c_id=rel.content_id and ct.int04 >= 1 and ct.int01 is not null and rel.main_id IN ($close_ref->{source_main_id}) and ct.int14 is null)");
 $rows = $sth->execute();

 return $rows;
}

1;