电销微信数据上传

src/main/java/com/ydtech/modules/admin/controller/SysTelemarketingController.java

@@ -29,46 +29,21 @@ public class SysTelemarketingController {
     @PostMapping("/page")
     @ApiOperation("电销数据分页查询")
     public HttpResult<BasePageResult<SysTelemarketingWechatData>> page(@RequestBody SysTelemarketingWechatDataVo sysTelemarketingWechatDataVo) {
-        Page<SysTelemarketingWechatData> page = new Page<>(sysTelemarketingWechatDataVo.getPageNum(), sysTelemarketingWechatDataVo.getPageSize());
-        String userId = BaseController.getUserId();
-        Page<SysTelemarketingWechatData> sysTelemarketingWechatDataPage = sysTelemarketingWechatDataService
-                .lambdaQuery()
-                .eq(SysTelemarketingWechatData::getUserId, userId)
-                .page(page);
-
-        BasePageResult<SysTelemarketingWechatData> basePageResult = new BasePageResult<>(
-                sysTelemarketingWechatDataVo.getPageNum(),
-                sysTelemarketingWechatDataVo.getPageSize(),
-                sysTelemarketingWechatDataPage.getTotal(),
-                sysTelemarketingWechatDataPage.getPages(),
-                sysTelemarketingWechatDataPage.getRecords());
-
+        BasePageResult<SysTelemarketingWechatData> basePageResult = sysTelemarketingWechatDataService.pageQuery(sysTelemarketingWechatDataVo);
         return HttpResult.ok(basePageResult);
     }
 
     @PostMapping
     @ApiOperation("电销数据添加")
     public HttpResult<Object> add(@RequestBody SysTelemarketingWechatDataSaveVo sysTelemarketingWechatDataSaveVo) {
-
-        sysTelemarketingWechatDataService.checkData(sysTelemarketingWechatDataSaveVo.getCreateTime());
-
-        SysTelemarketingWechatData sysTelemarketingWechatData = new SysTelemarketingWechatData();
-        BeanUtils.copyProperties(sysTelemarketingWechatDataSaveVo, sysTelemarketingWechatData);
-        String userId = BaseController.getUserId();
-        sysTelemarketingWechatData.setUserId(userId);
-        boolean save = sysTelemarketingWechatDataService.save(sysTelemarketingWechatData);
-        AssertionUtils.isSucceed(save, "添加失败");
+        sysTelemarketingWechatDataService.add(sysTelemarketingWechatDataSaveVo);
         return HttpResult.ok("添加成功");
     }
 
     @PutMapping("{telemarketingId}")
-    @ApiOperation("电销数据添加")
+    @ApiOperation("电销数据修改")
     public HttpResult<Object> revise(@RequestBody SysTelemarketingWechatDataSaveVo sysTelemarketingWechatDataSaveVo, @PathVariable String telemarketingId) {
-        SysTelemarketingWechatData sysTelemarketingWechatData = sysTelemarketingWechatDataService.getByIdExist(telemarketingId, "查询不到此数据");
-        BeanUtils.copyProperties(sysTelemarketingWechatDataSaveVo, sysTelemarketingWechatData);
-        sysTelemarketingWechatData.setUpdateTime(new Date());
-        boolean b = sysTelemarketingWechatDataService.updateById(sysTelemarketingWechatData);
-        AssertionUtils.isSucceed(b, "修改失败");
+        sysTelemarketingWechatDataService.revise(telemarketingId, sysTelemarketingWechatDataSaveVo);
         return HttpResult.ok("修改成功");
     }
 

src/main/java/com/ydtech/modules/admin/service/SysTelemarketingWechatDataService.java

@@ -2,6 +2,9 @@ package com.ydtech.modules.admin.service;
 
 import com.ydtech.extension.BaseIService;
 import com.ydtech.modules.admin.model.po.SysTelemarketingWechatData;
+import com.ydtech.modules.admin.model.vo.SysTelemarketingWechatDataSaveVo;
+import com.ydtech.modules.admin.model.vo.SysTelemarketingWechatDataVo;
+import com.ydtech.modules.order.entity.BasePageResult;
 import com.ydtech.modules.protocol.utils.AssertionUtils;
 
 import java.text.SimpleDateFormat;
@@ -20,13 +23,34 @@ public interface SysTelemarketingWechatDataService extends BaseIService<SysTelem
      *
      * @param date 添加日期
      */
-    default void checkData(Date date) {
+    default void checkData(Date date, String userId) {
         List<SysTelemarketingWechatData> list = lambdaQuery()
                 .eq(SysTelemarketingWechatData::getCreateTime, date)
+                .eq(SysTelemarketingWechatData::getUserId, userId)
                 .list();
         String dateStr = new SimpleDateFormat("yyyy-MM-dd").format(date);
         AssertionUtils.isSucceed(!list.isEmpty(), "日期为：" + dateStr + "添加了日期");
 
     }
 
+    /**
+     * 分页查询微信数据
+     *
+     * @param sysTelemarketingWechatDataVo 微信数据实体
+     * @return 分页微信数据
+     */
+    BasePageResult<SysTelemarketingWechatData> pageQuery(SysTelemarketingWechatDataVo sysTelemarketingWechatDataVo);
+
+    /**
+     * 电销数据添加
+     *
+     * @param sysTelemarketingWechatDataSaveVo 微信数据实体
+     */
+    void add(SysTelemarketingWechatDataSaveVo sysTelemarketingWechatDataSaveVo);
+
+    /**
+     * @param telemarketingId 电销id
+     * @param sysTelemarketingWechatDataSaveVo 微信数据实体
+     */
+    void revise(String telemarketingId, SysTelemarketingWechatDataSaveVo sysTelemarketingWechatDataSaveVo);
 }

src/main/java/com/ydtech/modules/admin/service/impl/SysTelemarketingWechatDataServiceImpl.java

@@ -1,19 +1,64 @@
 package com.ydtech.modules.admin.service.impl;
 
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ydtech.modules.admin.dao.SysTelemarketingWechatDataMapper;
 import com.ydtech.modules.admin.model.po.SysTelemarketingWechatData;
+import com.ydtech.modules.admin.model.vo.SysTelemarketingWechatDataSaveVo;
+import com.ydtech.modules.admin.model.vo.SysTelemarketingWechatDataVo;
 import com.ydtech.modules.admin.service.SysTelemarketingWechatDataService;
+import com.ydtech.modules.base.controller.BaseController;
+import com.ydtech.modules.order.entity.BasePageResult;
+import com.ydtech.modules.protocol.utils.AssertionUtils;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 
+import java.util.Date;
+
 /**
-* @author Administrator
-* @description 针对表【sys_telemarketing_wechat_data(微信提交数据)】的数据库操作Service实现
-* @createDate 2024-08-29 17:23:42
-*/
+ * @author Administrator
+ * @description 针对表【sys_telemarketing_wechat_data(微信提交数据)】的数据库操作Service实现
+ * @createDate 2024-08-29 17:23:42
+ */
 @Service
 public class SysTelemarketingWechatDataServiceImpl extends ServiceImpl<SysTelemarketingWechatDataMapper, SysTelemarketingWechatData>
-    implements SysTelemarketingWechatDataService {
+        implements SysTelemarketingWechatDataService {
+
+    @Override
+    public BasePageResult<SysTelemarketingWechatData> pageQuery(SysTelemarketingWechatDataVo sysTelemarketingWechatDataVo) {
+        Page<SysTelemarketingWechatData> page = new Page<>(sysTelemarketingWechatDataVo.getPageNum(), sysTelemarketingWechatDataVo.getPageSize());
+        String userId = BaseController.getUserId();
+        Page<SysTelemarketingWechatData> sysTelemarketingWechatDataPage = lambdaQuery()
+                .eq(SysTelemarketingWechatData::getUserId, userId)
+                .page(page);
+
+        return new BasePageResult<>(
+                sysTelemarketingWechatDataVo.getPageNum(),
+                sysTelemarketingWechatDataVo.getPageSize(),
+                sysTelemarketingWechatDataPage.getTotal(),
+                sysTelemarketingWechatDataPage.getPages(),
+                sysTelemarketingWechatDataPage.getRecords());
+    }
+
+    @Override
+    public void add(SysTelemarketingWechatDataSaveVo sysTelemarketingWechatDataSaveVo) {
+        String userId = BaseController.getUserId();
+        checkData(sysTelemarketingWechatDataSaveVo.getCreateTime(), userId);
+        SysTelemarketingWechatData sysTelemarketingWechatData = new SysTelemarketingWechatData();
+        BeanUtils.copyProperties(sysTelemarketingWechatDataSaveVo, sysTelemarketingWechatData);
+        sysTelemarketingWechatData.setUserId(userId);
+        boolean save = save(sysTelemarketingWechatData);
+        AssertionUtils.isSucceed(save, "添加失败");
+    }
+
+    @Override
+    public void revise(String telemarketingId, SysTelemarketingWechatDataSaveVo sysTelemarketingWechatDataSaveVo) {
+        SysTelemarketingWechatData sysTelemarketingWechatData = getByIdExist(telemarketingId, "查询不到此数据");
+        BeanUtils.copyProperties(sysTelemarketingWechatDataSaveVo, sysTelemarketingWechatData);
+        sysTelemarketingWechatData.setUpdateTime(new Date());
+        boolean b = updateById(sysTelemarketingWechatData);
+        AssertionUtils.isSucceed(b, "修改失败");
+    }
 
 }