数据库名切换

service/custom.go

@@ -340,15 +340,15 @@ func SaveConnection(tx *sql.Tx, positionId int64, businessId, ownerId string, en
 		if cm.CrmMysql.Count(table, map[string]interface{}{
 			"position_id": positionId,
 			"relate_id":   sourceType,
-			"type":        sourceType,
+			"itype":       sourceType,
 		}) > 0 {
 			cm.CrmMysql.UpdateByTx(tx, table, map[string]interface{}{
 				"position_id": positionId,
 				"relate_id":   businessId,
+				"itype":       sourceType,
 			}, map[string]interface{}{
 				"is_handle":   1,
 				"relate_id":   businessId,
-				"type":        sourceType,
 				"update_time": time.Now().Format(date.Date_Full_Layout),
 				"is create":   1,
 			})
@@ -362,6 +362,7 @@ func SaveConnection(tx *sql.Tx, positionId int64, businessId, ownerId string, en
 				"relate_id":   businessId,
 				"is_handle":   1,
 				"is create":   1,
+				"itype":       sourceType,
 				"create_time": time.Now().Format(date.Date_Full_Layout),
 			})
 			return id > 0