diff --git a/crmeb/src/main/java/com/zbkj/crmeb/front/request/LoginRequest.java b/crmeb/src/main/java/com/zbkj/crmeb/front/request/LoginRequest.java index 1097580f..7250649a 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/front/request/LoginRequest.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/front/request/LoginRequest.java @@ -27,12 +27,12 @@ public class LoginRequest implements Serializable { private static final long serialVersionUID=1L; - @ApiModelProperty(value = "手机号", required = true, example = "18991352728") + @ApiModelProperty(value = "手机号", required = true, example = "18888888") @Pattern(regexp = RegularConstants.PHONE, message = "手机号码格式错误") @JsonProperty(value = "account") private String phone; - @ApiModelProperty(value = "密码", required = true, example = "Abc123") + @ApiModelProperty(value = "密码", required = true, example = "1~[6,18]") @Pattern(regexp = RegularConstants.PASSWORD, message = "密码格式错误,密码必须以字母开头,长度在6~18之间,只能包含字符、数字和下划线") private String password; diff --git a/crmeb/src/main/java/com/zbkj/crmeb/front/service/impl/OrderServiceImpl.java b/crmeb/src/main/java/com/zbkj/crmeb/front/service/impl/OrderServiceImpl.java index 40071aaa..35aa175a 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/front/service/impl/OrderServiceImpl.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/front/service/impl/OrderServiceImpl.java @@ -185,9 +185,9 @@ public class OrderServiceImpl implements OrderService { // 检测支付方式 if(!orderUtils.checkPayType(request.getPayType())) throw new CrmebException("暂不支持该支付方式,请刷新页面或者联系管理员"); - Integer isChannel = 1; - if(request.getFrom() == "weixin") isChannel = 0; - if(request.getFrom() == "weixinh5") isChannel = 2; +// Integer isChannel = 1; +// if(request.getFrom() == "weixin") isChannel = 0; +// if(request.getFrom() == "weixinh5") isChannel = 2; String existCacheOrder = orderUtils.cacheGetOrderInfo(userService.getUserIdException(), orderKey); ConfirmOrderResponse cor = JSONObject.parseObject(existCacheOrder,ConfirmOrderResponse.class); if(null == existCacheOrder) throw new CrmebException("订单已过期,请刷新当前页面!"); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/sms/service/impl/SmsServiceImpl.java b/crmeb/src/main/java/com/zbkj/crmeb/sms/service/impl/SmsServiceImpl.java index 32b48557..958e16b1 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/sms/service/impl/SmsServiceImpl.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/sms/service/impl/SmsServiceImpl.java @@ -440,11 +440,15 @@ public class SmsServiceImpl implements SmsService { JSONObject data = joResult.getJSONObject("data"); String smsRecodeId = (data.containsKey("id") ? data.getString("id") : "0"); - // 注意这里的状态仅仅是调用是否成功的状态 需要等待5分钟一周另外一个任务去查询发送状态后再更新status数据 - SmsRecord smsRecord = new SmsRecord(0,sendSmsVo.getUid(), sendSmsVo.getMobile(),sendSmsVo.getContent(), - "", sendSmsVo.getTemplate().toString(), - resultCode,Integer.parseInt(smsRecodeId), message); - smsRecordService.save(smsRecord); + try{ + // 注意这里的状态仅仅是调用是否成功的状态 需要等待5分钟一周另外一个任务去查询发送状态后再更新status数据 + SmsRecord smsRecord = new SmsRecord(0,sendSmsVo.getUid(), sendSmsVo.getMobile(),sendSmsVo.getContent(), + "", sendSmsVo.getTemplate().toString(), + resultCode,Integer.parseInt(smsRecodeId), message); + smsRecordService.save(smsRecord); + }catch (Exception e){ + return true; + } // 添加到短信实际发送状态队列 if(smsRecodeId.length() > 0){ List recordsIds = new ArrayList<>(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/system/request/SystemAdminLoginRequest.java b/crmeb/src/main/java/com/zbkj/crmeb/system/request/SystemAdminLoginRequest.java index 103dce77..d0eb35e2 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/system/request/SystemAdminLoginRequest.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/system/request/SystemAdminLoginRequest.java @@ -15,11 +15,11 @@ import javax.validation.constraints.NotEmpty; */ @Data public class SystemAdminLoginRequest { - @ApiModelProperty(value = "后台管理员账号", example = "admin") + @ApiModelProperty(value = "后台管理员账号", example = "userName") @NotEmpty(message = "账号 不能为空") private String account; - @ApiModelProperty(value = "后台管理员密码", example = "123456") + @ApiModelProperty(value = "后台管理员密码", example = "userPassword") @NotEmpty(message = "密码 不能为空") private String pwd; diff --git a/crmeb/src/main/java/com/zbkj/crmeb/system/service/impl/SystemConfigServiceImpl.java b/crmeb/src/main/java/com/zbkj/crmeb/system/service/impl/SystemConfigServiceImpl.java index 6f81f573..25e189b6 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/system/service/impl/SystemConfigServiceImpl.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/system/service/impl/SystemConfigServiceImpl.java @@ -16,12 +16,14 @@ import com.zbkj.crmeb.system.service.SystemConfigService; import com.zbkj.crmeb.system.service.SystemFormTempService; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.ArrayList; import java.util.HashMap; import java.util.List; +import java.util.stream.Collectors; /** * @author Mr.Zhang @@ -45,6 +47,9 @@ public class SystemConfigServiceImpl extends ServiceImpl forAsyncPram = systemConfigList.stream().map(e -> { + e.setStatus(true); + return e; + }).collect(Collectors.toList()); + async(forAsyncPram); return true; } @@ -225,7 +234,8 @@ public class SystemConfigServiceImpl extends ServiceImpl info(Integer formId){ LambdaQueryWrapper lambdaQueryWrapper1 = new LambdaQueryWrapper<>(); - lambdaQueryWrapper1.eq(SystemConfig::getStatus, false).eq(SystemConfig::getFormId, formId); +// lambdaQueryWrapper1.eq(SystemConfig::getStatus, false).eq(SystemConfig::getFormId, formId); + lambdaQueryWrapper1.eq(SystemConfig::getFormId, formId); List systemConfigList = dao.selectList(lambdaQueryWrapper1); if(systemConfigList.size() < 1){ return null; @@ -281,6 +291,11 @@ public class SystemConfigServiceImpl extends ServiceImpl systemConfigList){ + if (!asyncConfig) { + //如果配置没有开启 + return; + } + for (SystemConfig systemConfig : systemConfigList) { if(systemConfig.getStatus()){ //隐藏之后,删除redis的数据 @@ -299,6 +314,10 @@ public class SystemConfigServiceImpl extends ServiceImpl lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(SystemConfig::getStatus, false).eq(SystemConfig::getName, name); + SystemConfig systemConfig = dao.selectOne(lambdaQueryWrapper); + if(null == systemConfig || StringUtils.isBlank(systemConfig.getValue())){ + return null; + } + + return systemConfig.getValue(); + + } setRedisByVoList(); Object data = redisUtil.hmGet(redisKey, name); if(null == data || StringUtils.isBlank(data.toString())){ @@ -318,8 +349,6 @@ public class SystemConfigServiceImpl extends ServiceImpl 0){ + if(size > 0 || !asyncConfig){ return; } diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncCloud.java b/crmeb/src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java similarity index 97% rename from crmeb/src/main/java/com/zbkj/crmeb/task/AsyncCloud.java rename to crmeb/src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java index 978ba43e..dcefd7ed 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncCloud.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java @@ -1,4 +1,4 @@ -package com.zbkj.crmeb.task; +package com.zbkj.crmeb.task.cloud; import com.utils.DateUtil; import com.zbkj.crmeb.system.service.SystemAttachmentService; diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncSmsSend.java b/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java similarity index 97% rename from crmeb/src/main/java/com/zbkj/crmeb/task/AsyncSmsSend.java rename to crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java index 62e9cf60..3e6ec932 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncSmsSend.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java @@ -1,4 +1,4 @@ -package com.zbkj.crmeb.task; +package com.zbkj.crmeb.task.sms; import com.utils.DateUtil; import com.zbkj.crmeb.sms.service.SmsService; diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncSmsSendResult.java b/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java similarity index 97% rename from crmeb/src/main/java/com/zbkj/crmeb/task/AsyncSmsSendResult.java rename to crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java index 523a9b65..3c20540d 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncSmsSendResult.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java @@ -1,4 +1,4 @@ -package com.zbkj.crmeb.task; +package com.zbkj.crmeb.task.sms; import com.utils.DateUtil; import com.zbkj.crmeb.sms.model.SmsRecord; diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncWeChatProgramTempMessage.java b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempMessage.java similarity index 97% rename from crmeb/src/main/java/com/zbkj/crmeb/task/AsyncWeChatProgramTempMessage.java rename to crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempMessage.java index 132e59b7..d60fd7c5 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncWeChatProgramTempMessage.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempMessage.java @@ -1,4 +1,4 @@ -package com.zbkj.crmeb.task; +package com.zbkj.crmeb.task.wechat; import com.utils.DateUtil; import com.zbkj.crmeb.wechat.service.TemplateMessageService; diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncWeChatPublicTempMessage.java b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java similarity index 87% rename from crmeb/src/main/java/com/zbkj/crmeb/task/AsyncWeChatPublicTempMessage.java rename to crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java index f92db8e7..b0a26ca7 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/AsyncWeChatPublicTempMessage.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java @@ -1,10 +1,7 @@ -package com.zbkj.crmeb.task; +package com.zbkj.crmeb.task.wechat; -import com.constants.Constants; import com.utils.DateUtil; -import com.zbkj.crmeb.system.service.SystemAttachmentService; import com.zbkj.crmeb.wechat.service.TemplateMessageService; -import com.zbkj.crmeb.wechat.service.WeChatService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; diff --git a/crmeb/src/main/resources/application-prod.yml b/crmeb/src/main/resources/application-prod.yml index 1e06d659..0dbb53b9 100644 --- a/crmeb/src/main/resources/application-prod.yml +++ b/crmeb/src/main/resources/application-prod.yml @@ -5,6 +5,8 @@ server: wechat-api-url: wechat-js-api-debug: false wechat-js-api-beta: false + asyncConfig: true + spring: profiles: # 配置的环境 diff --git a/crmeb/src/main/resources/application.yml b/crmeb/src/main/resources/application.yml index 71aec069..1592dc08 100644 --- a/crmeb/src/main/resources/application.yml +++ b/crmeb/src/main/resources/application.yml @@ -2,9 +2,10 @@ server: port: 8080 domain: - wechat-api-url: 微信消息转发服务器http地址 + wechat-api-url: #微信消息转发服务器http地址 wechat-js-api-debug: true wechat-js-api-beta: true + asyncConfig: false spring: profiles: diff --git a/crmeb_java_v1.0.sql b/crmeb_java_v1.0.sql index fc09fe74..c49d3195 100644 --- a/crmeb_java_v1.0.sql +++ b/crmeb_java_v1.0.sql @@ -7,7 +7,7 @@ # # Host: 127.0.0.1 (MySQL 5.7.23) # Database: crmeb_java -# Generation Time: 2020-08-26 02:49:50 +0000 +# Generation Time: 2020-08-28 05:02:57 +0000 # ************************************************************ @@ -754,12 +754,12 @@ CREATE TABLE `eb_sms_record` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '短信发送记录编号', `uid` varchar(255) NOT NULL COMMENT '短信平台账号', `phone` char(11) NOT NULL COMMENT '接受短信的手机号', - `content` text NOT NULL COMMENT '短信内容', + `content` text COMMENT '短信内容', `add_ip` varchar(30) DEFAULT NULL COMMENT '添加记录ip', `create_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', - `template` varchar(255) NOT NULL COMMENT '短信模板ID', - `resultcode` int(6) unsigned NOT NULL COMMENT '状态码 100=成功,130=失败,131=空号,132=停机,133=关机,134=无状态', - `record_id` int(11) unsigned NOT NULL COMMENT '发送记录id', + `template` varchar(255) DEFAULT '' COMMENT '短信模板ID', + `resultcode` int(6) unsigned DEFAULT NULL COMMENT '状态码 100=成功,130=失败,131=空号,132=停机,133=关机,134=无状态', + `record_id` int(11) unsigned DEFAULT NULL COMMENT '发送记录id', `memo` text COMMENT '短信平台返回信息', PRIMARY KEY (`id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='短信发送记录表';