fnvtk/cunkebao_v3
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码提交

Browse Source
This commit is contained in:
wong
2025-10-20 14:22:20 +08:00
parent 87bf284943
commit 527d5341db
8 changed files with 301 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Server/application/chukebao/controller/DataProcessing.php
View File

@@ -62,7 +62,7 @@ class DataProcessing extends BaseController
$friend->save();
$msg = '修标签成功';
break;
case 'CmdAllotFriend':
case 'CmdAllotFriend': //迁移好友
if(empty($toAccountId)){
return ResponseHelper::error('参数缺失');
}

17
Server/application/common/model/TrafficSourcePackage.php Normal file
View File

@@ -0,0 +1,17 @@
<?php
namespace app\common\model;
use think\Model;
/**
* 流量池模型类
*/
class TrafficSourcePackage extends Model
{
// 设置数据表名
protected $name = 'traffic_source_package';
}

17
Server/application/common/model/TrafficSourcePackageItem.php Normal file
View File

@@ -0,0 +1,17 @@
<?php
namespace app\common\model;
use think\Model;
/**
* 流量池模型类
*/
class TrafficSourcePackageItem extends Model
{
// 设置数据表名
protected $name = 'traffic_source_package_item';
}

11
Server/application/cunkebao/config/route.php
View File

@@ -63,13 +63,20 @@ Route::group('v1/', function () {
// 流量池相关
Route::group('traffic/pool', function () {
Route::get('getPackage', 'app\cunkebao\controller\TrafficController@getPackage');
Route::post('addPackage', 'app\cunkebao\controller\TrafficController@addPackage');
Route::post('editPackage', 'app\cunkebao\controller\TrafficController@editPackage');
Route::delete('deletePackage', 'app\cunkebao\controller\TrafficController@deletePackage');
Route::get('', 'app\cunkebao\controller\TrafficController@getTrafficPoolList');
Route::get('', 'app\cunkebao\controller\traffic\GetPotentialListWithInCompanyV1Controller@index');
//Route::get('', 'app\cunkebao\controller\traffic\GetPotentialListWithInCompanyV1Controller@index');
Route::get('getUserJourney', 'app\cunkebao\controller\traffic\GetPotentialListWithInCompanyV1Controller@getUserJourney');
Route::get('getUserTags', 'app\cunkebao\controller\traffic\GetPotentialListWithInCompanyV1Controller@getUserTags');
Route::get('getUserInfo', 'app\cunkebao\controller\traffic\GetPotentialListWithInCompanyV1Controller@getUser');
Route::post('addPackage', 'app\cunkebao\controller\traffic\GetPotentialListWithInCompanyV1Controller@addPackage');
// Route::post('addPackage', 'app\cunkebao\controller\traffic\GetPotentialListWithInCompanyV1Controller@addPackage');

2
Server/application/cunkebao/controller/RFMController.php
View File

@@ -11,7 +11,7 @@ class RFMController extends BaseController
* @param float $monetary 购买金额
* @return array{R:int,F:int,M:int}
*/
public static function calcRfmScores($recencyDays, $frequency, $monetary)
public static function calcRfmScores($recencyDays = 30, $frequency, $monetary)
{
$recencyDays = is_numeric($recencyDays) ? (int)$recencyDays : 9999;
$frequency = max(0, (int)$frequency);

259
Server/application/cunkebao/controller/TrafficController.php
View File

@@ -2,6 +2,8 @@
namespace app\cunkebao\controller;
use app\common\model\TrafficSourcePackage;
use app\common\model\TrafficSourcePackageItem;
use library\ResponseHelper;
use think\Db;
use app\cunkebao\controller\RFMController;
@@ -9,9 +11,15 @@ use app\cunkebao\controller\RFMController;
class TrafficController extends BaseController
{
/**
* 流量池包
* @return \think\response\Json
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function getPackage()
{
$page = $this->request->param('page', 1);
$limit = $this->request->param('limit', 10);
$keyword = $this->request->param('keyword', '');
@@ -34,7 +42,7 @@ class TrafficController extends BaseController
foreach ($list as $k => &$v) {
if ($v['type'] != 1) {
$v['createTime'] = !empty($v['createTime']) ? formatRelativeTime($v['createTime']) : '';
}else{
} else {
$v['createTime'] = '';
}
@@ -53,7 +61,6 @@ class TrafficController extends BaseController
$v['F'] = $scores['F'];
$v['M'] = $scores['M'];
$v['RFM'] = $scores['R'] + $scores['F'] + $scores['M'];
}
unset($v);
@@ -65,4 +72,250 @@ class TrafficController extends BaseController
return ResponseHelper::success($data);
}
/**
* 添加流量池
* @return \think\response\Json
* @throws \Exception
*/
public function addPackage()
{
$packageName = $this->request->param('packageName', '');
$description = $this->request->param('description', '');
$pic = $this->request->param('pic', '');
$companyId = $this->getUserInfo('companyId');
$userId = $this->getUserInfo('id');
if (empty($packageName)) {
return ResponseHelper::error('流量池名称不能为空');
}
$package = TrafficSourcePackage::where(['isDel' => 0, 'name' => $packageName])
->whereIn('companyId', [$companyId, 0])
->field('id,name')
->find();
if (!empty($package)) {
return ResponseHelper::error('该流量池名称已存在');
}
$packageId = TrafficSourcePackage::insertGetId([
'userId' => $userId,
'companyId' => $companyId,
'name' => $packageName,
'description' => $description,
'pic' => $pic,
'matchingRules' => json_encode([]),
'createTime' => time(),
'isDel' => 0,
]);
if (!empty($packageId)) {
return ResponseHelper::success($packageId, '该流量添加成功');
} else {
return ResponseHelper::error('该流量添加失败');
}
}
/**
* 编辑流量池
* @return \think\response\Json
* @throws \Exception
*/
public function editPackage()
{
$packageId = $this->request->param('packageId', '');
$packageName = $this->request->param('packageName', '');
$description = $this->request->param('description', '');
$pic = $this->request->param('pic', '');
$companyId = $this->getUserInfo('companyId');
$userId = $this->getUserInfo('id');
if (empty($packageId)) {
return ResponseHelper::error('流量池ID不能为空');
}
if (empty($packageName)) {
return ResponseHelper::error('流量池名称不能为空');
}
// 检查流量池是否存在且属于当前公司
$package = TrafficSourcePackage::where(['id' => $packageId, 'isDel' => 0])
->whereIn('companyId', [$companyId, 0])
->find();
if (empty($package)) {
return ResponseHelper::error('流量池不存在或已删除');
}
// 检查系统流量池是否可编辑
if ($package['isSys'] == 1) {
return ResponseHelper::error('系统流量池不允许编辑');
}
// 检查名称是否重复（排除当前记录）
$existPackage = TrafficSourcePackage::where(['isDel' => 0, 'name' => $packageName])
->whereIn('companyId', [$companyId, 0])
->where('id', '<>', $packageId)
->field('id,name')
->find();
if (!empty($existPackage)) {
return ResponseHelper::error('该流量池名称已存在');
}
// 更新流量池信息
$updateData = [
'name' => $packageName,
'updateTime' => time(),
];
// 更新描述字段（允许为空）
$updateData['description'] = $description;
// 更新图片字段（允许为空）
$updateData['pic'] = $pic;
$result = TrafficSourcePackage::where('id', $packageId)->update($updateData);
if ($result !== false) {
return ResponseHelper::success($packageId, '流量池编辑成功');
} else {
return ResponseHelper::error('流量池编辑失败');
}
}
/**
* 删除流量池（假删除）
* @return \think\response\Json
* @throws \Exception
*/
public function deletePackage()
{
$packageId = $this->request->param('packageId', '');
$companyId = $this->getUserInfo('companyId');
if (empty($packageId)) {
return ResponseHelper::error('流量池ID不能为空');
}
// 检查流量池是否存在且属于当前公司
$package = TrafficSourcePackage::where(['id' => $packageId, 'isDel' => 0])
->whereIn('companyId', [$companyId, 0])
->find();
if (empty($package)) {
return ResponseHelper::error('流量池不存在或已删除');
}
// 检查系统流量池是否可删除
if ($package['isSys'] == 1) {
return ResponseHelper::error('系统流量池不允许删除');
}
// 开启事务
Db::startTrans();
try {
// 执行流量池假删除
$result = TrafficSourcePackage::where('id', $packageId)->update([
'isDel' => 1,
'deleteTime' => time()
]);
if ($result === false) {
throw new \Exception('流量池删除失败');
}
// 删除流量池内容（TrafficSourcePackageItem）假删除
$itemResult = TrafficSourcePackageItem::where([
'packageId' => $packageId,
'companyId' => $companyId,
'isDel' => 0
])->update([
'isDel' => 1,
'deleteTime' => time()
]);
// 提交事务
Db::commit();
return ResponseHelper::success($packageId, '流量池及内容删除成功');
} catch (\Exception $e) {
// 回滚事务
Db::rollback();
return ResponseHelper::error('删除失败：' . $e->getMessage());
}
}
/**
* 流量池列表
* @return \think\response\Json
* @throws \Exception
*/
public function getTrafficPoolList()
{
$page = $this->request->param('page', 1);
$limit = $this->request->param('limit', 10);
$keyword = $this->request->param('keyword', '');
$packageId = $this->request->param('packageId', '');
$companyId = $this->getUserInfo('companyId');
$userId = $this->getUserInfo('id');
if (empty($packageId)) {
return ResponseHelper::error('流量包id不能为空');
}
$trafficSourcePackage = TrafficSourcePackage::where(['id' => $packageId, 'isDel' => 0])->whereIn('companyId', [$companyId, 0])->find();
if (empty($trafficSourcePackage)) {
return ResponseHelper::error('流量包不存在或已删除');
}
$where = [
['tspi.companyId', '=', $companyId],
['tspi.packageId', '=', $packageId],
];
if (empty($keyword)) {
$where[] = ['wa.nickname|wa.phone|wa.alias|wa.wechatId|p.mobile|p.identifier', 'like', '%' . $keyword . '%'];
}
$query = TrafficSourcePackageItem::alias('tspi')
->field(
[
'p.id', 'p.identifier', 'p.mobile', 'p.wechatId', 'tspi.companyId',
'wa.nickname', 'wa.avatar', 'wa.gender', 'wa.phone', 'wa.alias'
]
)
->join('traffic_pool p', 'p.identifier=tspi.identifier', 'left')
->join('wechat_account wa', 'tspi.identifier=wa.wechatId', 'left')
->where($where);
$query->order('tspi.id DESC,p.id DESC')->group('p.identifier');
$list = $query->page($page, $limit)->select()->toArray();
$total = $query->count();
foreach ($list as $k => &$v) {
//流量池筛选
$package = TrafficSourcePackageItem::alias('tspi')
->join('traffic_source_package p', 'tspi.packageId=p.id AND tspi.companyId=p.companyId')
->where(['tspi.identifier' => $v['identifier']])
->whereIn('tspi.companyId', [0, $v['companyId']])
->column('p.name');
$v['packages'] = $package;
$v['phone'] = !empty($v['phone']) ? $v['phone'] : $v['mobile'];
unset($v['mobile']);
$scores = RFMController::calcRfmScores(30, 30, 30);
$v['R'] = $scores['R'];
$v['F'] = $scores['F'];
$v['M'] = $scores['M'];
$v['RFM'] = $scores['R'] + $scores['F'] + $scores['M'];
$v['money'] = 2222;
$v['msgCount'] = 2222;
$v['tag'] = ['test', 'test2'];
}
unset($v);
$data = ['list' => $list, 'total' => $total];
return ResponseHelper::success($data);
}
}

1
Server/application/cunkebao/controller/plan/PostCreateAddFriendPlanV1Controller.php
View File

@@ -223,7 +223,6 @@ class PostCreateAddFriendPlanV1Controller extends BaseController
if (!empty($params['wechatGroups']) && is_array($params['wechatGroups'])) {
$rows = Db::name('wechat_group_member')->alias('gm')
->join('wechat_account wa', 'gm.identifier = wa.wechatId')
->where('gm.companyId', $this->getUserInfo('companyId'))
->whereIn('gm.groupId', $params['wechatGroups'])
->group('gm.identifier')
->column('wa.id,wa.wechatId,wa.alias,wa.phone');

1
Server/application/cunkebao/controller/plan/PostUpdateAddFriendPlanV1Controller.php
View File

@@ -198,7 +198,6 @@ class PostUpdateAddFriendPlanV1Controller extends BaseController
if (!empty($params['wechatGroups']) && is_array($params['wechatGroups'])) {
$rows = Db::name('wechat_group_member')->alias('gm')
->join('wechat_account wa', 'gm.identifier = wa.wechatId')
->where('gm.companyId', $this->getUserInfo('companyId'))
->whereIn('gm.groupId', $params['wechatGroups'])
->group('gm.identifier')
->column('wa.id,wa.wechatId,wa.alias,wa.phone');