AdService.php 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397
  1. <?php
  2. namespace App\JsonRpc;
  3. use App\Model\Ad;
  4. use App\Model\AdPlace;
  5. use App\Model\AdSize;
  6. use Hyperf\RpcServer\Annotation\RpcService;
  7. use App\Tools\Result;
  8. use Hyperf\DbConnection\Db;
  9. use App\Model\WebsiteTemplate;
  10. #[RpcService(name: "AdService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
  11. class AdService implements AdServiceInterface
  12. {
  13. /**
  14. * @param array $data
  15. * @return string
  16. */
  17. public function createAd(array $data): array
  18. {
  19. $insertData = [
  20. 'name'=>$data['name']??'',
  21. 'pid'=>$data['pid']??0,
  22. 'areaid'=>$data['areaid']??0,
  23. 'amount'=>$data['amount']??0,//浏览数量
  24. 'introduce'=>$data['introduce']??'',
  25. 'hits'=>$data['hits']??0, //点击数量
  26. 'fromtime'=>$data['f_t_date'][0]??0,
  27. 'totime'=>$data['f_t_date'][1]??0,
  28. 'text_name'=>$data['text_name']??'',
  29. 'text_url'=>$data['text_url']??'',
  30. 'text_title'=>$data['text_title']??'',
  31. 'image_src'=>$data['image_src']??'',
  32. 'image_url'=>$data['image_url']??'',
  33. 'image_alt'=>$data['image_alt']??'',
  34. 'video_src'=>$data['video_src']??'',//视频
  35. 'video_url'=>$data['video_url']??'',
  36. 'video_auto'=>$data['video_auto'] ??0,
  37. 'video_loop'=>$data['video_loop'] ??0,
  38. 'status'=>$data['status']??2,
  39. 'remark'=>$data['remark']??'',
  40. ];
  41. $result = Ad::query()->insertGetId($insertData);
  42. if($result){
  43. return Result::success();
  44. }else{
  45. return Result::error("创建广告失败",500);
  46. }
  47. }
  48. /**
  49. * @param int $id
  50. * @return array
  51. */
  52. public function getAdInfo(int $id): array
  53. {
  54. $adInfo = Ad::query()->find($id);
  55. if (empty($adInfo)) {
  56. return Result::error("没有数据",0);
  57. }
  58. return Result::success($adInfo->toArray());
  59. }
  60. /**
  61. * @param array $data
  62. * @return array
  63. */
  64. public function getAdList(array $data): array
  65. {
  66. if(isset($data['pid'])){
  67. $where[] = ['ad.pid','=',$data['pid']];
  68. }
  69. $rep = Ad::where($where)
  70. ->leftJoin("ad_place","ad.pid","ad_place.id")
  71. ->leftJoin("website","website.id","ad_place.website_id")
  72. ->select("ad.*","ad_place.name as place_name","ad_place.typeid","website.website_name")
  73. ->limit($data['pageSize'])->orderBy("ad.id","desc")->offset(($data['page']-1)*$data['pageSize'])->get();
  74. $count = Ad::where($where)
  75. ->leftJoin("ad_place","ad.pid","ad_place.id")
  76. ->leftJoin("website","website.id","ad_place.website_id")
  77. ->count();
  78. $data = [
  79. 'rows'=>$rep->toArray(),
  80. 'count'=>$count
  81. ];
  82. if(empty($rep->toArray())){
  83. return Result::error("没有数据");
  84. }
  85. return Result::success($data);
  86. }
  87. public function updateAd(array $data): array
  88. {
  89. $where = [
  90. 'id'=>$data['id']
  91. ];
  92. $insertData = [
  93. 'name'=>$data['name']??'',
  94. 'pid'=>$data['pid']??0,
  95. 'areaid'=>$data['areaid']??0,
  96. 'amount'=>$data['amount']??0,//浏览数量
  97. 'introduce'=>$data['introduce']??'',
  98. 'hits'=>$data['hits']??0, //点击数量
  99. 'fromtime'=>$data['f_t_date'][0]??0,
  100. 'totime'=>$data['f_t_date'][1]??0,
  101. 'text_name'=>$data['text_name']??'',
  102. 'text_url'=>$data['text_url']??'',
  103. 'text_title'=>$data['text_title']??'',
  104. 'image_src'=>$data['image_src']??'',
  105. 'image_url'=>$data['image_url']??'',
  106. 'image_alt'=>$data['image_alt']??'',
  107. 'video_src'=>$data['video_src']??'',//视频
  108. 'video_url'=>$data['video_url']??'',
  109. 'video_auto'=>isset($data['video_auto']) && empty($data['video_auto'])?0:$data['video_auto'],
  110. 'video_loop'=>isset($data['video_loop']) && empty($data['video_loop'])?0:$data['video_loop'],
  111. 'status'=>$data['status']??2,
  112. 'remark'=>$data['remark']??'',
  113. ];
  114. $result = Ad::where($where)->update($insertData);
  115. if($result){
  116. return Result::success($result);
  117. }else{
  118. return Result::error("更新失败");
  119. }
  120. }
  121. public function delAd(array $data): array
  122. {
  123. $result = Ad::where($data)->delete();
  124. if(!$result){
  125. return Result::error("删除失败");
  126. }
  127. return Result::success($result);
  128. }
  129. /**
  130. * 广告位列表
  131. * @param array $data
  132. * @return array
  133. */
  134. public function getAdPlaceList(array $data): array
  135. {
  136. $where = [];
  137. if(isset($data['name']) && $data['name']){
  138. array_push($where,['ad_place.name','like','%'.$data['name'].'%']);
  139. }
  140. if(isset($data['website_id']) && $data['website_id']){
  141. array_push($where,['ad_place.website_id','=',$data['website_id']]);
  142. }
  143. $rep = AdPlace::where($where)
  144. ->leftJoin("ad_size","ad_place.ad_size_id","ad_size.id")
  145. ->leftJoin("website","website.id","ad_place.website_id")
  146. ->limit($data['pageSize'])
  147. ->orderBy("ad_place.updated_at","desc")
  148. ->offset(($data['page']-1)*$data['pageSize'])
  149. ->select("ad_place.*","ad_size.width","ad_size.height","website.website_name","website.website_column_id","website.website_column_arr_id")
  150. ->get();
  151. if($rep){
  152. foreach ($rep as $key=>$val){
  153. $rep[$key]['website_column_arr_id'] = json_decode($val['website_column_arr_id'],true);
  154. }
  155. }
  156. $count = AdPlace::where($where)->count();
  157. $reponse = [
  158. 'rows'=>$rep->toArray(),
  159. 'count'=>$count
  160. ];
  161. if(empty($rep->toArray())){
  162. return Result::error("没有数据");
  163. }
  164. return Result::success($reponse);
  165. }
  166. public function createAdPlace(array $data): array
  167. {
  168. unset($data['size']);
  169. $result = AdPlace::query()->insertGetId($data);
  170. if($result){
  171. return Result::success();
  172. }else{
  173. return Result::error("创建广告位失败",500);
  174. }
  175. }
  176. /**
  177. * @param array $data
  178. * @return array
  179. */
  180. public function updateAdPlace(array $data): array
  181. {
  182. $where = [
  183. 'ad_place.id'=>$data['id']
  184. ];
  185. // $website_id = intval($data['website_id']);
  186. // 原代码 leftJoin 条件使用错误,第三个参数应该是关联字段,这里修正为 "website.id" 关联 "ad_place.website_id"
  187. $web = AdPlace::where($where)
  188. ->leftJoin("website","website.id","ad_place.website_id")
  189. ->select("website.*","ad_place.name",'ad_place.ad_tag')
  190. ->first();
  191. if(empty($web)){
  192. return Result::error("广告位不存在");
  193. }
  194. // 自助建站广告位-广告位编辑同步模板数据-------fr----start
  195. $website_column_arr_id = json_decode($web['website_column_arr_id'],true);
  196. Db::beginTransaction();
  197. try{
  198. // 判断网站的广告位是否通过自助建站创建的广告位(通过网系包含2来判断)
  199. if(in_array(2,$website_column_arr_id)){
  200. $template_data = ['ad_tag'=>$web['ad_tag']];
  201. $template_data = array_merge($data,$template_data);
  202. $template_module = WebsiteTemplate::where('website_id',$template_data['website_id'])->first();
  203. $page_type = explode('_', $template_data['ad_tag']);
  204. // 页面类型
  205. $page = $page_type[1];
  206. $ad_places = [];
  207. // 模板数据及画布数据
  208. $oldtemplate_data = json_decode($template_module['template_data'],true);
  209. $canvas_data = json_decode($template_module['canvas_data'],true);
  210. if(array_key_exists( $page,$oldtemplate_data['ad'])){
  211. $ad_places = $oldtemplate_data['ad'][$page];
  212. }
  213. foreach($ad_places as $key=>$val){
  214. if($template_data['ad_tag'] == $val['ad_tag']){
  215. $ad_place[$key] = [
  216. 'width' => $val['width'],
  217. 'height' => $val['height'],
  218. 'name'=>$template_data['name'], //广告位名称可更改
  219. 'price'=>$template_data['price'], //广告位价格可更改
  220. 'introduce'=>$template_data['introduce'], //广告位介绍可更改
  221. 'website_id'=>$val['website_id'],
  222. 'thumb'=>$template_data['thumb'], //广告位默认图可更改
  223. 'typeid'=>$val['typeid'],
  224. 'ad_tag'=>$val['ad_tag'],
  225. ];
  226. $template_ad = $ad_place[$key];
  227. }else{
  228. $ad_place[$key] = $val;
  229. }
  230. }
  231. // 保存的模板中的广告位相关信息
  232. $oldtemplate_data['ad'][$page] = $ad_place;
  233. if(array_key_exists( $page,$oldtemplate_data['template'])){
  234. $ad_places_info = $oldtemplate_data['template'][$page];
  235. }
  236. foreach($ad_places_info as $key=>$val){
  237. $ad_info[$key] = $val;
  238. if(array_key_exists('ad',$val) && $val['ad']['ad_tag'] == $template_data['ad_tag']){
  239. $ad_info[$key]['ad'] = $template_ad;
  240. $num = $key;
  241. }
  242. }
  243. foreach($canvas_data['template'][$page] as $key=>$val){
  244. $canvas_ad[$key] = $val;
  245. if(array_key_exists('ad',$val['content']) && $key == $num){
  246. // $canvas_ad[$key]['ad'] = $template_ad;
  247. $canvas_ad[$num]['content']['ad'] = [
  248. 'width' => $val['content']['ad']['width'],
  249. 'height' => $val['content']['ad']['height'],
  250. 'name'=>$template_data['name'], //广告位名称可更改
  251. 'price'=>$template_data['price'], //广告位价格可更改
  252. 'introduce'=>$template_data['introduce'], //广告位介绍可更改
  253. 'website_id'=>$val['content']['ad']['website_id'],
  254. 'thumb'=>$val['content']['ad']['thumb'], //广告位默认图可更改
  255. 'typeid'=>$val['content']['ad']['typeid'],
  256. 'ad_tag'=>$val['content']['ad']['ad_tag'],
  257. ];
  258. }
  259. }
  260. // Db::rollBack();
  261. // }
  262. // return Result::success($canvas_ad);
  263. $oldtemplate_data['template'][$page] = $ad_info; //模板广告位相关信息已修改
  264. if($page_type[1] == 'top'){
  265. $canvas_data['topAd'] = $template_ad;
  266. }else{
  267. // $canvas_ad = $ad_info;
  268. $canvas_data['template'][$page] = $canvas_ad;
  269. }
  270. $template_module['canvas_data'] = json_encode($canvas_data,JSON_UNESCAPED_UNICODE);
  271. $template_module['template_data'] = json_encode($oldtemplate_data,JSON_UNESCAPED_UNICODE);
  272. $template_result = WebsiteTemplate::where('website_id',$template_data['website_id'])->update([
  273. 'canvas_data'=>$template_module['canvas_data'],
  274. 'template_data'=>$template_module['template_data'],
  275. ]);
  276. if(!$template_result){
  277. Db::rollBack();
  278. return Result::error('同步模板失败!');
  279. }
  280. }
  281. // return Result::success($website_column_arr_id);
  282. $Insdata = [
  283. 'website_id'=>$data['website_id']??'',
  284. 'typeid'=>$data['typeid']??1,
  285. 'status'=>$data['status']??2,
  286. 'name'=>$data['name']??'',
  287. 'thumb'=>$data['thumb']??'',
  288. 'introduce'=>$data['introduce']??'',
  289. 'code'=>$data['code']??'',
  290. 'price'=>$data['price']??0,
  291. 'ad_size_id'=>$data['ad_size_id']??0,
  292. 'ad_url'=>$data['ad_url']??'',
  293. 'ad_tag'=>$data['ad_tag']??'',
  294. ];
  295. $result = AdPlace::where($where)->update($Insdata);
  296. if(!$result){
  297. Db::rollBack();
  298. return Result::error("更新失败");
  299. }
  300. Db::commit();
  301. return Result::success($result);
  302. }catch (\Exception $e) {
  303. Db::rollBack();
  304. return Result::error($e->getMessage());
  305. }
  306. // 自助建站广告位-广告位编辑同步模板数据-------fr----end
  307. }
  308. /**
  309. * 删除广告位
  310. * @param array $data
  311. * @return array
  312. */
  313. public function delAdPlace(array $data): array
  314. {
  315. $adList = Ad::where(['pid'=>$data['id']])->get();
  316. if($adList->toArray()){
  317. return Result::error("广告位里面还有广告,不能删除广告位");
  318. }
  319. $result = AdPlace::where($data)->delete();
  320. if(!$result){
  321. return Result::error("删除失败");
  322. }
  323. return Result::success($result);
  324. }
  325. /**
  326. * @param int $id
  327. * @return array
  328. */
  329. public function getAdPlaceInfo(int $id): array
  330. {
  331. $adInfo = AdPlace::query()->find($id);
  332. if (empty($adInfo)) {
  333. return Result::error("没有数据",0);
  334. }
  335. return Result::success($adInfo->toArray());
  336. }
  337. /**
  338. * @param array $data
  339. * @return array
  340. */
  341. public function addTwinAdPlace(array $data): array
  342. {
  343. Db::beginTransaction();
  344. try {
  345. //根据传过来的website_id查询网站下的广告位 ad_tag字段组合成一个数组
  346. $adTagList = AdPlace::where(['website_id'=>$data['adPlaceList'][0]['website_id']])->pluck('ad_tag')->toArray();
  347. //循环传过来的adPlaceList数组取参数的ad_tag字段
  348. $adTagNewList = array_column($data['adPlaceList'],'ad_tag');
  349. //假设$adTagNewList=[1,2,3],$adTagList=[1,2,4,5] 我要取到$adTagList 里面的4,5
  350. $adTagDiffList = array_diff($adTagList,$adTagNewList);
  351. //删除AdPlace模型里面的$adTagDiffList 里面的广告位
  352. if($adTagDiffList){
  353. AdPlace::whereIn('ad_tag',$adTagDiffList)->delete();
  354. }
  355. if(isset($data['adPlaceList']) && $data['adPlaceList']){
  356. foreach ($data['adPlaceList'] as $key=>$val){
  357. $adSizeInfo = AdSize::firstOrCreate(['width'=>$val['width'],'height'=>$val['height']]);
  358. $adPlaceInfo = AdPlace::updateOrCreate(
  359. [ 'ad_tag'=>$val['ad_tag'],'website_id'=>$val['website_id']],
  360. [
  361. 'website_id'=>$val['website_id'],
  362. 'typeid'=>$val['typeid'],
  363. 'status'=>1,
  364. 'name'=>$val['name']??'',
  365. 'thumb'=>$val['thumb']??'',
  366. 'code'=>$val['code']??'',
  367. 'ad_size_id'=>$adSizeInfo->id,
  368. 'ad_tag'=>$val['ad_tag']??'',
  369. 'introduce'=>$val['introduce']??'',
  370. 'price'=>$val['price']??0,
  371. ]
  372. );
  373. }
  374. }
  375. Db::commit();
  376. return Result::success([]);
  377. }catch (\Exception $e){
  378. Db::rollBack();
  379. return Result::error("创建广告位失败".$e->getMessage(),0);
  380. }
  381. }
  382. }