消息推送

src/main/java/com/caimei365/user/mapper/MessageCenterMapper.java

@@ -39,6 +39,7 @@ public interface MessageCenterMapper {
     List<MessageCenter> MessageList(Integer userType,Integer messageType,Integer commonId);
 
     String contractMobile(Integer clubID);
+    String contractMobiles(Integer ShopID);
 
     String getOpenidListByPermission(String unionId);
 

src/main/java/com/caimei365/user/service/impl/LoginServiceImpl.java

@@ -190,8 +190,9 @@ public class LoginServiceImpl implements LoginService {
         Integer savedCount=null;
 if(userID!=null) {
     Integer shopID = messageCenterMapper.shopID(userID);
+    log.info(">>>>>"+shopID);
     Integer newReceiptType = messageCenterMapper.newReceiptType(shopID);
-
+    log.info(">>>>>"+newReceiptType);
     Timerw(userID);
     Timesjf(userID);
     }
@@ -1023,6 +1024,28 @@ if(userID!=null) {
             messageCenter.setContent(nickName);
             messageCenter.setTime(current);
             messageCenterMapper.addMessageCenter(messageCenter);
+
+            //发短信
+            String message = "【采美365】恭喜您成功成为“引号内填写完整的供应商名称”的运营人员，您可通过微信直接登录采美商城管理您的账号。";
+            String mobile = messageCenterMapper.contractMobiles(operation.getShopId());
+            if (mobile != null && mobile != "") {
+                remoteCallService.remoteSendSms(2, 3, mobile, message);
+            }
+            try {
+                log.info("***********供应商通过邀请码登入微信公众号推送************");
+                String accessToken = weChatService.getAccessToken();
+                String openid = messageCenterMapper.getOpenidListByPermission(unionId);
+                String time=current;
+                String remarkText = "绑定成功后，您可通过微信登录采美商城管理您的账号";
+                // 跳转到【小程序付款-选择支付方式页面】
+                String pagePath = "https://www.caimei365.com/";
+                // sendTemplateMsg(openid, 标题, 金额, 收款日期, 备注, 跳转链接
+                log.error("获取openid>>>>>" + openid);
+                weChatService.sendTemplateMessg(accessToken,openid,nickName,time,remarkText, pagePath);
+            } catch (Exception e) {
+                log.error("【供应商通过邀请码登入通知】获取微信公众号access_token异常！", e);
+            }
+
         }
         // 更新运营人员信息
         operationMapper.updateOperationByInvitation(operationPo);

src/main/java/com/caimei365/user/service/impl/ShopServiceImpl.java

@@ -426,7 +426,7 @@ public class ShopServiceImpl implements ShopService {
     public void Open() {
         Jedis jedis=new Jedis("172.31.165.27", 6379);
         jedis.auth("6#xsI%b4o@5c3RoE");
-        jedis.del("constraint");
+        jedis.lpush("constraint","0");
     }
 
     @Override

src/main/resources/mapper/MessageCenter.xml

@@ -14,9 +14,9 @@
         SELECT shopID FROM `shop` WHERE userId=#{userId}
     </select>
 
-    <select id="shopID" resultType="java.lang.Integer">
-        SELECT shopID FROM `shop` WHERE userId=#{userId}
-    </select>
+<!--    <select id="shopID" resultType="java.lang.Integer">-->
+<!--        SELECT shopID FROM `shop` WHERE userId=#{userId}-->
+<!--    </select>-->
 
     <select id="clubList" resultType="com.caimei365.user.model.vo.UserVo">
         SELECT * FROM `user` WHERE userId=#{userId}
@@ -83,6 +83,10 @@
         SELECT contractMobile FROM club WHERE clubID=#{clubID}
     </select>
 
+    <select id="contractMobiles" resultType="java.lang.String">
+        SELECT contractMobile FROM shop WHERE shopID=#{shopID}
+    </select>
+
     <select id="getOpenidListByPermission" resultType="java.lang.String">
         SELECT openid FROM `wechat_user` WHERE unionId= #{unionId}
     </select>
@@ -146,6 +150,7 @@
              LEFT JOIN shop s ON s.shopID = a.shopID
     where
         a.shopID=#{shopID}
+    LIMIT 1
 </select>
     <update id="updateMessageAsRead">
         UPDATE message_center SET saved = 1

src/test/java/com/caimei365/user/UserApplicationTests.java

@@ -71,8 +71,8 @@ class UserApplicationTests {
         }
     }*/
 
-    @Test
-    void contextLoads() {
+//    @Test
+//    void contextLoads() {
 //        Calendar cal = Calendar.getInstance();
 //        cal.setTime(new Date());
 //        cal.set(Calendar.HOUR_OF_DAY, 0);
@@ -84,5 +84,5 @@ class UserApplicationTests {
 //        System.out.println("=======================");
 //        cal.add(Calendar.DAY_OF_MONTH,1);
 //        System.out.println(cal.getTime());
-    }
+//    }
 }