Api.php 92 KB

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