分类归档 OPENCART

需要的动作：
1：用户加入购物车，有其他的规格，增加其他规格的积分的显示
controller/checkout/cart.php里的index控制器里修改：

$jifennum=0; //重新定义积分 = 0 ；
foreach ($product[‘option’] as $option) {
if ($option[‘type’] != ‘file’) {
$value = $option[‘value’];
} else {
$upload_info = $this->model_tool_upload->getUploadByCode($option[‘value’]);

if ($upload_info) {
$value = $upload_info[‘name’];
} else {
$value = ”;
}
}

$option_data[] = array(
‘name’ => $option[‘name’],
‘value’ => (utf8_strlen($value) > 20 ? utf8_substr($value, 0, 20) . ‘..’ : $value)
);
//新增判断语句，判断积分的增减
if (!empty($option[‘points_prefix’]) && !empty($option[‘points’])){
if ($option[‘points_prefix’]==’+’){
$jifennum = ($jifennum+$option[‘points’]);
} else {
$jifennum = ($jifennum-$option[‘points’]);
}
}
//判断结束
}
$jifennum = ($jifennum*$product_total); //购买的数量，同时增加积分的总值

$jifen=($product[‘reward’]+$jifennum);
#然后，$data[‘products’][]多维数组重新修改显示的值：

// Display prices
if (($this->config->get(‘config_customer_price’) && $this->customer->isLogged()) || !$this->config->get(‘config_customer_price’)) {
$price = $this->currency->format($this->tax->calculate($product[‘price’], $product[‘tax_class_id’], $this->config->get(‘config_tax’)));
} else {
$price = false;
}

// Display prices
if (($this->config->get(‘config_customer_price’) && $this->customer->isLogged()) || !$this->config->get(‘config_customer_price’)) {
$total = $this->currency->format($this->tax->calculate($product[‘price’], $product[‘tax_class_id’], $this->config->get(‘config_tax’)) * $product[‘quantity’]);
} else {
$total = false;
}

$recurring = ”;

if ($product[‘recurring’]) {
$frequencies = array(
‘day’ => $this->language->get(‘text_day’),
‘week’ => $this->language->get(‘text_week’),
‘semi_month’ => $this->language->get(‘text_semi_month’),
‘month’ => $this->language->get(‘text_month’),
‘year’ => $this->language->get(‘text_year’),
);

if ($product[‘recurring’][‘trial’]) {
$recurring = sprintf($this->language->get(‘text_trial_description’), $this->currency->format($this->tax->calculate($product[‘recurring’][‘trial_price’] * $product[‘quantity’], $product[‘tax_class_id’], $this->config->get(‘config_tax’))), $product[‘recurring’][‘trial_cycle’], $frequencies[$product[‘recurring’][‘trial_frequency’]], $product[‘recurring’][‘trial_duration’]) . ‘ ‘;
}

if ($product[‘recurring’][‘duration’]) {
$recurring .= sprintf($this->language->get(‘text_payment_description’), $this->currency->format($this->tax->calculate($product[‘recurring’][‘price’] * $product[‘quantity’], $product[‘tax_class_id’], $this->config->get(‘config_tax’))), $product[‘recurring’][‘cycle’], $frequencies[$product[‘recurring’][‘frequency’]], $product[‘recurring’][‘duration’]);
} else {
$recurring .= sprintf($this->language->get(‘text_payment_cancel’), $this->currency->format($this->tax->calculate($product[‘recurring’][‘price’] * $product[‘quantity’], $product[‘tax_class_id’], $this->config->get(‘config_tax’))), $product[‘recurring’][‘cycle’], $frequencies[$product[‘recurring’][‘frequency’]], $product[‘recurring’][‘duration’]);
}
}

$data[‘products’][] = array(
‘key’ => $product[‘key’],
‘thumb’ => $image,
‘name’ => $product[‘name’],
‘model’ => $product[‘model’],
‘option’ => $option_data,
‘recurring’ => $recurring,
‘quantity’ => $product[‘quantity’],
‘stock’ => $product[‘stock’] ? true : !(!$this->config->get(‘config_stock_checkout’) || $this->config->get(‘config_stock_warning’)),
//’reward’ => ($product[‘reward’] ? sprintf($this->language->get(‘text_points’), $product[‘reward’]) : ”),
‘reward’ => ($product[‘reward’] ? sprintf($this->language->get(‘text_points’), $jifen) : ”),
‘price’ => $price,
‘total’ => $total,
‘href’ => $this->url->link(‘product/product’, ‘product_id=’ . $product[‘product_id’])
);

这样，用户在购物车看到的赠送积分的规则就变了

然后是后台管理员

2: 后台管理员对订单的操作，首先是修改添加的积分值
sale/order/info方法内

$data[‘reward’] = $order_info[‘reward’]; //获取赠送积分,自然已经自动区分了不同的会员等级

然后该方法内还有个foreach ($products as $product) 循环

$product_num = $product[‘quantity’]; //获取产品的数量
$jifen = 0; //订单规格的积分增加
foreach ($options as $option) {
//嵌入开发规格积分
$guige = $this->model_sale_order->getOrderOptionsData($option[‘product_option_id’],$product[‘product_id’],$option[‘product_option_value_id’]);
if (!empty($guige[‘points_prefix’]) && !empty($guige[‘points’])){

if ($guige[‘points_prefix’]==’+’){
$jifen = ($jifen+($guige[‘points’]*$product_num)); //因为是按数量来计算的
} else {
$jifen = ($jifen-($guige[‘points’]*$product_num));
}
}
if ($option[‘type’] != ‘file’) {
$option_data[] = array(
‘name’ => $option[‘name’],
‘value’ => $option[‘value’],
‘type’ => $option[‘type’]
);
} else {
$upload_info = $this->model_tool_upload->getUploadByCode($option[‘value’]);

if ($upload_info) {
$option_data[] = array(
‘name’ => $option[‘name’],
‘value’ => $upload_info[‘name’],
‘type’ => $option[‘type’],
‘href’ => $this->url->link(‘tool/upload/download’, ‘token=’ . $this->session->data[‘token’] . ‘&code=’ . $upload_info[‘code’], ‘SSL’)
);
}
}
}
$data[‘reward’] =($data[‘reward’]+$jifen); //把对应的规格积分进行相加

在这里引用了一个model
方法原型为：
public function getOrderOptionsData($product_option_id,$product_id,$value,$quantity){
$option_query = $this->db->query(“SELECT po.product_option_id, po.option_id, od.name, o.type FROM ” . DB_PREFIX . “product_option po
LEFT JOIN `” . DB_PREFIX . “option` o ON (po.option_id = o.option_id)
LEFT JOIN ” . DB_PREFIX . “option_description od ON (o.option_id = od.option_id)
WHERE po.product_option_id = ‘” . (int)$product_option_id . “‘
AND po.product_id = ‘” . (int)$product_id . “‘”);
$option_data=array();
if ($option_query->num_rows) {
if ($option_query->row[‘type’] == ‘select’ || $option_query->row[‘type’] == ‘radio’ || $option_query->row[‘type’] == ‘image’) {
$option_value_query = $this->db->query(“SELECT pov.option_value_id, ovd.name, pov.quantity, pov.subtract, pov.price, pov.price_prefix, pov.points, pov.points_prefix, pov.weight, pov.weight_prefix FROM ” . DB_PREFIX . “product_option_value pov LEFT JOIN ” . DB_PREFIX . “option_value ov ON (pov.option_value_id = ov.option_value_id) LEFT JOIN ” . DB_PREFIX . “option_value_description ovd ON (ov.option_value_id = ovd.option_value_id) WHERE pov.product_option_value_id = ‘” . (int)$value . “‘ AND pov.product_option_id = ‘” . (int)$product_option_id . “‘ AND ovd.language_id = ‘” . (int)$this->config->get(‘config_language_id’) . “‘”);

if ($option_value_query->num_rows) {
if ($option_value_query->row[‘price_prefix’] == ‘+’) {
$option_price += $option_value_query->row[‘price’];
} elseif ($option_value_query->row[‘price_prefix’] == ‘-‘) {
$option_price -= $option_value_query->row[‘price’];
}

if ($option_value_query->row[‘points_prefix’] == ‘+’) {
$option_points += $option_value_query->row[‘points’];
} elseif ($option_value_query->row[‘points_prefix’] == ‘-‘) {
$option_points -= $option_value_query->row[‘points’];
}

if ($option_value_query->row[‘weight_prefix’] == ‘+’) {
$option_weight += $option_value_query->row[‘weight’];
} elseif ($option_value_query->row[‘weight_prefix’] == ‘-‘) {
$option_weight -= $option_value_query->row[‘weight’];
}

if ($option_value_query->row[‘subtract’] && (!$option_value_query->row[‘quantity’] || ($option_value_query->row[‘quantity’] < $quantity))) {
$stock = false;
}

$option_data= array(
‘product_option_id’ => $product_option_id,
‘product_option_value_id’ => $value,
‘option_id’ => $option_query->row[‘option_id’],
‘option_value_id’ => $option_value_query->row[‘option_value_id’],
‘name’ => $option_query->row[‘name’],
‘value’ => $option_value_query->row[‘name’],
‘type’ => $option_query->row[‘type’],
‘quantity’ => $option_value_query->row[‘quantity’],
‘subtract’ => $option_value_query->row[‘subtract’],
‘price’ => $option_value_query->row[‘price’],
‘price_prefix’ => $option_value_query->row[‘price_prefix’],
‘points’ => $option_value_query->row[‘points’],
‘points_prefix’ => $option_value_query->row[‘points_prefix’],
‘weight’ => $option_value_query->row[‘weight’],
‘weight_prefix’ => $option_value_query->row[‘weight_prefix’]
);
}
} elseif ($option_query->row[‘type’] == ‘checkbox’ && is_array($value)) {
foreach ($value as $product_option_value_id) {
$option_value_query = $this->db->query(“SELECT pov.option_value_id, ovd.name, pov.quantity, pov.subtract, pov.price, pov.price_prefix, pov.points, pov.points_prefix, pov.weight, pov.weight_prefix FROM ” . DB_PREFIX . “product_option_value pov LEFT JOIN ” . DB_PREFIX . “option_value ov ON (pov.option_value_id = ov.option_value_id) LEFT JOIN ” . DB_PREFIX . “option_value_description ovd ON (ov.option_value_id = ovd.option_value_id) WHERE pov.product_option_value_id = ‘” . (int)$product_option_value_id . “‘ AND pov.product_option_id = ‘” . (int)$product_option_id . “‘ AND ovd.language_id = ‘” . (int)$this->config->get(‘config_language_id’) . “‘”);

if ($option_value_query->num_rows) {
if ($option_value_query->row[‘price_prefix’] == ‘+’) {
$option_price += $option_value_query->row[‘price’];
} elseif ($option_value_query->row[‘price_prefix’] == ‘-‘) {
$option_price -= $option_value_query->row[‘price’];
}

if ($option_value_query->row[‘points_prefix’] == ‘+’) {
$option_points += $option_value_query->row[‘points’];
} elseif ($option_value_query->row[‘points_prefix’] == ‘-‘) {
$option_points -= $option_value_query->row[‘points’];
}

if ($option_value_query->row[‘weight_prefix’] == ‘+’) {
$option_weight += $option_value_query->row[‘weight’];
} elseif ($option_value_query->row[‘weight_prefix’] == ‘-‘) {
$option_weight -= $option_value_query->row[‘weight’];
}

if ($option_value_query->row[‘subtract’] && (!$option_value_query->row[‘quantity’] || ($option_value_query->row[‘quantity’] < $quantity))) {
$stock = false;
}

$option_data= array(
‘product_option_id’ => $product_option_id,
‘product_option_value_id’ => $product_option_value_id,
‘option_id’ => $option_query->row[‘option_id’],
‘option_value_id’ => $option_value_query->row[‘option_value_id’],
‘name’ => $option_query->row[‘name’],
‘value’ => $option_value_query->row[‘name’],
‘type’ => $option_query->row[‘type’],
‘quantity’ => $option_value_query->row[‘quantity’],
‘subtract’ => $option_value_query->row[‘subtract’],
‘price’ => $option_value_query->row[‘price’],
‘price_prefix’ => $option_value_query->row[‘price_prefix’],
‘points’ => $option_value_query->row[‘points’],
‘points_prefix’ => $option_value_query->row[‘points_prefix’],
‘weight’ => $option_value_query->row[‘weight’],
‘weight_prefix’ => $option_value_query->row[‘weight_prefix’]
);
}
}
} elseif ($option_query->row[‘type’] == ‘text’ || $option_query->row[‘type’] == ‘textarea’ || $option_query->row[‘type’] == ‘file’ || $option_query->row[‘type’] == ‘date’ || $option_query->row[‘type’] == ‘datetime’ || $option_query->row[‘type’] == ‘time’) {
$option_data= array(
‘product_option_id’ => $product_option_id,
‘product_option_value_id’ => ”,
‘option_id’ => $option_query->row[‘option_id’],
‘option_value_id’ => ”,
‘name’ => $option_query->row[‘name’],
‘value’ => $value,
‘type’ => $option_query->row[‘type’],
‘quantity’ => ”,
‘subtract’ => ”,
‘price’ => ”,
‘price_prefix’ => ”,
‘points’ => ”,
‘points_prefix’ => ”,
‘weight’ => ”,
‘weight_prefix’ => ”
);
}
}
return $option_data;
}
最后是对积分进行增加和减少的操作
sale/order/addReward()添加积分和removeReward()移除积分

我们来从写addReward()
public function addReward() {
$this->load->language(‘sale/order’);

$json = array();

if (!$this->user->hasPermission(‘modify’, ‘sale/order’)) {
$json[‘error’] = $this->language->get(‘error_permission’);
$json[‘error’]= ‘后台API错误4’;
} else {
if (isset($this->request->get[‘order_id’])) {
$order_id = $this->request->get[‘order_id’];
} else {
$order_id = 0;
}

$this->load->model(‘sale/order’);

$order_info = $this->model_sale_order->getOrder($order_id);
//嵌入开发添加积分开始
$data[‘products’] = array(); //订单产品集
$products = $this->model_sale_order->getOrderProducts($order_id); //获取订单的所有产品
foreach ($products as $product) {
$option_data = array(); //产品规格
$options = $this->model_sale_order->getOrderOptions($order_id, $product[‘order_product_id’]); //获取规格
$product_num = $product[‘quantity’]; //获取产品的数量
$jifen = 0; //订单规格的积分增加
foreach ($options as $option) {
$guige = $this->model_sale_order->getOrderOptionsData($option[‘product_option_id’],$product[‘product_id’],$option[‘product_option_value_id’],$product_num);
if (!empty($guige[‘points_prefix’]) && !empty($guige[‘points’])){
if ($guige[‘points_prefix’]==’+’){
$jifen = ($jifen+($guige[‘points’]*$product_num)); //因为是按数量来计算的
} else {
$jifen = ($jifen-($guige[‘points’]*$product_num));
}
}
}
}
$reward =($order_info[‘reward’]+$jifen); //把对应的规格积分进行相加
//嵌入开发添加积分结束
if ($order_info && $order_info[‘customer_id’] && ($reward > 0)) {
$this->load->model(‘sale/customer’);

$reward_total = $this->model_sale_customer->getTotalCustomerRewardsByOrderId($order_id);

if (!$reward_total) {
//$this->model_sale_customer->addReward($order_info[‘customer_id’], $this->language->get(‘text_order_id’) . ‘ #’ . $order_id, $order_info[‘reward’], $order_id);
$this->model_sale_customer->addReward($order_info[‘customer_id’], $this->language->get(‘text_order_id’) . ‘ #’ . $order_id, $reward, $order_id);
}
}
$json[‘success’] = $this->language->get(‘text_reward_added’);
}
$this->response->addHeader(‘Content-Type: application/json’);
$this->response->setOutput(json_encode($json));
}
removeReward()的话，是根据订单的ID来实现直接删除对应ID，这个不需要修改，但为了避免员工在后台进行到底积分赠送，用户购买之后又把积分移除从新生成积分的刷分过程
直接关闭移除功能

今天做了下OPENCART内的外贸多语言多站点的开发，在OPENCART里默认有一个站点，如果有新添加站点后，重新修改默认站点的数据，导致默认站点的config_url不存在的现象。

先来分析下OPENCART修改默认店铺的流程：

默认的站点，使用的是setting/setting，修改的话不存在store_id的参数，如果是其他站点store_id为必须。

问题就来了。 因为默认站点不存在config_url的配置参数：

来看看setting的edit模型：
public function editSetting($code, $data, $store_id = 0) {
$this->db->query(“DELETE FROM `” . DB_PREFIX . “setting` WHERE store_id = ‘” . (int)$store_id . “‘ AND `code` = ‘” . $this->db->escape($code) . “‘”);

foreach ($data as $key => $value) {
if (substr($key, 0, strlen($code)) == $code) {
if (!is_array($value)) {
$this->db->query(“INSERT INTO ” . DB_PREFIX . “setting SET store_id = ‘” . (int)$store_id . “‘, `code` = ‘” . $this->db->escape($code) . “‘, `key` = ‘” . $this->db->escape($key) . “‘, `value` = ‘” . $this->db->escape($value) . “‘”);
} else {
$this->db->query(“INSERT INTO ” . DB_PREFIX . “setting SET store_id = ‘” . (int)$store_id . “‘, `code` = ‘” . $this->db->escape($code) . “‘, `key` = ‘” . $this->db->escape($key) . “‘, `value` = ‘” . $this->db->escape(serialize($value)) . “‘, serialized = ‘1’”);
}
}
}
}

在执行之前，OC已经完全的删除STORE=0的所有参数信息，然后重新写入

这样因为没有了默认的站点配置，就无法对基础站点的信息进行完整的区分，当然config.php里的文件就有定义常量HTTP_SERVER和HTTPS_SERVER但是多语言的实现URL的问题就会比较麻烦。

解决方法：

setting.tpl模型中添加个

<input type=”text” name=”config_url” value=”<?php echo HTTP_CATALOG; ?>” id=”input-owner” class=”form-control” />

小O这点做的和小M有点像

通过top/left/right布局，来调用对应的模型数据

$modules = $this->model_design_layout->getLayoutModules($layout_id, ‘content_top’);

#->根据布局ID和位置来提取布局内的模块

#->模型中读取layout_module根据排序提取布局ID和位置对应的模型数据

#->数据中会有一个$module[‘code’]的参数，使用的是类型.ID做连接

#->$part = explode(‘.’, $module[‘code’]);

#->然后使用foreach循环提取code值

$setting_info = $this->model_extension_module->getModule($part[1]);  #->根据PART来获取,PART稍后分析
#->操作数据模型-> module WHERE module_id='”.(int)$module_id.”‘”;

public function getModule($module_id) {
$query = $this->db->query(“SELECT * FROM ” . DB_PREFIX . “module WHERE module_id = ‘” . (int)$module_id . “‘”);
if ($query->row) {
return json_decode($query->row[‘setting’], true);
} else {
return array();
}
}

#->模型中，如果有存在对应的模型ID，解码JSON的setting数据到数组并返回

#->来看看JSON原型：{“name”:”Home Page”,”banner_id”:”7″,”width”:”1140″,”height”:”380″,”status”:”1″}

#->可以了，提取了有banner_id参数了

#->接下来$part[0]其实应该是类型 html/slideshow等

#->比如slideshow就是幻灯了

#->自然就要包含/module/slideshow控制器了

#->$data[‘modules’][] = $this->load->controller(‘module/’ . $part[0], $setting_info);

#-> 这样，在ControllerModuleSlideshow控制器里，index()方法中的参数也就存在了

最后作者说下part的参数值：通过打印出我们可以看到：

array(2) { [0]=> string(9) “slideshow” [1]=> string(2) “27” }
array(2) { [0]=> string(4) “html” [1]=> string(2) “32” }

第一就是类型了，第二是module的参数ID；这样就可以很精准的获取了！

最近发现OPENCART发邮件系统有点问题,不知道是配置问题还是怎么的,老是出现错误.

由于邮件系统都是使用/system/library/mail.php里的mail函数

而默认使用方法是:

$mail = new Mail();
$mail->protocol = $this->config->get(‘config_mail_protocol’);
$mail->parameter = $this->config->get(‘config_mail_parameter’);
$mail->smtp_hostname = $this->config->get(‘config_mail_smtp_hostname’);
$mail->smtp_username = $this->config->get(‘config_mail_smtp_username’);
$mail->smtp_password = html_entity_decode($this->config->get(‘config_mail_smtp_password’), ENT_QUOTES, ‘UTF-8’);
$mail->smtp_port = $this->config->get(‘config_mail_smtp_port’);
$mail->smtp_timeout = $this->config->get(‘config_mail_smtp_timeout’);

$mail->setTo($this->request->post[’email’]);
$mail->setFrom($this->config->get(‘config_email’));
$mail->setSender(html_entity_decode($this->config->get(‘config_name’), ENT_QUOTES, ‘UTF-8′));
$mail->setSubject($subject);
$mail->setText($message);
$mail->send();

在类里对成员protocol 进行判断使用MSTP还是SENDMAIL方法

为了保证OPENCART的核心可以正常的使用,作者修改了SMTP的类方法,但只能使用SMTP的类操作,暂未对SENDMAIL进行操作.

使用方法和默认的操作相同

$mail=new mail();
$mail->parameter=’13823819185@139.com’; #抄送一份
$mail->smtp_hostname=’smtp.ym.163.com’;  #邮箱地址
$mail->smtp_username=’admin@qingxinzui.com’;  #用户名
$mail->smtp_password=’************’;  #密码
$mail->smtp_port=’25’; #端口
$mail->smtp_timeout=’30’; #超时施加 //默认5,进行重写
$mailto=”收件人@qingxinzui.com”;
$mailtitle=”测试邮件”; //邮件标题
$mailbody =”<center><div style=’font-size:24px;color:red;’>标题</div></center>”;
$mailbody.=”<table align=’center’ width=’50%’ border=’1′ cellpadding=’2′ cellspacing=’0′>”;
$mailbody.=”<tr><td><center>联系人</center></td><td>名字</td></tr>”;
$mailbody.=”<tr><td><center>联系电话</center></td><td>电话</td></tr>”;
$mailbody.=”<tr><td><center>联系地址</center></td><td>地址</td></tr>”;
$mailbody.=”<tr><td><center>店铺名称</center></td><td>店名</td></tr>”;
$mailbody.=”</table>”;
$mail->setTo($mailto); //收件人
$mail->setFrom($mail->smtp_username); //发件人
$mail->setSubject(html_entity_decode($mailtitle, ENT_QUOTES, ‘UTF-8′));
$mail->setText($mailbody);
$mail->send();

以下为class mail类的封装:

class mail
{
protected $to; //收件人
protected $from; //发件人
protected $subject;
protected $text;
public $protocol;
public $smtp_hostname; #主机地址 smtp.qq.com
public $smtp_username; #用户名
public $smtp_password; #密码
public $smtp_port;  #邮件端口
public $smtp_timeout; #超时时间
public $newline;
public $verp;
public $parameter; //#附加发送
private $ishostname; //主机值保留localhost
public $log_file;
public $debug;
public $auth; //验证
private $sock;

function __construct()
{
$this->smtp_port=25; //构造方法给予端口赋默认值
$this->smtp_timeout=30; //构造方法给予超时赋默认值
$this->ishostname  = “localhost”; //默认值,禁止外部修改
$this->debug=TRUE; //开启调试
$this->log_file=””; //日志文件
$this->sock=FALSE;
$this->protocol=’SMTP’; #邮件类型
$this->auth=TRUE;
$this->newline = “\n”;
$this->verp = false;
$this->parameter=”;
}

public function setTo($to) {
$this->to = $to;
}

public function setFrom($from) {
$this->from = $from;
}

public function setReplyTo($reply_to) {
$this->reply_to = $reply_to;
}

public function setSubject($subject) {
$this->subject = $subject;
}

public function setText($text) {
$this->text = $text;
}

function send()
{
$this->sendmail($this->to, $this->from, $this->subject,$this->text,’HTML’,$this->parameter);
}

private function sendmail($to, $from, $subject = “”, $body = “”, $mailtype, $cc = “”, $bcc = “”, $additional_headers = “”)
{
//收件人,发件人,邮件标题,邮件内容,邮件类型,抄送等参数
$header= “”;
$mail_from = $this->get_address($this->strip_comment($from));
$body= mb_ereg_replace(“(^|(\r\n))(\\.)”, “\\1.\\3”, $body);
$header .= “MIME-Version:1.0\r\n”;
if ($mailtype == “HTML”) {
$header .= ‘Content-type: text/html; charset=utf-8’ . “\r\n”;
}
$header .= “To: ” . $to . “\r\n”;
if ($cc != “”) {
$header .= “Cc: ” . $cc . “\r\n”;
}
$header .= “From: ” .$from . “\r\n”;
$header .= “Subject: ” . $subject . “\r\n”;
$header .= $additional_headers;
$header .= “Date: ” . date(“r”) . “\r\n”;
$header .= “X-Mailer:By (PHP/” . phpversion() . “)\r\n”;
list($msec, $sec) = explode(” “, microtime());
$header .= “Message-ID: <” . date(“YmdHis”, $sec) . “.” . ($msec * 1000000) . “.” . $mail_from . “>\r\n”;
$TO = explode(“,”, $this->strip_comment($to));

if ($cc != “”) {
$TO = array_merge($TO, explode(“,”, $this->strip_comment($cc))); //合并一个或多个数组
}

if ($bcc != “”) {
$TO = array_merge($TO, explode(“,”, $this->strip_comment($bcc)));
}
$sent = TRUE;
foreach ($TO as $rcpt_to) {
$rcpt_to = $this->get_address($rcpt_to);
if (!$this->smtp_sockopen($rcpt_to)) {
$this->log_write(“Error: Cannot send email to ” . $rcpt_to . “\n”);
$sent = FALSE;
continue;

}
if ($this->smtp_send($this->ishostname, $mail_from, $rcpt_to, $header, $body)) {
$this->log_write(“E-mail has been sent to <” . $rcpt_to . “>\n”);
} else {
$this->log_write(“Error: Cannot send email to <” . $rcpt_to . “>\n”);
$sent = FALSE;
}
fclose($this->sock);
$this->log_write(“Disconnected from remote host\n”);
}
echo “<br>”;
return $sent;
}

private function smtp_send($helo, $from, $to, $header, $body = “”)
{
if (!$this->smtp_putcmd(“HELO”, $helo)) {
return $this->smtp_error(“sending HELO command”);
}
#auth
if ($this->auth) {
if (!$this->smtp_putcmd(“AUTH LOGIN”, base64_encode($this->smtp_username))) {
return $this->smtp_error(“sending HELO command”);
}

if (!$this->smtp_putcmd(“”, base64_encode($this->smtp_password))) {
return $this->smtp_error(“sending HELO command”);
}
}
#
if (!$this->smtp_putcmd(“MAIL”, “FROM:<” . $from . “>”)) {
return $this->smtp_error(“sending MAIL FROM command”);
}

if (!$this->smtp_putcmd(“RCPT”, “TO:<” . $to . “>”)) {
return $this->smtp_error(“sending RCPT TO command”);
}

if (!$this->smtp_putcmd(“DATA”)) {
return $this->smtp_error(“sending DATA command”);
}

if (!$this->smtp_message($header, $body)) {
return $this->smtp_error(“sending message”);
}

if (!$this->smtp_eom()) {
return $this->smtp_error(“sending <CR><LF>.<CR><LF> [EOM]”);
}

if (!$this->smtp_putcmd(“QUIT”)) {
return $this->smtp_error(“sending QUIT command”);
}

return TRUE;
}

private function smtp_sockopen($address)
{
if ($this->smtp_hostname == “”) {
return $this->smtp_sockopen_mx($address);
} else {
return $this->smtp_sockopen_relay();
}
}

private function smtp_sockopen_relay()
{
$this->log_write(“Trying to ” . $this->smtp_hostname . “:” . $this->smtp_port . “\n”);
if (empty($this->smtp_timeout))
{
$this->smtp_timeout=5;
}
$this->sock = @fsockopen($this->smtp_hostname, $this->smtp_port, $errno, $errstr, $this->smtp_timeout);

//var_dump($this->sock);die();

if (!($this->sock && $this->smtp_ok())) {
$this->log_write(“Error: Cannot connenct to relay host ” . $this->smtp_hostname . “\n”);
$this->log_write(“Error: ” . $errstr . ” (” . $errno . “)\n”);
return FALSE;
}
$this->log_write(“Connected to relay host ” . $this->smtp_hostname . “\n”);
return TRUE;
}

private function smtp_sockopen_mx($address)
{
$domain = ereg_replace(“^.+@([^@]+)$”, “\\1”, $address);
if (!@getmxrr($domain, $MXHOSTS)) {
$this->log_write(“Error: Cannot resolve MX \”” . $domain . “\”\n”);
return FALSE;
}
foreach ($MXHOSTS as $host) {
$this->log_write(“Trying to ” . $host . “:” . $this->smtp_port . “\n”);
$this->sock = @fsockopen($host, $this->smtp_port, $errno, $errstr, $this->smtp_timeout);
if (!($this->sock && $this->smtp_ok())) {
$this->log_write(“Warning: Cannot connect to mx host ” . $host . “\n”);
$this->log_write(“Error: ” . $errstr . ” (” . $errno . “)\n”);
continue;
}
$this->log_write(“Connected to mx host ” . $host . “\n”);
return TRUE;
}
$this->log_write(“Error: Cannot connect to any mx hosts (” . implode(“, “, $MXHOSTS) . “)\n”);
return FALSE;
}

private function smtp_message($header, $body)
{
fputs($this->sock, $header . “\r\n” . $body);
$this->smtp_debug(“> ” . str_replace(“\r\n”, “\n” . “> “, $header . “\n> ” . $body . “\n> “));

return TRUE;
}

private function smtp_eom()
{
fputs($this->sock, “\r\n.\r\n”);
$this->smtp_debug(“. [EOM]\n”);

return $this->smtp_ok();
}

private function smtp_ok()
{
$response = str_replace(“\r\n”, “”, fgets($this->sock, 512));
$this->smtp_debug($response . “\n”);

if (!mb_ereg(“^[23]”, $response)) {
fputs($this->sock, “QUIT\r\n”);
fgets($this->sock, 512);
$this->log_write(“Error: Remote host returned \”” . $response . “\”\n”);
return FALSE;
}
return TRUE;
}

private function smtp_putcmd($cmd, $arg = “”)
{
if ($arg != “”) {
if ($cmd == “”)
$cmd = $arg;
else
$cmd = $cmd . ” ” . $arg;
}

fputs($this->sock, $cmd . “\r\n”);
$this->smtp_debug(“> ” . $cmd . “\n”);

return $this->smtp_ok();
}

private function smtp_error($string)
{
$this->log_write(“Error: Error occurred while ” . $string . “.\n”);
return FALSE;
}

private function log_write($message)
{
$this->smtp_debug($message);

if ($this->log_file == “”) {
return TRUE;
}

$message = date(“M d H:i:s “) . get_current_user() . “[” . getmypid() . “]: ” . $message;
if (!@file_exists($this->log_file) || !($fp = @fopen($this->log_file, “a”))) {
$this->smtp_debug(“Warning: Cannot open log file \”” . $this->log_file . “\”\n”);
return FALSE;
}
flock($fp, LOCK_EX);
fputs($fp, $message);
fclose($fp);

return TRUE;
}

private function strip_comment($address)
{
$comment = “\\([^()]*\\)”;
while (mb_ereg($comment, $address)) {
$address = mb_ereg_replace($comment, “”, $address);
}

return $address;
}

private function get_address($address)
{
$address = mb_ereg_replace(“([ \t\r\n])+”, “”, $address);
$address = mb_ereg_replace(“^.*<(.+)>.*$”, “\\1”, $address);

return $address;
}

private function smtp_debug($message)
{
if ($this->debug) {
echo $message . “<br>”;
}
}

private function get_attach_type($image_tag) //
{

$filedata = array();

$img_file_con = fopen($image_tag, “r”);
unset($image_data);
while ($tem_buffer = AddSlashes(fread($img_file_con, filesize($image_tag))))
$image_data .= $tem_buffer;
fclose($img_file_con);
$filedata[‘context’]  = $image_data;
$filedata[‘filename’] = basename($image_tag);
$extension            = substr($image_tag, strrpos($image_tag, “.”), strlen($image_tag) – strrpos($image_tag, “.”));
switch ($extension) {
case “.gif”:
$filedata[‘type’] = “image/gif”;
break;
case “.gz”:
$filedata[‘type’] = “application/x-gzip”;
break;
case “.htm”:
$filedata[‘type’] = “text/html”;
break;
case “.html”:
$filedata[‘type’] = “text/html”;
break;
case “.jpg”:
$filedata[‘type’] = “image/jpeg”;
break;
case “.tar”:
$filedata[‘type’] = “application/x-tar”;
break;
case “.txt”:
$filedata[‘type’] = “text/plain”;
break;
case “.zip”:
$filedata[‘type’] = “application/zip”;
break;
default:
$filedata[‘type’] = “application/octet-stream”;
break;
}
return $filedata;
}
}

由于使用OPENCART管理员的核心代码进行二次开发,很多时候用户的操作权限是很重要的,否则就会出现越权修改其他商家的产品等信息.

由于现在作者编写的是B2O2O的类型,暂时还在O2O的开发阶段(B2因为是多域名区分而已,一样需要多用户实现,所以先把重心放在O2O上用户数据的区分上)

作者昨天写了一个图片库区分的方法,该方法类似,主要针对于常用的产品及用户信息(后期B2整合O2O的时候还需要对分类进行划分,思路相同)权限区分功能.

1:用户的登陆数据表是唯一的,有独立的唯一性;

2:用户上传的产品末尾添加字段:product_laction_id; //

OPENCART判断用户是否登陆,其实是判断是否存在$this->session->data[‘user_id’]的参数值

session是一个对象,data是session对象内的一个数组.

在登陆之后,可自行创建新的参数值,比如作者创建的是:

$this->session->data[‘location_user_id’]

虽然值是相同的,但访问权限用任意一个就可以了

为什么呢? 因为OPENCART触发的页面都是以GET的方式获取,如果说你有很强大的前端工程师支撑你完全可以纯AJAX化.

具体是唯一,GET的时候,我们就必须要判断下用户的合法性了

假设有两个用户ID

ID1=100;

ID2=200;

/index.php?route=localisation/location&token=TQEAMbDBFvt6CmRbYszezUn9GmozQQjr&location_user_id=100

我们看上面的链接中,请求localisation里的location控制器,调用默认的index方法

token为OPENCART的加密权限方式,但只是用于区分用户是否已登陆

最后一个参数location_user_id=100;

就是打开控制器之后,根据GET的location_user_id的值,显示用户ID=100的商家信息

直接改200就变ID=200的商家信息了,就会受到恶意的修改.

方法:针对GET的location_user_id与$this->session->data[‘location_user_id’]判断,不存在即die();

不过建议,最好在执行模型SQL语句的时候强制执行.

不管UPDATE还是DELETE.统一WHERE user_id= ‘$location_user_id’;

不管B2B,O2O,C2C,都是要完整的区分用户的目录结构.因为后台都是多用户操作.

在这作者假设你已经可以使用OPENCART二次开发来划分用户的登陆及显示数据.

假设创建一个用户之后,创建一个图片目录,目录名为用户的编号(假设编号$userid为1001);

mkdir(DIR_IMAGE . ‘catalog/’.$this->session->data[‘user_id’] , 0777);

chmod(DIR_IMAGE . ‘catalog/’.$this->session->data[‘user_id’] , 0777);

然后是用户独立后台上传图片,创建目录,进入目录时的方法:

在FileManager控制器中替换掉:

if (isset($this->request->get[‘directory’]))
{
$directory = DIR_IMAGE . ‘catalog/’. $this->request->get[‘directory’];
} else
{
$directory = DIR_IMAGE . ‘catalog/’.$this->session->data[‘user_id’];
}

由于处于开发阶段,可能需要更多的参数需要进行填写.暂时写的先贴上

默认需要有个install()安装控制器方法和uninstall()卸载方法

附上控制器和模型的类方法:

class ControllerPaymentCkzalipay extends Controller {
function index()
{
$this->load->language(‘payment/ckzalipay’);   //默认配置语言包
$this->document->setTitle($this->language->get(‘heading_title’)); //页面标题头
$this->load->model(‘setting/setting’);        //模块/插件的启用和关闭状态表
$this->load->model(‘payment/ckzalipay’); //模型配置模型包
/**
* 开始导入语言包
*/
$data[‘heading_title’] = $this->language->get(‘heading_title’);
$data[‘ckz_id’]=$this->language->get(‘ckz_id’);
$data[‘ckz_key’]=$this->language->get(‘ckz_key’);
$data[‘ckz_account’]=$this->language->get(‘ckz_account’);
$data[‘ckz_save’]=$this->language->get(‘ckz_save’);
$data[‘ckz_false’]=$this->language->get(‘ckz_false’);
$data[‘text_enabled’]=$this->language->get(‘text_enabled’);
$data[‘text_disabled’]=$this->language->get(‘text_disabled’);
$data[‘zhuangtai’]=$this->language->get(‘zhuangtai’);
$data[‘ckz_jishi_text’]=$this->language->get(‘ckz_jishi_text’);
$data[‘ckz_danbao_text’]=$this->language->get(‘ckz_danbao_text’);
$data[‘ckz_alipay_moshi’]=$this->language->get(‘ckz_alipay_moshi’);

/**
* 导入其他栏
*/
$data[‘header’] = $this->load->controller(‘common/header’);
$data[‘column_left’] = $this->load->controller(‘common/column_left’);
$data[‘footer’] = $this->load->controller(‘common/footer’);

/**
* 导入支付宝配置的参数
*/
$data[‘config’]=array();
if(isset($this->request->post[‘ckz_id’])
&& isset($this->request->post[‘ckz_key’])
&& isset($this->request->post[‘ckz_account’])
&& isset($this->request->post[‘ckz_zhuangtai’])
&& isset($this->request->post[‘ckz_moshi’])
)
{
//var_dump($_POST);die();
$data[‘config’][‘ckzalipay_id’]=$this->request->post[‘ckz_id’];
$data[‘config’][‘ckzalipay_key’]=$this->request->post[‘ckz_key’];
$data[‘config’][‘ckzalipay_account’]=$this->request->post[‘ckz_account’];
$data[‘config’][‘ckzalipay_type’]=$this->request->post[‘ckz_moshi’];
//以上三个参数为获取POST数据
$this->model_payment_ckzalipay->setckzalipayconfig($this->request->post[‘ckz_id’],
$this->request->post[‘ckz_key’],
$this->request->post[‘ckz_account’],
$this->request->post[‘ckz_moshi’]);
//执行更新用户的模型数据
$this->model_payment_ckzalipay->update_setting_value($this->request->post[‘ckz_zhuangtai’]);
//更新setting模块状态
$data[‘status_value’]=$this->request->post[‘ckz_zhuangtai’];
//获取当前模块的启用/关闭值得
}
else
{
$data[‘config’]=$this->model_payment_ckzalipay->getckzalipayconfig();
if (empty($data[‘config’]))
{
$data[‘config’][‘ckzalipay_id’]=’this is id’;
$data[‘config’][‘ckzalipay_key’]=’this is key’;
$data[‘config’][‘ckzalipay_account’]=’this is account’;
$data[‘config’][‘ckzalipay_type’]=’0′;
}
if($this->model_payment_ckzalipay->getckzalipayconfig_setting())
{
$data[‘status_value’]=1;
}
else
{
$data[‘status_value’]=0;
}
}
$data[‘action’] = $this->url->link(‘payment/ckzalipay’, ‘token=’ . $this->session->data[‘token’], ‘SSL’); //保存的时候请求的方法
$data[‘cancel’] = $this->url->link(‘extension/payment’, ‘token=’ . $this->session->data[‘token’], ‘SSL’);  //取消的时候返回的页面
$this->response->setOutput($this->load->view(‘payment/ckzalipay.tpl’, $data));
}

function install()
{
/**
* 加载语言模型文件
*/
$this->load->model(‘payment/ckzalipay’);
$this->load->model(‘setting/setting’);
$this->model_payment_ckzalipay->install();
}

function uninstall()
{
$this->load->model(‘payment/ckzalipay’);
$this->model_payment_ckzalipay->uninstall();
}
}

/**
* model file
*
*  由于是支付模块,属于extension
*  所以默认调用了安装,会给extension表内添加对应的字段
*
* */
class ModelPaymentCkzalipay extends Model
{
function install()
{
/**
$this->db->query(”
CREATE TABLE `” . DB_PREFIX . “order_ckzalipay` (
`order_id` int(11) NOT NULL,
`ckzalipay_order_id` varchar(255) NOT NULL,
`free_shipping`  tinyint NOT NULL DEFAULT 0,
KEY `ckzalipay_order_id` (`ckzalipay_order_id`),
PRIMARY KEY `order_id` (`order_id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;
“);

$this->db->query(”
CREATE TABLE `” . DB_PREFIX . “order_ckzalipay_product` (
`order_product_id`  int NOT NULL ,
`ckzalipay_order_item_code`  varchar(255) NOT NULL,
PRIMARY KEY (`order_product_id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;
“);
*/
/**
* 创建支付宝支付配置
* 参数为:
* 验证ID,验证KEY,用户帐户及支付类型(即使到帐和担保交易)
* 其中type=1时为即时到帐
* type=0时为担保交易
*/
$this->db->query(”
CREATE TABLE `” . DB_PREFIX . “order_ckzalipay_config` (
`ckzalipay_id`  varchar(255) NOT NULL ,
`ckzalipay_key`  varchar(255) NOT NULL ,
`ckzalipay_account` varchar(255) NOT NULL ,
`ckzalipay_type` varchar(32) NOT NULL,
PRIMARY KEY (`ckzalipay_id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;
“);

//添加系统模块/插件配置开关
$this->db->query(”
INSERT INTO `” . DB_PREFIX . “setting`
(`store_id`, `code`, `key`, `value`, `serialized`)
VALUES (‘0’, ‘config’, ‘ckzalipay_status’, ‘0’, ‘0’);
“);

}
function uninstall()
{
//以下两个参数暂时不执行
// $this->db->query(“DROP TABLE IF EXISTS `” . DB_PREFIX . “order_ckzalipay`;”);
// $this->db->query(“DROP TABLE IF EXISTS `” . DB_PREFIX . “order_ckzalipay_product`;”);
$this->db->query(“DROP TABLE IF EXISTS `” . DB_PREFIX . “order_ckzalipay_config`;”);
$this->db->query(“DELETE FROM `” . DB_PREFIX . “setting` WHERE `key`=’ckzalipay_status’;”);
}

/**
* 获取清心醉-支付宝的参数配置
* 返回一行数据(只有一行)
* @return unknown
*/
function getckzalipayconfig()
{
$config=$this->db->query(“SELECT * FROM `” . DB_PREFIX . “order_ckzalipay_config`;”);
$config=$config->row; //提取一行数据 全部为rows;
return $config;
}

/**
* 用户写入的清心醉-支付宝数据进行写入保存
* @param unknown $id
* @param unknown $key
* @param unknown $account
*/
function setckzalipayconfig($id,$key,$account,$type)
{
$config=$this->getckzalipayconfig();//首先获取看看有没有数据
if (empty($config))
{
$this->db->query(”
INSERT INTO `” . DB_PREFIX . “order_ckzalipay_config`
(`ckzalipay_id`,`ckzalipay_key`,`ckzalipay_account`,`ckzalipay_type`)
VALUES(‘$id’,’$key’,’$account’,’$type’);
“);
}
else
{
$this->db->query(“UPDATE`” . DB_PREFIX . “order_ckzalipay_config` SET `ckzalipay_id`= ‘$id’, `ckzalipay_key`=’$key’, `ckzalipay_account`=’$account’, `ckzalipay_type`=’$type’;”);
}
}

/**
* 判断开起的模块/插件中key值中是否存在对应的
* $kye的值明确为 ckzalipay_status
* ckzalipay为插件的名称
* status为插件的启用状态
* @param unknown $key
* @return boolean
*/
function getckzalipayconfig_setting()
{
$keys=$this->db->query(“SELECT * FROM `” . DB_PREFIX . “setting` WHERE `key`=’ckzalipay_status'”);
$keys=$keys->row;
if (!empty($keys))
{
if ($keys[‘value’]==1)
{
return true;
}
else {
return false;
}
}
else {
return false;
}
}

function update_setting_value($value)
{
$this->db->query(“UPDATE`” . DB_PREFIX . “setting` SET `value`= ‘$value’ WHERE `key`=’ckzalipay_status’;”);
}
}