浏览代码

铁塔数据导入

xuzhiheng 1 年之前
父节点
当前提交
a0ac65549a
共有 1 个文件被更改,包括 12 次插入0 次删除
  1. 12 0
      service/clue.go

+ 12 - 0
service/clue.go

@@ -66,6 +66,18 @@ func ClueImportTtSync(this *biservice.ClueImportReq) (string, int) {
 					BiService.Insert("customer_data_ttzl_gl", map[string]interface{}{"msg_id": dataId, "info_id": id, "details": details, "isHistory": "否"})
 					delete(v, "isCompetitors")
 					v["details"] = cleanHTML(details)
+					publishtime, _ := time.ParseInLocation(date.Date_Full_Layout, common.ObjToString(v["publishtime"]), time.Local)
+					docstarttime, _ := time.ParseInLocation(date.Date_Full_Layout, common.ObjToString(v["docstarttime"]), time.Local)
+					docendtime, _ := time.ParseInLocation(date.Date_Full_Layout, common.ObjToString(v["docendtime"]), time.Local)
+					bidstarttime, _ := time.ParseInLocation(date.Date_Full_Layout, common.ObjToString(v["bidstarttime"]), time.Local)
+					bidendtime, _ := time.ParseInLocation(date.Date_Full_Layout, common.ObjToString(v["bidendtime"]), time.Local)
+					bidopentime, _ := time.ParseInLocation(date.Date_Full_Layout, common.ObjToString(v["bidopentime"]), time.Local)
+					v["publishtime"] = publishtime.Unix()
+					v["docstarttime"] = docstarttime.Unix()
+					v["docendtime"] = docendtime.Unix()
+					v["bidstarttime"] = bidstarttime.Unix()
+					v["bidendtime"] = bidendtime.Unix()
+					v["bidopentime"] = bidopentime.Unix()
 					ok := Es.Save("ttbid", "ttbid", v)
 					if ok {
 						counts++