pitcher_panel.py 101 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527
  1. from model.DateUtils import DateUtils
  2. from model.DataBaseUtils import *
  3. from model.log import logger
  4. from model.CommonUtils import *
  5. from model import UserAuthUtils
  6. from model.UserAuthUtils import super_auth
  7. du = DateUtils()
  8. from data_manage.operate import get_pitcher
  9. log = logger()
  10. """根据公众号获取投手"""
  11. # def get_channel_belong_pitcher(channel):
  12. #
  13. # sql = f"select pitcher,channel from dw_daily_channel_cost where dt='{du.get_n_days(-1)}' and pitcher!='' and channel!=''"
  14. # data=ck.execute(('sql'))
  15. # di={}
  16. # for i in data:
  17. # di[i[1]]=i[0]
  18. # return di.get(channel,'')
  19. """根据名字获取其归属的公众号"""
  20. def get_pitcher_panel_channel(pitcher, channel, start, end, page, page_size, order_by, order):
  21. db = MysqlUtils()
  22. op1 = f" and pitcher='{pitcher}'" if pitcher else ''
  23. op2 = f" and channel='{channel}'" if channel else ''
  24. sql = f"""select channel,stage,platform,book,
  25. dt as date,cost,first_order_amount,
  26. if(cost=0,0,first_order_amount/cost) first_roi,
  27. first_order_user,first_order_count,
  28. round(if(first_order_user=0,0,cost/first_order_user),2) first_per_cost,
  29. view_count,click_count,follow_user,
  30. round(if(click_count=0,0,follow_user/click_count),4) follow_rate,
  31. round(if(follow_user=0,0,cost/follow_user),2) follow_per_cost,
  32. total_cost,
  33. round(if(total_cost=0,0,total_amount/total_cost),4) back_rate
  34. from dw_channel_daily where dt>='{start}' and dt<='{end}' {op1} {op2}
  35. order by {order_by} {order}
  36. """
  37. return getLimitData(db.quchen_text, sql, page, page_size)
  38. def get_pitcher_panel_daily(pitcher, start, end, page, page_size, order_by, order):
  39. db = MysqlUtils()
  40. op1 = f" and pitcher='{pitcher}'" if pitcher else ''
  41. op2 = f" and dt>='{start}' " if start else ''
  42. op3 = f" and dt<='{end}' " if end else ''
  43. op4 = f" order by {order_by} {order}" if order_by and order else ''
  44. sql = f"""
  45. select dt date,
  46. pitcher,cost,
  47. first_order_amount,
  48. reg_amount,
  49. round(if(cost=0,0,first_order_amount/cost),4) first_roi,
  50. amount order_amount,
  51. round(if(cost=0,0,reg_amount/cost),4) today_roi,
  52. reg_amount-cost profit
  53. from dw_pitcher_trend where 1=1 {op1} {op2} {op3} {op4}
  54. """
  55. print(sql)
  56. sumSql = f"""
  57. select '总计' date,sum(cost) cost,
  58. sum(first_order_amount) first_order_amount,sum(reg_amount) reg_amount,
  59. round(if(sum(cost)=0,0,sum(first_order_amount)/sum(cost)),4) first_roi,
  60. sum(order_amount) order_amount,
  61. round(if(sum(cost)=0,0,sum(reg_amount)/sum(cost)),4) today_roi,
  62. sum(profit) profit
  63. from ({sql}) b """
  64. print(sumSql)
  65. return getLimitSumData(db.dm, sql, sumSql, page, page_size)
  66. def get_pitcher_panel_overview(pitcher):
  67. db = MysqlUtils()
  68. op1 = f" and pitcher='{pitcher}'" if pitcher else ''
  69. sql = f"""select pitcher,
  70. total_cost cost,
  71. total_amount amount,
  72. if(total_cost=0,0,total_amount/total_cost) roi,
  73. channel_count,
  74. on_channel_count,
  75. off_channel_count,
  76. this_month_cost this_month_cost,
  77. this_month_amount this_month_amount,
  78. this_month_roi this_month_roi,
  79. last_month_cost last_month_cost,
  80. last_month_amount last_month_amount,
  81. last_month_roi last_month_roi,
  82. last_month_far_amount last_month_far_amount,
  83. follow_user,
  84. last_month_far_roi last_month_far_roi
  85. from dm_pitcher_daily_overview a
  86. left join (
  87. select sum(cost) total_cost,sum(reg_amount) total_amount,pitcher pitcher2 from dw_pitcher_trend group by pitcher) b on pitcher=pitcher2
  88. where 1=1 {op1}
  89. """
  90. print(sql)
  91. return db.dm.getData_json(sql)
  92. def get_agent_list(pitcher):
  93. db = MysqlUtils()
  94. op = f" and pitcher ='{pitcher}' " if pitcher else ''
  95. sql=f"""
  96. select distinct agent_id, agent_name from dw_channel where agent_id is not null and agent_id!= '' {op}
  97. """
  98. return db.dm.getData_json(sql)
  99. def get_channel_overview(user_id, channel, pitcher, stage, book,agent_id, start, end, page, page_size, order_by, order):
  100. db = MysqlUtils()
  101. if user_id in super_auth():
  102. op = ''
  103. else:
  104. if len(UserAuthUtils.get_auth_channel(user_id)) == 0:
  105. return None, None, None
  106. elif len(UserAuthUtils.get_auth_channel(user_id)) == 1:
  107. op = f" and channel = '{UserAuthUtils.get_auth_channel(user_id)[0]}'"
  108. else:
  109. op = f" and channel in {str(UserAuthUtils.get_auth_channel(user_id))}"
  110. op1 = f" and pitcher ='{pitcher}' " if pitcher else ''
  111. op2 = f" and a.channel='{channel}'" if channel else ''
  112. op3 = f" and a.dt>='{start}' " if start else ''
  113. op4 = f" and a.dt<='{end}' " if end else ''
  114. op5 = f" order by {order_by} {order}" if order_by and order else ''
  115. op6 = f" and stage='{stage}'" if stage else ''
  116. op7 = f" and book='{book}'" if book else ''
  117. op8 = f" and agent_id = '{agent_id}'" if agent_id else ''
  118. sql = f"""select a.channel,a.dt date,agent_name,reg_num,
  119. round(if(reg_num=0,0,cost/reg_num),2) reg_per_cost,
  120. create_user_num,
  121. hundred_user_num, -- 单日付费100+用户数
  122. round(cost/hundred_user_num,2) hundred_user_num_cost , -- 单日付费100+用户付费成本
  123. round(da7/cost,4) roi7, -- 最近7日首日ROI
  124. round(if(create_user_num=0,0,cost/create_user_num),2) create_user_per_cost,
  125. view_count,click_count,
  126. round(if(view_count=0,0,click_count/view_count),4) click_rate,
  127. follow_user,
  128. round(if(click_count=0,0,follow_user/click_count),4) follow_rate,
  129. round(if(follow_user=0,0,cost/follow_user),2) follow_per_cost,
  130. round(if(click_count=0,0,first_order_count/click_count),4) order_rate,
  131. round(if(first_order_user=0,0,cost/first_order_user),2) order_per_cost,
  132. cost,da7,
  133. first_order_count,first_order_user,
  134. first_order_amount,
  135. order_count,order_user,
  136. order_amount,
  137. game_user_sum,
  138. seven_stay_rate,
  139. fifteen_stay_rate,
  140. thirty_stay_rate,
  141. fortyfive_stay_rate,
  142. sixty_stay_rate,
  143. third_stay_rate,
  144. second_stay_rate,
  145. today_active_user_rate,
  146. order_amount-first_order_amount old_order_amount,
  147. round(if(first_order_user=0,0,first_order_amount/first_order_user),2) first_amount_per_user,
  148. round(if(follow_user=0,0,first_order_amount/follow_user),2) amount_per_follow,
  149. round(if(reg_order_user=0,0,cost/reg_order_user),2) first_cost_per_user,
  150. round(if(follow_user=0,0,first_order_user/follow_user),4) new_user_order_rate,
  151. reg_order_amount reg_user_amount,
  152. round(if(cost=0,0,first_order_amount/cost),4) day_roi,
  153. round(reg_order_amount/cost,4) roi,
  154. reg_order_user_again,
  155. reg_order_user,
  156. round(if(reg_order_user=0,0,reg_order_user_again/reg_order_user),4) old_user_once_order_rate,
  157. pitcher,stage,book,type,
  158. round(cost/first_order_user,2) first_order_user_per_cost,
  159. round(order_amount/order_user,2) user_per_amount,
  160. round(follow_user/click_count,4) click_follow_rate,
  161. round(reg_order_user/follow_user,4) follow_order_rate
  162. from dw_channel a
  163. left join dw_channel_amount_daily b on a.dt=b.dt and a.channel=b.channel
  164. where 1=1 {op} {op1} {op2} {op3} {op4} {op6} {op7} {op8} {op5} """
  165. sumsql = f"""select '总计' date,
  166. sum(reg_num) reg_num,
  167. max(game_user_sum) game_user_sum,
  168. sum(hundred_user_num) hundred_user_num, -- 单日付费100+用户数
  169. round(sum(cost)/sum(hundred_user_num),2) hundred_user_num_cost , -- 单日付费100+用户付费成本
  170. round(sum(da7)/sum(cost),4) roi7, -- 最近7日首日ROI
  171. round(if(sum(reg_num)=0,0,sum(reg_num*sixty_stay_rate)/sum(reg_num)),2) sixty_stay_rate,
  172. round(if(sum(reg_num)=0,0,sum(reg_num*fortyfive_stay_rate)/sum(reg_num)),2) fortyfive_stay_rate,
  173. round(if(sum(reg_num)=0,0,sum(reg_num*thirty_stay_rate)/sum(reg_num)),2) thirty_stay_rate,
  174. round(if(sum(reg_num)=0,0,sum(reg_num*fifteen_stay_rate)/sum(reg_num)),2) fifteen_stay_rate,
  175. round(if(sum(reg_num)=0,0,sum(reg_num*seven_stay_rate)/sum(reg_num)),2) seven_stay_rate,
  176. round(if(sum(reg_num)=0,0,sum(reg_num*third_stay_rate)/sum(reg_num)),2) third_stay_rate,
  177. round(if(sum(reg_num)=0,0,sum(reg_num*second_stay_rate)/sum(reg_num)),2) second_stay_rate,
  178. round(if(max(game_user_sum)=0,0,sum(game_user_sum*today_active_user_rate)/max(game_user_sum)),2) today_active_user_rate,
  179. round(if(sum(reg_num)=0,0,sum(cost)/sum(reg_num)),2) reg_per_cost,
  180. sum(create_user_num) create_user_num,
  181. round(if(sum(create_user_num)=0,0,sum(cost)/sum(create_user_num)),2) create_user_per_cost,
  182. sum(view_count) view_count,
  183. sum(click_count) click_count,
  184. round(sum(click_count)/sum(view_count),4) click_rate,
  185. sum(follow_user) follow_user,
  186. round(sum(follow_user)/sum(click_count),4) follow_rate,
  187. round(sum(cost)/sum(follow_user),2) follow_per_cost,
  188. round(sum(first_order_count)/sum(click_count),4) order_rate,
  189. round(sum(cost)/sum(first_order_user),2) order_per_cost,
  190. sum(cost) cost,
  191. sum(first_order_count) first_order_count,
  192. sum(first_order_user) first_order_user,
  193. sum(first_order_amount) first_order_amount,
  194. sum(order_count) order_count,
  195. sum(order_user) order_user,
  196. sum(order_amount) order_amount,
  197. sum(old_order_amount) old_order_amount,
  198. round(sum(first_order_amount)/sum(first_order_user),2) first_amount_per_user,
  199. round(sum(first_order_amount)/sum(follow_user),2) amount_per_follow,
  200. round(sum(cost)/sum(reg_order_user),2) first_cost_per_user,
  201. round(sum(first_order_user)/sum(follow_user),4) new_user_order_rate,
  202. sum(reg_user_amount) reg_user_amount,
  203. round(sum(first_order_amount)/sum(cost),4) day_roi,
  204. round(sum(reg_user_amount)/sum(cost),4) roi,
  205. round(sum(reg_order_user_again)/sum(reg_order_user),4) old_user_once_order_rate,
  206. round(sum(cost)/sum(first_order_user),2) first_order_user_per_cost,
  207. round(sum(order_amount)/sum(order_user),2) user_per_amount,
  208. round(sum(follow_user)/sum(click_count),4) click_follow_rate,
  209. round(sum(reg_order_user)/sum(follow_user),4) follow_order_rate
  210. from ({sql}) a
  211. """
  212. return getLimitSumData(db.dm, sql, sumsql, page, page_size)
  213. def get_channel_again_order_trend(channel, date):
  214. ck = CkUtils()
  215. db = MysqlUtils()
  216. sql = f"""select dt date,
  217. channel,book,pitcher,stage,
  218. cost,
  219. reg_order_amount reg_amount,
  220. round(if(cost=0,0,reg_order_amount/cost),4) roi,
  221. follow_user new_follow,
  222. round(if(follow_user=0,0,cost/follow_user),2) new_follow_per_cost,
  223. reg_order_count reg_count,reg_order_user reg_user,
  224. round(if(reg_order_user=0,0,cost/reg_order_user),2) cost_per_user,
  225. round(if(reg_order_user=0,0,reg_order_amount/reg_order_user),2) avg_order_amount,
  226. round(if(reg_order_user=0,0,reg_order_user_again/reg_order_user),4) avg_again_order_rate,
  227. if(reg_order_user=0,0,order_count/reg_order_user) order_count
  228. from dw_channel where channel='{channel}' and dt='{date}'
  229. """
  230. # print(sql)
  231. j = db.dm.getData_json(sql)
  232. if len(j) == 0:
  233. return None
  234. else:
  235. json1 = j[0]
  236. # print(json1)
  237. # print(json1)
  238. sql2 = f"""select
  239. 1 as ddf,count(1) c1,sum(if(count>1,1,0)) c2,sum(if(count>2,1,0)) c3,
  240. sum(if(count>3,1,0)) c4,sum(if(count>4,1,0)) c5,sum(if(count>5,1,0)) c6
  241. from (select count(1) count
  242. from order where channel='{channel}' and date='{date}'and status=2
  243. and formatDateTime(reg_time,'%Y-%m-%d')='{date}' group by user_id,date) a
  244. union all
  245. select
  246. 2 as ddf,count(1) c1,sum(if(count>1,1,0)) c2,sum(if(count>2,1,0)) c3,
  247. sum(if(count>3,1,0)) c4,sum(if(count>4,1,0)) c5,sum(if(count>5,1,0)) c6
  248. from (
  249. select count(1) count
  250. from order where channel='{channel}' and date>='{date}' and date<=addDays(toDate('{date}'),1) and status=2
  251. and formatDateTime(reg_time,'%Y-%m-%d')='{date}' group by user_id) a
  252. union all
  253. select
  254. 3 as ddf,count(1) c1,sum(if(count>1,1,0)) c2,sum(if(count>2,1,0)) c3,
  255. sum(if(count>3,1,0)) c4,sum(if(count>4,1,0)) c5,sum(if(count>5,1,0)) c6
  256. from (
  257. select count(1) count
  258. from order where channel='{channel}' and date>='{date}' and date<=addDays(toDate('{date}'),2) and status=2
  259. and formatDateTime(reg_time,'%Y-%m-%d')='{date}' group by user_id) a
  260. union all
  261. select
  262. 4 as ddf,count(1) c1,sum(if(count>1,1,0)) c2,sum(if(count>2,1,0)) c3,
  263. sum(if(count>3,1,0)) c4,sum(if(count>4,1,0)) c5,sum(if(count>5,1,0)) c6
  264. from (
  265. select count(1) count
  266. from order where channel='{channel}' and date>='{date}' and date<=addDays(toDate('{date}'),3) and status=2
  267. and formatDateTime(reg_time,'%Y-%m-%d')='{date}' group by user_id) a
  268. union all
  269. select
  270. 5 as ddf,count(1) c1,sum(if(count>1,1,0)) c2,sum(if(count>2,1,0)) c3,
  271. sum(if(count>3,1,0)) c4,sum(if(count>4,1,0)) c5,sum(if(count>5,1,0)) c6
  272. from (
  273. select count(1) count
  274. from order where channel='{channel}' and date>='{date}' and date<=addDays(toDate('{date}'),4) and status=2
  275. and formatDateTime(reg_time,'%Y-%m-%d')='{date}' group by user_id) a
  276. union all
  277. select
  278. 6 as ddf,count(1) c1,sum(if(count>1,1,0)) c2,sum(if(count>2,1,0)) c3,
  279. sum(if(count>3,1,0)) c4,sum(if(count>4,1,0)) c5,sum(if(count>5,1,0)) c6
  280. from (
  281. select count(1) count
  282. from order where channel='{channel}' and date>='{date}' and date<=addDays(toDate('{date}'),5) and status=2
  283. and formatDateTime(reg_time,'%Y-%m-%d')='{date}' group by user_id) a
  284. union all
  285. select
  286. 7 as ddf,count(1) c1,sum(if(count>1,1,0)) c2,sum(if(count>2,1,0)) c3,
  287. sum(if(count>3,1,0)) c4,sum(if(count>4,1,0)) c5,sum(if(count>5,1,0)) c6
  288. from (
  289. select count(1) count
  290. from order where channel='{channel}' and date>='{date}' and date<=addDays(toDate('{date}'),6) and status=2
  291. and formatDateTime(reg_time,'%Y-%m-%d')='{date}' group by user_id) a"""
  292. df = ck.execute(sql2)
  293. print(df)
  294. # 补全
  295. # xx=[i[0] for i in df]
  296. # for i in range(1,8):
  297. # if i not in xx:
  298. # df.append((i,0,0,0,0,0,0))
  299. # 排序
  300. import operator
  301. df.sort(key=operator.itemgetter(0))
  302. print(df)
  303. reg_user = json1["reg_user"]
  304. li = []
  305. for i in range(1, 6):
  306. print(i)
  307. d = {}
  308. d["user_order_count"] = i
  309. d1 = {}
  310. d1["origin"] = df[0][i]
  311. d1["new"] = 0
  312. d1["move"] = df[0][i + 1]
  313. d1["now"] = d1["origin"] + d1['new'] - d1["move"]
  314. d1["follow_order_rate"] = round(d1["now"] / df[0][1], 2) if df[0][i] != 0 else 0
  315. d['d1'] = d1
  316. d2 = {}
  317. d2["origin"] = d1["now"]
  318. d2["new"] = df[1][i] - df[0][i]
  319. d2["move"] = df[1][i + 1] - df[0][i + 1]
  320. d2["now"] = df[1][i] - df[1][i + 1]
  321. d2["follow_order_rate"] = round(d2["now"] / df[1][1], 2) if df[1][i] != 0 else 0
  322. d['d2'] = d2
  323. d3 = {}
  324. d3["origin"] = d2["now"]
  325. d3["new"] = df[2][i] - df[1][i]
  326. d3["move"] = df[2][i + 1] - df[1][i + 1]
  327. d3["now"] = df[2][i] - df[2][i + 1]
  328. d3["follow_order_rate"] = round(d3["now"] / df[2][1], 2) if df[2][i] != 0 else 0
  329. d['d3'] = d3
  330. d4 = {}
  331. d4["origin"] = d3["now"]
  332. d4["new"] = df[3][i] - df[2][i]
  333. d4["move"] = df[3][i + 1] - df[2][i + 1]
  334. d4["now"] = df[3][i] - df[3][i + 1]
  335. d4["follow_order_rate"] = round(d4["now"] / df[3][1], 2) if df[3][i] != 0 else 0
  336. d['d4'] = d4
  337. d5 = {}
  338. d5["origin"] = d4["now"]
  339. d5["new"] = df[4][i] - df[3][i]
  340. d5["move"] = df[4][i + 1] - df[3][i + 1]
  341. d5["now"] = df[4][i] - df[4][i + 1]
  342. d5["follow_order_rate"] = round(d4["now"] / df[4][1], 2) if df[3][i] != 0 else 0
  343. d['d5'] = d5
  344. d6 = {}
  345. d6["origin"] = d5["now"]
  346. d6["new"] = df[5][i] - df[4][i]
  347. d6["move"] = df[5][i + 1] - df[4][i + 1]
  348. d6["now"] = df[5][i] - df[5][i + 1]
  349. d6["follow_order_rate"] = round(d6["now"] / df[5][1], 2) if df[5][i] != 0 else 0
  350. d['d6'] = d6
  351. d7 = {}
  352. d7["origin"] = d6["now"]
  353. d7["new"] = df[6][i] - df[5][i]
  354. d7["move"] = df[6][i + 1] - df[5][i + 1]
  355. d7["now"] = df[6][i] - df[6][i + 1]
  356. d7["follow_order_rate"] = round(d7["now"] / df[6][1], 2) if df[6][i] != 0 else 0
  357. d['d7'] = d7
  358. li.append(d)
  359. print(li)
  360. json1['data'] = li
  361. # print([json1])
  362. return [json1]
  363. def get_channel_active(user_id, channel, pitcher, start, end, page, page_size, order_by, order):
  364. db = MysqlUtils()
  365. if user_id in super_auth():
  366. op = ''
  367. else:
  368. if len(UserAuthUtils.get_auth_channel(user_id)) == 0:
  369. return None, None, None
  370. elif len(UserAuthUtils.get_auth_channel(user_id)) == 1:
  371. op = f" and channel = '{UserAuthUtils.get_auth_channel(user_id)[0]}'"
  372. else:
  373. op = f" and channel in {str(UserAuthUtils.get_auth_channel(user_id))}"
  374. op1 = f" and pitcher ='{pitcher}' " if pitcher else ''
  375. op2 = f" and channel='{channel}'" if channel else ''
  376. op3 = f" and dt>='{start}' " if start else ''
  377. op4 = f" and dt<='{end}' " if end else ''
  378. op5 = f" order by {order_by} {order}" if order_by and order else ''
  379. sql = f"""
  380. select channel,dt date,book,stage,pitcher,cost,
  381. reg_order_amount reg_amount,
  382. dc7,dc30,
  383. round(reg_order_amount/cost,4) roi,
  384. follow_user new_follow_user,
  385. round(cost/follow_user,2) new_follow_per_cost,
  386. reg_order_user order_user,
  387. reg_order_count order_count,
  388. round(cost/reg_order_user,2) order_user_per_cost,
  389. round(dc7/follow_user,4) day7_avg_act_rate,
  390. round(cost/dc7,2) day7_avg_act_per_cost,
  391. round(dc30/follow_user,4) day30_avg_act_rate,
  392. round(cost/dc30,2) day30_avg_act_cost,
  393. round(cost/reg_order_user,2) act_per_cost,
  394. concat(dc1,',',cost/dc1,',',dc1/reg_order_user) d1,
  395. concat(dc2-dc1,',',cost/dc2,',',(dc2-dc1)/reg_order_user) d2,
  396. concat(dc3-dc2,',',cost/dc3,',',(dc3-dc2)/reg_order_user) d3,
  397. concat(dc4-dc3,',',cost/dc4,',',(dc4-dc3)/reg_order_user) d4,
  398. concat(dc5-dc4,',',cost/dc5,',',(dc5-dc4)/reg_order_user) d5,
  399. concat(dc6-dc5,',',cost/dc6,',',(dc6-dc5)/reg_order_user) d6,
  400. concat(dc7-dc6,',',cost/dc7,',',(dc7-dc6)/reg_order_user) d7,
  401. concat(dc8-dc7,',',cost/dc8,',',(dc8-dc7)/reg_order_user) d8,
  402. concat(dc9-dc8,',',cost/dc9,',',(dc9-dc8)/reg_order_user) d9,
  403. concat(dc10-dc9,',',cost/dc10,',',(dc10-dc9)/reg_order_user) d10,
  404. concat(dc11-dc10,',',cost/dc11,',',(dc11-dc10)/reg_order_user) d11,
  405. concat(dc12-dc11,',',cost/dc12,',',(dc12-dc11)/reg_order_user) d12,
  406. concat(dc13-dc12,',',cost/dc13,',',(dc13-dc12)/reg_order_user) d13,
  407. concat(dc14-dc13,',',cost/dc14,',',(dc14-dc13)/reg_order_user) d14,
  408. concat(dc15-dc14,',',cost/dc15,',',(dc15-dc14)/reg_order_user) d15,
  409. concat(dc16-dc15,',',cost/dc16,',',(dc16-dc15)/reg_order_user) d16,
  410. concat(dc17-dc16,',',cost/dc17,',',(dc17-dc16)/reg_order_user) d17,
  411. concat(dc18-dc17,',',cost/dc18,',',(dc18-dc17)/reg_order_user) d18,
  412. concat(dc19-dc18,',',cost/dc19,',',(dc19-dc18)/reg_order_user) d19,
  413. concat(dc20-dc19,',',cost/dc20,',',(dc20-dc19)/reg_order_user) d20,
  414. concat(dc21-dc20,',',cost/dc21,',',(dc21-dc20)/reg_order_user) d21,
  415. concat(dc22-dc21,',',cost/dc22,',',(dc22-dc21)/reg_order_user) d22,
  416. concat(dc23-dc22,',',cost/dc23,',',(dc23-dc22)/reg_order_user) d23,
  417. concat(dc24-dc23,',',cost/dc24,',',(dc24-dc23)/reg_order_user) d24,
  418. concat(dc25-dc24,',',cost/dc25,',',(dc25-dc24)/reg_order_user) d25,
  419. concat(dc26-dc25,',',cost/dc26,',',(dc26-dc25)/reg_order_user) d26,
  420. concat(dc27-dc26,',',cost/dc27,',',(dc27-dc26)/reg_order_user) d27,
  421. concat(dc28-dc27,',',cost/dc28,',',(dc28-dc27)/reg_order_user) d28,
  422. concat(dc29-dc28,',',cost/dc29,',',(dc29-dc28)/reg_order_user) d29,
  423. concat(dc30-dc29,',',cost/dc30,',',(dc30-dc29)/reg_order_user) d30
  424. from (select * from dw_channel where cost>0 {op} {op1} {op2} {op3} {op4}) a
  425. left join dw_channel_user_daily b using(dt,channel) {op5}
  426. """
  427. data, total = getLimitData(db.dm, sql, page, page_size)
  428. def parse(str):
  429. li = str.split(',')
  430. li[0] = round(float(li[0]), 0)
  431. li[1] = round(float(li[1]), 2)
  432. li[2] = round(float(li[2]), 4)
  433. return dict(zip(['act_user', 'act_cost_per_cost', 'act_rate'], li))
  434. for i in data:
  435. for x in i:
  436. if x in ['d1', 'd2', 'd3', 'd4', 'd5', 'd6', 'd7', 'd8', 'd9', 'd10',
  437. 'd11', 'd12', 'd13', 'd14', 'd15', 'd16', 'd17', 'd18', 'd19', 'd20', 'd21', 'd22', 'd23', 'd24',
  438. 'd25', 'd26', 'd27', 'd28', 'd29', 'd30']:
  439. i[x] = parse(i[x]) if i[x] is not None else {}
  440. return data, total
  441. def get_channel_order_trend(user_id, channel, pitcher,agent_id, start, end, page, page_size, order_by, order):
  442. db = MysqlUtils()
  443. if user_id in super_auth():
  444. op = ''
  445. else:
  446. if len(UserAuthUtils.get_auth_channel(user_id)) == 0:
  447. return None, None, None
  448. elif len(UserAuthUtils.get_auth_channel(user_id)) == 1:
  449. op = f" and channel = '{UserAuthUtils.get_auth_channel(user_id)[0]}'"
  450. else:
  451. op = f" and channel in {str(UserAuthUtils.get_auth_channel(user_id))}"
  452. op1 = f" and pitcher ='{pitcher}' " if pitcher else ''
  453. if not channel:
  454. op2 = ''
  455. elif type(channel) is str:
  456. op2 = f" and channel='{channel}'" if channel else ''
  457. elif len(channel) > 1:
  458. op2 = f" and channel in {str(tuple(channel))}"
  459. else:
  460. op2 = f" and channel='{channel[0]}'" if channel else ''
  461. op3 = f" and dt>='{start}' " if start else ''
  462. op4 = f" and dt<='{end}' " if end else ''
  463. op5 = f" order by {order_by} {order}" if order_by and order else ''
  464. op6 = f" and agent_id = '{agent_id}' " if agent_id else ""
  465. base_sql_multi_channel = f'''
  466. (select a.dt,a.agent_name agent_name,a.create_user_num,sum(a.reg_num) reg_num ,group_concat(a.channel) channel ,group_concat(a.pitcher ) pitcher ,
  467. group_concat(a.stage ) stage ,group_concat(a.platform) platform ,
  468. group_concat(a.book) book, group_concat(a.type) type,sum(a.order_count ) order_count ,
  469. sum(a.order_user ) order_user ,sum(a.order_amount ) order_amount ,
  470. sum(a.reg_order_amount) reg_order_amount,
  471. SUM(first_order_user) first_order_user,SUM(hundred_user_num) hundred_user_num,
  472. sum(a.first_order_amount ) first_order_amount ,sum(a.view_count) view_count,
  473. sum(a.click_count) click_count ,sum(a.follow_user) follow_user ,
  474. max(game_user_sum) game_user_sum,
  475. round(if(sum(reg_num)=0,0,sum(reg_num*sixty_stay_rate)/sum(reg_num)),2) sixty_stay_rate,
  476. round(if(sum(reg_num)=0,0,sum(reg_num*fortyfive_stay_rate)/sum(reg_num)),2) fortyfive_stay_rate,
  477. round(if(sum(reg_num)=0,0,sum(reg_num*thirty_stay_rate)/sum(reg_num)),2) thirty_stay_rate,
  478. round(if(sum(reg_num)=0,0,sum(reg_num*fifteen_stay_rate)/sum(reg_num)),2) fifteen_stay_rate,
  479. round(if(sum(reg_num)=0,0,sum(reg_num*seven_stay_rate)/sum(reg_num)),2) seven_stay_rate,
  480. round(if(sum(reg_num)=0,0,sum(reg_num*third_stay_rate)/sum(reg_num)),2) third_stay_rate,
  481. round(if(sum(reg_num)=0,0,sum(reg_num*second_stay_rate)/sum(reg_num)),2) second_stay_rate,
  482. round(if(max(game_user_sum)=0,0,sum(game_user_sum*today_active_user_rate)/max(game_user_sum)),2) today_active_user_rate,
  483. sum(a.cost) cost,sum(a.reg_order_count) reg_order_count,
  484. sum(a.reg_order_user) reg_order_user ,sum(a.web_view_count) web_view_count ,
  485. sum(a.platform_view_count) platform_view_count ,sum(a.web_order_count ) web_order_count ,
  486. sum(a.reg_order_user_again) reg_order_user_again ,sum(a.reg_order_user_again3 ) reg_order_user_again3 ,
  487. sum(a.reg_order_user_again4) reg_order_user_again4,sum(a.reg_order_user_again5) reg_order_user_again5,
  488. sum(a.reg_order_user_again6) reg_order_user_again6,sum(b.da1) as da1,
  489. sum(b.da2) as da2,
  490. sum(b.da3) as da3,
  491. sum(b.da4) as da4,
  492. sum(b.da5) as da5,
  493. sum(b.da6) as da6,
  494. sum(b.da7) as da7,
  495. sum(b.da8) as da8,
  496. sum(b.da9) as da9,
  497. sum(b.da10) as da10,
  498. sum(b.da11) as da11,
  499. sum(b.da12) as da12,
  500. sum(b.da13) as da13,
  501. sum(b.da14) as da14,
  502. sum(b.da15) as da15,
  503. sum(b.da16) as da16,
  504. sum(b.da17) as da17,
  505. sum(b.da18) as da18,
  506. sum(b.da19) as da19,
  507. sum(b.da20) as da20,
  508. sum(b.da21) as da21,
  509. sum(b.da22) as da22,
  510. sum(b.da23) as da23,
  511. sum(b.da24) as da24,
  512. sum(b.da25) as da25,
  513. sum(b.da26) as da26,
  514. sum(b.da27) as da27,
  515. sum(b.da28) as da28,
  516. sum(b.da29) as da29,
  517. sum(b.da30) as da30,
  518. sum(b.da31) as da31,
  519. sum(b.da32) as da32,
  520. sum(b.da33) as da33,
  521. sum(b.da34) as da34,
  522. sum(b.da35) as da35,
  523. sum(b.da36) as da36,
  524. sum(b.da37) as da37,
  525. sum(b.da38) as da38,
  526. sum(b.da39) as da39,
  527. sum(b.da40) as da40,
  528. sum(b.da41) as da41,
  529. sum(b.da42) as da42,
  530. sum(b.da43) as da43,
  531. sum(b.da44) as da44,
  532. sum(b.da45) as da45,
  533. sum(b.da46) as da46,
  534. sum(b.da47) as da47,
  535. sum(b.da48) as da48,
  536. sum(b.da49) as da49,
  537. sum(b.da50) as da50,
  538. sum(b.da51) as da51,
  539. sum(b.da52) as da52,
  540. sum(b.da53) as da53,
  541. sum(b.da54) as da54,
  542. sum(b.da55) as da55,
  543. sum(b.da56) as da56,
  544. sum(b.da57) as da57,
  545. sum(b.da58) as da58,
  546. sum(b.da59) as da59,
  547. sum(b.da60) as da60,
  548. sum(b.dm3) as dm3,
  549. sum(b.dm4) as dm4,
  550. sum(b.dm5) as dm5,
  551. sum(c.node) as node,
  552. group_concat(annual_mult) as annual_mult
  553. from
  554. ( select * from dw_channel where cost+reg_order_amount>0
  555. {op} {op1} {op2} {op3} {op4} {op6} ) a
  556. left join dw_channel_amount_daily b on a.channel=b.channel
  557. and a.dt=b.dt
  558. left join src_book_info c on a.dt=c.dt and a.book=c.book
  559. and a.type=c.type and a.platform=c.platform
  560. group by a.dt ) a
  561. '''
  562. base_sql_singel_channel = f'''
  563. ( select * from dw_channel where cost+reg_order_amount>0 {op} {op1} {op2} {op3} {op4} {op6} ) a
  564. left join dw_channel_amount_daily b on a.channel=b.channel and a.dt=b.dt
  565. left join src_book_info c on a.dt=c.dt and a.book=c.book and a.type=c.type and a.platform=c.platform
  566. '''
  567. base_sql = base_sql_multi_channel if channel and len(channel) > 1 else base_sql_singel_channel
  568. sql = f"""select row_number() over() as id,
  569. stage,pitcher,a.channel,a.dt date,a.book,a.agent_name agent_name,cost,
  570. a.type,
  571. a.reg_num,
  572. first_order_user, -- 新增付费人数
  573. round(cost/first_order_user,2) first_order_cost, -- '新增付费成本',
  574. round(first_order_amount/first_order_user,2) ARPU, -- 新增付费ARPU
  575. hundred_user_num, -- 单日付费100+用户数
  576. round(cost/hundred_user_num,2) hundred_user_num_cost , -- 单日付费100+用户付费成本
  577. round(first_order_user/a.reg_num,4) first_order_rate, -- 新增付费率
  578. round(reg_order_amount /reg_order_user,2) order_ARPU, -- 付费ARPU
  579. round(if(a.reg_num=0,0,cost/a.reg_num),2) reg_per_cost,
  580. a.create_user_num,
  581. round(if( a.create_user_num=0,0,cost/ a.create_user_num),2) create_user_per_cost,
  582. node/100 require_roi,round(100/node,2) require_mult,
  583. round(first_order_amount*100/node-cost,2) expect_profit,
  584. annual_mult,
  585. round(first_order_amount*annual_mult -cost,2) annual_expect_profit,
  586. first_order_amount first_amount,
  587. reg_order_amount reg_amount,
  588. reg_order_amount-cost profit,
  589. follow_user new_follow_user,
  590. game_user_sum,
  591. third_stay_rate,
  592. second_stay_rate,
  593. seven_stay_rate,
  594. fifteen_stay_rate,
  595. thirty_stay_rate,
  596. fortyfive_stay_rate,
  597. sixty_stay_rate,
  598. today_active_user_rate,
  599. round(reg_order_amount/cost,4) roi,
  600. round(first_order_amount/cost,4) first_roi,
  601. round(cost/follow_user,2) new_follow_per_cost,
  602. reg_order_user order_user,
  603. reg_order_count order_count,
  604. round(cost/reg_order_user ,2) order_user_per_cost,
  605. concat(da1,',',da1/cost,',', 0,',',1) d1,
  606. concat(da2-da1,',',da2/cost,',', (da2-da1)/cost,',',if(da1=0,1,da2/da1) ) d2,
  607. concat(da3-da2,',',da3/cost,',', (da3-da2)/cost,',',if(da1=0,1,da3/da1)) d3,
  608. concat(da4-da3,',',da4/cost,',', (da4-da3)/cost,',',if(da1=0,1,da4/da1)) d4,
  609. concat(da5-da4,',',da5/cost,',', (da5-da4)/cost,',',if(da1=0,1,da5/da1)) d5,
  610. concat(da6-da5,',',da6/cost,',', (da6-da5)/cost,',',if(da1=0,1,da6/da1)) d6,
  611. concat(da7-da6,',',da7/cost,',', (da7-da6)/cost,',',if(da1=0,1,da7/da1)) d7,
  612. concat(da8-da7,',',da8/cost,',', (da8-da7)/cost,',',if(da1=0,1,da8/da1)) d8,
  613. concat(da9-da8,',',da9/cost,',', (da9-da8)/cost,',',if(da1=0,1,da9/da1)) d9,
  614. concat(da10-da9 ,',' ,da10/cost ,',', (da10-da9)/cost ,',' ,if(da1=0,1,da10/da1)) d10,
  615. concat(da11-da10 ,',' ,da11/cost ,',', (da11-da10)/cost ,',' ,if(da1=0,1,da11/da1)) d11,
  616. concat(da12-da11 ,',' ,da12/cost ,',', (da12-da11)/cost ,',' ,if(da1=0,1,da12/da1)) d12,
  617. concat(da13-da12 ,',' ,da13/cost ,',', (da13-da12)/cost ,',' ,if(da1=0,1,da13/da1)) d13,
  618. concat(da14-da13 ,',' ,da14/cost ,',', (da14-da13)/cost ,',' ,if(da1=0,1,da14/da1)) d14,
  619. concat(da15-da14 ,',' ,da15/cost ,',', (da15-da14)/cost ,',' ,if(da1=0,1,da15/da1)) d15,
  620. concat(da16-da15 ,',' ,da16/cost ,',', (da16-da15)/cost ,',' ,if(da1=0,1,da16/da1)) d16,
  621. concat(da17-da16 ,',' ,da17/cost ,',', (da17-da16)/cost ,',' ,if(da1=0,1,da17/da1)) d17,
  622. concat(da18-da17 ,',' ,da18/cost ,',', (da18-da17)/cost ,',' ,if(da1=0,1,da18/da1)) d18,
  623. concat(da19-da18 ,',' ,da19/cost ,',', (da19-da18)/cost ,',' ,if(da1=0,1,da19/da1)) d19,
  624. concat(da20-da19 ,',' ,da20/cost ,',', (da20-da19)/cost ,',' ,if(da1=0,1,da20/da1)) d20,
  625. concat(da21-da20 ,',' ,da21/cost ,',', (da21-da20)/cost ,',' ,if(da1=0,1,da21/da1)) d21,
  626. concat(da22-da21 ,',' ,da22/cost ,',', (da22-da21)/cost ,',' ,if(da1=0,1,da22/da1)) d22,
  627. concat(da23-da22 ,',' ,da23/cost ,',', (da23-da22)/cost ,',' ,if(da1=0,1,da23/da1)) d23,
  628. concat(da24-da23 ,',' ,da24/cost ,',', (da24-da23)/cost ,',' ,if(da1=0,1,da24/da1)) d24,
  629. concat(da25-da24 ,',' ,da25/cost ,',', (da25-da24)/cost ,',' ,if(da1=0,1,da25/da1)) d25,
  630. concat(da26-da25 ,',' ,da26/cost ,',', (da26-da25)/cost ,',' ,if(da1=0,1,da26/da1)) d26,
  631. concat(da27-da26 ,',' ,da27/cost ,',', (da27-da26)/cost ,',' ,if(da1=0,1,da27/da1)) d27,
  632. concat(da28-da27 ,',' ,da28/cost ,',', (da28-da27)/cost ,',' ,if(da1=0,1,da28/da1)) d28,
  633. concat(da29-da28 ,',' ,da29/cost ,',', (da29-da28)/cost ,',' ,if(da1=0,1,da29/da1)) d29,
  634. concat(da30-da29 ,',' ,da30/cost ,',', (da30-da29)/cost ,',' ,if(da1=0,1,da30/da1)) d30,
  635. concat(da31-da30 ,',' ,da31/cost ,',', (da31-da30)/cost ,',' ,if(da1=0,1,da31/da1)) d31,
  636. concat(da32-da31 ,',' ,da32/cost ,',', (da32-da31)/cost ,',' ,if(da1=0,1,da32/da1)) d32,
  637. concat(da33-da32 ,',' ,da33/cost ,',', (da33-da32)/cost ,',' ,if(da1=0,1,da33/da1)) d33,
  638. concat(da34-da33 ,',' ,da34/cost ,',', (da34-da33)/cost ,',' ,if(da1=0,1,da34/da1)) d34,
  639. concat(da35-da34 ,',' ,da35/cost ,',', (da35-da34)/cost ,',' ,if(da1=0,1,da35/da1)) d35,
  640. concat(da36-da35 ,',' ,da36/cost ,',', (da36-da35)/cost ,',' ,if(da1=0,1,da36/da1)) d36,
  641. concat(da37-da36 ,',' ,da37/cost ,',', (da37-da36)/cost ,',' ,if(da1=0,1,da37/da1)) d37,
  642. concat(da38-da37 ,',' ,da38/cost ,',', (da38-da37)/cost ,',' ,if(da1=0,1,da38/da1)) d38,
  643. concat(da39-da38 ,',' ,da39/cost ,',', (da39-da38)/cost ,',' ,if(da1=0,1,da39/da1)) d39,
  644. concat(da40-da39 ,',' ,da40/cost ,',', (da40-da39)/cost ,',' ,if(da1=0,1,da40/da1)) d40,
  645. concat(da41-da40 ,',' ,da41/cost ,',', (da41-da40)/cost ,',' ,if(da1=0,1,da41/da1)) d41,
  646. concat(da42-da41 ,',' ,da42/cost ,',', (da42-da41)/cost ,',' ,if(da1=0,1,da42/da1)) d42,
  647. concat(da43-da42 ,',' ,da43/cost ,',', (da43-da42)/cost ,',' ,if(da1=0,1,da43/da1)) d43,
  648. concat(da44-da43 ,',' ,da44/cost ,',', (da44-da43)/cost ,',' ,if(da1=0,1,da44/da1)) d44,
  649. concat(da45-da44 ,',' ,da45/cost ,',', (da45-da44)/cost ,',' ,if(da1=0,1,da45/da1)) d45,
  650. concat(da46-da45 ,',' ,da46/cost ,',', (da46-da45)/cost ,',' ,if(da1=0,1,da46/da1)) d46,
  651. concat(da47-da46 ,',' ,da47/cost ,',', (da47-da46)/cost ,',' ,if(da1=0,1,da47/da1)) d47,
  652. concat(da48-da47 ,',' ,da48/cost ,',', (da48-da47)/cost ,',' ,if(da1=0,1,da48/da1)) d48,
  653. concat(da49-da48 ,',' ,da49/cost ,',', (da49-da48)/cost ,',' ,if(da1=0,1,da49/da1)) d49,
  654. concat(da50-da49 ,',' ,da50/cost ,',', (da50-da49)/cost ,',' ,if(da1=0,1,da50/da1)) d50,
  655. concat(da51-da50 ,',' ,da51/cost ,',', (da51-da50)/cost ,',' ,if(da1=0,1,da51/da1)) d51,
  656. concat(da52-da51 ,',' ,da52/cost ,',', (da52-da51)/cost ,',' ,if(da1=0,1,da52/da1)) d52,
  657. concat(da53-da52 ,',' ,da53/cost ,',', (da53-da52)/cost ,',' ,if(da1=0,1,da53/da1)) d53,
  658. concat(da54-da53 ,',' ,da54/cost ,',', (da54-da53)/cost ,',' ,if(da1=0,1,da54/da1)) d54,
  659. concat(da55-da54 ,',' ,da55/cost ,',', (da55-da54)/cost ,',' ,if(da1=0,1,da55/da1)) d55,
  660. concat(da56-da55 ,',' ,da56/cost ,',', (da56-da55)/cost ,',' ,if(da1=0,1,da56/da1)) d56,
  661. concat(da57-da56 ,',' ,da57/cost ,',', (da57-da56)/cost ,',' ,if(da1=0,1,da57/da1)) d57,
  662. concat(da58-da57 ,',' ,da58/cost ,',', (da58-da57)/cost ,',' ,if(da1=0,1,da58/da1)) d58,
  663. concat(da59-da58 ,',' ,da59/cost ,',', (da59-da58)/cost ,',' ,if(da1=0,1,da59/da1)) d59,
  664. concat(da60-da59 ,',' ,da60/cost ,',', (da60-da59)/cost ,',' ,if(da1=0,1,da60/da1)) d60,
  665. concat(dm3-da60 ,',' ,dm3/cost ,',', (dm3-da60)/cost ,',' ,if(da1=0,1,dm3/da1)) m3,
  666. concat(dm4-dm3 ,',' ,dm4/cost ,',', (dm4-dm3)/cost ,',' ,if(da1=0,1,dm4/da1)) m4,
  667. concat(dm5-dm4 ,',' ,dm5/cost ,',', (dm5-dm4)/cost ,',' ,if(da1=0,1,dm5/da1)) m5,
  668. da1,da2,da3,da4,da5,da6,da7,da8,da9,da10,da11,da12,da13,da14,da15,da16,da17,da18,da19,da20,
  669. da21,da22,da23,da24,da25,da26,da27,da28,da29,da30,da31,da32,da33,da34,da35,da36,da37,da38,da39,
  670. da40,da41,da42,da43,da44,da45,da46,da47,da48,da49,da50,da51,da52,da53,da54,da55,da56,da57,da58,
  671. da59,da60,dm3,dm4,dm5
  672. from {base_sql}
  673. {op5}
  674. """
  675. sumsql = f"""select concat(date_format(min(date),'%Y/%m/%d'),'~',date_format(max(date),'%Y/%m/%d')) date,
  676. sum(create_user_num) create_user_num,
  677. sum(first_order_user) first_order_user, -- 新增付费人数
  678. round(sum(cost)/sum(first_order_user),2) first_order_cost, -- '新增付费成本',
  679. round(sum(first_amount)/sum(first_order_user),2) ARPU, -- 新增付费ARPU
  680. sum(hundred_user_num), -- 单日付费100+用户数
  681. round(sum(cost)/sum(hundred_user_num),2) hundred_user_num_cost , -- 单日付费100+用户付费成本
  682. round(sum(first_order_user)/sum(reg_num),4) first_order_rate, -- 新增付费率
  683. round(sum(reg_amount) /sum(order_user),2) order_ARPU, -- 付费ARPU
  684. round(if( sum(create_user_num)=0,0,sum(cost)/ sum(create_user_num)),2) create_user_per_cost,
  685. sum(reg_num) reg_num,
  686. round(if(sum(reg_num)=0,0,sum(cost)/sum(reg_num)),2) reg_per_cost,
  687. sum(cost) cost,
  688. sum(reg_amount) reg_amount,
  689. sum(first_amount) first_amount,
  690. sum(profit) profit,
  691. sum(new_follow_user) new_follow_user,
  692. max(game_user_sum) game_user_sum,
  693. round(if(sum(reg_num)=0,0,sum(reg_num*sixty_stay_rate)/sum(reg_num)),2) sixty_stay_rate,
  694. round(if(sum(reg_num)=0,0,sum(reg_num*fortyfive_stay_rate)/sum(reg_num)),2) fortyfive_stay_rate,
  695. round(if(sum(reg_num)=0,0,sum(reg_num*thirty_stay_rate)/sum(reg_num)),2) thirty_stay_rate,
  696. round(if(sum(reg_num)=0,0,sum(reg_num*fifteen_stay_rate)/sum(reg_num)),2) fifteen_stay_rate,
  697. round(if(sum(reg_num)=0,0,sum(reg_num*seven_stay_rate)/sum(reg_num)),2) seven_stay_rate,
  698. round(if(sum(reg_num)=0,0,sum(reg_num*third_stay_rate)/sum(reg_num)),2) third_stay_rate,
  699. round(if(sum(reg_num)=0,0,sum(reg_num*second_stay_rate)/sum(reg_num)),2) second_stay_rate,
  700. round(if(max(game_user_sum)=0,0,sum(game_user_sum*today_active_user_rate)/max(game_user_sum)),2) today_active_user_rate,
  701. round(sum(reg_amount)/sum(cost),4) roi,
  702. round(sum(first_amount)/sum(cost),4) first_roi,
  703. round(sum(cost)/sum(new_follow_user),2) new_follow_per_cost,
  704. sum(order_user) order_user,
  705. sum(order_count) order_count,
  706. round(sum(cost)/sum(order_user),2) order_user_per_cost,
  707. round(avg(require_roi),4) require_roi,
  708. round(avg(require_mult),2) require_mult,
  709. round(sum(expect_profit),2) expect_profit,
  710. round(sum(annual_expect_profit),2) annual_expect_profit,
  711. concat(sum(da1),',',sum(da1)/sum(cost),',', 0,',',1) d1,
  712. concat(sum(da2)-sum(if (da2,da1,0)),',',sum(da2)/sum(if (da2,cost,0)),',', (sum(da2)-sum(if (da2,da1,0)))/sum(if (da2,cost,0)),',',if(sum(if (da2,da1,0))=0,1,sum(da2)/sum(if (da2,da1,0))) ) d2,
  713. concat(sum(da3)-sum(if (da3,da2,0)),',',sum(da3)/sum(if (da3,cost,0)),',', (sum(da3)-sum(if (da3,da2,0)))/sum(if (da3,cost,0)),',',if(sum(if (da3,da1,0))=0,1,sum(da3)/sum(if (da3,da1,0))) ) d3,
  714. concat(sum(da4)-sum(if (da4,da3,0)),',',sum(da4)/sum(if (da4,cost,0)),',', (sum(da4)-sum(if (da4,da3,0)))/sum(if (da4,cost,0)),',',if(sum(if (da4,da1,0))=0,1,sum(da4)/sum(if (da4,da1,0))) ) d4,
  715. concat(sum(da5)-sum(if (da5,da4,0)),',',sum(da5)/sum(if (da5,cost,0)),',', (sum(da5)-sum(if (da5,da4,0)))/sum(if (da5,cost,0)),',',if(sum(if (da5,da1,0))=0,1,sum(da5)/sum(if (da5,da1,0))) ) d5,
  716. concat(sum(da6)-sum(if (da6,da5,0)),',',sum(da6)/sum(if (da6,cost,0)),',', (sum(da6)-sum(if (da6,da5,0)))/sum(if (da6,cost,0)),',',if(sum(if (da6,da1,0))=0,1,sum(da6)/sum(if (da6,da1,0))) ) d6,
  717. concat(sum(da7)-sum(if (da7,da6,0)),',',sum(da7)/sum(if (da7,cost,0)),',', (sum(da7)-sum(if (da7,da6,0)))/sum(if (da7,cost,0)),',',if(sum(if (da7,da1,0))=0,1,sum(da7)/sum(if (da7,da1,0))) ) d7,
  718. concat(sum(da8)-sum(if (da8,da7,0)),',',sum(da8)/sum(if (da8,cost,0)),',', (sum(da8)-sum(if (da8,da7,0)))/sum(if (da8,cost,0)),',',if(sum(if (da8,da1,0))=0,1,sum(da8)/sum(if (da8,da1,0))) ) d8,
  719. concat(sum(da9)-sum(if (da9,da8,0)),',',sum(da9)/sum(if (da9,cost,0)),',', (sum(da9)-sum(if (da9,da8,0)))/sum(if (da9,cost,0)),',',if(sum(if (da9,da1,0))=0,1,sum(da9)/sum(if (da9,da1,0))) ) d9,
  720. concat(sum(da10)-sum(if (da10,da9,0)),',',sum(da10)/sum(if (da10,cost,0)),',', (sum(da10)-sum(if (da10,da9,0)))/sum(if (da10,cost,0)),',',if(sum(if (da10,da1,0))=0,1,sum(da10)/sum(if (da10,da1,0))) ) d10,
  721. concat(sum(da11)-sum(if (da11,da10,0)),',',sum(da11)/sum(if (da11,cost,0)),',', (sum(da11)-sum(if (da11,da10,0)))/sum(if (da11,cost,0)),',',if(sum(if (da11,da1,0))=0,1,sum(da11)/sum(if (da11,da1,0))) ) d11,
  722. concat(sum(da12)-sum(if (da12,da11,0)),',',sum(da12)/sum(if (da12,cost,0)),',', (sum(da12)-sum(if (da12,da11,0)))/sum(if (da12,cost,0)),',',if(sum(if (da12,da1,0))=0,1,sum(da12)/sum(if (da12,da1,0))) ) d12,
  723. concat(sum(da13)-sum(if (da13,da12,0)),',',sum(da13)/sum(if (da13,cost,0)),',', (sum(da13)-sum(if (da13,da12,0)))/sum(if (da13,cost,0)),',',if(sum(if (da13,da1,0))=0,1,sum(da13)/sum(if (da13,da1,0))) ) d13,
  724. concat(sum(da14)-sum(if (da14,da13,0)),',',sum(da14)/sum(if (da14,cost,0)),',', (sum(da14)-sum(if (da14,da13,0)))/sum(if (da14,cost,0)),',',if(sum(if (da14,da1,0))=0,1,sum(da14)/sum(if (da14,da1,0))) ) d14,
  725. concat(sum(da15)-sum(if (da15,da14,0)),',',sum(da15)/sum(if (da15,cost,0)),',', (sum(da15)-sum(if (da15,da14,0)))/sum(if (da15,cost,0)),',',if(sum(if (da15,da1,0))=0,1,sum(da15)/sum(if (da15,da1,0))) ) d15,
  726. concat(sum(da16)-sum(if (da16,da15,0)),',',sum(da16)/sum(if (da16,cost,0)),',', (sum(da16)-sum(if (da16,da15,0)))/sum(if (da16,cost,0)),',',if(sum(if (da16,da1,0))=0,1,sum(da16)/sum(if (da16,da1,0))) ) d16,
  727. concat(sum(da17)-sum(if (da17,da16,0)),',',sum(da17)/sum(if (da17,cost,0)),',', (sum(da17)-sum(if (da17,da16,0)))/sum(if (da17,cost,0)),',',if(sum(if (da17,da1,0))=0,1,sum(da17)/sum(if (da17,da1,0))) ) d17,
  728. concat(sum(da18)-sum(if (da18,da17,0)),',',sum(da18)/sum(if (da18,cost,0)),',', (sum(da18)-sum(if (da18,da17,0)))/sum(if (da18,cost,0)),',',if(sum(if (da18,da1,0))=0,1,sum(da18)/sum(if (da18,da1,0))) ) d18,
  729. concat(sum(da19)-sum(if (da19,da18,0)),',',sum(da19)/sum(if (da19,cost,0)),',', (sum(da19)-sum(if (da19,da18,0)))/sum(if (da19,cost,0)),',',if(sum(if (da19,da1,0))=0,1,sum(da19)/sum(if (da19,da1,0))) ) d19,
  730. concat(sum(da20)-sum(if (da20,da19,0)),',',sum(da20)/sum(if (da20,cost,0)),',', (sum(da20)-sum(if (da20,da19,0)))/sum(if (da20,cost,0)),',',if(sum(if (da20,da1,0))=0,1,sum(da20)/sum(if (da20,da1,0))) ) d20,
  731. concat(sum(da21)-sum(if (da21,da20,0)),',',sum(da21)/sum(if (da21,cost,0)),',', (sum(da21)-sum(if (da21,da20,0)))/sum(if (da21,cost,0)),',',if(sum(if (da21,da1,0))=0,1,sum(da21)/sum(if (da21,da1,0))) ) d21,
  732. concat(sum(da22)-sum(if (da22,da21,0)),',',sum(da22)/sum(if (da22,cost,0)),',', (sum(da22)-sum(if (da22,da21,0)))/sum(if (da22,cost,0)),',',if(sum(if (da22,da1,0))=0,1,sum(da22)/sum(if (da22,da1,0))) ) d22,
  733. concat(sum(da23)-sum(if (da23,da22,0)),',',sum(da23)/sum(if (da23,cost,0)),',', (sum(da23)-sum(if (da23,da22,0)))/sum(if (da23,cost,0)),',',if(sum(if (da23,da1,0))=0,1,sum(da23)/sum(if (da23,da1,0))) ) d23,
  734. concat(sum(da24)-sum(if (da24,da23,0)),',',sum(da24)/sum(if (da24,cost,0)),',', (sum(da24)-sum(if (da24,da23,0)))/sum(if (da24,cost,0)),',',if(sum(if (da24,da1,0))=0,1,sum(da24)/sum(if (da24,da1,0))) ) d24,
  735. concat(sum(da25)-sum(if (da25,da24,0)),',',sum(da25)/sum(if (da25,cost,0)),',', (sum(da25)-sum(if (da25,da24,0)))/sum(if (da25,cost,0)),',',if(sum(if (da25,da1,0))=0,1,sum(da25)/sum(if (da25,da1,0))) ) d25,
  736. concat(sum(da26)-sum(if (da26,da25,0)),',',sum(da26)/sum(if (da26,cost,0)),',', (sum(da26)-sum(if (da26,da25,0)))/sum(if (da26,cost,0)),',',if(sum(if (da26,da1,0))=0,1,sum(da26)/sum(if (da26,da1,0))) ) d26,
  737. concat(sum(da27)-sum(if (da27,da26,0)),',',sum(da27)/sum(if (da27,cost,0)),',', (sum(da27)-sum(if (da27,da26,0)))/sum(if (da27,cost,0)),',',if(sum(if (da27,da1,0))=0,1,sum(da27)/sum(if (da27,da1,0))) ) d27,
  738. concat(sum(da28)-sum(if (da28,da27,0)),',',sum(da28)/sum(if (da28,cost,0)),',', (sum(da28)-sum(if (da28,da27,0)))/sum(if (da28,cost,0)),',',if(sum(if (da28,da1,0))=0,1,sum(da28)/sum(if (da28,da1,0))) ) d28,
  739. concat(sum(da29)-sum(if (da29,da28,0)),',',sum(da29)/sum(if (da29,cost,0)),',', (sum(da29)-sum(if (da29,da28,0)))/sum(if (da29,cost,0)),',',if(sum(if (da29,da1,0))=0,1,sum(da29)/sum(if (da29,da1,0))) ) d29,
  740. concat(sum(da30)-sum(if (da30,da29,0)),',',sum(da30)/sum(if (da30,cost,0)),',', (sum(da30)-sum(if (da30,da29,0)))/sum(if (da30,cost,0)),',',if(sum(if (da30,da1,0))=0,1,sum(da30)/sum(if (da30,da1,0))) ) d30,
  741. concat(sum(da31)-sum(if (da31,da30,0)),',',sum(da31)/sum(if (da31,cost,0)),',', (sum(da31)-sum(if (da31,da30,0)))/sum(if (da31,cost,0)),',',if(sum(if (da31,da1,0))=0,1,sum(da31)/sum(if (da31,da1,0))) ) d31,
  742. concat(sum(da32)-sum(if (da32,da31,0)),',',sum(da32)/sum(if (da32,cost,0)),',', (sum(da32)-sum(if (da32,da31,0)))/sum(if (da32,cost,0)),',',if(sum(if (da32,da1,0))=0,1,sum(da32)/sum(if (da32,da1,0))) ) d32,
  743. concat(sum(da33)-sum(if (da33,da32,0)),',',sum(da33)/sum(if (da33,cost,0)),',', (sum(da33)-sum(if (da33,da32,0)))/sum(if (da33,cost,0)),',',if(sum(if (da33,da1,0))=0,1,sum(da33)/sum(if (da33,da1,0))) ) d33,
  744. concat(sum(da34)-sum(if (da34,da33,0)),',',sum(da34)/sum(if (da34,cost,0)),',', (sum(da34)-sum(if (da34,da33,0)))/sum(if (da34,cost,0)),',',if(sum(if (da34,da1,0))=0,1,sum(da34)/sum(if (da34,da1,0))) ) d34,
  745. concat(sum(da35)-sum(if (da35,da34,0)),',',sum(da35)/sum(if (da35,cost,0)),',', (sum(da35)-sum(if (da35,da34,0)))/sum(if (da35,cost,0)),',',if(sum(if (da35,da1,0))=0,1,sum(da35)/sum(if (da35,da1,0))) ) d35,
  746. concat(sum(da36)-sum(if (da36,da35,0)),',',sum(da36)/sum(if (da36,cost,0)),',', (sum(da36)-sum(if (da36,da35,0)))/sum(if (da36,cost,0)),',',if(sum(if (da36,da1,0))=0,1,sum(da36)/sum(if (da36,da1,0))) ) d36,
  747. concat(sum(da37)-sum(if (da37,da36,0)),',',sum(da37)/sum(if (da37,cost,0)),',', (sum(da37)-sum(if (da37,da36,0)))/sum(if (da37,cost,0)),',',if(sum(if (da37,da1,0))=0,1,sum(da37)/sum(if (da37,da1,0))) ) d37,
  748. concat(sum(da38)-sum(if (da38,da37,0)),',',sum(da38)/sum(if (da38,cost,0)),',', (sum(da38)-sum(if (da38,da37,0)))/sum(if (da38,cost,0)),',',if(sum(if (da38,da1,0))=0,1,sum(da38)/sum(if (da38,da1,0))) ) d38,
  749. concat(sum(da39)-sum(if (da39,da38,0)),',',sum(da39)/sum(if (da39,cost,0)),',', (sum(da39)-sum(if (da39,da38,0)))/sum(if (da39,cost,0)),',',if(sum(if (da39,da1,0))=0,1,sum(da39)/sum(if (da39,da1,0))) ) d39,
  750. concat(sum(da40)-sum(if (da40,da39,0)),',',sum(da40)/sum(if (da40,cost,0)),',', (sum(da40)-sum(if (da40,da39,0)))/sum(if (da40,cost,0)),',',if(sum(if (da40,da1,0))=0,1,sum(da40)/sum(if (da40,da1,0))) ) d40,
  751. concat(sum(da41)-sum(if (da41,da40,0)),',',sum(da41)/sum(if (da41,cost,0)),',', (sum(da41)-sum(if (da41,da40,0)))/sum(if (da41,cost,0)),',',if(sum(if (da41,da1,0))=0,1,sum(da41)/sum(if (da41,da1,0))) ) d41,
  752. concat(sum(da42)-sum(if (da42,da41,0)),',',sum(da42)/sum(if (da42,cost,0)),',', (sum(da42)-sum(if (da42,da41,0)))/sum(if (da42,cost,0)),',',if(sum(if (da42,da1,0))=0,1,sum(da42)/sum(if (da42,da1,0))) ) d42,
  753. concat(sum(da43)-sum(if (da43,da42,0)),',',sum(da43)/sum(if (da43,cost,0)),',', (sum(da43)-sum(if (da43,da42,0)))/sum(if (da43,cost,0)),',',if(sum(if (da43,da1,0))=0,1,sum(da43)/sum(if (da43,da1,0))) ) d43,
  754. concat(sum(da44)-sum(if (da44,da43,0)),',',sum(da44)/sum(if (da44,cost,0)),',', (sum(da44)-sum(if (da44,da43,0)))/sum(if (da44,cost,0)),',',if(sum(if (da44,da1,0))=0,1,sum(da44)/sum(if (da44,da1,0))) ) d44,
  755. concat(sum(da45)-sum(if (da45,da44,0)),',',sum(da45)/sum(if (da45,cost,0)),',', (sum(da45)-sum(if (da45,da44,0)))/sum(if (da45,cost,0)),',',if(sum(if (da45,da1,0))=0,1,sum(da45)/sum(if (da45,da1,0))) ) d45,
  756. concat(sum(da46)-sum(if (da46,da45,0)),',',sum(da46)/sum(if (da46,cost,0)),',', (sum(da46)-sum(if (da46,da45,0)))/sum(if (da46,cost,0)),',',if(sum(if (da46,da1,0))=0,1,sum(da46)/sum(if (da46,da1,0))) ) d46,
  757. concat(sum(da47)-sum(if (da47,da46,0)),',',sum(da47)/sum(if (da47,cost,0)),',', (sum(da47)-sum(if (da47,da46,0)))/sum(if (da47,cost,0)),',',if(sum(if (da47,da1,0))=0,1,sum(da47)/sum(if (da47,da1,0))) ) d47,
  758. concat(sum(da48)-sum(if (da48,da47,0)),',',sum(da48)/sum(if (da48,cost,0)),',', (sum(da48)-sum(if (da48,da47,0)))/sum(if (da48,cost,0)),',',if(sum(if (da48,da1,0))=0,1,sum(da48)/sum(if (da48,da1,0))) ) d48,
  759. concat(sum(da49)-sum(if (da49,da48,0)),',',sum(da49)/sum(if (da49,cost,0)),',', (sum(da49)-sum(if (da49,da48,0)))/sum(if (da49,cost,0)),',',if(sum(if (da49,da1,0))=0,1,sum(da49)/sum(if (da49,da1,0))) ) d49,
  760. concat(sum(da50)-sum(if (da50,da49,0)),',',sum(da50)/sum(if (da50,cost,0)),',', (sum(da50)-sum(if (da50,da49,0)))/sum(if (da50,cost,0)),',',if(sum(if (da50,da1,0))=0,1,sum(da50)/sum(if (da50,da1,0))) ) d50,
  761. concat(sum(da51)-sum(if (da51,da50,0)),',',sum(da51)/sum(if (da51,cost,0)),',', (sum(da51)-sum(if (da51,da50,0)))/sum(if (da51,cost,0)),',',if(sum(if (da51,da1,0))=0,1,sum(da51)/sum(if (da51,da1,0))) ) d51,
  762. concat(sum(da52)-sum(if (da52,da51,0)),',',sum(da52)/sum(if (da52,cost,0)),',', (sum(da52)-sum(if (da52,da51,0)))/sum(if (da52,cost,0)),',',if(sum(if (da52,da1,0))=0,1,sum(da52)/sum(if (da52,da1,0))) ) d52,
  763. concat(sum(da53)-sum(if (da53,da52,0)),',',sum(da53)/sum(if (da53,cost,0)),',', (sum(da53)-sum(if (da53,da52,0)))/sum(if (da53,cost,0)),',',if(sum(if (da53,da1,0))=0,1,sum(da53)/sum(if (da53,da1,0))) ) d53,
  764. concat(sum(da54)-sum(if (da54,da53,0)),',',sum(da54)/sum(if (da54,cost,0)),',', (sum(da54)-sum(if (da54,da53,0)))/sum(if (da54,cost,0)),',',if(sum(if (da54,da1,0))=0,1,sum(da54)/sum(if (da54,da1,0))) ) d54,
  765. concat(sum(da55)-sum(if (da55,da54,0)),',',sum(da55)/sum(if (da55,cost,0)),',', (sum(da55)-sum(if (da55,da54,0)))/sum(if (da55,cost,0)),',',if(sum(if (da55,da1,0))=0,1,sum(da55)/sum(if (da55,da1,0))) ) d55,
  766. concat(sum(da56)-sum(if (da56,da55,0)),',',sum(da56)/sum(if (da56,cost,0)),',', (sum(da56)-sum(if (da56,da55,0)))/sum(if (da56,cost,0)),',',if(sum(if (da56,da1,0))=0,1,sum(da56)/sum(if (da56,da1,0))) ) d56,
  767. concat(sum(da57)-sum(if (da57,da56,0)),',',sum(da57)/sum(if (da57,cost,0)),',', (sum(da57)-sum(if (da57,da56,0)))/sum(if (da57,cost,0)),',',if(sum(if (da57,da1,0))=0,1,sum(da57)/sum(if (da57,da1,0))) ) d57,
  768. concat(sum(da58)-sum(if (da58,da57,0)),',',sum(da58)/sum(if (da58,cost,0)),',', (sum(da58)-sum(if (da58,da57,0)))/sum(if (da58,cost,0)),',',if(sum(if (da58,da1,0))=0,1,sum(da58)/sum(if (da58,da1,0))) ) d58,
  769. concat(sum(da59)-sum(if (da59,da58,0)),',',sum(da59)/sum(if (da59,cost,0)),',', (sum(da59)-sum(if (da59,da58,0)))/sum(if (da59,cost,0)),',',if(sum(if (da59,da1,0))=0,1,sum(da59)/sum(if (da59,da1,0))) ) d59,
  770. concat(sum(da60)-sum(if (da60,da59,0)),',',sum(da60)/sum(if (da60,cost,0)),',', (sum(da60)-sum(if (da60,da59,0)))/sum(if (da60,cost,0)),',',if(sum(if (da60,da1,0))=0,1,sum(da60)/sum(if (da60,da1,0))) ) d60,
  771. concat(sum(dm3)-sum(if (dm3,da60,0)) ,',' ,sum(dm3)/sum(if(dm3,cost,0)) ,',', (sum(dm3)-sum(if (dm3,da60,0)))/sum(if(dm3,cost,0)) ,',' ,if(sum(if(dm3,da1,0))=0,1,sum(dm3)/sum(if(dm3,da1,0))) ) m3,
  772. concat(sum(dm4)-sum(if (dm4,dm3,0)),',',sum(dm4)/sum(if (dm4,cost,0)),',', (sum(dm4)-sum(if (dm4,dm3,0)))/sum(if (dm4,cost,0)),',',if(sum(if (dm4,da1,0))=0,1,sum(dm4)/sum(if (dm4,da1,0))) ) m4,
  773. concat(sum(dm5)-sum(if (dm5,dm4,0)),',',sum(dm5)/sum(if (dm5,cost,0)),',', (sum(dm5)-sum(if (dm5,dm4,0)))/sum(if (dm5,cost,0)),',',if(sum(if (dm5,da1,0))=0,1,sum(dm5)/sum(if (dm5,da1,0))) ) m5
  774. from ({sql}) a
  775. """
  776. print(sumsql)
  777. data, total, total_data = getLimitSumData(db.dm, sql, sumsql, page, page_size)
  778. def parse(key_str):
  779. if type(key_str) is not str:
  780. key_str = key_str.decode('utf-8')
  781. li = key_str.split(',')
  782. li[0] = round(float(li[0]), 2)
  783. li[1] = round(float(li[1]), 4)
  784. li[2] = round(float(li[2]), 4)
  785. li[3] = round(float(li[3]), 2)
  786. return dict(zip(['order', 'roi', 'add', 'mult'], li))
  787. for x in total_data.keys():
  788. if x in ['d1', 'd2', 'd3', 'd4', 'd5', 'd6', 'd7', 'd8', 'd9', 'd10', 'd11', 'd12', 'd13', 'd14', 'd15', 'd16',
  789. 'd17', 'd18',
  790. 'd19', 'd20', 'd21', 'd22', 'd23', 'd24', 'd25', 'd26', 'd27', 'd28', 'd29', 'd30', 'd31', 'd32',
  791. 'd33', 'd34', 'd35', 'd36', 'd37', 'd38',
  792. 'd39', 'd40', 'd41', 'd42', 'd43', 'd44', 'd45', 'd46', 'd47', 'd48', 'd49', 'd50', 'd51', 'd52',
  793. 'd53', 'd54', 'd55', 'd56', 'd57', 'd58', 'd59',
  794. 'd60', 'm3', 'm4', 'm5']:
  795. total_data[x] = parse(total_data[x]) if total_data[x] is not None else {}
  796. for i in data:
  797. for x in i:
  798. if x in ['d1', 'd2', 'd3', 'd4', 'd5', 'd6', 'd7', 'd8', 'd9', 'd10', 'd11', 'd12', 'd13', 'd14', 'd15',
  799. 'd16', 'd17', 'd18',
  800. 'd19', 'd20', 'd21', 'd22', 'd23', 'd24', 'd25', 'd26', 'd27', 'd28', 'd29', 'd30', 'd31', 'd32',
  801. 'd33', 'd34', 'd35', 'd36', 'd37', 'd38',
  802. 'd39', 'd40', 'd41', 'd42', 'd43', 'd44', 'd45', 'd46', 'd47', 'd48', 'd49', 'd50', 'd51', 'd52',
  803. 'd53', 'd54', 'd55', 'd56', 'd57', 'd58', 'd59',
  804. 'd60', 'm3', 'm4', 'm5']:
  805. i[x] = parse(i[x]) if i[x] is not None else {}
  806. # print(data)
  807. return data, total, total_data
  808. def get_channel_order_trend_nobody(user_id, game, pitcher, start, end, page, page_size, order_by, order):
  809. # TODO:之后添加对应的相关注册人数,付费人数,下单量等
  810. db = MysqlUtils()
  811. if user_id in super_auth():
  812. op = ''
  813. else:
  814. if len(UserAuthUtils.get_auth_game_name(user_id)) == 0:
  815. return None, None, None
  816. else:
  817. game_name_list = UserAuthUtils.get_auth_game_name(user_id)
  818. game_name_list = [_[0] for _ in game_name_list if _[0]]
  819. game_str = "'" + "','".join(game_name_list) + "'"
  820. op = f" and name in ({game_str}) "
  821. op1 = ''
  822. if not game:
  823. op2 = ''
  824. else:
  825. game_str = "'" + "','".join(game) + "'"
  826. op2 = f" and name in ({game}) "
  827. op3 = f" and date(FROM_UNIXTIME(c.create_time)) >= '{start}' " if start else ''
  828. op4 = f" and date(FROM_UNIXTIME(c.create_time)) <= '{end}' " if end else ''
  829. op5 = f" order by {order_by} {order}" if order_by and order else ''
  830. base_sql_multi_channel = f'''
  831. ( select date_format(dt,'%Y-%m-%d') as dt, null create_user_num, null reg_num,
  832. concat(name,'_自然渠道') channel ,null pitcher ,
  833. null stage ,null platform ,
  834. name book, null type,
  835. null order_count ,
  836. null order_user ,
  837. null order_amount ,
  838. order_amount reg_order_amount,
  839. null first_order_amount ,
  840. null view_count,
  841. null click_count ,null follow_user ,
  842. null game_user_sum,
  843. null third_stay_rate,
  844. null second_stay_rate,
  845. null today_active_user_rate,
  846. null cost,order_count reg_order_count,
  847. null reg_order_user ,null web_view_count ,
  848. null platform_view_count ,null web_order_count ,
  849. null reg_order_user_again ,null reg_order_user_again3 ,
  850. null reg_order_user_again4,null reg_order_user_again5,
  851. null reg_order_user_again6,null as da1,
  852. null as da2,
  853. null as da3,
  854. null as da4,
  855. null as da5,
  856. null as da6,
  857. null as da7,
  858. null as da8,
  859. null as da9,
  860. null as da10,
  861. null as da11,
  862. null as da12,
  863. null as da13,
  864. null as da14,
  865. null as da15,
  866. null as da16,
  867. null as da17,
  868. null as da18,
  869. null as da19,
  870. null as da20,
  871. null as da21,
  872. null as da22,
  873. null as da23,
  874. null as da24,
  875. null as da25,
  876. null as da26,
  877. null as da27,
  878. null as da28,
  879. null as da29,
  880. null as da30,
  881. null as da31,
  882. null as da32,
  883. null as da33,
  884. null as da34,
  885. null as da35,
  886. null as da36,
  887. null as da37,
  888. null as da38,
  889. null as da39,
  890. null as da40,
  891. null as da41,
  892. null as da42,
  893. null as da43,
  894. null as da44,
  895. null as da45,
  896. null as da46,
  897. null as da47,
  898. null as da48,
  899. null as da49,
  900. null as da50,
  901. null as da51,
  902. null as da52,
  903. null as da53,
  904. null as da54,
  905. null as da55,
  906. null as da56,
  907. null as da57,
  908. null as da58,
  909. null as da59,
  910. null as da60,
  911. null as dm3,
  912. null as dm4,
  913. null as dm5,
  914. null as node,
  915. null as annual_mult
  916. from
  917. (select sum(a.amount) as order_amount,
  918. count(*) as order_count,
  919. date(FROM_UNIXTIME(c.create_time)) as dt,
  920. b.name as name from db_mp.h_pay a
  921. left join db_mp.h_game b on a.app_id = b.id
  922. left join db_mp.h_member c on a.mem_id = c.id
  923. where a.status =2 and a.agent_id = 0
  924. {op} {op1} {op2} {op3} {op4}
  925. group by dt,name) a ) a
  926. '''
  927. print(base_sql_multi_channel)
  928. base_sql = base_sql_multi_channel
  929. sql = f"""select row_number() over() as id,
  930. stage,pitcher,a.channel,a.dt date,a.book,cost,
  931. a.type,
  932. a.reg_num,
  933. round(if(a.reg_num=0,0,cost/a.reg_num),2) reg_per_cost,
  934. a.create_user_num,
  935. round(if( a.create_user_num=0,0,cost/ a.create_user_num),2) create_user_per_cost,
  936. node/100 require_roi,round(100/node,2) require_mult,
  937. round(first_order_amount*100/node-cost,2) expect_profit,
  938. annual_mult,
  939. round(first_order_amount*annual_mult -cost,2) annual_expect_profit,
  940. first_order_amount first_amount,
  941. reg_order_amount reg_amount,
  942. reg_order_amount-cost profit,
  943. follow_user new_follow_user,
  944. game_user_sum,
  945. third_stay_rate,
  946. second_stay_rate,
  947. today_active_user_rate,
  948. round(reg_order_amount/cost,4) roi,
  949. round(first_order_amount/cost,4) first_roi,
  950. round(cost/follow_user,2) new_follow_per_cost,
  951. reg_order_user order_user,
  952. reg_order_count order_count,
  953. round(cost/reg_order_user ,2) order_user_per_cost,
  954. concat(da1,',',da1/cost,',', 0,',',1) d1,
  955. concat(da2-da1,',',da2/cost,',', (da2-da1)/cost,',',if(da1=0,1,da2/da1) ) d2,
  956. concat(da3-da2,',',da3/cost,',', (da3-da2)/cost,',',if(da1=0,1,da3/da1)) d3,
  957. concat(da4-da3,',',da4/cost,',', (da4-da3)/cost,',',if(da1=0,1,da4/da1)) d4,
  958. concat(da5-da4,',',da5/cost,',', (da5-da4)/cost,',',if(da1=0,1,da5/da1)) d5,
  959. concat(da6-da5,',',da6/cost,',', (da6-da5)/cost,',',if(da1=0,1,da6/da1)) d6,
  960. concat(da7-da6,',',da7/cost,',', (da7-da6)/cost,',',if(da1=0,1,da7/da1)) d7,
  961. concat(da8-da7,',',da8/cost,',', (da8-da7)/cost,',',if(da1=0,1,da8/da1)) d8,
  962. concat(da9-da8,',',da9/cost,',', (da9-da8)/cost,',',if(da1=0,1,da9/da1)) d9,
  963. concat(da10-da9 ,',' ,da10/cost ,',', (da10-da9)/cost ,',' ,if(da1=0,1,da10/da1)) d10,
  964. concat(da11-da10 ,',' ,da11/cost ,',', (da11-da10)/cost ,',' ,if(da1=0,1,da11/da1)) d11,
  965. concat(da12-da11 ,',' ,da12/cost ,',', (da12-da11)/cost ,',' ,if(da1=0,1,da12/da1)) d12,
  966. concat(da13-da12 ,',' ,da13/cost ,',', (da13-da12)/cost ,',' ,if(da1=0,1,da13/da1)) d13,
  967. concat(da14-da13 ,',' ,da14/cost ,',', (da14-da13)/cost ,',' ,if(da1=0,1,da14/da1)) d14,
  968. concat(da15-da14 ,',' ,da15/cost ,',', (da15-da14)/cost ,',' ,if(da1=0,1,da15/da1)) d15,
  969. concat(da16-da15 ,',' ,da16/cost ,',', (da16-da15)/cost ,',' ,if(da1=0,1,da16/da1)) d16,
  970. concat(da17-da16 ,',' ,da17/cost ,',', (da17-da16)/cost ,',' ,if(da1=0,1,da17/da1)) d17,
  971. concat(da18-da17 ,',' ,da18/cost ,',', (da18-da17)/cost ,',' ,if(da1=0,1,da18/da1)) d18,
  972. concat(da19-da18 ,',' ,da19/cost ,',', (da19-da18)/cost ,',' ,if(da1=0,1,da19/da1)) d19,
  973. concat(da20-da19 ,',' ,da20/cost ,',', (da20-da19)/cost ,',' ,if(da1=0,1,da20/da1)) d20,
  974. concat(da21-da20 ,',' ,da21/cost ,',', (da21-da20)/cost ,',' ,if(da1=0,1,da21/da1)) d21,
  975. concat(da22-da21 ,',' ,da22/cost ,',', (da22-da21)/cost ,',' ,if(da1=0,1,da22/da1)) d22,
  976. concat(da23-da22 ,',' ,da23/cost ,',', (da23-da22)/cost ,',' ,if(da1=0,1,da23/da1)) d23,
  977. concat(da24-da23 ,',' ,da24/cost ,',', (da24-da23)/cost ,',' ,if(da1=0,1,da24/da1)) d24,
  978. concat(da25-da24 ,',' ,da25/cost ,',', (da25-da24)/cost ,',' ,if(da1=0,1,da25/da1)) d25,
  979. concat(da26-da25 ,',' ,da26/cost ,',', (da26-da25)/cost ,',' ,if(da1=0,1,da26/da1)) d26,
  980. concat(da27-da26 ,',' ,da27/cost ,',', (da27-da26)/cost ,',' ,if(da1=0,1,da27/da1)) d27,
  981. concat(da28-da27 ,',' ,da28/cost ,',', (da28-da27)/cost ,',' ,if(da1=0,1,da28/da1)) d28,
  982. concat(da29-da28 ,',' ,da29/cost ,',', (da29-da28)/cost ,',' ,if(da1=0,1,da29/da1)) d29,
  983. concat(da30-da29 ,',' ,da30/cost ,',', (da30-da29)/cost ,',' ,if(da1=0,1,da30/da1)) d30,
  984. concat(da31-da30 ,',' ,da31/cost ,',', (da31-da30)/cost ,',' ,if(da1=0,1,da31/da1)) d31,
  985. concat(da32-da31 ,',' ,da32/cost ,',', (da32-da31)/cost ,',' ,if(da1=0,1,da32/da1)) d32,
  986. concat(da33-da32 ,',' ,da33/cost ,',', (da33-da32)/cost ,',' ,if(da1=0,1,da33/da1)) d33,
  987. concat(da34-da33 ,',' ,da34/cost ,',', (da34-da33)/cost ,',' ,if(da1=0,1,da34/da1)) d34,
  988. concat(da35-da34 ,',' ,da35/cost ,',', (da35-da34)/cost ,',' ,if(da1=0,1,da35/da1)) d35,
  989. concat(da36-da35 ,',' ,da36/cost ,',', (da36-da35)/cost ,',' ,if(da1=0,1,da36/da1)) d36,
  990. concat(da37-da36 ,',' ,da37/cost ,',', (da37-da36)/cost ,',' ,if(da1=0,1,da37/da1)) d37,
  991. concat(da38-da37 ,',' ,da38/cost ,',', (da38-da37)/cost ,',' ,if(da1=0,1,da38/da1)) d38,
  992. concat(da39-da38 ,',' ,da39/cost ,',', (da39-da38)/cost ,',' ,if(da1=0,1,da39/da1)) d39,
  993. concat(da40-da39 ,',' ,da40/cost ,',', (da40-da39)/cost ,',' ,if(da1=0,1,da40/da1)) d40,
  994. concat(da41-da40 ,',' ,da41/cost ,',', (da41-da40)/cost ,',' ,if(da1=0,1,da41/da1)) d41,
  995. concat(da42-da41 ,',' ,da42/cost ,',', (da42-da41)/cost ,',' ,if(da1=0,1,da42/da1)) d42,
  996. concat(da43-da42 ,',' ,da43/cost ,',', (da43-da42)/cost ,',' ,if(da1=0,1,da43/da1)) d43,
  997. concat(da44-da43 ,',' ,da44/cost ,',', (da44-da43)/cost ,',' ,if(da1=0,1,da44/da1)) d44,
  998. concat(da45-da44 ,',' ,da45/cost ,',', (da45-da44)/cost ,',' ,if(da1=0,1,da45/da1)) d45,
  999. concat(da46-da45 ,',' ,da46/cost ,',', (da46-da45)/cost ,',' ,if(da1=0,1,da46/da1)) d46,
  1000. concat(da47-da46 ,',' ,da47/cost ,',', (da47-da46)/cost ,',' ,if(da1=0,1,da47/da1)) d47,
  1001. concat(da48-da47 ,',' ,da48/cost ,',', (da48-da47)/cost ,',' ,if(da1=0,1,da48/da1)) d48,
  1002. concat(da49-da48 ,',' ,da49/cost ,',', (da49-da48)/cost ,',' ,if(da1=0,1,da49/da1)) d49,
  1003. concat(da50-da49 ,',' ,da50/cost ,',', (da50-da49)/cost ,',' ,if(da1=0,1,da50/da1)) d50,
  1004. concat(da51-da50 ,',' ,da51/cost ,',', (da51-da50)/cost ,',' ,if(da1=0,1,da51/da1)) d51,
  1005. concat(da52-da51 ,',' ,da52/cost ,',', (da52-da51)/cost ,',' ,if(da1=0,1,da52/da1)) d52,
  1006. concat(da53-da52 ,',' ,da53/cost ,',', (da53-da52)/cost ,',' ,if(da1=0,1,da53/da1)) d53,
  1007. concat(da54-da53 ,',' ,da54/cost ,',', (da54-da53)/cost ,',' ,if(da1=0,1,da54/da1)) d54,
  1008. concat(da55-da54 ,',' ,da55/cost ,',', (da55-da54)/cost ,',' ,if(da1=0,1,da55/da1)) d55,
  1009. concat(da56-da55 ,',' ,da56/cost ,',', (da56-da55)/cost ,',' ,if(da1=0,1,da56/da1)) d56,
  1010. concat(da57-da56 ,',' ,da57/cost ,',', (da57-da56)/cost ,',' ,if(da1=0,1,da57/da1)) d57,
  1011. concat(da58-da57 ,',' ,da58/cost ,',', (da58-da57)/cost ,',' ,if(da1=0,1,da58/da1)) d58,
  1012. concat(da59-da58 ,',' ,da59/cost ,',', (da59-da58)/cost ,',' ,if(da1=0,1,da59/da1)) d59,
  1013. concat(da60-da59 ,',' ,da60/cost ,',', (da60-da59)/cost ,',' ,if(da1=0,1,da60/da1)) d60,
  1014. concat(dm3-da60 ,',' ,dm3/cost ,',', (dm3-da60)/cost ,',' ,if(da1=0,1,dm3/da1)) m3,
  1015. concat(dm4-dm3 ,',' ,dm4/cost ,',', (dm4-dm3)/cost ,',' ,if(da1=0,1,dm4/da1)) m4,
  1016. concat(dm5-dm4 ,',' ,dm5/cost ,',', (dm5-dm4)/cost ,',' ,if(da1=0,1,dm5/da1)) m5,
  1017. da1,da2,da3,da4,da5,da6,da7,da8,da9,da10,da11,da12,da13,da14,da15,da16,da17,da18,da19,da20,
  1018. da21,da22,da23,da24,da25,da26,da27,da28,da29,da30,da31,da32,da33,da34,da35,da36,da37,da38,da39,
  1019. da40,da41,da42,da43,da44,da45,da46,da47,da48,da49,da50,da51,da52,da53,da54,da55,da56,da57,da58,
  1020. da59,da60,dm3,dm4,dm5
  1021. from {base_sql}
  1022. {op5}
  1023. """
  1024. sumsql = f"""select concat(date_format(min(date),'%Y/%m/%d'),'~',date_format(max(date),'%Y/%m/%d')) date,
  1025. sum(create_user_num) create_user_num,
  1026. round(if( sum(create_user_num)=0,0,sum(cost)/ sum(create_user_num)),2) create_user_per_cost,
  1027. sum(reg_num) reg_num,
  1028. round(if(sum(reg_num)=0,0,sum(cost)/sum(reg_num)),2) reg_per_cost,
  1029. sum(cost) cost,
  1030. sum(reg_amount) reg_amount,
  1031. sum(first_amount) first_amount,
  1032. sum(profit) profit,
  1033. sum(new_follow_user) new_follow_user,
  1034. sum(game_user_sum) game_user_sum,
  1035. round(if(sum(reg_num)=0,0,sum(reg_num*third_stay_rate)/sum(reg_num)),2) third_stay_rate,
  1036. round(if(sum(reg_num)=0,0,sum(reg_num*second_stay_rate)/sum(reg_num)),2) second_stay_rate,
  1037. round(if(sum(game_user_sum)=0,0,sum(game_user_sum*today_active_user_rate)/sum(game_user_sum)),2) today_active_user_rate,
  1038. round(sum(reg_amount)/sum(cost),4) roi,
  1039. round(sum(first_amount)/sum(cost),4) first_roi,
  1040. round(sum(cost)/sum(new_follow_user),2) new_follow_per_cost,
  1041. sum(order_user) order_user,
  1042. sum(order_count) order_count,
  1043. round(sum(cost)/sum(order_user),2) order_user_per_cost,
  1044. round(avg(require_roi),4) require_roi,
  1045. round(avg(require_mult),2) require_mult,
  1046. round(sum(expect_profit),2) expect_profit,
  1047. round(sum(annual_expect_profit),2) annual_expect_profit,
  1048. concat(sum(da1),',',sum(da1)/sum(cost),',', 0,',',1) d1,
  1049. concat(sum(da2)-sum(if (da2,da1,0)),',',sum(da2)/sum(if (da2,cost,0)),',', (sum(da2)-sum(if (da2,da1,0)))/sum(if (da2,cost,0)),',',if(sum(if (da2,da1,0))=0,1,sum(da2)/sum(if (da2,da1,0))) ) d2,
  1050. concat(sum(da3)-sum(if (da3,da2,0)),',',sum(da3)/sum(if (da3,cost,0)),',', (sum(da3)-sum(if (da3,da2,0)))/sum(if (da3,cost,0)),',',if(sum(if (da3,da1,0))=0,1,sum(da3)/sum(if (da3,da1,0))) ) d3,
  1051. concat(sum(da4)-sum(if (da4,da3,0)),',',sum(da4)/sum(if (da4,cost,0)),',', (sum(da4)-sum(if (da4,da3,0)))/sum(if (da4,cost,0)),',',if(sum(if (da4,da1,0))=0,1,sum(da4)/sum(if (da4,da1,0))) ) d4,
  1052. concat(sum(da5)-sum(if (da5,da4,0)),',',sum(da5)/sum(if (da5,cost,0)),',', (sum(da5)-sum(if (da5,da4,0)))/sum(if (da5,cost,0)),',',if(sum(if (da5,da1,0))=0,1,sum(da5)/sum(if (da5,da1,0))) ) d5,
  1053. concat(sum(da6)-sum(if (da6,da5,0)),',',sum(da6)/sum(if (da6,cost,0)),',', (sum(da6)-sum(if (da6,da5,0)))/sum(if (da6,cost,0)),',',if(sum(if (da6,da1,0))=0,1,sum(da6)/sum(if (da6,da1,0))) ) d6,
  1054. concat(sum(da7)-sum(if (da7,da6,0)),',',sum(da7)/sum(if (da7,cost,0)),',', (sum(da7)-sum(if (da7,da6,0)))/sum(if (da7,cost,0)),',',if(sum(if (da7,da1,0))=0,1,sum(da7)/sum(if (da7,da1,0))) ) d7,
  1055. concat(sum(da8)-sum(if (da8,da7,0)),',',sum(da8)/sum(if (da8,cost,0)),',', (sum(da8)-sum(if (da8,da7,0)))/sum(if (da8,cost,0)),',',if(sum(if (da8,da1,0))=0,1,sum(da8)/sum(if (da8,da1,0))) ) d8,
  1056. concat(sum(da9)-sum(if (da9,da8,0)),',',sum(da9)/sum(if (da9,cost,0)),',', (sum(da9)-sum(if (da9,da8,0)))/sum(if (da9,cost,0)),',',if(sum(if (da9,da1,0))=0,1,sum(da9)/sum(if (da9,da1,0))) ) d9,
  1057. concat(sum(da10)-sum(if (da10,da9,0)),',',sum(da10)/sum(if (da10,cost,0)),',', (sum(da10)-sum(if (da10,da9,0)))/sum(if (da10,cost,0)),',',if(sum(if (da10,da1,0))=0,1,sum(da10)/sum(if (da10,da1,0))) ) d10,
  1058. concat(sum(da11)-sum(if (da11,da10,0)),',',sum(da11)/sum(if (da11,cost,0)),',', (sum(da11)-sum(if (da11,da10,0)))/sum(if (da11,cost,0)),',',if(sum(if (da11,da1,0))=0,1,sum(da11)/sum(if (da11,da1,0))) ) d11,
  1059. concat(sum(da12)-sum(if (da12,da11,0)),',',sum(da12)/sum(if (da12,cost,0)),',', (sum(da12)-sum(if (da12,da11,0)))/sum(if (da12,cost,0)),',',if(sum(if (da12,da1,0))=0,1,sum(da12)/sum(if (da12,da1,0))) ) d12,
  1060. concat(sum(da13)-sum(if (da13,da12,0)),',',sum(da13)/sum(if (da13,cost,0)),',', (sum(da13)-sum(if (da13,da12,0)))/sum(if (da13,cost,0)),',',if(sum(if (da13,da1,0))=0,1,sum(da13)/sum(if (da13,da1,0))) ) d13,
  1061. concat(sum(da14)-sum(if (da14,da13,0)),',',sum(da14)/sum(if (da14,cost,0)),',', (sum(da14)-sum(if (da14,da13,0)))/sum(if (da14,cost,0)),',',if(sum(if (da14,da1,0))=0,1,sum(da14)/sum(if (da14,da1,0))) ) d14,
  1062. concat(sum(da15)-sum(if (da15,da14,0)),',',sum(da15)/sum(if (da15,cost,0)),',', (sum(da15)-sum(if (da15,da14,0)))/sum(if (da15,cost,0)),',',if(sum(if (da15,da1,0))=0,1,sum(da15)/sum(if (da15,da1,0))) ) d15,
  1063. concat(sum(da16)-sum(if (da16,da15,0)),',',sum(da16)/sum(if (da16,cost,0)),',', (sum(da16)-sum(if (da16,da15,0)))/sum(if (da16,cost,0)),',',if(sum(if (da16,da1,0))=0,1,sum(da16)/sum(if (da16,da1,0))) ) d16,
  1064. concat(sum(da17)-sum(if (da17,da16,0)),',',sum(da17)/sum(if (da17,cost,0)),',', (sum(da17)-sum(if (da17,da16,0)))/sum(if (da17,cost,0)),',',if(sum(if (da17,da1,0))=0,1,sum(da17)/sum(if (da17,da1,0))) ) d17,
  1065. concat(sum(da18)-sum(if (da18,da17,0)),',',sum(da18)/sum(if (da18,cost,0)),',', (sum(da18)-sum(if (da18,da17,0)))/sum(if (da18,cost,0)),',',if(sum(if (da18,da1,0))=0,1,sum(da18)/sum(if (da18,da1,0))) ) d18,
  1066. concat(sum(da19)-sum(if (da19,da18,0)),',',sum(da19)/sum(if (da19,cost,0)),',', (sum(da19)-sum(if (da19,da18,0)))/sum(if (da19,cost,0)),',',if(sum(if (da19,da1,0))=0,1,sum(da19)/sum(if (da19,da1,0))) ) d19,
  1067. concat(sum(da20)-sum(if (da20,da19,0)),',',sum(da20)/sum(if (da20,cost,0)),',', (sum(da20)-sum(if (da20,da19,0)))/sum(if (da20,cost,0)),',',if(sum(if (da20,da1,0))=0,1,sum(da20)/sum(if (da20,da1,0))) ) d20,
  1068. concat(sum(da21)-sum(if (da21,da20,0)),',',sum(da21)/sum(if (da21,cost,0)),',', (sum(da21)-sum(if (da21,da20,0)))/sum(if (da21,cost,0)),',',if(sum(if (da21,da1,0))=0,1,sum(da21)/sum(if (da21,da1,0))) ) d21,
  1069. concat(sum(da22)-sum(if (da22,da21,0)),',',sum(da22)/sum(if (da22,cost,0)),',', (sum(da22)-sum(if (da22,da21,0)))/sum(if (da22,cost,0)),',',if(sum(if (da22,da1,0))=0,1,sum(da22)/sum(if (da22,da1,0))) ) d22,
  1070. concat(sum(da23)-sum(if (da23,da22,0)),',',sum(da23)/sum(if (da23,cost,0)),',', (sum(da23)-sum(if (da23,da22,0)))/sum(if (da23,cost,0)),',',if(sum(if (da23,da1,0))=0,1,sum(da23)/sum(if (da23,da1,0))) ) d23,
  1071. concat(sum(da24)-sum(if (da24,da23,0)),',',sum(da24)/sum(if (da24,cost,0)),',', (sum(da24)-sum(if (da24,da23,0)))/sum(if (da24,cost,0)),',',if(sum(if (da24,da1,0))=0,1,sum(da24)/sum(if (da24,da1,0))) ) d24,
  1072. concat(sum(da25)-sum(if (da25,da24,0)),',',sum(da25)/sum(if (da25,cost,0)),',', (sum(da25)-sum(if (da25,da24,0)))/sum(if (da25,cost,0)),',',if(sum(if (da25,da1,0))=0,1,sum(da25)/sum(if (da25,da1,0))) ) d25,
  1073. concat(sum(da26)-sum(if (da26,da25,0)),',',sum(da26)/sum(if (da26,cost,0)),',', (sum(da26)-sum(if (da26,da25,0)))/sum(if (da26,cost,0)),',',if(sum(if (da26,da1,0))=0,1,sum(da26)/sum(if (da26,da1,0))) ) d26,
  1074. concat(sum(da27)-sum(if (da27,da26,0)),',',sum(da27)/sum(if (da27,cost,0)),',', (sum(da27)-sum(if (da27,da26,0)))/sum(if (da27,cost,0)),',',if(sum(if (da27,da1,0))=0,1,sum(da27)/sum(if (da27,da1,0))) ) d27,
  1075. concat(sum(da28)-sum(if (da28,da27,0)),',',sum(da28)/sum(if (da28,cost,0)),',', (sum(da28)-sum(if (da28,da27,0)))/sum(if (da28,cost,0)),',',if(sum(if (da28,da1,0))=0,1,sum(da28)/sum(if (da28,da1,0))) ) d28,
  1076. concat(sum(da29)-sum(if (da29,da28,0)),',',sum(da29)/sum(if (da29,cost,0)),',', (sum(da29)-sum(if (da29,da28,0)))/sum(if (da29,cost,0)),',',if(sum(if (da29,da1,0))=0,1,sum(da29)/sum(if (da29,da1,0))) ) d29,
  1077. concat(sum(da30)-sum(if (da30,da29,0)),',',sum(da30)/sum(if (da30,cost,0)),',', (sum(da30)-sum(if (da30,da29,0)))/sum(if (da30,cost,0)),',',if(sum(if (da30,da1,0))=0,1,sum(da30)/sum(if (da30,da1,0))) ) d30,
  1078. concat(sum(da31)-sum(if (da31,da30,0)),',',sum(da31)/sum(if (da31,cost,0)),',', (sum(da31)-sum(if (da31,da30,0)))/sum(if (da31,cost,0)),',',if(sum(if (da31,da1,0))=0,1,sum(da31)/sum(if (da31,da1,0))) ) d31,
  1079. concat(sum(da32)-sum(if (da32,da31,0)),',',sum(da32)/sum(if (da32,cost,0)),',', (sum(da32)-sum(if (da32,da31,0)))/sum(if (da32,cost,0)),',',if(sum(if (da32,da1,0))=0,1,sum(da32)/sum(if (da32,da1,0))) ) d32,
  1080. concat(sum(da33)-sum(if (da33,da32,0)),',',sum(da33)/sum(if (da33,cost,0)),',', (sum(da33)-sum(if (da33,da32,0)))/sum(if (da33,cost,0)),',',if(sum(if (da33,da1,0))=0,1,sum(da33)/sum(if (da33,da1,0))) ) d33,
  1081. concat(sum(da34)-sum(if (da34,da33,0)),',',sum(da34)/sum(if (da34,cost,0)),',', (sum(da34)-sum(if (da34,da33,0)))/sum(if (da34,cost,0)),',',if(sum(if (da34,da1,0))=0,1,sum(da34)/sum(if (da34,da1,0))) ) d34,
  1082. concat(sum(da35)-sum(if (da35,da34,0)),',',sum(da35)/sum(if (da35,cost,0)),',', (sum(da35)-sum(if (da35,da34,0)))/sum(if (da35,cost,0)),',',if(sum(if (da35,da1,0))=0,1,sum(da35)/sum(if (da35,da1,0))) ) d35,
  1083. concat(sum(da36)-sum(if (da36,da35,0)),',',sum(da36)/sum(if (da36,cost,0)),',', (sum(da36)-sum(if (da36,da35,0)))/sum(if (da36,cost,0)),',',if(sum(if (da36,da1,0))=0,1,sum(da36)/sum(if (da36,da1,0))) ) d36,
  1084. concat(sum(da37)-sum(if (da37,da36,0)),',',sum(da37)/sum(if (da37,cost,0)),',', (sum(da37)-sum(if (da37,da36,0)))/sum(if (da37,cost,0)),',',if(sum(if (da37,da1,0))=0,1,sum(da37)/sum(if (da37,da1,0))) ) d37,
  1085. concat(sum(da38)-sum(if (da38,da37,0)),',',sum(da38)/sum(if (da38,cost,0)),',', (sum(da38)-sum(if (da38,da37,0)))/sum(if (da38,cost,0)),',',if(sum(if (da38,da1,0))=0,1,sum(da38)/sum(if (da38,da1,0))) ) d38,
  1086. concat(sum(da39)-sum(if (da39,da38,0)),',',sum(da39)/sum(if (da39,cost,0)),',', (sum(da39)-sum(if (da39,da38,0)))/sum(if (da39,cost,0)),',',if(sum(if (da39,da1,0))=0,1,sum(da39)/sum(if (da39,da1,0))) ) d39,
  1087. concat(sum(da40)-sum(if (da40,da39,0)),',',sum(da40)/sum(if (da40,cost,0)),',', (sum(da40)-sum(if (da40,da39,0)))/sum(if (da40,cost,0)),',',if(sum(if (da40,da1,0))=0,1,sum(da40)/sum(if (da40,da1,0))) ) d40,
  1088. concat(sum(da41)-sum(if (da41,da40,0)),',',sum(da41)/sum(if (da41,cost,0)),',', (sum(da41)-sum(if (da41,da40,0)))/sum(if (da41,cost,0)),',',if(sum(if (da41,da1,0))=0,1,sum(da41)/sum(if (da41,da1,0))) ) d41,
  1089. concat(sum(da42)-sum(if (da42,da41,0)),',',sum(da42)/sum(if (da42,cost,0)),',', (sum(da42)-sum(if (da42,da41,0)))/sum(if (da42,cost,0)),',',if(sum(if (da42,da1,0))=0,1,sum(da42)/sum(if (da42,da1,0))) ) d42,
  1090. concat(sum(da43)-sum(if (da43,da42,0)),',',sum(da43)/sum(if (da43,cost,0)),',', (sum(da43)-sum(if (da43,da42,0)))/sum(if (da43,cost,0)),',',if(sum(if (da43,da1,0))=0,1,sum(da43)/sum(if (da43,da1,0))) ) d43,
  1091. concat(sum(da44)-sum(if (da44,da43,0)),',',sum(da44)/sum(if (da44,cost,0)),',', (sum(da44)-sum(if (da44,da43,0)))/sum(if (da44,cost,0)),',',if(sum(if (da44,da1,0))=0,1,sum(da44)/sum(if (da44,da1,0))) ) d44,
  1092. concat(sum(da45)-sum(if (da45,da44,0)),',',sum(da45)/sum(if (da45,cost,0)),',', (sum(da45)-sum(if (da45,da44,0)))/sum(if (da45,cost,0)),',',if(sum(if (da45,da1,0))=0,1,sum(da45)/sum(if (da45,da1,0))) ) d45,
  1093. concat(sum(da46)-sum(if (da46,da45,0)),',',sum(da46)/sum(if (da46,cost,0)),',', (sum(da46)-sum(if (da46,da45,0)))/sum(if (da46,cost,0)),',',if(sum(if (da46,da1,0))=0,1,sum(da46)/sum(if (da46,da1,0))) ) d46,
  1094. concat(sum(da47)-sum(if (da47,da46,0)),',',sum(da47)/sum(if (da47,cost,0)),',', (sum(da47)-sum(if (da47,da46,0)))/sum(if (da47,cost,0)),',',if(sum(if (da47,da1,0))=0,1,sum(da47)/sum(if (da47,da1,0))) ) d47,
  1095. concat(sum(da48)-sum(if (da48,da47,0)),',',sum(da48)/sum(if (da48,cost,0)),',', (sum(da48)-sum(if (da48,da47,0)))/sum(if (da48,cost,0)),',',if(sum(if (da48,da1,0))=0,1,sum(da48)/sum(if (da48,da1,0))) ) d48,
  1096. concat(sum(da49)-sum(if (da49,da48,0)),',',sum(da49)/sum(if (da49,cost,0)),',', (sum(da49)-sum(if (da49,da48,0)))/sum(if (da49,cost,0)),',',if(sum(if (da49,da1,0))=0,1,sum(da49)/sum(if (da49,da1,0))) ) d49,
  1097. concat(sum(da50)-sum(if (da50,da49,0)),',',sum(da50)/sum(if (da50,cost,0)),',', (sum(da50)-sum(if (da50,da49,0)))/sum(if (da50,cost,0)),',',if(sum(if (da50,da1,0))=0,1,sum(da50)/sum(if (da50,da1,0))) ) d50,
  1098. concat(sum(da51)-sum(if (da51,da50,0)),',',sum(da51)/sum(if (da51,cost,0)),',', (sum(da51)-sum(if (da51,da50,0)))/sum(if (da51,cost,0)),',',if(sum(if (da51,da1,0))=0,1,sum(da51)/sum(if (da51,da1,0))) ) d51,
  1099. concat(sum(da52)-sum(if (da52,da51,0)),',',sum(da52)/sum(if (da52,cost,0)),',', (sum(da52)-sum(if (da52,da51,0)))/sum(if (da52,cost,0)),',',if(sum(if (da52,da1,0))=0,1,sum(da52)/sum(if (da52,da1,0))) ) d52,
  1100. concat(sum(da53)-sum(if (da53,da52,0)),',',sum(da53)/sum(if (da53,cost,0)),',', (sum(da53)-sum(if (da53,da52,0)))/sum(if (da53,cost,0)),',',if(sum(if (da53,da1,0))=0,1,sum(da53)/sum(if (da53,da1,0))) ) d53,
  1101. concat(sum(da54)-sum(if (da54,da53,0)),',',sum(da54)/sum(if (da54,cost,0)),',', (sum(da54)-sum(if (da54,da53,0)))/sum(if (da54,cost,0)),',',if(sum(if (da54,da1,0))=0,1,sum(da54)/sum(if (da54,da1,0))) ) d54,
  1102. concat(sum(da55)-sum(if (da55,da54,0)),',',sum(da55)/sum(if (da55,cost,0)),',', (sum(da55)-sum(if (da55,da54,0)))/sum(if (da55,cost,0)),',',if(sum(if (da55,da1,0))=0,1,sum(da55)/sum(if (da55,da1,0))) ) d55,
  1103. concat(sum(da56)-sum(if (da56,da55,0)),',',sum(da56)/sum(if (da56,cost,0)),',', (sum(da56)-sum(if (da56,da55,0)))/sum(if (da56,cost,0)),',',if(sum(if (da56,da1,0))=0,1,sum(da56)/sum(if (da56,da1,0))) ) d56,
  1104. concat(sum(da57)-sum(if (da57,da56,0)),',',sum(da57)/sum(if (da57,cost,0)),',', (sum(da57)-sum(if (da57,da56,0)))/sum(if (da57,cost,0)),',',if(sum(if (da57,da1,0))=0,1,sum(da57)/sum(if (da57,da1,0))) ) d57,
  1105. concat(sum(da58)-sum(if (da58,da57,0)),',',sum(da58)/sum(if (da58,cost,0)),',', (sum(da58)-sum(if (da58,da57,0)))/sum(if (da58,cost,0)),',',if(sum(if (da58,da1,0))=0,1,sum(da58)/sum(if (da58,da1,0))) ) d58,
  1106. concat(sum(da59)-sum(if (da59,da58,0)),',',sum(da59)/sum(if (da59,cost,0)),',', (sum(da59)-sum(if (da59,da58,0)))/sum(if (da59,cost,0)),',',if(sum(if (da59,da1,0))=0,1,sum(da59)/sum(if (da59,da1,0))) ) d59,
  1107. concat(sum(da60)-sum(if (da60,da59,0)),',',sum(da60)/sum(if (da60,cost,0)),',', (sum(da60)-sum(if (da60,da59,0)))/sum(if (da60,cost,0)),',',if(sum(if (da60,da1,0))=0,1,sum(da60)/sum(if (da60,da1,0))) ) d60,
  1108. concat(sum(dm3)-sum(if (dm3,da60,0)) ,',' ,sum(dm3)/sum(if(dm3,cost,0)) ,',', (sum(dm3)-sum(if (dm3,da60,0)))/sum(if(dm3,cost,0)) ,',' ,if(sum(if(dm3,da1,0))=0,1,sum(dm3)/sum(if(dm3,da1,0))) ) m3,
  1109. concat(sum(dm4)-sum(if (dm4,dm3,0)),',',sum(dm4)/sum(if (dm4,cost,0)),',', (sum(dm4)-sum(if (dm4,dm3,0)))/sum(if (dm4,cost,0)),',',if(sum(if (dm4,da1,0))=0,1,sum(dm4)/sum(if (dm4,da1,0))) ) m4,
  1110. concat(sum(dm5)-sum(if (dm5,dm4,0)),',',sum(dm5)/sum(if (dm5,cost,0)),',', (sum(dm5)-sum(if (dm5,dm4,0)))/sum(if (dm5,cost,0)),',',if(sum(if (dm5,da1,0))=0,1,sum(dm5)/sum(if (dm5,da1,0))) ) m5
  1111. from ({sql}) a
  1112. """
  1113. data, total, total_data = getLimitSumData(db.dm, sql, sumsql, page, page_size)
  1114. def parse(key_str):
  1115. if type(key_str) is not str:
  1116. key_str = key_str.decode('utf-8')
  1117. li = key_str.split(',')
  1118. li[0] = round(float(li[0]), 2)
  1119. li[1] = round(float(li[1]), 4)
  1120. li[2] = round(float(li[2]), 4)
  1121. li[3] = round(float(li[3]), 2)
  1122. return dict(zip(['order', 'roi', 'add', 'mult'], li))
  1123. for x in total_data.keys():
  1124. if x in ['d1', 'd2', 'd3', 'd4', 'd5', 'd6', 'd7', 'd8', 'd9', 'd10', 'd11', 'd12', 'd13', 'd14', 'd15', 'd16',
  1125. 'd17', 'd18',
  1126. 'd19', 'd20', 'd21', 'd22', 'd23', 'd24', 'd25', 'd26', 'd27', 'd28', 'd29', 'd30', 'd31', 'd32',
  1127. 'd33', 'd34', 'd35', 'd36', 'd37', 'd38',
  1128. 'd39', 'd40', 'd41', 'd42', 'd43', 'd44', 'd45', 'd46', 'd47', 'd48', 'd49', 'd50', 'd51', 'd52',
  1129. 'd53', 'd54', 'd55', 'd56', 'd57', 'd58', 'd59',
  1130. 'd60', 'm3', 'm4', 'm5']:
  1131. total_data[x] = parse(total_data[x]) if total_data[x] is not None else {}
  1132. for i in data:
  1133. for x in i:
  1134. if x in ['d1', 'd2', 'd3', 'd4', 'd5', 'd6', 'd7', 'd8', 'd9', 'd10', 'd11', 'd12', 'd13', 'd14', 'd15',
  1135. 'd16', 'd17', 'd18',
  1136. 'd19', 'd20', 'd21', 'd22', 'd23', 'd24', 'd25', 'd26', 'd27', 'd28', 'd29', 'd30', 'd31', 'd32',
  1137. 'd33', 'd34', 'd35', 'd36', 'd37', 'd38',
  1138. 'd39', 'd40', 'd41', 'd42', 'd43', 'd44', 'd45', 'd46', 'd47', 'd48', 'd49', 'd50', 'd51', 'd52',
  1139. 'd53', 'd54', 'd55', 'd56', 'd57', 'd58', 'd59',
  1140. 'd60', 'm3', 'm4', 'm5']:
  1141. i[x] = parse(i[x]) if i[x] is not None else {}
  1142. return data, total, total_data
  1143. def get_channel_summary(user_id, channel, pitcher, page, page_size, order_by, order, state, location, start, end):
  1144. db = MysqlUtils()
  1145. if user_id in super_auth(): # 超级数据权限
  1146. op = ''
  1147. else:
  1148. channel_li = UserAuthUtils.get_auth_channel(user_id)
  1149. print(channel_li.__len__())
  1150. if len(channel_li) == 0:
  1151. return None, None, None
  1152. elif len(channel_li) == 1:
  1153. op = f" and a.channel = '{channel_li[0]}'"
  1154. else:
  1155. op = f" and a.channel in {tuple(channel_li)}"
  1156. op1 = f" and a.channel='{channel}'" if channel else ''
  1157. op2 = f" and pitcher='{pitcher}'" if pitcher else ''
  1158. op5 = f" and state='{state}'" if state else ''
  1159. op6 = f" and a.dt>='{start}'" if start else ''
  1160. op7 = f" and a.dt<='{end}'" if end else ''
  1161. sql = f"""SELECT channel,
  1162. if(end>date_sub(now(),interval 10 day),'在投','停投') state,
  1163. start,end,
  1164. total_cost,total_amount,
  1165. total_amount-total_cost profit,
  1166. if(total_cost=0,0,round(total_amount/total_cost,4)) roi,
  1167. follow_user,
  1168. if(follow_user=0,0,round(total_cost/follow_user,2)) follow_per_cost,
  1169. order_user,
  1170. if(follow_user=0,0,round(order_user/follow_user,4)) order_tran_rate,
  1171. if(order_user=0,0,round(total_cost/order_user,2)) order_tran_cost,
  1172. td_amount,yd_amount,byd_amount
  1173. FROM
  1174. (select
  1175. channel,
  1176. min(if(cost>0,dt,null)) start,
  1177. max(if(cost>0,dt,null)) end,
  1178. sum(cost) total_cost,
  1179. sum(reg_order_amount) total_amount,
  1180. sum(follow_user) follow_user,
  1181. sum(reg_order_user) order_user,
  1182. sum(ba1) td_amount,sum(ba2) yd_amount,sum(ba3) byd_amount
  1183. from dw_channel a
  1184. left join dw_channel_amount_daily_reverse b using (dt,channel)
  1185. left join quchen_text.advertiser_vx c on a.channel = c.name
  1186. where 1=1 and a.dt>=c.start_date
  1187. {op} {op1} {op2} {op6} {op7} GROUP BY a.channel) x
  1188. having 1=1 {op5} ORDER BY {order_by} {order}
  1189. """
  1190. print(sql)
  1191. sumsql = f"""select '总计' channel,
  1192. sum(total_cost) total_cost,
  1193. sum(total_amount) total_amount,sum(profit) profit,
  1194. round(sum(total_amount)/sum(total_cost),4) roi,
  1195. sum(follow_user) follow_user,
  1196. sum(order_user) order_user,
  1197. round(sum(total_cost)/sum(follow_user),2) follow_per_cost,
  1198. round(sum(order_user)/sum(follow_user),4) order_tran_rate,
  1199. round(sum(total_cost)/sum(order_user),2) order_tran_cost ,
  1200. sum(td_amount) td_amount,sum(yd_amount) yd_amount,sum(byd_amount) byd_amount
  1201. from ({sql}) a
  1202. """
  1203. return getLimitSumData(db.dm, sql, sumsql, page, page_size)
  1204. def get_pitcher_channel_summary(user_id, channel, pitcher, page, page_size, order_by, order, state, location, start,
  1205. end):
  1206. """投手投放号"""
  1207. db = MysqlUtils()
  1208. if user_id in super_auth(): # 超级数据权限
  1209. op = ''
  1210. else:
  1211. user_name_li = UserAuthUtils.get_auth_user(user_id)
  1212. if len(user_name_li) == 1:
  1213. op = f" and pitcher='{user_name_li[0]}'"
  1214. else:
  1215. op = f" and pitcher in {tuple(user_name_li)}"
  1216. op1 = f" and a.channel='{channel}'" if channel else ''
  1217. op2 = f" and pitcher='{pitcher}'" if pitcher else ''
  1218. op4 = f" and location='{location}' " if location else ''
  1219. op5 = f" and state='{state}'" if state else ''
  1220. op6 = f" and a.dt>='{start}'" if start else ''
  1221. op7 = f" and a.dt<='{end}'" if end else ''
  1222. sql = f"""SELECT channel,
  1223. if(end>date_sub(now(),interval 10 day),'在投','停投') state,
  1224. location,start,end,total_cost,total_amount,
  1225. total_amount-total_cost profit,
  1226. if(total_cost=0,0,round(total_amount/total_cost,4)) roi,
  1227. follow_user,
  1228. if(follow_user=0,0,round(total_cost/follow_user,2)) follow_per_cost,
  1229. order_user,
  1230. if(follow_user=0,0,round(order_user/follow_user,4)) order_tran_rate,
  1231. if(order_user=0,0,round(total_cost/order_user,2)) order_tran_cost,
  1232. pitcher,stage,td_amount,yd_amount,byd_amount
  1233. FROM
  1234. (select
  1235. channel,pitcher,stage,
  1236. type location,
  1237. min(if(cost>0,dt,null)) start,
  1238. max(if(cost>0,dt,null)) end,
  1239. sum(cost) total_cost,
  1240. sum(reg_order_amount) total_amount,
  1241. sum(follow_user) follow_user,
  1242. sum(reg_order_user) order_user,
  1243. sum(ba1) td_amount,sum(ba2) yd_amount,sum(ba3) byd_amount
  1244. from dw_channel a
  1245. left join dw_channel_amount_daily_reverse b using (dt,channel)
  1246. where 1=1 {op} {op1} {op2} {op6} {op7} GROUP BY a.channel,type,pitcher,stage) x
  1247. having 1=1 {op4} {op5} ORDER BY {order_by} {order}
  1248. """
  1249. print(sql)
  1250. sumsql = f"""select '总计' channel,
  1251. sum(total_cost) total_cost,
  1252. sum(total_amount) total_amount,sum(profit) profit,
  1253. round(sum(total_amount)/sum(total_cost),4) roi,
  1254. sum(follow_user) follow_user,
  1255. sum(order_user) order_user,
  1256. round(sum(total_cost)/sum(follow_user),2) follow_per_cost,
  1257. round(sum(order_user)/sum(follow_user),4) order_tran_rate,
  1258. round(sum(total_cost)/sum(order_user),2) order_tran_cost ,
  1259. sum(td_amount) td_amount,sum(yd_amount) yd_amount,sum(byd_amount) byd_amount
  1260. from ({sql}) a
  1261. """
  1262. return getLimitSumData(db.dm, sql, sumsql, page, page_size)
  1263. def get_pitcher_trend(pitcher, start=None, end=None, page=None, page_size=None, order_by=None, order=None):
  1264. db = MysqlUtils()
  1265. op1 = f" and pitcher='{pitcher}'"
  1266. op2 = f" and dt>='{start}' " if start else ''
  1267. op3 = f" and dt<='{end}' " if end else ''
  1268. op4 = f" order by {order_by} {order}" if order_by and order else ''
  1269. sql = f"""select dt,pitcher,
  1270. reg_num,create_user_num,
  1271. first_order_user, -- 新增付费人数
  1272. round(cost/first_order_user,2) first_order_cost, -- 新增付费成本
  1273. round(cost/reg_num,2) create_user_per_cost, -- 新注册用户平均付费
  1274. round(first_order_amount/first_order_user,2) ARPU, -- 新增付费ARPU
  1275. round(first_order_user/reg_num,4) first_order_rate, -- 新增付费率
  1276. round(reg_amount/reg_order_user,2) order_ARPU, -- 付费ARPU
  1277. hundred_user_num, -- 单日付费100+用户数
  1278. round(cost/hundred_user_num,2) hundred_user_num_cost , -- 单日付费100+用户付费成本
  1279. reg_order_user , -- 至今付费人数
  1280. reg_order_count, -- 至今付费次数
  1281. round(cost/create_user_num,2) create_user_num_cost, -- 新增创角单价
  1282. round(cost/reg_order_user,2) reg_order_user_cost , -- 至今付费单价
  1283. cost,
  1284. reg_amount,first_order_amount,
  1285. d1 first_amount,
  1286. round(d1/cost,4) first_roi,
  1287. round(reg_amount/cost,4) roi,
  1288. d7 reg_amount7,
  1289. round(d7/cost,4) roi7,
  1290. d30 reg_amount30,
  1291. round(d30/cost,4) roi30,
  1292. reg_amount-cost profit,
  1293. inva_cost expect_profit,
  1294. annual_expect_profit,
  1295. CONCAT(d1,",",0,',',round(d1/cost,4),',',1) d1,
  1296. CONCAT(d2-d1,",",round((d2-d1)/cost,4),',',round(d2/cost,4),',',d2/d1) d2,
  1297. CONCAT(d3-d2,",",round((d3-d2)/cost,4),',',round(d3/cost,4),',',d3/d1) d3,
  1298. CONCAT(d4-d3,",",round((d4-d3)/cost,4),',',round(d4/cost,4),',',d4/d1) d4,
  1299. CONCAT(d5-d4,",",round((d5-d4)/cost,4),',',round(d5/cost,4),',',d5/d1) d5,
  1300. CONCAT(d6-d5,",",round((d6-d5)/cost,4),',',round(d6/cost,4),',',d6/d1) d6,
  1301. CONCAT(d7-d6,",",round((d7-d6)/cost,4),',',round(d7/cost,4),',',d7/d1) d7,
  1302. CONCAT(d8-d7,",",round((d8-d7)/cost,4),',',round(d8/cost,4),',',d8/d1) d8,
  1303. CONCAT(d9-d8,",",round((d9-d8)/cost,4),',',round(d9/cost,4),',',d9/d1) d9,
  1304. CONCAT(d10-d9,",",round((d10-d9)/cost,4),',',round(d10/cost,4),',',d10/d1) d10,
  1305. CONCAT(d11-d10,",",round((d11-d10)/cost,4),',',round(d11/cost,4),',',d11/d1) d11,
  1306. CONCAT(d12-d11,",",round((d12-d11)/cost,4),',',round(d12/cost,4),',',d12/d1) d12,
  1307. CONCAT(d13-d12,",",round((d13-d12)/cost,4),',',round(d13/cost,4),',',d13/d1) d13,
  1308. CONCAT(d14-d13,",",round((d14-d13)/cost,4),',',round(d14/cost,4),',',d14/d1) d14,
  1309. CONCAT(d15-d14,",",round((d15-d14)/cost,4),',',round(d15/cost,4),',',d15/d1) d15,
  1310. CONCAT(d16-d15,",",round((d16-d15)/cost,4),',',round(d16/cost,4),',',d16/d1) d16,
  1311. CONCAT(d17-d16,",",round((d17-d16)/cost,4),',',round(d17/cost,4),',',d17/d1) d17,
  1312. CONCAT(d18-d17,",",round((d18-d17)/cost,4),',',round(d18/cost,4),',',d18/d1) d18,
  1313. CONCAT(d19-d18,",",round((d19-d18)/cost,4),',',round(d19/cost,4),',',d19/d1) d19,
  1314. CONCAT(d20-d19,",",round((d20-d19)/cost,4),',',round(d20/cost,4),',',d20/d1) d20,
  1315. CONCAT(d21-d20,",",round((d21-d20)/cost,4),',',round(d21/cost,4),',',d21/d1) d21,
  1316. CONCAT(d22-d21,",",round((d22-d21)/cost,4),',',round(d22/cost,4),',',d22/d1) d22,
  1317. CONCAT(d23-d22,",",round((d23-d22)/cost,4),',',round(d23/cost,4),',',d23/d1) d23,
  1318. CONCAT(d24-d23,",",round((d24-d23)/cost,4),',',round(d24/cost,4),',',d24/d1) d24,
  1319. CONCAT(d25-d24,",",round((d25-d24)/cost,4),',',round(d25/cost,4),',',d25/d1) d25,
  1320. CONCAT(d26-d25,",",round((d26-d25)/cost,4),',',round(d26/cost,4),',',d26/d1) d26,
  1321. CONCAT(d27-d26,",",round((d27-d26)/cost,4),',',round(d27/cost,4),',',d27/d1) d27,
  1322. CONCAT(d28-d27,",",round((d28-d27)/cost,4),',',round(d28/cost,4),',',d28/d1) d28,
  1323. CONCAT(d29-d28,",",round((d29-d28)/cost,4),',',round(d29/cost,4),',',d29/d1) d29,
  1324. CONCAT(d30-d29,",",round((d30-d29)/cost,4),',',round(d30/cost,4),',',d30/d1) d30,
  1325. d1 as da1,d2 as da2,d3 as da3,d4 as da4,d5 as da5,d6 as da6,d7 as da7,d8 as da8,d9 as da9,d10 as da10,
  1326. d11 as da11,d12 as da12,d13 as da13,d14 as da14,d15 as da15,d16 as da16,d17 as da17,d18 as da18,d19 as da19,
  1327. d20 as da20,d21 as da21,d22 as da22,d23 as da23,d24 as da24,d25 as da25,d26 as da26,d27 as da27,d28 as da28,
  1328. d29 as da29,d30 as da30
  1329. from dw_pitcher_trend where 1=1 {op1} {op2} {op3} {op4}
  1330. """
  1331. sumSql = f"""select concat(date_format(min(dt),'%Y/%m/%d'),'~',date_format(max(dt),'%Y/%m/%d')) dt,sum(cost) cost,
  1332. sum(reg_num) reg_num,
  1333. sum(create_user_num) create_user_num,
  1334. sum(reg_amount) reg_amount,
  1335. round(sum(first_order_user),2) first_order_user, -- 新增付费人数
  1336. round(sum(cost)/sum(first_order_user),2) first_order_cost, -- 新增付费成本
  1337. round(sum(cost)/sum(reg_num),2) create_user_per_cost, -- 新注册用户平均付费
  1338. round(sum(first_order_amount)/sum(first_order_user),2) ARPU, -- 新增付费ARPU
  1339. round(sum(first_order_user)/sum(reg_num),4) first_order_rate, -- 新增付费率
  1340. round(sum(reg_amount)/sum(reg_order_user),2) order_ARPU, -- 付费ARPU
  1341. sum(hundred_user_num) hundred_user_num, -- 单日付费100+用户数
  1342. round(sum(cost)/sum(hundred_user_num),2) hundred_user_num_cost, -- 单日付费100+用户付费成本
  1343. sum(reg_order_user) reg_order_user, -- 至今付费人数
  1344. sum(reg_order_count) reg_order_count, -- 至今付费次数
  1345. round(sum(cost)/sum(create_user_num),2) create_user_num_cost, -- 新增创角单价
  1346. round(sum(cost)/sum(reg_order_user),2) reg_order_user_cost , -- 至今付费单价
  1347. round(sum(first_amount)/sum(cost),4) first_roi,
  1348. round(sum(reg_amount)/sum(cost),4) roi,
  1349. sum(profit) profit,
  1350. sum(first_amount) first_amount,
  1351. round(sum(reg_amount7)/sum(cost),4) roi7,
  1352. sum(reg_amount30) reg_amount30,
  1353. round(sum(reg_amount30)/sum(cost),4) roi30,
  1354. sum(expect_profit) expect_profit,
  1355. sum(annual_expect_profit) annual_expect_profit,
  1356. concat(sum(da1),',',sum(da1)/sum(cost),',', 0,',',1) d1,
  1357. concat(sum(da2)-sum(if (da2,da1,0)),',',sum(da2)/sum(if (da2,cost,0)),',', (sum(da2)-sum(if (da2,da1,0)))/sum(if (da2,cost,0)),',',if(sum(if (da2,da1,0))=0,1,sum(da2)/sum(if (da2,da1,0))) ) d2,
  1358. concat(sum(da3)-sum(if (da3,da2,0)),',',sum(da3)/sum(if (da3,cost,0)),',', (sum(da3)-sum(if (da3,da2,0)))/sum(if (da3,cost,0)),',',if(sum(if (da3,da1,0))=0,1,sum(da3)/sum(if (da3,da1,0))) ) d3,
  1359. concat(sum(da4)-sum(if (da4,da3,0)),',',sum(da4)/sum(if (da4,cost,0)),',', (sum(da4)-sum(if (da4,da3,0)))/sum(if (da4,cost,0)),',',if(sum(if (da4,da1,0))=0,1,sum(da4)/sum(if (da4,da1,0))) ) d4,
  1360. concat(sum(da5)-sum(if (da5,da4,0)),',',sum(da5)/sum(if (da5,cost,0)),',', (sum(da5)-sum(if (da5,da4,0)))/sum(if (da5,cost,0)),',',if(sum(if (da5,da1,0))=0,1,sum(da5)/sum(if (da5,da1,0))) ) d5,
  1361. concat(sum(da6)-sum(if (da6,da5,0)),',',sum(da6)/sum(if (da6,cost,0)),',', (sum(da6)-sum(if (da6,da5,0)))/sum(if (da6,cost,0)),',',if(sum(if (da6,da1,0))=0,1,sum(da6)/sum(if (da6,da1,0))) ) d6,
  1362. concat(sum(da7)-sum(if (da7,da6,0)),',',sum(da7)/sum(if (da7,cost,0)),',', (sum(da7)-sum(if (da7,da6,0)))/sum(if (da7,cost,0)),',',if(sum(if (da7,da1,0))=0,1,sum(da7)/sum(if (da7,da1,0))) ) d7,
  1363. concat(sum(da8)-sum(if (da8,da7,0)),',',sum(da8)/sum(if (da8,cost,0)),',', (sum(da8)-sum(if (da8,da7,0)))/sum(if (da8,cost,0)),',',if(sum(if (da8,da1,0))=0,1,sum(da8)/sum(if (da8,da1,0))) ) d8,
  1364. concat(sum(da9)-sum(if (da9,da8,0)),',',sum(da9)/sum(if (da9,cost,0)),',', (sum(da9)-sum(if (da9,da8,0)))/sum(if (da9,cost,0)),',',if(sum(if (da9,da1,0))=0,1,sum(da9)/sum(if (da9,da1,0))) ) d9,
  1365. concat(sum(da10)-sum(if (da10,da9,0)),',',sum(da10)/sum(if (da10,cost,0)),',', (sum(da10)-sum(if (da10,da9,0)))/sum(if (da10,cost,0)),',',if(sum(if (da10,da1,0))=0,1,sum(da10)/sum(if (da10,da1,0))) ) d10,
  1366. concat(sum(da11)-sum(if (da11,da10,0)),',',sum(da11)/sum(if (da11,cost,0)),',', (sum(da11)-sum(if (da11,da10,0)))/sum(if (da11,cost,0)),',',if(sum(if (da11,da1,0))=0,1,sum(da11)/sum(if (da11,da1,0))) ) d11,
  1367. concat(sum(da12)-sum(if (da12,da11,0)),',',sum(da12)/sum(if (da12,cost,0)),',', (sum(da12)-sum(if (da12,da11,0)))/sum(if (da12,cost,0)),',',if(sum(if (da12,da1,0))=0,1,sum(da12)/sum(if (da12,da1,0))) ) d12,
  1368. concat(sum(da13)-sum(if (da13,da12,0)),',',sum(da13)/sum(if (da13,cost,0)),',', (sum(da13)-sum(if (da13,da12,0)))/sum(if (da13,cost,0)),',',if(sum(if (da13,da1,0))=0,1,sum(da13)/sum(if (da13,da1,0))) ) d13,
  1369. concat(sum(da14)-sum(if (da14,da13,0)),',',sum(da14)/sum(if (da14,cost,0)),',', (sum(da14)-sum(if (da14,da13,0)))/sum(if (da14,cost,0)),',',if(sum(if (da14,da1,0))=0,1,sum(da14)/sum(if (da14,da1,0))) ) d14,
  1370. concat(sum(da15)-sum(if (da15,da14,0)),',',sum(da15)/sum(if (da15,cost,0)),',', (sum(da15)-sum(if (da15,da14,0)))/sum(if (da15,cost,0)),',',if(sum(if (da15,da1,0))=0,1,sum(da15)/sum(if (da15,da1,0))) ) d15,
  1371. concat(sum(da16)-sum(if (da16,da15,0)),',',sum(da16)/sum(if (da16,cost,0)),',', (sum(da16)-sum(if (da16,da15,0)))/sum(if (da16,cost,0)),',',if(sum(if (da16,da1,0))=0,1,sum(da16)/sum(if (da16,da1,0))) ) d16,
  1372. concat(sum(da17)-sum(if (da17,da16,0)),',',sum(da17)/sum(if (da17,cost,0)),',', (sum(da17)-sum(if (da17,da16,0)))/sum(if (da17,cost,0)),',',if(sum(if (da17,da1,0))=0,1,sum(da17)/sum(if (da17,da1,0))) ) d17,
  1373. concat(sum(da18)-sum(if (da18,da17,0)),',',sum(da18)/sum(if (da18,cost,0)),',', (sum(da18)-sum(if (da18,da17,0)))/sum(if (da18,cost,0)),',',if(sum(if (da18,da1,0))=0,1,sum(da18)/sum(if (da18,da1,0))) ) d18,
  1374. concat(sum(da19)-sum(if (da19,da18,0)),',',sum(da19)/sum(if (da19,cost,0)),',', (sum(da19)-sum(if (da19,da18,0)))/sum(if (da19,cost,0)),',',if(sum(if (da19,da1,0))=0,1,sum(da19)/sum(if (da19,da1,0))) ) d19,
  1375. concat(sum(da20)-sum(if (da20,da19,0)),',',sum(da20)/sum(if (da20,cost,0)),',', (sum(da20)-sum(if (da20,da19,0)))/sum(if (da20,cost,0)),',',if(sum(if (da20,da1,0))=0,1,sum(da20)/sum(if (da20,da1,0))) ) d20,
  1376. concat(sum(da21)-sum(if (da21,da20,0)),',',sum(da21)/sum(if (da21,cost,0)),',', (sum(da21)-sum(if (da21,da20,0)))/sum(if (da21,cost,0)),',',if(sum(if (da21,da1,0))=0,1,sum(da21)/sum(if (da21,da1,0))) ) d21,
  1377. concat(sum(da22)-sum(if (da22,da21,0)),',',sum(da22)/sum(if (da22,cost,0)),',', (sum(da22)-sum(if (da22,da21,0)))/sum(if (da22,cost,0)),',',if(sum(if (da22,da1,0))=0,1,sum(da22)/sum(if (da22,da1,0))) ) d22,
  1378. concat(sum(da23)-sum(if (da23,da22,0)),',',sum(da23)/sum(if (da23,cost,0)),',', (sum(da23)-sum(if (da23,da22,0)))/sum(if (da23,cost,0)),',',if(sum(if (da23,da1,0))=0,1,sum(da23)/sum(if (da23,da1,0))) ) d23,
  1379. concat(sum(da24)-sum(if (da24,da23,0)),',',sum(da24)/sum(if (da24,cost,0)),',', (sum(da24)-sum(if (da24,da23,0)))/sum(if (da24,cost,0)),',',if(sum(if (da24,da1,0))=0,1,sum(da24)/sum(if (da24,da1,0))) ) d24,
  1380. concat(sum(da25)-sum(if (da25,da24,0)),',',sum(da25)/sum(if (da25,cost,0)),',', (sum(da25)-sum(if (da25,da24,0)))/sum(if (da25,cost,0)),',',if(sum(if (da25,da1,0))=0,1,sum(da25)/sum(if (da25,da1,0))) ) d25,
  1381. concat(sum(da26)-sum(if (da26,da25,0)),',',sum(da26)/sum(if (da26,cost,0)),',', (sum(da26)-sum(if (da26,da25,0)))/sum(if (da26,cost,0)),',',if(sum(if (da26,da1,0))=0,1,sum(da26)/sum(if (da26,da1,0))) ) d26,
  1382. concat(sum(da27)-sum(if (da27,da26,0)),',',sum(da27)/sum(if (da27,cost,0)),',', (sum(da27)-sum(if (da27,da26,0)))/sum(if (da27,cost,0)),',',if(sum(if (da27,da1,0))=0,1,sum(da27)/sum(if (da27,da1,0))) ) d27,
  1383. concat(sum(da28)-sum(if (da28,da27,0)),',',sum(da28)/sum(if (da28,cost,0)),',', (sum(da28)-sum(if (da28,da27,0)))/sum(if (da28,cost,0)),',',if(sum(if (da28,da1,0))=0,1,sum(da28)/sum(if (da28,da1,0))) ) d28,
  1384. concat(sum(da29)-sum(if (da29,da28,0)),',',sum(da29)/sum(if (da29,cost,0)),',', (sum(da29)-sum(if (da29,da28,0)))/sum(if (da29,cost,0)),',',if(sum(if (da29,da1,0))=0,1,sum(da29)/sum(if (da29,da1,0))) ) d29,
  1385. concat(sum(da30)-sum(if (da30,da29,0)),',',sum(da30)/sum(if (da30,cost,0)),',', (sum(da30)-sum(if (da30,da29,0)))/sum(if (da30,cost,0)),',',if(sum(if (da30,da1,0))=0,1,sum(da30)/sum(if (da30,da1,0))) ) d30
  1386. from ({sql}) a
  1387. """
  1388. data, total, total_data = getLimitSumData(db.dm, sql, sumSql, page, page_size)
  1389. print(data)
  1390. def parse(key_str, is_total=False):
  1391. if type(key_str) is not str:
  1392. key_str = key_str.decode('utf-8')
  1393. li = key_str.split(',')
  1394. li[0] = round(float(li[0]), 2)
  1395. li[1] = round(float(li[1]), 4)
  1396. li[2] = round(float(li[2]), 4)
  1397. li[3] = round(float(li[3]), 2)
  1398. if is_total:
  1399. return dict(zip(['amount', 'roi', 'add', 'mult'], li))
  1400. else:
  1401. return dict(zip(['amount', 'add', 'roi', 'mult'], li))
  1402. for k, v in total_data.items():
  1403. if k in ['d1', 'd2', 'd3', 'd4', 'd5', 'd6', 'd7', 'd8', 'd9', 'd10',
  1404. 'd11', 'd12', 'd13', 'd14', 'd15', 'd16', 'd17', 'd18', 'd19', 'd20', 'd21', 'd22', 'd23', 'd24',
  1405. 'd25', 'd26', 'd27', 'd28', 'd29', 'd30']:
  1406. total_data[k] = parse(v, is_total=True) if v else {}
  1407. for i in data:
  1408. for k, v in i.items():
  1409. if k in ['d1', 'd2', 'd3', 'd4', 'd5', 'd6', 'd7', 'd8', 'd9', 'd10',
  1410. 'd11', 'd12', 'd13', 'd14', 'd15', 'd16', 'd17', 'd18', 'd19', 'd20', 'd21', 'd22', 'd23', 'd24',
  1411. 'd25', 'd26', 'd27', 'd28', 'd29', 'd30']:
  1412. i[k] = parse(v) if v else {}
  1413. return data, total, total_data
  1414. if __name__ == '__main__':
  1415. get_pitcher_trend(pitcher="陈凯")