财务

cif-service/src/main/java/com/txz/cif/web/UserApiController.java

@@ -152,30 +152,6 @@ public class UserApiController extends AbstractApiController {
         return ResultGenerator.genSuccessResult(authService.getClaimsFromToken(authentication));
     }
 
-    /**
-     * 设置操作员TOKEN
-     *
-     * @param operator
-     * @return
-     */
-    private User setOperatorToken(User operator, Integer dateTime,Long userId) {
-        // 删掉之前的老token
-        String lastToken = operator.getLastToken();
-        if (StrUtil.isNotEmpty(lastToken)) {
-            redisUtil.del(lastToken);
-        }
-        String token = authService.buildJwtToken( userId);
-        //设置redis缓存1小时
-        if (dateTime == null) {
-            dateTime = 7;
-        }
-        operator.setPwd("***");
-        operator.setSalt("***");
-        operator.setLastToken(token);
-        userService.update(User.builder().id(operator.getId()).lastToken(token).lastLoginTime(
-                DateUtil.date()).build());
-        return operator;
-    }
 
     @ApiOperation(value = "获取验证码", notes = "",httpMethod = "GET")
     @GetMapping("/getCode")
@@ -199,6 +175,7 @@ public class UserApiController extends AbstractApiController {
     @ApiOperation(value = "查询用户资料", notes = "",httpMethod = "GET")
     @GetMapping("/getUserInfo")
     public Result<UserInfoBO> getUserInfo(HttpServletRequest request) {
+
         Long userId = authService.getTokenUserId(request);
         if (userId == null ){
             ResultGenerator.genFailResult(ResultCode.OAUTH_INVALID_ACCESS_TOKEN);

cif-service/src/main/java/com/txz/cif/web/mng/SubjectController.java

@@ -0,0 +1,239 @@
+package com.txz.cif.web.mng;
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONUtil;
+import cn.hutool.poi.excel.ExcelUtil;
+import cn.hutool.poi.excel.ExcelWriter;
+import com.txz.cif.core.Result;
+import com.txz.cif.model.DayCut;
+import com.txz.cif.model.Subject;
+import com.txz.cif.service.DayCutService;
+import com.txz.cif.service.SubjectService;
+import com.txz.cif.web.bo.AccountBO;
+import com.txz.cif.web.bo.SubjectBO;
+import com.txz.cif.web.para.AccountListParam;
+import com.txz.cif.web.para.InnerAccountParam;
+import com.txz.cif.web.para.RechargeForm;
+import com.txz.cif.web.para.SubjectListParam;
+import com.txz.cif.core.ResultGenerator;
+import com.txz.cif.model.Account;
+import com.txz.cif.service.AccountService;
+
+import com.txz.cif.core.ResultCode;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import com.txz.core.ServiceException;
+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 javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletResponse;
+import java.math.BigDecimal;
+import java.util.*;
+import java.util.stream.Collectors;
+
+import org.apache.commons.lang.StringUtils;
+
+/**
+* Created by CodeGenerator on 2022/11/04.
+*/
+@Api(tags = "[后台]科目管理")
+@RestController
+@RequestMapping("/subject")
+public class SubjectController {
+
+	private static Logger log = LoggerFactory.getLogger(SubjectController.class);
+
+	@Resource
+	private SubjectService subjectService;
+
+	@Resource
+	private DayCutService dayCutService;
+
+    @PostMapping("/list")
+	@ApiOperation(value = "获取科目列表",httpMethod = "POST")
+    public Result<List<SubjectBO>> list(@Validated @RequestBody SubjectListParam param) {
+		if (param.getStartTime().length()>10){
+			param.setStartTime(param.getStartTime().substring(0,9));
+		}
+		if (param.getEndTime().length()>10){
+			param.setEndTime(param.getEndTime().substring(0,9));
+		}
+		Date endTime = DateUtil.parse(param.getEndTime(),"yyyy-MM-DD");
+		if (endTime.after(DateUtil.yesterday())){
+			return ResultGenerator.genFailResult(ResultCode.ENDTIME_ERROR);
+		}
+		try {
+			List<Subject> subjects = subjectService.findAll();
+			if (CollUtil.isEmpty(subjects)){
+				return ResultGenerator.genSuccessResult(CollUtil.newArrayList());
+			}
+			List<SubjectBO> list = new ArrayList<>();
+			for (Subject subject:subjects) {
+				SubjectBO bo = BeanUtil.toBean(subject,SubjectBO.class);
+				bo.setSubjectId(subject.getId());
+				if (subject.getLeaf() == 1){
+					//设置初始日余额、日余额、借方发生额、贷方发生额
+					DayCut startDayCut = dayCutService.findByDayAndSubjectId(param.getStartTime(),subject.getId());
+					if (startDayCut == null){
+						startDayCut = DayCut.builder().initAmount(BigDecimal.ZERO).build();
+					}
+					bo.setInitAmount(startDayCut.getInitAmount());
+					DayCut endDayCut = dayCutService.findByDayAndSubjectId(param.getEndTime(),subject.getId());
+					if (endDayCut == null){
+						endDayCut = DayCut.builder().initAmount(BigDecimal.ZERO).build();
+					}
+					bo.setEndAmount(endDayCut.getEndAmount());
+					bo.setDebitAmount(dayCutService.sumAmount(subject.getId(),"D",param.getStartTime(),param.getEndTime()));
+					bo.setCreditAmount(dayCutService.sumAmount(subject.getId(),"C",param.getStartTime(),param.getEndTime()));
+				}
+				list.add(bo);
+			}
+			Map<String, SubjectBO> map = assembling(list);
+			List<SubjectBO> ret = CollUtil.newArrayList(map.get("1"),map.get("2"),map.get("3"),map.get("4"));
+			return ResultGenerator.genSuccessResult(ret);
+
+		} catch (Exception e) {
+			log.error("查询对象操作异常e:{}",e);
+			return ResultGenerator.genFailResult(ResultCode.INTERNAL_SERVER_ERROR);
+		}
+
+    }
+
+	/**
+	 * 组装树结构
+	 * @param list
+	 * @return
+	 */
+	private Map<String, SubjectBO> assembling(List<SubjectBO> list) {
+		Map<String, SubjectBO> temp = new HashMap(list.size());
+		for (SubjectBO subject:list) {
+			//存入自己
+			temp.put(subject.getSubjectId()+"",subject);
+		}
+		for (SubjectBO subject:list) {
+			//寻找父亲
+			SubjectBO parent = temp.get(subject.getParentId()+"");
+			if (parent == null){
+				continue;
+			}
+			if (CollUtil.isEmpty(parent.getChildren())){
+				parent.setChildren(CollUtil.newArrayList(subject));
+			} else {
+				parent.getChildren().add(subject);
+			}
+		}
+		return temp;
+	}
+
+
+	@GetMapping("/export")
+	@ApiOperation(value = "导出",httpMethod = "GET")
+	public void export( SubjectListParam param, HttpServletResponse response) {
+		ExcelWriter writer = ExcelUtil.getWriter();
+		try {
+			/**
+			 */
+			String head = "账务数据";
+			List<List<Object>> rows = new LinkedList<>();
+			try {
+				if (param.getStartTime().length()>10){
+					param.setStartTime(param.getStartTime().substring(0,9));
+				}
+				if (param.getEndTime().length()>10){
+					param.setEndTime(param.getEndTime().substring(0,9));
+				}
+				Date endTime = DateUtil.parse(param.getEndTime(),"yyyy-MM-DD");
+				if (endTime.after(DateUtil.yesterday())){
+					return ;
+				}
+				head = param.getStartTime()+"-"+param.getEndTime()+head;
+				List<Subject> subjects = subjectService.findAll();
+				if (CollUtil.isEmpty(subjects)){
+					return ;
+				}
+				List<SubjectBO> list = new ArrayList<>();
+				for (Subject subject:subjects) {
+					SubjectBO bo = BeanUtil.toBean(subject,SubjectBO.class);
+					bo.setSubjectId(subject.getId());
+					if (subject.getLeaf() == 1){
+						//设置初始日余额、日余额、借方发生额、贷方发生额
+						DayCut startDayCut = dayCutService.findByDayAndSubjectId(param.getStartTime(),subject.getId());
+						if (startDayCut == null){
+							startDayCut = DayCut.builder().initAmount(BigDecimal.ZERO).build();
+						}
+						bo.setInitAmount(startDayCut.getInitAmount());
+						DayCut endDayCut = dayCutService.findByDayAndSubjectId(param.getEndTime(),subject.getId());
+						if (endDayCut == null){
+							endDayCut = DayCut.builder().endAmount(BigDecimal.ZERO).build();
+						}
+						bo.setEndAmount(endDayCut.getEndAmount());
+						bo.setDebitAmount(dayCutService.sumAmount(subject.getId(),"D",param.getStartTime(),param.getEndTime()));
+						bo.setCreditAmount(dayCutService.sumAmount(subject.getId(),"C",param.getStartTime(),param.getEndTime()));
+					}
+					list.add(bo);
+				}
+				Map<String, SubjectBO> map = assembling(list);
+				List<SubjectBO> ret = CollUtil.newArrayList(map.get("1"),map.get("2"),map.get("3"),map.get("4"));
+
+				for (SubjectBO temp:ret) {
+					List<Object> rowA = CollUtil.newArrayList(temp.getAliases()
+							, temp.getName()
+							, temp.getDirection()
+							, temp.getInitAmount().toPlainString()
+							, temp.getDebitAmount().toPlainString()
+							, temp.getCreditAmount().toPlainString()
+							, temp.getEndAmount().toPlainString()
+					);
+					rows.add(rowA);
+					if (CollUtil.isNotEmpty(temp.getChildren())){
+						for (SubjectBO temp2:temp.getChildren()) {
+							List<Object> rowA2 = CollUtil.newArrayList(temp2.getAliases()
+									, temp2.getName()
+									, temp2.getDirection()
+									, temp2.getInitAmount().toPlainString()
+									, temp2.getDebitAmount().toPlainString()
+									, temp2.getCreditAmount().toPlainString()
+									, temp2.getEndAmount().toPlainString()
+							);
+							rows.add(rowA2);
+						}
+					}
+				}
+			} catch (Exception e) {
+				log.error("查询对象操作异常e:{}",e);
+				return ;
+			}
+			List<String> rowHead = CollUtil.newArrayList("科目别名", "科目", "余额方向", "初始日余额",
+					"借方发生额","贷方发生额","日余额");
+			writer.writeHeadRow(rowHead);
+			writer.write(rows);
+			//设置宽度自适应
+			writer.setColumnWidth(-1, 22);
+			//response为HttpServletResponse对象
+			response.setContentType("application/vnd.ms-excel;charset=utf-8");
+			//test.xls是弹出下载对话框的文件名，不能为中文，中文请自行编码
+			response.setHeader("Content-Disposition", "attachment;filename=" + new String((head).getBytes("UTF-8"), "ISO-8859-1") + ".xls");
+			ServletOutputStream out = response.getOutputStream();
+			//out为OutputStream，需要写出到的目标流
+			writer.flush(out);
+		} catch (Exception e) {
+			log.error("导出异常",e);
+			e.printStackTrace();
+		} finally {
+			// 关闭writer，释放内存
+			writer.close();
+		}
+	}
+}