wip:企业查询去重提交

jyBXSubscribe/api/bxsubscribe.api

@@ -26,6 +26,9 @@ type (
 		Subtype    string `json:"subtype,optional"`
 		Price      string `json:"price,optional"`
 		FileExists string `json:"fileExists,optional"`
+		Source     int  `json:"source,optional"`   //信息来源
+        IsRead     int  `json:"isRead,optional"`    //是否已读
+        Staffs     string `json:"staffs,optional"` //分发的员工
 		UserType   string `path:"userType,default=fType,options=fType|vType|mType|eType"` //fType：普通用户；vType：超级订阅用户；mType：大会员用户；eType：商机管理用户；
 		NewUserId  int64  `header:"newUserId"`
 		IsEnt      bool   `json:"isEnt,optional"`
@@ -120,4 +123,4 @@ service bxsubscribe-api {
 	post /jybx/subscribe/:userType/distributor(DistributorReq) returns (commonResp)
 	@handler viewStatus
 	post /jybx/subscribe/:userType/viewStatus(viewStatusReq) returns (commonResp)
-}
+}

jyBXSubscribe/rpc/bxsubscribe.proto

@@ -19,11 +19,14 @@ message SubscribeInfosReq {
   string  appId = 13;
   string  price = 14;
   string  fileExists = 15;
-  string  entUserId = 16;
-  string deptId = 17;
-  int64 newUserId = 18;
-  bool IsEnt = 19;
-  string SelectIds = 20;
+  string  isRead = 16; //是否已读
+  string  staffs = 17;//分发人员
+  string  source = 18; //信息来源
+  string  entUserId = 19;
+  string  deptId = 20;
+  int64 newUserId = 21;
+  bool IsEnt = 22;
+  string SelectIds = 23;
 }
 
 message SubscribeInfosResp {
@@ -185,6 +188,14 @@ message GetDistributorReq{
   string  queryType = 6;
 }
 
+message MsgDistributorReq{
+  string  appId = 1;
+  string  entId = 2;
+  string  entUserId = 3;
+  string  messageId = 4;//分发信息
+  string  staffs = 5; //分发的员工
+}
+
 message KeyResp {
   int64 err_code = 1;
   string err_msg = 2;
@@ -216,10 +227,10 @@ message ViewStatusResp {
   repeated UserStatus items = 3;//分发人员
 }
 message UserStatus {
-  string name =1;
-  int64 id =2;
-  int64 isvisit =3;
-  int64 visittime =4;
+  string name = 1;
+  int64 id = 2;
+  int64 isvisit = 3;
+  int64 visittime = 4;
 }
 
 
@@ -236,7 +247,9 @@ service Bxsubscribe {
   rpc SetRead(SetReadReq)returns(StatusResp);
   //关键词获取
   rpc GetKey(GetKeyReq)returns(KeyResp);
-  //手动分发人员
+  //信息分发
+  rpc MsgDistributor(MsgDistributorReq)returns(StatusResp);
+  //手动分发人员查询
   rpc GetDistributor(GetDistributorReq)returns(DistributorResp);
   //查看状态
   rpc GetViewStatus(GetViewStatusReq)returns(ViewStatusResp);