fix

netflix-dao/src/main/resources/mapper/UserDistributeMapper.xml

@@ -6,8 +6,8 @@
         select count(*)
         from `user_distribute_shared` us
                  inner join `order_don` od
-                            on od.user_id = us.shared_id
-        where us.shar_id = #{userId}
+                            on od.user_id = us.user_id
+        where us.shared_id = #{userId}
           and od.status not in ('close', 'noPayment', 'refund')
     </select>
 </mapper>

netflix-service/src/main/java/com/cyksj/task/Scheduler.java

@@ -211,14 +211,14 @@ public class Scheduler {
                         DistributeWaitingSendPoints::getUserId,
                         DistributeWaitingSendPoints::getSendTime))).orElse(new ArrayList<>());
         log.info("查询分销订单积分分发记录开始,条数:{}=======》", waitingSendPoints.size());
-        waitingSendPoints.forEach(wait->{
+        waitingSendPoints.forEach(wait -> {
             Long userId = wait.getUserId();
             User user = userMapper.selectById(userId);
             if (user == null) {
                 wait.setSendStatus(DistributeWaitingSendPoints.Status.not_exist);
                 log.info("分销订单,发送积分用户不存在");
                 distributeWaitingSendPointsMapper.updateById(wait);
-            }else {
+            } else {
                 wait.setSendStatus(DistributeWaitingSendPoints.Status.success);
                 log.info("更新用户积分开始=====>");
                 Integer update = userMapper.addPoints(user.getId(), wait.getPoints());