新增发票管理

wujianwei

2025-12-26 ec0d0617f3bdbc4d424fdb6253a5075fbf594537

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
package com.ruoyi.cwgl.service.impl;
 
 
import cn.hutool.http.HttpUtil;
 
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.sign.Md5Utils;
 
import com.ruoyi.cwgl.domain.InvoicingVo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
 
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
 
/**
 * 谷神开发的应用系统调用api
 * @author wjw
 */
@Service
public class GdpaasApiService {
    protected final Logger logger = LoggerFactory.getLogger(getClass());
 
    @Autowired
    private RedisCache redisCache;
    private final String tokenKey = "GDPAAS_API_TOKEN_KEY";
   // private  String ROOT_PATH = "http://172.16.24.46:9080/";
    @Value("${custom.gdpaasApi.path}")
    private String ROOT_PATH;
    @Value("${custom.gdpaasApi.appid}")
    private String appId;
    @Value("${custom.gdpaasApi.sign}")
    private String sign;
    /**
     * 获取token
     * @param appId
     * @param sign
     * @param time
     * @return
     */
    public String getToken(String appId, String sign, String time) {
        Object token = redisCache.getCacheObject(tokenKey);
        if (token == null) {
            //签名摘要
            String hash = Md5Utils.hash(appId + time + sign);
            String urlString = ROOT_PATH + "/gdpaas/apis/getAccessToken.htm" ;
            Map<String, Object> parm = new HashMap<>();
            parm.put("appId", appId);
            parm.put("sign", hash);
            parm.put("t", time);
            String json = null;
            logger.info("获取第三方token请求参数{}",parm);
            try {
                json = HttpUtil.get(urlString, parm);
            } catch (Exception e) {
                e.printStackTrace();
                logger.error("请求获取第三方token接口失败");
            }
            if (json == null) {
                return null;
            }
            logger.info("获取第三方token响应参数{}",json);
 
            JSONObject jsonObject = JSONObject.parseObject(json);
            Integer code = (Integer) jsonObject.get("code");
            if (code.equals(0)) {
                String data = jsonObject.getString("data");
                JSONObject dataJson = JSONObject.parseObject(data);
                String accessToken = dataJson.getString("accessToken");
                Integer expiresIn = (Integer) dataJson.get("expiresIn");
                redisCache.setCacheObject(tokenKey,accessToken,expiresIn, TimeUnit.SECONDS);
                return  accessToken;
            }
            return null;
        }
        return (String) token;
    }
 
    /**
     *  发票开具接口
     */
    public String invoicingApi(InvoicingVo order){
        String accessToken = getToken(appId, sign, System.currentTimeMillis() + "");
        if (accessToken==null){
            throw new ServiceException("获取令牌失败");
        }
        String urlString = ROOT_PATH + "/gdpaas/apis/invoke.htm?appId="+appId+"&accessToken="+accessToken+"&method=com.golden.bdp.cwzx.invoice.submitInvoice" ;
        String body = JSONObject.toJSONString(order);
        String json = null;
 
        try {
             json = HttpUtil.post(urlString, body);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error("发票开具接口接口失败");
        }
        logger.info("开票响应{}",json);
        return  json;
//        String code =  jsonObject.getString("code");
//        if (json == null) {
//            logger.info("开票失败");
//            return null;
//        }
//        if ("0".equals(code)) {
//            String data = jsonObject.getString("data");
//
//            JSONObject dataJson = JSONObject.parseObject(data);
//            String invoiceSerialNum = dataJson.getString("invoiceSerialNum");
//            logger.info("开票成功发票序列号为{}",invoiceSerialNum);
//            return invoiceSerialNum;
//        }
//    return null;
    }
 
    /**
     *  发票开具接口
     */
    public String invoicingApi(String body){
        String accessToken = getToken(appId, sign, System.currentTimeMillis() + "");
        if (accessToken==null){
            throw new ServiceException("获取令牌失败");
        }
        String urlString = ROOT_PATH + "/gdpaas/apis/invoke.htm?appId="+appId+"&accessToken="+accessToken+"&method=com.golden.bdp.cwzx.invoice.submitInvoice" ;
//        String body = JSONObject.toJSONString(order);
        String json = null;
 
        try {
            json = HttpUtil.post(urlString, body);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error("发票开具接口接口失败");
        }
        logger.info("开票响应{}",json);
        return  json;
    }
 
}