271 lines
12 KiB
Python
271 lines
12 KiB
Python
from email.policy import default
|
|
from datetime import datetime
|
|
|
|
from odoo import models, fields, api
|
|
from odoo.exceptions import UserError, ValidationError
|
|
|
|
|
|
class PropertyMeterArchives(models.Model):
|
|
_name = 'property.meter.archives'
|
|
_description = '电表库'
|
|
_order = 'number asc'
|
|
|
|
name = fields.Char(string='仪表编号')
|
|
unit_number = fields.Char(string='单元编号/用途')
|
|
number = fields.Integer(related='epitope_values_id.sequence', string="序号", store=True)
|
|
sequence1 = fields.Integer(string='序号')
|
|
installation_location = fields.Char(string='安装位置')
|
|
is_state = fields.Boolean(string='是否启用')
|
|
type = fields.Selection([('public', '公共'), ('fees', '收费')], string='类型')
|
|
gauge_magnification = fields.Integer(string='仪表倍率', default=1)
|
|
maximum_count = fields.Integer(string='最大位数')
|
|
lessee_id = fields.Many2one('property.tenant.information', string='承租方', store=True, compute='_compute_lessee_id')
|
|
employee_ids = fields.Many2many('hr.employee', string='抄表人')
|
|
epitope_values = fields.Char(string='表位置')
|
|
epitope_values_id = fields.Many2one('yuthon.epitope.values', string='表位置')
|
|
other = fields.Char(string='其他')
|
|
unit = fields.Float(string='当月单价')
|
|
archives_state = fields.Selection([('stop', '停用'), ('use', '正常'), ('rent', '出租')], string='状态', compute='_compute_archives_state', store=True, default='use')
|
|
start_time = fields.Date(string="安装日期")
|
|
end_time = fields.Date(string="拆除日期")
|
|
line_loss = fields.Float(string="线损", default=0.02)
|
|
standards_id = fields.Many2one('yuthon.electricity.setting', string='标准')
|
|
yuthon_property_ids = fields.Many2many('yuthon.property', string='物业信息')
|
|
line_ids = fields.One2many('meter.archives.line', 'archives_id', string='明细行')
|
|
remarks = fields.Text(string='备注')
|
|
state = fields.Selection([('reading', '已抄'), ('unreading', '未抄')], string='抄表状态', default='unreading')
|
|
|
|
# @api.model_create_multi 多条创建
|
|
@api.model
|
|
def create(self, vals):
|
|
record = super().create(vals)
|
|
if 'name' in vals and vals['name']:
|
|
existing_records = self.search([('name', '=', vals['name'])])
|
|
if existing_records:
|
|
raise ValidationError(f"仪表编号 '{vals['name']}' 已存在，请使用其他编号！")
|
|
record.archives_state = 'rent' if record.lessee_id else 'use'
|
|
return record
|
|
|
|
def update_epitope_values(self):
|
|
meter_ids = self.env["property.meter.archives"].browse(
|
|
self._context.get('active_ids', self._context.get('active_id'))
|
|
)
|
|
for meter in meter_ids:
|
|
for property in meter.yuthon_property_ids:
|
|
existing_energy = self.env['yuthon.property.energy'].search([
|
|
('yuthon_property_id', '=', property.id),
|
|
('property_meter_archives_id', '=', meter.id)
|
|
], limit=1)
|
|
if not existing_energy:
|
|
self.env['yuthon.property.energy'].create({
|
|
'property_meter_archives_id': meter.id,
|
|
'yuthon_property_id': property.id,
|
|
})
|
|
|
|
@api.onchange('name')
|
|
def _onchange_line_ids(self):
|
|
if self.line_ids:
|
|
for line in self.line_ids:
|
|
line.name = self.name
|
|
|
|
@api.depends('yuthon_property_ids.lessee_id')
|
|
def _compute_lessee_id(self):
|
|
for record in self:
|
|
if record.yuthon_property_ids:
|
|
record.lessee_id = record.yuthon_property_ids[0].lessee_id
|
|
else:
|
|
record.lessee_id = False
|
|
|
|
def open_record(self):
|
|
return {
|
|
'type': 'ir.actions.act_window',
|
|
'res_model': 'property.meter.archives',
|
|
'res_id': self.id,
|
|
'view_mode': 'form',
|
|
}
|
|
|
|
@api.depends('lessee_id')
|
|
def _compute_archives_state(self):
|
|
for record in self:
|
|
if record.lessee_id:
|
|
record.archives_state = 'rent'
|
|
else:
|
|
record.archives_state = 'use'
|
|
|
|
|
|
|
|
def button_archives_state(self):
|
|
archives_ids = self.env["property.meter.archives"].browse(self._context.get('active_ids', self._context.get('active_id')))
|
|
for record in archives_ids:
|
|
record.archives_state = 'stop'
|
|
|
|
|
|
@api.onchange('current_read', 'last_read')
|
|
def _onchange_current_meter(self):
|
|
for record in self:
|
|
if record.current_read > record.last_read:
|
|
record.current_meter = record.current_read - record.last_read
|
|
else:
|
|
if record.maximum_count > 0:
|
|
max_value = 10 ** record.maximum_count - 1
|
|
record.current_meter = max_value - record.last_read + record.current_read
|
|
else:
|
|
record.current_meter = 0
|
|
|
|
@api.onchange('yuthon_property_ids')
|
|
def _onchange_property(self):
|
|
if not self.line_ids:
|
|
return
|
|
sync_vals = {}
|
|
if self.yuthon_property_ids:
|
|
sync_vals['yuthon_property_ids'] = [(6, 0, self.yuthon_property_ids.ids)]
|
|
if sync_vals:
|
|
self.line_ids.write(sync_vals)
|
|
self.update_epitope_values()
|
|
|
|
|
|
def action_property_meter_wizard(self):
|
|
return {
|
|
"type": "ir.actions.act_window",
|
|
"name": "批量导入物业电表",
|
|
"res_model": "property.meter.wizard",
|
|
"view_mode": "form",
|
|
"target": "new",
|
|
}
|
|
|
|
def reading_publish(self):
|
|
menu_id = self.env['ir.ui.menu'].search([('name', '=', '水表抄表')])
|
|
reading_ids = self.env["property.meter.archives"].browse(self._context.get('active_ids', self._context.get('active_id')))
|
|
for record in reading_ids:
|
|
for employee_id in record.employee_ids:
|
|
url = f'https://oa.thtzjt.com/web#id={self.id}&cids=2&action={menu_id.action.id}&model=property.meter.archives&view_type=list&menu_id={menu_id.id}'
|
|
we_id = self.env['hr.employee'].search([('id', '=', employee_id)]).wecom_userid
|
|
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='notice', user_id=we_id,
|
|
title="通知公告",
|
|
description="您有抄表待处理，请及时处理",
|
|
url=url, btntxt="详细信息")
|
|
|
|
def batch_reading_push(self):
|
|
active_ids = self._context.get('active_ids', [])
|
|
return {
|
|
'name': '电水表推送',
|
|
'type': 'ir.actions.act_window',
|
|
'res_model': 'electric.water.wizard',
|
|
'view_mode': 'form',
|
|
'view_type': 'form',
|
|
'target': 'new',
|
|
'context': {
|
|
'default_meter_ids': [(6, 0, active_ids)]
|
|
}
|
|
}
|
|
|
|
|
|
class MeterArchivesLine(models.Model):
|
|
_name = 'meter.archives.line'
|
|
_description = '电表库明细行'
|
|
_order = 'number asc, sequence asc'
|
|
|
|
archives_id = fields.Many2one('property.meter.archives', string='电表库', required=True, ondelete='cascade')
|
|
# name = fields.Char(string='仪表编号')
|
|
number = fields.Integer(related='epitope_values_id.sequence', string="序号", store=True)
|
|
sequence = fields.Integer(related='archives_id.sequence1', string="表序号", store=True)
|
|
epitope_values_id = fields.Many2one('yuthon.epitope.values', string='表位置')
|
|
lessee_id = fields.Many2one('property.tenant.information', string='承租方')
|
|
yuthon_property_ids = fields.Many2many('yuthon.property', string='物业信息')
|
|
last_meter = fields.Date(string='上次抄表日期')
|
|
last_dosage = fields.Float(string='上次用量', compute="compute_meter_values")
|
|
last_read = fields.Float(string='上次读数', compute="compute_meter_values")
|
|
meter_date = fields.Date(string='任务日期')
|
|
current_meter = fields.Float(string='本次用量', compute='compute_meter_values')
|
|
current_read = fields.Float(string='本次读数')
|
|
unit_number = fields.Char(string='单元编号/用途')
|
|
gauge_magnification = fields.Integer(string='仪表倍率', readonly=True, default=1)
|
|
last_reading_time = fields.Date(string="最后读数时间")
|
|
receivables = fields.Float(string="应收", compute='_compute_receivables', store=True)
|
|
unit = fields.Float(string='当月单价')
|
|
line_loss = fields.Float(string="线损", default=0.02)
|
|
type = fields.Selection([('public', '公共'), ('fees', '收费')], string='类型')
|
|
start_time = fields.Date(string="安装日期")
|
|
end_time = fields.Date(string="拆除日期")
|
|
employee_ids = fields.Many2many('hr.employee', string='抄表人')
|
|
remarks = fields.Text(string='备注')
|
|
archives_state = fields.Selection([('stop', '停用'), ('use', '正常'), ('rent', '出租')], string='状态',
|
|
default='use')
|
|
state = fields.Selection([('reading', '已抄'), ('unreading', '未抄')], string='抄表状态', default='unreading')
|
|
maximum_count = fields.Integer(string='最大位数')
|
|
|
|
@api.depends('line_loss', 'current_meter', 'unit')
|
|
def _compute_receivables(self):
|
|
for record in self:
|
|
if record.line_loss and record.current_meter and record.unit:
|
|
record.receivables = record.current_meter * record.unit * (
|
|
1 + record.line_loss) * record.gauge_magnification
|
|
|
|
def update_meter(self):
|
|
current_year = datetime.now().year
|
|
target_date = datetime(current_year, 9, 1).date()
|
|
domain = [
|
|
('state', '=', 'unreading'), # 只处理未抄的记录
|
|
('meter_date', '<', target_date) # 任务日期在9月之前
|
|
]
|
|
active_ids = self._context.get('active_ids', self._context.get('active_id'))
|
|
if active_ids:
|
|
domain.append(('id', 'in', active_ids))
|
|
unread_meter_lines = self.env['meter.archives.line'].search(domain)
|
|
if unread_meter_lines:
|
|
unread_meter_lines.write({
|
|
'state': 'reading'
|
|
})
|
|
|
|
@api.depends('current_read', 'last_read', 'meter_date', 'maximum_count', 'archives_id')
|
|
def compute_meter_values(self):
|
|
"""合并计算当前用量和上次用量"""
|
|
for line in self:
|
|
if line.current_read >= line.last_read:
|
|
line.current_meter = line.current_read - line.last_read
|
|
else:
|
|
if line.current_read != 0:
|
|
if line.maximum_count > 0:
|
|
max_value = 10 ** line.maximum_count - 1
|
|
line.current_meter = max_value - line.last_read + line.current_read
|
|
else:
|
|
line.current_meter = 0
|
|
else:
|
|
line.current_meter = 0
|
|
|
|
lines = self.search([
|
|
('unit_number', '=', line.unit_number),
|
|
('meter_date', '!=', False)
|
|
], order='meter_date asc')
|
|
|
|
if line in lines:
|
|
idx = lines.ids.index(line.id)
|
|
if idx > 0:
|
|
prev_line = lines[idx - 1]
|
|
line.last_dosage = prev_line.current_meter
|
|
line.last_read = prev_line.current_read
|
|
else:
|
|
line.last_read = 0
|
|
line.last_dosage = 0.0
|
|
else:
|
|
line.last_read = 0
|
|
line.last_dosage = 0.0
|
|
|
|
@api.onchange('yuthon_property_ids')
|
|
def onchange_lessee_id(self):
|
|
for record in self:
|
|
if record.yuthon_property_ids:
|
|
record.lessee_id = record.yuthon_property_ids[0].lessee_id
|
|
else:
|
|
record.lessee_id = False
|
|
|
|
def update_date(self):
|
|
meter_ids = self.env["meter.archives.line"].browse(
|
|
self._context.get('active_ids', self._context.get('active_id')))
|
|
for record in meter_ids:
|
|
record.onchange_lessee_id()
|
|
|
|
class PropertyElectricReading(models.Model):
|
|
_name = 'property.electric.reading'
|
|
current_meter = fields.Float(string='本次用量', tracking=True)
|