asign.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548
  1. package asign
  2. import (
  3. "bytes"
  4. "encoding/json"
  5. "fmt"
  6. "mtp20access/global"
  7. "os/exec"
  8. "strings"
  9. "go.uber.org/zap"
  10. )
  11. // 签名规范:
  12. //
  13. // 1、表单提交方式:form-data
  14. // 2、请求头部参数
  15. // 参数1:sign(签名值,具体算法参考一下的前面算法)
  16. // 参数2:timestamp(时间戳,13位)
  17. // 3、请求体参数:
  18. // 参数1:appId(appId值,每个接入者唯一一个)
  19. // 参数2:timestamp(时间戳,13位,与上述一致)
  20. // 参数3:bizData(json字符串,举个例子,比方说要传合同编号如:{"contractNo":"0001"})
  21. // 4、签名算法:
  22. // 4.1、将上述3所属的bizData(json字符串),按照阿拉伯字母排序(如:{"ba":1,"ac":2}--->{"ac":2,"ba":1}),
  23. // 4.2、将4.1排序后的字符串,将【bizData+md5(bizData)+ appId + timestatmp】拼接后利用RSA非对称加密算法(SHA1withRSA),计算出最后的签名sign,对其base64编码,放入head的key(sign)中。
  24. // func getSignature(bizData string, appId string, privateKeyPEM string) (signatureBase64 string, timestamp string, err error) {
  25. // timestamp = strconv.FormatInt(time.Now().UnixMilli(), 10)
  26. // privateKeyBlock, _ := pem.Decode([]byte(privateKeyPEM))
  27. // // if privateKeyBlock == nil || privateKeyBlock.Type != "RSA PRIVATE KEY" {
  28. // if privateKeyBlock == nil {
  29. // err = errors.New("签名失败: Error decoding private key PEM")
  30. // return
  31. // }
  32. // // 解析 PKCS#8 格式的私钥
  33. // privateKey, err := x509.ParsePKCS1PrivateKey(privateKeyBlock.Bytes)
  34. // if err != nil {
  35. // fmt.Println("Failed to parse private key:", err)
  36. // return
  37. // }
  38. // // md5(bizData)
  39. // m := md5.New()
  40. // m.Write([]byte(bizData))
  41. // bdMd5Hx := hex.EncodeToString(m.Sum(nil))
  42. // // 待签内容
  43. // message := bizData + bdMd5Hx + appId + timestamp
  44. // // 使用私钥进行签名
  45. // hashed := sha256.Sum256([]byte(message))
  46. // signature, err := rsa.SignPKCS1v15(nil, privateKey, crypto.SHA256, hashed[:])
  47. // if err != nil {
  48. // fmt.Println("Error signing:", err)
  49. // return
  50. // }
  51. // // fmt.Println(signature)
  52. // signatureBase64 = base64.StdEncoding.EncodeToString(signature)
  53. // return
  54. // }
  55. // type pySignReqData struct {
  56. // ReqBodyData string `json:"reqBodyData"`
  57. // Timestamp string `json:"timestamp"`
  58. // AppId string `json:"appId"`
  59. // AppKey string `json:"appKey"`
  60. // }
  61. // func getSignatureByPy(bizData string, appId string, privateKeyPEM string) (signatureBase64 string, timestamp string, err error) {
  62. // // md5(bizData)
  63. // m := md5.New()
  64. // m.Write([]byte(bizData))
  65. // bdMd5Hx := hex.EncodeToString(m.Sum(nil))
  66. // timestamp = strconv.FormatInt(time.Now().UnixMilli(), 10)
  67. // // timestamp = "1691559290641"
  68. // // 待签内容
  69. // message := bizData + bdMd5Hx + appId + timestamp
  70. // // 构建请求数据结构
  71. // reqData := pySignReqData{
  72. // ReqBodyData: message,
  73. // Timestamp: timestamp,
  74. // AppId: appId,
  75. // AppKey: privateKeyPEM,
  76. // }
  77. // // 将请求数据转换为JSON字符串
  78. // reqJSON, err := json.Marshal(reqData)
  79. // if err != nil {
  80. // global.M2A_LOG.Error("[getSignatureByPy] 构建请求参数失败", zap.Error(err))
  81. // return
  82. // }
  83. // // 要执行的Python脚本命令
  84. // pythonScriptPath := "./py/sign.py"
  85. // // 创建一个命令对象
  86. // cmd := exec.Command("py", pythonScriptPath)
  87. // // 设置标准输入为JSON字符串
  88. // cmd.Stdin = strings.NewReader(string(reqJSON))
  89. // // 获取标准输出
  90. // output, err := cmd.CombinedOutput()
  91. // if err != nil {
  92. // global.M2A_LOG.Error("[getSignatureByPy] 签名失败", zap.Error(err))
  93. // return
  94. // }
  95. // // 获取签名结果
  96. // signatureBase64 = string(output)
  97. // return
  98. // }
  99. type AsignData interface {
  100. AddPersonalUserData | CreateContractData | AddSignerData | DownloadContractData | ContractStatusData
  101. }
  102. // AsignRsp 爱签响应参数
  103. type AsignRsp[T AsignData] struct {
  104. Code int `json:"code"` // 响应码,100000表示成功,其他表示异常
  105. Msg string `json:"msg"` // 响应信息
  106. Data T `json:"data"` // 响应数据
  107. }
  108. // https://preweb.asign.cn/platform/openDoc/docDetail?mid=addPersonalUser
  109. // 添加个人用户(https://{host}/user/addPersonalUser)
  110. // 错误码 错误描述
  111. // 100021 用户已存在
  112. // 100156 手机号码格式错误
  113. // 100157 邮箱格式错误
  114. // 100571 参数错误,唯一识别码Account为空
  115. // 100577 参数错误,{param}长度超过限制:{length}
  116. // 100579 参数错误,{param}不能为空
  117. // 100598 参数错误,身份证号码格式不正确
  118. // 100639 参数错误,名字点号格式不正确
  119. // func AddPersonalUser(account, name, idCard, mobile string, idCardType *int) (rspData AddPersonalUserRsp, err error) {
  120. // apiUrl := global.M2A_CONFIG.Asign.URL + "user/addPersonalUser"
  121. // appId := "290912417"
  122. // privateKey := `MIIBUwIBADANBgkqhkiG9w0BAQEFAASCAT0wggE5AgEAAkEAkMD+72J6iAF0ZNV+3t628lsRHfJ80nKZWK5/C7Pg+AZmOIzJlwHsKhRzCvxoxqYHQprhiFzW9l73v9vD9l1JYwIDAQABAkBVijccr01JYdKuY5t9iI8D2NzcnZc1pZMI3NUmzT18Uyg7b9CUvGHlLeg/gdT4QtVd7wIzHYCY4letEcEMh54BAiEAwzNWusj5XiLmty7PI0Hbakx4HtcND1+P0UHLEWqWOuECIQC91zQuL7nStgGzT3HvaeBB5Ouapa39fHRm2nCjHaxwwwIgRR2XdvmUOj23XWMomr5F14SN/7V7fVcD0D8wjNElsmECIDYavV5kb7tj7/wgqkInlKhzC8rZaUsTS0F9BBkY/eptAiAQJ8Saz8YlMIESdHMxANGSog01fECbcZqLFMuNf8SorA==`
  123. // // 请求参数
  124. // params := make(map[string]interface{})
  125. // params["account"] = account
  126. // params["name"] = name
  127. // params["idCard"] = idCard
  128. // params["idCardType"] = 1
  129. // if idCardType != nil {
  130. // params["idCardType"] = *idCardType
  131. // }
  132. // params["mobile"] = mobile
  133. // // 用户实名认证模式为强制认证时,需要选择认证方法:
  134. // // 1:身份证二要素认证
  135. // // 2:运营商三要素认证
  136. // // 3:银行卡四要素认证
  137. // params["identifyType"] = 2
  138. // params["identifyMobile"] = mobile
  139. // params["isNotice"] = 1
  140. // bizData, err := json.Marshal(params)
  141. // if err != nil {
  142. // global.M2A_LOG.Error("[AddPersonalUser] 构建请求参数失败", zap.Error(err))
  143. // return
  144. // }
  145. // global.M2A_LOG.Info("[AddPersonalUser] 构建请求参数", zap.Any("params", string(bizData)))
  146. // // 签名
  147. // sign, timestamp, err := getSignatureByPy(string(bizData), appId, privateKey)
  148. // sign = strings.Replace(sign, "\r\n", "", -1)
  149. // sign = strings.Replace(sign, "\r", "", -1)
  150. // if err != nil {
  151. // global.M2A_LOG.Error("[AddPersonalUser] 签名失败", zap.Error(err))
  152. // return
  153. // }
  154. // global.M2A_LOG.Info("[AddPersonalUser] 签名", zap.Any("sign", sign))
  155. // // 构建form-data请求参数
  156. // formValues := url.Values{}
  157. // formValues.Set("appId", appId)
  158. // formValues.Set("timestamp", timestamp)
  159. // formValues.Set("bizData", string(bizData))
  160. // // 构建请求
  161. // req, err := http.NewRequest("POST", apiUrl, bytes.NewReader([]byte(formValues.Encode())))
  162. // // 设置请求头
  163. // req.Header.Set("sign", sign)
  164. // req.Header.Set("timestamp", timestamp)
  165. // req.Header.Set("Content-Type", "multipart/form-data; charset=UTF-8")
  166. // req.Header.Set("Accept", "*/*")
  167. // client := &http.Client{}
  168. // rsp, err := client.Do(req)
  169. // if err != nil {
  170. // global.M2A_LOG.Error("[AddPersonalUser] 请求失败", zap.Error(err))
  171. // return
  172. // }
  173. // defer rsp.Body.Close()
  174. // body, err := io.ReadAll(rsp.Body)
  175. // if err != nil {
  176. // global.M2A_LOG.Error("[AddPersonalUser] 获取body失败", zap.Error(err))
  177. // return
  178. // }
  179. // if err = json.Unmarshal(body, &rspData); err != nil {
  180. // global.M2A_LOG.Error("[AddPersonalUser] 反序列化body失败", zap.Error(err))
  181. // return
  182. // }
  183. // return
  184. // }
  185. type AddPersonalUserData struct {
  186. SealNo string `json:"sealNo"` // 默认印章编号
  187. }
  188. // https://preweb.asign.cn/platform/openDoc/docDetail?mid=addPersonalUser
  189. // 添加个人用户(https://{host}/user/addPersonalUser)
  190. // 错误码 错误描述
  191. // 100021 用户已存在
  192. // 100156 手机号码格式错误
  193. // 100157 邮箱格式错误
  194. // 100571 参数错误,唯一识别码Account为空
  195. // 100577 参数错误,{param}长度超过限制:{length}
  196. // 100579 参数错误,{param}不能为空
  197. // 100598 参数错误,身份证号码格式不正确
  198. // 100639 参数错误,名字点号格式不正确
  199. func AddPersonalUserBy(account, name, idCard, mobile string, idCardType *int) (rspData AsignRsp[AddPersonalUserData], err error) {
  200. apiUrl := global.M2A_CONFIG.Asign.URL + "user/addPersonalUser"
  201. // 构建请求数据结构
  202. reqData := make(map[string]interface{})
  203. reqData["account"] = account
  204. reqData["name"] = name
  205. reqData["mobile"] = mobile
  206. reqData["idCard"] = idCard
  207. reqData["idCardType"] = 1
  208. if idCardType != nil {
  209. reqData["idCardType"] = *idCardType
  210. }
  211. reqData["api"] = "addPerson"
  212. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  213. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  214. reqData["apiUrl"] = apiUrl
  215. // 将请求数据转换为JSON字符串
  216. reqJSON, err := json.Marshal(reqData)
  217. if err != nil {
  218. global.M2A_LOG.Error("[AddPersonalUserBy] 构建请求参数失败", zap.Error(err))
  219. return
  220. }
  221. // 要执行的Python脚本命令
  222. pythonScriptPath := "./py/Enter.py"
  223. // 创建一个命令对象
  224. cmd := exec.Command("py", pythonScriptPath)
  225. // 设置标准输入为JSON字符串
  226. cmd.Stdin = strings.NewReader(string(reqJSON))
  227. // 创建一个字节缓冲区来捕获命令的输出
  228. var stdoutBuf, stderrBuf bytes.Buffer
  229. cmd.Stdout = &stdoutBuf
  230. cmd.Stderr = &stderrBuf
  231. // 执行命令
  232. err = cmd.Run()
  233. // 输出标准输出和标准错误
  234. fmt.Println("AddPersonalUserBy 标准输出:", stdoutBuf.String())
  235. fmt.Println("AddPersonalUserBy 标准错误:", stderrBuf.String())
  236. if err != nil {
  237. global.M2A_LOG.Error("[AddPersonalUserBy] 请求失败", zap.Error(err))
  238. return
  239. }
  240. // 结果
  241. rspBody := stdoutBuf.String()
  242. // 正确返回
  243. // {"code":100000,"msg":"�ɹ�","data":{"id":null,"userId":null,"partnerId":null,"type":null,"sealType":null,"sealTypeOfUser":null,"sealName":null,"sealCode":null,"startTime":null,"endTime":null,"sealNo":"9a82d2da479b4430b1da6f7f7cd96aee","sealPassword":null,"sealFont":null,"version":null,"caType":null,"certNo":null,"path":null,"isDefault":null,"status":null,"color":null,"fontSize":null,"imageWidth":null,"imageHeight":null,"imageShape":null,"signTimes":null,"logicDel":null,"createTime":null,"modifyTime":null}}
  244. // 错误返回
  245. // {"code":100021,"msg":"�û��Ѵ��ڣ�����֤�����ظ�","data":{"id":null,"partnerId":null,"account":"100000007","companyAccount":null,"name":null,"companyName":null,"userType":null,"mobile":null,"bankCard":null,"email":null,"idCard":"360428200007287603","idCardType":null,"creditCode":null,"contactName":null,"contactPhone":null,"contactIdCard":null,"isNotice":null,"isAutoSign":null,"signPwd":null,"identifyStatus":null,"identifyMobile":null,"identifyType":null,"userStatus":null,"needSeal":null,"remark":null,"createTime":null,"modifyTime":null,"sealType":null,"authType":null,"serialNo":null}}
  246. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  247. global.M2A_LOG.Error("[AddPersonalUserBy] 反序列化body失败", zap.Error(err))
  248. return
  249. }
  250. return
  251. }
  252. type CreateContractData struct {
  253. PreviewUrl string `json:"previewUrl"` // 合同预览链接
  254. ContractFiles []interface{} `json:"contractFiles"` // 合同文件信息(文件名称,附件编号,页数)
  255. }
  256. /*
  257. *
  258. CreateContract 上传待签署文件
  259. contractNo 合同ID,合同唯一编号
  260. contractName 合同名称
  261. templateNo 合同模板编号
  262. *
  263. */
  264. func CreateContract(contractNo, contractName, templateNo string) (rspData AsignRsp[CreateContractData], err error) {
  265. apiUrl := global.M2A_CONFIG.Asign.URL + "contract/createContract"
  266. // 构建请求数据结构
  267. reqData := make(map[string]interface{})
  268. reqData["contractNo"] = contractNo
  269. reqData["contractName"] = contractName
  270. reqData["validityTime"] = 30
  271. reqData["signOrder"] = 1 // 1:无序签约(默认
  272. reqData["templates"] = []map[string]string{
  273. {"templateNo": templateNo}} // 合同模板编号 - 目前只支持一份合同签一份协议
  274. reqData["notifyUrl"] = global.M2A_CONFIG.Asign.NotifyUrl
  275. reqData["api"] = "createContract"
  276. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  277. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  278. reqData["apiUrl"] = apiUrl
  279. // 将请求数据转换为JSON字符串
  280. reqJSON, err := json.Marshal(reqData)
  281. if err != nil {
  282. global.M2A_LOG.Error("[CreateContract] 构建请求参数失败", zap.Error(err))
  283. return
  284. }
  285. // 要执行的Python脚本命令
  286. pythonScriptPath := "./py/Enter.py"
  287. // 创建一个命令对象
  288. cmd := exec.Command("py", pythonScriptPath)
  289. // 设置标准输入为JSON字符串
  290. cmd.Stdin = strings.NewReader(string(reqJSON))
  291. // 创建一个字节缓冲区来捕获命令的输出
  292. var stdoutBuf, stderrBuf bytes.Buffer
  293. cmd.Stdout = &stdoutBuf
  294. cmd.Stderr = &stderrBuf
  295. // 执行命令
  296. err = cmd.Run()
  297. // 输出标准输出和标准错误
  298. // fmt.Println("标准输入:", string(reqJSON))
  299. fmt.Println("CreateContract 标准输出:", stdoutBuf.String())
  300. fmt.Println("CreateContract 标准错误:", stderrBuf.String())
  301. if err != nil {
  302. global.M2A_LOG.Error("[CreateContract] 请求失败", zap.Error(err))
  303. return
  304. }
  305. // 结果
  306. rspBody := stdoutBuf.String()
  307. // 正确返回:CreateContract 标准输出: {"code":100000,"msg":" ɹ ","data":{"pageSizeMap":{},"signUser":[],"previewUrl":"https://pre.asign.cn/m/#/mobile/previewApiContract/QhUqHj669cOmXIPrJ7eOhSfWh6_oDGlmQ53lOD5OVAvJRvTVpenYICiMWnvbCi4swvNWUIVuO1zPsTvIvHPGuE1fTZ-AQyCeUyWWu7f56Jg?expired=10800000","contractFiles":[]}}
  308. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  309. global.M2A_LOG.Error("[CreateContract] 反序列化body失败", zap.Error(err))
  310. return
  311. }
  312. return
  313. }
  314. // 合同用户信息
  315. type SignUserData struct {
  316. Account string `json:"account"` // 用户唯一识别码
  317. SignUrl string `json:"signUrl"` // 合同签署链接
  318. PwdSignUrl string `json:"pwdSignUrl"` // 密码签署链接
  319. SignOrder int `json:"signOrder"` // 顺序签约的序号
  320. Name string `json:"name"` // 用户姓名
  321. IdCard string `json:"idCard"` // 用户身份证
  322. }
  323. // 添加签署方响应数据
  324. type AddSignerData struct {
  325. ContractNo string `json:"contractNo"` // 合同编号
  326. ContractName string `json:"contractName"` // 合同名称
  327. ValidityTime string `json:"validityTime"` // 合同有效期
  328. PreviewUrl string `json:"previewUrl"` // 合同预览链接
  329. SignUser []SignUserData `json:"signUser"` // 合同用户信息
  330. }
  331. /*
  332. *
  333. AddSigner 添加签署方
  334. contractNo 合同ID,合同唯一编号
  335. account 用户唯一识别码(UserID)
  336. *
  337. */
  338. func AddSigner(contractNo, account string) (rspData AsignRsp[AddSignerData], err error) {
  339. apiUrl := global.M2A_CONFIG.Asign.URL + "contract/addSigner"
  340. // 构建请求数据结构
  341. reqData := make(map[string]interface{})
  342. reqData["contractNo"] = contractNo
  343. reqData["account"] = account
  344. reqData["signType"] = 3
  345. reqData["signStrategyList"] = []map[string]interface{}{
  346. {"attachNo": 1, "locationMode": 4, "signKey": "key_sign_name"},
  347. {"attachNo": 1, "locationMode": 4, "signKey": "key_sign_date"},
  348. }
  349. reqData["api"] = "addSigner"
  350. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  351. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  352. reqData["apiUrl"] = apiUrl
  353. // 将请求数据转换为JSON字符串
  354. reqJSON, err := json.Marshal(reqData)
  355. if err != nil {
  356. global.M2A_LOG.Error("[AddSigner] 构建请求参数失败", zap.Error(err))
  357. return
  358. }
  359. // 要执行的Python脚本命令
  360. pythonScriptPath := "./py/Enter.py"
  361. // 创建一个命令对象
  362. cmd := exec.Command("py", pythonScriptPath)
  363. // 设置标准输入为JSON字符串
  364. cmd.Stdin = strings.NewReader(string(reqJSON))
  365. // 创建一个字节缓冲区来捕获命令的输出
  366. var stdoutBuf, stderrBuf bytes.Buffer
  367. cmd.Stdout = &stdoutBuf
  368. cmd.Stderr = &stderrBuf
  369. // 执行命令
  370. err = cmd.Run()
  371. // 输出标准输出和标准错误
  372. fmt.Println("AddSigner 标准输出:", stdoutBuf.String())
  373. fmt.Println("AddSigner 标准错误:", stderrBuf.String())
  374. if err != nil {
  375. global.M2A_LOG.Error("[AddSigner] 请求失败", zap.Error(err))
  376. return
  377. }
  378. // 结果
  379. // 正确返回:AddSigner 标准输出: {"code":100000,"msg":"�ɹ�","data":{"contractNo":"100000008_20230815145538_10","pageSizeMap":{},"contractName":"���ݲ�Ҷ������ʾ�飨10.31���հ棩","signOrder":1,"validityTime":"2023-09-14","signUser":[{"account":"100000008","signUrl":"https://h5.asign.cn/web/short/eE7zmq515512","signOrder":1,"name":"����̼��","idCard":"110101200007285605","mobile":"15914012153"}],"previewUrl":"https://pre.asign.cn/m/#/mobile/previewApiContract/QhUqHj669cOmXIPrJ7eOhSfWh6_oDGlmQ53lOD5OVAvJRvTVpenYICiMWnvbCi4sS_knh8JQ124Lwf_uxqXkF0-n1uuC18qLy5B8TfAF88g?expired=10800000","contractFiles":[]}}
  380. // 错误返回:AddSigner 标准输出: {"code":100617,"msg":"ģ IJ [key_sign_name] ","data":null}
  381. rspBody := stdoutBuf.String()
  382. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  383. global.M2A_LOG.Error("[AddSigner] 反序列化body失败", zap.Error(err))
  384. return
  385. }
  386. return
  387. }
  388. // 下载合同响应数据
  389. type DownloadContractData struct {
  390. FileName string `json:"fileName"` // 文件名
  391. MD5 string `json:"md5"` // 文件md5值
  392. FileType int `json:"fileType"` // 文件类型 0:PDF 1:ZIP
  393. Size int `json:"size"` // 文件大小
  394. Data string `json:"data"` // Base64字符串
  395. }
  396. /*
  397. DownloadContract 下载合同
  398. contractNo 合同ID,合同唯一编号
  399. */
  400. func DownloadContract(contractNo string) (rspData AsignRsp[DownloadContractData], err error) {
  401. apiUrl := global.M2A_CONFIG.Asign.URL + "contract/downloadContract"
  402. // 构建请求数据结构
  403. reqData := make(map[string]interface{})
  404. reqData["contractNo"] = contractNo
  405. reqData["api"] = "downloadContract"
  406. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  407. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  408. reqData["apiUrl"] = apiUrl
  409. // 将请求数据转换为JSON字符串
  410. reqJSON, err := json.Marshal(reqData)
  411. if err != nil {
  412. global.M2A_LOG.Error("[DownloadContract] 构建请求参数失败", zap.Error(err))
  413. return
  414. }
  415. // 要执行的Python脚本命令
  416. pythonScriptPath := "./py/Enter.py"
  417. // 创建一个命令对象
  418. cmd := exec.Command("py", pythonScriptPath)
  419. // 设置标准输入为JSON字符串
  420. cmd.Stdin = strings.NewReader(string(reqJSON))
  421. // 创建一个字节缓冲区来捕获命令的输出
  422. var stdoutBuf, stderrBuf bytes.Buffer
  423. cmd.Stdout = &stdoutBuf
  424. cmd.Stderr = &stderrBuf
  425. // 执行命令
  426. err = cmd.Run()
  427. // 输出标准输出和标准错误
  428. fmt.Println("DownloadContract 标准输出:", stdoutBuf.String())
  429. fmt.Println("DownloadContract 标准错误:", stderrBuf.String())
  430. if err != nil {
  431. global.M2A_LOG.Error("[DownloadContract] 请求失败", zap.Error(err))
  432. return
  433. }
  434. // 结果
  435. rspBody := stdoutBuf.String()
  436. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  437. global.M2A_LOG.Error("[DownloadContract] 反序列化body失败", zap.Error(err))
  438. return
  439. }
  440. return
  441. }
  442. // 查询合同状态响应数据
  443. type ContractStatusData struct {
  444. ContractNo string `json:"contractNo"` // 合同唯一编号
  445. ContractName string `json:"contractName"` // 合同名称
  446. Status int `json:"status"` // 合同状态:0:等待签约 1:签约中 2:已签约 3:过期 4:拒签 6:作废 -2:状态异常
  447. }
  448. /*
  449. ContractStatus 查询合同状态
  450. contractNo 合同ID,合同唯一编号
  451. */
  452. func ContractStatus(contractNo string) (rspData AsignRsp[ContractStatusData], err error) {
  453. apiUrl := global.M2A_CONFIG.Asign.URL + "contract/status"
  454. // 构建请求数据结构
  455. reqData := make(map[string]interface{})
  456. reqData["contractNo"] = contractNo
  457. reqData["api"] = "contractStatus"
  458. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  459. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  460. reqData["apiUrl"] = apiUrl
  461. // 将请求数据转换为JSON字符串
  462. reqJSON, err := json.Marshal(reqData)
  463. if err != nil {
  464. global.M2A_LOG.Error("[ContractStatus] 构建请求参数失败", zap.Error(err))
  465. return
  466. }
  467. // 要执行的Python脚本命令
  468. pythonScriptPath := "./py/Enter.py"
  469. // 创建一个命令对象
  470. cmd := exec.Command("py", pythonScriptPath)
  471. // 设置标准输入为JSON字符串
  472. cmd.Stdin = strings.NewReader(string(reqJSON))
  473. // 创建一个字节缓冲区来捕获命令的输出
  474. var stdoutBuf, stderrBuf bytes.Buffer
  475. cmd.Stdout = &stdoutBuf
  476. cmd.Stderr = &stderrBuf
  477. // 执行命令
  478. err = cmd.Run()
  479. // 输出标准输出和标准错误
  480. fmt.Println("ContractStatus 标准输出:", stdoutBuf.String())
  481. fmt.Println("ContractStatus 标准错误:", stderrBuf.String())
  482. if err != nil {
  483. global.M2A_LOG.Error("[ContractStatus] 请求失败", zap.Error(err))
  484. return
  485. }
  486. // 结果
  487. rspBody := stdoutBuf.String()
  488. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  489. global.M2A_LOG.Error("[DownloadContract] 反序列化body失败", zap.Error(err))
  490. return
  491. }
  492. return
  493. }