no message

controllers/cygx/report_selection.go

@@ -10,6 +10,7 @@ import (
 	"hongze/hz_crm_api/models/cygx"
 	"hongze/hz_crm_api/models/system"
 	"hongze/hz_crm_api/services"
+	comeinService "hongze/hz_crm_api/services/comein"
 	cygxService "hongze/hz_crm_api/services/cygx"
 	"hongze/hz_crm_api/utils"
 	"os"
@@ -175,6 +176,10 @@ func (this *ReportSelectionController) PreserveAndPublish() {
 			br.ErrMsg = "发布失败,Err:" + err.Error()
 			return
 		}
+
+		if detail.PublishStatus == 1 && detail.VisibleRange == 1 {
+			go comeinService.ComeinUpdateReportSelectionPublish(req.ArticleId, "edit")
+		}
 	}
 	//if req.DoType == 1 {
 	//cygxService.DoThisWeekLastWeekWxTemplateMsg(itemCrs.Title, itemCrs.PublishDate.Format(utils.FormatDateTime), itemCrs.ProductDescription, req.ArticleId, 1)
@@ -957,10 +962,13 @@ func (this *ReportSelectionController) VisibleRange() {
 		if detail.IsSendWxMsg == 0 {
 			cygxService.DoThisWeekLastWeekWxTemplateMsg(detail.Title, detail.PublishDate, detail.ProductDescription, req.ArticleId, 1)
 		}
+
+		go comeinService.ComeinUpdateReportSelectionPublish(articleId, "publish")
 	} else {
 		item.AdminId = detail.AdminId
 		item.AdminName = detail.AdminName
 		item.VisibleRange = 0
+		go comeinService.ComeinUpdateReportSelectionPublish(articleId, "delete")
 	}
 	err = cygx.ReportSelectionVisibleRange(item)
 	if err != nil {

services/comein/comein.go

@@ -352,3 +352,64 @@ func ComeinUpdateActivityPublish(activityId int, action string) {
 	fmt.Println(string(body))
 	return
 }
+
+// 重点公司报告更新，同步到进门财经
+func ComeinUpdateReportSelectionPublish(articleId int, action string) {
+	var err error
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			go alarm_msg.SendAlarmMsg(fmt.Sprint("活动更新，同步到进门财经接口失败，articleId:", articleId, "action", action)+err.Error(), 3)
+		}
+	}()
+
+	postUrl := utils.COMEIN_ACTIVITY_URL + "/open-brm/hz-data/change-notice"
+	params := ComeinUpdateActivityPublishReq{
+		Action:   action,
+		Module:   "key_company_reports",
+		EntityId: articleId,
+	}
+	postData, e := json.Marshal(params)
+	if e != nil {
+		err = errors.New(fmt.Sprint("重点公司报告更新，同步到进门财经失败 Marshal:", e.Error()))
+		return
+	}
+	method := "POST"
+	client := &http.Client{}
+	req, e := http.NewRequest(method, postUrl, strings.NewReader(string(postData)))
+	if e != nil {
+		err = errors.New(fmt.Sprint("重点公司报告更新，同步到进门财经失败 NewRequest:", e.Error()))
+		return
+	}
+	req.Header.Add("Content-Type", "application/json")
+	res, e := client.Do(req)
+	if e != nil {
+		err = errors.New(fmt.Sprint("重点公司报告更新，同步到进门财经失败 client:", e.Error()))
+		return
+	}
+	defer res.Body.Close()
+	body, e := ioutil.ReadAll(res.Body)
+	if e != nil {
+		err = errors.New(fmt.Sprint("重点公司报告更新，同步到进门财经失败 ReadAll:", e.Error()))
+		return
+	}
+	itemApiLog := new(cygx.CygxThreeApiLog)
+	itemApiLog.CreateTime = time.Now()
+	itemApiLog.Source = 1
+	itemApiLog.Url = postUrl
+	itemApiLog.Body = string(postData)
+	itemApiLog.Result = string(body)
+	go cygx.AddCygxThreeApiLog(itemApiLog)
+	var ComeinResp *ComeinUpdateActivityPublishResp
+	e = json.Unmarshal(body, &ComeinResp)
+	if e != nil {
+		err = errors.New(fmt.Sprint("重点公司报告更新，同步到进门财经失败 Unmarshal:", e.Error()))
+		return
+	}
+	if ComeinResp.Code != "0" {
+		err = errors.New(fmt.Sprint("重点公司报告更新，同步到进门财经失败 Code:", ComeinResp.Code))
+		return
+	}
+	fmt.Println(string(body))
+	return
+}