调整代码

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")