Merge branch 'master' of http://git.hchbox.com/yuyou/client into master
commit
ac5815ed68
@ -0,0 +1,25 @@
|
||||
package com.yuyou.openapi.openapi.dao;
|
||||
|
||||
import com.yuyou.openapi.openapi.model.dataobject.WxFansMessageDO;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Modifying;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
/**
|
||||
* Copyright (C), 2012 - 2018, qyx
|
||||
* FileName: LuoshiMessageRepository
|
||||
* Author: 钱昱欣
|
||||
* Date: 2020/10/22 2:52 PM
|
||||
* Description: TODO
|
||||
* History:
|
||||
* <author> <time> <version> <desc>
|
||||
* 钱昱欣 2020/10/22 v1.0 创建此文件
|
||||
*/
|
||||
@Repository
|
||||
public interface WxFansMessageRepository extends JpaRepository<WxFansMessageDO, Long>{
|
||||
@Modifying
|
||||
@Query("update WxFansMessageDO t set t.sendStatus = ?1 where t.recId = ?2")
|
||||
void updateSendStatus(Integer sendStatus, Long recId);
|
||||
}
|
||||
|
@ -0,0 +1,76 @@
|
||||
package com.yuyou.openapi.openapi.model.dataobject;
|
||||
|
||||
import lombok.Data;
|
||||
import org.springframework.data.annotation.CreatedDate;
|
||||
import org.springframework.data.annotation.LastModifiedDate;
|
||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||
|
||||
import javax.persistence.*;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
@Table(name = "wxfans_message")
|
||||
@Entity
|
||||
@EntityListeners(AuditingEntityListener.class)
|
||||
public class WxFansMessageDO {
|
||||
|
||||
@Id
|
||||
@GeneratedValue(strategy= GenerationType.IDENTITY)
|
||||
private Long id;
|
||||
|
||||
@Column(name = "gmt_create")
|
||||
@CreatedDate
|
||||
private Date gmtCreate;
|
||||
|
||||
@Column(name = "gmt_modified")
|
||||
@LastModifiedDate
|
||||
private Date gmtModified;
|
||||
|
||||
/**
|
||||
* 记录id
|
||||
*/
|
||||
@Column(name = "rec_id")
|
||||
private Long recId;
|
||||
|
||||
/**
|
||||
* 业务码
|
||||
*/
|
||||
@Column(name = "pnum")
|
||||
private String pnum;
|
||||
|
||||
/**
|
||||
* 业务名
|
||||
*/
|
||||
@Column(name = "act_name")
|
||||
private String actName;
|
||||
|
||||
/**
|
||||
* 业务开始时间
|
||||
*/
|
||||
@Column(name = "start_time")
|
||||
private Date startTime;
|
||||
|
||||
/**
|
||||
* 业务类别(1:A,2:B,3:C,4:D,5:E,6:F)
|
||||
*/
|
||||
@Column(name = "client_type")
|
||||
private Integer clientType;
|
||||
|
||||
/**
|
||||
* 上游推送用户id
|
||||
*/
|
||||
@Column(name = "app_id")
|
||||
private String appId;
|
||||
|
||||
/**
|
||||
* 上游推送时间
|
||||
*/
|
||||
@Column(name = "push_time")
|
||||
private Date pushTime;
|
||||
|
||||
/**
|
||||
* 默认值为0 是否处理过请求 0 - 未处理 1 - 处理过
|
||||
*/
|
||||
@Column(name = "send_status")
|
||||
private Integer sendStatus = 0;
|
||||
}
|
@ -0,0 +1,35 @@
|
||||
package com.yuyou.openapi.openapi;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Paths;
|
||||
import java.nio.file.StandardOpenOption;
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
public class ExcelFileTest {
|
||||
|
||||
@Test
|
||||
public void testReadAllFiles() throws IOException {
|
||||
|
||||
|
||||
List<String> stringList = Files.readAllLines(Paths.get("H:\\1.txt"));
|
||||
|
||||
System.out.println(stringList.size());
|
||||
|
||||
List<String> collect = stringList.stream()
|
||||
.distinct()
|
||||
.filter(each -> (each.trim().length() == 24))
|
||||
.collect(Collectors.toList());
|
||||
|
||||
System.out.println(collect.size());
|
||||
|
||||
Files.write(Paths.get("H:\\all.txt"),collect, StandardOpenOption.CREATE);
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
Loading…
Reference in New Issue