update

src/main/java/com/hdp/pi/service/kolon/KolonMemberServiceImpl.java

@@ -72,9 +72,10 @@ public class KolonMemberServiceImpl implements KolonMemberService {
 			kolonMember.lifecycle = kolonMemberDTO.lifecycle;
 			kolonMember.customerType = kolonMemberDTO.customerType;
 			kolonMember.lastPurchaseDate = kolonMemberDTO.lastPurchaseDate;
-			kolonMember.dataSource = 1;
-			kolonMember.joinTime = new Date();
-			kolonMember.updateTime = new Date();
+			kolonMember.dataSource = 2;
+			Date date = new Date();
+			kolonMember.joinTime = date;
+			kolonMember.updateTime = date;
 			this.save(kolonMember);
 		} else { // 更新
 			boolean flag = false;

src/main/java/com/hdp/pi/utils/kolon/FtpUtil.java

@@ -57,6 +57,12 @@ public class FtpUtil {
 	@Value("${kolon.property.ftp.getFileName}")
 	private String getFileName;
 
+	/**
+	 * 临时路径
+	 */
+	@Value("${kolon.property.ftp.tempFileDir}")
+	private String tempFileDir;
+
 	/**
 	 * 临时存放生成的新注册用户文件路径
 	 */
@@ -151,9 +157,10 @@ public class FtpUtil {
 		try {
 			FTPClient ftpClient = this.getFTPClient();
 
-			//新的文件名
+			// 新的文件名
 			String suffix = getFileName.substring(getFileName.lastIndexOf("."));
-			String name = getFileName.substring(0, getFileName.lastIndexOf("."));
+			String name = getFileName
+					.substring(0, getFileName.lastIndexOf("."));
 			String newFileName = name + "_" + getTime() + suffix;
 
 			ftpClient.rename(getFileDir + getFileName, getFileHistoryDir
@@ -171,6 +178,7 @@ public class FtpUtil {
 	 * @return
 	 */
 	public CSVWriter getCSVWriter(Integer type) {
+		createdDirIfNotExist(tempFileDir);
 		CSVWriter writer = null;
 		try {
 			if (type == 1) {
@@ -216,4 +224,11 @@ public class FtpUtil {
 		return formattedDateTime;
 	}
 
+	public void createdDirIfNotExist(String path) {
+		File file = new File(path);
+		if (!file.exists() && !file.isDirectory()) {
+			file.mkdir();
+		}
+	}
+
 }

src/main/resources/kolon.properties

@@ -27,6 +27,7 @@ kolon.property.ftp.getFileDir = /Emarsys/
 kolon.property.ftp.getFileHistoryDir = /Emarsys/history/
 kolon.property.ftp.getFileName = contact.csv
 
+kolon.property.ftp.tempFileDir = /temp
 kolon.property.ftp.tempAddFileName = /temp/tempAddContact.csv
 kolon.property.ftp.tempUpdateFileName = /temp/tempUpdateContact.csv