package kingdee
|
|
import (
|
"bytes"
|
"encoding/json"
|
"fmt"
|
"io/ioutil"
|
"mime/multipart"
|
"net/http"
|
"strconv"
|
"time"
|
|
"kingdee-dbapi/config"
|
"kingdee-dbapi/logger"
|
"kingdee-dbapi/nsqclient"
|
)
|
|
var JoHeadTemplate = `
|
{
|
"fdate": "%s", //日期 当天日期
|
"ftype": 1054, //固定值
|
"forderinterid": 0, //固定值
|
"fpporderinterid": 0, //固定值
|
"fparentinterid": 0, //固定值
|
"fsupplyid": 0, //固定值
|
"fplanconfirmed": 0, //计划确认
|
"fplanmode": 14036, //计划模式
|
"fworktypeid": 55, //生产类型
|
"fmrp": 1052, //单据来源
|
"fbomcategory": 36820, //BOM 类别
|
"fcardclosed": 1059, //流转卡关联关闭
|
"fprintcount": 0, //打印次数
|
"ffinclosed": 0, //财务结算标志
|
"ffinclosedate": "", //财务结算日期
|
"ffincloseer": 0, //财务结算人
|
"fmtono": " ", //计划跟踪号:
|
"fauxqtyforitem": 0, //因料报废数量
|
"funitid": 0, //单位 接口自动获取, 设置成0就可以
|
"fcostobjid": 0, //成本对象 , 接口自动获取, 设置成0就可以
|
"fbominterid": 0, //BOM编号 接口自动获取, 设置成0就可以
|
"fbillerid": 16394, //与制单人一致
|
"fplancategory": 2, //计划类别
|
"fcheckdate": "%s", //制单日期
|
"fstartdate": "%s", //开工日期
|
"ffinishdate": "%s", //完工日期
|
"fplancommitdate": "%s", //计划开工日期
|
"fplanfinishdate": "%s", //计划完工日期
|
"fitemid": "%s->", //物料编码 *
|
"fworkshop": "%s->", //生产车间编号
|
"fauxqty": %d, //计划生产数量
|
"fauxinhighlimitqty": %d, //完工入库上限
|
"fauxinlowlimitqty": %d, //完工入库下限
|
"finhighlimit": 0, //完工入库超收比例
|
"finlowlimit": 0 //完工入库欠收比例
|
}
|
`
|
|
type CSTNsqQuery struct {
|
FBillNo string `json:"FBillNo"` // 订单编号
|
FNumber string `json:"FNumber"` // 物料代码
|
FSource string `json:"FSource"` // 生产车间代码
|
FStartDate string `json:"FStartDate"` // 开工日期
|
FFinishDate string `json:"FFinishDate"` // 完工日期
|
UseAmount float64 `json:"UseAmount"` // 使用数量
|
}
|
|
type CSTNsqReply struct {
|
FBillNo string `json:"FBillNo"` // 订单编号
|
FNumber string `json:"FNumber"` // 物料代码
|
ICMONo string `json:"ICMONo"` // 金蝶系统的生产任务单编号
|
Code int `json:"code"` // CST接口返回的code, 成功200
|
Message string `json:"message"` // 失败的错误信息
|
}
|
|
type CSTServiceResponse struct {
|
ErrCode int `json:"errcode"`
|
ErrMsg string `json:"errmsg"`
|
Data struct {
|
FBillNo string `json:"fbillno"`
|
FBillId string `json:"fbillid"`
|
FTranType string `json:"ftrantype"`
|
FClassTypeId int `json:"fclasstypeid"`
|
} `json:"data"`
|
}
|
|
func CSTQueryHandle(msg []byte) error {
|
var query []CSTNsqQuery
|
var reply []CSTNsqReply
|
|
if err := json.Unmarshal(msg, &query); err != nil {
|
logger.Warn("解析请求失败, %s", err.Error())
|
return err
|
}
|
logger.Debug("接收到创建生产任务单请求, 共%d条订单", len(query))
|
|
for _, q := range query {
|
ret := Commit2CSTService(q)
|
reply = append(reply, ret)
|
}
|
|
replyData, _ := json.Marshal(reply)
|
ok := nsqclient.Produce(config.Options.CSTReplyTopic, replyData)
|
logger.Warn("应答查询请求结果:%t, key:%s", ok, replyData)
|
|
return nil
|
}
|
|
func Commit2CSTService(order CSTNsqQuery) (result CSTNsqReply) {
|
result.Code = -1
|
result.FBillNo = order.FBillNo
|
result.FNumber = order.FNumber
|
|
if result.FBillNo == "" || result.FNumber == "" {
|
result.Message = "订单编号或物料编号不能为空"
|
return
|
}
|
|
today := time.Now().Format("2006-01-02")
|
joHead := fmt.Sprintf(JoHeadTemplate,
|
today, // 日期
|
today, // 制单日期
|
order.FStartDate, // 开工日期
|
order.FFinishDate, // 完工日期
|
order.FStartDate, // 计划开工日期
|
order.FFinishDate, // 计划完工日期
|
order.FNumber, // 物料编码
|
order.FSource, // 生产车间编码
|
int(order.UseAmount), // 生产数量
|
int(order.UseAmount), // 完工入库上限
|
int(order.UseAmount), // 完工入库下限
|
)
|
//fmt.Println(joHead)
|
params := map[string]string{
|
"action": "生产任务单.新增",
|
"fuserid": "16394",
|
"jo_head": joHead,
|
"ja_body": "[{}]",
|
}
|
|
request, err := newMultipartRequest(config.Options.CSTWebApi, params)
|
if err != nil {
|
result.Message = err.Error()
|
return
|
}
|
|
client := &http.Client{}
|
resp, err := client.Do(request)
|
if err != nil {
|
result.Message = err.Error()
|
return
|
}
|
|
defer resp.Body.Close()
|
|
body, err := ioutil.ReadAll(resp.Body)
|
if err != nil {
|
result.Message = err.Error()
|
return
|
}
|
|
var rspMsg CSTServiceResponse
|
err = json.Unmarshal(body, &rspMsg)
|
if err != nil {
|
result.Message = err.Error()
|
return
|
}
|
|
if rspMsg.ErrCode == 0 {
|
result.Code = 200
|
result.ICMONo = rspMsg.Data.FBillNo
|
} else {
|
result.Code = rspMsg.ErrCode
|
result.Message = rspMsg.ErrMsg
|
}
|
|
return
|
}
|
|
func newMultipartRequest(url string, params map[string]string) (*http.Request, error) {
|
body := &bytes.Buffer{}
|
writer := multipart.NewWriter(body)
|
|
// 设置Boundary, 接口验证了六个-
|
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)
|
}
|
|
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")
|
req.Header.Set("Accept", "*/*")
|
|
return req, err
|
}
|
