|
|
using DSWeb.Areas.CommMng.DAL;
|
|
|
using DSWeb.Areas.MvcShipping.Comm;
|
|
|
using DSWeb.Areas.MvcShipping.DB;
|
|
|
using DSWeb.Areas.MvcShipping.Helper;
|
|
|
using DSWeb.Areas.MvcShipping.Job;
|
|
|
using DSWeb.Areas.MvcShipping.Models.MsOpSeaeRunBill;
|
|
|
using DSWeb.MvcShipping.Comm.Cookie;
|
|
|
using DSWeb.MvcShipping.DAL.MsOpSeaeRunBill;
|
|
|
using log4net;
|
|
|
using Newtonsoft.Json;
|
|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Configuration;
|
|
|
using System.Data.SqlClient;
|
|
|
using System.Dynamic;
|
|
|
using System.Linq;
|
|
|
using System.Runtime.Caching;
|
|
|
using System.Web;
|
|
|
using System.Web.Mvc;
|
|
|
|
|
|
namespace DSWeb.MvcShipping.Controllers
|
|
|
{
|
|
|
public class MsOpSeaeRunBillController : Controller
|
|
|
{
|
|
|
private ILog logger = LogManager.GetLogger("MsOpSeaeRunBillController");
|
|
|
|
|
|
private RunBillContext runBillContext = new RunBillContext();
|
|
|
|
|
|
//新建
|
|
|
public ActionResult Create(string strBSNO)
|
|
|
{
|
|
|
ViewData["StrBSNO"] = strBSNO;
|
|
|
|
|
|
string BSNO = strBSNO.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries).First();
|
|
|
var opseae = runBillContext.OpSeaes.First(s => s.BSNO == BSNO);
|
|
|
var info = runBillContext.InfoClients.SingleOrDefault(i => i.SHORTNAME == opseae.CUSTOMERNAME);
|
|
|
OpSeaeRunBill runBill = new OpSeaeRunBill();
|
|
|
runBill.CUSTOMERNAME = opseae.CUSTOMERNAME;
|
|
|
runBill.CARRIER = opseae.CARRIER;
|
|
|
runBill.FORWARDER = opseae.FORWARDER;
|
|
|
runBill.ADDR = info.ADDR;
|
|
|
runBill.STATUS = OpSeaeRunBillStatus.Create.ToString();
|
|
|
ViewData["Bill"] = JsonConvert.SerializeObject(runBill.AsEditViewModel());
|
|
|
return View("edit");
|
|
|
}
|
|
|
|
|
|
//编辑
|
|
|
public ActionResult Edit(string gid)
|
|
|
{
|
|
|
ViewData["GID"] = gid;
|
|
|
var bsnoList = runBillContext.OpSeaeRunBillItems.Where(b => b.ParentId == gid).Select(b => b.BSNO).ToList();
|
|
|
ViewData["StrBSNO"] = string.Join(",", bsnoList);
|
|
|
ViewData["Bill"] = JsonConvert.SerializeObject(runBillContext.OpSeaeRunBills.First(b => b.GID == gid).AsEditViewModel());
|
|
|
return View();
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
//获取客户的联系人、电话、地址等信息
|
|
|
public JsonResult GetCustomerInfo(string shortName)
|
|
|
{
|
|
|
var info = runBillContext.InfoClients.SingleOrDefault(i => i.SHORTNAME == shortName);
|
|
|
if (info != null)
|
|
|
{
|
|
|
return Json(info);
|
|
|
}
|
|
|
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
//根据bsno字符串，获取opseae列表信息
|
|
|
public JsonResult GetOpseadList(string strBSNO)
|
|
|
{
|
|
|
string[] arrBSNO = strBSNO.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
var list = runBillContext.OpSeaes.Where(s => arrBSNO.Contains(s.BSNO)).ToList();
|
|
|
|
|
|
return Json(new { Success = true, Message = "", data = list, totalCount = list.Count });
|
|
|
}
|
|
|
|
|
|
//保存
|
|
|
public JsonResult Save(string data, string strBSNO)
|
|
|
{
|
|
|
var viewModel = JsonConvert.DeserializeObject<RunBillEditViewModel>(data);
|
|
|
OpSeaeRunBill saveModel = null;
|
|
|
if (!string.IsNullOrEmpty(viewModel.GID))
|
|
|
{
|
|
|
saveModel = runBillContext.OpSeaeRunBills.First(b => b.GID == viewModel.GID);
|
|
|
|
|
|
viewModel.AsModel(saveModel);
|
|
|
|
|
|
runBillContext.OpSeaeRunBillItems.RemoveRange(runBillContext.OpSeaeRunBillItems.Where(i => i.ParentId == viewModel.GID));
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
saveModel = viewModel.AsModel();
|
|
|
saveModel.GID = Guid.NewGuid().ToString();
|
|
|
saveModel.CREATETIME = DateTime.Now;
|
|
|
saveModel.CREATEUSER = Convert.ToString(Session["USERID"]);
|
|
|
saveModel.CREATEUSERNAME = Convert.ToString(Session["SHOWNAME"]);
|
|
|
saveModel.BillNO = PubSysDAL.GetBillNo("0700");
|
|
|
|
|
|
if (string.IsNullOrWhiteSpace(saveModel.STATUS))
|
|
|
{
|
|
|
saveModel.STATUS = OpSeaeRunBillStatus.Create.ToString();
|
|
|
}
|
|
|
runBillContext.OpSeaeRunBills.Add(saveModel);
|
|
|
}
|
|
|
|
|
|
//判断时间区间
|
|
|
if (saveModel.RUNTIME.HasValue)
|
|
|
{
|
|
|
int hour = saveModel.RUNTIME.Value.Hour;
|
|
|
if (hour <= 12)
|
|
|
{
|
|
|
saveModel.TimeSpan = "上午";
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
saveModel.TimeSpan = "下午";
|
|
|
}
|
|
|
}
|
|
|
|
|
|
string[] arrBSNO = strBSNO.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
foreach (var bsno in arrBSNO)
|
|
|
{
|
|
|
OpSeaeRunBillItem item = new OpSeaeRunBillItem();
|
|
|
item.GID = Guid.NewGuid().ToString();
|
|
|
item.BSNO = bsno;
|
|
|
item.ParentId = saveModel.GID;
|
|
|
runBillContext.OpSeaeRunBillItems.Add(item);
|
|
|
}
|
|
|
runBillContext.SaveChanges();
|
|
|
|
|
|
//推送
|
|
|
if (saveModel.STATUS == OpSeaeRunBillStatus.Dispatch.ToString())
|
|
|
{
|
|
|
var user = runBillContext.Users.FirstOrDefault(u => u.GID == saveModel.USERID);
|
|
|
if (!string.IsNullOrWhiteSpace(user.WeChatAccount))
|
|
|
{
|
|
|
WorkWeixinSendHelper.SendNotifyToUser(user.WeChatAccount, $"/MvcShipping/MsOpseaeRunBill/WxUserRedirect?userId={user.WeChatAccount}");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return Json(new { Success = true, Message = "保存成功", Data = saveModel.AsEditViewModel() });
|
|
|
}
|
|
|
|
|
|
//删除
|
|
|
public JsonResult Delete(string data) {
|
|
|
|
|
|
var viewModel = JsonConvert.DeserializeObject<RunBillEditViewModel>(data);
|
|
|
OpSeaeRunBill delModel = null;
|
|
|
|
|
|
|
|
|
delModel = runBillContext.OpSeaeRunBills.First(b => b.GID == viewModel.GID);
|
|
|
|
|
|
if (delModel.STATUS != OpSeaeRunBillStatus.Create.ToString())
|
|
|
{
|
|
|
return Json(new { Success = false, Message = "只能删除“创建”状态的跑单信息", Data = "" });
|
|
|
}
|
|
|
|
|
|
viewModel.AsModel(delModel);
|
|
|
|
|
|
runBillContext.OpSeaeRunBillItems.RemoveRange(runBillContext.OpSeaeRunBillItems.Where(i => i.ParentId == viewModel.GID));
|
|
|
|
|
|
runBillContext.OpSeaeRunBills.RemoveRange(runBillContext.OpSeaeRunBills.Where(i => i.GID == viewModel.GID));
|
|
|
|
|
|
runBillContext.SaveChanges();
|
|
|
|
|
|
return Json(new { Success = true, Message = "删除成功", Data = "" });
|
|
|
|
|
|
}
|
|
|
|
|
|
//列表页
|
|
|
public ActionResult Index()
|
|
|
{
|
|
|
return View();
|
|
|
}
|
|
|
|
|
|
//获取跑单列表数据
|
|
|
public JsonResult GetDataList(string condition, int start, int limit, int pageSize, string sort = null)
|
|
|
{
|
|
|
limit = start + pageSize;
|
|
|
var sessionInfo = new { USERID = Convert.ToString(Session["USERID"]), SHOWNAME = Convert.ToString(Session["SHOWNAME"]), COMPANYID = Convert.ToString(Session["COMPANYID"]) };
|
|
|
var count = runBillContext.Database.SqlQuery<int>(MsOpSeaeRunBillDAL.GetDataCountSql(condition, Convert.ToString(Session["USERID"]), Convert.ToString(Session["SHOWNAME"]), Convert.ToString(Session["COMPANYID"]))).First();
|
|
|
var list = runBillContext.Database.SqlQuery<OpSeaeRunBill>(MsOpSeaeRunBillDAL.GetDataListSql(condition, Convert.ToString(Session["USERID"]), Convert.ToString(Session["SHOWNAME"]), Convert.ToString(Session["COMPANYID"]), sort, start, limit));
|
|
|
return Json(new { Success = true, Message = "查询成功", totalCount = count, data = list.AsListViewModelList() }, JsonRequestBehavior.AllowGet);
|
|
|
}
|
|
|
|
|
|
//确认接单
|
|
|
public JsonResult AcceptBill(string strGID)
|
|
|
{
|
|
|
string[] arrGID = strGID.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
var uid = Convert.ToString(Session["USERID"]);
|
|
|
var staDispatch = OpSeaeRunBillStatus.Dispatch.ToString();
|
|
|
var list = runBillContext.OpSeaeRunBills.Where(s => s.STATUS == staDispatch && arrGID.Contains(s.GID)).ToList();
|
|
|
list.ForEach(b =>
|
|
|
{
|
|
|
b.ACCEPTTIME = DateTime.Now;
|
|
|
b.STATUS = OpSeaeRunBillStatus.Accept.ToString();
|
|
|
});
|
|
|
runBillContext.SaveChanges();
|
|
|
return Json(new { Success = true, Message = "操作成功" });
|
|
|
}
|
|
|
|
|
|
//转单
|
|
|
public JsonResult ChangeDispatch(string strGID, string userid, string username)
|
|
|
{
|
|
|
string[] arrGID = strGID.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
var uid = Convert.ToString(Session["USERID"]);
|
|
|
var staComplete = OpSeaeRunBillStatus.Complete.ToString();
|
|
|
var list = runBillContext.OpSeaeRunBills.Where(s => s.STATUS != staComplete && arrGID.Contains(s.GID)).ToList();
|
|
|
var user = runBillContext.Users.FirstOrDefault(u => u.GID == userid);
|
|
|
|
|
|
if (list.Count == 0)
|
|
|
{
|
|
|
return Json(new { Success = false, Message = "没有可供操作的已选数据" });
|
|
|
}
|
|
|
|
|
|
list.ForEach(b =>
|
|
|
{
|
|
|
b.USERID = userid;
|
|
|
b.USERNAME = username;
|
|
|
b.TRANSFERTIME = DateTime.Now;
|
|
|
b.TRANSFERUSER = Convert.ToString(Session["USERID"]);
|
|
|
});
|
|
|
runBillContext.SaveChanges();
|
|
|
|
|
|
logger.Debug("跑单转单，准备推送通知");
|
|
|
if (!string.IsNullOrWhiteSpace(user.WeChatAccount))
|
|
|
{
|
|
|
WorkWeixinSendHelper.SendNotifyToUser(user.WeChatAccount, $"/MvcShipping/MsOpseaeRunBill/WxUserRedirect?userId={user.WeChatAccount}");
|
|
|
logger.Debug("推送通知：" + user.WeChatAccount);
|
|
|
}
|
|
|
|
|
|
if (list.Count == 1)
|
|
|
{
|
|
|
return Json(new { Success = true, Message = "操作成功", Data = list[0].AsEditViewModel() });
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return Json(new { Success = true, Message = "操作成功" });
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//转单
|
|
|
public JsonResult CancelChangeDispatch(string strGID)
|
|
|
{
|
|
|
string[] arrGID = strGID.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
var uid = Convert.ToString(Session["USERID"]);
|
|
|
var staComplete = OpSeaeRunBillStatus.Complete.ToString();
|
|
|
var list = runBillContext.OpSeaeRunBills.Where(s => s.STATUS != staComplete && arrGID.Contains(s.GID)).ToList();
|
|
|
if (list.Count == 0)
|
|
|
{
|
|
|
return Json(new { Success = false, Message = "没有可供操作的已选数据" });
|
|
|
}
|
|
|
|
|
|
|
|
|
list.ForEach(b =>
|
|
|
{
|
|
|
b.USERID = b.TRANSFERUSER;
|
|
|
var user = runBillContext.Users.FirstOrDefault(u => u.GID == b.TRANSFERUSER);
|
|
|
b.USERNAME = user.SHOWNAME;
|
|
|
b.TRANSFERTIME = DateTime.Now;
|
|
|
b.TRANSFERUSER = Convert.ToString(Session["USERID"]);
|
|
|
});
|
|
|
runBillContext.SaveChanges();
|
|
|
|
|
|
|
|
|
|
|
|
if (list.Count == 1)
|
|
|
{
|
|
|
return Json(new { Success = true, Message = "操作成功", Data = list[0].AsEditViewModel() });
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return Json(new { Success = true, Message = "操作成功" });
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//派单
|
|
|
public JsonResult DispatchBill(string strGID)
|
|
|
{
|
|
|
string[] arrGID = strGID.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
var uid = Convert.ToString(Session["USERID"]);
|
|
|
var staComplete = OpSeaeRunBillStatus.Complete.ToString();
|
|
|
var list = runBillContext.OpSeaeRunBills.Where(s => s.STATUS != staComplete && arrGID.Contains(s.GID)).ToList();
|
|
|
|
|
|
if (list.Count == 0)
|
|
|
{
|
|
|
return Json(new { Success = false, Message = "没有可供操作的已选数据" });
|
|
|
}
|
|
|
|
|
|
list.ForEach(b =>
|
|
|
{
|
|
|
b.STATUS = OpSeaeRunBillStatus.Dispatch.ToString();
|
|
|
});
|
|
|
runBillContext.SaveChanges();
|
|
|
|
|
|
//推送消息
|
|
|
logger.Debug("跑单派单，准备推送通知");
|
|
|
string[] arrUser = list.Select(b => "'" + b.USERID + "'").Distinct().ToArray();
|
|
|
string strUserIds = string.Join(",", arrUser);
|
|
|
var users = runBillContext.Database.SqlQuery<VUser>($"select * from vw_user where userid in ({strUserIds})").ToList();
|
|
|
logger.Debug($"推送用户数量：{users.Count}");
|
|
|
foreach (var u in users)
|
|
|
{
|
|
|
logger.Debug($"推送给用户：{u.WeChatAccount}");
|
|
|
if (!string.IsNullOrWhiteSpace(u.WeChatAccount))
|
|
|
{
|
|
|
WorkWeixinSendHelper.SendNotifyToUser(u.WeChatAccount, $"/MvcShipping/MsOpseaeRunBill/WxUserRedirect?userId={u.WeChatAccount}");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (list.Count == 1)
|
|
|
{
|
|
|
return Json(new { Success = true, Message = "操作成功", Data = list[0].AsEditViewModel() });
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return Json(new { Success = true, Message = "操作成功" });
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//跑单完成
|
|
|
public JsonResult CompleteBill(string strGID)
|
|
|
{
|
|
|
string[] arrGID = strGID.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
|
|
|
var uid = Convert.ToString(Session["USERID"]);
|
|
|
var staAccept = OpSeaeRunBillStatus.Accept.ToString();
|
|
|
var list = runBillContext.OpSeaeRunBills.Where(s => s.STATUS == staAccept && arrGID.Contains(s.GID)).ToList();
|
|
|
list.ForEach(b =>
|
|
|
{
|
|
|
b.COMPLETETIME = DateTime.Now;
|
|
|
b.STATUS = OpSeaeRunBillStatus.Complete.ToString();
|
|
|
});
|
|
|
runBillContext.SaveChanges();
|
|
|
return Json(new { Success = true, Message = "操作成功" });
|
|
|
}
|
|
|
|
|
|
public ActionResult TokenShow()
|
|
|
{
|
|
|
var c = MemoryCache.Default.Contains(WechatWorkTokenJob.WorkWeixinAccessTokenStoreKey);
|
|
|
if (c)
|
|
|
{
|
|
|
return Content($"{c}, {MemoryCache.Default[WechatWorkTokenJob.WorkWeixinAccessTokenStoreKey].ToString()}");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return Content($"{c}");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#region 企业号
|
|
|
//跳转
|
|
|
public ActionResult WxRedirect(string code, string state)
|
|
|
{
|
|
|
if (!MemoryCache.Default.Contains(WechatWorkTokenJob.WorkWeixinAccessTokenStoreKey))
|
|
|
{
|
|
|
return Content("token失效，请联系管理员");
|
|
|
}
|
|
|
|
|
|
string token = MemoryCache.Default[WechatWorkTokenJob.WorkWeixinAccessTokenStoreKey].ToString();
|
|
|
|
|
|
string resp = WebRequestHelper.DoGet($"https://qyapi.weixin.qq.com/cgi-bin/user/getuserinfo?access_token={token}&code={code}");
|
|
|
|
|
|
var jsonObj = JsonConvert.DeserializeAnonymousType(resp, new
|
|
|
{
|
|
|
errcode = 0,
|
|
|
errmsg = "",
|
|
|
UserId = ""
|
|
|
});
|
|
|
|
|
|
if (jsonObj.errcode == 0)
|
|
|
{
|
|
|
return WxUserRedirect(jsonObj.UserId);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return Content("获取用户信息失败，请重试");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public ActionResult WxUserRedirect(string userId)
|
|
|
{
|
|
|
var user = runBillContext.Database.SqlQuery<VUser>("select * from vw_user where wechataccount=@uid", new SqlParameter("uid", userId)).FirstOrDefault();
|
|
|
if (user != null)
|
|
|
{
|
|
|
//获取用户信息，存储到session
|
|
|
Session["USERID"] = user.userid;
|
|
|
Session["SHOWNAME"] = user.SHOWNAME;
|
|
|
Session["COMPANYID"] = user.COMPANYID;
|
|
|
|
|
|
return RedirectToAction("WxRunBillList");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return Content($"未找到用户：{userId}，请联系管理员");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//跑单列表
|
|
|
public ActionResult WxRunBillList()
|
|
|
{
|
|
|
return View();
|
|
|
}
|
|
|
|
|
|
//跑单详情
|
|
|
public ActionResult WxRunBillDetail(string gid)
|
|
|
{
|
|
|
ViewData["gid"] = gid;
|
|
|
return View();
|
|
|
}
|
|
|
|
|
|
public ActionResult WxRunBillDetailData(string gid)
|
|
|
{
|
|
|
var bill = runBillContext.OpSeaeRunBills.FirstOrDefault(b => b.GID == gid);
|
|
|
if (bill != null)
|
|
|
{
|
|
|
var query = from a in runBillContext.OpSeaeRunBillItems
|
|
|
join s in runBillContext.OpSeaes on a.BSNO equals s.BSNO
|
|
|
where a.ParentId == gid
|
|
|
select s;
|
|
|
|
|
|
|
|
|
return Json(new
|
|
|
{
|
|
|
Success = true,
|
|
|
Bill = bill.AsListViewModel(),
|
|
|
Items = query.ToList(),
|
|
|
IsDispatch = bill.STATUS == OpSeaeRunBillStatus.Dispatch.ToString(),
|
|
|
IsAccept = bill.STATUS == OpSeaeRunBillStatus.Accept.ToString(),
|
|
|
IsTransfer = bill.STATUS != OpSeaeRunBillStatus.Complete.ToString()
|
|
|
});
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return Json(new { Success = false });
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public ActionResult WxRunBillTransfer(string gid)
|
|
|
{
|
|
|
ViewData["gid"] = gid;
|
|
|
return View();
|
|
|
}
|
|
|
#endregion
|
|
|
}
|
|
|
} |