Annotation of wpscripts/ztransfer/fetch.pm, Revision 1.1.1.1
1.1 yason 1: #!/usr/bin/perl
2: # $Id: fetch.pm,v 1.1.1.7 2006/12/06 14:45:25 init Exp $
3: package fetch;
4: use db;
5: use log; # bad! only for log::filelist()
6: use warnings;
7: my $EXPAND_SYMLINKS = 1;
8: my $QUERY_Z = "SELECT ID,Path,file_priority FROM upload_files WHERE Status=0 AND type_file=0";
9: my $QUERY_J = "SELECT ID,Path,file_priority FROM upload_files WHERE Status=0 AND type_file=1";
10: my $QUERY_P = "SELECT ID,Path,file_priority FROM upload_files WHERE Status=0 AND type_file=2";
11: my $QUERY_T = "SELECT ID,Path,file_priority FROM upload_files WHERE Status=0 AND type_file=3";
12:
13: my $sth;
14:
15: my @stack_ids; # stack for ID's
16: my @stack_paths;# stack for Path's
17: my $tos = 0; # top of stack
18:
19:
20: sub stack_push($$)
21: {
22: $stack_ids[$tos] = shift;
23: $stack_paths[$tos] = shift;
24: $tos++;
25: }
26:
27:
28: sub zayavki_list()
29: {
30: my @dbids;
31: my @dbpaths;
32: my @dbpri;
33: my $i = 0;
34:
35: $sth = $db::dbh->prepare($QUERY_Z);
36: $sth->execute( );
37: while( ($dbids[$i], $dbpaths[$i], $dbpri[$i]) = $sth->fetchrow_array( ) )
38: {
39: if($dbids[$i]) # element exists (THIS CODE SHOULD BE FIXED)
40: {
41: #convert samba-paths to local unix paths
42: $dbpaths[$i] = substr($dbpaths[$i], 23); # remove \\fileserver\wideprint\
43: $dbpaths[$i] =~ tr/\\/\//; # convert each \ to /
44: $dbpaths[$i] = '/WIDEPRINT/' . $dbpaths[$i];
45: $dbpaths[$i] = substr($dbpaths[$i], 0, ( index($dbpaths[$i], ' ', 0) ) );
46: #
47: # We must not save non-existent local file in array!
48: # Returning of array with bad element is deprecated,
49: # So this code too weak to work correctly.
50: #
51: if($EXPAND_SYMLINKS && -e $dbpaths[$i])
52: {
53: chomp( $_ = `dirname $dbpaths[$i] | xargs /usr/bin/readlink` );
54: chomp( $dbpaths[$i] = $_ . '/' . `basename $dbpaths[$i]` );
55:
56: # increment $i ONLY if local file exists, otherwise replace element in next iteration
57: $i++;
58: }
59: # if localfile does not exists, write result of next iteration on its place
60: }
61: else
62: {
63: next;
64: }
65: }
66:
67: # strip last row in arrays by decrementing $i counter
68: # SHOULD BE FIXED!
69: $i--;
70: $#dbids = $i;
71: $#dbpaths = $i;
72:
73: # reformat listing using file_priority database field
74: for($i = 0;$i < scalar(@dbids); $i++)
75: {
76: stack_push($dbids[$i], $dbpaths[$i]) if($dbpri[$i] == 0);
77: }
78: for($i = 0;$i < scalar(@dbids); $i++)
79: {
80: stack_push($dbids[$i], $dbpaths[$i]) if($dbpri[$i] == 1);
81: }
82: for($i = 0;$i < scalar(@dbids); $i++)
83: {
84: stack_push($dbids[$i], $dbpaths[$i]) if($dbpri[$i] == 2);
85: }
86: @dbids = @stack_ids;
87: @dbpaths = @stack_paths;
88:
89: # make current files list via log::filelist()
90: log::filelist(\@dbpaths);
91:
92: # we return the list of references to @dbids and @dbpaths
93: return( (\@dbids, \@dbpaths) );
94: }
95:
96:
97: sub jpegs_list()
98: {
99: my @dbids;
100: my @dbpaths;
101: my $i = 0;
102:
103: $sth = $db::dbh->prepare($QUERY_J);
104: $sth->execute( );
105: while(($dbids[$i], $dbpaths[$i]) = $sth->fetchrow_array( ) )
106: {
107: $dbpaths[$i] = substr($dbpaths[$i], 23);
108: $dbpaths[$i] =~ tr/\\/\//;
109: $dbpaths[$i] = '/WIDEPRINT/' . $dbpaths[$i];
110: $dbpaths[$i] = substr($dbpaths[$i], 0, ( index($dbpaths[$i], ' ', 0) ) );
111: if($EXPAND_SYMLINKS && -e $dbpaths[$i])
112: {
113: chomp( $_ = `dirname $dbpaths[$i] | xargs /usr/bin/readlink` );
114: chomp( $dbpaths[$i] = $_ . '/' . `basename $dbpaths[$i]` );
115: }
116: $i++;
117: }
118:
119: $i--;
120: $#dbids = $i;
121: $#dbpaths = $i;
122:
123: log::filelist(\@dbpaths);
124:
125: return( (\@dbids, \@dbpaths) );
126: }
127:
128:
129: sub probas_list()
130: {
131: my @dbids;
132: my @dbpaths;
133: my $i = 0;
134:
135: $sth = $db::dbh->prepare($QUERY_P);
136: $sth->execute( );
137: while(($dbids[$i], $dbpaths[$i]) = $sth->fetchrow_array( ) )
138: {
139: $dbpaths[$i] = substr($dbpaths[$i], 23);
140: $dbpaths[$i] =~ tr/\\/\//;
141: $dbpaths[$i] = '/WIDEPRINT/' . $dbpaths[$i];
142: $dbpaths[$i] = substr($dbpaths[$i], 0, ( index($dbpaths[$i], ' ', 0) ) );
143: if($EXPAND_SYMLINKS && -e $dbpaths[$i])
144: {
145: chomp( $_ = `dirname $dbpaths[$i] | xargs /usr/bin/readlink` );
146: chomp( $dbpaths[$i] = $_ . '/' . `basename $dbpaths[$i]` );
147: }
148: $i++;
149: }
150:
151: $i--;
152: $#dbids = $i;
153: $#dbpaths = $i;
154:
155: log::filelist(\@dbpaths);
156:
157:
158: return( (\@dbids, \@dbpaths) );
159: }
160:
161:
162: sub tpps_list()
163: {
164: my @dbids;
165: my @dbpaths;
166: my $i = 0;
167:
168: $sth = $db::dbh->prepare($QUERY_T);
169: $sth->execute( );
170: while(($dbids[$i], $dbpaths[$i]) = $sth->fetchrow_array( ) )
171: {
172: $dbpaths[$i] = substr($dbpaths[$i], 23);
173: $dbpaths[$i] =~ tr/\\/\//;
174: $dbpaths[$i] = '/WIDEPRINT/' . $dbpaths[$i];
175: $dbpaths[$i] = substr($dbpaths[$i], 0, ( index($dbpaths[$i], ' ', 0) ) );
176: if($EXPAND_SYMLINKS && -e $dbpaths[$i])
177: {
178: chomp( $_ = `dirname $dbpaths[$i] | xargs /usr/bin/readlink` );
179: chomp( $dbpaths[$i] = $_ . '/' . `basename $dbpaths[$i]` );
180: }
181: $i++;
182: }
183:
184: $i--;
185: $#dbids = $i;
186: $#dbpaths = $i;
187:
188: log::filelist(\@dbpaths);
189:
190: return( (\@dbids, \@dbpaths) );
191: }
192:
193:
194: return(1);
CVSweb
![[BACK]](/icons/back.gif){kind=icon}
Return to fetch.pm CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [local] / wpscripts / ztransfer