Skip to content

M
my-yaf-project
Commit 7bdd0fea authored by wwccw0591's avatar wwccw0591
Browse files
Options

pc

parent 5fb83a99
Hide whitespace changes
Inline Side-by-side
Showing with 103 additions and 28 deletions
application/models/Business/Store/ShopkeeperService.php
View file @ 7bdd0fea
......@@ -476,8 +476,7 @@ class ShopkeeperServiceModel extends \Business\AbstractModel
}
return $results;
}
//任务脚本
//任务脚本原来的方法是下面那个
public function insertStoreMemberStatics()
{
$orderGoodDao = \DAO\Order\OrderGoodsModel::getInstance(DbNameConst::salveDBConnectName);
......@@ -492,37 +491,86 @@ class ShopkeeperServiceModel extends \Business\AbstractModel
$addDatas = array();
$storeMemberStatisticData = $orderGoodDao->getMemberStoreStaticsByCreateTime($beginTime, $this->taskIndex, $this->taskSize);
$storeMemberStatisticData = isset($storeMemberStatisticData['list']) ? $storeMemberStatisticData['list'] : false;
$orderIds=array_column($storeMemberStatisticData,'orderId');
array_unique($orderIds);
if(!empty($orderIds)){
$orders=$orderDao->getByOrderId($orderIds,'order_amount as orderAmount,order_id as orderId','orderId');
}else{
$orders=[];
}
if ($storeMemberStatisticData) {
if($storeMemberStatisticData){
$this->taskIndex++;
foreach ($storeMemberStatisticData as $value) {
$addDatas[$value['buyerId'] . '-' . $value['storeId']]['storeId'] = $value['storeId'];
$addDatas[$value['buyerId'] . '-' . $value['storeId']]['memberId'] = $value['buyerId'];
if (isset($addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderGoodsCount'])) {
$addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderGoodsCount'] += $value['goodsNum'];
} else {
$addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderGoodsCount'] = $value['goodsNum'];
$storeId=array_column($storeMemberStatisticData,'storeId');
$memberId=array_column($storeMemberStatisticData,'buyerId');
$storeIds= array_unique($storeId);
$memberIds=array_unique($memberId);
$goodsNumCount=$orderGoodDao->getMemberStoreOrderGoodsCount($storeIds,$memberIds);
$ordersCount=$orderDao->getSumAmountCountByMemberAndStoreId($storeIds,$memberIds);
$arr = array();
if(!empty($goodsNumCount)&&!empty($ordersCount)){
foreach($goodsNumCount as $k=>$r){
$arr[] = array_merge($r,$ordersCount[$k]);
}
if (isset($addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderTotal'])) {
// $addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderTotal'] += $value['goodsPrice'];
$addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderTotal'] +=$orders[$value['orderId']]['orderAmount'];
} else {
$addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderTotal'] = $orders[$value['orderId']]['orderAmount'];
$addDatas=$arr;
}else{
if(!empty($goodsNumCount)){
$addDatas=$goodsNumCount;
}else{
$addDatas=$goodsNumCount;
}
}
if(!empty($goodsNumCount)){
$storeMemberStatisticDao->addAll($goodsNumCount,'orderGoodsCount');
}
if(!empty($ordersCount)){
$storeMemberStatisticDao->addAll($ordersCount,'orderTotal');
}
}
$addDatas = array_values($addDatas);
$storeMemberStatisticDao->addAll($addDatas);
} while ($storeMemberStatisticData);
file_put_contents($this->baseDir . PathConst::orderGoodsCreateTime, TIMESTAMP);
}
//任务脚本
// public function insertStoreMemberStatics()
// {
// $orderGoodDao = \DAO\Order\OrderGoodsModel::getInstance(DbNameConst::salveDBConnectName);
// $orderDao=\DAO\Order\OrderModel::getInstance();
// $storeMemberStatisticDao = \DAO\StoreMemberStatisticsModel::getInstance(DbNameConst::masterDBConnectName);
// $gmtCreate = file_get_contents($this->baseDir . PathConst::orderGoodsCreateTime);
// $gmtCreate = $gmtCreate ? $gmtCreate : ApiConst::zero;
// $beginTime = $gmtCreate;
// $this->taskIndex = PageConst::taskPageBegin;
// $this->taskSize = PageConst::taskPageSize;
// do {
// $addDatas = array();
// $storeMemberStatisticData = $orderGoodDao->getMemberStoreStaticsByCreateTime($beginTime, $this->taskIndex, $this->taskSize);
// $storeMemberStatisticData = isset($storeMemberStatisticData['list']) ? $storeMemberStatisticData['list'] : false;
// $orderIds=array_column($storeMemberStatisticData,'orderId');
// array_unique($orderIds);
// if(!empty($orderIds)){
// $orders=$orderDao->getByOrderId($orderIds,'order_amount as orderAmount,order_id as orderId','orderId');
// }else{
// $orders=[];
// }
// if ($storeMemberStatisticData) {
// $this->taskIndex++;
// foreach ($storeMemberStatisticData as $value) {
// $addDatas[$value['buyerId'] . '-' . $value['storeId']]['storeId'] = $value['storeId'];
// $addDatas[$value['buyerId'] . '-' . $value['storeId']]['memberId'] = $value['buyerId'];
// if (isset($addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderGoodsCount'])) {
// $addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderGoodsCount'] += $value['goodsNum'];
// } else {
// $addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderGoodsCount'] = $value['goodsNum'];
// }
// if (isset($addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderTotal'])) {
// // $addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderTotal'] += $value['goodsPrice'];
// $addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderTotal'] +=$orders[$value['orderId']]['orderAmount'];
// } else {
// $addDatas[$value['buyerId'] . '-' . $value['storeId']]['orderTotal'] = $orders[$value['orderId']]['orderAmount'];
// }
// }
// }
// $addDatas = array_values($addDatas);
// $storeMemberStatisticDao->addAll($addDatas);
// } while ($storeMemberStatisticData);
// file_put_contents($this->baseDir . PathConst::orderGoodsCreateTime, TIMESTAMP);
//
// }
//创建索引
public function createOrdersIndex()
......
application/models/DAO/Order/Order.php
View file @ 7bdd0fea
......@@ -377,6 +377,16 @@ class OrderModel extends \DAO\AbstractModel
}
}
public function getSumAmountCountByMemberAndStoreId($storeIds,$memberIds)
{
$this->setDb($this->dbName);
$where['store_id']=array('in',$storeIds);
$where['member_ids']=array('in',$memberIds);
$where['order_state']=array('notin','-1,0');
$res=$this->db->from($this->_tableName)->select(" buyer_id as buyerId,store_id as storeId,sum(order_amount) as orderTotal")->group('buyer_id')->group('store_id')->fetchAll();
return $res;
}
//待收货获取订单状态信息
public function getOrderStatusExtent($order)
{
......
application/models/DAO/Order/OrderGoods.php
View file @ 7bdd0fea
......@@ -19,7 +19,7 @@ class OrderGoodsModel extends \DAO\AbstractModel {
protected $_tableName = 'han_order_goods';
public $sumField="rec_id,store_id as storeId,buyer_id as buyerId,goods_num as goodsNum,goods_price as goodsPrice,gmt_create as gmtCreate,order_id as orderId";
public $groupField=array('buyer_id','store_id');
public $sumGoodsNum=' store_id as storeId,buyer_id as buyerId,sum(goods_num) as orderGoodsCount';
public $orderGoodsField = "order_id as orderId,rec_id as recId,goods_id as goodsId,goods_name as goodsName,goods_price as goodsPrice,goods_num as goodsNum,goods_image as goodsImage,goods_pay_price as goodsPayPrice,sale_act_id as saleActId,sale_id as saleId,comment_state as commentState,is_refund as isRefund,goods_spec as goodsSpec,refund_state_name as refundStateName,refund_id as refundId";
/**
* 主键
......@@ -225,6 +225,15 @@ class OrderGoodsModel extends \DAO\AbstractModel {
$res=$this->lists($where,array('gmt_create'=>'asc'),$this->sumField,$pageIndex,$pageSize);
return $res['list']?$res:false;
}
public function getMemberStoreOrderGoodsCount($storeIds,$memberIds){
$this->setDb($this->dbName);
$where['store_id']=array('in',$storeIds);
$where['buyer_id']=array('in',$memberIds);
$where['is_refund']=array('neq',ApiConst::one);
$res=$this->db->from($this->_tableName)->select($this->sumGoodsNum)->group("buyer_id")->group("store_id")->fetchAll();
return $res;
}
/**
* 类实例
*
......
application/models/DAO/StoreMemberStatistics.php
View file @ 7bdd0fea
......@@ -170,15 +170,23 @@ class StoreMemberStatisticsModel extends \DAO\AbstractModel {
}
//插入数据大量
public function addAll($datas)
public function addAll($datas,$field="orderGoodsCount")
{
$this->setDb(DbNameConst::masterDBConnectName);
$error = 0;
$baseSql = "insert into {$this->_tableName}({$this->insertField}) values";
$extentSql=" ON DUPLICATE KEY UPDATE order_goods_count=order_goods_count+values(order_goods_count),order_total=order_total+values(order_total)";
if($field=='orderGoodsCount'){
$extentSql=" ON DUPLICATE KEY UPDATE order_goods_count=values(order_goods_count)";
}
if($field=='orderTotal'){
$extentSql=" ON DUPLICATE KEY UPDATE order_total=values(order_total)";
}
$insertAllSql = $baseSql;
for ($i = 0; $i < count($datas); $i++) {
$addSql = \Our\Common::format("({0},{1},{2},{3},{4}),", $datas[$i]['storeId'], $datas[$i]['memberId'],$datas[$i]['orderGoodsCount'], $datas[$i]['orderTotal'],TIMESTAMP);
$datas[$i]['orderGoodsCount']=isset($datas[$i]['orderGoodsCount'])?$datas[$i]['orderGoodsCount']:ApiConst::zero;
$datas[$i]['orderTotal']=isset( $datas[$i]['orderTotal'])? $datas[$i]['orderTotal']:ApiConst::zero;
$addSql = \Our\Common::format("({0},{1},{2},{3},{4}),", $datas[$i]['storeId'], $datas[$i]['buyerId'],$datas[$i]['orderGoodsCount'], $datas[$i]['orderTotal'],TIMESTAMP);
$insertAllSql .= $addSql;
if ($i % 1000 == 0 && $i != 0) {
$insertAllSql = rtrim($insertAllSql, ',');
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment