<?php
namespace app\common\model;
use app\common\util\AppAuth;
use think\Db;
use think\Exception;

class EnergyDeviceElectricityRecord extends Base {

    public function updates($userId){
        $data = request()->post();
        $data['org_id'] = cur_org_id();
        $result = validate('EnergyDeviceElectricityRecord')->check($data,[],'');
        if(true !== $result){
            $this->error = validate('EnergyDeviceElectricityRecord')->getError();
            return false;
        }
        $id = $data['id'];
        unset($data['id']);
        $data['read_yyyy'] = date('Y',strtotime($data['read_time']));
        $data['read_yyyymm'] = date('Ym',strtotime($data['read_time']));
        $data['read_yyyymmdd'] = date('Ymd',strtotime($data['read_time']));
        if($id > 0){
            $data['update_time'] = date('Y-m-d H:i:s');

            $ret = $this->allowField(true)->save($data,['id'=>$id]);
        }else{
            //        查询上次录入
            $re = $this->where('sn',$data['sn'])
                ->order('read_time','desc')
                ->where('del',0)
                ->limit(1)
                ->find();
            if ($re){
                if (intval($data['degree']) < intval($re['degree'])){
                    $this->error ='本次抄表度数小于上次录入数据，请检查后重新录入';
                    return false;
                }
            }
            $warning =model('EnergyElectricityRecord')->warning('energy_device_electricity_record',$data);
            $data['create_time'] = date('Y-m-d H:i:s');
            $data['user_id'] = $userId;
            $ret = $this->allowField(true)->save($data);
        }
        if(!$ret){
            $this->error = '操作失败';
            return false;
        }
        return true;
    }

}