sharee.bike/copri4/main/src/Mod/APIsigclient.pm

467 lines
19 KiB
Perl
Raw Normal View History

2022-05-11 08:05:35 +02:00
package APIsigclient;
2022-03-26 10:19:13 +01:00
#
# SPDX-License-Identifier: AGPL-3.0-or-later
# Copyright (c) Rainer Gümpelein, TeilRad GmbH
#
2022-05-11 08:05:35 +02:00
#Client for sig
2022-03-26 10:19:13 +01:00
#
2022-03-31 07:28:37 +02:00
#380116b5-0522-43da-ab66-477744a731a3
#
2022-05-27 17:11:35 +02:00
#use lib qw(/var/www/copri-bike/shareeapp-sx/src);
2022-03-26 10:19:13 +01:00
use warnings;
use strict;
use POSIX;
use Exporter;
our @ISA = qw (Exporter);
2022-03-31 21:53:53 +02:00
#use POSIX;
2022-03-26 10:19:13 +01:00
use CGI;
use JSON;
use LWP::UserAgent;
use DateTime;
use Time::Piece;
use Scalar::Util qw(looks_like_number);
use Config::General;
use Lib::Config;
use Mod::DBtank;
use Mod::Basework;
2022-03-31 21:53:53 +02:00
use Mod::APIfunc;
2022-05-27 17:11:35 +02:00
use Mod::Shareework;
2022-03-26 10:19:13 +01:00
use Data::Dumper;
2022-03-31 21:53:53 +02:00
my $q = new CGI;
my $json = JSON->new->allow_nonref;
2022-03-26 10:19:13 +01:00
my $cf = new Config;
my $dbt = new DBtank;
2022-03-31 21:53:53 +02:00
my $apif = new APIfunc;
2022-05-27 17:11:35 +02:00
my $tk = new Shareework;
2022-03-26 10:19:13 +01:00
my $bw = new Basework;
sub new {
my $class = shift;
my $self = {};
bless($self,$class);
return $self;
}
2022-03-31 21:53:53 +02:00
my $now_dt = strftime "%Y-%m-%d %H:%M:%S", localtime;
my $api_file = "/var/www/copri4/shareeconf/apikeys.cfg";
my $aconf = Config::General->new($api_file);
my %apikeyconf = $aconf->getall;
2022-03-26 10:19:13 +01:00
2022-03-31 21:53:53 +02:00
my $ua = LWP::UserAgent->new;
2022-05-11 08:05:35 +02:00
$ua->agent("sharee sigclient");
2022-03-31 21:53:53 +02:00
my $size = $ua->max_size;
my $bytes = 100000;
$ua->max_size( $bytes );
$ua->default_header( 'x-api-key' => $apikeyconf{sigo}->{api_key} );
2022-03-26 10:19:13 +01:00
#will be called on bikes_available
2022-05-11 08:05:35 +02:00
sub sig_available {
2022-03-31 21:53:53 +02:00
my $self = shift;
my $q = shift;
my $varenv = shift || {};
2022-05-11 08:05:35 +02:00
my $ctadr = shift || {};
2022-03-26 10:19:13 +01:00
2022-03-31 21:53:53 +02:00
my $response_in = {};
my $dbh = "";
my $owner = 169;
2022-03-26 10:19:13 +01:00
2022-03-31 21:53:53 +02:00
my $authed = 0;
my $tariff_content = {};
2022-05-11 08:05:35 +02:00
$authed = 1 if(ref($ctadr) eq "HASH" && $ctadr->{c_id} && $ctadr->{c_id} > 0);
2022-05-27 17:11:35 +02:00
(my $bike_group,my $user_group,$tariff_content,my $user_tour) = $apif->fetch_tariff($varenv->{dbname},$ctadr,$q->param('authcookie'));
2022-03-26 10:19:13 +01:00
2022-04-07 21:07:59 +02:00
my $hotline_hash = {
table => "contentuser",
fetch => "one",
template_id => 197,
c_id => "1",
};
my $hotline_data = $dbt->fetch_record($dbh,$hotline_hash);
2022-05-04 17:50:14 +02:00
my $td_template = $dbt->rental_description_template();
2022-04-07 21:07:59 +02:00
2022-05-11 08:05:35 +02:00
open(FILE,">>$varenv->{logdir}/APIsigclient.log");
print FILE "\n*** $now_dt 'sig_available' \n";
2022-03-30 13:06:39 +02:00
2022-03-31 21:53:53 +02:00
#my $endpoint = "https://sigo.dev.sigo.green/api/v1/bikes";
my $endpoint = "$dbt->{operator}->{$varenv->{dbname}}->{endpoint}/bikes";
2022-04-04 14:57:43 +02:00
my $response_out = {};
my $return2copri = {};
2022-03-31 07:28:37 +02:00
my $rest_json = "";
2022-05-11 08:05:35 +02:00
(my $ret_json, my $ret_status) = $self->get_sig("$endpoint",$rest_json);
2022-03-31 07:28:37 +02:00
eval {
$response_in = decode_json($ret_json);
$now_dt = strftime "%Y-%m-%d %H:%M:%S", localtime;
2022-05-04 14:18:58 +02:00
print FILE "<--- $now_dt station_and_bikes response_in with status_line: $ret_status:\n";
2022-03-31 21:53:53 +02:00
#print FILE Dumper($response_in) . "\n";
2022-03-31 07:28:37 +02:00
if(ref($response_in) eq "HASH"){
2022-03-31 21:53:53 +02:00
foreach my $resp (@{ $response_in->{items} }) {
2022-04-02 20:28:45 +02:00
print FILE "response_in loop\n" . Dumper($resp) . "\n";
2022-03-31 21:53:53 +02:00
if(ref($resp->{site}) eq "HASH" && $dbt->{operator}->{$varenv->{dbname}}->{operatorApp} && $q->param('request') eq "stations_available"){
2022-03-31 21:53:53 +02:00
#station (mainly using sigojson site object)
my $station = "SX$resp->{site}->{id}";
2022-05-27 17:11:35 +02:00
if($station && looks_like_number($resp->{site}->{id})){
2022-03-31 21:53:53 +02:00
print FILE "Station: $station\n";
2022-04-04 14:57:43 +02:00
$response_out->{$station}->{station} = "$station";
$response_out->{$station}->{authed} = "$authed";
$response_out->{$station}->{uri_operator} = "$dbt->{operator}->{$varenv->{dbname}}->{operatorApp}";
$response_out->{$station}->{description} = "$resp->{site}->{address}" || "";
$response_out->{$station}->{station_group} = ["SX300102"];#E-Lastenrad
$response_out->{$station}->{gps}->{latitude} = "$resp->{site}->{lat}" || "";
$response_out->{$station}->{gps}->{longitude} = "$resp->{site}->{lon}" || "";
$response_out->{$station}->{gps_radius} = "75";
2022-05-27 17:11:35 +02:00
#Other than Active status, should not be used to display information to a customer
2022-04-04 14:57:43 +02:00
$response_out->{$station}->{state} = "defect";
2022-05-27 17:11:35 +02:00
if(uc($resp->{site}->{status}) eq "ACTIVE"){
2022-04-04 14:57:43 +02:00
$response_out->{$station}->{state} = "available";
2022-05-27 17:11:35 +02:00
}elsif(uc($resp->{site}->{status}) eq "MAINTANANCE"){
2022-04-04 14:57:43 +02:00
$response_out->{$station}->{state} = "maintanance";
2022-03-31 21:53:53 +02:00
}
2022-05-27 17:11:35 +02:00
2022-04-07 21:07:59 +02:00
$response_out->{$station}->{operator_data} = {
"operator_name" => "",
"operator_hours" => "",
"operator_color" => "",
"operator_logo" => "",
"operator_phone" => "",
"operator_email" => "",
};
$response_out->{$station}->{operator_data}->{operator_name} = Encode::encode('utf-8', Encode::decode('iso-8859-1',$hotline_data->{txt01})) if($hotline_data->{txt01});
$response_out->{$station}->{operator_data}->{operator_hours} = Encode::encode('utf-8', Encode::decode('iso-8859-1',$hotline_data->{txt84})) if($hotline_data->{txt84});
$response_out->{$station}->{operator_data}->{operator_color} = $hotline_data->{txt85} if($hotline_data->{txt85});
$response_out->{$station}->{operator_data}->{operator_logo} = $hotline_data->{img01} if($hotline_data->{img01});
$response_out->{$station}->{operator_data}->{operator_phone} = $hotline_data->{txt07} if($hotline_data->{txt07});
$response_out->{$station}->{operator_data}->{operator_email} = $hotline_data->{txt08} if($hotline_data->{txt08});
2022-03-31 07:28:37 +02:00
2022-04-05 12:29:58 +02:00
#just like caching
$return2copri->{$station}->{barcode} = $1 if($response_out->{$station}->{station} =~ /(\d+)/);#new on station context
$return2copri->{$station}->{int04} = $1 if($response_out->{$station}->{station} =~ /(\d+)/);
$return2copri->{$station}->{int06} = $1 if($response_out->{$station}->{gps_radius} =~ /(\d+)/);
$return2copri->{$station}->{txt01} = "$response_out->{$station}->{description}";
$return2copri->{$station}->{txt06} = "$response_out->{$station}->{gps}->{latitude},$response_out->{$station}->{gps}->{longitude}";
$return2copri->{$station}->{txt24} = "300102";
while (my ($key, $value) = each %{ $dbt->{copri_conf}->{station_state} }) {
if($response_out->{$station}->{state} eq $value){
$return2copri->{$station}->{int10} = $key;
}
}
2022-05-27 17:11:35 +02:00
delete $response_out->{$station} if(uc($resp->{site}->{status}) ne "ACTIVE" || !$resp->{site}->{lat} || !$resp->{site}->{lon});
2022-03-31 07:28:37 +02:00
}
2022-03-31 21:53:53 +02:00
}#end stations_available
if(ref($resp->{site}) eq "HASH" && $dbt->{operator}->{$varenv->{dbname}}->{operatorApp} && $q->param('request') eq "bikes_available"){
2022-03-31 21:53:53 +02:00
#bike (mainly using sigojson state object)
#my $bike = "SX$resp->{mobile_bike_id}";
my $bike = $q->escapeHTML($resp->{license_plate}) || "";
my $bike_id = $bike;
$bike_id =~ s/S[1-9]X/SX/;
$bike_id = $1 if($bike_id =~ /(\d+)/);
if($bike && looks_like_number($bike_id) && looks_like_number($resp->{site}->{id})){
2022-03-31 21:53:53 +02:00
print FILE "Bike: $bike\n";
2022-04-04 14:57:43 +02:00
$response_out->{$bike}->{bike} = "$bike";
$response_out->{$bike}->{authed} = "$authed";
$response_out->{$bike}->{station} = "SX$resp->{site}->{id}" || "";
$response_out->{$bike}->{uri_operator} = "$dbt->{operator}->{$varenv->{dbname}}->{operatorApp}";
$response_out->{$bike}->{description} = "E-Lastenrad";
$response_out->{$bike}->{gps}->{latitude} = "$resp->{state}->{lat}" || "";
$response_out->{$bike}->{gps}->{longitude} = "$resp->{state}->{lon}" || "";
$response_out->{$bike}->{bike_charge} = "$resp->{energy_level}" || "0";
$response_out->{$bike}->{state} = "defect";
2022-05-27 17:11:35 +02:00
if(uc($resp->{reservation_state}) eq "RESERVED"){
$response_out->{$bike}->{state} = "requested";
2022-05-27 17:11:35 +02:00
}elsif(uc($resp->{reservation_state}) eq "ACTIVE-RENTAL"){
2022-04-04 14:57:43 +02:00
$response_out->{$bike}->{state} = "occupied";
}elsif(!$resp->{reservation_state}){
$response_out->{$bike}->{state} = "available";
2022-03-31 21:53:53 +02:00
}
2022-05-27 17:11:35 +02:00
#1. change can take up to 2 mins to reflect
#2. When a customer will start a reservation, it will always be unlock,
#Sigo software automatically handle this condition
2022-04-05 12:29:58 +02:00
$response_out->{$bike}->{lock_state} = "unlocked";
2022-05-27 17:11:35 +02:00
if($resp->{lock}->{status} eq "locked"){
2022-04-04 14:57:43 +02:00
$response_out->{$bike}->{lock_state} = "locked";
2022-03-31 21:53:53 +02:00
}
2022-04-04 14:57:43 +02:00
$response_out->{$bike}->{system} = "sigo";
$response_out->{$bike}->{bike_group} = ["SX300102"];#E-Lastenrad
$response_out->{$bike}->{unlock_allowed} = "1";
$response_out->{$bike}->{tariff_description} = {};
2022-05-04 17:50:14 +02:00
$response_out->{$bike}->{rental_description} = {};
2022-03-31 21:53:53 +02:00
if(ref($tariff_content) eq "HASH"){
foreach my $tid (sort { $tariff_content->{$a}->{barcode} <=> $tariff_content->{$b}->{barcode} } keys (%$tariff_content)){
#deprecated
2022-04-04 14:57:43 +02:00
$response_out->{$bike}->{tariff_description}->{name} = "$tariff_content->{$tid}->{ct_name}";
$response_out->{$bike}->{tariff_description}->{number} = "$tariff_content->{$tid}->{barcode}";
$response_out->{$bike}->{tariff_description}->{eur_per_hour} = "$tariff_content->{$tid}->{int02}" || "0";
$response_out->{$bike}->{tariff_description}->{max_eur_per_day} = "$tariff_content->{$tid}->{int17}" if($tariff_content->{$tid}->{int17});
$response_out->{$bike}->{tariff_description}->{free_hours} = "$tariff_content->{$tid}->{int16}" if($tariff_content->{$tid}->{int16});
$response_out->{$bike}->{tariff_description}->{abo_eur_per_month} = "$tariff_content->{$tid}->{int15}" if($tariff_content->{$tid}->{int15});
2022-05-11 08:05:35 +02:00
$response_out->{$bike}->{tariff_description}->{operator_agb} = "Mit der Mietrad Anmietung wird folgender Betreiber <a href='$dbt->{operator}->{$varenv->{dbname}}->{operatorApp}/site/agb.html' target='_blank'>AGB</a> zugestimmt (Demo)." if($ctadr->{c_id} && ($ctadr->{c_id} == 1842 || $ctadr->{c_id} == 5781 || $ctadr->{c_id} == 22262));
2022-05-04 17:50:14 +02:00
#new rental_description
$response_out->{$bike}->{rental_description}->{name} = "$tariff_content->{$tid}->{ct_name}";
$response_out->{$bike}->{rental_description}->{id} = "$tariff_content->{$tid}->{barcode}";
$response_out->{$bike}->{rental_description}->{rental_info}->{1} = ["Tracking","Ich stimme der Speicherung (Tracking) meiner Fahrstrecke zwecks wissenschaftlicher Auswertung und Berechnung der CO2-Einsparung zu!"];#TODO if($resp->{gps_tracker_id});
2022-05-11 08:05:35 +02:00
$response_out->{$bike}->{rental_description}->{rental_info}->{2} = ["AGB","Mit der Mietrad Anmietung wird folgender Betreiber <a href='$varenv->{wwwhost}/site/agb.html' target='_blank'>AGB</a> zugestimmt (als Demo sharee AGB)."] if($ctadr->{c_id} && ($ctadr->{c_id} == 1842 || $ctadr->{c_id} == 5781 || $ctadr->{c_id} == 22262));
my $i = 0;
2022-04-26 20:57:13 +02:00
foreach my $td (sort keys (%$td_template)){
my $time_unit = "";
2022-04-26 20:57:13 +02:00
if($td_template->{$td}->{int35} && $tariff_content->{$tid}->{int35} && $tariff_content->{$tid}->{int35} > 0){
$tariff_content->{$tid}->{int35} =~ s/\./,/;
$time_unit = $dbt->time_format($tariff_content->{$tid}->{time01});
2022-05-04 17:50:14 +02:00
$response_out->{$bike}->{rental_description}->{tarif_elements}->{$td} = ["$td_template->{$td}->{int35}","$tariff_content->{$tid}->{int35} € / $time_unit"];
2022-04-26 20:57:13 +02:00
}elsif($td_template->{$td}->{int36} && $tariff_content->{$tid}->{int36} && $tariff_content->{$tid}->{int36} > 0){
$tariff_content->{$tid}->{int36} =~ s/\./,/;
$time_unit = $dbt->time_format($tariff_content->{$tid}->{time01});
2022-05-04 17:50:14 +02:00
$response_out->{$bike}->{rental_description}->{tarif_elements}->{$td} = ["$td_template->{$td}->{int36}", "$tariff_content->{$tid}->{int36} € / $time_unit"];
2022-04-26 20:57:13 +02:00
}elsif($td_template->{$td}->{int17} && $tariff_content->{$tid}->{int17} && $tariff_content->{$tid}->{int17} > 0){
$tariff_content->{$tid}->{int17} =~ s/\./,/;
2022-05-04 17:50:14 +02:00
$response_out->{$bike}->{rental_description}->{tarif_elements}->{$td} = ["$td_template->{$td}->{int17}","$tariff_content->{$tid}->{int17} € / Tag"];
2022-04-26 20:57:13 +02:00
}elsif($td_template->{$td}->{time02} && $tariff_content->{$tid}->{time02} =~ /[1-9]/){
$time_unit = $dbt->time_format($tariff_content->{$tid}->{time02});
2022-05-04 17:50:14 +02:00
$response_out->{$bike}->{rental_description}->{tarif_elements}->{$td} = ["$td_template->{$td}->{time02}","$time_unit / Tag"];
}
2022-05-04 17:50:14 +02:00
}#end new rental_description
2022-03-31 21:53:53 +02:00
}
}
2022-04-05 12:29:58 +02:00
#just like caching
2022-06-08 20:18:11 +02:00
$return2copri->{$bike}->{int11} = 3;#system
$return2copri->{$bike}->{int25} = 1;#tracking on
$return2copri->{$bike}->{barcode} = $bike_id;
$return2copri->{$bike}->{txt22} = $resp->{id};#sig bikeId like 380116b5-0522-43da-ab66-477744a731a3
2022-04-05 12:29:58 +02:00
$return2copri->{$bike}->{int04} = $1 if($response_out->{$bike}->{station} =~ /(\d+)/);
$return2copri->{$bike}->{txt01} = "$response_out->{$bike}->{description}";
2022-05-04 17:50:14 +02:00
$return2copri->{$bike}->{int25} = "1" if($resp->{gps_tracker_id});
2022-04-05 12:29:58 +02:00
$return2copri->{$bike}->{txt06} = "$response_out->{$bike}->{gps}->{latitude},$response_out->{$bike}->{gps}->{longitude}";
$return2copri->{$bike}->{int19} = $1 if($response_out->{$bike}->{bike_charge} =~ /(\d+)/);
while (my ($key, $value) = each %{ $dbt->{copri_conf}->{bike_state} }) {
if($response_out->{$bike}->{state} eq $value){
$return2copri->{$bike}->{int10} = $key;
}
}
while (my ($key, $value) = each %{ $dbt->{copri_conf}->{lock_state} }) {
if($response_out->{$bike}->{lock_state} eq $value){
$return2copri->{$bike}->{int20} = $key;
}
}
2022-05-27 17:11:35 +02:00
#delete if $resp->{status} ne "ACTIVE" || reservation_state ne Reserved|Active-Rental
delete $response_out->{$bike} if(uc($resp->{status}) ne "ACTIVE" || $resp->{reservation_state});#don't view not active bikes
2022-03-31 21:53:53 +02:00
}
}#end bikes_available
2022-03-31 07:28:37 +02:00
}
2022-03-26 10:19:13 +01:00
}
2022-03-31 07:28:37 +02:00
};
if ($@){
2022-05-04 14:18:58 +02:00
print FILE "<--- failure get_bikes raw response_in with status_line: $ret_status\n" . Dumper($ret_json) . "\n";
#warn $@;
print FILE "warn:" . $@ . "\n";
2022-03-31 07:28:37 +02:00
}
2022-05-11 08:05:35 +02:00
print FILE "sig_available response_out from response_in\n" . Dumper($response_out) . "\n";
2022-03-31 07:28:37 +02:00
close(FILE);
2022-03-26 10:19:13 +01:00
2022-04-04 14:57:43 +02:00
return ($response_out,$return2copri);
2022-05-11 08:05:35 +02:00
}#end sig_available
2022-04-07 21:07:59 +02:00
#POST resverve, rental, ...
sub sig_booking {
2022-04-07 21:07:59 +02:00
my $self = shift;
my $varenv = shift || {};
2022-06-02 10:34:03 +02:00
my $todo = shift || "";
2022-05-11 08:05:35 +02:00
my $ctadr = shift || {};
2022-04-07 21:07:59 +02:00
my $ct_bike = shift || {};
my $ctpos = shift || {};
2022-04-07 21:07:59 +02:00
my $dbh = "";
my $owner = 169;
my $sig_book = {};
2022-04-07 21:07:59 +02:00
2022-05-11 08:05:35 +02:00
open(FILE,">>$varenv->{logdir}/APIsigclient.log");
print FILE "\n*** $now_dt 'sig_post $todo' \n";
2022-04-07 21:07:59 +02:00
my $endpoint = "$dbt->{operator}->{$varenv->{dbname}}->{endpoint}/";
my %json = ();
#reservation start
2022-04-07 21:07:59 +02:00
if($todo eq "reserve"){
$endpoint .= "bikes/reserve";
%json = (
bikeId => "$ct_bike->{txt22}",
2022-05-11 08:05:35 +02:00
email => "$ctadr->{txt08}"
2022-04-07 21:07:59 +02:00
);
}
2022-05-11 08:05:35 +02:00
#reservation end, this sig request is still not defined. maybe end by rentalId
2022-05-27 17:11:35 +02:00
#int10 state will be set on booking_request
elsif($todo eq "reserve_end"){
$endpoint .= "reserve/end";
%json = (
reservationId => "$ctpos->{txt10}",
2022-05-11 08:05:35 +02:00
email => "$ctadr->{txt08}"
);
}
#rental start
2022-05-27 17:11:35 +02:00
#int10 state will be set on main booking_update
2022-04-12 11:21:19 +02:00
elsif($todo eq "rental"){
2022-04-07 21:07:59 +02:00
$endpoint .= "rental";
2022-06-02 10:34:03 +02:00
#my $sig_bikeId = $ctpos->{txt22} || $ct_bike->{txt22};
my $sig_bikeId = "380116b5-0522-43da-ab66-477744a731a3";
%json = (
2022-05-11 08:05:35 +02:00
bikeId => "$sig_bikeId",
email => "$ctadr->{txt08}"
);
}
#rental end
elsif($todo eq "rental_end"){
$endpoint .= "rental/end";
2022-04-07 21:07:59 +02:00
%json = (
rentalId => "$ctpos->{txt11}",
2022-05-11 08:05:35 +02:00
email => "$ctadr->{txt08}"
2022-04-07 21:07:59 +02:00
);
#keep in mind, it will return no json, just text: "Rental Ended"
2022-04-07 21:07:59 +02:00
}
2022-06-02 10:34:03 +02:00
#rentals running
#TODO, execute it before user_bikes_occupied
elsif($todo eq "rentals_running"){
$endpoint .= "rentals/running";
%json = (
email => "$ctadr->{txt08}"
);
}
2022-04-12 11:21:19 +02:00
else{
print "Failure, request $todo not defined\n";
}
2022-04-07 21:07:59 +02:00
2022-04-12 11:21:19 +02:00
print FILE "---> DATA $endpoint:\n" . Dumper(\%json) . "\n";
2022-04-07 21:07:59 +02:00
2022-04-12 11:21:19 +02:00
if(ref(\%json) eq "HASH" && $json{email}){
my $rest_json = encode_json(\%json);
2022-05-11 08:05:35 +02:00
(my $ret_json, my $ret_status) = $self->post_sig($endpoint,$rest_json);
$now_dt = strftime "%Y-%m-%d %H:%M:%S", localtime;
2022-04-07 21:07:59 +02:00
eval {
$sig_book = decode_json($ret_json);
2022-05-11 08:05:35 +02:00
print FILE "<--- $now_dt sig_booking sig_post $todo response_in with status_line: $ret_status\n" . Dumper($sig_book);
#print $ret_json . "\n";
2022-04-07 21:07:59 +02:00
};
if ($@){
2022-05-11 08:05:35 +02:00
print FILE "<--- $now_dt failure sig_booking sig_post $todo raw response_in with status_line: $ret_status\n" . Dumper($ret_json) . "\n";
2022-04-07 21:07:59 +02:00
#warn $@;
print FILE "warn:" . $@ . "\n";
}
2022-06-02 10:34:03 +02:00
#save always API return state for documentation
$sig_book->{return_state} = "$now_dt $todo: $ret_status";
2022-04-12 11:21:19 +02:00
}
2022-04-07 21:07:59 +02:00
2022-05-04 14:18:58 +02:00
if(ref($sig_book) ne "HASH"){
$sig_book = {
2022-05-11 08:05:35 +02:00
bikeId => "",
2022-05-04 14:18:58 +02:00
rentalId => "",
reservationId => ""
};
2022-05-11 08:05:35 +02:00
print FILE "<--- $now_dt failure sig_booking sig_post $todo , reset sig_book hash to empty\n";
}
if($ctpos->{c_id}){
2022-05-27 17:11:35 +02:00
my $rows = 0;
2022-05-11 08:05:35 +02:00
my $update_pos = {
table => "contenttranspos",
mtime => "now()",
owner => "169",
};
2022-05-27 17:11:35 +02:00
#TODO try it with user_bikes_available
#on sig api states maybe not just in time available
#check and save sig bike states
#$q->param(-name=>'request',-value=>"bikes_available");
#(my $response->{bikes},my $return2copri) = $self->sig_available($q,$varenv,$ctadr);
#my $ctrows = 0;
#$ctrows = $tk->sigbike_cupdate($return2copri);
#print FILE "<--- ctrows:$ctrows, update content state with:" . Dumper($return2copri) . "\n";
#foreach my $sid (keys (%{$return2copri})){
# $update_pos->{int10} = "$return2copri->{$sid}->{int10}" if($return2copri->{$sid}->{int10});
# $update_pos->{int20} = "$return2copri->{$sid}->{int20}" if($return2copri->{$sid}->{int20});
#}
2022-05-11 08:05:35 +02:00
$update_pos->{txt10} = "$sig_book->{reservationId}" if($sig_book->{reservationId});
2022-06-02 10:34:03 +02:00
$update_pos->{txt11} = "$sig_book->{rentalId}" if($sig_book->{rentalId});
$update_pos->{txt25} = "$ctpos->{txt25}\n$sig_book->{return_state}";# if($sig_book->{return_state});
2022-05-11 08:05:35 +02:00
$rows = $dbt->update_record($dbh,$update_pos,$ctpos);
print FILE "<--- rows: $rows, update_pos: $ctpos->{c_id}, with:" . Dumper($update_pos) . "\n";
2022-05-04 14:18:58 +02:00
}
2022-04-07 21:07:59 +02:00
close(FILE);
return $sig_book;
2022-03-26 10:19:13 +01:00
}
2022-04-07 21:07:59 +02:00
2022-03-26 10:19:13 +01:00
#main GET
2022-05-11 08:05:35 +02:00
sub get_sig {
2022-04-07 21:07:59 +02:00
my $self = shift;
2022-03-26 10:19:13 +01:00
my $endpoint = shift || "";
my $rest_json = shift || "";
2022-05-11 08:05:35 +02:00
my $sig_request = "$endpoint";
2022-03-26 10:19:13 +01:00
2022-05-11 08:05:35 +02:00
print FILE "===> GET sig >> " . $sig_request . "\n" . $rest_json . "\n";
2022-03-26 10:19:13 +01:00
2022-05-11 08:05:35 +02:00
my $req = HTTP::Request->new(GET => "$sig_request");
2022-03-26 10:19:13 +01:00
$req->content_type('application/json');
$req->content($rest_json);
my $res = $ua->request($req);
if ($res->is_success) {
#print $res->content;
2022-05-04 14:18:58 +02:00
#print $res->status_line, "\n";
return ($res->content, $res->status_line);
2022-03-26 10:19:13 +01:00
}else {
2022-05-04 14:18:58 +02:00
#print $res->status_line, "\n";
return ("", $res->status_line);
2022-03-26 10:19:13 +01:00
}
}
2022-04-07 21:07:59 +02:00
#main POST
2022-05-11 08:05:35 +02:00
sub post_sig {
2022-04-07 21:07:59 +02:00
my $self = shift;
2022-03-26 10:19:13 +01:00
my $endpoint = shift || "";
my $rest_json = shift || "";
2022-05-11 08:05:35 +02:00
my $sig_request = "$endpoint";
2022-03-26 10:19:13 +01:00
2022-05-11 08:05:35 +02:00
print FILE "===> POST sig >> " . $sig_request . "\n" . $rest_json . "\n";
2022-03-26 10:19:13 +01:00
2022-05-11 08:05:35 +02:00
my $req = HTTP::Request->new(POST => "$sig_request");
2022-03-26 10:19:13 +01:00
$req->content_type('application/json');
$req->content($rest_json);
my $res = $ua->request($req);
if ($res->is_success) {
#print $res->content;
2022-05-04 14:18:58 +02:00
#print $res->status_line, "\n";
return ($res->content, $res->status_line);
2022-03-26 10:19:13 +01:00
}else {
2022-05-04 14:18:58 +02:00
#print $res->status_line, "\n";
return ("", $res->status_line);
2022-03-26 10:19:13 +01:00
}
}
1;