Commit 3f64712b by 墨竹

fix:bug修改

parent bb294ddc
...@@ -18,4 +18,14 @@ public interface WxApplicationMapper { ...@@ -18,4 +18,14 @@ public interface WxApplicationMapper {
@Param("applicationType") int applicationType); @Param("applicationType") int applicationType);
int cancelWxApplication(@Param("wxEnterpriseId") String wxEnterpriseId, @Param("suiteId") String suiteId); int cancelWxApplication(@Param("wxEnterpriseId") String wxEnterpriseId, @Param("suiteId") String suiteId);
/**
* 选择通过公司id
*
* @param corpid corpid
* @return {@link TabHaobanWxApplication }
* @author mozhu
* @date 2021-12-21 22:00:54
*/
TabHaobanWxApplication selectByCorpId(@Param("corpid") String corpid);
} }
\ No newline at end of file
...@@ -96,7 +96,7 @@ public class HandoverOperationApiServiceImpl implements HandoverOperationApiServ ...@@ -96,7 +96,7 @@ public class HandoverOperationApiServiceImpl implements HandoverOperationApiServ
@Override @Override
public void dealQywxEnterpriseHandover(String wxEnterpriseId) { public void dealQywxEnterpriseHandover(String wxEnterpriseId) {
WxEnterpriseDTO wxEnterpriseDTO = wxEnterpriseService.selectById(wxEnterpriseId); WxEnterpriseDTO wxEnterpriseDTO = wxEnterpriseService.selectById(wxEnterpriseId);
logger.info("拉取单个企业微信的离职成员:{}", wxEnterpriseId, JSONObject.toJSONString(wxEnterpriseDTO)); logger.info("拉取单个企业微信的离职成员:{},{}", wxEnterpriseId, JSONObject.toJSONString(wxEnterpriseDTO));
List<QywxUnassignedInfoDTO> allQywxUnassigned = getAllQywxUnassigned(wxEnterpriseDTO); List<QywxUnassignedInfoDTO> allQywxUnassigned = getAllQywxUnassigned(wxEnterpriseDTO);
logger.info("处理离职成员数量:{},{}", wxEnterpriseId, allQywxUnassigned.size()); logger.info("处理离职成员数量:{},{}", wxEnterpriseId, allQywxUnassigned.size());
handoverService.saveHandover(wxEnterpriseId, allQywxUnassigned); handoverService.saveHandover(wxEnterpriseId, allQywxUnassigned);
......
...@@ -34,6 +34,7 @@ import com.gic.haoban.manage.api.service.MemberUnionidRelatedApiService; ...@@ -34,6 +34,7 @@ import com.gic.haoban.manage.api.service.MemberUnionidRelatedApiService;
import com.gic.haoban.manage.service.config.Config; import com.gic.haoban.manage.service.config.Config;
import com.gic.haoban.manage.service.dao.mapper.MemberUnionidRelatedMapper; import com.gic.haoban.manage.service.dao.mapper.MemberUnionidRelatedMapper;
import com.gic.haoban.manage.service.dao.mapper.TabHaobanWelcomeMapper; import com.gic.haoban.manage.service.dao.mapper.TabHaobanWelcomeMapper;
import com.gic.haoban.manage.service.dao.mapper.WxApplicationMapper;
import com.gic.haoban.manage.service.entity.*; import com.gic.haoban.manage.service.entity.*;
import com.gic.haoban.manage.service.exception.WxApiLimitException; import com.gic.haoban.manage.service.exception.WxApiLimitException;
import com.gic.haoban.manage.service.pojo.DealQywxExternalUserPojo; import com.gic.haoban.manage.service.pojo.DealQywxExternalUserPojo;
...@@ -124,6 +125,8 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -124,6 +125,8 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
@Autowired @Autowired
private CustomerApiService customerApiService; private CustomerApiService customerApiService;
@Autowired
private WxApplicationMapper wxApplicationMapper;
@Override @Override
public void dealQywxExternalUser(String params) { public void dealQywxExternalUser(String params) {
...@@ -726,12 +729,24 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -726,12 +729,24 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
public MemberUnionidRelatedDTO getMemberUnionidRelatedDTONew(MemberUnionidRelatedDTO dto) { public MemberUnionidRelatedDTO getMemberUnionidRelatedDTONew(MemberUnionidRelatedDTO dto) {
log.info("【新增外部联系人回调】dto={}", JSON.toJSONString(dto)); log.info("【新增外部联系人回调】dto={}", JSON.toJSONString(dto));
String corpId = dto.getCorpid(); String corpId = dto.getCorpid();
TabHaobanWxEnterprise wxEnterprise = wxEnterpriseService.getEnterpriseBycorpId(corpId); String wxEnterpriseId = "";
if (wxEnterprise == null) { //做兼容
return null; if (corpId.length() > 20) {
TabHaobanWxApplication tabHaobanWxApplication = wxApplicationMapper.selectByCorpId(corpId);
if (tabHaobanWxApplication == null) {
log.info("查询tab_haoban_wx_application为空:{}", corpId);
return null;
}
wxEnterpriseId = tabHaobanWxApplication.getWxEnterpriseId();
} else {
TabHaobanWxEnterprise wxEnterprise = wxEnterpriseService.getEnterpriseBycorpId(corpId);
if (wxEnterprise == null) {
log.info("查询tab_haoban_wx_enterprise为空:{}", corpId);
return null;
}
wxEnterpriseId = wxEnterprise.getWxEnterpriseId();
} }
//校验friend //校验friend
String wxEnterpriseId = wxEnterprise.getWxEnterpriseId();
String userId = dto.getWxUserId(); String userId = dto.getWxUserId();
String suiteid = dto.getSuiteid(); String suiteid = dto.getSuiteid();
ExternalUserDTO externalUserDTO; ExternalUserDTO externalUserDTO;
...@@ -745,7 +760,6 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -745,7 +760,6 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
log.info("【新增外部联系人回调】unionIdJson=null"); log.info("【新增外部联系人回调】unionIdJson=null");
return null; return null;
} }
dto.setWxEnterpriseId(wxEnterpriseId); dto.setWxEnterpriseId(wxEnterpriseId);
dto.setExternalName(EmojiFilterUtil.removeAllEmoji(externalUserDTO.getName())); dto.setExternalName(EmojiFilterUtil.removeAllEmoji(externalUserDTO.getName()));
dto.setAddCreateTime(externalUserDTO.getAddCreateTime()); dto.setAddCreateTime(externalUserDTO.getAddCreateTime());
...@@ -777,7 +791,6 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -777,7 +791,6 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
mid.setStatusFlag(0); mid.setStatusFlag(0);
memberUnionRelatedService.update(mid); memberUnionRelatedService.update(mid);
}); });
} }
memberUnionRelatedService.update(dto); memberUnionRelatedService.update(dto);
RedisUtil.unlock(lockKey); RedisUtil.unlock(lockKey);
......
...@@ -189,4 +189,12 @@ ...@@ -189,4 +189,12 @@
and site_id = #{suiteId} and site_id = #{suiteId}
and status_flag = 1 and status_flag = 1
</update> </update>
<select id="selectByCorpId" resultMap="BaseResultMap" parameterType="java.lang.String">
select
<include refid="Base_Column_List"/>
from tab_haoban_wx_application
where corpid = #{corpid,jdbcType=VARCHAR} and status_flag = 1 limit 1
</select>
</mapper> </mapper>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment