调整代码

zhangzengfei

2023-06-30 aed40b946f0e5de5aa82d4be47595905065770b0

调整代码

 kingdee/cst.go

@@ -5,13 +5,14 @@
    "encoding/json"
    "fmt"
    "io/ioutil"
    "kingdee-dbapi/config"
    "kingdee-dbapi/logger"
    "kingdee-dbapi/nsqclient"
    "mime/multipart"
    "net/http"
    "strconv"
    "time"

    "kingdee-dbapi/config"
    "kingdee-dbapi/logger"
    "kingdee-dbapi/nsqclient"
)

var JoHeadTemplate = `
@@ -104,7 +105,6 @@
}

func Commit2CSTService(order CSTNsqQuery) (result CSTNsqReply) {
    fmt.Println(order)
    result.Code = -1
    result.FBillNo = order.FBillNo
    result.FNumber = order.FNumber
@@ -128,7 +128,7 @@
        int(order.UseAmount), // 完工入库上限
        int(order.UseAmount), // 完工入库下限
    )
    fmt.Println(joHead)
    //fmt.Println(joHead)
    params := map[string]string{
        "action":  "生产任务单.新增",
        "fuserid": "16394",
@@ -167,7 +167,6 @@
    if rspMsg.ErrCode == 0 {
        result.Code = 200
        result.ICMONo = rspMsg.Data.FBillNo
        result.Message = ""
    } else {
        result.Code = rspMsg.ErrCode
        result.Message = rspMsg.ErrMsg
@@ -179,11 +178,12 @@
func newMultipartRequest(url string, params map[string]string) (*http.Request, error) {
    body := &bytes.Buffer{}
    writer := multipart.NewWriter(body)

    // 设置Boundary, 接口验证了六个-
    err := writer.SetBoundary("------basicHttpClient" + strconv.Itoa(int(time.Now().Unix())))
    if err != nil {
    if err := writer.SetBoundary("------basicHttpClient" + strconv.Itoa(int(time.Now().Unix()))); err != nil {
        fmt.Println(err.Error())
    }

    for key, val := range params {
        _ = writer.WriteField(key, val)
    }
@@ -191,6 +191,10 @@
    writer.Close()

    req, err := http.NewRequest("POST", url, body)
    if err != nil {
        return nil, err
    }

    req.Header.Set("Content-Type", writer.FormDataContentType())
    req.Header.Set("User-Agent", "basicHttpClient/0.0.1")
    req.Header.Set("Connection", "keep-alive")

 main.go

@@ -17,9 +17,7 @@

func main() {
    logger.InitLog("kingdee-dbapi.log", "debug", 15, false)
    logger.Info("kdingdee-dbapi start!")

    os.Setenv("GODEBUG", "tls10default=1")
    logger.Info("kingdee-dbapi start!")

    config.Load()


 nsqclient/client.go

@@ -8,7 +8,6 @@
)

var producerCli Producer
var consumeCli NsqConsumer

func InitNsqProducer() error {
    var err error

 webserver/controller.go

@@ -2,6 +2,7 @@

import (
    "fmt"

    "kingdee-dbapi/kingdee"

    "github.com/gin-gonic/gin"

 webserver/router.go

@@ -4,6 +4,7 @@
    "github.com/gin-gonic/gin"
)

// 测试用web服务
func Serve(port string) {
    r := gin.Default()
    r.GET("/order", OrderList)