• 一个在C#中集成Python的例子

    一个在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')）。 

    1. import clr
    2. import io
    3. import os
    4. import string
    5.  
    6. clr.AddReference('System')
    7. clr.AddReference('System.Data')
    8. clr.AddReference('Business')
    9.  
    10. from System import *
    11. from System.Data import *
    12. from Business import *
    13.  
    14. def get_account_money_by_dt(account_id,date):
    15.   db=Pub.db_name_mgr
    16.   InitMoney=Pub.select_str(db,"select InitMoney from account where account_id="+account_id)
    17.   cash=Pub.select_str(db,"select sum(amount_real) from tran where account_id="+account_id+" and tran_date<="+date)
    18.   stock_amount=float.Parse("0")
    19.   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")
    20.   for dr in table_stock.Rows:
    21.     code_type=DBUtils.get_str(dr, "code_type");
    22.     code=DBUtils.get_str(dr, "code");
    23.     count=DBUtils.get_str(dr, "c");
    24.     price=Pub.select_str(code_type+"\\"+code,"select close from data_day where dt<="+date+" order by dt desc limit 1")
    25.     if price<>'':
    26.       stock_amount=stock_amount+float.Parse(price)*float.Parse(count)
    27.   if cash=="":
    28.      cash="0"
    29.   if InitMoney=="":
    30.      InitMoney="0"
    31.   return (float.Parse(InitMoney)+float.Parse(cash)+stock_amount).ToString("0.00")

    C#的说明

    加载Python环境

                instance = new Py();
                instance.init_py_lib();

    1.         public void init_py_lib()
    2.         {
    3.           
    4.             engine = IronPython.Hosting.Python.CreateEngine();
    5.             scope = engine.CreateScope();
    6.             engine.Runtime.IO.SetOutput(Output,Encoding.Unicode);
    7.             engine.SetTrace(on_trace);
    8.             StringBuilder sb = new StringBuilder();
    9.             sb.AppendLine(@"import sys ");
    10.             sb.AppendLine(@"sys.path.append("".\py\Lib.zip"") ");
    11.             sb.AppendLine(@"sys.path.append("".\scripts"") ");
    12.             ScriptSource source = engine.CreateScriptSourceFromString(sb.ToString());
    13.             source.Execute(scope);
    14.             string init_py = Pub.exe_dir + @"\py\init.py";
    15.             if (System.IO.File.Exists(init_py))
    16.             {
    17.                 ScriptSource source_init = engine.CreateScriptSourceFromFile(init_py);
    18.                 source_init.Execute(scope);
    19.             }
    20.  
    21.         }

    执行脚本

     

    1.        public Boolean Execute(string script, out string msg, out IronPyErrors err, ExecRequest request)
    2.         {
    3.             msg = "";
    4.             err = new IronPyErrors();
    5.             StringBuilder sb = request.log;
    6.             sb.AppendLine("开始 "+DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") );
    7.             sb.AppendLine("------");
    8.             try
    9.             {
    10.                 last_trace_lineno = "";
    11.                 last_trace_result = "";
    12.                 ScriptSource source = engine.CreateScriptSourceFromString(script);                
    13.                 CompiledCode cc = source.Compile(err);  
    14.                 if (err.Items.Count > 0)
    15.                 {
    16.                     err.ToStringBuilder(sb);
    17.                     msg = "编译错误";
    18.                     sb.Append(msg);
    19.                     return false;
    20.                 }
    21.                 scope.SetVariable("request", request);
    22.                 Py.instance.Output.SetLength(0);
    23.                 string sql_err = DataAccess.DataConn.clear_err();
    24.                 cc.Execute(scope);               
    25.                 Py.instance.Output.Flush();
    26.                 string print_s = Encoding.Unicode.GetString(Py.instance.Output.ToArray());
    27.                 sql_err = DataAccess.DataConn.clear_err();
    28.                 if (sql_err != "")
    29.                     sb.AppendLine(sql_err);
    30.                 sb.AppendLine(print_s);
    31.                 sb.AppendLine("------");
    32.                 msg = "运行完成 "+ DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") ;
    33.                 sb.Append(msg);
    34.                 return true;
    35.             }
    36.             catch (Exception e)
    37.             {
    38.                 if (last_trace_lineno != "")
    39.                     msg = "trace line:" + last_trace_lineno;
    40.                 if (last_trace_result != "")
    41.                     msg = msg + " " + "trace:" + last_trace_result;
    42.                 msg = msg + " " + e.Message;
    43.                 sb.Append(msg);
    44.             }
    45.             return false;
    46.         }
    1. using System;
    2. using System.Collections.Generic;
    3. using System.Linq;
    4. using System.Text;
    5. using System.IO;
    6. using Microsoft.Scripting;
    7. using Microsoft.Scripting.Hosting;
    8. using IronPython;
    9. using IronPython.Runtime;
    10. using IronPython.Modules;
    11. using IronPython.Compiler;
    12. using IronPython.Runtime.Exceptions;
    13. using IronPython.Hosting;
    14. using Business;
    15.  
    16. namespace Mgr
    17. {
    18.    public class Py
    19.     {
    20.         public static Py instance = null;
    21.         public static void init()
    22.         {
    23.             if (instance != null)
    24.                 return;
    25.             instance = new Py();
    26.             instance.init_py_lib();
    27.         }
    28.         public ScriptEngine engine = null;
    29.         public ScriptScope scope = null;
    30.         public static string get_key(string name)
    31.         {
    32.             return name.Trim().ToLower();
    33.         }
    34.         
    35.         public static Dictionary<string , ScriptSource> ScriptDict = new Dictionary<string , ScriptSource>();
    36.         public string set_script(string id ,string script)
    37.         {
    38.             if (id == "")
    39.                 id = Guid.NewGuid().ToString();
    40.             id = get_key(id);
    41.             ScriptSource source = engine.CreateScriptSourceFromString(script);
    42.             ScriptDict[id] = source;
    43.             return id;
    44.         }
    45.         public string last_trace_lineno = "";
    46.         public string last_trace_result = "";
    47.         public TracebackDelegate on_trace(TraceBackFrame frame, string result, object payload)
    48.         {
    49.             last_trace_lineno = frame.f_lineno.ToString();
    50.             last_trace_result = result;
    51.             return on_trace;
    52.  
    53.         }
    54.         public Boolean Compile(string script,out string msg, out CompiledCode cc, out  IronPyErrors err)
    55.         {
    56.             msg = "";
    57.             err = new IronPyErrors();
    58.             cc = null;
    59.             try
    60.             {
    61.                 ScriptSource source = engine.CreateScriptSourceFromString(script);              
    62.                 cc = source.Compile(err);
    63.                 msg = "编译完成";
    64.                 return true;
    65.             }
    66.             catch (Exception e)
    67.             {
    68.                 msg = e.Message;
    69.             }
    70.             return false;
    71.         }
    72.         public Boolean Execute_cc(CompiledCode cc, out string msg, ExecRequest request)
    73.         {
    74.             msg = "";
    75.             StringBuilder sb = request.log;
    76.             sb.AppendLine("开始 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
    77.             sb.AppendLine("------");
    78.             try
    79.             {
    80.                 last_trace_lineno = "";
    81.                 last_trace_result = "";
    82.                 scope.SetVariable("request", request);
    83.                 Py.instance.Output.SetLength(0);
    84.                 string sql_err = DataAccess.DataConn.clear_err();
    85.                 cc.Execute(scope);
    86.                 Py.instance.Output.Flush();
    87.                 string print_s = Encoding.Unicode.GetString(Py.instance.Output.ToArray());
    88.                 sql_err = DataAccess.DataConn.clear_err();
    89.                 if (sql_err != "")
    90.                     sb.AppendLine(sql_err);
    91.                 sb.AppendLine(print_s);
    92.                 sb.AppendLine("------");
    93.                 msg = "运行完成 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
    94.                 sb.Append(msg);
    95.                 return true;
    96.             }
    97.             catch (Exception e)
    98.             {
    99.                 if (last_trace_lineno != "")
    100.                     msg = "trace line:" + last_trace_lineno;
    101.                 if (last_trace_result != "")
    102.                     msg = msg + " " + "trace:" + last_trace_result;
    103.                 msg = msg + " " + e.Message;
    104.                 sb.Append(msg);
    105.             }
    106.             return false;
    107.         }
    108.         public Boolean Execute(string script, out string msg, out IronPyErrors err, ExecRequest request)
    109.         {
    110.             msg = "";
    111.             err = new IronPyErrors();
    112.             StringBuilder sb = request.log;
    113.             sb.AppendLine("开始 "+DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") );
    114.             sb.AppendLine("------");
    115.             try
    116.             {
    117.                 last_trace_lineno = "";
    118.                 last_trace_result = "";
    119.                 ScriptSource source = engine.CreateScriptSourceFromString(script);                
    120.                 CompiledCode cc = source.Compile(err);  
    121.                 if (err.Items.Count > 0)
    122.                 {
    123.                     err.ToStringBuilder(sb);
    124.                     msg = "编译错误";
    125.                     sb.Append(msg);
    126.                     return false;
    127.                 }
    128.                 scope.SetVariable("request", request);
    129.                 Py.instance.Output.SetLength(0);
    130.                 string sql_err = DataAccess.DataConn.clear_err();
    131.                 cc.Execute(scope);               
    132.                 Py.instance.Output.Flush();
    133.                 string print_s = Encoding.Unicode.GetString(Py.instance.Output.ToArray());
    134.                 sql_err = DataAccess.DataConn.clear_err();
    135.                 if (sql_err != "")
    136.                     sb.AppendLine(sql_err);
    137.                 sb.AppendLine(print_s);
    138.                 sb.AppendLine("------");
    139.                 msg = "运行完成 "+ DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") ;
    140.                 sb.Append(msg);
    141.                 return true;
    142.             }
    143.             catch (Exception e)
    144.             {
    145.                 if (last_trace_lineno != "")
    146.                     msg = "trace line:" + last_trace_lineno;
    147.                 if (last_trace_result != "")
    148.                     msg = msg + " " + "trace:" + last_trace_result;
    149.                 msg = msg + " " + e.Message;
    150.                 sb.Append(msg);
    151.             }
    152.             return false;
    153.         }
    154.         public MemoryStream Output = new MemoryStream();
    155.         public void init_py_lib()
    156.         {
    157.           
    158.             engine = IronPython.Hosting.Python.CreateEngine();
    159.             scope = engine.CreateScope();
    160.             engine.Runtime.IO.SetOutput(Output,Encoding.Unicode);
    161.             engine.SetTrace(on_trace);
    162.             StringBuilder sb = new StringBuilder();
    163.             sb.AppendLine(@"import sys ");
    164.             sb.AppendLine(@"sys.path.append("".\py\Lib.zip"") ");
    165.             sb.AppendLine(@"sys.path.append("".\scripts"") ");
    166.             ScriptSource source = engine.CreateScriptSourceFromString(sb.ToString());
    167.             source.Execute(scope);
    168.             string init_py = Pub.exe_dir + @"\py\init.py";
    169.             if (System.IO.File.Exists(init_py))
    170.             {
    171.                 ScriptSource source_init = engine.CreateScriptSourceFromFile(init_py);
    172.                 source_init.Execute(scope);
    173.             }
    174.  
    175.         }
    176.     }
    177.     public class IronPyErrorsItem
    178.     {
    179.         public string Message { get; set; }
    180.         public int ErrorCode { get; set; }
    181.         public Severity sev { get; set; }
    182.         public SourceSpan Span { get; set; }
    183.         public string get_info()
    184.         {
    185.             string line = "";
    186.             line = Span.Start.Line.ToString() + "行" + Span.Start.Column.ToString() + "列";
    187.             line = line + "(" + sev.ToString() +" " + ErrorCode.ToString()+"): ";
    188.             line = line +  Message;
    189.             return line;
    190.         }
    191.     }
    192.     public class IronPyErrors : ErrorListener
    193.     {
    194.         public List Items = new List();
    195.         public void ToStringBuilder(StringBuilder sb)
    196.         {
    197.             foreach (IronPyErrorsItem i in Items)
    198.             {
    199.                 sb.AppendLine(i.get_info());
    200.             }
    201.         }
    202.         public override void ErrorReported(ScriptSource source, string message, Microsoft.Scripting.SourceSpan span, int errorCode, Microsoft.Scripting.Severity severity)
    203.         {
    204.             IronPyErrorsItem i = new IronPyErrorsItem{
    205.                 Message = message,
    206.                 ErrorCode = errorCode,
    207.                 sev = severity,
    208.                 Span = span
    209.             };
    210.             Items.Add(i);
    211.         }
    212. }
    213. }

  • 相关阅读:
    JavaSE之注解
    利用CNN识别英文语音数字
    11、voc转yolo数据集、训练集验证集划分、修改xml文件
    理解JS函数之call,apply,bind
    C++ Reference: Standard C++ Library reference: C Library: cstdio: fputs
    SQL的delete和drop
    微信小程序开发实战 云音乐
    【owt-server】RTC视频接收调用流程学习笔记1： Call::CreateVideoReceiveStream 前后
    zotero文献管理工具安装使用
    灰狼算法Grey Wolf Optimizer跑23个经典测试函数|含源码
  • 原文地址：https://blog.csdn.net/withcsharp2/article/details/139710244