新增开票接口及查询接口

src/main/java/com/gxwebsoft/booking/controller/UserInvoiceController.java

@@ -3,13 +3,11 @@ package com.gxwebsoft.booking.controller;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.StrUtil;
-import com.gxwebsoft.booking.entity.NuoNuo;
-import com.gxwebsoft.booking.entity.NuoNuoGoods;
-import com.gxwebsoft.booking.entity.NuoNuoOrder;
+import com.alibaba.fastjson.JSONObject;
+import com.gxwebsoft.booking.entity.*;
 import com.gxwebsoft.common.core.utils.JSONUtil;
 import com.gxwebsoft.common.core.web.BaseController;
 import com.gxwebsoft.booking.service.UserInvoiceService;
-import com.gxwebsoft.booking.entity.UserInvoice;
 import com.gxwebsoft.booking.param.UserInvoiceParam;
 import com.gxwebsoft.common.core.web.ApiResult;
 import com.gxwebsoft.common.core.web.PageResult;
@@ -17,13 +15,18 @@ import com.gxwebsoft.common.core.web.PageParam;
 import com.gxwebsoft.common.core.web.BatchParam;
 import com.gxwebsoft.common.core.annotation.OperationLog;
 import com.gxwebsoft.common.system.entity.User;
+import com.gxwebsoft.shop.entity.Order;
+import com.gxwebsoft.shop.service.OrderService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import io.swagger.models.auth.In;
 import nuonuo.open.sdk.NNOpenSDK;
+import org.apache.poi.ss.formula.functions.T;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
+import java.math.BigDecimal;
 import java.util.HashMap;
 import java.util.List;
 import java.util.UUID;
@@ -38,124 +41,136 @@ import java.util.UUID;
 @RestController
 @RequestMapping("/api/booking/user-invoice")
 public class UserInvoiceController extends BaseController {
-    @Resource
-    private UserInvoiceService userInvoiceService;
+  @Resource
+  private UserInvoiceService userInvoiceService;
+  @Resource
+  private OrderService orderService;
 
-    @ApiOperation("分页查询发票")
-    @GetMapping("/page")
-    public ApiResult<PageResult<UserInvoice>> page(UserInvoiceParam param) {
-        // 使用关联查询
-        return success(userInvoiceService.pageRel(param));
-    }
+  @ApiOperation("分页查询发票")
+  @GetMapping("/page")
+  public ApiResult<PageResult<UserInvoice>> page(UserInvoiceParam param) {
+    // 使用关联查询
+    return success(userInvoiceService.pageRel(param));
+  }
 
-    @ApiOperation("查询全部发票")
-    @GetMapping()
-    public ApiResult<List<UserInvoice>> list(UserInvoiceParam param) {
-        // 使用关联查询
-        return success(userInvoiceService.listRel(param));
-    }
+  @ApiOperation("查询全部发票")
+  @GetMapping()
+  public ApiResult<List<UserInvoice>> list(UserInvoiceParam param) {
+    // 使用关联查询
+    return success(userInvoiceService.listRel(param));
+  }
 
-    @PreAuthorize("hasAuthority('booking:userInvoice:list')")
-    @ApiOperation("根据id查询发票")
-    @GetMapping("/{id}")
-    public ApiResult<UserInvoice> get(@PathVariable("id") Integer id) {
-        // 使用关联查询
-        return success(userInvoiceService.getByIdRel(id));
-    }
+  @PreAuthorize("hasAuthority('booking:userInvoice:list')")
+  @ApiOperation("根据id查询发票")
+  @GetMapping("/{id}")
+  public ApiResult<UserInvoice> get(@PathVariable("id") Integer id) {
+    // 使用关联查询
+    return success(userInvoiceService.getByIdRel(id));
+  }
 
-    @ApiOperation("添加发票")
-    @PostMapping()
-    public ApiResult<?> save(@RequestBody UserInvoice userInvoice) {
-        // 记录当前登录用户id
-        User loginUser = getLoginUser();
-        if (loginUser != null) {
-         userInvoice.setUserId(loginUser.getUserId());
-        }
-        if (userInvoiceService.save(userInvoice)) {
-            return success("添加成功");
-        }
-        return fail("添加失败");
+  @ApiOperation("添加发票")
+  @PostMapping()
+  public ApiResult<?> save(@RequestBody UserInvoice userInvoice) {
+    // 记录当前登录用户id
+    User loginUser = getLoginUser();
+    if (loginUser != null) {
+      userInvoice.setUserId(loginUser.getUserId());
     }
+    if (userInvoiceService.save(userInvoice)) {
+      return success("添加成功");
+    }
+    return fail("添加失败");
+  }
 
-    @ApiOperation("修改发票")
-    @PutMapping()
-    public ApiResult<?> update(@RequestBody UserInvoice userInvoice) {
-        if (userInvoiceService.updateById(userInvoice)) {
-            return success("修改成功");
-        }
-        return fail("修改失败");
+  @ApiOperation("修改发票")
+  @PutMapping()
+  public ApiResult<?> update(@RequestBody UserInvoice userInvoice) {
+    if (userInvoiceService.updateById(userInvoice)) {
+      return success("修改成功");
     }
+    return fail("修改失败");
+  }
 
-    @ApiOperation("删除发票")
-    @DeleteMapping("/{id}")
-    public ApiResult<?> remove(@PathVariable("id") Integer id) {
-        if (userInvoiceService.removeById(id)) {
-            return success("删除成功");
-        }
-        return fail("删除失败");
+  @ApiOperation("删除发票")
+  @DeleteMapping("/{id}")
+  public ApiResult<?> remove(@PathVariable("id") Integer id) {
+    if (userInvoiceService.removeById(id)) {
+      return success("删除成功");
     }
+    return fail("删除失败");
+  }
 
-    @ApiOperation("批量添加发票")
-    @PostMapping("/batch")
-    public ApiResult<?> saveBatch(@RequestBody List<UserInvoice> list) {
-        if (userInvoiceService.saveBatch(list)) {
-            return success("添加成功");
-        }
-        return fail("添加失败");
+  @ApiOperation("批量添加发票")
+  @PostMapping("/batch")
+  public ApiResult<?> saveBatch(@RequestBody List<UserInvoice> list) {
+    if (userInvoiceService.saveBatch(list)) {
+      return success("添加成功");
     }
+    return fail("添加失败");
+  }
 
-    @ApiOperation("批量修改发票")
-    @PutMapping("/batch")
-    public ApiResult<?> removeBatch(@RequestBody BatchParam<UserInvoice> batchParam) {
-        if (batchParam.update(userInvoiceService, "id")) {
-            return success("修改成功");
-        }
-        return fail("修改失败");
+  @ApiOperation("批量修改发票")
+  @PutMapping("/batch")
+  public ApiResult<?> removeBatch(@RequestBody BatchParam<UserInvoice> batchParam) {
+    if (batchParam.update(userInvoiceService, "id")) {
+      return success("修改成功");
     }
+    return fail("修改失败");
+  }
 
-    @ApiOperation("批量删除发票")
-    @DeleteMapping("/batch")
-    public ApiResult<?> removeBatch(@RequestBody List<Integer> ids) {
-        if (userInvoiceService.removeByIds(ids)) {
-            return success("删除成功");
-        }
-        return fail("删除失败");
+  @ApiOperation("批量删除发票")
+  @DeleteMapping("/batch")
+  public ApiResult<?> removeBatch(@RequestBody List<Integer> ids) {
+    if (userInvoiceService.removeByIds(ids)) {
+      return success("删除成功");
     }
+    return fail("删除失败");
+  }
 
   @ApiOperation("开具发票")
-  @GetMapping("/doInvoice/{id}")
-  public ApiResult<?> doInvoice(@PathVariable("id") Integer id) {
-    final UserInvoice userInvoice = userInvoiceService.getByIdRel(id);
+  @PostMapping("/doInvoice")
+  public ApiResult<?> doInvoice(@RequestBody UserInvoice userInvoice) {
+    final Order orderInfo = orderService.getById(userInvoice.getOrderId());
+    System.out.println("orderInfo = " + orderInfo);
+    final UserInvoice invoice = userInvoiceService.getByIdRel(userInvoice.getId());
+
     // 开票接口
     NNOpenSDK sdk = NNOpenSDK.getIntance();
     String taxnum = "339901999999142";//ISV下授权商户税号，自用型应用置""即可
     String appKey = "SD56531018";
     String appSecret = "SD3C429B318C485E";
     String method = "nuonuo.OpeMplatform.requestBillingNew";//API方法名
-    String token = NNOpenSDK.getIntance().getMerchantToken("SD56531018","SD3C429B318C485E"); //访问令牌
+    String token = NNOpenSDK.getIntance().getMerchantToken("SD56531018", "SD3C429B318C485E"); //访问令牌
     final NuoNuo nuoNuo = new NuoNuo();
     final NuoNuoOrder order = new NuoNuoOrder();
-    order.setBuyerName(userInvoice.getName());
+    order.setBuyerName(invoice.getName());
+//    order.setSalerTaxNum(invoice.getInvoiceCode());
+//    order.setSalerTel(invoice.getPhone());
     order.setSalerTaxNum("339901999999142");
     order.setSalerTel("339901999999142");
-    order.setOrderNo(Long.toString(IdUtil.getSnowflakeNextId()));
+    order.setOrderNo(orderInfo.getOrderNo());
     order.setInvoiceDate(DateUtil.now());
     order.setClerk("张三");
     order.setBuyerPhone(userInvoice.getPhone());
     order.setInvoiceType("1");
     final NuoNuoGoods goods = new NuoNuoGoods();
-    goods.setGoodsName(userInvoice.getComments());
+    goods.setGoodsName(orderInfo.getComments());
     goods.setWithTaxFlag("0");
-    goods.setDField1("综合馆羽毛球馆 2024-05-16 (星期四) 18:00 - 20:00");
+    goods.setDField1(orderInfo.getComments());
     goods.setDField2("无");
     goods.setDField3("无");
     goods.setDField4("无");
     goods.setDField5("无");
-    goods.setTax("0.12");
-    goods.setTaxRate("0.13");
-    goods.setTaxExcludedAmount("0.88");
-    goods.setTaxIncludedAmount("1");
+    final String tax = orderInfo.getTotalPrice().multiply(new BigDecimal("0.06")).toString();
+    goods.setTax(tax);
+    goods.setTaxRate(new BigDecimal("0.06").toString());
+    System.out.println("不含税金额 = " + orderInfo.getTotalPrice());
+    System.out.println("税额 = " + tax);
+    System.out.println("含税金额 = " + orderInfo.getTotalPrice().add(new BigDecimal(tax)));
+    goods.setTaxExcludedAmount(orderInfo.getTotalPrice().toString());
+    goods.setTaxIncludedAmount(orderInfo.getTotalPrice().add(new BigDecimal(tax)).toString());
     order.setInvoiceDetail(goods);
+    System.out.println("order = " + order);
     nuoNuo.setOrder(order);
 
     String content = JSONUtil.toJSONString(nuoNuo);//API私有请求参数
@@ -164,9 +179,94 @@ public class UserInvoiceController extends BaseController {
     String json = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content); // 请求API
     System.out.println("json = " + json);
     if (StrUtil.isNotBlank(json)) {
-      return success("发票开具成功",json);
+      final JSONObject jsonObject = JSONObject.parseObject(json);
+      final String code = jsonObject.getString("code");
+      final String result = jsonObject.getString("result");
+      System.out.println("jsonObject = " + jsonObject);
+      if (code.equals("E0000")) {
+        final JSONObject resNo = JSONObject.parseObject(result);
+        final String invoiceSerialNum = resNo.getString("invoiceSerialNum");
+        orderInfo.setIsInvoice(1);
+        orderInfo.setInvoiceNo(invoiceSerialNum);
+        System.out.println("invoiceSerialNum = " + invoiceSerialNum);
+        orderService.updateById(orderInfo);
+        return success("发票开具成功", json);
+      }
     }
     return fail("发票开具失败");
   }
 
+
+  @ApiOperation("根据id查询发票")
+  @GetMapping("/showInvoice/{orderId}")
+  public ApiResult<String> showInvoice(@PathVariable("orderId") Integer orderId) {
+    final Order order = orderService.getById(orderId);
+    NNOpenSDK sdk = NNOpenSDK.getIntance();
+    String taxnum = "339901999999142";//ISV下授权商户税号，自用型应用置""即可
+    String appKey = "SD56531018";
+    String appSecret = "SD3C429B318C485E";
+    String method = "nuonuo.OpeMplatform.queryInvoiceResult";//API方法名
+    String token = NNOpenSDK.getIntance().getMerchantToken("SD56531018", "SD3C429B318C485E"); //访问令牌
+
+    HashMap<String, Object> map = new HashMap<>();
+//    map.put("invoiceCode",invoiceNo);
+    map.put("serialNos", order.getInvoiceNo());
+//    map.put("inTaxAmount", order.getPayPrice().subtract(order.getPayPrice().multiply(new BigDecimal("0.06")))); // 含税金额
+//    map.put("exTaxAmount", order.getPayPrice()); // 	不含税金额
+    System.out.println("map = " + map);
+    String content = JSONUtil.toJSONString(map);//API私有请求参数
+    String url = "https://sandbox.nuonuocs.cn/open/v1/services"; //SDK请求地址
+    String senid = UUID.randomUUID().toString(); // 唯一标识，由企业自己生成32位随机码
+
+    String result = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content);
+    System.out.println("result = " + result);
+    return success("查询成功", result);
+  }
+
+//  @ApiOperation("开具发票")
+//  @GetMapping("/doInvoice/{id}")
+//  public ApiResult<?> doInvoice(@PathVariable("id") Integer id) {
+//    final UserInvoice userInvoice = userInvoiceService.getByIdRel(id);
+//    // 开票接口
+//    NNOpenSDK sdk = NNOpenSDK.getIntance();
+//    String taxnum = "339901999999142";//ISV下授权商户税号，自用型应用置""即可
+//    String appKey = "SD56531018";
+//    String appSecret = "SD3C429B318C485E";
+//    String method = "nuonuo.OpeMplatform.requestBillingNew";//API方法名
+//    String token = NNOpenSDK.getIntance().getMerchantToken("SD56531018","SD3C429B318C485E"); //访问令牌
+//    final NuoNuo nuoNuo = new NuoNuo();
+//    final NuoNuoOrder order = new NuoNuoOrder();
+//    order.setBuyerName(userInvoice.getName());
+//    order.setSalerTaxNum("339901999999142");
+//    order.setSalerTel("339901999999142");
+//    order.setOrderNo(Long.toString(IdUtil.getSnowflakeNextId()));
+//    order.setInvoiceDate(DateUtil.now());
+//    order.setClerk("张三");
+//    order.setBuyerPhone(userInvoice.getPhone());
+//    order.setInvoiceType("1");
+//    final NuoNuoGoods goods = new NuoNuoGoods();
+//    goods.setGoodsName(userInvoice.getComments());
+//    goods.setWithTaxFlag("0");
+//    goods.setDField1("综合馆羽毛球馆 2024-05-16 (星期四) 18:00 - 20:00");
+//    goods.setDField2("无");
+//    goods.setDField3("无");
+//    goods.setDField4("无");
+//    goods.setDField5("无");
+//    goods.setTax("0.12");
+//    goods.setTaxRate("0.13");
+//    goods.setTaxExcludedAmount("0.88");
+//    goods.setTaxIncludedAmount("1");
+//    order.setInvoiceDetail(goods);
+//    nuoNuo.setOrder(order);
+//
+//    String content = JSONUtil.toJSONString(nuoNuo);//API私有请求参数
+//    String url = "https://sandbox.nuonuocs.cn/open/v1/services"; //SDK请求地址
+//    String senid = UUID.randomUUID().toString(); // 唯一标识，由企业自己生成32位随机码
+//    String json = sdk.sendPostSyncRequest(url, senid, appKey, appSecret, token, taxnum, method, content); // 请求API
+//    System.out.println("json = " + json);
+//    if (StrUtil.isNotBlank(json)) {
+//      return success("发票开具成功",json);
+//    }
+//    return fail("发票开具失败");
+//  }
 }

src/main/java/com/gxwebsoft/booking/entity/NuoNuoResult.java

@@ -0,0 +1,34 @@
+package com.gxwebsoft.booking.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * 发票
+ *
+ * @author 科技小王子
+ * @since 2024-05-25 17:20:15
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@ApiModel(value = "NuoNuo开票对象", description = "开票对象")
+public class NuoNuoResult implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "编码")
+    @TableField(exist = false)
+    private String code;
+
+    @ApiModelProperty(value = "描述")
+    @TableField(exist = false)
+    private String describe;
+
+    @ApiModelProperty(value = "返回结果")
+    @TableField(exist = false)
+    private String result;
+}

src/main/java/com/gxwebsoft/booking/entity/NuoNuoResultNo.java

@@ -0,0 +1,26 @@
+package com.gxwebsoft.booking.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * 发票
+ *
+ * @author 科技小王子
+ * @since 2024-05-25 17:20:15
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@ApiModel(value = "NuoNuo开票对象", description = "开票对象")
+public class NuoNuoResultNo implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "发票流水号")
+    @TableField(exist = false)
+    private String invoiceSerialNum;
+}

src/main/java/com/gxwebsoft/booking/entity/UserInvoice.java

@@ -12,6 +12,7 @@ import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
+import lombok.Value;
 
 /**
  * 发票
@@ -63,6 +64,9 @@ public class UserInvoice implements Serializable {
     @ApiModelProperty(value = "备注")
     private String comments;
 
+    @ApiModelProperty(value = "是否启用")
+    private Integer isCompany;
+
     @ApiModelProperty(value = "排序(数字越小越靠前)")
     private Integer sortNumber;
 
@@ -85,4 +89,7 @@ public class UserInvoice implements Serializable {
     @ApiModelProperty(value = "修改时间")
     private Date updateTime;
 
+    @ApiModelProperty(value = "订单号")
+    private Integer orderId;
+
 }

src/main/java/com/gxwebsoft/shop/controller/WxPayNotifyController.java

@@ -64,12 +64,12 @@ public class WxPayNotifyController extends BaseController {
   @PostMapping("/notify/{tenantId}")
   public String wxNotify(@RequestHeader Map<String, String> header, @RequestBody String body, @PathVariable("tenantId") Integer tenantId) {
     System.out.println("异步通知*************** = ");
-//    System.out.println("request header = " + header);
-//    System.out.println("request body = " + body);
-//    System.out.println("tenantId = " + tenantId);
+    System.out.println("request header = " + header);
+    System.out.println("request body = " + body);
+    System.out.println("tenantId = " + tenantId);
 
     // 获取支付配置信息用于解密
-    String key = "Payment:wxPay:".concat(tenantId.toString());
+    String key = "Payment:1:".concat(tenantId.toString());
     final Payment payment = redisUtil.get(key, Payment.class);
     String privateKey = payment.getApiKey();
     String apiclientCert = conf.getUploadPath().concat("/file").concat(payment.getApiclientCert());

src/main/java/com/gxwebsoft/shop/entity/Order.java

@@ -138,7 +138,10 @@ public class Order implements Serializable {
     private String startTime;
 
     @ApiModelProperty(value = "是否已开具发票：0未开发票，1已开发票，2不能开具发票")
-    private Boolean isInvoice;
+    private Integer isInvoice;
+
+    @ApiModelProperty(value = "发票流水号")
+    private String invoiceNo;
 
     @ApiModelProperty(value = "支付时间")
     private Date payTime;

src/main/java/com/gxwebsoft/shop/service/impl/OrderServiceImpl.java

@@ -189,6 +189,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
     // 微信小程序(微信支付)
     String key = "mp-weixin:".concat(order.getTenantId().toString());
     final String string = redisUtil.get(key);
+    System.out.println("string = " + string);
     final JSONObject mpWx = JSONObject.parseObject(string);
     System.out.println("mpWx = " + mpWx);
     String key2 = "Payment:".concat(order.getPayType().toString()).concat(":").concat(order.getTenantId().toString());

src/main/java/com/gxwebsoft/shop/task/OrderTask.java

@@ -29,7 +29,7 @@ public class OrderTask extends BaseController {
   /**
    * 自动处理过期订单任务
    */
-  @Scheduled(fixedDelay = 2000, initialDelay = 2000)
+//  @Scheduled(fixedDelay = 2000, initialDelay = 2000)
   @Transactional(rollbackFor = {Exception.class})
   public void settledExpirationOrder() {
     final OrderParam p = new OrderParam();