Order.java 201 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681
  1. package restcontroller.webmanage.sale.order;
  2. import beans.accountbalance.Accountbalance;
  3. import beans.accountbalance.CashbillEntity;
  4. import beans.clear.ClearData;
  5. import beans.datacontrllog.DataContrlLog;
  6. import beans.dataextend.DataExtend;
  7. import beans.datateam.DataTeam;
  8. import beans.enterprise.Enterprise;
  9. import beans.hr.Hr;
  10. import beans.itemprice.ItemPrice;
  11. import beans.parameter.Parameter;
  12. import beans.remind.Remind;
  13. import beans.salearea.SaleArea;
  14. import beans.uploaderpdata.UploadDataToERP;
  15. import com.alibaba.fastjson.JSONArray;
  16. import com.alibaba.fastjson.JSONObject;
  17. import com.sun.org.apache.bcel.internal.generic.NEW;
  18. import common.Controller;
  19. import common.YosException;
  20. import common.annotation.API;
  21. import common.annotation.CACHEING;
  22. import common.annotation.CACHEING_CLEAN;
  23. import common.data.*;
  24. import common.data.db.DBConnect;
  25. import common.data.db.SQLiteTable;
  26. import org.apache.commons.lang.StringUtils;
  27. import restcontroller.R;
  28. import restcontroller.sale.cashbill.cashbill;
  29. import restcontroller.sale.promotion.promotion;
  30. import restcontroller.webmanage.executorService.Executor;
  31. import java.io.IOException;
  32. import java.math.BigDecimal;
  33. import java.text.SimpleDateFormat;
  34. import java.util.*;
  35. import static beans.order.Order.*;
  36. /**
  37. * 销售订单
  38. */
  39. public class Order extends Controller {
  40. /**
  41. * 构造函数
  42. *
  43. * @param content
  44. */
  45. public Order(JSONObject content) throws YosException {
  46. super(content);
  47. }
  48. @API(title = "新增或更新", apiversion = R.ID20221108111402.v1.class, intervaltime = 200)
  49. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  50. public String insertOrUpdate() throws YosException {
  51. ArrayList<String> sqlList = new ArrayList<>();
  52. //表名
  53. String tableName = "sa_order";
  54. Long sa_orderid = content.getLong("sa_orderid");
  55. Long sys_enterpriseid_temp = content.getLongValue("sys_enterpriseid");
  56. if (sys_enterpriseid_temp > 0) {
  57. sys_enterpriseid = sys_enterpriseid_temp;
  58. }
  59. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_agents WHERE siteid='" + siteid + "' AND `status`='启用' AND sys_enterpriseid=" + sys_enterpriseid).isEmpty()) {
  60. return getErrReturnObject().setErrMsg("当前企业不存在或已禁用,无法下单").toString();
  61. }
  62. Long sa_brandid = content.getLong("sa_brandid");
  63. Long sa_contractid = content.getLongValue("sa_contractid");
  64. Long sa_projectid = content.getLongValue("sa_projectid");
  65. String type = content.getString("type");
  66. boolean isAdd;
  67. SQLFactory sqlFactory = new SQLFactory(this, "订单_新增");
  68. Rows rows = dbConnect.runSqlQuery("SELECT status from sa_order WHERE sa_orderid = " + sa_orderid);
  69. if (sa_orderid <= 0) {
  70. isAdd = true;
  71. sa_orderid = createTableID(tableName);
  72. //默认当前用户为负责人
  73. DataTeam.createTeam(this, "sa_order", sa_orderid, userid);
  74. dbConnect.runSqlUpdate(DataContrlLog.createLog(this, "sa_order", sa_orderid, "新增", "订单新增成功").getSQL());
  75. } else if (rows.isEmpty()) {
  76. isAdd = true;
  77. //默认当前用户为负责人
  78. DataTeam.createTeam(this, "sa_order", sa_orderid, userid);
  79. dbConnect.runSqlUpdate(DataContrlLog.createLog(this, "sa_order", sa_orderid, "新增", "订单新增成功").getSQL());
  80. } else {
  81. if (rows.get(0).getString("status").equals("新建") || rows.get(0).getString("status").equals("提交")) {
  82. //通过版本更新订单表头数据
  83. beans.order.Order.updateOrderWithVersion(this);
  84. sqlFactory = new SQLFactory(this, "订单_更新");
  85. isAdd = false;
  86. dbConnect.runSqlUpdate(DataContrlLog.createLog(this, "sa_order", sa_orderid, "更新", "订单更新成功").getSQL());
  87. } else {
  88. return getErrReturnObject().setErrMsg("【新建】【提交】状态可修改").toString();
  89. }
  90. }
  91. sqlFactory.addParameter("siteid", siteid);
  92. sqlFactory.addParameter("userid", userid);
  93. sqlFactory.addParameter("username", username);
  94. sqlFactory.addParameter("sa_orderid", sa_orderid);
  95. //订单编号
  96. sqlFactory.addParameter("sonum", createBillCode("orderbill"));
  97. //订单类型
  98. sqlFactory.addParameter("type", type);
  99. //明细分类
  100. sqlFactory.addParameter("typemx", content.getStringValue("typemx"));
  101. //订货企业id
  102. sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
  103. //营销账户类型ID
  104. OrderItemsHelper orderItemsHelper = new OrderItemsHelper(this);
  105. Long sa_accountclassid = orderItemsHelper.getAccountClassId(type);
  106. if (sa_accountclassid <= 0) {
  107. return getErrReturnObject().setErrMsg("未找到扣款账户信息").toString();
  108. }
  109. orderItemsHelper.isAccountCanUsed(sa_accountclassid);
  110. sqlFactory.addParameter("sa_accountclassid", sa_accountclassid);
  111. sqlList.addAll(updateAccountclassinfos(sa_orderid, sa_accountclassid, sys_enterpriseid));
  112. // if ((type.equals("标准订单") || type.equals("特殊订单")) && content.getString("tradefield").equals("整装工程")) {
  113. // sqlFactory.addParameter("sa_accountclassid", "69");
  114. // sqlList.addAll(updateAccountclassinfos(sa_orderid, 69, sys_enterpriseid));
  115. // } else {
  116. // if (type.equals("促销订单")) {
  117. // Rows accountclassRows = dbConnect.runSqlQuery("select sa_accountclassid from sa_promotion where siteid='" + siteid + "' and sa_promotionid=" + content.getLongValue("sa_promotionid"));
  118. // if (!accountclassRows.isEmpty()) {
  119. // sqlFactory.addParameter("sa_accountclassid", accountclassRows.get(0).getLong("sa_accountclassid"));
  120. // } else {
  121. // sqlFactory.addParameter("sa_accountclassid", beans.order.Order.getDefaultAccount(siteid, type));
  122. // }
  123. // } else {
  124. // sqlFactory.addParameter("sa_accountclassid", beans.order.Order.getDefaultAccount(siteid, type));
  125. // }
  126. // sqlList.addAll(updateAccountclassinfos(sa_orderid, beans.order.Order.getDefaultAccount(siteid, type), sys_enterpriseid));
  127. // }
  128. //品牌ID
  129. sqlFactory.addParameter("sa_brandid", sa_brandid);
  130. //合同ID
  131. sqlFactory.addParameter("sa_contractid", sa_contractid);
  132. //工程项目表ID
  133. sqlFactory.addParameter("sa_projectid", sa_projectid);
  134. //合作企业财务信息ID(开票信息)
  135. Long sys_enterprise_financeid = content.getLongValue("sys_enterprise_financeid");
  136. if (sys_enterprise_financeid <= 0 && isAdd) {
  137. sys_enterprise_financeid = getDefaultEnterpriseFinanceid(sys_enterpriseid);
  138. }
  139. sqlFactory.addParameter("sys_enterprise_financeid", sys_enterprise_financeid);
  140. //物流公司档案ID
  141. sqlFactory.addParameter("sa_logiscompid", content.getLongValue("sa_logiscompid"));
  142. //合作企业联系人表ID(收货信息)
  143. //合作企业联系人表ID(收货信息),设置默认
  144. Long rec_contactsid = content.getLongValue("rec_contactsid");
  145. if (rec_contactsid <= 0 && isAdd) {
  146. rec_contactsid = getDefaultContactsid(sys_enterpriseid);
  147. }
  148. sqlFactory.addParameter("rec_contactsid", rec_contactsid);
  149. //备注说明
  150. sqlFactory.addParameter("remarks", content.getStringValue("remarks"));
  151. //销售人员hrid,业务员hrid
  152. sqlFactory.addParameter("saler_hrid", getSaleHrid(sys_enterpriseid));
  153. //制单方 1表示工厂方,0表示客户方
  154. if (usertype == 21 || usertype == 22) {
  155. sqlFactory.addParameter("createflag", 0);
  156. } else {
  157. sqlFactory.addParameter("createflag", 1);
  158. }
  159. // 领域
  160. sqlFactory.addParameter("tradefield", content.getString("tradefield"));
  161. //结算单位
  162. Long pay_enterpriseid = content.getLongValue("pay_enterpriseid");
  163. if (isAdd) {
  164. pay_enterpriseid = sys_enterpriseid;
  165. }
  166. sqlFactory.addParameter("pay_enterpriseid", pay_enterpriseid);
  167. //单据日期
  168. String billdate = content.getStringValue("billdate");
  169. //订单新增时
  170. if (isAdd) {
  171. if (billdate.equals("")) {
  172. sqlFactory.addParameter_SQL("billdate", "current_time");
  173. } else {
  174. sqlFactory.addParameter("billdate", billdate);
  175. }
  176. if (content.containsKey("sa_accountclassid") && !content.getString("sa_accountclassid").equals("")) {
  177. sa_accountclassid = content.getLongValue("sa_accountclassid");
  178. if (sa_accountclassid <= 0) {
  179. return getErrReturnObject().setErrMsg("账户不存在").toString();
  180. }
  181. if (type.equals("标准订单")) {
  182. Rows accountclassrows = dbConnect.runSqlQuery("select * from sa_accountclass where siteid='" + siteid + "' and sa_accountclassid=" + sa_accountclassid);
  183. if (accountclassrows.isEmpty()) {
  184. return getErrReturnObject().setErrMsg("账户不存在").toString();
  185. } else {
  186. if (accountclassrows.get(0).getString("accountname").equals("活动账户")) {
  187. return getErrReturnObject().setErrMsg("标准订单禁止选择活动账户").toString();
  188. }
  189. }
  190. }
  191. sqlFactory.addParameter("sa_accountclassid", sa_accountclassid);
  192. sqlList.addAll(updateAccountclassinfos(sa_orderid, sa_accountclassid, sys_enterpriseid));
  193. }
  194. } else {
  195. //订单更新时
  196. if (content.getLongValue("sa_accountclassid") != 0) {
  197. Rows accountclassRows = dbConnect
  198. .runSqlQuery(
  199. "select accountno,accountname from sa_accountclass where sa_accountclassid=" + content.getLongValue("sa_accountclassid"));
  200. if (accountclassRows.isNotEmpty()) {
  201. if (accountclassRows.get(0).getString("accountname").equals("物料账户")) {
  202. Rows wuliaoRows = dbConnect.runSqlQuery("select * from sa_orderitems t1 where exists(select 1 from plm_item t left join plm_itemclass t2 on t.marketingcategory=t2.itemclassid and t.siteid=t2.siteid where t.itemid=t1.itemid and t2.itemclassname='物料') and t1.sa_orderid=" + sa_orderid);
  203. Rows itemRows = dbConnect.runSqlQuery("select * from sa_orderitems where sa_orderid=" + sa_orderid);
  204. if (wuliaoRows.size() != itemRows.size()) {
  205. return getErrReturnObject().setErrMsg("物料账户只能添加物料商品,请检查").toString();
  206. }
  207. }
  208. if (type.equals("标准订单")) {
  209. if (accountclassRows.get(0).getString("accountname").equals("活动账户")) {
  210. return getErrReturnObject().setErrMsg("标准订单禁止选择活动账户").toString();
  211. }
  212. }
  213. } else {
  214. return getErrReturnObject().setErrMsg("账户不存在").toString();
  215. }
  216. sqlFactory.addParameter("sa_accountclassid", content.getLongValue("sa_accountclassid"));
  217. sqlList.addAll(updateAccountclassinfos(sa_orderid, content.getLongValue("sa_accountclassid"), sys_enterpriseid));
  218. }
  219. if (billdate.equals("")) {
  220. sqlFactory.addParameter_SQL("billdate", "createdate");
  221. } else {
  222. sqlFactory.addParameter("billdate", billdate);
  223. }
  224. }
  225. sqlFactory.addParameter("rebate_userate", content.getBigDecimalValue("rebate_userate"));
  226. sqlFactory.addParameter("rebate_used", content.getBooleanValue("rebate_used"));
  227. sqlFactory.addParameter("signbacknum", content.getStringValue("signbacknum"));
  228. sqlFactory.addParameter("tradefieldmx", content.getStringValue("tradefieldmx"));
  229. sqlFactory.addParameter("sa_promotionid", content.getLongValue("sa_promotionid"));
  230. sqlFactory.addParameter("freightstatus", content.getStringValue("freightstatus"));
  231. sqlFactory.addParameter("saletype", content.getStringValue("saletype"));
  232. sqlFactory.addParameter("signbackstatus", content.getStringValue("signbackstatus", true, "不需要"));
  233. sqlFactory.addParameter("projectnote", content.getStringValue("projectnote"));
  234. sqlFactory.addParameter("abstract", content.getStringValue("abstract"));
  235. String sql = sqlFactory.getSQL();
  236. dbConnect.runSqlUpdate(sql);
  237. dbConnect.runSqlUpdate(sqlList);
  238. content.put("sa_orderid", sa_orderid);
  239. return selectDetail();
  240. }
  241. @API(title = "购物车转化订单", apiversion = R.ID20221128183202.v1.class,intervaltime = 2000)
  242. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  243. public String ship() throws YosException {
  244. ArrayList<String> sqlList1 = new ArrayList<>();
  245. Long istool = content.getLongValue("istool");
  246. Long sa_brandid = 0L;
  247. String tradefield = content.getStringValue("tradefield");
  248. Long sa_promotionid = content.getLongValue("sa_promotionid");
  249. JSONArray items = content.getJSONArray("items");
  250. ArrayList<Long> itemidids = new ArrayList();
  251. ArrayList<Long> sa_shoppingcartids = new ArrayList();
  252. String type = content.getStringValue("type", false, "标准订单");
  253. OrderItemsHelper orderItemsHelper = new OrderItemsHelper(this);
  254. //判断是否是同一个品牌的商品
  255. for (Object obj : items) {
  256. JSONObject item = (JSONObject) obj;
  257. if (type.equals("促销订单")) {
  258. orderItemsHelper.checkOffOrderItems("sa_promotion_items", item.getLongValue("itemid"), sa_promotionid);
  259. } else {
  260. orderItemsHelper.checkOffOrderItems("plm_item", item.getLongValue("itemid"), sa_promotionid);
  261. }
  262. Long temp_sa_brandid = item.getLongValue("sa_brandid");
  263. itemidids.add(item.getLongValue("itemid"));
  264. sa_shoppingcartids.add(item.getLongValue("sa_shoppingcartid"));
  265. if (sa_brandid == 0) {
  266. sa_brandid = temp_sa_brandid;
  267. }
  268. if (!type.equals("促销订单")) {
  269. if (!sa_brandid.equals(temp_sa_brandid)) {
  270. return getErrReturnObject().setErrMsg("请添加同一品牌的商品").toString();
  271. }
  272. }
  273. }
  274. //判断领域
  275. // String sql = "SELECT count(0) count from plm_item_tradefield WHERE tradefield='" + tradefield + "' and itemid in " + itemidids;
  276. // sql = sql.replace("[", "(").replace("]", ")");
  277. // if (dbConnect.runSqlQuery(sql).get(0).getLong("count") != itemidids.size()) {
  278. // return getErrReturnObject().setErrMsg("请添加同一领域的商品").toString();
  279. // }
  280. if (sa_promotionid > 0) {
  281. Rows rows = dbConnect.runSqlQuery("SELECT ifnull(tradefield,'[]') tradefield from sa_promotion WHERE sa_promotionid=" + sa_promotionid + " and siteid='" + siteid + "'");
  282. if (rows.isNotEmpty()) {
  283. String tradefields = rows.get(0).getString("tradefield");
  284. JSONArray jsonArray = JSONArray.parseArray(tradefields);
  285. tradefield = StringUtils.join(jsonArray, ",");
  286. }
  287. }
  288. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_agents WHERE siteid='" + siteid + "' AND `status`='启用' AND sys_enterpriseid=" + sys_enterpriseid).isEmpty()) {
  289. return getErrReturnObject().setErrMsg("当前企业不存在或已禁用,无法下单").toString();
  290. }
  291. //表名
  292. String tableName = "sa_order";
  293. //类型为标准订单时查询默认框架合同信息
  294. Long sa_contractid = 0L;
  295. Long sa_projectid = 0L;
  296. Long sa_orderid = createTableID(tableName);
  297. SQLFactory sqlFactory = new SQLFactory(this, "订单_新增");
  298. sqlFactory.addParameter("siteid", siteid);
  299. sqlFactory.addParameter("userid", userid);
  300. sqlFactory.addParameter("username", username);
  301. sqlFactory.addParameter("sa_orderid", sa_orderid);
  302. //订单编号
  303. sqlFactory.addParameter("sonum", createBillCode("orderbill"));
  304. //订单类型
  305. sqlFactory.addParameter("type", type);
  306. //明细分类
  307. sqlFactory.addParameter("typemx", "");
  308. //订货企业id
  309. sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
  310. // Long sa_accountclassid = 0L;
  311. // //营销账户类型ID
  312. // if ((type.equals("标准订单") || type.equals("特殊订单")) && content.getString("tradefield").equals("整装工程")) {
  313. // sa_accountclassid = 69l;
  314. //
  315. //
  316. // } else {
  317. // if (type.equals("促销订单")) {
  318. // Rows accountclassRows = dbConnect.runSqlQuery("select sa_accountclassid from sa_promotion where siteid='" + siteid + "' and sa_promotionid=" + content.getLongValue("sa_promotionid"));
  319. // if (!accountclassRows.isEmpty()) {
  320. // sa_accountclassid = accountclassRows.get(0).getLong("sa_accountclassid");
  321. //
  322. // } else {
  323. // sa_accountclassid = beans.order.Order.getDefaultAccount(siteid, type);
  324. //
  325. // }
  326. // } else {
  327. // sa_accountclassid = beans.order.Order.getDefaultAccount(siteid, type);
  328. //
  329. // }
  330. //
  331. // }
  332. // sqlFactory.addParameter("sa_accountclassid", sa_accountclassid);
  333. Long sa_accountclassid = orderItemsHelper.getAccountClassId(type);
  334. if (sa_accountclassid <= 0) {
  335. return getErrReturnObject().setErrMsg("未找到扣款账户信息").toString();
  336. }
  337. orderItemsHelper.isAccountCanUsed(sa_accountclassid);
  338. sqlFactory.addParameter("sa_accountclassid", sa_accountclassid);
  339. //品牌ID
  340. sqlFactory.addParameter("sa_brandid", sa_brandid);
  341. //合同ID
  342. sqlFactory.addParameter("sa_contractid", sa_contractid);
  343. //工程项目表ID
  344. sqlFactory.addParameter("sa_projectid", sa_projectid);
  345. //合作企业财务信息ID(开票信息)
  346. Long sys_enterprise_financeid = content.getLongValue("sys_enterprise_financeid");
  347. if (sys_enterprise_financeid <= 0) {
  348. sys_enterprise_financeid = getDefaultEnterpriseFinanceid(sys_enterpriseid);
  349. }
  350. sqlFactory.addParameter("sys_enterprise_financeid", sys_enterprise_financeid);
  351. //物流公司档案ID
  352. //sqlFactory.addParameter("sa_logiscompid", content.getLongValue("sa_logiscompid"));
  353. //合作企业联系人表ID(收货信息),设置默认
  354. Long rec_contactsid = content.getLongValue("rec_contactsid");
  355. if (rec_contactsid <= 0) {
  356. rec_contactsid = getDefaultContactsid(sys_enterpriseid);
  357. }
  358. sqlFactory.addParameter("rec_contactsid", rec_contactsid);
  359. //备注说明
  360. sqlFactory.addParameter("remarks", content.getStringValue("remarks"));
  361. //销售人员hrid,业务员hrid
  362. sqlFactory.addParameter("saler_hrid", getSaleHrid(sys_enterpriseid));
  363. //制单方 1表示工厂方,0表示客户方
  364. if (usertype == 21 || usertype == 22) {
  365. sqlFactory.addParameter("createflag", 0);
  366. } else {
  367. sqlFactory.addParameter("createflag", 1);
  368. }
  369. sqlFactory.addParameter("tradefield", tradefield);
  370. //结算单位
  371. Long pay_enterpriseid = content.getLongValue("pay_enterpriseid");
  372. if (pay_enterpriseid <= 0) {
  373. pay_enterpriseid = sys_enterpriseid;
  374. }
  375. sqlFactory.addParameter("pay_enterpriseid", pay_enterpriseid);
  376. //单据日期
  377. sqlFactory.addParameter_SQL("billdate", "current_time");
  378. sqlFactory.addParameter("rebate_used", content.getBooleanValue("rebate_used"));
  379. sqlFactory.addParameter("signbacknum", content.getBooleanValue("signbacknum"));
  380. sqlFactory.addParameter("tradefieldmx", content.getStringValue("tradefieldmx"));
  381. sqlFactory.addParameter("sa_promotionid", content.getLongValue("sa_promotionid"));
  382. sqlFactory.addParameter("freightstatus", content.getStringValue("freightstatus"));
  383. sqlFactory.addParameter("saletype", content.getStringValue("saletype"));
  384. sqlFactory.addParameter("signbackstatus", content.getStringValue("signbackstatus", true, "不需要"));
  385. sqlFactory.addParameter("projectnote", content.getStringValue("projectnote"));
  386. sqlFactory.addParameter("abstract", content.getStringValue("abstract"));
  387. dbConnect.runSqlUpdate(sqlFactory);
  388. content.put("sa_orderid", sa_orderid);
  389. content.put("sys_enterpriseid", sys_enterpriseid);
  390. content.put("type", type);
  391. String result = new OrderItems(content).insertOrUpdate();
  392. JSONObject jsonObject = JSONObject.parseObject(result);
  393. if (!jsonObject.getString("msg").equals("成功")) {
  394. return result;
  395. }
  396. ArrayList<String> sqlList = new ArrayList<>();
  397. //删除购物车中的数据
  398. String sql = "DELETE from sa_shoppingcart WHERE sys_enterpriseid = " + sys_enterpriseid + " and sa_shoppingcartid in " + sa_shoppingcartids + " AND siteid ='" + siteid + "'";
  399. sql = sql.replace("[", "(").replace("]", ")");
  400. sqlList.add(sql);
  401. // //清除多余的操作记录
  402. // sqlList.add("DELETE FROM sys_contrllog WHERE ownertable='sa_shoppingcart' AND siteid='" + siteid + "' AND NOT EXISTS (SELECT 1 FROM sa_shoppingcart WHERE siteid='" + siteid + "' AND sa_shoppingcartid=ownerid )");
  403. //默认当前用户为负责人
  404. sqlList.addAll(DataTeam.createTeamSQL(this, "sa_order", sa_orderid, userid));
  405. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "新增", "购物车转化订单成功").getSQL());
  406. dbConnect.runSqlUpdate(sqlList);
  407. // if ((type.equals("标准订单") || type.equals("特殊订单")) && content.getString("tradefield").equals("整装工程")) {
  408. // sqlList1.addAll(updateAccountclassinfos(sa_orderid, 69, sys_enterpriseid));
  409. // } else {
  410. // if (type.equals("促销订单")) {
  411. // Rows accountclassRows = dbConnect.runSqlQuery("select sa_accountclassid from sa_promotion where siteid='" + siteid + "' and sa_promotionid=" + content.getLongValue("sa_promotionid"));
  412. // if (!accountclassRows.isEmpty()) {
  413. // sqlList1.addAll(updateAccountclassinfos(sa_orderid, accountclassRows.get(0).getLong("sa_accountclassid"), sys_enterpriseid));
  414. // } else {
  415. // sqlList1.addAll(updateAccountclassinfos(sa_orderid, beans.order.Order.getDefaultAccount(siteid, type), sys_enterpriseid));
  416. // }
  417. // } else {
  418. // sqlList1.addAll(updateAccountclassinfos(sa_orderid, beans.order.Order.getDefaultAccount(siteid, type), sys_enterpriseid));
  419. // }
  420. //
  421. // }
  422. sqlList1.addAll(updateAccountclassinfos(sa_orderid, sa_accountclassid, sys_enterpriseid));
  423. dbConnect.runSqlUpdate(sqlList1);
  424. ClearData.clearShoppingCart(this);
  425. return selectDetail();
  426. }
  427. /**
  428. * 获取企业默认扣款账户
  429. *
  430. * @param sys_enterpriseid
  431. * @return
  432. * @throws YosException
  433. */
  434. public Long getDefaultAccountclassid(Long sys_enterpriseid) throws YosException {
  435. Long sa_accountclassid = 0L;
  436. SQLFactory sqlFactory = new SQLFactory(this, "查询经销商营销账号");
  437. sqlFactory.addParameter("siteid", siteid);
  438. sqlFactory.addParameter_in("sys_enterpriseid", sys_enterpriseid);
  439. Rows accountRows = dbConnect.runSqlQuery(sqlFactory.getSQL(false));
  440. if (accountRows.isNotEmpty()) {
  441. sa_accountclassid = accountRows.get(0).getLong("sa_accountclassid");
  442. }
  443. return sa_accountclassid;
  444. }
  445. /**
  446. * 获取企业默认财务信息(开票)
  447. *
  448. * @param sys_enterpriseid
  449. * @return
  450. * @throws YosException
  451. */
  452. public Long getDefaultEnterpriseFinanceid(Long sys_enterpriseid) throws YosException {
  453. Long id = 0L;
  454. SQLFactory sqlFactory = new SQLFactory(this, "查询经销商默认开票信息");
  455. sqlFactory.addParameter("siteid", siteid);
  456. sqlFactory.addParameter_in("sys_enterpriseid", sys_enterpriseid);
  457. Rows row = dbConnect.runSqlQuery(sqlFactory.getSQL(false));
  458. if (row.isNotEmpty()) {
  459. id = row.get(0).getLong("sys_enterprise_financeid");
  460. }
  461. return id;
  462. }
  463. /**
  464. * 获取企业默认联系人
  465. *
  466. * @param sys_enterpriseid
  467. * @return
  468. * @throws YosException
  469. */
  470. public Long getDefaultContactsid(Long sys_enterpriseid) throws YosException {
  471. Long rec_contactsid = 0L;
  472. SQLFactory sqlFactory = new SQLFactory(this, "查询经销商默认联系人");
  473. sqlFactory.addParameter("siteid", siteid);
  474. sqlFactory.addParameter_in("sys_enterpriseid", sys_enterpriseid);
  475. sqlFactory.addParameter_in("sys_enterpriseids", Enterprise.getUpDown(this, sys_enterpriseid));
  476. String sql = sqlFactory.getSQL(false);
  477. Rows contactsRows = dbConnect.runSqlQuery(sql);
  478. if (contactsRows.isNotEmpty()) {
  479. rec_contactsid = contactsRows.get(0).getLong("contactsid");
  480. }
  481. return rec_contactsid;
  482. }
  483. @API(title = "详情", apiversion = R.ID20221108151302.v1.class)
  484. @CACHEING
  485. public String selectDetail() throws YosException {
  486. Long sa_orderid = content.getLong("sa_orderid");
  487. SQLFactory sqlFactory = new SQLFactory(this, "订单_详情");
  488. sqlFactory.addParameter("sa_orderid", sa_orderid);
  489. sqlFactory.addParameter("siteid", siteid);
  490. Rows rows = dbConnect.runSqlQuery(sqlFactory);
  491. //System.err.println(sqlFactory.getSQL());
  492. //查询数据:amount,defaultamount,qty,writeoffamount,invoiceamount
  493. ArrayList<Long> sa_orderids = rows.toArrayList("sa_orderid", new ArrayList<>());
  494. sqlFactory = new SQLFactory(this, "订单_查询数据");
  495. sqlFactory.addParameter("siteid", siteid);
  496. sqlFactory.addParameter_in("sa_orderid", sa_orderids);
  497. RowsMap dataRowsMap = dbConnect.runSqlQuery(sqlFactory).toRowsMap("sa_orderid");
  498. ArrayList<Long> sys_enterpriseids = rows.toArrayList("pay_enterpriseid", new ArrayList<>());
  499. //查询开票信息
  500. sqlFactory = new SQLFactory(this, "查询经销商默认开票信息");
  501. sqlFactory.addParameter("siteid", siteid);
  502. sqlFactory.addParameter_in("sys_enterpriseid", sys_enterpriseids);
  503. RowsMap financeRowsMap = dbConnect.runSqlQuery(sqlFactory).toRowsMap("sys_enterpriseid");
  504. for (Row row : rows) {
  505. row.put("pay_finance", financeRowsMap.getOrDefault(row.getString("sys_enterpriseid"), new Rows()));
  506. Rows dataRows = dataRowsMap.getOrDefault(row.getString("sa_orderid"), new Rows());
  507. BigDecimal writeoffamount = BigDecimal.valueOf(0);
  508. BigDecimal invoiceamount = BigDecimal.valueOf(0);
  509. BigDecimal amount = BigDecimal.valueOf(0);
  510. BigDecimal defaultamount = BigDecimal.valueOf(0);
  511. BigDecimal qty = new BigDecimal("0");
  512. if (dataRows.isNotEmpty()) {
  513. writeoffamount = dataRows.get(0).getBigDecimal("writeoffamount");
  514. invoiceamount = dataRows.get(0).getBigDecimal("invoiceamount");
  515. amount = dataRows.get(0).getBigDecimal("amount");
  516. defaultamount = dataRows.get(0).getBigDecimal("defaultamount");
  517. qty = dataRows.get(0).getBigDecimal("qty");
  518. }
  519. row.put("amount", amount);
  520. row.put("defaultamount", defaultamount);
  521. row.put("qty", qty);
  522. row.put("writeoffamount", writeoffamount);
  523. row.put("invoiceamount", invoiceamount);
  524. if (writeoffamount.compareTo(BigDecimal.ZERO) == 0) {
  525. row.put("writeoffstatus", "未核销");
  526. } else if (writeoffamount.compareTo(amount) == 0) {
  527. row.put("writeoffstatus", "已核销");
  528. } else {
  529. row.put("writeoffstatus", "部分核销");
  530. }
  531. if (invoiceamount.compareTo(BigDecimal.ZERO) == 0) {
  532. row.put("invoicestatus", "未开票");
  533. } else if (invoiceamount.compareTo(amount) == 0) {
  534. row.put("invoicestatus", "已开票");
  535. } else {
  536. row.put("invoicestatus", "部分开票");
  537. }
  538. }
  539. Row row = rows.isNotEmpty() ? rows.get(0) : new Row();
  540. Long pay_enterpriseid = row.getLong("pay_enterpriseid");
  541. Long sa_accountclassid = row.getLong("sa_accountclassid");
  542. Long saler_hrid = row.getLong("saler_hrid");
  543. //开票信息
  544. sqlFactory = new SQLFactory(this, "订单_开票信息");
  545. sqlFactory.addParameter("siteid", siteid);
  546. sqlFactory.addParameter("sa_orderid", sa_orderid);
  547. Rows financeRows = dbConnect.runSqlQuery(sqlFactory);
  548. row.put("finance", financeRows.isNotEmpty() ? financeRows.get(0) : new Row());
  549. //营销账户类型
  550. sqlFactory = new SQLFactory(this, "订单-查询营销账号");
  551. sqlFactory.addParameter("siteid", siteid);
  552. sqlFactory.addParameter("sa_orderid", sa_orderid);
  553. sqlFactory.addParameter("pay_enterpriseid", pay_enterpriseid);
  554. sqlFactory.addParameter("sa_accountclassid", sa_accountclassid);
  555. String sql = sqlFactory.getSQL();
  556. Rows accountclassRows = dbConnect.runSqlQuery(sql);
  557. if (accountclassRows.isNotEmpty()) {
  558. accountclassRows.get(0).put("amount", row.getBigDecimal("amount"));
  559. accountclassRows.get(0).put("rebate_used", row.getBigDecimal("rebate_used"));
  560. accountclassRows.get(0).put("rebate_userate", row.getBigDecimal("rebate_userate"));
  561. accountclassRows.get(0).put("rebate_amount", row.getBigDecimal("amount").multiply(row.getBigDecimal("rebate_userate")));
  562. }
  563. row.put("accountclass", accountclassRows.isNotEmpty() ? accountclassRows.get(0) : new Row());
  564. //收货信息
  565. row.put("contacts", beans.order.Order.getContactsRow(this, row.getLong("rec_contactsid")));
  566. Rows deliveryRows = dbConnect.runSqlQuery("SELECT count(0) count from plm_item WHERE itemid in (SELECT itemid from sa_orderitems WHERE sa_orderid = " + sa_orderid + " and siteid = '" + siteid + "') and delivery >0 and siteid = '" + siteid + "'");
  567. if (deliveryRows.get(0).getLong("count") > 0) {
  568. row.put("isdelivery", 1);
  569. } else {
  570. row.put("isdelivery", 0);
  571. }
  572. row.put("rebatebalance", Accountbalance.getRebateBalance(this, pay_enterpriseid));
  573. // //查询业务员是否可编辑价格
  574. // Rows saleRows = dbConnect.runSqlQuery("SELECT * from sa_salearea_hr WHERE hrid = " + hrid + " and siteid='" + siteid + "'");
  575. //查询定制费用
  576. sql = "SELECT ifnull(sum(costamount),0) costamount from sa_order_cost WHERE sa_orderid=" + sa_orderid;
  577. BigDecimal costamount = dbConnect.runSqlQuery(0, sql).getBigDecimal("costamount");
  578. row.put("costamount", costamount);
  579. JSONArray jsonArray = row.getJSONArray("sa_accountclassinfos");
  580. int index = 1;
  581. for (Object object : jsonArray) {
  582. JSONObject jsonObject = (JSONObject) object;
  583. Long id = jsonObject.getLong("sa_accountclassid");
  584. Rows accountbalanceRows = dbConnect.runSqlQuery("SELECT balance from sa_accountbalance WHERE sa_accountclassid=" + id + " and sys_enterpriseid=" + row.getLong("sys_enterpriseid"));
  585. if (accountbalanceRows.isNotEmpty()) {
  586. jsonObject.put("realbalance", accountbalanceRows.get(0).getBigDecimal("balance"));
  587. }
  588. if (jsonArray.size() == index) {
  589. jsonObject.put("amount", jsonObject.getBigDecimalValue("amount").add(costamount));
  590. }
  591. index++;
  592. }
  593. row.replace("sa_accountclassinfos", jsonArray);
  594. row.replace("amount", row.getBigDecimal("amount").add(costamount));
  595. row.replace("defaultamount", row.getBigDecimal("defaultamount").add(costamount));
  596. //订单套餐
  597. Rows packagetypemxrows =dbConnect.runSqlQuery("select t2.packagetypemx,min(t1.qty/t2.orderminqty) packagetypeqty from sa_orderitems t1 inner join sa_promotion_items t2 on t1.sa_promotion_itemsid=t2.sa_promotion_itemsid and t1.siteid=t2.siteid where t1.siteid='"+siteid+"' and t1.sa_orderid="+sa_orderid+" and ifnull(t2.packagetypemx,'')!='' group by t2.packagetypemx");
  598. row.put("packagetypemxrows",packagetypemxrows);
  599. return getSucReturnObject().setData(row).toString();
  600. }
  601. @API(title = "查询订单列表(管理端)", apiversion = R.ID20230105143002.v1.class)
  602. @CACHEING
  603. public String selectListManage() throws YosException, IOException {
  604. StringBuffer where = new StringBuffer(" 1=1 ");
  605. if (content.containsKey("where")) {
  606. JSONObject whereObject = content.getJSONObject("where");
  607. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  608. where.append(" and(");
  609. where.append("t1.sonum like'%").append(whereObject.getString("condition")).append("%' ");
  610. where.append("or t2.enterprisename like'%").append(whereObject.getString("condition")).append("%' ");
  611. where.append("or t2.abbreviation like'%").append(whereObject.getString("condition")).append("%' ");
  612. // where.append("or t5.erpbillno like'%").append(whereObject.getString("condition")).append("%' ");
  613. where.append("or t1.remarks like'%").append(whereObject.getString("condition")).append("%' ");
  614. where.append(")");
  615. }
  616. //状态
  617. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  618. where.append(" and(");
  619. where.append("t1.status ='").append(whereObject.getString("status")).append("' ");
  620. where.append(")");
  621. }
  622. if (whereObject.containsKey("type") && !"".equals(whereObject.getString("type"))) {
  623. where.append(" and(");
  624. where.append("t1.type like'%").append(whereObject.getString("type")).append("%' ");
  625. where.append(")");
  626. }
  627. //品牌
  628. if (whereObject.containsKey("brandname") && !"".equals(whereObject.getString("brandname"))) {
  629. where.append(" and(");
  630. where.append("t3.brandname like'%").append(whereObject.getString("brandname")).append("%' ");
  631. where.append(")");
  632. }
  633. //领域
  634. if (whereObject.containsKey("tradefield") && !"".equals(whereObject.getString("tradefield"))) {
  635. where.append(" and(");
  636. where.append("t1.tradefield like'%").append(whereObject.getString("tradefield")).append("%' ");
  637. where.append(")");
  638. }
  639. if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
  640. where.append(" and DATE_FORMAT(t1.billdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate")).append("' ");
  641. }
  642. if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
  643. where.append(" and DATE_FORMAT(t1.billdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate")).append("' ");
  644. }
  645. if (whereObject.containsKey("begindate1") && !"".equals(whereObject.getString("begindate1"))) {
  646. where.append(" and DATE_FORMAT(t1.submitdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate1")).append("' ");
  647. }
  648. if (whereObject.containsKey("enddate1") && !"".equals(whereObject.getString("enddate1"))) {
  649. where.append(" and DATE_FORMAT(t1.submitdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate1")).append("' ");
  650. }
  651. if (whereObject.containsKey("begindate2") && !"".equals(whereObject.getString("begindate2"))) {
  652. where.append(" and DATE_FORMAT(t1.checkdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate2")).append("' ");
  653. }
  654. if (whereObject.containsKey("enddate2") && !"".equals(whereObject.getString("enddate2"))) {
  655. where.append(" and DATE_FORMAT(t1.checkdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate2")).append("' ");
  656. }
  657. if (whereObject.containsKey("remarks") && !"".equals(whereObject.getString("remarks"))) {
  658. where.append("and t1.remarks like'%").append(whereObject.getString("remarks")).append("%' ");
  659. }
  660. if (whereObject.containsKey("createby") && !"".equals(whereObject.getString("createby"))) {
  661. where.append("and t1.createby like'%").append(whereObject.getString("createby")).append("%' ");
  662. }
  663. if (whereObject.containsKey("checkby") && !"".equals(whereObject.getString("checkby"))) {
  664. where.append("and t1.checkby like'%").append(whereObject.getString("checkby")).append("%' ");
  665. }
  666. if (whereObject.containsKey("agentinfo") && !"".equals(whereObject.getString("agentinfo"))) {
  667. where.append(" and(");
  668. where.append(" t2.enterprisename like'%").append(whereObject.getString("agentinfo")).append("%' ");
  669. where.append("or t7.agentnum like'%").append(whereObject.getString("agentinfo")).append("%' ");
  670. where.append(")");
  671. }
  672. // if (whereObject.containsKey("writeoffstatus") && !"".equals(whereObject.getString("writeoffstatus"))) {
  673. // String writeoffstatus = whereObject.getStringValue("writeoffstatus");
  674. // if (writeoffstatus.equals("未核销")) {
  675. // where.append(" and t7.writeoffamount = 0");
  676. // } else if (writeoffstatus.equals("已核销")) {
  677. // where.append(" and t7.writeoffamount = t7.amount and t7.amount > 0");
  678. // } else {
  679. // where.append(" and t7.writeoffamount < t7.amount and t7.writeoffamount > 0");
  680. // }
  681. //
  682. // }
  683. // if (whereObject.containsKey("invoicestatus") && !"".equals(whereObject.getString("invoicestatus"))) {
  684. // String invoicestatus = whereObject.getStringValue("invoicestatus");
  685. // if (invoicestatus.equals("未开票")) {
  686. // where.append(" and t7.invoiceamount = 0");
  687. // } else if (invoicestatus.equals("已开票")) {
  688. // where.append(" and t7.invoiceamount = t7.amount and t7.amount > 0");
  689. // } else {
  690. // where.append(" and t7.invoiceamount < t7.amount and t7.invoiceamount > 0");
  691. // }
  692. //
  693. // }
  694. if (whereObject.containsKey("isreturn") && !"".equals(whereObject.getString("isreturn"))) {
  695. String isreturn = whereObject.getStringValue("isreturn");
  696. if (isreturn.equals("1")) {
  697. where.append(" and exists (select 1 from sa_orderitems where sa_orderid=t1.sa_orderid and siteid=t1.siteid and ifnull(returnqty,0)>0) ");
  698. } else {
  699. where.append(" and not exists (select 1 from sa_orderitems where sa_orderid=t1.sa_orderid and siteid=t1.siteid and ifnull(returnqty,0)=0) ");
  700. }
  701. }
  702. if (whereObject.containsKey("ischange") && !"".equals(whereObject.getString("ischange"))) {
  703. String ischange = whereObject.getStringValue("ischange");
  704. if (ischange.equals("0")) {
  705. where.append(" and not exists(SELECT * from sa_orderitems_change WHERE sa_orderid = t1.sa_orderid and siteid = t1.siteid)");
  706. } else {
  707. where.append(" and exists(SELECT * from sa_orderitems_change WHERE sa_orderid = t1.sa_orderid and siteid = t1.siteid)");
  708. }
  709. }
  710. if (whereObject.containsKey("tobeclosebyhand") && !"".equals(whereObject.getString("tobeclosebyhand"))) {
  711. String tobeclosebyhand = whereObject.getStringValue("tobeclosebyhand");
  712. if (tobeclosebyhand.equals("1")) {
  713. where.append(" and t1.status !='手工关闭' and sa_orderid in (select sa_orderid from sa_orderitems t1 left join (select t2.sa_orderitemsid,t2.siteid,sum(outwarehouseqty) sumoutwarehouseqty from sa_dispatch_items t2 inner join sa_dispatch t3 on t2.sa_dispatchid=t3.sa_dispatchid and t2.siteid=t3.siteid GROUP BY sa_orderitemsid,siteid) t2 on t1.sa_orderitemsid=t2.sa_orderitemsid and t1.siteid=t2.siteid where t1.qty>ifnull(t2.sumoutwarehouseqty,0) and t1.isfreeze=1) and sa_orderid in(select t1.sa_orderid from (select sa_orderid,t1.siteid,count(1) count from sa_orderitems t1 inner join (select t2.sa_orderitemsid,t2.siteid,sum(outwarehouseqty) sumoutwarehouseqty from sa_dispatch_items t2 inner join sa_dispatch t3 on t2.sa_dispatchid=t3.sa_dispatchid and t2.siteid=t3.siteid GROUP BY sa_orderitemsid,siteid) t2 on t1.sa_orderitemsid=t2.sa_orderitemsid and t1.siteid=t2.siteid where t1.isfreeze=0 and t1.qty=t2.sumoutwarehouseqty group by sa_orderid,t1.siteid) t1 inner join (select sa_orderid,t1.siteid,count(1) count from sa_orderitems t1 where t1.isfreeze=0 group by sa_orderid,t1.siteid) t2 on t1.siteid=t2.siteid and t1.sa_orderid=t2.sa_orderid where t1.count=t2.count)");
  714. } else {
  715. where.append(" and 1=1");
  716. }
  717. }
  718. }
  719. // SQLFactory sqlFactory = new SQLFactory(this, "订单(管理端)_列表", pageSize, pageNumber, pageSorting);
  720. // if (isExport) {
  721. // sqlFactory = new SQLFactory(this, "订单(管理端)_列表");
  722. // }
  723. // sqlFactory.addParameter("siteid", siteid);
  724. // sqlFactory.addParameter("hrid", hrid);
  725. // sqlFactory.addParameter("userid", userid);
  726. // sqlFactory.addParameter_SQL("where", where);
  727. // String sql = sqlFactory.getSQL();
  728. QuerySQL querySQL = queryListManage(where.toString());
  729. querySQL.setOrderBy(pageSorting);
  730. Rows rows;
  731. querySQL.setPage(pageSize, pageNumber);
  732. rows = querySQL.query();
  733. ArrayList<Long> ids = rows.toArrayList("sa_orderid", new ArrayList<>());
  734. //查询数量金额
  735. RowsMap OrderAmountRowsMap = beans.order.Order.getSumOrderAmount(this, ids);
  736. SQLFactory ischangeSQl = new SQLFactory("sql:SELECT distinct sa_orderid from sa_orderitems_change WHERE siteid='" + siteid + "' and sa_orderid in $sa_orderids$ ");
  737. ischangeSQl.addParameter_in("sa_orderids", rows.toArrayList("sa_orderid"));
  738. ArrayList<Long> ischangesa_orderidList = dbConnect.runSqlQuery(ischangeSQl.getSQL()).toArrayList("sa_orderid", new ArrayList<>());
  739. for (Row row : rows) {
  740. Long id = row.getLong("sa_orderid");
  741. if (OrderAmountRowsMap.get(id.toString()).isNotEmpty()) {
  742. row.put("amount", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("amount"));
  743. row.put("defaultamount", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("defaultamount"));
  744. row.put("qty", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("qty"));
  745. row.put("writeoffamount", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("writeoffamount"));
  746. row.put("invoiceamount", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("invoiceamount"));
  747. if (OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("returnqty").compareTo(BigDecimal.ZERO) > 0) {
  748. row.put("isreturn", "1");
  749. } else {
  750. row.put("isreturn", "0");
  751. }
  752. } else {
  753. row.put("amount", 0);
  754. row.put("defaultamount", 0);
  755. row.put("sumamount", 0);
  756. row.put("qty", 0);
  757. row.put("writeoffamount", 0);
  758. row.put("invoiceamount", 0);
  759. row.put("isreturn", "0");
  760. }
  761. BigDecimal writeoffamount = row.getBigDecimal("writeoffamount");
  762. BigDecimal invoiceamount = row.getBigDecimal("invoiceamount");
  763. BigDecimal amount = row.getBigDecimal("amount");
  764. row.put("ischange", ischangesa_orderidList.contains(row.getLong("sa_orderid")) ? "1" : "0");
  765. if (writeoffamount.compareTo(BigDecimal.ZERO) == 0) {
  766. row.put("writeoffstatus", "未核销");
  767. } else if (writeoffamount.compareTo(amount) == 0) {
  768. row.put("writeoffstatus", "已核销");
  769. } else {
  770. row.put("writeoffstatus", "部分核销");
  771. }
  772. if (invoiceamount.compareTo(BigDecimal.ZERO) == 0) {
  773. row.put("invoicestatus", "未开票");
  774. } else if (invoiceamount.compareTo(amount) == 0) {
  775. row.put("invoicestatus", "已开票");
  776. } else {
  777. row.put("invoicestatus", "部分开票");
  778. }
  779. }
  780. return getSucReturnObject().setData(rows).toString();
  781. }
  782. @API(title = "查询订单列表(区域经理)", apiversion = R.ID20231025160203.v1.class)
  783. @CACHEING
  784. public String selectListManage_regionalManager() throws YosException, IOException {
  785. StringBuffer where = new StringBuffer(" 1=1 ");
  786. if (content.containsKey("where")) {
  787. JSONObject whereObject = content.getJSONObject("where");
  788. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  789. where.append(" and(");
  790. where.append("t1.sonum like'%").append(whereObject.getString("condition")).append("%' ");
  791. where.append("or t2.enterprisename like'%").append(whereObject.getString("condition")).append("%' ");
  792. where.append("or t2.abbreviation like'%").append(whereObject.getString("condition")).append("%' ");
  793. // where.append("or t5.erpbillno like'%").append(whereObject.getString("condition")).append("%' ");
  794. where.append("or t1.remarks like'%").append(whereObject.getString("condition")).append("%' ");
  795. where.append(")");
  796. }
  797. //状态
  798. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  799. where.append(" and(");
  800. where.append("t1.status ='").append(whereObject.getString("status")).append("' ");
  801. where.append(")");
  802. }
  803. if (whereObject.containsKey("type") && !"".equals(whereObject.getString("type"))) {
  804. where.append(" and(");
  805. where.append("t1.type like'%").append(whereObject.getString("type")).append("%' ");
  806. where.append(")");
  807. }
  808. //品牌
  809. if (whereObject.containsKey("brandname") && !"".equals(whereObject.getString("brandname"))) {
  810. where.append(" and(");
  811. where.append("t3.brandname like'%").append(whereObject.getString("brandname")).append("%' ");
  812. where.append(")");
  813. }
  814. //领域
  815. if (whereObject.containsKey("tradefield") && !"".equals(whereObject.getString("tradefield"))) {
  816. where.append(" and(");
  817. where.append("t1.tradefield like'%").append(whereObject.getString("tradefield")).append("%' ");
  818. where.append(")");
  819. }
  820. if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
  821. where.append(" and DATE_FORMAT(t1.billdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate")).append("' ");
  822. }
  823. if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
  824. where.append(" and DATE_FORMAT(t1.billdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate")).append("' ");
  825. }
  826. if (whereObject.containsKey("begindate1") && !"".equals(whereObject.getString("begindate1"))) {
  827. where.append(" and DATE_FORMAT(t1.submitdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate1")).append("' ");
  828. }
  829. if (whereObject.containsKey("enddate1") && !"".equals(whereObject.getString("enddate1"))) {
  830. where.append(" and DATE_FORMAT(t1.submitdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate1")).append("' ");
  831. }
  832. if (whereObject.containsKey("begindate2") && !"".equals(whereObject.getString("begindate2"))) {
  833. where.append(" and DATE_FORMAT(t1.checkdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate2")).append("' ");
  834. }
  835. if (whereObject.containsKey("enddate2") && !"".equals(whereObject.getString("enddate2"))) {
  836. where.append(" and DATE_FORMAT(t1.checkdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate2")).append("' ");
  837. }
  838. if (whereObject.containsKey("remarks") && !"".equals(whereObject.getString("remarks"))) {
  839. where.append("and t1.remarks like'%").append(whereObject.getString("remarks")).append("%' ");
  840. }
  841. if (whereObject.containsKey("createby") && !"".equals(whereObject.getString("createby"))) {
  842. where.append("and t1.createby like'%").append(whereObject.getString("createby")).append("%' ");
  843. }
  844. if (whereObject.containsKey("checkby") && !"".equals(whereObject.getString("checkby"))) {
  845. where.append("and t1.checkby like'%").append(whereObject.getString("checkby")).append("%' ");
  846. }
  847. if (whereObject.containsKey("agentinfo") && !"".equals(whereObject.getString("agentinfo"))) {
  848. where.append(" and(");
  849. where.append(" t2.enterprisename like'%").append(whereObject.getString("agentinfo")).append("%' ");
  850. where.append("or t7.agentnum like'%").append(whereObject.getString("agentinfo")).append("%' ");
  851. where.append(")");
  852. }
  853. if (whereObject.containsKey("isreturn") && !"".equals(whereObject.getString("isreturn"))) {
  854. String isreturn = whereObject.getStringValue("isreturn");
  855. if (isreturn.equals("1")) {
  856. where.append(" and exists (select 1 from sa_orderitems where sa_orderid=t1.sa_orderid and siteid=t1.siteid and ifnull(returnqty,0)>0) ");
  857. } else {
  858. where.append(" and not exists (select 1 from sa_orderitems where sa_orderid=t1.sa_orderid and siteid=t1.siteid and ifnull(returnqty,0)=0) ");
  859. }
  860. }
  861. if (whereObject.containsKey("ischange") && !"".equals(whereObject.getString("ischange"))) {
  862. String ischange = whereObject.getStringValue("ischange");
  863. if (ischange.equals("0")) {
  864. where.append(" and not exists(SELECT * from sa_orderitems_change WHERE sa_orderid = t1.sa_orderid and siteid = t1.siteid)");
  865. } else {
  866. where.append(" and exists(SELECT * from sa_orderitems_change WHERE sa_orderid = t1.sa_orderid and siteid = t1.siteid)");
  867. }
  868. }
  869. }
  870. SQLFactory areasqlFactory = new SQLFactory(new promotion(content), "区域经理查询下属营销区域");
  871. areasqlFactory.addParameter("siteid", siteid);
  872. areasqlFactory.addParameter("hrid", hrid);
  873. Rows arearows = dbConnect.runSqlQuery(areasqlFactory);
  874. ArrayList<Long> arrayList = arearows.toArrayList("sa_saleareaid", new ArrayList<Long>());
  875. arrayList.addAll(SaleArea.getSubSaleAreaIds(this, arrayList));
  876. String sql = " and t1.sys_enterpriseid in (select sys_enterpriseid from sys_enterprise_tradefield where sa_saleareaid in " + arrayList + ")";
  877. sql = sql.replace("[", "(").replace("]", ")");
  878. where.append(sql);
  879. QuerySQL querySQL = queryListManage(where.toString());
  880. querySQL.setOrderBy(pageSorting);
  881. Rows rows;
  882. querySQL.setPage(pageSize, pageNumber);
  883. rows = querySQL.query();
  884. ArrayList<Long> ids = rows.toArrayList("sa_orderid", new ArrayList<>());
  885. //查询数量金额
  886. RowsMap OrderAmountRowsMap = beans.order.Order.getSumOrderAmount(this, ids);
  887. SQLFactory ischangeSQl = new SQLFactory("sql:SELECT distinct sa_orderid from sa_orderitems_change WHERE siteid='" + siteid + "' and sa_orderid in $sa_orderids$ ");
  888. ischangeSQl.addParameter_in("sa_orderids", rows.toArrayList("sa_orderid"));
  889. ArrayList<Long> ischangesa_orderidList = dbConnect.runSqlQuery(ischangeSQl.getSQL()).toArrayList("sa_orderid", new ArrayList<>());
  890. for (Row row : rows) {
  891. Long id = row.getLong("sa_orderid");
  892. if (OrderAmountRowsMap.get(id.toString()).isNotEmpty()) {
  893. row.put("amount", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("amount"));
  894. row.put("defaultamount", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("defaultamount"));
  895. row.put("qty", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("qty"));
  896. row.put("writeoffamount", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("writeoffamount"));
  897. row.put("invoiceamount", OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("invoiceamount"));
  898. if (OrderAmountRowsMap.get(id.toString()).get(0).getBigDecimal("returnqty").compareTo(BigDecimal.ZERO) > 0) {
  899. row.put("isreturn", "1");
  900. } else {
  901. row.put("isreturn", "0");
  902. }
  903. } else {
  904. row.put("amount", 0);
  905. row.put("defaultamount", 0);
  906. row.put("sumamount", 0);
  907. row.put("qty", 0);
  908. row.put("writeoffamount", 0);
  909. row.put("invoiceamount", 0);
  910. row.put("isreturn", "0");
  911. }
  912. BigDecimal writeoffamount = row.getBigDecimal("writeoffamount");
  913. BigDecimal invoiceamount = row.getBigDecimal("invoiceamount");
  914. BigDecimal amount = row.getBigDecimal("amount");
  915. row.put("ischange", ischangesa_orderidList.contains(row.getLong("sa_orderid")) ? "1" : "0");
  916. if (writeoffamount.compareTo(BigDecimal.ZERO) == 0) {
  917. row.put("writeoffstatus", "未核销");
  918. } else if (writeoffamount.compareTo(amount) == 0) {
  919. row.put("writeoffstatus", "已核销");
  920. } else {
  921. row.put("writeoffstatus", "部分核销");
  922. }
  923. if (invoiceamount.compareTo(BigDecimal.ZERO) == 0) {
  924. row.put("invoicestatus", "未开票");
  925. } else if (invoiceamount.compareTo(amount) == 0) {
  926. row.put("invoicestatus", "已开票");
  927. } else {
  928. row.put("invoicestatus", "部分开票");
  929. }
  930. }
  931. return getSucReturnObject().setData(rows).toString();
  932. }
  933. //查询订单列表(管理端)
  934. public QuerySQL queryListManage(String where) throws YosException {
  935. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_order",
  936. "sa_orderid", "sonum", "type", "status", "submitdate", "checkdate", "remarks", "createby", "checkby", "billdate", "tradefield");
  937. querySQL.setTableAlias("t1");
  938. querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise", "t2", "t2.sys_enterpriseid = t1.sys_enterpriseid and t2.siteid = t1.siteid",
  939. "enterprisename");
  940. querySQL.addJoinTable(JOINTYPE.left, "sa_agents", "t6", "t6.sys_enterpriseid=t1.sys_enterpriseid and t6.siteid = t1.siteid",
  941. "agentnum");
  942. querySQL.addJoinTable(JOINTYPE.left, "sa_promotion", "t7", "t7.sa_promotionid=t1.sa_promotionid and t7.siteid = t1.siteid",
  943. "promnum", "promname");
  944. querySQL.addQueryFields("amount", "CAST(0 AS CHAR(20))");
  945. querySQL.addQueryFields("qty", "CAST(0 AS CHAR(20))");
  946. querySQL.setWhere("t1.siteid", siteid);
  947. querySQL.setWhere(where);
  948. querySQL.setWhere("t1.deleted=0");
  949. querySQL.setWhere("(t1.status!='新建' or t1.createuserid =$userid$ or t1.createflag=1)");
  950. querySQL.addParameter("userid", userid);
  951. return querySQL;
  952. }
  953. @API(title = "查询订单列表(业务员)", apiversion = R.ID20221111145202.v1.class)
  954. public String selectList() throws YosException, IOException {
  955. StringBuffer where = new StringBuffer(" 1=1 ");
  956. if (content.containsKey("where")) {
  957. JSONObject whereObject = content.getJSONObject("where");
  958. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  959. where.append(" and(");
  960. where.append("t1.sonum like'%").append(whereObject.getString("condition")).append("%' ");
  961. where.append("or t2.enterprisename like'%").append(whereObject.getString("condition")).append("%' ");
  962. where.append("or t2.abbreviation like'%").append(whereObject.getString("condition")).append("%' ");
  963. where.append("or t1.remarks like'%").append(whereObject.getString("condition")).append("%' ");
  964. where.append(")");
  965. }
  966. //状态
  967. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  968. where.append(" and(");
  969. where.append("t1.status like'%").append(whereObject.getString("status")).append("%' ");
  970. where.append(")");
  971. }
  972. //品牌
  973. if (whereObject.containsKey("brandname") && !"".equals(whereObject.getString("brandname"))) {
  974. where.append(" and(");
  975. where.append("t3.brandname like'%").append(whereObject.getString("brandname")).append("%' ");
  976. where.append(")");
  977. }
  978. //领域
  979. if (whereObject.containsKey("tradefield") && !"".equals(whereObject.getString("tradefield"))) {
  980. where.append(" and(");
  981. where.append("t1.tradefield like'%").append(whereObject.getString("tradefield")).append("%' ");
  982. where.append(")");
  983. }
  984. if (whereObject.containsKey("type") && !"".equals(whereObject.getString("type"))) {
  985. where.append(" and(");
  986. where.append("t1.type like'%").append(whereObject.getString("type")).append("%' ");
  987. where.append(")");
  988. }
  989. if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
  990. where.append(" and DATE_FORMAT(t1.billdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate")).append("' ");
  991. }
  992. if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
  993. where.append(" and DATE_FORMAT(t1.billdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate")).append("' ");
  994. }
  995. if (whereObject.containsKey("begindate1") && !"".equals(whereObject.getString("begindate1"))) {
  996. where.append(" and DATE_FORMAT(t1.submitdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate1")).append("' ");
  997. }
  998. if (whereObject.containsKey("enddate1") && !"".equals(whereObject.getString("enddate1"))) {
  999. where.append(" and DATE_FORMAT(t1.submitdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate1")).append("' ");
  1000. }
  1001. if (whereObject.containsKey("begindate2") && !"".equals(whereObject.getString("begindate2"))) {
  1002. where.append(" and DATE_FORMAT(t1.checkdate, '%Y-%m-%d') >='").append(whereObject.getString("begindate2")).append("' ");
  1003. }
  1004. if (whereObject.containsKey("enddate2") && !"".equals(whereObject.getString("enddate2"))) {
  1005. where.append(" and DATE_FORMAT(t1.checkdate, '%Y-%m-%d') <='").append(whereObject.getString("enddate2")).append("' ");
  1006. }
  1007. if (whereObject.containsKey("remarks") && !"".equals(whereObject.getString("remarks"))) {
  1008. where.append("and t1.remarks like'%").append(whereObject.getString("remarks")).append("%' ");
  1009. }
  1010. if (whereObject.containsKey("agentinfo") && !"".equals(whereObject.getString("agentinfo"))) {
  1011. where.append(" and(");
  1012. where.append(" t2.enterprisename like'%").append(whereObject.getString("agentinfo")).append("%' ");
  1013. where.append("or t7.agentnum like'%").append(whereObject.getString("agentinfo")).append("%' ");
  1014. where.append(")");
  1015. }
  1016. // if (whereObject.containsKey("writeoffstatus") && !"".equals(whereObject.getString("writeoffstatus"))) {
  1017. // String writeoffstatus = whereObject.getStringValue("writeoffstatus");
  1018. // if (writeoffstatus.equals("未核销")) {
  1019. // where.append(" and t7.writeoffamount = 0");
  1020. // } else if (writeoffstatus.equals("已核销")) {
  1021. // where.append(" and t7.writeoffamount = t7.amount and t7.amount > 0");
  1022. // } else {
  1023. // where.append(" and t7.writeoffamount < t7.amount and t7.writeoffamount > 0");
  1024. // }
  1025. //
  1026. // }
  1027. // if (whereObject.containsKey("invoicestatus") && !"".equals(whereObject.getString("invoicestatus"))) {
  1028. // String invoicestatus = whereObject.getStringValue("invoicestatus");
  1029. // if (invoicestatus.equals("未开票")) {
  1030. // where.append(" and t7.invoiceamount = 0");
  1031. // } else if (invoicestatus.equals("已开票")) {
  1032. // where.append(" and t7.invoiceamount = t7.amount and t7.amount > 0");
  1033. // } else {
  1034. // where.append(" and t7.invoiceamount < t7.amount and t7.invoiceamount > 0");
  1035. // }
  1036. //
  1037. // }
  1038. }
  1039. ArrayList<Long> sys_enterpriseids = Hr.getAgents(this, hrid);
  1040. String sql = " and t1.sys_enterpriseid in " + sys_enterpriseids;
  1041. sql = sql.replace("[", "(").replace("]", ")");
  1042. where.append(sql);
  1043. boolean isExport = content.getBooleanValue("isExport");
  1044. //
  1045. //
  1046. // SQLFactory sqlFactory = new SQLFactory(this, "订单_列表", pageSize, pageNumber, pageSorting);
  1047. // if (isExport) {
  1048. // sqlFactory = new SQLFactory(this, "订单_列表");
  1049. // }
  1050. //
  1051. // sqlFactory.addParameter("siteid", siteid);
  1052. // sqlFactory.addParameter("hrid", hrid);
  1053. // sqlFactory.addParameter("userid", userid);
  1054. // sqlFactory.addParameter_SQL("where", where);
  1055. // sql = sqlFactory.getSQL();
  1056. // Rows rows = dbConnect.runSqlQuery(sql);
  1057. QuerySQL querySQL = queryList(where.toString());
  1058. querySQL.setOrderBy(pageSorting);
  1059. Rows rows;
  1060. // if (!isExport) {
  1061. querySQL.setPage(pageSize, pageNumber);
  1062. // }
  1063. rows = querySQL.query();
  1064. //查询数据:amount,defaultamount,qty
  1065. ArrayList<Long> sa_orderids = rows.toArrayList("sa_orderid", new ArrayList<>());
  1066. SQLFactory sqlFactory = new SQLFactory(this, "订单_查询数据");
  1067. sqlFactory.addParameter("siteid", siteid);
  1068. sqlFactory.addParameter_in("sa_orderid", sa_orderids);
  1069. RowsMap dataRowsMap = dbConnect.runSqlQuery(sqlFactory).toRowsMap("sa_orderid");
  1070. for (Row row : rows) {
  1071. Rows dataRows = dataRowsMap.getOrDefault(row.getString("sa_orderid"), new Rows());
  1072. if (dataRows.isNotEmpty()) {
  1073. row.putAll(dataRows.get(0));
  1074. } else {
  1075. row.put("amount", 0);
  1076. row.put("defaultamount", 0);
  1077. row.put("qty", 0);
  1078. }
  1079. }
  1080. // if (isExport) {
  1081. // //去除不需要导出项
  1082. // rows.getFieldList().remove("sa_orderid");
  1083. // rows.getFieldList().remove("submitdate");
  1084. // rows.getFieldList().remove("checkdate");
  1085. // rows.getFieldList().remove("typemx");
  1086. // rows.getFieldList().remove("sys_enterpriseid");
  1087. // Rows uploadRows = uploadExcelToObs("order", "订单列表", rows, getTitleMap());
  1088. // return getSucReturnObject().setData(uploadRows).toString();
  1089. // }
  1090. sqlFactory = new SQLFactory(this, "订单-查询筛选出的价格");
  1091. sqlFactory.addParameter("siteid", siteid);
  1092. sqlFactory.addParameter_in("sys_enterpriseid", sys_enterpriseids);
  1093. sqlFactory.addParameter_SQL("where", where);
  1094. Rows amountrows = dbConnect.runSqlQuery(sqlFactory);
  1095. return getSucReturnObject().setData(rows).setTips(amountrows.get(0).toJsonObject()).toString();
  1096. }
  1097. //查询订单列表(业务员)
  1098. public QuerySQL queryList(String where) throws YosException {
  1099. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_order");
  1100. querySQL.setTableAlias("t1");
  1101. querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise", "t2", "t2.sys_enterpriseid = t1.sys_enterpriseid and t2.siteid = t1.siteid",
  1102. "enterprisename", "abbreviation");
  1103. querySQL.addJoinTable(JOINTYPE.left, "sa_brand", "t3", "t3.sa_brandid = t1.sa_brandid",
  1104. "brandname");
  1105. querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise_contacts", "t4", "t4.contactsid = t1.rec_contactsid and t4.siteid = t1.siteid",
  1106. "name", "province", "city", "county", "address", "phonenumber");
  1107. querySQL.addJoinTable(JOINTYPE.left, "sa_agents", "t5", "t5.sys_enterpriseid=t1.sys_enterpriseid and t5.siteid = t1.siteid",
  1108. "agentnum");
  1109. querySQL.addJoinTable(JOINTYPE.left, "sys_hr", "t6", "t6.hrid = t1.saler_hrid and t6.siteid = t1.siteid");
  1110. //设置别名
  1111. querySQL.addQueryFields("salename", "t6.name");
  1112. querySQL.addJoinTable(JOINTYPE.left, "sa_project", "t7", "t7.sa_projectid = t1.sa_projectid and t7.siteid = t1.siteid",
  1113. "projectname");
  1114. querySQL.addQueryFields("amount", "CAST(0 AS CHAR(20))");
  1115. querySQL.addQueryFields("qty", "CAST(0 AS CHAR(20))");
  1116. querySQL.setWhere("t1.siteid", siteid);
  1117. querySQL.setWhere(where);
  1118. querySQL.setWhere("t1.type!='工具借用单'");
  1119. querySQL.setWhere("t1.deleted=0");
  1120. return querySQL;
  1121. }
  1122. //返回导出的标题
  1123. public HashMap<String, String> getTitleMap() {
  1124. HashMap<String, String> titleMap = new HashMap<>();
  1125. titleMap.put("sonum", "订单编号");
  1126. titleMap.put("brandname", "品牌名称");
  1127. titleMap.put("type", "订单类型");
  1128. titleMap.put("tradefield", "领域");
  1129. titleMap.put("remarks", "备注");
  1130. titleMap.put("status", "状态");
  1131. titleMap.put("createdate", "创建时间");
  1132. titleMap.put("enterprisename", "经销商名称");
  1133. titleMap.put("abbreviation", "简称");
  1134. titleMap.put("name", "收货人");
  1135. titleMap.put("amount", "订单金额");
  1136. titleMap.put("qty", "订单数量");
  1137. return titleMap;
  1138. }
  1139. @API(title = "删除", apiversion = R.ID20221108152102.v1.class)
  1140. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  1141. public String delete() throws YosException {
  1142. JSONArray sa_orderids = content.getJSONArray("sa_orderids");
  1143. if (sa_orderids.size() <= 0) {
  1144. return getErrReturnObject().setErrMsg("请选择要执行删除操作的数据。").toString();
  1145. }
  1146. String sql = "SELECT 1 from sa_order WHERE sa_orderid in " + sa_orderids + " and `status` !='新建' and siteid = '" + siteid + "'";
  1147. sql = sql.replace("[", "(").replace("]", ")");
  1148. if (dbConnect.runSqlQuery(sql).isNotEmpty()) {
  1149. return getErrReturnObject().setErrMsg("存在非新建状态数据,无法执行删除操作。").toString();
  1150. }
  1151. ArrayList<String> sqlList = new ArrayList<>();
  1152. SQLFactory sqlFactory = new SQLFactory(this, "订单_删除");
  1153. sqlFactory.addParameter("siteid", siteid);
  1154. sqlFactory.addParameter_in("sa_orderid", sa_orderids.toArray());
  1155. sqlList.add(sqlFactory.getSQL());
  1156. //订单删除原因
  1157. DataExtend.createDeleteReasonSql(this, "sa_order", sa_orderids.toJavaList(Long.class), content.getStringValue("deletereason"));
  1158. //操作记录
  1159. for (Object obj : sa_orderids) {
  1160. Long sa_orderid = Long.valueOf(obj.toString());
  1161. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "删除", "订单删除").getSQL());
  1162. }
  1163. dbConnect.runSqlUpdate(sqlList);
  1164. ClearData.clearOrder(this);
  1165. return getSucReturnObject().toString();
  1166. }
  1167. @API(title = "更新项目备注,备注,销售类别,摘要", apiversion = R.ID20230301152702.v1.class)
  1168. public String update() throws YosException {
  1169. Long sa_orderid = content.getLong("sa_orderid");
  1170. String projectnote = content.getStringValue("projectnote");
  1171. String remarks = content.getStringValue("remarks");
  1172. String saletype = content.getStringValue("saletype");
  1173. Rows orderRows = getOrderRows(this, sa_orderid);
  1174. if (orderRows.get(0).getString("status").equals("关闭")) {
  1175. return getErrReturnObject().setErrMsg("关闭状态无法修改").toString();
  1176. }
  1177. //通过版本更新订单表头数据
  1178. beans.order.Order.updateOrderWithVersion(this);
  1179. SQLFactory sqlFactory = new SQLFactory(this, "更新订单项目备注等信息");
  1180. sqlFactory.addParameter("siteid", siteid);
  1181. sqlFactory.addParameter("username", username);
  1182. sqlFactory.addParameter("userid", userid);
  1183. sqlFactory.addParameter("sa_orderid", sa_orderid);
  1184. sqlFactory.addParameter("projectnote", projectnote);
  1185. sqlFactory.addParameter("remarks", remarks);
  1186. sqlFactory.addParameter("saletype", saletype);
  1187. sqlFactory.addParameter("abstract", content.getStringValue("abstract"));
  1188. dbConnect.runSqlUpdate(sqlFactory);
  1189. return selectDetail();
  1190. }
  1191. @API(title = "更新订单明细分类", apiversion = R.ID20230706094703.v1.class)
  1192. public String updateTypemx() throws YosException {
  1193. Long sa_orderid = content.getLong("sa_orderid");
  1194. String typemx = content.getStringValue("typemx");
  1195. Rows orderRows = getOrderRows(this, sa_orderid);
  1196. if (orderRows.isEmpty()) {
  1197. return getErrReturnObject().setErrMsg("订单数据不存在").toString();
  1198. }
  1199. String status = orderRows.get(0).getString("status");
  1200. if (!(status.equals("预提交") || status.equals("确认") || status.equals("提交"))) {
  1201. return getErrReturnObject().setErrMsg("非预提交、提交、确认状态无法修改").toString();
  1202. }
  1203. SQLFactory sqlFactory = new SQLFactory(this, "更新订单明细分类");
  1204. sqlFactory.addParameter("siteid", siteid);
  1205. sqlFactory.addParameter("username", username);
  1206. sqlFactory.addParameter("userid", userid);
  1207. sqlFactory.addParameter("sa_orderid", sa_orderid);
  1208. sqlFactory.addParameter("typemx", typemx);
  1209. dbConnect.runSqlUpdate(sqlFactory);
  1210. return selectDetail();
  1211. }
  1212. @API(title = "使用返利金", apiversion = R.ID20230218225002.v1.class)
  1213. public String isUseRate() throws YosException {
  1214. Long sa_orderid = content.getLong("sa_orderid");
  1215. boolean isused = content.getBooleanValue("isused");
  1216. BigDecimal rebateamount = content.getBigDecimalValue("rebateamount");
  1217. if (rebateamount.compareTo(BigDecimal.ZERO) == 0) {
  1218. rebateamount = getMaxUsedRebateAmount(this, sa_orderid);
  1219. }
  1220. ArrayList<String> sqlList = new ArrayList<>();
  1221. if (Parameter.get(siteid, "order_rebate_used").equals("0")) {
  1222. return getErrReturnObject().setErrMsg("站点未开启返利金,无法使用返利金").toString();
  1223. }
  1224. Rows rows = getOrderRows(this, sa_orderid);
  1225. if (rows.isEmpty()) {
  1226. return getErrReturnObject().setErrMsg("未找到订单数据,无法使用返利金").toString();
  1227. }
  1228. //通过版本更新订单表头数据
  1229. beans.order.Order.updateOrderWithVersion(this);
  1230. Row orderRow = rows.get(0);
  1231. String type = orderRow.getString("type");
  1232. if (type.equals("标准订单") || type.equals("特殊订单")) {
  1233. //先初始化返利金价格
  1234. sqlList.add(beans.order.Order.updateRateInfo(this, sa_orderid, BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO));
  1235. sqlList.add("UPDATE sa_orderitems SET amount = defaultamount ,price = defaultprice ,rebateamount = 0 WHERE sa_orderid = " + sa_orderid + " and siteid='" + siteid + "'");
  1236. dbConnect.runSqlUpdate(sqlList);
  1237. sqlList.clear();
  1238. //使用返利金
  1239. if (isused) {
  1240. //站点返利金比例
  1241. BigDecimal order_rebate_userate = BigDecimal.valueOf(Double.valueOf(Parameter.get(siteid, "order_rebate_userate")));
  1242. //订单金额
  1243. BigDecimal defaultAmount = getDefaultAmount(this, sa_orderid);
  1244. //返利金最大使用金额
  1245. BigDecimal maxAmount = defaultAmount.multiply(order_rebate_userate).divide(BigDecimal.valueOf(1));
  1246. if (rebateamount.compareTo(maxAmount) == 1) {
  1247. return getErrReturnObject().setErrMsg("超过最大使用金度:" + maxAmount).toString();
  1248. }
  1249. Long pay_enterpriseid = orderRow.getLong("pay_enterpriseid");
  1250. if (pay_enterpriseid <= 0) {
  1251. return getErrReturnObject().setErrMsg("请选择结算企业").toString();
  1252. }
  1253. //当前返利金额度
  1254. BigDecimal rebateBalance = Accountbalance.getRebateBalance(this, pay_enterpriseid);
  1255. if (rebateamount.compareTo(rebateBalance) == 1) {
  1256. return getErrReturnObject().setErrMsg("超出返利金账户余额,可用余额为:" + rebateBalance).toString();
  1257. }
  1258. BigDecimal rebate_userate;
  1259. if (defaultAmount.compareTo(BigDecimal.ZERO) == 0) {
  1260. rebate_userate = BigDecimal.ZERO;
  1261. } else {
  1262. rebate_userate = rebateamount.divide(defaultAmount, 6, BigDecimal.ROUND_CEILING);
  1263. }
  1264. sqlList.add(beans.order.Order.updateRateInfo(this, sa_orderid, BigDecimal.valueOf(1), rebate_userate, rebateamount));
  1265. dbConnect.runSqlUpdate(sqlList);
  1266. // //更新订单商品数据
  1267. setRebateAmount(this, sa_orderid, rebateamount);
  1268. adjustLastRebateAmount(this, sa_orderid);
  1269. }
  1270. } else {
  1271. return getErrReturnObject().setErrMsg("非标准订单或特殊订单无法使用返利金").toString();
  1272. }
  1273. return getSucReturnObject().setData(rebateamount).toString();
  1274. }
  1275. @API(title = "提交", apiversion = R.ID20221108153402.v1.class, intervaltime = 5000)
  1276. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class, cashbill.class, promotion.class, restcontroller.webmanage.sale.promotion.promotion.class})
  1277. public String submit() throws YosException {
  1278. Long sa_orderid = content.getLong("sa_orderid");
  1279. Rows rows = getOrderRows(this, sa_orderid);
  1280. if (rows.isEmpty()) {
  1281. return getErrReturnObject().setErrMsg("订单不存在").toString();
  1282. }
  1283. Row row = rows.get(0);
  1284. //付款账户信息
  1285. JSONArray accountclassinfos = row.getJSONArray("sa_accountclassinfos");
  1286. Long sa_accountclassid = row.getLong("sa_accountclassid");
  1287. if (sa_accountclassid <= 0) {
  1288. return getErrReturnObject().setErrMsg("请选择支付账号").toString();
  1289. }
  1290. String type = row.getString("type");
  1291. String typemx = row.getString("typemx");
  1292. if (siteid.equalsIgnoreCase("CCYOSG") && !type.equals("促销订单")) {
  1293. if (typemx.equals("工程") || typemx.equals("电商") || typemx.equals("内部")) {
  1294. } else {
  1295. String tradefield = row.getString("tradefield");
  1296. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_optiontypemx");
  1297. querySQL.addJoinTable(JOINTYPE.inner, "sys_optiontype", "t2", "t2.optiontypeid=t1.optiontypeid");
  1298. querySQL.setWhere("t2.typename='domainrelatedaccounts'");
  1299. querySQL.setWhere("(t1.value='" + tradefield + "' or t1.remarks='" + tradefield + "')");
  1300. querySQL.setTableAlias("t1");
  1301. Rows accountsTows = querySQL.query();
  1302. if (accountsTows.isNotEmpty()) {
  1303. JSONArray subvalues = accountsTows.get(0).getJSONArray("subvalues");
  1304. if (!subvalues.contains(sa_accountclassid.toString())) {
  1305. return getErrReturnObject().setErrMsg("扣款账户不对,禁止提交,请更换支付账户后提交").toString();
  1306. }
  1307. }
  1308. }
  1309. }
  1310. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  1311. if (sys_enterpriseid <= 0) {
  1312. return getErrReturnObject().setErrMsg("请选择订货企业信息").toString();
  1313. }
  1314. //验证结算企业
  1315. Long pay_enterpriseid = row.getLong("pay_enterpriseid");
  1316. if (pay_enterpriseid <= 0) {
  1317. dbConnect.runSqlUpdate("UPDATE sa_order set pay_enterpriseid=sys_enterpriseid WHERE sa_orderid=" + sa_orderid);
  1318. // return getErrReturnObject().setErrMsg("请选择结算企业").toString();
  1319. }
  1320. Long sys_enterprise_financeid = row.getLong("sys_enterprise_financeid");
  1321. if (sys_enterprise_financeid <= 0) {
  1322. //return getErrReturnObject().setErrMsg("请选择财务信息").toString();
  1323. }
  1324. // //验证收货人信息
  1325. // Long rec_contactsid = row.getLong("rec_contactsid");
  1326. // if (rec_contactsid <= 0) {
  1327. // return getErrReturnObject().setErrMsg("请选择物收货人信息").toString();
  1328. // }
  1329. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_agents WHERE siteid='" + siteid + "' AND `status`='启用' AND sys_enterpriseid=" + sys_enterpriseid).isEmpty()) {
  1330. return getErrReturnObject().setErrMsg("当前企业不存在或已禁用,无法下单").toString();
  1331. }
  1332. Long sa_promotionid = row.getLong("sa_promotionid");
  1333. if (sa_promotionid > 0) {
  1334. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_promotion WHERE siteid='" + siteid + "' AND sa_promotionid='" + sa_promotionid + "'").isEmpty()) {
  1335. return getErrReturnObject().setErrMsg("该促销活动不存在,无法提交").toString();
  1336. }
  1337. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_promotion WHERE CURRENT_TIME> enddate AND siteid='" + siteid + "' AND sa_promotionid='" + sa_promotionid + "'").isNotEmpty()) {
  1338. return getErrReturnObject().setErrMsg("该促销活动已截止,无法提交").toString();
  1339. }
  1340. }
  1341. if (!((row.getString("status").equals("新建") && !row.getString("type").equals("特殊订单")) || (row.getString("status").equals("确认") && row.getString("type").equals("特殊订单")))) {
  1342. return getErrReturnObject().setErrMsg("新建或非确认无法提交").toString();
  1343. }
  1344. if (dbConnect.runSqlQuery("select * from sa_orderitems where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "'").isEmpty()) {
  1345. return getErrReturnObject().setErrMsg("订单表体不存在商品无法提交").toString();
  1346. }
  1347. if (type.equals("标准订单") || type.equals("促销订单")) {
  1348. if (dbConnect.runSqlQuery("select * from sa_orderitems where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "' and (price<=0 or amount<=0 or qty<=0)").isNotEmpty()) {
  1349. return getErrReturnObject().setErrMsg("商品单价或金额禁止小于等于0").toString();
  1350. }
  1351. }
  1352. Rows orderitems = dbConnect.runSqlQuery("select * from sa_orderitems where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "' and qty<=0");
  1353. if (orderitems.isNotEmpty()) {
  1354. return getErrReturnObject().setErrMsg("订单表体行号为【" + orderitems.get(0).getLong("rowno") + "】的商品数量为0无法提交").toString();
  1355. }
  1356. OrderItemsHelper orderItemsHelper = new OrderItemsHelper(this);
  1357. //标准订单:提交时商品必须是上架状态,否则不允许提交
  1358. if (type.equals("标准订单")) {
  1359. orderItemsHelper.checkOffOrderItems(sa_orderid, "plm_item", sa_promotionid);
  1360. }
  1361. //促销订单:提交时商品必须是上架状态,并且活动方案中的商品必须也是上架状态,否则不允许提交
  1362. if (type.equals("促销订单")) {
  1363. Rows promotionauthRows = dbConnect.runSqlQuery("select * from sa_promotion_auth where sa_promotionid=" + sa_promotionid + " and sys_enterpriseid ='" + sys_enterpriseid + "' and siteid='" + siteid + "'");
  1364. if(promotionauthRows.isNotEmpty()){
  1365. if(promotionauthRows.get(0).getBoolean("settlestatus")){
  1366. return getErrReturnObject().setErrMsg("该促销活动已返利完结,无法提交,请删除或联系总部。").toString();
  1367. }
  1368. }
  1369. // orderItemsHelper.checkOffOrderItems(sa_orderid, "plm_item");
  1370. orderItemsHelper.checkOffOrderItems(sa_orderid, "sa_promotion_items", sa_promotionid);
  1371. }
  1372. if (type.equals("标准订单") || type.equals("促销订单")) {
  1373. Rows orderiteminfos = dbConnect.runSqlQuery("select t1.* from sa_orderitems t1 where t1.sa_orderid=" + sa_orderid + " and t1.siteid='" + siteid + "'");
  1374. JSONArray jsonArray =new JSONArray();
  1375. //批量查询商品信息
  1376. for (Row orderiteminfo :orderiteminfos) {
  1377. JSONObject jsonObject =new JSONObject();
  1378. jsonObject.put("itemid",orderiteminfo.getLong("itemid"));
  1379. jsonArray.add(jsonObject);
  1380. }
  1381. RowsMap itemRowsMap = orderItemsHelper.getItemRowsMap(jsonArray);
  1382. for (Row row1 : orderiteminfos) {
  1383. ItemPrice itemPrice = ItemPrice.getItemPrice(this, rows.get(0).getLong("sys_enterpriseid"), row1.getLong("itemid"));
  1384. if (row1.getBigDecimal("saleprice").compareTo(BigDecimal.ZERO) > 0) {
  1385. JSONObject item =new JSONObject();
  1386. item.put("itemid",row1.getString("itemid"));
  1387. item.put("length",row1.getString("length"));
  1388. item.put("width",row1.getString("width"));
  1389. if (orderItemsHelper.getSalePrice(rows.get(0), itemPrice,item,itemRowsMap).compareTo(row1.getBigDecimal("saleprice")) != 0) {
  1390. return getErrReturnObject().setErrMsg("商品:" + row1.getString("itemno") + "销售价格有更新,请删除后重新添加!").toString();
  1391. }
  1392. }
  1393. }
  1394. }
  1395. //通过版本更新订单表头数据
  1396. beans.order.Order.updateOrderWithVersion(this);
  1397. // String type = row.getString("type");
  1398. //提交
  1399. String status = "提交";
  1400. //扣款的金额
  1401. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  1402. Row enterpriseRow = Enterprise.getEnterprise(this, sys_enterpriseid);
  1403. BigDecimal freefreightamount = BigDecimal.ZERO;
  1404. if (!enterpriseRow.isEmpty()) {
  1405. freefreightamount = enterpriseRow.getBigDecimal("freefreightamount");
  1406. }
  1407. String freightstatus = row.getString("freightstatus");
  1408. if (freightstatus.isEmpty()) {
  1409. if (freefreightamount.compareTo(BigDecimal.ZERO) == -1) {
  1410. freightstatus = "到付";
  1411. }
  1412. if (freefreightamount.compareTo(BigDecimal.ZERO) == 0) {
  1413. freightstatus = "预付";
  1414. }
  1415. if (freefreightamount.compareTo(BigDecimal.ZERO) == 1) {
  1416. if (amount.compareTo(freefreightamount) == 1) {
  1417. freightstatus = "预付";
  1418. } else {
  1419. freightstatus = "到付";
  1420. }
  1421. }
  1422. }
  1423. ArrayList<String> sqlList = new ArrayList<>();
  1424. String sonum = row.getString("sonum");
  1425. if (type.equals("促销订单")) {
  1426. Rows orderdetails = dbConnect.runSqlQuery("select sa_promotion_itemsid,itemno,sum(qty) qty from sa_orderitems where siteid='" + siteid + "' and sa_orderid=" + sa_orderid + " group by sa_promotion_itemsid,itemno");
  1427. Rows promotionitems = dbConnect.runSqlQuery("select * from sa_promotion_items where siteid='" + siteid + "' and sa_promotionid=" + row.getLong("sa_promotionid"));
  1428. RowsMap promotionitemsRowsMap = promotionitems.toRowsMap("sa_promotion_itemsid");
  1429. for (Row orderdetail : orderdetails) {
  1430. String sa_promotion_itemsid = orderdetail.getString("sa_promotion_itemsid");
  1431. BigDecimal qty = orderdetail.getBigDecimal("qty");
  1432. if (promotionitemsRowsMap.containsKey(sa_promotion_itemsid)) {
  1433. if (promotionitemsRowsMap.get(sa_promotion_itemsid).isNotEmpty()) {
  1434. BigDecimal saledqty = promotionitemsRowsMap.get(sa_promotion_itemsid).get(0).getBigDecimal("saledqty");
  1435. BigDecimal groupqty = promotionitemsRowsMap.get(sa_promotion_itemsid).get(0).getBigDecimal("groupqty");
  1436. boolean islimit = promotionitemsRowsMap.get(sa_promotion_itemsid).get(0).getBoolean("islimit");
  1437. if (islimit) {
  1438. if (groupqty.compareTo(saledqty.add(qty)) < 0) {
  1439. return getErrReturnObject().setErrMsg("品号:" + orderdetail.getString("itemno") + "已超过限购数量:" + groupqty.subtract(saledqty)).toString();
  1440. }
  1441. }
  1442. sqlList.add("update sa_promotion_items set saledqty=ifnull(saledqty,0)+" + qty + " where sa_promotion_itemsid=" + sa_promotion_itemsid);
  1443. }
  1444. }
  1445. }
  1446. //促销订单经销商限购金额判断
  1447. String promotiontype = "";
  1448. BigDecimal associationamount = BigDecimal.ZERO;
  1449. Rows promotion = dbConnect.runSqlQuery(" select * from sa_promotion where siteid='" + siteid + "'and sa_promotionid=" + sa_promotionid);
  1450. Rows promotion_auth = dbConnect.runSqlQuery(" select * from sa_promotion_auth where siteid='" + siteid + "'and sys_enterpriseid=" + sys_enterpriseid + " and sa_promotionid=" + sa_promotionid);
  1451. if (promotion.isNotEmpty()) {
  1452. promotiontype = promotion.get(0).getString("type");
  1453. associationamount = promotion.get(0).getBigDecimal("associationamount");
  1454. }
  1455. if (promotion_auth.isNotEmpty()) {
  1456. boolean islimit = promotion_auth.get(0).getBoolean("islimit");
  1457. BigDecimal limitamount = promotion_auth.get(0).getBigDecimal("limitamount");
  1458. BigDecimal saledamount = promotion_auth.get(0).getBigDecimal("saledamount");
  1459. //System.out.println("limitamount:" + limitamount);
  1460. //System.out.println("saledamount:" + saledamount);
  1461. //System.out.println("associationamount:" + associationamount);
  1462. if (islimit) {
  1463. if (!promotiontype.equals("返利促销")) {
  1464. if (amount.compareTo(limitamount.subtract(saledamount)) > 0) {
  1465. return getErrReturnObject().setErrMsg("已超过促销方案限定金额,无法提交").toString();
  1466. }
  1467. sqlList.add("update sa_promotion_auth set saledamount=ifnull(saledamount,0)+" + amount + " where sa_promotion_authid=" + promotion_auth.get(0).getLong("sa_promotion_authid"));
  1468. } else {
  1469. if (amount.subtract((limitamount.subtract(saledamount))).compareTo(associationamount) > 0) {
  1470. return getErrReturnObject().setErrMsg("已超过促销方案限定金额,无法提交").toString();
  1471. }
  1472. if (amount.compareTo((limitamount.subtract(saledamount))) > 0) {
  1473. sqlList.add("update sa_promotion_auth set saledamount=ifnull(saledamount,0)+" + (limitamount.subtract(saledamount)) + " where sa_promotion_authid=" + promotion_auth.get(0).getLong("sa_promotion_authid"));
  1474. } else {
  1475. sqlList.add("update sa_promotion_auth set saledamount=ifnull(saledamount,0)+" + amount + " where sa_promotion_authid=" + promotion_auth.get(0).getLong("sa_promotion_authid"));
  1476. }
  1477. }
  1478. }
  1479. }
  1480. }
  1481. //总的金额
  1482. BigDecimal amountAll = amount;
  1483. BigDecimal costamount_single = BigDecimal.ZERO;
  1484. //查询是否有定制费用,sa_order_cost
  1485. String order_paymentnode = Parameter.get(siteid, "order_paymentnode");
  1486. //订单返利使用开关
  1487. Boolean rebate_used = row.getBoolean("rebate_used");
  1488. //站点订单返利使用开关
  1489. String order_rebate_used = Parameter.get(siteid, "order_rebate_used");
  1490. ArrayList<Long> sa_cashbillidList = new ArrayList<>();
  1491. //查询定制费用
  1492. String sql = "SELECT ifnull(sum(costamount),0) costamount from sa_order_cost WHERE sa_orderid=" + sa_orderid;
  1493. BigDecimal costamount = dbConnect.runSqlQuery(0, sql).getBigDecimal("costamount");
  1494. if (order_paymentnode.equals("1")) {
  1495. if (order_rebate_used.equals("1") && rebate_used) {
  1496. //站点返利金比例
  1497. BigDecimal order_rebate_userate = BigDecimal.valueOf(Double.valueOf(Parameter.get(siteid, "order_rebate_userate")));
  1498. //订单返利金比例
  1499. BigDecimal rebate_userate = row.getBigDecimal("rebate_userate");
  1500. if (rebate_userate.compareTo(order_rebate_userate) == 1) {
  1501. return getErrReturnObject().setErrMsg("返利金使用比例超出站点设置比例,站点比例为" + order_rebate_userate).toString();
  1502. }
  1503. //查询返利金账户余额
  1504. BigDecimal rebateBalance = Accountbalance.getRebateBalance(this, pay_enterpriseid);
  1505. //返利金金额
  1506. BigDecimal rebateamount = row.getBigDecimal("rebateamount");
  1507. if (rebateamount.compareTo(rebateBalance) == 1) {
  1508. return getErrReturnObject().setErrMsg("超过返利金账户余额,返利金账户余额为" + rebateBalance).toString();
  1509. }
  1510. if (!Accountbalance.judgeBalance(this, pay_enterpriseid, sa_accountclassid, amount)) {
  1511. return getErrReturnObject().setErrMsg("账户余额不足,还差" + Accountbalance.InsufficientBalance(this, pay_enterpriseid, sa_accountclassid, amount) + "元!").toString();
  1512. }
  1513. JSONObject rateBillMap = useRateBill(row, "订单提交");
  1514. sqlList.addAll(rateBillMap.getJSONArray("sqlList").toJavaList(String.class));
  1515. sa_cashbillidList.add(rateBillMap.getLong("sa_cashbillid"));
  1516. } else {
  1517. Rows accountclassrows = dbConnect.runSqlQuery("select t1.*,ifnull(t2.balance,0) balance,ifnull(t2.creditquota,0) creditquota from sa_accountclass t1 left join sa_accountbalance t2 on t1.sa_accountclassid=t2.sa_accountclassid and t1.siteid=t2.siteid and t2.sys_enterpriseid=" + pay_enterpriseid + " where isused=1 and t1.siteid='" + siteid + "'");
  1518. RowsMap accountclassrowsMap = accountclassrows.toRowsMap("sa_accountclassid");
  1519. if (!accountclassinfos.isEmpty()) {
  1520. int index = 1;
  1521. for (Object object : accountclassinfos) {
  1522. JSONObject jsonObject = (JSONObject) object;
  1523. BigDecimal amount1 = jsonObject.getBigDecimal("amount");
  1524. if (index == accountclassinfos.size() && costamount.compareTo(BigDecimal.ZERO) > 0) {
  1525. if (Accountbalance.judgeBalance(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), amount1.add(costamount))) {
  1526. CashbillEntity entity = getCashbillEntity(amount1, sa_orderid, "订单提交", sonum, "由订单号" + sonum + "提交时生成");
  1527. //
  1528. if (accountclassrowsMap.containsKey(jsonObject.getString("sa_accountclassid")) && accountclassrowsMap.get(jsonObject.getString("sa_accountclassid")).isNotEmpty()) {
  1529. jsonObject.put("balance", accountclassrowsMap.get(jsonObject.getString("sa_accountclassid")).get(0).getBigDecimal("balance").subtract(amount1));
  1530. } else {
  1531. jsonObject.put("balance", jsonObject.getBigDecimalValue("balance").subtract(amount1));
  1532. }
  1533. JSONObject cashbillPay = Accountbalance.createCashbillPay(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), entity, true);
  1534. // sqlList.addAll(cashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  1535. ArrayList<String> sqlList2= (ArrayList<String>) cashbillPay.getJSONArray("sqlList").toJavaList(String.class);
  1536. dbConnect.runSqlUpdate(sqlList2);
  1537. sa_cashbillidList.add(cashbillPay.getLong("sa_cashbillid"));
  1538. //定制费用
  1539. CashbillEntity entityCost = getCashbillEntity(costamount, sa_orderid, "订单提交", sonum, "由" + sonum + "【定制费用】订单提交时自动产生");
  1540. JSONObject cashbillPayCost = Accountbalance.createCashbillPay(this, pay_enterpriseid, sa_accountclassid, entityCost, true);
  1541. sqlList.addAll(cashbillPayCost.getJSONArray("sqlList").toJavaList(String.class));
  1542. sa_cashbillidList.add(cashbillPayCost.getLong("sa_cashbillid"));
  1543. } else {
  1544. return getErrReturnObject().setErrMsg("账户余额不足,还差" + Accountbalance.InsufficientBalance(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), amount1.add(costamount)) + "元!").toString();
  1545. }
  1546. } else {
  1547. if (Accountbalance.judgeBalance(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), amount1)) {
  1548. CashbillEntity entity = getCashbillEntity(amount1, sa_orderid, "订单提交", sonum, "由订单号" + sonum + "提交时生成");
  1549. //
  1550. if (accountclassrowsMap.containsKey(jsonObject.getString("sa_accountclassid")) && accountclassrowsMap.get(jsonObject.getString("sa_accountclassid")).isNotEmpty()) {
  1551. jsonObject.put("balance", accountclassrowsMap.get(jsonObject.getString("sa_accountclassid")).get(0).getBigDecimal("balance").subtract(amount1));
  1552. } else {
  1553. jsonObject.put("balance", jsonObject.getBigDecimalValue("balance").subtract(amount1));
  1554. }
  1555. JSONObject cashbillPay = Accountbalance.createCashbillPay(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), entity, true);
  1556. sqlList.addAll(cashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  1557. sa_cashbillidList.add(cashbillPay.getLong("sa_cashbillid"));
  1558. } else {
  1559. return getErrReturnObject().setErrMsg("账户余额不足,还差" + Accountbalance.InsufficientBalance(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), amount1) + "元!").toString();
  1560. }
  1561. }
  1562. index++;
  1563. }
  1564. } else {
  1565. if (Accountbalance.judgeBalance(this, pay_enterpriseid, sa_accountclassid, amount.add(costamount))) {
  1566. CashbillEntity entity = getCashbillEntity(amount, sa_orderid, "订单提交", sonum, "由" + sonum + "订单提交时自动产生");
  1567. JSONObject cashbillPay = Accountbalance.createCashbillPay(this, pay_enterpriseid, sa_accountclassid, entity, true);
  1568. // sqlList.addAll(cashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  1569. ArrayList<String> sqlList2= (ArrayList<String>) cashbillPay.getJSONArray("sqlList").toJavaList(String.class);
  1570. dbConnect.runSqlUpdate(sqlList2);
  1571. sa_cashbillidList.add(cashbillPay.getLong("sa_cashbillid"));
  1572. //定制费用
  1573. if (costamount.compareTo(BigDecimal.ZERO) > 0) {
  1574. CashbillEntity entityCost = getCashbillEntity(costamount, sa_orderid, "订单提交", sonum, "由" + sonum + "【定制费用】订单提交时自动产生");
  1575. JSONObject cashbillPayCost = Accountbalance.createCashbillPay(this, pay_enterpriseid, sa_accountclassid, entityCost, true);
  1576. sqlList.addAll(cashbillPayCost.getJSONArray("sqlList").toJavaList(String.class));
  1577. sa_cashbillidList.add(cashbillPayCost.getLong("sa_cashbillid"));
  1578. }
  1579. } else {
  1580. return getErrReturnObject().setErrMsg("账户余额不足,还差" + Accountbalance.InsufficientBalance(this, pay_enterpriseid, sa_accountclassid, amount.add(costamount)) + "元!").toString();
  1581. }
  1582. }
  1583. }
  1584. }
  1585. String message = "您的订单【" + sonum + "】已提交 ,您的资金账户已支出【" + amount + "】!";
  1586. sqlList.add("update sa_order set sa_accountclassinfos='" + accountclassinfos + "' where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "'");
  1587. sqlList.add(getOrderSubmitSql(sa_orderid, status, freightstatus));
  1588. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "订单提交", "订单提交成功,金额:" + amount).getSQL());
  1589. dbConnect.runSqlUpdate(sqlList);
  1590. // sendMsg(message, sa_orderid, sys_enterpriseid);
  1591. // Executor.sendEml(this, "ordercheck", sa_orderid, siteid);
  1592. for (Long sa_cashbillid : sa_cashbillidList) {
  1593. Accountbalance.remindSend(this, pay_enterpriseid, sa_cashbillid);
  1594. }
  1595. return getSucReturnObject().toString();
  1596. }
  1597. public void sendMsg(String content, Long sa_orderid, Long sys_enterpriseid) throws YosException {
  1598. ArrayList<Long> userList = getEnterpriseHrs(sys_enterpriseid).toArrayList("userid", new ArrayList<>());
  1599. Remind remind = new Remind(this);
  1600. remind.setTitle("订单消息");
  1601. remind.setContent(content);
  1602. remind.setType("应用");
  1603. remind.setObjectid(sa_orderid);
  1604. remind.setObjectname("sa_order");
  1605. remind.setTouserid(userList);
  1606. remind.sendByDialogMsg().createSys_message();
  1607. }
  1608. /**
  1609. * @param orderRow
  1610. * @param source
  1611. * @return
  1612. * @throws YosException
  1613. */
  1614. public JSONObject useRateBill(Row orderRow, String source) throws YosException {
  1615. ArrayList<String> sqlList = new ArrayList<>();
  1616. Long sa_orderid = orderRow.getLong("sa_orderid");
  1617. Long pay_enterpriseid = orderRow.getLong("pay_enterpriseid");
  1618. Long sa_accountclassid = orderRow.getLong("sa_accountclassid");
  1619. BigDecimal rebateamount = orderRow.getBigDecimal("rebateamount");
  1620. String sonum = orderRow.getString("sonum");
  1621. JSONObject jsonObject = new JSONObject();
  1622. //金额=金额-返利金金额
  1623. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  1624. //创建支出凭证
  1625. CashbillEntity entity = getCashbillEntity(amount, sa_orderid, source, sonum, "由" + sonum + source + "时自动产生");
  1626. JSONObject cashbillPay = Accountbalance.createCashbillPay(this, pay_enterpriseid, sa_accountclassid, entity, true);
  1627. sqlList.addAll(cashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  1628. Long sa_cashbillid1 = cashbillPay.getLong("sa_cashbillid");
  1629. //创建返利金支出凭证
  1630. Rows cashbillRows = dbConnect.runSqlQuery("SELECT * from sa_cashbill WHERE class='返利金' and STATUS ='审核' and rebate_enddate>=CURRENT_TIME and rebate_balance>0 and sys_enterpriseid= " + pay_enterpriseid + " and siteid = '" + siteid + "' ORDER BY rebate_enddate ");
  1631. int count = 0;
  1632. while (rebateamount.compareTo(BigDecimal.ZERO) == 1) {
  1633. Row cashbillRow = cashbillRows.get(count);
  1634. //返利账户
  1635. sa_accountclassid = cashbillRow.getLong("sa_accountclassid");
  1636. //返利
  1637. Long sa_cashbillid = cashbillRow.getLong("sa_cashbillid");
  1638. BigDecimal rebate_balance = cashbillRow.getBigDecimal("rebate_balance");
  1639. CashbillEntity entity2 = new CashbillEntity();
  1640. //返利代金券小于返利金金额,例如:rebate_balance:10,rebateamount:50
  1641. if (rebate_balance.compareTo(rebateamount) == -1) {
  1642. entity2 = getCashbillEntity(rebate_balance, sa_orderid, source, sonum, "【返利金】由" + sonum + source + "时自动产生");
  1643. rebateamount = rebateamount.subtract(rebate_balance);
  1644. rebate_balance = BigDecimal.ZERO;
  1645. }
  1646. //返利代金券等于返利金金额
  1647. if (rebate_balance.compareTo(rebateamount) == 0) {
  1648. entity2 = getCashbillEntity(rebate_balance, sa_orderid, source, sonum, "【返利金】由" + sonum + source + "时自动产生");
  1649. rebateamount = BigDecimal.ZERO;
  1650. rebate_balance = BigDecimal.ZERO;
  1651. }
  1652. //返利代金券大于返利金金额
  1653. if (rebate_balance.compareTo(rebateamount) == 1) {
  1654. entity2 = getCashbillEntity(rebateamount, sa_orderid, source, sonum, "【返利金】由" + sonum + source + "时自动产生");
  1655. rebate_balance = rebate_balance.subtract(rebateamount);
  1656. rebateamount = BigDecimal.ZERO;
  1657. }
  1658. //不要放到sqlList中,多张返利金时会出现同时使用同一个余额减
  1659. JSONObject cashbillPay1 = Accountbalance.createCashbillPay(this, pay_enterpriseid, sa_accountclassid, entity2, true, sa_cashbillid);
  1660. dbConnect.runSqlUpdate(new ArrayList<>(cashbillPay1.getJSONArray("sqlList").toJavaList(String.class)));
  1661. Accountbalance.remindSend(this, pay_enterpriseid, cashbillPay1.getLong("sa_cashbillid"));
  1662. sqlList.add(updateCashbillSql(sa_cashbillid, rebate_balance));
  1663. count++;
  1664. }
  1665. jsonObject.put("sqlList", sqlList);
  1666. jsonObject.put("sa_cashbillid", sa_cashbillid1);
  1667. return jsonObject;
  1668. }
  1669. @API(title = "审核", apiversion = R.ID20221108153502.v1.class, intervaltime = 5000)
  1670. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class, cashbill.class})
  1671. public String check() throws YosException {
  1672. boolean isdebug = content.getBooleanValue("isdebug");
  1673. Long sa_orderid = content.getLong("sa_orderid");
  1674. String reviewtype = content.getString("reviewtype");
  1675. Rows rows = getOrderRows(this, sa_orderid);
  1676. if (rows.isEmpty()) {
  1677. return getErrReturnObject().setErrMsg("订单不存在").toString();
  1678. }
  1679. Row row = rows.get(0);
  1680. JSONArray accountclassinfos = row.getJSONArray("accountclassinfos");
  1681. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  1682. Long sa_accountclassid = row.getLong("sa_accountclassid");
  1683. if (sa_accountclassid <= 0) {
  1684. return getErrReturnObject().setErrMsg("请选择支付账号").toString();
  1685. }
  1686. // if (siteid.equals("TZ")) {
  1687. // if (StringUtils.isBlank(reviewtype)) {
  1688. // return getErrReturnObject().setErrMsg("订单评审类型为空,无法审核").toString();
  1689. // }
  1690. // }
  1691. // if (StringUtils.isBlank(row.getString("saletype"))) {
  1692. // return getErrReturnObject().setErrMsg("销售分类为空,无法审核").toString();
  1693. // }
  1694. //验证结算企业
  1695. Long pay_enterpriseid = row.getLong("pay_enterpriseid");
  1696. if (pay_enterpriseid <= 0) {
  1697. return getErrReturnObject().setErrMsg("请选择结算企业").toString();
  1698. }
  1699. //通过版本更新订单表头数据
  1700. beans.order.Order.updateOrderWithVersion(this);
  1701. // String type = row.getString("type");
  1702. String sonum = row.getString("sonum");
  1703. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  1704. ArrayList<String> sqlList = new ArrayList<>();
  1705. String order_paymentnode = Parameter.get(siteid, "order_paymentnode");
  1706. //订单返利使用开关
  1707. Boolean rebate_used = row.getBoolean("rebate_used");
  1708. //站点订单返利使用开关
  1709. String order_rebate_used = Parameter.get(siteid, "order_rebate_used");
  1710. ArrayList<Long> sa_cashbillidList = new ArrayList<>();
  1711. if (order_paymentnode.equals("2")) {
  1712. if (order_rebate_used.equals("1") && rebate_used) {
  1713. //站点返利金比例
  1714. BigDecimal order_rebate_userate = BigDecimal.valueOf(Double.valueOf(Parameter.get(siteid, "order_rebate_userate")));
  1715. //订单返利金比例
  1716. BigDecimal rebate_userate = row.getBigDecimal("rebate_userate");
  1717. if (rebate_userate.compareTo(order_rebate_userate) == 1) {
  1718. return getErrReturnObject().setErrMsg("返利金使用比例超出站点设置比例,站点比例为" + order_rebate_userate).toString();
  1719. }
  1720. //查询返利金账户余额
  1721. BigDecimal rebateBalance = Accountbalance.getRebateBalance(this, pay_enterpriseid);
  1722. //返利金金额
  1723. BigDecimal rebateamount = row.getBigDecimal("rebateamount");
  1724. if (rebateamount.compareTo(rebateBalance) == 1) {
  1725. return getErrReturnObject().setErrMsg("超过返利金账户余额,返利金账户余额为" + rebateBalance).toString();
  1726. }
  1727. if (!Accountbalance.judgeBalance(this, pay_enterpriseid, sa_accountclassid, amount)) {
  1728. return getErrReturnObject().setErrMsg("账户余额不足").toString();
  1729. }
  1730. JSONObject rateBillMap = useRateBill(row, "订单审核");
  1731. sqlList.addAll(rateBillMap.getJSONArray("sqlList").toJavaList(String.class));
  1732. sa_cashbillidList.add(rateBillMap.getLong("sa_cashbillid"));
  1733. } else {
  1734. if (!accountclassinfos.isEmpty()) {
  1735. for (Object object : accountclassinfos) {
  1736. JSONObject jsonObject = (JSONObject) object;
  1737. if (Accountbalance.judgeBalance(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), jsonObject.getBigDecimal("amount"))) {
  1738. CashbillEntity entity = getCashbillEntity(jsonObject.getBigDecimal("amount"), sa_orderid, "订单审核", sonum, "由订单号" + sonum + "审核时生成");
  1739. jsonObject.put("balance", jsonObject.getBigDecimalValue("balance").subtract(jsonObject.getBigDecimal("amount")));
  1740. JSONObject createCashbillPay = Accountbalance.createCashbillPay(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), entity, true);
  1741. sqlList.addAll(createCashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  1742. sa_cashbillidList.add(createCashbillPay.getLong("sa_cashbillid"));
  1743. } else {
  1744. return getErrReturnObject().setErrMsg("账户余额不足,还差" + Accountbalance.InsufficientBalance(this, pay_enterpriseid, jsonObject.getLong("sa_accountclassid"), jsonObject.getBigDecimal("amount")) + "元!").toString();
  1745. }
  1746. }
  1747. } else {
  1748. if (Accountbalance.judgeBalance(this, pay_enterpriseid, sa_accountclassid, amount)) {
  1749. CashbillEntity entity = getCashbillEntity(amount, sa_orderid, "订单审核", sonum, "由" + sonum + "订单审核时自动产生");
  1750. JSONObject cashbillPay = Accountbalance.createCashbillPay(this, pay_enterpriseid, sa_accountclassid, entity, true);
  1751. sqlList.addAll(cashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  1752. sa_cashbillidList.add(cashbillPay.getLong("sa_cashbillid"));
  1753. } else {
  1754. return getErrReturnObject().setErrMsg("账户余额不足,还差" + Accountbalance.InsufficientBalance(this, pay_enterpriseid, sa_accountclassid, amount) + "元!").toString();
  1755. }
  1756. }
  1757. }
  1758. }
  1759. String message = "您的订单【" + sonum + "】已审核!";
  1760. sqlList.add(getOrderCheckSql(sa_orderid, reviewtype));
  1761. dbConnect.runSqlUpdate(sqlList);
  1762. for (Long sa_cashbillid : sa_cashbillidList) {
  1763. Accountbalance.remindSend(this, pay_enterpriseid, sa_cashbillid);
  1764. }
  1765. ArrayList<Long> userIdList = dbConnect.runSqlQuery("select userid from sys_enterprise_hr where siteid='" + siteid + "' and isleader=1 and sys_enterpriseid=" + sys_enterpriseid).toArrayList("userid", new ArrayList<>());
  1766. Executor.sendEml(this, "order_check", sa_orderid, siteid, userIdList);
  1767. Rows orderBrand = dbConnect.runSqlQuery("select brandname from sa_brand where siteid='" + siteid + "' and sa_brandid=" + row.getLong("sa_brandid"));
  1768. if (Parameter.get("system.erp_dockswitch").equalsIgnoreCase("true")) {
  1769. UploadDataToERP uploadDataToERP = new UploadDataToERP(this, sa_orderid, "");
  1770. boolean issuccess = uploadDataToERP.upload();
  1771. if (!issuccess) {
  1772. uncheck();
  1773. return getErrReturnObject().setErrMsg("上传ERP失败,当前单据将自动反审核,请检查!").toString();
  1774. } else {
  1775. dbConnect.runSqlUpdate(DataContrlLog.createLog(this, "sa_order", sa_orderid, "订单审核", "订单审核成功,金额:" + amount).getSQL());
  1776. // sendMsg(message, sa_orderid, sys_enterpriseid);
  1777. sendEmail(sa_orderid, row, orderBrand);
  1778. }
  1779. } else {
  1780. dbConnect.runSqlUpdate(DataContrlLog.createLog(this, "sa_order", sa_orderid, "订单审核", "订单审核成功,金额:" + amount).getSQL());
  1781. // sendMsg(message, sa_orderid, sys_enterpriseid);
  1782. sendEmail(sa_orderid, row, orderBrand);
  1783. }
  1784. return getSucReturnObject().toString();
  1785. }
  1786. @API(title = "反审核", apiversion = R.ID20230102141502.v1.class, intervaltime = 5000)
  1787. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class, cashbill.class})
  1788. public String uncheck() throws YosException {
  1789. Long sa_orderid = content.getLong("sa_orderid");
  1790. Rows rows = getOrderRows(this, sa_orderid);
  1791. if (rows.isEmpty()) {
  1792. return getErrReturnObject().setErrMsg("订单不存在").toString();
  1793. }
  1794. Row row = rows.get(0);
  1795. if (dbConnect.runSqlQuery("SELECT 1 from sa_dispatch t1 " +
  1796. "left join sa_dispatch_items t2 on t1.sa_dispatchid=t2.sa_dispatchid and t1.siteid=t2.siteid " +
  1797. "left join sa_orderitems t3 on t2.sa_orderitemsid=t3.sa_orderitemsid and t2.siteid=t3.siteid " +
  1798. "WHERE t1.`status` != '新建' and t1.siteid='" + siteid + "' and t3.sa_orderid=" + sa_orderid).isNotEmpty()) {
  1799. return getErrReturnObject().setErrMsg("存在发货单,无法反审核").toString();
  1800. }
  1801. //通过版本更新订单表头数据
  1802. beans.order.Order.updateOrderWithVersion(this);
  1803. //验证结算企业
  1804. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  1805. String sonum = row.getString("sonum");
  1806. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  1807. ArrayList<String> sqlList = new ArrayList<>();
  1808. SQLFactory sqlFactory = new SQLFactory(this, "订单_反审核");
  1809. sqlFactory.addParameter("siteid", siteid);
  1810. sqlFactory.addParameter("userid", userid);
  1811. sqlFactory.addParameter("username", username);
  1812. sqlFactory.addParameter_in("sa_orderid", sa_orderid);
  1813. sqlList.add(sqlFactory.getSQL());
  1814. //订单扣款节点(1:订单提交、2:订单审核)
  1815. String order_paymentnode = Parameter.get(siteid, "order_paymentnode");
  1816. Long sa_cashbillid = 0L;
  1817. if (order_paymentnode.equals("2")) {
  1818. JSONObject jsonObject = returnPayBill(row, "订单反审核", sonum, "由" + sonum + "订单反审核时自动产生");
  1819. sqlList.addAll(jsonObject.getJSONArray("sqlList").toJavaList(String.class));
  1820. sa_cashbillid = jsonObject.getLong("sa_cashbillid");
  1821. }
  1822. String message = "您的订单【" + sonum + "】已反审核,请注意查看!";
  1823. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "订单反审核", "订单反审核成功,金额:" + amount).getSQL());
  1824. dbConnect.runSqlUpdate(sqlList);
  1825. sendMsg(message, sa_orderid, sys_enterpriseid);
  1826. if (order_paymentnode.equals("2")) {
  1827. Accountbalance.remindSend(this, row.getLong("pay_enterpriseid"), sa_cashbillid);
  1828. }
  1829. return getSucReturnObject().toString();
  1830. }
  1831. @API(title = "预提交反预提交", apiversion = R.ID20230331152503.v1.class)
  1832. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  1833. public String presubmit() throws YosException {
  1834. boolean isrecheck = content.getBooleanValue("isrecheck");
  1835. Long sa_orderid = content.getLong("sa_orderid");
  1836. Rows rows = getOrderRows(this, sa_orderid);
  1837. if (rows.isEmpty()) {
  1838. return getErrReturnObject().setErrMsg("订单不存在").toString();
  1839. }
  1840. //通过版本更新订单表头数据
  1841. beans.order.Order.updateOrderWithVersion(this);
  1842. Row row = rows.get(0);
  1843. String sonum = row.getString("sonum");
  1844. //验证结算企业
  1845. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  1846. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_agents WHERE siteid='" + siteid + "' AND `status`='启用' AND sys_enterpriseid=" + sys_enterpriseid).isEmpty()) {
  1847. return getErrReturnObject().setErrMsg("当前企业不存在或已禁用,无法下单").toString();
  1848. }
  1849. Long sa_promotionid = row.getLong("sa_promotionid");
  1850. if (sa_promotionid > 0) {
  1851. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_promotion WHERE CURRENT_TIME> enddate AND siteid='" + siteid + "' AND sa_promotionid='" + sa_promotionid + "'").isNotEmpty()) {
  1852. return getErrReturnObject().setErrMsg("该促销活动已截止,无法提交").toString();
  1853. }
  1854. }
  1855. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  1856. if (dbConnect.runSqlQuery("select * from sa_orderitems where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "'").isEmpty()) {
  1857. return getErrReturnObject().setErrMsg("订单表体不存在商品无法提交").toString();
  1858. }
  1859. ArrayList<String> sqlList = new ArrayList<>();
  1860. if (isrecheck) {
  1861. if (!row.getString("status").equals("新建")) {
  1862. return getErrReturnObject().setErrMsg("单号为:【" + row.getString("sonum") + "】的订单为非新建状态,无法预提交")
  1863. .toString();
  1864. }
  1865. } else {
  1866. if (!row.getString("status").equals("预提交")) {
  1867. return getErrReturnObject().setErrMsg("单号为:【" + row.getString("sonum") + "】的订单为非预提交状态,无法撤回")
  1868. .toString();
  1869. }
  1870. }
  1871. SQLFactory sqlFactoryupdate;
  1872. String message = "";
  1873. if (isrecheck) {
  1874. message = "您的订单【" + sonum + "】已预提交,请注意查看!";
  1875. sqlFactoryupdate = new SQLFactory(this, "订单预提交");
  1876. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "预提交", "订单预提交成功,金额:" + amount).getSQL());
  1877. } else {
  1878. message = "您的订单【" + sonum + "】已反预提交,请注意查看!";
  1879. sqlFactoryupdate = new SQLFactory(this, "订单反预提交");
  1880. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "反预提交", "订单反预提交成功,金额:" + amount).getSQL());
  1881. }
  1882. sqlFactoryupdate.addParameter("siteid", siteid);
  1883. sqlFactoryupdate.addParameter("sa_orderid", sa_orderid);
  1884. sqlFactoryupdate.addParameter("recheckby", username);
  1885. sqlList.add(sqlFactoryupdate.getSQL());
  1886. if (isrecheck && row.getString("type").equals("特殊订单")) {
  1887. sqlList.add("update sa_order set typemx='特价' where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "'");
  1888. }
  1889. dbConnect.runSqlUpdate(sqlList);
  1890. sendMsg(message, sa_orderid, sys_enterpriseid);
  1891. return getSucReturnObject().toString();
  1892. }
  1893. @API(title = "确认反确认", apiversion = R.ID20230331102503.v1.class)
  1894. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  1895. public String recheck() throws YosException {
  1896. boolean isrecheck = content.getBooleanValue("isrecheck");
  1897. Long sa_orderid = content.getLong("sa_orderid");
  1898. Rows rows = getOrderRows(this, sa_orderid);
  1899. if (rows.isEmpty()) {
  1900. return getErrReturnObject().setErrMsg("订单不存在").toString();
  1901. }
  1902. //通过版本更新订单表头数据
  1903. beans.order.Order.updateOrderWithVersion(this);
  1904. Row row = rows.get(0);
  1905. String sonum = row.getString("sonum");
  1906. //验证结算企业
  1907. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  1908. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  1909. ArrayList<String> sqlList = new ArrayList<>();
  1910. if (isrecheck) {
  1911. if (row.getBoolean("createflag")) {
  1912. if (!row.getString("status").equals("新建")) {
  1913. return getErrReturnObject().setErrMsg("单号为:【" + row.getString("sonum") + "】的订单为新建状态,无法确认")
  1914. .toString();
  1915. }
  1916. } else {
  1917. if (!row.getString("status").equals("预提交")) {
  1918. return getErrReturnObject().setErrMsg("单号为:【" + row.getString("sonum") + "】的订单为非预提交状态,无法确认")
  1919. .toString();
  1920. }
  1921. }
  1922. } else {
  1923. if (!row.getString("status").equals("确认")) {
  1924. return getErrReturnObject().setErrMsg("单号为:【" + row.getString("sonum") + "】的订单为非确认状态,无法反确认")
  1925. .toString();
  1926. }
  1927. }
  1928. SQLFactory sqlFactoryupdate;
  1929. String message = "";
  1930. if (isrecheck) {
  1931. message = "您的订单【" + sonum + "】已确认,请注意查看!";
  1932. sqlFactoryupdate = new SQLFactory(this, "订单确认");
  1933. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "确认", "订单确认成功,金额:" + amount).getSQL());
  1934. } else {
  1935. message = "您的订单【" + sonum + "】已反确认,请注意查看!";
  1936. if (!row.getBoolean("createflag")) {
  1937. sqlFactoryupdate = new SQLFactory(this, "订单反确认(业务端创建)");
  1938. } else {
  1939. sqlFactoryupdate = new SQLFactory(this, "订单反确认(管理端创建)");
  1940. }
  1941. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "反确认", "订单反确认成功,金额:" + amount).getSQL());
  1942. }
  1943. sqlFactoryupdate.addParameter("siteid", siteid);
  1944. sqlFactoryupdate.addParameter("sa_orderid", sa_orderid);
  1945. sqlFactoryupdate.addParameter("recheckby", username);
  1946. sqlList.add(sqlFactoryupdate.getSQL());
  1947. dbConnect.runSqlUpdate(sqlList);
  1948. sendMsg(message, sa_orderid, sys_enterpriseid);
  1949. return getSucReturnObject().toString();
  1950. }
  1951. @API(title = "退回", apiversion = R.ID20221108161902.v1.class, intervaltime = 5000)
  1952. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class, cashbill.class, promotion.class, restcontroller.webmanage.sale.promotion.promotion.class})
  1953. public String back() throws YosException {
  1954. Long sa_orderid = content.getLong("sa_orderid");
  1955. Rows rows = getOrderRows(this, sa_orderid);
  1956. if (rows.isEmpty()) {
  1957. return getErrReturnObject().setErrMsg("订单不存在").toString();
  1958. }
  1959. if (!rows.get(0).getString("status").equals("提交")) {
  1960. return getErrReturnObject().setErrMsg("订单非提交状态无法退回").toString();
  1961. }
  1962. Row row = rows.get(0);
  1963. Date submitdate = new Date();
  1964. Date date = new Date();
  1965. if (!StringUtils.isBlank(row.getString("submitdate"))) {
  1966. submitdate = row.getDate("submitdate");
  1967. }
  1968. if (!row.getString("type").equals("标准订单")) {
  1969. return getErrReturnObject().setErrMsg("非标准订单无法退回").toString();
  1970. }
  1971. if (!isMonth(submitdate, date) && row.getString("type").equals("标准订单")) {
  1972. return getErrReturnObject().setErrMsg("标准订单无法跨月退回").toString();
  1973. }
  1974. if (rows.get(0).getLong("sa_promotionid") != 0) {
  1975. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_promotion WHERE CURRENT_TIME> enddate AND siteid='" + siteid + "' AND sa_promotionid='" + rows.get(0).getLong("sa_promotionid") + "'").isNotEmpty()) {
  1976. //return getErrReturnObject().setErrMsg("活动已结束,是否确认退回,退回后无法再次提交").toString();
  1977. }
  1978. }
  1979. //通过版本更新订单表头数据
  1980. beans.order.Order.updateOrderWithVersion(this);
  1981. Long sa_accountclassid = row.getLong("sa_accountclassid");
  1982. //验证结算企业
  1983. Long pay_enterpriseid = row.getLong("pay_enterpriseid");
  1984. String sonum = row.getString("sonum");
  1985. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  1986. if (StringUtils.isBlank(row.getString("sa_accountclassinfos"))) {
  1987. dbConnect.runSqlUpdate(updateAccountclassinfos(sa_orderid, sa_accountclassid, sys_enterpriseid));
  1988. rows = getOrderRows(this, sa_orderid);
  1989. row = rows.get(0);
  1990. }
  1991. //System.out.println(rows.get(0).getString("sa_accountclassinfos"));
  1992. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  1993. ArrayList<String> sqlList = new ArrayList<>();
  1994. String type = row.getString("type");
  1995. if (type.equals("促销订单")) {
  1996. Rows orderdetails = dbConnect.runSqlQuery("select sa_promotion_itemsid,itemno,sum(qty) qty from sa_orderitems where siteid='" + siteid + "' and sa_orderid=" + sa_orderid + " group by sa_promotion_itemsid,itemno");
  1997. Rows promotionitems = dbConnect.runSqlQuery("select * from sa_promotion_items where siteid='" + siteid + "' and sa_promotionid=" + row.getLong("sa_promotionid"));
  1998. RowsMap promotionitemsRowsMap = promotionitems.toRowsMap("sa_promotion_itemsid");
  1999. for (Row orderdetail : orderdetails) {
  2000. String sa_promotion_itemsid = orderdetail.getString("sa_promotion_itemsid");
  2001. BigDecimal qty = orderdetail.getBigDecimal("qty");
  2002. if (promotionitemsRowsMap.containsKey(sa_promotion_itemsid)) {
  2003. if (promotionitemsRowsMap.get(sa_promotion_itemsid).isNotEmpty()) {
  2004. sqlList.add("update sa_promotion_items set saledqty=saledqty-" + qty + " where sa_promotion_itemsid=" + sa_promotion_itemsid);
  2005. }
  2006. }
  2007. }
  2008. //促销订单经销商限购金额判断
  2009. Rows promotion_auth = dbConnect.runSqlQuery("select * from sa_promotion_auth where sys_enterpriseid=" + sys_enterpriseid + " and sa_promotionid=" + row.getLong("sa_promotionid"));
  2010. if (promotion_auth.isNotEmpty()) {
  2011. boolean islimit = promotion_auth.get(0).getBoolean("islimit");
  2012. // BigDecimal limitamount = promotion_auth.get(0).getBigDecimal("limitamount");
  2013. // BigDecimal saledamount = promotion_auth.get(0).getBigDecimal("saledamount");
  2014. long sa_promotionid = promotion_auth.get(0).getLong("sa_promotionid");
  2015. Rows promotion = dbConnect.runSqlQuery("select * from sa_promotion where siteid='" + siteid + "'and sa_promotionid=" + sa_promotionid);
  2016. if (islimit) {
  2017. if (promotion.isNotEmpty()) {
  2018. Rows amountrows = dbConnect.runSqlQuery("select sum(amount) amount from sa_cashbill where ownerid='" + sa_orderid + "' and ownertable='sa_order' and sa_accountclassid=" + promotion.get(0).getLong("sa_accountclassid"));
  2019. if (amountrows.isNotEmpty()) {
  2020. if (amountrows.get(0).getBigDecimal("amount").compareTo(BigDecimal.ZERO) > 0) {
  2021. sqlList.add("update sa_promotion_auth set saledamount=saledamount-" + amountrows.get(0).getBigDecimal("amount") + " where sa_promotion_authid=" + promotion_auth.get(0).getLong("sa_promotion_authid"));
  2022. }
  2023. }
  2024. }
  2025. }
  2026. }
  2027. }
  2028. SQLFactory sqlFactory = new SQLFactory(this, "订单_退回");
  2029. sqlFactory.addParameter("siteid", siteid);
  2030. sqlFactory.addParameter("userid", userid);
  2031. sqlFactory.addParameter("username", username);
  2032. sqlFactory.addParameter_in("sa_orderid", sa_orderid);
  2033. sqlList.add(sqlFactory.getSQL());
  2034. // Rows cashbillRows = getCashbillRows(sa_orderid);
  2035. // String source = "";
  2036. // if (cashbillRows.isNotEmpty()) {
  2037. // source = cashbillRows.get(0).getString("source");
  2038. // amount = cashbillRows.get(0).getBigDecimal("amount");
  2039. // }
  2040. // if (source.equals("订单提交") || source.equals("订单审核")) {
  2041. // CashbillEntity entity = getCashbillEntity(amount.negate(), sa_orderid, "订单退回", "由" + sonum + "订单退回时自动产生");
  2042. // sqlList.addAll(Accountbalance.createCashbillPay(this, pay_enterpriseid, sa_accountclassid, entity, true));
  2043. // }
  2044. JSONObject jsonObject = returnPayBill(row, "订单退回", sonum, "由订单号" + sonum + "退回时生成");
  2045. sqlList.addAll(jsonObject.getJSONArray("sqlList").toJavaList(String.class));
  2046. Long sa_cashbillid = jsonObject.getLong("sa_cashbillid");
  2047. String message = "您的订单【" + sonum + "】已退回,退款金额为【" + amount + "】 已转入到您的资金账户";
  2048. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "订单退回", "订单退回成功,金额:" + amount).getSQL());
  2049. dbConnect.runSqlUpdate(sqlList);
  2050. //订单退回原因
  2051. ArrayList<Long> sa_orderids = new ArrayList<>();
  2052. sa_orderids.add(sa_orderid);
  2053. DataExtend.createBackReasonSql(this, "sa_order", sa_orderids, content.getStringValue("backreason"));
  2054. // sendMsg(message, sa_orderid, sys_enterpriseid);
  2055. Accountbalance.remindSend(this, pay_enterpriseid, sa_cashbillid);
  2056. ArrayList<Long> userIdList = dbConnect.runSqlQuery("select userid from sys_enterprise_hr where siteid='" + siteid + "' and sys_enterpriseid=" + sys_enterpriseid).toArrayList("userid", new ArrayList<>());
  2057. Executor.sendEml(this, "order_back", sa_orderid, siteid, userIdList);
  2058. return getSucReturnObject().toString();
  2059. }
  2060. @API(title = "撤回", apiversion = R.ID20230301190202.v1.class, intervaltime = 5000)
  2061. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class, cashbill.class, promotion.class, restcontroller.webmanage.sale.promotion.promotion.class})
  2062. public String revoke() throws YosException {
  2063. Long sa_orderid = content.getLong("sa_orderid");
  2064. Rows rows = getOrderRows(this, sa_orderid);
  2065. if (rows.isEmpty()) {
  2066. return getErrReturnObject().setErrMsg("订单不存在").toString();
  2067. }
  2068. //通过版本更新订单表头数据
  2069. beans.order.Order.updateOrderWithVersion(this);
  2070. Row row = rows.get(0);
  2071. if (!row.getString("status").equals("提交")) {
  2072. return getErrReturnObject().setErrMsg("非提交状态无法撤回").toString();
  2073. }
  2074. Long sa_accountclassid = row.getLong("sa_accountclassid");
  2075. //验证结算企业
  2076. Long pay_enterpriseid = row.getLong("pay_enterpriseid");
  2077. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  2078. String sonum = row.getString("sonum");
  2079. if (StringUtils.isBlank(row.getString("sa_accountclassinfos"))) {
  2080. dbConnect.runSqlUpdate(updateAccountclassinfos(sa_orderid, sa_accountclassid, sys_enterpriseid));
  2081. rows = getOrderRows(this, sa_orderid);
  2082. row = rows.get(0);
  2083. }
  2084. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  2085. ArrayList<String> sqlList = new ArrayList<>();
  2086. String type = row.getString("type");
  2087. if (type.equals("促销订单")) {
  2088. Rows orderdetails = dbConnect.runSqlQuery("select sa_promotion_itemsid,itemno,sum(qty) qty from sa_orderitems where siteid='" + siteid + "' and sa_orderid=" + sa_orderid + " group by sa_promotion_itemsid,itemno");
  2089. Rows promotionitems = dbConnect.runSqlQuery("select * from sa_promotion_items where siteid='" + siteid + "' and sa_promotionid=" + row.getLong("sa_promotionid"));
  2090. RowsMap promotionitemsRowsMap = promotionitems.toRowsMap("sa_promotion_itemsid");
  2091. for (Row orderdetail : orderdetails) {
  2092. String sa_promotion_itemsid = orderdetail.getString("sa_promotion_itemsid");
  2093. BigDecimal qty = orderdetail.getBigDecimal("qty");
  2094. if (promotionitemsRowsMap.containsKey(sa_promotion_itemsid)) {
  2095. if (promotionitemsRowsMap.get(sa_promotion_itemsid).isNotEmpty()) {
  2096. sqlList.add("update sa_promotion_items set saledqty=saledqty-" + qty + " where sa_promotion_itemsid=" + sa_promotion_itemsid);
  2097. }
  2098. }
  2099. }
  2100. }
  2101. if (row.getString("type").equals("特殊订单")) {
  2102. sqlList.add("update sa_order set status='确认' where sa_orderid = " + sa_orderid + " and siteid='" + siteid + "'");
  2103. } else {
  2104. SQLFactory sqlFactory = new SQLFactory(this, "订单_撤回");
  2105. sqlFactory.addParameter("siteid", siteid);
  2106. sqlFactory.addParameter("userid", userid);
  2107. sqlFactory.addParameter("username", username);
  2108. sqlFactory.addParameter_in("sa_orderid", sa_orderid);
  2109. sqlList.add(sqlFactory.getSQL());
  2110. }
  2111. JSONObject jsonObject = returnPayBill(row, "订单撤回", sonum, "由订单号" + sonum + "撤回时生成");
  2112. sqlList.addAll(jsonObject.getJSONArray("sqlList").toJavaList(String.class));
  2113. Long sa_cashbillid = jsonObject.getLong("sa_cashbillid");
  2114. String message = "您的订单【" + sonum + "】 金额为【" + amount + "】 已撤回!";
  2115. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "订单撤回", "订单撤回成功,金额:" + amount).getSQL());
  2116. dbConnect.runSqlUpdate(sqlList);
  2117. //订单退回原因
  2118. // sendMsg(message, sa_orderid, sys_enterpriseid);
  2119. Accountbalance.remindSend(this, pay_enterpriseid, sa_cashbillid);
  2120. return getSucReturnObject().toString();
  2121. }
  2122. @API(title = "交期待确认", apiversion = R.ID20230102143502.v1.class)
  2123. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  2124. public String confirmDelivery() throws YosException {
  2125. Long sa_orderid = content.getLong("sa_orderid");
  2126. Rows rows = getOrderRows(this, sa_orderid);
  2127. if (rows.isEmpty()) {
  2128. return getErrReturnObject().setErrMsg("订单不存在").toString();
  2129. }
  2130. //通过版本更新订单表头数据
  2131. beans.order.Order.updateOrderWithVersion(this);
  2132. Row row = rows.get(0);
  2133. Long sa_accountclassid = row.getLong("sa_accountclassid");
  2134. if (sa_accountclassid <= 0) {
  2135. return getErrReturnObject().setErrMsg("请选择支付账号").toString();
  2136. }
  2137. //验证结算企业
  2138. Long pay_enterpriseid = row.getLong("pay_enterpriseid");
  2139. if (pay_enterpriseid <= 0) {
  2140. return getErrReturnObject().setErrMsg("请选择结算企业").toString();
  2141. }
  2142. Long sys_enterprise_financeid = row.getLong("sys_enterprise_financeid");
  2143. if (sys_enterprise_financeid <= 0) {
  2144. return getErrReturnObject().setErrMsg("请选择财务信息").toString();
  2145. }
  2146. // //物流
  2147. // Long sa_logiscompid = row.getLong("sa_logiscompid");
  2148. // if (sa_logiscompid <= 0) {
  2149. // return getErrReturnObject().setErrMsg("请选择物流信息").toString();
  2150. // }
  2151. //验证收货人信息
  2152. Long rec_contactsid = row.getLong("rec_contactsid");
  2153. if (rec_contactsid <= 0) {
  2154. return getErrReturnObject().setErrMsg("请选择物收货人信息").toString();
  2155. }
  2156. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  2157. if (sys_enterpriseid <= 0) {
  2158. return getErrReturnObject().setErrMsg("请选择订货企业信息").toString();
  2159. }
  2160. //提交,交期待确认
  2161. String status = "交期待确认";
  2162. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  2163. ArrayList<String> sqlList = new ArrayList<>();
  2164. SQLFactory sqlFactory = new SQLFactory(this, "订单_交期待确认");
  2165. sqlFactory.addParameter("siteid", siteid);
  2166. sqlFactory.addParameter("userid", userid);
  2167. sqlFactory.addParameter("username", username);
  2168. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2169. sqlFactory.addParameter("status", status);
  2170. sqlList.add(sqlFactory.getSQL());
  2171. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, status, "订单" + status + ":" + amount).getSQL());
  2172. dbConnect.runSqlUpdate(sqlList);
  2173. Executor.sendEml(this, "orderresponse", sa_orderid, siteid);
  2174. return getSucReturnObject().toString();
  2175. }
  2176. @API(title = "确认交期,操作交期待确认的订单", apiversion = R.ID20221230094802.v1.class)
  2177. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  2178. public String confirmDeliveryDate() throws YosException {
  2179. Long sa_orderid = content.getLong("sa_orderid");
  2180. Rows rows = getOrderRows(this, sa_orderid);
  2181. if (rows.isEmpty()) {
  2182. return getErrReturnObject().setErrMsg("订单不存在").toString();
  2183. }
  2184. //通过版本更新订单表头数据
  2185. beans.order.Order.updateOrderWithVersion(this);
  2186. //交期待确认
  2187. String status = rows.get(0).getString("status");
  2188. if (!status.equals("交期待确认")) {
  2189. return getErrReturnObject().setErrMsg("只能操作交期待确认的订单").toString();
  2190. }
  2191. ArrayList<String> sqlList = new ArrayList<>();
  2192. SQLFactory sqlFactory = new SQLFactory(this, "订单-确认交期");
  2193. sqlFactory.addParameter("siteid", siteid);
  2194. sqlFactory.addParameter("userid", userid);
  2195. sqlFactory.addParameter("username", username);
  2196. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2197. sqlList.add(sqlFactory.getSQL());
  2198. //操作记录
  2199. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "交期确认", "订单交期确认").getSQL());
  2200. dbConnect.runSqlUpdate(sqlList);
  2201. return getSucReturnObject().toString();
  2202. }
  2203. @API(title = "交期撤回", apiversion = R.ID20230227160002.v1.class)
  2204. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  2205. public String revokeDelivery() throws YosException {
  2206. Long sa_orderid = content.getLong("sa_orderid");
  2207. Rows rows = getOrderRows(this, sa_orderid);
  2208. if (rows.isEmpty()) {
  2209. return getErrReturnObject().setErrMsg("订单不存在").toString();
  2210. }
  2211. //通过版本更新订单表头数据
  2212. beans.order.Order.updateOrderWithVersion(this);
  2213. Row row = rows.get(0);
  2214. Long sa_accountclassid = row.getLong("sa_accountclassid");
  2215. //验证结算企业
  2216. Long pay_enterpriseid = row.getLong("pay_enterpriseid");
  2217. Long sys_enterpriseid = row.getLong("sys_enterpriseid");
  2218. String sonum = row.getString("sonum");
  2219. BigDecimal amount = beans.order.Order.getAmount(this, sa_orderid);
  2220. ArrayList<String> sqlList = new ArrayList<>();
  2221. SQLFactory sqlFactory = new SQLFactory(this, "订单_交期撤回");
  2222. sqlFactory.addParameter("siteid", siteid);
  2223. sqlFactory.addParameter("userid", userid);
  2224. sqlFactory.addParameter("username", username);
  2225. sqlFactory.addParameter_in("sa_orderid", sa_orderid);
  2226. sqlList.add(sqlFactory.getSQL());
  2227. //订单扣款节点(1:订单提交、2:订单审核)
  2228. String order_paymentnode = Parameter.get(siteid, "order_paymentnode");
  2229. Long sa_cashbillid = 0L;
  2230. if (order_paymentnode.equals("2")) {
  2231. JSONObject jsonObject = returnPayBill(row, "订单_交期撤回", sonum, "由" + sonum + "订单交期撤回时自动产生");
  2232. sqlList.addAll(jsonObject.getJSONArray("sqlList").toJavaList(String.class));
  2233. sa_cashbillid = jsonObject.getLong("sa_cashbillid");
  2234. }
  2235. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "订单交期撤回", "订单交期撤回:" + amount).getSQL());
  2236. dbConnect.runSqlUpdate(sqlList);
  2237. sendMsg("订单交期撤回" + sonum, sa_orderid, sys_enterpriseid);
  2238. if (order_paymentnode.equals("2")) {
  2239. Accountbalance.remindSend(this, pay_enterpriseid, sa_cashbillid);
  2240. }
  2241. return getSucReturnObject().toString();
  2242. }
  2243. public JSONObject returnPayBill(Row orderrow, String source, String sourcenotes, String remarks) throws YosException {
  2244. JSONObject cashJsonObject = new JSONObject();
  2245. Long sa_orderid = orderrow.getLong("sa_orderid");
  2246. JSONArray sa_accountclassinfos = orderrow.getJSONArray("sa_accountclassinfos");
  2247. //Long sa_accountclassid = orderrow.getLong("sa_accountclassid");
  2248. //验证结算企业
  2249. Long pay_enterpriseid = orderrow.getLong("pay_enterpriseid");
  2250. ArrayList<String> sqlList = new ArrayList<>();
  2251. BigDecimal amount;
  2252. Rows rebateRows = getCashbillRebateRows(sa_orderid);
  2253. //返利金
  2254. if (rebateRows.isNotEmpty()) {
  2255. for (Row rebateRow : rebateRows) {
  2256. amount = rebateRow.getBigDecimal("amount");
  2257. if (amount.compareTo(BigDecimal.ZERO) > 0) {
  2258. Long sa_cashbillid_rebate = rebateRow.getLong("sa_cashbillid_rebate");
  2259. CashbillEntity entity = getCashbillEntity(amount.negate(), sa_orderid, source, sourcenotes, "【返利金】" + remarks);
  2260. sqlList.addAll(beans.order.Order.createRebateBillPay(this, entity, pay_enterpriseid, sa_cashbillid_rebate));
  2261. }
  2262. }
  2263. }
  2264. //金额
  2265. Rows amountRows = getMultipleAccountsCashbillRows(sa_orderid);
  2266. if (amountRows.isNotEmpty()) {
  2267. for (Row row : amountRows) {
  2268. amount = row.getBigDecimal("amount");
  2269. if (!sa_accountclassinfos.isEmpty()) {
  2270. for (Object object : sa_accountclassinfos) {
  2271. JSONObject jsonObject = (JSONObject) object;
  2272. if (jsonObject.getLong("sa_accountclassid") == row.getLong("sa_accountclassid")) {
  2273. //System.out.println(jsonObject.getBigDecimal("balance"));
  2274. //System.out.println(amount);
  2275. //System.out.println(jsonObject.getBigDecimal("balance").add(amount));
  2276. jsonObject.put("balance", jsonObject.getBigDecimal("balance").add(amount));
  2277. break;
  2278. }
  2279. }
  2280. }
  2281. if (amount.compareTo(BigDecimal.ZERO) > 0) {
  2282. CashbillEntity entity = getCashbillEntity(amount.negate(), sa_orderid, source, sourcenotes, remarks);
  2283. JSONObject cashbillPay = Accountbalance.createCashbillPay(this, pay_enterpriseid, row.getLong("sa_accountclassid"), entity, true);
  2284. sqlList.addAll(cashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  2285. cashJsonObject.put("sa_cashbillid", cashbillPay.getLongValue("sa_cashbillid"));
  2286. }
  2287. }
  2288. }
  2289. sqlList.add("update sa_order set sa_accountclassinfos='" + sa_accountclassinfos + "' where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "'");
  2290. cashJsonObject.put("sqlList", sqlList);
  2291. return cashJsonObject;
  2292. }
  2293. /**
  2294. * 邮件发送验证
  2295. *
  2296. * @param sa_orderid
  2297. * @param row
  2298. * @param orderBrand
  2299. */
  2300. public void sendEmail(Long sa_orderid, Row row, Rows orderBrand) {
  2301. switch (row.getString("tradefield")) {
  2302. case "全领域":
  2303. Executor.sendEml(this, "ordertradefield", sa_orderid, siteid);
  2304. break;
  2305. case "燃气":
  2306. Executor.sendEml(this, "ordertradefieldrq", sa_orderid, siteid);
  2307. break;
  2308. case "给水":
  2309. Executor.sendEml(this, "ordertradefieldgs", sa_orderid, siteid);
  2310. break;
  2311. case "暖通":
  2312. Executor.sendEml(this, "ordertradefieldnt", sa_orderid, siteid);
  2313. break;
  2314. case "消防":
  2315. Executor.sendEml(this, "ordertradefieldxf", sa_orderid, siteid);
  2316. break;
  2317. }
  2318. if (orderBrand.isNotEmpty()) {
  2319. switch (orderBrand.get(0).getString("brandname")) {
  2320. case "全品牌":
  2321. Executor.sendEml(this, "orderbrand", sa_orderid, siteid);
  2322. break;
  2323. case "班尼戈":
  2324. Executor.sendEml(this, "orderbrandbng", sa_orderid, siteid);
  2325. break;
  2326. case "中捷":
  2327. Executor.sendEml(this, "orderbrandzj", sa_orderid, siteid);
  2328. break;
  2329. }
  2330. }
  2331. }
  2332. /**
  2333. * 订单结案验证
  2334. *
  2335. * @throws
  2336. */
  2337. public String closeordervalidate(long sa_orderid) throws YosException {
  2338. ArrayList<String> sqlList = new ArrayList<>();
  2339. Rows Rowstatus = dbConnect.runSqlQuery(
  2340. "select * from sa_order where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "'");
  2341. Rows RowsDetail = dbConnect.runSqlQuery(
  2342. "select * from sa_orderitems where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "' order by rowno asc");
  2343. if (Rowstatus.isEmpty()) {
  2344. return "订单不存在";
  2345. } else {
  2346. if (!Rowstatus.get(0).getString("status").equals("审核")) {
  2347. return "非审核状态的订单无法结案";
  2348. }
  2349. }
  2350. if (!siteid.equalsIgnoreCase("TZ")) {
  2351. return "当前站点不可执行订单结案操作";
  2352. }
  2353. DBConnect connect = new DBConnect("ORACLE_TZ");
  2354. Rows rows = connect.runSqlQuery("select SO_LINE2,sum(QTY)as QTY from v_eso_shipped_qty where SO_NO2='" + Rowstatus.get(0).getString("sonum") + "' and ZT='" + (siteid.equalsIgnoreCase("TZ") ? "IDCZJ10" : "IBPNB10") + "' group by SO_LINE2");
  2355. for (Row row : rows) {
  2356. int SO_LINE2 = row.getInteger("SO_LINE2");//erp订单行号
  2357. double QTY = row.getInteger("QTY");//erp已发货数量
  2358. int i = 0;
  2359. for (Row row2 : RowsDetail) {
  2360. int rowno = row2.getInteger("rowno");//订单行号
  2361. if (SO_LINE2 == rowno) {
  2362. sqlList.add("update sa_orderitems set erpdeliedqty=" + QTY + " where sa_orderitemsid=" + row2.getLong("sa_orderitemsid"));
  2363. }
  2364. }
  2365. dbConnect.runSqlUpdate(sqlList);
  2366. }
  2367. {
  2368. String str = "";
  2369. RowsDetail = dbConnect.runSqlQuery(
  2370. "select * from sa_orderitems where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "' order by rowno asc");
  2371. for (Row row : RowsDetail) {
  2372. int rowno = row.getInteger("rowno");//订单行号
  2373. BigDecimal deliedqty = row.getBigDecimal("deliedqty");//订单已发货数量
  2374. BigDecimal erpdeliedqty = row.getBigDecimal("erpdeliedqty");//erp已发货数量
  2375. //System.out.println(deliedqty);
  2376. //System.out.println(erpdeliedqty);
  2377. if (deliedqty.compareTo(erpdeliedqty) != 0) {
  2378. str = str + "行" + rowno + "商品发货数量" + deliedqty + "与erp发货数量" + erpdeliedqty + "不一致,请检查;";
  2379. }
  2380. }
  2381. if (!str.equalsIgnoreCase("")) {
  2382. return str;
  2383. }
  2384. }
  2385. return "true";
  2386. }
  2387. @API(title = "关闭", apiversion = R.ID20221108164502.v1.class)
  2388. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  2389. public String close() throws YosException {
  2390. long sa_orderid = content.getLong("sa_orderid");
  2391. String str = closeordervalidate(sa_orderid);
  2392. if (!str.equals("true")) {
  2393. return getErrReturnObject().setErrMsg(str).toString();
  2394. }
  2395. //通过版本更新订单表头数据
  2396. beans.order.Order.updateOrderWithVersion(this);
  2397. Rows RowsDetails = dbConnect.runSqlQuery(
  2398. "select * from sa_orderitems where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "' order by rowno asc");
  2399. content.put("type", "数量");
  2400. content.put("remarks", "订单结案变更");
  2401. JSONArray itemifnos = new JSONArray();
  2402. for (Row row : RowsDetails) {
  2403. if (row.getBigDecimal("qty").compareTo(row.getBigDecimal("erpdeliedqty")) > 0) {
  2404. JSONObject jsonObject = new JSONObject();
  2405. jsonObject.put("itemid", row.getLong("itemid"));
  2406. jsonObject.put("sa_orderitemsid", row.getLong("sa_orderitemsid"));
  2407. jsonObject.put("newvalue", row.getString("erpdeliedqty"));
  2408. itemifnos.add(jsonObject);
  2409. }
  2410. }
  2411. content.put("itemifnos", itemifnos);
  2412. content.put("isjiean", true);
  2413. OrderItems orderItems = new OrderItems(content);
  2414. orderItems.changeItem();
  2415. if (Parameter.get("system.erp_dockswitch").equalsIgnoreCase("true")) {
  2416. Rows rows = dbConnect.runSqlQuery("select * from sa_orderitems_change where sa_orderid=" + sa_orderid
  2417. + " and siteid='" + siteid + "' order by createdate desc");
  2418. //System.out.println(!rows.isEmpty());
  2419. if (!rows.isEmpty()) {
  2420. UploadDataToERP uploadDataToERP = new UploadDataToERP(this, rows.get(0).getLong("sa_orderitems_changeid"), "订单变更");
  2421. boolean issuccess = uploadDataToERP.upload();
  2422. if (!issuccess) {
  2423. dbConnect.runSqlUpdate("update sa_order set changeuserid='" + userid + "',changeby= '"
  2424. + username
  2425. + "',changedate = current_time,status= '审核',closeby='',closedate = NULL where siteid = '"
  2426. + siteid + "' and sa_orderid =" + sa_orderid);
  2427. return getErrReturnObject().setErrMsg("上传ERP失败,当前单据将自动反关闭,请检查!").toString();
  2428. }
  2429. }
  2430. }
  2431. SQLFactory sqlFactory = new SQLFactory(this, "订单_关闭");
  2432. sqlFactory.addParameter("siteid", siteid);
  2433. sqlFactory.addParameter("userid", userid);
  2434. sqlFactory.addParameter("username", username);
  2435. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2436. dbConnect.runSqlUpdate(sqlFactory);
  2437. return getSucReturnObject().toString();
  2438. }
  2439. @API(title = "查询发货单列表", apiversion = R.ID20221205111302.v1.class)
  2440. @CACHEING
  2441. public String dispatchList() throws YosException {
  2442. Long sa_orderid = content.getLong("sa_orderid");
  2443. StringBuffer where = new StringBuffer(" 1=1 ");
  2444. if (content.containsKey("where")) {
  2445. JSONObject whereObject = content.getJSONObject("where");
  2446. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  2447. where.append(" and(");
  2448. where.append("t1.billno like'%").append(whereObject.getString("condition")).append("%' ");
  2449. where.append(")");
  2450. }
  2451. }
  2452. // SQLFactory sqlFactory = new SQLFactory(this, "订单_发货单列表", pageSize, pageNumber, pageSorting);
  2453. // sqlFactory.addParameter("siteid", siteid);
  2454. // sqlFactory.addParameter_SQL("where", where);
  2455. // sqlFactory.addParameter("sa_orderid", sa_orderid);
  2456. // Rows rows = dbConnect.runSqlQuery(sqlFactory);
  2457. QuerySQL querySQL = queryDispatchList(where.toString(), sa_orderid);
  2458. querySQL.setPage(pageSize, pageNumber);
  2459. querySQL.setOrderBy(pageSorting);
  2460. Rows rows = querySQL.query();
  2461. ArrayList<Long> ids = rows.toArrayList("sa_dispatchid", new ArrayList<>());
  2462. SQLFactory sqlFactory = new SQLFactory(this, "查询发货单数据");
  2463. sqlFactory.addParameter_in("sa_dispatchid", ids);
  2464. RowsMap rowsMap = dbConnect.runSqlQuery(sqlFactory).toRowsMap("sa_dispatchid");
  2465. for (Row row : rows) {
  2466. Rows rows2 = rowsMap.getOrDefault(row.getString("sa_dispatchid"), new Rows());
  2467. if (rows2.isNotEmpty()) {
  2468. row.putIfAbsent("sumamount", rows2.get(0).getBigDecimal("sumamount").setScale(2));
  2469. row.putIfAbsent("sumqty", rows2.get(0).getBigDecimal("sumqty").setScale(2));
  2470. }
  2471. row.putIfAbsent("sumamount", 0);
  2472. row.putIfAbsent("sumqty", 0);
  2473. }
  2474. return getSucReturnObject().setData(rows).toString();
  2475. }
  2476. //查询订单列表(业务员)
  2477. public QuerySQL queryDispatchList(String where, Long sa_orderid) throws YosException {
  2478. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_dispatch");
  2479. querySQL.setTableAlias("t1");
  2480. querySQL.setWhere("t1.siteid", siteid);
  2481. querySQL.setWhere("t1.sa_orderid", sa_orderid);
  2482. querySQL.setWhere(where);
  2483. querySQL.setWhere("t1.`status` != '新建'");
  2484. return querySQL;
  2485. }
  2486. @API(title = "查询物流单列表", apiversion = R.ID20221205111402.v1.class)
  2487. @CACHEING
  2488. public String logisticsList() throws YosException {
  2489. Long sa_orderid = content.getLong("sa_orderid");
  2490. StringBuffer where = new StringBuffer(" 1=1 ");
  2491. if (content.containsKey("where")) {
  2492. JSONObject whereObject = content.getJSONObject("where");
  2493. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  2494. where.append(" and(");
  2495. where.append("t3.name like'%").append(whereObject.getString("condition")).append("%' ");
  2496. where.append("or t3.phonenumber like'%").append(whereObject.getString("condition")).append("%' ");
  2497. where.append(")");
  2498. }
  2499. }
  2500. SQLFactory sqlFactory = new SQLFactory(this, "订单_物流单列表", pageSize, pageNumber, pageSorting);
  2501. sqlFactory.addParameter("siteid", siteid);
  2502. sqlFactory.addParameter_SQL("where", where);
  2503. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2504. String sql = sqlFactory.getSQL();
  2505. Rows rows = dbConnect.runSqlQuery(sql);
  2506. return getSucReturnObject().setData(rows).toString();
  2507. }
  2508. @API(title = "查询出库单列表", apiversion = R.ID20230815151203.v1.class)
  2509. @CACHEING
  2510. public String stockbillList() throws YosException {
  2511. Long sa_orderid = content.getLong("sa_orderid");
  2512. StringBuffer where = new StringBuffer(" 1=1 ");
  2513. if (content.containsKey("where")) {
  2514. JSONObject whereObject = content.getJSONObject("where");
  2515. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  2516. where.append(" and(");
  2517. where.append("t.billno like'%").append(whereObject.getString("condition")).append("%' ");
  2518. where.append(")");
  2519. }
  2520. }
  2521. SQLFactory sqlFactory = new SQLFactory(this, "订单_出库单列表", pageSize, pageNumber, pageSorting);
  2522. sqlFactory.addParameter("siteid", siteid);
  2523. sqlFactory.addParameter_SQL("where", where);
  2524. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2525. Rows rows = dbConnect.runSqlQuery(sqlFactory);
  2526. return getSucReturnObject().setData(rows).toString();
  2527. }
  2528. @API(title = "查询订单进度", apiversion = R.ID20221229093602.v1.class)
  2529. @CACHEING
  2530. public String getOrderProcess() throws YosException {
  2531. StringBuffer where = new StringBuffer(" 1=1 ");
  2532. if (content.containsKey("where")) {
  2533. JSONObject whereObject = content.getJSONObject("where");
  2534. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  2535. where.append(" and(");
  2536. where.append("t1.type like'%").append(whereObject.getString("condition")).append("%' ");
  2537. where.append("or t1.action like'%").append(whereObject.getString("condition")).append("%' ");
  2538. where.append("or t1.actionby like'%").append(whereObject.getString("condition")).append("%' ");
  2539. where.append("or t1.remarks like'%").append(whereObject.getString("condition")).append("%' ");
  2540. where.append(")");
  2541. }
  2542. }
  2543. Long sa_orderid = content.getLong("sa_orderid");
  2544. SQLFactory sqlFactory = new SQLFactory(this, "查询订单进度列表", pageSize, pageNumber, pageSorting);
  2545. sqlFactory.addParameter("siteid", siteid);
  2546. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2547. sqlFactory.addParameter_SQL("where", where);
  2548. String sql = sqlFactory.getSQL();
  2549. Rows rows = dbConnect.runSqlQuery(sql);
  2550. return getSucReturnObject().setData(rows).toString();
  2551. }
  2552. @API(title = "查询发票列表", apiversion = R.ID20221229154102.v1.class)
  2553. @CACHEING
  2554. public String queryinvoiceapplyList() throws YosException {
  2555. Long sa_orderid = content.getLong("sa_orderid");
  2556. StringBuffer where = new StringBuffer(" 1=1 ");
  2557. if (content.containsKey("where")) {
  2558. JSONObject whereObject = content.getJSONObject("where");
  2559. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  2560. where.append(" and(");
  2561. where.append("t1.invoiceno like'%").append(whereObject.getString("condition")).append("%' ");
  2562. where.append("or t1.invoicecode like'%").append(whereObject.getString("condition")).append("%' ");
  2563. where.append("or t1.invoiceserialnum like'%").append(whereObject.getString("condition")).append("%' ");
  2564. where.append("or t1.sa_invoicebillid_blue like'%").append(whereObject.getString("condition")).append("%' ");
  2565. where.append(")");
  2566. }
  2567. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  2568. where.append(" and t1.status ='").append(whereObject.getString("status")).append("' ");
  2569. }
  2570. if (whereObject.containsKey("rb") && !"".equals(whereObject.getString("rb"))) {
  2571. where.append(" and t1.rb ='").append(whereObject.getString("rb")).append("' ");
  2572. }
  2573. }
  2574. SQLFactory sqlFactory = new SQLFactory(this, "查询发票列表查询", pageSize, pageNumber, pageSorting);
  2575. sqlFactory.addParameter("siteid", siteid);
  2576. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2577. sqlFactory.addParameter_SQL("where", where);
  2578. Rows rows = dbConnect.runSqlQuery(sqlFactory);
  2579. return getSucReturnObject().setData(rows).toString();
  2580. }
  2581. @API(title = "一键复制订单", apiversion = R.ID20230102144502.v1.class)
  2582. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  2583. public String copyOrder() throws YosException {
  2584. Long sa_orderid = content.getLong("sa_orderid");
  2585. Long sys_enterpriseid = content.getLong("sys_enterpriseid");
  2586. ArrayList<String> sqlList = new ArrayList<>();
  2587. Rows rows = dbConnect.runSqlQuery("SELECT * from sa_order WHERE sa_orderid = " + sa_orderid + " and siteid = '" + siteid + "'");
  2588. if (rows.isEmpty()) {
  2589. return getErrReturnObject().setErrMsg("订单不存在").toString();
  2590. }
  2591. Row row = rows.get(0);
  2592. if (sys_enterpriseid > 0) {
  2593. boolean flag = true;
  2594. Row enterpriseRowOld = Enterprise.getEnterprise(this, row.getLong("sys_enterpriseid"));
  2595. Row enterpriseRowNew = Enterprise.getEnterprise(this, sys_enterpriseid);
  2596. if (enterpriseRowOld.isEmpty() || enterpriseRowNew.isEmpty()) {
  2597. return getErrReturnObject().setErrMsg("经销商不存在").toString();
  2598. } else {
  2599. // if (Enterprise.getEnterpriseGrade(this, row.getLong("sys_enterpriseid")).getGrade() != Enterprise.getEnterpriseGrade(this, sys_enterpriseid).getGrade() ||
  2600. // Enterprise.getEnterpriseGrade(this, row.getLong("sys_enterpriseid")).getPricegrade() != Enterprise.getEnterpriseGrade(this, sys_enterpriseid).getPricegrade()) {
  2601. // System.out.println("grade");
  2602. // flag = false;
  2603. // }
  2604. //企业领域
  2605. // Rows tradefieldrowsOld = dbConnect.runSqlQuery("SELECT tradefield from sys_enterprise_tradefield WHERE sys_enterpriseid =" + row.getLong("sys_enterpriseid") + " and siteid ='" + siteid + "'");
  2606. // Rows tradefieldrowsNew = dbConnect.runSqlQuery("SELECT tradefield from sys_enterprise_tradefield WHERE sys_enterpriseid =" + sys_enterpriseid + " and siteid ='" + siteid + "'");
  2607. // if (!tradefieldrowsNew.containsAll(tradefieldrowsOld)) {
  2608. // System.out.println("tradefield");
  2609. // flag = false;
  2610. // }
  2611. //企业营销类别
  2612. String itemclasssqlOld = "select itemclassid from plm_itemclass where siteid='" + siteid + "'";
  2613. boolean saleclassauthOld = enterpriseRowOld.getBoolean("saleclassauth");
  2614. if (saleclassauthOld) {
  2615. itemclasssqlOld = "select itemclassid from plm_itemclass where siteid='" + siteid + "' and itemclassid in ( SELECT itemclassid from sys_enterprise_saleclass WHERE sys_enterpriseid = " + row.getLong("sys_enterpriseid") + " and siteid='" + siteid + "')";
  2616. }
  2617. Rows itemclassrowsOld = dbConnect.runSqlQuery(itemclasssqlOld);
  2618. String itemclasssqlNew = "select itemclassid from plm_itemclass where siteid='" + siteid + "'";
  2619. boolean saleclassauthNew = enterpriseRowNew.getBoolean("saleclassauth");
  2620. if (saleclassauthNew) {
  2621. itemclasssqlNew = "select itemclassid from plm_itemclass where siteid='" + siteid + "' and itemclassid in ( SELECT itemclassid from sys_enterprise_saleclass WHERE sys_enterpriseid = " + sys_enterpriseid + " and siteid='" + siteid + "')";
  2622. }
  2623. Rows itemclassrowsNew = dbConnect.runSqlQuery(itemclasssqlNew);
  2624. if (!itemclassrowsNew.containsAll(itemclassrowsOld)) {
  2625. System.out.println("itemclass");
  2626. flag = false;
  2627. }
  2628. if (!flag) {
  2629. return getErrReturnObject().setErrMsg("所选经销商经营范围不一致,不允许复制").toString();
  2630. }
  2631. }
  2632. }
  2633. Long sa_orderid_copy = createTableID("sa_order");
  2634. SQLFactory sqlFactory = new SQLFactory(this, "复制订单");
  2635. sqlFactory.addParameter("siteid", siteid);
  2636. sqlFactory.addParameter("sa_orderid", sa_orderid_copy);
  2637. sqlFactory.addParameter("userid", userid);
  2638. sqlFactory.addParameter("username", username);
  2639. //订单编号
  2640. sqlFactory.addParameter("sonum", createBillCode("orderbill"));
  2641. //订单类型
  2642. sqlFactory.addParameter("type", row.getString("type"));
  2643. //明细分类
  2644. sqlFactory.addParameter("typemx", row.getString("typemx"));
  2645. //订货企业id
  2646. if (sys_enterpriseid == 0) {
  2647. sqlFactory.addParameter("sys_enterpriseid", row.getLong("sys_enterpriseid"));
  2648. //结算单位
  2649. sqlFactory.addParameter("pay_enterpriseid", row.getLong("sys_enterpriseid"));
  2650. } else {
  2651. sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
  2652. //结算单位
  2653. sqlFactory.addParameter("pay_enterpriseid", sys_enterpriseid);
  2654. }
  2655. //营销账户类型ID
  2656. sqlFactory.addParameter("sa_accountclassid", row.getLong("sa_accountclassid"));
  2657. //品牌ID
  2658. sqlFactory.addParameter("sa_brandid", row.getLong("sa_brandid"));
  2659. //合同ID
  2660. sqlFactory.addParameter("sa_contractid", row.getLong("sa_contractid"));
  2661. //工程项目表ID
  2662. sqlFactory.addParameter("sa_projectid", row.getLong("sa_projectid"));
  2663. //合作企业财务信息ID(开票信息)
  2664. sqlFactory.addParameter("sys_enterprise_financeid", 0);
  2665. //物流公司档案ID
  2666. sqlFactory.addParameter("sa_logiscompid", row.getLong("sa_logiscompid"));
  2667. //合作企业联系人表ID(收货信息)
  2668. sqlFactory.addParameter("rec_contactsid", row.getLong("rec_contactsid"));
  2669. //备注说明
  2670. sqlFactory.addParameter("remarks", row.getString("remarks"));
  2671. //销售人员hrid,业务员hrid
  2672. sqlFactory.addParameter("saler_hrid", row.getLong("saler_hrid"));
  2673. //制单方 1表示工厂方,0表示客户方
  2674. if (usertype == 21 || usertype == 22) {
  2675. sqlFactory.addParameter("createflag", 0);
  2676. } else {
  2677. sqlFactory.addParameter("createflag", 1);
  2678. }
  2679. // 领域
  2680. sqlFactory.addParameter("tradefield", row.getString("tradefield"));
  2681. //单据日期
  2682. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
  2683. sqlFactory.addParameter("billdate", sdf.format(new Date()));
  2684. sqlFactory.addParameter("rebate_userate", row.getBigDecimal("rebate_userate"));
  2685. if (row.getBoolean("rebate_used")) {
  2686. sqlFactory.addParameter("rebate_used", 1);
  2687. } else {
  2688. sqlFactory.addParameter("rebate_used", 0);
  2689. }
  2690. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid_copy, "订单复制", "由订单" + row.getString("sonum") + "复制而来").getSQL());
  2691. sqlList.add(sqlFactory.getSQL());
  2692. //复制商品
  2693. Rows orderitemsRows = dbConnect.runSqlQuery("SELECT * from sa_orderitems WHERE sa_orderid = " + sa_orderid + " and siteid = '" + siteid + "'");
  2694. for (Row orderitemsRow : orderitemsRows) {
  2695. sqlFactory = new SQLFactory(this, "复制订单商品");
  2696. sqlFactory.addParameter("siteid", siteid);
  2697. sqlFactory.addParameter("userid", userid);
  2698. sqlFactory.addParameter("username", username);
  2699. sqlFactory.addParameter("sa_orderitemsid", createTableID("sa_orderitems"));
  2700. sqlFactory.addParameter("sa_orderid", sa_orderid_copy);
  2701. sqlFactory.addParameter("rowno", orderitemsRow.getLong("rowno"));
  2702. sqlFactory.addParameter("itemid", orderitemsRow.getLong("itemid"));
  2703. sqlFactory.addParameter("remarks", orderitemsRow.getString("remarks"));
  2704. sqlFactory.addParameter("itemno", orderitemsRow.getString("itemno"));
  2705. sqlFactory.addParameter("itemname", orderitemsRow.getString("itemname"));
  2706. sqlFactory.addParameter("model", orderitemsRow.getString("model"));
  2707. sqlFactory.addParameter("unit", orderitemsRow.getString("unit"));
  2708. sqlFactory.addParameter("auxunit", orderitemsRow.getString("auxunit"));
  2709. sqlFactory.addParameter("batchcontrol", orderitemsRow.getLong("batchcontrol"));
  2710. sqlFactory.addParameter("delivery", orderitemsRow.getLong("delivery"));
  2711. sqlFactory.addParameter("needdate", orderitemsRow.getString("needdate").equals("") ? "null" : orderitemsRow.getString("needdate"));
  2712. sqlFactory.addParameter("deliverydate", orderitemsRow.getString("deliverydate").equals("") ? "null" : orderitemsRow.getString("deliverydate"));
  2713. sqlFactory.addParameter("conversionrate", orderitemsRow.getBigDecimal("conversionrate"));
  2714. //订购数量
  2715. sqlFactory.addParameter("qty", orderitemsRow.getBigDecimal("qty"));
  2716. //辅助单位数量
  2717. sqlFactory.addParameter("auxqty", orderitemsRow.getBigDecimal("auxqty"));
  2718. //单价,折后价(元)
  2719. sqlFactory.addParameter("price", orderitemsRow.getBigDecimal("price"));
  2720. //金额,折后金额(元)
  2721. sqlFactory.addParameter("amount", orderitemsRow.getBigDecimal("amount"));
  2722. //牌价、市场价(元)
  2723. sqlFactory.addParameter("marketprice", orderitemsRow.getBigDecimal("marketprice"));
  2724. //标准订单取框架内的价格
  2725. //折前价(元)
  2726. sqlFactory.addParameter("defaultprice", orderitemsRow.getBigDecimal("defaultprice"));
  2727. //折前金额(元)
  2728. sqlFactory.addParameter("defaultamount", orderitemsRow.getBigDecimal("defaultamount"));
  2729. sqlList.add(sqlFactory.getSQL());
  2730. }
  2731. dbConnect.runSqlUpdate(sqlList);
  2732. content.put("sa_orderid", sa_orderid_copy);
  2733. Rows ordercopyRows = dbConnect.runSqlQuery("select * from sa_order where siteid='" + siteid + "' and sa_orderid=" + sa_orderid_copy);
  2734. if (ordercopyRows.isNotEmpty()) {
  2735. dbConnect.runSqlUpdate(updateAccountclassinfos(sa_orderid_copy, ordercopyRows.get(0).getLong("sa_accountclassid"), ordercopyRows.get(0).getLong("sys_enterpriseid")));
  2736. }
  2737. return selectDetail();
  2738. }
  2739. @API(title = "回款记录,查询的是核销单", apiversion = R.ID20230102164402.v1.class)
  2740. @CACHEING
  2741. public String query() throws YosException {
  2742. StringBuffer where = new StringBuffer(" 1=1 ");
  2743. if (content.containsKey("where")) {
  2744. JSONObject whereObject = content.getJSONObject("where");
  2745. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  2746. where.append(" and (t1.billno like '%").append(whereObject.getString("condition")).append("%'");
  2747. where.append(" or t2.enterprisename like '%").append(whereObject.getString("condition")).append("%'");
  2748. where.append(" or t2.abbreviation like '%").append(whereObject.getString("condition")).append("%'");
  2749. where.append(" or t5.agentnum like '%").append(whereObject.getString("condition")).append("%'");
  2750. where.append(" or t4.billno like '%").append(whereObject.getString("condition")).append("%')");
  2751. }
  2752. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  2753. where.append(" and t1.status = '").append(whereObject.getString("status")).append("'");
  2754. }
  2755. }
  2756. Long sa_orderid = content.getLong("sa_orderid");
  2757. SQLFactory sqlFactory = new SQLFactory(this, "回款记录", pageSize, pageNumber, pageSorting);
  2758. sqlFactory.addParameter("siteid", siteid);
  2759. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2760. sqlFactory.addParameter_SQL("where", where);
  2761. Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  2762. return getSucReturnObject().setData(rows).toString();
  2763. }
  2764. @API(title = "查询企业的上下级,含支付账号信息", apiversion = R.ID20230104103702.v1.class)
  2765. public String getString() throws YosException {
  2766. StringBuffer where = new StringBuffer(" 1=1 ");
  2767. if (content.containsKey("where")) {
  2768. JSONObject whereObject = content.getJSONObject("where");
  2769. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  2770. where.append(" and (t1.enterprisename like '%").append(whereObject.getString("condition")).append("%'");
  2771. where.append(" or t1.province like '%").append(whereObject.getString("condition")).append("%'");
  2772. where.append(" or t1.city like '%").append(whereObject.getString("condition")).append("%'");
  2773. where.append(" or t1.county like '%").append(whereObject.getString("condition")).append("%'");
  2774. where.append(" or t1.contact like '%").append(whereObject.getString("condition")).append("%'");
  2775. where.append(" or t1.phonenumber like '%").append(whereObject.getString("condition")).append("%')");
  2776. }
  2777. }
  2778. sys_enterpriseid = content.containsKey("sys_enterpriseid") ? content.getLongValue("sys_enterpriseid") : sys_enterpriseid;
  2779. SQLFactory sqlFactory = new SQLFactory(this, "查询经销商上下级", pageSize, pageNumber, pageSorting);
  2780. sqlFactory.addParameter("siteid", siteid);
  2781. sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
  2782. sqlFactory.addParameter_SQL("where", where);
  2783. String sql = sqlFactory.getSQL();
  2784. Rows rows = dbConnect.runSqlQuery(sql);
  2785. ArrayList<Long> sys_enterpriseids = rows.toArrayList("sys_enterpriseid", new ArrayList<>());
  2786. //查询开票信息
  2787. sqlFactory = new SQLFactory(this, "查询经销商默认开票信息");
  2788. sqlFactory.addParameter("siteid", siteid);
  2789. sqlFactory.addParameter_in("sys_enterpriseid", sys_enterpriseids);
  2790. RowsMap financeRowsMap = dbConnect.runSqlQuery(sqlFactory).toRowsMap("sys_enterpriseid");
  2791. for (Row row : rows) {
  2792. row.put("finance", financeRowsMap.getOrDefault(row.getString("sys_enterpriseid"), new Rows()));
  2793. row.put("accounts", new Rows());
  2794. }
  2795. return getSucReturnObject().setData(rows).toString();
  2796. }
  2797. @API(title = "一键填写交货日期", apiversion = R.ID20230104143102.v1.class)
  2798. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  2799. public String updateDelivery() throws YosException {
  2800. Long sa_orderid = content.getLong("sa_orderid");
  2801. //通过版本更新订单表头数据
  2802. beans.order.Order.updateOrderWithVersion(this);
  2803. String deliverydate = content.getString("deliverydate");
  2804. dbConnect.runSqlUpdate("UPDATE sa_orderitems SET deliverydate='" + deliverydate + "' WHERE sa_orderid = " + sa_orderid + " and siteid = '" + siteid + "'");
  2805. return getSucReturnObject().toString();
  2806. }
  2807. @API(title = "一键填写需求日期", apiversion = R.ID20230104143802.v1.class)
  2808. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  2809. public String updateNeeddate() throws YosException {
  2810. Long sa_orderid = content.getLong("sa_orderid");
  2811. //通过版本更新订单表头数据
  2812. beans.order.Order.updateOrderWithVersion(this);
  2813. String needdate = content.getString("needdate");
  2814. dbConnect.runSqlUpdate("UPDATE sa_orderitems SET needdate='" + needdate + "' WHERE sa_orderid = " + sa_orderid + " and siteid = '" + siteid + "'");
  2815. return getSucReturnObject().toString();
  2816. }
  2817. @API(title = "查询居间费表头", apiversion = R.ID20230105194402.v1.class)
  2818. @CACHEING
  2819. public String getRebateInfo() throws YosException {
  2820. Long sa_orderid = content.getLong("sa_orderid");
  2821. SQLFactory sqlFactory = new SQLFactory(this, "居间费结算-详情", pageSize, pageNumber, pageSorting);
  2822. sqlFactory.addParameter("siteid", siteid);
  2823. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2824. Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  2825. Row row = rows.isNotEmpty() ? rows.get(0) : new Row();
  2826. return getSucReturnObject().setData(row).toString();
  2827. }
  2828. @API(title = "查询居间费列表", apiversion = R.ID20230105194902.v1.class)
  2829. @CACHEING
  2830. public String getRebateList() throws YosException {
  2831. StringBuffer where = new StringBuffer(" 1=1 ");
  2832. if (content.containsKey("where")) {
  2833. JSONObject whereObject = content.getJSONObject("where");
  2834. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  2835. where.append(" and (t1.billno like '%").append(whereObject.getString("condition")).append("%'");
  2836. where.append(" and t2.enterprisename like '%").append(whereObject.getString("condition")).append("%'");
  2837. where.append(" or t1.remarks like '%").append(whereObject.getString("condition")).append("%')");
  2838. }
  2839. }
  2840. Long sa_rebatesettlementid = content.getLong("sa_rebatesettlementid");
  2841. SQLFactory sqlFactory = new SQLFactory(this, "居间费结算明细-列表", pageSize, pageNumber, pageSorting);
  2842. sqlFactory.addParameter("siteid", siteid);
  2843. sqlFactory.addParameter("sa_rebatesettlementid", sa_rebatesettlementid);
  2844. sqlFactory.addParameter_SQL("where", where);
  2845. Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  2846. return getSucReturnObject().setData(rows).toString();
  2847. }
  2848. @API(title = "修改业务员", apiversion = R.ID20230213154802.v1.class)
  2849. @CACHEING_CLEAN(apiClass = {Order.class, OrderItems.class, restcontroller.sale.order.Order.class})
  2850. public String changeSaler() throws YosException {
  2851. Long saler_hrid = content.getLong("saler_hrid");
  2852. Long sa_orderid = content.getLong("sa_orderid");
  2853. //通过版本更新订单表头数据
  2854. beans.order.Order.updateOrderWithVersion(this);
  2855. SQLFactory sqlFactory = new SQLFactory(this, "订单-修改业务员");
  2856. sqlFactory.addParameter("siteid", siteid);
  2857. sqlFactory.addParameter("userid", userid);
  2858. sqlFactory.addParameter("username", username);
  2859. sqlFactory.addParameter("saler_hrid", saler_hrid);
  2860. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2861. dbConnect.runSqlUpdate(sqlFactory.getSQL());
  2862. return selectDetail();
  2863. }
  2864. @API(title = "查询订单流水信息", apiversion = R.ID20230221193203.v1.class)
  2865. @CACHEING
  2866. public String getOrderCashbill() throws YosException {
  2867. Long sa_orderid = content.getLong("sa_orderid");
  2868. Rows rows = dbConnect.runSqlQuery("SELECT * from sa_cashbill WHERE ownertable = 'sa_order' and ownerid = " + sa_orderid + " and siteid = '" + siteid + "' ORDER BY createdate DESC");
  2869. return getSucReturnObject().setData(rows).toString();
  2870. }
  2871. @API(title = "查询核销记录", apiversion = R.ID20230225141804.v1.class)
  2872. @CACHEING
  2873. public String getWriteoffbill() throws YosException {
  2874. Long sa_orderid = content.getLong("sa_orderid");
  2875. SQLFactory sqlFactory = new SQLFactory(this, "订单核销记录", pageSize, pageNumber, pageSorting);
  2876. sqlFactory.addParameter("siteid", siteid);
  2877. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2878. Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  2879. return getSucReturnObject().setData(rows).toString();
  2880. }
  2881. @API(title = "查询erp对接记录", apiversion = R.ID20230225141904.v1.class)
  2882. @CACHEING
  2883. public String getErpupdatelog() throws YosException {
  2884. Long sa_orderid = content.getLong("sa_orderid");
  2885. SQLFactory sqlFactory = new SQLFactory(this, "订单erp对接记录", pageSize, pageNumber, pageSorting);
  2886. sqlFactory.addParameter("siteid", siteid);
  2887. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2888. Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  2889. return getSucReturnObject().setData(rows).toString();
  2890. }
  2891. @API(title = "查询变更记录", apiversion = R.ID20230225142004.v1.class)
  2892. @CACHEING
  2893. public String getChange() throws YosException {
  2894. Long sa_orderid = content.getLong("sa_orderid");
  2895. SQLFactory sqlFactory = new SQLFactory(this, "订单变更记录", pageSize, pageNumber, pageSorting);
  2896. sqlFactory.addParameter("siteid", siteid);
  2897. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2898. Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  2899. return getSucReturnObject().setData(rows).toString();
  2900. }
  2901. /**
  2902. * 获取订单提交SQL
  2903. *
  2904. * @param sa_orderid
  2905. * @return
  2906. * @throws YosException
  2907. */
  2908. public String getOrderSubmitSql(Long sa_orderid, String status, String freightstatus) throws YosException {
  2909. SQLFactory sqlFactory = new SQLFactory(this, "订单_提交");
  2910. sqlFactory.addParameter("siteid", siteid);
  2911. sqlFactory.addParameter("userid", userid);
  2912. sqlFactory.addParameter("username", username);
  2913. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2914. sqlFactory.addParameter("status", status);
  2915. sqlFactory.addParameter("freightstatus", freightstatus);
  2916. return sqlFactory.getSQL();
  2917. }
  2918. /**
  2919. * 获取订单审核SQL
  2920. *
  2921. * @param sa_orderid
  2922. * @return
  2923. * @throws YosException
  2924. */
  2925. public String getOrderCheckSql(Long sa_orderid, String reviewtype) throws YosException {
  2926. SQLFactory sqlFactory = new SQLFactory(this, "订单_审核");
  2927. sqlFactory.addParameter("siteid", siteid);
  2928. sqlFactory.addParameter("userid", userid);
  2929. sqlFactory.addParameter("username", username);
  2930. sqlFactory.addParameter("reviewtype", reviewtype);
  2931. sqlFactory.addParameter("sa_orderid", sa_orderid);
  2932. return sqlFactory.getSQL();
  2933. }
  2934. /**
  2935. * 创建凭证实体
  2936. *
  2937. * @param amount
  2938. * @param ownerid
  2939. * @param source
  2940. * @param sourcenotes
  2941. * @param remarks
  2942. * @return
  2943. * @throws YosException
  2944. */
  2945. public CashbillEntity getCashbillEntity(BigDecimal amount, Long ownerid, String source, String sourcenotes, String remarks) throws YosException {
  2946. CashbillEntity entity = new CashbillEntity();
  2947. entity.setAmount(amount);
  2948. entity.setOwnerid(ownerid);
  2949. entity.setOwnertable("sa_order");
  2950. entity.setSource(source);
  2951. entity.setRemarks(remarks);
  2952. entity.setSourcenote(sourcenotes);
  2953. return entity;
  2954. }
  2955. /**
  2956. * 更新返利代金券余额
  2957. *
  2958. * @param sa_cashbillid
  2959. * @param rebate_balance
  2960. * @return
  2961. * @throws YosException
  2962. */
  2963. public String updateCashbillSql(Long sa_cashbillid, BigDecimal rebate_balance) throws YosException {
  2964. SQLFactory sqlFactory = new SQLFactory(this, "更新返利代金券");
  2965. sqlFactory.addParameter("siteid", siteid);
  2966. sqlFactory.addParameter("userid", userid);
  2967. sqlFactory.addParameter("username", username);
  2968. sqlFactory.addParameter("rebate_balance", rebate_balance);
  2969. sqlFactory.addParameter("sa_cashbillid", sa_cashbillid);
  2970. return sqlFactory.getSQL();
  2971. }
  2972. /**
  2973. * 获取支付凭证信息
  2974. *
  2975. * @param sa_orderid
  2976. * @return
  2977. * @throws YosException
  2978. */
  2979. public Rows getCashbillRows(Long sa_orderid) throws YosException {
  2980. return dbConnect.runSqlQuery("SELECT sum(amount) amount from sa_cashbill WHERE ownerid ='" + sa_orderid + "' and ownertable='sa_order' and type = 0 and sa_cashbillid_rebate is null and siteid = '" + siteid + "' ");
  2981. }
  2982. public Rows getMultipleAccountsCashbillRows(Long sa_orderid) throws YosException {
  2983. return dbConnect.runSqlQuery("SELECT sa_accountclassid,sum(amount) amount from sa_cashbill WHERE ownerid ='" + sa_orderid + "' and ownertable='sa_order' and type = 0 and sa_cashbillid_rebate is null and siteid = '" + siteid + "' group by sa_accountclassid");
  2984. }
  2985. public Rows getCashbillRebateRows(Long sa_orderid) throws YosException {
  2986. return dbConnect.runSqlQuery("SELECT sum(amount) amount,sa_cashbillid_rebate from sa_cashbill WHERE ownerid ='" + sa_orderid + "' and ownertable='sa_order' and type = 0 and sa_cashbillid_rebate is not null and siteid = '" + siteid + "' GROUP BY sa_cashbillid_rebate");
  2987. }
  2988. public Long getSaleHrid(Long sys_enterpriseid) throws YosException {
  2989. Rows rows = dbConnect.runSqlQuery("SELECT t1.hrid FROM sa_salearea_hr t1 INNER JOIN sys_enterprise_tradefield t2 ON t1.sa_saleareaid=t2.sa_saleareaid AND t1.siteid=t2.siteid WHERE t2.sys_enterpriseid=" + sys_enterpriseid);
  2990. if (rows.isNotEmpty()) {
  2991. return rows.get(0).getLong("hrid");
  2992. }
  2993. return 0L;
  2994. }
  2995. @API(title = "订单ERP仓库选择", apiversion = R.ID20230228193201.v1.class)
  2996. public String selectErpStock() throws YosException {
  2997. long itemid = content.getLong("itemid");
  2998. double qty = content.getDoubleValue("qty");
  2999. Rows rows = dbConnect.runSqlQuery("select erpitemno from plm_itemextend where siteid='" + siteid + "' and itemid=" + itemid);
  3000. if (rows.isEmpty()) {
  3001. return getSucReturnObject().toString();
  3002. }
  3003. String erpitemno = rows.get(0).getString("erpitemno");
  3004. String oraclebase = "";
  3005. String sid = "";
  3006. if ("NB".equals(siteid)) {
  3007. sid = "IBPNB10";
  3008. oraclebase = "ORACLE_NB";
  3009. } else if ("TZ".equals(siteid)) {
  3010. sid = "IDCZJ10";
  3011. oraclebase = "ORACLE_TZ";
  3012. } else if ("HY".equals(siteid)) {
  3013. sid = "IBPJX10";
  3014. oraclebase = "ORACLE_HY";
  3015. }
  3016. DBConnect oracleConnect = new DBConnect(oraclebase);
  3017. Rows icrows = oracleConnect.runSqlQuery(
  3018. "select WAREHOUSE,QTY,LOCATION,LOT from v_eso_actual_inventory where FITEMNO = '" + erpitemno + "' and SITEID='" + sid + "' and QTY>=" + qty);
  3019. return getSucReturnObject().setData(icrows).toString();
  3020. }
  3021. @API(title = "订单手动关闭", apiversion = R.ID20230406155202.v1.class)
  3022. public String closeOrder() throws YosException {
  3023. Long sa_orderid = content.getLong("sa_orderid");
  3024. //通过版本更新订单表头数据
  3025. beans.order.Order.updateOrderWithVersion(this);
  3026. Rows orderRow = getOrderRows(this, sa_orderid);
  3027. if (orderRow.isEmpty()) {
  3028. return getErrReturnObject().setErrMsg("订单不存在").toString();
  3029. }
  3030. if (orderRow.get(0).getString("status").equals("手工关闭")) {
  3031. return getErrReturnObject().setErrMsg("订单已关闭,无法再次手工关闭").toString();
  3032. }
  3033. if (!orderRow.get(0).getString("status").equals("审核")) {
  3034. return getErrReturnObject().setErrMsg("非审核状态无法手工关闭").toString();
  3035. }
  3036. Long sys_enterpriseid = orderRow.get(0).getLong("sys_enterpriseid");
  3037. Long sa_accountclassid = orderRow.get(0).getLong("sa_accountclassid");
  3038. if (StringUtils.isBlank(orderRow.get(0).getString("sa_accountclassinfos"))) {
  3039. dbConnect.runSqlUpdate(updateAccountclassinfos(sa_orderid, sa_accountclassid, sys_enterpriseid));
  3040. orderRow = getOrderRows(this, sa_orderid);
  3041. }
  3042. if (dbConnect.runSqlQuery("SELECT 1 from sa_dispatch t1 left join sa_dispatch_items t2 on t1.sa_dispatchid=t2.sa_dispatchid and t1.siteid=t2.siteid left join sa_orderitems t3 on t2.sa_orderitemsid=t3.sa_orderitemsid and t2.siteid=t3.siteid WHERE t1.status not in ('关闭','手工关闭') and t1.siteid='" + siteid + "' and t3.sa_orderid=" + sa_orderid).isNotEmpty()) {
  3043. return getErrReturnObject().setErrMsg("存在未关闭的发货单,无法关闭").toString();
  3044. }
  3045. ArrayList<String> sqlList = new ArrayList<>();
  3046. sqlList.add("UPDATE sa_order SET STATUS='手工关闭',closedate=current_time,closeby='" + username + "' WHERE sa_orderid='" + sa_orderid + "' and siteid = '" + siteid + "'");
  3047. sqlList.add("UPDATE sa_orderitems SET isclose=1 WHERE sa_orderid='" + sa_orderid + "' and siteid = '" + siteid + "'");
  3048. String type = orderRow.get(0).getString("type");
  3049. if (type.equals("促销订单")) {
  3050. Rows orderdetails = dbConnect.runSqlQuery("select sa_promotion_itemsid,itemno,sum(undeliqty) qty from sa_orderitems where siteid='" + siteid + "' and sa_orderid=" + sa_orderid + " group by sa_promotion_itemsid,itemno");
  3051. Rows promotionitems = dbConnect.runSqlQuery("select * from sa_promotion_items where siteid='" + siteid + "' and sa_promotionid=" + orderRow.get(0).getLong("sa_promotionid"));
  3052. RowsMap promotionitemsRowsMap = promotionitems.toRowsMap("sa_promotion_itemsid");
  3053. for (Row orderdetail : orderdetails) {
  3054. String sa_promotion_itemsid = orderdetail.getString("sa_promotion_itemsid");
  3055. BigDecimal qty = orderdetail.getBigDecimal("qty");
  3056. if (promotionitemsRowsMap.containsKey(sa_promotion_itemsid)) {
  3057. if (promotionitemsRowsMap.get(sa_promotion_itemsid).isNotEmpty()) {
  3058. sqlList.add("update sa_promotion_items set saledqty=saledqty-" + qty + " where sa_promotion_itemsid=" + sa_promotion_itemsid);
  3059. }
  3060. }
  3061. }
  3062. }
  3063. // String type = orderRow.get(0).getString("type");
  3064. // if (type.equals("促销订单")) {
  3065. // Rows orderdetails = dbConnect.runSqlQuery("select itemid,itemno,sum(undeliqty) qty from sa_orderitems where siteid='" + siteid + "' and sa_orderid=" + sa_orderid + " group by itemid,itemno");
  3066. // Rows promotionitems = dbConnect.runSqlQuery("select * from sa_promotion_items where siteid='" + siteid + "' and sa_promotionid=" + orderRow.get(0).getLong("sa_promotionid"));
  3067. // RowsMap promotionitemsRowsMap = promotionitems.toRowsMap("itemid");
  3068. // for (Row orderdetail : orderdetails) {
  3069. // String itemid = orderdetail.getString("itemid");
  3070. // BigDecimal qty = orderdetail.getBigDecimal("qty");
  3071. // if (promotionitemsRowsMap.containsKey(itemid)) {
  3072. // if (promotionitemsRowsMap.get(itemid).isNotEmpty()) {
  3073. // sqlList.add("update sa_promotion_items set saledqty=saledqty-" + qty + " where sa_promotion_itemsid=" + promotionitemsRowsMap.get(itemid).get(0).getLong("sa_promotion_itemsid"));
  3074. // }
  3075. // }
  3076. // }
  3077. // }
  3078. Rows rows = dbConnect.runSqlQuery("SELECT cast(sum(undeliqty*price) as DECIMAL(16,2)) totalprice from sa_orderitems WHERE sa_orderid=" + sa_orderid + " and siteid = '" + siteid + "'");
  3079. ArrayList<Long> sa_cashbillidList = new ArrayList<>();
  3080. if (rows.isNotEmpty()) {
  3081. BigDecimal totalprice = rows.get(0).getBigDecimal("totalprice");
  3082. JSONArray sa_accountclassinfos = orderRow.get(0).getJSONArray("sa_accountclassinfos");
  3083. JSONObject orderaccountclassinfo = new JSONObject();
  3084. JSONObject promotionaccountclassinfo = new JSONObject();
  3085. for (Object object : sa_accountclassinfos) {
  3086. JSONObject jsonObject = (JSONObject) object;
  3087. if (jsonObject.getLong("sa_accountclassid") == sa_accountclassid) {
  3088. orderaccountclassinfo = jsonObject;
  3089. } else {
  3090. promotionaccountclassinfo = jsonObject;
  3091. }
  3092. }
  3093. Rows promotion_auth = dbConnect.runSqlQuery(" select * from sa_promotion_auth where siteid='" + siteid + "'and sys_enterpriseid=" + sys_enterpriseid + " and sa_promotionid=" + orderRow.get(0).getLong("sa_promotionid"));
  3094. long sa_promotion_authid = 0;
  3095. if (promotion_auth.isNotEmpty()) {
  3096. sa_promotion_authid = promotion_auth.get(0).getLong("sa_promotion_authid");
  3097. }
  3098. BigDecimal amount_orderaccount = orderaccountclassinfo.getBigDecimalValue("amount", 0);
  3099. if (amount_orderaccount.compareTo(totalprice) >= 0) {
  3100. System.out.println("1111");
  3101. CashbillEntity entity = new CashbillEntity();
  3102. entity.setAmount(totalprice.negate());
  3103. entity.setSource("订单手工关闭");
  3104. entity.setSourcenote(orderRow.get(0).getString("sonum"));
  3105. entity.setOwnerid(sa_orderid);
  3106. entity.setOwnertable("sa_order");
  3107. entity.setRemarks("由订单号" + orderRow.get(0).getString("sonum") + "手工关闭时生成");
  3108. entity.setType("普通费用");
  3109. entity.setTypemx("订单关闭退款");
  3110. JSONObject cashbillPay = Accountbalance.createCashbillPay2(this, sys_enterpriseid, orderaccountclassinfo.getLongValue("sa_accountclassid"), entity, true);
  3111. sqlList.addAll(cashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  3112. sa_cashbillidList.add(cashbillPay.getLong("sa_cashbillid"));
  3113. sqlList.add("update sa_promotion_auth set saledamount=saledamount-" + totalprice + " where sa_promotion_authid=" + sa_promotion_authid);
  3114. } else if (amount_orderaccount.compareTo(totalprice) < 0) {
  3115. System.out.println("222");
  3116. CashbillEntity entity = new CashbillEntity();
  3117. entity.setAmount(amount_orderaccount.negate());
  3118. entity.setSource("订单手工关闭");
  3119. entity.setSourcenote(orderRow.get(0).getString("sonum"));
  3120. entity.setOwnerid(sa_orderid);
  3121. entity.setOwnertable("sa_order");
  3122. entity.setRemarks("由" + orderRow.get(0).getString("sonum") + "订单手工关闭时自动产生");
  3123. entity.setType("普通费用");
  3124. entity.setTypemx("订单关闭退款");
  3125. JSONObject cashbillPay = Accountbalance.createCashbillPay2(this, sys_enterpriseid, orderaccountclassinfo.getLongValue("sa_accountclassid"), entity, true);
  3126. sqlList.addAll(cashbillPay.getJSONArray("sqlList").toJavaList(String.class));
  3127. sa_cashbillidList.add(cashbillPay.getLong("sa_cashbillid"));
  3128. sqlList.add("update sa_promotion_auth set saledamount=saledamount-" + amount_orderaccount + " where sa_promotion_authid=" + sa_promotion_authid);
  3129. CashbillEntity promotionentity = new CashbillEntity();
  3130. promotionentity.setAmount((totalprice.subtract(amount_orderaccount)).negate());
  3131. promotionentity.setSource("订单手工关闭");
  3132. promotionentity.setSourcenote(orderRow.get(0).getString("sonum"));
  3133. promotionentity.setOwnerid(sa_orderid);
  3134. promotionentity.setOwnertable("sa_order");
  3135. promotionentity.setRemarks("由" + orderRow.get(0).getString("sonum") + "订单手工关闭时自动产生");
  3136. promotionentity.setType("普通费用");
  3137. promotionentity.setTypemx("订单关闭退款");
  3138. JSONObject cashbillPay1 = Accountbalance.createCashbillPay2(this, sys_enterpriseid, promotionaccountclassinfo.getLongValue("sa_accountclassid"), promotionentity, true);
  3139. sqlList.addAll(cashbillPay1.getJSONArray("sqlList").toJavaList(String.class));
  3140. sa_cashbillidList.add(cashbillPay1.getLong("sa_cashbillid"));
  3141. }
  3142. }
  3143. sqlList.add(DataContrlLog.createLog(this, "sa_order", sa_orderid, "订单手动关闭", "订单手动关闭").getSQL());
  3144. dbConnect.runSqlUpdate(sqlList);
  3145. //是否自动返利结算
  3146. new OrderItemsHelper(this).executeAutoRebate(sa_orderid, sys_enterpriseid);
  3147. for (Long sa_cashbillid : sa_cashbillidList) {
  3148. Accountbalance.remindSend(this, sys_enterpriseid, sa_cashbillid);
  3149. }
  3150. return getSucReturnObject().toString();
  3151. }
  3152. @API(title = "获取当前账号的角色名", apiversion = R.ID20230524160003.v1.class)
  3153. public String getrolename() throws YosException {
  3154. Rows rows = dbConnect.runSqlQuery("select rolename from sys_userrole t1 inner join sys_role t2 on t1.roleid=t2.roleid and t1.siteid=t2.siteid where t1.siteid='" + siteid + "' and t1.userid=" + userid);
  3155. RowsMap rowsMap = rows.toRowsMap("rolename");
  3156. String rolename = "其他";
  3157. if (rowsMap.containsKey("电商部")) {
  3158. rolename = "电商";
  3159. } else if (rowsMap.containsKey("工程部")) {
  3160. rolename = "工程";
  3161. }
  3162. return getSucReturnObject().setData(rolename).toString();
  3163. }
  3164. /**
  3165. * 更新订单扣款信息
  3166. */
  3167. public ArrayList<String> updateAccountclassinfos(Long sa_orderid, long sa_accountclassid, long sys_enterpriseid) throws YosException {
  3168. Rows orderRows = getOrderRows(this, sa_orderid);
  3169. ArrayList<String> sqlList = new ArrayList<>();
  3170. JSONArray jsonArray = new JSONArray();
  3171. JSONObject jsonObject = new JSONObject();
  3172. BigDecimal orderamount = getAmount(this, sa_orderid);
  3173. Rows accountclassrows = dbConnect.runSqlQuery("select t1.*,ifnull(t2.balance,0) balance,ifnull(t2.creditquota,0) creditquota from sa_accountclass t1 left join sa_accountbalance t2 on t1.sa_accountclassid=t2.sa_accountclassid and t1.siteid=t2.siteid and t2.sys_enterpriseid=" + (sys_enterpriseid == 0 ? orderRows.get(0).getLong("pay_enterpriseid") : sys_enterpriseid) + " where isused=1 and t1.siteid='" + siteid + "' and t1.sa_accountclassid=" + (sa_accountclassid == 0 ? orderRows.get(0).getLong("sa_accountclassid") : sa_accountclassid));
  3174. if (accountclassrows.isEmpty()) {
  3175. return new ArrayList<>();
  3176. }
  3177. if (orderRows.isEmpty()) {
  3178. //全部优先账户扣款
  3179. jsonObject.put("amount", orderamount);
  3180. jsonObject.put("sa_accountclassid", accountclassrows.get(0).getLong("sa_accountclassid"));
  3181. jsonObject.put("accountname", accountclassrows.get(0).getString("accountname"));
  3182. jsonObject.put("balance", accountclassrows.get(0).getBigDecimal("balance"));
  3183. jsonObject.put("creditquota", accountclassrows.get(0).getBigDecimal("creditquota"));
  3184. jsonArray.add(jsonObject);
  3185. sqlList.add("update sa_order set sa_accountclassinfos='" + jsonArray + "' where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "'");
  3186. return sqlList;
  3187. }
  3188. String type = "";
  3189. Rows promotionrows = dbConnect.runSqlQuery("select * from sa_promotion where siteid='" + siteid + "' and sa_promotionid=" + orderRows.get(0).getLong("sa_promotionid"));
  3190. Rows promotionenterpriserows = dbConnect.runSqlQuery("select * from sa_promotion_auth where siteid='" + siteid + "'and sys_enterpriseid=" + (sys_enterpriseid == 0 ? orderRows.get(0).getLong("pay_enterpriseid") : sys_enterpriseid) + " and sa_promotionid=" + orderRows.get(0).getLong("sa_promotionid"));
  3191. if (promotionrows.isNotEmpty()) {
  3192. type = promotionrows.get(0).getString("type");
  3193. }
  3194. if (type.equals("返利促销")) {
  3195. BigDecimal associationamount = promotionrows.get(0).getBigDecimal("associationamount");
  3196. long associationaccountclassid = promotionrows.get(0).getLong("associationaccountclassid");
  3197. Rows associationaccountclassrows = dbConnect.runSqlQuery("select t1.*,ifnull(t2.balance,0) balance,ifnull(t2.creditquota,0) creditquota from sa_accountclass t1 left join sa_accountbalance t2 on t1.sa_accountclassid=t2.sa_accountclassid and t1.siteid=t2.siteid and t2.sys_enterpriseid=" + (sys_enterpriseid == 0 ? orderRows.get(0).getLong("pay_enterpriseid") : sys_enterpriseid) + " where isused=1 and t1.siteid='" + siteid + "' and t1.sa_accountclassid=" + associationaccountclassid);
  3198. if (promotionenterpriserows.isNotEmpty()) {
  3199. if (promotionenterpriserows.get(0).getBoolean("islimit")) {
  3200. BigDecimal limitamount = promotionenterpriserows.get(0).getBigDecimal("limitamount");
  3201. BigDecimal saledamount = promotionenterpriserows.get(0).getBigDecimal("saledamount");
  3202. if (orderamount.compareTo(limitamount.subtract(saledamount)) <= 0) {
  3203. //全部优先账户扣款
  3204. jsonObject.put("amount", orderamount);
  3205. jsonObject.put("sa_accountclassid", accountclassrows.get(0).getLong("sa_accountclassid"));
  3206. jsonObject.put("accountname", accountclassrows.get(0).getString("accountname"));
  3207. jsonObject.put("balance", accountclassrows.get(0).getBigDecimal("balance"));
  3208. jsonObject.put("creditquota", accountclassrows.get(0).getBigDecimal("creditquota"));
  3209. jsonArray.add(jsonObject);
  3210. } else if (orderamount.compareTo(limitamount.subtract(saledamount)) > 0) {
  3211. //全部优先账户扣款
  3212. jsonObject.put("amount", limitamount.subtract(saledamount));
  3213. jsonObject.put("sa_accountclassid", accountclassrows.get(0).getLong("sa_accountclassid"));
  3214. jsonObject.put("accountname", accountclassrows.get(0).getString("accountname"));
  3215. jsonObject.put("balance", accountclassrows.get(0).getBigDecimal("balance"));
  3216. jsonObject.put("creditquota", accountclassrows.get(0).getBigDecimal("creditquota"));
  3217. jsonArray.add(jsonObject);
  3218. JSONObject associationjsonObject = new JSONObject();
  3219. associationjsonObject.put("amount", orderamount.subtract((limitamount.subtract(saledamount))));
  3220. associationjsonObject.put("sa_accountclassid", associationaccountclassrows.get(0).getLong("sa_accountclassid"));
  3221. associationjsonObject.put("accountname", associationaccountclassrows.get(0).getString("accountname"));
  3222. associationjsonObject.put("balance", associationaccountclassrows.get(0).getBigDecimal("balance"));
  3223. associationjsonObject.put("creditquota", associationaccountclassrows.get(0).getBigDecimal("creditquota"));
  3224. jsonArray.add(associationjsonObject);
  3225. } else {
  3226. return sqlList;
  3227. }
  3228. }
  3229. } else {
  3230. //全部优先账户扣款
  3231. jsonObject.put("amount", orderamount);
  3232. jsonObject.put("sa_accountclassid", accountclassrows.get(0).getLong("sa_accountclassid"));
  3233. jsonObject.put("accountname", accountclassrows.get(0).getString("accountname"));
  3234. jsonObject.put("balance", accountclassrows.get(0).getBigDecimal("balance"));
  3235. jsonObject.put("creditquota", accountclassrows.get(0).getBigDecimal("creditquota"));
  3236. jsonArray.add(jsonObject);
  3237. }
  3238. } else {
  3239. //全部优先账户扣款
  3240. jsonObject.put("amount", orderamount);
  3241. jsonObject.put("sa_accountclassid", accountclassrows.get(0).getLong("sa_accountclassid"));
  3242. jsonObject.put("accountname", accountclassrows.get(0).getString("accountname"));
  3243. jsonObject.put("balance", accountclassrows.get(0).getBigDecimal("balance"));
  3244. jsonObject.put("creditquota", accountclassrows.get(0).getBigDecimal("creditquota"));
  3245. jsonArray.add(jsonObject);
  3246. }
  3247. sqlList.add("update sa_order set sa_accountclassinfos='" + jsonArray + "' where sa_orderid=" + sa_orderid + " and siteid='" + siteid + "'");
  3248. return sqlList;
  3249. }
  3250. /**
  3251. * 判断是否在同一个月
  3252. *
  3253. * @return false:不在同一个月内,true在同一个月内
  3254. */
  3255. public boolean isMonth(Date date1, Date date2) {
  3256. Calendar calendar1 = Calendar.getInstance();
  3257. calendar1.setTime(date1);
  3258. Calendar calendar2 = Calendar.getInstance();
  3259. calendar2.setTime(date2);
  3260. int year1 = calendar1.get(Calendar.YEAR);
  3261. int year2 = calendar2.get(Calendar.YEAR);
  3262. int month1 = calendar1.get(Calendar.MONTH);
  3263. int month2 = calendar2.get(Calendar.MONTH);
  3264. return calendar1.get(Calendar.YEAR) == calendar2.get(Calendar.YEAR) && calendar1.get(Calendar.MONTH) == calendar2.get(Calendar.MONTH);
  3265. }
  3266. // @API(title = "发货单手动关闭", apiversion = R.ID20230406155302.v1.class)
  3267. // @Deprecated
  3268. // public String closeDispatch() throws YosException {
  3269. //
  3270. // Long sa_dispatchid = content.getLongValue("sa_dispatchid");
  3271. //
  3272. // ArrayList<String> sqlList = new ArrayList<>();
  3273. // sqlList.add("UPDATE sa_dispatch SET STATUS='关闭' WHERE sa_dispatchid='" + sa_dispatchid + "' and siteid = '" + siteid + "'");
  3274. // Rows rows = dbConnect.runSqlQuery("SELECT qty,sa_orderitemsid FROM sa_dispatch_items WHERE sa_dispatchid='" + sa_dispatchid + "' and siteid = '" + siteid + "'");
  3275. // for (Row row : rows) {
  3276. // Long sa_orderitemsid = row.getLong("sa_orderitemsid");
  3277. // Long qty = row.getLong("qty");
  3278. // sqlList.add("UPDATE sa_orderitems SET undeliqty=qty-" + qty + " WHERE sa_orderitemsid='" + sa_orderitemsid + "' and siteid = '" + siteid + "'");
  3279. // }
  3280. // sqlList.add(DataContrlLog.createLog(this, "sa_dispatch", sa_dispatchid, "发货单手动关闭", "发货单手动关闭").getSQL());
  3281. //
  3282. // dbConnect.runSqlUpdate(sqlList);
  3283. //
  3284. //
  3285. // return getSucReturnObject().toString();
  3286. // }
  3287. }