From 5cefa08d76ef7accc05d1e875cbcb43715f78042 Mon Sep 17 00:00:00 2001 From: xhxu Date: Tue, 20 Jul 2021 16:37:03 +0800 Subject: [PATCH 01/14] bug --- .../src/main/java/com/iformall/utils/AppTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java b/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java index 347a44f32..b07d83efc 100644 --- a/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java +++ b/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java @@ -56,8 +56,8 @@ public class AppTest { // paramMap.put("shopName","百丽");//门店名称 paramMap.put("userNumber","516625539215818752");//***会员Id // paramMap.put("userPhone","18872592633");//会员手机号 - paramMap.put("timeEnd","2021-07-20 14:18:00");//***付款时间(yyyy-MM-dd HH:mm:ss) - paramMap.put("amount","1800");//***付款金额(分) + paramMap.put("timeEnd","2021-07-20 15:19:00");//***付款时间(yyyy-MM-dd HH:mm:ss) + paramMap.put("amount","17900");//***付款金额(分) // paramMap.put("summary","");//付款摘要 /** @@ -107,7 +107,7 @@ public class AppTest { /** * 创建交易信息 接口 */ - String s = HttpUtil.doPost("https://openapitest.malls.iformall.com/api/thirdCircle/order", headMap, JSON.toJSONString(paramMap)); + String s = HttpUtil.doPost("https://openapi.malls.iformall.com/api/thirdCircle/order", headMap, JSON.toJSONString(paramMap)); // String s = HttpUtil.doPost("http://localhost:7070/public/api/thirdCircle/order", headMap, JSON.toJSONString(paramMap)); From 71f6eda8587413c3aaee0f5f4110601e091f9f7e Mon Sep 17 00:00:00 2001 From: xhxu Date: Tue, 20 Jul 2021 18:12:59 +0800 Subject: [PATCH 02/14] msg add --- .../src/main/java/com/iformall/sms/EnumSMSChannel.java | 1 + .../src/main/java/com/iformall/sms/SMSFactory.java | 9 ++++++++- .../src/main/java/com/iformall/sms/aliyun/AliyunSMS.java | 5 ++++- 3 files changed, 13 insertions(+), 2 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/sms/EnumSMSChannel.java b/mallinkService/src/main/java/com/iformall/sms/EnumSMSChannel.java index d5087279e..e49b10ee7 100644 --- a/mallinkService/src/main/java/com/iformall/sms/EnumSMSChannel.java +++ b/mallinkService/src/main/java/com/iformall/sms/EnumSMSChannel.java @@ -7,6 +7,7 @@ package com.iformall.sms; public enum EnumSMSChannel { ALIYUN(11, "ALIYUN"), + ALIYUN_ZDY(12, "ALIYUN_ZDY"), WIWIDE(0,"WIWIDE"); public static EnumSMSChannel getEnum(Integer code) { diff --git a/mallinkService/src/main/java/com/iformall/sms/SMSFactory.java b/mallinkService/src/main/java/com/iformall/sms/SMSFactory.java index 486a1e73e..65784a11c 100644 --- a/mallinkService/src/main/java/com/iformall/sms/SMSFactory.java +++ b/mallinkService/src/main/java/com/iformall/sms/SMSFactory.java @@ -1,6 +1,7 @@ package com.iformall.sms; import com.iformall.sms.aliyun.AliyunSMS; +import com.iformall.sms.aliyun.bean.AliyunSMSConfig; import com.iformall.sms.wiwide.WiwideUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -11,7 +12,10 @@ import javax.annotation.PostConstruct; public class SMSFactory { @Autowired - private AliyunSMS aliyunSMS; + private AliyunSMSConfig smsConfig; + + @Autowired + private AliyunSMS aliyunSMS ; @Autowired private WiwideUtil wiwide; @@ -26,6 +30,9 @@ public class SMSFactory { private static SMSExcutor getSendExcutor(Integer channel) { if(EnumSMSChannel.ALIYUN.getCode().equals(channel)) { + smsFactory.aliyunSMS.setSmsConfig(smsFactory.smsConfig); + return smsFactory.aliyunSMS; + }else if(EnumSMSChannel.ALIYUN_ZDY.getCode().equals(channel)){ return smsFactory.aliyunSMS; }else{ return smsFactory.wiwide; diff --git a/mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java b/mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java index 322caaaa8..34e115312 100644 --- a/mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java +++ b/mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java @@ -21,9 +21,12 @@ import java.text.SimpleDateFormat; @Slf4j public class AliyunSMS implements SMSExcutor { - @Autowired private AliyunSMSConfig smsConfig; + public void setSmsConfig(AliyunSMSConfig smsConfig){ + this.smsConfig = smsConfig; + } + @Override public String sendMsg(String secret, String bid, String publickey, String phone, String signature, String msg, String notifyUrl, String verifysms, Integer modelId, String templateParam, String templateCode, String outId) { SMSResult SMSResult = new SMSResult(); From 89065ec24fe660db06089ed9604293e93578304f Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 21 Jul 2021 11:44:42 +0800 Subject: [PATCH 03/14] msg add --- .../V202107210001__wx_msg_config_add_.sql | 5 +++ .../com/iformall/domain/po/WxMsgConfig.java | 9 +++++ .../service/impl/WxMsgModelServiceImpl.java | 5 ++- .../WxMsgValidationcodeModelServiceImpl.java | 5 ++- .../msg/impl/SendCallBackSmsServiceImpl.java | 4 +-- .../service/msg/impl/SendSmsServiceImpl.java | 9 +++-- .../java/com/iformall/sms/SMSFactory.java | 36 ++++++++++++------- .../sms/aliyun/bean/AliyunSMSConfig.java | 2 +- .../com/iformall/sms/wiwide/WiwideUtil.java | 3 +- .../resources/mapper/WxMsgConfigMapper.xml | 8 ++++- 10 files changed, 58 insertions(+), 28 deletions(-) create mode 100644 mallinkAdmin/src/main/resources/db/migration/V202107210001__wx_msg_config_add_.sql diff --git a/mallinkAdmin/src/main/resources/db/migration/V202107210001__wx_msg_config_add_.sql b/mallinkAdmin/src/main/resources/db/migration/V202107210001__wx_msg_config_add_.sql new file mode 100644 index 000000000..207242127 --- /dev/null +++ b/mallinkAdmin/src/main/resources/db/migration/V202107210001__wx_msg_config_add_.sql @@ -0,0 +1,5 @@ +ALTER TABLE `wx_msg_config` +ADD COLUMN `product` varchar(50) AFTER `sms_channel`, +ADD COLUMN `domain` varchar(100) AFTER `product`, +ADD COLUMN `region_id` varchar(50) AFTER `domain`, +ADD COLUMN `endpoint_name` varchar(50) AFTER `region_id`; \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/domain/po/WxMsgConfig.java b/mallinkService/src/main/java/com/iformall/domain/po/WxMsgConfig.java index 65eac003e..2f26420df 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/WxMsgConfig.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/WxMsgConfig.java @@ -43,5 +43,14 @@ public class WxMsgConfig extends TenantEntity { @io.swagger.annotations.ApiModelProperty(value="发短信渠道0:wiwidi; 11:aliyun",name="smsChannel") private Integer smsChannel; + + // 短信API产品名称(短信产品名固定,无需修改) product = "Dysmsapi" + private String product; + //短信API产品域名,接口地址固定,无需修改 domain = "dysmsapi.aliyuncs.com" + private String domain; + //API支持的RegionID,如短信API的值为: cn-hangzhou。 + private String regionId; + //服务结点: cn-hangzhou + private String endpointName; } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgModelServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgModelServiceImpl.java index 936e5892c..221de895f 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgModelServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgModelServiceImpl.java @@ -73,9 +73,8 @@ public class WxMsgModelServiceImpl implements WxMsgModelService { } } - String result = SMSFactory.addTemplate(secret, bid, wxMsgConfig.getPublickey(), signature, - content, wxMsgConfig.getModelnotifyurl(),EnumVerifyCode.NO.getCode().toString(), - wxMsgModel.getName(),1,wxMsgModel.getName(),wxMsgConfig.getSmsChannel()); + String result = SMSFactory.addTemplate(wxMsgConfig, signature,content, EnumVerifyCode.NO.getCode().toString(), + wxMsgModel.getName(),1,wxMsgModel.getName()); JSONObject jsonObjectResult = JSONObject.parseObject(result); String ret = jsonObjectResult.get("ret").toString(); logger.info("短信模板创建结果:" + result); diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeModelServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeModelServiceImpl.java index f6f9afee9..c5c0695c3 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeModelServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeModelServiceImpl.java @@ -141,9 +141,8 @@ public class WxMsgValidationcodeModelServiceImpl implements WxMsgValidationcodeM } } - String result = SMSFactory.addTemplate(secret, bid, wxMsgConfig.getPublickey(), signature, content, - wxMsgConfig.getVerifynotifyurl(),EnumVerifyCode.YES.getCode().toString(), - wxMsgModel.getName(),1,wxMsgModel.getName(),wxMsgConfig.getSmsChannel()); + String result = SMSFactory.addTemplate(wxMsgConfig, signature, content,EnumVerifyCode.YES.getCode().toString(), + wxMsgModel.getName(),1,wxMsgModel.getName()); JSONObject jsonObjectResult = JSONObject.parseObject(result); String ret = jsonObjectResult.get("ret").toString(); diff --git a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java index 5123969cc..713b69957 100644 --- a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java @@ -106,9 +106,9 @@ public class SendCallBackSmsServiceImpl implements MsgSendService { outId = Long.toString(record.getId()); }catch(Exception e){} - String result = SMSFactory.sendSms(secret, bid, publickey, phone, signature, msg, notifyUrl, + String result = SMSFactory.sendSms(wxMsgConfig, phone, signature, msg, EnumVerifyCode.NO.getCode().toString(), modelId, - null,wxMsgModel.getModelCode(),outId,wxMsgConfig.getSmsChannel()); + null,wxMsgModel.getModelCode(),outId); JSONObject jsonObjectResult = JSONObject.parseObject(result); String ret = jsonObjectResult.get("ret").toString(); diff --git a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java index 5597c8297..fa38bc82f 100644 --- a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java @@ -99,10 +99,9 @@ public class SendSmsServiceImpl implements MsgSendService { String notifyUrl = wxMsgConfig.getNotifyurl(); Integer modelId = wxMsgValidationcodeModel.getModelId(); String id = record.getDynamicContentMap().get("id"); - String result = SMSFactory.sendSms(secret, bid, publickey, phone, signature, msg, notifyUrl, - EnumVerifyCode.YES.getCode().toString(), modelId, - JSON.toJSONString(record.getDynamicContentMap()),wxMsgValidationcodeModel.getModelCode(), - id,wxMsgConfig.getSmsChannel()); + String result = SMSFactory.sendSms(wxMsgConfig, phone, signature, msg, + EnumVerifyCode.YES.getCode().toString(), modelId,JSON.toJSONString(record.getDynamicContentMap()), + wxMsgValidationcodeModel.getModelCode(),id); JSONObject jsonObjectResult = JSONObject.parseObject(result); String ret = jsonObjectResult.get("ret").toString(); String batchNo = jsonObjectResult.get("data").toString(); @@ -110,7 +109,7 @@ public class SendSmsServiceImpl implements MsgSendService { if (ret.equals("1")) { long currentTime = System.currentTimeMillis(); - Date createtime=new Date(currentTime); + Date createtime = new Date(currentTime); wxMsgValidationcode.setCreatetime(createtime); Integer minutes = wxMsgValidationcodeModel.getMinutes(); if(minutes >0) { diff --git a/mallinkService/src/main/java/com/iformall/sms/SMSFactory.java b/mallinkService/src/main/java/com/iformall/sms/SMSFactory.java index 65784a11c..6ed193859 100644 --- a/mallinkService/src/main/java/com/iformall/sms/SMSFactory.java +++ b/mallinkService/src/main/java/com/iformall/sms/SMSFactory.java @@ -1,5 +1,6 @@ package com.iformall.sms; +import com.iformall.domain.po.WxMsgConfig; import com.iformall.sms.aliyun.AliyunSMS; import com.iformall.sms.aliyun.bean.AliyunSMSConfig; import com.iformall.sms.wiwide.WiwideUtil; @@ -28,28 +29,39 @@ public class SMSFactory { smsFactory = this; } - private static SMSExcutor getSendExcutor(Integer channel) { - if(EnumSMSChannel.ALIYUN.getCode().equals(channel)) { + private static SMSExcutor getSendExcutor(WxMsgConfig wxMsgConfig) { + if(EnumSMSChannel.ALIYUN.getCode().equals(wxMsgConfig.getSmsChannel())) { smsFactory.aliyunSMS.setSmsConfig(smsFactory.smsConfig); return smsFactory.aliyunSMS; - }else if(EnumSMSChannel.ALIYUN_ZDY.getCode().equals(channel)){ + }else if(EnumSMSChannel.ALIYUN_ZDY.getCode().equals(wxMsgConfig.getSmsChannel())){ + smsFactory.smsConfig = new AliyunSMSConfig(); + smsFactory.smsConfig.setAccessKeyId(wxMsgConfig.getPublickey()); + smsFactory.smsConfig.setAccessKeySecret(wxMsgConfig.getSecret()); + smsFactory.smsConfig.setProduct(wxMsgConfig.getProduct()); + smsFactory.smsConfig.setDomain(wxMsgConfig.getDomain()); + smsFactory.smsConfig.setRegionId(wxMsgConfig.getRegionId()); + smsFactory.smsConfig.setEndpointName(wxMsgConfig.getEndpointName()); + smsFactory.aliyunSMS.setSmsConfig(smsFactory.smsConfig); return smsFactory.aliyunSMS; }else{ return smsFactory.wiwide; } } - public static String sendSms(String secret, String bid, String publickey,String phone, String signature, - String msg, String notifyUrl, String verifysms, Integer modelId,String templateParam, - String templateCode, String outId,Integer channel) { - return getSendExcutor(channel).sendMsg(secret, bid, publickey, phone, signature, msg, notifyUrl, + public static String sendSms(WxMsgConfig wxMsgConfig,String phone, String signature, String msg, + String verifysms, Integer modelId, String templateParam, + String templateCode, String outId) { + return getSendExcutor(wxMsgConfig).sendMsg(wxMsgConfig.getSecret(), wxMsgConfig.getBid(), wxMsgConfig.getPublickey(), + phone, signature, msg, wxMsgConfig.getNotifyurl(), verifysms, modelId,templateParam,templateCode,outId); } - public static String addTemplate(String secret, String bid, String publickey, String signature, String content, - String notifyUrl, String verifysms,String templateName,Integer templateType, - String remark,Integer channel) { - return getSendExcutor(channel).addTemplate(secret, bid, publickey, signature, content, notifyUrl,verifysms, - templateName,templateType,remark); + public static String addTemplate(WxMsgConfig wxMsgConfig, String signature, String content, + String verifysms,String templateName,Integer templateType, + String remark) { + return getSendExcutor(wxMsgConfig).addTemplate(wxMsgConfig.getSecret(), wxMsgConfig.getBid(), wxMsgConfig.getPublickey(), + signature, content, wxMsgConfig.getNotifyurl(), + verifysms,templateName,templateType,remark); } + } diff --git a/mallinkService/src/main/java/com/iformall/sms/aliyun/bean/AliyunSMSConfig.java b/mallinkService/src/main/java/com/iformall/sms/aliyun/bean/AliyunSMSConfig.java index 62ecf3828..a53c3fd51 100644 --- a/mallinkService/src/main/java/com/iformall/sms/aliyun/bean/AliyunSMSConfig.java +++ b/mallinkService/src/main/java/com/iformall/sms/aliyun/bean/AliyunSMSConfig.java @@ -23,7 +23,7 @@ public class AliyunSMSConfig { //API支持的RegionID,如短信API的值为: cn-hangzhou。 private String regionId; //#发送日期 支持30天内记录查询,格式: yyyyMMdd - private String dateFormat; + private String dateFormat = "yyyyMMdd"; //服务结点: cn-hangzhou private String endpointName; diff --git a/mallinkService/src/main/java/com/iformall/sms/wiwide/WiwideUtil.java b/mallinkService/src/main/java/com/iformall/sms/wiwide/WiwideUtil.java index 873b51b73..bf995de17 100644 --- a/mallinkService/src/main/java/com/iformall/sms/wiwide/WiwideUtil.java +++ b/mallinkService/src/main/java/com/iformall/sms/wiwide/WiwideUtil.java @@ -76,7 +76,8 @@ public class WiwideUtil implements SMSExcutor { } public static String sendMsg(String secret, String bid, String publickey, - String phone, String signature, String msg, String notifyUrl, String verifysms, Integer modelId) { + String phone, String signature, String msg, String notifyUrl, + String verifysms, Integer modelId) { TreeMap message = new TreeMap<>(); message.put("bid", bid); message.put("phone", phone); diff --git a/mallinkService/src/main/resources/mapper/WxMsgConfigMapper.xml b/mallinkService/src/main/resources/mapper/WxMsgConfigMapper.xml index 999716609..9456c59e8 100644 --- a/mallinkService/src/main/resources/mapper/WxMsgConfigMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxMsgConfigMapper.xml @@ -21,11 +21,17 @@ + + + + + `id`,`tenant_id`,`parent_tenant_id`,`secret`,`publickey`,`bid`,`recharge`,`remains`,`total`,`account`, - `reminderstatus`,`reminder`,`phone`,`notifyurl`,`modelnotifyurl`,`verifynotifyurl`,`sms_channel` + `reminderstatus`,`reminder`,`phone`,`notifyurl`,`modelnotifyurl`,`verifynotifyurl`,`sms_channel`, + `product`,`domain`,`region_id`,`endpoint_name` From 863195d3044b5beede54b0da9e0c1de34bfd2a13 Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 21 Jul 2021 14:28:33 +0800 Subject: [PATCH 04/14] msg add --- .../service/impl/WxCUserTagsServiceImpl.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserTagsServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserTagsServiceImpl.java index a443abfde..88872c557 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserTagsServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserTagsServiceImpl.java @@ -538,7 +538,7 @@ public class WxCUserTagsServiceImpl implements WxCUserTagsService { return resList; } - private List assignTypeId18(WxCUserBasicInfo user) { + private List assignTypeId18(WxCUserBasicInfo user,TenantEntity tenantEntity) { List resList = null; final int WORK_DAY = 0; @@ -558,12 +558,14 @@ public class WxCUserTagsServiceImpl implements WxCUserTagsService { startC.add(Calendar.DAY_OF_YEAR, -30); WxCouponOrder wxCouponOrder = new WxCouponOrder(); + wxCouponOrder.updateTenantInfo(tenantEntity); wxCouponOrder.setCUserId(user.getId()); wxCouponOrder.setCouponOrderStatus(EnumCouponOrderStatus.COUPON_ORDER_USED.getCode()); wxCouponOrder.setStartTime(startC.getTime()); wxCouponOrder.setEndTime(endC.getTime()); WxCardSpend wxCardSpend = new WxCardSpend(); + wxCardSpend.updateTenantInfo(tenantEntity); wxCardSpend.setOwnerId(user.getId()); wxCardSpend.setStartdate(startC.getTime()); wxCardSpend.setEnddate(endC.getTime()); @@ -632,7 +634,7 @@ public class WxCUserTagsServiceImpl implements WxCUserTagsService { return resList; } - private List assignTypeId22(WxCUserBasicInfo user) { + private List assignTypeId22(WxCUserBasicInfo user,TenantEntity tenantEntity) { List resList = null; int days = (int) ((new Date().getTime() - user.getCreateDate().getTime()) / (1000*3600*24)); @@ -772,9 +774,9 @@ public class WxCUserTagsServiceImpl implements WxCUserTagsService { //饮食偏好 resList = assignTypeId17(user,tenantEntity); //消费时段 - resList = assignTypeId18(user); + resList = assignTypeId18(user,tenantEntity); //消费频度 - resList = assignTypeId22(user); + resList = assignTypeId22(user,tenantEntity); } } break; @@ -841,9 +843,9 @@ public class WxCUserTagsServiceImpl implements WxCUserTagsService { resList = assignTypeId17(user,tenantEntity); //消费时段 - resList = assignTypeId18(user); + resList = assignTypeId18(user,tenantEntity); //消费频度 - resList = assignTypeId22(user); + resList = assignTypeId22(user,tenantEntity); //活跃 resList = assignTypeId21(user,tenantEntity); From 42da77efde4fb2f8c863db90cd7c01e09fd07e88 Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 21 Jul 2021 14:31:22 +0800 Subject: [PATCH 05/14] msg add --- .../src/main/java/com/iformall/sms/aliyun/AliyunSMS.java | 2 +- .../src/main/java/com/iformall/sms/wiwide/WiwideUtil.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java b/mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java index 34e115312..bffd2cf4a 100644 --- a/mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java +++ b/mallinkService/src/main/java/com/iformall/sms/aliyun/AliyunSMS.java @@ -78,7 +78,7 @@ public class AliyunSMS implements SMSExcutor { SendSmsResponse sendSmsResponse = null; try { sendSmsResponse = acsClient.getAcsResponse(request); - log.info("发送短信-----" + sendSmsResponse.getCode() + "----" + sendSmsResponse.getMessage()); + log.info("ali发送短信-----" + sendSmsResponse.getCode() + "----" + sendSmsResponse.getMessage()); } catch (ClientException e) { log.error("发送短信发生错误。错误代码是 [{}],错误消息是 [{}],错误请求ID是 [{}],错误Msg是 [{}],错误类型是 [{}]", e.getErrCode(), e.getMessage(), e.getRequestId(), e.getErrMsg(), e.getErrorType()); diff --git a/mallinkService/src/main/java/com/iformall/sms/wiwide/WiwideUtil.java b/mallinkService/src/main/java/com/iformall/sms/wiwide/WiwideUtil.java index bf995de17..4284f50b7 100644 --- a/mallinkService/src/main/java/com/iformall/sms/wiwide/WiwideUtil.java +++ b/mallinkService/src/main/java/com/iformall/sms/wiwide/WiwideUtil.java @@ -96,7 +96,7 @@ public class WiwideUtil implements SMSExcutor { sb.append("&secret=").append(secret); String sign = HMACSHA256.sha256_HMAC(sb.toString(), secret); message.put("sign", sign.toUpperCase()); - logger.debug(message.toString()); + logger.info("wiwide发短信---"+message.toString()); String str32 = HMACSHA256.STR2; String iv = HMACSHA256.IV; From f9c4ad321c11e77c27d546f758806ebfc511e85c Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 21 Jul 2021 15:20:03 +0800 Subject: [PATCH 06/14] msg bug --- .../java/com/iformall/domain/po/msg/WxMsgRecord.java | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/domain/po/msg/WxMsgRecord.java b/mallinkService/src/main/java/com/iformall/domain/po/msg/WxMsgRecord.java index 64c9bac9e..2d9ab9388 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/msg/WxMsgRecord.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/msg/WxMsgRecord.java @@ -15,8 +15,6 @@ import java.util.Map; public class WxMsgRecord extends BaseMsg { protected Long id; - @io.swagger.annotations.ApiModelProperty(value = "租户ID", name = "tenantId") - private String tenantId; @io.swagger.annotations.ApiModelProperty(value="消息类型 1短信 2回调短信 3邮件 4微信小程序模板 5微信公众号模板 6系统通知 7websocket",name="msg") private String msg; @io.swagger.annotations.ApiModelProperty(value="发送时间",name="sendTime") @@ -53,13 +51,4 @@ public class WxMsgRecord extends BaseMsg { @io.swagger.annotations.ApiModelProperty(value="动态替换内容",name="dynamicContentMap") private Map dynamicContentMap; - public void updateTenantInfo(TenantEntity tenantEntity) { - setTenantId(tenantEntity.getTenantId()); - } - - public TenantEntity getTenantInfo() { - TenantEntity tenantEntity = new TenantEntity(); - tenantEntity.setTenantId(tenantId); - return tenantEntity; - } } From 9af6e71af0a494c6fcd13ecbda730b5382809e3b Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 21 Jul 2021 17:05:42 +0800 Subject: [PATCH 07/14] =?UTF-8?q?bug=E3=80=82=E3=80=82=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/basic/WxBrandController.java | 18 +- .../controller/basic/WxShopController.java | 8 +- .../controller/car/WxCarController.java | 17 +- .../controller/mem/MemCouponController.java | 44 +-- .../msg/WxMsgValidationcodeController.java | 12 +- .../controller/sys/HomeController.java | 6 +- .../iformall/controller/WxInfoController.java | 12 +- .../WxMsgValidationcodeController.java | 6 +- .../iformall/service/impl/PosServiceImpl.java | 358 +++++++++--------- .../schedule/BillNotificationSchedule.java | 12 +- .../iformall/schedule/WxAppVisitSchedule.java | 12 +- .../domain/po/base/BaseTenantEntity.java | 7 +- .../domain/po/base/TenantVEntity.java | 12 +- .../com/iformall/domain/po/msg/BaseMsg.java | 8 +- .../com/iformall/domain/po/msg/WxMsg.java | 8 +- .../impl/MallPermissionServiceImpl.java | 29 +- .../impl/MemCouponFromDspServiceImpl.java | 18 +- .../service/impl/WxBillAllServiceImpl.java | 14 +- .../service/impl/WxBrandServiceImpl.java | 6 +- .../impl/WxCouponOrderServiceImpl.java | 78 ++-- .../service/impl/WxCouponSendServiceImpl.java | 8 +- .../service/impl/WxCouponServiceImpl.java | 6 +- .../impl/WxMallBuildingServiceImpl.java | 61 ++- .../service/impl/WxMallServiceImpl.java | 11 +- .../service/impl/WxMsgServiceImpl.java | 8 +- .../service/impl/WxOrderPressServiceImpl.java | 8 +- .../controller/basic/WxBrandController.java | 17 +- .../controller/basic/WxShopController.java | 8 +- .../msg/WxMsgValidationcodeController.java | 12 +- .../controller/sys/HomeController.java | 6 +- 30 files changed, 398 insertions(+), 432 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/basic/WxBrandController.java b/mallinkAdmin/src/main/java/com/iformall/controller/basic/WxBrandController.java index dc7d3a401..221cc814d 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/basic/WxBrandController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/basic/WxBrandController.java @@ -70,11 +70,11 @@ public class WxBrandController extends BaseController { if(EnumDelFlag.YES.getCode().equals(wxBrand.getIsDel())){ //判断是否解绑商户 - WxMerchant wxMerchant = new WxMerchant() {{ - setIsDel(0); - setBrand(wxBrand.getId()); - updateTenantInfo(wxBrand); - }}; + WxMerchant wxMerchant = new WxMerchant(); + wxMerchant.updateTenantInfo(wxBrand); + wxMerchant.setIsDel(0); + wxMerchant.setBrand(wxBrand.getId()); + List merchantList = wxMerchantService.findList(wxMerchant); if(CollectionUtils.isNotEmpty(merchantList)){ return new ResultData(Result.ERROR, "请先删除已绑定该品牌的商户。"); @@ -116,10 +116,10 @@ public class WxBrandController extends BaseController { @SystemControllerLog(description = "品牌-名称是否存在") public ResultData hasBrand(String name, Long id) { logger.debug("[" + getIpAddr() + "] WxBrandController::hasBrand"); - WxBrand wxBrand = new WxBrand() {{ - setName(name); - updateTenantInfo(getTenantInfo()); - }}; + WxBrand wxBrand = new WxBrand(); + wxBrand.updateTenantInfo(getTenantInfo()); + wxBrand.setName(name); + wxBrand.setId(id); return wxBrandService.hasBrand(wxBrand); } diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/basic/WxShopController.java b/mallinkAdmin/src/main/java/com/iformall/controller/basic/WxShopController.java index be6b6cce8..89b2b434e 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/basic/WxShopController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/basic/WxShopController.java @@ -116,10 +116,10 @@ public class WxShopController extends BaseController { @SystemControllerLog(description = "店铺管理-查询商铺号是否存在") public ResultData hasShopNumber(String shopNumber, Long id, Integer type) { logger.debug("[" + getIpAddr() + "] WxShopController::hasShopNumber"); - WxShop wxShop = new WxShop() {{ - setShopNumber(shopNumber); - setType(type); - }}; + WxShop wxShop = new WxShop(); + wxShop.setShopNumber(shopNumber); + wxShop.setType(type); + wxShop.setId(id); wxShop.updateTenantInfo(getTenantInfo()); return wxShopService.hasShopNumber(wxShop); diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/car/WxCarController.java b/mallinkAdmin/src/main/java/com/iformall/controller/car/WxCarController.java index b76095a95..9d841aa45 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/car/WxCarController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/car/WxCarController.java @@ -236,15 +236,14 @@ public class WxCarController extends BaseController { } // Save to wx_coupon_car - WxCouponCar couponCar = new WxCouponCar() {{ - setId(coupon.getId()); - updateTenantInfo(tenantEntity); - setParkId(park.getId()); - setVendorType(park.getVendorType()); - setVendorParams(coupon.getVendorParams()); - setCreateDate(curDate); - setUpdateDate(curDate); - }}; + WxCouponCar couponCar = new WxCouponCar(); + couponCar.setId(coupon.getId()); + couponCar.updateTenantInfo(tenantEntity); + couponCar.setParkId(park.getId()); + couponCar.setVendorType(park.getVendorType()); + couponCar.setVendorParams(coupon.getVendorParams()); + couponCar.setCreateDate(curDate); + couponCar.setUpdateDate(curDate); WxCouponCar newCouponCar = wxCouponCarService.getById(couponCar.getId()); if (newCouponCar == null) { wxCouponCarService.save(couponCar); diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/mem/MemCouponController.java b/mallinkAdmin/src/main/java/com/iformall/controller/mem/MemCouponController.java index 1206b06c0..61e84e8a5 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/mem/MemCouponController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/mem/MemCouponController.java @@ -109,21 +109,19 @@ public class MemCouponController extends BaseController { if (coupon == null) { return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL.getCode(), "券不存在:" + memCouponFromDsp.getCouponId()); } - MemCouponFromDsp couponQ = new MemCouponFromDsp() {{ - updateTenantInfo(memCouponFromDsp); - setCouponId(memCouponFromDsp.getCouponId()); - setStatus(0); - }}; + MemCouponFromDsp couponQ = new MemCouponFromDsp(); + couponQ.updateTenantInfo(memCouponFromDsp); + couponQ.setCouponId(memCouponFromDsp.getCouponId()); + couponQ.setStatus(0); Integer couponCount = memCouponFromDspService.countByInfo(couponQ); if (coupon.getRemainInventory() <= couponCount) { return new ResultData(ErrorCode.REMAIN_IS_EMPTY); } // 2. 检查此会员是否已超限, 达到券购买限制 - couponQ = new MemCouponFromDsp() {{ - updateTenantInfo(memCouponFromDsp); - setPhone(memCouponFromDsp.getPhone()); - setCouponId(memCouponFromDsp.getCouponId()); - }}; + couponQ = new MemCouponFromDsp(); + couponQ.updateTenantInfo(memCouponFromDsp); + couponQ.setPhone(memCouponFromDsp.getPhone()); + couponQ.setCouponId(memCouponFromDsp.getCouponId()); couponCount = memCouponFromDspService.countByInfo(couponQ); if (coupon.getUseLimitQuantity() <= couponCount) { return new ResultData(ErrorCode.ORDER_IS_LIMITED); @@ -152,21 +150,19 @@ public class MemCouponController extends BaseController { if (coupon == null) { return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL.getCode(), "券不存在:" + memCouponFromDsp.getCouponId()); } - MemCouponFromDsp couponQ = new MemCouponFromDsp() {{ - updateTenantInfo(memCouponFromDsp); - setCouponId(memCouponFromDsp.getCouponId()); - setStatus(0); - }}; + MemCouponFromDsp couponQ = new MemCouponFromDsp(); + couponQ.updateTenantInfo(memCouponFromDsp); + couponQ.setCouponId(memCouponFromDsp.getCouponId()); + couponQ.setStatus(0); Integer couponCount = memCouponFromDspService.countByInfo(couponQ); if (coupon.getRemainInventory() <= couponCount) { return new ResultData(ErrorCode.REMAIN_IS_EMPTY); } // 2. 检查此会员是否已超限, 达到券购买限制 - couponQ = new MemCouponFromDsp() {{ - updateTenantInfo(memCouponFromDsp); - setPhone(memCouponFromDsp.getPhone()); - setCouponId(memCouponFromDsp.getCouponId()); - }}; + couponQ = new MemCouponFromDsp(); + couponQ.updateTenantInfo(memCouponFromDsp); + couponQ.setPhone(memCouponFromDsp.getPhone()); + couponQ.setCouponId(memCouponFromDsp.getCouponId()); couponCount = memCouponFromDspService.countByInfo(couponQ); if (coupon.getUseLimitQuantity() <= couponCount) { return new ResultData(ErrorCode.ORDER_IS_LIMITED); @@ -186,10 +182,10 @@ public class MemCouponController extends BaseController { if (StringUtils.isEmpty(phone)) { return new ResultData(new ArrayList()); } - MemCouponFromDsp memQ = new MemCouponFromDsp() {{ - updateTenantInfo(getTenantInfo()); - setPhone(phone); - }}; + MemCouponFromDsp memQ = new MemCouponFromDsp(); + memQ.updateTenantInfo(getTenantInfo()); + memQ.setPhone(phone); + List memCouponFromDsps = memCouponFromDspService.getList(memQ); return new ResultData(memCouponFromDsps); } diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgValidationcodeController.java b/mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgValidationcodeController.java index ba42f6a3d..52a7eb909 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgValidationcodeController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgValidationcodeController.java @@ -83,10 +83,8 @@ public class WxMsgValidationcodeController extends BaseController { public ResultData sendvalidationcode(String tenantId, String parentTenantId, String phone, Integer type, String appid) { logger.debug("[" + getIpAddr() + "] WxMsgValidationcodeController::sendvalidationcode"); WxMsgValidationcode wxMsgValidationcode = new WxMsgValidationcode(); - wxMsgValidationcode.updateTenantInfo(new TenantEntity(){{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}); + wxMsgValidationcode.setTenantId(tenantId); + wxMsgValidationcode.setParentTenantId(parentTenantId); wxMsgValidationcode.setPhone(phone); wxMsgValidationcode.setType(type); wxMsgValidationcode.setAppid(appid); @@ -104,10 +102,8 @@ public class WxMsgValidationcodeController extends BaseController { public ResultData hasvalidationcode(String tenantId, String parentTenantId, String phone, Integer type, String code, String appid) { logger.debug("[" + getIpAddr() + "] WxMsgValidationcodeController::hasvalidationcode"); WxMsgValidationcode wxMsgValidationcode = new WxMsgValidationcode(); - wxMsgValidationcode.updateTenantInfo(new TenantEntity(){{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}); + wxMsgValidationcode.setTenantId(tenantId); + wxMsgValidationcode.setParentTenantId(parentTenantId); wxMsgValidationcode.setPhone(phone); wxMsgValidationcode.setType(type); wxMsgValidationcode.setCode(code); diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/sys/HomeController.java b/mallinkAdmin/src/main/java/com/iformall/controller/sys/HomeController.java index 786a9fabe..d16230aa4 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/sys/HomeController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/sys/HomeController.java @@ -241,9 +241,9 @@ public class HomeController extends BaseController { logger.error("appid未找到"); return new ResultData(ErrorCode.MALL_INFO_NOT_FOUND); } - TenantEntity tenantEntity = new TenantEntity() {{ - setTenantId(appinfo.getTenantId()); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(appinfo.getTenantId()); + if (StringUtils.isNotBlank(user.getPhone())) { // 领导登录 user = mallUserInfoService.getByPhone(user.getPhone(), tenantEntity); diff --git a/mallinkBApi/src/main/java/com/iformall/controller/WxInfoController.java b/mallinkBApi/src/main/java/com/iformall/controller/WxInfoController.java index 1887d6e50..bd4a819ab 100644 --- a/mallinkBApi/src/main/java/com/iformall/controller/WxInfoController.java +++ b/mallinkBApi/src/main/java/com/iformall/controller/WxInfoController.java @@ -244,9 +244,9 @@ public class WxInfoController extends BaseController { if (wxAppinfo == null) { return new ResultData(Result.ERROR, "APP无权限"); } - TenantEntity tenantEntity = new TenantEntity() {{ - setTenantId(wxAppinfo.getTenantId()); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(wxAppinfo.getTenantId()); + try { Map retMap = getOpenIdInfo(appId, code); String openId = retMap.get("openId"); @@ -362,9 +362,9 @@ public class WxInfoController extends BaseController { WxMaService wxMaService = getWeappService(appId); WxAppinfo wxAppinfo = getAppInfo(appId); - TenantEntity tenantEntity = new TenantEntity() {{ - setTenantId(wxAppinfo.getTenantId()); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(wxAppinfo.getTenantId()); + try { // 解密 WxMaPhoneNumberInfo phoneNoInfo = wxMaService.getUserService().getPhoneNoInfo(session_key, encryptedData, iv); diff --git a/mallinkBApi/src/main/java/com/iformall/controller/WxMsgValidationcodeController.java b/mallinkBApi/src/main/java/com/iformall/controller/WxMsgValidationcodeController.java index 47a915203..fcca737fb 100644 --- a/mallinkBApi/src/main/java/com/iformall/controller/WxMsgValidationcodeController.java +++ b/mallinkBApi/src/main/java/com/iformall/controller/WxMsgValidationcodeController.java @@ -87,10 +87,8 @@ public class WxMsgValidationcodeController extends BaseController { @ApiImplicitParam(name = "appid", value = "appid", dataType = "String", paramType = "query", required = true)}) public ResultData hasvalidationcode(String tenantId, String parentTenantId, String phone, Integer type, String code, String appid) { WxMsgValidationcode wxMsgValidationcode = new WxMsgValidationcode(); - wxMsgValidationcode.updateTenantInfo(new TenantEntity(){{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}); + wxMsgValidationcode.setTenantId(tenantId); + wxMsgValidationcode.setParentTenantId(parentTenantId); wxMsgValidationcode.setPhone(phone); wxMsgValidationcode.setType(EnumMsgModel.VALIDATION_CODE.getCode()); wxMsgValidationcode.setCode(code); diff --git a/mallinkPosApi/src/main/java/com/iformall/service/impl/PosServiceImpl.java b/mallinkPosApi/src/main/java/com/iformall/service/impl/PosServiceImpl.java index 94ff2dead..b762e5ccf 100644 --- a/mallinkPosApi/src/main/java/com/iformall/service/impl/PosServiceImpl.java +++ b/mallinkPosApi/src/main/java/com/iformall/service/impl/PosServiceImpl.java @@ -2089,36 +2089,36 @@ public class PosServiceImpl implements PosService { WxMerchantBUser merchantBUser, WxOrder order, Long memId, Long posPayOrderId, Integer neuPaymentAmount, Date neuPosPayOrderTime) { - WxPayOrder payOrder = new WxPayOrder() {{ - Date curDate = new Date(); - setTenantId(merchantBUser.getTenantId()); - final IdWorker idWorker = IdWorker.get(); - Long id = idWorker.nextId(); - setId(id); - updateTenantInfo(merchantBUser); - setCUserId(memId); - setOrderId(order.getId()); - setCreateTime(curDate); - setUpdateTime(curDate); - setPayTimeStart(curDate); - setPayTimeEnd(curDate); - setPayOrderNo(String.valueOf(id)); - setPayAmount(neuPaymentAmount); - setPayVendor(EnumPayWay.PAY_WAY_POS_NEU.getCode()); - setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); - setShare(EnumPayShare.NO.getCode()); - setPosPayOrderId(posPayOrderId); - setPosPayOrderTime(neuPosPayOrderTime.getTime()); - /// TODO - /// setPosPaymentType(EnumNeuPosPamentType.MEM_DISCOUNT.getCode()); - setPosPayDes("POS会员折扣支付"); - }}; + Date curDate = new Date(); + final IdWorker idWorker = IdWorker.get(); + + WxPayOrder payOrder = new WxPayOrder(); + payOrder.setId(idWorker.nextId()); + payOrder.updateTenantInfo(merchantBUser); + payOrder.setCUserId(memId); + payOrder.setOrderId(order.getId()); + payOrder.setCreateTime(curDate); + payOrder.setUpdateTime(curDate); + payOrder.setPayTimeStart(curDate); + payOrder.setPayTimeEnd(curDate); + payOrder.setPayOrderNo(String.valueOf(payOrder.getId())); + payOrder.setPayAmount(neuPaymentAmount); + payOrder.setPayVendor(EnumPayWay.PAY_WAY_POS_NEU.getCode()); + payOrder.setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); + payOrder.setShare(EnumPayShare.NO.getCode()); + payOrder.setPosPayOrderId(posPayOrderId); + payOrder.setPosPayOrderTime(neuPosPayOrderTime.getTime()); + /// TODO + /// setPosPaymentType(EnumNeuPosPamentType.MEM_DISCOUNT.getCode()); + payOrder.setPosPayDes("POS会员折扣支付"); + int sqlRow = payOrderMapper.insert(payOrder); if (sqlRow != 1) { logger.error("pay order insert error: " + payOrder.toString()); throw new MallinkException(ErrorCode.DB_FAIL); } return payOrder; + } /** @@ -2143,30 +2143,28 @@ public class PosServiceImpl implements PosService { if (null == payOrderList || payOrderList.size()<=0) { final IdWorker idWorker = IdWorker.get(); Long payOrderId = idWorker.nextId(); - payOrder = new WxPayOrder() {{ - Date curDate = new Date(); - setId(payOrderId); - setTenantId(merchantBUser.getTenantId()); - updateTenantInfo(merchantBUser); - setCUserId(memId); - setBUserId(merchantBUser.getId()); - setOrderId(order.getId()); - setCreateTime(curDate); - setUpdateTime(curDate); - setPayTimeStart(curDate); - setPayTimeEnd(curDate); - setPayOrderNo(String.valueOf(payOrderId)); - setPayAmount(neuPaymentAmount); - setPayVendor(EnumPayWay.PAY_WAY_POS_NEU.getCode()); - setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); - setShare(EnumPayShare.NO.getCode()); - setPayFrom(EnumPayFrom.POS.getCode()); - setPosPayOrderId(posPayOrderId); - setPosPayOrderTime(neuPosPayOrderTime.getTime()); - setPosPaymentType(EnumNeuPosPamentType.MEM_COUPON.getCode()); - setPosPayDes("POS优惠券支付"); - setPosPayOrderNo(posPayOrderNo); - }}; + payOrder = new WxPayOrder(); + Date curDate = new Date(); + payOrder.setId(payOrderId); + payOrder.updateTenantInfo(merchantBUser); + payOrder.setCUserId(memId); + payOrder.setBUserId(merchantBUser.getId()); + payOrder.setOrderId(order.getId()); + payOrder.setCreateTime(curDate); + payOrder.setUpdateTime(curDate); + payOrder.setPayTimeStart(curDate); + payOrder.setPayTimeEnd(curDate); + payOrder.setPayOrderNo(String.valueOf(payOrderId)); + payOrder.setPayAmount(neuPaymentAmount); + payOrder.setPayVendor(EnumPayWay.PAY_WAY_POS_NEU.getCode()); + payOrder.setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); + payOrder.setShare(EnumPayShare.NO.getCode()); + payOrder.setPayFrom(EnumPayFrom.POS.getCode()); + payOrder.setPosPayOrderId(posPayOrderId); + payOrder.setPosPayOrderTime(neuPosPayOrderTime.getTime()); + payOrder.setPosPaymentType(EnumNeuPosPamentType.MEM_COUPON.getCode()); + payOrder.setPosPayDes("POS优惠券支付"); + payOrder.setPosPayOrderNo(posPayOrderNo); int sqlRow = payOrderMapper.insert(payOrder); if (sqlRow != 1) { logger.error("pay order insert error: " + payOrder.toString()); @@ -2240,31 +2238,29 @@ public class PosServiceImpl implements PosService { if (null == payOrderList || payOrderList.size()<=0) { final IdWorker idWorker = IdWorker.get(); Long payOrderId = idWorker.nextId(); - payOrder = new WxPayOrder() {{ - Date curDate = new Date(); - setId(payOrderId); - setTenantId(buUser.getTenantId()); - updateTenantInfo(buUser); - setCUserId(memId); - setBUserId(buUser.getId()); - setOrderId(order.getId()); - setCreateTime(curDate); - setUpdateTime(curDate); - setPayTimeStart(curDate); - setPayTimeEnd(curDate); - setPayOrderNo(String.valueOf(payOrderId)); - setPayAmount(neuPaymentAmount); - setPayVendor(EnumPayWay.PAY_WAY_POS_NEU.getCode()); - setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); - setShare(EnumPayShare.NO.getCode()); - setPayFrom(EnumPayFrom.POS.getCode()); - setPosPayOrderId(posPayOrderId); - setPosPayOrderTime(neuPosPayOrderTime.getTime()); - setPosPaymentType(EnumNeuPosPamentType.MEM_CARD.getCode()); - setPosPayDes("POS富茂卡支付"); - setPosPayOrderNo(posPayOrderNo); - - }}; + payOrder = new WxPayOrder(); + Date curDate = new Date(); + payOrder.setId(payOrderId); + payOrder.setTenantId(buUser.getTenantId()); + payOrder.updateTenantInfo(buUser); + payOrder.setCUserId(memId); + payOrder.setBUserId(buUser.getId()); + payOrder.setOrderId(order.getId()); + payOrder.setCreateTime(curDate); + payOrder.setUpdateTime(curDate); + payOrder.setPayTimeStart(curDate); + payOrder.setPayTimeEnd(curDate); + payOrder.setPayOrderNo(String.valueOf(payOrderId)); + payOrder.setPayAmount(neuPaymentAmount); + payOrder.setPayVendor(EnumPayWay.PAY_WAY_POS_NEU.getCode()); + payOrder.setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); + payOrder.setShare(EnumPayShare.NO.getCode()); + payOrder.setPayFrom(EnumPayFrom.POS.getCode()); + payOrder.setPosPayOrderId(posPayOrderId); + payOrder.setPosPayOrderTime(neuPosPayOrderTime.getTime()); + payOrder.setPosPaymentType(EnumNeuPosPamentType.MEM_CARD.getCode()); + payOrder.setPosPayDes("POS富茂卡支付"); + payOrder.setPosPayOrderNo(posPayOrderNo); int sqlRow = payOrderMapper.insert(payOrder); if (sqlRow != 1) { logger.error("pay order insert error: " + payOrder.toString()); @@ -2317,30 +2313,29 @@ public class PosServiceImpl implements PosService { if (null == payOrderList || payOrderList.size()<=0) { final IdWorker idWorker = IdWorker.get(); Long payOrderId = idWorker.nextId(); - payOrder = new WxPayOrder() {{ - Date curDate = new Date(); - setId(payOrderId); - setTenantId(buUser.getTenantId()); - updateTenantInfo(buUser); - setCUserId(memId); - setOrderId(order.getId()); - setCreateTime(curDate); - setUpdateTime(curDate); - setPayTimeStart(curDate); - setPayTimeEnd(curDate); - setPayOrderNo(String.valueOf(payOrderId)); - setPayAmount(neuPaymentAmount); - setPayVendor(EnumPayWay.PAY_WAY_POS_NEU.getCode()); - setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); - setShare(EnumPayShare.NO.getCode()); - setPayFrom(EnumPayFrom.POS.getCode()); - setPosPayOrderId(neuPayOrderId); - setPosPayOrderTime(neuPosPayOrderTime.getTime()); - setPosPaymentType(neuPayOrderType); - setPosPayDes("POS支付"); - setPosPayOrderNo(neuPayThirdNo); - - }}; + payOrder = new WxPayOrder(); + Date curDate = new Date(); + payOrder.setId(payOrderId); + payOrder.setTenantId(buUser.getTenantId()); + payOrder.updateTenantInfo(buUser); + payOrder.setCUserId(memId); + payOrder.setOrderId(order.getId()); + payOrder.setCreateTime(curDate); + payOrder.setUpdateTime(curDate); + payOrder.setPayTimeStart(curDate); + payOrder.setPayTimeEnd(curDate); + payOrder.setPayOrderNo(String.valueOf(payOrderId)); + payOrder.setPayAmount(neuPaymentAmount); + payOrder.setPayVendor(EnumPayWay.PAY_WAY_POS_NEU.getCode()); + payOrder.setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); + payOrder.setShare(EnumPayShare.NO.getCode()); + payOrder.setPayFrom(EnumPayFrom.POS.getCode()); + payOrder.setPosPayOrderId(neuPayOrderId); + payOrder.setPosPayOrderTime(neuPosPayOrderTime.getTime()); + payOrder.setPosPaymentType(neuPayOrderType); + payOrder.setPosPayDes("POS支付"); + payOrder.setPosPayOrderNo(neuPayThirdNo); + int sqlRow = payOrderMapper.insert(payOrder); if (sqlRow != 1) { logger.error("pay order insert error: " + payOrder.toString()); @@ -2386,13 +2381,12 @@ public class PosServiceImpl implements PosService { String neuRefundThirdNo) { // 1. pay order // 查找支付订单 - WxPayOrder payOrderQ = new WxPayOrder() {{ - updateTenantInfo(refundOrder); - setCUserId(refundOrder.getCUserId()); - setOrderId(refundOrder.getId()); - setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); - setPosPayOrderId(posPayOrderId); - }}; + WxPayOrder payOrderQ = new WxPayOrder(); + payOrderQ.updateTenantInfo(refundOrder); + payOrderQ.setCUserId(refundOrder.getCUserId()); + payOrderQ.setOrderId(refundOrder.getId()); + payOrderQ.setPayOrderStatus(EnumPayStatus.PAY_STATUS_SUCCESS.getCode()); + payOrderQ.setPosPayOrderId(posPayOrderId); try { payOrderQ = payOrderMapper.selectOne(new QueryWrapper<>(payOrderQ)); @@ -2406,31 +2400,30 @@ public class PosServiceImpl implements PosService { // 2. insert into refund order final IdWorker idWorker = IdWorker.get(); Long refundId = idWorker.nextId(); - WxRefundOrder refundPayOrder = new WxRefundOrder() {{ - Date curDate = new Date(); - setId(refundId); - setRefundId(String.valueOf(refundId)); - setTenantId(buUser.getTenantId()); - updateTenantInfo(buUser); - setCUserId(memId); - setOrderId(refundOrder.getId()); - setCreateTime(curDate); - setUpdateTime(curDate); - setRefundTimeStart(curDate); - setRefundTimeEnd(curDate); - setTotalFee(posRefundAmount); - setRefundFee(posRefundAmount); - setRefundFrom(EnumPayFrom.POS.getCode()); - setRefundOrderStatus(EnumRefundStatus.REFUND_SUCCESS.getCode()); - setPosPayOrderId(posPayOrderId); - setPosRefundOrderId(posRefundOrderId); - setPosRefundOrderTime(posRefundOrderTime.getTime()); - setPosRefundOrderStatus(posRefundOrderStatus); - setPosRefundType(posRefundType); - setPosRefundDes("POS退款"); - setPosRefundOrderNo(neuRefundThirdNo); - - }}; + WxRefundOrder refundPayOrder = new WxRefundOrder(); + + Date curDate = new Date(); + refundPayOrder.setId(refundId); + refundPayOrder.setRefundId(String.valueOf(refundId)); + refundPayOrder.setTenantId(buUser.getTenantId()); + refundPayOrder.updateTenantInfo(buUser); + refundPayOrder.setCUserId(memId); + refundPayOrder.setOrderId(refundOrder.getId()); + refundPayOrder.setCreateTime(curDate); + refundPayOrder.setUpdateTime(curDate); + refundPayOrder.setRefundTimeStart(curDate); + refundPayOrder.setRefundTimeEnd(curDate); + refundPayOrder.setTotalFee(posRefundAmount); + refundPayOrder.setRefundFee(posRefundAmount); + refundPayOrder.setRefundFrom(EnumPayFrom.POS.getCode()); + refundPayOrder.setRefundOrderStatus(EnumRefundStatus.REFUND_SUCCESS.getCode()); + refundPayOrder.setPosPayOrderId(posPayOrderId); + refundPayOrder.setPosRefundOrderId(posRefundOrderId); + refundPayOrder.setPosRefundOrderTime(posRefundOrderTime.getTime()); + refundPayOrder.setPosRefundOrderStatus(posRefundOrderStatus); + refundPayOrder.setPosRefundType(posRefundType); + refundPayOrder.setPosRefundDes("POS退款"); + refundPayOrder.setPosRefundOrderNo(neuRefundThirdNo); refundPayOrder.setPayOrderNo(String.valueOf(payOrderQ.getId())); int sqlRow = refundOrderMapper.insert(refundPayOrder); @@ -2457,12 +2450,12 @@ public class PosServiceImpl implements PosService { final Long posOrderId, final Integer posAmount, final Date posOrderTime, final String orderCreateSn ) { boolean isExist = true; - WxOrder orderQ = new WxOrder() {{ - setType(EnumOrderType.POSPAY.getCode()); - setCUserId(memId); - setPaymentType(EnumPayType.PAY_PAYMENT.getCode()); - setPosOrderId(posOrderId); - }}; + WxOrder orderQ = new WxOrder(); + orderQ.setType(EnumOrderType.POSPAY.getCode()); + orderQ.setCUserId(memId); + orderQ.setPaymentType(EnumPayType.PAY_PAYMENT.getCode()); + orderQ.setPosOrderId(posOrderId); + try { orderQ = orderMapper.selectOne(new QueryWrapper<>(orderQ)); } catch (Exception e) { @@ -2475,25 +2468,25 @@ public class PosServiceImpl implements PosService { } final IdWorker idWorker = IdWorker.get(); Long orderId = idWorker.nextId(); - WxOrder order = new WxOrder() {{ - Date curr = new Date(); - String bodyStr = "POS支付, 金额: " + posAmount; - setId(orderId); - updateTenantInfo(merchantBUser); - setOrderNumber(orderId); - setType(EnumOrderType.POSPAY.getCode()); - setProductId(merchantBUser.getId()); - setCUserId(memId); - setPaymentType(EnumPayType.PAY_PAYMENT.getCode()); - setPayment(posAmount); - setOrderStatus(EnumOrderStatus.ORDER_STATUS_PAYMENT_SUCCESS.getCode()); - setDetail(bodyStr); - setCreateDate(curr); - setUpdateDate(curr); - setPosOrderId(posOrderId); - setPosOrderCreateTime(posOrderTime.getTime()); - setPosOrderCreateSn(orderCreateSn); - }}; + WxOrder order = new WxOrder(); + + Date curr = new Date(); + String bodyStr = "POS支付, 金额: " + posAmount; + order.setId(orderId); + order.updateTenantInfo(merchantBUser); + order.setOrderNumber(orderId); + order.setType(EnumOrderType.POSPAY.getCode()); + order.setProductId(merchantBUser.getId()); + order.setCUserId(memId); + order.setPaymentType(EnumPayType.PAY_PAYMENT.getCode()); + order.setPayment(posAmount); + order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_PAYMENT_SUCCESS.getCode()); + order.setDetail(bodyStr); + order.setCreateDate(curr); + order.setUpdateDate(curr); + order.setPosOrderId(posOrderId); + order.setPosOrderCreateTime(posOrderTime.getTime()); + order.setPosOrderCreateSn(orderCreateSn); try { orderMapper.insert(order); @@ -2519,12 +2512,12 @@ public class PosServiceImpl implements PosService { final Long posOrderId, final Integer orderAmount, final Date posOrderTime, final String orderCreateSn ) { // 1. 查找正向订单 - WxOrder orderQ = new WxOrder() {{ - setType(EnumOrderType.POSPAY.getCode()); - setCUserId(memId); - setPaymentType(EnumPayType.PAY_PAYMENT.getCode()); - setPosOrderId(posOrderId); - }}; + WxOrder orderQ = new WxOrder(); + orderQ.setType(EnumOrderType.POSPAY.getCode()); + orderQ.setCUserId(memId); + orderQ.setPaymentType(EnumPayType.PAY_PAYMENT.getCode()); + orderQ.setPosOrderId(posOrderId); + try { orderQ = orderMapper.selectOne(new QueryWrapper<>(orderQ)); } catch (Exception e) { @@ -2536,11 +2529,10 @@ public class PosServiceImpl implements PosService { } // 2. 查找是否有退款订单 - WxOrder refundQ = new WxOrder() {{ - setType(EnumOrderType.POSPAY.getCode()); - setCUserId(memId); - setPosOrderId(posOrderId); - }}; + WxOrder refundQ = new WxOrder(); + refundQ.setType(EnumOrderType.POSPAY.getCode()); + refundQ.setCUserId(memId); + refundQ.setPosOrderId(posOrderId); refundQ.setOrderNumber(orderQ.getOrderNumber()); try { refundQ = orderMapper.selectOne(new QueryWrapper<>(refundQ)); @@ -2555,24 +2547,24 @@ public class PosServiceImpl implements PosService { // 3. 创建退款订单 final IdWorker idWorker = IdWorker.get(); Long orderId = idWorker.nextId(); - WxOrder order = new WxOrder() {{ - Date curr = new Date(); - String bodyStr = "POS退款, 金额: " + orderAmount; - setId(orderId); - updateTenantInfo(buUser); - setType(EnumOrderType.POSPAY.getCode()); - setProductId(buUser.getId()); - setCUserId(memId); - setPaymentType(EnumPayType.PAY_POS_REFUND.getCode()); - setPayment(orderAmount); - setOrderStatus(EnumOrderStatus.ORDER_STATUS_REFUND_SUCCESS.getCode()); - setDetail(bodyStr); - setCreateDate(curr); - setUpdateDate(curr); - setPosOrderId(posOrderId); - setPosOrderCreateTime(posOrderTime.getTime()); - setPosOrderCreateSn(orderCreateSn); - }}; + WxOrder order = new WxOrder(); + + Date curr = new Date(); + String bodyStr = "POS退款, 金额: " + orderAmount; + order.setId(orderId); + order.updateTenantInfo(buUser); + order.setType(EnumOrderType.POSPAY.getCode()); + order.setProductId(buUser.getId()); + order.setCUserId(memId); + order.setPaymentType(EnumPayType.PAY_POS_REFUND.getCode()); + order.setPayment(orderAmount); + order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_REFUND_SUCCESS.getCode()); + order.setDetail(bodyStr); + order.setCreateDate(curr); + order.setUpdateDate(curr); + order.setPosOrderId(posOrderId); + order.setPosOrderCreateTime(posOrderTime.getTime()); + order.setPosOrderCreateSn(orderCreateSn); order.setOrderNumber(orderQ.getOrderNumber()); try { diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/BillNotificationSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/BillNotificationSchedule.java index 777c27724..a95d83c10 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/BillNotificationSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/BillNotificationSchedule.java @@ -68,10 +68,8 @@ public class BillNotificationSchedule { wxMsgRecord.setMsgType(EnumMsgRecordType.SMS.getCode()); wxMsgRecord.setModelType(EnumMsgModel.BILL_OWE.getCode()); wxMsgRecord.setReceiver(phone); - wxMsgRecord.updateTenantInfo(new TenantEntity(){{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}); + wxMsgRecord.setTenantId(tenantId); + wxMsgRecord.setParentTenantId(parentTenantId); Map map = new HashedMap(); map.put("price", price.toString()); map.put("app", appname); @@ -101,10 +99,8 @@ public class BillNotificationSchedule { wxMsgRecord.setMsgType(EnumMsgRecordType.SMS.getCode()); wxMsgRecord.setModelType(EnumMsgModel.BILL_WAIT_PAY.getCode()); wxMsgRecord.setReceiver(phone); - wxMsgRecord.updateTenantInfo(new TenantEntity(){{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}); + wxMsgRecord.setTenantId(tenantId); + wxMsgRecord.setParentTenantId(parentTenantId); Map map = new HashedMap(); map.put("price", price.toString()); map.put("app", appname); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WxAppVisitSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WxAppVisitSchedule.java index 51fae890e..f04a5e328 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/WxAppVisitSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WxAppVisitSchedule.java @@ -57,9 +57,9 @@ public class WxAppVisitSchedule { if(StringUtils.isBlank(app.getAppId())||StringUtils.isBlank(app.getSecret())||StringUtils.isBlank(app.getTenantId())) { continue; } - TenantEntity TenantEntity = new TenantEntity(){{ - setTenantId(app.getTenantId()); - }}; + TenantEntity TenantEntity = new TenantEntity(); + TenantEntity.setTenantId(app.getTenantId()); + WxMall byTenantInfo = wxMallService.getByTenantInfo(TenantEntity); if(byTenantInfo != null && StringUtils.isNotBlank(byTenantInfo.getParentTenantId())){ app.setParentTenantId(byTenantInfo.getParentTenantId()); @@ -89,9 +89,9 @@ public class WxAppVisitSchedule { if(StringUtils.isBlank(appinfo.getAppId())||StringUtils.isBlank(appinfo.getSecret())||StringUtils.isBlank(appinfo.getTenantId())) { continue; } - TenantEntity TenantEntity = new TenantEntity(){{ - setTenantId(appinfo.getTenantId()); - }}; + TenantEntity TenantEntity = new TenantEntity(); + TenantEntity.setTenantId(appinfo.getTenantId()); + WxMall byTenantInfo = wxMallService.getByTenantInfo(TenantEntity); if(byTenantInfo != null && StringUtils.isNotBlank(byTenantInfo.getParentTenantId())){ appinfo.setParentTenantId(byTenantInfo.getParentTenantId()); diff --git a/mallinkService/src/main/java/com/iformall/domain/po/base/BaseTenantEntity.java b/mallinkService/src/main/java/com/iformall/domain/po/base/BaseTenantEntity.java index 4b8d6120b..9fd1d9e59 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/base/BaseTenantEntity.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/base/BaseTenantEntity.java @@ -66,9 +66,10 @@ public class BaseTenantEntity extends BaseEntity { } public TenantEntity getTenantInfo() { - TenantEntity tenantEntity = new TenantEntity(); - tenantEntity.setTenantId(tenantId); - return tenantEntity; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(tenantId); + tenantEntity.setParentTenantId(parentTenantId); + return tenantEntity; } public String getTenantId() { diff --git a/mallinkService/src/main/java/com/iformall/domain/po/base/TenantVEntity.java b/mallinkService/src/main/java/com/iformall/domain/po/base/TenantVEntity.java index 6f4f357b4..47ee07caf 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/base/TenantVEntity.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/base/TenantVEntity.java @@ -42,12 +42,12 @@ public class TenantVEntity extends BaseEntity { } public TenantEntity getTenantInfo() { - return new TenantEntity() {{ - setTenantId(tenantId); - if (StringUtils.isNotBlank(parentTenantId)) { - setParentTenantId(parentTenantId); - } - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(tenantId); + if (StringUtils.isNotBlank(parentTenantId)) { + tenantEntity.setParentTenantId(parentTenantId); + } + return tenantEntity; } public String getTenantId() { diff --git a/mallinkService/src/main/java/com/iformall/domain/po/msg/BaseMsg.java b/mallinkService/src/main/java/com/iformall/domain/po/msg/BaseMsg.java index cc2dec90f..a1f87156f 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/msg/BaseMsg.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/msg/BaseMsg.java @@ -67,10 +67,10 @@ public class BaseMsg extends BaseEntity { } public TenantEntity getTenantInfo() { - return new TenantEntity() {{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(tenantId); + tenantEntity.setParentTenantId(parentTenantId); + return tenantEntity; } public String getFinalTenantId() { diff --git a/mallinkService/src/main/java/com/iformall/domain/po/msg/WxMsg.java b/mallinkService/src/main/java/com/iformall/domain/po/msg/WxMsg.java index 1043943e8..14518a7a4 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/msg/WxMsg.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/msg/WxMsg.java @@ -92,9 +92,9 @@ public class WxMsg extends BaseMsg { } public TenantEntity getTenantInfo() { - return new TenantEntity() {{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(tenantId); + tenantEntity.setParentTenantId(parentTenantId); + return tenantEntity; } } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/MallPermissionServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/MallPermissionServiceImpl.java index a2b40e3ca..dac7c2105 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/MallPermissionServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/MallPermissionServiceImpl.java @@ -77,14 +77,13 @@ public class MallPermissionServiceImpl implements MallPermissionService { public List queryAdminMenuList(MallUserInfo userInfo) { if(userInfo.fmSuperAdmin() || userInfo.getIsAdmin().equals(EnumUserAdmin.ADMIN.getCode())) { - WxMall q = new WxMall() {{ - if (StringUtils.isBlank(userInfo.getParentTenantId())) { - setTenantId(userInfo.getTenantId()); - } else { - setTenantId(userInfo.getTenantId()); - setParentTenantId(userInfo.getParentTenantId()); - } - }}; + WxMall q = new WxMall(); + if (StringUtils.isBlank(userInfo.getParentTenantId())) { + q.setTenantId(userInfo.getTenantId()); + } else { + q.setTenantId(userInfo.getTenantId()); + q.setParentTenantId(userInfo.getParentTenantId()); + } String menus = wxMallMapper.queryMenusByTenantInfo(q); JSONArray menuIdList = JSON.parseArray(menus); return menuIdList.toJavaList(Long.class); @@ -122,9 +121,9 @@ public class MallPermissionServiceImpl implements MallPermissionService { } else if (userInfo.checkGroupAdmin()) { // 集团超管 // if (boolNav) { - WxMall q = new WxMall() {{ - setTenantId(userInfo.getTenantId()); - }}; + WxMall q = new WxMall(); + q.setTenantId(userInfo.getTenantId()); + String menus = wxMallMapper.queryMenusByTenantInfo(q); JSONArray menuIdList = JSON.parseArray(menus); return getAllMenuListByParentId(0L, menuIdList.toJavaList(Long.class), boolNav); @@ -134,10 +133,10 @@ public class MallPermissionServiceImpl implements MallPermissionService { // } } else if (userInfo.checkAdmin()) { // 租户超管 - WxMall q = new WxMall() {{ - setTenantId(userInfo.getTenantId()); - setParentTenantId(userInfo.getParentTenantId()); - }}; + WxMall q = new WxMall(); + q.setTenantId(userInfo.getTenantId()); + q.setParentTenantId(userInfo.getParentTenantId()); + String menus = wxMallMapper.queryMenusByTenantInfo(q); JSONArray menuIdList = JSON.parseArray(menus); if (null != menuIdList) { diff --git a/mallinkService/src/main/java/com/iformall/service/impl/MemCouponFromDspServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/MemCouponFromDspServiceImpl.java index 2d8290b75..f8f8c6db3 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/MemCouponFromDspServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/MemCouponFromDspServiceImpl.java @@ -95,11 +95,11 @@ public class MemCouponFromDspServiceImpl implements MemCouponFromDspService { user.setOperatorType(EnumUserType.MALLUSER.getCode()); user.setOperatorId(user.getId()); // 手机是否有未注的券 - MemCouponFromDsp memQ = new MemCouponFromDsp() {{ - updateTenantInfo(record); - setPhone(record.getPhone()); - setStatus(EnumCouponDspStatus.RECEIVED.getCode()); - }}; + MemCouponFromDsp memQ = new MemCouponFromDsp(); + memQ.updateTenantInfo(record); + memQ.setPhone(record.getPhone()); + memQ.setStatus(EnumCouponDspStatus.RECEIVED.getCode()); + List couponFromDsps = memCouponFromDspMapper.findList(memQ); for (MemCouponFromDsp memCouponFromDsp: couponFromDsps) { // 注入券码, 无论此券是有价还是免费 @@ -128,10 +128,10 @@ public class MemCouponFromDspServiceImpl implements MemCouponFromDspService { @Override public void couponOrderFromDsp(TenantEntity tenantEntity, String phone) { - List couponFromDsps = getList( new MemCouponFromDsp() {{ - updateTenantInfo(tenantEntity); - setPhone(phone); - }}); + MemCouponFromDsp mcfdQ= new MemCouponFromDsp(); + mcfdQ.updateTenantInfo(tenantEntity); + mcfdQ.setPhone(phone); + List couponFromDsps = getList(mcfdQ); for(MemCouponFromDsp memCouponFromDsp: couponFromDsps ){ couponOrder(memCouponFromDsp); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java index 7bdf1e13d..22e1ae0d5 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java @@ -1646,10 +1646,9 @@ public class WxBillAllServiceImpl implements WxBillAllService { String manager = (String) mapList.get(0).get("manager"); String managerPhone = (String) mapList.get(0).get("managerPhone"); - TenantEntity tenantEntity = new TenantEntity() {{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(tenantId); + tenantEntity.setParentTenantId(parentTenantId); String billListStr = ""; BigDecimal sumNeedPay = new BigDecimal(0); @@ -1707,10 +1706,9 @@ public class WxBillAllServiceImpl implements WxBillAllService { String managerPhone = (String) mapList.get(0).get("managerPhone"); Long expiredDay = (Long) mapList.get(0).get("expiredDay"); - TenantEntity tenantEntity = new TenantEntity() {{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(tenantId); + tenantEntity.setParentTenantId(parentTenantId); String billListStr = ""; BigDecimal sumNeedPay = new BigDecimal(0); diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxBrandServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxBrandServiceImpl.java index 9e9665c7f..970ec80f4 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxBrandServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxBrandServiceImpl.java @@ -99,9 +99,9 @@ public class WxBrandServiceImpl implements WxBrandService { @Override public List> queryBrand(TenantEntity tenantEntity) { - WxBrand wxBrand = new WxBrand() {{ - updateTenantInfo(tenantEntity); - }}; + WxBrand wxBrand = new WxBrand(); + wxBrand.updateTenantInfo(tenantEntity); + return wxBrandMapper.queryBrandByTenant(wxBrand); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java index ec39ec985..d6afe85bc 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java @@ -816,10 +816,11 @@ public class WxCouponOrderServiceImpl implements WxCouponOrderService { // 4. get user info WxCUser user = null; - List list = wxCUserMapper.findList(new WxCUser(){{ - updateTenantInfo(bUser); - setUserId(couponOrder.getCUserId()); - }}); + + WxCUser wcuQ = new WxCUser(); + wcuQ.updateTenantInfo(bUser); + wcuQ.setUserId(couponOrder.getCUserId()); + List list = wxCUserMapper.findList(wcuQ); if(list != null && list.size() > 0){ user = list.get(0); } @@ -1447,45 +1448,44 @@ public class WxCouponOrderServiceImpl implements WxCouponOrderService { // 添加payOrder final IdWorker idWorker = IdWorker.get(); Long payOrderId = idWorker.nextId(); - WxPayOrder payOrder = new WxPayOrder() {{ - Date curDate = new Date(); - setId(payOrderId); - updateTenantInfo(microOrder); - setCUserId(microOrder.getCUserId()); - setOrderId(microOrder.getId()); - setCreateTime(curDate); - setUpdateTime(curDate); - setPayTimeStart(curDate); - setPayTimeEnd(curDate); - setPayOrderNo(String.valueOf(payOrderId)); - setIp(ipstr); - setAuthCode(authCode); - Integer payAmount = microOrder.getPayment() - wxCoupon.getPrice(); - setPayAmount(payAmount); + WxPayOrder payOrder = new WxPayOrder(); + Date curDate = new Date(); + payOrder.setId(payOrderId); + payOrder.updateTenantInfo(microOrder); + payOrder.setCUserId(microOrder.getCUserId()); + payOrder.setOrderId(microOrder.getId()); + payOrder.setCreateTime(curDate); + payOrder.setUpdateTime(curDate); + payOrder.setPayTimeStart(curDate); + payOrder.setPayTimeEnd(curDate); + payOrder.setPayOrderNo(String.valueOf(payOrderId)); + payOrder.setIp(ipstr); + payOrder.setAuthCode(authCode); + Integer payAmount = microOrder.getPayment() - wxCoupon.getPrice(); + payOrder.setPayAmount(payAmount); // if (microOrder.getPayment() > wxCoupon.getPrice()) { -// setPayAmount(wxCoupon.getPrice()); +// payOrder.setPayAmount(wxCoupon.getPrice()); // } else { -// setPayAmount(microOrder.getPayment()); +// payOrder.setPayAmount(microOrder.getPayment()); // } - setPayVendor(payWay.getCode()); - setPayOrderStatus(EnumPayStatus.PAY_STATUS_WAIT.getCode()); - setShare(shareCode); - if (shareCode.intValue() == EnumPayShare.YES.getCode().intValue()) { - // 分账金额 - int iChargeFee = PayUtils.getPayRate(payAmount, payAccount.getRate(), false); - Integer share_amount = payAmount - iChargeFee; - setShareAmount(share_amount); - if(payAccount.getRealRate() != null) { - int iRealChargeFee = PayUtils.getPayRate(payAmount, payAccount.getRealRate(), true); - setRateAmount(iRealChargeFee); - } - if (share_amount <= 0) { - setShare(EnumPayShare.NO.getCode()); - } + payOrder.setPayVendor(payWay.getCode()); + payOrder.setPayOrderStatus(EnumPayStatus.PAY_STATUS_WAIT.getCode()); + payOrder.setShare(shareCode); + if (shareCode.intValue() == EnumPayShare.YES.getCode().intValue()) { + // 分账金额 + int iChargeFee = PayUtils.getPayRate(payAmount, payAccount.getRate(), false); + Integer share_amount = payAmount - iChargeFee; + payOrder.setShareAmount(share_amount); + if(payAccount.getRealRate() != null) { + int iRealChargeFee = PayUtils.getPayRate(payAmount, payAccount.getRealRate(), true); + payOrder.setRateAmount(iRealChargeFee); + } + if (share_amount <= 0) { + payOrder.setShare(EnumPayShare.NO.getCode()); } - setPayFrom(EnumPayFrom.INSIDE_B.getCode()); - setPosPayOrderId(couponOrder.getId()); - }}; + } + payOrder.setPayFrom(EnumPayFrom.INSIDE_B.getCode()); + payOrder.setPosPayOrderId(couponOrder.getId()); try { payOrderMapper.insert(payOrder); diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java index b59bdab2d..b32d15a3f 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java @@ -440,10 +440,10 @@ public class WxCouponSendServiceImpl implements WxCouponSendService { private void sendMsgForSendCoupon(TenantEntity tenantEntity, WxCouponSend send, WxCouponOrder couponOrder, WxCUserBasicInfo user) { - List list = wxCUserMapper.findList(new WxCUser(){{ - updateTenantInfo(tenantEntity); - setUserId(couponOrder.getCUserId()); - }}); + WxCUser wcuQ = new WxCUser(); + wcuQ.updateTenantInfo(tenantEntity); + wcuQ.setUserId(couponOrder.getCUserId()); + List list = wxCUserMapper.findList(wcuQ); if(list != null && list.size() > 0){ for (WxCUser cuser:list) { //发订阅消息 diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java index 9bfaa047f..ba0023274 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java @@ -332,9 +332,9 @@ public class WxCouponServiceImpl implements WxCouponService { //有价券判断商户是否配置了分账账号 if (record.getSalePrice() != null && record.getSalePrice() > 0) { boolean share = false; - WxPayAccount payQ = new WxPayAccount() {{ - updateTenantInfo(record); - }}; + WxPayAccount payQ = new WxPayAccount(); + payQ.updateTenantInfo(record); + try { WxPayAccount payAccount = payAccountMapper.selectOne(new QueryWrapper<>(payQ)); if (payAccount != null) { diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMallBuildingServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMallBuildingServiceImpl.java index 0bf7f9a15..40616f8d4 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMallBuildingServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMallBuildingServiceImpl.java @@ -172,23 +172,22 @@ public class WxMallBuildingServiceImpl implements WxMallBuildingService { String [] floors = record.getFloors().split(","); // 楼座 - WxMallBuilding mallBuilding = new WxMallBuilding() {{ - setId(idWorker.nextId()); - updateTenantInfo(record); - setName(record.getBuilding()); - setFloorNumber(floors.size()); - }}; + WxMallBuilding mallBuilding = new WxMallBuilding(); + mallBuilding.setId(idWorker.nextId()); + mallBuilding.updateTenantInfo(record); + mallBuilding.setName(record.getBuilding()); + mallBuilding.setFloorNumber(floors.length); + wxMallBuildingMapper.insert(mallBuilding); // 楼层 for(String floor: floors) { - WxMallFloor mallFloor = new WxMallFloor() {{ - setId(idWorker.nextId()); - updateTenantInfo(record); - setBuildingId(mallBuilding.getId()); - setFloorName(floor); - setBackgroundImg(Constant.floor_back_img); - }}; + WxMallFloor mallFloor = new WxMallFloor(); + mallFloor.setId(idWorker.nextId()); + mallFloor.updateTenantInfo(record); + mallFloor.setBuildingId(mallBuilding.getId()); + mallFloor.setFloorName(floor); + mallFloor.setBackgroundImg(Constant.floor_back_img); wxMallFloorMapper.insert(mallFloor); } @@ -199,16 +198,15 @@ public class WxMallBuildingServiceImpl implements WxMallBuildingService { @Override public void saveFloorArea(WxMallFloor record) { - WxMallFloor mallFloor = new WxMallFloor() {{ - setId(record.getId()); - updateTenantInfo(record); - if (record.getTotalArea() != null) { - setTotalArea(record.getTotalArea()); - } - if (record.getOperatingArea() != null) { - setOperatingArea(record.getOperatingArea()); - } - }}; + WxMallFloor mallFloor = new WxMallFloor(); + mallFloor.setId(record.getId()); + mallFloor.updateTenantInfo(record); + if (record.getTotalArea() != null) { + mallFloor.setTotalArea(record.getTotalArea()); + } + if (record.getOperatingArea() != null) { + mallFloor.setOperatingArea(record.getOperatingArea()); + } wxMallFloorMapper.updateById(mallFloor); String key = Constant.mallBuildingPrev + record.getTenantId(); @@ -222,15 +220,14 @@ public class WxMallBuildingServiceImpl implements WxMallBuildingService { @Override public void saveFloorImg(WxMallFloor record) { - WxMallFloor mallFloor = new WxMallFloor() {{ - setId(record.getId()); - updateTenantInfo(record); - if(record.getFloorMaps() == null || record.getFloorMaps().size() == 0){ - setFloorMap("[]"); - }else{ - setFloorMap(JSON.toJSONString(record.getFloorMaps())); - } - }}; + WxMallFloor mallFloor = new WxMallFloor(); + mallFloor.setId(record.getId()); + mallFloor.updateTenantInfo(record); + if(record.getFloorMaps() == null || record.getFloorMaps().size() == 0){ + mallFloor.setFloorMap("[]"); + }else{ + mallFloor.setFloorMap(JSON.toJSONString(record.getFloorMaps())); + } wxMallFloorMapper.updateById(mallFloor); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMallServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMallServiceImpl.java index 8a75a051a..fc0a5e5e8 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMallServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMallServiceImpl.java @@ -143,9 +143,8 @@ public class WxMallServiceImpl implements WxMallService { if (mall == null) { return null; } - WxMallBuilding wxMallBuilding = new WxMallBuilding() {{ - updateTenantInfo(tenantEntity); - }}; + WxMallBuilding wxMallBuilding = new WxMallBuilding(); + wxMallBuilding.updateTenantInfo(tenantEntity); List buildings = wxMallBuildingMapper.findList(wxMallBuilding); List wxMallBuildings = buildings.stream().map(b -> { WxMallBuilding tempb = new WxMallBuilding(); @@ -238,9 +237,9 @@ public class WxMallServiceImpl implements WxMallService { @Override public void undateSubmall(String parentTenantId, List tenantIds) { wxMallMapper.undateSubmall(parentTenantId, tenantIds); - this.deleteRedis(new TenantEntity(){{ - setTenantId(parentTenantId); - }}); + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(parentTenantId); + this.deleteRedis(tenantEntity); } @Override diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java index 800dbac09..c18799c1d 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java @@ -217,10 +217,10 @@ public class WxMsgServiceImpl implements WxMsgService { @Override public ResultData add(WxMsg wxMsg){ - TenantEntity tenantEntity = new TenantEntity() {{ - setTenantId(wxMsg.getTenantId()); - setParentTenantId(wxMsg.getParentTenantId()); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(wxMsg.getTenantId()); + tenantEntity.setParentTenantId(wxMsg.getParentTenantId()); + //不是草稿检验疲劳度 if (!wxMsg.getStatus().equals(EnumMsgStatus.MSG_STATUS_DRAFT.getCode())) { if (wxMsg.getIsright().equals(EnumMsgSend.MSG_SEND_IMMEDIATELY.getCode())) { diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderPressServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderPressServiceImpl.java index ec3486cae..50d9af0e9 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderPressServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderPressServiceImpl.java @@ -163,10 +163,10 @@ public class WxOrderPressServiceImpl implements WxOrderPressService { } // 3. get user info WxCUser user = null; - List list = userMapper.findList(new WxCUser(){{ - updateTenantInfo(order); - setUserId(order.getCUserId()); - }}); + WxCUser wcuQ = new WxCUser(); + wcuQ.updateTenantInfo(order); + wcuQ.setUserId(order.getCUserId()); + List list = userMapper.findList(wcuQ); if(list != null && list.size() > 0){ user = list.get(0); } diff --git a/mallinkTTAdmin/src/main/java/com/iformall/controller/basic/WxBrandController.java b/mallinkTTAdmin/src/main/java/com/iformall/controller/basic/WxBrandController.java index dc7d3a401..1ad48608f 100644 --- a/mallinkTTAdmin/src/main/java/com/iformall/controller/basic/WxBrandController.java +++ b/mallinkTTAdmin/src/main/java/com/iformall/controller/basic/WxBrandController.java @@ -70,11 +70,11 @@ public class WxBrandController extends BaseController { if(EnumDelFlag.YES.getCode().equals(wxBrand.getIsDel())){ //判断是否解绑商户 - WxMerchant wxMerchant = new WxMerchant() {{ - setIsDel(0); - setBrand(wxBrand.getId()); - updateTenantInfo(wxBrand); - }}; + WxMerchant wxMerchant = new WxMerchant(); + wxMerchant.setIsDel(0); + wxMerchant.setBrand(wxBrand.getId()); + wxMerchant.updateTenantInfo(wxBrand); + List merchantList = wxMerchantService.findList(wxMerchant); if(CollectionUtils.isNotEmpty(merchantList)){ return new ResultData(Result.ERROR, "请先删除已绑定该品牌的商户。"); @@ -116,10 +116,9 @@ public class WxBrandController extends BaseController { @SystemControllerLog(description = "品牌-名称是否存在") public ResultData hasBrand(String name, Long id) { logger.debug("[" + getIpAddr() + "] WxBrandController::hasBrand"); - WxBrand wxBrand = new WxBrand() {{ - setName(name); - updateTenantInfo(getTenantInfo()); - }}; + WxBrand wxBrand = new WxBrand(); + wxBrand.updateTenantInfo(getTenantInfo()); + wxBrand.setName(name); wxBrand.setId(id); return wxBrandService.hasBrand(wxBrand); } diff --git a/mallinkTTAdmin/src/main/java/com/iformall/controller/basic/WxShopController.java b/mallinkTTAdmin/src/main/java/com/iformall/controller/basic/WxShopController.java index be6b6cce8..a8adc5c15 100644 --- a/mallinkTTAdmin/src/main/java/com/iformall/controller/basic/WxShopController.java +++ b/mallinkTTAdmin/src/main/java/com/iformall/controller/basic/WxShopController.java @@ -116,10 +116,10 @@ public class WxShopController extends BaseController { @SystemControllerLog(description = "店铺管理-查询商铺号是否存在") public ResultData hasShopNumber(String shopNumber, Long id, Integer type) { logger.debug("[" + getIpAddr() + "] WxShopController::hasShopNumber"); - WxShop wxShop = new WxShop() {{ - setShopNumber(shopNumber); - setType(type); - }}; + WxShop wxShop = new WxShop(); + wxShop.setShopNumber(shopNumber); + wxShop.setType(type); + wxShop.setId(id); wxShop.updateTenantInfo(getTenantInfo()); return wxShopService.hasShopNumber(wxShop); diff --git a/mallinkTTAdmin/src/main/java/com/iformall/controller/msg/WxMsgValidationcodeController.java b/mallinkTTAdmin/src/main/java/com/iformall/controller/msg/WxMsgValidationcodeController.java index ba42f6a3d..52a7eb909 100644 --- a/mallinkTTAdmin/src/main/java/com/iformall/controller/msg/WxMsgValidationcodeController.java +++ b/mallinkTTAdmin/src/main/java/com/iformall/controller/msg/WxMsgValidationcodeController.java @@ -83,10 +83,8 @@ public class WxMsgValidationcodeController extends BaseController { public ResultData sendvalidationcode(String tenantId, String parentTenantId, String phone, Integer type, String appid) { logger.debug("[" + getIpAddr() + "] WxMsgValidationcodeController::sendvalidationcode"); WxMsgValidationcode wxMsgValidationcode = new WxMsgValidationcode(); - wxMsgValidationcode.updateTenantInfo(new TenantEntity(){{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}); + wxMsgValidationcode.setTenantId(tenantId); + wxMsgValidationcode.setParentTenantId(parentTenantId); wxMsgValidationcode.setPhone(phone); wxMsgValidationcode.setType(type); wxMsgValidationcode.setAppid(appid); @@ -104,10 +102,8 @@ public class WxMsgValidationcodeController extends BaseController { public ResultData hasvalidationcode(String tenantId, String parentTenantId, String phone, Integer type, String code, String appid) { logger.debug("[" + getIpAddr() + "] WxMsgValidationcodeController::hasvalidationcode"); WxMsgValidationcode wxMsgValidationcode = new WxMsgValidationcode(); - wxMsgValidationcode.updateTenantInfo(new TenantEntity(){{ - setTenantId(tenantId); - setParentTenantId(parentTenantId); - }}); + wxMsgValidationcode.setTenantId(tenantId); + wxMsgValidationcode.setParentTenantId(parentTenantId); wxMsgValidationcode.setPhone(phone); wxMsgValidationcode.setType(type); wxMsgValidationcode.setCode(code); diff --git a/mallinkTTAdmin/src/main/java/com/iformall/controller/sys/HomeController.java b/mallinkTTAdmin/src/main/java/com/iformall/controller/sys/HomeController.java index 786a9fabe..d16230aa4 100644 --- a/mallinkTTAdmin/src/main/java/com/iformall/controller/sys/HomeController.java +++ b/mallinkTTAdmin/src/main/java/com/iformall/controller/sys/HomeController.java @@ -241,9 +241,9 @@ public class HomeController extends BaseController { logger.error("appid未找到"); return new ResultData(ErrorCode.MALL_INFO_NOT_FOUND); } - TenantEntity tenantEntity = new TenantEntity() {{ - setTenantId(appinfo.getTenantId()); - }}; + TenantEntity tenantEntity = new TenantEntity(); + tenantEntity.setTenantId(appinfo.getTenantId()); + if (StringUtils.isNotBlank(user.getPhone())) { // 领导登录 user = mallUserInfoService.getByPhone(user.getPhone(), tenantEntity); From 3ba3128d9ded9d23c67d36603a1dacd604438783 Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 21 Jul 2021 18:23:27 +0800 Subject: [PATCH 08/14] bug --- mallinkService/src/main/resources/mapper/WxCUserMapper.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml index de464fba7..1305e23cc 100644 --- a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml @@ -232,7 +232,7 @@