朋友圈任务增加发文功能

src/main/java/com/mokamrp/privates/controller/WorkEmployeeFriendcircleController.java

@@ -55,6 +55,7 @@ public class WorkEmployeeFriendcircleController extends BaseController<WorkEmplo
 
     /**
      * 导入
+     *
      * @param file
      * @param authUser
      * @return
@@ -65,9 +66,12 @@ public class WorkEmployeeFriendcircleController extends BaseController<WorkEmplo
         Map<Integer, String> feild = new HashMap<>(5);
         feild.put(0, "deviceCode");
         feild.put(1, "corpId");
-        feild.put(2, "shareUrl");
-        feild.put(3, "title");
-        feild.put(4, "sendAt"); //.2021-01-01 22:22:22
+        feild.put(2, "type");
+        feild.put(3, "box_name");
+        feild.put(4, "tag_name");
+        feild.put(5, "shareUrl");
+        feild.put(6, "title");
+        feild.put(7, "sendAt"); //.2021-01-01 22:22:22
         List<Map<String, String>> row = new ArrayList<>();
         try {
             row = Analysis.analysis(file, feild);

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

@@ -1,8 +1,12 @@
 package com.mokamrp.privates.controller.pangu;
 
+import com.mokamrp.privates.constant.HttpMsg;
 import com.mokamrp.privates.constant.HttpStatus;
 import com.mokamrp.privates.entity.PostBasePageHandle;
 import com.mokamrp.privates.help.AjaxResult;
+import com.mokamrp.privates.help.Analysis;
+import com.mokamrp.privates.interceptor.AuthUser;
+import com.mokamrp.privates.mapper.pojo.User;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.BindingResult;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -13,9 +17,13 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import com.mokamrp.privates.controller.BaseController;
 import javax.validation.Valid;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
 
 
 /**
@@ -48,7 +56,30 @@ public class FosterwxStationBindBoxController extends BaseController<FosterwxSta
         return AjaxResult.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, "type");
+        feild.put(2, "ghId");
+        feild.put(3, "boxName");
+        feild.put(4, "scope");
+        List<Map<String, String>> row = new ArrayList<>();
+        try {
+            row = Analysis.analysis(file, feild);
+        } catch (Exception e) {
+            return AjaxResult.error(e.getMessage());
+        }
+        Boolean res = fosterwxStationBindBoxService.importData(row,authUser);
+        return AjaxResult.success(HttpMsg.importSuccess);
+    }
 
 }
 

src/main/java/com/mokamrp/privates/mapper/pojo/WorkEmployeeFriendcircle.java

@@ -28,7 +28,9 @@ public class WorkEmployeeFriendcircle extends Model<WorkEmployeeFriendcircle> {
      */
       @TableId(value = "id", type = IdType.AUTO)
     private Integer id;
-
+    /**
+     * 发送类型1.朋友圈 2.发文
+     */
     private Integer type;
     /**
      * 企业ID(mc_corp.id)
@@ -39,6 +41,14 @@ public class WorkEmployeeFriendcircle extends Model<WorkEmployeeFriendcircle> {
      * 设备编码
      */
     private String deviceCode;
+    /**
+     * 小程序名称,隔开
+     */
+    private String boxName;
+    /**
+     * 标签名称
+     */
+    private String tagName;
 
     /**
      * 朋友圈标题

src/main/java/com/mokamrp/privates/service/impl/WorkEmployeeFriendcircleServiceImpl.java

@@ -70,6 +70,9 @@ public class WorkEmployeeFriendcircleServiceImpl extends ServiceImpl<WorkEmploye
             WorkEmployeeFriendcircle workEmployeeFriendcircle = new WorkEmployeeFriendcircle();
             workEmployeeFriendcircle.setDeviceCode(row.get(i).get("deviceCode"));
             workEmployeeFriendcircle.setCorpId(Integer.parseInt(row.get(i).get("corpId")));
+            workEmployeeFriendcircle.setType(Integer.parseInt(row.get(i).get("type")));
+            workEmployeeFriendcircle.setBoxName(row.get(i).get("boxName"));
+            workEmployeeFriendcircle.setTagName(row.get(i).get("tagName"));
             workEmployeeFriendcircle.setShareUrl(row.get(i).get("shareUrl"));
             workEmployeeFriendcircle.setTitle(row.get(i).get("title"));
             workEmployeeFriendcircle.setSendAt(LocalDateTime.parse(row.get(i).get("sendAt"),df));

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

@@ -3,6 +3,9 @@ package com.mokamrp.privates.service.pangu;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxStationBindBox;
 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>
@@ -15,4 +18,6 @@ import java.util.Map;
 public interface FosterwxStationBindBoxService extends IService<FosterwxStationBindBox> {
     //.@leon 获取数据列表
     public Map<String, Object> getList(PostBasePageHandle handle);
+    //.@leon 导入数据
+    public Boolean importData(List<Map<String,String>> row, User authUser);
 }

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

@@ -2,6 +2,8 @@ package com.mokamrp.privates.service.pangu.impl;
 
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxStationBindBox;
 import com.mokamrp.privates.mapper.pangu.FosterwxStationBindBoxMapper;
+import com.mokamrp.privates.mapper.pojo.User;
+import com.mokamrp.privates.mapper.pojo.WorkEmployeeFriendcircle;
 import com.mokamrp.privates.service.pangu.FosterwxStationBindBoxService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
@@ -9,6 +11,9 @@ 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.*;
 
 /**
@@ -39,4 +44,35 @@ public class FosterwxStationBindBoxServiceImpl extends ServiceImpl<FosterwxStati
         resMap.put("total", pageObj.getTotal());
         return resMap;
     }
+
+    /**
+     * 导入数据
+     * @param row
+     * @return
+     */
+    public Boolean importData(List<Map<String,String>> row, User authUser){
+        if(row.size() <= 0){
+            return false;
+        }
+        List<FosterwxStationBindBox> add = new ArrayList<>();
+        DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+        for (int i = 0;i<row.size();i++) {
+            System.out.println(row.get(i));
+            Map<String, String> cell = row.get(i);
+            FosterwxStationBindBox fosterwxStationBindBox = new FosterwxStationBindBox();
+            fosterwxStationBindBox.setStationId(Integer.parseInt(row.get(i).get("stationId")));
+            fosterwxStationBindBox.setType(Integer.parseInt(row.get(i).get("type")));
+            fosterwxStationBindBox.setGhId(row.get(i).get("ghId"));
+            fosterwxStationBindBox.setBoxName(row.get(i).get("boxName"));
+            fosterwxStationBindBox.setScope(row.get(i).get("scope"));
+            fosterwxStationBindBox.setUploadUid(authUser.getId());
+            fosterwxStationBindBox.setCreateAt(LocalDateTime.now());
+            fosterwxStationBindBox.setUpdateAt(LocalDateTime.now());
+            add.add(fosterwxStationBindBox);
+        }
+        this.saveBatch(add);
+        return true;
+    }
+
+
 }