|
|
@@ -807,11 +807,6 @@ class PreparePerfCalc {
|
|
|
if (!$this->_isCalcMonth) {
|
|
|
return true;
|
|
|
}
|
|
|
- file_put_contents('ccctxt.txt',var_export([
|
|
|
- 'offset' => $offset,
|
|
|
- 'CALC_MONTH' => $this->_calcYearMonth,
|
|
|
- 'PERIOD_NUM' => $this->_periodNum
|
|
|
- ],true), FILE_APPEND);
|
|
|
// AR_PERF_ORDER_PREPARE\AR_PERF_PERIOD_PREPARE\AR_PERIOD_PREPARE\AR_PERF_MONTH_PREPARE
|
|
|
// AR_PERIOD_PREPARE 表只需要是结算月的数据
|
|
|
// AR_PERF_PERIOD_PREPARE 表特殊,需要增加一个字段,是否存在于前三期中 已被第一次算月业绩使用过了
|
|
|
@@ -955,14 +950,14 @@ class PreparePerfCalc {
|
|
|
echo sprintf("时间:[%s]预计月业绩,结算月新添加的用户,当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
|
|
|
// 从缓存列表里面从底层往上倒序获取会员 IS_HAS_USER 0 代表是此结算周期新增的业绩
|
|
|
$allData = PerfPeriodPrepare::findUseDbCalc()
|
|
|
- ->select('USER_ID, SUM(FX_AMOUNT_CASH) AS FX_AMOUNT_CASH_SUM,SUM(PV_PCS) AS PV_PCS_SUM,
|
|
|
+ ->select('IS_HAS_USER,USER_ID, SUM(FX_AMOUNT_CASH) AS FX_AMOUNT_CASH_SUM,SUM(PV_PCS) AS PV_PCS_SUM,
|
|
|
SUM(PV_PCS_FX) AS PV_PCS_FX_SUM,SUM(PV_PSS) AS PV_PSS_SUM,
|
|
|
SUM(PV_1L) AS PV_1L_SUM,SUM(PV_2L) AS PV_2L_SUM,
|
|
|
SUM(PV_3L) AS PV_3L_SUM,SUM(PV_4L) AS PV_4L_SUM,
|
|
|
SUM(PV_5L) AS PV_5L_SUM,SUM(PV_1L_ZC) AS PV_1L_ZC_SUM,
|
|
|
SUM(PV_2L_ZC) AS PV_2L_ZC_SUM,SUM(PV_3L_ZC) AS PV_3L_ZC_SUM,
|
|
|
SUM(PV_4L_ZC) AS PV_4L_ZC_SUM,SUM(PV_5L_ZC) AS PV_5L_ZC_SUM')
|
|
|
- ->where('CALC_MONTH=:CALC_MONTH AND IS_HAS_USER=0', [':CALC_MONTH' => $this->_calcYearMonth])
|
|
|
+ ->where('CALC_MONTH=:CALC_MONTH', [':CALC_MONTH' => $this->_calcYearMonth])
|
|
|
->groupBy('USER_ID')
|
|
|
->orderBy('USER_ID DESC')
|
|
|
->offset($offset)
|
|
|
@@ -972,6 +967,9 @@ class PreparePerfCalc {
|
|
|
if ($allData) {
|
|
|
// 月度业绩表
|
|
|
foreach ($allData as $everyData) {
|
|
|
+ if ($everyData['IS_HAS_USER'] != 0) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
$userId = $everyData['USER_ID'];
|
|
|
//往期业绩
|
|
|
$userLastPerf = PrepareCalcCache::userPerf($userId, $this->_periodNum);
|