supplier_system/src/dashoo.cn/backend/api/business/workflow/ActivitiService.go

package workflow

import (
	"bufio"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"os"
	"strconv"
	"strings"
	"time"

	"dashoo.cn/utils"

	. "dashoo.cn/utils/db"
	"github.com/go-xorm/xorm"
	. "github.com/linxGnu/goseaweedfs"
)

type ActivitiService struct {
	BaseUrl		string
	AposeUrl	string
	OriginUrl	string
	Username 	string
	Password 	string
	ServiceBase
}

func GetActivitiService(xormEngine *xorm.Engine) *ActivitiService {
	s := new(ActivitiService)
	s.DBE = xormEngine
	//s.BaseUrl = "http://123.56.168.26:8080/activiti-rest/service"
	//s.BaseUrl = "http://localhost:8081/api/acti"
	s.BaseUrl = "http://47.92.212.59:8080/acti-api/api/acti"
	//s.BaseUrl = "http://localhost:8081/api/acti"
	s.AposeUrl = "http://47.92.212.59:8080/acti-api/api/apose"
	//s.OriginUrl = "http://localhost:8081/api"
	s.OriginUrl = "http://47.92.212.59:8080/acti-api/api"
	//s.AposeUrl = "http://localhost:8081/api/apose"
	//s.AposeUrl = "http://192.168.0.171:8081/api/apose"
	s.Username = "leader"
	s.Password = "123456"
	return s
}

func (this *ActivitiService) Post(url string, params string, token string) *http.Response {
	client := &http.Client{}
	req, err := http.NewRequest("POST", this.BaseUrl+url, strings.NewReader(params))
	req.Header.Add("Content-Type", "application/json")
	req.Header.Add("Authorization", "Bearer "+token)
	resp, err := client.Do(req)
	if err != nil {
		log.Println("err= ", err)
	}
	log.Println("resp= ", resp)
	return resp
}

func (this *ActivitiService) Post2(url string, params string, token string) *http.Response {
	client := &http.Client{}
	req, err := http.NewRequest("POST", this.AposeUrl+url, strings.NewReader(params))
	req.Header.Add("Content-Type", "application/json")
	req.Header.Add("Authorization", "Bearer "+token)
	resp, err := client.Do(req)
	if err != nil {
		log.Println("err= ", err)
	}
	log.Println("resp= ", resp)
	return resp
}
func (this *ActivitiService) PostOrigin(url string, params string, token string) *http.Response {
	client := &http.Client{}
	req, err := http.NewRequest("POST", this.OriginUrl+url, strings.NewReader(params))
	req.Header.Add("Content-Type", "application/json")
	req.Header.Add("Authorization", "Bearer "+token)
	resp, err := client.Do(req)
	if err != nil {
		log.Println("err= ", err)
	}
	log.Println("resp= ", resp)
	return resp
}

func (this *ActivitiService) Get(url string, params string, token string) *http.Response {
	client := &http.Client{}
	req, err := http.NewRequest("Get", this.BaseUrl+url, strings.NewReader(params))
	req.Header.Add("Content-Type", "application/json")
	req.Header.Add("Authorization", "Bearer "+token)
	resp, err := client.Do(req)
	if err != nil {
		log.Println("err= ", err)
	}
	log.Println("resp= ", resp)
	return resp
}

func (this *ActivitiService) StartProcess(processKey string, formEntityId string, userNames string) string {
	/*vars := make(map[string]string)
	vars["processDefinitionKey"] = processKey
	vars["formEntityId"] = formEntityId*/
	/*params := "processDefinitionKey="+processKey+"&formEntityId"+formEntityId*/
	var ActiProcess ActiProcessVM
	ActiProcess.ProcessKey = processKey
	ActiProcess.BusinessKey = formEntityId
	ActiProcess.UserNames = userNames
	json, err := json.Marshal(ActiProcess)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(json)
	fmt.Println(params)
	//token = Authorization(this.Username, this.Password)
	retVal := this.Post("/start-process", params, "")
	p, _ := ioutil.ReadAll(retVal.Body)
	return string(p)
}

//func (this *ActivitiService) TaskComplete(processKey string, formEntityId string, userNames string, userId string, result string, remarks string) string {
	/*var ActiComplete ActiCompleteVM
	ActiComplete.ProcessKey = processKey
	ActiComplete.BusinessKey = formEntityId
	ActiComplete.UserNames = userNames
	ActiComplete.UserId = userId
	ActiComplete.Result = result
	ActiComplete.Remarks = remarks*/

func (this *ActivitiService) TaskComplete(ActiComplete ActiCompleteVM) string {

	jsonParams, err := json.Marshal(ActiComplete)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(jsonParams)
	fmt.Println(params)
	//token = Authorization(this.Username, this.Password)
	retVal := this.Post("/task-complete", params, "")
	p, _ := ioutil.ReadAll(retVal.Body)
	return string(p)
}

/*func (this *ActivitiService) MultiTaskComplete(processKey string, formEntityId string, userNames string, multiOrgAudits []MultiOrgAuditVM, userId string, result string, remarks string, callbackUrl string) string {

	var ActiComplete MultiActiCompleteVM
	ActiComplete.ProcessKey = processKey
	ActiComplete.BusinessKey = formEntityId
	ActiComplete.UserNames = userNames
	ActiComplete.MultiOrgAudits = multiOrgAudits
	ActiComplete.UserId = userId
	ActiComplete.Result = result
	ActiComplete.Remarks = remarks
	ActiComplete.CallbackUrl = callbackUrl*/

func (this *ActivitiService) MultiTaskComplete(ActiComplete MultiActiCompleteVM) string {

	jsonParams, err := json.Marshal(ActiComplete)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(jsonParams)
	fmt.Println(params)
	//token = Authorization(this.Username, this.Password)
	retVal := this.Post("/multi-task-complete", params, "")
	p, _ := ioutil.ReadAll(retVal.Body)
	return string(p)
}

func (this *ActivitiService) GetMyTasks(processKey string, userId string) string {
	var ActiMyTasks ActiMyTasksVM
	ActiMyTasks.ProcessKey = processKey
	ActiMyTasks.UserId = userId
	json, err := json.Marshal(ActiMyTasks)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(json)
	fmt.Println(params)
	//token = Authorization(this.Username, this.Password)
	retVal := this.Post("/my-tasks", params, "")

	p, _ := ioutil.ReadAll(retVal.Body)
	return string(p)
}

func (this *ActivitiService) GetHistoricTasks(processKey string, businessKey string, processInstanceId string) []ActiHistoricTask {
	var ActiProcess ActiProcessVM
	ActiProcess.ProcessKey = processKey
	ActiProcess.BusinessKey = businessKey
	ActiProcess.ProcessInstanceId = processInstanceId
	jsonParam, err := json.Marshal(ActiProcess)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(jsonParam)
	fmt.Println(params)
	//token = Authorization(this.Username, this.Password)
	retVal := this.Post("/historic-tasks", params, "")
	jsonblob, _ := ioutil.ReadAll(retVal.Body)
	//	var historicTasks []ActiHistoricTask
	historicTasks := make([]ActiHistoricTask, 0)
	json.Unmarshal(jsonblob, &historicTasks)
	return historicTasks
}

func (this *ActivitiService) GetActivitiProccessImage(processInstanceId string) []byte {
	var ActiProcess ActiProcessVM
	ActiProcess.ProcessInstanceId = processInstanceId
	jsonParam, err := json.Marshal(ActiProcess)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(jsonParam)
	//token = Authorization(this.Username, this.Password)
	retVal := this.Post("/historic-tasks-image", params, "")
	imgByte, _ := ioutil.ReadAll(retVal.Body)
	return imgByte
}

func (this *ActivitiService) GetHistoryMyTasks(processKey string, userId string) string {
	var ActiMyTasks ActiMyTasksVM
	ActiMyTasks.ProcessKey = processKey
	ActiMyTasks.UserId = userId
	json, err := json.Marshal(ActiMyTasks)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(json)
	fmt.Println(params)
	//token = Authorization(this.Username, this.Password)
	retVal := this.Post("/my-tasks-finished", params, "")

	p, _ := ioutil.ReadAll(retVal.Body)
	return string(p)
}

func (this *ActivitiService) ExcelToPdf(addressUrl string) string {
	var aposeVM AposeVM
	aposeVM.AddressUrl = addressUrl
	fmt.Println("==addressUrl===", addressUrl)
	jsonParam, err := json.Marshal(aposeVM)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(jsonParam)
	//token = Authorization(this.Username, this.Password)
	retVal := this.Post2("/excel-to-pdf", params, "")
	if retVal.StatusCode != 200 {
		return ""
	}
	//pdfByte, err := ioutil.ReadAll(retVal.Body)
	//ioutil.WriteFile("E:\aa.pdf", pdfByte, 777)
	//模板下载到服务器
	_dir := utils.Cfg.MustValue("file", "tmplateDir") + "pdf"
	utils.CreatePath(_dir)
	_dir += "/tmp_" + strconv.Itoa(int(time.Now().Unix())) + ".pdf"
	raw := retVal.Body
	defer raw.Close()

	file, err := os.Create(_dir)
	defer file.Close()
	writer := bufio.NewWriter(file)
	defer writer.Flush()
	body, err := ioutil.ReadAll(raw)
	writer.Write(body)

	if err != nil {
		return ""
	}
	var sw *Seaweed
	var filer []string
	if _filer := os.Getenv("GOSWFS_FILER_URL"); _filer != "" {
		filer = []string{_filer}
	}
	sw = NewSeaweed("http", utils.Cfg.MustValue("file", "upFileHost"), filer, 2*1024*1024, 5*time.Minute)
	//_, fID, err := sw.Upload(retVal.Body, "tmp.pdf", int64(len(pdfByte)), "", "")
	_, _, fID, err := sw.UploadFile(_dir, "", "")
	retDocUrl := utils.Cfg.MustValue("file", "downFileHost") + "/" + fID
	os.Remove(_dir)
	fmt.Println("==retDocUrl==", retDocUrl)
	return retDocUrl
}


func (this *ActivitiService) FillWordTemplate(datas map[string]interface{}, templateUrl string, fileName string) string {
	var wordTempVM WordTemplateVM
	wordTempVM.Datas = datas
	wordTempVM.TemplateUrl = templateUrl
	wordTempVM.FileName = fileName
	fmt.Println("==templateUrl===", templateUrl)
	jsonParam, err := json.Marshal(wordTempVM)
	if err != nil {
		fmt.Println(err, "生成json字符串错误")
	}
	params := string(jsonParam)
	//token = Authorization(this.Username, this.Password)
	retVal := this.PostOrigin("/word/fill-word", params, "")
	if retVal.StatusCode != 200 {
		return ""
	}
	//pdfByte, err := ioutil.ReadAll(retVal.Body)
	//ioutil.WriteFile("E:\aa.pdf", pdfByte, 777)
	//模板下载到服务器
	_dir := utils.Cfg.MustValue("file", "tmplateDir") + "word"
	utils.CreatePath(_dir)
	_dir += "/tmp_" + strconv.Itoa(int(time.Now().Unix())) + ".docx"
	raw := retVal.Body
	defer raw.Close()

	file, err := os.Create(_dir)
	defer file.Close()
	writer := bufio.NewWriter(file)
	defer writer.Flush()
	body, err := ioutil.ReadAll(raw)
	writer.Write(body)

	if err != nil {
		return ""
	}
	var sw *Seaweed
	var filer []string
	if _filer := os.Getenv("GOSWFS_FILER_URL"); _filer != "" {
		filer = []string{_filer}
	}
	sw = NewSeaweed("http", utils.Cfg.MustValue("file", "upFileHost"), filer, 2*1024*1024, 5*time.Minute)
	//_, fID, err := sw.Upload(retVal.Body, "tmp.pdf", int64(len(pdfByte)), "", "")
	_, _, fID, err := sw.UploadFile(_dir, "", "")
	retDocUrl := utils.Cfg.MustValue("file", "downFileHost") + "/" + fID
	os.Remove(_dir)
	fmt.Println("==retDocUrl==", retDocUrl)
	return retDocUrl
}