合同管理系统接口 - 违约合同、更新合同状态、获取担保机构账户等

合同管理系统接口

本接口提供以下功能：

违约合同

/// <summary>
/// 违约合同内容：
/// </summary>
/// <param name='model'>操作数据</param>
/// <returns></returns>
public async Task<CommonResult> BreachOfContract(BreachOfContractModel model)
{
    var result = new CommonResult();
    using (var conn = MySqlHelper.GetConnection())
    {
        conn.Open();
        var tran = conn.BeginTransaction();
        try
        {
            var sql = @"update t_contract set status=@status,contract_breach_date=@contractBreachDate,contract_breach_reason=@contractBreachReason where contract_id=@contractId";
            var count = await conn.ExecuteAsync(sql, new { status = model.Status, contractBreachDate = model.ContractBreachDate, contractBreachReason = model.ContractBreachReason, contractId = model.ContractId }, tran);
            if (count > 0)
            {
                tran.Commit();
                result.ResultCode = ResultCodeAddMsgKeys.CommonObjectSuccessCode;
                result.ResultMsg = ResultCodeAddMsgKeys.CommonObjectSuccessMsg;
            }
            else
            {
                tran.Rollback();
                result.ResultCode = ResultCodeAddMsgKeys.CommonExceptionCode;
                result.ResultMsg = ResultCodeAddMsgKeys.CommonExceptionMsg;
            }
        }
        catch (Exception ex)
        {
            Logger.Error("违约合同异常", ex);
            tran.Rollback();
            result.ResultCode = ResultCodeAddMsgKeys.CommonExceptionCode;
            result.ResultMsg = ResultCodeAddMsgKeys.CommonExceptionMsg;
        }
    }
    return result;
}

更新合同状态

/// <summary>
/// 更新合同状态
/// </summary>
/// <param name='model'>操作数据</param>
/// <returns></returns>
public async Task<CommonResult> UpdateContractStatus(UpdateContractStatusModel model)
{
    var result = new CommonResult();
    using (var conn = MySqlHelper.GetConnection())
    {
        conn.Open();
        var tran = conn.BeginTransaction();
        try
        {
            var sql = @"update t_contract set status=@status,contract_effective_date=@contractEffectiveDate where contract_id=@contractId";
            var count = await conn.ExecuteAsync(sql, new { status = model.Status, contractEffectiveDate = model.ContractEffectiveDate, contractId = model.ContractId }, tran);
            if (count > 0)
            {
                tran.Commit();
                result.ResultCode = ResultCodeAddMsgKeys.CommonObjectSuccessCode;
                result.ResultMsg = ResultCodeAddMsgKeys.CommonObjectSuccessMsg;
            }
            else
            {
                tran.Rollback();
                result.ResultCode = ResultCodeAddMsgKeys.CommonExceptionCode;
                result.ResultMsg = ResultCodeAddMsgKeys.CommonExceptionMsg;
            }
        }
        catch (Exception ex)
        {
            Logger.Error("更新合同状态异常", ex);
            tran.Rollback();
            result.ResultCode = ResultCodeAddMsgKeys.CommonExceptionCode;
            result.ResultMsg = ResultCodeAddMsgKeys.CommonExceptionMsg;
        }
    }
    return result;
}

获取担保机构账户

/// <summary>
/// 获取担保机构账户
/// </summary>
/// <param name='guaranteeId'>担保机构ID</param>
/// <returns></returns>
public async Task<List<GuaranteeAccountModel>> GetGuaranteeAccount(string guaranteeId)
{
    var result = new List<GuaranteeAccountModel>();
    var sql = @"select ga.account_id,ga.guarantee_id,ga.account_type,ga.account_no,ga.account_name,ga.open_bank,ga.open_bank_province,ga.open_bank_city,ga.create_time,ga.create_user_id,ga.update_time,ga.update_user_id,ga.version 
                        from t_guarantee_account ga
                        where ga.guarantee_id=@guaranteeId";
    using (var conn = MySqlHelper.GetConnection())
    {
        result = await conn.QueryAsync<GuaranteeAccountModel>(sql, new { guaranteeId });
    }
    return result;
}

根据合同ID获取合同信息

/// <summary>
/// 根据合同ID获取合同信息
/// </summary>
/// <param name='contractId'>合同ID</param>
/// <returns></returns>
public async Task<ContractModel> GetContractById(string contractId)
{
    var result = new ContractModel();
    var sql = @"select * from t_contract where contract_id=@contractId";
    using (var conn = MySqlHelper.GetConnection())
    {
        result = await conn.QueryFirstOrDefaultAsync<ContractModel>(sql, new { contractId });
    }
    return result;
}

根据订单ID获取订单信息

/// <summary>
/// 根据订单ID获取订单信息
/// </summary>
/// <param name='orderId'>订单ID</param>
/// <returns></returns>
public async Task<OrderModel> GetOrderById(string orderId)
{
    var result = new OrderModel();
    var sql = @"select * from t_order where order_id=@orderId";
    using (var conn = MySqlHelper.GetConnection())
    {
        result = await conn.QueryFirstOrDefaultAsync<OrderModel>(sql, new { orderId });
    }
    return result;
}