学步园

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MeayunDB;

namespace Domain
{
    /// <summary>
    /// 计算上交所股票成交额
    /// </summary>
    [Command("{\"action\":\"Amount\"}", "计算上交所股票成交额")]
    public class Amount : BaseAction
    {
        public override JsonObject DoAction(JsonTree parameters)
        {
            // 构造返回结果，此action返回表，包含三列
            Table result = new Table();
            result.Append("证券代码", DataType.String);
            result.Append("证券名称", DataType.String);
            result.Append("成交额", DataType.Double);

            // 按索引名取索引，需要在config.xml配置表和索引，请参考config.xml配置文件
            Dictionary<string> securities = Indexes.Current["securities"] as Dictionary<string>;
            DictionarySortedList<string, int> quotation = Indexes.Current["quotation"] as DictionarySortedList<string, int>;

            // 查询股票代码，访问Dictionary的接口
            List<int> pointers = securities.Find();
            if (pointers.IsNull())
                return null;

            // 枚举股票代码
            foreach (int pointer in pointers)
            {
                // 取当前枚举的股票代码
                string securityCode = securities.Get<string>("F1_0002", pointer);

                // 取当前股票的所有行情记录
                List<int> list = quotation.Find(securityCode, true);
                if (list.IsNull())
                    continue;

                result.Add<string>("证券代码", securityCode);
                result.Add<string>("证券名称", securities.Get<string>("F2_0002", pointer));

                // 成交额求和
                result.Add<double>("成交额", quotation.Sum("F8_0001", list.GetEnumerator()));
            }

            // 转换为Json对象
            return result.ToJsonTree();
        }
    }
}

using System;
using System.Collections.Generic;

namespace MeayunDB
{
    public abstract class BaseIndex
    {
        public BaseIndex();
        public BaseIndex(string name, string keys);

        public int Count { get; set; }
        public string[] Keys { get; }
        public string Name { get; }

        public virtual double Avg(string field, IEnumerator<int> enumerator);
        public IEnumerator<int> Filter();
        public virtual IEnumerator<int> Filter(JsonTree parameters);
        public IEnumerator<int> Filter(string where);
        public virtual IEnumerator<int> Filter(IEnumerator<int> enumerator, string where);
        public IEnumerator<int> Filter(string on, string where);
        public virtual object Get(string name, int pointer);
        public virtual TValue Get<TValue>(string name, int pointer);
        public virtual BaseColumn GetValue(string field, IEnumerator<int> enumerator);
        public virtual Column<TValue> GetValue<TValue>(string field, IEnumerator<int> enumerator);
        public Table Query();
        public virtual Table Query(IEnumerator<int> enumerator);
        public Table Query(JsonTree parameters);
        public Table Query(string where);
        public Table Query(string[] fields);
        public virtual Table Query(IEnumerator<int> enumerator, string where);
        public virtual Table Query(IEnumerator<int> enumerator, string[] fields);
        public Table Query(string on, string where);
        public Table Query(string where, string[] fields);
        public virtual Table Query(IEnumerator<int> enumerator, string where, string[] fields);
        public Table Query(string on, string where, string[] fields);
        public virtual double Sum(string field, IEnumerator<int> enumerator);
    }
}