一次性订阅枚举

ch-core/src/main/java/com/wwdz/ch/core/consts/DisposableSubscribeRecordEnum.java

+package com.wwdz.ch.core.consts;
+
+public class DisposableSubscribeRecordEnum {
+}

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/distribution/DisposableSubscribeRecordServiceImpl.java

 package com.wwdz.ch.wx.impl.distribution;
 
+import com.wwdz.ch.core.api.WxAppletApi;
 import com.wwdz.ch.core.type.Result;
 import com.wwdz.ch.db.dao.DisposableSubscribeRecordDao;
+import com.wwdz.ch.db.dao.UserDao;
+import com.wwdz.ch.db.domain.User;
 import com.wwdz.ch.db.domain.distribution.DisposableSubscribeRecord;
 import com.wwdz.ch.db.dto.request.distribution.DisposableSubscribeRecordRequestDto;
 import com.wwdz.ch.wx.service.distribution.DisposableSubscribeRecordService;
@@ -21,16 +24,22 @@ public class DisposableSubscribeRecordServiceImpl implements DisposableSubscribe
     @Autowired
     DisposableSubscribeRecordDao disposableSubscribeRecordDao;
 
+    @Autowired
+    UserDao userDao;
+
     @Override
     public Result subscribed(DisposableSubscribeRecordRequestDto dto) {
         try {
-            String openid = dto.getOpenid();
+            long userId = dto.getUserId();
+            User user = userDao.queryById(userId);
+            String openid = user.getWeixinOpenid();
             String templateId = dto.getTemplateId();
             long targetId = dto.getTargetId();
             DisposableSubscribeRecord disposableSubscribeRecord = new DisposableSubscribeRecord();
             EntityMapper.copyAttribute(dto, disposableSubscribeRecord);
+            disposableSubscribeRecord.setOpenid(openid);
             disposableSubscribeRecord.setIsValid(true);
-            //如果有历史记录，则做更新
+            //没订阅过就新增数据
             if (!disposableSubscribeRecordDao.isSubscribed(openid, targetId, templateId)) {
                 disposableSubscribeRecordDao.insert(disposableSubscribeRecord);
             }