admin/liche
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add-sylive-item

Browse Source
This commit is contained in:
lccsw
2022-10-21 20:46:40 +08:00
parent 19dcf5a393
commit 79df3ac95a
17 changed files with 1804 additions and 190 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/controllers/plan/Plan.php
+1
View File
@@ -56,6 +56,7 @@ class Plan extends CI_Controller
$plan[] = array('url' => base_url(array('plan', 'syt', 'api_viewlog')), 'interval' => 5); //私域通直播间播放日志数据同步
$plan[] = array('url' => base_url(array('plan', 'syt', 'out_time')), 'interval' => 1); //订单过期
$plan[] = array('url' => base_url(array('plan', 'syt', 'union_user')), 'interval' => 1); //直播数据关联用户
$this->plan = $plan;
}
api/controllers/plan/Syt.php
+44 -5
View File
@@ -45,13 +45,20 @@ class Syt extends CI_Controller
$res = $this->mdSytSubscribemsg->select($where, 'id asc', 1, 100);
$log = array();
if ($res) {
$this->load->model('market/market_sylive_activity_model', 'mdSytActivity');
$wechatS = new WechatServer($this->options);
$wechatS->checkAuth();
$act_ids = implode(',',array_unique(array_column($res,'activityId')));
$act_rows = [];
if($act_ids){
$where = [
"activityId in ($act_ids)" => null
];
$act_rows = $this->market_sylive_activity_model->map('activityId','',$where,'',0,0,'activityId,title');
}
foreach ($res as $key => $value) {
$re_a = $this->mdSytActivity->get(array("activityId" => $value['a_id'], "status" => 0));
if ($re_a) {
$content = '您预约“' . $re_a['title'] . '”直播已经开始啦！赶紧进入直播间观看直播领取福利吧~';
$act = $act_rows['activityId'] ? $act_rows['activityId'][0] : [];
if ($act) {
$content = '您预约“' . $act['title'] . '”直播已经开始啦！赶紧进入直播间观看直播领取福利吧~';
$temp_arr = array(
'touser' => $value['openId'],
'template_id' => $value['templateId'],
@@ -69,6 +76,8 @@ class Syt extends CI_Controller
$log[] = $value['a_id'] . '=' . $value['openid'];
}
}
}else{
$this->mdSytSubscribemsg->update(['status' => -1], ['id' => $value['id']]);
}
}
}
@@ -260,7 +269,7 @@ class Syt extends CI_Controller
$where = [
'expireTime>' => 0,
'expireTime<' => time(),
'status' => 0
'status' => 0,
];
$rows = $this->market_sylive_order_model->select($where,'id asc',1,20);
if($rows){
@@ -432,4 +441,34 @@ class Syt extends CI_Controller
}
echo '更新完成';
}
//更新经销商地址
public function tem_bizinfo(){
require_once COMMPATH . '/third_party/PHPExcel/IOFactory.php';
$this->load->model('market/market_sylive_activity_bizinfo_model');
$file = FCPATH.'pdf/bizinfo.xlsx';
$reader = \PHPExcel_IOFactory::createReader('Excel2007'); // 读取 excel 文档
$PHPExcel = $reader->load($file); // 文档名称
$objWorksheet = $PHPExcel->getActiveSheet();
$rowCnt = $objWorksheet->getHighestRow(); //获取总行数
for ($i = 2; $i <= $rowCnt; $i++) { //读取内容
$areaName = $objWorksheet->getCell('A' . $i)->getValue();
$bizName = $objWorksheet->getCell('B' . $i)->getValue();
$provinceName = $objWorksheet->getCell('C' . $i)->getValue();
$cityName = $objWorksheet->getCell('D' . $i)->getValue();
$addData = [
'activityId' => 4,
'areaName' => $areaName,
'bizName' => $bizName,
'provinceName' => $provinceName,
'cityName' => $cityName,
];
if(!$this->market_sylive_activity_bizinfo_model->count($addData)){
$addData['createTime'] = date('Y-m-d H:i:s');
$this->market_sylive_activity_bizinfo_model->add($addData);
}
}
echo '执行结束';
}
}