using Newtonsoft.Json;
using Quartz;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Utils;
namespace PMS.NetCore.Service
{
///
/// 昆山项目发缴费短信
///
public class KunshanPayCostSmsJob : IJob
{
NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
public Task Execute(IJobExecutionContext context)
{
return Task.Run(() =>
{
try
{
var thisDate = DateTime.Now.ToString("yyyy-MM-dd");
//thisDate = "2020-12-01";
//NlogHelper.quartzLogger.Info("开始");
var sql = $" SELECT b.billitemname ,a.nneedpaymny ,a.nrevmny ,a.dneeddate,a.dbegindate,a.denddate,c.firsttel FROM fdc_pm_fare_b a INNER JOIN fdc_pm_billsitem b ON a.billitemcode=b.billitemcode INNER JOIN fdc_pm_owner c ON a.ownerid=c.ownerid WHERE ( a.flag=1 OR a.flag IS NULL) AND a.nneedpaymny>a.nrevmny AND CONVERT(VARCHAR(10),a.dneeddate,120)='{thisDate}' ";
//logger.Info($"主项计划sql:{sql}");
var manager = new actionsManager();
var dt = manager.Db.Ado.GetDataTable(sql);
for (int i = 0; i < dt.Rows.Count; i++)
{
//费用类型
var billitemname = dt.Rows[i]["billitemname"]?.ToString();
//手机号
var phone = dt.Rows[i]["firsttel"]?.ToString();
//应交日期
var dneeddate = dt.Rows[i]["dneeddate"].ToString();
//开始日期
var dbegindate = dt.Rows[i]["dbegindate"]?.ToString();
//结束日期
var denddate = dt.Rows[i]["denddate"]?.ToString();
////1:租金,2:水费,3:电费,4:服务费,5:押保,6:违约金,7:创收,8:水电费,9:物业费
var type = "";
if(billitemname=="租金")
{
type = "1";
}
else if (billitemname == "水费")
{
type = "2";
}
else if (billitemname == "电费")
{
type = "3";
}
else if (billitemname == "服务费")
{
type = "4";
}
else if (billitemname == "押保")
{
type = "5";
}
else if (billitemname == "违约金")
{
type = "6";
}
else if (billitemname == "创收")
{
type = "7";
}
else if (billitemname == "水电费")
{
type = "8";
}
else if (billitemname == "物业费")
{
type = "9";
}
if(type.IsNotNullAndEmpty())
{
var closingDate = Convert.ToDateTime(dbegindate).ToString("yyyy年MM月") + "至" + Convert.ToDateTime(denddate).ToString("yyyy年MM月");
var outingDate = Convert.ToDateTime(dneeddate).ToString("yyyy年MM月dd日");
string url = AppSettingsHelper.Configuration["kunshanUrl"];
var postvalues = new NameValueCollection();
postvalues.Add("telephone", phone);
postvalues.Add("type", type);
postvalues.Add("closingDate", closingDate);
postvalues.Add("outingDate", outingDate);
var res = WebClientHelper.ClientPost(url, postvalues);
NlogHelper.quartzLogger.Info($"手机号:{phone}发送短信执行完毕");
var outData = JsonConvert.DeserializeObject(res);
sql = $"insert into sms(Phone,status,msg,contents) values ('{phone}','{outData.status}','{outData.msg}','{outData.contents}')";
manager.Db.Ado.ExecuteCommand(sql);
}
}
}
catch (Exception ero)
{
NlogHelper.quartzLogger.Error(" 发邮件执行出错:" + ero, true);
}
});
}
}
public class OutData
{
public string status { get; set; }
public string msg { get; set; }
public string contents { get; set; }
}
}