数据同步

biz/user/services/UserService.php

@@ -300,18 +300,19 @@ class UserService extends BaseService
 		$realName = isset($data['realName']) ? $data['realName'] : $mobile;
 		$member = isset($data['member']) ? $data['member'] : -1;
 		$balance = isset($data['balance']) ? $data['balance'] : 0;
+		$growth = isset($data['growth']) ? $data['growth'] : 0;
 		
 		$originalInfo = [];
 		$originalInfo['merchantId'] = $merchantId;
 		$originalInfo['mobile'] = $mobile;
 		$originalInfo['realName'] = $realName;
-		
+		$originalInfo['userName'] = $realName;
+
 		$user = UserService::replaceUser($originalInfo, $source, $merchantId);
 		
 		$extend = MerchantExtendService::getByMerchantId($merchantId);
 		
 		//等级
-		$growth = 0;
 		if ($member > 0) {
 			$gradeList = xhMerchantExtendService::getGradeList($extend, 'desc');
 			$growth = isset($gradeList[$member]['growth']) ? $gradeList[$member]['growth'] : 0;
@@ -326,6 +327,7 @@ class UserService extends BaseService
 		
 		//会员升级
 		UserIntegralService::increaseToUpgrade(0, $growth, 0, $userId, $merchantId, $extend);
+		return $user;
 	}
 	
 }

common/config/main.php

@@ -16,6 +16,13 @@ return [
 			'password' => getenv('DB_PASSWORD'),
 			'charset' => 'utf8',
 		],
+		'db2' => [
+			'class' => 'yii\db\Connection',
+			'dsn' => getenv('DB_DSN_BAK'),
+			'username' => getenv('DB_USERNAME'),
+			'password' => getenv('DB_PASSWORD'),
+			'charset' => 'utf8',
+		],
 		'redis' => [
 			'class' => 'yii\redis\Connection',
 			'hostname' => getenv('REDIS_HOST'),

console/controllers/UpgradeController.php

@@ -2,6 +2,7 @@
 
 namespace console\controllers;
 
+use biz\user\services\UserService;
 use Yii;
 use yii\console\Controller;
 
@@ -713,4 +714,20 @@ ALTER TABLE `xhMerchantCapital` MODIFY `io` TINYINT NOT NULL DEFAULT 0 COMMENT '
 		
 	}
 	
+	public function actionInit2()
+	{
+		//国兰老客户导入
+		$oldUserList = Yii::$app->db2->createCommand('select * from xhUserOldData where `status`=0')->queryAll();
+		if (!empty($oldUserList)) {
+			foreach ($oldUserList as $user) {
+				$user['realName'] = $user['userName'];
+				$user['growth'] = $user['integral'];
+				$insertUser = UserService::addUser($user);
+				$id = $user['id'];
+				Yii::$app->db2->createCommand("update xhUserOldData set `status`=1 where id={$id}")->execute();
+				echo $insertUser['id'] . "\n";
+			}
+		}
+	}
+	
 }

sql2.txt

@@ -1,21 +1,19 @@
-2019.12.19 统计表的变更 注意线上哪些统计相关的表有数据，要转化（注意里面涉及的表）！！！
+统计表的变更 注意线上哪些统计相关的表有数据，要转化（注意里面涉及的表）！！！
 
-2019.12.17 shish 商家流水相关表修改 ！！！
+商家流水相关表修改 ！！！
 
 UPDATE `xhMerchantCapital` SET `relateId`=0;！！！！！！这条要使用php来转换
 UPDATE `xhUserGrowth` SET `relateId`=0;！！！！！！这条要使用php来转换
 UPDATE `xhUserCapital` SET `relateId`=0;！！！！！！这条要使用php来转换
 
-2019.12.29 shish 会员 这个需要特别注意国兰数据迁移问题！！！！
+xhOrder xhOrderGoods 关联关系
 
-订单表的优化 ！！！要写php更新 xhOrder xhOrderGoods
+增加xhRegion表结构和数据
 
-增加xhRegion表结构和数据！！
+全部的会员折扣要纠正
 
-!!执行下面的sql，全部的会员折扣要纠正
+国兰的商品款式表要给对应上，注意xhGoods表里的goodsStyle也要改
 
-！！国兰的商品款式表要给对应上，注意xhGoods表里的goodsStyle也要改
+注意第一家店分类与用途迁移的问题
 
-!!注意第一家店分类与用途迁移的问题
-
-!!!!!!老客户没给国兰导进来的要导进来客户表里
+从微信那边重新拉取国兰客户的头像