feat:微信通知改造

coolstore-partner-dao/src/main/java/com/cool/store/dao/PartnerUserWechatBindDAO.java

@@ -31,6 +31,27 @@ public class PartnerUserWechatBindDAO {
         return partnerUserWechatBindMapper.insert(partnerUserWechatBindDO);
     }
 
+    /**
+     * 更新
+     * @param partnerUserWechatBindDO
+     * @return
+     */
+    public Integer update(PartnerUserWechatBindDO partnerUserWechatBindDO) {
+        if (partnerUserWechatBindDO == null) {
+            return 0;
+        }
+        return partnerUserWechatBindMapper.update(partnerUserWechatBindDO);
+    }
+
+    /**
+     * 更新所有的unionId对应的服务号ID
+     * @param unionId 开发平台的用户ID
+     * @param serviceAccountOpenId 服务号ID
+     * @return
+     */
+    public Integer updateByUnionId(String unionId,String serviceAccountOpenId) {
+        return partnerUserWechatBindMapper.updateByUnionId(unionId,serviceAccountOpenId);
+    }
 
     public PartnerUserWechatBindDO getByOpenIdAndPartnerId(String partnerId, String openId) {
         if (StringUtil.isEmpty(partnerId)|| StringUtil.isEmpty(openId)){

coolstore-partner-dao/src/main/java/com/cool/store/mapper/PartnerUserWechatBindMapper.java

@@ -18,6 +18,22 @@ public interface PartnerUserWechatBindMapper {
      */
     Integer insert(PartnerUserWechatBindDO partnerUserWechatBindDO);
 
+    /**
+     * 更新数据
+     * @param partnerUserWechatBindDO
+     * @return
+     */
+    Integer update(PartnerUserWechatBindDO partnerUserWechatBindDO);
+
+
+    /**
+     * 更新所有的unionId对应的服务号ID
+     * @param unionId 开发平台的用户ID
+     * @param serviceAccountOpenId 服务号ID
+     * @return
+     */
+    Integer updateByUnionId(String unionId,String serviceAccountOpenId);
+
     /**
      * 根据partnerId与openId查询
      * @param partnerId

coolstore-partner-dao/src/main/resources/mapper/PartnerUserWechatBindMapper.xml

@@ -8,6 +8,8 @@
         <result column="open_id" property="openId" jdbcType="VARCHAR" />
         <result column="bind_time" property="bindTime" jdbcType="TIMESTAMP" />
         <result column="partner_id" property="partnerId" jdbcType="VARCHAR" />
+        <result column="union_id" property="unionId" jdbcType="VARCHAR" />
+        <result column="service_account_open_id" property="serviceAccountOpenId" jdbcType="VARCHAR" />
         <result column="create_time" property="createTime" jdbcType="TIMESTAMP" />
         <result column="update_time" property="updateTime" jdbcType="TIMESTAMP" />
     </resultMap>
@@ -17,15 +19,33 @@
         open_id,
         bind_time,
         partner_id,
+        union_id,
         create_time
         ) VALUES (
         #{openId, jdbcType=VARCHAR},
         #{bindTime, jdbcType=TIMESTAMP},
         #{partnerId, jdbcType=VARCHAR},
+        #{unionId, jdbcType=VARCHAR},
         #{createTime, jdbcType=TIMESTAMP}
         )
     </insert>
 
+    <update id="update" parameterType="com.cool.store.entity.PartnerUserWechatBindDO">
+        UPDATE xfsg_partner_user_wechat_bind
+        <set>
+            <if test="unionId != null">
+                union_id = #{unionId, jdbcType=VARCHAR},
+            </if>
+            where id = #{id}
+        </set>
+    </update>
+
+    <update id="updateByUnionId" >
+        UPDATE xfsg_partner_user_wechat_bind
+        set service_account_open_id = #{serviceAccountOpenId}
+        where union_id = #{unionId}
+    </update>
+
     <select id="selectByPartnerAndOpenId" resultMap="BaseResultMap">
         select * from xfsg_partner_user_wechat_bind where partner_id = #{partnerId} and open_id = #{openId}
     </select>

coolstore-partner-model/src/main/java/com/cool/store/entity/PartnerUserWechatBindDO.java

@@ -36,6 +36,10 @@ public class PartnerUserWechatBindDO implements Serializable {
      */
     private String partnerId;
 
+    private String unionId;
+
+    private String serviceAccountOpenId;
+
     /**
      * 创建时间
      */

coolstore-partner-service/src/main/java/com/cool/store/service/impl/WechatMiniAppServiceImpl.java

@@ -110,9 +110,14 @@ public class WechatMiniAppServiceImpl implements WechatMiniAppService {
             PartnerUserWechatBindDO bindDO = new PartnerUserWechatBindDO();
             bindDO.setBindTime(new Date());
             bindDO.setOpenId(openid);
+            bindDO.setUnionId(unionId);
             bindDO.setPartnerId(hyPartnerUserInfoDO.getPartnerId());
             bindDO.setCreateTime(new Date());
             partnerUserWechatBindDAO.insertSelective(bindDO);
+        }else {
+            //维护unionId 针对老数据没有unionId
+            zlPartnerUserBindDO.setUnionId(unionId);
+            partnerUserWechatBindDAO.update(zlPartnerUserBindDO);
         }
         BeanUtil.copyProperties(hyPartnerUserInfoDO, userInfoVO);
         fillLineInfo(userInfoVO, hyPartnerUserInfoDO.getPartnerId());