与管理平台传输注册记录

git-svn-id: svn+ssh://10.10.101.21/source/platform/platform-b2b@1036 f3bf4e98-0cf0-11e4-a00c-a99a8b9d557d

src/main/java/com/uas/platform/b2b/dao/RegisterRecordDao.java

@@ -1,5 +1,7 @@
 package com.uas.platform.b2b.dao;
 
+import java.util.List;
+
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 import org.springframework.stereotype.Repository;
 
@@ -9,4 +11,5 @@ import com.uas.platform.core.data.repository.GenericRepository;
 @Repository
 public interface RegisterRecordDao extends JpaSpecificationExecutor<RegisterRecord>, GenericRepository<RegisterRecord, Long> {
 	
+	public List<RegisterRecord> findBySendStatus(Short sendStatus);
 }

src/main/java/com/uas/platform/b2b/manage/controller/EnterpriseController.java

@@ -15,7 +15,9 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.ResponseBody;
 
 import com.uas.platform.b2b.model.Enterprise;
+import com.uas.platform.b2b.model.RegisterRecord;
 import com.uas.platform.b2b.service.EnterpriseService;
+import com.uas.platform.b2b.service.RegisterLogService;
 import com.uas.platform.b2b.service.UserService;
 import com.uas.platform.core.util.serializer.FlexJsonUtils;
 
@@ -33,6 +35,8 @@ public class EnterpriseController {
 	private EnterpriseService enterpriseService;
 	@Autowired
 	private UserService userService;
+	@Autowired
+	private RegisterLogService registerLogService;
 	
 	/**
 	 *管理平台获取需要审核的企业
@@ -107,5 +111,32 @@ public class EnterpriseController {
 		List<Long> enUUs = FlexJsonUtils.fromJsonArray(jsonStr, Long.class);
 		enterpriseService.enabledUploadSuccess(enUUs);
 	}
+	
+	/**
+	 * 获取平台上记录的注册相关记录
+	 * 
+	 * @param email
+	 * @return
+	 */
+	@RequestMapping(value = "/log", method = RequestMethod.GET)
+	@ResponseBody
+	public List<RegisterRecord> getRegisterRecordUpload() {
+		return registerLogService.getNotUpLoadRegisterLog();
+	}
+
+	/**
+	 * 下载平台上记录成功后修改记录的传输状态
+	 * 
+	 * @param email
+	 * @return
+	 * @throws UnsupportedEncodingException 
+	 */
+	@RequestMapping(value = "/log", method = RequestMethod.POST)
+	@ResponseBody
+	public void uploadRegisterLogSuccess(String data) throws UnsupportedEncodingException {
+		String jsonStr = URLDecoder.decode(data, "UTF-8");
+		List<Long> ids = FlexJsonUtils.fromJsonArray(jsonStr, Long.class);
+		registerLogService.upLoadSuccessRegister(ids);
+	}
 
 }

src/main/java/com/uas/platform/b2b/service/RegisterLogService.java

@@ -0,0 +1,22 @@
+package com.uas.platform.b2b.service;
+
+import java.util.List;
+
+import com.uas.platform.b2b.model.RegisterRecord;
+
+public interface RegisterLogService {
+
+	/**
+	 * 获取未上传（到管理平台）的企业注册相关记录
+	 * 
+	 * @param log
+	 */
+	public List<RegisterRecord> getNotUpLoadRegisterLog();
+	
+	/**
+	 * 成功上传到管理平台后修改注册记录的状态
+	 * @param idStr
+	 */
+	public void upLoadSuccessRegister(List<Long> ids);
+
+}

src/main/java/com/uas/platform/b2b/service/impl/RegisterLogServiceImpl.java

@@ -0,0 +1,43 @@
+package com.uas.platform.b2b.service.impl;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import com.uas.platform.b2b.dao.RegisterRecordDao;
+import com.uas.platform.b2b.model.RegisterRecord;
+import com.uas.platform.b2b.service.RegisterLogService;
+import com.uas.platform.core.model.Status;
+
+@Service
+public class RegisterLogServiceImpl implements RegisterLogService {
+
+	@Autowired
+	private RegisterRecordDao registerRecordDao;
+	
+	@Override
+	public List<RegisterRecord> getNotUpLoadRegisterLog() {
+		return registerRecordDao.findBySendStatus((short) Status.NOT_UPLOAD.value());
+	}
+
+	@Override
+	public void upLoadSuccessRegister(List<Long> ids) {
+		List<RegisterRecord> registerRecords = new ArrayList<RegisterRecord>();
+		if(!CollectionUtils.isEmpty(ids)) {
+			for(Long id : ids) {
+				RegisterRecord registerRecord = registerRecordDao.findOne(id);
+				if(registerRecord != null) {
+					registerRecord.setSendStatus((short) Status.DOWNLOADED.value());
+					registerRecords.add(registerRecord);
+				}
+			}
+		}
+		registerRecordDao.save(registerRecords);
+	}
+
+
+	
+}