Commit 955d320a authored by 王亮's avatar 王亮

format code.

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