xiugai

entity/entity.go

@@ -122,12 +122,17 @@ func (h *Handler) HandleMessage(m *nsq.Message) error {
 	userPositionId := util.Int64All((*msg)["userPositionId"])
 	entId := util.Int64All((*msg)["entId"])
 	entUserName := util.ObjToString((*msg)["entUserName"])
-	log.Println(userPositionId, entPostionId, entId)
+	entName := ""
+	log.Println(userPositionId, entPostionId, entId, entUserName, entName)
 	if userPositionId == 0 || entPostionId == 0 {
 		log.Println("职位id为空")
 		return nil
 	}
-	ok := JyBiMysql.Update("dwd_f_report_data_baseinfo", map[string]interface{}{"position_id": userPositionId}, map[string]interface{}{"position_id": entPostionId, "ent_id": entId, "position_type": 1, "user_name": entUserName})
+	data := JyMysql.FindOne("entniche_info", map[string]interface{}{"id": entId}, "", "")
+	if data != nil && len(*data) > 0 {
+		entName = util.ObjToString((*data)["name"])
+	}
+	ok := JyBiMysql.Update("dwd_f_report_data_baseinfo", map[string]interface{}{"position_id": userPositionId}, map[string]interface{}{"ent_id": entId, "position_type": 1, "user_name": entUserName, "company_name": entName})
 	if ok {
 		log.Println("个人销售数据同步企业数据成功！！！")
 	} else {