diff --git a/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusAgentInfoController.java b/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusAgentInfoController.java index d22b1c6..306dd6c 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusAgentInfoController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusAgentInfoController.java @@ -85,7 +85,7 @@ public class BusAgentInfoController extends BaseController { String date = sdf.format(minusDay); String startTime = date + " 00:00:00"; String endTime = date + " 23:59:59"; - int lastUserIntegralNum = iBusStoreInfoService.lastUserIntegralNum(bean.getAgentAccount(), startTime, endTime); + int lastUserIntegralNum = iBusStoreInfoService.lastUserIntegralNum(bean.getAgentAccount(), startTime, endTime,null); bean.setLastUseIntegralNum(lastUserIntegralNum); bean.setLastPositiveReviewsNum(iBusStoreInfoService.lastPositiveReviewsNum(bean.getAgentAccount(), startTime, endTime)); List lll = ll.stream().filter(f -> "1".equals(f.getReturnVisitStatus())).collect(Collectors.toList()); diff --git a/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusIntegralHistoryInfoController.java b/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusIntegralHistoryInfoController.java index 1ddf262..74d6a80 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusIntegralHistoryInfoController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusIntegralHistoryInfoController.java @@ -2,6 +2,10 @@ package com.ruoyi.business.controller; import java.util.List; import javax.servlet.http.HttpServletResponse; + +import com.ruoyi.common.utils.SecurityUtils; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; @@ -27,8 +31,9 @@ import com.ruoyi.common.core.page.TableDataInfo; * @author ruoyi * @date 2024-08-18 */ +@Api(tags = "账分快照") @RestController -@RequestMapping("/integral/integral") +@RequestMapping("/business/integral") public class BusIntegralHistoryInfoController extends BaseController { @Autowired @@ -37,7 +42,7 @@ public class BusIntegralHistoryInfoController extends BaseController /** * 查询帐分历史快照列表 */ - @PreAuthorize("@ss.hasPermi('integral:integral:list')") +// @PreAuthorize("@ss.hasPermi('integral:integral:list')") @GetMapping("/list") public TableDataInfo list(BusIntegralHistoryInfo busIntegralHistoryInfo) { @@ -46,14 +51,34 @@ public class BusIntegralHistoryInfoController extends BaseController return getDataTable(list); } + @GetMapping("/list1") + public TableDataInfo list1(String account, String expStartTime, String expEndTime) + { + startPage(); + expStartTime = expStartTime + " 00:00:00"; + expEndTime = expEndTime + " 23:59:59"; + List list = busIntegralHistoryInfoService.selectBusIntegralHistoryInfoList1(account, expStartTime,expEndTime); + return getDataTable(list); + } + + @ApiOperation("更新账分表") + @GetMapping("/updateIntegralHistoryInfo") + public AjaxResult updateIntegralHistoryInfo() + { + boolean flag = busIntegralHistoryInfoService.updateIntegralHistoryInfo(); + return AjaxResult.success(flag); + } /** * 导出帐分历史快照列表 */ - @PreAuthorize("@ss.hasPermi('integral:integral:export')") +// @PreAuthorize("@ss.hasPermi('integral:integral:export')") @Log(title = "帐分历史快照", businessType = BusinessType.EXPORT) @PostMapping("/export") public void export(HttpServletResponse response, BusIntegralHistoryInfo busIntegralHistoryInfo) { + if(!"admin".equals(SecurityUtils.getLoginUser().getUsername())){ + busIntegralHistoryInfo.setAccount(SecurityUtils.getLoginUser().getUsername()); + } List list = busIntegralHistoryInfoService.selectBusIntegralHistoryInfoList(busIntegralHistoryInfo); ExcelUtil util = new ExcelUtil(BusIntegralHistoryInfo.class); util.exportExcel(response, list, "帐分历史快照数据"); diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/config/ProxyProperties.java b/ruoyi-common/src/main/java/com/ruoyi/common/config/ProxyProperties.java index 09aa46b..ce699df 100644 --- a/ruoyi-common/src/main/java/com/ruoyi/common/config/ProxyProperties.java +++ b/ruoyi-common/src/main/java/com/ruoyi/common/config/ProxyProperties.java @@ -90,7 +90,7 @@ public class ProxyProperties { if (checkdpsvalid(ip) && getdpsvalidtime(ip)) { return ip; } - getUrl(); +// getUrl(); } finally { response.close(); } @@ -125,7 +125,7 @@ public class ProxyProperties { String code = jsonObject.getString(("code")); if ("0".equals(code)) { int count = jsonObject.getJSONObject("data").getInteger(proxy); - if (count > 30) { + if (count > 2) { System.out.println("剩余:"+count); return true; } diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java index 7fcdfa3..82b8480 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java @@ -2,6 +2,7 @@ package com.ruoyi.quartz.task; import com.ruoyi.business.service.IAiService; import com.ruoyi.business.service.IBusFifteenInfoService; +import com.ruoyi.business.service.IBusIntegralHistoryInfoService; import com.ruoyi.business.service.IMeituanService; import com.ruoyi.business.service.impl.AsyncTaskImpl; import lombok.extern.slf4j.Slf4j; @@ -25,6 +26,8 @@ public class RyTask { @Autowired private AsyncTaskImpl taskService; + @Autowired + private IBusIntegralHistoryInfoService iBusIntegralHistoryInfoService; /** * 获取订单并解析号码 5分钟 */ @@ -72,4 +75,10 @@ public class RyTask { taskService.clearStoreKey(); } + /** + * 账户账分快照 + */ + public void updateIntegralHistoryInfo(){ + iBusIntegralHistoryInfoService.updateIntegralHistoryInfo(); + } } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/domain/BusIntegralHistoryInfo.java b/ruoyi-system/src/main/java/com/ruoyi/business/domain/BusIntegralHistoryInfo.java index d275a2c..3414c7d 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/domain/BusIntegralHistoryInfo.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/domain/BusIntegralHistoryInfo.java @@ -32,11 +32,11 @@ public class BusIntegralHistoryInfo extends BaseEntity /** ai帐分 */ @Excel(name = "ai帐分") - private Long aiIntegralBalance; + private Integer aiIntegralBalance; /** sms帐分 */ @Excel(name = "sms帐分") - private Long integralBalance; + private Integer integralBalance; public void setId(Long id) { @@ -74,21 +74,21 @@ public class BusIntegralHistoryInfo extends BaseEntity { return superiorAgentCode; } - public void setAiIntegralBalance(Long aiIntegralBalance) + public void setAiIntegralBalance(Integer aiIntegralBalance) { this.aiIntegralBalance = aiIntegralBalance; } - public Long getAiIntegralBalance() + public Integer getAiIntegralBalance() { return aiIntegralBalance; } - public void setIntegralBalance(Long integralBalance) + public void setIntegralBalance(Integer integralBalance) { this.integralBalance = integralBalance; } - public Long getIntegralBalance() + public Integer getIntegralBalance() { return integralBalance; } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/mapper/BusIntegralHistoryInfoMapper.java b/ruoyi-system/src/main/java/com/ruoyi/business/mapper/BusIntegralHistoryInfoMapper.java index 22731dd..f0cf081 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/mapper/BusIntegralHistoryInfoMapper.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/mapper/BusIntegralHistoryInfoMapper.java @@ -2,6 +2,7 @@ package com.ruoyi.business.mapper; import java.util.List; import com.ruoyi.business.domain.BusIntegralHistoryInfo; +import org.apache.ibatis.annotations.Param; /** * 帐分历史快照Mapper接口 @@ -58,4 +59,8 @@ public interface BusIntegralHistoryInfoMapper * @return 结果 */ public int deleteBusIntegralHistoryInfoByIds(Long[] ids); + + public int insertBatch(@Param("infoList") List infoList); + + List selectBusIntegralHistoryInfoList1(@Param("account")String account,@Param("expStartTime") String expStartTime,@Param("expEndTime") String expEndTime); } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/mapper/BusStoreInfoMapper.java b/ruoyi-system/src/main/java/com/ruoyi/business/mapper/BusStoreInfoMapper.java index cd850dd..1c1ef9d 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/mapper/BusStoreInfoMapper.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/mapper/BusStoreInfoMapper.java @@ -32,7 +32,7 @@ public interface BusStoreInfoMapper public List selectBusStoreInfoList(BusStoreInfo busStoreInfo); - int lastUserIntegralNum(@Param("agentAccount") String agentAccount,@Param("startTime") String startTime,@Param("endTime") String endTime); + int lastUserIntegralNum(@Param("agentAccount") String agentAccount,@Param("startTime") String startTime,@Param("endTime") String endTime, @Param("integralType") String integralType); /** * 新增店铺信息 diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/IBusIntegralHistoryInfoService.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/IBusIntegralHistoryInfoService.java index 5707e94..bffd82e 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/IBusIntegralHistoryInfoService.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/IBusIntegralHistoryInfoService.java @@ -58,4 +58,8 @@ public interface IBusIntegralHistoryInfoService * @return 结果 */ public int deleteBusIntegralHistoryInfoById(Long id); + + public Boolean updateIntegralHistoryInfo(); + + public List selectBusIntegralHistoryInfoList1(String account, String expStartTime, String expEndTime); } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/IBusStoreInfoService.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/IBusStoreInfoService.java index 36661f8..679b4a3 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/IBusStoreInfoService.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/IBusStoreInfoService.java @@ -38,7 +38,7 @@ public interface IBusStoreInfoService * @return 店铺信息集合 */ public List selectBusStoreInfoList(BusStoreInfo busStoreInfo); - int lastUserIntegralNum(String agentAccount,String startTime,String endTime); + int lastUserIntegralNum(String agentAccount,String startTime,String endTime,String integralType); /** * 新增店铺信息 diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java index f93d852..0b01ce9 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java @@ -318,7 +318,8 @@ public class AiServiceImpl implements IAiService { BusOrderInfo busOrderInfo = orderInfoService.selectBusOrderInfoById(1L); String phoneNo = busOrderInfo.getPrivcyPhone().split(",")[0];//#分机号# content = content.replaceAll("分机号",busOrderInfo.getPrivcyPhone().split(",")[1]); - com.alibaba.fastjson.JSONObject jsonObject = busTencentProperties.smsCredential(phoneNo, content); +// com.alibaba.fastjson.JSONObject jsonObject = busTencentProperties.smsCredential(phoneNo, content); + com.alibaba.fastjson.JSONObject jsonObject = busTencentProperties.smsCredential("1050089","10011722840851099","4994af11076e4b5e872d9573abb7ee44",phoneNo, content); if("00".equals(jsonObject.getString("status"))){ log.error("发送成功========"); }else{ diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusIntegralHistoryInfoServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusIntegralHistoryInfoServiceImpl.java index 73f4143..06be1ce 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusIntegralHistoryInfoServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusIntegralHistoryInfoServiceImpl.java @@ -1,12 +1,25 @@ package com.ruoyi.business.service.impl; +import java.time.LocalDateTime; +import java.time.ZoneId; +import java.time.format.DateTimeFormatter; +import java.util.Date; import java.util.List; +import java.util.Objects; +import java.util.stream.Collectors; + +import com.ruoyi.business.domain.BusAgentInfo; +import com.ruoyi.business.mapper.BusAgentInfoMapper; +import com.ruoyi.business.mapper.BusStoreInfoMapper; +import com.ruoyi.business.service.IBusAgentInfoService; +import com.ruoyi.common.exception.ServiceException; import com.ruoyi.common.utils.DateUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.ruoyi.business.mapper.BusIntegralHistoryInfoMapper; import com.ruoyi.business.domain.BusIntegralHistoryInfo; import com.ruoyi.business.service.IBusIntegralHistoryInfoService; +import org.springframework.transaction.annotation.Transactional; /** * 帐分历史快照Service业务层处理 @@ -19,6 +32,10 @@ public class BusIntegralHistoryInfoServiceImpl implements IBusIntegralHistoryInf { @Autowired private BusIntegralHistoryInfoMapper busIntegralHistoryInfoMapper; + @Autowired + private BusAgentInfoMapper busAgentInfoMapper; + @Autowired + private BusStoreInfoMapper busStoreInfoMapper; /** * 查询帐分历史快照 @@ -92,4 +109,49 @@ public class BusIntegralHistoryInfoServiceImpl implements IBusIntegralHistoryInf { return busIntegralHistoryInfoMapper.deleteBusIntegralHistoryInfoById(id); } + + /* + * 更新账分表 + * */ + @Override + @Transactional(rollbackFor = ServiceException.class) + public Boolean updateIntegralHistoryInfo() { + boolean flag = false; + try { + BusAgentInfo busAgentInfo = new BusAgentInfo(); + LocalDateTime localDateTime = LocalDateTime.now().minusDays(1); + String dd = localDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); + String startTime = dd+" 00:00:00"; + String endTime = dd+" 23:59:59"; + List list = busAgentInfoMapper.selectBusAgentInfoList(busAgentInfo); + List infoList = list.stream().map(bean -> { + BusIntegralHistoryInfo busIntegralHistoryInfo = new BusIntegralHistoryInfo(); + busIntegralHistoryInfo.setAccount(bean.getAgentAccount()); + busIntegralHistoryInfo.setAccountName(bean.getAgentName()); + busIntegralHistoryInfo.setSuperiorAgentCode(bean.getSuperiorAgentAccount()); + int smsNum = busStoreInfoMapper.lastUserIntegralNum(bean.getAgentAccount(), startTime, endTime,"sms"); + int aiNum = busStoreInfoMapper.lastUserIntegralNum(bean.getAgentAccount(), startTime, endTime,"AI"); + if(smsNum == 0 && aiNum == 0){ + return null; + }else{ + busIntegralHistoryInfo.setIntegralBalance(smsNum); + busIntegralHistoryInfo.setAiIntegralBalance(aiNum); + busIntegralHistoryInfo.setCreateTime(Date.from(localDateTime.atZone(ZoneId.systemDefault()).toInstant())); + // remark + return busIntegralHistoryInfo; + } + }).filter(Objects::nonNull).collect(Collectors.toList()); + if(busIntegralHistoryInfoMapper.insertBatch(infoList) > 0){ + flag = true; + } + }catch (ServiceException e){ + throw new ServiceException("更新失败!"); + } + return flag; + } + + @Override + public List selectBusIntegralHistoryInfoList1(String account, String expStartTime, String expEndTime) { + return busIntegralHistoryInfoMapper.selectBusIntegralHistoryInfoList1(account,expStartTime,expEndTime); + } } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusStoreInfoServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusStoreInfoServiceImpl.java index f0ba224..3ba19c9 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusStoreInfoServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusStoreInfoServiceImpl.java @@ -86,8 +86,8 @@ public class BusStoreInfoServiceImpl implements IBusStoreInfoService } @Override - public int lastUserIntegralNum(String agentAccount,String startTime,String endTime){ - return busStoreInfoMapper.lastUserIntegralNum(agentAccount, startTime, endTime); + public int lastUserIntegralNum(String agentAccount,String startTime,String endTime,String integralType){ + return busStoreInfoMapper.lastUserIntegralNum(agentAccount, startTime, endTime,integralType); } /** diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java index 98b9293..b693a48 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java @@ -609,8 +609,8 @@ public class MeituanServiceImpl implements IMeituanService { code = jsonObject.getString(("code")); } catch (Exception e) { log.error("==============="+orderInfo.getOrderNo()+"承接-隧道代理订单解析号码出错:"+e.getMessage()+"==========转换隧道代理"); - client = proxyHttpClient(); try { + client = proxyHttpClient(); HttpResponse response = client.execute(httpPost); HttpEntity responseEntity = response.getEntity(); String resp = EntityUtils.toString(responseEntity); @@ -618,8 +618,8 @@ public class MeituanServiceImpl implements IMeituanService { code = jsonObject.getString(("code")); }catch (Exception e1) { log.error("==============="+orderInfo.getOrderNo()+"隧道代理订单解析号码出错:" + e1.getMessage() + "===========转换私密代理"); - client = proxyHttpClient2(proxyProperties.getUrl()); try { + client = proxyHttpClient2(proxyProperties.getUrl()); HttpResponse response = client.execute(httpPost); HttpEntity responseEntity = response.getEntity(); String resp = EntityUtils.toString(responseEntity); diff --git a/ruoyi-system/src/main/resources/mapper/business/BusIntegralHistoryInfoMapper.xml b/ruoyi-system/src/main/resources/mapper/business/BusIntegralHistoryInfoMapper.xml index 209c3ff..9a9bcba 100644 --- a/ruoyi-system/src/main/resources/mapper/business/BusIntegralHistoryInfoMapper.xml +++ b/ruoyi-system/src/main/resources/mapper/business/BusIntegralHistoryInfoMapper.xml @@ -35,6 +35,14 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" where id = #{id} + + insert into bus_integral_history_info @@ -57,6 +65,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + + insert into bus_integral_history_info (account,account_name,superior_agent_code,ai_integral_balance,integral_balance,create_time,remark) values + + (#{item.account},#{item.accountName},#{item.superiorAgentCode},#{item.aiIntegralBalance},#{item.integralBalance},#{item.createTime},#{item.remark}) + + + update bus_integral_history_info diff --git a/ruoyi-system/src/main/resources/mapper/business/BusStoreInfoMapper.xml b/ruoyi-system/src/main/resources/mapper/business/BusStoreInfoMapper.xml index 350bf64..38b095b 100644 --- a/ruoyi-system/src/main/resources/mapper/business/BusStoreInfoMapper.xml +++ b/ruoyi-system/src/main/resources/mapper/business/BusStoreInfoMapper.xml @@ -64,8 +64,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"