dever 6 years ago
parent
commit
6cf8913cce
2 changed files with 13 additions and 10 deletions
  1. 1 0
      applet/database/msg_form.php
  2. 12 10
      applet/src/Msg.php

+ 1 - 0
applet/database/msg_form.php

@@ -106,6 +106,7 @@ return array
 			# 匹配的正则或函数 选填项
 			# 匹配的正则或函数 选填项
 			'option' => array
 			'option' => array
 			(
 			(
+				'project_id' => 'yes',
 				'cdate' => array($time, '<='),
 				'cdate' => array($time, '<='),
 				'state' => 1,
 				'state' => 1,
 			),
 			),

+ 12 - 10
applet/src/Msg.php

@@ -102,20 +102,22 @@ class Msg
 		$emphasis_keyword = Dever::input('emphasis_keyword');
 		$emphasis_keyword = Dever::input('emphasis_keyword');
 		if ($project_id > 0 && $key && $page && $data) {
 		if ($project_id > 0 && $key && $page && $data) {
 			# 获取所有拥有formid的openid,并去重
 			# 获取所有拥有formid的openid,并去重
-			$data = Dever::db('applet/msg_form')->getAllGroupByOpenid();
+			$data = Dever::db('applet/msg_form')->getAllGroupByOpenid(array('option_project_id' => $project_id));
 			print_r($data);die;
 			print_r($data);die;
 			if ($data) {
 			if ($data) {
 				Dever::import('queue');
 				Dever::import('queue');
 				foreach ($data as $k => $v) {
 				foreach ($data as $k => $v) {
-					$param = array();
-					$param['key'] = $key;
-					$param['project_id'] = $project_id;
-					$param['touser'] = $v['openid'];
-					$param['page'] = $page;
-					$param['data'] = $data;
-					$param['form_id'] = $v['form_id'];
-					$param['emphasis_keyword'] = $emphasis_keyword;
-					Dever::push($param);
+					if (is_numeric($v['form_id'])) {
+						$param = array();
+						$param['key'] = $key;
+						$param['project_id'] = $project_id;
+						$param['touser'] = $v['openid'];
+						$param['page'] = $page;
+						$param['data'] = $data;
+						$param['form_id'] = $v['form_id'];
+						$param['emphasis_keyword'] = $emphasis_keyword;
+						Dever::push($param);
+					}
 				}
 				}
 			}
 			}
 		}
 		}