Merge branch 'dev' of http://gitlab.zhengzai.tv/dongjingwei/liquidnet-bus-v1 into dev

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/constant/KylinPerformanceStatusEnum.java

@@ -7,7 +7,7 @@ public enum KylinPerformanceStatusEnum {
     PERFORMANCESTATUS3("预览", 3),
     PERFORMANCESTATUS6("购买", 6),
     PERFORMANCESTATUS7("已下架", 7),
-    PERFORMANCESTATUS8("售馨", 8),
+    PERFORMANCESTATUS8("售磬", 8),
     PERFORMANCESTATUS9("未开始", 9),
     PERFORMANCESTATUS10("已结束", 10),
     PERFORMANCESTATUS11("已停售", 11);

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderRefundsMapper.xml

@@ -76,6 +76,7 @@
         <where>
             AND order_tickets_id = #{orderTicketsId}
             AND status != ${orderRefundStatusCancel}
+            AND status != 5
         </where>
     </select>
     <select id="selectEntitiesCount" resultType="java.lang.Integer">

liquidnet-bus-feign/liquidnet-api-feign-platform/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>liquidnet-bus-feign</artifactId>
+        <groupId>com.liquidnet</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>liquidnet-api-feign-platform</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+
+    </dependencies>
+
+</project>
\ No newline at end of file

liquidnet-bus-feign/liquidnet-api-feign-platform/src/main/java/com/liquidnet/service/feign/kylin/task/FeignPlatformAlipayBackClient.java

+package com.liquidnet.service.feign.kylin.task;
+
+import com.liquidnet.service.base.ResponseDto;
+import feign.hystrix.FallbackFactory;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+
+@Component
+@FeignClient(name = "liquidnet-service-platform",
+        contextId = "FeignPlatformAlipayBackClient", path = "",
+        url = "",
+        fallback = FallbackFactory.Default.class)
+public interface FeignPlatformAlipayBackClient {
+
+    @GetMapping("platform/refund/alipayActiveCallback")
+    ResponseDto<String> alipayActiveCallback();
+
+}

liquidnet-bus-feign/pom.xml

@@ -14,6 +14,7 @@
         <module>liquidnet-api-feign-adam</module>
         <module>liquidnet-api-feign-kylin</module>
         <module>liquidnet-api-feign-dragon</module>
+        <module>liquidnet-api-feign-platform</module>
 <!--        <module>liquidnet-api-feign-sequence</module>-->
 <!--        <module>liquidnet-api-feign-example</module>-->
 <!--        <module>liquidnet-api-feign-account</module>-->

liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/pom.xml

@@ -26,6 +26,12 @@
             <artifactId>liquidnet-api-feign-dragon</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.liquidnet</groupId>
+            <artifactId>liquidnet-api-feign-platform</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
 

liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/src/main/java/com/liquidnet/service/executor/main/handler/PlatformTaskHandler.java

+package com.liquidnet.service.executor.main.handler;
+
+import com.liquidnet.service.feign.kylin.task.FeignPlatformAlipayBackClient;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * Platform
+ */
+@Component
+public class PlatformTaskHandler {
+    private static final Logger log = LoggerFactory.getLogger(PlatformTaskHandler.class);
+
+    @Autowired
+    private FeignPlatformAlipayBackClient feignPlatformAlipayBackClient;
+
+    @XxlJob(value = "sev-platform:alipayActiveCallbackHandler")
+    public ReturnT<String> alipayActiveCallbackHandler() {
+        try {
+            String result = feignPlatformAlipayBackClient.alipayActiveCallback().getData();
+            log.info("alipayActiveCallback：结果："+result);
+            return ReturnT.SUCCESS;
+        } catch (Exception e) {
+            return ReturnT.FAIL;
+        }
+    }
+
+}

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/basicServices/WechatShareController.java

@@ -62,7 +62,7 @@ public class WechatShareController {
         String accessToken = accessToken(zhengzaiAppid, zhengzaiSecret);
         String jsapiTicket = jsapiTicket(zhengzaiAppid, accessToken);
 
-        Map<String, String> ret = sign(jsapiTicket, url);
+        Map<String, String> ret = sign(jsapiTicket, url, zhengzaiAppid);
         return ResponseDto.success(ret);
     }
 
@@ -75,11 +75,11 @@ public class WechatShareController {
         String accessToken = accessToken(modernskyAppid, modernskySecret);
         String jsapiTicket = jsapiTicket(modernskyAppid, accessToken);
 
-        Map<String, String> ret = sign(jsapiTicket, url);
+        Map<String, String> ret = sign(jsapiTicket, url, modernskyAppid);
         return ResponseDto.success(ret);
     }
 
-    public static Map<String, String> sign(String jsapi_ticket, String url) {
+    public static Map<String, String> sign(String jsapi_ticket, String url, String appid) {
         Map<String, String> ret = new HashMap();
         String nonce_str = create_nonce_str();
         String timestamp = create_timestamp();
@@ -114,6 +114,7 @@ public class WechatShareController {
         ret.put("nonceStr", nonce_str);
         ret.put("timestamp", timestamp);
         ret.put("signature", signature);
+        ret.put("appid", appid);
 
         return ret;
     }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/refund/OrderRefundCallbackController.java

@@ -5,6 +5,7 @@ import com.liquidnet.service.platform.service.refund.OrderRefundsCallbackService
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
@@ -31,4 +32,11 @@ public class OrderRefundCallbackController {
         String result = orderRefundsCallbackServiceImpl.refundCallback(refundCallbackParam);
         return result;
     }
+
+    @GetMapping("alipayActiveCallback")
+    @ApiOperation("支付宝主动查询退款结果")
+    public String alipayActiveCallback() {
+        String result = orderRefundsCallbackServiceImpl.alipayActiveCallback();
+        return result;
+    }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/refund/OrderRefundsCallbackServiceImpl.java

 package com.liquidnet.service.platform.service.refund;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
 import com.liquidnet.service.kylin.dto.param.RefundCallbackParam;
 import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
 import com.liquidnet.service.kylin.entity.KylinOrderRefunds;
+import com.liquidnet.service.kylin.entity.KylinOrderTickets;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.kylin.service.IKylinOrderRefundsService;
 import com.liquidnet.service.platform.utils.DataUtils;
@@ -14,13 +17,17 @@ import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.convert.MongoConverter;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
 
 import java.time.LocalDateTime;
+import java.util.List;
 
 /**
  * <p>
@@ -33,18 +40,23 @@ import java.time.LocalDateTime;
 @Slf4j
 @Service
 public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefundsMapper, KylinOrderRefunds> implements IKylinOrderRefundsService {
+    @Value("${liquidnet.client.admin.platformUrl}")
+    private String platformUrl;
+    @Value("${liquidnet.client.admin.phpPayUrl}")
+    private String phpPayUrl;
+
     @Autowired
     private KylinRefundsStatusServiceImpl kylinRefundsStatusServiceImpl;
 
     @Autowired
     private KylinOrderRefundsMapper kylinOrderRefundsMapper;
+    @Autowired
+    private KylinOrderTicketsMapper kylinOrderTicketsMapper;
 
     @Autowired
     MongoTemplate mongoTemplate;
-
     @Autowired
     private MongoConverter mongoConverter;
-
     @Autowired
     private DataUtils dataUtils;
 
@@ -57,8 +69,8 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
             log.info("Failed:{}.RefundController refundCallback: 退款订单查询失败，编号{}", "KylinOrderRefundsServiceImplRefundCallback", refundCallbackParam.getOrderRefundCode());
             return "fail";
         }
-        if (refundInfo.getStatus() == KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL) {
-            log.info("Failed:{}.RefundController refundCallback: 退款订单已取消，编号{}", "KylinOrderRefundsServiceImplRefundCallback", refundCallbackParam.getOrderRefundCode());
+        if (refundInfo.getStatus() == KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL || refundInfo.getStatus() == KylinTableStatusConst.ORDER_REFUND_STATUS_REJECT) {
+            log.info("Failed:{}.RefundController refundCallback: 退款订单已取消或已一审拒绝，编号{}", "KylinOrderRefundsServiceImplRefundCallback", refundCallbackParam.getOrderRefundCode());
             return "fail";
         }
         if (refundInfo.getStatus() == KylinTableStatusConst.ORDER_REFUND_STATUS_REFUNDED) {
@@ -104,4 +116,40 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
     public String getOrderRefundCode(String orderRefundCode,int type) {
         return null;
     }
+
+    public String alipayActiveCallback() {
+        LocalDateTime startTime =  LocalDateTime.now();
+        LocalDateTime newTime = startTime.minusHours(8);
+        List<KylinOrderRefunds> kylinOrderRefunds = kylinOrderRefundsMapper.selectList(
+                Wrappers.lambdaQuery(KylinOrderRefunds.class)
+                        .eq(KylinOrderRefunds::getStatus, KylinTableStatusConst.ORDER_REFUND_STATUS_UNFILLED)
+                        .lt(KylinOrderRefunds::getExecutorAt, newTime) // 默认减去8小时的
+        );
+        for (KylinOrderRefunds refundInfo : kylinOrderRefunds) {
+            KylinOrderTickets orderInfo = kylinOrderTicketsMapper.selectOne(
+                    Wrappers.lambdaQuery(KylinOrderTickets.class)
+                            .eq(KylinOrderTickets::getOrderTicketsId, refundInfo.getOrderTicketsId())
+            );
+            if (null != orderInfo.getPaymentType() && (orderInfo.getPaymentType().equals("WAPALIPAY") || orderInfo.getPaymentType().equals("APPALIPAY"))) {
+                log.info("\n支付宝退款主动查询处理结果：\n[{}] ", orderInfo.getOrderTicketsId());
+                MultiValueMap<String, String> params = new LinkedMultiValueMap();
+                params.add("callBackUrl", platformUrl.concat("/platform/refund/callback"));
+                params.add("orderCode", orderInfo.getOrderCode());
+                params.add("orderRefundCode", refundInfo.getOrderRefundCode());
+                params.add("paymentId", orderInfo.getPaymentId());
+
+                // log.info("退款参数" + JsonUtils.toJson(params));
+                log.info("\n支付宝退款主动查询参数：\n[{}] ", params.toString());
+                // 请求pay
+                try {
+                    String postResult = HttpUtil.post(phpPayUrl.concat("/dragon/refund/refund/alipay/result"), params);
+                    log.info("\n支付宝退款主动查询处理结果：\n[{}] " + postResult);
+                } catch (Exception e) {
+                    log.info("\n支付宝退款主动查询失败：[errorMsg=[{}], [orderRefundsId=[{}]", e.getMessage(), refundInfo.getOrderRefundsId());
+                }
+
+            }
+        }
+        return "success";
+    }
 }