<gh_stars>0
# -*- coding: utf-8 -*-

#############################################################################
#
# Copyright © <NAME>
# contact: <EMAIL>
#
# This software is a collection of webservices designed to provide a secure
# and scalable framework to build e-commerce websites.
#
# This software is governed by the CeCILL-B license under French law and
# abiding by the rules of distribution of free software. You can use,
# modify and/ or redistribute the software under the terms of the CeCILL-B
# license as circulated by CEA, CNRS and INRIA at the following URL
# " http://www.cecill.info".
#
# As a counterpart to the access to the source code and rights to copy,
# modify and redistribute granted by the license, users are provided only
# with a limited warranty and the software's author, the holder of the
# economic rights, and the successive licensors have only limited
# liability.
#
# In this respect, the user's attention is drawn to the risks associated
# with loading, using, modifying and/or developing or reproducing the
# software by the user in light of its specific status of free software,
# that may mean that it is complicated to manipulate, and that also
# therefore means that it is reserved for developers and experienced
# professionals having in-depth computer knowledge. Users are therefore
# encouraged to load and test the software's suitability as regards their
# requirements in conditions enabling the security of their systems and/or
# data to be ensured and, more generally, to use and operate it in the
# same conditions as regards security.
#
# The fact that you are presently reading this means that you have had
# knowledge of the CeCILL-B license and that you accept its terms.
#
#############################################################################


import datetime
import logging
import ujson

from B2SUtils.db_utils import insert
from B2SUtils.db_utils import update
from B2SUtils.db_utils import execute

def update_or_create_trans(conn, table_name, data, values, where, status):
    try:
        id_trans = update(conn,
                          table_name,
                          where=where,
                          values=values,
                          returning='id')
        if len(id_trans) == 0:
            values['create_time'] = datetime.datetime.now()
            id_trans = insert(conn, table_name, values=values,
                              returning='id')
        else:
            id_trans = id_trans[0]

        # append new content for log
        new_content = ('; ' +
                       status +
                       " : " +
                       ujson.dumps(data))

        update_sql = ("UPDATE %s "
                         "SET content = concat(content, '%s') "
                       "WHERE id = %%s"
                      % (table_name, new_content))
        execute(conn, update_sql, (id_trans[0],))
    except Exception, e:
        logging.error('create %s err: %s', table_name, e)
        raise

    return id_trans[0]
