feats

pom.xml

@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>com.huiju</groupId>
 	<artifactId>xiangsong</artifactId>
-	<version>1.0.29</version>
+	<version>1.0.30</version>
 	<name>xiangsong</name>
 	<description>香颂</description>
 

src/main/java/com/huiju/estateagents/property/dao/TaUserVerifyMapper.java

@@ -7,6 +7,7 @@ import com.huiju.estateagents.property.model.TaUserVerify;
 import org.apache.ibatis.annotations.*;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -163,4 +164,5 @@ public interface TaUserVerifyMapper extends BaseMapper<TaUserVerify> {
                                                     @Param("levelId") Integer levelId,
                                                     @Param("roomNoId") Integer roomNoId);
 
+    Page<Map<String, String>> getPropUserByPaged(Page<Map<String, String>> page, @Param("orgId") Integer orgId);
 }

src/main/java/com/huiju/estateagents/property/service/ITaUserVerifyService.java

@@ -1,10 +1,13 @@
 package com.huiju.estateagents.property.service;
 
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.center.taUser.entity.TaUser;
 import com.huiju.estateagents.property.model.TaUserVerify;
 
+import java.util.Map;
+
 /**
  * 审核 业务
  */
@@ -80,4 +83,10 @@ public interface ITaUserVerifyService extends IService<TaUserVerify> {
      */
     ResponseBean deleteCurrentUserVerify(TaUser userElement, Integer userVerifyId);
 
+    /**
+     * 获取所有业主基础内容
+     * @param orgId
+     * @return
+     */
+    Page<Map<String, String>> getPropUserByPaged(Page<Map<String, String>> page, Integer orgId);
 }

src/main/java/com/huiju/estateagents/property/service/impl/TaUserVerifyServiceImpl.java

@@ -471,4 +471,9 @@ public class TaUserVerifyServiceImpl extends ServiceImpl<TaUserVerifyMapper, TaU
         responseBean.addSuccess("操作成功！");
         return responseBean;
     }
+
+    @Override
+    public Page<Map<String, String>> getPropUserByPaged(Page<Map<String, String>> page, Integer orgId) {
+        return taUserVerifyMapper.getPropUserByPaged(page, orgId);
+    }
 }

src/main/java/com/huiju/estateagents/task/MpMessageEvent.java

@@ -1,22 +1,65 @@
 package com.huiju.estateagents.task;
 
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.huiju.estateagents.common.WxUtils;
+import com.huiju.estateagents.entity.TaOrg;
+import com.huiju.estateagents.property.service.ITaUserVerifyService;
+import com.huiju.estateagents.service.ITaOrgService;
 import com.huiju.estateagents.third.service.ITaMpInfoService;
 import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.mp.api.WxMpService;
+import org.checkerframework.checker.units.qual.A;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
 @Slf4j
 @Component
 public class MpMessageEvent {
+    @Autowired
+    WxUtils wxUtils;
 
     @Autowired
     ITaMpInfoService iTaMpInfoService;
 
+    @Autowired
+    ITaOrgService iTaOrgService;
+
+    @Autowired
+    ITaUserVerifyService iTaUserVerifyService;
+
     // 发送生日祝福
     @Scheduled(cron = "0 0 8 * * ?")
     public void sendBirthdayMessage() {
+        List<TaOrg> orgList = iTaOrgService.list();
+        for (TaOrg org: orgList) {
+            WxMpService mpService = wxUtils.getMpService(org.getOrgId());
+            if (null == mpService) {
+                continue;
+            }
+
+            long pageNum = 1L;
+            long pageSize = 10L;
+            long total = 0L;
+
+//            while (true) {
+//                Page<Map<String, String>> page = new Page<>(pageNum, pageSize);
+//                Page<Map<String, String>> result = iTaUserVerifyService.getPropUserByPaged(page, org.getOrgId());
+//
+//
+//
+//                pageNum = result.getCurrent();
+//                total = result.getTotal();
+//                if ((pageNum - 1) * pageSize >= total) {
+//                    break;
+//                }
+//            }
 
+        }
     }
 
     // 发送节日祝福

src/main/resources/mapper/property/TaUserVerifyMapper.xml

@@ -93,4 +93,19 @@
             and verify_status = #{verifyStatus}
         </if>
     </select>
+
+    <select id="getPropUserByPaged" resultType="java.util.Map">
+        SELECT DISTINCT
+            t.person_id as personId,
+            t.owner_name as ownerName,
+            t.id_card as idCard,
+            m.mp_openid as mpOpenid
+        FROM
+            ta_user_verify t
+        INNER JOIN ta_mp_miniapp s ON t.person_id = s.miniapp_person_id
+        INNER JOIN ta_mp_person m ON s.mp_person_id = m.mp_person_id
+        WHERE
+            t.org_id = #{orgId}
+            AND t.verify_status = 1
+    </select>
 </mapper>