information-system/webht/third_party/trippestOrderSync/controllers/send_operation.php

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class Send_operation extends CI_Controller {

    public function __construct(){
        parent::__construct();
        mb_regex_encoding("UTF-8");
        bcscale(4);
        $this->load->helper('array');
        $this->load->model('Send_operation_model', 'send_model');
        $this->send_url = 'https://www.mycht.cn/webht.php/apps/messagecenter/index/send_message/';
        header('Access-Control-Allow-Origin:*');
        header('Access-Control-Allow-Methods:POST, GET');
        header('Access-Control-Max-Age:0');
        header('Access-Control-Allow-Headers:x-requested-with, Content-Type');
        header('Access-Control-Allow-Credentials:true');
    }

    public function index()
    {
        $this->sms_log();
        return;
    }

    public function sms_log()
    {
        $date = $this->input->get_post("date");
        $date = $date ? $date : date('Y-m-d', strtotime("+1 day"));
        $ready_order["date"] = $date;
        $COLI_ID = $this->input->get_post("order_id");
        $ready_order["order_id"] = $COLI_ID;
        $ready_order["list"] = $this->send_model->daytour_order_ready_for_send(trim($COLI_ID), $date, "no_send_state");
        $this->load->view('sms_log', $ready_order);
        return;
    }

    public function order_sms_list($COLI_SN)
    {
        $data['list'] = $this->send_model->order_sms_list($COLI_SN);
        $list_table = $this->load->view('order_sms_list', $data, true);
        $this->output->set_content_type('application/json')->set_output(json_encode($list_table));
        return;
    }

    /*!
     * 通过短信发送导游信息给预定了Day Tour的客人
     * * 每天9:00, 16:00 尝试发送
     * * 第二次发送之后仍然发送失败或没有调度信息, 反馈到Alex邮箱
     * * 这里只是Day Tour 订单, 不含单接送, 因此每个订单仅发送一次
     * @date   2018-09-25
     */
    public function daytour($COLI_ID="")
    {
        $now_h = date("H");
        $time_flag = "";
        if ($now_h < 9 || $now_h > 19) {
            echo "Break time.";
            return false;
        } else if ($now_h >= 9 && $now_h < 16) {
            $time_flag = "try1";
        } else {
            $time_flag = "try2";
        }
        $date = date('Y-m-d', strtotime("+1 day"));
        if (trim($COLI_ID) !== "") {
            $date = null;
            $time_flag = "handle";
        }
        $ready_order = $this->send_model->daytour_order_ready_for_send(trim($COLI_ID), $date, $time_flag);
        if (empty($ready_order)) {
            echo "Empty. ";
            return false;
        }
        $order = $ready_order[0];
        if (strtotime($order->GCI_travelDate) < strtotime(date('Y-m-d')) ) {
            echo "已过期";
            return;
        }
        $send_body = array(
            "one"          => trim($order->GUT_FirstName . " " . $order->GUT_LastName)
            ,"two"         => substr($order->GCI_travelDate, 0, 10)
            ,"three"       => $order->GCOD_dutyName
            ,"four"        => "+86 " . $order->GCOD_dutyTel
            ,"phone"       => real_phone_number($order->GUT_TEL, $order->GUT_POST)
            ,"nation_code" => $order->GUT_POST
        );
        $cb_db = array(
            "TPSL_COLI_SN"     => $order->COLI_SN
            ,"TPSL_nationCode" => $send_body['nation_code']
            ,"TPSL_mobile"     => $send_body['phone']
            ,"TPSL_msgType"    => 'guide'
            ,"TPSL_sendState"  => 0
        );
        $ht_id = $this->send_model->insert_trippest_sms_log($cb_db);
        $error_msg = "";
        $send_time = date("Y-m-d H:i:s");
        if ($order->GCOD_dutyName !== null) {
            $send_cb = $this->excute_curl($this->send_url, $send_body);
            $send_cb_obj = json_decode($send_cb);
            $update_cb_db["TPSL_sendTime"]    = $send_time;
            $update_cb_db["TPSL_sendContent"] = json_encode($send_body);
            $update_cb_db['TPSL_sendState'] = $send_cb_obj->result===0 ? 1 : 0;
            $update_cb_db['TPSL_callbackJson'] = $send_cb;
            $update_cb_db['TPSL_callbackTime'] = date("Y-m-d H:i:s");
            $update_where = " TPSL_SN=" . $ht_id;
            $ht_id = $this->send_model->update_trippest_sms_log($update_where, $update_cb_db);
            $send_cb_obj->errmsg!=="OK" ? $error_msg=$send_cb_obj->errmsg : null;
        }
        if ($time_flag === "try1") {
            return;
        }
        if ($order->GCOD_dutyName === null || $error_msg !== "") {
            // 没有调度或发送失败
            // to Alex
            $operator_mailbody = "<p> Dear Alex: </p>" .
                "<p>导游信息发送客人失败：<br /></p>" .
                "<p>订单号:" . $order->COLI_ID ."</p>" .
                "<p>发团时间:" . substr($order->GCI_travelDate, 0, 10) ."</p>" .
                "<p>导游信息:" . $order->GCOD_dutyName . "(" . $order->GCOD_dutyTel . ")" ."</p>" .
                "<p>导游更新时间:" . $order->GCI_createTime . "    " . $order->GCOD_creatTime ."</p>" .
                "<p>发送时间:" . $send_time ."</p>";
            if ($error_msg !== "") {
                $operator_mailbody .= "<p>发送失败信息:" . $error_msg . "</p>";
            }
            $operator_mailbody .= "<p><a href='https://www.trippest.com/track-your-trip/'>Tracking Link</a>.</p>";
            $operator_mailbody .= "<p> 此邮件由系统自动发送, 请勿回复.</p>";
            $this->send_model->SendMail(
                "chinahighlights",
                "webform@chinahighlights.net",
                "YSL",
                "alex@chinahighlights.net", // ysl email alex@chinahighlights.net
                '#SMS send fail#  ' . $order->COLI_ID,
                $operator_mailbody);
        }
        echo "已发送";
        return;
    }

    protected function excute_curl($url, $postBody) {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_FAILONERROR, false);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
            "Accept: application/json"
        ));

        if (empty($postBody)) {
            return false;
        }
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $postBody);

        $reponse = curl_exec($ch);
        // $eval_resp = json_decode($reponse);

        if (curl_errno($ch)) {
            log_message('error', "curl error : ".curl_error($ch) . "; curl postBodyString: ".json_encode($postBody));
        } else {
            $httpStatusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            if (200 !== $httpStatusCode) {
                log_message('error', "curl response Status Code: ".$httpStatusCode."; curl postBodyString: ".json_encode($postBody));
            }
        }
        curl_close($ch);
        return $reponse;
    }

}

/* End of file send_operation.php */
/* Location: ./webht/third_party/trippestOrderSync/controllers/send_operation.php */