Api.php 98 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669
  1. <?php defined('BASEPATH') OR exit('No direct script access allowed');
  2. class Api extends Start_Controller {
  3. public function __construct(){
  4. parent::__construct();
  5. $this->load->library('session');
  6. $this->load->_model('Model_api','api');
  7. $this->load->_model('Model_shop','shop');
  8. $this->load->_model('Model_fullorder','fullorder');
  9. $this->load->_model('Model_fullordertt','fullordertt');
  10. $this->load->_model('Model_fullorder_smt','fullorder_smt');
  11. $this->load->_model('Model_fullordersmt','fullordersmt');
  12. $this->load->_model('Model_country','country');
  13. $this->load->_model('Model_hl','hl');
  14. $this->load->_model('Model_is','is');
  15. $this->load->_model('Model_kdniao','kdniao');
  16. $this->load->_model('Model_typeclass','typeclass');
  17. $this->load->_model('Model_warehouse','warehouse');
  18. $this->load->_model('Model_fullorderexcel','fullorderexcel');
  19. $this->load->_model('Model_dhl','dhl');
  20. $this->load->_model('Model_usps','usps');
  21. $this->load->_model('Model_ups','ups');
  22. $this->load->_model('Model_dhltest','dhltest');
  23. $this->load->_model('Model_customer','customer');
  24. $this->load->_model('Model_express','express');
  25. $this->load->_model('Model_notice','notice');
  26. $this->load->_model('Model_emaildata','emaildata');
  27. $this->load->_model('Model_whlabel','whlabel');
  28. $this->load->_model('Model_productdescribe','productdescribe');
  29. $this->load->_model('Model_ljg','ljg');
  30. $this->load->_model('Model_commodityread','commodityread');
  31. $this->load->_model('Model_service','service');
  32. $this->load->_model('Model_fedex','fedex');
  33. $this->load->_model('Model_apismt','apismt');
  34. $this->load->_model('Model_cne','cne');
  35. $this->load->_model('Model_specialstock','specialstock');
  36. $this->load->_model('Model_whlabellabel','whlabellabel');
  37. $this->load->_model('Model_allocation','allocation');
  38. $this->load->_model('Model_yswaybill','yswaybill');
  39. $this->load->_model('Model_paypal','paypal');
  40. $this->load->_model('Model_17track','17track');
  41. $this->load->_model('Model_ck','ck');
  42. $this->load->_model('Model_weight','weight');
  43. $this->load->_model('Model_pay','pay');
  44. $this->load->_model('Model_setting','setting');
  45. $this->load->_model('Model_classid','classid');
  46. $this->load->_model('Model_apiyy','apiyy');
  47. $this->load->_model('Model_whlabel_fc','whlabel_fc');
  48. $this->load->_model('Model_shopsku','shopsku');
  49. $this->load->_model('Model_awlgx','awlgx');
  50. $this->load->_model('Model_apitt','apitt');
  51. $this->load->_model('Model_producttitle','producttitle');
  52. $this->load->_model('Model_afspaypal','afspaypal');
  53. $this->load->_model('Model_message','message');
  54. $this->load->_model("Model_zztmpdata",'zztmpdata');
  55. $this->load->_model("Model_logic_ding","logic_ding");
  56. $this->load->_model("Model_customsdeclaration","customsdeclaration");
  57. $this->load->_model("Model_zzjobs","zzjobs");
  58. }
  59. //定义方法的调用规则 获取URI第二段值
  60. public function _remap($arg,$arg_array)
  61. {
  62. if($arg == 'isorder')//添加
  63. {
  64. $this->_isorder();
  65. }
  66. else if($arg == 'tb')//同步独立站
  67. {
  68. $this->_tb();
  69. }
  70. else if($arg == 'waybill')//运单上传独立站
  71. {
  72. $this->_waybill($arg_array);
  73. }
  74. else if($arg == 'waybillemail')
  75. {
  76. $this->_waybillemail($arg_array);
  77. }
  78. else if($arg == 'waybillfs')
  79. {
  80. $this->_waybillfs($arg_array);
  81. }
  82. else if($arg == 'headgear')//传输头套信息
  83. {
  84. $this->_headgear($arg_array);
  85. }
  86. else if($arg == 'fsstate')
  87. {
  88. $this->_fsstate();
  89. }
  90. else if($arg == 'fswaybillemail')
  91. {
  92. $this->_fswaybillemail();
  93. }
  94. else if($arg == 'zz')
  95. {
  96. $this->_zz();
  97. }
  98. else if($arg == 'zzcs')
  99. {
  100. $this->_zzcs();
  101. }
  102. else if($arg == 'cangku')
  103. {
  104. $this->_cangku();
  105. }
  106. else if($arg == 'kc')
  107. {
  108. $this->_kc();
  109. }
  110. else if($arg == 'wlfs')
  111. {
  112. $this->_wlfs();
  113. }
  114. else if($arg == 'query')
  115. {
  116. $this->_query();
  117. }
  118. else if($arg == 'kcjc')
  119. {
  120. $this->_kcjc();
  121. }
  122. else if($arg == 'klarna')
  123. {
  124. $this->_klarna();
  125. }
  126. else if($arg == 'logistics')
  127. {
  128. $this->_logistics();
  129. }
  130. else if($arg == 'hqpaypal')
  131. {
  132. $this->_hqpaypal();
  133. }
  134. else if($arg == 'hqstripe')
  135. {
  136. $this->_hqstripe();
  137. }
  138. else if($arg == 'htmlstock')
  139. {
  140. $this->_htmlstock();
  141. }
  142. else if($arg == 'dhl')
  143. {
  144. $this->_dhl();
  145. }
  146. else if($arg == '17track')
  147. {
  148. $this->_17track();
  149. }
  150. else if($arg == 'zc17track')
  151. {
  152. $this->_zc17track();
  153. }
  154. }
  155. //通过地址直接获取独立站订单信息
  156. public function _isorder()
  157. {
  158. $sid = '';$sd = array();
  159. if(isset($_SESSION['api']))
  160. {
  161. $user = $this->user->get_api($_SESSION['api']);
  162. $user = explode('|',trim($user['shop'],'|'));
  163. foreach ($user as $value)
  164. {
  165. $sid .= " id = '$value' or";
  166. }
  167. $sid = " and (".rtrim($sid,'or').")";
  168. }
  169. $post = $this->input->post(NULL, TRUE);
  170. $api = $this->input->get('api',true);
  171. $dshop = $this->input->get('dshop',true);
  172. //@$gethl = $this->hl->get_hl();//获取即时汇率
  173. $gethl = array();
  174. /* 订单号加入键值-k */
  175. /**
  176. $dataorder = array();
  177. $fdata = $this->fullorder->find_all('dtime > "'.(time()-96*3600).'"','orderinfo');
  178. foreach ($fdata as $v)
  179. {
  180. $dataorder[$v['orderinfo']] = "";//获取到单号
  181. }
  182. **/
  183. /* 订单号加入键值-j */
  184. /* 匹配加入 */
  185. $dictionaries = $this->typeclass->find_all('spare!= "" and classid != 1 and classid != 2 and classid != 3 and classid != 4 and classid != 5 and classid != 11 and classid != 16 and classid != 17 and classid != 20 and classid != 21 and classid != 23 and classid != 24 and classid != 29 and classid != 30 and classid != 31 and classid != 32 and classid != 36');
  186. // and (classid=13 or classid=22 or classid=8 or classid=15 or classid=27 or classid=25 or classid=26 or classid=18 or classid=14 or classid=9 or classid=12 or classid=10 or classid=6 or classid=100 or classid=999)
  187. $dtc = array();
  188. foreach ($dictionaries as $v)
  189. {
  190. if(stripos($v['spare'],'|') !== false)//如果有多个值
  191. {
  192. $v['spare'] = explode('|',$v['spare']);
  193. foreach ($v['spare'] as $k=>$vs)
  194. {
  195. if(stripos($v['zh'],'|') !== false)
  196. {
  197. $vzh = explode('|',$v['zh']);
  198. $dtc[strtolower($vs)] = array('classid'=>$v['classid'],'zh'=>$vzh[$k],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$vs);
  199. }
  200. else
  201. {
  202. $dtc[strtolower($vs)] = array('classid'=>$v['classid'],'zh'=>$v['zh'],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$vs);
  203. }
  204. }
  205. }
  206. else
  207. {
  208. $dtc[strtolower($v['spare'])] = array('classid'=>$v['classid'],'zh'=>$v['zh'],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$v['spare']);
  209. }
  210. }
  211. $dictionaries2 = $this->typeclass->find_all();
  212. foreach ($dictionaries2 as $v)
  213. {
  214. $dtctitle[$v['id']] = $v['title'];
  215. }
  216. /* 匹配结束 */
  217. /* 价格加入 */
  218. /**
  219. $money = array();
  220. $productdescribe = $this->productdescribe->find_all('1=1','number,purchase,cost,salesprice,title');
  221. foreach ($productdescribe as $v)
  222. {
  223. $money[$v['number']] = array('purchase'=>$v['purchase'],'cost'=>$v['cost'],'salesprice'=>$v['salesprice'],'title'=>$v['title']);
  224. }
  225. **/
  226. /* 价格加入 */
  227. /* 匹配ID加入 */
  228. $int = array();
  229. $intdata = $this->typeclass->find_all('classid=14','id,spare');
  230. foreach ($intdata as $v)
  231. {
  232. $v['spare'] = explode('|',$v['spare']);
  233. $int[$v['id']] = $v['spare'][0];
  234. }
  235. /* 匹配ID结束 */
  236. /* 国家加入键值-k */
  237. $cuy = array();
  238. $cuydata = $this->country->find_all('1=1','lb,id');
  239. foreach ($cuydata as $v)
  240. {
  241. $cuy[$v['lb']] = $v['id'];//获取到国家ID
  242. }
  243. /* 国家加入键值-j */
  244. /* 币种加入键值-k */
  245. $typeclass = array();
  246. $tdata = $this->typeclass->find_all('classid=30','id,title');
  247. foreach ($tdata as $v)
  248. {
  249. $typeclass[$v['title']] = $v['id'];
  250. }
  251. /* 币种加入键值-j */
  252. /* 支付方式-k */
  253. $pay = array();
  254. $tdata = $this->typeclass->find_all('classid=4','id,spare');
  255. foreach ($tdata as $v)
  256. {
  257. $paytype = $this->pay->get_typeclass($v['id']);
  258. if(isset($paytype['estimaterate']))
  259. {
  260. $estimaterate = $paytype['estimaterate'];
  261. }
  262. else
  263. {
  264. $estimaterate = 0;
  265. }
  266. if(stripos($v['spare'],'|') !== false)//如果有多个值
  267. {
  268. $v['spare'] = explode('|',$v['spare']);
  269. foreach ($v['spare'] as $k=>$vs)
  270. {
  271. $pay[$vs] = array('id'=>$v['id'],'estimaterate'=>$estimaterate);
  272. }
  273. }
  274. else
  275. {
  276. $pay[$v['spare']] = array('id'=>$v['id'],'estimaterate'=>$estimaterate);
  277. }
  278. }
  279. $pay['stripeios'] = $pay['stripe_payments'];
  280. /* 支付方式-j */
  281. /* 新增SKU-k */
  282. $zjsku = array();
  283. $shopsku = $this->shopsku->find_all();
  284. foreach ($shopsku as $val)
  285. {
  286. $ss = explode(',',trim($val['shop'],','));
  287. foreach ($ss as $v)
  288. {
  289. if(isset($zjsku[$v]))
  290. {
  291. $zjsku[$v] .= ','.trim($val['sku'],',');
  292. }
  293. else
  294. {
  295. $zjsku[$v] = trim($val['sku'],',');
  296. }
  297. }
  298. }
  299. /* 新增SKU-j */
  300. $is = $this->is->find_all('1=1','*','number asc');//获取仓库平匹配表
  301. if(isset($post['is']) || (isset($api) && $api = '89757'))
  302. {
  303. $tb = 0;
  304. if($dshop)
  305. {
  306. $shop = $this->shop->find_all("id = '$dshop'");
  307. }
  308. else
  309. {
  310. $shop = $this->shop->find_all("( type = 269 or type = 2768) and tb = 1".$sid);//获取独立站信息
  311. }
  312. foreach ($shop as $value)
  313. {
  314. $value['tbtime'] = 0;
  315. if((time()-$value['tbtime']) < 600)
  316. {
  317. $tb = 1;//正在同步中
  318. break;
  319. }
  320. else
  321. {
  322. $this->shop->save(array('tbtime'=>time()),$value['id']);
  323. }
  324. $setting = $this->setting->get_settings();
  325. $this->db->trans_begin();
  326. $res = $this->api->get_hq($value['brandname'],$value['shopadmin'],$value);
  327. $sd[] = $res;
  328. $sjc = $setting['sctime'];//时间差 之前是3600 现在为0
  329. if($res)
  330. {
  331. foreach ($res as $v)
  332. {
  333. if(!isset($v['order_id']))
  334. {
  335. continue;
  336. }
  337. if($value['token'] == 'SU')
  338. {
  339. $time = $v['purchased_on']-7*3600-$sjc;//之前是+$sjc
  340. }
  341. else if($value['program'] == 'Shopify')
  342. {
  343. $time = $v['purchased_on'];
  344. }
  345. else
  346. {
  347. if($value['id'] == 1)
  348. {
  349. $time = strtotime($v['purchased_on'])-7*3600-$sjc;//-$sjc;//之前是+$sjc
  350. }
  351. else
  352. {
  353. $time = strtotime($v['purchased_on'])-7*3600-$sjc;//订单时间更为时间戳 //之前是+$sjc
  354. }
  355. }
  356. $num = $this->fullorder->find_count('gtime = "'.date('Ymd',$time).'" and shop = "'.$value['id'].'"');
  357. if($value['program'] == 'Shopify'){
  358. $order_id = $v['order_id'];
  359. }else{
  360. $order_id = $value['id'].$v['order_id'];
  361. }
  362. $tc = 0;
  363. if(isset($v['global_currency_code']))
  364. {
  365. $tc = isset($typeclass[$v['global_currency_code']])?$typeclass[$v['global_currency_code']]:0;
  366. }
  367. $dataorder = $this->fullorder->get_orderinfo($order_id);
  368. $hmdid = '';
  369. if($value['program'] == 'Shopify' && isset($dataorder['id']))
  370. {
  371. if($v['order_comment'] != $dataorder['clientremarks'])
  372. {
  373. $this->fullorder->save(array('clientremarks'=>$v['order_comment']),$dataorder['id']);
  374. }
  375. }
  376. if(!isset($dataorder['id']))
  377. //现在为所有订单都获取。!$ord && strcasecmp($v['isstatus'],'processing') == 0如果没有此订单并且订单状态为等待发货则继续
  378. {
  379. if(!isset($cuy[$v['country']]))
  380. {
  381. $cuy[$v['country']] = 1004;
  382. }
  383. $post = $this->api->get_data($value,$v,$gethl,$time,$cuy[$v['country']],$is,$num,$v['country'],$tc,$dtc,array(),$int,$dtctitle,$pay,$zjsku);
  384. $kn = explode('-',$post['paypal']);
  385. if($post['pay'] == 23 && $value['klarnaname'] != '' && $value['klarnapass'] != '')
  386. {
  387. $klarna = $this->_klarnadata($post['paypal'],$value['klarnaname'],$value['klarnapass']);
  388. if($klarna != '')
  389. {
  390. $post['klarnadata'] = $klarna;
  391. }
  392. }
  393. if($post['pay'] == 26 && $value['afterpayname'] != '' && $value['afterpaypass'] != '')
  394. {
  395. $afterpay = $this->_afterpay($post['paypal'],$value['afterpayname'],$value['afterpaypass']);
  396. if($afterpay != '')
  397. {
  398. $post['klarnadata'] = $afterpay;
  399. }
  400. }
  401. if($post['pay'] == 27 && $value['clearpayname'] != '' && $value['clearpaypass'] != '')
  402. {
  403. $clearpay = $this->_clearpay($post['paypal'],$value['clearpayname'],$value['clearpaypass']);
  404. if($clearpay != '')
  405. {
  406. $post['klarnadata'] = $clearpay;
  407. }
  408. }
  409. if($post['pay'] == '28' && $post['state'] != '207')
  410. {
  411. continue;
  412. }
  413. if($post['state'] == '217' || $post['state'] == '203')
  414. {
  415. continue;
  416. }
  417. /**
  418. else if($post['pay'] == 22 && $value['paypalname'] != '' && $value['paypalpass'] != '')
  419. {
  420. $paypal = $this->_paypaldata($post['paypal'],$value['paypalname'],$value['paypalpass']);
  421. if($paypal != '')
  422. {
  423. $post['klarnadata'] = $paypal;
  424. }
  425. }
  426. **/
  427. /** 启用自动分配仓库 **/
  428. $post['express'] = 0;
  429. $warehouse = $this->warehouse->find_all("fpzd = '1'",'*','fpsx desc');
  430. foreach ($warehouse as $v)
  431. {
  432. if($v['bdcountry'] != 0 && $v['bdcountry'] != $post['country'])
  433. {
  434. continue;
  435. }
  436. $yx = 'get_yx_'.$v['bdck'];
  437. $kczd = $this->ck->$yx($post['state'],$v,$post['shop'],$post['number'],$post['whlabel'],$post['fpdata']);
  438. if($kczd['t'] == 0)
  439. {
  440. $country = $this->country->read($post['country']);//获取国家中配置物流
  441. if($country['express'] != 0)
  442. {
  443. $post['express'] = $country['express'];
  444. }
  445. if($v['express'] != 0)//优先使用仓库指定物流,替换掉上面的国家配置物流
  446. {
  447. $post['express'] = $v['express'];
  448. }
  449. $post['type'] = $v['id'];
  450. $post['whlabel'] = $kczd['whlabel'];
  451. $post['fpdata'] = $kczd['fpdata'];
  452. if(stripos($kczd['whlabel'],$v['hz']) !== false)
  453. {
  454. break 1;
  455. }
  456. }
  457. }
  458. $qdw = $this->warehouse->read($post['type']);
  459. $fl = $this->ck->get_fl($qdw['hz'],$post['whlabel'],$post['fpdata']);
  460. $post['sfxh'] = $fl['sfxh'];
  461. $post['ckfl'] = $fl['ckfl'];
  462. $zipcode = substr($post['zipcode'],0,1);
  463. if($post['type'] == 5 && $zipcode > 4)
  464. {
  465. $post['express'] = 63;
  466. }
  467. if($post['express'] > 0)
  468. {
  469. $xze = $this->express->read($post['express']);
  470. $post['printtype'] = $xze['type'];
  471. }
  472. //自动写位置 开始
  473. $zclp = array();$pxsl = array();
  474. $slpx = explode('|',$post['slpx']);//排序
  475. //监听报错原因
  476. //解决礼物类没有slpx的数据
  477. if(!empty($post['slpx'])){
  478. foreach ($slpx as $k=>$v)
  479. {
  480. $v = explode('-',$v);
  481. if(!isset($v[1]))
  482. {
  483. $v[1] == 1;
  484. }
  485. for($i=$v[0];$i<$v[1];$i++)
  486. {
  487. $pxsl[$i] = $k;
  488. }
  489. }
  490. }
  491. $mc = $qdw['bdck'];$zdidjl = '';$zdwzjl = '';
  492. if($qdw['wz'] == 1)
  493. {
  494. $pm = explode(';',trim($post['shipremarks'],';'));
  495. foreach ($pm as $k=>$vv)
  496. {
  497. $vv = trim($vv,' ');
  498. $tmp_vv = str_replace("'","",$vv);
  499. $lp = $this->typeclass->find_all("zh = '$tmp_vv'");
  500. if(isset($lp[0]['classid']))
  501. {
  502. $zclp[] = $vv;
  503. unset($pm[$k]);
  504. }
  505. }
  506. $pm = array_values($pm);
  507. $w = explode('|',trim($post['whlabel'],'|'));
  508. foreach ($w as $k=>$val)
  509. {
  510. $hwm = '';
  511. if(stripos($val,$qdw['hz']) !== false)
  512. {
  513. $num = explode('-',trim($val,'-'));
  514. $xq = explode('~',trim($num[2],'~'));
  515. $pmxq = '(';
  516. foreach ($xq as $v)
  517. {
  518. $zdidjl .= '('.trim($v,$qdw['hz']).')';
  519. $h = $this->$mc->read(trim($v,$qdw['hz']));
  520. if($h['details'] != '')
  521. {
  522. $pmxq .= $qdw['title'].':'.$h['details'].(($h['cpid']>0)?'-'.$h['cpid']:'').',';
  523. }
  524. }
  525. $xrid = ($h['cpid']>0)?'-'.$h['cpid']:'';
  526. if(isset($pxsl[$k]))
  527. {
  528. if(stripos($pm[$pxsl[$k]],$qdw['title'].':'.$h['details'].$xrid) === false)
  529. {
  530. $pm[$pxsl[$k]] .= trim($pmxq,',').')';
  531. }
  532. }
  533. $zdwzjl .= $h['details'].(($h['cpid']>0)?'-'.$h['cpid']:'');
  534. }
  535. }
  536. if($zclp)
  537. {
  538. $zclp = ';'.implode(";",$zclp);
  539. }
  540. else
  541. {
  542. $zclp = '';
  543. }
  544. $post['shipremarks'] = implode(";",$pm).$zclp;
  545. $post['contents'] = $zdidjl.' - '.$zdwzjl;
  546. }
  547. //自动写位置 结束
  548. //条数及申报
  549. $ts = 0;
  550. $dtsbjz = 0;
  551. $zsbjz = 0;
  552. $w = explode('|',trim($post['whlabel'],'|'));
  553. foreach ($w as $k=>$val)
  554. {
  555. $num = explode('-',trim($val,'-'));
  556. //$ts += $num[1];
  557. //判断是否是礼物 礼物不计数
  558. $is_gift_str = substr($num[0], 0, 3);
  559. if($is_gift_str != '131'){
  560. $ts += $num[1];
  561. }
  562. }
  563. if($ts > 0 && $ts < 6 && $post['country'] == 192)
  564. {
  565. $dtsbjz = ($ts==3)?sprintf("%.2f",100/$ts):100/$ts;
  566. $zsbjz = sprintf("%.2f",$dtsbjz*$ts);
  567. }
  568. $post['ts'] = $ts;
  569. $post['dtsbjz'] = $dtsbjz;
  570. $post['zsbjz'] = $zsbjz;
  571. /** **/
  572. //合并重复项
  573. $hbcfw = explode('|',trim($post['whlabel'],'|'));
  574. $hbcff = explode(';',trim($post['fpdata'],';'));
  575. $c = 0;
  576. $hbw = array();
  577. $hbf = array();
  578. for($i=0;$i<count($hbcfw);$i++)
  579. {
  580. $w = explode('-',$hbcfw[$i]);
  581. $f = explode('|',$hbcff[$i]);
  582. $w2 = ($w[2]==0)?0:'';
  583. if(!isset($hbw[$w[0].$w2]))
  584. {
  585. $hbw[$w[0].$w2] = $hbcfw[$i];
  586. $hbf[$w[0].$w2] = $hbcff[$i];
  587. }
  588. else
  589. {
  590. $c++;
  591. $cw = explode('-',$hbw[$w[0].$w2]);
  592. $cf = explode('|',$hbf[$w[0].$w2]);
  593. if($cw[2] != 0 && $w[2] != 0)
  594. {
  595. $cf[2] += $f[2];
  596. $cf[9] .= '~'.$f[9];
  597. $hbf[$w[0].$w2] = implode("|",$cf);
  598. $cw[1] += $f[2];
  599. $cw[2] .= '~'.$f[9];
  600. $hbw[$w[0].$w2] = implode("-",$cw);
  601. }
  602. else if($cw[2] == 0 && $w[2] == 0)
  603. {
  604. $cf[2] += $f[2];
  605. $hbf[$w[0].$w2] = implode("|",$cf);
  606. $cw[1] += $f[2];
  607. $hbw[$w[0].$w2] = implode("-",$cw);
  608. }
  609. else
  610. {
  611. $hbw[] = $hbcfw[$i];
  612. $hbf[] = $hbcff[$i];
  613. }
  614. }
  615. }
  616. if($c > 0)
  617. {
  618. $post['fpdata'] = implode(";",$hbf).';';
  619. $post['whlabel'] = '|'.implode("|",$hbw).'|';
  620. }
  621. //合并重复项结束
  622. //非占单设置为禁止占单开始
  623. $hbw = explode('|',trim($post['whlabel'],'|'));
  624. $hbf = explode(';',trim($post['fpdata'],';'));
  625. foreach ($hbw as $k=>$val)
  626. {
  627. $w = explode('-',$val);
  628. $f = explode('|',$hbf[$k]);
  629. if(!isset($w[2]) || $w[2] == 0)
  630. {
  631. $w[2] = "DNOTO";
  632. $f[9] = "DNOTO";
  633. $hbf[$k] = implode("|",$f);
  634. $hbw[$k] = implode("-",$w);
  635. }
  636. }
  637. $post['fpdata'] = implode(";",$hbf).';';
  638. $post['whlabel'] = '|'.implode("|",$hbw).'|';
  639. //非占单设置为禁止占单结束
  640. //查询净重开始
  641. $post['jweight'] = $this->weight->get_weightcx($post['fpdata']);
  642. $post['zzl'] = ($post['jweight']+100)/1000;
  643. if($post['express'] == 2)
  644. {
  645. $post['zzl'] = intval(($post['jweight']+100)*0.035);
  646. }
  647. //查询净重结束
  648. $tjid = $this->fullorder->insert($post);
  649. if($post['email'] == '')
  650. {
  651. $post['email'] = $post['name'].'@qq.com';
  652. }
  653. $adrs = $this->customer->get_email($post['email'],$post['shop']);
  654. preg_match_all('/[0-9]/u',$post['phone'],$result);
  655. $numphone = join('',$result[0]);
  656. $hmdaddress1 = str_replace(array(' parkway',' drive',' street',' road',' avenue',' boulevard',' alley',' court',' place',' lane',' manor',' terrace',' trail',' view',' cove'),array(' pkwy',' dr',' st',' rd',' av',' blvd',' aly',' ct',' pl',' ln',' mnr',' ter',' trl',' vw',' cv'),strtolower($post['address']));
  657. $hmdaddress2 = str_replace(array(' pkwy',' dr',' st',' rd',' av',' blvd',' aly',' ct',' pl',' ln',' mnr',' ter',' trl',' vw',' cv'),array(' parkway',' drive',' street',' road',' avenue',' boulevard',' alley',' court',' place',' lane',' manor',' terrace',' trail',' view',' cove'),strtolower($post['address']));
  658. $hmdaddress3 = str_replace(array(' avenue',' ave',' av'),array(' ave',' avenue',' ave'),strtolower($post['address']));
  659. $hmdid = '';
  660. $customerb = $this->customer->find_all("type = 2 and (email = '".$post['email']."' or address = '".$post['address']."' or address = '".$hmdaddress1."' or address = '".$hmdaddress2."' or address = '".$hmdaddress3."' or numphone = '".$numphone."')",'*','id desc');
  661. $lkh = (isset($customerb[0]['id']))?2:1;//白名单1黑名单2
  662. if($lkh == 2)
  663. {
  664. $hmdid = $customerb[0]['id'].'-('.$post['email'].'|'.$post['address'].'|'.$numphone.')'.'('.$customerb[0]['email'].'|'.$customerb[0]['address'].$customerb[0]['numphone'].')';
  665. }
  666. if($adrs)
  667. {
  668. $pdlkh = 1;//这个是判断是否老客户
  669. $this->customer->save(array('time'=>$post['dtime'],'is_tb'=>0,'num'=>$adrs['num']+1,'money'=>$adrs['money']+$post['shouldmoney']),$adrs['id']);
  670. $khid = $adrs['id'];
  671. }
  672. else
  673. {
  674. $str = $post['phone'];
  675. preg_match_all('/[0-9]/u',$str,$result);
  676. $numphone = join('',$result[0]);
  677. $ct['shop'] = $post['shop'];
  678. $ct['source'] = 10;
  679. $ct['level'] = 5;
  680. $ct['country'] = $post['country'];
  681. $ct['time'] = $post['dtime'];
  682. $ct['num'] = 1;
  683. $ct['money'] = $post['shouldmoney'];
  684. $ct['zipcode'] = $post['zipcode'];
  685. $ct['name'] = $post['name'];
  686. $ct['phone'] = $post['phone'];
  687. $ct['numphone'] = $numphone;
  688. $ct['email'] = preg_replace('/( | | |\s)+/','',$post['email']);
  689. $ct['province'] = $post['province'];
  690. $ct['city'] = $post['city'];
  691. $ct['address'] = $post['address'];
  692. $ct['zhcx'] = $post['shop'].'-'.$ct['email'];
  693. $ct['is_tb'] = 0;
  694. $khid = $this->customer->insert($ct);
  695. $pdlkh = 0;
  696. }
  697. $this->_znxc($post,$order_id,$lkh,$pdlkh,$hmdid);
  698. /**
  699. if($post['shop'] == '1' || $post['shop'] == '2' || $post['shop'] == '6' || $post['shop'] == '5')
  700. {
  701. $this->_znxc($post,$order_id,$lkh);
  702. }
  703. else
  704. {
  705. $this->_znx($post,$order_id,$lkh);
  706. }
  707. **/
  708. }//else{}如果有此订单
  709. }
  710. }
  711. if ($this->db->trans_status() === FALSE)
  712. {
  713. $this->db->trans_commit();
  714. }
  715. else
  716. {
  717. $this->db->trans_commit();
  718. }
  719. usleep(50);//停留2秒
  720. }
  721. if($tb == 1)
  722. {
  723. echo json_encode(array('msg'=>'有店铺正在同步中,请5分钟后再试!','success'=>true));exit;
  724. }
  725. echo json_encode(array('msg'=>'OK!','success'=>true));exit;
  726. }
  727. }
  728. public function _tb()
  729. {
  730. $api = $this->input->get('api',true);
  731. if(isset($api) && $api = '89757')
  732. {
  733. $data = $this->fullorder->find_all('dlz < 1 and source != 1 and waybill != "" and dtime > "'.(time()-48*3600).'"');
  734. $dataorder = array();$datashop = array();$dataex = array();$datack = array();
  735. /* 店铺加入键值-j */
  736. $fshop = $this->shop->find_all('1=1');
  737. foreach ($fshop as $v)
  738. {
  739. $datashop[$v['id']] = $v;
  740. }
  741. /* 店铺加入键值-k */
  742. /* 快递加入键值-j */
  743. $fex = $this->express->find_all('1=1');
  744. foreach ($fex as $v)
  745. {
  746. $dataex[$v['id']] = $v;
  747. }
  748. /* 快递加入键值-k */
  749. /* 仓库加入键值-k */
  750. $fwh = $this->warehouse->find_all('1=1');
  751. foreach ($fwh as $v)
  752. {
  753. $datack[$v['id']] = $v;
  754. }
  755. /* 仓库加入键值-j */
  756. //$fs = $this->notice->get_ordertatus(216);//216成功状态
  757. foreach ($data as $v)
  758. {
  759. if($v['shop'] == 5){
  760. $ddh = $v['orderinfo'];
  761. }else{
  762. $ddh = substr($v['orderinfo'],1);
  763. }
  764. $ydh = $v['waybill'];
  765. $xg = $v;//此订单数据
  766. $shop = $datashop[$xg['shop']];//此订单店铺
  767. $ex = $dataex[$xg['express']];//此订单快递
  768. $warehouse = $datack[$xg['type']];//此订单仓库
  769. $shopifyid = $v['shopify'];
  770. if($xg['shop'] < 7)
  771. {
  772. $xg['iscode'] = $ex['title'];
  773. $xg['url'] = $shop['shopname'];
  774. @$fs = $this->api->get_paypal($xg);
  775. $this->afspaypal->insert(array('number'=>$xg['number'],'cs'=>$fs));
  776. }
  777. $ms = $this->message->find_all("express like '%,".$xg['express'].",%'");
  778. if(!isset($ms[0]))
  779. {
  780. $ms = $this->message->read(2);
  781. }
  782. else
  783. {
  784. $ms = $ms[0];
  785. }
  786. $shopname = $shop['brandname']; //店铺名
  787. $buyername = $xg['bname']; //Bill Name
  788. $email_call = $shop['shopid']; //发货人邮箱;
  789. $phone = $shop['shopphone']; //发货人电话
  790. $track_type = $ex['title']; //快递名称
  791. $service = $ex['title']; //快递追踪名称
  792. $track_link = $ex['url']; //快递查询网址
  793. $logistics_number = $ydh; //运单号
  794. $t= array('%buyername%','%email_call%','%track_type%','%service%','%track_link%','%logistics_number%','%shop%','%phone%','%jtime%');
  795. $h= array($buyername,$email_call,$track_type,$service,$track_link,$logistics_number,$shopname,$phone,$ex['yjtime']);
  796. $remark = str_replace($t,$h,$ms['content']);
  797. @$gx = $this->api->get_gx($ddh,$ydh,$xg,$shop,$ex,$remark,$shopifyid);
  798. if(!isset($gx['res']))
  799. {
  800. continue;
  801. }
  802. $this->fullorder->save(array('dlz'=>$gx['res'],'state'=>$gx['state']),$v['id']);
  803. }
  804. }
  805. }
  806. //更新独立站运单信息
  807. public function _waybill($arg_array)
  808. {
  809. $where = "dlz < '1' and state = '207' and shop != '19' and ";
  810. if(date("H",time()) == '8' && date("i",time()) > '20' && date("i",time()) < '39')//USPS-USA单,已出库——使用模板3 每天早上8点半 触发发送【昨天早上7点-今天早上7点】出库的
  811. {
  812. $where .= "(express = '2' or express = '63' or express = '64') and librarytime > '".strtotime(date("Y-m-d 7:00:0",strtotime("-1 day")))."' and librarytime < '".strtotime(date("Y-m-d 7:00:0",time()))."'";
  813. $readid = 3;
  814. }
  815. else if(date("H",time()) == '21' && date("w",time()) != '0')//二、杭州联邦+杭州联邦-不报关,单独用一个模板—新模板2 每天晚上9点半 触发发送 【昨天晚上9:30——今天晚上9:30】出库的
  816. {
  817. if(date("w",time()) == '1')//周一执行:周六晚上9点半——周一晚上9点半 之间出库的
  818. {
  819. $where .= "(express = '24' or express = '31') and librarytime > '".strtotime(date("Y-m-d 21:00:0",strtotime("-2 day")))."' and librarytime < '".strtotime(date("Y-m-d 21:00:0",time()))."'";
  820. }
  821. else //周二到周六: 前一天晚上9点半——当天晚上9点半之间出库的
  822. {
  823. $where .= "(express = '24' or express = '31') and librarytime > '".strtotime(date("Y-m-d 21:00:0",strtotime("-1 day")))."' and librarytime < '".strtotime(date("Y-m-d 21:00:0",time()))."'";
  824. }
  825. $readid = 2;
  826. }
  827. else if(date("H",time()) == '19' && date("w",time()) != '0')//其他快递-使用模板1 DHL官方、UPS、DPEX 等系统里打印运单自动有运单号的,出库后当天晚上7点执行。
  828. {
  829. if(date("w",time()) == '1')//周一执行:周六晚上9点半——周一晚上9点半 之间出库的
  830. {
  831. $where .= "express != '2' and express != '24' and express != '31' and printtype = '1' and waybill != '' and librarytime > '".strtotime(date("Y-m-d 19:00:0",strtotime("-2 day")))."' and librarytime < '".strtotime(date("Y-m-d 19:00:0",time()))."'";
  832. }
  833. else //周二到周六: 前一天晚上9点半——当天晚上9点半之间出库的
  834. {
  835. $where .= "express != '2' and express != '24' and express != '31' and printtype = '1' and waybill != '' and librarytime > '".strtotime(date("Y-m-d 19:00:0",strtotime("-1 day")))."' and librarytime < '".strtotime(date("Y-m-d 19:00:0",time()))."'";
  836. }
  837. $readid = 1;
  838. }
  839. else if(date("H",time()) == '20' && date("w",time()) != '0')//特殊快递 有运单 但是打印状态是发货单
  840. {
  841. if(date("w",time()) == '1')//周一执行:周六晚上9点半——周一晚上9点半 之间出库的
  842. {
  843. $where .= "express = '71' and printtype = '2' and waybill != '' and librarytime > '".strtotime(date("Y-m-d 20:00:0",strtotime("-2 day")))."' and librarytime < '".strtotime(date("Y-m-d 20:00:0",time()))."'";
  844. }
  845. else //周二到周六: 前一天晚上9点半——当天晚上9点半之间出库的
  846. {
  847. $where .= "express = '71' and printtype = '2' and waybill != '' and librarytime > '".strtotime(date("Y-m-d 20:00:0",strtotime("-1 day")))."' and librarytime < '".strtotime(date("Y-m-d 20:00:0",time()))."'";
  848. }
  849. $readid = 1;
  850. }
  851. else
  852. {
  853. exit;
  854. }
  855. $dataorder = array();$datashop = array();$dataex = array();$datack = array();
  856. // 订单加入键值-k
  857. $fdata = $this->fullorder->find_all($where);//,'source,id,orderinfo,waybill,shop,express,type,msg,bname,state,client,name,phone,zipcode,address,email,shopify'
  858. //* 订单加入键值-j
  859. //* 店铺加入键值-j
  860. $fshop = $this->shop->find_all('1=1');
  861. foreach ($fshop as $v)
  862. {
  863. $datashop[$v['id']] = $v;
  864. }
  865. //* 店铺加入键值-k
  866. //* 快递加入键值-j
  867. $fex = $this->express->find_all('1=1');
  868. foreach ($fex as $v)
  869. {
  870. $dataex[$v['id']] = $v;
  871. }
  872. //* 快递加入键值-k
  873. //* 仓库加入键值-k
  874. $fwh = $this->warehouse->find_all('1=1');
  875. foreach ($fwh as $v)
  876. {
  877. $datack[$v['id']] = $v;
  878. }
  879. //* 仓库加入键值-j
  880. $i = 0;$j = 0;$ed = array();
  881. foreach ($fdata as $key=>$value)
  882. {
  883. if($value['source'] == 1)
  884. {
  885. $this->fullorder->save(array('dlz'=>3,'state'=>216),$value['id']);
  886. }
  887. else
  888. {
  889. if($value['shop'] == 5){
  890. $ddh = $value['orderinfo'];
  891. }else{
  892. $ddh = substr($value['orderinfo'],1);
  893. }
  894. $ydh = $value['waybill'];
  895. $xg = $value;//此订单数据
  896. $shop = $datashop[$xg['shop']];//此订单店铺
  897. $ex = $dataex[$xg['express']];//此订单快递
  898. $warehouse = $datack[$xg['type']];//此订单仓库
  899. $shopifyid = $value['shopify'];
  900. if($xg['shop'] < 7)
  901. {
  902. $xg['iscode'] = $ex['title'];
  903. $xg['url'] = $shop['shopname'];
  904. @$fs = $this->api->get_paypal($xg);
  905. $this->afspaypal->insert(array('number'=>$xg['number'],'cs'=>$fs));
  906. }
  907. $ms = $this->message->find_all("express like '%,".$xg['express'].",%'");
  908. if(!isset($ms[0]))
  909. {
  910. $ms = $this->message->read(2);
  911. }
  912. else
  913. {
  914. $ms = $ms[0];
  915. }
  916. $shopname = $shop['brandname']; //店铺名
  917. $buyername = $xg['bname']; //Bill Name
  918. $email_call = $shop['shopid']; //发货人邮箱;
  919. $phone = $shop['shopphone']; //发货人电话
  920. $track_type = $ex['title']; //快递名称
  921. $service = $ex['title']; //快递追踪名称
  922. $track_link = $ex['url']; //快递查询网址
  923. $logistics_number = $ydh; //运单号
  924. $t= array('%buyername%','%email_call%','%track_type%','%service%','%track_link%','%logistics_number%','%shop%','%phone%','%jtime%');
  925. $h= array($buyername,$email_call,$track_type,$service,$track_link,$logistics_number,$shopname,$phone,$ex['yjtime']);
  926. $remark = str_replace($t,$h,$ms['content']);
  927. // $this->logic_ding->sendToDing("erp同步独立站的信息ddh".json_encode($ddh));
  928. // $this->logic_ding->sendToDing("erp同步独立站的信息ydh".json_encode($ydh));
  929. // $this->logic_ding->sendToDing("erp同步独立站的信息xg".json_encode($xg));
  930. // $this->logic_ding->sendToDing("erp同步独立站的信息shop".json_encode($shop));
  931. // $this->logic_ding->sendToDing("erp同步独立站的信息ex".json_encode($ex));
  932. // $this->logic_ding->sendToDing("erp同步独立站的信息remark".json_encode($remark));
  933. @$gx = $this->api->get_gx($ddh,$ydh,$xg,$shop,$ex,$remark,$shopifyid);
  934. //$this->logic_ding->sendToDing("erp同步独立站的信息".json_encode($gx));
  935. if(!isset($gx['res']))
  936. {
  937. continue;
  938. }
  939. $this->fullorder->save(array('dlz'=>$gx['res'],'state'=>$gx['state']),$value['id']);
  940. }
  941. //sleep(4);
  942. }
  943. //同步更新 淘宝的运单号
  944. $this->_taobao();
  945. $this->_kcjc();
  946. }
  947. public function _taobao()
  948. {
  949. $data = $this->fullorder->find_all("shop = 19 and dlz != '3' and state = '207' and librarytime > 0");
  950. foreach ($data as $k=>$v)
  951. {
  952. $this->fullorder->save(array('dlz'=>3,'state'=>216),$v['id']);
  953. }
  954. }
  955. public function _kcjc()
  956. {
  957. $gethl = $this->whlabel->find_all("zd != '' and state = '0'");
  958. $b = array();
  959. foreach ($gethl as $k=>$v)
  960. {
  961. $a = $this->fullorder->get_number($v['zd']);
  962. if($a['librarytime'] > 0 && $a['library'] == 2)
  963. {
  964. //$b[] = array($v['sku'],$v['zd']);
  965. $this->whlabel->save(array('state'=>1,'orderinfo'=>$a['orderinfo'],'waybill'=>$a['waybill'],'outk'=>$a['librarytime'],'time'=>$a['librarytime']),$v['id']);
  966. }
  967. }
  968. }
  969. public function _waybillemail($arg_array)
  970. {
  971. $urls = array();$sl = 0;$time = time();
  972. /**
  973. if(date("H",time()) == '8' && date("i",time()) > '20' && date("i",time()) < '39')//USPS-USA单
  974. {
  975. $wid = 1;
  976. }
  977. else if(date("H",time()) == '22' && date("w",time()) != '0' && date("i",time()) > '20' && date("i",time()) < '39')//二、杭州联邦+杭州联邦-不报关
  978. {
  979. if(date("w",time()) == '1')//周一执行:周六晚上9点半——周一晚上9点半 之间出库的
  980. {
  981. $wid = 2;
  982. }
  983. else //周二到周六: 前一天晚上9点半——当天晚上9点半之间出库的
  984. {
  985. $wid = 3;
  986. }
  987. }
  988. else if(date("H",time()) == '20' && date("w",time()) != '0' && date("i",time()) > '20' && date("i",time()) < '39')//其他快递
  989. {
  990. if(date("w",time()) != '1')
  991. {
  992. $wid = 4;
  993. }
  994. else
  995. {
  996. $wid = 5;
  997. }
  998. }
  999. **/
  1000. if(date("H",time()) == '8' && date("i",time()) > '20' && date("i",time()) < '39')//USPS-USA单
  1001. {
  1002. $wid = 1;
  1003. }
  1004. else if(date("H",time()) == '20' && date("i",time()) > '20' && date("i",time()) < '39')//其他快递
  1005. {
  1006. $wid = 2;
  1007. }
  1008. else if(date("H",time()) == '21' && date("i",time()) > '20' && date("i",time()) < '39')//其他快递
  1009. {
  1010. $wid = 3;
  1011. }
  1012. else
  1013. {
  1014. exit;
  1015. }
  1016. $notice = $this->notice->find_all("message = '1' and state = '1' and type = '4' and ktime < '$time' and jtime > '$time'");//已有自动发送,这个是物流发送
  1017. foreach ($notice as $key=>$var)
  1018. {
  1019. $urls[] = array('url'=>'http://1.wepolicy.cn/api/waybillfs?v='.$var['id'],'data'=>array('var'=>$var,'wid'=>$wid));
  1020. }
  1021. foreach($urls as $value) {
  1022. $ch = curl_init();
  1023. $url = $value['url'];
  1024. curl_setopt($ch,CURLOPT_URL,$url);
  1025. curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
  1026. curl_setopt($ch,CURLOPT_HEADER,0);
  1027. curl_setopt($ch,CURLOPT_POST, 1);
  1028. curl_setopt($ch,CURLOPT_TIMEOUT,1);
  1029. //设置post数据
  1030. $post = array();
  1031. $post['data'] = $value['data'];
  1032. curl_setopt($ch, CURLOPT_POSTFIELDS,http_build_query($post));
  1033. $res = curl_exec($ch);
  1034. curl_close($ch);
  1035. $sl++;
  1036. }
  1037. echo $sl;
  1038. echo "<pre>";
  1039. print_r($urls);
  1040. }
  1041. public function _waybillfs()
  1042. {
  1043. $post = $this->input->post(NULL, TRUE);
  1044. $data = $this->input->post('data',true);
  1045. if($data)
  1046. {
  1047. $notice = $data['var'];
  1048. $notice['email'] = $this->emaildata->read($notice['email']);
  1049. $wid = $data['wid'];
  1050. $fsjs = "";
  1051. if($wid == 1 && (stripos($notice['express'],',2,') !== false || stripos($notice['express'],',63,') !== false || stripos($notice['express'],',64,') !== false))
  1052. {
  1053. $js = explode(',',trim($notice['js'],','));
  1054. if(count($js) > 1)
  1055. {
  1056. $fsjs = " and (";
  1057. foreach ($js as $v)
  1058. {
  1059. $fsjs .= "js = '$v' or ";
  1060. }
  1061. $fsjs = trim($fsjs,' or ').")" ;
  1062. }
  1063. else if(count($js) == 1)
  1064. {
  1065. $fsjs = " and js = '$js[0]'";
  1066. }
  1067. $where = "(express = '2' or express = '63' or express = '64') and librarytime > '".strtotime(date("Y-m-d 8:30:0",strtotime("-6 day")))."' and librarytime < '".strtotime(date("Y-m-d 8:30:0",time()))."'".$fsjs;//3
  1068. }
  1069. /**
  1070. else if($wid == 2 && stripos($notice['express'],',1,') !== false)
  1071. {
  1072. $where = "(express = '24' or express = '31') and librarytime > '".strtotime(date("Y-m-d 22:00:0",strtotime("-6 day")))."' and librarytime < '".strtotime(date("Y-m-d 22:00:0",time()))."'";//4
  1073. }
  1074. else if($wid == 3 && stripos($notice['express'],',1,') !== false)
  1075. {
  1076. $where = "(express = '24' or express = '31') and librarytime > '".strtotime(date("Y-m-d 22:00:0",strtotime("-6 day")))."' and librarytime < '".strtotime(date("Y-m-d 22:00:0",time()))."'";//3
  1077. }
  1078. else if($wid == 4 && stripos($notice['express'],',1,') !== false)
  1079. {
  1080. $where = "express != '2' and express != '24' and express != '31' and printtype = '1' and waybill != '' and librarytime > '".strtotime(date("Y-m-d 20:00:0",strtotime("-6 day")))."' and librarytime < '".strtotime(date("Y-m-d 20:00:0",time()))."'";//3
  1081. }
  1082. else if($wid == 5 && stripos($notice['express'],',1,') !== false)
  1083. {
  1084. $where = "express != '2' and express != '24' and express != '31' and printtype = '1' and waybill != '' and librarytime > '".strtotime(date("Y-m-d 20:00:0",strtotime("-6 day")))."' and librarytime < '".strtotime(date("Y-m-d 20:00:0",time()))."'";//4
  1085. }
  1086. **/
  1087. else if($wid == 2 && stripos($notice['express'],',1,') !== false)
  1088. {
  1089. $where = "express != '2' and express != '63' and express != '64' and printtype = '1' and waybill != '' and librarytime > '".strtotime(date("Y-m-d 20:00:0",strtotime("-6 day")))."' and librarytime < '".strtotime(date("Y-m-d 20:00:0",time()))."'";//4
  1090. }
  1091. else if($wid == 3 && stripos($notice['express'],',1,') !== false)
  1092. {
  1093. $where = "express = '71' and printtype = '2' and waybill != '' and librarytime > '".strtotime(date("Y-m-d 20:00:0",strtotime("-6 day")))."' and librarytime < '".strtotime(date("Y-m-d 20:00:0",time()))."'";//4
  1094. }
  1095. else
  1096. {
  1097. exit;
  1098. }
  1099. $wlfs = array();
  1100. $dd = $this->fullorder->find_all("source != '1' and dlzemail < '1' and shop = '".$notice['shop']."' and library = 2 and ".$where);
  1101. //$this->logic_ding->sendToDing("获取发送快件的快递条件"."source != '1' and dlzemail < '1' and shop = '".$notice['shop']."' and library = 2 and ".$where);
  1102. foreach ($dd as $v)
  1103. {
  1104. $shop = $this->shop->read($v['shop']);
  1105. $express = $this->express->read($v['express']);
  1106. if(empty($v['send_email'])){
  1107. $fs = $this->notice->get_god($v,$shop,$express,$notice);
  1108. }else{
  1109. $email = $v['email'];
  1110. $v['email'] = $v['send_email'];
  1111. $fs = $this->notice->get_god($v,$shop,$express,$notice);
  1112. $v['email'] = $email;
  1113. }
  1114. $this->logic_ding->sendToDing($v['orderinfo']."监听邮件发送的异常:订单信息【".json_encode($v,JSON_UNESCAPED_UNICODE)."】获取快递信息【".json_encode($notice,JSON_UNESCAPED_UNICODE)."】返回的信息".json_encode($fs));
  1115. if($fs == 1)
  1116. {
  1117. $this->fullorder->save(array('dlzemail'=>1,'dlzemailtime'=>time()),$v['id']);
  1118. //给crm发送信息 先存储数据 后续定时任务执行
  1119. if($v['shop'] < 10){
  1120. $this->zztmpdata->insert([
  1121. 'type'=>2,
  1122. 'act_name'=>'crm_order',
  1123. 'content'=>json_encode($v),
  1124. 'create_time'=>time()
  1125. ]);
  1126. }
  1127. }
  1128. else
  1129. {
  1130. //$pdtime = date('Y-m-d',time());
  1131. //$folderPath = './data/dlzemail/'.$pdtime; // 文件夹路径
  1132. //$permissions = 0777; // 权限设置
  1133. //if (!file_exists($folderPath)) { mkdir($folderPath, $permissions); }//创建文件夹
  1134. //file_exists($folderPath);
  1135. if(!is_file("./data/dlzemail/".$v['number'].".txt"))
  1136. {
  1137. $myfile = fopen("./data/dlzemail/".$v['number'].".txt", "w") or die("Unable to open file!");
  1138. fwrite($myfile, json_encode($fs.';'.$v.';'.$shop.';'.$express.';'.$notice));
  1139. fclose($myfile);
  1140. }
  1141. else
  1142. {
  1143. $myfile = fopen("./data/dlzemail/".$v['number'].".txt", "a+") or die("Unable to open file!");
  1144. fwrite($myfile, json_encode($fs.';'.$v.';'.$shop.';'.$express.';'.$notice));
  1145. fclose($myfile);
  1146. }
  1147. $this->fullorder->save(array('dlzemail'=>2,'dlzemailtime'=>time()),$v['id']);
  1148. }
  1149. sleep(50);
  1150. }
  1151. }
  1152. }
  1153. /**
  1154. //更新独立站运单信息
  1155. public function _waybill($arg_array)
  1156. {
  1157. //这里订单索引需要修改 8点是出已打印已出库 11点是已打印未出库
  1158. if(!isset($arg_array[0]) || !isset($arg_array[1]))
  1159. {
  1160. exit;
  1161. }
  1162. if(date("w",time()) == '0' && $arg_array[0] != '3')//非usps周日不更新
  1163. {
  1164. echo 7;exit;
  1165. }
  1166. if($arg_array[0] == 3)
  1167. {
  1168. $argarray = 2;
  1169. $typec = ' and express = 2 and printtime > "'.strtotime("-3 day").'"';//更新usps-usa快递的订单
  1170. }
  1171. else
  1172. {
  1173. $argarray = $arg_array[0];
  1174. $typec = ' and librarytime > "'.strtotime(date("Y-m-d 16:30:0",strtotime("-5 day"))).'" and librarytime < "'.strtotime(date("Y-m-d 18:0:0",time())).'"';//更新快递的订单
  1175. }
  1176. $dataorder = array();$datashop = array();$dataex = array();$datack = array();
  1177. // 订单加入键值-k
  1178. $fdata = $this->fullorder->find_all('state = "207" and print = "3" and dlz < "1" and libraryconfirm = "2" and library = "'.$argarray.'" and waybill != ""'.$typec,'source,id,orderinfo,waybill,shop,express,type,msg,bname,state,client,name,phone,zipcode,address,email');
  1179. //* 订单加入键值-j
  1180. //* 店铺加入键值-j
  1181. $fshop = $this->shop->find_all('1=1');
  1182. foreach ($fshop as $v)
  1183. {
  1184. $datashop[$v['id']] = $v;
  1185. }
  1186. //* 店铺加入键值-k
  1187. //* 快递加入键值-j
  1188. $fex = $this->express->find_all('1=1');
  1189. foreach ($fex as $v)
  1190. {
  1191. $dataex[$v['id']] = $v;
  1192. }
  1193. //* 快递加入键值-k
  1194. //* 仓库加入键值-k
  1195. $fwh = $this->warehouse->find_all('1=1');
  1196. foreach ($fwh as $v)
  1197. {
  1198. $datack[$v['id']] = $v;
  1199. }
  1200. //* 仓库加入键值-j
  1201. //$fs = $this->notice->get_ordertatus(216);//216成功状态
  1202. $i = 0;$j = 0;$ed = array();
  1203. foreach ($fdata as $key=>$value)
  1204. {
  1205. if($value['source'] == 1)
  1206. {
  1207. $this->fullorder->save(array('dlz'=>3,'state'=>216),$value['id']);
  1208. }
  1209. else
  1210. {
  1211. $ddh = substr($value['orderinfo'],1);
  1212. $ydh = $value['waybill'];
  1213. $xg = $value;//此订单数据
  1214. $shop = $datashop[$xg['shop']];//此订单店铺
  1215. $ex = $dataex[$xg['express']];//此订单快递
  1216. $warehouse = $datack[$xg['type']];//此订单仓库
  1217. //独立站地址更新订单状态、物流信息
  1218. if($arg_array[0] == 1)//23点更新用留言2
  1219. {
  1220. $readid = 2;
  1221. }
  1222. else if($arg_array[0] == 3)//7点更新用留言3
  1223. {
  1224. $readid = 3;
  1225. }
  1226. else //20点更新用默认留言(默认留言为1)
  1227. {
  1228. $readid = $xg['msg'];
  1229. }
  1230. @$gx = $this->api->get_gx($ddh,$ydh,$xg,$shop,$ex,$readid);
  1231. if(!isset($gx['res']))
  1232. {
  1233. exit;
  1234. }
  1235. $this->fullorder->save(array('dlz'=>$gx['res'],'state'=>$gx['state']),$xg['id']);
  1236. }
  1237. //if($gx['res'] == 1 && $fs)
  1238. //{
  1239. // $ck = $this->_email($fs['content'],$xg,$warehouse['company']);
  1240. //}
  1241. sleep(2);//停留2秒
  1242. }
  1243. }
  1244. **/
  1245. public function _headgear($arg_array)
  1246. {
  1247. $ip = $this->input->ip_address();
  1248. if(!isset($arg_array[0]) || !isset($arg_array[1]))
  1249. {
  1250. exit;
  1251. }
  1252. if(!is_numeric($arg_array[0]) || !is_numeric($arg_array[1]))
  1253. {
  1254. exit;
  1255. }
  1256. $where = 'printtime > "'.strtotime(date('Y-m-d',$arg_array[0])).'" and print = 3 and library = 1 and (type = 4 or type = 13 or type = 11 or type = 12 or type = 16)';//(type = 4 or type = 7)
  1257. if($arg_array[1] == 1)
  1258. {
  1259. $data = $this->fullordersmt->find_all($where,'express,number,orderinfo,shipremarks,printtime');
  1260. }
  1261. else
  1262. {
  1263. $data = $this->fullorder->find_all($where,'express,number,orderinfo,shipremarks,printtime');
  1264. }
  1265. foreach ($data as $k=>$v)
  1266. {
  1267. $express = $this->express->read($v['express']);
  1268. $data[$k]['express'] = $express['servicename'];
  1269. if($data[$k]['printtime'] > 0)
  1270. {
  1271. $data[$k]['printtime'] = date('Y-m-d H:i:s',$v['printtime']);
  1272. }
  1273. }
  1274. //$state = $this->api->get_headgear($data);
  1275. echo json_encode($data);
  1276. }
  1277. public function _kc_old()
  1278. {
  1279. $post = $this->input->post(NULL, TRUE);
  1280. if(isset($post['sku']))
  1281. {
  1282. $sku = $this->input->post('sku',true);
  1283. $warehouse = $this->warehouse->find_all();
  1284. $data = array();
  1285. foreach ($sku as $val)
  1286. {
  1287. $datasku = array();
  1288. foreach ($warehouse as $v)
  1289. {
  1290. $z = $this->whlabel->find_count('sku = "'.$val.'" and zd = "" and state = 0 and warehouse = "'.$v['id'].'"');
  1291. $datasku[] = array('name'=>$v['title'],'number'=>$z);
  1292. }
  1293. $data[$val] = $datasku;
  1294. }
  1295. }
  1296. echo json_encode($data);
  1297. }
  1298. public function _kc()
  1299. {
  1300. $datasku = array();
  1301. $info_list = $this->whlabel->find_pc("warehouse = '5'",'sku,features,warehouse','sku');
  1302. foreach ($info_list as $val)
  1303. {
  1304. $z = $this->whlabel->find_count('sku = "'.$val['sku'].'" and zd = "" and state = 0 and warehouse = "5"');
  1305. $datasku[] = array('sku'=>$val['sku'],'number'=>$z);
  1306. }
  1307. echo json_encode($datasku);
  1308. }
  1309. public function _fsstate()//订单消息页手动发送
  1310. {
  1311. $post = $this->input->post(NULL, TRUE);
  1312. if(isset($post['s']))
  1313. {
  1314. $id_arr = $this->input->post('s');
  1315. $notice = $this->input->post('notice');
  1316. $noticeid = $this->input->post('noticeid');
  1317. $id_arr = explode(',',trim($id_arr,','));
  1318. if(!$id_arr)
  1319. {
  1320. echo json_encode(array('msg'=>'参数错误!','success'=>false));exit;
  1321. }
  1322. if($notice == '1' || $notice == '')
  1323. {
  1324. foreach ($id_arr as $v)
  1325. {
  1326. $data = $this->fullorder->read($v);
  1327. $adrs = $this->customer->get_email($data['email'],$data['shop']);
  1328. //$lkh = ($adrs['type'] == 1)?1:2;//白名单1黑名单2
  1329. $lkh = 1;
  1330. $pdlkh = ($adrs['num'] > 1)?1:0;//判断是否老客户
  1331. $fs = $this->_znxc($data,$data['orderinfo'],$lkh,$pdlkh);
  1332. if($fs == 1)
  1333. {
  1334. $this->fullorder->save(array('exstateerror'=>''),$data['id']);
  1335. }
  1336. sleep(40);
  1337. }
  1338. }
  1339. else
  1340. {
  1341. foreach ($id_arr as $v)
  1342. {
  1343. $data = $this->fullorder->read($v);
  1344. $fs = $this->_sdfs($data,$noticeid);
  1345. sleep(40);
  1346. }
  1347. }
  1348. echo json_encode(array('msg'=>'发送完成!','id'=>$id_arr,'success'=>true));exit;
  1349. }
  1350. }
  1351. public function _fswaybillemail()//运单号通知页手动发送
  1352. {
  1353. $post = $this->input->post(NULL, TRUE);
  1354. if(isset($post['s']))
  1355. {
  1356. $time = time();
  1357. $id_arr = $this->input->post('s');
  1358. $id_arr = explode(',',trim($id_arr,','));
  1359. if(!$id_arr)
  1360. {
  1361. echo json_encode(array('msg'=>'参数错误!','success'=>false));exit;
  1362. }
  1363. foreach ($id_arr as $v)
  1364. {
  1365. $d = $this->fullorder->read($v);
  1366. $shop = $this->shop->read($d['shop']);
  1367. $ex = $this->express->read($d['express']);
  1368. $fs = $this->notice->find_all("shop = '".$d['shop']."' and message = '1' and state = '1' and type = '4' and ktime < '$time' and jtime > '$time'");
  1369. $fs = $fs[0];
  1370. $fs['email'] = $this->emaildata->read($fs['email']);
  1371. if(empty($d['send_email'])){
  1372. $ck = $this->notice->get_god($d,$shop,$ex,$fs);
  1373. }else{
  1374. $email = $d['email'];
  1375. $d['email'] = $d['send_email'];
  1376. $ck = $this->notice->get_god($d,$shop,$ex,$fs);
  1377. $d['email'] = $email;
  1378. }
  1379. $this->logic_ding->sendToDing($d['orderinfo']."监听邮件发送的异常:订单信息【".json_encode($d,JSON_UNESCAPED_UNICODE)."】获取快递信息【".json_encode($fs,JSON_UNESCAPED_UNICODE)."】返回的信息".json_encode($ck));
  1380. if($ck == 1)
  1381. {
  1382. $this->fullorder->save(array('dlzemail'=>1,'dlzemailtime'=>time()),$v);
  1383. }
  1384. sleep(1);
  1385. }
  1386. echo json_encode(array('msg'=>'发送完成!请检查是否成功','id'=>$id_arr,'success'=>true));exit;
  1387. }
  1388. }
  1389. /**
  1390. public function _fsstate()//订单消息页手动发送 _znxc 针对模板对应类型发送
  1391. {
  1392. $post = $this->input->post(NULL, TRUE);
  1393. if(isset($post['s']))
  1394. {
  1395. $id_arr = $this->input->post('s');
  1396. $id_arr = explode(',',$id_arr);
  1397. if(!$id_arr)
  1398. {
  1399. echo json_encode(array('msg'=>'参数错误!','success'=>false));exit;
  1400. }
  1401. foreach ($id_arr as $v)
  1402. {
  1403. $data = $this->fullorder->read($v);
  1404. $adrs = $this->customer->get_email($data['email'],$data['shop']);
  1405. $lkh = ($adrs['type'] == 1)?1:2;//白名单1黑名单2
  1406. $fs = $this->_znxc($data,$data['orderinfo'],$lkh);
  1407. if($fs == 1)
  1408. {
  1409. $this->fullorder->save(array('exstateerror'=>''),$data['id']);
  1410. }
  1411. }
  1412. echo json_encode(array('msg'=>'发送完成!','id'=>$id_arr[0],'success'=>true));exit;
  1413. }
  1414. }
  1415. **/
  1416. public function _cangku()
  1417. {
  1418. $post = $this->input->post(NULL, TRUE);
  1419. if(isset($post['tk']))
  1420. {
  1421. $tk = $this->input->post('tk');
  1422. $tj = $this->input->post('tj');
  1423. $d = $this->fullorder->find_all("dtime > '$tk' and dtime < '$tj'");
  1424. $k = $this->customer->find_all("time > '$tk' and time < '$tj'");
  1425. echo json_encode(array('d'=>$d,'k'=>$k));exit;
  1426. }
  1427. }
  1428. public function _znxc($fullorder,$order_id,$lkh,$pdlkh,$hmdid='')
  1429. {
  1430. $time = time();
  1431. $sl = explode(';',$fullorder['quantity']);
  1432. $quantity = 0;
  1433. foreach ($sl as $v)
  1434. {
  1435. if($v > 1)
  1436. {
  1437. $quantity = 1;
  1438. }
  1439. }
  1440. $fid = $this->fullorder->get_orderinfo($order_id);
  1441. if($lkh == 2 || (count($sl) > 1 && $quantity == 1) || stripos($fullorder['address'],'PO ') !== false || stripos($fullorder['address'],'P.O.') !== false || stripos($fullorder['address'],'P. O.') !== false || stripos($fullorder['address'],'PO.') !== false || stripos($fullorder['address'],'P.O') !== false || stripos($fullorder['address'],' APO ') !== false)//如果是黑名单客户、多产品的、有用户留言的、包含PO BOX、包含APO //留言的正常发$fullorder['clientremarks'] != '' ||
  1442. {
  1443. $asdasd = 0;
  1444. if($lkh == 2)
  1445. {
  1446. $asdasd = 1;
  1447. }
  1448. if(count($sl) > 1 && $quantity == 1)
  1449. {
  1450. $asdasd = 2;
  1451. }
  1452. if(stripos($fullorder['address'],'PO ') !== false || stripos($fullorder['address'],'P.O.') !== false || stripos($fullorder['address'],'P. O.') !== false || stripos($fullorder['address'],'PO.') !== false || stripos($fullorder['address'],'P.O') !== false || stripos($fullorder['address'],' APO ') !== false)
  1453. {
  1454. $asdasd = 3;
  1455. }
  1456. $this->fullorder->save(array('content'=>$fid['content'].'黑名单客户、多产品的、包含PO BOX、包含APO的不发送-'.$asdasd.(($hmdid)?'['.$hmdid.']':''),'zdstate'=>$fid['zdstate'].'1-x|'),$fid['id']);//留言的现在正常发
  1457. return 'a';
  1458. }
  1459. else
  1460. {
  1461. if(count($sl) == '1' && $fullorder['quantity'] > 1)//如果item(产品)是1,但quantity大于等于2
  1462. {
  1463. $tab = 2;
  1464. }
  1465. else if($fullorder['shouldmoney'] > '400' && $fullorder['guarantee'] == 'Ineligible')//如果金额大于400美元并且无卖家保障
  1466. {
  1467. $tab = 1;
  1468. }
  1469. /**
  1470. else if(count($sl) == '1' && $fullorder['quantity'] > 1 && $fullorder['baddress'] != $fullorder['saddress'])//如果item(产品)是1,但quantity大于等于2并且Bill Address不等于Ship Address
  1471. {
  1472. $tab = 4;
  1473. }
  1474. else if($fullorder['baddress'] != $fullorder['saddress'])//如果Bill Address不等于Ship Address
  1475. {
  1476. $tab = 3;
  1477. }
  1478. **/
  1479. else//常规模板
  1480. {
  1481. $tab = 0;
  1482. }
  1483. $notice = $this->notice->find_all("shop = '".$fullorder['shop']."' and ordertatus = '".$fullorder['state']."' and tab = '$tab' and message = '1' and state = '1' and ktime < '$time' and jtime > '$time'");//有条件不同模板匹配
  1484. if(isset($notice[0]['content']))
  1485. {
  1486. if($pdlkh == '1' && $notice[0]['thq'] != ''&& $notice[0]['thh'] != '')//非常规和老客户模板,如果是老客户并且需要替换的话
  1487. {
  1488. $notice[0]['content'] = str_replace($notice[0]['thq'],$notice[0]['thh'],$notice[0]['content']);
  1489. }
  1490. $shop = $this->shop->read($fullorder['shop']);
  1491. //$express = $this->express->read($fullorder['express']);
  1492. //$service = $this->service->read($express['service']);
  1493. $country = $this->country->read($fullorder['country']);
  1494. $fullorder['country'] = $country['ename'];
  1495. //$express['servicename'] =$service['title'];//增加快递名称
  1496. $express = array();
  1497. $notice[0]['email'] = $this->emaildata->read($notice[0]['email']);
  1498. if(empty($fullorder['send_email'])){
  1499. $go = $this->notice->get_god($fullorder,$shop,$express,$notice[0]);
  1500. }else{
  1501. $email = $fullorder['email'];
  1502. $fullorder['email'] = $fullorder['send_email'];
  1503. $go = $this->notice->get_god($fullorder,$shop,$express,$notice[0]);
  1504. $fullorder['email'] = $email;
  1505. }
  1506. $this->logic_ding->sendToDing($fullorder['orderinfo']."监听邮件发送的异常:订单信息【".json_encode($fullorder,JSON_UNESCAPED_UNICODE)."】获取快递信息【".json_encode($notice[0],JSON_UNESCAPED_UNICODE)."】返回的信息".json_encode($go));
  1507. if($go == 1)
  1508. {
  1509. $this->fullorder->save(array('content'=>$fid['content'].'自动发送-成功;','zdstate'=>$fid['zdstate'].$notice[0]['type'].'-'.$notice[0]['tab'].'|','exstateerror'=>''),$fid['id']);
  1510. return 1;
  1511. }
  1512. else
  1513. {
  1514. $this->fullorder->save(array('exstateerror'=>'自动发送失败1:'.date('Y-m-d H',time()).'-'.$go.'('.$notice[0]['type'].'-'.$notice[0]['message'].')'),$fid['id']);
  1515. }
  1516. }
  1517. else
  1518. {
  1519. $this->fullorder->save(array('exstateerror'=>'当前订单状态无匹配模板'),$fid['id']);
  1520. }
  1521. }
  1522. }
  1523. public function _sdfs($fullorder,$id)//手动发送信息
  1524. {
  1525. $time = time();
  1526. $notice = $this->notice->read($id);//无条件同模板匹配
  1527. $notice['email'] = $this->emaildata->read($notice['email']);
  1528. $shop = $this->shop->read($fullorder['shop']);
  1529. $express = $this->express->read($fullorder['express']);
  1530. if($notice['type'] == '1')
  1531. {
  1532. $fslx = 'tab';
  1533. $content = '自动发送';
  1534. $stripos = '1-';
  1535. }
  1536. else if ($notice['type'] == '2')
  1537. {
  1538. $fslx = 'logisticstatus';
  1539. $content = $notice['title'];
  1540. $stripos = $notice['type'].'-'.$notice[$fslx].'|';
  1541. }
  1542. if(stripos($fullorder['zdstate'],$stripos) === false && $fullorder['wltype'] == '0')//如果没发送过并且允许发送
  1543. {
  1544. if(empty($fullorder['send_email'])){
  1545. $go = $this->notice->get_god($fullorder,$shop,$express,$notice);
  1546. }else{
  1547. $email = $fullorder['email'];
  1548. $fullorder['email'] = $fullorder['send_email'];
  1549. $go = $this->notice->get_god($fullorder,$shop,$express,$notice);
  1550. $fullorder['email'] = $email;
  1551. }
  1552. $this->logic_ding->sendToDing($fullorder['orderinfo']."监听邮件发送的异常:订单信息【".json_encode($fullorder,JSON_UNESCAPED_UNICODE)."】获取快递信息【".json_encode($notice,JSON_UNESCAPED_UNICODE)."】返回的信息".json_encode($go));
  1553. if($go == 1)
  1554. {
  1555. if($notice['type'] == '1')
  1556. {
  1557. $this->fullorder->save(array('content'=>$fullorder['content'].$content.'-成功;','zdstate'=>$fullorder['zdstate'].$notice['type'].'-'.$notice[$fslx].'|','exstateerror'=>'','wlerror'=>''),$fullorder['id']);
  1558. }
  1559. else if ($notice['type'] == '2')
  1560. {
  1561. $this->fullorder->save(array('wlcontent'=>$fullorder['wlcontent'].$content.'-成功;','wlfstime'=>time(),'zdstate'=>$fullorder['zdstate'].$notice['type'].'-'.$notice[$fslx].'|','exstateerror'=>'','wlerror'=>''),$fullorder['id']);
  1562. }
  1563. return 1;
  1564. }
  1565. else
  1566. {
  1567. if($notice['type'] == '1')
  1568. {
  1569. $this->fullorder->save(array('exstateerror'=>$content.'发送失败1:'.date('Y-m-d H',time()).'-'.$go.'('.$notice['type'].'-'.$notice[$fslx].')'),$fullorder['id']);
  1570. }
  1571. else if ($notice['type'] == '2')
  1572. {
  1573. $this->fullorder->save(array('wlerror'=>$content.'发送失败2:'.date('Y-m-d H',time()).'-'.$go.'('.$notice['type'].'-'.$notice[$fslx].')'),$fullorder['id']);
  1574. }
  1575. }
  1576. }
  1577. }
  1578. public function _zz()
  1579. {
  1580. //$f = $this->fullorder->find_all("1=1",'wlfstime','wlfstime desc',0,2);
  1581. if(date("w") == '0')
  1582. {
  1583. exit;
  1584. }
  1585. $f17 = array();
  1586. $time = time();
  1587. $tjlike = array();
  1588. $urls = array();$sl = 0;
  1589. $notice = $this->notice->find_all("message = '1' and state = '1' and type = '2' and ktime < '$time' and jtime > '$time'");//已有自动发送,这个是物流发送
  1590. foreach ($notice as $key=>$var)
  1591. {
  1592. $urls[] = array('url'=>'http://a'.rand(10,50).'.wepolicy.cn/api/wlfs?v='.$var['id'],'data'=>array('where'=>array('shop'=>$var['shop'],'expressstate'=>$var['logisticstatus'],'wlcontent'=>$var['title']),'var'=>$var));
  1593. }
  1594. foreach($urls as $value) {
  1595. $tjlike[] = $value['url'];
  1596. $ch = curl_init();
  1597. $url = $value['url'];
  1598. curl_setopt($ch,CURLOPT_URL,$url);
  1599. curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
  1600. curl_setopt($ch,CURLOPT_HEADER,0);
  1601. curl_setopt($ch,CURLOPT_POST, 1);
  1602. curl_setopt($ch,CURLOPT_TIMEOUT,5);
  1603. //设置post数据
  1604. $post = array();
  1605. $post['data'] = $value['data'];
  1606. curl_setopt($ch, CURLOPT_POSTFIELDS,http_build_query($post));
  1607. $res = curl_exec($ch);
  1608. curl_close($ch);
  1609. $sl++;
  1610. }
  1611. echo "<pre>";
  1612. print_r($tjlike);
  1613. echo $sl;
  1614. /**
  1615. $urls = array();
  1616. $notice = $this->notice->find_all("message = '1' and state = '1' and type = '2' and ktime < '$time' and jtime > '$time'");//已有自动发送,这个是物流发送
  1617. foreach ($notice as $key=>$var)
  1618. {
  1619. $urls[] = array('url'=>'http://1.wepolicy.cn/api/wlfs?v='.$var['id'],'data'=>array('where'=>array('shop'=>$var['shop'],'expressstate'=>$var['logisticstatus'],'wlcontent'=>$var['title']),'var'=>$var));
  1620. }
  1621. $mh = curl_multi_init();
  1622. $urlHandlers = array();
  1623. $urlData = array();
  1624. // 初始化多个请求句柄为一个
  1625. foreach($urls as $value) {
  1626. $ch = curl_init();
  1627. $url = $value['url'];
  1628. $url .= strpos($url, '?') ? '&' : '?';
  1629. curl_setopt($ch, CURLOPT_URL, $url);
  1630. // 设置数据通过字符串返回,而不是直接输出
  1631. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  1632. curl_setopt($ch,CURLOPT_HEADER,0);
  1633. curl_setopt($ch,CURLOPT_POST, 1);
  1634. $post = array();
  1635. $post['data'] = $value['data'];
  1636. curl_setopt($ch,CURLOPT_POSTFIELDS,http_build_query($post));
  1637. $urlHandlers[] = $ch;
  1638. curl_multi_add_handle($mh, $ch);
  1639. }
  1640. $active = null;
  1641. // 检测操作的初始状态是否OK,CURLM_CALL_MULTI_PERFORM为常量值-1
  1642. do {
  1643. // 返回的$active是活跃连接的数量,$mrc是返回值,正常为0,异常为-1
  1644. $mrc = curl_multi_exec($mh, $active);
  1645. } while ($mrc == CURLM_CALL_MULTI_PERFORM);
  1646. // 如果还有活动的请求,同时操作状态OK,CURLM_OK为常量值0
  1647. while ($active && $mrc == CURLM_OK) {
  1648. // 持续查询状态并不利于处理任务,每60ms检查一次,此时释放CPU,降低机器负载
  1649. usleep(50000);
  1650. // 如果批处理句柄OK,重复检查操作状态直至OK。select返回值异常时为-1,正常为1(因为只有1个批处理句柄)
  1651. if (curl_multi_select($mh) != -1) {
  1652. do {
  1653. $mrc = curl_multi_exec($mh, $active);
  1654. } while ($mrc == CURLM_CALL_MULTI_PERFORM);
  1655. }
  1656. }
  1657. // 获取返回结果
  1658. foreach($urlHandlers as $index => $ch) {
  1659. $urlData[$index] = curl_multi_getcontent($ch);
  1660. // 移除单个curl句柄
  1661. curl_multi_remove_handle($mh, $ch);
  1662. }
  1663. curl_multi_close($mh);
  1664. print_r($urlData);
  1665. **/
  1666. /**
  1667. $notice = $this->notice->find_all("message = '1' and state = '1' and type = '2' and ktime < '$time' and jtime > '$time'");//已有自动发送,这个是物流发送
  1668. foreach ($notice as $key=>$var)
  1669. {
  1670. $where = "shop = '".$var['shop']."' and waybill != '' and library = '2' and expressstate <= '".$var['logisticstatus']."' and librarytime > '".(time()-15*24*3600)."' and wlcontent not like '%".$var['title']."%'";//正式发送的时候开启这个"'
  1671. //$where = "shop = '2' and waybill != '' and library = '2' and librarytime > '".(time()-15*24*3600)."'";
  1672. $ch = curl_init();
  1673. curl_setopt($ch,CURLOPT_URL,'http://'.$_SERVER['HTTP_HOST'].'/api/wlfs?v='.$var['id']);
  1674. curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
  1675. curl_setopt($ch,CURLOPT_HEADER,0);
  1676. curl_setopt($ch,CURLOPT_POST, 1);
  1677. curl_setopt($ch,CURLOPT_TIMEOUT,1);
  1678. //设置post数据
  1679. $post = array();
  1680. $post['data'] = array('where'=>$where,'var'=>$var);
  1681. curl_setopt($ch, CURLOPT_POSTFIELDS,http_build_query($post));
  1682. $res = curl_exec($ch);
  1683. curl_close($ch);
  1684. //$this->_wlfs($where,$var);
  1685. }
  1686. **/
  1687. /**
  1688. $var = $this->notice->read(63);//已有自动发送,这个是物流发送
  1689. $where = "shop = '".$var['shop']."' and waybill != '' and library = '2' and expressstate <= '".$var['logisticstatus']."' and librarytime > '".(time()-15*24*3600)."' and wlcontent not like '%".$var['title']."%'";//正式发送的时候开启这个"'
  1690. $this->_wlfs($where,$var);
  1691. **/
  1692. }
  1693. public function _wlfs()
  1694. {
  1695. $webhookregister = 0;
  1696. $post = $this->input->post(NULL, TRUE);
  1697. $data = $this->input->post('data',true);
  1698. $where = $data['where'];
  1699. $var = $data['var'];
  1700. $wlfs = array();
  1701. $shopid = $where['shop'];
  1702. @$this->allocation->insert(array('title'=>date('Y-m-d',time()).'-'.$shopid));
  1703. $where = "shop = '".$where['shop']."' and waybill != '' and library = '2' and expressstate <= '".$where['expressstate']."' and librarytime > '".(time()-22*24*3600)."' and wlcontent not like '%".$where['wlcontent']."%'";//正式发送的时候开启这个"'
  1704. //$where = "shop = '".$where['shop']."' and waybill != '' and library = '2' and express = '3' and librarytime > '1636300800' and wlcontent not like '%".$where['wlcontent']."%'";//正式发送的时候开启这个"'
  1705. $this->logic_ding->sendToDing("wlfs执行信息".json_encode($data,JSON_UNESCAPED_UNICODE));
  1706. $data = $this->fullorder->find_all($where);
  1707. $csck = array();
  1708. foreach ($data as $k=>$v)
  1709. {
  1710. //$this->logic_ding->sendToDing("获取订单的物流信息".$v['number']);
  1711. $vexpress = $v['express'];
  1712. $shop = $this->shop->read($v['shop']);
  1713. $express = $this->express->read($v['express']);
  1714. $service = $this->service->read($express['service']);
  1715. $country = $this->country->read($v['country']);
  1716. $v['country'] = $country['ename'];
  1717. $express['servicename'] =$service['title'];//增加快递名称
  1718. $v['cxcode'] = strtolower($express['cxcode']);//增加快递服务商码
  1719. if($v['expressstate'] == $var['logisticstatus'] && $v['wlyc'] == '0' && $v['wltype'] != '1' && $v['source'] != '1')//获取快递状态等于模板状态、订单状态等于模板状态、出库时间大于-、未加入物流异常、允许发送邮件状态、非线下单
  1720. {
  1721. if($v['shop'] < '7')// && $v['shouldmoney'] > 100)
  1722. {
  1723. $wlfs[] = array('v'=>$v,'id'=>$var['id']);
  1724. //$go = $this->_sdfs($v,$var['id']);//更新顺带发送
  1725. }
  1726. continue;
  1727. }
  1728. if(($express['cxcode'] == '' && $v['exstateerror'] == '') || ($express['cxcode'] == '' && $v['exstateerror'] != ''))
  1729. {
  1730. continue;
  1731. }
  1732. else if($express['cxcode'] == 'usps')//$express['cxcode'] == 'fedex' || $express['cxcode'] == 'dhl' || $express['cxcode'] == 'cne' || $express['cxcode'] == 'dpex' || $express['cxcode'] == 'dpd'
  1733. {
  1734. /**
  1735. if($express['cxcode'] == 'dpex' || $express['cxcode'] == 'dpd')
  1736. {
  1737. $express['cxcode'] = 'cne';
  1738. }
  1739. **/
  1740. $logistics = $express['cxcode'];
  1741. }
  1742. // else if($express['cxcode'] == 'yscx'){
  1743. // //由于云尚接口老是返回状态异常 或者是物流已经签收 但是云尚的却是只有中国阶段的轨迹不符合要求 就此废除
  1744. // $v['servicename'] =$service['title'];//增加快递名称
  1745. // $v['url'] = $express['url'];//增加快递链接
  1746. // $v['express'] = $vexpress;
  1747. // $this->zzjobs->insert([
  1748. // 'status'=>0,
  1749. // 'quque'=>'ysgjcx',//云尚轨迹查询
  1750. // 'payload'=>json_encode([
  1751. // 'v'=>$v,
  1752. // 'id'=>$var['id']
  1753. // ],JSON_UNESCAPED_UNICODE),
  1754. // 'do_interval'=>1,
  1755. // 'create_time'=>time()
  1756. // ]);
  1757. // continue;
  1758. // }
  1759. else if(($express['cxcode'] == 'ups' && $v['webhookregister'] == 1) || $express['cxcode'] == '17track')
  1760. {
  1761. continue;
  1762. }
  1763. else if($express['cxcode'] == 'ups' && $v['webhookregister'] < 1)//使用webhook注册模式 || $express['cxcode'] == '17track'
  1764. {
  1765. $logistics = $express['cxcode'];
  1766. $webhookregister = 1;
  1767. }
  1768. else
  1769. {
  1770. //暂时不启用第三方,这里直接跳出
  1771. $this->fullorder->save(array('expressstate'=>'99'),$v['id']);
  1772. continue;
  1773. //$logistics = 'apismt';
  1774. //$v['express'] = strtolower($express['cxcode']);//替换为快递服务商码
  1775. }
  1776. $this->logic_ding->sendToDing("检测是否检测--".$v['number']."--执行的轨迹追踪信息--".$logistics);
  1777. $v['servicename'] =$service['title'];//增加快递名称
  1778. $v['url'] = $express['url'];//增加快递链接
  1779. @$fs = $this->$logistics->get_logistics($v);
  1780. $csck[] = array($v['number'],$fs['f'],$fs['content']);
  1781. if(!isset($fs['f']))
  1782. {
  1783. $fs = $this->$logistics->get_logistics($v);
  1784. if(!isset($fs['f']))
  1785. {
  1786. continue;
  1787. }
  1788. if($fs['f'] == '1')
  1789. {
  1790. $v['express'] = $vexpress;
  1791. if($fs['exstate'] > $v['expressstate'] || isset($fs['webhookregister']))
  1792. {
  1793. $this->fullorder->save(array('expressstate'=>$fs['exstate'],'excontent'=>$fs['data'],'webhookregister'=>$webhookregister,'wlerror'=>''),$v['id']);
  1794. }
  1795. if($fs['exstate'] == $var['logisticstatus'] && $v['wlyc'] == '0' && $v['wltype'] != '1' && $v['source'] != '1')//获取快递状态等于模板状态、订单状态等于模板状态、出库时间大于-、未加入物流异常、允许发送邮件状态、非线下单
  1796. {
  1797. if($v['shop'] < '7')// && $v['shouldmoney'] > 100)
  1798. {
  1799. $wlfs[] = array('v'=>$v,'id'=>$var['id']);
  1800. //$go = $this->_sdfs($v,$var['id']);//更新顺带发送
  1801. }
  1802. }
  1803. }
  1804. /**
  1805. if($logistics == 'apismt')//第三方未购买,第三方查询直接进入无法查询状态
  1806. {
  1807. $this->fullorder->save(array('expressstate'=>'99'),$v['id']);
  1808. }
  1809. **/
  1810. }
  1811. else
  1812. {
  1813. if($fs['f'] == '1')
  1814. {
  1815. $v['express'] = $vexpress;
  1816. if($fs['exstate'] > $v['expressstate'] || isset($fs['webhookregister']))
  1817. {
  1818. $this->fullorder->save(array('expressstate'=>$fs['exstate'],'excontent'=>$fs['data'],'webhookregister'=>$webhookregister,'wlerror'=>''),$v['id']);
  1819. }
  1820. if($fs['exstate'] == $var['logisticstatus'] && $v['wlyc'] == '0' && $v['wltype'] != '1' && $v['source'] != '1')//获取快递状态等于模板状态、订单状态等于模板状态、出库时间大于-、未加入物流异常、允许发送邮件状态、非线下单
  1821. {
  1822. if($v['shop'] < '7')// && $v['shouldmoney'] > 100)
  1823. {
  1824. $wlfs[] = array('v'=>$v,'id'=>$var['id']);
  1825. //$go = $this->_sdfs($v,$var['id']);//更新顺带发送
  1826. }
  1827. }
  1828. }
  1829. else
  1830. {
  1831. $this->fullorder->save(array('wlerror'=>$fs['content']),$v['id']);
  1832. }
  1833. }
  1834. }
  1835. @$this->allocation->insert(array('title'=>$shopid.'-'.json_encode($csck)));
  1836. if($wlfs)
  1837. {
  1838. foreach ($wlfs as $k=>$v)
  1839. {
  1840. $t1 = microtime(true);
  1841. $this->_sdfs($v['v'],$v['id']);
  1842. $t2 = microtime(true);
  1843. $t3 = (40-($t2-$t1) < 1)?1:round(40-($t2-$t1));
  1844. sleep($t3);
  1845. }
  1846. }
  1847. }
  1848. public function _zzold()
  1849. {
  1850. $data = $this->fullorder->find_all("library = '2' and waybill != '' and exstate != '4' and exstate != '5' and dtime > '1580486400'");
  1851. foreach ($data as $k=>$v)
  1852. {
  1853. $shop = $this->shop->read($v['shop']);
  1854. $express = $this->express->read($v['express']);
  1855. $service = $this->service->read($express['service']);
  1856. $country = $this->country->read($v['country']);
  1857. $v['country'] = $country['ename'];
  1858. $express['servicename'] =$service['title'];//增加快递名称
  1859. if($express['cxcode'] == '' && $v['exstateerror'] == '')
  1860. {
  1861. continue;
  1862. }
  1863. else if($express['cxcode'] == '' && $v['exstateerror'] != '')
  1864. {
  1865. continue;
  1866. }
  1867. else if($express['cxcode'] == 'fedex' || $express['cxcode'] == 'usps' || $express['cxcode'] == 'dhl' || $express['cxcode'] == 'cne' || $express['cxcode'] == 'dpex' || $express['cxcode'] == 'dpd')
  1868. {
  1869. $logistics = $express['cxcode'];
  1870. }
  1871. else
  1872. {
  1873. $logistics = 'apismt';
  1874. }
  1875. $v['express'] = strtolower($express['cxcode']);//替换为快递服务商码
  1876. $v['servicename'] =$service['title'];//增加快递名称
  1877. $v['url'] = $express['url'];//增加快递链接
  1878. $fs = $this->$logistics->get_logistics($v);
  1879. if(!isset($fs['f']))
  1880. {
  1881. $this->fullorder->save(array('exstate'=>'99'),$v['id']);
  1882. }
  1883. else
  1884. {
  1885. if($fs['f'] == '0')
  1886. {
  1887. $this->fullorder->save(array('excontent'=>$fs['content']),$v['id']);
  1888. }
  1889. if($fs['f'] == '2')
  1890. {
  1891. }
  1892. else
  1893. {
  1894. $this->fullorder->save(array('exstate'=>$fs['exstate'],'excontent'=>$fs['data']),$v['id']);
  1895. }
  1896. }
  1897. }
  1898. }
  1899. public function _query()
  1900. {
  1901. header('Access-Control-Allow-Origin: *');
  1902. $post = $this->input->post(NULL, TRUE);
  1903. if(isset($post['orderinfo']))
  1904. {
  1905. $list = array();
  1906. $orderinfo = $this->input->post('orderinfo',true);
  1907. $orderinfo = explode(',',trim($orderinfo,','));
  1908. foreach ($orderinfo as $v)
  1909. {
  1910. $exp="/^([0-9A-Za-z\\-_\\.]+)@([0-9a-z]+\\.[a-z]{2,3}(\\.[a-z]{2})?)$/i";
  1911. if(is_numeric($v) && mb_strlen($v) > 8)
  1912. {
  1913. $w = "orderinfo like '%$v%'";
  1914. }
  1915. else if(filter_var($v, FILTER_VALIDATE_EMAIL))
  1916. {
  1917. $w = "email like '%$v%'";
  1918. }
  1919. else
  1920. {
  1921. echo json_encode(array('site'=>0,'success'=>true));exit;
  1922. }
  1923. $data = $this->fullorder->find_all($w." and dtime > '1577811600'");
  1924. if(isset($data[0]))
  1925. {
  1926. if($data[0]['library'] != '2')
  1927. {
  1928. $list[] = array('orderinfo'=>$v,'site'=>1);
  1929. }
  1930. else if($data[0]['library'] == '2' && $data[0]['exstate'] == '99')
  1931. {
  1932. $list[] = array('orderinfo'=>$v,'site'=>2);
  1933. }
  1934. else if($data[0]['library'] == '2' && $data[0]['exstate'] != '99')
  1935. {
  1936. if($data[0]['excontent'] != '成功;' && $data[0]['excontent'] != '')
  1937. {
  1938. $list[] = array('orderinfo'=>$v,'site'=>3,'data'=>$data[0]['excontent']);
  1939. }
  1940. else
  1941. {
  1942. $list[] = array('orderinfo'=>$v,'site'=>2);
  1943. }
  1944. }
  1945. }
  1946. else
  1947. {
  1948. $list[] = array('orderinfo'=>$v,'site'=>0);
  1949. }
  1950. }
  1951. echo json_encode(array('t'=>count($orderinfo),'list'=>$list,'success'=>true));exit;
  1952. }
  1953. }
  1954. public function _logistics()
  1955. {
  1956. if(isset($_GET['waybill']))
  1957. {
  1958. $waybill = $this->input->get('waybill',true);
  1959. $s = $this->input->get('shop',true);
  1960. //$express = $this->input->get('express',true);
  1961. $data = $this->fullorder->get_waybill($waybill);
  1962. if(isset($data['excontent']) && $data['excontent'] != '')
  1963. {
  1964. //$a = $this->$express->get_logistics(array('waybill'=>$waybill));
  1965. echo json_encode(array('track'=>array('f'=>1,'data'=>$data['excontent']),'msg'=>'','success'=>1));exit;
  1966. }
  1967. else
  1968. {
  1969. $shop = $this->shop->get_shopname($s);
  1970. if(!$shop)
  1971. {
  1972. echo json_encode(array('track'=>'','msg'=>'No logistics information','success'=>0));exit;
  1973. }
  1974. $data = $this->fullorder->get_orderinfo($shop.$waybill);
  1975. if(isset($data['excontent']) && $data['excontent'] != '')
  1976. {
  1977. echo json_encode(array('track'=>array('f'=>1,'data'=>$data['excontent']),'msg'=>'','success'=>1));exit;
  1978. }
  1979. echo json_encode(array('track'=>'','msg'=>'No logistics information','success'=>0));exit;
  1980. }
  1981. }
  1982. }
  1983. public function _klarna()
  1984. {
  1985. $shop = array();$cg = array();$sb = array();
  1986. $ftime = strtotime(date("Y-m-d 0:00:0",strtotime("-10 day")))+8*3600;
  1987. $ttime = strtotime(date("Y-m-d 8:00:0",time()));
  1988. $shopdata = $this->shop->find_all("type = '269' and klarnaname != '' and klarnapass != ''");
  1989. foreach($shopdata as $v)
  1990. {
  1991. $data = $this->fullorder->find_all("paypal like '%-%-%-%' and librarytime > '$ftime' and librarytime < '$ttime' and pay = '23' and library = '2' and source != '1' and klarna < '2' and shop = '".$v['id']."'","id,number,orderinfo,paypal,shouldmoney,shop");
  1992. foreach($data as $val)
  1993. {
  1994. $api = $this->_klarnaapi($val['paypal'],$val['shouldmoney'],$v['klarnaname'],$v['klarnapass']);
  1995. $header = $api['header'];
  1996. $api = $api['res'];
  1997. if(isset($api['error_messages'][0]))
  1998. {
  1999. if(stripos($api['error_messages'][0],'amount is 0 for') !== false)
  2000. {
  2001. $this->fullorder->save(array('klarna'=>3),$val['id']);
  2002. $sb[] = array($val['number'],$val['orderinfo'],'oooo3');
  2003. }
  2004. else
  2005. {
  2006. $this->fullorder->save(array('klarna'=>1,'klarnaerror'=>$api['error_messages'][0]),$val['id']);
  2007. $sb[] = array($val['number'],$val['orderinfo'],'oooo1');
  2008. }
  2009. }
  2010. else if($api == '')
  2011. {
  2012. if(isset($header['http_code']) && $header['http_code'] == 201)
  2013. {
  2014. $this->fullorder->save(array('klarna'=>2),$val['id']);
  2015. $cg[] = array($val['number'],$val['orderinfo'],'oooo2');
  2016. }
  2017. else
  2018. {
  2019. $this->fullorder->save(array('klarna'=>1,'klarnaerror'=>'未知错误'),$val['id']);
  2020. $sb[] = array($val['number'],$val['orderinfo'],'oooo0');
  2021. }
  2022. }
  2023. else if(isset($api['cs']))
  2024. {
  2025. $this->fullorder->save(array('klarna'=>1,'klarnaerror'=>'超时'),$val['id']);
  2026. $sb[] = array($val['number'],$val['orderinfo'],'oooo0');
  2027. }
  2028. else
  2029. {
  2030. $this->fullorder->save(array('klarna'=>1,'klarnaerror'=>'未知错误'),$val['id']);
  2031. $sb[] = array($val['number'],$val['orderinfo'],'oooo0');
  2032. }
  2033. }
  2034. }
  2035. echo "<pre>";
  2036. print_r($cg);
  2037. echo "<pre>";
  2038. print_r($sb);
  2039. }
  2040. public function _klarnaapi($paypal,$shouldmoney,$name,$pass)
  2041. {
  2042. $url = 'https://api-na.klarna.com/ordermanagement/v1/orders/'.$paypal.'/captures';
  2043. $data = '{"captured_amount": '.str_replace('.','',$shouldmoney).'}';
  2044. $header[] = "Content-Type:application/json";
  2045. $header[] = "Authorization: Basic ".base64_encode($name.":".$pass);
  2046. $ch = curl_init();
  2047. curl_setopt($ch, CURLOPT_URL, $url);
  2048. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2049. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  2050. curl_setopt($ch, CURLINFO_HEADER_OUT, TRUE);
  2051. curl_setopt($ch, CURLOPT_POST, 1);
  2052. curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  2053. curl_setopt($ch, CURLOPT_TIMEOUT, 20);
  2054. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  2055. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  2056. $res = curl_exec($ch);
  2057. $header = curl_getinfo($ch);
  2058. if($res === false)
  2059. {
  2060. if(curl_errno($ch))
  2061. {
  2062. return array('res'=>'1','header'=>'','cs'=>1);
  2063. }
  2064. }
  2065. else
  2066. {
  2067. $res = json_decode($res,true);
  2068. return array('res'=>$res,'header'=>$header);
  2069. }
  2070. curl_close($ch);
  2071. }
  2072. public function _klarnadata($paypal,$name,$pass)
  2073. {
  2074. $url = 'https://api-na.klarna.com/ordermanagement/v1/orders/'.$paypal;
  2075. $header[] = "Content-Type:application/json";
  2076. $header[] = "Authorization: Basic ".base64_encode($name.":".$pass);
  2077. $ch = curl_init();
  2078. curl_setopt($ch, CURLOPT_URL, $url);
  2079. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2080. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  2081. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  2082. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  2083. $res = curl_exec($ch);
  2084. curl_close($ch);
  2085. $res = json_decode($res,true);
  2086. $data = '';
  2087. if(isset($res['fraud_status']))
  2088. {
  2089. // $data = (($res['fraud_status'] == 'ACCEPTED')?1:2).'|<strong>'.$res['purchase_currency'].($res['order_amount']/100).'</strong> , '.(($res['fraud_status'] != 'ACCEPTED')?'<font style="color:#f00">'.$res['fraud_status'].'</font>':$res['fraud_status']).' , description:'.$res['initial_payment_method']['description'].' , number of installments:'.$res['initial_payment_method']['number_of_installments'].'|'.$res['billing_address']['street_address'].(($res['billing_address']['street_address2']!='')?' '.$res['billing_address']['street_address2']:'').','.$res['billing_address']['city'].','.$res['billing_address']['region'].','.$res['billing_address']['postal_code'].','.$res['billing_address']['country'].','.$res['billing_address']['given_name'].' '.$res['billing_address']['family_name'].','.$res['billing_address']['phone'].','.$res['billing_address']['email'].'|'.str_replace('|','&#124;',$res['shipping_address']['street_address']).(($res['shipping_address']['street_address2']!='')?' '.str_replace('|','&#124;',$res['shipping_address']['street_address2']):'').','.$res['shipping_address']['city'].','.$res['shipping_address']['region'].','.$res['shipping_address']['postal_code'].','.$res['shipping_address']['country'].','.$res['shipping_address']['given_name'].' '.$res['shipping_address']['family_name'].','.$res['shipping_address']['phone'].','.$res['shipping_address']['email'];
  2090. if(isset($res['initial_payment_method']['number_of_installments'])){
  2091. $number_of_installments = $res['initial_payment_method']['number_of_installments'];
  2092. }else{
  2093. $number_of_installments = 0;
  2094. }
  2095. $data = (($res['fraud_status'] == 'ACCEPTED')?1:2).'|<strong>'.$res['purchase_currency'].($res['order_amount']/100).'</strong> , '.(($res['fraud_status'] != 'ACCEPTED')?'<font style="color:#f00">'.$res['fraud_status'].'</font>':$res['fraud_status']).' , description:'.$res['initial_payment_method']['description'].' , number of installments:'.$number_of_installments.'|'.$res['billing_address']['street_address'].(($res['billing_address']['street_address2']!='')?' '.$res['billing_address']['street_address2']:'').','.$res['billing_address']['city'].','.$res['billing_address']['region'].','.$res['billing_address']['postal_code'].','.$res['billing_address']['country'].','.$res['billing_address']['given_name'].' '.$res['billing_address']['family_name'].','.$res['billing_address']['phone'].','.$res['billing_address']['email'].'|'.str_replace('|','&#124;',$res['shipping_address']['street_address']).(($res['shipping_address']['street_address2']!='')?' '.str_replace('|','&#124;',$res['shipping_address']['street_address2']):'').','.$res['shipping_address']['city'].','.$res['shipping_address']['region'].','.$res['shipping_address']['postal_code'].','.$res['shipping_address']['country'].','.$res['shipping_address']['given_name'].' '.$res['shipping_address']['family_name'].','.$res['shipping_address']['phone'].','.$res['shipping_address']['email'];
  2096. }
  2097. return $data;
  2098. }
  2099. public function _hqpaypal()
  2100. {
  2101. $shop = $this->shop->find_all("paypalname != ''");
  2102. foreach ($shop as $val)
  2103. {
  2104. $d = $this->fullorder->find_all("shop = '".$val['id']."' and dtime > '".(time()-(5*24*3600))."' and dtime < '".(time()-(3*3600))."' and (pay = '22' || pay = '7') and klarnadata = ''");
  2105. foreach ($d as $v)
  2106. {
  2107. $paypal = $this->paypal->data($v['paypal'],$val);
  2108. if($paypal != '')
  2109. {
  2110. $this->fullorder->save(array('klarnadata'=>$paypal),$v['id']);
  2111. }
  2112. }
  2113. }
  2114. }
  2115. public function _hqstripe()
  2116. {
  2117. $shop = $this->shop->find_all("stripe != ''");
  2118. foreach ($shop as $val)
  2119. {
  2120. $d = $this->fullorder->find_all("shop = '".$val['id']."' and dtime > '".(time()-(5*24*3600))."' and dtime < '".time()."' and pay = '1211' and klarnadata = ''");
  2121. foreach ($d as $v)
  2122. {
  2123. $paypal = $this->_stripe($v['paypal'],$val['stripe']);
  2124. if($paypal != '')
  2125. {
  2126. $this->fullorder->save(array('klarnadata'=>$paypal),$v['id']);
  2127. }
  2128. }
  2129. }
  2130. }
  2131. public function _stripe($pay,$stripe)
  2132. {
  2133. $url = 'https://api.stripe.com/v1/payment_intents/'.$pay;
  2134. $header[] = "Authorization:Bearer ".$stripe;
  2135. $ch = curl_init();
  2136. curl_setopt($ch, CURLOPT_URL, $url);
  2137. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2138. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  2139. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  2140. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  2141. $res = curl_exec($ch);
  2142. curl_close($ch);
  2143. $res = json_decode($res,true);
  2144. $k = '';
  2145. if(isset($res['shipping']['name']))
  2146. {
  2147. $line = ($res['shipping']['address']['line2'] != '')?$res['shipping']['address']['line1'].' '.$res['shipping']['address']['line2']:$res['shipping']['address']['line1'];
  2148. $k = 'stripe|'.json_encode(array('name'=>$res['shipping']['name'],'email'=>$res['receipt_email'],'address'=>$line.','.$res['shipping']['address']['city'].','.$res['shipping']['address']['state'].','.$res['shipping']['address']['postal_code'].','.$res['shipping']['address']['country'].','.$res['shipping']['phone'],'shouldmoney'=>$res['amount']/100));
  2149. }
  2150. return $k;
  2151. }
  2152. public function _afterpay($paypal,$name,$pass)
  2153. {
  2154. $url = 'https://global-api.afterpay.com/v2/payments?ids='.$paypal;
  2155. $header[] = "Accept:application/json";
  2156. $header[] = "User-Agent: Readme.io API Simulator'";
  2157. $header[] = "Authorization: Basic ".base64_encode($name.":".$pass);
  2158. $ch = curl_init();
  2159. curl_setopt($ch, CURLOPT_URL, $url);
  2160. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2161. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  2162. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  2163. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  2164. $res = curl_exec($ch);
  2165. curl_close($ch);
  2166. $res = json_decode($res,true);
  2167. $data = '';
  2168. if(isset($res['results'][0]['orderDetails']['consumer']['email']))
  2169. {
  2170. $data = $res['results'][0]['orderDetails']['consumer']['email'].'|'.str_replace('|','&#124;',$res['results'][0]['orderDetails']['billing']['line1']).','.str_replace('|','&#124;',$res['results'][0]['orderDetails']['billing']['line2']).','.$res['results'][0]['orderDetails']['billing']['area1'].','.$res['results'][0]['orderDetails']['billing']['region'].','.$res['results'][0]['orderDetails']['billing']['postcode'].','.$res['results'][0]['orderDetails']['billing']['countryCode'].','.$res['results'][0]['orderDetails']['billing']['name'].','.$res['results'][0]['orderDetails']['billing']['phoneNumber'].'|'.str_replace('|','&#124;',$res['results'][0]['orderDetails']['shipping']['line1']).','.str_replace('|','&#124;',$res['results'][0]['orderDetails']['shipping']['line2']).','.$res['results'][0]['orderDetails']['shipping']['area1'].','.$res['results'][0]['orderDetails']['shipping']['region'].','.$res['results'][0]['orderDetails']['shipping']['postcode'].','.$res['results'][0]['orderDetails']['shipping']['countryCode'].','.$res['results'][0]['orderDetails']['shipping']['name'].','.$res['results'][0]['orderDetails']['shipping']['phoneNumber'];
  2171. $data = str_replace(',,',',',$data);
  2172. }
  2173. return $data;
  2174. }
  2175. public function _clearpay($paypal,$name,$pass)
  2176. {
  2177. $url = 'https://global-api.afterpay.com/v2/payments?ids='.$paypal;
  2178. $header[] = "Accept:application/json";
  2179. $header[] = "User-Agent: Readme.io API Simulator'";
  2180. $header[] = "Authorization: Basic ".base64_encode($name.":".$pass);
  2181. $ch = curl_init();
  2182. curl_setopt($ch, CURLOPT_URL, $url);
  2183. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2184. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  2185. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  2186. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  2187. $res = curl_exec($ch);
  2188. curl_close($ch);
  2189. $res = json_decode($res,true);
  2190. $data = '';
  2191. if(isset($res['results'][0]['orderDetails']['consumer']['email']))
  2192. {
  2193. $data = $res['results'][0]['orderDetails']['consumer']['email'].'|'.str_replace('|','&#124;',$res['results'][0]['orderDetails']['billing']['line1']).','.str_replace('|','&#124;',$res['results'][0]['orderDetails']['billing']['line2']).','.$res['results'][0]['orderDetails']['billing']['area1'].','.$res['results'][0]['orderDetails']['billing']['region'].','.$res['results'][0]['orderDetails']['billing']['postcode'].','.$res['results'][0]['orderDetails']['billing']['countryCode'].','.$res['results'][0]['orderDetails']['billing']['name'].','.$res['results'][0]['orderDetails']['billing']['phoneNumber'].'|'.str_replace('|','&#124;',$res['results'][0]['orderDetails']['shipping']['line1']).','.str_replace('|','&#124;',$res['results'][0]['orderDetails']['shipping']['line2']).','.$res['results'][0]['orderDetails']['shipping']['area1'].','.$res['results'][0]['orderDetails']['shipping']['region'].','.$res['results'][0]['orderDetails']['shipping']['postcode'].','.$res['results'][0]['orderDetails']['shipping']['countryCode'].','.$res['results'][0]['orderDetails']['shipping']['name'].','.$res['results'][0]['orderDetails']['shipping']['phoneNumber'];
  2194. $data = str_replace(',,',',',$data);
  2195. }
  2196. return $data;
  2197. }
  2198. public function _htmlstock()
  2199. {
  2200. if(isset($_GET['hq']))
  2201. {
  2202. $ProductsType = $this->typeclass->find_all("classid = '16' and hq = '1'",'id,title','sequence asc');
  2203. foreach ($ProductsType as $k=>$v)
  2204. {
  2205. if($v['title'] == 'Closure')
  2206. {
  2207. $ProductsType[$k]['title'] = 'Closure/Frontal';
  2208. }
  2209. }
  2210. $HairColor = $this->typeclass->find_all("classid = '8' and hq = '1'",'id,title','sequence asc');
  2211. $HairWavy = $this->typeclass->find_all("classid = '15' and hq = '1'",'id,title','sequence asc');
  2212. $WigType = $this->typeclass->find_all("classid = '18' and hq = '1'",'id,title','sequence asc');
  2213. $Length = $this->typeclass->find_all("classid = '14' and hq = '1'",'id,title','sequence asc');
  2214. echo json_encode(array('ProductsType'=>$ProductsType,'HairColor'=>$HairColor,'HairWavy'=>$HairWavy,'WigType'=>$WigType,'Length'=>$Length));exit;
  2215. //http://1.wepolicy.cn/api/htmlstock?hq=1
  2216. }
  2217. if(isset($_GET['page']))
  2218. {
  2219. $del = array();
  2220. $typeclass13 = $this->typeclass->find_all("classid = '13'");
  2221. $typeclass16 = $this->typeclass->find_all("classid = '16'");
  2222. foreach ($typeclass16 as $key=>$value)
  2223. {
  2224. foreach ($typeclass13 as $v)
  2225. {
  2226. $del[] = $value['title'].' '.$v['title'];
  2227. }
  2228. }
  2229. $page = $this->input->get('page',true);
  2230. $perpage = $this->input->get('perpage',true);
  2231. $category = $this->input->get('ProductsType',true);//类目
  2232. $color = $this->input->get('HairColor',true);//颜色
  2233. $lowe = $this->input->get('HairWavy',true);//花型
  2234. $lacetype = $this->input->get('WigType',true);//头套种类
  2235. $size = $this->input->get('Length',true);//长度
  2236. $title = $this->input->get('title',true);//传输文本
  2237. $warehouse = 5;
  2238. $state = $this->input->get('state',true);
  2239. $where = "warehouse = '5' and state = '0'";
  2240. if($category)
  2241. {
  2242. $where .= " and features like '%-$category-%'";
  2243. }
  2244. if($color)
  2245. {
  2246. $where .= " and features like '%-$color-%'";
  2247. }
  2248. if($lowe)
  2249. {
  2250. $where .= " and features like '%-$lowe-%'";
  2251. }
  2252. if($lacetype)
  2253. {
  2254. $where .= " and features like '%-$lacetype-%'";
  2255. }
  2256. if($size)
  2257. {
  2258. $where .= " and features like '%-$size-%'";
  2259. }
  2260. if($title)
  2261. {
  2262. $where .= " and title like '%$title%'";
  2263. }
  2264. $order_str = "id desc";
  2265. if(empty($page))
  2266. {
  2267. $start = 0;
  2268. $perpage = 1;
  2269. }
  2270. else
  2271. {
  2272. $start = ($page - 1)*$perpage;
  2273. }
  2274. $info_list = $this->whlabel->find_pc($where,'sku,features,warehouse','id,warehouse,sku,title,features,number',$order_str,$start,$perpage);
  2275. $data = array();
  2276. foreach ($info_list as $key=>$value)
  2277. {
  2278. $c = $this->whlabel->find_count($where.' and sku = "'.$value['sku'].'" and state = 0 and warehouse = "5" and features = "'.$value['features'].'" and zd = ""');
  2279. if($c > 1)
  2280. {
  2281. $data[] = array('Item'=>str_replace($del,'',$value['title']),'Stock'=>$c);
  2282. }
  2283. }
  2284. $total = count($this->whlabel->find_pc($where,'sku,features,warehouse','id,warehouse,sku,title,features,number'));
  2285. $pagenum = ceil($total/$perpage);
  2286. $over = $total-($start+$perpage);
  2287. $rows = array('total'=>$total,'over'=>$over,'pagenum'=>$pagenum,'rows'=>($data));//总数量,剩余数量,总页数,数据
  2288. echo json_encode($rows);exit;
  2289. ///api/htmlstock?page=1&perpage=50&ProductsType=&HairColor=&HairWavy=&WigType=&Length= //页数、每页数量、类目、颜色、花型、头套种类、尺寸
  2290. }
  2291. }
  2292. public function _zc17track()
  2293. {
  2294. $express = array();
  2295. $ex = $this->express->find_all("cxcode = '17track'");
  2296. foreach ($ex as $v)
  2297. {
  2298. $express[$v['id']] = $v['title'];
  2299. }
  2300. $time_threshold = time() - 12 * 24 * 3600;
  2301. $this->db->select('a.number, a.express,a.waybill');
  2302. $this->db->from('crowd_fullorder as a');
  2303. $this->db->join('express as b', 'a.express = b.id', 'inner');
  2304. $this->db->where('a.waybill !=', '');
  2305. $this->db->where('a.library', '2');
  2306. $this->db->where('a.librarytime >', $time_threshold);
  2307. $this->db->where('a.webhookregister <', 1);
  2308. $this->db->where('b.cxcode', '17track');
  2309. $query = $this->db->get();
  2310. $data = $query->result_array();
  2311. $fsdata = array();
  2312. foreach ($data as $v)
  2313. {
  2314. if(!isset($express[$v['express']]))
  2315. {
  2316. continue;
  2317. }
  2318. if(stripos($express[$v['express']],'DHL') !== false)
  2319. {
  2320. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'100001');
  2321. }
  2322. else if(stripos($express[$v['express']],'UPS') !== false)
  2323. {
  2324. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'100002');
  2325. }
  2326. else if((stripos($express[$v['express']],'FEDEX') !== false)||(stripos($express[$v['express']],'FedEx') !== false) )
  2327. {
  2328. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'100003');
  2329. }
  2330. else if(stripos($express[$v['express']],'TNT') !== false)
  2331. {
  2332. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'100004');
  2333. }
  2334. else if(stripos($express[$v['express']],'ARAMEX') !== false)
  2335. {
  2336. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'100006');
  2337. }
  2338. else if(stripos($express[$v['express']],'YunExpress') !== false){
  2339. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'190008');
  2340. }
  2341. else if(stripos($express[$v['express']],'DEPX') !== false){
  2342. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'100014');
  2343. }
  2344. else if(stripos($express[$v['express']],'EMS') !== false)
  2345. {
  2346. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'3013');
  2347. }
  2348. else if(stripos($express[$v['express']],'GES') !== false)
  2349. {
  2350. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'190258');
  2351. }
  2352. else if(stripos($express[$v['express']],'3PE') !== false)
  2353. {
  2354. $fsdata[] = array('number'=>$v['waybill'],'carrier'=>'191376');
  2355. }
  2356. else
  2357. {
  2358. $fsdata[] = array('number'=>$v['waybill'],'auto_detection'=>'true');
  2359. }
  2360. }
  2361. $fsdata = array_chunk($fsdata, 40);
  2362. $logistics = '17track';
  2363. foreach ($fsdata as $v)
  2364. {
  2365. $fs = $this->$logistics->get_logistics(json_encode($v));
  2366. $this->logic_ding->sendToDing("监听17track注册为什么获取不到的原因,请求参数".json_encode($v));
  2367. $this->logic_ding->sendToDing("监听17track注册为什么获取不到的原因,返回参数".json_encode($fs));
  2368. if(isset($fs['f']))
  2369. {
  2370. $csck[] = array($v,$fs['f'],$fs['content']);
  2371. foreach ($v as $val)
  2372. {
  2373. $d = $this->fullorder->get_waybill($val['number']);
  2374. if($fs['f'] == '1')
  2375. {
  2376. $this->fullorder->save(array('webhookregister'=>1,'wlerror'=>''),$d['id']);
  2377. }
  2378. else
  2379. {
  2380. $this->fullorder->save(array('wlerror'=>$fs['content']),$d['id']);
  2381. }
  2382. }
  2383. }
  2384. else
  2385. {
  2386. $csck[] = array($v,'CW',"CS");
  2387. }
  2388. sleep(3);
  2389. }
  2390. @$this->allocation->insert(array('title'=>json_encode($csck)));
  2391. /**
  2392. $data = $this->fullorder->find_all("waybill != '' and library = '2' and librarytime > '".(time()-12*24*3600)."' and webhookregister < 1");
  2393. $csck = array();
  2394. foreach ($data as $k=>$v)
  2395. {
  2396. $express = $this->express->read($v['express']);
  2397. $service = $this->service->read($express['service']);
  2398. $v['servicename'] =$service['title'];//增加快递名称
  2399. $v['url'] = $express['url'];//增加快递链接
  2400. $logistics = '17track';
  2401. $fs = $this->$logistics->get_logistics($v);
  2402. if(isset($fs['f']))
  2403. {
  2404. $csck[] = array($v['number'],$fs['f'],$fs['content']);
  2405. if($fs['f'] == '1')
  2406. {
  2407. $this->fullorder->save(array('webhookregister'=>1,'wlerror'=>''),$v['id']);
  2408. }
  2409. else
  2410. {
  2411. $this->fullorder->save(array('wlerror'=>$fs['content']),$v['id']);
  2412. }
  2413. }
  2414. else
  2415. {
  2416. $csck[] = array($v['number'],'CW',"CS");
  2417. }
  2418. sleep(1);
  2419. }
  2420. @$this->allocation->insert(array('title'=>$shopid.'-'.json_encode($csck)));
  2421. **/
  2422. }
  2423. public function _17track()
  2424. {
  2425. $xq = array();
  2426. $j = file_get_contents('PHP://input');
  2427. $j = json_decode($j, true);
  2428. $j = $j['data'];
  2429. $express = array();
  2430. $expressdata = $this->express->find_all('1=1');
  2431. foreach ($expressdata as $v)
  2432. {
  2433. $express[$v['id']] = $v['title'];
  2434. }
  2435. //$sh = hash("sha256",$j['event'].'/'.json_encode($j).'/0811AC1711EAABB7D764D04B824F8C2D');
  2436. $f = 'fullorder';
  2437. $d = $this->fullorder->get_waybill($j['number']);
  2438. if(!$d)
  2439. {
  2440. $f = 'fullordersmt';
  2441. $d = $this->fullordersmt->get_waybill($j['number']);
  2442. if(!$d)
  2443. {
  2444. $f = 'fullordertt';
  2445. $d = $this->fullordertt->get_waybill($j['number']);
  2446. }
  2447. }
  2448. if(!$d)
  2449. {
  2450. exit;
  2451. }
  2452. $state = '';
  2453. $zxzt = '';
  2454. if(isset($j['track_info'])){
  2455. $zxzt = array_reverse($j['track_info']['milestone']);
  2456. foreach ($zxzt as $v)
  2457. {
  2458. if($v['time_iso'] != NULL)
  2459. {
  2460. $state = $v['key_stage'];
  2461. break;
  2462. }
  2463. }
  2464. }else{
  2465. //$this->logic_ding->sendToDing("17track接口返回数据异常,请求参数".json_encode($j));
  2466. }
  2467. $exstate = 0;//无信息
  2468. if($state == 'InfoReceived' || $state == 'PickedUp' || $state == 'Departure' || $state == 'Arrival')//运输途中
  2469. {
  2470. $exstate = 3;//在途中
  2471. }
  2472. else if($state == 'OutForDelivery')//派送中
  2473. {
  2474. $exstate = 4;
  2475. }
  2476. else if($state == 'Returned' || $zxzt == 'Returning')//投递失败
  2477. {
  2478. $exstate = 1;//派送异常
  2479. }
  2480. else if($state == 'Delivered')//成功签收
  2481. {
  2482. $exstate = 6;//签收
  2483. }
  2484. $pd = array();$xq = '';
  2485. if(isset($j['track_info']['tracking']['providers'][0]['events']))
  2486. {
  2487. foreach ($j['track_info']['tracking']['providers'][0]['events'] as $k=>$v)
  2488. {
  2489. if($k == 0)
  2490. {
  2491. $pd = $v['description'];
  2492. }
  2493. $xq .= date('Y-m-d H:i:s',strtotime($v['time_iso'])).' ['.$v['location'].'] '.$v['description'].'<br />';// a日期 c地址 z状态
  2494. }
  2495. if(stripos($express[$d['express']],'Fedex') !== false && stripos($pd,'International shipment release - Import') !== false)
  2496. {
  2497. $exstate = 4;//即将派送
  2498. }
  2499. else if(stripos($express[$d['express']],'DHL') !== false && stripos($pd,'Clearance processing complete') !== false)
  2500. {
  2501. $exstate = 4;//即将派送
  2502. }
  2503. else if(stripos($express[$d['express']],'UPS') !== false && stripos($pd['c'],'Louisville, KY, US') !== false && stripos($pd,'Departed from Facility') !== false)
  2504. {
  2505. $exstate = 4;//即将派送
  2506. }
  2507. else if(stripos($express[$d['express']],'GES') !== false && stripos($pd,'Shipment picked up') !== false)
  2508. {
  2509. $exstate = 4;//即将派送
  2510. }
  2511. else if(stripos($pd,'Delivery exception') !== false || stripos($pd,'Addressee Unknown') !== false || stripos($pd,'Delivered to Agent for Final Delivery') !== false || stripos($pd,'Reminder to pick up your item') !== false || stripos($pd,'Available for Pickup') !== false || stripos($pd,'Processing Exception') !== false || stripos($pd,'Return to Sender Processed') !== false || stripos($pd,'Redelivery Scheduled') !== false || stripos($pd,'Notice Left') !== false || stripos($pd,'Delivery attempted but no response at Consignee address') !== false || stripos($pd,'Delivery attempt could not be completed') !== false || stripos($pd,'Forwarded to a third party agent') !== false || stripos($pd,'Awaiting collection by the consignee') !== false || stripos($pd,'Consignee has moved from the address provided') !== false || stripos($pd,'awaiting customer pickup') !== false)
  2512. {
  2513. $exstate = 1;//异常
  2514. }
  2515. }
  2516. $awlgx = $this->awlgx->get_number($d['number']);
  2517. if($awlgx)
  2518. {
  2519. $this->awlgx->save(array("content"=>$xq,"time"=>time(),'exstate'=>$exstate,'type'=>$f),$awlgx['id']);
  2520. }
  2521. else
  2522. {
  2523. $this->awlgx->insert(array("number"=>$d['number'],"content"=>$xq,"time"=>time(),'exstate'=>$exstate,'type'=>$f));
  2524. }
  2525. if($xq != '')
  2526. {
  2527. $this->$f->save(array('expressstate'=>$exstate,'excontent'=>$xq),$d['id']);
  2528. $time = time();
  2529. if($f == 'fullorder')
  2530. {
  2531. $notice = $this->notice->find_all("message = '1' and state = '1' and type = '2' and ktime < '$time' and jtime > '$time' and shop = '".$d['shop']."' and logisticstatus = '".$exstate."'");
  2532. if($notice && $d['wlyc'] == '0' && $d['wltype'] != '1' && $d['source'] != '1' && stripos($d['wlcontent'],$notice[0]['title']) === false)
  2533. {
  2534. $this->_sdfs($d,$notice[0]['id']);
  2535. //给crm发送信息 先存储数据 后续定时任务执行
  2536. if($d['shop'] < 10){
  2537. //派送中
  2538. if($exstate == 4){
  2539. $this->zztmpdata->insert([
  2540. 'type'=>3,
  2541. 'act_name'=>'crm_order',
  2542. 'content'=>json_encode($d),
  2543. 'create_time'=>time()
  2544. ]);
  2545. }
  2546. //签收完成
  2547. if($exstate == 6){
  2548. $this->zztmpdata->insert([
  2549. 'type'=>4,
  2550. 'act_name'=>'crm_order',
  2551. 'content'=>json_encode($d),
  2552. 'create_time'=>time()
  2553. ]);
  2554. }
  2555. }
  2556. }
  2557. }
  2558. }
  2559. }
  2560. public function _dhl()//DHL
  2561. {
  2562. $data = $this->dhl->find_all("type != 1 and time > '".(time()-24*3600)."'");
  2563. foreach ($data as $v)
  2564. {
  2565. $y = $this->fullorder->get_number($v['number']);
  2566. if(!$y)
  2567. {
  2568. $y = $this->fullordertt->get_number($v['number']);
  2569. if(!$y)
  2570. {
  2571. $y = $this->fullordersmt->get_number($v['number']);
  2572. if(!$y)
  2573. {
  2574. continue;
  2575. }
  2576. }
  2577. }
  2578. //获取dhl规格
  2579. $dhl_gg_info = $this->customsdeclaration->get_ename($y['sbpm']);
  2580. if(empty($dhl_gg_info)){
  2581. continue;
  2582. }else{
  2583. $y['dhl_ggbm'] = $dhl_gg_info['dhlcode'];
  2584. }
  2585. $this->dhl->get_data_c($y,$v['id']);
  2586. }
  2587. }
  2588. }