RegimentActive.php 18 KB

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