库存及销量更新

application/models/DAO/Goods.php

@@ -313,7 +313,7 @@ class GoodsModel extends \DAO\AbstractModel {
         $updateAllSql = $baseSql;
         $dataIds = array();
         for ($i = 0; $i < count($datas); $i++) {
-            $updateSql = \Our\Common::format(" WHEN {0} THEN goods_storage{2}{1} ", $datas[$i]['goodsId'], $datas[$i]['goodsNum'],\Our\ArrayConst::ops[$op]);
+            $updateSql = \Our\Common::format(" WHEN {0} THEN goods_storage{2}{1},", $datas[$i]['goodsId'], $datas[$i]['goodsNum'],\Our\ArrayConst::ops[$op]);
             $dataIds[] = $datas[$i]['goodsId'];
             $updateAllSql .= $updateSql;
             if ($i % 1000 == 0 && $i != 0) {

application/models/DAO/GoodsCommon.php

@@ -214,26 +214,43 @@ class GoodsCommonModel extends \DAO\AbstractModel {
         if($updateSaleNumFlag&&$op!=\Our\ApiConst::set){
             $updateSaleNumOp = $op==\Our\ApiConst::minus?'+':'-';
         }
+        $goodsCommonSql = 'goods_storage = case goods_commonid ';
+        if($updateSaleNumFlag){
+            $saleNumSql = 'sale_num = case goods_commonid ';
+        }
         for ($i = 0; $i < count($datas); $i++) {
-            $updateSql = \Our\Common::format(" goods_storage = case goods_commonid  WHEN {0} THEN goods_storage{1}{2}, ", $datas[$i]['goodsCommonId'],\Our\ArrayConst::ops[$op], $datas[$i]['goodsNum']);
+            $goodsCommonSql .= \Our\Common::format("  WHEN {0} THEN goods_storage{1}{2}, ", $datas[$i]['goodsCommonId'],\Our\ArrayConst::ops[$op], $datas[$i]['goodsNum']);
             if($updateSaleNumFlag){
-                $updateSql = \Our\Common::format(" goods_storage = case goods_commonid  WHEN {0} THEN goods_storage{1}{2} END,sale_num = case goods_commonid when {0} THEN sale_num {3}{2} END,", $datas[$i]['goodsCommonId'],\Our\ArrayConst::ops[$op], $datas[$i]['goodsNum'],$updateSaleNumOp);
+                $saleNumSql .= \Our\Common::format(" when {0} THEN sale_num {1}{2},", $datas[$i]['goodsCommonId'],$updateSaleNumOp, $datas[$i]['goodsNum']);
             }
             $dataIds[] = $datas[$i]['goodsCommonId'];
-            $updateAllSql .= $updateSql;;
             if ($i % 1000 == 0 && $i != 0) {
-                $updateAllSql = trim($updateAllSql,',');
+                $goodsCommonSql = trim($goodsCommonSql,',').' END';
+                $updateAllSql .= $goodsCommonSql;
+                if($updateSaleNumFlag){
+                    $saleNumSql = ','.trim($saleNumSql,',').' END ';
+                    $updateAllSql .= $saleNumSql;
+                }
                 $updateAllSql .= \Our\Common::format(' where goods_commonid in ({0})',implode(',',$dataIds));
                 $one = $this->db->update($this->_tableName)->query($updateAllSql);
                 if (!$one) {
                     $error++;
                 }
                 $updateAllSql = $baseSql;
+                $goodsCommonSql = 'goods_storage = case goods_commonid ';
+                if($updateSaleNumFlag){
+                    $saleNumSql = 'sale_num = case goods_commonid ';
+                }
                 $dataIds = array();
             }
         }
         if ($updateAllSql != $baseSql) {
-            $updateAllSql = trim($updateAllSql,',');
+            $goodsCommonSql = trim($goodsCommonSql,',').' END ';
+            $updateAllSql .= $goodsCommonSql;
+            if($updateSaleNumFlag){
+                $saleNumSql = ','.trim($saleNumSql,',').' END ';
+                $updateAllSql .= $saleNumSql;
+            }
             $updateAllSql .= \Our\Common::format(' where goods_commonid in ({0})',implode(',',$dataIds));
             $one = $this->db->update($this->_tableName)->query($updateAllSql);