yxt_group
/
supervise
5
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

模版消息

master
wangpengfei 2 years ago
parent
6447b619ce
commit
666956f11c
5 changed files with 45 additions and 38 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/reportinventory/ReportInventoryService.java
  2. 76
      yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java
  3. 2
      yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/ds/crm/CrmMapper.java
  4. 1
      yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/ds/crm/ProjectInfo.java
  5. 2
      yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/ds/system/systemMapper.java

2
yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/reportinventory/ReportInventoryService.java
View File

@ -51,7 +51,7 @@ public class ReportInventoryService {
}
public void sendMessage(String orderDate) throws Exception {
wechatRest.inventorySendMessage(orderDate);
//wechatRest.inventorySendMessage(orderDate);
}
public String buildsExcelById(String orderDate) {

76
yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java
View File

@ -4,6 +4,7 @@ import cn.hutool.Hutool;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.yxt.common.base.config.RedisUtil;
import com.yxt.common.core.result.ResultBean;
import com.yxt.supervise.report.aes.AesException;
@ -24,6 +25,7 @@ import com.yxt.supervise.report.biz.stock.ReportStockDay;
import com.yxt.supervise.report.biz.stock.StockDayRest;
import com.yxt.supervise.report.biz.util.WeixinCheckoutUtil;
import com.yxt.supervise.report.ds.crm.CrmMapper;
import com.yxt.supervise.report.ds.crm.ProjectInfo;
import com.yxt.supervise.report.ds.crm.UserProject;
import com.yxt.supervise.report.ds.rms.Device;
import com.yxt.supervise.report.ds.rms.RiskAlarm;
@ -295,16 +297,18 @@ public class WechatRest {
List<String> user= crmMapper.suerList(projectSid);
List<String> openIds=new ArrayList<>();
for(String u:user){
SysUser sysUser=systemMapper.getAppletOpenidByUsersid(u);
String sysUser=systemMapper.getOpenId(u);
if(null!=sysUser) {
if (com.yxt.common.base.utils.StringUtils.isNotNull(sysUser.getAppletOpenid())) {
openIds.add(sysUser.getAppletOpenid());
if (com.yxt.common.base.utils.StringUtils.isNotNull(sysUser)) {
openIds.add(sysUser);
}
}
}
ProjectDaily projectDaily=projectDailyService.fetchByProjectAndDay(projectSid,orderDate);
// ProjectInfo projectInfo =crmMapper.getProjectNameBySid(projectSid);
ProjectInfo projectInfo=crmMapper.selectOne(new QueryWrapper<ProjectInfo>().eq("sid",projectSid));
// 公众号的模板id(也有相应的接口可以查询到)
r= SuperviseWxMessSender.jgsjzlSend("赵丽晓",openIds,projectSid,projectDaily.getProjectName(),projectDaily.getReportTime());
r= SuperviseWxMessSender.jgsjzlSend(projectInfo.getRegulatoryLeader(),openIds,projectSid,projectDaily.getProjectName(),projectDaily.getReportTime());
System.out.println(r);
}
@ -320,21 +324,21 @@ public class WechatRest {
List<UserProject> user= crmMapper.users(shSid);
List<String> openIds=new ArrayList<>();
List<String> mobiles=new ArrayList<>();
openIds.add("oA-GE69cBwiWG5Tx5R3vvy60o8qk");
openIds.add("oGdho60xVtWEXUks7nYEAn0tGlDE");
mobiles.add("15932270269");
openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs");
openIds.add("oGdho66394A-4-NyumcJ1MEaT8Lo");
mobiles.add("18603312020");
openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo");
openIds.add("oGdho615_xBMYYwftEjjBlC6p2uE");
mobiles.add("13513219196");
openIds.add("oA-GE67j581HgEsim_waItx2KOzE");
openIds.add("oGdho6yYB47f52HVk2NqirrFbRRk");
mobiles.add("13513211777");
openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y");
openIds.add("oGdho668Hew45t0xfBJC84TNGVzI");
mobiles.add("13623307393");
openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE");
openIds.add("oGdho68CArVhC_-7ELkG-jX21ruk");
mobiles.add("13131170271");
openIds.add("oA-GE668qWFcn4O-HpeiPe1FOecE");
openIds.add("oGdho69VxJil_NRxv9StYVpQg58U");
mobiles.add("13333113292");
openIds.add("oA-GE65ExG9RVkqPhOc4e2ctdh0c");
openIds.add("oGdho66Wy-Or1UeqoNHU1YL5yAEM");
mobiles.add("19933133338");
// for(UserProject u:user){
// SysUser sysUser=systemMapper.getAppletOpenidByUsersid(u.getUserSid());
@ -369,21 +373,21 @@ public class WechatRest {
List<UserProject> user= crmMapper.users(shSid);
List<String> openIds=new ArrayList<>();
List<String> mobiles=new ArrayList<>();
openIds.add("oA-GE69cBwiWG5Tx5R3vvy60o8qk");
openIds.add("oGdho60xVtWEXUks7nYEAn0tGlDE");
mobiles.add("15932270269");
openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs");
openIds.add("oGdho66394A-4-NyumcJ1MEaT8Lo");
mobiles.add("18603312020");
openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo");
openIds.add("oGdho615_xBMYYwftEjjBlC6p2uE");
mobiles.add("13513219196");
openIds.add("oA-GE67j581HgEsim_waItx2KOzE");
openIds.add("oGdho6yYB47f52HVk2NqirrFbRRk");
mobiles.add("13513211777");
openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y");
openIds.add("oGdho668Hew45t0xfBJC84TNGVzI");
mobiles.add("13623307393");
openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE");
openIds.add("oGdho68CArVhC_-7ELkG-jX21ruk");
mobiles.add("13131170271");
openIds.add("oA-GE668qWFcn4O-HpeiPe1FOecE");
openIds.add("oGdho69VxJil_NRxv9StYVpQg58U");
mobiles.add("13333113292");
openIds.add("oA-GE65ExG9RVkqPhOc4e2ctdh0c");
openIds.add("oGdho66Wy-Or1UeqoNHU1YL5yAEM");
mobiles.add("19933133338");
// for(UserProject u:user){
// SysUser sysUser=systemMapper.getAppletOpenidByUsersid(u.getUserSid());
@ -444,21 +448,21 @@ public class WechatRest {
List<UserProject> user= crmMapper.users(shSid);
List<String> openIds=new ArrayList<>();
List<String> mobiles=new ArrayList<>();
openIds.add("oA-GE69cBwiWG5Tx5R3vvy60o8qk");
openIds.add("oGdho60xVtWEXUks7nYEAn0tGlDE");
mobiles.add("15932270269");
openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs");
openIds.add("oGdho66394A-4-NyumcJ1MEaT8Lo");
mobiles.add("18603312020");
openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo");
openIds.add("oGdho615_xBMYYwftEjjBlC6p2uE");
mobiles.add("13513219196");
openIds.add("oA-GE67j581HgEsim_waItx2KOzE");
openIds.add("oGdho6yYB47f52HVk2NqirrFbRRk");
mobiles.add("13513211777");
openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y");
openIds.add("oGdho668Hew45t0xfBJC84TNGVzI");
mobiles.add("13623307393");
openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE");
openIds.add("oGdho68CArVhC_-7ELkG-jX21ruk");
mobiles.add("13131170271");
openIds.add("oA-GE668qWFcn4O-HpeiPe1FOecE");
openIds.add("oGdho69VxJil_NRxv9StYVpQg58U");
mobiles.add("13333113292");
openIds.add("oA-GE65ExG9RVkqPhOc4e2ctdh0c");
openIds.add("oGdho66Wy-Or1UeqoNHU1YL5yAEM");
mobiles.add("19933133338");
// for(UserProject u:user){
// SysUser sysUser=systemMapper.getAppletOpenidByUsersid(u.getUserSid());
@ -484,21 +488,21 @@ public class WechatRest {
//List<UserProject> user= crmMapper.users(shSid);
List<String> openIds=new ArrayList<>();
List<String> mobiles=new ArrayList<>();
openIds.add("oA-GE69cBwiWG5Tx5R3vvy60o8qk");
openIds.add("oGdho60xVtWEXUks7nYEAn0tGlDE");
mobiles.add("15932270269");
openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs");
openIds.add("oGdho66394A-4-NyumcJ1MEaT8Lo");
mobiles.add("18603312020");
openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo");
openIds.add("oGdho615_xBMYYwftEjjBlC6p2uE");
mobiles.add("13513219196");
openIds.add("oA-GE67j581HgEsim_waItx2KOzE");
openIds.add("oGdho6yYB47f52HVk2NqirrFbRRk");
mobiles.add("13513211777");
openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y");
openIds.add("oGdho668Hew45t0xfBJC84TNGVzI");
mobiles.add("13623307393");
openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE");
openIds.add("oGdho68CArVhC_-7ELkG-jX21ruk");
mobiles.add("13131170271");
openIds.add("oA-GE668qWFcn4O-HpeiPe1FOecE");
openIds.add("oGdho69VxJil_NRxv9StYVpQg58U");
mobiles.add("13333113292");
openIds.add("oA-GE65ExG9RVkqPhOc4e2ctdh0c");
openIds.add("oGdho66Wy-Or1UeqoNHU1YL5yAEM");
mobiles.add("19933133338");
// for(UserProject u:user){
// SysUser sysUser=systemMapper.getAppletOpenidByUsersid(u.getUserSid());

2
yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/ds/crm/CrmMapper.java
View File

@ -28,4 +28,6 @@ public interface CrmMapper extends BaseMapper<ProjectInfo> {
int getCountByUserSidAndProjectSid(@Param("projectSid") String projectSid,@Param("userSid")String userSid);
@Select("select * from storehouse_project where projectSid = #{projectSid} ")
List<StoreHouse> listStoreHouseByProjectSid(@Param("projectSid") String projectSid);
@Select("select * from project_information where sid = #{sid}")
ProjectInfo getProjectNameBySid(@Param("sid") String sid);
}

1
yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/ds/crm/ProjectInfo.java
View File

@ -8,4 +8,5 @@ import lombok.Data;
public class ProjectInfo {
private String sid;
private String entryName;
private String regulatoryLeader;
}

2
yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/ds/system/systemMapper.java
View File

@ -14,7 +14,7 @@ import java.util.List;
@Mapper
public interface systemMapper extends BaseMapper<com.yxt.supervise.report.ds.system.SysUser> {
@Select("select openid from sys_user where sid=#{userSid}")
@Select("select openid from sys_user where sid=#{userSid} and appletOpenid is not null")
String getOpenId(@Param("userSid") String userSid);
@Select("select openid from sys_user where sid=#{userSid} and subscriptionStatus='1'")
String getOpenIdByStatus(@Param("userSid") String userSid);

Write Preview
Loading…
Cancel
Save