Aatest.php 15 KB

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