Aatest.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436
  1. <?php defined('BASEPATH') OR exit('No direct script access allowed');
  2. class Aatest extends Start_Controller {
  3. public function __construct(){
  4. parent::__construct();
  5. $this->load->library('session');
  6. $this->load->_model('Model_whlabel','whlabel');
  7. $this->load->_model('Model_warehouse','warehouse');
  8. $this->load->_model('Model_productprice','productprice');
  9. $this->load->_model('Model_excel','excel');
  10. $this->load->_model('Model_fullorder','fullorder');
  11. $this->load->_model('Model_fullordertt','fullordertt');
  12. $this->load->_model('Model_fullordersmt','fullordersmt');
  13. $this->load->_model('Model_outbound','outbound');
  14. $this->load->_model('Model_express','express');
  15. $this->load->_model('Model_shop','shop');
  16. $this->load->_model('Model_typeclass','typeclass');
  17. $this->load->_model('Model_country','country');
  18. $this->load->_model('Model_kdniao','kdniao');
  19. $this->load->_model('Model_notice','notice');
  20. $this->load->_model('Model_dhl','dhl');
  21. $this->load->_model('Model_dhlhz','dhlhz');
  22. $this->load->_model('Model_usps','usps');
  23. $this->load->_model('Model_fedex','fedex');
  24. $this->load->_model('Model_fedex_cby','fedex_cby');
  25. $this->load->_model('Model_ups','ups');
  26. $this->load->_model('Model_ali','ali');
  27. $this->load->_model('Model_dpd','dpd');
  28. $this->load->_model('Model_shop','shop');
  29. $this->load->_model('Model_user','user');
  30. $this->load->_model('Model_whlabel','whlabel');
  31. $this->load->_model('Model_specialstock','specialstock');
  32. $this->load->_model('Model_ck','ck');
  33. $this->load->_model('Model_whlabellabel','whlabellabel');
  34. $this->load->_model('Model_apiyy','apiyy');
  35. $this->load->helper('url');
  36. $this->load->_model('Model_whlabel_fc','whlabel_fc');
  37. $this->load->_model('Model_systemtransfer','systemtransfer');
  38. $this->load->_model('Model_classid','classid');
  39. $this->load->_model('Model_allocation','allocation');
  40. $this->load->_model('Model_fullorderxw','fullorderxw');
  41. $this->load->_model('Model_fullorderpaypal','fullorderpaypal');
  42. $this->load->_model('Model_fedexv1','fedexv1');
  43. $this->load->_model('Model_logic_crm','logic_crm');
  44. $this->load->_model("Model_fullorder","fullorder");
  45. $this->load->_model("Model_express","express");
  46. $this->load->_model("Model_logic_ding","logic_ding");
  47. $this->load->_model("Model_api",'api');
  48. $this->load->_model("Model_usps",'usps');
  49. $this->load->_model('Model_emaildata','emaildata');
  50. $this->load->_model('Model_logic_tools','logic_tools');
  51. $this->load->_model('Model_logic_order','logic_order');
  52. $this->load->_model('Model_returngoods','returngoods');
  53. $this->load->_model('Model_returnlogs','returnlogs');
  54. $this->load->_model('Model_productdescribe','productdescribe');
  55. }
  56. //定义方法的调用规则 获取URI第二段值
  57. public function _remap($arg,$arg_array)
  58. {
  59. if($arg == 'fout')
  60. {
  61. $this->_fout();
  62. }else if($arg == 'waybillemail'){
  63. $this->_waybillemail();
  64. }else if($arg == 'getorder'){
  65. $this->_getorder();
  66. }elseif($arg == 'logistic'){
  67. $this->_logistic();
  68. }else{
  69. $this->_a($arg_array);
  70. }
  71. }
  72. //物流轨迹
  73. public function _logistic(){
  74. echo "<pre>";
  75. // $list = $this->fullorder->find_all("waybill = 284280923614");
  76. // var_dump($list);
  77. // die;
  78. // $v = $list[0];
  79. // $v = [
  80. // 'waybill'=>'285250961332'
  81. // ];
  82. // $fs = $this->fedexv1->get_logistics($v);
  83. // var_dump($fs);
  84. // die;
  85. // die;
  86. $list = $this->fullorder->findall("waybill = 9205590251001335234515");
  87. $v = $list['0'];
  88. @$fs = $this->usps->get_logistics($v);
  89. $csck[] = array($v['number'],$fs['f'],$fs['content']);
  90. if(!isset($fs['f']))
  91. {
  92. $fs = $this->usps->get_logistics($v);
  93. }
  94. var_dump($fs);
  95. die;
  96. }
  97. public function _getorder(){
  98. $name = 'SuperNova';
  99. $userKey = array(
  100. 'Alipearl' => array('username'=>'huchunmei','api_key'=>'huchunmei126_alipearl_erp888','url'=>'https://www.alipearlhair.com'),
  101. 'Asteria' => array('username'=>'huchunmei','api_key'=>'huchunmei126_asteria_erp888','url'=>'https://www.asteriahair.com'),
  102. 'WestKiss' => array('username'=>'huchunmei','api_key'=>'huchunmei126_westkiss_erp868','url'=>'https://www.westkiss.com'),
  103. 'SuperNova' => array('username'=>'huchunmei','api_key'=>'huchunmei126_supernova_erp6898','url'=>'https://www.supernovahair.com'),
  104. 'Wiggins' => array('username'=>'huchunmei','api_key'=>'huchunmei126_wiggins_erp652','url'=>'https://www.wigginshair.com'),
  105. 'Yolissa' => array('username'=>'huchunmei','api_key'=>'huchunmei126_yolissa_688','url'=>'https://www.yolissahair.com'),
  106. );
  107. $proxy = new SoapClient($userKey[$name]['url'].'/api/soap/?wsdl');
  108. try {
  109. $sessionId = $proxy->login($userKey[$name]['username'], $userKey[$name]['api_key']);
  110. }
  111. catch (Exception $e) {
  112. echo $e->getMessage();
  113. }
  114. $data = array('proxy'=>$proxy,'sessionId'=>$sessionId,'url'=>$userKey[$name]['url']);
  115. $fromTime = date('Y-m-d H:i:s',time()- 3600*24*6);
  116. $toTime = date('Y-m-d H:i:s',time());
  117. $filters = array(array('created_at'=>array('from'=>$fromTime,'to'=>$toTime)));
  118. $result = $data['proxy']->call($data['sessionId'],'sales_order.list',$filters);
  119. echo "<pre>";
  120. // print_r($result[0]);
  121. foreach($result as $item)
  122. {
  123. // print_r($item);exit;
  124. $iteminfo= $data['proxy']->call($data['sessionId'], 'sales_order.info', $item['increment_id']);
  125. print_r($iteminfo['items']);
  126. die;
  127. }
  128. }
  129. public function getDtc(){
  130. $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');
  131. $dtc = array();
  132. foreach ($dictionaries as $v)
  133. {
  134. if(stripos($v['spare'],'|') !== false)//如果有多个值
  135. {
  136. $v['spare'] = explode('|',$v['spare']);
  137. foreach ($v['spare'] as $k=>$vs)
  138. {
  139. if(stripos($v['zh'],'|') !== false)
  140. {
  141. $vzh = explode('|',$v['zh']);
  142. $dtc[strtolower($vs)] = array('classid'=>$v['classid'],'zh'=>$vzh[$k],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$vs);
  143. }
  144. else
  145. {
  146. $dtc[strtolower($vs)] = array('classid'=>$v['classid'],'zh'=>$v['zh'],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$vs);
  147. }
  148. }
  149. }
  150. else
  151. {
  152. $dtc[strtolower($v['spare'])] = array('classid'=>$v['classid'],'zh'=>$v['zh'],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$v['spare']);
  153. }
  154. }
  155. $dtctitle = [];
  156. $dictionaries2 = $this->typeclass->find_all();
  157. foreach ($dictionaries2 as $v)
  158. {
  159. $dtctitle[$v['id']] = $v['title'];
  160. }
  161. return [
  162. 'dtc'=>$dtc,
  163. 'dtctitle'=>$dtctitle
  164. ];
  165. }
  166. public function _a($arg_array){
  167. $list = $this->returngoods->find_all("table_type = 0");
  168. foreach($list as $k => $v){
  169. $type = $this->logic_order->getType("number = '".$v['number']."'");
  170. $this->returngoods->save([
  171. 'table_type'=>$type,
  172. ],$v['id']);
  173. }
  174. die;
  175. $data = $this->getDtc();
  176. $dtc = $data['dtc'];
  177. $dtctitle = $data['dtctitle'];
  178. $quantity = 'Loose Body--HDWig-26-HD5*5Wig-180%,WKPack';
  179. $issku = '1;1';
  180. $money = array();
  181. $productdescribe = $this->productdescribe->find_all('1=1');
  182. foreach ($productdescribe as $v)
  183. {
  184. $money[$v['number']] = array();
  185. }
  186. /* 价格加入 */
  187. /* 匹配ID加入 */
  188. $int = array();
  189. $intdata = $this->typeclass->find_all('classid=14','id,spare');
  190. foreach ($intdata as $v)
  191. {
  192. $v['spare'] = explode('|',$v['spare']);
  193. $int[$v['id']] = $v['spare'][0];
  194. }
  195. var_dump($dtc);
  196. var_dump($dtctitle);
  197. $r = $this->api->matching($quantity,$issku,$dtc,$money,$int,$dtctitle,[1],[
  198. ]);
  199. echo "<pre>";
  200. var_dump($r);
  201. die;
  202. $time = time();
  203. $jiami = "alipearlhair+".(string)$time;
  204. echo json_encode([
  205. 'shop'=>3,
  206. 'waybill'=>'283786008019',
  207. 'time'=>$time,
  208. 'key'=>$this->logic_tools->toolsjiami($jiami,"6amg!pnfrlbpnjgirv", "6ook4k!2w94m6jtm"),
  209. ]);
  210. die;
  211. $dtc = array();
  212. /* 订单号加入键值-j */
  213. /* 匹配加入 */
  214. $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');
  215. // 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)
  216. foreach ($dictionaries as $v)
  217. {
  218. if(stripos($v['spare'],'|') !== false)//如果有多个值
  219. {
  220. $v['spare'] = explode('|',$v['spare']);
  221. foreach ($v['spare'] as $k=>$vs)
  222. {
  223. if(stripos($v['zh'],'|') !== false)
  224. {
  225. $vzh = explode('|',$v['zh']);
  226. $dtc[strtolower($vs)] = array('classid'=>$v['classid'],'zh'=>$vzh[$k],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$vs);
  227. }
  228. else
  229. {
  230. $dtc[strtolower($vs)] = array('classid'=>$v['classid'],'zh'=>$v['zh'],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$vs);
  231. }
  232. }
  233. }
  234. else
  235. {
  236. $dtc[strtolower($v['spare'])] = array('classid'=>$v['classid'],'zh'=>$v['zh'],'id'=>$v['id'],'jm'=>$v['jm'],'spare'=>$v['spare']);
  237. }
  238. }
  239. $dtctitle = [];
  240. $dictionaries2 = $this->typeclass->find_all();
  241. foreach ($dictionaries2 as $v)
  242. {
  243. $dtctitle[$v['id']] = $v['title'];
  244. }
  245. echo "<pre>";
  246. $sku = "Free,Gift--PackQQS,NW--3+Ori6*6C-22 24 26-20-6*6C";
  247. $sl = "1;1;1;";
  248. $r = $this->api->matching($sl,$sku,$dtc,"","",$dtctitle,$shop=[],$extra = [
  249. "price"=>"565.7700",
  250. "row_total"=>"565.7700"
  251. ]);
  252. var_dump($r['title']);
  253. $r = $r['product'];
  254. $rr = explode(";",$r);
  255. print_r($rr);
  256. }
  257. public function _fout()
  258. {
  259. $waybill = $this->input->get('waybill');
  260. $info = $this->fullorder->get_waybill($waybill);
  261. //$r = $this->usps->get_new_logistics($info);
  262. $r = $this->fedexv1->get_logistics(123);
  263. echo "<pre>";
  264. var_dump($r);
  265. //$this->fedexv1->makeAccessToken();
  266. }
  267. public function _waybillemail()
  268. {
  269. $urls = array();$sl = 0;$time = time();
  270. $wid = 2;
  271. // if(date("H",time()) == '8' && date("i",time()) > '20' && date("i",time()) < '39')//USPS-USA单
  272. // {
  273. // $wid = 1;
  274. // }
  275. // else if(date("H",time()) == '20' && date("i",time()) > '20' && date("i",time()) < '39')//其他快递
  276. // {
  277. // $wid = 2;
  278. // }
  279. // else
  280. // {
  281. // exit;
  282. // }
  283. $notice = $this->notice->find_all("message = '1' and state = '1' and type = '4' and ktime < '$time' and jtime > '$time'");//已有自动发送,这个是物流发送
  284. foreach ($notice as $key=>$var)
  285. {
  286. $this->_waybillfs([
  287. 'var'=>$var,
  288. 'wid'=>$wid
  289. ]);
  290. }
  291. }
  292. public function upadtel(){
  293. $returngoods_id = 150;
  294. $insert_flag = 1217819;
  295. $number = 'KISS-50206-004';
  296. $returngoods_info = $this->returngoods->read($returngoods_id);
  297. $this->returngoods->save([
  298. 'status'=>80,
  299. 'back_no'=>$number,
  300. 'back_id'=>$insert_flag,
  301. 'update_time'=>date('Y-m-d H:i:s'),
  302. ],$returngoods_id);
  303. $this->returnlogs->insert([
  304. 'rg_id'=>(int)$returngoods_id,
  305. 'operat_id'=>10,
  306. 'operat_name'=>'admin',
  307. 'remark'=>"订单号:".$returngoods_info['orderinfo']."重新换货-换货新订单编码".$number,
  308. 'create_time'=>date('Y-m-d H:i:s'),
  309. ]);
  310. }
  311. public function _waybillfs($data)
  312. {
  313. if($data)
  314. {
  315. $notice = $data['var'];
  316. $notice['email'] = $this->emaildata->read($notice['email']);
  317. $wid = $data['wid'];
  318. $fsjs = "";
  319. if($wid == 1 && (stripos($notice['express'],',2,') !== false || stripos($notice['express'],',63,') !== false || stripos($notice['express'],',64,') !== false))
  320. {
  321. $js = explode(',',trim($notice['js'],','));
  322. if(count($js) > 1)
  323. {
  324. $fsjs = " and (";
  325. foreach ($js as $v)
  326. {
  327. $fsjs .= "js = '$v' or ";
  328. }
  329. $fsjs = trim($fsjs,' or ').")" ;
  330. }
  331. else if(count($js) == 1)
  332. {
  333. $fsjs = " and js = '$js[0]'";
  334. }
  335. $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
  336. }
  337. else if($wid == 2 && stripos($notice['express'],',1,') !== false)
  338. {
  339. $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
  340. }
  341. else
  342. {
  343. exit;
  344. }
  345. $this->logic_ding->sendToDing("source != '1' and dlzemail < '1' and shop = '".$notice['shop']."' and library = 2 and ".$where);
  346. // $wlfs = array();
  347. // $dd = $this->fullorder->find_all("source != '1' and dlzemail < '1' and shop = '".$notice['shop']."' and library = 2 and ".$where);
  348. // foreach($dd as $v){
  349. // $this->logic_ding->sendToDing($v['orderinfo']."监听邮件发送的异常:订单信息【".json_encode($v,JSON_UNESCAPED_UNICODE)."】");
  350. // }
  351. // foreach ($dd as $v)
  352. // {
  353. // $shop = $this->shop->read($v['shop']);
  354. // $express = $this->express->read($v['express']);
  355. // $fs = $this->notice->get_god($v,$shop,$express,$notice);
  356. // $this->logic_ding->sendToDing($v['orderinfo']."监听邮件发送的异常:订单信息【".json_encode($v,JSON_UNESCAPED_UNICODE)."】获取快递信息【".json_encode($notice,JSON_UNESCAPED_UNICODE)."】返回的信息".json_encode($fs));
  357. // if($fs == 1)
  358. // {
  359. // $this->fullorder->save(array('dlzemail'=>1,'dlzemailtime'=>time()),$v['id']);
  360. // //给crm发送信息 先存储数据 后续定时任务执行
  361. // if($v['shop'] < 10){
  362. // $this->zztmpdata->insert([
  363. // 'type'=>2,
  364. // 'act_name'=>'crm_order',
  365. // 'content'=>json_encode($v),
  366. // 'create_time'=>time()
  367. // ]);
  368. // }
  369. // }
  370. // else
  371. // {
  372. // //$pdtime = date('Y-m-d',time());
  373. // //$folderPath = './data/dlzemail/'.$pdtime; // 文件夹路径
  374. // //$permissions = 0777; // 权限设置
  375. // //if (!file_exists($folderPath)) { mkdir($folderPath, $permissions); }//创建文件夹
  376. // //file_exists($folderPath);
  377. // if(!is_file("./data/dlzemail/".$v['number'].".txt"))
  378. // {
  379. // $myfile = fopen("./data/dlzemail/".$v['number'].".txt", "w") or die("Unable to open file!");
  380. // fwrite($myfile, json_encode($fs.';'.$v.';'.$shop.';'.$express.';'.$notice));
  381. // fclose($myfile);
  382. // }
  383. // else
  384. // {
  385. // $myfile = fopen("./data/dlzemail/".$v['number'].".txt", "a+") or die("Unable to open file!");
  386. // fwrite($myfile, json_encode($fs.';'.$v.';'.$shop.';'.$express.';'.$notice));
  387. // fclose($myfile);
  388. // }
  389. // $this->fullorder->save(array('dlzemail'=>2,'dlzemailtime'=>time()),$v['id']);
  390. // }
  391. // sleep(50);
  392. // }
  393. }
  394. }
  395. }