|
|
@@ -0,0 +1,202 @@
|
|
|
+<?php
|
|
|
+/**
|
|
|
+ * 系统自动处理在途库存的香港问题
|
|
|
+ */
|
|
|
+class Model_logic_u9ztsd extends Lin_Model {
|
|
|
+ public $xczzcode = '130';//许昌销售公司编码
|
|
|
+ public $xccp_code = '13001';//许昌成品库的编码
|
|
|
+ public $xgzzcode = '140';//香港组织公司编码
|
|
|
+ public $xgzt_code = '14001';//香港在途库的编码
|
|
|
+ public $xgmc_code = '14002';//香港美仓的编码
|
|
|
+ public $ztcode = '001';//账套的code;
|
|
|
+ public $tb_org_arr =[140];//同步组织
|
|
|
+ public $gys = "98002";//供应商 98001 龙盈 98002 龙熠
|
|
|
+ public $yyid = "98003";
|
|
|
+ //切记要修改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');
|
|
|
+ $this->load->_model("Model_logic_order","logic_order");
|
|
|
+ $this->load->_model('Model_whlabeltransport', 'whlabeltransport');
|
|
|
+ }
|
|
|
+ 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,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ //创建调出单
|
|
|
+ public function createdDc($info){
|
|
|
+ $pre_data = $this->transPrepare();
|
|
|
+ $typeclass = $pre_data['typeclass'];
|
|
|
+ $classid = $pre_data['classid'];
|
|
|
+ $list = $this->whlabeltransport->find_all("order_no = '".$info['order_no']."'");
|
|
|
+ $do_flag = true;
|
|
|
+ foreach($list as $k=>$v){
|
|
|
+ if($v['cz'] ==1 ){
|
|
|
+ $do_flag = false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(!$do_flag){
|
|
|
+ $this->editData($info['id'],[
|
|
|
+ 'dc_status'=>-1,
|
|
|
+ 'update_time'=>time()
|
|
|
+ ],$info['order_no'],1,1,'dc',[],$this->logic_tools->ret_arr(-1,'此单有已经完成的数据，不能进行同步'));
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ $shipremarks = "";
|
|
|
+ $dc_list = [];
|
|
|
+ foreach($list as $k=>$v){
|
|
|
+ if(stripos($v['features'],'-131-') !== false)
|
|
|
+ {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $v['features'] = str_replace(array('-163-','-164-','-165-','-166-'),'-',$v['features']);
|
|
|
+ $shipremarks = $v["text"];
|
|
|
+ $tmp_ret = $this->logic_u9tools->getOneU9bm($v['features'],$classid,$typeclass);
|
|
|
+ $dc_list[] =[
|
|
|
+ 'jm'=>$tmp_ret['jm'],
|
|
|
+ 'bm'=>$tmp_ret['bm'],
|
|
|
+ 'zh'=>$tmp_ret['zh'],
|
|
|
+ 'dcsl'=>$v['num'],
|
|
|
+ 'is_register'=>0,//商品是否被注册 先都当没注册 后面会先确认下
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ if(empty($dc_list)){
|
|
|
+ $this->editData($info['id'],[
|
|
|
+ 'dc_status'=>-1,
|
|
|
+ 'update_time'=>time()
|
|
|
+ ],$info['order_no'],1,1,'dc',[],$this->logic_tools->ret_arr(-1,'此单sku转化为u9编码,发现没有匹配数据'));
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ $time = time();
|
|
|
+ $dc_params = [
|
|
|
+ 'gys'=>$this->gys,//供应商
|
|
|
+ 'number'=>$info['order_no'],//erp订单编码
|
|
|
+ "TransOutDocType_Code"=>"TransOut001",//组织间调拨
|
|
|
+ "time"=>$time,
|
|
|
+ 'TransferDirection'=>0,//普通
|
|
|
+ 'yyid'=>"",//来源店铺 这种需要在店铺表中有
|
|
|
+ 'shipremarks'=>$shipremarks,//订单的备注
|
|
|
+ 'dcckbm'=>$this->xccp_code,//调出仓库编码
|
|
|
+ 'drckbm'=>$this->xgzt_code,//调入仓库编码
|
|
|
+ 'drzz_code'=>$this->xgzzcode,//调入组织Code
|
|
|
+ 'owner_code'=>$this->xczzcode,//货主组织Code
|
|
|
+ 'ztcode'=>$this->ztcode,//账套
|
|
|
+ 'tb_org_arr'=>$this->tb_org_arr,//要同步的组织列表
|
|
|
+ 'list'=>$dc_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['id'],['dc_status'=>-1,'update_time'=>time()],$info['order_no'],1,1,'lpck',$r['msg'][1],$r['msg'][0]);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ //创建调出单
|
|
|
+ $dcd_res = $this->apiyyv1->dcdCrate($dc_params,$this->getToken(130));
|
|
|
+ if(empty($dcd_res[0]['Data'][0]["Code"])){
|
|
|
+ $this->editData($info['id'],['dc_status'=>-1,'update_time'=>time()],$info['order_no'],1,1,'dc',$dcd_res[1],$dcd_res[0]);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ //更新
|
|
|
+ $dcd_no = $dcd_res[0]['Data'][0]["Code"];
|
|
|
+ $this->editData($info['id'],['dc_no'=>$dcd_no,'dc_status'=>1,'update_time'=>time()],$info['order_no'],1,1,'dc',$dcd_res[1],$dcd_res[0]);
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ //根据返回的状态修改对应的值
|
|
|
+ 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")
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+
|
|
|
+ //检查u9编码是否存在 如果不存在 请先添加并
|
|
|
+ protected function checkLp($info,$token){
|
|
|
+ //未注册的货品的列表
|
|
|
+ $unregister_goods = [];
|
|
|
+ $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);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
|
|
+
|
