From 73cdacfddd70b4bcc829339bc52f4517f705a025 Mon Sep 17 00:00:00 2001 From: tomtom5152 Date: Thu, 6 Nov 2014 00:54:13 +0000 Subject: [PATCH] Added rig importer (beta) --- RIGS/importer.py | 42 ++++++++++++++++++++++++++++++++++++++++-- db.sqlite3 | Bin 1203200 -> 1203200 bytes 2 files changed, 40 insertions(+), 2 deletions(-) diff --git a/RIGS/importer.py b/RIGS/importer.py index f39060af..6eb42b66 100644 --- a/RIGS/importer.py +++ b/RIGS/importer.py @@ -47,6 +47,7 @@ def import_users(): object.save() print("Created " + str(object)) + def import_people(): cursor = setup_cursor() if cursor is None: @@ -135,19 +136,56 @@ def import_venues(delete=False): object.save() -def import_events(): +def import_rigs(): cursor = setup_cursor() if cursor is None: return + sql = """SELECT e.id, event, person_id, organisation_id, venue, description, status, start_date, start_time, end_date, end_time, access_date, access_time, meet_date, meet_time, meet_info, based_on_id, based_on_type, user_id, payment_method, order_no, payment_received, collectorsid FROM eventdetails AS e LEFT JOIN rigs AS r ON e.id = r.id WHERE describable_type = 'Rig'""" + cursor.execute(sql) + for row in cursor.fetchall(): + with transaction.atomic(), reversion.revision(): + venue = models.Venue.objects.get(name__iexact=row[4]) + status = { + 'Booked': models.Event.BOOKED, + 'Provisional': models.Event.PROVISIONAL, + 'Cancelled': models.Event.CANCELLED, + } + try: + object = models.Event.objects.get(pk=row[0]) + except ObjectDoesNotExist: + object = models.Event(pk=row[0]) + object.name = row[1] + object.person = row[2] + object.organisation = row[3] + object.venue = venue + object.notes = row[5] + object.status = status[row[6]] + object.start_date = row[7] + object.start_time = row[8] + object.end_date = row[9] + object.end_time = row[10] + object.access_at = datetime.combine(row[11], row[12]) + object.meet_at = datetime.combine(row[13], row[14]) + object.meet_info = row[15] + if row[17] == "Rig": + object.based_on = row[16] + object.dry_hire = row[18] + object.is_rig = True + object.mic = row[19] + object.payment_method = row[20] + object.purchase_order = row[21] + object.payment_received = row[22] + object.collector = row[23] def main(): - import_users() + # import_users() # import_people() # import_organisations() # import_vat_rates() # import_venues(True) # import_events() + import_rigs() if __name__ == "__main__": diff --git a/db.sqlite3 b/db.sqlite3 index 353dbc3e368feacfd9b1f11262db3e904b9ff39f..9343bef14592af3dd5ebdfbbd237d238f899643f 100644 GIT binary patch delta 1007 zcmaiyO>7!R7=~wez+f=gU@JCt)jF-KNQpxB7g(!5rYw++SZt#;>~0;oEaAtyu$b5g zj1na%hvd+zu{i9(hp48$-8p{&V5}bK&tUHrRbXh7ErFdf#zj6nOEc0R9YL!6PWcK5XDm;d_G_=MOm6@BQLR zU4RdO54=0(-B84O-+eTP!QP_#*HH)`0r&!b4=vx+L~Ag|{DE7(lw(SmhBkm-1N~?! z6OZ!BdNd{p*{BrfgE-o_3HG@{k!Cc4*0eCo5M(H#ahg^t6v|Pk1`;F~39a2*feahv#h{AH12Iy3=cPzv!hOJLO2Dwnb9qjSABU6Whh2 zQ8!CvBBYs}CRwTzdb%bsVkc7*^~#2*mkE(lI%!^^(m9b>k}6eI7a65vkZNwFrAQe= z(G^nUH^aTpdx3kp(iU^^wwM&jrKH$WYniH;6j()y(u!1Ol}@Ij@^BGxE$58;+o3h%{uGYbA;3ZZ;mcV!Vr=+w)^p_; zE?_H`ge(kjf;YExiCWdRTeFq62{0i8?WdIH_ z6Zhdify>s#BU@nXldjtf)}ziqAP}=EF~90F^V^lY8Qd(IW^spO3DP2;ct5aCWB$qE z;iCT$`lA3G4A*1+g9#TzGq{XD!)?f_zp%;frS8Y$pnECmoc4G~=V%lFs}c84-OGzn zX?0VPHCbxS=P7x4sYG1iiR%&LHnU7euH_<`G%fSQYO5s~YIr9eHl;5cyz(|Fg8eV4 qP?%vz_WZr)W%0ZQn?}$qZvPwYKL^+aCLAQ}VS?o7;j^rN#r`*Rjxrtq delta 729 zcmajbO-$2Z7zgmS@4lc6*zkh{6CiRkkhbfTVKnGINSE~;n`3JiB5oa{?OHY_ZfwB- z;eZECSQfLxjEM>tF2w9mjPYioS40mac;LuMj}R`tdNAHR{0`5Pf1c$3tnP8Ed)#Ip z-mG2m;vH`vytZB%!8(Z@47>*?;42Wo8?Zp^fVNhzZHvHP)jza{%vVXkx7GW}LB~4g z#G~BAy_rHWpH;NkmHIgO(Sn104D7cY>?cs)?{cB}90TWQ{s9OKYn}I8SZ?(Az|GpE zsSY=7D-ZM30$nQVxq@pkRg$D!x||&?>e+(q)~}bOs;FuzjQMG(`zyRpq@j9;NydUY ztY$RGh-^3($iY~I5)%Oxs*y6RO0ICMaD&r4az=>e1y{V96oT1QBBF#;-CU@@6+=QuU5Bqs`TTF;b1IxMB6BYv; z0Ub0PKk>EJ0Q;R78Uj52zn8XZ4WFsw-(%~?&5h$Gjt~eyOo$n=AXdbNv>C_E_Q7S# z7c78(CK~O%D+gG-kZc?QSbU>|$V&XgFSUzC`scgs~fUM$Eqes)Y1v