Commit e5922508 authored by 竹天卫's avatar 竹天卫

企业微信消息推送

parent a4dee111
...@@ -3,7 +3,6 @@ package cn.wise.sc.cement.business.controller; ...@@ -3,7 +3,6 @@ package cn.wise.sc.cement.business.controller;
import cn.wise.sc.cement.business.model.BaseResponse; import cn.wise.sc.cement.business.model.BaseResponse;
import cn.wise.sc.cement.business.model.PageQuery; import cn.wise.sc.cement.business.model.PageQuery;
import cn.wise.sc.cement.business.model.query.PlanPeopleQuery; import cn.wise.sc.cement.business.model.query.PlanPeopleQuery;
import cn.wise.sc.cement.business.model.query.SampleDistributionEnclosureQuery;
import cn.wise.sc.cement.business.service.IPlanPeopleService; import cn.wise.sc.cement.business.service.IPlanPeopleService;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
......
...@@ -291,4 +291,16 @@ public class ReportController { ...@@ -291,4 +291,16 @@ public class ReportController {
} }
} }
package cn.wise.sc.cement.business.controller; package cn.wise.sc.cement.business.controller;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import cn.hutool.core.util.URLUtil;
import cn.wise.sc.cement.business.model.BaseResponse; import cn.wise.sc.cement.business.model.BaseResponse;
import cn.wise.sc.cement.business.service.impl.WeiXinService; import cn.wise.sc.cement.business.service.impl.WeiXinService;
import cn.wise.sc.cement.business.util.weixin.Global;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
...@@ -139,14 +139,19 @@ public class WeiXinController { ...@@ -139,14 +139,19 @@ public class WeiXinController {
@ApiOperation(value = "发送消息") @ApiOperation(value = "发送消息")
@GetMapping("/sendTextMessage") @GetMapping("/sendTextMessage")
public BaseResponse sendTextMessage() { public BaseResponse sendTextMessage(String touser) {
try { try {
//发送企业微信消息内容 //发送企业微信消息内容
Integer notice = (int)(1+Math.random()*(10-1+1));
String URL = "https://lab.wisenergy.cn/lab-bangye?id="+269+"&path=/blanche/entrustdetail&notice="+notice;
String systemUrL = systemUrl.replace("U_R_L",URLUtil.encode(URL));
String content="你好!"+"竹天卫"+"向您申请了一条委托,请前往\n" + String content="你好!"+"竹天卫"+"向您申请了一条委托,请前往\n" +
systemUrl+"进行评审。"; systemUrL+"进行评审。";
System.out.println("**************************content**********************"); System.out.println("**************************content**********************");
System.out.println(content); System.out.println(content);
weiXinService.sendTextMessage("ZhuTianWei", content); weiXinService.sendTextMessage(touser, content);
// weiXinService.sendTextMessage("1","hello"); // weiXinService.sendTextMessage("1","hello");
...@@ -157,4 +162,5 @@ public class WeiXinController { ...@@ -157,4 +162,5 @@ public class WeiXinController {
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
} }
...@@ -62,4 +62,9 @@ public class SampleHandleEnclosure implements Serializable { ...@@ -62,4 +62,9 @@ public class SampleHandleEnclosure implements Serializable {
@ApiModelProperty("pdf路径") @ApiModelProperty("pdf路径")
private String pdfUrl; private String pdfUrl;
/**
* 是否允许委托人查看 是否公开 (0不公开,1公开)
*/
private Integer isPublic;
} }
...@@ -84,4 +84,9 @@ public class Team extends BaseEntity implements Serializable { ...@@ -84,4 +84,9 @@ public class Team extends BaseEntity implements Serializable {
@ApiModelProperty("是否需要平行(0否,1是)") @ApiModelProperty("是否需要平行(0否,1是)")
private Integer isParallel; private Integer isParallel;
@ApiModelProperty("是否需要派发(0否 样品处理完直接校核,1是样品处理完需要检测再校核)")
private Integer isPf;
} }
...@@ -185,6 +185,9 @@ ...@@ -185,6 +185,9 @@
<if test="params.status != null"> <if test="params.status != null">
and e.status = #{params.status} and e.status = #{params.status}
</if> </if>
<if test="params.handleStatus != null">
and e.status = #{params.handleStatus}
</if>
<if test="params.isUrgent != null"> <if test="params.isUrgent != null">
and e.is_urgent = #{params.isUrgent} and e.is_urgent = #{params.isUrgent}
</if> </if>
...@@ -241,6 +244,10 @@ ...@@ -241,6 +244,10 @@
<if test="params.status != null"> <if test="params.status != null">
and e.status = #{params.status} and e.status = #{params.status}
</if> </if>
<if test="params.distributionStatus != null">
and t.status = #{params.distributionStatus}
</if>
<if test="params.isUrgent != null"> <if test="params.isUrgent != null">
and e.is_urgent = #{params.isUrgent} and e.is_urgent = #{params.isUrgent}
</if> </if>
......
...@@ -16,6 +16,9 @@ ...@@ -16,6 +16,9 @@
from sample_distribution_enclosure t from sample_distribution_enclosure t
left join sys_user su on su.id = t.user_id left join sys_user su on su.id = t.user_id
where t.sample_distribution_id = #{params.sampleDistributionId} where t.sample_distribution_id = #{params.sampleDistributionId}
<if test="params.userId != null">
and t.user_id = #{params.userId}
</if>
order by t.id ASC order by t.id ASC
</select> </select>
......
...@@ -24,5 +24,5 @@ public class PageQuery implements Serializable { ...@@ -24,5 +24,5 @@ public class PageQuery implements Serializable {
@ApiModelProperty(value = "每页显示数量") @ApiModelProperty(value = "每页显示数量")
@NonNull @NonNull
private Integer pageSize = 10; private Integer pageSize = 20;
} }
...@@ -45,4 +45,7 @@ public class TeamQuery { ...@@ -45,4 +45,7 @@ public class TeamQuery {
@ApiModelProperty("是否需要平行(0否,1是)") @ApiModelProperty("是否需要平行(0否,1是)")
private Integer isParallel; private Integer isParallel;
@ApiModelProperty("是否需要派发(0否 样品处理完直接校核,1是样品处理完需要检测再校核)")
private Integer isPf;
} }
...@@ -71,5 +71,9 @@ public class TeamVo { ...@@ -71,5 +71,9 @@ public class TeamVo {
@ApiModelProperty("是否需要平行(0否,1是)") @ApiModelProperty("是否需要平行(0否,1是)")
private Integer isParallel; private Integer isParallel;
@ApiModelProperty("是否需要派发(0否 样品处理完直接校核,1是样品处理完需要检测再校核)")
private Integer isPf;
} }
...@@ -45,20 +45,13 @@ public interface IEntrustService extends IService<Entrust> { ...@@ -45,20 +45,13 @@ public interface IEntrustService extends IService<Entrust> {
BaseResponse<String> sureUpdate(sureUpdateQuery query); BaseResponse<String> sureUpdate(sureUpdateQuery query);
// BaseResponse<String> handle(HandleQuery query); //样品处理
//派发处理
BaseResponse<IPage<EntrustVo>> getSampleHandlePage(PageQuery pageQuery, String entrustCode, Integer status, BaseResponse<IPage<EntrustVo>> getSampleHandlePage(PageQuery pageQuery, String entrustCode, Integer status,
String clientName, String projectName, String projectCode, Integer isUrgent); String clientName, String projectName, String projectCode,
Integer isUrgent,Integer handleStatus);
BaseResponse<Map<String, Object>> getSampleHandleList(Integer id); BaseResponse<Map<String, Object>> getSampleHandleList(Integer id);
BaseResponse<String> acceptHandle(Integer[] ids);
BaseResponse<List<SampleHandleEnclosureVo>> getSampleHandleEnclosureList(Integer sampleHandleId);
BaseResponse<SampleHandleEnclosure> uploadEnclosureCL(SampleHandleEnclosureQuery query);
BaseResponse<SampleHandleVo> getHandleDtail(Integer id); BaseResponse<SampleHandleVo> getHandleDtail(Integer id);
BaseResponse<String> finishHandle(Integer id); BaseResponse<String> finishHandle(Integer id);
...@@ -70,22 +63,18 @@ public interface IEntrustService extends IService<Entrust> { ...@@ -70,22 +63,18 @@ public interface IEntrustService extends IService<Entrust> {
BaseResponse<String> handleAgain(HandleAgainQuery query); BaseResponse<String> handleAgain(HandleAgainQuery query);
//派发检测 //样品检测
BaseResponse<String> distribution(DistributionQuery query); BaseResponse<String> distribution(DistributionQuery query);
BaseResponse<IPage<EntrustVo>> getSampleDistributionPage(PageQuery pageQuery, String entrustCode, Integer status, BaseResponse<IPage<EntrustVo>> getSampleDistributionPage(PageQuery pageQuery, String entrustCode, Integer status,
String clientName, String projectName, String projectCode, Integer isUrgent); String clientName, String projectName, String projectCode,
Integer isUrgent, Integer distributionStatus);
BaseResponse<Map<String, Object>> getSampleDistributionList(Integer id); BaseResponse<Map<String, Object>> getSampleDistributionList(Integer id);
BaseResponse<String> acceptDistribution(Integer[] ids); BaseResponse<String> acceptDistribution(Integer[] ids);
BaseResponse<List<SampleDistributionEnclosureVo>> getSampleDistributionEnclosureList(Integer sampleDistributionId);
BaseResponse<SampleDistributionEnclosure> uploadEnclosurePF(SampleHandleEnclosureQuery query);
// BaseResponse<SampleDistribution> uploadEnclosurePF(SampleDistributionEnclosureQuery query);
BaseResponse<String> finishDistribution(FinishCheckGroupQuery query); BaseResponse<String> finishDistribution(FinishCheckGroupQuery query);
...@@ -97,12 +86,7 @@ public interface IEntrustService extends IService<Entrust> { ...@@ -97,12 +86,7 @@ public interface IEntrustService extends IService<Entrust> {
BaseResponse<String> distributioAgain(HandleAgainQuery query); BaseResponse<String> distributioAgain(HandleAgainQuery query);
//校核 //校核
BaseResponse<IPage<EntrustVo>> getCheckPage(PageQuery pageQuery, String startDate, String endDate, Integer status, BaseResponse<IPage<EntrustVo>> getCheckPage(PageQuery pageQuery, String startDate, String endDate, Integer status,
Integer clientId, String projectName, String projectCode); Integer clientId, String projectName, String projectCode);
...@@ -110,14 +94,27 @@ public interface IEntrustService extends IService<Entrust> { ...@@ -110,14 +94,27 @@ public interface IEntrustService extends IService<Entrust> {
BaseResponse<CheckUserResultVo> getCheckResult(Integer entrustId, Integer userId); BaseResponse<CheckUserResultVo> getCheckResult(Integer entrustId, Integer userId);
BaseResponse<List<SampleCheckVo>> getCheckDetail(String cementCode);
BaseResponse<Map<String, String>> checkCountFast(CheckCountFastQuery query); BaseResponse<Map<String, String>> checkCountFast(CheckCountFastQuery query);
BaseResponse<String> checkCountNew(CheckCountNewQuery query); BaseResponse<String> checkCountNew(CheckCountNewQuery query);
/*BaseResponse<String> check(CheckQuery query);*/
//附件的操作
BaseResponse<List<SampleHandleEnclosureVo>> getSampleHandleEnclosureList(Integer sampleHandleId);
BaseResponse<SampleHandleEnclosure> uploadEnclosureCL(SampleHandleEnclosureQuery query);
BaseResponse<List<SampleDistributionEnclosureVo>> getSampleDistributionEnclosureList(Integer sampleDistributionId);
BaseResponse<SampleDistributionEnclosure> uploadEnclosurePF(SampleHandleEnclosureQuery query);
BaseResponse<String> deleteEnclosure(Integer id,Integer type);
BaseResponse<String> makePublicEnclosure(Integer isPublic, Integer id,Integer type);
//报告
BaseResponse<IPage<EntrustVo>> getReportPage(PageQuery pageQuery, String startDate, BaseResponse<IPage<EntrustVo>> getReportPage(PageQuery pageQuery, String startDate,
String endDate, Integer clientId, String endDate, Integer clientId,
String projectName, String projectCode); String projectName, String projectCode);
...@@ -143,8 +140,6 @@ public interface IEntrustService extends IService<Entrust> { ...@@ -143,8 +140,6 @@ public interface IEntrustService extends IService<Entrust> {
BaseResponse<List<SampleHandleVo>> getSampleHandleDtail(Integer id); BaseResponse<List<SampleHandleVo>> getSampleHandleDtail(Integer id);
BaseResponse<List<SampleHandleEnclosureVo>> getSampleHandleDtailEnclosureList(Integer sampleHandleId);
BaseResponse<List<SampleVo>> getSampleCheckDtail(Integer id); BaseResponse<List<SampleVo>> getSampleCheckDtail(Integer id);
/** /**
......
package cn.wise.sc.cement.business.service; package cn.wise.sc.cement.business.service;
import cn.wise.sc.cement.business.entity.PlanPeople; import cn.wise.sc.cement.business.entity.PlanPeople;
import cn.wise.sc.cement.business.entity.PlanTraining;
import cn.wise.sc.cement.business.entity.SampleDistribution;
import cn.wise.sc.cement.business.model.BaseResponse; import cn.wise.sc.cement.business.model.BaseResponse;
import cn.wise.sc.cement.business.model.PageQuery; import cn.wise.sc.cement.business.model.PageQuery;
import cn.wise.sc.cement.business.model.query.PlanPeopleQuery; import cn.wise.sc.cement.business.model.query.PlanPeopleQuery;
import cn.wise.sc.cement.business.model.query.SampleDistributionEnclosureQuery;
import cn.wise.sc.cement.business.model.vo.PlanPeopleVo; import cn.wise.sc.cement.business.model.vo.PlanPeopleVo;
import cn.wise.sc.cement.business.model.vo.PlanTrainingVo;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import org.springframework.transaction.annotation.Transactional;
import java.util.Date;
import java.util.List; import java.util.List;
public interface IPlanPeopleService extends IService<PlanPeople> { public interface IPlanPeopleService extends IService<PlanPeople> {
......
...@@ -287,7 +287,7 @@ public class WeiXinService { ...@@ -287,7 +287,7 @@ public class WeiXinService {
//1.2必需 //1.2必需
message.setMsgtype("text"); message.setMsgtype("text");
message.setAgentid(agentId); message.setAgentid(agentIdPC);
Text text=new Text(); Text text=new Text();
text.setContent(content); text.setContent(content);
...@@ -295,7 +295,7 @@ public class WeiXinService { ...@@ -295,7 +295,7 @@ public class WeiXinService {
//2.获取access_token:根据企业id和通讯录密钥获取access_token,并拼接请求url //2.获取access_token:根据企业id和通讯录密钥获取access_token,并拼接请求url
// String accessToken= WeiXinUtil.getAccessToken(corpid, WeiXinParamesUtil.agentSecret).getToken(); // String accessToken= WeiXinUtil.getAccessToken(corpid, WeiXinParamesUtil.agentSecret).getToken();
String accessToken = getAccessToken(); String accessToken = getPCAccessToken();
System.out.println("accessToken:"+accessToken); System.out.println("accessToken:"+accessToken);
//3.发送消息:调用业务类,发送消息 //3.发送消息:调用业务类,发送消息
......
package cn.wise.sc.cement.business.util; package cn.wise.sc.cement.business.util;
import cn.hutool.core.net.URLEncoder;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import cn.hutool.core.util.URLUtil;
import cn.wise.sc.cement.business.service.impl.KeyValueMap; import cn.wise.sc.cement.business.service.impl.KeyValueMap;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import java.util.ArrayList; import java.util.ArrayList;
......
server: server:
port: 7007 port: 7007
#-Dspring.config.location=D:\idea_workspases\tianjin-cement\cement-business\src\main\resources\application.yml
spring: spring:
application: tianjin-cement application: tianjin-cement
profiles: profiles:
...@@ -57,8 +58,8 @@ weixin: ...@@ -57,8 +58,8 @@ weixin:
agentIdPC: 1000003 agentIdPC: 1000003
agentSecret: gFa_7XvXtCaoeAYERzjRwwz_OTJkJfgBb8weOKjmI3o agentSecret: gFa_7XvXtCaoeAYERzjRwwz_OTJkJfgBb8weOKjmI3o
agentSecretPC: itCLYcwl9ggA9VfZam_iz96Ikp9StDFfVr4Adb0yY7A agentSecretPC: itCLYcwl9ggA9VfZam_iz96Ikp9StDFfVr4Adb0yY7A
backUrl: https%3a%2f%2fccdcmtl.sinoma-tianjin.com%2flab-system backUrl: https%3a%2f%2flab.wisenergy.cn%2flab-bangye
systemUrl: '<a href="https://open.weixin.qq.com/connect/oauth2/authorize?appid=ww348f91b2573c1867&redirect_uri=https%3a%2f%2fccdcmtl.sinoma-tianjin.com%2flab-system%2f&response_type=code&scope=snsapi_base&state=#wechat_redirect">物化检测流程</a>,' systemUrl: '<a href="https://open.weixin.qq.com/connect/oauth2/authorize?appid=ww348f91b2573c1867&redirect_uri=U_R_L&response_type=code&scope=snsapi_base&state=#wechat_redirect">物化检测流程</a>,'
......
...@@ -42,21 +42,22 @@ mybatis-plus: ...@@ -42,21 +42,22 @@ mybatis-plus:
mapper-locations: classpath:/cn/wise/sc/cement/business/mapper/xml/*Mapper.xml mapper-locations: classpath:/cn/wise/sc/cement/business/mapper/xml/*Mapper.xml
#天津 #天津
weixin:
corpId: ww348f91b2573c1867
agentId: 1000002
agentIdPC: 1000003
agentSecret: gFa_7XvXtCaoeAYERzjRwwz_OTJkJfgBb8weOKjmI3o
agentSecretPC: itCLYcwl9ggA9VfZam_iz96Ikp9StDFfVr4Adb0yY7A
backUrl: https%3a%2f%2fccdcmtl.sinoma-tianjin.com%2flab-system
systemUrl: <a href=\"https://open.weixin.qq.com/connect/oauth2/authorize?appid="ww348f91b2573c1867"&redirect_uri="https%3a%2f%2fccdcmtl.sinoma-tianjin.com%2flab-system"%2f&response_type=code&scope=snsapi_base&state=#wechat_redirect\">物化检测流程</a>,
#邦业
#weixin: #weixin:
# corpId: ww348f91b2573c1867 # corpId: ww348f91b2573c1867
# agentId: 1000004 # agentId: 1000002
# agentIdPC: 1000005 # agentIdPC: 1000003
# agentSecret: flISLojPiE1_ieO9bPgyZ4g_4O-Rr-FKzs7e7p3HEtA # agentSecret: gFa_7XvXtCaoeAYERzjRwwz_OTJkJfgBb8weOKjmI3o
# agentSecretPC: ABagJNftdn1uOYsDLrhlCIM8jZdcTgEA9DyX6kn_-hY # agentSecretPC: itCLYcwl9ggA9VfZam_iz96Ikp9StDFfVr4Adb0yY7A
# backUrl: https%3a%2f%2flab.wisenergy.cn%2flab-bangye # backUrl: https%3a%2f%2fccdcmtl.sinoma-tianjin.com%2flab-system
# systemUrl: <a href=\"https://open.weixin.qq.com/connect/oauth2/authorize?appid="ww348f91b2573c1867"&redirect_uri="https%3a%2f%2fccdcmtl.sinoma-tianjin.com%2flab-system"%2f&response_type=code&scope=snsapi_base&state=#wechat_redirect\">物化检测流程</a>,
#邦业
weixin:
corpId: ww348f91b2573c1867
agentId: 1000004
agentIdPC: 1000005
agentSecret: flISLojPiE1_ieO9bPgyZ4g_4O-Rr-FKzs7e7p3HEtA
agentSecretPC: ABagJNftdn1uOYsDLrhlCIM8jZdcTgEA9DyX6kn_-hY
backUrl: https%3a%2f%2flab.wisenergy.cn%2flab-bangye
systemUrl: '<a href="https://open.weixin.qq.com/connect/oauth2/authorize?appid=ww348f91b2573c1867&redirect_uri=U_R_L&response_type=code&scope=snsapi_base&state=#wechat_redirect">物化检测流程</a>,'
# systemUrl: <a href=\"https://open.weixin.qq.com/connect/oauth2/authorize?appid="ww348f91b2573c1867"&redirect_uri="https%3a%2f%2flab.wisenergy.cn%2flab-bangye"%2f&response_type=code&scope=snsapi_base&state=#wechat_redirect\">物化检测流程</a>, # systemUrl: <a href=\"https://open.weixin.qq.com/connect/oauth2/authorize?appid="ww348f91b2573c1867"&redirect_uri="https%3a%2f%2flab.wisenergy.cn%2flab-bangye"%2f&response_type=code&scope=snsapi_base&state=#wechat_redirect\">物化检测流程</a>,
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment