package com.doumee.api; import com.alibaba.fastjson.JSONObject; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.model.ApiResponse; import com.doumee.core.utils.Constants; import com.doumee.core.utils.HttpsUtil; import com.doumee.core.utils.redis.RedisUtil; import com.doumee.core.wx.WXConstant; import com.doumee.dao.business.model.YwContract; import com.doumee.dao.business.model.YwOutinbound; import com.doumee.service.business.*; import com.doumee.service.business.impl.YwOutinboundServiceImpl; import com.doumee.service.system.SystemDictDataService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /** * Created by IntelliJ IDEA. * * @Author : Rk * @create 2024/11/28 10:58 */ @Api(tags = "阜宁运维系统定时器接口") @RestController @RequestMapping("/timer/yw") public class YwTimerController extends BaseController { @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private SystemDictDataService systemDictDataService; @Autowired private YwContractBillService ywContractBillService; @Autowired private YwContractService ywContractService; @Autowired private YwPatrolSchemeService ywPatrolSchemeService; @Autowired private YwOutinboundService ywOutinboundService; @Autowired private RedisTemplate redisTemplate; @ApiOperation("定时处理合同账单编码") @GetMapping("/ywDealContractBillCodeTimer") public ApiResponse ywDealContractBillCodeTimer() { ywContractBillService.dealDayBillCode(); return ApiResponse.success("定时处理合同账单编码"); } @ApiOperation("定时处理合同过期与执行中") @GetMapping("/ywDealContractTimeOutTimer") public ApiResponse ywDealContractTimeOutTimer() { ywContractService.dealTimeOut(); return ApiResponse.success("定时处理合同过期与执行中"); } public static void main(String[] args) { String url = WXConstant.GET_ACCESS_TOKEN_URL.replace("APPID","wx95ac1efb67f0330d") .replace("APPSECRET","f228b9e3b49a37b881b51431a483c939"); String response = HttpsUtil.get(url,false); JSONObject json = JSONObject.parseObject(response); } @ApiOperation("定时生成今日巡检任务任务") @GetMapping("/ywPatrolSchemeTaskTimer") public ApiResponse ywPatrolSchemeTaskTimer() { ywPatrolSchemeService.timerAuto(); return ApiResponse.success("定时生成今日巡检任务任务执行中"); } @ApiOperation("定时更新房源租赁状态") @GetMapping("/ywRoomStatusTimer") public ApiResponse ywRoomStatusTimer() { ywContractService.updRentContractStatus(); ywContractService.updRoomLeaseNowStatus(); return ApiResponse.success("定时更新房源租赁状态任务执行中"); } @ApiOperation("定时更新redis数据") @GetMapping("/ywUpdRedisDataTimer") public ApiResponse ywUpdRedisDataTimer() { //加入redis缓存,入库单总数量 RedisUtil.addObject(redisTemplate, Constants.RedisKeys.COM_OUTBOUND_IN_KEY,0); //加入redis缓存,出库单总数量 RedisUtil.addObject(redisTemplate,Constants.RedisKeys.COM_OUTBOUND_OUT_KEY,0); //加入redis缓存,盘点单总数量 RedisUtil.addObject(redisTemplate,Constants.RedisKeys.COM_OUTBOUND_TAKING_KEY,0); return ApiResponse.success("定时更新redis数据"); } }