eta_api/models/data_manage/future_good_chart_info.go

package data_manage

import (
	"eta_gn/eta_api/global"
	"eta_gn/eta_api/utils"
	"fmt"
	"time"
)

func EditFutureGoodChartEnInfoAndEdbEnInfo(chartInfoId int, chartNameEn string, edbInfoId int, edbNameEn, edbUnitEn string) (err error) {
	to := global.DmSQL["data"].Begin()
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	sql := ` UPDATE  chart_info
			SET
			  chart_name_en =?,
			  modify_time = NOW()
			WHERE chart_info_id = ?`

	err = to.Exec(sql, chartNameEn, chartInfoId).Error
	if err != nil {
		fmt.Println("UPDATE  chart_info Err:", err.Error())
		return err
	}
	var count int
	csql := `SELECT COUNT(1) AS count FROM chart_edb_mapping WHERE chart_info_id=? AND edb_info_id=? AND source = 1 `
	err = to.Raw(csql, chartInfoId, edbInfoId).Scan(&count).Error
	if err != nil {
		fmt.Println("QueryRow Err:", err.Error())
		return err
	}
	if count > 0 {
		msql := ` UPDATE  edb_info
			SET edb_name_en = ?,
			  unit_en = ?,
			  modify_time = NOW()
			WHERE edb_info_id = ? `
		err = to.Exec(msql, edbNameEn, edbUnitEn, edbInfoId).Error
		if err != nil {
			fmt.Println("edb_info Err:" + err.Error())
			return err
		}
	}

	return
}

type EditFutureGoodChartInfoBaseReq struct {
	ChartInfoId      int                         `description:"图表ID"`
	ChartName        string                      `description:"图表名称（根据当前语言版本不同而不同）"`
	ProfitName       string                      `description:"利润名称（根据当前语言版本不同而不同）"`
	FutureGoodName   string                      `description:"期货合约名称（根据当前语言版本不同而不同）"`
	ChartEdbInfoList []*EditChartInfoEdbBaseItem `description:"指标及配置信息"`
	XDataList        []string                    `description:"商品价格曲线的X轴数据"`
}

func EditBaseFutureGoodChartInfoAndEdbEnInfo(chartInfo *ChartInfo, req *EditFutureGoodChartInfoBaseReq, lang string) (err error) {
	to := global.DmSQL["data"].Begin()
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	updateChartCols := make([]string, 0)
	switch lang {
	case utils.EnLangVersion:
		chartInfo.ChartNameEn = req.ChartName
		updateChartCols = append(updateChartCols, "ChartNameEn")
	default:
		chartInfo.ChartName = req.ChartName
		updateChartCols = append(updateChartCols, "ChartName")
	}
	chartInfo.ModifyTime = time.Now()
	updateChartCols = append(updateChartCols, "ModifyTime", "BarConfig")
	err = to.Select(updateChartCols).Updates(chartInfo).Error
	if err != nil {
		fmt.Println("UPDATE  chart_info Err:", err.Error())
		return err
	}
	for _, v := range req.ChartEdbInfoList {
		msql := ` UPDATE edb_info SET modify_time = NOW()  `
		pars := make([]interface{}, 0)
		switch lang {
		case utils.EnLangVersion:
			if v.EdbName != `` {
				msql += ` ,edb_name_en = ? `
				pars = append(pars, v.EdbName)
			}

			if v.Unit != `` {
				msql += ` ,unit_en = ? `
				pars = append(pars, v.Unit)
			}

		default:

			if v.EdbName != `` {
				msql += ` ,edb_name = ? `
				pars = append(pars, v.EdbName)
			}

			if v.Unit != `` {
				msql += ` ,unit = ? `
				pars = append(pars, v.Unit)
			}
		}
		msql += ` WHERE edb_info_id = ? `
		pars = append(pars, v.EdbInfoId)
		err = to.Exec(msql, pars...).Error
		if err != nil {
			fmt.Println("edb_info Err:" + err.Error())
			return err
		}
	}

	return
}

func EditFutureGoodProfitChartEnInfoAndEdbEnInfo(chartInfoId int, chartNameEn string, edbInfoId int, edbNameEn, edbUnitEn, profitNameEn string) (err error) {
	to := global.DmSQL["data"].Begin()
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	sql := ` UPDATE  chart_info
			SET chart_name_en =?,modify_time = NOW()
			WHERE chart_info_id = ?`

	err = to.Exec(sql, chartNameEn, chartInfoId).Error
	if err != nil {
		fmt.Println("UPDATE  chart_info Err:", err.Error())
		return
	}

	sql = ` UPDATE  edb_info
			SET edb_name_en = ?,unit_en = ?,modify_time = NOW()
			WHERE edb_info_id = ? `
	err = to.Exec(sql, edbNameEn, edbUnitEn, edbInfoId).Error
	if err != nil {
		fmt.Println("edb_info Err:" + err.Error())
		return
	}

	sql = ` UPDATE  chart_info_future_good_profit
			SET profit_name_en = ?,modify_time = NOW()
			WHERE chart_info_id = ? `
	err = to.Exec(sql, profitNameEn, chartInfoId).Error
	if err != nil {
		fmt.Println("chart_info_future_good_profit Err:" + err.Error())
		return
	}

	return
}

func EditBaseFutureGoodProfitChartInfoAndEdbEnInfo(chartInfo *ChartInfo, req *EditFutureGoodChartInfoBaseReq, lang string) (err error) {
	to := global.DmSQL["data"].Begin()
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	updateChartCols := make([]string, 0)
	switch lang {
	case utils.EnLangVersion:
		chartInfo.ChartNameEn = req.ChartName
		updateChartCols = append(updateChartCols, "ChartNameEn")
	default:
		chartInfo.ChartName = req.ChartName
		updateChartCols = append(updateChartCols, "ChartName")
	}
	chartInfo.ModifyTime = time.Now()
	updateChartCols = append(updateChartCols, "ModifyTime", "ExtraConfig")
	err = to.Select(updateChartCols).Updates(chartInfo).Error
	if err != nil {
		fmt.Println("UPDATE  chart_info Err:", err.Error())
		return err
	}
	var sql string
	for _, v := range req.ChartEdbInfoList {
		msql := ` UPDATE edb_info SET modify_time = NOW()  `
		pars := make([]interface{}, 0)
		switch lang {
		case utils.EnLangVersion:
			if v.EdbName != `` {
				msql += ` ,edb_name_en = ? `
				pars = append(pars, v.EdbName)
			}

			if v.Unit != `` {
				msql += ` ,unit_en = ? `
				pars = append(pars, v.Unit)
			}

		default:

			if v.EdbName != `` {
				msql += ` ,edb_name = ? `
				pars = append(pars, v.EdbName)
			}

			if v.Unit != `` {
				msql += ` ,unit = ? `
				pars = append(pars, v.Unit)
			}
		}
		msql += ` WHERE edb_info_id = ? `
		pars = append(pars, v.EdbInfoId)
		err = to.Exec(msql, pars...).Error
		if err != nil {
			fmt.Println("edb_info Err:" + err.Error())
			return err
		}
	}

	switch lang {
	case utils.EnLangVersion:
		sql = ` UPDATE  chart_info_future_good_profit SET profit_name_en = ?,modify_time = NOW() WHERE chart_info_id = ? `
	default:
		sql = ` UPDATE  chart_info_future_good_profit SET profit_name = ?,modify_time = NOW() WHERE chart_info_id = ? `
	}
	err = to.Exec(sql, req.ProfitName, chartInfo.ChartInfoId).Error
	if err != nil {
		fmt.Println("chart_info_future_good_profit Err:" + err.Error())
		return
	}

	return
}