| | |
| | | import com.dy.common.mw.protocol.Data; |
| | | import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1; |
| | | import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd83CloseVo; |
| | | import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd83OpenVo; |
| | | import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd84Vo; |
| | | import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCdC0Vo; |
| | | import com.dy.common.util.DateTime; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrController; |
| | | import com.dy.pipIrrGlobal.pojoRm.RmClientAmountDay; |
| | | import com.dy.pipIrrGlobal.pojoRm.RmClientAmountDayLast; |
| | | import com.dy.pipIrrGlobal.pojoRm.RmIntakeAmountDay; |
| | | import com.dy.pipIrrGlobal.pojoRm.RmIntakeAmountDayLast; |
| | | import com.dy.pipIrrGlobal.pojoSe.SeClient; |
| | | import com.dy.rtuMw.server.rtuData.TaskSurpport; |
| | | import com.dy.rtuMw.server.rtuData.dbSv.DbSv; |
| | |
| | | poHistory = this.updateRmClientAmountBySameDateNewData(clientVo, poHistory, poLast, dV1_0_1, cdData); |
| | | sv.updateRmClientAmountDay(poHistory); |
| | | } |
| | | sv.saveRmClientAmountLast(poLast); |
| | | }else if(upYmd.after(poLast.dt)){ |
| | | //新的日期 |
| | | poLast = this.updateRmClientAmountLastByNewDateNewData(clientVo, dV1_0_1, cdData, poLast); |
| | | this.newAndSaveHistoryDataDeal(sv, clientVo, dV1_0_1, cdData, poLast); |
| | | sv.saveRmClientAmountLast(poLast); |
| | | }else{ |
| | | //这种情况不存在 |
| | | } |
| | |
| | | RmClientAmountDay poHistory = new RmClientAmountDay() ; |
| | | poHistory.clientId = clientVo.getId(); |
| | | if(lastPo != null){ |
| | | poHistory.amount += lastPo.amount ; |
| | | poHistory.money += lastPo.money ; |
| | | if(poHistory.amount != null){ |
| | | poHistory.amount += lastPo.amount ; |
| | | }else{ |
| | | poHistory.amount = lastPo.amount ; |
| | | } |
| | | if(poHistory.money != null){ |
| | | poHistory.money += lastPo.money ; |
| | | }else{ |
| | | poHistory.money = lastPo.money ; |
| | | } |
| | | poHistory.dt = lastPo.dt ; |
| | | poHistory.openDtLast = lastPo.openDtLast ; |
| | | poHistory.closeDtLast = lastPo.closeDtLast ; |
| | |
| | | */ |
| | | private RmClientAmountDay updateRmClientAmountBySameDateNewData(SeClient clientVo, RmClientAmountDay poHistory, RmClientAmountDayLast lastPo, DataV1_0_1 dV1_0_1, DataCd83CloseVo cdData)throws Exception { |
| | | poHistory.clientId = clientVo.getId(); |
| | | poHistory.amount += lastPo.amount ; |
| | | poHistory.money += lastPo.money ; |
| | | if(poHistory.amount != null){ |
| | | poHistory.amount += cdData.thisAmount ; |
| | | }else{ |
| | | poHistory.amount = cdData.thisAmount ; |
| | | } |
| | | if(poHistory.money != null){ |
| | | poHistory.money += cdData.thisMoney ; |
| | | }else{ |
| | | poHistory.money = cdData.thisMoney ; |
| | | } |
| | | poHistory.dt = lastPo.dt ; |
| | | poHistory.openDtLast = lastPo.openDtLast ; |
| | | poHistory.closeDtLast = lastPo.closeDtLast ; |