erp/core/CoreApp/controllers/Apipf.php

<?php
defined('BASEPATH') OR exit('No direct script access allowed');
/**
 * 本类是为了处理 erp协同其他系统，通过其他系统传递的条件 返回所需信息
 */
class Apipf extends Start_Controller{
    public function __construct(){
		parent::__construct();
        $this->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 "<pre>";
        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 "<pre>";
        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;
    }

}