123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570 |
- package services
- import (
- "eta/eta_api/models"
- "eta/eta_api/services/binlog"
- "eta/eta_api/services/data"
- edbmonitor "eta/eta_api/services/edb_monitor"
- "eta/eta_api/utils"
- "fmt"
- "strings"
- "time"
- )
- func Task() {
- fmt.Println("task start")
- {
-
-
-
-
-
-
- }
-
-
-
-
-
-
-
- go AutoInsertLogToDB()
-
- go ImportManualDataRefresh()
-
- go MysteelChemicalDataAdd()
-
-
- go AutoInsertAdminOperateRecordToDB()
-
- go data.HandleEdbRefreshQueue()
-
- go DealReplaceEdbCache()
-
- if utils.MYSQL_DATA_BINLOG_URL != "" {
- go binlog.ListenMysql()
- }
- go edbmonitor.HandleEdbMonitorEdbInfo()
-
- go binlog.HandleDataSourceChange2Es()
-
-
- fmt.Println("task end")
- }
- func ImportManualDataRefresh() {
- defer func() {
- if err := recover(); err != nil {
- fmt.Println("[ImportManualDataRefresh]", err)
- }
- }()
- for {
- utils.Rc.Brpop(utils.CACHE_IMPORT_MANUAL_DATA, func(b []byte) {
- edbCode := string(b)
- edbCode = strings.TrimPrefix(edbCode, `"`)
- edbCode = strings.TrimSuffix(edbCode, `"`)
- data.RefreshManualData(edbCode)
- })
- }
- }
- func MysteelChemicalDataAdd() {
- defer func() {
- if err := recover(); err != nil {
- fmt.Println("[ImportManualDataRefresh]", err)
- }
- }()
- for {
- utils.Rc.Brpop(utils.CACHE_MYSTEEL_CHEMICAL_ADD_DATA, func(b []byte) {
- edbCode := string(b)
- edbCode = strings.TrimPrefix(edbCode, `"`)
- edbCode = strings.TrimSuffix(edbCode, `"`)
- data.RefreshMysteelChemicalData(edbCode)
- })
- }
- }
- func FixEnCompanyPermission() {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("FixEnCompanyPermission Err: ", err.Error())
- }
- }()
-
- companies := make([]*models.EnglishCompany, 0)
- {
- cond := ` AND status = ?`
- pars := make([]interface{}, 0)
- pars = append(pars, 1)
- list, e := models.GetEnglishCompanyList(cond, pars, "")
- if e != nil {
- err = fmt.Errorf("GetEnglishCompanyList err: %s", e.Error())
- return
- }
- companies = list
- }
-
- permissions := make([]*models.EnPermission, 0)
- {
- cond := ` AND parent_id > ?`
- pars := make([]interface{}, 0)
- pars = append(pars, 0)
- ob := new(models.EnPermission)
- list, e := ob.GetItemsByCondition(cond, pars, []string{}, "")
- if e != nil {
- err = fmt.Errorf("GetPermissionItemsByCondition err: %s", e.Error())
- return
- }
- permissions = list
- }
- for _, c := range companies {
- ps := make([]*models.EnCompanyPermission, 0)
- for _, p := range permissions {
- ps = append(ps, &models.EnCompanyPermission{
- EnCompanyId: c.CompanyId,
- EnPermissionId: p.EnPermissionId,
- CreateTime: time.Now().Local(),
- })
- }
- if e := models.ClearAndCreateEnCompanyPermissions(c.CompanyId, ps); e != nil {
- err = fmt.Errorf("ClearAndCreateEnCompanyPermissions err: %s", e.Error())
- return
- }
- }
- fmt.Println("修复完成")
- }
- func ModifyEsEnglishReport() {
- fmt.Println("开始")
- err := ModifyAllEsEnglishReportVideo()
- if err != nil {
- err = fmt.Errorf("重置es中的英文研报信息失败:ModifyAllEnglishReportInEs err: %s", err.Error())
- return
- }
- fmt.Println("结束")
- }
|