Model_logic_u9xg.php 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550
  1. <?php
  2. /**
  3. * 此模型是为了支持从许昌销售公司调出库存到香港公司仓库的功能支持
  4. */
  5. class Model_logic_u9xg 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. }
  26. public function getToken($type){
  27. $name = "get_yytoken_".$type;
  28. $token = $this->settingtest->$name();
  29. return $token;
  30. }
  31. //转码准备数据
  32. public function transPrepare(){
  33. $classid = $this->classid->sku();
  34. $tcall = $this->typeclass->find_all();
  35. foreach ($tcall as $v)
  36. {
  37. $tcjm[$v['id']] = array($v['jm'],$v['classid']);
  38. $typeclass[$v['id']] = array('zh'=>$v['zh'],'classid'=>$v['classid'],'bm'=>$v['bm'],'title'=>$v['title'],'jm'=>$v['jm']);
  39. }
  40. return [
  41. 'classid'=>$classid,
  42. 'typeclass'=>$typeclass,
  43. ];
  44. }
  45. //必须先建立许昌成品仓的销售单和调出单 香港仓的采购单 一次执行5单
  46. //循环执行许昌成品仓的销售单 调出单和香港仓的采购单
  47. public function xdlsOneStep($list){
  48. $pre_data = $this->transPrepare();
  49. foreach($list as $k=>$v){
  50. $this->xdlsBeforeCreate($v,$pre_data['typeclass'],$pre_data['classid']);
  51. }
  52. }
  53. //修正原来的逻辑 调出单审核完成后才可以在批量执行后续订单
  54. public function xdlsOneExtraStep($list){
  55. foreach($list as $k=>$v){
  56. $this->xdlsCxDcd($v);
  57. }
  58. }
  59. //循环执行许昌仓的销售单 调出单和香港仓的采购单 提交 顺带的也执行审核
  60. public function xdlsTwoStep($list){
  61. foreach($list as $k=>$v){
  62. $r1 = $this->dcSubAndCheck($v);
  63. if(!$r1){
  64. continue;
  65. }
  66. $r2 = $this->cgSubAndCheck($v);
  67. if(!$r2){
  68. continue;
  69. }
  70. $this->xsSubAndCheck($v);
  71. }
  72. }
  73. //查询调出单生成的调入单是否生成 如果生成了就审核 如果没生成 说明异常了 这种都是按步骤走的
  74. public function xdlsThreeStep($list){
  75. foreach($list as $k=>$v){
  76. $r = $this->apiyyv1->drdcxBydcd($v['dc_no'],$this->getToken(140));
  77. //如果获取对应调入单没有成功
  78. if(empty($r[0]['Data'][0]['docno'])){
  79. $this->editData($v['id'],['dr_status'=>-1,'update_time'=>time()],$v['order_no'],6,1,'dr',$r[1],$r[0]);
  80. continue;
  81. }
  82. $dr_no = $r[0]['Data'][0]["docno"];
  83. $this->editData($v['id'],['dr_no'=>$dr_no,'dr_status'=>1,'update_time'=>time()],$v['order_no'],6,1,'dr',$r[1],$r[0]);
  84. //提交调入单
  85. $rr = $this->apiyyv1->drdSubmit(['number'=>$dr_no],$this->getToken(140));
  86. if(!$rr[0]['Data'][0]['IsSucess']){
  87. $this->editData($v['id'],['dr_status'=>-2,'update_time'=>time()],$v['order_no'],6,2,'dr',$rr[1],$rr[0]);
  88. continue;
  89. }
  90. $this->editData($v['id'],['dr_status'=>2,'update_time'=>time()],$v['order_no'],6,2,'dr',$rr[1],$rr[0]);
  91. //审核调入单
  92. $rrr = $this->apiyyv1->drdApprove(['number'=>$dr_no],$this->getToken(140));
  93. if(!$rrr[0]['Data'][0]['IsSucess']){
  94. $this->editData($v['id'],['dr_status'=>-3,'update_time'=>time()],$v['order_no'],6,3,'dr',$rrr[1],$rrr[0]);
  95. continue;
  96. }
  97. $this->editData($v['id'],['dr_status'=>3,'update_time'=>time()],$v['order_no'],6,3,'dr',$rrr[1],$rrr[0]);
  98. }
  99. }
  100. //建立香港的销售单 标准出库单有源的需要先审核
  101. public function xdlsFourStep($list){
  102. $pre_data = $this->transPrepare();
  103. foreach($list as $k=>$v){
  104. $this->xdlsAfterDetail($v,$pre_data['typeclass'],$pre_data['classid']);
  105. }
  106. }
  107. //审核香港销售单 同时生成标准出库单
  108. public function xdlsFiveStep($list){
  109. $xs_no_list = array_column($list,'xs_two_no');
  110. $r = $this->apiyyv1->xscsByordernos($xs_no_list,$this->getToken(140));
  111. if(empty($r[0]['Data'])){
  112. return ;
  113. }
  114. $tmp_list = [];
  115. foreach($r[0]['Data'] as $k=>$v){
  116. $v['dcsl'] = $v['shipplanqtypu'];
  117. $tmp_list[$v['docno']][] = $v;
  118. }
  119. $final_list = [];
  120. foreach($tmp_list as $k=>$v){
  121. foreach($list as $item){
  122. if($item['xs_two_no'] == $k){
  123. $final_list[] = [
  124. 'zq_u9_id'=>$item['id'],
  125. 'drckbm'=>$this->xdxgls_code,
  126. 'number'=>$item['order_no'],
  127. 'order_no'=>$item['order_no'],
  128. 'xs_no'=>$k,
  129. 'xs_two_no'=>$k,
  130. 'list'=>$v
  131. ];
  132. }
  133. }
  134. }
  135. foreach($final_list as $info){
  136. $this->xdlsFiveStepAfter($info);
  137. }
  138. }
  139. public function xdlsFiveStepAfter($info){
  140. //先审核 然后在执行
  141. $r = $this->xsSubAndCheck140($info);
  142. if(!$r){
  143. return ;
  144. }
  145. $bzch_res = $this->apiyyv1->bzchCreate($info,$this->getToken(140));
  146. if(empty($bzch_res[0]['Data'][0]['m_code'])){
  147. $this->editData($info['zq_u9_id'],['bzch_status'=>-1,'update_time'=>time()],$info['number'],4,1,'bzch',$bzch_res[1],$bzch_res[0]);
  148. return ;
  149. }
  150. //更新销售单数据
  151. $bzch_no = $bzch_res[0]['Data'][0]["m_code"];
  152. $this->editData($info['zq_u9_id'],['bzch_no'=>$bzch_no,'bzch_status'=>1,'update_time'=>time()],$info['number'],4,1,'bzch',$bzch_res[1],$bzch_res[0]);
  153. }
  154. //审核香港标准出库单
  155. public function xdlsSixStep($list){
  156. foreach($list as $k =>$v){
  157. $bzch_res = $this->apiyyv1->bzchSubmitAndApprove(['number'=>$v['bzch_no']],$this->getToken(140));
  158. if(empty($bzch_res[0]['Data'][0]['m_code'])){
  159. $this->editData($v['id'],['bzch_status'=>-3,'update_time'=>time()],$v['order_no'],4,3,'bzch',$bzch_res[1],$bzch_res[0]);
  160. return ;
  161. }
  162. //更新销售单数据
  163. $bzch_no = $bzch_res[0]['Data'][0]["m_code"];
  164. $this->editData($v['id'],['bzch_no'=>$bzch_no,'bzch_status'=>3,'update_time'=>time()],$v['order_no'],4,3,'bzch',$bzch_res[1],$bzch_res[0]);
  165. }
  166. }
  167. //由于调出单生成可能不会申请后实时出现 需要差几分钟再去申请,避免这种错误
  168. //从许昌成品库调出库存到香港临时仓
  169. //创建 调出单 销售单 采购单
  170. //必须先建立许昌成品仓的销售单和调出单 香港仓的采购单 因为u9生成需要时间 然后在进行 审核
  171. public function xdlsBeforeCreate($info,$typeclass,$classid){
  172. $time = time();
  173. $list = [];
  174. $fpdata = $info['fpdata'];
  175. $fpdata_list = explode(';',trim( $fpdata,';'));
  176. $whlabel_list = explode("|",trim($info['whlabel'],"|"));
  177. $total_goods_num = 0;//订单产品总数量
  178. foreach($whlabel_list as $k=>$v){
  179. $tmp_data = explode("-",trim($v,'-'));
  180. if(isset($tmp_data[1])){
  181. $total_goods_num += $tmp_data[1];
  182. }
  183. }
  184. $avg_price = floor(($info['skje']*1000)/$total_goods_num)/1000;
  185. foreach($fpdata_list as $k=>$v){
  186. $tmp_str = str_replace(array('-163-','-164-','-165-','-166-'),'-',$v);
  187. $tmp_arr = explode('|',trim($tmp_str,'|'));
  188. if(stripos($tmp_arr[0],',') !== false){
  189. $ft = explode(',',$tmp_arr[0]);
  190. $features = explode('-',trim($ft[1],'-'));
  191. $features[] = $ft[0];
  192. }else{
  193. $features = explode('-',trim($tmp_arr[0],'-'));
  194. }
  195. $sku = implode("-",$features);
  196. $tmp_ret = $this->logic_u9tools->getOneU9bm($sku,$classid,$typeclass);
  197. $list[] = [
  198. 'jm'=>$tmp_ret['jm'],
  199. 'bm'=>$tmp_ret['bm'],
  200. 'zh'=>$tmp_ret['zh'],
  201. 'final_price'=>$avg_price,//目前先不设置 等后期财务说了再说
  202. 'title'=>isset($tmp_arr[1])?$tmp_arr[1]:'无',
  203. 'dcsl'=>$tmp_arr[2],
  204. 'is_register'=>0,//商品是否被注册 先都当没注册 后面会先确认下
  205. ];
  206. }
  207. $shop = $this->shop->read($info['shop']);
  208. if(empty($shop['yyid'])){
  209. //如果没有在u9上设置店铺的组织 那么需要设置
  210. $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'',[],$this->logic_tools->ret_arr(-1,'店铺没有在u9平台设置参数'));
  211. return ;
  212. }
  213. $dc_params = [
  214. 'gys'=>$this->gys,//供应商
  215. 'number'=>$info['number'],//erp订单编码
  216. "TransOutDocType_Code"=>"TransOut001",//组织间调拨
  217. "time"=>$time,
  218. 'TransferDirection'=>0,//普通
  219. 'yyid'=>$shop['yyid'],//来源店铺 这种需要在店铺表中有
  220. 'shipremarks'=>$info['shipremarks'],//订单的备注
  221. 'dcckbm'=>$this->xdcp_code,//调出仓库编码
  222. 'drckbm'=>$this->xdxgls_code,//调入仓库编码
  223. 'drzz_code'=>$this->xdxgzzcode,//调入组织Code
  224. 'owner_code'=>$this->xdzzcode,//货主组织Code
  225. 'ztcode'=>$this->ztcode,//账套
  226. 'tb_org_arr'=>$this->tb_org_arr,//要同步的组织列表
  227. 'list'=>$list
  228. ];
  229. //调出单检测是否存在
  230. $cxdcd_r = $this->apiyyv1->xcDcdByOtherId($dc_params['number'],$this->getToken(130));
  231. $ret_data = $cxdcd_r[0]['Data'];
  232. if(isset($ret_data[0])){
  233. $descflexfield_pubdescseg4 = $ret_data[0]['descflexfield_pubdescseg4'];
  234. if($dc_params['number'] == $descflexfield_pubdescseg4){
  235. return ;
  236. }
  237. }
  238. //检测料品是否在u9被添加 检测香港仓有没有 许昌仓一定要有 没有
  239. $r = $this->checkLp($dc_params,$this->getToken(140));
  240. if($r['code'] !=1){
  241. $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'lpck',[],$r['msg']);
  242. return ;
  243. }
  244. //创建调出单
  245. $dcd_res = $this->apiyyv1->dcdCrate($dc_params,$this->getToken(130));
  246. if(empty($dcd_res[0]['Data'][0]["Code"])){
  247. $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'dc',$dcd_res[1],$dcd_res[0]);
  248. return ;
  249. }
  250. //更新
  251. $dcd_no = $dcd_res[0]['Data'][0]["Code"];
  252. $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]);
  253. // //创建许昌成品库的销售单
  254. // $xsd_res = $this->apiyyv1->xsdCreate($dc_params,$this->getToken(130));
  255. // if(empty($xsd_res[0]['Data'][0]['m_code'])){
  256. // $this->editData($info['zq_u9_id'],['xs_status'=>-1,'update_time'=>time()],$info['number'],2,1,'xs',$xsd_res[1],$xsd_res[0]);
  257. // return ;
  258. // }
  259. // //更新销售单数据
  260. // $xs_no = $xsd_res[0]['Data'][0]["m_code"];
  261. // $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]);
  262. // //创建香港公司的采购单
  263. // $cgd_res = $this->apiyyv1->cgdCreate($dc_params,$this->getToken(140));
  264. // if(empty($cgd_res[0]['Data'][0]["Code"])){
  265. // $this->editData($info['zq_u9_id'],['cg_status'=>-1,'update_time'=>time()],$info['number'],3,1,'cg',$cgd_res[1],$cgd_res[0]);
  266. // return ;
  267. // }
  268. // $this->editData($info['zq_u9_id'],['cg_no'=>$cgd_res[0]['Data'][0]["Code"],'cg_status'=>1,'update_time'=>time()],$info['number'],3,1,'cg',$cgd_res[1],$cgd_res[0]);
  269. return ;
  270. }
  271. // 提交审核调出单调出单
  272. public function dcSubAndCheck($info){
  273. $r = $this->apiyyv1->dcdSubmit([
  274. 'number'=>$info['dc_no']
  275. ],$this->getToken(130));
  276. if(!$r[0]['Data'][0]['IsSucess']){
  277. $this->editData($info['id'],['dc_status'=>-2,'update_time'=>time()],$info['order_no'],1,2,'dc',$r[1],$r[0]);
  278. return false;
  279. }
  280. //更新调出单
  281. $this->editData($info['id'],['dc_status'=>2,'update_time'=>time()],$info['order_no'],1,2,'dc',$r[1],$r[0]);
  282. $rr = $this->apiyyv1->dcdApprove([
  283. 'number'=>$info['dc_no']
  284. ],$this->getToken(130));
  285. if(!$rr[0]['Data'][0]['IsSucess']){
  286. $this->editData($info['id'],['dc_status'=>-3,'update_time'=>time()],$info['order_no'],1,3,'dc',$rr[1],$rr[0]);
  287. return false;
  288. }
  289. $this->editData($info['id'],['dc_status'=>3,'update_time'=>time()],$info['order_no'],1,3,'dc',$rr[1],$rr[0]);
  290. return true;
  291. }
  292. //提交审核采购单
  293. public function cgSubAndCheck($info){
  294. $r = $this->apiyyv1->cgdSubmit([
  295. 'number'=>$info['cg_no']
  296. ],$this->getToken(140));
  297. if(!$r[0]['Data'][0]['IsSucess']){
  298. $this->editData($info['id'],['cg_status'=>-2,'update_time'=>time()],$info['order_no'],3,2,'cg',$r[1],$r[0]);
  299. return false;
  300. }
  301. //更新采购单
  302. $this->editData($info['id'],['cg_status'=>2,'update_time'=>time()],$info['order_no'],3,2,'cg',$r[1],$r[0]);
  303. $rr = $this->apiyyv1->cgdApprove([
  304. 'number'=>$info['cg_no']
  305. ],$this->getToken(140));
  306. if(!$rr[0]['Data'][0]['IsSucess']){
  307. $this->editData($info['id'],['cg_status'=>-3,'update_time'=>time()],$info['order_no'],3,3,'cg',$rr[1],$rr[0]);
  308. return false;
  309. }
  310. $this->editData($info['id'],['cg_status'=>3,'update_time'=>time()],$info['order_no'],3,3,'cg',$rr[1],$rr[0]);
  311. return true;
  312. }
  313. //提交审核销售单
  314. public function xsSubAndCheck($info){
  315. $r = $this->apiyyv1->xsdSubmit([
  316. 'number'=>$info['xs_no']
  317. ],$this->getToken(130));
  318. if(!$r[0]['Data'][0]['m_isSucess']){
  319. $this->editData($info['id'],['xs_status'=>-2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  320. return false;
  321. }
  322. $this->editData($info['id'],['xs_status'=>2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  323. $rr = $this->apiyyv1->xsdApprove([
  324. 'number'=>$info['xs_no']
  325. ],$this->getToken(130));
  326. if(!$rr[0]['Data'][0]['m_isSucess']){
  327. $this->editData($info['id'],['xs_status'=>-3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  328. return false;
  329. }
  330. $this->editData($info['id'],['xs_status'=>3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  331. return true;
  332. }
  333. public function xsSubAndCheck140($info){
  334. $r = $this->apiyyv1->xsdSubmit([
  335. 'number'=>$info['xs_two_no']
  336. ],$this->getToken(140));
  337. if(!$r[0]['Data'][0]['m_isSucess']){
  338. $this->editData($info['zq_u9_id'],['xs_two_status'=>-2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  339. return false;
  340. }
  341. $this->editData($info['zq_u9_id'],['xs_two_status'=>2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  342. $rr = $this->apiyyv1->xsdApprove([
  343. 'number'=>$info['xs_two_no']
  344. ],$this->getToken(140));
  345. if(!$rr[0]['Data'][0]['m_isSucess']){
  346. $this->editData($info['zq_u9_id'],['xs_two_status'=>-3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  347. return false;
  348. }
  349. $this->editData($info['zq_u9_id'],['xs_two_status'=>3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  350. return true;
  351. }
  352. //建立销售单 和出货单
  353. public function xdlsAfterDetail($info,$typeclass,$classid){
  354. $time = time();
  355. $list = [];
  356. $fpdata = $info['fpdata'];
  357. $fpdata_list = explode(';',trim( $fpdata,';'));
  358. $whlabel_list = explode("|",trim($info['whlabel'],"|"));
  359. $total_goods_num = 0;//订单产品总数量
  360. foreach($whlabel_list as $k=>$v){
  361. $tmp_data = explode("-",trim($v,'-'));
  362. if(isset($tmp_data[1])){
  363. $total_goods_num += $tmp_data[1];
  364. }
  365. }
  366. $avg_price = floor(($info['skje']*1000)/$total_goods_num)/1000;
  367. foreach($fpdata_list as $k=>$v){
  368. $tmp_str = str_replace(array('-163-','-164-','-165-','-166-'),'-',$v);
  369. $tmp_arr = explode('|',trim($tmp_str,'|'));
  370. if(stripos($tmp_arr[0],',') !== false){
  371. $ft = explode(',',$tmp_arr[0]);
  372. $features = explode('-',trim($ft[1],'-'));
  373. $features[] = $ft[0];
  374. }else{
  375. $features = explode('-',trim($tmp_arr[0],'-'));
  376. }
  377. $sku = implode("-",$features);
  378. $tmp_ret = $this->logic_u9tools->getOneU9bm($sku,$classid,$typeclass);
  379. $list[] = [
  380. 'jm'=>$tmp_ret['jm'],
  381. 'bm'=>$tmp_ret['bm'],
  382. 'zh'=>$tmp_ret['zh'],
  383. 'final_price'=>$avg_price,//目前先不设置 等后期财务说了再说
  384. 'title'=>isset($tmp_arr[1])?$tmp_arr[1]:'无',
  385. 'dcsl'=>$tmp_arr[2],
  386. 'is_register'=>0,//商品是否被注册 先都当没注册 后面会先确认下
  387. ];
  388. }
  389. $shop = $this->shop->read($info['shop']);
  390. if(empty($shop['yyid'])){
  391. //如果没有在u9上设置店铺的组织 那么需要设置
  392. $this->editData($info['zq_u9_id'],['xs_two_status'=>-1,'update_time'=>time()],$info['number'],1,1,'',[],$this->logic_tools->ret_arr(-1,'店铺没有在u9平台设置参数'));
  393. return ;
  394. }
  395. $dc_params = [
  396. 'gys'=>$this->gys,//供应商
  397. 'number'=>$info['number'],//erp订单编码
  398. "TransOutDocType_Code"=>"TransOut001",//组织间调拨
  399. "time"=>$time,
  400. 'TransferDirection'=>0,//普通
  401. 'yyid'=>$shop['yyid'],//来源店铺 这种需要在店铺表中有
  402. 'shipremarks'=>$info['shipremarks'],//订单的备注
  403. 'dcckbm'=>$this->xdcp_code,//调出仓库编码
  404. 'drckbm'=>$this->xdxgls_code,//调入仓库编码
  405. 'drzz_code'=>$this->xdxgzzcode,//调入组织Code
  406. 'owner_code'=>$this->xdzzcode,//货主组织Code
  407. 'ztcode'=>$this->ztcode,//账套
  408. 'tb_org_arr'=>$this->tb_org_arr,//要同步的组织列表
  409. 'list'=>$list
  410. ];
  411. //创建香港仓的销售单
  412. $xsd_res = $this->apiyyv1->xsdCreate($dc_params,$this->getToken(140));
  413. if(empty($xsd_res[0]['Data'][0]['m_code'])){
  414. $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]);
  415. return ;
  416. }
  417. //更新销售单数据
  418. $xs_no = $xsd_res[0]['Data'][0]["m_code"];
  419. $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]);
  420. }
  421. //检查u9编码是否存在 如果不存在 请先添加并
  422. protected function checkLp($info,$token){
  423. //未注册的货品的列表
  424. $unregister_goods = [];
  425. // $info['list'][1]['jm'] ="9A-#NB-STW-20-FP-5*5C-C-180%-ww2";
  426. // $info['list'][1]['zh'] ="测试数据请删除2--".$info['list'][1]['zh'];
  427. // $info['list'][0]['jm'] ="9A-#NB-STW-22-ww2";
  428. // $info['list'][0]['zh'] ="测试数据请删除2--".$info['list'][0]['zh'];
  429. $r = $this->apiyyv1->cxLp($info['list'],$token);
  430. if(!$r[0]['Success']){
  431. return $this->logic_tools->ret_arr(-1,'查询商品信息异常'.json_encode($r,JSON_UNESCAPED_UNICODE));
  432. }
  433. foreach($r[0]['Data'] as $k=>$v)
  434. {
  435. foreach($info['list'] as $kk => $vv){
  436. if($v['m_code'] == $vv['jm']){
  437. $info['list'][$kk]['is_register'] = 1;
  438. }
  439. }
  440. }
  441. foreach($info['list'] as $k => $v){
  442. if($v['is_register'] == 0){
  443. $unregister_goods[] = $v;
  444. }
  445. }
  446. if(empty($unregister_goods)){
  447. return $this->logic_tools->ret_arr(1,"料品无异常");
  448. }
  449. $tb_info = $info;
  450. $tb_info['list'] = $unregister_goods;
  451. // //return $this->tbXgLp($tb_info,$token);
  452. return $this->tbXgLp($tb_info);
  453. }
  454. //将许昌仓的料品同步到香港仓
  455. public function tbXgLp($tb_info){
  456. $rr = $this->apiyyv1->tbLp($tb_info,$this->getToken(130));
  457. if($rr[0]['Success']){
  458. return $this->logic_tools->ret_arr(1,$rr);
  459. }else{
  460. return $this->logic_tools->ret_arr(-1,$rr);
  461. }
  462. }
  463. //添加料品并且下发
  464. // public function tjLpAndTb($tb_info,$token){
  465. // $r = $this->apiyyv1->cjLp($tb_info,$token);
  466. // if($r[0]["Success"]){
  467. // $rr = $this->apiyyv1->tbLp($tb_info,$token);
  468. // if($rr[0]['Success']){
  469. // return $this->logic_tools->ret_arr(1,$rr);
  470. // }else{
  471. // return $this->logic_tools->ret_arr(-1,$rr);
  472. // }
  473. // }else{
  474. // return $this->logic_tools->ret_arr(-1,$r);
  475. // }
  476. // }
  477. //根据返回的状态修改对应的值
  478. protected function editData($zq_u9_id,$z_qu_arr,$number,$one_type,$two_type,$apply_api,$apply_data,$ret_data){
  479. $this->zzquque_u9->save($z_qu_arr,$zq_u9_id);
  480. $this->zzququeu9_logs->insert([
  481. 'oid'=>$zq_u9_id,
  482. 'number'=>$number,
  483. 'one_type'=>$one_type,
  484. 'two_type'=>$two_type,
  485. 'apply_api'=>$apply_api,
  486. 'apply_data'=>json_encode($apply_data,JSON_UNESCAPED_UNICODE),
  487. 'ret_data'=>json_encode($ret_data,JSON_UNESCAPED_UNICODE),
  488. 'create_time'=>time(),
  489. 'read_time'=>date("Y-m-d H:i:s")
  490. ]);
  491. }
  492. public function xdlsCxDcd($info){
  493. $r = $this->apiyyv1->xdlsCxDcd($info['dc_no'],$this->getToken(130));
  494. if(empty($r[0]['Data'])){
  495. return ;
  496. }
  497. //更新销售单数据
  498. $xs_no = $r[0]['Data'];
  499. $this->editData($info['id'],['dc_data'=>$xs_no,'dc_data_status'=>1,'update_time'=>time()],$info['number'],7,1,'xs_two',$r[1],$r[0]);
  500. }
  501. }