LiFei 3 年 前
コミット
9b3c15e20c

+ 19 - 0
happy-boot-module-flexjob/src/main/java/org/jeecg/modules/hlwinvoice/controller/HlwInvoiceController.java

@@ -3,8 +3,11 @@ package org.jeecg.modules.hlwinvoice.controller;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.aspect.annotation.AutoLog;
+import org.jeecg.common.aspect.annotation.LimitSubmit;
 import org.jeecg.common.aspect.annotation.PermissionData;
 import org.jeecg.modules.hlwinvoice.entity.HlwInvoice;
 import org.jeecg.modules.hlwinvoice.service.IHlwInvoiceService;
@@ -57,4 +60,20 @@ public class HlwInvoiceController {
         Map<String,Object> map =hlwInvoiceService.invoicePayment(hlwInvoice,req);
         return Result.ok(map);
     }
+
+
+    /**
+     *   添加
+     *
+     * @param hlwInvoice
+     * @return
+     */
+    @LimitSubmit(key = "addInvoice:%s")
+    @AutoLog(value = "hlw_invoice-添加")
+    @ApiOperation(value="hlw_invoice-添加", notes="hlw_invoice-添加")
+    @PostMapping(value = "/add")
+    public Result<?> add(@RequestBody HlwInvoice hlwInvoice) {
+        hlwInvoiceService.saveHlwInvoice(hlwInvoice);
+        return Result.ok("添加成功!");
+    }
 }

+ 2 - 0
happy-boot-module-flexjob/src/main/java/org/jeecg/modules/hlwinvoice/service/IHlwInvoiceService.java

@@ -18,4 +18,6 @@ public interface IHlwInvoiceService extends IService<HlwInvoice> {
     Page<?> getPageList(Integer pageNo, Integer pageSize, HlwInvoice hlwInvoice, HttpServletRequest req);
 
     Map<String,Object> invoicePayment(HlwInvoice hlwInvoice,HttpServletRequest request);
+
+    void saveHlwInvoice(HlwInvoice hlwInvoice);
 }

+ 29 - 0
happy-boot-module-flexjob/src/main/java/org/jeecg/modules/hlwinvoice/service/impl/HlwInvoiceServiceImpl.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.shiro.SecurityUtils;
+import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.exception.JeecgBootException;
 import org.jeecg.common.system.vo.LoginUser;
 import org.jeecg.common.utils.CryptTool;
@@ -16,6 +17,7 @@ import org.jeecg.modules.hlwinvoice.mapper.HlwInvoiceMapper;
 import org.jeecg.modules.hlwinvoice.service.IHlwInvoiceService;
 import org.jeecg.modules.util.RoleDataUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.servlet.http.HttpServletRequest;
 import java.util.*;
@@ -85,4 +87,31 @@ public class HlwInvoiceServiceImpl extends ServiceImpl<HlwInvoiceMapper, HlwInvo
             throw new JeecgBootException("查询数据异常");
         }
     }
+
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void saveHlwInvoice(HlwInvoice hlwInvoice) {
+        //慧盈查询开票申请列表
+        String accessToken = OauthTokenUtils.getDayAccessToken();
+        String requestUrl = OauthApi.INVOICE_APPLY_INVOICE;
+        Map<String, Object> parameters = new HashMap<>();
+        //获取当前登录用户
+        LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
+        parameters.put("idsList", hlwInvoice.getIdsList());
+        parameters.put("createBy", sysUser.getUsername());
+        //数据加密
+        String biz_content = CryptTool.encode(JSONObject.toJSONString(parameters));
+        JSONObject jsonObject = OauthTokenUtils.doRequest(requestUrl, HttpsContants.POST, biz_content, accessToken);
+        log.info("开票===={}", jsonObject);
+        if (jsonObject != null) {
+            if (jsonObject.getBoolean(HttpsContants.SUCCESS_FLAG)) {
+                log.info("开票===={}", jsonObject);
+            } else {
+                throw new JeecgBootException("开票异常");
+            }
+        } else {
+            throw new JeecgBootException("开票异常");
+        }
+    }
 }