Model_logic_u9xgsd.php 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563
  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->createDataTwo($info);
  218. //创建香港公司的采购单
  219. $cgd_res = $this->apiyyv1->cgdCreate($dc_params,$this->getToken(140));
  220. if(empty($cgd_res[0]['Data'][0]["Code"])){
  221. $this->editData($info['id'],['cg_status'=>-1,'update_time'=>time()],$info['order_no'],3,1,'cg',$cgd_res[1],$cgd_res[0]);
  222. return $this->logic_tools->ret_arr(-1,"创建采购单失败");
  223. }
  224. $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]);
  225. return $this->logic_tools->ret_arr(1,"创建采购单成功");
  226. }
  227. //提交采购单
  228. public function subCg($info){
  229. $r = $this->apiyyv1->cgdSubmit([
  230. 'number'=>$info['cg_no']
  231. ],$this->getToken(140));
  232. if(!$r[0]['Data'][0]['IsSucess']){
  233. $this->editData($info['id'],['cg_status'=>-2,'update_time'=>time()],$info['order_no'],3,2,'cg',$r[1],$r[0]);
  234. return $this->logic_tools->ret_arr(-1,"提交采购单失败");
  235. }
  236. //更新采购单
  237. $this->editData($info['id'],['cg_status'=>2,'update_time'=>time()],$info['order_no'],3,2,'cg',$r[1],$r[0]);
  238. return $this->logic_tools->ret_arr(1,"提交采购单成功");
  239. }
  240. //审核采购单
  241. public function shCg($info){
  242. $rr = $this->apiyyv1->cgdApprove([
  243. 'number'=>$info['cg_no']
  244. ],$this->getToken(140));
  245. if(!$rr[0]['Data'][0]['IsSucess']){
  246. $this->editData($info['id'],['cg_status'=>-3,'update_time'=>time()],$info['order_no'],3,3,'cg',$rr[1],$rr[0]);
  247. return $this->logic_tools->ret_arr(-1,"审核采购单失败");
  248. }
  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. //创建销售单
  253. public function createXs($info){
  254. //在创建前边执行查询调出单
  255. if($info['dc_data_status'] != 1)
  256. {
  257. $r = $this->xdlsCxDcd($info);
  258. if($r['code']!= 1){
  259. return $this->logic_tools->ret_arr(-1,"调出单未被审核,请先去审核");
  260. }
  261. $info['dc_data'] = json_encode($r['data']['data']);
  262. }
  263. $dc_params = $this->createDataTwo($info);
  264. //创建许昌成品库的销售单
  265. $xsd_res = $this->apiyyv1->xsdCreate($dc_params,$this->getToken(130));
  266. if(empty($xsd_res[0]['Data'][0]['m_code'])){
  267. $this->editData($info['id'],['xs_status'=>-1,'update_time'=>time()],$info['order_no'],2,1,'xs',$xsd_res[1],$xsd_res[0]);
  268. return $this->logic_tools->ret_arr(-1,"创建销售单失败");
  269. }
  270. //更新销售单数据
  271. $xs_no = $xsd_res[0]['Data'][0]["m_code"];
  272. $this->editData($info['id'],['xs_no'=>$xs_no,'xs_status'=>1,'update_time'=>time()],$info['order_no'],2,1,'xs',$xsd_res[1],$xsd_res[0]);
  273. return $this->logic_tools->ret_arr(1,"创建销售单成功");
  274. }
  275. //提交销售单
  276. public function subXs($info){
  277. $r = $this->apiyyv1->xsdSubmit([
  278. 'number'=>$info['xs_no']
  279. ],$this->getToken(130));
  280. if(!$r[0]['Data'][0]['m_isSucess']){
  281. $this->editData($info['id'],['xs_status'=>-2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  282. return $this->logic_tools->ret_arr(-1,"提交销售单成功");
  283. }
  284. $this->editData($info['id'],['xs_status'=>2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  285. return $this->logic_tools->ret_arr(1,"提交销售单成功");
  286. }
  287. //审核销售单
  288. public function shXs($info){
  289. $rr = $this->apiyyv1->xsdApprove([
  290. 'number'=>$info['xs_no']
  291. ],$this->getToken(130));
  292. if(!$rr[0]['Data'][0]['m_isSucess']){
  293. $this->editData($info['id'],['xs_status'=>-3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  294. return $this->logic_tools->ret_arr(-1,"审核销售单成功");
  295. }
  296. $this->editData($info['id'],['xs_status'=>3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  297. return $this->logic_tools->ret_arr(1,"审核销售单成功");
  298. }
  299. //创建关联销售单
  300. public function createXsTwo($tmp_info){
  301. $time = time();
  302. if(empty($tmp_info['dc_data'])){
  303. return ;
  304. }
  305. $tmp_list = json_decode($tmp_info['dc_data'],true);
  306. if(empty($tmp_list)){
  307. return ;
  308. }
  309. $info = $this->logic_order->getInfoByPlat($tmp_info['platform'],$tmp_info['order_no']);
  310. $info['zq_u9_id'] = $tmp_info['id'];
  311. $info['dc_no'] = $tmp_info['dc_no'];
  312. $info['dc_data'] = $tmp_info['dc_data'];
  313. $total_goods_num = 0;//订单产品总数量
  314. foreach($tmp_list as $k=>$v){
  315. $total_goods_num += $v['costuomqty'];
  316. }
  317. $avg_price = floor(($info['shouldmoney']*1000)/$total_goods_num)/1000;
  318. $list = [];
  319. foreach($tmp_list as $k=>$v){
  320. $list[] = [
  321. 'jm'=>$v['iteminfo_itemcode'],
  322. 'zh'=>$v['iteminfo_itemname'],
  323. 'final_price'=>$avg_price,//目前先不设置 等后期财务说了再说
  324. 'dcsl'=>$v['costuomqty'],
  325. 'is_register'=>0,//商品是否被注册 先都当没注册 后面会先确认下
  326. ];
  327. }
  328. $dc_params = [
  329. 'gys'=>$this->gys,//供应商
  330. 'number'=>$info['number'],//erp订单编码
  331. "TransOutDocType_Code"=>"TransOut001",//组织间调拨
  332. "time"=>$time,
  333. 'TransferDirection'=>0,//普通
  334. 'yyid'=>$tmp_list[0]['descflexfield_pubdescseg2'],//来源店铺 这种需要在店铺表中有
  335. 'shipremarks'=>$tmp_list[0]['descflexfield_pubdescseg5'],//订单的备注
  336. 'dcckbm'=>$this->xdcp_code,//调出仓库编码
  337. 'drckbm'=>$this->xdxgls_code,//调入仓库编码
  338. 'drzz_code'=>$this->xdxgzzcode,//调入组织Code
  339. 'owner_code'=>$this->xdzzcode,//货主组织Code
  340. 'ztcode'=>$this->ztcode,//账套
  341. 'tb_org_arr'=>$this->tb_org_arr,//要同步的组织列表
  342. 'list'=>$list
  343. ];
  344. //创建香港仓的销售单
  345. $xsd_res = $this->apiyyv1->xsdTwoCreate($dc_params,$this->getToken(140));
  346. if(empty($xsd_res[0]['Data'][0]['m_code'])){
  347. $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]);
  348. return $this->logic_tools->ret_arr(-1,"创建香港销售单失败");
  349. }
  350. //更新销售单数据
  351. $xs_no = $xsd_res[0]['Data'][0]["m_code"];
  352. $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]);
  353. return $this->logic_tools->ret_arr(1,"创建香港销售单成功");
  354. }
  355. //提交审关联销售单
  356. public function subXsTwo($info){
  357. $r = $this->apiyyv1->xsdSubmit([
  358. 'number'=>$info['xs_two_no']
  359. ],$this->getToken(140));
  360. if(!$r[0]['Data'][0]['m_isSucess']){
  361. $this->editData($info['id'],['xs_two_status'=>-2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  362. return $this->logic_tools->ret_arr(-1,"提交香港销售单失败");
  363. }
  364. $this->editData($info['id'],['xs_two_status'=>2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
  365. return $this->logic_tools->ret_arr(1,"提交香港销售单成功");
  366. }
  367. //审核关联销售单
  368. public function shXsTwo($info){
  369. $rr = $this->apiyyv1->xsdApprove([
  370. 'number'=>$info['xs_two_no']
  371. ],$this->getToken(140));
  372. if(!$rr[0]['Data'][0]['m_isSucess']){
  373. $this->editData($info['id'],['xs_two_status'=>-3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  374. return $this->logic_tools->ret_arr(-1,"审核香港销售单失败");
  375. }
  376. $this->editData($info['id'],['xs_two_status'=>3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
  377. return $this->logic_tools->ret_arr(1,"审核香港销售单成功");
  378. }
  379. //创建出货单
  380. public function createCh($info){
  381. $r = $this->apiyyv1->xscsByordernos([$info['xs_two_no']],$this->getToken(140));
  382. if(empty($r[0]['Data'])){
  383. return ;
  384. }
  385. $tmp_list = [];
  386. foreach($r[0]['Data'] as $k=>$v){
  387. $v['dcsl'] = $v['shipplanqtypu'];
  388. $tmp_list[$v['docno']][] = $v;
  389. }
  390. $list = [$info];
  391. $final_list = [];
  392. foreach($tmp_list as $k=>$v){
  393. foreach($list as $item){
  394. if($item['xs_two_no'] == $k){
  395. $final_list[] = [
  396. 'zq_u9_id'=>$item['id'],
  397. 'drckbm'=>$this->xdxgls_code,
  398. 'number'=>$item['order_no'],
  399. 'order_no'=>$item['order_no'],
  400. 'xs_no'=>$k,
  401. 'xs_two_no'=>$k,
  402. 'list'=>$v
  403. ];
  404. }
  405. }
  406. }
  407. $do_data = $final_list[0];
  408. $bzch_res = $this->apiyyv1->bzchCreate($do_data,$this->getToken(140));
  409. if(empty($bzch_res[0]['Data'][0]['m_code'])){
  410. $this->editData($info['id'],['bzch_status'=>-1,'update_time'=>time()],$info['order_no'],4,1,'bzch',$bzch_res[1],$bzch_res[0]);
  411. return $this->logic_tools->ret_arr(-1,"创建标准出货单失败");
  412. }
  413. //更新销售单数据
  414. $bzch_no = $bzch_res[0]['Data'][0]["m_code"];
  415. $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]);
  416. return $this->logic_tools->ret_arr(1,"创建标准出货单成功");
  417. }
  418. //提交并审核出货单
  419. public function subAndShCh($info){
  420. $bzch_res = $this->apiyyv1->bzchSubmitAndApprove(['number'=>$info['bzch_no']],$this->getToken(140));
  421. if(empty($bzch_res[0]['Data'][0]['m_code'])){
  422. $this->editData($info['id'],['bzch_status'=>-3,'update_time'=>time()],$info['order_no'],4,3,'bzch',$bzch_res[1],$bzch_res[0]);
  423. return $this->logic_tools->ret_arr(-1,"提交标准出货单失败");
  424. }
  425. //更新销售单数据
  426. $bzch_no = $bzch_res[0]['Data'][0]["m_code"];
  427. $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]);
  428. return $this->logic_tools->ret_arr(1,"提交标准出货单成功");
  429. }
  430. //查询调入单
  431. public function createDr($info){
  432. $r = $this->apiyyv1->drdcxBydcd($info['dc_no'],$this->getToken(140));
  433. //如果获取对应调入单没有成功
  434. if(empty($r[0]['Data'][0]['docno'])){
  435. $this->editData($info['id'],['dr_status'=>-1,'update_time'=>time()],$info['order_no'],6,1,'dr',$r[1],$r[0]);
  436. return $this->logic_tools->ret_arr(-1,"审核标准出货单失败");
  437. }
  438. $dr_no = $r[0]['Data'][0]["docno"];
  439. $this->editData($info['id'],['dr_no'=>$dr_no,'dr_status'=>1,'update_time'=>time()],$info['order_no'],6,1,'dr',$r[1],$r[0]);
  440. return $this->logic_tools->ret_arr(1,"审核标准出货单成功");
  441. }
  442. //提交调入单
  443. public function subDr($info){
  444. //提交调入单
  445. $rr = $this->apiyyv1->drdSubmit(['number'=>$info['dr_no']],$this->getToken(140));
  446. if(!$rr[0]['Data'][0]['IsSucess']){
  447. $this->editData($info['id'],['dr_status'=>-2,'update_time'=>time()],$info['order_no'],6,2,'dr',$rr[1],$rr[0]);
  448. return $this->logic_tools->ret_arr(-1,"提交调入单失败");
  449. }
  450. $this->editData($info['id'],['dr_status'=>2,'update_time'=>time()],$info['order_no'],6,2,'dr',$rr[1],$rr[0]);
  451. return $this->logic_tools->ret_arr(1,"提交调入单成功");
  452. }
  453. //审核调入单
  454. public function shDr($info){
  455. //审核调入单
  456. $rrr = $this->apiyyv1->drdApprove(['number'=>$info['dr_no']],$this->getToken(140));
  457. if(!$rrr[0]['Data'][0]['IsSucess']){
  458. $this->editData($info['id'],['dr_status'=>-3,'update_time'=>time()],$info['order_no'],6,3,'dr',$rrr[1],$rrr[0]);
  459. return $this->logic_tools->ret_arr(-1,"审核调入单失败");
  460. }
  461. $this->editData($info['id'],['dr_status'=>3,'update_time'=>time()],$info['order_no'],6,3,'dr',$rrr[1],$rrr[0]);
  462. return $this->logic_tools->ret_arr(1,"审核调入单成功");
  463. }
  464. //检查u9编码是否存在 如果不存在 请先添加并
  465. protected function checkLp($info,$token){
  466. //未注册的货品的列表
  467. $unregister_goods = [];
  468. $r = $this->apiyyv1->cxLp($info['list'],$token);
  469. if(!$r[0]['Success']){
  470. return $this->logic_tools->ret_arr(-1,'查询商品信息异常'.json_encode($r,JSON_UNESCAPED_UNICODE));
  471. }
  472. foreach($r[0]['Data'] as $k=>$v)
  473. {
  474. foreach($info['list'] as $kk => $vv){
  475. if($v['m_code'] == $vv['jm']){
  476. $info['list'][$kk]['is_register'] = 1;
  477. }
  478. }
  479. }
  480. foreach($info['list'] as $k => $v){
  481. if($v['is_register'] == 0){
  482. $unregister_goods[] = $v;
  483. }
  484. }
  485. if(empty($unregister_goods)){
  486. return $this->logic_tools->ret_arr(1,"料品无异常");
  487. }
  488. $tb_info = $info;
  489. $tb_info['list'] = $unregister_goods;
  490. // //return $this->tbXgLp($tb_info,$token);
  491. return $this->tbXgLp($tb_info);
  492. }
  493. //将许昌仓的料品同步到香港仓
  494. public function tbXgLp($tb_info){
  495. $rr = $this->apiyyv1->tbLp($tb_info,$this->getToken(130));
  496. if($rr[0]['Success']){
  497. return $this->logic_tools->ret_arr(1,$rr);
  498. }else{
  499. return $this->logic_tools->ret_arr(-1,$rr);
  500. }
  501. }
  502. //根据返回的状态修改对应的值
  503. protected function editData($zq_u9_id,$z_qu_arr,$number,$one_type,$two_type,$apply_api,$apply_data,$ret_data){
  504. $this->zzquque_u9->save($z_qu_arr,$zq_u9_id);
  505. $this->zzququeu9_logs->insert([
  506. 'oid'=>$zq_u9_id,
  507. 'number'=>$number,
  508. 'one_type'=>$one_type,
  509. 'two_type'=>$two_type,
  510. 'apply_api'=>$apply_api,
  511. 'apply_data'=>json_encode($apply_data,JSON_UNESCAPED_UNICODE),
  512. 'ret_data'=>json_encode($ret_data,JSON_UNESCAPED_UNICODE),
  513. 'create_time'=>time(),
  514. 'read_time'=>date("Y-m-d H:i:s")
  515. ]);
  516. }
  517. //调出单查询并保存
  518. public function xdlsCxDcd($info){
  519. $r = $this->apiyyv1->xdlsCxDcd($info['dc_no'],$this->getToken(130));
  520. if(empty($r[0]['Data'])){
  521. return $this->logic_tools->ret_arr(-1,"该订单还未被审核,请先去审核");
  522. }
  523. //更新销售单数据
  524. $xs_no = json_encode($r[0]['Data']);
  525. $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]);
  526. return $this->logic_tools->ret_arr(1,"审核成功",$r[0]);
  527. }
  528. }