手动更新日期数据

operating-service/src/main/java/com/txz/operating/controller/ManualController.java

@@ -0,0 +1,66 @@
+package com.txz.operating.controller;
+import cn.hutool.core.collection.CollUtil;
+
+import com.txz.operating.core.ResultCode;
+import com.txz.operating.core.ResultGenerator;
+import com.txz.operating.model.Dimension;
+import com.txz.operating.result.Result;
+import com.txz.operating.service.*;
+import org.springframework.web.bind.annotation.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+
+import tk.mybatis.mapper.entity.Condition;
+import tk.mybatis.mapper.entity.Example.Criteria;
+
+import javax.annotation.Resource;
+import java.util.List;
+import org.apache.commons.lang.StringUtils;
+
+/**
+* Created by CodeGenerator on 2020/01/07.
+*/
+@Api(tags = "[手动]统计")
+@RestController
+@RequestMapping("/manual")
+public class ManualController {
+
+	private static Logger log = LoggerFactory.getLogger(ManualController.class);
+
+    @Resource
+    private DimensionService dimensionService;
+    @GetMapping("/statistics")
+	@ApiOperation(value = "统计",httpMethod = "GET")
+    public Result statistics(@RequestParam String time, @RequestParam(required = false) Integer dimensionId
+			, @RequestParam(required = false) Long sectionId) {
+    	if(StringUtils.isBlank(time)){
+    		return ResultGenerator.genFailResult(ResultCode.OBJECT_IS_NULL);
+    	}
+    	try {
+			Condition condition = new Condition(Dimension.class);
+			Criteria c = condition.createCriteria().andEqualTo("status",1).andEqualTo("interType",6);
+			if (dimensionId != null){
+				c.andEqualTo("id",dimensionId);
+			}
+			List<Dimension> dimensions = dimensionService.findByCondition(condition);
+			if (CollUtil.isNotEmpty(dimensions)){
+				for (Dimension dimension:dimensions) {
+					try{
+						dimensionService.execute(dimension,time,sectionId);
+					}catch (Exception e){
+						log.error("generalReportJob.dimensionId:"+dimension.getId()+"异常：",e);
+					}
+				}
+			}
+		} catch (Exception e) {
+			log.error("新增对象操作异常e:{}",e);
+			return ResultGenerator.genFailResult(ResultCode.INTERNAL_SERVER_ERROR);
+		}
+
+        return ResultGenerator.genSuccessResult();
+    }
+
+
+}