|
|
@@ -0,0 +1,617 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace Share\Src;
|
|
|
+
|
|
|
+use Dever;
|
|
|
+
|
|
|
+class User
|
|
|
+{
|
|
|
+ const INFO = 'set/info:applet';
|
|
|
+ const SHARE = 'comment/share:applet';
|
|
|
+ const USER = 'passport/user:applet';
|
|
|
+ const NEWS = 'content/news:applet';
|
|
|
+ const COURSE = 'content/course:applet';
|
|
|
+ const MEETING = 'content/meeting:applet';
|
|
|
+ const SERVICE = 'content/service:applet';
|
|
|
+ const ACTIVE = 'activity/active:applet';
|
|
|
+ const REFLUX = 'comment/share_reflux:applet';
|
|
|
+ const SHARELOG = 'comment/share_log:applet';
|
|
|
+ const SHAREGROUP = 'comment/share_group:applet';
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 小程序列表
|
|
|
+ *
|
|
|
+ * @return mixed
|
|
|
+ */
|
|
|
+ public function applet()
|
|
|
+ {
|
|
|
+ $info = Dever::db(self::INFO);
|
|
|
+ $data = $info->state();
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 导入excel
|
|
|
+ *
|
|
|
+ * @return mixed
|
|
|
+ */
|
|
|
+ public function import()
|
|
|
+ {
|
|
|
+ $file = Dever::data() . 'user.xlsx';
|
|
|
+ $reader = new \PHPExcel_Reader_Excel2007();
|
|
|
+ if(!$reader->canRead($file)){
|
|
|
+ $reader = new \PHPExcel_Reader_Excel5();
|
|
|
+ if(!$reader->canRead($file)){
|
|
|
+ echo 'no Excel';
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ $xls = $reader->load($file);
|
|
|
+ $currentSheet = $xls->getSheet(0);
|
|
|
+ $column = $currentSheet->getHighestColumn();
|
|
|
+ $row = $currentSheet->getHighestRow();
|
|
|
+
|
|
|
+ $group = $name = $wechat = array();
|
|
|
+ for ($curRow = 5;$curRow <= $row; $curRow++) {
|
|
|
+ for ($curColumn = 'A';$curColumn<= $column; $curColumn++) {
|
|
|
+ $value = $currentSheet->getCellByColumnAndRow(ord($curColumn) - 65,$curRow)->getValue();
|
|
|
+ if ($curColumn == 'B') {
|
|
|
+ //分组
|
|
|
+ if ($value) {
|
|
|
+ $group_id = Dever::upinto('share/group', array('name' => $value), array('name' => $value));
|
|
|
+ }
|
|
|
+
|
|
|
+ } elseif ($curColumn == 'C') {
|
|
|
+ //姓名
|
|
|
+ if ($value && isset($group_id) && $group_id) {
|
|
|
+ Dever::upinto('share/user', array('name' => $value), array('group_id' => $group_id, 'name' => $value));
|
|
|
+ }
|
|
|
+ } elseif ($curColumn == 'D') {
|
|
|
+ //微信
|
|
|
+ $wechat[$value] = $value;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 导出成excel
|
|
|
+ *
|
|
|
+ * @return mixed
|
|
|
+ */
|
|
|
+ public function out()
|
|
|
+ {
|
|
|
+ $applet = $this->applet();
|
|
|
+ $group = Dever::db('share/group')->state();
|
|
|
+ $user = Dever::db('share/user')->getAll();
|
|
|
+
|
|
|
+ $day = Dever::input('day');
|
|
|
+ if (!$day) {
|
|
|
+ $day = date('Y-m-d', time()-3600*24);
|
|
|
+ }
|
|
|
+ $start = Dever::maketime(date('Y-m-01 00:00:00', Dever::maketime($day)));
|
|
|
+ $end = Dever::maketime(date('Y-m-t 23:59:59', Dever::maketime($day)));
|
|
|
+
|
|
|
+ $log = Dever::db('share/log')->state();
|
|
|
+ $i = 0;
|
|
|
+ foreach ($user as $k => $v) {
|
|
|
+ if (!$v['wechat_name']) {
|
|
|
+ unset($user[$k]);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ $user[$k]['group'] = $group[$v['group_id']]['name'];
|
|
|
+ $user[$k]['info'] = Dever::db('share/info')->one(array('share_day' => $day, 'user_id' => $v['id']));
|
|
|
+ if (!$user[$k]['info']) {
|
|
|
+ $user[$k]['info']['share_article_num'] = 0;
|
|
|
+ $user[$k]['applet'] = '未知';
|
|
|
+ } else {
|
|
|
+ $user[$k]['applet'] = array();
|
|
|
+ if ($user[$k]['info']['applet']) {
|
|
|
+ $temp = explode(',', $user[$k]['info']['applet']);
|
|
|
+ foreach ($temp as $k1 => $v1) {
|
|
|
+ $user[$k]['applet'][$k1] = $applet[$v1]['name'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ $user[$k]['applet'] = implode("\r\n", $user[$k]['applet']);
|
|
|
+ }
|
|
|
+ $user[$k]['log'] = Dever::db('share/log')->state(array('share_day' => $day, 'user_id' => $v['id']));
|
|
|
+ $total = Dever::db('share/log')->month(array('start' => $start, 'end' => $end, 'user_id' => $v['id']));
|
|
|
+ $user[$k]['total'] = 0;
|
|
|
+ if ($total) {
|
|
|
+ $user[$k]['total'] = $total['num'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!$user[$k]['total']) {
|
|
|
+ $user[$k]['total'] = 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ $user[$k]['status'] = '已达标';
|
|
|
+ if ($user[$k]['info']['share_article_num'] < 3) {
|
|
|
+ $user[$k]['status'] = '未达标';
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($user[$k]['name'] && $user[$k]['info']) {
|
|
|
+ $data[$i] = array
|
|
|
+ (
|
|
|
+ $i+1,
|
|
|
+ $user[$k]['group'],
|
|
|
+ $user[$k]['name'],
|
|
|
+ $user[$k]['wechat_name'],
|
|
|
+ $user[$k]['applet'],
|
|
|
+ $user[$k]['info']['share_article_num'],
|
|
|
+ $user[$k]['total'],
|
|
|
+ $user[$k]['status'],
|
|
|
+ );
|
|
|
+ $i++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $header = array
|
|
|
+ (
|
|
|
+ '序号', '业务板块', '姓名', '微信昵称', '负责小程序名称', '分享文章数', '月总回流', '是否达标'
|
|
|
+ );
|
|
|
+
|
|
|
+ $file = $day . '_小程序推广';
|
|
|
+ if (Dever::input('test')) {
|
|
|
+ print_r($header);
|
|
|
+ print_r($data);die;
|
|
|
+ }
|
|
|
+
|
|
|
+ Dever::excelExport($data, $header, $file, $sheet = 0, $sheetName = $day);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ public function test()
|
|
|
+ {
|
|
|
+ $name = '姓名';
|
|
|
+ $header = array
|
|
|
+ (
|
|
|
+ $name,'手机号'
|
|
|
+ );
|
|
|
+ $data = array
|
|
|
+ (
|
|
|
+ array
|
|
|
+ (
|
|
|
+ '于斌', '15810090845'
|
|
|
+ ),
|
|
|
+ array
|
|
|
+ (
|
|
|
+ '3', '4'
|
|
|
+ ),
|
|
|
+ );
|
|
|
+ Dever::excelExport($data, $header, $filename = 'test');
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取数据
|
|
|
+ *
|
|
|
+ * @return mixed
|
|
|
+ */
|
|
|
+ public function data()
|
|
|
+ {
|
|
|
+ $user = Dever::db('share/user')->state();
|
|
|
+ foreach ($user as $k => $v) {
|
|
|
+ if ($v['wechat_name']) {
|
|
|
+ $user[$k] = $this->userData($v);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ public function userData($data)
|
|
|
+ {
|
|
|
+ if ($data['uid']) {
|
|
|
+ $where = array
|
|
|
+ (
|
|
|
+ 'option' => array
|
|
|
+ (
|
|
|
+ 'id' => array('yes', 'in'),
|
|
|
+ ),
|
|
|
+ 'id' => explode(',', $data['uid']),
|
|
|
+ );
|
|
|
+ $user = Dever::db(self::USER)->state($where);
|
|
|
+ } else {
|
|
|
+ $user = Dever::db(self::USER)->state(array('name' => $data['wechat_name']));
|
|
|
+ }
|
|
|
+
|
|
|
+ $ids = array();
|
|
|
+ if ($user) {
|
|
|
+ $ids = array_keys($user);
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($ids) {
|
|
|
+ $user = array();
|
|
|
+ $option = array
|
|
|
+ (
|
|
|
+ 'share_id' => 'yes',
|
|
|
+ 'uid' => array('yes', 'in'),
|
|
|
+ 'start' => array('yes-cdate', '>='),
|
|
|
+ 'end' => array('yes-cdate', '<='),
|
|
|
+ );
|
|
|
+
|
|
|
+ //获取昨天数据
|
|
|
+ $time = time() - (3600 * 24);
|
|
|
+ $set = Dever::input('set');
|
|
|
+ if ($set) {
|
|
|
+ $time = Dever::maketime($set);
|
|
|
+ }
|
|
|
+ $day = date('Y-m-d', $time);
|
|
|
+ $day_prev = date('Y-m-d', strtotime("$day -1 day"));//前天
|
|
|
+
|
|
|
+ $start = date('Y-m-d 00:00:00', $time);
|
|
|
+ $end = date('Y-m-d 23:59:59', $time);
|
|
|
+
|
|
|
+ $day_start = Dever::maketime($start);
|
|
|
+ $day_end = Dever::maketime($end);
|
|
|
+ $where = array
|
|
|
+ (
|
|
|
+ 'option' => $option,
|
|
|
+ 'uid' => $ids,
|
|
|
+ 'start' => $day_start,
|
|
|
+ 'end' => $day_end
|
|
|
+ );
|
|
|
+ $share = Dever::db(self::SHARE)->state($where);
|
|
|
+ if ($share) {
|
|
|
+ $user['applet'] = array();
|
|
|
+ //$user['applet'] = $data['applet'];
|
|
|
+ $user['user_id'] = $data['id'];
|
|
|
+ $user['share_day'] = $day;
|
|
|
+ $user['share_num'] = 0;
|
|
|
+ //$user['share_reflux_num'] = Dever::db(self::REFLUX)->total(array('source_uid' => $user['id']));
|
|
|
+ //获取月度回流
|
|
|
+ unset($where['option']['uid']);
|
|
|
+ $where['option']['source_uid'] = array('yes', 'in');
|
|
|
+ $where['source_uid'] = $ids;
|
|
|
+
|
|
|
+ //$user['share_reflux_num'] = Dever::db(self::REFLUX)->total($where);
|
|
|
+ $user['share_group_num'] = $user['share_reflux_num'] = 0;
|
|
|
+ $article = array();
|
|
|
+ foreach ($share as $k => $v) {
|
|
|
+ $info = $this->shareData($v, $where, $article);
|
|
|
+ if ($info) {
|
|
|
+ $user['applet'][$info['applet']['id']] = $info['applet']['id'];
|
|
|
+ $article[$info['source_table'] . '_' . $info['id']] = 1;
|
|
|
+ $user['share'][$k] = $info;
|
|
|
+ $user['share_num'] += $user['share'][$k]['num'];
|
|
|
+ $user['share_group_num'] += $user['share'][$k]['group_num'];
|
|
|
+ $user['share_reflux_num'] += $user['share'][$k]['reflux_num'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ $user['applet'] = implode(',', $user['applet']);
|
|
|
+ $user['share_article_num'] = count($article);
|
|
|
+
|
|
|
+ $this->updateInfo($user, $day_prev);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return $user;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ public function shareData($data, $where)
|
|
|
+ {
|
|
|
+ $result = array();
|
|
|
+ $table = false;
|
|
|
+ switch ($data['source_table']) {
|
|
|
+ case 1:
|
|
|
+ $table = self::NEWS;
|
|
|
+ break;
|
|
|
+ case 2:
|
|
|
+ $table = self::COURSE;
|
|
|
+ break;
|
|
|
+ case 3:
|
|
|
+ $table = self::MEETING;
|
|
|
+ break;
|
|
|
+ case 5:
|
|
|
+ $table = self::SERVICE;
|
|
|
+ break;
|
|
|
+ case 8:
|
|
|
+ $table = self::ACTIVE;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($table && $data['source_id'] > 0) {
|
|
|
+ $info = Dever::db($table)->one($data['source_id']);
|
|
|
+ if ($info) {
|
|
|
+ $result['applet'] = Dever::db(self::INFO)->one($data['info_id']);
|
|
|
+ $result['source_table'] = $data['source_table'];
|
|
|
+ $result['id'] = $info['id'];
|
|
|
+ $result['name'] = $info['name'];
|
|
|
+ $result['time'] = date('Y-m-d H:i:s', $data['cdate']);
|
|
|
+ $result['cdate'] = $data['cdate'];
|
|
|
+ $result['num'] = $data['num'];
|
|
|
+ $result['group_num'] = $data['group_num'];
|
|
|
+
|
|
|
+ $where['share_id'] = $data['id'];
|
|
|
+ $result['reflux_num'] = Dever::db(self::REFLUX)->total($where);
|
|
|
+
|
|
|
+ unset($where['option']['source_uid']);
|
|
|
+
|
|
|
+ $result['num'] = Dever::db(self::SHARELOG)->total($where);
|
|
|
+ $result['group_num'] = Dever::db(self::SHAREGROUP)->total($where);
|
|
|
+
|
|
|
+ if ($result['num'] <= 0) {
|
|
|
+ $result['reflux_num'] = 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($result['group_num'] > $result['num']) {
|
|
|
+ $result['num'] = $result['group_num'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return $result;
|
|
|
+ }
|
|
|
+
|
|
|
+ public function updateInfo($user, $day_prev)
|
|
|
+ {
|
|
|
+ # 获取上个月的数据 减去上个月的数据
|
|
|
+ /*
|
|
|
+ if ($user['share_day'] != $day_prev) {
|
|
|
+ $where = array();
|
|
|
+ $where['option_user_id'] = $user['user_id'];
|
|
|
+ $where['option_share_day'] = $day_prev;
|
|
|
+ $prev = Dever::db('share/info')->one($where);
|
|
|
+ if ($prev) {
|
|
|
+ $user['share_num'] = $user['share_num'] - $prev['share_num'];
|
|
|
+ $user['share_group_num'] = $user['share_group_num'] - $prev['share_group_num'];
|
|
|
+ }
|
|
|
+ }*/
|
|
|
+ $update = array();
|
|
|
+ $update['user_id'] = $user['user_id'];
|
|
|
+ $update['applet'] = $user['applet'];
|
|
|
+ $update['share_day'] = $user['share_day'];
|
|
|
+ $update['share_num'] = $user['share_num'];
|
|
|
+ $update['share_reflux_num'] = $user['share_reflux_num'];
|
|
|
+ $update['share_article_num'] = $user['share_article_num'];
|
|
|
+ $update['share_group_num'] = $user['share_group_num'];
|
|
|
+ $update['status'] = 1;
|
|
|
+ if ($update['share_article_num'] >= 3) {
|
|
|
+ $update['status'] = 2;
|
|
|
+ }
|
|
|
+
|
|
|
+ $where = array();
|
|
|
+ $where['option_user_id'] = $update['user_id'];
|
|
|
+ $where['option_share_day'] = $update['share_day'];
|
|
|
+
|
|
|
+ $info = Dever::db('share/info')->one($where);
|
|
|
+ if (!$info) {
|
|
|
+ $id = Dever::db('share/info')->insert($update);
|
|
|
+ } else {
|
|
|
+ $id = $info['id'];
|
|
|
+ $update['where_id'] = $id;
|
|
|
+ Dever::db('share/info')->update($update);
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($id > 0 && isset($user['share'])) {
|
|
|
+ $user['share_num'] = 0;
|
|
|
+ $user['share_group_num'] = 0;
|
|
|
+ foreach ($user['share'] as $k => $v) {
|
|
|
+ $result = $this->updateLog($k, $v, $id, $update['user_id'], $user['share_day'], $day_prev);
|
|
|
+ if (isset($result['share_num'])) {
|
|
|
+ $update['share_num'] += $result['share_num'];
|
|
|
+ }
|
|
|
+ if (isset($result['share_group_num'])) {
|
|
|
+ $update['share_group_num'] += $result['share_group_num'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if ($user['share_num'] > 0) {
|
|
|
+ $update = array();
|
|
|
+ $update['share_num'] = $user['share_num'];
|
|
|
+ $update['share_group_num'] = $user['share_group_num'];
|
|
|
+ $update['where_id'] = $id;
|
|
|
+ Dever::db('share/info')->update($update);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public function updateLog($share_id, $data, $info_id, $user_id, $day, $day_prev)
|
|
|
+ {
|
|
|
+ $prev = array();
|
|
|
+ /*
|
|
|
+ if ($day != $day_prev) {
|
|
|
+ $where = array();
|
|
|
+ $where['option_share_id'] = $share_id;
|
|
|
+ $where['option_user_id'] = $user_id;
|
|
|
+ $where['option_info_id'] = $info_id;
|
|
|
+ $where['option_source_id'] = $data['id'];
|
|
|
+ $where['option_share_day'] = $day_prev;
|
|
|
+ $where['option_applet'] = $data['applet']['id'];
|
|
|
+ $prev = Dever::db('share/log')->one($where);
|
|
|
+ if ($prev) {
|
|
|
+ $data['num'] = $data['num'] - $prev['share_num'];
|
|
|
+ $data['group_num'] = $data['group_num'] - $prev['share_group_num'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ */
|
|
|
+ $update = array();
|
|
|
+ $update['user_id'] = $user_id;
|
|
|
+ $update['info_id'] = $info_id;
|
|
|
+ $update['share_id'] = $share_id;
|
|
|
+ $update['share_day'] = $day;
|
|
|
+ $update['applet'] = $data['applet']['id'];
|
|
|
+ $update['name'] = $data['name'];
|
|
|
+ $update['source_id'] = $data['id'];
|
|
|
+ $update['source_table'] = $data['source_table'];
|
|
|
+ $update['share_num'] = $data['num'];
|
|
|
+ $update['sdate'] = $data['cdate'];
|
|
|
+ $update['share_group_num'] = $data['group_num'];
|
|
|
+ $update['share_reflux_num'] = $data['reflux_num'];
|
|
|
+
|
|
|
+ $where = array();
|
|
|
+ $where['option_share_id'] = $update['share_id'];
|
|
|
+ $where['option_user_id'] = $update['user_id'];
|
|
|
+ $where['option_info_id'] = $update['info_id'];
|
|
|
+ $where['option_source_id'] = $update['source_id'];
|
|
|
+ $where['option_share_day'] = $update['share_day'];
|
|
|
+ $where['option_applet'] = $update['applet'];
|
|
|
+
|
|
|
+ $info = Dever::db('share/log')->one($where);
|
|
|
+ if (!$info) {
|
|
|
+ Dever::db('share/log')->insert($update);
|
|
|
+ } else {
|
|
|
+ $update['where_id'] = $info['id'];
|
|
|
+ Dever::db('share/log')->update($update);
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($prev) {
|
|
|
+ return array
|
|
|
+ (
|
|
|
+ 'share_num' => $data['num'],
|
|
|
+ 'share_group_num' => $data['group_num'],
|
|
|
+ );
|
|
|
+ }
|
|
|
+ return array();
|
|
|
+ }
|
|
|
+
|
|
|
+ /*
|
|
|
+ public function userMonthData($data)
|
|
|
+ {
|
|
|
+ $user = Dever::db(self::USER)->one(array('name' => $data['wechat_name']));
|
|
|
+ if ($user) {
|
|
|
+ $option = array
|
|
|
+ (
|
|
|
+ 'share_id' => 'yes',
|
|
|
+ 'uid' => 'yes',
|
|
|
+ 'start' => array('yes-cdate', '>='),
|
|
|
+ 'end' => array('yes-cdate', '<='),
|
|
|
+ );
|
|
|
+
|
|
|
+ //获取昨天数据
|
|
|
+ $time = time() - (3600 * 24);
|
|
|
+ $set = Dever::input('set');
|
|
|
+ if ($set) {
|
|
|
+ $time = Dever::maketime($set);
|
|
|
+ }
|
|
|
+ $month = date('Y-m-d', $time);
|
|
|
+ $month_end = date('Y-m-t', $time);
|
|
|
+ $month_cur = date('Y-m-d', $time);
|
|
|
+ $month_prev = date('Y-m', strtotime("$month -1 month"));//上个月
|
|
|
+
|
|
|
+ $start = date('Y-m-01 00:00:00', $time);
|
|
|
+ if ($month_end == $month_cur || $set) {
|
|
|
+ $user['status'] = 1;//本月已经到月底
|
|
|
+ $end = date('Y-m-t 23:59:59', $time);
|
|
|
+ } else {
|
|
|
+ $user['status'] = 2;//本月还未到月底
|
|
|
+ $end = date('Y-m-d 23:59:59', $time);
|
|
|
+ }
|
|
|
+
|
|
|
+ $month_start = Dever::maketime($start);
|
|
|
+ $month_end = Dever::maketime($end);
|
|
|
+ $where = array
|
|
|
+ (
|
|
|
+ 'option' => $option,
|
|
|
+ 'uid' => $user['id'],
|
|
|
+ 'start' => $month_start,
|
|
|
+ 'end' => $month_end
|
|
|
+ );
|
|
|
+ $share = Dever::db(self::SHARE)->state($where);
|
|
|
+ if ($share) {
|
|
|
+ $user['applet'] = $data['applet'];
|
|
|
+ $user['user_id'] = $data['id'];
|
|
|
+ $user['share_month'] = $month;
|
|
|
+ $user['share_month_se'] = $start . '-' . $end;
|
|
|
+ $user['share_num'] = 0;
|
|
|
+ //$user['share_reflux_num'] = Dever::db(self::REFLUX)->total(array('source_uid' => $user['id']));
|
|
|
+ //获取月度回流
|
|
|
+ unset($where['option']['uid']);
|
|
|
+ $where['option']['source_uid'] = $user['id'];
|
|
|
+
|
|
|
+ $user['share_month_reflux_num'] = Dever::db(self::REFLUX)->total($where);
|
|
|
+ $user['share_group_num'] = 0;
|
|
|
+ foreach ($share as $k => $v) {
|
|
|
+ $info = $this->shareData($v, $where);
|
|
|
+ if ($info && $info['num'] > 0) {
|
|
|
+ $user['share'][$k] = $info;
|
|
|
+ $user['share_num'] += $user['share'][$k]['num'];
|
|
|
+ $user['share_group_num'] += $user['share'][$k]['group_num'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ $this->updateInfo($user, $month_prev);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return $user;
|
|
|
+ }
|
|
|
+
|
|
|
+ public function updateInfo($user, $month_prev)
|
|
|
+ {
|
|
|
+ # 获取上个月的数据 减去上个月的数据
|
|
|
+ if ($user['share_month'] != $month_prev) {
|
|
|
+ $where = array();
|
|
|
+ $where['option_user_id'] = $user['user_id'];
|
|
|
+ $where['option_share_month'] = $month_prev;
|
|
|
+ $prev = Dever::db('share/info')->one($where);
|
|
|
+ if ($prev) {
|
|
|
+ $user['share_num'] = $user['share_num'] - $prev['share_num'];
|
|
|
+ $user['share_group_num'] = $user['share_group_num'] - $prev['share_group_num'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $update = array();
|
|
|
+ $update['user_id'] = $user['user_id'];
|
|
|
+ $update['applet'] = $user['applet'];
|
|
|
+ $update['share_month'] = $user['share_month'];
|
|
|
+ $update['share_month_se'] = $user['share_month_se'];
|
|
|
+ $update['share_num'] = $user['share_num'];
|
|
|
+ $update['share_month_reflux_num'] = $user['share_month_reflux_num'];
|
|
|
+ $update['share_group_num'] = $user['share_group_num'];
|
|
|
+ $update['status'] = $user['status'];
|
|
|
+
|
|
|
+ $where = array();
|
|
|
+ $where['option_user_id'] = $update['user_id'];
|
|
|
+ $where['option_share_month'] = $update['share_month'];
|
|
|
+
|
|
|
+ $info = Dever::db('share/info')->one($where);
|
|
|
+ if (!$info) {
|
|
|
+ $id = Dever::db('share/info')->insert($update);
|
|
|
+ } else {
|
|
|
+ $id = $info['id'];
|
|
|
+ $update['where_id'] = $id;
|
|
|
+ Dever::db('share/info')->update($update);
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($id > 0 && $user['share']) {
|
|
|
+ foreach ($user['share'] as $k => $v) {
|
|
|
+ $this->updateLog($k, $v, $id, $update['user_id'], $user['share_month']);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public function updateLog($share_id, $data, $info_id, $user_id, $month)
|
|
|
+ {
|
|
|
+ $update = array();
|
|
|
+ $update['user_id'] = $user_id;
|
|
|
+ $update['info_id'] = $info_id;
|
|
|
+ $update['share_id'] = $share_id;
|
|
|
+ $update['share_month'] = $month;
|
|
|
+ $update['applet'] = $data['applet']['id'];
|
|
|
+ $update['name'] = $data['name'];
|
|
|
+ $update['source_id'] = $data['id'];
|
|
|
+ $update['source_table'] = $data['source_table'];
|
|
|
+ $update['share_num'] = $data['num'];
|
|
|
+ $update['sdate'] = $data['cdate'];
|
|
|
+ $update['share_group_num'] = $data['group_num'];
|
|
|
+ $update['share_reflux_num'] = $data['month_reflux_num'];
|
|
|
+
|
|
|
+ $where = array();
|
|
|
+ $where['option_share_id'] = $update['share_id'];
|
|
|
+ $where['option_user_id'] = $update['user_id'];
|
|
|
+ $where['option_info_id'] = $update['info_id'];
|
|
|
+ $where['option_source_id'] = $update['source_id'];
|
|
|
+ $where['option_share_month'] = $update['share_month'];
|
|
|
+ $where['option_applet'] = $update['applet'];
|
|
|
+
|
|
|
+ $info = Dever::db('share/log')->one($where);
|
|
|
+ if (!$info) {
|
|
|
+ Dever::db('share/log')->insert($update);
|
|
|
+ } else {
|
|
|
+ $update['where_id'] = $info['id'];
|
|
|
+ Dever::db('share/log')->update($update);
|
|
|
+ }
|
|
|
+ }*/
|
|
|
+}
|
rabin