biService/service/operate.go

package service

import (
	"bytes"
	"encoding/json"
	"io/ioutil"
	"log"
	"net/http"

	. "bp.jydev.jianyu360.cn/BaseService/biService/entity"
)

type Operate struct {
	NewId       string
	OperateType int64
}

func (a *Operate) InfoOperate() bool {
	//数据查询
	data := BiService.FindOne("customer_data_ttzl", map[string]interface{}{"id_new": a.NewId}, "", "")
	if data == nil || len(*data) == 0 {
		log.Println("没有找到该数据", a.NewId)
		return false
	}
	sendParam := map[string]interface{}{
		"type": a.OperateType,
	}
	if a.OperateType == 0 {
		//修改
		_, ok := CreateEs(*data)
		if !ok {
			return false
		}
		sendParam["nid"] = a.NewId
	} else {
		//清除es数据 清除mysql数据
		if !DelById("ttbid", a.NewId) || !BiService.Delete("customer_data_ttzl", map[string]interface{}{"id_new": a.NewId}) {
			return false
		}
		projectId := (*data)["projectId"]
		if projectId == "" {
			return true
		}
		sendParam["nid"] = projectId
	}
	marshalData, _ := json.Marshal(sendParam)
	DoPost(UpdataProjectUrl, marshalData)
	return true

}

func DoPost(url string, body []byte) ([]byte, error) {
	req, err := http.NewRequest("POST", url, bytes.NewReader(body))
	if err != nil {
		return nil, err
	}
	req.Header.Add("Content-Type", "application/json;charset=utf-8")
	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		return nil, err
	}
	bs, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}
	defer func() {
		_ = resp.Body.Close()
	}()
	log.Println(url, "调用结果 ", string(bs))
	return bs, nil
}