123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219 |
- package modules
- import (
- "context"
- "errors"
- "strings"
- "golang-fave/engine/utils"
- "golang-fave/engine/wrapper"
- )
- func (this *Modules) RegisterAction_BlogModify() *Action {
- return this.newAction(AInfo{
- Mount: "blog-modify",
- WantAdmin: true,
- }, func(wrap *wrapper.Wrapper) {
- pf_id := utils.Trim(wrap.R.FormValue("id"))
- pf_name := utils.Trim(wrap.R.FormValue("name"))
- pf_alias := utils.Trim(wrap.R.FormValue("alias"))
- pf_category := utils.Trim(wrap.R.FormValue("category"))
- pf_briefly := utils.Trim(wrap.R.FormValue("briefly"))
- pf_content := utils.Trim(wrap.R.FormValue("content"))
- pf_active := utils.Trim(wrap.R.FormValue("active"))
- if pf_active == "" {
- pf_active = "0"
- }
- if !utils.IsNumeric(pf_id) {
- wrap.MsgError(`Inner system error`)
- return
- }
- if !utils.IsNumeric(pf_category) {
- wrap.MsgError(`Inner system error`)
- return
- }
- if pf_name == "" {
- wrap.MsgError(`Please specify post name`)
- return
- }
- if pf_alias == "" {
- pf_alias = utils.GenerateSingleAlias(pf_name)
- }
- if !utils.IsValidSingleAlias(pf_alias) {
- wrap.MsgError(`Please specify correct post alias`)
- return
- }
- // Default is ROOT
- if pf_category == "0" {
- pf_category = "1"
- }
- if pf_id == "0" {
- var lastID int64 = 0
- if err := wrap.DB.Transaction(wrap.R.Context(), func(ctx context.Context, tx *wrapper.Tx) error {
- // Insert row
- res, err := tx.Exec(
- ctx,
- `INSERT INTO fave_blog_posts SET
- user = ?,
- name = ?,
- alias = ?,
- category = ?,
- briefly = ?,
- content = ?,
- datetime = ?,
- active = ?
- ;`,
- wrap.User.A_id,
- pf_name,
- pf_alias,
- utils.StrToInt(pf_category),
- pf_briefly,
- pf_content,
- utils.UnixTimestampToMySqlDateTime(utils.GetCurrentUnixTimestamp()),
- utils.StrToInt(pf_active),
- )
- if err != nil {
- return err
- }
- // Get inserted post id
- lastID, err = res.LastInsertId()
- if err != nil {
- return err
- }
- // Block rows
- if _, err := tx.Exec(ctx, "SELECT id FROM fave_blog_posts WHERE id = ? FOR UPDATE;", lastID); err != nil {
- return err
- }
- // Insert post and categories relations
- catids := utils.GetPostArrayInt("cats[]", wrap.R)
- if len(catids) > 0 {
- var catsCount int
- err = tx.QueryRow(
- ctx,
- `SELECT
- COUNT(*)
- FROM
- fave_blog_cats
- WHERE
- id IN(`+strings.Join(utils.ArrayOfIntToArrayOfString(catids), ",")+`)
- FOR UPDATE;`,
- ).Scan(
- &catsCount,
- )
- if *wrap.LogCpError(&err) != nil {
- return err
- }
- if len(catids) != catsCount {
- return errors.New("Inner system error")
- }
- var balkInsertArr []string
- for _, el := range catids {
- balkInsertArr = append(balkInsertArr, `(`+utils.Int64ToStr(lastID)+`,`+utils.IntToStr(el)+`)`)
- }
- if _, err = tx.Exec(
- ctx,
- `INSERT INTO fave_blog_cat_post_rel (post_id,category_id) VALUES `+strings.Join(balkInsertArr, ",")+`;`,
- ); err != nil {
- return err
- }
- }
- return nil
- }); err != nil {
- wrap.MsgError(err.Error())
- return
- }
- wrap.ResetCacheBlocks()
- wrap.Write(`window.location='/cp/blog/modify/` + utils.Int64ToStr(lastID) + `/';`)
- } else {
- if err := wrap.DB.Transaction(wrap.R.Context(), func(ctx context.Context, tx *wrapper.Tx) error {
- // Block rows
- if _, err := tx.Exec(ctx, "SELECT id FROM fave_blog_posts WHERE id = ? FOR UPDATE;", utils.StrToInt(pf_id)); err != nil {
- return err
- }
- if _, err := tx.Exec(ctx, "SELECT post_id FROM fave_blog_cat_post_rel WHERE post_id = ? FOR UPDATE;", utils.StrToInt(pf_id)); err != nil {
- return err
- }
- // Update row
- if _, err := tx.Exec(
- ctx,
- `UPDATE fave_blog_posts SET
- name = ?,
- alias = ?,
- category = ?,
- briefly = ?,
- content = ?,
- active = ?
- WHERE
- id = ?
- ;`,
- pf_name,
- pf_alias,
- utils.StrToInt(pf_category),
- pf_briefly,
- pf_content,
- utils.StrToInt(pf_active),
- utils.StrToInt(pf_id),
- ); err != nil {
- return err
- }
- // Delete post and categories relations
- if _, err := tx.Exec(ctx, "DELETE FROM fave_blog_cat_post_rel WHERE post_id = ?;", utils.StrToInt(pf_id)); err != nil {
- return err
- }
- // Insert post and categories relations
- catids := utils.GetPostArrayInt("cats[]", wrap.R)
- if len(catids) > 0 {
- var catsCount int
- err := tx.QueryRow(
- ctx,
- `SELECT
- COUNT(*)
- FROM
- fave_blog_cats
- WHERE
- id IN(`+strings.Join(utils.ArrayOfIntToArrayOfString(catids), ",")+`)
- FOR UPDATE;`,
- ).Scan(
- &catsCount,
- )
- if *wrap.LogCpError(&err) != nil {
- return err
- }
- if len(catids) != catsCount {
- return errors.New("Inner system error")
- }
- var balkInsertArr []string
- for _, el := range catids {
- balkInsertArr = append(balkInsertArr, `(`+pf_id+`,`+utils.IntToStr(el)+`)`)
- }
- if _, err := tx.Exec(
- ctx,
- `INSERT INTO fave_blog_cat_post_rel (post_id,category_id) VALUES `+strings.Join(balkInsertArr, ",")+`;`,
- ); err != nil {
- return err
- }
- }
- return nil
- }); err != nil {
- wrap.MsgError(err.Error())
- return
- }
- wrap.ResetCacheBlocks()
- wrap.Write(`window.location='/cp/blog/modify/` + pf_id + `/';`)
- }
- })
- }
|