RegimentActive.php 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329
  1. <?php namespace App\Http\Controllers\Admin;
  2. use App\Http\Requests\Admin\RegimentActive as Request;
  3. use App\Models\RegimentActive as Model;
  4. use App\Models\Regiment;
  5. use App\Models\Product as Product;
  6. use Illuminate\Support\Facades\DB;
  7. /**
  8. * 拼团活动
  9. *
  10. * @author jun
  11. *
  12. */
  13. class RegimentActive extends Auth{
  14. protected function _initialize(){
  15. parent::_initialize();
  16. $this->assign('breadcrumb1','拼团活动');
  17. $this->assign('breadcrumb2','活动列表');
  18. }
  19. /**
  20. * 列表页
  21. *
  22. * */
  23. public function index(Model $Model){
  24. // 接收参数
  25. $code = request('code','');
  26. $name = request('name','');
  27. $productName = request('product_name','');
  28. $status = request('status','');
  29. $start_time = request('start_time','');
  30. $end_time = request('end_time','');
  31. // 查询条件
  32. $map = [];
  33. // 组合条件
  34. if( $name ) $map[] = ['regiment_active.name','=',$name];
  35. if( $code ){
  36. $id = $Model->codeToId($code);
  37. $map[] = ['regiment_active.id','=',$id];
  38. }
  39. if( $productName ) $map[] = ['product.name','=',$productName];
  40. if( $status ) $map[] = ['regiment_active.status','=',$status];
  41. if( $start_time ) {
  42. $start_time = strtotime($start_time);
  43. $map[] = ['regiment_active.start_time','>=',$start_time];
  44. }
  45. if( $end_time ) {
  46. $end_time = strtotime($end_time);
  47. $map[] = ['regiment_active.end_time','<=',$end_time];
  48. }
  49. // 查询数据
  50. $list = $Model->query()
  51. ->join('product','product.id','=','regiment_active.product_id')
  52. ->where($map)
  53. ->select(['regiment_active.*','product.name as product_name'])
  54. ->orderByDesc('regiment_active.id')
  55. ->paginate(config('page_num',10));
  56. // 循环处理数据
  57. foreach ($list as &$value) {
  58. $value['code'] = $Model->idToCode($value['id']);
  59. }
  60. // 分配数据
  61. $this->assign('empty', '<tr><td colspan="20">~~暂无数据</td></tr>');
  62. $this->assign('list',$list);
  63. // 加载模板
  64. return $this->fetch();
  65. }
  66. /**
  67. * 添加
  68. *
  69. * */
  70. public function add(Request $request, Model $Model, Product $Product){
  71. if( request()->isMethod('post') ){
  72. // 验证参数
  73. $request->scene('add')->validate();
  74. // 接收数据
  75. $product_code = request('product_code','');
  76. $data['product_id'] = $Product->codeToId($product_code);
  77. if (!$data['product_id']) return json_send(['code'=>'error','msg'=>'产品不存在']);
  78. $data['regiment_price'] = request('regiment_price',0);
  79. $data['quota'] = request('quota','');
  80. $data['name'] = request('name','');
  81. $data['number'] = request('number',0);
  82. $expiration_day = request('expiration_day',0);
  83. $expiration_hours = request('expiration_hours',0);
  84. //$data['expiration'] = $expiration_day * 24 + $expiration_hours;
  85. $data['expiration'] = $expiration_hours;
  86. $data['start_time'] = request('start_time','');
  87. $data['end_time'] = request('end_time','');
  88. $data['start_time'] = $data['start_time'] ? strtotime($data['start_time']) : 0;
  89. $data['end_time'] = $data['end_time'] ? strtotime($data['end_time']) : 0;
  90. $data['participation_number'] = request('participation_number',0);
  91. $data['open_people'] = request('open_people',0);
  92. $data['partake_people'] = request('partake_people',0);
  93. $data['exceed_people'] = request('exceed_people',0);
  94. $data['automatic'] = request('automatic',0);
  95. $data['virtually'] = request('virtually',0);
  96. $data['status'] = 1;
  97. // 核对产品
  98. $product_res = $Model::query()->where([['status','=', 1],['product_id','=', $data['product_id']],['end_time','>=', time()]])->first();
  99. // 提示
  100. if ($product_res) return json_send(['code'=>'error','msg'=>'该产品正在参加拼团活动']);
  101. //核对产品价格
  102. $productInfo = $Product->getOne($data['product_id']);
  103. if ($productInfo['price'] < $data['regiment_price']) return json_send(['code'=>'error','msg'=>'拼团价格不能大于产品价格']);
  104. // 写入数据表
  105. $id = $Model->add($data);
  106. // 如果操作失败
  107. if( !$id ) return json_send(['code'=>'error','msg'=>'新增失败']);
  108. //商户开团
  109. if ($data['automatic'] == 1 ) {
  110. // 开团信息
  111. $regimentData = [
  112. 'custom_uid' => 0,
  113. 'active_id' => $id,
  114. 'product_id' => $data['product_id'],
  115. 'status' => 0,
  116. 'start_time' => $data['start_time'],
  117. 'end_time' => $data['start_time'] + $data['expiration']*60*60,
  118. 'update_time' => time(),
  119. 'insert_time' => time(),
  120. ];
  121. // 开团
  122. $regimentRes = Regiment::query()->insert($regimentData);
  123. // 开团结果
  124. if (!$regimentRes) return json_send(['code'=>'error','msg'=>'商户开团失败']);
  125. }
  126. // 记录行为
  127. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,1,[],$data);
  128. // 告知结果
  129. return json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
  130. }
  131. // 标签列表
  132. $tagList = [];
  133. $cityList = [];
  134. // 分配数据
  135. $this->assign('cityList',$cityList);
  136. $this->assign('tagList',$tagList);
  137. $this->assign('crumbs','新增');
  138. // 加载模板
  139. return $this->fetch();
  140. }
  141. /**
  142. * 修改
  143. *
  144. * */
  145. public function edit(Request $request,Model $Model,Product $Product,Regiment $Regiment){
  146. // 接收参数
  147. $id = request('id',0);
  148. // 查询用户
  149. $oldData = $Model->where(['id'=>$id])->first()->toArray();
  150. // 修改
  151. if(request()->isMethod('post')) {
  152. // 验证参数
  153. $request->scene('edit')->validate();
  154. // 接收数据
  155. $product_code = request('product_code','');
  156. $data['product_id'] = $Product->codeToId($product_code);
  157. if (!$data['product_id']) return json_send(['code'=>'error','msg'=>'产品不存在']);
  158. $data['regiment_price'] = request('regiment_price',0);
  159. $data['quota'] = request('quota','');
  160. $data['name'] = request('name','');
  161. $data['number'] = request('number',0);
  162. $expiration_day = request('expiration_day',0);
  163. $expiration_hours = request('expiration_hours',0);
  164. $data['expiration'] = $expiration_day * 24 + $expiration_hours;
  165. $data['start_time'] = request('start_time','');
  166. $data['end_time'] = request('end_time','');
  167. $data['start_time'] = $data['start_time'] ? strtotime($data['start_time']) : 0;
  168. $data['end_time'] = $data['end_time'] ? strtotime($data['end_time']) : 0;
  169. $data['participation_number'] = request('participation_number',0);
  170. $data['open_people'] = request('open_people',0);
  171. $data['partake_people'] = request('partake_people',0);
  172. $data['exceed_people'] = request('exceed_people',0);
  173. $data['automatic'] = request('automatic',0);
  174. $data['virtually'] = request('virtually',0);
  175. $data['status'] = 1;
  176. // 核对产品
  177. $product_res = $Model::query()->where([['id','><', $id],['status','=', 1],['product_id','=', $data['product_id']],['end_time','>=', time()]])->first();
  178. // 提示
  179. if ($product_res) return json_send(['code'=>'error','msg'=>'该产品正在参加拼团活动']);
  180. //核对产品价格
  181. $productInfo = $Product->getOne($data['product_id']);
  182. if ($productInfo['price'] < $data['regiment_price']) return json_send(['code'=>'error','msg'=>'拼团价格不能大于产品价格']);
  183. // 写入数据表
  184. $id = $Model->edit($id,$data);
  185. // 如果操作失败
  186. if( !$id ) return json_send(['code'=>'error','msg'=>'新增失败']);
  187. //商户开团
  188. if ($data['automatic'] == 1 ) {
  189. // 开团信息
  190. $regimentData = [
  191. 'custom_uid' => 0,
  192. 'active_id' => $id,
  193. 'product_id' => $data['product_id'],
  194. 'status' => 1,
  195. 'start_time' => $data['start_time'],
  196. 'end_time' => $data['start_time'] + $data['expiration']*60*60,
  197. 'update_time' => time(),
  198. 'insert_time' => time(),
  199. ];
  200. //查询开团信息
  201. $regimentIfo = Regiment::query()->where([['active_id','=',$id]])->first();
  202. if (!$regimentIfo){
  203. // 开团
  204. $regimentRes = Regiment::query()->insert($regimentData);
  205. // 开团结果
  206. if (!$regimentRes) return json_send(['code'=>'error','msg'=>'商户开团失败']);
  207. }
  208. }
  209. // 记录行为
  210. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,$oldData,$data);
  211. // 告知结果
  212. return json_send(['code'=>'success','msg'=>'修改成功','action'=>'edit']);
  213. }
  214. // 错误告知
  215. if( !$oldData ) return $this->error('查无数据');
  216. // 返回结果
  217. $oldData['product_code'] = $Product->idToCode($oldData['product_id']);
  218. $this->assign('oldData',$oldData);
  219. $this->assign('crumbs','修改');
  220. // 加载模板
  221. return $this->fetch();
  222. }
  223. /**
  224. * 修改状态
  225. *
  226. * */
  227. public function set_status(Request $request,Model $Model){
  228. // 验证参数
  229. $request->scene('set_status')->validate();
  230. // 设置状态
  231. $id = request('id',0);
  232. $status = request('status',0);
  233. // 查询用户
  234. $oldData = $Model->where(['id'=>$id])->first();
  235. // 如果用户不存在
  236. if( !$oldData ) return json_send(['code'=>'error','msg'=>'数据不存在']);
  237. // 执行修改
  238. $result = $Model->edit($id,['status'=>$status]);
  239. // 提示新增失败
  240. if( !$result ) return json_send(['code'=>'error','msg'=>'设置失败']);
  241. // 记录行为
  242. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,$oldData,['status'=>$status]);
  243. // 告知结果
  244. return json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
  245. }
  246. /**
  247. * 复制
  248. *
  249. * */
  250. public function copy(Request $request,Model $Model,Product $Product){
  251. // 接收参数
  252. $id = request('id',0);
  253. // 查询用户
  254. $oldData = $Model->where(['id'=>$id])->first()->toArray();
  255. // 修改
  256. if(request()->isMethod('post')) {
  257. // 验证参数
  258. $request->scene('edit')->validate();
  259. // 接收数据
  260. $product_code = request('product_code','');
  261. $data['product_id'] = $Product->codeToId($product_code);
  262. if (!$data['product_id']) return json_send(['code'=>'error','msg'=>'产品不存在']);
  263. $data['regiment_price'] = request('regiment_price',0);
  264. $data['quota'] = request('quota','');
  265. $data['name'] = request('name','');
  266. $data['number'] = request('number',0);
  267. $expiration_day = request('expiration_day',0);
  268. $expiration_hours = request('expiration_hours',0);
  269. $data['expiration'] = $expiration_day * 24 + $expiration_hours;
  270. $data['start_time'] = request('start_time','');
  271. $data['end_time'] = request('end_time','');
  272. $data['start_time'] = $data['start_time'] ? strtotime($data['start_time']) : 0;
  273. $data['end_time'] = $data['end_time'] ? strtotime($data['end_time']) : 0;
  274. $data['participation_number'] = request('participation_number',0);
  275. $data['open_people'] = request('open_people',0);
  276. $data['partake_people'] = request('partake_people',0);
  277. $data['exceed_people'] = request('exceed_people',0);
  278. $data['automatic'] = request('automatic',0);
  279. $data['virtually'] = request('virtually',0);
  280. // 核对产品
  281. $product_res = $Model::query()->where([['status','=', 1],['product_id','=', $data['product_id']],['end_time','>=', time()]])->first();
  282. // 提示
  283. if ($product_res) return json_send(['code'=>'error','msg'=>'该产品正在参加拼团活动']);
  284. // 写入数据表
  285. $result = $Model->add($data);
  286. // 如果操作失败
  287. if( !$result ) return json_send(['code'=>'error','msg'=>'复制失败']);
  288. //商户开团
  289. if ($data['automatic'] == 1 ) {
  290. // 开团信息
  291. $regimentData = [
  292. 'custom_uid' => 0,
  293. 'active_id' => $id,
  294. 'product_id' => $data['product_id'],
  295. 'status' => 1,
  296. 'start_time' => $data['start_time'],
  297. 'end_time' => $data['start_time'] + $data['expiration']*60*60,
  298. 'update_time' => time(),
  299. 'insert_time' => time(),
  300. ];
  301. // 开团
  302. $regimentRes = Regiment::query()->insert($regimentData);
  303. // 开团结果
  304. if (!$regimentRes) return json_send(['code'=>'error','msg'=>'商户开团失败']);
  305. }
  306. // 记录行为
  307. $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,$oldData,$data);
  308. // 告知结果
  309. return json_send(['code'=>'success','msg'=>'复制成功','action'=>'edit']);
  310. }
  311. // 错误告知
  312. if( !$oldData ) return $this->error('查无数据');
  313. // 返回结果
  314. $oldData['product_code'] = $Product->idToCode($oldData['product_id']);
  315. $this->assign('oldData',$oldData);
  316. $this->assign('crumbs','修改');
  317. // 加载模板
  318. return $this->fetch();
  319. }
  320. }