whm
/
BcCenter
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

初始版本

Browse Source
master
Hao 3 years ago
commit 9701794cd1
21 changed files with 3473 additions and 0 deletions
Show Stats Download Patch File Download Diff File

12
BcCenter/BcCenter.Common/App.config
Unescape Escape View File

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="utf-8"?>
<configuration>
<configSections>
<!-- For more information on Entity Framework configuration, visit http://go.microsoft.com/fwlink/?LinkID=237468 -->
<section name="entityFramework" type="System.Data.Entity.Internal.ConfigFile.EntityFrameworkSection, EntityFramework, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" requirePermission="false" />
</configSections>
<entityFramework>
<providers>
<provider invariantName="System.Data.SqlClient" type="System.Data.Entity.SqlServer.SqlProviderServices, EntityFramework.SqlServer" />
</providers>
</entityFramework>
</configuration>

94
BcCenter/BcCenter.Common/BcCenter.Common.csproj
Unescape Escape View File

@ -0,0 +1,94 @@
<?xml version="1.0" encoding="utf-8"?>
<Project ToolsVersion="15.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<Import Project="..\packages\EntityFramework.6.4.4\build\EntityFramework.props" Condition="Exists('..\packages\EntityFramework.6.4.4\build\EntityFramework.props')" />
<Import Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props" Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')" />
<PropertyGroup>
<Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
<Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
<ProjectGuid>{D26A3DF4-4F5B-4B40-8723-2B9477E754A1}</ProjectGuid>
<OutputType>Library</OutputType>
<AppDesignerFolder>Properties</AppDesignerFolder>
<RootNamespace>BcCenter.Common</RootNamespace>
<AssemblyName>BcCenter.Common</AssemblyName>
<TargetFrameworkVersion>v4.6.1</TargetFrameworkVersion>
<FileAlignment>512</FileAlignment>
<Deterministic>true</Deterministic>
<NuGetPackageImportStamp>
</NuGetPackageImportStamp>
</PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
<DebugSymbols>true</DebugSymbols>
<DebugType>full</DebugType>
<Optimize>false</Optimize>
<OutputPath>bin\Debug\</OutputPath>
<DefineConstants>DEBUG;TRACE</DefineConstants>
<ErrorReport>prompt</ErrorReport>
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
<DebugType>pdbonly</DebugType>
<Optimize>true</Optimize>
<OutputPath>bin\Release\</OutputPath>
<DefineConstants>TRACE</DefineConstants>
<ErrorReport>prompt</ErrorReport>
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<ItemGroup>
<Reference Include="Common.Logging, Version=3.3.1.0, Culture=neutral, PublicKeyToken=af08829b84f0328e, processorArchitecture=MSIL">
<HintPath>..\packages\Common.Logging.3.3.1\lib\net40\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="Common.Logging.Core, Version=3.3.1.0, Culture=neutral, PublicKeyToken=af08829b84f0328e, processorArchitecture=MSIL">
<HintPath>..\packages\Common.Logging.Core.3.3.1\lib\net40\Common.Logging.Core.dll</HintPath>
</Reference>
<Reference Include="EntityFramework, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089, processorArchitecture=MSIL">
<HintPath>..\packages\EntityFramework.6.4.4\lib\net45\EntityFramework.dll</HintPath>
</Reference>
<Reference Include="EntityFramework.SqlServer, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089, processorArchitecture=MSIL">
<HintPath>..\packages\EntityFramework.6.4.4\lib\net45\EntityFramework.SqlServer.dll</HintPath>
</Reference>
<Reference Include="log4net, Version=2.0.14.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
<HintPath>..\packages\log4net.2.0.14\lib\net45\log4net.dll</HintPath>
</Reference>
<Reference Include="Newtonsoft.Json, Version=13.0.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
<HintPath>..\packages\Newtonsoft.Json.13.0.1\lib\net45\Newtonsoft.Json.dll</HintPath>
</Reference>
<Reference Include="Quartz, Version=2.6.2.0, Culture=neutral, PublicKeyToken=f6b8c98a402cc8a4, processorArchitecture=MSIL">
<HintPath>..\packages\Quartz.2.6.2\lib\net40\Quartz.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.ComponentModel.DataAnnotations" />
<Reference Include="System.Configuration" />
<Reference Include="System.Core" />
<Reference Include="System.Web" />
<Reference Include="System.Xml.Linq" />
<Reference Include="System.Data.DataSetExtensions" />
<Reference Include="Microsoft.CSharp" />
<Reference Include="System.Data" />
<Reference Include="System.Net.Http" />
<Reference Include="System.Xml" />
</ItemGroup>
<ItemGroup>
<Compile Include="DB\BcCenterDataContext.cs" />
<Compile Include="DB\CommonDataContext.cs" />
<Compile Include="Helper\MailHelper.cs" />
<Compile Include="Helper\WebRequestHelper.cs" />
<Compile Include="JobListener.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
</ItemGroup>
<ItemGroup>
<None Include="App.config" />
<None Include="job_scheduling_data_2_0.xsd">
<SubType>Designer</SubType>
</None>
<None Include="packages.config" />
</ItemGroup>
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
<Target Name="EnsureNuGetPackageBuildImports" BeforeTargets="PrepareForBuild">
<PropertyGroup>
<ErrorText>这台计算机上缺少此项目引用的 NuGet 程序包。使用“NuGet 程序包还原”可下载这些程序包。有关更多信息，请参见 http://go.microsoft.com/fwlink/?LinkID=322105。缺少的文件是 {0}。</ErrorText>
</PropertyGroup>
<Error Condition="!Exists('..\packages\EntityFramework.6.4.4\build\EntityFramework.props')" Text="$([System.String]::Format('$(ErrorText)', '..\packages\EntityFramework.6.4.4\build\EntityFramework.props'))" />
<Error Condition="!Exists('..\packages\EntityFramework.6.4.4\build\EntityFramework.targets')" Text="$([System.String]::Format('$(ErrorText)', '..\packages\EntityFramework.6.4.4\build\EntityFramework.targets'))" />
</Target>
<Import Project="..\packages\EntityFramework.6.4.4\build\EntityFramework.targets" Condition="Exists('..\packages\EntityFramework.6.4.4\build\EntityFramework.targets')" />
</Project>

142
BcCenter/BcCenter.Common/DB/BcCenterDataContext.cs
Unescape Escape View File

@ -0,0 +1,142 @@
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
using System.Data.Entity;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace BcCenter.Common.DB
{
public class BcCenterDataContext : DbContext
{
public BcCenterDataContext(string conn) : base(conn)
{
}
public BcCenterDataContext() : base("BcCenterDB")
{
}
//邮件
public DbSet<Mails> Mails { get; set; }
//附件
public DbSet<Attachments> Attachments { get; set; }
//收件邮箱
public DbSet<MailUserAccount> UserAccounts { get; set; }
//api账户
public DbSet<ApiAccount> ApiAccount { get; set; }
}
//邮件
[Table("Mails")]
public class Mails
{
public const string SourceTypeMail = "Mail";
public const string SourceTypeApi = "Api";
public const string SourceTypeApiDirect = "ApiDirect";
public Mails()
{
this.ReceiveTime = DateTime.Now;
this.SourceType = SourceTypeMail;
}
[Key]
public string GID { get; set; }
public string MailId { get; set; }
public string MailPath { get; set; }
public string SendUserMail { get; set; }
public string MailSubject { get; set; }
public string Status { get; set; }
public DateTime? EmailDate { get; set; }
public DateTime ReceiveTime { get; set; }
public DateTime? UpdateTime { get; set; }
public string CompId { get; set; }
public string CompName { get; set; }
public string UserName { get; set; }
public string MailAccount { get; set; }
public int ImapId { get; set; }
public string MailUrl { get; set; }
public string UserId { get; set; }
public DateTime? MailDate { get; set; }
public string SourceType { get; set; }
}
//附件
[Table("Attachments")]
public class Attachments
{
[Key]
public string GID { get; set; }
public string MailGID { get; set; }
public string MailID { get; set; }
public string AttachMD5 { get; set; }
public string AttachPath { get; set; }
public string AttachUrl { get; set; }
public string AttachName { get; set; }
public DateTime CreateTime { get; set; }
public DateTime? UpdateTime { get; set; }
public string Status { get; set; }
public string FileType { get; set; }
public string Tips { get; set; }
public string SendStatus { get; set; }
}
[Table("MailUserAccount")]
public class MailUserAccount
{
[Key]
public string GID { get; set; }
public string MailAccount { get; set; }
public string Password { get; set; }
public string ReceiveServer { get; set; }
public bool UseImap { get; set; }
public int ReceivePort { get; set; }
public bool ReceiveSSL { get; set; }
public string SmtpServer { get; set; }
public int SmtpPort { get; set; }
public bool SmtpSSL { get; set; }
public bool IsChanged { get; set; }
public string RelativeId { get; set; }
public int ProcessorCount { get; set; }
public int SenderCount { get; set; }
public string ManagerMailAddress { get; set; }
public int ParserCount { get; set; }
public string UserId { get; set; }
public string CompId { get; set; }
public string UserName { get; set; }
public string CompName { get; set; }
public string CREATEUSER { get; set; }
public DateTime CREATETIME { get; set; }
public string MODIFIEDUSER { get; set; }
public DateTime? MODIFIEDTIME { get; set; }
}
//api账号
[Table("ApiAccount")]
public class ApiAccount
{
[Key]
public string GID { get; set; }
public string CompanyId { get; set; }
public string CompanyName { get; set; }
public string LoginAccount { get; set; }
public string LoginPassword { get; set; }
public DateTime CreateTime { get; set; }
public DateTime? UpdateTime { get; set; }
public bool IsDisable { get; set; }
public string CreateUser { get; set; }
public string UpdateUser { get; set; }
}
}

944
BcCenter/BcCenter.Common/DB/CommonDataContext.cs
Unescape Escape View File

@ -0,0 +1,944 @@
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
using System.Data.Entity;
using System.Linq;
using System.Web;
namespace BcCenter.Common.DB
{
public class CommonDataContext : DbContext
{
public CommonDataContext() : base("DongShengDB")
{
Database.SetInitializer<CommonDataContext>(null);
}
public CommonDataContext(string conn) : base(conn)
{
Database.SetInitializer<CommonDataContext>(null);
}
public DbSet<ParamSet> ParamSets { get; set; }
public DbSet<SysOpRecord> SysOpRecords { get; set; }
public DbSet<User> Users { get; set; }
public DbSet<UserBaseinfo> UserBases { get; set; }
public DbSet<CompanyNew> CompanyNew { get; set; }
public DbSet<CodeVessel> Vessels { get; set; }
public DbSet<CodeVoyno> Voynos { get; set; }
public DbSet<CodeCtn> Ctns { get; set; }
public DbSet<CodeIssutype> Issutypes { get; set; }
public DbSet<CodeFrt> Frts { get; set; }
public DbSet<CodePackage> Packages { get; set; }
public DbSet<CodeService> Services { get; set; }
public DbSet<SysPrintInfo> SysPrintInfos { get; set; }
public DbSet<OpSeaeMbT> OpSeaeMbT { get; set; }
public DbSet<CodeFtpset> FtpSet { get; set; }
public DbSet<CodeYardDataSet> YardDataSet { get; set; }
/// <summary>
/// 子系统网关配置
/// </summary>
public DbSet<SysGateway> SysGateway { get; set; }
#region edi相关
public DbSet<CodeCtnEdi> CodeCtnEdi { get; set; }
public DbSet<CodeCustEdi> CodeCustEdi { get; set; }
public DbSet<CodePkgsEdi> CodePkgsEdi { get; set; }
public DbSet<CodeServiceEdi> CodeServiceEdi { get; set; }
public DbSet<CodeVesselEdi> CodeVesselEdi { get; set; }
public DbSet<CodeDisportEdi> CodeDisportEdi { get; set; }
#endregion
//航线
public DbSet<CodeLanes> CodeLanes { get; set; }
#region 权限相关
public DbSet<UserAuthorityInfo> UserAuthorityInfo { get; set; }
public DbSet<UserAuthorityRange> UserAuthorityRanges { get; set; }
#endregion
public DbSet<BackgroundTaskFtp> BackgroundTaskFtp { get; set; }
public DbSet<BackgroundTaskCommon> BackgroundTaskCommon { get; set; }
//公司参数
public DbSet<CompanyNewParamValue> ParamValues { get; set; }
public void SetValue(Object newObj, Object srcObj, bool dosave = false)
{
var t1s = srcObj.GetType().GetProperties();
var t2s = newObj.GetType().GetProperties();
foreach (var p in t1s)
{
foreach (var q in t2s)
{
if (q.Name == p.Name)
{// 这里有可能需要对属性的类型和值做一些判断和转换，大家自己根据自己的业务添加处理，估计不会很多
q.SetValue(newObj, p.GetValue(srcObj), null);
}
}
}
if (dosave)
SaveChanges();
}
public DbSet<CUST_AUTH> CUST_AUTH { get; set; }
}
[Table("tb_sys_Dictionary")]
public class Tb_SysDictionary
{
[Key, DatabaseGenerated(DatabaseGeneratedOption.Identity)]
public long ID { get; set; }
public string Gid { get; set; }
/// <summary>
/// 排序
/// </summary>
public int IndexInt { get; set; }
/// <summary>
/// 分组 系统的sys
/// </summary>
public string GroupName { get; set; }
/// <summary>
/// 分组中的子键值
/// </summary>
public string Key { get; set; }
/// <summary>
/// 名称名字
/// </summary>
public string Title { get; set; }
/// <summary>
/// 备注
/// </summary>
public string Memo { get; set; }
/// <summary>
/// 创建时间戳
/// </summary>
public long AddTime { get; set; }
/// <summary>
/// 状态 1 -100
/// </summary>
public short Status { get; set; }
}
[Table("tb_SysGateway")]
public class SysGateway
{
[Key, DatabaseGenerated(DatabaseGeneratedOption.Identity)]
public long ID { get; set; }
public string Gid { get; set; }
/// <summary>
///子系统Key
/// </summary>
public string SysKey { get; set; }
/// <summary>
/// 子系统URl格式化模版
/// </summary>
public string Url { get; set; }
/// <summary>
/// 备注
/// </summary>
public string Memo { get; set; }
public DateTime CreateTime { get; set; }
public short Status { get; set; }
}
[Table("Sys_OpRecord")]
public class SysOpRecord
{
[Key, DatabaseGenerated(DatabaseGeneratedOption.Identity)]
public int ID { get; set; }
public string ModuleId { get; set; }
public string CateId { get; set; }
public DateTime OpTime { get; set; }
public string UserId { get; set; }
public string UserName { get; set; }
public string CompId { get; set; }
public string CompName { get; set; }
public string ReqAddr { get; set; }
public string ReqParam { get; set; }
public string RespData { get; set; }
public string IpAddr { get; set; }
public string WebBrowser { get; set; }
public string RelativeId { get; set; }
}
[Table("Sys_PrintInfo")]
public class SysPrintInfo
{
[Key]
public string GID { get; set; }
public string MODNAME { get; set; }
public string PRINTNAME { get; set; }
public string URL { get; set; }
public DateTime MODIFIEDTIME { get; set; }
public string CRC { get; set; }
}
#region code_开头系列
[Table("code_ctn")]
public class CodeCtn
{
[Key]
public string CTNID { get; set; }
public string CTNSIZE { get; set; }
public string CTNTYPE { get; set; }
public string CTN { get; set; }
public string EDICODE { get; set; }
public decimal? CTNWEIGHT { get; set; }
public string EEXPLAIN { get; set; }
public string CEXPLAIN { get; set; }
public string AFRCODE { get; set; }
public decimal? TEU { get; set; }
public decimal? DLIKGS { get; set; }
public string COSCO { get; set; }
public string EDICODE2 { get; set; }
public string EDICODE3 { get; set; }
public string EDICODE4 { get; set; }
public string CMACTN { get; set; }
public string CARGOSMARTCTN { get; set; }
}
/// <summary>
/// 付费方式
/// </summary>
[Table("code_frt")]
public class CodeFrt
{
[Key]
public string FEID { get; set; }
public string FRT { get; set; }
public string FRTCNAME { get; set; }
public string EDICODE { get; set; }
public string EDICODE_INTTRA_WEB { get; set; }
}
[Table("code_goods_inv")]
public class CodeGoodsInv
{
[Key]
public string GID { get; set; }
public string GOODCODE { get; set; }
public string GOODNAME { get; set; }
public string SPEC { get; set; }
public string UNIT { get; set; }
public string DESCRIP { get; set; }
public decimal? TAXRATE { get; set; }
public string TAXNO { get; set; }
public string TAXCLASS { get; set; }
public string TAXCLASSNAME { get; set; }
public string ISTAXPRICE { get; set; }
public string ISUSEPREF { get; set; }
public string ISDEF { get; set; }
public string ZTAXTYPE { get; set; }
public string DEFREMARK { get; set; }
public bool? ISSTOP { get; set; }
public string GoodsTypeGID { get; set; }
public string DEFCURR { get; set; }
public string CompId { get; set; }
public string CompName { get; set; }
public string CreateUser { get; set; }
public DateTime CreateTime { get; set; }
}
/// <summary>
/// 签单方式
/// </summary>
[Table("code_issutype")]
public class CodeIssutype
{
[Key]
public string GID { get; set; }
public string BLTYPE { get; set; }
}
/// <summary>
/// 包装
/// </summary>
[Table("code_package")]
public class CodePackage
{
[Key]
public string GID { get; set; }
public string PKGS { get; set; }
public string CEXPLAIN { get; set; }
public string EDICODE { get; set; }
public string AFRCODE { get; set; }
public string cosco { get; set; }
}
/// <summary>
/// 运输条款
/// </summary>
[Table("code_service")]
public class CodeService
{
[Key]
public string GID { get; set; }
public string SERVICE { get; set; }
}
[Table("code_vessel")]
public class CodeVessel
{
[Key]
public string VSID { get; set; }
public string VESSEL { get; set; }
public string CNAME { get; set; }
public string CARRIER { get; set; }
public string EDICODE { get; set; }
}
[Table("code_voyno")]
public class CodeVoyno
{
[Key]
public string VOID { get; set; }
public string VSID { get; set; }
public string VOYNO { get; set; }
public string PORTLOAD { get; set; }
public string PORTDISCHARGE { get; set; }
public DateTime? ETD { get; set; }
public DateTime? CLOSINGDATE { get; set; }
public DateTime? ETA { get; set; }
public string CORPID { get; set; }
public string YARDID { get; set; }
public string ENTREPORT { get; set; }
public string VESSEL { get; set; }
public DateTime? ATD { get; set; }
public string VOYNO_FORWARDER { get; set; }
public string FORWARDER { get; set; }
public string CARRIER { get; set; }
public DateTime? CLOSEDOCDATE { get; set; }
public DateTime? CLOSEVGMDATE { get; set; }
}
[Table("code_currency")]
public class CodeCurrency
{
[Key]
public string GID { get; set; }
public string CODENAME { get; set; }
public string NAME { get; set; }
public string DESCRIPTION { get; set; }
public decimal? DEFAULTRATE { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
public string MODIFIEDUSER { get; set; }
public DateTime? MODIFIEDTIME { get; set; }
public string FINANCESOFTCODE { get; set; }
}
[Table("code_goods_inv_template")]
public class CodeGoodsInvTemplate
{
[Key]
public string GID { get; set; }
public string GOODCODE { get; set; }
public string GOODNAME { get; set; }
public string SPEC { get; set; }
public string UNIT { get; set; }
public string DESCRIP { get; set; }
public decimal? TAXRATE { get; set; }
public string TAXNO { get; set; }
public string TAXCLASS { get; set; }
public string TAXCLASSNAME { get; set; }
public string ISTAXPRICE { get; set; }
public string ISUSEPREF { get; set; }
public string ISDEF { get; set; }
public string ZTAXTYPE { get; set; }
public string DEFREMARK { get; set; }
public string TradeType { get; set; }
}
#region edi相关
//集装箱
[Table("code_ctn_edi")]
public class CodeCtnEdi
{
[Key]
public string GID { get; set; }
public string CTN { get; set; }
public string EDICODE { get; set; }
public string EDINAME { get; set; }
public string REMARK { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
}
//往来单位
[Table("code_cust_edi")]
public class CodeCustEdi
{
[Key]
public string GID { get; set; }
public string CUST { get; set; }
public string EDICODE { get; set; }
public string EDINAME { get; set; }
public string REMARK { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
public string PORTSIDE { get; set; }
public string SENDINFO { get; set; }
}
//包装
[Table("code_pkgs_edi")]
public class CodePkgsEdi
{
[Key]
public string GID { get; set; }
public string PKGS { get; set; }
public string EDICODE { get; set; }
public string EDINAME { get; set; }
public string REMARK { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
}
//运输条款
[Table("code_service_edi")]
public class CodeServiceEdi
{
[Key]
public string GID { get; set; }
public string SERVICE { get; set; }
public string EDICODE { get; set; }
public string EDINAME { get; set; }
public string REMARK { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
}
//船名
[Table("code_vessel_edi")]
public class CodeVesselEdi
{
[Key]
public string GID { get; set; }
public string VESSEL { get; set; }
public string EDICODE { get; set; }
public string EDINAME { get; set; }
public string REMARK { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
}
//港口
[Table("code_disport_edi")]
public class CodeDisportEdi
{
[Key]
public string GID { get; set; }
public string PORTDISCHARGE { get; set; }
public string EDICODE { get; set; }
public string EDINAME { get; set; }
public string REMARK { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
public string PORTID { get; set; }
}
#endregion
//ftp设置
[Table("code_ftpset")]
public class CodeFtpset
{
[Key]
public string GID { get; set; }
public string EDINAME { get; set; }
public string SERVERIP { get; set; }
public string FOLDERNAME { get; set; }
public string USERNAME { get; set; }
public string PASSWORD { get; set; }
public string CORPID { get; set; }
public string SENDCODE { get; set; }
public string RECEIVECODE { get; set; }
public string SENDNAME { get; set; }
public string SENDATTN { get; set; }
public string SENDTEL { get; set; }
public string SENDEMAIL { get; set; }
public string SENDCOMPANYCODE { get; set; }
public string SENDSUBCOMPANYCODE { get; set; }
public string CARRIERID { get; set; }
public string RECEIVEEMAIL { get; set; }
public string RECEIVESIEMAIL { get; set; }
public string RECEIVEOP { get; set; }
public string RECEIVESALE { get; set; }
public string RECEIVEDEPT { get; set; }
public string SHIPPERTEL { get; set; }
public string CONSIGNEETEL { get; set; }
public string NOTIFYPARTYTEL { get; set; }
public string ISUSETEL { get; set; }
public string CompId { get; set; }
public string CompName { get; set; }
}
//场站对应
[Table("code_yarddata_set")]
public class CodeYardDataSet
{
[Key]
public string GID { get; set; }
public string YARDCODE { get; set; }
public string YARD { get; set; }
public string LOGINNAME { get; set; }
public string PASSWORD { get; set; }
public string REMARK { get; set; }
public string COMPANYID { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
public string YitongCode { get; set; }
public string YitongName { get; set; }
}
[Table("code_lanes")]
public class CodeLanes
{
[Key]
public string GID { get; set; }
public string LANEID { get; set; }
public string LANE { get; set; }
public string LANEEN { get; set; }
public string EDICODE { get; set; }
public string OP { get; set; }
public string DOC { get; set; }
}
#endregion
/// <summary>
/// 托单收发通模板
/// </summary>
[Table("op_seae_t_mb")]
public class OpSeaeMbT
{
[Key]
public string gid { get; set; }
public string mbname { get; set; }
public string mbtype { get; set; }
public string mbtext { get; set; }
public DateTime? createtime { get; set; }
public string userid { get; set; }
public string CompId { get; set; }
}
#region 权限相关
[Table("user_action")]
public class UserAction
{
[Key]
public string GID { get; set; }
public string ACTIONID { get; set; }
public string USERID { get; set; }
public string CREATEUSER { get; set; }
public DateTime CREATETIME { get; set; }
public string MODIFIEDUSER { get; set; }
public DateTime? MODIFIEDTIME { get; set; }
}
[Table("user_authority_range")]
public class UserAuthorityRange
{
[Key]
public string GID { get; set; }
public string USERID { get; set; }
public string AUTHORITYID { get; set; }
public int? VISIBLERANGE { get; set; }
public int? OPERATERANGE { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
public string MODIFIEDUSER { get; set; }
public DateTime? MODIFIEDTIME { get; set; }
}
[Table("VW_User_Authority")]
public class VUserAuthority
{
[Key]
public string GID { get; set; }
public string USERID { get; set; }
public int VISIBLERANGE { get; set; }
public int OPERATERANGE { get; set; }
public bool? ISDELETE { get; set; }
public string DESCRIPTION { get; set; }
public string NAME { get; set; }
public string MODULEURL { get; set; }
public string AUTHORITYID { get; set; }
public bool? ISALL { get; set; }
public bool? ISCOMPANY { get; set; }
public bool? ISDEPT { get; set; }
public bool? ISPERSON { get; set; }
}
[Table("AuthUserVirtualModule")]
public class AuthUserVirtualModule
{
public const string RangePersonal = "Personal";
public const string RangeAll = "All";
[Key]
public string GId { get; set; }
public string ModuleId { get; set; }
public string UserId { get; set; }
public bool HasAuth { get; set; }
public string RangeViewValue { get; set; }
public string RangeOperateValue { get; set; }
}
[Table("AuthVirtualModule")]
public class AuthVirtualModule
{
[Key]
public string GId { get; set; }
public string ModuleName { get; set; }
public string ParentId { get; set; }
public string ModuleMap { get; set; }
public string RangeMap { get; set; }
public int Sort { get; set; }
}
[Table("user_authority_info")]
public class UserAuthorityInfo
{
[Key]
public string GID { get; set; }
public string NAME { get; set; }
public string DESCRIPTION { get; set; }
public string MODULEURL { get; set; }
public bool? ISALL { get; set; }
public bool? ISCOMPANY { get; set; }
public bool? ISDEPT { get; set; }
public bool? ISPERSON { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
public string MODIFIEDUSER { get; set; }
public DateTime? MODIFIEDTIME { get; set; }
public bool? ISDELETE { get; set; }
}
#endregion
//后台ftp任务
[Table("BackgroundTaskFtp")]
public class BackgroundTaskFtp
{
public BackgroundTaskFtp()
{
Status = StatusCreate;
CreateTime = DateTime.Now;
}
/// <summary>
/// 上传ftp
/// </summary>
public const string TypeFtpUpload = "FtpUpload";
/// <summary>
/// 新建
/// </summary>
public const string StatusCreate = "Create";
/// <summary>
/// 正在执行
/// </summary>
public const string StatusDoing = "Doing";
/// <summary>
/// 执行成功
/// </summary>
public const string StatusSuccess = "Success";
/// <summary>
/// 执行失败
/// </summary>
public const string StatusFail = "Fail";
[Key]
public string GID { get; set; }
public string Type { get; set; }
public string FtpHost { get; set; }
public string FtpUser { get; set; }
public string FtpPassword { get; set; }
public string FtpData { get; set; }
public DateTime CreateTime { get; set; }
public int TryCount { get; set; }
public DateTime? LastDo { get; set; }
public string Status { get; set; }
public string Remark { get; set; }
}
//后台任务（通用）
[Table("BackgroundTaskCommon")]
public class BackgroundTaskCommon
{
/// <summary>
/// 订舱自动放舱
/// </summary>
public const string TypeBookingFangCang = "BookingFangCang";
/// <summary>
/// 订舱BC
/// </summary>
public const string TypeBookingBC = "BookingBC";
/// <summary>
/// 回写SI状态
/// </summary>
public const string TypeBookingPostSiStatus = "PostSiStatus";
/// <summary>
/// HTTP Feedback
/// </summary>
public const string TypeHttpFeedback = "HttpFeedback";
/// <summary>
/// 下货纸
/// </summary>
public const string TypeBookingXiahuozhi = "Xiahuozhi";
/// <summary>
/// VGM核查
/// </summary>
public const string TypeVgmCheck = "VgmCheck";
/// <summary>
/// 重新比较BC、发送下货纸任务
/// </summary>
public const string TypeCompareBcRedo = "CompareBcRedo";
public const string StatusCreate = "Create";
public const string StatusDoing = "Doing";
public const string StatusSuccess = "Success";
public const string StatusFail = "Fail";
public BackgroundTaskCommon()
{
CreateTime = DateTime.Now;
Status = StatusCreate;
}
[Key]
public string GID { get; set; }
public string Type { get; set; }
public string ParamData { get; set; }
public string Status { get; set; }
public DateTime CreateTime { get; set; }
public int ExecuteCount { get; set; }
public DateTime? ExecuteTime { get; set; }
public string ResultData { get; set; }
}
[Table("CUST_AUTH")]
public class CUST_AUTH
{
[Key]
public string GID { get; set; }
public string USERID { get; set; }
public string SKEY { get; set; }
public int? BSTYPE { get; set; }
public DateTime CREATETIME { get; set; }
public string username { get; set; }
public string comname { get; set; }
public string Module { get; set; }
public string ModuleJson { get; set; }
public string IpBlackList { get; set; }
public string IpWhiteList { get; set; }
public int Status { get; set; }
}
[Table("company_new")]
public class CompanyNew
{
public const string AuditStatusNotSubmit = "NotSubmit";
public const string AuditStatusAuditing = "Auditing";
public const string AuditStatusSuccess = "Success";
public const string AuditStatusReject = "Reject";
[Key]
public string CompId { get; set; }
public string CompName { get; set; }
public string SourceName { get; set; }
public int AlertMinValue { get; set; }
public string AuditStatus { get; set; }
public string AuditText { get; set; }
public string AdminUser { get; set; }
public string AdminShowName { get; set; }
public string Address { get; set; }
public string Tel { get; set; }
public string TaxCode { get; set; }
/// <summary>
/// 海关登记号
/// </summary>
public string CustomsCode { get; set; }
public string BankName { get; set; }
public string BankAccount { get; set; }
public string LicenceImage { get; set; }
public string InvoiceSystem { get; set; }
public string InvoiceApi { get; set; }
public string EmailShowName { get; set; }
public bool MinValueSMS { get; set; }
public bool MinValueEmail { get; set; }
public string MinValueEmailAddr { get; set; }
}
[Table("user")]
public class User
{
[Key]
public string GID { get; set; }
public string USERNAME { get; set; }
public string CODENAME { get; set; }
public string PASSWORD { get; set; }
public string SHOWNAME { get; set; }
public DateTime? ENROLLTIME { get; set; }
public string CREATEUSER { get; set; }
public string MODIFIEDUSER { get; set; }
public DateTime? MODIFIEDTIME { get; set; }
public bool? ISDELETED { get; set; }
public bool? ISDISABLE { get; set; }
public string DELETEUSER { get; set; }
public DateTime? DELETETIME { get; set; }
public string NOCODE { get; set; }
public string OPENID { get; set; }
public string WeChatAccount { get; set; }
public string FaSongFangDaiMa { get; set; }
public string ptPhone { get; set; }
public string ptEmail { get; set; }
public string comid { get; set; }
public bool isAllowGenerate { get; set; }
public bool isAllowSend { get; set; }
public string COMNAME { get; set; }
public string YAOQINGMA { get; set; }
public string cscode { get; set; }
public string COMTYPE { get; set; }
//用户绑定公司的ID，认证后或加入公司后，置值所属公司的ID
public string CompId { get; set; }
}
[Table("user_baseinfo")]
public class UserBaseinfo
{
[Key]
public string GID { get; set; }
public string USERID { get; set; }
public string COMPANYNAME { get; set; }
public string DEPTNAME { get; set; }
public string OFFICEPHONE { get; set; }
public string HOMEPHONE { get; set; }
public string MOBILE { get; set; }
public string FAX { get; set; }
public string EMAIL1 { get; set; }
public string EMAIL2 { get; set; }
public string HOMEADDRESS { get; set; }
public string REMARK { get; set; }
public string CREATEUSER { get; set; }
public DateTime? CREATETIME { get; set; }
public string MODIFIEDUSER { get; set; }
public DateTime? MODIFIEDTIME { get; set; }
public string EMERGUSER { get; set; }
public string EMERGPHONE { get; set; }
public string EMERGEMAIL { get; set; }
public string POSTCODE { get; set; }
public string QQ { get; set; }
public string MSN { get; set; }
public string FINANCESOFTCODE { get; set; }
public string IMAGEURL { get; set; }
public string SIGNATUREURL { get; set; }
public string FaSongFangDaiMa { get; set; }
public string JieShouFangDaiMa { get; set; }
public string QdPortUserName { get; set; }
public string QdPortPassword { get; set; }
}
[Table("sys_param_set")]
public class ParamSet
{
[Key]
public string GID { get; set; }
public string PARAMNAME { get; set; }
public string PARAMDESCRIPTION { get; set; }
public string PARAMVALUE { get; set; }
public string MODIFIEDUSER { get; set; }
public DateTime? MODIFIEDTIME { get; set; }
public string PARAMTYPE { get; set; }
public string FIELDTYPE { get; set; }
}
//公司参数
[Table("company_new_param")]
public class CompanyNewParam
{
[Key]
public string ParaCode { get; set; }
public string ParaName { get; set; }
public string Remark { get; set; }
}
//公司参数项
[Table("company_new_param_item")]
public class CompanyNewParamItem
{
[Key, Column(Order = 0)]
public string ParaCode { get; set; }
[Key, Column(Order = 1)]
public string ItemCode { get; set; }
public string ItemName { get; set; }
public string Remark { get; set; }
}
//公司参数值
[Table("company_new_param_value")]
public class CompanyNewParamValue
{
[Key, Column(Order = 0)]
public string ParaCode { get; set; }
[Key, Column(Order = 1)]
public string CompId { get; set; }
public string ItemCode { get; set; }
public string Remark { get; set; }
}
}

24
BcCenter/BcCenter.Common/Helper/MailHelper.cs
Unescape Escape View File

@ -0,0 +1,24 @@
using log4net;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace BcCenter.Common.Helper
{
public static class MailHelper
{
private static ILog logger = LogManager.GetLogger("MailHelper");
public static void SendMailService(string title, string body, string recUser)
{
var url = ConfigurationManager.AppSettings["MailSendServiceUrl"];
logger.Debug($"发送邮件【{title}】到【{recUser}】：{url}");
var rtn = WebRequestHelper.DoPost(url, JsonConvert.SerializeObject(new { }));
logger.Debug($"发送邮件返回：{rtn}");
}
}
}

337
BcCenter/BcCenter.Common/Helper/WebRequestHelper.cs
Unescape Escape View File

@ -0,0 +1,337 @@
using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Compression;
using System.Linq;
using System.Net;
using System.Text;
using System.Web;
namespace BcCenter.Common.Helper
{
public static class WebRequestHelper
{
public static string DoGet(string url, int timeout = 3000, Dictionary<string, string> dicHead = null)
{
string responseString = "";//post返回的结果
ServicePointManager.ServerCertificateValidationCallback += (sender, cert, chain, err) => { return true; };
ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(url);
req.Method = "GET";
req.ContentLength = 0;
req.Timeout = timeout;
req.KeepAlive = false;
if (dicHead != null && dicHead.Count > 0)
{
foreach (var key in dicHead.Keys)
{
req.Headers.Add(key, dicHead[key]);
}
}
var response = req.GetResponse();
Stream streamResponse = response.GetResponseStream();
StreamReader streamRead = new StreamReader(streamResponse);
responseString = streamRead.ReadToEnd();
response.Close();
streamRead.Close();
return responseString;
}
/// <summary>
/// Post Json提交
/// </summary>
/// <param name="url"></param>
/// <param name="PostData"></param>
/// <param name="timeout"></param>
/// <returns></returns>
public static string DoPostJson(string url, object PostData, int timeout = 10000) => DoPost(url, Newtonsoft.Json.JsonConvert.SerializeObject(PostData), timeout);
public static string DoPost(string url, string json, int timeout = 10000, Dictionary<string, string> dicHead = null)
{
string responseString = "";//post返回的结果
ServicePointManager.ServerCertificateValidationCallback += (sender, cert, chain, err) => { return true; };
ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(url);
req.Method = "POST";
req.Timeout = timeout;
if (dicHead != null && dicHead.Count > 0)
{
foreach (var key in dicHead.Keys)
{
req.Headers.Add(key, dicHead[key]);
}
}
if (!string.IsNullOrWhiteSpace(json))
{
byte[] postBytes = Encoding.UTF8.GetBytes(json);
req.ContentType = "application/json; charset=utf-8";
req.ContentLength = Encoding.UTF8.GetByteCount(json);
Stream stream = req.GetRequestStream();
stream.Write(postBytes, 0, postBytes.Length);
stream.Close();
}
else
{
req.ContentLength = 0;
}
var response = req.GetResponse();
Stream streamResponse = response.GetResponseStream();
StreamReader streamRead = new StreamReader(streamResponse);
responseString = streamRead.ReadToEnd();
response.Close();
streamRead.Close();
return responseString;
}
public static string DoPost(string url, Dictionary<string, string> dic, int timeout = 10000)
{
string responseString = "";//post返回的结果
ServicePointManager.ServerCertificateValidationCallback += (sender, cert, chain, err) => { return true; };
ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(url);
req.Method = "POST";
req.Timeout = timeout;
req.Headers.Add("Accept-Encoding", "gzip, deflate");
if (dic.Count > 0)
{
string strContent = string.Empty;
foreach (var item in dic)
{
if (strContent.Length > 0)
{
strContent += "&";
}
strContent += $"{item.Key}={item.Value}";
}
byte[] postBytes = Encoding.UTF8.GetBytes(strContent);
req.ContentType = "application/x-www-form-urlencoded";
req.ContentLength = postBytes.Length;
Stream stream = req.GetRequestStream();
stream.Write(postBytes, 0, postBytes.Length);
stream.Close();
}
else
{
req.ContentLength = 0;
}
var response = req.GetResponse();
responseString = GetResponseBody((HttpWebResponse)response);
return responseString;
}
private static string GetResponseBody(HttpWebResponse response)
{
string responseBody = string.Empty;
if (response.ContentEncoding.ToLower().Contains("gzip"))
{
using (GZipStream stream = new GZipStream(response.GetResponseStream(), CompressionMode.Decompress))
{
using (StreamReader reader = new StreamReader(stream))
{
responseBody = reader.ReadToEnd();
}
}
}
else if (response.ContentEncoding.ToLower().Contains("deflate"))
{
using (DeflateStream stream = new DeflateStream(
response.GetResponseStream(), CompressionMode.Decompress))
{
using (StreamReader reader =
new StreamReader(stream, Encoding.UTF8))
{
responseBody = reader.ReadToEnd();
}
}
}
else
{
using (Stream stream = response.GetResponseStream())
{
using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
{
responseBody = reader.ReadToEnd();
}
}
}
return responseBody;
}
/// <summary>
/// 使用Post方法获取字符串结果
/// </summary>
/// <param name="url"></param>
/// <param name="formItems">Post表单内容</param>
/// <param name="timeOut">默认20秒</param>
/// <returns></returns>
public static string PostForm(string url, List<FormItemModel> formItems, int timeOut = 20000)
{
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
#region 初始化请求对象
request.Method = "POST";
request.Timeout = timeOut;
request.Accept = "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8";
request.KeepAlive = true;
request.UserAgent = "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/31.0.1650.57 Safari/537.36";
#endregion
string boundary = "----" + DateTime.Now.Ticks.ToString("x");//分隔符
request.ContentType = string.Format("multipart/form-data; boundary={0}", boundary);
//请求流
var postStream = new MemoryStream();
#region 处理Form表单请求内容
//是否用Form上传文件
var formUploadFile = formItems != null && formItems.Count > 0;
if (formUploadFile)
{
//文件数据模板
string fileFormdataTemplate =
"\r\n--" + boundary +
"\r\nContent-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"" +
"\r\nContent-Type: application/octet-stream" +
"\r\n\r\n";
//文本数据模板
string dataFormdataTemplate =
"\r\n--" + boundary +
"\r\nContent-Disposition: form-data; name=\"{0}\"" +
"\r\n\r\n{1}";
foreach (var item in formItems)
{
string formdata = null;
if (item.IsFile)
{
//上传文件
formdata = string.Format(
fileFormdataTemplate,
item.Key, //表单键
item.FileName);
}
else
{
//上传文本
formdata = string.Format(
dataFormdataTemplate,
item.Key,
item.Value);
}
//统一处理
byte[] formdataBytes = null;
//第一行不需要换行
if (postStream.Length == 0)
formdataBytes = Encoding.UTF8.GetBytes(formdata.Substring(2, formdata.Length - 2));
else
formdataBytes = Encoding.UTF8.GetBytes(formdata);
postStream.Write(formdataBytes, 0, formdataBytes.Length);
//写入文件内容
if (item.FileContent != null && item.FileContent.Length > 0)
{
using (var stream = item.FileContent)
{
byte[] buffer = new byte[1024];
int bytesRead = 0;
while ((bytesRead = stream.Read(buffer, 0, buffer.Length)) != 0)
{
postStream.Write(buffer, 0, bytesRead);
}
}
}
}
//结尾
var footer = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");
postStream.Write(footer, 0, footer.Length);
}
else
{
request.ContentType = "application/x-www-form-urlencoded";
}
#endregion
request.ContentLength = postStream.Length;
#region 输入二进制流
if (postStream != null)
{
postStream.Position = 0;
//直接写入流
Stream requestStream = request.GetRequestStream();
byte[] buffer = new byte[1024];
int bytesRead = 0;
while ((bytesRead = postStream.Read(buffer, 0, buffer.Length)) != 0)
{
requestStream.Write(buffer, 0, bytesRead);
}
//postStream.Seek(0, SeekOrigin.Begin);
//StreamReader sr = new StreamReader(postStream);
//var postStr = sr.ReadToEnd();
postStream.Close();//关闭文件访问
}
#endregion
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
using (Stream responseStream = response.GetResponseStream())
{
using (StreamReader myStreamReader = new StreamReader(responseStream, Encoding.UTF8))
{
string retString = myStreamReader.ReadToEnd();
return retString;
}
}
}
}
/// <summary>
/// 表单数据项
/// </summary>
public class FormItemModel
{
/// <summary>
/// 表单键，request["key"]
/// </summary>
public string Key { set; get; }
/// <summary>
/// 表单值,上传文件时忽略，request["key"].value
/// </summary>
public string Value { set; get; }
/// <summary>
/// 是否是文件
/// </summary>
public bool IsFile
{
get
{
if (FileContent == null || FileContent.Length == 0)
return false;
if (FileContent != null && FileContent.Length > 0 && string.IsNullOrWhiteSpace(FileName))
throw new Exception("上传文件时 FileName 属性值不能为空");
return true;
}
}
/// <summary>
/// 上传的文件名
/// </summary>
public string FileName { set; get; }
/// <summary>
/// 上传的文件内容
/// </summary>
public Stream FileContent { set; get; }
}
}

126
BcCenter/BcCenter.Common/JobListener.cs
Unescape Escape View File

@ -0,0 +1,126 @@
using log4net;
using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace BcCenter.Common
{
public class JobListener : ISchedulerListener
{
private ILog logger = LogManager.GetLogger("JobListener");
public void JobAdded(IJobDetail jobDetail)
{
logger.Debug($"Job被添加：{jobDetail.JobType}");
}
public void JobDeleted(JobKey jobKey)
{
}
public void JobPaused(JobKey jobKey)
{
}
public void JobResumed(JobKey jobKey)
{
}
public void JobScheduled(ITrigger trigger)
{
}
public void JobsPaused(string jobGroup)
{
}
public void JobsResumed(string jobGroup)
{
}
public void JobUnscheduled(TriggerKey triggerKey)
{
}
public void SchedulerError(string msg, SchedulerException cause)
{
logger.Error(msg);
var excep = cause as Exception;
while (true)
{
logger.Error(excep.Message);
logger.Error(excep.StackTrace);
excep = excep.InnerException;
}
}
public void SchedulerInStandbyMode()
{
}
public void SchedulerShutdown()
{
logger.Debug($"SchedulerShutdown");
}
public void SchedulerShuttingdown()
{
}
public void SchedulerStarted()
{
logger.Debug($"SchedulerStarted");
}
public void SchedulerStarting()
{
}
public void SchedulingDataCleared()
{
}
public void TriggerFinalized(ITrigger trigger)
{
}
public void TriggerPaused(TriggerKey triggerKey)
{
}
public void TriggerResumed(TriggerKey triggerKey)
{
}
public void TriggersPaused(string triggerGroup)
{
}
public void TriggersResumed(string triggerGroup)
{
}
}
}

36
BcCenter/BcCenter.Common/Properties/AssemblyInfo.cs
Unescape Escape View File

@ -0,0 +1,36 @@
using System.Reflection;
using System.Runtime.CompilerServices;
using System.Runtime.InteropServices;
// 有关程序集的一般信息由以下
// 控制。更改这些特性值可修改
// 与程序集关联的信息。
[assembly: AssemblyTitle("BcCenter.Common")]
[assembly: AssemblyDescription("")]
[assembly: AssemblyConfiguration("")]
[assembly: AssemblyCompany("")]
[assembly: AssemblyProduct("BcCenter.Common")]
[assembly: AssemblyCopyright("Copyright © 2022")]
[assembly: AssemblyTrademark("")]
[assembly: AssemblyCulture("")]
// 将 ComVisible 设置为 false 会使此程序集中的类型
//对 COM 组件不可见。如果需要从 COM 访问此程序集中的类型
//请将此类型的 ComVisible 特性设置为 true。
[assembly: ComVisible(false)]
// 如果此项目向 COM 公开，则下列 GUID 用于类型库的 ID
[assembly: Guid("d26a3df4-4f5b-4b40-8723-2b9477e754a1")]
// 程序集的版本信息由下列四个值组成:
//
// 主版本
// 次版本
// 生成号
// 修订号
//
//可以指定所有这些值，也可以使用“生成号”和“修订号”的默认值
//通过使用 "*"，如下所示:
// [assembly: AssemblyVersion("1.0.*")]
[assembly: AssemblyVersion("1.0.0.0")]
[assembly: AssemblyFileVersion("1.0.0.0")]

364
BcCenter/BcCenter.Common/job_scheduling_data_2_0.xsd
Unescape Escape View File

@ -0,0 +1,364 @@
<?xml version="1.0" encoding="UTF-8"?>
<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema"
xmlns="http://quartznet.sourceforge.net/JobSchedulingData"
targetNamespace="http://quartznet.sourceforge.net/JobSchedulingData"
elementFormDefault="qualified"
version="2.0">
<xs:element name="job-scheduling-data">
<xs:annotation>
<xs:documentation>Root level node</xs:documentation>
</xs:annotation>
<xs:complexType>
<xs:sequence maxOccurs="unbounded">
<xs:element name="pre-processing-commands" type="pre-processing-commandsType" minOccurs="0" maxOccurs="1">
<xs:annotation>
<xs:documentation>Commands to be executed before scheduling the jobs and triggers in this file.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="processing-directives" type="processing-directivesType" minOccurs="0" maxOccurs="1">
<xs:annotation>
<xs:documentation>Directives to be followed while scheduling the jobs and triggers in this file.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="schedule" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:sequence maxOccurs="unbounded">
<xs:element name="job" type="job-detailType" minOccurs="0" maxOccurs="unbounded" />
<xs:element name="trigger" type="triggerType" minOccurs="0" maxOccurs="unbounded" />
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:sequence>
<xs:attribute name="version" type="xs:string">
<xs:annotation>
<xs:documentation>Version of the XML Schema instance</xs:documentation>
</xs:annotation>
</xs:attribute>
</xs:complexType>
</xs:element>
<xs:complexType name="pre-processing-commandsType">
<xs:sequence maxOccurs="unbounded">
<xs:element name="delete-jobs-in-group" type="xs:string" minOccurs="0" maxOccurs="unbounded">
<xs:annotation>
<xs:documentation>Delete all jobs, if any, in the identified group. "*" can be used to identify all groups. Will also result in deleting all triggers related to the jobs.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="delete-triggers-in-group" type="xs:string" minOccurs="0" maxOccurs="unbounded">
<xs:annotation>
<xs:documentation>Delete all triggers, if any, in the identified group. "*" can be used to identify all groups. Will also result in deletion of related jobs that are non-durable.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="delete-job" minOccurs="0" maxOccurs="unbounded">
<xs:annotation>
<xs:documentation>Delete the identified job if it exists (will also result in deleting all triggers related to it).</xs:documentation>
</xs:annotation>
<xs:complexType>
<xs:sequence>
<xs:element name="name" type="xs:string" />
<xs:element name="group" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:complexType>
</xs:element>
<xs:element name="delete-trigger" minOccurs="0" maxOccurs="unbounded">
<xs:annotation>
<xs:documentation>Delete the identified trigger if it exists (will also result in deletion of related jobs that are non-durable).</xs:documentation>
</xs:annotation>
<xs:complexType>
<xs:sequence>
<xs:element name="name" type="xs:string" />
<xs:element name="group" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:sequence>
</xs:complexType>
<xs:complexType name="processing-directivesType">
<xs:sequence>
<xs:element name="overwrite-existing-data" type="xs:boolean" minOccurs="0" default="true">
<xs:annotation>
<xs:documentation>Whether the existing scheduling data (with same identifiers) will be overwritten. If false, and ignore-duplicates is not false, and jobs or triggers with the same names already exist as those in the file, an error will occur.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="ignore-duplicates" type="xs:boolean" minOccurs="0" default="false">
<xs:annotation>
<xs:documentation>If true (and overwrite-existing-data is false) then any job/triggers encountered in this file that have names that already exist in the scheduler will be ignored, and no error will be produced.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="schedule-trigger-relative-to-replaced-trigger" type="xs:boolean" minOccurs="0" default="false">
<xs:annotation>
<xs:documentation>If true trigger's start time is calculated based on earlier run time instead of fixed value. Trigger's start time must be undefined for this to work.</xs:documentation>
</xs:annotation>
</xs:element>
</xs:sequence>
</xs:complexType>
<xs:complexType name="job-detailType">
<xs:annotation>
<xs:documentation>Define a JobDetail</xs:documentation>
</xs:annotation>
<xs:sequence>
<xs:element name="name" type="xs:string" />
<xs:element name="group" type="xs:string" minOccurs="0" />
<xs:element name="description" type="xs:string" minOccurs="0" />
<xs:element name="job-type" type="xs:string" />
<xs:sequence minOccurs="0">
<xs:element name="durable" type="xs:boolean" />
<xs:element name="recover" type="xs:boolean" />
</xs:sequence>
<xs:element name="job-data-map" type="job-data-mapType" minOccurs="0" />
</xs:sequence>
</xs:complexType>
<xs:complexType name="job-data-mapType">
<xs:annotation>
<xs:documentation>Define a JobDataMap</xs:documentation>
</xs:annotation>
<xs:sequence minOccurs="0" maxOccurs="unbounded">
<xs:element name="entry" type="entryType" />
</xs:sequence>
</xs:complexType>
<xs:complexType name="entryType">
<xs:annotation>
<xs:documentation>Define a JobDataMap entry</xs:documentation>
</xs:annotation>
<xs:sequence>
<xs:element name="key" type="xs:string" />
<xs:element name="value" type="xs:string" />
</xs:sequence>
</xs:complexType>
<xs:complexType name="triggerType">
<xs:annotation>
<xs:documentation>Define a Trigger</xs:documentation>
</xs:annotation>
<xs:choice>
<xs:element name="simple" type="simpleTriggerType" />
<xs:element name="cron" type="cronTriggerType" />
<xs:element name="calendar-interval" type="calendarIntervalTriggerType" />
</xs:choice>
</xs:complexType>
<xs:complexType name="abstractTriggerType" abstract="true">
<xs:annotation>
<xs:documentation>Common Trigger definitions</xs:documentation>
</xs:annotation>
<xs:sequence>
<xs:element name="name" type="xs:string" />
<xs:element name="group" type="xs:string" minOccurs="0" />
<xs:element name="description" type="xs:string" minOccurs="0" />
<xs:element name="job-name" type="xs:string" />
<xs:element name="job-group" type="xs:string" minOccurs="0" />
<xs:element name="priority" type="xs:nonNegativeInteger" minOccurs="0" />
<xs:element name="calendar-name" type="xs:string" minOccurs="0" />
<xs:element name="job-data-map" type="job-data-mapType" minOccurs="0" />
<xs:sequence minOccurs="0">
<xs:choice>
<xs:element name="start-time" type="xs:dateTime" />
<xs:element name="start-time-seconds-in-future" type="xs:nonNegativeInteger" />
</xs:choice>
<xs:element name="end-time" type="xs:dateTime" minOccurs="0" />
</xs:sequence>
</xs:sequence>
</xs:complexType>
<xs:complexType name="simpleTriggerType">
<xs:annotation>
<xs:documentation>Define a SimpleTrigger</xs:documentation>
</xs:annotation>
<xs:complexContent>
<xs:extension base="abstractTriggerType">
<xs:sequence>
<xs:element name="misfire-instruction" type="simple-trigger-misfire-instructionType" minOccurs="0" />
<xs:sequence minOccurs="0">
<xs:element name="repeat-count" type="repeat-countType" />
<xs:element name="repeat-interval" type="xs:nonNegativeInteger" />
</xs:sequence>
</xs:sequence>
</xs:extension>
</xs:complexContent>
</xs:complexType>
<xs:complexType name="cronTriggerType">
<xs:annotation>
<xs:documentation>Define a CronTrigger</xs:documentation>
</xs:annotation>
<xs:complexContent>
<xs:extension base="abstractTriggerType">
<xs:sequence>
<xs:element name="misfire-instruction" type="cron-trigger-misfire-instructionType" minOccurs="0" />
<xs:element name="cron-expression" type="cron-expressionType" />
<xs:element name="time-zone" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:extension>
</xs:complexContent>
</xs:complexType>
<xs:complexType name="calendarIntervalTriggerType">
<xs:annotation>
<xs:documentation>Define a DateIntervalTrigger</xs:documentation>
</xs:annotation>
<xs:complexContent>
<xs:extension base="abstractTriggerType">
<xs:sequence>
<xs:element name="misfire-instruction" type="date-interval-trigger-misfire-instructionType" minOccurs="0" />
<xs:element name="repeat-interval" type="xs:nonNegativeInteger" />
<xs:element name="repeat-interval-unit" type="interval-unitType" />
</xs:sequence>
</xs:extension>
</xs:complexContent>
</xs:complexType>
<xs:simpleType name="cron-expressionType">
<xs:annotation>
<xs:documentation>
Cron expression (see JavaDoc for examples)
Special thanks to Chris Thatcher (thatcher@butterfly.net) for the regular expression!
Regular expressions are not my strong point but I believe this is complete,
with the caveat that order for expressions like 3-0 is not legal but will pass,
and month and day names must be capitalized.
If you want to examine the correctness look for the [\s] to denote the
seperation of individual regular expressions. This is how I break them up visually
to examine them:
SECONDS:
(
((([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?,)*([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?)
| (([\*]|[0-9]|[0-5][0-9])/([0-9]|[0-5][0-9]))
| ([\?])
| ([\*])
) [\s]
MINUTES:
(
((([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?,)*([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?)
| (([\*]|[0-9]|[0-5][0-9])/([0-9]|[0-5][0-9]))
| ([\?])
| ([\*])
) [\s]
HOURS:
(
((([0-9]|[0-1][0-9]|[2][0-3])(-([0-9]|[0-1][0-9]|[2][0-3]))?,)*([0-9]|[0-1][0-9]|[2][0-3])(-([0-9]|[0-1][0-9]|[2][0-3]))?)
| (([\*]|[0-9]|[0-1][0-9]|[2][0-3])/([0-9]|[0-1][0-9]|[2][0-3]))
| ([\?])
| ([\*])
) [\s]
DAY OF MONTH:
(
((([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(-([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1]))?,)*([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(-([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1]))?(C)?)
| (([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])/([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(C)?)
| (L(-[0-9])?)
| (L(-[1-2][0-9])?)
| (L(-[3][0-1])?)
| (LW)
| ([1-9]W)
| ([1-3][0-9]W)
| ([\?])
| ([\*])
)[\s]
MONTH:
(
((([1-9]|0[1-9]|1[0-2])(-([1-9]|0[1-9]|1[0-2]))?,)*([1-9]|0[1-9]|1[0-2])(-([1-9]|0[1-9]|1[0-2]))?)
| (([1-9]|0[1-9]|1[0-2])/([1-9]|0[1-9]|1[0-2]))
| (((JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)(-(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))?,)*(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)(-(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))?)
| ((JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)/(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))
| ([\?])
| ([\*])
)[\s]
DAY OF WEEK:
(
(([1-7](-([1-7]))?,)*([1-7])(-([1-7]))?)
| ([1-7]/([1-7]))
| (((MON|TUE|WED|THU|FRI|SAT|SUN)(-(MON|TUE|WED|THU|FRI|SAT|SUN))?,)*(MON|TUE|WED|THU|FRI|SAT|SUN)(-(MON|TUE|WED|THU|FRI|SAT|SUN))?(C)?)
| ((MON|TUE|WED|THU|FRI|SAT|SUN)/(MON|TUE|WED|THU|FRI|SAT|SUN)(C)?)
| (([1-7]|(MON|TUE|WED|THU|FRI|SAT|SUN))(L|LW)?)
| (([1-7]|MON|TUE|WED|THU|FRI|SAT|SUN)#([1-7])?)
| ([\?])
| ([\*])
)
YEAR (OPTIONAL):
(
[\s]?
([\*])?
| ((19[7-9][0-9])|(20[0-9][0-9]))?
| (((19[7-9][0-9])|(20[0-9][0-9]))/((19[7-9][0-9])|(20[0-9][0-9])))?
| ((((19[7-9][0-9])|(20[0-9][0-9]))(-((19[7-9][0-9])|(20[0-9][0-9])))?,)*((19[7-9][0-9])|(20[0-9][0-9]))(-((19[7-9][0-9])|(20[0-9][0-9])))?)?
)
</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern
value="(((([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?,)*([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?)|(([\*]|[0-9]|[0-5][0-9])/([0-9]|[0-5][0-9]))|([\?])|([\*]))[\s](((([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?,)*([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?)|(([\*]|[0-9]|[0-5][0-9])/([0-9]|[0-5][0-9]))|([\?])|([\*]))[\s](((([0-9]|[0-1][0-9]|[2][0-3])(-([0-9]|[0-1][0-9]|[2][0-3]))?,)*([0-9]|[0-1][0-9]|[2][0-3])(-([0-9]|[0-1][0-9]|[2][0-3]))?)|(([\*]|[0-9]|[0-1][0-9]|[2][0-3])/([0-9]|[0-1][0-9]|[2][0-3]))|([\?])|([\*]))[\s](((([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(-([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1]))?,)*([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(-([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1]))?(C)?)|(([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])/([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(C)?)|(L(-[0-9])?)|(L(-[1-2][0-9])?)|(L(-[3][0-1])?)|(LW)|([1-9]W)|([1-3][0-9]W)|([\?])|([\*]))[\s](((([1-9]|0[1-9]|1[0-2])(-([1-9]|0[1-9]|1[0-2]))?,)*([1-9]|0[1-9]|1[0-2])(-([1-9]|0[1-9]|1[0-2]))?)|(([1-9]|0[1-9]|1[0-2])/([1-9]|0[1-9]|1[0-2]))|(((JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)(-(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))?,)*(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)(-(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))?)|((JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)/(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))|([\?])|([\*]))[\s]((([1-7](-([1-7]))?,)*([1-7])(-([1-7]))?)|([1-7]/([1-7]))|(((MON|TUE|WED|THU|FRI|SAT|SUN)(-(MON|TUE|WED|THU|FRI|SAT|SUN))?,)*(MON|TUE|WED|THU|FRI|SAT|SUN)(-(MON|TUE|WED|THU|FRI|SAT|SUN))?(C)?)|((MON|TUE|WED|THU|FRI|SAT|SUN)/(MON|TUE|WED|THU|FRI|SAT|SUN)(C)?)|(([1-7]|(MON|TUE|WED|THU|FRI|SAT|SUN))?(L|LW)?)|(([1-7]|MON|TUE|WED|THU|FRI|SAT|SUN)#([1-7])?)|([\?])|([\*]))([\s]?(([\*])?|(19[7-9][0-9])|(20[0-9][0-9]))?| (((19[7-9][0-9])|(20[0-9][0-9]))/((19[7-9][0-9])|(20[0-9][0-9])))?| ((((19[7-9][0-9])|(20[0-9][0-9]))(-((19[7-9][0-9])|(20[0-9][0-9])))?,)*((19[7-9][0-9])|(20[0-9][0-9]))(-((19[7-9][0-9])|(20[0-9][0-9])))?)?)" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="repeat-countType">
<xs:annotation>
<xs:documentation>Number of times to repeat the Trigger (-1 for indefinite)</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:integer">
<xs:minInclusive value="-1" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="simple-trigger-misfire-instructionType">
<xs:annotation>
<xs:documentation>Simple Trigger Misfire Instructions</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern value="SmartPolicy" />
<xs:pattern value="RescheduleNextWithExistingCount" />
<xs:pattern value="RescheduleNextWithRemainingCount" />
<xs:pattern value="RescheduleNowWithExistingRepeatCount" />
<xs:pattern value="RescheduleNowWithRemainingRepeatCount" />
<xs:pattern value="FireNow" />
<xs:pattern value="IgnoreMisfirePolicy" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="cron-trigger-misfire-instructionType">
<xs:annotation>
<xs:documentation>Cron Trigger Misfire Instructions</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern value="SmartPolicy" />
<xs:pattern value="DoNothing" />
<xs:pattern value="FireOnceNow" />
<xs:pattern value="IgnoreMisfirePolicy" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="date-interval-trigger-misfire-instructionType">
<xs:annotation>
<xs:documentation>Date Interval Trigger Misfire Instructions</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern value="SmartPolicy" />
<xs:pattern value="DoNothing" />
<xs:pattern value="FireOnceNow" />
<xs:pattern value="IgnoreMisfirePolicy" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="interval-unitType">
<xs:annotation>
<xs:documentation>Interval Units</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern value="Day" />
<xs:pattern value="Hour" />
<xs:pattern value="Minute" />
<xs:pattern value="Month" />
<xs:pattern value="Second" />
<xs:pattern value="Week" />
<xs:pattern value="Year" />
</xs:restriction>
</xs:simpleType>
</xs:schema>

9
BcCenter/BcCenter.Common/packages.config
Unescape Escape View File

@ -0,0 +1,9 @@
<?xml version="1.0" encoding="utf-8"?>
<packages>
<package id="Common.Logging" version="3.3.1" targetFramework="net461" />
<package id="Common.Logging.Core" version="3.3.1" targetFramework="net461" />
<package id="EntityFramework" version="6.4.4" targetFramework="net461" />
<package id="log4net" version="2.0.14" targetFramework="net461" />
<package id="Newtonsoft.Json" version="13.0.1" targetFramework="net461" />
<package id="Quartz" version="2.6.2" targetFramework="net461" />
</packages>

37
BcCenter/BcCenter.Service/App.config
Unescape Escape View File

@ -0,0 +1,37 @@
<?xml version="1.0" encoding="utf-8"?>
<configuration>
<configSections>
<!-- For more information on Entity Framework configuration, visit http://go.microsoft.com/fwlink/?LinkID=237468 -->
<section name="entityFramework" type="System.Data.Entity.Internal.ConfigFile.EntityFrameworkSection, EntityFramework, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" requirePermission="false" />
</configSections>
<appSettings>
<!-- 服务的名称、显示名称 -->
<add key="ServiceName" value="MyshppingBcCenterService" />
<add key="ServiceDisplayName" value="大简云-BC中心服务" />
<!-- 下载文件服务器地址 -->
<add key="FileDownloadUrl" value="http://www.myshipping.net:8660/" />
<!-- 邮件文件存放路径 -->
<add key="EmlSavePath" value="" />
<!-- 钉钉推送webhook地址 -->
<add key="DingTalkWebhookUrl" value="https://oapi.dingtalk.com/robot/send?access_token=ad9ab0ac215e9f88e3217e96c2e3af0064fd7ec9cb4bf25dfe6cacf0b8348353" />
<add key="DingTalkWebhookKeywords" value="BC中心" />
<!-- 邮件发送服务地址 -->
<add key="MailSendServiceUrl" value="" />
</appSettings>
<connectionStrings>
<!--本地开发 -->
<add name="DongShengDB" connectionString="Data Source=192.168.0.80;Initial Catalog=myshipping;Persist Security Info=True;User ID=sa;Password=sa123" providerName="System.Data.SqlClient" />
<add name="BcCenterDB" connectionString="Data Source=192.168.0.80;Initial Catalog=BcCenterDB;Persist Security Info=True;User ID=sa;Password=sa123" providerName="System.Data.SqlClient" />
</connectionStrings>
<startup>
<supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.6.1" />
</startup>
<entityFramework>
<providers>
<provider invariantName="System.Data.SqlClient" type="System.Data.Entity.SqlServer.SqlProviderServices, EntityFramework.SqlServer" />
</providers>
</entityFramework>
</configuration>

123
BcCenter/BcCenter.Service/BcCenter.Service.csproj
Unescape Escape View File

@ -0,0 +1,123 @@
<?xml version="1.0" encoding="utf-8"?>
<Project ToolsVersion="15.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<Import Project="..\packages\EntityFramework.6.4.4\build\EntityFramework.props" Condition="Exists('..\packages\EntityFramework.6.4.4\build\EntityFramework.props')" />
<Import Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props" Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')" />
<PropertyGroup>
<Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
<Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
<ProjectGuid>{3A539117-F2B7-4B78-8849-48DE29370F09}</ProjectGuid>
<OutputType>Exe</OutputType>
<RootNamespace>BcCenter.Service</RootNamespace>
<AssemblyName>BcCenter.Service</AssemblyName>
<TargetFrameworkVersion>v4.6.1</TargetFrameworkVersion>
<FileAlignment>512</FileAlignment>
<AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
<Deterministic>true</Deterministic>
<NuGetPackageImportStamp>
</NuGetPackageImportStamp>
</PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
<PlatformTarget>AnyCPU</PlatformTarget>
<DebugSymbols>true</DebugSymbols>
<DebugType>full</DebugType>
<Optimize>false</Optimize>
<OutputPath>bin\Debug\</OutputPath>
<DefineConstants>DEBUG;TRACE</DefineConstants>
<ErrorReport>prompt</ErrorReport>
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
<PlatformTarget>AnyCPU</PlatformTarget>
<DebugType>pdbonly</DebugType>
<Optimize>true</Optimize>
<OutputPath>bin\Release\</OutputPath>
<DefineConstants>TRACE</DefineConstants>
<ErrorReport>prompt</ErrorReport>
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<ItemGroup>
<Reference Include="BouncyCastle.Crypto, Version=1.9.0.0, Culture=neutral, PublicKeyToken=0e99375e54769942, processorArchitecture=MSIL">
<HintPath>..\packages\Portable.BouncyCastle.1.9.0\lib\net40\BouncyCastle.Crypto.dll</HintPath>
</Reference>
<Reference Include="Common.Logging, Version=3.3.1.0, Culture=neutral, PublicKeyToken=af08829b84f0328e, processorArchitecture=MSIL">
<HintPath>..\packages\Common.Logging.3.3.1\lib\net40\Common.Logging.dll</HintPath>
</Reference>
<Reference Include="Common.Logging.Core, Version=3.3.1.0, Culture=neutral, PublicKeyToken=af08829b84f0328e, processorArchitecture=MSIL">
<HintPath>..\packages\Common.Logging.Core.3.3.1\lib\net40\Common.Logging.Core.dll</HintPath>
</Reference>
<Reference Include="EntityFramework, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089, processorArchitecture=MSIL">
<HintPath>..\packages\EntityFramework.6.4.4\lib\net45\EntityFramework.dll</HintPath>
</Reference>
<Reference Include="EntityFramework.SqlServer, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089, processorArchitecture=MSIL">
<HintPath>..\packages\EntityFramework.6.4.4\lib\net45\EntityFramework.SqlServer.dll</HintPath>
</Reference>
<Reference Include="log4net, Version=2.0.14.0, Culture=neutral, PublicKeyToken=669e0ddf0bb1aa2a, processorArchitecture=MSIL">
<HintPath>..\packages\log4net.2.0.14\lib\net45\log4net.dll</HintPath>
</Reference>
<Reference Include="MailKit, Version=3.1.0.0, Culture=neutral, PublicKeyToken=4e064fe7c44a8f1b, processorArchitecture=MSIL">
<HintPath>..\packages\MailKit.3.1.1\lib\net46\MailKit.dll</HintPath>
</Reference>
<Reference Include="MimeKit, Version=3.1.0.0, Culture=neutral, PublicKeyToken=bede1c8a46c66814, processorArchitecture=MSIL">
<HintPath>..\packages\MimeKit.3.1.1\lib\net46\MimeKit.dll</HintPath>
</Reference>
<Reference Include="Newtonsoft.Json, Version=13.0.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
<HintPath>..\packages\Newtonsoft.Json.13.0.1\lib\net45\Newtonsoft.Json.dll</HintPath>
</Reference>
<Reference Include="Quartz, Version=2.6.2.0, Culture=neutral, PublicKeyToken=f6b8c98a402cc8a4, processorArchitecture=MSIL">
<HintPath>..\packages\Quartz.2.6.2\lib\net40\Quartz.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Buffers, Version=4.0.3.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
<HintPath>..\packages\System.Buffers.4.5.1\lib\net461\System.Buffers.dll</HintPath>
</Reference>
<Reference Include="System.ComponentModel.DataAnnotations" />
<Reference Include="System.Configuration" />
<Reference Include="System.Configuration.Install" />
<Reference Include="System.Core" />
<Reference Include="System.Runtime.Caching" />
<Reference Include="System.Security" />
<Reference Include="System.ServiceProcess" />
<Reference Include="System.Web" />
<Reference Include="System.Xml.Linq" />
<Reference Include="System.Data.DataSetExtensions" />
<Reference Include="Microsoft.CSharp" />
<Reference Include="System.Data" />
<Reference Include="System.Net.Http" />
<Reference Include="System.Xml" />
<Reference Include="Topshelf, Version=4.2.1.215, Culture=neutral, PublicKeyToken=b800c4cfcdeea87b, processorArchitecture=MSIL">
<HintPath>..\packages\Topshelf.4.2.1\lib\net452\Topshelf.dll</HintPath>
</Reference>
</ItemGroup>
<ItemGroup>
<Compile Include="MailJobService.cs" />
<Compile Include="Program.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="ReceiveJob.cs" />
<Compile Include="SchedulerJob.cs" />
</ItemGroup>
<ItemGroup>
<None Include="App.config" />
<None Include="job_scheduling_data_2_0.xsd">
<SubType>Designer</SubType>
</None>
<None Include="packages.config" />
</ItemGroup>
<ItemGroup>
<Content Include="quartz_jobs.xml" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\BcCenter.Common\BcCenter.Common.csproj">
<Project>{d26a3df4-4f5b-4b40-8723-2b9477e754a1}</Project>
<Name>BcCenter.Common</Name>
</ProjectReference>
</ItemGroup>
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
<Target Name="EnsureNuGetPackageBuildImports" BeforeTargets="PrepareForBuild">
<PropertyGroup>
<ErrorText>这台计算机上缺少此项目引用的 NuGet 程序包。使用“NuGet 程序包还原”可下载这些程序包。有关更多信息，请参见 http://go.microsoft.com/fwlink/?LinkID=322105。缺少的文件是 {0}。</ErrorText>
</PropertyGroup>
<Error Condition="!Exists('..\packages\EntityFramework.6.4.4\build\EntityFramework.props')" Text="$([System.String]::Format('$(ErrorText)', '..\packages\EntityFramework.6.4.4\build\EntityFramework.props'))" />
<Error Condition="!Exists('..\packages\EntityFramework.6.4.4\build\EntityFramework.targets')" Text="$([System.String]::Format('$(ErrorText)', '..\packages\EntityFramework.6.4.4\build\EntityFramework.targets'))" />
</Target>
<Import Project="..\packages\EntityFramework.6.4.4\build\EntityFramework.targets" Condition="Exists('..\packages\EntityFramework.6.4.4\build\EntityFramework.targets')" />
</Project>

52
BcCenter/BcCenter.Service/MailJobService.cs
Unescape Escape View File

@ -0,0 +1,52 @@
using BcCenter.Common;
using log4net;
using Quartz;
using Quartz.Impl;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Topshelf;
namespace BcCenter.Service
{
public class MailJobService : ServiceControl
{
private static ILog logger = LogManager.GetLogger("MailJobService");
private IScheduler scheduler;
public bool Start(HostControl hostControl)
{
// 开始具体的业务逻辑
logger.Debug("开始运行");
try
{
scheduler = StdSchedulerFactory.GetDefaultScheduler();
scheduler.ListenerManager.AddSchedulerListener(new JobListener());
scheduler.Start();
}
catch (Exception ex)
{
logger.Error("启动出错：");
logger.Error(ex.Message);
logger.Error(ex.StackTrace);
}
return true;
}
public bool Stop(HostControl hostControl)
{
// 结束
logger.Debug("停止运行");
scheduler.Shutdown();
return true;
}
}
}

15
BcCenter/BcCenter.Service/Program.cs
Unescape Escape View File

@ -0,0 +1,15 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace BcCenter.Service
{
class Program
{
static void Main(string[] args)
{
}
}
}

36
BcCenter/BcCenter.Service/Properties/AssemblyInfo.cs
Unescape Escape View File

@ -0,0 +1,36 @@
using System.Reflection;
using System.Runtime.CompilerServices;
using System.Runtime.InteropServices;
// 有关程序集的一般信息由以下
// 控制。更改这些特性值可修改
// 与程序集关联的信息。
[assembly: AssemblyTitle("BcCenter.Service")]
[assembly: AssemblyDescription("")]
[assembly: AssemblyConfiguration("")]
[assembly: AssemblyCompany("")]
[assembly: AssemblyProduct("BcCenter.Service")]
[assembly: AssemblyCopyright("Copyright © 2022")]
[assembly: AssemblyTrademark("")]
[assembly: AssemblyCulture("")]
// 将 ComVisible 设置为 false 会使此程序集中的类型
//对 COM 组件不可见。如果需要从 COM 访问此程序集中的类型
//请将此类型的 ComVisible 特性设置为 true。
[assembly: ComVisible(false)]
// 如果此项目向 COM 公开，则下列 GUID 用于类型库的 ID
[assembly: Guid("3a539117-f2b7-4b78-8849-48de29370f09")]
// 程序集的版本信息由下列四个值组成:
//
// 主版本
// 次版本
// 生成号
// 修订号
//
//可以指定所有这些值，也可以使用“生成号”和“修订号”的默认值
//通过使用 "*"，如下所示:
// [assembly: AssemblyVersion("1.0.*")]
[assembly: AssemblyVersion("1.0.0.0")]
[assembly: AssemblyFileVersion("1.0.0.0")]

424
BcCenter/BcCenter.Service/ReceiveJob.cs
Unescape Escape View File

@ -0,0 +1,424 @@

using log4net;
using MailKit;
using MailKit.Net.Imap;
using MailKit.Search;
using MimeKit;
using Quartz;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Runtime.Caching;
using System.Text.RegularExpressions;
using MimeKit.Utils;
using MailKit.Security;
using System.Configuration;
using System.Security.Cryptography;
using MimeKit.Encodings;
using BcCenter.Common.DB;
using BcCenter.Common.Helper;
namespace BcCenter.Service
{
public class ReceiveJob : IJob
{
ILog log = LogManager.GetLogger(typeof(ReceiveJob));
private const string KeyRecMail = "RecMail_";
private static string EmlSavePath = ConfigurationManager.AppSettings["EmlSavePath"];
private static string fileDownloadUrl = ConfigurationManager.AppSettings["FileDownloadUrl"];
public void Execute(IJobExecutionContext context)
{
try
{
string account = context.JobDetail.JobDataMap.GetString("Account");
string password = context.JobDetail.JobDataMap.GetString("Password");
string imapServer = context.JobDetail.JobDataMap.GetString("ImapServer");
int imapPort = context.JobDetail.JobDataMap.GetInt("ImapPort");
bool imapSSL = context.JobDetail.JobDataMap.GetBoolean("ImapSSL");
string smtpServer = context.JobDetail.JobDataMap.GetString("SmtpServer");
int stmpPort = context.JobDetail.JobDataMap.GetInt("SmtpPort");
bool smtpSSL = context.JobDetail.JobDataMap.GetBoolean("SmtpSSL");
if (!fileDownloadUrl.EndsWith("/"))
{
fileDownloadUrl += "/";
}
string keyMem = KeyRecMail + account;
if (MemoryCache.Default.Contains(keyMem))
{
log.Debug($"其他线程正收取邮件：{account}");
return;
}
MemoryCache.Default.Add(new CacheItem(keyMem, true), new CacheItemPolicy() { AbsoluteExpiration = DateTime.Now.AddMinutes(2) });
log.Debug($"正在收取邮箱{account}的邮件……");
DateTime mailDate = DateTime.Today;
//DateTime mailDate = DateTime.Parse("2019-06-10");
using (var imapClient = new ImapClient())
{
imapClient.ServerCertificateValidationCallback = (s, c, h, e) => true;
log.Debug($"正在连接邮件服务器：{imapServer}:{imapPort},SSL:{imapSSL}");
imapClient.Connect(imapServer, imapPort, imapSSL ? SecureSocketOptions.SslOnConnect : SecureSocketOptions.None);
log.Debug($"正在登录邮件服务器，账号:{account}");
imapClient.Authenticate(account, password);
var inbox = imapClient.Inbox;
inbox.Open(FolderAccess.ReadOnly);
var uids = inbox.Search(SearchQuery.DeliveredAfter(mailDate.AddDays(-1)));
log.Debug($"{account}邮件数量：{uids.Count}");
string savePath = string.Empty;
if (!string.IsNullOrEmpty(EmlSavePath))
{
savePath = Path.Combine(EmlSavePath, $"BillCenter\\{mailDate.ToString("yyyyMMdd")}\\{account}");
}
else
{
savePath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, $"BillCenter\\{mailDate.ToString("yyyyMMdd")}\\{account}");
}
if (!Directory.Exists(savePath))
{
Directory.CreateDirectory(savePath);
}
//找最大ID
long maxId = 0;
CommonDataContext commonData = new CommonDataContext();
BcCenterDataContext billCenterData = new BcCenterDataContext();
var mc = billCenterData.Mails.Count(r => r.MailAccount == account);
if (mc > 0)
{
maxId = billCenterData.Mails.Where(r => r.MailAccount == account).Max(r => r.ImapId);
uids = uids.Where(u => u.Id > maxId).ToList();
}
log.Debug($"{account}开始下载邮件");
int recCount = 0;
foreach (var uid in uids)
{
var c = billCenterData.Mails.Count(r => r.MailAccount == account && r.ImapId == uid.Id);
if (c > 0)
{
continue; //忽略
}
var headers = inbox.GetHeaders(uid);
var messageId = headers[HeaderId.MessageId];
var sendUser = headers[HeaderId.From];
var suject = headers[HeaderId.Subject];
var idxStart = sendUser.IndexOf("<");
var idxEnd = sendUser.IndexOf(">");
if (idxStart > -1 && idxEnd > -1)
{
sendUser = sendUser.Substring(idxStart + 1, idxEnd - idxStart - 1);
}
//判断发件人是否合法
var qUser = from ub in commonData.UserBases.AsNoTracking()
join u in commonData.Users.AsNoTracking() on ub.USERID equals u.GID
join comp in commonData.CompanyNew.AsNoTracking() on u.CompId equals comp.CompId
where ub.EMAIL1 == sendUser
select new { u.GID, u.SHOWNAME, comp.CompId, comp.CompName };
var usrObj = qUser.FirstOrDefault();
if (usrObj == null)
{
//发回复邮件，提醒注册大简云
log.Debug($"发送人邮箱{sendUser}未注册大简云");
MailHelper.SendMailService("账单未处理提醒", "当前邮箱未注册大简云，请联系客服注册后再试。", sendUser);
}
try
{
var recInfo = new Mails();
recInfo.GID = Guid.NewGuid().ToString();
recInfo.MailAccount = account;
recInfo.ImapId = (int)uid.Id;
recInfo.MailId = messageId;
recInfo.EmailDate = mailDate;
recInfo.SourceType = Mails.SourceTypeMail;
if (usrObj != null)
{
recInfo.UserId = usrObj.GID;
recInfo.UserName = usrObj.SHOWNAME;
recInfo.CompId = usrObj.CompId;
recInfo.CompName = usrObj.CompName;
recInfo.Status = "Ready";
}
else
{
recInfo.UserId = string.Empty;
recInfo.UserName = string.Empty;
recInfo.CompId = string.Empty;
recInfo.CompName = string.Empty;
recInfo.Status = "Fail";
}
recInfo.SendUserMail = sendUser;
recInfo.ReceiveTime = DateTime.Now;
recInfo.MailSubject = suject;
var listAtt = new List<Attachments>();
if (usrObj != null) //没有注册的不拉取邮件和附件
{
var mailGuid = Guid.NewGuid().ToString();
string emlSavePath = Path.Combine(savePath, $"{mailGuid}.eml");
var message = inbox.GetMessage(uid);
message.WriteTo(emlSavePath);
recInfo.MailPath = emlSavePath;
recInfo.MailUrl = $"{fileDownloadUrl}bill/GetMailFile?id={recInfo.GID}";
recInfo.MailDate = message.Date.ToLocalTime().DateTime;
//附件存放路径
var attPath = Path.Combine(savePath, $"{recInfo.ImapId}");
if (!Directory.Exists(attPath))
{
Directory.CreateDirectory(attPath);
}
//解析附件
ParseAttach(message, attPath, recInfo, listAtt);
var listErr = new List<string>();
//校验文件MD5存在
foreach (var att in listAtt)
{
if (att.Status != "Ready") //已处理过，不重复处理
{
continue;
}
var attInfo = billCenterData.Attachments.AsNoTracking().FirstOrDefault(aa => aa.AttachMD5 == att.AttachMD5);
if (attInfo != null)
{
var mail = billCenterData.Mails.AsNoTracking().First(mm => mm.GID == attInfo.MailGID);
var errMsg = " <tr>" +
$" <td style=\"border:1px solid gray;padding:5px;\">{att.AttachName}</td>" +
$" <td style=\"border:1px solid gray;padding:5px;\">{mail.SendUserMail}</td>" +
$" <td style=\"border:1px solid gray;padding:5px;\">{mail.ReceiveTime}</td>" +
$" <td style=\"border:1px solid gray;padding:5px;\">{mail.MailSubject}</td>" +
" </tr>";
listErr.Add(errMsg);
att.Status = "Repeat";
att.Tips = $"文件重复发送：{mail.SendUserMail} 在 {mail.ReceiveTime} 发送过此文件";
}
else
{
//2022-1-21，解决同一封邮件中同个附件重复问题的处理
var tmpList = listAtt.Where(x => x.AttachMD5 == att.AttachMD5).ToList();
if (tmpList.Count > 1)
{
for (var idx = 1; idx < tmpList.Count; idx++)
{
tmpList[idx].Status = "Repeat";
tmpList[idx].Tips = $"文件重复发送：在同一封邮件中";
}
}
}
}
if (listErr.Count > 0)
{
var str = string.Join("", listErr);
var strTable = "<table style=\"border:1px solid gray;border-collapse:collapse;\"> " +
" <thead>" +
" <tr>" +
" <th style=\"border:1px solid gray;padding:5px;\">文件名称</th>" +
" <th style=\"border:1px solid gray;padding:5px;\">上次发送人</th>" +
" <th style=\"border:1px solid gray;padding:5px;\">上次发送时间</th>" +
" <th style=\"border:1px solid gray;padding:5px;\">上次发件标题</th>" +
" </tr>" +
" </thead>" +
" <tbody>";
var strTableEnd = " </tbody>" +
"</table>";
str = $@"{strTable}{str}{strTableEnd}";
log.Debug($"附件重复发送：\r\n{str}");
MailHelper.SendMailService("账单未处理提醒：文件重复发送", str.Replace("\r\n", "<br/>"), sendUser);
}
}
else
{
recInfo.MailPath = string.Empty;
}
billCenterData.Mails.Add(recInfo);
billCenterData.Attachments.AddRange(listAtt);
billCenterData.SaveChanges(); //立即保存
log.Debug($"{account}已下载邮件，ID：{uid} 标题：{suject} 发送者：{sendUser}");
recCount++;
}
catch (Exception ex)
{
log.Error($"{account}收取邮件时，发生严重错误({uid})：");
var exp = ex;
while (exp != null)
{
log.Error(exp.Message);
log.Error(exp.StackTrace);
exp = exp.InnerException;
}
}
//2021-9-14，每封邮件置标志状态，防止单次设置10分钟收件未完成，第二个线程重复收取
if (MemoryCache.Default.Contains(keyMem))
{
MemoryCache.Default.Remove(keyMem);
}
MemoryCache.Default.Add(new CacheItem(keyMem, true), new CacheItemPolicy() { AbsoluteExpiration = DateTime.Now.AddMinutes(2) });
}
log.Debug($"{account}下载邮件完成，共{recCount}封");
inbox.Close();
imapClient.Disconnect(true);
}
MemoryCache.Default.Remove(keyMem);
}
catch (Exception ex)
{
log.Error($"收取邮件出错：{ex.Message}");
log.Error($"{ex.StackTrace}");
}
}
private void ParseAttach(MimeMessage message, string attPath, Mails parent, List<Attachments> listAtt)
{
//解析附件
foreach (var att in message.Attachments)
{
MimePart attPart = att as MimePart;
if (attPart != null && attPart.IsAttachment)
{
var attName = att.ContentType.Name;
var attExt = Path.GetExtension(attName);
//eml文件继续解析处理
if (attExt.ToLower() == ".eml")
{
//todo:
MemoryStream msMail = new MemoryStream();
att.WriteTo(msMail, true);
msMail.Position = 0;
StreamReader readerMail = new StreamReader(msMail);
var strB64Mail = readerMail.ReadToEnd();
var bsArrAtt = Convert.FromBase64String(strB64Mail);
msMail.Close();
msMail = new MemoryStream(bsArrAtt);
var attMail = MimeMessage.Load(msMail);
ParseAttach(attMail, attPath, parent, listAtt);
continue;
}
var attSaveName = Guid.NewGuid().ToString() + attExt;
Attachments attach = new Attachments();
attach.GID = Guid.NewGuid().ToString();
attach.MailGID = parent.GID;
attach.MailID = parent.MailId;
attach.CreateTime = DateTime.Now;
attach.AttachName = attName;
attach.FileType = attExt;
attach.Status = "Ready";
string attSavePath = Path.Combine(attPath, attSaveName);
MemoryStream ms = new MemoryStream();
att.WriteTo(ms, true);
ms.Position = 0;
StreamReader reader = new StreamReader(ms);
var strB64 = reader.ReadToEnd();
if (att.ContentType.MediaType == "application" || att.ContentType.MediaType == "binary")
{
var bsArrAtt = Convert.FromBase64String(strB64);
File.WriteAllBytes(attSavePath, bsArrAtt);
}
else if (att.ContentType.MediaType == "text")
{
File.WriteAllText(attSavePath, strB64);
}
else
{
log.Error($"未知附件类型:{att.ContentType.MediaType} {att.ContentType.MediaSubtype}");
attach.Status = "Fail";
attach.Tips = "未知附件类型";
}
attach.AttachMD5 = GetMD5HashFromFile(attSavePath);
attach.AttachPath = attSavePath;
attach.AttachUrl = $"{fileDownloadUrl}bill/GetAttFile?id={attach.GID}";
listAtt.Add(attach);
}
}
}
public string GetMD5HashFromBytes(byte[] arr)
{
try
{
MD5 md5 = new MD5CryptoServiceProvider();
byte[] retVal = md5.ComputeHash(arr);
StringBuilder sb = new StringBuilder();
for (int i = 0; i < retVal.Length; i++)
{
sb.Append(retVal[i].ToString("x2"));
}
return sb.ToString();
}
catch (Exception ex)
{
log.Error("计算文件MD5错误");
log.Error(ex.Message);
log.Error(ex.StackTrace);
throw new Exception("GetMD5HashFromFile() fail,error:" + ex.Message);
}
}
public string GetMD5HashFromFile(string fileName)
{
try
{
FileStream file = new FileStream(fileName, System.IO.FileMode.Open);
MD5 md5 = new MD5CryptoServiceProvider();
byte[] retVal = md5.ComputeHash(file);
file.Close();
StringBuilder sb = new StringBuilder();
for (int i = 0; i < retVal.Length; i++)
{
sb.Append(retVal[i].ToString("x2"));
}
return sb.ToString();
}
catch (Exception ex)
{
throw new Exception("GetMD5HashFromFile() fail,error:" + ex.Message);
}
}
}
}

130
BcCenter/BcCenter.Service/SchedulerJob.cs
Unescape Escape View File

@ -0,0 +1,130 @@
using BcCenter.Common.DB;
using log4net;
using Quartz;
using Quartz.Impl.Matchers;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Caching;
using System.Text;
namespace BcCenter.Service
{
public class SchedulerJob : IJob
{
private static readonly string MailGroup = "Mail";
ILog log = LogManager.GetLogger(typeof(SchedulerJob));
public void Execute(IJobExecutionContext context)
{
try
{
int getMailInterval = context.JobDetail.JobDataMap.GetInt("GetMailIntervalMinutes");
BcCenterDataContext mailData = new BcCenterDataContext();
List<MailUserAccount> listAccounts = null;
if (MemoryCache.Default.Contains("FirstRun"))
{
listAccounts = mailData.UserAccounts.Where(u => u.IsChanged).ToList();
log.Debug($"******发现修改的邮箱{listAccounts.Count}个");
}
else
{
MemoryCache.Default.Add(new CacheItem("FirstRun", true), new CacheItemPolicy() { Priority = CacheItemPriority.NotRemovable });
listAccounts = mailData.UserAccounts.ToList();
log.Debug($"******启动调度，待处理邮箱{listAccounts.Count}个");
}
int delay = 0;
foreach (var ua in listAccounts)
{
#region 先删除已存在的调度
JobKey jobFind = new JobKey($"JobGetMail_{ua.MailAccount}", MailGroup);
var job = context.Scheduler.GetJobDetail(jobFind);
if (job != null)
{
bool success = context.Scheduler.DeleteJob(jobFind);
log.Debug($">>>>>删除邮箱{ua.MailAccount}的获取邮件任务 {(success ? "成功" : "失败")}");
}
#endregion
Dictionary<IJobDetail, Quartz.Collection.ISet<ITrigger>> dicJob = new Dictionary<IJobDetail, Quartz.Collection.ISet<ITrigger>>();
#region 收取邮件调度
if (ua.UseImap)
{
log.Debug($"******新增邮箱{ua.MailAccount}的获取邮件任务调度");
IJobDetail jobGetMail = JobBuilder.Create<ReceiveJob>()
.WithIdentity($"JobGetMail_{ua.MailAccount}", MailGroup)
.UsingJobData("Account", ua.MailAccount)
.UsingJobData("Password", ua.Password)
.UsingJobData("ImapServer", ua.ReceiveServer)
.UsingJobData("ImapPort", ua.ReceivePort)
.UsingJobData("ImapSSL", ua.ReceiveSSL)
.UsingJobData("SmtpServer", ua.SmtpServer)
.UsingJobData("SmtpPort", ua.SmtpPort)
.UsingJobData("SmtpSSL", ua.SmtpSSL)
.Build();
ISimpleTrigger triGetMail = (ISimpleTrigger)TriggerBuilder.Create()
.WithIdentity($"TrigGetMail_{ua.MailAccount}", MailGroup)
.StartAt(DateTime.UtcNow.AddSeconds(delay++))
.WithSimpleSchedule(x => x.WithIntervalInMinutes(getMailInterval).RepeatForever())
.Build();
Quartz.Collection.HashSet<ITrigger> hsTriger = new Quartz.Collection.HashSet<ITrigger>();
hsTriger.Add(triGetMail);
dicJob.Add(jobGetMail, hsTriger);
}
//else
//{
// log.Debug($"******新增邮箱{ua.MailAccount}的获取邮件任务调度");
// IJobDetail jobGetMail = JobBuilder.Create<ReceivePopJob>()
// .WithIdentity($"JobGetMail_{ua.MailAccount}", MailGroup)
// .UsingJobData("Account", ua.MailAccount)
// .UsingJobData("Password", ua.Password)
// .UsingJobData("PopServer", ua.ReceiveServer)
// .UsingJobData("PopPort", ua.ReceivePort)
// .UsingJobData("PopSSL", ua.ReceiveSSL)
// .Build();
// ISimpleTrigger triGetMail = (ISimpleTrigger)TriggerBuilder.Create()
// .WithIdentity($"TrigGetMail_{ua.MailAccount}", MailGroup)
// .StartAt(DateTime.UtcNow.AddSeconds(delay++))
// .WithSimpleSchedule(x => x.WithIntervalInMinutes(getMailInterval).RepeatForever())
// .Build();
// Quartz.Collection.HashSet<ITrigger> hsTriger = new Quartz.Collection.HashSet<ITrigger>();
// hsTriger.Add(triGetMail);
// dicJob.Add(jobGetMail, hsTriger);
//}
#endregion
context.Scheduler.ScheduleJobs(dicJob, true);
ua.IsChanged = false;
mailData.SaveChanges();
}
}
catch (Exception ex)
{
log.Error($"处理调度任务出错：{ex.Message}");
log.Error($"{ex.StackTrace}");
Exception exTmp = ex.InnerException;
while (exTmp != null)
{
log.Error($"{exTmp.Message}");
log.Error($"{exTmp.StackTrace}");
exTmp = exTmp.InnerException;
}
}
}
}
}

364
BcCenter/BcCenter.Service/job_scheduling_data_2_0.xsd
Unescape Escape View File

@ -0,0 +1,364 @@
<?xml version="1.0" encoding="UTF-8"?>
<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema"
xmlns="http://quartznet.sourceforge.net/JobSchedulingData"
targetNamespace="http://quartznet.sourceforge.net/JobSchedulingData"
elementFormDefault="qualified"
version="2.0">
<xs:element name="job-scheduling-data">
<xs:annotation>
<xs:documentation>Root level node</xs:documentation>
</xs:annotation>
<xs:complexType>
<xs:sequence maxOccurs="unbounded">
<xs:element name="pre-processing-commands" type="pre-processing-commandsType" minOccurs="0" maxOccurs="1">
<xs:annotation>
<xs:documentation>Commands to be executed before scheduling the jobs and triggers in this file.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="processing-directives" type="processing-directivesType" minOccurs="0" maxOccurs="1">
<xs:annotation>
<xs:documentation>Directives to be followed while scheduling the jobs and triggers in this file.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="schedule" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:sequence maxOccurs="unbounded">
<xs:element name="job" type="job-detailType" minOccurs="0" maxOccurs="unbounded" />
<xs:element name="trigger" type="triggerType" minOccurs="0" maxOccurs="unbounded" />
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:sequence>
<xs:attribute name="version" type="xs:string">
<xs:annotation>
<xs:documentation>Version of the XML Schema instance</xs:documentation>
</xs:annotation>
</xs:attribute>
</xs:complexType>
</xs:element>
<xs:complexType name="pre-processing-commandsType">
<xs:sequence maxOccurs="unbounded">
<xs:element name="delete-jobs-in-group" type="xs:string" minOccurs="0" maxOccurs="unbounded">
<xs:annotation>
<xs:documentation>Delete all jobs, if any, in the identified group. "*" can be used to identify all groups. Will also result in deleting all triggers related to the jobs.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="delete-triggers-in-group" type="xs:string" minOccurs="0" maxOccurs="unbounded">
<xs:annotation>
<xs:documentation>Delete all triggers, if any, in the identified group. "*" can be used to identify all groups. Will also result in deletion of related jobs that are non-durable.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="delete-job" minOccurs="0" maxOccurs="unbounded">
<xs:annotation>
<xs:documentation>Delete the identified job if it exists (will also result in deleting all triggers related to it).</xs:documentation>
</xs:annotation>
<xs:complexType>
<xs:sequence>
<xs:element name="name" type="xs:string" />
<xs:element name="group" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:complexType>
</xs:element>
<xs:element name="delete-trigger" minOccurs="0" maxOccurs="unbounded">
<xs:annotation>
<xs:documentation>Delete the identified trigger if it exists (will also result in deletion of related jobs that are non-durable).</xs:documentation>
</xs:annotation>
<xs:complexType>
<xs:sequence>
<xs:element name="name" type="xs:string" />
<xs:element name="group" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:sequence>
</xs:complexType>
<xs:complexType name="processing-directivesType">
<xs:sequence>
<xs:element name="overwrite-existing-data" type="xs:boolean" minOccurs="0" default="true">
<xs:annotation>
<xs:documentation>Whether the existing scheduling data (with same identifiers) will be overwritten. If false, and ignore-duplicates is not false, and jobs or triggers with the same names already exist as those in the file, an error will occur.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="ignore-duplicates" type="xs:boolean" minOccurs="0" default="false">
<xs:annotation>
<xs:documentation>If true (and overwrite-existing-data is false) then any job/triggers encountered in this file that have names that already exist in the scheduler will be ignored, and no error will be produced.</xs:documentation>
</xs:annotation>
</xs:element>
<xs:element name="schedule-trigger-relative-to-replaced-trigger" type="xs:boolean" minOccurs="0" default="false">
<xs:annotation>
<xs:documentation>If true trigger's start time is calculated based on earlier run time instead of fixed value. Trigger's start time must be undefined for this to work.</xs:documentation>
</xs:annotation>
</xs:element>
</xs:sequence>
</xs:complexType>
<xs:complexType name="job-detailType">
<xs:annotation>
<xs:documentation>Define a JobDetail</xs:documentation>
</xs:annotation>
<xs:sequence>
<xs:element name="name" type="xs:string" />
<xs:element name="group" type="xs:string" minOccurs="0" />
<xs:element name="description" type="xs:string" minOccurs="0" />
<xs:element name="job-type" type="xs:string" />
<xs:sequence minOccurs="0">
<xs:element name="durable" type="xs:boolean" />
<xs:element name="recover" type="xs:boolean" />
</xs:sequence>
<xs:element name="job-data-map" type="job-data-mapType" minOccurs="0" />
</xs:sequence>
</xs:complexType>
<xs:complexType name="job-data-mapType">
<xs:annotation>
<xs:documentation>Define a JobDataMap</xs:documentation>
</xs:annotation>
<xs:sequence minOccurs="0" maxOccurs="unbounded">
<xs:element name="entry" type="entryType" />
</xs:sequence>
</xs:complexType>
<xs:complexType name="entryType">
<xs:annotation>
<xs:documentation>Define a JobDataMap entry</xs:documentation>
</xs:annotation>
<xs:sequence>
<xs:element name="key" type="xs:string" />
<xs:element name="value" type="xs:string" />
</xs:sequence>
</xs:complexType>
<xs:complexType name="triggerType">
<xs:annotation>
<xs:documentation>Define a Trigger</xs:documentation>
</xs:annotation>
<xs:choice>
<xs:element name="simple" type="simpleTriggerType" />
<xs:element name="cron" type="cronTriggerType" />
<xs:element name="calendar-interval" type="calendarIntervalTriggerType" />
</xs:choice>
</xs:complexType>
<xs:complexType name="abstractTriggerType" abstract="true">
<xs:annotation>
<xs:documentation>Common Trigger definitions</xs:documentation>
</xs:annotation>
<xs:sequence>
<xs:element name="name" type="xs:string" />
<xs:element name="group" type="xs:string" minOccurs="0" />
<xs:element name="description" type="xs:string" minOccurs="0" />
<xs:element name="job-name" type="xs:string" />
<xs:element name="job-group" type="xs:string" minOccurs="0" />
<xs:element name="priority" type="xs:nonNegativeInteger" minOccurs="0" />
<xs:element name="calendar-name" type="xs:string" minOccurs="0" />
<xs:element name="job-data-map" type="job-data-mapType" minOccurs="0" />
<xs:sequence minOccurs="0">
<xs:choice>
<xs:element name="start-time" type="xs:dateTime" />
<xs:element name="start-time-seconds-in-future" type="xs:nonNegativeInteger" />
</xs:choice>
<xs:element name="end-time" type="xs:dateTime" minOccurs="0" />
</xs:sequence>
</xs:sequence>
</xs:complexType>
<xs:complexType name="simpleTriggerType">
<xs:annotation>
<xs:documentation>Define a SimpleTrigger</xs:documentation>
</xs:annotation>
<xs:complexContent>
<xs:extension base="abstractTriggerType">
<xs:sequence>
<xs:element name="misfire-instruction" type="simple-trigger-misfire-instructionType" minOccurs="0" />
<xs:sequence minOccurs="0">
<xs:element name="repeat-count" type="repeat-countType" />
<xs:element name="repeat-interval" type="xs:nonNegativeInteger" />
</xs:sequence>
</xs:sequence>
</xs:extension>
</xs:complexContent>
</xs:complexType>
<xs:complexType name="cronTriggerType">
<xs:annotation>
<xs:documentation>Define a CronTrigger</xs:documentation>
</xs:annotation>
<xs:complexContent>
<xs:extension base="abstractTriggerType">
<xs:sequence>
<xs:element name="misfire-instruction" type="cron-trigger-misfire-instructionType" minOccurs="0" />
<xs:element name="cron-expression" type="cron-expressionType" />
<xs:element name="time-zone" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:extension>
</xs:complexContent>
</xs:complexType>
<xs:complexType name="calendarIntervalTriggerType">
<xs:annotation>
<xs:documentation>Define a DateIntervalTrigger</xs:documentation>
</xs:annotation>
<xs:complexContent>
<xs:extension base="abstractTriggerType">
<xs:sequence>
<xs:element name="misfire-instruction" type="date-interval-trigger-misfire-instructionType" minOccurs="0" />
<xs:element name="repeat-interval" type="xs:nonNegativeInteger" />
<xs:element name="repeat-interval-unit" type="interval-unitType" />
</xs:sequence>
</xs:extension>
</xs:complexContent>
</xs:complexType>
<xs:simpleType name="cron-expressionType">
<xs:annotation>
<xs:documentation>
Cron expression (see JavaDoc for examples)
Special thanks to Chris Thatcher (thatcher@butterfly.net) for the regular expression!
Regular expressions are not my strong point but I believe this is complete,
with the caveat that order for expressions like 3-0 is not legal but will pass,
and month and day names must be capitalized.
If you want to examine the correctness look for the [\s] to denote the
seperation of individual regular expressions. This is how I break them up visually
to examine them:
SECONDS:
(
((([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?,)*([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?)
| (([\*]|[0-9]|[0-5][0-9])/([0-9]|[0-5][0-9]))
| ([\?])
| ([\*])
) [\s]
MINUTES:
(
((([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?,)*([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?)
| (([\*]|[0-9]|[0-5][0-9])/([0-9]|[0-5][0-9]))
| ([\?])
| ([\*])
) [\s]
HOURS:
(
((([0-9]|[0-1][0-9]|[2][0-3])(-([0-9]|[0-1][0-9]|[2][0-3]))?,)*([0-9]|[0-1][0-9]|[2][0-3])(-([0-9]|[0-1][0-9]|[2][0-3]))?)
| (([\*]|[0-9]|[0-1][0-9]|[2][0-3])/([0-9]|[0-1][0-9]|[2][0-3]))
| ([\?])
| ([\*])
) [\s]
DAY OF MONTH:
(
((([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(-([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1]))?,)*([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(-([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1]))?(C)?)
| (([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])/([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(C)?)
| (L(-[0-9])?)
| (L(-[1-2][0-9])?)
| (L(-[3][0-1])?)
| (LW)
| ([1-9]W)
| ([1-3][0-9]W)
| ([\?])
| ([\*])
)[\s]
MONTH:
(
((([1-9]|0[1-9]|1[0-2])(-([1-9]|0[1-9]|1[0-2]))?,)*([1-9]|0[1-9]|1[0-2])(-([1-9]|0[1-9]|1[0-2]))?)
| (([1-9]|0[1-9]|1[0-2])/([1-9]|0[1-9]|1[0-2]))
| (((JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)(-(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))?,)*(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)(-(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))?)
| ((JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)/(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))
| ([\?])
| ([\*])
)[\s]
DAY OF WEEK:
(
(([1-7](-([1-7]))?,)*([1-7])(-([1-7]))?)
| ([1-7]/([1-7]))
| (((MON|TUE|WED|THU|FRI|SAT|SUN)(-(MON|TUE|WED|THU|FRI|SAT|SUN))?,)*(MON|TUE|WED|THU|FRI|SAT|SUN)(-(MON|TUE|WED|THU|FRI|SAT|SUN))?(C)?)
| ((MON|TUE|WED|THU|FRI|SAT|SUN)/(MON|TUE|WED|THU|FRI|SAT|SUN)(C)?)
| (([1-7]|(MON|TUE|WED|THU|FRI|SAT|SUN))(L|LW)?)
| (([1-7]|MON|TUE|WED|THU|FRI|SAT|SUN)#([1-7])?)
| ([\?])
| ([\*])
)
YEAR (OPTIONAL):
(
[\s]?
([\*])?
| ((19[7-9][0-9])|(20[0-9][0-9]))?
| (((19[7-9][0-9])|(20[0-9][0-9]))/((19[7-9][0-9])|(20[0-9][0-9])))?
| ((((19[7-9][0-9])|(20[0-9][0-9]))(-((19[7-9][0-9])|(20[0-9][0-9])))?,)*((19[7-9][0-9])|(20[0-9][0-9]))(-((19[7-9][0-9])|(20[0-9][0-9])))?)?
)
</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern
value="(((([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?,)*([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?)|(([\*]|[0-9]|[0-5][0-9])/([0-9]|[0-5][0-9]))|([\?])|([\*]))[\s](((([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?,)*([0-9]|[0-5][0-9])(-([0-9]|[0-5][0-9]))?)|(([\*]|[0-9]|[0-5][0-9])/([0-9]|[0-5][0-9]))|([\?])|([\*]))[\s](((([0-9]|[0-1][0-9]|[2][0-3])(-([0-9]|[0-1][0-9]|[2][0-3]))?,)*([0-9]|[0-1][0-9]|[2][0-3])(-([0-9]|[0-1][0-9]|[2][0-3]))?)|(([\*]|[0-9]|[0-1][0-9]|[2][0-3])/([0-9]|[0-1][0-9]|[2][0-3]))|([\?])|([\*]))[\s](((([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(-([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1]))?,)*([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(-([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1]))?(C)?)|(([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])/([1-9]|[0][1-9]|[1-2][0-9]|[3][0-1])(C)?)|(L(-[0-9])?)|(L(-[1-2][0-9])?)|(L(-[3][0-1])?)|(LW)|([1-9]W)|([1-3][0-9]W)|([\?])|([\*]))[\s](((([1-9]|0[1-9]|1[0-2])(-([1-9]|0[1-9]|1[0-2]))?,)*([1-9]|0[1-9]|1[0-2])(-([1-9]|0[1-9]|1[0-2]))?)|(([1-9]|0[1-9]|1[0-2])/([1-9]|0[1-9]|1[0-2]))|(((JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)(-(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))?,)*(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)(-(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))?)|((JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC)/(JAN|FEB|MAR|APR|MAY|JUN|JUL|AUG|SEP|OCT|NOV|DEC))|([\?])|([\*]))[\s]((([1-7](-([1-7]))?,)*([1-7])(-([1-7]))?)|([1-7]/([1-7]))|(((MON|TUE|WED|THU|FRI|SAT|SUN)(-(MON|TUE|WED|THU|FRI|SAT|SUN))?,)*(MON|TUE|WED|THU|FRI|SAT|SUN)(-(MON|TUE|WED|THU|FRI|SAT|SUN))?(C)?)|((MON|TUE|WED|THU|FRI|SAT|SUN)/(MON|TUE|WED|THU|FRI|SAT|SUN)(C)?)|(([1-7]|(MON|TUE|WED|THU|FRI|SAT|SUN))?(L|LW)?)|(([1-7]|MON|TUE|WED|THU|FRI|SAT|SUN)#([1-7])?)|([\?])|([\*]))([\s]?(([\*])?|(19[7-9][0-9])|(20[0-9][0-9]))?| (((19[7-9][0-9])|(20[0-9][0-9]))/((19[7-9][0-9])|(20[0-9][0-9])))?| ((((19[7-9][0-9])|(20[0-9][0-9]))(-((19[7-9][0-9])|(20[0-9][0-9])))?,)*((19[7-9][0-9])|(20[0-9][0-9]))(-((19[7-9][0-9])|(20[0-9][0-9])))?)?)" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="repeat-countType">
<xs:annotation>
<xs:documentation>Number of times to repeat the Trigger (-1 for indefinite)</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:integer">
<xs:minInclusive value="-1" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="simple-trigger-misfire-instructionType">
<xs:annotation>
<xs:documentation>Simple Trigger Misfire Instructions</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern value="SmartPolicy" />
<xs:pattern value="RescheduleNextWithExistingCount" />
<xs:pattern value="RescheduleNextWithRemainingCount" />
<xs:pattern value="RescheduleNowWithExistingRepeatCount" />
<xs:pattern value="RescheduleNowWithRemainingRepeatCount" />
<xs:pattern value="FireNow" />
<xs:pattern value="IgnoreMisfirePolicy" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="cron-trigger-misfire-instructionType">
<xs:annotation>
<xs:documentation>Cron Trigger Misfire Instructions</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern value="SmartPolicy" />
<xs:pattern value="DoNothing" />
<xs:pattern value="FireOnceNow" />
<xs:pattern value="IgnoreMisfirePolicy" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="date-interval-trigger-misfire-instructionType">
<xs:annotation>
<xs:documentation>Date Interval Trigger Misfire Instructions</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern value="SmartPolicy" />
<xs:pattern value="DoNothing" />
<xs:pattern value="FireOnceNow" />
<xs:pattern value="IgnoreMisfirePolicy" />
</xs:restriction>
</xs:simpleType>
<xs:simpleType name="interval-unitType">
<xs:annotation>
<xs:documentation>Interval Units</xs:documentation>
</xs:annotation>
<xs:restriction base="xs:string">
<xs:pattern value="Day" />
<xs:pattern value="Hour" />
<xs:pattern value="Minute" />
<xs:pattern value="Month" />
<xs:pattern value="Second" />
<xs:pattern value="Week" />
<xs:pattern value="Year" />
</xs:restriction>
</xs:simpleType>
</xs:schema>

14
BcCenter/BcCenter.Service/packages.config
Unescape Escape View File

@ -0,0 +1,14 @@
<?xml version="1.0" encoding="utf-8"?>
<packages>
<package id="Common.Logging" version="3.3.1" targetFramework="net461" />
<package id="Common.Logging.Core" version="3.3.1" targetFramework="net461" />
<package id="EntityFramework" version="6.4.4" targetFramework="net461" />
<package id="log4net" version="2.0.14" targetFramework="net461" />
<package id="MailKit" version="3.1.1" targetFramework="net461" />
<package id="MimeKit" version="3.1.1" targetFramework="net461" />
<package id="Newtonsoft.Json" version="13.0.1" targetFramework="net461" />
<package id="Portable.BouncyCastle" version="1.9.0" targetFramework="net461" />
<package id="Quartz" version="2.6.2" targetFramework="net461" />
<package id="System.Buffers" version="4.5.1" targetFramework="net461" />
<package id="Topshelf" version="4.2.1" targetFramework="net461" />
</packages>

159
BcCenter/BcCenter.Service/quartz_jobs.xml
Unescape Escape View File

@ -0,0 +1,159 @@
<?xml version="1.0" encoding="utf-8" ?>
<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData">
<processing-directives>
<overwrite-existing-data>true</overwrite-existing-data>
</processing-directives>
<schedule>
<job>
<name>JobScheduler</name>
<group>System</group>
<description>动态调度作业</description>
<job-type>DSWeb.BillCenter.Service.SchedulerJob,DSWeb.BillCenter.Service</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<entry>
<key>GetMailIntervalMinutes</key>
<value>1</value>
</entry>
<entry>
<key>ParseMailIntervalSeconds</key>
<value>10</value>
</entry>
<entry>
<key>ProcessMailIntervalSeconds</key>
<value>10</value>
</entry>
<entry>
<key>RetransmissionIntervalSeconds</key>
<value>10</value>
</entry>
</job-data-map>
</job>
<trigger>
<simple>
<name>TriggerScheduler</name>
<group>System</group>
<description>动态调度作业触发器</description>
<job-name>JobScheduler</job-name>
<job-group>System</job-group>
<repeat-count>-1</repeat-count>
<repeat-interval>60000</repeat-interval>
</simple>
</trigger>
<job>
<name>JobCheckProgress</name>
<group>System</group>
<description>检查附件处理进度作业</description>
<job-type>DSWeb.BillCenter.Service.JobCheckAttachProgress,DSWeb.BillCenter.Service</job-type>
<durable>true</durable>
<recover>false</recover>
</job>
<trigger>
<simple>
<name>TriggerCheckProgress</name>
<group>System</group>
<description>检查附件处理进度作业触发器</description>
<job-name>JobCheckProgress</job-name>
<job-group>System</job-group>
<repeat-count>-1</repeat-count>
<repeat-interval>60000</repeat-interval>
</simple>
</trigger>
<job>
<name>JobBillDataToDS7</name>
<group>System</group>
<description>账单推送DS7消息队列</description>
<job-type>DSWeb.BillCenter.Service.JobBillDataToDS7,DSWeb.BillCenter.Service</job-type>
<durable>true</durable>
<recover>false</recover>
</job>
<trigger>
<simple>
<name>TriggerBillDataToDS7</name>
<group>System</group>
<description>账单推送消息队列触发器</description>
<job-name>JobBillDataToDS7</job-name>
<job-group>System</job-group>
<repeat-count>-1</repeat-count>
<repeat-interval>10000</repeat-interval>
</simple>
</trigger>
<job>
<name>JobBillDataToDS7Task</name>
<group>System</group>
<description>账单推送DS7消息队列</description>
<job-type>DSWeb.BillCenter.Service.JobBillDataToDS7Task,DSWeb.BillCenter.Service</job-type>
<durable>true</durable>
<recover>false</recover>
</job>
<trigger>
<simple>
<name>TriggerBillDataToDS7Task</name>
<group>System</group>
<description>账单推送消息队列触发器</description>
<job-name>JobBillDataToDS7Task</job-name>
<job-group>System</job-group>
<repeat-count>-1</repeat-count>
<repeat-interval>10000</repeat-interval>
</simple>
</trigger>
<job>
<name>JobBillDataToDS7New</name>
<group>System</group>
<description>账单推送DS7消息队列</description>
<job-type>DSWeb.BillCenter.Service.JobBillDataToDS7New,DSWeb.BillCenter.Service</job-type>
<durable>true</durable>
<recover>false</recover>
</job>
<trigger>
<simple>
<name>TriggerBillDataToDS7New</name>
<group>System</group>
<description>账单推送消息队列触发器</description>
<job-name>JobBillDataToDS7New</job-name>
<job-group>System</job-group>
<repeat-count>-1</repeat-count>
<repeat-interval>10000</repeat-interval>
</simple>
</trigger>
<job>
<name>JobBillDataToDS7TaskDirect</name>
<group>System</group>
<description>账单推送DS7消息队列</description>
<job-type>DSWeb.BillCenter.Service.JobBillDataToDS7TaskDirect,DSWeb.BillCenter.Service</job-type>
<durable>true</durable>
<recover>false</recover>
</job>
<trigger>
<simple>
<name>TriggerBillDataToDS7TaskDirect</name>
<group>System</group>
<description>账单推送消息队列触发器</description>
<job-name>JobBillDataToDS7TaskDirect</job-name>
<job-group>System</job-group>
<repeat-count>-1</repeat-count>
<repeat-interval>10000</repeat-interval>
</simple>
</trigger>
</schedule>
</job-scheduling-data>

31
BcCenter/BcCenter.sln
Unescape Escape View File

@ -0,0 +1,31 @@

Microsoft Visual Studio Solution File, Format Version 12.00
# Visual Studio Version 16
VisualStudioVersion = 16.0.31702.278
MinimumVisualStudioVersion = 10.0.40219.1
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "BcCenter.Service", "BcCenter.Service\BcCenter.Service.csproj", "{3A539117-F2B7-4B78-8849-48DE29370F09}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "BcCenter.Common", "BcCenter.Common\BcCenter.Common.csproj", "{D26A3DF4-4F5B-4B40-8723-2B9477E754A1}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
Release|Any CPU = Release|Any CPU
EndGlobalSection
GlobalSection(ProjectConfigurationPlatforms) = postSolution
{3A539117-F2B7-4B78-8849-48DE29370F09}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{3A539117-F2B7-4B78-8849-48DE29370F09}.Debug|Any CPU.Build.0 = Debug|Any CPU
{3A539117-F2B7-4B78-8849-48DE29370F09}.Release|Any CPU.ActiveCfg = Release|Any CPU
{3A539117-F2B7-4B78-8849-48DE29370F09}.Release|Any CPU.Build.0 = Release|Any CPU
{D26A3DF4-4F5B-4B40-8723-2B9477E754A1}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{D26A3DF4-4F5B-4B40-8723-2B9477E754A1}.Debug|Any CPU.Build.0 = Debug|Any CPU
{D26A3DF4-4F5B-4B40-8723-2B9477E754A1}.Release|Any CPU.ActiveCfg = Release|Any CPU
{D26A3DF4-4F5B-4B40-8723-2B9477E754A1}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {31DE9E18-ED5A-41FA-850C-9C68B7E46272}
EndGlobalSection
EndGlobal
Write Preview
Loading…
Cancel
Save