Authored by unknown

update

... ... @@ -23,9 +23,9 @@ consumer:
producer:
- address: ${rabbit_common}
username: ${rabbit_common_user}
password: ${rabbit_common_password}
- address: 172.16.6.54:5672
username: yoho
password: yoho
producers:
- bean: yhProducer
async: true
... ...
... ... @@ -24,12 +24,12 @@ consumer:
producer:
- address: ${rabbit_crm_host}
username: ${rabbit_crm_user}
password: ${rabbit_crm_password}
producers:
- bean: yhProducer
async: true
trace: false
confirm: true
persistent: false
\ No newline at end of file
- address: ${rabbit_common}
username: ${rabbit_common_user}
password: ${rabbit_common_password}
producers:
- bean: yhProducer
async: true
trace: false
confirm: true
persistent: false
\ No newline at end of file
... ...
... ... @@ -178,7 +178,7 @@ public class WechatServiceImpl implements IWechatService {
JSONObject object = new JSONObject();
object.put("activityId",customMsgBO.getSendKey());
object.put("sendNum",sendSuccessList.size());
yhProducer.send(Consts.CUSTOM_MSG_SEND_NUM_TOPIC,object.toJSONString());
yhProducer.send(Consts.CUSTOM_MSG_SEND_NUM_TOPIC,object);
}
private void getDaysFilter(WechatCustomMsgBO customMsgBO, Set<String> openIdSet) {
... ... @@ -186,10 +186,8 @@ public class WechatServiceImpl implements IWechatService {
//根据间隔天数计算出需要过滤到的最早的一天
Calendar calendar = Calendar.getInstance();
calendar.add(Calendar.DATE, -filterDayReal);
String startDate = DateUtil.dateToString(calendar.getTime(), DATE_ID_FORMAT);
Date date = DateUtil.stringToDate(startDate,DATE_ID_FORMAT);
Calendar c = Calendar.getInstance();
c.setTime(date);
c.setTime(calendar.getTime());
int day = c.get(Calendar.DATE);
for (int i = 0; i <= filterDayReal; i++){
//从最早日期开始往后累加到每个日期,每天过滤
... ...