load->_model('Model_logic_order','logic_order'); $this->load->_model('Model_logic_tools','logic_tools'); $this->load->_model("Model_logic_ding",'logic_ding'); $this->load->_model('Model_customer','customer'); $this->load->_model('Model_typeclass','typeclass'); } private $key = "bpng!pjgirv6amnfr"; //加密所需要到的key private $iv = "k4k!94m66oojtm2w";//加密所需要到的iv private $api = "202503121009@ly"; //定义方法的调用规则 获取URI第二段值 public function _remap($arg,$arg_array) { if($arg == 'checkMoreThree')//添加 { $this->_checkMoreThree(); } elseif($arg == 'customerData') { $this->_customerData(); } elseif($arg == 'orderTbAllData') { $this->_orderTbAllData(); } elseif($arg == 'orderTbData') { $this->_orderTbData(); } else { exit('No direct script access allowed'); } } //检测客户是否超过3次且为传输 public function _checkMoreThree(){ $api = $this->input->get('api',true); if($api != $this->api){ die("No data to be executed"); } $hour = date("H"); $minute = date("i"); if($hour != 20){ die("Execution conditions hour do not allow"); } if(($minute >= 10)&&($minute <=20)){ $this->db->query("update crowd_customer set more_three = 1 where num >= 3 and more_three = 0"); die("No executable data available"); }else{ die("Execution conditions minute do not allow !"); } } /*** * 上传没有给批发站没有传递的客户信息 */ public function _customerData(){ $list = $this->customer->find_all("more_three = 1","id,shop,source,name,email,phone,money,num,country,province,city,street,address,address2,zipcode",'id asc',0,100); $list_ids = []; $send_list = []; foreach($list as $k=>$v){ $list_ids[] = $v['id']; $send_list[] = [ 'name'=>$v['name'], 'email'=>$v['email'], 'telephone'=>$v['phone'], 'money'=>$v['money'], 'num'=>$v['num'], 'country'=>$v['country'], 'province'=>$v['province'], 'city'=>$v['city'], 'street'=>$v['street'], 'address'=>$v['address'].$v['address2'], 'zipcode'=>$v['zipcode'] ]; } $header = []; $url = ""; if(empty($send_list)){ die("There is no customer data to be synchronized"); } die("update crowd_customer set more_three = 2 where id in (".implode(",",$list_ids).")"); $this->db->query("update crowd_customer set more_three = 2 where id in (".implode(",",$list_ids).")"); // $res = $this->sendHttp($url,$header,$send_list); // if($res){ // $this->db->query("update crowd_customer set more_three = 2 where id in (".implode(",",$list_ids).")"); // } } public function _orderTbAllData(){ $typeclass = $this->typeclass->find_all("classid = 29","id,classtitle,title,spare"); $typeclass = array_column($typeclass,null,'id'); $list = $this->customer->find_all("more_three = 2","id,shop,name,email",'id asc',0,100); foreach($list as $k=>$v){ $order_list = $this->getOrder($v,$typeclass); if(empty($order_list)){ continue; } } } private function getOrder($v,$typeclass){ $fdata = $this->fullorder->find_all('email = "'.$customer['email'].'" and shop = "'.$customer['shop'].'" and mergeid = 0 and reviewtime <= ','shop,orderinfo,issku,quantity,fpdata,state,product,name,email,dtime,shouldmoney,shipremarks','id desc'); $ret_list = []; foreach ($fdata as $k=>$v) { $sku_list = []; $issku_arr = explode(",",trim($v['issku'],',')); $quantity_arr = explode(";",trim($v['quantity'],";")); $product_arr = explode(",",trim($v['product'],";")); foreach($issku_arr as $key => $item){ $sku_list[] = [ 'sku'=>$item, 'qty'=>isset($quantity_arr[$key])?$quantity_arr[$key]:1, 'product_name'=>isset($product_arr[$key])?$product_arr[$key]:"", ]; } $goods_list = []; $fpdata_arr = explode(";",trim($v['fpdata'],";")); if(!empty($tmp_data[1])){ foreach($fpdata_arr as $key => $item){ $tmp_data = explode("|",$item); $goods_list[] = [ 'goods_name'=>$tmp_data[1], 'qty'=>$tmp_data[2] ]; } }else{ continue; } $ret_list[] = [ 'shop'=>$v['shop'], 'orderinfo'=>$v['orderinfo'], 'sku_list'=>$sku_list, 'goods_list'=>$goods_list, 'state'=>isset($typeclass[$v['state']])?$typeclass[$v['state']]['spare']:"", 'dtime'=>date('Y-m-d',$v['dtime']), 'name'=>$v['name'], 'email'=>$v['email'], 'shouldmoney'=>$v['shouldmoney'], 'shipremarks'=>$v['shipremarks'] ]; } return $fdata; } public function _orderTbData(){ $fdata = $this->fullorder->find_all('id = 1228433','shop,orderinfo,issku,quantity,fpdata,state,product,name,email,dtime,shouldmoney,shipremarks','id desc'); $ret_list = []; echo "
";
        foreach ($fdata as $k=>$v) 
        {
            var_dump($v);
            $sku_list = [];
            $issku_arr = explode(",",trim($v['issku'],','));
            $quantity_arr = explode(";",trim($v['quantity'],";"));
            $product_arr = explode(",",trim($v['product'],";"));
            foreach($issku_arr as $key => $item){
                $sku_list[] = [
                    'sku'=>$item,
                    'qty'=>isset($quantity_arr[$key])?$quantity_arr[$key]:1,
                    'product_name'=>isset($product_arr[$key])?$product_arr[$key]:"",
                ];
            }
            $goods_list = [];
            $fpdata_arr = explode(";",trim($v['fpdata'],";"));
            if(!empty($tmp_data[1])){
                foreach($fpdata_arr as $key => $item){
                    $tmp_data = explode("|",$item);
                    $goods_list[] = [
                        'goods_name'=>$tmp_data[1],
                        'qty'=>$tmp_data[2]
                    ];
                }
            }else{
                continue;
            }
           
            
            $ret_list[] = [
                'shop'=>$v['shop'],
                'orderinfo'=>$v['orderinfo'],
                'sku_list'=>$sku_list,
                'goods_list'=>$goods_list,
                'state'=>isset($typeclass[$v['state']])?$typeclass[$v['state']]['spare']:"",
                'dtime'=>date('Y-m-d',$v['dtime']),
                'name'=>$v['name'],
                'email'=>$v['email'],
                'shouldmoney'=>$v['shouldmoney'],
                'shipremarks'=>$v['shipremarks']
            ];
        }
        echo "
";
        var_dump($ret_list);
    }

    private function sendHttp($url,$header,$list){
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
		curl_setopt($ch, CURLINFO_HEADER_OUT, TRUE);
		curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $list);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        $res = curl_exec($ch);
		$res = json_decode($res,true);
		return $res;
    }

}