1: 2: 3: 4: 5: 6: 7: 8: 9: 10: 11: 12: 13: 14: 15: 16: 17: 18: 19: 20: 21: 22: 23: 24: 25: 26: 27: 28: 29: 30: 31: 32: 33: 34: 35: 36: 37: 38: 39: 40: 41: 42: 43: 44: 45: 46: 47: 48: 49: 50: 51: 52: 53: 54: 55: 56: 57: 58: 59: 60: 61: 62: 63: 64: 65: 66: 67: 68: 69: 70: 71: 72: 73: 74: 75: 76: 77: 78: 79: 80: 81: 82: 83: 84: 85: 86: 87: 88: 89: 90: 91: 92: 93: 94: 95: 96: 97: 98: 99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 109: 110: 111: 112: 113: 114: 115: 116: 117: 118: 119: 120: 121: 122: 123: 124: 125: 126: 127: 128: 129: 130: 131: 132: 133: 134: 135: 136: 137: 138: 139: 140: 141: 142: 143: 144: 145: 146: 147: 148: 149: 150: 151: 152: 153: 154: 155: 156: 157: 158: 159: 160: 161: 162: 163: 164: 165: 166: 167: 168: 169: 170: 171: 172: 173: 174: 175: 176: 177: 178: 179: 180: 181: 182: 183: 184: 185: 186: 187: 188: 189: 190: 191: 192: 193: 194: 195: 196: 197: 198: 199: 200: 201: 202: 203: 204: 205: 206: 207: 208: 209: 210: 211: 212: 213: 214: 215: 216: 217: 218: 219: 220: 221: 222: 223: 224: 225: 226: 227: 228: 229: 230: 231: 232: 233: 234: 235: 236: 237: 238: 239: 240: 241: 242: 243: 244: 245: 246: 247: 248: 249: 250: 251: 252: 253: 254: 255: 256: 257: 258: 259: 260: 261: 262: 263: 264: 265: 266: 267: 268: 269: 270: 271: 272: 273: 274: 275: 276: 277: 278: 279: 280: 281: 282: 283: 284: 285: 286: 287: 288: 289: 290: 291: 292: 293: 294: 295: 296: 297: 298: 299: 300: 301: 302: 303: 304: 305: 306: 307: 308: 309: 310: 311: 312: 313: 314: 315: 316: 317: 318: 319: 320: 321: 322: 323: 324: 325: 326: 327: 328: 329: 330: 331: 332: 333: 334: 335: 336: 337: 338: 339: 340: 341: 342: 343: 344: 345: 346: 347: 348: 349: 350: 351: 352: 353: 354: 355: 356: 357: 358: 359: 360: 361: 362: 363: 364: 365: 366: 367: 368: 369: 370: 371: 372: 373: 374: 375: 376: 377: 378: 379: 380: 381: 382: 383: 384: 385: 386: 387: 388: 389: 390: 391: 392: 393: 394: 395: 396: 397: 398: 399: 400: 401: 402: 403: 404: 405: 406: 407: 408: 409: 410: 411: 412: 413: 414: 415: 416: 417: 418: 419: 420: 421: 422: 423: 424: 425: 426: 427: 428: 429: 430: 431: 432: 433: 434: 435: 436: 437: 438: 439: 440: 441: 442: 443: 444: 445: 446: 447: 448: 449: 450: 451: 452: 453: 454: 455: 456: 457: 458: 459: 460: 461: 462: 463: 464: 465: 466: 467: 468: 469: 470: 471: 472: 473: 474: 475: 476: 477: 478: 479: 480: 481: 482: 483: 484: 485: 486: 487: 488: 489: 490: 491: 492: 493: 494: 495: 496: 497: 498: 499: 500: 501: 502: 503: 504: 505: 506: 507: 508: 509: 510: 511: 512: 513: 514: 515: 516: 517: 518: 519: 520: 521: 522: 523: 524: 525: 526: 527: 528: 529: 530: 531: 532: 533: 534: 535: 536: 537: 538: 539: 540: 541: 542: 543: 544: 545: 546: 547: 548: 549: 550: 551: 552: 553: 554: 555: 556: 557: 558: 559: 560: 561: 562: 563: 564: 565: 566: 567: 568: 569: 570: 571: 572: 573: 574: 575: 576: 577: 578: 579: 580: 581: 582: 583: 584: 585: 586: 587: 588: 589: 590: 591: 592: 593: 594: 595: 596: 597: 598: 599: 600: 601: 602: 603: 604: 605: 606: 607: 608: 609: 610: 611: 612: 613: 614: 615: 616: 617: 618: 619: 620: 621: 622: 623: 624: 625: 626: 627: 628: 629: 630: 631: 632: 633: 634: 635: 636: 637: 638: 639: 640: 641: 642: 643: 644: 645: 646: 647: 648: 649: 650: 651: 652: 653: 654: 655: 656: 657: 658: 659: 660: 661: 662: 663: 664: 665: 666: 667: 668: 669: 670: 671: 672: 673: 674: 675: 676: 677: 678: 679: 680: 681: 682: 683: 684: 685: 686: 687: 688: 689: 690: 691: 692: 693: 694: 695: 696: 697: 698: 699: 700: 701: 702: 703: 704: 705: 706: 707: 708: 709: 710: 711: 712: 713: 714: 715: 716: 717: 718: 719: 720: 721: 722: 723: 724: 725: 726: 727: 728: 729: 730: 731: 732: 733: 734: 735: 736: 737: 738: 739: 740: 741: 742: 743: 744: 745: 746: 747: 748: 749: 750: 751: 752: 753: 754: 755: 756: 757: 758: 759: 760: 761: 762: 763: 764: 765: 766: 767: 768: 769: 770: 771: 772: 773: 774: 775: 776: 777: 778: 779: 780: 781: 782: 783: 784: 785: 786: 787: 788: 789: 790: 791: 792: 793: 794: 795: 796: 797: 798: 799: 800: 801: 802: 803: 804: 805: 806: 807: 808: 809: 810: 811: 812: 813: 814: 815: 816: 817: 818: 819: 820: 821: 822: 823: 824: 825: 826: 827: 828: 829: 830: 831: 832: 833: 834: 835: 836: 837: 838: 839: 840: 841: 842: 843: 844: 845: 846: 847: 848: 849: 850: 851: 852: 853: 854: 855: 856: 857: 858: 859: 860: 861: 862: 863: 864: 865: 866: 867: 868: 869: 870: 871: 872: 873: 874: 875: 876: 877: 878: 879: 880: 881: 882: 883: 884: 885: 886: 887: 888: 889: 890: 891: 892: 893: 894: 895: 896: 897: 898: 899: 900: 901: 902: 903: 904: 905: 906: 907: 908: 909: 910: 911: 912: 913: 914: 915: 916: 917: 918: 919: 920: 921: 922: 923: 924: 925: 926: 927: 928: 929: 930: 931: 932: 933: 934: 935: 936: 937: 938: 939: 940: 941: 942: 943: 944: 945: 946: 947: 948: 949: 950: 951: 952: 953: 954: 955: 956: 957: 958: 959: 960: 961: 962: 963: 964: 965: 966: 967: 968: 969: 970: 971: 972: 973: 974: 975: 976: 977: 978: 979: 980: 981: 982: 983: 984: 985: 986: 987: 988: 989: 990: 991: 992: 993: 994: 995: 996: 997: 998: 999: 1000: 1001: 1002: 1003: 1004: 1005: 1006: 1007: 1008: 1009: 1010: 1011: 1012: 1013: 1014: 1015: 1016: 1017: 1018: 1019: 1020: 1021: 1022: 1023: 1024: 1025: 1026: 1027: 1028: 1029: 1030: 1031: 1032: 1033: 1034: 1035: 1036: 1037: 1038: 1039: 1040: 1041: 1042: 1043: 1044: 1045: 1046: 1047: 1048: 1049: 1050: 1051: 1052: 1053: 1054: 1055: 1056: 1057: 1058: 1059: 1060: 1061: 1062: 1063: 1064: 1065: 1066: 1067: 1068: 1069: 1070: 1071: 1072: 1073: 1074: 1075: 1076: 1077: 1078: 1079: 1080: 1081: 1082: 1083: 1084: 1085: 1086: 1087: 1088: 1089: 1090: 1091: 1092: 1093: 1094: 1095: 1096: 1097: 1098: 1099: 1100: 1101: 1102: 1103: 1104: 1105: 1106: 1107: 1108: 1109: 1110: 1111: 1112: 1113: 1114: 1115: 1116: 1117: 1118: 1119: 1120: 1121: 1122: 1123: 1124: 1125: 1126: 1127: 1128: 1129: 1130: 1131: 1132: 1133: 1134: 1135: 1136: 1137: 1138: 1139: 1140: 1141: 1142: 1143: 1144: 1145: 1146: 1147: 1148: 1149: 1150: 1151: 1152: 1153: 1154: 1155: 1156: 1157: 1158: 1159: 1160: 1161: 1162: 1163: 1164: 1165: 1166: 1167: 1168: 1169: 1170: 1171: 1172: 1173: 1174: 1175: 1176: 1177: 1178: 1179: 1180: 1181: 1182: 1183: 1184: 1185: 1186: 1187: 1188: 1189: 1190: 1191: 1192: 1193: 1194: 1195: 1196: 1197: 1198: 1199: 1200: 1201: 1202: 1203: 1204: 1205: 1206: 1207: 1208: 1209: 1210: 1211: 1212: 1213: 1214: 1215: 1216: 1217: 1218: 1219: 1220: 1221: 1222: 1223: 1224: 1225: 1226: 1227: 1228: 1229: 1230: 1231: 1232: 1233: 1234: 1235: 1236: 1237: 1238: 1239: 1240: 1241: 1242: 1243: 1244: 1245: 1246: 1247: 1248: 1249: 1250: 1251: 1252: 1253: 1254: 1255: 1256: 1257: 1258: 1259: 1260: 1261: 1262: 1263: 1264: 1265: 1266: 1267: 1268: 1269: 1270: 1271: 1272: 1273: 1274: 1275: 1276: 1277: 1278: 1279: 1280: 1281: 1282: 1283: 1284: 1285: 1286: 1287: 1288: 1289: 1290: 1291: 1292: 1293: 1294: 1295: 1296: 1297: 1298: 1299: 1300: 1301: 1302: 1303: 1304: 1305: 1306: 1307: 1308: 1309: 1310: 1311: 1312: 1313: 1314: 1315: 1316: 1317: 1318: 1319: 1320: 1321: 1322: 1323: 1324: 1325: 1326: 1327: 1328: 1329: 1330: 1331: 1332: 1333: 1334: 1335: 1336: 1337: 1338: 1339: 1340: 1341: 1342: 1343: 1344: 1345: 1346: 1347: 1348: 1349: 1350: 1351: 1352: 1353: 1354: 1355: 1356: 1357: 1358: 1359: 1360: 1361: 1362: 1363: 1364: 1365: 1366: 1367: 1368: 1369: 1370: 1371: 1372: 1373: 1374: 1375: 1376: 1377: 1378: 1379: 1380: 1381: 1382: 1383: 1384: 1385: 1386: 1387: 1388: 1389: 1390: 1391: 1392: 1393: 1394: 1395: 1396: 1397: 1398: 1399: 1400: 1401: 1402: 1403: 1404: 1405: 1406: 1407: 1408: 1409: 1410: 1411: 1412: 1413: 1414: 1415: 1416: 1417: 1418: 1419: 1420: 1421: 1422: 1423: 1424: 1425: 1426: 1427: 1428: 1429: 1430: 1431: 1432: 1433: 1434: 1435: 1436: 1437: 1438: 1439: 1440: 1441: 1442: 1443: 1444: 1445: 1446: 1447: 1448: 1449: 1450: 1451: 1452: 1453: 1454: 1455: 1456: 1457: 1458: 1459: 1460: 1461: 1462: 1463: 1464: 1465: 1466: 1467: 1468: 1469: 1470: 1471: 1472: 1473: 1474: 1475: 1476: 1477: 1478: 1479: 1480: 1481: 1482: 1483: 1484: 1485: 1486: 1487: 1488: 1489: 1490: 1491: 1492: 1493: 1494: 1495: 1496: 1497: 1498: 1499: 1500: 1501: 1502: 1503: 1504: 1505: 1506: 1507: 1508: 1509: 1510: 1511: 1512: 1513: 1514: 1515: 1516: 1517: 1518: 1519: 1520: 1521: 1522: 1523: 1524: 1525: 1526: 1527: 1528: 1529: 1530: 1531: 1532: 1533: 1534: 1535: 1536: 1537: 1538: 1539: 1540: 1541: 1542: 1543: 1544: 1545: 1546: 1547: 1548: 1549: 1550: 1551: 1552: 1553: 1554: 1555: 1556: 1557: 1558: 1559: 1560: 1561: 1562: 1563: 1564: 1565: 1566: 1567: 1568: 1569: 1570: 1571: 1572: 1573: 1574: 1575: 1576: 1577: 1578: 1579: 1580: 1581: 1582: 1583: 1584: 1585: 1586: 1587: 1588: 1589: 1590: 1591: 1592: 1593: 1594: 1595: 1596: 1597: 1598: 1599: 1600: 1601: 1602: 1603: 1604: 1605: 1606: 1607: 1608: 1609: 1610: 1611: 1612: 1613: 1614: 1615: 1616: 1617: 1618: 1619: 1620: 1621: 1622: 1623: 1624: 1625: 1626: 1627: 1628: 1629: 1630: 1631: 1632: 1633: 1634: 1635: 1636: 1637: 1638: 1639: 1640: 1641: 1642: 1643: 1644: 1645: 1646: 1647: 1648: 1649: 1650: 1651: 1652: 1653: 1654: 1655: 1656: 1657: 1658: 1659: 1660: 1661: 1662: 1663: 1664: 1665: 1666: 1667: 1668: 1669: 1670: 1671: 1672: 1673: 1674: 1675: 1676: 1677: 1678: 1679: 1680: 1681: 1682: 1683: 1684: 1685: 1686: 1687: 1688: 1689: 1690: 1691: 1692: 1693: 1694: 1695: 1696: 1697: 1698: 1699: 1700: 1701: 1702: 1703: 1704: 1705: 1706: 1707: 1708: 1709: 1710: 1711: 1712: 1713: 1714: 1715: 1716: 1717: 1718: 1719: 1720: 1721: 1722: 1723: 1724: 1725: 1726: 1727: 1728: 1729: 1730: 1731: 1732: 1733: 1734: 1735: 1736: 1737: 1738: 1739: 1740: 1741: 1742: 1743: 1744: 1745: 1746: 1747: 1748: 1749: 1750: 1751: 1752: 1753: 1754: 1755: 1756: 1757: 1758: 1759: 1760: 1761: 1762: 1763: 1764: 1765: 1766: 1767: 1768: 1769: 1770: 1771: 1772: 1773: 1774: 1775: 1776: 1777: 1778: 1779: 1780: 1781: 1782: 1783: 1784: 1785: 1786: 1787: 1788: 1789: 1790: 1791: 1792: 1793: 1794: 1795: 1796: 1797: 1798: 1799: 1800: 1801: 1802: 1803: 1804: 1805: 1806: 1807: 1808: 1809: 1810: 1811: 1812: 1813: 1814: 1815: 1816: 1817: 1818: 1819: 1820: 1821: 1822: 1823: 1824: 1825: 1826: 1827: 1828: 1829: 1830: 1831: 1832: 1833: 1834: 1835: 1836: 1837: 1838: 1839: 1840: 1841: 1842: 1843: 1844: 1845: 1846: 1847: 1848: 1849: 1850: 1851: 1852: 1853: 1854: 1855: 1856: 1857: 1858: 1859: 1860: 1861: 1862: 1863: 1864: 1865: 1866: 1867: 1868: 1869: 1870: 1871: 1872: 1873: 1874: 1875: 1876: 1877: 1878: 1879: 1880: 1881: 1882: 1883: 1884: 1885: 1886: 1887: 1888: 1889: 1890: 1891: 1892: 1893: 1894: 1895: 1896: 1897: 1898: 1899: 1900: 1901: 1902: 1903: 1904: 1905: 1906: 1907: 1908: 1909: 1910: 1911: 1912: 1913: 1914: 1915: 1916: 1917: 1918: 1919: 1920: 1921: 1922: 1923: 1924: 1925: 1926: 1927: 1928: 1929: 1930: 1931: 1932: 1933: 1934: 1935: 1936: 1937: 1938: 1939: 1940: 1941: 1942: 1943: 1944: 1945: 1946: 1947: 1948: 1949: 1950: 1951: 1952: 1953: 1954: 1955: 1956: 1957: 1958: 1959: 1960: 1961: 1962: 1963: 1964: 1965: 1966: 1967: 1968: 1969: 1970: 1971: 1972: 1973: 1974: 1975: 1976: 1977: 1978: 1979: 1980: 1981: 1982: 1983: 1984: 1985: 1986: 1987: 1988: 1989: 1990: 1991: 1992: 1993: 1994: 1995: 1996: 1997: 1998: 1999: 2000: 2001: 2002: 2003: 2004: 2005: 2006: 2007: 2008: 2009: 2010: 2011: 2012: 2013: 2014: 2015: 2016: 2017: 2018: 2019: 2020: 2021: 2022: 2023: 2024: 2025: 2026: 2027: 2028: 2029: 2030: 2031: 2032: 2033: 2034: 2035: 2036: 2037: 2038: 2039: 2040: 2041: 2042: 2043: 2044: 2045: 2046: 2047: 2048: 2049: 2050: 2051: 2052: 2053: 2054: 2055: 2056: 2057: 2058: 2059: 2060: 2061: 2062: 2063: 2064: 2065: 2066: 2067: 2068: 2069: 2070: 2071: 2072: 2073: 2074: 2075: 2076: 2077: 2078: 2079: 2080: 2081: 2082: 2083: 2084: 2085: 2086: 2087: 2088: 2089: 2090: 2091: 2092: 2093: 2094: 2095: 2096: 2097: 2098: 2099: 2100: 2101: 2102: 2103: 2104: 2105: 2106: 2107: 2108: 2109: 2110: 2111: 2112: 2113: 2114: 2115: 2116: 2117: 2118: 2119: 2120: 2121: 2122: 2123: 2124: 2125: 2126: 2127: 2128: 2129: 2130: 2131: 2132: 2133: 2134: 2135: 2136: 2137: 2138: 2139: 2140: 2141: 2142: 2143: 2144: 2145: 2146: 2147: 2148: 2149: 2150: 2151: 2152: 2153: 2154: 2155: 2156: 2157: 2158: 2159: 2160: 2161: 2162: 2163: 2164: 2165: 2166: 2167: 2168: 2169: 2170: 2171: 2172: 2173: 2174: 2175: 2176: 2177: 2178: 2179: 2180: 2181: 2182: 2183: 2184: 2185: 2186: 2187: 2188: 2189: 2190: 2191: 2192: 2193: 2194: 2195: 2196: 2197: 2198: 2199: 2200: 2201: 2202: 2203: 2204: 2205: 2206: 2207: 2208: 2209: 2210: 2211: 2212: 2213: 2214: 2215: 2216: 2217: 2218: 2219: 2220: 2221: 2222: 2223: 2224: 2225: 2226: 2227: 2228: 2229: 2230: 2231: 2232: 2233: 2234: 2235: 2236: 2237: 2238: 2239: 2240: 2241: 2242: 2243: 2244: 2245: 2246: 2247: 2248: 2249: 2250: 2251: 2252: 2253: 2254: 2255: 2256: 2257: 2258: 2259: 2260: 2261: 2262: 2263: 2264: 2265: 2266: 2267: 2268: 2269: 2270: 2271: 2272: 2273: 2274: 2275: 2276: 2277: 2278: 2279: 2280: 2281: 2282: 2283: 2284: 2285: 2286: 2287: 2288: 2289: 2290: 2291: 2292: 2293: 2294: 2295: 2296: 2297: 2298: 2299: 2300: 2301: 2302: 2303: 2304: 2305: 2306: 2307: 2308: 2309: 2310: 2311: 2312: 2313: 2314: 2315: 2316: 2317: 2318: 2319: 2320: 2321: 2322: 2323: 2324: 2325: 2326: 2327: 2328: 2329: 2330: 2331: 2332: 2333: 2334: 2335: 2336: 2337: 2338: 2339: 2340: 2341: 2342: 2343: 2344: 2345: 2346: 2347: 2348: 2349: 2350: 2351: 2352: 2353: 2354: 2355: 2356: 2357: 2358: 2359: 2360: 2361: 2362: 2363: 2364: 2365: 2366: 2367: 2368: 2369: 2370: 2371: 2372: 2373: 2374: 2375: 2376: 2377: 2378: 2379: 2380: 2381: 2382: 2383: 2384: 2385: 2386: 2387: 2388: 2389: 2390: 2391: 2392: 2393: 2394: 2395: 2396: 2397: 2398: 2399: 2400: 2401: 2402: 2403: 2404: 2405: 2406: 2407: 2408: 2409: 2410: 2411: 2412: 2413: 2414: 2415: 2416: 2417: 2418: 2419: 2420: 2421: 2422: 2423: 2424: 2425: 2426: 2427: 2428: 2429: 2430: 2431: 2432: 2433: 2434: 2435: 2436: 2437: 2438: 2439: 2440: 2441: 2442: 2443: 2444: 2445: 2446: 2447: 2448: 2449: 2450: 2451: 2452: 2453: 2454: 2455: 2456: 2457: 2458: 2459: 2460: 2461: 2462: 2463: 2464: 2465: 2466: 2467: 2468: 2469: 2470: 2471: 2472: 2473: 2474: 2475: 2476: 2477: 2478: 2479: 2480: 2481: 2482: 2483: 2484: 2485: 2486: 2487: 2488: 2489: 2490: 2491: 2492: 2493: 2494: 2495: 2496: 2497: 2498: 2499: 2500: 2501: 2502: 2503: 2504: 2505: 2506: 2507: 2508: 2509: 2510: 2511: 2512: 2513: 2514: 2515: 2516: 2517: 2518: 2519: 2520: 2521: 2522: 2523: 2524: 2525: 2526: 2527: 2528: 2529: 2530: 2531: 2532: 2533: 2534: 2535: 2536: 2537: 2538: 2539: 2540: 2541: 2542: 2543: 2544: 2545: 2546: 2547: 2548: 2549: 2550: 2551: 2552: 2553: 2554: 2555: 2556: 2557: 2558: 2559: 2560: 2561: 2562: 2563: 2564: 2565: 2566: 2567: 2568: 2569: 2570: 2571: 2572: 2573: 2574: 2575: 2576: 2577: 2578: 2579: 2580: 2581: 2582: 2583: 2584: 2585: 2586: 2587: 2588: 2589: 2590: 2591: 2592: 2593: 2594: 2595: 2596: 2597: 2598: 2599: 2600: 2601: 2602: 2603: 2604: 2605: 2606: 2607: 2608: 2609: 2610: 2611: 2612: 2613: 2614: 2615: 2616: 2617: 2618: 2619: 2620: 2621: 2622: 2623: 2624: 2625: 2626: 2627: 2628: 2629: 2630: 2631: 2632: 2633: 2634: 2635: 2636: 2637: 2638: 2639: 2640: 2641: 2642: 2643: 2644: 2645: 2646: 2647: 2648: 2649: 2650: 2651: 2652: 2653: 2654: 2655: 2656: 2657: 2658: 2659: 2660: 2661: 2662: 2663: 2664: 2665: 2666: 2667: 2668: 2669: 2670: 2671: 2672: 2673: 2674: 2675: 2676: 2677: 2678: 2679: 2680: 2681: 2682: 2683: 2684: 2685: 2686: 2687: 2688: 2689: 2690: 2691: 2692: 2693: 2694: 2695: 2696: 2697: 2698: 2699: 2700: 2701: 2702: 2703: 2704: 2705: 2706: 2707: 2708: 2709: 2710: 2711: 2712: 2713: 2714: 2715: 2716: 2717: 2718: 2719: 2720: 2721: 2722: 2723: 2724: 2725: 2726: 2727: 2728: 2729: 2730: 2731: 2732: 2733: 2734: 2735: 2736: 2737: 2738: 2739: 2740: 2741: 2742: 2743: 2744: 2745: 2746: 2747: 2748: 2749: 2750: 2751: 2752: 2753: 2754: 2755: 2756: 2757: 2758: 2759: 2760: 2761: 2762: 2763: 2764: 2765: 2766: 2767: 2768: 2769: 2770: 2771: 2772: 2773: 2774: 2775: 2776: 2777: 2778: 2779: 2780: 2781: 2782: 2783: 2784: 2785: 2786: 2787: 2788: 2789: 2790: 2791: 2792: 2793: 2794: 2795: 2796: 2797: 2798: 2799: 2800: 2801: 2802: 2803: 2804: 2805: 2806: 2807: 2808: 2809: 2810: 2811: 2812: 2813: 2814: 2815: 2816: 2817: 2818: 2819: 2820: 2821: 2822: 2823: 2824: 2825: 2826: 2827: 2828: 2829: 2830: 2831: 2832: 2833: 2834: 2835: 2836: 2837: 2838: 2839: 2840: 2841: 2842: 2843: 2844: 2845: 2846: 2847: 2848: 2849: 2850: 2851: 2852: 2853: 2854: 2855: 2856: 2857: 2858: 2859: 2860: 2861: 2862: 2863: 2864: 2865: 2866: 2867: 2868: 2869: 2870: 2871: 2872: 2873: 2874: 2875: 2876: 2877: 2878: 2879: 2880: 2881: 2882: 2883: 2884: 2885: 2886: 2887: 2888: 2889: 2890: 2891: 2892: 2893: 2894: 2895: 2896: 2897: 2898: 2899: 2900: 2901: 2902: 2903: 2904: 2905: 2906: 2907: 2908: 2909: 2910: 2911: 2912: 2913: 2914: 2915: 2916: 2917: 2918: 2919: 2920: 2921: 2922: 2923: 2924: 2925: 2926: 2927: 2928: 2929: 2930: 2931: 2932: 2933: 2934: 2935: 2936: 2937: 2938: 2939: 2940: 2941: 2942: 2943: 2944: 2945: 2946: 2947: 2948: 2949: 2950: 2951: 2952: 2953: 2954: 2955: 2956: 2957: 2958: 2959: 2960: 2961: 2962: 2963: 2964: 2965: 2966: 2967: 2968: 2969: 2970: 2971: 2972: 2973: 2974: 2975: 2976: 2977: 2978: 2979: 2980: 2981: 2982: 2983: 2984: 2985: 2986: 2987: 2988: 2989: 2990: 2991: 2992: 2993: 2994: 2995: 2996: 2997: 2998: 2999: 3000: 3001: 3002: 3003: 3004: 3005: 3006: 3007: 3008: 3009: 3010: 3011: 3012: 3013: 3014: 3015: 3016: 3017: 3018: 3019: 3020: 3021: 3022: 3023: 3024: 3025: 3026: 3027: 3028: 3029: 3030: 3031: 3032: 3033: 3034: 3035: 3036: 3037: 3038: 3039: 3040: 3041: 3042: 3043: 3044: 3045: 3046: 3047: 3048: 3049: 3050: 3051: 3052: 3053: 3054: 3055: 3056: 3057: 3058: 3059: 3060: 3061: 3062: 3063: 3064: 3065: 3066: 3067: 3068: 3069: 3070: 3071: 3072: 3073: 3074: 3075: 3076: 3077: 3078: 3079: 3080: 3081: 3082: 3083: 3084: 3085: 3086: 3087: 3088: 3089: 3090: 3091: 3092: 3093: 3094: 3095: 3096: 3097: 3098: 3099: 3100: 3101: 3102: 3103: 3104: 3105: 3106: 3107: 3108: 3109: 3110: 3111: 3112: 3113: 3114: 3115: 3116: 3117: 3118: 3119: 3120: 3121: 3122: 3123: 3124: 3125: 3126: 3127: 3128: 3129: 3130: 3131: 3132: 3133: 3134: 3135: 3136: 3137: 3138: 3139: 3140: 3141: 3142: 3143: 3144: 3145: 3146: 3147: 3148: 3149: 3150: 3151: 3152: 3153: 3154: 3155: 3156: 3157: 3158: 3159: 3160: 3161: 3162: 3163: 3164: 3165: 3166: 3167: 3168: 3169: 3170: 3171: 3172: 3173: 3174: 3175: 3176: 3177: 3178: 3179: 3180: 3181: 3182: 3183: 3184: 3185: 3186: 3187: 3188: 3189: 3190: 3191: 3192: 3193: 3194: 3195: 3196: 3197: 3198: 3199: 3200: 3201: 3202: 3203: 3204: 3205: 3206: 3207: 3208: 3209: 3210: 3211: 3212: 3213: 3214: 3215: 3216: 3217: 3218: 3219: 3220: 3221: 3222: 3223: 3224: 3225: 3226: 3227: 3228: 3229: 3230: 3231: 3232: 3233: 3234: 3235: 3236: 3237: 3238: 3239: 3240: 3241: 3242: 3243: 3244: 3245: 3246: 3247: 3248: 3249: 3250: 3251: 3252: 3253: 3254: 3255: 3256: 3257: 3258: 3259: 3260: 3261: 3262: 3263: 3264: 3265: 3266: 3267: 3268: 3269: 3270: 3271: 3272: 3273: 3274: 3275: 3276: 3277: 3278: 3279: 3280: 3281: 3282: 3283: 3284: 3285: 3286: 3287: 3288: 3289: 3290: 3291: 3292: 3293: 3294: 3295: 3296: 3297: 3298: 3299: 3300: 3301: 3302: 3303: 3304: 3305: 3306: 3307: 3308: 3309: 3310: 3311: 3312: 3313: 3314: 3315: 3316: 3317: 3318: 3319: 3320: 3321: 3322: 3323: 3324: 3325: 3326: 3327: 3328: 3329: 3330: 3331: 3332: 3333: 3334: 3335: 3336: 3337: 3338: 3339: 3340: 3341: 3342: 3343: 3344: 3345: 3346: 3347: 3348: 3349: 3350: 3351: 3352: 3353: 3354: 3355: 3356: 3357: 3358: 3359: 3360: 3361: 3362: 3363: 3364: 3365: 3366: 3367: 3368: 3369: 3370: 3371: 3372: 3373: 3374: 3375: 3376: 3377: 3378: 3379: 3380: 3381: 3382: 3383: 3384: 3385: 3386: 3387: 3388: 3389: 3390: 3391: 3392: 3393: 3394: 3395: 3396: 3397: 3398: 3399: 3400: 3401: 3402: 3403: 3404: 3405: 3406: 3407: 3408: 3409: 3410: 3411: 3412: 3413: 3414: 3415: 3416: 3417: 3418: 3419: 3420: 3421: 3422: 3423: 3424: 3425: 3426: 3427: 3428: 3429: 3430: 3431: 3432: 3433: 3434: 3435: 3436: 3437: 3438: 3439: 3440: 3441: 3442: 3443: 3444: 3445: 3446: 3447: 3448: 3449: 3450: 3451: 3452: 3453: 3454: 3455: 3456: 3457: 3458: 3459: 3460: 3461: 3462: 3463: 3464: 3465: 3466: 3467: 3468: 3469: 3470: 3471: 3472: 3473: 3474: 3475: 3476: 3477: 3478: 3479: 3480: 3481: 3482: 3483: 3484: 3485: 3486: 3487: 3488: 3489: 3490: 3491: 3492: 3493: 3494: 3495: 3496: 3497: 3498: 3499: 3500: 3501: 3502: 3503: 3504: 3505: 3506: 3507: 3508: 3509: 3510: 3511: 3512: 3513: 3514: 3515: 3516: 3517: 3518: 3519: 3520: 3521: 3522: 3523: 3524: 3525: 3526: 3527: 3528: 3529: 3530: 3531: 3532: 3533: 3534: 3535: 3536: 3537: 3538: 3539: 3540: 3541: 3542: 3543: 3544: 3545: 3546: 3547: 3548: 3549: 3550: 3551: 3552: 3553: 3554: 3555: 3556: 3557: 3558: 3559: 3560: 3561: 3562: 3563: 3564: 3565: 3566: 3567: 3568: 3569: 3570: 3571: 3572: 3573: 3574: 3575: 3576: 3577: 3578: 3579: 3580: 3581: 3582: 3583: 3584: 3585: 3586: 3587: 3588: 3589: 3590: 3591: 3592: 3593: 3594: 3595: 3596: 3597: 3598: 3599: 3600: 3601: 3602: 3603: 3604: 3605: 3606: 3607: 3608: 3609: 3610: 3611: 3612: 3613: 3614: 3615: 3616: 3617: 3618: 3619: 3620: 3621: 3622: 3623: 3624: 3625: 3626: 3627: 3628: 3629: 3630: 3631: 3632: 3633: 3634: 3635: 3636: 3637: 3638: 3639: 3640: 3641: 3642: 3643: 3644: 3645: 3646: 3647: 3648: 3649: 3650: 3651: 3652: 3653: 3654: 3655: 3656: 3657: 3658: 3659: 3660: 3661: 3662: 3663: 3664: 3665: 3666: 3667: 3668: 3669: 3670: 3671: 3672: 3673: 3674: 3675: 3676: 3677: 3678: 3679: 3680: 3681: 3682: 3683: 3684: 3685: 3686: 3687: 3688: 3689: 3690: 3691: 3692: 3693: 3694: 3695: 3696: 3697: 3698: 3699: 3700: 3701: 3702: 3703: 3704: 3705: 3706: 3707: 3708: 3709: 3710: 3711: 3712: 3713: 3714: 3715: 3716: 3717: 3718: 3719: 3720: 3721: 3722: 3723: 3724: 3725: 3726: 3727: 3728: 3729: 3730: 3731: 3732: 3733: 3734: 3735: 3736: 3737: 3738: 3739: 3740: 3741: 3742: 3743: 3744: 3745: 3746: 3747: 3748: 3749: 3750: 3751: 3752: 3753: 3754: 3755: 3756: 3757: 3758: 3759: 3760: 3761: 3762: 3763: 3764: 3765: 3766: 3767: 3768: 3769: 3770: 3771: 3772: 3773: 3774: 3775: 3776: 3777: 3778: 3779: 3780: 3781: 3782: 3783: 3784: 3785: 3786: 3787: 3788: 3789: 3790: 3791: 3792: 3793: 3794: 3795: 3796: 3797: 3798: 3799: 3800: 3801: 3802: 3803: 3804: 3805: 3806: 3807: 3808: 3809: 3810: 3811: 3812: 3813: 3814: 3815: 3816: 3817: 3818: 3819: 3820: 3821: 3822: 3823: 3824: 3825: 3826: 3827: 3828: 3829: 3830: 3831: 3832: 3833: 3834: 3835: 3836: 3837: 3838: 3839: 3840: 3841: 3842: 3843: 3844: 3845: 3846: 3847: 3848: 3849: 3850: 3851: 3852: 3853: 3854: 3855: 3856: 3857: 3858: 3859: 3860: 3861: 3862: 3863: 3864: 3865: 3866: 3867: 3868: 3869: 3870: 3871: 3872: 3873: 3874: 3875: 3876: 3877: 3878: 3879: 3880: 3881: 3882: 3883: 3884: 3885: 3886: 3887: 3888: 3889: 3890: 3891: 3892: 3893: 3894: 3895: 3896: 3897: 3898: 3899: 3900: 3901: 3902: 3903: 3904: 3905: 3906: 3907: 3908: 3909: 3910: 3911: 3912: 3913: 3914: 3915: 3916: 3917: 3918: 3919: 3920: 3921: 3922: 3923: 3924: 3925: 3926: 3927: 3928: 3929: 3930: 3931: 3932: 3933: 3934: 3935: 3936: 3937: 3938: 3939: 3940: 3941: 3942: 3943: 3944: 3945: 3946: 3947: 3948: 3949: 3950: 3951: 3952: 3953: 3954: 3955: 3956: 3957: 3958: 3959: 3960: 3961: 3962: 3963: 3964: 3965: 3966: 3967: 3968: 3969: 3970: 3971: 3972: 3973: 3974: 3975: 3976: 3977: 3978: 3979: 3980: 3981: 3982: 3983: 3984: 3985: 3986: 3987: 3988: 3989: 3990: 3991: 3992: 3993: 3994: 3995: 3996: 3997: 3998: 3999: 4000: 4001: 4002: 4003: 4004: 4005: 4006: 4007: 4008: 4009: 4010: 4011: 4012: 4013: 4014: 4015: 4016: 4017: 4018: 4019: 4020: 4021: 4022: 4023: 4024: 4025: 4026: 4027: 4028: 4029: 4030: 4031: 4032: 4033: 4034: 4035: 4036: 4037: 4038: 4039: 4040: 4041: 4042: 4043: 4044: 4045: 4046: 4047: 4048: 4049: 4050: 4051: 4052: 4053: 4054: 4055: 4056: 4057: 4058: 4059: 4060: 4061: 4062: 4063: 4064: 4065: 4066: 4067: 4068: 4069: 4070: 4071: 4072: 4073: 4074: 4075: 4076: 4077: 4078: 4079: 4080: 4081: 4082: 4083: 4084: 4085: 4086: 4087: 4088: 4089: 4090: 4091: 4092: 4093: 4094: 4095: 4096: 4097: 4098: 4099: 4100: 4101: 4102: 4103: 4104: 4105: 4106: 4107: 4108: 4109: 4110: 4111: 4112: 4113: 4114: 4115: 4116: 4117: 4118: 4119: 4120: 4121: 4122: 4123: 4124: 4125: 4126: 4127: 4128: 4129: 4130: 4131: 4132: 4133: 4134: 4135: 4136: 4137: 4138: 4139: 4140: 4141: 4142: 4143: 4144: 4145: 4146: 4147: 4148: 4149: 4150: 4151: 4152: 4153: 4154: 4155: 4156: 4157: 4158: 4159: 4160: 4161: 4162: 4163: 4164: 4165: 4166: 4167: 4168: 4169: 4170: 4171: 4172: 4173: 4174: 4175: 4176: 4177: 4178: 4179: 4180: 4181: 4182: 4183: 4184: 4185: 4186: 4187: 4188: 4189: 4190: 4191: 4192: 4193: 4194: 4195: 4196: 4197: 4198: 4199: 4200: 4201: 4202: 4203: 4204: 4205: 4206: 4207: 4208: 4209: 4210: 4211: 4212: 4213: 4214: 4215: 4216: 4217: 4218: 4219: 4220: 4221: 4222: 4223: 4224: 4225: 4226: 4227: 4228: 4229: 4230: 4231: 4232: 4233: 4234: 4235: 4236: 4237: 4238: 4239: 4240: 4241: 4242: 4243: 4244: 4245: 4246: 4247: 4248: 4249: 4250: 4251: 4252: 4253: 4254: 4255: 4256: 4257: 4258: 4259: 4260: 4261: 4262: 4263: 4264: 4265: 4266: 4267: 4268: 4269: 4270: 4271: 4272: 4273: 4274: 4275: 4276: 4277: 4278: 4279: 4280: 4281: 4282: 4283: 4284: 4285: 4286: 4287: 4288: 4289: 4290: 4291: 4292: 4293: 4294: 4295: 4296: 4297: 4298: 4299: 4300: 4301: 4302: 4303: 4304: 4305: 4306: 4307: 4308: 4309: 4310: 4311: 4312: 4313: 4314: 4315: 4316: 4317: 4318: 4319: 4320: 4321: 4322: 4323: 4324: 4325: 4326: 4327: 4328: 4329: 4330: 4331: 4332: 4333: 4334: 4335: 4336: 4337: 4338: 4339: 4340: 4341: 4342: 4343: 4344: 4345: 4346: 4347: 4348: 4349: 4350: 4351: 4352: 4353: 4354: 4355: 4356: 4357: 4358: 4359: 4360: 4361: 4362: 4363: 4364: 4365: 4366: 4367: 4368: 4369: 4370: 4371: 4372: 4373: 4374: 4375: 4376: 4377: 4378: 4379: 4380: 4381: 4382: 4383: 4384: 4385: 4386: 4387: 4388: 4389: 4390: 4391: 4392: 4393: 4394: 4395: 4396: 4397: 4398: 4399: 4400: 4401: 4402: 4403: 4404: 4405: 4406: 4407: 4408: 4409: 4410: 4411: 4412: 4413: 4414: 4415: 4416: 4417: 4418: 4419: 4420: 4421: 4422: 4423: 4424: 4425: 4426: 4427: 4428: 4429: 4430: 4431: 4432: 4433: 4434: 4435: 4436: 4437: 4438: 4439: 4440: 4441: 4442: 4443: 4444: 4445: 4446: 4447: 4448: 4449: 4450: 4451: 4452: 4453: 4454: 4455: 4456: 4457: 4458: 4459: 4460: 4461: 4462: 4463: 4464: 4465: 4466: 4467: 4468: 4469: 4470: 4471: 4472: 4473: 4474: 4475: 4476: 4477: 4478: 4479: 4480: 4481: 4482: 4483: 4484: 4485: 4486: 4487: 4488: 4489: 4490: 4491: 4492: 4493: 4494: 4495: 4496: 4497: 4498: 4499: 4500: 4501: 4502: 4503: 4504: 4505: 4506: 4507: 4508: 4509: 4510: 4511: 4512: 4513: 4514: 4515: 4516: 4517: 4518: 4519: 4520: 4521: 4522: 4523: 4524: 4525: 4526: 4527: 4528: 4529: 4530: 4531: 4532: 4533: 4534: 4535: 4536: 4537: 4538: 4539: 4540: 4541: 4542: 4543: 4544: 4545: 4546: 4547: 4548: 4549: 4550: 4551: 4552: 4553: 4554: 4555: 4556: 4557: 4558: 4559: 4560: 4561: 4562: 4563: 4564: 4565: 4566: 4567: 4568: 4569: 4570: 4571: 4572: 4573: 4574: 4575: 4576: 4577: 4578: 4579: 4580: 4581: 4582: 4583: 4584: 4585: 4586: 4587: 4588: 4589: 4590: 4591: 4592: 4593: 4594: 4595: 4596: 4597: 4598: 4599: 4600: 4601: 4602: 4603: 4604: 4605: 4606: 4607: 4608: 4609: 4610: 4611: 4612: 4613: 4614: 4615: 4616: 4617: 4618: 4619: 4620: 4621: 4622: 4623: 4624: 4625: 4626: 4627: 4628: 4629: 4630: 4631: 4632: 4633: 4634: 4635: 4636: 4637: 4638: 4639: 4640: 4641: 4642: 4643: 4644: 4645: 4646: 4647: 4648: 4649: 4650: 4651: 4652: 4653: 4654: 4655: 4656: 4657: 4658: 4659: 4660: 4661: 4662: 4663: 4664: 4665: 4666: 4667: 4668: 4669: 4670: 4671: 4672: 4673: 4674: 4675: 4676: 4677: 4678: 4679: 4680: 4681: 4682: 4683: 4684: 4685: 4686: 4687: 4688: 4689: 4690: 4691: 4692: 4693: 4694: 4695: 4696: 4697: 4698: 4699: 4700: 4701: 4702: 4703: 4704: 4705: 4706: 4707: 4708: 4709: 4710: 4711: 4712: 4713: 4714: 4715: 4716: 4717: 4718: 4719: 4720: 4721: 4722: 4723: 4724: 4725: 4726: 4727: 4728: 4729: 4730: 4731: 4732: 4733: 4734: 4735: 4736: 4737: 4738: 4739: 4740: 4741: 4742: 4743: 4744: 4745: 4746: 4747: 4748: 4749: 4750: 4751: 4752: 4753: 4754: 4755: 4756: 4757: 4758: 4759: 4760: 4761: 4762: 4763: 4764: 4765: 4766: 4767: 4768: 4769: 4770: 4771: 4772: 4773: 4774: 4775: 4776: 4777: 4778: 4779: 4780: 4781: 4782: 4783: 4784: 4785: 4786: 4787: 4788: 4789: 4790: 4791: 4792: 4793: 4794: 4795: 4796: 4797: 4798: 4799: 4800: 4801: 4802: 4803: 4804: 4805: 4806: 4807: 4808: 4809: 4810: 4811: 4812: 4813: 4814: 4815: 4816: 4817: 4818: 4819: 4820: 4821: 4822: 4823: 4824: 4825: 4826: 4827: 4828: 4829: 4830: 4831: 4832: 4833: 4834: 4835: 4836: 4837: 4838: 4839: 4840: 4841: 4842: 4843: 4844: 4845: 4846: 4847: 4848: 4849: 4850: 4851: 4852: 4853: 4854: 4855: 4856: 4857: 4858: 4859: 4860: 4861: 4862: 4863: 4864: 4865: 4866: 4867: 4868: 4869: 4870: 4871: 4872: 4873: 4874: 4875: 4876: 4877: 4878: 4879: 4880: 4881: 4882: 4883: 4884: 4885: 4886: 4887: 4888: 4889: 4890: 4891: 4892: 4893: 4894: 4895: 4896: 4897: 4898: 4899: 4900: 4901: 4902: 4903: 4904: 4905: 4906: 4907: 4908: 4909: 4910: 4911: 4912: 4913: 4914: 4915: 4916: 4917: 4918: 4919: 4920: 4921: 4922: 4923: 4924: 4925: 4926: 4927: 4928: 4929: 4930: 4931: 4932: 4933: 4934: 4935: 4936: 4937: 4938: 4939: 4940: 4941: 4942: 4943: 4944: 4945: 4946: 4947: 4948: 4949: 4950: 4951: 4952: 4953: 4954: 4955: 4956: 4957: 4958: 4959: 4960: 4961: 4962: 4963: 4964: 4965: 4966: 4967: 4968: 4969: 4970: 4971: 4972: 4973: 4974: 4975: 4976: 4977: 4978: 4979: 4980: 4981: 4982: 4983: 4984: 4985: 4986: 4987: 4988: 4989: 4990: 4991: 4992: 4993: 4994: 4995: 4996: 4997: 4998: 4999: 5000: 5001: 5002: 5003: 5004: 5005: 5006: 5007: 5008: 5009: 5010: 5011: 5012: 5013: 5014: 5015: 5016: 5017: 5018: 5019: 5020: 5021: 5022: 5023: 5024: 5025: 5026: 5027: 5028: 5029: 5030: 5031: 5032: 5033: 5034: 5035: 5036: 5037: 5038: 5039: 5040: 5041: 5042: 5043: 5044: 5045: 5046: 5047: 5048: 5049: 5050: 5051: 5052: 5053: 5054: 5055: 5056: 5057: 5058: 5059: 5060: 5061: 5062: 5063: 5064: 5065: 5066: 5067: 5068: 5069: 5070: 5071: 5072: 5073: 5074: 5075: 5076: 5077: 5078: 5079: 5080: 5081: 5082: 5083: 5084: 5085: 5086: 5087: 5088: 5089: 5090: 5091: 5092: 5093: 5094: 5095: 5096: 5097: 5098: 5099: 5100: 5101: 5102: 5103: 5104: 5105: 5106: 5107: 5108: 5109: 5110: 5111: 5112: 5113: 5114: 5115: 5116: 5117: 5118: 5119: 5120: 5121: 5122: 5123: 5124: 5125: 5126: 5127: 5128:
<?php
require_once(__DIR__ . '/' . 'common.php');
class APIException extends Exception { }
class APIAccessException extends Exception { }
class APIStatusException extends Exception { }
class APIAuthTokenException extends Exception { }
class LegiScan
{
const VERSION = '1.4.1';
const SCHEMA_VERSION = 9;
const API_OK = 'OK';
const API_ERROR = 'ERROR';
const IMPORT_NONE = 0;
const IMPORT_NEW = 1;
const IMPORT_CHANGED = 2;
const IMPORT_ALL = 3;
const STANCE_WATCH = 0;
const STANCE_SUPPORT = 1;
const STANCE_OPPOSE = 2;
static function getConfig($key = null, $default = null)
{
static $config = array();
if (empty($config))
$config = parse_ini_file(realpath(__DIR__ . '/' . 'config.php'));
if ($key !== null)
{
if (isset($config[$key]))
{
return $config[$key];
}
else
{
if ($default !== null)
return $default;
else
return null;
}
}
else
{
return $config;
}
}
static function fileLog($msg, $file = null)
{
static $log_dir;
if (!isset($log_dir))
{
$log_dir = LegiScan::getConfig('log_dir');
if ($log_dir[0] != '/' || $log_dir[1] != ':')
$log_dir = realpath(__DIR__ . '/' . $log_dir);
if (!is_dir($log_dir))
throw new APIAccessException("Log directory does not exist: " . LegiScan::getConfig('log_dir'));
}
$log_file = $log_dir . '/' . 'legiscan.log';
if ($file !== null)
$log_file = $log_dir . '/' . $file;
if (($fd = @fopen($log_file, 'a+')) !== false)
{
$msg = rtrim($msg);
$ts = strftime('[%Y/%m/%d %H:%M:%S]');
fwrite($fd, $ts . ' ' . $msg . "\n");
fclose($fd);
}
else
{
throw new APIAccessException("Cannot open log file for writing: $log_file");
}
}
static function sendMail($subject, $body)
{
static $last_sent;
static $throttle_warning = false;
if (!isset($last_sent))
{
$last_sent = time();
$throttled = false;
}
else
{
$throttled = (bool) ((time() - $last_sent) <= 300);
}
$email = LegiScan::getConfig('email');
$header = "From: LegiScan API <$email>";
if ($email && $email === filter_var($email, FILTER_VALIDATE_EMAIL) && !$throttled)
{
mail($email, $subject, $body, $header);
$last_sent = time();
$throttle_warning = false;
}
elseif ($throttled)
{
if (!$throttle_warning)
{
$body = "Mail has been throttled for the next 5 minutes, please see legiscan.log for more messages\n\n$body";
mail($email, "Throttled: $subject", $body, $header);
$throttle_warning = true;
}
else
{
LegiScan::fileLog("Mail throttled [$subject] " . str_replace("\n", '\\n', $body));
}
}
}
static function getVersion()
{
return self::VERSION;
}
}
class LegiScan_Cache_File
{
const TYPE_API = 1;
const TYPE_DOC = 2;
const LIFETIME = 3600;
private $lifetime;
private $cache_type;
private $cache_dir;
function __construct($type, $lifetime = self::LIFETIME)
{
switch ($type)
{
case 'api':
$api_dir = LegiScan::getConfig('api_cache');
if ($api_dir[0] != '/' && $api_dir[1] != ':')
$api_dir = realpath(__DIR__ . '/' . $api_dir);
$this->cache_dir = $api_dir;
if (!file_exists($this->cache_dir) || !is_dir($this->cache_dir))
throw new APIAccessException("LegiScan_Cache(): Invalid api cache directory: " . $this->cache_dir);
$this->cache_type = self::TYPE_API;
$this->lifetime = $lifetime;
break;
case 'doc':
$doc_dir = LegiScan::getConfig('doc_cache');
if ($doc_dir[0] != '/' && $doc_dir[1] != ':')
$doc_dir = realpath(__DIR__ . '/' . $doc_dir);
$this->cache_dir = $doc_dir;
if (!file_exists($this->cache_dir) || !is_dir($this->cache_dir))
throw new APIAccessException("LegiScan_Cache(): Invalid document cache directory: " . $this->cache_dir);
$this->cache_type = self::TYPE_DOC;
$this->lifetime = null;
break;
}
}
public function get($file, $lifetime = null)
{
$filename = $this->cache_dir . '/' . $file;
if (!file_exists($filename))
return false;
if ($this->cache_type == self::TYPE_API)
{
if ($lifetime === null)
$lifetime = $this->lifetime;
if (filemtime($filename) > (time() - $lifetime))
$data = file_get_contents($filename);
else
$data = false;
}
else
{
$data = file_get_contents($filename);
}
return $data;
}
public function set($file, $data)
{
$filename = $this->cache_dir . '/' . $file;
$dirname = dirname($filename);
if (!file_exists($dirname))
{
if (!@mkdir($dirname, 0777, true))
throw new APIAccessException("Cannot create directory $dirname");
}
if (@file_put_contents($filename, $data) !== false)
return true;
else
throw new APIAccessException("Cannot write $filename");
}
public function clean($verbose = false)
{
$result = true;
$subdirs = array(
'amendment',
'datasetlist',
'bill',
'masterlist',
'people',
'rollcall',
'search',
'sessionlist',
'supplement',
'text',
);
$size = 0;
$count = 0;
if ($this->cache_type == self::TYPE_API)
{
$dir = $this->cache_dir;
if (!($dh = opendir($dir))) {
throw new Exception("clean(): Unable to open API cache directory $dir");
}
while (($file = readdir($dh)) !== false)
{
if ($file != '.' && $file != '..' && in_array($file, $subdirs))
{
$dir2 = $dir . '/' . $file;
if (is_dir($dir2))
{
if (!($dh2 = opendir($dir2)))
throw new APIAccessException("clean(): Unable to open API cache directory $dir2");
while (($file2 = readdir($dh2)) !== false)
{
if ($file2 != '.' && $file2 != '..' && substr($file2, -4) == 'json')
{
$file2 = $dir2 . '/' . $file2;
if ((time() - @filemtime($file2)) > $this->lifetime)
{
if ($verbose) echo "Unlink $file2\n";
$stat = stat($file2);
$size += $stat['size'];
$result = ($result and (@unlink($file2)));
$count++;
}
}
}
}
closedir($dh2);
}
}
closedir($dh);
}
if ($verbose)
echo number_format($size) . ' bytes cleaned in ' . number_format($count) . " files\n";
return $result;
}
}
class LegiScan_Cache_Memory
{
const LIFETIME = 3600;
private static $lifetime;
private static $cache;
private static $instance;
private function __construct($lifetime)
{
self::$cache = array();
self::$lifetime = $lifetime;
}
public static function getInstance($lifetime = self::LIFETIME)
{
if (!isset(self::$instance))
{
$use_memcache = strtolower(LegiScan::getConfig('use_memcached'));
if ($use_memcache)
{
$memcache_host = LegiScan::getConfig('memcache_host');
$memcache_port = LegiScan::getConfig('memcache_port');
if (class_exists('Memcache', false))
{
self::$instance = new Memcache();
if (!@self::$instance->connect($memcache_host, $memcache_port))
throw new APIException('Could not connect via Memcache to ' . $memcache_host . ':' . $memcache_port);
}
elseif (class_exists('Memcached', false))
{
self::$instance = new Memcached();
self::$instance->addServer($memcache_host, $memcache_port);
if (empty(self::$instance->getVersion()))
throw new APIException('Could not connect via Memcached to ' . $memcache_host . ':' . $memcache_port);
}
else
{
throw new APIException('Missing Memcache/Memcached PHP extension for use_memory_cache = ' . $use_memcache);
}
}
else
{
self::$instance = new LegiScan_Cache_Memory($lifetime);
}
}
return self::$instance;
}
public function get($key)
{
$data = false;
if (isset(self::$cache[$key]) && self::$cache[$key]['expires'] > time())
{
$data = self::$cache[$key]['data'];
}
return $data;
}
public function set($key, $data, $lifetime = self::LIFETIME)
{
self::$cache[$key] = array(
'expires' => time() + $lifetime,
'lifetime' => $lifetime,
'data' => $data,
);
}
public function flush()
{
self::$cache = array();
return true;
}
}
class LegiScan_Push
{
protected $payload;
protected $payload_type;
protected $form_var;
function __construct()
{
$this->form_var = LegiScan::getConfig('push_form_var', 'UNKNOWN');
}
public function processPush()
{
if ($_SERVER['CONTENT_TYPE'] != 'application/x-www-form-urlencoded')
{
$payload = file_get_contents('php://input');
}
else
{
if (isset($_POST[$this->form_var]))
$payload = $_POST[$this->form_var];
else
throw new APIException('processPush expected POST variable [' . $this->form_var . '] is not set');
}
$this->payload = json_decode($payload, true);
if ($this->payload === false)
throw new APIException('processPush could not decode API payload');
if (isset($this->payload['bill']))
$this->payload_type = 'bill';
elseif (isset($this->payload['text']))
$this->payload_type = 'text';
elseif (isset($this->payload['roll_call']))
$this->payload_type = 'roll_call';
elseif (isset($this->payload['person']))
$this->payload_type = 'person';
elseif (isset($this->payload['amendment']))
$this->payload_type = 'amendment';
elseif (isset($this->payload['supplement']))
$this->payload_type = 'supplement';
elseif (isset($this->payload['session']))
$this->payload_type = 'session';
else
throw new APIException('processPush could not determine payload type [' . array_keys($this->payload)[0] . ']');
return true;
}
public function getPayload()
{
return $this->payload;
}
public function getPayloadType()
{
return $this->payload_type;
}
public function respondOk($missing = array())
{
$response = array('status'=>LegiScan::API_OK);
if (is_array($missing) && !empty($missing))
$response['missing'] = $missing;
$this->respond($response);
}
public function respondError($error_message)
{
$response = array(
'status' => LegiScan::API_ERROR,
'alert' => array(
'message'=>$error_message
),
);
$this->respond($response);
}
private function respond($response)
{
header("Content-Type: application/json");
$msg = json_encode($response);
echo $msg;
exit(0);
}
}
class LegiScan_Pull
{
protected $api_key;
protected $response;
protected $payload;
protected $cache;
protected $request_url;
function __construct()
{
$this->cache = new LegiScan_Cache_File('api');
$this->api_key = LegiScan::getConfig('api_key');
if (!preg_match('/^[0-9a-f]{32}$/i', $this->api_key))
throw new APIException('Invalid API key');
}
public function getSessionList($state)
{
$params = array('state'=>strtoupper($state));
return $this->apiRequest('getSessionList', $params);
}
public function getMasterList($session_id)
{
$params = array('id'=>$session_id);
if (preg_match('#^[A-Z]{2}#i', $session_id))
$params = array('state'=>$session_id);
return $this->apiRequest('getMasterList', $params);
}
public function getMasterListRaw($session_id)
{
$params = array('id'=>$session_id);
if (preg_match('#^[A-Z]{2}#i', $session_id))
$params = array('state'=>$session_id);
return $this->apiRequest('getMasterListRaw', $params);
}
public function getBill($bill_id)
{
$params = array('id'=>$bill_id);
return $this->apiRequest('getBill', $params);
}
public function getBillText($text_id)
{
$params = array('id'=>$text_id);
if (LegiScan::getConfig('prefer_pdf'))
$params['prefer'] = 'pdf';
return $this->apiRequest('getBillText', $params);
}
public function getAmendment($amendment_id)
{
$params = array('id'=>$amendment_id);
if (LegiScan::getConfig('prefer_pdf'))
$params['prefer'] = 'pdf';
return $this->apiRequest('getAmendment', $params);
}
public function getSupplement($supplement_id)
{
$params = array('id'=>$supplement_id);
if (LegiScan::getConfig('prefer_pdf'))
$params['prefer'] = 'pdf';
return $this->apiRequest('getSupplement', $params);
}
public function getRollCall($roll_call_id)
{
$params = array('id'=>$roll_call_id);
return $this->apiRequest('getRollCall', $params);
}
public function getPerson($people_id)
{
$params = array('id'=>$people_id);
return $this->apiRequest('getPerson', $params);
}
public function getSearch($search)
{
$params = array();
if (isset($search['state']))
$params['state'] = $search['state'];
if (isset($search['bill']))
$params['bill'] = $search['bill'];
if (isset($search['query']))
$params['query'] = $search['query'];
if (isset($search['year']))
$params['year'] = $search['year'];
if (isset($search['page']))
$params['page'] = $search['page'];
if (isset($search['raw']))
$params['raw'] = 1;
if (!isset($search['bill']) && !isset($search['query']))
throw new APIException('Missing required search parameters');
return $this->apiRequest('getSearch', $params);
}
public function getSearchRaw($search)
{
$params = array();
if (isset($search['state']))
$params['state'] = $search['state'];
if (isset($search['bill']))
$params['bill'] = $search['bill'];
if (isset($search['query']))
$params['query'] = $search['query'];
if (isset($search['year']))
$params['year'] = $search['year'];
if (isset($search['page']))
$params['page'] = $search['page'];
if (!isset($search['bill']) && !isset($search['query']))
throw new APIException('Missing required search parameters');
return $this->apiRequest('getSearchRaw', $params);
}
public function getDatasetList($filter)
{
$params = array();
if (isset($filter['state']))
$params['state'] = $filter['state'];
if (isset($filter['year']))
$params['year'] = $filter['year'];
return $this->apiRequest('getDatasetList', $params);
}
public function getDataset($session_id, $access_key)
{
$params = array('id'=>$session_id,'access_key'=>$access_key);
return $this->apiRequest('getDataset', $params);
}
public function getSessionPeople($session_id)
{
$params = array('id'=>$session_id);
return $this->apiRequest('getSessionPeople', $params);
}
public function getSponsoredList($people_id)
{
$params = array('id'=>$people_id);
return $this->apiRequest('getSponsoredList', $params);
}
public function getMonitorList($filter)
{
$params = array();
if (isset($filter['record']))
$params['record'] = $filter['record'];
else
$params['recrod'] = 'current';
return $this->apiRequest('getMonitorList', $params);
}
public function getMonitorListRaw($filter)
{
$params = array();
if (isset($filter['record']))
$params['record'] = $filter['record'];
else
$params['record'] = 'current';
return $this->apiRequest('getMonitorListRaw', $params);
}
public function setMonitor($monitor)
{
$params = array();
if (isset($monitor['action']))
$params['action'] = $monitor['action'];
if (isset($monitor['stance']))
$params['stance'] = $monitor['stance'];
$params['list'] = implode(',', $monitor['list']);
return $this->apiRequest('setMonitor', $params);
}
protected function apiRequest($op, $params)
{
$query = array_merge(array('key'=>$this->api_key,'op'=>$op), $params);
$query_string = http_build_query($query);
$this->request_url = 'https://api.legiscan.com/?' . $query_string;
$cache_times = array(
'getsessionlist' => 86400,
'getmasterlist' => 3600,
'getmasterlistraw' => 3600,
'getbill' => 10800,
'getbilltext' => 2592000,
'getamendment' => 2592000,
'getsupplement' => 2592000,
'getrollcall' => 2592000,
'getperson' => 604800,
'getsearch' => 3600,
'getsearchraw' => 3600,
'search' => 3600,
'searchraw' => 3600,
'getdatasetlist' => 86400,
'getdataset' => 86400,
'getsessionpeople' => 86400,
'getsponsoredlist' => 86400,
'getmonitorlist' => 0,
'getmonitorlistraw' => 0,
'setmonitor' => 0,
);
$lifetime = 3600;
$nop = strtolower($op);
if (isset($cache_times[$nop]))
$lifetime = $cache_times[$nop];
$cache_file = $this->getCacheFilename($op, $params);
$this->response = $this->cache->get($cache_file, $lifetime);
$update_cache = false;
if (!$this->response)
{
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $this->request_url);
curl_setopt($ch, CURLOPT_FAILONERROR, true);
curl_setopt($ch, CURLOPT_TIMEOUT, 30);
curl_setopt($ch, CURLOPT_BUFFERSIZE, 64000);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_USERAGENT, "LegiScan API Client " . LegiScan::VERSION);
$this->response = curl_exec($ch);
if ($this->response === false)
throw new APIException('Could not get response from LegiScan API server (cURL ' . curl_errno($ch) . ': ' . curl_error($ch) . ')');
$update_cache = true;
}
$this->payload = json_decode($this->response, true);
if ($this->payload === false)
throw new APIException('Could not decode JSON API response');
if ($this->payload['status'] == LegiScan::API_ERROR)
throw new APIException($this->payload['alert']['message']);
if ($update_cache)
$this->cache->set($cache_file, $this->response);
return $this->payload;
}
function importBillList($bills, $logic)
{
$n = count($bills) - 1;
foreach ($bills as $i => $bill_id)
{
LegiScan::fileLog("importBillList requesting bill $bill_id ($i / $n)");
$resp = $this->getBill($bill_id);
if ($resp)
{
$missing = $logic->processBill($resp);
if (!empty($missing))
{
if (isset($missing['texts']))
{
foreach ($missing['texts'] as $text_id)
{
LegiScan::fileLog("importBillList requesting text $text_id");
$resp = $this->getBillText($text_id);
if ($resp)
$logic->processBillText($resp);
}
}
if (isset($missing['amendments']))
{
foreach ($missing['amendments'] as $amendment_id)
{
LegiScan::fileLog("importBillList requesting amendment $amendment_id");
$resp = $this->getAmendment($amendment_id);
if ($resp)
$logic->processAmendment($resp);
}
}
if (isset($missing['supplements']))
{
foreach ($missing['supplements'] as $supplement_id)
{
LegiScan::fileLog("importBillList requesting supplement $supplement_id");
$resp = $this->getSupplement($supplement_id);
if ($resp)
$logic->processSupplement($resp);
}
}
if (isset($missing['sponsors']))
{
foreach ($missing['sponsors'] as $people_id)
{
LegiScan::fileLog("importBillList requesting person $people_id");
$resp = $this->getPerson($people_id);
if ($resp)
$logic->processPerson($resp);
}
}
if (isset($missing['votes']))
{
foreach ($missing['votes'] as $roll_call_id)
{
LegiScan::fileLog("importBillList requesting roll_call $roll_call_id");
$resp = $this->getRollCall($roll_call_id);
if ($resp)
{
$people_list = $logic->processRollCall($resp);
foreach ($people_list as $people_id)
{
LegiScan::fileLog("importBillList requesting person $people_id");
$resp = $this->getPerson($people_id);
if ($resp)
$logic->processPerson($resp);
}
}
}
}
}
}
if ($i != $n)
sleep(1);
}
return true;
}
function getURL()
{
return $this->request_url;
}
function getRawResponse()
{
return $this->response;
}
function getCacheFilename($op, $params)
{
$op = strtolower($op);
switch ($op)
{
case 'getbill':
$filename = 'bill/' . $params['id'] . '.json';
break;
case 'getperson':
$filename = 'people/' . $params['id'] . '.json';
break;
case 'getrollcall':
$filename = 'rollcall/' . $params['id'] . '.json';
break;
case 'getbilltext':
$filename = 'text/' . $params['id'] . '.json';
break;
case 'getamendment':
$filename = 'amendment/' . $params['id'] . '.json';
break;
case 'getsupplement':
$filename = 'supplement/' . $params['id'] . '.json';
break;
case 'getsessionlist':
$filename = 'sessionlist/' . $params['state'] . '.json';
break;
case 'getmasterlist':
case 'getmasterlistraw':
$raw = '';
if (isset($params['raw']) || $op == 'getmasterlistraw')
$raw = '_raw';
if (isset($params['state']))
$filename = 'masterlist/' . $params['state'] . $raw . '.json';
else
$filename = 'masterlist/' . $params['id'] . $raw . '.json';
break;
case 'search':
case 'searchraw':
case 'getsearch':
case 'getsearchraw':
$chunks = array();
if (isset($params['state']))
$chunks[] = $params['state'];
if (isset($params['raw']) || $op == 'searchraw')
$chunks[] = 'raw';
if (isset($params['bill']))
$chunks[] = $params['bill'];
if (isset($params['year']))
$chunks[] = 'y' . $params['year'];
if (isset($params['page']))
$chunks[] = 'p' . $params['page'];
if (isset($params['query']))
$chunks[] = $params['query'];
$file_chunk = strtolower(implode('_', $chunks));
$file_chunk = mb_ereg_replace("([^\w\s\d\-_~,;\[\]\(\).])", '', $file_chunk);
$file_chunk = mb_ereg_replace("([\.]{2,})", '', $file_chunk);
if ((strlen($file_chunk) + 5) > 255)
$file_chunk = substr($file_chunk, 0, 250);
$filename = 'search/' . $file_chunk . '.json';
break;
case 'getdatasetlist':
$chunks = array();
$chunks[] = 'list';
if (isset($params['state']))
$chunks[] = $params['state'];
if (isset($params['year']))
$chunks[] = 'y' . $params['year'];
$file_chunk = strtolower(implode('_', $chunks));
$filename = 'datasetlist/' . $file_chunk . '.json';
break;
case 'getdataset':
$filename = 'dataset/' . $params['id'] . '.json';
break;
case 'getsessionpeople':
$filename = 'sessionpeople/' . $params['id'] . '.json';
break;
case 'getsponsoredlist':
$filename = 'sponsoredlist/' . $params['id'] . '.json';
break;
case 'getmonitorlist':
case 'getmonitorlistraw':
$raw = '';
if ($op == 'getmonitorlistraw')
$raw = '_raw';
$filename = 'monitorlist/' . $params['record'] . $raw . '.json';
break;
case 'setmonitor':
$filename = 'monitorlist/' . $params['action'] . '.json';
break;
default:
throw new APIException("Cannot determine Pull API cache file for $op");
break;
}
return $filename;
}
}
class LegiScan_Bulk
{
protected $logic;
function __construct()
{
$this->logic = new LegiScan_Process();
}
function importDataset($zipfile, $params)
{
$dry_run = isset($params['dry_run']) ? $params['dry_run'] : false;
$verbose = isset($params['verbose']) ? $params['verbose'] : false;
$debug = isset($params['debug']) ? $params['debug'] : false;
$expected_hash = isset($params['expected_hash']) ? $params['expected_hash'] : '';
$hash = '';
$import_stats = array();
$timer_start = microtime(true);
try {
$zip = new ZipArchive();
$import_stats = array(
'bill' => 0,
'people' => 0,
'vote' => 0,
'text' => 0,
'amendment' => 0,
'supplement' => 0,
);
$zip->open($zipfile);
$import_hash = $zip->getFromIndex($zip->numFiles - 1);
$import_date = strftime('%Y-%m-%d', $zip->statIndex($zip->numFiles - 1)['mtime']);
$import_session_id = 0;
if ($expected_hash && $import_hash != $expected_hash)
{
throw new APIException("processDataset hash mismatch");
}
for ($i = 0; $i < $zip->numFiles; $i++)
{
$name = $zip->statIndex($i)['name'];
$basename = basename($name);
if (stripos($basename, '.json') !== false)
{
$payload = json_decode($zip->getFromIndex($i), true);
if ($payload)
{
if (stripos($name, '/bill/') !== false)
{
if ($debug) echo "\tbill {$payload['bill']['bill_id']} from $basename\n";
if (!$dry_run) $this->logic->processBill($payload);
$import_stats['bill']++;
if (!$import_session_id)
$import_session_id = $payload['bill']['session_id'];
}
elseif (stripos($name, '/people/') !== false)
{
if ($debug) echo "\tperson {$payload['person']['people_id']} from $basename\n";
if (!$dry_run) $this->logic->processPerson($payload);
$import_stats['people']++;
}
elseif (stripos($name, '/vote/') !== false)
{
if ($debug) echo "\troll_call {$payload['roll_call']['roll_call_id']} from $basename\n";
if (!$dry_run) $this->logic->processRollCall($payload);
$import_stats['vote']++;
}
elseif (stripos($name, '/text/') !== false)
{
if ($debug) echo "\ttext {$payload['text']['doc_id']} from $basename\n";
if (!$dry_run) $this->logic->processBillText($payload);
$import_stats['text']++;
}
elseif (stripos($name, '/amendment/') !== false)
{
if ($debug) echo "\tamendment {$payload['amendment']['amendment_id']} from $basename\n";
if (!$dry_run) $this->logic->processAmendment($payload);
$import_stats['amendment']++;
}
elseif (stripos($name, '/supplement/') !== false)
{
if ($debug) echo "\tsupplement {$payload['supplement']['supplement_id']} from $basename\n";
if (!$dry_run) $this->logic->processSupplement($payload);
$import_stats['supplement']++;
}
}
else
{
throw new APIException("import could not decode API payload $name");
}
}
}
$zip->close();
$timer_end = microtime(true);
$time_elapsed = $timer_end - $timer_start;
$time = sec2hms(round($time_elapsed));
$db = $this->logic->getDB();
$sql = 'UPDATE ls_session SET import_date = :import_date, import_hash = :import_hash WHERE session_id = :session_id';
$stmt = $db->prepare($sql);
$stmt->bindValue(':session_id', $import_session_id, PDO::PARAM_INT);
$stmt->bindValue(':import_hash', $import_hash, PDO::PARAM_STR);
$stmt->bindValue(':import_date', $import_date, PDO::PARAM_STR);
$stmt->execute();
$stats = array();
$stats[] = '[' . $import_session_id . ']';
$stats[] = basename($zipfile);
foreach ($import_stats as $k => $v)
{
if ($v)
{
if ($verbose) echo sprintf("%10d %s\n", $v, $k);
$stats[] = $v . ' ' . $k;
}
}
if ($verbose) echo sprintf("%10s elapsed time\n", $time);
$stats[] = 'in ' . $time;
$log_msg = "LegiScan Import Complete: " . implode(' ', $stats);
LegiScan::fileLog($log_msg);
} catch (Exception $e) {
$error_msg = "LegiScan Import ERROR: " . $e->getMessage() . ' in ' . basename($e->getFile()) . ' on line ' . $e->getLine();
LegiScan::fileLog($error_msg);
echo "$error_msg\n";
}
$response = array(
'hash' => $import_hash,
'stats' => $import_stats,
);
return $response;
}
}
class LegiScan_Process
{
protected $missing;
protected $db;
protected $cache;
protected $memcache;
private $massage;
function __construct()
{
$this->cache = new LegiScan_Cache_File('doc');
$this->memcache = LegiScan_Cache_Memory::getInstance();
$this->resetMissing();
$dsn = LegiScan::getConfig('dsn');
$username = LegiScan::getConfig('db_user');
$password = LegiScan::getConfig('db_pass');
$pdo_options = array(
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::ATTR_EMULATE_PREPARES => false,
);
if (stripos($dsn, 'mysql') === 0 && stripos($dsn, 'charset=utf8') === false)
$dsn .= ';charset=utf8';
$this->massage = (bool) LegiScan::getConfig('massage_dates', false);
if (stripos($dsn, 'pgsql') !== false)
$this->massage = true;
if (stripos($dsn, 'sqlsrv') !== false)
$this->massage = true;
$this->db = new PDO($dsn, $username, $password, $pdo_options);
}
public function processSessionList($payload)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processSessionList payload status = "' . $payload['status'] . '"');
$sessions = $payload['sessions'];
try {
foreach ($sessions as $session)
{
if ($this->checkExists('session', $session['session_id']))
$sql = "UPDATE ls_session
SET state_id = :state_id, year_start = :year_start, year_end = :year_end,
prefile = :prefile, prior = :prior, sine_die = :sine_die,
special = :special, session_title = :session_title,
session_name = :session_name, session_tag = :session_tag
WHERE session_id = :session_id";
else
$sql = "INSERT INTO ls_session (
session_id, state_id, year_start, year_end, prefile, prior, special,
sine_id, session_title, session_name, session_tag
) VALUES (
:session_id, :state_id, :year_start, :year_end, :prefile, :prior,
:sine_die, :special, :session_title, :session_name, :session_tag
)";
$this->db->beginTransaction();
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':session_id', $session['session_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $session['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':year_start', $session['year_start'], PDO::PARAM_INT);
$stmt->bindValue(':year_end', $session['year_end'], PDO::PARAM_INT);
$stmt->bindValue(':special', $session['special'], PDO::PARAM_INT);
$stmt->bindValue(':prefile', $session['prefile'], PDO::PARAM_INT);
$stmt->bindValue(':sine_die', $session['sine_die'], PDO::PARAM_INT);
$stmt->bindValue(':prior', $session['prior'], PDO::PARAM_INT);
$stmt->bindValue(':session_title', $session['session_title'], PDO::PARAM_STR);
$stmt->bindValue(':session_name', $session['session_name'], PDO::PARAM_STR);
$stmt->bindValue(':session_tag', $session['session_name'], PDO::PARAM_STR);
$stmt->execute();
$this->db->commit();
}
} catch (PDOException $e) {
$this->db->rollback();
throw($e);
}
return true;
}
public function processSession($payload)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processSession payload status = "' . $payload['status'] . '"');
$session = $payload['session'];
try {
if ($this->checkExists('session', $session['session_id']))
$sql = "UPDATE ls_session
SET state_id = :state_id, year_start = :year_start, year_end = :year_end,
prefile = :prefile, sine_die = :sine_die, prior = :prior,
special = :special, session_title = :session_title,
session_name = :session_name, session_tag = :session_tag
WHERE session_id = :session_id";
else
$sql = "INSERT INTO ls_session (
session_id, state_id, year_start, year_end, prefile, sine_die, prior,
special, session_title, session_name, session_tag
) VALUES (
:session_id, :state_id, :year_start, :year_end, :prefile, :sine_die, :prior,
:special, :session_title, :session_name, :session_tag
)";
$this->db->beginTransaction();
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':session_id', $session['session_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $session['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':year_start', $session['year_start'], PDO::PARAM_INT);
$stmt->bindValue(':year_end', $session['year_end'], PDO::PARAM_INT);
$stmt->bindValue(':prefile', $session['prefile'], PDO::PARAM_INT);
$stmt->bindValue(':prior', $session['prior'], PDO::PARAM_INT);
$stmt->bindValue(':sine_die', $session['sine_die'], PDO::PARAM_INT);
$stmt->bindValue(':special', $session['special'], PDO::PARAM_INT);
$stmt->bindValue(':session_title', $session['session_title'], PDO::PARAM_STR);
$stmt->bindValue(':session_name', $session['session_name'], PDO::PARAM_STR);
$stmt->bindValue(':session_tag', $session['session_tag'], PDO::PARAM_STR);
$stmt->execute();
$this->db->commit();
} catch (PDOException $e) {
$this->db->rollback();
throw($e);
}
return true;
}
public function processMasterList($payload, $import_type = LegiScan::IMPORT_ALL)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processMasterList payload status = "' . $payload['status'] . '"');
$session = array_shift($payload['masterlist']);
foreach ($payload['masterlist'] as $bill)
{
switch ($import_type)
{
case LegiScan::IMPORT_NEW:
if (!$this->checkExists('bill', $bill['bill_id']))
$this->request('bills', $bill['bill_id']);
break;
case LegiScan::IMPORT_CHANGED:
case LegiScan::IMPORT_ALL:
$sql = "SELECT bill_id
FROM ls_bill
WHERE bill_id = :bill_id AND change_hash = :change_hash";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':change_hash', $bill['change_hash'], PDO::PARAM_STR);
$stmt->execute();
$exists = $stmt->fetchColumn();
if (!$exists)
$this->request('bills', $bill['bill_id']);
break;
}
}
if (isset($this->missing['bills']))
return $this->missing['bills'];
else
return array();
}
public function processBill($payload)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processBill payload status = "' . $payload['status'] . '"');
$bill = $payload['bill'];
$bill_id = $bill['bill_id'];
$now = date('Y-m-d H:i:s');
try {
$exists_id = $this->checkExists('bill', $bill['bill_id']);
$this->db->beginTransaction();
if (!$exists_id)
{
if (!$this->checkExists('session', $bill['session_id']))
{
$sql = "INSERT INTO ls_session (
session_id, state_id, year_start, year_end, prefile, sine_die, prior,
special, session_name, session_title, session_tag
) VALUES (
:session_id, :state_id, :year_start, :year_end, :prefile, :sine_die, :prior,
:special, :session_name, :session_title, :session_tag
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':session_id', $bill['session_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $bill['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':year_start', $bill['session']['year_start'], PDO::PARAM_INT);
$stmt->bindValue(':year_end', $bill['session']['year_end'], PDO::PARAM_INT);
$stmt->bindValue(':special', $bill['session']['special'], PDO::PARAM_INT);
$stmt->bindValue(':session_name', $bill['session']['session_name'], PDO::PARAM_STR);
$stmt->bindValue(':session_title', $bill['session']['session_title'], PDO::PARAM_STR);
$stmt->bindValue(':session_tag', $bill['session']['session_tag'], PDO::PARAM_STR);
$stmt->bindValue(':prefile', $bill['session']['prefile'], PDO::PARAM_INT);
$stmt->bindValue(':sine_die', $bill['session']['sine_die'], PDO::PARAM_INT);
$stmt->bindValue(':prior', $bill['session']['prior'], PDO::PARAM_INT);
$stmt->execute();
$this->middlewareSignal('session', $bill['session_id']);
}
$sql = "INSERT INTO ls_bill (
bill_id, state_id, session_id, body_id, current_body_id,
bill_type_id, bill_number, pending_committee_id,
status_id, status_date, title, description,
legiscan_url, state_url, change_hash,
updated, created
) VALUES (
:bill_id, :state_id, :session_id, :body_id, :current_body_id,
:bill_type_id, :bill_number, :pending_committee_id,
:status_id, :status_date, :title, :description,
:legiscan_url, :state_url, :change_hash,
:updated, :created
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $bill['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':session_id', $bill['session']['session_id'], PDO::PARAM_INT);
$stmt->bindValue(':body_id', $bill['body_id'], PDO::PARAM_INT);
$stmt->bindValue(':current_body_id', $bill['current_body_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_type_id', $bill['bill_type_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_number', $bill['bill_number'], PDO::PARAM_STR);
$stmt->bindValue(':pending_committee_id', $bill['pending_committee_id'], PDO::PARAM_INT);
$stmt->bindValue(':status_id', $bill['status'], PDO::PARAM_INT);
$stmt->bindValue(':status_date', $this->dbDate($bill['status_date']), PDO::PARAM_STR);
$stmt->bindValue(':title', $bill['title'], PDO::PARAM_STR);
$stmt->bindValue(':description', $bill['description'], PDO::PARAM_STR);
$stmt->bindValue(':legiscan_url', $bill['url'], PDO::PARAM_STR);
$stmt->bindValue(':state_url', $bill['state_link'], PDO::PARAM_STR);
$stmt->bindValue(':change_hash', $bill['change_hash'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if ($bill['pending_committee_id'] && !$this->checkExists('committee', $bill['pending_committee_id']))
{
$sql = "INSERT INTO ls_committee (
committee_id, committee_body_id, committee_name
) VALUES (
:committee_id, :committee_body_id, :committee_name
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':committee_id', $bill['committee']['committee_id'], PDO::PARAM_INT);
$stmt->bindValue(':committee_body_id', $bill['committee']['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':committee_name', $bill['committee']['name'], PDO::PARAM_STR);
$stmt->execute();
}
if (!empty($bill['referrals']))
{
foreach ($bill['referrals'] as $idx => $link)
{
if (!$this->checkExists('committee', $link['committee_id']))
{
$sql = "INSERT INTO ls_committee (
committee_id, committee_body_id, committee_name
) VALUES (
:committee_id, :committee_body_id, :committee_name
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':committee_id', $link['committee_id'], PDO::PARAM_INT);
$stmt->bindValue(':committee_body_id', $link['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':committee_name', $link['name'], PDO::PARAM_STR);
$stmt->execute();
}
$step = $idx + 1;
$sql = "INSERT INTO ls_bill_referral (
bill_id, referral_step, referral_date, committee_id
) VALUES (
:bill_id, :referral_step, :referral_date, :committee_id
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':referral_step', $step, PDO::PARAM_INT);
$stmt->bindValue(':referral_date', $this->dbDate($link['date']), PDO::PARAM_STR);
$stmt->bindValue(':committee_id', $link['committee_id'], PDO::PARAM_INT);
$stmt->execute();
}
}
if (isset($bill['reasons']))
{
foreach ($bill['reasons'] as $reason_id => $reason)
{
$sql = "INSERT INTO ls_bill_reason (
bill_id, reason_id, created
) VALUES (
:bill_id, :reason_id, :created
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':reason_id', $reason_id, PDO::PARAM_INT);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
}
}
foreach ($bill['progress'] as $step => $progress)
{
$step += 1;
$sql = "INSERT INTO ls_bill_progress (
bill_id, progress_step, progress_date,
progress_event_id
) VALUES (
:bill_id, :progress_step, :progress_date,
:progress_event_id
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':progress_step', $step, PDO::PARAM_INT);
$stmt->bindValue(':progress_date', $this->dbDate($progress['date']), PDO::PARAM_STR);
$stmt->bindValue(':progress_event_id', $progress['event'], PDO::PARAM_INT);
$stmt->execute();
}
foreach ($bill['history'] as $step => $history)
{
$step += 1;
$sql = "INSERT INTO ls_bill_history (
bill_id, history_step, history_major,
history_body_id, history_date, history_action
) VALUES (
:bill_id, :history_step, :history_major,
:history_body_id, :history_date, :history_action
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':history_step', $step, PDO::PARAM_INT);
$stmt->bindValue(':history_major', $history['importance'], PDO::PARAM_INT);
$stmt->bindValue(':history_body_id', $history['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':history_date', $this->dbDate($history['date']), PDO::PARAM_STR);
$stmt->bindValue(':history_action', $history['action'], PDO::PARAM_STR);
$stmt->execute();
}
foreach ($bill['sponsors'] as $person)
{
$sql = "INSERT INTO ls_bill_sponsor (
bill_id, people_id, sponsor_order, sponsor_type_id
) VALUES (
:bill_id, :people_id, :sponsor_order, :sponsor_type_id
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':people_id', $person['people_id'], PDO::PARAM_INT);
$stmt->bindValue(':sponsor_order', $person['sponsor_order'], PDO::PARAM_INT);
$stmt->bindValue(':sponsor_type_id', $person['sponsor_type_id'], PDO::PARAM_INT);
$stmt->execute();
if (($people_exists_id = $this->checkExists('people', $person['people_id'])))
$sql = "UPDATE ls_people
SET state_id = :state_id, role_id = :role_id, party_id = :party_id,
name = :name, first_name = :first_name, middle_name = :middle_name,
last_name = :last_name, suffix = :suffix, nickname = :nickname,
district = :district, committee_sponsor_id = :committee_id,
votesmart_id = :votesmart_id, followthemoney_eid = :followthemoney_eid,
opensecrets_id = :opensecrets_id, ballotpedia = :ballotpedia,
knowwho_pid = :knowwho_pid, person_hash = :person_hash,
updated = :updated
WHERE people_id = :people_id";
else
$sql = "INSERT INTO ls_people (
people_id, state_id, role_id, party_id, name, first_name,
middle_name, last_name, suffix, nickname, district,
committee_sponsor_id, votesmart_id, followthemoney_eid,
opensecrets_id, ballotpedia, knowwho_pid, person_hash,
updated, created
) VALUES (
:people_id, :state_id, :role_id, :party_id, :name, :first_name,
:middle_name, :last_name, :suffix, :nickname, :district,
:committee_id, :votesmart_id, :followthemoney_eid,
:opensecrets_id, :ballotpedia, :knowwho_pid, :person_hash,
:updated, :created
)";
if ($people_exists_id)
$p = $this->db->query("SELECT person_hash FROM ls_people WHERE people_id = {$people_exists_id}")->fetch();
if (!$people_exists_id || $p['person_hash'] != $person['person_hash'])
{
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':people_id', $person['people_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $bill['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':role_id', $person['role_id'], PDO::PARAM_INT);
$stmt->bindValue(':party_id', $person['party_id'], PDO::PARAM_INT);
$stmt->bindValue(':name', $person['name'], PDO::PARAM_STR);
$stmt->bindValue(':first_name', $person['first_name'], PDO::PARAM_STR);
$stmt->bindValue(':middle_name', $person['middle_name'], PDO::PARAM_STR);
$stmt->bindValue(':last_name', $person['last_name'], PDO::PARAM_STR);
$stmt->bindValue(':suffix', $person['suffix'], PDO::PARAM_STR);
$stmt->bindValue(':nickname', $person['nickname'], PDO::PARAM_STR);
$stmt->bindValue(':district', $person['district'], PDO::PARAM_STR);
$stmt->bindValue(':committee_id', $person['committee_id'], PDO::PARAM_INT);
$stmt->bindValue(':ballotpedia', $person['ballotpedia'], PDO::PARAM_STR);
$stmt->bindValue(':followthemoney_eid', $person['ftm_eid'], PDO::PARAM_INT);
$stmt->bindValue(':votesmart_id', $person['votesmart_id'], PDO::PARAM_INT);
$stmt->bindValue(':knowwho_pid', $person['knowwho_pid'], PDO::PARAM_INT);
$stmt->bindValue(':opensecrets_id', $person['opensecrets_id'], PDO::PARAM_STR);
$stmt->bindValue(':person_hash', $person['person_hash'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
if (!$people_exists_id)
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
}
}
foreach ($bill['votes'] as $vote)
{
$sql = "INSERT INTO ls_bill_vote (
roll_call_id, bill_id, roll_call_body_id, roll_call_date,
roll_call_desc, yea, nay, nv, absent, total, passed,
legiscan_url, state_url, updated, created
) VALUES (
:roll_call_id, :bill_id, :roll_call_body_id, :roll_call_date,
:roll_call_desc, :yea, :nay, :nv, :absent, :total, :passed,
:legiscan_url, :state_url, :updated, :created
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':roll_call_id', $vote['roll_call_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':roll_call_body_id', $vote['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':roll_call_date', $this->dbDate($vote['date']), PDO::PARAM_STR);
$stmt->bindValue(':roll_call_desc', $vote['desc'], PDO::PARAM_STR);
$stmt->bindValue(':yea', $vote['yea'], PDO::PARAM_INT);
$stmt->bindValue(':nay', $vote['nay'], PDO::PARAM_INT);
$stmt->bindValue(':nv', $vote['nv'], PDO::PARAM_INT);
$stmt->bindValue(':absent', $vote['absent'], PDO::PARAM_INT);
$stmt->bindValue(':total', $vote['total'], PDO::PARAM_INT);
$stmt->bindValue(':passed', $vote['passed'], PDO::PARAM_INT);
$stmt->bindValue(':legiscan_url', $vote['url'], PDO::PARAM_STR);
$stmt->bindValue(':state_url', $vote['state_link'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if (LegiScan::getConfig('want_vote_details'))
$this->request('votes', $vote['roll_call_id']);
}
foreach ($bill['texts'] as $text)
{
$sql = "INSERT INTO ls_bill_text (
text_id, bill_id, local_copy, bill_text_type_id,
bill_text_mime_id, bill_text_date,
legiscan_url, state_url, bill_text_size, bill_text_hash,
updated, created
) VALUES (
:text_id, :bill_id, :local_copy, :bill_text_type_id,
:bill_text_mime_id, :bill_text_date,
:legiscan_url, :state_url, :bill_text_size, :bill_text_hash,
:updated, :created
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':text_id', $text['doc_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':local_copy', 0, PDO::PARAM_INT);
$stmt->bindValue(':bill_text_size', $text['text_size'], PDO::PARAM_INT);
$stmt->bindValue(':bill_text_hash', $text['text_hash'], PDO::PARAM_STR);
$stmt->bindValue(':bill_text_type_id', $text['type_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_text_mime_id', $text['mime_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_text_date', $this->dbDate($text['date']), PDO::PARAM_STR);
$stmt->bindValue(':legiscan_url', $text['url'], PDO::PARAM_STR);
$stmt->bindValue(':state_url', $text['state_link'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if (LegiScan::getConfig('want_bill_text'))
$this->request('texts', $text['doc_id']);
}
foreach ($bill['amendments'] as $amendment)
{
$sql = "INSERT INTO ls_bill_amendment (
amendment_id, bill_id, local_copy, adopted,
amendment_body_id, amendment_mime_id,
amendment_date, amendment_title, amendment_desc,
legiscan_url, state_url, amendment_size, amendment_hash,
updated, created
) VALUES (
:amendment_id, :bill_id, :local_copy, :adopted,
:amendment_body_id, :amendment_mime_id,
:amendment_date, :amendment_title, :amendment_desc,
:legiscan_url, :state_url, :amendment_size, :amendment_hash,
:updated, :created
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':amendment_id', $amendment['amendment_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':local_copy', 0, PDO::PARAM_INT);
$stmt->bindValue(':adopted', $amendment['adopted'], PDO::PARAM_INT);
$stmt->bindValue(':amendment_size', $amendment['amendment_size'], PDO::PARAM_INT);
$stmt->bindValue(':amendment_hash', $amendment['amendment_hash'], PDO::PARAM_STR);
$stmt->bindValue(':amendment_body_id', $amendment['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':amendment_mime_id', $amendment['mime_id'], PDO::PARAM_INT);
$stmt->bindValue(':amendment_date', $this->dbDate($amendment['date']), PDO::PARAM_STR);
$stmt->bindValue(':amendment_title', $amendment['title'], PDO::PARAM_STR);
$stmt->bindValue(':amendment_desc', $amendment['description'], PDO::PARAM_STR);
$stmt->bindValue(':legiscan_url', $amendment['url'], PDO::PARAM_STR);
$stmt->bindValue(':state_url', $amendment['state_link'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if (LegiScan::getConfig('want_amendment'))
$this->request('amendments', $amendment['amendment_id']);
}
foreach ($bill['supplements'] as $supplement)
{
$sql = "INSERT INTO ls_bill_supplement (
supplement_id, bill_id, local_copy,
supplement_type_id, supplement_mime_id,
supplement_date, supplement_title, supplement_desc,
legiscan_url, state_url, supplement_size, supplement_hash,
updated, created
) VALUES (
:supplement_id, :bill_id, :local_copy,
:supplement_type_id, :supplement_mime_id,
:supplement_date, :supplement_title, :supplement_desc,
:legiscan_url, :state_url, :supplement_size, :supplement_hash,
:updated, :created
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':supplement_id', $supplement['supplement_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':local_copy', 0, PDO::PARAM_INT);
$stmt->bindValue(':supplement_size', $supplement['supplement_size'], PDO::PARAM_INT);
$stmt->bindValue(':supplement_hash', $supplement['supplement_hash'], PDO::PARAM_STR);
$stmt->bindValue(':supplement_type_id', $supplement['type_id'], PDO::PARAM_INT);
$stmt->bindValue(':supplement_mime_id', $supplement['mime_id'], PDO::PARAM_INT);
$stmt->bindValue(':supplement_date', $this->dbDate($supplement['date']), PDO::PARAM_INT);
$stmt->bindValue(':supplement_title', $supplement['title'], PDO::PARAM_INT);
$stmt->bindValue(':supplement_desc', $supplement['description'], PDO::PARAM_INT);
$stmt->bindValue(':legiscan_url', $supplement['url'], PDO::PARAM_STR);
$stmt->bindValue(':state_url', $supplement['state_link'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if (LegiScan::getConfig('want_supplement'))
$this->request('supplements', $supplement['supplement_id']);
}
foreach ($bill['sasts'] as $sast)
{
$sql = "INSERT INTO ls_bill_sast (
bill_id, sast_type_id, sast_bill_id, sast_bill_number
) VALUES (
:bill_id, :sast_type_id, :sast_bill_id, :sast_bill_number
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':sast_type_id', $sast['type_id'], PDO::PARAM_INT);
$stmt->bindValue(':sast_bill_id', $sast['sast_bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':sast_bill_number', $sast['sast_bill_number'], PDO::PARAM_STR);
$stmt->execute();
}
foreach ($bill['subjects'] as $subject)
{
$sql = "INSERT INTO ls_bill_subject (
bill_id, subject_id
) VALUES (
:bill_id, :subject_id
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':subject_id', $subject['subject_id'], PDO::PARAM_INT);
$stmt->execute();
$subject_exists_id = $this->checkExists('subject', $subject['subject_id']);
if (!$subject_exists_id)
{
$sql = "INSERT INTO ls_subject (
subject_id, state_id, subject_name
) VALUES (
:subject_id, :state_id, :subject_name
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':subject_id', $subject['subject_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $bill['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':subject_name', $subject['subject_name'], PDO::PARAM_STR);
$stmt->execute();
}
}
foreach ($bill['calendar'] as $calendar)
{
$event_hash = md5(strtolower("{$calendar['type']}-{$calendar['date']}-{$calendar['time']}-{$calendar['location']}-{$calendar['description']}"));
$event_hash = substr($event_hash, 0, 8);
$sql = "SELECT 1 FROM ls_bill_calendar WHERE bill_id = :bill_id AND event_hash = :event_hash";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':event_hash', $event_hash, PDO::PARAM_STR);
$stmt->execute();
if (!$stmt->fetchColumn())
{
$sql = "INSERT INTO ls_bill_calendar (
bill_id, event_hash, event_type_id, event_date,
event_time, event_location, event_desc,
updated, created
) VALUES (
:bill_id, :event_hash, :event_type_id, :event_date,
:event_time, :event_location, :event_desc,
:updated, :created
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':event_hash', $event_hash, PDO::PARAM_STR);
$stmt->bindValue(':event_type_id', $calendar['type_id'], PDO::PARAM_INT);
$stmt->bindValue(':event_date', $this->dbDate($calendar['date']), PDO::PARAM_STR);
$stmt->bindValue(':event_time', $calendar['time'], PDO::PARAM_STR);
$stmt->bindValue(':event_location', $calendar['location'], PDO::PARAM_STR);
$stmt->bindValue(':event_desc', $calendar['description'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
}
}
}
else
{
$bill_old = $this->loadBill($bill['bill_id']);
$updates = array();
if ($bill['session']['prefile'] != $bill_old['session']['prefile'])
$updates['prefile'] = array($bill['session']['prefile'], PDO::PARAM_INT);
if ($bill['session']['sine_die'] != $bill_old['session']['sine_die'])
$updates['sine_die'] = array($bill['session']['sine_die'], PDO::PARAM_INT);
if ($bill['session']['prior'] != $bill_old['session']['prior'])
$updates['prior'] = array($bill['session']['prior'], PDO::PARAM_INT);
if ($updates)
{
$key = array(
'session_id'=>array($bill['session']['session_id'], PDO::PARAM_INT),
);
$stmt = $this->makeSQLStatement('update', 'ls_session', $updates, $key);
$stmt->execute();
$this->middlewareSignal('session', $bill['session_id']);
}
$updates = array();
if ($bill['bill_type_id'] != $bill_old['bill_type_id'])
$updates['bill_type_id'] = array($bill['bill_type_id'], PDO::PARAM_INT);
if ($bill['current_body_id'] != $bill_old['current_body_id'])
$updates['current_body_id'] = array($bill['current_body_id'], PDO::PARAM_INT);
if ($bill['status'] != $bill_old['status'])
$updates['status_id'] = array($bill['status'], PDO::PARAM_INT);
if ($bill['status_date'] != $bill_old['status_date'])
$updates['status_date'] = array($this->dbDate($bill['status_date']), PDO::PARAM_STR);
if ($bill['title'] != $bill_old['title'])
$updates['title'] = array($bill['title'], PDO::PARAM_STR);
if ($bill['description'] != $bill_old['description'])
$updates['description'] = array($bill['description'], PDO::PARAM_STR);
if ($bill['pending_committee_id'] != $bill_old['pending_committee_id'])
$updates['pending_committee_id'] = array($bill['pending_committee_id'], PDO::PARAM_INT);
if ($bill['change_hash'] != $bill_old['change_hash'])
$updates['change_hash'] = array($bill['change_hash'], PDO::PARAM_STR);
if ($updates)
{
$key = array(
'bill_id'=>array($bill['bill_id'], PDO::PARAM_INT),
);
$stmt = $this->makeSQLStatement('update', 'ls_bill', $updates, $key);
$stmt->execute();
}
if ($bill['pending_committee_id'] && !$this->checkExists('committee', $bill['pending_committee_id']))
{
$sql = "INSERT INTO ls_committee (
committee_id, committee_body_id, committee_name
) VALUES (
:committee_id, :committee_body_id, :committee_name
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':committee_id', $bill['committee']['committee_id'], PDO::PARAM_INT);
$stmt->bindValue(':committee_body_id', $bill['committee']['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':committee_name', $bill['committee']['name'], PDO::PARAM_STR);
$stmt->execute();
}
if (!empty($bill['referrals']))
{
foreach ($bill['referrals'] as $idx => $link)
{
if (!$this->checkExists('committee', $link['committee_id']))
{
$sql = "INSERT INTO ls_committee (
committee_id, committee_body_id, committee_name
) VALUES (
:committee_id, :committee_body_id, :committee_name
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':committee_id', $link['committee_id'], PDO::PARAM_INT);
$stmt->bindValue(':committee_body_id', $link['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':committee_name', $link['name'], PDO::PARAM_STR);
$stmt->execute();
}
$step = $idx + 1;
$updates = array();
$key = array(
'bill_id' => array($bill['bill_id'], PDO::PARAM_INT),
'referral_step' => array($step, PDO::PARAM_INT),
);
if (isset($bill_old['referrals'][$idx]))
{
if ($link['date'] != $bill_old['referrals'][$idx]['date'])
$updates['referral_date'] = array($this->dbDate($link['date']), PDO::PARAM_STR);
if ($link['committee_id'] != $bill_old['referrals'][$idx]['committee_id'])
$updates['committee_id'] = array($link['committee_id'], PDO::PARAM_INT);
if ($updates)
{
$stmt = $this->makeSQLStatement('update', 'ls_bill_referral', $updates, $key);
$stmt->execute();
}
}
else
{
$updates['referral_date'] = array($this->dbDate($link['date']), PDO::PARAM_STR);
$updates['committee_id'] = array($link['committee_id'], PDO::PARAM_STR);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_referral', $updates, $key);
$stmt->execute();
}
}
if (($ocnt = count($bill_old['referrals'])) > ($cnt = count($bill['referrals'])))
{
$step_cut = $ocnt - $cnt + 1;
$sql = 'DELETE FROM ls_bill_referral WHERE bill_id = :bill_id AND referral_step > :step_cut';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':step_cut', $step_cut, PDO::PARAM_INT);
$stmt->execute();
}
}
if (isset($bill['reasons']))
{
foreach ($bill['reasons'] as $reason_id => $reason)
{
$sql = "INSERT INTO ls_bill_reason (
bill_id, reason_id, created
) VALUES (
:bill_id, :reason_id, :created
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':reason_id', $reason_id, PDO::PARAM_INT);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
}
}
foreach ($bill['progress'] as $idx => $event)
{
$step = $idx + 1;
$updates = array();
$key = array(
'bill_id' => array($bill['bill_id'], PDO::PARAM_INT),
'progress_step' => array($step, PDO::PARAM_INT),
);
if (isset($bill_old['progress'][$idx]))
{
if ($event['date'] != $bill_old['progress'][$idx]['date'])
$updates['progress_date'] = array($this->dbDate($event['date']), PDO::PARAM_STR);
if ($event['event'] != $bill_old['progress'][$idx]['event'])
$updates['progress_event_id'] = array($event['event'], PDO::PARAM_INT);
if ($updates)
{
$stmt = $this->makeSQLStatement('update', 'ls_bill_progress', $updates, $key);
$stmt->execute();
}
}
else
{
$updates['progress_date'] = array($this->dbDate($event['date']), PDO::PARAM_STR);
$updates['progress_event_id'] = array($event['event'], PDO::PARAM_INT);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_progress', $updates, $key);
$stmt->execute();
}
}
if (($ocnt = count($bill_old['progress'])) > ($cnt = count($bill['progress'])))
{
$step_cut = $ocnt - $cnt + 1;
$sql = 'DELETE FROM ls_bill_progress WHERE bill_id = :bill_id AND progress_step > :step_cut';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':step_cut', $step_cut, PDO::PARAM_INT);
$stmt->execute();
}
foreach ($bill['history'] as $idx => $action)
{
$step = $idx + 1;
$updates = array();
$key = array(
'bill_id' => array($bill['bill_id'], PDO::PARAM_INT),
'history_step' => array($step, PDO::PARAM_INT),
);
if (isset($bill_old['history'][$idx]))
{
if ($action['importance'] != $bill_old['history'][$idx]['importance'])
$updates['history_major'] = array($action['importance'], PDO::PARAM_INT);
if ($action['chamber_id'] != $bill_old['history'][$idx]['chamber_id'])
$updates['history_body_id'] = array($action['chamber_id'], PDO::PARAM_INT);
if ($action['date'] != $bill_old['history'][$idx]['date'])
$updates['history_date'] = array($this->dbDate($action['date']), PDO::PARAM_STR);
if ($action['action'] != $bill_old['history'][$idx]['action'])
$updates['history_action'] = array($action['action'], PDO::PARAM_STR);
if ($updates)
{
$stmt = $this->makeSQLStatement('update', 'ls_bill_history', $updates, $key);
$stmt->execute();
}
}
else
{
$updates['history_major'] = array($action['importance'], PDO::PARAM_INT);
$updates['history_body_id'] = array($action['chamber_id'], PDO::PARAM_INT);
$updates['history_date'] = array($this->dbDate($action['date']), PDO::PARAM_STR);
$updates['history_action'] = array($action['action'], PDO::PARAM_STR);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_history', $updates, $key);
$stmt->execute();
}
}
if (($ocnt = count($bill_old['history'])) > ($cnt = count($bill['history'])))
{
$step_cut = $ocnt - $cnt + 1;
$sql = 'DELETE FROM ls_bill_history WHERE bill_id = :bill_id AND history_step > :step_cut';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':step_cut', $step_cut, PDO::PARAM_INT);
$stmt->execute();
}
foreach ($bill['sponsors'] as $idx => $person)
{
$exists = false;
$updates = array();
$key = array(
'bill_id' => array($bill['bill_id'], PDO::PARAM_INT),
'people_id' => array($person['people_id'], PDO::PARAM_INT),
);
foreach ($bill_old['sponsors'] as $og_idx => $og)
{
if ($person['people_id'] == $og['people_id'])
$exists = true;
}
if (!$exists)
{
$updates['sponsor_order'] = array($person['sponsor_order'], PDO::PARAM_INT);
$updates['sponsor_type_id'] = array($person['sponsor_type_id'], PDO::PARAM_INT);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_sponsor', $updates, $key);
$stmt->execute();
}
else
{
if ($person['sponsor_order'] != $bill_old['sponsors'][$og_idx]['sponsor_order'])
$updates['sponsor_order'] = array($person['sponsor_order'], PDO::PARAM_INT);
if ($person['sponsor_type_id'] != $bill_old['sponsors'][$og_idx]['sponsor_type_id'])
$updates['sponsor_type_id'] = array($person['sponsor_type_id'], PDO::PARAM_INT);
if ($updates)
{
$stmt = $this->makeSQLStatement('update', 'ls_bill_sponsor', $updates, $key);
$stmt->execute();
}
}
if (($people_exists_id = $this->checkExists('people', $person['people_id'])))
$sql = "UPDATE ls_people
SET state_id = :state_id, role_id = :role_id, party_id = :party_id,
name = :name, first_name = :first_name, middle_name = :middle_name,
last_name = :last_name, suffix = :suffix, nickname = :nickname,
district = :district, committee_sponsor_id = :committee_id,
votesmart_id = :votesmart_id, followthemoney_eid = :followthemoney_eid,
opensecrets_id = :opensecrets_id, ballotpedia = :ballotpedia,
knowwho_pid = :knowwho_pid, person_hash = :person_hash,
updated = :updated
WHERE people_id = :people_id";
else
$sql = "INSERT INTO ls_people (
people_id, state_id, role_id, party_id, name, first_name,
middle_name, last_name, suffix, nickname, district,
committee_sponsor_id, votesmart_id, followthemoney_eid,
opensecrets_id, ballotpedia, knowwho_pid, person_hash,
updated, created
) VALUES (
:people_id, :state_id, :role_id, :party_id, :name, :first_name,
:middle_name, :last_name, :suffix, :nickname, :district,
:committee_id, :votesmart_id, :followthemoney_eid,
:opensecrets_id, :ballotpedia, :knowwho_pid, :person_hash,
:updated, :created
)";
if ($people_exists_id)
$p = $this->db->query("SELECT person_hash FROM ls_people WHERE people_id = {$people_exists_id}")->fetch();
if (!$people_exists_id || $p['person_hash'] != $person['person_hash'])
{
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':people_id', $person['people_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $bill['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':role_id', $person['role_id'], PDO::PARAM_INT);
$stmt->bindValue(':party_id', $person['party_id'], PDO::PARAM_INT);
$stmt->bindValue(':name', $person['name'], PDO::PARAM_STR);
$stmt->bindValue(':first_name', $person['first_name'], PDO::PARAM_STR);
$stmt->bindValue(':middle_name', $person['middle_name'], PDO::PARAM_STR);
$stmt->bindValue(':last_name', $person['last_name'], PDO::PARAM_STR);
$stmt->bindValue(':suffix', $person['suffix'], PDO::PARAM_STR);
$stmt->bindValue(':nickname', $person['nickname'], PDO::PARAM_STR);
$stmt->bindValue(':district', $person['district'], PDO::PARAM_STR);
$stmt->bindValue(':committee_id', $person['committee_id'], PDO::PARAM_INT);
$stmt->bindValue(':ballotpedia', $person['ballotpedia'], PDO::PARAM_STR);
$stmt->bindValue(':followthemoney_eid', $person['ftm_eid'], PDO::PARAM_INT);
$stmt->bindValue(':votesmart_id', $person['votesmart_id'], PDO::PARAM_INT);
$stmt->bindValue(':knowwho_pid', $person['knowwho_pid'], PDO::PARAM_INT);
$stmt->bindValue(':opensecrets_id', $person['opensecrets_id'], PDO::PARAM_STR);
$stmt->bindValue(':person_hash', $person['person_hash'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
if (!$people_exists_id)
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
}
}
foreach ($bill_old['sponsors'] as $og)
{
$exists = false;
foreach ($bill['sponsors'] as $person)
{
if ($og['people_id'] == $person['people_id'])
$exists = true;
}
if (!$exists)
{
$sql = 'DELETE FROM ls_bill_sponsor WHERE bill_id = :bill_id AND people_id = :people_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':people_id', $og['people_id'], PDO::PARAM_INT);
$stmt->execute();
}
}
foreach ($bill['votes'] as $vote)
{
$updates = array();
$key = array(
'roll_call_id' => array($vote['roll_call_id'], PDO::PARAM_INT),
);
if (($exists_id = $this->checkExists('bill_vote', $vote['roll_call_id'])))
{
foreach ($bill_old['votes'] as $old_vote)
{
if ($vote['roll_call_id'] == $old_vote['roll_call_id'])
{
if ($vote['chamber_id'] != $old_vote['chamber_id'])
$updates['roll_call_body_id'] = array($vote['chamber_id'], PDO::PARAM_INT);
if ($vote['date'] != $old_vote['date'])
$updates['roll_call_date'] = array($this->dbDate($vote['date']), PDO::PARAM_STR);
if ($vote['desc'] != $old_vote['desc'])
$updates['roll_call_desc'] = array($vote['desc'], PDO::PARAM_STR);
if ($vote['yea'] != $old_vote['yea'])
$updates['yea'] = array($vote['yea'], PDO::PARAM_INT);
if ($vote['nay'] != $old_vote['nay'])
$updates['nay'] = array($vote['nay'], PDO::PARAM_INT);
if ($vote['nv'] != $old_vote['nv'])
$updates['nv'] = array($vote['nv'], PDO::PARAM_INT);
if ($vote['absent'] != $old_vote['absent'])
$updates['absent'] = array($vote['absent'], PDO::PARAM_INT);
if ($vote['total'] != $old_vote['total'])
$updates['total'] = array($vote['total'], PDO::PARAM_INT);
if ($vote['passed'] != $old_vote['passed'])
$updates['passed'] = array($vote['passed'], PDO::PARAM_INT);
if ($vote['url'] != $old_vote['url'])
$updates['legiscan_url'] = array($vote['url'], PDO::PARAM_STR);
if ($vote['state_link'] != $old_vote['state_link'])
$updates['state_url'] = array($vote['state_link'], PDO::PARAM_STR);
break;
}
}
if ($updates)
{
$stmt = $this->makeSQLStatement('update', 'ls_bill_vote', $updates, $key);
$stmt->execute();
}
}
else
{
$updates['roll_call_id'] = array($vote['roll_call_id'], PDO::PARAM_INT);
$updates['bill_id'] = array($bill['bill_id'], PDO::PARAM_INT);
$updates['roll_call_body_id'] = array($vote['chamber_id'], PDO::PARAM_INT);
$updates['roll_call_date'] = array($this->dbDate($vote['date']), PDO::PARAM_STR);
$updates['roll_call_desc'] = array($vote['desc'], PDO::PARAM_STR);
$updates['yea'] = array($vote['yea'], PDO::PARAM_INT);
$updates['nay'] = array($vote['nay'], PDO::PARAM_INT);
$updates['nv'] = array($vote['nv'], PDO::PARAM_INT);
$updates['absent'] = array($vote['absent'], PDO::PARAM_INT);
$updates['total'] = array($vote['total'], PDO::PARAM_INT);
$updates['passed'] = array($vote['passed'], PDO::PARAM_INT);
$updates['legiscan_url'] = array($vote['url'], PDO::PARAM_STR);
$updates['state_url'] = array($vote['state_link'], PDO::PARAM_STR);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_vote', $updates, $key);
$stmt->execute();
if (LegiScan::getConfig('want_vote_details'))
$this->request('votes', $vote['roll_call_id']);
}
}
foreach ($bill['texts'] as $text)
{
$updates = array();
$key = array(
'text_id' => array($text['doc_id'], PDO::PARAM_INT),
);
if (($exists_id = $this->checkExists('bill_text', $text['doc_id'])))
{
foreach ($bill_old['texts'] as $old_text)
{
if ($text['doc_id'] == $old_text['doc_id'])
{
if ($text['date'] != $old_text['date'])
$updates['bill_text_date'] = array($this->dbDate($text['date']), PDO::PARAM_STR);
if ($text['type_id'] != $old_text['type_id'])
$updates['bill_text_type_id'] = array($text['type_id'], PDO::PARAM_INT);
if ($text['mime_id'] != $old_text['mime_id'])
$updates['bill_text_mime_id'] = array($text['mime_id'], PDO::PARAM_INT);
if ($text['url'] != $old_text['url'])
$updates['legiscan_url'] = array($text['url'], PDO::PARAM_STR);
if ($text['state_link'] != $old_text['state_link'])
$updates['state_url'] = array($text['state_link'], PDO::PARAM_STR);
if ($text['text_size'] != $old_text['text_size'])
$updates['bill_text_size'] = array($text['text_size'], PDO::PARAM_INT);
if ($text['text_hash'] != $old_text['text_hash'])
$updates['bill_text_hash'] = array($text['text_hash'], PDO::PARAM_STR);
break;
}
}
if ($updates)
{
$stmt = $this->makeSQLStatement('update', 'ls_bill_text', $updates, $key);
$stmt->execute();
}
}
else
{
$updates['text_id'] = array($text['doc_id'], PDO::PARAM_INT);
$updates['bill_id'] = array($bill['bill_id'], PDO::PARAM_INT);
$updates['local_copy'] = array(0, PDO::PARAM_INT);
$updates['bill_text_size'] = array($text['text_size'], PDO::PARAM_INT);
$updates['bill_text_hash'] = array($text['text_hash'], PDO::PARAM_STR);
$updates['bill_text_type_id'] = array($text['type_id'], PDO::PARAM_INT);
$updates['bill_text_mime_id'] = array($text['mime_id'], PDO::PARAM_INT);
$updates['bill_text_date'] = array($this->dbDate($text['date']), PDO::PARAM_STR);
$updates['legiscan_url'] = array($text['url'], PDO::PARAM_STR);
$updates['state_url'] = array($text['state_link'], PDO::PARAM_STR);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_text', $updates, $key);
$stmt->execute();
if (LegiScan::getConfig('want_bill_text'))
$this->request('texts', $text['doc_id']);
}
}
foreach ($bill['amendments'] as $amendment)
{
$updates = array();
$key = array(
'amendment_id' => array($amendment['amendment_id'], PDO::PARAM_INT),
);
if (($exists_id = $this->checkExists('bill_amendment', $amendment['amendment_id'])))
{
foreach ($bill_old['amendments'] as $old_amendment)
{
if ($amendment['amendment_id'] == $old_amendment['amendment_id'])
{
if ($amendment['adopted'] != $old_amendment['adopted'])
$updates['adopted'] = array($amendment['adopted'], PDO::PARAM_INT);
if ($amendment['chamber_id'] != $old_amendment['chamber_id'])
$updates['amendment_body_id'] = array($amendment['chamber_id'], PDO::PARAM_INT);
if ($amendment['mime_id'] != $old_amendment['mime_id'])
$updates['amendment_mime_id'] = array($amendment['mime_id'], PDO::PARAM_INT);
if ($amendment['date'] != $old_amendment['date'])
$updates['amendment_date'] = array($this->dbDate($amendment['date']), PDO::PARAM_STR);
if ($amendment['title'] != $old_amendment['title'])
$updates['amendment_title'] = array($amendment['title'], PDO::PARAM_STR);
if ($amendment['description'] != $old_amendment['description'])
$updates['amendment_desc'] = array($amendment['description'], PDO::PARAM_STR);
if ($amendment['url'] != $old_amendment['url'])
$updates['legiscan_url'] = array($amendment['url'], PDO::PARAM_STR);
if ($amendment['state_link'] != $old_amendment['state_link'])
$updates['state_url'] = array($amendment['state_link'], PDO::PARAM_STR);
if ($amendment['amendment_size'] != $old_amendment['amendment_size'])
$updates['amendment_size'] = array($amendment['amendment_size'], PDO::PARAM_INT);
if ($amendment['amendment_hash'] != $old_amendment['amendment_hash'])
$updates['amendment_hash'] = array($amendment['amendment_hash'], PDO::PARAM_STR);
break;
}
}
if ($updates)
{
$stmt = $this->makeSQLStatement('update', 'ls_bill_amendment', $updates, $key);
$stmt->execute();
}
}
else
{
$updates['amendment_id'] = array($amendment['amendment_id'], PDO::PARAM_INT);
$updates['bill_id'] = array($bill['bill_id'], PDO::PARAM_INT);
$updates['local_copy'] = array(0, PDO::PARAM_INT);
$updates['adopted'] = array($amendment['adopted'], PDO::PARAM_INT);
$updates['amendment_size'] = array($amendment['amendment_size'], PDO::PARAM_INT);
$updates['amendment_hash'] = array($amendment['amendment_hash'], PDO::PARAM_STR);
$updates['amendment_body_id'] = array($amendment['chamber_id'], PDO::PARAM_INT);
$updates['amendment_mime_id'] = array($amendment['mime_id'], PDO::PARAM_INT);
$updates['amendment_date'] = array($this->dbDate($amendment['date']), PDO::PARAM_STR);
$updates['amendment_title'] = array($amendment['title'], PDO::PARAM_STR);
$updates['amendment_desc'] = array($amendment['description'], PDO::PARAM_STR);
$updates['legiscan_url'] = array($amendment['url'], PDO::PARAM_STR);
$updates['state_url'] = array($amendment['state_link'], PDO::PARAM_STR);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_amendment', $updates, $key);
$stmt->execute();
if (LegiScan::getConfig('want_amendment'))
$this->request('amendments', $amendment['amendment_id']);
}
}
foreach ($bill['supplements'] as $supplement)
{
$updates = array();
$key = array(
'supplement_id' => array($supplement['supplement_id'], PDO::PARAM_INT),
);
if (($exists_id = $this->checkExists('bill_supplement', $supplement['supplement_id'])))
{
foreach ($bill_old['supplements'] as $old_supplement)
{
if ($supplement['supplement_id'] == $old_supplement['supplement_id'])
{
if ($supplement['type_id'] != $old_supplement['type_id'])
$updates['supplement_type_id'] = array($supplement['type_id'], PDO::PARAM_INT);
if ($supplement['mime_id'] != $old_supplement['mime_id'])
$updates['supplement_mime_id'] = array($supplement['mime_id'], PDO::PARAM_INT);
if ($supplement['date'] != $old_supplement['date'])
$updates['supplement_date'] = array($this->dbDate($supplement['date']), PDO::PARAM_STR);
if ($supplement['title'] != $old_supplement['title'])
$updates['supplement_title'] = array($supplement['title'], PDO::PARAM_STR);
if ($supplement['description'] != $old_supplement['description'])
$updates['supplement_desc'] = array($supplement['description'], PDO::PARAM_STR);
if ($supplement['url'] != $old_supplement['url'])
$updates['legiscan_url'] = array($supplement['url'], PDO::PARAM_STR);
if ($supplement['state_link'] != $old_supplement['state_link'])
$updates['state_url'] = array($supplement['state_link'], PDO::PARAM_STR);
if ($supplement['supplement_size'] != $old_supplement['supplement_size'])
$updates['supplement_size'] = array($supplement['supplement_size'], PDO::PARAM_INT);
if ($supplement['supplement_hash'] != $old_supplement['supplement_hash'])
$updates['supplement_hash'] = array($supplement['supplement_hash'], PDO::PARAM_STR);
break;
}
}
if ($updates)
{
$stmt = $this->makeSQLStatement('update', 'ls_bill_supplement', $updates, $key);
$stmt->execute();
}
}
else
{
$updates['supplement_id'] = array($supplement['supplement_id'], PDO::PARAM_INT);
$updates['bill_id'] = array($bill['bill_id'], PDO::PARAM_INT);
$updates['local_copy'] = array(0, PDO::PARAM_INT);
$updates['supplement_size'] = array($supplement['supplement_size'], PDO::PARAM_INT);
$updates['supplement_hash'] = array($supplement['supplement_hash'], PDO::PARAM_STR);
$updates['supplement_type_id'] = array($supplement['type_id'], PDO::PARAM_INT);
$updates['supplement_mime_id'] = array($supplement['mime_id'], PDO::PARAM_INT);
$updates['supplement_date'] = array($this->dbDate($supplement['date']), PDO::PARAM_INT);
$updates['supplement_title'] = array($supplement['title'], PDO::PARAM_INT);
$updates['supplement_desc'] = array($supplement['description'], PDO::PARAM_STR);
$updates['legiscan_url'] = array($supplement['url'], PDO::PARAM_STR);
$updates['state_url'] = array($supplement['state_link'], PDO::PARAM_STR);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_supplement', $updates, $key);
$stmt->execute();
if (LegiScan::getConfig('want_supplement'))
$this->request('supplements', $supplement['supplement_id']);
}
}
$sast_ids = $old_sast_ids = array();
foreach ($bill['sasts'] as $sast)
$sast_ids[] = $sast['sast_bill_id'];
foreach ($bill_old['sasts'] as $old_sast)
$old_sast_ids[] = $old_sast['sast_bill_id'];
foreach ($bill['sasts'] as $sast)
{
if (!in_array($sast['sast_bill_id'], $old_sast_ids))
{
$sql = "INSERT INTO ls_bill_sast (
bill_id, sast_type_id, sast_bill_id, sast_bill_number
) VALUES (
:bill_id, :sast_type_id, :sast_bill_id, :sast_bill_number
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':sast_type_id', $sast['type_id'], PDO::PARAM_INT);
$stmt->bindValue(':sast_bill_id', $sast['sast_bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':sast_bill_number', $sast['sast_bill_number'], PDO::PARAM_STR);
$stmt->execute();
}
}
foreach ($bill_old['sasts'] as $old_sast)
{
if (!in_array($old_sast['sast_bill_id'], $sast_ids))
{
$sql = "DELETE FROM ls_bill_sast WHERE bill_id = :bill_id AND sast_bill_id = :sast_bill_id AND sast_type_id = :sast_type_id";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':sast_bill_id', $old_sast['sast_bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':sast_type_id', $old_sast['sast_type_id'], PDO::PARAM_INT);
$stmt->execute();
}
}
$subject_ids = $old_subject_ids = array();
foreach ($bill['subjects'] as $subject)
$subject_ids[] = $subject['subject_id'];
foreach ($bill_old['subjects'] as $old_subject)
$old_subject_ids[] = $old_subject['subject_id'];
foreach ($bill['subjects'] as $subject)
{
if (!in_array($subject['subject_id'], $old_subject_ids))
{
$sql = "INSERT INTO ls_bill_subject (
bill_id, subject_id
) VALUES (
:bill_id, :subject_id
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':subject_id', $subject['subject_id'], PDO::PARAM_INT);
$stmt->execute();
$subject_exists_id = $this->checkExists('subject', $subject['subject_id']);
if (!$subject_exists_id)
{
$sql = "INSERT INTO ls_subject (
subject_id, state_id, subject_name
) VALUES (
:subject_id, :state_id, :subject_name
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':subject_id', $subject['subject_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $bill['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':subject_name', $subject['subject_name'], PDO::PARAM_STR);
$stmt->execute();
}
}
}
foreach ($bill_old['subjects'] as $old_subject)
{
if (!in_array($old_subject['subject_id'], $subject_ids))
{
$sql = "DELETE FROM ls_bill_subject WHERE bill_id = :bill_id AND subject_id = :subject_id";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':subject_id', $old_subject['subject_id'], PDO::PARAM_INT);
$stmt->execute();
}
}
foreach ($bill['calendar'] as $cal)
{
$event_hash = md5(strtolower("{$cal['type']}-{$cal['date']}-{$cal['time']}-{$cal['location']}-{$cal['description']}"));
$event_hash = substr($event_hash, 0, 8);
$sql = "SELECT 1 FROM ls_bill_calendar WHERE bill_id = :bill_id AND event_hash = :event_hash";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':event_hash', $event_hash, PDO::PARAM_STR);
$stmt->execute();
if (!$stmt->fetchColumn())
{
$key = array(
'bill_id' => array($bill['bill_id'], PDO::PARAM_INT),
'event_hash' => array($event_hash, PDO::PARAM_STR),
);
$updates = array();
$updates['event_type_id'] = array($cal['type_id'], PDO::PARAM_INT);
$updates['event_date'] = array($this->dbDate($cal['date']), PDO::PARAM_STR);
$updates['event_time'] = array($cal['time'], PDO::PARAM_STR);
$updates['event_location'] = array($cal['location'], PDO::PARAM_STR);
$updates['event_desc'] = array($cal['description'], PDO::PARAM_STR);
$stmt = $this->makeSQLStatement('insert', 'ls_bill_calendar', $updates, $key);
$stmt->execute();
}
}
}
$this->db->commit();
$this->middlewareSignal('bill', $bill['bill_id']);
} catch (PDOException $e) {
$this->db->rollback();
throw($e);
}
if (!empty($this->missing))
return $this->missing;
else
return array();
}
public function processBillText($payload)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processBillText payload status = "' . $payload['status'] . '"');
$text = $payload['text'];
$now = date('Y-m-d H:i:s');
try {
if (($exists_id = $this->checkExists('bill_text', $text['doc_id'])))
$sql = "UPDATE ls_bill_text
SET bill_id = :bill_id,
local_copy = :local_copy,
bill_text_type_id = :bill_text_type_id,
bill_text_mime_id = :bill_text_mime_id,
bill_text_date = :bill_text_date,
bill_text_size = :bill_text_size,
bill_text_hash = :bill_text_hash,
updated = :updated
WHERE text_id = :text_id";
else
$sql = "INSERT INTO ls_bill_text (
text_id, bill_id, local_copy, bill_text_type_id,
bill_text_mime_id, bill_text_date, bill_text_size, bill_text_hash,
updated, created
) VALUES (
:text_id, :bill_id, :local_copy, :bill_text_type_id,
:bill_text_mime_id, :bill_text_date, :bill_text_size, :bill_text_hash,
:updated, :created
)";
$this->db->beginTransaction();
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':text_id', $text['doc_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_id', $text['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':local_copy', 0, PDO::PARAM_INT);
$stmt->bindValue(':bill_text_size', $text['text_size'], PDO::PARAM_INT);
$stmt->bindValue(':bill_text_hash', $text['text_hash'], PDO::PARAM_STR);
$stmt->bindValue(':bill_text_type_id', $text['type_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_text_mime_id', $text['mime_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_text_date', $this->dbDate($text['date']), PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
if (!$exists_id)
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if ($text['doc'] != '')
{
$blob = base64_decode($text['doc']);
if ($blob !== false)
{
$cache_file = $this->getCacheFilename('text', $text['doc_id']);
$this->cache->set($cache_file, $blob);
$sql = "UPDATE ls_bill_text
SET local_copy = :local_copy, local_fragment = :local_fragment
WHERE text_id = :text_id";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':local_copy', 1, PDO::PARAM_INT);
$stmt->bindValue(':local_fragment', $cache_file, PDO::PARAM_STR);
$stmt->bindValue(':text_id', $text['doc_id'], PDO::PARAM_INT);
$stmt->execute();
}
else
{
throw new APIException('Could not decode bill text blob');
}
}
$this->db->commit();
$this->middlewareSignal('text', $text['doc_id']);
} catch (PDOException $e) {
$this->db->rollback();
throw($e);
} catch (APIAccessException $e) {
$this->db->rollback();
throw($e);
} catch (APIException $e) {
$this->db->rollback();
throw($e);
}
return true;
}
public function processAmendment($payload)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processAmendment payload status = "' . $payload['status'] . '"');
$amendment = $payload['amendment'];
try {
if (($exists_id = $this->checkExists('bill_amendment', $amendment['amendment_id'])))
$sql = "UPDATE ls_bill_amendment
SET bill_id = :bill_id,
local_copy = :local_copy,
adopted = :adopted,
amendment_body_id = :amendment_body_id,
amendment_mime_id = :amendment_mime_id,
amendment_date = :amendment_date,
amendment_title = :amendment_title,
amendment_desc = :amendment_desc,
amendment_size = :amendment_size,
amendment_hash = :amendment_hash,
updated = :updated
WHERE amendment_id = :amendment_id";
else
$sql = "INSERT INTO ls_bill_amendment (
amendment_id, bill_id, local_copy, adopted,
amendment_body_id, amendment_mime_id, amendment_date,
amendment_title, amendment_desc, amendment_size, amendment_hash,
updated, created
) VALUES (
:amendment_id, :bill_id, :local_copy, :adopted,
:amendment_body_id, :amendment_mime_id, :amendment_date,
:amendment_title, :amendment_desc, :amendment_size, :amendment_hash,
:updated, :created
)";
$now = date('Y-m-d H:i:s');
$this->db->beginTransaction();
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':amendment_id', $amendment['amendment_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_id', $amendment['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':local_copy', 0, PDO::PARAM_INT);
$stmt->bindValue(':adopted', $amendment['adopted'], PDO::PARAM_INT);
$stmt->bindValue(':amendment_size', $amendment['amendment_size'], PDO::PARAM_INT);
$stmt->bindValue(':amendment_hash', $amendment['amendment_hash'], PDO::PARAM_STR);
$stmt->bindValue(':amendment_body_id', $amendment['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':amendment_mime_id', $amendment['mime_id'], PDO::PARAM_INT);
$stmt->bindValue(':amendment_date', $this->dbDate($amendment['date']), PDO::PARAM_STR);
$stmt->bindValue(':amendment_title', $amendment['title'], PDO::PARAM_STR);
$stmt->bindValue(':amendment_desc', $amendment['description'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
if (!$exists_id)
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if ($amendment['doc'] != '')
{
$blob = base64_decode($amendment['doc']);
if ($blob !== false)
{
$cache_file = $this->getCacheFilename('amendment', $amendment['amendment_id']);
$this->cache->set($cache_file, $blob);
$sql = "UPDATE ls_bill_amendment
SET local_copy = :local_copy, local_fragment = :local_fragment
WHERE amendment_id = :amendment_id";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':local_copy', 1, PDO::PARAM_INT);
$stmt->bindValue(':local_fragment', $cache_file, PDO::PARAM_STR);
$stmt->bindValue(':amendment_id', $amendment['amendment_id'], PDO::PARAM_INT);
$stmt->execute();
}
else
{
throw new APIException('Could not decode amendment text blob');
}
}
$this->db->commit();
$this->middlewareSignal('amendment', $amendment['amendment_id']);
} catch (PDOException $e) {
$this->db->rollback();
throw($e);
} catch (APIAccessException $e) {
$this->db->rollback();
throw($e);
} catch (APIException $e) {
$this->db->rollback();
throw($e);
}
return true;
}
public function processSupplement($payload)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processSupplement payload status = "' . $payload['status'] . '"');
$supplement = $payload['supplement'];
try {
if (($exists_id = $this->checkExists('bill_supplement', $supplement['supplement_id'])))
$sql = "UPDATE ls_bill_supplement
SET bill_id = :bill_id, local_copy = :local_copy,
supplement_type_id = :supplement_type_id,
supplement_mime_id = :supplement_mime_id,
supplement_date = :supplement_date,
supplement_title = :supplement_title,
supplement_desc = :supplement_desc,
supplement_size = :supplement_size,
supplement_hash = :supplement_hash,
updated = :updated
WHERE supplement_id = :supplement_id";
else
$sql = "INSERT INTO ls_bill_supplement (
supplement_id, bill_id, local_copy, supplement_type_id,
supplement_mime_id, supplement_date, supplement_title,
supplement_desc, supplement_size, supplement_hash,
updated, created
) VALUES (
:supplement_id, :bill_id, :local_copy, :supplement_type_id,
:supplement_mime_id, :supplement_date, :supplement_title,
:supplement_desc, :supplement_size, :supplement_hash,
:updated, :created
)";
$now = date('Y-m-d H:i:s');
$this->db->beginTransaction();
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':supplement_id', $supplement['supplement_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_id', $supplement['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':local_copy', 0, PDO::PARAM_INT);
$stmt->bindValue(':supplement_size', $supplement['supplement_size'], PDO::PARAM_INT);
$stmt->bindValue(':supplement_hash', $supplement['supplement_hash'], PDO::PARAM_STR);
$stmt->bindValue(':supplement_type_id', $supplement['type_id'], PDO::PARAM_INT);
$stmt->bindValue(':supplement_mime_id', $supplement['mime_id'], PDO::PARAM_INT);
$stmt->bindValue(':supplement_date', $this->dbDate($supplement['date']), PDO::PARAM_STR);
$stmt->bindValue(':supplement_title', $supplement['title'], PDO::PARAM_STR);
$stmt->bindValue(':supplement_desc', $supplement['description'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
if (!$exists_id)
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if ($supplement['doc'] != '')
{
$blob = base64_decode($supplement['doc']);
if ($blob !== false)
{
$cache_file = $this->getCacheFilename('supplement', $supplement['supplement_id']);
$this->cache->set($cache_file, $blob);
$sql = "UPDATE ls_bill_supplement
SET local_copy = :local_copy, local_fragment = :local_fragment
WHERE supplement_id = :supplement_id";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':local_copy', 1, PDO::PARAM_INT);
$stmt->bindValue(':local_fragment', $cache_file, PDO::PARAM_STR);
$stmt->bindValue(':supplement_id', $supplement['supplement_id'], PDO::PARAM_INT);
$stmt->execute();
}
else
{
throw new APIException('Could not decode supplement text blob');
}
}
$this->db->commit();
$this->middlewareSignal('supplement', $supplement['supplement_id']);
} catch (PDOException $e) {
$this->db->rollback();
throw($e);
} catch (APIAccessException $e) {
$this->db->rollback();
throw($e);
} catch (APIException $e) {
$this->db->rollback();
throw($e);
}
return true;
}
public function processRollCall($payload)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processRollCall payload status = "' . $payload['status'] . '"');
$roll_call = $payload['roll_call'];
try {
if (($exists_id = $this->checkExists('bill_vote', $roll_call['roll_call_id'])))
$sql = "UPDATE ls_bill_vote
SET bill_id = :bill_id, roll_call_body_id = :roll_call_body_id,
roll_call_date = :roll_call_date,
roll_call_desc = :roll_call_desc,
yea = :yea, nay = :nay,
nv = :nv, absent = :absent,
total = :total, passed = :passed,
updated = :updated
WHERE roll_call_id = :roll_call_id";
else
$sql = "INSERT INTO ls_bill_vote (
roll_call_id, bill_id, roll_call_body_id, roll_call_date,
roll_call_desc, yea, nay, nv, absent, total, passed,
updated, created
) VALUES (
:roll_call_id, :bill_id, :roll_call_body_id, :roll_call_date,
:roll_call_desc, :yea, :nay, :nv, :absent, :total, :passed,
:updated, :created
)";
$now = date('Y-m-d H:i:s');
$this->db->beginTransaction();
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':roll_call_id', $roll_call['roll_call_id'], PDO::PARAM_INT);
$stmt->bindValue(':bill_id', $roll_call['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':roll_call_body_id', $roll_call['chamber_id'], PDO::PARAM_INT);
$stmt->bindValue(':roll_call_date', $this->dbDate($roll_call['date']), PDO::PARAM_STR);
$stmt->bindValue(':roll_call_desc', $roll_call['desc'], PDO::PARAM_STR);
$stmt->bindValue(':yea', $roll_call['yea'], PDO::PARAM_INT);
$stmt->bindValue(':nay', $roll_call['nay'], PDO::PARAM_INT);
$stmt->bindValue(':nv', $roll_call['nv'], PDO::PARAM_INT);
$stmt->bindValue(':absent', $roll_call['absent'], PDO::PARAM_INT);
$stmt->bindValue(':total', $roll_call['total'], PDO::PARAM_INT);
$stmt->bindValue(':passed', $roll_call['passed'], PDO::PARAM_INT);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
if (!$exists_id)
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
if ($exists_id)
$this->db
->prepare('DELETE FROM ls_bill_vote_detail WHERE roll_call_id = :roll_call_id')
->execute([$roll_call['roll_call_id']]);
foreach ($roll_call['votes'] as $vote)
{
$sql = "INSERT INTO ls_bill_vote_detail (
roll_call_id, people_id, vote_id
) VALUES (
:roll_call_id, :people_id, :vote_id
)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':roll_call_id', $roll_call['roll_call_id'], PDO::PARAM_INT);
$stmt->bindValue(':people_id', $vote['people_id'], PDO::PARAM_INT);
$stmt->bindValue(':vote_id', $vote['vote_id'], PDO::PARAM_INT);
$stmt->execute();
if (!$this->checkExists('people', $vote['people_id']))
$this->request('sponsors', $vote['people_id']);
}
$this->db->commit();
$this->middlewareSignal('rollcall', $roll_call['roll_call_id']);
} catch (PDOException $e) {
$this->db->rollback();
throw($e);
}
if (isset($this->missing['sponsors']))
return $this->missing['sponsors'];
else
return array();
}
public function processPerson($payload)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processPerson payload status = "' . $payload['status'] . '"');
$person = $payload['person'];
$now = date('Y-m-d H:i:s');
try {
if (($exists_id = $this->checkExists('people', $person['people_id'])))
$sql = "UPDATE ls_people
SET state_id = :state_id, role_id = :role_id,
party_id = :party_id, name = :name,
first_name = :first_name, middle_name = :middle_name,
last_name = :last_name, suffix = :suffix,
nickname = :nickname, district = :district,
committee_sponsor_id = :committee_sponsor_id,
votesmart_id = :votesmart_id, followthemoney_eid = :followthemoney_eid,
opensecrets_id = :opensecrets_id, ballotpedia = :ballotpedia,
knowwho_pid = :knowwho_pid, person_hash = :person_hash,
updated = :updated
WHERE people_id = :people_id";
else
$sql = "INSERT INTO ls_people (
people_id, state_id, role_id, party_id, name,
first_name, middle_name, last_name, suffix,
nickname, district, committee_sponsor_id,
votesmart_id, followthemoney_eid, opensecrets_id,
ballotpedia, knowwho_pid, person_hash, updated, created
) VALUES (
:people_id, :state_id, :role_id, :party_id, :name,
:first_name, :middle_name, :last_name, :suffix,
:nickname, :district, :committee_sponsor_id,
:votesmart_id, :followthemoney_eid, :opensecrets_id,
:ballotpedia, :knowwho_pid, :person_hash, :updated, :created
)";
$this->db->beginTransaction();
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':people_id', $person['people_id'], PDO::PARAM_INT);
$stmt->bindValue(':state_id', $person['state_id'], PDO::PARAM_INT);
$stmt->bindValue(':role_id', $person['role_id'], PDO::PARAM_INT);
$stmt->bindValue(':party_id', $person['party_id'], PDO::PARAM_INT);
$stmt->bindValue(':name', $person['name'], PDO::PARAM_STR);
$stmt->bindValue(':first_name', $person['first_name'], PDO::PARAM_STR);
$stmt->bindValue(':middle_name', $person['middle_name'], PDO::PARAM_STR);
$stmt->bindValue(':last_name', $person['last_name'], PDO::PARAM_STR);
$stmt->bindValue(':suffix', $person['suffix'], PDO::PARAM_STR);
$stmt->bindValue(':nickname', $person['nickname'], PDO::PARAM_STR);
$stmt->bindValue(':district', $person['district'], PDO::PARAM_STR);
$stmt->bindValue(':committee_sponsor_id', $person['committee_id'], PDO::PARAM_INT);
$stmt->bindValue(':ballotpedia', $person['ballotpedia'], PDO::PARAM_STR);
$stmt->bindValue(':followthemoney_eid', $person['ftm_eid'], PDO::PARAM_INT);
$stmt->bindValue(':votesmart_id', $person['votesmart_id'], PDO::PARAM_INT);
$stmt->bindValue(':knowwho_pid', $person['knowwho_pid'], PDO::PARAM_INT);
$stmt->bindValue(':opensecrets_id', $person['opensecrets_id'], PDO::PARAM_STR);
$stmt->bindValue(':person_hash', $person['person_hash'], PDO::PARAM_STR);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
if (!$exists_id)
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
$this->db->commit();
$this->middlewareSignal('people', $person['people_id']);
} catch (PDOException $e) {
$this->db->rollback();
throw($e);
}
return true;
}
public function processSearch($payload, $import_type = LegiScan::IMPORT_ALL, $relevance_cutoff = 0)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processSearch payload status = "' . $payload['status'] . '"');
$results = $payload['searchresult'];
$summary = array_shift($results);
foreach ($results as $bill)
{
if ($bill['relevance'] > $relevance_cutoff)
{
switch ($import_type)
{
case LegiScan::IMPORT_NEW:
if (!$this->checkExists('bill', $bill['bill_id']))
$this->request('bills', $bill['bill_id']);
break;
case LegiScan::IMPORT_CHANGED:
case LegiScan::IMPORT_ALL:
$sql = "SELECT bill_id
FROM ls_bill
WHERE bill_id = :bill_id AND change_hash = :change_hash";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':change_hash', $bill_id['change_hash'], PDO::PARAM_STR);
$stmt->execute();
$exists = $stmt->fetchColumn();
if (!$exists)
$this->request('bills', $bill['bill_id']);
break;
}
}
}
if (isset($this->missing['bills']))
return $this->missing['bills'];
else
return array();
}
public function processMonitorList($payload, $import_type = LegiScan::IMPORT_ALL)
{
$this->resetMissing();
if (isset($payload['status']) && $payload['status'] != LegiScan::API_OK)
throw new APIStatusException('processMonitoredList payload status = "' . $payload['status'] . '"');
foreach ($payload['monitorlist'] as $bill)
{
switch ($import_type)
{
case LegiScan::IMPORT_NEW:
if (!$this->checkExists('bill', $bill['bill_id']))
$this->request('bills', $bill['bill_id']);
break;
case LegiScan::IMPORT_CHANGED:
case LegiScan::IMPORT_ALL:
$sql = "SELECT bill_id
FROM ls_bill
WHERE bill_id = :bill_id AND change_hash = :change_hash";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill['bill_id'], PDO::PARAM_INT);
$stmt->bindValue(':change_hash', $bill['change_hash'], PDO::PARAM_STR);
$stmt->execute();
$exists = $stmt->fetchColumn();
if (!$exists)
$this->request('bills', $bill['bill_id']);
break;
}
}
if (isset($this->missing['bills']))
return $this->missing['bills'];
else
return array();
}
function monitor($bill_id, $add = true, $stance = LegiScan::STANCE_WATCH)
{
$stmt = null;
if ($add)
{
$now = date('Y-m-d H:i:s');
if (!$this->checkExists('monitor', $bill_id))
$sql = 'INSERT INTO ls_monitor (bill_id, stance, created) VALUES (:bill_id, :stance, :created)';
else
$sql = 'UPDATE ls_monitor SET stance = :stance, created = :created WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->bindValue(':stance', $stance, PDO::PARAM_INT);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
$sql = 'DELETE FROM ls_ignore WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
}
elseif (!$add)
{
$sql = 'DELETE FROM ls_monitor WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
}
return true;
}
function ignore($bill_id, $add = true)
{
$stmt = null;
if ($add && !$this->checkExists('ignore', $bill_id))
{
$now = date('Y-m-d H:i:s');
$sql = 'INSERT INTO ls_ignore (bill_id, created) VALUES (:bill_id, :created)';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
$sql = 'DELETE FROM ls_monitor WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
}
elseif (!$add)
{
$sql = 'DELETE FROM ls_ignore WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
}
return true;
}
public function checkExists($table, $id, $skip_cache = false)
{
$table = str_replace('ls_', '', strtolower($table));
$sql = '';
$result = false;
$key = 'ls_' . $table . ':' . $id;
if (($result = $this->memcache->get($key)) === false || $skip_cache)
{
switch ($table)
{
case 'bill':
$sql = 'SELECT bill_id FROM ls_bill WHERE bill_id = :id';
break;
case 'monitor':
$sql = 'SELECT bill_id FROM ls_monitor WHERE bill_id = :id';
break;
case 'ignore':
$sql = 'SELECT bill_id FROM ls_ignore WHERE bill_id = :id';
break;
case 'session':
$sql = 'SELECT session_id FROM ls_session WHERE session_id = :id';
break;
case 'committee':
$sql = 'SELECT committee_id FROM ls_committee WHERE committee_id = :id';
break;
case 'people':
$sql = 'SELECT people_id FROM ls_people WHERE people_id = :id';
break;
case 'bill_text':
$sql = 'SELECT text_id FROM ls_bill_text WHERE text_id = :id';
break;
case 'bill_vote':
$sql = 'SELECT roll_call_id FROM ls_bill_vote WHERE roll_call_id = :id';
break;
case 'bill_amendment':
$sql = 'SELECT amendment_id FROM ls_bill_amendment WHERE amendment_id = :id';
break;
case 'bill_supplement':
$sql = 'SELECT supplement_id FROM ls_bill_supplement WHERE supplement_id = :id';
break;
case 'subject':
$sql = 'SELECT subject_id FROM ls_subject WHERE subject_id = :id';
break;
}
if ($sql)
{
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':id', $id);
$stmt->execute();
$result = $stmt->fetchColumn();
if ($result)
{
if (get_class($this->memcache) == 'Memcache')
$this->memcache->set($key, $result, false, 1800);
else
$this->memcache->set($key, $result, 1800);
}
}
}
return $result;
}
private function makeSQLStatement($type, $table, $updates, $keys)
{
$type = strtolower($type);
if ($type == 'update')
{
$sets = array();
$sql = "UPDATE $table SET ";
foreach (array_keys($updates) as $field)
{
$sets[] = "{$field} = :{$field}";
}
$sql .= implode(', ', $sets);
$where = array();
foreach (array_keys($keys) as $field)
{
$where[] = "{$field} = :{$field}";
}
$sql .= ' WHERE ' . implode(' AND ', $where);
}
else
{
$vals = array();
$sql = "INSERT INTO $table (" . implode(', ', array_keys(array_merge($keys, $updates))) . ') VALUES (';
foreach (array_keys(array_merge($keys, $updates)) as $field)
{
$vals[] = ":{$field}";
}
$sql .= implode(', ', $vals);
$sql .= ')';
}
try {
$stmt = $this->db->prepare($sql);
} catch (PDOException $e) {
throw new APIException("makeSQLStatement $type $table - " . $e->getMessage());
}
foreach (array_merge($updates, $keys) as $field => $value)
{
$stmt->bindValue(":{$field}", $value[0], $value[1]);
}
return $stmt;
}
private function billInit()
{
$bill = array();
$bill['bill_id'] = 0;
$bill['change_hash'] = '';
$bill['session'] = array('prefile'=>0,'sine_die'=>0,'prior'=>0);
$bill['session_id'] = 0;
$bill['url'] = '';
$bill['state_link'] = '';
$bill['completed'] = 0;
$bill['status'] = 0;
$bill['status_date'] = '';
$bill['progress'] = array();
$bill['state'] = '';
$bill['state_id'] = 0;
$bill['bill_number'] = '';
$bill['bill_type'] = '';
$bill['bill_type_id'] = 0;
$bill['body'] = '';
$bill['body_id'] = 0;
$bill['current_body'] = '';
$bill['current_body_id'] = 0;
$bill['title'] = '';
$bill['description'] = '';
$bill['pending_committee_id'] = 0;
$bill['committee'] = array();
$bill['referrals'] = array();
$bill['history'] = array();
$bill['sponsors'] = array();
$bill['sasts'] = array();
$bill['subjects'] = array();
$bill['texts'] = array();
$bill['votes'] = array();
$bill['amendments'] = array();
$bill['supplements'] = array();
$bill['calendar'] = array();
return $bill;
}
public function loadBill($bill_id)
{
$bill = $this->billInit();
$sql = 'SELECT *
FROM ls_bill b
INNER JOIN ls_session s ON b.session_id = s.session_id
WHERE b.bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
$r = $stmt->fetch();
if (empty($r))
return $bill;
$bill['bill_id'] = $r['bill_id'];
$bill['change_hash'] = $r['change_hash'];
$bill['session_id'] = $r['session_id'];
$bill['session'] = array(
'session_id' => $r['session_id'],
'year_start' => $r['year_start'],
'year_end' => $r['year_end'],
'prefile' => $r['prefile'],
'sine_die' => $r['sine_die'],
'prior' => $r['prior'],
'special' => $r['special'],
'session_tag' => $r['session_tag'],
'session_title' => $r['session_title'],
'session_name' => $r['session_name'],
);
$bill['url'] = $r['legiscan_url'];
$bill['state_link'] = $r['state_url'];
$bill['status'] = $r['status_id'];
$bill['status_date'] = $r['status_date'];
$bill['state_id'] = $r['state_id'];
$bill['bill_number'] = $r['bill_number'];
$bill['bill_type_id'] = $r['bill_type_id'];
$bill['body_id'] = $r['body_id'];
$bill['current_body_id'] = $r['current_body_id'];
$bill['title'] = $r['title'];
$bill['description'] = $r['description'];
$bill['pending_committee_id'] = $r['pending_committee_id'];
if ($r['pending_committee_id'])
{
$sql = 'SELECT * FROM ls_committee WHERE committee_id = :pending_committee_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':pending_committee_id', $r['pending_committee_id'], PDO::PARAM_INT);
$stmt->execute();
$r = $stmt->fetch();
$bill['committee'] = array(
'committee_id' => $r['committee_id'],
'chamber_id' => $r['committee_body_id'],
'name' => $r['committee_name']
);
}
$sql = 'SELECT * FROM ls_bill_referral WHERE bill_id = :bill_id ORDER BY referral_step';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['referrals'][] = array(
'date' => $r['referral_date'],
'committee_id' => $r['committee_id'],
);
}
$sql = 'SELECT * FROM ls_bill_history WHERE bill_id = :bill_id ORDER BY history_step';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['history'][] = array(
'date' => $r['history_date'],
'action' => $r['history_action'],
'chamber_id' => $r['history_body_id'],
'importance' => $r['history_major']
);
}
$sql = 'SELECT * FROM ls_bill_progress WHERE bill_id = :bill_id ORDER BY progress_step';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['progress'][] = array(
'date' => $r['progress_date'],
'event' => $r['progress_event_id']
);
}
$sql = 'SELECT *
FROM ls_bill_sponsor bs
INNER JOIN ls_people p ON bs.people_id = p.people_id
WHERE bill_id = :bill_id ORDER BY bs.sponsor_order';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['sponsors'][] = array(
'people_id' => $r['people_id'],
'person_hash' => $r['person_hash'],
'party_id' => $r['party_id'],
'role_id' => $r['role_id'],
'name' => $r['name'],
'first_name' => $r['first_name'],
'middle_name' => $r['middle_name'],
'last_name' => $r['last_name'],
'suffix' => $r['suffix'],
'nickname' => $r['nickname'],
'district' => $r['district'],
'ftm_eid' => $r['followthemoney_eid'],
'votesmart_id' => $r['votesmart_id'],
'opensecrets_id' => $r['opensecrets_id'],
'ballotpedia' => $r['ballotpedia'],
'sponsor_type_id' => $r['sponsor_type_id'],
'sponsor_order' => $r['sponsor_order'],
'committee_id' => $r['committee_sponsor_id']
);
}
$sql = 'SELECT * FROM ls_bill_vote WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['votes'][] = array(
'roll_call_id' => $r['roll_call_id'],
'date' => $r['roll_call_date'],
'desc' => $r['roll_call_desc'],
'yea' => $r['yea'],
'nay' => $r['nay'],
'nv' => $r['nv'],
'absent' => $r['absent'],
'total' => $r['total'],
'passed' => $r['passed'],
'chamber_id' => $r['roll_call_body_id'],
'url' => $r['legiscan_url'],
'state_link' => $r['state_url']
);
}
$sql = 'SELECT * FROM ls_bill_text WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['texts'][] = array(
'doc_id' => $r['text_id'],
'date' => $r['bill_text_date'],
'type_id' => $r['bill_text_type_id'],
'mime_id' => $r['bill_text_mime_id'],
'url' => $r['legiscan_url'],
'state_link' => $r['state_url'],
'text_size' => $r['bill_text_size'],
'text_hash' => $r['bill_text_hash']
);
}
$sql = 'SELECT * FROM ls_bill_amendment WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['amendments'][] = array(
'amendment_id' => $r['amendment_id'],
'adopted' => $r['adopted'],
'chamber_id' => $r['amendment_body_id'],
'date' => $r['amendment_date'],
'title' => $r['amendment_title'],
'description' => $r['amendment_desc'],
'mime_id' => $r['amendment_mime_id'],
'url' => $r['legiscan_url'],
'state_link' => $r['state_url'],
'amendment_size' => $r['amendment_size'],
'amendment_hash' => $r['amendment_hash']
);
}
$sql = 'SELECT * FROM ls_bill_supplement WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['supplements'][] = array(
'supplement_id' => $r['supplement_id'],
'date' => $r['supplement_date'],
'type_id' => $r['supplement_type_id'],
'title' => $r['supplement_title'],
'description' => $r['supplement_desc'],
'mime_id' => $r['supplement_mime_id'],
'url' => $r['legiscan_url'],
'state_link' => $r['state_url'],
'supplement_size' => $r['supplement_size'],
'supplement_hash' => $r['supplement_hash']
);
}
$sql = 'SELECT * FROM ls_bill_sast WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['sasts'][] = array(
'sast_bill_id' => $r['sast_bill_id'],
'sast_type_id' => $r['sast_type_id']
);
}
$sql = 'SELECT bs.subject_id, s.subject_name
FROM ls_bill_subject bs
INNER JOIN ls_subject s ON bs.subject_id = s.subject_id
WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['subjects'][] = array(
'subject_id' => $r['subject_id'],
'subject_name' => $r['subject_name']
);
}
$sql = 'SELECT * FROM ls_bill_calendar WHERE bill_id = :bill_id';
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':bill_id', $bill_id, PDO::PARAM_INT);
$stmt->execute();
while ($r = $stmt->fetch())
{
$bill['calendar'][] = array(
'type_id' => $r['event_type_id'],
'date' => $r['event_date'],
'time' => $r['event_time'],
'location' => $r['event_location'],
'description' => $r['event_desc']
);
}
return $bill;
}
public function request($object, $id)
{
static $requested = array();
$key = $object . ':' . $id;
if (!isset($requested[$key]))
{
$this->missing[$object][] = $id;
$requested[$key] = 1;
}
return true;
}
public function getMissing()
{
return $this->missing;
}
public function resetMissing()
{
$this->missing = array();
return true;
}
public function getDB()
{
return $this->db;
}
private function dbDate($date)
{
if ($this->massage && ($date == '0000-00-00' || $date == ''))
$date = null;
return $date;
}
public function getStateList()
{
static $state_list = array();
if (empty($state_list))
{
$sql = 'SELECT * FROM ls_state ORDER BY state_abbr';
$rs = $this->db->query($sql);
while ($r = $rs->fetch())
{
$state_list[$r['state_id']] = $r;
}
}
return $state_list;
}
public function middlewareSignal($object, $id)
{
$signal = strtolower(LegiScan::getConfig('middleware_signal'));
if (!$signal)
return true;
$now = date('Y-m-d H:i:s', time());
$object = strtolower($object);
if ($signal == 'table')
{
try {
$sql = "SELECT * FROM ls_signal WHERE object_type = :object AND object_id = :id";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':object', $object, PDO::PARAM_STR);
$stmt->bindValue(':id', $id, PDO::PARAM_INT);
$stmt->execute();
$semaphore = $stmt->fetch();
if ($semaphore == false)
$sql = 'INSERT INTO ls_signal (
object_type, object_id, processed,
updated, created
) VALUES (
:object_type, :object_id, :processed,
:updated, :created
)';
else
$sql = 'UPDATE ls_signal
SET processed = :processed, updated = :updated
WHERE object_type = :object_type AND object_id = :object_id';
if (!$semaphore || isset($semaphore['processed']) && $semaphore['processed'] >= 1)
{
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':object_type', $object, PDO::PARAM_STR);
$stmt->bindValue(':object_id', $id, PDO::PARAM_INT);
$stmt->bindValue(':processed', 0, PDO::PARAM_INT);
$stmt->bindValue(':updated', $now, PDO::PARAM_STR);
if (!$semaphore)
$stmt->bindValue(':created', $now, PDO::PARAM_STR);
$stmt->execute();
}
} catch (PDOException $e) {
return false;
}
}
elseif ($signal == 'directory')
{
$filename = $object . '.' . $id;
$file = realpath(__DIR__ . '/' . 'signal') . '/' . $filename;
$data = json_encode(array(
'object_type' => (string) $object,
'object_id' => (int) $id,
'updated' => (string) $now,
));
if (!file_exists($file))
{
if (!@file_put_contents($file, $data))
return false;
}
}
return true;
}
public function getCacheFilename($object, $id)
{
$suffix = array(
1 => 'html',
2 => 'pdf',
3 => 'wpd',
4 => 'doc',
5 => 'rtf',
6 => 'docx',
);
$object = strtolower($object);
switch ($object)
{
case 'text':
$sql = 'SELECT s.state_abbr, b.bill_number, b.session_id, bt.bill_text_mime_id AS mime_id
FROM ls_bill_text bt
INNER JOIN ls_bill b ON bt.bill_id = b.bill_id
INNER JOIN ls_state s ON b.state_id = s.state_id
WHERE bt.text_id = :id';
break;
case 'amendment':
$sql = 'SELECT s.state_abbr, b.bill_number, b.session_id, ba.amendment_mime_id AS mime_id
FROM ls_bill_amendment ba
INNER JOIN ls_bill b ON ba.bill_id = b.bill_id
INNER JOIN ls_state s ON b.state_id = s.state_id
WHERE ba.amendment_id = :id';
break;
case 'supplement':
$sql = 'SELECT s.state_abbr, b.bill_number, b.session_id, bs.supplement_mime_id AS mime_id
FROM ls_bill_supplement bs
INNER JOIN ls_bill b ON bs.bill_id = b.bill_id
INNER JOIN ls_state s ON b.state_id = s.state_id
WHERE bs.supplement_id = :id';
break;
}
$stmt = $this->db->prepare($sql);
$stmt->bindValue(':id', $id, PDO::PARAM_INT);
$stmt->execute();
$r = $stmt->fetch();
$filename = $object . '/' . $r['state_abbr'] . '/' . $r['session_id'] . '/' . $r['bill_number'] . '/' . $id . '/' . $suffix[$r['mime_id']];
$filename = strtolower($filename);
return $filename;
}
}