扫码问题

application/models/Business/Store/StoreService.php

@@ -56,6 +56,7 @@ class StoreServiceModel extends \Business\AbstractModel{
                 $storeMember['store_id'] = $storeId;
                 $storeMember['member_id'] = $memberId;
                 $storeMember['fav_from'] = \Our\ApiConst::scanFavor;
+                $storeMember['fav_type'] = \Our\ApiConst::one;
                 $storeMembers[] = $storeMember;
                 $favoritesStoreDao = \DAO\FavoritesStoreModel::getInstance();
                 $result = $favoritesStoreDao->insertAll($storeMembers);

application/models/Business/User/MemberService.php

@@ -320,6 +320,7 @@ class MemberServiceModel extends \Business\AbstractModel
                 $storeMember['store_id'] = $storeId;
                 $storeMember['member_id'] = $memberId;
                 $storeMember['fav_from'] = \Our\ApiConst::scanFavor;
+                $storeMember['fav_type'] = \Our\ApiConst::one;
                 $storeMembers[] = $storeMember;
             }
             /*$storeMemberDao = \DAO\StoreMemberModel::getInstance(\Our\DbNameConst::masterDBConnectName);

application/models/DAO/FavoritesStore.php

@@ -113,18 +113,24 @@ class FavoritesStoreModel extends \DAO\AbstractModel {
         return $result;
     }
 
+    /**
+     * 该函数目前仅适用于扫码关注业务 ,使用请谨慎
+     * @param $datas
+     * @return bool
+     * @throws \Our\Exception
+     */
     public function insertAll($datas){
         $this->setDb(\Our\DbNameConst::masterDBConnectName);
         $error = 0;
-        $baseSql = "insert IGNORE into {$this->_tableName}(member_id,store_id,fav_from,fav_time) values";
+        $baseSql = "insert IGNORE into {$this->_tableName}(member_id,store_id,fav_from,fav_time,fav_type) values";
         $insertAllSql = $baseSql;
         for ($i = 0; $i < count($datas); $i++) {
-            $addSql = \Our\Common::format("('{0}','{1}','{2}','{3}'),", $datas[$i]['member_id'], $datas[$i]['store_id'], $datas[$i]['fav_from'],TIMESTAMP);
+            $addSql = \Our\Common::format("('{0}','{1}','{2}','{3}','{4}'),", $datas[$i]['member_id'], $datas[$i]['store_id'], $datas[$i]['fav_from'],TIMESTAMP,$datas[$i]['fav_type']);
             \Our\RedisHelper::delCachedFunction(\Redis\Db6\FavoritesStoreRedisModel::getInstance(), array(&$this, 'selectList'), array() ,array($datas[$i]['member_id']));
             $insertAllSql .= $addSql;
             if ($i % 1000 == 0 && $i != 0) {
                 $insertAllSql = rtrim($insertAllSql, ',');
-                $insertAllSql .= 'ON DUPLICATE KEY UPDATE fav_time=VALUES (fav_time),fav_from = VALUES (fav_from)';
+                $insertAllSql .= 'ON DUPLICATE KEY UPDATE fav_time=VALUES (fav_time),fav_from = VALUES (fav_from) ,fav_type = VALUES (fav_type)';
                 $one = $this->db->insert($this->_tableName)->query($insertAllSql);
                 if (!$one) {
                     $error++;
@@ -134,7 +140,7 @@ class FavoritesStoreModel extends \DAO\AbstractModel {
         }
         if ($insertAllSql != $baseSql) {
             $insertAllSql = rtrim($insertAllSql, ',');
-            $insertAllSql .= 'ON DUPLICATE KEY UPDATE fav_time=VALUES (fav_time),fav_from = VALUES (fav_from)';
+            $insertAllSql .= 'ON DUPLICATE KEY UPDATE fav_time=VALUES (fav_time),fav_from = VALUES (fav_from),fav_type = VALUES (fav_type)';
             $one = $this->db->insert($this->_tableName)->query($insertAllSql);
 
             if (!$one) {