铁塔数据导入

service/clue.go

@@ -43,7 +43,7 @@ func ClueImportTtSync(this *biservice.ClueImportReq) (string, int) {
 	if ClueImportTtLock.TryLock() {
 		defer ClueImportTtLock.Unlock()
 		result, status, counts := "导入成功", 1, 0
-		data := JyBiTidb.Find("customer_data_temp", map[string]interface{}{"import_pc": this.Pcbh}, "", "", -1, -1)
+		data := BiService.Find("customer_data_temp", map[string]interface{}{"import_pc": this.Pcbh}, "", "", -1, -1)
 		if data != nil && len(*data) > 0 {
 			for _, v := range *data {
 				v["isCompetitors"] = "否"
@@ -77,14 +77,14 @@ func ClueImportTtSync(this *biservice.ClueImportReq) (string, int) {
 				}
 			}
 		}
-		JyBiTidb.Update("customer_data_import_record", map[string]interface{}{"import_pc": this.Pcbh}, map[string]interface{}{
+		BiService.Update("customer_data_import_record", map[string]interface{}{"import_pc": this.Pcbh}, map[string]interface{}{
 			"import_end_time": time.Now().Format(date.Date_Full_Layout),
 			"import_count":    counts,
 			"import_res":      result,
 		})
 		return result, status
 	} else {
-		JyBiTidb.Update("customer_data_import_record", map[string]interface{}{"import_pc": this.Pcbh}, map[string]interface{}{
+		BiService.Update("customer_data_import_record", map[string]interface{}{"import_pc": this.Pcbh}, map[string]interface{}{
 			"import_end_time": time.Now().Format(date.Date_Full_Layout),
 			"import_res":      "导入失败，有正在进行的导入任务",
 		})