| | |
|---|
| | | |
|---|
| | | namespace zymes_Project.OperationService |
|---|
| | | { |
|---|
| | | [Description("[业务员-审核]服务插件]")] |
|---|
| | | [Description("[业务员-保存]服务插件]")] |
|---|
| | | [HotUpdate] |
|---|
| | | public class zymes_RealessOperator : AbstractOperationServicePlugIn |
|---|
| | | { |
|---|
| | |
|---|
| | | Entity entity = this.BusinessInfo.GetEntity("FEntity");//获取明细信息 |
|---|
| | | foreach (var billObj in e.DataEntitys) |
|---|
| | | { |
|---|
| | | //var sql = $"exec zymes_RealessUnit {billObj["Id"]} "; |
|---|
| | | var forgName = Context.CurrentOrganizationInfo.Name; |
|---|
| | | if (!forgName.Contains("杭州斯莫尔磁性材料有限公司")) |
|---|
| | | continue; |
|---|
| | | //var sql = $"exec zymes_RealessOperator {billObj["Id"]} "; |
|---|
| | | var id = billObj["Id"].ToString(); |
|---|
| | | string sql =string.Empty; |
|---|
| | | sql = $@" |
|---|
| | | /*dialect*/ |
|---|
| | | select a.FOPERATORID as HItemID,'' as HNumber,'' as HName,'' as HHelpCode,'' as HShortNumber,0 as HParentID |
|---|
| | | select a.FENTRYID as HItemID,st.FNUMBER as HNumber,l.FNAME as HName,'' as HHelpCode,st.FNUMBER as HShortNumber,0 as HParentID |
|---|
| | | ,1 as HLevel,'true' as HEndFlag,'false' as HStopflag,'CLD-ERP导入' as HRemark,'' as HUseFlag,0 as HUSEORGID |
|---|
| | | ,0 as HOperatorId,'' as HOperatorType,0 as HSEQ,0 as HStaffId,0 as HIsUse |
|---|
| | | from T_BD_OPERATOR a with(nolock) |
|---|
| | | inner join T_BD_OPERATOR_L l with(nolock) on a.FOPERATORID=l.FOPERATORID and FLOCALEID=2052 |
|---|
| | | ,a.FOPERATORID as HOperatorId,a.FOPERATORTYPE as HOperatorType,a.FSEQ as HSEQ,a.FSTAFFID as HStaffId,a.FISUSE as HIsUse |
|---|
| | | from T_BD_OPERATORENTRY a with(nolock) |
|---|
| | | inner join T_BD_OPERATORENTRY_L l with(nolock) on a.FENTRYID=l.FENTRYID and FLOCALEID=2052 |
|---|
| | | left join T_BD_STAFF st on a.FSTAFFID = st.FSTAFFID |
|---|
| | | Where a.FOPERATORID={id} |
|---|
| | | "; |
|---|
| | | DataTable dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0]; |
|---|
| | |
|---|
| | | LogService.Write("业务员同步异常：" + sql); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | DataRow dr = dt.Rows[0]; |
|---|
| | | JObject model = new JObject(); |
|---|
| | | foreach (DataColumn column in dt.Columns) |
|---|
| | | //DataRow dr = dt.Rows[0]; |
|---|
| | | JArray array = new JArray(); |
|---|
| | | foreach(DataRow dr in dt.Rows) |
|---|
| | | { |
|---|
| | | model.Add(column.ColumnName, dr[column.ColumnName].ToString()); |
|---|
| | | JObject fentrymodel = new JObject(); |
|---|
| | | foreach (DataColumn column in dt.Columns) |
|---|
| | | { |
|---|
| | | fentrymodel.Add(column.ColumnName, dr[column.ColumnName].ToString()); |
|---|
| | | } |
|---|
| | | array.Add(fentrymodel); |
|---|
| | | } |
|---|
| | | JObject model = new JObject(); |
|---|
| | | model.Add("HOperatorInfoEntry", array); |
|---|
| | | //foreach (DataColumn column in dt.Columns) |
|---|
| | | //{ |
|---|
| | | // model.Add(column.ColumnName, dr[column.ColumnName].ToString()); |
|---|
| | | //} |
|---|
| | | JObject _jsonRoot = new JObject() |
|---|
| | | { |
|---|
| | | ["model"] = model |
|---|
| | | }; |
|---|
| | | LogService.Write("业务员同步示例：" + JsonConvert.SerializeObject(_jsonRoot)); |
|---|
| | | LogService.Write("业务员同步示例：" + _jsonRoot); |
|---|
| | | //LogService.Write("业务员同步示例：" + JsonConvert.SerializeObject(_jsonRoot)); |
|---|
| | | //LogService.Write("业务员同步示例：" + _jsonRoot); |
|---|
| | | //string clientUrl = Util.GetConfigKey(AppDomain.CurrentDomain.BaseDirectory + "/Config/kdapi.config", "ClientUrl");//K/3 Cloud 业务站点地址 |
|---|
| | | var client = new RestSharp.RestClient("http://61.130.182.102:18181/simoerAPI/"); |
|---|
| | | var client = new RestSharp.RestClient(" http://10.11.18.195:8080/simoerapi/"); |
|---|
| | | var requestPost = new RestRequest("Gy_Operator/SaveGy_OperatorListApi", Method.POST); |
|---|
| | | requestPost.AddParameter("application/json", JsonConvert.SerializeObject(_jsonRoot), ParameterType.RequestBody); |
|---|
| | | IRestResponse responsePost = client.Execute(requestPost); |
|---|
| | | var contentPost = responsePost.Content; |
|---|
| | | if (!contentPost.Contains("成功")) |
|---|
| | | { |
|---|
| | | LogService.Write("业务员同步异常,POST方式获取结果," + billObj["Id"] + "," + contentPost); |
|---|
| | | LogService.Write("业务员同步异常,POST方式获取结果," + billObj["Id"] + "," + responsePost.ErrorMessage); |
|---|
| | | LogService.Write("业务员同步异常,POST," + "Gy_Operator/SaveGy_OperatorListApi"); |
|---|
| | | LogService.Write("业务员同步异常,JsonConvert.SerializeObject(_jsonRoot)," + JsonConvert.SerializeObject(_jsonRoot)); |
|---|
| | | } |
|---|
