OrderSeeder.php 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115
  1. <?php
  2. use Illuminate\Database\Seeder;
  3. Class OrderSeeder extends Seeder
  4. {
  5. protected $sourceTable = 'sz_yi_order';
  6. protected $memberMappingTable = 'mc_mapping_fans';
  7. // protected $newMappingMemberTable = 'new_mapping_fans'; //todo 针对原来的自编openid用户的会员, 等待"会员重构组"生成新旧openid的对应表
  8. protected $orderTable = 'yz_order';
  9. protected $orderMappingTable = 'yz_order_mapping'; //用来记录新旧orderid的对应关系,包括新旧uid的对应关系
  10. public function run()
  11. {
  12. return;
  13. if (!Schema::hasTable($this->sourceTable)) {
  14. echo $this->sourceTable." 不存在 跳过\n";
  15. return;
  16. }
  17. //检测新的数据表是否有数据
  18. // $newList = DB::table($this->orderTable)->first();
  19. // if($newList){
  20. // echo $this->orderTable . "数据表已经有数据, 请检查.\n";
  21. // return;
  22. // }
  23. $sourceList = \Illuminate\Support\Facades\DB::table($this->sourceTable)->chunk(100, function($records){
  24. foreach ($records as $record){
  25. //如果旧表字段没有值,则设为0
  26. foreach ($record as $k => $v){
  27. if(!$v){
  28. $record[$k] = 0;
  29. }
  30. }
  31. //"删除时间"在旧表中没有对应字段, 只有"是否删除"字段
  32. //如果该订单删除, 则将"取消订单时间"设置为该订单相关时间的最大值 //todo
  33. $recentTime = max($record['createtime'], $record['finishtime'],
  34. $record['paytime'], $record['sendtime'], $record['canceltime']);
  35. if ($record['deleted'] != 0){
  36. $record['deleted_at'] = $recentTime;
  37. } else {
  38. $record['deleted_at'] = 0;
  39. }
  40. //"updated_at"在旧表中没有对应字段, 取该订单相关时间的最大值 //todo
  41. $record['updated_at'] = $recentTime;
  42. //旧表中"openid"和微擎"mc_member"表的uid的对应
  43. //微信登录用户的openid和uid的对应关系, 借助数据表mc_mapping_fans
  44. //手机注册用户的openid和uid的对应关系, 借助会员迁移后生成的临时表
  45. if (preg_match('/^o.*/', $record['openid'])){ //以o开头的就是微信登录用户
  46. $uid = \Illuminate\Support\Facades\DB::table($this->memberMappingTable)->select('uid')
  47. ->where('openid','=',$record['openid'])->first();
  48. if($uid){
  49. $record['uid'] = $uid['uid'];
  50. } else {
  51. // echo "mc_mapping_fans表内缺少用户".$record['openid']."的uid"."\n";
  52. // exit;
  53. $record['uid'] = 0; //todo 调试用
  54. }
  55. // } else if (preg_match('/^u.*/', $record['openid'])){ //以u开头的就是手机注册用户
  56. // $uid = DB::table($this->newMappingMemberTable) //todo 等待"会员重构组"的结果
  57. // ->where('openid','=',$record['openid'])->first();
  58. // if($uid){
  59. // $record['uid'] = $uid;
  60. // } else {
  61. // echo 'new_mapping_fans表内缺少该用户的uid'."\n";
  62. // exit;
  63. // }
  64. } else if(preg_match('/^u.*/', $record['openid'])){
  65. $record['uid'] = 0; //todo 临时调试用, 等待"会员重构组"针对原来的自编openid用户的会员的mapping数据
  66. } else {
  67. // echo '获取 uid 时产生非预期结果, 请检查错误'."\n";
  68. // return;
  69. $record['uid'] = 0; //todo 临时调试用
  70. }
  71. $newOrderId = \Illuminate\Support\Facades\DB::table($this->orderTable)->insertGetId(
  72. [
  73. 'uniacid' => $record['uniacid'], //公众号ID
  74. 'member_id' => $record['uid'], //mc_member的uid
  75. 'order_sn' => $record['ordersn'], //订单号
  76. 'price' => $record['price'] * 100, //订单金额 (单位为"分")
  77. 'goods_price' => $record['goodsprice'] * 100, //商品金额 (单位为"分")
  78. 'status' => $record['status'], //订单状态(-1为订单取消,0为待支付,1为已付款,2为已发货,3为已完成)
  79. 'create_time' => $record['createtime'], //下单时间
  80. 'is_deleted' => $record['deleted'], //是否删除
  81. 'is_member_deleted' => $record['userdeleted'], //是否用户删除
  82. 'finish_time' => $record['finishtime'], //交易完成时间
  83. 'pay_time' => $record['paytime'], //支付时间
  84. 'send_time' => $record['sendtime'], //发货时间
  85. 'cancel_time' => $record['canceltime'], //取消订单时间
  86. 'created_at' => $record['createtime'], //框架自动记录时间
  87. 'updated_at' => $record['updated_at'], //框架自动记录时间
  88. 'deleted_at' => $record['deleted_at'], //框架自动记录时间
  89. 'dispatch_type_id' => $record['dispatchid'], //配送方式ID
  90. 'pay_type_id' => $record['paytype'], //支付方式ID (1为余额,2为在线,3为到付)
  91. ]
  92. );
  93. \Illuminate\Support\Facades\DB::table($this->orderMappingTable)->insert(
  94. [
  95. 'old_order_id' => $record['id'],
  96. 'new_order_id' => $newOrderId,
  97. 'old_openid' => $record['openid'],
  98. 'new_member_id' =>$record['uid']
  99. ]
  100. );
  101. }
  102. });
  103. }
  104. }