# # -*- coding: utf-8 -*- # # import json # # from odoo import http, exceptions # from odoo.http import request # # from .. import defs # from .base import BaseController # # import logging # # _logger = logging.getLogger(__name__) # # # class WxappOrder(http.Controller, BaseController): # # @http.route('//order/create', # auth='public', methods=['POST'], csrf=False, type='http') # def create(self, sub_domain, **kwargs): # token = kwargs.pop('token', None) # try: # res, wechat_user, entry = self._check_user(sub_domain, token) # if res:return res # # # [{"goodsId":1,"number":3,"propertyChildIds":"1:1,2:4,","logisticsType":0, "inviter_id":0}] # goods_json = json.loads(kwargs.pop('goodsJsonStr')) # province_id = int(kwargs.pop('provinceId')) # city_id = int(kwargs.pop('cityId')) # district_id = int(kwargs.pop('districtId')) if 'districtId' in kwargs.keys() else False # zipcode = kwargs.pop('code') # link_man = kwargs.pop('linkMan') # calculate = kwargs.pop('calculate', False) # remark = kwargs.pop('remark', '') # # goods_price, logistics_price, total, goods_list = self.parse_goods_json( # goods_json, province_id, city_id, district_id, calculate # ) # # order_dict = { # 'zipcode': zipcode, # 'partner_id': wechat_user.partner_id.id, # 'number_goods': sum(map(lambda r: r['product_uom_qty'], goods_list)), # 'logistics_price': logistics_price, # 'province_id': province_id, # 'city_id': city_id, # 'district_id': district_id, # 'team_id': entry.team_id.id, # 'note': remark, # 'linkman': link_man, # } # order_dict.update(kwargs) # # if calculate: # _data = { # 'score': 0, # 'isNeedLogistics': 1, # 'amountTotle': goods_price, # 'amountLogistics': logistics_price, # } # else: # order = request.env(user=1)['sale.order'].create(order_dict) # for each_goods in goods_list: # each_goods['order_id'] = order.id # request.env(user=1)['sale.order.line'].create(each_goods) # # #mail_template = request.env.ref('wechat_mall_order_create') # #mail_template.sudo().send_mail(order.id, force_send=True, raise_exception=False) # _data = { # "amountReal": order.total, # "dateAdd": order.create_date, # "id": order.id, # "orderNumber": order.name, # "status": defs.OrderResponseStatus.attrs[order.customer_status], # "statusStr": defs.OrderStatus.attrs[order.customer_status], # } # # return self.res_ok(_data) # # except Exception as e: # _logger.exception(e) # return self.res_err(-1, e.name) # # def parse_goods_json(self, goods_json, province_id, city_id, district_id, calculate): # """ # :param goods_json: dict # :param province_id: 省 # :param city_id: 市 # :param district_id: 区 # :return: goods_price, logistics_price, total, goods_list # """ # # [{"goodsId":1,"number":3,"propertyChildIds":"1:1,2:4,","logisticsType":0, "inviter_id":0}] # goods_price, logistics_price = 0.0, 0.0 # goods_list = [] # # goods_id_set = set(map(lambda r: r['goodsId'], goods_json)) # product_list = [] # for data in goods_json: # rs = request.env['product.product'].sudo().search([ # ('product_tmpl_id', '=', data['goodsId']), # ('attr_val_str', '=', data['propertyChildIds']) # ]) # product_list += [p for p in rs] # # template_list = request.env['product.template'].sudo().search([ # ('id', 'in', list(goods_id_set)), # ('wxapp_published', '=', True) # ]) # template_dict = {template.id: template for template in template_list} # # if set(template_dict.keys()) - goods_id_set: # raise exceptions.ValidationError('订单中包含已下架的商品') # # for each_goods in goods_json: # property_child_ids = each_goods.get('propertyChildIds') # amount = each_goods['number'] # transport_type = each_goods['logisticsType'] # template = template_dict[each_goods['goodsId']] # # each_goods_price, each_goods_total, property_str, product = self.calculate_goods_fee(template, amount, property_child_ids, calculate) # each_logistics_price = self.calculate_logistics_fee(template, amount, transport_type, province_id, city_id, district_id) # goods_list.append({ # 'product_id': product.id, # 'price_unit': each_goods_price, # 'product_uom_qty': amount, # }) # goods_price += each_goods_total # logistics_price += each_logistics_price # # return goods_price, logistics_price, goods_price + logistics_price, goods_list # # def calculate_goods_fee(self, goods, amount, property_child_ids, calculate): # property_str = '' # # if 1:#property_child_ids: # property_child_ids = property_child_ids or '' # product = request.env['product.product'].sudo().search([ # ('product_tmpl_id', '=', goods.id), # ('attr_val_str', '=', property_child_ids) # ]) # if not product: # raise exceptions.ValidationError('商品不存在！') # # price = product.get_present_price() # total = price * amount # property_str = product.name # # stores = product.get_present_qty() - amount # if not property_child_ids: # stores = goods.get_present_qty() - amount # # if stores < 0: # raise exceptions.ValidationError('库存不足！') # if stores == 0: # # todo 发送库存空预警 # pass # if not calculate: # product.sudo().change_qty(-amount) # if not property_child_ids: # goods.sudo().change_qty(-amount) # # return price, total, property_str, product # # def calculate_logistics_fee(self, goods, amount, transport_type, province_id, city_id, district_id): # return 0 # # # @http.route('//order/statistics', auth='public', method=['GET']) # def statistics(self, sub_domain, token=None, **kwargs): # ''' # closed = ('closed', u'已关闭') # unpaid = ('unpaid', u'待支付') # pending = ('pending', u'待发货') # unconfirmed = ('unconfirmed', u'待收货') # unevaluated = ('unevaluated', u'待评价') # completed = ('completed', u'已完成') # ''' # try: # res, wechat_user, entry = self._check_user(sub_domain, token) # if res:return res # # orders = request.env['sale.order'].sudo().search([('partner_id', '=', wechat_user.partner_id.id)]) # order_statistics_dict = {order_status: 0 for order_status in defs.OrderStatus.attrs.keys()} # for each_order in orders: # order_statistics_dict[each_order.customer_status] += 1 # # data = { # "count_id_no_reputation": order_statistics_dict['unevaluated'], # "count_id_no_transfer": order_statistics_dict['pending'], # "count_id_close": order_statistics_dict['closed'], # "count_id_no_pay": order_statistics_dict['unpaid'], # "count_id_no_confirm": order_statistics_dict['unconfirmed'], # "count_id_success": order_statistics_dict['completed'] # } # return self.res_ok(data) # # except Exception as e: # _logger.exception(e) # return self.res_err(-1, e.name) # # # @http.route('//order/list', auth='public', method=['GET']) # def list(self, sub_domain, token=None, status=None, **kwargs): # try: # res, wechat_user, entry = self._check_user(sub_domain, token) # if res:return res # # if status is not None: # orders = request.env['sale.order'].sudo().search([ # ('partner_id', '=', wechat_user.partner_id.id), # ('customer_status', '=', defs.OrderRequestStatus.attrs[int(status)]) # ]) # else: # orders = request.env['sale.order'].search([ # ('partner_id', '=', wechat_user.partner_id) # ]) # # data = { # "orderList": [{ # "amountReal": each_order.total, # "dateAdd": each_order.create_date, # "id": each_order.id, # "orderNumber": each_order.name, # "status": defs.OrderResponseStatus.attrs[each_order.customer_status], # "statusStr": defs.OrderStatus.attrs[each_order.customer_status], # } for each_order in orders], # "goodsMap": { # each_order.id: [ # { # "pic": each_goods.product_id.product_tmpl_id.get_main_image(), # } for each_goods in each_order.order_line] # for each_order in orders} # } # return self.res_ok(data) # # except Exception as e: # _logger.exception(e) # return self.res_err(-1, e.name) # # # @http.route('//order/detail', auth='public', method=['GET']) # def detail(self, sub_domain, token=None, id=None, **kwargs): # order_id = id # try: # res, wechat_user, entry = self._check_user(sub_domain, token) # if res:return res # # if not order_id: # return self.res_err(300) # # order = request.env['sale.order'].sudo().search([ # ('partner_id', '=', wechat_user.partner_id.id), # ('id', '=', int(order_id)) # ]) # # if not order: # return self.res_err(404) # # data = { # "code": 0, # "data": { # "orderInfo": { # "amount": order.amount_total, # "amountLogistics": order.logistics_price, # "amountReal": order.total, # "dateAdd": order.create_date, # "dateUpdate": order.write_date, # "goodsNumber": order.number_goods, # "id": order.id, # "orderNumber": order.name, # "remark": order.note, # "status": defs.OrderResponseStatus.attrs[order.customer_status], # "statusStr": defs.OrderStatus.attrs[order.customer_status], # "type": 0, # "uid": 1,#user.id, # "userId": wechat_user.id # }, # "goods": [ # { # "amount": each_goods.price_unit, # "goodsId": each_goods.product_id.product_tmpl_id.id, # "goodsName": each_goods.name, # "id": each_goods.id, # "number": each_goods.product_uom_qty, # "orderId": order.id, # "pic": each_goods.product_id.product_tmpl_id.get_main_image(), # "property": each_goods.product_id.get_property_str(), # } for each_goods in order.order_line # ], # "logistics": { # "address": order.address, # "cityId": order.city_id.id, # "code": order.zipcode, # "dateUpdate": order.write_date, # "districtId": order.district_id.id or 0, # "linkMan": order.linkman, # "mobile": order.mobile, # "provinceId": order.province_id.id, # "shipperCode": order.shipper_id.code if order.shipper_id else '', # "shipperName": order.shipper_id.name if order.shipper_id else '', # "status": 0 if order.shipper_id else '', # "trackingNumber": order.shipper_no if order.shipper_no else '' # }, # }, # "msg": "success" # } # if order.shipper_no: # self.build_traces(order, data) # # return self.res_ok(data["data"]) # # except Exception as e: # _logger.exception(e) # return self.res_err(-1, e.name) # # def build_traces(self, order, data): # pass # # @http.route('//order/close', auth='public', method=['GET']) # def close(self, sub_domain, token=None, orderId=None, **kwargs): # order_id = orderId # try: # res, wechat_user, entry = self._check_user(sub_domain, token) # if res:return res # # if not order_id: # return self.res_err(300) # # order = request.env['sale.order'].sudo().search([ # ('partner_id', '=', wechat_user.partner_id.id), # ('id', '=', int(order_id)) # ]) # # if not order: # return self.res_err(404) # # order.write({'customer_status': 'closed'}) # order.action_cancel() # # #mail_template = request.env.ref('wechat_mall_order_closed') # #mail_template.sudo().send_mail(order.id, force_send=True, raise_exception=False) # # return self.res_ok() # # except Exception as e: # _logger.exception(e) # return self.res_err(-1, e.name) # # # @http.route('//order/delivery', auth='public', method=['GET']) # def delivery(self, sub_domain, token=None, orderId=None, **kwargs): # ''' # 确认收货接口 # ''' # order_id = orderId # try: # res, wechat_user, entry = self._check_user(sub_domain, token) # if res:return res # # if not order_id: # return self.res_err(300) # # order = request.env['sale.order'].sudo().search([ # ('partner_id', '=', wechat_user.partner_id.id), # ('id', '=', int(order_id)) # ]) # # if not order: # return self.res_err(404) # # order.write({'customer_status': 'unevaluated'}) # # #mail_template = request.env.ref('wechat_mall_order_confirmed') # #mail_template.sudo().send_mail(order.id, force_send=True, raise_exception=False) # # return self.res_ok() # # except Exception as e: # _logger.exception(e) # return self.res_err(-1, e.name) # # # @http.route('//order/reputation', auth='public', method=['GET']) # def reputation(self, sub_domain, token=None, order_id=None, reputation=2, **kwargs): # ''' # 评论接口 # { # "token": "xxx", # "orderId": "4", # "reputations": [{ # "id": "4", # "reputation": "2", # "remark": "xxx" # }] # } # ''' # try: # post_json = json.loads(kwargs.pop('postJsonString')) # token = post_json.get('token',None) # order_id = post_json.get('orderId',None) # reputations = post_json.get('reputations',[]) # # res, wechat_user, entry = self._check_user(sub_domain, token) # if res:return res # # if not order_id: # return self.res_err(300) # # order = request.env['sale.order'].sudo().search([ # ('partner_id', '=', wechat_user.partner_id.id), # ('id', '=', int(order_id)) # ]) # # if not order: # return self.res_err(404) # # order.write({'customer_status': 'completed'}) # # for reputation in reputations: # # 保存评论 # pass # # return request.make_response(json.dumps({'code': 0, 'msg': 'success'})) # # except Exception as e: # _logger.exception(e) # return self.res_err(-1, e.name) # # # @http.route('//order/pay', auth='public', method=['POST'], csrf=False) # def pay(self, sub_domain, token=None, orderId=None, **kwargs): # order_id = orderId # try: # res, wechat_user, entry = self._check_user(sub_domain, token) # if res:return res # # if not order_id: # return self.res_err(300) # # order = request.env['sale.order'].sudo().search([ # ('partner_id', '=', wechat_user.partner_id.id), # ('id', '=', int(order_id)) # ]) # # if not order: # return self.res_err(404) # # order.write({'customer_status': 'pending'}) # order.action_confirm() # return request.make_response(json.dumps({'code': 0, 'msg': 'success'})) # # except Exception as e: # _logger.exception(e) # return self.res_err(-1, e.name) #