新增调试接口

fs-company-app/src/main/java/com/fs/app/controller/FsUserCourseVideoController.java

@@ -122,6 +122,7 @@ public class FsUserCourseVideoController extends AppBaseController {
         // type 2 未完播---看课中断
         // 管理员看整个公司 否则看自己的
         CompanyUser companyUser = companyUserService.selectCompanyUserByUserId(Long.parseLong(getUserId()));
+        System.out.println(":进入到接口了");
         if (companyUser.isAdmin()) {
             params.put("companyId", companyUser.getCompanyId());
         } else {

fs-service-system/src/main/java/com/fs/course/mapper/FsCourseRedPacketLogMapper.java

@@ -171,4 +171,7 @@ public interface FsCourseRedPacketLogMapper
             "AND create_time >= DATE(NOW())  -- 但必须是今天\n" +
             "AND status = 0;")
     List<FsCourseRedPacketLog> selectFail();
+
+    @Select("SELECT * FROM fs_course_red_packet_log WHERE status = 0 and create_time > DATE_SUB(NOW(), INTERVAL 2 day) and company_user_id =#{userId}")
+    List<FsCourseRedPacketLog> selectFail(@Param("userId") Long userId);
 }

fs-service-system/src/main/java/com/fs/store/service/IFsStorePaymentService.java

@@ -113,4 +113,6 @@ public interface IFsStorePaymentService
     R sendRedPacketTest(WxSendRedPacketParam param);
 
     void bufaRedPacket();
+
+    R sendRewardByTest(Long userId);
 }

fs-service-system/src/main/java/com/fs/store/service/impl/FsStorePaymentServiceImpl.java

@@ -675,6 +675,7 @@ public class FsStorePaymentServiceImpl implements IFsStorePaymentService
             if (r.get("code").equals(200)){
                 log.setOutBatchNo(r.get("orderCode").toString());
                 log.setBatchId(r.get("batchId").toString());
+                log.setStatus(1);
                 redPacketLogMapper.updateFsCourseRedPacketLog(log);
                 logger.info("更新完成：{}",log.getLogId());
             }
@@ -703,4 +704,28 @@ public class FsStorePaymentServiceImpl implements IFsStorePaymentService
 //
 //        }
     }
+
+    @Override
+    public R sendRewardByTest(Long userId) {
+        List<FsCourseRedPacketLog> logs = redPacketLogMapper.selectFail(userId);
+        String appId = "wx414427b10866c04e";
+        for (FsCourseRedPacketLog log : logs) {
+            FsUser user = userService.selectFsUserById(log.getUserId());
+            WxSendRedPacketParam param = new WxSendRedPacketParam();
+            param.setAppId(appId);
+            if (user == null || user.getMaOpenId() == null) {
+                continue;
+            }
+            param.setOpenId(user.getMaOpenId());
+            param.setAmount(log.getAmount());
+            R r = this.sendRedPacketTest(param);
+            if (r.get("code").equals(200)) {
+                log.setOutBatchNo(r.get("orderCode").toString());
+                log.setBatchId(r.get("batchId").toString());
+                redPacketLogMapper.updateFsCourseRedPacketLog(log);
+                logger.info("更新完成：{}", log.getLogId());
+            }
+        }
+        return R.ok();
+        }
 }

fs-user-app/src/main/java/com/fs/app/controller/CourseController.java

@@ -15,6 +15,7 @@ import com.fs.course.service.*;
 import com.fs.course.service.impl.TencentCloudCosService;
 import com.fs.course.vo.*;
 import com.fs.his.vo.OptionsVO;
+import com.fs.store.service.IFsStorePaymentService;
 import com.fs.system.service.ISysConfigService;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -43,6 +44,8 @@ public class CourseController extends  AppBaseController{
     @Autowired
     private IFsUserCourseService courseService;
     @Autowired
+    private IFsStorePaymentService storePaymentService;
+    @Autowired
     private IFsUserCourseCategoryService courseCategoryService;
 
     @Autowired
@@ -539,4 +542,17 @@ public class CourseController extends  AppBaseController{
         return R.ok().put("data", pageInfo);
     }
 
+
+    /**
+     * 手动根据销售员工信息发放奖励
+     * @param userId
+     * @return
+     */
+    @GetMapping("/sendRewardByTest")
+    public R sendRewardByTest(@RequestBody Long userId)
+    {
+        logger.info("zyp \n【发放奖励】：{}",userId);
+        return  storePaymentService.sendRewardByTest(userId);
+    }
+
 }