asign.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620
  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(global.M2A_CONFIG.Asign.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 | WillFaceData
  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(global.M2A_CONFIG.Asign.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(global.M2A_CONFIG.Asign.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. // 签署方式指定:(从以下分类中指定一种)
  346. // 1:短信验证码签约(支持企业和个人)
  347. // 2:签约密码签约(支持企业和个人)
  348. // 3:人脸识别签约(支持企业和个人)
  349. // 4:手写签名(不推荐,仅限个人)
  350. // 6:手写识别签名+短信签约(仅限个人)
  351. // 7:手写签名+短信签约(仅限个人)
  352. // 8:手写签名+人脸识别签约(仅限个人)
  353. // 9:手写识别签名+人脸识别签约(仅限个人)
  354. reqData["validateType"] = 4
  355. reqData["signStrategyList"] = []map[string]interface{}{
  356. {"attachNo": 1, "locationMode": 4, "signKey": "key_sign_name"},
  357. {"attachNo": 1, "locationMode": 4, "signKey": "key_sign_date"},
  358. }
  359. reqData["api"] = "addSigner"
  360. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  361. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  362. reqData["apiUrl"] = apiUrl
  363. // 将请求数据转换为JSON字符串
  364. reqJSON, err := json.Marshal(reqData)
  365. if err != nil {
  366. global.M2A_LOG.Error("[AddSigner] 构建请求参数失败", zap.Error(err))
  367. return
  368. }
  369. // 要执行的Python脚本命令
  370. pythonScriptPath := "./py/Enter.py"
  371. // 创建一个命令对象
  372. cmd := exec.Command(global.M2A_CONFIG.Asign.Py, pythonScriptPath)
  373. // 设置标准输入为JSON字符串
  374. cmd.Stdin = strings.NewReader(string(reqJSON))
  375. // 创建一个字节缓冲区来捕获命令的输出
  376. var stdoutBuf, stderrBuf bytes.Buffer
  377. cmd.Stdout = &stdoutBuf
  378. cmd.Stderr = &stderrBuf
  379. // 执行命令
  380. err = cmd.Run()
  381. // 输出标准输出和标准错误
  382. fmt.Println("AddSigner 标准输出:", stdoutBuf.String())
  383. fmt.Println("AddSigner 标准错误:", stderrBuf.String())
  384. if err != nil {
  385. global.M2A_LOG.Error("[AddSigner] 请求失败", zap.Error(err))
  386. return
  387. }
  388. // 结果
  389. // 正确返回: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":[]}}
  390. // 错误返回:AddSigner 标准输出: {"code":100617,"msg":"ģ IJ [key_sign_name] ","data":null}
  391. rspBody := stdoutBuf.String()
  392. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  393. global.M2A_LOG.Error("[AddSigner] 反序列化body失败", zap.Error(err))
  394. return
  395. }
  396. return
  397. }
  398. // 下载合同响应数据
  399. type DownloadContractData struct {
  400. FileName string `json:"fileName"` // 文件名
  401. MD5 string `json:"md5"` // 文件md5值
  402. FileType int `json:"fileType"` // 文件类型 0:PDF 1:ZIP
  403. Size int `json:"size"` // 文件大小
  404. Data string `json:"data"` // Base64字符串
  405. }
  406. /*
  407. DownloadContract 下载合同
  408. contractNo 合同ID,合同唯一编号
  409. */
  410. func DownloadContract(contractNo string) (rspData AsignRsp[DownloadContractData], err error) {
  411. apiUrl := global.M2A_CONFIG.Asign.URL + "contract/downloadContract"
  412. // 构建请求数据结构
  413. reqData := make(map[string]interface{})
  414. reqData["contractNo"] = contractNo
  415. reqData["api"] = "downloadContract"
  416. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  417. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  418. reqData["apiUrl"] = apiUrl
  419. // 将请求数据转换为JSON字符串
  420. reqJSON, err := json.Marshal(reqData)
  421. if err != nil {
  422. global.M2A_LOG.Error("[DownloadContract] 构建请求参数失败", zap.Error(err))
  423. return
  424. }
  425. // 要执行的Python脚本命令
  426. pythonScriptPath := "./py/Enter.py"
  427. // 创建一个命令对象
  428. cmd := exec.Command(global.M2A_CONFIG.Asign.Py, pythonScriptPath)
  429. // 设置标准输入为JSON字符串
  430. cmd.Stdin = strings.NewReader(string(reqJSON))
  431. // 创建一个字节缓冲区来捕获命令的输出
  432. var stdoutBuf, stderrBuf bytes.Buffer
  433. cmd.Stdout = &stdoutBuf
  434. cmd.Stderr = &stderrBuf
  435. // 执行命令
  436. err = cmd.Run()
  437. // 输出标准输出和标准错误
  438. fmt.Println("DownloadContract 标准输出:", stdoutBuf.String())
  439. fmt.Println("DownloadContract 标准错误:", stderrBuf.String())
  440. if err != nil {
  441. global.M2A_LOG.Error("[DownloadContract] 请求失败", zap.Error(err))
  442. return
  443. }
  444. // 结果
  445. rspBody := stdoutBuf.String()
  446. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  447. global.M2A_LOG.Error("[DownloadContract] 反序列化body失败", zap.Error(err))
  448. return
  449. }
  450. return
  451. }
  452. // 查询合同状态响应数据
  453. type ContractStatusData struct {
  454. ContractNo string `json:"contractNo"` // 合同唯一编号
  455. ContractName string `json:"contractName"` // 合同名称
  456. Status int `json:"status"` // 合同状态:0:等待签约 1:签约中 2:已签约 3:过期 4:拒签 6:作废 -2:状态异常
  457. }
  458. /*
  459. ContractStatus 查询合同状态
  460. contractNo 合同ID,合同唯一编号
  461. */
  462. func ContractStatus(contractNo string) (rspData AsignRsp[ContractStatusData], err error) {
  463. apiUrl := global.M2A_CONFIG.Asign.URL + "contract/status"
  464. // 构建请求数据结构
  465. reqData := make(map[string]interface{})
  466. reqData["contractNo"] = contractNo
  467. reqData["api"] = "contractStatus"
  468. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  469. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  470. reqData["apiUrl"] = apiUrl
  471. // 将请求数据转换为JSON字符串
  472. reqJSON, err := json.Marshal(reqData)
  473. if err != nil {
  474. global.M2A_LOG.Error("[ContractStatus] 构建请求参数失败", zap.Error(err))
  475. return
  476. }
  477. // 要执行的Python脚本命令
  478. pythonScriptPath := "./py/Enter.py"
  479. // 创建一个命令对象
  480. cmd := exec.Command(global.M2A_CONFIG.Asign.Py, pythonScriptPath)
  481. // 设置标准输入为JSON字符串
  482. cmd.Stdin = strings.NewReader(string(reqJSON))
  483. // 创建一个字节缓冲区来捕获命令的输出
  484. var stdoutBuf, stderrBuf bytes.Buffer
  485. cmd.Stdout = &stdoutBuf
  486. cmd.Stderr = &stderrBuf
  487. // 执行命令
  488. err = cmd.Run()
  489. // 输出标准输出和标准错误
  490. fmt.Println("ContractStatus 标准输出:", stdoutBuf.String())
  491. fmt.Println("ContractStatus 标准错误:", stderrBuf.String())
  492. if err != nil {
  493. global.M2A_LOG.Error("[ContractStatus] 请求失败", zap.Error(err))
  494. return
  495. }
  496. // 结果
  497. rspBody := stdoutBuf.String()
  498. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  499. global.M2A_LOG.Error("[DownloadContract] 反序列化body失败", zap.Error(err))
  500. return
  501. }
  502. return
  503. }
  504. // 个人意愿核身认证响应数据
  505. type WillFaceData struct {
  506. Result int `json:"result"` // 认证结果:0.暂无结果/认证中
  507. SerialNo string `json:"serialNo"` // 认证流水号
  508. Type string `json:"type"` // 认证类型
  509. FaceUrl string `json:"faceUrl"` // 意愿核身链接
  510. }
  511. /*
  512. WillFace 个人意愿核身认证
  513. */
  514. func WillFace(realName, idCardNo, question, answer, recordId string) (rspData AsignRsp[WillFaceData], err error) {
  515. apiUrl := global.M2A_CONFIG.Asign.URL + "auth/person/willFace"
  516. // 构建请求数据结构
  517. reqData := make(map[string]interface{})
  518. reqData["realName"] = realName
  519. reqData["idCardNo"] = idCardNo
  520. reqData["question"] = question
  521. reqData["answer"] = answer
  522. reqData["redirectUrl"] = global.M2A_CONFIG.Asign.WillFaceRedirectUrl + "?recordId=" + recordId
  523. reqData["api"] = "willFace"
  524. reqData["appId"] = global.M2A_CONFIG.Asign.AppId
  525. reqData["appKey"] = global.M2A_CONFIG.Asign.PrivateKey
  526. reqData["apiUrl"] = apiUrl
  527. // 将请求数据转换为JSON字符串
  528. reqJSON, err := json.Marshal(reqData)
  529. if err != nil {
  530. global.M2A_LOG.Error("[WillFace] 构建请求参数失败", zap.Error(err))
  531. return
  532. }
  533. // 要执行的Python脚本命令
  534. pythonScriptPath := "./py/Enter.py"
  535. // 创建一个命令对象
  536. cmd := exec.Command(global.M2A_CONFIG.Asign.Py, pythonScriptPath)
  537. // 设置标准输入为JSON字符串
  538. cmd.Stdin = strings.NewReader(string(reqJSON))
  539. // 创建一个字节缓冲区来捕获命令的输出
  540. var stdoutBuf, stderrBuf bytes.Buffer
  541. cmd.Stdout = &stdoutBuf
  542. cmd.Stderr = &stderrBuf
  543. // 执行命令
  544. err = cmd.Run()
  545. // 输出标准输出和标准错误
  546. fmt.Println("ContractStatus 标准输出:", stdoutBuf.String())
  547. fmt.Println("ContractStatus 标准错误:", stderrBuf.String())
  548. if err != nil {
  549. global.M2A_LOG.Error("[ContractStatus] 请求失败", zap.Error(err))
  550. return
  551. }
  552. // 结果
  553. rspBody := stdoutBuf.String()
  554. if err = json.Unmarshal([]byte(rspBody), &rspData); err != nil {
  555. global.M2A_LOG.Error("[WillFace] 反序列化body失败", zap.Error(err))
  556. return
  557. }
  558. return
  559. }