Dao.go 82 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221
  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.PublishTimeStart != "" || query.PublishTimeEnd != "" {
  73. session.Where("publish_time between ? and ?", query.PublishTimeStart, query.PublishTimeEnd)
  74. }
  75. if query.EyeFillStart != 0 || query.EyeFillEnd != 0 {
  76. session.Where("eye_fill between ? and ?", query.EyeFillStart, query.EyeFillEnd)
  77. }
  78. if query.LikeCountStart != 0 || query.LikeCountEnd != 0 {
  79. session.Where("like_count between ? and ?", query.LikeCountStart, query.LikeCountEnd)
  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 like ?", "%"+query.ArticleDesc+"%")
  95. }
  96. Count, err := session.FindAndCount(&arr)
  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 like ?", "%"+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)
  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 like ?", "%"+query.TopicName+"%")
  287. }
  288. if query.TopicDesc != "" {
  289. session.Where("topic_desc like ?", "%"+query.TopicDesc+"%")
  290. }
  291. Count, err := session.FindAndCount(&arr)
  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)
  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 like ?", "%"+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 like ?", "%"+query.Remark+"%")
  497. }
  498. if query.BackRouterPath != "" {
  499. session.Where("back_router_path like ?", "%"+query.BackRouterPath+"%")
  500. }
  501. if query.State != "" {
  502. session.Where("state = ?", query.State)
  503. }
  504. Count, err := session.FindAndCount(&arr)
  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 like ?", "%"+query.RoleName+"%")
  593. }
  594. Count, err := session.FindAndCount(&arr)
  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)
  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)
  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 like ?", "%"+query.TableName+"%")
  869. }
  870. if query.TableComment != "" {
  871. session.Where("table_comment like ?", "%"+query.TableComment+"%")
  872. }
  873. if query.Name != "" {
  874. session.Where("name like ?", "%"+query.Name+"%")
  875. }
  876. if query.RouterName != "" {
  877. session.Where("router_name like ?", "%"+query.RouterName+"%")
  878. }
  879. if query.Remark != "" {
  880. session.Where("remark like ?", "%"+query.Remark+"%")
  881. }
  882. Count, err := session.FindAndCount(&arr)
  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 like ?", "%"+query.ColumnComment+"%")
  977. }
  978. if query.ColumnType != "" {
  979. session.Where("column_type like ?", "%"+query.ColumnType+"%")
  980. }
  981. if query.GoType != "" {
  982. session.Where("go_type like ?", "%"+query.GoType+"%")
  983. }
  984. if query.GoField != "" {
  985. session.Where("go_field like ?", "%"+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 like ?", "%"+query.DictType+"%")
  1004. }
  1005. if query.ColumnName != "" {
  1006. session.Where("column_name like ?", "%"+query.ColumnName+"%")
  1007. }
  1008. Count, err := session.FindAndCount(&arr)
  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)
  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 like ?", "%"+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)
  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 like ?", "%"+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.ValidityPeriodStart != "" || query.ValidityPeriodEnd != "" {
  1330. session.Where("validity_period between ? and ?", query.ValidityPeriodStart, query.ValidityPeriodEnd)
  1331. }
  1332. Count, err := session.FindAndCount(&arr)
  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)
  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 like ?", "%"+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)
  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 like ?", "%"+query.OrderName+"%")
  1625. }
  1626. if query.SkuId != 0 {
  1627. session.Where("sku_id = ?", query.SkuId)
  1628. }
  1629. if query.CountStart != 0 || query.CountEnd != 0 {
  1630. session.Where("count between ? and ?", query.CountStart, query.CountEnd)
  1631. }
  1632. if query.PriceStart != 0 || query.PriceEnd != 0 {
  1633. session.Where("price between ? and ?", query.PriceStart, query.PriceEnd)
  1634. }
  1635. if query.TotalPriceStart != 0 || query.TotalPriceEnd != 0 {
  1636. session.Where("total_price between ? and ?", query.TotalPriceStart, query.TotalPriceEnd)
  1637. }
  1638. if query.ContactInformation != "" {
  1639. session.Where("contact_information like ?", "%"+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)
  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 like ?", "%"+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.CreateTimeStart != "" || query.CreateTimeEnd != "" {
  1768. session.Where("create_time between ? and ?", query.CreateTimeStart, query.CreateTimeEnd)
  1769. }
  1770. if query.Sort != 0 {
  1771. session.Where("sort = ?", query.Sort)
  1772. }
  1773. if query.SeoTitle != "" {
  1774. session.Where("seo_title = ?", query.SeoTitle)
  1775. }
  1776. if query.SeoKeywords != "" {
  1777. session.Where("seo_keywords = ?", query.SeoKeywords)
  1778. }
  1779. if query.SeoDescription != "" {
  1780. session.Where("seo_description = ?", query.SeoDescription)
  1781. }
  1782. Count, err := session.FindAndCount(&arr)
  1783. var vo vo.BaseListVo
  1784. if err != nil {
  1785. return vo, err
  1786. }
  1787. if err != nil {
  1788. return vo, err
  1789. }
  1790. vo.PageNum = pageNum
  1791. vo.PageSize = pageSize
  1792. vo.List = make([]any, len(arr))
  1793. for i, v := range arr {
  1794. vo.List[i] = v
  1795. }
  1796. vo.Total = int(Count)
  1797. return vo, nil
  1798. }
  1799. func SaveGoodsSku(goodsSku *domain.GoodsSku) (domain.GoodsSku, error) {
  1800. _, err := configs.Engine.Table("goods_sku").Insert(&goodsSku)
  1801. if err != nil {
  1802. return *goodsSku, err
  1803. }
  1804. return *goodsSku, nil
  1805. }
  1806. func SetGoodsSku(goodsSkuMap map[string]interface{}, id int64) (domain.GoodsSku, bool, error) {
  1807. var goodsSku domain.GoodsSku
  1808. _, err := configs.Engine.Table("goods_sku").Where("id = ?", id).Update(goodsSkuMap)
  1809. if err != nil {
  1810. return goodsSku, false, err
  1811. }
  1812. return goodsSku, true, nil
  1813. }
  1814. func DeleteGoodsSku(id int64) bool {
  1815. var goodsSku domain.GoodsSku
  1816. i, err := configs.Engine.Table("goods_sku").Where("id = ?", id).Delete(&goodsSku)
  1817. if err != nil {
  1818. return false
  1819. }
  1820. return i > 0
  1821. }
  1822. func GetGoodsSkuCardById(id int64) (domain.GoodsSkuCard, error) {
  1823. var goodsSkuCard domain.GoodsSkuCard
  1824. _, err := configs.Engine.Table("goods_sku_card").Where("id = ?", id).Get(&goodsSkuCard)
  1825. if err != nil {
  1826. return goodsSkuCard, err
  1827. }
  1828. return goodsSkuCard, nil
  1829. }
  1830. func GetGoodsSkuCardListInId(ids []int64) ([]domain.GoodsSkuCard, error) {
  1831. rows, err := configs.Engine.Table("goods_sku_card").In("id", ids).Rows(&domain.GoodsSkuCard{})
  1832. if err != nil {
  1833. return make([]domain.GoodsSkuCard, 0), err
  1834. }
  1835. defer rows.Close()
  1836. var list []domain.GoodsSkuCard
  1837. for rows.Next() {
  1838. var u domain.GoodsSkuCard
  1839. rows.Scan(&u)
  1840. list = append(list, u)
  1841. }
  1842. return list, nil
  1843. }
  1844. func GetGoodsSkuCardList(goodsSkuCard domain.GoodsSkuCard, pageNum, pageSize int) (vo.BaseListVo, error) {
  1845. var arr []domain.GoodsSkuCard
  1846. Count, err := configs.Engine.Table("goods_sku_card").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsSkuCard)
  1847. var vo vo.BaseListVo
  1848. if err != nil {
  1849. return vo, err
  1850. }
  1851. if err != nil {
  1852. return vo, err
  1853. }
  1854. vo.PageNum = pageNum
  1855. vo.PageSize = pageSize
  1856. vo.List = make([]any, len(arr))
  1857. for i, v := range arr {
  1858. vo.List[i] = v
  1859. }
  1860. vo.Total = int(Count)
  1861. return vo, nil
  1862. }
  1863. func Get2GoodsSkuCardList(query domain.GoodsSkuCardQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1864. var arr []domain.GoodsSkuCard
  1865. session := configs.Engine.Table("goods_sku_card").Limit(pageSize, (pageNum-1)*pageSize)
  1866. if query.Id != 0 {
  1867. session.Where("id = ?", query.Id)
  1868. }
  1869. if query.CardName != "" {
  1870. session.Where("card_name like ?", "%"+query.CardName+"%")
  1871. }
  1872. if query.State != "" {
  1873. session.Where("state = ?", query.State)
  1874. }
  1875. if query.Count != 0 {
  1876. session.Where("count = ?", query.Count)
  1877. }
  1878. if query.TotalCount != "" {
  1879. session.Where("total_count = ?", query.TotalCount)
  1880. }
  1881. if query.CardKey != "" {
  1882. session.Where("card_key like ?", "%"+query.CardKey+"%")
  1883. }
  1884. if query.Use != "" {
  1885. session.Where("use = ?", query.Use)
  1886. }
  1887. if query.UploadTimeStart != "" || query.UploadTimeEnd != "" {
  1888. session.Where("upload_time between ? and ?", query.UploadTimeStart, query.UploadTimeEnd)
  1889. }
  1890. if query.SkuId != 0 {
  1891. session.Where("sku_id = ?", query.SkuId)
  1892. }
  1893. if query.Sort != "" {
  1894. session.Where("sort = ?", query.Sort)
  1895. }
  1896. Count, err := session.FindAndCount(&arr)
  1897. var vo vo.BaseListVo
  1898. if err != nil {
  1899. return vo, err
  1900. }
  1901. if err != nil {
  1902. return vo, err
  1903. }
  1904. vo.PageNum = pageNum
  1905. vo.PageSize = pageSize
  1906. vo.List = make([]any, len(arr))
  1907. for i, v := range arr {
  1908. vo.List[i] = v
  1909. }
  1910. vo.Total = int(Count)
  1911. return vo, nil
  1912. }
  1913. func SaveGoodsSkuCard(goodsSkuCard *domain.GoodsSkuCard) (domain.GoodsSkuCard, error) {
  1914. _, err := configs.Engine.Table("goods_sku_card").Insert(&goodsSkuCard)
  1915. if err != nil {
  1916. return *goodsSkuCard, err
  1917. }
  1918. return *goodsSkuCard, nil
  1919. }
  1920. func SetGoodsSkuCard(goodsSkuCardMap map[string]interface{}, id int64) (domain.GoodsSkuCard, bool, error) {
  1921. var goodsSkuCard domain.GoodsSkuCard
  1922. _, err := configs.Engine.Table("goods_sku_card").Where("id = ?", id).Update(goodsSkuCardMap)
  1923. if err != nil {
  1924. return goodsSkuCard, false, err
  1925. }
  1926. return goodsSkuCard, true, nil
  1927. }
  1928. func DeleteGoodsSkuCard(id int64) bool {
  1929. var goodsSkuCard domain.GoodsSkuCard
  1930. i, err := configs.Engine.Table("goods_sku_card").Where("id = ?", id).Delete(&goodsSkuCard)
  1931. if err != nil {
  1932. return false
  1933. }
  1934. return i > 0
  1935. }
  1936. func GetGoodsTagById(id int64) (domain.GoodsTag, error) {
  1937. var goodsTag domain.GoodsTag
  1938. _, err := configs.Engine.Table("goods_tag").Where("id = ?", id).Get(&goodsTag)
  1939. if err != nil {
  1940. return goodsTag, err
  1941. }
  1942. return goodsTag, nil
  1943. }
  1944. func GetGoodsTagListInId(ids []int64) ([]domain.GoodsTag, error) {
  1945. rows, err := configs.Engine.Table("goods_tag").In("id", ids).Rows(&domain.GoodsTag{})
  1946. if err != nil {
  1947. return make([]domain.GoodsTag, 0), err
  1948. }
  1949. defer rows.Close()
  1950. var list []domain.GoodsTag
  1951. for rows.Next() {
  1952. var u domain.GoodsTag
  1953. rows.Scan(&u)
  1954. list = append(list, u)
  1955. }
  1956. return list, nil
  1957. }
  1958. func GetGoodsTagList(goodsTag domain.GoodsTag, pageNum, pageSize int) (vo.BaseListVo, error) {
  1959. var arr []domain.GoodsTag
  1960. Count, err := configs.Engine.Table("goods_tag").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsTag)
  1961. var vo vo.BaseListVo
  1962. if err != nil {
  1963. return vo, err
  1964. }
  1965. if err != nil {
  1966. return vo, err
  1967. }
  1968. vo.PageNum = pageNum
  1969. vo.PageSize = pageSize
  1970. vo.List = make([]any, len(arr))
  1971. for i, v := range arr {
  1972. vo.List[i] = v
  1973. }
  1974. vo.Total = int(Count)
  1975. return vo, nil
  1976. }
  1977. func Get2GoodsTagList(query domain.GoodsTagQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  1978. var arr []domain.GoodsTag
  1979. session := configs.Engine.Table("goods_tag").Limit(pageSize, (pageNum-1)*pageSize)
  1980. if query.Id != 0 {
  1981. session.Where("id = ?", query.Id)
  1982. }
  1983. if query.Name != "" {
  1984. session.Where("name like ?", "%"+query.Name+"%")
  1985. }
  1986. if query.IconUrl != "" {
  1987. session.Where("icon_url = ?", query.IconUrl)
  1988. }
  1989. if query.Tag != "" {
  1990. session.Where("tag = ?", query.Tag)
  1991. }
  1992. Count, err := session.FindAndCount(&arr)
  1993. var vo vo.BaseListVo
  1994. if err != nil {
  1995. return vo, err
  1996. }
  1997. if err != nil {
  1998. return vo, err
  1999. }
  2000. vo.PageNum = pageNum
  2001. vo.PageSize = pageSize
  2002. vo.List = make([]any, len(arr))
  2003. for i, v := range arr {
  2004. vo.List[i] = v
  2005. }
  2006. vo.Total = int(Count)
  2007. return vo, nil
  2008. }
  2009. func SaveGoodsTag(goodsTag *domain.GoodsTag) (domain.GoodsTag, error) {
  2010. _, err := configs.Engine.Table("goods_tag").Insert(&goodsTag)
  2011. if err != nil {
  2012. return *goodsTag, err
  2013. }
  2014. return *goodsTag, nil
  2015. }
  2016. func SetGoodsTag(goodsTagMap map[string]interface{}, id int64) (domain.GoodsTag, bool, error) {
  2017. var goodsTag domain.GoodsTag
  2018. _, err := configs.Engine.Table("goods_tag").Where("id = ?", id).Update(goodsTagMap)
  2019. if err != nil {
  2020. return goodsTag, false, err
  2021. }
  2022. return goodsTag, true, nil
  2023. }
  2024. func DeleteGoodsTag(id int64) bool {
  2025. var goodsTag domain.GoodsTag
  2026. i, err := configs.Engine.Table("goods_tag").Where("id = ?", id).Delete(&goodsTag)
  2027. if err != nil {
  2028. return false
  2029. }
  2030. return i > 0
  2031. }
  2032. func GetGoodsTypeById(id int64) (domain.GoodsType, error) {
  2033. var goodsType domain.GoodsType
  2034. _, err := configs.Engine.Table("goods_type").Where("id = ?", id).Get(&goodsType)
  2035. if err != nil {
  2036. return goodsType, err
  2037. }
  2038. return goodsType, nil
  2039. }
  2040. func GetGoodsTypeListInId(ids []int64) ([]domain.GoodsType, error) {
  2041. rows, err := configs.Engine.Table("goods_type").In("id", ids).Rows(&domain.GoodsType{})
  2042. if err != nil {
  2043. return make([]domain.GoodsType, 0), err
  2044. }
  2045. defer rows.Close()
  2046. var list []domain.GoodsType
  2047. for rows.Next() {
  2048. var u domain.GoodsType
  2049. rows.Scan(&u)
  2050. list = append(list, u)
  2051. }
  2052. return list, nil
  2053. }
  2054. func GetGoodsTypeList(goodsType domain.GoodsType, pageNum, pageSize int) (vo.BaseListVo, error) {
  2055. var arr []domain.GoodsType
  2056. Count, err := configs.Engine.Table("goods_type").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &goodsType)
  2057. var vo vo.BaseListVo
  2058. if err != nil {
  2059. return vo, err
  2060. }
  2061. if err != nil {
  2062. return vo, err
  2063. }
  2064. vo.PageNum = pageNum
  2065. vo.PageSize = pageSize
  2066. vo.List = make([]any, len(arr))
  2067. for i, v := range arr {
  2068. vo.List[i] = v
  2069. }
  2070. vo.Total = int(Count)
  2071. return vo, nil
  2072. }
  2073. func Get2GoodsTypeList(query domain.GoodsTypeQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2074. var arr []domain.GoodsType
  2075. session := configs.Engine.Table("goods_type").Limit(pageSize, (pageNum-1)*pageSize)
  2076. if query.Id != 0 {
  2077. session.Where("id = ?", query.Id)
  2078. }
  2079. if query.Sort != 0 {
  2080. session.Where("sort = ?", query.Sort)
  2081. }
  2082. if query.TypeImage != "" {
  2083. session.Where("type_image = ?", query.TypeImage)
  2084. }
  2085. if query.TypeName != "" {
  2086. session.Where("type_name like ?", "%"+query.TypeName+"%")
  2087. }
  2088. if query.CreateTimeStart != "" || query.CreateTimeEnd != "" {
  2089. session.Where("create_time between ? and ?", query.CreateTimeStart, query.CreateTimeEnd)
  2090. }
  2091. Count, err := session.FindAndCount(&arr)
  2092. var vo vo.BaseListVo
  2093. if err != nil {
  2094. return vo, err
  2095. }
  2096. if err != nil {
  2097. return vo, err
  2098. }
  2099. vo.PageNum = pageNum
  2100. vo.PageSize = pageSize
  2101. vo.List = make([]any, len(arr))
  2102. for i, v := range arr {
  2103. vo.List[i] = v
  2104. }
  2105. vo.Total = int(Count)
  2106. return vo, nil
  2107. }
  2108. func SaveGoodsType(goodsType *domain.GoodsType) (domain.GoodsType, error) {
  2109. _, err := configs.Engine.Table("goods_type").Insert(&goodsType)
  2110. if err != nil {
  2111. return *goodsType, err
  2112. }
  2113. return *goodsType, nil
  2114. }
  2115. func SetGoodsType(goodsTypeMap map[string]interface{}, id int64) (domain.GoodsType, bool, error) {
  2116. var goodsType domain.GoodsType
  2117. _, err := configs.Engine.Table("goods_type").Where("id = ?", id).Update(goodsTypeMap)
  2118. if err != nil {
  2119. return goodsType, false, err
  2120. }
  2121. return goodsType, true, nil
  2122. }
  2123. func DeleteGoodsType(id int64) bool {
  2124. var goodsType domain.GoodsType
  2125. i, err := configs.Engine.Table("goods_type").Where("id = ?", id).Delete(&goodsType)
  2126. if err != nil {
  2127. return false
  2128. }
  2129. return i > 0
  2130. }
  2131. func GetUserById(id int64) (domain.User, error) {
  2132. var user domain.User
  2133. _, err := configs.Engine.Table("user").Where("id = ?", id).Get(&user)
  2134. if err != nil {
  2135. return user, err
  2136. }
  2137. return user, nil
  2138. }
  2139. func GetUserListInId(ids []int64) ([]domain.User, error) {
  2140. rows, err := configs.Engine.Table("user").In("id", ids).Rows(&domain.User{})
  2141. if err != nil {
  2142. return make([]domain.User, 0), err
  2143. }
  2144. defer rows.Close()
  2145. var list []domain.User
  2146. for rows.Next() {
  2147. var u domain.User
  2148. rows.Scan(&u)
  2149. list = append(list, u)
  2150. }
  2151. return list, nil
  2152. }
  2153. func GetUserList(user domain.User, pageNum, pageSize int) (vo.BaseListVo, error) {
  2154. var arr []domain.User
  2155. Count, err := configs.Engine.Table("user").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &user)
  2156. var vo vo.BaseListVo
  2157. if err != nil {
  2158. return vo, err
  2159. }
  2160. if err != nil {
  2161. return vo, err
  2162. }
  2163. vo.PageNum = pageNum
  2164. vo.PageSize = pageSize
  2165. vo.List = make([]any, len(arr))
  2166. for i, v := range arr {
  2167. vo.List[i] = v
  2168. }
  2169. vo.Total = int(Count)
  2170. return vo, nil
  2171. }
  2172. func Get2UserList(query domain.UserQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2173. var arr []domain.User
  2174. session := configs.Engine.Table("user").Limit(pageSize, (pageNum-1)*pageSize)
  2175. if query.Id != 0 {
  2176. session.Where("id = ?", query.Id)
  2177. }
  2178. if query.Username != "" {
  2179. session.Where("username like ?", "%"+query.Username+"%")
  2180. }
  2181. if query.Password != "" {
  2182. session.Where("password = ?", query.Password)
  2183. }
  2184. if query.CreationTime != 0 {
  2185. session.Where("creation_time = ?", query.CreationTime)
  2186. }
  2187. if query.LoginTime != 0 {
  2188. session.Where("login_time = ?", query.LoginTime)
  2189. }
  2190. if query.Status != "" {
  2191. session.Where("status = ?", query.Status)
  2192. }
  2193. if query.RoleId != 0 {
  2194. session.Where("role_id = ?", query.RoleId)
  2195. }
  2196. if query.Phone != "" {
  2197. session.Where("phone like ?", "%"+query.Phone+"%")
  2198. }
  2199. if query.Email != "" {
  2200. session.Where("email like ?", "%"+query.Email+"%")
  2201. }
  2202. if query.Name != "" {
  2203. session.Where("name like ?", "%"+query.Name+"%")
  2204. }
  2205. if query.Avatar != "" {
  2206. session.Where("avatar = ?", query.Avatar)
  2207. }
  2208. if query.RecommendCode != "" {
  2209. session.Where("recommend_code = ?", query.RecommendCode)
  2210. }
  2211. if query.InviterBy != 0 {
  2212. session.Where("inviter_by = ?", query.InviterBy)
  2213. }
  2214. Count, err := session.FindAndCount(&arr)
  2215. var vo vo.BaseListVo
  2216. if err != nil {
  2217. return vo, err
  2218. }
  2219. if err != nil {
  2220. return vo, err
  2221. }
  2222. vo.PageNum = pageNum
  2223. vo.PageSize = pageSize
  2224. vo.List = make([]any, len(arr))
  2225. for i, v := range arr {
  2226. vo.List[i] = v
  2227. }
  2228. vo.Total = int(Count)
  2229. return vo, nil
  2230. }
  2231. func SaveUser(user *domain.User) (domain.User, error) {
  2232. _, err := configs.Engine.Table("user").Insert(&user)
  2233. if err != nil {
  2234. return *user, err
  2235. }
  2236. return *user, nil
  2237. }
  2238. func SetUser(userMap map[string]interface{}, id int64) (domain.User, bool, error) {
  2239. var user domain.User
  2240. _, err := configs.Engine.Table("user").Where("id = ?", id).Update(userMap)
  2241. if err != nil {
  2242. return user, false, err
  2243. }
  2244. return user, true, nil
  2245. }
  2246. func DeleteUser(id int64) bool {
  2247. var user domain.User
  2248. i, err := configs.Engine.Table("user").Where("id = ?", id).Delete(&user)
  2249. if err != nil {
  2250. return false
  2251. }
  2252. return i > 0
  2253. }
  2254. func GetUserWalletById(id int64) (domain.UserWallet, error) {
  2255. var userWallet domain.UserWallet
  2256. _, err := configs.Engine.Table("user_wallet").Where("id = ?", id).Get(&userWallet)
  2257. if err != nil {
  2258. return userWallet, err
  2259. }
  2260. return userWallet, nil
  2261. }
  2262. func GetUserWalletListInId(ids []int64) ([]domain.UserWallet, error) {
  2263. rows, err := configs.Engine.Table("user_wallet").In("id", ids).Rows(&domain.UserWallet{})
  2264. if err != nil {
  2265. return make([]domain.UserWallet, 0), err
  2266. }
  2267. defer rows.Close()
  2268. var list []domain.UserWallet
  2269. for rows.Next() {
  2270. var u domain.UserWallet
  2271. rows.Scan(&u)
  2272. list = append(list, u)
  2273. }
  2274. return list, nil
  2275. }
  2276. func GetUserWalletList(userWallet domain.UserWallet, pageNum, pageSize int) (vo.BaseListVo, error) {
  2277. var arr []domain.UserWallet
  2278. Count, err := configs.Engine.Table("user_wallet").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &userWallet)
  2279. var vo vo.BaseListVo
  2280. if err != nil {
  2281. return vo, err
  2282. }
  2283. if err != nil {
  2284. return vo, err
  2285. }
  2286. vo.PageNum = pageNum
  2287. vo.PageSize = pageSize
  2288. vo.List = make([]any, len(arr))
  2289. for i, v := range arr {
  2290. vo.List[i] = v
  2291. }
  2292. vo.Total = int(Count)
  2293. return vo, nil
  2294. }
  2295. func Get2UserWalletList(query domain.UserWalletQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2296. var arr []domain.UserWallet
  2297. session := configs.Engine.Table("user_wallet").Limit(pageSize, (pageNum-1)*pageSize)
  2298. if query.Id != 0 {
  2299. session.Where("id = ?", query.Id)
  2300. }
  2301. if query.UserId != 0 {
  2302. session.Where("user_id = ?", query.UserId)
  2303. }
  2304. if query.BalanceStart != 0 || query.BalanceEnd != 0 {
  2305. session.Where("balance between ? and ?", query.BalanceStart, query.BalanceEnd)
  2306. }
  2307. if query.PromotionAmountStart != 0 || query.PromotionAmountEnd != 0 {
  2308. session.Where("promotion_amount between ? and ?", query.PromotionAmountStart, query.PromotionAmountEnd)
  2309. }
  2310. if query.RechargeAmountStart != 0 || query.RechargeAmountEnd != 0 {
  2311. session.Where("recharge_amount between ? and ?", query.RechargeAmountStart, query.RechargeAmountEnd)
  2312. }
  2313. Count, err := session.FindAndCount(&arr)
  2314. var vo vo.BaseListVo
  2315. if err != nil {
  2316. return vo, err
  2317. }
  2318. if err != nil {
  2319. return vo, err
  2320. }
  2321. vo.PageNum = pageNum
  2322. vo.PageSize = pageSize
  2323. vo.List = make([]any, len(arr))
  2324. for i, v := range arr {
  2325. vo.List[i] = v
  2326. }
  2327. vo.Total = int(Count)
  2328. return vo, nil
  2329. }
  2330. func SaveUserWallet(userWallet *domain.UserWallet) (domain.UserWallet, error) {
  2331. _, err := configs.Engine.Table("user_wallet").Insert(&userWallet)
  2332. if err != nil {
  2333. return *userWallet, err
  2334. }
  2335. return *userWallet, nil
  2336. }
  2337. func SetUserWallet(userWalletMap map[string]interface{}, id int64) (domain.UserWallet, bool, error) {
  2338. var userWallet domain.UserWallet
  2339. _, err := configs.Engine.Table("user_wallet").Where("id = ?", id).Update(userWalletMap)
  2340. if err != nil {
  2341. return userWallet, false, err
  2342. }
  2343. return userWallet, true, nil
  2344. }
  2345. func DeleteUserWallet(id int64) bool {
  2346. var userWallet domain.UserWallet
  2347. i, err := configs.Engine.Table("user_wallet").Where("id = ?", id).Delete(&userWallet)
  2348. if err != nil {
  2349. return false
  2350. }
  2351. return i > 0
  2352. }
  2353. func GetDictDataById(id int64) (domain.DictData, error) {
  2354. var dictData domain.DictData
  2355. _, err := configs.Engine.Table("dict_data").Where("id = ?", id).Get(&dictData)
  2356. if err != nil {
  2357. return dictData, err
  2358. }
  2359. return dictData, nil
  2360. }
  2361. func GetDictDataListInId(ids []int64) ([]domain.DictData, error) {
  2362. rows, err := configs.Engine.Table("dict_data").In("id", ids).Rows(&domain.DictData{})
  2363. if err != nil {
  2364. return make([]domain.DictData, 0), err
  2365. }
  2366. defer rows.Close()
  2367. var list []domain.DictData
  2368. for rows.Next() {
  2369. var u domain.DictData
  2370. rows.Scan(&u)
  2371. list = append(list, u)
  2372. }
  2373. return list, nil
  2374. }
  2375. func GetDictDataList(dictData domain.DictData, pageNum, pageSize int) (vo.BaseListVo, error) {
  2376. var arr []domain.DictData
  2377. Count, err := configs.Engine.Table("dict_data").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &dictData)
  2378. var vo vo.BaseListVo
  2379. if err != nil {
  2380. return vo, err
  2381. }
  2382. if err != nil {
  2383. return vo, err
  2384. }
  2385. vo.PageNum = pageNum
  2386. vo.PageSize = pageSize
  2387. vo.List = make([]any, len(arr))
  2388. for i, v := range arr {
  2389. vo.List[i] = v
  2390. }
  2391. vo.Total = int(Count)
  2392. return vo, nil
  2393. }
  2394. func Get2DictDataList(query domain.DictDataQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2395. var arr []domain.DictData
  2396. session := configs.Engine.Table("dict_data").Limit(pageSize, (pageNum-1)*pageSize)
  2397. if query.Id != 0 {
  2398. session.Where("id = ?", query.Id)
  2399. }
  2400. if query.Sort != 0 {
  2401. session.Where("sort = ?", query.Sort)
  2402. }
  2403. if query.DictLabel != "" {
  2404. session.Where("dict_label like ?", "%"+query.DictLabel+"%")
  2405. }
  2406. if query.DictValue != "" {
  2407. session.Where("dict_value like ?", "%"+query.DictValue+"%")
  2408. }
  2409. if query.DictType != "" {
  2410. session.Where("dict_type like ?", "%"+query.DictType+"%")
  2411. }
  2412. if query.Status != "" {
  2413. session.Where("status = ?", query.Status)
  2414. }
  2415. if query.CssStyle != "" {
  2416. session.Where("css_style = ?", query.CssStyle)
  2417. }
  2418. if query.IsDefault != "" {
  2419. session.Where("is_default = ?", query.IsDefault)
  2420. }
  2421. if query.Remark != "" {
  2422. session.Where("remark like ?", "%"+query.Remark+"%")
  2423. }
  2424. Count, err := session.FindAndCount(&arr)
  2425. var vo vo.BaseListVo
  2426. if err != nil {
  2427. return vo, err
  2428. }
  2429. if err != nil {
  2430. return vo, err
  2431. }
  2432. vo.PageNum = pageNum
  2433. vo.PageSize = pageSize
  2434. vo.List = make([]any, len(arr))
  2435. for i, v := range arr {
  2436. vo.List[i] = v
  2437. }
  2438. vo.Total = int(Count)
  2439. return vo, nil
  2440. }
  2441. func SaveDictData(dictData *domain.DictData) (domain.DictData, error) {
  2442. _, err := configs.Engine.Table("dict_data").Insert(&dictData)
  2443. if err != nil {
  2444. return *dictData, err
  2445. }
  2446. return *dictData, nil
  2447. }
  2448. func SetDictData(dictDataMap map[string]interface{}, id int64) (domain.DictData, bool, error) {
  2449. var dictData domain.DictData
  2450. _, err := configs.Engine.Table("dict_data").Where("id = ?", id).Update(dictDataMap)
  2451. if err != nil {
  2452. return dictData, false, err
  2453. }
  2454. return dictData, true, nil
  2455. }
  2456. func DeleteDictData(id int64) bool {
  2457. var dictData domain.DictData
  2458. i, err := configs.Engine.Table("dict_data").Where("id = ?", id).Delete(&dictData)
  2459. if err != nil {
  2460. return false
  2461. }
  2462. return i > 0
  2463. }
  2464. func GetDictTypeById(id int64) (domain.DictType, error) {
  2465. var dictType domain.DictType
  2466. _, err := configs.Engine.Table("dict_type").Where("id = ?", id).Get(&dictType)
  2467. if err != nil {
  2468. return dictType, err
  2469. }
  2470. return dictType, nil
  2471. }
  2472. func GetDictTypeListInId(ids []int64) ([]domain.DictType, error) {
  2473. rows, err := configs.Engine.Table("dict_type").In("id", ids).Rows(&domain.DictType{})
  2474. if err != nil {
  2475. return make([]domain.DictType, 0), err
  2476. }
  2477. defer rows.Close()
  2478. var list []domain.DictType
  2479. for rows.Next() {
  2480. var u domain.DictType
  2481. rows.Scan(&u)
  2482. list = append(list, u)
  2483. }
  2484. return list, nil
  2485. }
  2486. func GetDictTypeList(dictType domain.DictType, pageNum, pageSize int) (vo.BaseListVo, error) {
  2487. var arr []domain.DictType
  2488. Count, err := configs.Engine.Table("dict_type").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &dictType)
  2489. var vo vo.BaseListVo
  2490. if err != nil {
  2491. return vo, err
  2492. }
  2493. if err != nil {
  2494. return vo, err
  2495. }
  2496. vo.PageNum = pageNum
  2497. vo.PageSize = pageSize
  2498. vo.List = make([]any, len(arr))
  2499. for i, v := range arr {
  2500. vo.List[i] = v
  2501. }
  2502. vo.Total = int(Count)
  2503. return vo, nil
  2504. }
  2505. func Get2DictTypeList(query domain.DictTypeQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2506. var arr []domain.DictType
  2507. session := configs.Engine.Table("dict_type").Limit(pageSize, (pageNum-1)*pageSize)
  2508. if query.Id != 0 {
  2509. session.Where("id = ?", query.Id)
  2510. }
  2511. if query.DictName != "" {
  2512. session.Where("dict_name like ?", "%"+query.DictName+"%")
  2513. }
  2514. if query.DictType != "" {
  2515. session.Where("dict_type like ?", "%"+query.DictType+"%")
  2516. }
  2517. if query.Status != "" {
  2518. session.Where("status = ?", query.Status)
  2519. }
  2520. if query.Remark != "" {
  2521. session.Where("remark like ?", "%"+query.Remark+"%")
  2522. }
  2523. Count, err := session.FindAndCount(&arr)
  2524. var vo vo.BaseListVo
  2525. if err != nil {
  2526. return vo, err
  2527. }
  2528. if err != nil {
  2529. return vo, err
  2530. }
  2531. vo.PageNum = pageNum
  2532. vo.PageSize = pageSize
  2533. vo.List = make([]any, len(arr))
  2534. for i, v := range arr {
  2535. vo.List[i] = v
  2536. }
  2537. vo.Total = int(Count)
  2538. return vo, nil
  2539. }
  2540. func SaveDictType(dictType *domain.DictType) (domain.DictType, error) {
  2541. _, err := configs.Engine.Table("dict_type").Insert(&dictType)
  2542. if err != nil {
  2543. return *dictType, err
  2544. }
  2545. return *dictType, nil
  2546. }
  2547. func SetDictType(dictTypeMap map[string]interface{}, id int64) (domain.DictType, bool, error) {
  2548. var dictType domain.DictType
  2549. _, err := configs.Engine.Table("dict_type").Where("id = ?", id).Update(dictTypeMap)
  2550. if err != nil {
  2551. return dictType, false, err
  2552. }
  2553. return dictType, true, nil
  2554. }
  2555. func DeleteDictType(id int64) bool {
  2556. var dictType domain.DictType
  2557. i, err := configs.Engine.Table("dict_type").Where("id = ?", id).Delete(&dictType)
  2558. if err != nil {
  2559. return false
  2560. }
  2561. return i > 0
  2562. }
  2563. func GetShopTopicById(id int64) (domain.ShopTopic, error) {
  2564. var shopTopic domain.ShopTopic
  2565. _, err := configs.Engine.Table("shop_topic").Where("id = ?", id).Get(&shopTopic)
  2566. if err != nil {
  2567. return shopTopic, err
  2568. }
  2569. return shopTopic, nil
  2570. }
  2571. func GetShopTopicListInId(ids []int64) ([]domain.ShopTopic, error) {
  2572. rows, err := configs.Engine.Table("shop_topic").In("id", ids).Rows(&domain.ShopTopic{})
  2573. if err != nil {
  2574. return make([]domain.ShopTopic, 0), err
  2575. }
  2576. defer rows.Close()
  2577. var list []domain.ShopTopic
  2578. for rows.Next() {
  2579. var u domain.ShopTopic
  2580. rows.Scan(&u)
  2581. list = append(list, u)
  2582. }
  2583. return list, nil
  2584. }
  2585. func GetShopTopicList(shopTopic domain.ShopTopic, pageNum, pageSize int) (vo.BaseListVo, error) {
  2586. var arr []domain.ShopTopic
  2587. Count, err := configs.Engine.Table("shop_topic").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &shopTopic)
  2588. var vo vo.BaseListVo
  2589. if err != nil {
  2590. return vo, err
  2591. }
  2592. if err != nil {
  2593. return vo, err
  2594. }
  2595. vo.PageNum = pageNum
  2596. vo.PageSize = pageSize
  2597. vo.List = make([]any, len(arr))
  2598. for i, v := range arr {
  2599. vo.List[i] = v
  2600. }
  2601. vo.Total = int(Count)
  2602. return vo, nil
  2603. }
  2604. func Get2ShopTopicList(query domain.ShopTopicQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2605. var arr []domain.ShopTopic
  2606. session := configs.Engine.Table("shop_topic").Limit(pageSize, (pageNum-1)*pageSize)
  2607. if query.Id != 0 {
  2608. session.Where("id = ?", query.Id)
  2609. }
  2610. if query.Sort != "" {
  2611. session.Where("sort = ?", query.Sort)
  2612. }
  2613. if query.ParentId != 0 {
  2614. session.Where("parent_id = ?", query.ParentId)
  2615. }
  2616. if query.TopicPageImage != "" {
  2617. session.Where("topic_page_image = ?", query.TopicPageImage)
  2618. }
  2619. if query.TopicName != "" {
  2620. session.Where("topic_name like ?", "%"+query.TopicName+"%")
  2621. }
  2622. if query.TopicDesc != "" {
  2623. session.Where("topic_desc like ?", "%"+query.TopicDesc+"%")
  2624. }
  2625. if query.TypeIds != "" {
  2626. session.Where("type_ids = ?", query.TypeIds)
  2627. }
  2628. Count, err := session.FindAndCount(&arr)
  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 SaveShopTopic(shopTopic *domain.ShopTopic) (domain.ShopTopic, error) {
  2646. _, err := configs.Engine.Table("shop_topic").Insert(&shopTopic)
  2647. if err != nil {
  2648. return *shopTopic, err
  2649. }
  2650. return *shopTopic, nil
  2651. }
  2652. func SetShopTopic(shopTopicMap map[string]interface{}, id int64) (domain.ShopTopic, bool, error) {
  2653. var shopTopic domain.ShopTopic
  2654. _, err := configs.Engine.Table("shop_topic").Where("id = ?", id).Update(shopTopicMap)
  2655. if err != nil {
  2656. return shopTopic, false, err
  2657. }
  2658. return shopTopic, true, nil
  2659. }
  2660. func DeleteShopTopic(id int64) bool {
  2661. var shopTopic domain.ShopTopic
  2662. i, err := configs.Engine.Table("shop_topic").Where("id = ?", id).Delete(&shopTopic)
  2663. if err != nil {
  2664. return false
  2665. }
  2666. return i > 0
  2667. }
  2668. func GetShopAdviceCarouselById(id int64) (domain.ShopAdviceCarousel, error) {
  2669. var shopAdviceCarousel domain.ShopAdviceCarousel
  2670. _, err := configs.Engine.Table("shop_advice_carousel").Where("id = ?", id).Get(&shopAdviceCarousel)
  2671. if err != nil {
  2672. return shopAdviceCarousel, err
  2673. }
  2674. return shopAdviceCarousel, nil
  2675. }
  2676. func GetShopAdviceCarouselListInId(ids []int64) ([]domain.ShopAdviceCarousel, error) {
  2677. rows, err := configs.Engine.Table("shop_advice_carousel").In("id", ids).Rows(&domain.ShopAdviceCarousel{})
  2678. if err != nil {
  2679. return make([]domain.ShopAdviceCarousel, 0), err
  2680. }
  2681. defer rows.Close()
  2682. var list []domain.ShopAdviceCarousel
  2683. for rows.Next() {
  2684. var u domain.ShopAdviceCarousel
  2685. rows.Scan(&u)
  2686. list = append(list, u)
  2687. }
  2688. return list, nil
  2689. }
  2690. func GetShopAdviceCarouselList(shopAdviceCarousel domain.ShopAdviceCarousel, pageNum, pageSize int) (vo.BaseListVo, error) {
  2691. var arr []domain.ShopAdviceCarousel
  2692. Count, err := configs.Engine.Table("shop_advice_carousel").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &shopAdviceCarousel)
  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 Get2ShopAdviceCarouselList(query domain.ShopAdviceCarouselQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2710. var arr []domain.ShopAdviceCarousel
  2711. session := configs.Engine.Table("shop_advice_carousel").Limit(pageSize, (pageNum-1)*pageSize)
  2712. if query.Id != 0 {
  2713. session.Where("id = ?", query.Id)
  2714. }
  2715. if query.Name != "" {
  2716. session.Where("name like ?", "%"+query.Name+"%")
  2717. }
  2718. if query.ToId != 0 {
  2719. session.Where("to_id = ?", query.ToId)
  2720. }
  2721. if query.AdviceType != "" {
  2722. session.Where("advice_type = ?", query.AdviceType)
  2723. }
  2724. if query.Sort != "" {
  2725. session.Where("sort = ?", query.Sort)
  2726. }
  2727. if query.State != "" {
  2728. session.Where("state = ?", query.State)
  2729. }
  2730. if query.ShowType != "" {
  2731. session.Where("show_type = ?", query.ShowType)
  2732. }
  2733. if query.CreateBy != "" {
  2734. session.Where("create_by = ?", query.CreateBy)
  2735. }
  2736. if query.CreateTime != "" {
  2737. session.Where("create_time = ?", query.CreateTime)
  2738. }
  2739. if query.UpdateBy != "" {
  2740. session.Where("update_by = ?", query.UpdateBy)
  2741. }
  2742. if query.UpdateTime != "" {
  2743. session.Where("update_time = ?", query.UpdateTime)
  2744. }
  2745. if query.ImageUrl != "" {
  2746. session.Where("image_url = ?", query.ImageUrl)
  2747. }
  2748. if query.ToType != "" {
  2749. session.Where("to_type = ?", query.ToType)
  2750. }
  2751. Count, err := session.FindAndCount(&arr)
  2752. var vo vo.BaseListVo
  2753. if err != nil {
  2754. return vo, err
  2755. }
  2756. if err != nil {
  2757. return vo, err
  2758. }
  2759. vo.PageNum = pageNum
  2760. vo.PageSize = pageSize
  2761. vo.List = make([]any, len(arr))
  2762. for i, v := range arr {
  2763. vo.List[i] = v
  2764. }
  2765. vo.Total = int(Count)
  2766. return vo, nil
  2767. }
  2768. func SaveShopAdviceCarousel(shopAdviceCarousel *domain.ShopAdviceCarousel) (domain.ShopAdviceCarousel, error) {
  2769. _, err := configs.Engine.Table("shop_advice_carousel").Insert(&shopAdviceCarousel)
  2770. if err != nil {
  2771. return *shopAdviceCarousel, err
  2772. }
  2773. return *shopAdviceCarousel, nil
  2774. }
  2775. func SetShopAdviceCarousel(shopAdviceCarouselMap map[string]interface{}, id int64) (domain.ShopAdviceCarousel, bool, error) {
  2776. var shopAdviceCarousel domain.ShopAdviceCarousel
  2777. _, err := configs.Engine.Table("shop_advice_carousel").Where("id = ?", id).Update(shopAdviceCarouselMap)
  2778. if err != nil {
  2779. return shopAdviceCarousel, false, err
  2780. }
  2781. return shopAdviceCarousel, true, nil
  2782. }
  2783. func DeleteShopAdviceCarousel(id int64) bool {
  2784. var shopAdviceCarousel domain.ShopAdviceCarousel
  2785. i, err := configs.Engine.Table("shop_advice_carousel").Where("id = ?", id).Delete(&shopAdviceCarousel)
  2786. if err != nil {
  2787. return false
  2788. }
  2789. return i > 0
  2790. }
  2791. func GetShopTopicSkuById(id int64) (domain.ShopTopicSku, error) {
  2792. var shopTopicSku domain.ShopTopicSku
  2793. _, err := configs.Engine.Table("shop_topic_sku").Where("id = ?", id).Get(&shopTopicSku)
  2794. if err != nil {
  2795. return shopTopicSku, err
  2796. }
  2797. return shopTopicSku, nil
  2798. }
  2799. func GetShopTopicSkuListInId(ids []int64) ([]domain.ShopTopicSku, error) {
  2800. rows, err := configs.Engine.Table("shop_topic_sku").In("id", ids).Rows(&domain.ShopTopicSku{})
  2801. if err != nil {
  2802. return make([]domain.ShopTopicSku, 0), err
  2803. }
  2804. defer rows.Close()
  2805. var list []domain.ShopTopicSku
  2806. for rows.Next() {
  2807. var u domain.ShopTopicSku
  2808. rows.Scan(&u)
  2809. list = append(list, u)
  2810. }
  2811. return list, nil
  2812. }
  2813. func GetShopTopicSkuList(shopTopicSku domain.ShopTopicSku, pageNum, pageSize int) (vo.BaseListVo, error) {
  2814. var arr []domain.ShopTopicSku
  2815. Count, err := configs.Engine.Table("shop_topic_sku").Limit(pageSize, (pageNum-1)*pageSize).FindAndCount(&arr, &shopTopicSku)
  2816. var vo vo.BaseListVo
  2817. if err != nil {
  2818. return vo, err
  2819. }
  2820. if err != nil {
  2821. return vo, err
  2822. }
  2823. vo.PageNum = pageNum
  2824. vo.PageSize = pageSize
  2825. vo.List = make([]any, len(arr))
  2826. for i, v := range arr {
  2827. vo.List[i] = v
  2828. }
  2829. vo.Total = int(Count)
  2830. return vo, nil
  2831. }
  2832. func Get2ShopTopicSkuList(query domain.ShopTopicSkuQuery, pageNum, pageSize int) (vo.BaseListVo, error) {
  2833. var arr []domain.ShopTopicSku
  2834. session := configs.Engine.Table("shop_topic_sku").Limit(pageSize, (pageNum-1)*pageSize)
  2835. if query.Id != 0 {
  2836. session.Where("id = ?", query.Id)
  2837. }
  2838. if query.TopicId != 0 {
  2839. session.Where("topic_id = ?", query.TopicId)
  2840. }
  2841. if query.SkuId != 0 {
  2842. session.Where("sku_id = ?", query.SkuId)
  2843. }
  2844. Count, err := session.FindAndCount(&arr)
  2845. var vo vo.BaseListVo
  2846. if err != nil {
  2847. return vo, err
  2848. }
  2849. if err != nil {
  2850. return vo, err
  2851. }
  2852. vo.PageNum = pageNum
  2853. vo.PageSize = pageSize
  2854. vo.List = make([]any, len(arr))
  2855. for i, v := range arr {
  2856. vo.List[i] = v
  2857. }
  2858. vo.Total = int(Count)
  2859. return vo, nil
  2860. }
  2861. func SaveShopTopicSku(shopTopicSku *domain.ShopTopicSku) (domain.ShopTopicSku, error) {
  2862. _, err := configs.Engine.Table("shop_topic_sku").Insert(&shopTopicSku)
  2863. if err != nil {
  2864. return *shopTopicSku, err
  2865. }
  2866. return *shopTopicSku, nil
  2867. }
  2868. func SetShopTopicSku(shopTopicSkuMap map[string]interface{}, id int64) (domain.ShopTopicSku, bool, error) {
  2869. var shopTopicSku domain.ShopTopicSku
  2870. _, err := configs.Engine.Table("shop_topic_sku").Where("id = ?", id).Update(shopTopicSkuMap)
  2871. if err != nil {
  2872. return shopTopicSku, false, err
  2873. }
  2874. return shopTopicSku, true, nil
  2875. }
  2876. func DeleteShopTopicSku(id int64) bool {
  2877. var shopTopicSku domain.ShopTopicSku
  2878. i, err := configs.Engine.Table("shop_topic_sku").Where("id = ?", id).Delete(&shopTopicSku)
  2879. if err != nil {
  2880. return false
  2881. }
  2882. return i > 0
  2883. }