一个在C#中集成Python的例子。在C#中可以执行Python脚本，在Python中也可以调用C#宿主中的功能（clr.AddReference('Business')）。
文件说明
Debug为执行目录
Mgr.exe为执行文件
Py\init.py为python初始化脚本
Py\Lib.zip为python需要的模块，可以在init.py中import
Data为数据库目录
mgr.db为mgr.exe使用的数据库
操作说明
系统设置
可以在这里修改运行的参数
打开一个账户
用户的规则设置
交易
代码说明
Python的说明
在Python中可以调用C#宿主中的功能（clr.AddReference('Business')）。
import clr
import io
import os
import string
clr.AddReference('System')
clr.AddReference('System.Data')
clr.AddReference('Business')
from System import *
from System.Data import *
from Business import *
def get_account_money_by_dt(account_id,date):
db=Pub.db_name_mgr
InitMoney=Pub.select_str(db,"select InitMoney from account where account_id="+account_id)
cash=Pub.select_str(db,"select sum(amount_real) from tran where account_id="+account_id+" and tran_date<="+date)
stock_amount=float.Parse("0")
table_stock=Pub.select(db,"select code_type,code,sum(tran_count_real) as c from tran where account_id="+account_id+" and code<>'' and tran_date<="+date +" group by code_type,code")
for dr in table_stock.Rows:
code_type=DBUtils.get_str(dr, "code_type");
code=DBUtils.get_str(dr, "code");
count=DBUtils.get_str(dr, "c");
price=Pub.select_str(code_type+"\\"+code,"select close from data_day where dt<="+date+" order by dt desc limit 1")
if price<>'':
stock_amount=stock_amount+float.Parse(price)*float.Parse(count)
if cash=="":
cash="0"
if InitMoney=="":
InitMoney="0"
return (float.Parse(InitMoney)+float.Parse(cash)+stock_amount).ToString("0.00")C#的说明
加载Python环境
instance = new Py();
instance.init_py_lib();
public void init_py_lib()
{
engine = IronPython.Hosting.Python.CreateEngine();
scope = engine.CreateScope();
engine.Runtime.IO.SetOutput(Output,Encoding.Unicode);
engine.SetTrace(on_trace);
StringBuilder sb = new StringBuilder();
sb.AppendLine(@"import sys ");
sb.AppendLine(@"sys.path.append("".\py\Lib.zip"") ");
sb.AppendLine(@"sys.path.append("".\scripts"") ");
ScriptSource source = engine.CreateScriptSourceFromString(sb.ToString());
source.Execute(scope);
string init_py = Pub.exe_dir + @"\py\init.py";
if (System.IO.File.Exists(init_py))
{
ScriptSource source_init = engine.CreateScriptSourceFromFile(init_py);
source_init.Execute(scope);
}
}执行脚本
public Boolean Execute(string script, out string msg, out IronPyErrors err, ExecRequest request)
{
msg = "";
err = new IronPyErrors();
StringBuilder sb = request.log;
sb.AppendLine("开始 "+DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") );
sb.AppendLine("------");
try
{
last_trace_lineno = "";
last_trace_result = "";
ScriptSource source = engine.CreateScriptSourceFromString(script);
CompiledCode cc = source.Compile(err);
if (err.Items.Count > 0)
{
err.ToStringBuilder(sb);
msg = "编译错误";
sb.Append(msg);
return false;
}
scope.SetVariable("request", request);
Py.instance.Output.SetLength(0);
string sql_err = DataAccess.DataConn.clear_err();
cc.Execute(scope);
Py.instance.Output.Flush();
string print_s = Encoding.Unicode.GetString(Py.instance.Output.ToArray());
sql_err = DataAccess.DataConn.clear_err();
if (sql_err != "")
sb.AppendLine(sql_err);
sb.AppendLine(print_s);
sb.AppendLine("------");
msg = "运行完成 "+ DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") ;
sb.Append(msg);
return true;
}
catch (Exception e)
{
if (last_trace_lineno != "")
msg = "trace line:" + last_trace_lineno;
if (last_trace_result != "")
msg = msg + " " + "trace:" + last_trace_result;
msg = msg + " " + e.Message;
sb.Append(msg);
}
return false;
}using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using Microsoft.Scripting;
using Microsoft.Scripting.Hosting;
using IronPython;
using IronPython.Runtime;
using IronPython.Modules;
using IronPython.Compiler;
using IronPython.Runtime.Exceptions;
using IronPython.Hosting;
using Business;
namespace Mgr
{
public class Py
{
public static Py instance = null;
public static void init()
{
if (instance != null)
return;
instance = new Py();
instance.init_py_lib();
}
public ScriptEngine engine = null;
public ScriptScope scope = null;
public static string get_key(string name)
{
return name.Trim().ToLower();
}
public static Dictionary<string , ScriptSource> ScriptDict = new Dictionary<string , ScriptSource>();
public string set_script(string id ,string script)
{
if (id == "")
id = Guid.NewGuid().ToString();
id = get_key(id);
ScriptSource source = engine.CreateScriptSourceFromString(script);
ScriptDict[id] = source;
return id;
}
public string last_trace_lineno = "";
public string last_trace_result = "";
public TracebackDelegate on_trace(TraceBackFrame frame, string result, object payload)
{
last_trace_lineno = frame.f_lineno.ToString();
last_trace_result = result;
return on_trace;
}
public Boolean Compile(string script,out string msg, out CompiledCode cc, out IronPyErrors err)
{
msg = "";
err = new IronPyErrors();
cc = null;
try
{
ScriptSource source = engine.CreateScriptSourceFromString(script);
cc = source.Compile(err);
msg = "编译完成";
return true;
}
catch (Exception e)
{
msg = e.Message;
}
return false;
}
public Boolean Execute_cc(CompiledCode cc, out string msg, ExecRequest request)
{
msg = "";
StringBuilder sb = request.log;
sb.AppendLine("开始 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
sb.AppendLine("------");
try
{
last_trace_lineno = "";
last_trace_result = "";
scope.SetVariable("request", request);
Py.instance.Output.SetLength(0);
string sql_err = DataAccess.DataConn.clear_err();
cc.Execute(scope);
Py.instance.Output.Flush();
string print_s = Encoding.Unicode.GetString(Py.instance.Output.ToArray());
sql_err = DataAccess.DataConn.clear_err();
if (sql_err != "")
sb.AppendLine(sql_err);
sb.AppendLine(print_s);
sb.AppendLine("------");
msg = "运行完成 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
sb.Append(msg);
return true;
}
catch (Exception e)
{
if (last_trace_lineno != "")
msg = "trace line:" + last_trace_lineno;
if (last_trace_result != "")
msg = msg + " " + "trace:" + last_trace_result;
msg = msg + " " + e.Message;
sb.Append(msg);
}
return false;
}
public Boolean Execute(string script, out string msg, out IronPyErrors err, ExecRequest request)
{
msg = "";
err = new IronPyErrors();
StringBuilder sb = request.log;
sb.AppendLine("开始 "+DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") );
sb.AppendLine("------");
try
{
last_trace_lineno = "";
last_trace_result = "";
ScriptSource source = engine.CreateScriptSourceFromString(script);
CompiledCode cc = source.Compile(err);
if (err.Items.Count > 0)
{
err.ToStringBuilder(sb);
msg = "编译错误";
sb.Append(msg);
return false;
}
scope.SetVariable("request", request);
Py.instance.Output.SetLength(0);
string sql_err = DataAccess.DataConn.clear_err();
cc.Execute(scope);
Py.instance.Output.Flush();
string print_s = Encoding.Unicode.GetString(Py.instance.Output.ToArray());
sql_err = DataAccess.DataConn.clear_err();
if (sql_err != "")
sb.AppendLine(sql_err);
sb.AppendLine(print_s);
sb.AppendLine("------");
msg = "运行完成 "+ DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") ;
sb.Append(msg);
return true;
}
catch (Exception e)
{
if (last_trace_lineno != "")
msg = "trace line:" + last_trace_lineno;
if (last_trace_result != "")
msg = msg + " " + "trace:" + last_trace_result;
msg = msg + " " + e.Message;
sb.Append(msg);
}
return false;
}
public MemoryStream Output = new MemoryStream();
public void init_py_lib()
{
engine = IronPython.Hosting.Python.CreateEngine();
scope = engine.CreateScope();
engine.Runtime.IO.SetOutput(Output,Encoding.Unicode);
engine.SetTrace(on_trace);
StringBuilder sb = new StringBuilder();
sb.AppendLine(@"import sys ");
sb.AppendLine(@"sys.path.append("".\py\Lib.zip"") ");
sb.AppendLine(@"sys.path.append("".\scripts"") ");
ScriptSource source = engine.CreateScriptSourceFromString(sb.ToString());
source.Execute(scope);
string init_py = Pub.exe_dir + @"\py\init.py";
if (System.IO.File.Exists(init_py))
{
ScriptSource source_init = engine.CreateScriptSourceFromFile(init_py);
source_init.Execute(scope);
}
}
}
public class IronPyErrorsItem
{
public string Message { get; set; }
public int ErrorCode { get; set; }
public Severity sev { get; set; }
public SourceSpan Span { get; set; }
public string get_info()
{
string line = "";
line = Span.Start.Line.ToString() + "行" + Span.Start.Column.ToString() + "列";
line = line + "(" + sev.ToString() +" " + ErrorCode.ToString()+"): ";
line = line + Message;
return line;
}
}
public class IronPyErrors : ErrorListener
{
public List<IronPyErrorsItem> Items = new List<IronPyErrorsItem>();
public void ToStringBuilder(StringBuilder sb)
{
foreach (IronPyErrorsItem i in Items)
{
sb.AppendLine(i.get_info());
}
}
public override void ErrorReported(ScriptSource source, string message, Microsoft.Scripting.SourceSpan span, int errorCode, Microsoft.Scripting.Severity severity)
{
IronPyErrorsItem i = new IronPyErrorsItem{
Message = message,
ErrorCode = errorCode,
sev = severity,
Span = span
};
Items.Add(i);
}
}
}
