Aatest.php 14 KB

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