|
@@ -0,0 +1,1043 @@
|
|
|
+package task
|
|
|
+
|
|
|
+import (
|
|
|
+ "fmt"
|
|
|
+ "github.com/tealeg/xlsx"
|
|
|
+ "eta/eta_menu_sync/models"
|
|
|
+ "eta/eta_menu_sync/utils"
|
|
|
+ "strings"
|
|
|
+ "time"
|
|
|
+)
|
|
|
+
|
|
|
+// AddMsgPushRecord 定时生成待发送记录
|
|
|
+func AddMsgPushRecord() {
|
|
|
+ //fmt.Println("start task")
|
|
|
+ errMsgList := make([]string, 0)
|
|
|
+ defer func() {
|
|
|
+ if len(errMsgList) > 0 {
|
|
|
+ fmt.Println("定时发送消息失败:")
|
|
|
+ for _, errMsg := range errMsgList {
|
|
|
+ fmt.Println(errMsg)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ wechatGroupTagObj := models.WechatGroupTag{}
|
|
|
+ wechatGroupObj := models.WechatGroup{}
|
|
|
+ wechatMsgPushRecordObj := models.WechatMsgPushRecord{}
|
|
|
+
|
|
|
+ reportSendThsDetailObj := models.ReportSendThsDetail{}
|
|
|
+ list, err := reportSendThsDetailObj.GetNoRecordList()
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("获取同花顺数据失败,err:", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ wechatListenMsgRecordObj := models.WechatListenMsgRecord{}
|
|
|
+ //fmt.Println("开始处理了")
|
|
|
+ for _, thsRecord := range list {
|
|
|
+ if thsRecord.MsgType == 2 {
|
|
|
+ // 如果类型是:小程序
|
|
|
+ _, tmpErr := wechatListenMsgRecordObj.GetByJumpPath(models.ListenWxAppType, thsRecord.JumpUrl)
|
|
|
+ if tmpErr != nil {
|
|
|
+ if tmpErr != utils.ErrNoRow {
|
|
|
+ fmt.Println("查询小程序推送首发群记录失败,err:", err.Error())
|
|
|
+ }
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ }
|
|
|
+ thsRecord.RecordStatus = 1
|
|
|
+ err = thsRecord.Update([]string{"RecordStatus"})
|
|
|
+
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("更改同花顺记录失败:", err.Error())
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ labelList := make([]string, 0)
|
|
|
+ if thsRecord.LabelStr != `` {
|
|
|
+ labelList = strings.Split(thsRecord.LabelStr, ",")
|
|
|
+ }
|
|
|
+ if len(labelList) <= 0 {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ wechatGroupTagList, tmpErr := wechatGroupTagObj.GetListByTagNameList(labelList)
|
|
|
+ if tmpErr != nil {
|
|
|
+ fmt.Println("寻找客户标签失败:", tmpErr.Error())
|
|
|
+ continue
|
|
|
+ }
|
|
|
+
|
|
|
+ wechatGroupIdList := make([]int, 0)
|
|
|
+ for _, wechatGroupTag := range wechatGroupTagList {
|
|
|
+ wechatGroupIdList = append(wechatGroupIdList, wechatGroupTag.WechatGroupId)
|
|
|
+ }
|
|
|
+ if len(wechatGroupIdList) <= 0 {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+
|
|
|
+ wechatGroupList, tmpErr := wechatGroupObj.GetEnabledListByIdList(wechatGroupIdList)
|
|
|
+ if tmpErr != nil {
|
|
|
+ fmt.Println("寻找客户失败:", tmpErr.Error())
|
|
|
+ continue
|
|
|
+ }
|
|
|
+
|
|
|
+ wechatGroupMap := make(map[int]*models.WechatGroup)
|
|
|
+ for _, wechatGroup := range wechatGroupList {
|
|
|
+ wechatGroupMap[wechatGroup.WechatGroupId] = wechatGroup
|
|
|
+ }
|
|
|
+
|
|
|
+ addList := make([]models.WechatMsgPushRecord, 0)
|
|
|
+ for _, wechatGroupTag := range wechatGroupTagList {
|
|
|
+ wechatGroup, ok := wechatGroupMap[wechatGroupTag.WechatGroupId]
|
|
|
+ if !ok {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ addList = append(addList, models.WechatMsgPushRecord{
|
|
|
+ //WechatMsgId: 0,
|
|
|
+ MsgType: thsRecord.MsgType,
|
|
|
+ WechatGroupId: wechatGroupTag.WechatGroupId,
|
|
|
+ WechatHelperId: 0,
|
|
|
+ WechatGroupWechatId: wechatGroup.WechatId,
|
|
|
+ Title: thsRecord.Title,
|
|
|
+ Content: thsRecord.Content,
|
|
|
+ Pic: thsRecord.Pic,
|
|
|
+ JumpUrl: thsRecord.JumpUrl,
|
|
|
+ Status: 0,
|
|
|
+ Remark: "",
|
|
|
+ ServerResult: "",
|
|
|
+ ModifyTime: time.Now(),
|
|
|
+ CreateTime: time.Now(),
|
|
|
+ SendId: thsRecord.SendId,
|
|
|
+ Level: thsRecord.Level,
|
|
|
+ })
|
|
|
+
|
|
|
+ }
|
|
|
+ if len(addList) > 0 {
|
|
|
+ err = wechatMsgPushRecordObj.CreateList(addList)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("添加入库失败")
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+// StopMsgPushRecord 超时未发送的消息需要停止
|
|
|
+func StopMsgPushRecord() {
|
|
|
+ wechatMsgPushRecordObj := models.WechatMsgPushRecord{}
|
|
|
+
|
|
|
+ day := 2
|
|
|
+ err := wechatMsgPushRecordObj.StopTimeOutRecord(day)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("获取同花顺数据失败,err:", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func A() {
|
|
|
+ path := `C:\Users\123\Desktop\标签.xlsx`
|
|
|
+ xlFile, err := xlsx.OpenFile(path)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ type tmp struct {
|
|
|
+ Name string
|
|
|
+ WxId string
|
|
|
+ Label string
|
|
|
+ Helper []string
|
|
|
+ }
|
|
|
+ wxGroup := make(map[string]tmp)
|
|
|
+ helperMap := make(map[string]string)
|
|
|
+ // 遍历sheet页读取
|
|
|
+ for _, sheet := range xlFile.Sheets {
|
|
|
+ fmt.Println("sheet name: ", sheet.Name)
|
|
|
+ //遍历行读取
|
|
|
+ maxRow := sheet.MaxRow
|
|
|
+ fmt.Println("maxRow:", maxRow)
|
|
|
+ fmt.Println("maxRow")
|
|
|
+ for i := 0; i < maxRow; i++ {
|
|
|
+
|
|
|
+ if i == 0 {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ row := sheet.Row(i)
|
|
|
+ //fmt.Println(row)
|
|
|
+ cells := row.Cells
|
|
|
+
|
|
|
+ name := cells[1].Value
|
|
|
+ wxId := cells[2].Value
|
|
|
+ label := cells[3].Value
|
|
|
+ helper := cells[4].Value
|
|
|
+
|
|
|
+ if _, ok := helperMap[helper]; !ok {
|
|
|
+ helperMap[helper] = helper
|
|
|
+ }
|
|
|
+
|
|
|
+ if wxId == `` {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ tmpData, ok := wxGroup[wxId]
|
|
|
+ var tmpHelper []string
|
|
|
+ if !ok {
|
|
|
+ tmpHelper = make([]string, 0)
|
|
|
+ tmpData = tmp{
|
|
|
+ Name: name,
|
|
|
+ WxId: wxId,
|
|
|
+ Label: label,
|
|
|
+ Helper: tmpHelper,
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ tmpHelper = tmpData.Helper
|
|
|
+ }
|
|
|
+ tmpHelper = append(tmpHelper, helper)
|
|
|
+ tmpData.Helper = tmpHelper
|
|
|
+ wxGroup[wxId] = tmpData
|
|
|
+ //fmt.Println(name)
|
|
|
+ //fmt.Println(wxId)
|
|
|
+ //fmt.Println(label)
|
|
|
+ //fmt.Println(helper)
|
|
|
+ //return
|
|
|
+
|
|
|
+ //if i == 1 {
|
|
|
+ // row := sheet.Row(i)
|
|
|
+ // cells := row.Cells
|
|
|
+ //
|
|
|
+ // templateFail := false
|
|
|
+ // if cells[0].Value != "品种分类" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[1].Value != "录入日期" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[2].Value != "指标名称" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[3].Value != "值" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[4].Value != "频度" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[5].Value != "单位" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if templateFail {
|
|
|
+ // br.ErrMsg = "导入文件异常,请下载最新导入模板文件"
|
|
|
+ // br.Msg = "导入文件异常,请下载最新导入模板文件"
|
|
|
+ // return
|
|
|
+ // }
|
|
|
+ //}
|
|
|
+ //
|
|
|
+ //if i > 1 {
|
|
|
+ // row := sheet.Row(i)
|
|
|
+ // cells := row.Cells
|
|
|
+ // if len(cells) >= 6 {
|
|
|
+ // classifyName := cells[0].Value //分类
|
|
|
+ // if classifyName == "" { //过滤空白行
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // cell1 := cells[1].Value
|
|
|
+ // //createDate := utils.ConvertToFormatDay(cell1) //录入日期
|
|
|
+ // createDate := cell1
|
|
|
+ // cell2 := cells[2].Value //指标名称
|
|
|
+ // secName := strings.Trim(cell2, " ")
|
|
|
+ // frequency := cells[4].Value //频度
|
|
|
+ // unit := cells[5].Value //单位
|
|
|
+ //
|
|
|
+ // closeVal := cells[3].Value //值
|
|
|
+ // if strings.Contains(closeVal, "#N/A") {
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // closeValFloat, err := cells[3].Float() //值
|
|
|
+ //
|
|
|
+ // if err != nil {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = cells[3].Value
|
|
|
+ // failItem.Remark = "值类型异常"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // newDecimal := decimal.NewFromFloat(closeValFloat)
|
|
|
+ // newDecimal.Round(4)
|
|
|
+ // closeVal = newDecimal.String()
|
|
|
+ // if strings.Contains(closeVal, "#N/A") {
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // //closeVal := closeValFloat.
|
|
|
+ //
|
|
|
+ // //判断指标,类型,等数据是否正常
|
|
|
+ // classifyName = strings.Trim(classifyName, " ")
|
|
|
+ // frequency = utils.TrimStr(frequency)
|
|
|
+ // unit = utils.TrimStr(unit)
|
|
|
+ //
|
|
|
+ // // 成功数量超过20个指标,那就不导入了
|
|
|
+ // if len(targetMap) >= 150 {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "导入指标数量过多"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // if !strings.Contains(strings.Join(classifyNameStrList, ","), classifyName) {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "没有该品种分类权限"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // //fmt.Println(classifyName, createDate, secName, closeVal)
|
|
|
+ //
|
|
|
+ // //校验表格中的日期格式
|
|
|
+ // if strings.Contains(createDate, "-") {
|
|
|
+ // //如果是带有 - 的普通日期格式文本
|
|
|
+ // _, timeErr := time.Parse("2006-1-2", createDate)
|
|
|
+ // if timeErr != nil {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "日期格式异常"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // } else if strings.Contains(createDate, "/") {
|
|
|
+ // //如果是带有 / 的普通日期格式文本
|
|
|
+ // createDateTime, timeErr := time.Parse("2006/1/2", createDate)
|
|
|
+ // if timeErr != nil {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "日期格式异常"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // createDate = createDateTime.Format("2006-01-02")
|
|
|
+ // } else {
|
|
|
+ // //可能是excel的日期格式
|
|
|
+ // _, tmpErr := strconv.Atoi(createDate)
|
|
|
+ // if tmpErr != nil {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "日期格式异常"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // createDate = utils.ConvertToFormatDay(createDate) //录入日期
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //获取指标分类信息
|
|
|
+ // classify, ok := edbDataClassifyMap[classifyName]
|
|
|
+ // if !ok {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "指标分类不存在"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //判断指标是否存在
|
|
|
+ // target, ok := targetMap[secName]
|
|
|
+ // if !ok {
|
|
|
+ // tmpTarget, err := models.GetTargetBySecName(secName)
|
|
|
+ // if err != nil {
|
|
|
+ // //如果是找不到该指标,那么新增指标
|
|
|
+ // if err.Error() == utils.ErrNoRow() {
|
|
|
+ // if frequency == "" {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "新增指标失败,频度字段为空"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // if unit == "" {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "新增指标失败,单位字段为空"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // tmpErr := data.AddEdbInfo(secName, unit, frequency, "", sysUser.Mobile, classify.ClassifyId, sysUser.AdminId)
|
|
|
+ // if tmpErr != nil {
|
|
|
+ // fmt.Println("line 158")
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "新增指标失败"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // tmpTarget, tmpErr := models.GetTargetBySecName(secName)
|
|
|
+ // target = tmpTarget
|
|
|
+ // targetMap[secName] = target
|
|
|
+ // } else {
|
|
|
+ // fmt.Println("导入数据 获取指标:Err:" + err.Error())
|
|
|
+ // }
|
|
|
+ // } else {
|
|
|
+ // target = tmpTarget
|
|
|
+ // targetMap[secName] = target
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //设置10分钟缓存,不允许其他地方删除
|
|
|
+ // key := "import:edbinfo:data:" + target.TradeCode
|
|
|
+ // utils.Rc.SetNX(key, 1, time.Second*600)
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // if target == nil {
|
|
|
+ // fmt.Println("指标不存在")
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "指标不存在"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //更新指标信息
|
|
|
+ // updateCols := make([]string, 0)
|
|
|
+ // //更新指标分类
|
|
|
+ // if target.ClassifyId <= 0 && classify.ClassifyId > 0 {
|
|
|
+ // target.ClassifyId = classify.ClassifyId
|
|
|
+ // updateCols = append(updateCols, "ClassifyId")
|
|
|
+ // }
|
|
|
+ // if target.Frequency != frequency {
|
|
|
+ // target.Frequency = frequency
|
|
|
+ // target.NoticeTime = ""
|
|
|
+ // updateCols = append(updateCols, "Frequency", "NoticeTime")
|
|
|
+ // }
|
|
|
+ // if target.Unit != unit {
|
|
|
+ // target.Unit = unit
|
|
|
+ // updateCols = append(updateCols, "Unit")
|
|
|
+ // }
|
|
|
+ // if len(updateCols) > 0 {
|
|
|
+ // _ = target.Update(updateCols)
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //判断数据是否已经存在
|
|
|
+ // count, err := models.GetTargetsDataCount(target.TradeCode, createDate)
|
|
|
+ // if err != nil {
|
|
|
+ // go alarm_msg.SendAlarmMsg("导入数据 判断数据是否存在失败,Err:"+err.Error(), 3)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 判断数据是否存在失败:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // }
|
|
|
+ // //数据已存在,进行更新操作
|
|
|
+ // if count > 0 {
|
|
|
+ // edbData, err := models.GetTargetsData(target.TradeCode, createDate)
|
|
|
+ // if err != nil {
|
|
|
+ // go alarm_msg.SendAlarmMsg("导入数据 获取指标数据失败,Err:"+err.Error(), 3)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取指标数据失败:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // }
|
|
|
+ // if edbData != nil {
|
|
|
+ // err = models.ModifyTargetsDataByImport(target.TradeCode, createDate, closeVal)
|
|
|
+ // if err != nil {
|
|
|
+ // go alarm_msg.SendAlarmMsg("导入数据 修改数据失败,Err:"+err.Error(), 3)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 修改数据失败:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // } else { //数据不存在,进行新增操作
|
|
|
+ // if target.TradeCode != "" && createDate != "" && closeVal != "" {
|
|
|
+ // models.AddTargetsDataByImport(target.TradeCode, createDate, closeVal)
|
|
|
+ // if err != nil {
|
|
|
+ // go alarm_msg.SendAlarmMsg("导入数据 新增数据失败,Err:"+err.Error(), 3)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 新增数据失败:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // successCount++
|
|
|
+ // } else {
|
|
|
+ // //br.ErrMsg = "请填写导入内容"
|
|
|
+ // //br.Msg = "请填写导入内容"
|
|
|
+ // //return
|
|
|
+ // }
|
|
|
+ //}
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //wechatGroupList := make([]models.WechatGroup,0)
|
|
|
+ wechatGroupObj := models.WechatGroup{}
|
|
|
+ wxIdList := make([]string, 0)
|
|
|
+ wxIdMap := make(map[string]string)
|
|
|
+ for _, v := range wxGroup {
|
|
|
+ if _, ok := wxIdMap[v.WxId]; !ok {
|
|
|
+ wxIdList = append(wxIdList, v.WxId)
|
|
|
+ wxIdMap[v.WxId] = ``
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(wxIdList) <= 0 {
|
|
|
+ fmt.Println("没有群")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ groupList, err := wechatGroupObj.GetListByWxIdList(wxIdList)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("查找群列表失败,err:", err)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ groupMap := make(map[string]*models.WechatGroup)
|
|
|
+ for _, v := range groupList {
|
|
|
+ groupMap[v.WechatId] = v
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range wxGroup {
|
|
|
+ item, ok := groupMap[v.WxId]
|
|
|
+ if !ok {
|
|
|
+ fmt.Println("找不到该群:", v.Name)
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ if len(v.Helper) > 0 {
|
|
|
+ for _, helper := range v.Helper {
|
|
|
+ if helper != `弘则FICC小助手17号` {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ if helperId, ok := helperIdMap[helper]; ok {
|
|
|
+ tmpWechatGroupHelperRelation := &models.WechatGroupHelperRelation{
|
|
|
+ WechatGroupId: item.WechatGroupId,
|
|
|
+ WechatHelperId: helperId,
|
|
|
+ }
|
|
|
+
|
|
|
+ fmt.Println(tmpWechatGroupHelperRelation)
|
|
|
+ err = tmpWechatGroupHelperRelation.Create()
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(v.WxId, ";", v.Name, ";助手:", helper, "添加关系失败,ERR:", err)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ fmt.Println(wxGroup)
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+func B() {
|
|
|
+ path := `C:\Users\123\Desktop\标签.xlsx`
|
|
|
+ xlFile, err := xlsx.OpenFile(path)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ type tmp struct {
|
|
|
+ Name string
|
|
|
+ WxId string
|
|
|
+ Label string
|
|
|
+ Helper []string
|
|
|
+ }
|
|
|
+ wxGroup := make(map[string]tmp)
|
|
|
+ helperMap := make(map[string]string)
|
|
|
+ // 遍历sheet页读取
|
|
|
+ for _, sheet := range xlFile.Sheets {
|
|
|
+ fmt.Println("sheet name: ", sheet.Name)
|
|
|
+ //遍历行读取
|
|
|
+ maxRow := sheet.MaxRow
|
|
|
+ fmt.Println("maxRow:", maxRow)
|
|
|
+ fmt.Println("maxRow")
|
|
|
+ for i := 0; i < maxRow; i++ {
|
|
|
+
|
|
|
+ if i == 0 {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ row := sheet.Row(i)
|
|
|
+ //fmt.Println(row)
|
|
|
+ cells := row.Cells
|
|
|
+
|
|
|
+ name := cells[1].Value
|
|
|
+ wxId := cells[2].Value
|
|
|
+ label := cells[3].Value
|
|
|
+ helper := cells[4].Value
|
|
|
+
|
|
|
+ if _, ok := helperMap[helper]; !ok {
|
|
|
+ helperMap[helper] = helper
|
|
|
+ }
|
|
|
+
|
|
|
+ if wxId == `` {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ tmpData, ok := wxGroup[wxId]
|
|
|
+ var tmpHelper []string
|
|
|
+ if !ok {
|
|
|
+ tmpHelper = make([]string, 0)
|
|
|
+ tmpData = tmp{
|
|
|
+ Name: name,
|
|
|
+ WxId: wxId,
|
|
|
+ Label: label,
|
|
|
+ Helper: tmpHelper,
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ tmpHelper = tmpData.Helper
|
|
|
+ }
|
|
|
+ tmpHelper = append(tmpHelper, helper)
|
|
|
+ tmpData.Helper = tmpHelper
|
|
|
+ wxGroup[wxId] = tmpData
|
|
|
+ //fmt.Println(name)
|
|
|
+ //fmt.Println(wxId)
|
|
|
+ //fmt.Println(label)
|
|
|
+ //fmt.Println(helper)
|
|
|
+ //return
|
|
|
+
|
|
|
+ //if i == 1 {
|
|
|
+ // row := sheet.Row(i)
|
|
|
+ // cells := row.Cells
|
|
|
+ //
|
|
|
+ // templateFail := false
|
|
|
+ // if cells[0].Value != "品种分类" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[1].Value != "录入日期" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[2].Value != "指标名称" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[3].Value != "值" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[4].Value != "频度" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if cells[5].Value != "单位" {
|
|
|
+ // templateFail = true
|
|
|
+ // }
|
|
|
+ // if templateFail {
|
|
|
+ // br.ErrMsg = "导入文件异常,请下载最新导入模板文件"
|
|
|
+ // br.Msg = "导入文件异常,请下载最新导入模板文件"
|
|
|
+ // return
|
|
|
+ // }
|
|
|
+ //}
|
|
|
+ //
|
|
|
+ //if i > 1 {
|
|
|
+ // row := sheet.Row(i)
|
|
|
+ // cells := row.Cells
|
|
|
+ // if len(cells) >= 6 {
|
|
|
+ // classifyName := cells[0].Value //分类
|
|
|
+ // if classifyName == "" { //过滤空白行
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // cell1 := cells[1].Value
|
|
|
+ // //createDate := utils.ConvertToFormatDay(cell1) //录入日期
|
|
|
+ // createDate := cell1
|
|
|
+ // cell2 := cells[2].Value //指标名称
|
|
|
+ // secName := strings.Trim(cell2, " ")
|
|
|
+ // frequency := cells[4].Value //频度
|
|
|
+ // unit := cells[5].Value //单位
|
|
|
+ //
|
|
|
+ // closeVal := cells[3].Value //值
|
|
|
+ // if strings.Contains(closeVal, "#N/A") {
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // closeValFloat, err := cells[3].Float() //值
|
|
|
+ //
|
|
|
+ // if err != nil {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = cells[3].Value
|
|
|
+ // failItem.Remark = "值类型异常"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // newDecimal := decimal.NewFromFloat(closeValFloat)
|
|
|
+ // newDecimal.Round(4)
|
|
|
+ // closeVal = newDecimal.String()
|
|
|
+ // if strings.Contains(closeVal, "#N/A") {
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // //closeVal := closeValFloat.
|
|
|
+ //
|
|
|
+ // //判断指标,类型,等数据是否正常
|
|
|
+ // classifyName = strings.Trim(classifyName, " ")
|
|
|
+ // frequency = utils.TrimStr(frequency)
|
|
|
+ // unit = utils.TrimStr(unit)
|
|
|
+ //
|
|
|
+ // // 成功数量超过20个指标,那就不导入了
|
|
|
+ // if len(targetMap) >= 150 {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "导入指标数量过多"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // if !strings.Contains(strings.Join(classifyNameStrList, ","), classifyName) {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "没有该品种分类权限"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // //fmt.Println(classifyName, createDate, secName, closeVal)
|
|
|
+ //
|
|
|
+ // //校验表格中的日期格式
|
|
|
+ // if strings.Contains(createDate, "-") {
|
|
|
+ // //如果是带有 - 的普通日期格式文本
|
|
|
+ // _, timeErr := time.Parse("2006-1-2", createDate)
|
|
|
+ // if timeErr != nil {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "日期格式异常"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // } else if strings.Contains(createDate, "/") {
|
|
|
+ // //如果是带有 / 的普通日期格式文本
|
|
|
+ // createDateTime, timeErr := time.Parse("2006/1/2", createDate)
|
|
|
+ // if timeErr != nil {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "日期格式异常"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // createDate = createDateTime.Format("2006-01-02")
|
|
|
+ // } else {
|
|
|
+ // //可能是excel的日期格式
|
|
|
+ // _, tmpErr := strconv.Atoi(createDate)
|
|
|
+ // if tmpErr != nil {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "日期格式异常"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // createDate = utils.ConvertToFormatDay(createDate) //录入日期
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //获取指标分类信息
|
|
|
+ // classify, ok := edbDataClassifyMap[classifyName]
|
|
|
+ // if !ok {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "指标分类不存在"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取分类:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //判断指标是否存在
|
|
|
+ // target, ok := targetMap[secName]
|
|
|
+ // if !ok {
|
|
|
+ // tmpTarget, err := models.GetTargetBySecName(secName)
|
|
|
+ // if err != nil {
|
|
|
+ // //如果是找不到该指标,那么新增指标
|
|
|
+ // if err.Error() == utils.ErrNoRow() {
|
|
|
+ // if frequency == "" {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "新增指标失败,频度字段为空"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // if unit == "" {
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "新增指标失败,单位字段为空"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // tmpErr := data.AddEdbInfo(secName, unit, frequency, "", sysUser.Mobile, classify.ClassifyId, sysUser.AdminId)
|
|
|
+ // if tmpErr != nil {
|
|
|
+ // fmt.Println("line 158")
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "新增指标失败"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // tmpTarget, tmpErr := models.GetTargetBySecName(secName)
|
|
|
+ // target = tmpTarget
|
|
|
+ // targetMap[secName] = target
|
|
|
+ // } else {
|
|
|
+ // fmt.Println("导入数据 获取指标:Err:" + err.Error())
|
|
|
+ // }
|
|
|
+ // } else {
|
|
|
+ // target = tmpTarget
|
|
|
+ // targetMap[secName] = target
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //设置10分钟缓存,不允许其他地方删除
|
|
|
+ // key := "import:edbinfo:data:" + target.TradeCode
|
|
|
+ // utils.Rc.SetNX(key, 1, time.Second*600)
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // if target == nil {
|
|
|
+ // fmt.Println("指标不存在")
|
|
|
+ // failItem := new(models.EdbdataImportFail)
|
|
|
+ // failItem.SysUserId = strconv.Itoa(sysUser.AdminId)
|
|
|
+ // failItem.ClassifyName = classifyName
|
|
|
+ // failItem.CreateDate = createDate
|
|
|
+ // failItem.SecName = secName
|
|
|
+ // failItem.Close = closeVal
|
|
|
+ // failItem.Remark = "指标不存在"
|
|
|
+ // failItem.Frequency = frequency
|
|
|
+ // failItem.Unit = unit
|
|
|
+ // failDatas = append(failDatas, failItem)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //更新指标信息
|
|
|
+ // updateCols := make([]string, 0)
|
|
|
+ // //更新指标分类
|
|
|
+ // if target.ClassifyId <= 0 && classify.ClassifyId > 0 {
|
|
|
+ // target.ClassifyId = classify.ClassifyId
|
|
|
+ // updateCols = append(updateCols, "ClassifyId")
|
|
|
+ // }
|
|
|
+ // if target.Frequency != frequency {
|
|
|
+ // target.Frequency = frequency
|
|
|
+ // target.NoticeTime = ""
|
|
|
+ // updateCols = append(updateCols, "Frequency", "NoticeTime")
|
|
|
+ // }
|
|
|
+ // if target.Unit != unit {
|
|
|
+ // target.Unit = unit
|
|
|
+ // updateCols = append(updateCols, "Unit")
|
|
|
+ // }
|
|
|
+ // if len(updateCols) > 0 {
|
|
|
+ // _ = target.Update(updateCols)
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //判断数据是否已经存在
|
|
|
+ // count, err := models.GetTargetsDataCount(target.TradeCode, createDate)
|
|
|
+ // if err != nil {
|
|
|
+ // go alarm_msg.SendAlarmMsg("导入数据 判断数据是否存在失败,Err:"+err.Error(), 3)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 判断数据是否存在失败:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // }
|
|
|
+ // //数据已存在,进行更新操作
|
|
|
+ // if count > 0 {
|
|
|
+ // edbData, err := models.GetTargetsData(target.TradeCode, createDate)
|
|
|
+ // if err != nil {
|
|
|
+ // go alarm_msg.SendAlarmMsg("导入数据 获取指标数据失败,Err:"+err.Error(), 3)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 获取指标数据失败:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // }
|
|
|
+ // if edbData != nil {
|
|
|
+ // err = models.ModifyTargetsDataByImport(target.TradeCode, createDate, closeVal)
|
|
|
+ // if err != nil {
|
|
|
+ // go alarm_msg.SendAlarmMsg("导入数据 修改数据失败,Err:"+err.Error(), 3)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 修改数据失败:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // } else { //数据不存在,进行新增操作
|
|
|
+ // if target.TradeCode != "" && createDate != "" && closeVal != "" {
|
|
|
+ // models.AddTargetsDataByImport(target.TradeCode, createDate, closeVal)
|
|
|
+ // if err != nil {
|
|
|
+ // go alarm_msg.SendAlarmMsg("导入数据 新增数据失败,Err:"+err.Error(), 3)
|
|
|
+ // //go utils.SendEmail(utils.APPNAME+"失败提醒", "导入数据 新增数据失败:Err:"+err.Error(), utils.EmailSendToUsers)
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // successCount++
|
|
|
+ // } else {
|
|
|
+ // //br.ErrMsg = "请填写导入内容"
|
|
|
+ // //br.Msg = "请填写导入内容"
|
|
|
+ // //return
|
|
|
+ // }
|
|
|
+ //}
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //wechatGroupList := make([]models.WechatGroup,0)
|
|
|
+ //wechatGroupObj := models.WechatGroup{}
|
|
|
+ //for _, v := range wxGroup {
|
|
|
+ // item, tmpErr := wechatGroupObj.GetByWxId(v.WxId)
|
|
|
+ // if tmpErr != nil {
|
|
|
+ // fmt.Println(v.WxId, ";", v.Name, "查找失败,ERR:", err)
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // if len(v.Helper) > 0 {
|
|
|
+ // for _, helper := range v.Helper {
|
|
|
+ // if helper != `弘则FICC小助手17号` {
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ // if helperId, ok := helperIdMap[helper]; ok {
|
|
|
+ // tmpWechatGroupHelperRelation := &models.WechatGroupHelperRelation{
|
|
|
+ // WechatGroupId: item.WechatGroupId,
|
|
|
+ // WechatHelperId: helperId,
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // fmt.Println(tmpWechatGroupHelperRelation)
|
|
|
+ // //err = tmpWechatGroupHelperRelation.Create()
|
|
|
+ // //if err != nil {
|
|
|
+ // // fmt.Println(v.WxId, ";", v.Name, ";助手:", helper, "添加关系失败,ERR:", err)
|
|
|
+ // //}
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ //
|
|
|
+ // //tmpWechatGroup := &models.WechatGroup{
|
|
|
+ // // WechatGroupId: 0,
|
|
|
+ // // WechatGroupName: v.Name,
|
|
|
+ // // WechatId: v.WxId,
|
|
|
+ // // ModifyTime: time.Now(),
|
|
|
+ // // CreateTime: time.Now(),
|
|
|
+ // //}
|
|
|
+ // //
|
|
|
+ // //err = tmpWechatGroup.Create()
|
|
|
+ // //if err != nil {
|
|
|
+ // // global.LOG.Info("添加监听消息失败")
|
|
|
+ // //}
|
|
|
+ // //
|
|
|
+ // //if v.Label == `` {
|
|
|
+ // // continue
|
|
|
+ // //}
|
|
|
+ // //labelList := strings.Split(v.Label, ",")
|
|
|
+ // //
|
|
|
+ // //for _, label := range labelList {
|
|
|
+ // // tmpTag := models.WechatGroupTag{
|
|
|
+ // // WechatGroupId: tmpWechatGroup.WechatGroupId,
|
|
|
+ // // TagName: label,
|
|
|
+ // // ModifyTime: time.Now(),
|
|
|
+ // // CreateTime: time.Now(),
|
|
|
+ // // }
|
|
|
+ // // tmpTag.Create()
|
|
|
+ // //}
|
|
|
+ //}
|
|
|
+ fmt.Println(wxGroup)
|
|
|
+
|
|
|
+ fmt.Println("a")
|
|
|
+}
|
|
|
+
|
|
|
+var helperIdMap = map[string]int{
|
|
|
+ "弘则FICC小助手16号": 9,
|
|
|
+ "弘则FICC小助手18号": 11,
|
|
|
+ "弘则FICC小助手1号": 2,
|
|
|
+ //"弘则FICC小助手6号": 9,
|
|
|
+ //"弘则FICC小助手14号": 9,
|
|
|
+ "弘则FICC小助手5号": 8,
|
|
|
+ //"弘则FICC小助手9号": 2,
|
|
|
+ "弘则FICC小助手7号": 5,
|
|
|
+ "弘则FICC小助手3号": 7,
|
|
|
+ "弘则FICC小助手15号": 6,
|
|
|
+ "弘则FICC小助手2号": 3,
|
|
|
+ "弘则FICC小助手8号": 1,
|
|
|
+ "弘则FICC小助手17号": 12,
|
|
|
+ "弘则FICC小助手4号": 10,
|
|
|
+}
|