微信登录修改

server/src/main/java/com/pica/cloud/account/account/server/controller/LoginController.java

@@ -120,16 +120,16 @@ public class LoginController extends AccountBaseController {
     @PostMapping("/login/wechat/bind")
     public PicaResponse bindWeChat(@RequestBody EncryptEntity entity) throws Exception {
         BaseRequest request = CryptoUtil.decrypt(entity, BaseRequest.class);
-        request.setAccId(super.getAcctId());
-        loginService.bindWeChat(request);
+        long doctorId = super.getDoctorIdByToken();
+        loginService.bindWeChat(doctorId, request);
         return PicaResponse.toResponse();
     }
 
     @ApiOperation("微信解除绑定接口")
     @PutMapping("/login/wechat/unbind")
     public PicaResponse unbindWeChat() {
-        Integer acctId = super.getAcctId();
-        loginService.unbindWeChat(acctId);
+        long doctorId = super.getDoctorIdByToken();
+        loginService.unbindWeChat(doctorId);
         return PicaResponse.toResponse();
     }
 

server/src/main/java/com/pica/cloud/account/account/server/mapper/DoctorMapper.java

@@ -92,4 +92,6 @@ public interface DoctorMapper {
      * @return
      */
     //Long selectDoctorIdByMobile(String mobile);
+
+    Integer getAcctIdByDoctorId(long id);
 }
\ No newline at end of file

server/src/main/java/com/pica/cloud/account/account/server/service/LoginService.java

@@ -39,9 +39,9 @@ public interface LoginService {
     /**
      * 解除绑定
      *
-     * @param acctId 账户id
+     * @param doctorId 账户id
      */
-    void unbindWeChat(Integer acctId);
+    void unbindWeChat(long doctorId);
 
 
     /**
@@ -49,7 +49,7 @@ public interface LoginService {
      *
      * @param request 参数模型
      */
-    void bindWeChat(BaseRequest request);
+    void bindWeChat(long doctorId, BaseRequest request);
 
     PICAPDoctor queryDoctor(long doctorId);
 }

server/src/main/java/com/pica/cloud/account/account/server/service/impl/LoginServiceImpl.java

@@ -260,7 +260,8 @@ public class LoginServiceImpl implements LoginService {
 
     @Override
     @Transactional
-    public void unbindWeChat(Integer acctId) {
+    public void unbindWeChat(long doctorId) {
+        Integer acctId = doctorInfoMapper.getAcctIdByDoctorId(doctorId);
         accountUnionMapper.updateUnbindByAcctId(acctId);
         if (doubleWritingMode) {
             doctorService.unbindWeChat(acctId);
@@ -269,7 +270,7 @@ public class LoginServiceImpl implements LoginService {
 
     @Override
     @Transactional
-    public void bindWeChat(BaseRequest request) {
+    public void bindWeChat(long doctorId, BaseRequest request) {
         WeChatEntity weChatEntity = WeChatUtils.getAuthorizationInfo(appId, appSecret, request.getWeChatCode());
         Map map = new HashMap();
         map.put("access_token", weChatEntity.getAccess_token());
@@ -281,7 +282,8 @@ public class LoginServiceImpl implements LoginService {
         if (entity == null) {
             processWeChatInfoUser(weChatUserInfoEntity, request.getWeChatLoginType());
         }
-        processAccountUnion(request.getAccId(), unionId);
+        Integer acctId = doctorInfoMapper.getAcctIdByDoctorId(doctorId);
+        processAccountUnion(acctId, unionId);
     }
 
     /**

server/src/main/resources/mybatis/AccountUnionEntityMapper.xml

@@ -29,7 +29,8 @@
         select
         <include refid="Base_Column_List"/>
         from account_union
-        where union_id = #{unionId}
+        where union_id = #{unionId} and delete_flag = 1
+        limit 1
     </select>
 
     <!--解除绑定关系-->

server/src/main/resources/mybatis/AccountWeChatInfoEntityMapper.xml

@@ -44,7 +44,8 @@
     select
     <include refid="Base_Column_List"/>
     from account_wechat_info
-    where unionid = #{id}
+    where unionid = #{id} and delete_flag = 1
+    limit 1
   </select>
 
   <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >

server/src/main/resources/mybatis/DoctorMapper.xml

@@ -1026,4 +1026,8 @@
         FROM p_doctor aa
         where aa.id = #{doctorId} and aa.delete_flag = 1
     </select>
+
+    <select id="getAcctIdByDoctorId" resultType="java.lang.Integer" parameterType="java.lang.Long">
+      select acct_id from p_doctor where id = #{id}
+    </select>
 </mapper>
\ No newline at end of file