Commit f34cf31b authored by 王亮's avatar 王亮

accomplish.

parent f3697ee9
...@@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONArray; ...@@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
import java.util.List;
import javax.annotation.Resource; import javax.annotation.Resource;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.amqp.rabbit.core.RabbitTemplate;
...@@ -23,21 +24,21 @@ public class BlackHoleRegisteredEventListener implements ApplicationListener<Reg ...@@ -23,21 +24,21 @@ public class BlackHoleRegisteredEventListener implements ApplicationListener<Reg
private String routingKey; private String routingKey;
@Resource @Resource
private RabbitTemplate registeredNotifyBlackHoleRabbitTemplate; private RabbitTemplate registeredNotifyBlackHoleRabbitTemplate;
private long [] templateIds = {8L,280L};
private long [] templateIds_159913 = {433L,434L}; // 羊小咩小程序的渠道,合同内容不包含现金分期业务,如果这种情况较多可以考虑配置化 // 用户注册合同中心模版id
private static final Long YXM_CHANNEL = 159913L; // 羊小咩小程序的渠道(小程序_电商,小程序_VCC) @Value("${register.templateids}")
private List<Long> templateIds;
@Override @Override
public void onApplicationEvent(RegisterEvent event) { public void onApplicationEvent(RegisterEvent event) {
UserRegisterParam userRegisterParam = event.getUserRegisterParam(); User user = event.getUserRegisterParam().getUser();
User user = userRegisterParam.getUser(); log.info("onApplicationEvent cn.quantgroup.xyqb.event.BlackHoleRegisteredEventListener start userId = 【{}】, registerFrom = 【{}】", user.getId(), event);
log.info("onApplicationEvent cn.quantgroup.xyqb.event.BlackHoleRegisteredEventListener start userId = 【{}】, registerFrom = 【{}】", user.getId(), userRegisterParam.getRegisterFrom());
LocalDate signDate = LocalDate.now(); LocalDate signDate = LocalDate.now();
String dateStr = signDate.format(DateTimeFormatter.ofPattern("yyyy年MM月dd日")); String dateStr = signDate.format(DateTimeFormatter.ofPattern("yyyy年MM月dd日"));
int day = signDate.getDayOfMonth(); int day = signDate.getDayOfMonth();
// 信用钱包服务与隐私协议 // 信用钱包服务与隐私协议
long[] regTempIds = YXM_CHANNEL.equals(userRegisterParam.getRegisterFrom()) ? templateIds_159913 : templateIds; templateIds.forEach(id->{
for (long id : regTempIds) {
JSONObject fields = new JSONObject(); JSONObject fields = new JSONObject();
fields.put("phoneNo", user.getPhoneNo()); fields.put("phoneNo", user.getPhoneNo());
fields.put("genarateDateStr", dateStr); fields.put("genarateDateStr", dateStr);
...@@ -50,8 +51,6 @@ public class BlackHoleRegisteredEventListener implements ApplicationListener<Reg ...@@ -50,8 +51,6 @@ public class BlackHoleRegisteredEventListener implements ApplicationListener<Reg
JSONArray array = new JSONArray(); JSONArray array = new JSONArray();
array.add(json); array.add(json);
registeredNotifyBlackHoleRabbitTemplate.convertAndSend(exchange, routingKey, array.toString()); registeredNotifyBlackHoleRabbitTemplate.convertAndSend(exchange, routingKey, array.toString());
} });
} }
} }
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