feats

pom.xml

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

src/main/java/com/huiju/estateagents/EstateagentsApplication.java

@@ -4,14 +4,18 @@ import com.huiju.estateagents.websocket.ChatServer;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+@EnableAsync
+@EnableScheduling
 @SpringBootApplication
 public class EstateagentsApplication {
 
 	public static void main(String[] args) {
 		SpringApplication springApplication = new SpringApplication(EstateagentsApplication.class);
 		ConfigurableApplicationContext configurableApplicationContext = springApplication.run(args);
-		ChatServer.setApplicationContext(configurableApplicationContext);
+//		ChatServer.setApplicationContext(configurableApplicationContext);
 	}
 
 }

src/main/java/com/huiju/estateagents/center/taUser/service/impl/TaUserServiceImpl.java

@@ -569,7 +569,7 @@ public class TaUserServiceImpl extends ServiceImpl<TaUserMapper, TaUser> impleme
         taPersonBuildingQueryWrapper.eq("user_id", taUser.getUserId());
         taPersonBuildingMapper.delete(taPersonBuildingQueryWrapper);
         //保存项目
-        if (taUser.getIsConsultant()) {
+        if (Boolean.valueOf(true).equals(taUser.getIsConsultant())) {
             TaPersonBuilding taPersonBuilding = new TaPersonBuilding();
             taPersonBuilding.setBuildingId(taUser.getBuildingId());
             taPersonBuilding.setUserId(taUser.getUserId());

src/main/java/com/huiju/estateagents/controller/MiniAppController.java

@@ -255,7 +255,7 @@ public class MiniAppController extends BaseController {
             }
             taPersonService.updateById(taPerson);
 
-            if (StringUtils.isEmpty(mpOpenId)) {
+            if (!StringUtils.isEmpty(mpOpenId)) {
                 iTaMpMiniappService.mpPerson(taPerson, mpOpenId);
             }
 

src/main/java/com/huiju/estateagents/controller/WxPortalController.java

@@ -4,6 +4,7 @@ import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.common.WxUtils;
 import com.huiju.estateagents.entity.TaMiniapp;
+import com.huiju.estateagents.redpack.entity.TaMpMiniapp;
 import com.huiju.estateagents.redpack.entity.TaMpPerson;
 import com.huiju.estateagents.redpack.service.ITaMpPersonService;
 import com.huiju.estateagents.service.IMiniAppService;
@@ -122,8 +123,9 @@ public class WxPortalController extends BaseController {
         TaMiniapp taMiniapp = iMiniAppService.getAppByOrg(mpInfo.getOrgId());
 
         WxMpKefuMessage kefuMessage = WxMpKefuMessage.MINIPROGRAMPAGE().appId(taMiniapp.getMiniappId())
+                .toUser(person.getMpOpenid())
                 .title(taMiniapp.getName() + "欢迎您!")
-                .pagePath(miniAppIndex + "?mpOpenId=" + message.getOpenId())
+                .pagePath(miniAppIndex + "?mpOpenId=" + person.getMpOpenid() )
                 .thumbMediaId(mpInfo.getMiniappMedia())
                 .build();
 

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

@@ -0,0 +1,28 @@
+package com.huiju.estateagents.task;
+
+import com.huiju.estateagents.third.service.ITaMpInfoService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class MpMessageEvent {
+
+    @Autowired
+    ITaMpInfoService iTaMpInfoService;
+
+    // 发送生日祝福
+    @Scheduled(cron = "0 0 8 * * ?")
+    public void sendBirthdayMessage() {
+
+    }
+
+    // 发送节日祝福
+    @Scheduled(cron = "0 0 8 * * ?")
+    public void sendFestivalMessage() {
+
+    }
+
+}