kafka

protected/controllers/AllSubjectController.php

@@ -818,7 +818,7 @@ class AllSubjectController extends Controller{
                                 'examGroupId'=>$exam_data->exam_group_id,
                                 'generateTime'=>time()*1000
                             );
-                            sendDataToKafka("zsyte-academic-generate-report",$kafkaData);
+                            sendDataToKafka("xbkc-academic-generate-report",$kafkaData);
                             $this->sendNoticeToReport($exam_data->exam_group_id);
                             sendDataToKafka("zsy-marking-update-topic",$exam_data->exam_group_id,false);
 
@@ -1221,7 +1221,7 @@ class AllSubjectController extends Controller{
                     'examGroupId'=>$Exam_GroupId,
                     'generateTime'=>time()*1000
                 );
-                sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
             } catch (Exception $e) {
                 //如果操作失败, 数据回滚
                 $transaction->rollback();
@@ -1613,7 +1613,7 @@ class AllSubjectController extends Controller{
                                 'examGroupId'=>$exam_data->exam_group_id,
                                 'generateTime'=>time()*1000
                             );
-                            sendDataToKafka("zsyte-academic-generate-report",$kafkaData);
+                            sendDataToKafka("xbkc-academic-generate-report",$kafkaData);
                             $this->sendNoticeToReport($exam_data->exam_group_id);
                             sendDataToKafka("zsy-marking-update-topic",$exam_data->exam_group_id,false);
 
@@ -2054,7 +2054,7 @@ class AllSubjectController extends Controller{
                     'examGroupId'=>$Exam_GroupId,
                     'generateTime'=>time()*1000
                 );
-                sendDataToKafka("zsyte-academic-generate-report",$kafkaData);
+                sendDataToKafka("xbkc-academic-generate-report",$kafkaData);
                 $this->sendNoticeToReport($Exam_GroupId);
                 sendDataToKafka("zsy-marking-update-topic",$Exam_GroupId,false);
                 $exam_group_data	=	ExamGroup::model()->find('exam_group_id=:exam_group_id',array(':exam_group_id'=>$Exam_GroupId));
@@ -2263,7 +2263,7 @@ class AllSubjectController extends Controller{
                             'examGroupId'=>$exam_data->exam_group_id,
                             'generateTime'=>time()*1000
                         );
-                        sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                        sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
                         $this->sendNoticeToReport($exam_data->exam_group_id);
                         sendDataToKafka("zsy-marking-update-topic",$exam_data->exam_group_id,false);
                         $exam_group_data	=	ExamGroup::model()->find('exam_group_id=:exam_group_id',array(':exam_group_id'=>$exam_data->exam_group_id));

protected/controllers/BacklogController.php

@@ -119,7 +119,7 @@ class BacklogController extends Controller{
                         'exam_group_id'=>$exam_data->exam_group_id,
                         'exam_ids'=>array($exam_id)
                     );
-                    sendDataToKafka('php-product-html',$sendMsg);
+                    sendDataToKafka('xbkc-php-product-html',$sendMsg);
                 }
                 unset($exam_data);
 
@@ -228,7 +228,7 @@ class BacklogController extends Controller{
                         'exam_ids'=>array_values($exam_ids)
                     );
 
-                    sendDataToKafka('php-product-html',$sendMsg);
+                    sendDataToKafka('xbkc-php-product-html',$sendMsg);
                 }
 
                 echo json_encode(array('status'=>1,'count'=>count($rs)));exit;

protected/controllers/ClientController.php

@@ -306,7 +306,7 @@ class ClientController extends Controller
                 'exam_group_id'=>$examGroup['exam_group_id'],
                 'exam_ids'=>array($examId)
             );
-            sendDataToKafka('php-product-html',$sendMsg);
+            sendDataToKafka('xbkc-php-product-html',$sendMsg);
             return array(1, '');
         }
     }

protected/controllers/ExportController.php

@@ -445,7 +445,7 @@ join class c on e.class_id = c.class_id where e.class_id = '{$classId}' and e.ex
                          'complete_rate' => 0.9,
                      );
 
-                     sendDataToKafka('php-product-html',$sendMsg);
+                     sendDataToKafka('xbkc-php-product-html',$sendMsg);
 
                      echo json_encode(array("status"=>0));exit;
                  }

protected/controllers/PaperController.php

@@ -979,7 +979,7 @@
                                             'examGroupId'=>$exam_data->exam_group_id,
                                             'generateTime'=>time()*1000
                                         );
-                                        sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                                        sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
                                         $this->sendNoticeToReport($exam_data->exam_group_id);
                                     }
 
@@ -1667,7 +1667,7 @@
              'examGroupId'=>$Exam_GroupId,
              'generateTime'=>time()*1000
          );
-         sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+         sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
          $this->sendNoticeToReport($Exam_GroupId);
          if(Yii::app()->params['handle_log_on_off'])
          {
@@ -1833,7 +1833,7 @@
                              'examGroupId'=>$exam_data->exam_group_id,
                              'generateTime'=>time()*1000
                          );
-                         sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                         sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
 
                          //发送学生端消息
                          $sendJsonArr=array(
@@ -1984,7 +1984,7 @@
                              'examGroupId'=>$exam_data->exam_group_id,
                              'generateTime'=>time()*1000
                          );
-                         sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                         sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
                          echo 1;exit;
                      } catch (Exception $e) {
                          $transaction->rollback();
@@ -2218,7 +2218,7 @@
                                     'examGroupId'=>$exam_group_id,
                                     'generateTime'=>time()*1000
                                 );
-                                sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                                sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
                                 echo 1;exit;
                             } catch (Exception $e) {
                                 $transaction->rollback();
@@ -2790,7 +2790,7 @@
              'examGroupId'=>$Exam_GroupId,
              'generateTime'=>time()*1000
          );
-         sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+         sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
          if(Yii::app()->params['handle_log_on_off'])
          {
             writeFileLog(jsonEncode(array(
@@ -3176,7 +3176,7 @@
                      'examGroupId'=>$Exam_GroupId,
                      'generateTime'=>time()*1000
                  );
-                 sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                 sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
              } catch (Exception $e) {
                  //如果操作失败, 数据回滚
                  $transaction->rollback();
@@ -3485,7 +3485,7 @@
                                  'examGroupId'=>$exam_data->exam_group_id,
                                  'generateTime'=>time()*1000
                              );
-                             sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                             sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
                              $this->sendNoticeToReport($exam_data->exam_group_id);
 
                              //发送学生端消息
@@ -3641,7 +3641,7 @@
                      'examGroupId'=>$exam_data->exam_group_id,
                      'generateTime'=>time()*1000
                  );
-                 sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                 sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
 
                  if(isset($examGroupData) && $examGroupData->homework==1){
                      //发送学生端消息
@@ -4059,7 +4059,7 @@
                      'examGroupId'=>$examGroupId,
                      'generateTime'=>time()*1000
                  );
-                 sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                 sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
              } catch (Exception $e) {
                  //如果操作失败, 数据回滚
                  $transaction->rollback();
@@ -4316,7 +4316,7 @@
                                          'examGroupId'=>$exam_data->exam_group_id,
                                          'generateTime'=>time()*1000
                                      );
-                                     sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                                     sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
                                      $this->sendNoticeToReport($exam_data->exam_group_id);
 
                                      //发送学生端消息
@@ -4466,7 +4466,7 @@
                                          'examGroupId'=>$exam_data->exam_group_id,
                                          'generateTime'=>time()*1000
                                      );
-                                     sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                                     sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
                                      $this->sendNoticeToReport($exam_data->exam_group_id);
 
                                      //发送学生端消息

protected/controllers/PrintController.php

@@ -4941,7 +4941,7 @@
                 'examGroupId'=>$exam_data->exam_group_id,
                 'generateTime'=>time()*1000
             );
-            sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+            sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
 
 			echo json_encode(array('status'=>1));exit;
 		}
@@ -5503,7 +5503,7 @@
                                 $rs = http('/qxk/marking/exam/reset/'.$exam_group_id,'PUT',$this->schoolId,array(),'cgi');
                                 $rs=json_decode($rs,true);
                                 if(isset($rs['errCode']) && $rs['errCode']=='00'){
-                                    sendDataToKafka('zsyte-marking-reback-exam',array('examGroupId'=>$exam_group_id,'schoolId'=>$this->schoolId));
+                                    //sendDataToKafka('xbkc-marking-reback-exam',array('examGroupId'=>$exam_group_id,'schoolId'=>$this->schoolId));
                                     $transaction->commit();
                                 }else{
                                     throw new Exception($rs['errMsg']);
@@ -10373,7 +10373,7 @@ where e.exam_group_id='".$exam_group_id."'";
                      'exam_group_id'=>$exam_group_id,
                      'exam_ids'=>array($exam_id)
                  );
-                 sendDataToKafka('php-product-html',$sendMsg);
+                 sendDataToKafka('xbkc-php-product-html',$sendMsg);
                  $result['status']=1;
                  $result['msg']='发送成功';
 
@@ -10387,7 +10387,7 @@ where e.exam_group_id='".$exam_group_id."'";
                  'exam_group_id'=>$exam_group_id,
                  'exam_ids'=>array($exam_id)
              );
-             sendDataToKafka('php-product-html',$sendMsg);
+             sendDataToKafka('xbkc-php-product-html',$sendMsg);
              $result['status']=1;
              $result['msg']='发送成功';
          }
@@ -14820,7 +14820,7 @@ where e.exam_group_id='".$exam_group_id."'";
                      'examGroupId'=>$examGroupId,
                      'generateTime'=>time()*1000
                  );
-                 sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                 sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
              }
 
              $this->output(1, "转移成功");
@@ -14847,7 +14847,7 @@ where e.exam_group_id='".$exam_group_id."'";
              'exam_group_id'=>$examGroupId,
              'exam_ids'=>array($examId)
          );
-         sendDataToKafka('php-product-html',$sendMsg);
+         sendDataToKafka('xbkc-php-product-html',$sendMsg);
 
          return true;
      }

protected/controllers/RecordController.php

@@ -1768,7 +1768,7 @@ class RecordController extends Controller{
 
                     $producer = new RdKafka\Producer($conf);
 
-                    $topic = $producer->newTopic("zsyte-academic-offline-generate-report");
+                    $topic = $producer->newTopic("xbkc-academic-offline-generate-report");
 
                     $kafkaData=array(
                         'examGroupId'=>$exam_group_id,

protected/controllers/ThirdController.php

@@ -5508,7 +5508,7 @@ class ThirdController extends Controller
                     'examGroupId'=>$examGroupId,
                     'generateTime'=>time()*1000
                 );
-                sendDataToKafka("zsyte-academic-offline-generate-report",$kafkaData);
+                sendDataToKafka("xbkc-academic-offline-generate-report",$kafkaData);
                 if($error){
                    // Yii::app()->jump->error('导入成功,有部分学生成绩没有导入:'.implode(',',$error));
                     $this->render('import_underline_error',array('data'=>$error));

protected/controllers/WritingController.php

@@ -268,7 +268,7 @@ class WritingController extends Controller
 //                    'gp_group_id'=>$groupId,
 //                    'gp_ids'=>$gpIds
 //                );
-//                sendDataToKafka('php-product-html',$sendMsg);
+//                sendDataToKafka('xbkc-php-product-html',$sendMsg);
 
                 $transaction->commit();
             }catch(Exception $e){
@@ -290,7 +290,7 @@ class WritingController extends Controller
                     'gp_group_id'=>$groupId,
                     'gp_ids'=>$gpIds
                 );
-                sendDataToKafka('php-product-html',$sendMsg);
+                sendDataToKafka('xbkc-php-product-html',$sendMsg);
         }
         if($error){
             echo json_encode(array('status'=>0,'error'=>$error));exit;
@@ -372,7 +372,7 @@ class WritingController extends Controller
             'gp_group_id'=>$model['ew_group_id'],
             'gp_ids'=>array($ew_id)
         );
-        sendDataToKafka('php-product-html',$sendMsg);
+        sendDataToKafka('xbkc-php-product-html',$sendMsg);
 
         echo json_encode(array('status'=>1));exit;
     }
@@ -658,7 +658,7 @@ class WritingController extends Controller
                     'gp_group_id'=>$model['ew_group_id'],
                     'gp_ids'=>$ewIds
                 );
-                sendDataToKafka('php-product-html',$sendMsg);
+                sendDataToKafka('xbkc-php-product-html',$sendMsg);
             }
 
             $transaction->commit();