Browse Source

fix:table修改

duxin 8 months ago
parent
commit
55612c2943
1 changed files with 3 additions and 1 deletions
  1. 3 1
      rpc/consumer/internal/logic/publishinfologic.go

+ 3 - 1
rpc/consumer/internal/logic/publishinfologic.go

@@ -68,8 +68,10 @@ func (l *PublishInfoLogic) PublishInfo(in *consumerinfo.PublishInfoReq) (*consum
 	publishData["ent_name"] = in.EntName
 	//  0:全部;1:待审核;2:待人工审核(敏感词审核不通过||敏感词审核通过);3:自动审核通过;4:人工审核通过;-1:自动审核不通过(机构冻结);-2:人工审核不通过;
 	publishData["status"] = 1
+	table := "information"
 	switch in.MsgType {
 	case 3:
+		table = "supply_info"
 		publishData["contact_overt"] = mc.Int64All(mc.If(in.Contact.Overt == 0, 2, in.Contact.Overt)) //是否公开 默认不公开
 		if in.Deadline != "" {
 			publishData["validity_time"] = in.Deadline //信息有效期
@@ -120,7 +122,7 @@ func (l *PublishInfoLogic) PublishInfo(in *consumerinfo.PublishInfoReq) (*consum
 			publishData["amount"] = mc.Float64All(in.Amount) //中标金额
 		}
 	}
-	id := model.Mysql.Insert("information", publishData)
+	id := model.Mysql.Insert(table, publishData)
 	if id < 1 {
 		res.ErrCode = -1
 		res.ErrMsg = "信息保存失败"