HIT Database Analytics

Analytics for HIT Database--makes pretty graphs

当前为 2015-10-26 提交的版本,查看 最新版本

  1. // ==UserScript==
  2. // @name HIT Database Analytics
  3. // @author feihtality
  4. // @namespace https://greasyfork.org/en/users/12709
  5. // @version 0.9.003
  6. // @description Analytics for HIT Database--makes pretty graphs
  7. // @match https://www.mturk.com/mturk/dashboard
  8. // @require https://cdn.jsdelivr.net/momentjs/2.10.6/moment.min.js
  9. // @grant none
  10. // ==/UserScript==
  11.  
  12.  
  13.  
  14. ((D) => {
  15. 'use strict';
  16.  
  17. if (!('decRound' in self.Math) || !('Status' in window) || !('Progress' in window)) {
  18. console.log('execution order is either too high or HITDB MKII is not detected');
  19. return;
  20. }
  21.  
  22. Math.decRound = self.Math.decRound;
  23. var digitGroup = function(n) {
  24. n = String(n).split('.');
  25. if (n[0].length < 4) return n.join('.');
  26. n[0] = n[0].replace(/(\d)(?=(\d{3})+$)/g, '$1,');
  27. return n.join('.');
  28. },
  29. dec = (n,l) => Number(Math.decRound(n,l)).toFixed(l),
  30. m = this.moment;
  31.  
  32. // inject interface {{{
  33. var insertion = D.getElementById('hdbCSVInput'),
  34. searchbtn = D.getElementById('hdbSearch'),
  35. acheckbox = insertion.parentNode.insertBefore(D.createElement('INPUT'), insertion.nextSibling),
  36. alabel = insertion.parentNode.insertBefore(D.createElement('LABEL'), insertion.nextSibling),
  37. metrics = null;
  38.  
  39. acheckbox.type = 'checkbox';
  40. acheckbox.id = 'hdbAnalytics';
  41. acheckbox.style.verticalAlign = 'middle';
  42. alabel.textContent = 'Analyze';
  43. alabel.htmlFor = 'hdbAnalytics';
  44. alabel.style.verticalAlign = 'middle';
  45.  
  46. acheckbox.onclick = function() {
  47. if (searchbtn.textContent === "Export CSV") insertion.click();
  48. if (searchbtn.textContent === "Analyze") searchbtn.textContent = 'Search';
  49. else searchbtn.textContent = 'Analyze';
  50. };
  51. searchbtn.addEventListener('click', getData);
  52. //}}}
  53.  
  54. function getData(e) {//{{{
  55. if (e.target.textContent !== "Analyze") return;
  56. if (!window.HITStorage.db) { window.Status.push('AccessViolation: Database is not defined.', 'red'); return; }
  57. var range;
  58. dbrange = [D.getElementById('hdbMinDate').value || undefined, D.getElementById('hdbMaxDate').value || undefined];
  59. dbrange[3] = ['9999-99-99', '0000-00-00'];
  60. if (!dbrange[0] && !dbrange[1]) {
  61. dbrange[2] = 'ALL';
  62. range = null;
  63. } else if (dbrange[0] && !dbrange[1]) {
  64. dbrange[2] = dbrange[0]+'>>';
  65. range = window.IDBKeyRange.lowerBound(dbrange[0]);
  66. } else if (!dbrange[0] && dbrange[1]) {
  67. dbrange[2] = '<<'+dbrange[1];
  68. range = window.IDBKeyRange.upperBound(dbrange[1]);
  69. } else {
  70. dbrange[2] = dbrange[0]+':'+dbrange[1];
  71. range = window.IDBKeyRange.bound(dbrange[0],dbrange[1]);
  72. }
  73.  
  74. sets = new Sets();
  75. window.Progress.show();
  76. metrics = new window.Metrics('database_analytics');
  77. metrics.mark('dbrecall', 'start');
  78. dbrecall("HIT", {range: range}).then(analyzeData);
  79. }//}}}
  80.  
  81. /* . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . */
  82.  
  83. var
  84. Sets = function() {//{{{ main data obj
  85. this.quarter = {
  86. aggregate: {},
  87. pay: { labels: [], data: [] },
  88. hits: { labels: [], data: [] },
  89. };
  90. this.month = {
  91. aggregate: {},
  92. pay: { labels: [], data: [] },
  93. hits: { labels: [], data: [] },
  94. };
  95. this.week = {
  96. aggregate: {},
  97. pay: { labels: [], data: [] },
  98. hits: { labels: [], data: [] },
  99. };
  100. this.day = {
  101. aggregate: {},
  102. pay: { labels: [], data: [] },
  103. hits: { labels: [], data: [] },
  104. };
  105. this.dayofweek = {
  106. aggregate: {},
  107. pay: { labels: [], data: [] },
  108. hits: { labels: [], data: [] },
  109. };
  110. this.all = {
  111. aggregate: {},
  112. distribution: {
  113. hits: {'1':0,'2-5':0,'6-10':0,'11-15':0,'16-20':0,'21-25':0,'26-30':0,'31-35':0,
  114. '36-40':0,'41-45':0,'46-50':0,'51-100':0,'101-150':0,'151-200':0,'201-250':0,'251-300':0,
  115. '301-350':0,'351-400':0,'401-450':0,'451-500':0,'501-550':0,'551-600':0,'601-650':0,'651-700':0,
  116. '701-750':0,'751-800':0,'801-850':0,'851-900':0,'901-950':0,'951-1000':0,'1001+':0},
  117. pay: {'0':0, '0.01-0.05':0,'0.06-0.10':0,'0.11-0.15':0,'0.16-0.20':0,'0.21-0.25':0,
  118. '0.26-0.30':0,'0.31-0.35':0,'0.36-0.40':0,'0.41-0.45':0,'0.46-0.50':0,'0.51-0.55':0,
  119. '0.56-0.60':0,'0.61-0.65':0,'0.66-0.70':0,'0.71-0.75':0,'0.76-0.80':0,'0.81-0.85':0,
  120. '0.86-0.90':0,'0.91-0.95':0,'0.96-1.00':0,'1.01-1.25':0,'1.26-1.50':0,'1.51-1.75':0,
  121. '1.76-2.00':0,'2.01-2.25':0,'2.26-2.50':0,'2.51-2.75':0,'2.76-3.00':0,'3.01-3.25':0,
  122. '3.26-3.50':0,'3.51-3.75':0,'3.76-4.00':0,'4.01-4.25':0,'4.26-4.50':0,'4.51-4.75':0,
  123. '4.76-5.00':0,'5.01+':0},
  124. data: { hits: [], labelsh: [], pay: [], labelsp: [] } },
  125. hits: { total: 0, rejected: 0, pending: 0, bonus: 0, titles: {}, batch: [[],[],[],[]] },
  126. pay : { total: 0, rejected: 0, pending: 0, bonus: 0 },
  127. hitsPerRequester: { avg: 0, data: [], sd: 0, se: 0 },
  128. payPerHit: { avg: 0, data: [], sd: 0, se: 0 }
  129. };
  130. },//}}}
  131. sets = new Sets(),
  132. disth = Object.keys(sets.all.distribution.hits),
  133. distp = Object.keys(sets.all.distribution.pay),
  134. qmwdLabels = Object.keys(sets), dbrange;
  135.  
  136. function dbrecall(os, options) {
  137. options = options || {};
  138. var
  139. index = options.index || "date",
  140. range = options.range || null;
  141. //wRange = [null, null];
  142.  
  143. var total = 0;
  144. return new Promise( y => {
  145. window.HITStorage.db.transaction(os, "readonly").objectStore(os).index(index).openCursor(range).onsuccess = function() {
  146. if (this.result) {
  147. window.Status.message = 'Aggregating data... [ '+(total++)+' ]';
  148. aggregateCursor(this.result.value);
  149. this.result.continue();
  150. }
  151. else y(1);
  152. };
  153. });
  154. }
  155.  
  156. function analyzeData(r) {
  157. void(r);
  158. metrics.mark('dbrecall','end');
  159. metrics.mark('dsWorker', 'start');
  160. dsWorker.postMessage(sets);
  161. }
  162.  
  163. function drawCharts(sets) {//{{{
  164. var
  165. hitlineopt = {
  166. label: 'HITs Submitted',
  167. yAxixID: 'hits',
  168. backgroundColor: 'rgba(149,89,240,0.1)'/*'rgba(42,161,152,0.1)'*/,
  169. borderColor : 'rgba(149,89,240,0.5)'/*'rgba(42,161,152,0.5)'*/,
  170. pointBackgroundColor : 'rgba(149,89,240,1)'/*'rgba(42,161,152,1)'*/,
  171. pointHoverBackgroundColor: 'rgba(92,0,230,1)'/*'rgba(38,139,210,1)'*/
  172. },
  173. paylineopt = {
  174. label: 'Total Pay',
  175. yAxisID: 'pay',
  176. backgroundColor: 'rgba(200,242,48,0.1)'/*'rgba(181,137,0,0.1)'*/,
  177. borderColor : 'rgba(200,242,48,0.5)'/*'rgba(181,137,0,0.5)'*/,
  178. pointBackgroundColor : 'rgba(200,242,48,1)'/*'rgba(181,137,0,1)'*/,
  179. pointHoverBackgroundColor: 'rgba(129,163,5,1)'/*'rgba(133,153,0,1)'*/
  180. },
  181. chartopt = {}, humps = {};
  182. for (var k of Object.keys(sets)) {
  183. if (k === 'all') {
  184. var a = sets.all.hits;
  185. chartopt.bsratio = {
  186. type: 'pie', data: {
  187. labels: ['batch', 'survey'],
  188. datasets: [{ data: [Math.decRound(100*a.batch.total/a.total,2), Math.decRound(100*(a.total-a.batch.total)/a.total,2)],
  189. backgroundColor: ['#6A90F7', '#EDC147'] }]
  190. }, options: { tooltips: { template: '<%= label %>: <%= value %>%', fontSize: 12 } }
  191. };
  192. chartopt.pdist = {
  193. type: 'bar', data: {
  194. labels: sets.all.distribution.data.labelsp,
  195. datasets: [{ data: sets.all.distribution.data.pay,
  196. backgroundColor: '#47EDE1', hoverBackgroundColor: '#C7ED3E' }]
  197. }, options: { scales: { xAxes: [{ ticks: {show: false}, categorySpacing: 1 }] },
  198. tooltips: { multiTemplate: '<%= datasetLabel %><%= value %>%' }
  199. }
  200. };
  201. chartopt.hdist = {
  202. type: 'bar', data: {
  203. labels: sets.all.distribution.data.labelsh,
  204. datasets: [{ data: sets.all.distribution.data.hits,
  205. backgroundColor: '#47EDE1', hoverBackgroundColor: '#C7ED3E' }]
  206. }, options: { scales: { xAxes: [{ ticks: {show: false}, categorySpacing: 1}] },
  207. tooltips: { multiTemplate: '<%= datasetLabel %><%= value %>%' }
  208. }
  209. };
  210. continue;
  211. }
  212. var timeOpts,
  213. _hit = sets[k].hits.data.map(v => v).sort((a,b) => b-a),
  214. _pay = sets[k].pay.data.map(v => v).sort((a,b) => b-a);
  215.  
  216. _hit = [ _hit.shift(), _hit.pop() ];
  217. _pay = [ _pay.shift(), _pay.pop() ];
  218. humps[k] = { hit: { high: [_hit[0], sets[k].hits.labels[sets[k].hits.data.findIndex(v => v === _hit[0])]],
  219. low: [_hit[1], sets[k].hits.labels[sets[k].hits.data.findIndex(v => v === _hit[1])]] },
  220. pay: { high: [_pay[0], sets[k].hits.labels[sets[k].pay.data.findIndex(v => v === _pay[0])]],
  221. low: [_pay[1], sets[k].hits.labels[sets[k].pay.data.findIndex(v => v === _pay[1])]] } };
  222. switch (k) {
  223. case 'day': timeOpts = { format: 'YYYY-MM-DD (ddd)', displayFormat: 'MMMDD', unit: 'week', round: false }; break;
  224. case 'week': timeOpts = { format: 'gggg[ week ]ww', displayFormat: 'gg[w]ww', unit: k, round: false }; break;
  225. case 'month': timeOpts = { format: 'MMMM YYYY', displayFormat: 'MMM[\']YY', unit: k, round: false }; break;
  226. case 'quarter': timeOpts = { format: 'YYYY [Q]Q', displayFormat: 'YYYY [Q]Q', unit: k, round: false }; break;
  227. case 'dayofweek': timeOpts = false;/*{ format: 'dddd', displayFormat: 'dddd', unit: false, round: false };*/ break;
  228. }
  229. Object.assign(sets[k].hits, hitlineopt);
  230. Object.assign(sets[k].pay, paylineopt);
  231. chartopt[k] = {
  232. type:'line', data: { labels: sets[k].hits.labels, datasets: [sets[k].hits, sets[k].pay] },
  233. options: {
  234. stacked: false, scales: {
  235. xAxes: [{ gridLines: { offsetGridLines: false }, display: true, type: k === 'dayofweek' ? 'category' : 'time', time: timeOpts,
  236. scaleLabel: { show: false, labelString: k }, ticks: { maxRotation:45, fontColor: '#969696'} }],
  237. yAxes: [{ type: 'linear', display: true, position: 'left', id: 'hits',
  238. /*scaleLabel: {show: true, labelString: 'hits', fontColor: '#EEE8d5', fontFamily: 'Arial'}*/ },
  239. { type: 'linear', display: true, position: 'right', id: 'pay', gridLines: { drawOnChartArea: false },
  240. /*scaleLabel: {show:true, labelString: 'pay', fontColor: '#EEE8d5', fontFamily: 'Arial'}*/ }]
  241. }
  242. }
  243. };
  244. }
  245. var html = ['<head>',//{{{
  246. '<link href="https://fonts.googleapis.com/css?family=Open+Sans:300,400" rel="stylesheet" type="text/css">',
  247. '<script src="https://cdn.jsdelivr.net/g/momentjs@2.10.6,chart.js@2.0.0-alpha4"></script>',
  248. '<style>',
  249. '.caption {width:72%;margin:auto;padding:5px;text-align:center;font-size:0.85em}',
  250. '.hc {color:#AA7DF0} .pc {color:#C8F230}',
  251. '.bc {color:#6A90F7} .sc {color:#EDC147}',
  252. '.container {display:flex;align-content:center;justify-content:space-around}',
  253. '.mi {font-size:0.6em}',
  254. '.title {background-color:#EEE8D5;color:#073642;width:90%;margin:1% 6% 0% 5%;padding-left:2%;font-weight:400;}',
  255. '.btn {border:1px solid #EEE8D5; color:#EEE8D5; background:#073642; padding:1%; text-align:center; cursor:pointer; font-weight:400; flex:1}',
  256. '.btn-active {border:1px solid #073642; color:#073642; background:#EEE8D5}',
  257. '.btn:hover {border:1px solid #073642; color:#EEE8D5; background:rgba(238,232,213,0.3)}',
  258. '</style>',
  259. '<title>HIT Database Analytics | '+dbrange[2]+'</title>',
  260. '</head>',
  261. '<body style="color:#fff;background-color:#073642;font-size:100%;font-family:\'Open Sans\',Arial;font-weight:300">',
  262. '<h2 style="margin:1% 15%">MTurk HIT Database Analytics</h2>',
  263. '<h4 style="margin:0.5% 20%">'+dbrange[3][0]+' to '+dbrange[3][1]+'</h4>',
  264. '<div class="title">GENERAL STATISTICS</div>',
  265. '<div class="container">',
  266. '<div style="margin-top:5%;margin-left:5%;flex:1">',
  267. '<div class="container" style="margin-right:10%">',
  268. '<span style="text-align:right;color:#C7ED3E;flex:1">'+digitGroup(sets.all.hits.total)+'</span>',
  269. '<span style="text-align:center;flex:1">SUBMITTED</span>',
  270. '<span style="text-align:left;color:#C7ED3E;flex:1">$'+digitGroup(dec(sets.all.pay.total,2))+'</span>',
  271. '</div><div class="container" style="margin-right:10%">',
  272. '<span style="text-align:right;color:#C7ED3E;flex:1">'+digitGroup(sets.all.hits.bonus)+'</span>',
  273. '<span style="text-align:center;flex:1">BONUSES</span>',
  274. '<span style="text-align:left;color:#C7ED3E;flex:1">$'+digitGroup(dec(sets.all.pay.bonus,2))+'</span>',
  275. '</div><div class="container" style="margin-right:10%">',
  276. '<span style="text-align:right;color:#FF6666;flex:1">'+digitGroup(sets.all.hits.rejected)+'</span>',
  277. '<span style="text-align:center;flex:1">REJECTED</span>',
  278. '<span style="text-align:left;color:#FF6666;flex:1">$'+digitGroup(dec(sets.all.pay.rejected,2))+'</span>',
  279. '</div><div class="container" style="margin-right:10%">',
  280. '<span style="text-align:right;color:#E0B438;flex:1">'+digitGroup(sets.all.hits.pending)+'</span>',
  281. '<span style="text-align:center;flex:1">PENDING</span>',
  282. '<span style="text-align:left;color:#E0B438;flex:1">$'+digitGroup(dec(sets.all.pay.pending,2))+'</span>',
  283. '</div>',
  284. '<span class="mi" style="text-align:justify"><span style="color:#30CEF2">NOTE:</span> DOLLAR AMOUNT FOR \'PENDING\' MAY ',
  285. 'REFLECT VALUES FOR HITS WHICH HAVE ALREADY BEEN APPROVED. THESE FUNDS HAVE NOT BEEN FULLY CLEARED ',
  286. 'AND CREDITED TO YOUR ACCOUNT, AND THUS ARE STILL TECHNICALLY PENDING.</span>',
  287. '<div style="margin:10% 10% 10% 0;flex:1;text-align:center;">',
  288. 'AVERAGE SUBMISSION OF <span style="color:#C7ED3E">'+dec(sets.all.hitsPerRequester.avg,3)+'</span> ',
  289. '(<span style="color:#C7ED3E">&#177;'+dec(sets.all.hitsPerRequester.se,3)+'</span>) HITS PER REQUESTER',
  290. '<br><span class="mi">STANDARD DEVIATION: <span style="color:#FA5583">'+dec(sets.all.hitsPerRequester.sd,3)+'</span></span>',
  291. '<hr style="width:45%;color:#fff;background-color:#fff">',
  292. 'AVERAGE PAY OF <span style="color:#C7ED3E">$'+dec(sets.all.payPerHit.avg,3)+'</span> ',
  293. '(<span style="color:#C7ED3E">&#177;$'+dec(sets.all.payPerHit.se,3)+'</span>) PER HIT',
  294. '<br><span class="mi">STANDARD DEVIATION: <span style="color:#FA5583">'+dec(sets.all.payPerHit.sd,3)+'</span></span>',
  295. '<hr style="width:45%;color:#fff;background-color:#fff">',
  296. 'AVERAGING <span style="color:#C7ED3E">'+Math.ceil(1/(sets.all.payPerHit.avg+sets.all.payPerHit.se))+'</span>',
  297. '<span id="minbound"> TO <span style="color:#C7ED3E">'+Math.ceil(1/(sets.all.payPerHit.avg-sets.all.payPerHit.se))+
  298. '</span></span> HITS PER $1.00',
  299. '</div>',
  300. '</div>',
  301. '<div style="margin-top:3%;flex:1">',
  302. '<div><canvas id="hitdist"></canvas><div class="caption">HIT DISTRIBUTION PER REQUESTER</div></div>',
  303. '<div><canvas id="paydist"></canvas><div class="caption">PAY DISTRIBUTION PER HIT</div></div>',
  304. '</div>',
  305. '<div style="margin-top:10%;flex:1">',
  306. '<canvas id="batchpie"></canvas>',
  307. '<div class="caption"><span class="bc">BATCH</span> : <span class="sc">SURVEY</span><br>RATIO APPROXIMATION</div>',
  308. '</div>',
  309. '</div>',
  310. '<div class="title">ACTIVITY</div>',
  311. '<div class="container" style="margin-top:1%;margin-left:10%;margin-right:10%">',
  312. '<div class="btn btn-active" data-p="day">DAILY</div><div class="btn" data-p="week">WEEKLY</div>',
  313. '<div class="btn" data-p="month">MONTHLY</div><div class="btn" data-p="quarter">QUARTERLY</div>',
  314. '<div class="btn" data-p="dayofweek">DAY OF WEEK</div>',
  315. '</div>',
  316. '<div style="margin-top:1%;margin-left:5%;margin-right:5%">',
  317. '<div style="margin-left:5%;margin-right:5%"><canvas id="activityLines"></canvas></div>',
  318. '<div class="caption container" style="font-size:0.73em;font-weight:400">',
  319. '<div style="flex:1">',
  320. 'HIGHEST:&ensp;<span id="hh" class="hc"></span> (<span id="hhd"></span>), <span id="hp" class="pc"></span> (<span id="hpd"></span>)',
  321. '</div>',
  322. '<div style="flex:1">',
  323. 'LOWEST:&ensp;<span id="lh" class="hc"></span> (<span id="lhd"></span>), <span id="lp" class="pc"></span> (<span id="lpd"></span>)',
  324. '</div>',
  325. '</div>',
  326. '<div class="caption"><span class="hc">HITS SUBMITTED</span> | <span class="pc">TOTAL PAY</span></div>',
  327. '</div>',
  328. '<div class="title">TOP REQUESTERS</div>',
  329. '<div class="container">',
  330. '<table id="req10pay" style="font-weight:300;margin-top:1%;margin-left:5%;">',
  331. '<thead><tr><th colspan="2" style="text-align:left;padding-left:15">PAY</th></tr></thead><tbody></tbody></table>',
  332. '<table id="req10hit" style="font-weight:300;margin-top:1%;">',
  333. '<thead><tr><th colspan="2" style="text-align:left;padding-left:15">HITS</th></tr></thead><tbody></tbody></table>',
  334. '<table id="req10bns" style="font-weight:300;margin-top:1%;">',
  335. '<thead><tr><th colspan="2" style="text-align:left;padding-left:15">BONUS</th></tr></thead><tbody></tbody></table>',
  336. '<table id="req10rej" style="font-weight:300;margin-top:1%;margin-right:5%;">',
  337. '<thead><tr><th colspan="2" style="text-align:left;padding-left:15">REJECTIONS</th></tr></thead><tbody></tbody></table>',
  338. '</div>',
  339. '<script>',
  340. 'if (!NodeList.prototype[Symbol.iterator]) NodeList.prototype[Symbol.iterator] = Array.prototype[Symbol.iterator];',
  341. 'var chartopt = '+JSON.stringify(chartopt)+',',
  342. 'range = '+JSON.stringify(humps)+',',
  343. 'n = id => document.getElementById(id), _t = (n,t) => n.textContent = t, dec = v => Number(v).toFixed(2), dg = '+digitGroup+',',
  344. 'setHPstats = p => {',
  345. '_t(hh,dg(range[p].hit.high[0])); _t(hhd,range[p].hit.high[1]);',
  346. '_t(hp,"$"+dg(dec(range[p].pay.high[0]))); _t(hpd,range[p].pay.high[1]);',
  347. '_t(lh,dg(range[p].hit.low[0])); _t(lhd,range[p].hit.low[1]);',
  348. '_t(lp,"$"+dg(dec(range[p].pay.low[0]))); _t(lpd,range[p].pay.low[1]);',
  349. '},',
  350. 'aLines = new Chart(n("activityLines").getContext("2d"), Object.assign({}, chartopt.day)),',
  351. 'bsPie = new Chart(n("batchpie").getContext("2d"), chartopt.bsratio),',
  352. 'hdist = new Chart(n("hitdist").getContext("2d"), chartopt.hdist),',
  353. 'pdist = new Chart(n("paydist").getContext("2d"), chartopt.pdist),',
  354. 'r10hit = n("req10hit").tBodies[0], r10hHtml = [],',
  355. 'r10pay = n("req10pay").tBodies[0], r10pHtml = [],',
  356. 'r10bns = n("req10bns").tBodies[0], r10bHtml = [],',
  357. 'r10rej = n("req10rej").tBodies[0], r10rHtml = [],',
  358. 'hh = n("hh"), hhd = n("hhd"), hp = n("hp"), hpd = n("hpd"), lh = n("lh"), lhd = n("lhd"), lp = n("lp"), lpd = n("lpd"),',
  359. 'btns = Array.from(document.querySelectorAll(".btn")),',
  360. 'payArr = '+JSON.stringify(sets.all.rpay)+',',
  361. 'hitArr = '+JSON.stringify(sets.all.rhits)+',',
  362. 'bnsArr = '+JSON.stringify(sets.all.rbonus)+',',
  363. 'rejArr = '+JSON.stringify(sets.all.rrej)+',',
  364. 'mb = n("minbound"),',
  365. 'btnFn = function(e) {',
  366. 'if (e.target.classList.contains("btn-active")) return;',
  367. 'var _p = e.target.dataset.p;',
  368. 'document.querySelector(".btn-active").classList.toggle("btn-active");',
  369. 'e.target.classList.toggle("btn-active");',
  370. 'aLines.data = chartopt[_p].data;',
  371. 'aLines.options.scales.xAxes[0].time = chartopt[_p].options.scales.xAxes[0].time;',
  372. 'aLines.options.scales.xAxes[0].type = chartopt[_p].options.scales.xAxes[0].type;',
  373. 'aLines.buildScales();',
  374. 'aLines.update();',
  375. 'aLines.resetElements();',
  376. 'aLines.update();',
  377. 'aLines.initToolTip();',
  378. 'setHPstats(_p);',
  379. '};',
  380. 'btns.forEach(n => n.onclick = btnFn);',
  381. 'setHPstats("day");',
  382. 'if (mb.children[0].textContent === mb.previousSibling.textContent) mb.style.display = "none";',
  383. 'payArr.forEach(v => r10pHtml',
  384. '.push("<tr><td style=\\"text-align:right;padding-right:10;color:#47EDE1\\">$"+v.pay+"</td>',
  385. '<td style=\\"max-width:200\\">"+v.name+"</td></tr>"));',
  386. 'hitArr.forEach(v => r10hHtml',
  387. '.push("<tr><td style=\\"text-align:right;padding-right:10;color:#47EDE1\\">"+v.hits+"</td>',
  388. '<td style=\\"max-width:200\\">"+v.name+"</td></tr>"));',
  389. 'bnsArr.forEach(v => r10bHtml',
  390. '.push("<tr><td style=\\"text-align:right;padding-right:10;color:#47EDE1\\">$"+v.bonus+"</td>',
  391. '<td style=\\"max-width:200\\">"+v.name+"</td></tr>"));',
  392. 'rejArr.forEach(v => r10rHtml',
  393. '.push("<tr><td style=\\"text-align:right;padding-right:10;color:#FF6666\\">"+v.rej+',
  394. '" <span style=\\"color:#fff\\">(</span>$"+v.rejAmt+"<span style=\\"color:#fff\\">)</span></td>',
  395. '<td style=\\"max-width:200\\">"+v.name+"</td></tr>"));',
  396. 'if (r10bHtml.length === 0) r10bns.parentNode.style.display="none";',
  397. 'if (r10rHtml.length === 0) r10rej.parentNode.style.display="none";',
  398. 'r10hit.innerHTML = r10hHtml.join(""); r10pay.innerHTML = r10pHtml.join("");',
  399. 'r10bns.innerHTML = r10bHtml.join(""); r10rej.innerHTML = r10rHtml.join("");',
  400. '</script>',
  401. '</body>'];//}}}
  402. var blob = new Blob(html, {type:'text/html'}), _a = D.body.appendChild(D.createElement('A'));
  403. _a.href = URL.createObjectURL(blob);
  404. _a.target = '_blank';
  405. _a.click();
  406. _a.remove();
  407. }//}}}
  408.  
  409. function aggregateCursor(dat) {//{{{
  410. var _m = m(dat.date, 'YYYY-MM-DD'),
  411. qmwd = [
  412. _m.format('YYYY [Q]Q'),
  413. _m.format('MMMM YYYY'),
  414. _m.format('gggg[ week ]ww'),
  415. _m.format('YYYY-MM-DD (ddd)'),
  416. _m.format('dddd'),
  417. ],
  418. pay = isNaN(dat.reward) ? +dat.reward.pay : +dat.reward,
  419. bonus = isNaN(dat.reward) ? +dat.reward.bonus : 0;
  420.  
  421. if (dat.date < dbrange[3][0]) dbrange[3][0] = dat.date;
  422. else if (dat.date > dbrange[3][1]) dbrange[3][1] = dat.date;
  423.  
  424. // populate scaled aggregates
  425. for (var i=0; i<qmwd.length; i++) {
  426. var def = sets[qmwdLabels[i]].aggregate;
  427. if (!([qmwd[i]] in def)) {
  428. def[qmwd[i]] = { hits:0, pay:0 };
  429. }
  430. def[qmwd[i]].hits += 1;
  431. def[qmwd[i]].pay += pay;
  432. }// end for qmwd loop
  433. // repeat requester aggregation for 'all'
  434. if (!(dat.requesterId in sets.all.aggregate))
  435. sets.all.aggregate[dat.requesterId] = { name: dat.requesterName, hits: 0, pay: 0, bonus: 0, rej: 0, rejAmt: 0};
  436. sets.all.aggregate[dat.requesterId].hits += 1;
  437. sets.all.aggregate[dat.requesterId].pay += pay;
  438. sets.all.aggregate[dat.requesterId].bonus += bonus;
  439. sets.all.aggregate[dat.requesterId].rej += dat.status === "Rejected" ? 1 : 0;
  440. sets.all.aggregate[dat.requesterId].rejAmt += dat.status === "Rejected" ? pay : 0;
  441.  
  442. // populate pay distribution data
  443. // hit distribution needs to wait until later--after aggregation
  444. sets.all.payPerHit.data.push(pay);
  445. distp.forEach( v => {
  446. var range = v.split('-');
  447. if (pay === +v) { sets.all.distribution.pay[v] += 1; return; }
  448. if (v === '5.01+' && pay > 5) { sets.all.distribution.pay[v] += 1; return; }
  449. if (pay >= range[0] && pay <= range[1]) { sets.all.distribution.pay[v] += 1; return; }
  450. });
  451. // increment general stats
  452. var _t = dat.title.trim(), _t1 = _t.charAt(0).toLowerCase(), _ss;
  453. sets.all.hits.total += 1;
  454. sets.all.hits.rejected += dat.status === 'Rejected' ? 1 : 0;
  455. sets.all.hits.pending += dat.status === 'Pending Approval' ? 1 : 0;
  456. sets.all.hits.bonus += bonus ? 1 : 0;
  457. //sets.all.hits.titles[_t] = sets.all.hits.titles[_t] + 1 || 1;
  458. sets.all.pay.total += pay;
  459. sets.all.pay.rejected += dat.status === 'Rejected' ? pay : 0;
  460. sets.all.pay.pending += /pending/i.test(dat.status) ? pay : 0;
  461. sets.all.pay.bonus += bonus;
  462. // populate data for batch approximation
  463. if (_t1 < "h") _ss = 0;
  464. else if (_t1 < "o") _ss = 1;
  465. else if (_t1 < "v") _ss = 2;
  466. else _ss = 3;
  467. var hitLoc = sets.all.hits.batch[_ss].findIndex(v => v.title === _t && v.req === dat.requesterId);
  468. if (~hitLoc)
  469. sets.all.hits.batch[_ss][hitLoc].count += 1;
  470. else
  471. sets.all.hits.batch[_ss].push({ title: _t, req: dat.requesterId, count: 1 });
  472. }//}}}
  473.  
  474.  
  475. //set up a worker thread to prevent interface locking on large datasets
  476. var datasetsWorker = [//{{{
  477. 'var dec = '+dec+', digitGroup = '+digitGroup+';',
  478. 'Math.decRound = '+Math.decRound+';',
  479. // calculate the standard deviation
  480. 'function stdev(avg, N, data) {',
  481. 'var sum = 0;',
  482. 'data.forEach(v => sum += Math.pow(v-avg, 2));',
  483. 'return Math.sqrt(sum/(N-1));',
  484. '}',
  485.  
  486. 'function arrayFromObj(obj) {',
  487. 'var arr = [];',
  488. 'for (var k in obj) {',
  489. 'if (obj.hasOwnProperty(k))',
  490. 'arr.push(obj[k]);',
  491. '}',
  492. 'return arr;',
  493. '}',
  494.  
  495. 'onmessage = (e) => {',
  496. 'var sets = e.data, disth = '+JSON.stringify(disth)+', distp = '+JSON.stringify(distp)+', reqArr;',
  497. // sort aggregates
  498. 'for (var period of Object.keys(sets)) {',
  499. 'if (period === \'all\') { ',
  500. 'reqArr = arrayFromObj(sets.all.aggregate);',
  501. // calculate averages, sd, se
  502. 'postMessage( {type: "status", data: "Calculating averages..." });',
  503. 'var _pph = sets.all.payPerHit, _hpr = sets.all.hitsPerRequester;',
  504. '_pph.avg = sets.all.pay.total / sets.all.hits.total;',
  505. '_pph.sd = stdev(_pph.avg, _pph.data.length, _pph.data);',
  506. '_pph.se = _pph.sd/Math.sqrt(_pph.data.length);',
  507. '_hpr.data = reqArr.map( v => v.hits );',
  508. '_hpr.avg = sets.all.hits.total / _hpr.data.length;',
  509. '_hpr.sd = stdev(_hpr.avg, _hpr.data.length, _hpr.data);',
  510. '_hpr.se = _hpr.sd/Math.sqrt(_hpr.data.length);',
  511. // get hit distribution
  512. 'postMessage( {type: "status", data: "Populating distributions..." });',
  513. 'reqArr.forEach(v => {',
  514. 'disth.forEach(w => {',
  515. 'var range = w.split(\'-\');',
  516. 'if (range.length === 1) range.push(\'1\');',
  517. 'if (v.hits > 1000 && w === \'1001+\') { sets.all.distribution.hits[w] += 1; return; }',
  518. 'if (v.hits >= range[0] && v.hits <= range[1]) { sets.all.distribution.hits[w] += 1; return; }',
  519. '});',
  520. '});',
  521. // extract raw data for distributions
  522. 'disth.forEach(v => sets.all.distribution.data.hits.push(Math.decRound(100*sets.all.distribution.hits[v]/reqArr.length,3)));',
  523. 'distp.forEach(v => sets.all.distribution.data.pay.push(Math.decRound(100*sets.all.distribution.pay[v]/sets.all.hits.total,3)));',
  524. 'sets.all.distribution.data.labelsh = Object.keys(sets.all.distribution.hits);',
  525. 'sets.all.distribution.data.labelsp = Object.keys(sets.all.distribution.pay);',
  526. // get 'top' lists
  527. 'sets.all.rpay = reqArr.sort((a,b) => b.pay - a.pay ).slice(0,10);',
  528. 'sets.all.rhits = reqArr.sort((a,b) => b.hits - a.hits).slice(0,10);',
  529. 'sets.all.rbonus= reqArr.filter(e => e.bonus > 0).sort((a,b) => b.bonus - a.bonus).slice(0,10);',
  530. 'sets.all.rrej = reqArr.filter(e => e.rej > 0).sort((a,b) => b.rej - a.rej).slice(0,10);',
  531. 'sets.all.rpay.forEach(v => v.pay = digitGroup(dec(v.pay,2)));',
  532. 'sets.all.rhits.forEach(v => v.hits = digitGroup(v.hits));',
  533. 'sets.all.rbonus.forEach(v => v.bonus = digitGroup(dec(v.bonus,2)));',
  534. 'sets.all.rrej.forEach(v => v.rejAmt = dec(v.rejAmt,2));',
  535. 'continue;',
  536. '}',
  537. // populate labels/data for graphing
  538. 'postMessage({ type: "status", data: "Sorting by "+period+"..." });',
  539. 'var labels = Object.keys(sets[period].aggregate);',
  540. 'if (period === "dayofweek") labels = ["Sunday","Monday","Tuesday","Wednesday","Thursday","Friday","Saturday"]',
  541. '.filter(v => !!~Object.keys(sets[period].aggregate).indexOf(v));',
  542. 'for (k of labels) {',
  543. 'if (~[\'hits\',\'pay\'].indexOf(k)) continue;',
  544. 'sets[period].pay.labels.push(k);',
  545. 'sets[period].hits.labels.push(k);',
  546. 'sets[period].pay.data.push(Math.decRound(sets[period].aggregate[k].pay,2));',
  547. 'sets[period].hits.data.push(sets[period].aggregate[k].hits);',
  548. '}',
  549. '}',
  550. // if there are more than 5 hits with the same title under the same requester, assume it's a batch
  551. 'var _temp = [];',
  552. 'while (sets.all.hits.batch.length) _temp = _temp.concat(sets.all.hits.batch.shift().filter(v => v.count > 5));',
  553. 'sets.all.hits.batch = _temp;',
  554. 'sets.all.hits.batch.total = 0;',
  555. 'sets.all.hits.batch.forEach(v => {if (typeof v === "object") sets.all.hits.batch.total += v.count});',
  556.  
  557. 'postMessage({ type: "obj", data: sets });',
  558.  
  559. '}'];//}}}
  560.  
  561. datasetsWorker = new Blob(datasetsWorker, {type:'text/javascript'});
  562. var workerURL = URL.createObjectURL(datasetsWorker);
  563. var dsWorker = new Worker(workerURL);
  564.  
  565. dsWorker.onmessage = (e) => {//{{{
  566. if (e.data.type === 'status') {
  567. window.Status.message = e.data.data;
  568. console.log(e.data.data);
  569. } else {
  570. metrics.mark('dsWorker','end');
  571. metrics.stop();metrics.report();
  572. window.Status.message = 'Done!';
  573. window.Progress.hide();
  574. drawCharts(e.data.data);
  575. }
  576. };//}}}
  577.  
  578. })(document);
  579.  
  580. // vim: ts=2:sw=2:et:fdm=marker:noai