From 5ca3c6808cf3f3e8717f6051973d4a4adc50a7d6 Mon Sep 17 00:00:00 2001 From: MrWaradana Date: Fri, 24 Jan 2025 15:46:28 +0700 Subject: [PATCH] fix: create whole life cycle data create and update --- .../__pycache__/model.cpython-311.pyc | Bin 888 -> 1015 bytes .../__pycache__/schema.cpython-311.pyc | Bin 2763 -> 3129 bytes .../__pycache__/model.cpython-311.pyc | Bin 4248 -> 4123 bytes .../__pycache__/schema.cpython-311.pyc | Bin 7880 -> 7686 bytes .../__pycache__/service.cpython-311.pyc | Bin 3984 -> 4024 bytes src/plant_transaction_data/model.py | 1 - src/plant_transaction_data/schema.py | 3 -- src/plant_transaction_data/service.py | 30 +++++++++++------- 8 files changed, 18 insertions(+), 16 deletions(-) diff --git a/src/masterdata/__pycache__/model.cpython-311.pyc b/src/masterdata/__pycache__/model.cpython-311.pyc index f71ac25f931e438ed5b341e94c93c527933713cd..7f6af2f8717a921609bd1d42f1075cd80efc5f08 100644 GIT binary patch delta 264 zcmeyt_MM$~IWI340}xF5I5E9^BJTypDHHD*O#C9k$UgDCq%;Q;Ln=!uXA09A=4DI_ z46A_{0;0Hp(u~}bZ5a(1c_!yEIxF4cPDw3JF3Kz@$;{8YC0v@9SrVV07N47%SX^3^ znwy$eGI=9o8e`RD2_{VqA&CiUGsIS?ToBT~D5QTyNWa1RhLpk#wFP1uR4z!FUz9Sx zB4vJoMSQXYlP;t9E0US~h$-5dn^Err112#+ SWJ1k?*pDEYFIc3(1_A(SoJ?u} delta 174 zcmey){)3HoIWI340}#Z$h)?I8$a{e?Vd6alQT7z3HO$MH7#LOqF$6?$OnfiN$T_)? z(SVU_@*+m($?QyNjDeH$m^3FJVA5d}o&1(5N=gK%xJVR4hyjUT95%W6DWy57c12Q? e6Pcr}IT`gnFkliBL?+ZMi2VqX`GQ3nY#;#st}4U; diff --git a/src/masterdata/__pycache__/schema.cpython-311.pyc b/src/masterdata/__pycache__/schema.cpython-311.pyc index 62c253d87a60d49d02def4a92e9c0eae889eea48..0dca9795e0d9f5919fab6922ec5fe1081d238312 100644 GIT binary patch delta 978 zcmZvYKTH#G6vyw^{_d{5UTdM0R)m)FFP<2BF&!?UF*Rp`hNLFIhK3OCPza^uN4shh z2ThDg$#dx7z-A|-n=I;32jkL97#dt0Sxg`@Ir)1Bl+gOSyU)G*ec$ih`@SF1y?E$d zFsKN8eL3EF{7n29DiQJ(o|A_}f?s5k_(AogMa35F0OUNAqRJx)ws;ieQ3!TD>E6&) zEZ{C%wv?jDR3qY^>j%pmjsK<3tA8kJ>#i>WpA&rwXM=xaq}Qj-drm! z6<3!E_VRX_*#&#E1gdw2^umHSf0Om_v#ginKwRA@E|*vYH~J7>L=@4Fh(W{qfXqQ3 zoyp8rhXOfa6OFHu{`)!49%aHJ-f|BKPJ^Q(51sdY@C$0sz_q?XE zIIqWWd~5(ABd#E>AqEj)MB6+Y!cW(F0wcH0VT?x3f#tT}LrzLRiVarFwfTCc8PlDZ zz8}*ov(-qG>il-7-b#+u%DeL)GR>snB#r%~fwSN`e;W=pTHVL*zbvPqJ?6y!Wkxjgb;jz+{+~lmZ%}e##r0H5Pi315h2l@a6bW=b-Fbc>NW2n+V z2FN}FCd~#lbdj+}JI-PCIDcV@OG|vWMElk5=7lP}|56onuTOAkkfowgUGPQl`RCvd z;6xMA+JCV%0T`#}p`7<pF diff --git a/src/plant_transaction_data/__pycache__/model.cpython-311.pyc b/src/plant_transaction_data/__pycache__/model.cpython-311.pyc index 46923ac7e214c11001aaaf4b4a0d2fa040f44af5..f743fa1823cc2d74d18c77bb7f7e2ef033134bc5 100644 GIT binary patch delta 1465 zcmbQCI9q{tIWI340}y=Dot(aIBJaIO77z~zK1Z=KFidAiWr$)-VTfW%VT@vCVn}64 zWldpP!@P`%fnhZeLqHT8P8oKD%wz{f(R$7l77X27U^UoexN*wx;FRITDZ|IaU<333 zHjDUiY7#)mOcr3m?g1f$8nl2B#wjC$Q$`f0j2LbYh~v~GfsmQ}0EY*p5NgmoAdOQ- z2B(ZHP8m7e9+1bWNdX}^={7*Il}LGyqzP8k)PGO9Rb)Np%19j7J@gv{gy7VI9- zLa0IWfHqDU9h@?{IA!#3dq5wjCIf`b@+y*R+9+UI5I1MPiW$i0}jwzc_4i^HWN5QtgU-C%@rOcQs>l ZV*J2>ot$B^KxRelN3iS{9BRNu0|0S*^w$6Y delta 1620 zcmbQOFhh}dIWI340}%8#wWoia$a}Az6~qIA&s{*)bcR%hD8>|qD5ey~C}t*xR2Cp+ zO<`KYyo`~7VKop#KnfF3jAa=!Pz;D6Ac_s7K9xO%bq(7xCZG%uLuEK{%5c`>l;Q%* za04wuH;xCV3@=U@J{&TW-!gL4W3xm6hX#fyL7Xx|IAw%!%7`#A*Z_kKn-fHFY7#@p zOy0mGiq!)W2sLQYA&FB)3a5-TP8k{89+1VUNe&@1xq%tG2NV!$&^(}sQ$`7=j51Cc z72FaRAu~CE1-l0{5NgmopovpP3#W`WP8l8C9?-?9Ne>}2S%DS12MiEu&^%y> zQ^p9Vj4@6b6Wks!#i_{*Av5^{4i8u$)S!955~qw6P8n;QGBzpfEWr$#9Fs%XG>t+u z8E>&C7RQ&CW~OK|-Qq4N%FInHs*KN0t-QsWnU|7U;RaN}kyo0NlbDo~>ZfTtxsT0~ zgB@5{-eSs3*?f%c8MAp33j;#~9NrL7Z}5G<$=@M1fn@^AjF1ZgN*4u`t_Ub?VAYaiRH0MkQCzwX%g})>=y!2<0hVADHle0+cLG|l z0voUcBO3By89J~9{chyL60E`|)I7+C7OcPq?7)Z@`LGNf*n<8Z^(`j_{rNo?M$mQIobfu6Wqg(H-w2Q8KpRb5*_3rG$InVo?@B5zjarASn0&Oh1jHVF(w+QB0_Y~rqY%;s_CX?Iw)W}AsjR!ZJ-%gh8xgp=lUQl z!g;s`HI-*iLle%z3fzVPjeADm3@pP9=yf0;7U4WxgPIfh(1f$F0=Hqng?u;z%WwmF z8;}o+a2~Eftr7XqgtM>$w_!j>z8=zI^1S33=^-lVs_3J#9`c-%wLTvoHiqfUM`&3; zG}K>Hi$>+FO)>3xk+*%YFW402z5MTt8v`<YX^;Y-OqHiC0nmlfG+RRzi zMr$fNWm?(W_r{k3O`q%{PTyLS?y7ckVlr2-TIHKon}i~5zdHN*X@Idaab{3bwcjmR zR)P}lOi#N@QA&UP){V}&z$^7_VZ{iq8sV=-xDBM=?y}(>#l1z%Z!lZXe$eW+M!M)|yRaYs#)0-x*F%%r;=DL7uTw^Zr%~d8v zG5-NtF#1o`t?l61A*L>5lxs|q4F6#Vwl_-84IgFvnP^?g7&oiCZ~Qke!?R49e)v!B zShyhqi$U{ELQiZyI@(Qb^QZ8NEHyO&@|h|JC8ZC4^Mx`tDmzQm2snURA0A2>lGRn^>>^wT!(!mBrmezuSM`GD>B&iMp48E$4cN^$g`ks8&} zA#OwcB?N#=5W+Em)@kBfPc9*NVeEKZD!kC0I9E(+oncCYD delta 563 zcmZ{g&ui2`9K~mv%e*Z9U zLR3g?cvhHta$AJGdm-e9xB)mXxunz-ulFXdEl0IwT3cbYm4CBfb0q7B?T_uQPi33Q zHj(YHQk+90%?zIPA1VPnxS!^oT;_2d;E7n9iL@E2xlD6|)x>aO!;1`WFh>lJ8ck+2 zgH}=*=U@yiWpX4E%iR{ysvJON={q*No2Prd?a$+E{xQWq!#=_O??km?buv;Xsp>G* zA+ke4N2#DBtJBtAL4Pf+^Wn12IW~soEs8ycy%;YX(!|Ce$F pT1oi^M}j;DN-oc*t^ka?TuB|cDxM6d(nx`?Qif|~- Optional[PlantTransactionData]: """Returns a document based on the given document id.""" - query = Select(PlantTransactionData).filter(PlantTransactionData.id == transaction_data_id) + query = Select(PlantTransactionData).filter( + PlantTransactionData.id == transaction_data_id + ) result = await db_session.execute(query) return result.scalars().one_or_none() @@ -38,36 +40,40 @@ async def get_all( return results -async def create(*, db_session: DbSession, yeardata_in: PlantTransactionDataCreate): +async def create( + *, db_session: DbSession, transaction_data_in: PlantTransactionDataCreate +): """Creates a new document.""" - yeardata = PlantTransactionData(**yeardata_in.model_dump()) - db_session.add(yeardata) + transaction_data = PlantTransactionData(**transaction_data_in.model_dump()) + db_session.add(transaction_data) await db_session.commit() - return yeardata + return transaction_data async def update( *, db_session: DbSession, - yeardata: PlantTransactionData, - yeardata_in: PlantTransactionDataUpdate, + transaction_data: PlantTransactionData, + transaction_data_in: PlantTransactionDataUpdate, ): """Updates a document.""" - data = yeardata_in.model_dump() + data = transaction_data_in.model_dump() - update_data = yeardata_in.model_dump(exclude_defaults=True) + update_data = transaction_data_in.model_dump(exclude_defaults=True) for field in data: if field in update_data: - setattr(yeardata, field, update_data[field]) + setattr(transaction_data, field, update_data[field]) await db_session.commit() - return yeardata + return transaction_data async def delete(*, db_session: DbSession, transaction_data_id: str): """Deletes a document.""" - query = Delete(PlantTransactionData).where(PlantTransactionData.id == transaction_data_id) + query = Delete(PlantTransactionData).where( + PlantTransactionData.id == transaction_data_id + ) await db_session.execute(query) await db_session.commit()