From b457131dda80427bbd47b05b9ad27366cafa1718 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期二, 30 六月 2020 11:37:48 +0800 Subject: [PATCH] 首单 + 发单日志记录 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java | 57 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 55 insertions(+), 2 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java index 5b4fd29..141e421 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java @@ -14,6 +14,7 @@ import org.yeshi.utils.BigDecimalUtil; import org.yeshi.utils.taobao.TbImgUtil; +import com.alibaba.druid.support.logging.Log; import com.aliyun.openservices.ons.api.Message; import com.aliyun.openservices.ons.api.Producer; import com.yeshi.fanli.dao.mybatis.user.cloud.UserCloudMapper; @@ -407,6 +408,7 @@ } private void sendCircleByDynamic(Long uid, String id, int way) throws UserCloudException { + long time1= java.lang.System.currentTimeMillis(); UserInfo user = userInfoService.getUserByIdWithMybatis(uid); if (user == null) throw new UserCloudException(1, "鐢ㄦ埛淇℃伅涓嶅瓨鍦�"); @@ -427,7 +429,11 @@ if (StringUtil.isNullOrEmpty(relationId)) throw new UserCloudException(2, "娣樺疂鏈巿鏉冿紝璇峰墠寰�\"鎴戠殑\"缁戝畾娣樺疂璐﹀彿"); + + long time2= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByDynamic淇濋獙璇佺敤鎴风姸鎬侊細" + (time2 - time1)); + // 楠岃瘉鏄惁寮�閫� UserCloud userCloud = userCloudMapper.getValidByUid(uid); if (userCloud == null) @@ -441,6 +447,10 @@ if (StringUtil.isNullOrEmpty(wxId)) throw new UserCloudException(1003, "寰俊鍙蜂笉瀛樺湪锛岃鍏堝井淇$櫥褰�"); + long time3= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByDynamic楠岃瘉鏄惁婊¤冻寮�閫氾細" + (time3 - time2)); + + // 楠岃瘉寮�鍚姸鎬� List<UserCloudGroup> listGroup = userCloudGroupService.listByUid(uid); if (listGroup == null || listGroup.size() == 0) @@ -455,6 +465,9 @@ if (listOpen.size() == 0) throw new UserCloudException(1005, "璇峰厛寮�鍚簯鍙戝崟缇ゅ姛鑳�"); + long time4= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByDynamic楠岃瘉鏄惁寮�鍚細" + (time4 - time3)); + // 楠岃瘉鍙戝湀鏄惁鍙 GoodsEvaluate evaluate = goodsEvaluateService.getById(id); if (evaluate == null || evaluate.getState() == 0) @@ -468,6 +481,9 @@ if (comments == null || comments.size() == 0) throw new UserCloudException(1, "璇ュ唴瀹逛笉鑳借浆閾�"); + long time5= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByDynamic楠岃瘉鍙戝湀鍐呭鏄惁婊¤冻锛�" + (time5 - time4)); + // 妫�娴嬪井淇℃槸鍚︾櫥褰曠姸鎬� if (!AitaokerApiUtil.onlineCheck(robotId)) { // 閫氱煡鐧诲綍寰俊 @@ -476,6 +492,9 @@ throw new UserCloudException(1003, "寰俊宸叉帀绾匡紝闇�瑕侀噸鏂版壂鎻忎簩缁寸爜鐧诲綍"); } + long time6= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByDynamic楠岃瘉鍙戞槸鍚︾櫥褰曪細" + (time6 - time5)); + boolean hasToken = false; List<String> listComment = new ArrayList<>(); for (CommentInfo commentInfo : comments) { @@ -527,6 +546,10 @@ listImg.add(imgInfo.getUrl()); } } + + long time7= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByDynamic鍙戝湀鍐呭缁勭粐杞摼锛�" + (time7 - time6)); + // 淇濆瓨鍙戦�佽褰� UserCloudSendRecord sendRecord = new UserCloudSendRecord(); @@ -540,6 +563,10 @@ UserCloudSendRecord result = userCloudSendRecordService.save(sendRecord); String pid = result.getId(); + long time8= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByDynamic淇濆瓨鍙戝湀璁板綍锛�" + (time8 - time7)); + + for (UserCloudGroup cloudGroup : listOpen) { String title = evaluate.getTitle(); @@ -631,6 +658,10 @@ } userCloudSendContentService.save(sendContent); } + + long time9= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByDynamic鎵ц鍙戝湀鑰楁椂锛�" + (time9 - time8)); + } @Override @@ -672,6 +703,8 @@ private void sendCircleByGoods(Long uid, Long goodsId, Integer goodsType, Long storeId, Long sellerId, int way) throws UserCloudException { + long begainTime = java.lang.System.currentTimeMillis(); + // 楠岃瘉鏄惁鎺堟潈 UserInfo user = userInfoService.getUserByIdWithMybatis(uid); if (user == null) @@ -694,11 +727,19 @@ if (StringUtil.isNullOrEmpty(relationId)) throw new UserCloudException(2, "娣樺疂鏈巿鏉冿紝璇峰墠寰�\"鎴戠殑\"缁戝畾娣樺疂璐﹀彿"); + long time2 = java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByGoods楠岃瘉鐢ㄦ埛鑰楁椂锛�" + (time2 - begainTime)); + + // 楠岃瘉鏄惁寮�閫� UserCloud userCloud = userCloudMapper.getValidByUid(uid); if (userCloud == null) throw new UserCloudException(1001, "浜戝彂鍗曞凡杩囨湡"); - + + long time3= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByGoods楠岃瘉鏄惁寮�閫氾細" + (time3 - time2)); + + long time4 = time3; // 鍔犲叆鎴戠殑澶囬�夊簱 if (storeId == null) { try { @@ -710,6 +751,8 @@ + "]鍘熷洜锛�" + e.getMsg()); throw new UserCloudException(1, "鍔犲叆浜戝彂鍗曞閫夊簱澶辫触"); } + time4= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByGoods鍔犲叆澶囬�夊簱锛�" + (time4 - time3)); } // 鑷�夊簱鍟嗗搧鏄惁鎵撳紑 @@ -736,6 +779,9 @@ if (listGroup == null || listGroup.size() == 0) throw new UserCloudException(1003, "璇峰厛鐧诲綍寰俊"); + long time5= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByGoods楠岃瘉鏄惁缁戝畾寰俊锛�" + (time5 - time4)); + List<UserCloudGroup> listOpen = new ArrayList<>(); for (UserCloudGroup cloudGrou : listGroup) { if (cloudGrou.getState()) { @@ -754,6 +800,9 @@ throw new UserCloudException(1003, "寰俊宸叉帀绾匡紝闇�瑕侀噸鏂版壂鎻忎簩缁寸爜鐧诲綍"); } + long time6= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByGoods楠岃瘉鏄惁鐧诲綍寰俊锛�" + (time6 - time5)); + // 淇濆瓨鍙戦�佽褰� UserCloudSendRecord sendRecord = new UserCloudSendRecord(); sendRecord.setUid(uid); @@ -770,6 +819,9 @@ sendRecord.setSendWay(UserCloudSendRecord.SEND_WAY_MANUAL); } UserCloudSendRecord result = userCloudSendRecordService.save(sendRecord); + + long time7= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByGoods淇濆瓨鍙戦�佽褰曪細" + (time7 - time6)); try { if (goodsType == Constant.SOURCE_TYPE_TAOBAO) { @@ -792,7 +844,8 @@ record.setUpdateTime(new Date()); userCloudGoodsService.updateByPrimaryKeySelective(record); } - + long time8= java.lang.System.currentTimeMillis(); + LogHelper.test("sendCircleByGoods鎵ц鍙戦�侊細" + (time8 - time7)); } catch (UserCloudException e) { LogHelper.cloudInfo("autoSendCustomGoods - [uid:" + uid + " 搴搃d:" + storeId + "]鍘熷洜锛�" + e.getMsg()); // 鏇存柊鍙戝崟璁板綍 -- Gitblit v1.8.0