From a411a7673a32016de54ee0b95083951a549e89b0 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 20 Apr 2021 11:51:12 +0800
Subject: [PATCH] 20210420 签到

---
 zq-erp/src/main/java/com/matrix/system/shopXcx/api/vo/SeeAwardTextVo.java                 |    8 +
 zq-erp/src/main/java/com/matrix/system/activity/service/ActivitySignWriteoffService.java  |  137 ++++++--------------------
 zq-erp/src/main/java/com/matrix/system/activity/dao/ActivitySignWriteoffDao.java          |    2 
 zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java |   98 +++++++++++++++++++
 zq-erp/src/main/resources/mybatis/mapper/activity/ActivitySignWriteoffDao.xml             |    8 +
 5 files changed, 148 insertions(+), 105 deletions(-)

diff --git a/zq-erp/src/main/java/com/matrix/system/activity/dao/ActivitySignWriteoffDao.java b/zq-erp/src/main/java/com/matrix/system/activity/dao/ActivitySignWriteoffDao.java
index 660ab82..5bd6702 100644
--- a/zq-erp/src/main/java/com/matrix/system/activity/dao/ActivitySignWriteoffDao.java
+++ b/zq-erp/src/main/java/com/matrix/system/activity/dao/ActivitySignWriteoffDao.java
@@ -25,4 +25,6 @@
 	ZjrVo selectUsernameByUserId(@Param("userId")Long userId, @Param("receiveId")Long receiveId);
 
     ShopDeliveryInfo selectShopDeliveryInfoByLogisticsId(@Param("logisticsId")Integer logisticsId);
+
+	ActivitySignWriteoff selectActivitySignWriteoffByUserIDAndReceiveId(@Param("logisticsId")Long id, @Param("logisticsId")long receiveId);
 }
\ No newline at end of file
diff --git a/zq-erp/src/main/java/com/matrix/system/activity/service/ActivitySignWriteoffService.java b/zq-erp/src/main/java/com/matrix/system/activity/service/ActivitySignWriteoffService.java
index 3774bde..835ed41 100644
--- a/zq-erp/src/main/java/com/matrix/system/activity/service/ActivitySignWriteoffService.java
+++ b/zq-erp/src/main/java/com/matrix/system/activity/service/ActivitySignWriteoffService.java
@@ -27,6 +27,7 @@
 import com.matrix.system.common.dao.SystemDictionaryDao;
 import com.matrix.system.hive.action.util.QueryUtil;
 import com.matrix.system.hive.dao.SysVipInfoDao;
+import com.matrix.system.shopXcx.api.service.WxShopLogisticsQueryService;
 import com.matrix.system.shopXcx.bean.ShopActivities;
 import com.matrix.system.shopXcx.bean.ShopDeliveryInfo;
 import com.matrix.system.shopXcx.bean.ShopLogisticsInfo;
@@ -65,6 +66,8 @@
 	ShopDeliveryInfoDao shopDeliveryInfoDao;
 	@Autowired
 	ShopLogisticsInfoDao shopLogisticsInfoDao;
+	@Autowired
+	private WxShopLogisticsQueryService wxShopLogisticsQueryService;
 
 	public IPage<SignWriteoffListVo> findSignWriteoffList(Page<SignWriteoffListVo> page,
 			SignWriteoffListDto signWriteoffListDto) {
@@ -108,20 +111,22 @@
         		
         		//物流跟踪
         		Integer logisticsId = activitySignWriteoffLogistics.getLogisticsId();
-        		if(ObjectUtil.isNotEmpty(logisticsId)) {
-        			List<ShopLogisticsInfo> shopLogisticsInfos = shopLogisticsInfoDao.selectByDelieryId(logisticsId);
-        			if(CollUtil.isNotEmpty(shopLogisticsInfos)) {
-        				ArrayList<LogisticsVo> logisticsVos = new ArrayList<>();
-        				for(ShopLogisticsInfo shopLogistics : shopLogisticsInfos) {
-        					LogisticsVo logisticsVo = new LogisticsVo();
-        					logisticsVo.setContent(shopLogistics.getDescribe());
-        					logisticsVo.setTimestamp(shopLogistics.getLogisticsTime());
-        					logisticsVos.add(logisticsVo);
-        				}
-        				signWriteoffVo.setActivities(logisticsVos);
-        			}
-        		}
-        		
+				ShopDeliveryInfo shopDeliveryInfo = shopDeliveryInfoDao.selectById(logisticsId);
+				if(ObjectUtil.isNotEmpty(shopDeliveryInfo)){
+					//查看物流信息
+					wxShopLogisticsQueryService.selectLogisticsInfo(shopDeliveryInfo);
+					List<ShopLogisticsInfo> shopLogisticsInfos = shopLogisticsInfoDao.selectByDelieryId(shopDeliveryInfo.getId());
+					if(CollUtil.isNotEmpty(shopLogisticsInfos)) {
+						ArrayList<LogisticsVo> logisticsVos = new ArrayList<>();
+						for(ShopLogisticsInfo shopLogistics : shopLogisticsInfos) {
+							LogisticsVo logisticsVo = new LogisticsVo();
+							logisticsVo.setContent(shopLogistics.getDescribe());
+							logisticsVo.setTimestamp(shopLogistics.getLogisticsTime());
+							logisticsVos.add(logisticsVo);
+						}
+						signWriteoffVo.setActivities(logisticsVos);
+					}
+				}
         	}
         }
         result.putInMap("signWriteoffVo", signWriteoffVo);
@@ -194,96 +199,20 @@
 
         shopDeliveryInfo.setDeliveryTime(new Date());
         shopDeliveryInfoDao.insert(shopDeliveryInfo);
-//		Integer id = shopDeliveryInfo.getId();
-//		if(ObjectUtil.isNotEmpty(id)) {
-//			List<ShopLogisticsInfo> shopLogisticsList = new ArrayList<ShopLogisticsInfo>();
-//	        AjaxResult result = new AjaxResult();
-//	        Map<String, String> logisticsInfo = new HashMap<String, String>();
-//	        try {
-//	            if (shopDeliveryInfo == null) {
-//	                return new AjaxResult(AjaxResult.STATUS_FAIL, "找不到发货信息");
-//	            }
-//	            if (!StringUtils.isNotBlank(shopDeliveryInfo.getWaybillNo()) || !StringUtils.isNotBlank(shopDeliveryInfo.getLogisticsCompanyCode())) {
-//	                return new AjaxResult(AjaxResult.STATUS_FAIL, "物流公司信息为空");
-//	            }
-//	            logisticsInfo.put("logisticsCompany", shopDeliveryInfo.getLogisticsCompany());
-//	            logisticsInfo.put("waybillNo", shopDeliveryInfo.getWaybillNo());
-//
-//	            //如果已经签收直接查数据库
-//	            if (AppConstance.LOGISTICS_STATUS_OF_SIGN_FOR.equals(shopDeliveryInfo.getLogisticsStatus())) {
-//
-//	                List<ShopLogisticsInfo> shopLogisticsInfos = shopLogisticsInfoDao.selectByDelieryId(shopDeliveryInfo.getId());
-//	                logisticsInfo.put("logisticsStatus", String.valueOf(AppConstance.LOGISTICS_STATUS_OF_SIGN_FOR));
-//	                result.setStatus(AjaxResult.STATUS_SUCCESS);
-//	                result.setRows(shopLogisticsInfos);
-//	                result.putInMap("logisticsInfo", logisticsInfo);
-//	                return result;
-//	            }
-//	            Map<String, String> param = new HashMap<String, String>();
-//	            param.put("ShipperCode", shopDeliveryInfo.getLogisticsCompanyCode());
-//	            param.put("LogisticCode", shopDeliveryInfo.getWaybillNo());
-//	            Map<String, String> paramsUrl = getparams(param);
-//	            LogUtil.info("物流查询参数" + paramsUrl);
-//	            String logisticsResult = HttpCurlUtil.sendPost(logisticsUrl, paramsUrl);
-//	            LogUtil.info("查询物流返回信息" + logisticsResult);
-//	            LogisticsInfoVo logisticsInfoVo = JSON.parseObject(logisticsResult, LogisticsInfoVo.class);
-//	            if (logisticsInfoVo.isSuccess()) {
-//	                ShopDeliveryInfo shopDelivery = new ShopDeliveryInfo();
-//	                shopDelivery.setLogisticsStatus(Integer.valueOf(logisticsInfoVo.getState()));
-//	                shopDelivery.setId(shopDeliveryInfo.getId());
-//	                logisticsInfo.put("logisticsStatus", logisticsInfoVo.getState());
-//	                //更新物流状态
-//	                shopDeliveryInfoDao.updateByModel(shopDelivery);
-//	                if (CollectionUtils.isNotEmpty(logisticsInfoVo.getTraces())) {
-//	                    List<Map<String, String>> mapTraces = logisticsInfoVo.getTraces();
-//	                    for (int i = 0; i < mapTraces.size(); i++) {
-//	                        ShopLogisticsInfo shopLogisticsInfo = new ShopLogisticsInfo();
-//	                        shopLogisticsInfo.setCreateBy(AppConstance.SYSTEM_USER);
-//	                        shopLogisticsInfo.setUpdateBy(AppConstance.SYSTEM_USER);
-//	                        shopLogisticsInfo.setLogisticsTime(mapTraces.get(i).get("AcceptTime"));
-//	                        String acceptStation = mapTraces.get(i).get("AcceptStation");
-//	                        shopLogisticsInfo.setDescribe(acceptStation);
-//	                        shopLogisticsInfo.setDelieryId(shopDeliveryInfo.getId());
-//	                        if (acceptStation.indexOf(AppConstance.KDN_IS_SIGN) != -1) {
-//	                            shopLogisticsInfo.setState(AppConstance.LOGISTICS_STATUS_OF_SIGN_FOR);
-//	                        } else if (acceptStation.indexOf(AppConstance.KDN_IS_RECEIVE) != -1) {
-//	                            shopLogisticsInfo.setState(AppConstance.LOGISTICS_STATUS_OF_RECEIVE);
-//	                        } else if (acceptStation.indexOf(AppConstance.KDN_IS_ON_WAY) != -1) {
-//	                            shopLogisticsInfo.setState(AppConstance.LOGISTICS_STATUS_OF_ON_WAY);
-//	                        } else if (acceptStation.indexOf(AppConstance.KDN_IS_MISTAKE) != -1) {
-//	                            shopLogisticsInfo.setState(AppConstance.LOGISTICS_STATUS_OF_MISTAKE);
-//	                        } else {
-//	                            shopLogisticsInfo.setState(AppConstance.LOGISTICS_STATUS_OF_NONE);
-//	                        }
-//	                        shopLogisticsList.add(shopLogisticsInfo);
-//	                    }
-//	                    shopLogisticsInfoDao.deleteByDelieryId(shopDeliveryInfo.getId());
-//	                    if (CollectionUtils.isNotEmpty(shopLogisticsList)) {
-//	                        shopLogisticsInfoDao.batchInsert(shopLogisticsList);
-//	                    }
-//	                }
-//	            } else {
-//	                throw new GlobleException(logisticsInfoVo.getReason());
-//	            }
-//
-//	        } catch (Exception e) {
-//	            throw new GlobleException("物流信息查询失败");
-//	        }
-	        //更新核销记录
-	        activitySignWriteoff.setState(ActivitySignWriteoff.STATE_THREE);
-	        activitySignWriteoff.setWriteoffTime(new Date());
-	        activitySignWriteoff.setWriteoffUser(sysUsers.getSuName());
-	        activitySignWriteoff.setWriteoffUserid(sysUsers.getSuId());
-	        activitySignWriteoff.setLogisticsId(shopDeliveryInfo.getId());
-	        activitySignWriteoffDao.updateById(activitySignWriteoff);
-	        //更新领取记录
-	        ActivitySignReceiveRecord activitySignReceiveRecord = activitySignReceiveRecordDao.selectById(receiveId);
-	        activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_THREE);
-	        activitySignReceiveRecord.setConsignee(logisticsSubmitDto.getShr());
-	        activitySignReceiveRecord.setConsigneeAddress(logisticsSubmitDto.getShdz());
-	        activitySignReceiveRecord.setConsigneePhone(logisticsSubmitDto.getLxdh());
-	        activitySignReceiveRecordDao.updateById(activitySignReceiveRecord);
-//		}
+		//更新核销记录
+		activitySignWriteoff.setState(ActivitySignWriteoff.STATE_THREE);
+		activitySignWriteoff.setWriteoffTime(new Date());
+		activitySignWriteoff.setWriteoffUser(sysUsers.getSuName());
+		activitySignWriteoff.setWriteoffUserid(sysUsers.getSuId());
+		activitySignWriteoff.setLogisticsId(shopDeliveryInfo.getId());
+		activitySignWriteoffDao.updateById(activitySignWriteoff);
+		//更新领取记录
+		ActivitySignReceiveRecord activitySignReceiveRecord = activitySignReceiveRecordDao.selectById(receiveId);
+		activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_THREE);
+		activitySignReceiveRecord.setConsignee(logisticsSubmitDto.getShr());
+		activitySignReceiveRecord.setConsigneeAddress(logisticsSubmitDto.getShdz());
+		activitySignReceiveRecord.setConsigneePhone(logisticsSubmitDto.getLxdh());
+		activitySignReceiveRecordDao.updateById(activitySignReceiveRecord);
         return new AjaxResult(AjaxResult.STATUS_SUCCESS, "发货成功");
 	}
 
diff --git a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java
index da861c3..d3e876a 100644
--- a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java
+++ b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java
@@ -9,6 +9,7 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.matrix.component.redis.RedisUserLoginUtils;
+import com.matrix.core.exception.GlobleException;
 import com.matrix.core.pojo.AjaxResult;
 import com.matrix.core.tools.StringUtils;
 import com.matrix.system.activity.dao.ActivitySignAwardSetDao;
@@ -22,9 +23,14 @@
 import com.matrix.system.hive.bean.SysVipInfo;
 import com.matrix.system.shopXcx.api.dto.SeeAwardTextDto;
 import com.matrix.system.shopXcx.api.dto.SignAwardDto;
+import com.matrix.system.shopXcx.api.service.WxShopLogisticsQueryService;
 import com.matrix.system.shopXcx.api.vo.*;
 import com.matrix.system.shopXcx.bean.ShopActivities;
+import com.matrix.system.shopXcx.bean.ShopDeliveryInfo;
+import com.matrix.system.shopXcx.bean.ShopLogisticsInfo;
 import com.matrix.system.shopXcx.dao.ShopActivitiesDao;
+import com.matrix.system.shopXcx.dao.ShopDeliveryInfoDao;
+import com.matrix.system.shopXcx.dao.ShopLogisticsInfoDao;
 import com.matrix.system.shopXcx.vo.SalesOrderVo;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -63,6 +69,15 @@
 	
 	@Autowired
 	private ActivitySignRecordDao activitySignRecordDao;
+	
+    @Autowired
+    ShopDeliveryInfoDao shopDeliveryInfoDao;
+
+    @Autowired
+    private ShopLogisticsInfoDao shopLogisticsInfoDao;
+
+    @Autowired
+    private WxShopLogisticsQueryService wxShopLogisticsQueryService;
 	
 	@ApiOperation(value = "获取签到基本信息", notes = "")
 	@ApiResponses({
@@ -140,6 +155,56 @@
         ajaxResult.setData(signBasicInfoVo);
         return ajaxResult;
     }
+
+    /**
+     * 查看历史签到记录
+     *
+     * @param
+     * @return
+     */
+    @ApiOperation(value = "查看历史签到记录", notes = "")
+    @GetMapping(value = "getSignRecord/{actId}/{month}")
+    @ResponseBody
+    public AjaxResult getSignRecord(@PathVariable("actId") long actId,@PathVariable("month") String dateStr) {
+        //获取登录人信息
+        SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class);
+        Long companyId = loginUser.getCompanyId();
+        Long userId = loginUser.getId();
+        Date date = DateUtil.parse(dateStr);
+        /**
+         * 默认获取当前月份
+         *      获取当前月份的天数
+         */
+        List<ActivitySignRecordVo> activitySignRecordVos = new ArrayList<>();
+        //获取当前月的第一天是星期几
+        DateTime dateTime = DateUtil.beginOfMonth(date);
+        int i = DateUtil.dayOfWeek(dateTime);
+        for(int j = 1;j<i;j++){
+            ActivitySignRecordVo activitySignRecordVoNull = new ActivitySignRecordVo();
+            activitySignRecordVos.add(activitySignRecordVoNull);
+        }
+        List<String> monthFullDays = getMonthFullDay(DateUtil.year(DateUtil.date()), DateUtil.month(DateUtil.date()) + 1);
+        for(String monthFullDay : monthFullDays){
+            ActivitySignRecordVo activitySignRecordVo = new ActivitySignRecordVo();
+            activitySignRecordVo.setSignTime(monthFullDay);
+            activitySignRecordVo.setActivityId(actId);
+            activitySignRecordVo.setCompanyId(companyId);
+            //对应日期是否已签到
+            Date dateSign = DateUtil.parse(monthFullDay);
+            ActivitySignRecord activitySignRecordDone = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,dateSign);
+            if(ObjectUtil.isNotEmpty(activitySignRecordDone)){
+                activitySignRecordVo.setState(1);
+            }else{
+                activitySignRecordVo.setState(2);
+            }
+            activitySignRecordVos.add(activitySignRecordVo);
+        }
+        AjaxResult ajaxResult = new AjaxResult();
+        ajaxResult = AjaxResult.buildSuccessInstance("");
+        ajaxResult.setData(activitySignRecordVos);
+        return ajaxResult;
+    }
+
     /**
      *  java 获取 获取某年某月 所有日期(yyyy-mm-dd格式字符串)
      * @param year
@@ -445,7 +510,7 @@
      *
      * @return
      */
-    @ApiOperation(value = "物流配送确认", notes = "")
+    @ApiOperation(value = "物流配送信息查看", notes = "")
     @PostMapping(value = "/logisticsInsure")
     @ApiResponses({
             @ApiResponse(code = 200, message = "ok", response = SeeAwardTextVo.class)
@@ -455,9 +520,40 @@
         seeAwardTextDto.setUserId(loginUser.getId());
         seeAwardTextDto.setCompanyId(loginUser.getCompanyId());
         SeeAwardTextVo seeAwardTextVO = activitySignReceiveRecordDao.selectSeeAwardTextVOById(seeAwardTextDto);
+        long receiveId = seeAwardTextVO.getId();
+        //获取核销记录的ID
+        ActivitySignWriteoff activitySignWriteoff = activitySignWriteoffDao.selectActivitySignWriteoffByUserIDAndReceiveId(loginUser.getId(),receiveId);
+        Integer logisticsId = activitySignWriteoff.getLogisticsId();
+        ShopDeliveryInfo shopDeliveryInfo = shopDeliveryInfoDao.selectById(logisticsId);
+        if(ObjectUtil.isNotEmpty(shopDeliveryInfo)){
+            //查看物流信息
+            wxShopLogisticsQueryService.selectLogisticsInfo(shopDeliveryInfo);
+            List<ShopLogisticsInfo> shopLogisticsInfos = shopLogisticsInfoDao.selectByDelieryId(shopDeliveryInfo.getId());
+            seeAwardTextVO.setShopLogisticsInfos(shopLogisticsInfos);
+        }
         AjaxResult result=AjaxResult.buildSuccessInstance(seeAwardTextVO);
         return result;
     }
+
+    /**
+     * 物流配送确认收货
+     *
+     * @param
+     * @return
+     */
+    @ApiOperation(value = "物流配送确认收货", notes = "")
+    @GetMapping(value = "logisticsInsureById/{awardId}")
+    @ResponseBody
+    public AjaxResult logisticsInsureById(@PathVariable("awardId") long awardId) {
+        ActivitySignReceiveRecord activitySignReceiveRecord = activitySignReceiveRecordDao.selectById(awardId);
+        //如果不是待收货状态
+        if (ActivitySignReceiveRecord.STATE_FOUR != activitySignReceiveRecord.getState()) {
+            throw new GlobleException("该奖品不是待收货状态!");
+        }
+        activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE);
+        activitySignReceiveRecordDao.updateById(activitySignReceiveRecord);
+        return new AjaxResult(AjaxResult.STATUS_SUCCESS, "收货成功!");
+    }
     
     
     
diff --git a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/vo/SeeAwardTextVo.java b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/vo/SeeAwardTextVo.java
index 7dd4cfc..0e81d77 100644
--- a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/vo/SeeAwardTextVo.java
+++ b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/vo/SeeAwardTextVo.java
@@ -1,15 +1,20 @@
 package com.matrix.system.shopXcx.api.vo;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.matrix.system.shopXcx.bean.ShopLogisticsInfo;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 import java.util.Date;
+import java.util.List;
 
 @Data
 @ApiModel(value = "SeeAwardTextVo", description = "劵码信息")
 public class SeeAwardTextVo {
+
+	@ApiModelProperty(value ="中奖记录ID")
+	private long  id;
 	
 	@ApiModelProperty(value ="奖项名称")
 	private String  awardName;
@@ -46,4 +51,7 @@
 	@ApiModelProperty(value =" 是否已领取(1:待领取2:已领取)")
 	private Integer  state;
 
+	@ApiModelProperty(value ="物流信息记录")
+	private List<ShopLogisticsInfo> shopLogisticsInfos;
+
 }
diff --git a/zq-erp/src/main/resources/mybatis/mapper/activity/ActivitySignWriteoffDao.xml b/zq-erp/src/main/resources/mybatis/mapper/activity/ActivitySignWriteoffDao.xml
index 2a3fa33..0d3affe 100644
--- a/zq-erp/src/main/resources/mybatis/mapper/activity/ActivitySignWriteoffDao.xml
+++ b/zq-erp/src/main/resources/mybatis/mapper/activity/ActivitySignWriteoffDao.xml
@@ -101,4 +101,12 @@
 		where a.id = #{logisticsId}
 	</select>
 
+	<select id="selectActivitySignWriteoffByUserIDAndReceiveId" resultType="com.matrix.system.activity.entity.ActivitySignWriteoff">
+		SELECT
+			*
+		FROM
+			shop_delivery_info a
+		where a.id = #{logisticsId}
+	</select>
+
 </mapper>
\ No newline at end of file

--
Gitblit v1.9.1