Dao.go 87 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339
  1. package manage
  2. import (
  3. "demo/configs"
  4. "demo/data/domain"
  5. "demo/data/domain/vo"
  6. )
  7. func GetArticleById(id int64) (domain.Article, error) {
  8. var article domain.Article
  9. _, err := configs.Engine.Table("article").Where("id = ?", id).Get(&article)
  10. if err != nil {
  11. return article, err
  12. }
  13. return article, nil
  14. }
  15. func GetArticleListInId(ids []int64) ([]domain.Article, error) {
  16. rows, err := configs.Engine.Table("article").In("id", ids).Rows(&domain.Article{})
  17. if err != nil {
  18. return make([]domain.Article, 0), err
  19. }
  20. defer rows.Close()
  21. var list []domain.Article
  22. for rows.Next() {
  23. var u domain.Article
  24. rows.Scan(&u)
  25. list = append(list, u)
  26. }
  27. return list, nil
  28. }
  29. func GetArticleList(article domain.Article, pageNum, pageSize int) (vo.BaseListVo, error) {
  30. var arr []domain.Article
  31. Count, err := configs.Engine.Table("article").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &article)
  32. var vo vo.BaseListVo
  33. if err != nil {
  34. return vo, err
  35. }
  36. if err != nil {
  37. return vo, err
  38. }
  39. vo.PageNum = pageNum
  40. vo.PageSize = pageSize
  41. vo.List = make([]any, len(arr))
  42. for i, v := range arr {
  43. vo.List[i] = v
  44. }
  45. vo.Total = int(Count)
  46. return vo, nil
  47. }
  48. func Get2ArticleList(query domain.ArticleQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  49. var arr []domain.Article
  50. session := configs.Engine.Table("article").Limit(pageSize, (pageNum-1)*pageSize)
  51. if query.Id != 0{
  52. session.Where("id = ?", query.Id)
  53. }
  54. if query.ArticleTitle != ""{
  55. session.Where("article_title like ?", "%"+query.ArticleTitle+"%")
  56. }
  57. if query.ArticleContent != ""{
  58. session.Where("article_content like ?", "%"+query.ArticleContent+"%")
  59. }
  60. if query.State != ""{
  61. session.Where("state = ?", query.State)
  62. }
  63. if query.ArticleTagIds != ""{
  64. session.Where("article_tag_ids = ?", query.ArticleTagIds)
  65. }
  66. if query.ArticleTopicId != 0{
  67. session.Where("article_topic_id = ?", query.ArticleTopicId)
  68. }
  69. if query.Image != ""{
  70. session.Where("image = ?", query.Image)
  71. }
  72. if query.PublishTime != ""{
  73. session.Where("publish_time = ?", query.PublishTime)
  74. }
  75. if query.EyeFill != 0{
  76. session.Where("eye_fill = ?", query.EyeFill)
  77. }
  78. if query.LikeCount != 0{
  79. session.Where("like_count = ?", query.LikeCount)
  80. }
  81. if query.CreateBy != ""{
  82. session.Where("create_by = ?", query.CreateBy)
  83. }
  84. if query.CreateTime != ""{
  85. session.Where("create_time = ?", query.CreateTime)
  86. }
  87. if query.UpdateBy != ""{
  88. session.Where("update_by = ?", query.UpdateBy)
  89. }
  90. if query.UpdateTime != ""{
  91. session.Where("update_time = ?", query.UpdateTime)
  92. }
  93. if query.ArticleDesc != ""{
  94. session.Where("article_desc = ?", query.ArticleDesc)
  95. }
  96. Count, err := session.FindAndCount(&arr, &query)
  97. var vo vo.BaseListVo
  98. if err != nil {
  99. return vo, err
  100. }
  101. if err != nil {
  102. return vo, err
  103. }
  104. vo.PageNum = pageNum
  105. vo.PageSize = pageSize
  106. vo.List = make([]any, len(arr))
  107. for i, v := range arr {
  108. vo.List[i] = v
  109. }
  110. vo.Total = int(Count)
  111. return vo, nil
  112. }
  113. func SaveArticle(article *domain.Article) (domain.Article, error) {
  114. _, err := configs.Engine.Table("article").Insert(&article)
  115. if err != nil {
  116. return *article, err
  117. }
  118. return *article, nil
  119. }
  120. func SetArticle(articleMap map[string]interface{}, id int64) (domain.Article, bool, error) {
  121. var article domain.Article
  122. _, err := configs.Engine.Table("article").Where("id = ?", id).Update(articleMap)
  123. if err != nil {
  124. return article, false, err
  125. }
  126. return article, true, nil
  127. }
  128. func DeleteArticle(id int64) bool {
  129. var article domain.Article
  130. i, err := configs.Engine.Table("article").Where("id = ?", id).Delete(&article)
  131. if err != nil {
  132. return false
  133. }
  134. return i > 0
  135. }
  136. func GetArticleTagById(id int64) (domain.ArticleTag, error) {
  137. var articleTag domain.ArticleTag
  138. _, err := configs.Engine.Table("article_tag").Where("id = ?", id).Get(&articleTag)
  139. if err != nil {
  140. return articleTag, err
  141. }
  142. return articleTag, nil
  143. }
  144. func GetArticleTagListInId(ids []int64) ([]domain.ArticleTag, error) {
  145. rows, err := configs.Engine.Table("article_tag").In("id", ids).Rows(&domain.ArticleTag{})
  146. if err != nil {
  147. return make([]domain.ArticleTag, 0), err
  148. }
  149. defer rows.Close()
  150. var list []domain.ArticleTag
  151. for rows.Next() {
  152. var u domain.ArticleTag
  153. rows.Scan(&u)
  154. list = append(list, u)
  155. }
  156. return list, nil
  157. }
  158. func GetArticleTagList(articleTag domain.ArticleTag, pageNum, pageSize int) (vo.BaseListVo, error) {
  159. var arr []domain.ArticleTag
  160. Count, err := configs.Engine.Table("article_tag").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &articleTag)
  161. var vo vo.BaseListVo
  162. if err != nil {
  163. return vo, err
  164. }
  165. if err != nil {
  166. return vo, err
  167. }
  168. vo.PageNum = pageNum
  169. vo.PageSize = pageSize
  170. vo.List = make([]any, len(arr))
  171. for i, v := range arr {
  172. vo.List[i] = v
  173. }
  174. vo.Total = int(Count)
  175. return vo, nil
  176. }
  177. func Get2ArticleTagList(query domain.ArticleTagQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  178. var arr []domain.ArticleTag
  179. session := configs.Engine.Table("article_tag").Limit(pageSize, (pageNum-1)*pageSize)
  180. if query.Id != 0{
  181. session.Where("id = ?", query.Id)
  182. }
  183. if query.TagName != ""{
  184. session.Where("tag_name = ?", query.TagName)
  185. }
  186. if query.TagDesc != ""{
  187. session.Where("tag_desc = ?", query.TagDesc)
  188. }
  189. if query.TagTextColor != ""{
  190. session.Where("tag_text_color = ?", query.TagTextColor)
  191. }
  192. if query.TagBackgroundColor != ""{
  193. session.Where("tag_background_color = ?", query.TagBackgroundColor)
  194. }
  195. Count, err := session.FindAndCount(&arr, &query)
  196. var vo vo.BaseListVo
  197. if err != nil {
  198. return vo, err
  199. }
  200. if err != nil {
  201. return vo, err
  202. }
  203. vo.PageNum = pageNum
  204. vo.PageSize = pageSize
  205. vo.List = make([]any, len(arr))
  206. for i, v := range arr {
  207. vo.List[i] = v
  208. }
  209. vo.Total = int(Count)
  210. return vo, nil
  211. }
  212. func SaveArticleTag(articleTag *domain.ArticleTag) (domain.ArticleTag, error) {
  213. _, err := configs.Engine.Table("article_tag").Insert(&articleTag)
  214. if err != nil {
  215. return *articleTag, err
  216. }
  217. return *articleTag, nil
  218. }
  219. func SetArticleTag(articleTagMap map[string]interface{}, id int64) (domain.ArticleTag, bool, error) {
  220. var articleTag domain.ArticleTag
  221. _, err := configs.Engine.Table("article_tag").Where("id = ?", id).Update(articleTagMap)
  222. if err != nil {
  223. return articleTag, false, err
  224. }
  225. return articleTag, true, nil
  226. }
  227. func DeleteArticleTag(id int64) bool {
  228. var articleTag domain.ArticleTag
  229. i, err := configs.Engine.Table("article_tag").Where("id = ?", id).Delete(&articleTag)
  230. if err != nil {
  231. return false
  232. }
  233. return i > 0
  234. }
  235. func GetArticleTopicById(id int64) (domain.ArticleTopic, error) {
  236. var articleTopic domain.ArticleTopic
  237. _, err := configs.Engine.Table("article_topic").Where("id = ?", id).Get(&articleTopic)
  238. if err != nil {
  239. return articleTopic, err
  240. }
  241. return articleTopic, nil
  242. }
  243. func GetArticleTopicListInId(ids []int64) ([]domain.ArticleTopic, error) {
  244. rows, err := configs.Engine.Table("article_topic").In("id", ids).Rows(&domain.ArticleTopic{})
  245. if err != nil {
  246. return make([]domain.ArticleTopic, 0), err
  247. }
  248. defer rows.Close()
  249. var list []domain.ArticleTopic
  250. for rows.Next() {
  251. var u domain.ArticleTopic
  252. rows.Scan(&u)
  253. list = append(list, u)
  254. }
  255. return list, nil
  256. }
  257. func GetArticleTopicList(articleTopic domain.ArticleTopic, pageNum, pageSize int) (vo.BaseListVo, error) {
  258. var arr []domain.ArticleTopic
  259. Count, err := configs.Engine.Table("article_topic").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &articleTopic)
  260. var vo vo.BaseListVo
  261. if err != nil {
  262. return vo, err
  263. }
  264. if err != nil {
  265. return vo, err
  266. }
  267. vo.PageNum = pageNum
  268. vo.PageSize = pageSize
  269. vo.List = make([]any, len(arr))
  270. for i, v := range arr {
  271. vo.List[i] = v
  272. }
  273. vo.Total = int(Count)
  274. return vo, nil
  275. }
  276. func Get2ArticleTopicList(query domain.ArticleTopicQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  277. var arr []domain.ArticleTopic
  278. session := configs.Engine.Table("article_topic").Limit(pageSize, (pageNum-1)*pageSize)
  279. if query.Id != 0{
  280. session.Where("id = ?", query.Id)
  281. }
  282. if query.Image != ""{
  283. session.Where("image = ?", query.Image)
  284. }
  285. if query.TopicName != ""{
  286. session.Where("topic_name = ?", query.TopicName)
  287. }
  288. if query.TopicDesc != ""{
  289. session.Where("topic_desc = ?", query.TopicDesc)
  290. }
  291. Count, err := session.FindAndCount(&arr, &query)
  292. var vo vo.BaseListVo
  293. if err != nil {
  294. return vo, err
  295. }
  296. if err != nil {
  297. return vo, err
  298. }
  299. vo.PageNum = pageNum
  300. vo.PageSize = pageSize
  301. vo.List = make([]any, len(arr))
  302. for i, v := range arr {
  303. vo.List[i] = v
  304. }
  305. vo.Total = int(Count)
  306. return vo, nil
  307. }
  308. func SaveArticleTopic(articleTopic *domain.ArticleTopic) (domain.ArticleTopic, error) {
  309. _, err := configs.Engine.Table("article_topic").Insert(&articleTopic)
  310. if err != nil {
  311. return *articleTopic, err
  312. }
  313. return *articleTopic, nil
  314. }
  315. func SetArticleTopic(articleTopicMap map[string]interface{}, id int64) (domain.ArticleTopic, bool, error) {
  316. var articleTopic domain.ArticleTopic
  317. _, err := configs.Engine.Table("article_topic").Where("id = ?", id).Update(articleTopicMap)
  318. if err != nil {
  319. return articleTopic, false, err
  320. }
  321. return articleTopic, true, nil
  322. }
  323. func DeleteArticleTopic(id int64) bool {
  324. var articleTopic domain.ArticleTopic
  325. i, err := configs.Engine.Table("article_topic").Where("id = ?", id).Delete(&articleTopic)
  326. if err != nil {
  327. return false
  328. }
  329. return i > 0
  330. }
  331. func GetBackAuthorityById(id int64) (domain.BackAuthority, error) {
  332. var backAuthority domain.BackAuthority
  333. _, err := configs.Engine.Table("back_authority").Where("id = ?", id).Get(&backAuthority)
  334. if err != nil {
  335. return backAuthority, err
  336. }
  337. return backAuthority, nil
  338. }
  339. func GetBackAuthorityListInId(ids []int64) ([]domain.BackAuthority, error) {
  340. rows, err := configs.Engine.Table("back_authority").In("id", ids).Rows(&domain.BackAuthority{})
  341. if err != nil {
  342. return make([]domain.BackAuthority, 0), err
  343. }
  344. defer rows.Close()
  345. var list []domain.BackAuthority
  346. for rows.Next() {
  347. var u domain.BackAuthority
  348. rows.Scan(&u)
  349. list = append(list, u)
  350. }
  351. return list, nil
  352. }
  353. func GetBackAuthorityList(backAuthority domain.BackAuthority, pageNum, pageSize int) (vo.BaseListVo, error) {
  354. var arr []domain.BackAuthority
  355. Count, err := configs.Engine.Table("back_authority").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &backAuthority)
  356. var vo vo.BaseListVo
  357. if err != nil {
  358. return vo, err
  359. }
  360. if err != nil {
  361. return vo, err
  362. }
  363. vo.PageNum = pageNum
  364. vo.PageSize = pageSize
  365. vo.List = make([]any, len(arr))
  366. for i, v := range arr {
  367. vo.List[i] = v
  368. }
  369. vo.Total = int(Count)
  370. return vo, nil
  371. }
  372. func Get2BackAuthorityList(query domain.BackAuthorityQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  373. var arr []domain.BackAuthority
  374. session := configs.Engine.Table("back_authority").Limit(pageSize, (pageNum-1)*pageSize)
  375. if query.Id != 0{
  376. session.Where("id = ?", query.Id)
  377. }
  378. if query.AuthorityName != ""{
  379. session.Where("authority_name like ?", "%"+query.AuthorityName+"%")
  380. }
  381. if query.AuthorityPath != ""{
  382. session.Where("authority_path like ?", "%"+query.AuthorityPath+"%")
  383. }
  384. if query.Method != ""{
  385. session.Where("method = ?", query.Method)
  386. }
  387. if query.State != ""{
  388. session.Where("state = ?", query.State)
  389. }
  390. if query.AuthorityVerification != ""{
  391. session.Where("authority_verification like ?", "%"+query.AuthorityVerification+"%")
  392. }
  393. if query.CreateTimeStart != "" || query.CreateTimeEnd != ""{
  394. session.Where("create_time between ? and ?", query.CreateTimeStart, query.CreateTimeEnd)
  395. }
  396. Count, err := session.FindAndCount(&arr, &query)
  397. var vo vo.BaseListVo
  398. if err != nil {
  399. return vo, err
  400. }
  401. if err != nil {
  402. return vo, err
  403. }
  404. vo.PageNum = pageNum
  405. vo.PageSize = pageSize
  406. vo.List = make([]any, len(arr))
  407. for i, v := range arr {
  408. vo.List[i] = v
  409. }
  410. vo.Total = int(Count)
  411. return vo, nil
  412. }
  413. func SaveBackAuthority(backAuthority *domain.BackAuthority) (domain.BackAuthority, error) {
  414. _, err := configs.Engine.Table("back_authority").Insert(&backAuthority)
  415. if err != nil {
  416. return *backAuthority, err
  417. }
  418. return *backAuthority, nil
  419. }
  420. func SetBackAuthority(backAuthorityMap map[string]interface{}, id int64) (domain.BackAuthority, bool, error) {
  421. var backAuthority domain.BackAuthority
  422. _, err := configs.Engine.Table("back_authority").Where("id = ?", id).Update(backAuthorityMap)
  423. if err != nil {
  424. return backAuthority, false, err
  425. }
  426. return backAuthority, true, nil
  427. }
  428. func DeleteBackAuthority(id int64) bool {
  429. var backAuthority domain.BackAuthority
  430. i, err := configs.Engine.Table("back_authority").Where("id = ?", id).Delete(&backAuthority)
  431. if err != nil {
  432. return false
  433. }
  434. return i > 0
  435. }
  436. func GetBackMenuById(id int64) (domain.BackMenu, error) {
  437. var backMenu domain.BackMenu
  438. _, err := configs.Engine.Table("back_menu").Where("id = ?", id).Get(&backMenu)
  439. if err != nil {
  440. return backMenu, err
  441. }
  442. return backMenu, nil
  443. }
  444. func GetBackMenuListInId(ids []int64) ([]domain.BackMenu, error) {
  445. rows, err := configs.Engine.Table("back_menu").In("id", ids).Rows(&domain.BackMenu{})
  446. if err != nil {
  447. return make([]domain.BackMenu, 0), err
  448. }
  449. defer rows.Close()
  450. var list []domain.BackMenu
  451. for rows.Next() {
  452. var u domain.BackMenu
  453. rows.Scan(&u)
  454. list = append(list, u)
  455. }
  456. return list, nil
  457. }
  458. func GetBackMenuList(backMenu domain.BackMenu, pageNum, pageSize int) (vo.BaseListVo, error) {
  459. var arr []domain.BackMenu
  460. Count, err := configs.Engine.Table("back_menu").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &backMenu)
  461. var vo vo.BaseListVo
  462. if err != nil {
  463. return vo, err
  464. }
  465. if err != nil {
  466. return vo, err
  467. }
  468. vo.PageNum = pageNum
  469. vo.PageSize = pageSize
  470. vo.List = make([]any, len(arr))
  471. for i, v := range arr {
  472. vo.List[i] = v
  473. }
  474. vo.Total = int(Count)
  475. return vo, nil
  476. }
  477. func Get2BackMenuList(query domain.BackMenuQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  478. var arr []domain.BackMenu
  479. session := configs.Engine.Table("back_menu").Limit(pageSize, (pageNum-1)*pageSize)
  480. if query.Id != 0{
  481. session.Where("id = ?", query.Id)
  482. }
  483. if query.BackMenuName != ""{
  484. session.Where("back_menu_name = ?", query.BackMenuName)
  485. }
  486. if query.BackMenuPater != 0{
  487. session.Where("back_menu_pater = ?", query.BackMenuPater)
  488. }
  489. if query.Sort != 0{
  490. session.Where("sort = ?", query.Sort)
  491. }
  492. if query.Icon != ""{
  493. session.Where("icon = ?", query.Icon)
  494. }
  495. if query.Remark != ""{
  496. session.Where("remark = ?", query.Remark)
  497. }
  498. if query.BackRouterPath != ""{
  499. session.Where("back_router_path = ?", query.BackRouterPath)
  500. }
  501. if query.State != ""{
  502. session.Where("state = ?", query.State)
  503. }
  504. Count, err := session.FindAndCount(&arr, &query)
  505. var vo vo.BaseListVo
  506. if err != nil {
  507. return vo, err
  508. }
  509. if err != nil {
  510. return vo, err
  511. }
  512. vo.PageNum = pageNum
  513. vo.PageSize = pageSize
  514. vo.List = make([]any, len(arr))
  515. for i, v := range arr {
  516. vo.List[i] = v
  517. }
  518. vo.Total = int(Count)
  519. return vo, nil
  520. }
  521. func SaveBackMenu(backMenu *domain.BackMenu) (domain.BackMenu, error) {
  522. _, err := configs.Engine.Table("back_menu").Insert(&backMenu)
  523. if err != nil {
  524. return *backMenu, err
  525. }
  526. return *backMenu, nil
  527. }
  528. func SetBackMenu(backMenuMap map[string]interface{}, id int64) (domain.BackMenu, bool, error) {
  529. var backMenu domain.BackMenu
  530. _, err := configs.Engine.Table("back_menu").Where("id = ?", id).Update(backMenuMap)
  531. if err != nil {
  532. return backMenu, false, err
  533. }
  534. return backMenu, true, nil
  535. }
  536. func DeleteBackMenu(id int64) bool {
  537. var backMenu domain.BackMenu
  538. i, err := configs.Engine.Table("back_menu").Where("id = ?", id).Delete(&backMenu)
  539. if err != nil {
  540. return false
  541. }
  542. return i > 0
  543. }
  544. func GetBackRoleById(id int64) (domain.BackRole, error) {
  545. var backRole domain.BackRole
  546. _, err := configs.Engine.Table("back_role").Where("id = ?", id).Get(&backRole)
  547. if err != nil {
  548. return backRole, err
  549. }
  550. return backRole, nil
  551. }
  552. func GetBackRoleListInId(ids []int64) ([]domain.BackRole, error) {
  553. rows, err := configs.Engine.Table("back_role").In("id", ids).Rows(&domain.BackRole{})
  554. if err != nil {
  555. return make([]domain.BackRole, 0), err
  556. }
  557. defer rows.Close()
  558. var list []domain.BackRole
  559. for rows.Next() {
  560. var u domain.BackRole
  561. rows.Scan(&u)
  562. list = append(list, u)
  563. }
  564. return list, nil
  565. }
  566. func GetBackRoleList(backRole domain.BackRole, pageNum, pageSize int) (vo.BaseListVo, error) {
  567. var arr []domain.BackRole
  568. Count, err := configs.Engine.Table("back_role").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &backRole)
  569. var vo vo.BaseListVo
  570. if err != nil {
  571. return vo, err
  572. }
  573. if err != nil {
  574. return vo, err
  575. }
  576. vo.PageNum = pageNum
  577. vo.PageSize = pageSize
  578. vo.List = make([]any, len(arr))
  579. for i, v := range arr {
  580. vo.List[i] = v
  581. }
  582. vo.Total = int(Count)
  583. return vo, nil
  584. }
  585. func Get2BackRoleList(query domain.BackRoleQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  586. var arr []domain.BackRole
  587. session := configs.Engine.Table("back_role").Limit(pageSize, (pageNum-1)*pageSize)
  588. if query.Id != 0{
  589. session.Where("id = ?", query.Id)
  590. }
  591. if query.RoleName != ""{
  592. session.Where("role_name = ?", query.RoleName)
  593. }
  594. Count, err := session.FindAndCount(&arr, &query)
  595. var vo vo.BaseListVo
  596. if err != nil {
  597. return vo, err
  598. }
  599. if err != nil {
  600. return vo, err
  601. }
  602. vo.PageNum = pageNum
  603. vo.PageSize = pageSize
  604. vo.List = make([]any, len(arr))
  605. for i, v := range arr {
  606. vo.List[i] = v
  607. }
  608. vo.Total = int(Count)
  609. return vo, nil
  610. }
  611. func SaveBackRole(backRole *domain.BackRole) (domain.BackRole, error) {
  612. _, err := configs.Engine.Table("back_role").Insert(&backRole)
  613. if err != nil {
  614. return *backRole, err
  615. }
  616. return *backRole, nil
  617. }
  618. func SetBackRole(backRoleMap map[string]interface{}, id int64) (domain.BackRole, bool, error) {
  619. var backRole domain.BackRole
  620. _, err := configs.Engine.Table("back_role").Where("id = ?", id).Update(backRoleMap)
  621. if err != nil {
  622. return backRole, false, err
  623. }
  624. return backRole, true, nil
  625. }
  626. func DeleteBackRole(id int64) bool {
  627. var backRole domain.BackRole
  628. i, err := configs.Engine.Table("back_role").Where("id = ?", id).Delete(&backRole)
  629. if err != nil {
  630. return false
  631. }
  632. return i > 0
  633. }
  634. func GetBackRoleAuthorityById(id int64) (domain.BackRoleAuthority, error) {
  635. var backRoleAuthority domain.BackRoleAuthority
  636. _, err := configs.Engine.Table("back_role_authority").Where("id = ?", id).Get(&backRoleAuthority)
  637. if err != nil {
  638. return backRoleAuthority, err
  639. }
  640. return backRoleAuthority, nil
  641. }
  642. func GetBackRoleAuthorityListInId(ids []int64) ([]domain.BackRoleAuthority, error) {
  643. rows, err := configs.Engine.Table("back_role_authority").In("id", ids).Rows(&domain.BackRoleAuthority{})
  644. if err != nil {
  645. return make([]domain.BackRoleAuthority, 0), err
  646. }
  647. defer rows.Close()
  648. var list []domain.BackRoleAuthority
  649. for rows.Next() {
  650. var u domain.BackRoleAuthority
  651. rows.Scan(&u)
  652. list = append(list, u)
  653. }
  654. return list, nil
  655. }
  656. func GetBackRoleAuthorityList(backRoleAuthority domain.BackRoleAuthority, pageNum, pageSize int) (vo.BaseListVo, error) {
  657. var arr []domain.BackRoleAuthority
  658. Count, err := configs.Engine.Table("back_role_authority").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &backRoleAuthority)
  659. var vo vo.BaseListVo
  660. if err != nil {
  661. return vo, err
  662. }
  663. if err != nil {
  664. return vo, err
  665. }
  666. vo.PageNum = pageNum
  667. vo.PageSize = pageSize
  668. vo.List = make([]any, len(arr))
  669. for i, v := range arr {
  670. vo.List[i] = v
  671. }
  672. vo.Total = int(Count)
  673. return vo, nil
  674. }
  675. func Get2BackRoleAuthorityList(query domain.BackRoleAuthorityQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  676. var arr []domain.BackRoleAuthority
  677. session := configs.Engine.Table("back_role_authority").Limit(pageSize, (pageNum-1)*pageSize)
  678. if query.Id != 0{
  679. session.Where("id = ?", query.Id)
  680. }
  681. if query.RoleId != 0{
  682. session.Where("role_id = ?", query.RoleId)
  683. }
  684. if query.AuthorityId != 0{
  685. session.Where("authority_id = ?", query.AuthorityId)
  686. }
  687. Count, err := session.FindAndCount(&arr, &query)
  688. var vo vo.BaseListVo
  689. if err != nil {
  690. return vo, err
  691. }
  692. if err != nil {
  693. return vo, err
  694. }
  695. vo.PageNum = pageNum
  696. vo.PageSize = pageSize
  697. vo.List = make([]any, len(arr))
  698. for i, v := range arr {
  699. vo.List[i] = v
  700. }
  701. vo.Total = int(Count)
  702. return vo, nil
  703. }
  704. func SaveBackRoleAuthority(backRoleAuthority *domain.BackRoleAuthority) (domain.BackRoleAuthority, error) {
  705. _, err := configs.Engine.Table("back_role_authority").Insert(&backRoleAuthority)
  706. if err != nil {
  707. return *backRoleAuthority, err
  708. }
  709. return *backRoleAuthority, nil
  710. }
  711. func SetBackRoleAuthority(backRoleAuthorityMap map[string]interface{}, id int64) (domain.BackRoleAuthority, bool, error) {
  712. var backRoleAuthority domain.BackRoleAuthority
  713. _, err := configs.Engine.Table("back_role_authority").Where("id = ?", id).Update(backRoleAuthorityMap)
  714. if err != nil {
  715. return backRoleAuthority, false, err
  716. }
  717. return backRoleAuthority, true, nil
  718. }
  719. func DeleteBackRoleAuthority(id int64) bool {
  720. var backRoleAuthority domain.BackRoleAuthority
  721. i, err := configs.Engine.Table("back_role_authority").Where("id = ?", id).Delete(&backRoleAuthority)
  722. if err != nil {
  723. return false
  724. }
  725. return i > 0
  726. }
  727. func GetBackRoleMenuById(id int64) (domain.BackRoleMenu, error) {
  728. var backRoleMenu domain.BackRoleMenu
  729. _, err := configs.Engine.Table("back_role_menu").Where("id = ?", id).Get(&backRoleMenu)
  730. if err != nil {
  731. return backRoleMenu, err
  732. }
  733. return backRoleMenu, nil
  734. }
  735. func GetBackRoleMenuListInId(ids []int64) ([]domain.BackRoleMenu, error) {
  736. rows, err := configs.Engine.Table("back_role_menu").In("id", ids).Rows(&domain.BackRoleMenu{})
  737. if err != nil {
  738. return make([]domain.BackRoleMenu, 0), err
  739. }
  740. defer rows.Close()
  741. var list []domain.BackRoleMenu
  742. for rows.Next() {
  743. var u domain.BackRoleMenu
  744. rows.Scan(&u)
  745. list = append(list, u)
  746. }
  747. return list, nil
  748. }
  749. func GetBackRoleMenuList(backRoleMenu domain.BackRoleMenu, pageNum, pageSize int) (vo.BaseListVo, error) {
  750. var arr []domain.BackRoleMenu
  751. Count, err := configs.Engine.Table("back_role_menu").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &backRoleMenu)
  752. var vo vo.BaseListVo
  753. if err != nil {
  754. return vo, err
  755. }
  756. if err != nil {
  757. return vo, err
  758. }
  759. vo.PageNum = pageNum
  760. vo.PageSize = pageSize
  761. vo.List = make([]any, len(arr))
  762. for i, v := range arr {
  763. vo.List[i] = v
  764. }
  765. vo.Total = int(Count)
  766. return vo, nil
  767. }
  768. func Get2BackRoleMenuList(query domain.BackRoleMenuQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  769. var arr []domain.BackRoleMenu
  770. session := configs.Engine.Table("back_role_menu").Limit(pageSize, (pageNum-1)*pageSize)
  771. if query.Id != 0{
  772. session.Where("id = ?", query.Id)
  773. }
  774. if query.RoleId != 0{
  775. session.Where("role_id = ?", query.RoleId)
  776. }
  777. if query.MenuId != 0{
  778. session.Where("menu_id = ?", query.MenuId)
  779. }
  780. Count, err := session.FindAndCount(&arr, &query)
  781. var vo vo.BaseListVo
  782. if err != nil {
  783. return vo, err
  784. }
  785. if err != nil {
  786. return vo, err
  787. }
  788. vo.PageNum = pageNum
  789. vo.PageSize = pageSize
  790. vo.List = make([]any, len(arr))
  791. for i, v := range arr {
  792. vo.List[i] = v
  793. }
  794. vo.Total = int(Count)
  795. return vo, nil
  796. }
  797. func SaveBackRoleMenu(backRoleMenu *domain.BackRoleMenu) (domain.BackRoleMenu, error) {
  798. _, err := configs.Engine.Table("back_role_menu").Insert(&backRoleMenu)
  799. if err != nil {
  800. return *backRoleMenu, err
  801. }
  802. return *backRoleMenu, nil
  803. }
  804. func SetBackRoleMenu(backRoleMenuMap map[string]interface{}, id int64) (domain.BackRoleMenu, bool, error) {
  805. var backRoleMenu domain.BackRoleMenu
  806. _, err := configs.Engine.Table("back_role_menu").Where("id = ?", id).Update(backRoleMenuMap)
  807. if err != nil {
  808. return backRoleMenu, false, err
  809. }
  810. return backRoleMenu, true, nil
  811. }
  812. func DeleteBackRoleMenu(id int64) bool {
  813. var backRoleMenu domain.BackRoleMenu
  814. i, err := configs.Engine.Table("back_role_menu").Where("id = ?", id).Delete(&backRoleMenu)
  815. if err != nil {
  816. return false
  817. }
  818. return i > 0
  819. }
  820. func GetGenTableById(id int64) (domain.GenTable, error) {
  821. var genTable domain.GenTable
  822. _, err := configs.Engine.Table("gen_table").Where("id = ?", id).Get(&genTable)
  823. if err != nil {
  824. return genTable, err
  825. }
  826. return genTable, nil
  827. }
  828. func GetGenTableListInId(ids []int64) ([]domain.GenTable, error) {
  829. rows, err := configs.Engine.Table("gen_table").In("id", ids).Rows(&domain.GenTable{})
  830. if err != nil {
  831. return make([]domain.GenTable, 0), err
  832. }
  833. defer rows.Close()
  834. var list []domain.GenTable
  835. for rows.Next() {
  836. var u domain.GenTable
  837. rows.Scan(&u)
  838. list = append(list, u)
  839. }
  840. return list, nil
  841. }
  842. func GetGenTableList(genTable domain.GenTable, pageNum, pageSize int) (vo.BaseListVo, error) {
  843. var arr []domain.GenTable
  844. Count, err := configs.Engine.Table("gen_table").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &genTable)
  845. var vo vo.BaseListVo
  846. if err != nil {
  847. return vo, err
  848. }
  849. if err != nil {
  850. return vo, err
  851. }
  852. vo.PageNum = pageNum
  853. vo.PageSize = pageSize
  854. vo.List = make([]any, len(arr))
  855. for i, v := range arr {
  856. vo.List[i] = v
  857. }
  858. vo.Total = int(Count)
  859. return vo, nil
  860. }
  861. func Get2GenTableList(query domain.GenTableQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  862. var arr []domain.GenTable
  863. session := configs.Engine.Table("gen_table").Limit(pageSize, (pageNum-1)*pageSize)
  864. if query.Id != 0{
  865. session.Where("id = ?", query.Id)
  866. }
  867. if query.TableName != ""{
  868. session.Where("table_name = ?", query.TableName)
  869. }
  870. if query.TableComment != ""{
  871. session.Where("table_comment = ?", query.TableComment)
  872. }
  873. if query.Name != ""{
  874. session.Where("name = ?", query.Name)
  875. }
  876. if query.RouterName != ""{
  877. session.Where("router_name = ?", query.RouterName)
  878. }
  879. if query.Remark != ""{
  880. session.Where("remark = ?", query.Remark)
  881. }
  882. Count, err := session.FindAndCount(&arr, &query)
  883. var vo vo.BaseListVo
  884. if err != nil {
  885. return vo, err
  886. }
  887. if err != nil {
  888. return vo, err
  889. }
  890. vo.PageNum = pageNum
  891. vo.PageSize = pageSize
  892. vo.List = make([]any, len(arr))
  893. for i, v := range arr {
  894. vo.List[i] = v
  895. }
  896. vo.Total = int(Count)
  897. return vo, nil
  898. }
  899. func SaveGenTable(genTable *domain.GenTable) (domain.GenTable, error) {
  900. _, err := configs.Engine.Table("gen_table").Insert(&genTable)
  901. if err != nil {
  902. return *genTable, err
  903. }
  904. return *genTable, nil
  905. }
  906. func SetGenTable(genTableMap map[string]interface{}, id int64) (domain.GenTable, bool, error) {
  907. var genTable domain.GenTable
  908. _, err := configs.Engine.Table("gen_table").Where("id = ?", id).Update(genTableMap)
  909. if err != nil {
  910. return genTable, false, err
  911. }
  912. return genTable, true, nil
  913. }
  914. func DeleteGenTable(id int64) bool {
  915. var genTable domain.GenTable
  916. i, err := configs.Engine.Table("gen_table").Where("id = ?", id).Delete(&genTable)
  917. if err != nil {
  918. return false
  919. }
  920. return i > 0
  921. }
  922. func GetGenTableColumnById(id int64) (domain.GenTableColumn, error) {
  923. var genTableColumn domain.GenTableColumn
  924. _, err := configs.Engine.Table("gen_table_column").Where("id = ?", id).Get(&genTableColumn)
  925. if err != nil {
  926. return genTableColumn, err
  927. }
  928. return genTableColumn, nil
  929. }
  930. func GetGenTableColumnListInId(ids []int64) ([]domain.GenTableColumn, error) {
  931. rows, err := configs.Engine.Table("gen_table_column").In("id", ids).Rows(&domain.GenTableColumn{})
  932. if err != nil {
  933. return make([]domain.GenTableColumn, 0), err
  934. }
  935. defer rows.Close()
  936. var list []domain.GenTableColumn
  937. for rows.Next() {
  938. var u domain.GenTableColumn
  939. rows.Scan(&u)
  940. list = append(list, u)
  941. }
  942. return list, nil
  943. }
  944. func GetGenTableColumnList(genTableColumn domain.GenTableColumn, pageNum, pageSize int) (vo.BaseListVo, error) {
  945. var arr []domain.GenTableColumn
  946. Count, err := configs.Engine.Table("gen_table_column").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &genTableColumn)
  947. var vo vo.BaseListVo
  948. if err != nil {
  949. return vo, err
  950. }
  951. if err != nil {
  952. return vo, err
  953. }
  954. vo.PageNum = pageNum
  955. vo.PageSize = pageSize
  956. vo.List = make([]any, len(arr))
  957. for i, v := range arr {
  958. vo.List[i] = v
  959. }
  960. vo.Total = int(Count)
  961. return vo, nil
  962. }
  963. func Get2GenTableColumnList(query domain.GenTableColumnQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  964. var arr []domain.GenTableColumn
  965. session := configs.Engine.Table("gen_table_column").Limit(pageSize, (pageNum-1)*pageSize)
  966. if query.Id != 0{
  967. session.Where("id = ?", query.Id)
  968. }
  969. if query.TableId != 0{
  970. session.Where("table_id = ?", query.TableId)
  971. }
  972. if query.Sort != 0{
  973. session.Where("sort = ?", query.Sort)
  974. }
  975. if query.ColumnComment != ""{
  976. session.Where("column_comment = ?", query.ColumnComment)
  977. }
  978. if query.ColumnType != ""{
  979. session.Where("column_type = ?", query.ColumnType)
  980. }
  981. if query.GoType != ""{
  982. session.Where("go_type = ?", query.GoType)
  983. }
  984. if query.GoField != ""{
  985. session.Where("go_field = ?", query.GoField)
  986. }
  987. if query.IsKey != ""{
  988. session.Where("is_key = ?", query.IsKey)
  989. }
  990. if query.IsIncrement != ""{
  991. session.Where("is_increment = ?", query.IsIncrement)
  992. }
  993. if query.IsRequired != ""{
  994. session.Where("is_required = ?", query.IsRequired)
  995. }
  996. if query.QueryType != ""{
  997. session.Where("query_type = ?", query.QueryType)
  998. }
  999. if query.VueShowType != ""{
  1000. session.Where("vue_show_type = ?", query.VueShowType)
  1001. }
  1002. if query.DictType != ""{
  1003. session.Where("dict_type = ?", query.DictType)
  1004. }
  1005. if query.ColumnName != ""{
  1006. session.Where("column_name = ?", query.ColumnName)
  1007. }
  1008. Count, err := session.FindAndCount(&arr, &query)
  1009. var vo vo.BaseListVo
  1010. if err != nil {
  1011. return vo, err
  1012. }
  1013. if err != nil {
  1014. return vo, err
  1015. }
  1016. vo.PageNum = pageNum
  1017. vo.PageSize = pageSize
  1018. vo.List = make([]any, len(arr))
  1019. for i, v := range arr {
  1020. vo.List[i] = v
  1021. }
  1022. vo.Total = int(Count)
  1023. return vo, nil
  1024. }
  1025. func SaveGenTableColumn(genTableColumn *domain.GenTableColumn) (domain.GenTableColumn, error) {
  1026. _, err := configs.Engine.Table("gen_table_column").Insert(&genTableColumn)
  1027. if err != nil {
  1028. return *genTableColumn, err
  1029. }
  1030. return *genTableColumn, nil
  1031. }
  1032. func SetGenTableColumn(genTableColumnMap map[string]interface{}, id int64) (domain.GenTableColumn, bool, error) {
  1033. var genTableColumn domain.GenTableColumn
  1034. _, err := configs.Engine.Table("gen_table_column").Where("id = ?", id).Update(genTableColumnMap)
  1035. if err != nil {
  1036. return genTableColumn, false, err
  1037. }
  1038. return genTableColumn, true, nil
  1039. }
  1040. func DeleteGenTableColumn(id int64) bool {
  1041. var genTableColumn domain.GenTableColumn
  1042. i, err := configs.Engine.Table("gen_table_column").Where("id = ?", id).Delete(&genTableColumn)
  1043. if err != nil {
  1044. return false
  1045. }
  1046. return i > 0
  1047. }
  1048. func GetGoodsById(id int64) (domain.Goods, error) {
  1049. var goods domain.Goods
  1050. _, err := configs.Engine.Table("goods").Where("id = ?", id).Get(&goods)
  1051. if err != nil {
  1052. return goods, err
  1053. }
  1054. return goods, nil
  1055. }
  1056. func GetGoodsListInId(ids []int64) ([]domain.Goods, error) {
  1057. rows, err := configs.Engine.Table("goods").In("id", ids).Rows(&domain.Goods{})
  1058. if err != nil {
  1059. return make([]domain.Goods, 0), err
  1060. }
  1061. defer rows.Close()
  1062. var list []domain.Goods
  1063. for rows.Next() {
  1064. var u domain.Goods
  1065. rows.Scan(&u)
  1066. list = append(list, u)
  1067. }
  1068. return list, nil
  1069. }
  1070. func GetGoodsList(goods domain.Goods, pageNum, pageSize int) (vo.BaseListVo, error) {
  1071. var arr []domain.Goods
  1072. Count, err := configs.Engine.Table("goods").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goods)
  1073. var vo vo.BaseListVo
  1074. if err != nil {
  1075. return vo, err
  1076. }
  1077. if err != nil {
  1078. return vo, err
  1079. }
  1080. vo.PageNum = pageNum
  1081. vo.PageSize = pageSize
  1082. vo.List = make([]any, len(arr))
  1083. for i, v := range arr {
  1084. vo.List[i] = v
  1085. }
  1086. vo.Total = int(Count)
  1087. return vo, nil
  1088. }
  1089. func Get2GoodsList(query domain.GoodsQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1090. var arr []domain.Goods
  1091. session := configs.Engine.Table("goods").Limit(pageSize, (pageNum-1)*pageSize)
  1092. if query.Id != 0{
  1093. session.Where("id = ?", query.Id)
  1094. }
  1095. if query.TypeId != 0{
  1096. session.Where("type_id = ?", query.TypeId)
  1097. }
  1098. if query.GoodsName != ""{
  1099. session.Where("goods_name like ?", "%"+query.GoodsName+"%")
  1100. }
  1101. if query.IntroductionId != 0{
  1102. session.Where("introduction_id = ?", query.IntroductionId)
  1103. }
  1104. if query.SalesVolumeStart != 0 || query.SalesVolumeEnd != 0{
  1105. session.Where("sales_volume between ? and ?", query.SalesVolumeStart, query.SalesVolumeEnd)
  1106. }
  1107. if query.TagIds != ""{
  1108. session.Where("tag_ids = ?", query.TagIds)
  1109. }
  1110. Count, err := session.FindAndCount(&arr, &query)
  1111. var vo vo.BaseListVo
  1112. if err != nil {
  1113. return vo, err
  1114. }
  1115. if err != nil {
  1116. return vo, err
  1117. }
  1118. vo.PageNum = pageNum
  1119. vo.PageSize = pageSize
  1120. vo.List = make([]any, len(arr))
  1121. for i, v := range arr {
  1122. vo.List[i] = v
  1123. }
  1124. vo.Total = int(Count)
  1125. return vo, nil
  1126. }
  1127. func SaveGoods(goods *domain.Goods) (domain.Goods, error) {
  1128. _, err := configs.Engine.Table("goods").Insert(&goods)
  1129. if err != nil {
  1130. return *goods, err
  1131. }
  1132. return *goods, nil
  1133. }
  1134. func SetGoods(goodsMap map[string]interface{}, id int64) (domain.Goods, bool, error) {
  1135. var goods domain.Goods
  1136. _, err := configs.Engine.Table("goods").Where("id = ?", id).Update(goodsMap)
  1137. if err != nil {
  1138. return goods, false, err
  1139. }
  1140. return goods, true, nil
  1141. }
  1142. func DeleteGoods(id int64) bool {
  1143. var goods domain.Goods
  1144. i, err := configs.Engine.Table("goods").Where("id = ?", id).Delete(&goods)
  1145. if err != nil {
  1146. return false
  1147. }
  1148. return i > 0
  1149. }
  1150. func GetGoodsCommodityAreaById(id int64) (domain.GoodsCommodityArea, error) {
  1151. var goodsCommodityArea domain.GoodsCommodityArea
  1152. _, err := configs.Engine.Table("goods_commodity_area").Where("id = ?", id).Get(&goodsCommodityArea)
  1153. if err != nil {
  1154. return goodsCommodityArea, err
  1155. }
  1156. return goodsCommodityArea, nil
  1157. }
  1158. func GetGoodsCommodityAreaListInId(ids []int64) ([]domain.GoodsCommodityArea, error) {
  1159. rows, err := configs.Engine.Table("goods_commodity_area").In("id", ids).Rows(&domain.GoodsCommodityArea{})
  1160. if err != nil {
  1161. return make([]domain.GoodsCommodityArea, 0), err
  1162. }
  1163. defer rows.Close()
  1164. var list []domain.GoodsCommodityArea
  1165. for rows.Next() {
  1166. var u domain.GoodsCommodityArea
  1167. rows.Scan(&u)
  1168. list = append(list, u)
  1169. }
  1170. return list, nil
  1171. }
  1172. func GetGoodsCommodityAreaList(goodsCommodityArea domain.GoodsCommodityArea, pageNum, pageSize int) (vo.BaseListVo, error) {
  1173. var arr []domain.GoodsCommodityArea
  1174. Count, err := configs.Engine.Table("goods_commodity_area").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsCommodityArea)
  1175. var vo vo.BaseListVo
  1176. if err != nil {
  1177. return vo, err
  1178. }
  1179. if err != nil {
  1180. return vo, err
  1181. }
  1182. vo.PageNum = pageNum
  1183. vo.PageSize = pageSize
  1184. vo.List = make([]any, len(arr))
  1185. for i, v := range arr {
  1186. vo.List[i] = v
  1187. }
  1188. vo.Total = int(Count)
  1189. return vo, nil
  1190. }
  1191. func Get2GoodsCommodityAreaList(query domain.GoodsCommodityAreaQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1192. var arr []domain.GoodsCommodityArea
  1193. session := configs.Engine.Table("goods_commodity_area").Limit(pageSize, (pageNum-1)*pageSize)
  1194. if query.Id != 0{
  1195. session.Where("id = ?", query.Id)
  1196. }
  1197. if query.GoodsId != 0{
  1198. session.Where("goods_id = ?", query.GoodsId)
  1199. }
  1200. if query.CommodityAreaName != ""{
  1201. session.Where("commodity_area_name = ?", query.CommodityAreaName)
  1202. }
  1203. if query.DetailImage != ""{
  1204. session.Where("detail_image = ?", query.DetailImage)
  1205. }
  1206. if query.DetailIntroductionId != 0{
  1207. session.Where("detail_introduction_id = ?", query.DetailIntroductionId)
  1208. }
  1209. Count, err := session.FindAndCount(&arr, &query)
  1210. var vo vo.BaseListVo
  1211. if err != nil {
  1212. return vo, err
  1213. }
  1214. if err != nil {
  1215. return vo, err
  1216. }
  1217. vo.PageNum = pageNum
  1218. vo.PageSize = pageSize
  1219. vo.List = make([]any, len(arr))
  1220. for i, v := range arr {
  1221. vo.List[i] = v
  1222. }
  1223. vo.Total = int(Count)
  1224. return vo, nil
  1225. }
  1226. func SaveGoodsCommodityArea(goodsCommodityArea *domain.GoodsCommodityArea) (domain.GoodsCommodityArea, error) {
  1227. _, err := configs.Engine.Table("goods_commodity_area").Insert(&goodsCommodityArea)
  1228. if err != nil {
  1229. return *goodsCommodityArea, err
  1230. }
  1231. return *goodsCommodityArea, nil
  1232. }
  1233. func SetGoodsCommodityArea(goodsCommodityAreaMap map[string]interface{}, id int64) (domain.GoodsCommodityArea, bool, error) {
  1234. var goodsCommodityArea domain.GoodsCommodityArea
  1235. _, err := configs.Engine.Table("goods_commodity_area").Where("id = ?", id).Update(goodsCommodityAreaMap)
  1236. if err != nil {
  1237. return goodsCommodityArea, false, err
  1238. }
  1239. return goodsCommodityArea, true, nil
  1240. }
  1241. func DeleteGoodsCommodityArea(id int64) bool {
  1242. var goodsCommodityArea domain.GoodsCommodityArea
  1243. i, err := configs.Engine.Table("goods_commodity_area").Where("id = ?", id).Delete(&goodsCommodityArea)
  1244. if err != nil {
  1245. return false
  1246. }
  1247. return i > 0
  1248. }
  1249. func GetGoodsCouponById(id int64) (domain.GoodsCoupon, error) {
  1250. var goodsCoupon domain.GoodsCoupon
  1251. _, err := configs.Engine.Table("goods_coupon").Where("id = ?", id).Get(&goodsCoupon)
  1252. if err != nil {
  1253. return goodsCoupon, err
  1254. }
  1255. return goodsCoupon, nil
  1256. }
  1257. func GetGoodsCouponListInId(ids []int64) ([]domain.GoodsCoupon, error) {
  1258. rows, err := configs.Engine.Table("goods_coupon").In("id", ids).Rows(&domain.GoodsCoupon{})
  1259. if err != nil {
  1260. return make([]domain.GoodsCoupon, 0), err
  1261. }
  1262. defer rows.Close()
  1263. var list []domain.GoodsCoupon
  1264. for rows.Next() {
  1265. var u domain.GoodsCoupon
  1266. rows.Scan(&u)
  1267. list = append(list, u)
  1268. }
  1269. return list, nil
  1270. }
  1271. func GetGoodsCouponList(goodsCoupon domain.GoodsCoupon, pageNum, pageSize int) (vo.BaseListVo, error) {
  1272. var arr []domain.GoodsCoupon
  1273. Count, err := configs.Engine.Table("goods_coupon").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsCoupon)
  1274. var vo vo.BaseListVo
  1275. if err != nil {
  1276. return vo, err
  1277. }
  1278. if err != nil {
  1279. return vo, err
  1280. }
  1281. vo.PageNum = pageNum
  1282. vo.PageSize = pageSize
  1283. vo.List = make([]any, len(arr))
  1284. for i, v := range arr {
  1285. vo.List[i] = v
  1286. }
  1287. vo.Total = int(Count)
  1288. return vo, nil
  1289. }
  1290. func Get2GoodsCouponList(query domain.GoodsCouponQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1291. var arr []domain.GoodsCoupon
  1292. session := configs.Engine.Table("goods_coupon").Limit(pageSize, (pageNum-1)*pageSize)
  1293. if query.Id != 0{
  1294. session.Where("id = ?", query.Id)
  1295. }
  1296. if query.CouponName != ""{
  1297. session.Where("coupon_name like ?", "%"+query.CouponName+"%")
  1298. }
  1299. if query.CouponDesc != ""{
  1300. session.Where("coupon_desc = ?", query.CouponDesc)
  1301. }
  1302. if query.CashBackPoint != 0{
  1303. session.Where("cash_back_point = ?", query.CashBackPoint)
  1304. }
  1305. if query.CashBackPrice != 0{
  1306. session.Where("cash_back_price = ?", query.CashBackPrice)
  1307. }
  1308. if query.ConditionByTopic != ""{
  1309. session.Where("condition_by_topic = ?", query.ConditionByTopic)
  1310. }
  1311. if query.ConditionByType != ""{
  1312. session.Where("condition_by_type = ?", query.ConditionByType)
  1313. }
  1314. if query.ConditionByGoods != ""{
  1315. session.Where("condition_by_goods = ?", query.ConditionByGoods)
  1316. }
  1317. if query.GrantCount != ""{
  1318. session.Where("grant_count = ?", query.GrantCount)
  1319. }
  1320. if query.Count != 0{
  1321. session.Where("count = ?", query.Count)
  1322. }
  1323. if query.ReceiveType != ""{
  1324. session.Where("receive_type = ?", query.ReceiveType)
  1325. }
  1326. if query.Validity != ""{
  1327. session.Where("validity = ?", query.Validity)
  1328. }
  1329. if query.ValidityPeriod != ""{
  1330. session.Where("validity_period = ?", query.ValidityPeriod)
  1331. }
  1332. Count, err := session.FindAndCount(&arr, &query)
  1333. var vo vo.BaseListVo
  1334. if err != nil {
  1335. return vo, err
  1336. }
  1337. if err != nil {
  1338. return vo, err
  1339. }
  1340. vo.PageNum = pageNum
  1341. vo.PageSize = pageSize
  1342. vo.List = make([]any, len(arr))
  1343. for i, v := range arr {
  1344. vo.List[i] = v
  1345. }
  1346. vo.Total = int(Count)
  1347. return vo, nil
  1348. }
  1349. func SaveGoodsCoupon(goodsCoupon *domain.GoodsCoupon) (domain.GoodsCoupon, error) {
  1350. _, err := configs.Engine.Table("goods_coupon").Insert(&goodsCoupon)
  1351. if err != nil {
  1352. return *goodsCoupon, err
  1353. }
  1354. return *goodsCoupon, nil
  1355. }
  1356. func SetGoodsCoupon(goodsCouponMap map[string]interface{}, id int64) (domain.GoodsCoupon, bool, error) {
  1357. var goodsCoupon domain.GoodsCoupon
  1358. _, err := configs.Engine.Table("goods_coupon").Where("id = ?", id).Update(goodsCouponMap)
  1359. if err != nil {
  1360. return goodsCoupon, false, err
  1361. }
  1362. return goodsCoupon, true, nil
  1363. }
  1364. func DeleteGoodsCoupon(id int64) bool {
  1365. var goodsCoupon domain.GoodsCoupon
  1366. i, err := configs.Engine.Table("goods_coupon").Where("id = ?", id).Delete(&goodsCoupon)
  1367. if err != nil {
  1368. return false
  1369. }
  1370. return i > 0
  1371. }
  1372. func GetGoodsCouponUserById(id int64) (domain.GoodsCouponUser, error) {
  1373. var goodsCouponUser domain.GoodsCouponUser
  1374. _, err := configs.Engine.Table("goods_coupon_user").Where("id = ?", id).Get(&goodsCouponUser)
  1375. if err != nil {
  1376. return goodsCouponUser, err
  1377. }
  1378. return goodsCouponUser, nil
  1379. }
  1380. func GetGoodsCouponUserListInId(ids []int64) ([]domain.GoodsCouponUser, error) {
  1381. rows, err := configs.Engine.Table("goods_coupon_user").In("id", ids).Rows(&domain.GoodsCouponUser{})
  1382. if err != nil {
  1383. return make([]domain.GoodsCouponUser, 0), err
  1384. }
  1385. defer rows.Close()
  1386. var list []domain.GoodsCouponUser
  1387. for rows.Next() {
  1388. var u domain.GoodsCouponUser
  1389. rows.Scan(&u)
  1390. list = append(list, u)
  1391. }
  1392. return list, nil
  1393. }
  1394. func GetGoodsCouponUserList(goodsCouponUser domain.GoodsCouponUser, pageNum, pageSize int) (vo.BaseListVo, error) {
  1395. var arr []domain.GoodsCouponUser
  1396. Count, err := configs.Engine.Table("goods_coupon_user").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsCouponUser)
  1397. var vo vo.BaseListVo
  1398. if err != nil {
  1399. return vo, err
  1400. }
  1401. if err != nil {
  1402. return vo, err
  1403. }
  1404. vo.PageNum = pageNum
  1405. vo.PageSize = pageSize
  1406. vo.List = make([]any, len(arr))
  1407. for i, v := range arr {
  1408. vo.List[i] = v
  1409. }
  1410. vo.Total = int(Count)
  1411. return vo, nil
  1412. }
  1413. func Get2GoodsCouponUserList(query domain.GoodsCouponUserQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1414. var arr []domain.GoodsCouponUser
  1415. session := configs.Engine.Table("goods_coupon_user").Limit(pageSize, (pageNum-1)*pageSize)
  1416. if query.Id != 0{
  1417. session.Where("id = ?", query.Id)
  1418. }
  1419. if query.UserId != 0{
  1420. session.Where("user_id = ?", query.UserId)
  1421. }
  1422. if query.CouponId != 0{
  1423. session.Where("coupon_id = ?", query.CouponId)
  1424. }
  1425. if query.CollectionTime != ""{
  1426. session.Where("collection_time = ?", query.CollectionTime)
  1427. }
  1428. if query.State != ""{
  1429. session.Where("state = ?", query.State)
  1430. }
  1431. Count, err := session.FindAndCount(&arr, &query)
  1432. var vo vo.BaseListVo
  1433. if err != nil {
  1434. return vo, err
  1435. }
  1436. if err != nil {
  1437. return vo, err
  1438. }
  1439. vo.PageNum = pageNum
  1440. vo.PageSize = pageSize
  1441. vo.List = make([]any, len(arr))
  1442. for i, v := range arr {
  1443. vo.List[i] = v
  1444. }
  1445. vo.Total = int(Count)
  1446. return vo, nil
  1447. }
  1448. func SaveGoodsCouponUser(goodsCouponUser *domain.GoodsCouponUser) (domain.GoodsCouponUser, error) {
  1449. _, err := configs.Engine.Table("goods_coupon_user").Insert(&goodsCouponUser)
  1450. if err != nil {
  1451. return *goodsCouponUser, err
  1452. }
  1453. return *goodsCouponUser, nil
  1454. }
  1455. func SetGoodsCouponUser(goodsCouponUserMap map[string]interface{}, id int64) (domain.GoodsCouponUser, bool, error) {
  1456. var goodsCouponUser domain.GoodsCouponUser
  1457. _, err := configs.Engine.Table("goods_coupon_user").Where("id = ?", id).Update(goodsCouponUserMap)
  1458. if err != nil {
  1459. return goodsCouponUser, false, err
  1460. }
  1461. return goodsCouponUser, true, nil
  1462. }
  1463. func DeleteGoodsCouponUser(id int64) bool {
  1464. var goodsCouponUser domain.GoodsCouponUser
  1465. i, err := configs.Engine.Table("goods_coupon_user").Where("id = ?", id).Delete(&goodsCouponUser)
  1466. if err != nil {
  1467. return false
  1468. }
  1469. return i > 0
  1470. }
  1471. func GetGoodsIntroductionById(id int64) (domain.GoodsIntroduction, error) {
  1472. var goodsIntroduction domain.GoodsIntroduction
  1473. _, err := configs.Engine.Table("goods_introduction").Where("id = ?", id).Get(&goodsIntroduction)
  1474. if err != nil {
  1475. return goodsIntroduction, err
  1476. }
  1477. return goodsIntroduction, nil
  1478. }
  1479. func GetGoodsIntroductionListInId(ids []int64) ([]domain.GoodsIntroduction, error) {
  1480. rows, err := configs.Engine.Table("goods_introduction").In("id", ids).Rows(&domain.GoodsIntroduction{})
  1481. if err != nil {
  1482. return make([]domain.GoodsIntroduction, 0), err
  1483. }
  1484. defer rows.Close()
  1485. var list []domain.GoodsIntroduction
  1486. for rows.Next() {
  1487. var u domain.GoodsIntroduction
  1488. rows.Scan(&u)
  1489. list = append(list, u)
  1490. }
  1491. return list, nil
  1492. }
  1493. func GetGoodsIntroductionList(goodsIntroduction domain.GoodsIntroduction, pageNum, pageSize int) (vo.BaseListVo, error) {
  1494. var arr []domain.GoodsIntroduction
  1495. Count, err := configs.Engine.Table("goods_introduction").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsIntroduction)
  1496. var vo vo.BaseListVo
  1497. if err != nil {
  1498. return vo, err
  1499. }
  1500. if err != nil {
  1501. return vo, err
  1502. }
  1503. vo.PageNum = pageNum
  1504. vo.PageSize = pageSize
  1505. vo.List = make([]any, len(arr))
  1506. for i, v := range arr {
  1507. vo.List[i] = v
  1508. }
  1509. vo.Total = int(Count)
  1510. return vo, nil
  1511. }
  1512. func Get2GoodsIntroductionList(query domain.GoodsIntroductionQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1513. var arr []domain.GoodsIntroduction
  1514. session := configs.Engine.Table("goods_introduction").Limit(pageSize, (pageNum-1)*pageSize)
  1515. if query.Id != 0{
  1516. session.Where("id = ?", query.Id)
  1517. }
  1518. if query.GoodsArticleName != ""{
  1519. session.Where("goods_article_name = ?", query.GoodsArticleName)
  1520. }
  1521. if query.GoodsArticle != ""{
  1522. session.Where("goods_article = ?", query.GoodsArticle)
  1523. }
  1524. if query.CreateBy != ""{
  1525. session.Where("create_by = ?", query.CreateBy)
  1526. }
  1527. if query.CreateTime != ""{
  1528. session.Where("create_time = ?", query.CreateTime)
  1529. }
  1530. if query.UpdateBy != ""{
  1531. session.Where("update_by = ?", query.UpdateBy)
  1532. }
  1533. if query.UpdateTime != ""{
  1534. session.Where("update_time = ?", query.UpdateTime)
  1535. }
  1536. Count, err := session.FindAndCount(&arr, &query)
  1537. var vo vo.BaseListVo
  1538. if err != nil {
  1539. return vo, err
  1540. }
  1541. if err != nil {
  1542. return vo, err
  1543. }
  1544. vo.PageNum = pageNum
  1545. vo.PageSize = pageSize
  1546. vo.List = make([]any, len(arr))
  1547. for i, v := range arr {
  1548. vo.List[i] = v
  1549. }
  1550. vo.Total = int(Count)
  1551. return vo, nil
  1552. }
  1553. func SaveGoodsIntroduction(goodsIntroduction *domain.GoodsIntroduction) (domain.GoodsIntroduction, error) {
  1554. _, err := configs.Engine.Table("goods_introduction").Insert(&goodsIntroduction)
  1555. if err != nil {
  1556. return *goodsIntroduction, err
  1557. }
  1558. return *goodsIntroduction, nil
  1559. }
  1560. func SetGoodsIntroduction(goodsIntroductionMap map[string]interface{}, id int64) (domain.GoodsIntroduction, bool, error) {
  1561. var goodsIntroduction domain.GoodsIntroduction
  1562. _, err := configs.Engine.Table("goods_introduction").Where("id = ?", id).Update(goodsIntroductionMap)
  1563. if err != nil {
  1564. return goodsIntroduction, false, err
  1565. }
  1566. return goodsIntroduction, true, nil
  1567. }
  1568. func DeleteGoodsIntroduction(id int64) bool {
  1569. var goodsIntroduction domain.GoodsIntroduction
  1570. i, err := configs.Engine.Table("goods_introduction").Where("id = ?", id).Delete(&goodsIntroduction)
  1571. if err != nil {
  1572. return false
  1573. }
  1574. return i > 0
  1575. }
  1576. func GetGoodsOrderById(id int64) (domain.GoodsOrder, error) {
  1577. var goodsOrder domain.GoodsOrder
  1578. _, err := configs.Engine.Table("goods_order").Where("id = ?", id).Get(&goodsOrder)
  1579. if err != nil {
  1580. return goodsOrder, err
  1581. }
  1582. return goodsOrder, nil
  1583. }
  1584. func GetGoodsOrderListInId(ids []int64) ([]domain.GoodsOrder, error) {
  1585. rows, err := configs.Engine.Table("goods_order").In("id", ids).Rows(&domain.GoodsOrder{})
  1586. if err != nil {
  1587. return make([]domain.GoodsOrder, 0), err
  1588. }
  1589. defer rows.Close()
  1590. var list []domain.GoodsOrder
  1591. for rows.Next() {
  1592. var u domain.GoodsOrder
  1593. rows.Scan(&u)
  1594. list = append(list, u)
  1595. }
  1596. return list, nil
  1597. }
  1598. func GetGoodsOrderList(goodsOrder domain.GoodsOrder, pageNum, pageSize int) (vo.BaseListVo, error) {
  1599. var arr []domain.GoodsOrder
  1600. Count, err := configs.Engine.Table("goods_order").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsOrder)
  1601. var vo vo.BaseListVo
  1602. if err != nil {
  1603. return vo, err
  1604. }
  1605. if err != nil {
  1606. return vo, err
  1607. }
  1608. vo.PageNum = pageNum
  1609. vo.PageSize = pageSize
  1610. vo.List = make([]any, len(arr))
  1611. for i, v := range arr {
  1612. vo.List[i] = v
  1613. }
  1614. vo.Total = int(Count)
  1615. return vo, nil
  1616. }
  1617. func Get2GoodsOrderList(query domain.GoodsOrderQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1618. var arr []domain.GoodsOrder
  1619. session := configs.Engine.Table("goods_order").Limit(pageSize, (pageNum-1)*pageSize)
  1620. if query.Id != 0{
  1621. session.Where("id = ?", query.Id)
  1622. }
  1623. if query.OrderName != ""{
  1624. session.Where("order_name = ?", query.OrderName)
  1625. }
  1626. if query.SkuId != 0{
  1627. session.Where("sku_id = ?", query.SkuId)
  1628. }
  1629. if query.Count != 0{
  1630. session.Where("count = ?", query.Count)
  1631. }
  1632. if query.Price != 0{
  1633. session.Where("price = ?", query.Price)
  1634. }
  1635. if query.TotalPrice != 0{
  1636. session.Where("total_price = ?", query.TotalPrice)
  1637. }
  1638. if query.ContactInformation != ""{
  1639. session.Where("contact_information = ?", query.ContactInformation)
  1640. }
  1641. if query.CouponUserId != 0{
  1642. session.Where("coupon_user_id = ?", query.CouponUserId)
  1643. }
  1644. if query.State != ""{
  1645. session.Where("state = ?", query.State)
  1646. }
  1647. if query.CreateBy != 0{
  1648. session.Where("create_by = ?", query.CreateBy)
  1649. }
  1650. if query.CreateTime != ""{
  1651. session.Where("create_time = ?", query.CreateTime)
  1652. }
  1653. if query.OtherData != ""{
  1654. session.Where("other_data = ?", query.OtherData)
  1655. }
  1656. Count, err := session.FindAndCount(&arr, &query)
  1657. var vo vo.BaseListVo
  1658. if err != nil {
  1659. return vo, err
  1660. }
  1661. if err != nil {
  1662. return vo, err
  1663. }
  1664. vo.PageNum = pageNum
  1665. vo.PageSize = pageSize
  1666. vo.List = make([]any, len(arr))
  1667. for i, v := range arr {
  1668. vo.List[i] = v
  1669. }
  1670. vo.Total = int(Count)
  1671. return vo, nil
  1672. }
  1673. func SaveGoodsOrder(goodsOrder *domain.GoodsOrder) (domain.GoodsOrder, error) {
  1674. _, err := configs.Engine.Table("goods_order").Insert(&goodsOrder)
  1675. if err != nil {
  1676. return *goodsOrder, err
  1677. }
  1678. return *goodsOrder, nil
  1679. }
  1680. func SetGoodsOrder(goodsOrderMap map[string]interface{}, id int64) (domain.GoodsOrder, bool, error) {
  1681. var goodsOrder domain.GoodsOrder
  1682. _, err := configs.Engine.Table("goods_order").Where("id = ?", id).Update(goodsOrderMap)
  1683. if err != nil {
  1684. return goodsOrder, false, err
  1685. }
  1686. return goodsOrder, true, nil
  1687. }
  1688. func DeleteGoodsOrder(id int64) bool {
  1689. var goodsOrder domain.GoodsOrder
  1690. i, err := configs.Engine.Table("goods_order").Where("id = ?", id).Delete(&goodsOrder)
  1691. if err != nil {
  1692. return false
  1693. }
  1694. return i > 0
  1695. }
  1696. func GetGoodsSkuById(id int64) (domain.GoodsSku, error) {
  1697. var goodsSku domain.GoodsSku
  1698. _, err := configs.Engine.Table("goods_sku").Where("id = ?", id).Get(&goodsSku)
  1699. if err != nil {
  1700. return goodsSku, err
  1701. }
  1702. return goodsSku, nil
  1703. }
  1704. func GetGoodsSkuListInId(ids []int64) ([]domain.GoodsSku, error) {
  1705. rows, err := configs.Engine.Table("goods_sku").In("id", ids).Rows(&domain.GoodsSku{})
  1706. if err != nil {
  1707. return make([]domain.GoodsSku, 0), err
  1708. }
  1709. defer rows.Close()
  1710. var list []domain.GoodsSku
  1711. for rows.Next() {
  1712. var u domain.GoodsSku
  1713. rows.Scan(&u)
  1714. list = append(list, u)
  1715. }
  1716. return list, nil
  1717. }
  1718. func GetGoodsSkuList(goodsSku domain.GoodsSku, pageNum, pageSize int) (vo.BaseListVo, error) {
  1719. var arr []domain.GoodsSku
  1720. Count, err := configs.Engine.Table("goods_sku").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsSku)
  1721. var vo vo.BaseListVo
  1722. if err != nil {
  1723. return vo, err
  1724. }
  1725. if err != nil {
  1726. return vo, err
  1727. }
  1728. vo.PageNum = pageNum
  1729. vo.PageSize = pageSize
  1730. vo.List = make([]any, len(arr))
  1731. for i, v := range arr {
  1732. vo.List[i] = v
  1733. }
  1734. vo.Total = int(Count)
  1735. return vo, nil
  1736. }
  1737. func Get2GoodsSkuList(query domain.GoodsSkuQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1738. var arr []domain.GoodsSku
  1739. session := configs.Engine.Table("goods_sku").Limit(pageSize, (pageNum-1)*pageSize)
  1740. if query.Id != 0{
  1741. session.Where("id = ?", query.Id)
  1742. }
  1743. if query.SkuImage != ""{
  1744. session.Where("sku_image = ?", query.SkuImage)
  1745. }
  1746. if query.SkuName != ""{
  1747. session.Where("sku_name = ?", query.SkuName)
  1748. }
  1749. if query.Price != 0{
  1750. session.Where("price = ?", query.Price)
  1751. }
  1752. if query.HistoricalPrices != 0{
  1753. session.Where("historical_prices = ?", query.HistoricalPrices)
  1754. }
  1755. if query.InventoryNumber != 0{
  1756. session.Where("inventory_number = ?", query.InventoryNumber)
  1757. }
  1758. if query.CommodityAreaId != 0{
  1759. session.Where("commodity_area_id = ?", query.CommodityAreaId)
  1760. }
  1761. if query.GoodsId != 0{
  1762. session.Where("goods_id = ?", query.GoodsId)
  1763. }
  1764. if query.CreateBy != ""{
  1765. session.Where("create_by = ?", query.CreateBy)
  1766. }
  1767. if query.CreateTime != ""{
  1768. session.Where("create_time = ?", query.CreateTime)
  1769. }
  1770. Count, err := session.FindAndCount(&arr, &query)
  1771. var vo vo.BaseListVo
  1772. if err != nil {
  1773. return vo, err
  1774. }
  1775. if err != nil {
  1776. return vo, err
  1777. }
  1778. vo.PageNum = pageNum
  1779. vo.PageSize = pageSize
  1780. vo.List = make([]any, len(arr))
  1781. for i, v := range arr {
  1782. vo.List[i] = v
  1783. }
  1784. vo.Total = int(Count)
  1785. return vo, nil
  1786. }
  1787. func SaveGoodsSku(goodsSku *domain.GoodsSku) (domain.GoodsSku, error) {
  1788. _, err := configs.Engine.Table("goods_sku").Insert(&goodsSku)
  1789. if err != nil {
  1790. return *goodsSku, err
  1791. }
  1792. return *goodsSku, nil
  1793. }
  1794. func SetGoodsSku(goodsSkuMap map[string]interface{}, id int64) (domain.GoodsSku, bool, error) {
  1795. var goodsSku domain.GoodsSku
  1796. _, err := configs.Engine.Table("goods_sku").Where("id = ?", id).Update(goodsSkuMap)
  1797. if err != nil {
  1798. return goodsSku, false, err
  1799. }
  1800. return goodsSku, true, nil
  1801. }
  1802. func DeleteGoodsSku(id int64) bool {
  1803. var goodsSku domain.GoodsSku
  1804. i, err := configs.Engine.Table("goods_sku").Where("id = ?", id).Delete(&goodsSku)
  1805. if err != nil {
  1806. return false
  1807. }
  1808. return i > 0
  1809. }
  1810. func GetGoodsSkuCardById(id int64) (domain.GoodsSkuCard, error) {
  1811. var goodsSkuCard domain.GoodsSkuCard
  1812. _, err := configs.Engine.Table("goods_sku_card").Where("id = ?", id).Get(&goodsSkuCard)
  1813. if err != nil {
  1814. return goodsSkuCard, err
  1815. }
  1816. return goodsSkuCard, nil
  1817. }
  1818. func GetGoodsSkuCardListInId(ids []int64) ([]domain.GoodsSkuCard, error) {
  1819. rows, err := configs.Engine.Table("goods_sku_card").In("id", ids).Rows(&domain.GoodsSkuCard{})
  1820. if err != nil {
  1821. return make([]domain.GoodsSkuCard, 0), err
  1822. }
  1823. defer rows.Close()
  1824. var list []domain.GoodsSkuCard
  1825. for rows.Next() {
  1826. var u domain.GoodsSkuCard
  1827. rows.Scan(&u)
  1828. list = append(list, u)
  1829. }
  1830. return list, nil
  1831. }
  1832. func GetGoodsSkuCardList(goodsSkuCard domain.GoodsSkuCard, pageNum, pageSize int) (vo.BaseListVo, error) {
  1833. var arr []domain.GoodsSkuCard
  1834. Count, err := configs.Engine.Table("goods_sku_card").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsSkuCard)
  1835. var vo vo.BaseListVo
  1836. if err != nil {
  1837. return vo, err
  1838. }
  1839. if err != nil {
  1840. return vo, err
  1841. }
  1842. vo.PageNum = pageNum
  1843. vo.PageSize = pageSize
  1844. vo.List = make([]any, len(arr))
  1845. for i, v := range arr {
  1846. vo.List[i] = v
  1847. }
  1848. vo.Total = int(Count)
  1849. return vo, nil
  1850. }
  1851. func Get2GoodsSkuCardList(query domain.GoodsSkuCardQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1852. var arr []domain.GoodsSkuCard
  1853. session := configs.Engine.Table("goods_sku_card").Limit(pageSize, (pageNum-1)*pageSize)
  1854. if query.Id != 0{
  1855. session.Where("id = ?", query.Id)
  1856. }
  1857. if query.CardName != ""{
  1858. session.Where("card_name = ?", query.CardName)
  1859. }
  1860. if query.State != ""{
  1861. session.Where("state = ?", query.State)
  1862. }
  1863. if query.Count != 0{
  1864. session.Where("count = ?", query.Count)
  1865. }
  1866. if query.TotalCount != ""{
  1867. session.Where("total_count = ?", query.TotalCount)
  1868. }
  1869. if query.CardKey != ""{
  1870. session.Where("card_key = ?", query.CardKey)
  1871. }
  1872. if query.Use != ""{
  1873. session.Where("use = ?", query.Use)
  1874. }
  1875. if query.UploadTime != ""{
  1876. session.Where("upload_time = ?", query.UploadTime)
  1877. }
  1878. if query.SkuId != 0{
  1879. session.Where("sku_id = ?", query.SkuId)
  1880. }
  1881. if query.Sort != ""{
  1882. session.Where("sort = ?", query.Sort)
  1883. }
  1884. Count, err := session.FindAndCount(&arr, &query)
  1885. var vo vo.BaseListVo
  1886. if err != nil {
  1887. return vo, err
  1888. }
  1889. if err != nil {
  1890. return vo, err
  1891. }
  1892. vo.PageNum = pageNum
  1893. vo.PageSize = pageSize
  1894. vo.List = make([]any, len(arr))
  1895. for i, v := range arr {
  1896. vo.List[i] = v
  1897. }
  1898. vo.Total = int(Count)
  1899. return vo, nil
  1900. }
  1901. func SaveGoodsSkuCard(goodsSkuCard *domain.GoodsSkuCard) (domain.GoodsSkuCard, error) {
  1902. _, err := configs.Engine.Table("goods_sku_card").Insert(&goodsSkuCard)
  1903. if err != nil {
  1904. return *goodsSkuCard, err
  1905. }
  1906. return *goodsSkuCard, nil
  1907. }
  1908. func SetGoodsSkuCard(goodsSkuCardMap map[string]interface{}, id int64) (domain.GoodsSkuCard, bool, error) {
  1909. var goodsSkuCard domain.GoodsSkuCard
  1910. _, err := configs.Engine.Table("goods_sku_card").Where("id = ?", id).Update(goodsSkuCardMap)
  1911. if err != nil {
  1912. return goodsSkuCard, false, err
  1913. }
  1914. return goodsSkuCard, true, nil
  1915. }
  1916. func DeleteGoodsSkuCard(id int64) bool {
  1917. var goodsSkuCard domain.GoodsSkuCard
  1918. i, err := configs.Engine.Table("goods_sku_card").Where("id = ?", id).Delete(&goodsSkuCard)
  1919. if err != nil {
  1920. return false
  1921. }
  1922. return i > 0
  1923. }
  1924. func GetGoodsTagById(id int64) (domain.GoodsTag, error) {
  1925. var goodsTag domain.GoodsTag
  1926. _, err := configs.Engine.Table("goods_tag").Where("id = ?", id).Get(&goodsTag)
  1927. if err != nil {
  1928. return goodsTag, err
  1929. }
  1930. return goodsTag, nil
  1931. }
  1932. func GetGoodsTagListInId(ids []int64) ([]domain.GoodsTag, error) {
  1933. rows, err := configs.Engine.Table("goods_tag").In("id", ids).Rows(&domain.GoodsTag{})
  1934. if err != nil {
  1935. return make([]domain.GoodsTag, 0), err
  1936. }
  1937. defer rows.Close()
  1938. var list []domain.GoodsTag
  1939. for rows.Next() {
  1940. var u domain.GoodsTag
  1941. rows.Scan(&u)
  1942. list = append(list, u)
  1943. }
  1944. return list, nil
  1945. }
  1946. func GetGoodsTagList(goodsTag domain.GoodsTag, pageNum, pageSize int) (vo.BaseListVo, error) {
  1947. var arr []domain.GoodsTag
  1948. Count, err := configs.Engine.Table("goods_tag").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsTag)
  1949. var vo vo.BaseListVo
  1950. if err != nil {
  1951. return vo, err
  1952. }
  1953. if err != nil {
  1954. return vo, err
  1955. }
  1956. vo.PageNum = pageNum
  1957. vo.PageSize = pageSize
  1958. vo.List = make([]any, len(arr))
  1959. for i, v := range arr {
  1960. vo.List[i] = v
  1961. }
  1962. vo.Total = int(Count)
  1963. return vo, nil
  1964. }
  1965. func Get2GoodsTagList(query domain.GoodsTagQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1966. var arr []domain.GoodsTag
  1967. session := configs.Engine.Table("goods_tag").Limit(pageSize, (pageNum-1)*pageSize)
  1968. if query.Id != 0{
  1969. session.Where("id = ?", query.Id)
  1970. }
  1971. if query.Name != ""{
  1972. session.Where("name like ?", "%"+query.Name+"%")
  1973. }
  1974. if query.IconUrl != ""{
  1975. session.Where("icon_url = ?", query.IconUrl)
  1976. }
  1977. if query.Tag != ""{
  1978. session.Where("tag = ?", query.Tag)
  1979. }
  1980. Count, err := session.FindAndCount(&arr, &query)
  1981. var vo vo.BaseListVo
  1982. if err != nil {
  1983. return vo, err
  1984. }
  1985. if err != nil {
  1986. return vo, err
  1987. }
  1988. vo.PageNum = pageNum
  1989. vo.PageSize = pageSize
  1990. vo.List = make([]any, len(arr))
  1991. for i, v := range arr {
  1992. vo.List[i] = v
  1993. }
  1994. vo.Total = int(Count)
  1995. return vo, nil
  1996. }
  1997. func SaveGoodsTag(goodsTag *domain.GoodsTag) (domain.GoodsTag, error) {
  1998. _, err := configs.Engine.Table("goods_tag").Insert(&goodsTag)
  1999. if err != nil {
  2000. return *goodsTag, err
  2001. }
  2002. return *goodsTag, nil
  2003. }
  2004. func SetGoodsTag(goodsTagMap map[string]interface{}, id int64) (domain.GoodsTag, bool, error) {
  2005. var goodsTag domain.GoodsTag
  2006. _, err := configs.Engine.Table("goods_tag").Where("id = ?", id).Update(goodsTagMap)
  2007. if err != nil {
  2008. return goodsTag, false, err
  2009. }
  2010. return goodsTag, true, nil
  2011. }
  2012. func DeleteGoodsTag(id int64) bool {
  2013. var goodsTag domain.GoodsTag
  2014. i, err := configs.Engine.Table("goods_tag").Where("id = ?", id).Delete(&goodsTag)
  2015. if err != nil {
  2016. return false
  2017. }
  2018. return i > 0
  2019. }
  2020. func GetGoodsTypeById(id int64) (domain.GoodsType, error) {
  2021. var goodsType domain.GoodsType
  2022. _, err := configs.Engine.Table("goods_type").Where("id = ?", id).Get(&goodsType)
  2023. if err != nil {
  2024. return goodsType, err
  2025. }
  2026. return goodsType, nil
  2027. }
  2028. func GetGoodsTypeListInId(ids []int64) ([]domain.GoodsType, error) {
  2029. rows, err := configs.Engine.Table("goods_type").In("id", ids).Rows(&domain.GoodsType{})
  2030. if err != nil {
  2031. return make([]domain.GoodsType, 0), err
  2032. }
  2033. defer rows.Close()
  2034. var list []domain.GoodsType
  2035. for rows.Next() {
  2036. var u domain.GoodsType
  2037. rows.Scan(&u)
  2038. list = append(list, u)
  2039. }
  2040. return list, nil
  2041. }
  2042. func GetGoodsTypeList(goodsType domain.GoodsType, pageNum, pageSize int) (vo.BaseListVo, error) {
  2043. var arr []domain.GoodsType
  2044. Count, err := configs.Engine.Table("goods_type").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsType)
  2045. var vo vo.BaseListVo
  2046. if err != nil {
  2047. return vo, err
  2048. }
  2049. if err != nil {
  2050. return vo, err
  2051. }
  2052. vo.PageNum = pageNum
  2053. vo.PageSize = pageSize
  2054. vo.List = make([]any, len(arr))
  2055. for i, v := range arr {
  2056. vo.List[i] = v
  2057. }
  2058. vo.Total = int(Count)
  2059. return vo, nil
  2060. }
  2061. func Get2GoodsTypeList(query domain.GoodsTypeQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2062. var arr []domain.GoodsType
  2063. session := configs.Engine.Table("goods_type").Limit(pageSize, (pageNum-1)*pageSize)
  2064. if query.Id != 0{
  2065. session.Where("id = ?", query.Id)
  2066. }
  2067. if query.Sort != 0{
  2068. session.Where("sort = ?", query.Sort)
  2069. }
  2070. if query.TypeImage != ""{
  2071. session.Where("type_image = ?", query.TypeImage)
  2072. }
  2073. if query.TypeName != ""{
  2074. session.Where("type_name = ?", query.TypeName)
  2075. }
  2076. if query.CreateTime != ""{
  2077. session.Where("create_time = ?", query.CreateTime)
  2078. }
  2079. Count, err := session.FindAndCount(&arr, &query)
  2080. var vo vo.BaseListVo
  2081. if err != nil {
  2082. return vo, err
  2083. }
  2084. if err != nil {
  2085. return vo, err
  2086. }
  2087. vo.PageNum = pageNum
  2088. vo.PageSize = pageSize
  2089. vo.List = make([]any, len(arr))
  2090. for i, v := range arr {
  2091. vo.List[i] = v
  2092. }
  2093. vo.Total = int(Count)
  2094. return vo, nil
  2095. }
  2096. func SaveGoodsType(goodsType *domain.GoodsType) (domain.GoodsType, error) {
  2097. _, err := configs.Engine.Table("goods_type").Insert(&goodsType)
  2098. if err != nil {
  2099. return *goodsType, err
  2100. }
  2101. return *goodsType, nil
  2102. }
  2103. func SetGoodsType(goodsTypeMap map[string]interface{}, id int64) (domain.GoodsType, bool, error) {
  2104. var goodsType domain.GoodsType
  2105. _, err := configs.Engine.Table("goods_type").Where("id = ?", id).Update(goodsTypeMap)
  2106. if err != nil {
  2107. return goodsType, false, err
  2108. }
  2109. return goodsType, true, nil
  2110. }
  2111. func DeleteGoodsType(id int64) bool {
  2112. var goodsType domain.GoodsType
  2113. i, err := configs.Engine.Table("goods_type").Where("id = ?", id).Delete(&goodsType)
  2114. if err != nil {
  2115. return false
  2116. }
  2117. return i > 0
  2118. }
  2119. func GetUserById(id int64) (domain.User, error) {
  2120. var user domain.User
  2121. _, err := configs.Engine.Table("user").Where("id = ?", id).Get(&user)
  2122. if err != nil {
  2123. return user, err
  2124. }
  2125. return user, nil
  2126. }
  2127. func GetUserListInId(ids []int64) ([]domain.User, error) {
  2128. rows, err := configs.Engine.Table("user").In("id", ids).Rows(&domain.User{})
  2129. if err != nil {
  2130. return make([]domain.User, 0), err
  2131. }
  2132. defer rows.Close()
  2133. var list []domain.User
  2134. for rows.Next() {
  2135. var u domain.User
  2136. rows.Scan(&u)
  2137. list = append(list, u)
  2138. }
  2139. return list, nil
  2140. }
  2141. func GetUserList(user domain.User, pageNum, pageSize int) (vo.BaseListVo, error) {
  2142. var arr []domain.User
  2143. Count, err := configs.Engine.Table("user").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &user)
  2144. var vo vo.BaseListVo
  2145. if err != nil {
  2146. return vo, err
  2147. }
  2148. if err != nil {
  2149. return vo, err
  2150. }
  2151. vo.PageNum = pageNum
  2152. vo.PageSize = pageSize
  2153. vo.List = make([]any, len(arr))
  2154. for i, v := range arr {
  2155. vo.List[i] = v
  2156. }
  2157. vo.Total = int(Count)
  2158. return vo, nil
  2159. }
  2160. func Get2UserList(query domain.UserQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2161. var arr []domain.User
  2162. session := configs.Engine.Table("user").Limit(pageSize, (pageNum-1)*pageSize)
  2163. if query.Id != 0{
  2164. session.Where("id = ?", query.Id)
  2165. }
  2166. if query.Username != ""{
  2167. session.Where("username = ?", query.Username)
  2168. }
  2169. if query.Password != ""{
  2170. session.Where("password = ?", query.Password)
  2171. }
  2172. if query.CreationTime != 0{
  2173. session.Where("creation_time = ?", query.CreationTime)
  2174. }
  2175. if query.LoginTime != 0{
  2176. session.Where("login_time = ?", query.LoginTime)
  2177. }
  2178. if query.Status != ""{
  2179. session.Where("status = ?", query.Status)
  2180. }
  2181. if query.RoleId != 0{
  2182. session.Where("role_id = ?", query.RoleId)
  2183. }
  2184. if query.Phone != ""{
  2185. session.Where("phone = ?", query.Phone)
  2186. }
  2187. if query.Email != ""{
  2188. session.Where("email = ?", query.Email)
  2189. }
  2190. if query.Name != ""{
  2191. session.Where("name = ?", query.Name)
  2192. }
  2193. if query.Avatar != ""{
  2194. session.Where("avatar = ?", query.Avatar)
  2195. }
  2196. if query.RecommendCode != ""{
  2197. session.Where("recommend_code = ?", query.RecommendCode)
  2198. }
  2199. if query.InviterBy != 0{
  2200. session.Where("inviter_by = ?", query.InviterBy)
  2201. }
  2202. Count, err := session.FindAndCount(&arr, &query)
  2203. var vo vo.BaseListVo
  2204. if err != nil {
  2205. return vo, err
  2206. }
  2207. if err != nil {
  2208. return vo, err
  2209. }
  2210. vo.PageNum = pageNum
  2211. vo.PageSize = pageSize
  2212. vo.List = make([]any, len(arr))
  2213. for i, v := range arr {
  2214. vo.List[i] = v
  2215. }
  2216. vo.Total = int(Count)
  2217. return vo, nil
  2218. }
  2219. func SaveUser(user *domain.User) (domain.User, error) {
  2220. _, err := configs.Engine.Table("user").Insert(&user)
  2221. if err != nil {
  2222. return *user, err
  2223. }
  2224. return *user, nil
  2225. }
  2226. func SetUser(userMap map[string]interface{}, id int64) (domain.User, bool, error) {
  2227. var user domain.User
  2228. _, err := configs.Engine.Table("user").Where("id = ?", id).Update(userMap)
  2229. if err != nil {
  2230. return user, false, err
  2231. }
  2232. return user, true, nil
  2233. }
  2234. func DeleteUser(id int64) bool {
  2235. var user domain.User
  2236. i, err := configs.Engine.Table("user").Where("id = ?", id).Delete(&user)
  2237. if err != nil {
  2238. return false
  2239. }
  2240. return i > 0
  2241. }
  2242. func GetUserWalletById(id int64) (domain.UserWallet, error) {
  2243. var userWallet domain.UserWallet
  2244. _, err := configs.Engine.Table("user_wallet").Where("id = ?", id).Get(&userWallet)
  2245. if err != nil {
  2246. return userWallet, err
  2247. }
  2248. return userWallet, nil
  2249. }
  2250. func GetUserWalletListInId(ids []int64) ([]domain.UserWallet, error) {
  2251. rows, err := configs.Engine.Table("user_wallet").In("id", ids).Rows(&domain.UserWallet{})
  2252. if err != nil {
  2253. return make([]domain.UserWallet, 0), err
  2254. }
  2255. defer rows.Close()
  2256. var list []domain.UserWallet
  2257. for rows.Next() {
  2258. var u domain.UserWallet
  2259. rows.Scan(&u)
  2260. list = append(list, u)
  2261. }
  2262. return list, nil
  2263. }
  2264. func GetUserWalletList(userWallet domain.UserWallet, pageNum, pageSize int) (vo.BaseListVo, error) {
  2265. var arr []domain.UserWallet
  2266. Count, err := configs.Engine.Table("user_wallet").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &userWallet)
  2267. var vo vo.BaseListVo
  2268. if err != nil {
  2269. return vo, err
  2270. }
  2271. if err != nil {
  2272. return vo, err
  2273. }
  2274. vo.PageNum = pageNum
  2275. vo.PageSize = pageSize
  2276. vo.List = make([]any, len(arr))
  2277. for i, v := range arr {
  2278. vo.List[i] = v
  2279. }
  2280. vo.Total = int(Count)
  2281. return vo, nil
  2282. }
  2283. func Get2UserWalletList(query domain.UserWalletQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2284. var arr []domain.UserWallet
  2285. session := configs.Engine.Table("user_wallet").Limit(pageSize, (pageNum-1)*pageSize)
  2286. if query.Id != 0{
  2287. session.Where("id = ?", query.Id)
  2288. }
  2289. if query.UserId != 0{
  2290. session.Where("user_id = ?", query.UserId)
  2291. }
  2292. if query.Balance != 0{
  2293. session.Where("balance = ?", query.Balance)
  2294. }
  2295. if query.PromotionAmount != 0{
  2296. session.Where("promotion_amount = ?", query.PromotionAmount)
  2297. }
  2298. if query.RechargeAmount != 0{
  2299. session.Where("recharge_amount = ?", query.RechargeAmount)
  2300. }
  2301. Count, err := session.FindAndCount(&arr, &query)
  2302. var vo vo.BaseListVo
  2303. if err != nil {
  2304. return vo, err
  2305. }
  2306. if err != nil {
  2307. return vo, err
  2308. }
  2309. vo.PageNum = pageNum
  2310. vo.PageSize = pageSize
  2311. vo.List = make([]any, len(arr))
  2312. for i, v := range arr {
  2313. vo.List[i] = v
  2314. }
  2315. vo.Total = int(Count)
  2316. return vo, nil
  2317. }
  2318. func SaveUserWallet(userWallet *domain.UserWallet) (domain.UserWallet, error) {
  2319. _, err := configs.Engine.Table("user_wallet").Insert(&userWallet)
  2320. if err != nil {
  2321. return *userWallet, err
  2322. }
  2323. return *userWallet, nil
  2324. }
  2325. func SetUserWallet(userWalletMap map[string]interface{}, id int64) (domain.UserWallet, bool, error) {
  2326. var userWallet domain.UserWallet
  2327. _, err := configs.Engine.Table("user_wallet").Where("id = ?", id).Update(userWalletMap)
  2328. if err != nil {
  2329. return userWallet, false, err
  2330. }
  2331. return userWallet, true, nil
  2332. }
  2333. func DeleteUserWallet(id int64) bool {
  2334. var userWallet domain.UserWallet
  2335. i, err := configs.Engine.Table("user_wallet").Where("id = ?", id).Delete(&userWallet)
  2336. if err != nil {
  2337. return false
  2338. }
  2339. return i > 0
  2340. }
  2341. func GetDictDataById(id int64) (domain.DictData, error) {
  2342. var dictData domain.DictData
  2343. _, err := configs.Engine.Table("dict_data").Where("id = ?", id).Get(&dictData)
  2344. if err != nil {
  2345. return dictData, err
  2346. }
  2347. return dictData, nil
  2348. }
  2349. func GetDictDataListInId(ids []int64) ([]domain.DictData, error) {
  2350. rows, err := configs.Engine.Table("dict_data").In("id", ids).Rows(&domain.DictData{})
  2351. if err != nil {
  2352. return make([]domain.DictData, 0), err
  2353. }
  2354. defer rows.Close()
  2355. var list []domain.DictData
  2356. for rows.Next() {
  2357. var u domain.DictData
  2358. rows.Scan(&u)
  2359. list = append(list, u)
  2360. }
  2361. return list, nil
  2362. }
  2363. func GetDictDataList(dictData domain.DictData, pageNum, pageSize int) (vo.BaseListVo, error) {
  2364. var arr []domain.DictData
  2365. Count, err := configs.Engine.Table("dict_data").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &dictData)
  2366. var vo vo.BaseListVo
  2367. if err != nil {
  2368. return vo, err
  2369. }
  2370. if err != nil {
  2371. return vo, err
  2372. }
  2373. vo.PageNum = pageNum
  2374. vo.PageSize = pageSize
  2375. vo.List = make([]any, len(arr))
  2376. for i, v := range arr {
  2377. vo.List[i] = v
  2378. }
  2379. vo.Total = int(Count)
  2380. return vo, nil
  2381. }
  2382. func Get2DictDataList(query domain.DictDataQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2383. var arr []domain.DictData
  2384. session := configs.Engine.Table("dict_data").Limit(pageSize, (pageNum-1)*pageSize)
  2385. if query.Id != 0{
  2386. session.Where("id = ?", query.Id)
  2387. }
  2388. if query.Sort != 0{
  2389. session.Where("sort = ?", query.Sort)
  2390. }
  2391. if query.DictLabel != ""{
  2392. session.Where("dict_label = ?", query.DictLabel)
  2393. }
  2394. if query.DictValue != ""{
  2395. session.Where("dict_value = ?", query.DictValue)
  2396. }
  2397. if query.DictType != ""{
  2398. session.Where("dict_type = ?", query.DictType)
  2399. }
  2400. if query.Status != ""{
  2401. session.Where("status = ?", query.Status)
  2402. }
  2403. if query.CssStyle != ""{
  2404. session.Where("css_style = ?", query.CssStyle)
  2405. }
  2406. if query.IsDefault != ""{
  2407. session.Where("is_default = ?", query.IsDefault)
  2408. }
  2409. if query.Remark != ""{
  2410. session.Where("remark = ?", query.Remark)
  2411. }
  2412. Count, err := session.FindAndCount(&arr, &query)
  2413. var vo vo.BaseListVo
  2414. if err != nil {
  2415. return vo, err
  2416. }
  2417. if err != nil {
  2418. return vo, err
  2419. }
  2420. vo.PageNum = pageNum
  2421. vo.PageSize = pageSize
  2422. vo.List = make([]any, len(arr))
  2423. for i, v := range arr {
  2424. vo.List[i] = v
  2425. }
  2426. vo.Total = int(Count)
  2427. return vo, nil
  2428. }
  2429. func SaveDictData(dictData *domain.DictData) (domain.DictData, error) {
  2430. _, err := configs.Engine.Table("dict_data").Insert(&dictData)
  2431. if err != nil {
  2432. return *dictData, err
  2433. }
  2434. return *dictData, nil
  2435. }
  2436. func SetDictData(dictDataMap map[string]interface{}, id int64) (domain.DictData, bool, error) {
  2437. var dictData domain.DictData
  2438. _, err := configs.Engine.Table("dict_data").Where("id = ?", id).Update(dictDataMap)
  2439. if err != nil {
  2440. return dictData, false, err
  2441. }
  2442. return dictData, true, nil
  2443. }
  2444. func DeleteDictData(id int64) bool {
  2445. var dictData domain.DictData
  2446. i, err := configs.Engine.Table("dict_data").Where("id = ?", id).Delete(&dictData)
  2447. if err != nil {
  2448. return false
  2449. }
  2450. return i > 0
  2451. }
  2452. func GetDictTypeById(id int64) (domain.DictType, error) {
  2453. var dictType domain.DictType
  2454. _, err := configs.Engine.Table("dict_type").Where("id = ?", id).Get(&dictType)
  2455. if err != nil {
  2456. return dictType, err
  2457. }
  2458. return dictType, nil
  2459. }
  2460. func GetDictTypeListInId(ids []int64) ([]domain.DictType, error) {
  2461. rows, err := configs.Engine.Table("dict_type").In("id", ids).Rows(&domain.DictType{})
  2462. if err != nil {
  2463. return make([]domain.DictType, 0), err
  2464. }
  2465. defer rows.Close()
  2466. var list []domain.DictType
  2467. for rows.Next() {
  2468. var u domain.DictType
  2469. rows.Scan(&u)
  2470. list = append(list, u)
  2471. }
  2472. return list, nil
  2473. }
  2474. func GetDictTypeList(dictType domain.DictType, pageNum, pageSize int) (vo.BaseListVo, error) {
  2475. var arr []domain.DictType
  2476. Count, err := configs.Engine.Table("dict_type").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &dictType)
  2477. var vo vo.BaseListVo
  2478. if err != nil {
  2479. return vo, err
  2480. }
  2481. if err != nil {
  2482. return vo, err
  2483. }
  2484. vo.PageNum = pageNum
  2485. vo.PageSize = pageSize
  2486. vo.List = make([]any, len(arr))
  2487. for i, v := range arr {
  2488. vo.List[i] = v
  2489. }
  2490. vo.Total = int(Count)
  2491. return vo, nil
  2492. }
  2493. func Get2DictTypeList(query domain.DictTypeQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2494. var arr []domain.DictType
  2495. session := configs.Engine.Table("dict_type").Limit(pageSize, (pageNum-1)*pageSize)
  2496. if query.Id != 0{
  2497. session.Where("id = ?", query.Id)
  2498. }
  2499. if query.DictName != ""{
  2500. session.Where("dict_name = ?", query.DictName)
  2501. }
  2502. if query.DictType != ""{
  2503. session.Where("dict_type = ?", query.DictType)
  2504. }
  2505. if query.Status != ""{
  2506. session.Where("status = ?", query.Status)
  2507. }
  2508. if query.Remark != ""{
  2509. session.Where("remark = ?", query.Remark)
  2510. }
  2511. Count, err := session.FindAndCount(&arr, &query)
  2512. var vo vo.BaseListVo
  2513. if err != nil {
  2514. return vo, err
  2515. }
  2516. if err != nil {
  2517. return vo, err
  2518. }
  2519. vo.PageNum = pageNum
  2520. vo.PageSize = pageSize
  2521. vo.List = make([]any, len(arr))
  2522. for i, v := range arr {
  2523. vo.List[i] = v
  2524. }
  2525. vo.Total = int(Count)
  2526. return vo, nil
  2527. }
  2528. func SaveDictType(dictType *domain.DictType) (domain.DictType, error) {
  2529. _, err := configs.Engine.Table("dict_type").Insert(&dictType)
  2530. if err != nil {
  2531. return *dictType, err
  2532. }
  2533. return *dictType, nil
  2534. }
  2535. func SetDictType(dictTypeMap map[string]interface{}, id int64) (domain.DictType, bool, error) {
  2536. var dictType domain.DictType
  2537. _, err := configs.Engine.Table("dict_type").Where("id = ?", id).Update(dictTypeMap)
  2538. if err != nil {
  2539. return dictType, false, err
  2540. }
  2541. return dictType, true, nil
  2542. }
  2543. func DeleteDictType(id int64) bool {
  2544. var dictType domain.DictType
  2545. i, err := configs.Engine.Table("dict_type").Where("id = ?", id).Delete(&dictType)
  2546. if err != nil {
  2547. return false
  2548. }
  2549. return i > 0
  2550. }
  2551. func GetManageUserById(id int64) (domain.ManageUser, error) {
  2552. var manageUser domain.ManageUser
  2553. _, err := configs.Engine.Table("manage_user").Where("id = ?", id).Get(&manageUser)
  2554. if err != nil {
  2555. return manageUser, err
  2556. }
  2557. return manageUser, nil
  2558. }
  2559. func GetManageUserListInId(ids []int64) ([]domain.ManageUser, error) {
  2560. rows, err := configs.Engine.Table("manage_user").In("id", ids).Rows(&domain.ManageUser{})
  2561. if err != nil {
  2562. return make([]domain.ManageUser, 0), err
  2563. }
  2564. defer rows.Close()
  2565. var list []domain.ManageUser
  2566. for rows.Next() {
  2567. var u domain.ManageUser
  2568. rows.Scan(&u)
  2569. list = append(list, u)
  2570. }
  2571. return list, nil
  2572. }
  2573. func GetManageUserList(manageUser domain.ManageUser, pageNum, pageSize int) (vo.BaseListVo, error) {
  2574. var arr []domain.ManageUser
  2575. Count, err := configs.Engine.Table("manage_user").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &manageUser)
  2576. var vo vo.BaseListVo
  2577. if err != nil {
  2578. return vo, err
  2579. }
  2580. if err != nil {
  2581. return vo, err
  2582. }
  2583. vo.PageNum = pageNum
  2584. vo.PageSize = pageSize
  2585. vo.List = make([]any, len(arr))
  2586. for i, v := range arr {
  2587. vo.List[i] = v
  2588. }
  2589. vo.Total = int(Count)
  2590. return vo, nil
  2591. }
  2592. func Get2ManageUserList(query domain.ManageUserQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2593. var arr []domain.ManageUser
  2594. session := configs.Engine.Table("manage_user").Limit(pageSize, (pageNum-1)*pageSize)
  2595. if query.Id != 0{
  2596. session.Where("id = ?", query.Id)
  2597. }
  2598. if query.Name != ""{
  2599. session.Where("name = ?", query.Name)
  2600. }
  2601. if query.Username != ""{
  2602. session.Where("username = ?", query.Username)
  2603. }
  2604. if query.Password != ""{
  2605. session.Where("password = ?", query.Password)
  2606. }
  2607. if query.CreationTime != 0{
  2608. session.Where("creation_time = ?", query.CreationTime)
  2609. }
  2610. if query.LoginTime != 0{
  2611. session.Where("login_time = ?", query.LoginTime)
  2612. }
  2613. if query.Status != ""{
  2614. session.Where("status = ?", query.Status)
  2615. }
  2616. if query.RoleId != 0{
  2617. session.Where("role_id = ?", query.RoleId)
  2618. }
  2619. if query.Phone != ""{
  2620. session.Where("phone = ?", query.Phone)
  2621. }
  2622. if query.Email != ""{
  2623. session.Where("email = ?", query.Email)
  2624. }
  2625. if query.Avatar != ""{
  2626. session.Where("avatar = ?", query.Avatar)
  2627. }
  2628. Count, err := session.FindAndCount(&arr, &query)
  2629. var vo vo.BaseListVo
  2630. if err != nil {
  2631. return vo, err
  2632. }
  2633. if err != nil {
  2634. return vo, err
  2635. }
  2636. vo.PageNum = pageNum
  2637. vo.PageSize = pageSize
  2638. vo.List = make([]any, len(arr))
  2639. for i, v := range arr {
  2640. vo.List[i] = v
  2641. }
  2642. vo.Total = int(Count)
  2643. return vo, nil
  2644. }
  2645. func SaveManageUser(manageUser *domain.ManageUser) (domain.ManageUser, error) {
  2646. _, err := configs.Engine.Table("manage_user").Insert(&manageUser)
  2647. if err != nil {
  2648. return *manageUser, err
  2649. }
  2650. return *manageUser, nil
  2651. }
  2652. func SetManageUser(manageUserMap map[string]interface{}, id int64) (domain.ManageUser, bool, error) {
  2653. var manageUser domain.ManageUser
  2654. _, err := configs.Engine.Table("manage_user").Where("id = ?", id).Update(manageUserMap)
  2655. if err != nil {
  2656. return manageUser, false, err
  2657. }
  2658. return manageUser, true, nil
  2659. }
  2660. func DeleteManageUser(id int64) bool {
  2661. var manageUser domain.ManageUser
  2662. i, err := configs.Engine.Table("manage_user").Where("id = ?", id).Delete(&manageUser)
  2663. if err != nil {
  2664. return false
  2665. }
  2666. return i > 0
  2667. }
  2668. func GetShopTopicById(id int64) (domain.ShopTopic, error) {
  2669. var shopTopic domain.ShopTopic
  2670. _, err := configs.Engine.Table("shop_topic").Where("id = ?", id).Get(&shopTopic)
  2671. if err != nil {
  2672. return shopTopic, err
  2673. }
  2674. return shopTopic, nil
  2675. }
  2676. func GetShopTopicListInId(ids []int64) ([]domain.ShopTopic, error) {
  2677. rows, err := configs.Engine.Table("shop_topic").In("id", ids).Rows(&domain.ShopTopic{})
  2678. if err != nil {
  2679. return make([]domain.ShopTopic, 0), err
  2680. }
  2681. defer rows.Close()
  2682. var list []domain.ShopTopic
  2683. for rows.Next() {
  2684. var u domain.ShopTopic
  2685. rows.Scan(&u)
  2686. list = append(list, u)
  2687. }
  2688. return list, nil
  2689. }
  2690. func GetShopTopicList(shopTopic domain.ShopTopic, pageNum, pageSize int) (vo.BaseListVo, error) {
  2691. var arr []domain.ShopTopic
  2692. Count, err := configs.Engine.Table("shop_topic").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &shopTopic)
  2693. var vo vo.BaseListVo
  2694. if err != nil {
  2695. return vo, err
  2696. }
  2697. if err != nil {
  2698. return vo, err
  2699. }
  2700. vo.PageNum = pageNum
  2701. vo.PageSize = pageSize
  2702. vo.List = make([]any, len(arr))
  2703. for i, v := range arr {
  2704. vo.List[i] = v
  2705. }
  2706. vo.Total = int(Count)
  2707. return vo, nil
  2708. }
  2709. func Get2ShopTopicList(query domain.ShopTopicQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2710. var arr []domain.ShopTopic
  2711. session := configs.Engine.Table("shop_topic").Limit(pageSize, (pageNum-1)*pageSize)
  2712. if query.Id != 0{
  2713. session.Where("id = ?", query.Id)
  2714. }
  2715. if query.Sort != ""{
  2716. session.Where("sort = ?", query.Sort)
  2717. }
  2718. if query.ParentId != 0{
  2719. session.Where("parent_id = ?", query.ParentId)
  2720. }
  2721. if query.TopicPageImage != ""{
  2722. session.Where("topic_page_image = ?", query.TopicPageImage)
  2723. }
  2724. if query.TopicName != ""{
  2725. session.Where("topic_name = ?", query.TopicName)
  2726. }
  2727. if query.TopicDesc != ""{
  2728. session.Where("topic_desc = ?", query.TopicDesc)
  2729. }
  2730. if query.TypeIds != ""{
  2731. session.Where("type_ids = ?", query.TypeIds)
  2732. }
  2733. Count, err := session.FindAndCount(&arr, &query)
  2734. var vo vo.BaseListVo
  2735. if err != nil {
  2736. return vo, err
  2737. }
  2738. if err != nil {
  2739. return vo, err
  2740. }
  2741. vo.PageNum = pageNum
  2742. vo.PageSize = pageSize
  2743. vo.List = make([]any, len(arr))
  2744. for i, v := range arr {
  2745. vo.List[i] = v
  2746. }
  2747. vo.Total = int(Count)
  2748. return vo, nil
  2749. }
  2750. func SaveShopTopic(shopTopic *domain.ShopTopic) (domain.ShopTopic, error) {
  2751. _, err := configs.Engine.Table("shop_topic").Insert(&shopTopic)
  2752. if err != nil {
  2753. return *shopTopic, err
  2754. }
  2755. return *shopTopic, nil
  2756. }
  2757. func SetShopTopic(shopTopicMap map[string]interface{}, id int64) (domain.ShopTopic, bool, error) {
  2758. var shopTopic domain.ShopTopic
  2759. _, err := configs.Engine.Table("shop_topic").Where("id = ?", id).Update(shopTopicMap)
  2760. if err != nil {
  2761. return shopTopic, false, err
  2762. }
  2763. return shopTopic, true, nil
  2764. }
  2765. func DeleteShopTopic(id int64) bool {
  2766. var shopTopic domain.ShopTopic
  2767. i, err := configs.Engine.Table("shop_topic").Where("id = ?", id).Delete(&shopTopic)
  2768. if err != nil {
  2769. return false
  2770. }
  2771. return i > 0
  2772. }
  2773. func GetShopAdviceCarouselById(id int64) (domain.ShopAdviceCarousel, error) {
  2774. var shopAdviceCarousel domain.ShopAdviceCarousel
  2775. _, err := configs.Engine.Table("shop_advice_carousel").Where("id = ?", id).Get(&shopAdviceCarousel)
  2776. if err != nil {
  2777. return shopAdviceCarousel, err
  2778. }
  2779. return shopAdviceCarousel, nil
  2780. }
  2781. func GetShopAdviceCarouselListInId(ids []int64) ([]domain.ShopAdviceCarousel, error) {
  2782. rows, err := configs.Engine.Table("shop_advice_carousel").In("id", ids).Rows(&domain.ShopAdviceCarousel{})
  2783. if err != nil {
  2784. return make([]domain.ShopAdviceCarousel, 0), err
  2785. }
  2786. defer rows.Close()
  2787. var list []domain.ShopAdviceCarousel
  2788. for rows.Next() {
  2789. var u domain.ShopAdviceCarousel
  2790. rows.Scan(&u)
  2791. list = append(list, u)
  2792. }
  2793. return list, nil
  2794. }
  2795. func GetShopAdviceCarouselList(shopAdviceCarousel domain.ShopAdviceCarousel, pageNum, pageSize int) (vo.BaseListVo, error) {
  2796. var arr []domain.ShopAdviceCarousel
  2797. Count, err := configs.Engine.Table("shop_advice_carousel").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &shopAdviceCarousel)
  2798. var vo vo.BaseListVo
  2799. if err != nil {
  2800. return vo, err
  2801. }
  2802. if err != nil {
  2803. return vo, err
  2804. }
  2805. vo.PageNum = pageNum
  2806. vo.PageSize = pageSize
  2807. vo.List = make([]any, len(arr))
  2808. for i, v := range arr {
  2809. vo.List[i] = v
  2810. }
  2811. vo.Total = int(Count)
  2812. return vo, nil
  2813. }
  2814. func Get2ShopAdviceCarouselList(query domain.ShopAdviceCarouselQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2815. var arr []domain.ShopAdviceCarousel
  2816. session := configs.Engine.Table("shop_advice_carousel").Limit(pageSize, (pageNum-1)*pageSize)
  2817. if query.Id != 0{
  2818. session.Where("id = ?", query.Id)
  2819. }
  2820. if query.Name != ""{
  2821. session.Where("name = ?", query.Name)
  2822. }
  2823. if query.ToId != 0{
  2824. session.Where("to_id = ?", query.ToId)
  2825. }
  2826. if query.AdviceType != ""{
  2827. session.Where("advice_type = ?", query.AdviceType)
  2828. }
  2829. if query.Sort != ""{
  2830. session.Where("sort = ?", query.Sort)
  2831. }
  2832. if query.State != ""{
  2833. session.Where("state = ?", query.State)
  2834. }
  2835. if query.ShowType != ""{
  2836. session.Where("show_type = ?", query.ShowType)
  2837. }
  2838. if query.CreateBy != ""{
  2839. session.Where("create_by = ?", query.CreateBy)
  2840. }
  2841. if query.CreateTime != ""{
  2842. session.Where("create_time = ?", query.CreateTime)
  2843. }
  2844. if query.UpdateBy != ""{
  2845. session.Where("update_by = ?", query.UpdateBy)
  2846. }
  2847. if query.UpdateTime != ""{
  2848. session.Where("update_time = ?", query.UpdateTime)
  2849. }
  2850. if query.ImageUrl != ""{
  2851. session.Where("image_url = ?", query.ImageUrl)
  2852. }
  2853. if query.ToType != ""{
  2854. session.Where("to_type = ?", query.ToType)
  2855. }
  2856. Count, err := session.FindAndCount(&arr, &query)
  2857. var vo vo.BaseListVo
  2858. if err != nil {
  2859. return vo, err
  2860. }
  2861. if err != nil {
  2862. return vo, err
  2863. }
  2864. vo.PageNum = pageNum
  2865. vo.PageSize = pageSize
  2866. vo.List = make([]any, len(arr))
  2867. for i, v := range arr {
  2868. vo.List[i] = v
  2869. }
  2870. vo.Total = int(Count)
  2871. return vo, nil
  2872. }
  2873. func SaveShopAdviceCarousel(shopAdviceCarousel *domain.ShopAdviceCarousel) (domain.ShopAdviceCarousel, error) {
  2874. _, err := configs.Engine.Table("shop_advice_carousel").Insert(&shopAdviceCarousel)
  2875. if err != nil {
  2876. return *shopAdviceCarousel, err
  2877. }
  2878. return *shopAdviceCarousel, nil
  2879. }
  2880. func SetShopAdviceCarousel(shopAdviceCarouselMap map[string]interface{}, id int64) (domain.ShopAdviceCarousel, bool, error) {
  2881. var shopAdviceCarousel domain.ShopAdviceCarousel
  2882. _, err := configs.Engine.Table("shop_advice_carousel").Where("id = ?", id).Update(shopAdviceCarouselMap)
  2883. if err != nil {
  2884. return shopAdviceCarousel, false, err
  2885. }
  2886. return shopAdviceCarousel, true, nil
  2887. }
  2888. func DeleteShopAdviceCarousel(id int64) bool {
  2889. var shopAdviceCarousel domain.ShopAdviceCarousel
  2890. i, err := configs.Engine.Table("shop_advice_carousel").Where("id = ?", id).Delete(&shopAdviceCarousel)
  2891. if err != nil {
  2892. return false
  2893. }
  2894. return i > 0
  2895. }
  2896. func GetShopTopicSkuById(id int64) (domain.ShopTopicSku, error) {
  2897. var shopTopicSku domain.ShopTopicSku
  2898. _, err := configs.Engine.Table("shop_topic_sku").Where("id = ?", id).Get(&shopTopicSku)
  2899. if err != nil {
  2900. return shopTopicSku, err
  2901. }
  2902. return shopTopicSku, nil
  2903. }
  2904. func GetShopTopicSkuListInId(ids []int64) ([]domain.ShopTopicSku, error) {
  2905. rows, err := configs.Engine.Table("shop_topic_sku").In("id", ids).Rows(&domain.ShopTopicSku{})
  2906. if err != nil {
  2907. return make([]domain.ShopTopicSku, 0), err
  2908. }
  2909. defer rows.Close()
  2910. var list []domain.ShopTopicSku
  2911. for rows.Next() {
  2912. var u domain.ShopTopicSku
  2913. rows.Scan(&u)
  2914. list = append(list, u)
  2915. }
  2916. return list, nil
  2917. }
  2918. func GetShopTopicSkuList(shopTopicSku domain.ShopTopicSku, pageNum, pageSize int) (vo.BaseListVo, error) {
  2919. var arr []domain.ShopTopicSku
  2920. Count, err := configs.Engine.Table("shop_topic_sku").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &shopTopicSku)
  2921. var vo vo.BaseListVo
  2922. if err != nil {
  2923. return vo, err
  2924. }
  2925. if err != nil {
  2926. return vo, err
  2927. }
  2928. vo.PageNum = pageNum
  2929. vo.PageSize = pageSize
  2930. vo.List = make([]any, len(arr))
  2931. for i, v := range arr {
  2932. vo.List[i] = v
  2933. }
  2934. vo.Total = int(Count)
  2935. return vo, nil
  2936. }
  2937. func Get2ShopTopicSkuList(query domain.ShopTopicSkuQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2938. var arr []domain.ShopTopicSku
  2939. session := configs.Engine.Table("shop_topic_sku").Limit(pageSize, (pageNum-1)*pageSize)
  2940. if query.Id != 0{
  2941. session.Where("id = ?", query.Id)
  2942. }
  2943. if query.TopicId != 0{
  2944. session.Where("topic_id = ?", query.TopicId)
  2945. }
  2946. if query.SkuId != 0{
  2947. session.Where("sku_id = ?", query.SkuId)
  2948. }
  2949. Count, err := session.FindAndCount(&arr, &query)
  2950. var vo vo.BaseListVo
  2951. if err != nil {
  2952. return vo, err
  2953. }
  2954. if err != nil {
  2955. return vo, err
  2956. }
  2957. vo.PageNum = pageNum
  2958. vo.PageSize = pageSize
  2959. vo.List = make([]any, len(arr))
  2960. for i, v := range arr {
  2961. vo.List[i] = v
  2962. }
  2963. vo.Total = int(Count)
  2964. return vo, nil
  2965. }
  2966. func SaveShopTopicSku(shopTopicSku *domain.ShopTopicSku) (domain.ShopTopicSku, error) {
  2967. _, err := configs.Engine.Table("shop_topic_sku").Insert(&shopTopicSku)
  2968. if err != nil {
  2969. return *shopTopicSku, err
  2970. }
  2971. return *shopTopicSku, nil
  2972. }
  2973. func SetShopTopicSku(shopTopicSkuMap map[string]interface{}, id int64) (domain.ShopTopicSku, bool, error) {
  2974. var shopTopicSku domain.ShopTopicSku
  2975. _, err := configs.Engine.Table("shop_topic_sku").Where("id = ?", id).Update(shopTopicSkuMap)
  2976. if err != nil {
  2977. return shopTopicSku, false, err
  2978. }
  2979. return shopTopicSku, true, nil
  2980. }
  2981. func DeleteShopTopicSku(id int64) bool {
  2982. var shopTopicSku domain.ShopTopicSku
  2983. i, err := configs.Engine.Table("shop_topic_sku").Where("id = ?", id).Delete(&shopTopicSku)
  2984. if err != nil {
  2985. return false
  2986. }
  2987. return i > 0
  2988. }