RegimentActive.php 18 KB

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