Many.php 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
  1. <?php
  2. /**
  3. * @author: xaboy<365615158@qq.com>
  4. * @day: 2017/11/11
  5. */
  6. namespace app\models\many;
  7. use app\models\user\User;
  8. use app\models\user\UserBill;
  9. use crmeb\traits\ModelTrait;
  10. use crmeb\basic\BaseModel;
  11. use think\model\concern\SoftDelete;
  12. /**
  13. * Class StoreCategory
  14. * @package app\admin\model\store
  15. */
  16. class Many extends BaseModel
  17. {
  18. /**
  19. * 数据表主键
  20. * @var string
  21. */
  22. protected $pk = 'id';
  23. /**
  24. * 模型名称
  25. * @var string
  26. */
  27. protected $name = 'many';
  28. use ModelTrait;
  29. use SoftDelete;
  30. protected $autoWriteTimestamp = true;
  31. public static function list($where)
  32. {
  33. $model = self::field('*')->order('sort DESC,id DESC');
  34. if ($where['name'])$model->where('name' , 'like', '%'.$where['name'],'%');
  35. $data['count'] = $model->count();
  36. if ($where['page'] && $where['limit']){
  37. $model->page($where['page'], $where['limit']);
  38. }else{
  39. $model->page(20, 1);
  40. }
  41. $list = $model->select()->toArray();
  42. foreach ($list as &$item){
  43. $item['add_time'] = date('Y-m-d H:i:s',$item['add_time']);
  44. $item['end_time'] = date('Y-m-d H:i:s',$item['end_time']);
  45. }
  46. $data['data'] = $list;
  47. return $data;
  48. }
  49. /**
  50. * 众筹失败
  51. * @return void
  52. * @throws \think\db\exception\DataNotFoundException
  53. * @throws \think\db\exception\DbException
  54. * @throws \think\db\exception\ModelNotFoundException
  55. */
  56. public static function fail()
  57. {
  58. $many = self::where('end_time', '<', time())->where('status', '=', 1)->select();//找到结束为完成的场次
  59. if ($many) {
  60. foreach ($many as $item) {
  61. $stage = [$item['stage'],$item['stage'] - 3];//指定期数
  62. $stages = [$item['stage'] - 2, $item['stage'] - 1];//指定期数
  63. $many_order = ManyOrder::where('many_id', $item['id'])->where('status', '=', 0)->where('stage', 'in', $stage)->select();// 找到这期和三期前订单
  64. $order = ManyOrder::where('many_id', '=', $item['id'])->where('status', '=', 0)->where('stage', 'in', $stages)->select()->toArray();// 找到这期和三期前中间两期订单
  65. if ($many_order) {
  66. foreach ($many_order as $value) {
  67. if ($value['frozen'] > 0){
  68. $user = User::where('uid', $value['uid'])->find();
  69. $user['white_integral'] += $value['frozen'];// 返还
  70. $user->save();
  71. UserBill::income('种树失败返还肥料', $value['uid'], 'white_integral', 'sbfh_white_integral', $value['frozen'], 0, $user['white_integral'], '种树失败返还' . $item['name'] . '-第' . $value['stage'] . '期肥料');
  72. }else{
  73. $user = User::where('uid', $value['uid'])->find();
  74. $user['white_integral'] += $value['price'] * 1.01;// 返还
  75. $user->save();
  76. UserBill::income('种树失败返还肥料', $value['uid'], 'white_integral', 'sbfh_white_integral', $value['price'] * 1.01, 0, $user['white_integral'], '种树失败返还' . $item['name'] . '-第' . $value['stage'] . '期肥料');
  77. }
  78. }
  79. if ($order) {
  80. foreach ($order as $value) {
  81. $user = User::where('uid', $value['uid'])->find();
  82. $user['integral'] += $value['frozen'];// 返还百分之三十的阳光
  83. $user->save();
  84. UserBill::income('种树失败返还阳光', $value['uid'], 'integral', 'sbfh_integral', $value['price'] * 0.3, 0, $user['integral'], '种树失败返还' . $item['name'] . '-第' . $value['stage'] . '期阳光');
  85. }
  86. }
  87. ManyOrder::where('many_id', '=', $item['id'])->where('stage', 'in', [$item['stage'] - 3, $item['stage'], $item['stage'] - 2, $item['stage'] - 1])->update(['status' => 2]);
  88. ManyDiscipline::create(['many_id' => $item['id'], 'stage' => $item['stage'], 'status' => 2]);
  89. Many::where('id', $item['id'])->update(['status' => 0, 'suc' => 2]);
  90. }
  91. }
  92. }
  93. }
  94. /**
  95. * 自动增加额度
  96. * @return void
  97. * @throws \think\db\exception\DataNotFoundException
  98. * @throws \think\db\exception\DbException
  99. * @throws \think\db\exception\ModelNotFoundException
  100. */
  101. public static function second()
  102. {
  103. $many = self::where('second', '>', 0)->where('increase', '>', 0)->where('status', 1)->lock(true)->select();
  104. if ($many){
  105. foreach ($many as &$item) {
  106. if ($item['add_time']-600 < time()){
  107. if ($item['increase_time']+$item['second'] < time()){
  108. $number = $item['number'];
  109. $item['number'] += $item['increase'];
  110. if ($item['number'] >= $item['money']){
  111. $item['number'] = $item['money'];
  112. self::where('id', $item['id'])->update(['number' => $item['number'], 'increase_time' => time(), 'suc' => 1, 'status' => 0]);
  113. ManyOrder::order_return($item);
  114. ManyDiscipline::create(['many_id' => $item['id'], 'stage' => $item['stage'], 'status' => 1]);// 成功记录
  115. if ($item['stage'] >= 4){
  116. // 期数如果大于等于4
  117. $stage = $item['stage'] - 3;
  118. ManyOrder::where('many_id', $item['id'])->where('stage', $stage)->update(['is_return' => 1]);// 成功后添加返还状态
  119. }
  120. }else{
  121. self::where('id', $item['id'])->update(['number' => $item['number'], 'increase_time' => time()]);
  122. }
  123. }
  124. }
  125. }
  126. }
  127. }
  128. /**
  129. * 自动下一期
  130. * @return void
  131. * @throws \think\db\exception\DataNotFoundException
  132. * @throws \think\db\exception\DbException
  133. * @throws \think\db\exception\ModelNotFoundException
  134. */
  135. public static function next_period()
  136. {
  137. $many = self::where([['status','=', 0], ['suc', '=', 1]])->select();
  138. if ($many)
  139. {
  140. foreach ($many as $item)
  141. {
  142. $item['add_time'] += 86400*2;
  143. $item['end_time'] += 86400*2;
  144. $item['money'] = intval($item['money'] * 1.3);
  145. $item['number'] = 0;
  146. $item['stage'] += 1;
  147. $item['status'] = 1;
  148. $item['suc'] = 0;
  149. self::where('id', $item['id'])->update([
  150. 'add_time' => $item['add_time'],
  151. 'end_time' => $item['end_time'],
  152. 'money' => $item['money'],
  153. 'number' => $item['number'],
  154. 'stage' => $item['stage'],
  155. 'status' => $item['status'],
  156. 'suc' => $item['suc'],
  157. ]);
  158. }
  159. }
  160. }
  161. }