gengyang 5 tahun lalu
induk
melakukan
32ad7484bc

+ 4 - 0
src/main/java/com/mokamrp/privates/mapper/WorkContactEmployeeMapper.xml

@@ -95,10 +95,14 @@
                p.`name`          as company_name,
                a.contact_id,
                a.state,
+               d.ghid as gh_id,
+               d.openid as open_id,
+               d.appid as app_id,
                a.remark
         FROM mc_work_contact_employee AS a
                  LEFT JOIN mc_work_employee AS e ON a.employee_id = e.id
                  LEFT JOIN mc_work_contact AS c ON a.contact_id = c.id
+                 LEFT JOIN mc_work_contact_employee_openid AS d ON d.id = a.id
                  LEFT JOIN mc_corp AS p ON p.id = a.corp_id
         where 1 = 1 AND ${ew.sqlSegment}
         group by a.id

+ 2 - 27
src/main/java/com/mokamrp/privates/service/impl/WorkContactEmployeeServiceImpl.java

@@ -76,7 +76,6 @@ public class WorkContactEmployeeServiceImpl extends ServiceImpl<WorkContactEmplo
 
         //请求typer,匹配typer标签
         if (list.size() > 0) {
-            list = getAppIdAndOpenidList(list);
             list = getTyperTag(list);
         }
 
@@ -141,8 +140,8 @@ public class WorkContactEmployeeServiceImpl extends ServiceImpl<WorkContactEmplo
         for (int i = 0; i < j; i++) {
             for(t=0;t<resLen;t++) {
                 //匹配成功的
-                if(responseList.getJSONObject(i).get("openid").equals(list.get(i).getOpenId())){
-                    list.get(i).setTyperTag(responseList.getJSONObject(i).get("label").toString()+list.get(i).getOpenId()+"--"+responseList.getJSONObject(i).get("openid"));
+                if(list.get(i).getOpenId() != null && responseList.getJSONObject(i).get("openid").equals(list.get(i).getOpenId())){
+                    list.get(i).setTyperTag(responseList.getJSONObject(i).get("label").toString());
                 }
             }
         }
@@ -150,30 +149,6 @@ public class WorkContactEmployeeServiceImpl extends ServiceImpl<WorkContactEmplo
         return list;
     }
 
-
-    private List<WorkContactEmployeeVo> getAppIdAndOpenidList(List<WorkContactEmployeeVo> list){
-
-        int j = list.size();
-        List<String> userIds = new ArrayList<String>();
-
-        for (int i = 0; i < j; i++) {
-            userIds.add(list.get(i).getClientWxId());
-        }
-
-        /*
-        这边欠缺,通过userId兑换appId和openId
-         */
-
-
-
-        for (int i = 0; i < j; i++) {
-            list.get(i).setAppId("wx0fc21731a702b4d2");
-            list.get(i).setOpenId("0b11f9c6e87b4dff8efc9c520d8215a7");
-        }
-
-        return list;
-    }
-
     @Override
     public Map<String, Object> getPageList(GetWorkContactEmployeeHandle handle) {
 

+ 1 - 1
src/main/java/com/mokamrp/privates/tast/produce/ProduceDataHub.java

@@ -31,7 +31,7 @@ public class ProduceDataHub{
     /**
      * 导出任务,单进程
      */
-    @Scheduled(cron="0 0 10,18 * * *")
+    @Scheduled(cron="0 0 4,12 * * *")
     public void execute() {
         System.out.println("当前时间"+(new Date())+",定时任务推送公司粉丝datahub任务");
         QueryWrapper<Corp> obj= new QueryWrapper<Corp>();