fix quotations, RT#21103
[freeside.git] / bin / cdr_upstream_rate.import
1 #!/usr/bin/perl -w
2 #
3 # Usage: bin/cdr_upstream_rate.import username ratenum filename 
4 #
5 # records will be imported into cdr_upstream_rate, rate_detail and rate_region
6
7 # Example: bin/cdr_upstream_rate.import ivan 1 ~ivan/convergent/sample_rate_table.csv
8 #
9 #   username: a freeside login (from /usr/local/etc/freeside/mapsecrets)
10 #   ratenum: rate plan (FS::rate) created with the web UI
11 #   filename: CSV file
12 #
13 #     the following fields are currently used:
14 #       - Class Code         => cdr_upstream_rate.rateid
15 #       - Description        => rate_region.regionname
16 #                               (rate_detail->dest_region)
17 #       - 1_rate             => ( * 60 / 1_rate_seconds ) => rate_detail.min_charge
18 #       - 1_rate_seconds     => (used above)
19 #       - 1_second_increment => rate_detail.sec_granularity
20 #
21 #     the following fields are not (yet) used:
22 #       - Flagfall           => what's this for?
23 #
24 #       - 1_cap_time         => freeside doesn't have voip time caps yet...
25 #       - 1_cap_cost         => freeside doesn't have voip cost caps yet...
26 #       - 1_repeat           => not sure what this is for, sample data is all 0
27 #
28 #       - 2_rate             => \
29 #       - 2_rate_seconds     =>  |
30 #       - 2_second_increment =>  | not sure what the second set of rate data
31 #       - 2_cap_time         =>  | is supposed to be for...
32 #       - 2_cap_cost         =>  |
33 #       - 2_repeat           => /
34 #
35 #       - Carrier            => probably not needed?
36 #       - Start Date         => not necessary?
37
38 use strict;
39 use vars qw( $DEBUG );
40 use Text::CSV_XS;
41 use FS::UID qw(dbh adminsuidsetup);
42 use FS::Record qw(qsearchs);
43 use FS::rate;
44 use FS::cdr_upstream_rate;
45 use FS::rate_detail;
46 use FS::rate_region;
47
48 $DEBUG = 1;
49
50 my $user = shift or die &usage;
51 adminsuidsetup $user;
52
53 my $ratenum = shift or die &usage;
54
55 my $rate = qsearchs( 'rate', { 'ratenum' => $ratenum } );
56 die "rate plan $ratenum not found in rate table\n"
57   unless $rate;
58
59 my $csv = new Text::CSV_XS;
60 my $hline = scalar(<>);
61 chomp($hline);
62 $csv->parse($hline) or die "can't parse header: $hline\n";
63 my @header = $csv->fields();
64
65 $FS::UID::AutoCommit = 0;
66
67 while (<>) {
68
69   chomp;
70   my $line = $_;
71
72 #  #$line =~ /^(\d+),"([^"]+)"$/ or do {
73 #  #}
74 #  $line =~ /^(\d+),"([^"]+)"/ or do {
75 #    warn "unparsable line: $line\n";
76 #    next;
77 #  };
78
79   $csv->parse($line) or die "can't parse line: $line\n";
80   my @line = $csv->fields();
81
82   my %hash = map { $_ => shift(@line) } @header;
83
84   warn join('', map { "$_ => $hash{$_}\n" } keys %hash )
85     if $DEBUG > 1;
86
87   my $rate_region = new FS::rate_region {
88     'regionname' => $hash{'Description'}
89   };
90
91   my $error = $rate_region->insert;
92   if ( $error ) {
93     dbh->rollback;
94     die "error inserting into rate_region: $error\n";
95   }
96   my $dest_regionnum = $rate_region->regionnum;
97   warn "rate_region $dest_regionnum inserted\n"
98     if $DEBUG;
99
100   my $rate_detail = new FS::rate_detail {
101     'ratenum'         => $ratenum,
102     'dest_regionnum'  => $dest_regionnum,
103     'min_included'    => 0,
104     #'min_charge',     => sprintf('%.5f', 60 * $hash{'1_rate'} / $hash{'1_rate_seconds'} ),
105     'min_charge',     => sprintf('%.5f', $hash{'1_rate'} /
106                                          ( $hash{'1_rate_seconds'} / 60 )
107                                 ),
108     'sec_granularity' => $hash{'1_second_increment'},
109   };
110   $error = $rate_detail->insert;
111   if ( $error ) {
112     dbh->rollback;
113     die "error inserting into rate_detail: $error\n";
114   }
115   my $ratedetailnum = $rate_detail->ratedetailnum;
116   warn "rate_detail $ratedetailnum inserted\n"
117     if $DEBUG;
118
119   my $cdr_upstream_rate = new FS::cdr_upstream_rate {
120     'upstream_rateid'  => $hash{'Class Code'},
121     'ratedetailnum'    => $rate_detail->ratedetailnum,
122   };
123   $error = $cdr_upstream_rate->insert;
124   if ( $error ) {
125     dbh->rollback;
126     die "error inserting into cdr_upstream_rate: $error\n";
127   }
128   warn "cdr_upstream_rate ". $cdr_upstream_rate->upstreamratenum. " inserted\n"
129     if $DEBUG;
130
131   dbh->commit or die "can't commit: ". dbh->errstr;
132
133   warn "\n" if $DEBUG;
134
135 }
136
137 dbh->commit or die "can't commit: ". dbh->errstr;
138
139 sub usage {
140   "Usage:\n\ncdr_upstream_rate.import username ratenum filename\n";
141 }
142