价格管理

sto/src/main/java/com/shinsoft/sto/controller/main/PriceController.java

@@ -0,0 +1,100 @@
+package com.shinsoft.sto.controller.main;
+
+import com.shinsoft.tools.JSONTools;
+import com.shinsoft.tools.model.common.ResponseCodeMsg;
+import com.shinsoft.tools.model.common.ResultJSON;
+import com.shinsoft.sto.service.main.PriceService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.HashMap;
+import java.util.Map;
+
+@RestController
+@RequestMapping("/Price")
+public class PriceController {
+
+    @Autowired
+    private PriceService priceService;
+
+    ResultJSON resultJSON;
+
+    @RequestMapping(value = "/query")
+    public ResultJSON query(@RequestParam int page,
+                            @RequestParam int rows,
+                            @RequestParam(required = false) String customerName,
+                            @RequestParam(required = false) String materialName,
+                            HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            Map<String, Object> params = new HashMap<>();
+            if (customerName != null) {
+                params.put("customerName", customerName);
+            }
+            if (materialName != null) {
+                params.put("materialName", materialName);
+            }
+            resultJSON = priceService.query(page, rows, params);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        } finally {
+            return resultJSON;
+        }
+    }
+
+    @RequestMapping(value = "/queryByPK")
+    public ResultJSON queryByPK(@RequestParam String id, HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            resultJSON = priceService.queryByPK(id);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        } finally {
+            return resultJSON;
+        }
+    }
+
+    @RequestMapping(value = "/save")
+    public ResultJSON save(@RequestParam String json, HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            resultJSON = priceService.save(userId, json);
+        } catch (Exception ex) {
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+            ex.printStackTrace();
+        } finally {
+            return resultJSON;
+        }
+    }
+
+    @RequestMapping(value = "/remove")
+    public ResultJSON remove(@RequestParam String id, HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            resultJSON = priceService.remove(userId, id);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        } finally {
+            return resultJSON;
+        }
+    }
+
+    @RequestMapping(value = "/removeBatch")
+    public ResultJSON removeBatch(@RequestParam String ids, HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            resultJSON = priceService.removeBatch(userId, ids);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        } finally {
+            return resultJSON;
+        }
+    }
+}

sto/src/main/java/com/shinsoft/sto/mapper/main/PriceMapper.java

@@ -0,0 +1,24 @@
+package com.shinsoft.sto.mapper.main;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.shinsoft.sto.model.main.Price;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+import java.util.Map;
+
+public interface PriceMapper extends BaseMapper<Price> {
+
+    /**
+     * 分页查询价格信息
+     */
+    Page<Price> selectPricePage(Page<Price> page, @Param("params") Map<String, Object> params);
+
+    /**
+     * 根据客户ID查询价格信息
+     */
+    @Select("SELECT * FROM T_MAIN_PRICE WHERE cancel_flag = '0' AND customer_id = #{customerId}")
+    List<Price> selectByCustomerId(String customerId);
+}

sto/src/main/java/com/shinsoft/sto/mapper/main/PriceMapper.xml

@@ -0,0 +1,72 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.shinsoft.sto.mapper.main.PriceMapper">
+
+    <resultMap id="BaseResultMap" type="com.shinsoft.sto.model.main.Price">
+        <id column="id" property="id" jdbcType="VARCHAR"/>
+        <result column="process_instance_id" property="processInstanceId" jdbcType="VARCHAR"/>
+        <result column="process_instance_status" property="processInstanceStatus" jdbcType="VARCHAR"/>
+        <result column="add_id" property="addId" jdbcType="VARCHAR"/>
+        <result column="add_code" property="addCode" jdbcType="VARCHAR"/>
+        <result column="add_name" property="addName" jdbcType="VARCHAR"/>
+        <result column="add_dept_code" property="addDeptCode" jdbcType="VARCHAR"/>
+        <result column="add_dept_name" property="addDeptName" jdbcType="VARCHAR"/>
+        <result column="add_time" property="addTime" jdbcType="TIMESTAMP"/>
+        <result column="modify_id" property="modifyId" jdbcType="VARCHAR"/>
+        <result column="modify_code" property="modifyCode" jdbcType="VARCHAR"/>
+        <result column="modify_name" property="modifyName" jdbcType="VARCHAR"/>
+        <result column="modify_time" property="modifyTime" jdbcType="TIMESTAMP"/>
+        <result column="cancel_id" property="cancelId" jdbcType="VARCHAR"/>
+        <result column="cancel_code" property="cancelCode" jdbcType="VARCHAR"/>
+        <result column="cancel_name" property="cancelName" jdbcType="VARCHAR"/>
+        <result column="cancel_time" property="cancelTime" jdbcType="TIMESTAMP"/>
+        <result column="cancel_flag" property="cancelFlag" jdbcType="VARCHAR"/>
+        <result column="belong_id" property="belongId" jdbcType="VARCHAR"/>
+        <result column="customer_id" property="customerId" jdbcType="VARCHAR"/>
+        <result column="material_id" property="materialId" jdbcType="VARCHAR"/>
+        <result column="storage_price" property="storagePrice" jdbcType="NUMERIC"/>
+        <result column="transfer_price" property="transferPrice" jdbcType="NUMERIC"/>
+        <result column="weight_price" property="weightPrice" jdbcType="NUMERIC"/>
+        <result column="storage_type" property="storageType" jdbcType="VARCHAR"/>
+        <result column="material_name" property="materialName" jdbcType="VARCHAR"/>
+        <result column="keep_day" property="keepDay" jdbcType="NUMERIC"/>
+        <result column="ord_price" property="ordPrice" jdbcType="NUMERIC"/>
+        <result column="out_ord_price" property="outOrdPrice" jdbcType="NUMERIC"/>
+        <result column="pay_way" property="payWay" jdbcType="VARCHAR"/>
+
+        <!-- 关联客户信息 -->
+        <association property="customer" javaType="com.shinsoft.sto.model.main.Customer">
+            <id column="customer_id" property="id"/>
+            <result column="customer_nm" property="customerNm"/>
+            <result column="customer_short_nm" property="customerShortNm"/>
+            <result column="contact_person" property="contactPerson"/>
+            <result column="contact_info" property="contactInfo"/>
+            <result column="default_address" property="defaultAddress"/>
+        </association>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        p.id, p.process_instance_id, p.process_instance_status, p.add_id, p.add_code, p.add_name,
+        p.add_dept_code, p.add_dept_name, p.add_time, p.modify_id, p.modify_code, p.modify_name,
+        p.modify_time, p.cancel_id, p.cancel_code, p.cancel_name, p.cancel_time, p.cancel_flag,
+        p.belong_id, p.customer_id, p.material_id, p.storage_price, p.transfer_price, p.weight_price,
+        p.storage_type, p.material_name, p.keep_day, p.ord_price, p.out_ord_price, p.pay_way,
+        c.customer_nm, c.customer_short_nm, c.contact_person, c.contact_info, c.default_address
+    </sql>
+
+    <select id="selectPricePage" resultMap="BaseResultMap">
+        select
+        <include refid="Base_Column_List"/>
+        from T_MAIN_PRICE p
+        left join T_MAIN_CUSTOMER c on p.customer_id = c.id and c.cancel_flag = '0'
+        where p.cancel_flag = '0'
+        <if test="params.customerName != null and params.customerName != ''">
+            and c.customer_nm like '%' || #{params.customerName} || '%'
+        </if>
+        <if test="params.materialName != null and params.materialName != ''">
+            and p.material_name like '%' || #{params.materialName} || '%'
+        </if>
+        order by p.add_time desc
+    </select>
+
+</mapper>

sto/src/main/java/com/shinsoft/sto/model/main/Price.java

@@ -0,0 +1,62 @@
+package com.shinsoft.sto.model.main;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.shinsoft.generator.model.BaseModel;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.Accessors;
+
+import java.math.BigDecimal;
+
+@Getter
+@Setter
+@Accessors(chain = true)
+@TableName("T_MAIN_PRICE")
+@ApiModel(value = "价格管理", description = "价格管理信息表")
+public class Price extends BaseModel {
+
+    @ApiModelProperty("所属ID")
+    private String belongId;
+
+    @ApiModelProperty("客户ID")
+    private String customerId;
+
+    @ApiModelProperty("物料ID")
+    private String materialId;
+
+    @ApiModelProperty("仓储出库单价(元/吨)")
+    private BigDecimal storagePrice;
+
+    @ApiModelProperty("货权转移单价(元/吨)")
+    private BigDecimal transferPrice;
+
+    @ApiModelProperty("过磅称重单价(元/吨)")
+    private BigDecimal weightPrice;
+
+    @ApiModelProperty("仓储类型")
+    private String storageType;
+
+    @ApiModelProperty("物料名称")
+    private String materialName;
+
+    @ApiModelProperty("保存天数")
+    private Integer keepDay;
+
+    @ApiModelProperty("小于保存天数的价格")
+    private BigDecimal ordPrice;
+
+    @ApiModelProperty("大于保存天数的价格")
+    private BigDecimal outOrdPrice;
+
+    @ApiModelProperty("支付方式")
+    private String payWay;
+
+    // 关联客户信息
+    @TableField(exist = false)
+    @ApiModelProperty("客户信息")
+    private Customer customer;
+}

sto/src/main/java/com/shinsoft/sto/service/impl/main/PriceServiceImp.java

@@ -0,0 +1,126 @@
+package com.shinsoft.sto.service.impl.main;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.TypeReference;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.shinsoft.sto.mapper.main.PriceMapper;
+import com.shinsoft.sto.model.main.Price;
+import com.shinsoft.sto.service.main.PriceService;
+import com.shinsoft.tools.JSONTools;
+import com.shinsoft.tools.model.common.ResponseCodeMsg;
+import com.shinsoft.tools.model.common.ResultJSON;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+ * 价格管理 服务实现类
+ * </p>
+ *
+ * @author system
+ * @since 2024-10-15
+ */
+@Service
+public class PriceServiceImp extends ServiceImpl<PriceMapper, Price> implements PriceService {
+
+    ResultJSON resultJSON;
+
+    @Autowired
+    PriceMapper priceMapper;
+
+    @Override
+    public ResultJSON query(int page, int rows, Map<String, Object> params) {
+        try {
+            Page<Price> pricePage = new Page<>(page, rows);
+            Page<Price> list = priceMapper.selectPricePage(pricePage, params);
+            resultJSON = JSONTools.toResultJSON(list);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        }
+        return resultJSON;
+    }
+
+    @Override
+    public ResultJSON queryByPK(String id) {
+        try {
+            Price price = priceMapper.selectById(id);
+            resultJSON = JSONTools.toResultJSON(price);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        }
+        return resultJSON;
+    }
+
+    @Override
+    public ResultJSON save(String userId, String json) {
+        try {
+            Date date = new Date();
+            Price price = JSON.parseObject(json, new TypeReference<Price>() {});
+
+            if (StringUtils.isEmpty(price.getId())) {
+                price.setCancelFlag("0");
+                price.setAddId(userId);
+                price.setAddTime(date);
+                priceMapper.insert(price);
+            } else {
+                price.setModifyId(userId);
+                price.setModifyTime(date);
+                priceMapper.updateById(price);
+            }
+
+            resultJSON = JSONTools.toResultJSON(price);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        }
+        return resultJSON;
+    }
+
+    @Override
+    public ResultJSON remove(String userId, String id) {
+        try {
+            Date date = new Date();
+            Price price = priceMapper.selectById(id);
+            price.setCancelFlag("1");
+            price.setModifyId(userId);
+            price.setModifyTime(date);
+            priceMapper.updateById(price);
+            resultJSON = JSONTools.toResultJSON("");
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        }
+        return resultJSON;
+    }
+
+    @Override
+    public ResultJSON removeBatch(String userId, String ids) {
+        try {
+            Date date = new Date();
+            List<String> list = JSON.parseObject(ids, new TypeReference<List<String>>() {});
+            Price price;
+            for (String id : list) {
+                price = priceMapper.selectById(id);
+                price.setCancelFlag("1");
+                price.setModifyId(userId);
+                price.setModifyTime(date);
+                priceMapper.updateById(price);
+            }
+            resultJSON = JSONTools.toResultJSON("");
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        }
+        return resultJSON;
+    }
+}

sto/src/main/java/com/shinsoft/sto/service/main/PriceService.java

@@ -0,0 +1,28 @@
+package com.shinsoft.sto.service.main;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.shinsoft.sto.model.main.Price;
+import com.shinsoft.tools.model.common.ResultJSON;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 价格管理 服务类
+ * </p>
+ *
+ * @author system
+ * @since 2024-10-15
+ */
+public interface PriceService extends IService<Price> {
+
+    ResultJSON query(int page, int rows, Map<String, Object> params);
+
+    ResultJSON queryByPK(String id);
+
+    ResultJSON save(String userId, String json);
+
+    ResultJSON remove(String userId, String id);
+
+    ResultJSON removeBatch(String userId, String ids);
+}