feats

pom.xml

@@ -63,6 +63,11 @@
 			<artifactId>weixin-java-mp</artifactId>
 			<version>3.8.0</version>
 		</dependency>
+		<dependency>
+			<groupId>com.github.binarywang</groupId>
+			<artifactId>weixin-java-cp</artifactId>
+			<version>3.8.0</version>
+		</dependency>
 		<dependency>
 			<groupId>com.github.binarywang</groupId>
 			<artifactId>weixin-java-pay</artifactId>

src/main/java/com/yunzhi/marketing/common/WorkWxUtils.java

@@ -0,0 +1,51 @@
+package com.yunzhi.marketing.common;
+
+import com.alibaba.fastjson.JSONObject;
+import com.yunzhi.marketing.config.WorkConfig;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.cp.api.impl.WxCpServiceImpl;
+import me.chanjar.weixin.cp.config.impl.WxCpDefaultConfigImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@EnableConfigurationProperties(WorkConfig.class)
+public class WorkWxUtils {
+    WxCpServiceImpl wxCpService;
+
+    @Autowired
+    public WorkWxUtils(WorkConfig conf) {
+        WxCpDefaultConfigImpl config = new WxCpDefaultConfigImpl();
+        config.setCorpId(conf.getCorpid());
+        config.setCorpSecret(conf.getSecret());
+        config.setAgentId(Integer.valueOf(conf.getAgentid()));
+//        config.setToken("...");
+//        config.setAesKey("...");
+
+        wxCpService = new WxCpServiceImpl();
+        wxCpService.setWxCpConfigStorage(config);
+    }
+
+    public String getLivingCode(String livingid, String openid) throws Exception {
+        if (StringUtils.isEmpty(livingid) || StringUtils.isEmpty(openid)) {
+            throw new Exception("房间号或者人员openid不能为空");
+        }
+
+        String url = "/cgi-bin/living/get_living_code";
+        JSONObject params = new JSONObject();
+        params.put("livingid", livingid);
+        params.put("openid", openid);
+
+        String response = wxCpService.post(url, params.toJSONString());
+        JSONObject result = JSONObject.parseObject(response);
+
+        String errmsg = result.getString("errmsg");
+        if ("ok".equals(errmsg)) {
+            return result.getString("living_code");
+        } else {
+            throw new Exception(String.format("获取直播凭证失败: %s", errmsg));
+        }
+    }
+}

src/main/java/com/yunzhi/marketing/common/WxUtils.java

@@ -25,8 +25,6 @@ public class WxUtils {
 
     @PostConstruct
     public void init() {
-        System.out.println("-------------PostConstruct----------------");
-
         List<TaMiniapp> taMiniappList = iMiniAppService.getAllAvaliableMiniapps();
         if (null == taMiniappList) {
             return;

src/main/java/com/yunzhi/marketing/config/WorkConfig.java

@@ -0,0 +1,12 @@
+package com.yunzhi.marketing.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@Data
+@ConfigurationProperties(prefix = "workwx")
+public class WorkConfig {
+    private String corpid;
+    private String agentid;
+    private String secret;
+}

src/main/java/com/yunzhi/marketing/controller/TaLiveActivityController.java

@@ -7,6 +7,7 @@ import com.yunzhi.marketing.base.BaseController;
 import com.yunzhi.marketing.base.ResponseBean;
 import com.yunzhi.marketing.common.CommConstant;
 import com.yunzhi.marketing.common.StringUtils;
+import com.yunzhi.marketing.common.WorkWxUtils;
 import com.yunzhi.marketing.entity.ExtendContent;
 import com.yunzhi.marketing.entity.TaLiveActivity;
 import com.yunzhi.marketing.po.LiveAndVideoVO;
@@ -45,6 +46,9 @@ public class TaLiveActivityController extends BaseController {
     @Autowired
     public IExtendContentService iExtendContentService;
 
+    @Autowired
+    public WorkWxUtils workWxUtils;
+
     /**
      * 分页查询列表
      *
@@ -300,4 +304,16 @@ public class TaLiveActivityController extends BaseController {
         IPage<TaLiveActivity> pg = new Page<>(pageNum, pageSize);
         return ResponseBean.success(iTaLiveActivityService.getWxPureLiveActivityList(pg, orgId, cityId, buildingId, name, process));
     }
+
+    @GetMapping("/wx/taLiveActivity/work/livingCode")
+    public ResponseBean getWorkLivingCode(@RequestParam String livingid,
+                                          HttpServletRequest request) {
+        String openid = getOpenId(request);
+        try {
+            String livingCode = workWxUtils.getLivingCode(livingid, openid);
+            return ResponseBean.success(livingCode);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
 }

src/main/java/com/yunzhi/marketing/service/impl/TaLiveActivityServiceImpl.java

@@ -139,48 +139,48 @@ public class TaLiveActivityServiceImpl extends ServiceImpl<TaLiveActivityMapper,
         liveActivityQueryWrapper.eq("live_activity_id", id);
         liveActivityQueryWrapper.eq("org_id", orgId);
         TaLiveActivity result = taLiveActivityMapper.selectOne(liveActivityQueryWrapper);
-        if (result == null) {
-            responseBean.addSuccess(null);
-            return responseBean;
-        }
-
-        // 获取直播小程序信息
-        QueryWrapper<TdLiveDict> tdLiveDictQueryWrapper = new QueryWrapper<>();
-        tdLiveDictQueryWrapper.eq("id", result.getLiveApp());
-        tdLiveDictQueryWrapper.eq("status", "1");
-        TdLiveDict tdLiveDict = tdLiveDictMapper.selectOne(tdLiveDictQueryWrapper);
-        if (tdLiveDict == null) {
-            responseBean.addSuccess(null);
-            return responseBean;
-        }
-        result.setLiveAppName(tdLiveDict.getLivePlatName());
-        result.setLiveAppAppId(tdLiveDict.getLivePlatValue());
-
-        // 获取海报信息
-        QueryWrapper<TaPoster> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq("target_id", id + "");
-        queryWrapper.eq("target_type", CommConstant.LIVE);
-        queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
-        List<TaPoster> posterList = taPosterService.list(queryWrapper);
-
-        List<TaPoster> resultPosterList = new ArrayList<>();
-        if (CollectionUtils.isNotEmpty(posterList)) {
-            for (TaPoster poster : posterList) {
-                QueryWrapper<TdPosterTemplate> templateQueryWrapper = new QueryWrapper<>();
-                templateQueryWrapper.eq("status", CommConstant.STATUS_NORMAL);
-                templateQueryWrapper.eq("type ", "liveActivity");
-                List<TdPosterTemplate> posterTemplate = posterTemplateService.list(templateQueryWrapper);
-
-                poster.setTemplates(posterTemplate);
-                resultPosterList.add(poster);
-            }
-        }
-
-        // 获取分享内容信息
-        List<TaShareContent> shareContentList = shareContentService.getPostersForTarget(id + "", CommConstant.LIVE);
-
-        result.setPosters(resultPosterList);
-        result.setShareContents(shareContentList);
+//        if (result == null) {
+//            responseBean.addSuccess(null);
+//            return responseBean;
+//        }
+//
+//        // 获取直播小程序信息
+//        QueryWrapper<TdLiveDict> tdLiveDictQueryWrapper = new QueryWrapper<>();
+//        tdLiveDictQueryWrapper.eq("id", result.getLiveApp());
+//        tdLiveDictQueryWrapper.eq("status", "1");
+//        TdLiveDict tdLiveDict = tdLiveDictMapper.selectOne(tdLiveDictQueryWrapper);
+//        if (tdLiveDict == null) {
+//            responseBean.addSuccess(null);
+//            return responseBean;
+//        }
+//        result.setLiveAppName(tdLiveDict.getLivePlatName());
+//        result.setLiveAppAppId(tdLiveDict.getLivePlatValue());
+//
+//        // 获取海报信息
+//        QueryWrapper<TaPoster> queryWrapper = new QueryWrapper<>();
+//        queryWrapper.eq("target_id", id + "");
+//        queryWrapper.eq("target_type", CommConstant.LIVE);
+//        queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
+//        List<TaPoster> posterList = taPosterService.list(queryWrapper);
+//
+//        List<TaPoster> resultPosterList = new ArrayList<>();
+//        if (CollectionUtils.isNotEmpty(posterList)) {
+//            for (TaPoster poster : posterList) {
+//                QueryWrapper<TdPosterTemplate> templateQueryWrapper = new QueryWrapper<>();
+//                templateQueryWrapper.eq("status", CommConstant.STATUS_NORMAL);
+//                templateQueryWrapper.eq("type ", "liveActivity");
+//                List<TdPosterTemplate> posterTemplate = posterTemplateService.list(templateQueryWrapper);
+//
+//                poster.setTemplates(posterTemplate);
+//                resultPosterList.add(poster);
+//            }
+//        }
+//
+//        // 获取分享内容信息
+//        List<TaShareContent> shareContentList = shareContentService.getPostersForTarget(id + "", CommConstant.LIVE);
+//
+//        result.setPosters(resultPosterList);
+//        result.setShareContents(shareContentList);
         responseBean.addSuccess(result);
         return responseBean;
     }

src/main/resources/application-dev.yml

@@ -23,3 +23,9 @@ logging:
   config: classpath:log/logback-spring.xml
   level:
     root: info
+
+# 企业微信
+workwx:
+  corpid: wwf5f7889b49bb2510
+  agentid: 1000006
+  secret: qUa67wHPwyFrqoI00ti4gc4q7XLuYhvdok3ERDKuKW8

src/main/resources/application-prod.yml

@@ -23,3 +23,9 @@ logging:
   config: classpath:log/logback-spring.xml
   level:
     root: info
+
+# 企业微信
+workwx:
+  corpid: wwf5f7889b49bb2510
+  agentid: 1000006
+  secret: qUa67wHPwyFrqoI00ti4gc4q7XLuYhvdok3ERDKuKW8

src/main/resources/application-test.yml

@@ -23,3 +23,9 @@ logging:
   config: classpath:log/logback-spring.xml
   level:
     root: info
+
+# 企业微信
+workwx:
+  corpid: wwf5f7889b49bb2510
+  agentid: 1000006
+  secret: qUa67wHPwyFrqoI00ti4gc4q7XLuYhvdok3ERDKuKW8