增加账号录入导表逻辑

src/main/java/com/mokamrp/privates/controller/pangu/FosterwxMobileController.java

@@ -29,6 +29,7 @@ import org.springframework.web.multipart.MultipartFile;
 
 import javax.validation.Valid;
 import java.time.LocalDateTime;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -252,5 +253,48 @@ public class FosterwxMobileController extends BaseController<FosterwxMobile> {
         res.setFriend(friendList);
         return AjaxResult.success(Constants.SUCCESS, res);
     }
+
+    /**
+     * 导入
+     * @param file
+     * @param authUser
+     * @return
+     */
+    @PostMapping("/import")
+    public Object uploadFile(@RequestBody MultipartFile file, @AuthUser User authUser) {
+        Map<String, Object> map = new HashMap<>(16);
+        Map<Integer, String> feild = new HashMap<>(5);
+        feild.put(0, "stationId");
+        feild.put(1, "mobileCode");
+        feild.put(2, "mobileNo");
+        feild.put(3, "mobileOperator");
+        feild.put(4, "mobileCreateAt");
+        feild.put(5, "mobileAdvancePayAmt");
+        feild.put(6, "mobileCombo");
+        feild.put(7, "mobileRealName");
+        feild.put(8, "mobileIdentityCardNo");
+        feild.put(9, "wxPassword");
+        feild.put(10, "wxRegisterAt");
+        feild.put(11, "wxRealName");
+        feild.put(12, "wxIdentityCardNo");
+        feild.put(13, "bankCardNo");
+        feild.put(14, "bankCardMobileNo");
+        feild.put(15, "wxFriendName1");
+        feild.put(16, "wxFriendUserName1");
+        feild.put(17, "wxFriendName2");
+        feild.put(18, "wxFriendUserName2");
+        feild.put(19, "wxFriendName3");
+        feild.put(20, "wxFriendUserName3");
+        feild.put(21, "workWxCorp");
+        feild.put(22, "workWxRegisterAt");
+        List<Map<String, String>> row = new ArrayList<>();
+        try {
+            row = Analysis.analysis(file, feild);
+        } catch (Exception e) {
+            return AjaxResult.error(e.getMessage());
+        }
+        Boolean res = fosterwxMobileService.importData(row,authUser);
+        return AjaxResult.success(HttpMsg.importSuccess);
+    }
 }
 

src/main/java/com/mokamrp/privates/service/pangu/FosterwxMobileService.java

@@ -4,6 +4,9 @@ import com.mokamrp.privates.entity.pangu.GetForsterwxMobileHandle;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobile;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pojo.User;
+
+import java.util.List;
 import java.util.Map;
 /**
  * <p>
@@ -18,4 +21,6 @@ public interface FosterwxMobileService extends IService<FosterwxMobile> {
     public Map<String, Object> getList(GetForsterwxMobileHandle handle);
     //.@leon 获取指定站点下账号列表
     public Map<String, Object> getListByStationId(GetForsterwxMobileHandle getForsterwxMobileHandle, Integer stationId);
+
+    Boolean importData(List<Map<String,String>> row, User authUser);
 }

src/main/java/com/mokamrp/privates/service/pangu/impl/FosterwxMobileServiceImpl.java

@@ -5,14 +5,20 @@ import com.mokamrp.privates.entity.pangu.GetForsterwxMobileHandle;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobile;
 import com.mokamrp.privates.mapper.pangu.FosterwxMobileMapper;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobileWxfriend;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxStationBindBox;
+import com.mokamrp.privates.mapper.pojo.User;
 import com.mokamrp.privates.service.pangu.FosterwxMobileService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.mokamrp.privates.service.pangu.FosterwxMobileWxfriendService;
+import org.apache.tomcat.jni.Local;
 import org.springframework.stereotype.Service;
 import com.mokamrp.privates.entity.PostBasePageHandle;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
 
 /**
@@ -62,5 +68,60 @@ public class FosterwxMobileServiceImpl extends ServiceImpl<FosterwxMobileMapper,
         return resMap;
     }
 
+    /**
+     * 导入数据
+     * @param row
+     * @return
+     */
+    public Boolean importData(List<Map<String,String>> row, User authUser){
+        if(row.size() <= 0){
+            return false;
+        }
+        List<FosterwxMobile> add = new ArrayList<>();
+        DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+        for (int i = 0;i<row.size();i++) {
+
+            LocalDateTime nowDate = LocalDateTime.now();
+            Map<String, String> cell = row.get(i);
+            FosterwxMobile fosterwxMobile = new FosterwxMobile();
+            fosterwxMobile.setStationId(Integer.parseInt(row.get(i).get("stationId")));
+            fosterwxMobile.setMobileCode(Integer.parseInt(row.get(i).get("mobileCode")));
+            fosterwxMobile.setMobileNo(row.get(i).get("mobileNo"));
+            fosterwxMobile.setMobileOperator(Integer.parseInt(row.get(i).get("mobileOperator")));
+            fosterwxMobile.setMobileCreateAt(LocalDateTime.parse(row.get(i).get("mobileCreateAt"),df));
+            fosterwxMobile.setMobileAdvancePayAmt(Integer.parseInt(row.get(i).get("mobileAdvancePayAmt")));
+            fosterwxMobile.setMobileCombo(row.get(i).get("mobileCombo"));
+            fosterwxMobile.setMobileRealName(row.get(i).get("mobileRealName"));
+            fosterwxMobile.setMobileIdentityCardNo(row.get(i).get("mobileIdentityCardNo"));
+            fosterwxMobile.setWxPassword(row.get(i).get("wxPassword"));
+            fosterwxMobile.setWxRegisterAt(LocalDateTime.parse(row.get(i).get("wxRegisterAt")));
+            fosterwxMobile.setWxRealName(row.get(i).get("wxRealName"));
+            fosterwxMobile.setWxIdentityCardNo(row.get(i).get("wxIdentityCardNo"));
+            fosterwxMobile.setBankCardNo(row.get(i).get("bankCardNo"));
+            fosterwxMobile.setBankCardMobileNo(row.get(i).get("bankCardMobileNo"));
+            fosterwxMobile.setStationId(Integer.parseInt(row.get(i).get("workWxCorp")));
+            fosterwxMobile.setStationId(Integer.parseInt(row.get(i).get("workWxRegisterAt")));
+            fosterwxMobile.setCreateAt(nowDate);
+            fosterwxMobile.setUpdateAt(nowDate);
+            add.add(fosterwxMobile);
+            //.批量录入微信好友
+            List<FosterwxMobileWxfriend> addFriend = new ArrayList<>();
+            for (Integer s = 1;s<=3;s++) {
+                String sStr = s.toString();
+                FosterwxMobileWxfriend fosterwxMobileWxfriend = new FosterwxMobileWxfriend();
+                fosterwxMobileWxfriend.setMobileId(fosterwxMobile.getId());
+                fosterwxMobileWxfriend.setCreateAt(nowDate);
+                fosterwxMobileWxfriend.setUpdateAt(nowDate);
+                fosterwxMobileWxfriend.setSeq(s);
+                fosterwxMobileWxfriend.setWxName(row.get(i).get("wxFriendName"+sStr));
+                fosterwxMobileWxfriend.setWxUsername(row.get(i).get("wxFriendUserName"+sStr));
+                addFriend.add(fosterwxMobileWxfriend);
+            }
+            fosterwxMobileWxfriendService.remove(new QueryWrapper<FosterwxMobileWxfriend>().eq("mobile_id",fosterwxMobile.getId()));
+            fosterwxMobileWxfriendService.saveBatch(addFriend);
+        }
+        this.saveBatch(add);
+        return true;
+    }
 
 }