#!/usr/bin/perl

#use utf8;
use strict;
use JSON;
use CGI;
use Digest::SHA qw(
    sha1_base64
    sha1_hex
);

use Opals::Context;

use Opals::SolrIndex qw(
    slr_search
    slr_buildSearchQuery
    srl_buildQuery_datafield
);

use Opals::Report qw(
    rpt_getItemListByStatus
);
use Opals::Eq_SolrSearch;
use Opals::Equipment qw(
    
    eq_item_findByRId

);

use Opals::Tb_Search qw(

    search_rpt_getItemListByStatus

);


use Opals::Session qw(
    SessionHdl_viewMovingHolding
    SessionHdl_mhPrevNextRecord
    SessionHdl_moveHolding
    SessionHdl_setTarget
    SessionHdl_add
    SessionHdl_del
    SessionHdl_get
    SessionHdl_clearVar
    SessionHdl_exist_rid
    SessionHdl_exist_bc
    SessionHdl_count
    SessionHdl_getBriefRecList
    SessionHdl_getBrRecListByHolding
    SessionHdl_getSSID
);
my $FN_MAP={
    add=>\&add,
    del=>\&del,
    get=>\&get,
    clear=>\&clear,
    addAll=>{itemStatusRpt    =>\&addAll_itemStatusList,
             searchRs         =>\&addAll_searchRs,
             eq_searchRs      =>\&addAll_eq_searchRs,
             tb_itemStatusRpt =>\&addAll_tbItemStatusList,
             ge               =>\&addAll_ge
            },
    count=>\&count
};
my $dbh = Opals::Context->dbh();
END { $dbh->disconnect(); }
my $request=getRequest();
my $cgi    = CGI->new;
my $ssid   = SessionHdl_getSSID($cgi);
my $ssidCookie=CGI::Cookie->new(-name=>'globalSessionID',-value=>$ssid);

my $action=$request->{'action'};
my $selectSrc=$request->{'selectSrc'};
my $ret;
my $selItems;
if(defined $FN_MAP->{$action}){
    my $fn=undef;
    if($action eq 'addAll' && defined $FN_MAP->{$action}->{$selectSrc}){
        $fn =$FN_MAP->{$action}->{$selectSrc};
    }
    else{
        $fn = $FN_MAP->{$action};
    }

    if(defined $fn){
        $ret=&$fn();
        $ret=count()if($action ne 'count');
        $selItems=&$fn() if( $action eq 'get');;
    }
}
print "Set-Cookie: $ssidCookie\n";
print "Content-type: text/plain\n\n";

my $rs={status=>1,rs=>$ret,selItems=>$selItems};
print   to_json($rs);


#-------------------------------------------------------------------------------
sub add{
   foreach my $item(@{$request->{'itemList'}}){
       #if(!SessionHdl_exist_bc($dbh,$ssid, $request->{'varName'},$item->{'barcode'})){
            SessionHdl_add($dbh,$ssid, $request->{'varName'},$item->{'rid'},$item->{'barcode'},$item->{'note'});
       #}
   }
}
#-------------------------------------------------------------------------------
sub del{
   foreach my $item(@{$request->{'itemList'}}){
        SessionHdl_del($dbh,$ssid,$request->{'varName'},$item->{'rid'},$item->{'barcode'},$item->{'note'});
   }
   return 1;
   
}
#-------------------------------------------------------------------------------
sub get{
    return SessionHdl_get($dbh,$ssid,$request->{'varName'},$request->{'offset'},$request->{'count'});
}
#-------------------------------------------------------------------------------
sub count{
    my ($ridCount,$bcCount)= SessionHdl_count($dbh,$ssid,$request->{'varName'});
    return {ridCount=>$ridCount,bcCount=>$bcCount};
}
#-------------------------------------------------------------------------------
sub clear{
   SessionHdl_clearVar($dbh,$ssid,$request->{'varName'});
   return 1;
}
#-------------------------------------------------------------------------------

sub addAll_itemStatusList{ 

    my $from    =$request->{'from'};
    my $to      =$request->{'to'} ;
    my $status  =$request->{'status'};
    my $sort    =$request->{'sort'};
    my $sortDir =$request->{'sortDir'};
    my $incIllTmp=$request->{'incIllTmp'};

    my $filter    =$request->{'filter'}|| undef;
    my $varName= $request->{'varName'};


    my $rs =rpt_getItemListByStatus($dbh,$status,$from,$to,undef,undef,$sort,$sortDir,$incIllTmp,undef,undef,undef,$filter);
    if($rs->{'found'}>0){
        foreach my $item(@{$rs->{'itemList'}}){
            SessionHdl_add($dbh,$ssid,$varName,$item->{'rid'},$item->{'barcode'},$item->{'ondate'});

        }
    }

}
#-------------------------------------------------------------------------------
sub addAll_searchRs{

    my $lQuery=slr_buildSearchQuery($request->{'searchParam'});
    return _addAll_searchRs($lQuery);
}
#-------------------------------------------------------------------------------
sub addAll_ge{
    my $filter;
    my $from =$request->{'searchParam'}->{'dateImportFrom'};
    my $to   =$request->{'searchParam'}->{'dateImportTo'}; 
    if((defined $from && $from ne '' ) || (defined $to && $to ne '' ) ){
        $filter->{'dateImport'}={from=>$from,to=>$to};
    }
    if(defined $request->{'searchParam'}->{'recType'} && $request->{'searchParam'}->{'recType'} ne ''){
        $filter->{'recType'}=[$request->{'searchParam'}->{'recType'}];
    }
    my $lQuery=srl_buildQuery_datafield($request->{'searchParam'}->{'srchFields'},$filter);
    return _addAll_searchRs($lQuery);
}


#-------------------------------------------------------------------------------
sub _addAll_searchRs{
    my($lQuery) =@_;
    my $varName= $request->{'varName'};
    my $rs=undef;
    my ($offset,$size)=(0,100);
    if($lQuery ne ''){
        while(1){        
            $rs = slr_search({lQuery=>$lQuery,recFormat=>'detail',
                             offset=>$offset,size=>$size});  
           if($rs->{"hits"}>0){
               foreach my $rec (@{$rs->{'recordList'}}){
                   foreach my $h(@{$rec->{'itemList'}}){
                        SessionHdl_add($dbh,$ssid,$varName,$rec->{'rid'},$h->{'barcode'});
                   }
               }
               $offset +=$size;
               last if($offset>$rs->{"hits"});
           }
           else{ last;}
        
        }
        if($request->{'filterLoan'} ==1){
            $dbh->do("delete s from opl_sessionVar s inner join opl_loan l on l.barcode=s.barcode where l.dateReturn is null && s.var=? && s.ssid=?",undef,$varName,$ssid);
        }
    }
    return $rs;
}

#-------------------------------------------------------------------------------
sub addAll_tbItemStatusList{ 

    my $from    =$request->{'from'};
    my $to      =$request->{'to'} ;
    my $status  =$request->{'status'};
    my $sort    =$request->{'sort'};
    my $sortDir =$request->{'sortDir'};
    my $varName= $request->{'varName'};
    my $rs = search_rpt_getItemListByStatus ($dbh, 0, 10000,  $from,  $to, $sort ,$sortDir,$status);
    #my $rs =rpt_getItemListByStatus($dbh,$status,$from,$to,undef,undef,$sort,$sortDir,$incIllTmp);
    if($rs->{'found'}>0){
        foreach my $item(@{$rs->{'itemList'}}){
            SessionHdl_add($dbh,$ssid,$varName,$item->{'rid'},$item->{'barcode'},$item->{'ondate'});
        }
    }
}


sub addAll_eq_searchRs{
   my $eq_solr = Opals::Eq_SolrSearch->new(dbh=>$dbh);
   my ($offset,$size)=(0,10);
   my $varName = $request->{'varName'};
   my $rs=undef;
   my $lQuery = $eq_solr->eq_slr_buildSearchQuery($request->{'searchParam'});
   $lQuery .= "&fl=rid,eq_name,barcode";
   if($lQuery ne ''){
     while(1) {
        $request->{'searchParam'}->{'offset'} = $offset;
        $request->{'searchParam'}->{'pSize'} = $size;
        $lQuery = $eq_solr->eq_slr_buildSearchQuery($request->{'searchParam'});
        my $params={
            lQuery=>$lQuery,
            displayStyle=>$request->{'searchParam'}->{'displayStyle'},
        };
        $rs = $eq_solr->eq_slr_search($params);
        if ($rs->{'hits'}>0){
          foreach my $r (@{$rs->{'recordList'}}){
            if ($request->{'searchParam'}->{'displayStyle'} eq "record") {
                $r->{'itemList'} = eq_item_findByRId($dbh,$r->{'rid'});
                foreach my $h(@{$r->{'itemList'}}){
                    SessionHdl_add($dbh,$ssid, $varName,$r->{'rid'},$h->{'barcode'});
                }
            }else{
                SessionHdl_add($dbh,$ssid, $varName,$r->{'rid'},$r->{'barcode'})
            }
          }
          $offset +=$size;
          last if($offset>$rs->{"hits"});
        }
        else{last;}
     }
     if($request->{'filterLoan'} ==1){
        $dbh->do("delete s from opl_sessionVar s inner join eq_loan l on l.barcode=s.barcode where l.dateReturn is null && s.var=? && s.ssid=?",undef,$varName,$ssid);
        }
   } 
   return $rs;
}


#-------------------------------------------------------------------------------
sub getRequest{
  my $in={};
  if ($ENV{'REQUEST_METHOD'} eq "POST") {
        my $json ="";
        while (<STDIN>) {
            $json .= $_;
        }
        $in = decode_json($json);
   }
   return $in;
}
#------------------------------------------------------------------------------

#------------------------------------------------------------------------------