调整红包发放定时

fs-admin/src/main/java/com/fs/course/task/RedLogTask.java

@@ -0,0 +1,17 @@
+package com.fs.course.task;
+
+import com.fs.his.service.IFsStorePaymentService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component("redlogTask")
+public class RedLogTask {
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Autowired
+    private IFsStorePaymentService paymentService;
+    private void updateRedlogStatus(){
+        paymentService.updateRedlogStatus();
+    }
+}

fs-service/src/main/java/com/fs/course/service/impl/FsUserCourseVideoServiceImpl.java

@@ -1414,6 +1414,7 @@ public class FsUserCourseVideoServiceImpl implements IFsUserCourseVideoService
                     transferBillsResult = (TransferBillsResult)sendRedPacket.get("data");
                     redPacketLog.setResult(JSON.toJSONString(sendRedPacket));
                     redPacketLog.setOutBatchNo(transferBillsResult.getOutBillNo());
+                    redPacketLog.setBatchId(transferBillsResult.getTransferBillNo());
                 }else {
                     redPacketLog.setOutBatchNo(sendRedPacket.get("orderCode").toString());
                     redPacketLog.setBatchId(sendRedPacket.get("batchId").toString());

fs-service/src/main/java/com/fs/his/service/IFsStorePaymentService.java

@@ -124,4 +124,9 @@ public interface IFsStorePaymentService
     R paymentByWxaCode(FsStorePaymentPayParam payment);
 
     R getWxaCodeByPayment(FsStorePaymentGetWxaCodeParam param);
+
+    /**
+     * 没进行回调的数据进行更改
+     */
+    void updateRedlogStatus();
 }

fs-service/src/main/java/com/fs/his/service/impl/FsStorePaymentServiceImpl.java

@@ -38,6 +38,7 @@ import com.fs.core.config.WxMaConfiguration;
 import com.fs.core.config.WxPayProperties;
 import com.fs.core.utils.OrderCodeUtils;
 import com.fs.course.config.RedPacketConfig;
+import com.fs.course.domain.FsCourseRedPacketLog;
 import com.fs.course.service.IFsCourseRedPacketLogService;
 import com.fs.course.service.IFsUserCourseOrderService;
 import com.fs.course.service.IFsUserVipOrderService;
@@ -1471,6 +1472,14 @@ public class FsStorePaymentServiceImpl implements IFsStorePaymentService {
         }
     }
 
+    @Override
+    public void updateRedlogStatus() {
+        int status = 2;
+        List<FsCourseRedPacketLog> redPacketLogs = redPacketLogService.selectRedlogStatus(status);
+        for (FsCourseRedPacketLog redPacketLog : redPacketLogs) {
+
+        }
+    }
 
 
     @Override