|
@@ -14,6 +14,11 @@ use cmf\controller\AdminBaseController;
|
|
|
use think\Db;
|
|
use think\Db;
|
|
|
use think\db\Query;
|
|
use think\db\Query;
|
|
|
use app\admin\model\MarketModel;
|
|
use app\admin\model\MarketModel;
|
|
|
|
|
+use app\weixin\model\AccountLog;
|
|
|
|
|
+use app\weixin\model\Market;
|
|
|
|
|
+use app\weixin\model\Member;
|
|
|
|
|
+use app\weixin\model\UserBalanceLog;
|
|
|
|
|
+
|
|
|
use app\weixin\model\Wechat;
|
|
use app\weixin\model\Wechat;
|
|
|
use app\weixin\service\PRedis;
|
|
use app\weixin\service\PRedis;
|
|
|
|
|
|
|
@@ -37,7 +42,7 @@ class MarketController extends AdminBaseController
|
|
|
public function marketsetlist(){
|
|
public function marketsetlist(){
|
|
|
|
|
|
|
|
//查询得到分销表
|
|
//查询得到分销表
|
|
|
- $marketlist=Db::name('market')->where('status',1)
|
|
|
|
|
|
|
+ $marketlist=Db::name('market')
|
|
|
->order("updated_at DESC")
|
|
->order("updated_at DESC")
|
|
|
->paginate(15,false,['query'=>request()->param()]);
|
|
->paginate(15,false,['query'=>request()->param()]);
|
|
|
|
|
|
|
@@ -55,7 +60,7 @@ class MarketController extends AdminBaseController
|
|
|
public function marketset(){
|
|
public function marketset(){
|
|
|
|
|
|
|
|
//查询得到分销表
|
|
//查询得到分销表
|
|
|
- $market=Db::name('market')->where(array('status'=>1,'id'=> input('id')))->find();
|
|
|
|
|
|
|
+ $market=Db::name('market')->where(array('id'=> input('id')))->find();
|
|
|
|
|
|
|
|
// var_dump($market);die();
|
|
// var_dump($market);die();
|
|
|
$this->assign('market', $market);
|
|
$this->assign('market', $market);
|
|
@@ -618,6 +623,7 @@ class MarketController extends AdminBaseController
|
|
|
//开始进行调用成功发送
|
|
//开始进行调用成功发送
|
|
|
|
|
|
|
|
$data['agent_status'] = 1;
|
|
$data['agent_status'] = 1;
|
|
|
|
|
+ $data['agent_type'] = 1;
|
|
|
$result=Db::name('user')->where('id',$param['id'])->update($data);
|
|
$result=Db::name('user')->where('id',$param['id'])->update($data);
|
|
|
|
|
|
|
|
// echo Db::name('user')->getLastSql();die();
|
|
// echo Db::name('user')->getLastSql();die();
|
|
@@ -820,65 +826,70 @@ class MarketController extends AdminBaseController
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
- * 进行奖励充值
|
|
|
|
|
|
|
+ * 后台进行奖励充值
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
public function markettoreward(){
|
|
public function markettoreward(){
|
|
|
|
|
|
|
|
|
|
+
|
|
|
|
|
+ $where = ['id' => input('id'), 'agent_type' => 1, 'agent_status' => 1];
|
|
|
|
|
+
|
|
|
|
|
+ $field = 'id,openid,user_nickname,parent_id,user_login,balance';
|
|
|
|
|
+ $userInfo = Member::getInfo($where, $field);
|
|
|
|
|
|
|
|
- $this->assign("id",input('id'));
|
|
|
|
|
|
|
+ $nickname = isset($userInfo['nickname']) ? trim($userInfo['nickname']) : '';
|
|
|
|
|
+ $userLogin = isset($userInfo['user_login']) ? trim($userInfo['user_login']) : '';
|
|
|
|
|
+ $balance = isset($userInfo['balance']) ? floatval($userInfo['balance']) : 0;
|
|
|
|
|
+ $awardMoney = input('am');
|
|
|
|
|
+ $rm = input('ar');
|
|
|
|
|
+ $userId = input('id');
|
|
|
|
|
|
|
|
- $level2Award = isset($marketConfig['level_2']) ? floatval($marketConfig['level_2']) : 0;
|
|
|
|
|
- $awardMoneyTwo = $marketType==1? moneyFormat($level2Award) : moneyFormat($money * ($level2Award / 100));
|
|
|
|
|
- $logData['levelAward'] = $level2Award;
|
|
|
|
|
- if ($level2Award > 0 && $level2Award <= 100 && $awardMoneyTwo > 0) {
|
|
|
|
|
- // 账户变动
|
|
|
|
|
|
|
+ // 账户变动
|
|
|
Db::startTrans();
|
|
Db::startTrans();
|
|
|
- if (Member::where($whereTwo)->setInc('balance', $awardMoneyTwo)) {
|
|
|
|
|
- // 写入奖励日志
|
|
|
|
|
- $levelName = "您的下级[{$nickname}]邀请的[{$sourceNickname}]用户";
|
|
|
|
|
- $marketName = isset($marketConfig['name']) ? $marketConfig['name'] : '分销收益';
|
|
|
|
|
- $logTitle = "{$levelName}消费{$money}元,获得{$marketName}{$awardMoneyTwo}元";
|
|
|
|
|
|
|
+ if (Member::where($where)->setInc('balance', input('am'))) {
|
|
|
|
|
+ // 写入奖励日志
|
|
|
|
|
+
|
|
|
|
|
+ $logTitle = "后台为你进行了{$rm},奖励额度为:{$awardMoney}元";
|
|
|
$log = [
|
|
$log = [
|
|
|
- 'change' => $awardMoneyTwo,
|
|
|
|
|
- 'type' => $type,
|
|
|
|
|
- 'level' => 2,
|
|
|
|
|
|
|
+ 'change' => $awardMoney,
|
|
|
|
|
+ 'type' => 31, //平台奖励
|
|
|
|
|
+ 'level' => 1,
|
|
|
'change_type' => 1,
|
|
'change_type' => 1,
|
|
|
- 'pay_money' => $awardMoneyTwo,
|
|
|
|
|
- 'user_id' => $userTwoId,
|
|
|
|
|
- 'source_uid' => $userId,
|
|
|
|
|
- 'balance' => moneyFormat($balanceTwo + $awardMoneyTwo),
|
|
|
|
|
|
|
+ 'pay_money' => $awardMoney,
|
|
|
|
|
+ 'user_id' => $userId,
|
|
|
|
|
+ 'source_uid' => '',
|
|
|
|
|
+ 'balance' => moneyFormat($balance + $awardMoney),
|
|
|
'description' => $logTitle,
|
|
'description' => $logTitle,
|
|
|
'create_time' => time(),
|
|
'create_time' => time(),
|
|
|
'status' => 1,
|
|
'status' => 1,
|
|
|
];
|
|
];
|
|
|
- $logData['log'] = $log;
|
|
|
|
|
- PRedis::set("{$cacheKey}:log", $logData, 7200);
|
|
|
|
|
|
|
+
|
|
|
if(UserBalanceLog::insertGetId($log)){
|
|
if(UserBalanceLog::insertGetId($log)){
|
|
|
- // 账户明细
|
|
|
|
|
|
|
+
|
|
|
|
|
+ // 账户明细
|
|
|
$accountData = [
|
|
$accountData = [
|
|
|
'type' => 4,
|
|
'type' => 4,
|
|
|
'account_type' => 2,
|
|
'account_type' => 2,
|
|
|
'change_type' => 1,
|
|
'change_type' => 1,
|
|
|
- 'user_id' => $userTwoId,
|
|
|
|
|
- 'money' => $awardMoneyTwo,
|
|
|
|
|
- 'balance' => $balanceTwo,
|
|
|
|
|
|
|
+ 'user_id' => $userId,
|
|
|
|
|
+ 'money' => $awardMoney,
|
|
|
|
|
+ 'balance' => $balance,
|
|
|
'created_at' => date('Y-m-d H:i:s'),
|
|
'created_at' => date('Y-m-d H:i:s'),
|
|
|
'remark' => $logTitle,
|
|
'remark' => $logTitle,
|
|
|
];
|
|
];
|
|
|
if(AccountLog::insertGetId($accountData)){
|
|
if(AccountLog::insertGetId($accountData)){
|
|
|
// 发送模板消息
|
|
// 发送模板消息
|
|
|
- $openid = isset($userInfoTwo['openid'])? $userInfoTwo['openid'] : '';
|
|
|
|
|
|
|
+ $openid = isset($userInfo['openid'])? $userInfo['openid'] : '';
|
|
|
if($openid){
|
|
if($openid){
|
|
|
$checkTime = date('Y.m.d H:i');
|
|
$checkTime = date('Y.m.d H:i');
|
|
|
$remark = "感谢您对拾光的信任,我们一起解救单身青年!点击查看收益明细";
|
|
$remark = "感谢您对拾光的信任,我们一起解救单身青年!点击查看收益明细";
|
|
|
$msgParams = [
|
|
$msgParams = [
|
|
|
- 'title' => "您的下级[$nickname]邀请的用户[{$sourceNickname}]消费所得的收益已到账!\n\n类型:\t{$marketName}",
|
|
|
|
|
|
|
+ 'title' => "管理员后台为你奖励的收益已到账!\n\n类型:\t{$rm}",
|
|
|
'remark' => $remark,
|
|
'remark' => $remark,
|
|
|
'type' => 'income',
|
|
'type' => 'income',
|
|
|
'keywords' => [
|
|
'keywords' => [
|
|
|
'keyword1' => [
|
|
'keyword1' => [
|
|
|
- 'value' => "{$awardMoneyTwo}",
|
|
|
|
|
|
|
+ 'value' => "{$awardMoney}",
|
|
|
'color' => '#173177',
|
|
'color' => '#173177',
|
|
|
],
|
|
],
|
|
|
'keyword2' => [
|
|
'keyword2' => [
|
|
@@ -888,33 +899,29 @@ class MarketController extends AdminBaseController
|
|
|
],
|
|
],
|
|
|
'url' => url('/weixin/market/income', '', '', true),
|
|
'url' => url('/weixin/market/income', '', '', true),
|
|
|
];
|
|
];
|
|
|
- PRedis::set("{$cacheKey}:message", ['result' => $userInfoTwo, 'params' => $msgParams], 600);
|
|
|
|
|
|
|
+ // PRedis::set("{$cacheKey}:message", ['result' => $userInfo, 'params' => $msgParams], 600);
|
|
|
Wechat::sendTplMsg($openid, $msgParams);
|
|
Wechat::sendTplMsg($openid, $msgParams);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- Db::commit();
|
|
|
|
|
|
|
+ Db::commit();;
|
|
|
}else{
|
|
}else{
|
|
|
- PRedis::set("{$cacheKey}:account_log", $logData, 7200);
|
|
|
|
|
|
|
+ //PRedis::set("{$cacheKey}:account_log", $logData, 7200);
|
|
|
Db::rollback();
|
|
Db::rollback();
|
|
|
- return false;
|
|
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
}else{
|
|
}else{
|
|
|
- PRedis::set("{$cacheKey}:balance_log", $logData, 7200);
|
|
|
|
|
- Db::rollback();
|
|
|
|
|
- return false;
|
|
|
|
|
|
|
+
|
|
|
|
|
+ Db::rollback();
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
- } else {
|
|
|
|
|
- PRedis::set("{$cacheKey}:update_balance", $logData, 7200);
|
|
|
|
|
- Db::rollback();
|
|
|
|
|
- return false;
|
|
|
|
|
|
|
+ }else{
|
|
|
|
|
+ Db::rollback();
|
|
|
|
|
+ echo 0;die();
|
|
|
}
|
|
}
|
|
|
- } else {
|
|
|
|
|
- PRedis::set("{$cacheKey}:error_awardMoney", $logData, 7200);
|
|
|
|
|
- return false;
|
|
|
|
|
- }
|
|
|
|
|
|
|
|
|
|
- return $this->fetch();
|
|
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ echo 1;die();
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -1107,10 +1114,22 @@ class MarketController extends AdminBaseController
|
|
|
return $this->fetch('marketwithdraw');
|
|
return $this->fetch('marketwithdraw');
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ //删除分销设置
|
|
|
|
|
|
|
|
|
|
+ public function deleteset(){
|
|
|
|
|
|
|
|
|
|
+ $param = $this->request->param();
|
|
|
|
|
|
|
|
|
|
+ if (isset($param['ids']) && isset($param["yes"])) {
|
|
|
|
|
+ $ids = $this->request->param('ids/a');
|
|
|
|
|
|
|
|
|
|
+ Db::name('market')->where('id', 'in', $ids)->update(['status' => 2]);
|
|
|
|
|
+
|
|
|
|
|
+ $this->success("活动删除成功!", '');
|
|
|
|
|
+
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|