增加成员控制

Author: lamborc

conf/nbs.db

@@ -0,0 +1,18 @@
+package com.nbs.biz.data.dao;
+
+import org.apache.ibatis.session.SqlSession;
+
+/**
+ * @Package : com.nbs.biz.data.dao
+ * @Description : <p></p>
+ * @Author : lambor.c
+ * @Date : 2018/7/5-17:15
+ * Copyright (c) 2018, NBS , lambor.c<[email protected]>.
+ * All rights reserved.
+ */
+public class AttachmentInfoDao extends BasicDao {
+
+    public AttachmentInfoDao(SqlSession session) {
+        super(session, AttachmentInfoDao.class);
+    }
+}

src/main/java/com/nbs/biz/data/dao/AttachmentInfoDao.java

@@ -0,0 +1,159 @@
+package com.nbs.biz.data.entity;
+
+import java.util.Date;
+
+/**
+ * @Package : com.nbs.biz.data.entity
+ * @Description : <p></p>
+ * @Author : lambor.c
+ * @Date : 2018/7/5-17:06
+ * Copyright (c) 2018, NBS , lambor.c<[email protected]>.
+ * All rights reserved.
+ */
+public class AttachmentInfoEntity extends BasicEntity {
+
+    private String id;
+    private String peerid;
+    private String phash;
+    private String hash58;
+    private String fname;
+    private String fsize;
+    private String fsuffix;
+    private String fromid;
+    private String seqno;
+    private Integer cached;
+    private String cachedfile;
+    private Integer inlocal;
+    private String ftype;
+    private Integer sortno;
+    private Date ctime;
+    private Long lmtime;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getHash58() {
+        return hash58;
+    }
+
+    public void setHash58(String hash58) {
+        this.hash58 = hash58;
+    }
+
+    public String getFname() {
+        return fname;
+    }
+
+    public void setFname(String fname) {
+        this.fname = fname;
+    }
+
+    public String getFsize() {
+        return fsize;
+    }
+
+    public void setFsize(String fsize) {
+        this.fsize = fsize;
+    }
+
+    public String getFsuffix() {
+        return fsuffix;
+    }
+
+    public void setFsuffix(String fsuffix) {
+        this.fsuffix = fsuffix;
+    }
+
+    public String getFromid() {
+        return fromid;
+    }
+
+    public void setFromid(String fromid) {
+        this.fromid = fromid;
+    }
+
+    public String getSeqno() {
+        return seqno;
+    }
+
+    public void setSeqno(String seqno) {
+        this.seqno = seqno;
+    }
+
+    public Integer getCached() {
+        return cached;
+    }
+
+    public void setCached(Integer cached) {
+        this.cached = cached;
+    }
+
+    public String getCachedfile() {
+        return cachedfile;
+    }
+
+    public void setCachedfile(String cachedfile) {
+        this.cachedfile = cachedfile;
+    }
+
+    public Integer getInlocal() {
+        return inlocal;
+    }
+
+    public void setInlocal(Integer inlocal) {
+        this.inlocal = inlocal;
+    }
+
+    public String getFtype() {
+        return ftype;
+    }
+
+    public void setFtype(String ftype) {
+        this.ftype = ftype;
+    }
+
+    public Date getCtime() {
+        return ctime;
+    }
+
+    public void setCtime(Date ctime) {
+        this.ctime = ctime;
+    }
+
+    public Long getLmtime() {
+        return lmtime;
+    }
+
+    public void setLmtime(Long lmtime) {
+        this.lmtime = lmtime;
+    }
+
+    public String getPeerid() {
+        return peerid;
+    }
+
+    public void setPeerid(String peerid) {
+        this.peerid = peerid;
+    }
+
+    public String getPhash() {
+        return phash;
+    }
+
+    public void setPhash(String phash) {
+        this.phash = phash;
+    }
+
+    public Integer getSortno() {
+        return sortno;
+    }
+
+    public void setSortno(Integer sortno) {
+        this.sortno = sortno;
+    }
+}

src/main/java/com/nbs/biz/data/entity/AttachmentInfoEntity.java

@@ -0,0 +1,21 @@
+package com.nbs.biz.service;
+
+import com.nbs.biz.data.dao.AttachmentInfoDao;
+import com.nbs.biz.data.entity.AttachmentInfoEntity;
+import org.apache.ibatis.session.SqlSession;
+
+/**
+ * @Package : com.nbs.biz.service
+ * @Description : <p></p>
+ * @Author : lambor.c
+ * @Date : 2018/7/5-17:36
+ * Copyright (c) 2018, NBS , lambor.c<[email protected]>.
+ * All rights reserved.
+ */
+public class AttachmentInfoService extends BasicService<AttachmentInfoDao,AttachmentInfoEntity> {
+
+    public AttachmentInfoService(SqlSession sqlSession) {
+        dao = new AttachmentInfoDao(sqlSession);
+        setDao(dao);
+    }
+}

src/main/java/com/nbs/biz/service/AttachmentInfoService.java

@@ -15,5 +15,6 @@
 public class PeerContactsService extends BasicService<PeerContactsDao,PeerContactsEntity> {
     public PeerContactsService(SqlSession sqlSession) {
         dao = new PeerContactsDao(sqlSession);
+        setDao(dao);
     }
 }

src/main/java/com/nbs/biz/service/PeerContactsService.java

@@ -17,12 +17,10 @@
 import io.nbs.client.cnsts.ColorCnst;
 import io.nbs.client.ui.components.GBC;
 import io.nbs.client.ui.components.NbsListView;
-import io.nbs.commons.utils.Base64CodecUtil;
-import io.nbs.commons.utils.DbUtil;
 import io.nbs.client.ui.panels.ParentAvailablePanel;
-import io.nbs.commons.helper.RadomCharactersHelper;
 import io.ipfs.api.IPFS;
 import io.ipfs.api.JSONParser;
+import io.nbs.commons.utils.DataBaseUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -78,7 +76,7 @@ public class ContactsPanel extends ParentAvailablePanel {
     public ContactsPanel(JPanel parent) {
         super(parent);
         context = this;
-        service = new ContactsService(DbUtil.getSqlSession());
+        service = new ContactsService(DataBaseUtil.getSqlSession());
         initComponent();
         initView();
         initData();

src/main/java/com/nbs/ui/panels/ContactsPanel.java

@@ -3,15 +3,15 @@
 
 import com.nbs.biz.data.entity.PeerMessageEntity;
 import com.nbs.biz.service.PeerMessageService;
-import io.nbs.client.cnsts.AppGlobalCnst;
+
 import io.nbs.client.listener.IPFSSubscribeListener;
 import io.nbs.client.services.IpfsMessageSender;
 import io.nbs.client.ui.components.NbsListView;
 import io.nbs.client.ui.frames.MainFrame;
 import io.nbs.client.ui.panels.im.IMPeersPanel;
 import io.nbs.client.vo.ContactsItem;
-import io.nbs.commons.helper.ConfigurationHelper;
-import io.nbs.commons.utils.DbUtil;
+
+import io.nbs.commons.utils.DataBaseUtil;
 import io.nbs.commons.utils.UUIDGenerator;
 import io.nbs.sdk.beans.MessageItem;
 import io.nbs.sdk.beans.OnlineMessage;
@@ -39,7 +39,7 @@ public class ReceiverMessageAdapter implements IPFSSubscribeListener {
     public ReceiverMessageAdapter(List<MessageItem> items, NbsListView listView) {
         this.items = items;
         this.listView = listView;
-        SqlSession sqlSession = DbUtil.getSqlSession();
+        SqlSession sqlSession = DataBaseUtil.getSqlSession();
         peerMessageService = new PeerMessageService(sqlSession);
     }
 

src/main/java/io/nbs/client/adapter/ReceiverMessageAdapter.java

@@ -0,0 +1,69 @@
+package io.nbs.client.listener;
+
+import com.nbs.biz.service.AttachmentInfoService;
+import io.ipfs.api.IPFS;
+import io.ipfs.api.MerkleNode;
+import io.ipfs.api.NamedStreamable;
+import io.nbs.sdk.beans.MessageItem;
+import org.apache.ibatis.session.SqlSession;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.List;
+
+/**
+ * @Package : io.nbs.client.listener
+ * @Description : <p></p>
+ * @Author : lambor.c
+ * @Date : 2018/7/5-17:18
+ * Copyright (c) 2018, NBS , lambor.c<[email protected]>.
+ * All rights reserved.
+ */
+public class IPFSFileUploader {
+    private static IPFS ipfs;
+    private AttachmentInfoService service;
+
+    /**
+     *
+     * @param ipfs
+     * @param sqlSession
+     */
+    public IPFSFileUploader(IPFS ipfs, SqlSession sqlSession) {
+        this.ipfs = ipfs;
+        this.service = new AttachmentInfoService(sqlSession);
+    }
+
+    /**
+     *
+     * @param file
+     */
+    public void addFileToIPFS(File file){
+
+        if(!file.exists()||file.isDirectory())return;
+
+        try {
+            NamedStreamable.FileWrapper fileWrapper = new NamedStreamable.FileWrapper(file);
+            List<MerkleNode> list = ipfs.add(fileWrapper);
+            uploadSuccessNotify();
+            uploadSuccessSaveDB(list);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+
+
+    /**
+     * 上传成功系统展示
+     */
+    private void uploadSuccessNotify(){
+
+    }
+
+    /**
+     * 存库
+     */
+    private void uploadSuccessSaveDB( List<MerkleNode> list){
+
+    }
+}

src/main/java/io/nbs/client/listener/IPFSFileUploader.java

@@ -0,0 +1,16 @@
+package io.nbs.client.ui.panels.file;
+
+import javax.swing.*;
+
+/**
+ * @Package : io.nbs.client.ui.panels.file
+ * @Description : <p></p>
+ * @Author : lambor.c
+ * @Date : 2018/7/5-16:42
+ * Copyright (c) 2018, NBS , lambor.c<[email protected]>.
+ * All rights reserved.
+ */
+public class FileMasterPanel extends JPanel {
+
+
+}