serviceManager = $serviceManager; $this->init(); return $this; } private function init() { $dbService = $this->serviceManager->get('Db'); $this->db = $dbService->getPdo(); } public function fetchAll() { $sql='SELECT * FROM emailtext'; $rs=$this->db->query($sql); return $rs->fetchAll(\PDO::FETCH_ASSOC); } //插入邮件模板 public function insert($data) { $temp=$this->fetch($data['template']); if(isset($temp['id']) && is_numeric($temp['id']) && $temp['id']>0) { return '该邮件模板标识已经存在,请更换标识!'; } $dbhService = $this->serviceManager->get('Db'); $dbh = $dbhService->getDbh(); if(empty($data['subject'])) { $data['subject']='未命名模板'; } $rs = $dbh->insert('emailtext',$data,1); return $rs; } //删除邮件模板 public function del($id) { $sql = "DELETE FROM emailtext WHERE id=$id"; $rs = $this->db->exec($sql); return $rs; } //更新邮件模板 public function update($data,$id) { $temp=$this->fetch($data['template']); if(isset($temp['id']) && is_numeric($temp['id']) && $temp['id']>0) { if($id!=$temp['id']) return '该邮件模板标识已经存在,请更换标识!'; } $dbhService = $this->serviceManager->get('Db'); $dbh = $dbhService->getDbh(); $rs = $dbh->update('emailtext',$data,"id=$id",1); return $rs; } public function fetch($key) { if(is_numeric($key)) { $sql="SELECT * FROM emailtext WHERE id=$key"; }else { $sql="SELECT * FROM emailtext WHERE template='$key'"; } $rs=$this->db->query($sql); return $rs->fetch(); } }