Procházet zdrojové kódy

//update

release_toaliyun_real
xhxu před 4 roky
rodič
revize
6db17deaab
3 změnil soubory, kde provedl 35 přidání a 1 odebrání
  1. +2
    -0
      mallinkService/src/main/java/com/iformall/service/MallCooUserInfoService.java
  2. +9
    -1
      mallinkService/src/main/java/com/iformall/service/impl/MallCooUserInfoServiceImpl.java
  3. +24
    -0
      mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java

+ 2
- 0
mallinkService/src/main/java/com/iformall/service/MallCooUserInfoService.java Zobrazit soubor

@@ -24,6 +24,8 @@ public interface MallCooUserInfoService {
*/
MallCooUserInfo getById(Long id,String finalTenantId);

MallCooUserInfo getByPhone(String phone,String finalTenantId);

void pullByMobile(TenantEntity tenantEntity, WxCUserBasicInfo basicInfo);

}


+ 9
- 1
mallinkService/src/main/java/com/iformall/service/impl/MallCooUserInfoServiceImpl.java Zobrazit soubor

@@ -46,6 +46,14 @@ public class MallCooUserInfoServiceImpl implements MallCooUserInfoService {
return mallCooUserInfoMapper.selectById(id,finalTenantId);
}

@Override
public MallCooUserInfo getByPhone(String phone, String finalTenantId) {
MallCooUserInfo userInfo = new MallCooUserInfo();
userInfo.setFinalTenantId(finalTenantId);
userInfo.setPhone(phone);
return mallCooUserInfoMapper.selectOne(new QueryWrapper<>(userInfo));
}

@Async
@Override
public void pullByMobile(TenantEntity tenantEntity, WxCUserBasicInfo basicInfo) {
@@ -58,7 +66,7 @@ public class MallCooUserInfoServiceImpl implements MallCooUserInfoService {
if(StringUtils.isBlank(basicInfo.getPhone())){
basicInfo = wxCUserBasicInfoMapper.selectById(basicInfo.getId(),basicInfo.getFinalTenantId());
}
MallCooUserInfo mallCooUserInfo = this.getById(basicInfo.getId(), basicInfo.getFinalTenantId());
MallCooUserInfo mallCooUserInfo = this.getByPhone(basicInfo.getPhone(), basicInfo.getFinalTenantId());
if(mallCooUserInfo == null){
String openUserID = MallcooHelper.openByMobile(config, basicInfo.getPhone(), null);
if(StringUtils.isNotBlank(openUserID)){


+ 24
- 0
mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java Zobrazit soubor

@@ -307,4 +307,28 @@ public class AliyunSMS implements SMSExcutor {
return new DefaultAcsClient(profile);
}


public static void main(String[] args) {
IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", "LTAI4GKRhF2aSXuQi9FGPRGQ", "LD2Z12QI5ZOlhaFjatJipwFSb2dgjm");
try {
DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", "Dysmsapi", "dysmsapi.aliyuncs.com");
} catch (ClientException e) {
log.error("获取短信发送服务机发生错误。错误代码是 [{}],错误消息是 [{}],错误请求ID是 [{}],错误Msg是 [{}],错误类型是 [{}]",
e.getErrCode(), e.getMessage(), e.getRequestId(), e.getErrMsg(), e.getErrorType());
}
QuerySmsTemplateRequest request = new QuerySmsTemplateRequest();
request.setTemplateCode("SMS_239312983");

DefaultAcsClient acsClient = new DefaultAcsClient(profile);
QuerySmsTemplateResponse response = null;
try {
response = acsClient.getAcsResponse(request);
} catch (ClientException e) {
log.error("查询模板发生错误。错误代码是 [{}],错误消息是 [{}],错误请求ID是 [{}],错误Msg是 [{}],错误类型是 [{}]",
e.getErrCode(), e.getMessage(), e.getRequestId(), e.getErrMsg(), e.getErrorType());
}
log.info(" 查询模板----" + response.getCode() + "----" + JSON.toJSONString(response));

}

}

Načítá se…
Zrušit
Uložit