|
|
@@ -49,9 +49,9 @@ if ($date_range == 'current_month') {
|
|
|
|
|
|
// 阈值设置（可以移到数据库或配置文件中）
|
|
|
$order_amount_decrease_threshold = -15; // 订单金额下降超过15%触发预警
|
|
|
-$repurchase_cycle_max_threshold = 90; // 复购周期超过90天触发预警
|
|
|
-$repurchase_cycle_min_threshold = 0.5; // 复购周期小于正常值的50%触发预警（异常频繁购买）
|
|
|
-$inactive_threshold = 60; // 60天未购买视为不活跃客户
|
|
|
+$repurchase_cycle_threshold = 90; // 复购周期超过90天触发预警（3个月内未录入订单）
|
|
|
+$inactive_threshold = 90; // 90天未有客户信息修改视为不活跃客户（3个月）
|
|
|
+$churn_threshold = 365; // 365天未下单视为流失客户（1年）
|
|
|
$normal_repurchase_days = 30; // 正常复购周期参考值（天）
|
|
|
|
|
|
// 页面头部
|
|
|
@@ -119,11 +119,14 @@ include('statistics_header.php');
|
|
|
// 获取订单金额下降的客户数
|
|
|
$decreasing_amount_count = getDecreasingOrderAmountCustomers($conn, $current_start_date, $current_end_date, $previous_start_date, $previous_end_date, $order_amount_decrease_threshold, true, $selected_employee);
|
|
|
|
|
|
- // 获取复购周期异常的客户数
|
|
|
- $abnormal_cycle_count = getAbnormalRepurchaseCycleCustomers($conn, $current_start_date, $current_end_date, $repurchase_cycle_max_threshold, $repurchase_cycle_min_threshold, $normal_repurchase_days, true, $selected_employee);
|
|
|
+ // 获取复购周期异常（3个月内未录入订单）的客户数
|
|
|
+ $abnormal_cycle_count = getAbnormalRepurchaseCycleCustomers($conn, $current_start_date, $current_end_date, $repurchase_cycle_threshold, true, $selected_employee);
|
|
|
|
|
|
- // 获取长期不活跃客户数
|
|
|
+ // 获取长期不活跃（3个月内没有客户信息修改）客户数
|
|
|
$inactive_customers_count = getInactiveCustomers($conn, $current_end_date, $inactive_threshold, true, 1, 10, $selected_employee);
|
|
|
+
|
|
|
+ // 获取流失客户（1年内未录入订单）数
|
|
|
+ $churn_customers_count = getChurnCustomers($conn, $current_end_date, $churn_threshold, true, 1, 10, $selected_employee);
|
|
|
?>
|
|
|
|
|
|
<div class="col-md-3">
|
|
|
@@ -138,29 +141,23 @@ include('statistics_header.php');
|
|
|
<div class="stat-card warning">
|
|
|
<h3>复购周期异常客户</h3>
|
|
|
<div class="stat-value"><?php echo $abnormal_cycle_count; ?></div>
|
|
|
- <div class="stat-desc">周期异常或不规律</div>
|
|
|
+ <div class="stat-desc">3个月内未录入订单</div>
|
|
|
</div>
|
|
|
</div>
|
|
|
|
|
|
<div class="col-md-3">
|
|
|
<div class="stat-card danger">
|
|
|
- <h3>长期不活跃客户</h3>
|
|
|
- <div class="stat-value"><?php echo $inactive_customers_count; ?></div>
|
|
|
- <div class="stat-desc"><?php echo $inactive_threshold; ?>天以上未下单</div>
|
|
|
+ <h3>流失客户</h3>
|
|
|
+ <div class="stat-value"><?php echo $churn_customers_count; ?></div>
|
|
|
+ <div class="stat-desc">1年内未录入订单</div>
|
|
|
</div>
|
|
|
</div>
|
|
|
|
|
|
<div class="col-md-3">
|
|
|
<div class="stat-card info">
|
|
|
- <h3>客户活跃率</h3>
|
|
|
- <div class="stat-value">
|
|
|
- <?php
|
|
|
- $active_rate = ($warning_count['total_customers'] > 0) ?
|
|
|
- round(($warning_count['active_customers'] / $warning_count['total_customers']) * 100, 1) : 0;
|
|
|
- echo $active_rate . '%';
|
|
|
- ?>
|
|
|
- </div>
|
|
|
- <div class="stat-desc">选定周期内下单客户占比</div>
|
|
|
+ <h3>长期不活跃客户</h3>
|
|
|
+ <div class="stat-value"><?php echo $inactive_customers_count; ?></div>
|
|
|
+ <div class="stat-desc">3个月内无客户信息更新</div>
|
|
|
</div>
|
|
|
</div>
|
|
|
</div>
|
|
|
@@ -222,68 +219,140 @@ include('statistics_header.php');
|
|
|
</div>
|
|
|
|
|
|
<!-- 复购周期异常客户列表 -->
|
|
|
- <div class="warning-section">
|
|
|
+ <div class="warning-section" id="abnormal-customers">
|
|
|
<div class="section-header">
|
|
|
<h2>复购周期异常客户</h2>
|
|
|
- <p>复购周期异常延长或缩短的客户</p>
|
|
|
+ <p>3个月内未录入订单的客户</p>
|
|
|
</div>
|
|
|
|
|
|
<table class="data-table">
|
|
|
<thead>
|
|
|
<tr>
|
|
|
<th>客户名称</th>
|
|
|
- <th>平均复购周期(天)</th>
|
|
|
- <th>最近复购周期(天)</th>
|
|
|
- <th>偏离正常值</th>
|
|
|
- <th>最近出货日期</th>
|
|
|
- <th>订单总数</th>
|
|
|
+ <th>上次订单日期</th>
|
|
|
+ <th>未订单天数</th>
|
|
|
+ <th>历史订单总数</th>
|
|
|
+ <th>历史订单总额</th>
|
|
|
<th>业务员</th>
|
|
|
<th>操作</th>
|
|
|
</tr>
|
|
|
</thead>
|
|
|
<tbody>
|
|
|
<?php
|
|
|
+ // 获取分页参数
|
|
|
+ $abnormal_page = isset($_GET['abnormal_page']) ? intval($_GET['abnormal_page']) : 1;
|
|
|
+ $abnormal_page_size = 10; // 每页显示10条记录
|
|
|
+
|
|
|
+ // 获取总记录数
|
|
|
+ $total_abnormal = getAbnormalRepurchaseCycleCustomers($conn, $current_start_date, $current_end_date, $repurchase_cycle_threshold, true, $selected_employee);
|
|
|
+
|
|
|
+ // 计算总页数
|
|
|
+ $abnormal_total_pages = ceil($total_abnormal / $abnormal_page_size);
|
|
|
+
|
|
|
+ // 确保页码合法
|
|
|
+ if ($abnormal_page < 1) $abnormal_page = 1;
|
|
|
+ if ($abnormal_page > $abnormal_total_pages && $abnormal_total_pages > 0) $abnormal_page = $abnormal_total_pages;
|
|
|
+
|
|
|
+ // 获取当页数据
|
|
|
$abnormal_customers = getAbnormalRepurchaseCycleCustomers(
|
|
|
$conn,
|
|
|
$current_start_date,
|
|
|
$current_end_date,
|
|
|
- $repurchase_cycle_max_threshold,
|
|
|
- $repurchase_cycle_min_threshold,
|
|
|
- $normal_repurchase_days,
|
|
|
+ $repurchase_cycle_threshold,
|
|
|
false,
|
|
|
- $selected_employee
|
|
|
+ $selected_employee,
|
|
|
+ $abnormal_page,
|
|
|
+ $abnormal_page_size
|
|
|
);
|
|
|
|
|
|
while ($customer = $abnormal_customers->fetch_assoc()) {
|
|
|
- $deviation = round((($customer['recent_cycle'] - $normal_repurchase_days) / $normal_repurchase_days) * 100, 1);
|
|
|
- $deviation_text = $deviation > 0 ? "+{$deviation}%" : "{$deviation}%";
|
|
|
- $deviation_class = $deviation > 50 ? 'text-danger' : ($deviation < -30 ? 'text-warning' : 'text-info');
|
|
|
+ $inactive_days = $customer['inactive_days'];
|
|
|
+ $inactive_class = $inactive_days > 60 ? 'text-danger' : 'text-warning';
|
|
|
|
|
|
echo "<tr>";
|
|
|
echo "<td>" . htmlspecialchars($customer['cs_company']) . "</td>";
|
|
|
- echo "<td>" . round($customer['avg_cycle'], 1) . "</td>";
|
|
|
- echo "<td>" . round($customer['recent_cycle'], 1) . "</td>";
|
|
|
- echo "<td class='{$deviation_class}'>" . $deviation_text . "</td>";
|
|
|
- echo "<td>" . $customer['last_order_date'] . "</td>";
|
|
|
+ echo "<td>" . ($customer['last_order_date'] ? $customer['last_order_date'] : '从未下单') . "</td>";
|
|
|
+ echo "<td class='{$inactive_class}'>" . $inactive_days . "</td>";
|
|
|
echo "<td>" . $customer['order_count'] . "</td>";
|
|
|
+ echo "<td>¥" . number_format($customer['total_amount'], 2) . "</td>";
|
|
|
echo "<td>" . htmlspecialchars($customer['em_user']) . "</td>";
|
|
|
echo "<td><a href='customer_detail.php?id=" . $customer['id'] . "&from_warning=1' class='action-btn action-btn-view'>查看</a></td>";
|
|
|
echo "</tr>";
|
|
|
}
|
|
|
|
|
|
if ($abnormal_customers->num_rows == 0) {
|
|
|
- echo "<tr><td colspan='8' class='text-center'>没有发现复购周期异常的客户</td></tr>";
|
|
|
+ echo "<tr><td colspan='7' class='text-center'>没有发现复购周期异常的客户</td></tr>";
|
|
|
}
|
|
|
?>
|
|
|
</tbody>
|
|
|
</table>
|
|
|
+
|
|
|
+ <!-- 分页控件 -->
|
|
|
+ <?php if ($abnormal_total_pages > 1): ?>
|
|
|
+ <div class="pagination-container">
|
|
|
+ <ul class="pagination">
|
|
|
+ <?php
|
|
|
+ // 生成分页链接的基础URL
|
|
|
+ $base_url = '?';
|
|
|
+ foreach ($_GET as $key => $value) {
|
|
|
+ if ($key != 'abnormal_page') {
|
|
|
+ $base_url .= $key . '=' . urlencode($value) . '&';
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 上一页链接
|
|
|
+ if ($abnormal_page > 1) {
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}abnormal_page=" . ($abnormal_page - 1) . "#abnormal-customers'>上一页</a></li>";
|
|
|
+ } else {
|
|
|
+ echo "<li class='pager-item disabled'><a class='pager-link' href='#abnormal-customers'>上一页</a></li>";
|
|
|
+ }
|
|
|
+
|
|
|
+ // 页码链接
|
|
|
+ $start_page = max(1, $abnormal_page - 2);
|
|
|
+ $end_page = min($abnormal_total_pages, $abnormal_page + 2);
|
|
|
+
|
|
|
+ if ($start_page > 1) {
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}abnormal_page=1#abnormal-customers'>1</a></li>";
|
|
|
+ if ($start_page > 2) {
|
|
|
+ echo "<li class='pager-item disabled'><a class='pager-link' href='#abnormal-customers'>...</a></li>";
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ for ($i = $start_page; $i <= $end_page; $i++) {
|
|
|
+ if ($i == $abnormal_page) {
|
|
|
+ echo "<li class='pager-item active'><a class='pager-link' href='#abnormal-customers'>{$i}</a></li>";
|
|
|
+ } else {
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}abnormal_page={$i}#abnormal-customers'>{$i}</a></li>";
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($end_page < $abnormal_total_pages) {
|
|
|
+ if ($end_page < $abnormal_total_pages - 1) {
|
|
|
+ echo "<li class='pager-item disabled'><a class='pager-link' href='#abnormal-customers'>...</a></li>";
|
|
|
+ }
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}abnormal_page={$abnormal_total_pages}#abnormal-customers'>{$abnormal_total_pages}</a></li>";
|
|
|
+ }
|
|
|
+
|
|
|
+ // 下一页链接
|
|
|
+ if ($abnormal_page < $abnormal_total_pages) {
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}abnormal_page=" . ($abnormal_page + 1) . "#abnormal-customers'>下一页</a></li>";
|
|
|
+ } else {
|
|
|
+ echo "<li class='pager-item disabled'><a class='pager-link' href='#abnormal-customers'>下一页</a></li>";
|
|
|
+ }
|
|
|
+ ?>
|
|
|
+ </ul>
|
|
|
+ <div class="pagination-info">
|
|
|
+ 共 <?php echo $total_abnormal; ?> 条记录，当前显示第 <?php echo $abnormal_page; ?> 页，共 <?php echo $abnormal_total_pages; ?> 页
|
|
|
+ </div>
|
|
|
+ </div>
|
|
|
+ <?php endif; ?>
|
|
|
</div>
|
|
|
|
|
|
- <!-- 长期不活跃客户列表 -->
|
|
|
- <div class="warning-section" id="inactive-customers">
|
|
|
+ <!-- 流失客户列表 -->
|
|
|
+ <div class="warning-section">
|
|
|
<div class="section-header">
|
|
|
- <h2>长期不活跃客户</h2>
|
|
|
- <p>超过<?php echo $inactive_threshold; ?>天未下单的客户</p>
|
|
|
+ <h2>流失客户</h2>
|
|
|
+ <p>1年内未录入订单的客户</p>
|
|
|
</div>
|
|
|
|
|
|
<table class="data-table">
|
|
|
@@ -292,7 +361,7 @@ include('statistics_header.php');
|
|
|
<th>客户编码</th>
|
|
|
<th>客户名称</th>
|
|
|
<th>最后出货日期</th>
|
|
|
- <th>不活跃天数</th>
|
|
|
+ <th>未订单天数</th>
|
|
|
<th>历史订单数</th>
|
|
|
<th>历史订单总额</th>
|
|
|
<th>业务员</th>
|
|
|
@@ -302,25 +371,25 @@ include('statistics_header.php');
|
|
|
<tbody>
|
|
|
<?php
|
|
|
// 获取分页参数
|
|
|
- $page = isset($_GET['inactive_page']) ? intval($_GET['inactive_page']) : 1;
|
|
|
+ $page = isset($_GET['churn_page']) ? intval($_GET['churn_page']) : 1;
|
|
|
$page_size = 10; // 每页显示10条记录
|
|
|
|
|
|
// 获取总记录数
|
|
|
- $total_inactive = getInactiveCustomers($conn, $current_end_date, $inactive_threshold, true, 1, 10, $selected_employee);
|
|
|
+ $total_churn = getChurnCustomers($conn, $current_end_date, $churn_threshold, true, 1, 10, $selected_employee);
|
|
|
|
|
|
// 计算总页数
|
|
|
- $total_pages = ceil($total_inactive / $page_size);
|
|
|
+ $total_pages = ceil($total_churn / $page_size);
|
|
|
|
|
|
// 确保页码合法
|
|
|
if ($page < 1) $page = 1;
|
|
|
if ($page > $total_pages && $total_pages > 0) $page = $total_pages;
|
|
|
|
|
|
// 获取当页数据
|
|
|
- $inactive_customers = getInactiveCustomers($conn, $current_end_date, $inactive_threshold, false, $page, $page_size, $selected_employee);
|
|
|
+ $churn_customers = getChurnCustomers($conn, $current_end_date, $churn_threshold, false, $page, $page_size, $selected_employee);
|
|
|
|
|
|
- while ($customer = $inactive_customers->fetch_assoc()) {
|
|
|
+ while ($customer = $churn_customers->fetch_assoc()) {
|
|
|
$inactive_days = $customer['inactive_days'];
|
|
|
- $inactive_class = $inactive_days > 90 ? 'text-danger' : 'text-warning';
|
|
|
+ $inactive_class = $inactive_days > 365 ? 'text-danger' : 'text-warning';
|
|
|
|
|
|
echo "<tr>";
|
|
|
echo "<td title='{$customer['cs_code']}'>" . htmlspecialchars($customer['cs_code']) . "</td>";
|
|
|
@@ -334,8 +403,8 @@ include('statistics_header.php');
|
|
|
echo "</tr>";
|
|
|
}
|
|
|
|
|
|
- if ($inactive_customers->num_rows == 0) {
|
|
|
- echo "<tr><td colspan='8' class='text-center'>没有发现长期不活跃的客户</td></tr>";
|
|
|
+ if ($churn_customers->num_rows == 0) {
|
|
|
+ echo "<tr><td colspan='8' class='text-center'>没有发现流失客户</td></tr>";
|
|
|
}
|
|
|
?>
|
|
|
</tbody>
|
|
|
@@ -349,16 +418,16 @@ include('statistics_header.php');
|
|
|
// 生成分页链接的基础URL
|
|
|
$base_url = '?';
|
|
|
foreach ($_GET as $key => $value) {
|
|
|
- if ($key != 'inactive_page') {
|
|
|
+ if ($key != 'churn_page') {
|
|
|
$base_url .= $key . '=' . urlencode($value) . '&';
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 上一页链接
|
|
|
if ($page > 1) {
|
|
|
- echo "<li class='pager-item'><a class='pager-link' href='{$base_url}inactive_page=" . ($page - 1) . "#inactive-customers'>上一页</a></li>";
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}churn_page=" . ($page - 1) . "#churn-customers'>上一页</a></li>";
|
|
|
} else {
|
|
|
- echo "<li class='pager-item disabled'><a class='pager-link' href='#inactive-customers'>上一页</a></li>";
|
|
|
+ echo "<li class='pager-item disabled'><a class='pager-link' href='#churn-customers'>上一页</a></li>";
|
|
|
}
|
|
|
|
|
|
// 页码链接
|
|
|
@@ -366,37 +435,37 @@ include('statistics_header.php');
|
|
|
$end_page = min($total_pages, $page + 2);
|
|
|
|
|
|
if ($start_page > 1) {
|
|
|
- echo "<li class='pager-item'><a class='pager-link' href='{$base_url}inactive_page=1#inactive-customers'>1</a></li>";
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}churn_page=1#churn-customers'>1</a></li>";
|
|
|
if ($start_page > 2) {
|
|
|
- echo "<li class='pager-item disabled'><a class='pager-link' href='#inactive-customers'>...</a></li>";
|
|
|
+ echo "<li class='pager-item disabled'><a class='pager-link' href='#churn-customers'>...</a></li>";
|
|
|
}
|
|
|
}
|
|
|
|
|
|
for ($i = $start_page; $i <= $end_page; $i++) {
|
|
|
if ($i == $page) {
|
|
|
- echo "<li class='pager-item active'><a class='pager-link' href='#inactive-customers'>{$i}</a></li>";
|
|
|
+ echo "<li class='pager-item active'><a class='pager-link' href='#churn-customers'>{$i}</a></li>";
|
|
|
} else {
|
|
|
- echo "<li class='pager-item'><a class='pager-link' href='{$base_url}inactive_page={$i}#inactive-customers'>{$i}</a></li>";
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}churn_page={$i}#churn-customers'>{$i}</a></li>";
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if ($end_page < $total_pages) {
|
|
|
if ($end_page < $total_pages - 1) {
|
|
|
- echo "<li class='pager-item disabled'><a class='pager-link' href='#inactive-customers'>...</a></li>";
|
|
|
+ echo "<li class='pager-item disabled'><a class='pager-link' href='#churn-customers'>...</a></li>";
|
|
|
}
|
|
|
- echo "<li class='pager-item'><a class='pager-link' href='{$base_url}inactive_page={$total_pages}#inactive-customers'>{$total_pages}</a></li>";
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}churn_page={$total_pages}#churn-customers'>{$total_pages}</a></li>";
|
|
|
}
|
|
|
|
|
|
// 下一页链接
|
|
|
if ($page < $total_pages) {
|
|
|
- echo "<li class='pager-item'><a class='pager-link' href='{$base_url}inactive_page=" . ($page + 1) . "#inactive-customers'>下一页</a></li>";
|
|
|
+ echo "<li class='pager-item'><a class='pager-link' href='{$base_url}churn_page=" . ($page + 1) . "#churn-customers'>下一页</a></li>";
|
|
|
} else {
|
|
|
- echo "<li class='pager-item disabled'><a class='pager-link' href='#inactive-customers'>下一页</a></li>";
|
|
|
+ echo "<li class='pager-item disabled'><a class='pager-link' href='#churn-customers'>下一页</a></li>";
|
|
|
}
|
|
|
?>
|
|
|
</ul>
|
|
|
<div class="pagination-info">
|
|
|
- 共 <?php echo $total_inactive; ?> 条记录，当前显示第 <?php echo $page; ?> 页，共 <?php echo $total_pages; ?> 页
|
|
|
+ 共 <?php echo $total_churn; ?> 条记录，当前显示第 <?php echo $page; ?> 页，共 <?php echo $total_pages; ?> 页
|
|
|
</div>
|
|
|
</div>
|
|
|
<?php endif; ?>
|
|
|
@@ -961,35 +1030,33 @@ function getDecreasingOrderAmountCustomers($conn, $current_start, $current_end,
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * 获取复购周期异常的客户
|
|
|
+ * 获取复购周期异常的客户（3个月内未录入订单）
|
|
|
*/
|
|
|
-function getAbnormalRepurchaseCycleCustomers($conn, $current_start, $current_end, $max_threshold, $min_threshold, $normal_cycle, $count_only = false, $selected_employee = 0) {
|
|
|
+function getAbnormalRepurchaseCycleCustomers($conn, $current_start, $current_end, $threshold, $count_only = false, $selected_employee = 0, $page = 1, $page_size = 10) {
|
|
|
// 构建业务员筛选条件
|
|
|
$employee_filter = $selected_employee > 0 ? " AND c.cs_belong = ?" : "";
|
|
|
|
|
|
if ($count_only) {
|
|
|
- $sql = "SELECT COUNT(DISTINCT t.customer_id) as count
|
|
|
- FROM (
|
|
|
- SELECT
|
|
|
- o.customer_id,
|
|
|
- COUNT(o.id) as order_count,
|
|
|
- AVG(DATEDIFF(o.order_date, prev_order.order_date)) as avg_cycle,
|
|
|
- MAX(DATEDIFF(o.order_date, prev_order.order_date)) as recent_cycle
|
|
|
- FROM orders o
|
|
|
- JOIN customer c ON o.customer_id = c.id
|
|
|
- JOIN orders prev_order ON o.customer_id = prev_order.customer_id AND prev_order.order_date < o.order_date
|
|
|
- WHERE o.order_date BETWEEN ? AND ?" . $employee_filter . "
|
|
|
- GROUP BY o.customer_id
|
|
|
- HAVING order_count > 1
|
|
|
- AND (recent_cycle > ? OR recent_cycle < (? * ?))
|
|
|
- ) t";
|
|
|
+ $sql = "SELECT COUNT(DISTINCT c.id) as count
|
|
|
+ FROM customer c
|
|
|
+ LEFT JOIN (
|
|
|
+ SELECT customer_id, MAX(order_date) as last_order_date
|
|
|
+ FROM orders
|
|
|
+ GROUP BY customer_id
|
|
|
+ ) last_orders ON c.id = last_orders.customer_id
|
|
|
+ JOIN employee e ON c.cs_belong = e.id
|
|
|
+ WHERE c.cs_deal = 3
|
|
|
+ AND (
|
|
|
+ last_orders.last_order_date IS NULL
|
|
|
+ OR DATEDIFF(?, last_orders.last_order_date) > ?
|
|
|
+ )" . $employee_filter;
|
|
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
|
|
|
|
if ($selected_employee > 0) {
|
|
|
- $stmt->bind_param("ssiddd", $current_start, $current_end, $selected_employee, $max_threshold, $normal_cycle, $min_threshold);
|
|
|
+ $stmt->bind_param("sii", $current_end, $threshold, $selected_employee);
|
|
|
} else {
|
|
|
- $stmt->bind_param("ssddd", $current_start, $current_end, $max_threshold, $normal_cycle, $min_threshold);
|
|
|
+ $stmt->bind_param("si", $current_end, $threshold);
|
|
|
}
|
|
|
|
|
|
$stmt->execute();
|
|
|
@@ -998,48 +1065,45 @@ function getAbnormalRepurchaseCycleCustomers($conn, $current_start, $current_end
|
|
|
return $row['count'];
|
|
|
}
|
|
|
|
|
|
- // 使用子查询方式，先获取所有符合条件的客户及其复购周期数据
|
|
|
+ $offset = ($page - 1) * $page_size;
|
|
|
+
|
|
|
$sql = "SELECT
|
|
|
- abnormal.customer_id as id,
|
|
|
+ c.id,
|
|
|
c.cs_company,
|
|
|
- abnormal.order_count,
|
|
|
- abnormal.avg_cycle,
|
|
|
- abnormal.recent_cycle,
|
|
|
- abnormal.last_order_date,
|
|
|
- e.em_user,
|
|
|
- CASE
|
|
|
- WHEN abnormal.recent_cycle > ? THEN 1 /* 周期过长 */
|
|
|
- ELSE 2 /* 周期过短 */
|
|
|
- END as cycle_type,
|
|
|
+ last_orders.last_order_date,
|
|
|
CASE
|
|
|
- WHEN abnormal.recent_cycle > ? THEN abnormal.recent_cycle
|
|
|
- ELSE (? * ?) - abnormal.recent_cycle
|
|
|
- END as sort_value
|
|
|
- FROM (
|
|
|
- SELECT
|
|
|
- o.customer_id,
|
|
|
- COUNT(o.id) as order_count,
|
|
|
- AVG(DATEDIFF(o.order_date, prev_order.order_date)) as avg_cycle,
|
|
|
- MAX(DATEDIFF(o.order_date, prev_order.order_date)) as recent_cycle,
|
|
|
- (SELECT MAX(order_date) FROM orders WHERE customer_id = o.customer_id) as last_order_date
|
|
|
- FROM orders o
|
|
|
- JOIN customer c ON o.customer_id = c.id
|
|
|
- JOIN orders prev_order ON o.customer_id = prev_order.customer_id AND prev_order.order_date < o.order_date
|
|
|
- WHERE o.order_date BETWEEN ? AND ?" . $employee_filter . "
|
|
|
- GROUP BY o.customer_id
|
|
|
- HAVING order_count > 1
|
|
|
- AND (recent_cycle > ? OR recent_cycle < (? * ?))
|
|
|
- ) as abnormal
|
|
|
- JOIN customer c ON abnormal.customer_id = c.id
|
|
|
+ WHEN last_orders.last_order_date IS NULL THEN DATEDIFF(?, c.cs_addtime)
|
|
|
+ ELSE DATEDIFF(?, last_orders.last_order_date)
|
|
|
+ END as inactive_days,
|
|
|
+ IFNULL(order_stats.order_count, 0) as order_count,
|
|
|
+ IFNULL(order_stats.total_amount, 0) as total_amount,
|
|
|
+ e.em_user
|
|
|
+ FROM customer c
|
|
|
+ LEFT JOIN (
|
|
|
+ SELECT customer_id, MAX(order_date) as last_order_date
|
|
|
+ FROM orders
|
|
|
+ GROUP BY customer_id
|
|
|
+ ) last_orders ON c.id = last_orders.customer_id
|
|
|
+ LEFT JOIN (
|
|
|
+ SELECT customer_id, COUNT(*) as order_count, SUM(total_amount) as total_amount
|
|
|
+ FROM orders
|
|
|
+ GROUP BY customer_id
|
|
|
+ ) order_stats ON c.id = order_stats.customer_id
|
|
|
JOIN employee e ON c.cs_belong = e.id
|
|
|
- ORDER BY sort_value DESC";
|
|
|
+ WHERE c.cs_deal = 3
|
|
|
+ AND (
|
|
|
+ last_orders.last_order_date IS NULL
|
|
|
+ OR DATEDIFF(?, last_orders.last_order_date) > ?
|
|
|
+ )" . $employee_filter . "
|
|
|
+ ORDER BY inactive_days DESC
|
|
|
+ LIMIT ?, ?";
|
|
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
|
|
|
|
if ($selected_employee > 0) {
|
|
|
- $stmt->bind_param("ddddssiddd", $max_threshold, $max_threshold, $normal_cycle, $min_threshold, $current_start, $current_end, $selected_employee, $max_threshold, $normal_cycle, $min_threshold);
|
|
|
+ $stmt->bind_param("sssiii", $current_end, $current_end, $current_end, $threshold, $selected_employee, $offset, $page_size);
|
|
|
} else {
|
|
|
- $stmt->bind_param("ddddssddd", $max_threshold, $max_threshold, $normal_cycle, $min_threshold, $current_start, $current_end, $max_threshold, $normal_cycle, $min_threshold);
|
|
|
+ $stmt->bind_param("sssiii", $current_end, $current_end, $current_end, $threshold, $offset, $page_size);
|
|
|
}
|
|
|
|
|
|
$stmt->execute();
|
|
|
@@ -1047,12 +1111,81 @@ function getAbnormalRepurchaseCycleCustomers($conn, $current_start, $current_end
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * 获取长期不活跃的客户
|
|
|
+ * 获取长期不活跃的客户（3个月内没有客户信息修改）
|
|
|
*/
|
|
|
function getInactiveCustomers($conn, $end_date, $inactive_days, $count_only = false, $page = 1, $page_size = 10, $selected_employee = 0) {
|
|
|
// 构建业务员筛选条件
|
|
|
$employee_filter = $selected_employee > 0 ? " AND c.cs_belong = ?" : "";
|
|
|
|
|
|
+ if ($count_only) {
|
|
|
+ $sql = "SELECT COUNT(*) as count
|
|
|
+ FROM customer c
|
|
|
+ JOIN employee e ON c.cs_belong = e.id
|
|
|
+ WHERE c.cs_deal = 3
|
|
|
+ AND DATEDIFF(?, c.cs_updatetime) > ?" . $employee_filter;
|
|
|
+
|
|
|
+ $stmt = $conn->prepare($sql);
|
|
|
+
|
|
|
+ if ($selected_employee > 0) {
|
|
|
+ $stmt->bind_param("sii", $end_date, $inactive_days, $selected_employee);
|
|
|
+ } else {
|
|
|
+ $stmt->bind_param("si", $end_date, $inactive_days);
|
|
|
+ }
|
|
|
+
|
|
|
+ $stmt->execute();
|
|
|
+ $result = $stmt->get_result();
|
|
|
+ $row = $result->fetch_assoc();
|
|
|
+ return $row['count'];
|
|
|
+ }
|
|
|
+
|
|
|
+ $sql = "SELECT
|
|
|
+ c.id,
|
|
|
+ c.cs_company,
|
|
|
+ c.cs_code,
|
|
|
+ last_orders.last_order_date,
|
|
|
+ DATEDIFF(?, c.cs_updatetime) as inactive_days,
|
|
|
+ c.cs_updatetime as last_update_time,
|
|
|
+ IFNULL(order_stats.order_count, 0) as order_count,
|
|
|
+ IFNULL(order_stats.total_amount, 0) as total_amount,
|
|
|
+ e.em_user
|
|
|
+ FROM customer c
|
|
|
+ LEFT JOIN (
|
|
|
+ SELECT customer_id, MAX(order_date) as last_order_date
|
|
|
+ FROM orders
|
|
|
+ GROUP BY customer_id
|
|
|
+ ) last_orders ON c.id = last_orders.customer_id
|
|
|
+ LEFT JOIN (
|
|
|
+ SELECT customer_id, COUNT(*) as order_count, SUM(total_amount) as total_amount
|
|
|
+ FROM orders
|
|
|
+ GROUP BY customer_id
|
|
|
+ ) order_stats ON c.id = order_stats.customer_id
|
|
|
+ JOIN employee e ON c.cs_belong = e.id
|
|
|
+ WHERE c.cs_deal = 3
|
|
|
+ AND DATEDIFF(?, c.cs_updatetime) > ?" . $employee_filter . "
|
|
|
+ ORDER BY inactive_days DESC
|
|
|
+ LIMIT ?, ?";
|
|
|
+
|
|
|
+ $offset = ($page - 1) * $page_size;
|
|
|
+
|
|
|
+ $stmt = $conn->prepare($sql);
|
|
|
+
|
|
|
+ if ($selected_employee > 0) {
|
|
|
+ $stmt->bind_param("ssiiii", $end_date, $end_date, $inactive_days, $selected_employee, $offset, $page_size);
|
|
|
+ } else {
|
|
|
+ $stmt->bind_param("ssiii", $end_date, $end_date, $inactive_days, $offset, $page_size);
|
|
|
+ }
|
|
|
+
|
|
|
+ $stmt->execute();
|
|
|
+ return $stmt->get_result();
|
|
|
+}
|
|
|
+
|
|
|
+/**
|
|
|
+ * 获取流失客户（1年内未录入订单）
|
|
|
+ */
|
|
|
+function getChurnCustomers($conn, $end_date, $churn_days, $count_only = false, $page = 1, $page_size = 10, $selected_employee = 0) {
|
|
|
+ // 构建业务员筛选条件
|
|
|
+ $employee_filter = $selected_employee > 0 ? " AND c.cs_belong = ?" : "";
|
|
|
+
|
|
|
if ($count_only) {
|
|
|
$sql = "SELECT COUNT(*) as count
|
|
|
FROM customer c
|
|
|
@@ -1071,9 +1204,9 @@ function getInactiveCustomers($conn, $end_date, $inactive_days, $count_only = fa
|
|
|
$stmt = $conn->prepare($sql);
|
|
|
|
|
|
if ($selected_employee > 0) {
|
|
|
- $stmt->bind_param("sii", $end_date, $inactive_days, $selected_employee);
|
|
|
+ $stmt->bind_param("sii", $end_date, $churn_days, $selected_employee);
|
|
|
} else {
|
|
|
- $stmt->bind_param("si", $end_date, $inactive_days);
|
|
|
+ $stmt->bind_param("si", $end_date, $churn_days);
|
|
|
}
|
|
|
|
|
|
$stmt->execute();
|
|
|
@@ -1119,9 +1252,9 @@ function getInactiveCustomers($conn, $end_date, $inactive_days, $count_only = fa
|
|
|
$stmt = $conn->prepare($sql);
|
|
|
|
|
|
if ($selected_employee > 0) {
|
|
|
- $stmt->bind_param("sssiiii", $end_date, $end_date, $end_date, $inactive_days, $selected_employee, $offset, $page_size);
|
|
|
+ $stmt->bind_param("sssiiiii", $end_date, $end_date, $end_date, $churn_days, $selected_employee, $offset, $page_size);
|
|
|
} else {
|
|
|
- $stmt->bind_param("sssiii", $end_date, $end_date, $end_date, $inactive_days, $offset, $page_size);
|
|
|
+ $stmt->bind_param("sssiii", $end_date, $end_date, $end_date, $churn_days, $offset, $page_size);
|
|
|
}
|
|
|
|
|
|
$stmt->execute();
|
igb