00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032 #include "asterisk.h"
00033
00034 ASTERISK_FILE_VERSION(__FILE__, "$Revision: 348362 $")
00035
00036 #include "asterisk/module.h"
00037 #include "asterisk/channel.h"
00038 #include "asterisk/pbx.h"
00039 #include "asterisk/utils.h"
00040 #include "asterisk/app.h"
00041 #include "asterisk/cdr.h"
00042
00043
00044
00045
00046
00047
00048
00049
00050
00051
00052
00053
00054
00055
00056
00057
00058
00059
00060
00061
00062
00063
00064
00065
00066
00067
00068
00069
00070
00071
00072
00073
00074
00075
00076
00077
00078
00079
00080
00081
00082
00083
00084
00085
00086
00087
00088
00089
00090
00091
00092
00093
00094
00095
00096
00097
00098
00099
00100
00101
00102
00103
00104
00105
00106
00107
00108
00109
00110
00111
00112
00113
00114
00115
00116
00117
00118
00119
00120
00121
00122
00123
00124
00125
00126
00127
00128
00129
00130
00131
00132
00133
00134
00135
00136
00137
00138
00139
00140
00141
00142
00143
00144
00145
00146
00147
00148
00149
00150
00151
00152
00153
00154
00155
00156
00157
00158
00159
00160
00161
00162
00163
00164
00165
00166
00167
00168
00169
00170
00171
00172
00173
00174
00175
00176
00177
00178
00179 enum cdr_option_flags {
00180 OPT_RECURSIVE = (1 << 0),
00181 OPT_UNPARSED = (1 << 1),
00182 OPT_LAST = (1 << 2),
00183 OPT_SKIPLOCKED = (1 << 3),
00184 OPT_FLOAT = (1 << 4),
00185 };
00186
00187 AST_APP_OPTIONS(cdr_func_options, {
00188 AST_APP_OPTION('f', OPT_FLOAT),
00189 AST_APP_OPTION('l', OPT_LAST),
00190 AST_APP_OPTION('r', OPT_RECURSIVE),
00191 AST_APP_OPTION('s', OPT_SKIPLOCKED),
00192 AST_APP_OPTION('u', OPT_UNPARSED),
00193 });
00194
00195 static int cdr_read(struct ast_channel *chan, const char *cmd, char *parse,
00196 char *buf, size_t len)
00197 {
00198 char *ret;
00199 struct ast_flags flags = { 0 };
00200 struct ast_cdr *cdr;
00201 AST_DECLARE_APP_ARGS(args,
00202 AST_APP_ARG(variable);
00203 AST_APP_ARG(options);
00204 );
00205
00206 if (ast_strlen_zero(parse) || !chan)
00207 return -1;
00208
00209 ast_channel_lock(chan);
00210 cdr = chan->cdr;
00211 if (!cdr) {
00212 ast_channel_unlock(chan);
00213 return -1;
00214 }
00215
00216 AST_STANDARD_APP_ARGS(args, parse);
00217
00218 if (!ast_strlen_zero(args.options))
00219 ast_app_parse_options(cdr_func_options, &flags, NULL, args.options);
00220
00221 if (ast_test_flag(&flags, OPT_LAST))
00222 while (cdr->next)
00223 cdr = cdr->next;
00224
00225 if (ast_test_flag(&flags, OPT_SKIPLOCKED))
00226 while (ast_test_flag(cdr, AST_CDR_FLAG_LOCKED) && cdr->next)
00227 cdr = cdr->next;
00228
00229 if (!strcasecmp("billsec", args.variable) && ast_test_flag(&flags, OPT_FLOAT)) {
00230 if (!ast_tvzero(cdr->answer)) {
00231 double hrtime;
00232
00233 if(!ast_tvzero(cdr->end))
00234 hrtime = (double)(ast_tvdiff_us(cdr->end, cdr->answer) / 1000000.0);
00235 else
00236 hrtime = (double)(ast_tvdiff_us(ast_tvnow(), cdr->answer) / 1000000.0);
00237
00238 snprintf(buf, len, "%lf", hrtime);
00239 } else {
00240 snprintf(buf, len, "%lf", 0.0);
00241 }
00242 ret = buf;
00243 } else if (!strcasecmp("duration", args.variable) && ast_test_flag(&flags, OPT_FLOAT)) {
00244 double hrtime;
00245
00246 if(!ast_tvzero(cdr->end))
00247 hrtime = (double)(ast_tvdiff_us(cdr->end, cdr->start) / 1000000.0);
00248 else
00249 hrtime = (double)(ast_tvdiff_us(ast_tvnow(), cdr->start) / 1000000.0);
00250
00251 snprintf(buf, len, "%lf", hrtime);
00252
00253 if (!ast_strlen_zero(buf)) {
00254 ret = buf;
00255 }
00256 } else {
00257 ast_cdr_getvar(cdr, args.variable, &ret, buf, len,
00258 ast_test_flag(&flags, OPT_RECURSIVE),
00259 ast_test_flag(&flags, OPT_UNPARSED));
00260 }
00261
00262 ast_channel_unlock(chan);
00263 return ret ? 0 : -1;
00264 }
00265
00266 static int cdr_write(struct ast_channel *chan, const char *cmd, char *parse,
00267 const char *value)
00268 {
00269 struct ast_cdr *cdr;
00270 struct ast_flags flags = { 0 };
00271 AST_DECLARE_APP_ARGS(args,
00272 AST_APP_ARG(variable);
00273 AST_APP_ARG(options);
00274 );
00275
00276 if (ast_strlen_zero(parse) || !value || !chan)
00277 return -1;
00278
00279 ast_channel_lock(chan);
00280 cdr = chan->cdr;
00281 if (!cdr) {
00282 ast_channel_unlock(chan);
00283 return -1;
00284 }
00285
00286 AST_STANDARD_APP_ARGS(args, parse);
00287
00288 if (!ast_strlen_zero(args.options))
00289 ast_app_parse_options(cdr_func_options, &flags, NULL, args.options);
00290
00291 if (ast_test_flag(&flags, OPT_LAST))
00292 while (cdr->next)
00293 cdr = cdr->next;
00294
00295 if (!strcasecmp(args.variable, "accountcode"))
00296 ast_cdr_setaccount(chan, value);
00297 else if (!strcasecmp(args.variable, "peeraccount"))
00298 ast_cdr_setpeeraccount(chan, value);
00299 else if (!strcasecmp(args.variable, "userfield"))
00300 ast_cdr_setuserfield(chan, value);
00301 else if (!strcasecmp(args.variable, "amaflags"))
00302 ast_cdr_setamaflags(chan, value);
00303 else
00304 ast_cdr_setvar(cdr, args.variable, value, ast_test_flag(&flags, OPT_RECURSIVE));
00305
00306
00307
00308 ast_channel_unlock(chan);
00309 return 0;
00310 }
00311
00312 static struct ast_custom_function cdr_function = {
00313 .name = "CDR",
00314 .read = cdr_read,
00315 .write = cdr_write,
00316 };
00317
00318 static int unload_module(void)
00319 {
00320 return ast_custom_function_unregister(&cdr_function);
00321 }
00322
00323 static int load_module(void)
00324 {
00325 return ast_custom_function_register(&cdr_function);
00326 }
00327
00328 AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Call Detail Record (CDR) dialplan function");