Model_logic_u9xgsd.php 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513
  1. <?php
  2. /**
  3. * 手动处理香港小单列表的功能
  4. */
  5. class Model_logic_u9xgsd extends Lin_Model {
  6. public $xdzzcode = '130';//许昌销售公司编码
  7. public $xdcp_code = '13001';//许昌成品库的编码 测试的时候就用龙盈工厂的仓库
  8. public $xdxgzzcode = '140';//香港组织公司编码
  9. public $xdxgls_code = '14003';//香港临时库的编码 测试的时候用销售公司成品库的编码
  10. public $ztcode = '001';//账套的code;
  11. public $tb_org_arr =[101,110,130,140];//同步组织
  12. public $gys = "98002";//供应商 98001 龙盈 98002 龙熠
  13. //切记要修改token_120的token真正的token!!!!
  14. function __construct(){
  15. parent::__construct();
  16. $this->load->_model('Model_settingtest','settingtest');
  17. $this->load->_model("Model_apiyyv1",'apiyyv1');
  18. $this->load->_model('Model_classid','classid');
  19. $this->load->_model('Model_typeclass','typeclass');
  20. $this->load->_model('Model_shop','shop');
  21. $this->load->_model('Model_zzquque_u9','zzquque_u9');
  22. $this->load->_model('Model_zzququeu9_logs','zzququeu9_logs');
  23. $this->load->_model('Model_logic_tools','logic_tools');
  24. $this->load->_model('Model_logic_u9tools','logic_u9tools');
  25. $this->load->_model("Model_logic_order","logic_order");
  26. }
  27. public function getToken($type){
  28. $name = "get_yytoken_".$type;
  29. $token = $this->settingtest->$name();
  30. return $token;
  31. }
  32. //转码准备数据
  33. public function transPrepare(){
  34. $classid = $this->classid->sku();
  35. $tcall = $this->typeclass->find_all();
  36. foreach ($tcall as $v)
  37. {
  38. $tcjm[$v['id']] = array($v['jm'],$v['classid']);
  39. $typeclass[$v['id']] = array('zh'=>$v['zh'],'classid'=>$v['classid'],'bm'=>$v['bm'],'title'=>$v['title'],'jm'=>$v['jm']);
  40. }
  41. return [
  42. 'classid'=>$classid,
  43. 'typeclass'=>$typeclass,
  44. ];
  45. }
  46. //组合成要处理的数据
  47. public function createData($info){
  48. $pre_data = $this->transPrepare();
  49. $typeclass = $pre_data['typeclass'];
  50. $classid = $pre_data['classid'];
  51. $time = time();
  52. $list = [];
  53. $fpdata = $info['fpdata'];
  54. $fpdata_list = explode(';',trim( $fpdata,';'));
  55. $whlabel_list = explode("|",trim($info['whlabel'],"|"));
  56. $total_goods_num = 0;//订单产品总数量
  57. foreach($whlabel_list as $k=>$v){
  58. $tmp_data = explode("-",trim($v,'-'));
  59. if(isset($tmp_data[1])){
  60. $total_goods_num += $tmp_data[1];
  61. }
  62. }
  63. $avg_price = floor(($info['skje']*1000)/$total_goods_num)/1000;
  64. foreach($fpdata_list as $k=>$v){
  65. //礼物不占库存
  66. if(stripos($v,'-131-') !== false)
  67. {
  68. continue;
  69. }
  70. $tmp_str = str_replace(array('-163-','-164-','-165-','-166-'),'-',$v);
  71. $tmp_arr = explode('|',trim($tmp_str,'|'));
  72. if(stripos($tmp_arr[0],',') !== false){
  73. $ft = explode(',',$tmp_arr[0]);
  74. $features = explode('-',trim($ft[1],'-'));
  75. $features[] = $ft[0];
  76. }else{
  77. $features = explode('-',trim($tmp_arr[0],'-'));
  78. }
  79. $sku = implode("-",$features);
  80. $tmp_ret = $this->logic_u9tools->getOneU9bm($sku,$classid,$typeclass);
  81. $list[] = [
  82. 'jm'=>$tmp_ret['jm'],
  83. 'bm'=>$tmp_ret['bm'],
  84. 'zh'=>$tmp_ret['zh'],
  85. 'final_price'=>$avg_price,//目前先不设置 等后期财务说了再说
  86. 'title'=>isset($tmp_arr[1])?$tmp_arr[1]:'无',
  87. 'dcsl'=>$tmp_arr[2],
  88. 'is_register'=>0,//商品是否被注册 先都当没注册 后面会先确认下
  89. ];
  90. }
  91. $shop = $this->shop->read($info['shop']);
  92. if(empty($shop['yyid'])){
  93. //如果没有在u9上设置店铺的组织 那么需要设置
  94. $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'',[],$this->logic_tools->ret_arr(-1,'店铺没有在u9平台设置参数'));
  95. return ;
  96. }
  97. $dc_params = [
  98. 'gys'=>$this->gys,//供应商
  99. 'number'=>$info['number'],//erp订单编码
  100. "TransOutDocType_Code"=>"TransOut001",//组织间调拨
  101. "time"=>$time,
  102. 'TransferDirection'=>0,//普通
  103. 'yyid'=>$shop['yyid'],//来源店铺 这种需要在店铺表中有
  104. 'shipremarks'=>$info['shipremarks'],//订单的备注
  105. 'dcckbm'=>$this->xdcp_code,//调出仓库编码
  106. 'drckbm'=>$this->xdxgls_code,//调入仓库编码
  107. 'drzz_code'=>$this->xdxgzzcode,//调入组织Code
  108. 'owner_code'=>$this->xdzzcode,//货主组织Code
  109. 'ztcode'=>$this->ztcode,//账套
  110. 'tb_org_arr'=>$this->tb_org_arr,//要同步的组织列表
  111. 'list'=>$list
  112. ];
  113. return $dc_params;
  114. }
  115. //组合成要处理的数据 利用u9数据转化为提交数据 避免因为工厂出货和实际货不对版造成的
  116. public function createDataTwo($info){
  117. $tmp_list = json_decode($info['dc_data'],true);
  118. if(empty($tmp_list)){
  119. return ;
  120. }
  121. $time = time();
  122. $list = [];
  123. foreach($tmp_list as $k=>$v){
  124. $list[] = [
  125. 'jm'=>$v['iteminfo_itemcode'],
  126. 'zh'=>$v['iteminfo_itemname'],
  127. 'final_price'=>$v['costprice'],//目前先不设置 等后期财务说了再说
  128. 'dcsl'=>$v['costuomqty'],
  129. 'is_register'=>0,//商品是否被注册 先都当没注册 后面会先确认下
  130. ];
  131. }
  132. $dc_params = [
  133. 'gys'=>$this->gys,//供应商
  134. 'number'=>$info['order_no'],//erp订单编码
  135. "TransOutDocType_Code"=>"TransOut001",//组织间调拨
  136. "time"=>$time,
  137. 'TransferDirection'=>0,//普通
  138. 'yyid'=>$tmp_list[0]['descflexfield_pubdescseg2'],//来源店铺 这种需要在店铺表中有
  139. 'shipremarks'=>$tmp_list[0]['descflexfield_pubdescseg5'],//订单的备注
  140. 'dcckbm'=>$this->xdcp_code,//调出仓库编码
  141. 'drckbm'=>$this->xdxgls_code,//调入仓库编码
  142. 'drzz_code'=>$this->xdxgzzcode,//调入组织Code
  143. 'owner_code'=>$this->xdzzcode,//货主组织Code
  144. 'ztcode'=>$this->ztcode,//账套
  145. 'tb_org_arr'=>$this->tb_org_arr,//要同步的组织列表
  146. 'list'=>$list
  147. ];
  148. return $dc_params;
  149. }
  150. //创建调出单
  151. public function createDc($tmp_info){
  152. $info = $this->logic_order->getInfoByPlat($tmp_info['platform'],$tmp_info['order_no']);
  153. $info['zq_u9_id'] = $tmp_info['id'];
  154. $dc_params = $this->createData($info);
  155. //调出单检测是否存在
  156. $cxdcd_r = $this->apiyyv1->xcDcdByOtherId($dc_params['number'],$this->getToken(130));
  157. $ret_data = $cxdcd_r[0]['Data'];
  158. if(isset($ret_data[0])){
  159. $descflexfield_pubdescseg4 = $ret_data[0]['descflexfield_pubdescseg4'];
  160. if($dc_params['number'] == $descflexfield_pubdescseg4){
  161. return $this->logic_tools->ret_arr(-1,"对应的销售单已存在请勿重复操作");
  162. }
  163. }
  164. //检测料品是否在u9被添加 检测香港仓有没有 许昌仓一定要有 没有
  165. $r = $this->checkLp($dc_params,$this->getToken(140));
  166. if($r['code'] !=1){
  167. $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'lpck',$r['msg'][1],$r['msg'][0]);
  168. return $this->logic_tools->ret_arr(-1,"同步料品失败");
  169. }
  170. //创建调出单
  171. $dcd_res = $this->apiyyv1->dcdCrate($dc_params,$this->getToken(130));
  172. if(empty($dcd_res[0]['Data'][0]["Code"])){
  173. $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'dc',$dcd_res[1],$dcd_res[0]);
  174. return $this->logic_tools->ret_arr(-1,"创建调出单失败");
  175. }
  176. //更新
  177. $dcd_no = $dcd_res[0]['Data'][0]["Code"];
  178. $this->editData($info['zq_u9_id'],['dc_no'=>$dcd_no,'dc_status'=>1,'update_time'=>time()],$info['number'],1,1,'dc',$dcd_res[1],$dcd_res[0]);
  179. return $this->logic_tools->ret_arr(1,"创建调出单成功");
  180. }
  181. //提交调出单
  182. public function subDc($info){
  183. $r = $this->apiyyv1->dcdSubmit([
  184. 'number'=>$info['dc_no']
  185. ],$this->getToken(130));
  186. if(!$r[0]['Data'][0]['IsSucess']){
  187. $this->editData($info['id'],['dc_status'=>-2,'update_time'=>time()],$info['order_no'],1,2,'dc',$r[1],$r[0]);
  188. return $this->logic_tools->ret_arr(-1,"提交调出单失败");
  189. }
  190. //更新调出单
  191. $this->editData($info['id'],['dc_status'=>2,'update_time'=>time()],$info['order_no'],1,2,'dc',$r[1],$r[0]);
  192. return $this->logic_tools->ret_arr(1,"提交调出单失败");
  193. }
  194. //审核调出单
  195. public function shDc($info){
  196. $rr = $this->apiyyv1->dcdApprove([
  197. 'number'=>$info['dc_no']
  198. ],$this->getToken(130));
  199. if(!$rr[0]['Data'][0]['IsSucess']){
  200. $this->editData($info['id'],['dc_status'=>-3,'update_time'=>time()],$info['order_no'],1,3,'dc',$rr[1],$rr[0]);
  201. return $this->logic_tools->ret_arr(-1,"审核调出单失败");
  202. }
  203. $this->editData($info['id'],['dc_status'=>3,'update_time'=>time()],$info['order_no'],1,3,'dc',$rr[1],$rr[0]);
  204. return $this->logic_tools->ret_arr(1,"审核调出单成功");
  205. }
  206. //创建采购单
  207. public function createCg($info){
  208. //在创建前边执行查询调出单
  209. if($info['dc_data_status'] != 1)
  210. {
  211. $r = $this->xdlsCxDcd($info);
  212. if($r['code']!= 1){
  213. return $this->logic_tools->ret_arr(-1,"调出单未被审核,请先去审核");
  214. }
  215. $info['dc_data'] = json_encode($r['data']['data']);
  216. }
  217. $dc_params = $this->createData($info);
  218. echo "<pre>";
  219. var_dump($dc_params);
  220. die;
  221. //创建香港公司的采购单
  222. $cgd_res = $this->apiyyv1->cgdCreate($dc_params,$this->getToken(140));
  223. if(empty($cgd_res[0]['Data'][0]["Code"])){
  224. $this->editData($info['id'],['cg_status'=>-1,'update_time'=>time()],$info['order_no'],3,1,'cg',$cgd_res[1],$cgd_res[0]);
  225. return $this->logic_tools->ret_arr(-1,"创建采购单失败");
  226. }
  227. $this->editData($info['id'],['cg_no'=>$cgd_res[0]['Data'][0]["Code"],'cg_status'=>1,'update_time'=>time()],$info['order_no'],3,1,'cg',$cgd_res[1],$cgd_res[0]);
  228. return $this->logic_tools->ret_arr(1,"创建采购单成功");
  229. }
  230. //提交采购单
  231. public function subCg($info){
  232. $r = $this->apiyyv1->cgdSubmit([
  233. 'number'=>$info['cg_no']
  234. ],$this->getToken(140));
  235. if(!$r[0]['Data'][0]['IsSucess']){
  236. $this->editData($info['id'],['cg_status'=>-2,'update_time'=>time()],$info['order_no'],3,2,'cg',$r[1],$r[0]);
  237. return $this->logic_tools->ret_arr(-1,"提交采购单失败");
  238. }
  239. //更新采购单
  240. $this->editData($info['id'],['cg_status'=>2,'update_time'=>time()],$info['order_no'],3,2,'cg',$r[1],$r[0]);
  241. return $this->logic_tools->ret_arr(1,"提交采购单成功");
  242. }
  243. //审核采购单
  244. public function shCg($info){
  245. $rr = $this->apiyyv1->cgdApprove([
  246. 'number'=>$info['cg_no']
  247. ],$this->getToken(140));
  248. if(!$rr[0]['Data'][0]['IsSucess']){
  249. $this->editData($info['id'],['cg_status'=>-3,'update_time'=>time()],$info['order_no'],3,3,'cg',$rr[1],$rr[0]);
  250. return $this->logic_tools->ret_arr(-1,"审核采购单失败");
  251. }
  252. $this->editData($info['id'],['cg_status'=>3,'update_time'=>time()],$info['order_no'],3,3,'cg',$rr[1],$rr[0]);
  253. return $this->logic_tools->ret_arr(1,"审核采购单成功");
  254. }
  255. //创建销售单
  256. public function createXs($tmp_info){
  257. $info = $this->logic_order->getInfoByPlat($tmp_info['platform'],$tmp_info['order_no']);
  258. $info['zq_u9_id'] = $tmp_info['id'];
  259. $dc_params = $this->createData($info);
  260. //创建许昌成品库的销售单
  261. $xsd_res = $this->apiyyv1->xsdCreate($dc_params,$this->getToken(130));
  262. if(empty($xsd_res[0]['Data'][0]['m_code'])){
  263. $this->editData($info['zq_u9_id'],['xs_status'=>-1,'update_time'=>time()],$info['number'],2,1,'xs',$xsd_res[1],$xsd_res[0]);
  264. return $this->logic_tools->ret_arr(-1,"创建销售单失败");
  265. }
  266. //更新销售单数据
  267. $xs_no = $xsd_res[0]['Data'][0]["m_code"];
  268. $this->editData($info['zq_u9_id'],['xs_no'=>$xs_no,'xs_status'=>1,'update_time'=>time()],$info['number'],2,1,'xs',$xsd_res[1],$xsd_res[0]);
  269. return $this->logic_tools->ret_arr(1,"创建销售单成功");
  270. }
  271. //提交销售单
  272. public function subXs($info){
  273. $r = $this->apiyyv1->xsdSubmit([
  274. 'number'=>$info['xs_no']
  275. ],$this->getToken(130));
  276. if(!$r[0]['Data'][0]['m_isSucess']){
  277. $this->editData($info['id'],['xs_status'=>-2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  278. return $this->logic_tools->ret_arr(-1,"提交销售单成功");
  279. }
  280. $this->editData($info['id'],['xs_status'=>2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  281. return $this->logic_tools->ret_arr(1,"提交销售单成功");
  282. }
  283. //审核销售单
  284. public function shXs($info){
  285. $rr = $this->apiyyv1->xsdApprove([
  286. 'number'=>$info['xs_no']
  287. ],$this->getToken(130));
  288. if(!$rr[0]['Data'][0]['m_isSucess']){
  289. $this->editData($info['id'],['xs_status'=>-3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  290. return $this->logic_tools->ret_arr(-1,"审核销售单成功");
  291. }
  292. $this->editData($info['id'],['xs_status'=>3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  293. return $this->logic_tools->ret_arr(1,"审核销售单成功");
  294. }
  295. //创建关联销售单
  296. public function createXsTwo($tmp_info){
  297. $info = $this->logic_order->getInfoByPlat($tmp_info['platform'],$tmp_info['order_no']);
  298. $info['zq_u9_id'] = $tmp_info['id'];
  299. $dc_params = $this->createData($info);
  300. //创建香港仓的销售单
  301. $xsd_res = $this->apiyyv1->xsdCreate($dc_params,$this->getToken(140));
  302. if(empty($xsd_res[0]['Data'][0]['m_code'])){
  303. $this->editData($info['zq_u9_id'],['xs_two_status'=>-1,'update_time'=>time()],$info['number'],7,1,'xs_two',$xsd_res[1],$xsd_res[0]);
  304. return $this->logic_tools->ret_arr(-1,"创建香港销售单失败");
  305. }
  306. //更新销售单数据
  307. $xs_no = $xsd_res[0]['Data'][0]["m_code"];
  308. $this->editData($info['zq_u9_id'],['xs_two_no'=>$xs_no,'xs_two_status'=>1,'update_time'=>time()],$info['number'],7,1,'xs_two',$xsd_res[1],$xsd_res[0]);
  309. return $this->logic_tools->ret_arr(1,"创建香港销售单成功");
  310. }
  311. //提交审关联销售单
  312. public function subXsTwo($info){
  313. $r = $this->apiyyv1->xsdSubmit([
  314. 'number'=>$info['xs_two_no']
  315. ],$this->getToken(140));
  316. if(!$r[0]['Data'][0]['m_isSucess']){
  317. $this->editData($info['id'],['xs_two_status'=>-2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  318. return $this->logic_tools->ret_arr(-1,"提交香港销售单失败");
  319. }
  320. $this->editData($info['id'],['xs_two_status'=>2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  321. return $this->logic_tools->ret_arr(1,"提交香港销售单成功");
  322. }
  323. //审核关联销售单
  324. public function shXsTwo($info){
  325. $rr = $this->apiyyv1->xsdApprove([
  326. 'number'=>$info['xs_two_no']
  327. ],$this->getToken(140));
  328. if(!$rr[0]['Data'][0]['m_isSucess']){
  329. $this->editData($info['id'],['xs_two_status'=>-3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  330. return $this->logic_tools->ret_arr(-1,"审核香港销售单失败");
  331. }
  332. $this->editData($info['id'],['xs_two_status'=>3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  333. return $this->logic_tools->ret_arr(1,"审核香港销售单成功");
  334. }
  335. //创建出货单
  336. public function createCh($info){
  337. $r = $this->apiyyv1->xscsByordernos([$info['xs_two_no']],$this->getToken(140));
  338. if(empty($r[0]['Data'])){
  339. return ;
  340. }
  341. $tmp_list = [];
  342. foreach($r[0]['Data'] as $k=>$v){
  343. $v['dcsl'] = $v['shipplanqtypu'];
  344. $tmp_list[$v['docno']][] = $v;
  345. }
  346. $list = [$info];
  347. $final_list = [];
  348. foreach($tmp_list as $k=>$v){
  349. foreach($list as $item){
  350. if($item['xs_two_no'] == $k){
  351. $final_list[] = [
  352. 'zq_u9_id'=>$item['id'],
  353. 'drckbm'=>$this->xdxgls_code,
  354. 'number'=>$item['order_no'],
  355. 'order_no'=>$item['order_no'],
  356. 'xs_no'=>$k,
  357. 'xs_two_no'=>$k,
  358. 'list'=>$v
  359. ];
  360. }
  361. }
  362. }
  363. $do_data = $final_list[0];
  364. $bzch_res = $this->apiyyv1->bzchCreate($do_data,$this->getToken(140));
  365. if(empty($bzch_res[0]['Data'][0]['m_code'])){
  366. $this->editData($info['id'],['bzch_status'=>-1,'update_time'=>time()],$info['order_no'],4,1,'bzch',$bzch_res[1],$bzch_res[0]);
  367. return $this->logic_tools->ret_arr(-1,"创建标准出货单失败");
  368. }
  369. //更新销售单数据
  370. $bzch_no = $bzch_res[0]['Data'][0]["m_code"];
  371. $this->editData($info['id'],['bzch_no'=>$bzch_no,'bzch_status'=>1,'update_time'=>time()],$info['order_no'],4,1,'bzch',$bzch_res[1],$bzch_res[0]);
  372. return $this->logic_tools->ret_arr(1,"创建标准出货单成功");
  373. }
  374. //提交并审核出货单
  375. public function subAndShCh($info){
  376. $bzch_res = $this->apiyyv1->bzchSubmitAndApprove(['number'=>$info['bzch_no']],$this->getToken(140));
  377. if(empty($bzch_res[0]['Data'][0]['m_code'])){
  378. $this->editData($info['id'],['bzch_status'=>-3,'update_time'=>time()],$info['order_no'],4,3,'bzch',$bzch_res[1],$bzch_res[0]);
  379. return $this->logic_tools->ret_arr(-1,"提交标准出货单失败");
  380. }
  381. //更新销售单数据
  382. $bzch_no = $bzch_res[0]['Data'][0]["m_code"];
  383. $this->editData($info['id'],['bzch_no'=>$bzch_no,'bzch_status'=>3,'update_time'=>time()],$info['order_no'],4,3,'bzch',$bzch_res[1],$bzch_res[0]);
  384. return $this->logic_tools->ret_arr(1,"提交标准出货单成功");
  385. }
  386. //查询调入单
  387. public function createDr($info){
  388. $r = $this->apiyyv1->drdcxBydcd($info['dc_no'],$this->getToken(140));
  389. //如果获取对应调入单没有成功
  390. if(empty($r[0]['Data'][0]['docno'])){
  391. $this->editData($info['id'],['dr_status'=>-1,'update_time'=>time()],$info['order_no'],6,1,'dr',$r[1],$r[0]);
  392. return $this->logic_tools->ret_arr(-1,"审核标准出货单失败");
  393. }
  394. $dr_no = $r[0]['Data'][0]["docno"];
  395. $this->editData($info['id'],['dr_no'=>$dr_no,'dr_status'=>1,'update_time'=>time()],$info['order_no'],6,1,'dr',$r[1],$r[0]);
  396. return $this->logic_tools->ret_arr(1,"审核标准出货单成功");
  397. }
  398. //提交调入单
  399. public function subDr($info){
  400. //提交调入单
  401. $rr = $this->apiyyv1->drdSubmit(['number'=>$info['dr_no']],$this->getToken(140));
  402. if(!$rr[0]['Data'][0]['IsSucess']){
  403. $this->editData($info['id'],['dr_status'=>-2,'update_time'=>time()],$info['order_no'],6,2,'dr',$rr[1],$rr[0]);
  404. return $this->logic_tools->ret_arr(-1,"提交调入单失败");
  405. }
  406. $this->editData($info['id'],['dr_status'=>2,'update_time'=>time()],$info['order_no'],6,2,'dr',$rr[1],$rr[0]);
  407. return $this->logic_tools->ret_arr(1,"提交调入单成功");
  408. }
  409. //审核调入单
  410. public function shDr($info){
  411. //审核调入单
  412. $rrr = $this->apiyyv1->drdApprove(['number'=>$info['dr_no']],$this->getToken(140));
  413. if(!$rrr[0]['Data'][0]['IsSucess']){
  414. $this->editData($info['id'],['dr_status'=>-3,'update_time'=>time()],$info['order_no'],6,3,'dr',$rrr[1],$rrr[0]);
  415. return $this->logic_tools->ret_arr(-1,"审核调入单失败");
  416. }
  417. $this->editData($info['id'],['dr_status'=>3,'update_time'=>time()],$info['order_no'],6,3,'dr',$rrr[1],$rrr[0]);
  418. return $this->logic_tools->ret_arr(1,"审核调入单成功");
  419. }
  420. //检查u9编码是否存在 如果不存在 请先添加并
  421. protected function checkLp($info,$token){
  422. //未注册的货品的列表
  423. $unregister_goods = [];
  424. $r = $this->apiyyv1->cxLp($info['list'],$token);
  425. if(!$r[0]['Success']){
  426. return $this->logic_tools->ret_arr(-1,'查询商品信息异常'.json_encode($r,JSON_UNESCAPED_UNICODE));
  427. }
  428. foreach($r[0]['Data'] as $k=>$v)
  429. {
  430. foreach($info['list'] as $kk => $vv){
  431. if($v['m_code'] == $vv['jm']){
  432. $info['list'][$kk]['is_register'] = 1;
  433. }
  434. }
  435. }
  436. foreach($info['list'] as $k => $v){
  437. if($v['is_register'] == 0){
  438. $unregister_goods[] = $v;
  439. }
  440. }
  441. if(empty($unregister_goods)){
  442. return $this->logic_tools->ret_arr(1,"料品无异常");
  443. }
  444. $tb_info = $info;
  445. $tb_info['list'] = $unregister_goods;
  446. // //return $this->tbXgLp($tb_info,$token);
  447. return $this->tbXgLp($tb_info);
  448. }
  449. //将许昌仓的料品同步到香港仓
  450. public function tbXgLp($tb_info){
  451. $rr = $this->apiyyv1->tbLp($tb_info,$this->getToken(130));
  452. if($rr[0]['Success']){
  453. return $this->logic_tools->ret_arr(1,$rr);
  454. }else{
  455. return $this->logic_tools->ret_arr(-1,$rr);
  456. }
  457. }
  458. //根据返回的状态修改对应的值
  459. protected function editData($zq_u9_id,$z_qu_arr,$number,$one_type,$two_type,$apply_api,$apply_data,$ret_data){
  460. $this->zzquque_u9->save($z_qu_arr,$zq_u9_id);
  461. $this->zzququeu9_logs->insert([
  462. 'oid'=>$zq_u9_id,
  463. 'number'=>$number,
  464. 'one_type'=>$one_type,
  465. 'two_type'=>$two_type,
  466. 'apply_api'=>$apply_api,
  467. 'apply_data'=>json_encode($apply_data,JSON_UNESCAPED_UNICODE),
  468. 'ret_data'=>json_encode($ret_data,JSON_UNESCAPED_UNICODE),
  469. 'create_time'=>time(),
  470. 'read_time'=>date("Y-m-d H:i:s")
  471. ]);
  472. }
  473. //调出单查询并保存
  474. public function xdlsCxDcd($info){
  475. $r = $this->apiyyv1->xdlsCxDcd($info['dc_no'],$this->getToken(130));
  476. if(empty($r[0]['Data'])){
  477. return $this->logic_tools->ret_arr(-1,"该订单还未被审核,请先去审核");
  478. }
  479. //更新销售单数据
  480. $xs_no = json_encode($r[0]['Data']);
  481. $this->editData($info['id'],['dc_data'=>$xs_no,'dc_data_status'=>1,'dc_status'=>3,'update_time'=>time()],$info['order_no'],8,1,'dc_xc',$r[1],$r[0]);
  482. return $this->logic_tools->ret_arr(1,"审核成功",$r[0]);
  483. }
  484. }