|
|
@@ -0,0 +1,550 @@
|
|
|
+<?php
|
|
|
+/**
|
|
|
+ * 此模型是为了支持从许昌销售公司调出库存到香港公司仓库的功能支持
|
|
|
+ */
|
|
|
+class Model_logic_u9xg extends Lin_Model {
|
|
|
+ public $xdzzcode = '130';//许昌销售公司编码
|
|
|
+ public $xdcp_code = '13001';//许昌成品库的编码 测试的时候就用龙盈工厂的仓库
|
|
|
+ public $xdxgzzcode = '140';//香港组织公司编码
|
|
|
+ public $xdxgls_code = '14003';//香港临时库的编码 测试的时候用销售公司成品库的编码
|
|
|
+ public $ztcode = '001';//账套的code;
|
|
|
+ public $tb_org_arr =[101,110,130,140];//同步组织
|
|
|
+ public $gys = "98002";//供应商 98001 龙盈 98002 龙熠
|
|
|
+ //切记要修改token_120的token真正的token！！！！
|
|
|
+ function __construct(){
|
|
|
+ parent::__construct();
|
|
|
+ $this->load->_model('Model_settingtest','settingtest');
|
|
|
+ $this->load->_model("Model_apiyyv1",'apiyyv1');
|
|
|
+ $this->load->_model('Model_classid','classid');
|
|
|
+ $this->load->_model('Model_typeclass','typeclass');
|
|
|
+ $this->load->_model('Model_shop','shop');
|
|
|
+ $this->load->_model('Model_zzquque_u9','zzquque_u9');
|
|
|
+ $this->load->_model('Model_zzququeu9_logs','zzququeu9_logs');
|
|
|
+ $this->load->_model('Model_logic_tools','logic_tools');
|
|
|
+ $this->load->_model('Model_logic_u9tools','logic_u9tools');
|
|
|
+ }
|
|
|
+ public function getToken($type){
|
|
|
+ $name = "get_yytoken_".$type;
|
|
|
+ $token = $this->settingtest->$name();
|
|
|
+ return $token;
|
|
|
+ }
|
|
|
+ //转码准备数据
|
|
|
+ public function transPrepare(){
|
|
|
+ $classid = $this->classid->sku();
|
|
|
+ $tcall = $this->typeclass->find_all();
|
|
|
+ foreach ($tcall as $v)
|
|
|
+ {
|
|
|
+ $tcjm[$v['id']] = array($v['jm'],$v['classid']);
|
|
|
+ $typeclass[$v['id']] = array('zh'=>$v['zh'],'classid'=>$v['classid'],'bm'=>$v['bm'],'title'=>$v['title'],'jm'=>$v['jm']);
|
|
|
+ }
|
|
|
+ return [
|
|
|
+ 'classid'=>$classid,
|
|
|
+ 'typeclass'=>$typeclass,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ //必须先建立许昌成品仓的销售单和调出单 香港仓的采购单 一次执行5单
|
|
|
+ //循环执行许昌成品仓的销售单 调出单和香港仓的采购单
|
|
|
+ public function xdlsOneStep($list){
|
|
|
+
|
|
|
+ $pre_data = $this->transPrepare();
|
|
|
+ foreach($list as $k=>$v){
|
|
|
+ $this->xdlsBeforeCreate($v,$pre_data['typeclass'],$pre_data['classid']);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //修正原来的逻辑 调出单审核完成后才可以在批量执行后续订单
|
|
|
+ public function xdlsOneExtraStep($list){
|
|
|
+ foreach($list as $k=>$v){
|
|
|
+ $this->xdlsCxDcd($v);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //循环执行许昌仓的销售单 调出单和香港仓的采购单 提交 顺带的也执行审核
|
|
|
+ public function xdlsTwoStep($list){
|
|
|
+ foreach($list as $k=>$v){
|
|
|
+ $r1 = $this->dcSubAndCheck($v);
|
|
|
+ if(!$r1){
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ $r2 = $this->cgSubAndCheck($v);
|
|
|
+ if(!$r2){
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ $this->xsSubAndCheck($v);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //查询调出单生成的调入单是否生成 如果生成了就审核 如果没生成 说明异常了 这种都是按步骤走的
|
|
|
+ public function xdlsThreeStep($list){
|
|
|
+ foreach($list as $k=>$v){
|
|
|
+ $r = $this->apiyyv1->drdcxBydcd($v['dc_no'],$this->getToken(140));
|
|
|
+
|
|
|
+ //如果获取对应调入单没有成功
|
|
|
+ if(empty($r[0]['Data'][0]['docno'])){
|
|
|
+ $this->editData($v['id'],['dr_status'=>-1,'update_time'=>time()],$v['order_no'],6,1,'dr',$r[1],$r[0]);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $dr_no = $r[0]['Data'][0]["docno"];
|
|
|
+
|
|
|
+ $this->editData($v['id'],['dr_no'=>$dr_no,'dr_status'=>1,'update_time'=>time()],$v['order_no'],6,1,'dr',$r[1],$r[0]);
|
|
|
+
|
|
|
+ //提交调入单
|
|
|
+ $rr = $this->apiyyv1->drdSubmit(['number'=>$dr_no],$this->getToken(140));
|
|
|
+ if(!$rr[0]['Data'][0]['IsSucess']){
|
|
|
+ $this->editData($v['id'],['dr_status'=>-2,'update_time'=>time()],$v['order_no'],6,2,'dr',$rr[1],$rr[0]);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $this->editData($v['id'],['dr_status'=>2,'update_time'=>time()],$v['order_no'],6,2,'dr',$rr[1],$rr[0]);
|
|
|
+
|
|
|
+ //审核调入单
|
|
|
+ $rrr = $this->apiyyv1->drdApprove(['number'=>$dr_no],$this->getToken(140));
|
|
|
+ if(!$rrr[0]['Data'][0]['IsSucess']){
|
|
|
+ $this->editData($v['id'],['dr_status'=>-3,'update_time'=>time()],$v['order_no'],6,3,'dr',$rrr[1],$rrr[0]);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $this->editData($v['id'],['dr_status'=>3,'update_time'=>time()],$v['order_no'],6,3,'dr',$rrr[1],$rrr[0]);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ //建立香港的销售单 标准出库单有源的需要先审核
|
|
|
+ public function xdlsFourStep($list){
|
|
|
+ $pre_data = $this->transPrepare();
|
|
|
+ foreach($list as $k=>$v){
|
|
|
+ $this->xdlsAfterDetail($v,$pre_data['typeclass'],$pre_data['classid']);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //审核香港销售单 同时生成标准出库单
|
|
|
+ public function xdlsFiveStep($list){
|
|
|
+ $xs_no_list = array_column($list,'xs_two_no');
|
|
|
+
|
|
|
+ $r = $this->apiyyv1->xscsByordernos($xs_no_list,$this->getToken(140));
|
|
|
+
|
|
|
+ if(empty($r[0]['Data'])){
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ $tmp_list = [];
|
|
|
+ foreach($r[0]['Data'] as $k=>$v){
|
|
|
+ $v['dcsl'] = $v['shipplanqtypu'];
|
|
|
+ $tmp_list[$v['docno']][] = $v;
|
|
|
+ }
|
|
|
+
|
|
|
+ $final_list = [];
|
|
|
+ foreach($tmp_list as $k=>$v){
|
|
|
+ foreach($list as $item){
|
|
|
+ if($item['xs_two_no'] == $k){
|
|
|
+ $final_list[] = [
|
|
|
+ 'zq_u9_id'=>$item['id'],
|
|
|
+ 'drckbm'=>$this->xdxgls_code,
|
|
|
+ 'number'=>$item['order_no'],
|
|
|
+ 'order_no'=>$item['order_no'],
|
|
|
+ 'xs_no'=>$k,
|
|
|
+ 'xs_two_no'=>$k,
|
|
|
+ 'list'=>$v
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ foreach($final_list as $info){
|
|
|
+ $this->xdlsFiveStepAfter($info);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ public function xdlsFiveStepAfter($info){
|
|
|
+ //先审核 然后在执行
|
|
|
+ $r = $this->xsSubAndCheck140($info);
|
|
|
+ if(!$r){
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ $bzch_res = $this->apiyyv1->bzchCreate($info,$this->getToken(140));
|
|
|
+ if(empty($bzch_res[0]['Data'][0]['m_code'])){
|
|
|
+ $this->editData($info['zq_u9_id'],['bzch_status'=>-1,'update_time'=>time()],$info['number'],4,1,'bzch',$bzch_res[1],$bzch_res[0]);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+
|
|
|
+ //更新销售单数据
|
|
|
+ $bzch_no = $bzch_res[0]['Data'][0]["m_code"];
|
|
|
+ $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]);
|
|
|
+ }
|
|
|
+ //审核香港标准出库单
|
|
|
+ public function xdlsSixStep($list){
|
|
|
+ foreach($list as $k =>$v){
|
|
|
+ $bzch_res = $this->apiyyv1->bzchSubmitAndApprove(['number'=>$v['bzch_no']],$this->getToken(140));
|
|
|
+ if(empty($bzch_res[0]['Data'][0]['m_code'])){
|
|
|
+ $this->editData($v['id'],['bzch_status'=>-3,'update_time'=>time()],$v['order_no'],4,3,'bzch',$bzch_res[1],$bzch_res[0]);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ //更新销售单数据
|
|
|
+ $bzch_no = $bzch_res[0]['Data'][0]["m_code"];
|
|
|
+ $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]);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ //由于调出单生成可能不会申请后实时出现 需要差几分钟再去申请，避免这种错误
|
|
|
+ //从许昌成品库调出库存到香港临时仓
|
|
|
+ //创建 调出单 销售单 采购单
|
|
|
+ //必须先建立许昌成品仓的销售单和调出单 香港仓的采购单 因为u9生成需要时间 然后在进行 审核
|
|
|
+ public function xdlsBeforeCreate($info,$typeclass,$classid){
|
|
|
+ $time = time();
|
|
|
+ $list = [];
|
|
|
+ $fpdata = $info['fpdata'];
|
|
|
+ $fpdata_list = explode(';',trim( $fpdata,';'));
|
|
|
+ $whlabel_list = explode("|",trim($info['whlabel'],"|"));
|
|
|
+
|
|
|
+ $total_goods_num = 0;//订单产品总数量
|
|
|
+ foreach($whlabel_list as $k=>$v){
|
|
|
+ $tmp_data = explode("-",trim($v,'-'));
|
|
|
+ if(isset($tmp_data[1])){
|
|
|
+ $total_goods_num += $tmp_data[1];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $avg_price = floor(($info['skje']*1000)/$total_goods_num)/1000;
|
|
|
+ foreach($fpdata_list as $k=>$v){
|
|
|
+ $tmp_str = str_replace(array('-163-','-164-','-165-','-166-'),'-',$v);
|
|
|
+ $tmp_arr = explode('|',trim($tmp_str,'|'));
|
|
|
+ if(stripos($tmp_arr[0],',') !== false){
|
|
|
+ $ft = explode(',',$tmp_arr[0]);
|
|
|
+ $features = explode('-',trim($ft[1],'-'));
|
|
|
+ $features[] = $ft[0];
|
|
|
+ }else{
|
|
|
+ $features = explode('-',trim($tmp_arr[0],'-'));
|
|
|
+ }
|
|
|
+ $sku = implode("-",$features);
|
|
|
+ $tmp_ret = $this->logic_u9tools->getOneU9bm($sku,$classid,$typeclass);
|
|
|
+ $list[] = [
|
|
|
+ 'jm'=>$tmp_ret['jm'],
|
|
|
+ 'bm'=>$tmp_ret['bm'],
|
|
|
+ 'zh'=>$tmp_ret['zh'],
|
|
|
+ 'final_price'=>$avg_price,//目前先不设置 等后期财务说了再说
|
|
|
+ 'title'=>isset($tmp_arr[1])?$tmp_arr[1]:'无',
|
|
|
+ 'dcsl'=>$tmp_arr[2],
|
|
|
+ 'is_register'=>0,//商品是否被注册 先都当没注册 后面会先确认下
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ $shop = $this->shop->read($info['shop']);
|
|
|
+ if(empty($shop['yyid'])){
|
|
|
+ //如果没有在u9上设置店铺的组织 那么需要设置
|
|
|
+ $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'',[],$this->logic_tools->ret_arr(-1,'店铺没有在u9平台设置参数'));
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+
|
|
|
+ $dc_params = [
|
|
|
+ 'gys'=>$this->gys,//供应商
|
|
|
+ 'number'=>$info['number'],//erp订单编码
|
|
|
+ "TransOutDocType_Code"=>"TransOut001",//组织间调拨
|
|
|
+ "time"=>$time,
|
|
|
+ 'TransferDirection'=>0,//普通
|
|
|
+ 'yyid'=>$shop['yyid'],//来源店铺 这种需要在店铺表中有
|
|
|
+ 'shipremarks'=>$info['shipremarks'],//订单的备注
|
|
|
+ 'dcckbm'=>$this->xdcp_code,//调出仓库编码
|
|
|
+ 'drckbm'=>$this->xdxgls_code,//调入仓库编码
|
|
|
+ 'drzz_code'=>$this->xdxgzzcode,//调入组织Code
|
|
|
+ 'owner_code'=>$this->xdzzcode,//货主组织Code
|
|
|
+ 'ztcode'=>$this->ztcode,//账套
|
|
|
+ 'tb_org_arr'=>$this->tb_org_arr,//要同步的组织列表
|
|
|
+ 'list'=>$list
|
|
|
+ ];
|
|
|
+ //调出单检测是否存在
|
|
|
+ $cxdcd_r = $this->apiyyv1->xcDcdByOtherId($dc_params['number'],$this->getToken(130));
|
|
|
+ $ret_data = $cxdcd_r[0]['Data'];
|
|
|
+ if(isset($ret_data[0])){
|
|
|
+ $descflexfield_pubdescseg4 = $ret_data[0]['descflexfield_pubdescseg4'];
|
|
|
+ if($dc_params['number'] == $descflexfield_pubdescseg4){
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ //检测料品是否在u9被添加 检测香港仓有没有 许昌仓一定要有 没有
|
|
|
+ $r = $this->checkLp($dc_params,$this->getToken(140));
|
|
|
+
|
|
|
+ if($r['code'] !=1){
|
|
|
+ $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'lpck',[],$r['msg']);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+
|
|
|
+ //创建调出单
|
|
|
+ $dcd_res = $this->apiyyv1->dcdCrate($dc_params,$this->getToken(130));
|
|
|
+
|
|
|
+ if(empty($dcd_res[0]['Data'][0]["Code"])){
|
|
|
+ $this->editData($info['zq_u9_id'],['dc_status'=>-1,'update_time'=>time()],$info['number'],1,1,'dc',$dcd_res[1],$dcd_res[0]);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ //更新
|
|
|
+ $dcd_no = $dcd_res[0]['Data'][0]["Code"];
|
|
|
+ $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]);
|
|
|
+
|
|
|
+ // //创建许昌成品库的销售单
|
|
|
+ // $xsd_res = $this->apiyyv1->xsdCreate($dc_params,$this->getToken(130));
|
|
|
+ // if(empty($xsd_res[0]['Data'][0]['m_code'])){
|
|
|
+ // $this->editData($info['zq_u9_id'],['xs_status'=>-1,'update_time'=>time()],$info['number'],2,1,'xs',$xsd_res[1],$xsd_res[0]);
|
|
|
+ // return ;
|
|
|
+ // }
|
|
|
+ // //更新销售单数据
|
|
|
+ // $xs_no = $xsd_res[0]['Data'][0]["m_code"];
|
|
|
+ // $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]);
|
|
|
+
|
|
|
+ // //创建香港公司的采购单
|
|
|
+ // $cgd_res = $this->apiyyv1->cgdCreate($dc_params,$this->getToken(140));
|
|
|
+ // if(empty($cgd_res[0]['Data'][0]["Code"])){
|
|
|
+ // $this->editData($info['zq_u9_id'],['cg_status'=>-1,'update_time'=>time()],$info['number'],3,1,'cg',$cgd_res[1],$cgd_res[0]);
|
|
|
+ // return ;
|
|
|
+ // }
|
|
|
+
|
|
|
+ // $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]);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 提交审核调出单调出单
|
|
|
+ public function dcSubAndCheck($info){
|
|
|
+ $r = $this->apiyyv1->dcdSubmit([
|
|
|
+ 'number'=>$info['dc_no']
|
|
|
+ ],$this->getToken(130));
|
|
|
+ if(!$r[0]['Data'][0]['IsSucess']){
|
|
|
+ $this->editData($info['id'],['dc_status'=>-2,'update_time'=>time()],$info['order_no'],1,2,'dc',$r[1],$r[0]);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ //更新调出单
|
|
|
+ $this->editData($info['id'],['dc_status'=>2,'update_time'=>time()],$info['order_no'],1,2,'dc',$r[1],$r[0]);
|
|
|
+ $rr = $this->apiyyv1->dcdApprove([
|
|
|
+ 'number'=>$info['dc_no']
|
|
|
+ ],$this->getToken(130));
|
|
|
+ if(!$rr[0]['Data'][0]['IsSucess']){
|
|
|
+ $this->editData($info['id'],['dc_status'=>-3,'update_time'=>time()],$info['order_no'],1,3,'dc',$rr[1],$rr[0]);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ $this->editData($info['id'],['dc_status'=>3,'update_time'=>time()],$info['order_no'],1,3,'dc',$rr[1],$rr[0]);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ //提交审核采购单
|
|
|
+ public function cgSubAndCheck($info){
|
|
|
+ $r = $this->apiyyv1->cgdSubmit([
|
|
|
+ 'number'=>$info['cg_no']
|
|
|
+ ],$this->getToken(140));
|
|
|
+
|
|
|
+ if(!$r[0]['Data'][0]['IsSucess']){
|
|
|
+ $this->editData($info['id'],['cg_status'=>-2,'update_time'=>time()],$info['order_no'],3,2,'cg',$r[1],$r[0]);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ //更新采购单
|
|
|
+ $this->editData($info['id'],['cg_status'=>2,'update_time'=>time()],$info['order_no'],3,2,'cg',$r[1],$r[0]);
|
|
|
+ $rr = $this->apiyyv1->cgdApprove([
|
|
|
+ 'number'=>$info['cg_no']
|
|
|
+ ],$this->getToken(140));
|
|
|
+ if(!$rr[0]['Data'][0]['IsSucess']){
|
|
|
+ $this->editData($info['id'],['cg_status'=>-3,'update_time'=>time()],$info['order_no'],3,3,'cg',$rr[1],$rr[0]);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ $this->editData($info['id'],['cg_status'=>3,'update_time'=>time()],$info['order_no'],3,3,'cg',$rr[1],$rr[0]);
|
|
|
+ return true;
|
|
|
+
|
|
|
+ }
|
|
|
+ //提交审核销售单
|
|
|
+ public function xsSubAndCheck($info){
|
|
|
+ $r = $this->apiyyv1->xsdSubmit([
|
|
|
+ 'number'=>$info['xs_no']
|
|
|
+ ],$this->getToken(130));
|
|
|
+
|
|
|
+ if(!$r[0]['Data'][0]['m_isSucess']){
|
|
|
+ $this->editData($info['id'],['xs_status'=>-2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ $this->editData($info['id'],['xs_status'=>2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
|
|
|
+ $rr = $this->apiyyv1->xsdApprove([
|
|
|
+ 'number'=>$info['xs_no']
|
|
|
+ ],$this->getToken(130));
|
|
|
+ if(!$rr[0]['Data'][0]['m_isSucess']){
|
|
|
+ $this->editData($info['id'],['xs_status'=>-3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ $this->editData($info['id'],['xs_status'=>3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ public function xsSubAndCheck140($info){
|
|
|
+ $r = $this->apiyyv1->xsdSubmit([
|
|
|
+ 'number'=>$info['xs_two_no']
|
|
|
+ ],$this->getToken(140));
|
|
|
+
|
|
|
+ if(!$r[0]['Data'][0]['m_isSucess']){
|
|
|
+ $this->editData($info['zq_u9_id'],['xs_two_status'=>-2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ $this->editData($info['zq_u9_id'],['xs_two_status'=>2,'update_time'=>time()],$info['order_no'],2,2,'xs',$r[1],$r[0]);
|
|
|
+ $rr = $this->apiyyv1->xsdApprove([
|
|
|
+ 'number'=>$info['xs_two_no']
|
|
|
+ ],$this->getToken(140));
|
|
|
+ if(!$rr[0]['Data'][0]['m_isSucess']){
|
|
|
+ $this->editData($info['zq_u9_id'],['xs_two_status'=>-3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ $this->editData($info['zq_u9_id'],['xs_two_status'=>3,'update_time'=>time()],$info['order_no'],2,3,'xs',$rr[1],$rr[0]);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ //建立销售单 和出货单
|
|
|
+ public function xdlsAfterDetail($info,$typeclass,$classid){
|
|
|
+
|
|
|
+ $time = time();
|
|
|
+ $list = [];
|
|
|
+ $fpdata = $info['fpdata'];
|
|
|
+ $fpdata_list = explode(';',trim( $fpdata,';'));
|
|
|
+ $whlabel_list = explode("|",trim($info['whlabel'],"|"));
|
|
|
+
|
|
|
+ $total_goods_num = 0;//订单产品总数量
|
|
|
+ foreach($whlabel_list as $k=>$v){
|
|
|
+ $tmp_data = explode("-",trim($v,'-'));
|
|
|
+ if(isset($tmp_data[1])){
|
|
|
+ $total_goods_num += $tmp_data[1];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $avg_price = floor(($info['skje']*1000)/$total_goods_num)/1000;
|
|
|
+ foreach($fpdata_list as $k=>$v){
|
|
|
+ $tmp_str = str_replace(array('-163-','-164-','-165-','-166-'),'-',$v);
|
|
|
+ $tmp_arr = explode('|',trim($tmp_str,'|'));
|
|
|
+ if(stripos($tmp_arr[0],',') !== false){
|
|
|
+ $ft = explode(',',$tmp_arr[0]);
|
|
|
+ $features = explode('-',trim($ft[1],'-'));
|
|
|
+ $features[] = $ft[0];
|
|
|
+ }else{
|
|
|
+ $features = explode('-',trim($tmp_arr[0],'-'));
|
|
|
+ }
|
|
|
+ $sku = implode("-",$features);
|
|
|
+ $tmp_ret = $this->logic_u9tools->getOneU9bm($sku,$classid,$typeclass);
|
|
|
+ $list[] = [
|
|
|
+ 'jm'=>$tmp_ret['jm'],
|
|
|
+ 'bm'=>$tmp_ret['bm'],
|
|
|
+ 'zh'=>$tmp_ret['zh'],
|
|
|
+ 'final_price'=>$avg_price,//目前先不设置 等后期财务说了再说
|
|
|
+ 'title'=>isset($tmp_arr[1])?$tmp_arr[1]:'无',
|
|
|
+ 'dcsl'=>$tmp_arr[2],
|
|
|
+ 'is_register'=>0,//商品是否被注册 先都当没注册 后面会先确认下
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ $shop = $this->shop->read($info['shop']);
|
|
|
+ if(empty($shop['yyid'])){
|
|
|
+ //如果没有在u9上设置店铺的组织 那么需要设置
|
|
|
+ $this->editData($info['zq_u9_id'],['xs_two_status'=>-1,'update_time'=>time()],$info['number'],1,1,'',[],$this->logic_tools->ret_arr(-1,'店铺没有在u9平台设置参数'));
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+
|
|
|
+ $dc_params = [
|
|
|
+ 'gys'=>$this->gys,//供应商
|
|
|
+ 'number'=>$info['number'],//erp订单编码
|
|
|
+ "TransOutDocType_Code"=>"TransOut001",//组织间调拨
|
|
|
+ "time"=>$time,
|
|
|
+ 'TransferDirection'=>0,//普通
|
|
|
+ 'yyid'=>$shop['yyid'],//来源店铺 这种需要在店铺表中有
|
|
|
+ 'shipremarks'=>$info['shipremarks'],//订单的备注
|
|
|
+ 'dcckbm'=>$this->xdcp_code,//调出仓库编码
|
|
|
+ 'drckbm'=>$this->xdxgls_code,//调入仓库编码
|
|
|
+ 'drzz_code'=>$this->xdxgzzcode,//调入组织Code
|
|
|
+ 'owner_code'=>$this->xdzzcode,//货主组织Code
|
|
|
+ 'ztcode'=>$this->ztcode,//账套
|
|
|
+ 'tb_org_arr'=>$this->tb_org_arr,//要同步的组织列表
|
|
|
+ 'list'=>$list
|
|
|
+ ];
|
|
|
+
|
|
|
+
|
|
|
+ //创建香港仓的销售单
|
|
|
+ $xsd_res = $this->apiyyv1->xsdCreate($dc_params,$this->getToken(140));
|
|
|
+
|
|
|
+ if(empty($xsd_res[0]['Data'][0]['m_code'])){
|
|
|
+ $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]);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ //更新销售单数据
|
|
|
+ $xs_no = $xsd_res[0]['Data'][0]["m_code"];
|
|
|
+ $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]);
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ //检查u9编码是否存在 如果不存在 请先添加并
|
|
|
+ protected function checkLp($info,$token){
|
|
|
+
|
|
|
+ //未注册的货品的列表
|
|
|
+ $unregister_goods = [];
|
|
|
+ // $info['list'][1]['jm'] ="9A-#NB-STW-20-FP-5*5C-C-180%-ww2";
|
|
|
+ // $info['list'][1]['zh'] ="测试数据请删除2--".$info['list'][1]['zh'];
|
|
|
+ // $info['list'][0]['jm'] ="9A-#NB-STW-22-ww2";
|
|
|
+ // $info['list'][0]['zh'] ="测试数据请删除2--".$info['list'][0]['zh'];
|
|
|
+ $r = $this->apiyyv1->cxLp($info['list'],$token);
|
|
|
+ if(!$r[0]['Success']){
|
|
|
+ return $this->logic_tools->ret_arr(-1,'查询商品信息异常'.json_encode($r,JSON_UNESCAPED_UNICODE));
|
|
|
+ }
|
|
|
+
|
|
|
+ foreach($r[0]['Data'] as $k=>$v)
|
|
|
+ {
|
|
|
+ foreach($info['list'] as $kk => $vv){
|
|
|
+ if($v['m_code'] == $vv['jm']){
|
|
|
+ $info['list'][$kk]['is_register'] = 1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ foreach($info['list'] as $k => $v){
|
|
|
+ if($v['is_register'] == 0){
|
|
|
+ $unregister_goods[] = $v;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if(empty($unregister_goods)){
|
|
|
+ return $this->logic_tools->ret_arr(1,"料品无异常");
|
|
|
+ }
|
|
|
+ $tb_info = $info;
|
|
|
+ $tb_info['list'] = $unregister_goods;
|
|
|
+ // //return $this->tbXgLp($tb_info,$token);
|
|
|
+ return $this->tbXgLp($tb_info);
|
|
|
+ }
|
|
|
+ //将许昌仓的料品同步到香港仓
|
|
|
+ public function tbXgLp($tb_info){
|
|
|
+
|
|
|
+ $rr = $this->apiyyv1->tbLp($tb_info,$this->getToken(130));
|
|
|
+
|
|
|
+ if($rr[0]['Success']){
|
|
|
+ return $this->logic_tools->ret_arr(1,$rr);
|
|
|
+ }else{
|
|
|
+ return $this->logic_tools->ret_arr(-1,$rr);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //添加料品并且下发
|
|
|
+ // public function tjLpAndTb($tb_info,$token){
|
|
|
+ // $r = $this->apiyyv1->cjLp($tb_info,$token);
|
|
|
+ // if($r[0]["Success"]){
|
|
|
+ // $rr = $this->apiyyv1->tbLp($tb_info,$token);
|
|
|
+ // if($rr[0]['Success']){
|
|
|
+ // return $this->logic_tools->ret_arr(1,$rr);
|
|
|
+ // }else{
|
|
|
+ // return $this->logic_tools->ret_arr(-1,$rr);
|
|
|
+ // }
|
|
|
+ // }else{
|
|
|
+ // return $this->logic_tools->ret_arr(-1,$r);
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+
|
|
|
+ //根据返回的状态修改对应的值
|
|
|
+ protected function editData($zq_u9_id,$z_qu_arr,$number,$one_type,$two_type,$apply_api,$apply_data,$ret_data){
|
|
|
+ $this->zzquque_u9->save($z_qu_arr,$zq_u9_id);
|
|
|
+ $this->zzququeu9_logs->insert([
|
|
|
+ 'oid'=>$zq_u9_id,
|
|
|
+ 'number'=>$number,
|
|
|
+ 'one_type'=>$one_type,
|
|
|
+ 'two_type'=>$two_type,
|
|
|
+ 'apply_api'=>$apply_api,
|
|
|
+ 'apply_data'=>json_encode($apply_data,JSON_UNESCAPED_UNICODE),
|
|
|
+ 'ret_data'=>json_encode($ret_data,JSON_UNESCAPED_UNICODE),
|
|
|
+ 'create_time'=>time(),
|
|
|
+ 'read_time'=>date("Y-m-d H:i:s")
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+
|
|
|
+ public function xdlsCxDcd($info){
|
|
|
+ $r = $this->apiyyv1->xdlsCxDcd($info['dc_no'],$this->getToken(130));
|
|
|
+ if(empty($r[0]['Data'])){
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ //更新销售单数据
|
|
|
+ $xs_no = json_encode($r[0]['Data']);
|
|
|
+ $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]);
|
|
|
+ }
|
|
|
+}
|
longyi