销售端上传企业微信图片

fs-company/src/main/java/com/fs/company/controller/company/CompanyController.java

@@ -17,6 +17,7 @@ import com.fs.framework.service.TokenService;
 import com.fs.his.vo.OptionsVO;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
@@ -121,4 +122,13 @@ public class CompanyController extends BaseController
         List<OptionsVO> list = companyService.getCompanyListByCorpId(corpId);
         return R.ok().put("data",list);
     }
+
+    // 同步销售公司的 图片
+    @GetMapping("/syncCompanyCorIdImage")
+    @PreAuthorize("@ss.hasPermi('qw:tagGroup:imageSync')")
+    public R SyncCompanyCorIdImage() {
+        LoginUser loginUser = tokenService.getLoginUser(ServletUtils.getRequest());
+        companyService.SyncCompanyCorIdImage(loginUser.getUser().getCompanyId());
+        return R.ok();
+    }
 }

fs-service/src/main/java/com/fs/company/service/ICompanyService.java

@@ -212,4 +212,6 @@ public interface ICompanyService
      * 根据公司id集合查询多个公司
      * */
     List<Company> queryCompanyListByCompanyIds(List<Long> companyIds);
+
+    void SyncCompanyCorIdImage(Long companyId);
 }

fs-service/src/main/java/com/fs/company/service/impl/CompanyServiceImpl.java

@@ -27,8 +27,11 @@ import com.fs.company.vo.*;
 import com.fs.course.config.CourseConfig;
 import com.fs.course.config.RedPacketConfig;
 import com.fs.course.domain.FsCourseRedPacketLog;
+import com.fs.course.domain.FsUserCourse;
 import com.fs.course.mapper.FsCourseRedPacketLogMapper;
+import com.fs.course.mapper.FsUserCourseMapper;
 import com.fs.course.service.IFsCourseRedPacketLogService;
+import com.fs.course.service.impl.FsUserCourseServiceImpl;
 import com.fs.his.config.StoreConfig;
 import com.fs.his.domain.FsInquiryOrder;
 import com.fs.his.domain.FsStoreOrder;
@@ -44,6 +47,9 @@ import com.fs.hisStore.mapper.FsStoreOrderScrmMapper;
 import com.fs.live.domain.LiveOrder;
 import com.fs.live.mapper.LiveOrderMapper;
 import com.fs.live.service.ILiveService;
+import com.fs.qw.domain.QwCompany;
+import com.fs.qw.mapper.QwCompanyMapper;
+import com.fs.qw.service.IQwCompanyService;
 import com.fs.store.config.CompanyMenuConfig;
 import com.fs.system.domain.SysConfig;
 import com.fs.system.mapper.SysConfigMapper;
@@ -148,6 +154,15 @@ public class CompanyServiceImpl implements ICompanyService
     private ICompanyConfigService companyConfigService;
     @Autowired
     CompanyBindGatewayMapper companyBindGatewayMapper;
+    @Autowired
+    private FsUserCourseMapper fsUserCourseMapper;
+
+    @Autowired
+    private QwCompanyMapper qwCompanyMapper;
+
+    @Autowired
+    @Lazy
+    private FsUserCourseServiceImpl fsUserCourseService;
 
     @Value("${cloud_host.company_name}")
     private String companyName;
@@ -2040,4 +2055,33 @@ public class CompanyServiceImpl implements ICompanyService
         return companyList;
     }
 
+    @Override
+    public void SyncCompanyCorIdImage(Long companyId) {
+
+        // 获取所有需要处理的课程列表
+        List<FsUserCourse> fsUserCourses = fsUserCourseMapper.selectFsUserCourseAllCourseByQw();
+
+        // 获取所有企业微信配置
+        List<String> cropIds = qwCompanyMapper.selectQwCompanyCorpIdListByCompanyId(companyId);
+
+        // 遍历每个企业微信配置
+        for (String corpId : cropIds) {
+
+            if (corpId == null) {
+                continue;
+            }
+
+            // 遍历每个课程,上传图片到对应企业的素材库
+            for (FsUserCourse course : fsUserCourses) {
+                try {
+
+                    fsUserCourseService.uploadCourseImage(course, corpId);
+                } catch (Exception e) {
+                    logger.error("处理课程图片失败: courseId={}, corpId={}, error={}",
+                            course.getCourseId(), corpId, e.getMessage());
+                }
+            }
+        }
+    }
+
 }